修改销售装车

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

@@ -53,13 +53,14 @@ public class TmstruckLoadResultController extends BaseRESTfulController {
                                         Integer apiId,
                                         Integer pageNum,
                                         Integer pageSize,
-                                          Integer status ){
-        if(mapValue == null){
-            mapValue = new HashMap<>();
-        }
+                                        Integer status,
+                                        @RequestParam("orderType") Integer orderType){
         if(status != null){
             mapValue.put("status", status);
         }
+        if(orderType != null){
+            mapValue.put("orderTypee", orderType);
+        }
         //不分页筛选数据
         List<Map<String, Object>> allLoadResult = tmstruckLoadResultService.getAllLoadResult(mapValue);
         PageHelper.startPage(pageNum,pageSize);
@@ -70,13 +71,13 @@ public class TmstruckLoadResultController extends BaseRESTfulController {
         return success(pageList);
     }
 
-    @ApiOperation(value="新增汽车装车实绩")
+    @ApiOperation(value="新增CG汽车装车实绩")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "mapValue", value = "", required = false, dataType = "Map"),
     })
-    @PostMapping("/addLoadResult")
-    public RESTfulResult addLoadResult(@RequestBody(required=false) Map<String,Object> mapValue){
-        int i = tmstruckLoadResultService.addLoadResult(mapValue);
+    @PostMapping("/addCGLoadResult")
+    public RESTfulResult addCGLoadResult(@RequestBody(required=false) Map<String,Object> mapValue){
+        int i = tmstruckLoadResultService.addCGLoadResult(mapValue);
         return success(i);
     }
 
@@ -112,7 +113,7 @@ public class TmstruckLoadResultController extends BaseRESTfulController {
         tmstruckLoadResult.setDeleteName("admin");
         tmstruckLoadResult.setDeleteTime(new Date());
         tmstruckLoadResult.setResultId(new BigDecimal(resultId));
-        tmstruckLoadResult.setStatus(new BigDecimal(1));
+        tmstruckLoadResult.setStatus(new BigDecimal(1)); 
         int i = tmstruckLoadResultService.updateLoadResult(tmstruckLoadResult);
         return success(i);
     }

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

@@ -70,4 +70,27 @@ public class TmstruckTotalResultController extends BaseRESTfulController {
         PageListAdd pageList = columnDataUtil.tableColumnData(apiId, allUnloadResult,unloadResult);
         return success(pageList);
     }
+    @ApiOperation(value="查询所有的包月作业实绩")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "mapValue", value = "表头和参数", required = false, dataType = "map"),
+            @ApiImplicitParam(name = "apiId(111)", value = "动态表头", required = false, dataType = "Integer"),
+            @ApiImplicitParam(name = "pageNum", value = "页码", required = false, dataType = "Integer"),
+            @ApiImplicitParam(name = "pageSize", value = "页", required = false, dataType = "Integer"),
+            @ApiImplicitParam(name = "status", value = "状态码", required = false, dataType = "Integer"),
+    })
+    @PostMapping("/getTmstruckMonthResult")
+    public RESTfulResult getTmstruckMonthResult(@RequestBody(required=false) Map<String,Object> mapValue,
+                                                Integer apiId,
+                                                Integer pageNum,
+                                                Integer pageSize
+    ){
+        //不分页筛选数据
+        List<Map<String, Object>> allQualityResult = tmstruckTotalResultService.getTmstruckMonthResult(mapValue);
+        PageHelper.startPage(pageNum,pageSize);
+        //分页数据
+        List<Map<String, Object>> qualityResult = tmstruckTotalResultService.getTmstruckMonthResult(mapValue);
+        DataChange.dataTo2Number(qualityResult, "resultDeduction");
+        PageListAdd pageList = columnDataUtil.tableColumnData(apiId, allQualityResult,qualityResult);
+        return success(pageList);
+    }
 }

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

@@ -8,6 +8,7 @@ import com.steerinfo.framework.service.pagehelper.PageHelper;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.collections4.Put;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -50,8 +51,10 @@ public class TmstruckUnloadResultController extends BaseRESTfulController {
     public RESTfulResult getUnloadResult(@RequestBody(required=false) Map<String,Object> mapValue,
                                            Integer apiId,
                                            Integer pageNum,
-                                           Integer pageSize
+                                           Integer pageSize,
+                                           Integer orderType
     ){
+        mapValue.put("orderTypee", orderType);
         //不分页筛选数据
         List<Map<String, Object>> allUnloadResult = tmstruckUnloadResultService.getUnloadResult(mapValue);
         PageHelper.startPage(pageNum,pageSize);
@@ -72,7 +75,7 @@ public class TmstruckUnloadResultController extends BaseRESTfulController {
     }
 
 
-    @ApiOperation(value="新增卸货实绩 ")
+    @ApiOperation(value="新增卸货实绩：远程调用")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "mapValue", value = "总实绩ID、卸货点", required = false, dataType = "Map"),
     })

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

@@ -13,6 +13,7 @@ import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -66,12 +67,9 @@ public class TmstruckWeightResultController extends BaseRESTfulController {
                                                Integer pageSize,
                                                Integer orderType
     ){
-        if (mapValue == null){
-            mapValue = new HashMap<>();
-        }
-        if(orderType != null){
-            mapValue.put("orderTypee", orderType);
-        }
+
+        mapValue.put("orderTypee", orderType);
+
         //不分页筛选数据
         List<Map<String, Object>> allJiMaoResult = tmstruckWeightResultService.getAllJiMaoResult(mapValue);
         PageHelper.startPage(pageNum,pageSize);
@@ -96,12 +94,8 @@ public class TmstruckWeightResultController extends BaseRESTfulController {
                                            Integer pageSize,
                                            Integer orderType
     ){
-        if (mapValue == null){
-            mapValue = new HashMap<>();
-        }
-        if(orderType != null){
-            mapValue.put("orderTypee", orderType);
-        }
+
+        mapValue.put("orderTypee", orderType);
         //不分页筛选数据
         List<Map<String, Object>> allJiMaoResult = tmstruckWeightResultService.getAllJiPiResult(mapValue);
         PageHelper.startPage(pageNum,pageSize);
@@ -130,6 +124,15 @@ public class TmstruckWeightResultController extends BaseRESTfulController {
         int i = tmstruckWeightResultService.addJiPiResult(mapValue);
         return success(i);
     }
+
+    /**
+     *通过运输订单判断下一步是否需要计量,更新汽车衡到计量实绩中
+     */
+    @PostMapping("/updateTruckCalculate/{orderId}")
+    public RESTfulResult updateTruckCalculate(@PathVariable("orderId") Integer orderId){
+        int i=tmstruckWeightResultService.isNextNeedJl(new BigDecimal(orderId));
+        return  success(i);
+    }
 }
 
   

src/main/java/com/steerinfo/dil/feign/JoinFeign.java

@@ -0,0 +1,22 @@
+package com.steerinfo.dil.feign;
+
+import com.steerinfo.framework.controller.RESTfulResult;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.math.BigDecimal;
+import java.util.Map;
+
+/**
+ * @author luobang
+ * @create 2021-10-29 11:23
+ */
+@FeignClient(value = "dil-join-api-dev", url = "${openfeign.JoinFeign.url}")
+public interface JoinFeign {
+    @PostMapping("/api/v1/join/tmsTruckSms/insertSms")
+    public boolean push(@RequestBody(required = false)Map<String, Object> map2) ;
+
+
+}

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

@@ -15,8 +15,8 @@ public interface TmstruckLeaveFactoryResultMapper extends IBaseMapper<TmstruckLe
     @Select("select seq_tmstruck_leavefactory.nextval from dual")
     BigDecimal selectMaxId();
 
-    //查询所有的出厂实绩、
-    List<Map<String, Object>> getLeaveFactoryResult(Map<String, Object> map);
+    //查询采购所有的出厂实绩、
+    List<Map<String, Object>> getCGLeaveFactoryResult(Map<String, Object> map);
 
     //查询运输路线是否为出厂
     Integer selectTransportRoute(String orderNumber);

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

@@ -22,5 +22,5 @@ public interface TmstruckReceiptResultMapper extends IBaseMapper<TmstruckReceipt
     int updateByTotalResultId(TmstruckReceiptResult tmstruckReceiptResult);
 
     //查询所有收货实绩
-    List<Map<String, Object>> getReceiptResult(Map<String, Object> map);
+    List<Map<String, Object>> getCGReceiptResult(Map<String, Object> map);
 }

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

@@ -20,4 +20,7 @@ public interface TmstruckSmsRusultMapper extends IBaseMapper<TmstruckSmsRusult,
     String selectCarDriverByOrderNumber(String orderNumber);
     //查询短信实绩
     List<Map<String,Object>> selectSmsResult(Map<String,Object> map);
+
+    Map<String,Object> selectIdApp(BigDecimal bigDecimal);
+
 }

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

@@ -17,4 +17,6 @@ public interface TmstruckTotalResultMapper extends IBaseMapper<TmstruckTotalResu
 
     //查询计数作业
     List<Map<String,Object>> selectCountList(Map<String,Object> map);
+    //查询包月作业
+    List<Map<String, Object>> getTmstruckMonthResult(Map<String, Object> mapValue);
 }

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

@@ -11,8 +11,8 @@ import java.util.Map;
 
 @Mapper
 public interface TmstruckUnloadResultMapper extends IBaseMapper<TmstruckUnloadResult, BigDecimal> {
-    //查询卸货实绩
-    List<Map<String, Object>> getUnloadResult(Map<String, Object> map);
+    //查询采购卸货实绩
+    List<Map<String, Object>> getCGUnloadResult(Map<String, Object> map);
 
     //查询最大ID值
     @Select("select seq_tmstruck_unload_result.nextval from dual")

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

@@ -22,16 +22,23 @@ public interface TmstruckWeightResultMapper extends IBaseMapper<TmstruckWeightRe
     //通过汽车衡编号查询汽车衡ID
     Integer selectTruckCalculateId(String truckCalculateNumber);
 
-    //查询所有计毛实绩
-    List<Map<String, Object>> getAllJiMaoResult(Map<String, Object> map);
+    //查询采购所有计毛实绩
+    List<Map<String, Object>> getCGAllJiMaoResult(Map<String, Object> map);
 
     //查询所有计皮实绩
-    List<Map<String, Object>> getAllJiPiResult(Map<String, Object> map);
+    List<Map<String, Object>> getCGAllJiPiResult(Map<String, Object> map);
 
     //查询订单下所有的物资件数和物资理重
     List<Map<String, Object>> getMaterialMes(Integer orderId);
 
     //通过物资ID查询应该在哪个汽车衡计量
     List<Integer> getCalculateIdByMaterial(BigDecimal material);
-
+    //通过运输订单id获取路段顺序号、物资类型、计量实绩主键、line_id
+    Map<BigDecimal, String> selectByOrderId(BigDecimal orderId);
+    /**
+     * 通过物料、性质判断所去的汽车衡
+     */
+    BigDecimal getTruckCalculateNumber(BigDecimal materialTypeId, BigDecimal bigDecimal);
+
+    List<BigDecimal> getNextStep(BigDecimal lineId, int orderLineSequence);
 }

src/main/java/com/steerinfo/dil/service/ITmstruckLoadResultService.java

