package com.ruoyi.chargingPile.tulaidian.controller;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.chargingPile.api.model.TChargingGun;
import com.ruoyi.chargingPile.service.ISiteService;
import com.ruoyi.chargingPile.service.TChargingGunService;
import com.ruoyi.chargingPile.service.TChargingPileService;
import com.ruoyi.chargingPile.tulaidian.domain.ChargeRecord;
import com.ruoyi.chargingPile.tulaidian.domain.ChargeStatus;
import com.ruoyi.chargingPile.tulaidian.domain.ConnectorStatusInfos;
import com.ruoyi.chargingPile.tulaidian.domain.TContent;
import com.ruoyi.chargingPile.tulaidian.service.IContentService;
import com.ruoyi.chargingPile.tulaidian.util.AesEncryption;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.utils.DateUtils;
import com.ruoyi.order.api.feignClient.ChargingOrderClient;
import com.ruoyi.order.api.model.TChargingOrder;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.math.BigDecimal;
import java.text.ParseException;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;

/**
 * 广告控制器
 */
@Api
@RestController
@RequestMapping("/orderCallBack")
public class NotifyController {
    @Autowired
    private ChargingOrderClient chargingOrderClient;
    @Autowired
    private IContentService contentService;
    @Autowired
    private TChargingGunService chargingGunService;
    @Autowired
    private TChargingPileService chargingPileService;
    @Autowired
    private ISiteService siteService;
    private static final String OperatorID = "MA01H3BQ3";
    private static final String OperatorSecret = "f1331ef0b37c2d2";
    private static final String SigSecret = "a6fedf0e1b27d6f8";
    private static final String DataSecret = "50a61b93919c9606";
    private static final String DataSecretIV = "7c8ac6861661d586";

    private static final String OperatorSecretOther = "f1331ef0b37c2d2";
    private static final String SigSecretOther = "a6fedf0e1b27d6f8";
    private static final String DataSecretOther = "50a61b93919c9606";
    private static final String DataSecretIVOther = "7c8ac6861661d586";

