package com.hivekion.room.bean;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.extra.spring.SpringUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.hivekion.Global;
import com.hivekion.common.entity.ResponseCmdInfo;
import com.hivekion.common.redis.RedisUtil;
import com.hivekion.common.uuid.IdUtils;
import com.hivekion.room.RoomManager;
import com.hivekion.scenario.entity.BattleConsume;
import com.hivekion.scenario.entity.ScenarioTask;
import com.hivekion.scenario.service.IBattleConsumeService;
import com.hivekion.statistic.bean.*;
import com.hivekion.statistic.service.StatisticService;
import com.hivekion.statistic.service.impl.StatisticServiceImpl;
import com.hivekion.supplier.entity.SupplierRequest;
import com.hivekion.supplier.service.ISupplierRequestService;
import java.util.concurrent.atomic.AtomicBoolean;
import lombok.extern.slf4j.Slf4j;
import org.springframework.core.env.Environment;
import org.springframework.util.CollectionUtils;

import javax.swing.*;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.*;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * [类的简要说明]
 * <p>
 * [详细描述，可选]
 * <p>
 *
 * @author LiDongYU
 * @since 2025/7/22
 */
@Slf4j
public class BattleRootTask extends AbtParentTask  {

  private RedisUtil redisUtil = null;

  private ISupplierRequestService supplierRequestService;

  private IBattleConsumeService battleConsumeService;


  private static final Double FOOD_SPREED = 0.3D;
  private static final Double WATER_SPREED = 0.1D;
//  private static final Double FUEL_SPREED = 3.6D;
  private static final Double MEDICAL_SPREED = 0.2D;

 private final AtomicBoolean isAlreadyProduceTask = new AtomicBoolean(false);

  public BattleRootTask(ScenarioTask scenarioTask,String roomId) {
    super(scenarioTask,roomId);
  }

