Browse Source

Merge branch 'master' of https://git.steerinfo.com/DAL-DAZHOU/DAL-DAZHOU-API

luobang 3 years ago
parent
commit
0c699c266b

+ 11 - 0
src/main/java/com/steerinfo/dil/controller/AMScontroller.java

@@ -1879,4 +1879,15 @@ public class AMScontroller{
     public RESTfulResult matchingDriverTelRecently(@RequestParam String capacityNumber) {
     public RESTfulResult matchingDriverTelRecently(@RequestParam String capacityNumber) {
         return amsFeign.matchingDriverTelRecently(capacityNumber);
         return amsFeign.matchingDriverTelRecently(capacityNumber);
     }
     }
+
+    @ApiOperation(value = "展示副产品销售订单列表(apiId=481)")
+    @PostMapping("/getFuSaleOrderList")
+    public Map<String, Object> getFuSaleOrderList(@RequestBody(required = false) Map<String,Object> mapValue,
+                                                  Integer pageNum,
+                                                  Integer pageSize,
+                                                  Integer apiId,
+                                                  String con
+    ) {
+        return amsFeign.getFuSaleOrderList(mapValue==null?new HashMap<>():mapValue, pageNum, pageSize, apiId,con);
+    }
 }
 }

+ 11 - 1
src/main/java/com/steerinfo/dil/controller/BackgroundProcessingController.java

@@ -12,6 +12,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.bind.annotation.RestController;
 
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.List;
 import java.util.Map;
 import java.util.Map;
 
 
@@ -32,8 +33,17 @@ public class BackgroundProcessingController extends BaseRESTfulController {
 
 
     @ApiOperation(value = "关闭一车多趟方法")
     @ApiOperation(value = "关闭一车多趟方法")
     @PostMapping("/closePurOrderMoreTrips")
     @PostMapping("/closePurOrderMoreTrips")
-    public RESTfulResult closePurOrderMoreTrips(String purchaseOrderNo) {
+    public RESTfulResult closePurOrderMoreTrips(String purchaseOrderNo, String deleteNoReceiveOrder) {
         int i = backgroundProcessingMapper.closePurOrderMoreTrips(purchaseOrderNo);
         int i = backgroundProcessingMapper.closePurOrderMoreTrips(purchaseOrderNo);
+        if("yes".equals(deleteNoReceiveOrder)){
+            //查询该采购订单下所有未接收的运输订单(5,6,7,8,17,18)
+            ArrayList<Integer> orderIdList = backgroundProcessingMapper.getAllPurOrder(purchaseOrderNo);
+            if(orderIdList != null && orderIdList.size() != 0){
+                backgroundProcessingMapper.deleteOrders(orderIdList); //物理删除
+                backgroundProcessingMapper.deleteOrderMaterials(orderIdList);//物理删除物资子表
+                backgroundProcessingMapper.batchByOrderIdForTotalDelete(orderIdList);//总实绩表
+            }
+        }
         if(i != 1){
         if(i != 1){
             return failed("关闭失败!没有此采购订单");
             return failed("关闭失败!没有此采购订单");
         }
         }

+ 57 - 8
src/main/java/com/steerinfo/dil/controller/OMSController.java

@@ -286,6 +286,39 @@ public class OMSController {
                                                     ) {
                                                     ) {
         return omsFeign.selectAllOrderForSale(mapValue==null?new HashMap<>():mapValue, carrierId, apiId, pageNum, pageSize, orderType, orderStatus, saleOrderMaterialId, con);
         return omsFeign.selectAllOrderForSale(mapValue==null?new HashMap<>():mapValue, carrierId, apiId, pageNum, pageSize, orderType, orderStatus, saleOrderMaterialId, con);
     }
     }
+    /**
+     * 展示承运商接收销售公司已接受的销售订单
+     *
+     * @param
+     * @param pageNum
+     * @param pageSize
+     * @param apiId
+     * @return
+     */
+    @PostMapping("/getTransportOrder")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "apiId", value = "168", required = false, dataType = "BigDecimal"),
+    })
+    public Map<String, Object> getTransportOrder( @RequestBody(required = false) Map<String, Object> mapValue,
+                                                  Integer apiId,
+                                                  Integer pageNum,
+                                                  Integer pageSize,
+                                                   Integer orderId,
+                                                  Integer orderStatus
+    ) {
+        if (mapValue==null){
+            mapValue=new HashMap<>();
+        }
+        return omsFeign.getTransportOrder(mapValue,apiId,pageNum,pageSize,orderId,orderStatus);
+    }
+
+
+
+
+
+
+
+
     /**
     /**
      * 销售物流:司机接单pc端
      * 销售物流:司机接单pc端
      */
      */
@@ -298,16 +331,18 @@ public class OMSController {
             @ApiImplicitParam(name = "pageSize", value = "页", required = false, dataType = "Integer"),
             @ApiImplicitParam(name = "pageSize", value = "页", required = false, dataType = "Integer"),
     })
     })
     @PostMapping("/getDriverInfoForSale")
     @PostMapping("/getDriverInfoForSale")
-    public Map<String,Object> getDriverInfoForSale(@RequestBody(required=false) Map<String,Object> mapValue,
-                                            Integer apiId,
-                                            Integer pageNum,
-                                            Integer pageSize,
-                                            Integer orderStatus,
-                                            String con,
-                                            @RequestParam Integer saleOrderId
+    public Map<String,Object> getDriverInfoForSale(@RequestBody(required = false) Map<String, Object> mapValue,
+                                                   Integer apiId,
+                                                   Integer pageNum,
+                                                   Integer pageSize,
+                                                   Integer orderType,
+                                                   Integer orderStatus,
+                                                   String con,
+                                                   String carrierSsoId,
+                                                   Integer shipperId
     )
     )
     {
     {
-        return omsFeign.getDriverInfoForSale(mapValue==null?new HashMap<>():mapValue, apiId, pageNum, pageSize,orderStatus, con,saleOrderId);
+        return omsFeign.getDriverInfoForSale(mapValue==null?new HashMap<>():mapValue, apiId, pageNum, pageSize,orderType,orderStatus, con,carrierSsoId,shipperId);
     }
     }
     @PostMapping("/getDriverInfoForSale1")
     @PostMapping("/getDriverInfoForSale1")
     public Map<String,Object> getDriverInfoForSale1(@RequestBody(required=false) Map<String,Object> mapValue,
     public Map<String,Object> getDriverInfoForSale1(@RequestBody(required=false) Map<String,Object> mapValue,
@@ -837,4 +872,18 @@ public class OMSController {
     public Map<String, Object> updateMaterialMes(@RequestBody(required = false) Map<String, Object> map) {
     public Map<String, Object> updateMaterialMes(@RequestBody(required = false) Map<String, Object> map) {
         return omsFeign.updateMaterialMes(map);
         return omsFeign.updateMaterialMes(map);
     }
     }
+
+    @ApiOperation(value = "展示销售订单下的运输订单")
+    @PostMapping("getDriverInfoForSale2")
+    public Map<String, Object> getDriverInfoForSale2(@RequestBody(required = false) Map<String, Object> mapValue,
+                                                     Integer apiId,
+                                                     Integer pageNum,
+                                                     Integer pageSize,
+                                                     Integer saleOrderId,
+                                                     String con) {
+        if (mapValue == null) {
+            mapValue = new HashMap<>();
+        }
+        return omsFeign.getDriverInfoForSale2(mapValue,apiId,pageNum,pageSize,new BigDecimal(saleOrderId),con);
+    }
 }
 }

+ 22 - 0
src/main/java/com/steerinfo/dil/controller/RMScontroller.java

@@ -1106,4 +1106,26 @@ public class RMScontroller {
     public RESTfulResult deleteCapacityCarrier(@RequestBody(required = false) Map<String,Object> map){
     public RESTfulResult deleteCapacityCarrier(@RequestBody(required = false) Map<String,Object> map){
         return rmsFeign.deleteCapacityCarrier(map!=null?map:new HashMap<>());
         return rmsFeign.deleteCapacityCarrier(map!=null?map:new HashMap<>());
     }
     }
+
+    @ApiOperation("罗棒的")
+    @PostMapping("/getInwardContractMaterial")
+    public RESTfulResult getInwardContractMaterial(@RequestBody(required = false) Map<String,Object> map,
+                                                   Integer apiId,
+                                                   Integer pageNum,
+                                                   Integer pageSize,
+                                                   String con){
+        return rmsFeign.getInwardContractMaterial(map!=null?map:new HashMap<>(),apiId,pageNum,pageSize,con);
+    }
+
+    @ApiOperation("罗棒的")
+    @PostMapping("/insertMaterialType")
+    public RESTfulResult insertMaterialType(@RequestBody(required = false) Map<String,Object> map) {
+        return rmsFeign.insertMaterialType(map);
+    }
+
+    @ApiOperation("渲染运力修改数据")
+    @PostMapping("/getCapacityInfoById/{id}")
+    public Map<String, Object> getCapacityInfoById(@PathVariable("id") Integer id){
+        return rmsFeign.getCapacityInfoById(id);
+    }
 }
 }

+ 3 - 17
src/main/java/com/steerinfo/dil/controller/TMSController.java

