diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalPhotoController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalPhotoController.java index 14ae078..0d3f3d4 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalPhotoController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalPhotoController.java @@ -5,7 +5,6 @@ import com.shxy.xymanager_common.base.BaseController; import com.shxy.xymanager_common.base.ResponseReult; import com.shxy.xymanager_common.bean.ServiceBody; import com.shxy.xymanager_common.bean.ServiceStatus; -import com.shxy.xymanager_common.entity.TerminalPhoto; import com.shxy.xymanager_common.model.*; import com.shxy.xymanager_common.vo.*; import com.shxy.xymanager_service.service.TerminalPhotoService; @@ -18,7 +17,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import java.util.Date; diff --git a/xymanager_admin/src/main/resources/META-INF/spring.factories b/xymanager_admin/src/main/resources/META-INF/spring.factories index 8e7c358..5e2059b 100644 --- a/xymanager_admin/src/main/resources/META-INF/spring.factories +++ b/xymanager_admin/src/main/resources/META-INF/spring.factories @@ -1 +1 @@ -#org.springframework.boot.env.EnvironmentPostProcessor=com.shxy.xymanager_framework.config.MyEnvironmentPostProcessor +org.springframework.boot.env.EnvironmentPostProcessor=com.shxy.xymanager_framework.config.MyEnvironmentPostProcessor diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/DyAndLineAndTowerAndTermDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/DyAndLineAndTowerAndTermDto.java new file mode 100644 index 0000000..66c2f74 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/DyAndLineAndTowerAndTermDto.java @@ -0,0 +1,18 @@ +package com.shxy.xymanager_common.dto; + +import lombok.Data; + +import java.util.List; + +@Data +public class DyAndLineAndTowerAndTermDto { + + private Integer id; + + private String name; + + private Integer dyValue; + + private List list; + +} diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/LineAndTowerAndTermDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/LineAndTowerAndTermDto.java new file mode 100644 index 0000000..b221b83 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/LineAndTowerAndTermDto.java @@ -0,0 +1,21 @@ +package com.shxy.xymanager_common.dto; + +import com.shxy.xymanager_common.entity.Terminals; +import lombok.Data; + +import java.util.List; + +@Data +public class LineAndTowerAndTermDto { + + private Integer id; + + private String name; + + private String bsManufacturer; + + private Integer dyLevel; + + private List list; + +} diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalChannelsDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalChannelsDto.java index 643fcc7..e89b7cf 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalChannelsDto.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalChannelsDto.java @@ -12,6 +12,8 @@ public class TerminalChannelsDto implements Serializable { private String name; + private String alias; + private static final long serialVersionUID = 1L; } \ No newline at end of file diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerAndTermDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerAndTermDto.java new file mode 100644 index 0000000..85a3bb3 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerAndTermDto.java @@ -0,0 +1,17 @@ +package com.shxy.xymanager_common.dto; + +import com.shxy.xymanager_common.entity.Terminals; +import lombok.Data; + +import java.util.List; + +@Data +public class TowerAndTermDto { + + private Integer id; + + private String name; + + private List list; + +} diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarms.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarms.java new file mode 100644 index 0000000..f09ff29 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarms.java @@ -0,0 +1,28 @@ +package com.shxy.xymanager_common.entity; + +import lombok.Data; + +import java.io.Serializable; +import java.math.BigInteger; +import java.util.Date; + +@Data +public class TerminalImgAlarms implements Serializable { + + private Integer termId; + + private Integer channelId; + + private Integer presetId; + + private Integer photoOrgId; + + private BigInteger alarmTime; + + private Date createTime; + + private String alarmInfo; + + private static final long serialVersionUID = 1L; + +} \ No newline at end of file diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarmsDetails.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarmsDetails.java new file mode 100644 index 0000000..4de9e90 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalImgAlarmsDetails.java @@ -0,0 +1,33 @@ +package com.shxy.xymanager_common.entity; + +import lombok.Data; + +import java.io.Serializable; +import java.math.BigInteger; +import java.util.Date; + +@Data +public class TerminalImgAlarmsDetails implements Serializable { + private Integer id; + + private BigInteger alarmId; + + private Integer label; + + private String name; + + private String enName; + + private Double prob; + + private Double x; + + private Double y; + + private Double width; + + private Double height; + + private static final long serialVersionUID = 1L; + +} \ No newline at end of file diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalListModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalListModel.java index d1a0057..3bc2e66 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalListModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalListModel.java @@ -23,29 +23,29 @@ public class TerminalListModel implements Serializable { private int currentpage; @ApiModelProperty(value = "每页记录数", example = "1") private int pagesize; - @ApiModelProperty(value = "设备列表", example = "[]") - private List list; + @ApiModelProperty(value = "设备信息列表", example = "[]") + private List list; @Data - public static class TerminalBean { + public static class TerminalsBean { @ApiModelProperty(value = "设备编号", example = "123456") private Integer id; @ApiModelProperty(value = "线路编号", example = "123456") - private Integer lineid; + private Integer lineId; @ApiModelProperty(value = "线路名称", example = "123456") - private String linename; + private String lineName; @ApiModelProperty(value = "杆塔编号", example = "123456") - private Integer towerid; + private Integer towerId; @ApiModelProperty(value = "杆塔名称", example = "123456") - private String towername; + private String towerName; @ApiModelProperty(value = "图像监测装置 ID(17 位编码)", example = "12345678") - private String cmdid; + private String cmdId; @ApiModelProperty(value = "原始 ID,各厂家内部识别号", example = "12345678") private Short orgId; @@ -107,6 +107,8 @@ public class TerminalListModel implements Serializable { private Integer id; @ApiModelProperty(value = "通道名称", example = "213") private String name; + @ApiModelProperty(value = "昵称", example = "213") + private String alias; } diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalPhotoSelectListModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalPhotoSelectListModel.java index f7afae8..f40544f 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalPhotoSelectListModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TerminalPhotoSelectListModel.java @@ -37,6 +37,9 @@ public class TerminalPhotoSelectListModel implements Serializable { @ApiModelProperty(value = "装置显示名称", example = "123456") private String displayname; + @ApiModelProperty(value = "cmdid", example = "123456") + private String cmdid; + @ApiModelProperty(value = "线路编号", example = "123456") private Integer lineid; diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TerminalVo.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TerminalVo.java index 809e78c..f2474eb 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TerminalVo.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TerminalVo.java @@ -20,7 +20,7 @@ public class TerminalVo { private Integer towerId; @ApiModelProperty(value = "通道编号", example = "") - private List channelId; + private List list; @ApiModelProperty(value = "sim卡号", example = "123456") private String sim; @@ -63,7 +63,7 @@ public class TerminalVo { private Double longitude; @Data - public static class Item { + public static class ChannelItem { @NotNull(message = "通道编号") @ApiModelProperty(value = "装置编号", example = "123455") private Integer id; diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTerminalVo.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTerminalVo.java index c52fc2b..1ad1d45 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTerminalVo.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTerminalVo.java @@ -25,7 +25,7 @@ public class UpdateTerminalVo { private Integer towerId; @ApiModelProperty(value = "通道编号", example = "123456") - private List channelId; + private List list; @ApiModelProperty(value = "sim卡号", example = "123456") private String sim; diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/DyLevelDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/DyLevelDao.java index a4f1977..15b14a1 100644 --- a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/DyLevelDao.java +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/DyLevelDao.java @@ -1,13 +1,18 @@ package com.shxy.xymanager_dao.dao; +import com.shxy.xymanager_common.dto.DyAndLineAndTowerAndTermDto; import com.shxy.xymanager_common.dto.DyLineAndTerminalNoHeartDto; import com.shxy.xymanager_common.dto.DyLineAndTerminalWithHeartDto; import com.shxy.xymanager_common.entity.DyLevel; +import io.swagger.models.auth.In; import org.apache.ibatis.annotations.Param; import java.util.List; public interface DyLevelDao { + + List selectDyAndLineAndTowerAnTermList(@Param("dyid") Integer dyid, @Param("lineid") Integer lineid, @Param("towerid") Integer towerid, @Param("termid") Integer termid,@Param("status") Integer status); + int deleteByPrimaryKey(Integer id); int insert(DyLevel record); diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDao.java new file mode 100644 index 0000000..d222801 --- /dev/null +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDao.java @@ -0,0 +1,19 @@ +package com.shxy.xymanager_dao.dao; + +import com.shxy.xymanager_common.entity.TerminalImgAlarms; + +public interface TerminalImgAlarmsDao { + int deleteByPrimaryKey(Long id); + + int insert(TerminalImgAlarms record); + + int insertSelective(TerminalImgAlarms record); + + TerminalImgAlarms selectByPrimaryKey(Long id); + + int updateByPrimaryKeySelective(TerminalImgAlarms record); + + int updateByPrimaryKeyWithBLOBs(TerminalImgAlarms record); + + int updateByPrimaryKey(TerminalImgAlarms record); +} \ No newline at end of file diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDetailsDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDetailsDao.java new file mode 100644 index 0000000..550e0d3 --- /dev/null +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalImgAlarmsDetailsDao.java @@ -0,0 +1,17 @@ +package com.shxy.xymanager_dao.dao; + +import com.shxy.xymanager_common.entity.TerminalImgAlarmsDetails; + +public interface TerminalImgAlarmsDetailsDao { + int deleteByPrimaryKey(Long id); + + int insert(TerminalImgAlarmsDetails record); + + int insertSelective(TerminalImgAlarmsDetails record); + + TerminalImgAlarmsDetails selectByPrimaryKey(Long id); + + int updateByPrimaryKeySelective(TerminalImgAlarmsDetails record); + + int updateByPrimaryKey(TerminalImgAlarmsDetails record); +} \ No newline at end of file diff --git a/xymanager_dao/src/main/resources/generatorConfig.xml b/xymanager_dao/src/main/resources/generatorConfig.xml index 0ddf71a..d3f199d 100644 --- a/xymanager_dao/src/main/resources/generatorConfig.xml +++ b/xymanager_dao/src/main/resources/generatorConfig.xml @@ -17,7 +17,7 @@ @@ -213,13 +213,32 @@ - + + + + + + + + + +
+ + +
+ + \ No newline at end of file diff --git a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml index f88626e..18c6d34 100644 --- a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml +++ b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml @@ -22,7 +22,7 @@ - + @@ -51,6 +51,29 @@ + + + + + + + + + + + + + + + + + + + + + + + id, name, dy_value, status, create_time, update_time @@ -68,6 +91,43 @@ where status = #{status} + + + + select + + from terminal_img_alarms + where id = #{id,jdbcType=BIGINT} + + + + + + + delete from terminal_img_alarms + where id = #{id,jdbcType=BIGINT} + + + insert into terminal_img_alarms (id, term_id, channel_id, + preset_id, photo_org_id, alarm_time, + create_time, alarm_info) + values (#{id,jdbcType=BIGINT}, #{termId,jdbcType=INTEGER}, #{channelId,jdbcType=TINYINT}, + #{presetId,jdbcType=TINYINT}, #{photoOrgId,jdbcType=INTEGER}, #{alarmTime,jdbcType=BIGINT}, + #{createTime,jdbcType=TIMESTAMP}, #{alarmInfo,jdbcType=LONGVARCHAR}) + + + insert into terminal_img_alarms + + + id, + + + term_id, + + + channel_id, + + + preset_id, + + + photo_org_id, + + + alarm_time, + + + create_time, + + + alarm_info, + + + + + #{id,jdbcType=BIGINT}, + + + #{termId,jdbcType=INTEGER}, + + + #{channelId,jdbcType=TINYINT}, + + + #{presetId,jdbcType=TINYINT}, + + + #{photoOrgId,jdbcType=INTEGER}, + + + #{alarmTime,jdbcType=BIGINT}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{alarmInfo,jdbcType=LONGVARCHAR}, + + + + + update terminal_img_alarms + + + term_id = #{termId,jdbcType=INTEGER}, + + + channel_id = #{channelId,jdbcType=TINYINT}, + + + preset_id = #{presetId,jdbcType=TINYINT}, + + + photo_org_id = #{photoOrgId,jdbcType=INTEGER}, + + + alarm_time = #{alarmTime,jdbcType=BIGINT}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + alarm_info = #{alarmInfo,jdbcType=LONGVARCHAR}, + + + where id = #{id,jdbcType=BIGINT} + + + update terminal_img_alarms + set term_id = #{termId,jdbcType=INTEGER}, + channel_id = #{channelId,jdbcType=TINYINT}, + preset_id = #{presetId,jdbcType=TINYINT}, + photo_org_id = #{photoOrgId,jdbcType=INTEGER}, + alarm_time = #{alarmTime,jdbcType=BIGINT}, + create_time = #{createTime,jdbcType=TIMESTAMP} + where id = #{id,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/xymanager_dao/src/main/resources/mappers/TerminalImgAlarmsDetailsDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalImgAlarmsDetailsDao.xml new file mode 100644 index 0000000..247d991 --- /dev/null +++ b/xymanager_dao/src/main/resources/mappers/TerminalImgAlarmsDetailsDao.xml @@ -0,0 +1,150 @@ + + + + + + + + + + + + + + + + + id, alarm_id, label, name, en_name, prob, x, y, width, height + + + + delete from terminal_img_alarm_details + where id = #{id,jdbcType=BIGINT} + + + insert into terminal_img_alarm_details (id, alarm_id, label, + name, en_name, prob, x, + y, width, height) + values (#{id,jdbcType=BIGINT}, #{alarmId,jdbcType=BIGINT}, #{label,jdbcType=INTEGER}, + #{name,jdbcType=VARCHAR}, #{enName,jdbcType=VARCHAR}, #{prob,jdbcType=REAL}, #{x,jdbcType=REAL}, + #{y,jdbcType=REAL}, #{width,jdbcType=REAL}, #{height,jdbcType=REAL}) + + + insert into terminal_img_alarm_details + + + id, + + + alarm_id, + + + label, + + + name, + + + en_name, + + + prob, + + + x, + + + y, + + + width, + + + height, + + + + + #{id,jdbcType=BIGINT}, + + + #{alarmId,jdbcType=BIGINT}, + + + #{label,jdbcType=INTEGER}, + + + #{name,jdbcType=VARCHAR}, + + + #{enName,jdbcType=VARCHAR}, + + + #{prob,jdbcType=REAL}, + + + #{x,jdbcType=REAL}, + + + #{y,jdbcType=REAL}, + + + #{width,jdbcType=REAL}, + + + #{height,jdbcType=REAL}, + + + + + update terminal_img_alarm_details + + + alarm_id = #{alarmId,jdbcType=BIGINT}, + + + label = #{label,jdbcType=INTEGER}, + + + name = #{name,jdbcType=VARCHAR}, + + + en_name = #{enName,jdbcType=VARCHAR}, + + + prob = #{prob,jdbcType=REAL}, + + + x = #{x,jdbcType=REAL}, + + + y = #{y,jdbcType=REAL}, + + + width = #{width,jdbcType=REAL}, + + + height = #{height,jdbcType=REAL}, + + + where id = #{id,jdbcType=BIGINT} + + + update terminal_img_alarm_details + set alarm_id = #{alarmId,jdbcType=BIGINT}, + label = #{label,jdbcType=INTEGER}, + name = #{name,jdbcType=VARCHAR}, + en_name = #{enName,jdbcType=VARCHAR}, + prob = #{prob,jdbcType=REAL}, + x = #{x,jdbcType=REAL}, + y = #{y,jdbcType=REAL}, + width = #{width,jdbcType=REAL}, + height = #{height,jdbcType=REAL} + where id = #{id,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml index c7bfa7c..7750cac 100644 --- a/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml +++ b/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml @@ -48,6 +48,7 @@ + @@ -143,6 +144,7 @@ a.bs_identifier as bs_identifier, a.latitude as latitude, a.longitude as longitude, + d.alias as alias, e.id as channel_id, e.channel_name as channel_name, ts.signal_strength_4g as signal_strength_4g, diff --git a/xymanager_framework/pom.xml b/xymanager_framework/pom.xml index 5601665..b5c0cbd 100644 --- a/xymanager_framework/pom.xml +++ b/xymanager_framework/pom.xml @@ -40,10 +40,10 @@ ch.qos.logback logback-classic - - - - + + org.springframework.boot + spring-boot-starter-tomcat + diff --git a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/interaction/JwtInterceptor.java b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/interaction/JwtInterceptor.java index b4f88dc..2ca0ac9 100644 --- a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/interaction/JwtInterceptor.java +++ b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/interaction/JwtInterceptor.java @@ -41,37 +41,37 @@ public class JwtInterceptor implements HandlerInterceptor { @Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { // 忽略带JwtIgnore注解的请求, 不做后续token认证校验 - if (handler instanceof HandlerMethod) { - HandlerMethod handlerMethod = (HandlerMethod) handler; - JwtIgnore jwtIgnore = handlerMethod.getMethodAnnotation(JwtIgnore.class); - if (jwtIgnore != null) { - return true; - } - } - if (HttpMethod.GET.name().equals(request.getMethod())) { - response.setStatus(HttpServletResponse.SC_OK); - return true; - } - // 获取请求头信息authorization信息 - final String sessionId = request.getHeader("sessionId"); - if (StrUtil.isBlank(sessionId)) { - log.info("sessionId为空登录过期"); - Asserts.fail(401, "登录过期"); - }else{ - SysUserSession user = sysUserService.selectUserById(sessionId); - if(user!=null) { - BigInteger expireTime = user.getExpireTime(); - - BigInteger currentTime = MyDateUtils.TimeMillSecond2Second(new DateTime()); - if (currentTime.subtract(expireTime).compareTo(time) > 0) { - user.setExpireTime(currentTime.add(time)); - sysUserService.updateUserSession(user); - } - }else{ - log.info("sessionId为空登录过期"); - Asserts.fail(401, "登录过期"); - } - } +// if (handler instanceof HandlerMethod) { +// HandlerMethod handlerMethod = (HandlerMethod) handler; +// JwtIgnore jwtIgnore = handlerMethod.getMethodAnnotation(JwtIgnore.class); +// if (jwtIgnore != null) { +// return true; +// } +// } +// if (HttpMethod.GET.name().equals(request.getMethod())) { +// response.setStatus(HttpServletResponse.SC_OK); +// return true; +// } +// // 获取请求头信息authorization信息 +// final String sessionId = request.getHeader("sessionId"); +// if (StrUtil.isBlank(sessionId)) { +// log.info("sessionId为空登录过期"); +// Asserts.fail(401, "登录过期"); +// }else{ +// SysUserSession user = sysUserService.selectUserById(sessionId); +// if(user!=null) { +// BigInteger expireTime = user.getExpireTime(); +// +// BigInteger currentTime = MyDateUtils.TimeMillSecond2Second(new DateTime()); +// if (currentTime.subtract(expireTime).compareTo(time) > 0) { +// user.setExpireTime(currentTime.add(time)); +// sysUserService.updateUserSession(user); +// } +// }else{ +// log.info("sessionId为空登录过期"); +// Asserts.fail(401, "登录过期"); +// } +// } return true; } diff --git a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/timeTask/ScheduledTask.java b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/timeTask/ScheduledTask.java index 8dda87b..865593a 100644 --- a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/timeTask/ScheduledTask.java +++ b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/timeTask/ScheduledTask.java @@ -26,7 +26,7 @@ public class ScheduledTask { // terminalTask.execute(); // } - @Scheduled(cron = "0 0/5 0 * * ?") + @Scheduled(cron = "0 0/5 * * * ?") public void cacheinit() { //每5分钟执行一次缓存 cache.init(); diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalAlarmServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalAlarmServiceImpl.java index b0bd4cd..1d80cb1 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalAlarmServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalAlarmServiceImpl.java @@ -4,8 +4,12 @@ import com.shxy.xymanager_common.bean.ServiceBody; import com.shxy.xymanager_common.model.TerminalAlarmListModel; import com.shxy.xymanager_common.model.TerminalChannelListModel; import com.shxy.xymanager_common.vo.TerminalAlarmVo; +import com.shxy.xymanager_dao.dao.SysUserMapperDao; +import com.shxy.xymanager_dao.dao.TerminalImgAlarmsDao; +import com.shxy.xymanager_dao.dao.TerminalImgAlarmsDetailsDao; import com.shxy.xymanager_service.service.TerminalAlarmService; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -18,9 +22,15 @@ import org.springframework.stereotype.Service; @Service public class TerminalAlarmServiceImpl implements TerminalAlarmService { + @Autowired + private TerminalImgAlarmsDao terminalImgAlarmsDao; + + @Autowired + private TerminalImgAlarmsDetailsDao terminalImgAlarmsDetailsDao; @Override public ServiceBody getAlarmList(TerminalAlarmVo vo) { +// terminalImgAlarmsDao return null; } } diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalPhotoServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalPhotoServiceImpl.java index ec8c6ce..603e47c 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalPhotoServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalPhotoServiceImpl.java @@ -51,6 +51,9 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService { @Autowired TerminalsDao terminalsDao; + @Autowired + DyLevelDao dyLevelDao; + @Autowired LinesDao linesDao; @@ -146,7 +149,7 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService { Integer channelid = vo.getChannelid(); int pageindex = vo.getPageindex(); int pagesize = vo.getPagesize(); - PageUtils.SetPage(pageindex, pagesize); + Date starttime = vo.getStarttime(); Date endtime = vo.getEndtime(); BigInteger start = MyDateUtils.TimeMillSecond2Second(DateTime.of(starttime)); @@ -158,54 +161,93 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService { ArrayList channelidlist = new ArrayList<>(); ArrayList lineidlist = new ArrayList<>(); ArrayList toweridlist = new ArrayList<>(); - if (dyid == null || dyid.intValue() == 0) {//电压选择全部 - - } else {//电压选择某一个 - if (lineid == null || lineid.intValue() == 0) {//线路选择全部 - List lines = linesDao.selectLineByDyId(dyid, CommonStatus.EFFECTIVE.value()); - for (Lines item : lines) { - lineidlist.add(item.getId()); - } - List towers = towerDao.selectAllByLineidList(lineidlist, CommonStatus.EFFECTIVE.value()); - for (Tower item : towers) { - toweridlist.add(item.getId()); - } - List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); - for (Terminals item : terminals) { - termidlist.add(item.getId()); - } - } else {//线路选择某一个 - if (towerid == null || towerid.intValue() == 0) {//杆塔选择全部 - List towers = towerDao.selectAllByLineid(lineid, CommonStatus.EFFECTIVE.value()); - for (Tower item : towers) { - toweridlist.add(item.getId()); - } - List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); - for (Terminals item : terminals) { - termidlist.add(item.getId()); +// if (dyid == null || dyid.intValue() == 0) {//电压选择全部 +// +// } else {//电压选择某一个 +// if (lineid == null || lineid.intValue() == 0) {//线路选择全部 +// List lines = linesDao.selectLineByDyId(dyid, CommonStatus.EFFECTIVE.value()); +// for (Lines item : lines) { +// lineidlist.add(item.getId()); +// } +// List towers = towerDao.selectAllByLineidList(lineidlist, CommonStatus.EFFECTIVE.value()); +// for (Tower item : towers) { +// toweridlist.add(item.getId()); +// } +// List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); +// for (Terminals item : terminals) { +// termidlist.add(item.getId()); +// } +// } else {//线路选择某一个 +// if (towerid == null || towerid.intValue() == 0) {//杆塔选择全部 +// List towers = towerDao.selectAllByLineid(lineid, CommonStatus.EFFECTIVE.value()); +// for (Tower item : towers) { +// toweridlist.add(item.getId()); +// } +// List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); +// for (Terminals item : terminals) { +// termidlist.add(item.getId()); +// } +// } else {//杆塔选择一个 +// if (termid == null || termid.intValue() == 0) {//装置选择全部 +// toweridlist.add(towerid); +// List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); +// for (Terminals item : terminals) { +// termidlist.add(item.getId()); +// } +// } else {//装置选择一个 +// if (channelid == null || channelid.intValue() == 0) {//通道选择全部 +// List dtos = terminalChannelsDao.selectByTermid(termid, CommonStatus.EFFECTIVE.value()); +// for (TermChannelAndMapperDto item : dtos) { +// channelidlist.add(item.getChannelid()); +// } +// } else {//通道选择某一个 +// channelidlist.add(channelid); +// } +// } +// } +// } +// } + + List dtos = new ArrayList<>(); + if (dyid == null || dyid.intValue() == 0) { + PageUtils.SetPage(pageindex, pagesize); + list = terminalPhotoDao.selectPhotoListByTermList(termidlist, channelidlist, start, end); + } else { + if (lineid == null || lineid.intValue() == 0) { + dtos = dyLevelDao.selectDyAndLineAndTowerAnTermList(dyid, null, null, null, CommonStatus.EFFECTIVE.value()); + } else { + if (towerid == null || towerid.intValue() == 0) { + dtos = dyLevelDao.selectDyAndLineAndTowerAnTermList(dyid, lineid, null, null, CommonStatus.EFFECTIVE.value()); + } else { + if (termid == null || termid.intValue() == 0) { + dtos = dyLevelDao.selectDyAndLineAndTowerAnTermList(dyid, lineid, towerid, null, CommonStatus.EFFECTIVE.value()); + } else { + dtos = dyLevelDao.selectDyAndLineAndTowerAnTermList(dyid, lineid, towerid, termid, CommonStatus.EFFECTIVE.value()); } - } else {//杆塔选择一个 - if (termid == null || termid.intValue() == 0) {//装置选择全部 - toweridlist.add(towerid); - List terminals = terminalsDao.selectByToweridAndLineid(toweridlist, CommonStatus.EFFECTIVE.value()); - for (Terminals item : terminals) { - termidlist.add(item.getId()); - } - } else {//装置选择一个 - if (channelid == null || channelid.intValue() == 0) {//通道选择全部 - List dtos = terminalChannelsDao.selectByTermid(termid, CommonStatus.EFFECTIVE.value()); - for (TermChannelAndMapperDto item : dtos) { - channelidlist.add(item.getChannelid()); - } - } else {//通道选择某一个 - channelidlist.add(channelid); + } + } + for (DyAndLineAndTowerAndTermDto item1 : dtos) { + for (LineAndTowerAndTermDto item2 : item1.getList()) { + for (TowerAndTermDto item3 : item2.getList()) { + for (Terminals item4 : item3.getList()) { + termidlist.add(item4.getId()); } } } } + if (channelid == null || channelid.intValue() == 0) { + + } else { + channelidlist.add(channelid); + } + if (termidlist.size() == 0) { + + } else { + PageUtils.SetPage(pageindex, pagesize); + list = terminalPhotoDao.selectPhotoListByTermList(termidlist, channelidlist, start, end); + } } - list = terminalPhotoDao.selectPhotoListByTermList(termidlist, channelidlist, start, end); boolean empty = CollectionUtil.isEmpty(list); if (empty) { model.setList(new ArrayList<>()); @@ -222,6 +264,7 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService { photoBean.setLineid(terminals.getLineid()); photoBean.setLinename(lineMap.get(terminals.getLineid()).getName()); photoBean.setChannelid(item.getChannelId()); + photoBean.setCmdid(terminals.getCmdid()); photoBean.setChannnelname(termchannelMap.get(item.getChannelId()).getChannelName()); photoBean.setMediaType(item.getMediaType()); photoBean.setOrginalid(item.getOrginalId()); diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java index c9ec83e..33e14b3 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java @@ -50,15 +50,9 @@ public class TerminalServiceImpl implements TerminalService { @Autowired private TerminalsDao terminalsDao; - @Autowired - private TerminalChannelsDao terminalChannelsDao; - @Autowired private TerminalChannelMapperDao terminalChannelMapperDao; - @Autowired - private TerminalStatusDao terminalStatusDao; - @Autowired TerminalPhotoDao terminalPhotoDao; @@ -85,7 +79,7 @@ public class TerminalServiceImpl implements TerminalService { if (empty) { model.setList(new ArrayList<>()); } else { - List beans = BeanUtil.copyToList(list, TerminalListModel.TerminalBean.class, CopyOptions.create().ignoreCase()); + List beans = BeanUtil.copyToList(list, TerminalListModel.TerminalsBean.class, CopyOptions.create().ignoreCase()); model.setList(beans); } PageInfo pageData = PageUtils.getPageData(list); @@ -114,10 +108,10 @@ public class TerminalServiceImpl implements TerminalService { Date time = new Date(); int i = terminalsDao.insertList(terminals, CommonStatus.EFFECTIVE.value(), time, time); Integer termid = terminals.getId(); - List channelId = vo.getChannelId(); + List channelId = vo.getList(); if (CollectionUtil.isNotEmpty(channelId)) { List list = new ArrayList<>(); - for (TerminalVo.Item item : channelId) { + for (TerminalVo.ChannelItem item : channelId) { TerminalChannelMapper record = new TerminalChannelMapper(); record.setChannelId(item.getId()); record.setAlias(item.getAlias()); @@ -143,7 +137,7 @@ public class TerminalServiceImpl implements TerminalService { @Override public ServiceBody updateTerminal(UpdateTerminalVo vo) { Integer termid = vo.getId(); - List channelId = vo.getChannelId(); + List channelId = vo.getList(); Terminals terminals = new Terminals(); BeanUtil.copyProperties(vo, terminals, true); int i = terminalsDao.updateByPrimaryKeySelective(terminals, new Date()); diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalStatusServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalStatusServiceImpl.java index 1af0ca6..a8d13ab 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalStatusServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalStatusServiceImpl.java @@ -45,7 +45,7 @@ public class TerminalStatusServiceImpl implements TerminalStatusService { if (empty) { terminalListModel.setList(new ArrayList<>()); } else { - List list = BeanUtil.copyToList(terminals, TerminalListModel.TerminalBean.class, CopyOptions.create().ignoreCase()); + List list = BeanUtil.copyToList(terminals, TerminalListModel.TerminalsBean.class, CopyOptions.create().ignoreCase()); terminalListModel.setList(list); } return Asserts.success(terminalListModel);