123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116 |
- <?php
- namespace App\Console\Commands;
- use Illuminate\Console\Command;
- use App\Modules\OfficialAccount\Services\OfficialAccountService;
- use App\Modules\Finance\Services\WithdrawCashService;
- use App\Modules\User\Models\UserSign;
- use App\Modules\User\Models\TempsUserSign;
- use App\Modules\User\Models\SmartPushUserSign;
- use App\Modules\OfficialAccount\Models\DistributionSelfDefineConfig;
- use App\Modules\Finance\Services\FinancialStatService;
- use Redis;
- class AsyncUserSign extends Command
- {
-
- protected $signature = 'AsyncUserSign';
-
- protected $description = '签到user_sign异步批量插入';
-
- public function __construct()
- {
- parent::__construct();
- }
-
- public function handle()
- {
- $this->start();
- }
- public function start(){
- \Log::info('AsyncUserSign_start');
-
- $uids = Redis::smembers('user_sign:uid');
- $loop_num = 100;
- $loop_current = 0;
- if(!empty($uids)){
-
- $batch_insert_data = [];
- foreach($uids as $uid){
- try{
- $loop_current ++;
-
- $insert_data = [];
-
- $sign_data = Redis::hget('user_sign:uid:info',$uid);
- $sign_data = object_to_array(json_decode($sign_data));
-
- if(!empty($sign_data)){
- $batch_insert_data[] = $sign_data;
- Redis::srem('user_sign:uid',$uid);
- Redis::hdel('user_sign:uid:info',$uid);
- }
- if($loop_current == $loop_num){
- self::batch_sign_insert($batch_insert_data);
- $batch_insert_data = [];
- $loop_current = 0;
- }
- }catch(\Exception $e){
- \Log::info('AsyncUserSign_ept:'.$e->getMessage());
- }
- }
-
-
- \Log::info('$last_batch_insert_data');
- \Log::info($batch_insert_data);
- self::batch_sign_insert($batch_insert_data);
-
- }
- \Log::info('AsyncUserSign_end:'.count($uids));
- }
-
- public static function batch_sign_insert($batch_insert_data){
- if(!empty($batch_insert_data)){
- $model = new UserSign();
- $model->setCurrentTable(date('Ym'));
- $model->insert($batch_insert_data);
- $model->setCurrentTable( date('Ym',strtotime('next Month')) );
- $model->insert($batch_insert_data);
-
-
-
- SmartPushUserSign::insert($batch_insert_data);
- }
- }
- }
|