docking
/
docking
9
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加对接枚举

liujun-yunwei
zhaokai 2025-07-05 17:59:47 +08:00
parent 65aeab91f6
commit cbac164b95
64 changed files with 1997 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/zcloud/modules/data/aop/AesEncryptionUtil.java
View File

@ -1,7 +1,5 @@
package com.zcloud.modules.data.aop;
import com.alibaba.fastjson.JSONObject;
import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;
import java.nio.charset.StandardCharsets;
@ -40,4 +38,16 @@ public class AesEncryptionUtil {
byte[] decrypted = cipher.doFinal(decodedBytes);
return new String(decrypted, StandardCharsets.UTF_8);
}
public static void main(String[] args) throws Exception {
String s = "{'demo':'demo222','name':'zhaoaa'}";
String encrypt = encrypt(SECRET_KEY, s);
System.out.println("加密"+encrypt);
String decrypt = decrypt(encrypt);
System.out.println("解密"+decrypt);
}
}

90
src/main/java/com/zcloud/modules/data/aop/AesEncryptionUtilss.java Normal file
View File

@ -0,0 +1,90 @@
package com.zcloud.modules.data.aop;
import javax.crypto.Cipher;
import javax.crypto.KeyGenerator;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import java.nio.charset.StandardCharsets;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.util.Base64;
public class AesEncryptionUtilss {
private static final String ALGORITHM = "AES";
private static final String TRANSFORMATION = "AES/ECB/PKCS5Padding";
private static final int KEY_SIZE = 128; // 可以选择 128, 192 或 256
/**
* 自动生成 AES 密钥
* @return 返回 Base64 编码的密钥字符串
*/
public static String generateAesKey() {
try {
KeyGenerator keyGen = KeyGenerator.getInstance(ALGORITHM);
keyGen.init(KEY_SIZE, new SecureRandom());
SecretKey secretKey = keyGen.generateKey();
String s = new String(secretKey.getEncoded());
return Base64.getEncoder().encodeToString(secretKey.getEncoded());
} catch (NoSuchAlgorithmException e) {
throw new RuntimeException("Failed to generate AES key", e);
}
}
/**
* AES 加密
* @param plainText 明文
* @param base64Key Base64 编码的密钥
* @return Base64 编码的加密结果
*/
public static String encrypt(String plainText, String base64Key) {
try {
byte[] decodedKey = Base64.getDecoder().decode(base64Key);
SecretKeySpec secretKey = new SecretKeySpec(decodedKey, ALGORITHM);
Cipher cipher = Cipher.getInstance(TRANSFORMATION);
cipher.init(Cipher.ENCRYPT_MODE, secretKey);
byte[] encryptedBytes = cipher.doFinal(plainText.getBytes(StandardCharsets.UTF_8));
return Base64.getEncoder().encodeToString(encryptedBytes);
} catch (Exception e) {
throw new RuntimeException("AES encryption failed", e);
}
}
/**
* AES 解密
* @param encryptedText Base64 编码的加密文本
* @param base64Key Base64 编码的密钥
* @return 解密后的明文
*/
public static String decrypt(String encryptedText, String base64Key) {
try {
byte[] decodedKey = Base64.getDecoder().decode(base64Key);
SecretKeySpec secretKey = new SecretKeySpec(decodedKey, ALGORITHM);
Cipher cipher = Cipher.getInstance(TRANSFORMATION);
cipher.init(Cipher.DECRYPT_MODE, secretKey);
byte[] encryptedBytes = Base64.getDecoder().decode(encryptedText);
byte[] decryptedBytes = cipher.doFinal(encryptedBytes);
return new String(decryptedBytes, StandardCharsets.UTF_8);
} catch (Exception e) {
throw new RuntimeException("AES decryption failed", e);
}
}
public static void main(String[] args) {
// 1. 生成密钥
String secretKey = generateAesKey();
System.out.println("Generated AES Key: " + secretKey);
// 2. 加密示例
String originalText = "Hello, AES Encryption!";
String encryptedText = encrypt(originalText, secretKey);
System.out.println("Encrypted Text: " + encryptedText);
// 3. 解密示例
String decryptedText = decrypt(encryptedText, secretKey);
System.out.println("Decrypted Text: " + decryptedText);
}
}

7
src/main/java/com/zcloud/modules/data/aop/EncryptionAspect.java
View File

