AutoSavePriceListen.php 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  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, 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. @file_put_contents('yesterday.txt', AwardIntegralPrice::getLastSql());
  28. if (!isset($yesterday['basePrice'])) {
  29. return;
  30. }
  31. $service->setPrice($day, $yesterday['price'], $yesterday['commission'], $yesterday['achievement'], $yesterday['num']);
  32. });
  33. }
  34. }