修改港存库

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

@@ -60,4 +60,7 @@ public interface TmsshipLoadShipResultMapper extends IBaseMapper<TmsshipLoadShip
     //根据港口名称获得港存库主键id
    Map<String,Object> selectGmIdByPortId(Map<String,Object> idMap);
 
+    //为出库查询批次和实装数量
+    List<Map<String,Object>> getBatchIdForOut(Map<String,Object> map);
+
 }

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

@@ -71,10 +71,10 @@ public class TmsshipLoadShipResultServiceImpl implements ITmsshipLoadShipResultS
         BigDecimal orderId = new BigDecimal((Integer) rowMap.get("orderId"));
         BigDecimal batchInfactoryId= DataChange.dataToBigDecimal(rowMap.get("batchInfactoryId"));
         Map<String,Object> ppMap = tmsshipLoadShipResultMapper.getPortAndPier(batchInfactoryId);
+        BigDecimal batchId =DataChange.dataToBigDecimal(rowMap.get("batchId"));
         BigDecimal pierId = (BigDecimal) ppMap.get("pierId");
         Date noticeDeliveryTime = (Date) ppMap.get("noticeDeliveryTime");
         BigDecimal startPortId = DataChange.dataToBigDecimal(ppMap.get("startPortId"));
-
         String resultMemo = (String) mapVal.get("resultMemo");
         Date resultArrivalTime = new Date((Long)mapVal.get("resultArrivalTime"));
         tmsshipLoadShipResult.setResultArrivalPortTime(resultArrivalTime);
@@ -117,7 +117,7 @@ public class TmsshipLoadShipResultServiceImpl implements ITmsshipLoadShipResultS
         //通过总实绩id查找船运起运港口
         //根据港口和批次Id查询实时库存id
         Map<String,Object> idMap=new HashMap<>();
-        idMap.put("batchInfactoryId",batchInfactoryId);
+        idMap.put("batchInfactoryId",batchId);
         idMap.put("downSwimPortId",startPortId);
         //查询实时库存
         Map<String,Object> gmMap = tmsshipLoadShipResultMapper.selectGmIdByPortId(idMap);
@@ -137,6 +137,13 @@ public class TmsshipLoadShipResultServiceImpl implements ITmsshipLoadShipResultS
         tmsshipLoadShipResult.setResultIsclear(resultIsClear);
         if (resultIsClear.equals("清场")){
            wmshboundFeign.clearWmshGridMaterial(gmMap);
+        }else {
+            Map<String,Object> outBoundMap=new HashMap<>();
+            //装船入下游港口港存库库存
+            outBoundMap.put("portId",rowMap.get("downSwimPortId"));
+            outBoundMap.put("batchId",rowMap.get("batchId"));
+            outBoundMap.put("resultMaterialNumber",resultActualInstallations);
+            wmshboundFeign.addResult(outBoundMap);
         }
         String resultNumber = noUtil.setResultNo("ZC",resultEntryId);
         tmsshipLoadShipResult.setResultId(resultId);

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

@@ -102,15 +102,15 @@ public class TmsshipUnloadShipResultServiceImpl implements ITmsshipUnloadShipRes
         tmsshipUnloadShipResult.setInsertUpdateRemark("无");
         tmsshipUnloadShipResult.setDeleted(new BigDecimal(0));
         // 新增出库实绩
-            Map<String,Object> totalId = new HashMap<>();
-            totalId.put("totalResultId",totalResultId);
-            List<TmsshipLoadShipResult> tmsshipLoadShipResults = tmsshipLoadShipResultMapper.selectByParameters(totalId);
-            TmsshipLoadShipResult tmsshipLoadShipResult = tmsshipLoadShipResults.get(0);
-            Map<String,Object> mapValue = new HashMap<>();
-            mapValue.put("batchId",tmsshipLoadShipResult.getBatchId());
-            mapValue.put("portId",downSwimPortId);
-            mapValue.put("resultMaterialNumber",tmsshipLoadShipResult.getResultActualInstallations());
-            wmshboundFeign.addWarehousingResult(mapValue);
+        Map<String,Object> totalId = new HashMap<>();
+        totalId.put("totalResultId",totalResultId);
+        List<Map<String,Object>> tmsshipLoadShipResults = tmsshipLoadShipResultMapper.getBatchIdForOut(totalId);
+        Map<String,Object> tmsshipLoadShipResult = tmsshipLoadShipResults.get(0);
+        Map<String,Object> mapValue = new HashMap<>();
+        mapValue.put("batchId",tmsshipLoadShipResult.get("batchId"));
+        mapValue.put("portId",downSwimPortId);
+        mapValue.put("resultMaterialNumber",tmsshipLoadShipResult.get("resultMaterialNumber"));
+        wmshboundFeign.addWarehousingResult(mapValue);
 
         return tmsshipUnloadShipResultMapper.insert(tmsshipUnloadShipResult);
     }

src/main/resources/application-prod.yml

@@ -27,9 +27,9 @@ piction:
 
 openfeign:
   WmshboundFeign:
-    url: ${WMSHBOUNDFEIGN_URL:172.16.33.166:8070}
+    url: ${WMSHBOUNDFEIGN_URL:localhost:8070}
   ColumnDataFeign:
-    url: ${COLUMNDATAFEIGN_URL:172.16.33.166:8083}
+    url: ${COLUMNDATAFEIGN_URL:172.16.33.161:8083}
 
 server:
   port: 8090

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

@@ -830,6 +830,21 @@
         select WGM.GM_ID "gmId",
                WGM.GM_TONNAGE "tonnage"
         from WMSH_GRID_MATERIAL WGM
+        left join DIL_BATCH DB
+        on WGM.BATCH_ID=DB.BATCH_ID
         WHERE WGM.BATCH_ID=#{batchInfactoryId} and WGM.PORT_ID=#{downSwimPortId}
     </select>
+
+    <select id="getBatchIdForOut" resultType="java.util.Map">
+        select  DB.BATCH_ID "batchId",
+                TLSR.RESULT_ACTUAL_INSTALLATIONS "resultMaterialNumber"
+        from TMSSHIP_LOAD_SHIP_RESULT TLSR
+                 left join DIL_BATCH_INFACOTRY DBI
+                           on TLSR.BATCH_ID=DBI.BATCH_INFACOTRY_ID
+                 left join DIL_BATCH DB
+                           on DBI.BATCH_ID=DB.BATCH_ID
+        where TLSR.TOTAL_RESULT_ID=#{totalResultId}
+    </select>
+
+
 </mapper>

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

@@ -552,6 +552,7 @@
         oic.INSTRUCTIONS_CAPACITY_ID AS "orderId",
         DBI.BATCH_INFACOTRY_ID AS "batchInfactoryId",
         ada.DOWN_SWIM_PORT_ID AS "downSwimPortId",
+        db.BATCH_ID AS "batchId" ,
         rp1.PORT_NAME AS "portName1",
         ada.PORT_ID AS "portId",
         rp2.PORT_NAME AS "portName2",