修改计量委托

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

@@ -341,5 +341,9 @@ public interface OmstruckOrderMapper extends IBaseMapper<OmstruckOrder, BigDecim
 
     //销售：接收运输订单展示pc端界面
     List<Map<String, Object>> getDriverInfoForSale2(Map<String, Object> map);
+
     List<Map<String, Object>> getTransportOrder(Map<String, Object> mapValue);
+
+    //判断是否为达钢厂区内转
+    Map<String,Object> isInwardLine(BigDecimal orderId);
 }

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

@@ -206,5 +206,6 @@ public interface IOmstruckOrderService {
     int refuseCtrlZ(Map<String, Object> map);
 
     List<Map<String, Object>> getDriverInfoForSale2(Map<String, Object> mapValue);
+
     List<Map<String, Object>> getTransportOrder(Map<String, Object> mapValue);
 }

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

@@ -77,6 +77,8 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
     @Autowired
     JoinFeign joinFeign;
 
+    private static final String judgeInwardFactory = "化工园区铁专线内转";
+
 
     /**
      * 用于远程调用运输订单新增
@@ -116,9 +118,8 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
             case 1:
             case 2:
             case 3:
-                i = dispatchSteelOrder(map);//新增焦炭发运计划订单
-                break;
             case 4:
+                i = dispatchSteelOrder(map);//新增焦炭发运计划订单
                 break;
             case 5:
             case 6:
@@ -599,7 +600,7 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
                 result += omstruckOrderMapper.deleteTimeTaskByTotalId(resultTotalId);
             }
         }
-        if(orderType == 1){
+        if(orderType == 1||orderType == 4){
             //取消订阅车辆
             String remark = String.valueOf(mesMap.get("insertUpdateRemark"));
             if("电子围栏订阅成功".equals(remark)){
@@ -839,7 +840,7 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
                 throw new RuntimeException("订单已被接收或已被拒绝!");
             }
             int orderType = DataChange.dataToBigDecimal(orderMessage.get("orderType")).intValue();
-            if(orderType == 1){
+            if(orderType == 1||orderType==4){
                 //订阅车辆 查询车牌号
                 String capacityNumber = omstruckOrderMapper.getCapacityNumberByCapacityId(DataChange.dataToBigDecimal(orderMessage.get("capacityId")));
                 Map<String, Object> subMap = new HashMap<>();
@@ -854,16 +855,29 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
                 }
             }
             if(orderType == 11 || orderType == 15 || orderType == 16){
-                //发送计量委托
-                orderMessage.put("asd", 1);
+                //判断是否为化专线厂区内转
+                Map<String, Object> inwardLine = omstruckOrderMapper.isInwardLine(orderId);
+                String rangeValue = (String) inwardLine.get("rangeValue");
+                if (rangeValue!=null&&rangeValue.contains(judgeInwardFactory)) {
+                    //设置进厂厂区为达兴能源
+                     orderMessage.put("factory",2);
+                }else {
+                    //设置进厂厂区为达兴能源
+                     orderMessage.put("factory",1);
+                }
                 orderMessage.put("orderId", orderId);
+                orderMessage.put("asd", 1);
                 Map<String, Object> mcMap = tmsTruckFeign.sendMeasureCommission(orderMessage);
-                if(!"200".equals(mcMap.get("code"))){
+                if (!"200".equals(mcMap.get("code"))) {
                     throw new RuntimeException("委托发送失败!");
                 }
             }else if(orderType!=21){
                 //添加各个实绩
                 omstruckOrderSeparateService.addAllSonResult(orderMessage);
+            }
+            //如果订单类型为4发送钢材空委托给计量系统
+            if (orderType==4){
+
             }
             //判断订单是否是一车多单
             if (orderType ==12 || orderType ==13 || orderType ==14 || orderType ==19) {
@@ -953,7 +967,7 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
         map.put("capacityId", capacityId);
         //通过运力Id匹配 已下发的运输订单
         List<Map<String, Object>> truckOrderByCapacityNum;
-        if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2) {
+        if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2||(Integer) map.get("orderType") == 4) {
             truckOrderByCapacityNum = omstruckOrderMapper.getSaleTruckOrderByCapacityNum(map);
         } else {
             truckOrderByCapacityNum = omstruckOrderMapper.getTruckOrderByCapacityNum(map);
@@ -1294,7 +1308,7 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
         }
         //通过运力Id匹配 已下发的运输订单
         Map<String, Object> truckOrderByCapacityNum = new HashMap<>();
-        if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2) {
+        if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2||(Integer) map.get("orderType") == 4) {
             //查询主干信息
             Map<String, Object> map1 = omstruckOrderMapper.getSaleTruckOrderByCapacityId(map);
             //查询物资信息
@@ -1985,6 +1999,7 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
         String steelJudge = null;
         switch (orderType){
             case 1:
+            case 4:
                 mesMap = omstruckOrderMapper.getSteelOrderMessageToApp(map);
                 steelJudge = "steel";
                 break;
@@ -1992,7 +2007,6 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
                 mesMap = omstruckOrderMapper.getXSOrderMessageToApp(map);
                 break;
             case 3:
-            case 4:
                 mesMap = omstruckOrderMapper.getFYJHOrderMessageToApp(map);
                 break;
             case 5:

src/main/resources/application-dev.yml

@@ -1,7 +1,7 @@
 #测试环境
 spring:
   datasource:
-    url: jdbc:oracle:thin:@172.16.33.165:1521:ilsdbstd
+    url: jdbc:oracle:thin:@172.16.33.163:1521:ilsdbpri
     password: root123
     username: dagang
     driver-class-name: oracle.jdbc.OracleDriver
@@ -20,8 +20,10 @@ openfeign:
     url: ${IMFEIGN_URL:172.16.33.166:8055}
   BmsTruckFeign:
     url: ${BMSTRUCKFEIGN_URL:172.16.33.166:8009}
+  JoinFeign:
+    url: ${JOINFEIGN_URL:172.16.33.166:8066}
 
 
 server:
-  port: 8095
+  port: 8016
 

src/main/resources/application-prod.yml

@@ -5,13 +5,20 @@ spring:
     password: Dil123789
     username: dil
     driver-class-name: oracle.jdbc.OracleDriver
+    druid:
+      max-active: 20
+      max-wait: 1200
+      keep-alive: true
+      initial-size: 10
+      min-evictable-idle-time-millis: 180000
+      min-idle: 10
   application:
     name: DAL-OMS-API-PROD
 
 #feign设置
 openfeign:
   ColumnDataFeign:
-    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8083}
+    url: ${COLUMNDATAFEIGN_URL:172.16.33.161:8083}
   TmsTruckFeign:
     url: ${TMSTRUCKFEIGN_URL:172.16.33.166:8088}
   AmsFeign:

src/main/resources/bootstrap.yml

@@ -1,7 +1,7 @@
 api.version: api/v1/oms
 spring:
   profiles:
-    include: ${SPRING_PROFILES:dev}
+    include: ${SPRING_PROFILES:prod}
   jackson:
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
@@ -17,11 +17,11 @@ eureka:
   client:
     service-url:
       defaultZone: http://root:root@${EUREKA_HOST:172.16.33.166}:${EUREKA_PORT:8081}/eureka/
-    register-with-eureka: true #表示向EurekaServer注册自己 默认为true
-    fetch-registry: true #是否从EurekaServer抓取已有的注册信息，默认为true,单节点无所谓,集群必须设置为true才能配合ribbon使用负载均衡
+    register-with-eureka: false #表示向EurekaServer注册自己 默认为true
+    fetch-registry: false #是否从EurekaServer抓取已有的注册信息，默认为true,单节点无所谓,集群必须设置为true才能配合ribbon使用负载均衡
 
   instance:
-    prefer-ip-address: true
+    prefer-ip-address: false
     status-page-url: http://${spring.cloud.client.ip-address}:${server.port}/swagger-ui.html#/
     instance-id: ${spring.cloud.client.ip-address}:${server.port}
 

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

@@ -3975,5 +3975,20 @@
         where  OO.ORDER_ID=#{orderId} and OO.ORDER_STATUS = #{orderStatus}
     </select>
 
+   <!-- 判断是否为达钢厂区内转-->
+    <select id="isInwardLine" resultType="java.util.Map" parameterType="java.math.BigDecimal">
+     select RTR.TRANS_RANGE_VALUE "rangeValue"
+      from OMSTRUCK_ORDER OO
+     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 AIR.REQUIREMENT_ID =ARP.REQUIREMENT_ID
+     left join RMS_TRANS_RANGE RTR
+     ON AIR.LINE_ID = RTR.TRANS_RANGE_ID
+     WHERE  OO.ORDER_ID =#{orderId}
+    </select>
+
 
 </mapper>