package com.dingzhuo.energy.project.reportForm.service.impl;

import com.dingzhuo.energy.project.common.CommonConst;
import com.dingzhuo.energy.project.common.StringUtil;
import com.dingzhuo.energy.project.reportForm.domain.reportSet;
import com.dingzhuo.energy.project.reportForm.domain.reportSetDataModel;
import com.dingzhuo.energy.project.reportForm.domain.reportSetRequestModel;
import com.dingzhuo.energy.project.reportForm.mapper.reportSetMapper;
import com.dingzhuo.energy.project.reportForm.service.IreportSetService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;

/**
 * stagseDataEntryService业务层处理
 *
 * @author sys
 * @date 2020-03-25
 */
@Service
public class reportSetServiceImpl implements IreportSetService {
    @Autowired
    private reportSetMapper reportSetMapper;

    /**
     * 获取上报设置列表
     *
     * @param requestModel 参数
     * @return
     */
    @Override
    public List<reportSet> listReportSet(reportSetRequestModel requestModel) {
        List<reportSet> models = reportSetMapper.listReportSet(requestModel.getNodeId(), requestModel.getIndexId());
        if (models.isEmpty()) {
            reportSet daySet = new reportSet();
            daySet.setDateType("DAY");
            daySet.setIndexId(requestModel.getIndexId());
            daySet.setNodeId(requestModel.getNodeId());
            models.add(daySet);
            reportSet monthSet = new reportSet();
            monthSet.setDateType("MONTH");
            monthSet.setIndexId(requestModel.getIndexId());
            monthSet.setNodeId(requestModel.getNodeId());
            models.add(monthSet);
        }
        for (reportSet model : models) {
            if ("DAY".equals(model.getDateType())) {
                model.setDateTypeShow("日");
            } else {
                model.setDateTypeShow("月");
            }
        }
        return models;
    }

    /**
     * 保存上报配置
     *
     * @param listMap
     */
    @Override
    public int saveReportSet(List<reportSet> listMap, String username) {
        if (!listMap.isEmpty()) {
            for (reportSet reportSet : listMap) {
                reportSet.setCreateBy(username);
                reportSet.setUpdateBy(username);
                reportSet.setId(UUID.randomUUID().toString());
            }
            reportSet rs = listMap.get(0);
            int delRes = reportSetMapper.deleteReportSetByNodeId(rs.getNodeId(), rs.getIndexId(), username);
            int res = reportSetMapper.saveReportSet(listMap);
        }

        return 1;
    }

    /**
     * 获取节点下的点位列表
     *
     * @param nodeId
     * @param indexType
     * @return
     */
    @Override
    public List<reportSetDataModel> listNodeIndex(String nodeId, String indexType) {
        List<reportSetDataModel> models = reportSetMapper.listNodeIndex(nodeId, indexType);
        List<reportSet> reportSetList = reportSetMapper.listNodeReportSet(nodeId);
        for (reportSetDataModel model : models) {
            reportSet rs = reportSetList.stream().filter(x -> StringUtil.ifEmptyOrNullReturnValue(x.getIndexId()).equals(model.getIndexId())).findAny().orElse(null);
            if (rs != null) {
                if (rs.getEnableLimitValue() != null) {
                    model.setEnableLimitValue(rs.getEnableLimitValue() == CommonConst.DIGIT_1);
                }
            }
        }
        return models;
    }

    /**
     * 设置该点位的限值启用状态
     *
     * @param nodeId
     * @param indexId
     * @param enableStatus 要设置的状态
     * @param username
     * @return
     */
    @Override
    public int updateEnableStatus(String nodeId, String indexId, boolean enableStatus, String username) {
        List<reportSet> models = reportSetMapper.listReportSet(nodeId, indexId);
        if(models.isEmpty()){
            return -1;
        }
        int intEnableStatus = enableStatus ? CommonConst.DIGIT_1 : CommonConst.DIGIT_0;
        return reportSetMapper.updateEnableStatus(nodeId, indexId, intEnableStatus, username);
    }
}