HUJIANGUO 3 yıl önce
ebeveyn
işleme
bb73b2e95f

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

@@ -223,4 +223,15 @@ public class OmstruckOrderSeparateController extends BaseRESTfulController {
         int i = omstruckOrderSeparateService.updateOmstruckOrder(omstruckOrder);
         return success(i);
     }
+
+    /**
+     * 承运商销售分派运输订单给司机
+     * @param mapValue
+     * @return
+     */
+    @PostMapping("/addSaleTruckOrder")
+    public RESTfulResult addSaleTruckOrder(@RequestBody Map<String, Object> mapValue){
+        Integer result = omstruckOrderSeparateService.addSaleTruckOrder(mapValue);
+        return success(result);
+    }
 }

+ 3 - 0
src/main/java/com/steerinfo/dil/service/IOmstruckOrderSeparateService.java

@@ -17,4 +17,7 @@ public interface IOmstruckOrderSeparateService {
 
     //根据运输订单id修改运力id
     int updateOmstruckOrder(OmstruckOrder omstruckOrder);
+
+    // 承运商销售分派运输订单给司机
+    Integer addSaleTruckOrder(Map<String, Object> mapValue);
 }

+ 62 - 0
src/main/java/com/steerinfo/dil/service/impl/OmstruckOrderSeparateServiceImpl.java

@@ -307,4 +307,66 @@ public class OmstruckOrderSeparateServiceImpl implements IOmstruckOrderSeparateS
     public int updateOmstruckOrder(OmstruckOrder omstruckOrder) {
         return omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
     }
+
+    /**
+     * 承运商销售分派运输订单给司机
+     * @param mapValue
+     * @return
+     */
+    @Override
+    public Integer addSaleTruckOrder(Map<String, Object> mapValue) {
+        Integer orderType = (Integer) mapValue.get("orderType");
+        Integer lineId = (Integer) mapValue.get("lineId");
+        BigDecimal dispatchId = DataChange.dataToBigDecimal(mapValue.get("dispatchId"));
+        String capacityNumber = (String) mapValue.get("capacityNumber");
+        OmstruckOrder omstruckOrder = new OmstruckOrder();
+        BigDecimal orderId = omstruckOrderMapper.selectMaxId();
+        Map<String,Object> orderIdMap = new HashMap<>();
+        orderIdMap.put("orderId",orderId);
+        tmsTruckFeign.addTotalResult(orderIdMap);
+        omstruckOrder.setOrderId(orderId);
+        BigDecimal saleOrderMaterialId = omstruckOrderMapper.getSaleMaterialId(dispatchId);
+        omstruckOrder.setOrderPlanId(saleOrderMaterialId);
+        String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue());
+        omstruckOrder.setOrderNumber(orderNumber);
+        omstruckOrder.setLineId(new BigDecimal(lineId));
+        omstruckOrder.setOrderIssueTime(new Date());
+        omstruckOrder.setOrderStatus(new BigDecimal(4));
+        omstruckOrder.setInsertTime(new Date());
+        omstruckOrder.setUpdateTime(new Date());
+        omstruckOrder.setInsertUsername("admin");
+        omstruckOrder.setUpdateUsername("admin");
+        omstruckOrder.setInsertUpdateRemark("无");
+        omstruckOrder.setDeleted(new BigDecimal(0));
+        omstruckOrder.setOrderType(new BigDecimal(orderType));
+        BigDecimal capacityId = omstruckOrderMapper.getCapacityId(capacityNumber);
+        omstruckOrder.setCapacityId(capacityId);
+        List<Map<String, Object>> mapList = omstruckOrderMapper.getMaterialMessages(dispatchId);
+        if (mapList != null && mapList.size() != 0) {
+            for (Map<String, Object> map : mapList) {
+                OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
+                BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
+                omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
+                omstruckOrderMaterial.setOrderId(orderId);
+                omstruckOrderMaterial.setInsertTime(new Date());
+                omstruckOrderMaterial.setUpdateTime(new Date());
+                omstruckOrderMaterial.setInsertUsername("admin");
+                omstruckOrderMaterial.setUpdateUsername("admin");
+                omstruckOrderMaterial.setInsertUpdateRemark("无");
+                if (map != null) {
+                    BigDecimal materialTheoreticalWeight = (BigDecimal) map.get("materialTheoreticalWeight");
+                    BigDecimal saleOrderMaterialNumber = (BigDecimal) map.get("saleOrderMaterialNumber");
+                    BigDecimal materialId = (BigDecimal) map.get("materialId");
+                    omstruckOrderMaterial.setOrderMaterialWeight(materialTheoreticalWeight);
+                    omstruckOrderMaterial.setMaterialId(materialId);
+                    omstruckOrderMaterial.setOrderMaterialNumber(saleOrderMaterialNumber);
+                }
+                omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
+            }
+        }
+        int result = omstruckOrderMapper.insertSelective(omstruckOrder);
+        // 调用websocket推送数据给司机
+        pushMesToWebsocket(orderIdMap);
+        return result;
+    }
 }

+ 6 - 5
src/main/java/com/steerinfo/dil/service/impl/OmstruckOrderServiceImpl.java

@@ -1063,7 +1063,6 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
      * @param carrierId
      * @return
      */
