package com.thhy.secure.modules.biz.train.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.github.pagehelper.util.StringUtil;
import com.thhy.general.common.BasicResult;
import com.thhy.general.config.SysUserInfo;
import com.thhy.general.utils.UserInfoUtils;
import com.thhy.secure.modules.biz.encourage.mapper.TEncourageMapper;
import com.thhy.secure.modules.biz.file.service.FileService;
import com.thhy.secure.modules.biz.train.entity.OpenUserInfo;
import com.thhy.secure.modules.biz.train.entity.TSecureTrain;
import com.thhy.secure.modules.biz.train.entity.dto.*;
import com.thhy.secure.modules.biz.train.mapper.TSecureTrainMapper;
import com.thhy.secure.modules.biz.train.service.TSecureTrainService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

@Service
public class TSecureTrainServiceImpl implements TSecureTrainService {

    @Resource
    private TSecureTrainMapper secureTrainMapper;

    @Resource
    private FileService fileService;
    @Resource
    private TEncourageMapper encourageMapper;

    @Override
    public BasicResult secureTrainInsert(Map<String, Object> values) {
        System.out.println("请求-----------------");
        System.out.println(values);
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String companyId = sysUserInfo.getCompanyId();

        values.put("companyId",companyId);

        values.put("secureId","");
        secureTrainMapper.secureTrainInsert(values);
        //文件
        String secureId = values.get("secureId").toString();
        List<String> files = (List<String>) values.get("files");
        for (String file :files){
            HashMap<String, Object> hashMap = new HashMap<>();
            hashMap.put("securePathId","");
            hashMap.put("securePathVideo",file);
            hashMap.put("secureId",secureId);
            secureTrainMapper.secureTrainPathInsert(hashMap);
        }
        return BasicResult.success("添加成功");
    }

    @Override
    public BasicResult secureTrainList(Map<String, Object> values) {
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String companyId = sysUserInfo.getCompanyId();
        values.put("companyId",companyId);
        Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
        Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
        PageHelper.startPage(pageNum,pageSize);
        List<TSecureTrain> tSecureTrains= secureTrainMapper.secureTrainList(values);
        System.out.println("-----------"+tSecureTrains.size());
        if(!CollectionUtils.isEmpty(tSecureTrains)){
            tSecureTrains.stream().forEach(st->{
                System.out.println("----"+st);
                String totals= secureTrainMapper.totalsSum(st.getSecureId(),companyId);
                String completes= secureTrainMapper.completesSum(st.getSecureId());
                if(!StringUtil.isEmpty(totals)){
                    st.setTotals(totals);
                }else {
                    st.setTotals("0");
                }
                if(!StringUtil.isEmpty(completes)){
                    st.setCompletes(completes);
                }else {
                    st.setCompletes("0");
                }
            });
        }
        PageInfo<TSecureTrain> tSecureTrainPageInfo = new PageInfo<>(tSecureTrains);
        return BasicResult.success(tSecureTrainPageInfo);
    }

    @Override
    public BasicResult secureTrainInfo(Map<String, Object> values) {
        //安全培训id
        String secureId = values.get("secureId").toString();
        SecureTrainDto trainDto = secureTrainMapper.secureTrainInfo(secureId);
        List<SecurePathDto> pathDtos = secureTrainMapper.securePath(secureId);
        pathDtos.stream().forEach(fl->{
            JSONObject json = new JSONObject();
            json.put("fullpath",fl.getSecurePathVideo());
            BasicResult basicResult = fileService.fileinfo(json.toJSONString());
            if(basicResult.isSuccess()){
                JSONArray jsonArray = JSONArray.parseArray(basicResult.getData().toString());
                for(Object obj : jsonArray){
                    JSONObject j = JSON.parseObject(obj.toString());
                    if(j.containsKey("name")&&"name".equals(j.getString("name"))){
                        fl.setSecurePathVideoName(j.getString("value"));
                    }
                }
            }
        });
        trainDto.setSecurePathDtos(pathDtos);
        List<SecureGroupDto> groupDtos = secureTrainMapper.secureGroup(secureId);
        trainDto.setSecureGroupDtos(groupDtos);
        return BasicResult.success(trainDto);
    }

    @Override
    public BasicResult secureTrainPull(Map<String, Object> values) {
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String companyId = sysUserInfo.getCompanyId();
        values.put("companyId",companyId);
        List<SecureTrainDto> secureTrainDtos = secureTrainMapper.secureTrainPull(values);
        return BasicResult.success(secureTrainDtos);
    }

    @Override
    public BasicResult secureTrainDel(Map<String, Object> values) {
        String secureId = values.get("secureId").toString();
        secureTrainMapper.secureTrainDel(secureId);
        return BasicResult.success("删除成功");
    }

