From 42521c9b51c1bd9a40036f18fd610cd46601222d Mon Sep 17 00:00:00 2001
From: yanghui <2536613402@qq.com>
Date: 星期一, 28 十一月 2022 14:45:22 +0800
Subject: [PATCH] #feat .

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/api/UserApi.java |  423 +++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 399 insertions(+), 24 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/api/UserApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/api/UserApi.java
index 68fdaa7..278d4b4 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/api/UserApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/api/UserApi.java
@@ -4,6 +4,18 @@
 
 import javax.annotation.Resource;
 
+import cn.hutool.core.util.StrUtil;
+import com.panzhihua.common.model.dtos.DataKanBansDto;
+import com.panzhihua.common.model.dtos.community.convenient.ConvenientMerchantDTO;
+import com.panzhihua.common.model.dtos.community.convenient.DisableOrEnableConvenientMerchantDTO;
+import com.panzhihua.common.model.dtos.community.microCommercialStreet.BindUserPhoneDTO;
+import com.panzhihua.common.model.dtos.community.microCommercialStreet.LoginWithPhoneDTO;
+import com.panzhihua.common.model.dtos.community.microCommercialStreet.McsMerchantDTO;
+import com.panzhihua.common.model.dtos.partybuilding.ComPbCheckUserDTO;
+import com.panzhihua.common.service.community.CommunityService;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.web.bind.annotation.*;
 
 import com.panzhihua.common.model.dtos.PageDTO;
@@ -34,6 +46,7 @@
     @Resource
     private SysUserInputService sysUserInputService;
 
+
     /**
      * 新增微信用户
      *
@@ -47,8 +60,8 @@
      */
     @PostMapping("/addOrUpdate")
     public R addOrUpdate(@RequestParam("openid") String openid, @RequestParam("sessionKey") String sessionKey,
-        @RequestParam("unionid") String unionid) {
-        return userService.updateInsertUser(openid, sessionKey, unionid);
+        @RequestParam("unionid") String unionid,@RequestParam("appId")String appId) {
+        return userService.updateInsertUser(openid, sessionKey, unionid,appId);
     }
 
     /**
@@ -94,10 +107,13 @@
      */
     @PostMapping("/getUserInfo")
     public R<LoginUserInfoVO> getUserInfo(@RequestParam("userName") String userName) {
-        int index = userName.lastIndexOf("_");
-        String type = userName.substring(index + 1);
-        String name = userName.substring(0, index);
-        return userService.getUserInfo(name, Integer.parseInt(type));
+        int index2 = userName.lastIndexOf("_");
+        String appid=userName.substring(index2+1);
+        String username=userName.substring(0,index2);
+        int index = username.lastIndexOf("_");
+        String type = username.substring(index + 1);
+        String name = username.substring(0, index);
+        return userService.getUserInfo(name, Integer.parseInt(type),appid);
     }
 
     /**
@@ -137,6 +153,18 @@
     }
 
     /**
+     * 批量重置密码
+     *
+     * @param userId
+     *            新密码
+     * @return 修改结果
+     */
+    @GetMapping("resetPasswordPatch")
+    public R resetPasswordPatch(@RequestParam("userIds") Long[] userId,@RequestParam("password")String password) {
+        return userService.resetPasswordPatch(userId,password);
+    }
+
+    /**
      * 某社区后台人员查询
      *
      * @param param
@@ -152,7 +180,7 @@
 
     /**
      * 微心愿搜索社区团队人员列表
-     * 
+     *
      * @param param
      *            请求参数
      * @param communityId
@@ -228,7 +256,7 @@
      * @return 人员详情
      */
     @PostMapping("detailuser")
