mall/jobs/SyncSharerList.php

<?php

namespace app\jobs;

use app\models\StoreMini;
use app\modules\admin\models\VideoShopForm;
use app\modules\admin\models\VideoShopOrderForm;
use app\utils\Wechat\WechatMini;
use yii\base\BaseObject;
use yii\queue\JobInterface;
use app\models\Store;

class SyncSharerList extends BaseObject implements JobInterface
{
    public $store_id;

    public function execute($queue)
    {

        $storeList = [];
        if(is_null($this->store_id)){
            $storeList = Store::find()->where(['is_delete' => 0])->select('id')->column();
        }else{
            $storeList = [$this->store_id];
        }
        foreach ($storeList as $store_id){
        $base_ = new WechatMini();

        $form_ = new VideoShopOrderForm();
        $form = new VideoShopForm();
        $store_mini = StoreMini::find()->where(['store_id' => $store_id, 'fuwu_type' => 1, 'is_cancle' => 0])->select('id')->column();
        foreach ($store_mini as $mini_item) {
            $miniProgram = $base_::getWechatConfig($store_id, $mini_item, 1);

            if ($miniProgram) {
                $form->miniProgram = $miniProgram;
                $form->store_id = $store_id;
                $form->mini_id = $base_::$mini_id;
                $form->getApplySharerInfo();
                $form->syncSharerList();

                $form_->miniProgram = $miniProgram;
                $form_->store_id = $store_id;
                $form_->mini_id = $base_::$mini_id;
                $form_->end_time = time();
                $form_->start_time = time() - (60 * 60 * 24 * 2);
                $form_->syncOrderList();
            }
        }
        }


    }
}