cwchen
/
ah_jjsp_data
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

初始化提交

This commit is contained in:
haozq 2024-05-08 16:18:12 +08:00
parent 847c257a53
commit 0fa013a492
8 changed files with 670 additions and 631 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java
View File

@ -74,8 +74,93 @@ public interface InterMapper {
void insertJjBidInfo(List<JjBidInfo> list);
/**
*
*工程 履历
* @param list
*/
void insertGcLlData(List<JjPrjEnginneringExperience> list);
/*
* 插入站班会数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 9:57
*/
void insertClassMeetingData(List<JjClassMeetting> list);
/*
* 插入站班会人员数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 10:21
*/
void insertClassMeetingPeopleData(List<JjClassMeetingPeople> list);
/**
* 插入单项工程数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 13:49
*/
void insertSingleProjectData(List<JjSingleProject> list);
/**
* 插入到岗到位数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:23
*/
void insertOnDutyData(List<JjOnDuty> list);
/**
* 插入风险底数一本帐数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:35
*/
void insertRiskPrecautionData(List<JjRiskPrecaution> list);
/**
* 插入基建单位数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:49
*/
void insertUnitData(List<JjUnit> list);
/**
* 插入扩展信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:08
*/
void insertInfoData(List<JjInfo> list);
/**
* 插入杆塔信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:40
*/
void insertGtData(List<JjGt> list);
/**
* 插入项目部信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:56
*/
void insertDeptGcProjectData(List<JjDeptGcProject> list);
}

101
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java
View File

@ -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<JjClassMeetting> list);
/*
* 插入站班会人员数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 10:21
*/
void insertClassMeetingPeopleData(List<JjClassMeetingPeople> list);
/**
* 插入单项工程数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 13:49
*/
void insertSingleProjectData(List<JjSingleProject> list);
/**
* 插入到岗到位数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:23
*/
void insertOnDutyData(List<JjOnDuty> list);
/**
* 插入风险底数一本帐数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:35
*/
void insertRiskPrecautionData(List<JjRiskPrecaution> list);
/**
* 插入基建单位数据
*
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 14:49
*/
void insertUnitData(List<JjUnit> list);
/**
* 插入扩展信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:08
*/
void insertInfoData(List<JjInfo> list);
/**
* 插入杆塔信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:40
*/
void insertGtData(List<JjGt> list);
/**
* 插入项目部信息数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 15:56
*/
void insertDeptGcProjectData(List<JjDeptGcProject> list);
}

21
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java
View File

@ -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<JjClassMeetting> 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<JjClassMeetingPeople> 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<JjSingleProject> 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<JjOnDuty> 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<JjRiskPrecaution> 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<JjUnit> 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<JjInfo> 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<JjGt> 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<JjDeptGcProject> list) {
try{
mapper2.insertDeptGcProjectData(list);
mapper.insertDeptGcProjectData(list);
}catch (Exception e){
XxlJobHelper.log("项目部数据处理异常内容--->{}",e.toString());
XxlJobHelper.handleFail(e.toString());

268
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java
View File

@ -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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetting> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetingPeople> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjSingleProject> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjOnDuty> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjRiskPrecaution> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjUnit> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjInfo> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjGt> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjDeptGcProject> 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);
}
}
}

308
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java
View File

@ -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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetting> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetingPeople> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjSingleProject> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjOnDuty> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjRiskPrecaution> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjUnit> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjInfo> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjGt> 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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjDeptGcProject> 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);
}
}
}

109
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
View File

@ -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();
}
}

206
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml
View File

@ -1,206 +0,0 @@
<?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.xxl.job.executor.inter.mapper.InterMapper2">
<!--插入站班会数据-->
<insert id="insertClassMeetingData">
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
<foreach collection="list" item="item" separator=",">(
#{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}
)
</foreach>
</insert>
<!--插入站班会人员数据-->
<insert id="insertClassMeetingPeopleData">
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
<foreach collection="list" item="item" separator=",">(
#{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}
)
</foreach>
</insert>
<!--插入单项工程数据-->
<insert id="insertSingleProjectData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入到岗到位数据-->
<insert id="insertOnDutyData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入风险底数一本帐数据-->
<insert id="insertRiskPrecautionData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入基建单位数据-->
<insert id="insertUnitData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入扩展信息数据-->
<insert id="insertInfoData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入杆塔数据-->
<insert id="insertGtData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入项目部数据-->
<insert id="insertDeptGcProjectData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
</mapper>

201
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml
View File

@ -276,5 +276,204 @@
)</foreach>
</insert>
<!--插入站班会数据-->
<insert id="insertClassMeetingData">
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
<foreach collection="list" item="item" separator=",">(
#{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}
)
</foreach>
</insert>
<!--插入站班会人员数据-->
<insert id="insertClassMeetingPeopleData">
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
<foreach collection="list" item="item" separator=",">(
#{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}
)
</foreach>
</insert>
<!--插入单项工程数据-->
<insert id="insertSingleProjectData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入到岗到位数据-->
<insert id="insertOnDutyData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入风险底数一本帐数据-->
<insert id="insertRiskPrecautionData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入基建单位数据-->
<insert id="insertUnitData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入扩展信息数据-->
<insert id="insertInfoData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入杆塔数据-->
<insert id="insertGtData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
<!--插入项目部数据-->
<insert id="insertDeptGcProjectData">
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
<foreach collection="list" item="item" separator=",">
(
#{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}
)
</foreach>
</insert>
</mapper>