Skip to content

H
hzsomms
Commit 35d3ce25 authored by hkl's avatar hkl
Browse files
Options

feat: 1.车站bug提交

parent b877db1c
Show whitespace changes
Inline Side-by-side
Showing with 1500 additions and 108 deletions
jeecg-boot-base-core/src/main/java/org/jeecg/config/shiro/ShiroConfig.java
View file @ 35d3ce25
...@@ -52,7 +52,7 @@ public class ShiroConfig { ...@@ -52,7 +52,7 @@ public class ShiroConfig {
/** /**
* Filter Chain定义说明 * Filter Chain定义说明
* * <p>
* 1、一个URL可以配置多个Filter，使用逗号分隔 * 1、一个URL可以配置多个Filter，使用逗号分隔
* 2、当设置多个过滤器时，全部验证通过，才视为通过 * 2、当设置多个过滤器时，全部验证通过，才视为通过
* 3、部分过滤器可指定参数，如perms，roles * 3、部分过滤器可指定参数，如perms，roles
...@@ -65,12 +65,12 @@ public class ShiroConfig { ...@@ -65,12 +65,12 @@ public class ShiroConfig {
Map<String, String> filterChainDefinitionMap = new LinkedHashMap<String, String>(); Map<String, String> filterChainDefinitionMap = new LinkedHashMap<String, String>();
//支持yml方式，配置拦截排除 //支持yml方式，配置拦截排除
if(jeecgBaseConfig!=null && jeecgBaseConfig.getShiro()!=null){ if (jeecgBaseConfig != null && jeecgBaseConfig.getShiro() != null) {
String shiroExcludeUrls = jeecgBaseConfig.getShiro().getExcludeUrls(); String shiroExcludeUrls = jeecgBaseConfig.getShiro().getExcludeUrls();
if(oConvertUtils.isNotEmpty(shiroExcludeUrls)){ if (oConvertUtils.isNotEmpty(shiroExcludeUrls)) {
String[] permissionUrl = shiroExcludeUrls.split(","); String[] permissionUrl = shiroExcludeUrls.split(",");
for(String url : permissionUrl){ for (String url : permissionUrl) {
filterChainDefinitionMap.put(url,"anon"); filterChainDefinitionMap.put(url, "anon");
} }
} }
} }
...@@ -124,14 +124,15 @@ public class ShiroConfig { ...@@ -124,14 +124,15 @@ public class ShiroConfig {
filterChainDefinitionMap.put("/sys/annountCement/show/**", "anon"); filterChainDefinitionMap.put("/sys/annountCement/show/**", "anon");
//积木报表排除 //积木报表排除
filterChainDefinitionMap.put("/jmreport/**", "anon"); // filterChainDefinitionMap.put("/jmreport/**", "anon");
filterChainDefinitionMap.put("/**/*.js.map", "anon"); // filterChainDefinitionMap.put("/**/*.js.map", "anon");
filterChainDefinitionMap.put("/**/*.css.map", "anon"); // filterChainDefinitionMap.put("/**/*.css.map", "anon");
filterChainDefinitionMap.put("/test/**", "anon");
//大屏模板例子 //大屏模板例子
filterChainDefinitionMap.put("/test/bigScreen/**", "anon"); // filterChainDefinitionMap.put("/test/bigScreen/**", "anon");
filterChainDefinitionMap.put("/bigscreen/template1/**", "anon"); // filterChainDefinitionMap.put("/bigscreen/template1/**", "anon");
filterChainDefinitionMap.put("/bigscreen/template1/**", "anon"); // filterChainDefinitionMap.put("/bigscreen/template1/**", "anon");
//filterChainDefinitionMap.put("/test/jeecgDemo/rabbitMqClientTest/**", "anon"); //MQ测试 //filterChainDefinitionMap.put("/test/jeecgDemo/rabbitMqClientTest/**", "anon"); //MQ测试
//filterChainDefinitionMap.put("/test/jeecgDemo/html", "anon"); //模板页面 //filterChainDefinitionMap.put("/test/jeecgDemo/html", "anon"); //模板页面
//filterChainDefinitionMap.put("/test/jeecgDemo/redis/**", "anon"); //redis测试 //filterChainDefinitionMap.put("/test/jeecgDemo/redis/**", "anon"); //redis测试
...@@ -155,7 +156,7 @@ public class ShiroConfig { ...@@ -155,7 +156,7 @@ public class ShiroConfig {
Map<String, Filter> filterMap = new HashMap<String, Filter>(1); Map<String, Filter> filterMap = new HashMap<String, Filter>(1);
//如果cloudServer为空 则说明是单体 需要加载跨域配置【微服务跨域切换】 //如果cloudServer为空 则说明是单体 需要加载跨域配置【微服务跨域切换】
Object cloudServer = env.getProperty(CommonConstant.CLOUD_SERVER_KEY); Object cloudServer = env.getProperty(CommonConstant.CLOUD_SERVER_KEY);
filterMap.put("jwt", new JwtFilter(cloudServer==null)); filterMap.put("jwt", new JwtFilter(cloudServer == null));
shiroFilterFactoryBean.setFilters(filterMap); shiroFilterFactoryBean.setFilters(filterMap);
// <!-- 过滤链定义，从上向下顺序执行，一般将/**放在最为下边 // <!-- 过滤链定义，从上向下顺序执行，一般将/**放在最为下边
filterChainDefinitionMap.put("/**", "jwt"); filterChainDefinitionMap.put("/**", "jwt");
...@@ -189,6 +190,7 @@ public class ShiroConfig { ...@@ -189,6 +190,7 @@ public class ShiroConfig {
/** /**
* 下面的代码是添加注解支持 * 下面的代码是添加注解支持
*
* @return * @return
*/ */
@Bean @Bean
...@@ -255,11 +257,11 @@ public class ShiroConfig { ...@@ -255,11 +257,11 @@ public class ShiroConfig {
redisManager.setPassword(lettuceConnectionFactory.getPassword()); redisManager.setPassword(lettuceConnectionFactory.getPassword());
} }
manager = redisManager; manager = redisManager;
}else{ } else {
// redis集群支持，优先使用集群配置 // redis集群支持，优先使用集群配置
RedisClusterManager redisManager = new RedisClusterManager(); RedisClusterManager redisManager = new RedisClusterManager();
Set<HostAndPort> portSet = new HashSet<>(); Set<HostAndPort> portSet = new HashSet<>();
lettuceConnectionFactory.getClusterConfiguration().getClusterNodes().forEach(node -> portSet.add(new HostAndPort(node.getHost() , node.getPort()))); lettuceConnectionFactory.getClusterConfiguration().getClusterNodes().forEach(node -> portSet.add(new HostAndPort(node.getHost(), node.getPort())));
//update-begin--Author:scott Date:20210531 for：修改集群模式下未设置redis密码的bug issues/I3QNIC //update-begin--Author:scott Date:20210531 for：修改集群模式下未设置redis密码的bug issues/I3QNIC
if (oConvertUtils.isNotEmpty(lettuceConnectionFactory.getPassword())) { if (oConvertUtils.isNotEmpty(lettuceConnectionFactory.getPassword())) {
JedisCluster jedisCluster = new JedisCluster(portSet, 2000, 2000, 5, JedisCluster jedisCluster = new JedisCluster(portSet, 2000, 2000, 5,
......
jeecg-module-system/src/main/java/org/jeecg/codegenerate/CodeGenerate.java
View file @ 35d3ce25
...@@ -13,7 +13,7 @@ import java.util.HashMap; ...@@ -13,7 +13,7 @@ import java.util.HashMap;
import java.util.Map; import java.util.Map;
public class CodeGenerate { public class CodeGenerate {
public static String url = "jdbc:mysql://47.94.207.62:3306/hzsomms?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&zeroDateTimeBehavior=convertToNull"; public static String url = "jdbc:mysql://47.94.207.62:3306/hzgw?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&zeroDateTimeBehavior=convertToNull";
public static String username = "root"; public static String username = "root";
public static String password = "superAdmin&321"; public static String password = "superAdmin&321";
...@@ -25,12 +25,11 @@ public class CodeGenerate { ...@@ -25,12 +25,11 @@ public class CodeGenerate {
String outputDir = projectPath + "\\jeecg-module-system\\src\\main\\java\\"; String outputDir = projectPath + "\\jeecg-module-system\\src\\main\\java\\";
// 模块名 // 模块名
String moduleName = "maintenanceWork"; String moduleName = "checkData.equipmentCheckData";
// 表名 // 表名
String[] tables = { String[] tables = {
"t_mw_work_batch", "t_djt_movement_tqi_report_unit_device_map",
"t_mw_work_batch_detail",
}; };
......
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/entity/MovementCheckDataUnitDeviceMap.java
View file @ 35d3ce25
...@@ -85,15 +85,15 @@ public class MovementCheckDataUnitDeviceMap implements Serializable { ...@@ -85,15 +85,15 @@ public class MovementCheckDataUnitDeviceMap implements Serializable {
@TableField("check_id") @TableField("check_id")
private String checkId; private String checkId;
@ApiModelProperty("检查项目id") @ApiModelProperty("检查项目id[注:轨检车是tqi的id]")
@TableField("check_item_id") @TableField("check_item_id")
private String checkItemId; private String checkItemId;
@ApiModelProperty("检查开始里程") @ApiModelProperty("检查开始里程 [注:轨检车和添乘仪此id为null]")
@TableField("check_item_starting_mileage") @TableField("check_item_starting_mileage")
private BigDecimal checkItemStartingMileage; private BigDecimal checkItemStartingMileage;
@ApiModelProperty("检查结束里程") @ApiModelProperty("检查结束里程 [注:轨检车和添乘仪此id为null]")
@TableField("check_item_end_mileage") @TableField("check_item_end_mileage")
private BigDecimal checkItemEndMileage; private BigDecimal checkItemEndMileage;
......
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/entity/MovementOverReportUnitDeviceMap.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Getter;
import lombok.Setter;
/**
* <p>
* 动静态几何尺寸-轨检车单元设备映射
* </p>
*
* @author hkl
* @since 2023-08-22
*/
@Getter
@Setter
@TableName("t_djt_movement_over_report_unit_device_map")
@ApiModel(value = "MovementOverReportUnitDeviceMap对象", description = "动静态几何尺寸-轨检车单元设备映射")
public class MovementOverReportUnitDeviceMap implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty("主键")
@TableId("id")
private String id;
@ApiModelProperty("创建人")
@TableField("create_by")
private String createBy;
@ApiModelProperty("创建日期")
@TableField("create_time")
private Date createTime;
@ApiModelProperty("更新人")
@TableField("update_by")
private String updateBy;
@ApiModelProperty("更新时间")
@TableField("update_time")
private Date updateTime;
@ApiModelProperty("设备单元id")
@TableField("unit_id")
private String unitId;
@ApiModelProperty("设备单元编码")
@TableField("unit_code")
private String unitCode;
@ApiModelProperty("设备单元类型1-钢轨,2-曲线,3-竖曲线,4-道岔")
@TableField("unit_type")
private Integer unitType;
@ApiModelProperty("设备单元类型名称")
@TableField("unit_type_name")
private String unitTypeName;
@ApiModelProperty("设备单元起始里程")
@TableField("unit_starting_mileage")
private BigDecimal unitStartingMileage;
@ApiModelProperty("设备单元中心里程")
@TableField("unit_center_mileage")
private BigDecimal unitCenterMileage;
@ApiModelProperty("设备单元终点里程")
@TableField("unit_end_mileage")
private BigDecimal unitEndMileage;
@ApiModelProperty("检查数据类型 1-人工静态检查 2-轨检仪静态检查 3-轨检车检查 4-添乘仪检查")
@TableField("check_type")
private Integer checkType;
@ApiModelProperty("检查主表id")
@TableField("check_id")
private String checkId;
@ApiModelProperty("轨检车超限表id")
@TableField("over_report_id")
private String overReportId;
@ApiModelProperty("超限里程")
@TableField("over_report_mileage")
private BigDecimal overReportMileage;
@ApiModelProperty("超限类型")
@TableField("over_type")
private String overType;
@ApiModelProperty("超限等级")
@TableField("over_level")
private Integer overLevel;
@ApiModelProperty("峰值（mm或g）")
@TableField("peak_value")
private String peakValue;
@ApiModelProperty("管理数据差")
@TableField("data_difference")
private String dataDifference;
@ApiModelProperty("线性")
@TableField("xianxing")
private String xianxing;
@ApiModelProperty("检测标准")
@TableField("standard")
private String standard;
@ApiModelProperty("速度（km/h）")
@TableField("spend")
private String spend;
@ApiModelProperty("备注")
@TableField("remark")
private String remark;
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/entity/MovementTqiReportUnitDeviceMap.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Getter;
import lombok.Setter;
/**
* <p>
* 轨检车-tqi单元总结报告和单元映射关联关系
* </p>
*
* @author hkl
* @since 2023-08-24
*/
@Getter
@Setter
@TableName("t_djt_movement_tqi_report_unit_device_map")
@ApiModel(value = "MovementTqiReportUnitDeviceMap对象", description = "轨检车-tqi单元总结报告和单元映射关联关系")
public class MovementTqiReportUnitDeviceMap implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty("主键")
@TableId("id")
private String id;
@ApiModelProperty("创建人")
@TableField("create_by")
private String createBy;
@ApiModelProperty("创建日期")
@TableField("create_time")
private Date createTime;
@ApiModelProperty("更新人")
@TableField("update_by")
private String updateBy;
@ApiModelProperty("更新时间")
@TableField("update_time")
private Date updateTime;
@ApiModelProperty("检查主表id")
@TableField("check_id")
private String checkId;
@ApiModelProperty("检查数据类型 1-人工静态检查 2-轨检仪静态检查 3-轨检车检查 4-添乘仪检查")
@TableField("check_type")
private Integer checkType;
@TableField("unit_id")
private String unitId;
@TableField("unit_code")
private String unitCode;
@TableField("unit_type")
private Integer unitType;
@TableField("unit_type_name")
private String unitTypeName;
@TableField("unit_starting_mileage")
private BigDecimal unitStartingMileage;
@TableField("unit_center_mileage")
private BigDecimal unitCenterMileage;
@TableField("unit_end_mileage")
private BigDecimal unitEndMileage;
@ApiModelProperty("tqi报告id")
@TableField("tqi_report_id")
private String tqiReportId;
@ApiModelProperty("开始里程(m)")
@TableField("start_mileage")
private BigDecimal startMileage;
@ApiModelProperty("终点里程(m)")
@TableField("end_mileage")
private BigDecimal endMileage;
@ApiModelProperty("区间名称")
@TableField("section_name")
private String sectionName;
@ApiModelProperty("高低左")
@TableField("high_low_left")
private String highLowLeft;
@ApiModelProperty("高低右")
@TableField("high_low_right")
private String highLowRight;
@ApiModelProperty("轨向左")
@TableField("track_left")
private String trackLeft;
@ApiModelProperty("轨向右")
@TableField("track_right")
private String trackRight;
@ApiModelProperty("水平（mm）")
@TableField("level")
private String level;
@ApiModelProperty("轨距（mm）")
@TableField("track_gauge")
private String trackGauge;
@ApiModelProperty("三角坑（mm）")
@TableField("triangular_pit")
private String triangularPit;
@ApiModelProperty("TQI数值")
@TableField("tqi_come_upon")
private String tqiComeUpon;
@ApiModelProperty("TQI超标")
@TableField("tqi_above_standard")
private String tqiAboveStandard;
@ApiModelProperty("扣分")
@TableField("deduct")
private String deduct;
@ApiModelProperty("检测标准")
@TableField("standard")
private String standard;
@ApiModelProperty("速度（km/h）")
@TableField("spend")
private String spend;
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/mapper/MovementOverReportUnitDeviceMapMapper.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.mapper;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementOverReportUnitDeviceMap;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* <p>
* 动静态几何尺寸-轨检车单元设备映射 Mapper 接口
* </p>
*
* @author hkl
* @since 2023-08-22
*/
public interface MovementOverReportUnitDeviceMapMapper extends BaseMapper<MovementOverReportUnitDeviceMap> {
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/mapper/MovementTqiReportUnitDeviceMapMapper.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.mapper;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementTqiReportUnitDeviceMap;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* <p>
* 轨检车-tqi单元总结报告和单元映射关联关系 Mapper 接口
* </p>
*
* @author hkl
* @since 2023-08-24
*/
public interface MovementTqiReportUnitDeviceMapMapper extends BaseMapper<MovementTqiReportUnitDeviceMap> {
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/mapper/xml/MovementOverReportUnitDeviceMapMapper.xml 0 → 100644
View file @ 35d3ce25
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.jeecg.modules.checkData.equipmentCheckData.mapper.MovementOverReportUnitDeviceMapMapper">
</mapper>
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/mapper/xml/MovementTqiReportUnitDeviceMapMapper.xml 0 → 100644
View file @ 35d3ce25
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.jeecg.modules.checkData.equipmentCheckData.mapper.MovementTqiReportUnitDeviceMapMapper">
</mapper>
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/service/IMovementOverReportUnitDeviceMapService.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.service;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementOverReportUnitDeviceMap;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 动静态几何尺寸-轨检车单元设备映射 服务类
* </p>
*
* @author hkl
* @since 2023-08-22
*/
public interface IMovementOverReportUnitDeviceMapService extends IService<MovementOverReportUnitDeviceMap> {
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/service/IMovementTqiReportUnitDeviceMapService.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.service;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementTqiReportUnitDeviceMap;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 轨检车-tqi单元总结报告和单元映射关联关系 服务类
* </p>
*
* @author hkl
* @since 2023-08-24
*/
public interface IMovementTqiReportUnitDeviceMapService extends IService<MovementTqiReportUnitDeviceMap> {
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/service/impl/MovementOverReportUnitDeviceMapServiceImpl.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.service.impl;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementOverReportUnitDeviceMap;
import org.jeecg.modules.checkData.equipmentCheckData.mapper.MovementOverReportUnitDeviceMapMapper;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementOverReportUnitDeviceMapService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
/**
* <p>
* 动静态几何尺寸-轨检车单元设备映射 服务实现类
* </p>
*
* @author hkl
* @since 2023-08-22
*/
@Service
public class MovementOverReportUnitDeviceMapServiceImpl extends ServiceImpl<MovementOverReportUnitDeviceMapMapper, MovementOverReportUnitDeviceMap> implements IMovementOverReportUnitDeviceMapService {
}
jeecg-module-system/src/main/java/org/jeecg/modules/checkData/equipmentCheckData/service/impl/MovementTqiReportUnitDeviceMapServiceImpl.java 0 → 100644
View file @ 35d3ce25
package org.jeecg.modules.checkData.equipmentCheckData.service.impl;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementTqiReportUnitDeviceMap;
import org.jeecg.modules.checkData.equipmentCheckData.mapper.MovementTqiReportUnitDeviceMapMapper;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementTqiReportUnitDeviceMapService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
/**
* <p>
* 轨检车-tqi单元总结报告和单元映射关联关系 服务实现类
* </p>
*
* @author hkl
* @since 2023-08-24
*/
@Service
public class MovementTqiReportUnitDeviceMapServiceImpl extends ServiceImpl<MovementTqiReportUnitDeviceMapMapper, MovementTqiReportUnitDeviceMap> implements IMovementTqiReportUnitDeviceMapService {
}
jeecg-module-system/src/main/java/org/jeecg/modules/dynamicStaticAnalysis/algorithm/AnalysisAlgorithm.java
View file @ 35d3ce25
...@@ -10,14 +10,8 @@ import org.jeecg.modules.checkData.dynamicStaticGeometricData.entity.RailInspect ...@@ -10,14 +10,8 @@ import org.jeecg.modules.checkData.dynamicStaticGeometricData.entity.RailInspect
import org.jeecg.modules.checkData.dynamicStaticGeometricData.entity.RailInspectionEquipmentItemDetail; import org.jeecg.modules.checkData.dynamicStaticGeometricData.entity.RailInspectionEquipmentItemDetail;
import org.jeecg.modules.checkData.dynamicStaticGeometricData.service.IRailInspectionEquipmentItemDetailService; import org.jeecg.modules.checkData.dynamicStaticGeometricData.service.IRailInspectionEquipmentItemDetailService;
import org.jeecg.modules.checkData.dynamicStaticGeometricData.service.IRailInspectionEquipmentItemService; import org.jeecg.modules.checkData.dynamicStaticGeometricData.service.IRailInspectionEquipmentItemService;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementCheckDataUnitDeviceMap; import org.jeecg.modules.checkData.equipmentCheckData.entity.*;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementCourse; import org.jeecg.modules.checkData.equipmentCheckData.service.*;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementCourseInfo;
import org.jeecg.modules.checkData.equipmentCheckData.entity.MovementOverReport;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementCheckDataUnitDeviceMapService;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementCourseInfoService;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementCourseService;
import org.jeecg.modules.checkData.equipmentCheckData.service.IMovementOverReportService;
import org.jeecg.modules.dynamicStaticAnalysis.entity.*; import org.jeecg.modules.dynamicStaticAnalysis.entity.*;
import org.jeecg.modules.dynamicStaticAnalysis.mapper.AnalysisAlgorithmMapper; import org.jeecg.modules.dynamicStaticAnalysis.mapper.AnalysisAlgorithmMapper;
import org.jeecg.modules.dynamicStaticAnalysis.service.*; import org.jeecg.modules.dynamicStaticAnalysis.service.*;
...@@ -65,7 +59,23 @@ public class AnalysisAlgorithm { ...@@ -65,7 +59,23 @@ public class AnalysisAlgorithm {
@Resource @Resource
private IMovementOverReportService movementOverReportService; private IMovementOverReportService movementOverReportService;
@Resource @Resource
private IConfigGradeLimitService iConfigGradeLimitService; private IConfigGradeLimitService configGradeLimitService;
@Resource
private IMovementTqiReportService movementTqiReportService;
@Resource
private IMovementAdditiveInfoService movementAdditiveInfoService;
@Resource
private IMovementOverReportUnitDeviceMapService movementOverReportUnitDeviceMapService;
@Resource
private IConfigRailVehicleTqlService configRailVehicleTqlService;
@Resource
private IConfigRailVehicleCheckService configRailVehicleCheckService;
@Resource
private IMovementTqiReportUnitDeviceMapService movementTqiReportUnitDeviceMapService;
public void analysis(String analysisBatchId) { public void analysis(String analysisBatchId) {
Map<String, Map<String, Object>> unitDeviceTable = new TreeMap<>(); Map<String, Map<String, Object>> unitDeviceTable = new TreeMap<>();
...@@ -108,6 +118,7 @@ public class AnalysisAlgorithm { ...@@ -108,6 +118,7 @@ public class AnalysisAlgorithm {
} else { } else {
addInstrumentAnalysis(analysisBatch, checkDataMap, unitDeviceList);
} }
} }
...@@ -129,7 +140,7 @@ public class AnalysisAlgorithm { ...@@ -129,7 +140,7 @@ public class AnalysisAlgorithm {
// 3.1 保存分析批次-单元设备 // 3.1 保存分析批次-单元设备
List<ConfigGradeLimit> configGradeLimitList = iConfigGradeLimitService.lambdaQuery() List<ConfigGradeLimit> configGradeLimitList = configGradeLimitService.lambdaQuery()
.eq(ConfigGradeLimit::getSpeedMax, analysisBatch.getSpeedMax()) .eq(ConfigGradeLimit::getSpeedMax, analysisBatch.getSpeedMax())
.eq(ConfigGradeLimit::getSpeedMin, analysisBatch.getSpeedMin()) .eq(ConfigGradeLimit::getSpeedMin, analysisBatch.getSpeedMin())
.eq(ConfigGradeLimit::getDelFlag, '0') .eq(ConfigGradeLimit::getDelFlag, '0')
...@@ -268,7 +279,6 @@ public class AnalysisAlgorithm { ...@@ -268,7 +279,6 @@ public class AnalysisAlgorithm {
} }
} }
analysisBatchUnitDeviceService.saveBatch(analysisBatchUnitDevices); analysisBatchUnitDeviceService.saveBatch(analysisBatchUnitDevices);
analysisBatchUnitDeviceTransfiniteService.saveBatch(transfiniteList); analysisBatchUnitDeviceTransfiniteService.saveBatch(transfiniteList);
...@@ -281,42 +291,377 @@ public class AnalysisAlgorithm { ...@@ -281,42 +291,377 @@ public class AnalysisAlgorithm {
log.info("[分析完成]|线程id:【" + Thread.currentThread().getId() + "】=============分析批次ID:【" + analysisBatchId + "】"); log.info("[分析完成]|线程id:【" + Thread.currentThread().getId() + "】=============分析批次ID:【" + analysisBatchId + "】");
} }
/**
* 添乘仪查数据解析
*/
private void addInstrumentAnalysis(AnalysisBatch analysisBatch, AnalysisBatchCheckDataMap checkDataMap, List<Map<String, Object>> unitDeviceList) {
// 1.添乘仪查数据相关数据
// 1.1 获取缺陷报告
List<MovementOverReport> movementOverReports = movementOverReportService.lambdaQuery()
.eq(MovementOverReport::getMovementMasterId, checkDataMap.getEkId())
.ge(MovementOverReport::getMileage, analysisBatch.getStartingMileage())
.le(MovementOverReport::getMileage, analysisBatch.getEndMileage())
.orderByAsc(MovementOverReport::getMileage)
.list();
Map<BigDecimal, List<MovementOverReport>> movementOverReportMap = new HashMap<>();
for (MovementOverReport movementOverReport : movementOverReports) {
List<MovementOverReport> list = movementOverReportMap.get(movementOverReport.getMileage());
if (ObjectUtil.isEmpty(list)) {
list = new ArrayList<>();
movementOverReportMap.put(movementOverReport.getMileage(), list);
}
list.add(movementOverReport);
}
// 1.2 获取tqi数据
List<MovementTqiReport> tqiReports = movementTqiReportService.lambdaQuery()
.eq(MovementTqiReport::getMovementMasterId, checkDataMap.getEkId())
.ge(MovementTqiReport::getStartMileage, analysisBatch.getStartingMileage())
.le(MovementTqiReport::getEndMileage, analysisBatch.getEndMileage())
.orderByAsc(MovementTqiReport::getStartMileage)
.list();
// 1.3 获取是否派工配置
// 轨检车动态检查数据-1级超限
Integer isWorkRailVehicleOver1 = 1;
String reasonLabelRailVehicleOver1 = "";
// 轨检车动态检查数据-2级超限
Integer isWorkRailVehicleOver2 = 1;
String reasonLabelRailVehicleOver2 = "";
// 轨检车动态检查数据-3级超限
Integer isWorkRailVehicleOver3 = 1;
String reasonLabelRailVehicleOver3 = "";
// 轨检车动态检查数据-4级超限
Integer isWorkRailVehicleOver4 = 1;
String reasonLabelRailVehicleOver4 = "";
JSONArray dispatchingList = JSONArray.parseArray(analysisBatch.getDispatching());
}
/** /**
* 轨检车检查数据解析 * 轨检车检查数据解析
*/ */
private void railVehicleCheckDataAnalysis(AnalysisBatch analysisBatch, private void railVehicleCheckDataAnalysis(AnalysisBatch analysisBatch,
AnalysisBatchCheckDataMap checkDataMap, AnalysisBatchCheckDataMap checkDataMap,
List<Map<String, Object>> unitDeviceList) { List<Map<String, Object>> unitDeviceList) {
// 1.获取轨检车检查超限
// 1.获取轨检车相关数据
// 1.1 获取缺陷报告
List<MovementOverReport> movementOverReports = movementOverReportService.lambdaQuery() List<MovementOverReport> movementOverReports = movementOverReportService.lambdaQuery()
.eq(MovementOverReport::getMovementMasterId, checkDataMap.getEkId()) .eq(MovementOverReport::getMovementMasterId, checkDataMap.getEkId())
.ge(MovementOverReport::getMileage, analysisBatch.getStartingMileage())
.le(MovementOverReport::getMileage, analysisBatch.getEndMileage())
.orderByAsc(MovementOverReport::getMileage)
.list();
Map<BigDecimal, List<MovementOverReport>> movementOverReportMap = new HashMap<>();
for (MovementOverReport movementOverReport : movementOverReports) {
List<MovementOverReport> list = movementOverReportMap.get(movementOverReport.getMileage());
if (ObjectUtil.isEmpty(list)) {
list = new ArrayList<>();
movementOverReportMap.put(movementOverReport.getMileage(), list);
}
list.add(movementOverReport);
}
// 1.2 获取tqi数据
List<MovementTqiReport> tqiReports = movementTqiReportService.lambdaQuery()
.eq(MovementTqiReport::getMovementMasterId, checkDataMap.getEkId())
.ge(MovementTqiReport::getStartMileage, analysisBatch.getStartingMileage())
.le(MovementTqiReport::getEndMileage, analysisBatch.getEndMileage())
.orderByAsc(MovementTqiReport::getStartMileage)
.list(); .list();
// 1.3 获取是否派工配置
// 轨检车动态检查数据-1级超限
Integer isWorkRailVehicleOver1 = 1;
String reasonLabelRailVehicleOver1 = "";
// 轨检车动态检查数据-2级超限
Integer isWorkRailVehicleOver2 = 1;
String reasonLabelRailVehicleOver2 = "";
// 轨检车动态检查数据-3级超限
Integer isWorkRailVehicleOver3 = 1;
String reasonLabelRailVehicleOver3 = "";
// 轨检车动态检查数据-4级超限
Integer isWorkRailVehicleOver4 = 1;
String reasonLabelRailVehicleOver4 = "";
JSONArray dispatchingList = JSONArray.parseArray(analysisBatch.getDispatching());
for (Object obj : dispatchingList) {
JSONObject dispatching = (JSONObject) obj;
String reasonValue = String.valueOf(dispatching.get("reasonValue"));
String reasonLabel = String.valueOf(dispatching.get("reasonLabel"));
if ("rail_vehicle_over_1".equals(reasonValue)) {
Boolean isWorkTemp = Boolean.valueOf(dispatching.get("isWork").toString());
if (isWorkTemp) {
isWorkRailVehicleOver1 = 1;
reasonLabelRailVehicleOver1 = reasonLabel;
} else {
isWorkRailVehicleOver1 = 0;
}
}
if ("rail_vehicle_over_2".equals(reasonValue)) {
Boolean isWorkTemp = Boolean.valueOf(dispatching.get("isWork").toString());
if (isWorkTemp) {
isWorkRailVehicleOver2 = 1;
reasonLabelRailVehicleOver2 = reasonLabel;
} else {
isWorkRailVehicleOver2 = 0;
}
}
if ("rail_vehicle_over_3".equals(reasonValue)) {
Boolean isWorkTemp = Boolean.valueOf(dispatching.get("isWork").toString());
if (isWorkTemp) {
isWorkRailVehicleOver3 = 1;
reasonLabelRailVehicleOver3 = reasonLabel;
} else {
isWorkRailVehicleOver3 = 0;
}
}
if ("rail_vehicle_over_4".equals(reasonValue)) {
Boolean isWorkTemp = Boolean.valueOf(dispatching.get("isWork").toString());
if (isWorkTemp) {
isWorkRailVehicleOver4 = 1;
reasonLabelRailVehicleOver4 = reasonLabel;
} else {
isWorkRailVehicleOver4 = 0;
}
}
}
// 1.4 获取轨检车检查超限权值
ConfigRailVehicleCheck configRailVehicle = configRailVehicleCheckService.lambdaQuery()
.eq(ConfigRailVehicleCheck::getSpeedMax, analysisBatch.getSpeedMax())
.eq(ConfigRailVehicleCheck::getSpeedMin, analysisBatch.getSpeedMin())
.eq(ConfigRailVehicleCheck::getDelFlag, "0")
.last("limit 1")
.one();
// 1-钢轨,2-曲线,3-竖曲线,4-道岔
JSONObject railWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getRail());
JSONObject curveWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getCurve());
JSONObject verticalCurveWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getVerticalCurve());
JSONObject switchWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getRailSwitch());
// 1.5 获取轨检车TQI超限权值
ConfigRailVehicleTql configRailVehicleTql = configRailVehicleTqlService.lambdaQuery()
.eq(ConfigRailVehicleTql::getSpeedMax, analysisBatch.getSpeedMax())
.eq(ConfigRailVehicleTql::getSpeedMin, analysisBatch.getSpeedMin())
.eq(ConfigRailVehicleTql::getDelFlag, "0")
.last("limit 1")
.one();
// 1.6
// 1-钢轨,2-曲线,3-竖曲线,4-道岔
// JSONObject railWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getRail());
// JSONObject curveWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getCurve());
// JSONObject verticalCurveWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getVerticalCurve());
// JSONObject switchWeightValueJsonObject = JSONObject.parseObject(configRailVehicle.getRailSwitch());
// 2. 根据分析批次的里程查询出映射单元 // 2. 根据分析批次的里程查询出映射单元
BigDecimal checkStartingMileage = analysisBatch.getStartingMileage(); List<MovementOverReportUnitDeviceMap> overReportUnitDeviceMaps = new ArrayList<>();
BigDecimal checkEndMileage = analysisBatch.getEndMileage(); List<MovementTqiReportUnitDeviceMap> movementTqiReportUnitDeviceMaps = new ArrayList<>();
for (Map<String, Object> unitDevice : unitDeviceList) { for (Map<String, Object> unitDevice : unitDeviceList) {
// 1-钢轨,2-曲线,3-竖曲线,4-道岔
Integer type = Convert.toInt(unitDevice.get("type"));
JSONObject jsonObject = null;
if (type == 1) {
jsonObject = railWeightValueJsonObject;
} else if (type == 2) {
jsonObject = curveWeightValueJsonObject;
} else if (type == 3) {
jsonObject = verticalCurveWeightValueJsonObject;
} else if (type == 4) {
jsonObject = switchWeightValueJsonObject;
}
BigDecimal bigTrackGaugeWeightValues = jsonObject.getBigDecimal("bigTrackGauge");
BigDecimal smallTrackGaugeWeightValues = jsonObject.getBigDecimal("smallTrackGauge");
BigDecimal directionWeightValues = jsonObject.getBigDecimal("direction");
BigDecimal triangularPitWeightValues = jsonObject.getBigDecimal("triangularPit");
BigDecimal heightWeightValues = jsonObject.getBigDecimal("height");
BigDecimal levelWeightValues = jsonObject.getBigDecimal("level");
List<AnalysisBatchUnitDeviceTransfinite> railVehicleTransfiniteList = new ArrayList<>();
BigDecimal startMileage = Convert.toBigDecimal(unitDevice.get("startMileage")); BigDecimal startMileage = Convert.toBigDecimal(unitDevice.get("startMileage"));
BigDecimal centerMileage = Convert.toBigDecimal(unitDevice.get("centerMileage"));
BigDecimal endMileage = Convert.toBigDecimal(unitDevice.get("endMileage")); BigDecimal endMileage = Convert.toBigDecimal(unitDevice.get("endMileage"));
BigDecimal centerMileage = startMileage.add(endMileage).divide(new BigDecimal("2"), 3, RoundingMode.HALF_UP);
unitDevice.put("centerMileage", centerMileage);
// 命中单元设备
if (checkStartingMileage.compareTo(centerMileage) <= 0 && checkEndMileage.compareTo(centerMileage) > 0) {
// 循环超限数据来比 // 2.1 缺陷记录报告表里程落在单元设备【开始-结束】这个设备上面，视为这个区间的超限记录
for (MovementOverReport movementOverReport : movementOverReports) { for (MovementOverReport movementOverReport : movementOverReports) {
BigDecimal mileage = movementOverReport.getMileage(); // 说明超限
if (startMileage.compareTo(mileage) <= 0 && endMileage.compareTo(mileage) > 0) { if (startMileage.compareTo(movementOverReport.getMileage()) <= 0 && endMileage.compareTo(movementOverReport.getMileage()) > 0) {
break; Integer transfiniteGrade = Convert.toInt(movementOverReport.getOverrunLevel());
// 超限
AnalysisBatchUnitDeviceTransfinite transfinite = new AnalysisBatchUnitDeviceTransfinite();
transfinite.setId(UUIDGenerator.generate());
transfinite.setTransfiniteGrade(transfiniteGrade);
transfinite.setTransfiniteType(movementOverReport.getOverrunType());
if (1 == transfiniteGrade) {
transfinite.setTransfiniteGradeName(reasonLabelRailVehicleOver1);
transfinite.setIsWork(isWorkRailVehicleOver1);
}
String allowValue = Convert.toBigDecimal(movementOverReport.getPeakValue()).subtract(Convert.toBigDecimal(movementOverReport.getDataDifference())).toString();
transfinite.setAllowValue(allowValue);
transfinite.setMeasurePointValue(movementOverReport.getPeakValue());
railVehicleTransfiniteList.add(transfinite);
// 保存超限和设备关联关系
MovementOverReportUnitDeviceMap overReportUnitDeviceMap = new MovementOverReportUnitDeviceMap();
overReportUnitDeviceMap.setId(UUIDGenerator.generate());
overReportUnitDeviceMap.setUnitId(Convert.toStr(unitDevice.get("id")));
overReportUnitDeviceMap.setUnitCode(Convert.toStr(unitDevice.get("unitCode")));
overReportUnitDeviceMap.setUnitType(Convert.toInt(unitDevice.get("type")));
overReportUnitDeviceMap.setUnitTypeName(Convert.toStr(unitDevice.get("typeName")));
overReportUnitDeviceMap.setUnitStartingMileage(Convert.toBigDecimal(unitDevice.get("startMileage")));
overReportUnitDeviceMap.setUnitCenterMileage(Convert.toBigDecimal(unitDevice.get("centerMileage")));
overReportUnitDeviceMap.setUnitEndMileage(Convert.toBigDecimal(unitDevice.get("endMileage")));
overReportUnitDeviceMap.setCheckId(checkDataMap.getEkId());
overReportUnitDeviceMap.setCheckType(checkDataMap.getEkType());
overReportUnitDeviceMap.setOverReportId(movementOverReport.getId());
overReportUnitDeviceMap.setOverReportMileage(movementOverReport.getMileage());
overReportUnitDeviceMap.setOverLevel(Convert.toInt(movementOverReport.getOverrunLevel()));
overReportUnitDeviceMap.setOverType(movementOverReport.getOverrunType());
overReportUnitDeviceMap.setPeakValue(movementOverReport.getPeakValue());
overReportUnitDeviceMap.setDataDifference(movementOverReport.getDataDifference());
overReportUnitDeviceMap.setXianxing(movementOverReport.getXianxing());
overReportUnitDeviceMap.setStandard(movementOverReport.getStandard());
overReportUnitDeviceMap.setSpend(movementOverReport.getSpend());
overReportUnitDeviceMaps.add(overReportUnitDeviceMap);
}
}
unitDevice.put("railVehicleTransfiniteList", railVehicleTransfiniteList);
// 2.2 单元设备中心里程落在tqi【开始-结束】这个区间视为这个区间的单元设备
// 统计单元得分
// 统计tqi得分
for (MovementTqiReport tqiReport : tqiReports) {
// 如果命中处理测点映射关系
if (tqiReport.getStartMileage().compareTo(centerMileage) <= 0 && tqiReport.getEndMileage().compareTo(centerMileage) > 0) {
MovementTqiReportUnitDeviceMap movementTqiReportUnitDeviceMap = new MovementTqiReportUnitDeviceMap();
movementTqiReportUnitDeviceMap.setId(UUIDGenerator.generate());
movementTqiReportUnitDeviceMap.setCheckId(checkDataMap.getEkId());
movementTqiReportUnitDeviceMap.setCheckType(checkDataMap.getEkType());
movementTqiReportUnitDeviceMap.setUnitId(Convert.toStr(unitDevice.get("id")));
movementTqiReportUnitDeviceMap.setUnitCode(Convert.toStr(unitDevice.get("unitCode")));
movementTqiReportUnitDeviceMap.setUnitType(Convert.toInt(unitDevice.get("type")));
movementTqiReportUnitDeviceMap.setUnitTypeName(Convert.toStr(unitDevice.get("typeName")));
movementTqiReportUnitDeviceMap.setUnitStartingMileage(Convert.toBigDecimal(unitDevice.get("startMileage")));
movementTqiReportUnitDeviceMap.setUnitCenterMileage(Convert.toBigDecimal(unitDevice.get("centerMileage")));
movementTqiReportUnitDeviceMap.setUnitEndMileage(Convert.toBigDecimal(unitDevice.get("endMileage")));
movementTqiReportUnitDeviceMap.setTqiReportId(tqiReport.getId());
movementTqiReportUnitDeviceMap.setStartMileage(tqiReport.getStartMileage());
movementTqiReportUnitDeviceMap.setEndMileage(tqiReport.getEndMileage());
movementTqiReportUnitDeviceMap.setSectionName(tqiReport.getSectionName());
movementTqiReportUnitDeviceMap.setHighLowLeft(tqiReport.getHighLowLeft());
movementTqiReportUnitDeviceMap.setHighLowRight(tqiReport.getHighLowRight());
movementTqiReportUnitDeviceMap.setTrackLeft(tqiReport.getTrackLeft());
movementTqiReportUnitDeviceMap.setTrackRight(tqiReport.getTrackRight());
movementTqiReportUnitDeviceMap.setLevel(tqiReport.getLevel());
movementTqiReportUnitDeviceMap.setTrackGauge(tqiReport.getTrackGauge());
movementTqiReportUnitDeviceMap.setTriangularPit(tqiReport.getTriangularPit());
movementTqiReportUnitDeviceMap.setTqiComeUpon(tqiReport.getTqiComeUpon());
movementTqiReportUnitDeviceMap.setTqiAboveStandard(tqiReport.getTqiAboveStandard());
movementTqiReportUnitDeviceMap.setDeduct(tqiReport.getDeduct());
movementTqiReportUnitDeviceMap.setStandard(tqiReport.getStandard());
movementTqiReportUnitDeviceMap.setSpend(tqiReport.getSpend());
movementTqiReportUnitDeviceMaps.add(movementTqiReportUnitDeviceMap);
// 计算轨距得分
if (ObjectUtil.isNotEmpty(railVehicleTransfiniteList)) {
Double finalTrackGauge = Convert.toDouble(tqiReport.getTrackGauge());
int trackGaugeSize = 1;
double sumTrackGauge = Convert.toDouble(tqiReport.getTrackGauge());
for (AnalysisBatchUnitDeviceTransfinite record : railVehicleTransfiniteList) {
if ("轨距变化率".equals(record.getTransfiniteType())) {
Double trackGauge = Convert.toDouble(record.getMeasurePointValue());
if (1 == analysisBatch.getAnalysisType()) { // 均值
sumTrackGauge = sumTrackGauge + trackGauge;
trackGaugeSize++;
finalTrackGauge = sumTrackGauge / trackGaugeSize;
} else { // 峰值
if (finalTrackGauge < trackGauge) {
finalTrackGauge = trackGauge;
} }
} }
} }
} }
}
Double finalLevel = null;
Double finalTriangularPit = null;
Double finalHeight = null;
Double finalDirection = null;
double sumTrackGauge = 0;
double sumLevel = 0;
double sumTriangularPit = 0;
double sumHeight = 0;
double sumDirection = 0;
double maxTrackGauge = 0;
double maxLevel = 0;
double maxTriangularPit = 0;
double maxHeight = 0;
double maxDirection = 0;
double avgTrackGauge = 0;
double avgLevel = 0;
double avgTriangularPit = 0;
double avgHeight = 0;
double avgDirection = 0;
double levelSize = 0;
double triangularPitSize = 0;
double heightSize = 0;
double directionSize = 0;
}
}
// unitDevice.put("railDeviceCheckScore", sumUnitScore);
// unitDevice.put("railDeviceCheckScoreList", scoreList);
}
if (ObjectUtil.isNotEmpty(overReportUnitDeviceMaps)) {
movementOverReportUnitDeviceMapService.lambdaUpdate().eq(MovementOverReportUnitDeviceMap::getCheckId, checkDataMap.getEkId()).remove();
movementOverReportUnitDeviceMapService.saveBatch(overReportUnitDeviceMaps);
}
if (ObjectUtil.isNotEmpty(movementTqiReportUnitDeviceMaps)) {
movementTqiReportUnitDeviceMapService.lambdaUpdate().eq(MovementTqiReportUnitDeviceMap::getCheckId, checkDataMap.getEkId()).remove();
movementTqiReportUnitDeviceMapService.saveBatch(movementTqiReportUnitDeviceMaps);
}
} }
/** /**
...@@ -424,26 +769,26 @@ public class AnalysisAlgorithm { ...@@ -424,26 +769,26 @@ public class AnalysisAlgorithm {
Map<String, Object> unitDevice) { Map<String, Object> unitDevice) {
Integer analysisType = analysisBatch.getAnalysisType(); Integer analysisType = analysisBatch.getAnalysisType();
Integer finalTrackGauge = null; Double finalTrackGauge = null;
Integer finalTriangularPit = null; Double finalTriangularPit = null;
Integer finalLevel = null; Double finalLevel = null;
int sumTrackGauge = 0; double sumTrackGauge = 0;
int sumTriangularPit = 0; double sumTriangularPit = 0;
int sumLevel = 0; double sumLevel = 0;
int maxTrackGauge = 0; double maxTrackGauge = 0;
int maxTriangularPit = 0; double maxTriangularPit = 0;
int maxLevel = 0; double maxLevel = 0;
int avgTrackGauge = 0; double avgTrackGauge = 0;
int avgTriangularPit = 0; double avgTriangularPit = 0;
int avgLevel = 0; double avgLevel = 0;
int trackGaugeSize = 0; double trackGaugeSize = 0;
int triangularPitSize = 0; double triangularPitSize = 0;
int levelSize = 0; double levelSize = 0;
// 循环计算均值/峰值 // 循环计算均值/峰值
for (RailInspectionEquipmentItemDetail movementCourseInfo : railDeviceCheckList) { for (RailInspectionEquipmentItemDetail movementCourseInfo : railDeviceCheckList) {
...@@ -712,7 +1057,8 @@ public class AnalysisAlgorithm { ...@@ -712,7 +1057,8 @@ public class AnalysisAlgorithm {
/** /**
* 轨检仪检查 * 轨检仪检查
*/ */
private MovementCheckDataUnitDeviceMap railDeviceCheckDeviceMapSave(RailInspectionEquipmentItemDetail movementCourseInfo, private MovementCheckDataUnitDeviceMap railDeviceCheckDeviceMapSave(RailInspectionEquipmentItemDetail
movementCourseInfo,
Map<String, Object> unitDevice, Map<String, Object> unitDevice,
RailInspectionEquipmentItem checkItem) { RailInspectionEquipmentItem checkItem) {
MovementCheckDataUnitDeviceMap movementCheckDataUnitDeviceMap = new MovementCheckDataUnitDeviceMap(); MovementCheckDataUnitDeviceMap movementCheckDataUnitDeviceMap = new MovementCheckDataUnitDeviceMap();
...@@ -846,29 +1192,29 @@ public class AnalysisAlgorithm { ...@@ -846,29 +1192,29 @@ public class AnalysisAlgorithm {
Map<String, Object> unitDevice) { Map<String, Object> unitDevice) {
Integer analysisType = analysisBatch.getAnalysisType(); Integer analysisType = analysisBatch.getAnalysisType();
Integer finalTrackGauge = null; Double finalTrackGauge = null;
Integer finalLevel = null; Double finalLevel = null;
Integer finalTriangularPit = null; Double finalTriangularPit = null;
Integer finalHeight = null; Double finalHeight = null;
Integer finalDirection = null; Double finalDirection = null;
int sumTrackGauge = 0; double sumTrackGauge = 0;
int sumLevel = 0; double sumLevel = 0;
int sumTriangularPit = 0; double sumTriangularPit = 0;
int sumHeight = 0; double sumHeight = 0;
int sumDirection = 0; double sumDirection = 0;
int maxTrackGauge = 0; double maxTrackGauge = 0;
int maxLevel = 0; double maxLevel = 0;
int maxTriangularPit = 0; double maxTriangularPit = 0;
int maxHeight = 0; double maxHeight = 0;
int maxDirection = 0; double maxDirection = 0;
int avgTrackGauge = 0; double avgTrackGauge = 0;
int avgLevel = 0; double avgLevel = 0;
int avgTriangularPit = 0; double avgTriangularPit = 0;
int avgHeight = 0; double avgHeight = 0;
int avgDirection = 0; double avgDirection = 0;
int trackGaugeSize = 0; int trackGaugeSize = 0;
...@@ -1130,7 +1476,7 @@ public class AnalysisAlgorithm { ...@@ -1130,7 +1476,7 @@ public class AnalysisAlgorithm {
score.setAnalysisBatchId(analysisBatch.getId()); score.setAnalysisBatchId(analysisBatch.getId());
score.setAnalysisBatchCode(analysisBatch.getAnalysisBatchCode()); score.setAnalysisBatchCode(analysisBatch.getAnalysisBatchCode());
score.setCheckType(1); score.setCheckType(1);
score.setPointTypeName("高低"); score.setPointTypeName("水平");
score.setPointValue(finalLevel); score.setPointValue(finalLevel);
score.setWeightValues(levelWeightValues); score.setWeightValues(levelWeightValues);
score.setPointScore(levelUnitScore); score.setPointScore(levelUnitScore);
...@@ -1147,7 +1493,8 @@ public class AnalysisAlgorithm { ...@@ -1147,7 +1493,8 @@ public class AnalysisAlgorithm {
* @param movementCourseInfo * @param movementCourseInfo
* @return * @return
*/ */
private AnalysisBatchUnitDeviceTransfinite labourCheckTransfinite(AnalysisBatch analysisBatch, MovementCourseInfo movementCourseInfo) { private AnalysisBatchUnitDeviceTransfinite labourCheckTransfinite(AnalysisBatch
analysisBatch, MovementCourseInfo movementCourseInfo) {
// 超限配置 // 超限配置
JSONObject allowValue = JSONObject.parseObject(analysisBatch.getAllowValue()); JSONObject allowValue = JSONObject.parseObject(analysisBatch.getAllowValue());
Integer bigTrackGauge = Convert.toInt(allowValue.get("bigTrackGauge")); // 大轨距 Integer bigTrackGauge = Convert.toInt(allowValue.get("bigTrackGauge")); // 大轨距
...@@ -1268,10 +1615,6 @@ public class AnalysisAlgorithm { ...@@ -1268,10 +1615,6 @@ public class AnalysisAlgorithm {
private MovementCheckDataUnitDeviceMap labourCheckDeviceMapSave(MovementCourseInfo movementCourseInfo, private MovementCheckDataUnitDeviceMap labourCheckDeviceMapSave(MovementCourseInfo movementCourseInfo,
Map<String, Object> unitDevice, Map<String, Object> unitDevice,
MovementCourse checkItem) { MovementCourse checkItem) {
BigDecimal startMileage = Convert.toBigDecimal(unitDevice.get("startMileage"));
BigDecimal endMileage = Convert.toBigDecimal(unitDevice.get("endMileage"));
BigDecimal centerMileage = startMileage.add(endMileage).divide(new BigDecimal("2"), 3, RoundingMode.HALF_UP);
MovementCheckDataUnitDeviceMap record = new MovementCheckDataUnitDeviceMap(); MovementCheckDataUnitDeviceMap record = new MovementCheckDataUnitDeviceMap();
record.setId(UUIDGenerator.generate()); record.setId(UUIDGenerator.generate());
record.setCheckType(1);// 人工检查 record.setCheckType(1);// 人工检查
...@@ -1279,9 +1622,9 @@ public class AnalysisAlgorithm { ...@@ -1279,9 +1622,9 @@ public class AnalysisAlgorithm {
record.setUnitCode(Convert.toStr(unitDevice.get("unitCode"))); record.setUnitCode(Convert.toStr(unitDevice.get("unitCode")));
record.setUnitType(Convert.toInt(unitDevice.get("type"))); record.setUnitType(Convert.toInt(unitDevice.get("type")));
record.setUnitTypeName(Convert.toStr(unitDevice.get("typeName"))); record.setUnitTypeName(Convert.toStr(unitDevice.get("typeName")));
record.setUnitStartingMileage(startMileage); record.setUnitStartingMileage(Convert.toBigDecimal(unitDevice.get("startMileage")));
record.setUnitCenterMileage(centerMileage); record.setUnitCenterMileage(Convert.toBigDecimal(unitDevice.get("centerMileage")));
record.setUnitEndMileage(endMileage); record.setUnitEndMileage(Convert.toBigDecimal(unitDevice.get("endMileage")));
record.setCheckId(checkItem.getMovementMasterId()); record.setCheckId(checkItem.getMovementMasterId());
record.setCheckItemId(checkItem.getId()); record.setCheckItemId(checkItem.getId());
record.setCheckItemStartingMileage(checkItem.getCourseStartingMileage()); record.setCheckItemStartingMileage(checkItem.getCourseStartingMileage());
......
jeecg-module-system/src/main/java/org/jeecg/modules/dynamicStaticAnalysis/entity/AnalysisBatchUnitDevicePointScore.java
View file @ 35d3ce25
...@@ -97,7 +97,7 @@ public class AnalysisBatchUnitDevicePointScore implements Serializable { ...@@ -97,7 +97,7 @@ public class AnalysisBatchUnitDevicePointScore implements Serializable {
@ApiModelProperty("测点值") @ApiModelProperty("测点值")
@TableField("point_value") @TableField("point_value")
private Integer pointValue; private Double pointValue;
@ApiModelProperty("测点得分") @ApiModelProperty("测点得分")
@TableField("point_score") @TableField("point_score")
......
jeecg-module-system/src/main/java/org/jeecg/modules/subwayNetwork/dto/SubwaySectionQueryDTO.java
View file @ 35d3ce25
...@@ -14,4 +14,7 @@ public class SubwaySectionQueryDTO { ...@@ -14,4 +14,7 @@ public class SubwaySectionQueryDTO {
@ApiModelProperty(value = "线别id") @ApiModelProperty(value = "线别id")
private String lineAliasId; private String lineAliasId;
@ApiModelProperty(value = "线路Id")
private String railLine;
} }
jeecg-module-system/src/main/java/org/jeecg/modules/subwayNetwork/mapper/xml/SubwaySectionMapper.xml
View file @ 35d3ce25
...@@ -23,16 +23,16 @@ ...@@ -23,16 +23,16 @@
t1.remark t1.remark
FROM FROM
t_sn_subway_section t1 LEFT JOIN t_sn_light_rail t2 ON t1.light_rail_id = t2.id t_sn_subway_section t1 LEFT JOIN t_sn_light_rail t2 ON t1.light_rail_id = t2.id
<where> WHERE t2.status = 1
1=1
<if test="query.sectionName != null and query.sectionName != ''"> <if test="query.sectionName != null and query.sectionName != ''">
AND t1.section_name like concat('%',#{query.sectionName},'%') AND t1.section_name like concat('%',#{query.sectionName},'%')
</if> </if>
<if test="query.lineAliasId !=null and query.lineAliasId!=''"> <if test="query.lineAliasId !=null and query.lineAliasId!=''">
AND t1.line_alias_id = #{query.lineAliasId} AND t1.line_alias_id = #{query.lineAliasId}
</if> </if>
AND t2.status = 1 <if test="query.railLine !=null and query.railLine!=''">
</where> AND t1.light_rail_id = #{query.railLine}
</if>
</select> </select>
<select id="getTreeSubwaySectionList" resultType="org.jeecg.modules.subwayNetwork.vo.SectionStationNode"> <select id="getTreeSubwaySectionList" resultType="org.jeecg.modules.subwayNetwork.vo.SectionStationNode">
SELECT t.id, SELECT t.id,
......
jeecg-module-system/src/main/java/org/jeecg/modules/subwayNetwork/service/impl/SubwaySectionServiceImpl.java
View file @ 35d3ce25
...@@ -60,8 +60,8 @@ public class SubwaySectionServiceImpl extends ServiceImpl<SubwaySectionMapper, S ...@@ -60,8 +60,8 @@ public class SubwaySectionServiceImpl extends ServiceImpl<SubwaySectionMapper, S
SubwaySection subwaySection = BeanUtil.copyProperties(dto, SubwaySection.class); SubwaySection subwaySection = BeanUtil.copyProperties(dto, SubwaySection.class);
LightRail rail = lightRailMapper.selectById(dto.getLightRailId()); // 线路id LightRail rail = lightRailMapper.selectById(dto.getLightRailId()); // 线路id
subwaySection.setLightRailName(rail.getRailLineName());// 线路昵称 subwaySection.setLightRailName(rail.getRailLineName());// 线路昵称
subwaySection.setSectionStartingMileage(startTrainStation.getEndMileage()); // 区间起始里程 subwaySection.setSectionStartingMileage(startTrainStation.getCenterMileage()); // 区间起始里程
subwaySection.setSectionEndMileage(endTrainStation.getStartingMileage());// 区间结束里程 subwaySection.setSectionEndMileage(endTrainStation.getCenterMileage());// 区间结束里程
//维护区间的更新人和更新时间 //维护区间的更新人和更新时间
subwaySection.setUpdateTime(new Date()); subwaySection.setUpdateTime(new Date());
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal(); LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
......
jeecg-module-system/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java
View file @ 35d3ce25
package org.jeecg.modules.system.service.impl; package org.jeecg.modules.system.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
...@@ -26,7 +25,10 @@ import org.jeecg.common.desensitization.annotation.SensitiveEncode; ...@@ -26,7 +25,10 @@ import org.jeecg.common.desensitization.annotation.SensitiveEncode;
import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.exception.JeecgBootException;
import org.jeecg.common.system.vo.LoginUser; import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.common.system.vo.SysUserCacheInfo; import org.jeecg.common.system.vo.SysUserCacheInfo;
import org.jeecg.common.util.*; import org.jeecg.common.util.FillRuleUtil;
import org.jeecg.common.util.PasswordUtil;
import org.jeecg.common.util.UUIDGenerator;
import org.jeecg.common.util.oConvertUtils;
import org.jeecg.config.mybatis.MybatisPlusSaasConfig; import org.jeecg.config.mybatis.MybatisPlusSaasConfig;
import org.jeecg.modules.base.service.BaseCommonService; import org.jeecg.modules.base.service.BaseCommonService;
import org.jeecg.modules.system.entity.*; import org.jeecg.modules.system.entity.*;
...@@ -39,11 +41,9 @@ import org.jeecg.modules.system.vo.lowapp.DepartAndUserInfo; ...@@ -39,11 +41,9 @@ import org.jeecg.modules.system.vo.lowapp.DepartAndUserInfo;
import org.jeecg.modules.system.vo.lowapp.DepartInfo; import org.jeecg.modules.system.vo.lowapp.DepartInfo;
import org.jeecg.modules.system.vo.lowapp.UpdateDepartInfo; import org.jeecg.modules.system.vo.lowapp.UpdateDepartInfo;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -134,7 +134,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl ...@@ -134,7 +134,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
//TODO 外部模拟登陆临时账号，列表不显示 //TODO 外部模拟登陆临时账号，列表不显示
queryWrapper.ne("username", "_reserve_user_external"); queryWrapper.ne("username", "_reserve_user_external");
queryWrapper.eq("del_flag",0); // queryWrapper.eq("del_flag",0);
Page<SysUser> page = new Page<SysUser>(pageNo, pageSize); Page<SysUser> page = new Page<SysUser>(pageNo, pageSize);
IPage<SysUser> pageList = this.page(page, queryWrapper); IPage<SysUser> pageList = this.page(page, queryWrapper);
......
jeecg-module-system/src/main/resources/application.yml
View file @ 35d3ce25
...@@ -2,4 +2,4 @@ spring: ...@@ -2,4 +2,4 @@ spring:
application: application:
name: jeecg-system name: jeecg-system
profiles: profiles:
active: dev active: hkl
subwayOA-app/.gitignore 0 → 100644
View file @ 35d3ce25
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
subwayOA-app/pom.xml 0 → 100644
View file @ 35d3ce25
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.14</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.suntray</groupId>
<artifactId>subwayOA-app</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>subwayOA-app</name>
<description>地铁公务系统</description>
<repositories>
<repository>
<id>aliyun</id>
<name>aliyun Repository</name>
<url>https://maven.aliyun.com/repository/public</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
<properties>
<java.version>1.8</java.version>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-freemarker</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.18</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.27</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.3.2</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.5.3.2</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.28</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-openapi2-spring-boot-starter</artifactId>
<version>4.3.0</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.10.5</version>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.3</version>
</dependency>
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.3</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>dingtalk</artifactId>
<version>2.0.30</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
subwayOA-app/src/main/java/com/suntray/oa/app/SubwayOaApplication.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app;
import lombok.extern.log4j.Log4j2;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.env.Environment;
import java.net.InetAddress;
import java.net.UnknownHostException;
@SpringBootApplication
@Log4j2
public class SubwayOaApplication {
public static void main(String[] args) throws UnknownHostException {
ConfigurableApplicationContext application = SpringApplication.run(SubwayOaApplication.class, args);
Environment env = application.getEnvironment();
String ip = InetAddress.getLocalHost().getHostAddress();
String port = env.getProperty("server.port");
String path = env.getProperty("server.servlet.context-path");
log.info("\n----------------------------------------------------------\n\t" +
"Application " + env.getProperty("spring.application.name") + " is running! Access URLs:\n\t" +
"Local: \t\thttp://localhost:" + port + path + "/\n\t" +
"External: \thttp://" + ip + ":" + port + path + "/\n\t" +
"Swagger文档: \thttp://" + ip + ":" + port + path + "/doc.html\n" +
"----------------------------------------------------------");
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/constant/CommonCode.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.constant;
/**
* @author 黄康林
* @function 通用错误码
*/
public enum CommonCode {
/**
* 成功操作
*/
C0000("0", "操作成功", null, null),
;
private String code;
private String message;
private String possibleReason;
private String suggestMeasure;
CommonCode(String code, String message) {
this.code = code;
this.message = message;
}
CommonCode(String code, String message, String possibleReason, String suggestMeasure) {
this.code = code;
this.message = message;
this.possibleReason = possibleReason;
this.suggestMeasure = suggestMeasure;
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/exception/BusinessException.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.exception;
/**
* 系统业务异常类
*/
public class BusinessException extends RuntimeException {
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/exception/GlobalExceptionHandler.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.exception;
import com.suntray.oa.app.common.response.BaseResponse;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;
/**
* 全局异常处理器
*/
@ControllerAdvice
public class GlobalExceptionHandler {
@ExceptionHandler(value = {Exception.class})
@ResponseBody
public BaseResponse<?> deal(Exception e) {
BaseResponse<?> response = new BaseResponse<>();
if (e instanceof BusinessException) {
} else if (e instanceof ParamValidException) {
} else {
response.setCode(-1);
response.setSuccess(false);
response.setMessage("系统错误");
}
return response;
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/exception/ParamValidException.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.exception;
/**
* 系统参数异常类
*/
public class ParamValidException extends RuntimeException {
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/response/BaseResponse.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.response;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "统一响应结构")
public class BaseResponse<T> {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "成功标志")
private boolean success = true;
@ApiModelProperty(value = "返回处理消息")
private String message = "";
@ApiModelProperty(value = "返回代码")
private Integer code = 0;
@ApiModelProperty(value = "返回数据对象")
private T result;
@ApiModelProperty(value = "时间戳")
private long timestamp = System.currentTimeMillis();
public static BaseResponse<String> ok() {
return ok("操作成功");
}
public static BaseResponse<String> ok(String message) {
BaseResponse<String> response = new BaseResponse<>();
return response;
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/common/util/UUIDGenerator.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.common.util;
import java.net.InetAddress;
public class UUIDGenerator {
/**
* 产生一个32位的UUID
*
* @return
*/
public static String generate() {
return new StringBuilder(32).append(format(getIp())).append(
format(getJvm())).append(format(getHiTime())).append(
format(getLoTime())).append(format(getCount())).toString();
}
private static final int IP;
static {
int ipadd;
try {
ipadd = toInt(InetAddress.getLocalHost().getAddress());
} catch (Exception e) {
ipadd = 0;
}
IP = ipadd;
}
private static short counter = (short) 0;
private static final int JVM = (int) (System.currentTimeMillis() >>> 8);
private final static String format(int intval) {
String formatted = Integer.toHexString(intval);
StringBuilder buf = new StringBuilder("00000000");
buf.replace(8 - formatted.length(), 8, formatted);
return buf.toString();
}
private final static String format(short shortval) {
String formatted = Integer.toHexString(shortval);
StringBuilder buf = new StringBuilder("0000");
buf.replace(4 - formatted.length(), 4, formatted);
return buf.toString();
}
private final static int getJvm() {
return JVM;
}
private final static short getCount() {
synchronized (UUIDGenerator.class) {
if (counter < 0) {
counter = 0;
}
return counter++;
}
}
/**
* Unique in a local network
*/
private final static int getIp() {
return IP;
}
/**
* Unique down to millisecond
*/
private final static short getHiTime() {
return (short) (System.currentTimeMillis() >>> 32);
}
private final static int getLoTime() {
return (int) System.currentTimeMillis();
}
private final static int toInt(byte[] bytes) {
int result = 0;
int length = 4;
for (int i = 0; i < length; i++) {
result = (result << 8) - Byte.MIN_VALUE + (int) bytes[i];
}
return result;
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/config/Knife4jConfig.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.config;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import org.springframework.beans.factory.annotation.Value;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2WebMvc;
import springfox.documentation.service.Contact;
import springfox.documentation.builders.RequestHandlerSelectors;
@Slf4j
@Configuration
@EnableSwagger2WebMvc
public class Knife4jConfig {
@Value("${spring.application.name:default}")
private String applicationName;
@Bean
public Docket docket() {
// 指定使用Swagger2规范
Docket docket = new Docket(DocumentationType.SWAGGER_2)
.apiInfo(new ApiInfoBuilder()
// 简介(支持Markdown语法)
.description("地铁公务APP端api")
// 服务地址
.termsOfServiceUrl("API服务条款")
// 作者及联系信息
.contact(new Contact("地铁公务", "地铁公务", "地铁公务"))
// api版本
.version("1.0.0")
.build())
//分组名称(微服务项目可以用微服务名分组)
.groupName(applicationName)
.select()
// 定位api
// .apis(
// RequestHandlerSelectors.basePackage(getProjectBasePackage())
// .and(RequestHandlerSelectors.withClassAnnotation(RestController.class)
// .or(RequestHandlerSelectors.withClassAnnotation(Controller.class))
// )
// )
// .paths(PathSelectors.any())
.build();
// docket.securitySchemes(securitySchemes()).securityContexts(securityContexts());
return docket;
}
}
subwayOA-app/src/main/java/com/suntray/oa/app/modules/test/TestController.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app.modules.test;
import com.suntray.oa.app.common.response.BaseResponse;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@Api(tags = "测试模块")
public class TestController {
@GetMapping(value = "/test1")
@ApiOperation(value = "test1")
public BaseResponse<String> test1() {
return BaseResponse.ok("添加成功");
}
}
subwayOA-app/src/main/resources/application-dev.yml 0 → 100644
View file @ 35d3ce25
server:
port: 16999
servlet:
context-path: /hzsomms-app/api
spring:
datasource:
druid:
url: jdbc:mysql://47.94.207.62:3306/hzgw?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&zeroDateTimeBehavior=convertToNull
username: root
password: superAdmin&321
driver-class-name: com.mysql.cj.jdbc.Driver
initial-size: 5
min-idle: 5
max-active: 20
maxWait: 60000
timeBetweenEvictionRunsMillis: 60000
minEvictableIdleTimeMillis: 300000
validation-query: SELECT 1
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
redis:
database: 0
host: 47.94.207.62
password: 'redis@123'
port: 6773
mybatis-plus:
mapper-locations: classpath*:com/suntray/subway/oa/app/modules/**/xml/*Mapper.xml
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
call-setters-on-nulls: true
map-underscore-to-camel-case: true
subwayOA-app/src/main/resources/application-hkl.yml 0 → 100644
View file @ 35d3ce25
server:
port: 16999
servlet:
context-path: /hzsomms-app/api
spring:
datasource:
druid:
url: jdbc:mysql://192.168.81.81:3306/hzgw?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&zeroDateTimeBehavior=convertToNull
username: root
password: huang123
driver-class-name: com.mysql.cj.jdbc.Driver
initial-size: 5
min-idle: 5
max-active: 20
maxWait: 60000
timeBetweenEvictionRunsMillis: 60000
minEvictableIdleTimeMillis: 300000
validation-query: SELECT 1
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
redis:
database: 0
host: 47.94.207.62
password: 'redis@123'
port: 6773
mybatis-plus:
mapper-locations: classpath*:com/suntray/subway/oa/app/modules/**/xml/*Mapper.xml
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
call-setters-on-nulls: true
map-underscore-to-camel-case: true
#第三方APP对接
third-app:
# 钉钉小程序应用凭证
dingtalk:
AgentId: 2690626997
AppKey: dingmuvi6qfwaqcpanry
AppSecret: DPgW5bP0ljIeEFB9LKpbDlrZY78MfzE-HMVL3yV1wIhTaaQdJ3PCv1jFMmr-kvAi
subwayOA-app/src/main/resources/application.yml 0 → 100644
View file @ 35d3ce25
spring:
application:
name: subwayOA-app
profiles:
active: dev
subwayOA-app/src/main/resources/logback-spring.xml 0 → 100644
View file @ 35d3ce25
<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
<!--定义日志文件的存储地址 -->
<property name="LOG_HOME" value="../logs" />
<!--<property name="COLOR_PATTERN" value="%black(%contextName-) %red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta( %replace(%caller{1}){'\t|Caller.{1}0|\r\n', ''})- %gray(%msg%xEx%n)" />-->
<!-- 控制台输出 -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50}:%L - %msg%n</pattern>-->
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %highlight(%-5level) %cyan(%logger{50}:%L) - %msg%n</pattern>
</encoder>
</appender>
<!-- 按照每天生成日志文件 -->
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
<!--日志文件输出的文件名 -->
<FileNamePattern>${LOG_HOME}/jeecgboot-%d{yyyy-MM-dd}.%i.log</FileNamePattern>
<!--日志文件保留天数 -->
<MaxHistory>30</MaxHistory>
<maxFileSize>10MB</maxFileSize>
</rollingPolicy>
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50}:%L - %msg%n</pattern>
</encoder>
</appender>
<!-- 生成 error html格式日志开始 -->
<appender name="HTML" class="ch.qos.logback.core.FileAppender">
<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
<!--设置日志级别,过滤掉info日志,只输入error日志-->
<level>ERROR</level>
</filter>
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="ch.qos.logback.classic.html.HTMLLayout">
<pattern>%p%d%msg%M%F{32}%L</pattern>
</layout>
</encoder>
<file>${LOG_HOME}/error-log.html</file>
</appender>
<!-- 生成 error html格式日志结束 -->
<!-- 每天生成一个html格式的日志开始 -->
<appender name="FILE_HTML" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
<!--日志文件输出的文件名 -->
<FileNamePattern>${LOG_HOME}/jeecgboot-%d{yyyy-MM-dd}.%i.html</FileNamePattern>
<!--日志文件保留天数 -->
<MaxHistory>30</MaxHistory>
<MaxFileSize>10MB</MaxFileSize>
</rollingPolicy>
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="ch.qos.logback.classic.html.HTMLLayout">
<pattern>%p%d%msg%M%F{32}%L</pattern>
</layout>
</encoder>
</appender>
<!-- 每天生成一个html格式的日志结束 -->
<!--myibatis log configure -->
<logger name="com.apache.ibatis" level="TRACE" />
<logger name="java.sql.Connection" level="DEBUG" />
<logger name="java.sql.Statement" level="DEBUG" />
<logger name="java.sql.PreparedStatement" level="DEBUG" />
<!-- 日志输出级别 -->
<root level="INFO">
<appender-ref ref="STDOUT" />
<appender-ref ref="FILE" />
<appender-ref ref="HTML" />
<appender-ref ref="FILE_HTML" />
</root>
</configuration>
\ No newline at end of file
subwayOA-app/src/test/java/com/suntray/oa/app/SubwayOaAppApplicationTests.java 0 → 100644
View file @ 35d3ce25
package com.suntray.oa.app;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class SubwayOaAppApplicationTests {
@Test
void contextLoads() {
}
}
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