@@ -24,7 +24,7 @@ public interface ITmstruckLoadResultService{
     List<Map<String, Object>> getAllLoadResult(Map<String, Object> map);
 
     //新增装车实绩
-    int addLoadResult(Map<String, Object> map);
+    int addCGLoadResult(Map<String, Object> map);
 
     //新增虚拟装车实绩
     int addSaleLoadResult(Map<String, Object> map);

src/main/java/com/steerinfo/dil/service/ITmstruckTotalResultService.java

@@ -14,4 +14,6 @@ public interface ITmstruckTotalResultService {
     public int addTotalResult(BigDecimal orderId);
     //查询计数作业
     List<Map<String,Object>> selectCountList(Map<String,Object> map);
+    //查询包月作业
+    List<Map<String, Object>> getTmstruckMonthResult(Map<String, Object> mapValue);
 }

src/main/java/com/steerinfo/dil/service/ITmstruckWeightResultService.java

@@ -35,4 +35,8 @@ public interface ITmstruckWeightResultService{
 
     //通过物资ID查询应该在哪个汽车衡计量
     int getCalculateIdByMaterial(BigDecimal materialId);
+    /**
+     *通过运输订单判断下一步是否需要计量,更新汽车衡到计量实绩中
+     */
+    int isNextNeedJl(BigDecimal bigDecimal);
 }

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

@@ -91,14 +91,8 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
 
                 break;
             case 5:
-
-                break;
             case 6:
-
-                break;
             case 7:
-
-                break;
             case 8:
                 return tmstruckEnfactoryResultMapper.getCGJKEnFactoryResult(map);
             case 9:

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

@@ -104,13 +104,10 @@ public class TmstruckLeaveFactoryResultServiceImpl implements ITmstruckLeaveFact
 
                 break;
             case 5:
-                break;
             case 6:
-                break;
             case 7:
-                break;
             case 8:
-                return tmstruckLeaveFactoryResultMapper.getLeaveFactoryResult(map);
+                return tmstruckLeaveFactoryResultMapper.getCGLeaveFactoryResult(map);
             case 9:
                 break;
             case 10:
@@ -152,7 +149,7 @@ public class TmstruckLeaveFactoryResultServiceImpl implements ITmstruckLeaveFact
             case 8:
                 i += updateLeaveResultByPDA(map); //更新出厂实绩
                 i += utilsService.updateOrderStatus(map, 2); // 修改运输订单状态 2：已结束
-                i += utilsService.updateCapacityStatus(map, 0); //修改运力状态 0：空闲中
+//                i += utilsService.updateCapacityStatus(map, 0); //修改运力状态 0：空闲中
                 //采购出厂 通过feign调用新增详单
                 try {
                     bmsShipFeign.addDetailsOrder(DataChange.dataToBigDecimal(map.get("resultId"))); // 出厂实绩Id

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

@@ -103,6 +103,7 @@ public class TmstruckLoadResultServiceImpl implements ITmstruckLoadResultService
     }
 
     /**
+
      * 添加装货实绩
      *
      * @param map
@@ -112,6 +113,50 @@ public class TmstruckLoadResultServiceImpl implements ITmstruckLoadResultService
         return 0;
     }
 
+        /**
+         *
+         */
+    @Transactional
+    public int addCGLoadResult(Map<String,Object> map){
+        //通过运输订单号 或 运单Id 查询实绩总表ID  此方法在 进厂作业mapper中
+        Integer totalId = tmstruckEnfactoryResultMapper.selectOrderIdByCpAndOn(map);
+        // 新增装车实绩
+        TmstruckLoadResult tmstruckLoadResult = new TmstruckLoadResult();
+        //添加主键Id
+        tmstruckLoadResult.setResultId(tmstruckLoadResultMapper.selectMaxId());
+        //新增计量吨位 装车所装的重量
+        BigDecimal resultMeasuredTonnage = DataChange.dataToBigDecimal(map.get("resultMeasuredTonnage"));
+        tmstruckLoadResult.setResultMeasuredTonnage(resultMeasuredTonnage);
+        tmstruckLoadResult.setStatus(new BigDecimal(0));
+        tmstruckLoadResult.setResultTotalId(new BigDecimal(totalId));
+        String resultIsclear = (String) (map.get("resultIsclear"));
+        tmstruckLoadResult.setResultIsclear(resultIsclear);
+        tmstruckLoadResult.setResultLoadStartTime(new Date((long) map.get("resultLoadStartTime")));
+        tmstruckLoadResult.setInsertUpdateRemark((String) map.get("insertUpdateRemark"));
+        int i = tmstruckLoadResultMapper.insertSelective(tmstruckLoadResult);
+
+        //修改订单状态为执行中 1
+        int i1 = utilsService.updateOrderStatus(map, 1);
+
+        //修改运力状态为执行中 1
+//        int i2 = utilsService.updateCapacityStatus(map, 1);
+
+//        //新增港存库出库实绩 并修改实时库存
+//        BigDecimal portId = tmstruckLoadResultMapper.getPortIdBySendStationId(DataChange.dataToBigDecimal(map.get("loadingId")));
+//        if(portId != null){
+//            BigDecimal batchId = tmstruckLoadResultMapper.getBatchIdByOrderId(DataChange.dataToBigDecimal(map.get("orderId")));
+//            if(batchId != null){
+//                Map<String, Object> hashMap = new HashMap<>();
+//                hashMap.put("batchId", batchId);
+//                hashMap.put("portId", portId);
+//                hashMap.put("resultTonnage",resultMeasuredTonnage);
+//                hashMap.put("isClean", resultIsclear);
+//                wmshBoundFeign.addResult(hashMap);
+//            }
+//        }
+        return i + i1;
+    }
+
 
     /**
      * 遗留问题  （销售装车）

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

@@ -53,16 +53,10 @@ public class TmstruckReceiptResultServiceImpl implements ITmstruckReceiptResultS
 
                 break;
             case 5:
-
-                break;
             case 6:
-
-                break;
             case 7:
-
-                break;
             case 8:
-                return tmstruckReceiptResultMapper.getReceiptResult(map);
+                return tmstruckReceiptResultMapper.getCGReceiptResult(map);
             case 9:
                 break;
             case 10:

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

@@ -1,16 +1,20 @@
 package com.steerinfo.dil.service.impl;
 
+import com.steerinfo.dil.feign.JoinFeign;
 import com.steerinfo.dil.mapper.TmstruckLeaveFactoryResultMapper;
 import com.steerinfo.dil.mapper.TmstruckSmsRusultMapper;
 import com.steerinfo.dil.model.TmstruckSmsRusult;
 import com.steerinfo.dil.service.ITmstruckSmsRusultService;
+import com.steerinfo.dil.util.MD5Util;
 import com.steerinfo.framework.mapper.IBaseMapper;
 import com.steerinfo.framework.service.impl.BaseServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+
 import java.math.BigDecimal;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -34,6 +38,8 @@ public class TmstruckSmsRusultServiceImpl extends BaseServiceImpl<TmstruckSmsRus
     private TmstruckSmsRusultMapper tmstruckSmsRusultMapper;
     @Autowired
     private TmstruckLeaveFactoryResultMapper tmstruckLeaveFactoryResultMapper;
+    @Autowired
+    JoinFeign joinFeign;
 //    @Autowired
 //    private OmstruckOrderMapper omstruckOrderMapper;
 
@@ -64,15 +70,41 @@ public class TmstruckSmsRusultServiceImpl extends BaseServiceImpl<TmstruckSmsRus
         Integer shipperId = tmstruckSmsRusultMapper.selectShipperIdByOrderNumber(orderNumber);
         //设置发送方id
         tmstruckSmsRusult.setSenderId(new BigDecimal(shipperId));
+        //通过发送方ID查询appId和秘钥
+        Map<String,Object>map5=tmstruckSmsRusultMapper.selectIdApp(new BigDecimal(shipperId));
+        String AppId= (String) map5.get("AppId");
+        String secretKey=(String) map5.get("secretKey");
+
         tmstruckSmsRusult.setResultSendingTime(new Date());
         //根据运输订单号查找司机电话号码
         String driverPhone=tmstruckSmsRusultMapper.selectCarDriverByOrderNumber(orderNumber);
+        String content="您好!您在达钢购买的钢材已发车，司机电话"+driverPhone+"欲知详情，请前往xxxxx地址，下载APP 达钢物流";
         tmstruckSmsRusult.setResultSmsContent("您好!您在达钢购买的钢材已发车，司机电话"+driverPhone+"欲知详情，请前往xxxxx地址，下载APP 达钢物流");
+
         //新增短信实绩
         tmstruckSmsRusult.setInsertTime(new Date());
-//        tmstruckSmsRusult.setInsertUsername(personnelName);
-        int i=tmstruckSmsRusultMapper.insertSelective(tmstruckSmsRusult);
-        return i;
+        //调用接口发送短信
+        Map<String, Object> map2 = new HashMap<>();
+        String timestamp=String.valueOf(new Date().getTime());
+        String sign=AppId+secretKey+timestamp;
+        try {
+            String signMd5=MD5Util.md5Encode(sign);
+            map2.put("sign",signMd5);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+      	map2.put("AppId",AppId);
+        map2.put("timestamp",timestamp);
+        map2.put("content",content);
+        map2.put("mobiles",driverPhone);
+        if (joinFeign.push(map2)){
+            int i=tmstruckSmsRusultMapper.insertSelective(tmstruckSmsRusult);
+            return i;
+        }
+        else return 0;
+
+
+
     }
 
     @Override

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

@@ -45,5 +45,12 @@ public class TmstruckTotalResultServiceImpl implements ITmstruckTotalResultServi
     public List<Map<String, Object>> selectCountList(Map<String, Object> map) {
         return tmstruckTotalResultMapper.selectCountList(map);
     }
-
+    /**
+     * 展示包月实绩列表
+     * @param map
+     * @return
+     */
+    public List<Map<String, Object>> getTmstruckMonthResult(Map<String, Object> mapValue) {
+        return tmstruckTotalResultMapper.getTmstruckMonthResult(mapValue);
+    }
 }

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

