Commit 67c8ee5d authored by 周健威's avatar 周健威

Merge remote-tracking branch 'origin/feature_chw_zjw' into feature_chw_zjw

parents 2b00cbc1 f6576e6c
......@@ -224,6 +224,8 @@ public class BaseOrderAcceptDetailedBiz extends BaseBiz<BaseOrderAcceptDetailedM
if (insureAmount.compareTo(BigDecimal.ZERO) > 0){
Integer type = status == 1 ? 2 : 1;
BaseOrderAcceptDetailed acceptDetailed=new BaseOrderAcceptDetailed();
acceptDetailed.setMchId(0);
acceptDetailed.setUserId(orderDetailDTO.getUserId());
acceptDetailed.setOrderNo(orderDetailDTO.getOrderNo());
acceptDetailed.setOrderId(orderDetailDTO.getOrderId());
acceptDetailed.setOrderAmount(orderDetailDTO.getOrderAmount());
......
......@@ -47,6 +47,11 @@ public class WaterMQHandler {
@RabbitListener(queues = ORDER_WATER_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
log.info("分账队列 messageJson:"+ JSONUtil.parse(message));
try {
Thread.sleep(2000L);
}catch (Exception e) {
log.error(e.getMessage(), e);
}
ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(new Runnable() {
@Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment