| | |
| | | import com.matrix.system.common.bean.BusParameterSettings; |
| | | import com.matrix.system.common.constance.AppConstance; |
| | | import com.matrix.system.common.dao.BusParameterSettingsDao; |
| | | import com.matrix.system.hive.bean.SysVipInfo; |
| | | import com.matrix.system.hive.dao.SysVipInfoDao; |
| | | import com.matrix.system.shopXcx.bean.ShopDeliveryInfo; |
| | | import com.matrix.system.shopXcx.bean.ShopOrder; |
| | | import com.matrix.system.shopXcx.bean.ShopOrderDetails; |
| | | import com.matrix.system.shopXcx.dao.ShopDeliveryInfoDao; |
| | | import com.matrix.system.shopXcx.dao.ShopOrderDao; |
| | | import com.matrix.system.shopXcx.dao.ShopOrderDetailsDao; |
| | | import com.rabbitmq.client.DeliverCallback; |
| | |
| | | @Autowired |
| | | SysVipInfoDao sysVipInfoDao; |
| | | |
| | | @Autowired |
| | | ShopDeliveryInfoDao shopDeliveryInfoDao; |
| | | |
| | | @Override |
| | | public void handle(String consumerTag, Delivery message) throws IOException { |
| | | String orderId = new String(message.getBody(), "UTF-8"); |
| | | String orderIdStr = new String(message.getBody(), "UTF-8"); |
| | | Integer orderId=Integer.valueOf(orderIdStr); |
| | | //获取订单信息 |
| | | ShopOrder order = shopOrderDao.selectById(Integer.valueOf(orderId)); |
| | | ShopOrder order = shopOrderDao.selectById(orderId); |
| | | LogUtil.debug("收到创建订单通知任务orderId={}", orderId); |
| | | BusParameterSettings wxOrderNoticeDingdingToken = parameterSettingsDao.selectCompanyParamByCode(AppConstance.WX_ORDER_NOTICE_DINGDING_TOKEN, order.getCompanyId()); |
| | | if (wxOrderNoticeDingdingToken != null && StringUtils.isNotBlank(wxOrderNoticeDingdingToken.getParamValue())) { |
| | |
| | | StringBuilder content = new StringBuilder(); |
| | | orderDetails.stream().forEach(i -> content.append(i.getsTitle()).append("*").append( |
| | | i.getCount()).append(";")); |
| | | ShopDeliveryInfo addInfo = shopDeliveryInfoDao.selectByOrderId(orderId); |
| | | |
| | | DingDingRobotUtil.sendText(wxOrderNoticeDingdingToken.getParamValue(),"微商城订单 ("+order.getUserName()+") | 订单金额:¥"+order.getOrderMoney()+",订单内容:"+ content.toString(),""); |
| | | String shippingMethod="物流配送"; |
| | | if(AppConstance.SHIPPING_METHOD_SELF .equals(order.getShippingMethod())){ |
| | | shippingMethod="门店自提"; |
| | | } |
| | | DingDingRobotUtil.sendText(wxOrderNoticeDingdingToken.getParamValue(), |
| | | "新订单,微商城订单编号 "+order.getOrderNo() |
| | | +"; 订单金额:¥"+order.getOrderMoney() |
| | | +";订单内容:"+ content.toString() |
| | | +";收货电话:"+ order.getUserTel()+",收货人:"+ order.getUserName()+",收货地址:"+ addInfo.getReceiveAddress() |
| | | +"配送方式:"+shippingMethod |
| | | ,""); |
| | | }else{ |
| | | LogUtil.debug("未配置订单钉钉提醒"); |
| | | } |