feat：【地图信息统计】提交

src/main/java/com/fkzy/warn/common/constants/ReportConstants.java

@@ -82,4 +82,40 @@ public class ReportConstants {
      * 6.4 高频诉讼对手
      **/
     public static final String HIGH_FREQUENCY_TEXT = "highFrequencyText";
+    public static final  String[] PROVINCE = {
+        "北京市",
+        "天津市",
+        "河北省",
+        "山西省",
+        "内蒙古自治区",
+        "辽宁省",
+        "吉林省",
+        "黑龙江省",
+        "上海市",
+        "江苏省",
+        "浙江省",
+        "安徽省",
+        "福建省",
+        "江西省",
+        "山东省",
+        "河南省",
+        "湖北省",
+        "湖南省",
+        "广东省",
+        "广西壮族自治区",
+        "海南省",
+        "重庆市",
+        "四川省",
+        "贵州省",
+        "云南省",
+        "西藏自治区",
+        "陕西省",
+        "甘肃省",
+        "青海省",
+        "宁夏回族自治区",
+        "新疆维吾尔自治区",
+        "台湾省",
+        "香港",
+        "澳门"
+    };
 }

src/main/java/com/fkzy/warn/common/util/ReportUtil.java

@@ -954,6 +954,160 @@ public class ReportUtil {
         return result.toString();
     }
     /**
+     * 案件金额
+     *
+     * @return java.lang.String
+     * @author zhangjing
+     * @create 2024/12/16
+     **/
+    public static BigDecimal getCaseAmount(List<LawCase> caseList) {
+        BigDecimal totalAmount = BigDecimal.ZERO;
+        for (LawCase lawCase : caseList) {
+             if (lawCase.getNQsbdje()!=null){
+                 totalAmount = totalAmount.add(lawCase.getNQsbdje());
+             }
+        }
+        return totalAmount.divide(BigDecimal.valueOf(10000), 2, BigDecimal.ROUND_HALF_UP);
+    }
+    /**
+     * 设置案由，诉讼地位，审理阶段信息
+     *
+     * @return java.lang.String
+     * @author zhangjing
+     * @create 2024/12/16
+     **/
+    public static void setAlarmInfo(EnterpriseAlarmInfo data,List<LawCase> caseList,List<EnterpriseProvince> enterpriseProvinceList) {
+        Map<String, Integer> roleCaseCountMap = new HashMap<>();
+        Map<String, BigDecimal> roleCaseAmountMap = new HashMap<>();
+        Map<String, Integer> slcxCaseCountMap = new HashMap<>();
+        Map<String, BigDecimal> slcxCaseAmountMap = new HashMap<>();
+        Map<String, Integer> caseReasonCountMap = new HashMap<>();
+        Map<String, BigDecimal> caseReasonAmontMap = new HashMap<>();
+        //省份
+
+        Map<String, EnterpriseProvince> provinceMap = new HashMap<>();
+        for(String name : ReportConstants.PROVINCE){
+            provinceMap.put(name,new EnterpriseProvince(data.getCreditCode(), name,0,BigDecimal.ZERO));
+        }
+
+
+
+
+
+
+        BigDecimal totalAmount = BigDecimal.ZERO;
+        slcxCaseCountMap.put("一审", 0);
+        slcxCaseCountMap.put("二审", 0);
+        slcxCaseCountMap.put("再审审查", 0);
+        slcxCaseCountMap.put("再审", 0);
+        slcxCaseAmountMap.put("一审", BigDecimal.ZERO);
+        slcxCaseAmountMap.put("二审", BigDecimal.ZERO);
+        slcxCaseAmountMap.put("再审审查", BigDecimal.ZERO);
+        slcxCaseAmountMap.put("再审", BigDecimal.ZERO);
+
+
+        roleCaseCountMap.put("原告", 0);
+        roleCaseCountMap.put("被告", 0);
+        roleCaseCountMap.put("第三人", 0);
+        roleCaseCountMap.put("其他", 0);
+        roleCaseAmountMap.put("原告", BigDecimal.ZERO);
+        roleCaseAmountMap.put("被告", BigDecimal.ZERO);
+        roleCaseAmountMap.put("第三人", BigDecimal.ZERO);
+        roleCaseAmountMap.put("其他", BigDecimal.ZERO);
+
+
+        for (LawCase lawCase : caseList) {
+
+
+            String slcx = lawCase.getNSlcx();
+            String companyName = lawCase.getCompanyName();
+            if (slcxCaseCountMap.containsKey(slcx)) {
+                slcxCaseCountMap.put(slcx, slcxCaseCountMap.get(slcx) + 1);
+                if (lawCase.getNQsbdje()!=null){
+                    slcxCaseAmountMap.put(slcx, slcxCaseAmountMap.getOrDefault(slcx, BigDecimal.ZERO).add(lawCase.getNQsbdje()));
+                }
+            }
+            if (lawCase.getCSsdy()!=null&&provinceMap.containsKey(lawCase.getCSsdy())){
+                EnterpriseProvince enterpriseProvince = provinceMap.get(lawCase.getCSsdy());
+                enterpriseProvince.setCount(enterpriseProvince.getCount()+1);
+                if (lawCase.getNQsbdje()!=null){
+                    enterpriseProvince.setAmount(enterpriseProvince.getAmount().add(lawCase.getNQsbdje()));
+                }
+                provinceMap.put(lawCase.getCSsdy(),enterpriseProvince);
+            }
+
+            for (LitigantInfo litigantInfo : lawCase.getLitigantInfoList()) {
+                String role = litigantInfo.getNSsdw();
+                if (companyName.equals(litigantInfo.getCMc())&&roleCaseCountMap.containsKey(role)) {
+                    roleCaseCountMap.put(role, roleCaseCountMap.get(role) + 1);
+                    if (lawCase.getNQsbdje()!=null){
+                        roleCaseAmountMap.put(role, roleCaseAmountMap.get(role).add(lawCase.getNQsbdje()));
+                    }
+                }
+            }
+            if (lawCase.getNQsbdje()!=null){
+                totalAmount = totalAmount.add(lawCase.getNQsbdje());
+            }
+            // 统计案由
+            String caseReason = lawCase.getNLaay();
+            if (caseReason != null && !caseReason.isEmpty()) {
+                caseReasonCountMap.put(caseReason, caseReasonCountMap.getOrDefault(caseReason, 0) + 1);
+                if (lawCase.getNQsbdje()!=null){
+                    caseReasonAmontMap.put(caseReason, caseReasonAmontMap.getOrDefault(caseReason, BigDecimal.ZERO).add(lawCase.getNQsbdje()));
+                }
+            }
+        }
+        // 案由进行排序
+        List<Map.Entry<String, Integer>> sortedCaseReasons = new ArrayList<>(caseReasonCountMap.entrySet());
+        sortedCaseReasons.sort((entry1, entry2) -> entry2.getValue().compareTo(entry1.getValue()));
+        // 案由金额进行排序
+        List<Map.Entry<String, BigDecimal>> sortedCaseReasonAmonts = new ArrayList<>(caseReasonAmontMap.entrySet());
+        sortedCaseReasonAmonts.sort((entry1, entry2) -> entry2.getValue().compareTo(entry1.getValue()));
+        // 取出前三的案由金额
+        data.setAyAmountTop1(sortedCaseReasonAmonts.get(0).getValue());
+        data.setAyAmountTop2(sortedCaseReasonAmonts.get(1).getValue());
+        data.setAyAmountTop3(sortedCaseReasonAmonts.get(2).getValue());
+        data.setAyNameAmountTop1(sortedCaseReasonAmonts.get(0).getKey());
+        data.setAyNameAmountTop2(sortedCaseReasonAmonts.get(1).getKey());
+        data.setAyNameAmountTop3(sortedCaseReasonAmonts.get(2).getKey());
+
+
+        // 取出前三的案由
+        data.setAyCountTop1(sortedCaseReasons.get(0).getValue());
+        data.setAyCountTop2(sortedCaseReasons.get(1).getValue());
+        data.setAyCountTop3(sortedCaseReasons.get(2).getValue());
+        data.setAyNameTop1(sortedCaseReasons.get(0).getKey());
+        data.setAyNameTop2(sortedCaseReasons.get(1).getKey());
+        data.setAyNameTop3(sortedCaseReasons.get(2).getKey());
+        //审理阶段
+        data.setYsCount(slcxCaseCountMap.get("一审"));
+        data.setEsCount(slcxCaseCountMap.get("二审"));
+        data.setZsCount(slcxCaseCountMap.get("再审审查"));
+        data.setZxCount(slcxCaseCountMap.get("再审"));
+        data.setYsAmount(slcxCaseAmountMap.get("一审"));
+        data.setEsAmount(slcxCaseAmountMap.get("二审"));
+        data.setZsAmount(slcxCaseAmountMap.get("再审审查"));
+        data.setZxAmount(slcxCaseAmountMap.get("再审"));
+        //诉讼地位
+        data.setYgCount(roleCaseCountMap.get("原告"));
+        data.setBgCount(roleCaseCountMap.get("被告"));
+        data.setDsrCount(roleCaseCountMap.get("第三人"));
+        data.setQtCount(roleCaseCountMap.get("其他"));
+        data.setYgAmount(roleCaseAmountMap.get("原告"));
+        data.setBgAmount(roleCaseAmountMap.get("被告"));
+        data.setDsrAmount(roleCaseAmountMap.get("第三人"));
+        data.setQtAmount(roleCaseAmountMap.get("其他"));
+
+        for(String k:provinceMap.keySet()) {
+            enterpriseProvinceList.add(provinceMap.get(k));
+        }
+
+        data.setThreeYearsCount(caseList.size());
+        data.setThreeYearsAmount(totalAmount);
+
+    }
+
+    /**
      * @Description: 跨列合并
      * table
      * row:行

src/main/java/com/fkzy/warn/mapper/AdministratorMapper.java

@@ -0,0 +1,14 @@
+package com.fkzy.warn.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fkzy.warn.model.Administrator;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zhangjing
+ * @date 2024/12/04 14:48
+ * @description
+ */
+@Mapper
+public interface AdministratorMapper extends BaseMapper<Administrator> {
+}