-    @Transactional
     @Override
     public int addAppTruckOrder(Integer dispatchId, Integer orderType, String capacityNumber, Integer carrierId) {
         OmstruckOrder omstruckOrder = new OmstruckOrder();
@@ -1116,12 +1115,14 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
                 omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
             }
         }
-        RmsCapacity rmsCapacity = rmsCapacityMapper.selectByPrimaryKey(capacityId);
-        rmsCapacity.setCapacityStatus(new BigDecimal(2));
-        rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
+//        RmsCapacity rmsCapacity = new RmsCapacity();
+//        rmsCapacity.setCapacityId(capacityId);
+//        rmsCapacity.setCapacityStatus(new BigDecimal(2));
+//        rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
+        int result = omstruckOrderMapper.insertSelective(omstruckOrder);
         // 调用websocket推送数据给司机
         pushMesToWebsocket(orderIdMap);
-        return omstruckOrderMapper.insertSelective(omstruckOrder);
+        return result;
     }
 
     /**

+ 16 - 16
src/main/resources/bootstrap.yml

@@ -42,23 +42,23 @@ redis:
 
 #feign设置
 openfeign:
+  ColumnDataFeign:
+    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8083}
+  TmsTruckFeign:
+    url: ${TMSTRUCKFEIGN_URL:localhost:8088}
+  AmsFeign:
+    url: ${AMSFEIGN_URL:localhost:8079}
+  ImFeign:
+    url: ${IMFEIGN_URL:172.16.33.166:8055}
+    #测试环境
 #  ColumnDataFeign:
-#    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8083}
+#    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8001}
 #  TmsTruckFeign:
-#    url: ${TMSTRUCKFEIGN_URL:172.16.33.166:8088}
+#    url: ${TMSTRUCKFEIGN_URL:172.16.33.166:8008}
 #  AmsFeign:
-#    url: ${AMSFEIGN_URL:172.16.33.166:8079}
+#    url: ${AMSFEIGN_URL:172.16.33.166:8015}
 #  ImFeign:
-#    url: ${IMFEIGN_URL:172.16.33.166:8055}
-    #测试环境
-#  ColumnDataFeign:
-    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8001}
-    TmsTruckFeign:
-      url: ${TMSTRUCKFEIGN_URL:172.16.33.166:8008}
-    AmsFeign:
-      url: ${AMSFEIGN_URL:172.16.33.166:8015}
-    ImFeign:
-      url: ${IMFEIGN_URL:172.16.33.166:8018}
+#    url: ${IMFEIGN_URL:172.16.33.166:8018}
 
 
 mybatis:
@@ -70,7 +70,7 @@ mybatis:
     call-setters-on-nulls: true
 
 server:
-  #正式
-#  port: 8095
+#  正式
+  port: 8095
   #测试
-  port: 8016
+#  port: 8016

+ 4 - 8
src/main/resources/com/steerinfo/dil/mapper/OmstruckOrderMapper.xml

@@ -1497,16 +1497,10 @@
     <!--通过运输订单ID查询数据 用于websocket推送数据  如果订单实绩中有卸货点  没有卸货点通过传入的卸货点进行查询-->
     <select id="pushMesToWebsocket" parameterType="java.util.Map" resultType="java.util.Map">
         select OO.ORDER_NUMBER           "orderNumber",
-               OOM.ORDER_MATERIAL_WEIGHT "orderMaterialWeight",
-               RM.MATERIAL_NAME          "materialName",
                RC.CAPACITY_NUMBER        "capacityNumber"
         from OMSTRUCK_ORDER OO
                  left join RMS_CAPACITY RC
                            on RC.CAPACITY_ID = OO.CAPACITY_ID
-                 left join OMSTRUCK_ORDER_MATERIAL OOM
-                           on OOM.ORDER_ID = OO.ORDER_ID
-                 left join RMS_MATERIAL RM
-                           on RM.MATERIAL_ID = OOM.MATERIAL_ID
         where OO.ORDER_ID = #{orderId}
     </select>
 
@@ -2271,14 +2265,16 @@
                RM.MATERIAL_SPECIFICATION || RM.MATERIAL_MODEL AS "specificationModel",
                ASTM.MATERIAL_THEORETICAL_WEIGHT               AS "materialTheoreticalWeight",
                ASTM.SALE_ORDER_MATERIAL_NUMBER                AS "saleOrderMaterialNumber",
-               ASTM.MATERIAL_ID                               AS "materialId"
+               ASM.MATERIAL_ID                               AS "materialId"
         FROM AMS_DISPATCH_SALE_ORDER ADSO
                  LEFT JOIN AMS_SALE_ORDER_MATERIAL ASOM
                            ON ADSO.SALE_ORDER_MATERIAL_ID = ASOM.SALE_ORDER_MATERIAL_ID
                  LEFT JOIN AMS_SALE_TRUCKNO_MATERIAL ASTM
                            ON ASTM.SALE_ORDER_MATERIAL_ID = ASOM.SALE_ORDER_MATERIAL_ID
+                LEFT JOIN AMS_SALE_MATERIAL ASM
+            ON ASM.SALE_MATERIAL_ID = ASTM.MATERIAL_ID
                  LEFT JOIN RMS_MATERIAL RM
-                           ON RM.MATERIAL_ID = ASTM.MATERIAL_ID
+                           ON RM.MATERIAL_ID = ASM.MATERIAL_ID
         WHERE ADSO.DISPATCH_ID = #{dispatchId}
     </select>