diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java index 25f7629..1fbbebb 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java @@ -74,8 +74,93 @@ public interface InterMapper { void insertJjBidInfo(List list); /** - * + *工程 履历 * @param list */ void insertGcLlData(List list); + + /* + * 插入站班会数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 9:57 + */ + void insertClassMeetingData(List list); + + /* + * 插入站班会人员数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 10:21 + */ + void insertClassMeetingPeopleData(List list); + + /** + * 插入单项工程数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 13:49 + */ + void insertSingleProjectData(List list); + + /** + * 插入到岗到位数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:23 + */ + void insertOnDutyData(List list); + + /** + * 插入风险底数一本帐数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:35 + */ + void insertRiskPrecautionData(List list); + + /** + * 插入基建单位数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:49 + */ + void insertUnitData(List list); + + /** + * 插入扩展信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:08 + */ + void insertInfoData(List list); + + /** + * 插入杆塔信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:40 + */ + void insertGtData(List list); + + /** + * 插入项目部信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:56 + */ + void insertDeptGcProjectData(List list); } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java deleted file mode 100644 index 4da506b..0000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java +++ /dev/null @@ -1,101 +0,0 @@ -package com.xxl.job.executor.inter.mapper; - -import com.xxl.job.executor.inter.entity.*; -import org.apache.ibatis.annotations.Param; -import org.springframework.stereotype.Repository; - -import java.util.List; - -/** - * 数据接口数据层 - * - * @author 黑子 - */ -@Repository -public interface InterMapper2 { - - /* - * 插入站班会数据 - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 9:57 - */ - void insertClassMeetingData(List list); - - /* - * 插入站班会人员数据 - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 10:21 - */ - void insertClassMeetingPeopleData(List list); - - /** - * 插入单项工程数据 - * - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 13:49 - */ - void insertSingleProjectData(List list); - - /** - * 插入到岗到位数据 - * - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 14:23 - */ - void insertOnDutyData(List list); - - /** - * 插入风险底数一本帐数据 - * - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 14:35 - */ - void insertRiskPrecautionData(List list); - - /** - * 插入基建单位数据 - * - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 14:49 - */ - void insertUnitData(List list); - - /** - * 插入扩展信息数据 - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 15:08 - */ - void insertInfoData(List list); - - /** - * 插入杆塔信息数据 - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 15:40 - */ - void insertGtData(List list); - - /** - * 插入项目部信息数据 - * @param list - * @return void - * @author cwchen - * @date 2024/5/8 15:56 - */ - void insertDeptGcProjectData(List list); -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java index 4efa439..5d53e98 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java @@ -3,7 +3,6 @@ package com.xxl.job.executor.inter.service; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.executor.inter.entity.*; import com.xxl.job.executor.inter.mapper.InterMapper; -import com.xxl.job.executor.inter.mapper.InterMapper2; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -21,8 +20,6 @@ public class DataCenterService { @Autowired private InterMapper mapper; - @Autowired - private InterMapper2 mapper2; /** * 数据存储入库 @@ -181,7 +178,7 @@ public class DataCenterService { public void insertClassMeetingData(List list) { try{ - mapper2.insertClassMeetingData(list); + mapper.insertClassMeetingData(list); }catch (Exception e){ XxlJobHelper.log("站班会数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -191,7 +188,7 @@ public class DataCenterService { public void insertClassMeetingPeopleData(List list) { try{ - mapper2.insertClassMeetingPeopleData(list); + mapper.insertClassMeetingPeopleData(list); }catch (Exception e){ XxlJobHelper.log("站班会人员数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -201,7 +198,7 @@ public class DataCenterService { public void insertSingleProjectData(List list) { try{ - mapper2.insertSingleProjectData(list); + mapper.insertSingleProjectData(list); }catch (Exception e){ XxlJobHelper.log("单项工程数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -211,7 +208,7 @@ public class DataCenterService { public void insertOnDutyData(List list) { try{ - mapper2.insertOnDutyData(list); + mapper.insertOnDutyData(list); }catch (Exception e){ XxlJobHelper.log("到岗到位数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -221,7 +218,7 @@ public class DataCenterService { public void insertRiskPrecautionData(List list) { try{ - mapper2.insertRiskPrecautionData(list); + mapper.insertRiskPrecautionData(list); }catch (Exception e){ XxlJobHelper.log("风险底数一本帐数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -231,7 +228,7 @@ public class DataCenterService { public void insertUnitData(List list) { try{ - mapper2.insertUnitData(list); + mapper.insertUnitData(list); }catch (Exception e){ XxlJobHelper.log("基建单位数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -241,7 +238,7 @@ public class DataCenterService { public void insertInfoData(List list) { try{ - mapper2.insertInfoData(list); + mapper.insertInfoData(list); }catch (Exception e){ XxlJobHelper.log("扩展数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -251,7 +248,7 @@ public class DataCenterService { public void insertGtData(List list) { try{ - mapper2.insertGtData(list); + mapper.insertGtData(list); }catch (Exception e){ XxlJobHelper.log("杆塔数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); @@ -261,7 +258,7 @@ public class DataCenterService { public void insertDeptGcProjectData(List list) { try{ - mapper2.insertDeptGcProjectData(list); + mapper.insertDeptGcProjectData(list); }catch (Exception e){ XxlJobHelper.log("项目部数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java index 4187799..85bfba1 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java @@ -328,7 +328,273 @@ public class InterService { XxlJobHelper.handleFail(e.toString()); log.error(e.toString(), e); } - } + + /* + * 站班会 + * @return void + * @author cwchen + * @date 2024/5/8 9:49 + */ + public void getClassMeetingInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "1"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetting.class); + service.insertClassMeetingData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /* + * 站班会人员 + * @return void + * @author cwchen + * @date 2024/5/8 10:14 + */ + public void getClassMeetingPeopleInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "2"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetingPeople.class); + service.insertClassMeetingPeopleData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 单项工程 + * + * @return void + * @author cwchen + * @date 2024/5/8 13:48 + */ + public void getSingleProjectInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "3"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjSingleProject.class); + service.insertSingleProjectData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 到岗到位 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:22 + */ + public void getOnDutyInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "4"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjOnDuty.class); + service.insertOnDutyData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 风险底数一本帐 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:33 + */ + public void getRiskPrecautionInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "5"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjRiskPrecaution.class); + service.insertRiskPrecautionData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 基建单位 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:48 + */ + public void getUnitInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "6"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjUnit.class); + service.insertUnitData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 扩展信息 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:58 + */ + public void getInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "7"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjInfo.class); + service.insertInfoData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 杆塔 + * + * @return void + * @author cwchen + * @date 2024/5/8 15:37 + */ + public void getGtInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "8"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjGt.class); + service.insertGtData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + /** + * 项目部 + * @return void + * @author cwchen + * @date 2024/5/8 15:55 + */ + public void getDeptGcProject() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "9"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjDeptGcProject.class); + service.insertDeptGcProjectData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getDeptGcProject(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java deleted file mode 100644 index ce041e8..0000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java +++ /dev/null @@ -1,308 +0,0 @@ -package com.xxl.job.executor.inter.service; - -import cn.hutool.http.HttpResponse; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; -import com.xxl.job.core.context.XxlJobHelper; -import com.xxl.job.executor.inter.config.GlobalConfig; -import com.xxl.job.executor.inter.entity.*; -import com.xxl.job.executor.inter.utils.DataUtils; -import com.xxl.job.executor.inter.utils.PostUtils; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; - -import java.util.List; -import java.util.Map; - -/** - * 业务工程管理 - * - * @author cwchen - */ -@Service -@Slf4j -public class InterService2 { - - @Autowired - private DataCenterService service; - - - /** - * 分页 - */ - public Integer pageNum = 1; - /** - * 分页默认条数 - */ - public Integer pageSize = 10; - - - /* - * 站班会 - * @return void - * @author cwchen - * @date 2024/5/8 9:49 - */ - public void getClassMeetingInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "1"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetting.class); - service.insertClassMeetingData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getClassMeetingInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /* - * 站班会人员 - * @return void - * @author cwchen - * @date 2024/5/8 10:14 - */ - public void getClassMeetingPeopleInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "2"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetingPeople.class); - service.insertClassMeetingPeopleData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getClassMeetingPeopleInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 单项工程 - * - * @return void - * @author cwchen - * @date 2024/5/8 13:48 - */ - public void getSingleProjectInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "3"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjSingleProject.class); - service.insertSingleProjectData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getSingleProjectInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 到岗到位 - * - * @return void - * @author cwchen - * @date 2024/5/8 14:22 - */ - public void getOnDutyInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "4"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjOnDuty.class); - service.insertOnDutyData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getOnDutyInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 风险底数一本帐 - * - * @return void - * @author cwchen - * @date 2024/5/8 14:33 - */ - public void getRiskPrecautionInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "5"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjRiskPrecaution.class); - service.insertRiskPrecautionData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getRiskPrecautionInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 基建单位 - * - * @return void - * @author cwchen - * @date 2024/5/8 14:48 - */ - public void getUnitInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "6"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjUnit.class); - service.insertUnitData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getUnitInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 扩展信息 - * - * @return void - * @author cwchen - * @date 2024/5/8 14:58 - */ - public void getInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "7"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjInfo.class); - service.insertInfoData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 杆塔 - * - * @return void - * @author cwchen - * @date 2024/5/8 15:37 - */ - public void getGtInfo() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "8"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjGt.class); - service.insertGtData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getGtInfo(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } - - /** - * 项目部 - * @return void - * @author cwchen - * @date 2024/5/8 15:55 - */ - public void getDeptGcProject() { - try { - //当前页 - int pageNum = 1; - JSONObject obj = new JSONObject(); - obj.put("type", "9"); - HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); - Map map = DataUtils.getArray(httpResponse); - JSONArray array = (JSONArray) map.get("array"); - if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), JjDeptGcProject.class); - service.insertDeptGcProjectData(list); - pageNum++; - if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { - // getDeptGcProject(); - } - } - } catch (Exception e) { - XxlJobHelper.handleFail(e.toString()); - log.error(e.toString(), e); - } - } -} - diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java index 42d7d36..258db82 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java @@ -15,16 +15,22 @@ public class DataCenterXxlJob { @Autowired private InterService interService; + /** + * 项目信息 + */ @XxlJob("getProInfo") public void getProInfo(){ interService.getProInfo(); } + + /** + * 标段工程 + */ @XxlJob("getBidPro") public void getBidPro(){ interService.getBidPro(); } - /** * 班组信息获取 */ @@ -102,4 +108,105 @@ public class DataCenterXxlJob { public void getGcLL(){ interService.getGcLL(); } + + + + /** + * 站班会定时任务 + */ + @XxlJob("getClassMeetingInfo") + public void getClassMeetingInfo() { + interService.getClassMeetingInfo(); + } + + /** + * 站班会人员定时任务 + */ + @XxlJob("getClassMeetingPeopleInfo") + public void getClassMeetingPeopleInfo() { + interService.getClassMeetingPeopleInfo(); + } + + /** + * 单项工程定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:11 + */ + @XxlJob("getSingleProjectInfo") + public void getSingleProjectInfo() { + interService.getSingleProjectInfo(); + } + + /** + * 到岗到位定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:27 + */ + @XxlJob("getOnDutyInfo") + public void getOnDutyInfo() { + interService.getOnDutyInfo(); + } + + /** + * 风险底数一本帐定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:38 + */ + @XxlJob("getRiskPrecautionInfo") + public void getRiskPrecautionInfo() { + interService.getRiskPrecautionInfo(); + } + + /** + * 基建单位定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:53 + */ + @XxlJob("getUnitInfo") + public void getUnitInfo() { + interService.getUnitInfo(); + } + + /** + * 扩展信息定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:53 + */ + @XxlJob("getInfo") + public void getInfo() { + interService.getInfo(); + } + + /** + * 杆塔定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 15:45 + */ + @XxlJob("getGtInfo") + public void getGtInfo() { + interService.getGtInfo(); + } + + /** + * 项目部定时任务 + * @return void + * @author cwchen + * @date 2024/5/8 16:00 + */ + @XxlJob("getDeptGcProject") + public void getDeptGcProject() { + interService.getDeptGcProject(); + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml deleted file mode 100644 index c511f38..0000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml +++ /dev/null @@ -1,206 +0,0 @@ - - - - - - - REPLACE INTO - jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address, - tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag, - single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, - voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, - create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, - file_id,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, - current_constr_headcount,construction_headcount,change_time) VALUES - ( - #{item.id},#{item.workStartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, - #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, - #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, - #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, - #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId}, - #{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel}, - #{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime} - ) - - - - - REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag, - position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name, - validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES - ( - #{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag}, - #{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName}, - #{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate} - ) - - - - - REPLACE INTO jj_single_project(id, single_project_type, jgjsver_special_project_expense, - jgjsver_auxiliary_facilities_cost, jgjsver_cost_file_name, jgjsver_project_type, jgjsver_software_type, - jgjsver_status, single_project_prer_type, single_project_details_type, constr_nature, construction_line_length, - constr_transformer_capacity, production_line_length, prod_trans_capacity, fea_line_length, feas_trans_capacity, - prj_code, line_quantity, main_transformer_quantity, fea_dinvest, fea_sinvest, apply_flag, - integrate_intosys_flag, status, planned_commencement_date, actual_commencement_date, planned_commissioning_date, - single_project_code, actual_commissioning_date, plan_compl_date, actual_completion_date, construction_status, - constr_address, location_province, location_province_name, location_municipality, location_municipality_name, - location_area, single_project_name, location_area_name, delete_flag, creater_id, create_time, updater_id, - update_time, gspfver_stage, gspfver_version, gspfver_dynamic_investment, gspfver_static_investment, - province_code, gspfver_construction_cost, gspfver_installation_cost, gspfver_cost_of_equip_procurement, - gspfver_other_expenses, gspfver_basic_contingency, gspfver_special_project_expense, - gspfver_auxiliary_facilities_cost, gspfver_cost_file_name, gspfver_project_type, gspfver_software_type, - province_name, gspfver_status, sgtssver_stage, sgtssver_version, sgtssver_dynamic_investment, - sgtssver_static_investment, sgtssver_construction_cost, sgtssver_installation_cost, - sgtssver_cost_of_equip_procurement, sgtssver_other_expenses, sgtssver_basic_contingency, build_unit_code, - sgtssver_special_project_expense, sgtssver_auxiliary_facilities_cost, sgtssver_cost_file_name, - sgtssver_project_type, sgtssver_software_type, sgtssver_status, sgtpfver_stag, sgtpfver_version, - sgtpfver_dynamic_investment, sgtpfver_static_investment, BUILD_UNIT_NAME, sgtpfver_construction_cost, - sgtpfver_installation_cost, sgtpfver_cost_of_equip_procurement, sgtpfver_other_expenses, - sgtpfver_basic_contingency, sgtpfver_special_project_expense, sgtpfver_auxiliary_facilities_cost, - sgtpfver_cost_file_name, sgtpfver_project_type, sgtpfver_software_type, voltage_level, sgtpfver_status, - jgjsver_stage, jgjsver_version, jgjsver_dynamic_investment, jgjsver_static_investment, - jgjsver_construction_cost, jgjsver_installation_cost, jgjsver_cost_of_equip_procurement, jgjsver_other_expenses, - jgjsver_basic_contingency) VALUES - - ( - #{item.id},#{item.singleProjectType},#{item.jgjsverSpecialProjectExpense}, - #{item.jgjsverAuxiliaryFacilitiesCost},#{item.jgjsverCostFileName},#{item.jgjsverProjectType},#{item.jgjsverSoftwareType}, - #{item.jgjsverStatus},#{item.singleProjectPrerType},#{item.singleProjectDetailsType},#{item.constrNature},#{item.constructionLineLength}, - #{item.constrTransformerCapacity},#{item.productionLineLength},#{item.prodTransCapacity},#{item.feaLineLength},#{item.feasTransCapacity}, - #{item.prjCode},#{item.lineQuantity},#{item.mainTransformerQuantity},#{item.feaDinvest},#{item.feaSinvest},#{item.applyFlag}, - #{item.integrateIntosysFlag},#{item.status},#{item.plannedCommencementDate},#{item.actualCommencementDate},#{item.plannedCommissioningDate}, - #{item.singleProjectCode},#{item.actualCommissioningDate},#{item.planComplDate},#{item.actualCompletionDate},#{item.constructionStatus}, - #{item.constrAddress},#{item.locationProvince},#{item.locationProvinceName},#{item.locationMunicipality},#{item.locationMunicipalityName}, - #{item.locationArea},#{item.singleProjectName},#{item.locationAreaName},#{item.deleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId}, - #{item.updateTime},#{item.gspfverStage},#{item.gspfverVersion},#{item.gspfverDynamicInvestment},#{item.gspfverStaticInvestment}, - #{item.provinceCode},#{item.gspfverConstructionCost},#{item.gspfverInstallationCost},#{item.gspfverCostOfEquipProcurement}, - #{item.gspfverOtherExpenses},#{item.gspfverBasicContingency},#{item.gspfverSpecialProjectExpense}, - #{item.gspfverAuxiliaryFacilitiesCost},#{item.gspfverCostFileName},#{item.gspfverProjectType},#{item.gspfverSoftwareType}, - #{item.provinceName},#{item.gspfverStatus},#{item.sgtssverStage},#{item.sgtssverVersion},#{item.sgtssverDynamicInvestment}, - #{item.sgtssverStaticInvestment},#{item.sgtssverConstructionCost},#{item.sgtssverInstallationCost}, - #{item.sgtssverCostOfEquipProcurement},#{item.sgtssverOtherExpenses},#{item.sgtssverBasicContingency},#{item.buildUnitCode}, - #{item.sgtssverSpecialProjectExpense},#{item.sgtssverAuxiliaryFacilitiesCost},#{item.sgtssverCostFileName}, - #{item.sgtssverProjectType},#{item.sgtssverSoftwareType},#{item.sgtssverStatus},#{item.sgtpfverStag},#{item.sgtpfverVersion}, - #{item.sgtpfverDynamicInvestment},#{item.sgtpfverStaticInvestment},#{item.buildUnitName},#{item.sgtpfverConstructionCost}, - #{item.sgtpfverInstallationCost},#{item.sgtpfverCostOfEquipProcurement},#{item.sgtpfverOtherExpenses}, - #{item.sgtpfverBasicContingency},#{item.sgtpfverSpecialProjectExpense},#{item.sgtpfverAuxiliaryFacilitiesCost}, - #{item.sgtpfverCostFileName},#{item.sgtpfverProjectType},#{item.sgtpfverSoftwareType},#{item.voltageLevel},#{item.sgtpfverStatus}, - #{item.jgjsverStage},#{item.jgjsverVersion},#{item.jgjsverDynamicInvestment},#{item.jgjsverStaticInvestment}, - #{item.jgjsverConstructionCost},#{item.jgjsverInstallationCost},#{item.jgjsverCostOfEquipProcurement},#{item.jgjsverOtherExpenses}, - #{item.jgjsverBasicContingency} - ) - - - - - REPLACE INTO jj_on_duty(id, bidding_section_code, single_project_code, prj_code, id_card, build_unit_code, - province_code, creater_id, create_time, updater_id, update_time, tool_box_talk_id, delete_flag, - onduty_longitude, onduty_latitude, onduty_address, personnel_id, real_name, unit_name, position_code, mobile, - onduty_hierarchy, remark) VALUES - - ( - #{item.id},#{item.biddingSectionCode},#{item.singleProjectCode},#{item.prjCode},#{item.idCard},#{item.buildUnitCode}, - #{item.provinceCode},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime},#{item.toolBoxTalkId},#{item.deleteFlag}, - #{item.ondutyLongitude},#{item.ondutyLatitude},#{item.ondutyAddress},#{item.personnelId},#{item.realName},#{item.unitName},#{item.positionCode},#{item.mobile}, - #{item.ondutyHierarchy},#{item.remark} - ) - - - - - REPLACE INTO jj_risk_precaution(id, part_subentry, work_type, work_procedure, assessment_risk_level, - re_assessment_risk_level, min_constr_headcount, risk_assessment_value, work_content, working_condition, - voltage_drp_flag, source_risk_precaution_id, merge, risk_status, publish_state, planned_start_date, - execute_time, end_time, huv_flag, build_unit_code, province_code, creater_id, risk_no, create_time, updater_id, - update_time, delete_flag, working_condition_flag, constr_meth_id, single_project_code, bidding_section_code, - work_site_id, work_site_name, work_site_type, professional) VALUES - - ( - #{item.id},#{item.partSubentry},#{item.workType},#{item.workProcedure},#{item.assessmentRiskLevel}, - #{item.reAssessmentRiskLevel},#{item.minConstrHeadcount},#{item.riskAssessmentValue},#{item.workContent},#{item.workingCondition}, - #{item.voltageDrpFlag},#{item.sourceRiskPrecautionId},#{item.merge},#{item.riskStatus},#{item.publishState},#{item.plannedStartDate}, - #{item.executeTime},#{item.endTime},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.riskNo},#{item.createTime},#{item.updaterId}, - #{item.updateTime},#{item.deleteFlag},#{item.workingConditionFlag},#{item.constrMethId},#{item.singleProjectCode},#{item.biddingSectionCode}, - #{item.workSiteId},#{item.workSiteName},#{item.workSiteType},#{item.professional} - ) - - - - - REPLACE INTO jj_unit(id, legal_repr_mobile, contact_phone, unit_type, unit_nature, sys_type, sys_categ, - unit_sign, establishment_date, register_capital, website, isc_unit_id, province, city, county, address, - main_business, data_source, huv_flag, province_code, build_unit_code, creater_id, safety_sgc_unit_id, - create_time, updater_id, update_time, delete_flag, legal_id_card, business_file_id, unit_name, unit_abbr_name, - unit_code, main_code, unified_social_credit_id, legal_repr) VALUES - - ( - #{item.id},#{item.legalReprMobile},#{item.contactPhone},#{item.unitType},#{item.unitNature},#{item.sysType},#{item.sysCateg}, - #{item.unitSign},#{item.establishmentDate},#{item.registerCapital},#{item.website},#{item.iscUnitId},#{item.province},#{item.city},#{item.county},#{item.address}, - #{item.mainBusiness},#{item.dataSource},#{item.huvFlag},#{item.provinceCode},#{item.buildUnitCode},#{item.createrId},#{item.safetySgcUnitId}, - #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.legalIdCard},#{item.businessFileId},#{item.unitName},#{item.unitAbbrName}, - #{item.unitCode},#{item.mainCode},#{item.unifiedSocialCreditId},#{item.legalRepr} - ) - - - - - REPLACE INTO jj_info(id, replenish_content_1, replenish_content_2, replenish_content_3, replenish_content_4, - replenish_content_5, replenish_content_6, replenish_content_7, delete_flag, create_time, update_time, ref_id, - ref_id2, sort_no, ext_type, content_type) VALUES - - ( - #{item.id},#{item.replenishContent1},#{item.replenishContent2},#{item.replenishContent3},#{item.replenishContent4}, - #{item.replenishContent5},#{item.replenishContent6},#{item.replenishContent7},#{item.deleteFlag},#{item.createTime},#{item.updateTime},#{item.refId}, - #{item.refId2},#{item.sortNo},#{item.extType},#{item.contentType} - ) - - - - - REPLACE INTO jj_gt(id, topography, stent_flag, borrowed_flag, span, tower_cuircuit_number, circuit_quantity, - longitude, latitude, east_coordinate, north_coordinate, single_project_code, center_pile_elevation, - rotation_degree, geology, tower_leg_baseform_first, tower_leg_baseform_second, tower_leg_baseform_third, - tower_leg_baseform_fourth, tower_leg_max_depth_first, tower_leg_max_depth_second, tower_leg_max_depth_third, - bidding_section_code, tower_leg_max_depth_fourth, tower_type, tension_tower_flag, tower_structure, creater_id, - create_time, updater_id, update_time, delete_flag, province_code, general_design_flag, tower_type_no, - upstream_tower_no, dismantle_flag, cover4g_flag, tower_sequence_no, remark, representative_span, - tension_section_length, county, town, tower_no, village, run_tower_code, ground_thing_name, design_change_no, - section_divide_point_flag, section_adjust_num, tower_weight, slope, construction_dept_id, supervision_dept_id, - module_no, devise_dept_id, owner_dept_id, uhv_flag, address, custom_flag, nominal_height, tower_full_height, - major_crossing_flag) VALUES - - ( - #{item.id},#{item.topography},#{item.stentFlag},#{item.borrowedFlag},#{item.span},#{item.towerCuircuitNumber},#{item.circuitQuantity}, - #{item.longitude},#{item.latitude},#{item.eastCoordinate},#{item.northCoordinate},#{item.singleProjectCode},#{item.centerPileElevation}, - #{item.rotationDegree},#{item.geology},#{item.towerLegBaseformFirst},#{item.towerLegBaseformSecond},#{item.towerLegBaseformThird}, - #{item.towerLegBaseformFourth},#{item.towerLegMaxDepthFirst},#{item.towerLegMaxDepthSecond},#{item.towerLegMaxDepthThird}, - #{item.biddingSectionCode},#{item.towerLegMaxDepthFourth},#{item.towerType},#{item.tensionTowerFlag},#{item.towerStructure},#{item.createrId}, - #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.provinceCode},#{item.generalDesignFlag},#{item.towerTypeNo}, - #{item.upstreamTowerNo},#{item.dismantleFlag},#{item.cover4gFlag},#{item.towerSequenceNo},#{item.remark},#{item.representativeSpan}, - #{item.tensionSectionLength},#{item.county},#{item.town},#{item.towerNo},#{item.village},#{item.runTowerCode},#{item.groundThingName},#{item.designChangeNo}, - #{item.sectionDividePointFlag},#{item.sectionAdjustNum},#{item.towerWeight},#{item.slope},#{item.constructionDeptId},#{item.supervisionDeptId}, - #{item.moduleNo},#{item.deviseDeptId},#{item.ownerDeptId},#{item.uhvFlag},#{item.address},#{item.customFlag},#{item.nominalHeight},#{item.towerFullHeight}, - #{item.majorCrossingFlag} - ) - - - - - REPLACE INTO jj_dept_gc_project(id, dept_id, prj_code, single_project_code, bidding_section_code, disband_flag, - d_delete_flag, year, province_code, build_unit_code, project_dept_no, project_department_name, affiliation_code, - establishment_date, dept_province_code, dept_cities_code, dept_district_code, address, postal_code, - contact_telephone, email_address, fax_no, group_markup, department_type, department_status, history_flag, - p_delete_flag, creater_id, create_time, updater_id, update_time) VALUES - - ( - #{item.id},#{item.deptId},#{item.prjCode},#{item.singleProjectCode},#{item.biddingSectionCode},#{item.disbandFlag}, - #{item.dDeleteFlag},#{item.year},#{item.provinceCode},#{item.buildUnitCode},#{item.projectDeptNo},#{item.projectDepartmentName},#{item.affiliationCode}, - #{item.establishmentDate},#{item.deptProvinceCode},#{item.deptCitiesCode},#{item.deptDistrictCode},#{item.address},#{item.postalCode}, - #{item.contactTelephone},#{item.emailAddress},#{item.faxNo},#{item.groupMarkup},#{item.departmentType},#{item.departmentStatus},#{item.historyFlag}, - #{item.pDeleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime} - ) - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml index c3c5b71..e691cfb 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml @@ -276,5 +276,204 @@ ) - + + + REPLACE INTO + jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address, + tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag, + single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, + voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, + create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, + file_id,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, + current_constr_headcount,construction_headcount,change_time) VALUES + ( + #{item.id},#{item.workStartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, + #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, + #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, + #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId}, + #{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel}, + #{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime} + ) + + + + + REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag, + position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name, + validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES + ( + #{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag}, + #{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName}, + #{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate} + ) + + + + + REPLACE INTO jj_single_project(id, single_project_type, jgjsver_special_project_expense, + jgjsver_auxiliary_facilities_cost, jgjsver_cost_file_name, jgjsver_project_type, jgjsver_software_type, + jgjsver_status, single_project_prer_type, single_project_details_type, constr_nature, construction_line_length, + constr_transformer_capacity, production_line_length, prod_trans_capacity, fea_line_length, feas_trans_capacity, + prj_code, line_quantity, main_transformer_quantity, fea_dinvest, fea_sinvest, apply_flag, + integrate_intosys_flag, status, planned_commencement_date, actual_commencement_date, planned_commissioning_date, + single_project_code, actual_commissioning_date, plan_compl_date, actual_completion_date, construction_status, + constr_address, location_province, location_province_name, location_municipality, location_municipality_name, + location_area, single_project_name, location_area_name, delete_flag, creater_id, create_time, updater_id, + update_time, gspfver_stage, gspfver_version, gspfver_dynamic_investment, gspfver_static_investment, + province_code, gspfver_construction_cost, gspfver_installation_cost, gspfver_cost_of_equip_procurement, + gspfver_other_expenses, gspfver_basic_contingency, gspfver_special_project_expense, + gspfver_auxiliary_facilities_cost, gspfver_cost_file_name, gspfver_project_type, gspfver_software_type, + province_name, gspfver_status, sgtssver_stage, sgtssver_version, sgtssver_dynamic_investment, + sgtssver_static_investment, sgtssver_construction_cost, sgtssver_installation_cost, + sgtssver_cost_of_equip_procurement, sgtssver_other_expenses, sgtssver_basic_contingency, build_unit_code, + sgtssver_special_project_expense, sgtssver_auxiliary_facilities_cost, sgtssver_cost_file_name, + sgtssver_project_type, sgtssver_software_type, sgtssver_status, sgtpfver_stag, sgtpfver_version, + sgtpfver_dynamic_investment, sgtpfver_static_investment, BUILD_UNIT_NAME, sgtpfver_construction_cost, + sgtpfver_installation_cost, sgtpfver_cost_of_equip_procurement, sgtpfver_other_expenses, + sgtpfver_basic_contingency, sgtpfver_special_project_expense, sgtpfver_auxiliary_facilities_cost, + sgtpfver_cost_file_name, sgtpfver_project_type, sgtpfver_software_type, voltage_level, sgtpfver_status, + jgjsver_stage, jgjsver_version, jgjsver_dynamic_investment, jgjsver_static_investment, + jgjsver_construction_cost, jgjsver_installation_cost, jgjsver_cost_of_equip_procurement, jgjsver_other_expenses, + jgjsver_basic_contingency) VALUES + + ( + #{item.id},#{item.singleProjectType},#{item.jgjsverSpecialProjectExpense}, + #{item.jgjsverAuxiliaryFacilitiesCost},#{item.jgjsverCostFileName},#{item.jgjsverProjectType},#{item.jgjsverSoftwareType}, + #{item.jgjsverStatus},#{item.singleProjectPrerType},#{item.singleProjectDetailsType},#{item.constrNature},#{item.constructionLineLength}, + #{item.constrTransformerCapacity},#{item.productionLineLength},#{item.prodTransCapacity},#{item.feaLineLength},#{item.feasTransCapacity}, + #{item.prjCode},#{item.lineQuantity},#{item.mainTransformerQuantity},#{item.feaDinvest},#{item.feaSinvest},#{item.applyFlag}, + #{item.integrateIntosysFlag},#{item.status},#{item.plannedCommencementDate},#{item.actualCommencementDate},#{item.plannedCommissioningDate}, + #{item.singleProjectCode},#{item.actualCommissioningDate},#{item.planComplDate},#{item.actualCompletionDate},#{item.constructionStatus}, + #{item.constrAddress},#{item.locationProvince},#{item.locationProvinceName},#{item.locationMunicipality},#{item.locationMunicipalityName}, + #{item.locationArea},#{item.singleProjectName},#{item.locationAreaName},#{item.deleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId}, + #{item.updateTime},#{item.gspfverStage},#{item.gspfverVersion},#{item.gspfverDynamicInvestment},#{item.gspfverStaticInvestment}, + #{item.provinceCode},#{item.gspfverConstructionCost},#{item.gspfverInstallationCost},#{item.gspfverCostOfEquipProcurement}, + #{item.gspfverOtherExpenses},#{item.gspfverBasicContingency},#{item.gspfverSpecialProjectExpense}, + #{item.gspfverAuxiliaryFacilitiesCost},#{item.gspfverCostFileName},#{item.gspfverProjectType},#{item.gspfverSoftwareType}, + #{item.provinceName},#{item.gspfverStatus},#{item.sgtssverStage},#{item.sgtssverVersion},#{item.sgtssverDynamicInvestment}, + #{item.sgtssverStaticInvestment},#{item.sgtssverConstructionCost},#{item.sgtssverInstallationCost}, + #{item.sgtssverCostOfEquipProcurement},#{item.sgtssverOtherExpenses},#{item.sgtssverBasicContingency},#{item.buildUnitCode}, + #{item.sgtssverSpecialProjectExpense},#{item.sgtssverAuxiliaryFacilitiesCost},#{item.sgtssverCostFileName}, + #{item.sgtssverProjectType},#{item.sgtssverSoftwareType},#{item.sgtssverStatus},#{item.sgtpfverStag},#{item.sgtpfverVersion}, + #{item.sgtpfverDynamicInvestment},#{item.sgtpfverStaticInvestment},#{item.buildUnitName},#{item.sgtpfverConstructionCost}, + #{item.sgtpfverInstallationCost},#{item.sgtpfverCostOfEquipProcurement},#{item.sgtpfverOtherExpenses}, + #{item.sgtpfverBasicContingency},#{item.sgtpfverSpecialProjectExpense},#{item.sgtpfverAuxiliaryFacilitiesCost}, + #{item.sgtpfverCostFileName},#{item.sgtpfverProjectType},#{item.sgtpfverSoftwareType},#{item.voltageLevel},#{item.sgtpfverStatus}, + #{item.jgjsverStage},#{item.jgjsverVersion},#{item.jgjsverDynamicInvestment},#{item.jgjsverStaticInvestment}, + #{item.jgjsverConstructionCost},#{item.jgjsverInstallationCost},#{item.jgjsverCostOfEquipProcurement},#{item.jgjsverOtherExpenses}, + #{item.jgjsverBasicContingency} + ) + + + + + REPLACE INTO jj_on_duty(id, bidding_section_code, single_project_code, prj_code, id_card, build_unit_code, + province_code, creater_id, create_time, updater_id, update_time, tool_box_talk_id, delete_flag, + onduty_longitude, onduty_latitude, onduty_address, personnel_id, real_name, unit_name, position_code, mobile, + onduty_hierarchy, remark) VALUES + + ( + #{item.id},#{item.biddingSectionCode},#{item.singleProjectCode},#{item.prjCode},#{item.idCard},#{item.buildUnitCode}, + #{item.provinceCode},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime},#{item.toolBoxTalkId},#{item.deleteFlag}, + #{item.ondutyLongitude},#{item.ondutyLatitude},#{item.ondutyAddress},#{item.personnelId},#{item.realName},#{item.unitName},#{item.positionCode},#{item.mobile}, + #{item.ondutyHierarchy},#{item.remark} + ) + + + + + REPLACE INTO jj_risk_precaution(id, part_subentry, work_type, work_procedure, assessment_risk_level, + re_assessment_risk_level, min_constr_headcount, risk_assessment_value, work_content, working_condition, + voltage_drp_flag, source_risk_precaution_id, merge, risk_status, publish_state, planned_start_date, + execute_time, end_time, huv_flag, build_unit_code, province_code, creater_id, risk_no, create_time, updater_id, + update_time, delete_flag, working_condition_flag, constr_meth_id, single_project_code, bidding_section_code, + work_site_id, work_site_name, work_site_type, professional) VALUES + + ( + #{item.id},#{item.partSubentry},#{item.workType},#{item.workProcedure},#{item.assessmentRiskLevel}, + #{item.reAssessmentRiskLevel},#{item.minConstrHeadcount},#{item.riskAssessmentValue},#{item.workContent},#{item.workingCondition}, + #{item.voltageDrpFlag},#{item.sourceRiskPrecautionId},#{item.merge},#{item.riskStatus},#{item.publishState},#{item.plannedStartDate}, + #{item.executeTime},#{item.endTime},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.riskNo},#{item.createTime},#{item.updaterId}, + #{item.updateTime},#{item.deleteFlag},#{item.workingConditionFlag},#{item.constrMethId},#{item.singleProjectCode},#{item.biddingSectionCode}, + #{item.workSiteId},#{item.workSiteName},#{item.workSiteType},#{item.professional} + ) + + + + + REPLACE INTO jj_unit(id, legal_repr_mobile, contact_phone, unit_type, unit_nature, sys_type, sys_categ, + unit_sign, establishment_date, register_capital, website, isc_unit_id, province, city, county, address, + main_business, data_source, huv_flag, province_code, build_unit_code, creater_id, safety_sgc_unit_id, + create_time, updater_id, update_time, delete_flag, legal_id_card, business_file_id, unit_name, unit_abbr_name, + unit_code, main_code, unified_social_credit_id, legal_repr) VALUES + + ( + #{item.id},#{item.legalReprMobile},#{item.contactPhone},#{item.unitType},#{item.unitNature},#{item.sysType},#{item.sysCateg}, + #{item.unitSign},#{item.establishmentDate},#{item.registerCapital},#{item.website},#{item.iscUnitId},#{item.province},#{item.city},#{item.county},#{item.address}, + #{item.mainBusiness},#{item.dataSource},#{item.huvFlag},#{item.provinceCode},#{item.buildUnitCode},#{item.createrId},#{item.safetySgcUnitId}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.legalIdCard},#{item.businessFileId},#{item.unitName},#{item.unitAbbrName}, + #{item.unitCode},#{item.mainCode},#{item.unifiedSocialCreditId},#{item.legalRepr} + ) + + + + + REPLACE INTO jj_info(id, replenish_content_1, replenish_content_2, replenish_content_3, replenish_content_4, + replenish_content_5, replenish_content_6, replenish_content_7, delete_flag, create_time, update_time, ref_id, + ref_id2, sort_no, ext_type, content_type) VALUES + + ( + #{item.id},#{item.replenishContent1},#{item.replenishContent2},#{item.replenishContent3},#{item.replenishContent4}, + #{item.replenishContent5},#{item.replenishContent6},#{item.replenishContent7},#{item.deleteFlag},#{item.createTime},#{item.updateTime},#{item.refId}, + #{item.refId2},#{item.sortNo},#{item.extType},#{item.contentType} + ) + + + + + REPLACE INTO jj_gt(id, topography, stent_flag, borrowed_flag, span, tower_cuircuit_number, circuit_quantity, + longitude, latitude, east_coordinate, north_coordinate, single_project_code, center_pile_elevation, + rotation_degree, geology, tower_leg_baseform_first, tower_leg_baseform_second, tower_leg_baseform_third, + tower_leg_baseform_fourth, tower_leg_max_depth_first, tower_leg_max_depth_second, tower_leg_max_depth_third, + bidding_section_code, tower_leg_max_depth_fourth, tower_type, tension_tower_flag, tower_structure, creater_id, + create_time, updater_id, update_time, delete_flag, province_code, general_design_flag, tower_type_no, + upstream_tower_no, dismantle_flag, cover4g_flag, tower_sequence_no, remark, representative_span, + tension_section_length, county, town, tower_no, village, run_tower_code, ground_thing_name, design_change_no, + section_divide_point_flag, section_adjust_num, tower_weight, slope, construction_dept_id, supervision_dept_id, + module_no, devise_dept_id, owner_dept_id, uhv_flag, address, custom_flag, nominal_height, tower_full_height, + major_crossing_flag) VALUES + + ( + #{item.id},#{item.topography},#{item.stentFlag},#{item.borrowedFlag},#{item.span},#{item.towerCuircuitNumber},#{item.circuitQuantity}, + #{item.longitude},#{item.latitude},#{item.eastCoordinate},#{item.northCoordinate},#{item.singleProjectCode},#{item.centerPileElevation}, + #{item.rotationDegree},#{item.geology},#{item.towerLegBaseformFirst},#{item.towerLegBaseformSecond},#{item.towerLegBaseformThird}, + #{item.towerLegBaseformFourth},#{item.towerLegMaxDepthFirst},#{item.towerLegMaxDepthSecond},#{item.towerLegMaxDepthThird}, + #{item.biddingSectionCode},#{item.towerLegMaxDepthFourth},#{item.towerType},#{item.tensionTowerFlag},#{item.towerStructure},#{item.createrId}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.provinceCode},#{item.generalDesignFlag},#{item.towerTypeNo}, + #{item.upstreamTowerNo},#{item.dismantleFlag},#{item.cover4gFlag},#{item.towerSequenceNo},#{item.remark},#{item.representativeSpan}, + #{item.tensionSectionLength},#{item.county},#{item.town},#{item.towerNo},#{item.village},#{item.runTowerCode},#{item.groundThingName},#{item.designChangeNo}, + #{item.sectionDividePointFlag},#{item.sectionAdjustNum},#{item.towerWeight},#{item.slope},#{item.constructionDeptId},#{item.supervisionDeptId}, + #{item.moduleNo},#{item.deviseDeptId},#{item.ownerDeptId},#{item.uhvFlag},#{item.address},#{item.customFlag},#{item.nominalHeight},#{item.towerFullHeight}, + #{item.majorCrossingFlag} + ) + + + + + REPLACE INTO jj_dept_gc_project(id, dept_id, prj_code, single_project_code, bidding_section_code, disband_flag, + d_delete_flag, year, province_code, build_unit_code, project_dept_no, project_department_name, affiliation_code, + establishment_date, dept_province_code, dept_cities_code, dept_district_code, address, postal_code, + contact_telephone, email_address, fax_no, group_markup, department_type, department_status, history_flag, + p_delete_flag, creater_id, create_time, updater_id, update_time) VALUES + + ( + #{item.id},#{item.deptId},#{item.prjCode},#{item.singleProjectCode},#{item.biddingSectionCode},#{item.disbandFlag}, + #{item.dDeleteFlag},#{item.year},#{item.provinceCode},#{item.buildUnitCode},#{item.projectDeptNo},#{item.projectDepartmentName},#{item.affiliationCode}, + #{item.establishmentDate},#{item.deptProvinceCode},#{item.deptCitiesCode},#{item.deptDistrictCode},#{item.address},#{item.postalCode}, + #{item.contactTelephone},#{item.emailAddress},#{item.faxNo},#{item.groupMarkup},#{item.departmentType},#{item.departmentStatus},#{item.historyFlag}, + #{item.pDeleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime} + ) + + \ No newline at end of file