添加抽取接收数据的业务

V1.0.0
zhaokai 2025-07-15 18:13:47 +08:00
parent 7661f4226e
commit f0fecb0571
72 changed files with 4500 additions and 0 deletions

View File

@ -0,0 +1,97 @@
package com.zcloud.config;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.ssl.TrustStrategy;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.web.client.ResponseErrorHandler;
import org.springframework.web.client.RestTemplate;
import javax.net.ssl.SSLContext;
import java.io.IOException;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
@Configuration
public class RestTemplateConfig {
@Bean
public RestTemplate restTemplateHbsy(HttpComponentsClientHttpRequestFactory httpsFactory) {
RestTemplate restTemplate = new RestTemplate(httpsFactory);
restTemplate.setErrorHandler(new ResponseErrorHandler() {
@Override
public boolean hasError(ClientHttpResponse response) throws IOException {
return false;
}
@Override
public void handleError(ClientHttpResponse response) throws IOException {
}
});
return restTemplate;
}
@Bean
public RestTemplate restTemplate(HttpComponentsClientHttpRequestFactory httpsFactory) {
httpsFactory.setConnectTimeout(1000 * 60 * 2);
httpsFactory.setReadTimeout(1000 * 60 * 5);
RestTemplate restTemplate = new RestTemplate(httpsFactory);
restTemplate.setErrorHandler(new ResponseErrorHandler() {
@Override
public boolean hasError(ClientHttpResponse response) throws IOException {
return false;
}
@Override
public void handleError(ClientHttpResponse response) throws IOException {
}
});
return restTemplate;
}
@Bean("httpsFactory")
public HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory() throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
CloseableHttpClient httpClient = client();
HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
factory.setConnectTimeout(20000);
return factory;
}
private CloseableHttpClient client() throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
HttpClientBuilder builder = HttpClientBuilder.create();
// 无条件信任ssl证书
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
@Override
public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
return true;
}
}).build();
builder.setSSLContext(sslContext);
NoopHostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE;
SSLConnectionSocketFactory sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslContext, hostnameVerifier);
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create().register("http", PlainConnectionSocketFactory.getSocketFactory()).register("https", sslConnectionSocketFactory).build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
connectionManager.setMaxTotal(200);
connectionManager.setDefaultMaxPerRoute(100);
builder.setConnectionManager(connectionManager);
return builder.build();
}
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataCarRecordEntity;
/**
* (DataCarRecord)访
*
* @author zhaokai
* @since 2025-07-15 17:32:56
*/
public interface DataCarRecordDao extends BaseMapper<DataCarRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataDangerCheckRecordEntity;
/**
* (DataDangerCheckRecord)访
*
* @author zhaokai
* @since 2025-07-15 14:54:43
*/
public interface DataDangerCheckRecordDao extends BaseMapper<DataDangerCheckRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataDangerInfoEntity;
/**
* (DataDangerInfo)访
*
* @author zhaokai
* @since 2025-07-15 15:33:34
*/
public interface DataDangerInfoDao extends BaseMapper<DataDangerInfoEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataDeviceRunStatusEntity;
/**
* (DataDeviceRunStatus)访
*
* @author zhaokai
* @since 2025-07-15 16:36:02
*/
public interface DataDeviceRunStatusDao extends BaseMapper<DataDeviceRunStatusEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataEquipDataReceivingEntity;
/**
* (DataEquipDataReceiving)访
*
* @author zhaokai
* @since 2025-07-15 18:01:10
*/
public interface DataEquipDataReceivingDao extends BaseMapper<DataEquipDataReceivingEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataHiddenCheckMissionEntity;
/**
* (DataHiddenCheckMission)访
*
* @author zhaokai
* @since 2025-07-15 14:32:03
*/
public interface DataHiddenCheckMissionDao extends BaseMapper<DataHiddenCheckMissionEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataPersonRecordEntity;
/**
* (DataPersonRecord)访
*
* @author zhaokai
* @since 2025-07-15 17:40:52
*/
public interface DataPersonRecordDao extends BaseMapper<DataPersonRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataProductionPromiseEntity;
/**
* (DataProductionPromise)访
*
* @author zhaokai
* @since 2025-07-15 16:24:51
*/
public interface DataProductionPromiseDao extends BaseMapper<DataProductionPromiseEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataPromiseTicketEntity;
/**
* (DataPromiseTicket)访
*
* @author zhaokai
* @since 2025-07-15 16:46:53
*/
public interface DataPromiseTicketDao extends BaseMapper<DataPromiseTicketEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataRiskControlMeasureEntity;
/**
* (DataRiskControlMeasure)访
*
* @author zhaokai
* @since 2025-07-15 09:46:30
*/
public interface DataRiskControlMeasureDao extends BaseMapper<DataRiskControlMeasureEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataRiskIdentificationEntity;
/**
* (DataRiskIdentification)访
*
* @author zhaokai
* @since 2025-07-15 14:01:36
*/
public interface DataRiskIdentificationDao extends BaseMapper<DataRiskIdentificationEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.data;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.data.DataUnitStopEntity;
/**
* /(DataUnitStop)访
*
* @author zhaokai
* @since 2025-07-15 16:00:37
*/
public interface DataUnitStopDao extends BaseMapper<DataUnitStopEntity> {
}

View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.dao.temp;
import com.zcloud.modules.sys.entity.PageData;
import java.util.List;
public interface TempPushDataDao {
List<PageData> listConfinedSpaceDataAll(PageData pd);
List<PageData> getHighWorkData();
List<PageData> getHotWorkData();
List<PageData> getElectricityData();
List<PageData> getBreakgroundData();
List<PageData> getCutroadData();
}

View File

