From df9a5913fb1be237a3ad190a3bd3a1b69d34099e Mon Sep 17 00:00:00 2001
From: huanghongfa <huanghongfa123456>
Date: 星期四, 17 六月 2021 17:20:57 +0800
Subject: [PATCH] 添加资源文件数据时新增资源文件名字段

---
 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java |   32 ++++++++++++++++++++------------
 1 files changed, 20 insertions(+), 12 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 c1abaf9..d7fff02 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
@@ -280,6 +280,7 @@
                 eventResourceDO.setRefId(eventDO.getId());
                 eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
                 eventResourceDO.setResourceTime(commonEventAddDTO.getAudioTime());
+                eventResourceDO.setResourceName(commonEventAddDTO.getAudio().substring(commonEventAddDTO.getAudio().lastIndexOf("/")+1));
                 int audioAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                 if (audioAdd != 1) {
                     throw new ServiceException("添加音频失败");
@@ -294,6 +295,7 @@
                 eventResourceDO.setRefId(eventDO.getId());
                 eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
                 eventResourceDO.setResourceTime(commonEventAddDTO.getVideoTime());
+                eventResourceDO.setResourceName(commonEventAddDTO.getVideo().substring(commonEventAddDTO.getVideo().lastIndexOf("/")+1));
                 int videoAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                 if (videoAdd != 1) {
                     throw new ServiceException("添加视频失败");
@@ -309,6 +311,7 @@
                     eventResourceDO.setUrl(pica[i]);
                     eventResourceDO.setRefId(eventDO.getId());
                     eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
+                    eventResourceDO.setResourceName(pica[i].substring(pica[i].lastIndexOf("/")+1));
                     int picAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                     if (picAdd != 1) {
                         throw new ServiceException("添加图片失败");
@@ -515,6 +518,8 @@
         eventDO.setUpdateBy(eventRevokeDTO.getUserId());
         eventDO.setProcessType(1);//网格员处理
         eventDO.setCommunityProcess(0);//非 社区处理
+        eventDO.setRevokeType(eventRevokeDTO.getRevokeType());
+        eventDO.setRevokeId(eventRevokeDTO.getRevokeId());
         int updated = this.getBaseMapper().updateById(eventDO);
         if (updated == 1) {
             addTransferRecord(eventDO.getId(), eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(),
@@ -531,10 +536,10 @@
         if (eventDO == null) {
             return R.fail("事件不存在");
         }
-        boolean canDealByUser = eventDO.getEventStatus() == 2 && eventDO.getEventProcessStatus() == 1;
+        boolean canDealByUser = (eventDO.getEventStatus() == 2||eventDO.getEventStatus()==4) && eventDO.getEventProcessStatus() == 1;
         if (!canDealByUser) {
-            if (eventDO.getEventStatus() != 2) {
-                return R.fail("事件不是发布状态");
+            if (eventDO.getEventStatus() != 2 ) {
+                return R.fail("事件不是发布/待处理状态");
             }
             if (eventDO.getEventProcessStatus() != 1) {
                 return R.fail("事件不是待处理状态");
@@ -1262,12 +1267,12 @@
             if (eventDO.getEventCategory() == 1) {
                 boolean canRevoke = eventDO.getEventDealStatus() == 3; //上报状态
                 if (!canRevoke) {
-                    return R.fail("当前事件不是上报状态,不允许标为无效");
+                    return R.fail("当前事件不是上报状态,不允许撤销");
                 }
             } else if (eventDO.getEventCategory() == 2) {
                 boolean canRevoke = eventDO.getEventDealStatus() == 8; //发布状态
                 if (!canRevoke) {
-                    return R.fail("当前事件不是发布状态,不允许标为无效");
+                    return R.fail("当前事件不是发布状态,不允许撤销");
                 }
             } else {
                 return R.fail("");
@@ -1281,6 +1286,8 @@
         eventDO.setEventStatus(4);//4、撤销
         eventDO.setProcessType(1);//网格员处理
         eventDO.setCommunityProcess(0);//非 社区处理
+        eventDO.setRevokeId(eventRevokeDTO.getRevokeId());
+        eventDO.setRevokeType(eventRevokeDTO.getRevokeType());
         int updated = this.getBaseMapper().updateById(eventDO);
         if (updated == 1) {
             addTransferRecord(eventDO.getId(), eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(), 1, "标为无效", eventRevokeDTO.getCommunityId(), eventRevokeDTO.getCommunityName(), 4);
@@ -1511,7 +1518,7 @@
                 .orderByDesc(EventTransferRecordDO::getCreateAt)
         );
         EventTransferRecordDO eventTransferRecordDO = new EventTransferRecordDO();
-        if (list != null || list.size() > 0) {
+        if (list != null && list.size() > 0) {
             EventTransferRecordDO lastRecord = list.get(0);
             eventTransferRecordDO.setFromType(lastRecord.getToType());
             eventTransferRecordDO.setFromId(lastRecord.getToId());
@@ -1581,10 +1588,11 @@
                 Integer community_process = eventDO.getCommunityProcess() != null ? eventDO.getCommunityProcess() : -1;
 
                 Integer eventDealStatus = -1;
-                if (eventDO.getInvalid() != null && eventDO.getInvalid() == false) {
+                /*if (eventDO.getInvalid() != null && eventDO.getInvalid() == false) {
                     eventDealStatus = 7;
                     //7已失效
-                } else if (event_status == 1) {
+                }*/
+                if (event_status == 1) {
                     eventDealStatus = 5;
                     //"草稿箱"
                 } else if (event_status == 4) {
@@ -1776,15 +1784,15 @@
                     throw new ServiceException("id为" + id + "的事件不存在");
                 }
                 if (eventDO.getEventCategory() != null) {
-                    if (eventDO.getEventCategory() == 1) {
+                    if (eventDO.getEventCategory() == 1) {//
                         boolean canRevoke = eventDO.getEventDealStatus() == 3; //上报状态
                         if (!canRevoke) {
-                            throw new ServiceException("当前事件不是上报状态,不允许标为无效");
+                            throw new ServiceException("当前事件不是上报状态,不允许撤销");
                         }
-                    } else if (eventDO.getEventCategory() == 2) {
+                    } else if (eventDO.getEventCategory() == 2) {//宣传教育
                         boolean canRevoke = eventDO.getEventDealStatus() == 8; //发布状态
                         if (!canRevoke) {
-                            throw new ServiceException("当前事件不是发布状态,不允许标为无效");
+                            throw new ServiceException("当前事件不是发布状态,不允许撤销");
                         }
                     } else {
                         throw new ServiceException("事件分类错误");

--
Gitblit v1.7.1