package com.landtool.lanbase.common;

import java.io.IOException;
import java.net.*;
import java.sql.Timestamp;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.Consumer;

import com.landtool.lanbase.common.utils.ShiroUtils;
import com.landtool.lanbase.modules.sys.entity.SysSystemProblemTrack;
import com.landtool.lanbase.modules.sys.entity.SysSysteminfo;
import com.landtool.lanbase.modules.sys.redis.OnlineUserRedis;
import com.landtool.lanbase.modules.sys.service.impl.MonitorServiceImpl;

import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.shiro.session.mgt.SessionManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.landtool.lanbase.config.WebSocketServer;
import com.landtool.lanbase.modules.sys.controller.SecModController;

@Component
@Configuration
@EnableScheduling
public class ScheduleTask {

	private  Logger log=LoggerFactory.getLogger(ScheduleTask.class);
	@Autowired
	public SecModController secModController;
	@Autowired
	public MonitorServiceImpl monitorService;
	@Autowired
	private OnlineUserRedis onlineUserRedis;
	
	@Scheduled(fixedRate=10*1000)
	public void	 pushMonitorInfo() throws InterruptedException {
		//人员在线状态
		String onlineUser=secModController.queryonlineUser();

		String serverinfo=secModController.serverstatus();
		String errorSystem=secModController.queryErrorSystem(null,null);
		//用户使用行为
		
		//服务资源状态
		
		//服务资源调用情况
		try {
			WebSocketServer.BroadCastInfo(onlineUser);
			WebSocketServer.BroadCastInfo(serverinfo);
			WebSocketServer.BroadCastInfo(errorSystem);
		
		} catch (IOException e) {
			log.error("WEBSOCKET PUSHH ERROR"+e.toString());
			e.printStackTrace();
		}
		
	}
	

//	@Scheduled(fixedRate=10*1000)
//	public void	 removeDownlineUser() throws InterruptedException {
//	//	onlineUserRedis.removeDownlineUser();
//	}
	

	@Scheduled(fixedRate=100*1000)
	public void	 checkSystemStatus() throws InterruptedException {
		Map<String,Object> map=new HashMap<>();
		List<SysSysteminfo> sysSysteminfos=monitorService.querySysSystemInfo(map);
        sysSysteminfos.forEach(new Consumer<SysSysteminfo>() {
			@Override
			public void accept(SysSysteminfo sysSysteminfo) {
				Socket s=new Socket();
				//ping通地址
				try {
					URI uri=new URI(sysSysteminfo.getSysaddress());
					SocketAddress add=new InetSocketAddress(uri.getHost(),uri.getPort()==-1?80:uri.getPort());
					s.connect(add,5000);
				} catch ( IOException e) {
					log.debug(sysSysteminfo.getSysaddress()+"服务异常"+e.getMessage());
					//此处更新系统状态记录表
					SysSystemProblemTrack sysSystemProblemTrack=new SysSystemProblemTrack();
					sysSystemProblemTrack.setAppid(sysSysteminfo.getAppid());
					sysSystemProblemTrack.setAddress(sysSysteminfo.getSysaddress());
					sysSystemProblemTrack.setStatus("fail");
					sysSystemProblemTrack.setCreatetime(Timestamp.valueOf(LocalDateTime.now()));
					sysSystemProblemTrack.setProblemreason("网络问题");
					monitorService.insertSystemProblem(sysSystemProblemTrack);

			
				} catch (URISyntaxException e) {
					e.printStackTrace();
				} finally {
					try {
						s.close();
					} catch (IOException e) {
						e.printStackTrace();
					}
				}

			}
		});

	}

	


//	@Scheduled(fixedRate=360*1000)
//	public void	 checkSystemStatus() throws InterruptedException {
//		Map<String,Object> map=new HashMap<>();
//		List<SysSysteminfo> sysSysteminfos=monitorService.querySysSystemInfo(map);
//		sysSysteminfos.forEach(new Consumer<SysSysteminfo>() {
//			@Override
//			public void accept(SysSysteminfo sysSysteminfo) {
//
//				//ping通地址
//				try {
//					URI uri=new URI(sysSysteminfo.getSysaddress());
//					CloseableHttpClient httpClient=HttpClients.createDefault();
//					HttpGet get=new HttpGet(sysSysteminfo.getSysaddress());
//					HttpResponse httpResponse=httpClient.execute(get);
//					if(httpResponse.getStatusLine().getStatusCode()!=200){
//						SysSystemProblemTrack sysSystemProblemTrack=new SysSystemProblemTrack();
//						sysSystemProblemTrack.setAppid(sysSysteminfo.getAppid());
//						sysSystemProblemTrack.setAddress(sysSysteminfo.getSysaddress());
//						sysSystemProblemTrack.setStatus("fail");
//						sysSystemProblemTrack.setProblemreason("网络问题:"+httpResponse.getStatusLine().getStatusCode()+httpResponse.getEntity().getContent());
//						monitorService.insertSystemProblem(sysSystemProblemTrack);
//					}
//				} catch ( IOException e) {
//					//此处更新系统状态记录
//					e.printStackTrace();
//				} catch (URISyntaxException e) {
//					e.printStackTrace();
//				} finally {
//					try {
//						s.close();
//					} catch (IOException e) {
//						e.printStackTrace();
//					}
//				}
//
//			}
//		});
//
//	}
}