  private void initBean(){

    if(redisUtil == null) {
      redisUtil = SpringUtil.getBean(RedisUtil.class);
    }
    if(supplierRequestService == null){
      supplierRequestService = SpringUtil.getBean(ISupplierRequestService.class);
    }
    if(battleConsumeService == null){
      battleConsumeService = SpringUtil.getBean(IBattleConsumeService.class);
    }
  }
  //执行一次
  @Override
  public void doSomeThing() {
    log.info("===============begin BattleRootTask=========={}==========",this.getRoomStatus());
    this.initBean();
    if(this.getRoomStatus()) {
      long initDuringTime = this.getDuringTime();
      redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),"duringTime",String.valueOf(initDuringTime));
      String jsonStr = (String)redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),"scenarioInfo");
      ScenarioInfo scenarioInfo =JSONObject.parseObject(jsonStr,ScenarioInfo.class);

      log.info("===============================初始化本次战斗任务各种资源数====================================");
      double suppleAmount =scenarioInfo.getAmmunition().getTotal();
      int suppleDeath =scenarioInfo.getPerson().getDeath();
      int suppleInjured =scenarioInfo.getPerson().getInjured();
      final  Map<String,Boolean>  suppleFlagMap = new HashMap<>();
      suppleFlagMap.put("ammunition",false);
      suppleFlagMap.put("death",false);
      suppleFlagMap.put("injured",false);
      //定时检查统计各种资源消耗量
      this.createBattleTaskOnTimingHandle(new BizTaskOnTiming() {
        @Override
        public void execTask() {
          log.info("===============================定时检查统计各种资源消耗量 begin====================================");
          Long deathConsume = null;
          Long injuredConsume = null;
          Double ammunitionConsume = null;
          Double foodConsume = null;
          Double waterConsume = null;
//          Double fuelConsume = null;
          Double medicalConsume = null;
          String teamLat = null;
          String teamLng = null;
          JSONObject jsonObject = new JSONObject();
          String jsonStr = (String)redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),"scenarioInfo");
          ScenarioInfo scenarioInfoOnTime =JSONObject.parseObject(jsonStr,ScenarioInfo.class);

          try {

            long duringTime = getDuringTime();
            long lastDuringTime = Long.valueOf(redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),"duringTime").toString());
            long intervalDuringTime = duringTime - lastDuringTime;
            double ammunition = Double.valueOf(scenarioInfoOnTime.getAmmunition().getCurrent());
            double food = Double.valueOf(scenarioInfoOnTime.getFood().getCurrent());
            double medical = Double.valueOf(scenarioInfoOnTime.getMedical().getCurrent());
            double water = Double.valueOf(scenarioInfoOnTime.getWater().getCurrent());
            long death = Long.valueOf(scenarioInfoOnTime.getPerson().getDeath());
            long injured = Long.valueOf(scenarioInfoOnTime.getPerson().getInjured());
            teamLat = scenarioInfoOnTime.getTeam().getLat().toString();
            teamLng = scenarioInfoOnTime.getTeam().getLng().toString();
            if(scenarioInfoOnTime.getPerson().getCurrent() >0) {
              //
              deathConsume = RandomUtil.getSecureRandom().nextInt(2) * intervalDuringTime* RoomManager.getMag(roomId);
              injuredConsume = RandomUtil.getSecureRandom().nextInt(3) * intervalDuringTime* RoomManager.getMag(roomId);
              ammunitionConsume = intervalDuringTime * (0.1D + RandomUtil.getSecureRandom().nextDouble())* RoomManager.getMag(roomId);
              foodConsume = intervalDuringTime * FOOD_SPREED* RoomManager.getMag(roomId);
              waterConsume = intervalDuringTime * WATER_SPREED* RoomManager.getMag(roomId);

              medicalConsume = intervalDuringTime * MEDICAL_SPREED* RoomManager.getMag(roomId);


              if(scenarioInfoOnTime.getAmmunition().getCurrent() >0) {
                scenarioInfoOnTime.getAmmunition().setCurrent(Double.valueOf(ammunition - ammunitionConsume));
              }
              if(scenarioInfoOnTime.getFood().getCurrent() > 0) {
                scenarioInfoOnTime.getFood().setCurrent(Double.valueOf(food - foodConsume));
              }
              if(scenarioInfoOnTime.getMedical().getCurrent() > 0) {
                scenarioInfoOnTime.getMedical().setCurrent(Double.valueOf(medical - medicalConsume));
              }
              if(scenarioInfoOnTime.getWater().getCurrent() > 0) {
                scenarioInfoOnTime.getWater().setCurrent(Double.valueOf(water - waterConsume));
              }
              scenarioInfoOnTime.getPerson().setDeath(Long.valueOf(death + deathConsume).intValue());
              scenarioInfoOnTime.getPerson().setInjured(Long.valueOf(injured + injuredConsume).intValue());
              scenarioInfoOnTime.getPerson().setCurrent(scenarioInfo.getPerson().getCurrent() - Long.valueOf(deathConsume).intValue()-Long.valueOf(injuredConsume).intValue());

              String updJsonStr = (String) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "updScenarioInfo");
              EditScenarioInfo updScenarioInfo = JSON.parseObject(updJsonStr, EditScenarioInfo.class);
              if(updScenarioInfo.getJbxx().getAmmunition().getCurrent() >0) {
                updScenarioInfo.getJbxx().getAmmunition().setCurrent(Double.valueOf(ammunition - ammunitionConsume));
              }
              if(updScenarioInfo.getJbxx().getFood().getCurrent() > 0) {
                updScenarioInfo.getJbxx().getFood().setCurrent(Double.valueOf(food - foodConsume));
              }
