// +---------------------------------------------------------------------- namespace crmeb\listens; use app\common\repositories\user\UserBillRepository; use crmeb\interfaces\ListenerInterface; use crmeb\services\TimerService; use Swoole\Timer; use think\facade\Db; class AutoUnLockBrokerageListen extends TimerService implements ListenerInterface { public function handle($event): void { //TODO 自动解冻佣金 $this->tick(1000 * 60 * 20, function () { $userBill = app()->make(UserBillRepository::class); request()->clearCache(); $timer = ((int)systemConfig('lock_brokerage_timer')); $time = date('Y-m-d H:i:s', $timer ? strtotime("- $timer day") : time()); $bills = $userBill->getTimeoutBrokerageBill($time); Db::transaction(function () use ($userBill, $bills) { foreach ($bills as $bill) { if ($bill->number > 0) { $refund = $userBill->refundBrokerage($bill->link_id, $bill->uid); $bill->user->brokerage_price = bcadd($bill->user->brokerage_price, bcsub($bill->number, $refund, 2), 2); $bill->user->save(); } $bill->status = 1; $bill->balance = $bill->user->brokerage_price; $bill->save(); } }); }); } }