From 9703e8584ce472efbf3cc00a26b489cf973564fc Mon Sep 17 00:00:00 2001 From: cwchen <1048842385@qq.com> Date: Wed, 8 May 2024 10:50:28 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E7=AB=99=E7=8F=AD=E4=BC=9A/=E7=AB=99?= =?UTF-8?q?=E7=8F=AD=E4=BC=9A=E4=BA=BA=E5=91=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inter/entity/JjClassMeetingPeople.java | 138 +++++++++ .../inter/entity/JjClassMeetting.java | 285 ++++++++++++++++++ .../executor/inter/mapper/InterMapper2.java | 33 ++ .../inter/service/DataCenterService.java | 28 +- .../executor/inter/service/InterService2.java | 100 ++++++ .../main/resources/mapper/InterMapper2.xml | 36 +++ 6 files changed, 617 insertions(+), 3 deletions(-) create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java new file mode 100644 index 0000000..fbe7177 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java @@ -0,0 +1,138 @@ +package com.xxl.job.executor.inter.entity; + +import java.util.Date; + /** + * 站班会人员 实体类 + * 2024-05-08 09:31:40 zijixiangba + */ + + +public class JjClassMeetingPeople{ + private String id; //主键ID + private String registrationDate; //准入生效日期 + private String validityPeriod; //准入失效期限 + private String provinceCode; //省公司编码 + private String createrId; //创建人 + private String createTime; //创建时间 + private String updaterId; //更新人 + private String updateTime; //更新时间 + private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 + private String workCode; //工种编码 + private String personnelId; //人员id； + private String toolBoxTalkId; //站班会id + private String realName; //姓名 + private String idCard; //身份证号 + private String positionCode; //岗位编码 + private String safetyGuardianFlag; //是否安全监护人；包括：0-非安全监护人；1-安全监护人 + private String positionFlag; //是否在岗 + private String workDivision; //具体分工 1-施工人员， 2-新增人员（临时人员） + public void setId(String id){ + this.id=id; + } + public String getId(){ + return id; + } + public void setRegistrationDate(String registrationDate){ + this.registrationDate=registrationDate; + } + public String getRegistrationDate(){ + return registrationDate; + } + public void setValidityPeriod(String validityPeriod){ + this.validityPeriod=validityPeriod; + } + public String getValidityPeriod(){ + return validityPeriod; + } + public void setProvinceCode(String provinceCode){ + this.provinceCode=provinceCode; + } + public String getProvinceCode(){ + return provinceCode; + } + public void setCreaterId(String createrId){ + this.createrId=createrId; + } + public String getCreaterId(){ + return createrId; + } + public void setCreateTime(String createTime){ + this.createTime=createTime; + } + public String getCreateTime(){ + return createTime; + } + public void setUpdaterId(String updaterId){ + this.updaterId=updaterId; + } + public String getUpdaterId(){ + return updaterId; + } + public void setUpdateTime(String updateTime){ + this.updateTime=updateTime; + } + public String getUpdateTime(){ + return updateTime; + } + public void setDeleteFlag(String deleteFlag){ + this.deleteFlag=deleteFlag; + } + public String getDeleteFlag(){ + return deleteFlag; + } + public void setWorkCode(String workCode){ + this.workCode=workCode; + } + public String getWorkCode(){ + return workCode; + } + public void setPersonnelId(String personnelId){ + this.personnelId=personnelId; + } + public String getPersonnelId(){ + return personnelId; + } + public void setToolBoxTalkId(String toolBoxTalkId){ + this.toolBoxTalkId=toolBoxTalkId; + } + public String getToolBoxTalkId(){ + return toolBoxTalkId; + } + public void setRealName(String realName){ + this.realName=realName; + } + public String getRealName(){ + return realName; + } + public void setIdCard(String idCard){ + this.idCard=idCard; + } + public String getIdCard(){ + return idCard; + } + public void setPositionCode(String positionCode){ + this.positionCode=positionCode; + } + public String getPositionCode(){ + return positionCode; + } + public void setSafetyGuardianFlag(String safetyGuardianFlag){ + this.safetyGuardianFlag=safetyGuardianFlag; + } + public String getSafetyGuardianFlag(){ + return safetyGuardianFlag; + } + public void setPositionFlag(String positionFlag){ + this.positionFlag=positionFlag; + } + public String getPositionFlag(){ + return positionFlag; + } + public void setWorkDivision(String workDivision){ + this.workDivision=workDivision; + } + public String getWorkDivision(){ + return workDivision; + } +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java new file mode 100644 index 0000000..98c4ba2 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java @@ -0,0 +1,285 @@ +package com.xxl.job.executor.inter.entity; + +import java.util.Date; + /** + * 站班会 实体类 + * 2024-05-08 09:31:40 zijixiangba + */ + + +public class JjClassMeetting{ + private String id; //主键ID + private String workStartTime; //作业开始时间 + private String currentConstrDate; //施工时间；施工日期 + private String currentConstructionStatus; //当前施工状态 01-开始；02-暂停； 03-恢复；04-完成 + private String workOvernightFlag; //是否跨零点作业 和 施工作业票日施工作业任务关联 中跨零点作业是否一致 ，，一致，作业时间算第二天 + private String toolBoxTalkAddress; //站班会地址 + private String toolBoxTalkLongitude; //站班会地理坐标-经度 + private String toolBoxTalkLatitude; //站班会地理坐标-纬度 + private String mcWorkSiteId; //距离站班会最近的作业部位ID；根据坐标获取最近的 + private String biddingSectionCode; //标段编码 + private String biddingSectionName; //标段名称 + private String offOnlineFlag; //离线标识：0-非离线，1-离线 + private String singleProjectCode; //单项工程编码 + private String singleProjectName; //单项工程名称 + private String singleProjectType; //单项工程类型 + private String constrUnifiedSocialCreditId; //施工单位统一社会信用代码 + private String supervisionUnitName; //监理单位名称 + private String supervisionSocialCreditCode; //监理单位统一社会信用代码 + private String voltageLevel; //电压等级编码 + private String huvFlag; //0:常规工程 1:特高压 + private String buildUnitCode; //建设管理单位编码 + private String provinceCode; //省公司编码 + private String createrId; //创建人； + private String prjName; //项目名称； + private String createTime; //创建时间 + private String updaterId; //更新人； + private String updateTime; //更新时间 + private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 + private String riskPrecautionId; //风险底数一本账id + private String talkDesStatusChangeId; // + private String fileId; // + private String cameraId; //布控球id； + private String prjCode; //项目编码 + private String ticketId; //作业票id + private String ticketNo; //作业票编号 + private String reAssessmentRiskLevel; //复测风险等级 + private String currentConstrHeadcount; //当日作业人数 + private String constructionHeadcount; //施工人数是当前班组人数 + private String changeTime; //状态变更时间 + public void setId(String id){ + this.id=id; + } + public String getId(){ + return id; + } + public void setWorkStartTime(String workStartTime){ + this.workStartTime=workStartTime; + } + public String getWorkStartTime(){ + return workStartTime; + } + public void setCurrentConstrDate(String currentConstrDate){ + this.currentConstrDate=currentConstrDate; + } + public String getCurrentConstrDate(){ + return currentConstrDate; + } + public void setCurrentConstructionStatus(String currentConstructionStatus){ + this.currentConstructionStatus=currentConstructionStatus; + } + public String getCurrentConstructionStatus(){ + return currentConstructionStatus; + } + public void setWorkOvernightFlag(String workOvernightFlag){ + this.workOvernightFlag=workOvernightFlag; + } + public String getWorkOvernightFlag(){ + return workOvernightFlag; + } + public void setToolBoxTalkAddress(String toolBoxTalkAddress){ + this.toolBoxTalkAddress=toolBoxTalkAddress; + } + public String getToolBoxTalkAddress(){ + return toolBoxTalkAddress; + } + public void setToolBoxTalkLongitude(String toolBoxTalkLongitude){ + this.toolBoxTalkLongitude=toolBoxTalkLongitude; + } + public String getToolBoxTalkLongitude(){ + return toolBoxTalkLongitude; + } + public void setToolBoxTalkLatitude(String toolBoxTalkLatitude){ + this.toolBoxTalkLatitude=toolBoxTalkLatitude; + } + public String getToolBoxTalkLatitude(){ + return toolBoxTalkLatitude; + } + public void setMcWorkSiteId(String mcWorkSiteId){ + this.mcWorkSiteId=mcWorkSiteId; + } + public String getMcWorkSiteId(){ + return mcWorkSiteId; + } + public void setBiddingSectionCode(String biddingSectionCode){ + this.biddingSectionCode=biddingSectionCode; + } + public String getBiddingSectionCode(){ + return biddingSectionCode; + } + public void setBiddingSectionName(String biddingSectionName){ + this.biddingSectionName=biddingSectionName; + } + public String getBiddingSectionName(){ + return biddingSectionName; + } + public void setOffOnlineFlag(String offOnlineFlag){ + this.offOnlineFlag=offOnlineFlag; + } + public String getOffOnlineFlag(){ + return offOnlineFlag; + } + public void setSingleProjectCode(String singleProjectCode){ + this.singleProjectCode=singleProjectCode; + } + public String getSingleProjectCode(){ + return singleProjectCode; + } + public void setSingleProjectName(String singleProjectName){ + this.singleProjectName=singleProjectName; + } + public String getSingleProjectName(){ + return singleProjectName; + } + public void setSingleProjectType(String singleProjectType){ + this.singleProjectType=singleProjectType; + } + public String getSingleProjectType(){ + return singleProjectType; + } + public void setConstrUnifiedSocialCreditId(String constrUnifiedSocialCreditId){ + this.constrUnifiedSocialCreditId=constrUnifiedSocialCreditId; + } + public String getConstrUnifiedSocialCreditId(){ + return constrUnifiedSocialCreditId; + } + public void setSupervisionUnitName(String supervisionUnitName){ + this.supervisionUnitName=supervisionUnitName; + } + public String getSupervisionUnitName(){ + return supervisionUnitName; + } + public void setSupervisionSocialCreditCode(String supervisionSocialCreditCode){ + this.supervisionSocialCreditCode=supervisionSocialCreditCode; + } + public String getSupervisionSocialCreditCode(){ + return supervisionSocialCreditCode; + } + public void setVoltageLevel(String voltageLevel){ + this.voltageLevel=voltageLevel; + } + public String getVoltageLevel(){ + return voltageLevel; + } + public void setHuvFlag(String huvFlag){ + this.huvFlag=huvFlag; + } + public String getHuvFlag(){ + return huvFlag; + } + public void setBuildUnitCode(String buildUnitCode){ + this.buildUnitCode=buildUnitCode; + } + public String getBuildUnitCode(){ + return buildUnitCode; + } + public void setProvinceCode(String provinceCode){ + this.provinceCode=provinceCode; + } + public String getProvinceCode(){ + return provinceCode; + } + public void setCreaterId(String createrId){ + this.createrId=createrId; + } + public String getCreaterId(){ + return createrId; + } + public void setPrjName(String prjName){ + this.prjName=prjName; + } + public String getPrjName(){ + return prjName; + } + public void setCreateTime(String createTime){ + this.createTime=createTime; + } + public String getCreateTime(){ + return createTime; + } + public void setUpdaterId(String updaterId){ + this.updaterId=updaterId; + } + public String getUpdaterId(){ + return updaterId; + } + public void setUpdateTime(String updateTime){ + this.updateTime=updateTime; + } + public String getUpdateTime(){ + return updateTime; + } + public void setDeleteFlag(String deleteFlag){ + this.deleteFlag=deleteFlag; + } + public String getDeleteFlag(){ + return deleteFlag; + } + public void setRiskPrecautionId(String riskPrecautionId){ + this.riskPrecautionId=riskPrecautionId; + } + public String getRiskPrecautionId(){ + return riskPrecautionId; + } + public void setTalkDesStatusChangeId(String talkDesStatusChangeId){ + this.talkDesStatusChangeId=talkDesStatusChangeId; + } + public String getTalkDesStatusChangeId(){ + return talkDesStatusChangeId; + } + public void setFileId(String fileId){ + this.fileId=fileId; + } + public String getFileId(){ + return fileId; + } + public void setCameraId(String cameraId){ + this.cameraId=cameraId; + } + public String getCameraId(){ + return cameraId; + } + public void setPrjCode(String prjCode){ + this.prjCode=prjCode; + } + public String getPrjCode(){ + return prjCode; + } + public void setTicketId(String ticketId){ + this.ticketId=ticketId; + } + public String getTicketId(){ + return ticketId; + } + public void setTicketNo(String ticketNo){ + this.ticketNo=ticketNo; + } + public String getTicketNo(){ + return ticketNo; + } + public void setReAssessmentRiskLevel(String reAssessmentRiskLevel){ + this.reAssessmentRiskLevel=reAssessmentRiskLevel; + } + public String getReAssessmentRiskLevel(){ + return reAssessmentRiskLevel; + } + public void setCurrentConstrHeadcount(String currentConstrHeadcount){ + this.currentConstrHeadcount=currentConstrHeadcount; + } + public String getCurrentConstrHeadcount(){ + return currentConstrHeadcount; + } + public void setConstructionHeadcount(String constructionHeadcount){ + this.constructionHeadcount=constructionHeadcount; + } + public String getConstructionHeadcount(){ + return constructionHeadcount; + } + public void setChangeTime(String changeTime){ + this.changeTime=changeTime; + } + public String getChangeTime(){ + return changeTime; + } +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java new file mode 100644 index 0000000..2a95326 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java @@ -0,0 +1,33 @@ +package com.xxl.job.executor.inter.mapper; + +import com.xxl.job.executor.inter.entity.*; +import org.apache.ibatis.annotations.Param; +import org.springframework.stereotype.Repository; + +import java.util.List; + +/** + * 数据接口数据层 + * @author 黑子 + */ +@Repository +public interface InterMapper2 { + + /* + * 插入站班会数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 9:57 + */ + void insertClassMeetingData(List list); + + /* + * 插入站班会人员数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 10:21 + */ + void insertClassMeetingPeopleData(List list); +} 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..dd556c5 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,10 +1,9 @@ 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 com.xxl.job.executor.inter.mapper.InterMapper2; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -22,6 +21,9 @@ public class DataCenterService { @Autowired private InterMapper mapper; + @Autowired + private InterMapper2 mapper2; + /** * 数据存储入库 * @param list @@ -60,4 +62,24 @@ public class DataCenterService { log.error(e.toString(),e); } } + + public void insertClassMeetingData(List list) { + try{ + mapper2.insertClassMeetingData(list); + }catch (Exception e){ + XxlJobHelper.log("站班会数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void getClassMeetingPeopleInfo(List list) { + try{ + mapper2.insertClassMeetingPeopleData(list); + }catch (Exception e){ + XxlJobHelper.log("站班会人员数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java new file mode 100644 index 0000000..c023ecf --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java @@ -0,0 +1,100 @@ +package com.xxl.job.executor.inter.service; + +import cn.hutool.http.HttpResponse; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.executor.inter.config.GlobalConfig; +import com.xxl.job.executor.inter.entity.JjClassMeetingPeople; +import com.xxl.job.executor.inter.entity.JjClassMeetting; +import com.xxl.job.executor.inter.utils.DataUtils; +import com.xxl.job.executor.inter.utils.PostUtils; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Map; + +/** + * 业务工程管理 + * + * @author cwchen + */ +@Service +@Slf4j +public class InterService2 { + + @Autowired + private DataCenterService service; + + + /** + * 分页 + */ + public Integer pageNum = 1; + /** + * 分页默认条数 + */ + public Integer pageSize = 10; + + + /* + * 站班会 + * @return void + * @author cwchen + * @date 2024/5/8 9:49 + */ + public void getClassMeetingInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "1"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetting.class); + service.insertClassMeetingData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /* + * 站班会人员 + * @return void + * @author cwchen + * @date 2024/5/8 10:14 + */ + public void getClassMeetingPeopleInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "2"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetingPeople.class); + service.getClassMeetingPeopleInfo(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } 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/resources/mapper/InterMapper2.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml new file mode 100644 index 0000000..27fecca --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml @@ -0,0 +1,36 @@ + + + + + + + REPLACE INTO jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address, + tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag, + single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, + voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, + create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, + file_id,,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, + current_constr_headcount,construction_headcount,change_time) VALUES + ( + #{item.id},#{item.workstartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, + #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, + #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, + #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId}, + #{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel}, + #{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime} + ) + + + + REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag, + position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name, + validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES + ( + #{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag}, + #{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName}, + #{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate} + ) + + \ No newline at end of file From a3379227a6d7bb6f15945d5e92ea15bc647cea6a Mon Sep 17 00:00:00 2001 From: cwchen <1048842385@qq.com> Date: Wed, 8 May 2024 13:10:47 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E7=AB=99=E7=8F=AD=E4=BC=9A/=E7=AB=99?= =?UTF-8?q?=E7=8F=AD=E4=BC=9A=E4=BA=BA=E5=91=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inter/entity/JjClassMeetingPeople.java | 214 ++++----- .../inter/entity/JjClassMeetting.java | 438 +++++++----------- .../inter/service/DataCenterService.java | 2 +- .../executor/inter/service/InterService2.java | 2 +- .../service/jobhandler/DataCenterXxlJob.java | 21 +- .../{InterMapper2.xml => Inter2Mapper.xml} | 4 +- 6 files changed, 263 insertions(+), 418 deletions(-) rename xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/{InterMapper2.xml => Inter2Mapper.xml} (94%) diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java index fbe7177..798c731 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetingPeople.java @@ -1,138 +1,88 @@ package com.xxl.job.executor.inter.entity; +import lombok.Data; + import java.util.Date; - /** - * 站班会人员 实体类 - * 2024-05-08 09:31:40 zijixiangba - */ - -public class JjClassMeetingPeople{ - private String id; //主键ID - private String registrationDate; //准入生效日期 - private String validityPeriod; //准入失效期限 - private String provinceCode; //省公司编码 - private String createrId; //创建人 - private String createTime; //创建时间 - private String updaterId; //更新人 - private String updateTime; //更新时间 - private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 - private String workCode; //工种编码 - private String personnelId; //人员id； - private String toolBoxTalkId; //站班会id - private String realName; //姓名 - private String idCard; //身份证号 - private String positionCode; //岗位编码 - private String safetyGuardianFlag; //是否安全监护人；包括：0-非安全监护人；1-安全监护人 - private String positionFlag; //是否在岗 - private String workDivision; //具体分工 1-施工人员， 2-新增人员（临时人员） - public void setId(String id){ - this.id=id; - } - public String getId(){ - return id; - } - public void setRegistrationDate(String registrationDate){ - this.registrationDate=registrationDate; - } - public String getRegistrationDate(){ - return registrationDate; - } - public void setValidityPeriod(String validityPeriod){ - this.validityPeriod=validityPeriod; - } - public String getValidityPeriod(){ - return validityPeriod; - } - public void setProvinceCode(String provinceCode){ - this.provinceCode=provinceCode; - } - public String getProvinceCode(){ - return provinceCode; - } - public void setCreaterId(String createrId){ - this.createrId=createrId; - } - public String getCreaterId(){ - return createrId; - } - public void setCreateTime(String createTime){ - this.createTime=createTime; - } - public String getCreateTime(){ - return createTime; - } - public void setUpdaterId(String updaterId){ - this.updaterId=updaterId; - } - public String getUpdaterId(){ - return updaterId; - } - public void setUpdateTime(String updateTime){ - this.updateTime=updateTime; - } - public String getUpdateTime(){ - return updateTime; - } - public void setDeleteFlag(String deleteFlag){ - this.deleteFlag=deleteFlag; - } - public String getDeleteFlag(){ - return deleteFlag; - } - public void setWorkCode(String workCode){ - this.workCode=workCode; - } - public String getWorkCode(){ - return workCode; - } - public void setPersonnelId(String personnelId){ - this.personnelId=personnelId; - } - public String getPersonnelId(){ - return personnelId; - } - public void setToolBoxTalkId(String toolBoxTalkId){ - this.toolBoxTalkId=toolBoxTalkId; - } - public String getToolBoxTalkId(){ - return toolBoxTalkId; - } - public void setRealName(String realName){ - this.realName=realName; - } - public String getRealName(){ - return realName; - } - public void setIdCard(String idCard){ - this.idCard=idCard; - } - public String getIdCard(){ - return idCard; - } - public void setPositionCode(String positionCode){ - this.positionCode=positionCode; - } - public String getPositionCode(){ - return positionCode; - } - public void setSafetyGuardianFlag(String safetyGuardianFlag){ - this.safetyGuardianFlag=safetyGuardianFlag; - } - public String getSafetyGuardianFlag(){ - return safetyGuardianFlag; - } - public void setPositionFlag(String positionFlag){ - this.positionFlag=positionFlag; - } - public String getPositionFlag(){ - return positionFlag; - } - public void setWorkDivision(String workDivision){ - this.workDivision=workDivision; - } - public String getWorkDivision(){ - return workDivision; - } +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：站班会人员实体类 + */ +@Data +public class JjClassMeetingPeople { + /** + * 主键ID + */ + private String id; + /** + * 准入生效日期 + */ + private String registrationDate; + /** + * 准入失效期限 + */ + private String validityPeriod; + /** + * 省公司编码 + */ + private String provinceCode; + /** + * 创建人 + */ + private String createrId; + /** + * 创建时间 + */ + private String createTime; + /** + * 更新人 + */ + private String updaterId; + /** + * 更新时间 + */ + private String updateTime; + /** + * 删除状态；默认0，包括：0未删除，1已删除 + */ + private String deleteFlag; + /** + * 工种编码 + */ + private String workCode; + /** + * 人员id + */ + private String personnelId; + /** + * 站班会id + */ + private String toolBoxTalkId; + /** + * 姓名 + */ + private String realName; + /** + * 身份证号 + */ + private String idCard; + /** + * 岗位编码 + */ + private String positionCode; + /** + * 是否安全监护人；包括：0-非安全监护人；1-安全监护人 + */ + private String safetyGuardianFlag; + /** + * 是否在岗 + */ + private String positionFlag; + /** + * 具体分工 1-施工人员， 2-新增人员（临时人员） + */ + private String workDivision; } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java index 98c4ba2..54e6761 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java @@ -1,285 +1,165 @@ package com.xxl.job.executor.inter.entity; import java.util.Date; - /** - * 站班会 实体类 - * 2024-05-08 09:31:40 zijixiangba - */ - -public class JjClassMeetting{ - private String id; //主键ID - private String workStartTime; //作业开始时间 - private String currentConstrDate; //施工时间；施工日期 - private String currentConstructionStatus; //当前施工状态 01-开始；02-暂停； 03-恢复；04-完成 - private String workOvernightFlag; //是否跨零点作业 和 施工作业票日施工作业任务关联 中跨零点作业是否一致 ，，一致，作业时间算第二天 - private String toolBoxTalkAddress; //站班会地址 - private String toolBoxTalkLongitude; //站班会地理坐标-经度 - private String toolBoxTalkLatitude; //站班会地理坐标-纬度 - private String mcWorkSiteId; //距离站班会最近的作业部位ID；根据坐标获取最近的 - private String biddingSectionCode; //标段编码 - private String biddingSectionName; //标段名称 - private String offOnlineFlag; //离线标识：0-非离线，1-离线 - private String singleProjectCode; //单项工程编码 - private String singleProjectName; //单项工程名称 - private String singleProjectType; //单项工程类型 - private String constrUnifiedSocialCreditId; //施工单位统一社会信用代码 - private String supervisionUnitName; //监理单位名称 - private String supervisionSocialCreditCode; //监理单位统一社会信用代码 - private String voltageLevel; //电压等级编码 - private String huvFlag; //0:常规工程 1:特高压 - private String buildUnitCode; //建设管理单位编码 - private String provinceCode; //省公司编码 - private String createrId; //创建人； - private String prjName; //项目名称； - private String createTime; //创建时间 - private String updaterId; //更新人； - private String updateTime; //更新时间 - private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 - private String riskPrecautionId; //风险底数一本账id - private String talkDesStatusChangeId; // - private String fileId; // - private String cameraId; //布控球id； - private String prjCode; //项目编码 - private String ticketId; //作业票id - private String ticketNo; //作业票编号 - private String reAssessmentRiskLevel; //复测风险等级 - private String currentConstrHeadcount; //当日作业人数 - private String constructionHeadcount; //施工人数是当前班组人数 - private String changeTime; //状态变更时间 - public void setId(String id){ - this.id=id; - } - public String getId(){ - return id; - } - public void setWorkStartTime(String workStartTime){ - this.workStartTime=workStartTime; - } - public String getWorkStartTime(){ - return workStartTime; - } - public void setCurrentConstrDate(String currentConstrDate){ - this.currentConstrDate=currentConstrDate; - } - public String getCurrentConstrDate(){ - return currentConstrDate; - } - public void setCurrentConstructionStatus(String currentConstructionStatus){ - this.currentConstructionStatus=currentConstructionStatus; - } - public String getCurrentConstructionStatus(){ - return currentConstructionStatus; - } - public void setWorkOvernightFlag(String workOvernightFlag){ - this.workOvernightFlag=workOvernightFlag; - } - public String getWorkOvernightFlag(){ - return workOvernightFlag; - } - public void setToolBoxTalkAddress(String toolBoxTalkAddress){ - this.toolBoxTalkAddress=toolBoxTalkAddress; - } - public String getToolBoxTalkAddress(){ - return toolBoxTalkAddress; - } - public void setToolBoxTalkLongitude(String toolBoxTalkLongitude){ - this.toolBoxTalkLongitude=toolBoxTalkLongitude; - } - public String getToolBoxTalkLongitude(){ - return toolBoxTalkLongitude; - } - public void setToolBoxTalkLatitude(String toolBoxTalkLatitude){ - this.toolBoxTalkLatitude=toolBoxTalkLatitude; - } - public String getToolBoxTalkLatitude(){ - return toolBoxTalkLatitude; - } - public void setMcWorkSiteId(String mcWorkSiteId){ - this.mcWorkSiteId=mcWorkSiteId; - } - public String getMcWorkSiteId(){ - return mcWorkSiteId; - } - public void setBiddingSectionCode(String biddingSectionCode){ - this.biddingSectionCode=biddingSectionCode; - } - public String getBiddingSectionCode(){ - return biddingSectionCode; - } - public void setBiddingSectionName(String biddingSectionName){ - this.biddingSectionName=biddingSectionName; - } - public String getBiddingSectionName(){ - return biddingSectionName; - } - public void setOffOnlineFlag(String offOnlineFlag){ - this.offOnlineFlag=offOnlineFlag; - } - public String getOffOnlineFlag(){ - return offOnlineFlag; - } - public void setSingleProjectCode(String singleProjectCode){ - this.singleProjectCode=singleProjectCode; - } - public String getSingleProjectCode(){ - return singleProjectCode; - } - public void setSingleProjectName(String singleProjectName){ - this.singleProjectName=singleProjectName; - } - public String getSingleProjectName(){ - return singleProjectName; - } - public void setSingleProjectType(String singleProjectType){ - this.singleProjectType=singleProjectType; - } - public String getSingleProjectType(){ - return singleProjectType; - } - public void setConstrUnifiedSocialCreditId(String constrUnifiedSocialCreditId){ - this.constrUnifiedSocialCreditId=constrUnifiedSocialCreditId; - } - public String getConstrUnifiedSocialCreditId(){ - return constrUnifiedSocialCreditId; - } - public void setSupervisionUnitName(String supervisionUnitName){ - this.supervisionUnitName=supervisionUnitName; - } - public String getSupervisionUnitName(){ - return supervisionUnitName; - } - public void setSupervisionSocialCreditCode(String supervisionSocialCreditCode){ - this.supervisionSocialCreditCode=supervisionSocialCreditCode; - } - public String getSupervisionSocialCreditCode(){ - return supervisionSocialCreditCode; - } - public void setVoltageLevel(String voltageLevel){ - this.voltageLevel=voltageLevel; - } - public String getVoltageLevel(){ - return voltageLevel; - } - public void setHuvFlag(String huvFlag){ - this.huvFlag=huvFlag; - } - public String getHuvFlag(){ - return huvFlag; - } - public void setBuildUnitCode(String buildUnitCode){ - this.buildUnitCode=buildUnitCode; - } - public String getBuildUnitCode(){ - return buildUnitCode; - } - public void setProvinceCode(String provinceCode){ - this.provinceCode=provinceCode; - } - public String getProvinceCode(){ - return provinceCode; - } - public void setCreaterId(String createrId){ - this.createrId=createrId; - } - public String getCreaterId(){ - return createrId; - } - public void setPrjName(String prjName){ - this.prjName=prjName; - } - public String getPrjName(){ - return prjName; - } - public void setCreateTime(String createTime){ - this.createTime=createTime; - } - public String getCreateTime(){ - return createTime; - } - public void setUpdaterId(String updaterId){ - this.updaterId=updaterId; - } - public String getUpdaterId(){ - return updaterId; - } - public void setUpdateTime(String updateTime){ - this.updateTime=updateTime; - } - public String getUpdateTime(){ - return updateTime; - } - public void setDeleteFlag(String deleteFlag){ - this.deleteFlag=deleteFlag; - } - public String getDeleteFlag(){ - return deleteFlag; - } - public void setRiskPrecautionId(String riskPrecautionId){ - this.riskPrecautionId=riskPrecautionId; - } - public String getRiskPrecautionId(){ - return riskPrecautionId; - } - public void setTalkDesStatusChangeId(String talkDesStatusChangeId){ - this.talkDesStatusChangeId=talkDesStatusChangeId; - } - public String getTalkDesStatusChangeId(){ - return talkDesStatusChangeId; - } - public void setFileId(String fileId){ - this.fileId=fileId; - } - public String getFileId(){ - return fileId; - } - public void setCameraId(String cameraId){ - this.cameraId=cameraId; - } - public String getCameraId(){ - return cameraId; - } - public void setPrjCode(String prjCode){ - this.prjCode=prjCode; - } - public String getPrjCode(){ - return prjCode; - } - public void setTicketId(String ticketId){ - this.ticketId=ticketId; - } - public String getTicketId(){ - return ticketId; - } - public void setTicketNo(String ticketNo){ - this.ticketNo=ticketNo; - } - public String getTicketNo(){ - return ticketNo; - } - public void setReAssessmentRiskLevel(String reAssessmentRiskLevel){ - this.reAssessmentRiskLevel=reAssessmentRiskLevel; - } - public String getReAssessmentRiskLevel(){ - return reAssessmentRiskLevel; - } - public void setCurrentConstrHeadcount(String currentConstrHeadcount){ - this.currentConstrHeadcount=currentConstrHeadcount; - } - public String getCurrentConstrHeadcount(){ - return currentConstrHeadcount; - } - public void setConstructionHeadcount(String constructionHeadcount){ - this.constructionHeadcount=constructionHeadcount; - } - public String getConstructionHeadcount(){ - return constructionHeadcount; - } - public void setChangeTime(String changeTime){ - this.changeTime=changeTime; - } - public String getChangeTime(){ - return changeTime; - } +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：站班会实体类 + */ +public class JjClassMeetting { + /** + * 主键ID + */ + private String id; + /** + * 作业开始时间 + */ + private String workStartTime; + /** + * 施工时间；施工日期 + */ + private String currentConstrDate; + /** + * 当前施工状态 01-开始；02-暂停； 03-恢复；04-完成 + */ + private String currentConstructionStatus; + /** + * 是否跨零点作业 和 施工作业票日施工作业任务关联 中跨零点作业是否一致 ，，一致，作业时间算第二天 + */ + private String workOvernightFlag; + /** + * 站班会地址 + */ + private String toolBoxTalkAddress; + /** + * 站班会地理坐标-经度 + */ + private String toolBoxTalkLongitude; + /** + * 站班会地理坐标-纬度 + */ + private String toolBoxTalkLatitude; + /** + * 距离站班会最近的作业部位ID；根据坐标获取最近的 + */ + private String mcWorkSiteId; + /** + * 标段编码 + */ + private String biddingSectionCode; + /** + * 标段名称 + */ + private String biddingSectionName; + /** + * 离线标识：0-非离线，1-离线 + */ + private String offOnlineFlag; + /** + * 单项工程编码 + */ + private String singleProjectCode; + /** + * 单项工程名称 + */ + private String singleProjectName; + /** + * 单项工程类型 + */ + private String singleProjectType; + /** + * 施工单位统一社会信用代码 + */ + private String constrUnifiedSocialCreditId; + /** + * 监理单位名称 + */ + private String supervisionUnitName; + /** + * 监理单位统一社会信用代码 + */ + private String supervisionSocialCreditCode; + /** + * 电压等级编码 + */ + private String voltageLevel; + /** + * 0:常规工程 1:特高压 + */ + private String huvFlag; + /** + * 建设管理单位编码 + */ + private String buildUnitCode; + /** + * 省公司编码 + */ + private String provinceCode; /** + * 创建人 + */ + private String createrId; + /** + * 项目名称 + */ + private String prjName; + /** + * 创建时间 + */ + private String createTime; + /** + * 更新人 + */ + private String updaterId; + /** + * 更新时间 + */ + private String updateTime; + /** + * 删除状态；默认0，包括：0未删除，1已删除 + */ + private String deleteFlag; + /** + * 风险底数一本账id + */ + private String riskPrecautionId; + /** + * + */ + private String talkDesStatusChangeId; + private String fileId; + /** + * 布控球id + */ + private String cameraId; + /** + * 项目编码 + */ + private String prjCode; + /** + * 作业票id + */ + private String ticketId; + /** + * 作业票编号 + */ + private String ticketNo; + /** + * 复测风险等级 + */ + private String reAssessmentRiskLevel; + /** + * 当日作业人数 + */ + private String currentConstrHeadcount; + /** + * 施工人数是当前班组人数 + */ + private String constructionHeadcount; + /** + * 状态变更时间 + */ + private String changeTime; } 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 dd556c5..339065f 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 @@ -73,7 +73,7 @@ public class DataCenterService { } } - public void getClassMeetingPeopleInfo(List list) { + public void insertClassMeetingPeopleData(List list) { try{ mapper2.insertClassMeetingPeopleData(list); }catch (Exception e){ diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java index c023ecf..3d9649d 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java @@ -85,7 +85,7 @@ public class InterService2 { JSONArray array = (JSONArray) map.get("array"); if (array != null) { List list = JSONArray.parseArray(array.toJSONString(), JjClassMeetingPeople.class); - service.getClassMeetingPeopleInfo(list); + service.insertClassMeetingPeopleData(list); pageNum++; if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { // getProInfo(); 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..982ad37 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 @@ -2,6 +2,7 @@ package com.xxl.job.executor.service.jobhandler; import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.executor.inter.service.InterService; +import com.xxl.job.executor.inter.service.InterService2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -16,6 +17,9 @@ public class DataCenterXxlJob { @Autowired private InterService interService; + @Autowired + private InterService2 interService2; + @XxlJob("getProInfo") public void getProInfo(){ interService.getProInfo(); @@ -27,13 +31,24 @@ public class DataCenterXxlJob { interService.getBidPro(); } - /** - * 站班会 - */ @XxlJob("getClassMet") public void getClassMet(){ interService.getClassMet(); } + /** + * 站班会定时任务 + */ + @XxlJob("getClassMeetingInfo") + public void getClassMeetingInfo(){ + interService2.getClassMeetingInfo(); + } + /** + * 站班会人员定时任务 + */ + @XxlJob("getClassMeetingPeopleInfo") + public void getClassMeetingPeopleInfo(){ + interService2.getClassMeetingPeopleInfo(); + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml similarity index 94% rename from xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml rename to xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml index 27fecca..45729e7 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper2.xml +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml @@ -10,10 +10,10 @@ single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, - file_id,,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, + file_id,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, current_constr_headcount,construction_headcount,change_time) VALUES ( - #{item.id},#{item.workstartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, + #{item.id},#{item.workStartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, From c48c576c699cb54af61a32d3552e8757227e53f4 Mon Sep 17 00:00:00 2001 From: cwchen <1048842385@qq.com> Date: Wed, 8 May 2024 16:02:46 +0800 Subject: [PATCH 3/3] =?UTF-8?q?SQL=E6=8F=92=E5=85=A5=E8=AF=AD=E5=8F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inter/entity/JjClassMeetting.java | 3 + .../inter/entity/JjDeptGcProject.java | 47 ++++ .../xxl/job/executor/inter/entity/JjGt.java | 79 ++++++ .../xxl/job/executor/inter/entity/JjInfo.java | 31 +++ .../job/executor/inter/entity/JjOnDuty.java | 39 +++ .../inter/entity/JjRiskPrecaution.java | 51 ++++ .../inter/entity/JjSingleProject.java | 120 +++++++++ .../xxl/job/executor/inter/entity/JjUnit.java | 50 ++++ .../executor/inter/mapper/InterMapper2.java | 68 +++++ .../inter/service/DataCenterService.java | 70 ++++++ .../executor/inter/service/InterService2.java | 212 +++++++++++++++- .../service/jobhandler/DataCenterXxlJob.java | 94 ++++++- .../main/resources/mapper/Inter2Mapper.xml | 234 +++++++++++++++--- 13 files changed, 1059 insertions(+), 39 deletions(-) create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDeptGcProject.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjGt.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjInfo.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjOnDuty.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjRiskPrecaution.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjSingleProject.java create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUnit.java diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java index 54e6761..84708d1 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjClassMeetting.java @@ -1,5 +1,7 @@ package com.xxl.job.executor.inter.entity; +import lombok.Data; + import java.util.Date; /** @@ -8,6 +10,7 @@ import java.util.Date; * @version：1.0 * @description：站班会实体类 */ +@Data public class JjClassMeetting { /** * 主键ID diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDeptGcProject.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDeptGcProject.java new file mode 100644 index 0000000..22c280b --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDeptGcProject.java @@ -0,0 +1,47 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：项目部实体类 + */ + +@Data +public class JjDeptGcProject{ + private String id; //主键ID + private String deptId; //项目部ID + private String prjCode; //项目编码 + private String singleProjectCode; //单项工程编码 + private String biddingSectionCode; //标段编码 + private String disbandFlag; //是否解散；0：否；1：是； + private String dDeleteFlag; //删除状态；默认 0；0：未删除；1：已删除 + private String year; //年份；默认当前年 + private String provinceCode; //省公司编码 + private String buildUnitCode; //建设管理单位编码 + private String projectDeptNo; //项目部编码 + private String projectDepartmentName; //项目部名称 + private String affiliationCode; //所属单位编码 + private String establishmentDate; //成立日期 + private String deptProvinceCode; //项目部地址省编码 + private String deptCitiesCode; //项目部地址市编码 + private String deptDistrictCode; //项目部地址区编码 + private String address; //详细地址 + private String postalCode; //邮政编码 + private String contactTelephone; //办公电话 + private String emailAddress; //电子邮箱 + private String faxNo; //传真号码 + private String groupMarkup; //是否为班组式；0：否；1：是； + private String departmentType; //是否为班组式；0：否；1：是； + private String departmentStatus; //项目部文件签署状态；0：通知已签署；1：通知未签署; + private String historyFlag; //是否历史；默认 0；0：否；1：是 + private String pDeleteFlag; //删除状态；默认 0；0：未删除；1：已删除 + private String createrId; //创建人 + private String createTime; //创建时间 + private String updaterId; //修改人 + private String updateTime; //修改时间 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjGt.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjGt.java new file mode 100644 index 0000000..f0fe791 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjGt.java @@ -0,0 +1,79 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：杆塔实体类 + */ +@Data +public class JjGt{ + private String id; //主键 + private String topography; //地形地貌； + private String stentFlag; //是否架构；1是、0否 + private String borrowedFlag; //是否借用塔；1是、0否。 + private String span; //档距； + private String towerCuircuitNumber; //杆塔回数；0 单回,1 双回,2 三回,3 四回,4 六回 + private String circuitQuantity; //线路回数；0 单回,1 双回,2 三回,3 四回,4 六回 + private String longitude; //经度； + private String latitude; //纬度； + private String eastCoordinate; //东坐标； + private String northCoordinate; //北坐标； + private String singleProjectCode; //单项工程编码 + private String centerPileElevation; //中心桩高程； + private String rotationDegree; //转角度数； + private String geology; //地质； + private String towerLegBaseformFirst; //塔脚1基础形式；0装配式,1非装配式,2灌注桩,3其他,阶梯基础,4直柱大板基础,5斜柱基础,6角钢插入基础,7岩石基础,8半掏挖基础,9掏挖基础,10岩石嵌固基础. (支持手动录入) + private String towerLegBaseformSecond; //塔脚2基础形式； + private String towerLegBaseformThird; //塔脚3基础形式； + private String towerLegBaseformFourth; //塔脚4基础形式； + private String towerLegMaxDepthFirst; //塔脚1基础最大深度m + private String towerLegMaxDepthSecond; //塔脚2基础最大深度m； + private String towerLegMaxDepthThird; //塔脚3基础最大深度m； + private String biddingSectionCode; //标段编码 + private String towerLegMaxDepthFourth; //塔脚4基础最大深度m； + private String towerType; //杆塔型式 + private String tensionTowerFlag; //1) 名称: 是否耐张塔 2)1是 0否 + private String towerStructure; //杆塔结构 2）描述 + private String createrId; // + private String createTime; // + private String updaterId; // + private String updateTime; // + private String deleteFlag; // + private String provinceCode; //省公司编码 + private String generalDesignFlag; //是否应用通用设计；1是、0否。 + private String towerTypeNo; //塔型编号 + private String upstreamTowerNo; //上行塔号 + private String dismantleFlag; //是否拆旧 1是 0否 + private String cover4gFlag; //4g信号是否覆盖 1是 0否 + private String towerSequenceNo; //杆塔排列序号，默认0起 逐次+1 + private String remark; //备注 + private String representativeSpan; //代表档距 + private String tensionSectionLength; //耐张段长度 + private String county; //区县 + private String town; //乡镇 + private String towerNo; //塔号； + private String village; //村庄 + private String runTowerCode; //运行塔号 + private String groundThingName; //地上物 + private String designChangeNo; //设计变更编号 + private String sectionDividePointFlag; //1) 是否区段点击杆塔 区段划分时用到的，被定位就 1 没有为0或null + private String sectionAdjustNum; //1) 区段划分调整量 用于区段划分中区段调整量 向前为-0.00 向后为+0.00 + private String towerWeight; //塔重 + private String slope; //塔基坡度 + private String constructionDeptId; //施工项目部id + private String supervisionDeptId; //监理项目部id + private String moduleNo; //模块编号； + private String deviseDeptId; //设计项目部id + private String ownerDeptId; //业主项目部id + private String uhvFlag; // + private String address; //细地址 + private String customFlag; //自定义标识 + private String nominalHeight; //呼称高； + private String towerFullHeight; //塔全高； + private String majorCrossingFlag; //重要跨越跨越物； +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjInfo.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjInfo.java new file mode 100644 index 0000000..cdc1630 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjInfo.java @@ -0,0 +1,31 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：扩展信息实体类 + */ +@Data +public class JjInfo { + private String id; // + private String replenishContent1; //补充内容 + private String replenishContent2; //补充内容 + private String replenishContent3; //补充内容 + private String replenishContent4; //补充内容 + private String replenishContent5; //补充内容 + private String replenishContent6; //补充内容 + private String replenishContent7; //补充内容 + private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 + private String createTime; // + private String updateTime; // + private String refId; //外键id； + private String refId2; //外键id； + private String sortNo; //排序号 + private String extType; //扩展类型：10：风险预控措施,20：施工作业票_预控措施30：预控措施_站班会40：施工作业票_扩展信息50：风险底数一本账_扩展信息 60：站班会_扩展信息 70：站班会_拆分扩展信息 + private String contentType; //ext_type 10：预控措施类型；包括：01-风险库；02-风险清册；03-风险底数一本账；04-一览表 20：预控措施 30：预控措施 40：内容类型；包括：01-变化情况；02-情况控制措施；03-主要风险 50：内容类型；包括：01-备注；02-风险可能导致后果；03-风险控制关键因素；04-作业部位名称；05-一览表作业部位名称 60：当日控制措施 70：内容类型；包括：01-备注；02-现场风险复测变化情况及补充措施；03-风险异常原因；04-补充安全控制措施 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjOnDuty.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjOnDuty.java new file mode 100644 index 0000000..45f7203 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjOnDuty.java @@ -0,0 +1,39 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：到岗到位实体类 + */ + +@Data +public class JjOnDuty{ + private String id; //主键ID + private String biddingSectionCode; //标段编码 + private String singleProjectCode; //单项工程编码 + private String prjCode; //项目编码 + private String idCard; //身份证号 + private String buildUnitCode; //建设管理单位编码 + private String provinceCode; //省公司编码 + private String createrId; //创建人 + private String createTime; //创建时间 + private String updaterId; //更新人 + private String updateTime; //更新时间 + private String toolBoxTalkId; //站班会id + private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 + private String ondutyLongitude; //到岗到位经度 + private String ondutyLatitude; //到岗到位纬度 + private String ondutyAddress; //地址 + private String personnelId; //人员id + private String realName; //现场监督人员姓名； + private String unitName; //现场监督人员单位名 + private String positionCode; //岗位编码 + private String mobile; //手机号码 + private String ondutyHierarchy; //履职人员所属层级；包括：10施工，20监理，30业主,40建管，50省公司 + private String remark; //备注 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjRiskPrecaution.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjRiskPrecaution.java new file mode 100644 index 0000000..1745330 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjRiskPrecaution.java @@ -0,0 +1,51 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：风险底数一本帐实体类 + */ + +@Data +public class JjRiskPrecaution{ + private String id; //主键ID + private String partSubentry; //分部分项 + private String workType; //作业类型 + private String workProcedure; //工序 + private String assessmentRiskLevel; //初勘风险等级 + private String reAssessmentRiskLevel; //复测风险等级 + private String minConstrHeadcount; //最少施工人数 + private String riskAssessmentValue; //风险评估值(D) + private String workContent; //作业内容 + private String workingCondition; //8+2工况 + private String voltageDrpFlag; //是否压降 + private String sourceRiskPrecautionId; //风险底数一本账源头id + private String merge; //合并作业分组 + private String riskStatus; //风险状态；包括：01-待执行，02-执行中，03-已完成，04-已销号 + private String publishState; //发布状态 01 待提交 02 已发布 + private String plannedStartDate; //计划开始时间 + private String executeTime; //执行时间 + private String endTime; //结束时间 + private String huvFlag; //0:常规工程 1:特高压 + private String buildUnitCode; //建设管理单位编码； + private String provinceCode; //省公司编码 + private String createrId; //创建人 + private String riskNo; //风险编号 + private String createTime; //创建时间 + private String updaterId; //更新人 + private String updateTime; //更新时间 + private String deleteFlag; //删除状态；默认0，包括：0未删除，1已删除 + private String workingConditionFlag; //是否8+2工况，默认0；包括：0否，1是 + private String constrMethId; //工法ID；工法ID，字符串拼接，使用“,”隔开单项工程编码 + private String singleProjectCode; //单项工程编码 + private String biddingSectionCode; //标段编码 + private String workSiteId; //作业部位id + private String workSiteName; //作业部位名称 + private String workSiteType; //作业部位类型；1-变电，2-电力井，3-杆塔，4-区段 + private String professional; //工程类型 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjSingleProject.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjSingleProject.java new file mode 100644 index 0000000..1f74374 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjSingleProject.java @@ -0,0 +1,120 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：单项工程实体类 + */ +@Data +public class JjSingleProject{ + private String id; //主键ID + private String singleProjectType; //单项工程类型 + private String jgjsverSpecialProjectExpense; //特殊项目费 + private String jgjsverAuxiliaryFacilitiesCost; //辅助设施工程 + private String jgjsverCostFileName; //造价文件名称 + private String jgjsverProjectType; //造价的工程类型 + private String jgjsverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算 + private String jgjsverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回 + private String singleProjectPrerType; //单项工程预规类型 + private String singleProjectDetailsType; //单项工程明细类型 + private String constrNature; //建设性质 + private String constructionLineLength; //建设线路长度 + private String constrTransformerCapacity; //建设变电容量 + private String productionLineLength; //投产线路长度 + private String prodTransCapacity; //投产变电容量 + private String feaLineLength; //可研线路长度 + private String feasTransCapacity; //可研变电容量 + private String prjCode; //项目编码 + private String lineQuantity; //线路条数 + private String mainTransformerQuantity; //主变台数 + private String feaDinvest; //可研动态投资 + private String feaSinvest; //可研静态投资 + private String applyFlag; //是否申请创优工程，默认0， 0：否；1：是 + private String integrateIntosysFlag; //是否纳入系统管理：0：否；1：是； + private String status; //状态：0：未提交；1：已提交； + private String plannedCommencementDate; //计划开工时间 + private String actualCommencementDate; //实际开工时间 + private String plannedCommissioningDate; //计划投产时间 + private String singleProjectCode; //单项工程编码 + private String actualCommissioningDate; //实际投产时间 + private String planComplDate; //计划竣工时间 + private String actualCompletionDate; //实际竣工时间 + private String constructionStatus; //在建状态：默认0：0：施工；1：暂停； + private String constrAddress; //建设地址 + private String locationProvince; //单项所在省编码， + private String locationProvinceName; //单项所在省名称 + private String locationMunicipality; //单项所在市编码 + private String locationMunicipalityName; //单项所在市名称， + private String locationArea; //单项所在区/县编码， + private String singleProjectName; //单项工程 + private String locationAreaName; //单项所在区/县名称 + private String deleteFlag; //删除状态：默认 0；0：未删除；1：已删除 + private String createrId; //创建人 + private String createTime; //创建时间 + private String updaterId; //修改人 + private String updateTime; //修改时间 + private String gspfverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算 + private String gspfverVersion; //版本；GSPFVER：概算审定版 + private String gspfverDynamicInvestment; //单项动态投资 + private String gspfverStaticInvestment; //单项静态投资 + private String provinceCode; //省公司编码； + private String gspfverConstructionCost; //建筑工程费 + private String gspfverInstallationCost; //安装工程费 + private String gspfverCostOfEquipProcurement; //设备购置费 + private String gspfverOtherExpenses; //其他工程费 + private String gspfverBasicContingency; //基本预备费 + private String gspfverSpecialProjectExpense; //特殊项目费 + private String gspfverAuxiliaryFacilitiesCost; //辅助设施工程 + private String gspfverCostFileName; //造价文件名称 + private String gspfverProjectType; //造价的工程类型 + private String gspfverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算 + private String provinceName; //省公司名称 + private String gspfverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回 + private String sgtssverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算 + private String sgtssverVersion; //版本；SGTSSVER：预算建安版、 + private String sgtssverDynamicInvestment; //单项动态投资 + private String sgtssverStaticInvestment; //单项静态投资 + private String sgtssverConstructionCost; //建筑工程费 + private String sgtssverInstallationCost; //安装工程费 + private String sgtssverCostOfEquipProcurement; //设备购置费 + private String sgtssverOtherExpenses; //其他工程费 + private String sgtssverBasicContingency; //基本预备费 + private String buildUnitCode; //建设管理单位编码； + private String sgtssverSpecialProjectExpense; //特殊项目费 + private String sgtssverAuxiliaryFacilitiesCost; //辅助设施工程 + private String sgtssverCostFileName; //造价文件名称 + private String sgtssverProjectType; //造价的工程类型 + private String sgtssverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算 + private String sgtssverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回 + private String sgtpfverStag; //阶段； + private String sgtpfverVersion; //版本；SGTPFVER：预算全口径版 + private String sgtpfverDynamicInvestment; //单项动态投资 + private String sgtpfverStaticInvestment; //单项静态投资 + private String buildUnitName; //建设管理单位名称； + private String sgtpfverConstructionCost; //建筑工程费 + private String sgtpfverInstallationCost; //安装工程费 + private String sgtpfverCostOfEquipProcurement; //设备购置费 + private String sgtpfverOtherExpenses; //其他工程费 + private String sgtpfverBasicContingency; //基本预备费 + private String sgtpfverSpecialProjectExpense; //特殊项目费 + private String sgtpfverAuxiliaryFacilitiesCost; //辅助设施工程 + private String sgtpfverCostFileName; //造价文件名称 + private String sgtpfverProjectType; //造价的工程类型 + private String sgtpfverSoftwareType; //造价软件类型；造价软件类型 造价2016、造价2018预规、造价2018综合单价、造价2018结算 + private String voltageLevel; //电压等级编码 + private String sgtpfverStatus; //状态；状态 1：未完成、2：已完成、3：DB模式、4：已退回 + private String jgjsverStage; //阶段；GENERAL：概算、SGT：预算、BALANC：结算 + private String jgjsverVersion; //版本；JGJSVER：结算审定版 + private String jgjsverDynamicInvestment; //单项动态投资 + private String jgjsverStaticInvestment; //单项静态投资 + private String jgjsverConstructionCost; //建筑工程费 + private String jgjsverInstallationCost; //安装工程费 + private String jgjsverCostOfEquipProcurement; //设备购置费 + private String jgjsverOtherExpenses; //其他工程费 + private String jgjsverBasicContingency; //基本预备费 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUnit.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUnit.java new file mode 100644 index 0000000..17b0903 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjUnit.java @@ -0,0 +1,50 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +import java.util.Date; +/** + * @author：cwchen + * @date：2024-05-08-11:26 + * @version：1.0 + * @description：基建单位实体类 + */ +@Data +public class JjUnit{ + private String id; //主键 + private String legalReprMobile; //法定代表人手机号 + private String contactPhone; //联系方式； + private String unitType; //单位类型（1-建设管理单位 2-勘察单位 3-设计单位 4-评审单位 5-监理单位 6-施工单位 7-分包单位 8-环保单位 99-其他） + private String unitNature; //单位性质 + private String sysType; //系统类型； + private String sysCateg; //系统分类； + private String unitSign; //单位标识 + private String establishmentDate; //成立日期； + private String registerCapital; //注册资本； + private String website; //企业网站 + private String iscUnitId; //基建id + private String province; //所在省 + private String city; //所在市 + private String county; //所在县 + private String address; //单位地址 + private String mainBusiness; //经营范围； + private String dataSource; //数据来源； + private String huvFlag; //0:常规工程 1:特高压 + private String provinceCode; //网省编码 + private String buildUnitCode; //建设管理单位编码 + private String createrId; //创建人 + private String safetySgcUnitId; //安监id + private String createTime; //创建时间 + private String updaterId; //修改人 + private String updateTime; //修改时间 + private String deleteFlag; // + private String legalIdCard; //法人身份证号 + private String businessFileId; //营业执照照片id + private String unitName; //单位全称 + private String unitAbbrName; //单位简称 + private String unitCode; //单位编码 + private String mainCode; //主数据单位编码 + private String unifiedSocialCreditId; //统一社会信用代码 + private String legalRepr; //法定代表人 +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java index 2a95326..4da506b 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper2.java @@ -8,6 +8,7 @@ import java.util.List; /** * 数据接口数据层 + * * @author 黑子 */ @Repository @@ -30,4 +31,71 @@ public interface InterMapper2 { * @date 2024/5/8 10:21 */ void insertClassMeetingPeopleData(List list); + + /** + * 插入单项工程数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 13:49 + */ + void insertSingleProjectData(List list); + + /** + * 插入到岗到位数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:23 + */ + void insertOnDutyData(List list); + + /** + * 插入风险底数一本帐数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:35 + */ + void insertRiskPrecautionData(List list); + + /** + * 插入基建单位数据 + * + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 14:49 + */ + void insertUnitData(List list); + + /** + * 插入扩展信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:08 + */ + void insertInfoData(List list); + + /** + * 插入杆塔信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:40 + */ + void insertGtData(List list); + + /** + * 插入项目部信息数据 + * @param list + * @return void + * @author cwchen + * @date 2024/5/8 15:56 + */ + void insertDeptGcProjectData(List list); } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java index 339065f..9bfd8c9 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 @@ -82,4 +82,74 @@ public class DataCenterService { log.error(e.toString(),e); } } + + public void insertSingleProjectData(List list) { + try{ + mapper2.insertSingleProjectData(list); + }catch (Exception e){ + XxlJobHelper.log("单项工程数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertOnDutyData(List list) { + try{ + mapper2.insertOnDutyData(list); + }catch (Exception e){ + XxlJobHelper.log("到岗到位数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertRiskPrecautionData(List list) { + try{ + mapper2.insertRiskPrecautionData(list); + }catch (Exception e){ + XxlJobHelper.log("风险底数一本帐数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertUnitData(List list) { + try{ + mapper2.insertUnitData(list); + }catch (Exception e){ + XxlJobHelper.log("基建单位数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertInfoData(List list) { + try{ + mapper2.insertInfoData(list); + }catch (Exception e){ + XxlJobHelper.log("扩展数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertGtData(List list) { + try{ + mapper2.insertGtData(list); + }catch (Exception e){ + XxlJobHelper.log("杆塔数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } + + public void insertDeptGcProjectData(List list) { + try{ + mapper2.insertDeptGcProjectData(list); + }catch (Exception e){ + XxlJobHelper.log("项目部数据处理异常内容--->{}",e.toString()); + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(),e); + } + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java index 3d9649d..e687dca 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService2.java @@ -5,8 +5,7 @@ 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.JjClassMeetingPeople; -import com.xxl.job.executor.inter.entity.JjClassMeetting; +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; @@ -96,5 +95,214 @@ public class InterService2 { log.error(e.toString(), e); } } + + /** + * 单项工程 + * + * @return void + * @author cwchen + * @date 2024/5/8 13:48 + */ + public void getSingleProjectInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "3"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjSingleProject.class); + service.insertSingleProjectData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 到岗到位 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:22 + */ + public void getOnDutyInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "4"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjOnDuty.class); + service.insertOnDutyData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 风险底数一本帐 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:33 + */ + public void getRiskPrecautionInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "5"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjRiskPrecaution.class); + service.insertRiskPrecautionData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 基建单位 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:48 + */ + public void getUnitInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "6"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjUnit.class); + service.insertUnitData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 扩展信息 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:58 + */ + public void getInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "7"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjInfo.class); + service.insertInfoData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 杆塔 + * + * @return void + * @author cwchen + * @date 2024/5/8 15:37 + */ + public void getGtInfo() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "8"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjGt.class); + service.insertGtData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + log.error(e.toString(), e); + } + } + + /** + * 项目部 + * @return void + * @author cwchen + * @date 2024/5/8 15:55 + */ + public void getDeptGcProject() { + try { + //当前页 + int pageNum = 1; + JSONObject obj = new JSONObject(); + obj.put("type", "9"); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjDeptGcProject.class); + service.insertDeptGcProjectData(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + // getProInfo(); + } + } + } 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 982ad37..9261f95 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 @@ -8,6 +8,7 @@ import org.springframework.stereotype.Component; /** * 数据中台 处理中心 + * * @author 黑子 */ @Component @@ -21,18 +22,18 @@ public class DataCenterXxlJob { private InterService2 interService2; @XxlJob("getProInfo") - public void getProInfo(){ + public void getProInfo() { interService.getProInfo(); } @XxlJob("getBidPro") - public void getBidPro(){ + public void getBidPro() { interService.getBidPro(); } @XxlJob("getClassMet") - public void getClassMet(){ + public void getClassMet() { interService.getClassMet(); } @@ -40,7 +41,7 @@ public class DataCenterXxlJob { * 站班会定时任务 */ @XxlJob("getClassMeetingInfo") - public void getClassMeetingInfo(){ + public void getClassMeetingInfo() { interService2.getClassMeetingInfo(); } @@ -48,7 +49,90 @@ public class DataCenterXxlJob { * 站班会人员定时任务 */ @XxlJob("getClassMeetingPeopleInfo") - public void getClassMeetingPeopleInfo(){ + public void getClassMeetingPeopleInfo() { interService2.getClassMeetingPeopleInfo(); } + + /** + * 单项工程定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:11 + */ + @XxlJob("getSingleProjectInfo") + public void getSingleProjectInfo() { + interService2.getSingleProjectInfo(); + } + + /** + * 到岗到位定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:27 + */ + @XxlJob("getOnDutyInfo") + public void getOnDutyInfo() { + interService2.getOnDutyInfo(); + } + + /** + * 风险底数一本帐定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:38 + */ + @XxlJob("getRiskPrecautionInfo") + public void getRiskPrecautionInfo() { + interService2.getRiskPrecautionInfo(); + } + + /** + * 基建单位定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:53 + */ + @XxlJob("getUnitInfo") + public void getUnitInfo() { + interService2.getUnitInfo(); + } + + /** + * 扩展信息定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 14:53 + */ + @XxlJob("getInfo") + public void getInfo() { + interService2.getInfo(); + } + + /** + * 杆塔定时任务 + * + * @return void + * @author cwchen + * @date 2024/5/8 15:45 + */ + @XxlJob("getGtInfo") + public void getGtInfo() { + interService2.getGtInfo(); + } + + /** + * 项目部定时任务 + * @return void + * @author cwchen + * @date 2024/5/8 16:00 + */ + @XxlJob("getDeptGcProject") + public void getDeptGcProject() { + interService2.getDeptGcProject(); + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml index 45729e7..c511f38 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/Inter2Mapper.xml @@ -1,36 +1,206 @@ - + - - - REPLACE INTO jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address, - tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag, - single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, - voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, - create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, - file_id,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, - current_constr_headcount,construction_headcount,change_time) VALUES - ( - #{item.id},#{item.workStartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, - #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, - #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, - #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, - #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId}, - #{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel}, - #{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime} - ) - - - - REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag, - position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name, - validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES - ( - #{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag}, - #{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName}, - #{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate} - ) - + + + REPLACE INTO + jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address, + tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag, + single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code, + voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name, + create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id, + file_id,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level, + current_constr_headcount,construction_headcount,change_time) VALUES + ( + #{item.id},#{item.workStartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress}, + #{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag}, + #{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode}, + #{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId}, + #{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel}, + #{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime} + ) + + + + + REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag, + position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name, + validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES + ( + #{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag}, + #{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName}, + #{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate} + ) + + + + + REPLACE INTO jj_single_project(id, single_project_type, jgjsver_special_project_expense, + jgjsver_auxiliary_facilities_cost, jgjsver_cost_file_name, jgjsver_project_type, jgjsver_software_type, + jgjsver_status, single_project_prer_type, single_project_details_type, constr_nature, construction_line_length, + constr_transformer_capacity, production_line_length, prod_trans_capacity, fea_line_length, feas_trans_capacity, + prj_code, line_quantity, main_transformer_quantity, fea_dinvest, fea_sinvest, apply_flag, + integrate_intosys_flag, status, planned_commencement_date, actual_commencement_date, planned_commissioning_date, + single_project_code, actual_commissioning_date, plan_compl_date, actual_completion_date, construction_status, + constr_address, location_province, location_province_name, location_municipality, location_municipality_name, + location_area, single_project_name, location_area_name, delete_flag, creater_id, create_time, updater_id, + update_time, gspfver_stage, gspfver_version, gspfver_dynamic_investment, gspfver_static_investment, + province_code, gspfver_construction_cost, gspfver_installation_cost, gspfver_cost_of_equip_procurement, + gspfver_other_expenses, gspfver_basic_contingency, gspfver_special_project_expense, + gspfver_auxiliary_facilities_cost, gspfver_cost_file_name, gspfver_project_type, gspfver_software_type, + province_name, gspfver_status, sgtssver_stage, sgtssver_version, sgtssver_dynamic_investment, + sgtssver_static_investment, sgtssver_construction_cost, sgtssver_installation_cost, + sgtssver_cost_of_equip_procurement, sgtssver_other_expenses, sgtssver_basic_contingency, build_unit_code, + sgtssver_special_project_expense, sgtssver_auxiliary_facilities_cost, sgtssver_cost_file_name, + sgtssver_project_type, sgtssver_software_type, sgtssver_status, sgtpfver_stag, sgtpfver_version, + sgtpfver_dynamic_investment, sgtpfver_static_investment, BUILD_UNIT_NAME, sgtpfver_construction_cost, + sgtpfver_installation_cost, sgtpfver_cost_of_equip_procurement, sgtpfver_other_expenses, + sgtpfver_basic_contingency, sgtpfver_special_project_expense, sgtpfver_auxiliary_facilities_cost, + sgtpfver_cost_file_name, sgtpfver_project_type, sgtpfver_software_type, voltage_level, sgtpfver_status, + jgjsver_stage, jgjsver_version, jgjsver_dynamic_investment, jgjsver_static_investment, + jgjsver_construction_cost, jgjsver_installation_cost, jgjsver_cost_of_equip_procurement, jgjsver_other_expenses, + jgjsver_basic_contingency) VALUES + + ( + #{item.id},#{item.singleProjectType},#{item.jgjsverSpecialProjectExpense}, + #{item.jgjsverAuxiliaryFacilitiesCost},#{item.jgjsverCostFileName},#{item.jgjsverProjectType},#{item.jgjsverSoftwareType}, + #{item.jgjsverStatus},#{item.singleProjectPrerType},#{item.singleProjectDetailsType},#{item.constrNature},#{item.constructionLineLength}, + #{item.constrTransformerCapacity},#{item.productionLineLength},#{item.prodTransCapacity},#{item.feaLineLength},#{item.feasTransCapacity}, + #{item.prjCode},#{item.lineQuantity},#{item.mainTransformerQuantity},#{item.feaDinvest},#{item.feaSinvest},#{item.applyFlag}, + #{item.integrateIntosysFlag},#{item.status},#{item.plannedCommencementDate},#{item.actualCommencementDate},#{item.plannedCommissioningDate}, + #{item.singleProjectCode},#{item.actualCommissioningDate},#{item.planComplDate},#{item.actualCompletionDate},#{item.constructionStatus}, + #{item.constrAddress},#{item.locationProvince},#{item.locationProvinceName},#{item.locationMunicipality},#{item.locationMunicipalityName}, + #{item.locationArea},#{item.singleProjectName},#{item.locationAreaName},#{item.deleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId}, + #{item.updateTime},#{item.gspfverStage},#{item.gspfverVersion},#{item.gspfverDynamicInvestment},#{item.gspfverStaticInvestment}, + #{item.provinceCode},#{item.gspfverConstructionCost},#{item.gspfverInstallationCost},#{item.gspfverCostOfEquipProcurement}, + #{item.gspfverOtherExpenses},#{item.gspfverBasicContingency},#{item.gspfverSpecialProjectExpense}, + #{item.gspfverAuxiliaryFacilitiesCost},#{item.gspfverCostFileName},#{item.gspfverProjectType},#{item.gspfverSoftwareType}, + #{item.provinceName},#{item.gspfverStatus},#{item.sgtssverStage},#{item.sgtssverVersion},#{item.sgtssverDynamicInvestment}, + #{item.sgtssverStaticInvestment},#{item.sgtssverConstructionCost},#{item.sgtssverInstallationCost}, + #{item.sgtssverCostOfEquipProcurement},#{item.sgtssverOtherExpenses},#{item.sgtssverBasicContingency},#{item.buildUnitCode}, + #{item.sgtssverSpecialProjectExpense},#{item.sgtssverAuxiliaryFacilitiesCost},#{item.sgtssverCostFileName}, + #{item.sgtssverProjectType},#{item.sgtssverSoftwareType},#{item.sgtssverStatus},#{item.sgtpfverStag},#{item.sgtpfverVersion}, + #{item.sgtpfverDynamicInvestment},#{item.sgtpfverStaticInvestment},#{item.buildUnitName},#{item.sgtpfverConstructionCost}, + #{item.sgtpfverInstallationCost},#{item.sgtpfverCostOfEquipProcurement},#{item.sgtpfverOtherExpenses}, + #{item.sgtpfverBasicContingency},#{item.sgtpfverSpecialProjectExpense},#{item.sgtpfverAuxiliaryFacilitiesCost}, + #{item.sgtpfverCostFileName},#{item.sgtpfverProjectType},#{item.sgtpfverSoftwareType},#{item.voltageLevel},#{item.sgtpfverStatus}, + #{item.jgjsverStage},#{item.jgjsverVersion},#{item.jgjsverDynamicInvestment},#{item.jgjsverStaticInvestment}, + #{item.jgjsverConstructionCost},#{item.jgjsverInstallationCost},#{item.jgjsverCostOfEquipProcurement},#{item.jgjsverOtherExpenses}, + #{item.jgjsverBasicContingency} + ) + + + + + REPLACE INTO jj_on_duty(id, bidding_section_code, single_project_code, prj_code, id_card, build_unit_code, + province_code, creater_id, create_time, updater_id, update_time, tool_box_talk_id, delete_flag, + onduty_longitude, onduty_latitude, onduty_address, personnel_id, real_name, unit_name, position_code, mobile, + onduty_hierarchy, remark) VALUES + + ( + #{item.id},#{item.biddingSectionCode},#{item.singleProjectCode},#{item.prjCode},#{item.idCard},#{item.buildUnitCode}, + #{item.provinceCode},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime},#{item.toolBoxTalkId},#{item.deleteFlag}, + #{item.ondutyLongitude},#{item.ondutyLatitude},#{item.ondutyAddress},#{item.personnelId},#{item.realName},#{item.unitName},#{item.positionCode},#{item.mobile}, + #{item.ondutyHierarchy},#{item.remark} + ) + + + + + REPLACE INTO jj_risk_precaution(id, part_subentry, work_type, work_procedure, assessment_risk_level, + re_assessment_risk_level, min_constr_headcount, risk_assessment_value, work_content, working_condition, + voltage_drp_flag, source_risk_precaution_id, merge, risk_status, publish_state, planned_start_date, + execute_time, end_time, huv_flag, build_unit_code, province_code, creater_id, risk_no, create_time, updater_id, + update_time, delete_flag, working_condition_flag, constr_meth_id, single_project_code, bidding_section_code, + work_site_id, work_site_name, work_site_type, professional) VALUES + + ( + #{item.id},#{item.partSubentry},#{item.workType},#{item.workProcedure},#{item.assessmentRiskLevel}, + #{item.reAssessmentRiskLevel},#{item.minConstrHeadcount},#{item.riskAssessmentValue},#{item.workContent},#{item.workingCondition}, + #{item.voltageDrpFlag},#{item.sourceRiskPrecautionId},#{item.merge},#{item.riskStatus},#{item.publishState},#{item.plannedStartDate}, + #{item.executeTime},#{item.endTime},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.riskNo},#{item.createTime},#{item.updaterId}, + #{item.updateTime},#{item.deleteFlag},#{item.workingConditionFlag},#{item.constrMethId},#{item.singleProjectCode},#{item.biddingSectionCode}, + #{item.workSiteId},#{item.workSiteName},#{item.workSiteType},#{item.professional} + ) + + + + + REPLACE INTO jj_unit(id, legal_repr_mobile, contact_phone, unit_type, unit_nature, sys_type, sys_categ, + unit_sign, establishment_date, register_capital, website, isc_unit_id, province, city, county, address, + main_business, data_source, huv_flag, province_code, build_unit_code, creater_id, safety_sgc_unit_id, + create_time, updater_id, update_time, delete_flag, legal_id_card, business_file_id, unit_name, unit_abbr_name, + unit_code, main_code, unified_social_credit_id, legal_repr) VALUES + + ( + #{item.id},#{item.legalReprMobile},#{item.contactPhone},#{item.unitType},#{item.unitNature},#{item.sysType},#{item.sysCateg}, + #{item.unitSign},#{item.establishmentDate},#{item.registerCapital},#{item.website},#{item.iscUnitId},#{item.province},#{item.city},#{item.county},#{item.address}, + #{item.mainBusiness},#{item.dataSource},#{item.huvFlag},#{item.provinceCode},#{item.buildUnitCode},#{item.createrId},#{item.safetySgcUnitId}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.legalIdCard},#{item.businessFileId},#{item.unitName},#{item.unitAbbrName}, + #{item.unitCode},#{item.mainCode},#{item.unifiedSocialCreditId},#{item.legalRepr} + ) + + + + + REPLACE INTO jj_info(id, replenish_content_1, replenish_content_2, replenish_content_3, replenish_content_4, + replenish_content_5, replenish_content_6, replenish_content_7, delete_flag, create_time, update_time, ref_id, + ref_id2, sort_no, ext_type, content_type) VALUES + + ( + #{item.id},#{item.replenishContent1},#{item.replenishContent2},#{item.replenishContent3},#{item.replenishContent4}, + #{item.replenishContent5},#{item.replenishContent6},#{item.replenishContent7},#{item.deleteFlag},#{item.createTime},#{item.updateTime},#{item.refId}, + #{item.refId2},#{item.sortNo},#{item.extType},#{item.contentType} + ) + + + + + REPLACE INTO jj_gt(id, topography, stent_flag, borrowed_flag, span, tower_cuircuit_number, circuit_quantity, + longitude, latitude, east_coordinate, north_coordinate, single_project_code, center_pile_elevation, + rotation_degree, geology, tower_leg_baseform_first, tower_leg_baseform_second, tower_leg_baseform_third, + tower_leg_baseform_fourth, tower_leg_max_depth_first, tower_leg_max_depth_second, tower_leg_max_depth_third, + bidding_section_code, tower_leg_max_depth_fourth, tower_type, tension_tower_flag, tower_structure, creater_id, + create_time, updater_id, update_time, delete_flag, province_code, general_design_flag, tower_type_no, + upstream_tower_no, dismantle_flag, cover4g_flag, tower_sequence_no, remark, representative_span, + tension_section_length, county, town, tower_no, village, run_tower_code, ground_thing_name, design_change_no, + section_divide_point_flag, section_adjust_num, tower_weight, slope, construction_dept_id, supervision_dept_id, + module_no, devise_dept_id, owner_dept_id, uhv_flag, address, custom_flag, nominal_height, tower_full_height, + major_crossing_flag) VALUES + + ( + #{item.id},#{item.topography},#{item.stentFlag},#{item.borrowedFlag},#{item.span},#{item.towerCuircuitNumber},#{item.circuitQuantity}, + #{item.longitude},#{item.latitude},#{item.eastCoordinate},#{item.northCoordinate},#{item.singleProjectCode},#{item.centerPileElevation}, + #{item.rotationDegree},#{item.geology},#{item.towerLegBaseformFirst},#{item.towerLegBaseformSecond},#{item.towerLegBaseformThird}, + #{item.towerLegBaseformFourth},#{item.towerLegMaxDepthFirst},#{item.towerLegMaxDepthSecond},#{item.towerLegMaxDepthThird}, + #{item.biddingSectionCode},#{item.towerLegMaxDepthFourth},#{item.towerType},#{item.tensionTowerFlag},#{item.towerStructure},#{item.createrId}, + #{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.provinceCode},#{item.generalDesignFlag},#{item.towerTypeNo}, + #{item.upstreamTowerNo},#{item.dismantleFlag},#{item.cover4gFlag},#{item.towerSequenceNo},#{item.remark},#{item.representativeSpan}, + #{item.tensionSectionLength},#{item.county},#{item.town},#{item.towerNo},#{item.village},#{item.runTowerCode},#{item.groundThingName},#{item.designChangeNo}, + #{item.sectionDividePointFlag},#{item.sectionAdjustNum},#{item.towerWeight},#{item.slope},#{item.constructionDeptId},#{item.supervisionDeptId}, + #{item.moduleNo},#{item.deviseDeptId},#{item.ownerDeptId},#{item.uhvFlag},#{item.address},#{item.customFlag},#{item.nominalHeight},#{item.towerFullHeight}, + #{item.majorCrossingFlag} + ) + + + + + REPLACE INTO jj_dept_gc_project(id, dept_id, prj_code, single_project_code, bidding_section_code, disband_flag, + d_delete_flag, year, province_code, build_unit_code, project_dept_no, project_department_name, affiliation_code, + establishment_date, dept_province_code, dept_cities_code, dept_district_code, address, postal_code, + contact_telephone, email_address, fax_no, group_markup, department_type, department_status, history_flag, + p_delete_flag, creater_id, create_time, updater_id, update_time) VALUES + + ( + #{item.id},#{item.deptId},#{item.prjCode},#{item.singleProjectCode},#{item.biddingSectionCode},#{item.disbandFlag}, + #{item.dDeleteFlag},#{item.year},#{item.provinceCode},#{item.buildUnitCode},#{item.projectDeptNo},#{item.projectDepartmentName},#{item.affiliationCode}, + #{item.establishmentDate},#{item.deptProvinceCode},#{item.deptCitiesCode},#{item.deptDistrictCode},#{item.address},#{item.postalCode}, + #{item.contactTelephone},#{item.emailAddress},#{item.faxNo},#{item.groupMarkup},#{item.departmentType},#{item.departmentStatus},#{item.historyFlag}, + #{item.pDeleteFlag},#{item.createrId},#{item.createTime},#{item.updaterId},#{item.updateTime} + ) + + \ No newline at end of file