255 lines
10 KiB
PHP
255 lines
10 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | likeadmin快速开发前后端分离管理后台（PHP版）
|
||
// +----------------------------------------------------------------------
|
||
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
||
// | 开源版本可自由商用，可去除界面版权logo
|
||
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
|
||
// | github下载：https://github.com/likeshop-github/likeadmin
|
||
// | 访问官网：https://www.likeadmin.cn
|
||
// | likeadmin团队 版权所有 拥有最终解释权
|
||
// +----------------------------------------------------------------------
|
||
// | author: likeadminTeam
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\api\logic;
|
||
|
||
|
||
use app\common\logic\BaseLogic;
|
||
use app\common\logic\GpsLogic;
|
||
use app\common\model\vehicle\Company;
|
||
use app\common\model\vehicle\Vehicle;
|
||
use app\common\model\vehicle\VehicleRent;
|
||
use app\common\model\vehicle\VehicleRentRecord;
|
||
use think\facade\Cache;
|
||
use think\facade\Log;
|
||
|
||
|
||
/**
|
||
* 车辆逻辑
|
||
* Class VehicleLogic
|
||
* @package app\api\logic
|
||
*/
|
||
class VehicleLogic extends BaseLogic
|
||
{
|
||
public static function getTaskToken() {
|
||
//获取缓存数据
|
||
$task_token = Cache::get('task_token');
|
||
//验证缓存数据是否存在，如果缓存数据存在则直接返回缓存数据
|
||
if(!empty($task_token)) return $task_token;
|
||
|
||
$getToken = curl_post('https://worker-task.lihaink.cn/adminapi/login/account',[],['account'=>'admin','password'=>'123456','terminal'=>1]);
|
||
if($getToken['code'] == 0){
|
||
return '';
|
||
}
|
||
//设置缓存数据
|
||
Cache::set('task_token', $getToken['data']['token'], 86400);
|
||
return $getToken['data']['token'];
|
||
}
|
||
|
||
public static function companyInfo():array {
|
||
$data = Company::field('id,company_name')->where('company_name',30)->select();
|
||
if($data){
|
||
return ['code'=>1,'msg'=>'请求成功','data'=>$data->toArray()];
|
||
}else{
|
||
return ['code'=>0,'msg'=>'请求失败'];
|
||
}
|
||
}
|
||
|
||
public static function rentRecord($params):array {
|
||
//获取数据
|
||
if($params['rent_type'] ==1){
|
||
$cars = Vehicle::field('id')->where('status',0)->where('type',0)->limit($params['num'])->select();
|
||
if(!$cars || $cars->count() < $params['num']){
|
||
return ['code'=>0,'msg'=>'车辆数量不足'];
|
||
}
|
||
$ids = array_column($cars->toArray(),'id');
|
||
$ids = implode(',',$ids);
|
||
}else{
|
||
$ids = $params['car_id'];
|
||
}
|
||
//发起合同
|
||
VehicleRentRecord::startTrans();
|
||
try {
|
||
//发起合同
|
||
$setContract = curl_post('https://worker-task.lihaink.cn/adminapi/company/initiate_contract',[
|
||
'token:'.self::getTaskToken()
|
||
],[
|
||
'id' => $params['party_b'],
|
||
'party_a' => $params['party_a'],
|
||
'contract_type' => 29,
|
||
]);
|
||
if($setContract['code'] == 0){
|
||
return ['code'=>0,'msg'=>$setContract['msg']];
|
||
}
|
||
//写入数据
|
||
$res = VehicleRentRecord::create([
|
||
'car_ids' => $ids,
|
||
'contract_id' => $setContract['data']['id'],
|
||
'party_a' => $params['party_a'],
|
||
'party_b' => $params['party_b'],
|
||
'num' => $params['num'],
|
||
'rent_type' => $params['rent_type'],
|
||
'status' => 1,
|
||
'create_time' => time(),
|
||
'update_time' => time(),
|
||
]);
|
||
VehicleRentRecord::commit();
|
||
return ['code'=>1,'msg'=>'发起成功，等待平台风控部上传合同'];
|
||
}catch(\Exception $e) {
|
||
VehicleRentRecord::rollback();
|
||
return ['code'=>0,'msg'=>$e->getMessage()];
|
||
}
|
||
}
|
||
|
||
public static function rendRecordInfo($contract_id):array {
|
||
$record = VehicleRentRecord::field('car_ids,num,create_time')->where('contract_id',$contract_id)->find();
|
||
if(!$record){
|
||
return ['code'=>0,'msg'=>'数据不存在'];
|
||
}
|
||
$cars = Vehicle::field('license')->where('id','in',$record['car_ids'])->select();
|
||
if(!$cars){
|
||
return ['code'=>0,'msg'=>'车辆不存在'];
|
||
}
|
||
$car_license = array_column($cars->toArray(),'license');
|
||
$data = [
|
||
'num' => $record['num'],
|
||
'car_license' => $car_license,
|
||
'create_time' => $record['create_time']
|
||
];
|
||
return ['code'=>1,'msg'=>'请求成功','data'=>$data];
|
||
}
|
||
|
||
public static function rendRecordEdit($contract_id):array {
|
||
$record = VehicleRentRecord::where('contract_id',$contract_id)->where('status',1)->find();
|
||
if(!$record){
|
||
return ['code'=>0,'msg'=>'数据不存在'];
|
||
}
|
||
VehicleRentRecord::startTrans();
|
||
try {
|
||
if($record['rent_type'] == 1){
|
||
//获取承租公司信息
|
||
$company = Company::field('id,user_id,company_name,master_name,master_phone')->where('id',$record['party_b'])->find();
|
||
//设置数据
|
||
$ids = explode(',',$record['car_ids']);
|
||
$data = [];
|
||
foreach($ids as $v){
|
||
$car = Vehicle::where('id',$v)->find();
|
||
if($car){
|
||
$data[] = [
|
||
'car_id' => $v,
|
||
'lessee_one_contract_id' => $contract_id,
|
||
'lessee_one_company_id' => $company['id'],
|
||
'lessee_one_company' => $company['company_name'],
|
||
'lessee_one_user_id' => $company['user_id'],
|
||
'lessee_one_user' => $company['master_name'],
|
||
'lessee_one_phone' => $company['master_phone'],
|
||
'lessee_one_start_time' => strtotime($record['create_time']),
|
||
'lessee_one_flag' => 1,
|
||
];
|
||
}
|
||
}
|
||
(new VehicleRent()) -> saveAll($data);
|
||
//更新车辆列表中的车辆状态
|
||
Vehicle::where('id','in',$ids)->update(['status'=>1]);
|
||
}else{
|
||
//获取数据
|
||
$rent = VehicleRent::where('car_id',$record['car_ids'])->where('lessee_one_company_id',$record['party_a'])->find();
|
||
if(!$rent){
|
||
return ['code'=>0,'msg'=>'未找到车辆信息'];
|
||
}
|
||
//获取第二承租方公司信息
|
||
$company = Company::field('id,user_id,company_name,master_name,master_phone')->where('id',$record['party_b'])->find();
|
||
//验证公司信息
|
||
if(!$company){
|
||
return ['code'=>0,'msg'=>'未找到承租公司'];
|
||
}
|
||
//设置数据
|
||
$data = [
|
||
'id' => $rent['id'],
|
||
'lessee_two_contract_id' => $record['contract_id'],
|
||
'lessee_two_company_id' => $company['id'],
|
||
'lessee_two_company_name' => $company['company_name'],
|
||
'lessee_two_user_id' => $company['user_id'],
|
||
'lessee_two_user' => $company['master_name'],
|
||
'lessee_two_phone' => $company['master_phone'],
|
||
'lessee_two_start_time' => strtotime($record['create_time']),
|
||
'lessee_two_flag' => 1,
|
||
];
|
||
//写入数据
|
||
VehicleRent::update($data);
|
||
}
|
||
$res = curl_post('https://worker-task.lihaink.cn/v1/notify_property',[
|
||
'token:'.self::getTaskToken(),
|
||
'authority:worker-task.lihaink.cn',
|
||
],[
|
||
'company_id'=> $record['party_b'],
|
||
'object_id' => $record['car_ids']
|
||
]);
|
||
Log::write($res);
|
||
VehicleRentRecord::where('id',$record['id'])->update(['status'=>2,'update_time'=>time()]);
|
||
VehicleRentRecord::commit();
|
||
return ['code'=>1,'msg'=>'操作成功'];
|
||
}catch(\Exception $e) {
|
||
VehicleRentRecord::rollback();
|
||
return ['code'=>0,'msg'=>$e->getMessage()];
|
||
}
|
||
}
|
||
|
||
public static function getCompanyCars($params):array {
|
||
$company_str = $params['company_type'] == 1 ? 'lessee_one_company_id' : 'lessee_two_company_id';
|
||
$data = VehicleRent::where($company_str,$params['company_id'])->select()->each(function($item){
|
||
$car = Vehicle::field('license')->where('id',$item['car_id'])->find();
|
||
$item['license'] = $car['license'];
|
||
return $item;
|
||
});
|
||
if($data){
|
||
return ['code'=>1,'msg'=>'请求成功','data'=>$data->toArray()];
|
||
}else{
|
||
return ['code'=>1,'msg'=>'请求失败'];
|
||
}
|
||
}
|
||
|
||
public static function getCarLocal($params):array {
|
||
$car = Vehicle::field('gps_carid')->where('id',$params['car_id'])->find();
|
||
if(!$car){
|
||
return ['code'=>0,'msg'=>'车辆不存在'];
|
||
}
|
||
//获取车辆当前位置
|
||
$local = (new GpsLogic()) -> status($car['gps_carid']);
|
||
if($local['code'] == 1){
|
||
$data = [
|
||
'car_id' => $params['car_id'],
|
||
'lat' => $local['data']['carStatus']['latc'],
|
||
'lon' => $local['data']['carStatus']['lonc'],
|
||
];
|
||
return ['code'=>1,'msg'=>'请求成功','data'=>$data];
|
||
}else{
|
||
return ['code'=>0,'msg'=>$local['msg']];
|
||
}
|
||
}
|
||
|
||
public static function getCarHistory($params):array {
|
||
//获取车辆信息
|
||
$car = Vehicle::where('id',$params['car_id'])->find();
|
||
if(empty($car)){
|
||
return ['code'=>0,'msg'=>'车辆不存在'];
|
||
}else{
|
||
$params['gps_car_id'] = $car['gps_carid'];
|
||
}
|
||
//获取车辆行驶历史信息
|
||
$result = (new GpsLogic()) -> history($params);
|
||
//返回数据
|
||
if($result['code'] == 1){
|
||
$data = [];
|
||
foreach ($result['data'] as $k => $v) {
|
||
$data[$k]['lat'] = $v['latc'];
|
||
$data[$k]['lon'] = $v['lonc'];
|
||
}
|
||
return ['code'=>1,'msg'=>$result['msg'],'data'=>$data];
|
||
}else{
|
||
return ['code'=>0,'msg'=>$result['msg']];
|
||
}
|
||
}
|
||
}
|