package com.wgcloud.controller;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.wgcloud.config.CommonConfig;
import com.wgcloud.entity.HeathMonitor;
import com.wgcloud.entity.HeathState;
import com.wgcloud.service.HeathMonitorService;
import com.wgcloud.service.LogInfoService;
import com.wgcloud.util.ResDataUtils;
import com.wgcloud.util.TokenUtils;
import com.wgcloud.util.msg.WarnMailUtil;
import com.wgcloud.util.msg.WarnPools;
import com.wgcloud.util.staticvar.BatchData;
import com.wgcloud.util.staticvar.StaticKeys;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * @version v3.3
 * @ClassName:AgentHeathMonitorGoController.java
 * @author: http://www.wgstart.com
 * @date: 2022年9月16日
 * @Description: server-backup监控服务接口数据提交处理，默认每10分钟提交一次
 * @Copyright: 2019-2022 wgcloud. All rights reserved.
 */
@Controller
@RequestMapping("/agentHeathMonitorGo")
public class AgentHeathMonitorGoController {


    private static final Logger logger = LoggerFactory.getLogger(AgentHeathMonitorGoController.class);


    @Resource
    private LogInfoService logInfoService;
    @Autowired
    private HeathMonitorService heathMonitorService;
    @Autowired
    private TokenUtils tokenUtils;
    @Autowired
    private CommonConfig commonConfig;

    @ResponseBody
    @RequestMapping("/minTask")
    public String minTask(@RequestBody String paramBean) {
        JSONObject agentJsonObject = (JSONObject) JSONUtil.parse(paramBean);
        logger.debug("server-backup监控服务接口上报数据-------------" + agentJsonObject.toString());
        JSONObject resultJson = new JSONObject();
        if (!tokenUtils.checkAgentToken(agentJsonObject)) {
            logger.error(StaticKeys.TOKEN_ERROR);
            return ResDataUtils.resetErrorJson(StaticKeys.TOKEN_ERROR);
        }
        Date nowtime = new Date();

        try {
            //服务接口上报数据
            JSONArray heathMonitorsJsonArr = agentJsonObject.getJSONArray("heathMonitorsUpdate");
            if (heathMonitorsJsonArr == null) {
                logger.error("heathMonitorsUpdate is null");
                return ResDataUtils.resetErrorJson("heathMonitorsUpdate is null");
            }
            //处理数据源状态数据
            List<HeathMonitor> heathMonitorList = JSONUtil.toList(heathMonitorsJsonArr, HeathMonitor.class);
            for (HeathMonitor h : heathMonitorList) {
                //之前存贮的旧数据
                HeathMonitor heathMonitorSaved = heathMonitorService.selectById(h.getId());
                h.setCreateTime(nowtime);
                //接口下线后，不再更新时间 begin
                if (!StaticKeys.HEATH_STATUS_200.equals(h.getHeathStatus())) {
                    h.setCreateTime(null);
                }
                //接口下线后，不再更新时间 end
                try {
                    heathMonitorService.updateForServerBackup(h);
                } catch (Exception e) {
                    e.printStackTrace();
                }

                HeathState heathState = new HeathState();
                heathState.setResTimes(h.getResTimes());
                heathState.setHeathId(h.getId());
                heathState.setCreateTime(nowtime);
                BatchData.HEATH_STATE_LIST.add(heathState);
                heathMonitorSaved.setHeathStatus(h.getHeathStatus());
                if (!StaticKeys.HEATH_STATUS_200.equals(h.getHeathStatus())) {
                    //返回错误处理
                    WarnMailUtil.sendHeathInfo(heathMonitorSaved, true);
                } else {
                    //返回成功处理
                    if (null != WarnPools.MEM_WARN_MAP.get(h.getId())) {
                        WarnMailUtil.sendHeathInfo(heathMonitorSaved, false);
                    }
                }
            }

        } catch (Exception e) {
            logger.error("解析server-backup监控服务接口上报数据错误", e);
            return ResDataUtils.resetErrorJson(e.toString());
        }
        return ResDataUtils.resetSuccessJson(null);
    }


}