    // 结束充电后 特来电主动 推送充电订单信息
    @ResponseBody
    @PostMapping("/notification_charge_order_info")
    public Map<String, Object> notification_charge_order_info(@RequestBody String json) throws ParseException {
        TContent tContent = new TContent();
        tContent.setType(1);
        tContent.setContent(json);
        tContent.setCreateTime(new Date());
        contentService.save(tContent);
        JSONObject jsonObject1 = JSONObject.parseObject(json);
        String data = jsonObject1.getString("Data");
        String decrypt = AesEncryption.decrypt(DataSecret, DataSecretIV, data);
        System.err.println(decrypt);
        JSONObject jsonObject = JSONObject.parseObject(decrypt);
        System.err.println("结束充电后 特来电主动推送订单信息");
        ChargeRecord chargeRecord = JSON.parseObject(jsonObject.toJSONString(), ChargeRecord.class);
        // 新增订单
        TChargingOrder chargingOrder = new TChargingOrder();
        chargingOrder.setCode(chargeRecord.getStartChargeSeq());
        chargingOrder.setOrderSource(2);
        // TODO 运营商id
        chargingOrder.setOperatorId(1);
        chargingOrder.setTripartitePlatformName("途来电");
        chargingOrder.setStartChargeSeq(chargeRecord.getStartChargeSeq());
        chargingOrder.setSourceName("途来电");
        chargingOrder.setStartTime(DateUtils.stringToLocalDateTime(chargeRecord.getStartTime()));
        chargingOrder.setEndTime(DateUtils.stringToLocalDateTime(chargeRecord.getEndTime()));
        chargingOrder.setStatus(5);
        chargingOrder.setEndMode(1);
        chargingOrder.setElectrovalence(chargeRecord.getTotalElecMoney());
        chargingOrder.setServiceCharge(chargeRecord.getTotalSeviceMoney());
        chargingOrder.setTotalElectricity(chargeRecord.getTotalPower());
        chargingOrder.setPaymentAmount(chargeRecord.getTotalMoney());
        chargingOrder.setRechargePaymentType(1);
        chargingOrder.setRechargePaymentStatus(2);
        chargingOrder.setChargeAmount(chargeRecord.getTotalMoney());
        chargingOrder.setOrderAmount(chargeRecord.getTotalMoney());
        chargingOrder.setResidualAmount(BigDecimal.ZERO);
        chargingOrder.setPaymentAmount(chargeRecord.getTotalMoney());
        chargingOrder.setPayTime(LocalDateTime.now());
        // 通过枪编号查询枪
        TChargingGun chargingGun = chargingGunService.getOne(Wrappers.lambdaQuery(TChargingGun.class)
                .eq(TChargingGun::getCode, chargeRecord.getConnectorID()));
        if(Objects.nonNull(chargingGun)){
            chargingOrder.setChargingGunId(chargingGun.getId());
            chargingOrder.setChargingPileId(chargingGun.getChargingPileId());
            chargingOrder.setSiteId(chargingGun.getSiteId());
        }
        R<Long> orderIdR = chargingOrderClient.addChargingOrder(chargingOrder);
        if(orderIdR.getCode() == 200){
            // TODO 充电明细
        }
        Map<String,Object> map = new HashMap<>();
        map.put("StartChargeSeq",chargeRecord.getStartChargeSeq());
        map.put("ConnectorID",chargeRecord.getConnectorID());
        map.put("ConfirmResult",0);
        return map;
    }

//    @ResponseBody
//    @PostMapping("/notification_equip_charge_status")
//    public R notification_equip_charge_status(@RequestBody String json) throws ParseException {
//        TContent tContent = new TContent();
//        tContent.setType(2);
//        tContent.setContent(json);
//        tContent.setCreateTime(new Date());
//        contentService.save(tContent);
//        JSONObject jsonObject1 = JSONObject.parseObject(json);
//        String data = jsonObject1.getString("Data");
//        String decrypt = AesEncryption.decrypt(DataSecret, DataSecretIV, data);
//        System.err.println(decrypt);
//        JSONObject jsonObject = JSONObject.parseObject(decrypt);
//        System.err.println("特来电主动推送订单状态");
//        ChargeStatus chargeStatus = JSON.parseObject(jsonObject.toJSONString(), ChargeStatus.class);
//        R<TChargingOrder> chargeOrderR = chargingOrderClient.getChargingOrderByStartChargeSeq(chargeStatus.getStartChargeSeq());
//        TChargingOrder chargingOrder = chargeOrderR.getData();
//        if (chargingOrder!=null){
//            // 修改订单状态
//            chargingOrder.setStatus(chargeStatus.getStartChargeSeqStat());
//            chargingOrderClient.updateChargingOrder(chargingOrder);
//        }
//        return R.ok();
//    }

    @ResponseBody
    @PostMapping("/notification_stationStatus")
    public Map<String,Integer> notification_stationStatus(@RequestBody String json) {
        TContent tContent = new TContent();
        tContent.setType(3);
        tContent.setContent(json);
        tContent.setCreateTime(new Date());
        contentService.save(tContent);
        JSONObject jsonObject1 = JSONObject.parseObject(json);
        String data = jsonObject1.getString("Data");
        String decrypt = AesEncryption.decrypt(DataSecret, DataSecretIV, data);
        System.err.println(decrypt);
        JSONObject jsonObject = JSONObject.parseObject(decrypt);
        System.err.println("特来电主动推送设备状态");
        ConnectorStatusInfos connectorStatusInfos = JSON.parseObject(jsonObject.toJSONString(), ConnectorStatusInfos.class);
        TChargingGun chargingGun = chargingGunService.getOne(Wrappers.lambdaQuery(TChargingGun.class)
                .eq(TChargingGun::getCode, connectorStatusInfos.getConnectorID()));
        if (Objects.nonNull(chargingGun)){
            // 修改订单状态
            switch (connectorStatusInfos.getStatus()){
                case 0:
                    chargingGun.setStatus(1);
                    break;
                case 1:
                    chargingGun.setStatus(2);
                    break;
                case 2:
                    chargingGun.setStatus(3);
                    break;
                case 3:
                    chargingGun.setStatus(4);
                    break;
                case 4:
                    chargingGun.setStatus(6);
                    break;
                case 255:
                    chargingGun.setStatus(7);
                    break;
            }
            chargingGunService.updateById(chargingGun);
        }
        Map<String,Integer> map = new HashMap<>();
        map.put("Status",0);
        return map;
    }
}