用户新功能

cms-common/cms-common-model/src/main/java/com/mmc/iuav/user/model/dto/UserAccountSimpleDTO.java

 package com.mmc.iuav.user.model.dto;
 
+import com.mmc.iuav.user.model.vo.CompanyAuthVO;
+import com.mmc.iuav.user.model.vo.CooperationTagVO;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -48,4 +50,8 @@ public class UserAccountSimpleDTO implements Serializable {
     private Integer companyAuthStatus;
     @ApiModelProperty(value = "合作标签id")
     private Integer cooperationTagId;
+    @ApiModelProperty(value = "认证企业")
+    private String companyName;
+    @ApiModelProperty(value = "合作标签")
+    private String tagName;
 }
\ No newline at end of file

cms-common/cms-common-model/src/main/java/com/mmc/iuav/user/model/qo/UserAccountQO.java

+package com.mmc.iuav.user.model.qo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.data.domain.Page;
+
+import javax.validation.constraints.Min;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * @author: zj
+ * @Date: 2023/6/6 20:41
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class UserAccountQO implements Serializable {
+    private static final long serialVersionUID = -6821428525057467450L;
+    @ApiModelProperty(value = "关键字", required = false, example = "lux")
+    private String keyword;
+
+    @ApiModelProperty(value = "电话号码", required = false)
+    private String phoneNum;
+
+    @ApiModelProperty(value = "用户名", required = false, hidden = true)
+    private String userName;
+
+    @ApiModelProperty(value = "开始时间", example = "2023-05-18 00:00:00")
+    private String startTime;
+
+    @ApiModelProperty(value = "结束时间", example = "2023-10-18 23:59:59")
+    private String endTime;
+
+    @ApiModelProperty(value = "实名认证状态（0未通过，1通过）", hidden = true)
+    private Integer realAuthStatus;
+
+    @ApiModelProperty(value = "企业认证状态（0未通过，1通过）", example = "1")
+    private Integer companyAuthStatus;
+
+    @ApiModelProperty(value = "电子签章认证状态（0未通过，1通过）", hidden = true)
+    private Integer entVerifyStatus;
+
+    @ApiModelProperty(value = "用户来源：0自然流，1海报，2抖音，3公众号，4社群，5招投标，默认0", hidden = true)
+    private Integer source;
+
+    @ApiModelProperty(value = "页码", required = true, example = "1")
+    @NotNull(message = "页码不能为空", groups = Page.class)
+    @Min(value = 1, groups = Page.class)
+    private Integer pageNo;
+
+    @ApiModelProperty(value = "每页显示数", required = true, example = "10")
+    @NotNull(message = "每页显示数不能为空", groups = Page.class)
+    @Min(value = 1, groups = Page.class)
+    private Integer pageSize;
+
+    public void buildCurrentPage() {
+        this.pageNo = (pageNo - 1) * pageSize;
+    }
+}

cms-common/cms-common-model/src/main/java/com/mmc/iuav/user/model/vo/UserAccountVO.java

@@ -59,5 +59,9 @@ public class UserAccountVO implements Serializable {
     private Integer companyAuthStatus;
     @ApiModelProperty(value = "合作标签id")
     private Integer cooperationTagId;
+    @ApiModelProperty(value = "企业名称")
+    private String companyName;
+    @ApiModelProperty(value = "合作标签名称")
+    private String tagName;
 
 }

cms-common/cms-common-util/src/main/java/com/mmc/iuav/group/Page.java

+package com.mmc.iuav.group;
+/** 
+* @author 作者 geDuo
+* @version 创建时间：2021年8月28日 下午5:37:58 
+* @explain 类说明 
+*/
+public interface Page {
+
+}

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/BackUserAccountController.java

