From fcea223b0523132ae529700b0d493149e9bc4777 Mon Sep 17 00:00:00 2001
From: Administrator <1923636941@qq.com>
Date: Fri, 24 Mar 2023 10:57:16 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E6=94=BF=E5=8A=A1=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=8E=A8=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       |   5 +
 .../zhgd/xmgl/async/AsyncSendAttendance.java  |   4 +
 .../modules/govtapi/GovtOpenApiService.java   | 146 ++++++++++++++++++
 .../ProjectOperationsAnalysisServiceImpl.java |   9 +-
 ...WorkerMonthAttendanceStatisticsMapper.java |   2 +
 .../WorkerMonthAttendanceStatisticsMapper.xml |   8 +
 .../impl/WorkerAttendanceServiceImpl.java     |  10 ++
 .../service/impl/WorkerInfoServiceImpl.java   |  10 ++
 ...rMonthAttendanceStatisticsServiceImpl.java |  12 ++
 .../java/com/zhgd/xmgl/task/GovtSyncTask.java |  77 +++++++++
 src/main/resources/application-ljw.properties |  32 ++--
 11 files changed, 298 insertions(+), 17 deletions(-)
 create mode 100644 src/main/java/com/zhgd/xmgl/modules/govtapi/GovtOpenApiService.java
 create mode 100644 src/main/java/com/zhgd/xmgl/task/GovtSyncTask.java

diff --git a/pom.xml b/pom.xml
index ac4935a67..f322b7366 100644
--- a/pom.xml
+++ b/pom.xml
@@ -496,6 +496,11 @@
             <artifactId>gexin-rp-sdk-http</artifactId>
             <version>4.1.1.4</version>
         </dependency>
+        <dependency>
+            <groupId>com.gexin.platform</groupId>
+            <artifactId>gexin-rp-fastjson</artifactId>
+            <version>1.0.0.7</version>
+        </dependency>
         <!-- 海康视频-->
         <dependency>
             <groupId>com.hikvision.ga</groupId>
