From 905576b68bd0383a8b6f28df6ba50d059649c95d Mon Sep 17 00:00:00 2001 From: zhangyue Date: Tue, 9 Jan 2024 19:20:45 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=86=E9=A2=91=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zcloud/util/HttpClientService.java | 72 ++++++++- .../java/com/zcloud/util/HttpRequestUtil.java | 65 ++++++++ src/main/java/com/zcloud/util/RedisUtil.java | 69 ++++++++ src/main/java/com/zcloud/util/ys/YSUtil.java | 148 ++++++++++++++++++ src/main/resources/application-dev.properties | 18 +-- .../webapp/uploadFiles/ys/ysDictionaries.md | 0 6 files changed, 361 insertions(+), 11 deletions(-) create mode 100644 src/main/java/com/zcloud/util/RedisUtil.java create mode 100644 src/main/java/com/zcloud/util/ys/YSUtil.java create mode 100644 src/main/webapp/uploadFiles/ys/ysDictionaries.md diff --git a/src/main/java/com/zcloud/util/HttpClientService.java b/src/main/java/com/zcloud/util/HttpClientService.java index 2adb7701..654957db 100644 --- a/src/main/java/com/zcloud/util/HttpClientService.java +++ b/src/main/java/com/zcloud/util/HttpClientService.java @@ -5,10 +5,8 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.entity.PageData; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; -import org.apache.http.HttpStatus; import org.apache.http.NameValuePair; import org.apache.http.client.HttpClient; -import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; @@ -249,6 +247,76 @@ public class HttpClientService { } return null; } + /** + * 发送POST请求 + * @param url + * @param headerMap + * @param bodyMap + * @return JSON或者字符串 + * @throws Exception + */ + public static Map sendPostJsonForMap(String url, Map headerMap, PageData bodyMap) throws Exception{ + JSONObject jsonObject = null; + HttpClient client = new SSLClient(); + HttpResponse response = null; + try{ + /** + * 创建一个httpclient对象 + */ + client = HttpClients.createDefault(); + /** + * 创建一个post对象 + */ + HttpPost post = new HttpPost(url); + for (String key : headerMap.keySet()) { + post.setHeader(key, headerMap.get(key).toString()); + } + /** + * 包装成一个Entity对象 + */ + StringEntity entity = new StringEntity(JSONObject.toJSONString(bodyMap), ContentType.create("application/json", "utf-8")); + /** + * 设置请求的内容 + */ + post.setEntity(entity); + /** + * 执行post请求 + */ + response = client.execute(post); + /** + * 获取响应码 + */ + int statusCode = response.getStatusLine().getStatusCode(); + if (SUCCESS_CODE == statusCode){ + /** + * 通过EntityUitls获取返回内容 + */ + String result = EntityUtils.toString(response.getEntity(),"UTF-8"); + /** + * 转换成json,根据合法性返回json或者字符串 + */ + try{ + jsonObject = JSONObject.parseObject(result); + Map maps = new HashMap(); + maps = parseJSON2Map(jsonObject); + return maps; + }catch (Exception e){ + e.printStackTrace(); + return null; + } + }else{ + LOGGER.error("HttpClientService-line: {}, errorMsg：{}", 146, "POST请求失败！"); + } + }catch (Exception e){ + LOGGER.error("HttpClientService-line: {}, Exception：{}", 149, e); + }finally { + /* response.close(); + client.close();*/ + } + return null; + } + + /** * 发送POST请求（无请求头Accept） diff --git a/src/main/java/com/zcloud/util/HttpRequestUtil.java b/src/main/java/com/zcloud/util/HttpRequestUtil.java index a8b82c9b..040e2ece 100644 --- a/src/main/java/com/zcloud/util/HttpRequestUtil.java +++ b/src/main/java/com/zcloud/util/HttpRequestUtil.java @@ -9,6 +9,7 @@ import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; +import java.util.Map; /** * description: http请求工具类 @@ -130,6 +131,70 @@ public class HttpRequestUtil { return result.toString(); } + + + /** + * Http get请求 + * + * @param httpUrl 连接 + * @return 响应数据 + */ + public static String doGetInitHearer(String httpUrl, Map headerMap) throws Exception { + //链接 + HttpURLConnection connection = null; + InputStream is = null; + BufferedReader br = null; + StringBuffer result = new StringBuffer(); + try { + //创建连接 + URL url = new URL(httpUrl); + connection = (HttpURLConnection) url.openConnection(); + //设置请求方式 + connection.setRequestMethod("GET"); + + //设置请求头 + for (String key : headerMap.keySet()) { + connection.setRequestProperty(key, headerMap.get(key).toString()); + } + //设置连接超时时间 + connection.setReadTimeout(15000); + //开始连接 + connection.connect(); + //获取响应数据 + if (connection.getResponseCode() == 200) { + //获取返回的数据 + is = connection.getInputStream(); + if (null != is) { + br = new BufferedReader(new InputStreamReader(is, "UTF-8")); + String temp = null; + while (null != (temp = br.readLine())) { + result.append(temp); + } + } + } + } catch (Exception e) { + e.printStackTrace(); + } finally { + if (null != br) { + try { + br.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (null != is) { + try { + is.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + //关闭远程连接 + connection.disconnect(); + } + return result.toString(); + } + /** * Http get请求 * diff --git a/src/main/java/com/zcloud/util/RedisUtil.java b/src/main/java/com/zcloud/util/RedisUtil.java new file mode 100644 index 00000000..e82c30eb --- /dev/null +++ b/src/main/java/com/zcloud/util/RedisUtil.java @@ -0,0 +1,69 @@ +package com.zcloud.util; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import javax.annotation.Resource; +import java.util.concurrent.TimeUnit; + +/** + * @author fangjiakai + * @date 2024/1/8 20:56 + */ +@Component +public class RedisUtil { + @Autowired + private RedisTemplate redisTemplate; + + /** + * 保存string + * @param key + * @param value + */ + public void setString(String key, String value){ + redisTemplate.opsForValue().set(key,value); + } + /** + * 获取string + * @param key + * @param value + */ + public String getString(String key){ + return redisTemplate.opsForValue().get(key).toString(); + } + + /** + * 保存string并设置失效（time为秒） + * @param key + * @param value + * @param time + */ + public void setString(String key, String value, long time){ + redisTemplate.opsForValue().set(key,value,time, TimeUnit.SECONDS); + } + /** + * 查看是否有key + * @param key + */ + public boolean hasKey(String key){ + return redisTemplate.hasKey(key); + } + /** + * 查看key过期时间 + * @param key + */ + public long getExpire(String key){ + return redisTemplate.getExpire(key); + } + + /** + * 设置过期时间 + * @param key + * @param time + */ + public void expire(String key, long time) { + redisTemplate.expire(key, time, TimeUnit.SECONDS); + } +} diff --git a/src/main/java/com/zcloud/util/ys/YSUtil.java b/src/main/java/com/zcloud/util/ys/YSUtil.java new file mode 100644 index 00000000..fbb9628f --- /dev/null +++ b/src/main/java/com/zcloud/util/ys/YSUtil.java @@ -0,0 +1,148 @@ +package com.zcloud.util.ys; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.zcloud.entity.PageData; +import com.zcloud.util.*; +import org.apache.http.NameValuePair; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; +import org.springframework.stereotype.Controller; + +import java.net.URLEncoder; +import java.util.*; + +/** + * 宇视工具类 + */ + +@Component +public class YSUtil { + private static final String vmip = "http://172.14.0.54"; + private static final String name = "loadmin"; + private static final String passwd = "_Ab54321"; + private static final String vmport = "7010"; + private static final String linkPort = "8093"; + private static final String VIIDPort = "8088"; + @Autowired + private RedisUtil redisUtil; + + + public void loginOrKeepAlive() throws Exception { + // 剩余过期时间 -2为AccessToken已经过期 + Long residueTimeOut = redisUtil.getExpire("AccessToken"); + // 如果已经过期，重新获取AccessToken + if (residueTimeOut < 0) { + Map resultFinal = null; + // 首次登录获取accessCode + Map resultFirst = HttpClientService.sendPostJsonForMap(vmip + ":" + VIIDPort + "/VIID/login/v2", new HashMap(), null); + if (resultFirst != null && resultFirst.get("AccessCode") != null) { + String accessCode = resultFirst.get("AccessCode").toString(); + // MD5(BASE64(UserName)+ AccessCode + MD5(用户密码)) + PageData pd = new PageData(); + String LoginSignature = MD5.md5(encode(name.getBytes()) + accessCode + MD5.md5(passwd)); + pd.put("UserName", name); + pd.put("AccessCode", accessCode); + pd.put("LoginSignature", LoginSignature); + // 第二次登录获取AccessToken + resultFinal = HttpClientService.sendPostJsonForMap(vmip + ":" + VIIDPort + "/VIID/login/v2", new HashMap(), pd); + if (resultFinal != null && resultFinal.get("AccessToken") != null) { + String AccessToken = resultFinal.get("AccessToken").toString(); + redisUtil.setString("AccessToken", AccessToken, 30); + } + } + } else if (residueTimeOut < 10) { // 10秒内过期，进行AccessToken保活，并刷新redis过期时间 + Map header = new HashMap(); + System.out.println(redisUtil.getString("AccessToken")); + header.put("Authorization", redisUtil.getString("AccessToken")); + Map keepAliveResult = HttpClientService.sendPostJsonForMap(vmip + ":" + VIIDPort + "/VIID/hadesadapter/user/keepalive", header, null); + if (keepAliveResult != null && keepAliveResult.get("ErrCode") != null && ("0").equals(keepAliveResult.get("ErrCode").toString())) { + redisUtil.expire("AccessToken", 30); + } + } + } + + public JSONObject queryAreaList(PageData pd) throws Exception { + this.loginOrKeepAlive(); + Map header = new HashMap(); + header.put("Authorization", redisUtil.getString("AccessToken")); + JSONObject condition = new JSONObject(); + condition.put("QueryCount", 1); + condition.put("PageFirstRowNumber", 0); + condition.put("PageRowNum", 200); + JSONArray conditionArray = new JSONArray(); + // 查询条件 + // 这个queryCondition查询条件翻译过来就是 where RES_TYPE = "1" + // 查询条件的类型 - 256-资源类型(RES_TYPE) + // 查询条件的逻辑关系 0 代表等于 +// 查询条件的值 在资源类型中 1 -组织域 +// JSONObject queryCondition = initQueryCondition(256, 0, "1"); + + // 这个queryCondition1查询条件翻译过来就是 order by RES_SUB_TYPE asc + // 查询条件的类型 - 11-资源子类型(RES_SUB_TYPE) + // 查询条件的逻辑关系 6 代表升序 +// JSONObject queryCondition2 = initQueryCondition(11, 6, ""); + + // 这个queryCondition3查询条件翻译过来就是 order by EVENT_TYPE_NAME asc + // 查询条件的类型 - 273-事件类型名称(EVENT_TYPE_NAME) + // 查询条件的逻辑关系 6 代表升序 +// JSONObject queryCondition3 = initQueryCondition(273, 6, ""); + // 以此类推，下面将不在举例说明具体的查询条件，编码数据字典附录在src/main/webapp/uploadFiles/ys/ysDictionaries.md 这里 + + conditionArray.add(initQueryCondition(256, 0, "1")); + conditionArray.add(initQueryCondition(11, 6, "")); + conditionArray.add(initQueryCondition(273, 6, "")); + conditionArray.add(initQueryCondition(1, 6, "")); + conditionArray.add(initQueryCondition(269, 0, "1")); + condition.put("Condition", conditionArray); + condition.put("ItemNum", conditionArray.size()); + String encodedOrg = URLEncoder.encode(pd.get("org").toString(), "UTF-8"); + String encodedCondition = URLEncoder.encode(condition.toJSONString(), "UTF-8"); + String resultStr = HttpRequestUtil.doGetInitHearer(vmip + ":" + VIIDPort +"/VIID/query?org="+encodedOrg+"&condition="+encodedCondition, header); + JSONObject resultJson = JSONObject.parseObject(resultStr); + return resultJson; + } + + public JSONObject queryCameraList(PageData pd) throws Exception { + this.loginOrKeepAlive(); + Map header = new HashMap(); + header.put("Authorization", redisUtil.getString("AccessToken")); + JSONObject condition = new JSONObject(); + condition.put("QueryCount", 1); + condition.put("PageFirstRowNumber", 0); + condition.put("PageRowNum", 200); + JSONArray conditionArray = new JSONArray(); + + conditionArray.add(initQueryCondition(256, 0, "1001")); + conditionArray.add(initQueryCondition(273, 6, "")); + conditionArray.add(initQueryCondition(1, 6, "")); + condition.put("Condition", conditionArray); + condition.put("ItemNum", conditionArray.size()); + String encodedOrg = URLEncoder.encode(pd.get("org").toString(), "UTF-8"); + String encodedCondition = URLEncoder.encode(condition.toJSONString(), "UTF-8"); + String resultStr = HttpRequestUtil.doGetInitHearer(vmip + ":" + VIIDPort +"/VIID/query?org="+encodedOrg+"&condition="+encodedCondition, header); + JSONObject resultJson = JSONObject.parseObject(resultStr); + return resultJson; + } + + + private JSONObject initQueryCondition(int queryType, int logicFlag, String queryData) { + JSONObject queryCondition = new JSONObject(); + queryCondition.put("QueryType", queryType); // 查询条件的类型 + queryCondition.put("LogicFlag", logicFlag); // 查询条件的逻辑关系 + queryCondition.put("QueryData", queryData); // 查询条件的值 + return queryCondition; + } + + + + //base64加密 + public static String encode(byte[] content) { + return new sun.misc.BASE64Encoder().encode(content); + } + + +} diff --git a/src/main/resources/application-dev.properties b/src/main/resources/application-dev.properties index 2705b8e5..133ad827 100644 --- a/src/main/resources/application-dev.properties +++ b/src/main/resources/application-dev.properties @@ -1,11 +1,11 @@ datasource.no1.driver-class-name: com.mysql.cj.jdbc.Driver -datasource.no1.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-prevention?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 +datasource.no1.url=jdbc:mysql://192.168.0.18:3306/qa-cmt-prevention?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 datasource.no1.username=root -datasource.no1.password=Mysql@zcloud88888 -datasource.no2.driver-class-name: com.mysql.cj.jdbc.Driver -datasource.no2.url=jdbc:mysql://39.101.130.96:33068/qa-gwj-regulatory?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 +datasource.no1.password=root +datasource.no2.driver-class-name: com.mysql.cj.jdbc.Driver +datasource.no2.url=jdbc:mysql://192.168.0.18:3306/qa-cmt-regulatory?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf-8 datasource.no2.username=root -datasource.no2.password=Mysql@zcloud88888 +datasource.no2.password=root #druid??? @@ -82,7 +82,7 @@ rocketmq.consumer.group2=edu-admin-edit rocketmq.consumer.group1=edu-admin-add #rocketmq.name-server=10.0.140.141:9876 #rocketmq.name-server=192.168.0.70:9876 -rocketmq.name-server=192.168.0.31:9876 +rocketmq.name-server=192.168.0.18:9876 rocketmq.producer.group=libmiddle rocketmq.producer.send-message-timeout=3000 rocketmq.producer.compress-message-body-threshold=4096 @@ -110,11 +110,11 @@ base.info.BACKENDADDR=http://192.168.0.31:8992/qa-regulatory-gwj/ # Redis\u6570\u636E\u5E93\u7D22\u5F15\uFF08\u9ED8\u8BA4\u4E3A0\uFF09 spring.redis.database=0 # Redis\u670D\u52A1\u5668\u5730\u5740 -spring.redis.host=39.103.224.166 +spring.redis.host=127.0.0.1 # Redis\u670D\u52A1\u5668\u8FDE\u63A5\u7AEF\u53E3 -spring.redis.port=63799 +spring.redis.port=6379 # Redis\u670D\u52A1\u5668\u8FDE\u63A5\u5BC6\u7801\uFF08\u9ED8\u8BA4\u4E3A\u7A7A\uFF09 -spring.redis.password=redis@zcloud88888 +spring.redis.password= # \u8FDE\u63A5\u6C60\u6700\u5927\u8FDE\u63A5\u6570\uFF08\u4F7F\u7528\u8D1F\u503C\u8868\u793A\u6CA1\u6709\u9650\u5236\uFF09 spring.redis.jedis.pool.max-active=20 # \u8FDE\u63A5\u6C60\u6700\u5927\u963B\u585E\u7B49\u5F85\u65F6\u95F4\uFF08\u4F7F\u7528\u8D1F\u503C\u8868\u793A\u6CA1\u6709\u9650\u5236\uFF09 diff --git a/src/main/webapp/uploadFiles/ys/ysDictionaries.md b/src/main/webapp/uploadFiles/ys/ysDictionaries.md new file mode 100644 index 00000000..e69de29b