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;
|
import com.matrix.system.hive.service.SysOrderService;
|
import com.rabbitmq.client.DeliverCallback;
|
import com.rabbitmq.client.Delivery;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.io.IOException;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 微商城发货后erp出库
|
*/
|
public class OrderOutSotoreTask implements MessageHandler {
|
|
@Autowired
|
SysOrderDao sysOrderDao;
|
|
@Autowired
|
SysOrderService orderService;
|
|
@Override
|
public String getName() {
|
return "微商城发货后erp出库";
|
}
|
|
@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();
|
sourceOrder.setOrderNo(orderNo);
|
List<SysOrder> list = sysOrderDao.selectByModel(sourceOrder);
|
if (CollectionUtils.isNotEmpty(list)) {
|
//订单出库
|
orderService.addOutStore(list.get(0));
|
} else {
|
LogUtil.error("订单编号{}erp不存在", orderNo);
|
}
|
|
}
|
}
|
