Merge branch 'master' of https://git.steerinfo.com/DAL-DAZHOU2/DAI_DAZHOU-OMS

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

@@ -795,7 +795,7 @@ public class OmstruckOrderController extends BaseRESTfulController {
                                               Integer orderType,
                                               Integer orderStatus,
                                               String con,
-                                              Integer carrierId
+                                              String carrierSsoId
     ) {
         int count = 0;
         if (orderType != null) {
@@ -807,10 +807,8 @@ public class OmstruckOrderController extends BaseRESTfulController {
             mapValue.put("orderStatus", orderStatus);
             count++;
         }
-        if (carrierId != null) {
-            mapValue.put("carrierId", carrierId);
-            count++;
-        }
+        mapValue.put("carrierSsoId",carrierSsoId);
+        count++;
         //框计算
         if (con != null) {
             if (!"undefined".equals(con)) {
@@ -1202,13 +1200,17 @@ public class OmstruckOrderController extends BaseRESTfulController {
                                                   Integer apiId,
                                                   Integer pageNum,
                                                   Integer pageSize,
-                                                  String con) {
+                                                  String con,
+                                                  String carrierId) {
         if (con != null) {
             if(!"undefined".equals(con)){
                 String index="get_capacity_driver";//设置要查询的索引名称
                 return success(esFeign.getConResult(mapValue,index,apiId,pageNum,pageSize,con));//获取查询结果
             }
         }
+        if (carrierId != null && !"undefined".equals(carrierId)){
+            mapValue.put("carrierIds",carrierId);
+        }
         List<Map<String, Object>> dispatchSaleOrderList = null;
         if (mapValue.size() == 0) {
             //将查询结果存入索引中
@@ -1255,11 +1257,11 @@ public class OmstruckOrderController extends BaseRESTfulController {
                                                   Integer pageNum,
                                                   Integer pageSize,
                                                   Integer orderStatus,
-                                                  Integer carrierId,
+                                                  String carrierId,
                                                   String con) {
         if (con != null) {
             if(!"undefined".equals(con)){
-                String index="get_inward_order_list";//设置要查询的索引名称
+                String index="get_inward_order_list3";//设置要查询的索引名称
                 return success(esFeign.getConResult(mapValue,index,apiId,pageNum,pageSize,con));//获取查询结果
             }
         }
@@ -1267,8 +1269,8 @@ public class OmstruckOrderController extends BaseRESTfulController {
         if (mapValue == null) {
             mapValue = new HashMap<>();
         }
-        if (carrierId != null && !"undefined".equals(carrierId.toString())) {
-            mapValue.put("carrierId",new BigDecimal(carrierId));
+        if (carrierId != null && !"undefined".equals(carrierId)) {
+            mapValue.put("carrierId",carrierId);
             count++;
         }
         mapValue.put("orderStatus",(orderStatus));
@@ -1279,7 +1281,7 @@ public class OmstruckOrderController extends BaseRESTfulController {
             dispatchSaleOrderList = omstruckOrderService.getInwardOrderList(mapValue);
             Map<String, Object> map1 = new HashMap<>();
             //添加索引
-            map1.put("index","get_inward_order_list");
+            map1.put("index","get_inward_order_list3");
             //添加id
             map1.put("indexId","planId");
             dispatchSaleOrderList.add(map1);
@@ -1381,4 +1383,11 @@ public class OmstruckOrderController extends BaseRESTfulController {
         String capacityNumber = (String) mapvalue.get("capacityNumber");
         return omstruckOrderMapper.getAllRefuseOrderNumberByCapacity(capacityNumber);
     }
+
+    @ApiOperation(value = "通过运单下的物资信息")
+    @PostMapping("/getOrderMaterialList")
+    public RESTfulResult getOrderMaterialList(@RequestParam Integer orderId) {
+        List<Map<String, Object>> orderMaterialList = omstruckOrderMapper.getOrderMaterialList(new BigDecimal(orderId));
+        return success(orderMaterialList);
+    }
 }

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

@@ -254,4 +254,9 @@ public interface OmstruckOrderMapper extends IBaseMapper<OmstruckOrder, BigDecim
     List<Map<String, Object>> getResultListByCapacity(String capacityNumber);
     // 通过卸货点名称查询卸货点id
     BigDecimal getUnloadPointId(String unloadPoint);
+
+    // 通过ssoId查询承运商id
+    BigDecimal getCarrierIdBySSO(String carrierSsoId);
+
+    List<Map<String, Object>> getOrderMaterialList(BigDecimal orderId);
 }

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

@@ -796,6 +796,9 @@ public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
 
     @Override
     public List<Map<String, Object>> selectTransportOrderForSale(Map<String, Object> map) {
+        String carrierSsoId = (String) map.get("carrierSsoId");
+        BigDecimal carrierId = omstruckOrderMapper.getCarrierIdBySSO(carrierSsoId);
+        map.put("carrierId",carrierId);
         return omstruckOrderMapper.selectTransportOrderForSale(map);
     }
 

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

@@ -1657,19 +1657,13 @@
         OO.ORDER_NUMBER "orderNumber",
         ASO.SALE_NUMBER "saleNumber",
         RC.CAPACITY_NUMBER "capacityNumber",
-        RM.MATERIAL_NAME "materialName",
-        OOM.ORDER_MATERIAL_WEIGHT "orderMaterialweight",
-        OOM.ORDER_MATERIAL_NUMBER "orderMaterialNumber",
-        RM.MATERIAL_THEORETICAL_WEIGHT "materialTheoreticalWeight",
         RC2.CONSIGNEE_COMPANY_NAME "consigneeCompanyName",
         RRA.ADDRESS_DELIVERY_ADDRESS "addressDeliveryAddress",
         ASOM.SALE_DATE_OF_RECEIPT "saleDateOfReceipt",
         OO.ORDER_RECEIVE_REFUSE_TIME "orderReceiveRefuseTime",
-        RS.SHIPPER_NAME "shipperName"
-
+        RS.SHIPPER_NAME "shipperName",
+        OO.ORDER_ID "orderId"
         FROM OMSTRUCK_ORDER OO
-        LEFT JOIN OMSTRUCK_ORDER_MATERIAL OOM
-        ON OO.ORDER_ID=OOM.ORDER_ID
         LEFT JOIN AMS_SALE_ORDER_MATERIAL ASOM
         ON ASOM.SALE_ORDER_MATERIAL_ID=OO.ORDER_PLAN_ID
         LEFT JOIN AMS_SALE_ORDER ASO
@@ -1678,8 +1672,6 @@
         ON RC2.CONSIGNEE_ID=ASO.RECEIVE_ID
         LEFT JOIN RMS_CAPACITY RC
         ON OO.CAPACITY_ID=RC.CAPACITY_ID
-        LEFT JOIN RMS_MATERIAL RM
-        ON OOM.MATERIAL_ID=RM.MATERIAL_ID
         LEFT JOIN RMS_SHIPPER RS
         ON RS.SHIPPER_ID=ASO.SHIPPER_ID
         LEFT JOIN RMS_RECEIVE_ADDRESS RRA
@@ -2343,6 +2335,9 @@
         FROM RMS_CAPACITY RC
         WHERE RC.CAPACITY_STATUS = 0
         AND RC.CAPACITY_TYPE_ID = 1
+        <if test="carrierIds != null">
+            and RC.CARRIER_ID = (select rcr.carrier_id from rms_carrier rcr where rcr.carrier_sso_id = #{carrierIds})
+        </if>
         )
         <where>
             <if test="capacityNumber != null">
@@ -2365,29 +2360,30 @@
     <!-- 查询分解运输计划 -->
     <select id="getInwardOrderList" resultType="java.util.Map" parameterType="java.util.Map">
         SELECT *
-        FROM (SELECT APO.PURCHASE_ORDER_NO AS "purchaseOrderNo",
-        RM.MATERIAL_NAME AS "materialName",
-        DB.RESULT_FOREIGN_SHIP_NAME AS "resultForeignShipName",
-        AIP.PLAN_NUMBER AS "planNumber",
-        RCA.CARRIER_NAME AS "carrierName",
-        AIP.CARRIER_ID AS "carrierId",
-        RC.CAPACITY_NUMBER AS "capacityNumber",
-        OOM.ORDER_MATERIAL_NUMBER AS "orderMaterialNumber",
-        AIR.REQUIREMENT_NUMBER AS "requirementNumber",
-        AIP.PLAN_ISSUE_TIME AS "planIssueTime",
-        AIP.PLAN_ISSUE_NAME AS "planIssueName",
-        AIR.REQUIREMENT_TYPE AS "requirementType",
-        RCT.CAPACITY_TYPE_NAME AS "capacityTypeName",
-        ARM.MATERIAL_COUNT AS "materialNumber",
-        ARM.MATERIAL_WEIGHT AS "materialWeight",
-        AIR.REQUIREMENT_TRUCK_TIME AS "requirementTruckTime",
-        RW.WAREHOUSE_NAME AS "wareHouseName",
-        AIR.REQUIREMENT_WORK_TYPE AS "requirementWorkType",
-        AIR.REQUIREMENT_WORK_CONTENT AS "requirementWorkContent",
-        AIR.REQUIREMENT_WORK_ENVIRONMENT AS "requirementWorkEnvironment",
+        FROM (SELECT APO.PURCHASE_ORDER_NO              AS "purchaseOrderNo",
+        RM.MATERIAL_NAME                   AS "materialName",
+        DB.RESULT_FOREIGN_SHIP_NAME        AS "resultForeignShipName",
+        AIP.PLAN_NUMBER                    AS "planNumber",
+        RCA.CARRIER_NAME                   AS "carrierName",
+        AIP.CARRIER_ID                     AS "carrierId",
+        RC.CAPACITY_NUMBER                 AS "capacityNumber",
+        OOM.ORDER_MATERIAL_NUMBER          AS "orderMaterialNumber",
+        AIR.REQUIREMENT_NUMBER             AS "requirementNumber",
+        AIP.PLAN_ISSUE_TIME                AS "planIssueTime",
+        AIP.PLAN_ISSUE_NAME                AS "planIssueName",
+        AIR.REQUIREMENT_TYPE               AS "requirementType",
+        RCT.CAPACITY_TYPE_NAME             AS "capacityTypeName",
+        ARM.MATERIAL_COUNT                 AS "materialNumber",
+        ARM.MATERIAL_WEIGHT                AS "materialWeight",
+        AIR.REQUIREMENT_TRUCK_TIME         AS "requirementTruckTime",
+        RW.WAREHOUSE_NAME                  AS "wareHouseName",
+        AIR.REQUIREMENT_WORK_TYPE          AS "requirementWorkType",
+        AIR.REQUIREMENT_WORK_CONTENT       AS "requirementWorkContent",
+        AIR.REQUIREMENT_WORK_ENVIRONMENT   AS "requirementWorkEnvironment",
         AIR.REQUIREMENT_ESTIMATED_DURATION AS "requirementEstimatedDuration",
-        OO.ORDER_ID AS "orderId",
-        AIP.INSERT_TIME AS "insertTime"
+        RW1.WAREHOUSE_NAME                 "unloadWarehouseName",
+        OO.ORDER_ID                        AS "orderId",
+        AIP.INSERT_TIME                    AS "insertTime"
         FROM OMSTRUCK_ORDER OO
         LEFT JOIN OMSTRUCK_ORDER_MATERIAL OOM
         ON OOM.ORDER_ID = OO.ORDER_ID
@@ -2406,17 +2402,20 @@
         LEFT JOIN DIL_BATCH DB
         ON APO.BATCH_ID = DB.BATCH_ID
         LEFT JOIN RMS_MATERIAL RM
-        ON RM.MATERIAL_ID = DB.MATERIAL_ID
+        ON RM.MATERIAL_ID = OOM.MATERIAL_ID
         LEFT JOIN RMS_WAREHOUSE RW
         ON RW.WAREHOUSE_ID = AIR.REQUIREMNT_UNIT_ID
+        LEFT JOIN RMS_WAREHOUSE RW1
+        ON RW1.WAREHOUSE_ID = AIR.REQUIREMENT_UNLOAD_UNIT_ID
         LEFT JOIN RMS_CARRIER RCA
         ON RCA.CARRIER_ID = AIP.CARRIER_ID
         LEFT JOIN RMS_CAPACITY_TYPE RCT
         ON RCT.CAPACITY_TYPE_ID = AIR.CAPACITY_TYPE_ID
         WHERE AIP.DELETED = 0
-        AND OO.ORDER_TYPE IN (4,9,10,11)
+        AND OO.ORDER_TYPE IN (4, 9, 10, 11)
         <if test="carrierId != null">
-            AND AIP.CARRIER_ID = #{carrierId}
+            AND AIP.CARRIER_ID = (select rc.carrier_id from rms_carrier rc
+            where rc.carrier_sso_id =  #{carrierId})
         </if>
         <if test="orderStatus != null">
             AND OO.ORDER_STATUS = #{orderStatus}
@@ -2794,28 +2793,31 @@
     <!--  查询内转运输订单给APP 9 10 11-->
     <select id="getNZOrderMessageToApp" parameterType="java.math.BigDecimal" resultType="java.util.Map">
        SELECT OO.ORDER_ID            "orderId",
-              OO.ORDER_NUMBER        "orderNumber",
-              OO.ORDER_LINE_SEQUENCE "orderLineSequence",
-              RC.CAPACITY_NUMBER     "capacityNumber",
-              rwl.warehouse_name     "loadName",
-              RW.WAREHOUSE_NAME      "unloadName",
-              OO.ORDER_TYPE          "orderType"
-         FROM OMSTRUCK_ORDER OO
-         LEFT JOIN AMSTRUCK_REQUIREMENT_PLAN ARP
-           ON OO.ORDER_PLAN_ID = ARP.PLAN_ID
-         LEFT JOIN AMSTRUCK_INWARD_REQUIREMENT AIR
-           ON AIR.REQUIREMENT_ID = ARP.REQUIREMENT_ID
-         left join rms_warehouse rwl
-           on rwl.warehouse_id = air.requirement_platform_id
-         LEFT JOIN AMS_PURCHASE_ORDER APO
-           ON APO.PURCHASE_ORDER_ID = AIR.PURCHASE_ORDER_ID
-         LEFT JOIN RMS_SUPPLIER RS
-           ON RS.SUPPLIER_ID = APO.SUPPLIER_UNIT_ID
-         LEFT JOIN RMS_WAREHOUSE RW
-           ON RW.WAREHOUSE_ID = air.requirement_unload_unit_id
-         LEFT JOIN RMS_CAPACITY RC
-           ON RC.CAPACITY_ID = OO.CAPACITY_ID
-        WHERE OO.ORDER_ID = #{orderId} AND OO.ORDER_STATUS in (4, 5)
+       OO.ORDER_NUMBER        "orderNumber",
+       OO.ORDER_LINE_SEQUENCE "orderLineSequence",
+       RC.CAPACITY_NUMBER     "capacityNumber",
+       rwl.warehouse_name     "loadName",
+       RW.WAREHOUSE_NAME      "unloadName",
+       OO.ORDER_TYPE          "orderType"
+  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 ARP.PLAN_ID = AIP.PLAN_ID
+  LEFT JOIN AMSTRUCK_INWARD_REQUIREMENT AIR
+    ON AIR.REQUIREMENT_ID = ARP.REQUIREMENT_ID
+  LEFT JOIN AMS_PURCHASE_ORDER APO
+    ON APO.PURCHASE_ORDER_ID = AIR.PURCHASE_ORDER_ID
+  left join rms_warehouse rwl
+    on rwl.warehouse_id = AIR.REQUIREMNT_UNIT_ID
+  LEFT JOIN RMS_SUPPLIER RS
+    ON RS.SUPPLIER_ID = APO.SUPPLIER_UNIT_ID
+  LEFT JOIN RMS_WAREHOUSE RW
+    ON RW.WAREHOUSE_ID = air.requirement_unload_unit_id
+  LEFT JOIN RMS_CAPACITY RC
+    ON RC.CAPACITY_ID = OO.CAPACITY_ID
+ WHERE OO.ORDER_ID = #{orderId}
+   AND OO.ORDER_STATUS in (4, 5)
     </select>
     <!--  查询发运计划运输订单给APP  2 3 4 -->
     <select id="getFYJHOrderMessageToApp" parameterType="java.math.BigDecimal" resultType="java.util.Map">
@@ -2935,4 +2937,24 @@
         WHERE OO.ORDER_ID = #{orderId}
           AND OO.ORDER_STATUS in (4, 5)
     </select>
+
+    <select id="getCarrierIdBySSO" parameterType="java.lang.String" resultType="DECIMAL" >
+        SELECT
+            RC.CARRIER_ID AS "carrierId"
+        FROM RMS_CARRIER RC
+        WHERE RC.CARRIER_SSO_ID = #{carrierSsoId}
+    </select>
+
+    <select id="getOrderMaterialList" parameterType="DECIMAL" resultType="java.util.Map" >
+        SELECT
+        OOM.MATERIAL_ID AS "materialId",
+               RM.MATERIAL_NAME AS "materialName",
+               OOM.ORDER_MATERIAL_WEIGHT AS "materialWeight",
+               OOM.ORDER_MATERIAL_NUMBER AS "materialNumber",
+               RM.MATERIAL_SPECIFICATION || RM.MATERIAL_MODEL AS "specificationModel"
+        FROM OMSTRUCK_ORDER_MATERIAL OOM
+        LEFT JOIN RMS_MATERIAL RM
+        ON RM.MATERIAL_ID = OOM.MATERIAL_ID
+        WHERE OOM.ORDER_ID = #{orderId}
+    </select>
 </mapper>