package com.landtool.lanbase.modules.sys.controller;

import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.function.BiConsumer;
import java.util.function.Consumer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.landtool.lanbase.common.utils.RedisUtils;
import com.landtool.lanbase.modules.sys.service.MonitorService;
import com.landtool.lanbase.modules.sys.service.impl.MonitorServiceImpl;

import oshi.SystemInfo;
import oshi.hardware.CentralProcessor;
import oshi.hardware.GlobalMemory;

@RequestMapping("/api/monitor")
@Controller
@CrossOrigin
public class SecModController {
	@Autowired
	private MonitorService monitor;

	@Autowired
	public RedisUtils redisUtils;


	/**
	 * 用户在线人数统计
	 */
	@RequestMapping("/onlineUser")
	public @ResponseBody String onlineUser() {
		ConcurrentHashMap<String, Double> info = redisUtils.get("onlineuser", ConcurrentHashMap.class);
		JSONObject json = new JSONObject();
		Map<String,Object> col=new HashMap<>();
		
		// 查询在线用户信息
		info.forEach(new BiConsumer<String, Double>() {

		
			@Override
			public void accept(String t, Double u) {
				col.put(t, new Date(u.longValue()) );
				
				
			}
		});
		json.put("count", col.size());
		json.put("onlineUser", col);
		return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
	}


	/**
	 *查询异常系统
	 */
	@RequestMapping("/queryErrorSystem")
	public @ResponseBody String queryErrorSystem(Integer page,Integer limit) {
		JSONObject json = new JSONObject();
		Map<String,Object> param=new HashMap<>();
		param.put("page", page);
		param.put("limit", limit);
		 List<Map> list=monitor.queryProblemSystem(param);
		json.put("count", list.size());
		json.put("errorsystem", list);
		return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
	}

	/**
	 * 查询用户访问行为
	 */
	@RequestMapping("/queryUserTrace")
	public @ResponseBody String queryUserTrace(String username,Integer page,Integer limit) {
		JSONObject json = new JSONObject();
		Map<String,Object> param=new HashMap<>();
		param.put("username",username);
		param.put("page", page);
		param.put("limit", limit);
		List<Map> list=monitor.queryUserTrace(param);
		json.put("total", list.size());
		json.put("data", list);
		return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
	}



