Merge remote-tracking branch 'origin/lingshan_master' into lingshan_master

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/common/CustomerOrgRedis.java

@@ -95,10 +95,10 @@ public class CustomerOrgRedis {
         }
         Result<AgencyInfoCache> agencyInfoResult = customerOrgRedis.commonAggFeignClient.getAgencyInfo(agencyId);
         if (!agencyInfoResult.success()){
-            throw new RenException("查询组织信息失败...");
+            throw new RenException("查询行政组织信息失败，组织ID：" + agencyInfoResult);
         }
         if (null == agencyInfoResult.getData()){
-            throw new RenException("没有此组织信息...");
+            throw new RenException("没有此行政组织信息, 组织ID：" + agencyInfoResult);
         }
         Map<String, Object> map = BeanUtil.beanToMap(agencyInfoResult.getData(), false, true);
         customerOrgRedis.redisUtils.hMSet(key, map);

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/lingshan/LingShanSpecialCrowdStatsByOrgResultDTO.java

@@ -21,5 +21,7 @@ public class LingShanSpecialCrowdStatsByOrgResultDTO {
      */
     private Integer quantity = 0;
 
+    private String longitude;
+    private String latitude;
 
 }

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

@@ -5,8 +5,11 @@ import com.epmet.commons.tools.constant.ServiceConstant;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.feign.ResultDataResolver;
 import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
+import com.epmet.commons.tools.redis.common.bean.AgencyInfoCache;
+import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
 import com.epmet.commons.tools.utils.PidUtils;
 import com.epmet.constant.LevelConstant;
+import com.epmet.constant.OrgInfoConstant;
 import com.epmet.dao.*;
 import com.epmet.dto.result.SubOrgResDTO;
 import com.epmet.dto.result.lingshan.LingShanSpecialCrowdStatsByOrgResultDTO;
@@ -51,9 +54,25 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD
 
         List<LingShanSpecialCrowdStatsByOrgResultDTO> rl = subOrgs.stream().map(sub -> {
             LingShanSpecialCrowdStatsByOrgResultDTO t = new LingShanSpecialCrowdStatsByOrgResultDTO();
+
+            String longitude = null;
+            String latitude = null;
+
+            if (OrgInfoConstant.AGENCY.equals(sub.getOrgType())) {
+                AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(sub.getOrgId());
+                longitude = agencyInfo.getLongitude();
+                latitude = agencyInfo.getLatitude();
+            } else if (OrgInfoConstant.GRID.equals(sub.getOrgType())) {
+                GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(sub.getOrgId());
+                longitude = gridInfo.getLongitude();
+                latitude = gridInfo.getLatitude();
+            }
+
             t.setOrgId(sub.getOrgId());
             t.setOrgName(sub.getOrgName());
             t.setOrgType(sub.getOrgType());
+            t.setLongitude(longitude);
+            t.setLatitude(latitude);
             t.setOrgIdPath(PidUtils.convertPid2OrgIdPath(sub.getOrgId(), sub.getPids()));
             return t;
         }).collect(Collectors.toList());