From bfd87d12adb1d511334cd91cf6c7ff3608fae8b9 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期三, 09 十月 2024 16:30:38 +0800 Subject: [PATCH] 最新版本 --- server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java | 209 +++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 167 insertions(+), 42 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java b/server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java index b1ea5b6..0d7e426 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java @@ -1,29 +1,24 @@ package com.doumee.core.haikang.model; import com.alibaba.fastjson.JSONObject; -import com.doumee.config.SpringContextUtil; import com.doumee.core.haikang.model.param.request.CarPictureRequest; import com.doumee.core.haikang.service.HKService; -import com.doumee.core.utils.Constants; import com.doumee.dao.business.model.InterfaceLog; import com.doumee.service.business.InterfaceLogService; import com.hikvision.artemis.sdk.ArtemisHttpUtil; import com.hikvision.artemis.sdk.config.ArtemisConfig; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; -import org.apache.tomcat.util.bcel.Const; -import org.yaml.snakeyaml.scanner.Constant; -import java.io.*; -import java.net.HttpURLConnection; -import java.net.InetSocketAddress; -import java.net.Proxy; -import java.net.URL; -import java.text.DateFormat; -import java.text.ParseException; -import java.text.SimpleDateFormat; -import java.util.*; +import java.io.File; +import java.io.FileOutputStream; +import java.io.InputStream; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; +import java.util.UUID; @Slf4j @@ -60,7 +55,7 @@ } public static InterfaceLogService interfaceLogService = null; - private static void saveInterfaceLog(String s, String result,Map<String, String> path) { + private static void saveInterfaceLog(String s, String result,Map<String, String> path,String name) { // InterfaceLogService bean = SpringContextUtil.getBean(InterfaceLogService.class); if(interfaceLogService !=null){ InterfaceLog hkMonitoryLogDO=new InterfaceLog(); @@ -69,7 +64,7 @@ hkMonitoryLogDO.setIsdeleted(0); hkMonitoryLogDO.setRequest(s); hkMonitoryLogDO.setRepose(result); - hkMonitoryLogDO.setName(path.get(HKConstants.https)); + hkMonitoryLogDO.setName("銆愬畨闃插钩鍙般��"+name); hkMonitoryLogDO.setUrl(HKConstants.https + ArtemisConfig.host+path.get(HKConstants.https)); interfaceLogService.create(hkMonitoryLogDO); } @@ -78,9 +73,9 @@ private static Map<String, String> getPath(String str) { final String getCamsApi = HKConstants.ARTEMIS_PATH + str; Map<String, String> path = new HashMap<String, String>(2) { - { - put(HKConstants.https, getCamsApi);// 鏍规嵁鐜板満鐜閮ㄧ讲纭鏄痟ttp杩樻槸https - } + { + put(HKConstants.https, getCamsApi);// 鏍规嵁鐜板満鐜閮ㄧ讲纭鏄痟ttp杩樻槸https + } }; return path; } @@ -237,16 +232,28 @@ */ public static InputStream getFaceInputStream(String body) throws Exception{ - Map<String, String> path = getPath(HKConstants.InterfacePath.facePicture); + Map<String, String> path = getPath(HKConstants.InterfacePath.facePicture[0]); //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆 - HttpResponse resp = ArtemisHttpUtil.doPostStringImgArtemis( path, body, null, null,"application/json",null); - if (200==resp.getStatusLine().getStatusCode()) { - HttpEntity entity = resp.getEntity(); - InputStream in = entity.getContent(); - return in; - }else{ - throw new Exception("浜鸿劯涓嬭浇鍑洪敊"); + log.error("=========================ArtemisConfig.host***********************************"+ ArtemisConfig.host); + log.error("=========================ArtemisConfig.key********************************"+ArtemisConfig.appKey); + try { + log.error("-------------------------ArtemisConfig.host***********************************"+ ArtemisConfig.host); + log.error("-------------------------ArtemisConfig.key********************************"+ArtemisConfig.appKey); + HttpResponse resp = ArtemisHttpUtil.doPostStringImgArtemis( path, body, null, null,"application/json",null); + if (200==resp.getStatusLine().getStatusCode()) { + HttpEntity entity = resp.getEntity(); + InputStream in = entity.getContent(); + return in; + }else{ + log.error("浜鸿劯涓嬭浇鍑洪敊"); + throw new Exception("浜鸿劯涓嬭浇鍑洪敊"); + } + }catch (Exception e){ + e.printStackTrace(); } + log.error("+++++++++++++++++++++++++ArtemisConfig.host***********************************"+ ArtemisConfig.host); + log.error("+++++++++++++++++++++++++ArtemisConfig.key********************************"+ArtemisConfig.appKey); + return null; } /** * 鑾峰彇璁垮璁板綍涓殑鍥剧墖 @@ -254,7 +261,7 @@ * @return */ public static InputStream getVisitPicture(String body) throws Exception{ - Map<String, String> path = getPath(HKConstants.InterfacePath.visitPicture); + Map<String, String> path = getPath(HKConstants.InterfacePath.visitPicture[0]); //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆 HttpResponse resp = ArtemisHttpUtil.doPostStringImgArtemis( path, body, null, null,"application/json",null); if (200==resp.getStatusLine().getStatusCode()) { @@ -272,7 +279,7 @@ */ public static InputStream getDevicePicture(String body) throws Exception{ - Map<String, String> path = getPath(HKConstants.InterfacePath.devicePicture); + Map<String, String> path = getPath(HKConstants.InterfacePath.devicePicture[0]); //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆 HttpResponse resp = ArtemisHttpUtil.doPostStringImgArtemis( path, body, null, null,"application/json",null); if (200==resp.getStatusLine().getStatusCode()) { @@ -291,7 +298,7 @@ */ public static InputStream getCarPicture(String body) throws Exception{ - Map<String, String> path = getPath(HKConstants.InterfacePath.carPicture); + Map<String, String> path = getPath(HKConstants.InterfacePath.carPicture[0]); //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆 HttpResponse resp = ArtemisHttpUtil.doPostStringImgArtemis( path, body, null, null,"application/json",null); if (200==resp.getStatusLine().getStatusCode()) { @@ -335,6 +342,22 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.visitAppiontment,body); } /** + * 璁垮棰勭害 + * @param body + * @return + */ + public static String iccmAppointment(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.iccmAppointment,body); + } + /** + * 璁垮鍏嶇櫥璁伴绾� + * @param body + * @return + */ + public static String iccmAppointmentMDJ(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.iccmAppointmentMDJ,body); + } + /** * 璁垮鍏嶇櫥璁伴绾� * @param body * @return @@ -352,20 +375,38 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.visitCancel,body); } - public static String startDoPostStringArtemis(String pathStr,String body){ - Map<String, String> path = getPath(pathStr); + public static String startDoGetStringArtemis(String[] pathStr,Map<String,String> body ){ + Map<String, String> path = getPath(pathStr[0]); Map<String, String> header = new HashMap<>(); header.put("tagId", UUID.randomUUID().toString().replace("-", "")); - String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟 - saveInterfaceLog(body,result,path); + String result = ArtemisHttpUtil.doGetArtemis(path, body, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟 + saveInterfaceLog(JSONObject.toJSONString(body),result,path,pathStr[1]); return result; } - public static String startDoPostStringArtemis(String pathStr,Map<String, String> querys,Map<String, String> header,String body){ - Map<String, String> path = getPath(pathStr); + public static String startDoPostStringArtemis(String[] pathStr,String body ){ + Map<String, String> path = getPath(pathStr[0]); + Map<String, String> header = new HashMap<>(); + header.put("tagId", UUID.randomUUID().toString().replace("-", "")); + String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟 + saveInterfaceLog(body,result,path,pathStr[1]); + return result; + + } + public static String startDoPostStringArtemis(String[] pathStr,String param,String body ){ + Map<String, String> path = getPath(pathStr[0]+StringUtils.defaultString(param,"")); + Map<String, String> header = new HashMap<>(); + header.put("tagId", UUID.randomUUID().toString().replace("-", "")); + String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟 + saveInterfaceLog(body,result,path,pathStr[1]); + return result; + + } + public static String startDoPostStringArtemis(String[] pathStr,Map<String, String> querys,Map<String, String> header,String body){ + Map<String, String> path = getPath(pathStr[0]); header.put("tagId", UUID.randomUUID().toString().replace("-", "")); String result = ArtemisHttpUtil.doPostStringArtemis(path, body, querys, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟 - saveInterfaceLog(body,result,path); + saveInterfaceLog(body,result,path,pathStr[1]); return result; } @@ -503,6 +544,14 @@ } /** + * 鑾峰彇鍏ㄩ噺缁勭粐淇℃伅 + * @param body + * @return + */ + public static String orgAllList(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.orgAllList,body); + } + /** * 鑾峰彇璁垮棰勭害璁板綍鍒楄〃 * @param body * @return @@ -510,13 +559,81 @@ public static String appointmentRecords(String body) { return startDoPostStringArtemis(HKConstants.InterfacePath.appointmentRecords,body); } + /** - * 鑾峰彇鍏ㄩ噺缁勭粐鍒楄〃 + * 鑾峰彇璁垮棰勭害璁板綍鍒楄〃 iccm * @param body * @return */ - public static String orgAllList(String body) { - return startDoPostStringArtemis(HKConstants.InterfacePath.orgAllList,body); + public static String iccmAppointmentRecords(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.iccmAppointmentRecords,body); + } + /** + * 鏍规嵁寰俊鍏紬鍙蜂俊鎭幏鍙朅ccessToken + * @return + */ + public static String wxAccessToken(String configId,String tagId) { + String[] wxAccessToken= HKConstants.InterfacePath.wxAccessToken; + wxAccessToken[0] = HKConstants.InterfacePath.wxAccessToken+"?tagId="+tagId+"&configId"+configId; + return startDoPostStringArtemis(wxAccessToken,""); + } + /** + * 鏍规嵁閰嶇疆寰俊鍏紬鍙风紪鍙锋煡璇㈠井淇″叕浼楀彿淇℃伅 + * @param body + * @return + */ + public static String getWxConfig(Map<String,String> body) { + return startDoGetStringArtemis(HKConstants.InterfacePath.getWxConfig,body); + } + /** + * 鏍规嵁閰嶇疆寰俊鍏紬鍙风紪鍙锋煡璇㈠井淇″叕浼楀彿淇℃伅 + * @param body + * @return + */ + public static String nhEventPageList(Map<String,String> body) { + return startDoGetStringArtemis(HKConstants.InterfacePath.nhEventPageList,body); + } + + /** + * 鏌ヨ娑堥槻璁惧閮ㄤ欢鐘舵�� + * @param body + * @return + */ + public static String fireDeviceStatusSearch(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.fireDeviceStatusSearch,body); + } + /** + * 鍒嗛〉鏌ヨ娑堥槻浼犳劅鍣ㄩ儴浠剁姸鎬� + * @param body + * @return + */ + public static String sensorStatusSearch(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.sensorStatusSearch,body); + } + /** + * 鍒嗛〉鏌ヨ璁惧涓嬬殑鎵�鏈夋姤璀﹁褰� + * @param body + * @return + */ + public static String findDeviceAlarmPage(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.findDeviceAlarmPage,body); + } + /** + * 璇㈡秷闃茶澶囧垪琛� + * @param body + * @return + */ + public static String fireChannelSearch(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.fireChannelSearch,body); + } + + /** + * 璇㈡秷闃茶澶囧垪琛� + * @param body + * @return + */ + public static String fireDeviceSearch(String body) { + return startDoPostStringArtemis(HKConstants.InterfacePath.fireDeviceSearch,body); } /** * 鑾峰彇鍏ㄩ噺鐢ㄦ埛鍒楄〃 @@ -625,11 +742,14 @@ } /** * 鑾峰彇鏈堝彴鐘舵�� - * @param body * @return */ - public static String platformStatus(String body) { - return startDoPostStringArtemis(HKConstants.InterfacePath.platformStatus,body); + public static String platformStatus(String param) { + if(StringUtils.isNotBlank(param)){ + return startDoPostStringArtemis(HKConstants.InterfacePath.platformStatus,"?platformIds="+param,null); + }else{ + return startDoPostStringArtemis(HKConstants.InterfacePath.platformStatus,null); + } } /** * 鑾峰彇鏈堝彴缁勪欢閰嶇疆鐨凩ED璁惧娓呭崟 @@ -682,4 +802,9 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.applyST,body); } + public static String getMenuUrl(String menuId, String token) { + String url = HKConstants.InterfacePath.goMenuUrl[0]; + url = url.replace("${menuId}", menuId).replace("${token}",token); + return url; + } } -- Gitblit v1.9.3