package com.gkhy.safePlatform.account.rpc.test;

import com.alibaba.fastjson.JSONObject;
import com.gkhy.safePlatform.account.enums.schedule.TimeTypeEnum;
import com.gkhy.safePlatform.account.model.dto.req.AccountAddReqDTO;
import com.gkhy.safePlatform.account.model.dto.req.AccountModReqDTO;
import com.gkhy.safePlatform.account.model.dto.resp.*;
import com.gkhy.safePlatform.account.model.query.AccountQuery;
import com.gkhy.safePlatform.account.rpc.apimodel.AccountUserService;
import com.gkhy.safePlatform.account.rpc.apimodel.model.req.AccountAddRPCReqDTO;
import com.gkhy.safePlatform.account.rpc.apimodel.model.req.AccountModRPCReqDTO;
import com.gkhy.safePlatform.account.rpc.apimodel.model.req.query.AccountRPCQuery;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.*;
import com.gkhy.safePlatform.account.service.AccountService;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.exception.BusinessException;
import com.gkhy.safePlatform.commons.query.PageQuery;
import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;

import java.time.LocalDate;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;


@DubboService
public class AccountUserServiceProvider implements AccountUserService {


    @Autowired
    private AccountService accountService;

    @Override
    public String getAccountPage(Long userId, PageQuery<AccountRPCQuery> RPCPageQuery) {
        ;
        AccountQuery accountQuery = new AccountQuery();
        BeanUtils.copyProperties(RPCPageQuery.getSearchParams(), accountQuery);
        PageQuery<AccountQuery> pageQuery = new PageQuery<>();
        pageQuery.setPageIndex(RPCPageQuery.getPageIndex());
        pageQuery.setPageSize(RPCPageQuery.getPageSize());
        pageQuery.setSearchParams(accountQuery);
        SearchResultVO<List<UserDetailRespDTO>> accountPage = accountService.listAccountByPage(userId, pageQuery);
        return  JSONObject.toJSONString(accountPage);
    }


    @Override
    public ResultVO<List<DepUserRPCRespDTO>> getDepList(Long userId,Long depId) {
        try {
            List<DepUserInfoRespDTO> depUserList = accountService.getDepUserList(userId, depId);
            List<DepUserRPCRespDTO> data = BeanCopyUtils.copyBeanList(depUserList, DepUserRPCRespDTO.class);
            return new ResultVO<>(ResultCodes.OK, data);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
//            return new ResultVO<>(ResultCodes.SERVER_ERROR);
        }
    }

