package com.wgcloud.service;

import com.wgcloud.entity.*;
import com.wgcloud.util.DateUtil;
import com.wgcloud.util.FormatUtil;
import com.wgcloud.util.HostUtil;
import com.wgcloud.util.staticvar.StaticKeys;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @version v3.3
 * @ClassName:TaskUtilService.java
 * @author: http://www.wgstart.com
 * @date: 2021年4月19日
 * @Description: 任务数据处理辅助service
 * @Copyright: 2019-2021 wgcloud. All rights reserved.
 */
@Service
public class TaskUtilService {

    private Logger logger = LoggerFactory.getLogger(TaskUtilService.class);

    @Autowired
    SystemInfoService systemInfoService;
    @Autowired
    AppInfoService appInfoService;
    @Autowired
    DockerInfoService dockerInfoService;
    @Autowired
    PortInfoService portInfoService;
    @Autowired
    DiskStateService diskStateService;

    /**
     * 清理历史数据过程中，将主机、端口、进程、docker的更新时间刷新为当前时间
     *
     * @throws Exception
     */
    @Transactional
    public void refreshCommitDate() throws Exception {
        Date nowDate = DateUtil.getNowTime();
        logger.info("刷新监控数据更新时间：" + nowDate);
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("state", StaticKeys.ON_STATE);
        List<SystemInfo> systemInfolist = systemInfoService.selectAllByParams(params);
        for (SystemInfo systemInfo : systemInfolist) {
            systemInfo.setCreateTime(nowDate);
        }
        systemInfoService.updateRecord(systemInfolist);//更新
    }


    /**
     * 获取所有磁盘总容量之和，转为G 或 T
     *
     * @return
     * @throws Exception
     */
    public String sumDiskSizeCache(HttpServletRequest request) throws Exception {
        Map<String, Object> params = new HashMap<String, Object>();

        //校验是否添加过滤用户查询条件
        HostUtil.addAccountquery(request, params);

        //监控主机所有磁盘
        List<DiskState> deskStateList = diskStateService.selectAllByParams(params);
        BigDecimal sumSize = new BigDecimal(0);
        for (DiskState deskState : deskStateList) {
            if (!StringUtils.isEmpty(deskState.getDiskSize())) {
                try {
                    sumSize = sumSize.add(new BigDecimal(deskState.getDiskSize().replace("G", "")));
                } catch (Exception e) {
                    logger.error("double类型转换错误：", e);
                }
            }
        }
        String sumSizeStr = String.valueOf(sumSize);
        if (sumSizeStr.indexOf(".") > 0) {
            sumSizeStr = sumSizeStr.substring(0, sumSizeStr.lastIndexOf("."));
        }
        return FormatUtil.gToT(sumSizeStr);
    }


}