居民端-根据userId获取用户访问过的网格列表

epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllGridsByUserIdResultDTO.java

@@ -0,0 +1,31 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Auther sun
+ * 获取用户访问过的所有网格列表-接口返参
+ */
+@Data
+public class AllGridsByUserIdResultDTO implements Serializable {
+
+    private static final long serialVersionUID = -1L;
+
+    /**
+     * 客户Id
+     */
+    private String customerId;
+
+    /**
+     * 网格Id
+     */
+    private String gridId;
+
+    /**
+     * 网格名称
+     */
+    private String gridName;
+
+}

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerGridController.java

@@ -171,4 +171,15 @@ public class CustomerGridController {
         return customerGridService.getAgencyAndStaffsBygridId(gridId);
     }
 
+    /**
+     * @param gridIdList
+     * @return
+     * @Description 根据网格Id集合获取网格列表信息
+     * @Author sun
+     */
+    @PostMapping("getgridlistbygridids")
+    public Result<List<AllGridsByUserIdResultDTO>> getGridListByGridIds(@RequestBody List<String> gridIdList) {
+        return customerGridService.getGridListByGridIds(gridIdList);
+    }
+
 }

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerGridDao.java

@@ -46,23 +46,20 @@ import java.util.Map;
 @Mapper
 public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
-
-
     /**
+     * @return CustomerGridForStrangerResultDTO
      * @Description 查整个城市的网格
      * @Param areaCode
-     * @return CustomerGridForStrangerResultDTO
      * @Author wangc
      * @Date 2020.03.19 15:53
      **/
     List<CustomerGridForStrangerResultDTO> selectGridByCityLike(ListCustomerGridFormDTO listCustomerGridFormDTO);
 
-
     /**
+     * @return CustomerGridForStrangerResultDTO
      * @Description 指定区时查询当前城市下除该区之外其余的网格
      * @Param areaCode
      * @Param cityCode
-     * @return CustomerGridForStrangerResultDTO
      * @Author wangc
      * @Date 2020.03.19 15:53
      **/
@@ -71,7 +68,6 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
     CustomerGridDTO getCustomerGridByGridId(CustomerGridFormDTO customerGridFormDTO);
 
     /**
-     *
      * @Description 根据网格id查询网格名称
      * @Author zxc
      * @CreatedTime 2020/4/27 9:22
@@ -88,6 +84,7 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 根据gridId获取网格详情
+     *
      * @param customerGridFormDTO
      * @return
      */
@@ -95,6 +92,7 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 根据gridId查询uerId和pid
+     *
      * @param customerGridFormDTO
      * @return
      */
@@ -102,6 +100,7 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 根据userId查询customerId
+     *
      * @param userId
      * @return
      */
@@ -109,6 +108,7 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 根据pid查询pids
+     *
      * @param pid
      * @return
      */
@@ -116,6 +116,7 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 根据gridName查询gridId
+     *
      * @param gridName
      * @return
      */
@@ -123,43 +124,50 @@ public interface CustomerGridDao extends BaseDao<CustomerGridEntity> {
 
     /**
      * 编辑网格信息
+     *
      * @param customerGridDTO
      */
     void editGrid(CustomerGridDTO customerGridDTO);
 
     /**
      * 删除网格
+     *
      * @param deleteGridFormDTO
      */
     void deleteGrid(DeleteGridFormDTO deleteGridFormDTO);
 
     /**
-     *
      * @Description 根据gridId查询userId
      * @Author zxc
      * @CreatedTime 2020/4/26 10:08
      */
     List<UserIdDTO> selectUserIdByGrid(@Param("gridId") String gridId);
 
-
-
     /**
+     * @return int
      * @Description 得到当前机构的网格总数
      * @Param agencyId(String) 对应CUSTOMER_GRID中的PID字段
-     * @return int
      * @Author wangc
      * @Date 2020.04.23 15:05
      **/
     int selectGridCountByAgencyId(@Param("agencyId") String agencyId);
 
     /**
+     * @return List<GridBaseInfoResultDTO> -> GridBaseInfoResultDTO :: getGridId :: getGridName :: getTotalUser
      * @Description 得到当前机构的网格详情列表
      * @Param agencyId(String) 对应CUSTOMER_GRID中的PID字段
-     * @return List<GridBaseInfoResultDTO> -> GridBaseInfoResultDTO :: getGridId :: getGridName :: getTotalUser
      * @Author wangc
      * @Date 2020.04.23 15:30
      **/
     List<GridBaseInfoResultDTO> selectGridListByAgencyId(@Param("agencyId") String agencyId, @Param("pageSize") Integer pageSize);
 
     List<GridByStaffResultDTO> listGridsbystaffid(@Param("staffId") String staffId);
+
+    /**
+     * @param gridIdList
+     * @return
+     * @Description 根据网格Id集合获取网格列表信息
+     * @Author sun
+     */
+    List<AllGridsByUserIdResultDTO> selectGridByIds(@Param("gridIdList") List<String> gridIdList);
 }

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerGridService.java

