find('psreceiver', '*', ['id'=>$id]);
}
public static function getOrder($trade_no){
global $DB;
return $DB->getRow("SELECT A.*,B.channel,B.account,B.name,B.rate FROM pre_psorder A LEFT JOIN pre_psreceiver B ON A.rid=B.id WHERE A.trade_no=:trade_no", [':trade_no'=>$trade_no]);
}
//订单分账定时任务
public static function task(){
global $DB;
$limit = 10; //每次查询分账的订单数量
$list = $DB->getAll("SELECT A.*,B.channel,B.account,B.name,B.uid psuid,C.uid,C.subchannel FROM pre_psorder A INNER JOIN pre_psreceiver B ON B.id=A.rid LEFT JOIN pre_order C ON C.trade_no=A.trade_no WHERE A.status=1 ORDER BY A.id ASC LIMIT {$limit}");
foreach($list as $srow){
self::process_item($srow);
}
$limit = 10; //每次提交分账的订单数量
$list = $DB->getAll("SELECT A.*,B.channel,B.account,B.name,B.uid psuid,C.uid,C.subchannel FROM pre_psorder A INNER JOIN pre_psreceiver B ON B.id=A.rid LEFT JOIN pre_order C ON C.trade_no=A.trade_no WHERE A.status=0 AND (A.addtime<=DATE_SUB(NOW(), INTERVAL 60 SECOND) AND A.delay=0 OR A.addtime<=DATE_SUB(NOW(), INTERVAL 24 HOUR) AND A.delay=1) ORDER BY A.id ASC LIMIT {$limit}");
foreach($list as $srow){
self::process_item($srow);
}
}
//处理一个订单分账任务
public static function process_item($row){
global $DB;
$id = $row['id'];
$channel = $row['subchannel'] > 0 ? \lib\Channel::getSub($row['subchannel']) : \lib\Channel::get($row['channel'], $row['uid']?$DB->findColumn('user', 'channelinfo', ['uid'=>$row['uid']]):null);
if(!$channel) return;
$model = self::getModel($channel);
// status:0-待分账,1-已提交,2-成功,3-失败
if($row['status']==0){
if($row['money'] == 0){
$DB->update('psorder', ['status'=>3,'result'=>'分账金额为0'], ['id'=>$id]);
echo $row['trade_no'].' 分账金额为0
';
return;
}
$result = $model->submit($row['trade_no'], $row['api_trade_no'], $row['account'], $row['name'], $row['money']);
if($result['code'] == 0){
$DB->update('psorder', ['status'=>1,'settle_no'=>$result['settle_no']], ['id'=>$id]);
}elseif($result['code'] == 1){
$DB->update('psorder', ['status'=>2,'settle_no'=>$result['settle_no']], ['id'=>$id]);
if(!empty($row['psuid']) && $channel['mode']==0){
changeUserMoney($row['psuid'], $row['money'], false, '订单分账', $row['trade_no']);
}
}elseif($result['code'] == -1){
$DB->update('psorder', ['status'=>3,'result'=>$result['msg']], ['id'=>$id]);
}
echo $row['trade_no'].' '.$result['msg'].'
';
}elseif($row['status']==1){
$result = $model->query($row['trade_no'], $row['api_trade_no'], $row['settle_no']);
if($result['code']==0){
if($result['status']==1){
$DB->update('psorder', ['status'=>2], ['id'=>$id]);
if(!empty($row['psuid']) && $channel['mode']==0){
changeUserMoney($row['psuid'], $row['money'], false, '订单分账', $row['trade_no']);
}
$result = '分账成功';
}elseif($result['status']==2){
$DB->update('psorder', ['status'=>3,'result'=>$result['reason']], ['id'=>$id]);
$result = '分账失败:'.$result['reason'];
}else{
$result = '正在分账';
}
echo $row['trade_no'].' '.$result.'
';
}else{
echo $row['trade_no'].' 查询失败:'.$result['msg'].'
';
}
}
}
}