|
@@ -126,13 +126,16 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
log.info("任务回调执行取消:" + JSON.toJSONString(event));
|
|
log.info("任务回调执行取消:" + JSON.toJSONString(event));
|
|
taskBean.setAciIndex(Integer.parseInt(event.getLp1()));
|
|
taskBean.setAciIndex(Integer.parseInt(event.getLp1()));
|
|
taskBean = amsTaskService.selectAmsTaskByModel(taskBean);
|
|
taskBean = amsTaskService.selectAmsTaskByModel(taskBean);
|
|
- taskBean.setEvent(eventId);
|
|
|
|
- taskBean.setServerAck(0);
|
|
|
|
- taskBean.setAciAccept(1);
|
|
|
|
- taskBean.setRoadway("任务回调执行取消");
|
|
|
|
- taskBean.setSystemStatus(null);
|
|
|
|
- taskBean.setIsDelete(null);
|
|
|
|
- amsTaskService.updateAmsTask(taskBean);
|
|
|
|
|
|
+
|
|
|
|
+ AmsTask taskBeanUpdate = new AmsTask();
|
|
|
|
+ taskBeanUpdate.setId(taskBean.getId());
|
|
|
|
+ taskBeanUpdate.setEvent(eventId);
|
|
|
|
+ taskBeanUpdate.setServerAck(0);
|
|
|
|
+ taskBeanUpdate.setAciAccept(1);
|
|
|
|
+ taskBeanUpdate.setRoadway("任务回调执行取消");
|
|
|
|
+ taskBeanUpdate.setSystemStatus(null);
|
|
|
|
+ taskBeanUpdate.setIsDelete(null);
|
|
|
|
+ amsTaskService.updateAmsTask(taskBeanUpdate);
|
|
//任务状态回调
|
|
//任务状态回调
|
|
statusUpdateService.updateStatus(taskBean.getId().longValue(), icarNo);
|
|
statusUpdateService.updateStatus(taskBean.getId().longValue(), icarNo);
|
|
break;
|
|
break;
|
|
@@ -151,11 +154,13 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
taskBean.setAciIndex(Integer.parseInt(event.getLp1()));
|
|
taskBean.setAciIndex(Integer.parseInt(event.getLp1()));
|
|
taskBean = amsTaskService.selectAmsTaskByModel(taskBean);
|
|
taskBean = amsTaskService.selectAmsTaskByModel(taskBean);
|
|
|
|
|
|
- taskBean.setEvent(eventId);
|
|
|
|
- taskBean.setServerAck(0);
|
|
|
|
- taskBean.setSystemStatus(null);
|
|
|
|
- taskBean.setIsDelete(null);
|
|
|
|
- amsTaskService.updateAmsTask(taskBean);
|
|
|
|
|
|
+ AmsTask taskBeanUpdate01 = new AmsTask();
|
|
|
|
+ taskBeanUpdate01.setId(taskBean.getId());
|
|
|
|
+ taskBeanUpdate01.setEvent(eventId);
|
|
|
|
+ taskBeanUpdate01.setServerAck(0);
|
|
|
|
+ taskBeanUpdate01.setSystemStatus(null);
|
|
|
|
+ taskBeanUpdate01.setIsDelete(null);
|
|
|
|
+ amsTaskService.updateAmsTask(taskBeanUpdate01);
|
|
|
|
|
|
statusUpdateService.updateStatus(taskBean.getId().longValue(), icarNo);
|
|
statusUpdateService.updateStatus(taskBean.getId().longValue(), icarNo);
|
|
break;
|
|
break;
|