This commit is contained in:
hujiabin 2022-11-24 16:41:23 +08:00
parent 2c4684e657
commit 5bb33b6630
2 changed files with 17 additions and 3 deletions

View File

@ -160,7 +160,8 @@ class CallbackController extends BaseController {
myself()->_rspErr(1, 'param error'); myself()->_rspErr(1, 'param error');
return; return;
} }
$tranDb= Transaction::find($transId); error_log('Transaction:'.$transId);
$tranDb= Transaction::findByAccountId($this->accountId,$transId);
if (!$tranDb){ if (!$tranDb){
myself()->_rspErr(1, 'param error'); myself()->_rspErr(1, 'param error');
return; return;
@ -250,7 +251,7 @@ class CallbackController extends BaseController {
myself()->_rspErr(1, 'param error'); myself()->_rspErr(1, 'param error');
return; return;
} }
$tranDb= Transaction::find($transId); $tranDb= Transaction::findByAccountId($this->accountId,$transId);
if (!$tranDb){ if (!$tranDb){
myself()->_rspErr(1, 'param error'); myself()->_rspErr(1, 'param error');
return; return;
@ -337,7 +338,7 @@ class CallbackController extends BaseController {
return; return;
} }
$tranDb= Transaction::find($transId); $tranDb= Transaction::findByAccountId($this->accountId,$transId);
if (!$tranDb){ if (!$tranDb){
myself()->_rspErr(1, 'param error'); myself()->_rspErr(1, 'param error');
return; return;

View File

@ -46,6 +46,19 @@ class Transaction extends BaseModel {
return $row; return $row;
} }
public static function findByAccountId($accountId,$transId)
{
$row = SqlHelper::ormSelectOne(
myself()->_getMysql($accountId),
't_transaction',
array(
'account_id' => myself()->_getAccountId(),
'trans_id' => $transId,
)
);
return $row;
}
public static function add($transId, $action, $tokenId, $tokenType, $itemUniId, $itemId, $result) public static function add($transId, $action, $tokenId, $tokenType, $itemUniId, $itemId, $result)
{ {
SqlHelper::insert( SqlHelper::insert(