/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.sxkj.gd.workorder.service.impl;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.AllArgsConstructor;
import org.springblade.core.tool.utils.StringUtil;
import org.sxkj.gd.workorder.dto.GdDeviceCallDetailExternalSaveDTO;
import org.sxkj.gd.workorder.entity.GdDeviceCallDetailEntity;
import org.sxkj.gd.workorder.entity.GdDeviceCallEntity;
import org.sxkj.gd.workorder.entity.GdManageDeviceEntity;
import org.sxkj.gd.workorder.entity.GdPatrolTaskEntity;
import org.sxkj.gd.workorder.service.IGdDeviceCallDetailService;
import org.sxkj.gd.workorder.service.IGdManageDeviceService;
import org.sxkj.gd.workorder.service.IGdPatrolTaskService;
import org.sxkj.gd.workorder.vo.GdDeviceCallVO;
import org.sxkj.gd.workorder.excel.GdDeviceCallExcel;
import org.sxkj.gd.workorder.mapper.GdDeviceCallMapper;
import org.sxkj.gd.workorder.service.IGdDeviceCallService;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.sxkj.system.cache.SysCache;
import org.sxkj.system.cache.UserCache;

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

/**
 * 设备调用表 服务实现类
 *
 * @author Aix
 * @since 2026-02-26
 */
@Service
@AllArgsConstructor
public class GdDeviceCallServiceImpl extends BaseServiceImpl<GdDeviceCallMapper, GdDeviceCallEntity> implements IGdDeviceCallService {

	private final IGdDeviceCallDetailService gdDeviceCallDetailService;
	private final IGdPatrolTaskService gdPatrolTaskService;
	private final IGdManageDeviceService gdManageDeviceService;

	@Override
	public IPage<GdDeviceCallVO> selectGdDeviceCallPage(IPage<GdDeviceCallVO> page, GdDeviceCallVO gdDeviceCall) {
		return page.setRecords(baseMapper.selectGdDeviceCallPage(page, gdDeviceCall));
	}

	@Override
	public boolean saveGdDeviceCallExternal(List<GdDeviceCallDetailExternalSaveDTO> dtos) {

		// 保存设备调用
		GdPatrolTaskEntity patrolTask = gdPatrolTaskService.getById(dtos.get(0).getPatrolTaskId());
		if (patrolTask == null) {
			log.warn("巡查任务不存在：" + dtos.get(0).getPatrolTaskId());
			return false;
		}
		GdDeviceCallEntity callEntity = new GdDeviceCallEntity();
		callEntity.setId(patrolTask.getId());
		callEntity.setPatrolTaskName(patrolTask.getPatrolTaskName());
		callEntity.setTaskDepartment(SysCache.getDeptName(patrolTask.getCreateDept()));
		callEntity.setTaskDepartmentId(patrolTask.getCreateDept());
		callEntity.setTaskInitiator(UserCache.getUser(patrolTask.getCreateUser()).getName());
		callEntity.setTaskInitiatorId(patrolTask.getCreateUser());
		callEntity.setPlanExecuteTime(patrolTask.getExecuteTime());
		callEntity.setActualExecuteTime(dtos.get(0).getOccurTime());// 第一条数据的发生时间

		// 计算飞行时长（毫秒转分钟）
		// 计算飞行时长（处理可能的空值情况）
		Date startTime = dtos.get(0).getOccurTime();
		Date endTime = dtos.get(dtos.size() - 1).getOccurTime();

		if (startTime == null || endTime == null) {
			log.warn("时间数据不完整，无法计算飞行时长");
			callEntity.setFlightDuration(0L);
		} else {
			long flightDurationMs = endTime.getTime() - startTime.getTime();
			// 可以选择不同的时间单位
			callEntity.setFlightDuration(flightDurationMs / 1000); // 秒
		}


		// 计算总飞行距离
		double totalDistance = dtos.stream()
			.mapToDouble(GdDeviceCallDetailExternalSaveDTO::getFlightDistance)
			.sum();
		callEntity.setFlightDistance(totalDistance);

		// 设备ID&名称
		String deviceSn = dtos.get(0).getDeviceSn();
		Long deviceId = null;
		String deviceName = null;

		if (StringUtil.hasText(deviceSn)) {
			GdManageDeviceEntity gdManageDevice = gdManageDeviceService.getOne(
				Wrappers.lambdaQuery(GdManageDeviceEntity.class)
					.eq(GdManageDeviceEntity::getDeviceSn, deviceSn),
				false
			);

			if (gdManageDevice == null) {
				log.warn("设备不存在：" + deviceSn);
				return false;
			}
			deviceId = gdManageDevice.getId();
			deviceName = gdManageDevice.getDeviceName();
		}

		callEntity.setDeviceId(deviceId);
		callEntity.setDeviceName(deviceName);

		// 保存设备调用详情
		if (baseMapper.insert(callEntity) <= 0) {
			return false;
		}

		List<GdDeviceCallDetailEntity> detailEntities = dtos.stream().map(dto -> {
			GdDeviceCallDetailEntity entity = new GdDeviceCallDetailEntity();
			entity.setCallId(dto.getPatrolTaskId());
			entity.setDeviceStatus(dto.getDeviceStatus());
			entity.setOccurTime(dto.getOccurTime());
			entity.setFlightDistance(dto.getFlightDistance());
			entity.setSort(dto.getSort());
			return entity;
		}).collect(Collectors.toList());

		return gdDeviceCallDetailService.saveBatch(detailEntities);
	}

	@Override
	public List<GdDeviceCallExcel> exportGdDeviceCall(Wrapper<GdDeviceCallEntity> queryWrapper) {
		List<GdDeviceCallExcel> gdDeviceCallList = baseMapper.exportGdDeviceCall(queryWrapper);
		//gdDeviceCallList.forEach(gdDeviceCall -> {
		//	gdDeviceCall.setTypeName(DictCache.getValue(DictEnum.YES_NO, GdDeviceCall.getType()));
		//});
		return gdDeviceCallList;
	}

}