Skip to content

A
amos-boot-biz
Commit 6ae99059 authored by tianbo's avatar tianbo
Browse files
Options

隐患修改提交

parent da3cd2bf
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 4832 additions and 0 deletions
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/pom.xml 0 → 100644
View file @ 6ae99059
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>amos-boot-module-api</artifactId>
<groupId>com.amosframework.boot</groupId>
<version>1.0.0</version>
</parent>
<artifactId>amos-boot-module-latentdanger-api</artifactId>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
<exclusions>
<exclusion>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-jdbc</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-base</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-web</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-annotation</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>org.jsoup</groupId>
<artifactId>jsoup</artifactId>
<version>1.11.2</version>
</dependency>
<dependency>
<groupId>com.amosframework.boot</groupId>
<artifactId>amos-boot-module-common-api</artifactId>
<version>${amos-biz-boot.version}</version>
</dependency>
<dependency>
<groupId>com.amosframework.boot</groupId>
<artifactId>amos-boot-biz-common</artifactId>
<version>${amos-biz-boot.version}</version>
</dependency>
</dependencies>
</project>
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/DangerHandleStateEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* @author DELL
*/
@Getter
@AllArgsConstructor
public enum DangerHandleStateEnum {
/**
* 隐患治理中
*/
HANDLE("隐患治理中", 0),
/**
* 隐患治理完成
*/
COMPLETED("隐患治理完成", 1);
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private Integer code;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/DictTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 字典枚举对象
* @author maoying
*
*/
public enum DictTypeEnum {
/**
* 隐患等级
*/
DANGERLEVEL("隐患等级", "DANGER_LEVEL");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
private DictTypeEnum(String name, String code){
this.name = name;
this.code = code;
}
public static DictTypeEnum getEnum(String code) {
DictTypeEnum instance = null;
for(DictTypeEnum type: DictTypeEnum.values()) {
if (type.getCode().equals(code)) {
instance = type;
break;
}
}
return instance;
}
public static List<Map<String,String>> getEnumList() {
List<Map<String,String>> list = new ArrayList<>();
for(DictTypeEnum e : DictTypeEnum.values()) {
Map<String, String> map = new HashMap<String, String>();
map.put("code", e.getCode());
map.put("name", e.getName());
list.add(map);
}
return list;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/ExecuteStateEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
public enum ExecuteStateEnum {
未执行("未执行", 1, ""),
通过("通过", 2, "{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": false}]}"),
驳回("驳回", 3, "{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": true}]}"),
已确认("已确认", 4, ""),
停止执行("停止执行", 5, ""),
作业开始执行("作业开始执行", 6, ""),
作业完成("作业完成", 7, "");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private Integer code;
private String requestBody;
ExecuteStateEnum(String name, Integer code, String requestBody) {
this.name = name;
this.code = code;
this.requestBody = requestBody;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public String getRequestBody() {
return requestBody;
}
public void setRequestBody(String requestBody) {
this.requestBody = requestBody;
}
public static ExecuteStateEnum getByCode(Integer code) {
for (ExecuteStateEnum e : ExecuteStateEnum.values()) {
if (code.equals(e.getCode())) {
return e;
}
}
return null;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/InstanceKeyEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 规则请求枚举
* @author WJK
*
*/
@Getter
@AllArgsConstructor
public enum InstanceKeyEnum {
NORMAL("无码无计划隐患","normalHazardManagement"),
PATROL("巡检隐患","hazardManagement" );
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerBizTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
/**
* 业务配置枚举
*
* @author DELL
*/
public enum LatentDangerBizTypeEnum {
/**
* 防火监督
*/
防火监督("防火监督", "supervision", "fire_supervision_hazard_management"),
/**
* 巡检
*/
巡检("巡检", "patrol", "");
/**
* 业务名称
*/
String name;
/**
* 业务code
*/
String code;
/**
* 业务对应工作流定义key
*/
String workflowDefKey;
LatentDangerBizTypeEnum(String name, String code, String workflowDefKey) {
this.name = name;
this.code = code;
this.workflowDefKey = workflowDefKey;
}
public static LatentDangerBizTypeEnum getByCode(String code) {
for (LatentDangerBizTypeEnum l : LatentDangerBizTypeEnum.values()) {
if (l.getCode().equals(code)) {
return l;
}
}
return null;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerExecuteTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
/**
* @author Dell
*/
public enum LatentDangerExecuteTypeEnum {
填写隐患完成("填写隐患完成", 1, ExecuteStateEnum.通过, LatentDangerStateEnum.待评审,
"{\"action\": \"complete\"}"),
隐患评审通过("隐患评审通过", 2, ExecuteStateEnum.通过, LatentDangerStateEnum.待治理,
"{\"reviewResult\": \"通过\"}"),
隐患评审拒绝("隐患评审拒绝", 3, ExecuteStateEnum.驳回, LatentDangerStateEnum.已撤销,
"{\"reviewResult\": \"不通过\"}"),
隐患常规治理("隐患常规治理", 4, ExecuteStateEnum.通过, LatentDangerStateEnum.待验证,
"{\"rectifyResult\": \"常规整改\"}"),
隐患安措计划("隐患安措计划", 5, ExecuteStateEnum.通过, LatentDangerStateEnum.安措计划中,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rectification\",\"value\": \"plan\"}]}"),
隐患延期治理("隐患延期治理", 15, ExecuteStateEnum.通过, LatentDangerStateEnum.延期治理申请待车间部门审核,
"{\"rectifyResult\": \"延期\"}"),
隐患延期治理车间部门审核通过("隐患延期治理车间部门审核通过", 16, ExecuteStateEnum.通过, LatentDangerStateEnum.待治理,
"{\"approveResult\": \"通过\"}"),
隐患延期治理车间部门审核拒绝("隐患延期治理车间部门审核拒绝", 17, ExecuteStateEnum.驳回, LatentDangerStateEnum.待治理,
"{\"approveResult\": \"不通过\"}"),
隐患延期治理公司审核通过("隐患延期治理公司审核通过", 18, ExecuteStateEnum.通过, LatentDangerStateEnum.待治理,
"{\"approveResult\": true}"),
隐患延期治理公司审核拒绝("隐患延期治理公司审核拒绝", 19, ExecuteStateEnum.驳回, LatentDangerStateEnum.延期治理申请待车间部门审核,
"{\"approveResult\": false}"),
填写安措计划完成("填写安措计划完成", 6, ExecuteStateEnum.通过, LatentDangerStateEnum.安措计划中,
"{\"action\": \"complete\"}"),
车间部门审核通过("车间部门审核通过", 7, ExecuteStateEnum.通过, LatentDangerStateEnum.安措计划中,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": false}]}"),
车间部门审核拒绝("车间部门审核拒绝", 8, ExecuteStateEnum.驳回, LatentDangerStateEnum.待治理,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": true}]}"),
总工程师审核通过("总工程师审核通过", 9, ExecuteStateEnum.通过, LatentDangerStateEnum.安措计划中,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": false}]}"),
总工程师审核拒绝("总工程师审核拒绝", 10, ExecuteStateEnum.驳回, LatentDangerStateEnum.待治理,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": true}]}"),
公司负责人审核通过("公司负责人审核通过", 11, ExecuteStateEnum.通过, LatentDangerStateEnum.待验证,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": false}]}"),
公司负责人审核拒绝("公司负责人审核拒绝", 12, ExecuteStateEnum.驳回, LatentDangerStateEnum.待治理,
"{\"action\": \"complete\",\"variables\": [{\"name\": \"rejected\",\"value\": true}]}"),
隐患验证通过("隐患验证通过", 13, ExecuteStateEnum.通过, LatentDangerStateEnum.治理完毕,
"{\"validationResult\": \"通过\"}"),
隐患验证拒绝("隐患验证拒绝", 14, ExecuteStateEnum.驳回, LatentDangerStateEnum.待治理,
"{\"validationResult\": \"不通过\"}");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private Integer code;
/**
* 执行状态
*/
private ExecuteStateEnum executeState;
private String requestBody;
private LatentDangerStateEnum nextState;
LatentDangerExecuteTypeEnum(String name, Integer code, ExecuteStateEnum executeState, LatentDangerStateEnum nextState, String requestBody) {
this.name = name;
this.code = code;
this.executeState = executeState;
this.requestBody = requestBody;
this.nextState = nextState;
}
public static LatentDangerExecuteTypeEnum getByCode(Integer code) {
for (LatentDangerExecuteTypeEnum e : LatentDangerExecuteTypeEnum.values()) {
if (code.equals(e.getCode())) {
return e;
}
}
return null;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public ExecuteStateEnum getExecuteState() {
return executeState;
}
public void setExecuteState(ExecuteStateEnum executeState) {
this.executeState = executeState;
}
public String getRequestBody() {
return requestBody;
}
public void setRequestBody(String requestBody) {
this.requestBody = requestBody;
}
public LatentDangerStateEnum getNextState() {
return nextState;
}
public void setNextState(LatentDangerStateEnum nextState) {
this.nextState = nextState;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerLevelEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import com.yeejoin.amos.boot.biz.common.utils.DynamicEnumUtil;
import java.util.HashMap;
import java.util.Map;
/**
* @author DELL
*/
public enum LatentDangerLevelEnum {
/**
* 安全问题
*/
安全问题("安全问题", "0", "0", 1),
/**
* 一般隐患
*/
一般隐患("一般隐患", "1", "1", 2),
/**
* 重大隐患
*/
重大隐患("重大隐患", "2", "2", 3);
/**
* 枚举缓存
*/
public static Map<String, LatentDangerLevelEnum> enumMap = new HashMap<>();
public static final String dictCode = "_DANGER_LEVEL";
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
/**
* 风险源等级
*/
private String riskSourceDangerLevelCode;
/**
* 排序
*/
private Integer order;
// static {
// EnumSet<LatentDangerLevelEnum> set = EnumSet.allOf(LatentDangerLevelEnum.class);
// for (LatentDangerLevelEnum each : set) {
// // 增加一个缓存 减少对枚举的修改
// enumMap.put(each.code, each);
// }
// }
LatentDangerLevelEnum(String name, String code, String riskSourceDangerLevelCode, Integer order) {
this.name = name;
this.code = code;
this.riskSourceDangerLevelCode = riskSourceDangerLevelCode;
this.order = order;
}
public static LatentDangerLevelEnum getByRiskSourceDangerLevelCode(String riskSourceDangerLevelCode) {
for (LatentDangerLevelEnum l : LatentDangerLevelEnum.values()) {
if (riskSourceDangerLevelCode.equals(l.getRiskSourceDangerLevelCode())) {
return l;
}
}
return null;
}
public static LatentDangerLevelEnum getEnumByOrder(Integer order) {
for (LatentDangerLevelEnum l : enumMap.values()) {
if (order.equals(l.getOrder())) {
return l;
}
}
return null;
}
/**
* 根据关键字段获取枚举值 可以在这里做一些修改 来达到动态添加的效果
*
* @param code
*/
public static LatentDangerLevelEnum getEnumByCode(String code) {
// 这里可以做一些修改 比如若从 enumMap 中没有取得 则加载配置动态添加
return enumMap.get(code);
}
public static LatentDangerLevelEnum addEnumDynamic(String enumName, String name, String code,
String riskSourceDangerLevelCode, Integer order) {
LatentDangerLevelEnum dangerLevelEnum = DynamicEnumUtil.addEnum(LatentDangerLevelEnum.class, enumName,
new Class[]{String.class, String.class, String.class, Integer.class}, new Object[]{name, code,
riskSourceDangerLevelCode, order});
enumMap.put(code, dangerLevelEnum);
return dangerLevelEnum;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getRiskSourceDangerLevelCode() {
return riskSourceDangerLevelCode;
}
public void setRiskSourceDangerLevelCode(String riskSourceDangerLevelCode) {
this.riskSourceDangerLevelCode = riskSourceDangerLevelCode;
}
public Integer getOrder() {
return order;
}
public void setOrder(Integer order) {
this.order = order;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerOvertimeStateEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
public enum LatentDangerOvertimeStateEnum {
未超时("未超时", 0),
已超时("已超时", 1);
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private Integer code;
LatentDangerOvertimeStateEnum(String name, Integer code) {
this.name = name;
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public static LatentDangerOvertimeStateEnum getByCode(Integer code) {
for (LatentDangerOvertimeStateEnum l : LatentDangerOvertimeStateEnum.values()) {
if (code.equals(l.getCode())) {
return l;
}
}
return null;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerReformTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import com.yeejoin.amos.boot.biz.common.utils.DynamicEnumUtil;
import java.util.HashMap;
import java.util.Map;
/**
* 隐患治理方式枚举
*
* @author DELL
*/
public enum LatentDangerReformTypeEnum {
/**
* 常规整改
*/
常规整改("常规整改", "1"),
/**
* 安措计划
*/
安措计划("安措计划", "2"),
/**
* 延期治理
*/
延期治理("延期治理", "3");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
/**
* 枚举缓存
*/
public static Map<String, LatentDangerReformTypeEnum> enumMap = new HashMap<>();
public static final String dictCode = "_GOVERNANCE";
LatentDangerReformTypeEnum(String name, String code) {
this.name = name;
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
/**
* 根据关键字段获取枚举值 可以在这里做一些修改 来达到动态添加的效果
*
* @param code
*/
public static LatentDangerReformTypeEnum getEnumByCode(String code) {
// 这里可以做一些修改 比如若从 enumMap 中没有取得 则加载配置动态添加
return enumMap.get(code);
}
public static LatentDangerReformTypeEnum addEnumDynamic(String enumName, String name, String code) {
LatentDangerReformTypeEnum dangerReformTypeEnum = DynamicEnumUtil.addEnum(LatentDangerReformTypeEnum.class, enumName,
new Class[]{String.class, String.class}, new Object[]{name, code});
enumMap.put(code, dangerReformTypeEnum);
return dangerReformTypeEnum;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerStateEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import com.yeejoin.amos.boot.biz.common.utils.DynamicEnumUtil;
import java.util.HashMap;
import java.util.Map;
public enum LatentDangerStateEnum {
待评审("待评审", "1"),
待治理("待治理", "2"),
安措计划中("安措计划中", "3"),
待验证("待验证", "4"),
治理完毕("治理完毕", "5"),
已撤销("已撤销", "6"),
延期治理申请("延期治理中", "7"),
延期治理申请待车间部门审核("延期治理待车间部门审核", "8"),
延期治理申请待公司审核("延期治理待公司审核", "9");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
/**
* 枚举缓存
*/
public static Map<String, LatentDangerStateEnum> enumMap = new HashMap<>();
public static final String dictCode = "_GOVERNANCE_PROGRESS";
LatentDangerStateEnum(String name, String code) {
this.name = name;
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public static String getEnumName(String code) {
return enumMap.get(code).getName();
}
public static LatentDangerStateEnum getByCode(String code) {
return enumMap.get(code);
}
public static LatentDangerStateEnum addEnumDynamic(String enumName, String name, String code) {
LatentDangerStateEnum dangerStateEnum = DynamicEnumUtil.addEnum(LatentDangerStateEnum.class, enumName,
new Class[]{String.class, String.class}, new Object[]{name, code});
enumMap.put(code, dangerStateEnum);
return dangerStateEnum;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
/**
* 隐患来源类型枚举
*
* @author DELL
*/
public enum LatentDangerTypeEnum {
/**
* 无码检查
*/
无码检查("无码检查", "1"),
/**
* 计划检查
*/
计划检查("计划检查", "2"),
/**
* 无计划检查
*/
无计划检查("无计划检查", "3"),
/**
* 随手拍
*/
随手拍("随手拍", "4");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
LatentDangerTypeEnum(String name, String code) {
this.name = name;
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public static String getEnumName(String code) {
String name = "";
for(LatentDangerTypeEnum type: LatentDangerTypeEnum.values()) {
if (type.getCode()==code) {
name = type.getName();
break;
}
}
return name;
}
public static LatentDangerTypeEnum getByCode(String code) {
for (LatentDangerTypeEnum l : LatentDangerTypeEnum.values()) {
if (code.equals(l.getCode())) {
return l;
}
}
return null;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/MsgSubscribeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import java.util.List;
import java.util.Map;
/**
* @author DELL
*/
public enum MsgSubscribeEnum {
/**
* 风险评价提醒推送
*/
风险评价提醒推送("riskFatorApp", "风险评价提醒", "风险评价提醒", false, "default"),
/**
* 隐患治理推送
*/
隐患治理推送("latentDangerApp", "隐患治理", "隐患治理移动端推送", false, "default");
private String msgType;
private String title;
private String desc;
private Boolean canConfig;
private String type;
MsgSubscribeEnum(String msgType, String title, String desc, Boolean canConfig, String type) {
this.msgType = msgType;
this.title = title;
this.desc = desc;
this.canConfig = canConfig;
this.type = type;
}
public static List<Map<String, String>> getEnumList() {
List<Map<String, String>> list = Lists.newArrayList();
for (MsgSubscribeEnum e : MsgSubscribeEnum.values()) {
if (e.canConfig && !e.getMsgType().equals("checkRecordNoPushApp") && !e.getType().equals("email")) {
Map<String, String> msgType = Maps.newHashMap();
msgType.put(e.getMsgType(), e.getTitle());
list.add(msgType);
}
}
return list;
}
public static MsgSubscribeEnum getByMsgType(String msgType) {
for (MsgSubscribeEnum typeEnum : MsgSubscribeEnum.values()) {
if (msgType.equals(typeEnum.msgType)) {
return typeEnum;
}
}
return null;
}
public String getMsgType() {
return msgType;
}
public void setMsgType(String msgType) {
this.msgType = msgType;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getDesc() {
return desc;
}
public void setDesc(String desc) {
this.desc = desc;
}
public Boolean getCanConfig() {
return canConfig;
}
public void setCanConfig(Boolean canConfig) {
this.canConfig = canConfig;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/MsgTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author DELL
*/
public enum MsgTypeEnum {
/**
* 隐患排查
*/
CHECK("隐患排查", "check");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
private MsgTypeEnum(String name, String code) {
this.name = name;
this.code = code;
}
public static MsgTypeEnum getEnum(String code) {
MsgTypeEnum MsgTypeEnum = null;
for (MsgTypeEnum type : MsgTypeEnum.values()) {
if (type.getCode().equals(code)) {
MsgTypeEnum = type;
break;
}
}
return MsgTypeEnum;
}
public static List<Map<String, String>> getEnumList() {
List<Map<String, String>> list = new ArrayList<>();
for (MsgTypeEnum e : MsgTypeEnum.values()) {
Map<String, String> msgType = new HashMap<>();
msgType.put(e.getCode(), e.getName());
list.add(msgType);
}
return list;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/WorkFlowRiskFactorUriEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
/**
* @author DELL
*/
public enum WorkFlowRiskFactorUriEnum {
/**
* 隐患治理结果推送
*/
隐患治理结果推送("隐患治理结果推送", "/api/protal/hiddentrouble", "");
private String desc;
private String uri;
private String params;
WorkFlowRiskFactorUriEnum(String desc, String uri, String params) {
this.desc = desc;
this.uri = uri;
this.params = params;
}
public String getDesc() {
return desc;
}
public void setDesc(String desc) {
this.desc = desc;
}
public String getUri() {
return uri;
}
public void setUri(String uri) {
this.uri = uri;
}
public String getParams() {
return params;
}
public void setParams(String params) {
this.params = params;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/WorkFlowUriEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
public enum WorkFlowUriEnum {
启动流程("启动流程", "/workflow/task/startTask", ""),
流程详情("流程详情", "/workflow/task/{taskId}", "taskId"),
合并启动流程("合并启动流程", "/workflow/task/startProcess", ""),
所有已执行任务详情("所有已执行任务详情","/workflow/activitiHistory/task/detail/{taskId}","taskId"),
流程任务("流程任务", "/workflow/task?processInstanceId={processInstanceId}", "processInstanceId"),
我的代办("我的代办", "/workflow/task/all-list?processDefinitionKey={processDefinitionKey}", "processDefinitionKey"),
我的代办有ID("我的代办有ID", "/workflow/task/all-list?processDefinitionKey={processDefinitionKey}&userId={userId}", "processDefinitionKey,userId"),
已执行任务("已执行任务", "/workflow/activitiHistory/all-historytasks?processDefinitionKey={processDefinitionKey}", "processDefinitionKey"),
已执行任务有ID("已执行任务有ID", "/workflow/activitiHistory/all-historytasks?processDefinitionKey={processDefinitionKey}&userId={userId}", "processDefinitionKey,userId"),
启动免登录流程("启动免登录流程", "/processes/{appKey}", "appKey"),
当前节点("当前节点", "/wf/taskstodo?processInstanceId={processInstanceId}", "processInstanceId"),
执行流程("执行流程", "/workflow/task/pickupAndCompleteTask/{taskId}", "taskId"),
终止流程("终止流程", "/wf/processes/{processInstanceId}?deleteReason={deleteReason}", "processInstanceId,deleteReason"),
当前子节点("当前子节点", "/wf/processes/{processInstanceId}/tasks?taskDefinitionKey={taskDefinitionKey}", "processInstanceId,taskDefinitionKey"),
工作流流水("工作流流水","/wf/processes/{processInstanceId}/tasks", "processInstanceId"),
子节点信息("子节点信息","/workflow/task/list/all/{instanceId}", "instanceId");
private String desc;
private String uri;
private String params;
WorkFlowUriEnum(String desc, String uri, String params) {
this.desc = desc;
this.uri = uri;
this.params = params;
}
public String getDesc() {
return desc;
}
public void setDesc(String desc) {
this.desc = desc;
}
public String getUri() {
return uri;
}
public void setUri(String uri) {
this.uri = uri;
}
public String getParams() {
return params;
}
public void setParams(String params) {
this.params = params;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/YesOrNoEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.common.enums;
/**
* 是否枚举
* @author WJK
*
*/
public enum YesOrNoEnum {
NO("否","0"),
YES("是","1" );
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
private YesOrNoEnum(String name, String code){
this.name = name;
this.code = code;
}
public static YesOrNoEnum getEnum(String code) {
YesOrNoEnum jPushTypeEnum = null;
for(YesOrNoEnum type: YesOrNoEnum.values()) {
if (type.getCode().equals(code)) {
jPushTypeEnum = type;
break;
}
}
return jPushTypeEnum;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/request/CommonPageable.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.core.common.request;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
/**
* <pre>
* 分页实体
* </pre>
*
* @author as-chenjiajun
* @version $Id: CommonPageable.java, v 0.1 2016-12-14 上午10:42:44 as-chenjiajun
* Exp $
*/
public class CommonPageable implements Pageable {
/**
* 页号（大于等于0）
*/
protected int pageNumber = 0;
/**
* 每页大小（大于等于0）
*/
protected int pageSize = 10;
/**
* 起始索引
*/
protected int offset = 0;
/**
* 排序
*/
protected Sort sort = null;
public CommonPageable() {
this.pageNumber = 0;
this.pageSize = 10;
this.offset = pageSize * pageNumber;
}
public CommonPageable(int pageNumber, int pageSize) {
this.pageNumber = pageNumber;
this.pageSize = pageSize;
this.offset = pageSize * pageNumber;
}
public CommonPageable(int pageNumber, int pageSize, Sort sort) {
this.pageNumber = pageNumber;
this.pageSize = pageSize;
this.sort = sort;
this.offset = pageSize * pageNumber;
}
public int getPageNumber() {
return this.pageNumber;
}
public void setPageNumber(int pageNumber) {
this.pageNumber = pageNumber;
}
public int getPageSize() {
return pageSize;
}
public void setPageSize(int pageSize) {
this.pageSize = pageSize;
}
public long getOffset() {
offset = pageSize * pageNumber;
return offset;
}
public void setOffset(int offset) {
this.offset = offset;
}
public Sort getSort() {
return sort;
}
public void setSort(Sort sort) {
this.sort = sort;
}
public Pageable next() {
return null;
}
public Pageable previousOrFirst() {
return null;
}
public Pageable first() {
return null;
}
public boolean hasPrevious() {
return false;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/request/CommonRequest.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.patrol.core.common.request;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**
*
* <pre>
* 公共请求对象
* </pre>
*
* @author as-shibaobao
* @version $Id: CommonRequest.java, v 0.1 2018年1月26日 上午10:59:19 as-shibaobao Exp $
*/
@ApiModel
public class CommonRequest {
/**
* 字段名称
*/
@ApiModelProperty(value="字段名称",required=true)
private String name;
/**
* 字段值
*/
@ApiModelProperty(value="字段值",required=true)
private Object value;
/**
* 查询类型
*/
@ApiModelProperty(value="查询类型",notes="空值时，默认为等于；其它类型按QueryOperatorEnum",required=false)
private String type;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Object getValue() {
return value;
}
public void setValue(Object value) {
this.value = value;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/request/LatentDangerResultPushSpcRequest.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.core.common.request;
import java.util.List;
/**
* @author DELL
*/
public class LatentDangerResultPushSpcRequest {
/**
* 隐患状态
*/
private String hiddenTroubleStatus;
/**
* 处理时间
*/
private String processingTime;
/**
* 隐患名称
*/
private String hiddenTroubleName;
/**
* 风险点id
*/
private String riskSourceId;
/**
* 所有隐患的状态集合
*/
private List<String> troubleList;
public String getHiddenTroubleStatus() {
return hiddenTroubleStatus;
}
public void setHiddenTroubleStatus(String hiddenTroubleStatus) {
this.hiddenTroubleStatus = hiddenTroubleStatus;
}
public String getProcessingTime() {
return processingTime;
}
public void setProcessingTime(String processingTime) {
this.processingTime = processingTime;
}
public String getHiddenTroubleName() {
return hiddenTroubleName;
}
public void setHiddenTroubleName(String hiddenTroubleName) {
this.hiddenTroubleName = hiddenTroubleName;
}
public String getRiskSourceId() {
return riskSourceId;
}
public void setRiskSourceId(String riskSourceId) {
this.riskSourceId = riskSourceId;
}
public List<String> getTroubleList() {
return troubleList;
}
public void setTroubleList(List<String> troubleList) {
this.troubleList = troubleList;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/request/RoutePointInputItemRequest.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.patrol.core.common.request;
/**
* 线路巡检点巡检项查询条件
* @author Administrator
*
*/
public class RoutePointInputItemRequest {
/**
* 巡检点id
*/
private Long pointId;
/**
* 是否绑定
*/
private String isBound;
/**
* 路线id
*/
private Long routeId;
/**
* 分类id
*/
private Long classifyId;
/**
* 巡检项等级
*/
private String level;
/**
* 巡检项名称
*/
private String inputName;
public Long getPointId() {
return pointId;
}
public void setPointId(Long pointId) {
this.pointId = pointId;
}
public Long getRouteId() {
return routeId;
}
public void setRouteId(Long routeId) {
this.routeId = routeId;
}
public Long getClassifyId() {
return classifyId;
}
public void setClassifyId(Long classifyId) {
this.classifyId = classifyId;
}
public String getLevel() {
return level;
}
public void setLevel(String level) {
this.level = level;
}
public String getInputName() {
return inputName;
}
public void setInputName(String inputName) {
this.inputName = inputName;
}
public String getIsBound() {
return isBound;
}
public void setIsBound(String isBound) {
this.isBound = isBound;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/response/CommonPage.java 0 → 100644
View file @ 6ae99059
/**
* NewHeight.com Inc.
* Copyright (c) 2008-2010 All Rights Reserved.
*/
package com.yeejoin.amos.patrol.core.common.response;
import java.util.List;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.Pageable;
/**
* <pre>
* 分页数据
* </pre>
*
* @author as-youjun
* @version $Id: CompanyPage.java, v 0.1 2017年4月13日 上午11:35:25 as-youjun Exp $
*/
public final class CommonPage<T> extends PageImpl<T> {
/**
* <pre>
* uid
* </pre>
*/
private static final long serialVersionUID = -5533124806408380886L;
/**
*
*/
private String message;
/**
* 返回结果状态
*/
private String result;
public CommonPage(List<T> content, Pageable pageable, long total) {
super(content, pageable, total);
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public String getResult()
{
return result;
}
public void setResult(String result)
{
this.result = result;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/response/DangerListResponse.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.core.common.response;
import cn.afterturn.easypoi.excel.annotation.Excel;
import lombok.Data;
import java.util.Date;
@Data
public class DangerListResponse {
/**
* 隐患id
*/
private Long dangerId;
@Excel(name = "治理进度", orderNum = "1")
private String dangerState;// 治理进度
@Excel(name = "隐患名称", width = 20, orderNum = "2")
private String dangerName;// 隐患名称
@Excel(name = "隐患地点", width = 20, orderNum = "3")
private String structureName;// 隐患地点
private String dangerPosition;// 详细地址
private String structureId;// 建筑Id
@Excel(name = "隐患级别", orderNum = "4")
private String dangerLevel;// 隐患级别
@Excel(name = "治理方式", orderNum = "5")
private String reformType;// 治理方式
private Date deadlineDate;
@Excel(name = "整改期限", width = 20, orderNum = "6")
private String deadline;// 整改期限
@Excel(name = "是否逾期", orderNum = "7")
private String overtimeState;// 是否逾期
@Excel(name = "隐患来源名称", width = 15, orderNum = "8")
private String dangerTypeName;//隐患来源名称
private String dangerType;//隐患来源
/**
* 隐患流程id
*/
private String processInstanceId;
/**
* 可执行人
*/
private String canExecuteUser;
/**
* 隐患发现人
*/
private String discoverUser;
/**
* 执行人
*/
private String executeUser;
/**
* 问题描述
*/
@Excel(name = "问题描述", width = 35, orderNum = "9")
private String problemDescription;
/**
* 原因分析
*/
@Excel(name = "原因分析", width = 35, orderNum = "10")
private String reasonAnalysis;
/**
* 举一反三
*/
@Excel(name = "举一反三", width = 35, orderNum = "11")
private String inferOtherThings;
/**
* 备注
*/
@Excel(name = "备注", width = 35, orderNum = "12")
private String remark;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/core/common/response/WebStockResponse.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.core.common.response;
import lombok.Data;
@Data
public class WebStockResponse {
/**
* 消息类型
*/
private String type;
/**
* 内容
*/
private String content;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/BasicEntity.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import org.springframework.data.annotation.CreatedDate;
import javax.persistence.Column;
import javax.persistence.Id;
import java.io.Serializable;
import java.util.Date;
/**
* <pre>
* 基本实体类
* </pre>
* @author DELL
*/
@Data
public class BasicEntity implements Serializable {
private static final long serialVersionUID = -5464322936854328207L;
/**
* id
*/
@TableId(type = IdType.ID_WORKER)
private Long id;
// @CreatedDate
@Column(name = "create_date")
private Date createDate;
// @Id
// @GeneratedValue(strategy = GenerationType.IDENTITY)
// @Column(name = "ID", nullable = false, unique = true)
// public long getId() {
// return id;
// }
//
// public void setId(long id) {
// this.id = id;
// }
public Date getCreateDate() {
return createDate;
}
public void setCreateDate(Date createDate) {
this.createDate = createDate;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/LatentDanger.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.hibernate.annotations.Where;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.NamedQuery;
import javax.persistence.Table;
import java.util.Date;
/**
* @author keyong
* @title: LatentDanger
* <pre>
* @description: 隐患表
* </pre>
* @date 2021/1/26 14:03
*/
@Data
@EqualsAndHashCode(callSuper = true)
@Accessors(chain = true)
@TableName("cb_latent_danger")
@ApiModel(value="LatentDanger", description="隐患信息")
public class LatentDanger extends BasicEntity {
private static final long serialVersionUID = 1L;
/**
* 业务唯一标识
*/
@Column(name = "business_key")
private String businessKey;
/**
* 公司组织机构
*/
@Column(name = "org_code")
private String orgCode;
/**
* 隐患名称
*/
@Column(name = "danger_name")
private String dangerName;
@Column(name = "instance_id")
private String instanceId;
@Column(name = "current_flow_record_id")
private Long currentFlowRecordId;
/**
* 隐患等级（1：一般隐患；2：重大隐患；0：安全问题）
*/
@Column(name = "danger_level")
private String dangerLevel;
/**
* 隐患等级名称
*/
@Column(name = "danger_level_name")
private String dangerLevelName;
/**
* 隐患地点
*/
@Column(name = "danger_position")
private String dangerPosition;
/**
* 隐患类型（1：普通隐患；2：巡检隐患）
*/
@Column(name = "danger_type")
private String dangerType;
/**
* 隐患类型名称
*/
@Column(name = "danger_type_name")
private String dangerTypeName;
/**
* 备注
*/
@Column(name = "remark")
private String remark;
/**
* 整改类型（1：常规整改；2：安措计划；3：延期整改）
*/
@Column(name = "reform_type")
private String reformType;
/**
* 整改类型名称
*/
@Column(name = "reform_type_name")
private String reformTypeName;
/**
* 限制时间
*/
@Column(name = "reform_limit_date")
private Date reformLimitDate;
@Column(name = "overtime_state")
private Integer overtimeState;
@Column(name = "reform_json")
private String reformJson;
/**
* 隐患状态（1：待评审；2：待治理；3：安措计划中；4：逾期未治理；5：待验证；6：治理完毕；7：已撤销）
*/
@Column(name = "danger_state")
private String dangerState;
/**
* 隐患状态名称
*/
@Column(name = "danger_state_name")
private String dangerStateName;
/**
* 发现人
*/
@Column(name = "discoverer_user_id")
private String discovererUserId;
@Column(name = "discoverer_department_id")
private String discovererDepartmentId;
@Column(name = "photo_urls")
private String photoUrls;
/**
* 是否删除（0：否；1：是）
*/
@Column(name = "deleted")
private Boolean deleted;
/**
* 记录修改时间
*/
@Column(name = "update_date")
private Date updateDate;
/**
* 延期治理时间
*/
@Column(name = "delay_limit_date")
private Date delayLimitDate;
/**
* 问题描述
*/
@Column(name = "problem_description")
private String problemDescription;
/**
* 原因分析
*/
@Column(name = "reason_analysis")
private String reasonAnalysis;
/**
* 举一反三
*/
@Column(name = "infer_other_things")
private String inferOtherThings;
/**
* 检查记录创建的隐患检查项对应id
*/
@Column(name = "biz_id")
private Long bizId;
/**
* 建筑id
*/
@Column(name = "structure_id")
private Long structureId;
/**
* 建筑名称
*/
@Column(name = "structure_name")
private String structureName;
@Column(name = "instance_key")
private String instanceKey;
/**
* 业务类型（不同业务创建的隐患以此区分:巡检隐患、防火监督隐患、其他隐患。。。）
*/
@Column(name = "biz_type")
private String bizType;
/**
* 经度
*/
private String longitude;
/**
* 纬度
*/
private String latitude;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/LatentDangerFlowRecord.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.hibernate.annotations.Where;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.NamedQuery;
import javax.persistence.Table;
import java.util.Date;
/**
* @author keyong
* @title: LatentDangerFlowRecord
* <pre>
* @description: 隐患工作流记录表
* </pre>
* @date 2021/1/26 14:18
*/
@Data
@EqualsAndHashCode(callSuper = true)
@Accessors(chain = true)
@TableName("cb_latent_danger_flow_record")
@ApiModel(value="LatentDangerFlowRecord", description="隐患工作流记录信息")
public class LatentDangerFlowRecord extends BasicEntity {
private static final long serialVersionUID = 1L;
@Column(name = "danger_id")
private Long dangerId;
@Column(name = "action_flag")
private String actionFlag;
@Column(name = "flow_task_name")
private String flowTaskName;
@Column(name = "flow_task_user_ids")
private String flowTaskUserIds;
@Column(name = "flow_task_id")
private String flowTaskId;
@Column(name = "execute_state")
private Integer executeState;
@Column(name = "execute_user_id")
private String executeUserId;
@Column(name = "execute_result")
private String executeResult;
@Column(name = "remark")
private String remark;
@Column(name = "flow_json")
private String flowJson;
/**
* 是否删除（0：否；1：是）
*/
@Column(name = "deleted")
private Boolean deleted = false;
/**
* 记录修改时间
*/
@Column(name = "update_date")
private Date updateDate;
@Column(name = "execute_department_id")
private String executeDepartmentId;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/LatentDangerPatrol.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import org.hibernate.annotations.Where;
import org.springframework.data.annotation.Transient;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.NamedQuery;
import javax.persistence.Table;
import java.util.Date;
/**
* @author keyong
* @title: LatentDangerPatrol
* <pre>
* @description: 隐患巡检关系表
* </pre>
* @date 2021/1/26 14:51
*/
@TableName("cb_latent_danger_patrol")
@Data
public class LatentDangerPatrol extends BasicEntity {
private static final long serialVersionUID = 1L;
@Column(name = "latent_danger_id")
private Long latentDangerId;
@Column(name = "point_classify_id")
private Long pointClassifyId;
@Column(name = "check_id")
private Long checkId;
@Column(name = "item_id")
private Long itemId;
@Column(name = "point_id")
private Long pointId;
@Column(name = "route_id")
private Long routeId;
@Column(name = "risk_factor_flow_id")
private String riskFactorFlowId;
@Column(name = "route_point_item_id")
private Long routePointItemId;
/**
* 是否删除（0：否；1：是）
*/
@Column(name = "deleted")
private Integer deleted;
/**
* 检查类型-交大字段，只是前段显示用
*/
@Transient
private String checkType;
/**
* 记录修改时间
*/
@Column(name = "update_date")
private Date updateDate;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/LatentDangerPhoto.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import org.hibernate.annotations.Where;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.NamedQuery;
import javax.persistence.Table;
/**
* @author keyong
* @title: LatentDangerPhoto
* <pre>
* @description: 隐患图片
* </pre>
* @date 2021/1/26 14:50
*/
@TableName("cb_latent_danger_photo")
@Data
public class LatentDangerPhoto extends BasicEntity {
private static final long serialVersionUID = 1L;
@Column(name = "biz_code")
private String bizCode;
@Column(name = "url")
private String url;
@Column(name = "biz_id")
private Long bizId;
@Column(name = "deleted")
private String deleted;
@Column(name = "update_date")
private String updateDate;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/Msg.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Lob;
import javax.persistence.Table;
import javax.persistence.Transient;
import java.util.Date;
/**
* 消息
*
* @author Administrator
*/
@TableName("p_msg")
public class Msg extends BasicEntity {
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 标题
*/
@Column(name = "title")
private String title;
/**
* 消息
*/
@Lob
@Column(name = "body")
private String body;
private String pushBody;
/**
* 接收人名称
*/
@Column(name = "reciver_name")
private String reciverName;
/**
* 接收人ID
*/
@Column(name = "user_id")
private String userId;
/**
* 消息类型：对应MsgTypeEnum类,
*/
@Column(name = "msg_type")
private String msgType;
/**
* 发送状态0：未发送；1：已发送
*/
@Column(name = "status")
private int status = 1;
/**
* 发送时间
*/
@Column(name = "send_time")
private Date sendTime;
/**
* 关联id：巡检点；任务；计划
*/
@Column(name = "relation_id")
private Long relationId;
/**
* 发送方式true 按用户设置时间发送（主要针对任务提醒和消息发送），false 定时器发送
*/
@Column(name = "is_immediately")
private boolean isImmediately = true;
/**
* 定点发送时间
*/
@Column(name = "fixed_time")
private Date fixedTime;
/**
* 组织机构
*/
@Column(name = "org_code")
private String orgCode;
/**
* 是否已读
*/
@Column(name = "is_read")
private boolean isRead = false;
/**
* 接收消息电话号码
*/
@Column(name = "target_tel")
private String targetTel;
/**
* 创建者
*/
@Column(name = "create_by")
private Long createBy;
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getBody() {
return body;
}
public void setBody(String body) {
this.body = body;
}
public String getMsgType() {
return msgType;
}
public void setMsgType(String msgType) {
this.msgType = msgType;
}
public int getStatus() {
return status;
}
public void setStatus(int status) {
this.status = status;
}
public Date getSendTime() {
return sendTime;
}
public void setSendTime(Date sendTime) {
this.sendTime = sendTime;
}
public Long getRelationId() {
return relationId;
}
public void setRelationId(Long relationId) {
this.relationId = relationId;
}
public boolean getIsImmediately() {
return isImmediately;
}
public void setIsImmediately(boolean isImmediately) {
this.isImmediately = isImmediately;
}
public Date getFixedTime() {
return fixedTime;
}
public void setFixedTime(Date fixedTime) {
this.fixedTime = fixedTime;
}
public String getOrgCode() {
return orgCode;
}
public void setOrgCode(String orgCode) {
this.orgCode = orgCode;
}
public boolean getIsRead() {
return isRead;
}
public void setIsRead(boolean isRead) {
this.isRead = isRead;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getTargetTel() {
return targetTel;
}
public void setTargetTel(String targetTel) {
this.targetTel = targetTel;
}
public Long getCreateBy() {
return createBy;
}
public void setCreateBy(Long createBy) {
this.createBy = createBy;
}
@Transient
public String getPushBody() {
return pushBody;
}
public void setPushBody(String pushBody) {
this.pushBody = pushBody;
}
public String getReciverName() {
return reciverName;
}
public void setReciverName(String reciverName) {
this.reciverName = reciverName;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/dao/entity/MsgSubscribe.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.dao.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.NamedQuery;
import javax.persistence.Table;
/**
* 消息订阅设置实体
*
* @author gaodongdong
*/
@TableName("p_msg_subscribe")
public class MsgSubscribe extends BasicEntity {
/**
*
*/
private static final long serialVersionUID = -3679029984718140789L;
@Column(name = "org_code")
private String orgCode; // 公司ID
@Column(name = "user_id")
private String userId; // 用户ID
@Column(name = "msg_type")
private String msgType; // 消息类型
@Column(name = "attribute1")
private String attribute1; // 消息属性
@Column(name = "attribute2")
private String attribute2;
@Column(name = "attribute3")
private String attribute3;
@Column(name = "attribute4")
private String attribute4;
@Column(name = "attribute5")
private String attribute5;
public String getOrgCode() {
return orgCode;
}
public void setOrgCode(String orgCode) {
this.orgCode = orgCode;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getMsgType() {
return msgType;
}
public void setMsgType(String msgType) {
this.msgType = msgType;
}
public String getAttribute1() {
return attribute1;
}
public void setAttribute1(String attribute1) {
this.attribute1 = attribute1;
}
public String getAttribute2() {
return attribute2;
}
public void setAttribute2(String attribute2) {
this.attribute2 = attribute2;
}
public String getAttribute3() {
return attribute3;
}
public void setAttribute3(String attribute3) {
this.attribute3 = attribute3;
}
public String getAttribute4() {
return attribute4;
}
public void setAttribute4(String attribute4) {
this.attribute4 = attribute4;
}
public String getAttribute5() {
return attribute5;
}
public void setAttribute5(String attribute5) {
this.attribute5 = attribute5;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/pom.xml 0 → 100644
View file @ 6ae99059
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>amos-boot-module-biz</artifactId>
<groupId>com.amosframework.boot</groupId>
<version>1.0.0</version>
</parent>
<artifactId>amos-boot-module-latentdanger-biz</artifactId>
<dependencies>
<dependency>
<groupId>com.amosframework.boot</groupId>
<artifactId>amos-boot-module-latentdanger-api</artifactId>
<version>${amos-biz-boot.version}</version>
</dependency>
<dependency>
<groupId>com.amosframework.boot</groupId>
<artifactId>amos-boot-module-common-api</artifactId>
<version>${amos-biz-boot.version}</version>
</dependency>
<dependency>
<groupId>com.yeejoin</groupId>
<artifactId>amos-component-rule</artifactId>
<exclusions>
<exclusion>
<groupId>org.typroject</groupId>
<artifactId>tyboot-core-auth</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
<exclusions>
<exclusion>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-jdbc</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- 添加fastjson 依赖包. -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/com.google.zxing/core -->
<dependency>
<groupId>com.google.zxing</groupId>
<artifactId>core</artifactId>
<version>3.3.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.google.zxing/javase -->
<dependency>
<groupId>com.google.zxing</groupId>
<artifactId>javase</artifactId>
<version>3.3.0</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<version>3.11.1</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>3.15</version>
</dependency>
<dependency>
<groupId>fr.opensagres.xdocreport</groupId>
<artifactId>xdocreport</artifactId>
<version>1.0.6</version>
</dependency>
<dependency>
<groupId>org.apache.tika</groupId>
<artifactId>tika-core</artifactId>
<version>1.13</version>
</dependency>
<dependency>
<groupId>org.apache.tika</groupId>
<artifactId>tika-parsers</artifactId>
<version>1.13</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
<dependency>
<groupId>cn.jpush.api</groupId>
<artifactId>jpush-client</artifactId>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.5.1</version>
</dependency>
<dependency>
<groupId>org.liquibase</groupId>
<artifactId>liquibase-core</artifactId>
</dependency>
</dependencies>
</project>
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dao/mapper/BaseMapper.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dao.mapper;
import org.apache.ibatis.annotations.Mapper;
/**
* @author DELL
*/
@Mapper
public interface BaseMapper extends com.baomidou.mybatisplus.core.mapper.BaseMapper {
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dao/mapper/LatentDangerFlowRecordMapper.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dao.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.extend.LatentDangerFlowRecordBo;
import com.yeejoin.amos.latentdanger.business.vo.DangerTimeAxisVo;
import com.yeejoin.amos.latentdanger.dao.entity.LatentDangerFlowRecord;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
public interface LatentDangerFlowRecordMapper extends BaseMapper<LatentDangerFlowRecord> {
Integer save(LatentDangerFlowRecordBo latentDangerFlowRecordBo);
LatentDangerFlowRecordBo getByDangerIdAndActionFlag(@Param("dangerId") Long dangerId, @Param("actionFlag") String actionFlag);
LatentDangerFlowRecordBo getByDangerIdAndCreate(@Param("dangerId") Long dangerId);
LatentDangerFlowRecordBo getById(Long id);
List<LatentDangerFlowRecordBo> listPassByDangerId(Long dangerId);
Integer update(LatentDangerFlowRecordBo latentDangerFlowRecordBo);
LatentDangerFlowRecordBo getNewestRecordByDangerId(Long dangerId);
List<LatentDangerFlowRecordBo> listNewestRecordByDangerIds(List<Long> dangerIds);
List<LatentDangerFlowRecordBo> listByDangerId(Long dangerId);
void deleteByLatentDangerIds(List<Long> dangerIds);
List<DangerTimeAxisVo> listExecuteLog(Map<String, Object> map);
LatentDangerFlowRecordBo getByIdOderByDate(Long dangerId);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dao/mapper/LatentDangerMapper.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dao.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.extend.LatentDangerBo;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.extend.LatentDangerNoticeBo;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerListParam;
import com.yeejoin.amos.latentdanger.business.param.PageParam;
import com.yeejoin.amos.latentdanger.core.common.response.DangerListResponse;
import com.yeejoin.amos.latentdanger.dao.entity.LatentDanger;
import org.apache.ibatis.annotations.Param;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public interface LatentDangerMapper extends BaseMapper<LatentDanger> {
Integer save(LatentDangerBo latentDangerBo);
List<LatentDangerBo> listByMap(Map<String, Object> map);
Long countByMap(Map<String, Object> map);
LatentDangerBo getById(Long id);
Integer update(LatentDangerBo latentDangerBo);
LatentDangerBo getByInstanceId(String instanceId);
List<LatentDangerBo> listOfOvertime();
Integer countNotFinishByFlowId(String flowId);
List<LatentDangerBo> listNotFinishByPointId(HashMap<String, Object> params);
Long countByFlowUserIds(String userId);
Long countNotFinishByTypeAndDeptId(@Param("type") Integer type, @Param("departmentId") String departmentId);
String getNotFinishIdsByTypeAndDeptId(@Param("type") Integer type, @Param("departmentId") String departmentId);
void deleteByIds(List<Long> dangerIds);
/**
* 查询治理期限即将到期的隐患
*
* @return
*/
List<LatentDangerNoticeBo> listNeedNoticeDanger();
/**
* 根据隐患id获取评审信息
*
* @param dangerId
* @return
*/
List<HashMap<String, Object>> getReViewInfo(Long dangerId);
List<DangerListResponse> dangerListByMap(PageParam pageParam);
Long countDangerListByMap(PageParam pageParam);
List<LatentDangerBo> getByBathBusinessKeys(@Param("businessKeys") List<String> businessKeys, @Param("latentDangerListParam") LatentDangerListParam latentDangerListParam);
int countByBathBusinessKeys(@Param("businessKeys") List<String> businessKeys, @Param("latentDangerListParam") LatentDangerListParam latentDangerListParam);
int countByStatus(@Param("businessKeys") List<String> businessKeys);
void updateCheckInputDangerState(@Param("id") Long id, @Param("code") int code);
LatentDangerBo getbyBusinessKey(@Param("businessKey") String businessKey);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dao/mapper/LatentDangerPatrolMapper.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dao.mapper;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.extend.LatentDangerPatrolBo;
import java.util.List;
import java.util.Map;
public interface LatentDangerPatrolMapper extends BaseMapper {
Integer save(LatentDangerPatrolBo latentDangerPatrolBo);
LatentDangerPatrolBo getByDangerId(Long dangerId);
List<LatentDangerPatrolBo> listByMap(Map<String, Object> map);
List<LatentDangerPatrolBo> listByPointId(Long pointId);
List<LatentDangerPatrolBo> queryByPointClassifyIds(List<String> pointClassifyIds);
void deleteByLatentDangerIds(List<Long> latentDangerIds);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dao/mapper/MsgMapper.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dao.mapper;
import java.util.List;
import java.util.Map;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.CheckMsgBo;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.PushTargetBo;
import org.apache.ibatis.annotations.Param;
public interface MsgMapper extends BaseMapper{
public List<PushTargetBo> getAppPushTargetBo(@Param(value="userId")String userId, @Param(value="checkType")String checkType,
@Param(value="routeId")Long routeId);
public List<PushTargetBo> getEmailPushTargetBo(@Param(value="userId")String userId, @Param(value="checkEmail")String checkEmail,
@Param(value="routeId")Long routeId);
public List<PushTargetBo> getPushUserBo(@Param(value="type")String type, @Param(value="userIds")String userIds,
@Param(value="routeId")Long routeId, @Param(value="checkType")String checkType);
/**
* 根据巡检id获取巡检详情
* @param checkId
* @return
*/
public CheckMsgBo getCheckMsgBos(@Param(value="checkId")Long checkId);
/**
* 根据巡检记录ID获取对应点和路线的负责人ID
*
* @param checkId
* @return
*/
public Map<String, Object> getChargerId(@Param(value="checkId")Long checkId);
/**
* 根据巡检记录ID获取对应点和路线的负责人ID
*
* @param checkId
* @return
*/
public List getChargerIds(@Param(value="checkId")Long checkId);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dto/DangerExecuteSubmitDto.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dto;
import com.yeejoin.amos.latentdanger.common.enums.LatentDangerExecuteTypeEnum;
import lombok.Data;
/**
* @author DELL
*/
@Data
public class DangerExecuteSubmitDto extends ExecuteSubmitDto {
private String pointOriginalId;
private Long pointId;
private String dangerName;
private Long dangerId;
private LatentDangerExecuteTypeEnum executeTypeEnum;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/dto/ExecuteSubmitDto.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.dto;
import lombok.Data;
/**
* @author DELL
*/
@Data
public class ExecuteSubmitDto {
private Boolean isOk;
private String msg;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/CheckMsgBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
public class CheckMsgBo {
/**
* 检查id
*/
private long checkId;
/**
* 执行人
*/
private String userId;
private String name;
private String orgCode;
/**
* 检查状态
*/
private String status;
/**
* 路线id
*/
private long routeId;
/**
* 点id
*/
private long pointId;
/**
* 存储消息内容
*/
private String saveMsg;
/**
* 发送消息内容
*/
private String pushMsg;
/**
* 建筑地址id
*/
private String riskSourceId;
public long getCheckId() {
return checkId;
}
public void setCheckId(long checkId) {
this.checkId = checkId;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public long getRouteId() {
return routeId;
}
public void setRouteId(long routeId) {
this.routeId = routeId;
}
public String getSaveMsg() {
return saveMsg;
}
public void setSaveMsg(String saveMsg) {
this.saveMsg = saveMsg;
}
public String getPushMsg() {
return pushMsg;
}
public void setPushMsg(String pushMsg) {
this.pushMsg = pushMsg;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getOrgCode() {
return orgCode;
}
public void setOrgCode(String orgCode) {
this.orgCode = orgCode;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public long getPointId() {
return pointId;
}
public void setPointId(long pointId) {
this.pointId = pointId;
}
public String getRiskSourceId() {
return riskSourceId;
}
public void setRiskSourceId(String riskSourceId) {
this.riskSourceId = riskSourceId;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/DangerResultBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
import lombok.Data;
/**
* @author keyong
* @title: DangerResultBo
* <pre>
* @description: TODO
* </pre>
* @date 2021/2/1 20:19
*/
@Data
public class DangerResultBo {
private int state;
private String orgCode;
private String userName;
private Long inputItemId;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/DictBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
import lombok.Data;
@Data
public class DictBo {
private String dictDataValue;
private String dictCode;
private int orderNum;
private String dictDataKey;
private String applicationCode;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/LatentDangerFlowRecordBoExtend.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
import lombok.Data;
@Data
public class LatentDangerFlowRecordBoExtend {
private String executeDepartmentName = "";
private String executeUserName;
private String executeTime;
private Integer dangerOvertimeState;
private Integer dangerState;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/LatentDangerPatrolBoExtend.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
import lombok.Data;
@Data
public class LatentDangerPatrolBoExtend {
private String itemName;
private String itemBasis;
private String pointName;
private String pointLevel;
private String pointNo;
private String planName;
private String planType;
private String routeName;
private String itemRemark;
private String checkTime;
private String checkUserId;
private String classifyName;
private String pointDepartMentId;
private String classifyOriginalId;
private String pointOriginalId;
private String itemOriginalId;
private Integer executeRate;
private String checkDepartmentId;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/PushTargetBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis;
public class PushTargetBo {
private String userId;
private String orgCode;
private String name;
private String username;
private String email;
public String getOrgCode() {
return orgCode;
}
public void setOrgCode(String orgCode) {
this.orgCode = orgCode;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/extend/LatentDangerBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis.extend;
import lombok.Data;
import java.util.Date;
/**
* 隐患表
*
* @author DELL
*/
@Data
public class LatentDangerBo {
/**
* 主键自增
*/
private Long id;
/**
* 业务唯一标识
*/
private String businessKey;
/**
* 公司组织机构
*/
private String orgCode;
/**
* 隐患名称
*/
private String dangerName;
private String instanceId;
private Long currentFlowRecordId;
/**
* 隐患等级（1：一般隐患；2：重大隐患；0：安全问题）
*/
private String dangerLevel;
/**
* 隐患地点
*/
private String dangerPosition;
/**
* 隐患类型（1：普通隐患；2：巡检隐患）
*/
private String dangerType;
/**
* 备注
*/
private String remark;
/**
* 整改类型（1：常规整改；2：安措计划；3：延期整改）
*/
private String reformType;
/**
* 限制时间
*/
private Date reformLimitDate;
private Integer overtimeState;
private String reformJson;
/**
* 隐患状态（1：待评审；2：待治理；3：安措计划中；4：逾期未治理；5：待验证；6：治理完毕；7：已撤销）
*/
private String dangerState;
/**
* 发现人
*/
private String discovererUserId;
private String discovererDepartmentId;
private String photoUrls;
/**
* 是否删除（0：否；1：是）
*/
private Integer deleted;
/**
* 记录创建时间
*/
private Date createDate;
/**
* 记录修改时间
*/
private Date updateDate;
/**
* 延期治理时间
*/
private Date delayLimitDate;
/**
* 问题描述
*/
private String problemDescription;
/**
* 原因分析
*/
private String reasonAnalysis;
/**
* 举一反三
*/
private String inferOtherThings;
/**
* 检查记录创建的隐患检查项对应id
*/
private Long bizId;
/**
* 建筑id
*/
private Long structureId;
/**
* 建筑名称
*/
private String structureName;
private String instanceKey;
/**
* 业务类型（不同业务创建的隐患以此区分:巡检隐患、防火监督隐患、其他隐患。。。）
*/
private String bizType;
/**
* 经度
*/
private String longitude;
/**
* 纬度
*/
private String latitude;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/extend/LatentDangerFlowRecordBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis.extend;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.LatentDangerFlowRecordBoExtend;
import lombok.Data;
import java.util.Date;
@Data
public class LatentDangerFlowRecordBo extends LatentDangerFlowRecordBoExtend {
private Long id;
private Long dangerId;
private String actionFlag;
private String flowTaskName;
private String flowTaskUserIds;
private String flowTaskId;
private Integer executeState;
private String executeUserId;
private String executeResult;
private String remark;
private String flowJson;
/**
* 是否删除（0：否；1：是）
*/
private Integer deleted;
/**
* 记录创建时间
*/
private Date createDate;
/**
* 记录修改时间
*/
private Date updateDate;
private String excuteDepartmentId;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/extend/LatentDangerNoticeBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis.extend;
import java.util.Date;
public class LatentDangerNoticeBo {
/**
* 隐患id
*/
private Long dangerId;
private String orgCode;
/**
* 隐患状态
*/
private Integer dangerState;
/**
* 隐患名称
*/
private String dangerName;
/**
* 治理期限
*/
private Date reformLimitDate;
/**
* 消息接收人（隐患治理人）
*/
private String receiverIds;
private String instanceId;
public String getInstanceId() {
return instanceId;
}
public void setInstanceId(String instanceId) {
this.instanceId = instanceId;
}
public Long getDangerId() {
return dangerId;
}
public void setDangerId(Long dangerId) {
this.dangerId = dangerId;
}
public String getOrgCode() {
return orgCode;
}
public void setOrgCode(String orgCode) {
this.orgCode = orgCode;
}
public Integer getDangerState() {
return dangerState;
}
public void setDangerState(Integer dangerState) {
this.dangerState = dangerState;
}
public String getDangerName() {
return dangerName;
}
public void setDangerName(String dangerName) {
this.dangerName = dangerName;
}
public Date getReformLimitDate() {
return reformLimitDate;
}
public void setReformLimitDate(Date reformLimitDate) {
this.reformLimitDate = reformLimitDate;
}
public String getReceiverIds() {
return receiverIds;
}
public void setReceiverIds(String receiverIds) {
this.receiverIds = receiverIds;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/entity/mybatis/extend/LatentDangerPatrolBo.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.entity.mybatis.extend;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.LatentDangerPatrolBoExtend;
import lombok.Data;
import java.util.Date;
/**
* 隐患巡检关系表
*/
@Data
public class LatentDangerPatrolBo extends LatentDangerPatrolBoExtend {
private Long id;
private Long latentDangerId;
private Long pointClassifyId;
private Long checkId;
private Long itemId;
private Long pointId;
private Long routeId;
private String riskFactorFlowId;
private Long routePointItemId;
/**
* 是否删除（0：否；1：是）
*/
private Integer deleted;
/**
* 检查类型-交大字段，只是前段显示用
*/
private String checkType;
/**
* 记录创建时间
*/
private Date createDate;
/**
* 记录修改时间
*/
private Date updateDate;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/feign/Business.java 0 → 100644
View file @ 6ae99059
//package com.yeejoin.amos.latentdanger.business.feign;
//
//import com.yeejoin.amos.latentdanger.business.entity.mybatis.DangerResultBo;
//import com.yeejoin.amos.latentdanger.business.util.CommonResponse;
//import org.springframework.cloud.openfeign.FeignClient;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//
//@FeignClient(name = "${Business.fegin.name}", configuration = FeignConfiguration.class)
//public interface Business {
//
// /**
// * <pre>
// * @Description: 隐患治理完成更新rpn值
// * </pre>
// *
// * @MethodName:
// * @Param:
// * @Return: null
// * @Throws
// * @Author keyong
// * @Date 2021/2/4 20:55
// */
// @PostMapping(value = "/fireAutoSys/api/risksource/data/danger/state")
// CommonResponse processProtalDataFromDanger(@RequestBody DangerResultBo data);
//}
\ No newline at end of file
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/feign/EquipFeign.java 0 → 100644
View file @ 6ae99059
//package com.yeejoin.amos.latentdanger.business.feign;
//
//import org.springframework.cloud.openfeign.FeignClient;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RequestMethod;
//import org.springframework.web.bind.annotation.RequestParam;
//
//import java.util.LinkedHashMap;
//
////装备
//@FeignClient(name = "${equip.fegin.name}")
//public interface EquipFeign {
// @RequestMapping(value = "${equip.fegin.prefix}" + "/equipSpecific/getSourceNameByEquipSpeId", method = RequestMethod.GET, consumes = "application/json")
// LinkedHashMap<String, Object> getEquipDetail(@RequestParam(value = "id", required = true) Long id);
//
// @RequestMapping(value = "${equip.fegin.prefix}" + "/equipSpecific/getSourceNameList", method = RequestMethod.POST, consumes = "application/json")
// LinkedHashMap<String, Object> getEquipList(@RequestBody Long id);
//
// @RequestMapping(value = "${equip.fegin.prefix}" + "/warehouse-structure/listAll", method = RequestMethod.GET, consumes = "application/json")
// String getStructureNameAll();
//
// /**
// * 消防建筑树
// *
// * @return
// */
// @RequestMapping(value = "${equip.fegin.prefix}" + "/building/tree", method = RequestMethod.GET, consumes = "application/json")
// LinkedHashMap<String, Object> getBuildingTree();
//
// @RequestMapping(value = "${equip.fegin.prefix}" + "/building/getBuildingAbsolutePosition", method = RequestMethod.GET, consumes = "application/json")
// LinkedHashMap<String, Object> getBuildingAbsolutePosition();
//
// /**
// * 所属局域树
// *
// * @return
// */
// @RequestMapping(value = "${equip.fegin.prefix}" + "/area/tree", method = RequestMethod.GET, consumes = "application/json")
// LinkedHashMap<String, Object> getRegionTress();
//}
//
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/feign/FeignBasicAuthRequestInterceptor.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.feign;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
public class FeignBasicAuthRequestInterceptor implements RequestInterceptor {
public FeignBasicAuthRequestInterceptor() {
}
@Override
public void apply(RequestTemplate template) {
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
if (requestAttributes == null) {
return;
}
ServletRequestAttributes attributes = (ServletRequestAttributes) requestAttributes;
HttpServletRequest request = attributes.getRequest();
//设置header
String token = request.getHeader("X-Access-Token");
String product = request.getHeader("product");
String appKey = request.getHeader("appKey");
template.header("token", token);
template.header("product", product);
template.header("appKey", appKey);
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/feign/FeignConfiguration.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.feign;
import feign.codec.Encoder;
import feign.form.spring.SpringFormEncoder;
import org.springframework.beans.factory.ObjectFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.cloud.openfeign.support.SpringEncoder;
import org.springframework.context.annotation.Bean;
public class FeignConfiguration {
@Autowired
private ObjectFactory<HttpMessageConverters> messageConverters;
@Bean
public Encoder feignFormEncoder() {
return new SpringFormEncoder(new SpringEncoder(messageConverters));
}
@Bean
public FeignBasicAuthRequestInterceptor basicAuthRequestInterceptor() {
return new FeignBasicAuthRequestInterceptor();
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/listeners/LatentDangerListener.java 0 → 100644
View file @ 6ae99059
//package com.yeejoin.amos.latentdanger.business.listeners;
//
//import org.springframework.beans.factory.annotation.Lookup;
//import org.springframework.scheduling.annotation.EnableAsync;
//import org.springframework.stereotype.Component;
//
///**
// * 隐患状态监听器
// *
// * @author DELL
// */
//@Component
//public interface LatentDangerListener {
//
// /**
// * 隐患关闭
// *
// * @param latentDangerId 隐患id
// */
// @Lookup
// void latentDangerClosed(String latentDangerId);
//}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/listeners/LatentDangerListenerImpl.java 0 → 100644
View file @ 6ae99059
//package com.yeejoin.amos.latentdanger.business.listeners;
//
//import com.yeejoin.amos.latentdanger.core.listeners.LatentDangerListener;
//import org.springframework.scheduling.annotation.EnableAsync;
//import org.springframework.stereotype.Component;
//
///**
// * 隐患状态监听器
// *
// * @author DELL
// */
//public class LatentDangerListenerImpl implements LatentDangerListener {
//
// /**
// * 隐患关闭
// *
// * @param latentDangerId 隐患id
// */
// @Override
// public void latentDangerClosed(String latentDangerId) {
//
// };
//}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/JPushTypeEnum.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
/**
* JPush 推送类型
* @author maoying
*
*/
public enum JPushTypeEnum {
ALL("广播","1"),
TAG("标签","2" ),
ALIAS("别名", "3");
/**
* 名称，描述
*/
private String name;
/**
* 编码
*/
private String code;
private JPushTypeEnum(String name, String code){
this.name = name;
this.code = code;
}
public static JPushTypeEnum getEnum(String code) {
JPushTypeEnum jPushTypeEnum = null;
for(JPushTypeEnum type: JPushTypeEnum.values()) {
if (type.getCode().equals(code)) {
jPushTypeEnum = type;
break;
}
}
return jPushTypeEnum;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/LatentDangerDto.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import lombok.Data;
import javax.persistence.Column;
import java.util.List;
/**
* @author tb
* @title: LatentDangerDto
* <pre>
* @description: TODO
* </pre>
* @date 2021/1/26 14:48
*/
@Data
public class LatentDangerDto {
/**
* 隐患等级（1：一般隐患；2：重大隐患；0：安全问题）
*/
private String dangerLevel;
/**
* 隐患等级名称
*/
private String dangerLevelName;
/**
* 问题描述
*/
private String remark;
/**
* 创建隐患的业务id（p_check_input）
*/
private Long bizId;
/**
* 建筑id
*/
private Long structureId;
/**
* 建筑名称
*/
private String structureName;
private String instanceKey;
/**
* 隐患名称
*/
private String name;
/**
* 整改日期
*/
private String reformLimitDate;
/**
* 经度
*/
private String longitude;
/**
* 纬度
*/
private String latitude;
/**
* 隐患图片列表
*/
private List<String> photoUrl;
/**
* 检查项名称
*/
private String inputItemName;
/**
* 风险点id
*/
private String riskSourceId;
/**
* 隐患地址
*/
private String dangerPosition;
/**
* 治理方式
*/
private String reformType;
/**
* 治理方式名称
*/
private String reformTypeName;
/**
* 是否删除（0未删除、1已删除）
*/
private Boolean deleted = false;
/**
* 主键
*/
private Long id;
/**
* 隐患状态
*/
private String dangerState;
/**
* 隐患状态名称
*/
private String dangerStateName;
/**
* 业务类型（不同业务创建的隐患以此区分:巡检隐患、防火监督隐患、其他隐患。。。）
*/
private String bizType;
/**
* 检查类型（1无码检查、2计划检查、3无计划检查、4随手拍）
*/
private String checkMode;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/LatentDangerExecuteParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import com.alibaba.fastjson.JSONObject;
import lombok.Data;
/**
* @author DELL
*/
@Data
public class LatentDangerExecuteParam {
/**
* 隐患工作流记录id
*/
private Long flowRecordId;
/**
* 任务id
*/
private String taskId;
/**
* 执行类型
*/
private Integer executeType;
/**
* 备注
*/
private String remark;
/**
* 可执行人
*/
private String nextCanActionUser;
/**
* 整改日期
*/
private String reformLimitDate;
private JSONObject flowJson;
/**
* 整改延期日期
*/
private String delayLimitDate;
/**
* 隐患id
*/
private Long dangerId;
/**
* 延期治理是否需要公司审核
*/
private Integer needCompanyVerify;
/**
* 原因分析
*/
private String reasonAnalysis;
/**
* 举一反三
*/
private String inferOtherThings;
/**
*问题描述
*/
private String problemDescription;
/**
* 隐患等级
*/
private String dangerLevel;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/LatentDangerListParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import com.yeejoin.amos.latentdanger.core.common.request.CommonPageable;
import lombok.Data;
/**
* @author keyong
* @title: LatentDangerListParam
* <pre>
* @description: TODO
* </pre>
* @date 2021/1/26 14:49
*/
@Data
public class LatentDangerListParam extends CommonPageable {
/**
* 0:全部；1：我的
*/
private Integer belongType;
/**
* 0:全部；1：待评审；2：待治理；3：安措计划中；4：待验证；5：治理完毕；6：已撤销；7：延期治理中；8：延期治理待车间部门审核；9：延期治理待公司审核
*/
private Integer dangerState;
/**
* 是否已处理（1：是；2：否）
*/
private Boolean isHandle;
/**
* -1:全部；1：一般隐患；2：重大隐患；0：安全问题
*/
private Integer dangerLevel;
private String dangerName;
private String userId;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/LatentDangerNormalParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import lombok.Data;
import java.util.List;
/**
* @author keyong
* @title: LatentDangerNormalParam
* <pre>
* @description: 隐患
* </pre>
* @date 2021/1/26 14:46
*/
@Data
public class LatentDangerNormalParam {
/**
* 隐患名称
*/
private String dangerName;
/**
* 隐患等级（1：一般隐患；2：重大隐患；3：安全问题）
*/
private String dangerLevel;
/**
* 隐患地点
*/
private String dangerPosition;
/**
* 备注
*/
private String remark;
/**
* 拍照路径集合（多个逗号分开）
*/
private List<String> photoUrl;
/**
* 建筑id
*/
private Long structureId;
/**
* 建筑名称
*/
private String structureName;
/**
* 隐患地址经度
*/
private String longitude;
/**
* 隐患地址纬度
*/
private String latitude;
/**
* 业务类型（不同业务创建的隐患以此区分:巡检隐患、防火监督隐患、其他隐患。。。）
*/
private String bizType;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/LatentDangerPatrolParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import lombok.Data;
import java.util.List;
/**
* @author keyong
* @title: LatentDangerPatrolParam
* <pre>
* @description: TODO
* </pre>
* @date 2021/1/26 14:47
*/
@Data
public class LatentDangerPatrolParam {
private List<LatentDangerDto> dangerList;
/**
* 业务类型（不同业务创建的隐患以此区分:巡检隐患、防火监督隐患、其他隐患。。。）
*/
private String bizType;
/**
* 检查类型（1无码检查、2计划检查、3无计划检查、4随手拍）
*/
private String checkMode;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/PageParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import java.util.HashMap;
public class PageParam<K, V> extends HashMap<K, V> implements Pageable {
/**
* 页号（大于等于0）
*/
protected int pageNumber = 0;
/**
* 每页大小（大于等于0）
*/
protected int pageSize = 10;
/**
* 起始索引
*/
protected int offset = 0;
/**
* 排序
*/
protected Sort sort = null;
public PageParam() {
this.pageNumber = 0;
this.pageSize = 10;
this.offset = pageSize * pageNumber;
}
public PageParam(int pageNumber, int pageSize) {
this.pageNumber = pageNumber;
this.pageSize = pageSize;
this.offset = pageSize * pageNumber;
}
public PageParam(int pageNumber, int pageSize, Sort sort) {
this.pageNumber = pageNumber;
this.pageSize = pageSize;
this.sort = sort;
this.offset = pageSize * pageNumber;
}
public int getPageNumber() {
return this.pageNumber;
}
public int getPageSize() {
return pageSize;
}
public long getOffset() {
offset = pageSize * pageNumber;
return offset;
}
public Sort getSort() {
return sort;
}
public Pageable next() {
return null;
}
public Pageable previousOrFirst() {
return null;
}
public Pageable first() {
return null;
}
public boolean hasPrevious() {
return false;
}
public void setPageNumber(int pageNumber) {
this.pageNumber = pageNumber;
}
public void setPageSize(int pageSize) {
this.pageSize = pageSize;
}
public void setSort(Sort sort) {
this.sort = sort;
}
public void setOffset(int offset) {
this.offset = offset;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/param/PushMsgParam.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.param;
import java.util.List;
import java.util.Map;
public class PushMsgParam {
/**
* 标题
*/
private String subject;
/**
* 消息内容
*/
private String content;
/**
* 邮件地址
*/
private String[] emails;
/**
* jpush接收人
*/
private List<String> recivers;
//
/**
* jpush参数传递
*/
Map<String, String> extras;
/**
* jpush发送类型：1：广播；2：标签；3：别名
*/
private String type = "3";
private String relationId;
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public List<String> getRecivers() {
return recivers;
}
public void setRecivers(List<String> recivers) {
this.recivers = recivers;
}
public Map<String, String> getExtras() {
return extras;
}
public void setExtras(Map<String, String> extras) {
this.extras = extras;
}
public String getSubject() {
return subject;
}
public void setSubject(String subject) {
this.subject = subject;
}
public String[] getEmails() {
return emails;
}
public void setEmails(String[] emails) {
this.emails = emails;
}
public String getRelationId() {
return relationId;
}
public void setRelationId(String relationId) {
this.relationId = relationId;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/impl/LatentDangerFlowRecordServiceImpl.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.service.impl;
import com.yeejoin.amos.latentdanger.business.dao.mapper.LatentDangerFlowRecordMapper;
import com.yeejoin.amos.latentdanger.business.entity.mybatis.extend.LatentDangerFlowRecordBo;
import com.yeejoin.amos.latentdanger.business.service.intfc.ILatentDangerFlowRecordService;
import com.yeejoin.amos.latentdanger.dao.entity.LatentDangerFlowRecord;
import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.rdbms.service.BaseService;
/**
* @author DELL
*/
@Service("latentDangerFlowRecordService")
public class LatentDangerFlowRecordServiceImpl extends BaseService<LatentDangerFlowRecordBo, LatentDangerFlowRecord,
LatentDangerFlowRecordMapper> implements ILatentDangerFlowRecordService {
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/intfc/ILatentDangerFlowRecordService.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.service.intfc;
import com.alibaba.fastjson.JSONObject;
import com.yeejoin.amos.boot.biz.common.bo.RoleBo;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
import com.yeejoin.amos.latentdanger.business.dto.DangerExecuteSubmitDto;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerExecuteParam;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerListParam;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerNormalParam;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerPatrolParam;
import com.yeejoin.amos.latentdanger.business.param.PageParam;
import com.yeejoin.amos.latentdanger.business.util.CommonResponse;
import com.yeejoin.amos.latentdanger.business.vo.DangerTimeAxisVo;
import com.yeejoin.amos.latentdanger.core.common.response.DangerListResponse;
import org.springframework.data.domain.Page;
import java.util.List;
/**
* @author tb
* @title: ILatentDangerFlowRecordService
* <pre>
* @description: TODO
* </pre>
* @date 2021/1/26 14:44
*/
public interface ILatentDangerFlowRecordService {
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/intfc/ILatentDangerService.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.service.intfc;
import java.util.List;
import java.util.Map;
import com.yeejoin.amos.feign.systemctl.model.DictionarieValueModel;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerDto;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerExecuteParam;
import com.yeejoin.amos.latentdanger.business.param.PageParam;
import com.yeejoin.amos.latentdanger.common.enums.LatentDangerLevelEnum;
import org.springframework.data.domain.Page;
import com.alibaba.fastjson.JSONObject;
import com.yeejoin.amos.boot.biz.common.bo.RoleBo;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
import com.yeejoin.amos.latentdanger.business.dto.DangerExecuteSubmitDto;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerListParam;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerNormalParam;
import com.yeejoin.amos.latentdanger.business.param.LatentDangerPatrolParam;
import com.yeejoin.amos.latentdanger.business.util.CommonResponse;
import com.yeejoin.amos.latentdanger.business.vo.DangerTimeAxisVo;
import com.yeejoin.amos.latentdanger.core.common.response.DangerListResponse;
/**
* @author keyong
* @title: ILatentDangerService
* <pre>
* @description: TODO
* </pre>
* @date 2021/1/26 14:44
*/
public interface ILatentDangerService {
CommonResponse saveNormal(LatentDangerNormalParam latentDangerParam, String userId, String userRealName,
String departmentId, String departmentName, String companyId, String orgCode, RoleBo role);
CommonResponse savePatrol(List<LatentDangerDto> latentDangerDtoList, String userId, String userRealName,
String departmentId, String departmentName, String companyId, String orgCode, RoleBo role) throws IllegalAccessException, InstantiationException;
CommonResponse list(String toke, String product, String appKey, LatentDangerListParam latentDangerListParam, AgencyUserModel user, String loginOrgCode, String deptId);
/**
* 隐患流程执行
*
* @param latentDangerExecuteParam
* @param userId
* @param userRealName
* @param departmentId
* @param departmentName
* @param role
* @return
*/
DangerExecuteSubmitDto execute(LatentDangerExecuteParam latentDangerExecuteParam, String userId,
String userRealName, String departmentId, String departmentName, RoleBo role);
CommonResponse detail(String id, String userId,boolean isFinish);
CommonResponse getByInstanceId(String instanceId);
DangerExecuteSubmitDto executeCallBack(String instanceId, Integer actionType, String remark, String token, String userId,
String userRealName, String departmentId, String departmentName);
void updateDangerStateOfOvertime();
CommonResponse listFlowRecord(String token, String product, String appKey, Long id);
void sendLatentDangerExecuteResult(DangerExecuteSubmitDto executeSubmitDto);
void freshRiskJudgmentLangerCount(LatentDangerExecuteParam latentDangerExecuteParam);
/**
* 获取隐患等级字典值
*
* @return
*/
List<DictionarieValueModel> getDangerLevel();
/**
* 获取隐患治理方式字典值
*
* @return
*/
List<DictionarieValueModel> getDangerGovernance();
// /**
// * 根据等级字符串获取等级字典对象
// *
// * @param dangerLevelStr 等级（"1","2","0"）
// * @return
// */
// JSONObject getDangerLevelJsonObject(String dangerLevelStr, String token, String product, String appKey, String dictCode);
/**
* 根据隐患id获取评审信息
*
* @param dangerId
* @return
*/
JSONObject getReviewInfo(Long dangerId);
Page<DangerListResponse> listDanger(PageParam pageParam);
List<DangerListResponse> export(PageParam pageParam);
List<DangerTimeAxisVo> queryExecuteLog(Integer dateTime);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/intfc/IMessageService.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.service.intfc;
import com.yeejoin.amos.latentdanger.dao.entity.Msg;
public interface IMessageService {
/**
* 消息公告推送
*
* @param msg
*/
Msg pushMsgAndSave(String toke, String product, String appKey, Msg msg);
void pushMsg(String toke, String product, String appKey, com.yeejoin.amos.latentdanger.business.param.PushMsgParam pmsg);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/service/intfc/IMsgSubscribeService.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.service.intfc;
import java.util.List;
import org.springframework.data.domain.Page;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
import com.yeejoin.amos.latentdanger.business.util.DaoCriteria;
import com.yeejoin.amos.latentdanger.core.common.request.CommonPageable;
import com.yeejoin.amos.latentdanger.dao.entity.Msg;
import com.yeejoin.amos.latentdanger.dao.entity.MsgSubscribe;
public interface IMsgSubscribeService {
public List<MsgSubscribe> queryMsgSubscribes(String orgCode, String userId);
public List<MsgSubscribe> queryMsgSubscribes(String userId);
public void saveSubscribe(List<MsgSubscribe> subscribe);
/**
* 根据登陆用户获取未读消息数
* @param user
* @return
*/
public int getUnreadCount(AgencyUserModel user);
/**
* 根据条件获取用户消息列表
* @param criterias
* @param commonPageable
* @return
*/
public Page<Msg> queryMsgList(List<DaoCriteria> criterias,CommonPageable commonPageable);
/**
* 修改消息为已读
* @param msgId
* @return
*/
public Msg isRead(long msgId);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/trigger/ITriggerDataService.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.trigger;
import java.util.HashMap;
public interface ITriggerDataService {
/**
* 判断表类型，进行不同的查询，调用安全进行数据维护
* @param keyMap
* @return
*/
boolean process(HashMap<String,Object> keyMap);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/trigger/TriggerDataServiceImpl.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.trigger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import java.util.HashMap;
@Service("triggerDataService")
public class TriggerDataServiceImpl implements ITriggerDataService {
/**
* 日志记录器
*/
private static final Logger logger = LoggerFactory.getLogger(TriggerDataServiceImpl.class);
@Override
public boolean process(HashMap<String, Object> keyMap) {
return false;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/trigger/TriggerKeyQueue.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.trigger;
import com.yeejoin.amos.latentdanger.context.IotContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.HashMap;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class TriggerKeyQueue {
/**
* 日志记录器
*/
private static final Logger log = LoggerFactory.getLogger(TriggerKeyQueue.class);
/**
* 单例
*/
private static TriggerKeyQueue instance;
/**
* 队列
*/
private static final BlockingQueue<HashMap<String,Object>> blockingQueue = new LinkedBlockingQueue<HashMap<String,Object>>();
/**
* 控制消费者线程运行状态
*/
private static boolean isRunning = true;
/**
* 构造方法
*/
private TriggerKeyQueue() {
}
/**
* 获取单例
*
* @return
*/
public static TriggerKeyQueue getInstance() {
if (instance == null) {
synchronized (TriggerKeyQueue.class) {
if (instance == null) {
instance = new TriggerKeyQueue();
}
}
}
return instance;
}
/**
* 添加数据
*
* @param frame
*/
public void add(HashMap<String,Object> keyMap) {
while (blockingQueue.add(keyMap)) {
log.debug("add a keyMap into blockingQueue successful!");
break;
}
}
public void start() {
Thread thread = new Thread(new TriggerKeyConsumer(), "trigger consumer thread");
thread.start();
}
/**
* 消费者线程
*
* @author as-suhg
*
*/
class TriggerKeyConsumer implements Runnable {
/**
* 1.从队列中取出数据；2.调用业务接口；
*/
@Override
public void run() {
while (isRunning) {
// 1.从队列中取出数据
HashMap<String,Object> keyMap = new HashMap<String,Object>();
try {
keyMap = blockingQueue.take();
} catch (InterruptedException e) {
log.error(e.getMessage(),e);
}
// 2.调用业务接口；
if (keyMap == null||keyMap.isEmpty()) {
log.warn("keyMap is empty!");
} else {
try {
ITriggerDataService triggerDataService = (ITriggerDataService) IotContext.getInstance().getBean(("triggerDataService"));
triggerDataService.process(keyMap);
} catch (Exception e) {
log.error(e.getMessage(),e);
// 失败处理
}
}
}
}
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/AbstractHtml.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
public interface AbstractHtml {
public void createHtml(String inputFile, String outputFile) throws Exception;
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/BeanCopierUtil.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
import org.springframework.cglib.beans.BeanCopier;
import java.util.concurrent.ConcurrentHashMap;
/**
* @Author: xinglei
* @Description:
* @Date: 2020/5/31 21:45
*/
public class BeanCopierUtil {
/**
* BeanCopier的缓存
*/
static final ConcurrentHashMap<String, BeanCopier> BEAN_COPIER_CACHE = new ConcurrentHashMap<>();
/**
* BeanCopier的copy
* @param source 源文件的
* @param target 目标文件
*/
public static void copyProperties(Object source, Object target) {
String key = genKey(source.getClass(), target.getClass());
BeanCopier beanCopier;
if (BEAN_COPIER_CACHE.containsKey(key)) {
beanCopier = BEAN_COPIER_CACHE.get(key);
} else {
beanCopier = BeanCopier.create(source.getClass(), target.getClass(), false);
BEAN_COPIER_CACHE.put(key, beanCopier);
}
beanCopier.copy(source, target, null);
}
/**
* 生成key
* @param srcClazz 源文件的class
* @param tgtClazz 目标文件的class
* @return string
*/
private static String genKey(Class<?> srcClazz, Class<?> tgtClazz) {
return srcClazz.getName() + tgtClazz.getName();
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/CacheFactory.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
//获取对象
public class CacheFactory {
private static CacheMap cacheMap;
private CacheFactory(){
}
public synchronized static CacheMap newChacheMap(){
if(cacheMap==null){
cacheMap=new CacheMap();
}
return cacheMap;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/CacheMap.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
public class CacheMap{
//缓存Map
ConcurrentHashMap<String, CacheValue> cacheMap=new ConcurrentHashMap<String, CacheValue> ();
//保证不能被外界 构造
CacheMap(){
}
public void setex(String key,Toke value,long times){
CacheValue cValue=new CacheValue();
cValue.setTimes(System.currentTimeMillis()+times*1000);
cValue.setValue(value);
cacheMap.put(key, cValue);
}
public Toke getValue(String key){
CacheValue cValue=cacheMap.get(key);
if(cValue!=null && cValue.getTimes()>System.currentTimeMillis()){
return cValue.getValue();
}else if(cValue!=null && cacheMap.containsKey(key)){
//清理一次
cacheMap.remove(key);
}
return null;
}
/**
获取key集合
@return
*/
public Set getKeys(){
return cacheMap.keySet();
}
}
\ No newline at end of file
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/CacheValue.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
public class CacheValue {
private Toke value; //真实数据对象
private long times; //缓存到期时间
public Toke getValue() {
return value;
}
public void setValue(Toke value) {
this.value = value;
}
public long getTimes() {
return times;
}
public void setTimes(long times) {
this.times = times;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/ClazzFieldUtil.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
/**
* <pre>
* 处理反射映射问题
* </pre>
*
* @author wanwei
* @time 2020-6-17 15:43:32
*/
public class ClazzFieldUtil {
public static Field[] getAllFields(Object object){
Class clazz = object.getClass();
List<Field> fieldList = new ArrayList<>();
while (clazz != null){
fieldList.addAll(new ArrayList<>(Arrays.asList(clazz.getDeclaredFields())));
clazz = clazz.getSuperclass();
}
Field[] fields = new Field[fieldList.size()];
fieldList.toArray(fields);
return fields;
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-latentdanger-biz/src/main/java/com/yeejoin/amos/latentdanger/business/util/CommonResponse.java 0 → 100644
View file @ 6ae99059
package com.yeejoin.amos.latentdanger.business.util;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
/**
* <pre>
* 返回封装对象
* </pre>
*
* @author mincx
* @version CommonReponse.java v0.1
* @time 2017-9-19 15:43:32
*/
public class CommonResponse implements Serializable {
private static final long serialVersionUID = -8737351878134480646L;
/**
* 操作状态
*/
@ApiModelProperty(required=true,value="操作状态")
private String result;
/**
* 操作状态
*/
@ApiModelProperty(required=true,value="状态码")
private int status;
/**
* 数据
*/
@ApiModelProperty(required=false,value="数据")
private Object dataList;
/**
* 操作详细信息
*/
@ApiModelProperty(required=false,value="操作详细信息")
private String message;
public CommonResponse(){
}
public CommonResponse(String result) {
this.result = result;
}
public CommonResponse(Object dataList) {
this.dataList = dataList;
this.result = "";
}
public CommonResponse(String result, Object dataList) {
this.dataList = dataList;
this.result = result;
}
public CommonResponse(String result, String message) {
this.result = result;
this.message = message;
}
public CommonResponse(String result, Object dataList, String message) {
this.dataList = dataList;
this.result = result;
this.message = message;
}
public CommonResponse(String result, Object dataList, int status) {
this.dataList = dataList;
this.result = result;
this.status = status;
}
public CommonResponse(String result, String message, int status) {
this.result = result;
this.message = message;
this.status = status;
}
public CommonResponse(String result, Object dataList, String message, int status) {
this.dataList = dataList;
this.result = result;
this.message = message;
this.status = status;
}
public Boolean isSuccess(){
return "SUCCESS".equals(getResult());
}
public String getResult() {
return result;
}
public void setResult(String result) {
this.result = result;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public Object getDataList() {
return dataList;
}
public void setDataList(Object dataList) {
this.dataList = dataList;
}
public void setStatus(int status) {
this.status = status;
}
public int getStatus() {
return status;
}
public String toJsonStr() throws Exception {
return JSON.toJSONString(this,SerializerFeature.WriteMapNullValue,SerializerFeature.DisableCircularReferenceDetect,SerializerFeature.SkipTransientField);
}
}
amos-boot-system-latentdanger/pom.xml 0 → 100644
View file @ 6ae99059
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment