package com.ruoyi.dataInterchange.util.haikang;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hikvision.artemis.sdk.ArtemisHttpUtil;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import com.ruoyi.dataInterchange.util.haikang.model.EventSubscriptionByEventTypesRequest;
import com.ruoyi.dataInterchange.util.haikang.model.EventSubscriptionViewRequest;
import com.ruoyi.dataInterchange.util.haikang.model.EventUnSubscriptionByEventTypesRequest;
import lombok.extern.slf4j.Slf4j;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 事件订阅工具类
 * @author zhibing.pu
 * @Date 2025/5/20 16:17
 */
@Slf4j
@WebListener
public class Artemis implements ServletContextListener {
	
	/**
	 * STEP2：设置OpenAPI接口的上下文
	 */
	private static final String ARTEMIS_PATH = "/artemis";
	/**
	 * STEP1：设置平台参数，根据实际情况,设置host appkey appsecret 三个参数.
	 *
	 * ip:port : 平台门户/nginx的IP和端口（必须使用https协议，https端口默认为443）
	 * appKey : 请填入appKey
	 * appSecret : 请填入appSecret
	 */
	private static ArtemisConfig artemisConfig = new ArtemisConfig("112.18.106.230:443", "27273246", "vjvZA7X4hHUc0SbONht9");
	
	//按事件类型取消订阅
	public static String eventUnSubscriptionByEventTypes(EventUnSubscriptionByEventTypesRequest eventUnSubscriptionByEventTypesRequest) throws Exception {
		String eventUnSubscriptionByEventTypesDataApi = ARTEMIS_PATH +"/api/eventService/v1/eventUnSubscriptionByEventTypes";
		Map<String,String> path = new HashMap<String,String>(2){
			{
				put("https://",eventUnSubscriptionByEventTypesDataApi);
			}
		};
		String body= JSON.toJSONString(eventUnSubscriptionByEventTypesRequest);
		String result =ArtemisHttpUtil.doPostStringArtemis(artemisConfig,path,body,null,null,"application/json");
		return result;
	}
	
	@Override
	public void contextInitialized(ServletContextEvent sce) {
		try {
			//先查询是否订阅事件
			EventSubscriptionViewRequest eventSubscriptionViewRequest = new EventSubscriptionViewRequest();
			eventSubscriptionViewRequest.setSubWay(1);
			String eventSubscriptionView = Artemis.eventSubscriptionView(eventSubscriptionViewRequest);
			JSONObject jsonObject = JSON.parseObject(eventSubscriptionView);
			String code = jsonObject.getString("code");
			if("200".equals(code)){
				JSONArray jsonArray = jsonObject.getJSONObject("data").getJSONArray("detail");
				List<String> list = new ArrayList<>();
				for (int i = 0; i < jsonArray.size(); i++) {
					JSONArray eventTypes = jsonArray.getJSONObject(i).getJSONArray("eventTypes");
					eventTypes.forEach(eventType -> {
						list.add(eventType.toString());
					});
				}
				//告警事件类型
				if(!list.contains("5201154049")){
					//订阅事件
					EventSubscriptionByEventTypesRequest eventSubscriptionByEventTypesRequest = new EventSubscriptionByEventTypesRequest();
					eventSubscriptionByEventTypesRequest.setSubWay(1);
					eventSubscriptionByEventTypesRequest.setEventDest("http://221.182.45.100:1000/dataInterchange/warnMsgAdptInfo/alarmNotice");
					eventSubscriptionByEventTypesRequest.setEventTypes(new ArrayList<String>(){{
						add("5201154049");
					}});
					String subscription = Artemis.eventSubscriptionByEventTypes(eventSubscriptionByEventTypesRequest);
					jsonObject = JSON.parseObject(subscription);
					code = jsonObject.getString("code");
					if(!"200".equals(code)){
						log.error("告警事件订阅失败");
					}else {
						log.info("告警事件订阅成功");
					}
				}
			}else{
				log.error("查询事件订阅信息失败");
			}
		}catch (Exception e){
			e.printStackTrace();
		}
	}
	
	//查询事件订阅信息
	public static String eventSubscriptionView(EventSubscriptionViewRequest eventSubscriptionViewRequest) throws Exception {
		String eventSubscriptionViewDataApi = ARTEMIS_PATH +"/api/eventService/v1/eventSubscriptionView";
		Map<String,String> path = new HashMap<String,String>(2){
			{
				put("https://",eventSubscriptionViewDataApi);
			}
		};
		String body=JSON.toJSONString(eventSubscriptionViewRequest);
		String result =ArtemisHttpUtil.doPostStringArtemis(artemisConfig,path,body,null,null,"application/json");
		return result;
	}
	
	//按事件类型订阅事件
	public static String eventSubscriptionByEventTypes(EventSubscriptionByEventTypesRequest eventSubscriptionByEventTypesRequest) throws Exception {
		String eventSubscriptionByEventTypesDataApi = ARTEMIS_PATH +"/api/eventService/v1/eventSubscriptionByEventTypes";
		Map<String,String> path = new HashMap<String,String>(2){
			{
				put("https://",eventSubscriptionByEventTypesDataApi);
			}
		};
		String body=JSON.toJSONString(eventSubscriptionByEventTypesRequest);
		String result = ArtemisHttpUtil.doPostStringArtemis(artemisConfig,path,body,null,null,"application/json");
		return result;
	}
	
	@Override
	public void contextDestroyed(ServletContextEvent sce) {
	
	}
}