liuguijing 2 years ago
commit 41f7ad5603

@ -7,6 +7,7 @@ import com.shxy.xymanager_common.bean.ServiceBody;
import com.shxy.xymanager_common.bean.ServiceStatus;
import com.shxy.xymanager_common.model.TerminalListModel;
import com.shxy.xymanager_common.model.TerminalModel;
import com.shxy.xymanager_common.model.TerminalUpdateModel;
import com.shxy.xymanager_common.vo.*;
import com.shxy.xymanager_service.service.TerminalService;
import io.swagger.annotations.Api;
@ -122,8 +123,8 @@ public class TerminalController extends BaseController {
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})
@RequestMapping("/updateTerminalId")
@Log(title = "图像装置ID设置", type = "修改")
public ResponseReult<String> updateTerminalId(@RequestBody @Validated TerminalIdUpdateVo vo) {
ServiceBody<String> serviceBody = terminalService.updateTerminalId(vo);
public ResponseReult<TerminalUpdateModel> updateTerminalId(@RequestBody @Validated TerminalIdUpdateVo vo) {
ServiceBody<TerminalUpdateModel> serviceBody = terminalService.updateTerminalId(vo);
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {
return ResponseReult.success(serviceBody.getData());
} else {
@ -135,8 +136,8 @@ public class TerminalController extends BaseController {
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})
@RequestMapping("/selectTerminalId")
@Log(title = "图像装置ID查询", type = "修改")
public ResponseReult<String> selectTerminalId(@RequestBody @Validated TerminalIdUpdateVo vo) {
ServiceBody<String> serviceBody = terminalService.updateTerminalId(vo);
public ResponseReult<TerminalUpdateModel> selectTerminalId(@RequestBody @Validated TerminalIdUpdateVo vo) {
ServiceBody<TerminalUpdateModel> serviceBody = terminalService.updateTerminalId(vo);
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {
return ResponseReult.success(serviceBody.getData());
} else {

@ -62,8 +62,21 @@ public class TerminalPhotoController extends BaseController {
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})
@RequestMapping("/getPhotoTime")
@Log(title = "拍照时间表", type = "查询")
public ResponseReult<Boolean> getPhotoTime(@RequestBody @Validated TerminalPhotoTimeVo vo) {
ServiceBody<Boolean> serviceBody = terminalPhotoService.getPhotoTime(vo);
public ResponseReult<String> getPhotoTime(@RequestBody @Validated TerminalPhotoTimeVo vo) {
ServiceBody<String> serviceBody = terminalPhotoService.getPhotoTime(vo);
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("/selectPhotoTimeGet")
@Log(title = "拍照时间表查询触发", type = "查询")
public ResponseReult<String> selectPhotoTimeGet(@RequestBody @Validated TerminalReqPhotoTimeVo vo) {
ServiceBody<String> serviceBody = terminalPhotoService.selectPhotoTimeGet(vo);
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {
return ResponseReult.success(serviceBody.getData());
} else {
@ -137,12 +150,12 @@ public class TerminalPhotoController extends BaseController {
}
}
@ApiOperation(value = "图像采集参数查询", notes = "图像采集参数查询", httpMethod = "POST")
@ApiOperation(value = "最新图片采集参数触发", notes = "最新图片采集参数触发", httpMethod = "POST")
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})
@RequestMapping("/getPhotoQueryParamList")
@Log(title = "图像采集参数查询", type = "查询")
public ResponseReult<TerminalPhotosParamsModel> getPhotoQueryParamList(@RequestParam("termId") Integer termId) {
ServiceBody<TerminalPhotosParamsModel> serviceBody = terminalPhotoService.getPhotoQueryParam(termId);
@Log(title = "最新图片采集参数触发", type = "查询")
public ResponseReult<String> getPhotoQueryParamList(@RequestParam("termId") Integer termId) {
ServiceBody<String> serviceBody = terminalPhotoService.getPhotoQueryParam(termId);
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {
return ResponseReult.success(serviceBody.getData());
} else {
@ -150,10 +163,10 @@ public class TerminalPhotoController extends BaseController {
}
}
@ApiOperation(value = "获取最新图片采集参数", notes = "获取最新图片采集参数", httpMethod = "POST")
@ApiOperation(value = "图像采集参数查询", notes = "图像采集参数查询", httpMethod = "POST")
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})
@RequestMapping("/getLastedPhotoQueryParam")
@Log(title = "获取最新图片采集参数", type = "查询")
@RequestMapping("/photoQueryParamGet")
@Log(title = "图像采集参数查询", type = "查询")
public ResponseReult<TerminalPhotosParamsModel> getLastedPhotoQueryParam(@RequestBody @Validated ReturnedPhotoParamsVo vo) {
ServiceBody<TerminalPhotosParamsModel> serviceBody = terminalPhotoService.getLastedPhotoQueryParam(vo);
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {

@ -0,0 +1,19 @@
package com.shxy.xymanager_common.model;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
/**
*
*/
@Data
@ApiModel(value = "图片采集参数更新对象", description = "图片采集参数对象信息")
public class PhotoParamUpdateModel implements Serializable {
@ApiModelProperty(value = "装置编号", example = "120")
private Integer termId;
@ApiModelProperty(value = "请求ID", example = "120")
private Integer requestId;
}

@ -41,7 +41,5 @@ public class TerminalPhotosParamsModel implements Serializable {
@ApiModelProperty(value = "心跳上送周期", example = "123456")
private String cmdId;
@ApiModelProperty(value = "查询时间", example = "123456")
private DateTime queryTime;
}

@ -25,7 +25,7 @@ public class TerminalPhotosTimeModel implements Serializable {
private Integer termId;
@ApiModelProperty(value = "自定义图像分辨率", example = "123456")
@ApiModelProperty(value = "请求ID", example = "123456")
private Integer requestId;
}

@ -0,0 +1,22 @@
package com.shxy.xymanager_common.model;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.math.BigInteger;
import java.util.Date;
import java.util.List;
/**
*
*/
@Data
@ApiModel(value = "装置ID更新对象", description = "图片轮询列表对象信息")
public class TerminalUpdateModel implements Serializable {
@ApiModelProperty(value = "装置编号", example = "120")
private Integer termId;
@ApiModelProperty(value = "请求ID", example = "120")
private Integer requestId;
}

@ -16,5 +16,5 @@ public class ReturnedPhotoParamsVo {
@ApiModelProperty(value = "手动拍照时间", required = true, example = "A0001")
private DateTime photoTime;
private Integer requestId;
}

@ -7,6 +7,9 @@ import lombok.Data;
@Data
@ApiModel(value = "装置信息对象", description = "设备信息对象描述")
public class TerminalIdUpdateVo {
@ApiModelProperty(value = "装置编号", example = "123456")
private Integer termId;
@ApiModelProperty(value = "装置ID", example = "123456")
private String cmdId;

@ -18,9 +18,13 @@ public class TerminalReqPhotoTimeVo {
@ApiModelProperty(value = "装置ID", example = "123455")
private Short termId;
@NotNull(message = "检测装置ID不能缺少")
@ApiModelProperty(value = "检测装置ID", example = "123455")
private Short cmdId;
@ApiModelProperty(value = "请求ID", example = "123455")
private String requestId;
private Integer requestId;
}

@ -47,7 +47,7 @@ public interface TerminalPhotoDao {
BigInteger getLatestPhotoParam(Integer termId);
String getRequestResult(@Param("requestId") String requestId);
String getRequestResult(@Param("requestId") Integer requestId);
}

@ -286,7 +286,7 @@
select
result
from request_results
where request_id = #{requestId,jdbcType=VARCHAR}
where request_id = #{requestId,jdbcType=TINYINT}
</select>
<!--<select id="selectCmdIdById" resultType="java.lang.Integer">

@ -12,6 +12,7 @@ import com.github.pagehelper.Constant;
import com.github.pagehelper.PageInfo;
import com.google.common.collect.Lists;
import com.shxy.xymanager_common.bean.ServiceBody;
import com.shxy.xymanager_common.constant.Constants;
import com.shxy.xymanager_common.dto.PhotoAndLineAndChannelDto;
import com.shxy.xymanager_common.dto.PhotoParamsDto;
import com.shxy.xymanager_common.dto.PhotoTimeResultDto;
@ -358,87 +359,78 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService {
}
@Override
public ServiceBody<Boolean> getPhotoTime(TerminalPhotoTimeVo vo) {
TerminalPhotosTimeModel model = new TerminalPhotosTimeModel();
public ServiceBody<String> getPhotoTime(TerminalPhotoTimeVo vo) {
List<TerminalPhotoScheduleDto> dtoList = terminalPhotoDao.selectPhotoSchedule(vo);
List<TerminalPhotosTimeModel.PhotosTimeBean> beanList = Lists.newArrayList();
for(int j = 0; j<dtoList.size();j++){
TerminalPhotosTimeModel.PhotosTimeBean bean = new TerminalPhotosTimeModel.PhotosTimeBean();
Short span = dtoList.get(j).getSpan();
Date startTime = dtoList.get(j).getStartTime();
Short startHour = Short.parseShort(MyDateUtils.parseHourAndMinute(startTime).split("/")[0]);
Short startMin = Short.parseShort(MyDateUtils.parseHourAndMinute(startTime).split("/")[1]);
Date endTime = dtoList.get(j).getEndTime();
Short endTimeHour = Short.parseShort(MyDateUtils.parseHourAndMinute(endTime).split("/")[0]);
Short endTimeMin = Short.parseShort(MyDateUtils.parseHourAndMinute(endTime).split("/")[1]);
Short span1 =-1;
Short span2 =-1;
if(span/60 > 0) {
span1 =(short)(span/60);
span2 =(short)(span % 60);
}else if(span<60 ){
span1 = (short)0;
span2 = span;
}
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=schedule --cmdid="+dtoList.get(j).getCmid() +"\t" +"--channel="+ vo.getChannel() +"\t"
+ "--group=3 --hour1=" + startHour +"\t"+ "--min1=" + startMin +"\t"+ "--preset1=255 --hour2=" + endTimeHour +"\t"+ "--min2=" + endTimeMin +"\t"
+"--preset2=255 --hour3=" + span1 +"\t" + "--min3=" + span2 +"\t"+"--preset3=255";
ProcessExecUtils.exec(cmd);
};
return Asserts.success(true);
for(int j = 0; j<dtoList.size();j++){
TerminalPhotosTimeModel.PhotosTimeBean bean = new TerminalPhotosTimeModel.PhotosTimeBean();
Short span = dtoList.get(j).getSpan();
Date startTime = dtoList.get(j).getStartTime();
Short startHour = Short.parseShort(MyDateUtils.parseHourAndMinute(startTime).split("/")[0]);
Short startMin = Short.parseShort(MyDateUtils.parseHourAndMinute(startTime).split("/")[1]);
Date endTime = dtoList.get(j).getEndTime();
Short endTimeHour = Short.parseShort(MyDateUtils.parseHourAndMinute(endTime).split("/")[0]);
Short endTimeMin = Short.parseShort(MyDateUtils.parseHourAndMinute(endTime).split("/")[1]);
Short span1 =-1;
Short span2 =-1;
if(span/60 > 0) {
span1 =(short)(span/60);
span2 =(short)(span % 60);
}else if(span<60 ){
span1 = (short)0;
span2 = span;
}
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=schedule --cmdid="+ dtoList.get(j).getCmid() +"\t"+"--channel="+ vo.getChannel() +"\t"
+ "--group=3 --hour1=" + startHour +"\t"+ "--min1=" + startMin +"\t"+ "--preset1=255 --hour2=" + endTimeHour +"\t"+ "--min2=" + endTimeMin +"\t"
+"--preset2=255 --hour3=" + span1 +"\t" + "--min3=" + span2 +"\t"+"--preset3=255";
ProcessExecUtils.exec(cmd);
};
return Asserts.success("修改成功");
}
@Override
public ServiceBody<TerminalPhotosParamsModel> getPhotoQueryParam(Integer termId) {
public ServiceBody<String> getPhotoQueryParam(Integer termId) {
String cmdId = terminalPhotoDao.selectCmdIdById(termId);
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=imgparams --cmdid="+cmdId +"\t" +"--flag=1 --rf=7";
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=imgparams --cmdid="+cmdId +"\t" +"--clientid=10 --reqid="+Constants.REQUEST_ID+"--flag=1 --rf=7";
ProcessExecUtils.exec(cmd);
TerminalPhotosParamsModel model = new TerminalPhotosParamsModel();
/* TerminalPhotosParamsModel model = new TerminalPhotosParamsModel();
PhotoParamsDto dto= terminalPhotoDao.selectPhotoParams(termId);
if(dto!=null) {
BeanUtils.copyProperties(dto, model);
DateTime now = DateTime.now();
model.setQueryTime(now);
}
return Asserts.success(model);
}*/
return Asserts.success("查询成功");
}
@Override
public ServiceBody<String> addOrUpdatePhotoParams(PhotoParamsVo vo) {
Integer result = terminalPhotoDao.updateOrInsertParams(vo);
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=imgparams --cmdid="+vo.getCmdId() +"\t" +"--color=" +vo.getColor() +"\t" + "--resolution="+ vo.getResolution() +"\t"
+ "--luminance=" + vo.getLuminance() +"\t"+ "-contrast=" + vo.getContrast() +"\t"+ "--saturation=" + vo.getSaturation();
ProcessExecUtils.exec(cmd);
if(result>0){
return Asserts.success("操作成功");
if (result>0) {
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=imgparams --cmdid=" + vo.getCmdId() + "\t" + "--color=" + vo.getColor() + "\t" + "--resolution=" + vo.getResolution() + "\t"
+ "--luminance=" + vo.getLuminance() + "\t" + "-contrast=" + vo.getContrast() + "\t" + "--saturation=" + vo.getSaturation();
ProcessExecUtils.exec(cmd);
return Asserts.success("更新成功");
}
return Asserts.error("操作失败");
return Asserts.error("更新失败");
}
@Override
public ServiceBody<TerminalPhotosParamsModel> getLastedPhotoQueryParam(ReturnedPhotoParamsVo vo) {
Boolean hasNew;
BigInteger photoTime = terminalPhotoDao.getLatestPhotoParam(vo.getTermId());
BigInteger localPhotoTime = MyDateUtils.TimeMillSecond2Second(vo.getPhotoTime());
hasNew = photoTime.compareTo(localPhotoTime)<0?false:true;
if(hasNew){
String result = terminalPhotoDao.getRequestResult(vo.getRequestId());
TerminalPhotosParamsModel model = new TerminalPhotosParamsModel();
if(StringUtils.isNotBlank(result)) {
JSONObject resultObj = JSONObject.parseObject(result);
model = JSONObject.parseObject(resultObj.get("groupData").toString(), TerminalPhotosParamsModel.class);
}else{
PhotoParamsDto dto= terminalPhotoDao.selectPhotoParams(vo.getTermId());
if(null!=dto){
TerminalPhotosParamsModel model = new TerminalPhotosParamsModel();
BeanUtils.copyProperties(dto,model);
return Asserts.success(model);
if(dto!=null) {
BeanUtils.copyProperties(dto, model);
}
}
return Asserts.success(null);
return Asserts.success(model);
}
@Override
@ -469,5 +461,12 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService {
return Asserts.success(model);
}
@Override
public ServiceBody<String> selectPhotoTimeGet(TerminalReqPhotoTimeVo vo) {
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --port=6891 --act=imgparams --cmdid="+vo.getCmdId()+ "\t" + "--reqid="+vo.getRequestId()+ "\t"+ "--clientid=10--flag=1 --rf=7";
ProcessExecUtils.exec(cmd);
return Asserts.success("操作成功");
}
}

@ -6,6 +6,7 @@ import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateTime;
import com.github.pagehelper.PageInfo;
import com.shxy.xymanager_common.bean.ServiceBody;
import com.shxy.xymanager_common.constant.Constants;
import com.shxy.xymanager_common.dto.TerminalInfoDto;
import com.shxy.xymanager_common.dto.TerminalsAndLineAndChannelDto;
import com.shxy.xymanager_common.entity.TerminalChannelMapper;
@ -14,6 +15,7 @@ import com.shxy.xymanager_common.enums.CommonStatus;
import com.shxy.xymanager_common.exception.Asserts;
import com.shxy.xymanager_common.model.TerminalListModel;
import com.shxy.xymanager_common.model.TerminalModel;
import com.shxy.xymanager_common.model.TerminalUpdateModel;
import com.shxy.xymanager_common.page.PageUtils;
import com.shxy.xymanager_common.util.MyDateUtils;
import com.shxy.xymanager_common.util.ProcessExecUtils;
@ -231,13 +233,17 @@ public class TerminalServiceImpl implements TerminalService {
}
@Override
public ServiceBody<String> updateTerminalId(TerminalIdUpdateVo vo) {
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --act=termid --cmdid="+vo.getCmdId()+"\t"+"--newcmdid="+vo.getNewCmdId();
public ServiceBody<TerminalUpdateModel> updateTerminalId(TerminalIdUpdateVo vo) {
TerminalUpdateModel model = new TerminalUpdateModel();
String cmd = "/usr/local/bin/xympadmn --server=127.0.0.1 --act=termid --cmdid="+vo.getCmdId()+"\t"+"--reqid="+ Constants.REQUEST_ID +"\t"+"--newcmdid="+vo.getNewCmdId()+"\t"+"--newcmdid="+vo.getNewCmdId();
Integer retCode = ProcessExecUtils.exec(cmd);
model.setRequestId(Integer.parseInt(Constants.REQUEST_ID.toString()));
model.setTermId(vo.getTermId());
Constants.REQUEST_ID.addAndGet(1);
if(retCode==0){
int result = terminalsDao.updateCmd(vo);
if(result>0) {
return Asserts.success("装置ID修改成功");
return Asserts.success(model);
}
}
return Asserts.error("装置ID修改失败");

@ -61,14 +61,14 @@ public interface TerminalPhotoService {
*
* @return
*/
ServiceBody<Boolean> getPhotoTime(TerminalPhotoTimeVo vo);
ServiceBody<String> getPhotoTime(TerminalPhotoTimeVo vo);
/**
*
*
* @return
*/
ServiceBody<TerminalPhotosParamsModel> getPhotoQueryParam(Integer termId);
ServiceBody<String> getPhotoQueryParam(Integer termId);
ServiceBody<String> addOrUpdatePhotoParams(PhotoParamsVo vo);
@ -77,6 +77,8 @@ public interface TerminalPhotoService {
ServiceBody<TerminalScheduleRuleTimeListModel> selectPhotoTime(TerminalReqPhotoTimeVo vo);
ServiceBody<String> selectPhotoTimeGet(TerminalReqPhotoTimeVo vo);
}

@ -3,6 +3,7 @@ package com.shxy.xymanager_service.service;
import com.shxy.xymanager_common.bean.ServiceBody;
import com.shxy.xymanager_common.model.TerminalListModel;
import com.shxy.xymanager_common.model.TerminalModel;
import com.shxy.xymanager_common.model.TerminalUpdateModel;
import com.shxy.xymanager_common.vo.*;
/**
@ -60,6 +61,6 @@ public interface TerminalService {
* @param vo
* @return
*/
ServiceBody<String> updateTerminalId(TerminalIdUpdateVo vo);
ServiceBody<TerminalUpdateModel> updateTerminalId(TerminalIdUpdateVo vo);
}

Loading…
Cancel
Save