diff --git a/src/main/java/com/zhgd/xmgl/async/AsyncSendAttendance.java b/src/main/java/com/zhgd/xmgl/async/AsyncSendAttendance.java
index 0d81ec57d..ba75470f6 100644
--- a/src/main/java/com/zhgd/xmgl/async/AsyncSendAttendance.java
+++ b/src/main/java/com/zhgd/xmgl/async/AsyncSendAttendance.java
@@ -40,10 +40,14 @@ public class AsyncSendAttendance {
     private IWorkerAttendancePresenceService workerAttendancePresenceService;
     @Autowired
     private WkServiceuCall wkServiceuCall;
+    @Autowired
+    private GovtOpenApiService govtOpenApiService;
 
     @Async("sendAttendanceExecutor")
     public void saveAndSendAttendance(WorkerAttendance workerAttendance, WorkerInfo info){
         try {
+            // 向政务平台发送数据
+            govtOpenApiService.workerAttendanceSync(workerAttendance);
             //计算在场
             workerAttendancePresenceService.addWorkerAttendancePresence(workerAttendance);
             //上传住建
diff --git a/src/main/java/com/zhgd/xmgl/modules/govtapi/GovtOpenApiService.java b/src/main/java/com/zhgd/xmgl/modules/govtapi/GovtOpenApiService.java
new file mode 100644
index 000000000..9bcd170df
--- /dev/null
+++ b/src/main/java/com/zhgd/xmgl/modules/govtapi/GovtOpenApiService.java
@@ -0,0 +1,146 @@
+package com.zhgd.xmgl.modules.govtapi;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.http.HttpUtil;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.zhgd.xmgl.modules.realnamestatistics.entity.ProjectOperationsAnalysis;
+import com.zhgd.xmgl.modules.worker.entity.WorkerAttendance;
+import com.zhgd.xmgl.modules.worker.entity.WorkerInfo;
+import com.zhgd.xmgl.modules.worker.entity.WorkerMonthAttendanceStatistics;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 湖里政务平台开放api调用
+ *
+ * @author HZI.HUI
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class GovtOpenApiService {
+
+
+    @Value("${govt.host}")
+    public String govtHost;
+
+
+    /**
+     * 考勤打卡
+     *
+     * @param workerAttendance
+     */
+    public void workerAttendanceSync(WorkerAttendance workerAttendance) {
+        try {
+            String result = HttpUtil.post(govtHost + "/openapi/labour/worker/attendance/sync", JSONUtil.toJsonStr(workerAttendance), 6000);
+            JSONObject jsonObject = JSONUtil.parseObj(result);
+            String code = jsonObject.getStr("code");
+            if ("200".equals(code)) {
+                log.info("[劳务管理-考勤打卡-同步到政务] 成功，数据：{}", JSONUtil.toJsonStr(workerAttendance));
+                return;
+            }
+            log.error("[劳务管理-考勤打卡-同步到政务] 失败，数据：{}, 错误：{}", JSONUtil.toJsonStr(workerAttendance), result);
+        } catch (Exception e) {
+            log.error("[劳务管理-考勤打卡-同步到政务] 失败，数据：{}, 异常：", JSONUtil.toJsonStr(workerAttendance), e);
+        }
+    }
+
+
+    /**
+     * 劳务管理-考情统计-同步到政务
+     *
+     * @param statistics
+     */
+    public void workerMonthAttendanceStatisticsSync(WorkerMonthAttendanceStatistics statistics) {
+        try {
+            String result = HttpUtil.post(govtHost + "/openapi/labour/worker/month/attendance/statistics/sync", JSONUtil.toJsonStr(statistics), 6000);
+            JSONObject jsonObject = JSONUtil.parseObj(result);
+            String code = jsonObject.getStr("code");
+            if ("200".equals(code)) {
+                log.info("[劳务管理-考情统计-同步到政务] 成功，数据：{}", JSONUtil.toJsonStr(statistics));
+                return;
+            }
+            log.error("[劳务管理-考情统计-同步到政务] 失败，数据：{}, 错误：{}", JSONUtil.toJsonStr(statistics), result);
+        } catch (Exception e) {
+            log.error("[劳务管理-考情统计-同步到政务] 失败，数据：{}, 异常：", JSONUtil.toJsonStr(statistics), e);
+        }
+    }
+
+    /**
+     * 劳务管理-开放api-实名制统计
+     *
+     * @param analysisList
+     */
+    public void projectOperationsAnalysisUpdateSync(List<ProjectOperationsAnalysis> analysisList) {
+        if (CollUtil.isEmpty(analysisList)) {
+            return;
+        }
+        for (ProjectOperationsAnalysis projectOperationsAnalysis : analysisList) {
+            try {
+                String result = HttpUtil.post(govtHost + "/openapi/labour/project/operations/analysis/update", JSONUtil.toJsonStr(projectOperationsAnalysis), 20000);
+                JSONObject jsonObject = JSONUtil.parseObj(result);
+                String code = jsonObject.getStr("code");
+                if ("200".equals(code)) {
+                    log.info("[劳务管理-实名制统计-同步到政务] 成功，数据：{}", JSONUtil.toJsonStr(projectOperationsAnalysis));
+                    continue;
+                }
+                log.error("[劳务管理-实名制统计-同步到政务] 失败，数据：{}, 错误：{}", JSONUtil.toJsonStr(projectOperationsAnalysis), result);
+            } catch (Exception e) {
+                log.error("[劳务管理-实名制统计-同步到政务] 失败，数据：{}, 异常：", JSONUtil.toJsonStr(projectOperationsAnalysis), e);
+            }
+        }
+
+    }
+
+
+    /**
+     * 劳务管理-开放api-劳务人员新增
+     *
+     * @param workerInfo
+     */
+    public void workerInfoAddSync(WorkerInfo workerInfo) {
+        try {
+            String result = HttpUtil.post(govtHost + "/openapi/labour/worker/info/add", JSONUtil.toJsonStr(workerInfo), 6000);
+            JSONObject jsonObject = JSONUtil.parseObj(result);
+            String code = jsonObject.getStr("code");
+            if ("200".equals(code)) {
+                log.info("[劳务管理-劳务人员新增-同步到政务] 成功，数据：{}", JSONUtil.toJsonStr(workerInfo));
+                return;
+            }
+            log.error("[劳务管理-劳务人员新增-同步到政务] 失败，数据：{}, 错误：{}", JSONUtil.toJsonStr(workerInfo), result);
+        } catch (Exception e) {
+            log.error("[劳务管理-劳务人员新增-同步到政务] 失败，数据：{}, 异常：", JSONUtil.toJsonStr(workerInfo), e);
+        }
+    }
+
+
+    /**
+     * 劳务管理-开放api-劳务人员新增
+     *
+     * @param workerInfo
+     */
+    public void workerInfoDelSync(WorkerInfo workerInfo) {
+        try {
+            String result = HttpUtil.post(govtHost + "/openapi/labour/worker/info/del/sync", JSONUtil.toJsonStr(workerInfo), 6000);
+            JSONObject jsonObject = JSONUtil.parseObj(result);
+            String code = jsonObject.getStr("code");
+            if ("200".equals(code)) {
+                log.info("[劳务管理-劳务人员删除-同步到政务] 成功，数据：{}", JSONUtil.toJsonStr(workerInfo));
+                return;
+            }
+            log.error("[劳务管理-劳务人员删除-同步到政务] 失败，数据：{}, 错误：{}", JSONUtil.toJsonStr(workerInfo), result);
+        } catch (Exception e) {
+            log.error("[劳务管理-劳务人员删除-同步到政务] 失败，数据：{}, 异常：", JSONUtil.toJsonStr(workerInfo), e);
+        }
+    }
+
+
+
+
+
+}
diff --git a/src/main/java/com/zhgd/xmgl/modules/realnamestatistics/service/impl/ProjectOperationsAnalysisServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/realnamestatistics/service/impl/ProjectOperationsAnalysisServiceImpl.java
index 42a9463db..bac39515f 100644
--- a/src/main/java/com/zhgd/xmgl/modules/realnamestatistics/service/impl/ProjectOperationsAnalysisServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/realnamestatistics/service/impl/ProjectOperationsAnalysisServiceImpl.java
@@ -4,6 +4,7 @@ package com.zhgd.xmgl.modules.realnamestatistics.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.zhgd.xmgl.modules.govtapi.GovtOpenApiService;
 import com.zhgd.xmgl.modules.realnamestatistics.entity.ProjectOperationsAnalysis;
 import com.zhgd.xmgl.modules.realnamestatistics.entity.ProjectTotalStatistics;
 import com.zhgd.xmgl.modules.realnamestatistics.entity.vo.TodayAttendance;
@@ -48,13 +49,15 @@ public class ProjectOperationsAnalysisServiceImpl extends ServiceImpl<ProjectOpe
     ITeamInfoService teamInfoService;
     @Autowired
     IWorkerInfoService workerInfoService;
+    @Autowired
+    GovtOpenApiService govtOpenApiService;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void updateProjectOperationsAnalysisStatistics() {
         try {
             //查询所有在建项目
-            log.info("同步在建项目实名制人员核酸详情开始" + new Date().getTime());
+            log.info("同步在建项目实名制人员核酸详情开始" + System.currentTimeMillis());
             List<ProjectOperationsAnalysis> analysisList = projectOperationsAnalysisMapper.getAllDetails();
             for (ProjectOperationsAnalysis projectOperationsAnalysis : analysisList) {
                 String projectSn = projectOperationsAnalysis.getProjectSn();
@@ -73,7 +76,9 @@ public class ProjectOperationsAnalysisServiceImpl extends ServiceImpl<ProjectOpe
                 baseMapper.deleteById(projectOperationsAnalysis.getId());
             }
             this.saveBatch(analysisList);
-            log.info("数据库同步在建项目实名制人员核酸详情结束" + new Date().getTime());
+            // 同步到政务平台
+            govtOpenApiService.projectOperationsAnalysisUpdateSync(analysisList);
+            log.info("数据库同步在建项目实名制人员核酸详情结束" + System.currentTimeMillis());
         } catch (Exception e) {
             log.error("项目统计操作失败", e);
         }
diff --git a/src/main/java/com/zhgd/xmgl/modules/worker/mapper/WorkerMonthAttendanceStatisticsMapper.java b/src/main/java/com/zhgd/xmgl/modules/worker/mapper/WorkerMonthAttendanceStatisticsMapper.java
index 16e99436c..d26b4b506 100644
--- a/src/main/java/com/zhgd/xmgl/modules/worker/mapper/WorkerMonthAttendanceStatisticsMapper.java
+++ b/src/main/java/com/zhgd/xmgl/modules/worker/mapper/WorkerMonthAttendanceStatisticsMapper.java
@@ -33,4 +33,6 @@ public interface WorkerMonthAttendanceStatisticsMapper extends BaseMapper<Worker
     List<EntityMap> selectProjectMonthAttendanceList(HashMap<String, Object> param);
 
     List<EntityMap> getListByProjectSn(String projectSn);
+
+    WorkerMonthAttendanceStatistics selectByCondition(Map<String, Object> param);
 }
diff --git a/src/main/java/com/zhgd/xmgl/modules/worker/mapper/xml/WorkerMonthAttendanceStatisticsMapper.xml b/src/main/java/com/zhgd/xmgl/modules/worker/mapper/xml/WorkerMonthAttendanceStatisticsMapper.xml
index acb6b7bc1..8bf10c066 100644
--- a/src/main/java/com/zhgd/xmgl/modules/worker/mapper/xml/WorkerMonthAttendanceStatisticsMapper.xml
+++ b/src/main/java/com/zhgd/xmgl/modules/worker/mapper/xml/WorkerMonthAttendanceStatisticsMapper.xml
@@ -185,4 +185,12 @@
                  inner join worker_info wi on wi.person_sn = wmas.person_sn
         where wi.project_sn = #{projectSn}
     </select>
+
+    <select id="selectByCondition"
+            resultType="com.zhgd.xmgl.modules.worker.entity.WorkerMonthAttendanceStatistics">
+        select *  from worker_month_attendance_statistics
+        where project_sn = #{projectSn}
+          and person_sn = #{personSn}
+          and query_time = date_format(#{inputTime}, '%Y-%m')
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerAttendanceServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerAttendanceServiceImpl.java
index 2eacb9d54..98d17686a 100644
--- a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerAttendanceServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerAttendanceServiceImpl.java
@@ -14,6 +14,7 @@ import com.zhgd.jeecg.common.mybatis.EntityMap;
 import com.zhgd.xmgl.async.AsyncSendAttendance;
 import com.zhgd.xmgl.modules.basicdata.service.ICompanyService;
 import com.zhgd.xmgl.modules.basicdata.service.UploadFileService;
+import com.zhgd.xmgl.modules.govtapi.GovtOpenApiService;
 import com.zhgd.xmgl.modules.project.entity.ProjectUfaceConfig;
 import com.zhgd.xmgl.modules.project.mapper.ProjectUfaceConfigMapper;
 import com.zhgd.xmgl.modules.worker.entity.*;
@@ -78,6 +79,9 @@ public class WorkerAttendanceServiceImpl extends ServiceImpl<WorkerAttendanceMap
 
     @Autowired
     private ICompanyService companyService;
+    @Autowired
+    private GovtOpenApiService govtOpenApiService;
+
     @Value("${basePath}")
     private String basePath;
     @Value("${imageType}")
@@ -105,6 +109,8 @@ public class WorkerAttendanceServiceImpl extends ServiceImpl<WorkerAttendanceMap
         SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
         String nowTime = sdf1.format(new Date());
         workerAttendanceMapper.insert(workerAttendance);
+        // 向政务平台发送数据
+        govtOpenApiService.workerAttendanceSync(workerAttendance);
         //如果不是当天补的考勤则重新计算考勤统计
         if (!nowTime.equals(time)) {
             WorkerInfo workerInfo = workerInfoMapper.selectWorkerInfoByPersonSn(MapUtils.getString(map, "personSn"));
@@ -450,6 +456,8 @@ public class WorkerAttendanceServiceImpl extends ServiceImpl<WorkerAttendanceMap
             workerAttendance.setCardType(7);
             workerAttendance.setImageUrl(MapUtils.getString(map, "photoUrl"));
             workerAttendanceMapper.insert(workerAttendance);
+            // 向政务平台发送数据
+            govtOpenApiService.workerAttendanceSync(workerAttendance);
         }
     }
 
@@ -731,6 +739,8 @@ public class WorkerAttendanceServiceImpl extends ServiceImpl<WorkerAttendanceMap
                 workerAttendance.setAttendanceType(1);
                 workerAttendanceMapper.insert(workerAttendance);
                 //asyncSendAttendance.saveAndSendAttendance(workerAttendance,info);
+                // 向政务平台发送数据
+                govtOpenApiService.workerAttendanceSync(workerAttendance);
             }
         } catch (Exception e) {
             e.printStackTrace();
diff --git a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerInfoServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerInfoServiceImpl.java
index 43cff57af..53bef3ce1 100644
--- a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerInfoServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerInfoServiceImpl.java
@@ -19,6 +19,7 @@ import com.zhgd.xmgl.async.AsyncWorker;
 import com.zhgd.xmgl.modules.basicdata.entity.Company;
 import com.zhgd.xmgl.modules.basicdata.mapper.CompanyMapper;
 import com.zhgd.xmgl.modules.basicdata.service.UploadFileService;
+import com.zhgd.xmgl.modules.govtapi.GovtOpenApiService;
 import com.zhgd.xmgl.modules.project.entity.Project;
 import com.zhgd.xmgl.modules.project.entity.ProjectEnterprise;
 import com.zhgd.xmgl.modules.project.mapper.ProjectEnterpriseMapper;
@@ -102,6 +103,9 @@ public class WorkerInfoServiceImpl extends ServiceImpl<WorkerInfoMapper, WorkerI
     @Autowired
     private IWorkerPhotoFeaturesService workerPhotoFeaturesService;
 
+    @Autowired
+    private GovtOpenApiService govtOpenApiService;
+
     @Value("${basePath}")
     private String basePath;
     @Value("${isGetFaceFeatureDate}")
@@ -266,6 +270,9 @@ public class WorkerInfoServiceImpl extends ServiceImpl<WorkerInfoMapper, WorkerI
         if (isGetFaceFeatureDate) {
             workerPhotoFeaturesService.saveWorkerPhotoFeatures(workerInfo);
         }
+        // 同步到政务平台
+        govtOpenApiService.workerInfoAddSync(workerInfo);
+
         return workerInfo;
     }
 
@@ -310,6 +317,9 @@ public class WorkerInfoServiceImpl extends ServiceImpl<WorkerInfoMapper, WorkerI
         if (isGetFaceFeatureDate) {
             workerPhotoFeaturesService.saveWorkerPhotoFeatures(workerInfo);
         }
+
+        // 同步到政务平台
+        govtOpenApiService.workerInfoAddSync(workerInfo);
         return workerInfo;
     }
 
