From 1f1c6ad6ca048c9270000f4af80a88a30f9244ed Mon Sep 17 00:00:00 2001
From: Jackwang <wt373747285@163.com>
Date: Mon, 13 Jul 2020 09:54:51 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E5=86=85=E5=AE=B9=E5=AE=A1=E6=A0=B8?=
 =?UTF-8?q?=E3=80=91-=E3=80=90=E8=AE=AE=E9=A2=98=E9=A1=B9=E7=9B=AE-?=
 =?UTF-8?q?=E6=88=91=E8=A6=81=E6=8A=A5=E4=BA=8B=E3=80=91-=EF=BC=88?=
 =?UTF-8?q?=E7=8E=8B=E7=AB=A5=EF=BC=89-2020/07/13?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/EpdcEventsServiceImpl.java   | 49 +++++++++++++++++++
 1 file changed, 49 insertions(+)

diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java
index e79fda084..7ecfb104c 100644
--- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/events/service/impl/EpdcEventsServiceImpl.java
@@ -23,9 +23,15 @@ import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
 import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
 import com.elink.esua.epdc.commons.tools.constant.NumConstant;
 import com.elink.esua.epdc.commons.tools.constant.OrganizationTypeConstant;
+import com.elink.esua.epdc.commons.tools.exception.RenException;
 import com.elink.esua.epdc.commons.tools.page.PageData;
 import com.elink.esua.epdc.commons.tools.redis.RedisKeys;
 import com.elink.esua.epdc.commons.tools.redis.RedisUtils;
+import com.elink.esua.epdc.commons.tools.security.content.CheckDataUtils;
+import com.elink.esua.epdc.commons.tools.security.content.ModuleName;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsDTO;
+import com.elink.esua.epdc.commons.tools.security.content.dto.result.CheckResultDTO;
+import com.elink.esua.epdc.commons.tools.security.content.dto.result.CheckResultMessageDTO;
 import com.elink.esua.epdc.commons.tools.security.user.SecurityUser;
 import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
 import com.elink.esua.epdc.commons.tools.utils.Result;
@@ -59,6 +65,7 @@ import com.elink.esua.epdc.modules.events.entity.EpdcEventsEntity;
 import com.elink.esua.epdc.modules.events.service.EpdcEventsService;
 import com.elink.esua.epdc.modules.events.service.ImgService;
 import com.elink.esua.epdc.modules.feign.AdminFeignClient;
+import com.elink.esua.epdc.modules.feign.ContentSecurityFeignClient;
 import com.elink.esua.epdc.modules.feign.GroupFeignClient;
 import com.elink.esua.epdc.modules.issue.dao.IssueDao;
 import com.elink.esua.epdc.modules.issue.entity.IssueEntity;
@@ -69,6 +76,8 @@ import com.elink.esua.epdc.modules.item.service.ItemService;
 import com.elink.esua.epdc.modules.rocketmq.dto.CategoryModifyDTO;
 import com.elink.esua.epdc.modules.rocketmq.dto.OrganizationModifyDTO;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -117,6 +126,11 @@ public class EpdcEventsServiceImpl extends BaseServiceImpl<EpdcEventsDao, EpdcEv
     @Autowired
     private RedisUtils redisUtils;
 
+    @Autowired
+    private ContentSecurityFeignClient contentSecurityFeign;
+
+    private static final Logger logger = LoggerFactory.getLogger(EpdcEventsServiceImpl.class);
+
     @Override
     public PageData<EpdcEventsDTO> listOfPendingReviewEvents(Map<String, Object> params) {
         IPage<EpdcEventsDTO> page = getPage(params);
@@ -157,6 +171,27 @@ public class EpdcEventsServiceImpl extends BaseServiceImpl<EpdcEventsDao, EpdcEv
     @Override
     @Transactional(rollbackFor = Exception.class)
     public EpdcEventsEntity saveEvent(EpdcEventSubmitFormDTO dto) {
+        //内容审核
+        List<String> textList = new ArrayList<>();
+        textList.add(dto.getEventContent());
+        CheckResultDTO contentResult = CheckDataUtils.checkContent(textList);
+        CheckResultDTO imgResult = CheckDataUtils.checkImgs(dto.getImages());
+        if (contentResult != null && imgResult != null
+                && 200 == contentResult.getDetails().get(0).getCode()
+                && 200 == imgResult.getDetails().get(0).getCode()) {
+            if (!contentResult.getAllPass() || !imgResult.getAllPass()) {
+                //组装要保存的信息
+                SaveCheckRecordsDTO record = CheckDataUtils.getPackageRecords(dto.getUserId(),
+                        dto.getNickName(), CheckDataUtils.cate_two, CheckDataUtils.decision_one, ModuleName.ISSUE_SUBMIT.getCode(), textList,
+                        dto.getImages(), null,contentResult, imgResult,null);
+                contentSecurityFeign.insertViolationsRecord(record);
+                throw new RenException(CheckDataUtils.violations_message);
+//                return new Result().error(CheckDataUtils.violations_message);
+            }
+        } else {
+            logger.error("解析审核结果异常contentResult：" + contentResult + "---imgResult:" + imgResult);
+        }
+
         EpdcEventsEntity entity = ConvertUtils.sourceToTarget(dto, EpdcEventsEntity.class);
         insert(entity);
 
@@ -168,6 +203,20 @@ public class EpdcEventsServiceImpl extends BaseServiceImpl<EpdcEventsDao, EpdcEv
 
         //短信通知 所有有菜单权限的议题审核员
         issueOverseeResultsTask.getSysGridLeaderPhone(dto.getGridId());
+
+        //保存待审核记录
+        if (contentResult != null && imgResult != null
+                && 200 == contentResult.getDetails().get(0).getCode()
+                && 200 == imgResult.getDetails().get(0).getCode()) {
+            CheckResultMessageDTO twoTypes = CheckDataUtils.checkTwoTypes(contentResult, imgResult);
+            if (CheckDataUtils.review.equals(twoTypes.getSuggestion())) {
+                //组装要保存的信息
+                SaveCheckRecordsDTO record = CheckDataUtils.getPackageRecords(dto.getUserId(),
+                        dto.getNickName(), CheckDataUtils.cate_two, null,ModuleName.ISSUE_SUBMIT.getCode(), textList,
+                        dto.getImages(), entity.getId(),null,null, twoTypes);
+                contentSecurityFeign.insertRecords(record);
+            }
+        }
         return entity;
     }