package com.zhgd.xmgl.async;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.zhgd.xmgl.modules.basicdata.entity.AttendanceDev;
import com.zhgd.xmgl.modules.basicdata.entity.AttendanceDevSync;
import com.zhgd.xmgl.modules.basicdata.entity.SystemDictData;
import com.zhgd.xmgl.modules.basicdata.entity.WorkerInfo;
import com.zhgd.xmgl.modules.basicdata.mapper.AttendanceDevMapper;
import com.zhgd.xmgl.modules.basicdata.service.IAttendanceDevSyncService;
import com.zhgd.xmgl.modules.basicdata.service.ISystemDictDataService;
import com.zhgd.xmgl.util.HttpUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

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

/**
 * @description: 考勤相关信息异步任务
 **/
@Slf4j
@Component
public class AsyncAttendance {

    @Autowired
    private IAttendanceDevSyncService attendanceDevSyncService;

    @Autowired
    private AttendanceDevMapper attendanceDevMapper;

    @Autowired
    private ISystemDictDataService systemDictDataService;

    /**
     * 同步考勤设备信息
     * @param requestUrl
     * @param attendanceDev
     */
    @Async("countAttendanceExecutor")
    public void syncAttendanceDev(String requestUrl, AttendanceDev attendanceDev) {
        try {
            JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(attendanceDev));
            // 推送同步信息
            String result = HttpUtil.doPost(requestUrl, jsonObject.toString());
            int state = result == null ? 0 : 1;
            // 记录推送信息
            AttendanceDevSync attendanceDevSync = new AttendanceDevSync();
            attendanceDevSync.setMainId(attendanceDev.getCode());
            attendanceDevSync.setRequestUrl(requestUrl);
            attendanceDevSync.setContent(jsonObject.toString());
            attendanceDevSync.setState(state);
            attendanceDevSync.setType(1);
            attendanceDevSync.setCreateTime(new Date());
            attendanceDevSyncService.save(attendanceDevSync);
        }catch (Exception e){
            e.printStackTrace();
            log.error("推送考勤设备数据出现异常,请求路径:" + requestUrl + ",设备ID:" + attendanceDev.getId());
        }
    }

    /**
     * 同步考勤人员信息
     * @param workerInfo
     */
    @Async("countAttendanceExecutor")
    public void syncAttendanceWorker(Integer type, WorkerInfo workerInfo) {
        try {
            // 查询人员项目/工程对应的设备厂商信息
            List<String> productList = attendanceDevMapper.getProductList(workerInfo, "ignoreDataScope");
            List<AttendanceDev> attendanceDevList = attendanceDevMapper.getList(workerInfo, "ignoreDataScope");
            for (String product : productList) {
                SystemDictData data = systemDictDataService.getOne(Wrappers.<SystemDictData>lambdaQuery()
                        .eq(SystemDictData::getDictLabel, type).eq(SystemDictData::getDictType, product));
                if (data == null) {
                    continue;
                }
                String requestUrl = data.getRemark();
                JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(workerInfo));
                jsonObject.put("attendDevList", JSONArray.parseArray(JSON.toJSONString(
                        attendanceDevList.stream().filter(a -> a.getProduceName().equals(product)).collect(Collectors.toList()))));
                // 推送同步信息
                String result = HttpUtil.doPost(requestUrl, jsonObject.toString());
                int state = 1;
                if (result == null) {
                    //请求未成功,记录状态
                    state = 0;
                }
                // 记录推送信息
                AttendanceDevSync attendanceDevSync = new AttendanceDevSync();
                attendanceDevSync.setMainId(workerInfo.getId().toString());
                attendanceDevSync.setRequestUrl(requestUrl);
                attendanceDevSync.setContent(jsonObject.toString());
                attendanceDevSync.setState(state);
                attendanceDevSync.setType(2);
                attendanceDevSync.setCreateTime(new Date());
                attendanceDevSyncService.save(attendanceDevSync);
            }
        }catch (Exception e){
            e.printStackTrace();
            log.error("推送考勤人员数据出现异常");
        }
    }
}