解决城市数据问题

crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemCityAsyncServiceImpl.java

@@ -91,7 +91,7 @@ public class SystemCityAsyncServiceImpl extends ServiceImpl<SystemCityDao, Syste
         lambdaQueryWrapper.in(SystemCity::getIsShow, true);
         List<SystemCity> systemCityList = dao.selectList(lambdaQueryWrapper);
         if(systemCityList != null && systemCityList.size() > 0){
-            redisUtil.hmSet(Constants.CITY_LIST, pid, systemCityList);
+            redisUtil.hmSet(Constants.CITY_LIST, pid.toString(), systemCityList);
         }
     }
 

crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemCityServiceImpl.java

@@ -48,12 +48,31 @@ public class SystemCityServiceImpl extends ServiceImpl<SystemCityDao, SystemCity
      */
     @Override
     public Object getList(SystemCitySearchRequest request) {
-        if(redisUtil.hmGet(Constants.CITY_LIST, request.getParentId()) == null){
+        if(redisUtil.hmGet(Constants.CITY_LIST, request.getParentId().toString()) == null){
             asyncRedis(request.getParentId());
         }
-        return redisUtil.hmGet(Constants.CITY_LIST, request.getParentId());
+        Object list = redisUtil.hmGet(Constants.CITY_LIST, request.getParentId().toString());
+        if(null == list){
+            //城市数据，异步同步到redis，第一次拿不到数据，去数据库读取
+            list = getList(request.getParentId());
+        }
+
+        return list;
     }
 
+    /**
+     * 根据父级id获取数据
+     * @param parentId integer parentId
+     * @author Mr.Zhang
+     * @since 2020-04-17
+     * @return Object
+     */
+    private Object getList(Integer parentId) {
+        LambdaQueryWrapper<SystemCity> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(SystemCity::getParentId, parentId);
+        lambdaQueryWrapper.in(SystemCity::getIsShow, true);
+        return dao.selectList(lambdaQueryWrapper);
+    }
     /**
      * 修改状态
      * @param id integer id