From 52552445ea0e49bc662d5cdc0d9e33318104c41c Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@63.com> Date: 星期一, 09 八月 2021 12:51:01 +0800 Subject: [PATCH] # --- src/main/java/zy/cloud/wms/common/service/task/OrderScheduler.java | 35 +++++++++++++++++++++++++++++++++++ 1 files changed, 35 insertions(+), 0 deletions(-) diff --git a/src/main/java/zy/cloud/wms/common/service/task/OrderScheduler.java b/src/main/java/zy/cloud/wms/common/service/task/OrderScheduler.java index fd9a5b7..62e9b25 100644 --- a/src/main/java/zy/cloud/wms/common/service/task/OrderScheduler.java +++ b/src/main/java/zy/cloud/wms/common/service/task/OrderScheduler.java @@ -5,6 +5,7 @@ import com.core.exception.CoolException; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; @@ -27,6 +28,40 @@ private OrderService orderService; @Autowired private PakoutService pakoutService; + @Autowired + private JdbcTemplate jdbcTemplate; + + /** + * 璁㈠崟杞巻鍙叉。澶勭悊鍣� + */ + @Transactional + @Scheduled(cron = "0/10 * * * * ? ") + public void orderBeLogExecute(){ + List<Order> orders = orderService.selectList(new EntityWrapper<Order>().in("settle", 3, 6)); + for (Order order : orders) { + // 淇濆瓨璁㈠崟鍘嗗彶妗� + int saveOrderLog = jdbcTemplate.update("insert into man_order_log select * from man_order where id=" + order.getId()); + if (saveOrderLog == 0) { + throw new CoolException("淇濆瓨璁㈠崟鍘嗗彶妗eけ璐�"); + } + // 淇濆瓨璁㈠崟鏄庣粏鍘嗗彶妗� + int saveOrderDetlLog = jdbcTemplate.update("insert into man_order_detl_log select * from man_order_detl where order_id=" + order.getId()); + if (saveOrderDetlLog == 0) { +// throw new CoolException("淇濆瓨璁㈠崟鏄庣粏鍘嗗彶妗eけ璐�"); + } + // 鍒犻櫎璁㈠崟 + int delOrder = jdbcTemplate.update("delete from man_order where id=" + order.getId()); + if (delOrder == 0) { + throw new CoolException("鍒犻櫎璁㈠崟澶辫触"); + } + // 鍒犻櫎璁㈠崟鏄庣粏 + int delOrderDetl = jdbcTemplate.update("delete from man_order_detl where order_id=" + order.getId()); + if (delOrderDetl == 0) { +// throw new CoolException("鍒犻櫎璁㈠崟鏄庣粏澶辫触"); + } + } + + } /** * 鍙栨秷璁㈠崟澶勭悊鍣� -- Gitblit v1.9.1