|
@@ -112,7 +112,7 @@ public class SetCallbackServiceImpl implements SetCallbackService {
|
|
|
}
|
|
|
//rocketMq发送消息
|
|
|
rocketMQTemplate.syncSendOrderly(CHILD_ORDER_TOPIC + ":" + FAIL_TAG, MessageBuilder.withPayload(childStr).build(), String.valueOf(mobileFlowDispatchRec.getRecId()));
|
|
|
-
|
|
|
+ log.info(orderId + "订单 FAILED");
|
|
|
//状态成功 主订单置成功 分发订单置成功
|
|
|
}else if("SUCCESS".equals(setCallbackParam.getStatus())){
|
|
|
mobileFlowDispatchRec.setSendStatus(ORDER_SUCCESS.status());
|
|
@@ -136,6 +136,7 @@ public class SetCallbackServiceImpl implements SetCallbackService {
|
|
|
jedisCluster.hset(CHILD_ORDER_INFO.key() + hKey, orderNo, childStr);
|
|
|
//分发记录rocketMq发送消息
|
|
|
rocketMQTemplate.syncSendOrderly(CHILD_ORDER_TOPIC + ":" + SUCCESS_TAG, MessageBuilder.withPayload(childStr).build(), String.valueOf(mobileFlowDispatchRec.getRecId()));
|
|
|
+ log.info(orderId + "订单 SUCCESS");
|
|
|
} catch (Exception e) {
|
|
|
log.error(e.toString());
|
|
|
return "failed";
|
|
@@ -146,6 +147,4 @@ public class SetCallbackServiceImpl implements SetCallbackService {
|
|
|
return "success";
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
}
|