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