提交 669f0a58 authored 作者: 胡宁宁's avatar 胡宁宁

添加运单流程日志

上级 613c398d
......@@ -5,6 +5,7 @@ import com.clx.order.vo.pc.carrier.InvoicingCompanyVO;
import com.clx.performance.component.IdGenerateSnowFlake;
import com.clx.performance.config.SettlementConfig;
import com.clx.performance.constant.RabbitKeyConstants;
import com.clx.performance.dao.OrderChildDao;
import com.clx.performance.dao.OrderChildSyncTransportInvoiceRecordDao;
import com.clx.performance.dao.OrderGoodsDao;
import com.clx.performance.dao.OwnerAccountDao;
......@@ -31,6 +32,7 @@ import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;
......@@ -71,7 +73,7 @@ public class OrderChildSyncTransportListener {
private final InvoicingCompanyService invoicingCompanyService;
private final SettlementConfig settlementConfig;
private final OrderChildSyncBrokerService orderChildSyncBrokerService;
private final OrderChildDao orderChildDao;
/**
* 承运同步网络货运运单
*/
......@@ -80,9 +82,10 @@ public class OrderChildSyncTransportListener {
OrderChild orderChild = JSONUtil.toBean(message, OrderChild.class);
//是否通过风控,调用网络货运
try {
log.info("当前OrderChildSyncTransportListener监听同步网络货运,运单{}", JSONUtil.parse(orderChild).toString());
OrderChild orderChildBase = orderChildDao.getByChildNo(orderChild.getChildNo()).orElseThrow(PerformanceResultEnum.ORDER_CHILD_NO_FOUND);
log.info("当前OrderChildSyncTransportListener监听同步网络货运,运单{}", JSONUtil.parse(orderChildBase).toString());
transportOrderChildProcess(orderChild);
transportOrderChildProcess(orderChildBase);
} catch (Exception e) {
log.info("当前OrderChildSyncTransportListener监听同步网络货运失败,运单号{}, 错误信息{}", orderChild.getChildNo(), ExceptionUtils.getStackTrace(e));
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论