package org.springblade.modules.traceability.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.google.zxing.WriterException;
import org.springblade.common.config.TraceabilityCodeConfig;
import org.springblade.common.utils.QRCodeUtil;
import org.springblade.modules.farm.entity.Farm;
import org.springblade.modules.farm.entity.FarmPaper;
import org.springblade.modules.farm.entity.FarmingRecord;
import org.springblade.modules.farm.service.FarmPaperService;
import org.springblade.modules.farm.service.FarmService;
import org.springblade.modules.farm.service.FarmingRecordService;
import org.springblade.modules.farm.vo.FarmPaperVO;
import org.springblade.modules.farm.vo.FarmVO;
import org.springblade.modules.farm.vo.FarmingRecordVO;
import org.springblade.modules.lang.entity.Land;
import org.springblade.modules.lang.service.ILandService;
import org.springblade.modules.lang.vo.LandVO;
import org.springblade.modules.recovery.service.RecoveryService;
import org.springblade.modules.recovery.vo.RecoveryVO;
import org.springblade.modules.traceability.dto.TraceabilityDTO;
import org.springblade.modules.traceability.dto.TraceabilityDetailDTO;
import org.springblade.modules.traceability.entity.SweepRecord;
import org.springblade.modules.traceability.entity.Traceability;
import org.springblade.modules.traceability.mapper.TraceabilityMapper;
import org.springblade.modules.traceability.service.SweepRecordService;
import org.springblade.modules.traceability.service.TraceabilityService;
import org.springblade.modules.traceability.vo.TraceabilityVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import sun.misc.BASE64Encoder;

import javax.sound.midi.Receiver;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.Date;
import java.util.List;

/**
 * 溯源码表服务实现类
 * @since 2022-05-19
 * @author zhongrj
 */
@Service
public class TraceabilityServiceImpl extends ServiceImpl<TraceabilityMapper, Traceability> implements TraceabilityService {

	@Autowired
	private RecoveryService recoveryService;

	@Autowired
	private FarmingRecordService farmingRecordService;

	@Autowired
	private FarmService farmService;

	@Autowired
	private FarmPaperService farmPaperService;

	@Autowired
	private ILandService landService;

	@Autowired
	private SweepRecordService sweepRecordService;

	/**
	 * 自定义分页
	 *
	 * @param page
	 * @param traceability
	 * @return
	 */
	@Override
	public IPage<TraceabilityVO> selectTraceabilityPage(IPage<TraceabilityVO> page, TraceabilityVO traceability) {
		return page.setRecords(baseMapper.selectTraceabilityPage(page, traceability));
	}

	@Override
	public IPage<TraceabilityVO> selectTraceabilityXcxPage(IPage<TraceabilityVO> page, TraceabilityVO traceability) {
		return page.setRecords(baseMapper.selectTraceabilityXcxPage(page, traceability));
	}

	@Override
	public String selectRevorid(String code) {
		return baseMapper.selectRevorid(code);
	}

