<?php

namespace app\controller;

use app\common;
use app\model\EnterpriseUser;
use app\model\ServiceFee;
use app\Request;
use think\facade\Cache;
use think\facade\Db;
use think\facade\Log;
use think\response\Json;

/**
 * 特来电对接
 * https://ion.teld.cn/document
 */
class HardMessage extends common
{


    /**
     * 查询充电站信息query_stations_info
     * @param $PageNo
     * @return string
     */
    public function Get_stations_info($PageNo = 1)
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }

        $kk = [
            'LastQueryTime' => '',
            'PageNo' => $PageNo,
            'PageSize' => 10,
        ];
        $en = $this->Encrypt(json_encode($kk));


        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);

        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];

        $message = $this->CurlSend(config('hard.url') . '/query_stations_info', $data, $token);
        $de_data = $this->Decrypt($message['Data']);
        $array = json_decode($de_data, true);
//        dd($array);


        foreach ($array['StationInfos'] as $station_arr) {
            $station_arr1 = (array)$station_arr;

            $station_arr1 = array_diff_key($station_arr1, ["EquipmentInfos" => 'xy', "CtrlsInfos" => 'xy']);
            $check = Db::table('stationinfo_slow')->where('StationID', $station_arr1['StationID'])->find();
            if (!$check) {
                Db::table('stationinfo_slow')->save($station_arr1);
            }

            foreach ($station_arr['EquipmentInfos'] as $equipment_arr) {
                $equipment_arr1 = (array)$equipment_arr;
                $equipment_arr1 = array_diff_key($equipment_arr1, ["ConnectorInfos" => 'xy']);
                $equipment_arr1['StationID'] = $station_arr['StationID'];
                $check = Db::table('equipmentinfo_slow')->where('EquipmentID', $equipment_arr1['EquipmentID'])->find();
                if (!$check) {
                    Db::table('equipmentinfo_slow')->save($equipment_arr1);
                }
                foreach ($equipment_arr['ConnectorInfos'] as $connector_arr) {
                    $connector_arr = (array)$connector_arr;
                    $connector_arr['EquipmentID'] = $equipment_arr['EquipmentID'];
                    $check = Db::table('connectorinfo_slow')->where('ConnectorID', $connector_arr['ConnectorID'])->find();
                    if (!$check) {
                        Db::table('connectorinfo_slow')->save($connector_arr);
                    }
                }
            }
        }
        return 'OK';
    }


    public function query_token()
    {
        $TimeStamp = '';
        $Seq = '';
        $OperatorSecret = config('hard.OperatorSecret');
        $params = file_get_contents('php://input');

        Db::table('charge_logo')->save(['name' => 'query_token', 'mark' => $params]);

        $params = json_decode($params, true);
        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $checkParams = $this->checkParams($params);
        if ($checkParams != 2) {
            return json(['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]]);
        }
        $checkSig = $this->checkSig($OperatorID, $params);
        if ($checkSig == 1) {
            $data = json_encode(['OperatorID' => $OperatorID, 'SuccStat' => 1, 'FailReason' => 4]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '签名错误', 'Ret' => 4001, 'Data' => $data, 'Sig' => $s]);
        }
        $data = $this->Decrypt($params['Data']);
        $datas = json_decode($data, true);
        if (isset($datas['OperatorID']) && isset($datas['OperatorSecret'])) {
            if (($datas['OperatorID'] == $OperatorID) && ($datas['OperatorSecret'] == $OperatorSecret)) {
                $AccessToken = $this->signToken();
                Cache::set('accesstoken', $AccessToken, 7200);
                $strr = ['OperatorID' => $OperatorID, 'SuccStat' => 0, 'AccessToken' => $AccessToken,
                    'TokenAvailableTime' => 7200, 'FailReason' => 0];
                $data = json_encode($strr);
                $data = $this->Encrypt($data);
                $seq = empty($Seq) ? '0001' : $params['Seq'];
                $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
                $sig = $OperatorID . $data . $datetime . $seq;
                $s = $this->HmacMD5($sig);
                return json(['Msg' => '', 'Ret' => 0, 'Data' => $data, 'Sig' => $s]);
            }
            $re = ['OperatorID' => $OperatorID, 'SuccStat' => 1, 'FailReason' => 5];
            $data = json_encode($re);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => 'OperatorID,Data错误', 'Ret' => 4003, 'Data' => $data, 'Sig' => $s]);
        }
    }

    /**
     * 设备接口状态查询query_station_status
     * 数组长度不超过50
     * @param $stationid
     * @return void
     */
    public function Get_station_status($stationid = [])
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }


        $kk['StationIDs'] = $stationid;
        $en = $this->Encrypt(json_encode($kk));

        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);

        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];
        $message = $this->CurlSend(config('hard.url') . '/query_station_status', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);
        $array = json_decode($de_data, true);


        foreach ($array['StationStatusInfos'] as $stationStatusInfo_arr) {
            foreach ($stationStatusInfo_arr['ConnectorStatusInfos'] as $connectorStatusInfo_arr) {
                $connectorStatusInfo_arr['StationID'] = $stationStatusInfo_arr['StationID'];
                Db::table('charge_pile')
                    ->where('ConnectorID', $connectorStatusInfo_arr['ConnectorID'])
                    ->update(['status' => $connectorStatusInfo_arr['Status']]);

                $check = Db::table('connectorstatusinfo_slow')
                    ->where('ConnectorID', $connectorStatusInfo_arr['ConnectorID'])
                    ->find();
                if (!$check) {
                    Db::table('connectorstatusinfo_slow')->save($connectorStatusInfo_arr);
                } else {
                    Db::table('connectorstatusinfo_slow')->where('ConnectorID', $connectorStatusInfo_arr['ConnectorID'])->update($connectorStatusInfo_arr);

                }
            }
        }
    }


    /**
     * 设备状态变化推送 notification_stationStatus
     * @param Request $request
     * @return void
     * 充电设备接口编码 ConnectorID 充电设备接口编码，同一运营商内唯一 是 字符串 <=26字符
     *
     * 充电设备接口状态 Status 0：离网 1：空闲 2：占用（未充电） 3：占用（充电中） 4：占用（预约锁定） 255：故障 是 整型
     *
     * 车位状态 ParkStatus 0：未知 10：空闲 50：占用 否 整型
     *
     * 地锁状态 LockStatus 0：未知 10：已解锁 50：已上锁
     */
    public function notification_station(Request $request)
    {
        Db::table('charge_logo')->save(['name' => '设备状态变化推送notification_station', 'mark' => '']);
        $params = file_get_contents('php://input');
        $params = json_decode($params, true);

        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $authorization = $request->header()['authorization'];//传递过来的token
        $auths = explode(' ', trim($authorization));
        $auth = $auths[count($auths) - 1];
        $checkParams = $this->checkParams($params);


        if ($checkParams != 2) {
            return ['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]];
        }

        if (!$auth) {
            return $this->encodeData(['Status' => 1], $params, 4002, 'Bearer 未添加');
        }

        if ($this->checkToken_assess($auth) == 1 || $this->checkSig($params['OperatorID'], $params) == 1) {
            $data = json_encode(['Status' => 1]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '请检查签名或Token过期或者无效', 'Ret' => 4002, 'Data' => $data, 'Sig' => $s]);
        }


        $data = $this->Decrypt($params['Data']);
        Db::table('charge_logo')->save(['name' => '设备状态变化推送notification_station', 'mark' => $data]);


        $data = json_decode($data, true);
        $da = $data['ConnectorStatusInfo'];
        if (isset($da['ConnectorID']) && isset($da['Status'])) {
            $ConnectorID = $da['ConnectorID'];
            Db::table('charge_pile')->where('ConnectorID', $ConnectorID)
                ->save(['status' => $da['Status'], 'is_pushed' => 1]);
            return $this->encodeData(['Status' => 0], $params, 0);
        }

    }


    /**
     * 请求设备认证
     * @param $EquipAuthSeq string
     * @param $ConnectorID string
     * @return mixed
     *
     * 设备认证流水号 EquipAuthSeq 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电设备接口编码 ConnectorID 字符串 电设备接口编码:格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     *
     * 操作结果 SuccStat 整型 0:成功； 1:失败 失败原因 FailReason 整型 0:无； 1:此设备尚未插枪； 2:设备检测失败： 3～99:自定义
     */
    public function Get_query_equip_auth($EquipAuthSeq, $ConnectorID)
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }

        $kk = [
            'EquipAuthSeq' => $EquipAuthSeq,
            'ConnectorID' => $ConnectorID,
        ];
        $en = $this->Encrypt(json_encode($kk));


        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);


        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,

        ];
        $message = $this->CurlSend(config('hard.url') . '/query_equip_auth', $data, $token);


        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);

        return json_decode($de_data, true);

    }


    /**
     * 请求启动充电
     * @param $StartChargeSeq string 充电订单号:格式“运营商ID+唯一编号”，27字符
     * @param $ConnectorID string 充电设备接口编码:格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     * @param $QRCode string 二维码其他信息
     * @param $PhoneNum string 手机号 false 个人支付必传，格式确保正确
     * @param $PlateNum string 车牌号 false 停车减免必传，格式确保正确
     * @return array
     * 设备认证流水号 EquipAuthSeq 字符串 式“运营商ID+唯一编号”，27字符
     *
     * 充电设备接口编码 ConnectorID 字符串 参见《电动汽车充换电服务信息交换 第2部分：公共信息交换规范》
     *
     * 操作结果 SuccStat 整型 0:成功； 1:失败 失败原因 FailReason 整型 0:无； 1:此设备尚未插枪； 2:设备检测失败： 3～99:自定义
     *
     */
    public function Get_query_start_charge($StartChargeSeq, $ConnectorID, $QRCode, $PhoneNum = '', $PlateNum = '')
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }

        $kk = [
            'StartChargeSeq' => $StartChargeSeq,
            'ConnectorID' => $ConnectorID,
            'QRCode' => $QRCode,
            'PhoneNum' => $PhoneNum,
            'PlateNum' => $PlateNum,
        ];
        $en = $this->Encrypt(json_encode($kk));

        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);

        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];
        $message = $this->CurlSend(config('hard.url') . '/query_start_charge', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);

        return json_decode($de_data, true);
    }


    /**
     * 请求启动充电
     * @param $StartChargeSeq string 充电订单号
     * @param $ConnectorID string 充电设备接口编码
     * @param $QRCode string 二维码其他信息
     * @param $ChargeModel  string 未知作用
     * @param $vin string 车辆VIN码
     * @param $PhoneNum string 手机号
     * @return array
     */
    public function Get_query_start_charge_test($StartChargeSeq, $ConnectorID, $QRCode, $ChargeModel, $vin = '', $PhoneNum = ''): array
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }


        $kk = [
            'StartChargeSeq' => $StartChargeSeq,
            'ConnectorID' => $ConnectorID,
            'QRCode' => $QRCode,
            'PhoneNum' => $PhoneNum,
            'ChargeModel' => $ChargeModel,
            'Vin' => $vin,
        ];
        $en = $this->Encrypt(json_encode($kk));


        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);


        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];
        $message = $this->CurlSend(config('hard.url') . '/query_start_charge', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);


        return json_decode($de_data, true);
    }

    /**
     * @@@@@@@---------推送充电结果----------@@@@@@@@@@@@
     * 发起充电后，由特来电方推送启动充电结果，包括充电订单号、订单状态、充电设备接口编码、充电启动时间。
     * @param Request $request
     *充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电订单状态 StartChargeSeqStat 是 整型 1：启动中 2：充电中 3：停止中 ：已结束 5：未知
     *
     * 充电设备接口编码 ConnectorID 是 字符串 格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     *
     * 充电启动时间  StartTime  是  字符串    格式“yyyy-MM-dd HH:mm:ss”
     *
     * 验证码 IdentCode 否 字符串 特来电将该字段作为启动充电失败原因错误码
     *
     * @return Json
     * 充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 操作结果 SuccStat 是 整型 0:成功； 1:失败
     *
     * 失败原因 FailReason 是 整型 0:无； 1:接收失败；
     */
    public function notification_start_charge_result(Request $request)
    {
        $params = file_get_contents('php://input');
        $params = json_decode($params, true);
        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $authorization = $request->header()['authorization'];//传递过来的token
        $auths = explode(' ', trim($authorization));
        $auth = $auths[count($auths) - 1];


        $checkParams = $this->checkParams($params);
        if ($checkParams != 2) {
            return json(['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]]);
        }

        if (!$auth) {
            return $this->encodeData(['Status' => 1], $params, 4002, 'Bearer 未添加');
        }


        if ($this->checkToken_assess($auth) == 1 || $this->checkSig($params['OperatorID'], $params) == 1) {
            $data = json_encode(['Status' => 1]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '签名错误/Token过期或者无效', 'Ret' => 4002, 'Data' => $data, 'Sig' => $s]);
        }


        $data = $this->Decrypt($params['Data']);
        Db::table('charge_logo')->save(['name' => $params['OperatorID'] . '：推送充电结果notification_start_charge_result', 'mark' => $data]);
        $data = json_decode($data, true);


        if ($data['StartChargeSeqStat'] == 2) {
            //充电中
            $ss = [
                'status' => $data['StartChargeSeqStat'],
                'StartChargeSeqStat' => $data['StartChargeSeqStat'],
                'start_time' => date('Y-m-d H:i:s', strtotime($data['StartTime'])),
                'vin' => $data['VIN'],
            ];
        } else {
            $time = date('Y-m-d H:i:s', time());
            $ss = [
                'status' => $data['StartChargeSeqStat'],//充电状态
                'StartChargeSeqStat' => $data['StartChargeSeqStat'],//充电状态
                'start_time' => $time,
                'end_time' => $time,
                'stop_type' => 15,
                'TotalMoney' => 0,
                'TotalPower' => 0,
                'IdentCode' => $data['IdentCode'] ?? '',
                'vin' => $data['VIN'] ?? '',
            ];
        }
        Db::table('zxc_charge_order')->where('StartChargeSeq', $data['StartChargeSeq'])
            ->update($ss);
        exit();
    }


    /**
     * 查询充电状态
     * 通过充电订单号查询充电状态。
     * @param $StartChargeSeq string 充电订单号
     * @return int[]
     *
     * 充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电订单状态 StartChargeSeqStat 是 整型 1：启动中 2：充电中 3：停止中 4：已结束 5：未知
     *
     * 充电设备接口编码 ConnectorID 是 字符串 参见《电动汽车充换电服务信息交换   第2部分：公共信息交换规范》
     *
     * 充电设备接口状态 ConnectorStatus 是 整型 1：空闲 2：占用（未充电） 3：占用（充电中） 4：占用（预约锁定） 255：故障
     *
     * A相电流 CurrentA 是 浮点型 单位：A，默认：0 含直流(输出)
     *
     * B相电流 CurrentB 否 浮点型 单位：A，默认：0
     *
     * C相电流 CurrentC 否 浮点型 单位：A，默认：0
     *
     * A相电压 VoltageA  是 浮点型 单位：V，默认：0含直流(输出)
     *
     * B相电压 VoltageB 否 浮点型 单位：V，默认：0
     *
     * C相电压 VoltageC 否 浮点型 单位：V，默认：0
     *
     * 电池剩余电量  Soc 是 浮点型 默认：0
     *
     * 开始充电时间 StartTime 是 字符型 格式“yyyy-MM-dd HH:mm:ss”
     *
     * 本次采样时间 EndTime 是 字符型 格式“yyyy-MM-dd HH:mm:ss”
     *
     * 累计充电量 TotalPower 是 浮点型 单位：度，小数点后3位
     *
     * 累计电费 ElecMoney 否 浮点型 单位：元，小数点后2位
     *
     * 累计服务费 SeviceMoney 否 浮点型 单位：元，小数点后2位
     *
     * 累计总金额 TotalMoney 否 浮点型 单位：元，小数点后2位
     *
     * 时段数N SumPeriod 否 整型 范围：0～32
     *
     * 充电明细信息 ChargeDetails 否
     *
     * ChargeDetails数组 单时段充电明细信息
     *充电明细信息体（ChargeDetails）
     * 参数名称             定义                  必填          参数类型        描述
     * 始时间              DetailStartTime       是          字符串         格式“yyyy-MM-dd HH:mm:ss”
     * 结束时间            DetailEndTime         是         字符串          格式“yyyy-MM-dd HH:mm:ss”
     * 时段电价            ElecPrice             否         浮点型          小数点后4位
     * 时段服务费价格       SevicePrice           否         浮点型          小数点后4位
     * 时段充电量          DetailPower           是          浮点型          单位：度，小数点后3位
     * 时段电费            DetailElecMoney       否        浮点型           小数点后2位
     * 时段服务费          DetailSeviceMoney     否           浮点型         小数点后2位
     */
    public function Get_query_equip_charge_status($StartChargeSeq)
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }


        $kk['StartChargeSeq'] = $StartChargeSeq;
        $en = $this->Encrypt(json_encode($kk));

        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);

        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];
        $message = $this->CurlSend(config('hard.url') . '/query_equip_charge_status ', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);
        Db::table('charge_logo')->insert(['mark' => $de_data, 'name' => $StartChargeSeq . ':充电状态Get_query_equip_charge_status']);


        $array = json_decode($de_data, true);

        if (isset($data['TotalMoney']) && $data['TotalMoney'] > 0) {
            //累计金额？？？？？？

            $ll = array_diff_key($array, ["ChargeDetails" => 'xy', 'StartTime' => 'xy', "StartChargeSeq" => 'xy', 'ConnectorID' => 'xy', 'TotalMoney' => 'xy']);


            $charge_order_info = Db::table('zxc_charge_order')
                ->where('StartChargeSeq', $StartChargeSeq)
                ->field('openid,charge_station_id,order_number,WithholdingMoney,status, end_time')
                ->find();

            $station_type = \app\model\ChargeStation::where('charge_station_id', $charge_order_info['charge_station_id'])->value('station_type');

            $detail_message = '';
            if ((int)$station_type == 0) {
                $ii = 1;
                $total = 0;
                $ElectMoney = 0;
                $SeviceMoney = 0;
                foreach ($array['ChargeDetails'] as $Details) {
                    $Details = (array)$Details;
                    $per_price = $this->Rank($charge_order_info['charge_station_id'], $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_order_info['openid'])['Elect'];
                    $S_price = $this->Rank($charge_order_info['charge_station_id'], $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_order_info['openid'])['Serve'];
                    $period_price = round($Details['DetailPower'] * $per_price, 2);
                    $service_price = round($Details['DetailPower'] * $S_price, 2);
                    $total_money = $period_price + $service_price;
                    $detail_message .= '时段' . $ii .
                        ':开始时间:' . $Details['DetailStartTime'] . ',' .
                        '结束时间:' . $Details['DetailEndTime'] . ',' .
                        '所用度数:' . $Details['DetailPower'] . ',' .
                        '时段电费单价:' . $per_price . ',' .
                        '时段电费金额:' . $period_price . ',' .
                        '时段服务费单价:' . $S_price . ',' .
                        '时段服务费金额:' . $service_price . ',' .
                        '时段总价:' . $total_money . ';';
                    $ii += 1;
                    $total += $total_money;
                    $ElectMoney += $period_price;
                    $SeviceMoney += $service_price;
                }
            } else {
                $price = $this->GetPrice($charge_order_info['charge_station_id'], $charge_order_info['openid']);
                $total = $ll['TotalPower'] * $price['EPrice'] + ($ll['TotalPower'] * $price['SPrice']);
                $ElectMoney = $array['TotalPower'] * $price['EPrice'];
                $SeviceMoney = $array['TotalPower'] * $price['SPrice'];
            }


            if ((float)$charge_order_info['WithholdingMoney'] - (float)$total <= 3) {
                Db::table('charge_logo')->save([
                    'name' => '检测到费用不足执行结束--查询充电状态',
                    'mark' => json_encode([
                        'WithholdingMoney' => $charge_order_info['WithholdingMoney'],
                        'TotalMoney' => $array['TotalMoney'],
                    ])
                ]);
                $order = new ChargeOrder();
                $order->EndOrder2($charge_order_info['openid'], $charge_order_info['order_number']);
            }

            $ll['status'] = $ll['StartChargeSeqStat'];
            $ll['TotalMoney'] = round($total, 2);
            $ll['ElecMoney'] = round($ElectMoney, 2);
            $ll['SeviceMoney'] = round($SeviceMoney, 2);

            if (empty($charge_order_info['end_time']) && $charge_order_info['status'] != 4) {
                Db::table('zxc_charge_order')
                    ->where('StartChargeSeq', $StartChargeSeq)
                    ->save($ll);
            }
            return ['code' => 200];
        } else {
            return ['code' => 1];
        }
    }


    //查询充电状态 同上但是只返回了数据信息
    public function Get_query_equip_charge_status_test($StartChargeSeq)
    {
        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }
        $datetime = date('YmdHis');
        $kk['StartChargeSeq'] = $StartChargeSeq;
        $en = $this->Encrypt(json_encode($kk));
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);
        $rr['OperatorID'] = config('hard.OperatorID');
        $rr['Data'] = $en;
        $rr['TimeStamp'] = $datetime;
        $rr['Seq'] = config('hard.Seq');
        $rr['Sig'] = $s;
        $data = $rr;
        $message = $this->CurlSend(config('hard.url') . '/query_equip_charge_status ', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);
        $arr = json_decode($de_data);
        $array = (array)$arr;
