新增本地缓存

935090232@qq.com

2021-10-25 2151a5efbac31c1f6a1b2563ccb352170aa48c9c

 zq-erp/src/test/java/com/matrix/SalesOrderTaskTest.java

@@ -3,8 +3,8 @@
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.matrix.biz.bean.BizUser;
import com.matrix.biz.service.BizUserService;
import com.matrix.system.hive.bean.SysVipInfo;
import com.matrix.system.hive.service.SysVipInfoService;
import com.matrix.core.constance.MatrixConstance;
import com.matrix.core.tools.LogUtil;
import com.matrix.core.tools.StringUtils;
@@ -53,7 +53,7 @@
    ShopOrderDetailsDao shopOrderDetailsDao;

    @Autowired
    BizUserService bizUserService;
    SysVipInfoService sysVipInfoService;


    @Autowired
@@ -97,7 +97,7 @@
    @Test
    public void handleExtensionOrder() {
       ShopOrder order = new ShopOrder();
       order.setUserId("oJkRK4_pWN2kjp75B_G6oGSWawj0");

       order.setId(1190);
       order.setCompanyId(36L);
       
@@ -118,8 +118,8 @@
       order.setDetails(details);
       order.setOrderMoney(new BigDecimal(0.01));
        //判读客户是否存在上级，存在则产生上级的收益
        BizUser bizUser = bizUserService.findByOpenId(order.getUserId());
        LogUtil.debug("处理分销订单userOpid={}",bizUser.getOpenId());
        SysVipInfo sysVipInfo = sysVipInfoService.findById(order.getUserId());
        LogUtil.debug("处理分销订单userOpid={}",sysVipInfo.getId());
        //判断是否重复生成
        QueryWrapper queryWrapper=new QueryWrapper();
        queryWrapper.eq("order_id",order.getId());
@@ -150,9 +150,9 @@
                if(StringUtils.isNotBlank(item.getShopProduct().getAttrValues())
                        && item.getShopProduct().getAbleSales()==ShopProduct.ABLE_SALES){
                    //分销规则是否开启自购返佣
                    BusParameterSettings zgfy = parameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_ZGFY, bizUser.getCompanyId());
                    BusParameterSettings zgfy = parameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_ZGFY, sysVipInfo.getCompanyId());
                    //按分销等级计算
                    ShopSalesmanGrade shopSalesmanGrade = shopSalesmanGradeDao.selectById(bizUser.getSalesmanGrade());
                    ShopSalesmanGrade shopSalesmanGrade = shopSalesmanGradeDao.selectById(sysVipInfo.getSalesmanGrade());
                    if(ObjectUtil.isNotEmpty(zgfy)) {
                        //获取商品的自购返佣价格,如果没有设置，在去获取当前推广人的等级的自购返佣比例
                       if(StrUtil.isNotEmpty(zgfy.getParamValue()) && 
@@ -178,19 +178,19 @@
                shopSalesmanOrderDao.insert(salesmanOrder);
            }
            //存在上级
            if(StringUtils.isNotBlank(bizUser.getParentOpenId())) {
               BizUser salesMan=bizUserService.findByOpenId(bizUser.getParentOpenId());
            if(sysVipInfo.getRecommendId()!=null) {
               SysVipInfo salesMan=sysVipInfoService.findById(sysVipInfo.getRecommendId());
                Double salesAmount=0D;
                Double invitationAmount=0D;
               BizUser invitationMan=null;
               SysVipInfo invitationMan=null;
               ShopSalesmanOrder invitationOrder=null;
               boolean hasInvitationMan=StringUtils.isNotBlank(salesMan.getParentOpenId());
               boolean hasInvitationMan=salesMan.getRecommendId()!=null;
               //判断推广员是否还存在上级,存在则计算邀请收益
               if(hasInvitationMan){
                  invitationMan=bizUserService.findByOpenId(salesMan.getParentOpenId());
                  invitationMan=sysVipInfoService.findById(salesMan.getRecommendId());
                  invitationOrder=new ShopSalesmanOrder();
                  BeanUtils.copyProperties(salesmanOrder,invitationOrder);
                  invitationOrder.setSalesUserId(invitationMan.getOpenId());
                  invitationOrder.setSalesUserId(invitationMan.getId());
                  invitationOrder.setRevenueType(ShopSalesmanOrder.REVENUE_TYPE_INVITATION);
               }
               //收益计算
@@ -226,7 +226,7 @@
                    zk=order.getOrderMoney().doubleValue()/orderTotal;
                    salesAmount=salesAmount*zk;
                    salesmanOrder.setAmount(salesAmount);
                    salesmanOrder.setSalesUserId(bizUser.getParentOpenId());
                    salesmanOrder.setSalesUserId(sysVipInfo.getRecommendId());
                    shopSalesmanOrderDao.insert(salesmanOrder);
                }
                //邀请提成记录
@@ -237,7 +237,7 @@
                    shopSalesmanOrderDao.insert(invitationOrder);
                } 
            }else{
                LogUtil.debug("不存在父级userOpid={}",bizUser.getOpenId());
                LogUtil.debug("不存在父级userOpid={}",sysVipInfo.getId());
            }
        }else{
            LogUtil.debug("重复订单id={}",order.getId());