@@ -219,4 +219,13 @@ public interface CustomerGridService extends BaseService<CustomerGridEntity> {
     Result<AgencyAndStaffsResultDTO> getAgencyAndStaffsBygridId(String gridId);
 
     List<GridByStaffResultDTO> listGridsbystaffid(String staffId);
+
+    /**
+     * @param gridIdList
+     * @return
+     * @Description 根据网格Id集合获取网格列表信息
+     * @Author sun
+     */
+    Result<List<AllGridsByUserIdResultDTO>> getGridListByGridIds(List<String> gridIdList);
+
 }

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerGridServiceImpl.java

@@ -522,4 +522,17 @@ public class CustomerGridServiceImpl extends BaseServiceImpl<CustomerGridDao, Cu
     public List<GridByStaffResultDTO> listGridsbystaffid(String staffId) {
         return baseDao.listGridsbystaffid(staffId);
     }
+
+    /**
+     * @param gridIdList
+     * @return
+     * @Description 根据网格Id集合获取网格列表信息
+     * @Author sun
+     */
+    @Override
+    public Result<List<AllGridsByUserIdResultDTO>> getGridListByGridIds(List<String> gridIdList) {
+        Result<List<AllGridsByUserIdResultDTO>> result = new Result<List<AllGridsByUserIdResultDTO>>();
+        List<AllGridsByUserIdResultDTO> list = baseDao.selectGridByIds(gridIdList);
+        return result.ok(list);
+    }
 }

epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerGridDao.xml

@@ -263,4 +263,18 @@
           AND sg.USER_ID = #{staffId}
     </select>
 
+    <select id="selectGridByIds" resultType="com.epmet.dto.result.AllGridsByUserIdResultDTO">
+        SELECT
+            id AS 'gridId',
+            grid_name AS 'gridName',
+            customer_id AS 'customerId'
+        FROM customer_grid
+        WHERE del_flag = '0'
+        AND id IN
+        <foreach item="id" collection="gridIdList" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+        ORDER BY CONVERT (grid_name USING gbk) ASC<!-- 网格名称对应拼音升序排序 -->
+    </select>
+
 </mapper>

epmet-module/resi-mine/resi-mine-server/pom.xml

@@ -77,6 +77,18 @@
             <version>2.0.0</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.epmet</groupId>
+            <artifactId>gov-org-client</artifactId>
+            <version>2.0.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.epmet</groupId>
+            <artifactId>gov-org-client</artifactId>
+            <version>2.0.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java

@@ -13,6 +13,8 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 
+import java.util.List;
+
 /**
  * @Description 居民端陌生人导览  调用epmet-user服务
  * @Author sun
@@ -51,4 +53,13 @@ public interface EpmetUserFeignClient {
      **/
     @PostMapping(value = "epmetuser/userresiinfo/getverificationcode")
     Result getVerificationCode(VerificationCodeFormDTO formDTO);
+
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    @PostMapping(value = "epmetuser/gridlatest/getgridsbyuserid/{userId}")
+    Result<List<String>> getGridsByUserId(@PathVariable("userId") String userId);
 }

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/GovOrgFeignClient.java

@@ -0,0 +1,28 @@
+package com.epmet.modules.feign;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.result.AllGridsByUserIdResultDTO;
+import com.epmet.modules.feign.fallback.GovOrgFeignClientFallBack;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+import java.util.List;
+
+/**
+ * @Description gov-org服务
+ * @Author sun
+ */
+@FeignClient(name = ServiceConstant.GOV_ORG_SERVER, fallback = GovOrgFeignClientFallBack.class)
+public interface GovOrgFeignClient {
+
+    /**
+     * @param gridIdList
+     * @return
+     * @Description 根据网格Id集合获取网格列表信息
+     * @Author sun
+     */
+    @PostMapping("/gov/org/customergrid/getgridlistbygridids")
+    Result<List<AllGridsByUserIdResultDTO>> getGridListByGridIds(List<String> gridIdList);
+
+}

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallBack.java

