package com.ruoyi.chargingPile.controller;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.account.api.feignClient.AppUserClient;
import com.ruoyi.account.api.feignClient.AppUserVipDetailClient;
import com.ruoyi.account.api.model.TAppUser;
import com.ruoyi.account.api.model.TAppUserVipDetail;
import com.ruoyi.account.api.vo.GetAppUserVipDetail;
import com.ruoyi.chargingPile.api.dto.GetSiteListDTO;
import com.ruoyi.chargingPile.api.feignClient.ParkingLotClient;
import com.ruoyi.chargingPile.api.feignClient.SiteClient;
import com.ruoyi.chargingPile.api.model.*;
import com.ruoyi.chargingPile.api.query.GetSiteList;
import com.ruoyi.chargingPile.api.query.SiteDetailQuery;
import com.ruoyi.chargingPile.api.query.SiteQuery;
import com.ruoyi.chargingPile.api.vo.*;
import com.ruoyi.chargingPile.api.domain.SiteMenu;
import com.ruoyi.chargingPile.dto.ChargingPercentBack;
import com.ruoyi.chargingPile.dto.BatchSetSiteAccountingStrategyDTO;
import com.ruoyi.chargingPile.dto.SiteExcelDTO;
import com.ruoyi.chargingPile.dto.SiteImportResultDTO;
import com.ruoyi.common.core.dto.ChargingOrderGroup;
import com.ruoyi.common.core.dto.ChargingPercentProvinceDto;
import com.ruoyi.chargingPile.service.*;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.utils.DateUtils;
import com.ruoyi.common.core.utils.ServletUtils;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.core.utils.poi.ExcelUtil;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.common.core.web.page.PageInfo;
import com.ruoyi.common.log.annotation.Log;
import com.ruoyi.common.log.enums.BusinessType;
import com.ruoyi.common.log.enums.OperatorType;
import com.ruoyi.common.security.annotation.Logical;
import com.ruoyi.common.security.annotation.RequiresPermissions;
import com.ruoyi.common.security.service.TokenService;
import com.ruoyi.common.security.utils.SecurityUtils;
import com.ruoyi.order.api.feignClient.ChargingOrderClient;
import com.ruoyi.order.api.model.TChargingOrder;
import com.ruoyi.other.api.domain.TVip;
import com.ruoyi.other.api.feignClient.RoleSiteClient;
import com.ruoyi.other.api.feignClient.UserSiteClient;
import com.ruoyi.other.api.feignClient.VipClient;
import com.ruoyi.system.api.domain.SysUser;
import com.ruoyi.system.api.feignClient.SysUserClient;
import com.ruoyi.system.api.feignClient.SysUserRoleClient;
import com.ruoyi.system.api.model.SysUserRoleVo;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.math.BigDecimal;
import java.time.LocalTime;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author zhibing.pu
 * @Date 2024/8/7 19:56
 */
@RestController
@RequestMapping("/site")
public class SiteController {
	
	@Resource
	private ISiteService siteService;
	
	@Resource
	private IPartnerService partnerService;

	@Resource
	private SysUserClient sysUserClient;
	
	@Resource
	private UserSiteClient userSiteClient;
	
	@Resource
	private RoleSiteClient roleSiteClient;
	@Resource
	private SysUserRoleClient sysUserRoleClient;
	@Resource
	private TChargingPileService chargingPileService;
	@Resource
	private TChargingGunService chargingGunService;

	@Autowired
	private TParkingLotService parkingLotService;
	@Autowired
	private TAccountingStrategyService accountingStrategyService;
	@Autowired
	private TAccountingStrategyDetailService accountingStrategyDetailService;

	@Resource
	private ChargingOrderClient chargingOrderClient;

