package com.gs.dingtalk.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gs.dingtalk.dto.DingTalkMessage;
import com.gs.dingtalk.dto.QaMsgDto;
import com.gs.dingtalk.entity.MesQaDingtalk;
import com.gs.dingtalk.entity.QaSj;
import com.gs.dingtalk.service.MesQaDingtalkService;
import com.gs.dingtalk.mapper.MesQaDingtalkMapper;
import com.gs.dingtalk.service.QaSjService;
import com.gs.dingtalk.service.SimpleExample;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;

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

/**
 * @author Administrator
 * @description 针对表【MES_QA_DINGTALK】的数据库操作Service实现
 * @createDate 2025-12-03 18:53:07
 */
@Service
@RequiredArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class MesQaDingtalkServiceImpl extends ServiceImpl<MesQaDingtalkMapper, MesQaDingtalk>
        implements MesQaDingtalkService {


    private final SimpleExample simpleExample;

    private final QaSjService qaSjService;

    @Override
    public void sendQaMsgSJ(QaMsgDto dto) {
        LambdaQueryWrapper<MesQaDingtalk> wrapper = new LambdaQueryWrapper<>();

        wrapper.eq(MesQaDingtalk::getLineName, dto.getLineName())
                .eq(MesQaDingtalk::getDepartmentname, dto.getWorkshopName())
                .eq(MesQaDingtalk::getQaType, dto.getQaType());

        //获取到用户id，当用户没有id时重新获取并更新MesQaDingtalk表
        List<MesQaDingtalk> list = list(wrapper);

        if (list.isEmpty()) {
            // 如果没有找到对应的用户，直接返回
            return;
        }

        LambdaQueryWrapper<QaSj> qaSjQueryWrapper = new LambdaQueryWrapper<>();
        qaSjQueryWrapper.eq(QaSj::getBillNo, dto.getBillNo());
        QaSj qaSj = qaSjService.getOne(qaSjQueryWrapper, false);

        if (qaSj == null) {
            // 如果没有找到对应的检验信息，直接返回
            return;
        }

        String message = String.format("首件[检验单号:%s, 物料编码:%s, 物料名称:%s, 车间:%s, 线体:%s, 工单号:%s, 检验结果:%s]，请进行后续操作",
                qaSj.getBillNo(), qaSj.getItemNo(), qaSj.getItemName(), qaSj.getWorkshopName(),
                qaSj.getLineName(), qaSj.getDaa001(), qaSj.getJyjg());

        // 把List<MesQaDingtalk>中的userId使用,拼接起来变成userIdList这个变量

        List<String> sidList = list.stream()
                .map(MesQaDingtalk::getTelephone)
                .collect(Collectors.toList());

        List<String> userIdList = getDingtalkUserIdListByPhones(sidList);

        if (userIdList == null || userIdList.isEmpty()) {
            log.warn("没有有效的钉钉用户ID");
            return;
        }

        String userIdListStr = String.join(",", userIdList);


        DingTalkMessage dingTalkMessage = null;
        try {
            dingTalkMessage = simpleExample.sendMessage(userIdListStr, message);
        } catch (Exception e) {
            throw new RuntimeException("发送钉钉消息失败", e);
        }

        if (dingTalkMessage != null && dingTalkMessage.getErrcode() == 0) {
            System.out.println("发送成功");
        } else {
            System.out.println("发送失败");
        }
    }

    private List<String> getDingtalkUserIdListByPhones(List<String> phoneList) {
        try {
            if (phoneList == null || phoneList.isEmpty()) {
                return new ArrayList<>();
            }

            // 去重
            phoneList = phoneList.stream().distinct().collect(Collectors.toList());

            // 根据sid查询DingtalkInfo
            List<MesQaDingtalk> list = baseMapper.selectList(
                    new LambdaQueryWrapper<MesQaDingtalk>().in(MesQaDingtalk::getTelephone, phoneList)
            );

            if (list == null || list.isEmpty()) {
                return new ArrayList<>();
            }

            // 使用stream流过滤出list中dingtalkId为空的数据
            List<MesQaDingtalk> emptyDingtalkIdList = list.stream()
                    .filter(info -> !StringUtils.hasText(info.getUserId()))
                    .collect(Collectors.toList());

            // 如果存在为空的数据就通过钉钉的接口获取，为dingtalkId赋值，并且更新数据库
            if (!emptyDingtalkIdList.isEmpty()) {
                String accessToken = simpleExample.getAccessToken();

                for (MesQaDingtalk info : emptyDingtalkIdList) {
                    if (StringUtils.hasText(info.getTelephone())) {
                        try {
                            // 通过手机号获取钉钉用户ID
                            com.dingtalk.api.response.OapiV2UserGetbymobileResponse response =
                                    simpleExample.getOapiV2UserGetbymobileResponse(info.getTelephone(), accessToken);

                            if (response != null && response.getResult() != null) {
                                info.setUserId(response.getResult().getUserid());
                                // 更新数据库
                                updateById(info);
                            }
                        } catch (Exception e) {
                            log.error("获取钉钉用户ID失败，手机号：" + info.getTelephone());
                        }
                    }
                }
            }

            // 不存在为空的数据或者处理完空数据后，返回所有有效的dingtalkId列表
            return list.stream()
                    .map(MesQaDingtalk::getUserId)
                    .filter(StringUtils::hasText)
                    .distinct()
                    .collect(Collectors.toList());
        } catch (Exception e) {
            log.error("获取钉钉用户列表失败", e);
            return new ArrayList<>();
        }
    }
}