From 13da1c52ac5bb9124ffd31fb6c85ecee45a642e7 Mon Sep 17 00:00:00 2001
From: yinzuomei <yinzuomei@elink-cn.com>
Date: Wed, 18 Dec 2019 14:57:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9EneedCachingUserInfo=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3=E8=8E=B7=E5=8F=96=E7=94=A8=E6=88=B7=E7=BC=93=E5=AD=98?=
 =?UTF-8?q?=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/EpdcAppUserController.java     |  3 +-
 .../java/com/elink/esua/epdc/dao/UserDao.java | 11 ++++++
 .../com/elink/esua/epdc/dao/UserTagDao.java   |  3 ++
 .../elink/esua/epdc/service/UserService.java  | 10 +++++
 .../epdc/service/impl/UserServiceImpl.java    | 25 ++++++++++++
 .../src/main/resources/mapper/UserDao.xml     | 38 +++++++++++++++++++
 .../src/main/resources/mapper/UserTagDao.xml  | 15 ++++++++
 7 files changed, 103 insertions(+), 2 deletions(-)

diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/controller/EpdcAppUserController.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/controller/EpdcAppUserController.java
index 989883a69..668fe130b 100644
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/controller/EpdcAppUserController.java
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/controller/EpdcAppUserController.java
@@ -365,7 +365,6 @@ public class EpdcAppUserController {
      */
     @PostMapping("needCachingUserInfo")
     public Result<CachingUserInfoDTO> needCachingUserInfo(@RequestBody EpdcAppQueryUserInfoFormDTO formDTO) {
-        //TODO:尹作梅
-        return null;
+        return userService.queryCachingUserInfo(formDTO);
     }
 }
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserDao.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserDao.java
index f16a1eeec..531085a61 100644
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserDao.java
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserDao.java
@@ -18,6 +18,7 @@
 package com.elink.esua.epdc.dao;
 
 import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
+import com.elink.esua.epdc.dto.CachingUserInfoDTO;
 import com.elink.esua.epdc.dto.UserDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcUnauthorizedAmountFromDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcUserGroupInviteFormDTO;
@@ -156,4 +157,14 @@ public interface UserDao extends BaseDao<UserEntity> {
      * @Date 2019/12/7 11:23
      **/
     List<EpdcWorkUserResultDTO> selectPartyAuthenticationFailedList(EpdcWorkUserFromDTO workUserFromDto);
+
+    /**
+     * @param openId
+     * @param unionId
+     * @return com.elink.esua.epdc.dto.CachingUserInfoDTO
+     * @Author yinzuomei
+     * @Description 获取用户缓存信息
+     * @Date 2019/12/18 14:12
+     **/
+	CachingUserInfoDTO selectCachingUserInfoDTO(@Param("openId") String openId, @Param("unionId") String unionId);
 }
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserTagDao.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserTagDao.java
index 136991b23..17f4fc75f 100755
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserTagDao.java
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/dao/UserTagDao.java
@@ -18,6 +18,7 @@
 package com.elink.esua.epdc.dao;
 
 import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
+import com.elink.esua.epdc.dto.UserTagInfo;
 import com.elink.esua.epdc.entity.UserTagEntity;
 import org.apache.ibatis.annotations.Mapper;
 
@@ -38,4 +39,6 @@ public interface UserTagDao extends BaseDao<UserTagEntity> {
 	 * @Date 2019/12/17 19:17
 	 **/
 	UserTagEntity selectByTagCode(String tagCode);
+
+	UserTagInfo selectByUserId(String userId);
 }
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/UserService.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/UserService.java
index 6185fc88e..b77aefc7e 100644
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/UserService.java
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/UserService.java
@@ -20,6 +20,7 @@ package com.elink.esua.epdc.service;
 import com.elink.esua.epdc.commons.mybatis.service.BaseService;
 import com.elink.esua.epdc.commons.tools.page.PageData;
 import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.dto.CachingUserInfoDTO;
 import com.elink.esua.epdc.dto.UserDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcUserGroupInviteFormDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcUserRegistFormDTO;
@@ -258,4 +259,13 @@ public interface UserService extends BaseService<UserEntity> {
      * @Date 2019/12/7 13:58
      **/
     Result<UserDTO> queryUserDto(EpdcAppQueryUserInfoFormDTO formDTO);
+
+    /**
+     * @param formDTO
+     * @return com.elink.esua.epdc.commons.tools.utils.Result<com.elink.esua.epdc.dto.CachingUserInfoDTO>
+     * @Author yinzuomei
+     * @Description 获取用户缓存信息
+     * @Date 2019/12/18 14:01
+     **/
+    Result<CachingUserInfoDTO> queryCachingUserInfo(EpdcAppQueryUserInfoFormDTO formDTO);
 }
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java
index 7db3cc563..4e66fa588 100644
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java
@@ -36,6 +36,7 @@ import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
 import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.constant.UserFieldConsant;
 import com.elink.esua.epdc.dao.*;
