政策重点认证事业部 风险项入库

adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/PolicyWorkFlowController.java

@@ -56,7 +56,7 @@ public class PolicyWorkFlowController {
     private PolicyWorkFlowService policyWorkFlowService;
 
     /**
-     * 政策征求意见导出
+     * 纳入重点问题管控
      */
     @PostMapping("/enterIssue")
     @ApiOperation("纳入重点问题管控")

adc-da-activiti/src/main/java/com/adc/da/workFlow/service/PolicyWorkFlowService.java

@@ -21,9 +21,11 @@ public class PolicyWorkFlowService  {
     public boolean enterIssue(String json){
         boolean count=false; //是否成功
         JSONObject dataJsonObj = JSONObject.parseObject(json);
+        JSONObject jsonData = dataJsonObj.getJSONObject("json");
 
-        if ("1".equals(dataJsonObj.getString("department"))) {
+
-            JSONArray dataList = dataJsonObj.getJSONArray("dataList");
+        if ("1".equals(  jsonData.getString("feedbackDept"))) {
+            JSONArray dataList = jsonData.getJSONArray("infoTableDatas");
 
             /**
              * 把json对象转换未实体对象
@@ -31,11 +33,13 @@ public class PolicyWorkFlowService  {
             List<BusinessDeptIssue> data = dataList
                     .stream()
                     .map(jsonObj -> {
-
                         BusinessDeptIssue businessDeptIssue = JSONObject.parseObject(jsonObj.toString(), BusinessDeptIssue.class);
                         businessDeptIssue.setId(UUIDUtils.randomUUID20());
                         return businessDeptIssue;
-                    }).collect(Collectors.toList());
+                    }).collect(Collectors.toList())
+                    .stream()
+                    .filter(item->"1".equals(item.getIsRisk()))
+                    .collect(Collectors.toList());
             count=businessDeptIssueService.saveBatch(data);
 
         }

adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandUnqualified/entity/BusinessDeptIssue.java

@@ -85,6 +85,10 @@ public class BusinessDeptIssue {
   @TableField("is_close")
   private String isClose;
 
+  @ExcelIgnore
+  @TableField("is_risk")
+  private String isRisk;
+
   @ExcelIgnore
   @TableField(exist = false)
   private Integer page;