diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/common/publish/BussEventMulticaster.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/common/publish/BussEventMulticaster.java index 1867ee56..14a5029f 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/common/publish/BussEventMulticaster.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/common/publish/BussEventMulticaster.java @@ -30,7 +30,7 @@ public class BussEventMulticaster implements BeanPostProcessor { if (sync){ String result= listener.doEvent(event); if (event.getCallback() !=null && result !=null){ - event.getCallback().accept(result,null); + event.getCallback().accept(result); }; }else { //TODO:异步回调 diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/GroupDickInStorageTask.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/GroupDickInStorageTask.java index 8873d2fd..0e39f592 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/GroupDickInStorageTask.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/GroupDickInStorageTask.java @@ -77,7 +77,8 @@ public class GroupDickInStorageTask extends AbstractTask { if (execution == null){ throw new BadRequestException("申请任务失败:载具"+vehicle_code+"任务流程信息不存在"+currentInstId); } - BussEventMulticaster.Publish(new FlowContinueEvent(currentInstId,null , new JSONObject(MapOf.of("start_point", point_code1)))); + FlowContinueEvent continueEvent = new FlowContinueEvent(currentInstId, null, new JSONObject(MapOf.of("start_point", point_code1))); + BussEventMulticaster.Publish(continueEvent); }else { BussEventMulticaster.Publish( new FlowStartEvent("md_group", @@ -87,7 +88,10 @@ public class GroupDickInStorageTask extends AbstractTask { .build("md_pb_vehicleMater",item) ); } - //执行流程// + //流程创建完毕,更新组盘信息为完成 + iMdGruopDickService.update(new UpdateWrapper() + .set("status", StatusEnum.FORM_STATUS.code("完成")) + .eq("vehicle_code", vehicle_code)); } return null; } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/execution/impl/FlowOperationServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/execution/impl/FlowOperationServiceImpl.java index 4718ceb3..610291b6 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/execution/impl/FlowOperationServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/execution/impl/FlowOperationServiceImpl.java @@ -114,6 +114,10 @@ public class FlowOperationServiceImpl implements IFlowOperationService { entity.setProc_inst_id(execution.getProc_inst_id()); entity.setParent_id(execution.getParent_id()); entity.setAuxParam(execution.getAux_param()); + //手动添加扩展数据 + if (!CollectionUtils.isEmpty(auxParam)){ + entity.getAuxParam().putAll(auxParam); + } entity.setForm_type(execution.getForm_type()); entity.setForm_id(execution.getForm_id()); entity.setStartActivityId(execution.getActivity_id());