From 4a3777f7aca51a51755c2d8db2191f3cf174db7a Mon Sep 17 00:00:00 2001
From: jyy <935090232@qq.com>
Date: Fri, 12 Mar 2021 13:51:47 +0800
Subject: [PATCH] 新增申请成为分销员接口8
---
zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderTask.java | 71 ++++++++++++++++++++++++++++++++++-
1 files changed, 68 insertions(+), 3 deletions(-)
diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderTask.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderTask.java
index 8fd2018..63374e7 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderTask.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/OrderTask.java
@@ -3,11 +3,15 @@
import com.matrix.biz.bean.BizUser;
import com.matrix.biz.service.BizUserService;
+import com.matrix.core.constance.MatrixConstance;
import com.matrix.core.tools.LogUtil;
import com.matrix.core.tools.StringUtils;
import com.matrix.system.common.constance.AppConstance;
import com.matrix.system.common.dao.BusParameterSettingsDao;
import com.matrix.system.constance.Dictionary;
+import com.matrix.system.fenxiao.dao.ShopSalesmanGradeDao;
+import com.matrix.system.fenxiao.dao.ShopSalesmanOrderDao;
+import com.matrix.system.fenxiao.entity.ShopSalesmanOrder;
import com.matrix.system.hive.bean.*;
import com.matrix.system.hive.dao.*;
import com.matrix.system.hive.service.CodeService;
@@ -78,6 +82,12 @@
@Autowired
private ShoppingGoodsDao shoppingGoodsDao;
+ @Autowired
+ private ShopSalesmanOrderDao shopSalesmanOrderDao;
+
+ @Autowired
+ private ShopSalesmanGradeDao shopSalesmanGradeDao;
+
@Transactional(rollbackFor = Exception.class)
public void createOrder(ShopOrder orderDto) {
@@ -93,6 +103,7 @@
BizUser bizUser = bizUserService.findByOpenId(orderDto.getUserId());
SysOrder order = new SysOrder();
+ //TODO 根据公司id区分
SysVipInfo vipInfo = vipDao.selectByPhone(bizUser.getPhoneNumber());
if(SysVipInfo.UNDEAL_VIP==vipInfo.getIsDeal()){
//非成交客户下单更新客户为成交客户
@@ -101,7 +112,7 @@
}
//获取订单归属门店
- order.setCompanyId(vipInfo.getCompanyId());
+ order.setCompanyId(orderDto.getCompanyId());
order.setShopId(Long.parseLong(orderDto.getStoreId()+""));
//同步的订单订单编号保持一致
order.setOrderNo(orderDto.getOrderNo());
@@ -116,7 +127,7 @@
order.setTotal(orderDto.getOrderMoney().doubleValue());
order.setZkTotal(orderDto.getOrderMoney().doubleValue());
order.setPayTime(new Date());
- order.setArrears(0);
+ order.setArrears(0D);
int i = sysOrderDao.insert(order);
// 创建订单明细,并计算总价与折扣总价
int count = 0;
@@ -236,7 +247,61 @@
//获取订单详情
List<ShopOrderDetails> orderDetails = shopOrderDetailsDao.selectByOrderId(Integer.valueOf(orderId));
order.setDetails(orderDetails);
- createOrder(order);
+ //同步订单到erp
+ synchronizationOrderToErp(order);
+ //处理分销订单
+ handleExtensionOrder(order);
+
+ }
+
+ /**
+ * 处理分销订单
+ * @param order
+ */
+ @Transactional
+ void handleExtensionOrder(ShopOrder order) {
+ //判读客户是否存在上级，存在则产生上级的收益
+ BizUser bizUser = bizUserService.findByOpenId(order.getUserId());
+ if(StringUtils.isNotBlank(bizUser.getParentOpenId())){
+ LogUtil.debug("处理分销订单userOpid={}",bizUser.getOpenId());
+ //存在上级
+ ShopSalesmanOrder shopSalesmanOrder=new ShopSalesmanOrder();
+ shopSalesmanOrder.setCompanyId(order.getCompanyId());
+ shopSalesmanOrder.setCreateBy(MatrixConstance.SYSTEM_USER);
+ shopSalesmanOrder.setUpdateBy(MatrixConstance.SYSTEM_USER);
+ shopSalesmanOrder.setCreateTime(new Date());
+ shopSalesmanOrder.setUpdateTime(new Date());
+ shopSalesmanOrder.setOrderId(Long.parseLong(order.getId()+""));
+ shopSalesmanOrder.setUserId(order.getUserId());
+ shopSalesmanOrder.setSalesUserId(bizUser.getParentOpenId());
+ shopSalesmanOrder.setRevenueType(ShopSalesmanOrder.REVENUE_TYPE_SALES);
+ shopSalesmanOrder.setOrderStatus(ShopSalesmanOrder.STATUS_DJS);
+ Double amount=0D;
+ for (ShopOrderDetails item:order.getDetails() ){
+ if(StringUtils.isNotBlank(item.getShopProduct().getAttrValues())
+ && item.getShopProduct().getAttrValues().contains("分销商城")){
+ if(item.getShopSku().getSealesPrice()==null
+ ||item.getShopSku().getSealesPrice().doubleValue()==0){
+ //按分销等级计算
+ BizUser salesMan=bizUserService.findByOpenId(bizUser.getParentOpenId());
+ shopSalesmanGradeDao.selectById(salesMan.getSalesmanGrade())
+
+ }else{
+ //按产品设置的金额计算
+ amount+=item.getShopSku().getSealesPrice().doubleValue();
+ }
+
+ }
+ }
+
+
+
+
+
+ }else{
+ LogUtil.debug("不存在父级userOpid={}",bizUser.getOpenId());
+ }
+
}
}
--
Gitblit v1.9.1