You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
132 lines
4.2 KiB
132 lines
4.2 KiB
2 months ago
|
<?php
|
||
|
namespace app\model;
|
||
|
/**
|
||
|
* @property int id
|
||
|
* @property int user_id
|
||
|
* @property int contract_id
|
||
|
* @property float usable_num
|
||
|
* @property float frozen_num
|
||
|
* @property string create_time
|
||
|
* @property string update_time
|
||
|
*/
|
||
|
class UserContractSecModel extends BaseModel
|
||
|
{
|
||
|
protected $name = 'user_contract_sec';
|
||
|
protected $pk = 'id';
|
||
|
|
||
|
public static function getUserContractByUserId(array $data):array
|
||
|
{
|
||
|
|
||
|
if(!empty($data['trade_name'])){
|
||
|
$contract_id=strtoupper($data['trade_name']);
|
||
|
}else{
|
||
|
$contract_id='USDT';
|
||
|
}
|
||
|
$info = self::where([
|
||
|
'user_id'=>$data['user_id'],
|
||
|
'contract_id'=>$contract_id
|
||
|
])->field('usable_num,frozen_num,contract_id as name')->find();
|
||
|
if(empty($info)){
|
||
|
// 如果没有则创建
|
||
|
$info = new self;
|
||
|
$info->user_id = $data['user_id'];
|
||
|
$info->contract_id = $contract_id;
|
||
|
$info->usable_num = 0;
|
||
|
$info->frozen_num = 0;
|
||
|
$info->create_time = date('Y-m-d H:i:s');
|
||
|
$info->update_time = date('Y-m-d H:i:s');
|
||
|
$info->save();
|
||
|
}
|
||
|
return $info->toArray();
|
||
|
}
|
||
|
public static function getUserContractLock(int $user_id,string $contract_id='USDT'):array
|
||
|
{
|
||
|
$info = self::where([
|
||
|
'user_id'=>$user_id,
|
||
|
'contract_id'=>$contract_id
|
||
|
])->lock(true)->find();
|
||
|
if(empty($info)){
|
||
|
$info = new self;
|
||
|
$info->user_id = $user_id;
|
||
|
$info->contract_id = $contract_id;
|
||
|
$info->usable_num = 0;
|
||
|
$info->frozen_num = 0;
|
||
|
$info->create_time = date('Y-m-d H:i:s');
|
||
|
$info->update_time = date('Y-m-d H:i:s');
|
||
|
$info->save();
|
||
|
}
|
||
|
return $info->toArray();
|
||
|
}
|
||
|
public static function getUserContractList(int $user_id):array
|
||
|
{
|
||
|
|
||
|
$list = self::where([
|
||
|
'user_id'=>$user_id,
|
||
|
])->field('usable_num,frozen_num,contract_id as name')->select();
|
||
|
if($list->isEmpty()){
|
||
|
$self = new self;
|
||
|
$self->user_id = $user_id;
|
||
|
$self->contract_id = 'USDT';
|
||
|
$self->usable_num = '0';
|
||
|
$self->frozen_num = '0';
|
||
|
$self->create_time = date('Y-m-d H:i:s');
|
||
|
$self->update_time = date('Y-m-d H:i:s');
|
||
|
$self->save();
|
||
|
$list = self::where([
|
||
|
'user_id'=>$user_id,
|
||
|
])->field('usable_num,frozen_num,stock_id as name')->select();
|
||
|
}
|
||
|
|
||
|
foreach ($list as $key=>$val){
|
||
|
if($val['name']=='USDT'){
|
||
|
$list[$key]['buy_up']=[
|
||
|
'buy_num'=>0,
|
||
|
'buy_money'=>0
|
||
|
];
|
||
|
$list[$key]['buy_down']=[
|
||
|
'buy_num'=>0,
|
||
|
'buy_money'=>0
|
||
|
];
|
||
|
}else{
|
||
|
//获取持仓成本
|
||
|
$list[$key]['buy_up']=ContractSecTradeModel::getTradeOrderBuyNum($user_id,$val['name'],1);
|
||
|
$list[$key]['buy_down']=ContractSecTradeModel::getTradeOrderBuyNum($user_id,$val['name'],2);
|
||
|
}
|
||
|
|
||
|
}
|
||
|
//获取平仓累计盈亏
|
||
|
$daily_num=ContractSecTradeModel::getTradeOrderDailyNum($user_id);
|
||
|
$earnest_money=ContractSecTradeModel::getUserEarnestMmoney($user_id);
|
||
|
$fee_num=ContractSecTradeModel::getTradeOrderFee($user_id);
|
||
|
return [
|
||
|
'earnest_money'=>$earnest_money,//保证金
|
||
|
'daily_num'=>$daily_num,//累计盈亏
|
||
|
'fee_num'=>$fee_num,//累计盈亏
|
||
|
'list'=>$list->toArray()
|
||
|
];
|
||
|
|
||
|
}
|
||
|
|
||
|
|
||
|
public static function InsertUserContract(array $data)
|
||
|
{
|
||
|
$self = new self;
|
||
|
$self->user_id = $data['user_id'];
|
||
|
$self->contract_id = $data['contract_id'];
|
||
|
$self->usable_num = $data['usable_num'];
|
||
|
$self->frozen_num = $data['frozen_num'];
|
||
|
$self->create_time = date('Y-m-d H:i:s');
|
||
|
$self->save();
|
||
|
}
|
||
|
public static function updateUserContract(array $update_data,array $where)
|
||
|
{
|
||
|
$update_data['update_time']=date('Y-m-d H:i:s');
|
||
|
$res=self::where($where)->save($update_data);
|
||
|
//echo self::where($where)->getLastSql();
|
||
|
return $res;
|
||
|
}
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
}
|