src/main/java/com/fkzy/warn/mapper/EnterpriseAlarmInfoMapper.java

@@ -0,0 +1,14 @@
+package com.fkzy.warn.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fkzy.warn.model.EnterpriseAlarmInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zhangjing
+ * @date 2024/12/04 14:48
+ * @description
+ */
+@Mapper
+public interface EnterpriseAlarmInfoMapper extends BaseMapper<EnterpriseAlarmInfo> {
+}

src/main/java/com/fkzy/warn/mapper/EnterpriseProvinceMapper.java

@@ -0,0 +1,14 @@
+package com.fkzy.warn.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fkzy.warn.model.EnterpriseProvince;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author zhangjing
+ * @date 2024/12/04 14:48
+ * @description
+ */
+@Mapper
+public interface EnterpriseProvinceMapper extends BaseMapper<EnterpriseProvince> {
+}

src/main/java/com/fkzy/warn/mapper/LawCaseMapper.java

@@ -3,6 +3,9 @@ package com.fkzy.warn.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.fkzy.warn.model.LawCase;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * @author zhangjing
@@ -11,4 +14,5 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface LawCaseMapper extends BaseMapper<LawCase> {
+    List<LawCase> queryByAlarmCase(@Param("creditCode") String creditCode);
 }

src/main/java/com/fkzy/warn/model/Administrator.java

