修改抓取规则保存功能

ruoyi-admin/src/main/java/com/ruoyi/web/controller/wisdomarbitrate/DeptIdentifyController.java

         return deptIdentifyService.saveFatchRules(templateManage);
     }
 
+    /**
+     * 查询column和注释
+     * @return
+     */
+    @PostMapping("/selectColumnandComment")
+    public AjaxResult selectColumnandComment(){
+        List<FatchRule> fatchRuleList = deptIdentifyService.selectColumnandComment();
+        return AjaxResult.success(fatchRuleList);
+    }
 
+    /**
+     * 查询column
+     * @return
+     */
+    @PostMapping("/selectColumnbycomment")
+    public AjaxResult selectColumnbycomment(@RequestBody  FatchRule fatchRule){
+        FatchRule fatchRulesel = deptIdentifyService.selectColumnbycomment(fatchRule);
+        return AjaxResult.success(fatchRulesel);
+    }
 
 
 

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/domain/CaseApplication.java

 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.ruoyi.common.annotation.Excel;
 import com.ruoyi.common.core.domain.BaseEntity;
+import com.ruoyi.wisdomarbitrate.domain.vo.ColumnValue;
+
 import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
     private Long templateId;
 
 
+
     /** 立案日期 */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private Date registerDate;
         this.annexTypeList = annexTypeList;
     }
 
+    private List<ColumnValue> columnValues;
+
+    public List<ColumnValue> getColumnValues() {
+        return columnValues;
+    }
+
+    public void setColumnValues(List<ColumnValue> columnValues) {
+        this.columnValues = columnValues;
+    }
+
     /**
      * 案件附件列表
      */

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/domain/FatchRule.java

     private Integer isDefault;
 
     private Long templateId;
+    private String databaseName;
 
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/domain/vo/ColumnValue.java

      */
     private Long caseId;
 
+    private Integer isDefault;
+
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/mapper/ColumnValueMapper.java

 package com.ruoyi.wisdomarbitrate.mapper;
 
+import com.ruoyi.wisdomarbitrate.domain.CaseApplication;
 import com.ruoyi.wisdomarbitrate.domain.FatchRule;
 import com.ruoyi.wisdomarbitrate.domain.vo.ColumnValue;
 import org.apache.ibatis.annotations.Param;
      */
     List<ColumnValue> listByCaseId(@Param("caseId") Long caseId);
 
+    List<ColumnValue> queryColumnValueList(ColumnValue columnValue);
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/mapper/FatchRuleMapper.java

    void deletebatchFatchRule(@Param("fatchRuleIds")  List<Long> fatchRuleIds);
 
    int insertFatchRule(FatchRule fatchRule);
+
+   List<FatchRule> selectColumnandComment(FatchRule fatchRuleselect);
+
+   FatchRule selectColumnbycomment(FatchRule fatchRule);
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/IDeptIdentifyService.java

     List<FatchRule> getFatchRuleByTemplateid(TemplateManage templateManage);
 
     AjaxResult saveFatchRules(TemplateManage templateManage);
+
+    List<FatchRule> selectColumnandComment();
+
+    FatchRule selectColumnbycomment(FatchRule fatchRule);
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/CaseApplicationServiceImpl.java

         arbitrateRecord.setCaseAppliId(caseApplication.getId());
         ArbitrateRecord arbitrateRecordselect = arbitrateRecordMapper.selectArbitrateRecord(arbitrateRecord);
 
+        ColumnValue columnValue = new ColumnValue();
+        columnValue.setIsDefault(1);
+        columnValue.setCaseId(caseApplication.getId());
+        List<ColumnValue> columnValueList = columnValueMapper.queryColumnValueList(columnValue);
+        caseApplicationselect.setColumnValues(columnValueList);
+
 //        CaseAttach caseAttachSelect = new CaseAttach();
 //        caseAttachSelect.setCaseAppliId(caseApplication.getId());
 //        caseAttachSelect.setAnnexType(2);
             caseApplicationselect.setRespondentName(respondentName.toString());
             caseApplicationselect.setCaseAffiliates(caseAffiliatListeselect);
             caseApplicationselect.setArbitrateRecord(arbitrateRecordselect);
+
         }
         return caseApplicationselect;
     }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/DeptIdentifyServiceImpl.java

 import com.ruoyi.common.core.domain.entity.SysDept;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.exception.EsignDemoException;
+import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.SealUtil;
 import com.ruoyi.common.utils.file.FileUploadUtils;
 import com.ruoyi.system.domain.SysUserPost;
 import java.time.LocalDate;
 import java.util.*;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 import static com.ruoyi.common.utils.PageUtils.startPage;
 import static com.ruoyi.common.utils.SecurityUtils.getUsername;
         templateFatchRuleMapper.deleteTemplateFatchRule(templateManage.getId());
 
         List<FatchRule> fatchRules = templateManage.getFatchRules();