@@ -11,6 +11,8 @@ import com.epmet.dto.result.ResiRegisterResultDTO;
 import com.epmet.modules.feign.EpmetUserFeignClient;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 /**
  * @Description 居民端-陌生人导览 调用epmet-user服务
  * @Author sun
@@ -61,5 +63,14 @@ public class EpmetUserFeignClientFallBack implements EpmetUserFeignClient {
         return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getVerificationCode", formDTO);
     }
 
-
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    @Override
+    public Result<List<String>> getGridsByUserId(String userId) {
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getGridsByUserId", userId);
+    }
 }

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/GovOrgFeignClientFallBack.java

@@ -0,0 +1,23 @@
+package com.epmet.modules.feign.fallback;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.utils.ModuleUtils;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.result.AllGridsByUserIdResultDTO;
+import com.epmet.modules.feign.GovOrgFeignClient;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Description gov-org服务
+ * @Author sun
+ */
+@Component
+public class GovOrgFeignClientFallBack implements GovOrgFeignClient {
+
+    @Override
+    public Result<List<AllGridsByUserIdResultDTO>> getGridListByGridIds(List<String> gridIdList) {
+        return ModuleUtils.feignConError(ServiceConstant.GOV_ORG_SERVER, "getGridListByGridIds", gridIdList);
+    }
+}

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/controller/ResiMineGridController.java

@@ -3,13 +3,17 @@ package com.epmet.modules.grid.controller;
 import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.result.AllGridsByUserIdResultDTO;
 import com.epmet.dto.result.LatestGridInfoResultDTO;
 import com.epmet.modules.grid.service.ResiMineGridService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 /**
  * @Description 居民端用户网格信息相关接口入口
  * @Author yinzuomei
@@ -32,4 +36,15 @@ public class ResiMineGridController {
 	public Result<LatestGridInfoResultDTO> getLatestGridInfo(@LoginUser TokenDto tokenDto){
 		return resiMineGridService.getLatestGridInfo(tokenDto);
 	}
+
+	/**
+	 * @return
+	 * @param tokenDto
+	 * @Description 获取用户访问过的所有网格列表
+	 * @Author sun
+	 **/
+	@PostMapping("allgrids")
+	public Result<List<AllGridsByUserIdResultDTO>> allGrids(@LoginUser TokenDto tokenDto){
+		return resiMineGridService.allGrids(tokenDto.getUserId());
+	}
 }

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/ResiMineGridService.java

@@ -2,8 +2,11 @@ package com.epmet.modules.grid.service;
 
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.result.AllGridsByUserIdResultDTO;
 import com.epmet.dto.result.LatestGridInfoResultDTO;
 
+import java.util.List;
+
 /**
  * @Description 居民端用户网格信息service
  * @Author yinzuomei
@@ -18,4 +21,12 @@ public interface ResiMineGridService {
 	 * @return com.epmet.commons.tools.utils.Result<com.epmet.resi.mine.dto.result.LatestGridInfoResultDTO>
 	 */
 	Result<LatestGridInfoResultDTO> getLatestGridInfo(TokenDto tokenDto);
+
+	/**
+	 * @return
+	 * @param userId
+	 * @Description 获取用户访问过的所有网格列表
+	 * @Author sun
+	 **/
+	Result<List<AllGridsByUserIdResultDTO>> allGrids(String userId);
 }

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/grid/service/impl/ResiMineGridServiceImpl.java

@@ -1,11 +1,14 @@
 package com.epmet.modules.grid.service.impl;
 
 import com.epmet.commons.tools.constant.AppClientConstant;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.result.AllGridsByUserIdResultDTO;
 import com.epmet.dto.result.LatestGridInfoResultDTO;
 import com.epmet.modules.feign.EpmetUserFeignClient;
+import com.epmet.modules.feign.GovOrgFeignClient;
 import com.epmet.modules.grid.service.ResiMineGridService;
 import com.epmet.modules.utils.ModuleConstant;
 import org.apache.commons.lang3.StringUtils;
@@ -14,6 +17,9 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
+import java.util.List;
+
 /**
  * @Description  居民端用户网格信息service
  * @Author yinzuomei
@@ -24,6 +30,8 @@ public class ResiMineGridServiceImpl implements ResiMineGridService {
 	private Logger logger = LoggerFactory.getLogger(getClass());
 	@Autowired
 	private EpmetUserFeignClient epmetUserFeignClient;
+	@Autowired
+	private GovOrgFeignClient govOrgFeignClient;
 
 	/**
 	 * @param tokenDto
@@ -44,4 +52,33 @@ public class ResiMineGridServiceImpl implements ResiMineGridService {
 		}
 		return epmetUserFeignClient.getLatestGridInfoByUserId(tokenDto.getUserId());
 	}
+
+	/**
+	 * @return
+	 * @param userId
+	 * @Description 获取用户访问过的所有网格列表
+	 * @Author sun
+	 **/
+	@Override
+	public Result<List<AllGridsByUserIdResultDTO>> allGrids(String userId) {
+		Result<List<AllGridsByUserIdResultDTO>> result = new Result<List<AllGridsByUserIdResultDTO>>();
+		//1:调用epmet-user服务，根据用户Id查询用户访问过的网格列表Id集合
+		Result<List<String>> resultGridIds = epmetUserFeignClient.getGridsByUserId(userId);
+		if (!resultGridIds.success()) {
+			throw new RenException(ModuleConstant.SELECT_EXCEPTION);
+		}
+		if (null == resultGridIds.getData() || resultGridIds.getData().size() < NumConstant.ONE) {
+			return result.ok(new ArrayList<AllGridsByUserIdResultDTO>());
+		}
+		List<String> gridIdList = resultGridIds.getData();
+		//2:调用gov-org服务，根据网格Id集合获取网格列表信息
+		Result<List<AllGridsByUserIdResultDTO>> resultGrids = govOrgFeignClient.getGridListByGridIds(gridIdList);
+		if (!resultGrids.success()) {
+			throw new RenException(ModuleConstant.SELECT_EXCEPTION);
+		}
+		if (null == resultGrids.getData() || resultGrids.getData().size() < NumConstant.ONE) {
+			return result.ok(new ArrayList<AllGridsByUserIdResultDTO>());
+		}
+		return result.ok(resultGrids.getData());
+	}
 }

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/utils/ModuleConstant.java