//            updScenarioInfo.getJbxx().getFuel().setCurrent(Double.valueOf(fuel - fuelConsume));
              if(updScenarioInfo.getJbxx().getMedical().getCurrent() > 0) {
                updScenarioInfo.getJbxx().getMedical().setCurrent(Double.valueOf(medical - medicalConsume));
              }
              if(updScenarioInfo.getJbxx().getWater().getCurrent() > 0) {
                updScenarioInfo.getJbxx().getWater().setCurrent(Double.valueOf(water - waterConsume));
              }
              updScenarioInfo.getJbxx().getPerson().setDeath(Long.valueOf(death + deathConsume).intValue());
              updScenarioInfo.getJbxx().getPerson().setInjured(Long.valueOf(injured + injuredConsume).intValue());
              updScenarioInfo.getJbxx().getPerson().setCurrent(updScenarioInfo.getJbxx().getPerson().getCurrent() - Long.valueOf(deathConsume).intValue()-Long.valueOf(injuredConsume).intValue());
              redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
                      "updScenarioInfo", JSON.toJSONString(updScenarioInfo));
              ResponseCmdInfo<String> respObj = new ResponseCmdInfo<>();
              respObj.setData(JSON.toJSONString(updScenarioInfo));
              respObj.setRoom(roomId);
              respObj.setScenarioId(scenarioTask.getScenarioId());
              respObj.setCmdType("updScenarioInfo");
              Global.sendCmdInfoQueue.add(respObj);
              redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "duringTime", String.valueOf(duringTime));
              redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "scenarioInfo", JSONObject.toJSONString(scenarioInfoOnTime));
            }
          }catch (Exception ex){
            ex.printStackTrace();
            log.error("==============================设置消耗信息失败=============================================",ex.getMessage());
          }
          try {
            if(scenarioInfoOnTime.getPerson().getCurrent() >0) {
              //推送消耗數據
              String battleConsumeStr = "";
              ResponseCmdInfo<String> sendConsumeMsg = new ResponseCmdInfo<>();
              LocalDateTime currentDateTime = new Date().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
              battleConsumeStr += currentDateTime.toString() + " 战斗消耗 [";
              battleConsumeStr += "死亡人数:" + deathConsume;
              battleConsumeStr += "受伤人数:" + injuredConsume;
              battleConsumeStr += "弹药消耗:" + ammunitionConsume;
              battleConsumeStr += "食品消耗:" + foodConsume;
              battleConsumeStr += "用水消耗:" + waterConsume;
              battleConsumeStr += "药材消耗:" + medicalConsume + "]";
              jsonObject.put("teamLat",teamLat);
              jsonObject.put("teamLng",teamLng);
              jsonObject.put("resourceId", scenarioTask.getResourceId());

              jsonObject.put("消耗时间", currentDateTime);
              jsonObject.put("日志类型", "战斗消耗");

              sendConsumeMsg.setData(battleConsumeStr);
              sendConsumeMsg.setRoom(roomId);
              sendConsumeMsg.setScenarioId(scenarioTask.getScenarioId());
              sendConsumeMsg.setCmdType("battleConsume");
              Global.sendCmdInfoQueue.add(sendConsumeMsg);
              BattleConsume battleConsume = new BattleConsume();
              battleConsume.setLat(teamLat);
              battleConsume.setLng(teamLng);
              battleConsume.setId(IdUtils.simpleUUID());
              battleConsume.setAmmunition(ammunitionConsume);
              battleConsume.setDeath(Integer.valueOf(Double.valueOf(deathConsume).intValue()));
              battleConsume.setInjured(Integer.valueOf(Double.valueOf(injuredConsume).intValue()));
              battleConsume.setFood(foodConsume);
//            battleConsume.setFuel(fuelConsume);
              battleConsume.setMedical(medicalConsume);
              battleConsume.setWater(waterConsume);
              battleConsume.setResourceId(scenarioTask.getResourceId());
              battleConsume.setConsumeDate(currentDateTime);
              battleConsumeService.save(battleConsume);
              if (injuredConsume > 2 && !isAlreadyProduceTask.get()) {
                //产生一个

              }
            }
          }catch (Exception ex){
            ex.printStackTrace();
            log.error("==================推送消耗數據 失败============================================",ex.getMessage());
          }

          try {
            if(scenarioInfoOnTime.getPerson().getCurrent() >0) {
              LocalDateTime currentDateTime = new Date().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
              String death = SpringUtil.getBean(Environment.class).getProperty("death.warn");
              String injured = SpringUtil.getBean(Environment.class).getProperty("injured.warn");
              String ammunition = SpringUtil.getBean(Environment.class).getProperty("ammunition.warn");
              log.info("===========person ammunition==={}===={}====={}========", death, injured, ammunition);

              Double restAmmunition = Double.valueOf(scenarioInfoOnTime.getAmmunition().getCurrent());
//            StatisticBean battleResourceStat = statisticService.statistic(scenarioTask.getResourceId());
              Double ammunitionConsumeRate = restAmmunition / scenarioInfoOnTime.getAmmunition().getTotal() * 100;
              if (Double.valueOf(ammunitionConsumeRate) <= Double.valueOf(ammunition) && suppleFlagMap.get("ammunition") == false) {
                SupplierRequest supplierRequest = new SupplierRequest();
                supplierRequest.setId(IdUtils.simpleUUID());
                supplierRequest.setFromResourceId(scenarioTask.getResourceId());
                supplierRequest.setSupplierNum(String.valueOf(suppleAmount));
                supplierRequest.setSupplierType("ammunition");
                supplierRequest.setGeneralTime(currentDateTime);
                supplierRequest.setLat(jsonObject.get("teamLat").toString());
                supplierRequest.setLng(jsonObject.get("teamLng").toString());
                supplierRequestService.save(supplierRequest);
                ResponseCmdInfo<String> respObj = new ResponseCmdInfo<>();
                respObj.setData(JSON.toJSONString(supplierRequest));
                respObj.setRoom(roomId);
                respObj.setScenarioId(scenarioTask.getScenarioId());
                respObj.setCmdType("ammunitionRequest");
                Global.sendCmdInfoQueue.add(respObj);
                suppleFlagMap.put("ammunition", true);
              }
              Long restDeath = Long.valueOf(scenarioInfo.getPerson().getDeath());
              Long deathConsumeRate = 0L;
              if (scenarioInfo.getPerson().getTotal() != 0) {
                deathConsumeRate = restDeath * 100 / scenarioInfoOnTime.getPerson().getTotal();
              }
              if (deathConsumeRate >= Long.valueOf(death) && suppleFlagMap.get("death") == false) {
                SupplierRequest supplierRequest = new SupplierRequest();
                supplierRequest.setId(IdUtils.simpleUUID());
                supplierRequest.setFromResourceId(scenarioTask.getResourceId());
                supplierRequest.setSupplierNum(String.valueOf(suppleDeath));
                supplierRequest.setSupplierType("death");
                supplierRequest.setGeneralTime(currentDateTime);
                supplierRequest.setLat(jsonObject.get("teamLat").toString());
                supplierRequest.setLng(jsonObject.get("teamLng").toString());
                supplierRequestService.save(supplierRequest);
                ResponseCmdInfo<String> respObj = new ResponseCmdInfo<>();
                respObj.setData(JSON.toJSONString(supplierRequest));
                respObj.setRoom(roomId);
                respObj.setScenarioId(scenarioTask.getScenarioId());
                respObj.setCmdType("deathRequest");
                Global.sendCmdInfoQueue.add(respObj);
                suppleFlagMap.put("death", true);
              }
              Long restInjured = Long.valueOf(scenarioInfoOnTime.getPerson().getInjured());
              Long injuredConsumeRate = restInjured * 100 / scenarioInfoOnTime.getPerson().getTotal();
              if (Long.valueOf(injuredConsumeRate) <= Long.valueOf(injured) && suppleFlagMap.get("injured") == false) {
                SupplierRequest supplierRequest = new SupplierRequest();
                supplierRequest.setId(IdUtils.simpleUUID());
                supplierRequest.setFromResourceId(scenarioTask.getResourceId());
                supplierRequest.setSupplierNum(String.valueOf(suppleInjured));
                supplierRequest.setSupplierType("injured");
                supplierRequest.setGeneralTime(currentDateTime);
                supplierRequest.setLat(jsonObject.get("teamLat").toString());
                supplierRequest.setLng(jsonObject.get("teamLng").toString());
                supplierRequestService.save(supplierRequest);
                ResponseCmdInfo<String> respObj = new ResponseCmdInfo<>();
                respObj.setData(JSON.toJSONString(supplierRequest));
                respObj.setRoom(roomId);
                respObj.setScenarioId(scenarioTask.getScenarioId());
                respObj.setCmdType("injuredRequest");
                Global.sendCmdInfoQueue.add(respObj);
                suppleFlagMap.put("injured", true);
              }
            }
          }catch (Exception ex){
            ex.printStackTrace();
            log.error("===========BattleRootTask supplierRequestService.saveBatch error====================",ex.getMessage());
          }
          log.info("===============================定时检查统计各种资源消耗量 end====================================");
        }
      });

    }

  }




}