Commit 8d9dc214 authored by hezhen's avatar hezhen

修改消息

parent b3788347
...@@ -5,6 +5,7 @@ import cn.hutool.db.sql.Order; ...@@ -5,6 +5,7 @@ import cn.hutool.db.sql.Order;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.github.wxiaoqi.security.admin.biz.AppUserSellingWaterBiz; import com.github.wxiaoqi.security.admin.biz.AppUserSellingWaterBiz;
import com.github.wxiaoqi.security.admin.biz.BaseOrderAcceptDetailedBiz;
import com.github.wxiaoqi.security.admin.dto.OrderGoodsDTO; import com.github.wxiaoqi.security.admin.dto.OrderGoodsDTO;
import com.github.wxiaoqi.security.admin.dto.OrderWaterDTO; import com.github.wxiaoqi.security.admin.dto.OrderWaterDTO;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
...@@ -36,6 +37,9 @@ public class WaterMQHandler { ...@@ -36,6 +37,9 @@ public class WaterMQHandler {
@Autowired @Autowired
AppUserSellingWaterBiz waterBiz; AppUserSellingWaterBiz waterBiz;
@Autowired
BaseOrderAcceptDetailedBiz acceptDetailedBiz;
/** /**
* 佣金 * 佣金
* @param * @param
...@@ -128,7 +132,7 @@ public class WaterMQHandler { ...@@ -128,7 +132,7 @@ public class WaterMQHandler {
break; break;
} }
waterBiz.orderWater(orderWaterDTO); acceptDetailedBiz.orderWater(orderWaterDTO);
executorService.shutdown(); executorService.shutdown();
Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG); Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
......
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