提交排队代码

src/main/java/com/steerinfo/dil/controller/AMScontroller.java

@@ -1,6 +1,7 @@
 package com.steerinfo.dil.controller;
 
 import com.steerinfo.dil.feign.AmsFeign;
+import com.steerinfo.dil.service.impl.UniversalServiceImpl;
 import com.steerinfo.framework.controller.RESTfulResult;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -27,6 +28,15 @@ public class AMScontroller{
     @Autowired
     AmsFeign amsFeign;
 
+    /*@Autowired
+    UniversalServiceImpl universalService;*/
+
+    /*@GetMapping("/test")
+    public int test1(){
+        universalService.closePassedOrder();
+        return 1;
+    }*/
+
     @ApiOperation(value="查询运输预约")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "mapValue", value = "表头和参数", required = false, dataType = "map"),

src/main/java/com/steerinfo/dil/mapper/UniversalMapper.java

@@ -245,4 +245,15 @@ public interface UniversalMapper {
 
     List<Map<String, Object>> getLuhaoNum(@Param("orderId") BigDecimal orderId, @Param("materialId") BigDecimal materialId);
 
+
+    //查询多拼数据
+    BigDecimal queueMore(BigDecimal orderId);
+
+    //查询单拼数据
+    BigDecimal queueSingle(BigDecimal orderId);
+
+    //删除单拼数据
+    int delectQueueS(BigDecimal capacityIdS);
+    //删除多拼数据
+    int delectQueueM(BigDecimal capacityIdM);
 }

src/main/java/com/steerinfo/dil/service/impl/UniversalServiceImpl.java

@@ -244,6 +244,26 @@ public class UniversalServiceImpl implements UniversalService {
         List<Map<String,Object>> passedOrderList = universalMapper.findPassedOrder();
         System.out.println("关闭的未出厂过期订单如下：<" + passedOrderList + ">");
         int result = universalMapper.closePassedOrder();
+        try {
+            for (Map<String, Object> map : passedOrderList) {
+                BigDecimal orderId = (BigDecimal) map.get("orderId");
+                //查询多拼的数据
+                BigDecimal capacityIdM =universalMapper.queueMore(orderId);
+                if (capacityIdM !=null){
+                    //删除多拼
+                    universalMapper.delectQueueM(capacityIdM);
+                }
+                //查询单拼的数据
+                BigDecimal capacityIdS=universalMapper.queueSingle(orderId);
+                if (capacityIdS !=null){
+                    //删除单拼
+                    universalMapper.delectQueueS(capacityIdS);
+                }
+            }
+        }catch (Exception e){
+
+        }
+
         System.out.println("订单关闭数为：" + result);
     }
 }

src/main/resources/com/steerinfo/dil/mapper/UniversalMapper.xml

@@ -1344,4 +1344,33 @@
         )
     </update>
 
+    <delete id="delectQueueS">
+        delete from QMS_QUEUE_LIST qql
+        where qql.LIST_ID=#{capacityIdM}
+    </delete>
+
+    <delete id="delectQueueM">
+        delete from QMS_QUEUE_SPELLING_LIST qqsl
+        where qqsl.SPELLING_RESULT_ID=#{capacityIdM}
+    </delete>
+
+    <select id="queueMore" resultType="java.math.BigDecimal">
+        select
+        distinct
+        qqsl.SPELLING_RESULT_ID
+        from OMSTRUCK_ORDER oo
+        LEFT JOIN QMS_QUEUE_RESULT qqr
+        on qqr.capacity_id=oo.capacity_id
+        LEFT JOIN QMS_QUEUE_SPELLING_LIST qqsl
+        on qqsl.queue_result_id=qqr.result_total_id
+        where oo.order_id=#{orderId}
+    </select>
+
+    <select id="queueSingle" resultType="java.math.BigDecimal">
+        select qql.LIST_ID
+        from OMSTRUCK_ORDER oo
+        LEFT JOIN QMS_QUEUE_LIST qql
+        on qql.capacity_id=oo.capacity_id
+        where oo.order_id=#{orderId}
+    </select>
 </mapper>