@@ -1271,21 +1271,6 @@ public class TMSController extends BaseRESTfulController {
         String orderNumber = (String) mapValue.get("orderNumber");
         String orderNumber = (String) mapValue.get("orderNumber");
         orderNumber = orderNumber.substring(0, orderNumber.length()-1);
         orderNumber = orderNumber.substring(0, orderNumber.length()-1);
         mapValue.put("orderNumber", orderNumber);
         mapValue.put("orderNumber", orderNumber);
-        //通过订单号获取订单ID 和 订单类型
-        Map<String, Object> orderMesMap = universalMapper.getOrderMesByOrderNumber(orderNumber);
-        BigDecimal orderType = DataChange.dataToBigDecimal(orderMesMap.get("orderType"));
-        //如果订单类型为2 则需要财务公司审核才能进厂
-        if(orderType.intValue() == 2){
-            Integer saleOrderStatus = universalMapper.getSaleOrderStatus(DataChange.dataToBigDecimal(orderMesMap.get("orderId")));
-            if(saleOrderStatus != 4){
-                //如果不等于4则是未通过财务审批 ,不可以进厂
-                Map<String, Object> returnMap = new HashMap<>();
-                returnMap.put("code", "201");
-                returnMap.put("status", "failed");
-                returnMap.put("data", "审批未通过不能进厂!");
-                return returnMap;
-            }
-        }
         return tmsTruckFeign.enFactoryResultByPDA(mapValue);
         return tmsTruckFeign.enFactoryResultByPDA(mapValue);
     }
     }
 
 
@@ -1956,9 +1941,10 @@ public class TMSController extends BaseRESTfulController {
                                           String carrierSsoId,
                                           String carrierSsoId,
                                                 Integer orderType,
                                                 Integer orderType,
                                                 Integer shipperId,
                                                 Integer shipperId,
-                                                String receiveName
+                                                String receiveName,
+                                                String materialName
     ){
     ){
-        return tmsTruckFeign.getAllSaleReport(mapValue==null?new HashMap<>():mapValue, apiId, pageNum, pageSize, startTime, endTime, carrierSsoId,orderType,shipperId,receiveName);
+        return tmsTruckFeign.getAllSaleReport(mapValue==null?new HashMap<>():mapValue, apiId, pageNum, pageSize, startTime, endTime, carrierSsoId,orderType,shipperId,receiveName,materialName);
     }
     }
 
 
     @ApiOperation(value="查询销售统计报表筛选过后的总净重")
     @ApiOperation(value="查询销售统计报表筛选过后的总净重")

+ 6 - 1
src/main/java/com/steerinfo/dil/controller/UniversalController.java

