盘点任务回复

src/main/java/com/mushiny/heli/xnr/service/Sql_Table.java

@@ -24,6 +24,16 @@ public interface Sql_Table {
             "AND MD_ITEMDATA.WAREHOUSE_ID = ?\n" +
             "GROUP BY MD_ITEMDATA.ITEM_NO,MD_ITEMDATA.NAME";
 
+    String SQL_FINDALLITEM_RESP = "SELECT SUM(AMOUNT) AS AMOUNT,MD_ITEMDATA.`ITEM_NO` AS SKUID,\n" +
+            "MD_STORAGELOCATION.`SECTION_ID` AS SECTION,\n" +
+            "MD_ITEMDATA.`CLIENT_ID` AS FACTORY\n" +
+            "FROM INV_STOCKUNIT, MD_ITEMDATA,INV_UNITLOAD, MD_STORAGELOCATION \n" +
+            "WHERE MD_ITEMDATA.ID = INV_STOCKUNIT.`ITEMDATA_ID`\n" +
+            "AND INV_UNITLOAD.ID = INV_STOCKUNIT.UNITLOAD_ID\n" +
+            "AND INV_UNITLOAD.STORAGELOCATION_ID = MD_STORAGELOCATION.ID\n" +
+            "AND AMOUNT > 0 AND MD_STORAGELOCATION.`NAME` LIKE 'P00%'\n" +
+            "GROUP BY MD_ITEMDATA.ITEM_NO,MD_ITEMDATA.NAME LIMIT 200";
+
     String SQL_FINDITEM_BYITENNO = "SELECT SUM(AMOUNT) AS SUMALL,MD_ITEMDATA.`ITEM_NO`,\n" +
             "MD_ITEMDATA.`NAME` , \n" +
             "MD_STORAGELOCATION.`NAME` AS PNAME,\n" +

src/main/java/com/mushiny/heli/xnr/service/WMSRespService.java

@@ -57,6 +57,9 @@ public class WMSRespService {
     @Value("${mushiny.heli.wms.icqaResp.url}")
     private String icqaResp_url;
 
+    @Value("${mushiny.heli.wms.storage.url}")
+    private String storage_url;
+
     public static final String FINISH = "Finish";
     public static final String AVAILABLE = "Available";
     public static final String PROCESS = "Process";
@@ -306,4 +309,20 @@ public class WMSRespService {
         //返回所有
         return new ArrayList<>(temp.values());
     }
+
+    @Scheduled(fixedDelay = 10*1000L)
+    @Transactional
+    public void storageResp(){
+        List<Map> rows = this.jdbcRepository
+                .queryBySql(Sql_Table.SQL_FINDALLITEM_RESP);
+        String json = JsonUtils.list2Json(rows);
+        logger.debug("post data: " + json);
+        HttpHeaders headers = this.getHttpHeaders();
+        RestTemplate restTemplate = builder.build();
+        HttpEntity<String> httpEntity = new HttpEntity<String>(json, headers);
+        ResponseEntity<String> res = restTemplate.postForEntity(this.storage_url, httpEntity, String.class);
+        Map result = JsonUtils.json2Map(res.getBody());
+        logger.debug("result: " + result);
+
+    }
 }