【添加内容审核】-【党群议事-议题项目-评论】-（王童）-2020/07/07

5 years ago · d062818a7f
13 changed files with 579 additions and 0 deletions
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/CheckDataUtils.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/CheckDataUtils.java
@ -0,0 +1,114 @@
+package com.elink.esua.epdc.commons.tools.security.content;
+
+import cn.hutool.http.HttpRequest;
+import cn.hutool.http.HttpResponse;
+import com.alibaba.fastjson.JSONObject;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.CheckContentFormDTO;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.CheckDataFromDTO;
+import com.elink.esua.epdc.commons.tools.security.content.dto.result.CheckResultDTO;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.cloud.netflix.ribbon.apache.HttpClientUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @program: esua-epdc
+ * @description: 内容违规校验
+ * @author: wangtong
+ * @create: 2020-07-03 17:02
+ **/
+public class CheckDataUtils{
+
+    //内容审核地址
+    private static String contentUrl = "https://epmet-dev.elinkservice.cn/epmetscan/api/textSyncScan";
+
+    //图片审核地址
+    private static String imgUrl = "https://epmet-dev.elinkservice.cn/epmetscan/api/imgSyncScan";
+
+    private static Logger log = LogManager.getLogger(HttpClientUtils.class);
+
+    public static void main(String[] args) {
+        checkContent(null,"bbb");
+//        checkImgs("https://epdc-shibei.elinkservice.cn/epdcFile/M00/06/80/rBAAM17wjcKACqqXAAIyYyB0O-8107.png,,https://epdc-shibei.elinkservice.cn/epdcFile/M00/06/80/rBAAM17wjcKACqqXAAIyYyB0O-8107.png,");
+    }
+
+    /**
+    * @describe:内容审核
+    * @author wangtong
+    * @date 2020/7/6 10:13
+    * @param [title, content]
+    * @return java.lang.Object
+    */
+    public static CheckResultDTO checkContent(String title, String content) {
+        String text = "";
+        if (StringUtils.isBlank(content)) {
+            return null;
+        } else if(StringUtils.isNotBlank(title)){
+            text = title + ":" + content;
+        } else {
+            text = content;
+        }
+        CheckDataFromDTO tasks = new CheckDataFromDTO();
+        List<CheckContentFormDTO> contentList = new ArrayList<>();
+        CheckContentFormDTO contentDto = new CheckContentFormDTO();
+        contentDto.setDataId("1");
+        contentDto.setContent(text);
+        contentList.add(contentDto);
+        tasks.setTasks(contentList);
+        String json = JSONObject.toJSONString(tasks);
+        log.info("审核组装json:" + json);
+        HttpResponse response = HttpRequest.post(contentUrl).body(json)
+                .header("lan", "zh")
+                .header("Content-Type", "application/json").execute();
+        log.info("审核返回数据:" + response.body());
+        JSONObject res = JSONObject.parseObject(response.body());
+        //审核成功
+        if (0 == Integer.valueOf(res.get("code").toString())) {
+            CheckResultDTO result = (CheckResultDTO)JSONObject.toJavaObject((JSONObject)res.get("data"),CheckResultDTO.class);
+            return result;
+        }else{
+            log.error("内容审核返回信息错误："+res);
+            return null;
+        }
+    }
+
+    /**
+    * @describe: 图片审核:只要有一张图片被驳回，本次审核判定为不通过
+    * @author wangtong
+    * @date 2020/7/6 9:09
+    * @param [imgs]
+    * @return java.lang.Object
+    */
+    public static CheckResultDTO checkImgs(String imgs){
+        String[] imgList = imgs.split(",");
+        CheckDataFromDTO tasks = new CheckDataFromDTO();
+        List<CheckContentFormDTO> contentList = new ArrayList<>();
+        for(int i = 0;i<imgList.length;i++){
+            if(StringUtils.isNotBlank(imgList[i])){//图片地址为空会报错
+                CheckContentFormDTO imgDto = new CheckContentFormDTO();
+                imgDto.setDataId(i+"");
+                imgDto.setUrl(imgList[i]);
+                contentList.add(imgDto);
+            }
+        }
+        tasks.setTasks(contentList);
+        String json = JSONObject.toJSONString(tasks);
+        log.info("审核组装json:" + json);
+        HttpResponse response = HttpRequest.post(imgUrl).body(json)
+                .header("lan", "zh")
+                .header("Content-Type", "application/json").execute();
+        log.info("审核返回数据:" + response.body());
+        JSONObject res = JSONObject.parseObject(response.body());
+        //审核成功
+        if (0 == Integer.valueOf(res.get("code").toString())) {
+            CheckResultDTO result = (CheckResultDTO)JSONObject.toJavaObject((JSONObject)res.get("data"),CheckResultDTO.class);
+            return result;
+        }else{
+            log.error("内容审核返回信息错误："+res);
+            return null;
+        }
+    }
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/CheckContentFormDTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/CheckContentFormDTO.java
@ -0,0 +1,33 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @program: esua-epdc
+ * @description: 校验数据传输数据
+ * @author: wangtong
+ * @create: 2020-07-03 17:23
+ **/
+@Data
+public class CheckContentFormDTO implements Serializable {
+
+
+    private static final long serialVersionUID = -8348919053746539794L;
+
+    /**
+     * 要审核的内容Id
+     */
+    private String dataId;
+
+    /**
+     * 要审核的内容
+     */
+    private String content;
+
+    /**
+     * 要审核的图片地址
+     */
+    private String url;
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/CheckDataFromDTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/CheckDataFromDTO.java
@ -0,0 +1,21 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @program: esua-epdc
+ * @description: 内容审核传参
+ * @author: wangtong
+ * @create: 2020-07-06 09:14
+ **/
+@Data
+public class CheckDataFromDTO implements Serializable {
+
+
+    private static final long serialVersionUID = -4551870884807465268L;
+
+    private List<CheckContentFormDTO> tasks;
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/SaveCheckRecordsFTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/form/SaveCheckRecordsFTO.java
@ -0,0 +1,108 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @program: esua-epdc
+ * @description: 保存审核记录信息
+ * @author: wangtong
+ * @create: 2020-07-06 16:07
+ **/
+@Data
+public class SaveCheckRecordsFTO implements Serializable {
+
+    private static final long serialVersionUID = -9048821001719866937L;
+
+    /**
+     * 用户ID
+     */
+    private String userId;
+
+    /**
+     * 用户名称
+     */
+    private String name;
+
+    /**
+     * 工作类别:1工作2居民
+     */
+    private String category;
+
+    /**
+     * 关联信息表ID
+     */
+    private String relationId;
+
+    /**
+     * 类型：1文字2图片
+     */
+    private Integer type;
+
+    /**
+     * 判定方式:1系统2人工
+     */
+    private String decision;
+
+    /**
+     * 功能模块
+     */
+    private String module;
+
+    /**
+     * 内容
+     */
+    private String content;
+
+    /**
+     * 图片地址
+     */
+    private String url;
+
+    /**
+     * 系统返回编码
+     */
+    private String code;
+
+    /**
+     * 系统返回信息
+     */
+    private String msg;
+
+    /**
+     * 审核状态
+     */
+    private String suggestionText;
+
+    /**
+     * 图片鉴黄审核状态
+     */
+    private String suggestionImgPorn;
+
+    /**
+     * 图片暴恐涉政审核状态
+     */
+    private String suggestionImgTerrorism;
+
+    /**
+     * 检测结果分类
+     */
+    private String labelText;
+
+    /**
+     * 图片鉴黄
+     */
+    private String labelImgPorn;
+
+    /**
+     * 图片暴恐涉政识别
+     */
+    private String labelImgTerrorism;
+
+    /**
+     * 结果属于当前分类的概率，取值范围：0.00~100.00。值越高，表示越有可能属于当前分类。
+     */
+    private BigDecimal rate;
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckDetailResultsDTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckDetailResultsDTO.java
@ -0,0 +1,41 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @program: esua-epdc
+ * @description: 审核详情-详细结果
+ * @author: wangtong
+ * @create: 2020-07-06 13:55
+ **/
+@Data
+public class CheckDetailResultsDTO implements Serializable {
+
+    private static final long serialVersionUID = 8601710510211924859L;
+
+    /**
+     *结果属于当前分类的概率，取值范围：
+     * 0.00~100.00。值越高，表示越有可能属于当前分类。
+     */
+    private BigDecimal rate;
+
+    /**
+     * pass：文本正常
+     * review：文本需要进一步人工审核
+     * block：文本违规
+     */
+    private String suggestion;
+
+    /**
+     * antispam
+     */
+    private String scene;
+
+    /**
+     *文本垃圾检测结果的分类
+     */
+    private String label;
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckResultDTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckResultDTO.java
@ -0,0 +1,38 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @program: esua-epdc
+ * @description: 审核结果信息
+ * @author: wangtong
+ * @create: 2020-07-06 13:43
+ **/
+@Data
+public class CheckResultDTO implements Serializable {
+
+    private static final long serialVersionUID = 6227038632643603309L;
+
+    /**
+     * 审核通过的dataId列表
+     */
+    private List<String> successDataIds;
+
+    /**
+     *审核未通过的dataId列表
+     */
+    private List<String> failDataIds;
+
+    /**
+     *审核详情
+     */
+    private List<CheckResultDetailsDTO> details;
+
+    /**
+     *提交的任务是否全部通过，true-是；false-否
+     */
+    private Boolean allPass;
+}
--- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckResultDetailsDTO.java
+++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/security/content/dto/result/CheckResultDetailsDTO.java
@ -0,0 +1,38 @@
+package com.elink.esua.epdc.commons.tools.security.content.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @program: esua-epdc
+ * @description: 审核结果详情
+ * @author: wangtong
+ * @create: 2020-07-06 13:51
+ **/
+@Data
+public class CheckResultDetailsDTO implements Serializable {
+
+    private static final long serialVersionUID = 4004896322410088693L;
+
+    /**
+     * 状态码
+     */
+     private Integer code;
+
+    /**
+     *响应信息
+     */
+    private String  msg;
+
+    /**
+     *检测的数据Id
+     */
+    private String dataId;
+
+    /**
+     *审核详细结果
+     */
+    private List<CheckDetailResultsDTO> results;
+}
--- a/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/controller/HandleResultController.java
+++ b/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/controller/HandleResultController.java
@ -0,0 +1,50 @@
+package com.elink.esua.epdc.controller;
+
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.service.ViolationsRecordsService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @program: esua-epdc
+ * @description: 处理审核结果
+ * @author: wangtong
+ * @create: 2020-07-07 09:14
+ **/
+@RestController
+@RequestMapping("handleResult")
+public class HandleResultController{
+
+    @Autowired
+    private ViolationsRecordsService violationsRecordsService;
+
+    /**
+    * @describe: 保存违规记录
+    * @author wangtong
+    * @date 2020/7/7 9:19
+    * @param [formDto]
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("insertViolationsRecord")
+    public Result insertViolationsRecord(@RequestBody SaveCheckRecordsFTO formDto) {
+//        ValidatorUtils.validateEntity(formDto);
+        return violationsRecordsService.insertViolationsRecord(formDto);
+    }
+
+    /**
+    * @describe: 保存待审核记录
+    * @author wangtong
+    * @date 2020/7/7 10:39
+    * @param [formDto]
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("insertRecords")
+    public Result insertRecords(@RequestBody SaveCheckRecordsFTO formDto) {
+//        ValidatorUtils.validateEntity(formDto);
+        return violationsRecordsService.insertRecords(formDto);
+    }
+}
--- a/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/service/ViolationsRecordsService.java
+++ b/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/service/ViolationsRecordsService.java
@ -19,6 +19,8 @@ package com.elink.esua.epdc.service;

 import com.elink.esua.epdc.commons.mybatis.service.BaseService;
 import com.elink.esua.epdc.commons.tools.page.PageData;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
+import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.dto.ViolationsRecordsDTO;
 import com.elink.esua.epdc.entity.ViolationsRecordsEntity;

@ -92,4 +94,22 @@ public interface ViolationsRecordsService extends BaseService<ViolationsRecordsE
     * @date 2020-07-03
     */
    void delete(String[] ids);
+
+    /**
+    * @describe: 保存违规记录
+    * @author wangtong
+    * @date 2020/7/7 9:20
+    * @param [formDto]
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    Result insertViolationsRecord(SaveCheckRecordsFTO formDto);
+
+    /**
+    * @describe: 保存待审核记录
+    * @author wangtong
+    * @date 2020/7/7 10:39
+    * @param [formDto]
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    Result insertRecords(SaveCheckRecordsFTO formDto);
 }
--- a/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/service/impl/ViolationsRecordsServiceImpl.java
+++ b/esua-epdc/epdc-module/epdc-content-security/epdc-content-security-server/src/main/java/com/elink/esua/epdc/service/impl/ViolationsRecordsServiceImpl.java
@ -21,8 +21,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
 import com.elink.esua.epdc.commons.tools.page.PageData;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
 import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
 import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
+import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.dao.ViolationsRecordsDao;
 import com.elink.esua.epdc.dto.ViolationsRecordsDTO;
 import com.elink.esua.epdc.entity.ViolationsRecordsEntity;
@ -101,4 +103,18 @@ public class ViolationsRecordsServiceImpl extends BaseServiceImpl<ViolationsReco
        baseDao.deleteBatchIds(Arrays.asList(ids));
    }

+    @Override
+    public Result insertViolationsRecord(SaveCheckRecordsFTO formDto) {
+        ViolationsRecordsEntity entity = ConvertUtils.sourceToTarget(formDto, ViolationsRecordsEntity.class);
+        insert(entity);
+        return new Result();
+    }
+
+    @Override
+    public Result insertRecords(SaveCheckRecordsFTO formDto) {
+        ViolationsRecordsEntity entity = ConvertUtils.sourceToTarget(formDto, ViolationsRecordsEntity.class);
+        insert(entity);
+        return new Result();
+    }
+
 }
--- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/comment/service/impl/EventCommentServiceImpl.java
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/comment/service/impl/EventCommentServiceImpl.java
@ -23,6 +23,9 @@ 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.page.PageData;
+import com.elink.esua.epdc.commons.tools.security.content.CheckDataUtils;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
+import com.elink.esua.epdc.commons.tools.security.content.dto.result.CheckResultDTO;
 import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
 import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.constant.EventsNoticeConstant;
@ -43,6 +46,7 @@ import com.elink.esua.epdc.modules.comment.entity.EventCommentEntity;
 import com.elink.esua.epdc.modules.comment.service.EventCommentService;
 import com.elink.esua.epdc.modules.comment.service.EventCommentUserAttitudeService;
 import com.elink.esua.epdc.modules.events.service.EpdcEventsService;
+import com.elink.esua.epdc.modules.feign.ContentSecurityFeignClient;
 import com.elink.esua.epdc.modules.issue.entity.IssueEntity;
 import com.elink.esua.epdc.modules.issue.service.IssueService;
 import com.elink.esua.epdc.modules.item.entity.ItemEntity;
@ -85,6 +89,9 @@ public class EventCommentServiceImpl extends BaseServiceImpl<EventCommentDao, Ev
    @Autowired
    private EventCommentUserAttitudeService eventCommentUserAttitudeService;

+    @Autowired
+    private ContentSecurityFeignClient contentSecurityFeign;
+
    @Override
    public PageData<EventCommentDTO> page(Map<String, Object> params) {
        IPage<EventCommentEntity> page = baseDao.selectPage(
@ -140,6 +147,27 @@ public class EventCommentServiceImpl extends BaseServiceImpl<EventCommentDao, Ev
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Result submit(SubmitCommentFormDTO commentFormDTO) {
+        //内容审核
+        CheckResultDTO checkResult = CheckDataUtils.checkContent(null,commentFormDTO.getContent());
+        if(checkResult != null && 200 == checkResult.getDetails().get(0).getCode()){
+            if(false == checkResult.getAllPass()){
+                SaveCheckRecordsFTO record = new SaveCheckRecordsFTO();
+                record.setUserId(commentFormDTO.getUserId());
+                record.setName(commentFormDTO.getUserName());
+                record.setCategory("2");//居民
+                record.setType(1);//文字
+                record.setModule("issue_comment");//党群议事-议题项目-评论
+                record.setContent(commentFormDTO.getContent());
+                record.setSuggestionText(checkResult.getDetails().get(0).getResults().get(0).getSuggestion());
+                record.setLabelText(checkResult.getDetails().get(0).getResults().get(0).getLabel());
+                record.setRate(checkResult.getDetails().get(0).getResults().get(0).getRate());
+                contentSecurityFeign.insertViolationsRecord(record);
+                return new Result().error("内容审核未通过，请修改后重新提交！");
+            }
+        }else{
+            logger.error("解析审核结果异常："+checkResult);
+        }
+
        IssueEntity issueEntity = null;
        ItemEntity itemEntity = null;

@ -240,6 +268,23 @@ public class EventCommentServiceImpl extends BaseServiceImpl<EventCommentDao, Ev
        // 发送消息
        newsTask.insertUserInformation(informationFormDTO);

+        //判断是否为待审核
+        if(checkResult != null
+                && 200 == checkResult.getDetails().get(0).getCode()
+                && "review".equals(checkResult.getDetails().get(0).getResults().get(0).getSuggestion())){
+            SaveCheckRecordsFTO record = new SaveCheckRecordsFTO();
+            record.setUserId(commentFormDTO.getUserId());
+            record.setName(commentFormDTO.getUserName());
+            record.setCategory("2");//居民
+            record.setType(1);//文字
+            record.setModule("issue_comment");//党群议事-议题项目-评论
+            record.setContent(commentFormDTO.getContent());
+            record.setRelationId(commentEntity.getId());
+            record.setSuggestionText(checkResult.getDetails().get(0).getResults().get(0).getSuggestion());
+            record.setLabelText(checkResult.getDetails().get(0).getResults().get(0).getLabel());
+            record.setRate(checkResult.getDetails().get(0).getResults().get(0).getRate());
+            contentSecurityFeign.insertRecords(record);
+        }//如果是审核状态是pass，不作任何处理
        return new Result();
    }

--- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/ContentSecurityFeignClient.java
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/ContentSecurityFeignClient.java
@ -0,0 +1,27 @@
+package com.elink.esua.epdc.modules.feign;
+
+import com.elink.esua.epdc.commons.tools.constant.ServiceConstant;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.modules.feign.fallback.ContentSecurityFeignClientFallback;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+/**
+ * 内容审核端接口
+ *
+ * @author wangtong
+ * @date 2020/7/6 15:58
+ */
+
+@FeignClient(name = ServiceConstant.EPDC_CONTENT_SECURITY_SERVER, fallback = ContentSecurityFeignClientFallback.class)
+public interface ContentSecurityFeignClient {
+
+    @PostMapping(value = "content-sercurity/handleResult/insertViolationsRecord", consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    Result insertViolationsRecord(@RequestBody SaveCheckRecordsFTO record);
+
+    @PostMapping(value = "content-sercurity/handleResult/insertRecords", consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    Result insertRecords(@RequestBody SaveCheckRecordsFTO record);
+}
--- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/ContentSecurityFeignClientFallback.java
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/feign/fallback/ContentSecurityFeignClientFallback.java
@ -0,0 +1,28 @@
+package com.elink.esua.epdc.modules.feign.fallback;
+
+import com.elink.esua.epdc.commons.tools.constant.ServiceConstant;
+import com.elink.esua.epdc.commons.tools.security.content.dto.form.SaveCheckRecordsFTO;
+import com.elink.esua.epdc.commons.tools.utils.ModuleUtils;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.modules.feign.ContentSecurityFeignClient;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author wangtong
+ * @date 2020/7/6 15:58
+ */
+@Component
+public class ContentSecurityFeignClientFallback implements ContentSecurityFeignClient {
+
+    @Override
+    public Result insertViolationsRecord(SaveCheckRecordsFTO record) {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CONTENT_SECURITY_SERVER, "insertViolationsRecord", record);
+    }
+
+    @Override
+    public Result insertRecords(SaveCheckRecordsFTO record) {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CONTENT_SECURITY_SERVER, "insertRecords", record);
+    }
+
+
+}