charge123/charge-pile-serve
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
main
charge-pile-serve/app/controller/ChargeOrder.php

1371 lines
58 KiB
PHP
Raw Permalink Normal View History

init
2025-11-10 16:12:07 +08:00
<?php
declare (strict_types=1);
namespace app\controller;
use app\common;
use app\model\ChargeOrder as ChargeOrderModel;
use app\model\ChargeStation as ChargeStationModel;
use app\model\ServiceFee;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\Exception;
use think\facade\Db;
use think\helper\Str;
use think\Request;
class ChargeOrder extends common
{
/**
* 显示资源列表
*
* @return \think\Response
*/
public function index()
{
$list = ChargeOrderModel::withSearch(['order_number', 'charge_station_id', 'openid', 'charge_date', 'status'], [
'order_number' => request()->param('order_number'),
'charge_station_id' => request()->param('charge_station_id'),
'openid' => request()->param('openid'),
'charge_date' => request()->param('charge_date'),
'status' => request()->param('status'),
])->paginate([
'list_rows' => 20,
'query' => request()->param()
]);
return json($list);
}
/**
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\DataNotFoundException
*/
public function FuzzyOrder($charge_station_name = '', $message = '', $start_time = '', $end_time = '', $order = ''): \think\response\Json
{
$where = [];
if ($message) {
$where[] = ['message', 'like', '%' . $message . '%'];
}
if ($charge_station_name) {
$charge_station_id = Db::table('charge_station')->where('charge_station_name', $charge_station_name)->value('charge_station_id');
if ($charge_station_id) {
$where[] = ['charge_station_id', '=', $charge_station_id];
}
}
if ($start_time) {
$where[] = ['start_time', '>=', $start_time];
}
if ($end_time) {
$where[] = ['start_time', '<=', $end_time];
}
$list = Db::table('zxc_charge')
->where($where)
->order('start_time desc')
->field('charge_station_id,order_number,order_id,TotalPower,TotalMoney,ElecMoney,SeviceMoney,end_time,EndTime,DetailMessage,status,start_time,openid')
->select(); // 获取全部数据
foreach ($list as $key => &$value) {
$value['charge_station_name'] = Db::table('charge_station')->where('charge_station_id', $value['charge_station_id'])->value('charge_station_name');
$phone = Db::table('zxc_user')->where('openid', $value['openid'])->value('phone');
$value['phone'] = $phone;
}
return json($list);
}
public function GennerateOrder($openid, $station_number, $no, $account)
{
$table = 'zxc_charge_order';
$table_user = 'zxc_user';
$balance = Db::table($table_user)->where('openid', $openid)->value('account');
$exit = Db::table($table)->where('openid', $openid)->find();
$exit2 = Db::table($table)->where('openid', $openid)->order('order_id desc')->value('end_time');
if (($balance - $account) >= 0 && ($openid == "o-wLg5DGWU_rYwfmp1-1Wck1lKGw" || (empty($exit) || !empty($exit2)))) {
return $this->Charge($station_number, $no, $openid, $table, $table_user, $account);
} elseif (($balance - $account) < 0) {
return json(['code' => 3, 'message' => '余额不足 请充值']);
} else {
return json(['code' => 1, 'message' => '请先完成当前订单']);
}
}
protected function Charge($station_number, $no, $openid, $table, $table_user, $account): \think\response\Json
{
$station_id = Db::table('charge_station')->where('charge_station_number', $station_number)->value('charge_station_id');
$ConnectorID = Db::table('charge_pile')->where(['charge_station_id' => $station_id, 'no' => $no])->value('ConnectorID');
$EquipAuthSeq = Db::table('charge_pile')->where(['charge_station_id' => $station_id, 'no' => $no])->value('EquipAuthSeq');
if (empty($EquipAuthSeq)) {
$EquipAuthSeq = $this->generate_EquipmentAuth(7);
Db::table('charge_pile')->where(['charge_station_id' => $station_id, 'no' => $no])->update(['EquipAuthSeq' => $EquipAuthSeq]);
}
$Hard = new HardMessage();
$AuthMessage = $Hard->Get_query_equip_auth($EquipAuthSeq, $ConnectorID);
if (isset($AuthMessage['FailReason']) && isset($AuthMessage['SuccStat'])) {//认证成功 请求启动充电
if ($AuthMessage['FailReason'] == 0 && $AuthMessage['SuccStat'] == 0) {
$StartChargeSeq = $this->generate_StartChargeSeq(7);
ChargeOrderModel::insert(['openid' => $openid, 'StartChargeSeq' => $StartChargeSeq]);
$ChargeModel = 2;
$StartCharge = $Hard->Get_query_start_charge_test($StartChargeSeq, $ConnectorID, 'QRCode', $ChargeModel);
if ($StartCharge['StartChargeSeqStat'] == 1 && $StartCharge['SuccStat'] == 0 && $StartCharge['FailReason'] == 0) {
$check = Db::table($table)->where('openid', $openid)->order('order_id desc')->value('end_time');
$check2 = Db::table($table)->where('openid', $openid)->find();
if ((!empty($check) || empty($check2))) {
$order_number = $this->generate_order(6);
$charge_date = date('Y-m-d', time());
$Equipment_number = Db::table('charge_pile')->where([
['charge_station_id', '=', $station_id],
['no', '=', $no]
])->value('charge_pile_number');
$mess = [
'order_number' => $order_number,
'charge_station_id' => $station_id,
'openid' => $openid,
'charge_date' => $charge_date,
'Equipment_number' => $Equipment_number,
'StartChargeSeq' => $StartChargeSeq,
'status' => $StartCharge['StartChargeSeqStat'],
'StartChargeSeqStat' => $StartCharge['StartChargeSeqStat'],
'ConnectorID' => $ConnectorID,
'WithholdingMoney' => $account
];
Db::table($table_user)->where('openid', $openid)->update(['account' => Db::raw('account-' . $account)]);
Db::table($table)->save($mess);
return json(['code' => 200, 'message' => '订单创建成功', 'order_number' => $order_number, 'info' => Db::table($table)->where(['order_number' => $order_number])->find()]);
} else {
return json(['code' => 1, 'message' => '请不要点击过快']);
}
} elseif ($StartCharge['SuccStat'] == 1) {
if ($StartCharge['FailReason'] == 0) {
return json(['code' => 1, 'message' => '设备认证操作结果失败5']);
} elseif ($StartCharge['FailReason'] == 1) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 此设备不存在']);
} elseif ($StartCharge['FailReason'] == 2) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 此设备离线']);
} elseif ($StartCharge['FailReason'] == 90) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 车辆未备案']);
} elseif ($StartCharge['FailReason'] == 91) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 该车辆充电中']);
} else {
return json(['code' => 1, 'message' => '未知错误 设备认证成功 请求充电失败']);
}
} else {
return json(['code' => 1, 'message' => '未知错误 设备认证成功 请求充电失败']);
}
} elseif ($AuthMessage['SuccStat'] == 1) {
if ($AuthMessage['FailReason'] == 0) {
return json(['code' => 1, 'message' => '设备认证操作结果失败3']);
} elseif ($AuthMessage['FailReason'] == 1) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 此设备尚未插枪']);
} elseif ($AuthMessage['FailReason'] == 2) {
return json(['code' => 1, 'message' => '设备认证操作结果失败 设备检测失败']);
} else {
return json(['code' => 1, 'message' => '未知错误 设备认证失败4']);
}
} else {
return json(['code' => 1, 'message' => '未知错误 设备认证失败2']);
}
} else {
return json(['code' => 1, 'message' => '未知错误 设备认证失败1']);
}
}
// 潜江充电模式
public function GennerateOrder2()
{
$params = input();
//启动前验证
$check = $this->startChargeCheck($params);
if ($check && $check['code'] == 1) {
return json(['code' => 1, 'message' => $check['message']]);
}
$openid = $params['openid'];
$account = $params['account'];
$type = $params['type'];
//认证成功 生成系统充电订单号
$StartChargeSeq = $this->generate_StartChargeSeq(7);
if ($type == 1) {// 即充即退
//
// $time = time();
// Db::table('zxc_charge_order')->save([
// 'type' => 1,
// 'openid' => 'obUtOvjCdTSrZTqbjTByESPo6kLE',
// 'directly_pay_no' => '1217752501201407033233368026',
// 'directly_pay_status' => 1,
// 'directly_pay_time' => $time,
// 'directly_prepaid_amount' => $account,
// 'WithholdingMoney' => $account,
// 'start_time' => date('Y-m-d H:i:s', $time),
// ]);
//
// Db::table('zxc_charge')->save([
// 'type' => 2,
// 'openid' => 'obUtOvjCdTSrZTqbjTByESPo6kLE',
// 'out_trade_no' => $StartChargeSeq,
// 'transaction_id' => '1217752501201407033233368026',
// 'trade_state' => 1,
// 'total' => $account,
// 'payer_total' => $account,
// 'success_time' => date('Y-m-d H:i:s', $time),
// ]);
//
// \app\model\User::addMoneyLog('obUtOvjCdTSrZTqbjTByESPo6kLE', $account, 2, '用户使用即充即退');
//返回支付信息 生成充电订单
$out_trade_no = $this->generate_order(6);
$pay_info = (new WechatPay())->directlyConfig($out_trade_no, $params['openid'], $account);
$pay_info['StartChargeSeq'] = $StartChargeSeq;
return json(['code' => 2, 'message' => '获取支付参数', 'data' => $pay_info]);
// return json(['code' => 200, 'message' => '可以充值', 'data' => ['StartChargeSeq' => $StartChargeSeq]]);
} elseif ($type == 2) { // 个人钱包充电
// 判断余额
// 账户余额
$balance = Db::table('zxc_user')->where('openid', $openid)->value('account');
if ($balance < 20) {
return json(['code' => 1, 'message' => '余额不足 请充值']);
}
return json(['code' => 200, 'message' => '可以充值', 'data' => ['StartChargeSeq' => $StartChargeSeq]]);
} elseif ($type == 3) { // 企业充电
// 判断余额
} else {
return json(['code' => 1, 'message' => '参数错误']);
}
}
//潜江充电----启动充电
public function startCharging()
{
$params = input();
//是否存在订单号
$StartChargeSeq = $params['StartChargeSeq'];
if (!$StartChargeSeq) {
return json(['code' => 1, 'message' => '请求失败']);
}
//启动前验证
$check = $this->startChargeCheck($params, true);
if ($check && $check['code'] == 1) {
return json(['code' => 1, 'message' => $check['message']]);
}
//生成充电桩唯一标识
$charge_pile_info = Db::table('charge_pile')->where('ConnectorID', $params['ConnectorId'])->find();
if (empty($charge_pile_info['EquipAuthSeq'])) {
$EquipAuthSeq = $this->generate_EquipmentAuth(7);
Db::table('charge_pile')->where(['ConnectorID' => $params['ConnectorId']])->update(['EquipAuthSeq' => $EquipAuthSeq]);
}
$result = false;
//创建系统订单
$order_number = $this->generate_order(6);
$charge_date = date('Y-m-d', time());
$save_data = [
'StartChargeSeq' => $StartChargeSeq,
'order_number' => $order_number,
'charge_station_id' => $charge_pile_info['charge_station_id'],
'openid' => $params['openid'],
'charge_date' => $charge_date,
'Equipment_number' => $charge_pile_info['charge_pile_number'],
'status' => $StartCharge['StartChargeSeqStat'] ?? '',
'StartChargeSeqStat' => $StartCharge['StartChargeSeqStat'] ?? '',
'ConnectorID' => $params['ConnectorId'],
'WithholdingMoney' => $params['account'],
'type' => $params['type']
];
if ($params['type'] == 1) {//通过支付后回调产生订单更新订单号
$result = Db::table('zxc_charge_order')->where('directly_pay_no', $params['out_trade_no'])->update($save_data);
} else if ($params['type'] == 2) {
$result = Db::table('zxc_charge_order')->save($save_data);
}
if ($result) {
//请求充电
$Hard = new HardMessage();
$StartCharge = $Hard->Get_query_start_charge_test($StartChargeSeq, $params['ConnectorId'], 'QRCode', 2);
if ($StartCharge['StartChargeSeqStat'] != 1) {
Db::table('zxc_charge_order')->where(['order_number' => $order_number])->delete();
return json(['code' => 1, 'message' => '充电启动失败' . $StartCharge['FailReason']]);
}
$info = Db::table('zxc_charge_order')->where(['order_number' => $order_number])->find();
return json(['code' => 200, 'message' => '订单创建成功', 'order_number' => $order_number, 'info' => $info]);
}
return json(['code' => 1, 'message' => '系统出错啦~']);
}
//潜江充电前验证
public function startChargeCheck($params, $status = false)
{
//1.订单验证
$exit2 = Db::table('zxc_charge_order')
->where('openid', $params['openid'])
->where('end_time', '=', null)
->find();
if ($exit2 && !$status) {
return ['code' => 1, 'message' => '存在未结束订单'];
}
//2.设备信息验证和更新
$charge_pile_info = Db::table('charge_pile')
->where('ConnectorID', $params['ConnectorId'])
->find();
$EquipAuthSeq = $charge_pile_info['EquipAuthSeq'];
if (empty($EquipAuthSeq)) {
$EquipAuthSeq = $this->generate_EquipmentAuth(7);
Db::table('charge_pile')
->where(['ConnectorID' => $params['ConnectorId']])
->update(['EquipAuthSeq' => $EquipAuthSeq]);
}
//3设备认证
$Hard = new HardMessage();
$AuthMessage = $Hard->Get_query_equip_auth($EquipAuthSeq, $params['ConnectorId']);
if ($AuthMessage['SuccStat'] != 0) {
$arr = [
'0' => '无',
'1' => '此设备尚未插枪',
'2' => '设备检测失败',
];
return ['code' => 1, 'message' => $arr[$AuthMessage['FailReason']] ?? '设备认证1-自定义错误信息' . $AuthMessage['FailReason']];
}
return ['code' => 2];
}
public function QRCode($address, $openid)
{
$exit = Db::table('user')->where('openid', $openid)->value('area');
if (!empty($exit)) {
$ConnectorID = substr($address, 7, 13);
$OperatorID = substr($address, 21, 9);
if ($OperatorID != '395815801') {
return json(['code' => 1, 'message' => '运营商出现问题']);
}
$Equipment = Db::table('charge_pile')->where('ConnectorID', $ConnectorID)->find();
$Station_id = $Equipment['charge_station_id'];
$Station_number = Db::table('charge_station')->where('charge_station_id', $Station_id)->value('charge_station_number');
$Station_name = Db::table('charge_station')->where('charge_station_id', $Station_id)->value('charge_station_name');
$no = $Equipment['no'];
$status = $Equipment['status'];
if ($status == 3 || $status == 4) {
return json(['code' => 1, 'message' => '该充电桩已被占用']);
} elseif ($status == 255) {
return json(['code' => 1, 'message' => '该充电桩故障']);
} elseif ($status == 1 || $status == 2) {
$kk['station_name'] = $Station_name;
$kk['station_number'] = $Station_number;
$kk['no'] = $no;
return json(['code' => 200, 'message' => '成功', 'data' => $kk]);
} elseif ($status == 0) {
return json(['code' => 1, 'message' => '该充电桩离网']);
}
} else {
return json(['code' => 1, 'message' => '没有获取到地址信息 请先登录']);
}
}
public function OrderDetail($openid, $order_number)
{
$table = 'zxc_charge_order';
$StartChargeSeq = Db::table($table)->where('order_number', $order_number)->value('StartChargeSeq');
$Equipment_number = Db::table($table)->where('order_number', $order_number)->value('Equipment_number');
$message['charge_length'] = null;
$status = Db::table($table)->where('order_number', $order_number)->value('status');
$end_time = Db::table($table)->where('order_number', $order_number)->value('end_time');
if (empty($end_time) && ($status == 2)) {
$Hard = new HardMessage();
$Hard->Get_query_equip_charge_status($StartChargeSeq);
}
$message = Db::table($table)->where('order_number', $order_number)->find();
$start_time = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('start_time');
$end_time = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('end_time');
if (isset($message['start_time']) && strtotime($message['start_time']) < strtotime('2099-02-03 00:00:00') && $message['status'] == 4) {
$station_type = \app\model\ChargeStation::where('charge_station_id', $message['charge_station_id'])->value('station_type');
if ($station_type == 0) {
$message['SeviceMoney'] = round($message['TotalPower'] * 0.2, 2);
} else {
$message['SeviceMoney'] = round($message['TotalPower'] * 0.4, 2);
}
$message['ElecMoney'] = round($message['TotalMoney'] - $message['SeviceMoney'], 2);
} else {
$message['ElecMoney'] = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('ElecMoney');
$message['SeviceMoney'] = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('SeviceMoney');
}
if (!empty($end_time)) {
$charge_length = (strtotime($end_time) - strtotime($start_time)) % 86400 / 3600;
Db::table($table)->where('order_number', $order_number)->update(['charge_length' => $charge_length]);
$message['charge_length'] = $charge_length;
}
$charge_station_id = Db::table($table)->where('order_number', $order_number)->value('charge_station_id');
$charge_station_number = Db::table('charge_station')->where('charge_station_id', $charge_station_id)->value('charge_station_number');
$charge_station_name = Db::table('charge_station')->where('charge_station_id', $charge_station_id)->value('charge_station_name');
$no = Db::table('charge_pile')->where('charge_pile_number', $Equipment_number)->value('no');
if ($message['TotalPower'] == null) {
$message['TotalPower'] = 0;
}
$message['TotalPower'] = number_format($message['TotalPower'], 3);
$message['charge_station_number'] = $charge_station_number;
$message['charge_station_name'] = $charge_station_name;
$message['no'] = $no;
if ($message['status'] == 1) {
$message['message'] = '启动中';
} elseif ($message['status'] == 2) {
$message['message'] = '充电中';
} elseif ($message['status'] == 3) {
$message['message'] = '停止中';
} elseif ($message['status'] == 4) {
$message['message'] = '已结束';
} elseif ($message['status'] == 5) {
$message['message'] = '未知错误';
}
if (strlen((string)$message['stop_type']) != 0 && $message['stop_type'] == 0) {
$message['stop_type'] = '正常停止';
} elseif ($message['stop_type'] == 4) {
$message['stop_type'] = '连接器断开';
} elseif ($message['stop_type'] == 5) {
$message['stop_type'] = '电池已充满';
} elseif ($message['stop_type'] == 7) {
$message['stop_type'] = '设备异常';
} elseif ($message['stop_type'] == 8) {
$message['stop_type'] = '枪头被拔下';
} elseif ($message['stop_type'] == 10) {
$message['stop_type'] = '设备故障';
} elseif ($message['stop_type'] == 11) {
$message['stop_type'] = '车辆故障';
} elseif ($message['stop_type'] == 14) {
$message['stop_type'] = '未知';
} elseif ($message['stop_type'] == 15) {
$message['stop_type'] = '系统异常';
} elseif ($message['stop_type'] == 22) {
$message['stop_type'] = '车辆识别失败';
} elseif ($message['stop_type'] == 24) {
$message['stop_type'] = '设备终止';
} elseif ($message['stop_type'] == 25) {
$message['stop_type'] = '互联互通终止';
} elseif ($message['stop_type'] == 26) {
$message['stop_type'] = '平台终止';
} elseif ($message['stop_type'] == 27) {
$message['stop_type'] = 'SOC限制终止';
} elseif ($message['stop_type'] == 13) {
$message['stop_type'] = '急停按钮被按下';
} elseif ($message['stop_type'] == 16) {
$message['stop_type'] = '主动防护';
} elseif ($message['stop_type'] == 6) {
$message['stop_type'] = 'BMS异常';
} elseif ($message['stop_type'] == 12) {
$message['stop_type'] = '账户余额不足';
} elseif ($message['stop_type'] == 31) {
$message['stop_type'] = '操作频繁，请稍后再试';
} elseif ($message['stop_type'] == 32) {
$message['stop_type'] = '请重新插枪启动充电';
} elseif ($message['stop_type'] == 33) {
$message['stop_type'] = '账户超出限额';
} elseif (strlen((string)$message['stop_type']) == 0) {
$message['stop_type'] = null;
} else {
$message['stop_type'] = '未知错误';
}
return json(['code' => 200, 'data' => $message]);
}
public function OrderDetail2($openid, $order_number)
{
$table = 'zxc_charge_order';
$message = Db::table($table)->where('order_number', $order_number)->find();
$message['charge_length'] = null;
if (empty($message['end_time']) && ($message['status'] == 2)) {
$Hard = new HardMessage();
$Hard->Get_query_equip_charge_status($message['StartChargeSeq']);
$message = Db::table($table)->where('order_number', $order_number)->find();
}
if (isset($message['start_time']) && strtotime($message['start_time']) < strtotime('2099-02-03 00:00:00') && $message['status'] == 4) {
$station_type = \app\model\ChargeStation::where('charge_station_id', $message['charge_station_id'])->value('station_type');
if ($station_type == 0) {
$message['SeviceMoney'] = round($message['TotalPower'] * 0.2, 2);
} else {
$message['SeviceMoney'] = round($message['TotalPower'] * 0.4, 2);
}
$message['ElecMoney'] = round($message['TotalMoney'] - $message['SeviceMoney'], 2);
}
if (!empty($message['end_time'])) {
$charge_length = (strtotime($message['end_time']) - strtotime($message['start_time'])) % 86400 / 3600;
Db::table($table)->where('order_number', $order_number)->update(['charge_length' => $charge_length]);
$message['charge_length'] = $charge_length;
}
$charge_station_info = Db::table('charge_station')
->where('charge_station_id', $message['charge_station_id'])
->field('charge_station_number,charge_station_name')
->find();
$no = Db::table('charge_pile')->where('ConnectorID', $message['ConnectorID'])->value('no');
if ($message['TotalPower'] == null) {
$message['TotalPower'] = 0;
}
$message['TotalPower'] = number_format($message['TotalPower'], 3);
$message['charge_station_number'] = $message['ConnectorID'];
$message['charge_station_name'] = $charge_station_info['charge_station_name'];
$message['no'] = $no;
$message_arr = [
'1' => '启动中',
'2' => '充电中',
'3' => '停止中',
'4' => '已结束',
'5' => '未知错误',
];
$message['message'] = $message_arr[$message['status']] ?? '未知错误';
if (strlen((string)$message['stop_type']) != 0 && $message['stop_type'] == 0) {
$message['stop_type'] = '正常停止';
} elseif ($message['stop_type'] == 4) {
$message['stop_type'] = '连接器断开';
} elseif ($message['stop_type'] == 5) {
$message['stop_type'] = '电池已充满';
} elseif ($message['stop_type'] == 7) {
$message['stop_type'] = '设备异常';
} elseif ($message['stop_type'] == 8) {
$message['stop_type'] = '枪头被拔下';
} elseif ($message['stop_type'] == 10) {
$message['stop_type'] = '设备故障';
} elseif ($message['stop_type'] == 11) {
$message['stop_type'] = '车辆故障';
} elseif ($message['stop_type'] == 14) {
$message['stop_type'] = '未知';
} elseif ($message['stop_type'] == 15) {
$message['stop_type'] = '系统异常';
} elseif ($message['stop_type'] == 22) {
$message['stop_type'] = '车辆识别失败';
} elseif ($message['stop_type'] == 24) {
$message['stop_type'] = '设备终止';
} elseif ($message['stop_type'] == 25) {
$message['stop_type'] = '互联互通终止';
} elseif ($message['stop_type'] == 26) {
$message['stop_type'] = '平台终止';
} elseif ($message['stop_type'] == 27) {
$message['stop_type'] = 'SOC限制终止';
} elseif ($message['stop_type'] == 13) {
$message['stop_type'] = '急停按钮被按下';
} elseif ($message['stop_type'] == 16) {
$message['stop_type'] = '主动防护';
} elseif ($message['stop_type'] == 6) {
$message['stop_type'] = 'BMS异常';
} elseif ($message['stop_type'] == 12) {
$message['stop_type'] = '账户余额不足';
} elseif ($message['stop_type'] == 31) {
$message['stop_type'] = '操作频繁，请稍后再试';
} elseif ($message['stop_type'] == 32) {
$message['stop_type'] = '请重新插枪启动充电';
} elseif ($message['stop_type'] == 33) {
$message['stop_type'] = '账户超出限额';
} elseif (strlen((string)$message['stop_type']) == 0) {
$message['stop_type'] = null;
} else {
$message['stop_type'] = '未知错误';
}
return json(['code' => 200, 'data' => $message]);
}
public function StationFee()
{
$params = input();
$station_number = $params['station_number'] ?? '';
$openid = $params['openid'] ?? '';
$charge_station_info = Db::table('charge_station')
->where('charge_station_number', $station_number)->find();
$user_info = Db::table('zxc_user')->where('openid', $openid)->field('type,account,group_id')->find();
// if ($user_info['type'] == 3) {
// $ServiceFee = ServiceFee::where('type', $user_info['type'])->where('group_id', $user_info['group_id'])->where('station_type', $charge_station_info['station_type'])->value('service_fee');
// } else {
// $ServiceFee = ServiceFee::where('type', $user_info['type'])->where('station_type', $charge_station_info['station_type'])->value('service_fee');
// }
$ServiceFee = ServiceFee::where('id', 1)->value('service_fee');
$time_price = $this->returnFree($charge_station_info['ElectricityFee'], $ServiceFee);
$ElectricityFee = str_replace('电费:', '', $charge_station_info['ElectricityFee']);
$Elect = explode(',', $ElectricityFee);
for ($index = 0; $index < count($Elect); $index++) {
$kk['time_interval'] = substr($Elect[$index], 0, 11);
$kk['univalence'] = explode(':', $Elect[$index])[3];
$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;
}
return json(['code' => 200, 'ElectricityFee' => $ss, 'ServiceFee' => $mm, 'data' => $time_price, 'balance' => $user_info ? $user_info['account'] : '0.00']);
}
//改后暂未使用
public function QueryPayStatus($openid)
{
$table = 'zxc_charge_order';
$paystatus = Db::table($table)->where('openid', $openid)->order('start_time desc')->value('PayStatus');
if ($paystatus == 1) {
$message['paystatus'] = 1;
$message['paymessage'] = '存在订单未支付 无法生成';
return json(['code' => 1, 'data' => $message]);
} elseif ($paystatus == 2 || empty($paystatus)) {
$message['paystatus'] = 2;
$message['paymessage'] = '订单已全部支付 可以正常生成订单';
return json(['code' => 200, 'data' => $message]);
} elseif ($paystatus == 0) {
$message['paystatus'] = 0;
$message['paymessage'] = '订单未完成 请先完成当前订单';
return json(['code' => 1, 'data' => $message]);
}
}
/**
* 显示指定的资源
*
* @param int $id
* @return \think\Response
*/
public function read_order(Request $request)
{
$data = $request->param();
$table = 'zxc_charge_order';
$count = Db::table($table)->select()->count();
$query = Db::table($table)->paginate(20, $count)->toArray();
$i = 0;
foreach ($query['data'] as $d) {
$query['data'][$i]['order_id'] = $i + 1;
if (strtotime($query['data'][$i]['start_time']) < strtotime('2023-02-03 00:00:00') && ($query['data'][$i]['ElecMoney'] + $query['data'][$i]['SeviceMoney']) != $query['data'][$i]['TotalMoney']) {
$station_type = \app\model\ChargeStation::where('charge_station_id', $query['data'][$i]['charge_station_id'])->value('station_type');
if ($station_type == 0) {
$query['data'][$i]['SeviceMoney'] = round(($query['data'][$i]['TotalPower'] * 0.2), 2);
} else {
$query['data'][$i]['SeviceMoney'] = round(($query['data'][$i]['TotalPower'] * 0.4), 2);
}
$query['data'][$i]['ElecMoney'] = round($query['data'][$i]['TotalMoney'] - $query['data'][$i]['SeviceMoney'], 2);
}
$station_name = \app\model\ChargeStation::where('charge_station_id', $query['data'][$i]['charge_station_id'])->value('charge_station_name');
$query['data'][$i]['charge_station_name'] = $station_name;
$i += 1;
}
return json($query);
}
public function order_all(Request $request)
{
$data = $request->param();
$table = 'zxc_charge_order';
$charge_station_name = $data['charge_station_name'];
$charge_station_id = Db::table('charge_station')->where('charge_station_name', $charge_station_name)->value('charge_station_id');
$list = Db::table($table)->where('charge_station_id', $charge_station_id)->select();
return json($list);
}
public function read_equipment(Request $request)
{
$data = $request->param();
$where = [];
if (isset($data['area'])) {
$where[] = ['street', '=', $data['area']];
}
if (isset($data['charge_station_name'])) {
$where[] = ['charge_station_name', '=', $data['charge_station_name']];
}
if (isset($data['status'])) {
$where[] = ['status', '>', 3];
}
$mess = Db::table('charge_pile')->where($where)->orderRaw('charge_station_id asc,CAST(no AS SIGNED) ASC')->paginate([
'list_rows' => 20,
'query' => request()->param()
]);
$statusMap = [
'1' => '空闲中',
'2' => '联通中',
'3' => '充电中',
'0' => '离网中',
'255' => '故障中'
];
$mess->each(function($item, $key) use ($statusMap) {
$item['status_text'] = $statusMap[(int)$item['status']] ?? '未知';
$item['charge_station_name'] = Db::table('charge_station')->where('charge_station_id', $item['charge_station_id'])->value('charge_station_name');
return $item;
});
return json($mess);
}
public function read_total(Request $request)
{
$data = $request->param();
$charge_station_name = $data['charge_station_name'];
$charge_station_id = Db::table('charge_station')->where('charge_station_name', $charge_station_name)->value('charge_station_id');
$table = 'zxc_charge_order';
$revenue = Db::table($table)->where('charge_station_id', $charge_station_id)->sum('TotalMoney');
$degree = Db::table($table)->where('charge_station_id', $charge_station_id)->sum('TotalPower');
$order_num = Db::table($table)->where('charge_station_id', $charge_station_id)->count();
$message = [
'charge_station_id' => $charge_station_id,
'degree' => round($degree, 2),
'revenue' => round($revenue, 2),
'order_num' => $order_num
];
return json($message);
}
public function EndOrder($openid, $order_number)
{
$table = 'zxc_charge_order';
$StartChargeSeq = Db::table($table)->where('order_number', $order_number)->value('StartChargeSeq');
$ConnectorID = Db::table($table)->where('order_number', $order_number)->value('ConnectorID');
$Hard = new HardMessage();
$Stop = $Hard->Get_query_stop_charge($StartChargeSeq, $ConnectorID);
$StopFailReson = Db::table($table)->where('order_number', $order_number)->value('StopFailreason');
if (!empty($StopFailReson) && (int)$StopFailReson == 2) {
return json(['code' => 1, 'message' => '设备离线，请耐心等待，请直接拔枪，后续信息会回传']);
} elseif (!empty($StopFailReson) && (int)$StopFailReson == 15) {
return json(['code' => 1, 'message' => '系统异常，请多次尝试，或直接拔枪，后续信息会回传']);
}
if ($Stop['StartChargeSeqStat'] == 3 && $Stop['SuccStat'] == 0 && $Stop['FailReason'] == 0) {
return json(['code' => 200, 'message' => '正在结束充电']);
} elseif ($Stop['SuccStat'] == 1) {
if ($Stop['FailReason'] == 1) {
return json(['code' => 1, 'message' => '请求停止充电失败 此设备不存在']);
} elseif ($Stop['FailReason'] == 2) {
return json(['code' => 1, 'message' => '请求停止充电失败 此设备离线']);
} elseif ($Stop['FailReason'] == 3) {
return json(['code' => 1, 'message' => '请求停止充电失败 设备已停止充电']);
} elseif ($Stop['FailReason'] == 4) {
return json(['code' => 1, 'message' => '请求停止充电失败 订单编号不符合规范']);
} else {
return json(['code' => 1, 'message' => '请求停止充电失败 系统异常']);
}
} elseif ($Stop['SuccStat'] == 0 && $Stop['FailReason'] == 0) {
return json(['code' => 200, 'message' => '正在结束充电']);
} else {
return json(['code' => 1, 'message' => '未知原因']);
}
}
// 请求停止充电
public function EndOrder2($order_number)
{
$charge_info = Db::table('zxc_charge_order')->where('order_number', $order_number)->find();
$StopFailReson = $charge_info['StopFailreason'];
if (!empty($StopFailReson) && (int)$StopFailReson == 2) {
return json(['code' => 1, 'message' => '设备离线，请耐心等待，请直接拔枪，后续信息会回传']);
} elseif (!empty($StopFailReson) && (int)$StopFailReson == 15) {
return json(['code' => 1, 'message' => '系统异常，请多次尝试，或直接拔枪，后续信息会回传']);
}
//请求停止充电
$Hard = new HardMessage();
$Stop = $Hard->Get_query_stop_charge($charge_info['StartChargeSeq'], $charge_info['ConnectorID']);
if ($Stop['StartChargeSeqStat'] == 3 && $Stop['SuccStat'] == 0 && $Stop['FailReason'] == 0) {
return json(['code' => 200, 'message' => '正在结束充电']);
} elseif ($Stop['SuccStat'] == 1) {
$arr = [
'1' => '请求停止充电失败 此设备不存在',
'2' => '请求停止充电失败 此设备离线',
'3' => '请求停止充电失败 设备已停止充电',
'4' => '请求停止充电失败 订单编号不符合规范'
];
return json(['code' => 1, 'message' => $arr[$Stop['FailReason']] ?? '请求停止充电失败 系统异常']);
} elseif ($Stop['SuccStat'] == 0 && $Stop['FailReason'] == 0) {
return json(['code' => 200, 'message' => '正在结束充电']);
} else {
return json(['code' => 1, 'message' => '未知原因']);
}
}
public function total()
{
$already_revenue = ChargeOrderModel::where('status', 1)->sum('revenue');
$total_revenue = ChargeOrderModel::sum('revenue');
$total_degree = ChargeOrderModel::sum('charge_degree');
$message = [
'已收益' => $already_revenue,
'总收益' => $total_revenue,
'总耗电量' => $total_degree
];
return json([
'code' => 200,
'message' => $message
]);
}
public function List_ToWechat()
{
$list = Db::table('charge_order,charge_pile')
->where('charge_order.Equipment_number=charge_pile.charge_pile_number')
->field('order_number,start_time,end_time,charge_length,revenue,stop_type,charge_order.Equipment_number,charge_pile.charge_pile_name,charge_pile.power')
->select()->toArray();
for ($i = 0; $i < count($list); $i++) {
$list[$i]['charge_length'] *= 60;
if ($list[$i]['stop_type'] == 1) {
$list[$i]['stop_type'] = '正常停止';
} elseif ($list[$i]['stop_type'] == 2) {
$list[$i]['stop_type'] = '强制停止';
} elseif ($list[$i]['stop_type'] == 3) {
$list[$i]['stop_type'] = '故障停止';
}
}
return json($list);
}
public function StreetWithName()
{
$area = Db::table('area_three')->column('area');
foreach ($area as $a) {
$station = Db::table('charge_station')->where('street', $a)->column('charge_station_name');
$i = 0;
foreach ($station as $st) {
$name = $a . $i . '号充电站';
$station_id = Db::table('charge_station')->where(['street' => $a, 'charge_station_name' => $st])->value('charge_station_id');
$flag = Db::table('charge_station')->where('charge_station_id', $station_id)->value('charge_station_name');
if (empty($flag)) {
Db::table('charge_station')->where('charge_station_id', $station_id)->update(['charge_station_name' => $name]);
} else {
$i += 1;
}
$i += 1;
}
}
$data = [];
foreach ($area as $a) {
$station_data = [];
$station = Db::table('charge_station')->where('street', $a)->column('charge_station_name');
$i = 1;
foreach ($station as $s) {
array_push($station_data, ['station' => $s]);
$i += 1;
}
array_push($data, ['station' => $a, 'children' => $station_data]);
}
return json($data);
}
public function OrderList($openid)
{
$table = 'zxc_charge_order';
$list = Db::table($table)->where('openid', $openid)->order('order_id desc')->select()->toArray();
$i = 0;
foreach ($list as $l) {
if (!empty($l['end_time']) && ($l['start_time'] != $l['end_time']) && ($l['status'] == 2 || $l['status'] == 5)) {
Db::table($table)->where('order_number', $l['order_number'])->save(['status' => 4, 'StartChargeSeqStat' => 4, 'TotalMoney' => round($l['WithholdingMoney'] - $l['FeedbackMoney'], 2)]);
} elseif (!empty($l['end_time']) && ($l['start_time'] == $l['end_time'])) {
Db::table($table)->where('order_number', $l['order_number'])->save(['status' => 5, 'StartChargeSeqStat' => 5]);
} elseif (empty($l['end_time']) && $l['status'] == 4 && empty($l['FeedbackMoney'])) {
$this->AmendmentOrders($openid, $table, $l['StartChargeSeq'], $l['WithholdingMoney']);
}
}
$list = Db::table($table)->where('openid', $openid)->order('order_id desc')->select()->toArray();
foreach ($list as $l) {
if ($l['status'] == 1 || $l['status'] == 2 || $l['status'] == 3) {
$list[$i]['status'] = '正在充电中';
} elseif ($l['status'] == 4) {
$list[$i]['status'] = '充电完成';
} else {
$list[$i]['status'] = '系统异常';
}
$list[$i]['TotalMoney'] = sprintf("%01.2f", $list[$i]['TotalMoney']);
$i += 1;
}
return json($list);
}
public function OrderList2($openid)
{
$table = 'zxc_charge_order';
$list = Db::table($table)->where('openid', $openid)->order('order_id desc')->select()->toArray();
$i = 0;
foreach ($list as $l) {
if (!empty($l['end_time']) && ($l['start_time'] != $l['end_time']) && ($l['status'] == 2 || $l['status'] == 5)) {
Db::table('zxc_charge_order')->where('order_number', $l['order_number'])->save(['status' => 4, 'StartChargeSeqStat' => 4, 'TotalMoney' => round($l['WithholdingMoney'] - $l['FeedbackMoney'], 2)]);
} elseif (!empty($l['end_time']) && ($l['start_time'] == $l['end_time'])) {
Db::table('zxc_charge_order')->where('order_number', $l['order_number'])->save(['status' => 5, 'StartChargeSeqStat' => 5]);
} elseif (empty($l['end_time']) && $l['status'] == 4 && empty($l['FeedbackMoney'])) {
$this->AmendmentOrders($openid, 'zxc_charge_order', $l['StartChargeSeq'], $l['WithholdingMoney']);
}
}
$list = Db::table($table)->where('openid', $openid)->field('order_number,start_time,end_time,TotalMoney,status,PayStatus,WithholdingMoney,FeedbackMoney,StartChargeSeqStat,StartChargeSeq')->order('order_id desc')->select()->toArray();
foreach ($list as $l) {
if ($l['status'] == 1 || $l['status'] == 2 || $l['status'] == 3) {
$list[$i]['status'] = '正在充电中';
} elseif ($l['status'] == 4) {
$list[$i]['status'] = '充电完成';
} else {
$list[$i]['status'] = '系统异常';
}
$list[$i]['TotalMoney'] = sprintf("%01.2f", $list[$i]['TotalMoney']);
$i += 1;
}
return json($list);
}
public function AmendmentAccount($table, $StartChargeSeq)
{
$hard = new HardMessage();
$data = $hard->Get_query_equip_charge_status_test($StartChargeSeq);
$TotalMoney = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('TotalMoney');
$TotalMoney = round($TotalMoney, 2);
if ($data['code'] == 200 && $TotalMoney == $data['data']['TotalMoney']) {
Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->save([
'TotalPower' => $data['data']['TotalPower'],
'ElecMoney' => $data['data']['ElecMoney'],
'SeviceMoney' => $data['data']['SeviceMoney'],
]);
}
}
protected function AmendmentOrders($openid, $table, $StartChargeSeq, $WithholdingMoney)
{
$hard = new HardMessage();
$data = $hard->Get_query_equip_charge_status_test($StartChargeSeq);
if ($data['code'] == 200) {
$FeedbackMoney = $WithholdingMoney - $data['data']['TotalMoney'];
$table_user = 'zxc_user';
$check = Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->value('FeedbackMoney');
if (empty($check)) {
Db::table($table_user)->where('openid', $openid)->update(['account' => Db::raw('account+' . round($FeedbackMoney, 2))]);
Db::table($table)->where('StartChargeSeq', $StartChargeSeq)->save([
'end_time' => $data['data']['EndTime'],
'charge_degree' => $data['data']['TotalPower'],
'stop_type' => 25,
'TotalPower' => $data['data']['TotalPower'],
'ElecMoney' => $data['data']['ElecMoney'],
'SeviceMoney' => $data['data']['SeviceMoney'],
'TotalMoney' => $data['data']['TotalMoney'],
'Soc' => $data['data']['Soc'],
'DetailMessage' => $data['data']['DetailMessage'],
'FeedbackMoney' => $FeedbackMoney,
'status' => $data['data']['StartChargeSeqStat']
]);
}
}
}
public function OrderNum($openid)
{
$table = 'zxc_charge_order';
$count = Db::table($table)->where('openid', $openid)->field('order_number,start_time,end_time,revenue,status')->count();
return json(['code' => 200, 'message' => '请求成功', 'count' => $count]);
}
public function RechargeRecord($openid)
{
$table = 'zxc_recharge';
$list = Db::table($table)->where('openid', $openid)->order('id desc')->select()->toArray();
$i = 0;
foreach ($list as $l) {
$list[$i]['total'] /= 100;
$list[$i]['payer_total'] /= 100;
if ($list[$i]['trade_state'] == 'SUCCESS') {
$list[$i]['trade_state'] = '支付成功';
} else {
$list[$i]['trade_state'] = '支付失败';
}
$i += 1;
}
return json($list);
}
public function RechargeAll($start_time = '', $end_time = '')
{
if (!empty($end_time)) {
$end_time = date("Y-m-d", strtotime("+1day", strtotime($end_time)));
}
$query = Db::table('zxc_recharge')->select()->toArray();
$i = 0;
foreach ($query as $d) {
$query[$i]['id'] = $i + 1;
$query[$i]['total'] = round($query[$i]['total'] / 100, 2);
$query[$i]['payer_total'] = round($query[$i]['payer_total'] / 100, 2);
$i += 1;
}
return json($query);
}
public function RechargeAllExport($start_time = '', $end_time = '')
{
$where = [];
if ($start_time) {
$where[] = ['success_time', '>=', $start_time];
}
if ($end_time) {
$where[] = ['success_time', '<=', $end_time];
}
$list = Db::table('zxc_recharge')->where($where)->order('id desc')->select()->toArray();
foreach ($list as $key => &$value) {
$value['total'] = round($value['total'] / 100, 2);
$value['payer_total'] = round($value['payer_total'] / 100, 2);
$table = 'zxc_user';
$phone = Db::table($table)->where('openid', $value['openid'])->value('phone');
$value['phone'] = $phone;
}
return json($list);
}
public function OrderExport($charge_station_name = '', $start_time = '', $end_time = '')
{
$where = [];
if ($charge_station_name) {
$charge_station_id = Db::table('charge_station')->where('charge_station_name', $charge_station_name)->value('charge_station_id');
if ($charge_station_id) {
$where[] = ['charge_station_id', '=', $charge_station_id];
}
}
if ($start_time) {
$where[] = ['start_time', '>=', $start_time];
}
if ($end_time) {
$where[] = ['start_time', '<=', $end_time];
}
$list = Db::table('zxc_charge_order')
->where($where)
->field('charge_station_id,order_number,order_id,TotalPower,TotalMoney,ElecMoney,SeviceMoney,end_time,EndTime,DetailMessage,status,start_time,openid')
->order('start_time DESC')
->select(); // 获取全部数据
foreach ($list as $key => &$value) {
$value['charge_station_name'] = Db::table('charge_station')->where('charge_station_id', $value['charge_station_id'])->value('charge_station_name');
$table = 'zxc_user';
$phone = Db::table($table)->where('openid', $value['openid'])->value('phone');
$value['phone'] = $phone;
}
return json($list);
}
/**
* @throws DataNotFoundException
* @throws ModelNotFoundException
* @throws DbException
*/
public function OrderQuery($message)
{
$table = 'zxc_charge_order';
$query = Db::table($table)->where('openid', 'like', '%' . $message . '%')->select()->toArray();
$i = 0;
foreach ($query as $d) {
if (strtotime($query[$i]['start_time']) < strtotime('2023-02-03 00:00:00') && ($query[$i]['ElecMoney'] + $query[$i]['SeviceMoney']) != $query[$i]['TotalMoney']) {
$station_type = \app\model\ChargeStation::where('charge_station_id', $d['charge_station_id'])->value('station_type');
if ($station_type == 0) {
$query[$i]['SeviceMoney'] = round(($query[$i]['TotalPower'] * 0.2), 2);
} else {
$query[$i]['SeviceMoney'] = round(($query[$i]['TotalPower'] * 0.4), 2);
}
$query[$i]['ElecMoney'] = round($query[$i]['TotalMoney'] - $query[$i]['SeviceMoney'], 2);
}
$query[$i]['order_id'] = $i + 1;
$query[$i]["charge_station_name"] = Db::table('charge_station')->where('charge_station_id', $query[$i]['charge_station_id'])->value('charge_station_name');
$i += 1;
}
return json(['data' => $query]);
}
/**
* @param $order
* @param string $union
* @return string
*/
protected function getStr($order, string $union): string
{
if (!empty($order) && (int)$order == 1) {
$union .= ' AND ' . ' (status = 1 or status = 2 or status = 3)';
} elseif (!empty($order) && (int)$order == 2) {
$union .= ' AND ' . ' status = 4';
} elseif (!empty($order) && (int)$order == 3) {
$union .= ' AND ' . ' status = 5';
}
return $union;
}
protected function getSelect1($order, $query)
{
if (!empty($order) && (int)$order == 1) {
$query = $query->whereOr('status', 1)->whereOr('status', 2)->whereOr('status', 3)->select();
} elseif (!empty($order) && (int)$order == 2) {
$query = $query->whereOr('status', 4)->select();
} elseif (!empty($order) && (int)$order == 3) {
$query = $query->whereOr('status', 5)->select();
} else {
$query = $query->select();
}
return $query;
}
// 查询充电桩信息
public function getChargePileNew($start_time = "", $end_time = "", $station_name = [], $selectt = "", $listQuery = "")
{
$station_name = array_merge(...array_map(fn($item) => json_decode($item, true), $station_name));
$statusMap = [
'1' => '空闲中',
'2' => '联通中',
'3' => '充电中',
'0' => '离网中',
'255' => '故障中'
];
$where = [];
if (!empty($station_name)) {
$charge_station_ids = Db::table('charge_station')->where('charge_station_name', 'in', implode(',', $station_name))->column('charge_station_id');
$where[] = ['charge_station_id', 'in', $charge_station_ids];
}
$pileList = Db::table('charge_pile')->where($where)->order('charge_station_id,ConnectorID')->select()->toArray();
// 获取所有充电站ID
$stationIds = array_unique(array_column($pileList, 'charge_station_id'));
// 批量查询充电站名称
$stations = Db::table('charge_station')
->whereIn('charge_station_id', $stationIds)
->column('charge_station_name', 'charge_station_id');
$where = [];
if (!empty($station_name)) {
$charge_station_ids = Db::table('charge_station')->where('charge_station_name', 'in', $station_name)->column('charge_station_id');
$ids = array_map('intval', $charge_station_ids); // 强制转为整数
$where[] = ['charge_station_id', 'in', implode(',', $ids)];
}
if (!empty($selectt) && !empty($listQuery)) {
if ($selectt == 1) {
// 当天查询 (格式: YYYY-MM-DD 00:00:00)
$listQuery = $listQuery . ' 00:00:00';
$where[] = ['charge_date', '=', $listQuery];
} elseif ($selectt == 3) {
// 当月查询 (格式: YYYY-MM)
$monthStart = date('Y-m-01 00:00:00', strtotime($listQuery));
$monthEnd = date('Y-m-t 23:59:59', strtotime($listQuery));
$where[] = ['charge_date', '>=', $monthStart];
$where[] = ['charge_date', '<=', $monthEnd];
} elseif ($selectt == 5) {
// 当年查询 (格式: YYYY)
$yearStart = date('Y-01-01 00:00:00', strtotime($listQuery));
$yearEnd = date('Y-12-31 23:59:59', strtotime($listQuery));
$where[] = ['charge_date', '>=', $yearStart];
$where[] = ['charge_date', '<=', $yearEnd];
}
} else {
if (!empty($start_time)) {
$where[] = ['start_time', '>=', $start_time];
}
if (!empty($end_time)) {
$where[] = ['start_time', '<=', $end_time];
}
}
$allOrders = Db::table('zxc_charge_order')
->where($where)
->order('charge_station_id ASC,ConnectorID')
->select()->toArray();
$ordersByConnector = [];
foreach ($allOrders as $order) {
$connectorId = $order['ConnectorID'];
if (!isset($ordersByConnector[$connectorId])) {
$ordersByConnector[$connectorId] = [];
}
$ordersByConnector[$connectorId][] = $order;
}
foreach ($pileList as &$pile) {
// 设置状态文本
$pile['status_text'] = $statusMap[$pile['status']] ?? '未知状态';
// 设置充电站名称
$pile['charge_station_name'] = $stations[$pile['charge_station_id']] ?? '未知电站';
// 初始化统计数据
$pile['totalPower'] = 0; // 总电量(kWh)
$pile['totalTime'] = 0; // 总时长(秒)
$pile['totalPrice'] = 0; // 总费用(元)
// 获取该充电桩的所有订单
$connectorId = $pile['ConnectorID'];
if (isset($ordersByConnector[$connectorId])) {
foreach ($ordersByConnector[$connectorId] as $order) {
// 计算充电时长（秒）
if (!empty($order['end_time']) && !empty($order['start_time'])) {
$startTime = strtotime($order['start_time']);
$endTime = strtotime($order['end_time']);
if ($startTime && $endTime && $endTime > $startTime) {
$pile['totalTime'] += ($endTime - $startTime);
}
}
// 累加电量和费用
$pile['totalPower'] += floatval($order['TotalPower'] ?? 0);
$pile['totalPrice'] += floatval($order['TotalMoney'] ?? 0);
}
}
// 将秒转换为小时:分钟:秒格式
$pile['totalTimeFormatted'] = number_format(($pile['totalTime'] / 3600), 4);
// 格式化金额和电量
$pile['totalPrice'] = number_format($pile['totalPrice'], 2);
$pile['totalPower'] = number_format($pile['totalPower'], 2);
}
return $pileList;
}
}
Reference in New Issue Copy Permalink