package com.zy.asrs.task; import com.core.common.Cools; import com.zy.asrs.entity.OrderPakout; import com.zy.asrs.service.OrderPakoutService; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.GroupOrderFormHandler; import com.zy.common.entity.Parameter; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.List; /** * Created by Monkey D. Luffy on 2025.11.10 * 徐工汉云..............以下.............上饶江铜.............拆垛完成信息处理 */ @Slf4j @Component public class GroupOrderFormScheduler { @Autowired private GroupOrderFormHandler groupOrderFormHandler; @Autowired private OrderPakoutService orderPakoutService; @Scheduled(cron = "0/5 * * * * ? ") public void abandonedGroupOrderForm(){ String erpReport = Parameter.get().getErpReport(); if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { List orders = orderPakoutService.selectSettle(99L); for (OrderPakout order : orders) { try{ ReturnT result = groupOrderFormHandler.abandoned(order); if (!result.isSuccess()) { log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); } }catch (Exception e){ log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); log.error("订单"+order+"处理失败,异常信息:"+e); } } } } @Scheduled(cron = "0/5 * * * * ? ") public void outGroupOrderForm(){ String erpReport = Parameter.get().getErpReport(); if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { List orders = orderPakoutService.selectSettle(11L); for (OrderPakout order : orders) { try{ ReturnT result = groupOrderFormHandler.start(order); if (!result.isSuccess()) { log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); } }catch (Exception e){ log.error("计划组货单[orderNo={}]出库失败", order.getOrderNo()); log.error("订单"+order+"处理失败,异常信息:"+e); } } } } }