+
+        Map<Object, Long> columnmap  = fatchRules.stream().collect(Collectors.groupingBy(fatchRule -> fatchRule.getColumn(), Collectors.counting()));
+        Stream<Object> columnStream = columnmap.entrySet().stream().filter(entry -> entry.getValue() > 1).map(entry -> entry.getKey());
+        List<String> strlist1 = new ArrayList<>();
+        columnStream.forEach(column -> {
+            strlist1.add(column.toString());
+        });
+        if(strlist1!=null&&strlist1.size()>0){
+            throw new ServiceException("字段' " + String.join(",", strlist1)  + " '重复");
+        }
+
+        Map<Object, Long> columnNamemap  = fatchRules.stream().collect(Collectors.groupingBy(fatchRule -> fatchRule.getColumnName(), Collectors.counting()));
+        Stream<Object> columnNameStream = columnNamemap.entrySet().stream().filter(entry -> entry.getValue() > 1).map(entry -> entry.getKey());
+        List<String> strlist2 = new ArrayList<>();
+        columnNameStream.forEach(column -> {
+            strlist2.add(column.toString());
+        });
+        if(strlist2!=null&&strlist2.size()>0){
+            throw new ServiceException("字段' " + String.join(",", strlist2) + " '重复");
+        }
+
         if(fatchRules!=null&&fatchRules.size()>0){
             for (FatchRule fatchRule : fatchRules) {
                 //保存抓取规则数据
-                fatchRule.setIsDefault(0);
                 fatchRuleMapper.insertFatchRule(fatchRule);
                 //保存模板抓取规则关联关系
                 Long fatchRuleId = fatchRule.getId();
         return AjaxResult.error();
     }
 
+    @Override
+    public List<FatchRule> selectColumnandComment() {
+        List<FatchRule>  fatchRules = new ArrayList<>();
+        FatchRule fatchRuleselect = new FatchRule();
+        fatchRuleselect.setDatabaseName("test_smart_arbitration");
+        fatchRules = fatchRuleMapper.selectColumnandComment(fatchRuleselect);
+        return fatchRules;
+    }
+
+    @Override
+    public FatchRule selectColumnbycomment(FatchRule fatchRule) {
+        fatchRule.setDatabaseName("test_smart_arbitration");
+        FatchRule fatchRulesel = fatchRuleMapper.selectColumnbycomment(fatchRule);
+        return fatchRulesel;
+    }
+
     private String getFileExtension(String fileName) {
         int lastDotIndex = fileName.lastIndexOf(".");
         if (lastDotIndex > 0 && lastDotIndex < fileName.length() - 1) {

ruoyi-system/src/main/resources/mapper/wisdomarbitrate/ColumnValueMapper.xml

         select * from column_value where case_id=#{caseId}
     </select>
 
+    <select id="queryColumnValueList"  parameterType="ColumnValue"  resultMap="BaseResultMap">
+        select * from column_value c
+        <where>
+            <if test="caseId != null">
+                AND c.case_id  = #{caseId}
+            </if>
+            <if test="isDefault != null">
+                AND c.is_default  = #{isDefault}
+            </if>
+
+        </where>
+    </select>
+
 
 </mapper>

ruoyi-system/src/main/resources/mapper/wisdomarbitrate/FatchRuleMapper.xml

         </where>
     </select>
 
+    <select id="selectColumnandComment"  parameterType="FatchRule"  resultMap="BaseResultMap">
+        select
+            a.COLUMN_name as `column`,
+            a.COLumn_comment as column_name
+        from
+            information_schema.COLUMNS a
+        where
+            TABLE_schema =  #{databaseName}
+            and TABLE_name in('case_application','case_affiliate')
+            and COLUMN_NAME  not in('id','case_appli_id','case_num','case_subject_amount',
+        'register_date','arbitrat_method','case_status','hear_date','begin_video_date',
+        'online_video_person','create_time','update_by','update_time','create_by',
+        'arbitrator_id','arbitrator_name','pended_trial_arbitorid','pending_appoint_arbotrar',
+        'case_name','case_result','is_agree_pend_tral','objection_add_eviden','open_court_hear',
+        'paid_expenses','filearbitra_url','pay_type','adjudica_counter','proper_preser','objecti_juris',
+        'is_absence','respon_cross_opin','applica_cross_opin','respon_defen_opini','appli_is_absen',
+        'lock_status','room_id','import_flag','version','batch_number','template_id','applicant_agent_user_id','contract_number','identity_type','application_organ_id')
+
+    </select>
+
+    <select id="selectColumnbycomment"  parameterType="FatchRule"  resultMap="BaseResultMap">
+        select
+              COLUMN_NAME
+        from
+            information_schema.COLUMNS
+        where
+            TABLE_schema =  #{databaseName}
+            and TABLE_name in('case_application','case_affiliate')
+            and  COLumn_comment  = #{columnName}
+
+    </select>
+
+
     <select id="selectFatchRuleListIsDefault" parameterType="FatchRule" resultMap="BaseResultMap">
         SELECT f.id ,f.file_name ,f.start_content ,f.end_content ,
         f.`column` ,f.is_default ,f.columnName