@@ -50,7 +50,7 @@ public class BackUserAccountController extends BaseController{
 
     @ApiOperation(value = "账号-删除")
     @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
-    @PostMapping("removeBAccount")
+    @GetMapping("removeBAccount")
     public ResultBody removeBAccount(@RequestParam Integer userAccountId, HttpServletRequest request) {
         return userAccountService.removeBAccount(userAccountId);
     }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/CooperationController.java

@@ -12,6 +12,7 @@ import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.List;
 
 /**
  * @author: zj
@@ -28,7 +29,7 @@ public class CooperationController extends BaseController{
     @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = CooperationTagVO.class) })
     @GetMapping("listTag")
     public ResultBody listTag() {
-        return cooperationService.listTag();
+        return ResultBody.success(cooperationService.listTag());
     }
 
     @ApiOperation(value = "根据id获取标签信息")
@@ -53,4 +54,11 @@ public class CooperationController extends BaseController{
     public ResultBody changeUserTag(@RequestParam("userAccountId") Integer userAccountId, @RequestParam("cooperationTagId") Integer cooperationTagId) {
         return cooperationService.changeUserTag(userAccountId, cooperationTagId);
     }
+
+    @ApiOperation(value = "获取合作渠道标签", hidden = true)
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = CooperationTagVO.class) })
+    @GetMapping("feignListCooperationTag")
+    public List<CooperationTagVO> feignListCooperationTag(){
+        return cooperationService.listTag();
+    }
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/UserAccountController.java

 package com.mmc.iuav.user.controller;
 
+import com.mmc.iuav.group.Page;
 import com.mmc.iuav.group.Update;
 import com.mmc.iuav.response.ResultBody;
 import com.mmc.iuav.user.model.dto.UserAccountSimpleDTO;
+import com.mmc.iuav.user.model.qo.UserAccountQO;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
 import com.mmc.iuav.user.service.UserAccountService;
 import io.swagger.annotations.*;
@@ -25,6 +27,13 @@ public class UserAccountController extends BaseController{
     @Autowired
     private UserAccountService userAccountService;
 
+    @ApiOperation(value = "客户列表")
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = UserAccountVO.class) })
+    @PostMapping("listAppUser")
+    public ResultBody listAppUser(@Validated(value = {Page.class})@RequestBody UserAccountQO userAccountQO){
+        return userAccountService.listAppUser(userAccountQO);
+    }
+
     @ApiOperation(value = "获取用户信息")
     @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = UserAccountVO.class) })
     @GetMapping("info")
@@ -61,4 +70,32 @@ public class UserAccountController extends BaseController{
         return userAccountService.getUserPhoneNumber(this.getUserLoginInfoFromRedis(request).getUserAccountId(), code);
     }
 
+    @ApiOperation(value = "根据用户id查询用户信息", hidden = true)
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = UserAccountSimpleDTO.class) })
+    @PostMapping("feignListUserAccountByIds")
+    public List<UserAccountSimpleDTO> feignListUserAccountByIds(@RequestBody List<Integer> ids){
+        return userAccountService.feignListUserAccountByIds(ids);
+    }
+
+    @ApiOperation(value = "根据用户ids上级推荐人信息", hidden = true)
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = UserAccountSimpleDTO.class) })
+    @PostMapping("feignListRcdUserInfo")
+    public List<UserAccountSimpleDTO> feignListRcdUserInfo(@RequestBody List<Integer> userIds){
+        return userAccountService.feignListRcdUserInfo(userIds);
+    }
+
+    @ApiOperation(value = "查询上级推荐人id", hidden = true)
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = Integer.class) })
+    @GetMapping("feignGetSuperiorRef")
+    public Integer feignGetSuperiorRef(@RequestParam Integer userAccountId){
+        return userAccountService.feignGetSuperiorRef(userAccountId);
+    }
+
+    @ApiOperation(value = "查询上级推荐人信息", hidden = true)
+    @ApiResponses({ @ApiResponse(code = 200, message = "OK", response = UserAccountSimpleDTO.class) })
+    @GetMapping("feignGetUserRcdInfo")
+    public UserAccountSimpleDTO feignGetUserRcdInfo(@RequestParam Integer userAccountId){
+        return userAccountService.feignGetUserRcdInfo(userAccountId);
+    }
+
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/dao/UserServiceDao.java

 package com.mmc.iuav.user.dao;
 
 import com.mmc.iuav.user.entity.UserAccountDO;
+import com.mmc.iuav.user.entity.UserRcdDO;
 import com.mmc.iuav.user.model.qo.BUserAccountQO;
+import com.mmc.iuav.user.model.qo.UserAccountQO;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -104,4 +107,46 @@ public interface UserServiceDao {
      * @return
      */
     UserAccountDO getUserAuthPwdInfo(Integer id);
+
+    /**
+     * 根据id查询用户信息
+     * @param userIds
+     * @return
+     */
+    List<UserAccountDO> listUserAccountByIds(@Param("userIds")List<Integer> userIds);
+
+    /**
+     * 获取用户推荐人信息
+     * @param userIds
+     * @return
+     */
+    List<UserAccountDO> feignListRcdUserInfo(@Param("userIds") List<Integer> userIds);
+
+    /**
+     * 获取推荐人信息
+     * @param userAccountId
+     * @return
+     */
+    UserAccountDO getUserRcdByAccountId(Integer userAccountId);
+
+    /**
+     * 获取用户推荐信息
+     * @param userAccountId
+     * @return
+     */
+    UserRcdDO getUserRcdDO(Integer userAccountId);
+
+    /**
+     * 用户数量
+     * @param param
+     * @return
+     */
+    int countListAppUser(UserAccountQO param);
+
+    /**
+     * 用户信息
+     * @param param
+     * @return
+     */
+    List<UserAccountDO> listAppUser(UserAccountQO param);
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/entity/UserAccountDO.java

@@ -46,6 +46,8 @@ public class UserAccountDO implements Serializable {
 
     private Integer cooperationTagId;
     private Integer companyAuthStatus;
+    private String companyName;
+    private String tagName;
 
     public UserAccountDO(UserAccountVO userAccountVO) {
         this.id = userAccountVO.getId();
@@ -76,13 +78,14 @@ public class UserAccountDO implements Serializable {
     public UserAccountVO buildUserAccountVO() {
         return UserAccountVO.builder().id(this.id).uid(this.uid).accountNo(this.accountNo).accountType(this.accountType).phoneNum(this.phoneNum).userName(this.userName).nickName(this.nickName)
                 .userImg(this.userImg).userSex(this.userSex).email(this.email).source(this.source).accountStatus(this.accountStatus).remark(this.remark).portType(this.portType)
-                .createTime(this.createTime).companyAuthStatus(this.companyAuthStatus).cooperationTagId(this.cooperationTagId).build();
+                .createTime(this.createTime).companyAuthStatus(this.companyAuthStatus == null || this.companyAuthStatus != 1 ? 0 : 1).cooperationTagId(this.cooperationTagId).companyName(this.companyName)
+                .tagName(this.tagName).build();
     }
 
     public UserAccountSimpleDTO buildUserAccountSimpleDTO() {
         return UserAccountSimpleDTO.builder().id(this.id).uid(this.uid).accountNo(this.accountNo).accountType(this.accountType).phoneNum(this.phoneNum).userName(this.userName).nickName(this.nickName)
               .userImg(this.userImg).userSex(this.userSex).email(this.email).source(this.source).accountStatus(this.accountStatus).portType(this.portType)
-                .companyAuthStatus(this.companyAuthStatus == null || this.companyAuthStatus != 1 ? 0 : 1).cooperationTagId(this.cooperationTagId)
+                .companyAuthStatus(this.companyAuthStatus == null || this.companyAuthStatus != 1 ? 0 : 1).cooperationTagId(this.cooperationTagId).companyName(this.companyName)
               .build();
     }
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/entity/UserRcdDO.java

+package com.mmc.iuav.user.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author: zj
+ * @Date: 2023/6/6 17:13
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class UserRcdDO implements Serializable {
+    private static final long serialVersionUID = 5407029715338119583L;
+    private Integer id;
+    private Integer userAccountId;
+    private Integer rcdUserId;
+    private String remark;
+    private Date createTime;
+}

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/CooperationService.java

 package com.mmc.iuav.user.service;
 
 import com.mmc.iuav.response.ResultBody;
+import com.mmc.iuav.user.model.vo.CooperationTagVO;
 import com.mmc.iuav.user.model.vo.UserApplyTagVO;
 
+import java.util.List;
+
 /**
  * @author: zj
  * @Date: 2023/5/17 21:19
@@ -12,7 +15,7 @@ public interface CooperationService {
      * 加盟标签列表
      * @return
      */
-    ResultBody listTag();
+    List<CooperationTagVO> listTag();
 
     /**
      * 用户申请加盟

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/UserAccountService.java

@@ -5,6 +5,7 @@ import com.mmc.iuav.user.entity.UserAccountDO;
 import com.mmc.iuav.user.model.dto.UserAccountSimpleDTO;
 import com.mmc.iuav.user.model.qo.BUserAccountQO;
 import com.mmc.iuav.user.model.qo.LoginUserQO;
+import com.mmc.iuav.user.model.qo.UserAccountQO;
 import com.mmc.iuav.user.model.vo.BUserAccountVO;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
 
@@ -123,4 +124,39 @@ public interface UserAccountService {
      * @return
      */
     ResultBody getUserPhoneNumber(Integer id, String code);
+
+    /**
+     * 根据id获取用户信息
+     * @param ids
+     * @return
+     */
+    List<UserAccountSimpleDTO> feignListUserAccountByIds(List<Integer> ids);
+
+    /**
+     * 根据用户id获取推荐人信息
+     * @param userIds
+     * @return
+     */
+    List<UserAccountSimpleDTO> feignListRcdUserInfo(List<Integer> userIds);
+
+    /**
+     * 获取推荐人id
+     * @param userAccountId
+     * @return
+     */
+    Integer feignGetSuperiorRef(Integer userAccountId);
+
+    /**
+     * 获取推荐人信息
+     * @param userAccountId
+     * @return
+     */
+    UserAccountSimpleDTO feignGetUserRcdInfo(Integer userAccountId);
+
+    /**
+     * 用户列表
+     * @param userAccountQO
+     * @return
+     */
+    ResultBody listAppUser(UserAccountQO userAccountQO);
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/AuthServiceImpl.java

@@ -134,7 +134,6 @@ public class AuthServiceImpl implements AuthService {
     public ResultBody backEndLogin(LoginUserQO param) {
         //查询用户信息
         UserAccountDO user = userAccountService.getUserLoginInfo(param.getAccountNo(), param.getPassWord());
-        System.out.println("login user:---------------->" + user.toString() );
         if (user == null) {
             return ResultBody.error(ResultEnum.LOGIN_ACCOUNT_NOT_EXIT_ERROR);
         }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/CooperationServiceImpl.java

@@ -30,10 +30,10 @@ public class CooperationServiceImpl implements CooperationService {
     private CompanyAuthDao companyAuthDao;
 
     @Override
-    public ResultBody listTag() {
+    public List<CooperationTagVO> listTag() {
         List<CooperationTagDO> list = cooperationDao.listTags();
         List<CooperationTagVO> resList = list.stream().map(CooperationTagDO::buildCooperationTagVO).collect(Collectors.toList());
-        return ResultBody.success(resList);
+        return resList;
     }
 
     @Override

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/UserAccountServiceImpl.java

@@ -7,10 +7,13 @@ import com.mmc.iuav.response.ResultEnum;
 import com.mmc.iuav.user.auth.PwdUtil;
 import com.mmc.iuav.user.dao.CooperationDao;
 import com.mmc.iuav.user.dao.UserServiceDao;
+import com.mmc.iuav.user.entity.CooperationTagDO;
 import com.mmc.iuav.user.entity.UserAccountDO;
+import com.mmc.iuav.user.entity.UserRcdDO;
 import com.mmc.iuav.user.entity.UserTagDO;
 import com.mmc.iuav.user.model.dto.UserAccountSimpleDTO;
 import com.mmc.iuav.user.model.qo.BUserAccountQO;
+import com.mmc.iuav.user.model.qo.UserAccountQO;
 import com.mmc.iuav.user.model.vo.BUserAccountVO;
 import com.mmc.iuav.user.model.vo.CompanyAuthVO;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
@@ -20,9 +23,12 @@ import com.mmc.iuav.user.service.WxService;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.security.NoSuchAlgorithmException;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -229,11 +235,76 @@ public class UserAccountServiceImpl implements UserAccountService {
         if (StringUtils.isBlank(userPhoneNumber)){
             return ResultBody.error(ResultEnum.AUTH_PHONE_NUMBER_ERROR);
         }
-        System.out.println("userPhoneNumber:"+userPhoneNumber);
         UserAccountDO userAccount = new UserAccountDO();
         userAccount.setId(id);
         userAccount.setPhoneNum(userPhoneNumber);
         userServiceDao.update(userAccount);
         return ResultBody.success();
     }
+
+    @Override
+    public List<UserAccountSimpleDTO> feignListUserAccountByIds(List<Integer> ids) {
+        List<UserAccountDO> userAccountDOS = userServiceDao.listUserAccountByIds(ids);
+        if (!CollectionUtils.isEmpty(userAccountDOS)){
+            List<UserAccountSimpleDTO> userAccountSimpleDTOS = userAccountDOS.stream().map(UserAccountDO::buildUserAccountSimpleDTO).collect(Collectors.toList());
+            return userAccountSimpleDTOS;
+        }
+        return null;
+    }
+
+    @Override
+    public List<UserAccountSimpleDTO> feignListRcdUserInfo(List<Integer> userIds) {
+        List<UserAccountDO> userAccountDOS = userServiceDao.feignListRcdUserInfo(userIds);
+        if (!CollectionUtils.isEmpty(userAccountDOS)){
+            List<UserAccountSimpleDTO> userAccountSimpleDTOS = userAccountDOS.stream().map(UserAccountDO::buildUserAccountSimpleDTO).collect(Collectors.toList());
+            return userAccountSimpleDTOS;
+        }
+        return null;
+    }
+
+    @Override
+    public Integer feignGetSuperiorRef(Integer userAccountId) {
+        UserRcdDO userRcdDO = userServiceDao.getUserRcdDO(userAccountId);
+        if (userRcdDO != null){
+            return userRcdDO.getId();
+        }
+        return null;
+    }
+
+    @Override
+    public UserAccountSimpleDTO feignGetUserRcdInfo(Integer userAccountId) {
+        UserAccountDO rcdAccountDO = userServiceDao.getUserRcdByAccountId(userAccountId);
+        if (rcdAccountDO != null){
+            return rcdAccountDO.buildUserAccountSimpleDTO();
+        }
+        return null;
+    }
+
+    @Override
+    public ResultBody listAppUser(UserAccountQO param) {
+        int count = userServiceDao.countListAppUser(param);
+        if (count == 0){
+            return ResultBody.success(PageResult.buildPage(param.getPageNo(), param.getPageSize(), count));
+        }
+        int pageNo = param.getPageNo();
+        param.buildCurrentPage();
+        List<UserAccountDO> userAccountDOList = userServiceDao.listAppUser(param);
+        List<UserAccountDO> res = buildTagInfo(userAccountDOList);
+        List<UserAccountVO> userAccountVOS = res.stream().map(UserAccountDO::buildUserAccountVO).collect(Collectors.toList());
+        return ResultBody.success(PageResult.buildPage(pageNo, param.getPageSize(), count, userAccountVOS));
+    }
+
+    private List<UserAccountDO> buildTagInfo(List<UserAccountDO> userAccountDOList) {
+        List<CooperationTagDO> cooperationTagDOS = cooperationDao.listTags();
+        Map<Integer, CooperationTagDO> cooperationTagDOMap = cooperationTagDOS.stream().collect(Collectors.toMap(CooperationTagDO::getId, d -> d, (k1, k2) -> k2));
+        for (UserAccountDO userAccountDO : userAccountDOList) {
+            CooperationTagDO cooperationTagDO = cooperationTagDOMap.get(userAccountDO.getCooperationTagId());
+            if (cooperationTagDO != null){
+                userAccountDO.setTagName(cooperationTagDO.getTagName());
+            }
+        }
+        return userAccountDOList;
+    }
+
+
 }

csm-service/cms-service-user/src/main/resources/mapper/UserServiceDao.xml

@@ -213,4 +213,104 @@
           and id =
               #{id}
     </select>
+
+    <select id="listUserAccountByIds" resultType="com.mmc.iuav.user.entity.UserAccountDO">
+        select ua.id, ua.account_type, ua.account_no, ua.uid, ua.phone_num, ua.user_name, ua.nick_name, ua.user_img, ua.open_id, ua.union_id, ua.user_sex, ua.email, ua.source, ua.account_status, ua.remark,
+        ua.port_type, ua.is_deleted as deleted, ua.create_time, ua.update_time, ut.cooperation_tag_id, ca.auth_status as companyAuthStatus, ca.company_name
+        from user_account ua left join user_tag ut on ua.id = ut.user_account_id left join company_auth ca on ua.id = ca.user_account_id
+        where ua.is_deleted = 0
+        <if test=" userIds != null ">
+            <foreach collection="userIds" item="id" open="and ua.id in (" close=")" separator=",">
+                #{id}
+            </foreach>
+        </if>
+    </select>
+
+    <select id="feignListRcdUserInfo" resultType="com.mmc.iuav.user.entity.UserAccountDO">
+        select ua.id, ua.account_type, ua.account_no, ua.uid, ua.phone_num, ua.user_name, ua.nick_name, ua.user_img, ua.open_id, ua.union_id, ua.user_sex, ua.email, ua.source, ua.account_status, ua.remark,
+        ua.port_type, ua.is_deleted as deleted, ua.create_time, ua.update_time, ut.cooperation_tag_id, ca.auth_status as companyAuthStatus, ca.company_name
+        from user_rcd ur inner join user_account ua on ua.id = ur.rcd_user_id left join user_tag ut on ua.id = ut.user_account_id left join company_auth ca on ua.id = ca.user_account_id
+        where ua.is_deleted = 0
+        <if test=" userIds != null ">
+            <foreach collection="userIds" item="id" open="and ur.user_account_id in (" close=")" separator=",">
+                #{id}
+            </foreach>
+        </if>
+    </select>
+
+    <select id="getUserRcdByAccountId" resultType="com.mmc.iuav.user.entity.UserAccountDO">
+        select ua.id, ua.account_type, ua.account_no, ua.uid, ua.phone_num, ua.user_name, ua.nick_name, ua.user_img, ua.open_id, ua.union_id, ua.user_sex, ua.email, ua.source, ua.account_status, ua.remark,
+        ua.port_type, ua.is_deleted as deleted, ua.create_time, ua.update_time, ut.cooperation_tag_id, ca.auth_status as companyAuthStatus, ca.company_name
+        from user_rcd ur inner join user_account ua on ua.id = ur.rcd_user_id left join user_tag ut on ua.id = ut.user_account_id left join company_auth ca on ua.id = ca.user_account_id
+        where ua.is_deleted = 0 and ur.user_account_id = #{userAccountId}
+    </select>
+
+    <select id="getUserRcdDO" resultType="com.mmc.iuav.user.entity.UserRcdDO">
+        select id, user_account_id,rcd_user_id from user_rcd where user_account_id = #{userAccountId}
+    </select>
+
+    <select id="countListAppUser" resultType="int" parameterType="com.mmc.iuav.user.model.qo.UserAccountQO">
+        SELECT
+        count(*)
+        FROM
+        user_account ua
+        LEFT JOIN company_auth ca ON ua.id = ca.user_account_id
+        WHERE
+        ua.is_deleted = 0 and ua.port_type = 100
+        <if test="phoneNum != null and phoneNum != '' ">
+            and ( ua.phone_num like CONCAT("%",#{phoneNum},"%") )
+        </if>
+        <if test="companyAuthStatus != null ">
+            AND ca.auth_status >= #{companyAuthStatus}
+        </if>
+        <if test="startTime != null ">
+            AND ua.create_time >= #{startTime}
+        </if>
+        <if test="endTime != null ">
+            and #{endTime} >= ua.create_time
+        </if>
+        <if test="source != null ">
+            and ua.source = #{source}
+        </if>
+        <if test="keyword != null and keyword != '' ">
+            and (
+            ua.user_name like CONCAT("%",#{keyword},"%")
+            or ua.nick_name like CONCAT("%",#{keyword},"%")
+            or ua.uid like CONCAT("%",#{keyword},"%")
+            )
+        </if>
+    </select>
+
+    <select id="listAppUser" resultType="com.mmc.iuav.user.entity.UserAccountDO" parameterType="com.mmc.iuav.user.model.qo.UserAccountQO">
+        select ua.id, ua.account_type, ua.account_no, ua.uid, ua.phone_num, ua.user_name, ua.nick_name, ua.user_img, ua.open_id, ua.union_id, ua.user_sex, ua.email, ua.source, ua.account_status, ua.remark,
+        ua.port_type, ua.is_deleted as deleted, ua.create_time, ua.update_time, ut.cooperation_tag_id, ca.auth_status as companyAuthStatus, ca.company_name
+        from user_account ua left join user_tag ut on ua.id = ut.user_account_id left join company_auth ca on ua.id = ca.user_account_id
+        where
+            ua.is_deleted = 0 and ua.port_type = 100
+        <if test="phoneNum != null and phoneNum != '' ">
+            and ( ua.phone_num like CONCAT("%",#{phoneNum},"%") )
+        </if>
+        <if test="companyAuthStatus != null and companyAuthStatus != 0">
+            AND ca.auth_status >= #{companyAuthStatus}
+        </if>
+        <if test="startTime != null ">
+            AND ua.create_time >= #{startTime}
+        </if>
+        <if test="endTime != null ">
+            and #{endTime} >= ua.create_time
+        </if>
+        <if test="source != null ">
+            and ua.source = #{source}
+        </if>
+        <if test="keyword != null and keyword != '' ">
+            and (
+            ua.user_name like CONCAT("%",#{keyword},"%")
+            or ua.nick_name like CONCAT("%",#{keyword},"%")
+            or ua.uid like CONCAT("%",#{keyword},"%")
+            )
+        </if>
+        order by ua.create_time desc
+        limit #{pageNo}, #{pageSize}
+    </select>
+
 </mapper>
\ No newline at end of file