package com.hxzk.gps.service.impl.Department;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hxzk.gps.controller.DepartMent.Results.DepartMentResult;
import com.hxzk.gps.controller.DepartMent.dto.DpeartMentTreeTableDto;
import com.hxzk.gps.controller.Person.Results.PersonResult;
import com.hxzk.gps.controller.System.SystemLogUtil;
import com.hxzk.gps.entity.Department.TbDepartment;
import com.hxzk.gps.entity.Person.TbPerson;
import com.hxzk.gps.entity.System.TbSystemOperationLog;
import com.hxzk.gps.mapper.Department.TbDepartmentMapper;
import com.hxzk.gps.service.Company.TbCompanyService;
import com.hxzk.gps.service.Department.TbDepartmentService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hxzk.gps.service.System.TbSystemOperationLogService;
import com.hxzk.gps.util.AuToComplete;
import com.hxzk.gps.util.GetUser.UserInfoUtil;
import com.hxzk.gps.util.MessageUtils.MessageUtils;
import com.hxzk.gps.util.Result.ReturnMessage;
import com.hxzk.gps.util.Result.TableDto;

import com.hxzk.gps.util.Time.TimeUtil;
import com.hxzk.gps.util.UDP.UDP_Department;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author YuZhiTong
 * @since 2025-05-18
 */
@Service
public class TbDepartmentServiceImpl extends ServiceImpl<TbDepartmentMapper, TbDepartment> implements TbDepartmentService {

    @Autowired
    TbCompanyService companyService;
    @Autowired
    TbSystemOperationLogService systemOperationLogService;
    @Override
    public DepartMentResult FindDepartmentInfo(DpeartMentTreeTableDto departmentTreeTableDto) {
        // 创建查询包装器
        QueryWrapper<TbDepartment> queryWrapper = new QueryWrapper<>();

        // 处理部门 ID 为空的情况
        if (StringUtils.isEmpty(departmentTreeTableDto.getDepartmentId())) {
            List<Long> list = companyService.getChildCompanyIds(UserInfoUtil.getUserCompanyId());
            queryWrapper.in("companyid", list);
        } else {
            queryWrapper.eq("companyid", departmentTreeTableDto.getDepartmentId());
        }

        // 处理部门名称查询条件
        Optional.ofNullable(departmentTreeTableDto.getDepartmentname()).ifPresent(departmentname ->
                queryWrapper.like("departmentname", departmentname));

        // 使用PageHelper进行分页查询
        Page<TbDepartment> page = PageHelper.startPage(departmentTreeTableDto.getPageNum(), departmentTreeTableDto.getPageSize())
                .doSelectPage(() -> baseMapper.selectList(queryWrapper));

        // 封装部门列表
        TableDto tableDto = new TableDto(page.getResult(), page.getPageNum(), page.getPageSize(), page.getTotal());

        // 获取成功消息
        String message = MessageUtils.getMessage("Success");

        // 返回结果
        return new DepartMentResult(200, message, tableDto);
    }

    @Override
    public List<AuToComplete> DepartmentAutocomplete(TbDepartment department) {
        if (department.getCompanyid().equals("")){
            department.setCompanyid(UserInfoUtil.getUserCompanyId());
        }
        List<Long> companyids = companyService.getChildCompanyIds(department.getCompanyid());
        QueryWrapper<TbDepartment> queryWrapper = new QueryWrapper<>();
        String id = Optional.ofNullable(department.getCompanyid())
                .filter(s -> !s.isEmpty())
                .orElse(UserInfoUtil.getUserCompanyId());
        queryWrapper.in("companyid",companyids);
        List<TbDepartment> departmentList = baseMapper.selectList(queryWrapper);
        List<AuToComplete> addCustomerList = departmentList.stream()
                .map(departments -> {
                    AuToComplete addCustomer = new AuToComplete();
                    addCustomer.setValue(departments.getDepartmentname());
                    addCustomer.setLink(String.valueOf(departments.getId()));
                    return addCustomer;
                })
                .collect(Collectors.toList());

        return addCustomerList;
    }

    @Override
    public TbDepartment FindOneDepartMent(TbPerson person) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("departmentname",person.getPDepartment());
        queryWrapper.eq("company",Optional.ofNullable(person.getCompany()).orElse(UserInfoUtil.getUserCompany()));
        return baseMapper.selectOne(queryWrapper);
    }

    /*
    * 新增部门
    * @param department 部门信息
    * @return 结果信息
    * */
    @Override
    public ReturnMessage add(TbDepartment department) {
         /*
        声明操作状态
        * */
        boolean isSuccess = false;
        department.setCompanyid(UserInfoUtil.isNullGetCompanyId(department.getCompanyid()));
        // 检查部门是否重复
        if (isDepartmentRepeat(department)) {
            return ReturnMessage.ReturnMessageError("DepartmentRepeat");
        }
        try {
            department.setBaoliu5(UserInfoUtil.getUserName());
            department.setAddtime(TimeUtil.GetTime());
            baseMapper.insert(department);
            /*
             * 发送指令到CS
             * */
            UDP_Department.AddDepartment(department);
            isSuccess = true;
        }catch (Exception e){

        }
        return SystemLogUtil.handleAddResult(isSuccess,"DepartmentAdd",department.getDepartmentname());

    }
    /*
     * 修改部门
     * @param department 部门图标信息
     * @return 结果信息
    * */

    @Override
    public ReturnMessage update(TbDepartment department) {
         /*
        声明操作状态
        * */
        boolean isSuccess = false;
        // 设置公司 ID
        department.setCompanyid(UserInfoUtil.isNullGetCompanyId(department.getCompanyid()));
        // 检查部门是否重复
        if (isUpDepartmentRepeat(department)) {
            return ReturnMessage.ReturnMessageError("DepartmentRepeat");
        }
        try {
            // 更新部门信息
            QueryWrapper<TbDepartment> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("id", department.getId());
            department.setAddtime(TimeUtil.GetTime());
            baseMapper.update(department, queryWrapper);
            /*
             * 发送指令到CS
             * */
            UDP_Department.UpDepartment(department);
            isSuccess = true;
        }catch (Exception e){

        }
        return SystemLogUtil.handleUpdateResult(isSuccess,"DepartmentUpdate",department.getDepartmentname());
    }
    /*
     * 删除部门
     * @param department 部门信息
     * @return 结果信息
    * */
    @Override
    public ReturnMessage delete(TbDepartment department) {
         /*
        声明操作状态
        * */
        boolean isSuccess = false;
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("id",department.getId());
        try {
            baseMapper.delete(queryWrapper);
            UDP_Department.DeDepartment(department);
            isSuccess = true;
        }catch (Exception e){

        }
        return SystemLogUtil.handleDeleteResult(isSuccess,"DepartmentDelete",department.getDepartmentname());
    }



    /**
     * 检查部门是否重复
     * @param department 部门信息
     * @return 如果部门重复返回 true，否则返回 false
     */
    private boolean isDepartmentRepeat(TbDepartment department) {
        QueryWrapper<TbDepartment> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("company", department.getCompany())
                .eq("departmentname", department.getDepartmentname());
        return baseMapper.selectCount(queryWrapper) > 0;
    }
    private boolean isUpDepartmentRepeat(TbDepartment department) {
        QueryWrapper<TbDepartment> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("company", department.getCompany())
                .eq("departmentname", department.getDepartmentname());
        return baseMapper.selectCount(queryWrapper) > 1;
    }
}