package com.zy.asrs.task.handler; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.zy.asrs.entity.*; import com.zy.asrs.service.*; import com.zy.asrs.task.AbstractHandler; import com.zy.asrs.task.core.ReturnT; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.Date; import java.util.List; @Service @Slf4j public class OrderMoveHistoryHandler extends AbstractHandler { @Autowired private OrderPakoutService orderPakoutService; @Autowired private OrderPakinService orderPakinService; @Autowired private OrderDetlPakinService orderDetlPakinService; @Autowired private OrderDetlPakoutService orderDetlPakoutService; @Autowired private OrderReportService orderReportService; @Autowired private OrderDetlReportService orderDetlReportService; @Autowired private OrderDetlReportLogService orderDetlReportLogService; public ReturnT startPakin() { List settleEqual6 = orderPakinService.selectList(new EntityWrapper() .eq("settle", 6)); for (OrderPakin order : settleEqual6) { List orderDetlPakouts = orderDetlPakinService.selectList(new EntityWrapper() .eq("order_no", order.getOrderNo())); moveBothPakin(order, orderDetlPakouts); log.info("已完成单据移动至历史表成功 =====>" + order); } return SUCCESS; } private void moveBothPakin(OrderPakin order, List orderDetlPakins) { Date now = new Date(); if (!Cools.isEmpty(orderDetlPakins)) { for (OrderDetlPakin orderDetlPakout : orderDetlPakins) { orderDetlPakout.setUpdateBy(0L); orderDetlPakout.setUpdateTime(now); orderDetlPakinService.addToLogTable(orderDetlPakout); orderDetlPakinService.delete(new EntityWrapper() .eq("id", orderDetlPakout.getId())); } } if (!Cools.isEmpty(order)) { order.setUpdateBy(0L); order.setUpdateTime(now); orderPakinService.addToLogTable(order); orderPakinService.delete(new EntityWrapper() .eq("id", order.getId())); } } public ReturnT startPakout() { List settleEqual6 = orderPakoutService.selectList(new EntityWrapper() .eq("settle", 6)); for (OrderPakout order : settleEqual6) { List orderDetlPakouts = orderDetlPakoutService.selectList(new EntityWrapper() .eq("order_no", order.getOrderNo())); moveBothPakout(order, orderDetlPakouts); log.info("已完成单据移动至历史表成功 =====>" + order); } return SUCCESS; } private void moveBothPakout(OrderPakout order, List orderDetlPakouts) { Date now = new Date(); if (!Cools.isEmpty(orderDetlPakouts)) { for (OrderDetlPakout orderDetlPakout : orderDetlPakouts) { orderDetlPakout.setUpdateBy(0L); orderDetlPakout.setUpdateTime(now); orderDetlPakoutService.addToLogTable(orderDetlPakout); orderDetlPakoutService.delete(new EntityWrapper() .eq("id", orderDetlPakout.getId())); } } if (!Cools.isEmpty(order)) { order.setUpdateBy(0L); order.setUpdateTime(now); orderPakoutService.addToLogTable(order); orderPakoutService.delete(new EntityWrapper() .eq("id", order.getId())); } } }