diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java index 5ad69d4..054034c 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java @@ -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 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); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java index 7d99e2d..c3ed236 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java @@ -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"; + + } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBall.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBall.java new file mode 100644 index 0000000..86258a6 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBall.java @@ -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; // +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBidInfo.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBidInfo.java new file mode 100644 index 0000000..eeb610e --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjBidInfo.java @@ -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; //删除状态 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDayPlan.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDayPlan.java new file mode 100644 index 0000000..f0f09b1 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDayPlan.java @@ -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; //省公司编码 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjPrjEnginneringExperience.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjPrjEnginneringExperience.java new file mode 100644 index 0000000..89101e5 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjPrjEnginneringExperience.java @@ -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; //修改时间 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeam.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeam.java new file mode 100644 index 0000000..b3531a8 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeam.java @@ -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; //标段工程编码 +} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeamPeople.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeamPeople.java new file mode 100644 index 0000000..3b3018f --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTeamPeople.java @@ -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; //身份证号； + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicket.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicket.java new file mode 100644 index 0000000..1712370 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicket.java @@ -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; //单项工程名称 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicketPeople.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicketPeople.java new file mode 100644 index 0000000..3c6a603 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjTicketPeople.java @@ -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; //岗位编码 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUser.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUser.java new file mode 100644 index 0000000..08e7a25 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUser.java @@ -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; //政治面貌 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjWeeksPlan.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjWeeksPlan.java new file mode 100644 index 0000000..a0292a2 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjWeeksPlan.java @@ -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 + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java index d9ea95e..25f7629 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java @@ -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 list); /** - * 插入站班会数据 + * 插入 班组team * @param list */ - void insertClassMetting(List list); + void insertTeam(List list); + + void insertTeamPeople(List list); + + /** + * 作业票信息 + * @param list + */ + void insertTicket(List list); + + /** + * 新增作业票信息 + * @param list + */ + void insertTicketPeople(List list); + /** + * 新增周计划 + */ + void insertWeeksPlanData(List list); + + /** + * 新增日计划 + * @param list + */ + void insertDayPlanData(List list); + + /** + * 基建人员信息 + * @param list + */ + void insertJJUser(List list); + + /** + * 新增布控球 + * @param list + */ + void insertJjBall(List list); + + /** + * 基建标段信息 + * @param list + */ + void insertJjBidInfo(List list); + + /** + * + * @param list + */ + void insertGcLlData(List list); } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java index ba38928..ae95f35 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java @@ -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 list) { + /** + * 班组信息自动花 + * @param list + */ + public void insertTeam(List 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 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 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 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 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 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 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 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 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 list) { + try{ + mapper.insertGcLlData(list); }catch (Exception e){ XxlJobHelper.log("数据处理异常内容--->{}",e.toString()); XxlJobHelper.handleFail(e.toString()); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java index 720a8eb..4187799 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java @@ -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 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 map = DataUtils.getArray(httpResponse); JSONArray array = (JSONArray) map.get("array"); if (array != null) { - List list = JSONArray.parseArray(array.toJSONString(), ClassMetting.class); - service.insertClassMetting(list); + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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 map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List 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); + } + + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java index 13e85f1..42d7d36 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java @@ -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(); + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml index 80c2c55..c3c5b71 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml @@ -70,28 +70,211 @@ #{item.planFinDate},#{item.actualStartDate},#{item.actualFinDate},#{item.status},#{item.biddingSectionType},#{item.deleteFlag},#{item.createTime}) - - - 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 - ( - #{item.id},#{item.currentConstrDate},NULL,#{item.workStartTime},NULL,NULL, - NULL,NULL,NULL,NULL,NULL,NULL - + + + 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 + ( + #{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}) + - + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + + + replace into jj_ball( + id,camera_name,camera_no,delete_flag, + puid,province_code,creater_id,create_time, + updater_id,updater_time + )values + ( + #{item.id},#{item.cameraName},#{item.cameraNo},#{item.deleteFlag}, + #{item.puid},#{item.provinceCode},#{item.createrId},#{item.createTime}, + #{item.updaterId},#{item.updaterTime} + ) + + + + 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 + ( + #{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} + ) + + + 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 + ( + #{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} + ) + \ No newline at end of file