修改大厅查询

base-manager/src/main/java/com/mortals/xhx/daemon/task/StatSiteDeptMatterTaskImpl.java

 package com.mortals.xhx.daemon.task;
 
+import com.alibaba.fastjson.JSONObject;
 import com.mortals.framework.exception.AppException;
+import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.service.ITask;
 import com.mortals.framework.service.ITaskExcuteService;
 import com.mortals.xhx.common.code.SourceEnum;
+import com.mortals.xhx.common.keys.RedisCacheKeys;
 import com.mortals.xhx.module.dept.model.DeptEntity;
 import com.mortals.xhx.module.dept.model.DeptQuery;
 import com.mortals.xhx.module.dept.service.DeptService;
@@ -11,18 +14,16 @@ import com.mortals.xhx.module.matter.model.MatterEntity;
 import com.mortals.xhx.module.matter.model.MatterQuery;
 import com.mortals.xhx.module.matter.service.MatterService;
 import com.mortals.xhx.module.matters.service.MattersService;
-import com.mortals.xhx.module.site.model.SiteEntity;
-import com.mortals.xhx.module.site.model.SiteMatterQuery;
-import com.mortals.xhx.module.site.model.SiteQuery;
+import com.mortals.xhx.module.site.model.*;
 import com.mortals.xhx.module.site.service.SiteMatterService;
 import com.mortals.xhx.module.site.service.SiteService;
+import com.mortals.xhx.module.site.service.SiteThemeService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 统计站点部门事项
@@ -35,7 +36,13 @@ public class StatSiteDeptMatterTaskImpl implements ITaskExcuteService {
     @Autowired
     private MatterService matterService;
     @Autowired
-    private  SiteService siteService;
+    private SiteService siteService;
+
+    @Autowired
+    private ICacheService cacheService;
+
+    @Autowired
+    private SiteThemeService siteThemeService;
 
 
     @Override
@@ -47,21 +54,47 @@ public class StatSiteDeptMatterTaskImpl implements ITaskExcuteService {
             DeptQuery query = new DeptQuery();
             query.setSiteId(siteEntity.getId());
             List<DeptEntity> deptEntities = deptService.find(query);
-        for (DeptEntity deptEntity : deptEntities) {
+            for (DeptEntity deptEntity : deptEntities) {
 
-            MatterQuery matterQuery = new MatterQuery();
-            matterQuery.setEventTypeShowNotList(Arrays.asList("行政处罚"));
-            int total = matterService.count(matterQuery.source(SourceEnum.政务网.getValue()).deptCode(deptEntity.getDeptNumber()), null);
-            DeptEntity deptQuery = new DeptEntity();
-            deptQuery.setTotal(total);
-            deptQuery.setUpdateTime(new Date());
-            DeptEntity condition = new DeptEntity();
-            condition.setId(deptEntity.getId());
-            deptService.getDao().update(deptQuery, condition);
-        }
+                MatterQuery matterQuery = new MatterQuery();
+                matterQuery.setEventTypeShowNotList(Arrays.asList("行政处罚"));
+                int total = matterService.count(matterQuery.source(SourceEnum.政务网.getValue()).deptCode(deptEntity.getDeptNumber()), null);
+                DeptEntity deptQuery = new DeptEntity();
+                deptQuery.setTotal(total);
+                deptQuery.setUpdateTime(new Date());
+                DeptEntity condition = new DeptEntity();
+                condition.setId(deptEntity.getId());
+                deptService.getDao().update(deptQuery, condition);
+            }
 
         }
+        //分组暂存 站点 个人企业  主题
+        Map<String, List<SiteThemeEntity>> collect = siteThemeService.find(new SiteThemeQuery())
+                .parallelStream()
+                .collect(Collectors.groupingBy(x -> x.getSiteId() + "_" + x.getUserType() + "_" + x.getThemeCode()
+        ));
+        Iterator<Map.Entry<String, List<SiteThemeEntity>>> iterator = collect.entrySet().iterator();
+        while (iterator.hasNext()) {
+            Map.Entry<String, List<SiteThemeEntity>> next = iterator.next();
+            if (next.getValue().size() == 0) {
+                iterator.remove();
+            }
+        }
+        //重新  构建redis siteId+userType= >themeCodelist
+        List<SiteThemeEntity> themeEntities = collect.values().stream().flatMap(i -> i.stream()).collect(Collectors.toList());
 
+        themeEntities.stream()
+                .collect(Collectors.groupingBy(x -> x.getSiteId() + "_" + x.getUserType()))
+                .entrySet()
+                .stream()
+                .forEach(item -> {
+                    String key = item.getKey();
+                    List<SiteThemeEntity> values = item.getValue();
+                    String[] split = key.split("_");
+                    String siteId = split[0];
+                    String userType = split[1];
+                    cacheService.hset(RedisCacheKeys.getSiteUserTypeThemeCodeKey() + siteId, userType, JSONObject.toJSONString(values));
+                });
     }
 
     @Override

base-manager/src/main/java/com/mortals/xhx/module/matter/service/MatterService.java

@@ -5,6 +5,7 @@ import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
 import com.mortals.framework.model.PageInfo;
 import com.mortals.framework.model.Result;
+import com.mortals.framework.service.ICRUDCacheService;
 import com.mortals.framework.service.ICRUDService;
 import com.mortals.xhx.module.matter.dao.MatterDao;
 import com.mortals.xhx.module.matter.model.MatterEntity;
@@ -23,7 +24,7 @@ import java.util.Map;
  * @author zxfei
  * @date 2022-01-12
  */
-public interface MatterService extends ICRUDService<MatterEntity, Long> {
+public interface MatterService extends ICRUDCacheService<MatterEntity, Long> {
 
 
     MatterDao getDao();

base-manager/src/main/java/com/mortals/xhx/module/matter/service/impl/MatterServiceImpl.java

@@ -61,7 +61,7 @@ import java.util.stream.Collectors;
  */
 @Service("matterService")
 @Slf4j
-public class MatterServiceImpl extends AbstractCRUDServiceImpl<MatterDao, MatterEntity, Long> implements MatterService {
+public class MatterServiceImpl extends AbstractCRUDCacheServiceImpl<MatterDao, MatterEntity, Long> implements MatterService {
     @Autowired
     private SiteMatterService siteMatterService;
     @Autowired

base-manager/src/main/resources/sqlmap/module/window/WindowMapperExt.xml

@@ -14,6 +14,7 @@
                 and a.siteId = #{condition.siteId}
             </if>
         </trim>
+
     </select>
 
     <!-- 获取事项差集列表列表 -->

common-lib/src/main/java/com/mortals/xhx/common/keys/RedisCacheKeys.java

@@ -49,5 +49,10 @@ public final class RedisCacheKeys {
     public static String getFlowSubKey() {
         return "workflow:sub:key:";
     }
-    
+
+
+    public static String getSiteUserTypeThemeCodeKey() {
+        return "site:usertype:themecode:";
+    }
+
 }