package com.ruoyi.integration.controller;

import com.ruoyi.chargingPile.api.feignClient.ChargingGunClient;
import com.ruoyi.chargingPile.api.feignClient.ChargingPileClient;
import com.ruoyi.chargingPile.api.feignClient.SiteClient;
import com.ruoyi.chargingPile.api.model.Site;
import com.ruoyi.chargingPile.api.model.TChargingGun;
import com.ruoyi.chargingPile.api.model.TChargingPile;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.core.web.page.PageInfo;
import com.ruoyi.integration.drainage.TCECUtil;
import com.ruoyi.integration.drainage.model.*;
import com.ruoyi.integration.drainage.model.enu.*;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * @author zhibing.pu
 * @Date 2025/1/21 17:52
 */
@RestController
@RequestMapping("")
public class TCECController {
	
	@Resource
	private SiteClient siteClient;
	
	@Resource
	private ChargingPileClient chargingPileClient;
	
	@Resource
	private ChargingGunClient chargingGunClient;
	
	
	/**
	 * 查询充电站信息
	 * @param query
	 * @return
	 */
	@PostMapping("/query_stations_info")
	public QueryStationsInfoResult queryStationsInfo(@RequestBody QueryStationsInfo query){
		Integer pageNo = query.getPageNo();
		Integer pageSize = query.getPageSize();
		if(null == pageNo){
			pageNo = 1;
		}
		if(null == pageSize){
			pageSize = 10;
		}
		PageInfo<Site> siteListPaging = siteClient.getSiteListPaging(pageNo, pageSize);
		QueryStationsInfoResult queryStationsInfoResult = new QueryStationsInfoResult();
		queryStationsInfoResult.setPageNo(pageNo);
		queryStationsInfoResult.setPageCount((0 == (siteListPaging.getTotal() % pageSize) ? 0 : 1) + Double.valueOf(siteListPaging.getTotal() / pageSize).intValue());
		queryStationsInfoResult.setItemSize(Long.valueOf(siteListPaging.getTotal()).intValue());
		
		List<StationInfo> StationInfos = new ArrayList<>();
		for (Site datum : siteListPaging.getRecords()) {
			StationInfo stationInfo = new StationInfo();
			stationInfo.setStationID(datum.getId().toString());
			stationInfo.setOperatorID();
			stationInfo.setEquipmentOwnerID();
			stationInfo.setStationName(datum.getName());
			stationInfo.setCountryCode(datum.getCountryCode());
			stationInfo.setAreaCode(datum.getDistrictsCode());
			stationInfo.setAddress(datum.getAddress());
			stationInfo.setStationTel(datum.getPhone());
			stationInfo.setServiceTel(datum.getServicePhone());
			switch (datum.getSiteType()){
				case 0:
					stationInfo.setStationType(StationTypeEnum.OTHER.getType());
					break;
				case 1:
					stationInfo.setStationType(StationTypeEnum.PUBLIC.getType());
					break;
				case 2:
					stationInfo.setStationType(StationTypeEnum.PERSONAGE.getType());
					break;
				case 3:
					stationInfo.setStationType(StationTypeEnum.BUS_SPECIFIC.getType());
					break;
				case 4:
					stationInfo.setStationType(StationTypeEnum.SANITATION_SPECIFIC.getType());
					break;
				case 5:
					stationInfo.setStationType(StationTypeEnum.LOGISTICS_SPECIFIC.getType());
					break;
				case 6:
					stationInfo.setStationType(StationTypeEnum.TEXT_SPECIFIC.getType());
					break;
			}
			if(datum.getStatus() == 1){
				stationInfo.setStationStatus(StationStatusEnum.NORMAL_USE.getStatus());
			}
			if(datum.getStatus() == 2){
				stationInfo.setStationStatus(StationStatusEnum.MAINTAIN.getStatus());
			}
			if(datum.getStatus() == 3){
				stationInfo.setStationStatus(StationStatusEnum.OFF_LINE.getStatus());
			}
			stationInfo.setParkNums(datum.getParkingSpace());
			stationInfo.setStationLat(new BigDecimal(datum.getLat()).setScale(6, RoundingMode.DOWN));
			stationInfo.setStationLng(new BigDecimal(datum.getLon()).setScale(6, RoundingMode.DOWN));
			stationInfo.setConstruction(datum.getConstructionSite() == 0 ? ConstructionEnum.OTHER.getType() : datum.getConstructionSite());
			stationInfo.setPictures(Arrays.asList(datum.getImgUrl().split(",")));
			stationInfo.setSiteGuide(datum.getGuide());
			stationInfo.setMatchCars(datum.getVehicleDescription());
			stationInfo.setBusineHours(datum.getStartServiceTime() + "-" + datum.getEndServiceTime());
			stationInfo.setElectricityFee(datum.getRateDescription());
			//构建充电设备信息数据
			List<TChargingPile> tChargingPiles = chargingPileClient.getChargingPileBySiteId(datum.getId()).getData();
			stationInfo.setEquipmentInfos(buildEquipmentInfo(tChargingPiles));
			StationInfos.add(stationInfo);
		}
		queryStationsInfoResult.setStationInfos(StationInfos);
		return queryStationsInfoResult;
	}
	
	
	/**
	 * 构建桩数据
	 * @param tChargingPiles
	 * @return
	 */
	public List<EquipmentInfo> buildEquipmentInfo(List<TChargingPile> tChargingPiles){
		List<EquipmentInfo> equipmentInfos = new ArrayList<>();
		for (TChargingPile tChargingPile : tChargingPiles) {
			EquipmentInfo equipmentInfo = new EquipmentInfo();
			equipmentInfo.setEquipmentID(tChargingPile.getId().toString());
			equipmentInfo.setManufacturerID(tChargingPile.getManufacturerCode());
			equipmentInfo.setManufacturerName(tChargingPile.getManufacturer());
			equipmentInfo.setEquipmentModel(tChargingPile.getEquipmentType());
			if(null != tChargingPile.getProductionDate()){
				equipmentInfo.setProductionDate(tChargingPile.getProductionDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
			}
			switch (tChargingPile.getType()){
				case 0:
					equipmentInfo.setEquipmentType(EquipmentTypeEnum.OTHER.getType());
					break;
				case 1:
					equipmentInfo.setEquipmentType(EquipmentTypeEnum.DIRECT_CURRENT.getType());
					break;
				case 2:
					equipmentInfo.setEquipmentType(EquipmentTypeEnum.ALTERNATING_CURRENT.getType());
					break;
				case 3:
					equipmentInfo.setEquipmentType(EquipmentTypeEnum.ALTERNATING_DIRECT.getType());
					break;
				case 4:
					equipmentInfo.setEquipmentType(EquipmentTypeEnum.WIRELESS_DEVICE.getType());
					break;
			}
			
			//构建设备接口信息
			List<TChargingGun> chargingGunList = chargingGunClient.getChargingGunByChargingPileId(tChargingPile.getId()).getData();
			equipmentInfo.setConnectorInfos(buildConnectorInfos(chargingGunList));
			equipmentInfos.add(equipmentInfo);
		}
		return equipmentInfos;
	}
	
	
	/**
	 * 构建接口数据
	 * @param chargingGunList
	 * @return
	 */
	public List<ConnectorInfo> buildConnectorInfos(List<TChargingGun> chargingGunList){
		List<ConnectorInfo> connectorInfos = new ArrayList<>();
		for (TChargingGun chargingGun : chargingGunList) {
			ConnectorInfo connectorInfo = new ConnectorInfo();
			connectorInfo.setConnectorID(chargingGun.getId().toString());
			connectorInfo.setConnectorName(chargingGun.getName());
			switch (chargingGun.getType()){
				case 0:
					connectorInfo.setConnectorType(ConnectorTypeEnum.OTHER.getType());
					break;
				case 1:
					connectorInfo.setConnectorType(ConnectorTypeEnum.HOUSEHOLD_SOCKET.getType());
					break;
				case 2:
					connectorInfo.setConnectorType(ConnectorTypeEnum.AC_SOCKET.getType());
					break;
				case 3:
					connectorInfo.setConnectorType(ConnectorTypeEnum.AC_INTERFACE_PLUG.getType());
					break;
				case 4:
					connectorInfo.setConnectorType(ConnectorTypeEnum.DC_INTERFACE_GUN_HEAD.getType());
					break;
				case 5:
					connectorInfo.setConnectorType(ConnectorTypeEnum.WIRELESS_CHARGING_STAND.getType());
					break;
			}
			connectorInfo.setVoltageUpperLimits(chargingGun.getUpperRatedVoltage().intValue());
			connectorInfo.setVoltageLowerLimits(chargingGun.getLowerLimitOfRatedVoltage().intValue());
			connectorInfo.setCurrent(chargingGun.getRatedCurrent().intValue());
			connectorInfo.setPower(chargingGun.getRatedPower());
			connectorInfo.setParkNo(chargingGun.getParkingNumber());
			connectorInfo.setNationalStandard(Integer.valueOf(chargingGun.getNationalStandard()));
			connectorInfos.add(connectorInfo);
		}
		return connectorInfos;
	}
	
	
	/**
	 * 接口状态变化后推送给第三方
	 * @return
	 */
	@PostMapping("/pushChargingGunStatus")
	public R pushChargingGunStatus(@RequestParam("id") Integer id, @RequestParam("status") Integer status){
		ConnectorStatusInfo connectorStatusInfo = new ConnectorStatusInfo();
		connectorStatusInfo.setConnectorID(id.toString());
		switch (status){
			case 1:
				connectorStatusInfo.setStatus(0);
				break;
			case 2:
				connectorStatusInfo.setStatus(1);
				break;
			case 3:
				connectorStatusInfo.setStatus(2);
				break;
			case 4:
				connectorStatusInfo.setStatus(3);
				break;
			case 5:
				connectorStatusInfo.setStatus(3);
				break;
			case 6:
				connectorStatusInfo.setStatus(4);
				break;
			case 7:
				connectorStatusInfo.setStatus(255);
				break;
		}
		NotificationStationStatusResult result = TCECUtil.notificationStationStatus(connectorStatusInfo);
		return R.ok();
	}
	
	
	
	/**
	 * 设备接口状态查询
	 * @param query
	 * @return
	 */
	@PostMapping("/query_station_status")
	public QueryStationStatusResult queryStationStatus(@RequestBody QueryStationStatus query){
	
	}
}