/**
 * Copyright (c) 2020 ucsmy.com, All rights reserved.
 */
package com.ruoyi.project.mobile.service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.security.ShiroUtils;
import com.ruoyi.framework.web.service.JpushService;
import com.ruoyi.project.mobile.domain.ApiRequestHeader;
import com.ruoyi.project.mobile.domain.ApiResult;
import com.ruoyi.project.system.company.domain.Company;
import com.ruoyi.project.system.company.service.ICompanyService;
import com.ruoyi.project.system.dept.domain.Dept;
import com.ruoyi.project.system.dept.service.IDeptService;
import com.ruoyi.project.system.notice.domain.Notice;
import com.ruoyi.project.system.notice.mapper.NoticeMapper;
import com.ruoyi.project.system.notice.service.INoticeService;
import com.ruoyi.project.system.role.service.IRoleService;
import com.ruoyi.project.system.user.domain.User;
import com.ruoyi.project.system.user.service.IUserService;
import com.ruoyi.project.tr.dataStatistics.domain.DataStatistics;
import com.ruoyi.project.tr.hiddenTroubleType.domain.HiddenTroubleType;
import com.ruoyi.project.tr.hiddenTroubleType.service.IHiddenTroubleTypeService;
import com.ruoyi.project.tr.region.domain.Region;
import com.ruoyi.project.tr.region.service.IRegionService;
import com.ruoyi.project.tr.report.service.ReportService;
import com.ruoyi.project.tr.riskCheckPoint.domain.RiskCheckPoint;
import com.ruoyi.project.tr.riskCheckPoint.service.IRiskCheckPointService;
import com.ruoyi.project.tr.riskEvaluationPlan.domain.RiskEvaluationPlan;
import com.ruoyi.project.tr.riskEvaluationPlan.service.IRiskEvaluationPlanService;
import com.ruoyi.project.tr.riskList.domain.RiskList;
import com.ruoyi.project.tr.riskList.service.IRiskListService;
import com.ruoyi.project.tr.slideshowPic.domain.SlideshowPic;
import com.ruoyi.project.tr.slideshowPic.service.ISlideshowPicService;
import com.ruoyi.project.tr.troubleshootType.domain.TroubleshootType;
import com.ruoyi.project.tr.troubleshootType.service.ITroubleshootTypeService;
import com.ruoyi.project.tr.versionControl.domain.VersionControl;
import com.ruoyi.project.tr.versionControl.service.IVersionControlService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.ui.ModelMap;

import java.lang.reflect.Type;
import java.util.*;

/**
 * @Description:用于风险评估的前端方法,
 * @Author: Administrator
 * @Created Date: 2020年05月15日
 * @LastModifyDate:
 * @LastModifyBy:
 * @Version:
 */
@Service
public class ApiBaseService extends BaseApiService {

    @Autowired
    private IUserService userService;

    @Autowired
    private IDeptService deptService;

    @Autowired
    private IRegionService regionService;

    @Autowired
    private IRiskListService riskListService;

    @Autowired
    private IHiddenTroubleTypeService hiddenTroubleTypeService;

    @Autowired
    private ITroubleshootTypeService troubleshootTypeService;

    @Autowired
    private IRiskEvaluationPlanService riskEvaluationPlanService;

    @Autowired
    private IRiskCheckPointService riskCheckPointService;


    @Autowired
    private INoticeService noticeService;
    @Autowired
    private NoticeMapper noticeMapper;

    @Autowired
    private IVersionControlService versionControlService;

    @Autowired
    private ReportService reportService;

    @Autowired
    private ICompanyService companyService;

    @Autowired
    private ISlideshowPicService slideshowPicService;

    @Autowired
    private IRoleService roleService;


    @Autowired
    JpushService jpushService;

