站班会/站班会人员

This commit is contained in:
cwchen 2024-05-08 10:50:28 +08:00
parent ebbefc6946
commit 9703e8584c
6 changed files with 617 additions and 3 deletions

View File

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

View File

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

View File

@ -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<JjClassMeetting> list);
/*
* 插入站班会人员数据
* @param list
* @return void
* @author cwchen
* @date 2024/5/8 10:21
*/
void insertClassMeetingPeopleData(List<JjClassMeetingPeople> list);
}

View File

@ -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<JjClassMeetting> 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<JjClassMeetingPeople> list) {
try{
mapper2.insertClassMeetingPeopleData(list);
}catch (Exception e){
XxlJobHelper.log("站班会人员数据处理异常内容--->{}",e.toString());
XxlJobHelper.handleFail(e.toString());
log.error(e.toString(),e);
}
}
}

View File

@ -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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetting> list = JSONArray.parseArray(array.toJSONString(), JjClassMeetting.class);
service.insertClassMeetingData(list);
pageNum++;
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
// getProInfo();
}
}
} catch (Exception e) {
XxlJobHelper.handleFail(e.toString());
log.error(e.toString(), e);
}
}
/*
* 站班会人员
* @return void
* @author cwchen
* @date 2024/5/8 10:14
*/
public void getClassMeetingPeopleInfo() {
try {
//当前页
int pageNum = 1;
JSONObject obj = new JSONObject();
obj.put("type", "2");
HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.DW_JJ_XM_URL);
Map<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjClassMeetingPeople> list = JSONArray.parseArray(array.toJSONString(), JjClassMeetingPeople.class);
service.getClassMeetingPeopleInfo(list);
pageNum++;
if (pageNum <= (Integer) map.get("TOTAL_PAGE")) {
// getProInfo();
}
}
} catch (Exception e) {
XxlJobHelper.handleFail(e.toString());
log.error(e.toString(), e);
}
}
}

View File

@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xxl.job.executor.inter.mapper.InterMapper2">
<!--插入站班会数据-->
<insert id="insertClassMeetingData">
REPLACE INTO jj_class_meetting(id,work_start_time,current_constr_date,current_construction_status,work_overnight_flag,tool_box_talk_address,
tool_box_talk_longitude,tool_box_talk_Latitude,mc_work_site_id,bidding_section_code,bidding_section_name,off_online_flag,
single_project_code,single_project_name,single_project_type,constr_unified_social_credit_id,supervision_unit_name,supervision_social_credit_code,
voltage_level,huv_flag,build_unit_code,province_code,creater_id,prj_name,
create_time,updater_id,update_time,delete_flag,risk_precaution_id,talk_des_status_change_id,
file_id,,camera_id,prj_code,ticket_id,ticket_no,re_assessment_risk_level,
current_constr_headcount,construction_headcount,change_time) VALUES
<foreach collection="list" item="item" separator=",">(
#{item.id},#{item.workstartTime},#{item.currentConstrDate},#{item.currentConstructionStatus},#{item.workOvernightFlag},#{item.toolBoxTalkAddress},
#{item.toolBoxTalkLongitude},#{item.toolBoxTalkLatitude},#{item.mcWorkSiteId},#{item.biddingSectionCode},#{item.biddingSectionName},#{item.offOnlineFlag},
#{item.singleProjectCode},#{item.singleProjectName},#{item.singleProjectType},#{item.constrUnifiedSocialCreditId},#{item.supervisionUnitName},#{item.supervisionSocialCreditCode},
#{item.voltageLevel},#{item.huvFlag},#{item.buildUnitCode},#{item.provinceCode},#{item.createrId},#{item.prjName},
#{item.createTime},#{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.riskPrecautionId},#{item.talkDesStatusChangeId},
#{item.fileId},#{item.cameraId},#{item.prjCode},#{item.ticketId},#{item.ticketNo},#{item.reAssessmentRiskLevel},
#{item.currentConstrHeadcount},#{item.constructionHeadcount},#{item.changeTime}
)</foreach>
</insert>
<!--插入站班会人员数据-->
<insert id="insertClassMeetingPeopleData">
REPLACE INTO jj_class_meeting_people(id,work_code,personnel_id,create_time,updater_id,safety_guardian_flag,
position_flag,province_code,tool_box_talk_id,id_card,work_division,real_name,
validity_period,delete_flag,update_time,position_code,creater_id,registration_date) VALUES
<foreach collection="list" item="item" separator=",">(
#{item.id},#{item.workCode},#{item.personnelId},#{item.createTime},#{item.updaterId},#{item.safetyGuardianFlag},
#{item.positionFlag},#{item.provinceCode},#{item.toolBoxTalkId},#{item.idCard},#{item.workDivision},#{item.realName},
#{item.validityPeriod},#{item.deleteFlag},#{item.updateTime},#{item.positionCode},#{item.createrId},#{item.registrationDate}
)</foreach>
</insert>
</mapper>