<?php
/**
 * link: http://www.zjhejiang.com/
 * copyright: Copyright (c) 2018 浙江禾匠信息科技有限公司
 * author: xay
 */

namespace app\jobs;

use app\forms\common\CommonOption;
use app\forms\common\mptemplate\MpTplMessage;
use app\models\MpTemplateRecord;
use app\models\Option;
use yii\base\BaseObject;
use yii\queue\JobInterface;

class MpTplMessageJob extends BaseJob implements JobInterface
{
    public $mall;
    public $token;
    public $url;
    public $templateId;
    public $data;
    public $miniprogram;

    public $admin_open_list = [];
    public $app_id;
    public $app_secret;
    /**
     * @param \yii\queue\Queue $queue
     * @throws \Exception
     */
    public function execute($queue)
    {
        try {
            $this->setRequest();
            $logs = [];
            $count = 0;

            foreach ($this->admin_open_list as $item) {
                //发送数据
                $args = [
                    'touser' => $item['open_id'],
                    'template_id' => $this->templateId,
                    'data' => $this->data,
                ];

                $log = [
                    'open_id' => $args['touser'],
                    'mall_id' => $this->mall->id,
                    'status' => 1,
                    'data' => \Yii::$app->serializer->encode($args),
                    'error' => '',
                    'created_at' => mysql_timestamp(),
                    'token' => $this->token,
                ];

                try {
                    $res = (new MpTplMessage())->senderMsg($args, [
                        'app_id' => $this->app_id,
                        'app_secret' => $this->app_secret,
                        'mall_id' => $this->mall->id,
                    ]);
                } catch (\Exception $e) {
                    \Yii::error($e);
                    $log['error'] = $e->getMessage();
                    $log['status'] = 0;
                }
                $count++;
                $logs[] = $log;
            }

            if ($count > 0) {
                \Yii::$app->db->createCommand()->batchInsert(
                    MpTemplateRecord::tableName(),
                    ['open_id', 'mall_id', 'status', 'data', 'error', 'created_at', 'token'],
                    $logs
                )->execute();
            }
        } catch (\Exception $e) {
            \Yii::warning($e);
            throw $e;
        }
    }
}