package com.vincent.rsf.server.manager.schedules;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.vincent.rsf.framework.common.R;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.api.controller.erp.params.ReportDataParam;
|
import com.vincent.rsf.server.api.controller.erp.params.ReportParams;
|
import com.vincent.rsf.server.api.service.ReportMsgService;
|
import com.vincent.rsf.server.common.utils.FieldsUtils;
|
import com.vincent.rsf.server.manager.entity.*;
|
import com.vincent.rsf.server.manager.enums.*;
|
import com.vincent.rsf.server.manager.mapper.AsnOrderItemMapper;
|
import com.vincent.rsf.server.manager.mapper.AsnOrderMapper;
|
import com.vincent.rsf.server.manager.service.*;
|
import com.vincent.rsf.server.manager.service.impl.StockItemServiceImpl;
|
import com.vincent.rsf.server.manager.service.impl.StockServiceImpl;
|
import com.vincent.rsf.server.system.entity.User;
|
import com.vincent.rsf.server.system.service.UserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDate;
|
import java.time.ZoneId;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author Ryan
|
* @version 1.0
|
* @title AsnOrderLogSchedule
|
* @description
|
* @create 2025/3/19 19:07
|
*/
|
@Slf4j
|
@Component
|
public class AsnOrderLogSchedule {
|
|
@Autowired
|
private PurchaseService purchaseService;
|
@Autowired
|
private DeliveryService deliveryService;
|
@Autowired
|
private AsnOrderService asnOrderService;
|
@Autowired
|
private AsnOrderItemService asnOrderItemService;
|
@Autowired
|
private AsnOrderLogService asnOrderLogService;
|
@Autowired
|
private AsnOrderItemLogService asnOrderItemLogService;
|
|
@Autowired
|
private TransferService transferService;
|
|
@Autowired
|
private ReportMsgService reportMsgService;
|
|
@Autowired
|
private AsnOrderMapper asnOrderMapper;
|
@Autowired
|
private AsnOrderItemMapper asnOrderItemMapper;
|
|
/**
|
* @param
|
* @return
|
* @author Ryan
|
* @description 删除已完成订单加入Log表
|
* @time 2025/3/19 19:09
|
*/
|
@Scheduled(cron = "0 0 5 * * ?")
|
@Transactional(rollbackFor = Exception.class)
|
public void InStockToLog() {
|
List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
|
.eq(WkOrder::getType, OrderType.ORDER_IN.type)
|
.isNotNull(WkOrder::getPoCode)
|
.ne(WkOrder::getPoCode, "")
|
.eq(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val));
|
if (wkOrders.isEmpty()) {
|
return;
|
}
|
try {
|
moveOrderToLog(wkOrders, OrderType.ORDER_IN.type);
|
} catch (Exception e) {
|
throw new CoolException(e.getMessage());
|
}
|
}
|
|
/**
|
* @param
|
* @return
|
* @author Ryan
|
* @description 出库单完成后，状态修改
|
* @time 2025/6/16 08:35
|
*/
|
@Scheduled(cron = "0/25 * * * * ? ")
|
// @Scheduled(cron = "0 0 2 1 * ?")
|
@Transactional(rollbackFor = Exception.class)
|
public void outStockComplete() {
|
List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
|
.eq(WkOrder::getType, OrderType.ORDER_OUT.type)
|
.isNotNull(WkOrder::getPoCode)
|
.ne(WkOrder::getPoCode, "")
|
.eq(WkOrder::getExceStatus, AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val));
|
if (wkOrders.isEmpty()) {
|
return;
|
}
|
try {
|
moveOrderToLog(wkOrders, OrderType.ORDER_OUT.type);
|
} catch (Exception e) {
|
throw new CoolException(e.getMessage());
|
}
|
}
|
|
|
/**
|
* @param
|
* @param type
|
* @return
|
* @author Ryan
|
* @description 添加历史单据, 产上报ERP
|
* @time 2025/6/16 08:56
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void moveOrderToLog(List<WkOrder> wkOrders, String type) {
|
Set<Long> longSet = wkOrders.stream().map(WkOrder::getId).collect(Collectors.toSet());
|
List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>()
|
.in(WkOrderItem::getOrderId, longSet));
|
if (orderItems.isEmpty()) {
|
throw new CoolException("收货明细为空！！");
|
}
|
|
for (WkOrder order : wkOrders) {
|
if (order.getType().equals(OrderType.ORDER_OUT.type)) {
|
try {
|
//上报次数限定
|
if (order.getReportOnce() < 4) {
|
//上报已完成订单至ERP、MES等三方系统
|
reportMsgService.reportOrders(order);
|
order.setReportOnce(order.getReportOnce() + 1);
|
if (!asnOrderService.updateById(order)) {
|
log.error(order.getCode() + "，单据上传次数修改失败！！");
|
}
|
}
|
} catch (Exception e) {
|
log.error(e.getMessage());
|
}
|
}
|
// if (order.getType().equals(OrderType.ORDER_OUT.type) && order.getReportOnce() >= 4) {
|
AsnOrderLog one = asnOrderLogService.getOne(new LambdaQueryWrapper<AsnOrderLog>().eq(AsnOrderLog::getCode, order.getCode()), false);
|
AsnOrderLog orderLog;
|
if (Objects.isNull(one)) {
|
orderLog = new AsnOrderLog();
|
if (type.equals(OrderType.ORDER_OUT.type)) {
|
order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
|
order.setQty(order.getWorkQty());
|
}
|
BeanUtils.copyProperties(order, orderLog);
|
orderLog.setId(null);
|
orderLog.setAsnId(order.getId());
|
if (!asnOrderLogService.save(orderLog)) {
|
throw new CoolException("主单历史档添加失败！！");
|
}
|
} else {
|
if (type.equals(OrderType.ORDER_OUT.type)) {
|
order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
|
order.setQty(order.getWorkQty());
|
}
|
long existingLogId = one.getId();
|
BeanUtils.copyProperties(order, one);
|
one.setId(existingLogId);
|
one.setAsnId(order.getId());
|
if (!asnOrderLogService.updateById(one)) {
|
throw new CoolException("主单历史档更新失败！！");
|
}
|
orderLog = one;
|
asnOrderItemLogService.remove(new LambdaQueryWrapper<AsnOrderItemLog>().eq(AsnOrderItemLog::getLogId, existingLogId));
|
}
|
|
List<AsnOrderItemLog> logs = new ArrayList<>();
|
List<WkOrderItem> items = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>()
|
.eq(WkOrderItem::getOrderId, order.getId()));
|
items.forEach(item -> {
|
AsnOrderItemLog itemLog = new AsnOrderItemLog();
|
BeanUtils.copyProperties(item, itemLog);
|
itemLog.setAsnItemId(item.getId())
|
.setId(null)
|
.setMatnrId(item.getMatnrId())
|
.setLogId(orderLog.getId())
|
.setAsnId(item.getOrderId());
|
logs.add(itemLog);
|
});
|
if (!asnOrderItemLogService.saveBatch(logs)) {
|
throw new CoolException("单据明细历史档保存失败！！");
|
}
|
|
//更新PO/DO单执行状态
|
if (type.equals(OrderType.ORDER_IN.type)) {
|
if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER.type)) {
|
order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
|
if (!asnOrderService.updateById(order)) {
|
throw new CoolException("单据状态更新失败！！");
|
}
|
// List<TransferOrder> orders = transferOrderService.list(new LambdaQueryWrapper<TransferOrder>().eq(TransferOrder::getTransferId, order.getPoId()));
|
// if (orders.isEmpty()) {
|
// throw new CoolException("数据错误：关联表信息不存在！！");
|
// }
|
// Set<Long> orderIds = orders.stream().map(TransferOrder::getOrd erId).collect(Collectors.toSet());
|
// if (!asnOrderItemService.remove(new LambdaQueryWrapper<WkOrderItem>()
|
// .in(WkOrderItem::getOrderId, orderIds))) {
|
// throw new CoolException("原单据明细删除失败！！");
|
// }
|
// if (!this.asnOrderService.removeByIds(orderIds)) {
|
// throw new CoolException("原单据删除失败！！");
|
// }
|
if (!transferService.update(new LambdaUpdateWrapper<Transfer>()
|
.eq(Transfer::getId, order.getPoId())
|
.set(Transfer::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val))) {
|
throw new CoolException("调拔单状态修改失败！！");
|
}
|
removeOriginalOrderAndItems(order);
|
continue;
|
} else {
|
if (!Objects.isNull(order.getPoId())) {
|
purchaseService.update(new LambdaUpdateWrapper<Purchase>()
|
.set(Purchase::getExceStatus, POExceStatus.PO_EXCE_STATUS_ALL_DONE.val)
|
.eq(Purchase::getId, order.getPoId()));
|
}
|
}
|
} else {
|
if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_STOCK_TERANSFER.type)) {
|
order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
|
if (!asnOrderService.updateById(order)) {
|
throw new CoolException("单据状态更新失败！！");
|
}
|
//如果为调拔单据保留
|
removeOriginalOrderAndItems(order);
|
continue;
|
} else {
|
if (!Objects.isNull(order.getPoId())) {
|
deliveryService.update(new LambdaUpdateWrapper<Delivery>()
|
.eq(Delivery::getId, order.getPoId())
|
.set(Delivery::getExceStatus, POExceStatus.PO_EXCE_STATUS_ALL_DONE.val));
|
}
|
}
|
}
|
// 转入历史后删除原单及明细
|
removeOriginalOrderAndItems(order);
|
}
|
}
|
|
/** 删除原入库/出库通知单及明细（转入历史后调用） */
|
private void removeOriginalOrderAndItems(WkOrder order) {
|
if (!asnOrderItemService.remove(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()))) {
|
throw new CoolException("原单据明细删除失败！！");
|
}
|
if (!asnOrderService.removeById(order.getId())) {
|
throw new CoolException("原单据删除失败！！");
|
}
|
}
|
|
/** 每月1号凌晨执行：物理删除上上个月之前已被逻辑删除的入库/出库通知单及明细 */
|
@Scheduled(cron = "0 0 0 1 * ?")
|
@Transactional(rollbackFor = Exception.class)
|
public void physicalDeleteLogicDeletedOrders() {
|
LocalDate startOfTwoMonthsAgo = LocalDate.now().minusMonths(2).withDayOfMonth(1);
|
Date before = Date.from(startOfTwoMonthsAgo.atStartOfDay(ZoneId.systemDefault()).toInstant());
|
List<Long> ids = asnOrderMapper.selectLogicDeletedOrderIdsBefore(before);
|
if (ids == null || ids.isEmpty()) {
|
return;
|
}
|
final int batchSize = 500;
|
for (int i = 0; i < ids.size(); i += batchSize) {
|
int to = Math.min(i + batchSize, ids.size());
|
List<Long> batch = ids.subList(i, to);
|
asnOrderItemMapper.physicalDeleteByOrderIds(batch);
|
asnOrderMapper.physicalDeleteByIds(batch);
|
}
|
log.info("物理删除上上个月之前已逻辑删除的原单及明细，订单数：{}", ids.size());
|
}
|
}
|