    @Override
    public ResultVO<String> addAccount(ContextCacheUser currentUser, AccountAddRPCReqDTO accountAddRPCReqDTO) {
        ;
        ResultVO<String> result = new ResultVO<>(ResultCodes.OK);
        try {
            AccountAddReqDTO accountAddReqDTO = new AccountAddReqDTO();
            BeanUtils.copyProperties(accountAddRPCReqDTO, accountAddReqDTO);
            accountService.addAccount(currentUser,accountAddReqDTO);
        } catch (AusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (BusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (Exception e) {
            result.setCode(ResultCodes.SERVER_ERROR.getCode());
            result.setMsg(ResultCodes.SERVER_ERROR.getDesc());
        }
        return result;
    }

    @Override
    public ResultVO<String> modAccount(ContextCacheUser currentUser, AccountModRPCReqDTO accountModRPCReqDTO) {
        ;
        ResultVO<String> result = new ResultVO<>(ResultCodes.OK);
        try {
            AccountModReqDTO accountModReqDTO = new AccountModReqDTO();
            BeanUtils.copyProperties(accountModRPCReqDTO, accountModReqDTO);
            accountService.modAccount(currentUser,accountModReqDTO);
        } catch (AusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (BusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (Exception e) {
            result.setCode(ResultCodes.SERVER_ERROR.getCode());
            result.setMsg(ResultCodes.SERVER_ERROR.getDesc());
        }
        return result;
    }

    @Override
    public ResultVO<String> delAccount(ContextCacheUser currentUser, Long id) {
        ;
        ResultVO<String> result = new ResultVO<>(ResultCodes.OK);
        try {
            accountService.delAccount(currentUser, id);
        } catch (AusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (BusinessException e) {
            result.setCode(e.getCode());
            result.setMsg(e.getMessage());
        } catch (Exception e) {
            result.setCode(ResultCodes.SERVER_ERROR.getCode());
            result.setMsg(ResultCodes.SERVER_ERROR.getDesc());
        }
        return result;

    }

    @Override
    public ResultVO<PersonalDetailRPCRespDTO> getPersonalAccountDetail(Long userId) {
        ;
        PersonalDetailRespDTO personalDetailRespDTO = accountService.getPersonalAccountByUserId(userId);
        assert personalDetailRespDTO != null;
        PersonalDetailRPCRespDTO personalDetailRPCRespDTO = new PersonalDetailRPCRespDTO();
        BeanUtils.copyProperties(personalDetailRespDTO,personalDetailRPCRespDTO);
        // 部门
        if (personalDetailRespDTO.getDepartment() != null) {
            PersonalDetailDepRPCRespDTO personalDetailDepRPCRespDTO = new PersonalDetailDepRPCRespDTO();
            BeanUtils.copyProperties(personalDetailRespDTO.getDepartment(), personalDetailDepRPCRespDTO);
            personalDetailRPCRespDTO.setDepartment(personalDetailDepRPCRespDTO);
        }
        // 角色
        if (personalDetailRespDTO.getRole() != null) {
            PersonalDetailRoleRPCRespDTO personalDetailRoleRPCRespDTO = new PersonalDetailRoleRPCRespDTO();
            BeanUtils.copyProperties(personalDetailRespDTO.getRole(), personalDetailRoleRPCRespDTO);
            personalDetailRPCRespDTO.setRole(personalDetailRoleRPCRespDTO);
        }

        return new ResultVO<>(ResultCodes.OK,personalDetailRPCRespDTO);
    }

    @Override
    public ResultVO<UserGroupTimTableRPCRespDTO> getUserGroupWorkTimeTable(Long uid,LocalDate startTime,LocalDate endTime) {
        UserGroupTimTableRPCRespDTO res = new UserGroupTimTableRPCRespDTO();
        UserGroupTimTableRespDTO userGroupWorkSchedule = accountService.getUserGroupWorkSchedule(uid,startTime,endTime);
        if (userGroupWorkSchedule != null) {
            res.setGroupId(userGroupWorkSchedule.getGroupId());
            res.setGroupName(userGroupWorkSchedule.getGroupName());
            res.setPhone(userGroupWorkSchedule.getPhone());
            res.setUid(userGroupWorkSchedule.getUid());
            res.setRealName(userGroupWorkSchedule.getRealName());
            res.setUsername(userGroupWorkSchedule.getUsername());
            if (userGroupWorkSchedule.getTimeDetails() != null) {
                List<UserTimeTableDetailRespDTO> userTimeTableDetailRespDTOS = userGroupWorkSchedule.getTimeDetails();
                List<UserTimeTableRPCRespDTO> result = new ArrayList<>(userTimeTableDetailRespDTOS.size());
                if (userTimeTableDetailRespDTOS.size() > 0) {
                    UserTimeTableRPCRespDTO rpcRespDTO;
                    for (UserTimeTableDetailRespDTO detail : userTimeTableDetailRespDTOS) {
                        rpcRespDTO = new UserTimeTableRPCRespDTO();
                        rpcRespDTO.setStartTime(detail.getStartTime());
                        rpcRespDTO.setEndTime(detail.getEndTime());
                        rpcRespDTO.setType(detail.getType());
                        TimeTypeEnum timeTypeEnum = TimeTypeEnum.parse(detail.getType());
                        if (timeTypeEnum != null) {
                            rpcRespDTO.setTypeDesc(timeTypeEnum.getValue());
                        }
                        result.add(rpcRespDTO);
                    }
                }
                res.setTimeDetails(result);
            }



        }

        return new ResultVO<>(ResultCodes.OK, res);
    }

    @Override
    public ResultVO<UserInfoRPCRespDTO> getUserInfoByUid(Long uid) {
        try {
            UserInfoRPCRespDTO result = null;
            UserInfoRespDTO userInfo = accountService.getUserInfoByUid(uid);
            if (userInfo != null) {
                result = new UserInfoRPCRespDTO();
                BeanUtils.copyProperties(userInfo,result);
            }
            return new ResultVO<>(ResultCodes.OK,result);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
//            return new ResultVO<>(ResultCodes.SERVER_ERROR);
        }

    }

    @Override
    public ResultVO<List<UserInfoRPCRespDTO>> listUserInfoByUids(List<Long> uids) {
        try {
            List<UserInfoRespDTO> data = accountService.listUserByUids(uids);
            List<UserInfoRPCRespDTO> result = new ArrayList<>(data.size());
            UserInfoRPCRespDTO rpcRespDTO;
            for (UserInfoRespDTO respDTO : data) {
                rpcRespDTO = new UserInfoRPCRespDTO();
                rpcRespDTO.setUid(respDTO.getUid());
                rpcRespDTO.setUuid(respDTO.getUuid());
                rpcRespDTO.setUsername(respDTO.getUsername());
                rpcRespDTO.setRealName(respDTO.getRealName());
                rpcRespDTO.setGender(respDTO.getGender());
                rpcRespDTO.setType(respDTO.getType());
                rpcRespDTO.setStatus(respDTO.getStatus());
                rpcRespDTO.setPhone(respDTO.getPhone());
                rpcRespDTO.setIdentify(respDTO.getIdentify());
                rpcRespDTO.setEmail(respDTO.getEmail());
                rpcRespDTO.setDepId(respDTO.getDepId());
                rpcRespDTO.setRoleId(respDTO.getRoleId());
                rpcRespDTO.setPositionId(respDTO.getPositionId());
                result.add(rpcRespDTO);
            }
            return new ResultVO<>(ResultCodes.OK,result);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
//            return new ResultVO<>(ResultCodes.SERVER_ERROR);
        }
    }

    @Override
    public ResultVO<List<UserInfoRPCRespDTO>> listUserInfoByRealName(String realName) {
        try {

            List<UserInfoRespDTO> userInfoRespDTOs = accountService.listUserByRealName(realName);
            List<UserInfoRPCRespDTO> result = new ArrayList<>(userInfoRespDTOs.size());
            if (userInfoRespDTOs.size() > 0) {
                UserInfoRPCRespDTO rpcRespDTO;
                for (UserInfoRespDTO respDTO : userInfoRespDTOs) {
                    rpcRespDTO = new UserInfoRPCRespDTO();
                    rpcRespDTO.setUid(respDTO.getUid());
                    rpcRespDTO.setUuid(respDTO.getUuid());
                    rpcRespDTO.setUsername(respDTO.getUsername());
                    rpcRespDTO.setRealName(respDTO.getRealName());
                    rpcRespDTO.setGender(respDTO.getGender());
                    rpcRespDTO.setType(respDTO.getType());
                    rpcRespDTO.setStatus(respDTO.getStatus());
                    rpcRespDTO.setPhone(respDTO.getPhone());
                    rpcRespDTO.setIdentify(respDTO.getIdentify());
                    rpcRespDTO.setEmail(respDTO.getEmail());
                    rpcRespDTO.setDepId(respDTO.getDepId());
                    rpcRespDTO.setRoleId(respDTO.getRoleId());
                    rpcRespDTO.setPositionId(respDTO.getPositionId());
                    result.add(rpcRespDTO);
                }
            }
            return new ResultVO<>(ResultCodes.OK, result);
        } catch (AusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (BusinessException e) {
            return new ResultVO<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            ResultVO resultVO = new ResultVO<>();
            resultVO.setCode(ResultCodes.SERVER_ERROR);
            return resultVO;
//            return new ResultVO<>(ResultCodes.SERVER_ERROR);
        }
    }


}