@@ -152,7 +152,8 @@ public class UniversalController extends BaseRESTfulController {
                                         Integer pageSize,
                                         Integer pageSize,
                                         String carrierSsoId,
                                         String carrierSsoId,
                                         String index,
                                         String index,
-                                        String con
+                                        String con,
+                                        String indexText
     ){
     ){
         if(mapValue == null){
         if(mapValue == null){
             mapValue = new HashMap<>();
             mapValue = new HashMap<>();
@@ -163,6 +164,10 @@ public class UniversalController extends BaseRESTfulController {
         if (con != null&& !con.equals("undefined")){
         if (con != null&& !con.equals("undefined")){
             mapValue.put("con",con);
             mapValue.put("con",con);
         }
         }
+        if (indexText != null&& !indexText.equals("undefined")){
+            mapValue.put("indexText",indexText);
+        }
+
         if (carrierSsoId != null && carrierSsoId.equals("undefined")) {
         if (carrierSsoId != null && carrierSsoId.equals("undefined")) {
             carrierSsoId = null;
             carrierSsoId = null;
         }
         }

+ 8 - 0
src/main/java/com/steerinfo/dil/feign/AmsFeign.java

@@ -1655,4 +1655,12 @@ public interface AmsFeign {
     // 自动匹配上一条运单的司机电话
     // 自动匹配上一条运单的司机电话
     @PostMapping(value = "/api/v1/ams/amssaleorders/matchingDriverTelRecently")
     @PostMapping(value = "/api/v1/ams/amssaleorders/matchingDriverTelRecently")
     RESTfulResult matchingDriverTelRecently(@RequestParam String capacityNumber);
     RESTfulResult matchingDriverTelRecently(@RequestParam String capacityNumber);
+
+    // 展示副产品销售订单列表
+    @PostMapping(value = "/api/v1/ams/amssaleorders/getFuSaleOrderList")
+    Map<String, Object> getFuSaleOrderList(@RequestBody(required = false) Map<String, Object> mapValue,
+                                           @RequestParam Integer pageNum,
+                                           @RequestParam Integer pageSize,
+                                           @RequestParam Integer apiId,
+                                           @RequestParam String con);
 }
 }

+ 24 - 7
src/main/java/com/steerinfo/dil/feign/OmsFeign.java

@@ -130,13 +130,15 @@ public interface OmsFeign {
      * 销售物流司机接收新的订单
      * 销售物流司机接收新的订单
      */
      */
     @PostMapping(value = "api/v1/oms/omstruckorders/getDriverInfoForSale")
     @PostMapping(value = "api/v1/oms/omstruckorders/getDriverInfoForSale")
-    Map<String,Object> getDriverInfoForSale(@RequestBody(required=false) Map<String,Object> mapValue,
-                                            @RequestParam("apiId")      Integer apiId,
-                                            @RequestParam("pageNum")    Integer pageNum,
-                                            @RequestParam("pageSize")   Integer pageSize,
-                                            @RequestParam("orderStatus")Integer orderStatus,
-                                            @RequestParam("con")        String con,
-                                            @RequestParam("saleOrderId") Integer saleOrderId
+    Map<String,Object> getDriverInfoForSale(@RequestBody(required = false) Map<String, Object> mapValue,
+                                            @RequestParam Integer apiId,
+                                            @RequestParam Integer pageNum,
+                                            @RequestParam Integer pageSize,
+                                            @RequestParam Integer orderType,
+                                            @RequestParam Integer orderStatus,
+                                            @RequestParam String con,
+                                            @RequestParam String carrierSsoId,
+                                            @RequestParam Integer shipperId
     );
     );
 
 
 
 
@@ -494,5 +496,20 @@ public interface OmsFeign {
     @PostMapping("api/v1/oms/omstruckmatetialorders/updateMaterialMes")
     @PostMapping("api/v1/oms/omstruckmatetialorders/updateMaterialMes")
     public Map<String, Object> updateMaterialMes(@RequestBody(required = false) Map<String, Object> map);
     public Map<String, Object> updateMaterialMes(@RequestBody(required = false) Map<String, Object> map);
 
 
+    @PostMapping("api/v1/oms/omstruckorders/getDriverInfoForSale2")
+    Map<String, Object> getDriverInfoForSale2(@RequestBody(required = false) Map<String, Object> mapValue,
+                                              @RequestParam Integer apiId,
+                                              @RequestParam Integer pageNum,
+                                              @RequestParam Integer pageSize,
+                                              @RequestParam BigDecimal saleOrderId,
+                                              @RequestParam String con);
+
+    @PostMapping("api/v1/oms/omstruckorders/getTransportOrder")
+    Map<String, Object> getTransportOrder(@RequestBody(required = false) Map<String, Object> mapValue,
+                                          @RequestParam("apiId") Integer apiId,
+                                          @RequestParam("pageNum") Integer pageNum,
+                                          @RequestParam("pageSize") Integer pageSize,
+                                          @RequestParam("orderId") Integer orderId,
+                                          @RequestParam("orderStatus") Integer orderStatus);
 }
 }
 
 

+ 13 - 0
src/main/java/com/steerinfo/dil/feign/RmsFeign.java

@@ -605,4 +605,17 @@ public interface RmsFeign {
     @ApiOperation("解除承运商和车辆的绑定关系")
     @ApiOperation("解除承运商和车辆的绑定关系")
     @PostMapping("api/v1/rms/rmscapacity/deleteCapacityCarrier")
     @PostMapping("api/v1/rms/rmscapacity/deleteCapacityCarrier")
     public RESTfulResult deleteCapacityCarrier(@RequestBody(required = false) Map<String,Object> map);
     public RESTfulResult deleteCapacityCarrier(@RequestBody(required = false) Map<String,Object> map);
+
+    @PostMapping("api/v1/rms/rmsmaterialtype/getInwardContractMaterial")
+    RESTfulResult getInwardContractMaterial(@RequestBody(required = false) Map<String, Object> map,
+                                            @RequestParam Integer apiId,
+                                            @RequestParam Integer pageNum,
+                                            @RequestParam Integer pageSize,
+                                            @RequestParam String con);
+
+    @PostMapping("api/v1/rms/rmsmaterialtype/insertMaterialType")
+    RESTfulResult insertMaterialType(@RequestBody(required = false) Map<String, Object> map);
+
+    @PostMapping("api/v1/rms/rmscapacity/getCapacityInfoById/{id}")
+    Map<String,Object> getCapacityInfoById(@PathVariable("id") Integer id);
 }
 }

+ 2 - 1
src/main/java/com/steerinfo/dil/feign/TmsTruckFeign.java

@@ -393,7 +393,8 @@ public interface TmsTruckFeign {
                                       @RequestParam("carrierSsoId")   String carrierSsoId,
                                       @RequestParam("carrierSsoId")   String carrierSsoId,
                                          @RequestParam("orderType") Integer orderType,
                                          @RequestParam("orderType") Integer orderType,
                                          @RequestParam("shipperId") Integer shipperId,
                                          @RequestParam("shipperId") Integer shipperId,
-                                         @RequestParam("receiveName") String receiveName
+                                         @RequestParam("receiveName") String receiveName,
+                                         @RequestParam String materialName
     );
     );
 
 
     @PostMapping("api/v1/truckTms/statisticalReport/getAllSaleReportTotal")
     @PostMapping("api/v1/truckTms/statisticalReport/getAllSaleReportTotal")

+ 37 - 1
src/main/java/com/steerinfo/dil/mapper/BackgroundProcessingMapper.java

@@ -1,8 +1,11 @@
 package com.steerinfo.dil.mapper;
 package com.steerinfo.dil.mapper;
 
 
+import org.apache.ibatis.annotations.Param;
 import org.mapstruct.Mapper;
 import org.mapstruct.Mapper;
 
 
 import java.math.BigDecimal;
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.Map;
 
 
 @Mapper
 @Mapper
@@ -16,5 +19,38 @@ public interface BackgroundProcessingMapper {
 
 
     Map<String, Object> getOrderMesByOrderNum(String orderNumber);
     Map<String, Object> getOrderMesByOrderNum(String orderNumber);
 
 
-    Map<String, Object> getEnFactoryResult(BigDecimal resultTotalId);
+    ArrayList<Integer> getAllPurOrder(String purchaseOrderNo);
+
+    int deleteOrders(ArrayList<Integer> list);
+
+    int deleteOrderMaterials(ArrayList<Integer> list);
+
+    int batchByOrderIdForTotalDelete(ArrayList<Integer> list);
+
+    List<Integer> enFactoryCheck(BigDecimal resultTotalId);
+    List<Integer> loadCheck(BigDecimal resultTotalId);
+    List<Integer> unloadCheck(BigDecimal resultTotalId);
+    List<Integer> weightCheck(BigDecimal resultTotalId);
+    List<Integer> outFactoryCheck(BigDecimal resultTotalId);
+
+    List<Map<String, Object>> getEnFactoryResult(@Param("resultTotalId") BigDecimal resultTotalId,@Param("sqe") Integer sqe);
+
+    List<Map<String, Object>> loadResult(@Param("resultTotalId") BigDecimal resultTotalId,@Param("sqe") Integer sqe);
+
+    List<Map<String, Object>> unloadResult(@Param("resultTotalId") BigDecimal resultTotalId,@Param("sqe") Integer sqe);
+
+    List<Map<String, Object>> weightResult(@Param("resultTotalId") BigDecimal resultTotalId,@Param("sqe") Integer sqe);
+
+    List<Map<String, Object>> outFactoryResult(@Param("resultTotalId") BigDecimal resultTotalId,@Param("sqe") Integer sqe);
+
+    int deleteEnFactoryUnnecessaryResult(@Param("list") List<Integer> list);
+
+    int deleteLoadUnnecessaryResult(@Param("list") List<Integer> list);
+
+    int deleteUnloadUnnecessaryResult(@Param("list") List<Integer> list);
+
+    int deleteWeightUnnecessaryResult(@Param("list") List<Integer> list);
+
+    int deleteOutFactoryUnnecessaryResult(@Param("list") List<Integer> list);
+
 }
 }

