From 6c5d0a4a9264b7508c7ffe81b45ba239cabf2244 Mon Sep 17 00:00:00 2001
From: nidapeng <jp@doumee.com>
Date: 星期三, 10 四月 2024 17:59:08 +0800
Subject: [PATCH] 最新版本
---
server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java | 379 +++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 358 insertions(+), 21 deletions(-)
diff --git a/server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java b/server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java
index 19e86dc..446c04c 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java
@@ -2,6 +2,8 @@
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;
@@ -13,10 +15,7 @@
import org.apache.tomcat.util.bcel.Const;
import org.yaml.snakeyaml.scanner.Constant;
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
+import java.io.*;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.Proxy;
@@ -34,26 +33,36 @@
public static void main(String[] args) throws Exception {
-// Proxy proxy = new Proxy(Proxy.Type.DIRECT, new InetSocketAddress("127.0.0.1",Integer.valueOf("1080")));
- URL realUrl = new URL("https://10.50.60.253/artemis/api/eventService/v1/eventSubscriptionByEventTypes");
- HttpURLConnection con = (HttpURLConnection) realUrl.openConnection();
- con.setRequestMethod("GET");
-// con.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:57.0) ;Gecko/20100101 Firefox/57.0");
- BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
- String inputLine;
- StringBuffer content = new StringBuffer();
- while ((inputLine = in.readLine()) != null) {
- content.append(inputLine);
+ ArtemisConfig.host = "10.50.60.253";
+ ArtemisConfig.appKey = "27786546";
+ ArtemisConfig.appSecret = "kC5dohxU7CvEqgGhVt4R";
+ HKConstants.https = "https://";
+ CarPictureRequest param = new CarPictureRequest();
+ param.setPicUri( "HKIMG=/pic?0dd400=4c40ip-feo831-933*9o4=3=2109*2l0001893117*0t7=6*2ps==014b*=787d*069d70361-95754d-9*l108od0b192=001");
+ param.setAswSyscode("3fa3e5e3-db3e-41ba-97fc-39c948778dfe");
+ InputStream is = HKService.getCarPicture(param);
+ File imageFile = new File("D:\\visit\\111"+UUID.randomUUID().toString()+".png");
+ try {
+ byte[] bytes = new byte[1024];
+ FileOutputStream outStream = new FileOutputStream(imageFile);
+ int index;
+ while ((index = is.read(bytes)) != -1) {
+ outStream.write(bytes, 0, index);
+ outStream.flush();
+ }
+// outStream = new FileOutputStream(imageFile);
+// outStream.write(bytes);
+ //鍏抽棴杈撳嚭娴�
+ outStream.close(); //鍐欏叆鏁版嵁
+ } catch ( Exception e) {
+ throw new RuntimeException(e);
}
- in.close();
- con.disconnect();
-
- System.out.println(content.toString());
}
+ public static InterfaceLogService interfaceLogService = null;
private static void saveInterfaceLog(String s, String result,Map<String, String> path) {
- InterfaceLogService bean = SpringContextUtil.getBean(InterfaceLogService.class);
- if(bean !=null){
+// InterfaceLogService bean = SpringContextUtil.getBean(InterfaceLogService.class);
+ if(interfaceLogService !=null){
InterfaceLog hkMonitoryLogDO=new InterfaceLog();
hkMonitoryLogDO.setType(0);
hkMonitoryLogDO.setCreateDate(new Date());
@@ -62,7 +71,7 @@
hkMonitoryLogDO.setRepose(result);
hkMonitoryLogDO.setName(path.get(HKConstants.https));
hkMonitoryLogDO.setUrl(HKConstants.https + ArtemisConfig.host+path.get(HKConstants.https));
- bean.create(hkMonitoryLogDO);
+ interfaceLogService.create(hkMonitoryLogDO);
}
}
@@ -291,6 +300,61 @@
}
}
/**
+ * 鑾峰彇璁垮璁板綍涓殑鍥剧墖
+ * @param body
+ * @return
+ */
+ public static InputStream getVisitPicture(String body) throws Exception{
+
+ Map<String, String> path = getPath(HKConstants.InterfacePath.visitPicture);
+ //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆
+ 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("鑾峰彇璁垮璁板綍涓殑鍥剧墖涓嬭浇鍑洪敊");
+ }
+ }
+ /**
+ * 鑾峰彇闂ㄧ浜嬩欢鐨勫浘鐗�
+ * @param body
+ * @return
+ */
+ public static InputStream getDevicePicture(String body) throws Exception{
+
+ Map<String, String> path = getPath(HKConstants.InterfacePath.devicePicture);
+ //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆
+ 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("鑾峰彇闂ㄧ浜嬩欢鐨勫浘鐗囦笅杞藉嚭閿�");
+ }
+ }
+
+ /**
+ * 鏌ヨ杞﹁締鎶撴媿鍥剧墖
+ * @param body
+ * @return
+ */
+ public static InputStream getCarPicture(String body) throws Exception{
+
+ Map<String, String> path = getPath(HKConstants.InterfacePath.carPicture);
+ //鍙傛暟鏍规嵁鎺ュ彛瀹為檯鎯呭喌璁剧疆
+ 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("鏌ヨ杞﹁締鎶撴媿鍥剧墖涓嬭浇鍑洪敊");
+ }
+ }
+ /**
* 鑾峰彇闂ㄧ鐐瑰垪琛�
* @param body
* @return
@@ -390,8 +454,281 @@
saveInterfaceLog(body,result,path);
return result;
}
+ /**
+ * 鍙栨秷浜嬩欢璁㈤槄
+ * @param body
+ * @return
+ */
+ public static String cancelEventSub(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.cancelEventSub);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鍒涘缓涓�鍗￠�氭潈闄愪笅杞戒换鍔�
+ * @param body
+ * @return
+ */
+ public static String taskAddition(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskAddition);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鏌ヨ涓�鍗￠�氭潈闄愭煡璇㈣澶囬�氶亾鐨勪汉鍛樻潈闄愪笅杞借鎯呮�绘暟v2
+ * @param body
+ * @return
+ */
+ public static String taskProgress(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskProgress);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鏌ヨ涓�鍗￠�氭潈闄愪笅杞戒换鍔¤繘搴�
+ * @param body
+ * @return
+ */
+ public static String taskProgressNum(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskProgressNum);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 涓�鍗￠�氭潈闄愪笅杞戒换鍔′腑娣诲姞鏁版嵁_鏍规嵁浜哄憳涓庤澶囬�氶亾鎸囧畾涓嬭浇
+ * @param body
+ * @return
+ */
+ public static String taskDataAddition(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskDataAddition);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 涓�鍗￠�氬紑濮嬩笅杞戒换鍔�
+ * @param body
+ * @return
+ */
+ public static String taskStart(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskStart);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鏌ヨ鏉冮檺鏉＄洰鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String authItemList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.authItemList);
+ Map<String, String> header = new HashMap<>();
+ header.put("tagId", UUID.randomUUID().toString().replace("-", ""));
+// header.put("tagId", "frs");
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鎵归噺寮�鍗�
+ * @param body
+ * @return
+ */
+ public static String cardBingding(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.cardBingding);
+ Map<String, String> header = new HashMap<>();
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 閫�鍗�
+ * @param body
+ * @return
+ */
+ public static String cardDeletion(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.cardDeletion);
+ Map<String, String> header = new HashMap<>();
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鎵归噺鎸傚け
+ * @param body
+ * @return
+ */
+ public static String cardLoss(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.cardLoss);
+ Map<String, String> header = new HashMap<>();
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鎵归噺瑙ｆ寕
+ * @param body
+ * @return
+ */
+ public static String cardUnloss(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.cardUnloss);
+ Map<String, String> header = new HashMap<>();
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鏌ヨ璁惧閫氶亾鐨勪汉鍛樻潈闄愪笅杞借鎯�
+ * @param body
+ * @return
+ */
+ public static String taskPersoDetail(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.taskPersoDetail);
+ Map<String, String> header = new HashMap<>();
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鑾峰彇璁垮棰勭害璁板綍鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String visitingRecords(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.visitingRecords);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鑾峰彇璁垮棰勭害璁板綍鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String appointmentRecords(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.appointmentRecords);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鑾峰彇鍏ㄩ噺缁勭粐鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String orgAllList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.orgAllList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鑾峰彇鍏ㄩ噺鐢ㄦ埛鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String userAllList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.userAllList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 澧為噺鑾峰彇缁勭粐鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String orgTimeRangeList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.orgTimeRangeList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 澧為噺鑾峰彇鐢ㄦ埛鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String userTimeRangeList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.userTimeRangeList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 澧為噺鑾峰彇杞﹁締鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String vehicleTimeRangeList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.vehicleTimeRangeList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鍏ㄩ噺鑾峰彇杞﹁締鍒楄〃
+ * @param body
+ * @return
+ */
+ public static String vehicleList(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.vehicleList);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鍋滆溅鍦鸿繃杞﹁褰曟煡璇�
+ * @param body
+ * @return
+ */
+ public static String parkCrossRecords(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.parkCrossRecords);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鍋滆溅鍦鸿繃杞﹁褰曟煡璇�
+ * @param body
+ * @return
+ */
+ public static String facePictureCheck(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.facePictureCheck);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+ /**
+ * 鑾峰彇闂ㄧ璁惧鍦ㄧ嚎鐘舵��
+ * @param body
+ * @return
+ */
+ public static String acsDeviceStatus(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.acsDeviceStatus);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
+
+ /**
+ * 鏌ヨ鍦哄唴杞﹀仠杞︿俊鎭�
+ * @param body
+ * @return
+ */
+ public static String tempCarInRecords(String body) {
+ Map<String, String> path = getPath(HKConstants.InterfacePath.tempCarInRecords);
+ String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", null);// post璇锋眰application/json绫诲瀷鍙傛暟
+ saveInterfaceLog(body,result,path);
+ return result;
+ }
}
--
Gitblit v1.9.3