@@ -0,0 +1,72 @@
+package com.fkzy.warn.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 企业基本信息
+ * @author zhangjing
+ * @date 2024/12/05 14:07
+ * @description
+ */
+@Data
+@TableName("t_administrator")
+public class Administrator extends BaseField{
+
+    @TableId(value = "id", type = IdType.ASSIGN_UUID)
+    private String id;
+    /**
+     * 统一信用代码
+     */
+    @ApiModelProperty("统一信用代码")
+    @TableField(value = "CREDITCODE")
+    private String CREDITCODE;
+    /**
+     * 企业名称
+     */
+    @ApiModelProperty("企业名称")
+    @TableField(value = "ENTNAME")
+    private String ENTNAME;
+    /**
+     * 高管姓名
+     */
+    @ApiModelProperty("高管姓名")
+    @TableField(value = "PERNAME")
+    private String PERNAME;
+    /**
+     * 职位
+     */
+    @ApiModelProperty("职位")
+    @TableField(value = "POSITION")
+    private String POSITION;
+    /**
+     * 高管总数量
+     */
+    @ApiModelProperty("高管总数量")
+    @TableField(value = "PERSONAMOUNT")
+    private Integer PERSONAMOUNT;
+    /**
+     * 任职开始时间
+     */
+    @ApiModelProperty("任职开始时间")
+    @TableField(value = "CEIINCLUDEDATE")
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    private Date CEIINCLUDEDATE;
+    /**
+     * 任职截止时间
+     */
+    @ApiModelProperty("任职截止时间")
+    @TableField(value = "CEIREMOVEDATE")
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    private Date CEIREMOVEDATE;
+
+
+
+}

src/main/java/com/fkzy/warn/model/EnterpriseAlarmInfo.java

@@ -0,0 +1,229 @@
+package com.fkzy.warn.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 企业司法告警汇总
+ * @author zhangjing
+ * @date 2024/12/05 14:07
+ * @description
+ */
+@Data
+@TableName("t_enterprise_alarm_info")
+public class EnterpriseAlarmInfo extends BaseField{
+    /**
+     * 统一社会信用代码
+     */
+    @ApiModelProperty("统一社会信用代码")
+    @TableId(value = "credit_code", type = IdType.INPUT)
+    private String creditCode;
+    /**
+     * 企业名称
+     */
+    @ApiModelProperty("企业名称")
+    private String companyName;
+    /**
+     * 企业法人
+     */
+    @ApiModelProperty("企业法人")
+    private String legalPerson;
+    /**
+     * 告警次数
+     */
+    @ApiModelProperty("告警次数")
+    private Integer alarmCount;
+    /**
+     * 告警金额
+     */
+    @ApiModelProperty("告警金额")
+    private BigDecimal alarmAmount;
+
+    /**
+     * 近三月新发案件数
+     */
+    @ApiModelProperty("近三月新发案件数")
+    private Integer threeMonthsCount;
+    /**
+     * 近三月新发案件金额
+     */
+    @ApiModelProperty("近三月新发案件金额")
+    private BigDecimal threeMonthsAmount;
+
+    /**
+     * 案由数量top1
+     */
+    @ApiModelProperty("案由数量top1")
+    private Integer ayCountTop1;
+
+    /**
+     * 案由名top1
+     */
+    @ApiModelProperty("案由名top1")
+    private String ayNameTop1;
+    /**
+     * 案由数量top2
+     */
+    @ApiModelProperty("案由数量top2")
+    private Integer ayCountTop2;
+
+    /**
+     * 案由名top2
+     */
+    @ApiModelProperty("案由名top2")
+    private String ayNameTop2;
+
+    /**
+     * 案由数量top3
+     */
+    @ApiModelProperty("案由数量top3")
+    private Integer ayCountTop3;
+
+    /**
+     * 案由名top3
+     */
+    @ApiModelProperty("案由名top3")
+    private String ayNameTop3;
+
+    /**
+     * 原告数
+     */
+    @ApiModelProperty("原告数")
+    private Integer ygCount;
+
+    /**
+     * 被告数
+     */
+    @ApiModelProperty("被告数")
+    private Integer bgCount;
+
+    /**
+     * 第三人数
+     */
+    @ApiModelProperty("第三人数")
+    private Integer dsrCount;
+
+    /**
+     * 其他数
+     */
+    @ApiModelProperty("其他数")
+    private Integer qtCount;
+
+    /**
+     * 一审数
+     */
+    @ApiModelProperty("一审数")
+    private Integer ysCount;
+
+    /**
+     * 二审数
+     */
+    @ApiModelProperty("二审数")
+    private Integer esCount;
+
+    /**
+     * 再审数
+     */
+    @ApiModelProperty("再审数")
+    private Integer zsCount;
+
+    /**
+     * 执行数
+     */
+    @ApiModelProperty("执行数")
+    private Integer zxCount;
+    /**
+     * 近三年案件数
+     */
+    @ApiModelProperty("近三年案件数")
+    private Integer threeYearsCount;
+    /**
+     * 近三年案件金额
+     */
+    @ApiModelProperty("近三年案件金额")
+    private BigDecimal threeYearsAmount;
+
+    /**
+     * 案由金额top1
+     */
+    @ApiModelProperty("案由金额top1")
+    private BigDecimal ayAmountTop1;
+    /**
+     * 案由金额top2
+     */
+    @ApiModelProperty("案由金额top2")
+    private BigDecimal ayAmountTop2;
+    /**
+     * 案由金额top3
+     */
+    @ApiModelProperty("案由金额top3")
+    private BigDecimal ayAmountTop3;
+
+    /**
+     * 原告金额
+     */
+    @ApiModelProperty("原告金额")
+    private BigDecimal ygAmount;
+
+    /**
+     * 被告金额
+     */
+    @ApiModelProperty("被告金额")
+    private BigDecimal bgAmount;
+
+    /**
+     * 第三人金额
+     */
+    @ApiModelProperty("第三人金额")
+    private BigDecimal dsrAmount;
+
+    /**
+     * 其他金额
+     */
+    @ApiModelProperty("其他金额")
+    private BigDecimal qtAmount;
+
+    /**
+     * 一审金额
+     */
+    @ApiModelProperty("一审金额")
+    private BigDecimal ysAmount;
+
+    /**
+     * 二审金额
+     */
+    @ApiModelProperty("二审金额")
+    private BigDecimal esAmount;
+
+    /**
+     * 再审金额
+     */
+    @ApiModelProperty("再审金额")
+    private BigDecimal zsAmount;
+
+    /**
+     * 执行金额
+     */
+    @ApiModelProperty("执行金额")
+    private BigDecimal zxAmount;
+    /**
+     * 案由名top1(金额排序)
+     */
+    @ApiModelProperty("案由名top1")
+    private String ayNameAmountTop1;
+    /**
+     * 案由名top2(金额排序)
+     */
+    @ApiModelProperty("案由名top2")
+    private String ayNameAmountTop2;
+    /**
+     * 案由名top3(金额排序)
+     */
+    @ApiModelProperty("案由名top3")
+    private String ayNameAmountTop3;
+}