    /**
     * 根据公司id 获取用户信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getUserListByCompanyId(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 {
            JSONObject parseObject = JSONObject.parseObject(str);

            Long companyId = parseObject.getLong("companyId");

            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }

            String userName = parseObject.getString("userName");

            User u = new User();
            u.setCompanyId(companyId);
            if (!StringUtils.isEmpty(userName)) {
                u.setUserName(userName);
            }
            List<User> userList = userService.selectUserList(u);

            return ApiResult.success("查询成功", userList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 根据公司id 获取用户信息(如果是总公司或分公司账号，则可以查询所有成员)
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getParentAndSonUserListByCompanyId(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 {
            JSONObject parseObject = JSONObject.parseObject(str);
            Long companyId = parseObject.getLong("companyId");
            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }
            Company company = companyService.selectCompanyById(companyId);
            List<Company> companyList = new ArrayList<>();
            if (companyId != null && companyId != 0L && companyId != -1L && company != null) {
                if (company.getParentId() == 0L) {
                    companyList.add(company);
                    //查询是否存在子公司
                    Company sonQuery = new Company();
                    sonQuery.setParentId(companyId);
                    List<Company> sonList = companyService.selectCompanyList(sonQuery);
                    if (sonList.size() == 0) {

                    } else {
                        companyList.addAll(sonList);
                    }
                } else {
                    Company companyParent = companyService.selectCompanyById(company.getParentId());
                    companyList.add(companyParent);
                    //查询是否存在子公司
                    Company sonQuery = new Company();
                    sonQuery.setParentId(companyParent.getCompanyId());
                    List<Company> sonList = companyService.selectCompanyList(sonQuery);
                    companyList.addAll(sonList);
                }
            }
            String userName = parseObject.getString("userName");

            List<Long> companyIdList = new ArrayList<>();
            for (Company c : companyList) {
                companyIdList.add(c.getCompanyId());
            }
            User u = new User();
            u.setCompanyIdList(companyIdList);
            if (!StringUtils.isEmpty(userName)) {
                u.setUserName(userName);
            }
            List<User> userList = userService.selectUserList(u);
            return ApiResult.success("查询成功", userList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 根据公司id 获取部门信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getDeptListByCompanyId(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 {
            JSONObject parseObject = JSONObject.parseObject(str);

            Long companyId = parseObject.getLong("companyId");

            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }

            User u = new User();
            u.setCompanyId(companyId);
            List<Dept> deptList = deptService.selectDeptListByCompanyId(companyId);

            return ApiResult.success("查询成功", deptList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 根据公司id 获取区域信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getRegionListByCompanyId(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 {
            JSONObject parseObject = JSONObject.parseObject(str);
            Long companyId = parseObject.getLong("companyId");
            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }
            List<Region> regionList = regionService.selectRegionListByCompanyId(companyId);
            return ApiResult.success("查询成功", regionList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 根据公司id和风险单元类型,获取风险信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getRiskListByCompanyIdAndType(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 {
            RiskList risk = new RiskList();


            JSONObject parseObject = JSONObject.parseObject(str);

            Long companyId = parseObject.getLong("companyId");

            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }
            risk.setCompanyId(companyId);

            Integer type = parseObject.getInteger("type");
            if (type == null) {
                return ApiResult.error("风险单元类型不能为空");
            }
            risk.setRiskType(type);

            List<RiskList> riskList = riskListService.selectRiskListList(risk);

            return ApiResult.success("查询成功", riskList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 获取隐患类别基本设置
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getHiddenTroubleTypeByCompanyId(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 {
            HiddenTroubleType hiddenTroubleType = new HiddenTroubleType();


            JSONObject parseObject = JSONObject.parseObject(str);

            Long companyId = parseObject.getLong("companyId");

            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }
            hiddenTroubleType.setCompanyId(companyId);

            List<HiddenTroubleType> hiddenTroubleTypeList = hiddenTroubleTypeService.selectHiddenTroubleTypeList(hiddenTroubleType);

            return ApiResult.success("查询成功", hiddenTroubleTypeList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 获取排查类型基本设置
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getTroubleShootTypeByCompanyId(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 {
            TroubleshootType troubleshootType = new TroubleshootType();


            JSONObject parseObject = JSONObject.parseObject(str);

            Long companyId = parseObject.getLong("companyId");

            if (companyId == null) {
                return ApiResult.error("公司ID不能为空!");
            }
//            troubleshootType.setCompanyId(companyId);

            List<TroubleshootType> hiddenTroubleTypeList = troubleshootTypeService.selectTroubleshootTypeList(troubleshootType);

            return ApiResult.success("查询成功", hiddenTroubleTypeList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 根据检查点id,返回这条检查点 最近此一次的评价计划,对应的检查点
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getCheckPointByRiskId(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 {
            JSONObject parseObject = JSONObject.parseObject(str);

            Long riskId = parseObject.getLong("riskId");
            if (riskId == null) {
                return ApiResult.error("riskId不能为空!");
            }

            RiskList risk = riskListService.selectRiskListById(riskId);

            if (risk == null) {
                return ApiResult.error("未查到该风险单元!");
            }

            //查询该风险单元最近的评价计划
            RiskEvaluationPlan plan = riskEvaluationPlanService.getRiskEvaluationPlanByRecent(riskId);
            if (plan == null) {
                return ApiResult.error("该风险单元未评价!");
            }

            RiskCheckPoint checkPoint = new RiskCheckPoint();
            checkPoint.setPlanId(plan.getPlanId());

            List<RiskCheckPoint> checkPointList = riskCheckPointService.selectRiskCheckPointList(checkPoint);

            return ApiResult.success("查询成功", checkPointList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    /**
     * 获取最新一条公告
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getNewNotice(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 {
            Notice notice = new Notice();
            notice.setStatus("0");
            notice.setPublishStatus("已发布");
            List<Notice> noticeList = noticeService.selectNoticeList(notice);

            if (noticeList.size() > 0) {
                return ApiResult.success("查询成功", noticeList.get(0));
            } else {
                return ApiResult.success("查询成功", new Notice());
            }

        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    //获取全部公告
    public ApiResult getAllNotice(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 {
            Set<String> stringSet = roleService.selectRoleKeys(Long.valueOf(header.userId));
            Notice notice = new Notice();
            if (stringSet.contains("straightRegionUser")) {

            } else {
                notice.setPublishStatus("已发布");
            }
            notice.setStatus("0");
            List<Notice> noticeList = noticeService.selectNoticeList(notice);
            return ApiResult.success("查询公告成功", noticeList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    //新增公告
    public ApiResult addNotice(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 {
            Notice notice = new ObjectMapper().readValue(str, Notice.class);
            if (StringUtils.isEmpty(notice.getNoticeTitle())) {
                return ApiResult.error("公告标题不能为空");
            }
            if (StringUtils.isEmpty(notice.getNoticeContent())) {
                return ApiResult.error("公告内容不能为空");
            }
//            notice.setPublishStatus("未发布");
            notice.setPublishStatus("已发布");
            notice.setStatus("0");
            notice.setCreateBy(header.loginName);

            int i = noticeMapper.insertNotice(notice);

            //大文本通知栏样式
            Map<String, String> extrasMap = new HashMap<String, String>();
            extrasMap.put("message", "这是一个公告通知");
            extrasMap.put("methodType", "goToNotice");
            extrasMap.put("notice", JSONObject.toJSONString(notice));
            jpushService.pushAll(notice.getNoticeTitle(), notice.getNoticeContent(), 1, notice.getNoticeContent(), extrasMap);

            return ApiResult.success("新增公告成功", notice);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    //修改公告
    public ApiResult updateNotice(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 {
            Notice notice = new ObjectMapper().readValue(str, Notice.class);
            if (StringUtils.isEmpty(notice.getNoticeTitle())) {
                return ApiResult.error("公告标题不能为空");
            }
            if (StringUtils.isEmpty(notice.getNoticeContent())) {
                return ApiResult.error("公告内容不能为空");
            }
            notice.setUpdateBy(header.loginName);
            int i = noticeMapper.updateNotice(notice);
            return ApiResult.success("修改公告成功", notice);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    //发布公告
    public ApiResult publishNotice(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 {
            Notice notice = new ObjectMapper().readValue(str, Notice.class);
            if (notice.getNoticeId() == null) {
                return ApiResult.error("公告id不能为空");
            }
            notice.setPublishStatus("已发布");
            notice.setUpdateBy(header.loginName);
            int i = noticeMapper.updateNotice(notice);
            return ApiResult.success("发布公告成功", notice);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }


    //删除公告
    public ApiResult deleteNotice(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 {
            Notice notice = new ObjectMapper().readValue(str, Notice.class);
            if (notice.getNoticeId() == null) {
                return ApiResult.error("公告id不能为空");
            }
            int i = noticeService.deleteNoticeByIds(notice.getNoticeId().toString());
            return ApiResult.success("删除公告成功", i);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 获取所用的安卓版本
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getAllVersionControl(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 {
            List<VersionControl> versionControlList = versionControlService.selectVersionControlList(new VersionControl());

            return ApiResult.success("查询成功", versionControlList);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 获取公示页面头部信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getPublicityHeadData(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 {
            JSONObject parseObject = JSONObject.parseObject(str);
            Long userId = parseObject.getLong("userId");
            if (userId != null) {
                User user = userService.selectUserById(userId);
                if (user == null) {
                    return ApiResult.error("未找到该用户!");
                }
                ModelMap modelMap = new ModelMap();
                reportService.selectPublicityHeadData(user.getCompanyId(), modelMap);
                return ApiResult.success("查询成功", modelMap);
            } else {
                return ApiResult.error("userId不能为空!");
            }
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 获取公司信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getCompanyInfo(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 {
            JSONObject parseObject = JSONObject.parseObject(str);
            Long userId = parseObject.getLong("userId");
            if (userId != null) {
                User user = userService.selectUserById(userId);
                if (user == null) {
                    return ApiResult.error("未找到该用户!");
                }
                Company company = companyService.selectCompanyById(user.getCompanyId());
                return ApiResult.success("查询成功", company);
            } else {
                return ApiResult.error("userId不能为空!");
            }
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }

    /**
     * 查询轮播图信息
     *
     * @param str
     * @param header
     * @return
     */
    public ApiResult getSlideshowPic(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 {
            List<SlideshowPic> slideshowPics = slideshowPicService.selectSlideshowPicList(new SlideshowPic());
            List<String> list = new ArrayList<>();
            if (slideshowPics != null && slideshowPics.size() != 0) {
                for (int i = 0; i < slideshowPics.size(); i++) {
                    if (slideshowPics.get(i) != null && StringUtils.isNotEmpty(slideshowPics.get(i).getPicUrl())) {
                        list.add(slideshowPics.get(i).getPicUrl());
                    }
                }
            }
            return ApiResult.success("查询成功", list);
        } catch (Exception ex) {
            ApiResult.error("异常");
        }
        return ApiResult.error("异常");
    }
}