Helius
2022-02-14 59cf24b0aba393e145f4ba3d58e98b7a01a80992
zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderOutSotoreTask.java
@@ -1,6 +1,7 @@
package com.matrix.system.shopXcx.mqTask;
import com.matrix.component.asyncmessage.MessageHandler;
import com.matrix.core.tools.LogUtil;
import com.matrix.system.hive.bean.SysOrder;
import com.matrix.system.hive.dao.SysOrderDao;
@@ -12,11 +13,12 @@
import java.io.IOException;
import java.util.List;
import java.util.Map;
/**
 * 微商城发货后erp出库
 */
public class OrderOutSotoreTask implements DeliverCallback {
public class OrderOutSotoreTask implements MessageHandler {
    @Autowired
    SysOrderDao sysOrderDao;
@@ -25,9 +27,19 @@
    SysOrderService orderService;
    @Override
    public void handle(String consumerTag, Delivery message) throws IOException {
    public String getName() {
        return "微商城发货后erp出库";
    }
        String orderNo = new String(message.getBody(), "UTF-8");
    @Override
    public String getRouteKey() {
        return AsyncMessageRouting.ORDER_OUT_SOTORE;
    }
    @Override
    public void handle(Map<String,Object> param){
        String orderNo = (String) param.get("orderNo");
        LogUtil.debug("收到出库订单orderNo={}", orderNo);
        //获取订单信息
        SysOrder sourceOrder = new SysOrder();