@@ -100,16 +100,10 @@ public class TmstruckUnloadResultServiceImpl implements ITmstruckUnloadResultSer
 
                 break;
             case 5:
-
-                break;
             case 6:
-
-                break;
             case 7:
-
-                break;
             case 8:
-                return tmstruckUnloadResultMapper.getUnloadResult(map);
+                return tmstruckUnloadResultMapper.getCGUnloadResult(map);
             case 9:
                 break;
             case 10:

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

@@ -64,16 +64,10 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
 
                 break;
             case 5:
-
-                break;
             case 6:
-
-                break;
             case 7:
-
-                break;
             case 8:
-                return tmstruckWeightResultMapper.getAllJiMaoResult(map);
+                return tmstruckWeightResultMapper.getCGAllJiMaoResult(map);
             case 9:
                 break;
             case 10:
@@ -107,16 +101,10 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
 
                 break;
             case 5:
-
-                break;
             case 6:
-
-                break;
             case 7:
-
-                break;
             case 8:
-                return tmstruckWeightResultMapper.getAllJiPiResult(map);
+                return tmstruckWeightResultMapper.getCGAllJiPiResult(map);
             case 9:
                 break;
             case 10:
@@ -178,9 +166,19 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
         DecimalFormat df =  new DecimalFormat("0.00");
         String resultGrossWeight = df.format((double) map.get("resultGrossWeight"));
         tmstruckWeightResult.setResultGrossWeight(new BigDecimal(resultGrossWeight));
+        //添加毛重时间
+        long resultGrossWeightTime = (long) map.get("resultGrossWeightTime");
+        tmstruckWeightResult.setResultGrossWeightTime(new Date(resultGrossWeightTime));
+
+        //通过汽车衡编号查询汽车衡ID
+        Integer calculateId = tmstruckWeightResultMapper.selectTruckCalculateId((String) map.get("truckCalculateNumber"));
+        //添加计毛汽车衡
+        if(calculateId != null){
+            tmstruckWeightResult.setResultGrossPlaceId(new BigDecimal(calculateId));
+        }
         Integer lineSequence = null; //路段顺序号
-        Integer orderType = (Integer) map.get("orderTypee");
-        switch (orderType){
+        BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderTypee"));
+        switch (orderType.intValue()){
             //如果订单类型为销售订单 则执行销售订单计皮规则 resultTareWeight
             case 1:
                 //计算净重  从map中获取皮重 tareWeight
@@ -190,23 +188,27 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
                 addUpdateRegularField(tmstruckWeightResult); //插入第二次计重时间
                 lineSequence = 5; //设置路段顺序号为5：出厂
                 break;
-            //采购订单记录计毛为第一次计重
+            case 2:
+                break;
             case 3:
-                addInsertRegularField(tmstruckWeightResult); //插入第一次计重时间
-                lineSequence = 5; //设置路段顺序号为5：出厂
-        }
-
-        //通过汽车衡编号查询汽车衡ID
-        Integer calculateId = tmstruckWeightResultMapper.selectTruckCalculateId((String) map.get("truckCalculateNumber"));
-        //添加计毛汽车衡
-        if(calculateId != null){
-            tmstruckWeightResult.setResultGrossPlaceId(new BigDecimal(calculateId));
+                break;
+            case 4:
+                break;
+            case 5:
+            case 6:
+            case 7:
+            case 8: //采购订单记录计毛为第一次计重 添加磅单号
+                tmstruckWeightResult.setResultPoundNo((String) map.get("resultPoundNo"));
+                addInsertRegularField(tmstruckWeightResult); //插入第一次计重时间常规字段
+                lineSequence = 5; //设置路段顺序号为3：卸货
+                break;
+            case 9:
+                break;
+            case 10:
+                break;
+            case 11:
+                break;
         }
-        //添加磅单号
-        tmstruckWeightResult.setResultPoundNo((String) map.get("resultPoundNo"));
-        //添加毛重时间
-        long resultGrossWeightTime = (long) map.get("resultGrossWeightTime");
-        tmstruckWeightResult.setResultGrossWeightTime(new Date(resultGrossWeightTime));
 
         int i = tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
         //更新订单路段顺序号
@@ -241,12 +243,29 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
         //添加皮重时间
         long resultTareWeightTime = (long) map.get("resultTareWeightTime");
         tmstruckWeightResult.setResultTareWeightTime(new Date(resultTareWeightTime));
-
+        //通过汽车衡编号查询汽车衡ID 添加计皮汽车衡
+        Integer calculateId = tmstruckWeightResultMapper.selectTruckCalculateId((String) map.get("truckCalculateNumber"));
+        if(calculateId != null){
+            tmstruckWeightResult.setResultTarePlaceId(new BigDecimal(calculateId));
+        }
         int i1 = 0;
-        Integer orderType = (Integer) map.get("orderTypee");
-        switch (orderType){
-            //如果订单类型为采购订单 则执行采购订单计皮规则
+        Integer lineSequence = null; //路段顺序号
+        BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderTypee"));
+        switch (orderType.intValue()){
+            case 1: //销售订单计皮为第一次计重
+                tmstruckWeightResult.setResultPoundNo((String) map.get("resultPoundNo"));
+                addInsertRegularField(tmstruckWeightResult);// 添加插入常规字段 就是第一次计重时间
+                break;
+            case 2:
+                break;
             case 3:
+                break;
+            case 4:
+                break;
+            case 5:
+            case 6:
+            case 7:
+            case 8:  //如果订单类型为采购订单 则执行采购订单计皮规则
                 //计算净重  先从map中获取毛重 grossWeight
                 double netWeight = ((BigDecimal) map.get("grossWeight")).doubleValue() - ((Double) map.get("resultTareWeight"));
                 String resultNetWeight = df.format(netWeight);
@@ -259,21 +278,18 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
                 tmstruckReceiptResult.setInsertUsername("admin");
                 tmstruckReceiptResult.setInsertTime(new Date());
                 i1 = tmstruckReceiptResultMapper.updateByTotalResultId(tmstruckReceiptResult);
+                lineSequence = 5; // 出厂
+                break;
+            case 9:
+                break;
+            case 10:
+                break;
+            case 11:
                 break;
-            //销售订单计皮为第一次计重
-            case 1:
-                addInsertRegularField(tmstruckWeightResult);// 添加插入常规字段 就是第一次计重时间
-        }
-
-        //通过汽车衡编号查询汽车衡ID
-        Integer calculateId = tmstruckWeightResultMapper.selectTruckCalculateId((String) map.get("truckCalculateNumber"));
-        //添加计皮汽车衡
-        if(calculateId != null){
-            tmstruckWeightResult.setResultTarePlaceId(new BigDecimal(calculateId));
         }
         int i = tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
         //更新订单路段顺序号
-        int i2 = utilsService.updateOrderLineSequence(map, 4);
+        int i2 = utilsService.updateOrderLineSequence(map, lineSequence);
         return i + i1 + i2;
     }
 
@@ -295,4 +311,111 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
         tmstruckWeightResult.setUpdateTime(new Date());
         tmstruckWeightResult.setUpdateUsername("admin");
     }
