From b2c975094e4a3cac5ba67c154e9b7b4fd0ce35c9 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期一, 25 四月 2022 17:34:36 +0800
Subject: [PATCH] 花城E+防疫修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java |   59 +++++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 49 insertions(+), 10 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
index 491636f..12c2e7a 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
@@ -1975,6 +1975,30 @@
     /**
      * 修改用户的党员状态
      *
+     * @param phone
+     *            身份证号
+     * @return 修改结果
+     */
+    @Override
+    public R updateUserIsPartymemberByPhone(String phone) {
+        SysUserDO sysUserDO = userDao.selectOne(
+                new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone, phone).eq(SysUserDO::getType, 1));
+        if (sysUserDO != null) {
+            sysUserDO.setIsPartymember(1);
+            int updated = userDao.updateById(sysUserDO);
+            if (updated > 0) {
+                // 删除用户信息缓存
+                String userKey = UserConstants.LOGIN_USER_INFO + sysUserDO.getUserId();
+                stringRedisTemplate.delete(userKey);
+            }
+            log.info("新增党员修改用户党员状态成功 手机号【{}】", phone);
+        }
+        return R.ok();
+    }
+
+    /**
+     * 修改用户的党员状态
+     *
      * @param idCard
      *            身份证号
      * @return 修改结果
@@ -2315,7 +2339,7 @@
 
     /**
      * 修改app用户密码
-     * 
+     *
      * @param userInfoAppDTO
      *            请求参数
      * @return 修改结果
@@ -2347,7 +2371,7 @@
 
     /**
      * 添加网格员
-     * 
+     *
      * @param eventGridMemberAddDTO
      *            请求参数
      * @return 结果
@@ -2464,7 +2488,7 @@
 
     /**
      * 网格员管理
-     * 
+     *
      * @param memberRelationDTO
      *            请求参数
      * @return 网格员列表
@@ -2501,7 +2525,7 @@
 
     /**
      * 修改网格员信息
-     * 
+     *
      * @param gridMemberDTO
      *            请求参数
      * @return 修改结果
@@ -2597,7 +2621,7 @@
 
     /**
      * 重置网格员密码
-     * 
+     *
      * @param gridMemberDTO
      *            请求参数
      * @return 重置结果
@@ -2615,7 +2639,7 @@
 
     /**
      * 批量删除网格员
-     * 
+     *
      * @param Ids
      *            网格员id集合
      * @return 删除结果
@@ -2654,7 +2678,7 @@
 
     /**
      * 查询社区的收益说明
-     * 
+     *
      * @param communityId
      *            社区id
      * @return 收益说明
@@ -2701,7 +2725,7 @@
 
     /**
      * 根据用户id查询用户openid
-     * 
+     *
      * @param userId
      *            用户id
      * @return openid
@@ -2717,7 +2741,7 @@
 
     /**
      * 查询社区后台工作人员列表
-     * 
+     *
      * @param communityId
      *            社区id
      * @return 社区后台工作人员列表
@@ -2851,7 +2875,7 @@
         userDao.disableOrEnableMerchantUsers(disableOrEnableConvenientMerchantDTO.getType(), disableOrEnableConvenientMerchantDTO.getUserIds());
         return R.ok();
     }
-    
+
     /**
      * 根据openid维护社区团队里是否注册
      * @param openid    用户微信唯一标识
@@ -3210,4 +3234,19 @@
         }
         return rs.toString();
     }
+
+    @Override
+    public R updateUserPartyStatus(Long userId) {
+        SysUserDO sysUserDO = userDao.selectById(userId);
+        if (sysUserDO != null) {
+            sysUserDO.setIsPartymember(1);
+            int updated = userDao.updateById(sysUserDO);
+            if (updated > 0) {
+                // 删除用户信息缓存
+                String userKey = UserConstants.LOGIN_USER_INFO + sysUserDO.getUserId();
+                stringRedisTemplate.delete(userKey);
+            }
+        }
+        return R.ok();
+    }
 }

--
Gitblit v1.7.1