From bbe0a2fd03063316e50cf141986bda984599bbda Mon Sep 17 00:00:00 2001
From: 935090232@qq.com <ak473600000>
Date: Tue, 22 Feb 2022 23:41:42 +0800
Subject: [PATCH] Merge branch 'developer'

---
 zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxUserAction.java |   57 +++++++++++++++++++++++++++++++++------------------------
 1 files changed, 33 insertions(+), 24 deletions(-)

diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxUserAction.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxUserAction.java
index c4c6da2..e07d511 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxUserAction.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxUserAction.java
@@ -2,20 +2,23 @@
 
 import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.matrix.component.redis.RedisUserLoginUtils;
+import com.matrix.system.common.constance.AppConstance;
+import com.matrix.system.common.init.UserCacheManager;
 import com.matrix.component.tools.HttpCurlUtil;
-import com.matrix.component.wechat.externalInterface.weixinUtil.WeixinServiceUtil;
 import com.matrix.core.pojo.AjaxResult;
 import com.matrix.core.tools.LogUtil;
 import com.matrix.core.tools.StringUtils;
 import com.matrix.core.web.BaseAction;
+import com.matrix.system.activity.dao.ActivitySignReceiveRecordDao;
 import com.matrix.system.common.bean.BusParameterSettings;
 import com.matrix.system.common.dao.BusParameterSettingsDao;
 import com.matrix.system.common.interceptor.HostInterceptor;
 import com.matrix.system.constance.Dictionary;
 import com.matrix.system.fenxiao.constant.FenxiaoSettingConstant;
 import com.matrix.system.fenxiao.dao.ShopSalesmanApplyDao;
+import com.matrix.system.fenxiao.dao.ShopSalesmanGradeDao;
 import com.matrix.system.fenxiao.entity.ShopSalesmanApply;
+import com.matrix.system.fenxiao.entity.ShopSalesmanGrade;
 import com.matrix.system.fenxiao.service.ShopSalesmanApplyService;
 import com.matrix.system.hive.bean.SysVipInfo;
 import com.matrix.system.hive.dao.MoneyCardUseDao;
@@ -54,7 +57,7 @@
     @Autowired
     BusParameterSettingsDao busParameterSettingsDao;
     @Autowired
-    private RedisUserLoginUtils redisUserLoginUtils;
+    private UserCacheManager userCacheManager;
     @Autowired
     ShopSalesmanApplyDao salesmanApplyDao;
 
@@ -68,8 +71,10 @@
     private MoneyCardUseDao moneyCardUseDao;
 
     @Autowired
-    private WeixinServiceUtil weixinServiceUtil;
+    ShopCouponRecordDao shopCouponRecordDao;
 
+    @Autowired
+    ActivitySignReceiveRecordDao activitySignReceiveRecordDao;
     @Value("${debug}")
     private String isDebug;
 
@@ -123,14 +128,14 @@
                     sysVipInfo.setVipNo(openId);
                     sysVipInfoService.add(sysVipInfo);
 
-                }else{
+                } else {
                     sysVipInfo.setSessionKey(sessionKey);
                     sysVipInfoDao.update(sysVipInfo);
                 }
             }
             // 存放redis
             sysVipInfo.setLevelCard(null);
-            String token = redisUserLoginUtils.saveUserInfo(sysVipInfo);
+            String token = userCacheManager.saveUserInfo(sysVipInfo);
             LogUtil.info("用户token={}", token);
             res.putInMap("token", token);
             res.putInMap("userInfo", sysVipInfo);
@@ -142,8 +147,9 @@
         return res;
     }
 
+
     @Autowired
