429 lines
18 KiB
PHP
429 lines
18 KiB
PHP
<?php
|
||
|
||
/**
|
||
* @author Any
|
||
* @description KISS
|
||
* @date 2020-12-2
|
||
* @version 1.0.0
|
||
*
|
||
* _____LOG_____
|
||
*
|
||
*/
|
||
|
||
namespace app\modules\api\models;
|
||
|
||
use app\models\Order;
|
||
use app\models\OrderDetail;
|
||
use app\models\UserCoupon;
|
||
use app\modules\api\components\Mqtt;
|
||
use function AlibabaCloud\Client\value;
|
||
use app\components\FlashStorage;
|
||
use app\components\SiteHelper;
|
||
use app\models\BallCart;
|
||
use app\models\BallMark;
|
||
use app\models\Coach;
|
||
use app\models\DeviceUniqueBindUser;
|
||
use app\models\Store;
|
||
use app\models\User;
|
||
use app\components\auth\AToken;
|
||
use app\components\EncryptHelper;
|
||
use app\modules\api\components\ApiHelper;
|
||
use app\modules\api\components\GetDistance;
|
||
use yii\data\Pagination;
|
||
|
||
|
||
class BallCartForm extends ApiModel
|
||
{
|
||
|
||
|
||
public $user_id;
|
||
public $cx_mch_id;
|
||
public $store_id;
|
||
|
||
public $limit;
|
||
public $page;
|
||
public $pageCount; // 总页数
|
||
|
||
public $redis_name = 'api:cxaibc:ball_cart_v2:';
|
||
|
||
const BALL_CART_INFO = 'api:cxaibc:mqtt:data:';
|
||
|
||
public $user_type;
|
||
public $init_order; // 第一次进入
|
||
|
||
public function rules()
|
||
{
|
||
return [
|
||
[['store_id','init_order'], 'string'],
|
||
[['limit', 'page','user_id','init_order'], 'integer'],
|
||
[['page'], 'default', 'value' => 1],
|
||
[['limit'], 'default', 'value' => 20],
|
||
];
|
||
}
|
||
|
||
|
||
public function search()
|
||
{
|
||
if (!$this->validate()) {
|
||
return $this->getModelError();
|
||
}
|
||
$query = BallCart::find()->alias('ball')
|
||
->leftJoin(['store' => Store::tableName()], 'ball.store_id=store.id')
|
||
->leftJoin(['mark' => BallMark::tableName()], 'ball.mark_id=mark.id')
|
||
->select('ball.id,ball.cover_pic,ball.money,mark.name as mark_name,mark.id as mard_id,ball.ball_number,ball.status,store.name')
|
||
->where([
|
||
'ball.is_delete' => 0,
|
||
])->andWhere(['!=', 'ball.status', 2])
|
||
->andFilterWhere([
|
||
'ball.store_id' => $this->store_id
|
||
]);
|
||
|
||
$count = $query->count();
|
||
$pagination = new Pagination(['totalCount' => $count, 'pageSize' => $this->limit, 'page' => $this->page - 1]);
|
||
$list = $query->offset($pagination->offset)->limit($pagination->limit)->orderBy(['ball.id' => SORT_DESC])->asArray()->all();
|
||
$this->pageCount = $pagination->pageCount;
|
||
|
||
//门店管理员
|
||
if ($this->user_type == 2) {
|
||
$store_user_info = ApiHelper::findOneUserStoreId($this->user_id);
|
||
if ($store_user_info['user_type'] == 3) {
|
||
$user_store_id = 0;
|
||
} else {
|
||
$user_store_id = $store_user_info['store_id'] ? $store_user_info['store_id'] : 0;
|
||
}
|
||
}
|
||
|
||
if ($list) {
|
||
$temp_data = [];
|
||
///可以查看为0，否则为1
|
||
foreach ($list as $key => $value) {
|
||
$list[$key]['cover_pic'] = SiteHelper::getFullUrl($value['cover_pic']);
|
||
$list[$key]['ball_user_stauts'] = 0; // 正确
|
||
$list[$key]['ball_info_stauts'] = 0; // 是否能进入详情页面
|
||
$list[$key]['order_id'] = 0; # 订单号
|
||
$ball_less = $this->lease($value['ball_number']);
|
||
if ($ball_less['code'] != 0) {
|
||
// $list[$key]['ball_arr'] = json_decode('{"orig_data":"","TIMESTAMP":0,"IMEI":"","SIMID":"","CSQ":0,"OPERATION_ENABLE":0,"OPERATION_LEVEL":0,"MODE":0,"ELEC_PERCENT":0,"RANGE":0,"RANGE_CURRENT":0,"RUNTIME":0,"RUNTIME_CURRENT":0}', true);
|
||
unset($list[$key]);
|
||
continue;
|
||
} else {
|
||
$list[$key]['ball_arr'] = $ball_less['data']['ball_arr'];
|
||
}
|
||
|
||
//租赁中
|
||
if ($value['status'] == 1) {
|
||
$find_order = Order::find()->alias('o')
|
||
->join('inner join', ['od' => OrderDetail::tableName()], 'o.id=od.order_id')
|
||
->andWhere([
|
||
'od.goods_id' => $value['ball_number'],
|
||
'o.is_delete' => 0,
|
||
'od.is_delete' => 0,
|
||
])->andWhere([
|
||
'in', 'o.status', [1, 2]
|
||
])->select('o.id,o.store_id,o.user_id')->asArray()->one();
|
||
|
||
// 能否进入控制台，是否为当前车辆的购买者，是否为当前车辆的管理者
|
||
if (!empty($find_order) && ($find_order['user_id'] == $this->user_id || $find_order['store_id'] == $user_store_id)) {
|
||
//判断是否是自己租赁的球车
|
||
if ($find_order['user_id'] == $this->user_id) {
|
||
$list[$key]['ball_user_stauts'] = 0;
|
||
} else {
|
||
$list[$key]['ball_user_stauts'] = 1;
|
||
}
|
||
// 是否能进入详情页面
|
||
$list[$key]['ball_info_stauts'] = 1;
|
||
//判断车辆管理者显示归还功能 0 显示确认归还 1 不显示
|
||
$list[$key]['ball_user_store'] = $find_order['store_id'] == $user_store_id ? 0 : 1;
|
||
if ($find_order['user_id'] == $this->user_id) {
|
||
$temp_data['user_data'][] = $list[$key];
|
||
} else {
|
||
$temp_data['un_data'][] = $list[$key];
|
||
}
|
||
} else {
|
||
$list[$key]['ball_user_store'] = $find_order['store_id'] == $user_store_id ? 0 : 1;
|
||
$list[$key]['ball_user_stauts'] = 1;
|
||
$list[$key]['ball_info_stauts'] = 0;
|
||
$temp_data['un_data'][] = $list[$key];
|
||
}
|
||
/*
|
||
$redis_name = $this->redis_name . $value['ball_number']; //租赁当前球车的用户ID
|
||
$ball_redis_user = \Yii::$app->redis->get($redis_name);
|
||
if($ball_redis_user == $this->user_id){
|
||
|
||
|
||
}else{
|
||
$list[$key]['ball_user_stauts'] = 1;
|
||
$list[$key]['ball_info_stauts'] = 0;
|
||
}*/
|
||
} else {
|
||
$temp_data['success_data'][] = $list[$key];
|
||
}
|
||
}
|
||
|
||
$list = [];
|
||
$list = array_merge($list, $temp_data['user_data'] ?? []);
|
||
$list = array_merge($list, $temp_data['success_data'] ?? []);
|
||
$list = array_merge($list, $temp_data['un_data'] ?? []);
|
||
}
|
||
// $list = array_merge($list);
|
||
$count = count($list);
|
||
$end_flag = $this->page >= $pagination->pageCount ? true : false;
|
||
return [
|
||
'code' => 0,
|
||
'msg' => 'ok',
|
||
'data' => $list,
|
||
'count' => $count,
|
||
'page_size' => $this->limit,
|
||
'page_count' => $this->pageCount,
|
||
'page_no' => $this->page,
|
||
'end_flag' => $end_flag
|
||
];
|
||
}
|
||
|
||
|
||
/**
|
||
*球车详情
|
||
*/
|
||
public function lease($ball_number)
|
||
{
|
||
if (empty($ball_number)) {
|
||
return $this->apiReturnError('球车编号不能为空');
|
||
}
|
||
$redis_name = self::BALL_CART_INFO . $ball_number . '_Detail';
|
||
$redis_name_lock = $redis_name . "_ttl_lock";
|
||
$qc_status_error = "";
|
||
|
||
$video_url = '';
|
||
// $content = base64_decode(SiteHelper::getCustomiseOptionByKey("_page_handle_video_", "hump"));
|
||
// if(!empty($content)){
|
||
// $content = SiteHelper::getFullUrl($content);
|
||
// $video_url = $content;
|
||
// }
|
||
if(!empty($this->init_order) && !empty($this->user_id)){
|
||
$redis_name = "cxaibc:api:actionHandleVideo_v1";
|
||
$get = \Yii::$app->redis->get($redis_name);
|
||
//保留观看视频
|
||
$user = ApiHelper::findOneUser($this->user_id);
|
||
if (empty($user->is_view) && !empty($get)) {
|
||
$content = base64_decode(SiteHelper::getCustomiseOptionByKey("_page_handle_video_", "hump"));
|
||
if(!empty($content)){
|
||
$content = SiteHelper::getFullUrl($content);
|
||
$video_url = $content;
|
||
}
|
||
}
|
||
|
||
// 初始化所有订单，把此用户未支付的订单全变更为取消，并返还优惠券
|
||
$select_data = Order::find()->andWhere([
|
||
'user_id' => $this->user_id,
|
||
'is_pay' => 0,
|
||
'cancel_status' => 0,
|
||
'is_delete' => 0,
|
||
])->andWhere([
|
||
'in','status',[4,5]
|
||
])->select('*')->all();
|
||
if(!empty($select_data)){
|
||
foreach ($select_data as $key=>$val){
|
||
$t = \Yii::$app->db->beginTransaction();
|
||
$val->status = 4;
|
||
$val->cancel_status = 1;
|
||
$val->is_delete = 0;
|
||
if(!$val->save()){
|
||
$t->rollBack();
|
||
continue;
|
||
}
|
||
// 归还车辆信息
|
||
$order_detail = OrderDetail::findOne(['order_id' => $val->id]);
|
||
if(!empty($order_detail)){
|
||
$ball_cart = BallCart::find()->where(['status' => 3,'is_delete' => 0,'ball_number' => $order_detail->goods_id])->one();
|
||
if(!empty($ball_cart)){
|
||
$ball_cart->status = 0;
|
||
$ball_cart->save();
|
||
}
|
||
}
|
||
if(!empty($val->use_user_coupon_id)){
|
||
// 退回优惠券
|
||
UserCoupon::updateAll([
|
||
'status' => 0,
|
||
'updated_at' => time(),
|
||
],[
|
||
'id' => $val->use_user_coupon_id,
|
||
'is_delete' => 0,
|
||
]);
|
||
}
|
||
$t->commit();
|
||
}
|
||
}
|
||
|
||
// 判断当前用户所属门店
|
||
$store_data = ApiHelper::findOneUserStoreId($this->user_id);
|
||
$ball_cart = BallCart::find()->andWhere(['ball_number' => $ball_number, 'is_delete' => 0])->orderBy(['id' => SORT_DESC])->one();
|
||
if (empty($store_data) || $store_data->store_id != $ball_cart->store_id) {
|
||
//查看用户是否有进行中的订单
|
||
$orderIng = Order::find()->alias('o')
|
||
// ->innerJoin(['rt' => OrderDetail::tableName()], 'o.id=rt.order_id')
|
||
->andWhere(['o.user_id' => $this->user_id,])
|
||
// ->andWhere(['o.store_id' => $ball_cart->store_id])
|
||
->andWhere(['o.is_pay' => 1])
|
||
->andWhere(['<>','o.cancel_status' , 1])
|
||
->andWhere(['o.is_delete' => 0])
|
||
->andWhere(['IN', 'o.status', [1, 2]])
|
||
->one();
|
||
if (!empty($orderIng)) {
|
||
$qc_status_error = "您有一笔订单正在进行中,请先结束订单";
|
||
}
|
||
}
|
||
}
|
||
|
||
/*if(\Yii::$app->redis->setnx($redis_name_lock,1)){
|
||
// 去请求mqtt车辆详细信息
|
||
$obj = new Mqtt();
|
||
$obj->getInfo($ball_number,7);
|
||
\Yii::$app->redis->expire($redis_name_lock,20);
|
||
}*/
|
||
|
||
// //球车编号
|
||
// try {
|
||
// var_dump(\Yii::$app->redis->set($redis_name, $json_arr));
|
||
// } catch (\Exception $e) {
|
||
// $this->apiReturnError($e->getMessage());
|
||
// }
|
||
// die();
|
||
|
||
// ELEC_PERCENT 剩余电量 RANGE_CURRENT 本次行驶里程 RUNTIME_CURRENT 本次运行时常 CSQ 信号 OPERATION_ENABLE 操作许可
|
||
|
||
|
||
if (\Yii::$app->redis->setnx($redis_name, 1)) {
|
||
\Yii::$app->redis->del($redis_name);
|
||
// return $this->apiReturnError('获取球车信息错误,请联系客服');
|
||
}
|
||
|
||
$json_data = \Yii::$app->redis->get($redis_name);
|
||
|
||
$json_data = json_decode($json_data, true);
|
||
$json_data = json_decode($json_data['data'], true);
|
||
if (!is_array($json_data) && empty($json_data)) {
|
||
$json_data = json_decode('{"orig_data":"","TIMESTAMP":0,"IMEI":"","SIMID":"","CSQ":0,"OPERATION_ENABLE":0,"OPERATION_LEVEL":0,"MODE":0,"ELEC_PERCENT":0,"RANGE":0,"RANGE_CURRENT":0,"RUNTIME":0,"RUNTIME_CURRENT":0}', true);
|
||
// return $this->apiReturnError('球车已断开连接,请联系服务员');
|
||
}
|
||
|
||
$query = BallCart::find()->alias('ball')
|
||
->leftJoin(['store' => Store::tableName()], 'ball.store_id=store.id')
|
||
->leftJoin(['mark' => BallMark::tableName()], 'ball.mark_id=mark.id')
|
||
->select('ball.id,ball.store_id,ball.cover_pic,ball.money,ball.content,mark.name as mark_name,mark.id as mard_id,ball.ball_number,ball.status,store.name')
|
||
->andWhere([
|
||
'ball.is_delete' => 0,
|
||
'ball.ball_number' => $ball_number
|
||
])->andWhere(['!=', 'ball.status', 2])
|
||
->orderBy(['id' => SORT_DESC])
|
||
->asArray()
|
||
->one();
|
||
// $data['ball_number'] = $ball_number;
|
||
$data = $query;
|
||
|
||
$data['content'] = SiteHelper::repairContent($data['content']);
|
||
$data['cover_pic'] = SiteHelper::getFullUrl($data['cover_pic']);
|
||
// $data['store_cover_pic'] = SiteHelper::getFullUrl($data['store_cover_pic']);
|
||
// $data['video_url'] = $video_url; //操作视频路径
|
||
$data['video_url'] = $video_url; //操作视频路径
|
||
|
||
|
||
$user_store_id = 0;
|
||
//门店管理员
|
||
if ($this->user_type == 2) {
|
||
$store_user_info = ApiHelper::findOneUserStoreId($this->user_id);
|
||
if ($store_user_info['user_type'] == 3) {
|
||
$user_store_id = 0;
|
||
} else {
|
||
$user_store_id = $store_user_info['store_id'] ? $store_user_info['store_id'] : 0;
|
||
}
|
||
}
|
||
|
||
$data['ball_user_store'] = 1; # 是否未当前门店管理员或服务员,0为展示车辆控制1为不展示
|
||
$data['ball_user_stauts'] = 0; # 判断用户是否为自己
|
||
$data['ball_info_stauts'] = 1;
|
||
$data['title'] = "";
|
||
//租赁中
|
||
if ($data['status'] == 1) {
|
||
$find_order = Order::find()->alias('o')
|
||
->join('inner join', ['od' => OrderDetail::tableName()], 'o.id=od.order_id')
|
||
->join('inner join', ['user' => User::tableName()], 'o.user_id=user.id')
|
||
->andWhere([
|
||
'od.goods_id' => $data['ball_number'],
|
||
'o.is_delete' => 0,
|
||
'od.is_delete' => 0,
|
||
])
|
||
->andWhere([
|
||
'in', 'o.status', [1, 2]
|
||
])
|
||
->select('o.id,o.store_id,o.user_id,o.created_at as begin_time,user.nickname,user.real_name,user.mobile_phone,o.status')
|
||
->orderBy(['id' => SORT_DESC])
|
||
->asArray()->one();
|
||
// 能否进入控制台，是否为当前车辆的购买者，是否为当前车辆的管理者
|
||
$data['user_id'] = $this->user_id;
|
||
if (!empty($find_order) && ($find_order['user_id'] == $this->user_id || $user_store_id == $find_order['store_id'])) {
|
||
//判断是否是自己租赁的球车
|
||
if ($find_order['user_id'] == $this->user_id) {
|
||
$data['ball_user_stauts'] = 0;
|
||
} else {
|
||
$data['ball_user_stauts'] = 1;
|
||
}
|
||
// 是否能进入详情页面
|
||
$data['ball_info_stauts'] = 1;
|
||
//判断车辆管理者显示归还功能 0 显示确认归还 1 不显示
|
||
$data['ball_user_store'] = $find_order['store_id'] == $user_store_id ? 0 : 1;
|
||
} else {
|
||
$data['ball_user_store'] = $find_order['store_id'] == $user_store_id ? 0 : 1;
|
||
$data['ball_user_stauts'] = 1;
|
||
$data['ball_info_stauts'] = 0;
|
||
}
|
||
if ($find_order['status'] == 2) {
|
||
$data['title'] = "还车申请中...";
|
||
}
|
||
$data['begin_time'] = $find_order['begin_time']; //租赁开始时间
|
||
$data['begin_time_date'] = date('Y-m-d H:i:s', $find_order['begin_time']); //租赁开始时间
|
||
$data['user_name'] = $find_order['real_name'] ? $find_order['real_name'] : $find_order['nickname']; //用户姓名 有昵称取昵称没有获取真实姓名
|
||
$data['mobile_phone'] = $find_order['mobile_phone']; //用户姓名 有昵称取昵称没有获取真实姓名
|
||
}
|
||
$json_data['CSQ_step'] = 0;
|
||
if (!empty($json_data['CSQ'])) {
|
||
if ($json_data['CSQ'] < 12) {
|
||
$json_data['CSQ_step'] = 1;
|
||
} elseif ($json_data['CSQ'] < 22) {
|
||
$json_data['CSQ_step'] = 2;
|
||
} else {
|
||
$json_data['CSQ_step'] = 3;
|
||
}
|
||
}
|
||
$OPERATION_LEVEL_arr = [
|
||
0 => '助力模式',
|
||
1 => '摇杆模式',
|
||
2 => '跟随模式',
|
||
];
|
||
$json_data['OPERATION_LEVEL_str'] = $OPERATION_LEVEL_arr[$json_data['OPERATION_LEVEL']] ?? '--';
|
||
$data['ball_arr'] = $json_data;
|
||
$data['qc_status_error'] = $qc_status_error;
|
||
$data['init_order'] = $this->init_order;
|
||
$data['user_id'] = $this->user_id;
|
||
return ['code' => 0, 'data' => $data];
|
||
}
|
||
|
||
|
||
public function getUserBallCart()
|
||
{
|
||
$orderData = Order::find()->alias('o')
|
||
->innerJoin(['rt' => OrderDetail::tableName()], 'o.id=rt.order_id')
|
||
->innerJoin(['ball' => BallCart::tableName()], 'rt.goods_id=ball.ball_number')
|
||
->select('rt.goods_id as id,rt.goods_id as ball_number')
|
||
->where(['o.user_id' => $this->user_id])
|
||
->andWhere(['o.is_pay' => 1])
|
||
->andWhere(['IN', 'o.status', [1, 2]])
|
||
->andWhere(['o.is_delete' => 0, 'rt.is_delete' => 0, 'ball.is_delete' => 0, 'ball.status' => 1])
|
||
->asArray()->one();
|
||
|
||
if ($orderData == null) {
|
||
return $this->apiReturnError('', []);
|
||
}
|
||
return $this->apiReturnSuccess('', $orderData);
|
||
}
|
||
|
||
} |