Browse Source

【小米对接】【增加库存组织字段对接】

wub 1 month ago
parent
commit
3eff5bc6d2

+ 4 - 2
src/main/java/com/uas/eis/task/SyncProductStockTask.java

@@ -39,8 +39,9 @@ public class SyncProductStockTask {
         while(rs2.next()) {
             String V_HOUR = rs2.getGeneralString("v_hour");
             String V_MI = rs2.getGeneralString("v_mi");
-            if (("08".equals(V_HOUR) || "20".equals(V_HOUR) || "02".equals(V_HOUR) || "14".equals(V_HOUR) )
-             //       && ("00".equals(V_MI)  )
+            boolean XIAOMIUPLOAD = baseDao.isDBSetting("XIAOMI", "XIAOMIUPLOAD");
+            if (("08".equals(V_HOUR) || "20".equals(V_HOUR) || XIAOMIUPLOAD  )
+                    //&& ("00".equals(V_MI) || "04".equals(V_MI) )
             ) {
                 X5JsonHttpClient x5JsonHttpClient = new X5JsonHttpClient(configuration.getX5appid(), configuration.getX5appkey(), configuration.getX5ProductStockUrl());
                 Map<String, Object> data = new HashMap<>();
@@ -67,6 +68,7 @@ public class SyncProductStockTask {
                     map.put("common_status", rs.getGeneralString("cd_varchar50_6"));
                     map.put("stock_num", rs.getGeneralDouble("cd_number_2"));
                     map.put("stock_unit", rs.getGeneralString("cd_varchar50_5"));
+                    map.put("stock_org", rs.getGeneralString("cd_varchar50_7"));
                     map.put("ct_id", rs.getGeneralInt("ct_id"));
                     list.add(map);
                 }

+ 3 - 1
src/main/java/com/uas/eis/task/SyncProductWIPTask.java

@@ -40,7 +40,8 @@ public class SyncProductWIPTask {
         while(rs2.next()){
             String V_HOUR = rs2.getGeneralString("v_hour");
             String V_MI = rs2.getGeneralString("v_mi");
-            if(("02".equals(V_HOUR) || "08".equals(V_HOUR) || "14".equals(V_HOUR) || "20".equals(V_HOUR) )
+            boolean XIAOMIUPLOAD = baseDao.isDBSetting("XIAOMI", "XIAOMIUPLOAD");
+            if(("02".equals(V_HOUR) || "08".equals(V_HOUR) || "14".equals(V_HOUR) || "20".equals(V_HOUR) || XIAOMIUPLOAD)
               //&& ("00".equals(V_MI) || "04".equals(V_MI) || "06".equals(V_MI))
             ){
                 X5JsonHttpClient x5JsonHttpClient = new X5JsonHttpClient(configuration.getX5appid(),configuration.getX5appkey(),configuration.getX5ProductWIPUrl());
@@ -69,6 +70,7 @@ public class SyncProductWIPTask {
                     map.put("project_name",rs.getGeneralString("cd_varchar50_5"));
                     map.put("product_code",rs.getGeneralString("cd_varchar50_6"));
                     map.put("fact_date",rs.getGeneralString("cd_date_ywfs"));
+                    map.put("stock_org", rs.getGeneralString("cd_varchar50_7"));
                     map.put("ct_id",rs.getGeneralInt("ct_id"));
                     list.add(map);
                 }