代码更新

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/OutTask.java

@@ -42,23 +42,48 @@ public class OutTask extends AbstractAcsTask {
         /*
          * 下发给ACS时需要特殊处理
          */
-        JSONArray arr = WQLObject.getWQLObject("SCH_BASE_Task").query("handle_class = '" + THIS_CLASS + "' and task_status = '" + TaskStatusEnum.START_AND_POINT.getCode() + "' and is_delete ='0' order by sort_seq ASC").getResultJSONArray(0);
+        //任务表
+        WQLObject wo_Task = WQLObject.getWQLObject("SCH_BASE_Task");
+
+        JSONArray arr = WQLObject.getWQLObject("SCH_BASE_Task").query("handle_class = '" + THIS_CLASS + "' and task_status = '" + TaskStatusEnum.START_AND_POINT.getCode() + "' and is_delete ='0'").getResultJSONArray(0);
 
         ArrayList<AcsTaskDto> resultList = new ArrayList<>();
         for (int i = 0; i < arr.size(); i++) {
             JSONObject json = arr.getJSONObject(i);
 
-            AcsTaskDto dto = AcsTaskDto.builder()
+            // 1.查询此任务是否有任务组
-                    .ext_task_id(json.getString("task_id"))
+            if (ObjectUtil.isEmpty(json.getString("task_group_id"))) {
-                    .task_code(json.getString("task_code"))
+                AcsTaskDto dto = AcsTaskDto.builder()
-                    .task_type(json.getString("acs_task_type"))
+                        .ext_task_id(json.getString("task_id"))
-                    .start_device_code(json.getString("point_code1"))
+                        .task_code(json.getString("task_code"))
-                    .next_device_code(json.getString("point_code2"))
+                        .task_type(json.getString("acs_task_type"))
-                    .vehicle_code(json.getString("vehicle_code"))
+                        .start_device_code(json.getString("point_code1"))
-                    .priority(json.getString("priority"))
+                        .next_device_code(json.getString("point_code2"))
-                    .remark(json.getString("remark"))
+                        .vehicle_code(json.getString("vehicle_code"))
-                    .build();
+                        .priority(json.getString("priority"))
-            resultList.add(dto);
+                        .remark(json.getString("remark"))
+                        .build();
+                resultList.add(dto);
+            } else {
+                // 2.有任务组：按照执行顺序下发 大到小
+                JSONArray taskArr = wo_Task.query("task_group_id = '" + json.getString("task_group_id") + "' order by sort_seq DESC").getResultJSONArray(0);
+
+                for (int j = 0; j < taskArr.size(); j++) {
+                    JSONObject json2 = taskArr.getJSONObject(j);
+
+                    AcsTaskDto dto = AcsTaskDto.builder()
+                            .ext_task_id(json2.getString("task_id"))
+                            .task_code(json2.getString("task_code"))
+                            .task_type(json2.getString("acs_task_type"))
+                            .start_device_code(json2.getString("point_code1"))
+                            .next_device_code(json2.getString("point_code2"))
+                            .vehicle_code(json2.getString("vehicle_code"))
+                            .priority(json2.getString("priority"))
+                            .remark(json2.getString("remark"))
+                            .build();
+                    resultList.add(dto);
+                }
+            }
         }
         return resultList;
     }

lms/nladmin-system/src/main/java/org/nl/wms/st/outbill/service/impl/CheckOutBillServiceImpl.java

@@ -27,6 +27,7 @@ import org.nl.wms.basedata.st.service.impl.UserStorServiceImpl;
 import org.nl.wms.ext.mes.service.impl.LmsToMesServiceImpl;
 import org.nl.wms.ext.sap.service.impl.LmsToSapServiceImpl;
 import org.nl.wms.pda.mps.eum.RegionTypeEnum;
+import org.nl.wms.sch.AcsTaskDto;
 import org.nl.wms.sch.manage.TaskStatusEnum;
 import org.nl.wms.sch.tasks.OutTask;
 import org.nl.wms.st.inbill.service.CheckOutBillService;