//        dd($array);
        if (isset($array['TotalMoney'])) {
            $ll = array_diff_key($array, ["ChargeDetails" => 'xy', 'StartTime' => 'xy', "StartChargeSeq" => 'xy', 'ConnectorID' => 'xy', 'TotalMoney' => 'xy']);
            $station_id = Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->value('charge_station_id');
            $station_type = \app\model\ChargeStation::where('charge_station_id', $station_id)->value('station_type');
            $openid = Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->value('openid');
            $detail_message = '';
//            dd($array);
            if ((int)$station_type == 0) {
                $ii = 1;
                $total = 0;
                $total_elet = 0;
                $total_ser = 0;

                foreach ($array['ChargeDetails'] as $Details) {
                    $Details = (array)$Details;
                    $price = $this->Rank($station_id, $Details['DetailStartTime'], $Details['DetailEndTime'], $openid);
                    $per_price = $price['Elect'];
                    $S_price = $price['Serve'];
                    $period_price = round($Details['DetailPower'] * $per_price, 2);
                    $service_price = round($Details['DetailPower'] * $S_price, 2);
                    $total_money = $period_price + $service_price;
                    $detail_message .= '时段' . $ii .
                        ':开始时间:' . $Details['DetailStartTime'] . ',' .
                        '结束时间:' . $Details['DetailEndTime'] . ',' .
                        '所用度数:' . $Details['DetailPower'] . ',' .
                        '时段电费单价:' . $per_price . ',' .
                        '时段电费金额:' . $period_price . ',' .
                        '时段服务费单价:' . $S_price . ',' .
                        '时段服务费金额:' . $service_price . ',' .
                        '时段总价:' . $total_money . ';';
                    $ii += 1;
                    $total += $total_money;
                    $total_elet += $period_price;
                    $total_ser += $service_price;
                }
            } else {
                $price = $this->GetPrice($station_id, $openid);
                $total = $ll['TotalPower'] * $price['EPrice'] + ($ll['TotalPower'] * $price['SPrice']);
                $total_elet = $ll['TotalPower'] * $price['EPrice'];
                $total_ser = $ll['TotalPower'] * $price['SPrice'];
            }
            $ll['TotalMoney'] = round($total, 2);
            $ll['ElecMoney'] = round($total_elet, 2);
            $ll['SeviceMoney'] = round($total_ser, 2);
//            $WithholdingMoney = Db::table($table)->where('StartChargeSeq',$StartChargeSeq)->value('WithholdingMoney');
//            $openid = Db::table($table)->where('StartChargeSeq',$StartChargeSeq)->value('openid');
//            $order_num = Db::table($table)->where('StartChargeSeq',$StartChargeSeq)->value('order_number');
//            if ((float)$WithholdingMoney - (float)$ll['TotalMoney']<=3){
//                $order = new ChargeOrder();
//                $order->EndOrder($openid,$order_num);
//            }
            $ll['status'] = $ll['StartChargeSeqStat'];
            $ll['DetailMessage'] = $detail_message;
            return ['code' => 200, 'data' => $ll];
//            $end_time = Db::table($table)->where('order_number',$order_num)->value('end_time');
//            if (empty($end_time)){
//                Db::table($table)->where('StartChargeSeq',$StartChargeSeq)->update($ll);
//            }
        } else {
            return ['code' => 1];
        }
    }


