From 80cd1569120416b096d28ebbe9a8e6e1d867f6e0 Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期四, 19 九月 2024 14:19:45 +0800 Subject: [PATCH] 盘点异常处理 --- src/main/java/com/zy/asrs/task/GhjtScheduler.java | 53 ++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 40 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/GhjtScheduler.java b/src/main/java/com/zy/asrs/task/GhjtScheduler.java index 65209f8..f145c11 100644 --- a/src/main/java/com/zy/asrs/task/GhjtScheduler.java +++ b/src/main/java/com/zy/asrs/task/GhjtScheduler.java @@ -6,7 +6,10 @@ import com.zy.asrs.mapper.OrderMapper; import com.zy.asrs.mapper.WrkMastMapper; import com.zy.asrs.task.handler.GhjtHandler; +import com.zy.system.entity.Config; +import com.zy.system.mapper.ConfigMapper; import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.annotation.Resource; @@ -30,11 +33,30 @@ @Resource private OrderMapper orderMapper; + @Resource + private ConfigMapper configMapper; + + // 澶囪揣(鏍规嵁鍑哄簱鍗曪紝鎶婅鍑虹殑璐ф彁鍓嶆斁鍒伴潬杩戝嚭搴撳彛浣嶇疆) +// @Scheduled(cron = "0/4 * * * * ? ") + public void stockUp() { + // 鏌ヨ寰呭嚭搴撹鍗� + List<Order> orderList = orderMapper.selectList(new EntityWrapper<Order>().eq("settle", 1)); +// ghjtHandler.stockUp(); + List<Order> orders = orderMapper.selectComplete(); + for (Order order : orders) { + try { +// ghjtHandler.OutBoundCompleteReport(order); + } catch (Exception e) { + log.error("鍑哄簱璁㈠崟瀹屾垚鍒欎笂鎶ES澶辫触锛屽紓甯镐俊鎭細" + e); + } + } + } + // 涓嬪彂鍑哄簱浠诲姟缁橤WCS(浠庡嚭搴撶爜澶村埌鍑哄簱鍙�) -// @Scheduled(cron = "0/2 * * * * ? ") + @Scheduled(cron = "0/2 * * * * ? ") public void ckrwPushGwcs() { // 鏌ヨ鐘舵�佷负13鐨勫伐浣滄。 - List<WrkMast> wrkMasts = wrkMastMapper.selectList(new EntityWrapper<WrkMast>().eq("io_type", 101).eq("wrk_sts", 13)); + List<WrkMast> wrkMasts = wrkMastMapper.selectList(new EntityWrapper<WrkMast>().in("io_type", 101,103,107,110,3).eq("wrk_sts", 13)); for (WrkMast wrkMast : wrkMasts) { try { ghjtHandler.startCkrwPushGwcs(wrkMast); @@ -44,17 +66,22 @@ } } - // 鍑哄簱璁㈠崟瀹屾垚鍒欎笂鎶ES -// @Scheduled(cron = "0/4 * * * * ? ") - public void OutBoundCompleteReport() { - // 鏌ヨ鍑哄簱璁㈠崟鐘舵�佷负4.宸插畬鎴� - List<Order> orders = orderMapper.selectComplete(); - for (Order order : orders) { - try { - ghjtHandler.OutBoundCompleteReport(order); - } catch (Exception e) { - log.error("鍑哄簱璁㈠崟瀹屾垚鍒欎笂鎶ES澶辫触锛屽紓甯镐俊鎭細" + e); - } + // 绌洪棽鐞嗚揣 + @Scheduled(cron = "0/5 * * * * ? ") + public void autoTallyGoods() { + // 绯荤粺閰嶇疆鐣岄潰鍚敤 + Config config = configMapper.selectConfigByCode("auto_tally_goods"); + if (config == null || config.getStatus() == 0) { + return; } + // 鍥涗釜鎹㈢洏鐐癸紝涓や釜缁勭洏鐐� + // 鍏堟煡浠诲姟鐩爣绔欎负 3045/3044鍜�3041/3040鐨勬崲鐩樼粍 濡傛灉鏈変负绌虹殑缁勫垯鍙互鍑猴紝鏈変竴涓垨涓や釜閮戒笉鑳藉嚭 + // todo 闇�鏂板涓や釜鍏ュ簱璺緞 3046/3042 + // 瀵绘壘涓や釜鑳界粍鐩樼殑搴撲綅锛屽簱浣嶇姸鎬佷负F锛屾弧瓒崇粍鐩樻潯浠� + // 鍑哄簱鎬庝箞鍑猴紝鎵嶈兘鎶婄粍濂界殑鐩樹竴娆″嚭鍑哄幓 + // gwcs鎬庝箞淇濊瘉涓や釜閮芥媶瀹屼簡鎵嶈姹傜粍鐩樺畬鎴� + + } + } -- Gitblit v1.9.1