	/**
	 * 用户在线人数查询
	 */
	@RequestMapping("/queryonlineUser")
	public @ResponseBody String queryonlineUser() {
   		if(!redisUtils.exists("onlineuser")){
			return "not exist";
		}else{	
		ConcurrentHashMap<String, Object> info = redisUtils.get("onlineuser", ConcurrentHashMap.class);
		ConcurrentHashMap<String, Object> vkinfo=new ConcurrentHashMap<>();
		List<String> list = new ArrayList<String>();
		Consumer<String> consumer = (str) -> {
		    JSONObject json=JSON.parseObject(info.get(str).toString());
		    vkinfo.put(json.getString("username"), json.getLong("time"));
			list.add(json.getString("username"));
		};
		info.forEachKey(info.size(), consumer);
		List<Map> personlist = new ArrayList<>();
		if(!list.isEmpty()){
		personlist = monitor.queryUsers(list);
		}
		JSONObject json = new JSONObject();
		// 查询在线用户信息
		json.put("count", info.size());
		personlist.forEach(new Consumer<Map>() {

			@Override
			public void accept(Map t) {
				/** modified by qufangxu**/
				Long times = (Long) vkinfo.get((String)t.get("loginname"));
				t.put("time", new Date(  times.longValue() ));
			}
		});
		json.put("onlineUser", personlist);
		return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
		}
	}
	
	
	/**
	 * 用户行为分析
	 */
	@RequestMapping("/analysisUser")
	public @ResponseBody String analysisUserAction(Integer userid,Integer day,String startdate,String enddate, String username) {
	    //分析
		Map<String,Object> map=new HashMap<String, Object>();
		map.put("day",day);
		map.put("startdate",startdate);
		map.put("enddate",enddate);
		map.put("userid",userid );
		map.put("username",username );
		List<Map> list=monitor.queryUserops(map);
		return JSONObject.toJSONString(list, SerializerFeature.WriteMapNullValue);
	}
	public String serverstatus() throws InterruptedException {
    	JSONObject json=new JSONObject();
    	json.put("cpuinfo", printlnCpuInfo());
    	json.put("meminfo", MemInfo());
		return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
    	
    }
    private static JSONObject printlnCpuInfo() throws InterruptedException {
        //map.put("----------------cpu信息----------------");
        SystemInfo systemInfo = new SystemInfo();
        CentralProcessor processor = systemInfo.getHardware().getProcessor();
        long[] prevTicks = processor.getSystemCpuLoadTicks();
        // 睡眠1s
        TimeUnit.SECONDS.sleep(1);
        long[] ticks = processor.getSystemCpuLoadTicks();
        long nice = ticks[CentralProcessor.TickType.NICE.getIndex()] - prevTicks[CentralProcessor.TickType.NICE.getIndex()];
        long irq = ticks[CentralProcessor.TickType.IRQ.getIndex()] - prevTicks[CentralProcessor.TickType.IRQ.getIndex()];
        long softirq = ticks[CentralProcessor.TickType.SOFTIRQ.getIndex()] - prevTicks[CentralProcessor.TickType.SOFTIRQ.getIndex()];
        long steal = ticks[CentralProcessor.TickType.STEAL.getIndex()] - prevTicks[CentralProcessor.TickType.STEAL.getIndex()];
        long cSys = ticks[CentralProcessor.TickType.SYSTEM.getIndex()] - prevTicks[CentralProcessor.TickType.SYSTEM.getIndex()];
        long user = ticks[CentralProcessor.TickType.USER.getIndex()] - prevTicks[CentralProcessor.TickType.USER.getIndex()];
        long iowait = ticks[CentralProcessor.TickType.IOWAIT.getIndex()] - prevTicks[CentralProcessor.TickType.IOWAIT.getIndex()];
        long idle = ticks[CentralProcessor.TickType.IDLE.getIndex()] - prevTicks[CentralProcessor.TickType.IDLE.getIndex()];
        long totalCpu = user + nice + cSys + idle + iowait + irq + softirq + steal;
        JSONObject map=new JSONObject();
      
    
        map.put("cpuCore", processor.getLogicalProcessorCount());
        map.put("cpuSysUsage", new DecimalFormat("#.##%").format(cSys * 1.0 / totalCpu));
        map.put("cpuUserUsage", new DecimalFormat("#.##%").format(user * 1.0 / totalCpu));
        map.put("cpuRtcWaitUsage", new DecimalFormat("#.##%").format(iowait * 1.0 / totalCpu));
        map.put("cpuRtcUseUsage", new DecimalFormat("#.##%").format(1.0-(idle * 1.0 / totalCpu)));
		return map;
    }

    public static JSONObject MemInfo(){
        JSONObject map=new JSONObject();
        SystemInfo systemInfo = new SystemInfo();
        GlobalMemory memory = systemInfo.getHardware().getMemory();
        //总内存
        long totalByte = memory.getTotal();
        //剩余
        long acaliableByte = memory.getAvailable();
        map.put("totalmem", formatByte(totalByte));
        map.put("use", formatByte(totalByte-acaliableByte));
        map.put("remainmem", formatByte(acaliableByte));
        map.put("usage", new DecimalFormat("#.##%").format((totalByte-acaliableByte)*1.0/totalByte));
		return map;
    }
    public static String formatByte(long byteNumber){
        //换算单位
        double FORMAT = 1024.0;
        double kbNumber = byteNumber/FORMAT;
        if(kbNumber<FORMAT){
            return new DecimalFormat("#.##KB").format(kbNumber);
        }
        double mbNumber = kbNumber/FORMAT;
        if(mbNumber<FORMAT){
            return new DecimalFormat("#.##MB").format(mbNumber);
        }
        double gbNumber = mbNumber/FORMAT;
        if(gbNumber<FORMAT){
            return new DecimalFormat("#.##GB").format(gbNumber);
        }
        double tbNumber = gbNumber/FORMAT;
        return new DecimalFormat("#.##TB").format(tbNumber);
    }

}