统计部门入驻事项

base-manager/src/main/java/com/mortals/xhx/module/site/web/SiteMatterController.java

@@ -5,6 +5,7 @@ import com.mortals.framework.common.Rest;
 import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
 import com.mortals.framework.model.OrderCol;
+import com.mortals.framework.util.ThreadPool;
 import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
 import com.mortals.framework.web.BasePhpCRUDJsonMappingController;
 import com.mortals.xhx.base.system.param.service.ParamService;
@@ -76,27 +77,39 @@ public class SiteMatterController extends BaseCRUDJsonBodyMappingController<Site
     @Override
     protected int batchSaveAfter(List<SiteMatterEntity> list, Map<String, Object> model, Context context) throws AppException {
         //统计部门入驻数量
-        List<SiteEntity> siteEntities = siteService.find(new SiteQuery());
-        for (SiteEntity siteEntity : siteEntities) {
-            DeptQuery query = new DeptQuery();
-            query.setSiteId(siteEntity.getId());
-            List<DeptEntity> deptEntities = deptService.find(query);
-            for (DeptEntity deptEntity : deptEntities) {
-                DeptEntity deptQuery = new DeptEntity();
-                deptQuery.setUpdateTime(new Date());
+        Runnable runnable = new Runnable() {
+            /**
+             *
+             */
+            @Override
+            public void run() {
 
-                //统计入驻事项
-                SiteMatterQuery siteMatterQuery = new SiteMatterQuery();
-                siteMatterQuery.setDeptCode(deptEntity.getDeptNumber());
-                siteMatterQuery.setSource(SourceEnum.政务网.getValue());
-                siteMatterQuery.setHallCheckIn(YesNoEnum.YES.getValue());
-                int incount = siteMatterService.count(siteMatterQuery, null);
-                deptQuery.setInNum(incount);
-                DeptEntity condition = new DeptEntity();
-                condition.setId(deptEntity.getId());
-                deptService.getDao().update(deptQuery, condition);
+                List<SiteEntity> siteEntities = siteService.find(new SiteQuery());
+                for (SiteEntity siteEntity : siteEntities) {
+                    DeptQuery query = new DeptQuery();
+                    query.setSiteId(siteEntity.getId());
+                    List<DeptEntity> deptEntities = deptService.find(query);
+                    for (DeptEntity deptEntity : deptEntities) {
+                        DeptEntity deptQuery = new DeptEntity();
+                        deptQuery.setUpdateTime(new Date());
+
+                        //统计入驻事项
+                        SiteMatterQuery siteMatterQuery = new SiteMatterQuery();
+                        siteMatterQuery.setDeptCode(deptEntity.getDeptNumber());
+                        siteMatterQuery.setSource(SourceEnum.政务网.getValue());
+                        siteMatterQuery.setHallCheckIn(YesNoEnum.YES.getValue());
+                        int incount = siteMatterService.count(siteMatterQuery, null);
+                        deptQuery.setInNum(incount);
+                        DeptEntity condition = new DeptEntity();
+                        condition.setId(deptEntity.getId());
+                        deptService.getDao().update(deptQuery, condition);
+                    }
+                }
             }
-        }
+        };
+        ThreadPool.getInstance().execute(runnable);
+
+
         return super.batchSaveAfter(list, model, context);
     }
 }
\ No newline at end of file