src/main/java/com/fkzy/warn/model/EnterpriseProvince.java

@@ -0,0 +1,56 @@
+package com.fkzy.warn.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 企业案件地域信息汇总
+ * @author zhangjing
+ * @date 2024/12/05 14:07
+ * @description
+ */
+@Data
+@TableName("t_enterprise_province")
+public class EnterpriseProvince extends BaseField{
+
+    /**
+     * id
+     */
+    @ApiModelProperty("id")
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    /**
+     * 统一社会信用代码
+     */
+    @ApiModelProperty("统一社会信用代码")
+    private String creditCode;
+    /**
+     * 省份
+     */
+    @ApiModelProperty("省份")
+    private String province;
+    /**
+     * 数量
+     */
+    @ApiModelProperty("数量")
+    private Integer count;
+    /**
+     * 金额
+     */
+    @ApiModelProperty("金额")
+    private BigDecimal amount;
+    public EnterpriseProvince() {
+
+    }
+    public EnterpriseProvince(String creditCode,String province, Integer count, BigDecimal amount) {
+        this.creditCode = creditCode;
+        this.province = province;
+        this.count = count;
+        this.amount = amount;
+    }
+}

src/main/java/com/fkzy/warn/service/AdministratorService.java

@@ -0,0 +1,40 @@
+package com.fkzy.warn.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fkzy.warn.model.Administrator;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+public interface AdministratorService extends IService<Administrator> {
+
+    /**
+     * 保存
+     * @param entity
+     * @return
+     */
+    void saveModel(Administrator entity,String ticket);
+
+    /**
+     * 修改
+     * @param entity
+     * @return
+     */
+    void updateModel(Administrator entity,String ticket);
+
+    /**
+     * 删除
+     * @param ids
+     * @return
+     */
+    void deleteModel(List<String> ids);
+
+
+
+
+
+}

src/main/java/com/fkzy/warn/service/EnterpriseAlarmInfoService.java

@@ -0,0 +1,48 @@
+package com.fkzy.warn.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fkzy.warn.common.request.RequestParameter;
+import com.fkzy.warn.common.response.ApiResponse;
+import com.fkzy.warn.model.EnterpriseAlarmInfo;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+public interface EnterpriseAlarmInfoService extends IService<EnterpriseAlarmInfo> {
+
+    /**
+     * 保存
+     * @param entity
+     * @return
+     */
+    ApiResponse saveModel(EnterpriseAlarmInfo entity, String ticket);
+
+    /**
+     * 修改
+     * @param entity
+     * @return
+     */
+    ApiResponse updateModel(EnterpriseAlarmInfo entity,String ticket);
+
+    /**
+     * 删除
+     * @param ids
+     * @return
+     */
+    ApiResponse deleteModel(List<String> ids);
+
+    /**
+     * 分页查询
+     * @param parameter
+     * @return
+     */
+    Page<EnterpriseAlarmInfo> queryPage(RequestParameter parameter);
+
+
+
+}

src/main/java/com/fkzy/warn/service/EnterpriseProvinceService.java

@@ -0,0 +1,48 @@
+package com.fkzy.warn.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fkzy.warn.common.request.RequestParameter;
+import com.fkzy.warn.common.response.ApiResponse;
+import com.fkzy.warn.model.EnterpriseProvince;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+public interface EnterpriseProvinceService extends IService<EnterpriseProvince> {
+
+    /**
+     * 保存
+     * @param entity
+     * @return
+     */
+    ApiResponse saveModel(EnterpriseProvince entity, String ticket);
+
+    /**
+     * 修改
+     * @param entity
+     * @return
+     */
+    ApiResponse updateModel(EnterpriseProvince entity,String ticket);
+
+    /**
+     * 删除
+     * @param ids
+     * @return
+     */
+    ApiResponse deleteModel(List<String> ids);
+
+    /**
+     * 分页查询
+     * @param parameter
+     * @return
+     */
+    Page<EnterpriseProvince> queryPage(RequestParameter parameter);
+
+
+
+}

src/main/java/com/fkzy/warn/service/LawCaseService.java

@@ -41,6 +41,14 @@ public interface LawCaseService extends IService {
      * @return
      */
     void judicialModelSave(JSONObject jsonObject);
-
-
+    /**
+     *
+     * 三年案件
+     * @param creditCode
+     * @return java.util.List<com.fkzy.warn.model.LawCase>
+     * @author zhangjing
+     * @create 2024/12/26
+     **/
+
+    List<LawCase> threeYearsCases(String creditCode);
 }

src/main/java/com/fkzy/warn/service/impl/AdministratorServiceImpl.java

@@ -0,0 +1,43 @@
+package com.fkzy.warn.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fkzy.warn.common.constants.EntityConstants;
+import com.fkzy.warn.mapper.AdministratorMapper;
+import com.fkzy.warn.model.Administrator;
+import com.fkzy.warn.service.AdministratorService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+@Service
+public class AdministratorServiceImpl extends ServiceImpl<AdministratorMapper, Administrator> implements
+    AdministratorService {
+
+
+    @Override
+    public void saveModel(Administrator entity, String ticket) {
+        save(entity);
+    }
+
+    @Override
+    public void updateModel(Administrator entity,String ticket) {
+        this.updateById(entity);
+    }
+
+    @Override
+    public void deleteModel(List<String> ids) {
+        Administrator entity = new Administrator();
+        entity.setIsDel(EntityConstants.DEL);
+        QueryWrapper wrapper = new QueryWrapper();
+        wrapper.in("id", ids);
+        update(entity, wrapper);
+    }
+
+
+}

src/main/java/com/fkzy/warn/service/impl/EnterpriseAlarmInfoServiceImpl.java

@@ -0,0 +1,58 @@
+package com.fkzy.warn.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fkzy.warn.common.constants.EntityConstants;
+import com.fkzy.warn.common.request.RequestParameter;
+import com.fkzy.warn.common.response.ApiResponse;
+import com.fkzy.warn.mapper.EnterpriseAlarmInfoMapper;
+import com.fkzy.warn.model.EnterpriseAlarmInfo;
+import com.fkzy.warn.service.EnterpriseAlarmInfoService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+@Service
+public class EnterpriseAlarmInfoServiceImpl extends ServiceImpl<EnterpriseAlarmInfoMapper, EnterpriseAlarmInfo> implements
+    EnterpriseAlarmInfoService {
+
+
+    @Override
+    public ApiResponse saveModel(EnterpriseAlarmInfo entity, String ticket) {
+        save(entity);
+        return new ApiResponse();
+    }
+
+    @Override
+    public ApiResponse updateModel(EnterpriseAlarmInfo entity,String ticket) {
+        this.updateById(entity);
+        return new ApiResponse();
+    }
+
+    @Override
+    public ApiResponse deleteModel(List<String> ids) {
+        EnterpriseAlarmInfo entity = new EnterpriseAlarmInfo();
+        entity.setIsDel(EntityConstants.DEL);
+        QueryWrapper wrapper = new QueryWrapper();
+        wrapper.in("id", ids);
+        update(entity, wrapper);
+        return new ApiResponse();
+    }
+
+    @Override
+    public Page<EnterpriseAlarmInfo> queryPage(RequestParameter parameter) {
+        EnterpriseAlarmInfo entity = parameter.getParameter().toJavaObject(EnterpriseAlarmInfo.class);
+        Page<EnterpriseAlarmInfo> page = new Page<EnterpriseAlarmInfo>(parameter.getCurrent(), parameter.getSize());
+        page.setSearchCount(true);
+        page.setOptimizeCountSql(true);
+        QueryWrapper<EnterpriseAlarmInfo> eWrapper = new QueryWrapper<EnterpriseAlarmInfo>(entity);
+        Page<EnterpriseAlarmInfo> result = this.page(page, eWrapper);
+        return result;
+    }
+}

src/main/java/com/fkzy/warn/service/impl/EnterpriseInfoServiceImpl.java

@@ -1,14 +1,18 @@
 package com.fkzy.warn.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.fkzy.warn.common.constants.EntityConstants;
 import com.fkzy.warn.mapper.EnterpriseInfoMapper;
+import com.fkzy.warn.model.Administrator;
 import com.fkzy.warn.model.EnterpriseInfo;
 import com.fkzy.warn.model.LawCase;
+import com.fkzy.warn.service.AdministratorService;
 import com.fkzy.warn.service.EnterpriseInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
