diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalAlarmController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalAlarmController.java index 1fe10f7..74896c1 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalAlarmController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalAlarmController.java @@ -6,6 +6,7 @@ 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.model.*; +import com.shxy.xymanager_common.util.HeaderUtil; import com.shxy.xymanager_common.vo.*; import com.shxy.xymanager_service.service.TerminalAlarmService; import io.swagger.annotations.Api; @@ -14,8 +15,10 @@ 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.http.HttpHeaders; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestHeader; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -32,8 +35,9 @@ public class TerminalAlarmController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getTerminalAlarmList") @Log(title = "获取告警列表", type = "查询") - public ResponseReult getTerminalAlarmList(@RequestBody @Validated TerminalAlarmSelectVo vo) { - ServiceBody serviceBody = terminalAlarmService.getTerminalAlarmList(vo); + public ResponseReult getTerminalAlarmList(@RequestHeader HttpHeaders headers, @RequestBody @Validated TerminalAlarmSelectVo vo) { + String requestIp = HeaderUtil.getRequestIp(headers); + ServiceBody serviceBody = terminalAlarmService.getTerminalAlarmList(requestIp,vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalController.java index b91421a..3ab8f65 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalController.java @@ -6,6 +6,7 @@ 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.model.*; +import com.shxy.xymanager_common.util.HeaderUtil; import com.shxy.xymanager_common.vo.*; import com.shxy.xymanager_service.service.TerminalService; import io.swagger.annotations.Api; @@ -14,6 +15,7 @@ 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.http.HttpHeaders; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; @@ -43,8 +45,9 @@ public class TerminalController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getCoordinate") @Log(title = "获取绘制图标", type = "查询") - public ResponseReult getCoordinate(@RequestBody @Validated MarkReqVo vo) { - ServiceBody serviceBody = terminalService.getCoordinate(vo); + public ResponseReult getCoordinate(@RequestHeader HttpHeaders headers, @RequestBody @Validated MarkReqVo vo) { + String requestIp = HeaderUtil.getRequestIp(headers); + ServiceBody serviceBody = terminalService.getCoordinate(requestIp,vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { 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 2068994..ccb8e6c 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 @@ -39,7 +39,7 @@ public class TerminalPhotoController extends BaseController { @Log(title = "获取图片列表", type = "查询") public ResponseReult getTerminalPhotoList(@RequestHeader HttpHeaders headers, @RequestBody @Validated TerminalAndChannelIdAndTimeVo vo) { String requestIp = HeaderUtil.getRequestIp(headers); - ServiceBody serviceBody = terminalPhotoService.getTerminalPhotoList(requestIp,vo); + ServiceBody serviceBody = terminalPhotoService.getTerminalPhotoList(requestIp, vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { @@ -90,9 +90,9 @@ public class TerminalPhotoController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getPhotoList") @Log(title = "图片查询", type = "查询") - public ResponseReult getPhotoList(@RequestHeader HttpHeaders headers,@RequestBody @Validated TerminalPhotoSelectVo vo) { + public ResponseReult getPhotoList(@RequestHeader HttpHeaders headers, @RequestBody @Validated TerminalPhotoSelectVo vo) { String requestIp = HeaderUtil.getRequestIp(headers); - ServiceBody serviceBody = terminalPhotoService.getPhotoList(requestIp,vo); + ServiceBody serviceBody = terminalPhotoService.getPhotoList(requestIp, vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { @@ -117,9 +117,9 @@ public class TerminalPhotoController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getPhotoBanner") @Log(title = "图片轮询", type = "查询") - public ResponseReult getPhotoBanner(@RequestHeader HttpHeaders headers,@RequestBody @Validated PageVo vo) { + public ResponseReult getPhotoBanner(@RequestHeader HttpHeaders headers, @RequestBody @Validated PageVo vo) { String requestIp = HeaderUtil.getRequestIp(headers); - ServiceBody serviceBody = terminalPhotoService.getPhotoBanner(requestIp,vo); + ServiceBody serviceBody = terminalPhotoService.getPhotoBanner(requestIp, vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { @@ -171,9 +171,9 @@ public class TerminalPhotoController extends BaseController { @ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")}) @RequestMapping("/getHistoryList") @Log(title = "历史图片", type = "查询") - public ResponseReult getHistoryList(@RequestHeader HttpHeaders headers,@RequestBody @Validated TermIdAndChannelIdVo vo) { + public ResponseReult getHistoryList(@RequestHeader HttpHeaders headers, @RequestBody @Validated TermIdAndChannelIdVo vo) { String requestIp = HeaderUtil.getRequestIp(headers); - ServiceBody serviceBody = terminalPhotoService.getHistoryList(requestIp,vo); + ServiceBody serviceBody = terminalPhotoService.getHistoryList(requestIp, vo); if (serviceBody.getCode() == ServiceStatus.SUCCESS) { return ResponseReult.success(serviceBody.getData()); } else { diff --git a/xymanager_admin/src/main/resources/application-test.yml b/xymanager_admin/src/main/resources/application-test.yml index 380afa7..f4c0f13 100644 --- a/xymanager_admin/src/main/resources/application-test.yml +++ b/xymanager_admin/src/main/resources/application-test.yml @@ -181,6 +181,8 @@ photo: address: /photos/ video: address: /videos/ +system: + address: http://23.56.100.12 session: expire_time: 3600 open_expire_time: 1800 diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalChannelMapper.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalChannelMapper.java index 8ffab7e..10f4ae5 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalChannelMapper.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/entity/TerminalChannelMapper.java @@ -3,6 +3,7 @@ package com.shxy.xymanager_common.entity; import lombok.Data; import java.io.Serializable; +import java.math.BigInteger; import java.util.Date; @Data @@ -15,6 +16,10 @@ public class TerminalChannelMapper implements Serializable { private String alias; + private BigInteger photoId; + + private BigInteger photoTime; + private Date createTime; private Date updateTime; diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/util/HeaderUtil.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/util/HeaderUtil.java index c9b73b0..ad00a6c 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/util/HeaderUtil.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/util/HeaderUtil.java @@ -1,15 +1,27 @@ package com.shxy.xymanager_common.util; +import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.StrUtil; +import cn.hutool.core.util.URLUtil; +import org.springframework.beans.factory.annotation.Value; import org.springframework.http.HttpHeaders; +import org.springframework.stereotype.Component; +import java.net.URL; import java.util.List; /** * 请求头工具类 */ +@Component public class HeaderUtil { + private static String address; + + @Value("${system.address}") + public void setHost(String address) { + HeaderUtil.address = address; + } /** * 获取请求地址 * @@ -20,7 +32,16 @@ public class HeaderUtil { String origin = httpHeaders.getOrigin(); if (StrUtil.isEmpty(origin)) { List list = httpHeaders.get("referer"); - requestip = list.get(0); + if (CollectionUtil.isEmpty(list) || StrUtil.isEmpty(list.get(0))) { + requestip = address; + } else { + String s = list.get(0); + URL url = URLUtil.url(s); + String protocol = url.getProtocol(); + String host = url.getHost(); + int port = url.getPort(); + requestip = protocol.concat("://").concat(host).concat(":").concat(String.valueOf(port)); + } } else { requestip = origin; } diff --git a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalChannelMapperDao.java b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalChannelMapperDao.java index feddc6b..1fa9d52 100644 --- a/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalChannelMapperDao.java +++ b/xymanager_dao/src/main/java/com/shxy/xymanager_dao/dao/TerminalChannelMapperDao.java @@ -1,9 +1,9 @@ package com.shxy.xymanager_dao.dao; -import com.shxy.xymanager_common.entity.Lines; import com.shxy.xymanager_common.entity.TerminalChannelMapper; import org.apache.ibatis.annotations.Param; +import java.math.BigInteger; import java.util.Date; import java.util.List; @@ -22,6 +22,8 @@ public interface TerminalChannelMapperDao { List selectAll(); + List selectAllByPhotoTime(@Param("time") BigInteger time); + int updateByPrimaryKeySelective(TerminalChannelMapper record); int updateByPrimaryKey(TerminalChannelMapper record); 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 e0b8c34..6d7644c 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 @@ -33,13 +33,15 @@ public interface TerminalPhotoDao { TerminalPhoto getLatestPhoto(@Param("termId") Integer termId); - List getLatestPhotoByTermidAndChannelid(@Param("termId") Integer termId,@Param("channelId") Integer channelId); + List getLatestPhotoByTermidAndChannelid(@Param("termId") Integer termId, @Param("channelId") Integer channelId); + + List selectPhotosByIdList(@Param("list") List list); List selectPhotos(); List selectTermAndChannelLatestPhotoList(@Param("list") List list); - List selectPhotoListForOpen(@Param("termId") Integer terminalid,@Param("starttime") BigInteger starttime, @Param("endtime") BigInteger endtime); + List selectPhotoListForOpen(@Param("termId") Integer terminalid, @Param("starttime") BigInteger starttime, @Param("endtime") BigInteger endtime); List selectPhotoSchedule(TerminalPhotoTimeVo vo); @@ -53,12 +55,12 @@ public interface TerminalPhotoDao { String getRequestResult(@Param("requestId") Integer requestId); - void deleteByMarkId(@Param("markId")Integer markId); + void deleteByMarkId(@Param("markId") Integer markId); Integer addPhotoMark(PhotoMarkVo vo); - Integer addPhotoMarkPath(@Param("list")List list, @Param("markId")Integer id); + Integer addPhotoMarkPath(@Param("list") List list, @Param("markId") Integer id); void updatePhotoMark(PhotoMarkVo vo); diff --git a/xymanager_dao/src/main/resources/mappers/TerminalChannelMapperDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalChannelMapperDao.xml index c54aea4..6483d49 100644 --- a/xymanager_dao/src/main/resources/mappers/TerminalChannelMapperDao.xml +++ b/xymanager_dao/src/main/resources/mappers/TerminalChannelMapperDao.xml @@ -6,11 +6,13 @@ + + - id, term_id, channel_id,alias, create_time, update_time + id, term_id, channel_id,alias, photo_id,photo_time,create_time, update_time + + - - - - - - +