package com.ruoyi.project.mobile.service;


import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.pagehelper.util.StringUtil;
import com.ruoyi.common.constant.TrHiddenDangerCheckConstants;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.security.ShiroUtils;
import com.ruoyi.project.enumerate.TrRiskTypeEnum;
import com.ruoyi.project.mobile.domain.ApiRequestHeader;
import com.ruoyi.project.mobile.domain.ApiResult;
import com.ruoyi.project.system.user.domain.User;
import com.ruoyi.project.system.user.service.IUserService;
import com.ruoyi.project.tr.hiddenDangerCheck.domain.HiddenDangerCheck;
import com.ruoyi.project.tr.hiddenDangerCheck.service.IHiddenDangerCheckService;
import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.BaseCheckPointDTO;
import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.HiddenDangerCheckPoint;
import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.RiskCheckPointDTO;
import com.ruoyi.project.tr.hiddenDangerCheckPoint.service.IHiddenDangerCheckPointService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;


@Service
public class ApiDangerBaseService extends BaseApiService {

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

    @Autowired
    IHiddenDangerCheckService hiddenDangerCheckService;//隐患Service

    @Autowired
    IHiddenDangerCheckPointService hdcpService;//隐患检查点Service


    /**
     * 获取隐患排查的检查点
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult selectRiskCheckPointListByCheckId(String str, ApiRequestHeader header) {
        //验证userId,loginName,token,deviceType,deviceId,appType 是否一致
        ApiRequestHeader requestHeader = getHeader(header);
        if (!(header.equals(requestHeader))) {
            return ApiResult.errorToken("验证userId,loginName,token,deviceType,deviceId,appType 不一致");
        }
        try {
            Map<String, String> queryHiddenDangerCheck = new ObjectMapper().readValue(str, HashMap.class);
            String checkId = queryHiddenDangerCheck.get("checkId");//隐患排查ID
            String riskType = queryHiddenDangerCheck.get("riskType");///** 风险单元类型(1设备设置,2作业活动,3工艺节点 4.基础清单) */
            if (StringUtil.isEmpty(checkId)||StringUtil.isEmpty(riskType)) {
                return ApiResult.error("传输参数为空");
            } else {
                if(TrRiskTypeEnum.BASE.getCode().toString().equals(riskType)){
                    BaseCheckPointDTO baseCheckPointDTO = new BaseCheckPointDTO();
                    baseCheckPointDTO.setCheckId(Long.valueOf(checkId));
                    List<BaseCheckPointDTO> resultList = hdcpService.selectBaseCheckPointListByCheckId(baseCheckPointDTO);
                    return ApiResult.success("请求数据成功", resultList);
                }else if(TrRiskTypeEnum.DEVICE.getCode().toString().equals(riskType)||
                        TrRiskTypeEnum.WORK.getCode().toString().equals(riskType)||
                        TrRiskTypeEnum.CRAFTS.getCode().toString().equals(riskType)||
                        TrRiskTypeEnum.ROOM.getCode().toString().equals(riskType)){
                    RiskCheckPointDTO riskCheckPointDTO = new RiskCheckPointDTO();
                    riskCheckPointDTO.setCheckId(Long.valueOf(checkId));
                    List<RiskCheckPointDTO> resultList = hdcpService.selectRiskCheckPointListByCheckId(riskCheckPointDTO);
                    return ApiResult.success("请求数据成功", resultList);
                }else{
                    return ApiResult.error("传输riskType有误");
                }
            }
        } catch (Exception e) {
            return ApiResult.error("异常");
        }
    }




    /**
     * 获取隐患排查的检查点，并合并检查内容相同的行
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult selectRiskCheckPointListByCheckIdAndMergeSamePoint(String str, ApiRequestHeader header) {
        //验证userId,loginName,token,deviceType,deviceId,appType 是否一致
        ApiRequestHeader requestHeader = getHeader(header);
        if (!(header.equals(requestHeader))) {
            return ApiResult.errorToken("验证userId,loginName,token,deviceType,deviceId,appType 不一致");
        }
        try {
            Map<String, String> queryHiddenDangerCheck = new ObjectMapper().readValue(str, HashMap.class);
            String checkId = queryHiddenDangerCheck.get("checkId");//隐患排查ID
            String riskType = queryHiddenDangerCheck.get("riskType");///** 风险单元类型(1设备设置,2作业活动,3工艺节点 4.基础清单) */
            if (StringUtil.isEmpty(checkId) || StringUtil.isEmpty(riskType)) {
                return ApiResult.error("传输参数为空");
            } else {
                if (TrRiskTypeEnum.BASE.getCode().toString().equals(riskType)) {
                    BaseCheckPointDTO baseCheckPointDTO = new BaseCheckPointDTO();
                    baseCheckPointDTO.setCheckId(Long.valueOf(checkId));
                    List<BaseCheckPointDTO> list = hdcpService.selectBaseCheckPointListByCheckId(baseCheckPointDTO);

                    List<BaseCheckPointDTO> listLast = new ArrayList<>();
                    Set<Long> checkPointIds = new HashSet<Long>();
                    for (int i = 0; i < list.size(); i++) {
                        if ("0".equals(list.get(i).getWhetherDanger())) {
                            listLast.add(list.get(i));
                            checkPointIds.add(list.get(i).getCheckPointId());
                        } else if ("1".equals(list.get(i).getWhetherDanger())) {
                            if (checkPointIds.contains(list.get(i).getCheckPointId())) {
                                for (int a = 0; a < listLast.size(); a++) {
                                    BaseCheckPointDTO baseCheckPointDTOTemp = listLast.get(a);
                                    if ((list.get(i).getCheckPointId()).equals(baseCheckPointDTOTemp.getCheckPointId())) {
                                        List<Long> hiddenDangerCheckPointIds = listLast.get(a).getHiddenDangerCheckPointIds();
                                        hiddenDangerCheckPointIds.add(list.get(i).getId());
                                        listLast.get(a).setHiddenDangerCheckPointIds(hiddenDangerCheckPointIds);
                                        break;
                                    }
                                }
                            } else {
                                List<Long> hiddenDangerCheckPointIds = new ArrayList<>();
                                hiddenDangerCheckPointIds.add(list.get(i).getId());
                                list.get(i).setHiddenDangerCheckPointIds(hiddenDangerCheckPointIds);
                                listLast.add(list.get(i));
                                checkPointIds.add(list.get(i).getCheckPointId());
                            }
                        } else {
                            listLast.add(list.get(i));
                            checkPointIds.add(list.get(i).getCheckPointId());
                        }
                    }

                    return ApiResult.success("请求数据成功", listLast);
                } else if (TrRiskTypeEnum.DEVICE.getCode().toString().equals(riskType) ||
                        TrRiskTypeEnum.WORK.getCode().toString().equals(riskType) ||
                        TrRiskTypeEnum.CRAFTS.getCode().toString().equals(riskType) ||
                        TrRiskTypeEnum.ROOM.getCode().toString().equals(riskType)) {
                    RiskCheckPointDTO riskCheckPointDTO = new RiskCheckPointDTO();
                    riskCheckPointDTO.setCheckId(Long.valueOf(checkId));
                    List<RiskCheckPointDTO> list = hdcpService.selectRiskCheckPointListByCheckId(riskCheckPointDTO);

                    List<RiskCheckPointDTO> listLast = new ArrayList<>();
                    Set<Long> checkPointIds = new HashSet<Long>();
                    for (int i = 0; i < list.size(); i++) {
                        if ("0".equals(list.get(i).getWhetherDanger())) {
                            listLast.add(list.get(i));
                            checkPointIds.add(list.get(i).getCheckPointId());
                        } else if ("1".equals(list.get(i).getWhetherDanger())) {
                            if (checkPointIds.contains(list.get(i).getCheckPointId())) {
                                for (int a = 0; a < listLast.size(); a++) {
                                    RiskCheckPointDTO riskCheckPointDTOTemp = listLast.get(a);
                                    if ((list.get(i).getCheckPointId()).equals(riskCheckPointDTOTemp.getCheckPointId())) {
                                        List<Long> hiddenDangerCheckPointIds = listLast.get(a).getHiddenDangerCheckPointIds();
                                        hiddenDangerCheckPointIds.add(list.get(i).getId());
                                        listLast.get(a).setHiddenDangerCheckPointIds(hiddenDangerCheckPointIds);
                                        break;
                                    }
                                }
                            } else {
                                List<Long> hiddenDangerCheckPointIds = new ArrayList<>();
                                hiddenDangerCheckPointIds.add(list.get(i).getId());
                                list.get(i).setHiddenDangerCheckPointIds(hiddenDangerCheckPointIds);
                                listLast.add(list.get(i));
                                checkPointIds.add(list.get(i).getCheckPointId());
                            }
                        } else {
                            listLast.add(list.get(i));
                            checkPointIds.add(list.get(i).getCheckPointId());
                        }
                    }

                    return ApiResult.success("请求数据成功", listLast);
                } else {
                    return ApiResult.error("传输riskType有误");
                }
            }
        } catch (Exception e) {
            return ApiResult.error("异常");
        }
    }


}