@@ -2465,16 +2466,62 @@ public class CheckOutBillServiceImpl implements CheckOutBillService {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void issueTask(JSONObject whereJson) {
-        //出库分配表
-        WQLObject wo_dis = WQLObject.getWQLObject("ST_IVT_IOStorInvDis");
         //任务表
         WQLObject wo_Task = WQLObject.getWQLObject("SCH_BASE_Task");
 
         Long currentUserId = SecurityUtils.getCurrentUserId();
         String nickName = SecurityUtils.getCurrentNickName();
         String now = DateUtil.now();
+
+        JSONObject jsonTask = wo_Task.query("task_id = '" + whereJson.getString("task_id") + "'").uniqueResult(0);
+
+        // 调用出库任务类下发任务
+        new OutTask().immediateNotifyAcs(jsonTask.getString("task_id"));
+//        List<AcsTaskDto> acsTaskDtos = new OutTask().addTask();
+//        System.out.println(acsTaskDtos.toString());
+
+        // 更新任务状态为下发
+        jsonTask.put("task_status",TaskStatusEnum.ISSUE.getCode());
+        jsonTask.put("update_optid",currentUserId);
+        jsonTask.put("update_optname",nickName);
+        jsonTask.put("update_time",now);
+        wo_Task.update(jsonTask);
+
+       /* ArrayList<AcsTaskDto> resultList = new ArrayList<>();
+
         // 1.查询此任务是否有任务组
-        // 2.有任务组：按照执行顺序下发
+        JSONObject jsonTask = wo_Task.query("task_id = '" + whereJson.getString("task_id") + "'").uniqueResult(0);
+        if (ObjectUtil.isEmpty(jsonTask.getString("task_group_id"))) {
+            AcsTaskDto dto = AcsTaskDto.builder()
+                    .ext_task_id(jsonTask.getString("task_id"))
+                    .task_code(jsonTask.getString("task_code"))
+                    .task_type(jsonTask.getString("acs_task_type"))
+                    .start_device_code(jsonTask.getString("point_code1"))
+                    .next_device_code(jsonTask.getString("point_code2"))
+                    .vehicle_code(jsonTask.getString("vehicle_code"))
+                    .priority(jsonTask.getString("priority"))
+                    .remark(jsonTask.getString("remark"))
+                    .build();
+            resultList.add(dto);
+        } else {
+            // 2.有任务组：按照执行顺序下发 大到小
+            JSONArray taskArr = wo_Task.query("task_group_id = '" + jsonTask.getString("task_group_id") + "' order by sort_seq DESC").getResultJSONArray(0);
+            for (int i = 0; i < taskArr.size(); i++) {
+                JSONObject json = taskArr.getJSONObject(i);
+
+                AcsTaskDto dto = AcsTaskDto.builder()
+                        .ext_task_id(json.getString("task_id"))
+                        .task_code(json.getString("task_code"))
+                        .task_type(json.getString("acs_task_type"))
+                        .start_device_code(json.getString("point_code1"))
+                        .next_device_code(json.getString("point_code2"))
+                        .vehicle_code(json.getString("vehicle_code"))
+                        .priority(json.getString("priority"))
+                        .remark(json.getString("remark"))
+                        .build();
+                resultList.add(dto);
+            }
+        }*/
     }
 
     @Override

lms/nladmin-system/src/main/java/org/nl/wms/st/outbill/wql/ST_OUTIVT03.wql

@@ -255,12 +255,12 @@
     IF 输入.flag = "6"
 		QUERY
             SELECT
-              ivt.struct_id,
+                max( ivt.struct_id ) AS struct_id,
-              ivt.material_id,
+                max( ivt.material_id ) AS material_id,
-              sum(ivt.canuse_qty) AS canuse_qty,
+                sum( ivt.canuse_qty ) AS canuse_qty,
-              max(ivt.pcsn) AS pcsn,
+                max( ivt.pcsn ) AS pcsn,
-              ivt.qty_unit_id,
+                max( ivt.qty_unit_id ) AS qty_unit_id,
-              unit.unit_name
+                max( unit.unit_name ) AS unit_name
             FROM
                 ST_IVT_StructIvt ivt
                 LEFT JOIN md_pb_measureunit unit ON ivt.qty_unit_id = unit.measure_unit_id