From 90cc59400715f3ece6384eddf01cefd8eff449ea Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Sun, 28 Apr 2024 14:53:27 +0800
Subject: [PATCH] 视频站点设置，南科院初始化

---
 skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java |   86 +++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 82 insertions(+), 4 deletions(-)

diff --git a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java
index d2aa000..e6491f5 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java
@@ -1,14 +1,12 @@
 package cn.gistack.nky.service.impl;
 
 import cn.gistack.common.utils.SpringContextUtil;
-import cn.gistack.nky.resultpojo.DataBigResultPojo;
-import cn.gistack.nky.resultpojo.DataResChildrenPo;
-import cn.gistack.nky.resultpojo.DataResPo;
-import cn.gistack.nky.resultpojo.ZtResultPo;
+import cn.gistack.nky.resultpojo.*;
 import cn.gistack.nky.service.IZtApiService;
 import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.utils.ObjectUtil;
+import org.springblade.core.tool.utils.StringUtil;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpMethod;
@@ -53,6 +51,9 @@
 	 * 渗流监测
 	 */
 	private static final String SL_API ="/services/1234567890ABCDEFGHIJKLMN/monitor/sl/api?res_nm=&cd=&city_cd=&county_cd=&pageNo=1&pageSize=9999";
+
+	private static final String RES_DAM_MONITOR ="/services/1234567890ABCDEFGHIJKLMN/res_dam_monitor/api?province_cd=420000000000&res_nm=";
+	private static final String BASE_CD ="/services/1234567890ABCDEFGHIJKLMN/base/cd/api";
 
 
 	int getSyCount = 0;
@@ -119,6 +120,46 @@
 	public List<DataResChildrenPo> getSl() {
 		Map<String, Object> params = new LinkedHashMap<>();
 		return getData(SL_API, "get", params);
+	}
+
+	@Override
+	public List<ResDamMonitorResult> getResDamMonitor() {
+		Map<String, Object> params = new LinkedHashMap<>();
+		return getResDamMonitorResult(RES_DAM_MONITOR, "get", params);
+	}
+
+	@Override
+	public List<BaseCd> getBaseCd(String resGuid, String type) {
+		Map<String, Object> params = new LinkedHashMap<>();
+		String url = BASE_CD + StringUtil.format("?res_cd={}&type={}",resGuid,type);
+		// 获取环境
+		String activeProfile = SpringContextUtil.getActiveProfile();
+		if (activeProfile.equals("dev")) {
+			url = LOCAL+ url ;
+		}
+		if (activeProfile.equals("prod")) {
+			url = ONLINE+ url ;
+		}
+		if (activeProfile.equals("test")) {
+			url = ONLINE + url;
+		}
+
+		HttpMethod method;
+			method = HttpMethod.GET;
+		// 声明一个header变量
+		HttpHeaders headers = new HttpHeaders();
+		// 设置apikey
+		headers.set("apikey",API_KEY);
+
+		HttpEntity<String> httpEntity = new HttpEntity(null, headers);
+		log.info("中台请求地址：{}", url);
+		RestTemplate template = new RestTemplate();
+		ResponseEntity<ZtResultPo2> ztResultPojoResponseEntity = template.exchange(url, method,httpEntity, ZtResultPo2.class,params);
+		List<BaseCd> returnResult = new ArrayList<>();
+		if (ztResultPojoResponseEntity.getStatusCodeValue() == 200) {
+			returnResult = ztResultPojoResponseEntity.getBody().getData();
+		}
+		return returnResult;
 	}
 
 	private List<DataResChildrenPo> getData(String url, String type, Map<String, Object> params) {
@@ -203,4 +244,41 @@
 		return null;
 	}
 
+	private List<ResDamMonitorResult> getResDamMonitorResult(String url, String type, Map<String, Object> params){
+
+		// 获取环境
+		String activeProfile = SpringContextUtil.getActiveProfile();
+		if (activeProfile.equals("dev")) {
+			url = LOCAL+ url ;
+		}
+		if (activeProfile.equals("prod")) {
+			url = ONLINE+ url ;
+		}
+		if (activeProfile.equals("test")) {
+			url = ONLINE + url;
+		}
+
+
+		HttpMethod method;
+		if (type.toLowerCase().equals("get".toLowerCase())) {
+			method = HttpMethod.GET;
+		} else {
+			method = HttpMethod.POST;
+		}
+		// 声明一个header变量
+		HttpHeaders headers = new HttpHeaders();
+		// 设置apikey
+		headers.set("apikey",API_KEY);
+
+		HttpEntity<String> httpEntity = new HttpEntity(null, headers);
+		log.info("中台请求地址：{}", url);
+		RestTemplate template = new RestTemplate();
+		ResponseEntity<ZtResult> ztResultPojoResponseEntity = template.exchange(url, method,httpEntity, ZtResult.class,params);
+		if (ztResultPojoResponseEntity.getStatusCodeValue() == 200) {
+			List<ResDamMonitorResult> resDamMonitorResultList = ztResultPojoResponseEntity.getBody().getResultList();
+			return resDamMonitorResultList;
+		}
+		return null;
+	}
+
 }

--
Gitblit v1.9.3