-    ShopCouponRecordDao shopCouponRecordDao;
+    ShopSalesmanGradeDao shopSalesmanGradeDao;
 
     /**
      * 查询用户信息
@@ -151,14 +157,23 @@
     @RequestMapping(value = "/findUserInfo")
     public @ResponseBody
     AjaxResult findUserInfo() {
-        SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
+        SysVipInfo loginUser = userCacheManager.getLoginUser();
         SysVipInfo sysVipInfo = sysVipInfoService.findById(loginUser.getId());
         sysVipInfo.setPointAll(scoreVipDetailDao.selectUserTotalScore(loginUser.getId()));
         sysVipInfo.setBalance(moneyCardUseDao.selectVipCardTotalMoney(loginUser.getId()));
         AjaxResult res = new AjaxResult();
         res.putInMap("couponCount", shopCouponRecordDao.countUnuseCouponRecord(loginUser.getId()));
-        res.putInMap("prizeCount",0);
+        res.putInMap("prizeCount", activitySignReceiveRecordDao.getSignAwardReceiveCount(loginUser.getId(), loginUser.getCompanyId()));
         res.putInMap("userInfo", sysVipInfo);
+        //查询会员等级
+        if (sysVipInfo.getSalesmanGrade() != null) {
+            ShopSalesmanGrade shopSalesmanGrade = shopSalesmanGradeDao.selectById(sysVipInfo.getSalesmanGrade());
+            res.putInMap("vipLevel", shopSalesmanGrade.getName());
+        } else if (sysVipInfo.getVipLevel() != null) {
+            res.putInMap("vipLevel", sysVipInfo.getVipLevel().getLevelName());
+        } else {
+            res.putInMap("vipLevel", "初级会员");
+        }
         res.setStatus(AjaxResult.STATUS_SUCCESS);
         return res;
     }
@@ -170,7 +185,7 @@
     public @ResponseBody
     AjaxResult findUserInfo(@PathVariable String openId) {
         SysVipInfo sysVipInfo = sysVipInfoService.findByOpenId(openId);
-        SysVipInfo bizUserQuery=new SysVipInfo();
+        SysVipInfo bizUserQuery = new SysVipInfo();
         bizUserQuery.setNickName(sysVipInfo.getNickName());
         bizUserQuery.setAvatarUrl(sysVipInfo.getAvatarUrl());
         bizUserQuery.setOpenId(openId);
@@ -185,17 +200,17 @@
     public @ResponseBody
     AjaxResult saveUserInfo(@RequestBody XcxUserSaveUserInfoDto xcxUserSaveUserInfoDto) {
 
-        SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
-        SysVipInfo sysVipInfo=new SysVipInfo();
+        SysVipInfo loginUser = userCacheManager.getLoginUser();
+        SysVipInfo sysVipInfo = new SysVipInfo();
         sysVipInfo.setId(loginUser.getId());
 
-        BeanUtil.copyProperties(xcxUserSaveUserInfoDto,sysVipInfo);
+        BeanUtil.copyProperties(xcxUserSaveUserInfoDto, sysVipInfo);
         sysVipInfo.setPhone(xcxUserSaveUserInfoDto.getPhoneNumber());
-        if(StringUtils.isBlank(loginUser.getVipName())||loginUser.getVipName().equals("微信用户")){
+        if (StringUtils.isBlank(loginUser.getVipName()) || loginUser.getVipName().equals("微信用户")) {
             sysVipInfo.setVipName(xcxUserSaveUserInfoDto.getNickName());
         }
-        if(StringUtils.isBlank(loginUser.getSex())){
-            sysVipInfo.setSex(xcxUserSaveUserInfoDto.getGender()==1?"男":"女");
+        if (StringUtils.isBlank(loginUser.getSex())) {
+            sysVipInfo.setSex(xcxUserSaveUserInfoDto.getGender() == 1 ? "男" : "女");
         }
 
         int i = sysVipInfoDao.update(sysVipInfo);
@@ -208,13 +223,12 @@
     }
 
 
-
     void checkNeedToBeSalesman(SysVipInfo sysVipInfo, SysVipInfo loginUser) {
         //查询是否需要自动成为分销员
         if ((loginUser.getIsSales() == null || loginUser.getIsSales() == 2)
                 && StringUtils.isNotBlank(sysVipInfo.getNickName())) {//目前还不是分销员
             BusParameterSettings fxSwith = busParameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_SWITCH, HostInterceptor.getCompanyId());
-            if (fxSwith.getParamValue().equals("1")) {//开启分销
+            if (fxSwith!=null && fxSwith.getParamValue().equals("1")) {//开启分销
                 BusParameterSettings applyWay = busParameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_APPLY_WAY, loginUser.getCompanyId());
                 if (applyWay.getParamValue().equals(FenxiaoSettingConstant.FX_APPLY_WAY_AUTO)) {//自动成为分销员
                     QueryWrapper<ShopSalesmanApply> queryWrapper = new QueryWrapper<>();
@@ -222,12 +236,7 @@
                     queryWrapper.eq("apply_status", ShopSalesmanApply.APPLY_STATUS_DSH);
                     ShopSalesmanApply shopSalesmanApply = salesmanApplyDao.selectOne(queryWrapper);
                     if (shopSalesmanApply == null) {//没有待审核记录
-                        try {
-                            shopSalesmanApplyService.applyToBeAnSalesman(loginUser.getId(), null, null, 2);
-                        }catch (Exception e){
-                            LogUtil.debug(e.getMessage());
-                        }
-
+                        shopSalesmanApplyService.applyToBeAnSalesman(loginUser.getId(), null, null, 2);
                     }
                 }
             }

--
Gitblit v1.9.1