diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/GloableParamsController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/GloableParamsController.java new file mode 100644 index 0000000..0d0791f --- /dev/null +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/GloableParamsController.java @@ -0,0 +1,55 @@ +package com.shxy.xymanager_admin.controller; + +import com.shxy.xymanager_common.annotation.Log; +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_service.service.GloablParamsService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiResponse; +import io.swagger.annotations.ApiResponses; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + + +@Api(value = "全局参数设置接口", tags = "全局参数设置接口相关") +@RestController +@Slf4j +public class GloableParamsController extends BaseController { + + @Autowired + GloablParamsService gloableParamsService; + + @ApiOperation(value = "查询图片绘制开关状态", notes = "查询图片绘制开关状态接口", httpMethod = "POST") + @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) + @RequestMapping("/getMarkEnableStatus") + @Log(title = "新增杆塔", type = "查询") + public ResponseReult getMarkEnableStatus() { + ServiceBody serviceBody = gloableParamsService.getMarkEnableStatus(); + if (serviceBody.getCode() == ServiceStatus.SUCCESS) { + return ResponseReult.success(serviceBody.getData()); + } else { + return ResponseReult.error(serviceBody.getCode(), serviceBody.getMsg()); + } + } + + @ApiOperation(value = "新增杆塔", notes = "新增杆塔接口", httpMethod = "POST") + @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) + @RequestMapping("/updateMarkEnableStatus") + @Log(title = "新增杆塔", type = "查询") + public ResponseReult updateMarkEnableStatus(@RequestParam("status") Integer status) { + ServiceBody serviceBody = gloableParamsService.updateMarkEnableStatus(status); + if (serviceBody.getCode() == ServiceStatus.SUCCESS) { + return ResponseReult.success(serviceBody.getData()); + } else { + return ResponseReult.error(serviceBody.getCode(), serviceBody.getMsg()); + } + } + + +} diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TowerController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TowerController.java index f4abc47..0ea56bd 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TowerController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TowerController.java @@ -10,7 +10,7 @@ import com.shxy.xymanager_common.model.AllTowerListModel; import com.shxy.xymanager_common.model.TowerListModel; import com.shxy.xymanager_common.vo.PageVo; import com.shxy.xymanager_common.vo.TowerIdVo; -import com.shxy.xymanager_common.vo.TowerVo; +import com.shxy.xymanager_common.vo.TowersVo; import com.shxy.xymanager_common.vo.UpdateTowerVo; import com.shxy.xymanager_service.service.TowerService; import io.swagger.annotations.Api; @@ -38,7 +38,7 @@ public class TowerController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/addTower") @Log(title = "新增杆塔", type = "查询") - public ResponseReult addTower(@RequestBody @Validated TowerVo vo) { + public ResponseReult addTower(@RequestBody @Validated TowersVo vo) { ServiceBody serviceBody = towerService.addTower(vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); @@ -64,7 +64,7 @@ public class TowerController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getTowerInfo") @Log(title = "获取杆塔", type = "查询") - public ResponseReult getTowerInfo(@RequestParam("id")Integer id) { + public ResponseReult getTowerInfo(@RequestParam("id") Integer id) { ServiceBody serviceBody = towerService.getTowerInfo(id); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); @@ -113,5 +113,4 @@ public class TowerController extends BaseController { } - } 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/TowerDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerDto.java index 3e5b1b2..3e05a4a 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerDto.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TowerDto.java @@ -14,6 +14,10 @@ public class TowerDto implements Serializable { private String lineName; + private Integer order; + + private Integer status; + 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/GlobalParams.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/GlobalParams.java new file mode 100644 index 0000000..49d9173 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/GlobalParams.java @@ -0,0 +1,22 @@ +package com.shxy.xymanager_common.entity; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +@Data +public class GlobalParams implements Serializable { + private Integer id; + + private String paramName; + + private String paramValue; + + private Date createTime; + + private Date updateTime; + + 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/Tower.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/Tower.java deleted file mode 100644 index d2de881..0000000 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/Tower.java +++ /dev/null @@ -1,14 +0,0 @@ -package com.shxy.xymanager_common.entity; - -import lombok.Data; - -import java.io.Serializable; - -@Data -public class Tower implements Serializable { - - private Integer id; - private String name; - private Integer lineId; - -} \ No newline at end of file diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/Towers.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/Towers.java new file mode 100644 index 0000000..e63ce3e --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/Towers.java @@ -0,0 +1,20 @@ +package com.shxy.xymanager_common.entity; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +@Data +public class Towers implements Serializable { + + private Integer id; + private String name; + private Integer lineId; + private Integer order; + private Integer status; + private Date createTime; + + private Date updateTime; + +} \ No newline at end of file diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/enums/GloableParamsType.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/enums/GloableParamsType.java new file mode 100644 index 0000000..0124106 --- /dev/null +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/enums/GloableParamsType.java @@ -0,0 +1,27 @@ +package com.shxy.xymanager_common.enums; + + +/** + * 常用状态 + * "ImgMark" + * + * @author 晶晶 + */ +public enum GloableParamsType { + ImgMark("img_mark"); + + private String name; + + GloableParamsType(String name) { + this.name = name; + } + + @Override + public String toString() { + return this.name; + } + + public String value() { + return this.name; + } +} diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/AllTowerListModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/AllTowerListModel.java index 2ae247b..6dfa190 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/AllTowerListModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/AllTowerListModel.java @@ -32,5 +32,8 @@ public class AllTowerListModel implements Serializable { @ApiModelProperty(value = "线路编号", example = "123456") private String lineName; + @ApiModelProperty(value = "杆塔排序", example = "123456") + private Integer order; + } } diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/PhotoMarkModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/PhotoMarkModel.java index 2c6109e..5a24e12 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/PhotoMarkModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/PhotoMarkModel.java @@ -44,4 +44,7 @@ public class PhotoMarkModel implements Serializable { @ApiModelProperty(value = "通道编号和名称", example = "213") private List list; + @ApiModelProperty(value = "", example = "0--关 1---开启") + private Integer markEnable; + } diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TowerListModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TowerListModel.java index 53cd6f1..524fa33 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TowerListModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/TowerListModel.java @@ -41,6 +41,9 @@ public class TowerListModel implements Serializable { @ApiModelProperty(value = "线路编号", example = "123456") private String lineName; + @ApiModelProperty(value = "杆塔排序", example = "123456") + private Integer order; + } diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowerVo.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowersVo.java similarity index 70% rename from xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowerVo.java rename to xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowersVo.java index aa52c70..837aa31 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowerVo.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/TowersVo.java @@ -4,31 +4,34 @@ import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; -import javax.validation.constraints.Min; import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotEmpty; +import javax.validation.constraints.NotNull; import java.util.List; @Data @ApiModel(value = "杆塔对象", description = "杆塔对象描述") -public class TowerVo { +public class TowersVo { @NotEmpty(message = "不能传入空值") @ApiModelProperty(value = "杆塔对象数组", required = true, example = "A0001") - private List list; + private List list; @Data public static class TowerItem { @ApiModelProperty(value = "线路编号", example = "123456") - @NotBlank(message = "线路编号不能缺少") + @NotNull(message = "线路编号不能缺少") private Integer lineId; @ApiModelProperty(value = "杆塔名称", example = "12345678") @NotBlank(message = "杆塔名称") private String name; - } + @ApiModelProperty(value = "杆塔排序顺序", example = "12345678") + @NotNull(message = "杆塔排序顺序") + private Integer order; + } } diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTowerVo.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTowerVo.java index c0bcab5..6a158d5 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTowerVo.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/vo/UpdateTowerVo.java @@ -23,6 +23,9 @@ public class UpdateTowerVo { @NotNull(message = "线路编号不能缺少") private Integer lineId; + @ApiModelProperty(value = "排序", example = "单位") + @NotNull(message = "排序") + private Integer order; } diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/GlobalParamsDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/GlobalParamsDao.java new file mode 100644 index 0000000..1d5a5c4 --- /dev/null +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/GlobalParamsDao.java @@ -0,0 +1,25 @@ +package com.shxy.xymanager_dao.dao; + +import com.shxy.xymanager_common.entity.GlobalParams; +import org.apache.ibatis.annotations.Param; + +import java.util.Date; +import java.util.List; + +public interface GlobalParamsDao { + int deleteByPrimaryKey(Long id); + + int insert(GlobalParams record); + + int insertSelective(GlobalParams record); + + GlobalParams selectByPrimaryKey(Long id); + + List selectAll(); + + int updateByPrimaryKeySelective(GlobalParams record); + + int updateByPrimaryKey(GlobalParams record); + + int updateByParamName(@Param("data") GlobalParams record, @Param("updatetime") Date updatetime); +} \ No newline at end of file diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalPhotoDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalPhotoDao.java index 53f2514..e0b8c34 100644 --- a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalPhotoDao.java +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalPhotoDao.java @@ -15,7 +15,7 @@ public interface TerminalPhotoDao { List selectPhotoList(@Param("terminalid") Integer terminalid, @Param("channelid") List channelid, @Param("starttime") BigInteger starttime, @Param("endtime") BigInteger endtime); - List selectPhotoListByOrginIdList(@Param("orginidlist") List orginidlist); + List selectPhotoListByOrginIdAndTermList(@Param("list") List list); List selectPhotoListByTermList(@Param("terminalidlist") List terminalid, @Param("channelidlist") List channelid, @Param("starttime") BigInteger starttime, @Param("endtime") BigInteger endtime); diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TowerDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TowerDao.java index 62779d8..1c78c56 100644 --- a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TowerDao.java +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TowerDao.java @@ -1,7 +1,7 @@ package com.shxy.xymanager_dao.dao; import com.shxy.xymanager_common.dto.TowerDto; -import com.shxy.xymanager_common.entity.Tower; +import com.shxy.xymanager_common.entity.Towers; import org.apache.ibatis.annotations.Param; import java.util.Date; @@ -10,17 +10,17 @@ import java.util.List; public interface TowerDao { - int addTower(@Param("list") List towerLst, @Param("date")Date date); + int addTower(@Param("list") List towersLst, @Param("status") Integer status, @Param("date") Date date); - List selectAll(@Param("status") Integer status); + List selectAll(@Param("status") Integer status); - List selectAllByLineid(@Param("lineid") Integer id,@Param("status") Integer status); + List selectAllByLineid(@Param("lineid") Integer id, @Param("status") Integer status); - List selectAllByLineidList(@Param("lineidlist") List id,@Param("status") Integer status); + List selectAllByLineidList(@Param("lineidlist") List id, @Param("status") Integer status); - int deleteById(@Param("list") List record, @Param("status") Integer status, @Param("update") Date update); + int deleteById(@Param("list") List record, @Param("status") Integer status, @Param("update") Date update); - int updateByPrimaryKeySelective(@Param("data") Tower record, @Param("update") Date update); + int updateByPrimaryKeySelective(@Param("data") Towers record, @Param("update") Date update); - TowerDto getInfoByPrimaryKey(@Param("id") Integer id, @Param("status") Integer status); + TowerDto getInfoByPrimaryKey(@Param("id") Integer id, @Param("status") Integer status); } \ 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 7d64fd1..b08d042 100644 --- a/xymanager_dao/src/main/resources/generatorConfig.xml +++ b/xymanager_dao/src/main/resources/generatorConfig.xml @@ -237,9 +237,17 @@ - + + + + + + + +
diff --git a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml index 18c6d34..cfe072f 100644 --- a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml +++ b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml @@ -109,7 +109,7 @@ d.display_name as display_name, d.model as model from (((dy_level a left join `lines` b on a.id = b.dy_level_id and a.status = #{status} and b.status =#{status}) - left join tower c on c.line_id = b.id and c.status = #{status}) + left join towers c on c.line_id = b.id and c.status = #{status}) left join terminals d on d.tower_id = c.id and d.status = #{status}) true @@ -147,7 +147,7 @@ f.last_heartbeat as last_heartbeat from ((((dy_level z left join `lines` x on z.id = x.dy_level_id and x.status = #{status} and z.status = #{status}) left join terminals y on x.id = y.line_id and y.status = #{status}) - left join tower t on y.tower_id = t.id) + left join towers t on y.tower_id = t.id) left join terminal_status f on f.term_id = y.id) diff --git a/xymanager_dao/src/main/resources/mappers/GlobalParamsDao.xml b/xymanager_dao/src/main/resources/mappers/GlobalParamsDao.xml new file mode 100644 index 0000000..fca3365 --- /dev/null +++ b/xymanager_dao/src/main/resources/mappers/GlobalParamsDao.xml @@ -0,0 +1,108 @@ + + + + + + + + + + + + id, param_name, param_value, create_time, update_time + + + + + + delete from global_params + where id = #{id,jdbcType=BIGINT} + + + insert into global_params (id, param_name, param_value, + create_time, update_time) + values (#{id,jdbcType=BIGINT}, #{paramName,jdbcType=VARCHAR}, #{paramValue,jdbcType=VARCHAR}, + #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}) + + + insert into global_params + + + id, + + + param_name, + + + param_value, + + + create_time, + + + update_time, + + + + + #{id,jdbcType=BIGINT}, + + + #{paramName,jdbcType=VARCHAR}, + + + #{paramValue,jdbcType=VARCHAR}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{updateTime,jdbcType=TIMESTAMP}, + + + + + update global_params + + + param_name = #{paramName,jdbcType=VARCHAR}, + + + param_value = #{paramValue,jdbcType=VARCHAR}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + where id = #{id,jdbcType=BIGINT} + + + update global_params + set param_name = #{paramName,jdbcType=VARCHAR}, + param_value = #{paramValue,jdbcType=VARCHAR}, + create_time = #{createTime,jdbcType=TIMESTAMP}, + update_time = #{updateTime,jdbcType=TIMESTAMP} + where id = #{id,jdbcType=BIGINT} + + + + update global_params + set + param_value = #{data.paramValue}, + update_time = #{updatetime} + where param_name = #{data.paramName} + + \ No newline at end of file diff --git a/xymanager_dao/src/main/resources/mappers/SysUserDao.xml b/xymanager_dao/src/main/resources/mappers/SysUserDao.xml index 467e1c1..9ad5d3a 100644 --- a/xymanager_dao/src/main/resources/mappers/SysUserDao.xml +++ b/xymanager_dao/src/main/resources/mappers/SysUserDao.xml @@ -17,21 +17,21 @@ - delete from sys_user + delete from sys_users where uid = #{uid,jdbcType=INTEGER} - insert into sys_user (uid, user_name, status, + insert into sys_users (uid, user_name, status, nick_name, password, role, create_time, update_time) values (#{uid,jdbcType=INTEGER}, #{userName,jdbcType=VARCHAR}, #{status,jdbcType=INTEGER}, @@ -39,7 +39,7 @@ #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}) - insert into sys_user + insert into sys_users uid, @@ -94,7 +94,7 @@ - update sys_user + update sys_users user_name = #{userName,jdbcType=VARCHAR}, @@ -121,7 +121,7 @@ where uid = #{uid,jdbcType=INTEGER} - update sys_user + update sys_users set user_name = #{userName,jdbcType=VARCHAR}, status = #{status,jdbcType=INTEGER}, nick_name = #{nickName,jdbcType=VARCHAR}, diff --git a/xymanager_dao/src/main/resources/mappers/SysUserMapperDao.xml b/xymanager_dao/src/main/resources/mappers/SysUserMapperDao.xml index 9ce39b9..041e89e 100644 --- a/xymanager_dao/src/main/resources/mappers/SysUserMapperDao.xml +++ b/xymanager_dao/src/main/resources/mappers/SysUserMapperDao.xml @@ -25,11 +25,11 @@ user_name, `status` FROM - sys_user u + sys_users u - update sys_user set password = #{password} where user_name = #{userName} + update sys_users set password = #{password} where user_name = #{userName} - insert into sys_user(user_name,nick_name,password,role,create_time) + insert into sys_users(user_name,nick_name,password,role,create_time) values(#{userName},#{userName},#{password},#{role},#{createTime}) @@ -89,7 +89,7 @@ - update `sys_user` + update `sys_users` user_name = #{userName}, @@ -111,7 +111,7 @@ - update `sys_user` + update `sys_users` set status = 0 where uid = #{userId} @@ -129,7 +129,7 @@ nick_name as nickName, create_time as createTime, role - from sys_user + from sys_users WHERE status = #{status} order by create_time desc diff --git a/xymanager_dao/src/main/resources/mappers/TerminalPhotoDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalPhotoDao.xml index fdc30e5..6546989 100644 --- a/xymanager_dao/src/main/resources/mappers/TerminalPhotoDao.xml +++ b/xymanager_dao/src/main/resources/mappers/TerminalPhotoDao.xml @@ -111,16 +111,24 @@ order by photo_time desc - select from terminal_photos - - where orginal_id in - - #{item} + + where + + ( + + orginal_id = #{item.photoOrgId} + + + and term_id = #{item.termId} + + ) + @@ -16,27 +20,30 @@ t.id as id, t.name as name, l.id as lineId, - l.name as lineName - from tower t, + l.name as lineName, + t.order as `order`, + t.status as status + from towers t, `lines` l - where t.line_id = l.id and t.status = #{status,jdbcType=INTEGER} order by t.create_time desc + where t.line_id = l.id and t.status = #{status,jdbcType=INTEGER} order by t.`order` asc - select - id, name, line_id - from tower + id, name, line_id,`order`,status + from towers where status = #{status} and line_id = #{lineid} + order by `order` asc - select - id, name, line_id - from tower + id, name, line_id,`order`,status + from towers where status = #{status} and line_id in @@ -44,6 +51,7 @@ #{item} + order by `order` asc - insert into `tower` - (name,line_id,create_time,update_time) + insert into `towers` + (name,line_id,status,`order`,create_time,update_time) VALUES - (#{item.name},#{item.lineId},#{date},#{date}) + (#{item.name},#{item.lineId},#{status},#{item.order},#{date},#{date}) - update `tower` + update `towers` set status = #{status}, update_time = #{update} where id in @@ -78,8 +88,8 @@ - - update `tower` + + update `towers` name = #{data.name,jdbcType=VARCHAR}, @@ -87,6 +97,10 @@ line_id = #{data.lineId,jdbcType=INTEGER}, + + `order` = #{data.order}, + + update_time = #{update} where id = #{data.id} 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_service/src/main/java/com/shxy/xymanager_service/cache/XyCache.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/cache/XyCache.java index 344c12f..6711022 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/cache/XyCache.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/cache/XyCache.java @@ -2,10 +2,7 @@ package com.shxy.xymanager_service.cache; import com.shxy.xymanager_common.dto.LineAndDyNameDto; import com.shxy.xymanager_common.dto.TowerDto; -import com.shxy.xymanager_common.entity.TerminalChannelMapper; -import com.shxy.xymanager_common.entity.TerminalChannels; -import com.shxy.xymanager_common.entity.TerminalImgAlarmParams; -import com.shxy.xymanager_common.entity.Terminals; +import com.shxy.xymanager_common.entity.*; import com.shxy.xymanager_common.enums.CommonStatus; import com.shxy.xymanager_dao.dao.*; import org.springframework.beans.factory.annotation.Autowired; @@ -28,6 +25,8 @@ public class XyCache { //告警类型 public static Map alarmParamMap = new HashMap(); + public static Map globalParams = new HashMap(); + @Autowired private LinesDao linesDao; @Autowired @@ -40,6 +39,8 @@ public class XyCache { private TerminalChannelMapperDao terminalChannelMapperDao; @Autowired private TerminalImgAlarmParamsDao terminalImgAlarmParamsDao; + @Autowired + private GlobalParamsDao globalParamsDao; @PostConstruct public void init() { @@ -51,6 +52,7 @@ public class XyCache { termchannelMap.clear(); termchannelMapMap.clear(); alarmParamMap.clear(); + globalParams.clear(); List lineAndDyNameDtos = linesDao.selectAll(CommonStatus.EFFECTIVE.value()); for (LineAndDyNameDto lineitem : lineAndDyNameDtos) { @@ -83,6 +85,11 @@ public class XyCache { alarmParamMap.put(item.getLabel(), item); } + List globalParamslist = globalParamsDao.selectAll(); + for (GlobalParams item : globalParamslist) { + globalParams.put(item.getParamName(), item.getParamValue()); + } + } @PreDestroy diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/GloablParamsServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/GloablParamsServiceImpl.java new file mode 100644 index 0000000..352b392 --- /dev/null +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/GloablParamsServiceImpl.java @@ -0,0 +1,59 @@ +package com.shxy.xymanager_service.impl; + +import com.shxy.xymanager_common.bean.ServiceBody; +import com.shxy.xymanager_common.entity.GlobalParams; +import com.shxy.xymanager_common.enums.GloableParamsType; +import com.shxy.xymanager_common.exception.Asserts; +import com.shxy.xymanager_dao.dao.GlobalParamsDao; +import com.shxy.xymanager_service.cache.XyCache; +import com.shxy.xymanager_service.service.GloablParamsService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.Date; +import java.util.Map; + + +/** + * 装置通道实现层 + */ +@Service +@Slf4j +public class GloablParamsServiceImpl implements GloablParamsService { + + @Autowired + GlobalParamsDao globalParamsDao; + + /** + * 获取绘制状态 + * + * @return + */ + @Override + public ServiceBody getMarkEnableStatus() { + Map globalParams = XyCache.globalParams; + String s = globalParams.get(GloableParamsType.ImgMark.value()); + Integer integer = Integer.valueOf(s); + return Asserts.success(integer); + } + + /** + * 修改绘制状态 + * + * @return + */ + @Override + public ServiceBody updateMarkEnableStatus(Integer status) { + GlobalParams record = new GlobalParams(); + record.setParamName(GloableParamsType.ImgMark.value()); + record.setParamValue(String.valueOf(status)); + int i = globalParamsDao.updateByParamName(record, new Date()); + if (i != 0) { + XyCache.globalParams.put(GloableParamsType.ImgMark.value(), String.valueOf(status)); + return Asserts.success("修改成功"); + } else { + return Asserts.error("修改失败"); + } + } +} diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/LineServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/LineServiceImpl.java index cee3eb9..04c4337 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/LineServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/LineServiceImpl.java @@ -10,7 +10,7 @@ import com.shxy.xymanager_common.dto.TermChannelAndMapperDto; import com.shxy.xymanager_common.entity.DyLevel; import com.shxy.xymanager_common.entity.Lines; import com.shxy.xymanager_common.entity.Terminals; -import com.shxy.xymanager_common.entity.Tower; +import com.shxy.xymanager_common.entity.Towers; import com.shxy.xymanager_common.enums.CommonStatus; import com.shxy.xymanager_common.exception.Asserts; import com.shxy.xymanager_common.model.LineAndGtAndChannelListModel; @@ -165,7 +165,7 @@ public class LineServiceImpl implements LineService { } } else if (type == 3) { if (id != null) { - List list = towerDao.selectAllByLineid(id, CommonStatus.EFFECTIVE.value()); + List list = towerDao.selectAllByLineid(id, CommonStatus.EFFECTIVE.value()); beans = BeanUtil.copyToList(list, LineAndGtAndChannelListModel.Bean.class); } } else if (type == 4) { @@ -211,7 +211,7 @@ public class LineServiceImpl implements LineService { beans = BeanUtil.copyToList(list, LineAndGtAndChannelListModel.Bean.class); } else { if (id != null) { - List list = towerDao.selectAllByLineid(id, CommonStatus.EFFECTIVE.value()); + List list = towerDao.selectAllByLineid(id, CommonStatus.EFFECTIVE.value()); beans = BeanUtil.copyToList(list, LineAndGtAndChannelListModel.Bean.class); } } 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 19108b6..64d20b2 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 @@ -73,7 +73,7 @@ public class TerminalAlarmServiceImpl implements TerminalAlarmService { Integer label = vo.getLabel(); List labellist = new ArrayList<>(); Map alarmParamMap = XyCache.alarmParamMap; - if (label != null && label == -1) { + if (label == null || label == -1) { alarmParamMap.forEach((key, value) -> { labellist.add(value); }); @@ -124,14 +124,14 @@ public class TerminalAlarmServiceImpl implements TerminalAlarmService { Map termchannelMapMap = XyCache.termchannelMapMap; - ArrayList originidlist = new ArrayList<>(); - for (TerminalImgAlarmsDto item : list) { - originidlist.add(item.getPhotoOrgId()); - } - List alarmphotolist = terminalPhotoDao.selectPhotoListByOrginIdList(originidlist); - Map map = new HashMap<>(); +// ArrayList originidlist = new ArrayList<>(); +// for (TerminalImgAlarmsDto item : list) { +// originidlist.add(item.getPhotoOrgId()); +// } + List alarmphotolist = terminalPhotoDao.selectPhotoListByOrginIdAndTermList(list); + Map map = new HashMap<>(); for (TerminalPhoto item : alarmphotolist) { - map.put(item.getOrginalId(), item); + map.put(item.getTermId() + "#" + item.getOrginalId(), item); } // List alarmBeans = BeanUtil.copyToList(list, TerminalAlarmListModel.AlarmBean.class, CopyOptions.create().ignoreCase()); @@ -169,7 +169,7 @@ public class TerminalAlarmServiceImpl implements TerminalAlarmService { alarmBean.setPresetId(item.getPresetId()); alarmBean.setPhotoOrgId(item.getPhotoOrgId()); if (map != null) { - TerminalPhoto terminalPhoto = map.get(item.getPhotoOrgId()); + TerminalPhoto terminalPhoto = map.get(item.getTermId() + "#" + item.getPhotoOrgId()); if (terminalPhoto != null) { String path = terminalPhoto.getPath(); Integer mediaType = terminalPhoto.getMediaType(); 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 2c7a08d..3543bcf 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 @@ -12,9 +12,11 @@ import com.shxy.xymanager_common.dto.DyLineAndTerminalNoHeartDto; import com.shxy.xymanager_common.dto.PhotoMarkDto; import com.shxy.xymanager_common.dto.TerminalInfoDto; import com.shxy.xymanager_common.dto.TerminalsAndLineAndChannelDto; +import com.shxy.xymanager_common.entity.GlobalParams; import com.shxy.xymanager_common.entity.TerminalChannelMapper; import com.shxy.xymanager_common.entity.Terminals; import com.shxy.xymanager_common.enums.CommonStatus; +import com.shxy.xymanager_common.enums.GloableParamsType; import com.shxy.xymanager_common.exception.Asserts; import com.shxy.xymanager_common.model.*; import com.shxy.xymanager_common.page.PageUtils; @@ -23,6 +25,7 @@ import com.shxy.xymanager_common.util.ProcessExecUtils; import com.shxy.xymanager_common.util.StringUtils; import com.shxy.xymanager_common.vo.*; import com.shxy.xymanager_dao.dao.*; +import com.shxy.xymanager_service.cache.XyCache; import com.shxy.xymanager_service.service.TerminalService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; @@ -37,6 +40,7 @@ import java.math.BigInteger; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Map; /** @@ -366,7 +370,11 @@ public class TerminalServiceImpl implements TerminalService { @Override public ServiceBody getCoordinate(MarkReqVo vo) { + Map globalParams = XyCache.globalParams; + String s = globalParams.get(GloableParamsType.ImgMark.value()); + Integer integer = Integer.valueOf(s); PhotoMarkModel model = new PhotoMarkModel(); + model.setMarkEnable(integer); PhotoMarkDto dto = null; if (vo.getNeedPic() == 0) { dto = terminalPhotoDao.selectPhotoMark(vo); diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TowerServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TowerServiceImpl.java index 84eab15..42515f6 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TowerServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TowerServiceImpl.java @@ -6,15 +6,15 @@ import cn.hutool.core.collection.CollectionUtil; import com.github.pagehelper.PageInfo; import com.shxy.xymanager_common.bean.ServiceBody; import com.shxy.xymanager_common.dto.TowerDto; -import com.shxy.xymanager_common.entity.Tower; +import com.shxy.xymanager_common.entity.Towers; import com.shxy.xymanager_common.enums.CommonStatus; import com.shxy.xymanager_common.exception.Asserts; import com.shxy.xymanager_common.model.AllTowerListModel; -import com.shxy.xymanager_common.model.TerminalChannelListModel; import com.shxy.xymanager_common.model.TowerListModel; import com.shxy.xymanager_common.page.PageUtils; import com.shxy.xymanager_common.vo.*; import com.shxy.xymanager_dao.dao.TowerDao; +import com.shxy.xymanager_service.cache.XyCache; import com.shxy.xymanager_service.service.TowerService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -38,10 +38,10 @@ public class TowerServiceImpl implements TowerService { private TowerDao towerDao; @Override - public ServiceBody addTower(TowerVo vo) { - List towerLst = BeanUtil.copyToList(vo.getList(), Tower.class, CopyOptions.create().ignoreCase()); + public ServiceBody addTower(TowersVo vo) { + List towersLst = BeanUtil.copyToList(vo.getList(), Towers.class, CopyOptions.create().ignoreCase()); Date date = new Date(); - int i = towerDao.addTower(towerLst, date); + int i = towerDao.addTower(towersLst,CommonStatus.EFFECTIVE.value(), date); if (i != 0) { return Asserts.success("录入成功"); } else { @@ -80,7 +80,7 @@ public class TowerServiceImpl implements TowerService { @Override public ServiceBody deleteTower(TowerIdVo vo) { - List lines = BeanUtil.copyToList(vo.getList(), Tower.class); + List lines = BeanUtil.copyToList(vo.getList(), Towers.class); Date date = new Date(); int i = towerDao.deleteById(lines, CommonStatus.DELETE.value(), date); if (i != 0) { @@ -92,9 +92,9 @@ public class TowerServiceImpl implements TowerService { @Override public ServiceBody updateTower(UpdateTowerVo vo) { - Tower tower = new Tower(); - BeanUtil.copyProperties(vo, tower, true); - int i = towerDao.updateByPrimaryKeySelective(tower, new Date()); + Towers towers = new Towers(); + BeanUtil.copyProperties(vo, towers, true); + int i = towerDao.updateByPrimaryKeySelective(towers, new Date()); if (i != 0) { return Asserts.success("修改成功"); } else { diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/service/GloablParamsService.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/GloablParamsService.java new file mode 100644 index 0000000..70b899d --- /dev/null +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/GloablParamsService.java @@ -0,0 +1,28 @@ +package com.shxy.xymanager_service.service; + + +import com.shxy.xymanager_common.bean.ServiceBody; + +/** + * 全局参数设置 + * + * @author jingjing + */ +public interface GloablParamsService { + + /** + * 获取绘制状态 + * + * @return + */ + ServiceBody getMarkEnableStatus(); + + /** + * 修改绘制状态 + * + * @return + */ + ServiceBody updateMarkEnableStatus(Integer status); + + +} diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TowerService.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TowerService.java index b9e8250..763a69e 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TowerService.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/service/TowerService.java @@ -19,7 +19,7 @@ public interface TowerService { * * @return */ - ServiceBody addTower(TowerVo vo); + ServiceBody addTower(TowersVo vo); /** * 新增杆塔