+    /**
+     *通过运输订单判断下一步是否需要计量,更新汽车衡到计量实绩中
+     */
+    @Override
+    public int isNextNeedJl(BigDecimal orderId) {
+        //通过运输订单id获取路段顺序号、物资类型、计量实绩主键、line_id
+        Map<BigDecimal,String> map=tmstruckWeightResultMapper.selectByOrderId(orderId);
+        //通过运输订单id获取物资的类型
+        BigDecimal materialTypeId=new BigDecimal(map.get("materialTypeId").toString());
+        //获取路段顺序号
+        BigDecimal orderLineSequence=new BigDecimal(map.get("orderLineSequence").toString());
+        //计量实绩主键
+        BigDecimal weightTaskResultId=new BigDecimal(map.get("weightTaskResultId").toString());
+        //line_id
+        BigDecimal lineId=new BigDecimal(map.get("lineId").toString());
+        //通过运输线路判断下一步是否为计量，当前是啥，下下一步是啥
+        //如果下一步为计量，且当前步为进厂，则选择进厂称，如果下下步为出厂则选择出厂称，其他则选择中转称
+        List<BigDecimal> list=getNextStep(lineId,orderLineSequence.intValue());
+        if(list.size()==3){
+            //0:进厂；1：计毛；2：计皮；3：卸货；4：装货；5：出厂
+            if(list.get(1).intValue()==1 || list.get(1).intValue()==2){
+                //如果当前为进厂
+                if(list.get(0).intValue()==0){
+                    //获取到汽车衡id
+                    BigDecimal truckCalculateId =tmstruckWeightResultMapper.getTruckCalculateNumber(materialTypeId,new BigDecimal(1));
+                    //将获取到的汽车衡id更新到计量实绩表中
+                    //如果下一步为计毛作业
+                    if(list.get(1).intValue()==1){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultGrossPlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                    //如果下一步为计皮作业
+                    if(list.get(1).intValue()==2){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultTarePlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                }
+                //如果计量后一步为出厂
+                else if(list.get(2).intValue()==5){
+                    //获取到汽车衡id
+                    BigDecimal truckCalculateId =tmstruckWeightResultMapper.getTruckCalculateNumber(materialTypeId,new BigDecimal(2));
+                    //将获取到的汽车衡id更新到计量实绩表中
+                    //如果下一步为计毛作业
+                    if(list.get(1).intValue()==1){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultGrossPlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                    //如果下一步为计皮作业
+                    if(list.get(1).intValue()==2){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultTarePlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                }else{
+                    //获取到汽车衡id
+                    BigDecimal truckCalculateId =tmstruckWeightResultMapper.getTruckCalculateNumber(materialTypeId,new BigDecimal(3));
+                    //将获取到的汽车衡id更新到计量实绩表中
+                    //如果下一步为计毛作业
+                    if(list.get(1).intValue()==1){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultGrossPlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                    //如果下一步为计皮作业
+                    if(list.get(1).intValue()==2){
+                        //通过订单号获取计量实绩主键，并更新
+                        TmstruckWeightResult tmstruckWeightResult=new TmstruckWeightResult();
+                        tmstruckWeightResult.setWeightTaskResultId(weightTaskResultId);
+                        tmstruckWeightResult.setResultTarePlaceId(truckCalculateId);
+                        tmstruckWeightResult.setUpdateTime(new Date());
+                        tmstruckWeightResult.setUpdateUsername("admin");
+                        tmstruckWeightResultMapper.updateByPrimaryKeySelective(tmstruckWeightResult);
+                    }
+                }
+            }
+        }else {
+            return 0;
+        }
+        return 0;
+    }
+
+    public List<BigDecimal> getNextStep(BigDecimal lineId, int orderLineSequence) {
+        return tmstruckWeightResultMapper.getNextStep(lineId,orderLineSequence);
+    }
 }

src/main/java/com/steerinfo/dil/util/MD5Util.java

@@ -0,0 +1,50 @@
+package com.steerinfo.dil.util;
+
+import java.security.MessageDigest;
+
+/**
+ * @author luobang
+ * @create 2021-10-29 10:16
+ */
+
+    public class MD5Util {
+        /***
+         * MD5加密 生成32位md5码
+         *
+         * @param 待加密字符串
+         * @return 返回32位md5码
+         */
+        public static String md5Encode(String inStr) throws Exception {
+            MessageDigest md5 = null;
+            try {
+                md5 = MessageDigest.getInstance("MD5");
+            } catch (Exception e) {
+                System.out.println(e.toString());
+                e.printStackTrace();
+                return "";
+            }
+
+            byte[] byteArray = inStr.getBytes("UTF-8");
+            byte[] md5Bytes = md5.digest(byteArray);
+            StringBuffer hexValue = new StringBuffer();
+            for (int i = 0; i < md5Bytes.length; i++) {
+                int val = ((int) md5Bytes[i]) & 0xff;
+                if (val < 16) {
+                    hexValue.append("0");
+                }
+                hexValue.append(Integer.toHexString(val));
+            }
+            return hexValue.toString();
+        }
+
+        /**
+         *测试
+         * @throws Exception
+         */
+        public static void main(String[] args) throws Exception {
+            String str = "123456";
+            System.out.println(MD5Util.md5Encode(str));
+        }
+
+    }
+

src/main/resources/bootstrap.yml

@@ -27,6 +27,8 @@ openfeign:
     url: ${WMSHBOUNDFEIGN_URL:localhost:8093}
   OmsFeign:
     url: ${OMSFEIGN_URL:localhost:8095}
+  JoinFeign:
+    url: ${JOINFEIGN_URL:localhost:8066}
 
 
 #eureka设置

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

@@ -83,12 +83,15 @@
 <!--    获取辅料车辆 并且为空闲状态 -->
     <select id="getFuCapacityId" resultType="java.util.LinkedHashMap">
         select
-            RC.CAPACITY_ID "id",
-            RC.CAPACITY_ID "value",
+            RDC.DRIVER_CAPACITY_ID "id",
+            RDC.DRIVER_CAPACITY_ID "value",
             RC.CAPACITY_NUMBER "label"
         from
-            RMS_CAPACITY RC
-        where RC.CAPACITY_STATUS = 0 and RC.CARRIER_ID = 2
+            RMS_DRIVER_CAPACITY RDC
+            left join RMS_CAPACITY RC
+            on RC.CAPACITY_ID = RDC.CAPACITY_ID
+        where RC.CAPACITY_STATUS = 0 and RC.CAPACITY_TYPE_ID = 1
+--           and RC.CARRIER_ID = 2
     </select>
 
 <!--    获取所有的港口 -->

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

@@ -459,8 +459,10 @@
                             on APO.PURCHASE_ORDER_ID = OO.ORDER_PLAN_ID
                   left join DIL_BATCH DB
                             on DB.BATCH_ID = APO.BATCH_ID
+                  left join RMS_DRIVER_CAPACITY RDC
+                            on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
                   left join RMS_CAPACITY RC
-                            on RC.CAPACITY_ID = OO.CAPACITY_ID
+                            on RC.CAPACITY_ID = RDC.CAPACITY_ID
                   left join RMS_SUPPLIER RS
                             on RS.SUPPLIER_ID = APO.SUPPLIER_UNIT_ID
                   left join RMS_CONSIGNEE RCON

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

@@ -440,7 +440,7 @@
     </sql>
 
     <!-- 查询所有的出厂实绩 -->
-    <select id="getLeaveFactoryResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
+    <select id="getCGLeaveFactoryResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
         select *
         from (
         select
@@ -467,12 +467,14 @@
             on OOM.ORDER_ID = OO.ORDER_ID
         left join RMS_MATERIAL RM
             on RM.MATERIAL_ID = OOM.MATERIAL_ID
+        left join RMS_DRIVER_CAPACITY RDC
+            on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
         left join RMS_CAPACITY RC
-            on RC.CAPACITY_ID = OO.CAPACITY_ID
+            on RC.CAPACITY_ID = RDC.CAPACITY_ID
         left join RMS_GATEPOST RG
             on RG.GATEPOST_ID = TLFR.GATEPOST_ID
 
-        where RESULT_OUT_GATE_TIME is not null
+        where RESULT_OUT_GATE_TIME is not null and OO.ORDER_TYPE = #{orderTypee}
         )
         <where>
             <if test="purchaseOrderNo != null">

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

@@ -612,13 +612,15 @@
                             on DB.BATCH_ID = APO.BATCH_ID
                   left join RMS_MATERIAL RM
                             on OOM.MATERIAL_ID = RM.MATERIAL_ID
+                  left join RMS_DRIVER_CAPACITY RDC
+                            on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
                   left join RMS_CAPACITY RC
-                            on RC.CAPACITY_ID = OO.CAPACITY_ID
+                            on RC.CAPACITY_ID = RDC.CAPACITY_ID
                   left join RMS_SUPPLIER RS
                             on RS.SUPPLIER_ID = APO.SUPPLIER_UNIT_ID
                   left join RMS_CONSIGNEE RCON
                             on RCON.CONSIGNEE_ID = APO.RECEIVE_UNIT_ID
-           where TLR.STATUS = #{status}
+           where TLR.STATUS = #{status} and OO.ORDER_TYPE = #{orderTypee}
          )
     <where>
       <if test="purchaseOrderId != null">

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

@@ -453,7 +453,7 @@
   </sql>
 
 <!--  查询所有签收实绩 -->
-  <select id="getReceiptResult" parameterType="java.util.Map" resultType="java.util.Map">
+  <select id="getCGReceiptResult" parameterType="java.util.Map" resultType="java.util.Map">
     select
            *
     from (
@@ -477,8 +477,10 @@
                             on APO.PURCHASE_ORDER_ID = OO.ORDER_PLAN_ID
                   left join DIL_BATCH DB
                             on DB.BATCH_ID = APO.BATCH_ID
+                  left join RMS_DRIVER_CAPACITY RDC
+                            on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
                   left join RMS_CAPACITY RC
-                            on RC.CAPACITY_ID = OO.CAPACITY_ID
+                            on RC.CAPACITY_ID = RDC.CAPACITY_ID
                   left join TMSTRUCK_WEIGHT_RESULT TWR
                             on TWR.RESULT_TOTAL_ID = TRR.RESULT_TOTAL_ID
                   left join TMSTRUCK_UNLOAD_RESULT TUR
@@ -489,7 +491,7 @@
                             on OOM.MATERIAL_ID = RM.MATERIAL_ID
                   left join RMS_WAREHOUSE RW
                             on RW.WAREHOUSE_ID = TUR.RESULT_UNLOAD_PLACE_ID
-                where TRR.STATUS = 1
+                where TRR.STATUS = 1 and OO.ORDER_TYPE = #{orderTypee}
          )
         <where>
           <if test="purchaseOrderNo != null">

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

@@ -368,4 +368,11 @@
     left join RMS_SHIPPER RS
     on TSR.SENDER_ID=RS.SHIPPER_ID
   </select>
+    <select id="selectIdApp" resultType="java.util.Map">
+      select
+      rs.SHIPPER_APPID "AppId",
+        rs.SHIPPER_SECRETKEY "secretKey"
+      from RMS_SHIPPER RS
+      where rs.SHIPPER_ID=#{bigDecimal}
+    </select>
 </mapper>

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

@@ -383,4 +383,13 @@
     WHERE AIR.REQUIREMENT_TYPE=2 AND RW.WAREHOUSE_TYPE_ID=3
       AND  OO.ORDER_STATUS=4
   </select>
+  <!-- 查询所有的包月作业实绩 -->
+  <select id="getTmstruckMonthResult" parameterType="java.util.Map" resultType="java.util.Map">
+    select * from tmstruck_total_result  ttr
+                    left join omstruck_order oo on ttr.order_id=oo.order_id
+                    left join amstruck_inward_plan aip on oo.order_plan_id=aip.plan_id
+                    left join amstruck_requirement_plan arp on aip.plan_id=arp.plan_id
+                    left join amstruck_inward_requirement air on arp.requirement_plan_id=air.requirement_id
+    where oo.order_type=4 and air.requirement_type=3
+  </select>
 </mapper>

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

@@ -492,8 +492,8 @@
         </if>
     </sql>
 
-    <!-- 获取卸货实绩 -->
-    <select id="getUnloadResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
+    <!-- 获取采购卸货实绩 -->
+    <select id="getCGUnloadResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
         select *
         from (
         select
@@ -519,11 +519,13 @@
         on OOM.ORDER_ID = OO.ORDER_ID
         left join RMS_MATERIAL RM
         on OOM.MATERIAL_ID = RM.MATERIAL_ID
+        left join RMS_DRIVER_CAPACITY RDC
+        on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
         left join RMS_CAPACITY RC
-        on RC.CAPACITY_ID = OO.CAPACITY_ID
+        on RC.CAPACITY_ID = RDC.CAPACITY_ID
         left join RMS_WAREHOUSE RW
         on RW.WAREHOUSE_ID = TUR.RESULT_UNLOAD_PLACE_ID
-        where RESULT_START_TIME is not null
+        where RESULT_START_TIME is not null and OO.ORDER_TYPE = #{orderTypee}
         )
         <where>
             <if test="purchaseOrderNo != null">

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

@@ -564,7 +564,7 @@
   </select>
 
   <!--  查询所有的计毛实绩  -->
-  <select id="getAllJiMaoResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
+  <select id="getCGAllJiMaoResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
     select *
     from (
     select
@@ -585,8 +585,10 @@
     on TTR.ORDER_ID = OO.ORDER_ID
     left join AMS_PURCHASE_ORDER APO
     on APO.PURCHASE_ORDER_ID = OO.ORDER_PLAN_ID
+        left join RMS_DRIVER_CAPACITY RDC
+            on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
     left join RMS_CAPACITY RC
-    on RC.CAPACITY_ID = OO.CAPACITY_ID
+    on RC.CAPACITY_ID = RDC.CAPACITY_ID
     left join RMS_TRUCK_CALCULATE RTC
     on RTC.TRUCK_CALCULATE_ID = TWR.RESULT_GROSS_PLACE_ID
     left join OMSTRUCK_ORDER_MATERIAL OOM
@@ -597,7 +599,7 @@
     on RS.SUPPLIER_ID = APO.SUPPLIER_UNIT_ID
     left join RMS_CONSIGNEE RCON
     on RCON.CONSIGNEE_ID = APO.RECEIVE_UNIT_ID
-        where RESULT_GROSS_WEIGHT_TIME is not null
+    where RESULT_GROSS_WEIGHT_TIME is not null and OO.ORDER_TYPE = #{orderTypee}
     )
     <where>
       <if test="purchaseOrderNo != null">
@@ -655,7 +657,7 @@
   </select>
 
   <!--  查询所有的计皮实绩  -->
-    <select id="getAllJiPiResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
+    <select id="getCGAllJiPiResult" parameterType="java.util.Map" resultType="java.util.LinkedHashMap">
     select *
     from (
       select
@@ -681,8 +683,10 @@
     on APO.PURCHASE_ORDER_ID = OO.ORDER_PLAN_ID
     left join DIL_BATCH DB
     on DB.BATCH_ID = APO.BATCH_ID
+    left join RMS_DRIVER_CAPACITY RDC
+        on RDC.DRIVER_CAPACITY_ID = OO.DRIVER_CAPACITY_ID
     left join RMS_CAPACITY RC
-    on RC.CAPACITY_ID = OO.CAPACITY_ID
+    on RC.CAPACITY_ID = RDC.CAPACITY_ID
     left join RMS_TRUCK_CALCULATE RTC
     on RTC.TRUCK_CALCULATE_ID = TWR.RESULT_TARE_PLACE_ID
     left join OMSTRUCK_ORDER_MATERIAL OOM
@@ -796,6 +800,7 @@
       where RM.MATERIAL_ID = #{materialId}
     </select>
 
+
 <!--计量委托查询所需数据-->
 <!--销售查询计毛 -->
   <select id="selectMakesureGrossForSaleByOrderNumber" parameterType="java.lang.String" resultType="java.util.Map">
@@ -958,4 +963,45 @@
            ON  RC.CAPACITY_ID=OO.CAPACITY_ID
     WHERE OO.ORDER_NUMBER=#{orderNumber}
   </select>
+<!--  //通过运输订单id获取路段顺序号、物资类型、计量实绩主键、line_id
+    Map<BigDecimal, String> selectByOrderId(BigDecimal orderId);-->
+    <select id="selectByOrderId" parameterType="java.math.BigDecimal" resultType="java.util.Map">
+      select oo.ORDER_LINE_SEQUENCE as "orderLineSequence",
+             oo.LINE_ID as "lineId",
+             rm.material_type_id as "materialTypeId",
+             twr.weight_task_result_id as "weightTaskResultId"
+        from omstruck_order oo
+             join omstruck_order_material oom on oom.order_id=oo.order_id
+             left join rms_material rm on oom.material_id=rm.material_id
+             left join tmstruck_total_result ttr on oo.order_id=ttr.order_id
+             left join tmstruck_weight_result twr on ttr.result_total_id=twr.result_total_id
+      where oo.order_id=#{orderId} and rownum=1 order by twr.weight_task_result_id desc
+    </select>
+
+<!--  * 通过物料、性质判断所去的汽车衡-->
+  <select id="getTruckCalculateNumber" parameterType="java.util.Map" resultType="java.math.BigDecimal">
+    select rtc.truck_calculate_id from rms_truck_calculate_material rtcm
+                                         left join rms_truck_calculate rtc on rtcm.truck_calculate_id=rtc.truck_calculate_id
+    where rtcm.material_type_id=#{materialTypeId} and rtc.nature=#{nature} and rownum=1 order by rtc.truck_calculate_priority
+  </select>
+
+  <!--    //返回下一步路段顺序号对应的终点type
+    BigDecimal getNextStep(BigDecimal lineId, int i);-->
+  <select id="getNextStep" parameterType="java.util.Map" resultType="java.math.BigDecimal">
+    select rls.segment_end_node_type
+    from rms_line_segemnt rls
+    where rls.line_id = #{lineId}
+      and rls.segment_sqe = #{orderLineSequence}
+    union
+    select rls.segment_end_node_type
+    from rms_line_segemnt rls
+    where rls.line_id = 1
+      and rls.segment_sqe = #{orderLineSequence}+1
+    union
+    select rls.segment_end_node_type
+    from rms_line_segemnt rls
+    where rls.line_id = 1
+      and rls.segment_sqe = #{orderLineSequence}+2
+
+  </select>
 </mapper>