@@ -28,4 +28,9 @@ public interface ModuleConstant extends Constant {
 	 */
 	String FOR_RESI_CALL="当前接口只限居民端调用";
 
+	/**
+	 * 调用epmet-user服务，查询用户访问过的网格列表失败
+	 */
+	String SELECT_EXCEPTION = "获取用户访问过的网格列表失败";
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/controller/GridLatestController.java

@@ -103,4 +103,16 @@ public class GridLatestController {
     public Result<LatestGridInfoResultDTO> getLatestGridInfoByUserId(@PathVariable("userId") String userId){
         return gridLatestService.getLatestGridInfoByUserId(userId);
     }
+
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    @PostMapping("getgridsbyuserid/{userId}")
+    public Result<List<String>> getGridsByUserId(@PathVariable("userId") String userId){
+        return gridLatestService.getGridsByUserId(userId);
+    }
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/GridLatestDao.java

@@ -22,6 +22,9 @@ import com.epmet.dto.GridLatestDTO;
 import com.epmet.dto.result.LatestGridInfoResultDTO;
 import com.epmet.entity.GridLatestEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 最近访问网格表 记录用户访问网格的最近一次记录，对同一网格只记录一条记录，同一网格每次只更新最近一次访问的时间
@@ -36,8 +39,6 @@ public interface GridLatestDao extends BaseDao<GridLatestEntity> {
 
     int updateByLatestId(GridLatestDTO dto);
 
-    GridLatestEntity getGridLatestByIds(GridLatestDTO formDTO);
-
     /**
      * @return com.epmet.dto.result.LatestGridInfoResultDTO
      * @param userId
@@ -46,4 +47,12 @@ public interface GridLatestDao extends BaseDao<GridLatestEntity> {
      * @Date 2020/3/24 13:17
      **/
 	LatestGridInfoResultDTO selectLatestGridInfoByUserId(String userId);
+
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    List<String> selectAllGridsByUserId(@Param("userId") String userId);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/GridLatestService.java

@@ -112,4 +112,12 @@ public interface GridLatestService extends BaseService<GridLatestEntity> {
      **/
     Result<LatestGridInfoResultDTO> getLatestGridInfoByUserId(String userId);
 
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    Result<List<String>> getGridsByUserId(String userId);
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/GridLatestServiceImpl.java

@@ -21,10 +21,10 @@ package com.epmet.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
-import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constant.GridVisitedConstant;
 import com.epmet.dao.GridLatestDao;
@@ -160,4 +160,16 @@ public class GridLatestServiceImpl extends BaseServiceImpl<GridLatestDao, GridLa
         return new Result<LatestGridInfoResultDTO>().ok(latestGridInfoResultDTO);
     }
 
+    /**
+     * @return
+     * @param userId
+     * @Description 根据用户Id查询用户访问过的网格列表Id集合
+     * @Author sun
+     **/
+    @Override
+    public Result<List<String>> getGridsByUserId(String userId) {
+        List<String> gridList = baseDao.selectAllGridsByUserId(userId);
+        return new Result<List<String>>().ok(gridList);
+    }
+
 }

epmet-user/epmet-user-server/src/main/resources/mapper/GridLatestDao.xml

@@ -71,4 +71,14 @@
             gl.LATEST_TIME DESC
             LIMIT 1
     </select>
+
+    <select id="selectAllGridsByUserId" resultType="string">
+        SELECT DISTINCT
+            grid_id
+        FROM
+            grid_latest
+        WHERE
+            del_flag = '0'
+        AND customer_user_id = #{userId}
+    </select>
 </mapper>