初始化提交
This commit is contained in:
parent
ebbefc6946
commit
bc1f1755d7
|
|
@ -41,6 +41,7 @@ public class GenEntity {
|
|||
try {
|
||||
Class.forName(DRIVER);
|
||||
conn = DriverManager.getConnection(URL, NAME, PASS);
|
||||
conn.setCatalog("xxl_job");
|
||||
} catch (Exception e1) {
|
||||
e1.printStackTrace();
|
||||
}
|
||||
|
|
@ -64,7 +65,7 @@ public class GenEntity {
|
|||
//获取数据库的元数据
|
||||
DatabaseMetaData db = getConnection().getMetaData();
|
||||
//从元数据中获取到所有的表名
|
||||
rs = db.getTables(null, null, null, new String[] { "TABLE" });
|
||||
rs = db.getTables("xxl_job",null, null, new String[] { "TABLE" });
|
||||
while(rs.next()) {
|
||||
tableNames.add(rs.getString(3));
|
||||
}
|
||||
|
|
@ -88,10 +89,10 @@ public class GenEntity {
|
|||
System.out.println("===========autoCreateClass start==============");
|
||||
String packageName = GenEntity.class.getPackage().getName();
|
||||
List<String> tableName= getMysqlTableName(packageName);
|
||||
// tableName.stream().forEach(str ->{
|
||||
// genEntity(packageName , str);
|
||||
// });
|
||||
genEntity(packageName , "jj_project");
|
||||
tableName.stream().forEach(str ->{
|
||||
genEntity(packageName , str);
|
||||
});
|
||||
// genEntity(packageName , "jj_project");
|
||||
System.out.println("===========autoCreateClass end==============");
|
||||
}
|
||||
|
||||
|
|
@ -140,7 +141,7 @@ public class GenEntity {
|
|||
File directory = new File("");
|
||||
String path = GenEntity.class.getResource("").getPath();
|
||||
|
||||
FileWriter fw = new FileWriter("F:\\File\\"+ initcap(javaClassName)
|
||||
FileWriter fw = new FileWriter("F:\\File\\sql\\"+ initcap(javaClassName)
|
||||
+ ".java");
|
||||
PrintWriter pw = new PrintWriter(fw);
|
||||
pw.println(content);
|
||||
|
|
|
|||
|
|
@ -5,6 +5,8 @@ package com.xxl.job.executor.inter.config;
|
|||
*/
|
||||
public class GlobalConfig {
|
||||
|
||||
|
||||
|
||||
//申请接入时分配的 ebuild2AppId
|
||||
public static String ebuild2AppId = "test123456";
|
||||
//申请接入时分配的 sm2PubKey
|
||||
|
|
@ -17,6 +19,7 @@ public class GlobalConfig {
|
|||
|
||||
public final static String TEST_URL=IP_URL+"/biz-api/ifsct/up/sel/testInterface";
|
||||
|
||||
|
||||
/**
|
||||
* 电网基建项目
|
||||
*/
|
||||
|
|
@ -33,68 +36,94 @@ public class GlobalConfig {
|
|||
/**
|
||||
* 站班会信息
|
||||
*/
|
||||
public final static String ZBH_URL=IP_URL+"/test/getSmDwToolBoxTalk";
|
||||
public final static String ZBH_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmDwToolBoxTalk";
|
||||
/**
|
||||
* 施工作业任务-日
|
||||
*/
|
||||
public final static String RJH_URL=IP_URL+"/test/getSmDwConstructionTaskDesDaily";
|
||||
public final static String RJH_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmDwConstructionTaskDesDaily";
|
||||
/**
|
||||
* 安监人员
|
||||
*/
|
||||
public final static String AJ_RY_URL=IP_URL+"/test/getSmSafetyPersonnel";
|
||||
public final static String AJ_RY_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmSafetyPersonnel";
|
||||
|
||||
/**
|
||||
* 站班会人员
|
||||
*/
|
||||
public final static String ZBH_PEO_URL=IP_URL+"/test/getSmSafetyPersonnel";
|
||||
public final static String ZBH_PEO_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmSafetyPersonnel";
|
||||
|
||||
/**
|
||||
* 到岗到位人员
|
||||
*/
|
||||
public final static String DGDW_USER_URL=IP_URL+"/test/getSmOndutyRecord";
|
||||
public final static String DGDW_USER_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmOndutyRecord";
|
||||
|
||||
/**
|
||||
* 风险、作业票、站班会扩展信息
|
||||
*/
|
||||
public final static String DETAILS_URL=IP_URL+"/test/getSmDwDataStandardExt";
|
||||
public final static String DETAILS_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmDwDataStandardExt";
|
||||
|
||||
/**
|
||||
* 施工作业票
|
||||
*/
|
||||
public final static String SG_TICKET_URL=IP_URL+"/test/getSmConstructionWorkTicket";
|
||||
public final static String SG_TICKET_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmConstructionWorkTicket";
|
||||
|
||||
/**
|
||||
* 风险底数一本账
|
||||
*/
|
||||
public final static String RISK_DS_URL=IP_URL+"/test/getSmDwRiskPrecaution";
|
||||
|
||||
public final static String RISK_DS_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmDwRiskPrecaution";
|
||||
|
||||
/**
|
||||
* 施工作业票人员
|
||||
*/
|
||||
public final static String TICKET_USER_URL=IP_URL+"/test/getSmDwRiskPrecaution";
|
||||
public final static String TICKET_USER_URL=IP_URL+"/biz-api/ifsct/up/sel/smTicketDesMember";
|
||||
|
||||
/**
|
||||
* 施工作业任务_周
|
||||
*/
|
||||
public final static String SG_WEEK_URL=IP_URL+"/test/getSmDwRiskPrecaution";
|
||||
public final static String SG_WEEK_URL=IP_URL+"/biz-api/ifsct/up/sel/smDwConstructionTaskDesWeekly";
|
||||
|
||||
/**
|
||||
* 施工作业计划_日
|
||||
*/
|
||||
public final static String SG_DAY_URL=IP_URL+"/biz-api/ifsct/up/sel/smDwConstructionTaskDesDaily";
|
||||
|
||||
/**
|
||||
* 班组
|
||||
*
|
||||
*/
|
||||
public final static String WORK_TEAM_URL=IP_URL+"/test/getSmDwRiskPrecaution";
|
||||
public final static String WORK_TEAM_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmDwRiskPrecaution";
|
||||
/**
|
||||
* 安全-班组成员信息
|
||||
*
|
||||
*/
|
||||
public final static String TEAM_USER_URL=IP_URL+"/test/getSmWorkingTeamMember";
|
||||
public final static String TEAM_USER_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmWorkingTeamMember";
|
||||
|
||||
/**
|
||||
* 杆塔
|
||||
*/
|
||||
public final static String SG_GT_URL=IP_URL+"/test/getSmTowerSafety";
|
||||
public final static String SG_GT_URL=IP_URL+"/biz-api/ifsct/up/sel/getSmTowerSafety";
|
||||
|
||||
/**
|
||||
* 基建单位
|
||||
*/
|
||||
public final static String JJ_DW_URL=IP_URL+"/test/getBaseSgcUnit";
|
||||
public final static String JJ_DW_URL=IP_URL+"/biz-api/ifsct/up/sel/getBaseSgcUnit";
|
||||
/**
|
||||
* 安全人员信息
|
||||
*/
|
||||
public final static String AQ_ZR_USER_URL=IP_URL+"/biz-api/ifsct/up/sel/smSafetyPersonnel";
|
||||
|
||||
/**
|
||||
* 基建布控球
|
||||
*/
|
||||
public static final String JJ_BALL_URL = IP_URL+"/biz-api/ifsct/up/sel/getSmCamera";
|
||||
|
||||
/**
|
||||
* 标段安全 -信息
|
||||
*/
|
||||
public static final String JJ_BID_INFO_URL = IP_URL+"/biz-api/ifsct/up/sel/getSmBiddingSectionSafetyInfo";
|
||||
/**
|
||||
* 工程履历
|
||||
*/
|
||||
public static final String JJ_GC_LL_URL = IP_URL+"/biz-api/ifsct/up/sel/getPrjEnginneringExperience";
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,33 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjBall 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjBall{
|
||||
|
||||
private String id; //
|
||||
|
||||
private String cameraName; //布控球名称；
|
||||
|
||||
private String cameraNo; //布控球编码；
|
||||
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除
|
||||
|
||||
private String puid; //puid
|
||||
|
||||
private String provinceCode; //省公司编码；
|
||||
|
||||
private String createrId; //
|
||||
|
||||
private String createTime; //
|
||||
|
||||
private String updaterId; //
|
||||
|
||||
private String updaterTime; //
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,64 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjBidInfo 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjBidInfo{
|
||||
|
||||
private String id; //
|
||||
|
||||
private String singleProjectCode; //单项工程编码
|
||||
|
||||
private String biddingSectionId; //工程标段表id
|
||||
|
||||
private String biddingSectionName; //标段名称
|
||||
|
||||
private String safetyCode; //安全编码；anqu
|
||||
|
||||
private String biddingSectionCode; //标段编码
|
||||
|
||||
private String safetyProjectStatus; //安全工程状态；包括:01-待建; 02-在施;03-停工;04-投产
|
||||
|
||||
private String provinceCode; //省公司编码；
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
|
||||
private String buildUnitConPerson; //建设管理人名
|
||||
|
||||
private String buildUnitMobile; //建设管理单位联系人电话
|
||||
|
||||
private String acrossArea; //流经区域
|
||||
|
||||
private String towerNo; //线路基础数（基）；
|
||||
|
||||
private String actualCommencementDate; //安全实际开工时间
|
||||
|
||||
private String actualFinishTime; //安全实际完工时间；
|
||||
|
||||
private String currentDrpRate; //当前压降率
|
||||
|
||||
private String currentWorkStage; //当前作业阶段；
|
||||
|
||||
private String towerFoundComNum; //工程基础完工数（基）；
|
||||
|
||||
private String towerAssemNum; //工程组塔完工数（基）
|
||||
|
||||
private String lineComNum; //架线完成数（km）；
|
||||
|
||||
private String remark; //备注；
|
||||
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
|
||||
private String createrId; //创建人；
|
||||
|
||||
private String prjCode; //项目编码
|
||||
|
||||
private String deleteFlag; //删除状态
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,76 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjDayPlan 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjDayPlan{
|
||||
|
||||
private String id; //主键
|
||||
|
||||
private String cDeleteFlag; //--
|
||||
|
||||
private String createrId; //创建时间
|
||||
|
||||
private String createTime; //更新时间
|
||||
|
||||
private String updaterId; //更新人
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String batchNo; //批次号
|
||||
|
||||
private String taskDailyId; //日计划id
|
||||
|
||||
private String ticketId; //作业票id；
|
||||
|
||||
private String riskPrecautionId; //风险底数一本账id
|
||||
|
||||
private String workSiteId; //作业部位id；
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
|
||||
private String tDeleteFlag; //--
|
||||
|
||||
private String execStatus; //是否执行 0-未执行 1-已执行 2-已取消
|
||||
|
||||
private String toolBoxTalkId; //站班会id
|
||||
|
||||
private String subSectionProjectId; //分部工程id
|
||||
|
||||
private String subSectionProjectName; //分部工程名称
|
||||
|
||||
private String subEntryProjectId; //分项工程id
|
||||
|
||||
private String subEntryProjectName; //分项工程名称
|
||||
|
||||
private String cancelReason; //取消原因
|
||||
|
||||
private String workOvernightFlag; //是否跨零点作业
|
||||
|
||||
private String auditHierarchy; //审批层级
|
||||
|
||||
private String singleProjectCode; //单项工程编码
|
||||
|
||||
private String planStatus; //计划状态 01 撤回，02 驳回，03 审批中，04 已完成
|
||||
|
||||
private String tPlannedStartDate; //--
|
||||
|
||||
private String biddingSectionCode; //标段工程编码
|
||||
|
||||
private String biddingSectionName; //标段工程名称
|
||||
|
||||
private String teamId; //班组id
|
||||
|
||||
private String cPlannedStartDate; //--
|
||||
|
||||
private String additionalPlanFlag; //是否为增补计划
|
||||
|
||||
private String provinceCode; //省公司编码
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,55 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
/**
|
||||
* jjPrjEnginneringExperience 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
* 工程履历
|
||||
*/
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class JjPrjEnginneringExperience{
|
||||
|
||||
private String id; //主键ID
|
||||
|
||||
private String unitCode; //单位编码
|
||||
|
||||
private String personnelId; //人员ID
|
||||
|
||||
private String projectDepartmentId; //项目部ID
|
||||
|
||||
private String positionCode; //工程角色编码；同统一权限一致
|
||||
|
||||
private String positionName; //工程角色名称
|
||||
|
||||
private String entryDate; //进场时间
|
||||
|
||||
private String exitDate; //出场时间
|
||||
|
||||
private String provinceCode; //省公司编码
|
||||
|
||||
private String departType; //项目部类型；0：施工项目部；1：设计项目部；2：监理项目部；3：业主项目部；4：项目管理部
|
||||
|
||||
private String workingTeamId; //班组编码；项目部人员不需要维护此字段
|
||||
|
||||
private String jobCode; //工程岗位编码
|
||||
|
||||
private String jobName; //工程岗位名称
|
||||
|
||||
private String specialty; //专业
|
||||
|
||||
private String manageUnit; //1) 名称: 操作单位;0: 建设管理单位; 1: 监理单位
|
||||
|
||||
private String deleteFlag; //删除状态；默认 0；0：未删除；1：已删除
|
||||
|
||||
private String createrId; //创建人
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //修改人
|
||||
|
||||
private String updateTime; //修改时间
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,41 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import com.alibaba.fastjson.annotation.JSONField;
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class JjTeam {
|
||||
|
||||
@JSONField(name = "ID")
|
||||
private String id; //
|
||||
|
||||
private String constrUnitId;
|
||||
//施工单位id
|
||||
private String huvFlag; //0:常规工程 1:特高压 过滤：0:特高压
|
||||
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删
|
||||
|
||||
private String createrId; //创建人id
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //修改人
|
||||
|
||||
private String updateTime; //修改时间
|
||||
|
||||
private String workingTeamName; //作业班组名称
|
||||
|
||||
private String workingTeamType; //作业班组类型；包括：0101-架空线路基础；0102-架空线路组塔；0103-架空线路架线；0201-电缆线路顶管班；0202-电缆线路混凝土；0203-电缆线路电气安装；0301-变电土建；0302- 变电站桩基作业；0303-变电站混凝土作业；0304-变申站钢结构安装作业；0305-变电电气安装；0306-变电站电气安装一次作业；0307- 变电站电气安装二次作业；0308-变电站调试作业
|
||||
|
||||
private String workingTeamAttribute; //作业班组属性；包括：01-自有班组；02-专业分包班组；03-劳务分包班组 自有班组？骨干成员、一般作业人员（施工单位获取，施工项目经理单位）
|
||||
|
||||
private String teamStatus; //班组状态；包括：01-正常；02-解散
|
||||
|
||||
private String provinceCode; //省公司编码；
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
|
||||
private String singleProjectCode; //单项工程编码
|
||||
|
||||
private String biddingSectionCode; //标段工程编码
|
||||
}
|
||||
|
|
@ -0,0 +1,45 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import com.alibaba.fastjson.annotation.JSONField;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjTeamPeople 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
@Data
|
||||
public class JjTeamPeople{
|
||||
|
||||
@JSONField(name = "ID")
|
||||
private String id; //
|
||||
|
||||
private String provinceCode; //省公司编码；
|
||||
|
||||
private String createrId; //创建人
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //更新id
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String deleteFlag; //删除状态
|
||||
|
||||
private String teamId; //班组id
|
||||
|
||||
private String personnelId; //人员id
|
||||
|
||||
private String unitCode; //单位id
|
||||
|
||||
private String personType; //人员类型，1自有，2分包
|
||||
|
||||
private String realName; //姓名；
|
||||
|
||||
private String workCode; //工种编码
|
||||
|
||||
private String positionCode; //岗位编码
|
||||
|
||||
private String idCard; //身份证号；
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,78 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjTicket 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjTicket{
|
||||
|
||||
private String id; //主键
|
||||
|
||||
private String teamId; //班组id；
|
||||
|
||||
private String workingTeamName; //作业班组名称；
|
||||
|
||||
private String constructionHeadcount; //施工人数
|
||||
|
||||
private String plannedStartDate; //计划开始时间
|
||||
|
||||
private String plannedEndDate; //计划结束时间
|
||||
|
||||
private String startTime; //开始时间；
|
||||
|
||||
private String endTime; //结束时间；
|
||||
|
||||
private String assessmentRiskLevel; //初勘风险等级
|
||||
|
||||
private String reAssessmentRiskLevel; //复测风险等级
|
||||
|
||||
private String ticketStatus; //业票状态；包括：01-撤回；02-驳回；03-提交审核中；04-待执行；05-执行中；06-已结束；07-作废；08-删除
|
||||
|
||||
private String ticketType; //作业票类型；包括：a-a票；b-b票
|
||||
|
||||
private String currentConstructionStatus; //当日施工状态
|
||||
|
||||
private String auditHierarchy; //审批层级
|
||||
|
||||
private String issueDate; //签发日期；
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
|
||||
private String provinceCode; //省公司编码；
|
||||
|
||||
private String remark; //备注
|
||||
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
|
||||
private String createrId; //创建人
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //更新人
|
||||
|
||||
private String ticketNo; //作业票编号；
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String deleteFlag; //delete_flag 删除状态；默认0，包括：0未删除，1已删除
|
||||
|
||||
private String voltageLevel; //电压等级编码
|
||||
|
||||
private String ticketName; //作业票名称
|
||||
|
||||
private String biddingSectionCode; //标段编码
|
||||
|
||||
private String biddingSectionName; //标段名称
|
||||
|
||||
private String singleProjectType; //单项工程类型
|
||||
|
||||
private String singleProjectCode; //单项工程编码
|
||||
|
||||
private String singleProjectName; //单项工程名称
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,50 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjTicketPeople 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjTicketPeople{
|
||||
|
||||
private String id; //主机
|
||||
|
||||
private String workDivision; //具体分工1-施工人员， 2-新增人员（临时人员）
|
||||
|
||||
private String createrId; //创建人
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //修改时间
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除
|
||||
|
||||
private String provinceCode; //省公司编码
|
||||
|
||||
private String chosedFlag; //是否选中
|
||||
|
||||
private String positionFlag; //是否在岗，用于变更负责人离场 默认：1-在岗，包括：0-不在岗；1-在岗
|
||||
|
||||
private String ticketId; //作业票id
|
||||
|
||||
private String toolBoxTalkId; //站班会id
|
||||
|
||||
private String personnelId; //统一权限id
|
||||
|
||||
private String idCard; //身份证号
|
||||
|
||||
private String realName; //姓名
|
||||
|
||||
private String mobile; //手机号码
|
||||
|
||||
private String workCode; //工种编码
|
||||
|
||||
private String positionCode; //岗位编码
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,78 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjUser 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class JjUser{
|
||||
|
||||
private String id; //主键
|
||||
|
||||
private String nation; //民族；
|
||||
|
||||
private String birthPlace; //籍贯；
|
||||
|
||||
private String unitId; //单位id；
|
||||
|
||||
private String deptId; //部门id
|
||||
|
||||
private String headFileId; //照片
|
||||
|
||||
private String dataSource; //数据来源；
|
||||
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
|
||||
private String provinceCode; //省公司编码
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码
|
||||
|
||||
private String createrId; //创建人
|
||||
|
||||
private String realName; //姓名；
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //更新人
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String deleteFlag; //删除状态
|
||||
|
||||
private String deptName; //部门名称；
|
||||
|
||||
private String personnelId; //安监personnel表id
|
||||
|
||||
private String accessDate; //入职时间
|
||||
|
||||
private String accessState; //准入状态
|
||||
|
||||
private String accessStartDate; //准入开始时间
|
||||
|
||||
private String accessEndDate; //准入结束时间
|
||||
|
||||
private String gender; //性别
|
||||
|
||||
private String professionalskillName; //--
|
||||
|
||||
private String professionalskillLevel; //--
|
||||
|
||||
private String techQualLevel; //专业技术职称，字典项
|
||||
|
||||
private String idCard; //身份证号
|
||||
|
||||
private String iscAccount; //统一权限账号
|
||||
|
||||
private String safetyPersonnelId; //安监id
|
||||
|
||||
private String mobile; //电话
|
||||
|
||||
private String education; //学历；
|
||||
|
||||
private String politicsStatus; //政治面貌
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,73 @@
|
|||
package com.xxl.job.executor.inter.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* jjWeeksPlan 实体类
|
||||
* 2024-05-08 09:31:40 zijixiangba
|
||||
*/
|
||||
@Data
|
||||
public class JjWeeksPlan{
|
||||
|
||||
private String id; //主机
|
||||
|
||||
private String currentSignalFlag; //当前是否有信号
|
||||
|
||||
private String additionalPlanFlag; //是否为增补计划
|
||||
|
||||
private String singleProjectType; //单项工程类型
|
||||
|
||||
private String auditHierarchy; //审批层级 1:施工项目部、2:监理项目部、3:业主项目部、4:建管单位、5:省公司
|
||||
|
||||
private String planStatus; //计划状态;01-撤回;02-驳回;03-审批中;04-已完成
|
||||
|
||||
private String excuteFlag; //执行状态 0-未执行;1-已执行 开作业票：执行
|
||||
|
||||
private String teamUpdateFlag; //班组调整标识；是否允许修改班组(自己班组抢的还是施工经理指派的)，1-允许；0-不允许
|
||||
|
||||
private String electricityRiskLevel; //电网风险等级 1-不涉及 2-电网五级风险 默认值1
|
||||
|
||||
private String buildUnitCode; //建设管理单位编码；
|
||||
|
||||
private String provinceCode; //省公司编码
|
||||
|
||||
private String riskPrecautionId; //风险底数一本账id
|
||||
|
||||
private String huvFlag; //0:常规工程 1:特高压
|
||||
|
||||
private String cDeleteFlag; //--
|
||||
|
||||
private String createrId; //创建人id
|
||||
|
||||
private String createTime; //创建时间
|
||||
|
||||
private String updaterId; //更新人id
|
||||
|
||||
private String updateTime; //更新时间
|
||||
|
||||
private String subSectionProjectId; //分部工程id
|
||||
|
||||
private String subSectionProjectName; //分部工程名称
|
||||
|
||||
private String ticketId; //作业票id
|
||||
|
||||
private String tDeleteFlag; //--
|
||||
|
||||
private String biddingSectionCode; //标段编码
|
||||
|
||||
private String reAssessmentRiskLevel; //复测风险等级
|
||||
|
||||
private String singleProjectCode; //单项工程编码
|
||||
|
||||
private String biddingSectionName; //标段工程名称
|
||||
|
||||
private String plannedStartDate; //计划开始时间
|
||||
|
||||
private String plannedEndDate; //计划结束时间
|
||||
|
||||
private String teamId; //班组id；
|
||||
|
||||
private String workSiteId; //作业部位id
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -1,8 +1,6 @@
|
|||
package com.xxl.job.executor.inter.mapper;
|
||||
|
||||
import com.xxl.job.executor.inter.entity.BidProject;
|
||||
import com.xxl.job.executor.inter.entity.ClassMetting;
|
||||
import com.xxl.job.executor.inter.entity.JjProject;
|
||||
import com.xxl.job.executor.inter.entity.*;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
|
|
@ -14,11 +12,6 @@ import java.util.List;
|
|||
*/
|
||||
@Repository
|
||||
public interface InterMapper {
|
||||
/**
|
||||
* 测试方法
|
||||
* @return
|
||||
*/
|
||||
String getTest();
|
||||
|
||||
/**
|
||||
* 批量插入项目信息
|
||||
|
|
@ -33,8 +26,56 @@ public interface InterMapper {
|
|||
void insertBidPro(List<BidProject> list);
|
||||
|
||||
/**
|
||||
* 插入站班会数据
|
||||
* 插入 班组team
|
||||
* @param list
|
||||
*/
|
||||
void insertClassMetting(List<ClassMetting> list);
|
||||
void insertTeam(List<JjTeam> list);
|
||||
|
||||
void insertTeamPeople(List<JjTeamPeople> list);
|
||||
|
||||
/**
|
||||
* 作业票信息
|
||||
* @param list
|
||||
*/
|
||||
void insertTicket(List<JjTicket> list);
|
||||
|
||||
/**
|
||||
* 新增作业票信息
|
||||
* @param list
|
||||
*/
|
||||
void insertTicketPeople(List<JjTicketPeople> list);
|
||||
/**
|
||||
* 新增周计划
|
||||
*/
|
||||
void insertWeeksPlanData(List<JjWeeksPlan> list);
|
||||
|
||||
/**
|
||||
* 新增日计划
|
||||
* @param list
|
||||
*/
|
||||
void insertDayPlanData(List<JjDayPlan> list);
|
||||
|
||||
/**
|
||||
* 基建人员信息
|
||||
* @param list
|
||||
*/
|
||||
void insertJJUser(List<JjUser> list);
|
||||
|
||||
/**
|
||||
* 新增布控球
|
||||
* @param list
|
||||
*/
|
||||
void insertJjBall(List<JjBall> list);
|
||||
|
||||
/**
|
||||
* 基建标段信息
|
||||
* @param list
|
||||
*/
|
||||
void insertJjBidInfo(List<JjBidInfo> list);
|
||||
|
||||
/**
|
||||
*
|
||||
* @param list
|
||||
*/
|
||||
void insertGcLlData(List<JjPrjEnginneringExperience> list);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,9 +1,7 @@
|
|||
package com.xxl.job.executor.inter.service;
|
||||
|
||||
import com.xxl.job.core.context.XxlJobHelper;
|
||||
import com.xxl.job.executor.inter.entity.BidProject;
|
||||
import com.xxl.job.executor.inter.entity.ClassMetting;
|
||||
import com.xxl.job.executor.inter.entity.JjProject;
|
||||
import com.xxl.job.executor.inter.entity.*;
|
||||
import com.xxl.job.executor.inter.mapper.InterMapper;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
|
@ -49,11 +47,127 @@ public class DataCenterService {
|
|||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void insertClassMetting(List<ClassMetting> list) {
|
||||
/**
|
||||
* 班组信息自动花
|
||||
* @param list
|
||||
*/
|
||||
public void insertTeam(List<JjTeam> list) {
|
||||
try{
|
||||
mapper.insertClassMetting(list);
|
||||
mapper.insertTeam(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
* @param list
|
||||
*/
|
||||
public void insertTeamPeople(List<JjTeamPeople> list) {
|
||||
try{
|
||||
mapper.insertTeamPeople(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 作业票信息
|
||||
* @param list
|
||||
*/
|
||||
public void insertTicket(List<JjTicket> list) {
|
||||
try{
|
||||
mapper.insertTicket(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertTicketPeople(List<JjTicketPeople> list) {
|
||||
try{
|
||||
mapper.insertTicketPeople(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertWeeksPlanData(List<JjWeeksPlan> list) {
|
||||
try{
|
||||
mapper.insertWeeksPlanData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
public void insertDayPlanData(List<JjDayPlan> list) {
|
||||
try{
|
||||
mapper.insertDayPlanData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 基建人员
|
||||
* @param list
|
||||
*/
|
||||
public void insertJJUser(List<JjUser> list) {
|
||||
try{
|
||||
mapper.insertJJUser(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 布控球
|
||||
* @param list
|
||||
*/
|
||||
public void insertJjBall(List<JjBall> list) {
|
||||
try{
|
||||
mapper.insertJjBall(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 标段安全信息
|
||||
* @param list
|
||||
*/
|
||||
public void insertJjBidInfo(List<JjBidInfo> list) {
|
||||
try{
|
||||
mapper.insertJjBidInfo(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(),e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 工程履历
|
||||
* @param list
|
||||
*/
|
||||
public void insertGcLlData(List<JjPrjEnginneringExperience> list) {
|
||||
try{
|
||||
mapper.insertGcLlData(list);
|
||||
}catch (Exception e){
|
||||
XxlJobHelper.log("数据处理异常内容--->{}",e.toString());
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
|
|
|
|||
|
|
@ -5,15 +5,12 @@ 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.BidProject;
|
||||
import com.xxl.job.executor.inter.entity.ClassMetting;
|
||||
import com.xxl.job.executor.inter.entity.JjProject;
|
||||
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;
|
||||
|
||||
|
|
@ -74,8 +71,7 @@ public class InterService {
|
|||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "2");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL);
|
||||
// HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.BD_PRO_URL);
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.BD_PRO_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
|
|
@ -95,24 +91,22 @@ public class InterService {
|
|||
}
|
||||
|
||||
/**
|
||||
* 站班会
|
||||
* 查询班组信息
|
||||
*/
|
||||
public void getClassMet() {
|
||||
public void getTeam() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "3");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL);
|
||||
// HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.ZBH_URL);
|
||||
obj.put("type", "21");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.WORK_TEAM_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<ClassMetting> list = JSONArray.parseArray(array.toJSONString(), ClassMetting.class);
|
||||
service.insertClassMetting(list);
|
||||
List<JjTeam> list = JSONArray.parseArray(array.toJSONString(), JjTeam.class);
|
||||
service.insertTeam(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getBidPro();
|
||||
// getTeam();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
|
|
@ -121,6 +115,220 @@ public class InterService {
|
|||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 班组人员接口
|
||||
*/
|
||||
public void getTeamPeople() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "22");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.TEAM_USER_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjTeamPeople> list = JSONArray.parseArray(array.toJSONString(), JjTeamPeople.class);
|
||||
service.insertTeamPeople(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getTeamPeople();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 作业票信息
|
||||
*/
|
||||
public void getTicket() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "23");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.SG_TICKET_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjTicket> list = JSONArray.parseArray(array.toJSONString(), JjTicket.class);
|
||||
service.insertTicket(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getTeamPeople();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
|
||||
public void getTicketPeople() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "24");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.TICKET_USER_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjTicketPeople> list = JSONArray.parseArray(array.toJSONString(), JjTicketPeople.class);
|
||||
service.insertTicketPeople(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getTeamPeople();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
public void getWeeksPlan() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "25");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.SG_WEEK_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjWeeksPlan> list = JSONArray.parseArray(array.toJSONString(), JjWeeksPlan.class);
|
||||
service.insertWeeksPlanData(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getWeeksPlan();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
public void getDayPlan() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "26");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.SG_DAY_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjDayPlan> list = JSONArray.parseArray(array.toJSONString(), JjDayPlan.class);
|
||||
service.insertDayPlanData(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getDayPlan();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 安全人员获取
|
||||
*/
|
||||
public void getJJUser() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "27");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.AQ_ZR_USER_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjUser> list = JSONArray.parseArray(array.toJSONString(), JjUser.class);
|
||||
service.insertJJUser(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getJJUser();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 布控球
|
||||
*/
|
||||
public void getJJBall() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "999");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.JJ_BALL_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjBall> list = JSONArray.parseArray(array.toJSONString(), JjBall.class);
|
||||
service.insertJjBall(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getJJBall();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 标段安全信息
|
||||
*/
|
||||
public void getJJBidInfo() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "999");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.JJ_BID_INFO_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjBidInfo> list = JSONArray.parseArray(array.toJSONString(), JjBidInfo.class);
|
||||
service.insertJjBidInfo(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getJJBall();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取工程履历信息
|
||||
*/
|
||||
public void getGcLL() {
|
||||
try {
|
||||
int pageNum = 1;
|
||||
JSONObject obj = new JSONObject();
|
||||
obj.put("type", "999");
|
||||
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.JJ_GC_LL_URL);
|
||||
Map<String, Object> map = DataUtils.getArray(httpResponse);
|
||||
JSONArray array = (JSONArray) map.get("array");
|
||||
if (array != null) {
|
||||
List<JjPrjEnginneringExperience> list = JSONArray.parseArray(array.toJSONString(), JjPrjEnginneringExperience.class);
|
||||
service.insertGcLlData(list);
|
||||
pageNum++;
|
||||
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
|
||||
// getGcLL();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
XxlJobHelper.handleFail(e.toString());
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -12,7 +12,6 @@ import org.springframework.stereotype.Component;
|
|||
@Component
|
||||
public class DataCenterXxlJob {
|
||||
|
||||
|
||||
@Autowired
|
||||
private InterService interService;
|
||||
|
||||
|
|
@ -20,20 +19,87 @@ public class DataCenterXxlJob {
|
|||
public void getProInfo(){
|
||||
interService.getProInfo();
|
||||
}
|
||||
|
||||
|
||||
@XxlJob("getBidPro")
|
||||
public void getBidPro(){
|
||||
interService.getBidPro();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 站班会
|
||||
* 班组信息获取
|
||||
*/
|
||||
@XxlJob("getClassMet")
|
||||
public void getClassMet(){
|
||||
interService.getClassMet();
|
||||
@XxlJob("getTeam")
|
||||
public void getTeam(){
|
||||
interService.getTeam();
|
||||
}
|
||||
|
||||
/**
|
||||
* 班组信息获取
|
||||
*/
|
||||
@XxlJob("getTeamPeople")
|
||||
public void getTeamPeople(){
|
||||
interService.getTeamPeople();
|
||||
}
|
||||
|
||||
/**
|
||||
* 作业票信息
|
||||
*/
|
||||
@XxlJob("getTicket")
|
||||
public void getTicket(){
|
||||
interService.getTicket();
|
||||
}
|
||||
|
||||
/**
|
||||
* 作业票人员
|
||||
*/
|
||||
@XxlJob("getTicketPeople")
|
||||
public void getTicketPeople(){
|
||||
interService.getTicketPeople();
|
||||
}
|
||||
|
||||
/**
|
||||
* 日计划
|
||||
*/
|
||||
@XxlJob("getDayPlan")
|
||||
public void getDayPlan(){
|
||||
interService.getDayPlan();
|
||||
}
|
||||
/**
|
||||
* 周计划
|
||||
*/
|
||||
@XxlJob("getWeeksPlan")
|
||||
public void getWeeksPlan(){
|
||||
interService.getWeeksPlan();
|
||||
}
|
||||
|
||||
/**
|
||||
* 安全人员
|
||||
*/
|
||||
@XxlJob("getJJUser")
|
||||
public void getJJUser(){
|
||||
interService.getJJUser();
|
||||
}
|
||||
/**
|
||||
* 布控球
|
||||
*/
|
||||
@XxlJob("getJJBall")
|
||||
public void getJJBall(){
|
||||
interService.getJJBall();
|
||||
}
|
||||
|
||||
/**
|
||||
* 标段安全信息
|
||||
*/
|
||||
@XxlJob("getJJBidInfo")
|
||||
public void getJJBidInfo(){
|
||||
interService.getJJBidInfo();
|
||||
}
|
||||
|
||||
/**
|
||||
* 工程履历
|
||||
*/
|
||||
@XxlJob("getGcLL")
|
||||
public void getGcLL(){
|
||||
interService.getGcLL();
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -70,28 +70,211 @@
|
|||
#{item.planFinDate},#{item.actualStartDate},#{item.actualFinDate},#{item.status},#{item.biddingSectionType},#{item.deleteFlag},#{item.createTime})
|
||||
</foreach>
|
||||
</insert>
|
||||
<!--插入站班会数据-->
|
||||
<insert id="insertClassMetting">
|
||||
REPLACE INTO t_class_metting(class_id,work_day,team_name,start_time,end_time,work_location,
|
||||
work_manager,work_manager_num,work_manager_phone,safety_manager,changes,controll,
|
||||
sub,mac_id,puid,work_content,risk_level,ticket_id,
|
||||
lon,lat,current_control,sg_num,work_position,voltage,
|
||||
org,pro_name,sign_name,bid_name,sign_code,bid_code,
|
||||
pro_code,is_week,fxys,jldw,ticket_no,sgdw,
|
||||
ztsj,del_flag,create_time,sg_status,remarks,work_gx,
|
||||
work_type,yes_work_gx,yes_work_type,build_unit) VALUES
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.currentConstrDate},NULL,#{item.workStartTime},NULL,NULL,
|
||||
NULL,NULL,NULL,NULL,NULL,NULL
|
||||
</foreach>
|
||||
|
||||
<insert id="insertTeam">
|
||||
replace into jj_team
|
||||
(id,constr_unit_id,huv_flag,delete_flag,
|
||||
creater_id,create_time,updater_id,update_time,
|
||||
working_team_name,working_team_type,working_team_attribute,
|
||||
team_status,province_code,build_unit_code,single_project_code,
|
||||
bidding_section_code) VALUES
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id}, #{item.constrUnitId},#{item.huvFlag}, #{item.deleteFlag},
|
||||
#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime},
|
||||
#{item.workingTeamName}, #{item.workingTeamType}, #{item.workingTeamAttribute},
|
||||
#{item.teamStatus}, #{item.provinceCode}, #{item.buildUnitCode}, #{item.singleProjectCode},
|
||||
#{item.biddingSectionCode})
|
||||
</foreach>
|
||||
</insert>
|
||||
|
||||
<select id="getTest" resultType="java.lang.String">
|
||||
select userName
|
||||
from xxl_job_user
|
||||
</select>
|
||||
<insert id="insertTeamPeople">
|
||||
replace into jj_team_people(
|
||||
id,province_code,creater_id,create_time,
|
||||
updater_id,update_time,delete_flag,team_id,
|
||||
personnel_id,unit_code,person_type,
|
||||
real_name,work_code,position_code,id_card)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.provinceCode},#{item.createrId},#{item.createTime},
|
||||
#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.teamId},
|
||||
#{item.personnelId},#{item.unitCode},#{item.personType},
|
||||
#{item.realName},#{item.workCode},#{item.positionCode},#{item.idCard}
|
||||
)</foreach>
|
||||
</insert>
|
||||
<insert id="insertTicket">
|
||||
replace into jj_ticket(
|
||||
id,team_id,working_team_name,construction_headcount,
|
||||
planned_start_date,planned_end_date,
|
||||
start_time,end_time,assessment_risk_level,re_assessment_risk_level,
|
||||
ticket_status,ticket_type,current_construction_status,audit_hierarchy,
|
||||
issue_date,build_unit_code,province_code,remark,huv_flag,
|
||||
creater_id,create_time,updater_id,
|
||||
ticket_no,update_time,delete_flag,
|
||||
voltage_level,ticket_name,bidding_section_code,
|
||||
bidding_section_name,single_project_type,single_project_code,single_project_name
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.teamId},#{item.workingTeamName},#{item.constructionHeadcount},
|
||||
#{item.plannedStartDate},#{item.plannedEndDate},
|
||||
#{item.startTime},#{item.endTime},#{item.assessmentRiskLevel},#{item.reAssessmentRiskLevel},
|
||||
#{item.ticketStatus},#{item.ticketType},#{item.currentConstructionStatus},#{item.auditHierarchy},
|
||||
#{item.issueDate},#{item.buildUnitCode},#{item.provinceCode},#{item.remark},#{item.huvFlag},
|
||||
#{item.createrId},#{item.createTime},#{item.updaterId},
|
||||
#{item.ticketNo},#{item.updateTime},#{item.deleteFlag},
|
||||
#{item.voltageLevel},#{item.ticketName},#{item.biddingSectionCode},
|
||||
#{item.biddingSectionName},#{item.singleProjectType},#{item.singleProjectCode},#{item.singleProjectName}
|
||||
)</foreach>
|
||||
</insert>
|
||||
|
||||
<insert id="insertTicketPeople">
|
||||
replace into jj_ticket_people(
|
||||
id,work_division,creater_id,
|
||||
create_time,updater_id,update_time,
|
||||
delete_flag,province_code,chosed_flag,
|
||||
position_flag,ticket_id,tool_box_talk_id,
|
||||
personnel_id,id_card,real_name,
|
||||
mobile,work_code,position_code
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.workDivision},#{item.createrId},
|
||||
#{item.createTime},#{item.updaterId},#{item.updateTime},
|
||||
#{item.deleteFlag},#{item.provinceCode},#{item.chosedFlag},
|
||||
#{item.positionFlag},#{item.ticketId},#{item.toolBoxTalkId},
|
||||
#{item.personnelId},#{item.idCard},#{item.realName},
|
||||
#{item.mobile},#{item.workCode},#{item.positionCode}
|
||||
)</foreach>
|
||||
</insert>
|
||||
<insert id="insertWeeksPlanData">
|
||||
replace into jj_weeks_plan(
|
||||
id,current_signal_flag,additional_plan_flag,
|
||||
single_project_type,audit_hierarchy,plan_status,
|
||||
excute_flag,team_update_flag,electricity_risk_level,
|
||||
build_unit_code,province_code,risk_precaution_id,
|
||||
huv_flag,c_delete_flag,creater_id,
|
||||
create_time,updater_id,update_time,
|
||||
sub_section_project_id,sub_section_project_name,ticket_id,
|
||||
t_delete_flag,bidding_section_code,re_assessment_risk_level,
|
||||
single_project_code,bidding_section_name,planned_start_date,
|
||||
planned_end_date,team_id,work_site_id
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.currentSignalFlag},#{item.additionalPlanFlag},
|
||||
#{item.singleProjectType},#{item.auditHierarchy},#{item.planStatus},
|
||||
#{item.excuteFlag},#{item.teamUpdateFlag},#{item.electricityRiskLevel},
|
||||
#{item.buildUnitCode},#{item.provinceCode},#{item.riskPrecautionId},
|
||||
#{item.huvFlag},#{item.cDeleteFlag},#{item.createrId},
|
||||
#{item.createTime},#{item.updaterId},#{item.updateTime},
|
||||
#{item.subSectionProjectId},#{item.subSectionProjectName},#{item.ticketId},
|
||||
#{item.tDeleteFlag},#{item.biddingSectionCode},#{item.reAssessmentRiskLevel},
|
||||
#{item.singleProjectCode},#{item.biddingSectionName},#{item.plannedStartDate},
|
||||
#{item.plannedEndDate},#{item.teamId},#{item.workSiteId}
|
||||
)</foreach>
|
||||
</insert>
|
||||
<insert id="insertDayPlanData">
|
||||
replace into jj_day_plan(
|
||||
id,c_delete_flag,creater_id,
|
||||
create_time,updater_id,update_time,
|
||||
batch_no,task_daily_id,ticket_id,
|
||||
risk_precaution_id,work_site_id,build_unit_code,
|
||||
t_delete_flag,exec_status,tool_box_talk_id,
|
||||
sub_section_project_id,sub_section_project_name,sub_entry_project_id,
|
||||
sub_entry_project_name,cancel_reason,work_overnight_flag,
|
||||
audit_hierarchy,single_project_code,plan_status,
|
||||
t_planned_start_date,bidding_section_code,bidding_section_name,
|
||||
team_id,c_planned_start_date,additional_plan_flag,province_code
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.cDeleteFlag}, #{item.createrId},
|
||||
#{item.createTime},#{item.updaterId},#{item.updateTime},
|
||||
#{item.batchNo}, #{item.taskDailyId},#{item.ticketId},
|
||||
#{item.riskPrecautionId},#{item.workSiteId},#{item.buildUnitCode},
|
||||
#{item.tDeleteFlag},#{item.execStatus},#{item.toolBoxTalkId},
|
||||
#{item.subSectionProjectId},#{item.subSectionProjectName},#{item.subEntryProjectId},
|
||||
#{item.subEntryProjectName},#{item.cancelReason},#{item.workOvernightFlag},
|
||||
#{item.auditHierarchy},#{item.singleProjectCode},#{item.planStatus},
|
||||
#{item.tPlannedStartDate},#{item.biddingSectionCode},#{item.biddingSectionName},
|
||||
#{item.teamId}, #{item.cPlannedStartDate},#{item.additionalPlanFlag},#{item.provinceCode}
|
||||
)</foreach>
|
||||
</insert>
|
||||
<insert id="insertJJUser">
|
||||
replace into jj_user(
|
||||
id,nation,birth_place,unit_id,
|
||||
dept_id,head_file_id,data_source,huv_flag,
|
||||
province_code,build_unit_code,creater_id,
|
||||
real_name,create_time,updater_id,
|
||||
update_time,delete_flag,dept_name,
|
||||
personnel_id,access_date,access_state,
|
||||
access_start_date,access_end_date,gender,
|
||||
professionalskill_name,professionalskill_level,tech_qual_level,
|
||||
id_card,isc_account,safety_personnel_id,
|
||||
mobile,education,politics_status
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.nation},#{item.birthPlace},#{item.unitId},
|
||||
#{item.deptId},#{item.headFileId},#{item.dataSource},#{item.huvFlag},
|
||||
#{item.provinceCode},#{item.buildUnitCode},#{item.createrId},
|
||||
#{item.realName},#{item.createTime},#{item.updaterId},
|
||||
#{item.updateTime},#{item.deleteFlag},#{item.deptName},
|
||||
#{item.personnelId},#{item.accessDate},#{item.accessState},
|
||||
#{item.accessStartDate},#{item.accessEndDate},#{item.gender},
|
||||
#{item.professionalskillName},#{item.professionalskillLevel},#{item.techQualLevel},
|
||||
#{item.idCard},#{item.iscAccount},#{item.safetyPersonnelId},
|
||||
#{item.mobile},#{item.education},#{item.politicsStatus}
|
||||
)</foreach>
|
||||
</insert>
|
||||
|
||||
<insert id="insertJjBall">
|
||||
replace into jj_ball(
|
||||
id,camera_name,camera_no,delete_flag,
|
||||
puid,province_code,creater_id,create_time,
|
||||
updater_id,updater_time
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id},#{item.cameraName},#{item.cameraNo},#{item.deleteFlag},
|
||||
#{item.puid},#{item.provinceCode},#{item.createrId},#{item.createTime},
|
||||
#{item.updaterId},#{item.updaterTime}
|
||||
)</foreach>
|
||||
</insert>
|
||||
|
||||
<insert id="insertJjBidInfo">
|
||||
replace into jj_bid_info(
|
||||
id,single_project_code,bidding_section_id,
|
||||
bidding_section_name,safety_code,bidding_section_code,
|
||||
safety_project_status,province_code,build_unit_code,
|
||||
build_unit_con_person,build_unit_mobile,across_area,
|
||||
tower_no,actual_commencement_date,actual_finish_time,
|
||||
current_drp_rate,current_work_stage,tower_found_com_num,
|
||||
tower_assem_num,line_com_num,remark,
|
||||
huv_flag,creater_id,prj_code,delete_flag
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id}, #{item.singleProjectCode},#{item.biddingSectionId},
|
||||
#{item.biddingSectionName},#{item.safetyCode},#{item.biddingSectionCode},
|
||||
#{item.safetyProjectStatus},#{item.provinceCode},#{item.buildUnitCode},
|
||||
#{item.buildUnitConPerson},#{item.buildUnitMobile},#{item.acrossArea},
|
||||
#{item.towerNo},#{item.actualCommencementDate},#{item.actualFinishTime},
|
||||
#{item.currentDrpRate},#{item.currentWorkStage},#{item.towerFoundComNum},
|
||||
#{item.towerAssemNum},#{item.lineComNum},#{item.remark},
|
||||
#{item.huvFlag},#{item.createrId},#{item.prjCode},#{item.deleteFlag}
|
||||
)</foreach>
|
||||
</insert>
|
||||
<insert id="insertGcLlData">
|
||||
replace into jj_prj_enginnering_experience(
|
||||
id,unit_code,personnel_id,project_department_id,
|
||||
position_code,position_name,entry_date,
|
||||
exit_date,province_code,depart_type,
|
||||
working_team_id,job_code,job_name,
|
||||
specialty,manage_unit,delete_flag,
|
||||
creater_id,create_time,updater_id,update_time
|
||||
)values
|
||||
<foreach collection="list" item="item" separator=",">(
|
||||
#{item.id}, #{item.unitCode},#{item.personnelId},#{item.projectDepartmentId},
|
||||
#{item.positionCode},#{item.positionName},#{item.entryDate},
|
||||
#{item.exitDate},#{item.provinceCode},#{item.departType},
|
||||
#{item.workingTeamId},#{item.jobCode},#{item.jobName},
|
||||
#{item.specialty},#{item.manageUnit},#{item.deleteFlag},
|
||||
#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime}
|
||||
)</foreach>
|
||||
</insert>
|
||||
|
||||
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue