mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整商户冻结金额解冻

Browse Source
This commit is contained in:
luofei 2024-03-08 11:05:36 +08:00
parent 54bf58b197
commit 50248f1c2b
1 changed files with 28 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
crmeb/listens/AutoUnlockMerchantMoneyListen.php
View File

@ -18,24 +18,39 @@ use app\common\repositories\user\UserBillRepository;
use crmeb\interfaces\ListenerInterface;
use crmeb\services\TimerService;
use think\facade\Db;
use think\facade\Log;
class AutoUnlockMerchantMoneyListen extends TimerService implements ListenerInterface
{
public function handle($event): void
{
$this->tick(1000 * 60 * 20, function () {
request()->clearCache();
$userBill = app()->make(UserBillRepository::class);
$timer = ((int)systemConfig('mer_lock_time'));
$time = date('Y-m-d H:i:s', $timer ? strtotime("- $timer day") : time());
$bills = $userBill->getTimeoutMerchantMoneyBill($time);
$merchant = app()->make(MerchantRepository::class);
foreach ($bills as $bill) {
Db::transaction(function () use ($bill, $merchant) {
$merchant->addMoney($bill->mer_id, $bill->number);
$bill->status = 1;
$bill->save();
});
$this->tick(1000 * 60 * 60, function () {
if (time() >= strtotime('today 18:00:00') && time() >= strtotime('today 20:00:00')) {
request()->clearCache();
/** @var UserBillRepository $userBill */
$userBill = app()->make(UserBillRepository::class);
// $timer = ((int)systemConfig('mer_lock_time'));
// $time = date('Y-m-d H:i:s', $timer ? strtotime("- $timer day") : time());
$time = date('Y-m-d 00:00:00');
$bills = $userBill->getTimeoutMerchantMoneyBill($time);
$merchant = app()->make(MerchantRepository::class);
$count = 0;
foreach ($bills as $bill) {
Db::startTrans();
try {
$merchant->addMoney($bill->mer_id, $bill->number);
$bill->status = 1;
$bill->save();
Db::commit();
$count++;
} catch (\Throwable $e) {
Db::rollback();
Log::error('商户冻结金额解冻出错：' . $e->getMessage());
}
}
if ($count > 0) {
Log::info('商户冻结金额解冻成功：' . $count);
}
}
});
}