//    计算单个价格
    public function Rank($station_id, $start, $end, $openid)
    {

        $start_time = date('H:i:s', strtotime($start));
        $end_time = date('H:i:s', strtotime($end));
//        echo $start_time;
//        echo $end_time;
        $interval = $this->GetPrice($station_id, $openid);
        $SPrice = $interval['SPrice'];
        $interval = $interval['message'];
        $station_type = \app\model\ChargeStation::where('charge_station_id', $station_id)->value('station_type');
        if ((int)$station_type == 0) {
            $i = 0;
            foreach ($interval as $in) {
                $st = date('H:i:s', strtotime($in['start']));
//                $en = date('H:i:s',strtotime('-1 seconds',strtotime($in['end'])));
                $en = date('H:i:s', strtotime($in['end']));
                $check = date('H:i:s', strtotime('23:59:59'));
                $check1 = date('H:i:s', strtotime('00:00:00'));
                if ($i <= 7 && $start_time >= $st && $end_time <= $en && $end_time != $check1) {
                    return ['Elect' => $in['univalence'], 'Serve' => $SPrice];
                } elseif ($i == 7 && $start_time >= $st && ($end_time <= $check || $end_time = $check1)) {
                    return ['Elect' => $in['univalence'], 'Serve' => $SPrice];
                }
                $i += 1;
            }
        }
    }

    //计算电费
    public function GetPrice($station_id, $openid)
    {
        $station_type = \app\model\ChargeStation::where('charge_station_id', $station_id)->value('station_type');
        $ElectricityFee = Db::table('charge_station')->where('charge_station_id', $station_id)->value('ElectricityFee');
        $type = Db::table('zxc_user')->where('openid', $openid)->value('type');
        if ($type != 3) {
            $ServiceFee = ServiceFee::where('type', $type)->where('station_type', $station_type)->value('service_fee');
        } else {
            $group_id = EnterpriseUser::where('openid', $openid)->value('group_id');
            $ServiceFee = ServiceFee::where('type', $type)->where('station_type', $station_type)->where('group_id', $group_id)->value('service_fee');
        }
//        $ServiceFee= Db::table('charge_station')->where('charge_station_id',$station_id)->value('ServiceFee');
        $ElectricityFee = str_replace('电费:', '', $ElectricityFee);
        $Elect = explode(',', $ElectricityFee);

        for ($index = 0; $index < count($Elect); $index++) {
            $kk['time_interval'] = substr($Elect[$index], 0, 11);
            $tt = explode('~', $kk['time_interval']);
            $start = $tt[0] . ':00';
            $end = $tt[1] ?? $tt[1] . ':00';

            $kk['univalence'] = explode(':', $Elect[$index])[3];
            $kk['start'] = $start;
            $kk['end'] = $end;
            $ss[] = $kk;
        }
        $ServiceFee = str_replace('服务费:', '', $ServiceFee);
        $Server = explode(',', $ServiceFee);
        for ($index = 0; $index < count($Server); $index++) {
            $ll['time_interval'] = substr($Server[$index], 0, -5);
            $ll['univalence'] = substr($Server[$index], Strlen($Server[$index]) - 4);
            $mm[] = $ll;
        }
        if ($station_type == 1) {
            return ['EPrice' => number_format((float)($ss[0]['univalence']), 6), 'SPrice' => number_format((float)($mm[0]['univalence']), 2)];
        } elseif ($station_type == 0) {
            return ['message' => $ss, 'SPrice' => number_format((float)($mm[0]['univalence']), 2)];

        }
    }


    /**
     * 推送充电状态
     * 启动充电后，由特来电每@@@@@@五分钟@@@@@@@@推一次充电状态
     * @param Request $request
     * @return array|Json
     */
    public function notification_equip_charge_status(Request $request)
    {
        $params = file_get_contents('php://input');


        $params = json_decode($params, true);
        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $authorization = $request->header()['authorization'];//传递过来的token
        $auths = explode(' ', trim($authorization));
        $auth = $auths[count($auths) - 1];
        $checkParams = $this->checkParams($params);

        if ($checkParams != 2) {
            return ['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]];
        }

        if (!$auth) {
            return $this->encodeData(['Status' => 1], $params, 4002, 'Bearer 未添加');
        }

        if ($this->checkToken_assess($auth) == 1 || $this->checkSig($params['OperatorID'], $params) == 1) {
            $data = json_encode(['Status' => 1]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '签名错误、Token过期或者无效', 'Ret' => 4002, 'Data' => $data, 'Sig' => $s]);
        }


        $data = $this->Decrypt($params['Data']);
        Db::table('charge_logo')->save(['name' => '推送充电状态notification_equip_charge_status', 'mark' => $data]);


        $data = json_decode($data, true);
        if (isset($data['TotalMoney']) && $data['TotalMoney'] > 0) {
            $array = array_diff_key($data, ["ChargeDetails" => 'xy', 'StartTime' => 'xy', 'StartChargeSeq' => 'xy', 'ConnectorID' => 'xy', 'TotalMoney' => 'xy']);
            $array['start_time'] = $data['StartTime'];


            $charge_order_info = Db::table('zxc_charge_order')->where('StartChargeSeq', $data['StartChargeSeq'])->find();
            Db::table('charge_logo')->save(['name' => '调试数据', 'mark' => json_encode($charge_order_info)]);
            
            $station_type = \app\model\ChargeStation::where('charge_station_id', $charge_order_info['charge_station_id'])->value('station_type');

            $detail_message = '';
            if ((int)$station_type == 0) {
                $ii = 1;
                $total = 0;
                $ElectMoney = 0;
                $SeviceMoney = 0;
                foreach ($data['ChargeDetails'] as $Details) {
                    $Details = (array)$Details;
                    $per_price = $this->Rank($charge_order_info['charge_station_id'], $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_order_info['openid'])['Elect'];
                    $S_price = $this->Rank($charge_order_info['charge_station_id'], $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_order_info['openid'])['Serve'];
                    $period_price = round($Details['DetailPower'] * $per_price, 2);
                    $service_price = round($Details['DetailPower'] * $S_price, 2);
                    $total_money = $period_price + $service_price;
                    $detail_message .= '时段' . $ii .
                        ':开始时间:' . $Details['DetailStartTime'] . ',' .
                        '结束时间:' . $Details['DetailEndTime'] . ',' .
                        '所用度数:' . $Details['DetailPower'] . ',' .
                        '时段电费单价:' . $per_price . ',' .
                        '时段电费金额:' . $period_price . ',' .
                        '时段服务费单价:' . $S_price . ',' .
                        '时段服务费金额:' . $service_price . ',' .
                        '时段总价:' . $total_money . ';';
                    $ii += 1;
                    $total += $total_money;
                    $ElectMoney += $period_price;
                    $SeviceMoney += $service_price;
                }
            } else {
                $price = $this->GetPrice($charge_order_info['charge_station_id'], $charge_order_info['openid']);
                $total = $array['TotalPower'] * $price['EPrice'] + ($array['TotalPower'] * $price['SPrice']);
                $ElectMoney = $data['TotalPower'] * $price['EPrice'];
                $SeviceMoney = $data['TotalPower'] * $price['SPrice'];
            }

            $array['TotalMoney'] = round($total, 2);
            $order_num = Db::table('zxc_charge_order')->where('StartChargeSeq', $data['StartChargeSeq'])->value('order_number');
            if ((float)$charge_order_info['WithholdingMoney'] - (float)$array['TotalMoney'] <= 3) {
                Db::table('charge_logo')->save([
                    'name' => '检测到费用不足执行结束--推送',
                    'mark' => json_encode([
                        'WithholdingMoney' => $charge_order_info['WithholdingMoney'],
                        'TotalMoney' => $array['TotalMoney'],
                    ])
                ]);
                $order = new ChargeOrder();
                $order->EndOrder2($charge_order_info['openid'], $order_num);
            }


            $array['ElecMoney'] = round($ElectMoney, 2);
            $array['SeviceMoney'] = round($SeviceMoney, 2);
            $array['status'] = $array['StartChargeSeqStat'];

            if (empty($charge_order_info['end_time']) && $charge_order_info['status'] != 4) {
                Db::table('zxc_charge_order')->where('StartChargeSeq', $data['StartChargeSeq'])->save($array);
            }

            $kk['StartChargeSeq'] = $data['StartChargeSeq'];
            $kk['SuccStat'] = 0;
            return $this->encodeData($kk, $params, 0);
        }


    }


    /**
     * 接口名称：请求停止充电query_stop_charge
     * 接口说明：通过充电订单号、设备接口编码，请求停止充电。
     * 请求格式：json
     * 请求方式：post
     * @param $StartChargeSeq string 充电订单号
     * @param $ConnectorID string 充电设备接口编码
     * @return array
     */
    public function Get_query_stop_charge($StartChargeSeq, $ConnectorID)
    {

        $token = Cache::get('token');
        if (!$token) {
            $hardtoken = new HardToken();
            $token = $hardtoken->getToken();
        }


        $kk = [
            'StartChargeSeq' => $StartChargeSeq,
            'ConnectorID' => $ConnectorID,
        ];
        $en = $this->Encrypt(json_encode($kk));


        $datetime = date('YmdHis');
        $sig = config('hard.OperatorID') . $en . $datetime . config('hard.Seq');
        $s = $this->HmacMD5($sig);

        $data = [
            'OperatorID' => config('hard.OperatorID'),
            'Data' => $en,
            'TimeStamp' => $datetime,
            'Seq' => config('hard.Seq'),
            'Sig' => $s,
        ];
        $message = $this->CurlSend(config('hard.url') . '/query_stop_charge', $data, $token);
        $en_mess = $message['Data'];
        $de_data = $this->Decrypt($en_mess);


        return json_decode($de_data, true);
    }


    /**
     * 接口名称：推送停止充电结果notification_stop_charge_result
     * 接口说明：发起停止充电请求后，由特来电方推送停止充电结果，包括充电订单号、订单状态、充电设备接口编码、充电启动时间。
     * 请求格式：json
     * 请求方式：post
     * @param Request $request
     * 充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电订单状态 StartChargeSeqStat 是 整型 1：启动中 2：充电中 3：停止中 4：已结束 5：未知
     *
     * 充电设备接口编码 ConnectorID 是 字符串 格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     *
     * 成功标识 SuccStat 是 整型  0:成功； 1:失败
     *
     * 停止失败原因 FailReason 是 整型 0:无； 1:此设备不存在； 2:此设备离线： 3:设备已停止充电； 4～99:自定义
     *
     * @return array|Json
     * 充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符，与6.5.3章节相同
     *
     * 操作结果 SuccStat 是 整型 0:成功；  1:失败
     * 失败原因 FailReason 是 整型 0:无； 1:接收失败；
     *
     */
    public function notification_stop_charge_result(Request $request)
    {
        $params = file_get_contents('php://input');

        Db::table('charge_logo')->save(['name' => '推送停止充电结果notification_stop_charge_result', 'mark' => $params]);
        $params = json_decode($params, true);
        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $authorization = $request->header()['authorization'];//传递过来的token
        $auths = explode(' ', trim($authorization));
        $auth = $auths[count($auths) - 1];
        $checkParams = $this->checkParams($params);
        if ($checkParams != 2) {
            return ['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]];
        }

        if (!$auth) {
            return $this->encodeData(['Status' => 1], $params, 4002, 'Bearer 未添加');
        }


        if ($this->checkToken_assess($auth) == 1 || $this->checkSig($params['OperatorID'], $params) == 1) {
            $data = json_encode(['Status' => 1]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '签名错误/Token过期或者无效', 'Ret' => 4002, 'Data' => $data, 'Sig' => $s]);
        }


        $data = $this->Decrypt($params['Data']);
        Db::table('charge_logo')->save(['name' => $params['OperatorID'] . '：停止充电推送结果notification_stop_charge_result', 'mark' => $data]);
        $data = json_decode($data, true);


        if ($data['StartChargeSeqStat'] == 4 && $data['SuccStat'] == 0 && $data['FailReason'] == 0) {

            $ss['StartChargeSeqStat'] = $data['StartChargeSeqStat'];
            $ss['status'] = $data['StartChargeSeqStat'];

            Db::table('zxc_charge_order')->where('StartChargeSeq', $data['StartChargeSeq'])->update($ss);

            exit();
        } else {
            Db::table('zxc_charge_order')
                ->where('StartChargeSeq', $data['StartChargeSeq'])
                ->update(['StopFailreason' => $data['FailReason']]);
            exit();
        }

    }


    /**
     * 接口名称：推送充电订单信息notification_charge_order_info
     * 接口说明：结束充电后，由特来电推送充电订单信息。
     * 请求格式：json
     * 请求方式：post
     * @param Request $request
     *充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电设备接口编码 ConnectorID 是 字符串 格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     *
     * 开始充电时间 StartTime 是 字符串 格式“yyyy-MM-dd HH:mm:ss”
     *
     * 结束充电时间 EndTime 是 字符串 格式“yyyy-MM-dd HH:mm:ss”
     *
     * 累计充电量 TotalPower 是 浮点型 单位：度，小数点后3位
     *
     * 总电费 TotalElecMoney 是 浮点型 单位：元，小数点后2位
     *
     * 总服务费 TotalSeviceMoney 是 浮点型 单位：元，小数点后2位
     *
     * 累计总金额 TotalMoney 是 浮点型 单位：元，小数点后2位
     *
     * 充电结束原因 StopReason 是 整型  0:用户手动停止充电 1:客户归属地运营商平台停止充电 2：BMS停止充电； 3：充电机设备故障； 4：连接器断开 5-99自定义
     *
     * 时段数N SumPeriod 否 整型 范围：0～32
     *
     * 充电明细信息 ChargeDetails 否 ChargeDetails数组 单时段充电明细信息
     * @return array|Json
     *充电订单号 StartChargeSeq 是 字符串 格式“运营商ID+唯一编号”，27字符
     *
     * 充电设备接口编码 ConnectorID 是 字符串 格式“6位行政区编码，4位电站编码，3位终端编码”，13位字符
     *
     * 确认结果 ConfirmResult 是 整型 0:成功 1:争议交易 2～99:自定义
     */
    public function notification_charge_order_info(Request $request)
    {

        $params = file_get_contents('php://input');
        $params = json_decode($params, true);
        $OperatorID = empty($params['OperatorID']) ? '' : $params['OperatorID'];
        $authorization = $request->header()['authorization'];//传递过来的token
        $auths = explode(' ', trim($authorization));
        $auth = $auths[count($auths) - 1];

        $checkParams = $this->checkParams($params);
        if ($checkParams != 2) {
            return ['Msg' => $checkParams . '为空', 'Ret' => 4003, 'Data' => ['Status' => 1]];
        }


        if (!$auth) {
            return $this->encodeData(['Status' => 1], $params, 4002, 'Bearer 未添加');
        }
        if ($this->checkToken_assess($auth) == 1 || $this->checkSig($params['OperatorID'], $params) == 1) {
            $data = json_encode(['Status' => 1]);
            $data = $this->Encrypt($data);
            $seq = empty($Seq) ? '0001' : $params['Seq'];
            $datetime = empty($TimeStamp) ? date('YmdHis') : $params['TimeStamp'];
            $sig = $OperatorID . $data . $datetime . $seq;
            $s = $this->HmacMD5($sig);
            return json(['Msg' => '签名错误、Token过期或者无效', 'Ret' => 4002, 'Data' => $data, 'Sig' => $s]);
        }

        $data = $this->Decrypt($params['Data']);
        Db::table('charge_logo')->save(['name' => $params['OperatorID'] . '：推送充电订单信息notification_charge_order_info', 'mark' => $data]);
        $data = json_decode($data, true);


        if (isset($data['StopReason'])) {

            $StartChargeSeq = $data['StartChargeSeq'];

            $charge_info = Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->find();

            $WithholdingMoney = $charge_info['WithholdingMoney'];
            $station_id = $charge_info['charge_station_id'];
            $station_type = \app\model\ChargeStation::where('charge_station_id', $station_id)->value('station_type');

            $detail_message = '';
            if ((int)$station_type == 0) {
                $ii = 1;
                $total = 0;
                $ElectMoney = 0;
                $SeviceMoney = 0;
                foreach ($data['ChargeDetails'] as $Details) {
                    $Details = (array)$Details;
                    $per_price = $this->Rank($station_id, $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_info['openid'])['Elect'];
                    $S_price = $this->Rank($station_id, $Details['DetailStartTime'], $Details['DetailEndTime'], $charge_info['openid'])['Serve'];
                    $period_price = round($Details['DetailPower'] * $per_price, 2);
                    $service_price = round($Details['DetailPower'] * $S_price, 2);
                    $total_money = $period_price + $service_price;
                    $detail_message .= '时段' . $ii .
                        ':开始时间:' . $Details['DetailStartTime'] . ',' .
                        '结束时间:' . $Details['DetailEndTime'] . ',' .
                        '所用度数:' . $Details['DetailPower'] . ',' .
                        '时段电费单价:' . $per_price . ',' .
                        '时段电费金额:' . $period_price . ',' .
                        '时段服务费单价:' . $S_price . ',' .
                        '时段服务费金额:' . $service_price . ',' .
                        '时段总价:' . $total_money . ';';
                    $ii += 1;
                    $total += $total_money;
                    $ElectMoney += $period_price;
                    $SeviceMoney += $service_price;
                }
            } else {
                $price = $this->GetPrice($station_id, $charge_info['openid']);
                $total = $data['TotalPower'] * $price['EPrice'] + ($data['TotalPower'] * $price['SPrice']);
                $ElectMoney = $data['TotalPower'] * $price['EPrice'];
                $SeviceMoney = $data['TotalPower'] * $price['SPrice'];
            }
            $ss['end_time'] = $data['EndTime'];
            $ss['TotalPower'] = $data['TotalPower'];
            $TotalMoney = round($total, 2);
            $ss['ElecMoney'] = round($ElectMoney, 2);
            $ss['SeviceMoney'] = round($SeviceMoney, 2);
            $ss['TotalMoney'] = $TotalMoney;
            $ss['stop_type'] = $data['StopReason'];
            $ss['SumPeriod'] = $data['SumPeriod'];
            $ss['status'] = 4;
            $ss['StartChargeSeqStat'] = 4;
            $ss['FeedbackMoney'] = round($WithholdingMoney - $TotalMoney, 2);
            $ss['DetailMessage'] = $detail_message;

            $check = $charge_info['FeedbackMoney'];
            if (empty($check)) {
                
                Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->save($ss);
                $charge_info = Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->find();
                
                
                // 即充即退
                if ($charge_info['type'] == 1 && $charge_info['directly_refund_status'] == 0 && $charge_info['is_wind'] == 0) {
                    $td = new WechatReimburse();
                    $td->Refund2($charge_info['order_id'], $charge_info['openid'], $charge_info['FeedbackMoney'], $charge_info['WithholdingMoney'], $charge_info['directly_pay_no']);
                    Db::table('charge_logo')->save(['name' => '充电结束即充即退执行退款', 'mark' => json_encode($charge_info)]);
                }

                //个人余额
                if ($charge_info['type'] == 2 && $charge_info['is_wind'] == 0) {
                    Db::table('zxc_charge_order')->where('StartChargeSeq', $StartChargeSeq)->save(['is_wind'=>1]);
                    \app\model\User::addMoneyLog($charge_info['openid'], $TotalMoney, 1, '充电结束执行用户使用个人钱包充电' . $ss['FeedbackMoney']);
                    Db::table('zxc_user')->where('openid', $charge_info['openid'])->update(['account' => Db::raw('account-' . $TotalMoney)]);
                }

            }


            Log::error('充电结束' . json_encode($data), 'error');

            exit();
        }

    }
}