package cn.iocoder.yudao.module.erp.service.sale.listener;
|
|
import cn.iocoder.yudao.module.erp.dal.dataobject.sale.ErpSaleOrderDO;
|
import cn.iocoder.yudao.module.erp.dal.mysql.sale.ErpSaleOrderMapper;
|
import cn.iocoder.yudao.module.mes.api.event.ProductionFinishedEvent;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.context.event.EventListener;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 生产完成事件监听器
|
*
|
* 监听 MES 模块发布的 ProductionFinishedEvent，更新销售订单的生产状态
|
*
|
* @author 芋道源码
|
*/
|
@Component
|
@Slf4j
|
public class ProductionFinishedListener {
|
|
@Resource
|
private ErpSaleOrderMapper saleOrderMapper;
|
|
@EventListener
|
@Async
|
public void onProductionFinished(ProductionFinishedEvent event) {
|
log.info("[onProductionFinished] 收到生产完成事件，销售订单ID: {}", event.getSaleOrderId());
|
|
// 更新销售订单的生产状态
|
saleOrderMapper.updateById(new ErpSaleOrderDO()
|
.setId(event.getSaleOrderId())
|
.setProductionStatus(1)
|
.setProductionFinishTime(event.getFinishTime()));
|
|
log.info("[onProductionFinished] 销售订单 {} 生产状态已更新为完成", event.getSaleOrderId());
|
}
|
|
}
|