+ 68 - 2
src/main/java/com/steerinfo/dil/service/impl/BackgroundProcessingServiceImpl.java

@@ -1,7 +1,6 @@
 package com.steerinfo.dil.service.impl;
 package com.steerinfo.dil.service.impl;
 
 
 import com.steerinfo.dil.mapper.BackgroundProcessingMapper;
 import com.steerinfo.dil.mapper.BackgroundProcessingMapper;
-import com.steerinfo.dil.mapper.UniversalMapper;
 import com.steerinfo.dil.service.IBackgroundProcessService;
 import com.steerinfo.dil.service.IBackgroundProcessService;
 import com.steerinfo.dil.util.DataChange;
 import com.steerinfo.dil.util.DataChange;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -43,7 +42,74 @@ public class BackgroundProcessingServiceImpl implements IBackgroundProcessServic
             return 0;
             return 0;
         }
         }
         BigDecimal resultTotalId = DataChange.dataToBigDecimal(orderMes.get("resultTotalId"));
         BigDecimal resultTotalId = DataChange.dataToBigDecimal(orderMes.get("resultTotalId"));
-
+        List<Integer> enFactoryList = backgroundProcessingMapper.enFactoryCheck(resultTotalId);
+        if(enFactoryList != null && enFactoryList.size() != 0){
+            //查询出当前顺序号中所有的实绩
+            for (Integer sqe : enFactoryList) {
+                List<Map<String, Object>> mesList = backgroundProcessingMapper.getEnFactoryResult(resultTotalId, sqe);
+                closeWay(mesList, 1);
+            }
+        }
+        List<Integer> loadList = backgroundProcessingMapper.loadCheck(resultTotalId);
+        if(loadList != null && loadList.size() != 0){
+            for (Integer sqe : loadList) {
+                List<Map<String, Object>> mesList = backgroundProcessingMapper.loadResult(resultTotalId, sqe);
+                closeWay(mesList, 2);
+            }
+        }
+        List<Integer> unloadList = backgroundProcessingMapper.unloadCheck(resultTotalId);
+        if(unloadList != null && unloadList.size() != 0){
+            for (Integer sqe : unloadList) {
+                List<Map<String, Object>> mesList = backgroundProcessingMapper.unloadResult(resultTotalId, sqe);
+                closeWay( mesList, 3);
+            }
+        }
+        List<Integer> weightList = backgroundProcessingMapper.weightCheck(resultTotalId);
+        if(weightList != null && weightList.size() != 0){
+            for (Integer sqe : weightList) {
+                List<Map<String, Object>> mesList = backgroundProcessingMapper.weightResult(resultTotalId, sqe);
+                closeWay(mesList, 4);
+            }
+        }
+        List<Integer> outFactoryList = backgroundProcessingMapper.outFactoryCheck(resultTotalId);
+        if(outFactoryList != null && outFactoryList.size() != 0){
+            for (Integer sqe : outFactoryList) {
+                List<Map<String, Object>> mesList = backgroundProcessingMapper.outFactoryResult(resultTotalId, sqe);
+                closeWay(mesList, 5);
+            }
+        }
         return 0;
         return 0;
     }
     }
+
+    /**
+     * 关闭通用方法
+     * @param mesList 这些顺序号的实绩信息
+     * @param type 1:进厂 2:计量 3:装货:4:卸货 5:出厂
+     */
+    public void closeWay(List<Map<String, Object>> mesList, int type){
+        List<Integer> resultList = new ArrayList<>();
+        for (Map<String, Object> map : mesList) {
+            //有过操作时间的不做删除
+            if(map.get("time") == null){
+                resultList.add(DataChange.dataToBigDecimal(map.get("resultId")).intValue()); //添入列表中
+            }
+        }
+        if(mesList.size() == resultList.size()){
+            //如果所有的实绩都为空 ,则只保留一条实绩,其余的全部删除
+            resultList.remove(0);
+        }
+        if(resultList.size() != 0){
+            //删除实绩数据
+            if(type == 1)
+                backgroundProcessingMapper.deleteEnFactoryUnnecessaryResult(resultList);
+            else if(type == 2)
+                backgroundProcessingMapper.deleteLoadUnnecessaryResult(resultList);
+            else if(type == 3)
+                backgroundProcessingMapper.deleteUnloadUnnecessaryResult(resultList);
+            else if(type == 4)
+                backgroundProcessingMapper.deleteWeightUnnecessaryResult(resultList);
+            else if(type == 5)
+                backgroundProcessingMapper.deleteOutFactoryUnnecessaryResult(resultList);
+        }
+    }
 }
 }

+ 2 - 3
src/main/resources/application-dev.yml

@@ -23,7 +23,6 @@ openfeign:
     url: ${TMSTRAINFEIGN_URL:172.16.33.162:8004}
     url: ${TMSTRAINFEIGN_URL:172.16.33.162:8004}
   TmsTruckFeign:
   TmsTruckFeign:
     url: ${TMSTRUCKFEIGN_URL:172.16.33.162:8008}
     url: ${TMSTRUCKFEIGN_URL:172.16.33.162:8008}
-    #url: ${TMSTRUCKFEIGN_URL:172.16.33.162:8088}
   TmsshipFeign:
   TmsshipFeign:
     url: ${TMSSHIPFEIGN_URL:172.16.33.162:8003}
     url: ${TMSSHIPFEIGN_URL:172.16.33.162:8003}
   WMSHFeign:
   WMSHFeign:
@@ -33,12 +32,12 @@ openfeign:
   OMSFeign:
   OMSFeign:
     url: ${OMSFEIGN_URL:172.16.33.162:8016}
     url: ${OMSFEIGN_URL:172.16.33.162:8016}
   RmsFeign:
   RmsFeign:
-    url: ${RMSFEIGN_HRL:172.16.33.162:8060}
+    url: ${RMSFEIGN_HRL:172.16.33.162:8014}
   JoinFeign:
   JoinFeign:
     url: ${JOINFEIGN_URL:172.16.33.162:8006}
     url: ${JOINFEIGN_URL:172.16.33.162:8006}
   OTMSFeign:
   OTMSFeign:
     url: ${OTMSFEIGN_URL:172.16.33.162:8038}
     url: ${OTMSFEIGN_URL:172.16.33.162:8038}
-    #url: ${OTMSFEIGN_URL:localhost:8038}
+
 piction:
 piction:
   #path: C:\Users\24390\Desktop\work\a
   #path: C:\Users\24390\Desktop\work\a
   #path: D:\Code\work\jpg
   #path: D:\Code\work\jpg

+ 0 - 1
src/main/resources/bootstrap.yml

@@ -1,7 +1,6 @@
 api.version: api/v1
 api.version: api/v1
 spring:
 spring:
   profiles:
   profiles:
-    #include: ${SPRING_PROFILES:dev}
     include: ${SPRING_PROFILES:prod}
     include: ${SPRING_PROFILES:prod}
   jackson:
   jackson:
     date-format: yyyy-MM-dd HH:mm:ss
     date-format: yyyy-MM-dd HH:mm:ss

+ 160 - 2
src/main/resources/com/steerinfo/dil/mapper/BackgroundProcessingMapper.xml

@@ -30,9 +30,167 @@
 
 
     <select id="getEnFactoryResult" resultType="java.util.Map">
     <select id="getEnFactoryResult" resultType="java.util.Map">
         select TER.RESULT_ID    "resultId",
         select TER.RESULT_ID    "resultId",
