This commit is contained in:
hujiabin 2024-08-06 11:35:52 +08:00
parent 12297587f7
commit 330e1fc9da
2 changed files with 20 additions and 17 deletions

View File

@ -1699,8 +1699,7 @@ CREATE TABLE `t_hash_rate` (
`period` int(11) NOT NULL DEFAULT '0' COMMENT '算力期数',
`createtime` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间',
`modifytime` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间',
PRIMARY KEY (`idx`),
UNIQUE KEY `account_period_task_id` (`account_id`,`period`, `task_id`)
PRIMARY KEY (`idx`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
--

View File

@ -8,15 +8,27 @@ class HashRate extends BaseModel
{
public static function find($taskId,$period){
return SqlHelper::ormSelectOne(
myself()->_getSelfMysql(),
't_hash_rate',
// return SqlHelper::ormSelectOne(
// myself()->_getSelfMysql(),
// 't_hash_rate',
// array(
// 'account_id' => myself()->_getAccountId(),
// 'task_id' => $taskId,
// 'period' => $period,
// )
// );
$row = myself()->_getSelfMysql()->execQueryOne(
'SELECT * FROM t_hash_rate WHERE account_id=:account AND period=:period AND task_id=:task_id ORDER BY idx DESC LIMIT 1',
array(
'account_id' => myself()->_getAccountId(),
'task_id' => $taskId,
'period' => $period,
':account' => myself()->_getAccountId(),
':period' => $period,
':task_id' => $taskId,
)
);
if (!$row){
$row = array();
}
return $row;
}
public static function getCount($period){
@ -33,17 +45,9 @@ class HashRate extends BaseModel
public static function add($taskId,$period){
SqlHelper::upsert(
SqlHelper::insert(
myself()->_getSelfMysql(),
't_hash_rate',
array(
'account_id' => myself()->_getAccountId(),
'period' => $period,
'task_id' => $taskId
),
array(
'modifytime' => myself()->_getNowTime()
),
array(
'account_id' => myself()->_getAccountId(),
'period' => $period,