|
|
|
@ -150,7 +150,7 @@ public class SpsSyncExportStatusController {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@AuthRuleAnnotation("")
|
|
|
|
|
@PostMapping("/spssync/basic/udiinfo/finishTask")
|
|
|
|
|
@PostMapping("/spssync/udiinfo/finishTask")
|
|
|
|
|
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
|
|
|
|
|
public BaseResponse finishTask(@RequestBody BasicExportStatusEntity basicExportStatusEntity) {
|
|
|
|
|
|
|
|
|
@ -176,6 +176,31 @@ public class SpsSyncExportStatusController {
|
|
|
|
|
return ResultVOUtils.error(500, "更新成功!");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@AuthRuleAnnotation("")
|
|
|
|
|
@PostMapping("/spssync/udiinfo/receiveTask")
|
|
|
|
|
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
|
|
|
|
|
public BaseResponse receiveTask(@RequestBody BasicExportStatusEntity basicExportStatusEntity) {
|
|
|
|
|
|
|
|
|
|
if (StrUtil.isBlank(basicExportStatusEntity.getId())) {
|
|
|
|
|
return ResultVOUtils.error(500, "缺少唯一标识!");
|
|
|
|
|
}
|
|
|
|
|
if (StrUtil.isEmpty(basicExportStatusEntity.getReceiveStatus())) {
|
|
|
|
|
basicExportStatusEntity.setEndTime(new Date());
|
|
|
|
|
}
|
|
|
|
|
basicExportStatusEntity.setUpdateTime(new Date());
|
|
|
|
|
basicExportStatusEntity.setStatus(BasicExportStatusEnum.COMPLETED.getCode());
|
|
|
|
|
boolean b = basicExportService.update(Wrappers.lambdaUpdate(BasicExportStatusEntity.class)
|
|
|
|
|
.set(BasicExportStatusEntity::getUpdateTime, new Date())
|
|
|
|
|
.set(BasicExportStatusEntity::getReceiveStatus, 1)
|
|
|
|
|
.eq(BasicExportStatusEntity::getId, basicExportStatusEntity.getId())
|
|
|
|
|
.eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.COMPLETED.getCode())
|
|
|
|
|
);
|
|
|
|
|
if (b)
|
|
|
|
|
return ResultVOUtils.success("更新成功!");
|
|
|
|
|
else
|
|
|
|
|
return ResultVOUtils.error(500, "更新成功!");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@AuthRuleAnnotation("")
|
|
|
|
|
@GetMapping("/spssync/basic/schedule/lastTime")
|
|
|
|
|