-               TER.SEGMEN_SQE   "segmentSqe",
-               TER.RESULT_ENTRY_GATE_TIME   "resultEntryGateTime"
+               TER.RESULT_ENTRY_GATE_TIME   "time"
         from TMSTRUCK_ENFACTORY_RESULT TER
         from TMSTRUCK_ENFACTORY_RESULT TER
         where TER.RESULT_TOTAL_ID = #{resultTotalId}
         where TER.RESULT_TOTAL_ID = #{resultTotalId}
+          and  TER.SEGMEN_SQE = #{sqe}
     </select>
     </select>
+
+    <select id="loadResult" resultType="java.util.Map">
+        select T.RESULT_ID    "resultId",
+               T.RESULT_LOAD_END_TIME   "time"
+        from TMSTRUCK_LOAD_RESULT T
+        where T.RESULT_TOTAL_ID = #{resultTotalId}
+          and  T.SEGMENT_SQE = #{sqe}
+    </select>
+
+    <select id="unloadResult" resultType="java.util.Map">
+        select T.RESULT_ID    "resultId",
+               T.RESULT_END_TIME   "time"
+        from TMSTRUCK_UNLOAD_RESULT T
+        where T.RESULT_TOTAL_ID = #{resultTotalId}
+          and  T.SEGMENT_SQE = #{sqe}
+    </select>
+
+    <select id="weightResult" resultType="java.util.Map">
+        select T.WEIGHT_TASK_RESULT_ID    "resultId",
+               T.RESULT_TARE_WEIGHT_TIME   "time"
+        from TMSTRUCK_WEIGHT_RESULT T
+        where T.RESULT_TOTAL_ID = #{resultTotalId}
+          and  T.GROSS_SEGMENT_SQE = #{sqe}
+    </select>
+
+    <select id="outFactoryResult" resultType="java.util.Map">
+        select T.RESULT_ID    "resultId",
+               T.RESULT_OUT_GATE_TIME   "time"
+        from TMSTRUCK_LEAVE_FACTORY_RESULT T
+        where T.RESULT_TOTAL_ID = #{resultTotalId}
+          and  T.SEGMENT_SQE = #{sqe}
+    </select>
+
+    <select id="getAllPurOrder" resultType="java.lang.Integer">
+        select OO.ORDER_ID
+        from OMSTRUCK_ORDER OO
+        left join AMS_PURCHASE_ORDER APO
+            on OO.ORDER_PLAN_ID = APO.PURCHASE_ORDER_ID
+        where APO.PURCHASE_ORDER_NO = #{purchaseOrderNo}
+          and OO.ORDER_TYPE in (5,6,7,8,17,18)
+          and OO.ORDER_STATUS in (3,4)
+    </select>
+
+    <delete id="deleteOrders" parameterType="arraylist">
+        delete
+        from OMSTRUCK_ORDER OO
+        where OO.ORDER_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")" >
+            ${id}
+        </foreach>
+    </delete>
+
+    <delete id="deleteOrderMaterials" parameterType="arraylist">
+        delete
+        from OMSTRUCK_ORDER_MATERIAL OOM
+        where OOM.ORDER_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")" >
+            ${id}
+        </foreach>
+    </delete>
+
+    <delete id="batchByOrderIdForTotalDelete" parameterType="arraylist">
+        delete from TMSTRUCK_TOTAL_RESULT TTR
+        where TTR.ORDER_ID in
+        <foreach collection="list" item="id" open="(" close=")" separator=",">
+            #{id}
+        </foreach>
+    </delete>
+
+    <select id="enFactoryCheck" parameterType="decimal" resultType="int">
+        SELECT
+            TER.SEGMEN_SQE  "segmentSqe"
+        FROM
+            TMSTRUCK_ENFACTORY_RESULT TER
+        WHERE
+            TER.RESULT_TOTAL_ID = #{resultTotalId}
+        GROUP BY TER.SEGMEN_SQE
+        HAVING count( TER.SEGMEN_SQE ) > 1
+    </select>
+
+    <select id="loadCheck" parameterType="decimal" resultType="int">
+        SELECT
+            T.SEGMENT_SQE  "segmentSqe"
+        FROM
+            TMSTRUCK_LOAD_RESULT T
+        WHERE
+            T.RESULT_TOTAL_ID = #{resultTotalId}
+        GROUP BY T.SEGMENT_SQE
+        HAVING count( T.SEGMENT_SQE ) > 1
+    </select>
+
+    <select id="unloadCheck" parameterType="decimal" resultType="int">
+        SELECT
+            T.SEGMENT_SQE  "segmentSqe"
+        FROM
+            TMSTRUCK_UNLOAD_RESULT T
+        WHERE
+            T.RESULT_TOTAL_ID = #{resultTotalId}
+        GROUP BY T.SEGMENT_SQE
+        HAVING count( T.SEGMENT_SQE ) > 1
+    </select>
+
+    <select id="weightCheck" parameterType="decimal" resultType="int">
+        SELECT
+            T.GROSS_SEGMENT_SQE   "segmentSqe"
+        FROM
+            TMSTRUCK_WEIGHT_RESULT T
+        WHERE
+            T.RESULT_TOTAL_ID = #{resultTotalId}
+        GROUP BY T.GROSS_SEGMENT_SQE
+        HAVING count( T.GROSS_SEGMENT_SQE  ) > 1
+    </select>
+
+    <select id="outFactoryCheck" parameterType="decimal" resultType="int">
+        SELECT
+            T.SEGMENT_SQE  "segmentSqe"
+        FROM
+            TMSTRUCK_LEAVE_FACTORY_RESULT T
+        WHERE
+            T.RESULT_TOTAL_ID = #{resultTotalId}
+        GROUP BY T.SEGMENT_SQE
+        HAVING count( T.SEGMENT_SQE ) > 1
+    </select>
+
+    <delete id="deleteEnFactoryUnnecessaryResult">
+        delete from TMSTRUCK_ENFACTORY_RESULT where RESULT_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            ${id}
+        </foreach>
+    </delete>
+
+  <delete id="deleteLoadUnnecessaryResult">
+        delete from TMSTRUCK_LOAD_RESULT where RESULT_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            ${id}
+        </foreach>
+    </delete>
+
+    <delete id="deleteUnloadUnnecessaryResult">
+        delete from TMSTRUCK_UNLOAD_RESULT where RESULT_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            ${id}
+        </foreach>
+    </delete>
+
+    <delete id="deleteWeightUnnecessaryResult">
+        delete from TMSTRUCK_WEIGHT_RESULT where WEIGHT_TASK_RESULT_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            ${id}
+        </foreach>
+    </delete>
+
+    <delete id="deleteOutFactoryUnnecessaryResult">
+        delete from TMSTRUCK_LEAVE_FACTORY_RESULT where RESULT_ID in
+        <foreach collection="list" item="id" open="(" separator="," close=")">
+            ${id}
+        </foreach>
+    </delete>
 </mapper>
 </mapper>

