承运同步网络货运异步

performance-web/src/main/java/com/clx/performance/job/OrderChildSyncTransportInvoiceExceptionJob.java

@@ -56,9 +56,10 @@ public class OrderChildSyncTransportInvoiceExceptionJob {
             if (bean.succeed()) {
                 JSON json = JSONUtil.parse(bean.getData());
                 Object status = json.getByPath("status");
+                ids.add(record.getId());
+
                 if (ObjectUtil.equal(status, 1)) {
                     OrderChild orderChild = orderChildDao.getByChildNo(record.getChildNo()).get();
-                    ids.add(record.getId());
                     orderChildPaySync.transportOrderChildProcess(orderChild);
                 } else {
                     Object riskReason = json.getByPath("riskReason");

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementServiceImpl.java

@@ -75,7 +75,7 @@ public class SettlementServiceImpl implements SettlementService {
             //TODO 发送MQ异步
             Message message = MessageBuilder.withBody(JSONUtil.parse(orderChild).toString().getBytes()).build();
             rabbitTemplate.send(
-                    RabbitKeyConstants.ORDER_CANCEL_EXCHANGE, RabbitKeyConstants.ORDER_CANCEL_ROUTE_KEY, message
+                    RabbitKeyConstants.ORDER_CHILD_SYNC_TRANSPORT_EXCHANGE, RabbitKeyConstants.ORDER_CHILD_SYNC_TRANSPORT_ROUTE_KEY, message
             );
             return;
 //            OrderGoods orderGoods = orderGoodsDao.getByOrderGoodsNo(orderChild.getOrderGoodsNo()).get();