-    public R detailUser(@RequestParam("userId") Long userId) {
+    public R<LoginUserInfoVO> detailUser(@RequestParam("userId") Long userId) {
         return userService.detailUser(userId);
     }
 
@@ -378,6 +406,18 @@
     @PostMapping("putuserbackstage")
     R putUserBackstage(@RequestBody AdministratorsUserVO administratorsUserVO) {
         return userService.putUserBackstage(administratorsUserVO);
+    }
+
+    /**
+     * 更新
+     *
+     * @param administratorsUserVO
+     *            编辑账户内容
+     * @return 编辑结果
+     */
+    @PostMapping("updateStreet")
+    R updateStreet(@RequestBody AdministratorsUserVO administratorsUserVO) {
+        return userService.updateStreetId(administratorsUserVO);
     }
 
     /**
@@ -531,8 +571,8 @@
      * @return 协议内容
      */
     @PostMapping("useragreement")
-    public R userAgreement(@RequestParam("type") int type) {
-        return userService.userAgreement(type);
+    public R userAgreement(@RequestParam("type") int type,@RequestParam("appid")String appId) {
+        return userService.userAgreement(type,appId);
     }
 
     /**
@@ -613,8 +653,8 @@
      * @return 运营后台数据看板
      */
     @PostMapping("datakanban")
-    public R dataKanban() {
-        return userService.dataKanban();
+    public R dataKanban(@RequestParam("areaCode")String areaCode) {
+        return userService.dataKanban(areaCode);
     }
 
     /**
@@ -663,9 +703,14 @@
         return userService.updateUserIsPartymember(idCard);
     }
 
+    @PostMapping("updateuserispartymemberByPhone")
+    public R updateUserIsPartymemberByPhone(@RequestParam("phone") String phone) {
+        return userService.updateUserIsPartymemberByPhone(phone);
+    }
+
     /**
      * 修改用户为非党员状态
-     * 
+     *
      * @param idCard
      *            身份证号
      * @return 修改结果
@@ -683,8 +728,8 @@
      * @return 协议内容
      */
     @PostMapping("agreement")
-    public R agreement(@RequestParam("type") Integer type) {
-        return userService.agreement(type);
+    public R agreement(@RequestParam("type") Integer type,@RequestParam("appId")String appId) {
+        return userService.agreement(type,appId);
     }
 
     /**
@@ -1011,7 +1056,7 @@
 
     /**
      * 修改app用户密码
-     * 
+     *
      * @param userInfoAppDTO
      *            请求参数
      * @return 修改结果
@@ -1023,7 +1068,7 @@
 
     /**
      * 添加网格员
-     * 
+     *
      * @param eventGridMemberAddDTO
      *            请求参数
      * @return 结果
@@ -1035,7 +1080,7 @@
 
     /**
      * 网格员管理
-     * 
+     *
      * @param memberRelationDTO
      *            请求参数
      * @return 网格员列表
@@ -1047,7 +1092,7 @@
 
     /**
      * 修改网格员信息
-     * 
+     *
      * @param gridMemberDTO
      *            请求参数
      * @return 修改结果
@@ -1059,7 +1104,7 @@
 
     /**
      * 重置网格员密码
-     * 
+     *
      * @param gridMemberDTO
      *            请求参数
      * @return 重置结果
@@ -1071,7 +1116,7 @@
 
     /**
      * 批量删除网格员
-     * 
+     *
      * @param Ids
      *            网格员id集合
      * @return 删除结果
@@ -1093,7 +1138,7 @@
 
     /**
      * 查询社区的收益说明
-     * 
+     *
      * @param communityId
      *            社区id
      * @return 收益说明
@@ -1115,7 +1160,7 @@
 
     /**
      * 根据用户id查询用户openid
-     * 
+     *
      * @param userId
      *            用户id
      * @return openid
@@ -1127,7 +1172,7 @@
 
     /**
      * 查询社区后台工作人员列表
-     * 
+     *
      * @param communityId
      *            社区id
      * @return 社区后台工作人员列表
@@ -1147,4 +1192,334 @@
     public R checkCurrentUserIsTeam(String phone, Long communityId) {
         return userService.checkCurrentUserIsTeam(phone, communityId);
     }
+
+    /**
+     * 便民服务新增商家账号
+     * @param convenientMerchantDTO
+     * @return 商家用户id
+     */
+    @PostMapping("insertMerchantAccount")
+    public R addConvenientMerchantUser(@RequestBody ConvenientMerchantDTO convenientMerchantDTO) {
+        return userService.addConvenientMerchantUser(convenientMerchantDTO);
+    }
+
+    /**
+     * 修改便民服务商家绑定账号
+     * @param userId 用户id
+     * @param account 修改账户
+     * @return 修改结果
+     */
+    @PutMapping("putMerchantUserAccount")
+    public R putUserAccount(@RequestParam("userId") Long userId, @RequestParam("account") String account) {
+        return userService.putUserAccount(userId, account);
+    }
+
+    /**
+     * 禁用/启用便民服务商家用户
+     * @param disableOrEnableConvenientMerchantDTO
+     * @return
+     */
+    @PutMapping("disableOrEnableMerchantUsers")
+    public R disableOrEnableMerchantUsers(@RequestBody DisableOrEnableConvenientMerchantDTO disableOrEnableConvenientMerchantDTO) {
+        return userService.disableOrEnableMerchantUsers(disableOrEnableConvenientMerchantDTO);
+    }
+
+    /**
+     * 根据openid维护社区团队里是否注册
+     * @param openid    用户微信唯一标识
+     */
+    @PostMapping("judgeCommunityTeam")
+    public void judgeCommunityTeam(@RequestParam("openid") String openid) {
+        userService.judgeCommunityTeam(openid);
+    }
+
+    /**
+     * 数据看板升级版
+     *
+     * @return 运营后台数据看板升级版
+     */
+    @PostMapping("datakanbans")
+    public R dataKanBans(@RequestBody DataKanBansDto dataKanBansDto) {
+        return userService.dataKanBans(dataKanBansDto);
+    }
+
+    /**
+     * 运营后台-用户数据统计汇总
+     * @return  用户数据统计汇总
+     */
+    @GetMapping("community/statistics")
+    public R communityStatistics(@RequestParam("areaCode") String areaCode) {
+        return userService.communityStatistics(areaCode);
+    }
+
+    @GetMapping("community/statistics/export")
+    public R communityStatisticsExport(@RequestParam("areaCode") String areaCode) {
+        return userService.communityStatisticsExport(areaCode);
+    }
+
+    /**
+     * 通过UnionId获取用户信息
+     * @param unionId
+     * @return
+     */
+    @GetMapping("/getByUnionId")
+    public R getUserInfoByUnionId(@RequestParam("unionId") String unionId) {
+        return userService.getUserInfoByUnionId(unionId);
+    }
+
+    /**
+     * 微商业街新增商家账号
+     * @param mcsMerchantDTO
+     * @return 商家用户id
+     */
+    @PostMapping("insertMcsMerchantAccount")
+    public R addMcsMerchantUser(@RequestBody McsMerchantDTO mcsMerchantDTO) {
+        return userService.addMcsMerchantUser(mcsMerchantDTO);
+    }
+
+    /**
+     * 微商业街修改商家账号
+     * @param mcsMerchantDTO
+     * @return
+     */
+    @PutMapping("putMcsMerchantUser")
+    public R putMcsMerchantUser(@RequestBody McsMerchantDTO mcsMerchantDTO) {
+        return userService.putMcsMerchantUser(mcsMerchantDTO);
+    }
+
+    /**
+     * 检查用户是否有效
+     * @param userId
+     * @param type
+     * @return
+     */
+    @PutMapping("checkUserIsValid")
+    public Boolean checkUserIsValid(@RequestParam("userId") Long userId, @RequestParam("type") Integer type) {
+        return userService.checkUserIsValid(userId, type);
+    }
+
+    /**
+     * 根据手机号、用户类型查询用户
+     * @param phone
+     * @param type
+     * @return
+     */
+    @GetMapping("/getSysUserByPhone")
+    public R getSysUserByPhone(@RequestParam("phone") String phone, @RequestParam("type") Integer type) {
+        return userService.getSysUserByPhone(phone, type);
+    }
+
+    /**
+     * 发送验证码
+     * @param phone 手机号
+     * @param clientIP 用户ip
+     * @param prefixKey redis Key 前缀
+     * @param limit 获取次数限制
+     * @param timeout 超次数获取时间等待
+     * @return
+     */
+    @GetMapping("/sendMessageCode")
+    public R sendMessageCode(@RequestParam("phone") String phone,
+                                     @RequestParam(value = "clientIP", required = false) String clientIP,
+                                     @RequestParam("prefixKey") String prefixKey,
+                                     @RequestParam("limit") Integer limit,
+                                     @RequestParam("timeout") Integer timeout) {
+        return userService.sendMessageCode(phone, clientIP, prefixKey, limit, timeout);
+    }
+
+    /**
+     * 根据openId获取微商业街用户
+     * @param openid
+     * @return
+     */
+    @GetMapping("/getMcsUserByOpenId")
+    public R getMcsUserByOpenId(@RequestParam("openid") String openid) {
+        return userService.getMcsUserByOpenId(openid);
+    }
+
+    /**
+     * 商业街用户微信授权-绑定手机号
+     * @param bindUserPhoneDTO
+     * @return
+     */
+    @PostMapping("/mcs/bindPhone")
+    public R bindOrAddMcsUser(@RequestBody BindUserPhoneDTO bindUserPhoneDTO) {
+        return userService.bindOrAddMcsUser(bindUserPhoneDTO);
+    }
+
+    /**
+     * 删除用户信息缓存
+     * @param phone
+     */
+    @DeleteMapping("/deleteUserCashByPhone")
+    public R deleteUserCashByPhone(@RequestParam("phone") String phone) {
+        return userService.deleteUserCashByPhone(phone);
+    }
+
+    @PostMapping("/update/user/party/status")
+    public R updateUserPartyStatus(@RequestParam("userId") Long userId) {
+        return userService.updateUserPartyStatus(userId);
+    }
+
+    @PostMapping("/uuLogin")
+    public R uuLogin(@RequestBody UuLoginVO uuLoginVO){
+        return userService.uuLogin(uuLoginVO);
+    }
+
+
+    /**
+     * 数据看板:数据总览
+     * @return
+     */
+    @GetMapping("/indexData/totalData")
+    public R indexData(@RequestParam(value = "type",required = false) Integer type,
+                       @RequestParam(value = "streetId",required = false) Long streetId,
+                       @RequestParam(value = "areaCode",required = false) Long areaCode,@RequestParam("appId")String appId){
+        return userService.newIndexData(type,streetId,areaCode,appId);
+    }
+
+    /**
+     * 数据看板:用户占比
+     * @return
+     */
+    @GetMapping("/indexData/userRate")
+    public R userRate(@RequestParam(value = "type",required = false) Integer type,
+                          @RequestParam(value = "streetId",required = false) Long streetId,
+                          @RequestParam(value = "areaCode",required = false) Long areaCode,
+                      @RequestParam(value = "range",required = false) Integer range,@RequestParam("appId")String appId){
+        return userService.userRate(type,streetId,areaCode,range,appId);
+    }
+
+    /**
+     * 数据看板:真实用户统计
+     * @return
+     */
+    @GetMapping("/indexData/realUser")
+    public R realUser(@RequestParam(value = "type",required = false) Integer type,
+                      @RequestParam(value = "streetId",required = false) Long streetId,
+                      @RequestParam(value = "areaCode",required = false) Long areaCode,
+                      @RequestParam(value = "range",required = false) Integer range,@RequestParam(value = "appId",required = false)String appId){
+        return userService.realUser(type,streetId,areaCode,range,appId);
+    }
+
+
+    @GetMapping("/indexData/userActivity")
+    public R userActivity(@RequestParam(value = "type",required = false) Integer type,
+                          @RequestParam(value = "streetId",required = false) Long streetId,
+                          @RequestParam(value = "areaCode",required = false) Long areaCode,
+                          @RequestParam(value = "range",required = false) Integer range,
+                          @RequestParam(value = "appId",required = false) String appId){
+        return userService.userActivity(type,streetId,areaCode,range, appId);
+    }
+
+
+    /**
+     *导出验证密码
+     */
+    @GetMapping("/checkExport")
+    public R checkExport(@RequestParam("account")String account,@RequestParam("password")String password,@RequestParam("oldPassword")String oldPassword){
+        return userService.checkExport(account,password,oldPassword);
+    }
+
+    /**
+     * uu洗车推送
+     * @param washPhone
+     * @param phone
+     * @param washName
+     * @param orderStatus
+     * @return
+     */
+    @GetMapping("/uuPush")
+    public R uuPush(@RequestParam(value = "washPhone",required = false)String washPhone,@RequestParam("phone")String phone,@RequestParam(value = "washName",required = false)String washName,@RequestParam("orderStatus")Integer orderStatus){
+        return userService.uuPush(washPhone,phone,washName,orderStatus);
+    }
+
+    /**
+     * 无水洗车推送
+     * @param washPhone
+     * @param phone
+     * @param washName
+     * @param orderStatus
+     * @return
+     */
+    @GetMapping("/wsPush")
+    public R wsPush(@RequestParam(value = "washPhone",required = false)String washPhone,@RequestParam("phone")String phone,@RequestParam(value = "washName",required = false)String washName,@RequestParam("orderStatus")Integer orderStatus){
+        return userService.wsPush(washPhone,phone,washName,orderStatus);
+    }
+
+    @GetMapping("/indexData/getAreaAndStreet")
+    public R getAreaAndStreet(){
+        return userService.getAreaAndStreet();
+    }
+
+    @GetMapping("/communityList")
+    public R getCommunityList(@RequestParam("name") String name, @RequestParam(value = "id",required = false) Long id){
+        return userService.getCommunityList(name,id);
+    }
+
+    @GetMapping("/getAllCommunityList")
+    public R getAllCommunityList(){
+        return userService.getAllCommunityList();
+    }
+
+    @GetMapping("/resetPasswordAccount")
+    public R resetPasswordAccount(@RequestParam("type")Integer type,@RequestParam("account")String account,@RequestParam("appId")String appId){
+        return userService.resetPassword(type,account,appId);
+    }
+
+    @PostMapping("/tfLogin")
+    public R tfLogin(@RequestBody UuLoginVO uuLoginVO){
+        return userService.tfLogin(uuLoginVO);
+    }
+
+    /**
+     * 三说会堂新增业务中心或专家账号
+     * */
+    @PostMapping("/sanshuoAddUser")
+    public R sanshuoAddUser(@RequestBody AdministratorsUserVO administratorsUserVO){
+        return userService.addExpertOrIndustryCenter(administratorsUserVO);
+    }
+
+    /**
+     * 三说会堂后台重置密码
+     * */
+    @GetMapping("/sanshuoResetPassword")
+    public R sanshuoAddUser(@RequestParam("account") String account,@RequestParam("pass")String password){
+        return userService.resetPassExpertOrIndustryCenter(account,password);
+    }
+
+    /**
+     * 移除账号专家权限
+     *
+     */
+    @GetMapping("/removeExpertRole")
+    public R removeExpertRole(@RequestParam(value = "phone",required = false)String phone){
+        return userService.removeExpertRole(phone);
+    }
+
+    @GetMapping("/accept")
+    public R accept(@RequestParam("userId")Long userId){
+        return userService.accept(userId);
+    }
+
+    @PostMapping("/addComPbCheckUser")
+    public R addComPbCheckUser(@RequestBody ComPbCheckUserDTO comPbCheckUserDTO){
+        return userService.addComPbCheckUser(comPbCheckUserDTO);
+    }
+
+    @PostMapping("/feedBackReply")
+    public R feedBackReply(@RequestBody SysUserFeedbackVO sysUserFeedbackVO){
+        return userService.feedBackReply(sysUserFeedbackVO);
+    }
+
+    @GetMapping("/myFeedBack")
+    public R myFeedBack(@RequestParam("userId")Long id,@RequestParam(value = "type",required = false)Integer type,@RequestParam("propertyId")Long propertyId){
+        return userService.myFeedBack(id,type,propertyId);
+    }
+
+    @GetMapping("/propertyCheck")
+    public R propertyCheck(@RequestParam String phone){
+        return userService.propertyCheck(phone);
+    }
+
 }

--
Gitblit v1.7.1