+ 16 - 13
src/main/resources/com/steerinfo/dil/mapper/UniversalMapper.xml

@@ -149,18 +149,18 @@
     <select id="getAllCapacityByCarrierLike" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
     <select id="getAllCapacityByCarrierLike" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
         SELECT *
         SELECT *
         FROM (
         FROM (
-                 SELECT
-                        RC.CAPACITY_ID        "capacityId",
-                        RCC.CARRIER_ID         "carrierId",
-                        RC.CAPACITY_NUMBER     "capacityNumber",
-                        RCA.CARRIER_NAME       "carrierName",
-                        RC.INSERT_UPDATE_REMARK "remark"
-                 FROM RMS_CAPACITY_CARRIER RCC
-                            LEFT JOIN RMS_CAPACITY RC
-                     ON RCC.CAPACITY_ID = RC.CAPACITY_ID
-                          JOIN RMS_CARRIER RCA
-                                ON RCA.CARRIER_ID = RCC.CARRIER_ID
-                 WHERE RC.CAPACITY_SSO_ID is not NULL
+        SELECT
+        RC.CAPACITY_ID "capacityId",
+        RCC.CARRIER_ID "carrierId",
+        RCC.CAPACITY_CARRIER_ID,
+        RC.CAPACITY_NUMBER "capacityNumber",
+        RCA.CARRIER_NAME "carrierName",
+        RCC.INSERT_UPDATE_REMARK "remark"
+        FROM
+        RMS_CAPACITY_CARRIER RCC
+        LEFT JOIN RMS_CAPACITY RC ON RCC.CAPACITY_ID = RC.CAPACITY_ID
+        JOIN RMS_CARRIER RCA ON RCA.CARRIER_ID = RCC.CARRIER_ID
+        WHERE RC.CAPACITY_SSO_ID is not NULL
             <if test="carrierId != null" >
             <if test="carrierId != null" >
                 and RCC.CARRIER_ID = #{carrierId}
                 and RCC.CARRIER_ID = #{carrierId}
             </if>
             </if>
@@ -168,7 +168,10 @@
                 and (instr(RC.CAPACITY_NUMBER, #{index}) > 0 or instr(RCA.CARRIER_NAME, #{index}) > 0 or  instr(RC.INSERT_UPDATE_REMARK, #{index})>0)
                 and (instr(RC.CAPACITY_NUMBER, #{index}) > 0 or instr(RCA.CARRIER_NAME, #{index}) > 0 or  instr(RC.INSERT_UPDATE_REMARK, #{index})>0)
             </if>
             </if>
             <if test="con != null">
             <if test="con != null">
-                and instr(RC.INSERT_UPDATE_REMARK, #{con}) > 0
+                and instr(RCC.INSERT_UPDATE_REMARK, #{con}) > 0
+            </if>
+            <if test="indexText!=null">
+                and instr(RCC.CAPACITY_USER_DEP, #{indexText}) > 0
             </if>
             </if>
         )
         )
         <where>
         <where>