package cn.besteam.modules.medical.biz;
|
|
import cn.besteam.common.constant.ErrorCode;
|
import cn.besteam.common.exception.BusinessException;
|
import cn.besteam.common.util.RedisUtil;
|
import cn.besteam.modules.medical.entity.MwMonitorDevice;
|
import cn.besteam.modules.system.entity.SysDict;
|
import cn.besteam.modules.system.entity.SysDictItem;
|
import cn.besteam.modules.system.service.ISysDictItemService;
|
import cn.besteam.modules.system.service.ISysDictService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.List;
|
|
@Service
|
@Slf4j
|
public class MonitorDeviceApiService {
|
|
//登录
|
private static final String LOGIN_URL = "https://video-1.scjakj.com/StandardApiAction_login.action?account=%s&password=%s";
|
|
//添加设备
|
private static final String ADD_DEVICE_URL = "https://video-1.scjakj.com/StandardApiAction_addDevice.action?jsession=%s&devIdno=%s&devType=7&factoryType=0&companyName=%s&account=%s&channelNum=%s";
|
|
//绑定设备
|
private static final String BIND_DEVICE_URL = "https://video-1.scjakj.com/StandardApiAction_addVehicle.action?jsession=%s&vehiIdno=%s&devIdno=%s&devType=7&factoryType=0&companyName=%s&account=%s";
|
|
//删除设备
|
private static final String DELETE_DEVICE_URL = "https://video-1.scjakj.com/StandardApiAction_deleteVehicle.action?jsession=%s&vehiIdno=%s&delDevice=1";
|
|
//查询设备状态
|
private static final String SELState_DEVICE_URL = "https://video-1.scjakj.com/StandardApiAction_getDeviceOlStatus.action?jsession=%s&devIdno=%s";
|
|
//默认用户名、公司名
|
private static final String DEFAULT_ACCOUNT = "scjakj", DEFAULT_COMPANY = "scjakj", DEFAULT_PASSWORD = "123456";
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
private ISysDictService sysDictService;
|
|
@Autowired
|
private ISysDictItemService sysDictItemService;
|
|
/**
|
* 登录
|
*
|
* @return
|
*/
|
public String getJSession() {
|
|
MonitorConfig monitorConfig = getMonitorConfig();
|
String key = "monitor:device:jsession";
|
String jsession = redisUtil.get(key);
|
if (jsession == null) {
|
RestTemplate restTemplate = new RestTemplate();
|
String completeUrl = String.format(LOGIN_URL, monitorConfig.getAccount(), monitorConfig.getPassword());
|
log.info("视频服务器:登录接口传参数据:{}", completeUrl);
|
ApiResult result = restTemplate.getForObject(completeUrl, ApiResult.class);
|
log.info("视频服务器:登录接口返回数据:{}", result);
|
if (result == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
if (result.getResult().equals(0)) {
|
jsession = result.getJsession();
|
} else {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
}
|
redisUtil.set(key, jsession, 300);
|
return jsession;
|
}
|
|
/**
|
* 绑定设备
|
*
|
* @param mwMonitorDevice
|
* @return
|
*/
|
public boolean bindDevice(MwMonitorDevice mwMonitorDevice) {
|
|
MonitorConfig monitorConfig = getMonitorConfig();
|
RestTemplate restTemplate = new RestTemplate();
|
String completeUrl = String.format(BIND_DEVICE_URL, getJSession(), mwMonitorDevice.getDevIdno(), mwMonitorDevice.getDevIdno(), monitorConfig.getCompany(), monitorConfig.getAccount());
|
log.info("视频服务器:绑定设备接口传参数据:{}", completeUrl);
|
ApiResult result = restTemplate.getForObject(completeUrl, ApiResult.class);
|
log.info("视频服务器:绑定设备接口返回数据:{}", result);
|
if (result == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
// if (result.getResult().equals(20)) {
|
// throw new BusinessException(ErrorCode.ERR_500, "Current device does not match the company");
|
// } else if (result.getResult().equals(0) || result.getResult().equals(16)) {
|
// return true;
|
// } else {
|
// return false;
|
// }
|
if (result.getResult().equals(0)) {
|
return true;
|
} else {
|
if (StringUtils.isNotEmpty(result.getMessage()) && result.getMessage().contains("already exists")) {
|
throw new BusinessException(ErrorCode.ERR_500, "监控设备已存在");
|
}
|
throw new BusinessException(ErrorCode.ERR_500, result.getMessage());
|
}
|
}
|
|
/**
|
* 添加设备
|
*
|
* @param mwMonitorDevice
|
* @return
|
*/
|
public boolean addDevice(MwMonitorDevice mwMonitorDevice) {
|
|
MonitorConfig monitorConfig = getMonitorConfig();
|
RestTemplate restTemplate = new RestTemplate();
|
String completeUrl = String.format(ADD_DEVICE_URL, getJSession(), mwMonitorDevice.getDevIdno(), monitorConfig.getCompany(), monitorConfig.getAccount(), mwMonitorDevice.getChannelNum());
|
log.info("视频服务器:添加设备接口传参数据:{}", completeUrl);
|
ApiResult result = restTemplate.getForObject(completeUrl, ApiResult.class);
|
log.info("视频服务器:添加设备接口返回数据:{}", result);
|
if (result == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
if (result.getResult().equals(0)) {
|
return true;
|
} else {
|
if (StringUtils.isNotEmpty(result.getMessage()) && result.getMessage().contains("already exists")) {
|
throw new BusinessException(ErrorCode.ERR_500, "监控设备已存在");
|
}
|
throw new BusinessException(ErrorCode.ERR_500, result.getMessage());
|
}
|
}
|
|
/**
|
* 删除设备
|
*
|
* @param devIdno
|
* @return
|
*/
|
public boolean deleteDevice(String devIdno) {
|
|
RestTemplate restTemplate = new RestTemplate();
|
String completeUrl = String.format(DELETE_DEVICE_URL, getJSession(), devIdno);
|
log.info("视频服务器:删除设备接口传参数据:{}", completeUrl);
|
ApiResult result = restTemplate.getForObject(completeUrl, ApiResult.class);
|
log.info("视频服务器:删除设备接口返回数据:{}", result);
|
if (result == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
if (result.getResult().equals(0)) {
|
return true;
|
} else {
|
throw new BusinessException(ErrorCode.ERR_500, result.getMessage());
|
}
|
}
|
|
/**
|
* 获取设备状态:
|
* 在线状态
|
* 1表示在线，否则不在线。
|
*
|
* @param devIdno
|
* @return
|
*/
|
public Integer getDeviceState(String devIdno) {
|
Integer state=0;
|
RestTemplate restTemplate = new RestTemplate();
|
String completeUrl = String.format(SELState_DEVICE_URL, getJSession(), devIdno);
|
log.info("视频服务器:获取设备状态接口传参数据:{}", completeUrl);
|
ApiStateResult result = restTemplate.getForObject(completeUrl, ApiStateResult.class);
|
log.info("视频服务器:获取设备状态接口返回数据:{}", result);
|
if (result == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "视频服务器连接失败");
|
}
|
if (result.getResult().equals(0)) {
|
state=0;
|
if(result.getOnlines()!=null && result.getOnlines().size()>0){
|
state=result.getOnlines().get(0).getOnline();
|
}
|
}
|
return state;
|
}
|
|
@Data
|
private static class ApiResult {
|
|
private String message;
|
|
private Integer result;
|
|
private String jsession;
|
|
}
|
|
@Data
|
private static class ApiStateResult {
|
|
private Integer result;
|
|
private List<ApiOnline> onlines;
|
|
}
|
|
@Data
|
private static class ApiOnline{
|
private String did;
|
private String vid;
|
private Integer online;
|
}
|
|
@Data
|
private static class MonitorConfig {
|
|
private String account;
|
|
private String company;
|
|
private String password;
|
|
}
|
|
public MonitorConfig getMonitorConfig() {
|
|
SysDict sysDict = sysDictService.getOne(new QueryWrapper<SysDict>().lambda().eq(SysDict::getDictCode, "MONITOR_DEVICE_CONFIG"));
|
if (sysDict == null) {
|
throw new BusinessException(ErrorCode.ERR_500, "请联系管理员进行参数初始化");
|
}
|
List<SysDictItem> sysDictItemList = sysDictItemService.list(new QueryWrapper<SysDictItem>().lambda().eq(SysDictItem::getDictId, sysDict.getId()));
|
if (CollectionUtils.isEmpty(sysDictItemList)) {
|
throw new BusinessException(ErrorCode.ERR_500, "请联系管理员进行参数初始化");
|
}
|
MonitorConfig config = new MonitorConfig();
|
for (SysDictItem sysDictItem : sysDictItemList) {
|
if (sysDictItem.getItemText().equals("account")) {
|
config.setAccount(sysDictItem.getItemValue());
|
}
|
if (sysDictItem.getItemText().equals("company")) {
|
config.setCompany(sysDictItem.getItemValue());
|
}
|
if (sysDictItem.getItemText().equals("password")) {
|
config.setPassword(sysDictItem.getItemValue());
|
}
|
}
|
return config;
|
}
|
|
}
|