@@ -22,6 +26,9 @@ import java.util.List;
 public class EnterpriseInfoServiceImpl extends ServiceImpl<EnterpriseInfoMapper, EnterpriseInfo> implements
     EnterpriseInfoService {
 
+    @Autowired
+    AdministratorService administratorService;
+
 
     @Override
     public void saveModel(EnterpriseInfo entity, String ticket) {
@@ -46,8 +53,17 @@ public class EnterpriseInfoServiceImpl extends ServiceImpl
     public void industryModelSave(JSONObject jsonObject) {
         JSONObject data = jsonObject.getJSONObject("data");
         JSONObject BASIC = data.getJSONObject("BASIC");
+        JSONArray  PERSON = data.getJSONArray("PERSON");
         EnterpriseInfo enterpriseInfo = JSON.parseObject(BASIC.toString(), EnterpriseInfo.class);
-        save(enterpriseInfo);
+        List<Administrator> administratorList = JSON.parseArray(PERSON.toString(), Administrator.class);
+        for (Administrator administrator : administratorList){
+            administrator.setCREDITCODE(enterpriseInfo.getCREDITCODE());
+        }
+        QueryWrapper query = new QueryWrapper<>();
+        query.eq("CREDITCODE", enterpriseInfo.getCREDITCODE());
+        administratorService.remove(query);
+        administratorService.saveBatch(administratorList);
+        saveOrUpdate(enterpriseInfo);
     }
 
 

src/main/java/com/fkzy/warn/service/impl/EnterpriseProvinceServiceImpl.java

@@ -0,0 +1,58 @@
+package com.fkzy.warn.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fkzy.warn.common.constants.EntityConstants;
+import com.fkzy.warn.common.request.RequestParameter;
+import com.fkzy.warn.common.response.ApiResponse;
+import com.fkzy.warn.mapper.EnterpriseProvinceMapper;
+import com.fkzy.warn.model.EnterpriseProvince;
+import com.fkzy.warn.service.EnterpriseProvinceService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author zhangjing
+ * @date 2023/10/16 18:17
+ * @description
+ */
+@Service
+public class EnterpriseProvinceServiceImpl extends ServiceImpl<EnterpriseProvinceMapper, EnterpriseProvince> implements
+    EnterpriseProvinceService {
+
+
+    @Override
+    public ApiResponse saveModel(EnterpriseProvince entity, String ticket) {
+        save(entity);
+        return new ApiResponse();
+    }
+
+    @Override
+    public ApiResponse updateModel(EnterpriseProvince entity,String ticket) {
+        this.updateById(entity);
+        return new ApiResponse();
+    }
+
+    @Override
+    public ApiResponse deleteModel(List<String> ids) {
+        EnterpriseProvince entity = new EnterpriseProvince();
+        entity.setIsDel(EntityConstants.DEL);
+        QueryWrapper wrapper = new QueryWrapper();
+        wrapper.in("id", ids);
+        update(entity, wrapper);
+        return new ApiResponse();
+    }
+
+    @Override
+    public Page<EnterpriseProvince> queryPage(RequestParameter parameter) {
+        EnterpriseProvince entity = parameter.getParameter().toJavaObject(EnterpriseProvince.class);
+        Page<EnterpriseProvince> page = new Page<EnterpriseProvince>(parameter.getCurrent(), parameter.getSize());
+        page.setSearchCount(true);
+        page.setOptimizeCountSql(true);
+        QueryWrapper<EnterpriseProvince> eWrapper = new QueryWrapper<EnterpriseProvince>(entity);
+        Page<EnterpriseProvince> result = this.page(page, eWrapper);
+        return result;
+    }
+}

src/main/java/com/fkzy/warn/service/impl/LawCaseServiceImpl.java

@@ -8,10 +8,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.fkzy.warn.common.constants.EntityConstants;
 import com.fkzy.warn.common.util.ReportUtil;
 import com.fkzy.warn.mapper.LawCaseMapper;
-import com.fkzy.warn.model.EnterpriseInfo;
-import com.fkzy.warn.model.LawCase;
-import com.fkzy.warn.model.LitigantInfo;
-import com.fkzy.warn.model.ReportModel;
+import com.fkzy.warn.model.*;
 import com.fkzy.warn.service.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,6 +41,15 @@ public class LawCaseServiceImpl extends ServiceImpl impl
     @Autowired
     private EnterpriseInfoService enterpriseInfoService;
 
+    @Autowired
+    private EnterpriseAlarmInfoService enterpriseAlarmInfoService;
+
+
+    @Autowired
+    private AlarmCaseService alarmCaseService;
+    @Autowired
+    private EnterpriseProvinceService enterpriseProvinceService;
+
     @Override
     public void saveModel(LawCase entity, String ticket) {
         save(entity);
@@ -70,7 +76,7 @@ public class LawCaseServiceImpl extends ServiceImpl impl
      * @author zhangjing
      * @create 2024/12/15
      **/
-    private List<LawCase> threeMonthsCases() {
+    private List<LawCase> threeMonthsCases(String creditCode,boolean needLitigant) {
         // 获取当前日期
         Date currentDate = new Date();
         Calendar calendar = Calendar.getInstance();
@@ -81,11 +87,14 @@ public class LawCaseServiceImpl extends ServiceImpl impl
         QueryWrapper<LawCase> query = new QueryWrapper<>();
         query.ge("d_larq", threeMonthsAgo);
         List<LawCase> caseList = this.list(query);
-        for (LawCase lawCase : caseList) {
-            QueryWrapper<LitigantInfo> infoQueryWrapper = new QueryWrapper<>();
-            infoQueryWrapper.eq("n_ajbs", lawCase.getNAjbs());
-            lawCase.setLitigantInfoList(litigantInfoService.list(infoQueryWrapper));
+        if (needLitigant){
+            for (LawCase lawCase : caseList) {
+                QueryWrapper<LitigantInfo> infoQueryWrapper = new QueryWrapper<>();
+                infoQueryWrapper.eq("n_ajbs", lawCase.getNAjbs());
+                lawCase.setLitigantInfoList(litigantInfoService.list(infoQueryWrapper));
+            }
         }
+
         return caseList;
     }
     /**
@@ -95,7 +104,8 @@ public class LawCaseServiceImpl extends ServiceImpl impl
      * @author zhangjing
      * @create 2024/12/15
      **/
-    private List<LawCase> threeYearsCases() {
+    @Override
+    public List<LawCase> threeYearsCases(String creditCode) {
         // 获取当前日期
         Date currentDate = new Date();
         Calendar calendar = Calendar.getInstance();
@@ -114,19 +124,19 @@ public class LawCaseServiceImpl extends ServiceImpl impl
         return caseList;
     }
 
-    private ReportModel createReportData(){
+    private ReportModel createReportData(String creditCode){
         ReportModel reportModel = new ReportModel();
         QueryWrapper<EnterpriseInfo> enterpriseInfoQueryWrapper = new QueryWrapper<>();
-        enterpriseInfoQueryWrapper.eq("CREDITCODE", "91440300087909371X");
+        enterpriseInfoQueryWrapper.eq("CREDITCODE", creditCode);
         EnterpriseInfo enterpriseInfo = enterpriseInfoService.getOne(enterpriseInfoQueryWrapper);
         reportModel.setBackgroundJudicial(ReportUtil.backgroundJudicial(enterpriseInfo));
         reportModel.setBasicEnterprise(enterpriseInfo);
-        List<LawCase> threeMonthsCases = threeMonthsCases();
+        List<LawCase> threeMonthsCases = threeMonthsCases(creditCode,true);
         reportModel.setThreeMonthsText1(ReportUtil.threeMonthsText1(threeMonthsCases));
         reportModel.setThreeMonthsCases(threeMonthsCases);
         reportModel.setThreeMonthsText2(ReportUtil.threeMonthsText2(threeMonthsCases));
         reportModel.setThreeMonthsText3(ReportUtil.threeMonthsText3(threeMonthsCases));
-        List<LawCase> threeYearsCases = threeYearsCases();
+        List<LawCase> threeYearsCases = threeYearsCases(creditCode);
         reportModel.setCaseStageText1(ReportUtil.caseStageText1(threeYearsCases));
         reportModel.setLocationText(ReportUtil.locationText(threeYearsCases));
         reportModel.setCaseActionText1(ReportUtil.caseActionText1(threeYearsCases));
@@ -137,21 +147,54 @@ public class LawCaseServiceImpl extends ServiceImpl impl
         reportModel.setHighFrequencyText(ReportUtil.highFrequencyText(threeYearsCases));
         return reportModel;
     }
-
-
+    /**
+     *
+     * 案件信息汇总
+     * @param creditCode
+     * @return void
+     * @author zhangjing
+     * @create 2024/12/24
+     **/
+    private void setAlarmInfo(String creditCode){
+        EnterpriseAlarmInfo data = new EnterpriseAlarmInfo();
+        data.setCreditCode(creditCode);
+        //告警数
+        QueryWrapper<AlarmCase> alarmCaseQueryWrapper = new QueryWrapper<>();
+        alarmCaseQueryWrapper.eq("credit_code", creditCode);
+        data.setAlarmCount(alarmCaseService.count(alarmCaseQueryWrapper));
+        //告警案件金额
+        List<LawCase> alarmCases = baseMapper.queryByAlarmCase(creditCode);
+        data.setAlarmAmount(ReportUtil.getCaseAmount(alarmCases));
+        //近三月案件信息
+        List<LawCase> threeMonths = threeMonthsCases(creditCode,false);
+        data.setThreeMonthsCount(threeMonths.size());
+        data.setThreeMonthsAmount(ReportUtil.getCaseAmount(threeMonths));
+        //近三年案件信息
+        List<LawCase> threeYears = threeYearsCases(creditCode);
+        List<EnterpriseProvince> enterpriseProvinceList = new ArrayList<>();
+        ReportUtil.setAlarmInfo(data, threeYears,enterpriseProvinceList);
+        QueryWrapper<EnterpriseProvince> enterpriseProvinceQueue = new QueryWrapper<>();
+        enterpriseProvinceQueue.eq("credit_code",creditCode);
+        enterpriseProvinceService.remove(enterpriseProvinceQueue);
+        enterpriseProvinceService.saveBatch(enterpriseProvinceList);
+        enterpriseAlarmInfoService.saveOrUpdate(data);
+    }
 
     @Override
     public void judicialModelSave(JSONObject jsonObject) {
-          ReportModel reportModel = createReportData();
-          ReportUtil.createReport(reportModel);
+//        setAlarmInfo("91440300087909371X");
+
+//          ReportModel reportModel = createReportData();
+//          ReportUtil.createReport(reportModel);
 //        String filePath = "司法.txt";
-//        String filePath = "工商.txt";
-//        String jsonOutput = convertTextToJson(filePath);
-//       if (jsonOutput == null) {
-//            logger.error("转换失败，JSON 字符串为空");
-//            return;
-//        }
-//        jsonObject = new JSONObject().parseObject(jsonOutput);
+        String filePath = "工商.txt";
+        String jsonOutput = convertTextToJson(filePath);
+       if (jsonOutput == null) {
+            logger.error("转换失败，JSON 字符串为空");
+            return;
+        }
+        jsonObject = new JSONObject().parseObject(jsonOutput);
+        enterpriseInfoService.industryModelSave(jsonObject);
 //        JSONArray arr = jsonObject.getJSONArray("data");
 //        if (arr == null || arr.isEmpty()) {
 //            logger.error("数据数组为空");
@@ -257,87 +300,27 @@ public class LawCaseServiceImpl extends ServiceImpl impl
         }
     }
 
-
-    // 批量大小
-    private static final int BATCH_SIZE = 20;
-
-
-    private static final int THREAD_COUNT = 1;
     public void saveOrUpdateCases(List<LawCase> entityList) {
         int batchSize=20;
-        int size = entityList.size();  // 总记录数
+        int size = entityList.size();
         for (int i = 0; i < size; i += batchSize) {
-            int toIndex = Math.min(i + batchSize, size);  // 计算当前批次的结束索引
-            List<LawCase> batch = entityList.subList(i, toIndex);  // 提取当前批次的记录
-            // 执行批量插入或更新操作
+            int toIndex = Math.min(i + batchSize, size);
+            List<LawCase> batch = entityList.subList(i, toIndex);
             this.saveOrUpdateBatch(batch);
         }
     }
-//    public void saveOrUpdateCases(List<LawCase> lawCaseList) {
-//        ExecutorService executorService = Executors.newFixedThreadPool(THREAD_COUNT);
-//        AtomicInteger counter = new AtomicInteger(0);
-//
-//        for (int i = 0; i < lawCaseList.size(); i += BATCH_SIZE) {
-//            int start = i;
-//            int end = Math.min(i + BATCH_SIZE, lawCaseList.size());
-//            List<LawCase> batch = lawCaseList.subList(start, end);
-//            int finalCounter = counter.getAndIncrement();
-//            executorService.submit(() -> {
-//                try {
-//                    this.saveOrUpdateBatch(batch, BATCH_SIZE);
-//                } catch (Exception e) {
-//                    // 处理异常
-//                    System.err.println("Error processing batch " + finalCounter + ": " + e.getMessage());
-//                }
-//            });
-//        }
-//        executorService.shutdown();
-//        try {
-//            executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
-//        } catch (InterruptedException e) {
-//            Thread.currentThread().interrupt();
-//            throw new RuntimeException("Interrupted while waiting for tasks to complete", e);
-//        }
-//    }
+
 public void saveOrUpdateLitigantInfo(List<LitigantInfo> entityList) {
     int batchSize=20;
-    int size = entityList.size();  // 总记录数
+    int size = entityList.size();
     for (int i = 0; i < size; i += batchSize) {
-        int toIndex = Math.min(i + batchSize, size);  // 计算当前批次的结束索引
-        List<LitigantInfo> batch = entityList.subList(i, toIndex);  // 提取当前批次的记录
+        int toIndex = Math.min(i + batchSize, size);
+        List<LitigantInfo> batch = entityList.subList(i, toIndex);
         // 执行批量插入或更新操作
         litigantInfoService.saveOrUpdateBatch(batch);
     }
 }
-//    public void saveOrUpdateLitigantInfo(List<LitigantInfo> litigantInfoList) {
-////        QueryWrapper<LitigantInfo> query = new QueryWrapper<LitigantInfo>();
-////        query.eq("n_ajbs", litigantInfoList.get(0).getN_ajbs());
-////        litigantInfoService.remove(query);
-//        ExecutorService executorService = Executors.newFixedThreadPool(THREAD_COUNT);
-//        AtomicInteger counter = new AtomicInteger(0);
-//
-//        for (int i = 0; i < litigantInfoList.size(); i += BATCH_SIZE) {
-//            int start = i;
-//            int end = Math.min(i + BATCH_SIZE, litigantInfoList.size());
-//            List<LitigantInfo> batch = litigantInfoList.subList(start, end);
-//            int finalCounter = counter.getAndIncrement();
-//            executorService.submit(() -> {
-//                try {
-//                    litigantInfoService.saveOrUpdateBatch(batch, BATCH_SIZE);
-//                } catch (Exception e) {
-//                    // 处理异常
-//                    System.err.println("Error processing batch LitigantInfo" + finalCounter + ": " + e.getMessage());
-//                }
-//            });
-//        }
-//        executorService.shutdown();
-//        try {
-//            executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
-//        } catch (InterruptedException e) {
-//            Thread.currentThread().interrupt();
-//            throw new RuntimeException("Interrupted while waiting for tasks to complete", e);
-//        }
-//    }
+
 
     public String convertTextToJson(String filePath) {
         StringBuilder contentBuilder = new StringBuilder();

src/main/resources/mapper/LawCaseMapper.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fkzy.warn.mapper.LawCaseMapper">
+
+    <select id="queryByAlarmCase" resultType="com.fkzy.warn.model.LawCase">
+        select l.*
+        from t_law_case l
+                 join
+             t_alarm_case a
+             on
+                 a.credit_code = #{creditCode}
+                     and a.n_ajbs = l.n_ajbs
+    </select>
+
+</mapper>