From 4d76ec2cc1cbbf9f192d532922c2d0a05900f510 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期五, 23 四月 2021 11:40:23 +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..fa67b3b 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