AutoSavePriceListen.php 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2024 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace crmeb\listens;
  12. use app\common\model\user\AwardIntegralPrice;
  13. use app\common\repositories\user\AwardIntegralPriceRepository;
  14. use crmeb\interfaces\ListenerInterface;
  15. use crmeb\services\TimerService;
  16. class AutoSavePriceListen extends TimerService implements ListenerInterface
  17. {
  18. public function handle($event): void
  19. {
  20. //TODO 自动清除积分
  21. $this->tick(1000 * 30, function () {
  22. //如果没有昨天的价格,就保存
  23. $day = date('Y-m-d', strtotime('-1 day'));
  24. $service = app()->make(AwardIntegralPriceRepository::class);
  25. $yesterday = $service->awardIntegralPrice($day);
  26. // @file_put_contents('yesterday.txt', json_encode($yesterday) . PHP_EOL, FILE_APPEND);
  27. if (!isset($yesterday['basePrice'])) {
  28. return;
  29. }
  30. $service->setPrice($day, $yesterday['price'], $yesterday['commission'], $yesterday['achievement'], $yesterday['num'],$yesterday['add_price']);
  31. });
  32. }
  33. }