@ -0,0 +1,60 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataCarRecord)
*
* @author zhaokai
* @since 2025-07-15 17:32:56
*/
@SuppressWarnings("serial")
@Data
@ApiModel("卡口车辆通行记录")
public class DataCarRecordReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "通行方向参考枚举DataPassDirectionEnum,1-入场 2-出场")
private String passDirection;
@ApiModelProperty(value = "车牌号码")
private String cnumberplate;
@ApiModelProperty(value = "车牌颜色")
private String plateColor;
@ApiModelProperty(value = "车辆通行卡口名称")
private String entranceName;
@ApiModelProperty(value = "企业名称")
private String enterpriseName;
@ApiModelProperty(value = "道闸编号")
private String trackgateNum;
@ApiModelProperty(value = "车辆抓拍图片,BASE64 图片流")
private String image1Base64Str;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,107 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataDangerCheckRecord)
*
* @author zhaokai
* @since 2025-07-15 14:54:43
*/
@Data
@ApiModel("隐患排查记录请求实体")
public class DataDangerCheckRecordReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "关联隐患排查任务ID")
private String checkTaskId;
@ApiModelProperty(value = "排查时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkTime;
@ApiModelProperty(value = "IMEI码")
private String mobileMe;
@ApiModelProperty(value = "是否包保责任人任务,参照枚举DataIsDefendEnum")
private String isDefend;
@ApiModelProperty(value = "排查状态,参照枚举DataCheckStatusEnum")
private String checkStatus;
@ApiModelProperty(value = "排查风险等级,参照枚举DataCheckRiskLevelEnum")
private String checkRiskLevel;
@ApiModelProperty(value = "排查风险名称")
private String checkRiskName;
@ApiModelProperty(value = "排查部门")
private String checkDep;
@ApiModelProperty(value = "排查人")
private String checker;
@ApiModelProperty(value = "排查人联系电话")
private String checkerPhoneNo;
@ApiModelProperty(value = "创建人手机号")
private String createByMobile;
@ApiModelProperty(value = "更新人手机号")
private String updateByMobile;
@ApiModelProperty(value = "隐患排查清单ID")
private String planid;
@ApiModelProperty(value = "任务名称")
private String taskName;
@ApiModelProperty(value = "任务类型,参考枚举DataWorkTypeEnum")
private String taskType;
@ApiModelProperty(value = "排查级别,参考枚举DataOrgLevelEnum")
private String orglevel;
@ApiModelProperty(value = "排查级别,参考枚举DataCheckTypeEnum")
private String checkType;
@ApiModelProperty(value = "岗位")
private String postName;
@ApiModelProperty(value = "部门")
private String deptName;
@ApiModelProperty(value = "负责人")
private String chargePerson;
@ApiModelProperty(value = "任务开始时间")
private String startDate;
@ApiModelProperty(value = "任务结束时间")
private String endDate;
@ApiModelProperty(value = "隐患排查内容")
private String checkitemcontent;
@ApiModelProperty(value = "任务执行状态,0-待执行,1-已完成")
private String status;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,105 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataDangerInfo)
*
* @author zhaokai
* @since 2025-07-15 15:33:34
*/
@Data
@ApiModel("隐患排查记录请求实体")
public class DataDangerInfoReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "安全风险分析对象编码")
private String hazardCode;
@ApiModelProperty(value = "关联风险管控措施ID")
private String riskMeasureId;
@ApiModelProperty(value = "关联隐患排查记录ID")
private String checkRecordId;
@ApiModelProperty(value = "隐患名称")
private String dangerName;
@ApiModelProperty(value = "隐患等级,参照枚举 DataDangerLevelEnum")
private String dangerLevel;
@ApiModelProperty(value = "登记时间,格式:yyyy-MM-dd HH:mm:ss")
private String registerTime;
@ApiModelProperty(value = "登记人姓名")
private String registrant;
@ApiModelProperty(value = "隐患来源,参照枚举DataDangerSrcEnum")
private String dangerSrc;
@ApiModelProperty(value = "执法编号")
private String enforcementId;
@ApiModelProperty(value = "隐患治理类型,参照枚举DataDangerManageTypeEnum")
private String dangerManageType;
@ApiModelProperty(value = "隐患类型,参照枚举DataHazardDangerTypeEnum")
private String hazardDangerType;
@ApiModelProperty(value = "隐患类别,参照枚举DataHazardCategoryEnum")
private String hazardCategory;
@ApiModelProperty(value = "隐患描述")
private String dangerDesc;
@ApiModelProperty(value = "原因分析")
private String dangerReason;
@ApiModelProperty(value = "控制措施")
private String controlMeasures;
@ApiModelProperty(value = "资金(万元)")
private String cost;
@ApiModelProperty(value = "整改责任人姓名")
private String liablePerson;
@ApiModelProperty(value = "隐患治理期限,格式:yyyy-MM-dd HH:mm:ss")
private String dangerManageDeadline;
@ApiModelProperty(value = "验收人姓名")
private String checkAcceptPerson;
@ApiModelProperty(value = "验收时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkAcceptTime;
@ApiModelProperty(value = "验收情况")
private String checkAcceptComment;
@ApiModelProperty(value = "隐患状态,参照枚举DataDangerStatusEnum")
private String dangerState;
@ApiModelProperty(value = "隐患照片")
private String dangerImg;
@ApiModelProperty(value = "整改后照片")
private String dangerAcceptImg;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,67 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataDeviceRunStatus)
*
* @author zhaokai
* @since 2025-07-15 16:36:02
*/
@SuppressWarnings("serial")
@Data
@ApiModel("上报承诺装置运行状态请求实体")
public class DataDeviceRunStatusReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "承诺详情ID,与企业承诺详情表的ID对应")
private String promiseId;
@ApiModelProperty(value = "危险源编码")
private String hazardCode;
@ApiModelProperty(value = "是否处于试生产,参考枚举DataIsCommonStatusEnum")
private String isTesting;
@ApiModelProperty(value = "运行状态,参考枚举DataRunStatusEnum")
private String runStatus;
@ApiModelProperty(value = "运行状态开始时间")
private String runStatusBeginTime;
@ApiModelProperty(value = "运行状态结束时间")
private String runStatusEndTime;
@ApiModelProperty(value = "处于该运行状态的原因")
private String runStatusReason;
@ApiModelProperty(value = "是否变更过,参考枚举DataIsCommonStatusEnum")
private String isChanged;
@ApiModelProperty(value = "变更时间")
private String changedTime;
@ApiModelProperty(value = "变更原因")
private String changedReason;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,88 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataEquipDataReceiving)
*
* @author zhaokai
* @since 2025-07-15 18:01:10
*/
@SuppressWarnings("serial")
@Data
@ApiModel("雷电预警设备基础数据请求实体")
public class DataEquipDataReceivingReqDto extends DataCommonReqDto{
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "设备编码")
private String equipCode;
@ApiModelProperty(value = "监控半径单位KM")
private String radius;
@ApiModelProperty(value = "设备名称")
private String equipName;
@ApiModelProperty(value = "设备经度")
private String longitude;
@ApiModelProperty(value = "设备纬度")
private String latitude;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,82 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataHiddenCheckMission)
*
* @author zhaokai
* @since 2025-07-15 14:32:03
*/
@SuppressWarnings("serial")
@Data
@ApiModel("隐患排查任务数据请求实体")
public class DataHiddenCheckMissionReqDto extends DataCommonReqDto{
@ApiModelProperty(value = "管控措施id,")
private String riskMeasureId;
@ApiModelProperty(value = "隐患排查内容")
private String troubleshootContent;
@ApiModelProperty(value = "巡检周期,排查周期,本次生成排查任务到下次生成排查任务的时间跨度,需大于0")
private Integer checkCycle;
@ApiModelProperty(value = "巡检周期单位,参照枚举 DataCheckCycleUnitEnum ")
private String checkCycleUnit;
@ApiModelProperty(value = "任务开始时间,指该任务首次开始执行的时间,时间格式yyyy-MM-dd HH:mm:ss")
private String taskStartTime;
@ApiModelProperty(value = "工作开始时间,当排查周期是小时的时候为必填,时间格式yyyy-MM-dd HH:mm:ss")
private String workStartTime;
@ApiModelProperty(value = "工作结束时间,当排查周期是小时的时候为必填,时间格式yyyy-MM-dd HH:mm:ss")
private String workEndTime;
@ApiModelProperty(value = "工作日类型,参考枚举DataWorkDayTypeEnum")
private String workDayType;
@ApiModelProperty(value = "任务类型,参考枚举DataWorkTypeEnum")
private String workType;
@ApiModelProperty(value = "包保任务对应项,参照枚举DataTaskNumEnum,当任务类型为主要负责人任务、技术负责人任务、操作负责人任务时,此项为必填")
private String taskNum;
@ApiModelProperty(value = "巡检级别,参照枚举DataCheckLevelEnum")
private String checkLevel;
@ApiModelProperty(value = "巡检频次(天数/班数)")
private String checkTimesDay;
@ApiModelProperty(value = "巡检频次(次数)")
private String checkTimesNum;
@ApiModelProperty(value = "巡检任务类型,参照枚举DataCheckTaskTypeEnum")
private String checkTaskType;
@ApiModelProperty(value = "巡检有效开始时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkStartDate;
@ApiModelProperty(value = "巡检有效结束时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkEndDate;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,62 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataPersonRecord)
*
* @author zhaokai
* @since 2025-07-15 17:40:52
*/
@SuppressWarnings("serial")
@Data
@ApiModel("卡口人员通行记录请求实体")
public class DataPersonRecordReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "通行方向,参考枚举DataCrossTypeEnum")
private String crossType;
@ApiModelProperty(value = "通行时间(yyyy-MM-dd HH:mm:ss)")
private String eventTime;
@ApiModelProperty(value = "设备编码")
private String equipmentCode;
@ApiModelProperty(value = "人员编码")
private String staffCode;
@ApiModelProperty(value = "人员名称")
private String staffType;
@ApiModelProperty(value = "通行卡口名称")
private String checkName;
@ApiModelProperty(value = "人员抓拍图片(BASE64)")
private String picUri;
@ApiModelProperty(value = "所属企业名称")
private String enterpriseName;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,141 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataProductionPromise)
*
* @author zhaokai
* @since 2025-07-15 16:24:51
*/
@SuppressWarnings("serial")
@Data
@ApiModel("上报安全承诺数据请求实体")
public class DataProductionPromiseReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "生产装置套数")
private Integer unitsNumber;
@ApiModelProperty(value = "运行套数")
private Integer runNumber;
@ApiModelProperty(value = "停车套数")
private Integer parkNumber;
@ApiModelProperty(value = "特级动火作业数量")
private Integer firesNumber;
@ApiModelProperty(value = "一级动火作业数量")
private Integer fire1Number;
@ApiModelProperty(value = "二级动火作业数量")
private Integer fire2Number;
@ApiModelProperty(value = "断路作业数量")
private Integer roadworkNumber;
@ApiModelProperty(value = "动土作业数量")
private Integer soilworkNumber;
@ApiModelProperty(value = "高处作业数量")
private Integer highworkNumber;
@ApiModelProperty(value = "临时用电作业数量")
private Integer electricityworkNumber;
@ApiModelProperty(value = "吊装作业数量")
private Integer liftingworkNumber;
@ApiModelProperty(value = "盲板作业数量")
private Integer blindplateNumber;
@ApiModelProperty(value = "受限空间作业数量")
private Integer spaceworkNumber;
@ApiModelProperty(value = "检维修作业数量")
private Integer inspectionNumber;
@ApiModelProperty(value = "倒罐作业数量")
private Integer pourOutNumber;
@ApiModelProperty(value = "清罐作业数量")
private Integer cleanTankNumber;
@ApiModelProperty(value = "切水作业数量")
private Integer drainingNumber;
@ApiModelProperty(value = "承包商作业数量")
private Integer contractorNumber;
@ApiModelProperty(value = "变更作业数量")
private Integer changedTaskNumber;
@ApiModelProperty(value = "是否有承包商作业,参考枚举DataIsCommonStatusEnum")
private String contractor;
@ApiModelProperty(value = "是否处于试生产期,参考枚举DataIsCommonStatusEnum")
private String trialProduction;
@ApiModelProperty(value = "是否处于开停车状态,参考枚举DataIsCommonStatusEnum")
private Integer openParking;
@ApiModelProperty(value = "正在开停车装置数")
private Integer openParkingNumber;
@ApiModelProperty(value = "开车装置数")
private Integer workNumber;
@ApiModelProperty(value = "停车装置数")
private Integer notWorkNumber;
@ApiModelProperty(value = "是否开展中(扩)试,参考枚举DataIsCommonStatusEnum")
private String test;
@ApiModelProperty(value = "试生产装置数")
private Integer testNumber;
@ApiModelProperty(value = "检维修套数")
private Integer overhaulWorkNumber;
@ApiModelProperty(value = "重点监管危险工艺数量")
private Integer dangerProcessNumber;
@ApiModelProperty(value = "有无重大隐患,参考枚举DataIsCommonStatusEnum")
private String mHazards;
@ApiModelProperty(value = "风险级别,参考枚举DataRiskGradEnum")
private String riskGrade;
@ApiModelProperty(value = "承诺时间")
private String commitDate;
@ApiModelProperty(value = "承诺人")
private String commitment;
@ApiModelProperty(value = "承诺内容")
private String commitContent;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,45 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataPromiseTicket)
*
* @author zhaokai
* @since 2025-07-15 16:46:53
*/
@SuppressWarnings("serial")
@Data
@ApiModel("上报安全承诺作业票详情请求实体")
public class DataPromiseTicketReqDto extends DataCommonReqDto {
@ApiModelProperty(value = "承诺详情ID,")
private String promiseId;
@ApiModelProperty(value = "作业票证ID,")
private String ticketId;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,64 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataRiskControlMeasure)
*/
@Data
@ApiModel("安全风险管控措施请求实体")
public class DataRiskControlMeasureReqDto extends DataCommonReqDto{
@ApiModelProperty(value = "关联风险事件ID")
private String riskEventId;
@ApiModelProperty(value = "管控方式,参照枚举DataDataSrcEnum")
private String dataSrc;
@ApiModelProperty(value = "安全风险管控措施描述")
private String riskMeasureDesc;
@ApiModelProperty(value = "管控措施分类1,参照枚举 DataClassify1Enum")
private String classify1;
@ApiModelProperty(value = "管控措施分类2,参照枚举 DataClassify2Enum")
private String classify2;
@ApiModelProperty(value = "管控措施分类3,企业自定义")
private String classify3;
@ApiModelProperty(value = "隐患排查内容")
private String troubleshootContent;
@ApiModelProperty(value = "管控级别,参照枚举 DataRiskMeasureLevelEnum")
private String riskMeasureLevel;
@ApiModelProperty(value = "管控责任部门")
private String riskMeasureDep;
@ApiModelProperty(value = "管控责任人")
private String riskMeasurer;
@ApiModelProperty(value = "隐患问题描述JSON字符串")
private String hiddenDangerDescription;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,78 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* (DataRiskIdentification)
*
* @author zhaokai
* @since 2025-07-15 14:01:36
*/
@Data
@ApiModel("风险事件辨识信息请求实体")
public class DataRiskIdentificationReqDto extends DataCommonReqDto{
@ApiModelProperty(value = "风险分析单元ID")
private String riskUnitId;
@ApiModelProperty(value = "辨识部位")
private String partName;
@ApiModelProperty(value = "管控方式 参照枚举")
private String dataSrc;
@ApiModelProperty(value = "风险识别内容")
private String riskIdentificationContent;
@ApiModelProperty(value = "检查内容")
private String checkContent;
@ApiModelProperty(value = "风险事件名称")
private String riskEventName;
@ApiModelProperty(value = "管控部门")
private String deptName;
@ApiModelProperty(value = "管控责任人")
private String chargePerson;
@ApiModelProperty(value = "应急处置措施")
private String emergencyDisposal;
@ApiModelProperty(value = "评分方法 LEC、LS")
private String ratingMethod;
@ApiModelProperty(value = "LEC评级的L项对应ID,参照枚举DataLevelLEnum")
private Integer levelL;
@ApiModelProperty(value = "LEC评级的E项对应ID,参照枚举DataLevelEEnum")
private Integer levelE;
@ApiModelProperty(value = "LEC评级的C项对应ID,参照枚举DataLevelCEnum")
private Integer levelC;
@ApiModelProperty(value = "风险等级,参照枚举DataRiskLeveEnum")
private Integer riskLevel;
@ApiModelProperty(value = "业务数据删除状态, 参照枚举DataIsDeleteEnum")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,48 @@
package com.zcloud.modules.data.dto.data.req;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* /(DataUnitStop)
*
* @author zhaokai
* @since 2025-07-15 16:00:37
*/
@Data
@ApiModel("上报停用/检修记录数据请求实体")
public class DataUnitStopReqDto extends DataCommonReqDto{
@ApiModelProperty(value = "风险分析对象编码即危险化学品登记信息管理系统中的危险源编码")
private String hazardCode;
@ApiModelProperty(value = "所属风险单元ID")
private String riskUnitId;
@ApiModelProperty(value = "停用/检修开始时间,时间格式yyyy-MM-dd HH:mm:ss")
private String stopStartTime;
@ApiModelProperty(value = "停用/检修结束时间,时间格式yyyy-MM-dd HH:mm:ss")
private String stopEndTime;
@ApiModelProperty(value = "停用/检修原因")
private String stopReason;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
}

View File

@ -0,0 +1,100 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataCarRecord)
*
* @author zhaokai
* @since 2025-07-15 17:32:56
*/
@SuppressWarnings("serial")
@Data
@TableName("data_car_record")
public class DataCarRecordEntity extends Model<DataCarRecordEntity> {
@ApiModelProperty(value = "主键UUID")
private Integer id;
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "通行记录编码")
private String passId;
@ApiModelProperty(value = "车辆通行时间,yyyy-MM-ddT HH:mm:ss")
private String passTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "通行方向参考枚举DataPassDirectionEnum,1-入场 2-出场")
private String passDirection;
@ApiModelProperty(value = "车牌号码")
private String cnumberplate;
@ApiModelProperty(value = "车牌颜色")
private String plateColor;
@ApiModelProperty(value = "车辆通行卡口名称")
private String entranceName;
@ApiModelProperty(value = "企业名称")
private String enterpriseName;
@ApiModelProperty(value = "道闸编号")
private String trackgateNum;
@ApiModelProperty(value = "车辆抓拍图片,BASE64 图片流")
private String image1Base64Str;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,146 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataDangerCheckRecord)
*
* @author zhaokai
* @since 2025-07-15 14:54:43
*/
@SuppressWarnings("serial")
@Data
@TableName("data_danger_check_record")
public class DataDangerCheckRecordEntity extends Model<DataDangerCheckRecordEntity> {
@ApiModelProperty(value = "主键UUID")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "关联隐患排查任务ID")
private String checkTaskId;
@ApiModelProperty(value = "排查时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkTime;
@ApiModelProperty(value = "IMEI码")
private String mobileMe;
@ApiModelProperty(value = "是否包保责任人任务,参照枚举DataIsDefendEnum")
private String isDefend;
@ApiModelProperty(value = "排查状态,参照枚举DataCheckStatusEnum")
private String checkStatus;
@ApiModelProperty(value = "排查风险等级,参照枚举DataCheckRiskLevelEnum")
private String checkRiskLevel;
@ApiModelProperty(value = "排查风险名称")
private String checkRiskName;
@ApiModelProperty(value = "排查部门")
private String checkDep;
@ApiModelProperty(value = "排查人")
private String checker;
@ApiModelProperty(value = "排查人联系电话")
private String checkerPhoneNo;
@ApiModelProperty(value = "创建人手机号")
private String createByMobile;
@ApiModelProperty(value = "更新人手机号")
private String updateByMobile;
@ApiModelProperty(value = "隐患排查清单ID")
private String planid;
@ApiModelProperty(value = "任务名称")
private String taskName;
@ApiModelProperty(value = "任务类型,参考枚举DataWorkTypeEnum")
private String taskType;
@ApiModelProperty(value = "排查级别,参考枚举DataOrgLevelEnum")
private String orglevel;
@ApiModelProperty(value = "排查级别,参考枚举DataCheckTypeEnum")
private String checkType;
@ApiModelProperty(value = "岗位")
private String postName;
@ApiModelProperty(value = "部门")
private String deptName;
@ApiModelProperty(value = "负责人")
private String chargePerson;
@ApiModelProperty(value = "任务开始时间")
private String startDate;
@ApiModelProperty(value = "任务结束时间")
private String endDate;
@ApiModelProperty(value = "隐患排查内容")
private String checkitemcontent;
@ApiModelProperty(value = "任务执行状态,0-待执行,1-已完成")
private String status;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,146 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataDangerInfo)
*
* @author zhaokai
* @since 2025-07-15 15:33:34
*/
@SuppressWarnings("serial")
@Data
@TableName("data_danger_info")
public class DataDangerInfoEntity extends Model<DataDangerInfoEntity> {
@ApiModelProperty(value = "主键UUID")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "安全风险分析对象编码")
private String hazardCode;
@ApiModelProperty(value = "关联风险管控措施ID")
private String riskMeasureId;
@ApiModelProperty(value = "关联隐患排查记录ID")
private String checkRecordId;
@ApiModelProperty(value = "隐患名称")
private String dangerName;
@ApiModelProperty(value = "隐患等级,参照枚举 DataDangerLevelEnum")
private String dangerLevel;
@ApiModelProperty(value = "登记时间,格式:yyyy-MM-dd HH:mm:ss")
private String registerTime;
@ApiModelProperty(value = "登记人姓名")
private String registrant;
@ApiModelProperty(value = "隐患来源,参照枚举DataDangerSrcEnum")
private String dangerSrc;
@ApiModelProperty(value = "执法编号")
private String enforcementId;
@ApiModelProperty(value = "隐患治理类型,参照枚举DataDangerManageTypeEnum")
private String dangerManageType;
@ApiModelProperty(value = "隐患类型,参照枚举DataHazardDangerTypeEnum")
private String hazardDangerType;
@ApiModelProperty(value = "隐患类别,参照枚举DataHazardCategoryEnum")
private String hazardCategory;
@ApiModelProperty(value = "隐患描述")
private String dangerDesc;
@ApiModelProperty(value = "原因分析")
private String dangerReason;
@ApiModelProperty(value = "控制措施")
private String controlMeasures;
@ApiModelProperty(value = "资金(万元)")
private String cost;
@ApiModelProperty(value = "整改责任人姓名")
private String liablePerson;
@ApiModelProperty(value = "隐患治理期限,格式:yyyy-MM-dd HH:mm:ss")
private String dangerManageDeadline;
@ApiModelProperty(value = "验收人姓名")
private String checkAcceptPerson;
@ApiModelProperty(value = "验收时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkAcceptTime;
@ApiModelProperty(value = "验收情况")
private String checkAcceptComment;
@ApiModelProperty(value = "隐患状态,参照枚举DataDangerStatusEnum")
private String dangerState;
@ApiModelProperty(value = "隐患照片")
private String dangerImg;
@ApiModelProperty(value = "整改后照片")
private String dangerAcceptImg;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,104 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataDeviceRunStatus)
*
* @author zhaokai
* @since 2025-07-15 16:36:02
*/
@SuppressWarnings("serial")
@Data
@TableName("data_device_run_status")
public class DataDeviceRunStatusEntity extends Model<DataDeviceRunStatusEntity> {
@ApiModelProperty(value = "主键UUID")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "承诺详情ID,与企业承诺详情表的ID对应")
private String promiseId;
@ApiModelProperty(value = "危险源编码")
private String hazardCode;
@ApiModelProperty(value = "是否处于试生产,参考枚举DataIsCommonStatusEnum")
private String isTesting;
@ApiModelProperty(value = "运行状态,参考枚举DataRunStatusEnum")
private String runStatus;
@ApiModelProperty(value = "运行状态开始时间")
private String runStatusBeginTime;
@ApiModelProperty(value = "运行状态结束时间")
private String runStatusEndTime;
@ApiModelProperty(value = "处于该运行状态的原因")
private String runStatusReason;
@ApiModelProperty(value = "是否变更过,参考枚举DataIsCommonStatusEnum")
private String isChanged;
@ApiModelProperty(value = "变更时间")
private String changedTime;
@ApiModelProperty(value = "变更原因")
private String changedReason;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,89 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataEquipDataReceiving)
*
* @author zhaokai
* @since 2025-07-15 18:01:10
*/
@SuppressWarnings("serial")
@Data
@TableName("data_equip_data_receiving")
public class DataEquipDataReceivingEntity extends Model<DataEquipDataReceivingEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "设备编码")
private String equipCode;
@ApiModelProperty(value = "监控半径单位KM")
private String radius;
@ApiModelProperty(value = "设备名称")
private String equipName;
@ApiModelProperty(value = "设备经度")
private String longitude;
@ApiModelProperty(value = "设备纬度")
private String latitude;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,122 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataHiddenCheckMission)
*
* @author zhaokai
* @since 2025-07-15 14:32:03
*/
@SuppressWarnings("serial")
@Data
@TableName("data_hidden_check_mission")
public class DataHiddenCheckMissionEntity extends Model<DataHiddenCheckMissionEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码,危化品登记平台登记的9位企业编码")
private String companyCode;
@ApiModelProperty(value = "管控措施id,")
private String riskMeasureId;
@ApiModelProperty(value = "隐患排查内容")
private String troubleshootContent;
@ApiModelProperty(value = "巡检周期,排查周期,本次生成排查任务到下次生成排查任务的时间跨度,需大于0")
private Integer checkCycle;
@ApiModelProperty(value = "巡检周期单位,参照枚举 DataCheckCycleUnitEnum ")
private String checkCycleUnit;
@ApiModelProperty(value = "任务开始时间,指该任务首次开始执行的时间,时间格式yyyy-MM-dd HH:mm:ss")
private String taskStartTime;
@ApiModelProperty(value = "工作开始时间,当排查周期是小时的时候为必填,时间格式yyyy-MM-dd HH:mm:ss")
private String workStartTime;
@ApiModelProperty(value = "工作结束时间,当排查周期是小时的时候为必填,时间格式yyyy-MM-dd HH:mm:ss")
private String workEndTime;
@ApiModelProperty(value = "工作日类型,参考枚举DataWorkDayTypeEnum")
private String workDayType;
@ApiModelProperty(value = "任务类型,参考枚举DataWorkTypeEnum")
private String workType;
@ApiModelProperty(value = "包保任务对应项,参照枚举DataTaskNumEnum,当任务类型为主要负责人任务、技术负责人任务、操作负责人任务时,此项为必填")
private String taskNum;
@ApiModelProperty(value = "巡检级别,参照枚举DataCheckLevelEnum")
private String checkLevel;
@ApiModelProperty(value = "巡检频次(天数/班数)")
private String checkTimesDay;
@ApiModelProperty(value = "巡检频次(次数)")
private String checkTimesNum;
@ApiModelProperty(value = "巡检任务类型,参照枚举DataCheckTaskTypeEnum")
private String checkTaskType;
@ApiModelProperty(value = "巡检有效开始时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkStartDate;
@ApiModelProperty(value = "巡检有效结束时间,格式:yyyy-MM-dd HH:mm:ss")
private String checkEndDate;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,97 @@
package com.zcloud.modules.data.entity.data;
import java.util.Date;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import io.swagger.annotations.ApiModelProperty;
/**
* (DataPersonRecord)
*
* @author zhaokai
* @since 2025-07-15 17:40:52
*/
@SuppressWarnings("serial")
@Data
@TableName("data_person_record")
public class DataPersonRecordEntity extends Model<DataPersonRecordEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "通行方向,参考枚举DataCrossTypeEnum")
private String crossType;
@ApiModelProperty(value = "通行时间(yyyy-MM-dd HH:mm:ss)")
private String eventTime;
@ApiModelProperty(value = "设备编码")
private String equipmentCode;
@ApiModelProperty(value = "人员编码")
private String staffCode;
@ApiModelProperty(value = "人员名称")
private String staffType;
@ApiModelProperty(value = "通行卡口名称")
private String checkName;
@ApiModelProperty(value = "人员抓拍图片(BASE64)")
private String picUri;
@ApiModelProperty(value = "所属企业名称")
private String enterpriseName;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,176 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataProductionPromise)
*
* @author zhaokai
* @since 2025-07-15 16:24:51
*/
@SuppressWarnings("serial")
@Data
@TableName("data_production_promise")
public class DataProductionPromiseEntity extends Model<DataProductionPromiseEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "生产装置套数")
private Integer unitsNumber;
@ApiModelProperty(value = "运行套数")
private Integer runNumber;
@ApiModelProperty(value = "停车套数")
private Integer parkNumber;
@ApiModelProperty(value = "特级动火作业数量")
private Integer firesNumber;
@ApiModelProperty(value = "一级动火作业数量")
private Integer fire1Number;
@ApiModelProperty(value = "二级动火作业数量")
private Integer fire2Number;
@ApiModelProperty(value = "断路作业数量")
private Integer roadworkNumber;
@ApiModelProperty(value = "动土作业数量")
private Integer soilworkNumber;
@ApiModelProperty(value = "高处作业数量")
private Integer highworkNumber;
@ApiModelProperty(value = "临时用电作业数量")
private Integer electricityworkNumber;
@ApiModelProperty(value = "吊装作业数量")
private Integer liftingworkNumber;
@ApiModelProperty(value = "盲板作业数量")
private Integer blindplateNumber;
@ApiModelProperty(value = "受限空间作业数量")
private Integer spaceworkNumber;
@ApiModelProperty(value = "检维修作业数量")
private Integer inspectionNumber;
@ApiModelProperty(value = "倒罐作业数量")
private Integer pourOutNumber;
@ApiModelProperty(value = "清罐作业数量")
private Integer cleanTankNumber;
@ApiModelProperty(value = "切水作业数量")
private Integer drainingNumber;
@ApiModelProperty(value = "承包商作业数量")
private Integer contractorNumber;
@ApiModelProperty(value = "变更作业数量")
private Integer changedTaskNumber;
@ApiModelProperty(value = "是否有承包商作业,参考枚举DataIsCommonStatusEnum")
private String contractor;
@ApiModelProperty(value = "是否处于试生产期,参考枚举DataIsCommonStatusEnum")
private String trialProduction;
@ApiModelProperty(value = "是否处于开停车状态,参考枚举DataIsCommonStatusEnum")
private Integer openParking;
@ApiModelProperty(value = "正在开停车装置数")
private Integer openParkingNumber;
@ApiModelProperty(value = "开车装置数")
private Integer workNumber;
@ApiModelProperty(value = "停车装置数")
private Integer notWorkNumber;
@ApiModelProperty(value = "是否开展中(扩)试,参考枚举DataIsCommonStatusEnum")
private String test;
@ApiModelProperty(value = "试生产装置数")
private Integer testNumber;
@ApiModelProperty(value = "检维修套数")
private Integer overhaulWorkNumber;
@ApiModelProperty(value = "重点监管危险工艺数量")
private Integer dangerProcessNumber;
@ApiModelProperty(value = "有无重大隐患,参考枚举DataIsCommonStatusEnum")
private String mHazards;
@ApiModelProperty(value = "风险级别,参考枚举DataRiskGradEnum")
private String riskGrade;
@ApiModelProperty(value = "承诺时间")
private String commitDate;
@ApiModelProperty(value = "承诺人")
private String commitment;
@ApiModelProperty(value = "承诺内容")
private String commitContent;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,79 @@
package com.zcloud.modules.data.entity.data;
import java.util.Date;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import io.swagger.annotations.ApiModelProperty;
/**
* (DataPromiseTicket)
*
* @author zhaokai
* @since 2025-07-15 16:46:53
*/
@SuppressWarnings("serial")
@Data
@TableName("data_promise_ticket")
public class DataPromiseTicketEntity extends Model<DataPromiseTicketEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "承诺详情ID,")
private String promiseId;
@ApiModelProperty(value = "作业票证ID,")
private String ticketId;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,107 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataRiskControlMeasure)
*
* @author zhaokai
* @since 2025-07-15 09:46:30
*/
@SuppressWarnings("serial")
@Data
@TableName("data_risk_control_measure")
public class DataRiskControlMeasureEntity extends Model<DataRiskControlMeasureEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "关联风险事件ID")
private String riskEventId;
@ApiModelProperty(value = "管控方式,参照枚举DataDataSrcEnum")
private String dataSrc;
@ApiModelProperty(value = "安全风险管控措施描述")
private String riskMeasureDesc;
@ApiModelProperty(value = "管控措施分类1,参照枚举 DataClassify1Enum")
private String classify1;
@ApiModelProperty(value = "管控措施分类2,参照枚举 DataClassify2Enum")
private String classify2;
@ApiModelProperty(value = "管控措施分类3,企业自定义")
private String classify3;
@ApiModelProperty(value = "隐患排查内容")
private String troubleshootContent;
@ApiModelProperty(value = "管控级别,参照枚举 DataRiskMeasureLevelEnum")
private String riskMeasureLevel;
@ApiModelProperty(value = "管控责任部门")
private String riskMeasureDep;
@ApiModelProperty(value = "管控责任人")
private String riskMeasurer;
@ApiModelProperty(value = "隐患问题描述JSON字符串")
private String hiddenDangerDescription;
@ApiModelProperty(value = "业务数据删除状态")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,113 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* (DataRiskIdentification)
*
* @author zhaokai
* @since 2025-07-15 14:01:36
*/
@SuppressWarnings("serial")
@Data
@TableName("data_risk_identification")
public class DataRiskIdentificationEntity extends Model<DataRiskIdentificationEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "推送状态(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "风险分析单元ID")
private String riskUnitId;
@ApiModelProperty(value = "辨识部位")
private String partName;
@ApiModelProperty(value = "管控方式 参照枚举")
private String dataSrc;
@ApiModelProperty(value = "风险识别内容")
private String riskIdentificationContent;
@ApiModelProperty(value = "检查内容")
private String checkContent;
@ApiModelProperty(value = "风险事件名称")
private String riskEventName;
@ApiModelProperty(value = "管控部门")
private String deptName;
@ApiModelProperty(value = "管控责任人")
private String chargePerson;
@ApiModelProperty(value = "应急处置措施")
private String emergencyDisposal;
@ApiModelProperty(value = "评分方法 LEC、LS")
private String ratingMethod;
@ApiModelProperty(value = "LEC评级的L项对应ID,参照枚举DataLevelLEnum")
private Integer levelL;
@ApiModelProperty(value = "LEC评级的E项对应ID,参照枚举DataLevelEEnum")
private Integer levelE;
@ApiModelProperty(value = "LEC评级的C项对应ID,参照枚举DataLevelCEnum")
private Integer levelC;
@ApiModelProperty(value = "风险等级,参照枚举DataRiskLeveEnum")
private Integer riskLevel;
@ApiModelProperty(value = "业务数据删除状态, 参照枚举DataIsDeleteEnum")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,89 @@
package com.zcloud.modules.data.entity.data;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* /(DataUnitStop)
*
* @author zhaokai
* @since 2025-07-15 16:00:37
*/
@SuppressWarnings("serial")
@Data
@TableName("data_unit_stop")
public class DataUnitStopEntity extends Model<DataUnitStopEntity> {
@ApiModelProperty(value = "主键")
private Integer id;
@ApiModelProperty(value = "业务数据id")
private String dataId;
@ApiModelProperty(value = "三方平台id")
private Integer thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Integer servicePlatformId;
@ApiModelProperty(value = "企业id")
private Integer companyId;
@ApiModelProperty(value = "推送状态,(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "接收状态,(1.接收正常,2.接收异常)")
private Integer receiveStatus;
@ApiModelProperty(value = "业务类型,枚举形式BusinessDataTypeEnum")
private String businessType;
@ApiModelProperty(value = "接收时间")
private Date receiveTime;
@ApiModelProperty(value = "推送时间")
private Date pushTime;
@ApiModelProperty(value = "企业编码")
private String companyCode;
@ApiModelProperty(value = "风险分析对象编码即危险化学品登记信息管理系统中的危险源编码")
private String hazardCode;
@ApiModelProperty(value = "所属风险单元ID")
private String riskUnitId;
@ApiModelProperty(value = "停用/检修开始时间,时间格式yyyy-MM-dd HH:mm:ss")
private String stopStartTime;
@ApiModelProperty(value = "停用/检修结束时间,时间格式yyyy-MM-dd HH:mm:ss")
private String stopEndTime;
@ApiModelProperty(value = "停用/检修原因")
private String stopReason;
@ApiModelProperty(value = "业务数据删除状态,0-未删除 1-已删除")
private String deleted;
@ApiModelProperty(value = "创建时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyy-MM-dd HH:mm:ss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常0已删除1")
private Integer isDelete;
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataCarRecordEntity;
/**
* (DataCarRecord)
*
* @author zhaokai
* @since 2025-07-15 17:32:56
*/
public interface DataCarRecordService extends IService<DataCarRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataDangerCheckRecordEntity;
/**
* (DataDangerCheckRecord)
*
* @author zhaokai
* @since 2025-07-15 14:54:43
*/
public interface DataDangerCheckRecordService extends IService<DataDangerCheckRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataDangerInfoEntity;
/**
* (DataDangerInfo)
*
* @author zhaokai
* @since 2025-07-15 15:33:34
*/
public interface DataDangerInfoService extends IService<DataDangerInfoEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataDeviceRunStatusEntity;
/**
* (DataDeviceRunStatus)
*
* @author zhaokai
* @since 2025-07-15 16:36:02
*/
public interface DataDeviceRunStatusService extends IService<DataDeviceRunStatusEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataEquipDataReceivingEntity;
/**
* (DataEquipDataReceiving)
*
* @author zhaokai
* @since 2025-07-15 18:01:10
*/
public interface DataEquipDataReceivingService extends IService<DataEquipDataReceivingEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataHiddenCheckMissionEntity;
/**
* (DataHiddenCheckMission)
*
* @author zhaokai
* @since 2025-07-15 14:32:03
*/
public interface DataHiddenCheckMissionService extends IService<DataHiddenCheckMissionEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataPersonRecordEntity;
/**
* (DataPersonRecord)
*
* @author zhaokai
* @since 2025-07-15 17:40:52
*/
public interface DataPersonRecordService extends IService<DataPersonRecordEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataProductionPromiseEntity;
/**
* (DataProductionPromise)
*
* @author zhaokai
* @since 2025-07-15 16:24:51
*/
public interface DataProductionPromiseService extends IService<DataProductionPromiseEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataPromiseTicketEntity;
/**
* (DataPromiseTicket)
*
* @author zhaokai
* @since 2025-07-15 16:46:53
*/
public interface DataPromiseTicketService extends IService<DataPromiseTicketEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataRiskControlMeasureEntity;
/**
* (DataRiskControlMeasure)
*
* @author zhaokai
* @since 2025-07-15 09:46:30
*/
public interface DataRiskControlMeasureService extends IService<DataRiskControlMeasureEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataRiskIdentificationEntity;
/**
* (DataRiskIdentification)
*
* @author zhaokai
* @since 2025-07-15 14:01:36
*/
public interface DataRiskIdentificationService extends IService<DataRiskIdentificationEntity> {
}

View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.service.data;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.data.DataUnitStopEntity;
/**
* /(DataUnitStop)
*
* @author zhaokai
* @since 2025-07-15 16:00:37
*/
public interface DataUnitStopService extends IService<DataUnitStopEntity> {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataCarRecordDao;
import com.zcloud.modules.data.entity.data.DataCarRecordEntity;
import com.zcloud.modules.data.service.data.DataCarRecordService;
import org.springframework.stereotype.Service;
/**
* (DataCarRecord)
*
* @author zhaokai
* @since 2025-07-15 17:32:56
*/
@Service("dataCarRecordService")
public class DataCarRecordServiceImpl extends ServiceImpl<DataCarRecordDao, DataCarRecordEntity> implements DataCarRecordService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataDangerCheckRecordDao;
import com.zcloud.modules.data.entity.data.DataDangerCheckRecordEntity;
import com.zcloud.modules.data.service.data.DataDangerCheckRecordService;
import org.springframework.stereotype.Service;
/**
* (DataDangerCheckRecord)
*
* @author zhaokai
* @since 2025-07-15 14:54:43
*/
@Service("dataDangerCheckRecordService")
public class DataDangerCheckRecordServiceImpl extends ServiceImpl<DataDangerCheckRecordDao, DataDangerCheckRecordEntity> implements DataDangerCheckRecordService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataDangerInfoDao;
import com.zcloud.modules.data.entity.data.DataDangerInfoEntity;
import com.zcloud.modules.data.service.data.DataDangerInfoService;
import org.springframework.stereotype.Service;
/**
* (DataDangerInfo)
*
* @author zhaokai
* @since 2025-07-15 15:33:34
*/
@Service("dataDangerInfoService")
public class DataDangerInfoServiceImpl extends ServiceImpl<DataDangerInfoDao, DataDangerInfoEntity> implements DataDangerInfoService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataDeviceRunStatusDao;
import com.zcloud.modules.data.entity.data.DataDeviceRunStatusEntity;
import com.zcloud.modules.data.service.data.DataDeviceRunStatusService;
import org.springframework.stereotype.Service;
/**
* (DataDeviceRunStatus)
*
* @author zhaokai
* @since 2025-07-15 16:36:02
*/
@Service("dataDeviceRunStatusService")
public class DataDeviceRunStatusServiceImpl extends ServiceImpl<DataDeviceRunStatusDao, DataDeviceRunStatusEntity> implements DataDeviceRunStatusService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataEquipDataReceivingDao;
import com.zcloud.modules.data.entity.data.DataEquipDataReceivingEntity;
import com.zcloud.modules.data.service.data.DataEquipDataReceivingService;
import org.springframework.stereotype.Service;
/**
* (DataEquipDataReceiving)
*
* @author zhaokai
* @since 2025-07-15 18:01:10
*/
@Service("dataEquipDataReceivingService")
public class DataEquipDataReceivingServiceImpl extends ServiceImpl<DataEquipDataReceivingDao, DataEquipDataReceivingEntity> implements DataEquipDataReceivingService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataHiddenCheckMissionDao;
import com.zcloud.modules.data.entity.data.DataHiddenCheckMissionEntity;
import com.zcloud.modules.data.service.data.DataHiddenCheckMissionService;
import org.springframework.stereotype.Service;
/**
* (DataHiddenCheckMission)
*
* @author zhaokai
* @since 2025-07-15 14:32:03
*/
@Service("dataHiddenCheckMissionService")
public class DataHiddenCheckMissionServiceImpl extends ServiceImpl<DataHiddenCheckMissionDao, DataHiddenCheckMissionEntity> implements DataHiddenCheckMissionService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataPersonRecordDao;
import com.zcloud.modules.data.entity.data.DataPersonRecordEntity;
import com.zcloud.modules.data.service.data.DataPersonRecordService;
import org.springframework.stereotype.Service;
/**
* (DataPersonRecord)
*
* @author zhaokai
* @since 2025-07-15 17:40:52
*/
@Service("dataPersonRecordService")
public class DataPersonRecordServiceImpl extends ServiceImpl<DataPersonRecordDao, DataPersonRecordEntity> implements DataPersonRecordService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataProductionPromiseDao;
import com.zcloud.modules.data.entity.data.DataProductionPromiseEntity;
import com.zcloud.modules.data.service.data.DataProductionPromiseService;
import org.springframework.stereotype.Service;
/**
* (DataProductionPromise)
*
* @author zhaokai
* @since 2025-07-15 16:24:51
*/
@Service("dataProductionPromiseService")
public class DataProductionPromiseServiceImpl extends ServiceImpl<DataProductionPromiseDao, DataProductionPromiseEntity> implements DataProductionPromiseService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataPromiseTicketDao;
import com.zcloud.modules.data.entity.data.DataPromiseTicketEntity;
import com.zcloud.modules.data.service.data.DataPromiseTicketService;
import org.springframework.stereotype.Service;
/**
* (DataPromiseTicket)
*
* @author zhaokai
* @since 2025-07-15 16:46:53
*/
@Service("dataPromiseTicketService")
public class DataPromiseTicketServiceImpl extends ServiceImpl<DataPromiseTicketDao, DataPromiseTicketEntity> implements DataPromiseTicketService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataRiskControlMeasureDao;
import com.zcloud.modules.data.entity.data.DataRiskControlMeasureEntity;
import com.zcloud.modules.data.service.data.DataRiskControlMeasureService;
import org.springframework.stereotype.Service;
/**
* (DataRiskControlMeasure)
*
* @author zhaokai
* @since 2025-07-15 09:46:30
*/
@Service("dataRiskControlMeasureService")
public class DataRiskControlMeasureServiceImpl extends ServiceImpl<DataRiskControlMeasureDao, DataRiskControlMeasureEntity> implements DataRiskControlMeasureService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataRiskIdentificationDao;
import com.zcloud.modules.data.entity.data.DataRiskIdentificationEntity;
import com.zcloud.modules.data.service.data.DataRiskIdentificationService;
import org.springframework.stereotype.Service;
/**
* (DataRiskIdentification)
*
* @author zhaokai
* @since 2025-07-15 14:01:36
*/
@Service("dataRiskIdentificationService")
public class DataRiskIdentificationServiceImpl extends ServiceImpl<DataRiskIdentificationDao, DataRiskIdentificationEntity> implements DataRiskIdentificationService {
}

View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.service.data.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.data.DataUnitStopDao;
import com.zcloud.modules.data.entity.data.DataUnitStopEntity;
import com.zcloud.modules.data.service.data.DataUnitStopService;
import org.springframework.stereotype.Service;
/**
* /(DataUnitStop)
*
* @author zhaokai
* @since 2025-07-15 16:00:37
*/
@Service("dataUnitStopService")
public class DataUnitStopServiceImpl extends ServiceImpl<DataUnitStopDao, DataUnitStopEntity> implements DataUnitStopService {
}

View File

@ -0,0 +1,23 @@
package com.zcloud.modules.data.service.temp;
import com.zcloud.modules.sys.entity.PageData;
import java.util.List;
public interface TempPushDataService {
/**
*
*/
List<PageData> pushConfinedSpaceData();
List<PageData> getHighWorkData();
List<PageData> getHotWorkData();
List<PageData> getElectricityData();
List<PageData> getBreakgroundData();
List<PageData> getCutroadData();
}

View File

@ -0,0 +1,57 @@
package com.zcloud.modules.data.service.temp.impl;
import com.zcloud.modules.data.dao.temp.TempPushDataDao;
import com.zcloud.modules.data.service.temp.TempPushDataService;
import com.zcloud.modules.data.thirdservice.baotou.ty.TyReportUtilService;
import com.zcloud.modules.sys.entity.PageData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class TempPushDataServiceImpl implements TempPushDataService {
@Autowired
private TempPushDataDao tempPushDataDao;
@Autowired
private TyReportUtilService tyReportUtilService;
@Override
public List<PageData> pushConfinedSpaceData() {
List<PageData> pageData = tempPushDataDao.listConfinedSpaceDataAll(new PageData());
System.out.println(pageData);
return pageData;
}
@Override
public List<PageData> getHighWorkData() {
List<PageData> pageData = tempPushDataDao.getHighWorkData();
System.out.println(pageData);
return pageData;
}
@Override
public List<PageData> getHotWorkData() {
return tempPushDataDao.getHotWorkData();
}
@Override
public List<PageData> getElectricityData() {
return tempPushDataDao.getElectricityData();
}
@Override
public List<PageData> getBreakgroundData() {
return tempPushDataDao.getBreakgroundData();
}
@Override
public List<PageData> getCutroadData() {
return tempPushDataDao.getCutroadData();
}
}

View File

@ -0,0 +1,90 @@
package com.zcloud.modules.data.thirdservice.data.convert;
import com.zcloud.modules.data.dto.data.info.HazardPoint;
import com.zcloud.modules.data.dto.tangshan.dj.req.DjSafeRiskAnalysisUnitReqDto;
import com.zcloud.modules.data.dto.tangshan.dj.req.DjSafeRiskControlMeasureReqDto;
import com.zcloud.modules.data.dto.tangshan.dj.req.DjSafeRiskEventReqDto;
import com.zcloud.modules.data.entity.data.DataRiskControlMeasureEntity;
import com.zcloud.modules.data.entity.data.DataRiskEventsEntity;
import com.zcloud.modules.data.entity.data.DataRiskUnitEntity;
import com.zcloud.modules.data.enums.data.*;
import com.zcloud.modules.util.ConvertBeanUtil;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.Named;
import org.mapstruct.factory.Mappers;
@Mapper
public interface DjDtoConvertMapper {
//转换数据,字段比较多,只能一个一个手动赋值,注意枚举信息
DjDtoConvertMapper INSTANCE = Mappers.getMapper(DjDtoConvertMapper.class);
@Mapping(source = "deleted", target = "recordDeleted")
@Mapping(source = "createDate", target = "recordCreateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "updateDate", target = "recordUpdateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "dataId", target = "recordId")
@Mapping(source = "createBy", target = "recordCreateBy")
@Mapping(source = "updateBy", target = "recordUpdateBy")
@Mapping(source = "hazardPoint", target = "hazardPoint", qualifiedByName = "convertHazardPoint")
@Mapping(source = "hazardRank", target = "hazardRank", qualifiedByName = "convertHazardRank")
@Mapping(source = "hazardType", target = "hazardType", qualifiedByName = "convertHazardType")
DjSafeRiskAnalysisUnitReqDto convertSafeRiskUnitReqDto(DataRiskUnitEntity dtoList);
@Mapping(source = "deleted", target = "recordDeleted")
@Mapping(source = "createDate", target = "recordCreateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "updateDate", target = "recordUpdateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "dataId", target = "recordId")
@Mapping(source = "createBy", target = "recordCreateBy")
@Mapping(source = "updateBy", target = "recordUpdateBy")
DjSafeRiskEventReqDto convertSafeRiskEventsReqDto(DataRiskEventsEntity newDataRiskEventsEntity);
@Mapping(source = "dataId", target = "recordId")
@Mapping(source = "deleted", target = "recordDeleted")
@Mapping(source = "createDate", target = "recordCreateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "updateDate", target = "recordUpdateTime", dateFormat = "yyyy-MM-dd HH:mm:ss")
@Mapping(source = "createBy", target = "recordCreateBy")
@Mapping(source = "updateBy", target = "recordUpdateBy")
@Mapping(source = "dataSrc", target = "dataSrc", qualifiedByName = "convertDataSrc")
@Mapping(source = "classify1", target = "classify1", qualifiedByName = "convertClassify1")
@Mapping(source = "classify2", target = "classify2", qualifiedByName = "convertClassify2")
@Mapping(source = "riskMeasureLevel", target = "riskMeasureLevel", qualifiedByName = "convertRiskMeasureLevel")
DjSafeRiskControlMeasureReqDto convertControlMeasureReqDto(DataRiskControlMeasureEntity entity);
@Named("convertHazardPoint")
default HazardPoint convertHazardPoint(String source) {
return ConvertBeanUtil.convertBean(source, HazardPoint.class);
}
@Named("convertHazardRank")
default String convertHazardRank(String hazardRank) {
return DataHazardRankEnum.getByCode(hazardRank).getDjCode();
}
@Named("convertHazardType")
default String convertHazardType(String hazardType) {
return DataHazardTypeEnum.getByCode(hazardType).getDjCode();
}
@Named("convertDataSrc")
default String convertDataSrc(String dataSrc) {
return DataDataSrcEnum.getByCode(dataSrc).getDjcode();
}
@Named("convertClassify1")
default String convertClassify1(String classify1) {
return DataClassify1Enum.getByCode(classify1).getDjcode();
}
@Named("convertClassify2")
default String convertClassify2(String classify2) {
return DataClassify2Enum.getByCode(classify2).getDjCode();
}
@Named("convertRiskMeasureLevel")
default String convertRiskMeasureLevel(String riskMeasureLevel) {
return DataRiskMeasureLevelEnum.getByCode(riskMeasureLevel).getDjCode();
}
}

View File

@ -0,0 +1,37 @@
package com.zcloud.modules.data.thirdservice.data.convert;
import com.zcloud.modules.data.dto.tangshan.ds.req.DsRiskAnalysisReqDto;
import com.zcloud.modules.data.dto.tangshan.ds.req.DsRiskAnalysisUnitReqDto;
import com.zcloud.modules.data.entity.data.DataRiskObjectEntity;
import com.zcloud.modules.data.entity.data.DataRiskUnitEntity;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.factory.Mappers;
@Mapper
public interface DsDtoConvertMapper {
//转换数据,字段比较多,只能一个一个手动赋值,注意枚举信息
DsDtoConvertMapper INSTANCE = Mappers.getMapper(DsDtoConvertMapper.class);
/**
* DTO
* @param dataRiskUnitEntity
* @return DTO
*/
DsRiskAnalysisUnitReqDto convertSafeRiskUnitReqDto(DataRiskUnitEntity dataRiskUnitEntity);
/**
* DTO
* @param dataRiskObjectEntity
* @return DTO
*/
@Mapping(source = "dataId", target = "id")
@Mapping(source = "companyCode", target = "orgCode")
@Mapping(source = "deleted", target = "delFlag", numberFormat = "#")
@Mapping(source = "isMajorHazard", target = "isMajorHazard", numberFormat = "#")
@Mapping(source = "majorHazardId", target = "majorHazardId", numberFormat = "#")
DsRiskAnalysisReqDto convertSafeRiskObjectReqDto(DataRiskObjectEntity dataRiskObjectEntity);
}

View File

@ -0,0 +1,23 @@
package com.zcloud.modules.data.thirdservice.data.convert;
import com.zcloud.modules.data.dto.baotou.ty.req.TyRiskUnitReqDto;
import com.zcloud.modules.data.dto.wh.HeBeiReportV10.req.SjEquipDataReceivingReqDto;
import com.zcloud.modules.data.entity.data.DataEquipDataReceivingEntity;
import com.zcloud.modules.data.entity.data.DataRiskUnitEntity;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.factory.Mappers;
@Mapper
public interface HbV1DtoConvertMapper {
//转换数据,字段比较多,只能一个一个手动赋值,注意枚举信息
HbV1DtoConvertMapper INSTANCE = Mappers.getMapper(HbV1DtoConvertMapper.class);
@Mapping(source = "dataId", target = "id")
SjEquipDataReceivingReqDto convertEquipDataReceivingReqDto(DataEquipDataReceivingEntity entity);
}

View File

@ -0,0 +1,182 @@
package com.zcloud.modules.data.thirdservice.data.convert;
import com.zcloud.modules.data.dto.baotou.ty.req.*;
import com.zcloud.modules.data.entity.data.*;
import com.zcloud.modules.data.enums.data.*;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.Named;
import org.mapstruct.factory.Mappers;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeParseException;
@Mapper
public interface TyDtoConvertMapper {
//转换数据,字段比较多,只能一个一个手动赋值,注意枚举信息
TyDtoConvertMapper INSTANCE = Mappers.getMapper(TyDtoConvertMapper.class);
/**
*
*
* @param dtoList
* @return DTO
*/
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "dataId", target = "id")
@Mapping(source = "riskLevel", target = "riskLevel", qualifiedByName = "convertRiskLevel")
TyRiskUnitReqDto convertSafeRiskUnitReqDto(DataRiskUnitEntity dtoList);
/**
*
*
* @param newDataRiskEventsEntity
* @return DTO
*/
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
TyRiskEventsReqDto convertSafeRiskEventsReqDto(DataRiskEventsEntity newDataRiskEventsEntity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "dataSrc", target = "dataSrc", qualifiedByName = "convertDataSrc")
@Mapping(source = "classify1", target = "classify1", qualifiedByName = "convertClassify1")
@Mapping(source = "classify2", target = "classify2", qualifiedByName = "convertClassify2")
TyRiskControlMeasuresReqDto convertControlMeasureReqDto(DataRiskControlMeasureEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "checkCycleUnit", target = "checkCycleUnit", qualifiedByName = "convertcheckCycleUnit")
@Mapping(source = "taskStartTime", target = "taskStartTime", qualifiedByName = "convertDateString")
@Mapping(source = "workType", target = "workType", qualifiedByName = "convertWorkType")
TyHiddenCheckMissionReqDto convertHiddenCheckMissionReqDto(DataHiddenCheckMissionEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "checkTime", target = "checkTime", qualifiedByName = "convertDateString")
@Mapping(source = "checkStatus", target = "checkStatus", qualifiedByName = "convertCheckStatus")
TyHiddenCheckRecordReqDto convertDangerCheckRecordReqDto(DataDangerCheckRecordEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "dangerLevel", target = "dangerLevel", qualifiedByName = "convertDangerLevel")
@Mapping(source = "registerTime", target = "registTime", qualifiedByName = "convertDateString")
@Mapping(source = "dangerManageDeadline", target = "dangerManageDeadline", qualifiedByName = "convertDateString")
@Mapping(source = "checkAcceptTime", target = "checkAcceptTime", qualifiedByName = "convertDateString")
@Mapping(source = "dangerManageType", target = "dangerManageType", qualifiedByName = "convertDangerManageType")
TyHiddenDangerInfoReqDto convertDangerInfoReqDto(DataDangerInfoEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "stopStartTime", target = "stopStartTime", qualifiedByName = "convertDateString")
@Mapping(source = "stopEndTime", target = "stopEndTime", qualifiedByName = "convertDateString")
TyMaintenanceRecordReqDto convertUnitStopReqDto(DataUnitStopEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
TyProductionPromiseReqDto convertProductionPromiseReqDto(DataProductionPromiseEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
@Mapping(source = "runStatusBeginTime", target = "runStatusBeginTime", qualifiedByName = "convertDateString")
@Mapping(source = "runStatusEndTime", target = "runStatusEndTime", qualifiedByName = "convertDateString")
TyDeviceRunStatusReqDto convertDeviceRunStatusReqDto(DataDeviceRunStatusEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
TyPromiseTicketReqDto convertPromiseTicketReqDto(DataPromiseTicketEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
TyCarRecordReqDto convertCarRecordReqDto(DataCarRecordEntity entity);
@Mapping(source = "dataId", target = "id")
@Mapping(source = "createDate", target = "createDate", qualifiedByName = "convertDateString")
@Mapping(source = "updateDate", target = "updateDate", qualifiedByName = "convertDateString")
TyPersonRecordReqDto convertPersonRecordReqDto(DataPersonRecordEntity entity);
@Named("convertDangerManageType")
default String convertDangerManageType(String dangerManageType) {
return DataDangerManageTypeEnum.getByCode(dangerManageType).getTyCode();
}
@Named("convertDangerLevel")
default String convertDangerLevel(String dangerLevel) {
return DataDangerLevelEnum.getByCode(dangerLevel).getTycode();
}
@Named("convertCheckStatus")
default String convertCheckStatus(String checkStatus) {
return DataCheckStatusEnum.getByCode(checkStatus).getTycode();
}
@Named("convertWorkType")
default String convertWorkType(String workType) {
return DataWorkTypeEnum.getByCode(workType).getTycode();
}
@Named("convertcheckCycleUnit")
default String convertcheckCycleUnit(String checkCycleUnit) {
return DataCheckCycleUnitEnum.getByCode(checkCycleUnit).getTycode();
}
@Named("convertDataSrc")
default String convertDataSrc(String dataSrc) {
return DataDataSrcEnum.getByCode(dataSrc).getTycode();
}
@Named("convertClassify1")
default String convertClassify1(String classify1) {
return DataClassify1Enum.getByCode(classify1).getTycode();
}
@Named("convertClassify2")
default String convertClassify2(String classify2) {
return DataClassify2Enum.getByCode(classify2).getTyCode();
}
/**
*
*
* @param riskLevel
* @return
*/
@Named("convertRiskLevel")
default String convertRiskLevel(String riskLevel) {
return DataRiskLeveEnum.getByCode(riskLevel).getTyCode();
}
@Named("convertDateString")
default String convertDateString(String sourceDate) {
if (sourceDate == null) {
return null;
}
try {
DateTimeFormatter sourceFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
DateTimeFormatter targetFormatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
LocalDateTime dateTime = LocalDateTime.parse(sourceDate, sourceFormatter);
return dateTime.format(targetFormatter);
} catch (DateTimeParseException e) {
return null;
}
}
}

View File

@ -0,0 +1,425 @@
package com.zcloud.modules.data.thirdservice.data.impl;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zcloud.common.utils.R;
import com.zcloud.modules.corp.entity.BusCompanyThirdRelationEntity;
import com.zcloud.modules.corp.entity.BusThirdDataItemsRelationEntity;
import com.zcloud.modules.corp.entity.BusThirdPlatformEntity;
import com.zcloud.modules.corp.service.BusCompanyThirdRelationService;
import com.zcloud.modules.corp.service.BusThirdDataItemsRelationService;
import com.zcloud.modules.corp.service.BusThirdPlatformService;
import com.zcloud.modules.data.dao.DynamicTableDao;
import com.zcloud.modules.data.dto.data.req.*;
import com.zcloud.modules.data.dto.panjin.PjEncryptionDto;
import com.zcloud.modules.data.entity.business.BusLogInfoYearEntity;
import com.zcloud.modules.data.entity.data.DataPushScheduledEntity;
import com.zcloud.modules.data.enums.business.BusIsRequiredEnum;
import com.zcloud.modules.data.enums.business.BusPushFrequencyEnum;
import com.zcloud.modules.data.enums.data.DataIsDeleteEnum;
import com.zcloud.modules.data.enums.data.DataPushStatusEnum;
import com.zcloud.modules.data.enums.data.DataReceiveStatusEnum;
import com.zcloud.modules.data.enums.panjin.url.PjReportV11Enum;
import com.zcloud.modules.data.service.business.BusLogInfoYearService;
import com.zcloud.modules.data.service.data.DataPushScheduledService;
import com.zcloud.modules.data.service.data.DataServiceAggregate;
import com.zcloud.modules.data.thirdservice.data.ExchangeDataCommonService;
import com.zcloud.modules.data.thirdservice.panjin.PjReportUtilService;
import com.zcloud.modules.util.HandBeanUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.function.Function;
import java.util.stream.Collectors;
@Service
@Slf4j
public class PjExchangeDataServiceImpl implements ExchangeDataCommonService {
@Autowired
private DataServiceAggregate dataServiceAggregate;
@Autowired
private BusThirdDataItemsRelationService thirdDataItemsRelationService;
@Autowired
private BusThirdPlatformService thirdPlatformService;
@Autowired
private BusCompanyThirdRelationService companyThirdRelationService;
@Autowired
private BusLogInfoYearService busLogInfoYearService;
@Autowired
private PjReportUtilService pjReportUtilService;
@Autowired
private DataPushScheduledService dataPushScheduledService;
@Autowired
@Qualifier("dataPushThreadPool") // 通过 @Qualifier 指定 Bean 名称
private ThreadPoolTaskExecutor dataPushThreadPool;
@Autowired
private DynamicTableDao dynamicTableDao;
@Override
public R pushRiskUnitData(DataRiskUnitReqDto reqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskUnitData,盘锦园区暂时不支持推送安全风险分析单元");
return R.ok();
}
@Override
public R pushRiskEventsData(DataRiskEventsReqDto reqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskObjectData,盘锦园区暂时不支持推送安全风险事件数据");
return R.ok();
}
@Override
public R pushRiskObjectData(DataRiskObjectReqDto dataRiskObjectReqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskUnitData,盘锦园区暂时不支持推送分享分析对象数据");
return R.ok();
}
@Override
public R pushRiskControlMeasureData(DataRiskControlMeasureReqDto dataRiskControlMeasureReqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskControlMeasureData,盘锦园区暂时不支持推送安全风险控制措施数据");
return R.ok();
}
@Override
public R pushRiskIdentificationData(DataRiskIdentificationReqDto dataRiskIdentificationReqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskIdentificationData,盘锦园区暂时不支持推送上报安全风险识别数据");
return R.ok();
}
@Override
public R pushHiddenCheckMissionData(DataHiddenCheckMissionReqDto dataHiddenCheckMissionReqDto) {
log.info("PjExchangeDataServiceImpl->pushRiskIdentificationData,盘锦园区暂时不支持推送上报隐患排查任务数据");
return R.ok();
}
@Override
public R pushDangerCheckRecordData(DataDangerCheckRecordReqDto dataDangerCheckRecordReqDto) {
log.info("PjExchangeDataServiceImpl->pushDangerCheckRecordData,盘锦园区暂时不支持推送隐患排查记录数据");
return R.ok();
}
@Override
public R pushDangerInfoData(DataDangerInfoReqDto dangerInfoReqDto) {
return null;
}
@Override
public R pushUnitStopData(DataUnitStopReqDto dataUnitStopReqDto) {
log.info("PjExchangeDataServiceImpl->pushUnitStopData,盘锦园区暂时不支持推送上报停用/检修记录数据");
return R.ok();
}
@Override
public R pushProductionPromiseData(DataProductionPromiseReqDto dataProductionPromiseReqDto) {
log.info("PjExchangeDataServiceImpl->pushProductionPromiseData,盘锦园区暂时不支持推送上报安全承诺数据");
return R.ok();
}
@Override
public R pushDeviceRunStatusData(DataDeviceRunStatusReqDto dataDeviceRunStatusReqDto) {
log.info("PjExchangeDataServiceImpl->pushDeviceRunStatusData,盘锦园区暂时不支持推送上报承诺装置运行状态数据");
return R.ok();
}
@Override
public R pushPromiseTicketData(DataPromiseTicketReqDto dataPromiseTicketReqDto) {
log.info("PjExchangeDataServiceImpl->pushPromiseTicketData,盘锦园区暂时不支持推送上报安全承诺作业票详情数据");
return R.ok();
}
@Override
public R pushCarRecordData(DataCarRecordReqDto dataCarRecordReqDto) {
log.info("PjExchangeDataServiceImpl->pushCarRecordData,盘锦园区暂时不支持推送卡口车辆通行记录数据");
return R.ok();
}
@Override
public R pushPersonRecordData(DataPersonRecordReqDto dataPersonRecordReqDto) {
log.info("PjExchangeDataServiceImpl->pushPersonRecordData,盘锦园区暂时不支持推送卡口人员通行记录数据");
return R.ok();
}
@Override
public R pushEquipDataReceivingData(DataEquipDataReceivingReqDto dataEquipDataReceivingReqDto) {
log.info("PjExchangeDataServiceImpl->pushEquipDataReceivingData,盘锦园区暂时不支持推送雷电预警设备基础数据");
return R.ok();
}
/**
*
*
* @param reqDto DTO
* @param entityClass Class
* @param reportEnum
* @param converter
* @param <T> DTO
* @param <E>
* @param <D> DTO
* @return
*/
private <T extends DataCommonReqDto, E, D> R processData(T reqDto, Class<E> entityClass, PjReportV11Enum reportEnum, Function<E, D> converter, Object dataService) throws Exception {
// 查找上游推送配置信息
BusCompanyThirdRelationEntity companyThirdRelation = getCompanyThirdRelation(reqDto);
// 记录请求日志信息
BusLogInfoYearEntity busLogInfoYearEntity = new BusLogInfoYearEntity();
//获取实体bean进行copyProperties及赋值服务平台id和企业编码
E entity = entityClass.getDeclaredConstructor().newInstance();
// BeanUtils.copyProperties(reqDto, entity);
HandBeanUtils.copyProperties(reqDto, entity);
//获取bean中的属性
Integer servicePlatformId = (Integer)getEntityMethodValue(entity, entityClass, "getServicePlatformId");
Object companyCode = getEntityMethodValue(entity, entityClass, "getCompanyCode");
Integer thirdPlatformId = (Integer) getEntityMethodValue(entity, entityClass, "getThirdPlatformId");
Integer companyId = (Integer) getEntityMethodValue(entity, entityClass, "getCompanyId");
// 记录推送状态
setEntityPushStatus(entity, entityClass, "setPushStatus", DataPushStatusEnum.NOT.getCode());
//赋值busLogInfoYearEntity 属性
String businessType = (String) getEntityMethodValue(entity, entityClass, "getBusinessType");
String dataId = (String) getEntityMethodValue(entity, entityClass, "getDataId");
busLogInfoYearEntity.setBusinessType(businessType);
busLogInfoYearEntity.setIndexReq(dataId);
log.info("PjExchangeDataServiceImpl->,接收到推送盘锦的数据信息,服务平台id={},企业编码={},推送类型:{},", servicePlatformId, companyCode,reportEnum.getDesc());
busLogInfoYearEntity.setReceiver(reportEnum.getReceiver());
busLogInfoYearEntity.setReceiverUrl(companyThirdRelation.getUrl() + "/" + reportEnum.getUrl());
// 校验数据项信息
List<BusThirdDataItemsRelationEntity> dataItemsList = thirdDataItemsRelationService.getThirdDataItemlist(
thirdPlatformId,
businessType);
if (CollUtil.isEmpty(dataItemsList)) {
// 推送的数据项为空,不进行推送,记录日志
log.error("PjExchangeDataServiceImpl->,接收到推送盘锦的数据信息,服务平台id={},企业编码={},推送类型:{},配置的推送的数据项为空,不进行推送", servicePlatformId, companyCode,reportEnum.getDesc());
busLogInfoYearEntity.setResponse("推送的数据项为空,不进行推送");
//设置推送状态和接收状态
setEntityPushStatus(entity, entityClass, "setReceiveStatus", DataReceiveStatusEnum.FAIL.getCode());
setEntityPushStatus(entity, entityClass, "setPushStatus", DataPushStatusEnum.FAILED.getCode());
//保存数据
Method saveMethod = dataService.getClass().getMethod("save", Object.class);
saveMethod.invoke(dataService, entity);
//记录日志中id
Integer id = (Integer) getEntityMethodValue(entity, entityClass, "getId");
busLogInfoYearEntity.setDataId(id);
busLogInfoYearService.save(busLogInfoYearEntity);
return R.error(500, "推送盘锦未配置数据项,不进行推送");
}
// 校验参数是否必填
List<String> nullRequiredFieldNameList = new ArrayList<>();
checkFileName(entityClass, dataItemsList, reqDto, nullRequiredFieldNameList);
// 校验必填字段是否都填写
if (CollUtil.isNotEmpty(nullRequiredFieldNameList)) {
log.error("PjExchangeDataServiceImpl->,接收到推送盘锦的数据信息,服务平台id={},企业编码={},推送类型:{},存在必填字段为空的情况,不进行推送,字段为:{}", servicePlatformId, companyCode,reportEnum.getDesc(), nullRequiredFieldNameList);
// 存在必填字段为空的情况,不进行推送,记录日志
busLogInfoYearEntity.setResponse("存在必填字段为空的情况,不进行推送,字段为:" + nullRequiredFieldNameList);
//出现异常,设置推送状态
setEntityPushStatus(entity, entityClass, "setReceiveStatus", DataReceiveStatusEnum.FAIL.getCode());
setEntityPushStatus(entity, entityClass, "setPushStatus", DataPushStatusEnum.FAILED.getCode());
//保存数据
Method saveMethod = dataService.getClass().getMethod("save", Object.class);
saveMethod.invoke(dataService, entity);
//记录日志中id
Integer id = (Integer) getEntityMethodValue(entity, entityClass, "getId");
busLogInfoYearEntity.setDataId(id);
busLogInfoYearService.saveOrUpdate(busLogInfoYearEntity);
return R.error(500, "推送盘锦存在必填字段为空的情况,不进行推送");
}
//说明校验没问题,接收正常,赋值
setEntityPushStatus(entity, entityClass, "setReceiveStatus", DataReceiveStatusEnum.SUCCESS.getCode());
// 保存本地信息
Method saveMethod = dataService.getClass().getMethod("save", Object.class);
saveMethod.invoke(dataService, entity);
//记录日志中id
Integer id = (Integer) getEntityMethodValue(entity, entityClass, "getId");
busLogInfoYearEntity.setDataId(id);
// 组装业务数据
D dto = converter.apply(entity);
// 先保存下log
busLogInfoYearEntity.setRequest(JSONUtil.toJsonStr(dto));
busLogInfoYearService.saveOrUpdate(busLogInfoYearEntity);
// 判断是否是定时推送
BusThirdPlatformEntity thirdPlatformInfo = thirdPlatformService.getById(thirdPlatformId);
if (!BusPushFrequencyEnum.REALTIME.getCode().equals(thirdPlatformInfo.getFrequency())) {
// TODO 定时推送,需要将数据存入数据库中,定时任务进行推送
setEntityPushStatus(entity, entityClass, "setPushStatus", DataPushStatusEnum.SCHEDULED.getCode());
Method saveOrUpdateMethod = dataService.getClass().getMethod("saveOrUpdate", Object.class);
saveOrUpdateMethod.invoke(dataService, entity);
// 异步保存定时推送数据
CompletableFuture.runAsync(() -> dataPushScheduledService.saveScheduledData(businessType, id, dataId, thirdPlatformId, dto, companyId, companyCode, thirdPlatformInfo.getFrequency(), servicePlatformId), dataPushThreadPool);
log.info("PjExchangeDataServiceImpl->,接收到推送盘锦的数据信息,服务平台id={},企业编码={},推送类型:{},配置定时推送,暂时不推送", servicePlatformId, companyCode,reportEnum.getDesc());
} else {
log.info("PjExchangeDataServiceImpl->,接收到推送盘锦的数据信息,服务平台id={},企业编码={},推送类型:{},配置实时推送", servicePlatformId, companyCode,reportEnum.getDesc());
//就此处和其他有区别
PjEncryptionDto configurationDto = new PjEncryptionDto();
configurationDto.setUrl(companyThirdRelation.getUrl());
configurationDto.setCode( companyThirdRelation.getCode().substring(companyThirdRelation.getCode().length() - 6));
configurationDto.setCompanyCode(companyThirdRelation.getCompanyCode());
Integer status = pjReportUtilService.pushData(dto, reportEnum, busLogInfoYearEntity, configurationDto);
// 返回的是推送状态
setEntityPushStatus(entity, entityClass, "setPushStatus", status);
if (DataPushStatusEnum.SUCCESSFUL.getCode().equals(status)) {
// Method setPushTimeMethod = entityClass.getMethod("setPushTime", Date.class);
// setPushTimeMethod.invoke(entity, new Date());
setEntityPushStatus(entity, entityClass, "setPushTime", new Date());
Method updateMethod = dataService.getClass().getMethod("updateById", Object.class);
updateMethod.invoke(dataService, entity);
} else {
Method updateMethod = dataService.getClass().getMethod("updateById", Object.class);
updateMethod.invoke(dataService, entity);
return R.error(500, "推送盘锦推送失败");
}
}
return R.ok();
}
@Override
public void dataPushscheduled(List<DataPushScheduledEntity> dataPushScheduledEntities) {
log.info("dataPushscheduled,定时推送数据,土右数据数量:{}",dataPushScheduledEntities.size());
//需要修改对应业务数据表状态修改log表状态修改定时表状态
for (int i = 0; i < dataPushScheduledEntities.size(); i++) {
DataPushScheduledEntity dataPushScheduledInfo = dataPushScheduledEntities.get(i);
BusLogInfoYearEntity logInfo = busLogInfoYearService.getLogInfo(dataPushScheduledInfo);
if(logInfo == null) {
log.error("dataPushscheduled,定时推送土右信息数据库中没有对应日志信息,暂时不推送,业务id={},业务类型={},定时数据:{}",dataPushScheduledInfo.getDataId(),dataPushScheduledInfo.getBusinessType(),JSONUtil.toJsonStr(dataPushScheduledInfo));
continue;
}
LambdaQueryWrapper<BusCompanyThirdRelationEntity> companyThirdRelationWrapper = new LambdaQueryWrapper<>();
companyThirdRelationWrapper.eq(BusCompanyThirdRelationEntity::getThirdPlatformId, dataPushScheduledInfo.getThirdPlatformId())
.eq(BusCompanyThirdRelationEntity::getServiceId, dataPushScheduledInfo.getServicePlatformId())
.eq(BusCompanyThirdRelationEntity::getCompanyId, dataPushScheduledInfo.getCompanyId())
.eq(BusCompanyThirdRelationEntity::getIsDelete, DataIsDeleteEnum.NO.getCode());
BusCompanyThirdRelationEntity companyThirdRelation = companyThirdRelationService.getOne(companyThirdRelationWrapper);
PjReportV11Enum pjReportV11Enum = PjReportV11Enum.getByBusinessType(dataPushScheduledInfo.getBusinessType());
PjEncryptionDto configurationDto = new PjEncryptionDto();
configurationDto.setUrl(companyThirdRelation.getUrl());
configurationDto.setCode( companyThirdRelation.getCode().substring(companyThirdRelation.getCode().length() - 6));
configurationDto.setCompanyCode(companyThirdRelation.getCompanyCode());
List<Object> list = new ArrayList<>();
list.add(logInfo.getRequest());
Integer status = pjReportUtilService.pushData(list, pjReportV11Enum, logInfo, configurationDto);
// 需要反查出对应的业务数据信息,修改状态 46张表怎么查动态拼接SQL
dynamicTableDao.updatePushStatus(status,dataPushScheduledInfo.getBusinessType(),dataPushScheduledInfo.getDataId());
dataPushScheduledInfo.setPushStatus(status);
dataPushScheduledInfo.setPushTime(new Date());
dataPushScheduledService.updateById(dataPushScheduledInfo);
}
}
/**
*
*
* @param entity
* @param entityClass Class
* @param methodName
* @return
* @throws
*/
private Object getEntityMethodValue(Object entity, Class<?> entityClass, String methodName) throws Exception {
Method method = entityClass.getMethod(methodName);
return method.invoke(entity);
}
/**
*
*
* @param entity
* @param entityClass Class
* @param methodName
* @param value
* @param <T>
* @throws
*/
private <T> void setEntityPushStatus(Object entity, Class<?> entityClass, String methodName, T value) throws Exception {
// 获取属性值的类型
Class<?> valueClass = value != null ? value.getClass() : Object.class;
Method setMethod = entityClass.getMethod(methodName, valueClass);
setMethod.invoke(entity, value);
}
private BusCompanyThirdRelationEntity getCompanyThirdRelation(DataCommonReqDto reqDto) {
LambdaQueryWrapper<BusCompanyThirdRelationEntity> companyThirdRelationWrapper = new LambdaQueryWrapper<>();
companyThirdRelationWrapper.eq(BusCompanyThirdRelationEntity::getThirdPlatformId, reqDto.getThirdPlatformId())
.eq(BusCompanyThirdRelationEntity::getServiceId, reqDto.getServicePlatformId())
.eq(BusCompanyThirdRelationEntity::getCompanyId, reqDto.getCompanyId())
.eq(BusCompanyThirdRelationEntity::getIsDelete, DataIsDeleteEnum.NO.getCode());
List<BusCompanyThirdRelationEntity> companyThirdRelationList = companyThirdRelationService.list(companyThirdRelationWrapper);
//不判断为空,上层已校验
BusCompanyThirdRelationEntity companyThirdRelation = companyThirdRelationList.get(0);
return companyThirdRelation;
}
/**
*
*
* @param dataItemsList
*/
private <T> T checkFileName(Class<T> newEntityClass, List<BusThirdDataItemsRelationEntity> dataItemsList, DataCommonReqDto reqDto, List<String> nullRequiredFieldNameList) {
List<String> fieldNameList = dataItemsList.stream().map(BusThirdDataItemsRelationEntity::getFieldName).collect(Collectors.toList());
// 获取dataItemsList中所有is_required字段为1的field_name字段list
List<String> requiredFieldNameList = dataItemsList.stream().filter(item -> BusIsRequiredEnum.YES.getCode().equals(item.getIsRequired())).map(BusThirdDataItemsRelationEntity::getFieldName).collect(Collectors.toList());
// 将reqDto转成json并获取所有fieldNameList中的key重新组装成一个json对象
Map<String, Object> infoMap = JSONUtil.toBean(JSONUtil.toJsonStr(reqDto), Map.class);
// 将bean中所有key不在fieldNameList中的key移除
infoMap.keySet().removeIf(key -> !fieldNameList.contains(key));
// 验证infoMap中的 在requiredFieldNameList 总的key哪些是为空的返回list
nullRequiredFieldNameList.addAll(requiredFieldNameList.stream().filter(key -> ObjectUtil.isNull(infoMap.get(key))).collect(Collectors.toList()));
// 将infoMap转成新的实体对象
return JSONUtil.toBean(JSONUtil.toJsonStr(infoMap), newEntityClass);
}
@Override
public String getPlatformCode() {
return "pj";
}
}

View File

@ -0,0 +1,125 @@
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
druid:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://47.92.102.56:33068/integrated_whb?serverTimezone=Asia/Shanghai&useSSL=false&useUnicode=true&characterEncoding=utf-8
username: root
password: Admin@@admin88888
initial-size: 10
max-active: 100
min-idle: 10
max-wait: 60000
pool-prepared-statements: true
max-pool-prepared-statement-per-connection-size: 20
time-between-eviction-runs-millis: 60000
min-evictable-idle-time-millis: 300000
#Oracle需要打开注释
#validation-query: SELECT 1 FROM DUAL
test-while-idle: true
test-on-borrow: false
test-on-return: false
stat-view-servlet:
enabled: true
url-pattern: /druid/*
login-username: admin
login-password: admin
allow: 192.168.0.14
filter:
stat:
log-slow-sql: true
slow-sql-millis: 1000
merge-sql: false
wall:
config:
multi-statement-allow: true
redis:
open: true # 是否开启redis缓存 true开启 false关闭
database: 0
host: 192.168.0.17
port: 6379
timeout: 6000ms # 连接超时时长(毫秒)
jedis:
pool:
max-active: 1000 # 连接池最大连接数(使用负值表示没有限制)
max-wait: -1ms # 连接池最大阻塞等待时间(使用负值表示没有限制)
max-idle: 10 # 连接池中的最大空闲连接
min-idle: 5 # 连接池中的最小空闲连接
kafka:
bootstrap-servers: 192.168.20.230:9092
consumer:
# 消费者分组的id,可以在 kafka 的 config 目录下的 consumer.properties 中配置
group-id: test-consumer-group
# 是否自动提交消费者的偏移量
enable-auto-commit: true
# 自动提交的频率 3s
auto-commit-interval: 3000
server:
servlet:
encoding:
charset: UTF-8
enabled: true
force: true
logging:
level:
org.apache.kafka: ERROR
org.springframework.kafka: ERROR
rocketmq:
name-server: 192.168.20.230:9876
producer:
group: docking-producer
compress-message-body-threshold: 4096
send-message-timeout: 3000
max-message-size: 4194304
retry-times-when-send-failed: 3
retry-next-server: true
retry-times-when-send-async-failed: 3
consumer:
group: docking-consumer
instance-name: docking-consumer-instance
consume-message-batch-max-size: 1
consume-concurrently-max-spin-time-millis: 3000
consume-concurrently-max-size: 10
consume-thread-min: 20
consume-thread-max: 64
topic:
info: docking
wh-v10-topic: wh-v10-topic
xxl:
job:
admin:
addresses: http://192.168.20.230:28080/xxl-job-admin
#调度中心部署根地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册;
accessToken: yjb.prod
port: 1234
executor:
appname: docking-admin-task
logretentiondays: 30
wh:
sj:
v10:
url: http://www.baidu.com
appid: appids
secret: secrets
key: keysss
vi: vissss
tangshan:
dj:
url: https://ip:port/edi/data_upload
#唯一身份标识UUID 格式)
accessKey: 1011f4fe-62d9-46cb-80d8-90cacc457754
# Base64 编码的 RSA 公钥
rsaPublicKey: MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCjAFbhuGfSrEPv8kzWeaUM11gIXF1RlRa25kCMH2BcHgy6syTRzDEyyn6bYEGvqCgD46gVUmGb83QVcLWDfJaVvGInq1dmsuo762ss53QKmTs6j5wp/H304eifCGuu1PwWw9BlyErmgGsWSiJ18JxQHhu4/AO6Xrca96C0d+D5zwIDAQAB
charKey: Aa1Bb2Cc3Dd4Ee5Ff6Gg7Hh8Ii9Jj0KkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz\
baotou:
ty:
url: https://syncdata.park.tuyou.hgyq365.cn:8898
panjin:
url: http://124.94.111.159:6689/api/sync/data/

View File

@ -0,0 +1,451 @@
<?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.zcloud.modules.data.dao.temp.TempPushDataDao">
<!--分页查询-->
<select id="listConfinedSpaceDataAll" parameterType="com.zcloud.modules.sys.entity.PageData" resultType="com.zcloud.modules.sys.entity.PageData">
SELECT
b.companyCode,
a.CHECK_NO AS ticketNo,
'' AS ticketStatus,
a.CREATTIME AS issueTime,
'' AS planStartTime,
'' AS planEndTime,
a.WORK_START_DATE AS startTime,
a.WORK_END_DATE AS endTime,
a.PLS_NAME AS ticketPosition,
'' AS workAreaCode,
a.WORK_CONTENT AS ticketContent,
a.ACCEPT_TIME AS checkedTime,
c.`NAME` AS checkedPerson,
'' AS longitude,
'' AS latitude,
d.`NAME` AS supervisorName,
e.`NAME` AS workerName,
f.`NAME` AS workDeptment,
'' AS isContractorWork,
'' AS contractorOrg,
'' AS isAssociation,
'' AS associationTicket,
a.RISK_IDENTIFICATION AS riskIdentification,
g.`NAME` AS disclosePerson,
h.`NAME` AS acceptPerson,
i.`NAME` AS tickerResponsName,
i.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS commitmentLetter,
a.LIMITSPACE_NAME AS spaceName,
a.MEDIUM_NAME AS spaceMedium,
'0' AS deleted,
j.`NAME` AS createBy,
a.CREATTIME AS createDate,
k.`NAME` AS updateBy,
a.OPERATTIME AS updateDate
FROM
bus_confinedspace a
LEFT JOIN bus_corp_info b ON b.CORPINFO_ID = a.CORPINFO_ID
LEFT JOIN sys_user c ON a.ACCEPT_USER_ID = c.USER_ID
LEFT JOIN sys_user d ON a.GUARDIAN_USER_ID = d.USER_ID
LEFT JOIN sys_user e ON a.APPLY_USER_ID = e.USER_ID
LEFT JOIN oa_department f ON a.APPLY_DEPARTMENT_ID = f.DEPARTMENT_ID
LEFT JOIN sys_user g ON a.CONFESS_USER_ID = g.USER_ID
LEFT JOIN sys_user h ON a.ACCEPT_CONFESS_USER_ID = h.USER_ID
LEFT JOIN sys_user i ON a.CONFIRM_USER_ID = i.USER_ID
LEFT JOIN sys_user j ON a.CREATOR = j.USER_ID
LEFT JOIN sys_user k ON a.OPERATOR = k.USER_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = a.CONFINEDSPACE_ID
WHERE
a.ISDELETE = '0'
AND a.CORPINFO_ID IN ( '81e73a8e669d4421b5657ed05ace77c9', '90d4973740e94ff6a6382dcc709e98cb', 'bebfd3ee740a4abd9e78f9d94a85871d' )
and log.NEXT_STEP_ID = '99' and a.STEP_ID != -1
</select>
<select id="getHighWorkData" parameterType="com.zcloud.modules.sys.entity.PageData" resultType="com.zcloud.modules.sys.entity.PageData">
SELECT
a.HIGHWORK_ID as id,
b.companyCode,
a.CHECK_NO AS ticketNo,
'3' AS ticketStatus,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as issueTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as planStartTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as planEndTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as startTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as endTime,
a.WORK_PLACE AS ticketPosition,
'' AS workAreaCode,
a.WORK_CONTENT AS ticketContent,
DATE_FORMAT(a.ACCEPT_TIME, '%Y%m%d%H%i%s') as checkedTime,
c.`NAME` AS checkedPerson,
'' AS longitude,
'' AS latitude,
d.`NAME` AS supervisorName,
e.`NAME` AS workerName,
f.`NAME` AS workDeptment,
'' AS contractorOrg,
'0' AS isAssociation,
'' AS associationTicket,
a.RISK_IDENTIFICATION AS riskIdentification,
g.`NAME` AS disclosePerson,
h.`NAME` AS acceptPerson,
i.`NAME` AS tickerResponsName,
i.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'0' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS commitmentLetter,
a.WORK_LEVEL AS highLevel,
a.WORK_HIGH AS highHeight,
'0' AS deleted,
j.`NAME` AS createBy,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as createDate,
k.`NAME` AS updateBy,
DATE_FORMAT(a.OPERATTIME, '%Y%m%d%H%i%s') as updateDate
FROM
bus_highwork a
LEFT JOIN bus_corp_info b ON b.CORPINFO_ID = a.CORPINFO_ID
LEFT JOIN sys_user c ON a.ACCEPT_USER_ID = c.USER_ID
LEFT JOIN sys_user d ON a.GUARDIAN_USER_ID = d.USER_ID
LEFT JOIN sys_user e ON a.APPLY_USER_ID = e.USER_ID
LEFT JOIN oa_department f ON a.APPLY_DEPARTMENT_ID = f.DEPARTMENT_ID
LEFT JOIN sys_user g ON a.CONFESS_USER_ID = g.USER_ID
LEFT JOIN sys_user h ON a.ACCEPT_CONFESS_USER_ID = h.USER_ID
LEFT JOIN sys_user i ON a.CONFIRM_USER_ID = i.USER_ID
LEFT JOIN sys_user j ON a.CREATOR = j.USER_ID
LEFT JOIN sys_user k ON a.OPERATOR = k.USER_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = a.HIGHWORK_ID
WHERE
a.CORPINFO_ID IN ( '81e73a8e669d4421b5657ed05ace77c9', '90d4973740e94ff6a6382dcc709e98cb', 'bebfd3ee740a4abd9e78f9d94a85871d' )
AND a.ISDELETE = '0' and log.NEXT_STEP_ID = '99' and a.STEP_ID != -1
</select>
<select id="getHotWorkData" parameterType="com.zcloud.modules.sys.entity.PageData" resultType="com.zcloud.modules.sys.entity.PageData">
SELECT
f.HOTWORK_ID AS id,
ci.companyCode AS companyCode,
f.CHECK_NO AS ticketNo,
'' AS ticketStatus,
DATE_FORMAT(f.CREATTIME, '%Y%m%d%H%i%s') as issueTime,
DATE_FORMAT(f.WORK_START_DATE, '%Y%m%d%H%i%s') as planStartTime,
DATE_FORMAT(f.WORK_END_DATE, '%Y%m%d%H%i%s') as planEndTime,
DATE_FORMAT(f.WORK_START_DATE, '%Y%m%d%H%i%s') as startTime,
DATE_FORMAT(f.WORK_END_DATE, '%Y%m%d%H%i%s') as endTime,
f.WORK_PLACE AS ticketPosition,
'' AS workAreaCode,
f.WORK_CONTENT AS ticketContent,
f.ACCEPT_TIME AS checkedTime,
cp.`NAME` AS checkedPerson,
ci.LATITUDE AS latitude,
ci.LONGITUDE AS longitude,
guau.`NAME` AS supervisorName,
appu.`NAME` AS workerName,
appo.`NAME` AS workDeptment,
'' AS isContractorWork,
'' AS contractorOrg,
'0' AS isAssociation,
'' AS associationTicket,
f.RISK_IDENTIFICATION AS riskIdentification,
aq.`NAME` AS disclosePerson,
js.`NAME` AS acceptPerson,
confu.`NAME` AS tickerResponsName,
confu.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'0' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS gasAnalysis,
'' AS commitmentLetter,
'' AS fireLocation,
f.WORK_LEVEL AS fireLevel,
f.WORK_USER AS firePerson,
f.WORK_FUNCTION AS fireStyle,
'0' AS deleted,
cr.`NAME` AS createBy,
DATE_FORMAT(f.CREATTIME, '%Y%m%d%H%i%s') as createDate,
DATE_FORMAT(f.OPERATTIME, '%Y%m%d%H%i%s') as updateDate,
op.`NAME` AS updateBy,
f.TASK_ID AS TASK_ID,
f.STEP_ID AS STEP_ID,
f.SPECIAL_WORK AS SPECIAL_WORK
FROM
bus_hotwork f
LEFT JOIN sys_user AS appu ON f.APPLY_USER_ID = appu.USER_ID
LEFT JOIN sys_user AS guau ON f.GUARDIAN_USER_ID = guau.USER_ID
LEFT JOIN sys_user AS confu ON f.CONFIRM_USER_ID = confu.USER_ID
LEFT JOIN sys_user AS cp ON f.ACCEPT_USER_ID = cp.USER_ID
LEFT JOIN sys_user AS aq ON f.CONFESS_USER_ID = aq.USER_ID
LEFT JOIN sys_user AS js ON f.ACCEPT_CONFESS_USER_ID = js.USER_ID
LEFT JOIN sys_user AS cr ON f.CREATOR = cr.USER_ID
LEFT JOIN sys_user AS op ON f.CREATOR = op.USER_ID
LEFT JOIN oa_department AS appo ON f.APPLY_DEPARTMENT_ID = appo.DEPARTMENT_ID
LEFT JOIN bus_corp_info AS ci ON f.CORPINFO_ID = ci.CORPINFO_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = f.HOTWORK_ID
WHERE
f.ISDELETE = '0'
AND f.CORPINFO_ID IN ( '81e73a8e669d4421b5657ed05ace77c9', '90d4973740e94ff6a6382dcc709e98cb', 'bebfd3ee740a4abd9e78f9d94a85871d' )
and log.NEXT_STEP_ID = '99' and f.STEP_ID != -1
ORDER BY
f.STEP_ID,
f.CREATTIME DESC;
</select>
<select id="getElectricityData" parameterType="com.zcloud.modules.sys.entity.PageData" resultType="com.zcloud.modules.sys.entity.PageData">
SELECT
a.ELECTRICITY_ID id,
b.companyCode,
a.CHECK_NO AS ticketNo,
'3' AS ticketStatus,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as issueTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as planStartTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as planEndTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as startTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as endTime,
a.WORK_PLACE AS ticketPosition,
'' AS workAreaCode,
a.WORK_CONTENT AS ticketContent,
a.ACCEPT_TIME AS checkedTime,
c.`NAME` AS checkedPerson,
'' AS longitude,
'' AS latitude,
d.`NAME` AS supervisorName,
e.`NAME` AS workerName,
f.`NAME` AS workDeptment,
'' AS isContractorWork,
'' AS contractorOrg,
'0' AS isAssociation,
'' AS associationTicket,
a.RISK_IDENTIFICATION AS riskIdentification,
g.`NAME` AS disclosePerson,
h.`NAME` AS acceptPerson,
i.`NAME` AS tickerResponsName,
i.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'0' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS commitmentLetter,
a.ALLOW_POWER AS powerStrategy,
a.WORK_VOLTAGE AS workVoltage,
a.RATED_POWER AS electricalEquipment,
a.LEADER_CARD_NO AS headCode,
a.CARD_NO AS personCode,
'0' AS deleted,
j.`NAME` AS createBy,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as createDate,
DATE_FORMAT(a.OPERATTIME, '%Y%m%d%H%i%s') as updateDate,
k.`NAME` AS updateBy
FROM
bus_electricity a
LEFT JOIN bus_corp_info b ON b.CORPINFO_ID = a.CORPINFO_ID
LEFT JOIN sys_user c ON a.ACCEPT_USER_ID = c.USER_ID
LEFT JOIN sys_user d ON a.GUARDIAN_USER_ID = d.USER_ID
LEFT JOIN sys_user e ON a.APPLY_USER_ID = e.USER_ID
LEFT JOIN oa_department f ON a.APPLY_DEPARTMENT_ID = f.DEPARTMENT_ID
LEFT JOIN sys_user g ON a.CONFESS_USER_ID = g.USER_ID
LEFT JOIN sys_user h ON a.ACCEPT_CONFESS_USER_ID = h.USER_ID
LEFT JOIN sys_user i ON a.CONFIRM_USER_ID = i.USER_ID
LEFT JOIN sys_user j ON a.CREATOR = j.USER_ID
LEFT JOIN sys_user k ON a.OPERATOR = k.USER_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = a.ELECTRICITY_ID
WHERE
a.ISDELETE = '0'
AND a.CORPINFO_ID IN ( '81e73a8e669d4421b5657ed05ace77c9', '90d4973740e94ff6a6382dcc709e98cb', 'bebfd3ee740a4abd9e78f9d94a85871d' )
and log.NEXT_STEP_ID = '99' and a.STEP_ID != -1
ORDER BY
b.CORP_NAME,
a.CHECK_NO DESC;
</select>
<select id="getBreakgroundData" parameterType="com.zcloud.modules.sys.entity.PageData" resultType="com.zcloud.modules.sys.entity.PageData">
SELECT
a.BREAKGROUND_ID id,
b.companyCode AS companyCode,
a.CHECK_NO AS ticketNo,
'3' AS ticketStatus,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as issueTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as planStartTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as planEndTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as startTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as endTime,
a.WORK_PLACE AS ticketPosition,
'' AS workAreaCode,
a.WORK_CONTENT AS ticketContent,
a.ACCEPT_TIME AS checkedTime,
c.`NAME` AS checkedPerson,
'' AS longitude,
'' AS latitude,
d.`NAME` AS supervisorName,
e.`NAME` AS workerName,
f.`NAME` AS workDeptment,
'' AS isContractorWork,
'' AS contractorOrg,
'0' AS isAssociation,
'' AS associationTicket,
a.RISK_IDENTIFICATION AS riskIdentification,
g.`NAME` AS disclosePerson,
h.`NAME` AS acceptPerson,
i.`NAME` AS tickerResponsName,
i.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'0' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS commitmentLetter,
'0' AS deleted,
j.`NAME` AS createBy,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as createDate,
DATE_FORMAT(a.OPERATTIME, '%Y%m%d%H%i%s') as updateDate,
k.`NAME` AS updateBy
FROM
bus_breakground a
LEFT JOIN bus_corp_info b ON b.CORPINFO_ID = a.CORPINFO_ID
LEFT JOIN sys_user c ON a.ACCEPT_USER_ID = c.USER_ID
LEFT JOIN sys_user d ON a.GUARDIAN_USER_ID = d.USER_ID
LEFT JOIN sys_user e ON a.APPLY_USER_ID = e.USER_ID
LEFT JOIN oa_department f ON a.APPLY_DEPARTMENT_ID = f.DEPARTMENT_ID
LEFT JOIN sys_user g ON a.CONFESS_USER_ID = g.USER_ID
LEFT JOIN sys_user h ON a.ACCEPT_CONFESS_USER_ID = h.USER_ID
LEFT JOIN sys_user i ON a.CONFIRM_USER_ID = i.USER_ID
LEFT JOIN sys_user j ON a.CREATOR = j.USER_ID
LEFT JOIN sys_user k ON a.OPERATOR = k.USER_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = a.BREAKGROUND_ID
WHERE
a.ISDELETE = '0'
AND a.CORPINFO_ID IN ( '81e73a8e669d4421b5657ed05ace77c9', '90d4973740e94ff6a6382dcc709e98cb', 'bebfd3ee740a4abd9e78f9d94a85871d' )
and log.NEXT_STEP_ID = '99' and a.STEP_ID != -1
ORDER BY
b.CORP_NAME,
a.CHECK_NO
DESC;
</select>
<select id="getCutroadData" >
SELECT
a.CUTROAD_ID AS id,
b.companyCode,
a.CHECK_NO AS ticketNo,
'3' AS ticketStatus,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as issueTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as planStartTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as planEndTime,
DATE_FORMAT(a.WORK_START_DATE, '%Y%m%d%H%i%s') as startTime,
DATE_FORMAT(a.WORK_END_DATE, '%Y%m%d%H%i%s') as endTime,
a.PLS_NAME AS ticketPosition,
'' AS workAreaCode,
a.WORK_CONTENT AS ticketContent,
a.ACCEPT_TIME AS checkedTime,
c.`NAME` AS checkedPerson,
'' AS longitude,
'' AS latitude,
d.`NAME` AS supervisorName,
e.`NAME` AS workerName,
f.`NAME` AS workDeptment,
'' AS isContractorWork,
'' AS contractorOrg,
'0' AS isAssociation,
'' AS associationTicket,
a.RISK_IDENTIFICATION AS riskIdentification,
g.`NAME` AS disclosePerson,
h.`NAME` AS acceptPerson,
i.`NAME` AS tickerResponsName,
i.USERNAME AS majorPersonMobile,
'0' AS isChanged,
'' AS changedCause,
'0' AS isCancelled,
'' AS cancelledCause,
'' AS mobileDeviceCode,
'' AS workTicketAtt,
'' AS safeDiscloseAtt,
'' AS countersignImg,
'' AS commitmentLetter,
a.WORK_REASON AS breakReason,
'' as involveUnit,
'0' AS deleted,
j.`NAME` AS createBy,
DATE_FORMAT(a.CREATTIME, '%Y%m%d%H%i%s') as createDate,
DATE_FORMAT(a.OPERATTIME, '%Y%m%d%H%i%s') as updateDate,
k.`NAME` AS updateBy
FROM
bus_cutroad a
LEFT JOIN bus_corp_info b ON b.CORPINFO_ID = a.CORPINFO_ID
LEFT JOIN sys_user c ON a.ACCEPT_USER_ID = c.USER_ID
LEFT JOIN sys_user d ON a.GUARDIAN_USER_ID = d.USER_ID
LEFT JOIN sys_user e ON a.APPLY_USER_ID = e.USER_ID
LEFT JOIN oa_department f ON a.APPLY_DEPARTMENT_ID = f.DEPARTMENT_ID
LEFT JOIN sys_user g ON a.CONFESS_USER_ID = g.USER_ID
LEFT JOIN sys_user h ON a.ACCEPT_CONFESS_USER_ID = h.USER_ID
LEFT JOIN sys_user i ON a.CONFIRM_USER_ID = i.USER_ID
LEFT JOIN sys_user j ON a.CREATOR = j.USER_ID
LEFT JOIN sys_user k ON a.OPERATOR = k.USER_ID
left join ( SELECT *
FROM
( SELECT *, row_number ( ) over ( PARTITION BY WORK_ID ORDER BY ACT_TIME DESC ) AS rn FROM vi_eightwork_flow_log ) pca
WHERE
pca.rn = 1) log on log.WORK_ID = a.CUTROAD_ID
WHERE a.ISDELETE = '0' AND
a.CORPINFO_ID IN (
'81e73a8e669d4421b5657ed05ace77c9',
'90d4973740e94ff6a6382dcc709e98cb',
'bebfd3ee740a4abd9e78f9d94a85871d'
)
and log.NEXT_STEP_ID = '99' and a.STEP_ID != -1
</select>
</mapper>

View File

@ -0,0 +1,65 @@
package temp;
import com.alibaba.fastjson.JSONObject;
import com.zcloud.MainApplication;
import com.zcloud.modules.data.dto.baotou.ty.TyEncryptionDto;
import com.zcloud.modules.data.service.temp.TempPushDataService;
import com.zcloud.modules.data.thirdservice.baotou.ty.TyReportUtilService;
import com.zcloud.modules.sys.entity.PageData;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import java.util.List;
import java.util.Map;
@SpringBootTest(classes = MainApplication.class)
@ActiveProfiles("temp")
public class TempPushDataTest {
@Autowired
private TempPushDataService tempPushDataService;
@Autowired
private TyReportUtilService tyReportUtilService;
@Test
void demo() {
// 测试Spring上下文加载
List<PageData> pageData = tempPushDataService.pushConfinedSpaceData();
pageData.forEach(info->{
if("SX2024072701".equals(info.get("ticketNo"))){
info.put("longitude", "110.6373659090688");
info.put("latitude", "40.5136337373363");
}
String companyCode="91150221561240426H";
TyEncryptionDto configurationDto = new TyEncryptionDto();
// configurationDto.setUrl("https://syncdata.park.tuyou.hgyq365.cn:8898");
configurationDto.setUrl("https://syncdata.park.tuyou.hgyq365.cn:8898/api/sync/local/list/t_enterprise_area");
configurationDto.setCode("40426H");
configurationDto.setCompanyCode(companyCode);
JSONObject resEnterpriseData = tyReportUtilService.pushEnterpriseArea(configurationDto);
System.out.println(resEnterpriseData);
Map<String,Object> enterpriseData = (Map<String, Object>) resEnterpriseData.get("data");
List<Map<String, Object>> enterpriseRegion = (List<Map<String, Object>>) enterpriseData.get("list");
// List<Map<String, Object>> corpEnterpriseRegion = enterpriseRegion.stream().filter(map -> map.get("enterprise_name").equals(dataJob.getString("CORP_NAME"))).collect(Collectors.toList());
System.out.println(enterpriseRegion);
// Integer status = tyReportUtilService.pushData(info, TyReportV16Enum.secSpecialJobTicketSpace, new BusLogInfoYearEntity(), configurationDto);
});
}
}