	@Resource
	private SysUserRoleClient userRoleClient;
	@Resource
	private VipClient vipClient;
	@Resource
	private TokenService tokenService;
	@Resource
	private AppUserClient appUserClient;
	@Resource
	private AppUserVipDetailClient vipDetailClient;
	// 远程新增临时站点
	@ResponseBody
	@PostMapping("/addSiteTemp")
	@ApiOperation(value = "添加站点", tags = {"管理后台-站点管理"})
	@Log(title = "【站点管理】添加站点", businessType = BusinessType.INSERT)
	public R addSiteTemp(@RequestBody Site site){
		siteService.save(site);
		return R.ok(site.getId());
	}
	/**
	 * 根据站点id 查询所有充电桩
	 * @param siteId
	 * @return
	 */
	@GetMapping("/getPileListBySiteId/{siteId}")
	public R<List<TChargingPile>> getPileListBySiteId(@PathVariable("siteId")Integer siteId){

		return R.ok(chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, siteId).list());
	}
	/**
	 * 小程序扫一扫
	 * @param number
	 * @return
	 */
	@Log(title = "【扫一扫】通过桩编号获取电站信息", businessType = BusinessType.OTHER,operatorType = OperatorType.MOBILE)
	@GetMapping("/getSiteInfoByNumber")
	@ApiOperation(value = "扫一扫后通过桩编号获取电站信息", tags = {"小程序-扫一扫"})
	public R<SiteInfoVO> getSiteInfoByNumber(@RequestParam("number") String number){
		SiteInfoVO siteInfoVO = new SiteInfoVO();
		TChargingGun chargingGun = chargingGunService.getOne(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getFullNumber, number));
		Site site = siteService.getById(chargingGun.getSiteId());
		siteInfoVO.setMemberDiscountFlag(site.getMemberDiscountFlag());
		Integer accountingStrategyId = chargingGun.getAccountingStrategyId();
		if(null == accountingStrategyId){
			accountingStrategyId = site.getAccountingStrategyId();
		}
		TChargingPile one = chargingPileService.getById(chargingGun.getChargingPileId());
		TAccountingStrategy byId1 = accountingStrategyService.getById(accountingStrategyId);
		List<TAccountingStrategyDetail> list = accountingStrategyDetailService.lambdaQuery().eq(TAccountingStrategyDetail::getAccountingStrategyId, byId1.getId()).list();
		list.stream().filter(item -> "00:00".equals(item.getEndTime())).forEach(item -> item.setEndTime("23:59:59"));
		for (TAccountingStrategyDetail tAccountingStrategyDetail : list) {
			// 当前时间属于那个阶段 取哪个阶段的电价
			if(DateUtils.string2LocalTime(tAccountingStrategyDetail.getStartTime() + ":00").compareTo(LocalTime.now()) <= 0
					&& DateUtils.string2LocalTime(tAccountingStrategyDetail.getEndTime() + ("23:59:59".equals(tAccountingStrategyDetail.getEndTime())?"":":00")).compareTo(LocalTime.now()) > 0){
				siteInfoVO.setElectrovalence(tAccountingStrategyDetail.getElectrovalence().add(tAccountingStrategyDetail.getServiceCharge()).setScale(4, BigDecimal.ROUND_HALF_UP));
				siteInfoVO.setVipElectrovalence(siteInfoVO.getElectrovalence());
				// 获取当前登录用户id
				String token = SecurityUtils.getToken(ServletUtils.getRequest());
				if(Integer.valueOf(1).equals(site.getMemberDiscountFlag()) && StringUtils.isNotEmpty(token)){
					Long userId = tokenService.getLoginUserApplet().getUserId();
					// 根据id查询用户信息
					TAppUser appUser = appUserClient.getUserById(userId).getData();
					if(Objects.nonNull(byId1.getDiscount())){
						siteInfoVO.setVipElectrovalence((tAccountingStrategyDetail.getServiceCharge().multiply(byId1.getDiscount()).add(tAccountingStrategyDetail.getElectrovalence())).setScale(4, BigDecimal.ROUND_HALF_UP));
					}else {
						siteInfoVO.setVipElectrovalence((tAccountingStrategyDetail.getServiceCharge().add(tAccountingStrategyDetail.getElectrovalence())).setScale(4, BigDecimal.ROUND_HALF_UP));
					}
					TVip vip = null;
					if(Objects.nonNull(appUser)){
//					TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
						GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();
						getAppUserVipDetail.setAppUserId(userId);
						getAppUserVipDetail.setVipId(appUser.getVipId());
						R<TAppUserVipDetail> appUserVipDetail = vipDetailClient.getAppUserVipDetail(getAppUserVipDetail);
						TAppUserVipDetail data1 = appUserVipDetail.getData();
						if(Objects.nonNull(data1)){
							String vipJson = data1.getVipJson();
							vip = JSON.parseObject(vipJson, TVip.class);
						}
					}

					if(Objects.nonNull(vip) && vip.getType() == 2){
						siteInfoVO.setVipElectrovalence(vip.getDiscount().divide(new BigDecimal(10)).multiply(tAccountingStrategyDetail.getServiceCharge()).add(tAccountingStrategyDetail.getElectrovalence()));
					}
				}
			}
		}
		siteInfoVO.setChargingGunId(chargingGun.getId());
		siteInfoVO.setChargingPileId(one.getId());
		siteInfoVO.setName(site.getName());
		siteInfoVO.setNumber(one.getNumber().toString());
		siteInfoVO.setSpaceChargeExplain(site.getSpaceChargeExplain());
		siteInfoVO.setSupportOrder(site.getSupportOrder());
		siteInfoVO.setReservationStartTime(site.getReservationStartTime());
		siteInfoVO.setReservationEndTime(site.getReservationEndTime());
		siteInfoVO.setVinFlag(one.getVinFlag());
		return R.ok(siteInfoVO);
	}
	/**
	 * 通过桩编号获取电站信息 遠程調用
	 * @param number
	 * @return
	 */
	@PostMapping("/getSiteInfoByNumber1")
	public R<SiteInfoVO> getSiteInfoByNumber1(@RequestParam("number") String number){
		SiteInfoVO siteInfoVO = new SiteInfoVO();
		TChargingPile one = chargingPileService.lambdaQuery().eq(TChargingPile::getCode, number).one();
		TChargingGun chargingGun = chargingGunService.getOne(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getChargingPileId, one.getId()).last(" limit 0, 1"));
		Site site = siteService.getById(chargingGun.getSiteId());
		siteInfoVO.setMemberDiscountFlag(site.getMemberDiscountFlag());
		Integer accountingStrategyId = chargingGun.getAccountingStrategyId();
		if(null == accountingStrategyId){
			accountingStrategyId = site.getAccountingStrategyId();
		}
		TAccountingStrategy byId1 = accountingStrategyService.getById(accountingStrategyId);
		List<TAccountingStrategyDetail> list = accountingStrategyDetailService.lambdaQuery().eq(TAccountingStrategyDetail::getAccountingStrategyId, byId1.getId()).list();
		list.stream().filter(item -> "00:00".equals(item.getEndTime())).forEach(item -> item.setEndTime("23:59:59"));
		for (TAccountingStrategyDetail tAccountingStrategyDetail : list) {
			// 当前时间属于那个阶段 取哪个阶段的电价
			if(DateUtils.string2LocalTime(tAccountingStrategyDetail.getStartTime() + ":00").compareTo(LocalTime.now()) <= 0
					&& DateUtils.string2LocalTime(tAccountingStrategyDetail.getEndTime() + ("23:59:59".equals(tAccountingStrategyDetail.getEndTime())?"":":00")).compareTo(LocalTime.now()) > 0){
				siteInfoVO.setElectrovalence(tAccountingStrategyDetail.getElectrovalence().add(tAccountingStrategyDetail.getServiceCharge()).setScale(4, BigDecimal.ROUND_HALF_UP));
				siteInfoVO.setVipElectrovalence(siteInfoVO.getElectrovalence());
				// 获取当前登录用户id
				String token = SecurityUtils.getToken(ServletUtils.getRequest());
				if(Integer.valueOf(1).equals(site.getMemberDiscountFlag()) && StringUtils.isNotEmpty(token)){
					Long userId = tokenService.getLoginUserApplet().getUserId();
					// 根据id查询用户信息
					TAppUser appUser = appUserClient.getUserById(userId).getData();
					if(Objects.nonNull(appUser)){
//					TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
						GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();
						getAppUserVipDetail.setAppUserId(userId);
						getAppUserVipDetail.setVipId(appUser.getVipId());
						R<TAppUserVipDetail> appUserVipDetail = vipDetailClient.getAppUserVipDetail(getAppUserVipDetail);
						TAppUserVipDetail data1 = appUserVipDetail.getData();
						if(Objects.nonNull(data1)){
							String vipJson = data1.getVipJson();
							TVip vip = JSON.parseObject(vipJson, TVip.class);
							if(Objects.nonNull(vip) && vip.getType() == 2){
								siteInfoVO.setVipElectrovalence(vip.getDiscount().divide(new BigDecimal(10)).multiply(tAccountingStrategyDetail.getServiceCharge()).add(tAccountingStrategyDetail.getElectrovalence()));
							}
						}
					}
				}

				if(Integer.valueOf(1).equals(site.getMemberDiscountFlag()) && Objects.nonNull(byId1.getDiscount())){
					siteInfoVO.setVipElectrovalence((tAccountingStrategyDetail.getServiceCharge().multiply(byId1.getDiscount()).add(tAccountingStrategyDetail.getElectrovalence())).setScale(4, BigDecimal.ROUND_HALF_UP));
				}else {
					siteInfoVO.setVipElectrovalence((tAccountingStrategyDetail.getServiceCharge().add(tAccountingStrategyDetail.getElectrovalence())).setScale(4, BigDecimal.ROUND_HALF_UP));
				}

			}
		}
		List<TVip> vips = vipClient.getVipList().getData();
		if(!CollectionUtils.isEmpty(vips)){
			TVip tVip = vips.get(0);
			JSONArray objects = JSONArray.parseArray(tVip.getCoupon());
			Integer num = 0;
			for (Object object : objects) {
				JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(object));
				Integer number1 = jsonObject.getInteger("number");
				num += number1;
			}
			siteInfoVO.setCouponCount(num);
		}
		siteInfoVO.setChargingPileId(one.getId());
		siteInfoVO.setName(site.getName());
		siteInfoVO.setNumber(one.getNumber().toString());
		siteInfoVO.setSpaceChargeExplain(site.getSpaceChargeExplain());
		siteInfoVO.setSupportOrder(site.getSupportOrder());
		siteInfoVO.setReservationStartTime(site.getReservationStartTime());
		siteInfoVO.setReservationEndTime(site.getReservationEndTime());
		siteInfoVO.setVinFlag(one.getVinFlag());
		return R.ok(siteInfoVO);
	}
	
	@RequiresPermissions(value = {"/systemUserManagement/update", "/site", "/platformRevenueAnalysis", "/chargingOperationAnalysis",
			"/chargingUserAnalysis", "/operationMaintenanceAnalysis", "/chargingEquipmentMonitoring", "/activityExpense", "/chargeEvaluation/list",
			"/parkingLot", "/parkingRecord", "/workbench", "/invoiceManagement"}, logical = Logical.OR)
	@GetMapping("/getSiteList")
	@ApiOperation(value = "获取站点列表", tags = {"管理后台-站点管理"})
	public AjaxResult<PageInfo<GetSiteListDTO>> getSiteList(GetSiteList siteList){
		PageInfo<GetSiteListDTO> list = siteService.getSiteList(siteList);
		return AjaxResult.success(list);
	}
	
	
	@GetMapping("/getSiteList/byUserId")
	@ApiOperation(value = "获取站点列表", tags = {"管理后台-站点管理"})
	public R<List<GetSiteListDTO>> getSiteListByUserId(@RequestParam("userId") Long userId){
		PageInfo<GetSiteListDTO> list = siteService.getSiteList1(userId);
		return R.ok(list.getRecords());
	}
	
	
	
	@RequiresPermissions(value = {"/chargeDistribution"}, logical = Logical.OR)
	@GetMapping("/map/getSiteList")
	@ApiOperation(value = "获取站点", tags = {"管理后台-数据分析-电站分析"})
	public R<List<GetSiteListDTO>> getMapSiteList(GetSiteList siteList){

		siteList.setPageCurr(1);
		siteList.setPageSize(99999);
		PageInfo<GetSiteListDTO> list = siteService.getSiteList(siteList);
		for (GetSiteListDTO record : list.getRecords()) {
			List<Integer> c1 = new ArrayList<>();
			c1.add(3);
			c1.add(4);
			c1.add(5);
			c1.add(6);
			Long count = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 1).eq(TChargingGun::getStatus, 2).count();
			record.setC1(count);
			Long count1 = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 1).count();
			record.setC2(count1);
			Long count2 = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 2).eq(TChargingGun::getStatus, 2).count();
			record.setK1(count2);
			Long count3 = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 2).count();
			record.setK2(count3);
			Long count4 = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 3).eq(TChargingGun::getStatus, 2).count();
			record.setM1(count4);
			Long count5 = chargingGunService.lambdaQuery().eq(TChargingGun::getSiteId, record.getId()).eq(TChargingGun::getChargeMode, 3).count();
			record.setM2(count5);

			//利用率
			BigDecimal bigDecimal = new BigDecimal("0");
			//获取该站点的总充电度数
			List<TChargingOrder> chargingOrders = chargingOrderClient.getList(record.getId()).getData();
			for (TChargingOrder chargingOrder : chargingOrders) {
				bigDecimal = bigDecimal.add(chargingOrder.getChargingCapacity());
			}
			//获取该站点的所有充电桩
			List<TChargingPile> chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, record.getId()).list();
			BigDecimal bigDecimal1 = new BigDecimal("0");
			for (TChargingPile chargingPile : chargingPiles) {
				bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower());
			}
			BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24"));

			BigDecimal divide = bigDecimal.divide(multiply, 4, BigDecimal.ROUND_HALF_EVEN).multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_EVEN);
			record.setP1(divide);

		}
		return R.ok(list.getRecords());
	}
	
	
	@RequiresPermissions(value = {"/chargeDistribution"}, logical = Logical.OR)
	@GetMapping("/map/getPercent")
	@ApiOperation(value = "获取该充电站的利用率", tags = {"管理后台-数据分析-电站分析"})
	public R getPercent(Integer siteId){
		BigDecimal bigDecimal = new BigDecimal("0");
		//获取该站点的总充电度数
		List<TChargingOrder> chargingOrders = chargingOrderClient.getList(siteId).getData();
		for (TChargingOrder chargingOrder : chargingOrders) {
			bigDecimal = bigDecimal.add(chargingOrder.getChargingCapacity());
		}
		//获取该站点的所有充电桩
		List<TChargingPile> chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, siteId).list();
		BigDecimal bigDecimal1 = new BigDecimal("0");
		for (TChargingPile chargingPile : chargingPiles) {
			bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower());
		}
		BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24"));

		BigDecimal divide = bigDecimal.divide(multiply, 0, BigDecimal.ROUND_HALF_UP);


		return R.ok(divide);
	}

	


	
	
	
	@RequiresPermissions(value = {"/chargeDistribution"}, logical = Logical.OR)
	@PostMapping("/map/getPercentByprovinceCode")
	@ApiOperation(value = "获取该充电站的利用率", tags = {"管理后台-数据分析-电站分析"})
	public R getPercentByCityCode(@RequestBody ChargingPercentProvinceDto chargingPercentProvinceDto){
		Set<Integer> ids = null;
		//校验合作商权限
		SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
		Integer roleType = sysUser.getRoleType();
		Integer objectId = sysUser.getObjectId();
		R<Integer> admin = sysUserClient.isAdmin(SecurityUtils.getUserId());
		//合作商
		if(roleType == 2){
			ids = partnerService.authSite(objectId, SiteMenu.SITE_LIST);
		}else{
			//非管理员需要根据角色和用户配置查询允许的站点数据
			//改用roleId=1来判断
			if(admin.getData()!=1){
				List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();
				List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();
				if(data2.size() > 0){
					List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
					data.addAll(data1);
				}
				ids = new HashSet<>(data);
			}
		}
		chargingPercentProvinceDto.setSiteIds(ids);


		GetSiteList siteList = new GetSiteList();
		siteList.setProvinceCode(chargingPercentProvinceDto.getProvinceCode());
		siteList.setPageCurr(1);
		siteList.setPageCurr(9999);
		ChargingPercentBack chargingPercentBack = new ChargingPercentBack();

		//通过省编码获取充电站id
		List<GetSiteListDTO> records = siteService.getSiteList(siteList).getRecords();
		List<Integer> collect = records.stream().map(GetSiteListDTO::getId).collect(Collectors.toList());
		// 通过时间段获取和充电桩id获取各个充电站的充电订单
		if (chargingPercentProvinceDto.getDate1().equals(chargingPercentProvinceDto.getDate2())){
			chargingPercentProvinceDto.setDate2(chargingPercentProvinceDto.getDate1().plusDays(1));
		}
		List<ChargingOrderGroup> data = chargingOrderClient.getBySiteIdAndTime(chargingPercentProvinceDto).getData();
		// 计算利用率展示
		for (ChargingOrderGroup datum : data) {
			List<TChargingPile> chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, datum.getSiteId()).list();
			BigDecimal bigDecimal1 = new BigDecimal("0");
			for (TChargingPile chargingPile : chargingPiles) {
				bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower());
			}

			long daysBetween = ChronoUnit.DAYS.between(chargingPercentProvinceDto.getDate1(), chargingPercentProvinceDto.getDate2());
			BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24")).multiply(BigDecimal.valueOf(daysBetween));
			//得到利用率
			BigDecimal divide = datum.getChargingCapacity().divide(multiply, 0, BigDecimal.ROUND_HALF_UP);
			//如果利用率大于等于10
			if (divide.compareTo(BigDecimal.valueOf(10))>=0){
				chargingPercentBack.setCount1(chargingPercentBack.getCount1()+1);
			}

			//如果利用率大于等于5小于10
			if (divide.compareTo(BigDecimal.valueOf(5))>=0 && divide.compareTo(BigDecimal.valueOf(10))<0){
				chargingPercentBack.setCount2(chargingPercentBack.getCount2()+1);
			}
			//如果利用率大于等于1小于5
			if (divide.compareTo(BigDecimal.valueOf(1))>=0 && divide.compareTo(BigDecimal.valueOf(5))<0){
				chargingPercentBack.setCount3(chargingPercentBack.getCount3()+1);
			}
			//如果利用率小于1
			if (divide.compareTo(BigDecimal.valueOf(1))<0){
				chargingPercentBack.setCount4(chargingPercentBack.getCount4()+1);
			}

		}
		return R.ok(chargingPercentBack);
	}


	@GetMapping("/getSiteList1")
	@ApiOperation(value = "获取站点列表 不分页", tags = {"管理后台-活动费用统计"})
	public AjaxResult<List<Site>> getSiteList1(){
		return AjaxResult.success(siteService.list(new QueryWrapper<>()));
	}
	
	@RequiresPermissions(value = {"/systemUserManagement", "/site", "/faultInformationList", "/repairRecord", "/balanceSheetRecord", "/chargingPileOrder",
			"/chargeOrderMonitoring", "/chargingPile", "/chargingGun"}, logical = Logical.OR)
	@GetMapping("/getSiteListGun")
	@ApiOperation(value = "获取站点列表 不分页", tags = {"管理后台-接口信息使用"})
	public AjaxResult<List<Site>> getSiteListGun(){
		return AjaxResult.success(siteService.getSiteListGun());
	}
	
	
	@RequiresPermissions(value = {"/parkingLot/add", "/parkingLot/select", "/parkingLot/update"}, logical = Logical.OR)
	@GetMapping("/getSiteListParkLot")
	@ApiOperation(value = "获取站点列表不分页", tags = {"管理后台-停车场绑定"})
	public AjaxResult<List<Site>> getSiteListParkLot(){
		return AjaxResult.success(siteService.getSiteListParkLot());
	}
	
	
	
	@ApiOperation(value = "获取站点分页列表", tags = {"小程序-站点管理-首页"})
	@PostMapping("/pageList")
	public AjaxResult<PageInfo<SiteVO>> pageList(@Validated @RequestBody SiteQuery query, HttpServletRequest request){
		int isLogin = StringUtils.isEmpty(SecurityUtils.getToken(request)) ? 0 : 1;
		return AjaxResult.success(siteService.pageList(query,isLogin));
	}
	
	
	@ApiOperation(value = "获取站点列表", tags = {"小程序-站点管理-地图导航站点"})
	@PostMapping("/getMapSiteList")
	public AjaxResult<List<SiteVO>> getMapSiteList(@Validated @RequestBody SiteQuery query, HttpServletRequest request){
		int isLogin = StringUtils.isEmpty(SecurityUtils.getToken(request)) ? 0 : 1;
		return AjaxResult.success(siteService.getMapSiteList(query,isLogin));
	}
	
	
	@ApiOperation(value = "获取站点详细信息", tags = {"小程序-站点管理-站点详情"})
	@PostMapping("/getDetailById")
	public AjaxResult<SiteDetailVO> getDetailById(@Validated @RequestBody SiteDetailQuery query){
		SiteDetailVO siteDetailVO = siteService.getDetailById(query);
		// 查询合作商名称
		Partner partner = partnerService.getById(siteDetailVO.getPartnerId());
		if(Objects.nonNull(partner)){
			siteDetailVO.setPartnerName(partner.getName());
		}
		// 计算距离
//		Map<String, Double> distance = GeodesyUtil.getDistance(query.getLat() + "," + query.getLon(), siteDetailVO.getLat() + "," + siteDetailVO.getLon());
//		siteDetailVO.setDistance(distance.get("WGS84"));
		// 查询绑定车牌提示文案
		TParkingLot parkingLot = parkingLotService.getOne(Wrappers.lambdaQuery(TParkingLot.class)
				.eq(TParkingLot::getSiteId, query.getSiteId()));
		if(Objects.nonNull(parkingLot)){
			siteDetailVO.setRemark(parkingLot.getRemark());
		}
		return AjaxResult.success(siteDetailVO);
	}
	
	
	@ApiOperation(value = "获取站点下充电桩及充电枪列表", tags = {"小程序-站点管理-站点详情"})
	@GetMapping("/getChargingGunList")
	public AjaxResult<List<TChargingPileVO>> getChargingGunList(@RequestParam(value = "siteId")@ApiParam(value = "站点id", required = true)Integer siteId,
																@RequestParam(value = "type",required = false)@ApiParam(value = "类型 1=超充，2=快充，3=慢充")Integer type){
		return AjaxResult.success(chargingPileService.getChargingGunList(siteId,type));
	}

	@ApiOperation(value = "获取站点下充电枪数量统计", tags = {"管理后台-数据分析-电站分析"})
	@GetMapping("/getChargingGunCount")
	public AjaxResult<Map<String,ChargingGunCountVO>> getChargingGunCount(@RequestParam(value = "siteId")@ApiParam(value = "站点id", required = true)Integer siteId){
		return AjaxResult.success(chargingGunService.getChargingGunCount(siteId));
	}
	
	
	@ApiOperation(value = "获取站点下充电枪数量统计", tags = {"小程序-站点管理-站点详情"})
	@GetMapping("/getChargingGunCount1")
	public AjaxResult<Map<String,ChargingGunCountVO>> getChargingGunCount1(@RequestParam(value = "siteId")@ApiParam(value = "站点id", required = true)Integer siteId){
		return AjaxResult.success(chargingGunService.getChargingGunCount(siteId));
	}

	@RequiresPermissions(value = {"/site/add"}, logical = Logical.OR)
	@GetMapping("/importTemplate")
	@ApiOperation(value = "下载站点导入模板", tags = {"管理后台-站点管理"})
	public void importTemplate(HttpServletResponse response) {
		ExcelUtil<SiteExcelDTO> util = new ExcelUtil<>(SiteExcelDTO.class);
		util.importTemplateExcel(response, "站点导入模板",
				"填写说明：所在区域填写区县行政区划代码；带*字段为必填；合作商、服务商、场地方和计费模板填写系统中的完整名称。") ;
	}

	@RequiresPermissions(value = {"/site/add"}, logical = Logical.OR)
	@PostMapping("/import")
	@Log(title = "【站点管理】导入站点", businessType = BusinessType.IMPORT, operatorType = OperatorType.MANAGE)
	@ApiOperation(value = "导入站点", tags = {"管理后台-站点管理"})
	public AjaxResult importSites(@RequestParam("file") MultipartFile file,
			@RequestParam(value = "cover", defaultValue = "false") Boolean cover) throws Exception {
		SiteImportResultDTO result = siteService.importSites(file, cover);
		if (Boolean.TRUE.equals(result.getNeedConfirm())) {
			return AjaxResult.error("发现重复站点编号，请确认是否覆盖", result);
		}
		if (result.getErrorCount() != null && result.getErrorCount() > 0) {
			return AjaxResult.error("导入失败，请检查错误信息", result);
		}
		return AjaxResult.success("导入成功", result);
	}

	@RequiresPermissions(value = {"/site/export", "/site"}, logical = Logical.OR)
	@PutMapping("/export")
	@Log(title = "【站点管理】导出站点", businessType = BusinessType.EXPORT, operatorType = OperatorType.MANAGE)
	@ApiOperation(value = "导出站点", tags = {"管理后台-站点管理"})
	public void exportSites(@RequestBody GetSiteList query, HttpServletResponse response) {
		List<Site> sites = siteService.listSitesForExport(query);
		Set<Integer> partnerIds = sites.stream()
				.flatMap(site -> Arrays.asList(site.getPartnerId(), site.getVenuePartnerId()).stream())
				.filter(Objects::nonNull)
				.collect(Collectors.toSet());
		Map<Integer, String> partnerNames = partnerIds.isEmpty() ? Collections.emptyMap()
				: partnerService.listByIds(partnerIds).stream()
				.collect(Collectors.toMap(Partner::getId, Partner::getName, (a, b) -> a));
		Set<Integer> strategyIds = sites.stream().map(Site::getAccountingStrategyId)
				.filter(Objects::nonNull).collect(Collectors.toSet());
		Map<Integer, String> strategyNames = strategyIds.isEmpty() ? Collections.emptyMap()
				: accountingStrategyService.listByIds(strategyIds).stream()
				.collect(Collectors.toMap(TAccountingStrategy::getId, TAccountingStrategy::getName, (a, b) -> a));
		List<SiteExcelDTO> rows = sites.stream().map(site -> SiteExcelDTO.from(site,
				partnerNames.get(site.getPartnerId()), partnerNames.get(site.getVenuePartnerId()),
				strategyNames.get(site.getAccountingStrategyId()))).collect(Collectors.toList());
		new ExcelUtil<>(SiteExcelDTO.class).exportExcel(response, rows, "站点数据");
	}
	
	@RequiresPermissions(value = {"/site/add"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/addSite")
	@ApiOperation(value = "添加站点", tags = {"管理后台-站点管理"})
	@Log(title = "【站点管理】添加站点", businessType = BusinessType.INSERT)
	public AjaxResult addSite(@RequestBody Site site){
		return siteService.addSite(site);
	}
	
	
	
	@RequiresPermissions(value = {"/site/update"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/getSiteInfo/{id}")
	@ApiOperation(value = "获取站点详情", tags = {"管理后台-站点管理"})
	public AjaxResult<Site> getSiteInfo(@PathVariable Integer id){
		Site site = siteService.getById(id);
		return AjaxResult.success(site);
	}
	
	
	
		@RequiresPermissions(value = {"/site/update"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/getReservationSetting/{id}")
	@ApiOperation(value = "获取站点预约设置", tags = {"管理后台-站点管理"})
	public AjaxResult<Site> getReservationSetting(@PathVariable Integer id){
		Site site = siteService.lambdaQuery()
				.select(Site::getId, Site::getName, Site::getSupportOrder, Site::getReservationStartTime, Site::getReservationEndTime, Site::getReservationAheadMinute)
				.eq(Site::getId, id)
				.eq(Site::getDelFlag, 0)
				.one();
		return AjaxResult.success(site);
	}

	@RequiresPermissions(value = {"/site/update"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/saveReservationSetting")
	@ApiOperation(value = "保存站点预约设置", tags = {"管理后台-站点管理"})
	public AjaxResult saveReservationSetting(@RequestBody Site site){
		if (site == null || site.getId() == null) {
			return AjaxResult.error("站点id不能为空");
		}
		boolean success = siteService.lambdaUpdate()
				.eq(Site::getId, site.getId())
				.eq(Site::getDelFlag, 0)
				.set(Site::getSupportOrder, site.getSupportOrder())
				.set(Site::getReservationStartTime, site.getReservationStartTime())
				.set(Site::getReservationEndTime, site.getReservationEndTime())
				.set(Site::getReservationAheadMinute, site.getReservationAheadMinute())
				.update();
		return success ? AjaxResult.success() : AjaxResult.error("保存预约设置失败");
	}
@RequiresPermissions(value = {"/site/update"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/editSite")
	@ApiOperation(value = "编辑站点", tags = {"管理后台-站点管理"})
	@Log(title = "【站点管理】编辑站点", businessType = BusinessType.UPDATE)
	public AjaxResult editSite(@RequestBody Site site){
		return siteService.editSite(site);
	}
	
	
	
	@RequiresPermissions(value = {"/site/del", "/site/batch_del"}, logical = Logical.OR)
	@ResponseBody
	@DeleteMapping("/delSite")
	@ApiOperation(value = "删除站点", tags = {"管理后台-站点管理"})
	@ApiImplicitParams({
			@ApiImplicitParam(value = "站点id", name = "id", dataTypeClass = Integer.class, required = true)
	})
	@Log(title = "【站点管理】删除站点", businessType = BusinessType.DELETE)
	public AjaxResult delSite(@RequestParam("id") Integer[] id){
		return siteService.delSite(id);
	}
	
	
	
	@RequiresPermissions(value = {"/site/accounting_strategy"}, logical = Logical.OR)
	@ResponseBody
	@PostMapping("/setAccountingStrategy/{id}")
	@ApiOperation(value = "设置站点计费策略", tags = {"管理后台-站点管理"})
	@ApiImplicitParams({
			@ApiImplicitParam(value = "站点id", name = "id", dataTypeClass = Integer.class, required = true),
			@ApiImplicitParam(value = "计费策略id", name = "accountingStrategyId", dataTypeClass = Integer.class, required = true)
	})
	@Log(title = "【站点管理】设置站点计费策略", businessType = BusinessType.OTHER)
	public AjaxResult setAccountingStrategy(@PathVariable("id") Integer id, @RequestParam("accountingStrategyId") Integer accountingStrategyId){
		siteService.setAccountingStrategy(id, accountingStrategyId);
		return AjaxResult.success();
	}

	@RequiresPermissions(value = {"/site/accounting_strategy"}, logical = Logical.OR)
	@PostMapping("/batchSetAccountingStrategy")
	@ApiOperation(value = "批量设置站点计费策略", tags = {"管理后台-站点管理"})
	@Log(title = "【站点管理】批量设置站点计费策略", businessType = BusinessType.UPDATE)
	public AjaxResult batchSetAccountingStrategy(@RequestBody BatchSetSiteAccountingStrategyDTO request){
		if (request == null || CollectionUtils.isEmpty(request.getIds())) {
			return AjaxResult.error("请选择要设置计费策略的站点");
		}
		if (request.getAccountingStrategyId() == null) {
			return AjaxResult.error("请选择计费模板");
		}
		siteService.batchSetAccountingStrategy(request.getIds(), request.getAccountingStrategyId());
		return AjaxResult.success();
	}
	
	
	@RequiresPermissions(value = {"/roleManagement/add", "/roleManagement/info", "/roleManagement/update", "/systemNotification", "/chargingPeriodStatistics",
			"/parkingPaymentOrder", "/generateStatement", "/chargingPile/add", "/chargingPile/select", "/chargingPile/update",
			"/appUserWhitelist/add", "/appUserWhitelist/update", "/appUserWhitelist/import"}, logical = Logical.OR)
	@ResponseBody
	@GetMapping("/getAllSiteList")
	@ApiOperation(value = "获取所有站点数据", tags = {"管理后台-充电桩信息", "管理后台-系统用户管理", "管理后台-角色管理", "管理后台-系统通知", "管理后台-充电评价"})
	public AjaxResult<List<Site>> getAllSiteList(){
		//校验当前账户站点权限
		SysUser sysUser = sysUserClient.getSysUser(tokenService.getLoginUser().getUserid()).getData();
		Integer roleType = sysUser.getRoleType();
		Integer objectId = sysUser.getObjectId();
		LambdaQueryWrapper<Site> wrapper = new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0);
		if(2 == roleType){
			Set<Integer> list = partnerService.authSite(objectId, SiteMenu.SITE_LIST);
			wrapper.in(Site::getId, list);
		}else{
			//非管理员需要根据角色和用户配置查询允许的站点数据
			if(!SecurityUtils.isAdmin(tokenService.getLoginUser().getUserid())){
				List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();
				List<SysUserRoleVo> data2 = userRoleClient.getRoleByUserId(sysUser.getUserId()).getData();
				List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
				data.addAll(data1);
				Set<Integer> list = new HashSet<>(data);
				wrapper.in(Site::getId, list);
			}
		}
		List<Site> list = siteService.list(wrapper.orderByDesc(Site::getCreateTime));
		return AjaxResult.success(list);
	}
	
	
	/**
	 * 获取站点数据集合
	 * @param ids
	 * @return
	 */
	@ResponseBody
	@PostMapping("/getSiteByIds")
	public R<List<Site>> getSiteByIds(@RequestBody List<Integer> ids){
		if (CollectionUtils.isEmpty(ids)) {
			return R.ok(Collections.emptyList());
		}
		List<Site> sites = siteService.list(new LambdaQueryWrapper<Site>().in(Site::getId, ids).eq(Site::getDelFlag, 0));
		return R.ok(sites);
	}

	@GetMapping("/getSitesByIds")
	@ApiOperation(value = "小程序批量获取站点基础信息", tags = {"小程序-收藏"})
	public R<List<Site>> getSitesByIds(@RequestParam String ids) {
		List<Integer> siteIds = Arrays.stream(ids.split(","))
				.filter(StringUtils::isNotEmpty)
				.map(Integer::valueOf)
				.collect(Collectors.toList());
		if (siteIds.isEmpty()) {
			return R.ok(Collections.emptyList());
		}
		return R.ok(siteService.list(new LambdaQueryWrapper<Site>()
				.in(Site::getId, siteIds)
				.eq(Site::getDelFlag, 0)));
	}

	@PostMapping("/favoriteSitePrices")
	@ApiOperation(value = "批量获取收藏站点当前价格", tags = {"内部接口-收藏"})
	public R<List<FavoriteSitePriceVO>> favoriteSitePrices(@RequestBody List<Integer> ids) {
		if (CollectionUtils.isEmpty(ids)) {
			return R.ok(Collections.emptyList());
		}
		List<Site> sites = siteService.list(new LambdaQueryWrapper<Site>()
				.in(Site::getId, ids)
				.eq(Site::getDelFlag, 0));
		List<FavoriteSitePriceVO> result = sites.stream().map(site -> {
			FavoriteSitePriceVO vo = new FavoriteSitePriceVO();
			vo.setSiteId(site.getId());
			vo.setSiteName(site.getName());
			vo.setStatus(site.getStatus());
			vo.setCurrentPrice(getCurrentSitePrice(site));
			return vo;
		}).collect(Collectors.toList());
		return R.ok(result);
	}

	private BigDecimal getCurrentSitePrice(Site site) {
		if (site.getAccountingStrategyId() == null) {
			return null;
		}
		LocalTime now = LocalTime.now();
		List<TAccountingStrategyDetail> details = accountingStrategyDetailService.lambdaQuery()
				.eq(TAccountingStrategyDetail::getAccountingStrategyId, site.getAccountingStrategyId())
				.list();
		for (TAccountingStrategyDetail detail : details) {
			LocalTime start = parsePriceTime(detail.getStartTime(), false);
			LocalTime end = parsePriceTime(detail.getEndTime(), true);
			if (start != null && end != null && !now.isBefore(start) && !now.isAfter(end)) {
				return detail.getElectrovalence().add(detail.getServiceCharge())
						.setScale(4, BigDecimal.ROUND_HALF_UP);
			}
		}
		return null;
	}

	private LocalTime parsePriceTime(String value, boolean endTime) {
		if (StringUtils.isEmpty(value)) {
			return null;
		}
		if (endTime && "00:00".equals(value)) {
			return LocalTime.of(23, 59, 59);
		}
		return LocalTime.parse(value.length() == 5 ? value + ":00" : value);
	}
	
	
	/**
	 * 获取所有站点数据
	 * @return
	 */
	@ResponseBody
	@PostMapping("/getSiteAll")
	public R<List<Site>> getSiteAll(){
		List<Site> list = siteService.list(new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0));
		return R.ok(list);
	}
	
	
	/**
	 * 分页查询站电数据
	 * @param PageNo
	 * @param PageSize
	 * @return
	 */
	@PostMapping("/getSiteListPaging")
	public PageInfo<Site> getSiteListPaging(@RequestParam("PageNo") Integer PageNo, @RequestParam("PageSize") Integer PageSize,
	                                        @RequestParam("ids") List<String> ids, @RequestParam("isOpenSynchronization") Integer isOpenSynchronization){
		PageInfo<Site> pageInfo = new PageInfo<>(PageNo, PageSize);
		PageInfo<Site> page = siteService.lambdaQuery().eq(Site::getStatus, 1)
				.in(ids.size() > 0, Site::getId, ids)
				.eq(-1 != isOpenSynchronization, Site::getIsOpenSynchronization, isOpenSynchronization)
				.ne(Site::getSiteType, 2).page(pageInfo);
		return page;
	}
	/**
	 * 分页查询站电数据
	 * @param PageNo
	 * @param PageSize
	 * @return
	 */
	@PostMapping("/getSiteListPagingJianGuan")
	public PageInfo<Site> getSiteListPagingJianGuan(@RequestParam("PageNo") Integer PageNo, @RequestParam("PageSize") Integer PageSize,
	                                        @RequestParam("ids") List<String> ids){
		PageInfo<Site> pageInfo = new PageInfo<>(PageNo, PageSize);
		PageInfo<Site> page = siteService.lambdaQuery().eq(Site::getStatus, 1).in(ids.size() > 0, Site::getId, ids).page(pageInfo);
		return page;
	}
}