This commit is contained in:
aozhiwei 2023-08-08 12:03:31 +08:00
parent ae8e978683
commit a49d3468e8

View File

@ -10,7 +10,7 @@ class Market extends BaseModel {
const BUY_OK_STATE = 1; const BUY_OK_STATE = 1;
const CANCEL_STATE = 2; const CANCEL_STATE = 2;
public static function find($orderId){ public static function find($orderId, $netId){
$row = SqlHelper::ormSelectOne( $row = SqlHelper::ormSelectOne(
myself()->_getMysql(''), myself()->_getMysql(''),
't_market', 't_market',
@ -21,10 +21,11 @@ class Market extends BaseModel {
return $row; return $row;
} }
public static function add($orderId, $tokenId, $seller, $nftToken, public static function add($orderId, $netId, $tokenId, $seller, $nftToken,
$amount, $currency, $pirce) { $amount, $currency, $pirce) {
self::internalUpdate( self::internalUpdate(
$orderId, $orderId,
$netId,
array( array(
'token_id' => $tokenId, 'token_id' => $tokenId,
'seller' => $seller, 'seller' => $seller,
@ -39,32 +40,35 @@ class Market extends BaseModel {
)); ));
} }
public static function updatePrice($orderId, $price) { public static function updatePrice($orderId, $netId, $price) {
self::internalUpdate( self::internalUpdate(
$orderId, $orderId,
$netId,
array( array(
'update_price' => $price, 'update_price' => $price,
'update_time' => myself()->_getNowTime(), 'update_time' => myself()->_getNowTime(),
)); ));
} }
public static function buyOk($orderId) { public static function buyOk($orderId, $netId) {
self::internalUpdate( self::internalUpdate(
$orderId, $orderId,
$netId,
array( array(
'status' => self::BUY_OK_STATE, 'status' => self::BUY_OK_STATE,
)); ));
} }
public static function cancel($orderId) { public static function cancel($orderId, $netId) {
self::internalUpdate( self::internalUpdate(
$orderId, $orderId,
$netId,
array( array(
'status' => self::CANCEL_STATE, 'status' => self::CANCEL_STATE,
)); ));
} }
private static function internalUpdate($orderId, $fieldsKv){ private static function internalUpdate($orderId, $netId, $fieldsKv){
SqlHelper::upsert SqlHelper::upsert
(myself()->_getMysql(''), (myself()->_getMysql(''),
't_market', 't_market',
@ -75,6 +79,7 @@ class Market extends BaseModel {
), ),
array( array(
'order_id' => $orderId, 'order_id' => $orderId,
'net_id' => $netId,
'createtime' => myself()->_getNowTime(), 'createtime' => myself()->_getNowTime(),
'modifytime' => myself()->_getNowTime(), 'modifytime' => myself()->_getNowTime(),
) )