where([ 'user_id' => $user_id, 'fund_id' => $fund_id ])->lockForUpdate()->first(); return $q; } /** * @param $userId * @param $fundIds * @return \Illuminate\Database\Eloquent\Collection * 获取用户全部资金账户 */ public static function getAllAccount($userId, $fundIds) { $query = self::query(); $query->where('user_id', $userId); $query->whereIn('fund_id', $fundIds); return $query->get(); } public function user() { return $this->hasOne(User::class, 'id', 'user_id'); } // // public function userInfo() // { // return $this->hasOne(UserInfo::class, 'user_id', 'user_id'); // } /** * @param $userId * @param $fundId * @param $amount * @return int * 减少资金 */ public static function dec($userId, $fundId, $amount) { $query = self::query(); $query->where('user_id', $userId); $query->where('fund_id', $fundId); return $query->decrement('balance', $amount); } /** * @param $userId * @param $fundId * @param $amount * @return int * 增加资金 */ public static function inc($userId, $fundId, $amount) { $query = self::query(); $query->where('user_id', $userId); $query->where('fund_id', $fundId); return $query->increment('balance', $amount); } }