From a2b83e708f265bf80e8c448cd4c3ca3dc09216d8 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期三, 24 一月 2024 14:14:18 +0800
Subject: [PATCH] 新增加管理后台数据权限

---
 ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java |   53 ++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 44 insertions(+), 9 deletions(-)

diff --git a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
index 9df1d7a..258fcad 100644
--- a/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
+++ b/ruoyi-modules/ruoyi-member/src/main/java/com/ruoyi/member/service/impl/member/MemberServiceImpl.java
@@ -8,6 +8,7 @@
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.exception.ServiceException;
 import com.ruoyi.common.core.utils.DateUtils;
 import com.ruoyi.common.core.utils.StringUtils;
@@ -113,6 +114,12 @@
 
     @Resource
     private RemoteOrderService remoteOrderService;
+
+    @Resource
+    private RemoteUserService remoteUserService;
+
+
+
 
     /**
      * @description: TODO
@@ -292,7 +299,6 @@
     }
 
     public static String getMobileByWX(String accessToken, String code) throws Exception {
-        String method = "POST";
         Map<String, String> headers = new HashMap<>(16);
         headers.put("Content-Type", "application/json");
         headers.put("Accept", "application/json");
@@ -321,6 +327,7 @@
         appUserInfoVo.setNickName(member.getNickName());
         appUserInfoVo.setRealName(member.getRealName());
         appUserInfoVo.setPhonenumber(member.getMobile());
+        //绑定会员显示绑定店铺
         if (member.getRelationShopId() != null && member.getBindingFlag() == 1) {
             appUserInfoVo.setRelationShopId(member.getRelationShopId());
             Shop shop = shopService.getShop(member.getRelationShopId()).getData();
@@ -330,9 +337,11 @@
         appUserInfoVo.setBirthday(member.getBirthday());
         appUserInfoVo.setGender(member.getGender());
         appUserInfoVo.setAvatar(member.getAvatar());
+        //待支付待核销统计
         AppOrderTotalVo appOrderTotalVo = orderService.getAppOrderTotal(userId).getData();
         appUserInfoVo.setNoPayCount(appOrderTotalVo.getNoPayCount());
         appUserInfoVo.setNoUseCount(appOrderTotalVo.getNoUseCount());
+        //积分
         MemberTotal memberTotal = memberTotalService.getById(member.getMemberId());
         appUserInfoVo.setIntegral(memberTotal.getUseableIntegral());
         return appUserInfoVo;
@@ -622,8 +631,14 @@
         String phoneNumber = merMemberAddDto.getPhonenumber();
         Member oldMember = this.getByMobile(phoneNumber);
         // Check if the member already exists
-        if (oldMember != null) {
+        if (oldMember != null && oldMember.getBindingFlag() == 1) {
             throw new ServiceException(AppErrorConstant.MOBILE_USER_DOUBLE);
+        }
+        if (oldMember != null && oldMember.getBindingFlag() == 0) {
+            oldMember.setRelationShopId(merMemberAddDto.getShopId());
+            oldMember.setBindingFlag(1);
+            this.updateById(oldMember);
+            return oldMember.getUserId();
         }
         // Get the sysUser by mobile number
         SysUser sysUser = sysUserService.getSysUserByMobile(phoneNumber).getData();
@@ -940,6 +955,15 @@
                 //活跃度赋值
                 Date lastPayTime;
                 for (MgtMemberPageVo mgtMemberPageVo : memberPageVoList) {
+                    if(null != mgtMemberPageVo.getRelationShopId() && 1 == mgtMemberPageVo.getBindingFlag()){
+                        R<Shop> shop_r = remoteShopService.getShop(mgtMemberPageVo.getRelationShopId());
+                        if(shop_r.getCode() == 200){
+                            Shop data = shop_r.getData();
+                            if(null != data){
+                                mgtMemberPageVo.setRelationShopName(data.getShopName());
+                            }
+                        }
+                    }
                     lastPayTime = mgtMemberPageVo.getLastPayTime();
                     StringJoiner sj = new StringJoiner(",");
                     if (lastPayTime != null) {
@@ -1135,7 +1159,13 @@
         mgtMemberGetVo.setLastPayTime(memberTotal.getLastPayTime());
         mgtMemberGetVo.setGoodsType(member.getGoodsType());
         if(member.getBindingFlag()==1){
-            mgtMemberGetVo.setRelationShopName(member.getRelationShopName());
+            R<Shop> shop = remoteShopService.getShop(member.getRelationShopId());
+            if(shop.getCode() == 200){
+                Shop data = shop.getData();
+                if(null != data){
+                    mgtMemberGetVo.setRelationShopName(data.getShopName());
+                }
+            }
         }
         mgtMemberGetVo.setIntegral(memberTotal.getTotalIntegral());
         mgtMemberGetVo.setMemberFrom(member.getCustomerSource());
@@ -1212,10 +1242,10 @@
      * @date 2023/6/18 16:45
      */
     @Override
-    public MgtBulletinBoardVo boardMemberTotal() {
+    public MgtBulletinBoardVo boardMemberTotal(List<Long> userIds) {
         MgtBulletinBoardVo mgtBulletinBoardVo = new MgtBulletinBoardVo();
-        mgtBulletinBoardVo.setMemberTotal(memberMapper.memberTotal());
-        mgtBulletinBoardVo.setMemberToday(memberMapper.memberToday());
+        mgtBulletinBoardVo.setMemberTotal(memberMapper.memberTotal(userIds));
+        mgtBulletinBoardVo.setMemberToday(memberMapper.memberToday(userIds));
         return mgtBulletinBoardVo;
     }
 
@@ -1421,6 +1451,10 @@
             }else{
                 return plTotalMemberTotalVo;
             }
+            List<Long> userId = remoteUserService.getScopeOfAuthorityUserId();
+            List<Shop> shops = remoteShopService.getShopBySysUserIds(userId);
+            List<Long> collect = shops.stream().map(Shop::getShopId).collect(Collectors.toList());
+            list.addAll(collect);
             mgtBasePlatformDto.setShopIdList(list);
         }
         //获取基础统计
@@ -2167,12 +2201,13 @@
      */
     @Override
     public void sendBirthdayBless(){
-        List<String> mobileList = memberMapper.listTodayBirthday();
+        List<Member> mobileList = memberMapper.listTodayBirthday();
         if(mobileList!=null&&!mobileList.isEmpty()){
             log.info("生日祝福发送短信---"+mobileList.toString());
-            for(String mobile : mobileList){
+            for(Member member : mobileList){
                 try {
-                    MsgUtils.sendMsg(mobile,null,null);
+                    String msg = "{\"name\":\"" + (StringUtils.isEmpty(member.getRealName()) ? member.getNickName() : member.getRealName()) + "\"}";
+                    MsgUtils.sendMsg(member.getMobile(),null, msg);
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }

--
Gitblit v1.7.1