_getSelfMysql(), 't_hash_rate', array( 'account_id' => myself()->_getAccountId(), 'task_id' => $taskId, 'period' => $period, ) ); } public static function add($taskId,$period){ SqlHelper::upsert( 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, 'task_id' => $taskId, 'createtime' => myself()->_getNowTime(), 'modifytime' => myself()->_getNowTime() ) ); } public static function rewardAdd($period,$reward){ SqlHelper::upsert( myself()->_getSelfMysql(), 't_hash_rate_reward', array( 'account_id' => myself()->_getAccountId(), 'period' => $period, ), array( 'reward' => function () use($reward) { return "reward + ${reward}"; }, 'modifytime' => myself()->_getNowTime() ), array( 'account_id' => myself()->_getAccountId(), 'period' => $period, 'reward' => $reward, 'createtime' => myself()->_getNowTime(), 'modifytime' => myself()->_getNowTime() ) ); } public static function getMyHashRate($period){ $row = SqlHelper::ormSelectOne( myself()->_getSelfMysql(), 't_hash_rate_reward', array( 'account_id' => myself()->_getAccountId(), 'period' => $period, ) ); $myHashRate = 0; if ($row){ $myHashRate = $row['reward']; } return $myHashRate; } public static function getTotalByAccount($accountId,$period){ $row = SqlHelper::ormSelect( myself()->_getSelfMysql(), 't_hash_rate_reward', array( 'account_id' => $accountId, 'period' => $period, ) ); $totalHashRate = 0; if ($row){ $totalHashRate = $row['reward']; } return $totalHashRate; } }