package com.gkhy.exam.noncoalmine.service.impl;

import com.alibaba.fastjson2.JSONObject;
import com.alibaba.fastjson2.TypeReference;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.exam.noncoalmine.entity.NcExaminees;
import com.gkhy.exam.noncoalmine.entity.NcStaff;
import com.gkhy.exam.noncoalmine.mapper.NcExamPlanMapper;
import com.gkhy.exam.noncoalmine.entity.NcExamPlan;
import com.gkhy.exam.noncoalmine.model.query.NcExamPlanQuery;
import com.gkhy.exam.noncoalmine.model.vo.ExamPlanExaminee;
import com.gkhy.exam.noncoalmine.model.vo.ExamPlanInfo;
import com.gkhy.exam.noncoalmine.model.vo.ReturnVO;
import com.gkhy.exam.noncoalmine.service.NcExamPlanService;
import com.gkhy.exam.noncoalmine.service.NcExamineesService;
import com.gkhy.exam.noncoalmine.service.NcStaffService;
import com.ruoyi.common.enums.HttpMethod;
import com.ruoyi.common.exception.ServiceException;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import static com.ruoyi.common.signature.SignatureUtils.getObject;

/**
 * (NcExamPlan)表服务实现类
 *
 * @author makejava
 * @since 2023-09-18 13:21:55
 */
@Service("ncExamPlanService")
public class NcExamPlanServiceImpl extends ServiceImpl<NcExamPlanMapper, NcExamPlan> implements NcExamPlanService {
	@Autowired
	private NcExamPlanMapper ncExamPlanMapper;

	@Autowired
	private NcStaffService ncStaffService;
	@Autowired
	private NcExamineesService ncExamineesService;
	@Override
	public List<NcExamPlan> selectNcExamPlanList(NcExamPlanQuery query) {
		return ncExamPlanMapper.selectNcExamPlanList(query);
	}
	@Transactional
	@Override
	public void syncExamPlan() {

		String startTime = "2018-05-25 00:00:00";
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		String endTime = sdf.format(new Date());
		try {
			startTime = URLEncoder.encode(startTime, "UTF-8");
			endTime = URLEncoder.encode(endTime, "UTF-8");
		} catch (UnsupportedEncodingException e) {
			throw new RuntimeException(e.getCause());
		}
		String getQueryParam = "startTime=" + startTime + "&endTime=" + endTime;
		String json = getObject(getQueryParam,"/api/v1/exam/plan/enroll/download", HttpMethod.GET);
		ReturnVO<List<ExamPlanInfo<ExamPlanExaminee>>> returnVo = JSONObject.parseObject(json, new TypeReference<ReturnVO<List<ExamPlanInfo<ExamPlanExaminee>>>>() {});
		if(returnVo.getCode() == null || returnVo.getCode() != 200){
			throw new ServiceException("拉取数据异常");
		}
		if(returnVo.getData() == null){
			throw new ServiceException("无数据可更新");
		}
		List<ExamPlanInfo<ExamPlanExaminee>> data = returnVo.getData();
		for (ExamPlanInfo examPlanInfo : data) {
			NcExamPlan ncExamPlan = new NcExamPlan();
			BeanUtils.copyProperties(examPlanInfo,ncExamPlan);
			ncExamPlan.setDelFlag((byte)0);
			ncExamPlan.setId(null);
			ncExamPlan.setExamPlanId(examPlanInfo.getId());
			//判断是否已同步
			if(!this.isExsit(examPlanInfo.getId())){
				//插入
				ncExamPlanMapper.insert(ncExamPlan);
				List<ExamPlanExaminee> examPlanExaminees = examPlanInfo.getExaminees();
				if(!CollectionUtils.isEmpty(examPlanInfo.getExaminees())){
					for (ExamPlanExaminee examPlanExaminee : examPlanExaminees) {
						NcExaminees ncExaminees = new NcExaminees();
						ncExaminees.setExamPlanId(examPlanInfo.getId());
						ncExaminees.setDelFlag((byte)0);
						ncExaminees.setCardNum(examPlanExaminee.getCardNum());
						ncExaminees.setCardType(examPlanExaminee.getCardType());
						ncExaminees.setName(examPlanExaminee.getName());
						//判断人员是否存在
						NcStaff ncStaff = ncStaffService.getByIdCard(examPlanExaminee.getCardNum());
						if(ncStaff == null){
							//插入staff表
							ncStaff = new NcStaff();
							ncStaff.setName(examPlanExaminee.getName());
							ncStaff.setSex(examPlanExaminee.getSex());
							ncStaff.setIdCardNum(examPlanExaminee.getCardNum());
							ncStaff.setDelFlag((byte)0);
							ncStaffService.save(ncStaff);

						}
						ncExaminees.setStaffId(ncStaff.getId());
						ncExamineesService.save(ncExaminees);
					}

				}
			}
		}
	}
	public boolean isExsit(Long explanId){
		NcExamPlan ncExamPlan = ncExamPlanMapper.selectOne(new LambdaQueryWrapper<NcExamPlan>()
				.eq(NcExamPlan::getDelFlag, (byte) 0)
				.eq(NcExamPlan::getExamPlanId, explanId));
		if(ncExamPlan != null){
			return true;
		}
		return false;
	}
}