Browse Source

更新B2B委外单不存在重新上传的方法

hejq 7 years ago
parent
commit
6075bf00a2
1 changed files with 11 additions and 5 deletions
  1. 11 5
      src/main/java/com/uas/erp/schedular/b2b/task/OrderCheckTask.java

+ 11 - 5
src/main/java/com/uas/erp/schedular/b2b/task/OrderCheckTask.java

@@ -1,5 +1,6 @@
 package com.uas.erp.schedular.b2b.task;
 
+import com.uas.erp.schedular.b2b.domain.Make;
 import com.uas.erp.schedular.b2b.domain.NotExistOrders;
 import com.uas.erp.schedular.b2b.domain.Purchase;
 import com.uas.erp.schedular.b2b.domain.PurchaseDetail;
@@ -121,14 +122,19 @@ public class OrderCheckTask extends AbstractTask {
     @TaskMapping(title = "获取未上传委外单", fixedDelay = 60000)
     public void checkMakeMain() {
         List<NotExistOrders> orders = getForList("/erp/notExistOrders/makeMain", NotExistOrders.class);
-        List<String> sqlList = new ArrayList<>();
         if (!CollectionUtils.isEmpty(orders)) {
             ContextHolder.setDataSize(orders.size());
+            List<Make> makes = new ArrayList<>();
             for (NotExistOrders order : orders) {
-                sqlList.add("update make set ma_sendStatus = '待上传' where ma_code = '" + order.getCode() + "'");
-            }
-            if (!CollectionUtils.isEmpty(sqlList)) {
-                jdbcTemplate.batchExecute(sqlList);
+                Make make = jdbcTemplate.queryForBean("select make.*, ve_uu from make left join vendor on ma_vendcode=ve_code where ma_code ='" + order.getCode() + "'",
+                        Make.class);
+                if (null != make) {
+                    makes.add(make);
+                }
+                if (!CollectionUtils.isEmpty(makes)) {
+                    ContextHolder.setDataSize(makes.size());
+                    post("/erp/make", dataWrap(makes));
+                }
             }
             String idStr = CollectionUtil.getKeyString(orders, new CollectionUtil.KeyIterator<NotExistOrders>() {
                 @Override