Merge remote-tracking branch 'origin/master'
# Conflicts: # xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
This commit is contained in:
commit
0608ce6fb7
|
|
@ -0,0 +1,88 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：站班会人员实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjClassMeetingPeople {
|
||||
/**
|
||||
* 主键ID
|
||||
*/
|
||||
private String id;
|
||||
/**
|
||||
* 准入生效日期
|
||||
*/
|
||||
private String registrationDate;
|
||||
/**
|
||||
* 准入失效期限
|
||||
*/
|
||||
private String validityPeriod;
|
||||
/**
|
||||
* 省公司编码
|
||||
*/
|
||||
private String provinceCode;
|
||||
/**
|
||||
* 创建人
|
||||
*/
|
||||
private String createrId;
|
||||
/**
|
||||
* 创建时间
|
||||
*/
|
||||
private String createTime;
|
||||
/**
|
||||
* 更新人
|
||||
*/
|
||||
private String updaterId;
|
||||
/**
|
||||
* 更新时间
|
||||
*/
|
||||
private String updateTime;
|
||||
/**
|
||||
* 删除状态；默认0，包括：0未删除，1已删除
|
||||
*/
|
||||
private String deleteFlag;
|
||||
/**
|
||||
* 工种编码
|
||||
*/
|
||||
private String workCode;
|
||||
/**
|
||||
* 人员id
|
||||
*/
|
||||
private String personnelId;
|
||||
/**
|
||||
* 站班会id
|
||||
*/
|
||||
private String toolBoxTalkId;
|
||||
/**
|
||||
* 姓名
|
||||
*/
|
||||
private String realName;
|
||||
/**
|
||||
* 身份证号
|
||||
*/
|
||||
private String idCard;
|
||||
/**
|
||||
* 岗位编码
|
||||
*/
|
||||
private String positionCode;
|
||||
/**
|
||||
* 是否安全监护人；包括：0-非安全监护人；1-安全监护人
|
||||
*/
|
||||
private String safetyGuardianFlag;
|
||||
/**
|
||||
* 是否在岗
|
||||
*/
|
||||
private String positionFlag;
|
||||
/**
|
||||
* 具体分工 1-施工人员， 2-新增人员（临时人员）
|
||||
*/
|
||||
private String workDivision;
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,168 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：站班会实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjClassMeetting {
|
||||
/**
|
||||
* 主键ID
|
||||
*/
|
||||
private String id;
|
||||
/**
|
||||
* 作业开始时间
|
||||
*/
|
||||
private String workStartTime;
|
||||
/**
|
||||
* 施工时间；施工日期
|
||||
*/
|
||||
private String currentConstrDate;
|
||||
/**
|
||||
* 当前施工状态 01-开始；02-暂停； 03-恢复；04-完成
|
||||
*/
|
||||
private String currentConstructionStatus;
|
||||
/**
|
||||
* 是否跨零点作业 和 施工作业票日施工作业任务关联 中跨零点作业是否一致 ，，一致，作业时间算第二天
|
||||
*/
|
||||
private String workOvernightFlag;
|
||||
/**
|
||||
* 站班会地址
|
||||
*/
|
||||
private String toolBoxTalkAddress;
|
||||
/**
|
||||
* 站班会地理坐标-经度
|
||||
*/
|
||||
private String toolBoxTalkLongitude;
|
||||
/**
|
||||
* 站班会地理坐标-纬度
|
||||
*/
|
||||
private String toolBoxTalkLatitude;
|
||||
/**
|
||||
* 距离站班会最近的作业部位ID；根据坐标获取最近的
|
||||
*/
|
||||
private String mcWorkSiteId;
|
||||
/**
|
||||
* 标段编码
|
||||
*/
|
||||
private String biddingSectionCode;
|
||||
/**
|
||||
* 标段名称
|
||||
*/
|
||||
private String biddingSectionName;
|
||||
/**
|
||||
* 离线标识：0-非离线，1-离线
|
||||
*/
|
||||
private String offOnlineFlag;
|
||||
/**
|
||||
* 单项工程编码
|
||||
*/
|
||||
private String singleProjectCode;
|
||||
/**
|
||||
* 单项工程名称
|
||||
*/
|
||||
private String singleProjectName;
|
||||
/**
|
||||
* 单项工程类型
|
||||
*/
|
||||
private String singleProjectType;
|
||||
/**
|
||||
* 施工单位统一社会信用代码
|
||||
*/
|
||||
private String constrUnifiedSocialCreditId;
|
||||
/**
|
||||
* 监理单位名称
|
||||
*/
|
||||
private String supervisionUnitName;
|
||||
/**
|
||||
* 监理单位统一社会信用代码
|
||||
*/
|
||||
private String supervisionSocialCreditCode;
|
||||
/**
|
||||
* 电压等级编码
|
||||
*/
|
||||
private String voltageLevel;
|
||||
/**
|
||||
* 0:常规工程 1:特高压
|
||||
*/
|
||||
private String huvFlag;
|
||||
/**
|
||||
* 建设管理单位编码
|
||||
*/
|
||||
private String buildUnitCode;
|
||||
/**
|
||||
* 省公司编码
|
||||
*/
|
||||
private String provinceCode; /**
|
||||
* 创建人
|
||||
*/
|
||||
private String createrId;
|
||||
/**
|
||||
* 项目名称
|
||||
*/
|
||||
private String prjName;
|
||||
/**
|
||||
* 创建时间
|
||||
*/
|
||||
private String createTime;
|
||||
/**
|
||||
* 更新人
|
||||
*/
|
||||
private String updaterId;
|
||||
/**
|
||||
* 更新时间
|
||||
*/
|
||||
private String updateTime;
|
||||
/**
|
||||
* 删除状态；默认0，包括：0未删除，1已删除
|
||||
*/
|
||||
private String deleteFlag;
|
||||
/**
|
||||
* 风险底数一本账id
|
||||
*/
|
||||
private String riskPrecautionId;
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String talkDesStatusChangeId;
|
||||
private String fileId;
|
||||
/**
|
||||
* 布控球id
|
||||
*/
|
||||
private String cameraId;
|
||||
/**
|
||||
* 项目编码
|
||||
*/
|
||||
private String prjCode;
|
||||
/**
|
||||
* 作业票id
|
||||
*/
|
||||
private String ticketId;
|
||||
/**
|
||||
* 作业票编号
|
||||
*/
|
||||
private String ticketNo;
|
||||
/**
|
||||
* 复测风险等级
|
||||
*/
|
||||
private String reAssessmentRiskLevel;
|
||||
/**
|
||||
* 当日作业人数
|
||||
*/
|
||||
private String currentConstrHeadcount;
|
||||
/**
|
||||
* 施工人数是当前班组人数
|
||||
*/
|
||||
private String constructionHeadcount;
|
||||
/**
|
||||
* 状态变更时间
|
||||
*/
|
||||
private String changeTime;
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,47 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：项目部实体类
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjDeptGcProject{
|
||||
private String id; //主键ID
|
||||
private String deptId; //项目部ID
|
||||
private String prjCode; //项目编码
|
||||
private String singleProjectCode; //单项工程编码
|
||||
private String biddingSectionCode; //标段编码
|
||||
private String disbandFlag; //是否解散；0：否；1：是；
|
||||
private String dDeleteFlag; //删除状态；默认 0；0：未删除；1：已删除
|
||||
private String year; //年份；默认当前年
|
||||
private String provinceCode; //省公司编码
|
||||
private String buildUnitCode; //建设管理单位编码
|
||||
private String projectDeptNo; //项目部编码
|
||||
private String projectDepartmentName; //项目部名称
|
||||
private String affiliationCode; //所属单位编码
|
||||
private String establishmentDate; //成立日期
|
||||
private String deptProvinceCode; //项目部地址省编码
|
||||
private String deptCitiesCode; //项目部地址市编码
|
||||
private String deptDistrictCode; //项目部地址区编码
|
||||
private String address; //详细地址
|
||||
private String postalCode; //邮政编码
|
||||
private String contactTelephone; //办公电话
|
||||
private String emailAddress; //电子邮箱
|
||||
private String faxNo; //传真号码
|
||||
private String groupMarkup; //是否为班组式；0：否；1：是；
|
||||
private String departmentType; //是否为班组式；0：否；1：是；
|
||||
private String departmentStatus; //项目部文件签署状态；0：通知已签署；1：通知未签署;
|
||||
private String historyFlag; //是否历史；默认 0；0：否；1：是
|
||||
private String pDeleteFlag; //删除状态；默认 0；0：未删除；1：已删除
|
||||
private String createrId; //创建人
|
||||
private String createTime; //创建时间
|
||||
private String updaterId; //修改人
|
||||
private String updateTime; //修改时间
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,79 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：杆塔实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjGt{
|
||||
private String id; //主键
|
||||
private String topography; //地形地貌；
|
||||
private String stentFlag; //是否架构；1是、0否
|
||||
private String borrowedFlag; //是否借用塔；1是、0否。
|
||||
private String span; //档距；
|
||||
private String towerCuircuitNumber; //杆塔回数；0 单回,1 双回,2 三回,3 四回,4 六回
|
||||
private String circuitQuantity; //线路回数；0 单回,1 双回,2 三回,3 四回,4 六回
|
||||
private String longitude; //经度；
|
||||
private String latitude; //纬度；
|
||||
private String eastCoordinate; //东坐标；
|
||||
private String northCoordinate; //北坐标；
|
||||
private String singleProjectCode; //单项工程编码
|
||||
private String centerPileElevation; //中心桩高程；
|
||||
private String rotationDegree; //转角度数；
|
||||
private String geology; //地质；
|
||||
private String towerLegBaseformFirst; //塔脚1基础形式；0装配式,1非装配式,2灌注桩,3其他,阶梯基础,4直柱大板基础,5斜柱基础,6角钢插入基础,7岩石基础,8半掏挖基础,9掏挖基础,10岩石嵌固基础. (支持手动录入)
|
||||
private String towerLegBaseformSecond; //塔脚2基础形式；
|
||||
private String towerLegBaseformThird; //塔脚3基础形式；
|
||||
private String towerLegBaseformFourth; //塔脚4基础形式；
|
||||
private String towerLegMaxDepthFirst; //塔脚1基础最大深度m
|
||||
private String towerLegMaxDepthSecond; //塔脚2基础最大深度m；
|
||||
private String towerLegMaxDepthThird; //塔脚3基础最大深度m；
|
||||
private String biddingSectionCode; //标段编码
|
||||
private String towerLegMaxDepthFourth; //塔脚4基础最大深度m；
|
||||
private String towerType; //杆塔型式
|
||||
private String tensionTowerFlag; //1) 名称: 是否耐张塔 2)1是 0否
|
||||
private String towerStructure; //杆塔结构 2）描述
|
||||
private String createrId; //
|
||||
private String createTime; //
|
||||
private String updaterId; //
|
||||
private String updateTime; //
|
||||
private String deleteFlag; //
|
||||
private String provinceCode; //省公司编码
|
||||
private String generalDesignFlag; //是否应用通用设计；1是、0否。
|
||||
private String towerTypeNo; //塔型编号
|
||||
private String upstreamTowerNo; //上行塔号
|
||||
private String dismantleFlag; //是否拆旧 1是 0否
|
||||
private String cover4gFlag; //4g信号是否覆盖 1是 0否
|
||||
private String towerSequenceNo; //杆塔排列序号，默认0起 逐次+1
|
||||
private String remark; //备注
|
||||
private String representativeSpan; //代表档距
|
||||
private String tensionSectionLength; //耐张段长度
|
||||
private String county; //区县
|
||||
private String town; //乡镇
|
||||
private String towerNo; //塔号；
|
||||
private String village; //村庄
|
||||
private String runTowerCode; //运行塔号
|
||||
private String groundThingName; //地上物
|
||||
private String designChangeNo; //设计变更编号
|
||||
private String sectionDividePointFlag; //1) 是否区段点击杆塔 区段划分时用到的，被定位就 1 没有为0或null
|
||||
private String sectionAdjustNum; //1) 区段划分调整量 用于区段划分中区段调整量 向前为-0.00 向后为+0.00
|
||||
private String towerWeight; //塔重
|
||||
private String slope; //塔基坡度
|
||||
private String constructionDeptId; //施工项目部id
|
||||
private String supervisionDeptId; //监理项目部id
|
||||
private String moduleNo; //模块编号；
|
||||
private String deviseDeptId; //设计项目部id
|
||||
private String ownerDeptId; //业主项目部id
|
||||
private String uhvFlag; //
|
||||
private String address; //细地址
|
||||
private String customFlag; //自定义标识
|
||||
private String nominalHeight; //呼称高；
|
||||
private String towerFullHeight; //塔全高；
|
||||
private String majorCrossingFlag; //重要跨越跨越物；
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：扩展信息实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjInfo {
|
||||
private String id; //
|
||||
private String replenishContent1; //补充内容
|
||||
private String replenishContent2; //补充内容
|
||||
private String replenishContent3; //补充内容
|
||||
private String replenishContent4; //补充内容
|
||||
private String replenishContent5; //补充内容
|
||||
private String replenishContent6; //补充内容
|
||||
private String replenishContent7; //补充内容
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除
|
||||
private String createTime; //
|
||||
private String updateTime; //
|
||||
private String refId; //外键id；
|
||||
private String refId2; //外键id；
|
||||
private String sortNo; //排序号
|
||||
private String extType; //扩展类型：10：风险预控措施,20：施工作业票_预控措施30：预控措施_站班会40：施工作业票_扩展信息50：风险底数一本账_扩展信息 60：站班会_扩展信息 70：站班会_拆分扩展信息
|
||||
private String contentType; //ext_type 10：预控措施类型；包括：01-风险库；02-风险清册；03-风险底数一本账；04-一览表 20：预控措施 30：预控措施 40：内容类型；包括：01-变化情况；02-情况控制措施；03-主要风险 50：内容类型；包括：01-备注；02-风险可能导致后果；03-风险控制关键因素；04-作业部位名称；05-一览表作业部位名称 60：当日控制措施 70：内容类型；包括：01-备注；02-现场风险复测变化情况及补充措施；03-风险异常原因；04-补充安全控制措施
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,39 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：到岗到位实体类
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjOnDuty{
|
||||
private String id; //主键ID
|
||||
private String biddingSectionCode; //标段编码
|
||||
private String singleProjectCode; //单项工程编码
|
||||
private String prjCode; //项目编码
|
||||
private String idCard; //身份证号
|
||||
private String buildUnitCode; //建设管理单位编码
|
||||
private String provinceCode; //省公司编码
|
||||
private String createrId; //创建人
|
||||
private String createTime; //创建时间
|
||||
private String updaterId; //更新人
|
||||
private String updateTime; //更新时间
|
||||
private String toolBoxTalkId; //站班会id
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除
|
||||
private String ondutyLongitude; //到岗到位经度
|
||||
private String ondutyLatitude; //到岗到位纬度
|
||||
private String ondutyAddress; //地址
|
||||
private String personnelId; //人员id
|
||||
private String realName; //现场监督人员姓名；
|
||||
private String unitName; //现场监督人员单位名
|
||||
private String positionCode; //岗位编码
|
||||
private String mobile; //手机号码
|
||||
private String ondutyHierarchy; //履职人员所属层级；包括：10施工，20监理，30业主,40建管，50省公司
|
||||
private String remark; //备注
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,51 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：风险底数一本帐实体类
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjRiskPrecaution{
|
||||
private String id; //主键ID
|
||||
private String partSubentry; //分部分项
|
||||
private String workType; //作业类型
|
||||
private String workProcedure; //工序
|
||||
private String assessmentRiskLevel; //初勘风险等级
|
||||
private String reAssessmentRiskLevel; //复测风险等级
|
||||
private String minConstrHeadcount; //最少施工人数
|
||||
private String riskAssessmentValue; //风险评估值(D)
|
||||
private String workContent; //作业内容
|
||||
private String workingCondition; //8+2工况
|
||||
private String voltageDrpFlag; //是否压降
|
||||
private String sourceRiskPrecautionId; //风险底数一本账源头id
|
||||
private String merge; //合并作业分组
|
||||
private String riskStatus; //风险状态；包括：01-待执行，02-执行中，03-已完成，04-已销号
|
||||
private String publishState; //发布状态 01 待提交 02 已发布
|
||||
private String plannedStartDate; //计划开始时间
|
||||
private String executeTime; //执行时间
|
||||
private String endTime; //结束时间
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
private String provinceCode; //省公司编码
|
||||
private String createrId; //创建人
|
||||
private String riskNo; //风险编号
|
||||
private String createTime; //创建时间
|
||||
private String updaterId; //更新人
|
||||
private String updateTime; //更新时间
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除
|
||||
private String workingConditionFlag; //是否8+2工况，默认0；包括：0否，1是
|
||||
private String constrMethId; //工法ID；工法ID，字符串拼接，使用“,”隔开单项工程编码
|
||||
private String singleProjectCode; //单项工程编码
|
||||
private String biddingSectionCode; //标段编码
|
||||
private String workSiteId; //作业部位id
|
||||
private String workSiteName; //作业部位名称
|
||||
private String workSiteType; //作业部位类型；1-变电，2-电力井，3-杆塔，4-区段
|
||||
private String professional; //工程类型
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,120 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：单项工程实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjSingleProject{
|
||||
private String id; //主键ID
|
||||
private String singleProjectType; //单项工程类型
|
||||
private String jgjsverSpecialProjectExpense; //特殊项目费
|
||||
private String jgjsverAuxiliaryFacilitiesCost; //辅助设施工程
|
||||
private String jgjsverCostFileName; //造价文件名称
|
||||
private String jgjsverProjectType; //造价的工程类型
|
||||
private String jgjsverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算
|
||||
private String jgjsverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回
|
||||
private String singleProjectPrerType; //单项工程预规类型
|
||||
private String singleProjectDetailsType; //单项工程明细类型
|
||||
private String constrNature; //建设性质
|
||||
private String constructionLineLength; //建设线路长度
|
||||
private String constrTransformerCapacity; //建设变电容量
|
||||
private String productionLineLength; //投产线路长度
|
||||
private String prodTransCapacity; //投产变电容量
|
||||
private String feaLineLength; //可研线路长度
|
||||
private String feasTransCapacity; //可研变电容量
|
||||
private String prjCode; //项目编码
|
||||
private String lineQuantity; //线路条数
|
||||
private String mainTransformerQuantity; //主变台数
|
||||
private String feaDinvest; //可研动态投资
|
||||
private String feaSinvest; //可研静态投资
|
||||
private String applyFlag; //是否申请创优工程，默认0， 0：否；1：是
|
||||
private String integrateIntosysFlag; //是否纳入系统管理：0：否；1：是；
|
||||
private String status; //状态：0：未提交；1：已提交；
|
||||
private String plannedCommencementDate; //计划开工时间
|
||||
private String actualCommencementDate; //实际开工时间
|
||||
private String plannedCommissioningDate; //计划投产时间
|
||||
private String singleProjectCode; //单项工程编码
|
||||
private String actualCommissioningDate; //实际投产时间
|
||||
private String planComplDate; //计划竣工时间
|
||||
private String actualCompletionDate; //实际竣工时间
|
||||
private String constructionStatus; //在建状态：默认0：0：施工；1：暂停；
|
||||
private String constrAddress; //建设地址
|
||||
private String locationProvince; //单项所在省编码，
|
||||
private String locationProvinceName; //单项所在省名称
|
||||
private String locationMunicipality; //单项所在市编码
|
||||
private String locationMunicipalityName; //单项所在市名称，
|
||||
private String locationArea; //单项所在区/县编码，
|
||||
private String singleProjectName; //单项工程
|
||||
private String locationAreaName; //单项所在区/县名称
|
||||
private String deleteFlag; //删除状态：默认 0；0：未删除；1：已删除
|
||||
private String createrId; //创建人
|
||||
private String createTime; //创建时间
|
||||
private String updaterId; //修改人
|
||||
private String updateTime; //修改时间
|
||||
private String gspfverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算
|
||||
private String gspfverVersion; //版本；GSPFVER：概算审定版
|
||||
private String gspfverDynamicInvestment; //单项动态投资
|
||||
private String gspfverStaticInvestment; //单项静态投资
|
||||
private String provinceCode; //省公司编码；
|
||||
private String gspfverConstructionCost; //建筑工程费
|
||||
private String gspfverInstallationCost; //安装工程费
|
||||
private String gspfverCostOfEquipProcurement; //设备购置费
|
||||
private String gspfverOtherExpenses; //其他工程费
|
||||
private String gspfverBasicContingency; //基本预备费
|
||||
private String gspfverSpecialProjectExpense; //特殊项目费
|
||||
private String gspfverAuxiliaryFacilitiesCost; //辅助设施工程
|
||||
private String gspfverCostFileName; //造价文件名称
|
||||
private String gspfverProjectType; //造价的工程类型
|
||||
private String gspfverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算
|
||||
private String provinceName; //省公司名称
|
||||
private String gspfverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回
|
||||
private String sgtssverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算
|
||||
private String sgtssverVersion; //版本；SGTSSVER：预算建安版、
|
||||
private String sgtssverDynamicInvestment; //单项动态投资
|
||||
private String sgtssverStaticInvestment; //单项静态投资
|
||||
private String sgtssverConstructionCost; //建筑工程费
|
||||
private String sgtssverInstallationCost; //安装工程费
|
||||
private String sgtssverCostOfEquipProcurement; //设备购置费
|
||||
private String sgtssverOtherExpenses; //其他工程费
|
||||
private String sgtssverBasicContingency; //基本预备费
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
private String sgtssverSpecialProjectExpense; //特殊项目费
|
||||
private String sgtssverAuxiliaryFacilitiesCost; //辅助设施工程
|
||||
private String sgtssverCostFileName; //造价文件名称
|
||||
private String sgtssverProjectType; //造价的工程类型
|
||||
private String sgtssverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算
|
||||
private String sgtssverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回
|
||||
private String sgtpfverStag; //阶段；
|
||||
private String sgtpfverVersion; //版本；SGTPFVER：预算全口径版
|
||||
private String sgtpfverDynamicInvestment; //单项动态投资
|
||||
private String sgtpfverStaticInvestment; //单项静态投资
|
||||
private String buildUnitName; //建设管理单位名称；
|
||||
private String sgtpfverConstructionCost; //建筑工程费
|
||||
private String sgtpfverInstallationCost; //安装工程费
|
||||
private String sgtpfverCostOfEquipProcurement; //设备购置费
|
||||
private String sgtpfverOtherExpenses; //其他工程费
|
||||
private String sgtpfverBasicContingency; //基本预备费
|
||||
private String sgtpfverSpecialProjectExpense; //特殊项目费
|
||||
private String sgtpfverAuxiliaryFacilitiesCost; //辅助设施工程
|
||||
private String sgtpfverCostFileName; //造价文件名称
|
||||
private String sgtpfverProjectType; //造价的工程类型
|
||||
private String sgtpfverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算
|
||||
private String voltageLevel; //电压等级编码
|
||||
private String sgtpfverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回
|
||||
private String jgjsverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算
|
||||
private String jgjsverVersion; //版本；JGJSVER：结算审定版
|
||||
private String jgjsverDynamicInvestment; //单项动态投资
|
||||
private String jgjsverStaticInvestment; //单项静态投资
|
||||
private String jgjsverConstructionCost; //建筑工程费
|
||||
private String jgjsverInstallationCost; //安装工程费
|
||||
private String jgjsverCostOfEquipProcurement; //设备购置费
|
||||
private String jgjsverOtherExpenses; //其他工程费
|
||||
private String jgjsverBasicContingency; //基本预备费
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,50 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-05-08-11:26
|
||||
* @version：1.0
|
||||
* @description：基建单位实体类
|
||||
*/
|
||||
@Data
|
||||
public class JjUnit{
|
||||
private String id; //主键
|
||||
private String legalReprMobile; //法定代表人手机号
|
||||
private String contactPhone; //联系方式；
|
||||
private String unitType; //单位类型（1-建设管理单位 2-勘察单位 3-设计单位 4-评审单位 5-监理单位 6-施工单位 7-分包单位 8-环保单位 99-其他）
|
||||
private String unitNature; //单位性质
|
||||
private String sysType; //系统类型；
|
||||
private String sysCateg; //系统分类；
|
||||
private String unitSign; //单位标识
|
||||
private String establishmentDate; //成立日期；
|
||||
private String registerCapital; //注册资本；
|
||||
private String website; //企业网站
|
||||
private String iscUnitId; //基建id
|
||||
private String province; //所在省
|
||||
private String city; //所在市
|
||||
private String county; //所在县
|
||||
private String address; //单位地址
|
||||
private String mainBusiness; //经营范围；
|
||||
private String dataSource; //数据来源；
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
private String provinceCode; //网省编码
|
||||
private String buildUnitCode; //建设管理单位编码
|
||||
private String createrId; //创建人
|
||||
private String safetySgcUnitId; //安监id
|
||||
private String createTime; //创建时间
|
||||
private String updaterId; //修改人
|
||||
private String updateTime; //修改时间
|
||||
private String deleteFlag; //
|
||||
private String legalIdCard; //法人身份证号
|
||||
private String businessFileId; //营业执照照片id
|
||||
private String unitName; //单位全称
|
||||
private String unitAbbrName; //单位简称
|
||||
private String unitCode; //单位编码
|
||||
private String mainCode; //主数据单位编码
|
||||
private String unifiedSocialCreditId; //统一社会信用代码
|
||||
private String legalRepr; //法定代表人
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,101 @@
|
|||
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);
|
||||
}
|
||||
|
|
@ -3,6 +3,7 @@ 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;
|
||||
|
|
@ -20,6 +21,9 @@ public class DataCenterService {
|
|||
@Autowired
|
||||
private InterMapper mapper;
|
||||
|
||||
@Autowired
|
||||
private InterMapper2 mapper2;
|
||||
|
||||
/**
|
||||
* 数据存储入库
|
||||
* @param list
|
||||
|
|
@ -174,4 +178,94 @@ public class DataCenterService {
|
|||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertClassMeetingData(List<JjClassMeetting> list) {
|
||||
try{
|
||||
mapper2.insertClassMeetingData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("站班会数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertClassMeetingPeopleData(List<JjClassMeetingPeople> list) {
|
||||
try{
|
||||
mapper2.insertClassMeetingPeopleData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("站班会人员数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertSingleProjectData(List<JjSingleProject> list) {
|
||||
try{
|
||||
mapper2.insertSingleProjectData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("单项工程数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertOnDutyData(List<JjOnDuty> list) {
|
||||
try{
|
||||
mapper2.insertOnDutyData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("到岗到位数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertRiskPrecautionData(List<JjRiskPrecaution> list) {
|
||||
try{
|
||||
mapper2.insertRiskPrecautionData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("风险底数一本帐数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertUnitData(List<JjUnit> list) {
|
||||
try{
|
||||
mapper2.insertUnitData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("基建单位数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertInfoData(List<JjInfo> list) {
|
||||
try{
|
||||
mapper2.insertInfoData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("扩展数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertGtData(List<JjGt> list) {
|
||||
try{
|
||||
mapper2.insertGtData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("杆塔数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertDeptGcProjectData(List<JjDeptGcProject> list) {
|
||||
try{
|
||||
mapper2.insertDeptGcProjectData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("项目部数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,308 @@
|
|||
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")) {
|
||||
// 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")) {
|
||||
// getProInfo();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,206 @@
|
|||
<?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>
|
||||
Loading…
Reference in New Issue