	/**
	 * 获取溯源简介信息
	 * @param traceability
	 * @return
	 */
	@Override
	public TraceabilityDTO getSimpleInfo(Traceability traceability) {
		TraceabilityDTO simpleInfo = baseMapper.getSimpleInfo(traceability);
		simpleInfo.setCode(traceability.getCode());
		//获取二维码信息
		String url = TraceabilityCodeConfig.getCodeUrl();
		String encoded = null;
		try {
			encoded = URLEncoder.encode(traceability.getCode(),"UTF-8");
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		String content = url + "?code=" + encoded;
		byte[] qrCodeImage = new byte[0];
		try {
			qrCodeImage = QRCodeUtil.getQRCodeImage(content, 350, 350);
		} catch (WriterException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		String encode = new BASE64Encoder().encode(qrCodeImage);
		simpleInfo.setQrcode("data:image/png;base64,"+encode);
		//返回
		return simpleInfo;
	}

	/**
	 * 获取溯源详情信息（包含农产品信息，认证检测信息，产地（地块信息），农事记录，企业信息）
	 * @param traceability
	 * @return
	 */
	@Override
	public TraceabilityDetailDTO getTraceabilityDetailInfo(Traceability traceability) {

		TraceabilityDetailDTO dto = new TraceabilityDetailDTO();
		int count = 0;
		//根据溯源码编号查询溯源信息
		Traceability traceability1 = baseMapper.selectOne(new QueryWrapper<>(traceability));
		//记录扫描记录
		if (null!=traceability.getBind() && traceability.equals("0")){
			//插入扫描记录
			SweepRecord sweepRecord = new SweepRecord();
			sweepRecord.setCreateTime(new Date());
			sweepRecord.setCode(traceability1.getId().toString());
			sweepRecord.setDeptId(traceability1.getDeptId());
			//新增
			sweepRecordService.save(sweepRecord);
		}
		//1. 查询农产品采收记录信息
		RecoveryVO recoveryVO = recoveryService.getRecoveryDetail(traceability1.getRecoveryId());
		//2. 查询相关检测信息
		List<FarmPaperVO> farmPaperList = farmPaperService.getFarmPaperList(recoveryVO.getFarmId(),recoveryVO.getFarmPlantId());
		//3. 查询产地（地块）信息
		LandVO land = new LandVO();
		land.setId(Long.parseLong(recoveryVO.getLandId()));
		LandVO landInfo = (LandVO)landService.getLandInfo(land);
		//4. 查询农事记录信息(种植开始起)
		List<FarmingRecordVO> farmingRecordVOList = farmingRecordService.getFarmingRecordByFarmPlantId(recoveryVO);
		//5. 查询农场信息
		Farm farm = farmService.getById(recoveryVO.getFarmId());
		//6. 数据封装
		dto.setRecoveryVO(recoveryVO);
		dto.setFarm(farm);
		dto.setRecordVOList(farmingRecordVOList);
		dto.setPaperVOList(farmPaperList);
		dto.setLandVO(landInfo);
		//计算百分比
		if (null!=recoveryVO){
			count = count + 20;
		}
		if (null!=farm){
			count = count + 20;
		}
		if (null==landInfo){
			count = count + 20;
		}
		if (farmingRecordVOList.size()>0){
			count = count + 20;
		}
		if (farmPaperList.size()>0){
			count = count + 20;
		}
		dto.setNum(count);
		//返回数据
		return dto;
	}

	/**
	 * 自定义查询，不分页
	 * @param traceability
	 * @return
	 */
	@Override
	public List<TraceabilityVO> getTraceabilityList(TraceabilityVO traceability) {
		return baseMapper.getTraceabilityList(traceability);
	}

	/**
	 * 获取溯源详情信息（包含农产品信息，认证检测信息，产地（地块信息），农事记录，企业信息）扫码
	 * @param traceability
	 * @return
	 */
	@Override
	@Transactional
	public TraceabilityDetailDTO getTraceabilityDetailInfos(Traceability traceability) {
		TraceabilityDetailDTO dto = new TraceabilityDetailDTO();
		int count = 0;
		//根据溯源码编号查询溯源信息
		Traceability traceability1 = baseMapper.selectOne(new QueryWrapper<>(traceability));
		//记录扫描记录
		SweepRecord sweepRecord = new SweepRecord();
		sweepRecord.setCreateTime(new Date());
		sweepRecord.setCode(traceability1.getId().toString());
		sweepRecord.setDeptId(traceability1.getDeptId());
		//新增
		sweepRecordService.save(sweepRecord);
		//1. 查询农产品采收记录信息
		RecoveryVO recoveryVO = recoveryService.getRecoveryDetail(traceability1.getRecoveryId());
		//2. 查询相关检测信息
		List<FarmPaperVO> farmPaperList = farmPaperService.getFarmPaperList(recoveryVO.getFarmId(),recoveryVO.getFarmPlantId());
		//3. 查询产地（地块）信息
		LandVO land = new LandVO();
		land.setId(Long.parseLong(recoveryVO.getLandId()));
		LandVO landInfo = (LandVO)landService.getLandInfo(land);
		//4. 查询农事记录信息(种植开始起)
		List<FarmingRecordVO> farmingRecordVOList = farmingRecordService.getFarmingRecordByFarmPlantId(recoveryVO);
		//5. 查询企业信息
		Farm farm = farmService.getById(recoveryVO.getFarmId());
		//6. 数据封装
		dto.setRecoveryVO(recoveryVO);
		dto.setFarm(farm);
		dto.setRecordVOList(farmingRecordVOList);
		dto.setPaperVOList(farmPaperList);
		dto.setLandVO(landInfo);
		//返回
		return dto;
	}
}