@ -3,11 +3,14 @@ package com.zcloud.modules.data.aop;
import com.alibaba.fastjson.JSONObject;
import com.zcloud.common.utils.R;
import com.zcloud.modules.data.dto.system.EncryptionReqDto;
import com.zcloud.modules.data.entity.LogInfoYearEntity;
import com.zcloud.modules.data.service.LogInfoYearService;
import lombok.extern.java.Log;
import org.apache.commons.lang.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@ -23,6 +26,9 @@ import java.util.stream.Collectors;
@Log
public class EncryptionAspect {
@Autowired
private LogInfoYearService logInfoYearService;
@Around("@annotation(EncryptionMapping)")
public Object decryptAround(ProceedingJoinPoint joinPoint) throws Throwable {
Object[] args = joinPoint.getArgs();
@ -47,6 +53,7 @@ public class EncryptionAspect {
if (StringUtils.isEmpty(reqDto.getData())) {
return R.error("系统异常：2000");
}
LogInfoYearEntity byId = logInfoYearService.getById(1);
// 解密请求参数
String decryptedData = AesEncryptionUtil.decrypt(reqDto.getData());
// 替换原始参数为解密后的数据

15
src/main/java/com/zcloud/modules/data/dao/business/BusDataRiskEventsDao.java Normal file
View File

@ -0,0 +1,15 @@
package com.zcloud.modules.data.dao.business;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zcloud.modules.data.entity.business.BusDataRiskEventsEntity;
/**
* 上报安全风险事件数据表(BusDataRiskEvents)表数据库访问层
*
* @author zhaokai
* @since 2025-07-04 18:28:56
*/
public interface BusDataRiskEventsDao extends BaseMapper<BusDataRiskEventsEntity> {
}

78
src/main/java/com/zcloud/modules/data/entity/business/BusDataRiskEventsEntity.java Normal file
View File

@ -0,0 +1,78 @@
package com.zcloud.modules.data.entity.business;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import io.swagger.annotations.ApiModelProperty;
/**
* 上报安全风险事件数据表(BusDataRiskEvents)表实体类
*
* @author zhaokai
* @since 2025-07-04 18:28:56
*/
@SuppressWarnings("serial")
@Data
@TableName("bus_data_risk_events")
public class BusDataRiskEventsEntity extends Model<BusDataRiskEventsEntity> {
@ApiModelProperty(value = "UUID主键")
private String id;
@ApiModelProperty(value = "三方平台id")
private Long thirdPlatformId;
@ApiModelProperty(value = "服务平台id")
private Long servicePlatformId;
@ApiModelProperty(value = "推送状态(1.未推送,2.推送成功,3.重试中,4.推送失败)")
private Integer pushStatus;
@ApiModelProperty(value = "企业编码,危化品登记平台登记 的 9 位企业编码")
private String companyCode;
@ApiModelProperty(value = "风险分析单元 ID")
private String riskUnitId;
@ApiModelProperty(value = "风险事件名称")
private String riskEventName;
@ApiModelProperty(value = "风险事件内容")
private String riskEventContent;
@ApiModelProperty(value = "风险事件因素")
private String riskEventFactor;
@ApiModelProperty(value = "可能发生的事故")
private String possibleAccident;
@ApiModelProperty(value = "影响范围")
private String affectRange;
@ApiModelProperty(value = "潜在的后果")
private String affectResult;
@ApiModelProperty(value = "责任部门")
private String riskEventDep;
@ApiModelProperty(value = "责任人姓名")
private String riskEventPerson;
@ApiModelProperty(value = "创建时间,时间格式 yyyyMMddHHmmss")
private String createDate;
@ApiModelProperty(value = "创建人")
private String createBy;
@ApiModelProperty(value = "修改时间,时间格式 yyyyMMddHHmmss")
private String updateDate;
@ApiModelProperty(value = "更新人")
private String updateBy;
@ApiModelProperty(value = "删除状态,正常：0；已删除：1")
private Integer isDelete;
}

8
src/main/java/com/zcloud/modules/data/entity/ty/TyHiddenDangerInfoEntity.java
View File

@ -88,7 +88,13 @@ public class TyHiddenDangerInfoEntity extends Model<TyHiddenDangerInfoEntity> {
@ApiModelProperty(value = "隐患状态,参考枚举TyDangerStatusEnum")
private String dangerState;
@ApiModelProperty(value = "隐患照片")
private String dangerImg;
@ApiModelProperty(value = "整改后照片")
private String dangerAcceptImg;
@ApiModelProperty(value = "删除状态,参考枚举TyDeleteStatusEnum,正常:0;已删除:1")
private String deleted;

22
src/main/java/com/zcloud/modules/data/enums/baotou/ty/enums/TyCheckCycleUnitEnum.java Normal file
View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.enums.baotou.ty.enums;
import lombok.Getter;
/**
* 字段：巡检周期单位。 checkCycleUnit
*/
@Getter
public enum TyCheckCycleUnitEnum {
HOUR("小时", "小时"),
DAY("天", "天"),
MONTH("月", "月"),
YEAR("年", "年"),
;
private final String code;
private final String desc;
TyCheckCycleUnitEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

3
src/main/java/com/zcloud/modules/data/enums/baotou/ty/enums/TyClassify2Enum.java
View File

@ -14,12 +14,15 @@ public enum TyClassify2Enum {
CLASSIFY2THREE("1-3", "安全附件"),
CLASSIFY2FOUR("1-4", "安全仪表"),
CLASSIFY2FIVE("1-5", "其他"),
CLASSIFY2SIX("2-1", "动设备"),
CLASSIFY2SEVEN("2-2", "静设备"),
CLASSIFY2EIGHT("2-3", "其他"),
CLASSIFY2NINE("3-1", "人员资质"),
CLASSIFY2TEN("3-2", "操作记录"),
CLASSIFY2ELEVEN("3-3", "其他"),
CLASSIFY2TWELVE("4-1", "应急设施"),
CLASSIFY2THIRTEEN("4-2", "个体防护"),
CLASSIFY2FOURTEEN("4-3", "消防设施"),

8
src/main/java/com/zcloud/modules/data/enums/baotou/ty/enums/TyDangerLevelEnum.java
View File

@ -8,14 +8,14 @@ import lombok.Getter;
*/
@Getter
public enum TyDangerLevelEnum {
LEVEL1(0, "一般隐患"),
LEVEL2(1, "重大隐患"),
LEVEL1("0", "一般隐患"),
LEVEL2("1", "重大隐患"),
;
private final Integer code;
private final String code;
private final String desc;
TyDangerLevelEnum(Integer code, String desc) {
TyDangerLevelEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}

8
src/main/java/com/zcloud/modules/data/enums/baotou/ty/enums/TyDangerManageTypeEnum.java
View File

@ -11,13 +11,13 @@ import lombok.Getter;
@Getter
public enum TyDangerManageTypeEnum {
TYPE1(0, "即查即改"),
TYPE2(1, "限期整改"),
TYPE1("0", "即查即改"),
TYPE2("1", "限期整改"),
;
private final Integer code;
private final String code;
private final String desc;
TyDangerManageTypeEnum(Integer code, String desc) {
TyDangerManageTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}

42
src/main/java/com/zcloud/modules/data/enums/business/BusinessDataTypeEnum.java Normal file
View File

@ -0,0 +1,42 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* business_type 业务类型
*
*/
@Getter
public enum BusinessDataTypeEnum {
bus_data_risk_unit(1,"bus_data_risk_unit", "安全风险分析单元数据"),
bus_data_risk_events(2,"bus_data_risk_events", "安全风险事件数据表"),
bus_data_risk_control_measure(3,"bus_data_risk_control_measure", "安全风险管控措施表"),
bus_data_risk_identification(4,"bus_data_risk_identification", "安全风险管控措施表"),
bus_data_hidden_check_mission(5,"bus_data_hidden_check_mission", "隐患排查任务数据表"),
bus_data_danger_check_record(6,"bus_data_danger_check_record", "隐患排查记录表"),
bus_data_danger_info(7,"bus_data_danger_info", "隐患信息表"),
bus_data_start_stop_work(8,"bus_data_start_stop_work", "开停车数据表"),
bus_data_meanwhile(9,"bus_data_meanwhile", "上报三同数据表"),
bus_data_maintenance(10,"bus_data_maintenance", "上报大检修数据表"),
bus_data_hidden_danger_plan(11,"bus_data_hidden_danger_plan", "隐患排查清单表"),
bus_data_production_promise(12,"bus_data_production_promise", "上报安全承诺数据表"),
bus_data_device_run_status(13,"bus_data_device_run_status", "上报承诺装置运行状态表"),
bus_data_promise_ticket(14,"bus_data_promise_ticket", "上报承诺作业票详情表"),
;
private final Integer id;
private final String code;
private final String desc;
BusinessDataTypeEnum(Integer id,String code, String desc) {
this.code = code;
this.desc = desc;
this.id = id;
}
}

52
src/main/java/com/zcloud/modules/data/enums/business/DataCheckCycleUnitEnum.java Normal file
View File

@ -0,0 +1,52 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyCheckCycleUnitEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjCheckCycleUnitEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* data_hidden_check_mission 字段：巡检周期单位。 checkCycleUnit
* 东江 DjCheckCycleUnitEnum
* 土右 TyCheckCycleUnitEnum
* 河北省 和土右一样
* 内蒙古 和土右一样
*
*/
@Getter
public enum DataCheckCycleUnitEnum {
HOUR("1", "小时", DjCheckCycleUnitEnum.HOUR.getCode(), TyCheckCycleUnitEnum.HOUR.getCode()),
DAY("2", "天", DjCheckCycleUnitEnum.DAY.getCode(), TyCheckCycleUnitEnum.DAY.getCode()),
MONTH("3", "月",DjCheckCycleUnitEnum.MONTH.getCode(), TyCheckCycleUnitEnum.MONTH.getCode()),
YEAR("4", "年",DjCheckCycleUnitEnum.YEAR.getCode(), TyCheckCycleUnitEnum.YEAR.getCode()),
;
private static final Map<String, DataCheckCycleUnitEnum> codeMap = new HashMap<>();
static {
for (DataCheckCycleUnitEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
DataCheckCycleUnitEnum(String code, String desc, String djcode, String tycode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
}
public static DataCheckCycleUnitEnum getByCode(String code) {
return codeMap.get(code);
}
}

43
src/main/java/com/zcloud/modules/data/enums/business/DataCheckLevelEnum.java Normal file
View File

@ -0,0 +1,43 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjCheckLevelEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_hidden_check_mission 字段：巡检级别。 checkLevel
* 东江 DjCheckLevelEnum
*/
@Getter
public enum DataCheckLevelEnum {
ENTERPRISE("1", "企业级", DjCheckLevelEnum.ENTERPRISE.getCode()),
DEPARTMENT("2", "部门级", DjCheckLevelEnum.DEPARTMENT.getCode()),
WORKSHOP("3", "车间级", DjCheckLevelEnum.WORKSHOP.getCode()),
TEAM("4", "班组级", DjCheckLevelEnum.TEAM.getCode()),
POSITION("5", "岗位级", DjCheckLevelEnum.POSITION.getCode()),
;
private static final Map<String, DataCheckLevelEnum> codeMap = new HashMap<>();
static {
for (DataCheckLevelEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
DataCheckLevelEnum(String code, String desc, String djcode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
}
public static DataCheckLevelEnum getByCode(String code) {
return codeMap.get(code);
}
}

23
src/main/java/com/zcloud/modules/data/enums/business/DataCheckRiskLevelEnum.java Normal file
View File

@ -0,0 +1,23 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_danger_check_record 字段：排查风险等级。 checkRiskLevel
* 东江
*/
@Getter
public enum DataCheckRiskLevelEnum {
MAJOR_RISK("1", "重大风险"),
SIGNIFICANT_RISK("2", "较大风险"),
GENERAL_RISK("3", "一般风险"),
LOW_RISK("4", "低风险"),
;
private final String code;
private final String desc;
DataCheckRiskLevelEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

47
src/main/java/com/zcloud/modules/data/enums/business/DataCheckStatusEnum.java Normal file
View File

@ -0,0 +1,47 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyCheckStatusEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjCheckStatusEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_check_record 字段：排查状态。 checkStatus
* 东江 DjCheckStatusEnum
* 土右 TyCheckStatusEnum
*/
@Getter
public enum DataCheckStatusEnum {
NORMAL("1", "正常", DjCheckStatusEnum.NORMAL.getCode(), TyCheckStatusEnum.NORMAL.getCode()),
HIDDEN_DANGERS("2", "存在隐患", DjCheckStatusEnum.HIDDEN_DANGERS.getCode(), TyCheckStatusEnum.HIDDEN_DANGERS.getCode()),
NOT_INVESTIGATED("3", "未排查", DjCheckStatusEnum.NOT_INVESTIGATED.getCode(), TyCheckStatusEnum.NOT_INVESTIGATED.getCode()),
OTHER("4", "其他", DjCheckStatusEnum.OTHER.getCode(), TyCheckStatusEnum.OTHER.getCode()),
;
private static final Map<String, DataCheckStatusEnum> codeMap = new HashMap<>();
static {
for (DataCheckStatusEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
DataCheckStatusEnum(String code, String desc, String djcode, String tycode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
}
public static DataCheckStatusEnum getByCode(String code) {
return codeMap.get(code);
}
}

44
src/main/java/com/zcloud/modules/data/enums/business/DataCheckTaskTypeEnum.java Normal file
View File

@ -0,0 +1,44 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjCheckTaskTypeEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_hidden_check_mission 字段：巡检任务类型。 checkTaskType
* 东江 DjCheckTaskTypeEnum
*
*/
@Getter
public enum DataCheckTaskTypeEnum {
PERSONAL("1", "个人任务", DjCheckTaskTypeEnum.PERSONAL.getCode()),
DEPARTMENT("2", "部门任务", DjCheckTaskTypeEnum.DEPARTMENT.getCode()),
GROUP("3", "群组任务", DjCheckTaskTypeEnum.GROUP.getCode()),
ALL("4", "全员任务", DjCheckTaskTypeEnum.ALL.getCode()),
;
private static final Map<String, DataCheckTaskTypeEnum> codeMap = new HashMap<>();
static {
for (DataCheckTaskTypeEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
DataCheckTaskTypeEnum(String code, String desc, String djcode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
}
public static DataCheckTaskTypeEnum getByCode(String code) {
return codeMap.get(code);
}
}

30
src/main/java/com/zcloud/modules/data/enums/business/DataCheckTypeEnum.java Normal file
View File

@ -0,0 +1,30 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_danger_check_record 字段：检查类型。 checkType
* 东胜
*/
@Getter
public enum DataCheckTypeEnum {
SRC1("1", "日常排查"),
SRC2("2", "综合性排查"),
SRC3("3", "专业性排查"),
SRC4("4", "季节性排查"),
SRC5("5", "重点时段及节假日前排查"),
SRC6("6", "事故类比排查"),
SRC7("7", "复产复工前排查"),
SRC8("8", "外聘专家诊断式排查"),
SRC9("9", "管控措施实效"),
SRC10("10", "其他"),
SRC11("11", "执法检查");
;
private final String code;
private final String desc;
DataCheckTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

52
src/main/java/com/zcloud/modules/data/enums/business/DataClassify1Enum.java Normal file
View File

@ -0,0 +1,52 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyClassify1Enum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjClassify1Enum;
import com.zcloud.modules.data.enums.tangshan.ds.enums.DsClassify1Enum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_risk_control_measure表中 字段：管控措施分类1。 classify1
* 参照枚举 DjClassify1Enum
* 参考枚举TyClassify1Enum
* 唐山东胜的枚举 DsClassify1Enum
* 河北省
* 内蒙古
*/
@Getter
public enum DataClassify1Enum {
ENGINEERING("1", "工程技术", DjClassify1Enum.ENGINEERING.getCode(), TyClassify1Enum.CLASSIFY1ONE.getCode(), DsClassify1Enum.ENGINEERING.getCode()),
MAINTENANCE("2", "维护保养",DjClassify1Enum.MAINTENANCE.getCode(), TyClassify1Enum.CLASSIFY1TWO.getCode(), DsClassify1Enum.MAINTENANCE.getCode()),
OPERATIONAL("3", "操作行为",DjClassify1Enum.OPERATIONAL.getCode(), TyClassify1Enum.CLASSIFY1THREE.getCode(), DsClassify1Enum.OPERATE.getCode()),
EMERGENCY("4", "应急措施",DjClassify1Enum.EMERGENCY.getCode(), TyClassify1Enum.CLASSIFY1FOUR.getCode(), DsClassify1Enum.EMERGENCY.getCode()),
;
private static final Map<String, DataClassify1Enum> codeMap = new HashMap<>();
static {
for (DataClassify1Enum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
private final String dscode;
DataClassify1Enum(String code, String desc, String djcode, String tycode, String dscode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
this.dscode = dscode;
}
public static DataClassify1Enum getByCode(String code) {
return codeMap.get(code);
}
}

72
src/main/java/com/zcloud/modules/data/enums/business/DataClassify2Enum.java Normal file
View File

@ -0,0 +1,72 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyClassify2Enum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjClassify2Enum;
import com.zcloud.modules.data.enums.tangshan.ds.enums.DsClassify2Enum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_risk_control_measure表中 字段：管控措施分类2。 classify2
* 参照枚举 DjClassify2Enum
* 参考枚举 TyClassify2Enum 有差别
* 唐山东胜的枚举 DsClassify2Enum
* 还差河北省平台和内蒙古平台的枚举
*/
@Getter
public enum DataClassify2Enum {
PROCESS("1-1", "工艺控制", DjClassify2Enum.CLASSIFY2ONE.getCode(), TyClassify2Enum.CLASSIFY2ONE.getCode(), DsClassify2Enum.PROCESS.getCode()),
KEY_EQUIPMENT("1-2", "关键设备/部件", DjClassify2Enum.CLASSIFY2TWO.getCode(), TyClassify2Enum.CLASSIFY2TWO.getCode(), DsClassify2Enum.KEY_EQUIPMENT.getCode()),
ATTACHMENTS("1-3", "安全附件",DjClassify2Enum.CLASSIFY2THREE.getCode(), TyClassify2Enum.CLASSIFY2THREE.getCode(), DsClassify2Enum.ATTACHMENTS.getCode()),
INSTRUMENT("1-4", "安全仪表",DjClassify2Enum.CLASSIFY2FOUR.getCode(), TyClassify2Enum.CLASSIFY2FOUR.getCode(), DsClassify2Enum.INSTRUMENT.getCode()),
OTHER1("1-5", "其它", DjClassify2Enum.CLASSIFY2FIVE.getCode(), TyClassify2Enum.CLASSIFY2FIVE.getCode(), DsClassify2Enum.OTHER1.getCode()),
ACTIVE_DEVICE("2-1", "动设备",DjClassify2Enum.CLASSIFY2SIX.getCode(), TyClassify2Enum.CLASSIFY2SIX.getCode(), DsClassify2Enum.ACTIVE_DEVICE.getCode()),
static_DEVICE("2-2", "静设备",DjClassify2Enum.CLASSIFY2SEVEN.getCode(), TyClassify2Enum.CLASSIFY2SEVEN.getCode(), DsClassify2Enum.static_DEVICE.getCode()),
OTHER2("2-3", "其它",DjClassify2Enum.CLASSIFY2EIGHT.getCode(), TyClassify2Enum.CLASSIFY2EIGHT.getCode(), DsClassify2Enum.OTHER2.getCode()),
QUALIFICATIONS("3-1", "人员资质",DjClassify2Enum.CLASSIFY2NINE.getCode(), TyClassify2Enum.CLASSIFY2NINE.getCode(), DsClassify2Enum.QUALIFICATIONS.getCode()),
RECORD("3-2", "操作记录",DjClassify2Enum.CLASSIFY2TEN.getCode(), TyClassify2Enum.CLASSIFY2TEN.getCode(), DsClassify2Enum.RECORD.getCode()),
CHANGE_SHIFTS("3-3", "交接班",null, null, DsClassify2Enum.CHANGE_SHIFTS.getCode()),
OTHER3("3-4", "其它",DjClassify2Enum.CLASSIFY2ELEVEN.getCode(), TyClassify2Enum.CLASSIFY2ELEVEN.getCode(), DsClassify2Enum.OTHER3.getCode()),
EMERGENCY_FACILITIES("4-1", "应急设施",DjClassify2Enum.CLASSIFY2TWELVE.getCode(), TyClassify2Enum.CLASSIFY2TWELVE.getCode(), DsClassify2Enum.EMERGENCY_FACILITIES.getCode()),
PROTECTION("4-2", "个体防护",DjClassify2Enum.CLASSIFY2THIRTEEN.getCode(), TyClassify2Enum.CLASSIFY2THIRTEEN.getCode(), DsClassify2Enum.PROTECTION.getCode()),
FIRE_FIGHTING("4-3", "消防设施",DjClassify2Enum.CLASSIFY2FOURTEEN.getCode(), TyClassify2Enum.CLASSIFY2FOURTEEN.getCode(), DsClassify2Enum.FIRE_FIGHTING.getCode()),
EMERGENCY_PLAN("4-4", "应急预案",DjClassify2Enum.CLASSIFY2FIFTEEN.getCode(), TyClassify2Enum.CLASSIFY2FIFTEEN.getCode(), DsClassify2Enum.EMERGENCY_PLAN.getCode()),
OTHER("4-5", "其它",DjClassify2Enum.CLASSIFY2SIXTEEN.getDesc(), TyClassify2Enum.CLASSIFY2SIXTEEN.getDesc(), DsClassify2Enum.OTHER.getCode());
private static final Map<String, DataClassify2Enum> codeMap = new HashMap<>();
static {
for (DataClassify2Enum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djCode;
private final String tyCode;
private final String dsCode;
// private final String hebeiCode;
// private final String neimengguCode;
DataClassify2Enum(String code, String desc, String djCode, String tyCode, String dsCode) {
this.code = code;
this.desc = desc;
this.djCode = djCode;
this.tyCode = tyCode;
this.dsCode = dsCode;
// this.hebeiCode = hebeiCode;
// this.neimengguCode = neimengguCode;
}
public static DataClassify2Enum getByCode(String code) {
return codeMap.get(code);
}
}

27
src/main/java/com/zcloud/modules/data/enums/business/DataCronEnum.java Normal file
View File

@ -0,0 +1,27 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_hidden_danger_plan 字段：排查频率。 cron
* 东胜
*/
@Getter
public enum DataCronEnum {
HOURLY("HOURLY", "每小时"),
DAILY("DAILY", "每天"),
WEEKLY("WEEKLY", "每周"),
MONTHLY("MONTHLY", "每月"),
QUARTERLY("QUARTERLY", "每季度"),
SEMIYEARLY("SEMIYEARLY", "每半年"),
ANNUALLY("ANNUALLY", "每年");
private final String code;
private final String desc;
DataCronEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

47
src/main/java/com/zcloud/modules/data/enums/business/DataDangerLevelEnum.java Normal file
View File

@ -0,0 +1,47 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyDangerLevelEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjDangerLevelEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_info 字段：隐患等级。 dangerLevel
* 东江 DjDangerLevelEnum
* 土右 TyDangerLevelEnum
* 河北省 和土右一样
* 内蒙古 和土右一样
*/
@Getter
public enum DataDangerLevelEnum {
GENERAL_DANGER("0", "一般隐患", DjDangerLevelEnum.GENERAL_DANGER.getCode(), TyDangerLevelEnum.LEVEL1.getCode()),
MAJOR_DANGER("1", "重大隐患", DjDangerLevelEnum.MAJOR_DANGER.getCode(), TyDangerLevelEnum.LEVEL2.getCode()),
;
private static final Map<String, DataDangerLevelEnum> codeMap = new HashMap<>();
static {
for (DataDangerLevelEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
DataDangerLevelEnum(String code, String desc, String djcode, String tycode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
}
public static DataDangerLevelEnum getByCode(String code) {
return codeMap.get(code);
}
}

48
src/main/java/com/zcloud/modules/data/enums/business/DataDangerManageTypeEnum.java Normal file
View File

@ -0,0 +1,48 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyDangerManageTypeEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjDangerManageTypeEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_info 字段：治理类型。 dangerManageType
* 东江 DjDangerManageTypeEnum
* 土右 TyDangerManageTypeEnum
* 河北省 一样
* 内蒙古 一样
*/
@Getter
public enum DataDangerManageTypeEnum {
TYPE1("0", "即查即改", DjDangerManageTypeEnum.TYPE1.getCode(), TyDangerManageTypeEnum.TYPE1.getCode()),
TYPE2("1", "期限整改",DjDangerManageTypeEnum.TYPE2.getCode(), TyDangerManageTypeEnum.TYPE2.getCode()),
;
private static final Map<String, DataDangerManageTypeEnum> codeMap = new HashMap<>();
static {
for (DataDangerManageTypeEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djCode;
private final String tyCode;
DataDangerManageTypeEnum(String code, String desc, String djCode, String tyCode) {
this.code = code;
this.desc = desc;
this.djCode = djCode;
this.tyCode = tyCode;
}
public static DataDangerManageTypeEnum getByCode(String code) {
return codeMap.get(code);
}
}

49
src/main/java/com/zcloud/modules/data/enums/business/DataDangerSrcEnum.java Normal file
View File

@ -0,0 +1,49 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_info 字段：隐患来源。 dangerSrc
* 东江 一样
* 土右 一样
* 河北省 一样
* 内蒙古 一样
*/
@Getter
public enum DataDangerSrcEnum {
SRC1("1", "日常排查"),
SRC2("2", "综合性排查"),
SRC3("3", "专业性排查"),
SRC4("4", "季节性排查"),
SRC5("5", "重点时段及节假日前排查"),
SRC6("6", "事故类比排查"),
SRC7("7", "复产复工前排查"),
SRC8("8", "外聘专家诊断式排查"),
SRC9("9", "管控措施实效"),
SRC10("10", "其他"),
SRC11("11", "执法检查");
;
private static final Map<String, DataDangerSrcEnum> codeMap = new HashMap<>();
static {
for (DataDangerSrcEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
DataDangerSrcEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
public static DataDangerSrcEnum getByCode(String code) {
return codeMap.get(code);
}
}

43
src/main/java/com/zcloud/modules/data/enums/business/DataDangerStatusEnum.java Normal file
View File

@ -0,0 +1,43 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjDangerStateEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_infoo 字段：隐患状态 dangerState
* 东江 DjDangerStateEnum
* 土右 一样
*/
@Getter
public enum DataDangerStatusEnum {
STATUS0("0", "整改中", DjDangerStateEnum.UNDER_RECTIFICATION.getCode()),
STATUS1("1", "待验收",DjDangerStateEnum.PENDING.getCode()),
STATUS3("9", "已验收",DjDangerStateEnum.ACCEPTED.getCode()),
;
private static final Map<String, DataDangerStatusEnum> codeMap = new HashMap<>();
static {
for (DataDangerStatusEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
DataDangerStatusEnum(String code, String desc, String djcode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
}
public static DataDangerStatusEnum getByCode(String code) {
return codeMap.get(code);
}
}

48
src/main/java/com/zcloud/modules/data/enums/business/DataDataSrcEnum.java Normal file
View File

@ -0,0 +1,48 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyDataSrcEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjDataSrcEnum;
import com.zcloud.modules.data.enums.tangshan.ds.enums.DsDataSrcEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_risk_control_measure表中 字段：管控方式。 dataSrc
* 参照枚举 DjDataSrcEnum
* 参考枚举 TyDataSrcEnum
*/
@Getter
public enum DataDataSrcEnum {
AUTOMATED("1", "自动化监控", DjDataSrcEnum.AUTOMATED.getCode(), TyDataSrcEnum.DATASRC1.getCode(),DsDataSrcEnum.AUTOMATIC.getCode()),
HAZARD_INVESTIGATION("2", "隐患排查",DjDataSrcEnum.HAZARD_INVESTIGATION.getCode(), TyDataSrcEnum.DATASRC2.getCode(),DsDataSrcEnum.HIDDEN_DANGER.getCode()),
OTHER("3", "其他",null, TyDataSrcEnum.DATASRC3.getCode(),null);
;
private static final Map<String, DataDataSrcEnum> codeMap = new HashMap<>();
static {
for (DataDataSrcEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
private final String dscode;
DataDataSrcEnum(String code, String desc, String djcode, String tycode, String dscode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
this.dscode = dscode;
}
public static DataDataSrcEnum getByCode(String code) {
return codeMap.get(code);
}
}

21
src/main/java/com/zcloud/modules/data/enums/business/DataExamineApproveStatusEnum.java Normal file
View File

@ -0,0 +1,21 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
bus_data_meanwhile 表中审批状态
河北省
*/
@Getter
public enum DataExamineApproveStatusEnum {
APPLY("0", "待审批"),
APPROVE("1", "已审批"),
;
private final String code;
private final String desc;
DataExamineApproveStatusEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

45
src/main/java/com/zcloud/modules/data/enums/business/DataHazardCategoryEnum.java Normal file
View File

@ -0,0 +1,45 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjHazardCategoryEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_danger_info 字段：隐患类别。 hazardCategory
* 东江 DjHazardCategoryEnum
* 土右 一样
* 河北省 一样
* 内蒙古 一样
*/
@Getter
public enum DataHazardCategoryEnum {
TYPE0("0", "其他隐患", DjHazardCategoryEnum.TYPE1.getCode()),
TYPE1("1", "主要负责人登记隐患", DjHazardCategoryEnum.TYPE2.getCode()),
TYPE2("2", "技术负责人登记隐患",DjHazardCategoryEnum.TYPE3.getCode()),
TYPE3("3", "操作负责人登记隐患", DjHazardCategoryEnum.TYPE4.getCode()),
;
private static final Map<String, DataHazardCategoryEnum> codeMap = new HashMap<>();
static {
for (DataHazardCategoryEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
DataHazardCategoryEnum(String code, String desc, String djcode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
}
public static DataHazardCategoryEnum getByCode(String code) {
return codeMap.get(code);
}
}

47
src/main/java/com/zcloud/modules/data/enums/business/DataHazardDangerTypeEnum.java Normal file
View File

@ -0,0 +1,47 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
*bus_data_danger_info 字段：隐患类型。 hazardDangerType
* 东江 一样
* 土右 一样
* 河北省
* 内蒙古
*/
@Getter
public enum DataHazardDangerTypeEnum {
TYPE1("1", "安全"),
TYPE2("2", "工艺"),
TYPE3("3", "电气"),
TYPE4("4", "仪表"),
TYPE5("5", "消防"),
TYPE6("6", "总图"),
TYPE7("7", "设备"),
TYPE8("8", "其他"),
;
private static final Map<String, DataHazardDangerTypeEnum> codeMap = new HashMap<>();
static {
for (DataHazardDangerTypeEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
DataHazardDangerTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
public static DataHazardDangerTypeEnum getByCode(String code) {
return codeMap.get(code);
}
}

27
src/main/java/com/zcloud/modules/data/enums/business/DataHazardRankEnum.java Normal file
View File

@ -0,0 +1,27 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_risk_unit 表的字段枚举hazard_rank字段
* 风险分析单元等级
*/
@Getter
public enum DataHazardRankEnum {
ONE("1", "Ⅰ级最高"),
TWO("2", "Ⅱ级"),
THREE("3", "Ⅲ级"),
FOUR("4", "Ⅳ级最低"),
;
private final String code;
private final String desc;
DataHazardRankEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

23
src/main/java/com/zcloud/modules/data/enums/business/DataHazardTypeEnum.java Normal file
View File

@ -0,0 +1,23 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_risk_unit 字段：风险分析单元分类。 hazardType
* 唐山东江
*/
@Getter
public enum DataHazardTypeEnum {
ACTIVITIES("1", "作业活动"),
WORKPLACE("2", "作业场所"),
EQUIPMENT("3", "设备"),
OTHERS("4", "其他"),
;
private final String code;
private final String desc;
DataHazardTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

20
src/main/java/com/zcloud/modules/data/enums/business/DataIsCommonStatusEnum.java Normal file
View File

@ -0,0 +1,20 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* 公共状态 0:否 1:是
*/
@Getter
public enum DataIsCommonStatusEnum {
NO("0", "否"),
YES("1", "是");
private final String code;
private final String desc;
DataIsCommonStatusEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

24
src/main/java/com/zcloud/modules/data/enums/business/DataIsDefendEnum.java Normal file
View File

@ -0,0 +1,24 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_danger_check_record 字段：是否包保责任人任务。 isDefend
* 东江
* 土右
* 河北省
* 内蒙古省
*/
@Getter
public enum DataIsDefendEnum {
NO("0", "否"),
YES("1", "是"),
;
private final String code;
private final String desc;
DataIsDefendEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

20
src/main/java/com/zcloud/modules/data/enums/business/DataIsDeleteEnum.java Normal file
View File

@ -0,0 +1,20 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* 删除公共状态 0-未删除 1-已删除
*/
@Getter
public enum DataIsDeleteEnum {
NO("0", "否"),
YES("1", "是");
private final String code;
private final String desc;
DataIsDeleteEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

21
src/main/java/com/zcloud/modules/data/enums/business/DataIsHazardEnum.java Normal file
View File

@ -0,0 +1,21 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_risk_unit表：是否为风险分析对象。 IsHazard
* 唐山东江，
*/
@Getter
public enum DataIsHazardEnum {
NO("0", "否"),
YES("1", "是");
;
private final String code;
private final String desc;
DataIsHazardEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

25
src/main/java/com/zcloud/modules/data/enums/business/DataLevelCEnum.java Normal file
View File

@ -0,0 +1,25 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* data_risk_identification 表中 LEC评级的C项对应ID
*/
@Getter
public enum DataLevelCEnum {
leve1("1", "完全符合"),
leve2("2", "不符合公司的安全操作程序、规定"),
leve3("3", "不符合上级或行业的安全方针、制度、规定等"),
leve4("4", "潜在违反法规和标准"),
leve5("5", "违反法律法规和标准"),
leve6("6", "严重违反法律法规和标准"),
;
private final String code;
private final String desc;
DataLevelCEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

24
src/main/java/com/zcloud/modules/data/enums/business/DataLevelEEnum.java Normal file
View File

@ -0,0 +1,24 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* data_risk_identification 表中 LEC评级的E项对应ID
*/
@Getter
public enum DataLevelEEnum {
leve1("1", "非常罕见地暴露"),
leve2("2", "每年几次暴露"),
leve3("3", "每月一次暴露"),
leve4("4", "每周一次或偶然暴露"),
leve5("5", "每天工作时间内暴露"),
leve6("6", "连续暴露"),
;
private final String code;
private final String desc;
DataLevelEEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

25
src/main/java/com/zcloud/modules/data/enums/business/DataLevelLEnum.java Normal file
View File

@ -0,0 +1,25 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* data_risk_identification 中 LEC评级的C项对应ID
*/
@Getter
public enum DataLevelLEnum {
level1("1", "实际不可能"),
level2("2", "极不可能；有充分、有效的防范、控制、监测、保护措施；或员工安全卫生意识相当高，严格执行操作规程"),
level3("3", "很不可能，可以设想；危害一旦发生能及时发现，并能定期进行监测。"),
level4("4", "可能性小，完全意外；或危害的发生容易被发现；现场有监测系统或曾经作过监测；或过去曾经发生类似事故、事件或偏差；或在异常情况下发生过类似事故、事件或偏差"),
level5("5", "可能，但不经常；或危害的发生不容易被发现；现场没有检测系统或保护措施（如没有保护装置、没有个人防护用品等），也未作过任何监测；或未严格按操作规程执行；或在现场有控制措施，但未有效执行或控制措施不当；或危害在预期情况下发生"),
level6("6", "相当可能；或危害的发生不能被发现（没有监测系统）；或在现场没有采取防范、监测、保护、控制措施；或在正常情况下经常发生此类事故、事件或偏差"),
level7("7", "完全可以预料"),
;
private final String code;
private final String desc;
DataLevelLEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

20
src/main/java/com/zcloud/modules/data/enums/business/DataOperation2StatusEnum.java Normal file
View File

@ -0,0 +1,20 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_maintenance 表中 operation_status
*/
@Getter
public enum DataOperation2StatusEnum {
statusOne(1, "进行中"),
statusTwo(2, "已完成");
private final Integer code;
private final String desc;
DataOperation2StatusEnum(Integer code, String desc) {
this.code = code;
this.desc = desc;
}
}

21
src/main/java/com/zcloud/modules/data/enums/business/DataOperationStatusEnum.java Normal file
View File

@ -0,0 +1,21 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_start_stop_work表中operation_status
*/
@Getter
public enum DataOperationStatusEnum {
IN_PROCESS(1, "改成进程中"),
SUCCESS(2, "已完成成功"),
FAIL(3, "已完成失败");
private final Integer code;
private final String desc;
DataOperationStatusEnum(Integer code, String desc) {
this.code = code;
this.desc = desc;
}
}

26
src/main/java/com/zcloud/modules/data/enums/business/DataOrgLevelEnum.java Normal file
View File

@ -0,0 +1,26 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_danger_check_record orgLevel
* 东胜
*/
@Getter
public enum DataOrgLevelEnum {
REGULATORY(1, "监管级"),
EXPERT(2, "专家级"),
COMPANY(3, "公司级"),
WORKSHOP(4, "车间级"),
GROUP(5, "班组级"),
POST(6, "岗位级");
private final Integer code;
private final String desc;
DataOrgLevelEnum(Integer code, String desc) {
this.code = code;
this.desc = desc;
}
}

22
src/main/java/com/zcloud/modules/data/enums/business/DataPlanTypeEnum.java Normal file
View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_hidden_danger_plan plan_type 清单类型 0-普通排查计划 1-包保责任人排查计划
* 东胜
*/
@Getter
public enum DataPlanTypeEnum {
ONE(1, "普通排查计划"),
TWO(2, "包保责任人排查计划");
private final Integer code;
private final String desc;
DataPlanTypeEnum(Integer code, String desc) {
this.code = code;
this.desc = desc;
}
}

39
src/main/java/com/zcloud/modules/data/enums/business/DataPushStatusEnum.java Normal file
View File

@ -0,0 +1,39 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* data表中push_status 推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)
*/
@Getter
public enum DataPushStatusEnum {
NOT("1", "未推送"),
SCHEDULED("2", "定时推送"),
SUCCESSFUL("3", "推送成功"),
TRYING_AGAIN("4", "重试中"),
FAILED("5", "推送失败"),
;
private static final Map<String, DataPushStatusEnum> codeMap = new HashMap<>();
static {
for (DataPushStatusEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
DataPushStatusEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
public static DataPushStatusEnum getByCode(String code) {
return codeMap.get(code);
}
}

19
src/main/java/com/zcloud/modules/data/enums/business/DataRatingMethodEnum.java Normal file
View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* data_risk_identification 表：评分方法。 ratingMethod
* 评分方法
*/
@Getter
public enum DataRatingMethodEnum {
LEC("LEC"),
LS("LS");
private final String code;
DataRatingMethodEnum(String code) {
this.code = code;
}
}

39
src/main/java/com/zcloud/modules/data/enums/business/DataReceiveStatusEnum.java Normal file
View File

@ -0,0 +1,39 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* data表中push_status 推送状态(1.未推送,2.定时推送,3.推送成功,4.重试中,5.推送失败)
*/
@Getter
public enum DataReceiveStatusEnum {
NOT("1", "未推送"),
SCHEDULED("2", "定时推送"),
SUCCESSFUL("3", "推送成功"),
TRYING_AGAIN("4", "重试中"),
FAILED("5", "推送失败"),
;
private static final Map<String, DataReceiveStatusEnum> codeMap = new HashMap<>();
static {
for (DataReceiveStatusEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
DataReceiveStatusEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
public static DataReceiveStatusEnum getByCode(String code) {
return codeMap.get(code);
}
}

22
src/main/java/com/zcloud/modules/data/enums/business/DataRiskGradEnum.java Normal file
View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_production_promise字段：风险级别 riskGrade
* 土右
*/
@Getter
public enum DataRiskGradEnum {
HIGH_RISK("1", "高风险"),
MAJOR_RISKS("2", "较大风险"),
GENERAL_RISKS("3", "一般风险"),
LOW_RISK("4", "低风险");
private final String code;
private final String desc;
DataRiskGradEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

27
src/main/java/com/zcloud/modules/data/enums/business/DataRiskLeveEnum.java Normal file
View File

@ -0,0 +1,27 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.tangshan.ds.enums.DsRiskLeveEnum;
import lombok.Getter;
/**
*bus_data_risk_unit 表风险等级，risk_level 0-重大风险,1-较大风险,2-一般风险,3-低风险
* 土右，
* 东胜 DsRiskLeveEnum
*/
@Getter
public enum DataRiskLeveEnum {
MAJOR_RISK("0", "重大风险", DsRiskLeveEnum.MAJOR_RISK.getCode()),
SIGNIFICANT_RISK("1", "较大风险",DsRiskLeveEnum.SIGNIFICANT_RISK.getCode()),
GENERAL_RISK("2", "一般风险",DsRiskLeveEnum.GENERAL_RISK.getCode()),
LOW_RISK("3", "低风险",DsRiskLeveEnum.LOW_RISK.getCode()),
;
private final String code;
private final String desc;
private final String sdCode;
DataRiskLeveEnum(String code, String desc, String sdCode) {
this.code = code;
this.desc = desc;
this.sdCode = sdCode;
}
}

27
src/main/java/com/zcloud/modules/data/enums/business/DataRiskMeasureLevelEnum.java Normal file
View File

@ -0,0 +1,27 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_risk_control_measure 字段：管控级别。 riskMeasureLevel
* 东江
*/
@Getter
public enum DataRiskMeasureLevelEnum {
ENTERPRISE("1", "企业级"),
DEPARTMENT("2", "部门级"),
WORKSHOP("3", "车间级"),
TEAM("4", "班组级"),
POSITION("5", "岗位级"),
MAIN_RESPONSIBLE("6", "主要负责人"),
TECHNICAL("7", "技术负责人"),
OPERATION("8", "操作负责人"),
;
private final String code;
private final String desc;
DataRiskMeasureLevelEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

22
src/main/java/com/zcloud/modules/data/enums/business/DataRunStatusEnum.java Normal file
View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_device_run_status 字段：运行状态 runStatus
* 土右
*/
@Getter
public enum DataRunStatusEnum {
NORMAL("1", "正常生产运行"),
DRIVING("2", "开车"),
PARKING("3", "停车"),
SHUTDOWN("4", "停产停用");
private final String code;
private final String desc;
DataRunStatusEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

19
src/main/java/com/zcloud/modules/data/enums/business/DataStartStopTypeEnum.java Normal file
View File

@ -0,0 +1,19 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_start_stop_work 字段：车辆状态。 startStopType
* 河北省
*/
@Getter
public enum DataStartStopTypeEnum {
start("1", "开车"),
stop("2", "停车");
private final String code;
private final String desc;
DataStartStopTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

57
src/main/java/com/zcloud/modules/data/enums/business/DataTaskNumEnum.java Normal file
View File

@ -0,0 +1,57 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_hidden_check_mission 字段：包保任务对应项。 taskNum
* 东江 DjTaskNumEnum
* 土右 暂无说明
* 河北省 暂无说明
* 内蒙古 暂无说明
*/
@Getter
public enum DataTaskNumEnum {
ONE("1", "2","主要负责人任务","1","核查技术负责人、操作负责人是否按规定时间、规定内容履行职责"),
TWO("2", "2","主要负责人任务","2","确认重大危险源安全管理制度、操作规程是否实用有效，操作员是否按制度和操作规程执行"),
THREE("3", "2","主要负责人任务","3","核查是否存在重大安全隐患，确认各类安全隐患是否及时整改"),
FOUR("4", "2","主要负责人任务","4","核查重大危险源的管理和操作岗位人员数量、学历和资格是否满 足要求，是否进行安全培训，是否具备安全管理、操作和应急方面的能力"),
FIVE("5", "2","主要负责人任务","5","确认有关重大危险源的安全投入是否到位，是否合理有效使用安全费用"),
SIX("6", "2","主要负责人任务","6","确认重大危险源安全监测监控有关数据是否接入危险化学品安全生产风险监测预警系统"),
SEVEN("7", "2","主要负责人任务","7","确认重大危险源现场安全设施是否完好"),
EIGHT("8", "2","主要负责人任务","8","确认重大危险源专项应急预案是否每半年演练一次，是否达到演练效果"),
NINE("9", "2","主要负责人任务","9","核查双重预防机制数字化运行效果是否达到优良等级"),
TEN("10", "3","技术负责人任务","1","现场确认重大危险源温度、压力、液位、流量、组份等信息的不间断采集和监测系统以及可燃气体和有毒有害气体泄漏检测报警装置是否具备信息远传、连续记录、事故预警、信息存储等功能"),
ELEVEN("11", "3","技术负责人任务","2","现场核查重大危险源安全阀、压力表、液位计、可燃有毒气体报警仪、视频监控等是否存在故障、报警等信息，有关设备是否存在超期未检问题"),
TWELVE("12", "3","技术负责人任务","3","确认重大危险源设备设施的设计、制造、安装、使用、检测、维 修、改造和报废，是否符合国家标准或者行业标准"),
THIRTEEN("13", "3","技术负责人任务","4","确认重大危险源与周边安全间距是否符合安全要求。对于超过个人和社会可容许风险值限值标准的重大危险源，组织采取相应的降低风险措施，直至风险满足可容许风险标准要求"),
FOURTEEN("14", "3","技术负责人任务","5","组织审查涉及重大危险源的外来施工单位及人员的相关资质、安全管理等情况"),
FIFTEEN("15", "3","技术负责人任务","6","重大活动、重点时段和节假日前组织进行重大危险源安全风险隐患排查"),
SIXTEEN("16", "3","技术负责人任务","7","现场审查涉及重大危险源的工艺、设备、人员变更方案，确保变更过程风险受控"),
SEVENTEEN("17", "3","技术负责人任务","8","针对重大危险源安全风险隐患排查情况，组织制定管控措施和治理方案并监督落实"),
EIGHTEEN("18", "3","技术负责人任务","9","组织演练重大危险源专项应急预案和现场处置方案"),
NINETEEN("19", "4","操作负责任任务","1","检查岗位操作人员是否严格执行重大危险源安全生产规章制度和操作规程，是否严格遵守劳动纪律"),
TWENTY("20", "4","操作负责任任务","2","检查涉及重大危险源的特殊作业、检维修作业是否按规定办理作业票，监护人是否在场，作业过程有无违章，安全风险是否受控"),
TWENTY_ONE("21", "4","操作负责任任务","3","检查重大危险源安全隐患是否整改到位，装置设备是否存在带“病”运行情形"),
TWENTY_TWO("22", "4","操作负责任任务","4","检查涉及重大危险源的外来施工单位及人员有无违章行为"),
TWENTY_THREE("23", "4","操作负责任任务","5","检查重大危险源的设备设施 (包括动静设备、自控系统、安全设 施等)是否完好"),
TWENTY_FOUR("24", "4","操作负责任任务","6","检查应急设施、应急装备、应急器材、消防设施是否完好"),
TWENTY_FIVE("25", "4","操作负责任任务","7","确认现场监控设施是否完好，是否有效覆盖重大危险源区域"),
TWENTY_SIX("26", "4","操作负责任任务","8","确认现场可燃、有毒气体报警器和火灾报警器是否处于正常状态，报警信息是否及时处置"),
TWENTY_SEVEN("27", "4","操作负责任任务","9","检查危险化学品安全生产风险监测预警系统，警示信息是否及时处置，系统是否正常运行"),
TWENTY_EIGHT("28", "4","操作负责任任务","10","检查现场隐患排查人员是否熟悉排查流程，是否运用移动终端开展隐患排查，并形成闭环管理"),
;
private final String index;
private final String workTypeCode;
private final String workTypedesc;
private final String taskNum;
private final String taskNumName;
DataTaskNumEnum(String index, String workTypeCode, String workTypedesc, String taskNum, String taskNumName) {
this.index = index;
this.workTypeCode = workTypeCode;
this.workTypedesc = workTypedesc;
this.taskNum = taskNum;
this.taskNumName = taskNumName;
}
}

24
src/main/java/com/zcloud/modules/data/enums/business/DataTaskTypeEnum.java Normal file
View File

@ -0,0 +1,24 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
/**
* bus_data_hidden_danger_plan 表中 taskType
* 东胜
*/
@Getter
public enum DataTaskTypeEnum {
DAILY("0", "日常任务"),
MAIN("1", "主要责任人任务"),
TECHNOLOGY("2", "技术负责人任务"),
OPERATE("3", "操作负责人任务");
private final String code;
private final String desc;
DataTaskTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

43
src/main/java/com/zcloud/modules/data/enums/business/DataWorkDayTypeEnum.java Normal file
View File

@ -0,0 +1,43 @@
package com.zcloud.modules.data.enums.business;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* data_hidden_check_mission 字段：工作日类型。 workDayType
* 东江
* 土右，
* 目前格式一致
*
*/
@Getter
public enum DataWorkDayTypeEnum {
EVERYDAY("0", "每天"),
WORKDAY("1", "法定工作日"),
SELECTDAY("2", "非法定工作日");
;
private static final Map<String, DataWorkDayTypeEnum> codeMap = new HashMap<>();
static {
for (DataWorkDayTypeEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
DataWorkDayTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
public static DataWorkDayTypeEnum getByCode(String code) {
return codeMap.get(code);
}
}

53
src/main/java/com/zcloud/modules/data/enums/business/DataWorkTypeEnum.java Normal file
View File

@ -0,0 +1,53 @@
package com.zcloud.modules.data.enums.business;
import com.zcloud.modules.data.enums.baotou.ty.enums.TyWorkTypeEnum;
import com.zcloud.modules.data.enums.tangshan.dj.enums.DjWorkTypeEnum;
import com.zcloud.modules.data.enums.tangshan.ds.enums.DsTaskTypeEnum;
import lombok.Getter;
import java.util.HashMap;
import java.util.Map;
/**
* bus_data_hidden_check_mission 字段：任务类型。 workType
* 东江 DjWorkTypeEnum
* 土右 TyWorkTypeEnum
* 东胜 DsTaskTypeEnum
* 河北省 和土右
* 内蒙古 不一样
*/
@Getter
public enum DataWorkTypeEnum {
WORKTYPEZERO("1", "日常任务", DjWorkTypeEnum.WORKTYPEZERO.getCode(), TyWorkTypeEnum.WORKTYPEZERO.getCode(), DsTaskTypeEnum.DAILY.getCode()),
WORKTYPEONE("2", "主要负责人任务", DjWorkTypeEnum.WORKTYPEONE.getCode(), TyWorkTypeEnum.WORKTYPEONE.getCode(),DsTaskTypeEnum.MAIN.getCode()),
WORKTYPETWO("3", "技术负责人任务", DjWorkTypeEnum.WORKTYPETWO.getCode(), TyWorkTypeEnum.WORKTYPETWO.getCode(),DsTaskTypeEnum.TECHNOLOGY.getCode()),
WORKTYPETHREE("4", "操作负责人任务", DjWorkTypeEnum.WORKTYPETHREE.getCode(), TyWorkTypeEnum.WORKTYPETHREE.getCode(),DsTaskTypeEnum.TECHNOLOGY.getCode()),
;;
private static final Map<String, DataWorkTypeEnum> codeMap = new HashMap<>();
static {
for (DataWorkTypeEnum type : values()) {
codeMap.put(type.code, type);
}
}
private final String code;
private final String desc;
private final String djcode;
private final String tycode;
private final String dscode;
DataWorkTypeEnum(String code, String desc, String djcode, String tycode, String dscode) {
this.code = code;
this.desc = desc;
this.djcode = djcode;
this.tycode = tycode;
this.dscode = dscode;
}
public static DataWorkTypeEnum getByCode(String code) {
return codeMap.get(code);
}
}

3
src/main/java/com/zcloud/modules/data/enums/tangshan/dj/enums/DjClassify2Enum.java
View File

@ -13,12 +13,15 @@ public enum DjClassify2Enum {
CLASSIFY2THREE("103", "安全附件"),
CLASSIFY2FOUR("104", "安全仪表"),
CLASSIFY2FIVE("105", "其他"),
CLASSIFY2SIX("201", "动设备"),
CLASSIFY2SEVEN("202", "静设备"),
CLASSIFY2EIGHT("203", "其他"),
CLASSIFY2NINE("301", "人员资质"),
CLASSIFY2TEN("302", "操作记录"),
CLASSIFY2ELEVEN("303", "其他"),
CLASSIFY2TWELVE("401", "应急设施"),
CLASSIFY2THIRTEEN("402", "个体防护"),
CLASSIFY2FOURTEEN("403", "消防设施"),

1
src/main/java/com/zcloud/modules/data/enums/tangshan/dj/enums/DjHazardRankEnum.java
View File

@ -14,6 +14,7 @@ public enum DjHazardRankEnum {
THREE("3", "Ⅲ级"),
FOUR("4", "Ⅳ级最低"),
;
private final String code;
private final String desc;
DjHazardRankEnum(String code, String desc) {

22
src/main/java/com/zcloud/modules/data/enums/tangshan/ds/enums/DsRiskLeveEnum.java Normal file
View File

@ -0,0 +1,22 @@
package com.zcloud.modules.data.enums.tangshan.ds.enums;
import lombok.Getter;
/**
* addRiskIdentification，risk_level
* 1 2 3 4 ，没有具体说明
*/
@Getter
public enum DsRiskLeveEnum {
MAJOR_RISK("1", "重大风险"),
SIGNIFICANT_RISK("2", "较大风险"),
GENERAL_RISK("3", "一般风险"),
LOW_RISK("4", "低风险"),
;
private final String code;
private final String desc;
DsRiskLeveEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}
}

12
src/main/java/com/zcloud/modules/data/enums/tangshan/ds/enums/DsTaskTypeEnum.java
View File

@ -8,14 +8,14 @@ import lombok.Getter;
@Getter
public enum DsTaskTypeEnum {
DAILY(0, "日常任务"),
MAIN(1, "主要责任人任务"),
TECHNOLOGY(2, "技术负责人任务"),
OPERATE(3, "操作负责人任务");
private final Integer code;
DAILY("0", "日常任务"),
MAIN("1", "主要责任人任务"),
TECHNOLOGY("2", "技术负责人任务"),
OPERATE("3", "操作负责人任务");
private final String code;
private final String desc;
DsTaskTypeEnum(Integer code, String desc) {
DsTaskTypeEnum(String code, String desc) {
this.code = code;
this.desc = desc;
}

17
src/main/java/com/zcloud/modules/data/service/business/BusDataRiskEventsService.java Normal file
View File

@ -0,0 +1,17 @@
package com.zcloud.modules.data.service.business;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zcloud.modules.data.entity.business.BusDataRiskEventsEntity;
/**
* 上报安全风险事件数据表(BusDataRiskEvents)表服务接口
*
* @author zhaokai
* @since 2025-07-04 18:28:56
*/
public interface BusDataRiskEventsService extends IService<BusDataRiskEventsEntity> {
void pushRiskUnitData();
}

52
src/main/java/com/zcloud/modules/data/service/business/impl/BusDataRiskEventsServiceImpl.java Normal file
View File

@ -0,0 +1,52 @@
package com.zcloud.modules.data.service.business.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zcloud.modules.data.dao.business.BusDataRiskEventsDao;
import com.zcloud.modules.data.entity.business.BusDataRiskEventsEntity;
import com.zcloud.modules.data.service.business.BusDataRiskEventsService;
import com.zcloud.modules.data.service.third.PushDataStrategyFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* 上报安全风险事件数据表(BusDataRiskEvents)表服务实现类
*
* @author zhaokai
* @since 2025-07-04 18:28:56
*/
@Service("busDataRiskEventsService")
public class BusDataRiskEventsServiceImpl extends ServiceImpl<BusDataRiskEventsDao, BusDataRiskEventsEntity> implements BusDataRiskEventsService {
@Autowired
private PushDataStrategyFactory pushDataStrategyFactory;
@Override
public void pushRiskUnitData() {
/**
* 1.根据企业companyCode判断 需要往哪些平台推
* 2.选择企业根据策略模式选择上游平台
* 3.记录业务数据信息，服务平台已接收状态
* 4.根据业务类型和上游平台id，查找对应的数据项信息
* 5.根据数据项去找从新组装json及判断参数是否必填
* 6.组装数据，并记录请求log
* 7.推送上游平台
* 8.失败发送mq进行重试
* 9.修改业务数据信息及请求log信息
*/
//使用枚举,可能会有多个
pushDataStrategyFactory.getStrategy("ty").pushRiskUnitData();
}
/**
* 1.接收上游数据
*
* 转发
* 策略模式选择上游平台，土右的实现类
* 写公共的接口，然后各个上游去实现
*
*/
}

11
src/main/java/com/zcloud/modules/data/service/third/ExchangeDataCommonService.java Normal file
View File

@ -0,0 +1,11 @@
package com.zcloud.modules.data.service.third;
/**
* 此处写公共接口，写46个接口
*/
public interface ExchangeDataCommonService {
void pushRiskUnitData();
String getType();
}

34
src/main/java/com/zcloud/modules/data/service/third/PushDataStrategyFactory.java Normal file
View File

@ -0,0 +1,34 @@
package com.zcloud.modules.data.service.third;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class PushDataStrategyFactory {
private final Map<String, ExchangeDataCommonService> strategies = new HashMap<>();
@Autowired
private List<ExchangeDataCommonService> paymentStrategies;
@PostConstruct
public void init() {
for (ExchangeDataCommonService strategy : paymentStrategies) {
strategies.put(strategy.getType(), strategy);
}
}
public ExchangeDataCommonService getStrategy(String type) {
ExchangeDataCommonService strategy = strategies.get(type);
if (strategy == null) {
throw new IllegalArgumentException("Unknown push data type: " + type);
}
return strategy;
}
}

30
src/main/java/com/zcloud/modules/data/service/third/impl/TyExchangeDataServiceImpl.java Normal file
View File

@ -0,0 +1,30 @@
package com.zcloud.modules.data.service.third.impl;
import com.zcloud.modules.data.service.third.ExchangeDataCommonService;
public class TyExchangeDataServiceImpl implements ExchangeDataCommonService {
@Override
public void pushRiskUnitData() {
System.out.println("ty push data");
/**
*3.记录业务数据信息，服务平台已接收状态
* 4.根据业务类型和上游平台id，查找对应的数据项信息
* 5.根据数据项去找从新组装json及判断参数是否必填
* 6.组装数据，并记录请求log
* 7.推送上游平台
* 8.失败发送mq进行重试
* 9.修改业务数据信息及请求log信息
*/
}
@Override
public String getType() {
return "ty";
}
}

1
src/main/java/com/zcloud/modules/data/thirdservice/baotou/ty/TyPullDataService.java
View File

@ -11,6 +11,7 @@ import java.util.List;
public interface TyPullDataService {
/**
* 上报安全风险分析单元数据
*

109
src/main/java/com/zcloud/modules/util/mq/AnnotationReaderUtil.java Normal file
View File

@ -0,0 +1,109 @@
package com.zcloud.modules.util.mq;
import com.zcloud.modules.data.dto.baotou.ty.req.TyJobTicketApprovalReqDto;
import io.swagger.annotations.ApiModelProperty;
import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
public class AnnotationReaderUtil {
/**
* 获取指定类的所有字段的ApiModelProperty注解的value值
*
* @param clazz 要获取注解的类
* @return 包含字段名和value值的Map
*/
public static Map<String, String> getApiModelPropertyValues(Class<?> clazz) {
Map<String, String> result = new HashMap<>();
// 获取所有声明的字段（包括private字段）
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
// 获取字段上的ApiModelProperty注解
ApiModelProperty annotation = field.getAnnotation(ApiModelProperty.class);
if (annotation != null) {
// 将字段名和注解的value值存入map
result.put(field.getName(), annotation.value());
}
}
return result;
}
public static void main(String[] args) {
// 示例：获取某个类的字段和注解信息
Map<String, String> properties = getApiModelPropertyValues(TyJobTicketApprovalReqDto.class);
// 打印结果
properties.forEach((fieldName, annotationValue) ->
System.out.println("Field: " + fieldName + ", @ApiModelProperty value: " + annotationValue));
System.out.println("数量："+properties.size());
Map<String, String> allApiModelPropertyValues = getAllApiModelPropertyValues(TyJobTicketApprovalReqDto.class);
allApiModelPropertyValues.forEach((fieldName, annotationValue) ->
System.out.println("Field: " + fieldName + ", @ApiModelProperty value: " + annotationValue));
System.out.println("数量："+allApiModelPropertyValues.size());
}
/**
* 获取类及其父类所有字段的@ApiModelProperty注解value值
* @param clazz 要分析的类
* @return Map<字段名, 注解value值>
*/
public static Map<String, String> getAllApiModelPropertyValues(Class<?> clazz) {
Map<String, String> result = new LinkedHashMap<>();
// 递归获取所有父类的字段
collectApiModelProperties(clazz, result);
return result;
}
private static void collectApiModelProperties(Class<?> clazz, Map<String, String> result) {
if (clazz == null || clazz == Object.class) {
return;
}
// 先处理父类，保证父类字段在前
collectApiModelProperties(clazz.getSuperclass(), result);
// 处理当前类的字段
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
ApiModelProperty annotation = field.getAnnotation(ApiModelProperty.class);
if (annotation != null) {
result.put(field.getName(), annotation.value());
}
}
}
/**
* 获取更详细的注解信息
* @param clazz 要分析的类
* @return Map<字段名, ApiModelProperty注解对象>
*/
public static Map<String, ApiModelProperty> getAllApiModelProperties(Class<?> clazz) {
Map<String, ApiModelProperty> result = new LinkedHashMap<>();
collectFullApiModelProperties(clazz, result);
return result;
}
private static void collectFullApiModelProperties(Class<?> clazz, Map<String, ApiModelProperty> result) {
if (clazz == null || clazz == Object.class) {
return;
}
collectFullApiModelProperties(clazz.getSuperclass(), result);
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
ApiModelProperty annotation = field.getAnnotation(ApiModelProperty.class);
if (annotation != null) {
result.put(field.getName(), annotation);
}
}
}
}