diff --git a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerMonthAttendanceStatisticsServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerMonthAttendanceStatisticsServiceImpl.java
index 02e4c06ce..08f21f868 100644
--- a/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerMonthAttendanceStatisticsServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/worker/service/impl/WorkerMonthAttendanceStatisticsServiceImpl.java
@@ -1,11 +1,13 @@
 package com.zhgd.xmgl.modules.worker.service.impl;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zhgd.jeecg.common.mybatis.EntityMap;
+import com.zhgd.xmgl.modules.govtapi.GovtOpenApiService;
 import com.zhgd.xmgl.modules.project.entity.Project;
 import com.zhgd.xmgl.modules.project.mapper.ProjectMapper;
 import com.zhgd.xmgl.modules.worker.entity.WorkerAttendanceRule;
@@ -52,6 +54,8 @@ public class WorkerMonthAttendanceStatisticsServiceImpl extends ServiceImpl<Work
     private ProjectMapper projectMapper;
     @Autowired
     private WorkerInfoMapper workerWorkInfoMapper;
+    @Autowired
+    private GovtOpenApiService govtOpenApiService;
 
 
     @Override
@@ -128,7 +132,9 @@ public class WorkerMonthAttendanceStatisticsServiceImpl extends ServiceImpl<Work
                 statistics.setPersonSn(info.getPersonSn());
                 statistics.setQueryTime(inputTime.substring(0, 7));
                 workerMonthAttendanceStatisticsMapper.insert(statistics);