    @Override
    public BasicResult secureTrainRecord(Map<String, Object> values) {

        String secureId = values.get("secureId").toString();
        Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
        Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
        PageHelper.startPage(pageNum,pageSize);
        List<SecureGroupUserDto> secureGroupUserDtos =secureTrainMapper.secureTrainRecord(values);
        PageInfo<SecureGroupUserDto> secureGroupUserDtoPageInfo = new PageInfo<>(secureGroupUserDtos);
        return BasicResult.success(secureGroupUserDtoPageInfo);
    }

    @Override
    @Transactional
    public BasicResult secureTrainUpdate(Map<String, Object> values) {
        String secureId = values.get("secureId").toString();

        secureTrainMapper.secureTrainGroupDel(secureId);
        //业务改动 ：  班组 改为岗位
        List<String> groupIds = (List<String>) values.get("groupIds");
        if(groupIds!=null&&groupIds.size()>0){
            for (String groupId : groupIds){
                HashMap<String, Object> hashMap = new HashMap<>();
                hashMap.put("groupId",groupId);
                hashMap.put("secureId",secureId);
                hashMap.put("secureGroupId","");
                secureTrainMapper.secureTrainGroupInsert(hashMap);
            }
        }
        secureTrainMapper.secureTrainPathDel(secureId);
        List<String> files = (List<String>) values.get("files");
        for (String file :files){
            HashMap<String, Object> hashMap = new HashMap<>();
            hashMap.put("securePathId","");
            hashMap.put("securePathVideo",file);
            hashMap.put("secureId",secureId);
            secureTrainMapper.secureTrainPathInsert(hashMap);
        }
        secureTrainMapper.secureTrainUpdate(values);
        return BasicResult.success("修改成功");
    }

    @Override
    public BasicResult secureTrainUserInfo(Map<String, Object> values) {
       // String openId = values.get("openId").toString();
        String userType = values.get("userType").toString();
        if(userType.equals("1")){
            SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
            String userId = sysUserInfo.getUserId();
            String platId = secureTrainMapper.platId(userId);
            values.put("userId",platId);
        }

        OpenUserInfo userInfo = secureTrainMapper.secureTrainUserInfo(values);
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String companyId = sysUserInfo.getCompanyId();
        Double jia = encourageMapper.encourageSecurityCodeJia(userInfo.getUserId(),companyId);
        Double jian = encourageMapper.encourageSecurityCodeJian(userInfo.getUserId(),companyId);
        if(jia!=null){

        }else {
            jia=0.0;
        }
        if(jian!=null){

        }else {
            jian=0.0;
        }
        userInfo.setAn((userInfo.getAn()+jia-jian));
        return BasicResult.success(userInfo);
    }

    @Override
    public BasicResult secureTrainUser(Map<String, Object> values) {
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String userId = sysUserInfo.getUserId();
        //人员表里面的 id
        String platId = secureTrainMapper.platId(userId);
        String companyId = sysUserInfo.getCompanyId();

        values.put("platId",platId);
        values.put("companyId",companyId);
        List<SecureTrainUserDto> secureTrainUserDtos=secureTrainMapper.secureTrainUser(values);
        for (SecureTrainUserDto s : secureTrainUserDtos){
            List<SecurePathDto> pathDtos = secureTrainMapper.securePath(s.getSecureId());
            pathDtos.stream().forEach(fl->{
                JSONObject json = new JSONObject();
                json.put("fullpath",fl.getSecurePathVideo());
                BasicResult basicResult = fileService.fileinfo(json.toJSONString());
                if(basicResult.isSuccess()){
                    JSONArray jsonArray = JSONArray.parseArray(basicResult.getData().toString());
                    for(Object obj : jsonArray){
                        JSONObject j = JSON.parseObject(obj.toString());
                        if(j.containsKey("name")&&"name".equals(j.getString("name"))){
                            fl.setSecurePathVideoName(j.getString("value"));
                        }
                    }
                }
            });
            s.setSecurePathDtos(pathDtos);
        }
       // t_secure_record
        List<String> secureIds =secureTrainMapper.secureRecord(userId);

//        secureTrainUserDtos.stream().forEach(s1->{
//            for (String s : secureIds){
//                if(s1.getSecureId().equals(s)){
//                    secureTrainUserDtos.remove(s1);
//                }
//            }
//        });
        HashMap<String, Object> hashMap = new HashMap<>();
        hashMap.put("secureTrainUserDtos",secureTrainUserDtos);
        hashMap.put("secureIds",secureIds);
        return BasicResult.success(hashMap);
    }

    @Override
    public BasicResult secureTrainRecordInsert(Map<String, Object> values) {
        SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
        String userId = sysUserInfo.getUserId();
        values.put("recordId","");
        values.put("userId",userId);
        secureTrainMapper.secureTrainRecordInsert(values);
        return BasicResult.success("培训完成");
    }


}