diff --git a/bonus-modules/bonus-smart-site/pom.xml b/bonus-modules/bonus-smart-site/pom.xml index 8a347d6..9b98269 100644 --- a/bonus-modules/bonus-smart-site/pom.xml +++ b/bonus-modules/bonus-smart-site/pom.xml @@ -115,6 +115,32 @@ okhttp + + + org.codehaus.jackson + jackson-core-asl + 1.9.13 + + + + org.codehaus.jackson + jackson-mapper-asl + 1.9.13 + + + + dom4j + dom4j + 1.6.1 + compile + + + + commons-httpclient + commons-httpclient + 3.1 + + diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/controller/VideoEquipmentController.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/controller/VideoEquipmentController.java index ce0a393..e0207d5 100644 --- a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/controller/VideoEquipmentController.java +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/controller/VideoEquipmentController.java @@ -9,13 +9,12 @@ import com.bonus.common.core.web.page.TableDataInfo; import com.bonus.common.log.annotation.SysLog; import com.bonus.common.log.enums.OperaType; import com.bonus.common.redis.service.RedisService; +import com.bonus.smartsite.basic.domain.BallMachineControl; import com.bonus.smartsite.basic.domain.PlatformConfiguration; import com.bonus.smartsite.basic.domain.VideoEquipment; import com.bonus.smartsite.basic.service.IVideoEquipmentService; import com.bonus.smartsite.common.annotation.PreventRepeatSubmit; -import com.bonus.smartsite.common.utils.DateTimeHelper; -import com.bonus.smartsite.common.utils.HttpClient; -import com.bonus.smartsite.common.utils.SystemUtils; +import com.bonus.smartsite.common.utils.*; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; @@ -61,6 +60,9 @@ public class VideoEquipmentController extends BaseController { * 设置视频叠加文字 */ private static final String WATERMARK_URL = "IV/F_IV_TextAdd"; + private static final String TYPE_CLEAR = "清新"; + private static final String TYPE_CREATION = "创世"; + private static final String TYPE_UNIFIED = "统一"; /** * 查询视频设备管理列表 @@ -293,17 +295,18 @@ public class VideoEquipmentController extends BaseController { public AjaxResult updateWaterMark(@RequestBody VideoEquipment bean) { try { String token = redisService.getCacheObject("videoToken"); - String text = bean.getOneText() + "\r\n" + bean.getTwoText(); - Map jsonMap = new HashMap<>(16); - jsonMap.put("puid", bean.getPuId()); - jsonMap.put("idx", 0); - jsonMap.put("text", text); - jsonMap.put("align", "右下对齐"); - jsonMap.put("xpos", "2"); - jsonMap.put("ypos", "2"); - String json = JSON.toJSONString(jsonMap); - String res = HttpClient.sendPost(bean.getVideoPath() + WATERMARK_URL + "?token=" + token, json); - return success(res); +// String text = bean.getOneText() + "\r\n" + bean.getTwoText(); +// Map jsonMap = new HashMap<>(128); +// jsonMap.put("puid", bean.getPuId()); +// jsonMap.put("idx", 0); +// jsonMap.put("text", text); +// jsonMap.put("align", "右下对齐"); +// jsonMap.put("xpos", "2"); +// jsonMap.put("ypos", "2"); +// String json = JSON.toJSONString(jsonMap); +// String res = HttpClient.sendPost(bean.getVideoPath() + WATERMARK_URL + "?token=" + token, json); + String str = QxVideotape.setOsdText(bean,token); + return success(str); } catch (Exception e) { logger.error(e.toString(), e); } @@ -311,4 +314,78 @@ public class VideoEquipmentController extends BaseController { } + /** + * 球机调试权限 + * 暂时废弃 + */ + @ApiOperation(value = "球机调试权限") + @PostMapping("/getDebugBallMachine") + public AjaxResult getDebugBallMachine(VideoEquipment bean) { + try { + if(service.getDebugBallMachine(bean) > 0){ + return success(); + } else { + String typeName = getTypeName(bean.getType()); + return error(typeName +"平台配置未启用！"); + } + } catch (Exception e) { + logger.error(e.toString(), e); + } + return error("系统异常,请联系管理员"); + } + + private String getTypeName(String type) { + if (type == null) { + return ""; + } + switch (type) { + case "1": + return TYPE_CLEAR; + case "2": + return TYPE_CREATION; + case "3": + return TYPE_UNIFIED; + default: + return ""; + } + } + + /** + * 设置3D云台 + * @param bean bean + * @return AjaxResult + */ + + @PostMapping("set3dCloudConfig") + public AjaxResult set3dCloudConfig(@RequestBody BallMachineControl bean) { + AjaxResult ar = new AjaxResult(); + try { + String token = redisService.getCacheObject("videoToken"); + // 校验输入参数 + validateBean(bean); + + String resultMsg = QxVideotape.set3DyunConfig( + bean.getSx(), bean.getSy(), bean.getEx(), bean.getEy(), bean.getPuid(), bean.getUrl(),token + ); + return AjaxResult.success(resultMsg); + } catch (IllegalArgumentException e) { + log.error("参数校验失败: {}", e.getMessage()); + return AjaxResult.error("设置失败"); + } catch (Exception e) { + log.error("设置3D云配置时发生异常", e); + return AjaxResult.error("设置异常"); + } + } + + private void validateBean(BallMachineControl bean) { + if (bean == null) { + throw new IllegalArgumentException("请求参数不能为空"); + } + if (bean.getSx() == null || bean.getSy() == null || bean.getEx() == null || bean.getEy() == null + || bean.getPuid() == null || bean.getUrl() == null) { + throw new IllegalArgumentException("请求参数包含空值"); + } + } + + } diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/BallMachineControl.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/BallMachineControl.java new file mode 100644 index 0000000..77d74ec --- /dev/null +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/BallMachineControl.java @@ -0,0 +1,19 @@ +package com.bonus.smartsite.basic.domain; + +import lombok.Data; + +@Data +public class BallMachineControl { + + private String puid; + + private String sx; + + private String sy; + + private String ex; + + private String ey; + + private String url; +} diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/VideoEquipment.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/VideoEquipment.java index 65e6a36..d02abc2 100644 --- a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/VideoEquipment.java +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/domain/VideoEquipment.java @@ -183,4 +183,9 @@ public class VideoEquipment implements Serializable { */ private String videoPath; + /** + * 平台类型 + */ + private String type; + } diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/mapper/VideoEquipmentMapper.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/mapper/VideoEquipmentMapper.java index 8f4f5ec..dcc09b0 100644 --- a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/mapper/VideoEquipmentMapper.java +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/mapper/VideoEquipmentMapper.java @@ -77,4 +77,11 @@ public interface VideoEquipmentMapper { * 获取视频设备平台配置详细信息 */ PlatformConfiguration getVideoEquipment(); + + /** + * 球机调试权限 + * @param bean VideoEquipment + * @return int + */ + int getDebugBallMachine(VideoEquipment bean); } diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/IVideoEquipmentService.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/IVideoEquipmentService.java index 79c9a13..87d70c6 100644 --- a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/IVideoEquipmentService.java +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/IVideoEquipmentService.java @@ -4,6 +4,7 @@ import com.bonus.smartsite.basic.domain.PlatformConfiguration; import com.bonus.smartsite.basic.domain.VideoEquipment; import java.util.List; +import java.util.Map; /** * 视频设备管理Service接口 @@ -60,4 +61,12 @@ public interface IVideoEquipmentService { * 获取视频设备平台配置详细信息 */ PlatformConfiguration getVideoEquipment(); + + /** + * 球机调试权限 + * @param bean VideoEquipment + * @return int + */ + int getDebugBallMachine(VideoEquipment bean); + } diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/impl/VideoEquipmentServiceImpl.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/impl/VideoEquipmentServiceImpl.java index 1692cbb..732d11d 100644 --- a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/impl/VideoEquipmentServiceImpl.java +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/basic/service/impl/VideoEquipmentServiceImpl.java @@ -127,4 +127,14 @@ public class VideoEquipmentServiceImpl implements IVideoEquipmentService { public PlatformConfiguration getVideoEquipment() { return videoEquipmentMapper.getVideoEquipment(); } + + /** + * 球机调试权限 + * @param bean VideoEquipment + * @return int + */ + @Override + public int getDebugBallMachine(VideoEquipment bean) { + return videoEquipmentMapper.getDebugBallMachine(bean); + } } diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JacksonHelper.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JacksonHelper.java new file mode 100644 index 0000000..61b86a4 --- /dev/null +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JacksonHelper.java @@ -0,0 +1,48 @@ +package com.bonus.smartsite.common.utils; + +import org.codehaus.jackson.map.ObjectMapper; +import org.codehaus.jackson.type.TypeReference; + +import java.io.IOException; + +/** + * @author 19814 + */ +public class JacksonHelper implements JsonHelper { + + @Override + public String jsonSerialize(Object value) { + ObjectMapper objectMapper = new ObjectMapper(); + try { + return objectMapper.writeValueAsString(value); + } catch (IOException e) { + e.printStackTrace(); + return null; + } + } + + @Override + @SuppressWarnings("unchecked") + public T jsonDeserialize(String value, Class tClass) { + ObjectMapper objectMapper = new ObjectMapper(); + try { + return (T) objectMapper.readValue(value, tClass); + } catch (IOException e) { + e.printStackTrace(); + return null; + } + } + + @SuppressWarnings("unchecked") + public T jsonDeserialize(String value, + TypeReference typeReference) { + ObjectMapper objectMapper = new ObjectMapper(); + try { + return (T) objectMapper.readValue(value, typeReference); + } catch (IOException e) { + e.printStackTrace(); + return null; + } + } + +} diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JsonHelper.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JsonHelper.java new file mode 100644 index 0000000..086f2d3 --- /dev/null +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/JsonHelper.java @@ -0,0 +1,159 @@ +package com.bonus.smartsite.common.utils; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; + +import java.util.List; + +public interface JsonHelper { + + public String jsonSerialize(Object value); + + public T jsonDeserialize(String value, Class tClass); + + /** + * 将任意bean转换成json字符串 + * fast json + * @param bean + * @param + * @return + */ + public static String beanToJsonStr(T bean) { + String jsonStr = JSON.toJSONString(bean); + return jsonStr; + } + + /** + * 把一个json字符串转换成bean对象 + * fast json + * @param str + * @param + * @return + */ + public static T jsonStrToBean(String str, Class clazz) { + T bean = JSON.parseObject(str, clazz); + return bean; + } + + /** + * 把一个jsonObj转换成bean对象 + * fast json + * @param jsonObj + * @param + * @return + */ + public static T jsonObjToBean(JSONObject jsonObj, Class clazz) { + String s = jsonObj.toJSONString(); + T bean = JSON.parseObject(s, clazz); + return bean; + } + + /** + * 把一个bean对象转换成jsonObj + * fast json + * @param bean + * @param + * @return + */ + public static JSONObject beanToJsonObj(T bean) { + Object o = JSON.toJSON(bean); + return (JSONObject) o; + } + + /** + * 把一个jsonStr转换成jsonObj + * fast json + * @param str + * @return + */ + public static JSONObject jsonStrToJsonObj(String str) { + Object o = JSON.parseObject(str); + return (JSONObject) o; + } + + /** + * 把一个jsonObj转换成jsonStr + * fast json + * @param jsonObj + * @return + */ + public static String jsonObjToJsonStr(JSONObject jsonObj) { + String s = jsonObj.toJSONString(); + return s; + } + + + /** + * 把一个beanList对象转换成jsonArrStr + * fast json + * @param beanList + * @param + * @return + */ + public static JSONArray beanListToJsonArrStr(List beanList) { + Object o = JSON.toJSON(beanList); + return (JSONArray) o; + } + + /** + * 把一个jsonArrStr转换成beanList对象 + * fast json + * @param jsonArrStr + * @param + * @return + */ + public static List jsonArrStrToBeanList(String jsonArrStr,Class clazz) { + List ts = JSON.parseArray(jsonArrStr, clazz); + return ts; + } + + + /** + * 把一个JsonArr转换成JsonArrStr + * fast json + * @param jsonArr + * @return + */ + public static String jsonArrToJsonArrStr(JSONArray jsonArr) { + String s = JSON.toJSONString(jsonArr); + return s; + } + + + /** + * 把一个JsonArrStr文本转换成JsonArr + * fast json + * @param jsonArrStr + * @return + */ + public static JSONArray jsonArrStrToJsonArr(String jsonArrStr) { + Object o = JSON.parse(jsonArrStr); + return (JSONArray) o; + } + + + /** + * 把一个JsonArr转换成beanList + * fast json + * @param jsonArr + * @return + */ + public static List jsonArrToBeanList(JSONArray jsonArr,Class clazz) { + String s = JSON.toJSONString(jsonArr); + List ts = JSON.parseArray(s, clazz); + return ts; + } + + + /** + * 把一个beanList文本转换成JsonArr + * fast json + * @param beanList + * @return + */ + public static JSONArray beanListToJsonArr(List beanList) { + Object o = JSON.toJSON(beanList); + return (JSONArray) o; + } +} diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/PostXml.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/PostXml.java new file mode 100644 index 0000000..189b31f --- /dev/null +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/PostXml.java @@ -0,0 +1,116 @@ +package com.bonus.smartsite.common.utils; + + +import lombok.extern.slf4j.Slf4j; + +import org.apache.commons.httpclient.methods.PostMethod; +import org.dom4j.Document; +import org.dom4j.DocumentHelper; +import org.dom4j.Element; + +import java.io.IOException; +import java.util.Iterator; + +import org.apache.commons.httpclient.NameValuePair; + + +@Slf4j +public class PostXml { + + /** + * 获取3d云台报文 + * + * @param Sx 开始横坐标 + * @param Sy 开始y坐标 + * @param Ex 结束点很坐标 + * @param Ey 结束点 y坐标 + * @return + */ + public static String get3DyunXmlData(String Sx, String Sy, String Ex, String Ey) { + StringBuffer builder = new StringBuffer(); + try { + builder.append("\n"); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + } catch (Exception e) { + log.error(e.toString(), e); + } + return builder.toString(); + } + + /** + * 设置水印 + * + * @param value + * @return + */ + public static String getOsDText(String value) { + StringBuffer builder = new StringBuffer(); + try { + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + builder.append(""); + } catch (Exception e) { + log.error(e.toString(), e); + } + return builder.toString(); + } + + public static String sedPostXml(String postUrl, String xmlString) throws IOException { + + String postURL; + PostMethod postMethod = null; + postMethod = new PostMethod(postUrl); + postMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8"); + //参数设置，需要注意的就是里边不能传NULL，要传空字符串 + NameValuePair[] data = { + new NameValuePair("xml", xmlString), + }; + postMethod.setRequestBody(data); + org.apache.commons.httpclient.HttpClient httpClient = new org.apache.commons.httpclient.HttpClient(); + int response = httpClient.executeMethod(postMethod); // 执行POST方法 + String result = postMethod.getResponseBodyAsString(); + return result; + } + + + /** + * xml解析 + * + * @return + */ + public static String getXml3dYunConfigData(String xml) { + String msg = "设置成功"; + try { + Document doc = DocumentHelper.parseText(xml); // 将字符串转为XML + Element rootElt = doc.getRootElement(); // 获取根节点 + // System.out.println("根节点：" + rootElt.getName()); // 拿到根节点的名称 + Element C = rootElt.element("C"); + // System.out.println("子节点：" + C.getName()); // 拿到子节点名称 + Iterator iter = C.elementIterator("Res"); // 获取结果点下的返回数据集合 + while (iter.hasNext()) { + Element Event = (Element) iter.next();//子节点名//父类节点 + // System.out.println("根节点：" + Event.getName()); // 拿到根节点的名称 + String type = Event.attributeValue("Type"); + if (!"PTZ".equals(type)) { + msg = "设置失败"; + } + } + + } catch (Exception e) { + msg = "设置失败"; + } + return msg; + } + +} diff --git a/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/QxVideotape.java b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/QxVideotape.java new file mode 100644 index 0000000..4b39a94 --- /dev/null +++ b/bonus-modules/bonus-smart-site/src/main/java/com/bonus/smartsite/common/utils/QxVideotape.java @@ -0,0 +1,103 @@ +package com.bonus.smartsite.common.utils; + +import com.bonus.common.redis.service.RedisService; +import com.bonus.smartsite.basic.domain.VideoEquipment; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.HashMap; +import java.util.Map; + + +/** + * 清新平台数据获取 + * + * @author 吕继龙 + */ +@Slf4j +@Component +public class QxVideotape { + + @Autowired + private RedisService redisService; + + private static final String EPID = "system";// 登录平台企业ID + private static final int BFIX = 1;// 登录平台是否通过网闸模式 + private static final String LOGIN_URL = "login";// 登录地址 + private static final String LOGIN_URL2 = "login2";// 加密登录 + private static final String GETBALLURL = "CAS/C_CAS_QueryPUIDRes";// 球机状态批量获取 + private static final String GETBALLFILE = "SG/C_SG_QueryRecordFiles"; // 获取前端录像-图片- + private static final String GETBALLLIST = "CAS/C_CAS_QueryPUIDSets"; // 获取平台下球机列表 + private static final String GPSBALLURL = "GPS/C_GS_QueryLastGPSData";//获取球机gps + private static final String GETBALLLoadFile = "SG/C_SG_DownLoadFile_PushMode"; //下载前端抓拍文件 + private static final String ON_DEMAND_VIDEO = "SG/VODFile.flv"; //前端存储 - 点播前端录像 + private static final String ONDEMANDVIDEOPLATFORM = "CSS/VODFile.flv"; //云台点播 - 点播云台录像 + private static final String QUERYSTORAGEFILES = "CSS/C_CSS_QueryStorageFiles"; //云存储 - 查询云录像云抓拍 + private static final String QUERYPICTUREFILES = "CSS/C_CSS_DownloadFile";//云存储 - 下载云平台图片文件 + + private static final String DOWN_WEB_URL="SG/C_SG_DownLoadFile_PushMode"; + + + private static final String BallUpdown = "RawRequest?dstType=8&dstID=&token=";//球机上下线 + + private static final String setConfig = "RawRequest?dstType=201&dstID=";//裸命令接口 + + private static final String set3dConfig = "RawRequest?dstType=201&dstID=";//裸命令接口 + + private static final String WATERMARK_URL = "IV/F_IV_TextAdd";//设置视频叠加文字 + + private static final String RawRequest_URL = "RawRequest";//设置视频叠加文字 + + public static final String pictureQuery = QUERYPICTUREFILES; //云存储 - 下载云平台图片文件 + + public static final String videoQuery = ONDEMANDVIDEOPLATFORM;//云台点播 - 点播云台录像 + + public static final String videoWebQuery = ON_DEMAND_VIDEO;//前端录像点播 + + + private static final String setDeviceText = "xml?dstType=201&dstID="; + + + + + public static String set3DyunConfig(String Sx, String Sy, String Ex, String Ey, String puid, String Q2HTTPURL,String token ) { + String msg = "设置成功"; + try { + String xml = PostXml.get3DyunXmlData(Sx, Sy, Ex, Ey); + Map jsonMap = new HashMap<>(16); + jsonMap.put("xml", xml); + String json = new JacksonHelper().jsonSerialize(jsonMap); + String resultXml = HttpClient.sendPost(Q2HTTPURL + set3dConfig + puid + "&token=" + token, json); + msg = PostXml.getXml3dYunConfigData(resultXml); + } catch (Exception e) { + msg = "设置失败"; + log.error(e.toString(), e); + } + return msg; + } + + /** + * 设置叠加文字 + * + * @param o + * @return + */ + public static String setOsdText(VideoEquipment o,String token) { + String text = o.getOneText() + "\r\n" + o.getTwoText(); + try { + //登录 + + log.info("xml:" + o.getVideoPath() + setDeviceText + o.getPuId() + "&token=" + token); + String xml = PostXml.getOsDText(text); + String str = PostXml.sedPostXml(o.getVideoPath() + setDeviceText + o.getPuId() + "&token=" + token, xml); + return str; + } catch (Exception e) { + log.error(e.toString(), e); + return ""; + } + } + + + +} diff --git a/bonus-modules/bonus-smart-site/src/main/resources/mapper/VideoEquipmentMapper.xml b/bonus-modules/bonus-smart-site/src/main/resources/mapper/VideoEquipmentMapper.xml index edea4c3..d57fb22 100644 --- a/bonus-modules/bonus-smart-site/src/main/resources/mapper/VideoEquipmentMapper.xml +++ b/bonus-modules/bonus-smart-site/src/main/resources/mapper/VideoEquipmentMapper.xml @@ -122,4 +122,9 @@ FROM sys_video_config WHERE del_flag = 0 AND status = 1 + \ No newline at end of file