+
                 //workerMonthAttendanceStatisticsMapper.insertMonthAttendanceStatistics(param);
+
             }
             //修改人员时长
             param.put("durationNum", durationNum);
@@ -142,6 +148,12 @@ public class WorkerMonthAttendanceStatisticsServiceImpl extends ServiceImpl<Work
                 workerMonthAttendanceDurationMapper.insert(duration);
                 //workerMonthAttendanceDurationMapper.insertMonthAttendanceDuration(param);
             }
+            // 同步到湖里政务平台
+            WorkerMonthAttendanceStatistics syncData = workerMonthAttendanceStatisticsMapper.selectByCondition(param);
+            if (ObjectUtil.isNotNull(syncData)) {
+                govtOpenApiService.workerMonthAttendanceStatisticsSync(syncData);
+            }
+
         } catch (Exception e) {
             String err = new StringBuilder("计算人员的考勤状态失败")
                     .append(",inputTime:").append(inputTime)
diff --git a/src/main/java/com/zhgd/xmgl/task/GovtSyncTask.java b/src/main/java/com/zhgd/xmgl/task/GovtSyncTask.java
new file mode 100644
index 000000000..102a75642
--- /dev/null
+++ b/src/main/java/com/zhgd/xmgl/task/GovtSyncTask.java
@@ -0,0 +1,77 @@
+package com.zhgd.xmgl.task;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.zhgd.xmgl.modules.govtapi.GovtOpenApiService;
+import com.zhgd.xmgl.modules.realnamestatistics.entity.ProjectOperationsAnalysis;
+import com.zhgd.xmgl.modules.realnamestatistics.service.IProjectOperationsAnalysisService;
+import com.zhgd.xmgl.modules.worker.entity.WorkerAttendance;
+import com.zhgd.xmgl.modules.worker.entity.WorkerInfo;
+import com.zhgd.xmgl.modules.worker.entity.WorkerMonthAttendanceStatistics;
+import com.zhgd.xmgl.modules.worker.service.IWorkerAttendanceService;
+import com.zhgd.xmgl.modules.worker.service.IWorkerInfoService;
+import com.zhgd.xmgl.modules.worker.service.IWorkerMonthAttendanceStatisticsService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.time.DateUtils;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author HZI.HUI
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class GovtSyncTask {
+
+    private final GovtOpenApiService govtOpenApiService;
+    private final IWorkerInfoService workerInfoService;
+    private final IWorkerAttendanceService workerAttendanceService;
+    private final IProjectOperationsAnalysisService projectOperationsAnalysisService;
+    private final IWorkerMonthAttendanceStatisticsService workerMonthAttendanceStatisticsService;
+
+
+    @PostConstruct
+    public void initSyncWorkerInfoData() {
+        List<WorkerInfo> list = workerInfoService.list(Wrappers.<WorkerInfo>lambdaQuery()
+                .in(WorkerInfo::getProjectSn, "29E5B97B246544E0B0EF18534FA7C78D"));
+        for (WorkerInfo workerInfo : list) {
+            govtOpenApiService.workerInfoAddSync(workerInfo);
+        }
+        initSyncWorkerAttendanceData();
+        initProjectOperationsAnalysisData();
+        getMonthAttendanceStatistics();
+    }
+
+
+    public void initSyncWorkerAttendanceData() {
+        List<WorkerAttendance> list = workerAttendanceService.list(Wrappers.<WorkerAttendance>lambdaQuery()
+                .in(WorkerAttendance::getProjectSn, "29E5B97B246544E0B0EF18534FA7C78D"));
+        for (WorkerAttendance workerAttendance : list) {
+            govtOpenApiService.workerAttendanceSync(workerAttendance);
+        }
+    }
+
+
+
+    public void initProjectOperationsAnalysisData() {
+        List<ProjectOperationsAnalysis> list = projectOperationsAnalysisService.list(Wrappers.<ProjectOperationsAnalysis>lambdaQuery()
+                .in(ProjectOperationsAnalysis::getProjectSn, "29E5B97B246544E0B0EF18534FA7C78D"));
+        govtOpenApiService.projectOperationsAnalysisUpdateSync(list);
+    }
+
+
+
+    public void getMonthAttendanceStatistics() {
+        List<WorkerMonthAttendanceStatistics> list = workerMonthAttendanceStatisticsService.list(Wrappers.<WorkerMonthAttendanceStatistics>lambdaQuery()
+                .in(WorkerMonthAttendanceStatistics::getProjectSn, "29E5B97B246544E0B0EF18534FA7C78D"));
+        for (WorkerMonthAttendanceStatistics workerAttendance : list) {
+            govtOpenApiService.workerMonthAttendanceStatisticsSync(workerAttendance);
+        }
+    }
+}
diff --git a/src/main/resources/application-ljw.properties b/src/main/resources/application-ljw.properties
index 576e0eec2..50149904c 100644
--- a/src/main/resources/application-ljw.properties
+++ b/src/main/resources/application-ljw.properties
@@ -27,7 +27,7 @@ isGetEnvironmentData=false
 isGetFaceFeatureDate=false
 
 
-#海康视频报警图片IP端口替换
+#\u6D77\u5EB7\u89C6\u9891\u62A5\u8B66\u56FE\u7247IP\u7AEF\u53E3\u66FF\u6362
 video.alarm.newUrl=223.82.100.80:6040
 
 wx-appid=
@@ -37,29 +37,29 @@ mqtt-scope=devTopic
 
 serverUrl=http://47.97.202.104:6023
 #serverUrl=http://127.0.0.1:6023
-#视频分析url
+#\u89C6\u9891\u5206\u6790url
 video-analysis-url=
 
-#默认政务创建项目所属企�?
+#\u9ED8\u8BA4\u653F\u52A1\u521B\u5EFA\u9879\u76EE\u6240\u5C5E\u4F01\uFFFD?
 defaultZwComapnySn=
 
-#文件存储配置
-#默认使用的存储平�?
+#\u6587\u4EF6\u5B58\u50A8\u914D\u7F6E
+#\u9ED8\u8BA4\u4F7F\u7528\u7684\u5B58\u50A8\u5E73\uFFFD?
 spring.file-storage.default-platform=local
-#".min.jpg" #缩略图后缀，例如�?min.jpg】�?png�?
+#".min.jpg" #\u7F29\u7565\u56FE\u540E\u7F00\uFF0C\u4F8B\u5982\uFFFD?min.jpg\u3011\uFFFD?png\uFFFD?
 spring.file-storage.thumbnail-suffix=.jpg
-# 本地存储，不使用的情况下可以不写
-# 存储平台标识
+# \u672C\u5730\u5B58\u50A8\uFF0C\u4E0D\u4F7F\u7528\u7684\u60C5\u51B5\u4E0B\u53EF\u4EE5\u4E0D\u5199
+# \u5B58\u50A8\u5E73\u53F0\u6807\u8BC6
 spring.file-storage.local[0].platform=local
-#启用存储
+#\u542F\u7528\u5B58\u50A8
 spring.file-storage.local[0].enable-storage=true
-#启用访问（线上请使用 Nginx 配置，效率更高）
+#\u542F\u7528\u8BBF\u95EE\uFF08\u7EBF\u4E0A\u8BF7\u4F7F\u7528 Nginx \u914D\u7F6E\uFF0C\u6548\u7387\u66F4\u9AD8\uFF09
 spring.file-storage.local[0].enable-access=false
-# 访问域名，例如：“http://127.0.0.1:6023/image/”，注意后面要和 path-patterns 保持一致，�?”结尾，本地存储建议使用相对路径，方便后期更换域�?
+# \u8BBF\u95EE\u57DF\u540D\uFF0C\u4F8B\u5982\uFF1A\u201Chttp://127.0.0.1:6023/image/\u201D\uFF0C\u6CE8\u610F\u540E\u9762\u8981\u548C path-patterns \u4FDD\u6301\u4E00\u81F4\uFF0C\uFFFD?\u201D\u7ED3\u5C3E\uFF0C\u672C\u5730\u5B58\u50A8\u5EFA\u8BAE\u4F7F\u7528\u76F8\u5BF9\u8DEF\u5F84\uFF0C\u65B9\u4FBF\u540E\u671F\u66F4\u6362\u57DF\uFFFD?
 spring.file-storage.local[0].domain=
-# 存储地址
+# \u5B58\u50A8\u5730\u5740
 spring.file-storage.local[0].base-path=C:/itbgpImage/
-# 访问路径，开�?enable-access 后，通过此路径可以访问到上传的文�?
+# \u8BBF\u95EE\u8DEF\u5F84\uFF0C\u5F00\uFFFD?enable-access \u540E\uFF0C\u901A\u8FC7\u6B64\u8DEF\u5F84\u53EF\u4EE5\u8BBF\u95EE\u5230\u4E0A\u4F20\u7684\u6587\uFFFD?
 spring.file-storage.local[0].path-patterns=
 
 spring.file-storage.aliyun-oss[0].platform=aliyun-oss
@@ -68,11 +68,13 @@ spring.file-storage.aliyun-oss[0].access-key=
 spring.file-storage.aliyun-oss[0].secret-key=
 spring.file-storage.aliyun-oss[0].end-point=
 spring.file-storage.aliyun-oss[0].bucket-name=
-# 访问域名，注意�?”结尾，例如：https://abc.oss-cn-shanghai.aliyuncs.com/
+# \u8BBF\u95EE\u57DF\u540D\uFF0C\u6CE8\u610F\uFFFD?\u201D\u7ED3\u5C3E\uFF0C\u4F8B\u5982\uFF1Ahttps://abc.oss-cn-shanghai.aliyuncs.com/
 spring.file-storage.aliyun-oss[0].domain=
 spring.file-storage.aliyun-oss[0].base-path=
-#�ͻ��� License�������
+#\uFFFD\u037B\uFFFD\uFFFD\uFFFD License\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD
 
 license.licensePath=C:/license/license.lic
 license.publicKeysStorePath=C:/license/publicCerts.keystore
 
+# ????
+govt.host=http://47.96.183.143/uatapi