From c3811d01d1929a98a0f34f70ca187d82ee312dbb Mon Sep 17 00:00:00 2001
From: manailin <261030956@qq.com>
Date: 星期三, 03 十一月 2021 17:26:50 +0800
Subject: [PATCH] Merge branch 'test' of http://gitlab.nhys.cdnhxx.com/root/zhihuishequ into test

---
 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java |   36 +++++++++++++++++++-----------------
 1 files changed, 19 insertions(+), 17 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java
index c3920a7..a1038a9 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java
@@ -317,7 +317,9 @@
 
         if (eventMapper.insert(eventDO) == 1) {
             // 如果是特殊人群,则新增特殊人群与事件关系
-            if (commonEventAddDTO.getEventType().equals(6)) {
+            if (commonEventAddDTO.getEventType().equals(6)
+                    && commonEventAddDTO.getPopulationIds() != null
+                    && commonEventAddDTO.getPopulationIds().size() > 0) {
                 if (commonEventAddDTO.getPopulationIds() != null && commonEventAddDTO.getPopulationIds().size() > 0) {
                     List<EventSpecialCrowdRecordDO> crowdRecordList = new ArrayList<>();
                     commonEventAddDTO.getPopulationIds().forEach(populationId -> {
@@ -397,11 +399,11 @@
 
         if (commonEventEditDTO.getId() == null) {
             // 检查特殊人群上报时参数
-            if (commonEventEditDTO.getEventType().equals(6)) {
-                if (commonEventEditDTO.getPopulationIds().isEmpty()) {
-                    return R.fail("上报人员为空");
-                }
-            }
+//            if (commonEventEditDTO.getEventType().equals(6)) {
+//                if (commonEventEditDTO.getPopulationIds().isEmpty()) {
+//                    return R.fail("上报人员为空");
+//                }
+//            }
 
             EventDO eventDO = new EventDO();
             BeanUtils.copyProperties(commonEventEditDTO, eventDO);
@@ -418,7 +420,8 @@
             if (eventMapper.insert(eventDO) > 0) {
 
                 // 如果是特殊人群,则新增特殊人群与事件关系
-                if (commonEventEditDTO.getEventType().equals(6)) {
+                if (commonEventEditDTO.getEventType().equals(6) && commonEventEditDTO.getPopulationIds() != null
+                        && commonEventEditDTO.getPopulationIds().size() > 0) {
                     List<EventSpecialCrowdRecordDO> crowdRecordList = new ArrayList<>();
                     commonEventEditDTO.getPopulationIds().forEach(populationId -> {
                         EventSpecialCrowdRecordDO specialCrowdRecordDO = new EventSpecialCrowdRecordDO();
@@ -1373,10 +1376,11 @@
         } else {
             return R.fail("事件所属错误");
         }
-        eventDO.setInvalid(false);
+//        eventDO.setInvalid(false);
         // 标为无效后, 交给网格员处理
         eventDO.setUpdateBy(eventRevokeDTO.getUserId());
         eventDO.setEventStatus(4);// 4、撤销
+        eventDO.setEventDealStatus(6);// 4、撤销
         eventDO.setProcessType(1);// 网格员处理
         eventDO.setCommunityProcess(0);// 非 社区处理
         eventDO.setRevokeId(eventRevokeDTO.getRevokeId());
@@ -1396,11 +1400,13 @@
         if (eventDO == null) {
             return R.fail("事件不存在");
         }
-        boolean canRepulish = eventDO.getEventDealStatus() == 7 | eventDO.getEventDealStatus() == 5; // 已失效状态
+        boolean canRepulish = eventDO.getEventDealStatus() == 7 || eventDO.getEventDealStatus() == 5 || eventDO.getEventDealStatus() == 6; // 已失效状态
         if (!canRepulish) {
-            return R.fail("当前事件不是已失效状态/草稿状态,不能重新发布");
+            return R.fail("当前事件不是已失效状态/草稿状态/撤销状态,不能重新发布");
         }
         eventDO.setInvalid(true);
+        eventDO.setEventStatus(2);
+        eventDO.setEventDealStatus(1);
         int updated = this.getBaseMapper().updateById(eventDO);
         if (updated == 1) {
             addTransferRecord(eventDO.getId(), commonEventRepublishDTO.getUserId(),
@@ -1816,11 +1822,7 @@
                     if (eventDO == null) {
                         throw new ServiceException("id为" + id + "的事件不存在");
                     }
-                    if (eventDO.getEventStatus() != null
-                        && (eventDO.getEventStatus().intValue() == 1 || eventDO.getEventStatus().intValue() == 4)) {// 草稿
-                                                                                                                    // 或者
-                                                                                                                    // 已撤销
-                                                                                                                    // 的事件可以删除
+                    if (eventDO.getEventStatus() != null) {
                         eventDO.setEventStatus(3);// 逻辑删除
                         eventDO.setUpdateBy(userId);
                         int updated = this.getBaseMapper().updateById(eventDO);
@@ -1945,8 +1947,8 @@
     public R getGridEventStatisticsByApp(Long gridId, Long userId) {
         GridEventStatisticsVO result = this.baseMapper.getGridEventStatisticsByApp(gridId);
         if (result != null) {
-            result.setTodayNum(result.getTodayNum() + result.getZfTodayNum());
-            result.setMonthNum(result.getMonthNum() + result.getZfMonthNum());
+            result.setTodayNum(result.getTodayNum() + result.getZfTodayNum() + result.getSspTodayNum());
+            result.setMonthNum(result.getMonthNum() + result.getZfMonthNum() + result.getSspMonthNum());
 
             // 查询当前网格员下管理的楼栋名称
             List<Map<String, Object>> buildNameList = this.baseMapper.getMemberBuildName(userId);

--
Gitblit v1.7.1