Commit cd7df598 authored by hezhen's avatar hezhen

Merge branch 'master_chw_publish' into dev-chw

# Conflicts:
#	xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/feign/OrderFeign.java
parents 1a38eaae 3d04c3a2
...@@ -61,7 +61,7 @@ public interface OrderFeign { ...@@ -61,7 +61,7 @@ public interface OrderFeign {
BaseOrder updateBaseOrder(@RequestBody BaseOrder baseOrder); BaseOrder updateBaseOrder(@RequestBody BaseOrder baseOrder);
@RequestMapping(value = "chw/orderPulishReceive/app/unauth/refund", method = RequestMethod.GET) @PostMapping(value = "chw/orderPulishReceive/app/unauth/refund")
ObjectRestResponse refund(ReceiveRefundDTO receiveRefundDTO); ObjectRestResponse refund(@RequestBody ReceiveRefundDTO receiveRefundDTO);
} }
...@@ -41,11 +41,11 @@ public class OrderPulishReceiveController extends BaseController<OrderPulishRece ...@@ -41,11 +41,11 @@ public class OrderPulishReceiveController extends BaseController<OrderPulishRece
} }
@RequestMapping(value = "app/unauth/refund", method = RequestMethod.GET) @PostMapping(value = "app/unauth/refund")
@ResponseBody @ResponseBody
@ApiOperation(value = "退款") @ApiOperation(value = "退款")
@IgnoreUserToken @IgnoreUserToken
public ObjectRestResponse refund(ReceiveRefundDTO receiveRefundDTO) { public ObjectRestResponse refund(@RequestBody ReceiveRefundDTO receiveRefundDTO) {
receiveService.refund(receiveRefundDTO); receiveService.refund(receiveRefundDTO);
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
......
...@@ -39,6 +39,11 @@ public class VehicleReceiveMQHandler { ...@@ -39,6 +39,11 @@ public class VehicleReceiveMQHandler {
@RabbitListener(queues = VEHICLE_RECEVIE_REFUND_QUEUE) @RabbitListener(queues = VEHICLE_RECEVIE_REFUND_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) { public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
log.info("接单退款信息 messageJson:"+ JSONUtil.parse(message)); log.info("接单退款信息 messageJson:"+ JSONUtil.parse(message));
try {
Thread.sleep(2000L);
}catch (Exception e) {
log.error(e.getMessage(), e);
}
ExecutorService executorService = Executors.newCachedThreadPool(); ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(new Runnable() { executorService.execute(new Runnable() {
@Override @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