项目归集前置机测试数据保存

pom.xml

@@ -209,5 +209,6 @@
     <modules>
         <module>pmapi</module>
         <module>ningda-generator</module>
+        <module>syn-data-task</module>
     </modules>
 </project>

syn-data-task/pom.xml

@@ -0,0 +1,210 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>project-management</artifactId>
+        <groupId>com.ningdatech</groupId>
+        <version>1.0.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>syn-data-task</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.8.5</version>
+        </dependency>
+        <!-- mysql -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <!--lombok-->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <!-- mybatis plus-->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-freemarker</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.tomcat.embed</groupId>
+            <artifactId>tomcat-embed-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+        <!--实现springboot的热加载-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <optional>true</optional>
+            <scope>true</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+        <!--cache-->
+        <dependency>
+            <groupId>com.github.ben-manes.caffeine</groupId>
+            <artifactId>caffeine</artifactId>
+        </dependency>
+
+        <!--引入jwt-->
+        <dependency>
+            <groupId>com.auth0</groupId>
+            <artifactId>java-jwt</artifactId>
+            <version>3.10.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.ningdatech</groupId>
+            <artifactId>nd-log-starter</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.ningdatech</groupId>
+            <artifactId>nd-basic</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>com.ningdatech</groupId>
+            <artifactId>nd-swagger2-starter</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+    </dependencies>
+
+    <!-- 打包 -->
+    <!--配置环境的profile-->
+    <profiles>
+        <profile>
+            <id>dev</id>
+            <properties>
+                <!--使用${environment}获取值-->
+                <environment>dev</environment>
+            </properties>
+        </profile>
+        <profile>
+            <id>test</id>
+            <properties>
+                <environment>test</environment>
+            </properties>
+        </profile>
+        <profile>
+            <id>pre</id>
+            <properties>
+                <environment>pre</environment>
+            </properties>
+        </profile>
+        <profile>
+            <id>prod</id>
+            <properties>
+                <environment>prod</environment>
+            </properties>
+        </profile>
+    </profiles>
+
+    <build>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <includes>
+                    <include>**/*</include>
+                </includes>
+            </resource>
+            <resource>
+                <directory>src/main/java</directory>
+                <includes>
+                    <include>**/*.xml</include>
+                </includes>
+            </resource>
+            <resource>
+                <directory>src/main/lib</directory>
+                <targetPath>BOOT-INF/lib/</targetPath>
+                <includes>
+                    <include>**/*.jar</include>
+                </includes>
+            </resource>
+            <resource>
+                <directory>src/main/resources</directory>
+                <targetPath>BOOT-INF/classes/</targetPath>
+            </resource>
+        </resources>
+        <finalName>${project.artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.6.8</version>
+                <configuration>
+                    <includeSystemScope>true</includeSystemScope>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <!-- 跳过单元测试 -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <configuration>
+                    <skipTests>true</skipTests>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>

syn-data-task/src/main/java/com/ningdatech/syndataapi/SynDataTaskApp.java

@@ -0,0 +1,29 @@
+package com.ningdatech.syndataapi;
+
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+/**
+ * @author CMM
+ * @since 2023/08/22 18:14
+ */
+@SpringBootApplication
+@EnableAsync
+@MapperScan(SynDataTaskApp.MAPPER_PACKAGES)
+@EnableScheduling
+@EnableTransactionManagement
+@EnableAspectJAutoProxy(exposeProxy = true)
+public class SynDataTaskApp {
+
+    protected static final String MAPPER_PACKAGES = "com.ningdatech.syndataapi.**.mapper";
+
+    public static void main(String[] args) {
+        SpringApplication.run(SynDataTaskApp.class, args);
+    }
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectApplyMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApply;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 项目申报信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectApplyMapper extends BaseMapper<ProjectApply> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectApplyMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectApplyMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectApproveMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApprove;
+
+/**
+ * <p>
+ * 项目立项评审信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectApproveMapper extends BaseMapper<ProjectApprove> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectApproveMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectApproveMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectBaseInfoMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectBaseInfo;
+
+/**
+ * <p>
+ * 项目基本信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectBaseInfoMapper extends BaseMapper<ProjectBaseInfo> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectBaseInfoMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectBaseInfoMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectCimplementMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectCimplement;
+
+/**
+ * <p>
+ * 建设项目实施信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectCimplementMapper extends BaseMapper<ProjectCimplement> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectCimplementMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectCimplementMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectMimplementMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectMimplement;
+
+/**
+ * <p>
+ * 运维项目实施信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectMimplementMapper extends BaseMapper<ProjectMimplement> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectMimplementMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectMimplementMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectProcureMapper.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectProcure;
+
+/**
+ * <p>
+ * 项目采购信息 Mapper 接口
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface ProjectProcureMapper extends BaseMapper<ProjectProcure> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/mapper/ProjectProcureMapper.xml

@@ -0,0 +1,5 @@
+<?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.ningdatech.syndataapi.scheduler.mapper.ProjectProcureMapper">
+
+</mapper>

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectApply.java

@@ -0,0 +1,138 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 项目申报信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_apply")
+@ApiModel(value = "SzlsDaBiz331100ProjectApply对象", description = "项目申报信息")
+public class ProjectApply implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("发改项目代码")
+    private String baseDevelopCode;
+
+    @ApiModelProperty("财政项目代码")
+    private String setProjCodeFinan;
+
+    @ApiModelProperty("历年项目名称")
+    private String baseHistorProjName;
+
+    @ApiModelProperty("历年项目代码")
+    private String baseHistorProjId;
+
+    @ApiModelProperty("关联IRS应用名称")
+    private String baseProjSys;
+
+    @ApiModelProperty("关联IRS应用编码")
+    private String baseProjSysCode;
+
+    @ApiModelProperty("一本账重大应用名称")
+    private String baseAccountAppName;
+
+    @ApiModelProperty("“领域大脑”一本账名称")
+    private String baseBrainName;
+
+    @ApiModelProperty("单位核心业务名称")
+    private String baseCoreBusiness;
+
+    @ApiModelProperty("单位核心业务编码")
+    private String baseCoreBusinessCode;
+
+    @ApiModelProperty("项目起始时间")
+    private String baseProjStartTime;
+
+    @ApiModelProperty("项目终止时间")
+    private String baseProjEndTime;
+
+    @ApiModelProperty("项目期限")
+    private String baseProjDuration;
+
+    @ApiModelProperty("预算年度")
+    private String baseProjSetYear;
+
+    @ApiModelProperty("预算来源")
+    private String baseProjAmountOri;
+
+    @ApiModelProperty("预算来源说明")
+    private String baseBasisAmountOri;
+
+    @ApiModelProperty("项目总投资")
+    private String baseProjTotalAmount;
+
+    @ApiModelProperty("申报年度预算")
+    private String baseProjDeclAmount;
+
+    @ApiModelProperty("建设层级")
+    private String baseProjConsClass;
+
+    @ApiModelProperty("贯通层级")
+    private String baseLowestLevel;
+
+    @ApiModelProperty("立项依据")
+    private String baseProjBasis;
+
+    @ApiModelProperty("立项依据说明")
+    private String baseBasisEstablish;
+
+    @ApiModelProperty("立项依据证明材料")
+    private String baseProjBasisFile;
+
+    @ApiModelProperty("项目概述")
+    private String baseProjIntro;
+
+    @ApiModelProperty("项目内容与预期成效")
+    private String beseExpectedResults;
+
+    @ApiModelProperty("可行性研究报告")
+    private String baseResearchReportFile;
+
+    @ApiModelProperty("项目申报书")
+    private String baseProjApplyFile;
+
+    @ApiModelProperty("运维方案")
+    private String baseOperatMaintenFile;
+
+    @ApiModelProperty("其他附件")
+    private String baseProjOtherFile;
+
+    @ApiModelProperty("备注")
+    private String baseProjRemark;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectApprove.java

@@ -0,0 +1,90 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 项目立项评审信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_approve")
+@ApiModel(value = "SzlsDaBiz331100ProjectApprove对象", description = "项目立项评审信息")
+public class ProjectApprove implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("发改项目代码")
+    private String baseDevelopCode;
+
+    @ApiModelProperty("财政项目代码")
+    private String setProjCodeFinan;
+
+    @ApiModelProperty("评审结果")
+    private String baseReviewResults;
+
+    @ApiModelProperty("评审意见")
+    private String baseReviewOpinion;
+
+    @ApiModelProperty("评审意见附件")
+    private String baseReviewCommentsFile;
+
+    @ApiModelProperty("建议总投资")
+    private String baseExpertTotalMoney;
+
+    @ApiModelProperty("建议年度预算")
+    private String baseExpertYearMoney;
+
+    @ApiModelProperty("立项批复文件")
+    private String approvalFile;
+
+    @ApiModelProperty("建议批复总投资")
+    private String baseInitialReviewTotalMoney;
+
+    @ApiModelProperty("建议批复年度预算")
+    private String baseProjReplyAmount;
+
+    @ApiModelProperty("等保定级")
+    private String equalProtectionLevel;
+
+    @ApiModelProperty("初步设计方案")
+    private String preliminaryDesignScheme;
+
+    @ApiModelProperty("初步设计方案批复函")
+    private String preliminaryDesignFile;
+
+    @ApiModelProperty("年度预算下达金额")
+    private String releaseYearMoney;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectBaseInfo.java

@@ -0,0 +1,105 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 项目基本信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_baseinfo")
+@ApiModel(value = "SzlsDaBiz331100ProjectBaseinfo对象", description = "项目基本信息")
+public class ProjectBaseInfo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("所属区划")
+    private String baseAreaName;
+
+    @ApiModelProperty("所属区划编码")
+    private String baseAreaCode;
+
+    @ApiModelProperty("是否涉密")
+    private String baseProjIsConfidentiality;
+
+    @ApiModelProperty("项目类型")
+    private String baseProjType;
+
+    @ApiModelProperty("内容类别")
+    private String baseConstructionType;
+
+    @ApiModelProperty("项目状态")
+    private String baseProjSetProg;
+
+    @ApiModelProperty("信息是否有效")
+    private String isEffective;
+
+    @ApiModelProperty("上级主管单位")
+    private String baseProvManDeprt;
+
+    @ApiModelProperty("上级主管单位浙政钉ID")
+    private String baseProvManDeprtDing;
+
+    @ApiModelProperty("本级主管单位")
+    private String baseManDeprt;
+
+    @ApiModelProperty("本级主管单位浙政钉ID")
+    private String baseManDeprtDing;
+
+    @ApiModelProperty("本级主管单位统一社会信用代码")
+    private String baseManDepartUsci;
+
+    @ApiModelProperty("建设单位（申报单位）")
+    private String baseBuildDeprt;
+
+    @ApiModelProperty("建设单位浙政钉ID")
+    private String baseBuildDeprtDing;
+
+    @ApiModelProperty("建设单位统一社会信用代码")
+    private String baseBuildDepartUsci;
+
+    @ApiModelProperty("项目负责人")
+    private String baseProjPrincipal;
+
+    @ApiModelProperty("项目负责人手机号")
+    private String baseProjPrincipalCall;
+
+    @ApiModelProperty("项目联系人")
+    private String baseProjContacts;
+
+    @ApiModelProperty("项目联系人手机号")
+    private String baseProjContactsCall;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectCimplement.java

@@ -0,0 +1,108 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 建设项目实施信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_cimplement")
+@ApiModel(value = "SzlsDaBiz331100ProjectCimplement对象", description = "建设项目实施信息")
+public class ProjectCimplement implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("标段代码")
+    private String baseBidCode;
+
+    @ApiModelProperty("标段名称")
+    private String baseBidName;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("发改项目代码")
+    private String baseDevelopCode;
+
+    @ApiModelProperty("关联IRS应用编码")
+    private String baseProjSysCode;
+
+    @ApiModelProperty("初验意见")
+    private String baseInitialOpinionFile;
+
+    @ApiModelProperty("信息安全等级保护测评报告")
+    private String baseInforLevelFile;
+
+    @ApiModelProperty("商业密码应用评估报告")
+    private String basePasswAssessFile;
+
+    @ApiModelProperty("第三方验收测试报告")
+    private String baseThirdAcceptFile;
+
+    @ApiModelProperty("建设核查表")
+    private String baseCheckFile;
+
+    @ApiModelProperty("财务审计报告")
+    private String baseFinanlAuditFile;
+
+    @ApiModelProperty("用户使用报告")
+    private String baseUserConsFile;
+
+    @ApiModelProperty("监理总结报告")
+    private String baseEstaSummFile;
+
+    @ApiModelProperty("IRS应用试运行报告")
+    private String baseIrsTestRunFile;
+
+    @ApiModelProperty("项目总结报告")
+    private String baseSummReportFile;
+
+    @ApiModelProperty("是否完成日志数据归集")
+    private String baseLogAggregation;
+
+    @ApiModelProperty("实际成效指标")
+    private String baseBusinessMetrics;
+
+    @ApiModelProperty("终验意见")
+    private String baseFinalExpertOpinionFile;
+
+    @ApiModelProperty("项目延期申请表")
+    private String baseEngineerPostpoFile;
+
+    @ApiModelProperty("变更申请单")
+    private String baseChangeFormFile;
+
+    @ApiModelProperty("变更批复文件")
+    private String baseChanFile;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectMimplement.java

@@ -0,0 +1,96 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 运维项目实施信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_mimplement")
+@ApiModel(value = "SzlsDaBiz331100ProjectMimplement对象", description = "运维项目实施信息")
+public class ProjectMimplement implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("标段代码")
+    private String baseBidCode;
+
+    @ApiModelProperty("标段名称")
+    private String baseBidName;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("发改项目代码")
+    private String baseDevelopCode;
+
+    @ApiModelProperty("关联IRS应用编码")
+    private String baseProjSysCode;
+
+    @ApiModelProperty("信息安全等级保护测评报告")
+    private String baseInforLevelFile;
+
+    @ApiModelProperty("商业密码应用评估报告")
+    private String basePasswAssessFile;
+
+    @ApiModelProperty("第三方验收测试报告")
+    private String baseThirdAcceptFile;
+
+    @ApiModelProperty("用户使用报告")
+    private String baseUserConsFile;
+
+    @ApiModelProperty("监理总结报告")
+    private String baseEstaSummFile;
+
+    @ApiModelProperty("运维总结报告")
+    private String baseOperatMaintenSummFile;
+
+    @ApiModelProperty("是否完成日志数据归集")
+    private String baseLogAggregation;
+
+    @ApiModelProperty("实际成效指标")
+    private String baseBusinessMetrics;
+
+    @ApiModelProperty("终验意见")
+    private String baseFinalExpertOpinionFile;
+
+    @ApiModelProperty("项目延期申请表")
+    private String baseEngineerPostpoFile;
+
+    @ApiModelProperty("变更报告")
+    private String baseEngineerAlterFile;
+
+    @ApiModelProperty("变更批复文件")
+    private String baseChanFile;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/model/entity/ProjectProcure.java

@@ -0,0 +1,96 @@
+package com.ningdatech.syndataapi.scheduler.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * <p>
+ * 项目采购信息
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Data
+@TableName("szls_da_biz_331100_project_procure")
+@ApiModel(value = "SzlsDaBiz331100ProjectProcure对象", description = "项目采购信息")
+public class ProjectProcure implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("标段代码")
+    private String baseBidCode;
+
+    @ApiModelProperty("标段名称")
+    private String baseBidName;
+
+    @ApiModelProperty("项目代码")
+    private String baseProjId;
+
+    @ApiModelProperty("项目名称")
+    private String baseProjName;
+
+    @ApiModelProperty("财政项目代码")
+    private String setProjCodeFinan;
+
+    @ApiModelProperty("采购方式")
+    private String baseProjPurchaseWay;
+
+    @ApiModelProperty("预算执行确认书编号")
+    private String basePurchaseCode;
+
+    @ApiModelProperty("招标（采购）文件")
+    private String purchaseFile;
+
+    @ApiModelProperty("采购代理机构")
+    private String basePurchasingAgencies;
+
+    @ApiModelProperty("采购代理机构统一社会信用代码")
+    private String baseUnifiedCreditCode;
+
+    @ApiModelProperty("中标（成交）时间")
+    private String baseWinningBidTime;
+
+    @ApiModelProperty("中标（成交）金额")
+    private String baseProjPurchaseAmount;
+
+    @ApiModelProperty("中标（成交）通知书")
+    private String biddingFile;
+
+    @ApiModelProperty("中标（成交）供应商名称")
+    private String baseConsDeprt;
+
+    @ApiModelProperty("中标（成交）供应商统一社会信用代码")
+    private String baseConsDeprtUsci;
+
+    @ApiModelProperty("采购合同")
+    private String purchaseContract;
+
+    @ApiModelProperty("项目款支付时间")
+    private String basePaymentTime;
+
+    @ApiModelProperty("项目款支付金额")
+    private String paymentProgress;
+
+    @ApiModelProperty("数据来源")
+    private String areaCode;
+
+    @ApiModelProperty("出生产库时间")
+    private LocalDateTime bizTime;
+
+    @ApiModelProperty("操作标记")
+    private String op;
+
+    @ApiModelProperty("数据入库时间")
+    private LocalDateTime tongTime;
+
+    @ApiModelProperty("发送端自增列")
+    @TableId(value = "tongID", type = IdType.AUTO)
+    private Integer tongID;
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectApplyService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApply;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 项目申报信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectApplyService extends IService<ProjectApply> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectApproveService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApprove;
+
+/**
+ * <p>
+ * 项目立项评审信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectApproveService extends IService<ProjectApprove> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectBaseInfoService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectBaseInfo;
+
+/**
+ * <p>
+ * 项目基本信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectBaseInfoService extends IService<ProjectBaseInfo> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectCimplementService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectCimplement;
+
+/**
+ * <p>
+ * 建设项目实施信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectCimplementService extends IService<ProjectCimplement> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectMimplementService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectMimplement;
+
+/**
+ * <p>
+ * 运维项目实施信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectMimplementService extends IService<ProjectMimplement> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/IProjectProcureService.java

@@ -0,0 +1,16 @@
+package com.ningdatech.syndataapi.scheduler.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectProcure;
+
+/**
+ * <p>
+ * 项目采购信息 服务类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+public interface IProjectProcureService extends IService<ProjectProcure> {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/IProjectCimplementServiceImpl.java

@@ -0,0 +1,21 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import org.springframework.stereotype.Service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectCimplementMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectCimplement;
+import com.ningdatech.syndataapi.scheduler.service.IProjectCimplementService;
+
+/**
+ * <p>
+ * 建设项目实施信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class IProjectCimplementServiceImpl extends ServiceImpl<ProjectCimplementMapper, ProjectCimplement> implements IProjectCimplementService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/ProjectApplyServiceImpl.java

@@ -0,0 +1,20 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApply;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectApplyMapper;
+import com.ningdatech.syndataapi.scheduler.service.IProjectApplyService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 项目申报信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class ProjectApplyServiceImpl extends ServiceImpl<ProjectApplyMapper, ProjectApply> implements IProjectApplyService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/ProjectApproveServiceImpl.java

@@ -0,0 +1,21 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import org.springframework.stereotype.Service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectApproveMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectApprove;
+import com.ningdatech.syndataapi.scheduler.service.IProjectApproveService;
+
+/**
+ * <p>
+ * 项目立项评审信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class ProjectApproveServiceImpl extends ServiceImpl<ProjectApproveMapper, ProjectApprove> implements IProjectApproveService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/ProjectBaseInfoServiceImpl.java

@@ -0,0 +1,21 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import org.springframework.stereotype.Service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectBaseInfoMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectBaseInfo;
+import com.ningdatech.syndataapi.scheduler.service.IProjectBaseInfoService;
+
+/**
+ * <p>
+ * 项目基本信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class ProjectBaseInfoServiceImpl extends ServiceImpl<ProjectBaseInfoMapper, ProjectBaseInfo> implements IProjectBaseInfoService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/ProjectMimplementServiceImpl.java

@@ -0,0 +1,21 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import org.springframework.stereotype.Service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectMimplementMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectMimplement;
+import com.ningdatech.syndataapi.scheduler.service.IProjectMimplementService;
+
+/**
+ * <p>
+ * 运维项目实施信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class ProjectMimplementServiceImpl extends ServiceImpl<ProjectMimplementMapper, ProjectMimplement> implements IProjectMimplementService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/service/impl/ProjectProcureServiceImpl.java

@@ -0,0 +1,21 @@
+package com.ningdatech.syndataapi.scheduler.service.impl;
+
+import org.springframework.stereotype.Service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ningdatech.syndataapi.scheduler.mapper.ProjectProcureMapper;
+import com.ningdatech.syndataapi.scheduler.model.entity.ProjectProcure;
+import com.ningdatech.syndataapi.scheduler.service.IProjectProcureService;
+
+/**
+ * <p>
+ * 项目采购信息 服务实现类
+ * </p>
+ *
+ * @author CMM
+ * @since 2023-08-22
+ */
+@Service
+public class ProjectProcureServiceImpl extends ServiceImpl<ProjectProcureMapper, ProjectProcure> implements IProjectProcureService {
+
+}

syn-data-task/src/main/java/com/ningdatech/syndataapi/scheduler/task/SynDataTask.java

@@ -0,0 +1,245 @@
+package com.ningdatech.syndataapi.scheduler.task;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import com.alibaba.fastjson.JSON;
+import com.ningdatech.syndataapi.scheduler.model.entity.*;
+import com.ningdatech.syndataapi.scheduler.service.*;
+
+import cn.hutool.core.collection.CollUtil;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * @author CMM
+ * @since 2023/08/22 18:16
+ */
+@Component
+@Slf4j
+@RequiredArgsConstructor
+public class SynDataTask {
+
+    private final IProjectApplyService projectApplyService;
+
+    private final IProjectApproveService projectApproveService;
+
+    private final IProjectBaseInfoService projectBaseInfoService;
+
+    private final IProjectCimplementService projectCimplementService;
+
+    private final IProjectMimplementService projectMimplementService;
+
+    private final IProjectProcureService projectProcureService;
+
+    @Value("${task.switch.is-open}")
+    private boolean flag;
+
+    @Value("${task.host}")
+    public String HOST;
+
+    // 测试数据
+    private static final String PROJECT_BASE_INFO_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseAreaName\":\"遂昌县\",\n" +
+            "    \"baseAreaCode\":\"331123000\",\n" +
+            "    \"baseProjIsConfidentiality\":\"01\",\n" +
+            "    \"baseProjType\":\"01\",\n" +
+            "    \"baseConstructionType\":\"01\",\n" +
+            "    \"baseProjSetProg\":\"05\",\n" +
+            "    \"isEffective\":\"02\",\n" +
+            "    \"baseProvManDeprt\":\"遂昌县大数据和金融发展中心\",\n" +
+            "    \"baseProvManDeprtDing\":\"GO_9a7dce7fbaf54787998fa004f1b7c0e1\",\n" +
+            "    \"baseManDeprt\":\"遂昌县大数据和金融发展中心\",\n" +
+            "    \"baseManDeprtDing\":\"GO_9a7dce7fbaf54787998fa004f1b7c0e1\",\n" +
+            "    \"baseManDepartUsci\":\"12332527MB1D48606A\",\n" +
+            "    \"baseBuildDeprt\":\"遂昌县大数据和金融发展中心\",\n" +
+            "    \"baseBuildDeprtDing\":\"GO_9a7dce7fbaf54787998fa004f1b7c0e1\",\n" +
+            "    \"baseBuildDepartUsci\":\"12332527MB1D48606A\",\n" +
+            "    \"baseProjPrincipal\":\"蒋国海\",\n" +
+            "    \"baseProjPrincipalCall\":\"13884366607\",\n" +
+            "    \"baseProjContacts\":\"毛以林\",\n" +
+            "    \"baseProjContactsCall\":\"13857049999\"\n" +
+            "}";
+
+
+    private static final String PROJECT_APPLY_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseDevelopCode\":\"否\",\n" +
+            "    \"setProjCodeFinan\":\"331123220130969000000\",\n" +
+            "    \"baseHistorProjName\":\"无\",\n" +
+            "    \"baseHistorProjId\":\"000000\",\n" +
+            "    \"baseAccountAppName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseBrainName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseProjStartTime\":\"2023—03—08\",\n" +
+            "    \"baseProjEndTime\":\"2023—12—08\",\n" +
+            "    \"baseProjDuration\":\"9月\",\n" +
+            "    \"baseProjSetYear\":\"2023\",\n" +
+            "    \"baseProjAmountOri\":\"02\",\n" +
+            "    \"baseBasisAmountOri\":\"\",\n" +
+            "    \"baseProjTotalAmount\":\"300\",\n" +
+            "    \"baseProjDeclAmount\":\"300\",\n" +
+            "    \"baseProjConsClass\":\"c\",\n" +
+            "    \"baseLowestLevel\":\"c\",\n" +
+            "    \"baseProjBasis\":\"01:02：03\",\n" +
+            "    \"baseBasisEstablish\":\"丽水市中共遂昌县委组织部新时代挺进师战斗力指数应用解决了县级干部考评普遍存在考评指标模糊、展示界面缺乏、考核过程不规范、考评流程繁杂等问题，采用C/S架构，即客户端/服务器架构，包含五维考评、挂帅争先、村级红黑榜、天工考评、交办工作等考评模块，面向领导干部、乡干部、村干部等三类人员，实现了链条、全过程追溯每个班子、每名干部实绩的功能。\",\n" +
+            "    \"baseProjBasisFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseProjIntro\":\"丽水市中共遂昌县委组织部新时代挺进师战斗力指数应用解决了县级干部考评普遍存在考评指标模糊、展示界面缺乏、考核过程不规范、考评流程繁杂等问题，采用C/S架构，即客户端/服务器架构，包含五维考评、挂帅争先、村级红黑榜、天工考评、交办工作等考评模块，面向领导干部、乡干部、村干部等三类人员，实现了链条、全过程追溯每个班子、每名干部实绩的功能。\",\n" +
+            "    \"beseExpectedResults\":\"省项管系统项目的主要内容为项目全生命周期管理，业务对象为全省电子政务项目，预期成效指标有 项目数据归集覆盖11个地市和90个区县和项目信息完整率达98%以上\",\n" +
+            "    \"baseResearchReportFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseProjApplyFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseOperatMaintenFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseProjOtherFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseProjRemark\":\"丽水市中共遂昌县委组织部新时代挺进师战斗力指数应用解决了县级干部考评普遍存在考评指标模糊、展示界面缺乏、考核过程不规范、考评流程繁杂等问题，采用C/S架构，即客户端/服务器架构，包含五维考评、挂帅争先、村级红黑榜、天工考评、交办工作等考评模块，面向领导干部、乡干部、村干部等三类人员，实现了链条、全过程追溯每个班子、每名干部实绩的功能。\"\n" +
+            "}";
+
+    private static final String PROJECT_APPROVE_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseDevelopCode\":\"否\",\n" +
+            "    \"setProjCodeFinan\":\"331123220130969000000\",\n" +
+            "    \"baseReviewResults\":\"01\",\n" +
+            "    \"baseReviewOpinion\":\"通过\",\n" +
+            "    \"baseReviewCommentsFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseExpertTotalMoney\":\"300\",\n" +
+            "    \"baseExpertYearMoney\":\"300\",\n" +
+            "    \"approvalFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseInitialReviewTotalMoney\":\"300\",\n" +
+            "    \"baseProjReplyAmount\":\"300\",\n" +
+            "    \"equalProtectionLevel\":\"03\",\n" +
+            "    \"preliminaryDesignScheme\":\"否\",\n" +
+            "    \"preliminaryDesignFile\":\"否\",\n" +
+            "    \"releaseYearMoney\":\"300\"\n" +
+            "}";
+
+    private static final String PROJECT_PROCURE_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"setProjCodeFinan\":\"331123220130969000000\",\n" +
+            "    \"baseBidCode\":\"33112322013096900000—01\",\n" +
+            "    \"baseBidName\":\"标段一\",\n" +
+            "    \"baseProjPurchaseWay\":\"01\",\n" +
+            "    \"basePurchaseCode\":\"否\",\n" +
+            "    \"purchaseFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"basePurchasingAgencies\":\"测试代理机构\",\n" +
+            "    \"baseUnifiedCreditCode\":\"91330108MA2H2JUB3G\",\n" +
+            "    \"baseWinningBidTime\":\"2022—03—08\",\n" +
+            "    \"baseProjPurchaseAmount\":\"300\",\n" +
+            "    \"biddingFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseConsDeprt\":\"测试供应商\",\n" +
+            "    \"baseConsDeprtUsci\":\"91330108MA2H2JUB3G\",\n" +
+            "    \"purchaseContract\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"basePaymentTime\":\"2023—03—08\",\n" +
+            "    \"paymentProgress\":\"300\"\n" +
+            "}";
+
+    private static final String PROJECT_CIMPLEMENT_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseDevelopCode\":\"否\",\n" +
+            "    \"baseInitialOpinionFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseInforLevelFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"basePasswAssessFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseThirdAcceptFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseCheckFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseFinanlAuditFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseUserConsFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseEstaSummFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseIrsTestRunFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseSummReportFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseLogAggregation\":\"2\",\n" +
+            "    \"baseBusinessMetrics\":\"核心业务1+实际成效指标1+100\",\n" +
+            "    \"baseFinalExpertOpinionFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseEngineerPostpoFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseChangeFormFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseChanFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"areaCode\":\"331100\"\n" +
+            "}";
+
+    private static final String PROJECT_MIMPLEMENT_TEST_DATA = "{\n" +
+            "    \"baseProjId\":\"33112322013096900000\",\n" +
+            "    \"baseProjName\":\"遂昌县大数据和金融发展中心天工系统\",\n" +
+            "    \"baseDevelopCode\":\"否\",\n" +
+            "    \"baseInforLevelFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"basePasswAssessFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseThirdAcceptFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseUserConsFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseEstaSummFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseOperatMaintenSummFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseLogAggregation\":\"1\",\n" +
+            "    \"baseBusinessMetrics\":\"核心业务1+实际成效指标1+100\",\n" +
+            "    \"baseFinalExpertOpinionFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseEngineerPostpoFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseEngineerAlterFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"baseChanFile\":\"http://60.188.225.145/pm/file/download?fileId=951\",\n" +
+            "    \"areaCode\":\"331100\"\n" +
+            "}";
+
+
+
+    /**
+     * 定时同步前置机数据 每天3点开始执行一次
+     *
+     */
+    @Scheduled(cron = "0 20 11 * * ?")
+    public void doTask() throws UnknownHostException {
+        if (flag && HOST.equals(InetAddress.getLocalHost().getHostName())) {
+            // 先删除表中的所有数据,再插入数据,测试数据只有一条，这里只插入一条
+            List<ProjectBaseInfo> baseInfos = projectBaseInfoService.list();
+            if (CollUtil.isNotEmpty(baseInfos)) {
+                projectBaseInfoService.removeBatchByIds(baseInfos);
+            }
+
+            // 项目基本信息
+            ProjectBaseInfo projectBaseInfo = JSON.parseObject(PROJECT_BASE_INFO_TEST_DATA, ProjectBaseInfo.class);
+            projectBaseInfoService.save(projectBaseInfo);
+
+            List<ProjectApply> applies = projectApplyService.list();
+            if (CollUtil.isNotEmpty(applies)){
+                projectApplyService.removeBatchByIds(applies);
+            }
+            // 项目申报信息
+            ProjectApply projectApply = JSON.parseObject(PROJECT_APPLY_TEST_DATA, ProjectApply.class);
+            projectApplyService.save(projectApply);
+
+            List<ProjectApprove> approves = projectApproveService.list();
+            if (CollUtil.isNotEmpty(approves)){
+                projectApproveService.removeBatchByIds(approves);
+            }
+            // 项目立项评审信息
+            ProjectApprove projectApprove = JSON.parseObject(PROJECT_APPROVE_TEST_DATA, ProjectApprove.class);
+            projectApproveService.save(projectApprove);
+
+            List<ProjectProcure> procures = projectProcureService.list();
+            if (CollUtil.isNotEmpty(procures)){
+                projectProcureService.removeBatchByIds(procures);
+            }
+            // 项目采购信息
+            ProjectProcure projectProcure = JSON.parseObject(PROJECT_PROCURE_TEST_DATA, ProjectProcure.class);
+            projectProcureService.save(projectProcure);
+
+            List<ProjectCimplement> cimplements = projectCimplementService.list();
+            if (CollUtil.isNotEmpty(cimplements)){
+                projectCimplementService.removeBatchByIds(cimplements);
+            }
+            // 建设项目实施信息
+            ProjectCimplement projectCimplement = JSON.parseObject(PROJECT_CIMPLEMENT_TEST_DATA, ProjectCimplement.class);
+            projectCimplementService.save(projectCimplement);
+
+            List<ProjectMimplement> mimplements = projectMimplementService.list();
+            if (CollUtil.isNotEmpty(mimplements)){
+                projectCimplementService.removeBatchByIds(cimplements);
+            }
+            // 运维项目实施信息
+            ProjectMimplement projectMimplement = JSON.parseObject(PROJECT_MIMPLEMENT_TEST_DATA, ProjectMimplement.class);
+            projectMimplementService.save(projectMimplement);
+        }
+    }
+}

syn-data-task/src/main/resources/application-dev.yml

@@ -0,0 +1,81 @@
+server:
+  port: 38888
+  servlet:
+    context-path: /pm
+spring:
+  application:
+    name: syn-data-task
+  jackson:
+    default-property-inclusion: non_null
+    time-zone: GMT+8
+    date-format: yyyy-MM-dd HH:mm:ss
+  jpa:
+    properties:
+      hibernate:
+        default_schema: PUBLIC
+        hbm2ddl:
+          auto: update
+        show_sql: true
+    show-sql: true
+    hibernate:
+      ddl-auto: update
+  datasource:
+    type: com.zaxxer.hikari.HikariDataSource
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://47.98.125.47:3306/szls_da_lsxmss_sjgx?serverTimezone=Asia/Shanghai&characterEncoding=utf8&allowPublicKeyRetrieval=true&useSSL=false
+    username: root
+    password: NingdaKeji123!
+    # 数据源
+    hikari:
+      # 是客户端等待连接池连接的最大毫秒数
+      connection-timeout: 30000
+      # 是允许连接在连接池中空闲的最长时间
+      minimum-idle: 5
+      # 配置最大池大小
+      maximum-pool-size: 20
+      # 是允许连接在连接池中空闲的最长时间（以毫秒为单位）
+      idle-timeout: 60000
+      # 池中连接关闭后的最长生命周期（以毫秒为单位）
+      max-lifetime: 600000
+      # 配置从池返回的连接的默认自动提交行为。默认值为true。
+      auto-commit: true
+      # 开启连接监测泄露
+      leak-detection-threshold: 5000
+      # 测试连接数据库
+      connection-test-query: SELECT 1
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      logic-delete-value: true
+      logic-not-delete-value: false
+logging:
+  config: classpath:logback-spring.xml
+  #日志配置
+  level:
+    root: info
+  file:
+    path: logs
+# 日志文件配置
+log:
+  path: ./logs
+  info:
+    file-size: 50MB
+    max-size: 5
+    total-size: 200MB
+  error:
+    file-size: 10MB
+    max-size: 5
+    total-size: 50MB
+
+swagger:
+  enabled: true
+
+task:
+  host: iZbp13nwyvib53j4j1p2xoZ
+  switch:
+    is-open: true #开关
+
+
+

syn-data-task/src/main/resources/application-pre.yml

@@ -0,0 +1,79 @@
+server:
+  port: 38888
+  servlet:
+    context-path: /pm
+spring:
+  application:
+    name: syn-data-task
+  jackson:
+    default-property-inclusion: non_null
+    time-zone: GMT+8
+    date-format: yyyy-MM-dd HH:mm:ss
+  jpa:
+    properties:
+      hibernate:
+        default_schema: PUBLIC
+        hbm2ddl:
+          auto: update
+        show_sql: true
+    show-sql: true
+    hibernate:
+      ddl-auto: update
+  datasource:
+    type: com.zaxxer.hikari.HikariDataSource
+      driver-class-name: com.mysql.cj.jdbc.Driver
+      url: jdbc:mysql://10.53.129.228:63306/szls_da_lsxmss_sjgx?serverTimezone=Asia/Shanghai&characterEncoding=utf8&allowPublicKeyRetrieval=true&useSSL=false
+      username: szls_da_lsxmss
+      password: 1Lzo6XqF
+    # 数据源
+    hikari:
+      # 是客户端等待连接池连接的最大毫秒数
+      connection-timeout: 30000
+      # 是允许连接在连接池中空闲的最长时间
+      minimum-idle: 10
+      # 配置最大池大小
+      maximum-pool-size: 20
+      # 是允许连接在连接池中空闲的最长时间（以毫秒为单位）
+      idle-timeout: 60000
+      # 池中连接关闭后的最长生命周期（以毫秒为单位）
+      max-lifetime: 600000
+      # 配置从池返回的连接的默认自动提交行为。默认值为true。
+      auto-commit: true
+      # 开启连接监测泄露
+      leak-detection-threshold: 5000
+      # 测试连接数据库
+      connection-test-query: SELECT 1
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      logic-delete-value: true
+      logic-not-delete-value: false
+logging:
+  config: classpath:logback-spring.xml
+  #日志配置
+  level:
+    root: info
+  file:
+    path: logs
+# 日志文件配置
+log:
+  path: ./logs
+  info:
+    file-size: 50MB
+    max-size: 5
+    total-size: 200MB
+  error:
+    file-size: 10MB
+    max-size: 5
+    total-size: 50MB
+
+swagger:
+  enabled: true
+
+task:
+  host: iZ6mx01asxnsmennpzoxooZ
+  switch:
+    is-open: true #开关
+

syn-data-task/src/main/resources/application.yml

@@ -0,0 +1,3 @@
+spring:
+  profiles:
+    active: dev

syn-data-task/src/main/resources/logback-spring.xml

@@ -0,0 +1,68 @@
+<configuration scan="true" scanPeriod="10 seconds">
+    <springProperty name="logPath" scope="context" source="log.path" defaultValue="./logs"/>
+    <springProperty name="infoFileSize" scope="context" source="log.info.file-size"/>
+    <springProperty name="infoMaxSize" scope="context" source="log.info.max-size"/>
+    <springProperty name="infoTotalSize" scope="context" source="log.info.total-size"/>
+    <springProperty name="errorFileSize" scope="context" source="log.error.file-size"/>
+    <springProperty name="errorMaxSize" scope="context" source="log.error.max-size"/>
+    <springProperty name="errorTotalSize" scope="context" source="log.error.total-size"/>
+
+    <appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <File>${logPath}/info.log</File>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${logPath}/info-%d{yyyyMMdd}-%i.log</fileNamePattern>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>${infoFileSize}</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+            <maxHistory>${infoMaxSize}</maxHistory>
+            <totalSizeCap>${infoTotalSize}</totalSizeCap>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
+            <layout class="ch.qos.logback.classic.PatternLayout">
+                <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} -%msg%n
+                </Pattern>
+            </layout>
+            <charset>UTF-8</charset>
+        </encoder>
+    </appender>
+
+    <appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+            <level>ERROR</level>
+        </filter>
+        <File>${logPath}/error.log</File>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${logPath}/error-%d{yyyyMMdd}-%i.log</fileNamePattern>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>${errorFileSize}</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+            <maxHistory>${errorMaxSize}</maxHistory>
+            <totalSizeCap>${errorTotalSize}</totalSizeCap>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
+            <layout class="ch.qos.logback.classic.PatternLayout">
+                <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} -%msg%n
+                </Pattern>
+            </layout>
+            <charset>UTF-8</charset>
+        </encoder>
+    </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>
+            <charset>UTF-8</charset>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+            <level>DEBUG</level>
+        </filter>
+    </appender>
+
+    <root level="INFO">
+        <appender-ref ref="INFO_FILE"/>
+        <appender-ref ref="ERROR_FILE"/>
+        <appender-ref ref="STDOUT"/>
+    </root>
+</configuration>