+import com.elink.esua.epdc.dto.CachingUserInfoDTO;
 import com.elink.esua.epdc.dto.ParentAndAllDeptDTO;
 import com.elink.esua.epdc.dto.UserDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcUserGroupInviteFormDTO;
@@ -767,6 +768,30 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
         return new Result();
     }
 
+    /**
+     * @param formDTO
+     * @return com.elink.esua.epdc.commons.tools.utils.Result<com.elink.esua.epdc.dto.CachingUserInfoDTO>
+     * @Author yinzuomei
+     * @Description 获取用户缓存信息
+     * @Date 2019/12/18 14:01
+     **/
+    @Override
+    public Result<CachingUserInfoDTO> queryCachingUserInfo(EpdcAppQueryUserInfoFormDTO formDTO) {
+        if (StringUtils.isBlank(formDTO.getOpenId())) {
+            throw new RenException("openId不能为空");
+        }
+        CachingUserInfoDTO cachingUserInfoDTO = null;
+        if (StringUtils.isNotBlank(formDTO.getUnionId())) {
+            //根据unionId查询
+            cachingUserInfoDTO = this.baseDao.selectCachingUserInfoDTO(null, formDTO.getUnionId());
+        }
+        if (null == cachingUserInfoDTO) {
+            //根据openId查询
+            cachingUserInfoDTO = this.baseDao.selectCachingUserInfoDTO(formDTO.getOpenId(), null);
+        }
+        return new Result<CachingUserInfoDTO>().ok(cachingUserInfoDTO);
+    }
+
     /**
      * 根据微信信息查询用户
      *
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserDao.xml b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserDao.xml
index 0bd225d9e..80be322a7 100644
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserDao.xml
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserDao.xml
@@ -352,4 +352,42 @@
         LIMIT #{pageIndex},#{pageSize}
     </select>
 
+    <resultMap id="CachingUserInfoDTOMap" type="com.elink.esua.epdc.dto.CachingUserInfoDTO">
+        <result property="id" column="ID"/>
+        <result property="nickname" column="NICKNAME"/>
+        <result property="mobile" column="MOBILE"/>
+        <result property="faceImg" column="FACE_IMG"/>
+        <result property="sex" column="SEX"/>
+        <result property="realName" column="REAL_NAME"/>
+        <result property="gridId" column="gridId"/>
+        <collection property="userTagInfos" select="com.elink.esua.epdc.dao.UserTagDao.selectByUserId"
+                    column="id">
+        </collection>
+    </resultMap>
+    <!--  获取用户缓存信息  -->
+    <select id="selectCachingUserInfoDTO" parameterType="map" resultMap="CachingUserInfoDTOMap">
+        SELECT
+            eu.ID,
+            eu.NICKNAME,
+            eu.MOBILE,
+            eu.FACE_IMG,
+            eu.SEX,
+            eu.REAL_NAME,
+        (select r.GRID_ID
+            from epdc_user_grid_relation r
+            where r.USER_ID=eu.ID
+            order by r.CREATED_TIME desc
+            limit 1
+        )as gridId
+        FROM
+            epdc_user eu
+        WHERE
+            eu.DEL_FLAG = '0'
+        <if test="openId!=null and openId!=''">
+            and eu.WX_OPEN_ID=#{openId}
+        </if>
+        <if test="unionId!=null and unionId!=''">
+            and eu.WX_UNION_ID=#{unionId}
+        </if>
+    </select>
 </mapper>
diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserTagDao.xml b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserTagDao.xml
index aab9d9d05..342b01090 100755
--- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserTagDao.xml
+++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/UserTagDao.xml
@@ -23,4 +23,19 @@
         where m.DEL_FLAG='0'
         and m.TAG_CODE=#{tagCode}
     </select>
+
+    <!--  根据用户id 查询用户标签信息 -->
+    <select id="selectByUserId" resultType="com.elink.esua.epdc.dto.UserTagInfo">
+    SELECT
+        u.id,
+        u.TAG_CODE  as tagCode
+    FROM
+        epdc_user_tag u
+    WHERE u.DEL_FLAG='0'
+       and u.ID IN ( SELECT r.TAG_ID
+                FROM epdc_user_tag_relation r
+                 WHERE r.DEL_FLAG = '0'
+                 AND r.USER_ID = #{userId}
+        )
+    </select>
 </mapper>