From 6b014bbfa38a67d9b7337d626fdb537f95ee4f2f Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 26 四月 2021 10:16:42 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/service/erp/task/ErpScheduler.java |   44 ++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 40 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/common/service/erp/task/ErpScheduler.java b/src/main/java/com/zy/common/service/erp/task/ErpScheduler.java
index ebd0150..c69f735 100644
--- a/src/main/java/com/zy/common/service/erp/task/ErpScheduler.java
+++ b/src/main/java/com/zy/common/service/erp/task/ErpScheduler.java
@@ -109,7 +109,7 @@
     /**
      * 鎴愬搧
      */
-//    @Scheduled(cron = "0/3 * * * * ? ")
+    @Scheduled(cron = "0/5 * * * * ? ")
 //    @PostConstruct
     public void inCPICMOExecute(){
 //        List<M_item> item = erpService.getItem();
@@ -156,7 +156,7 @@
         }
     }
 
-//    @Scheduled(cron = "0/3 * * * * ? ")
+    @Scheduled(cron = "0/5 * * * * ? ")
     public void syncMat(){
         List<M_item> items = erpService.getItem();
         for (M_item item : items) {
@@ -166,11 +166,21 @@
                 VersionUtils.setMatCode(matCode, item);
                 matCode.setAppeTime(new Date());
                 matCode.setModiTime(new Date());
-                matCodeService.insert(matCode);
+                boolean insert = matCodeService.insert(matCode);
+                if (insert) {
+                    log.info("=====>> 鏂板鐗╂枡鎴愬姛 锛� {}", JSON.toJSONString(item));
+                } else {
+                    log.error("=====>> 鏂板鐗╂枡澶辫触锛侊紒锛� 锛� {}", JSON.toJSONString(item));
+                }
             } else {
                 VersionUtils.setMatCode(matCode, item);
                 matCode.setModiTime(new Date());
-                matCodeService.updateById(matCode);
+                boolean b = matCodeService.updateById(matCode);
+                if (b) {
+                    log.info("=====>> 鏇存柊鐗╂枡鎴愬姛 锛� {}", JSON.toJSONString(item));
+                } else {
+                    log.error("=====>> 鏇存柊鐗╂枡澶辫触锛侊紒锛� 锛� {}", JSON.toJSONString(item));
+                }
             }
             // 鏇存柊瀹屼箣鍚庡垹闄�
             erpService.deleteItem(item.getMnumber());
@@ -178,6 +188,32 @@
     }
 
     /**
+     * 鎴愬搧鍑哄簱-鍙戣揣閫氱煡鍗曡〃澶�
+     */
+    @Scheduled(cron = "0/30 * * * * ? ")
+    public void syncOutStock(){
+        boolean result = erpService.syncOutStock();
+        if (result) {
+//            System.out.format("%s\33[%d;%dm%s%n", "", 32, 3, "==========OutStockBill琛ㄥ悓姝ユ垚鍔�==========");
+        } else {
+            System.out.format("%s\33[%d;%dm%s%n", "", 31, 3, "==========OutStockBill琛ㄥ悓姝ュけ璐�==========");
+        }
+    }
+
+    /**
+     * 鎴愬搧鍑哄簱-鍙戣揣閫氱煡鍗曡〃浣�
+     */
+    @Scheduled(cron = "0/30 * * * * ? ")
+    public void syncOutStockDetail(){
+        boolean result = erpService.syncOutStockDetail();
+        if (result) {
+//            System.out.format("%s\33[%d;%dm%s%n", "", 32, 3, "==========OutStockBillEntry琛ㄥ悓姝ユ垚鍔�==========");
+        } else {
+            System.out.format("%s\33[%d;%dm%s%n", "", 31, 3, "==========OutStockBillEntry琛ㄥ悓姝ュけ璐�==========");
+        }
+    }
+
+    /**
      * 鍘熸潗鏂欏嚭搴�
      */
 //    @Scheduled(cron = "0/3 * * * * ? ")

--
Gitblit v1.9.1