账号归属配置 特约

commons/src/main/java/com/jzg/commons/constants/InsuranceRisk.java

@@ -0,0 +1,20 @@
+package com.jzg.commons.constants;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum InsuranceRisk {
+    TRAFFIC("0507", "机动车交通事故责任强制保险", "交强"),
+
+    BUSINESS("0510", "机动车商业保险", "商业"),
+
+    ACCIDENT("0513", "意外险", "非车");
+
+    private final String code;
+
+    private final String desc;
+
+    private final String shortName;
+}

commons/src/main/java/com/jzg/commons/constants/PtlApiType.java

@@ -0,0 +1,17 @@
+package com.jzg.commons.constants;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum PtlApiType {
+
+    API(1, "api对接"),
+    PYTHON(2, "python对接");
+
+    private final int code;
+
+    private final String desc;
+
+}

commons/src/main/java/com/jzg/commons/constants/PtlCrawlerApiType.java

@@ -0,0 +1,25 @@
+package com.jzg.commons.constants;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum PtlCrawlerApiType {
+
+    API_1(1, "归属配置"),
+    API_2(2, "报价"),
+    API_3(3, "影像上传"),
+    API_4(4, "核保"),
+    API_5(5, "缴费查询"),
+    API_6(6, "保单下载"),
+    API_7(7, "非车险查询"),
+    API_8(8, "人工核保状态刷新"),
+    API_9(9, "撤销订单"),
+    API_10(10, "验车码");
+
+    private final int code;
+
+    private final String desc;
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/dto/PtlAttributionTemplateDto.java

@@ -0,0 +1,29 @@
+package com.jzg.commons.entity.agreement.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+@Schema(description = "归属配置模版")
+public class PtlAttributionTemplateDto implements Serializable {
+
+    private static final long serialVersionUID = 1000183859846970741L;
+
+    @Schema(description = "字段")
+    private String field;
+
+    @Schema(description = "标签")
+    private String label;
+
+    @Schema(description = "类型（text 文本框，select 选择框）")
+    private String type;
+
+    @Schema(description = "是否允许修改（true 可修改，false 不可修改）")
+    private Boolean isEdit;
+
+    @Schema(description = "值")
+    private String value;
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/po/PtlCrawlerApi.java

@@ -0,0 +1,72 @@
+package com.jzg.commons.entity.agreement.po;
+
+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.jzg.commons.constants.PtlCrawlerApiType;
+import com.jzg.commons.entity.agreement.vo.PtlCrawlerApiSaveVo;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * python对接接口
+ *
+ * @TableName ptl_crawler_api
+ */
+@TableName(value = "ptl_crawler_api")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PtlCrawlerApi implements Serializable {
+    /**
+     *
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private String id;
+
+    /**
+     * 模板id
+     */
+    @TableField(value = "template_id")
+    private String templateId;
+
+    /**
+     * 1、归属配置；2、报价；3、影像上传；4、核保；5、缴费查询；6、保单下载；7、非车险查询
+     */
+    @TableField(value = "api_type")
+    private Integer apiType;
+
+    /**
+     * api名称
+     */
+    @TableField(value = "api_name")
+    private String apiName;
+
+    /**
+     * 请求路劲
+     */
+    @TableField(value = "url")
+    private String url;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+
+    public static List<PtlCrawlerApi> toPtlCrawlerApiList(String templateId, List<PtlCrawlerApiSaveVo> ptlCrawlerApiSaveVoList) {
+        return ptlCrawlerApiSaveVoList.stream().map(a -> new PtlCrawlerApi(templateId, a)).collect(Collectors.toList());
+    }
+
+    public PtlCrawlerApi(String templateId, PtlCrawlerApiSaveVo ptlCrawlerApiSaveVo) {
+        this.templateId = templateId;
+        this.apiType = ptlCrawlerApiSaveVo.getApiType();
+        this.apiName = Enum.valueOf(PtlCrawlerApiType.class, "API_" + ptlCrawlerApiSaveVo.getApiType()).getDesc();
+        this.url = ptlCrawlerApiSaveVo.getUrl();
+    }
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/po/PtlInsAttributionTemplate.java

@@ -0,0 +1,68 @@
+package com.jzg.commons.entity.agreement.po;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateSaveVo;
+import com.jzg.commons.util.idgen.IdGenerate;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+
+import java.io.Serializable;
+
+/**
+ * 保险公司归属信息模板配置
+ *
+ * @TableName ptl_ins_attribution_template
+ */
+@Data
+@Schema(description = "保险公司归属信息模板配置")
+public class PtlInsAttributionTemplate implements Serializable {
+    /**
+     *
+     */
+    @TableId(value = "id")
+    private String id;
+
+    /**
+     * api类型（1、api对接，2、python对接）
+     */
+    @TableField(value = "api_type")
+    private Integer apiType;
+
+    /**
+     * 保险公司ID
+     */
+    @TableField(value = "ins_company_id")
+    private String insCompanyId;
+
+    /**
+     * 保险公司名称
+     */
+    @TableField(value = "ins_company_name")
+    private String insCompanyName;
+
+    /**
+     * 字段集
+     */
+    @TableField(value = "fields", typeHandler = FastjsonTypeHandler.class)
+    private JSONArray fields;
+
+
+
+    public PtlInsAttributionTemplate(PtlInsAttributionTemplateSaveVo ptlInsAttributionTemplateSaveVo,String esmInsCompanyName) {
+        if(!ptlInsAttributionTemplateSaveVo.getId().equals("")) {
+            this.id = ptlInsAttributionTemplateSaveVo.getId();
+        }else{
+            this.id = IdGenerate.nextId();
+        }
+        this.apiType = ptlInsAttributionTemplateSaveVo.getApiType();
+        this.insCompanyId = ptlInsAttributionTemplateSaveVo.getInsCompanyId();
+        this.insCompanyName = esmInsCompanyName;
+        this.fields = JSON.parseArray(JSON.toJSONString(ptlInsAttributionTemplateSaveVo.getFields()));
+    }
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/vo/PtlCrawlerApiSaveVo.java

@@ -0,0 +1,23 @@
+package com.jzg.commons.entity.agreement.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+@Schema(description = "python对接接口保存信息")
+@AllArgsConstructor
+public class PtlCrawlerApiSaveVo implements Serializable {
+
+    private static final long serialVersionUID = -8746020505828059226L;
+
+    @Schema(description = "1、归属配置；2、报价；3、影像上传；4、核保；5、缴费查询；6、保单下载；7、非车险查询；8、人工核保状态刷新；9、撤销订单")
+    private Integer apiType;
+
+    @Schema(description = "url")
+    private String url;
+
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/vo/PtlInsAttributionTemplateQueryVo.java

@@ -0,0 +1,21 @@
+package com.jzg.commons.entity.agreement.vo;
+
+import com.jzg.commons.core.base.PageRequest;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+public class PtlInsAttributionTemplateQueryVo extends PageRequest {
+
+    @Schema(description = "保险公司id")
+    private String companyId;
+
+    @Schema(description = "id")
+    private String id;
+
+    @Schema(description = "类型")
+    private String apiType;
+
+    @Schema(description = "字段信息")
+    private PtlInsAttributionTemplateVo.Field field;
+}

commons/src/main/java/com/jzg/commons/entity/agreement/vo/PtlInsAttributionTemplateSaveVo.java

@@ -0,0 +1,92 @@
+package com.jzg.commons.entity.agreement.vo;
+
+import com.jzg.commons.constants.PtlApiType;
+import com.jzg.commons.core.base.PageRequest;
+import com.jzg.commons.entity.agreement.dto.PtlAttributionTemplateDto;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PtlInsAttributionTemplateSaveVo{
+
+    @Schema(description = "id")
+    private String id;
+
+    @Schema(description = "api类型")
+    private Integer apiType;
+
+    @Schema(description = "保险公司ID")
+    private String insCompanyId;
+
+    @Schema(description = "字段集")
+    private List<PtlAttributionTemplateDto> fields;
+
+    @Schema(description = "归属配置")
+    private String attributionConfig;
+
+    @Schema(description = "报价")
+    private String quotation;
+
+    @Schema(description = "影像上传")
+    private String imageUpload;
+
+    @Schema(description = "核保")
+    private String insurance;
+
+    @Schema(description = "缴费查询")
+    private String paymentQuery;
+
+    @Schema(description = "保单下载")
+    private String policyDownload;
+
+    @Schema(description = "非车险查询")
+    private String nonCarInsurance;
+
+    @Schema(description = "人工核保状态刷新")
+    private String manualStatusRefresh;
+
+    @Schema(description = "撤销订单")
+    private String revokeOrder;
+
+    @Schema(description = "api类型为2（python）必传")
+    private List<PtlCrawlerApiSaveVo> api;
+
+    /**
+     * 将python的连接 转换到api内
+     */
+    public void converApi(){
+        if(this.apiType == PtlApiType.PYTHON.getCode()){
+            if(this.attributionConfig!=null && !"".equals(this.attributionConfig)){
+                this.api.add(new PtlCrawlerApiSaveVo(1,this.attributionConfig));
+            }
+            if(this.quotation!=null &&!"".equals(this.quotation)){
+                this.api.add(new PtlCrawlerApiSaveVo(2,this.quotation));
+            }
+            if(this.imageUpload!=null &&!"".equals(this.imageUpload)){
+                this.api.add(new PtlCrawlerApiSaveVo(3,this.imageUpload));
+            }
+            if(this.insurance!=null &&!"".equals(this.insurance)){
+                this.api.add(new PtlCrawlerApiSaveVo(4,this.insurance));
+            }
+            if(this.paymentQuery!=null &&!"".equals(this.paymentQuery)){
+                this.api.add(new PtlCrawlerApiSaveVo(5,this.paymentQuery));
+            }
+            if(this.policyDownload!=null &&!"".equals(this.policyDownload)){
+                this.api.add(new PtlCrawlerApiSaveVo(6,this.policyDownload));
+            }
+            if(this.nonCarInsurance!=null &&!"".equals(this.nonCarInsurance)){
+                this.api.add(new PtlCrawlerApiSaveVo(7,this.nonCarInsurance));
+            }
+            if(this.manualStatusRefresh!=null &&!"".equals(this.manualStatusRefresh)){
+                this.api.add(new PtlCrawlerApiSaveVo(8,this.manualStatusRefresh));
+            }
+            if(this.revokeOrder!=null &&!"".equals(this.revokeOrder)){
+                this.api.add(new PtlCrawlerApiSaveVo(9,this.revokeOrder));
+            }
+        }
+    }
+
+}

commons/src/main/java/com/jzg/commons/entity/agreement/vo/PtlInsAttributionTemplateVo.java

@@ -0,0 +1,76 @@
+package com.jzg.commons.entity.agreement.vo;
+
+import com.alibaba.fastjson.JSONObject;
+import com.jzg.commons.core.base.PageRequest;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Data
+public class PtlInsAttributionTemplateVo extends PageRequest {
+
+    /**
+     *
+     */
+    private String id;
+
+    /**
+     * api类型（1、api对接，2、python对接）
+     */
+    private Integer apiType;
+
+    /**
+     * 保险公司ID
+     */
+    private String insCompanyId;
+
+    /**
+     * 保险公司名称
+     */
+    private String insCompanyName;
+
+    /**
+     * 字段集
+     */
+    private List<Field> fields;
+
+    @Data
+    public static class Field{
+        @Schema(description = "字段类型")
+        private String type;
+
+        @Schema(description = "字段")
+        private String field;
+
+        @Schema(description = "字段名称")
+        private String label;
+
+        @Schema(description = "默认值")
+        private String value;
+
+        @Schema(description = "是否可编辑")
+        private String isEdit;
+    }
+
+    public static List<PtlInsAttributionTemplateVo> convert(List<PtlInsAttributionTemplate> list){
+        List<PtlInsAttributionTemplateVo> vos = new ArrayList<>();
+        list.forEach(ptlInsAttributionTemplate -> {
+            PtlInsAttributionTemplateVo vo = new PtlInsAttributionTemplateVo();
+            vo.setId(ptlInsAttributionTemplate.getId());
+            vo.setApiType(ptlInsAttributionTemplate.getApiType());
+            vo.setInsCompanyId(ptlInsAttributionTemplate.getInsCompanyId());
+            vo.setInsCompanyName(ptlInsAttributionTemplate.getInsCompanyName());
+            List<Field> fields = new ArrayList<>();
+            ptlInsAttributionTemplate.getFields().forEach(field->{
+                fields.add(JSONObject.parseObject(field.toString(), Field.class));
+            });
+            vo.setFields(fields);
+            vos.add(vo);
+        });
+        return vos;
+    }
+
+}

commons/src/main/java/com/jzg/commons/entity/dto/SysOrganizationParam.java

@@ -16,6 +16,9 @@ public class SysOrganizationParam extends PageRequest {
     @Schema(description = "搜索参数 输入姓名，手机号，工号查找")
     private String param;
 
+    @Schema(description = "队伍类型")
+    private String attribute;
+
 
 
 

commons/src/main/java/com/jzg/commons/entity/po/InsCompanyClause.java

@@ -0,0 +1,34 @@
+package com.jzg.commons.entity.po;
+
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.jzg.commons.core.base.BaseModel;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+@Schema(description = "特约条款")
+public class InsCompanyClause extends BaseModel {
+
+    @TableId(value = "id")
+    @Schema(description = "主键")
+    private String id;
+
+    @Schema(description = "险种code")
+    private String riskCode;
+
+    @Schema(description = "保险公司id")
+    private String companyId;
+
+    @Schema(description = "条款名称")
+    private String clauseName;
+
+    @Schema(description = "条款code")
+    private String clauseCode;
+
+    @Schema(description = "条款内容")
+    private String clauseContent;
+
+
+}

commons/src/main/java/com/jzg/commons/entity/vo/CompanyClauseVo.java

@@ -0,0 +1,22 @@
+package com.jzg.commons.entity.vo;
+
+import com.jzg.commons.core.base.PageRequest;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+public class CompanyClauseVo extends PageRequest {
+
+    @Schema(description = "保险公司id")
+    private String companyId;
+
+    @Schema(description = "险种信息")
+    private String riskCode;
+
+    @Schema(description = "条款名称")
+    private String clauseName;
+
+    @Schema(description = "条款内容")
+    private String clauseContent;
+
+}

commons/src/main/java/com/jzg/commons/entity/vo/SysOrganizationUserLinkQueryVo.java

@@ -6,4 +6,6 @@ import lombok.Data;
 @Data
 public class SysOrganizationUserLinkQueryVo extends PageRequest {
     private String id;
+
+    private String name;
 }

commons/src/main/java/com/jzg/commons/entity/vo/SysOrganizationUserLinkVo.java

@@ -8,10 +8,11 @@ public class SysOrganizationUserLinkVo{
     private String id;
     private String userId;
     private String mobile;
-    private String uname;
     private String type;
     private String deptId;
     private String deptName;
     private String status;
     private String accountStatus;
+    private String isEnable;
+    private String manager;
 }

commons/src/main/java/com/jzg/commons/exception/SystemException.java

@@ -15,10 +15,10 @@ public class SystemException extends RuntimeException {
         this.code = code;
     }
 
-    public SystemException(String code, String message, Throwable cause) {
-        super(message, cause);
-        this.code = code;
-    }
+//    public SystemException(String code, Throwable cause) {
+//        super(message, cause);
+//        this.code = code;
+//    }
 
     public String getCode() {
         return code;

platform/pom.xml

@@ -5,12 +5,27 @@
         <groupId>com.jzg</groupId>
         <artifactId>jzg</artifactId>
         <version>1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
     </parent>
     <artifactId>platform</artifactId>
     <packaging>jar</packaging>
     <name>platform Maven Webapp</name>
     <url>http://maven.apache.org</url>
     <dependencies>
+        <!-- sleuth服务追踪的启动依赖-->
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.cloud</groupId>-->
+<!--            <artifactId>spring-cloud-starter-sleuth</artifactId>-->
+<!--            <version>3.0.0</version>-->
+<!--        </dependency>-->
+
+<!--        &lt;!&ndash; zipkin服务追踪的启动依赖&ndash;&gt;-->
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.cloud</groupId>-->
+<!--            <artifactId>spring-cloud-starter-zipkin</artifactId>-->
+<!--            <version>2.2.8.RELEASE</version>-->
+<!--        </dependency>-->
+
 
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -69,6 +84,11 @@
         </dependency>
     </dependencies>
     <build>
-        <finalName>platform</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
     </build>
 </project>

platform/src/main/java/com/jzg/PlatFormApplication.java

@@ -8,12 +8,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @SpringBootApplication
 public class PlatFormApplication {
     public static void main(String[] args) {
-//        /*
-//         * 指定使用的日志框架，否则将会告警
-//         * RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.InternalThreadLocalMap).
-//         * RocketMQLog:WARN Please initialize the logger system properly.
-//         */
-//        System.setProperty("rocketmq.client.logUseSlf4j", "true");
         SpringApplication.run(PlatFormApplication.class, args);
     }
 

platform/src/main/java/com/jzg/controller/ClauseController.java

@@ -0,0 +1,65 @@
+package com.jzg.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.jzg.commons.core.page.HttpResult;
+import com.jzg.commons.entity.po.InsCompanyClause;
+import com.jzg.commons.entity.vo.CompanyClauseVo;
+import com.jzg.service.InsCompanyClauseService;
+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;
+
+/**
+ * 特别约定管理
+ */
+@RestController
+@RequestMapping("/manager/clause")
+public class ClauseController {
+
+    @Autowired
+    private InsCompanyClauseService insCompanyClauseService;
+
+    /**
+     * 特别约定分页
+     * @param companyClauseVo
+     * @return
+     */
+    @PostMapping(value = "getClausePage")
+    public HttpResult<Page<InsCompanyClause>> getClausePage(@RequestBody CompanyClauseVo companyClauseVo){
+        Page page = companyClauseVo.getPage();
+        return HttpResult.ok(insCompanyClauseService.getClausePage(page,companyClauseVo));
+    }
+
+    /**
+     * 添加特别约定
+     * @param insCompanyClause
+     * @return
+     */
+    @PostMapping(value = "addClause")
+    public HttpResult addClause(@RequestBody InsCompanyClause insCompanyClause){
+        return insCompanyClauseService.addClause(insCompanyClause)? HttpResult.ok("添加特约成功") : HttpResult.error("添加特约失败");
+    }
+
+    /**
+     * 修改特别约定
+     * @param insCompanyClause
+     * @return
+     */
+    @PostMapping(value = "updateClause")
+    public HttpResult updateClause(@RequestBody InsCompanyClause insCompanyClause){
+        return insCompanyClauseService.updateClause(insCompanyClause)? HttpResult.ok("修改特约成功") : HttpResult.error("修改特约失败");
+    }
+
+    /**
+     * 删除特别约定
+     * @param insCompanyClause
+     * @return
+     */
+    @PostMapping(value = "deleteClause")
+    public HttpResult deleteClause(@RequestBody InsCompanyClause insCompanyClause){
+        return insCompanyClauseService.removeById(insCompanyClause.getId())? HttpResult.ok("删除特约成功") : HttpResult.error("删除特约失败");
+    }
+
+}

platform/src/main/java/com/jzg/controller/FileUploadController.java

@@ -44,8 +44,10 @@ public class FileUploadController extends BaseController {
     @PostMapping("/upload")
     @Operation(summary = "文件上传接口", description = "文件上传接口")
     public HttpResult uploadFile(@RequestParam("file") MultipartFile file) {
+        System.out.printf("调用文件上传接口");
         try {
             // 获取文件原始名称和扩展名
+            System.out.printf("1111111111111");
             String originalFileName = file.getOriginalFilename();
             String extension = getFileExtension(originalFileName);
 
@@ -54,17 +56,20 @@ public class FileUploadController extends BaseController {
             String objectName = generateObjectName(originalFileName, fileMD5, extension);
             String fileETag = FileUtils.getFileETag(file);
 
+            System.out.printf("22222222222222222");
             // 查找文件是否已经存在于MinIO
             if (isFileExistsInMinIO(objectName, fileETag)) {
                 return HttpResult.ok(getFileFromDatabase(fileETag,objectName, extension));
             }
 
+            System.out.printf("333333333333333333333");
             //如果文件不存在，执行上传操作
             SysUploadFiles sysUploadFiles = uploadFileToMinIO(file, objectName, fileETag, extension);
-
+            System.out.printf("444444444444444444444444444");
             return HttpResult.ok(sysUploadFiles);
         } catch (Exception e) {
             e.printStackTrace();
+            System.out.printf("eeeeeeeeeeeeeeeeeeeeeeeeee");
             return HttpResult.error("文件上传失败: " + e.getMessage());
         }
     }

platform/src/main/java/com/jzg/controller/UserRoleController.java

@@ -11,7 +11,6 @@ import com.jzg.commons.util.StringUtils;
 import com.jzg.service.UserRoleService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
-import okhttp3.internal.platform.Platform;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;

platform/src/main/java/com/jzg/mapper/InsCompanyClauseMapper.java

@@ -0,0 +1,25 @@
+package com.jzg.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.jzg.commons.entity.dto.SysUserParam;
+import com.jzg.commons.entity.po.InsCompanyClause;
+import com.jzg.commons.entity.po.SysUser;
+import com.jzg.commons.entity.vo.SysUserVo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+* @author dongxin
+* @description 针对表【ins_company_clause】的数据库操作Mapper
+* @createDate 2025-01-13 10:53:51
+* @Entity generator.domain.SysUser
+*/
+@Mapper
+public interface InsCompanyClauseMapper extends BaseMapper<InsCompanyClause> {
+
+}
+
+
+
+

platform/src/main/java/com/jzg/mapper/PtlCrawlerApiMapper.java

@@ -0,0 +1,10 @@
+package com.jzg.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.jzg.commons.entity.agreement.po.PtlCrawlerApi;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface PtlCrawlerApiMapper extends BaseMapper<PtlCrawlerApi> {
+}

platform/src/main/java/com/jzg/mapper/PtlInsAttributionTemplateMapper.java

@@ -0,0 +1,9 @@
+package com.jzg.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface PtlInsAttributionTemplateMapper extends BaseMapper<PtlInsAttributionTemplate> {
+}

platform/src/main/java/com/jzg/service/InsCompanyClauseService.java

@@ -0,0 +1,46 @@
+package com.jzg.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.jzg.commons.entity.dto.SysUserAddParam;
+import com.jzg.commons.entity.dto.SysUserEditParam;
+import com.jzg.commons.entity.dto.SysUserParam;
+import com.jzg.commons.entity.po.InsCompanyClause;
+import com.jzg.commons.entity.po.SysUser;
+import com.jzg.commons.entity.vo.CompanyClauseVo;
+import com.jzg.commons.entity.vo.SysUserVo;
+import com.jzg.commons.entity.vo.UpAndDownVo;
+
+import java.util.List;
+
+/**
+* @author dongxin
+* @description 针对表【InsCompanyClause】的数据库操作Service
+* @createDate 2025-01-13 10:53:51
+*/
+public interface InsCompanyClauseService extends IService<InsCompanyClause> {
+
+    /**
+     * 特别约定分页
+     * @param page
+     * @param companyClauseVo
+     * @return
+     */
+    public Page<InsCompanyClause> getClausePage(Page page, CompanyClauseVo companyClauseVo);
+
+    /**
+     * 添加特别约定
+     * @param insCompanyClause
+     * @return
+     */
+    public boolean addClause(InsCompanyClause insCompanyClause);
+
+
+    /**
+     * 修改特别约定
+     * @param insCompanyClause
+     * @return
+     */
+    public boolean updateClause(InsCompanyClause insCompanyClause);
+
+}

platform/src/main/java/com/jzg/service/PtlCrawlerApiService.java

@@ -0,0 +1,19 @@
+package com.jzg.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.jzg.commons.entity.agreement.po.PtlCrawlerApi;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateQueryVo;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateSaveVo;
+
+import java.util.List;
+
+/**
+* @author
+* @description 针对表【PtlInsAttributionTemplateService】的数据库操作Service
+* @createDate 2025-01-13 10:53:51
+*/
+public interface PtlCrawlerApiService extends IService<PtlCrawlerApi> {
+
+}

platform/src/main/java/com/jzg/service/PtlInsAttributionTemplateService.java

@@ -0,0 +1,33 @@
+package com.jzg.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateQueryVo;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateSaveVo;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateVo;
+
+import java.util.List;
+
+/**
+* @author
+* @description 针对表【PtlInsAttributionTemplateService】的数据库操作Service
+* @createDate 2025-01-13 10:53:51
+*/
+public interface PtlInsAttributionTemplateService extends IService<PtlInsAttributionTemplate> {
+
+    /**
+     * 分页查询
+     * @param page
+     * @param ptlInsAttributionTemplateVo
+     * @return
+     */
+    public List<PtlInsAttributionTemplate> getList(PtlInsAttributionTemplateQueryVo ptlInsAttributionTemplateVo);
+
+    /**
+     * 保存 保险公司归属信息模版
+     * @param ptlInsAttributionTemplateSaveVo
+     * @return
+     */
+    public boolean submit(List<PtlInsAttributionTemplateSaveVo> ptlInsAttributionTemplateSaveVo);
+}

platform/src/main/java/com/jzg/service/impl/InsCompanyClauseServiceImpl.java

@@ -0,0 +1,71 @@
+package com.jzg.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.jzg.commons.entity.po.InsCompanyClause;
+import com.jzg.commons.entity.vo.CompanyClauseVo;
+import com.jzg.commons.exception.ValidateException;
+import com.jzg.mapper.InsCompanyClauseMapper;
+import com.jzg.service.InsCompanyClauseService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class InsCompanyClauseServiceImpl extends ServiceImpl<InsCompanyClauseMapper, InsCompanyClause> implements InsCompanyClauseService {
+
+    @Override
+    public Page<InsCompanyClause> getClausePage(Page page, CompanyClauseVo companyClauseVo) {
+        LambdaQueryWrapper wrapper = new LambdaQueryWrapper<InsCompanyClause>()
+                .eq(!companyClauseVo.getCompanyId().equals(""),InsCompanyClause::getCompanyId,companyClauseVo.getCompanyId())
+                .eq(!companyClauseVo.getRiskCode().equals(""),InsCompanyClause::getRiskCode,companyClauseVo.getRiskCode())
+                .like(!companyClauseVo.getClauseName().equals(""),InsCompanyClause::getClauseName,companyClauseVo.getClauseName())
+                .like(!companyClauseVo.getClauseContent().equals(""),InsCompanyClause::getClauseContent,companyClauseVo.getClauseContent());
+        return baseMapper.selectPage(page, wrapper);
+    }
+
+    @Override
+    public boolean addClause(InsCompanyClause insCompanyClause) {
+        //查询是否有相同的特约名称
+        LambdaQueryWrapper wrapper = new LambdaQueryWrapper<InsCompanyClause>()
+                .eq(InsCompanyClause::getCompanyId,insCompanyClause.getCompanyId())
+                .eq(InsCompanyClause::getClauseName,insCompanyClause.getClauseName());
+        InsCompanyClause queryClause = baseMapper.selectOne(wrapper);
+        if(queryClause != null){
+            throw new ValidateException("已存在特约名称,请重新输入");
+        }
+        //查询是否有相同的特约code
+        LambdaQueryWrapper wrapper1 = new LambdaQueryWrapper<InsCompanyClause>()
+               .eq(InsCompanyClause::getCompanyId,insCompanyClause.getCompanyId())
+               .eq(InsCompanyClause::getClauseCode,insCompanyClause.getClauseCode());
+        InsCompanyClause quoeryClauseCode = baseMapper.selectOne(wrapper1);
+        if(quoeryClauseCode!= null){
+            throw new ValidateException("已存在特约code,请重新输入");
+        }
+
+        return save(insCompanyClause);
+    }
+
+    @Override
+    public boolean updateClause(InsCompanyClause insCompanyClause) {
+        //查询是否有相同的特约名称
+        LambdaQueryWrapper wrapper = new LambdaQueryWrapper<InsCompanyClause>()
+                .eq(InsCompanyClause::getCompanyId,insCompanyClause.getCompanyId())
+                .eq(InsCompanyClause::getClauseName,insCompanyClause.getClauseName())
+                .ne(InsCompanyClause::getId,insCompanyClause.getId());
+        InsCompanyClause queryClause = baseMapper.selectOne(wrapper);
+        if(queryClause != null){
+            throw new ValidateException("已存在特约名称,请重新输入");
+        }
+        //查询是否有相同的特约code
+        LambdaQueryWrapper wrapper1 = new LambdaQueryWrapper<InsCompanyClause>()
+                .eq(InsCompanyClause::getCompanyId,insCompanyClause.getCompanyId())
+                .eq(InsCompanyClause::getClauseCode,insCompanyClause.getClauseCode())
+                .ne(InsCompanyClause::getId,insCompanyClause.getId());
+        InsCompanyClause quoeryClauseCode = baseMapper.selectOne(wrapper1);
+        if(quoeryClauseCode!= null){
+            throw new ValidateException("已存在特约code,请重新输入");
+        }
+
+        return updateById(insCompanyClause);
+    }
+}

platform/src/main/java/com/jzg/service/impl/PtlCrawlerApiServiceImpl.java

@@ -0,0 +1,12 @@
+package com.jzg.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.jzg.commons.entity.agreement.po.PtlCrawlerApi;
+import com.jzg.mapper.PtlCrawlerApiMapper;
+import com.jzg.service.PtlCrawlerApiService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class PtlCrawlerApiServiceImpl extends ServiceImpl<PtlCrawlerApiMapper, PtlCrawlerApi> implements PtlCrawlerApiService {
+
+}

platform/src/main/java/com/jzg/service/impl/PtlInsAttributionTemplateServiceImpl.java

@@ -0,0 +1,80 @@
+package com.jzg.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.jzg.commons.constants.PtlApiType;
+import com.jzg.commons.entity.agreement.po.PtlCrawlerApi;
+import com.jzg.commons.entity.agreement.po.PtlInsAttributionTemplate;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateQueryVo;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateSaveVo;
+import com.jzg.commons.entity.agreement.vo.PtlInsAttributionTemplateVo;
+import com.jzg.commons.entity.po.EsmInsCompany;
+import com.jzg.commons.exception.ValidateException;
+import com.jzg.commons.util.AssertionUtils;
+import com.jzg.mapper.PtlInsAttributionTemplateMapper;
+import com.jzg.service.PtlCrawlerApiService;
+import com.jzg.service.EsmInsCompanyService;
+import com.jzg.service.PtlInsAttributionTemplateService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Service
+public class PtlInsAttributionTemplateServiceImpl extends ServiceImpl<PtlInsAttributionTemplateMapper, PtlInsAttributionTemplate> implements PtlInsAttributionTemplateService {
+
+    @Autowired
+    EsmInsCompanyService esmInsCompanyService;
+
+    @Autowired
+    PtlCrawlerApiService ptlCrawlerApiService;
+
+    @Override
+    public List<PtlInsAttributionTemplate> getList(PtlInsAttributionTemplateQueryVo ptlInsAttributionTemplateVo) {
+        LambdaQueryWrapper<PtlInsAttributionTemplate> wrapper = new LambdaQueryWrapper<PtlInsAttributionTemplate>()
+                .eq(PtlInsAttributionTemplate::getInsCompanyId,ptlInsAttributionTemplateVo.getCompanyId());
+        List<PtlInsAttributionTemplate> list = baseMapper.selectList(wrapper);
+        List<PtlInsAttributionTemplateVo> ptlInsAttributionTemplateVos = PtlInsAttributionTemplateVo.convert(list);
+        list.forEach(ptlInsAttributionTemplate -> {
+
+        });
+        return list;
+    }
+
+    @Override
+    @Transactional
+    public boolean submit(List<PtlInsAttributionTemplateSaveVo> ptlInsAttributionTemplateSaveVo) {
+        // 一个保险公司，一种api方式只能配置一种
+        ptlInsAttributionTemplateSaveVo.forEach(this::validate);
+
+        ptlInsAttributionTemplateSaveVo.forEach(saveVo -> {
+            EsmInsCompany esmInsCompany = esmInsCompanyService.isExists(saveVo.getInsCompanyId());
+            PtlInsAttributionTemplate ptlInsAttributionTemplate = new PtlInsAttributionTemplate(saveVo, esmInsCompany.getCnName());
+            baseMapper.insert(ptlInsAttributionTemplate);
+
+            // 保存请求链接
+            if (PtlApiType.PYTHON.getCode() == saveVo.getApiType()) {
+                //先删除配置
+                ptlCrawlerApiService.remove(new LambdaQueryWrapper<PtlCrawlerApi>()
+                        .eq(PtlCrawlerApi::getTemplateId, ptlInsAttributionTemplate.getId()));
+                List<PtlCrawlerApi> ptlCrawlerApiList = PtlCrawlerApi.toPtlCrawlerApiList(ptlInsAttributionTemplate.getId(), saveVo.getApi());
+                //增加配置
+                boolean b = ptlCrawlerApiService.saveBatch(ptlCrawlerApiList);
+                AssertionUtils.isSucceed(b, "保险公司api请求插入失败");
+            }
+        });
+
+        return true;
+    }
+
+    private void validate(PtlInsAttributionTemplateSaveVo ptlInsAttributionTemplateSaveVo){
+        LambdaQueryWrapper<PtlInsAttributionTemplate> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(PtlInsAttributionTemplate::getInsCompanyId, ptlInsAttributionTemplateSaveVo.getInsCompanyId())
+                .eq(PtlInsAttributionTemplate::getApiType, ptlInsAttributionTemplateSaveVo.getApiType());
+        List<PtlInsAttributionTemplate> ptlInsAttributionTemplates = baseMapper.selectList(wrapper);
+        if(!ptlInsAttributionTemplates.isEmpty()){
+            throw new ValidateException("一个保险公司，一种api方式只能配置一种");
+        }
+    }
+}

platform/src/main/java/com/jzg/service/impl/SysSystemServiceImpl.java

@@ -20,8 +20,8 @@ import com.jzg.commons.exception.SystemException;
 import com.jzg.commons.util.MinioUtils;
 import com.jzg.commons.util.StringUtils;
 import com.jzg.mapper.*;
-import com.jzg.service.SysAreaBService;
 import com.jzg.service.SysSystemService;
+import com.jzg.service.SysAreaBService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -31,7 +31,6 @@ import org.springframework.transaction.annotation.Transactional;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 import java.util.stream.Collectors;
 
 /**

platform/src/main/java/com/jzg/service/impl/SysUserServiceImpl.java

@@ -14,7 +14,10 @@ import com.jzg.commons.entity.po.*;
 import com.jzg.commons.entity.vo.SysUserVo;
 import com.jzg.commons.entity.vo.UpAndDownVo;
 import com.jzg.commons.util.StringUtils;
-import com.jzg.mapper.*;
+import com.jzg.mapper.SysUserMapper;
+import com.jzg.mapper.SysUserRoleMapper;
+import com.jzg.mapper.SysRoleMapper;
+import com.jzg.mapper.SysUserPlateInfoMapper;
 import com.jzg.service.SysUserService;
 import com.jzg.commons.util.PasswordUtils;
 import org.springframework.beans.BeanUtils;

platform/src/main/java/com/jzg/service/impl/UserRoleServiceImpl.java

@@ -150,13 +150,17 @@ public class UserRoleServiceImpl extends ServiceImpl<SysRoleMapper, SysRole> imp
             sysRoleDataScopeMapper.insert(sysRoleDataScope);
             if (sysRoleDataScope.getDataMark().equals("2") || sysRoleDataScope.getDataMark().equals("1")) {
                 List<SysRoleDataScopeLink> sysRoleDataScopeLinks = new ArrayList<>();
-                sysRoleVo.getDataScope().getDeptIds().forEach(item -> {
-                    SysRoleDataScopeLink sysRoleDataScopeLink = new SysRoleDataScopeLink();
-                    sysRoleDataScopeLink.setId(IdGenerate.nextId());
-                    sysRoleDataScopeLink.setRoleId(sysRole.getId());
-                    sysRoleDataScopeLink.setDeptId(item);
-                    sysRoleDataScopeLinks.add(sysRoleDataScopeLink);
-                });
+                if(!Objects.isNull(sysRoleVo.getDataScope().getDeptIds())) {
+                    if (!sysRoleVo.getDataScope().getDeptIds().isEmpty()) {
+                        sysRoleVo.getDataScope().getDeptIds().forEach(item -> {
+                            SysRoleDataScopeLink sysRoleDataScopeLink = new SysRoleDataScopeLink();
+                            sysRoleDataScopeLink.setId(IdGenerate.nextId());
+                            sysRoleDataScopeLink.setRoleId(sysRole.getId());
+                            sysRoleDataScopeLink.setDeptId(item);
+                            sysRoleDataScopeLinks.add(sysRoleDataScopeLink);
+                        });
+                    }
+                }
                 sysRoleDataScopeLinkMapper.insert(sysRoleDataScopeLinks);
             }
         }

platform/src/main/resources/application.yml

@@ -1,11 +1,16 @@
 server:
   port: 8083
 spring:
+
+#  zipkin:
+#    base-url: http://192.168.0.250:9411
+#  sleuth:
+#    sampler:
+#      probability: 1.0
   redis:
     redisson:
       address: redis://192.168.0.250:6379
       password: 123456
-      database: 0
   servlet:
     multipart:
       max-file-size: 5MB
@@ -46,15 +51,19 @@ tenant:
     - sys_upload_files
     - sys_role_data_scope
     - sys_role_data_scope_link
+    - sys_area
 
   ignoreLoginNames:
 
+  ignoreFunction:
+    - /userInfo/getUser
+
 data-scope:
   ignoreTables:
 
 minio:
-  url: http://192.168.0.250:9000
-  access-key: v7Zb8XhyLcYNcSHlxvyK
-  secret-key: 58YibMwpxGKtXcekPL065OM4GonC1hf2tFMjI9EN
+  url: http://test-api.baoxianzhanggui.com
+  access-key: N8hf40VDM3Uf2xJ5vnvE
+  secret-key: CDe1raroqIMo5R2KhHl6ZQbJOhdq0mrtCI78g3vq
   bucket-name: jzg
 

platform/src/main/resources/logback-spring.xml

@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <!-- 定义 Graylog GELF appender -->
+<!--    <appender name="GELF" class="de.siegmar.logbackgelf.GelfUdpAppender">-->
+<!--        &lt;!&ndash; Graylog server 的主机名或 IP 地址 &ndash;&gt;-->
+<!--        <graylogHost>192.168.0.250</graylogHost>-->
+<!--        &lt;!&ndash; Graylog 服务器端口，通常为 12201（UDP）或 12202（TCP） &ndash;&gt;-->
+<!--        <graylogPort>12201</graylogPort>-->
+<!--        &lt;!&ndash; 可选项：指定协议，默认使用 UDP &ndash;&gt;-->
+<!--        <transport>UDP</transport>-->
+<!--        &lt;!&ndash; 发送日志时是否压缩 &ndash;&gt;-->
+<!--        <compress>true</compress>-->
+<!--        &lt;!&ndash; 是否在 GELF 消息中加入时间戳 &ndash;&gt;-->
+<!--        <includeTimestamp>true</includeTimestamp>-->
+<!--        &lt;!&ndash; 日志内容最大字节数 &ndash;&gt;-->
+<!--        <maxMessageSize>32768</maxMessageSize>-->
+<!--        &lt;!&ndash; 设置自定义字段 &ndash;&gt;-->
+<!--        <additionalFields>-->
+<!--        </additionalFields>-->
+<!--    </appender>-->
+
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+
+    <root level="INFO">
+        <appender-ref ref="STDOUT"/>
+    </root>
+<!--    <root name="com.jzg" level="DEBUG">-->
+<!--        <appender-ref ref="GELF"/>-->
+<!--    </root>-->
+</configuration>