<?php
/**
 * Created by PhpStorm.
 * User: 风哀伤
 * Date: 2019/2/20
 * Time: 14:11
 * @copyright: ©2019 浙江禾匠信息科技
 * @link: http://www.zjhejiang.com
 */

namespace app\jobs;


use app\core\response\ApiCode;
use app\forms\common\platform\PlatformConfig;
use app\forms\common\template\TemplateSender;
use app\forms\common\template\tplmsg\BaseTemplate;
use app\models\Formid;
use app\models\Mall;
use app\models\TemplateRecord;
use app\models\User;
use app\models\UserInfo;
use yii\base\BaseObject;
use yii\queue\JobInterface;

class TemplateSendJob extends BaseJob implements JobInterface
{
    public $user;
    public $templateTpl;
    public $templateId;
    public $page;
    public $data;
    public $token;
    public $titleStyle;
    public $dataKey;
    public $tplClass;

    /* @var TemplateSender */
    public $sender;
    private $platform;

    /**
     * @param \yii\queue\Queue $queue
     * @throws \Exception
     */
    public function execute($queue)
    {
        try {
            \Yii::warning('---订阅消息发送提醒---');
            $this->setRequest();
            $userList = $this->getUserList();
            $mall = Mall::findOne(['id' => $this->user->mall_id]);
            \Yii::$app->setMall($mall);
            $userListId = [];
            foreach ($userList as $item) {
                $userListId[] = $item->id;
            }
            $formList = $this->getFormList($userListId);

            $formIdList = [];
            $templateRecord = [];
            foreach ($userList as $item) {
                $platform = PlatformConfig::getInstance()->getPlatform($item);
                $platformList = explode('_', $platform);
                foreach ($platformList as $value) {
                    $this->platform = $value;
                    $templateRecord[] = $this->send($item, $formList, $formIdList);
                }
            }
            if (!empty($formIdList)) {
                // 模板消息发送成功相应的form_id剩余发放次数减1
                Formid::updateAll(['remains' => '`remains`-1'], ['id' => $formIdList]);
            }
            if (count($templateRecord) > 0) {
                // 批量存储发送模板消息数据
                \Yii::$app->db->createCommand()->batchInsert(
                    TemplateRecord::tableName(),
                    ['user_id', 'mall_id', 'status', 'data', 'error', 'created_at', 'token'],
                    $templateRecord
                )->execute();
            }
        } catch (\Exception $e) {
            \Yii::warning($e);
            throw $e;
        }
    }

    /**
     * @return mixed
     * @throws \Exception
     */
    private function sender()
    {
        $plugin = \Yii::$app->plugin->getPlugin($this->platform);
        return $plugin->templateSender();
    }

    private function getUserList()
    {
        /* @var User[] $userList */
        if (isset($this->user)) {
            if (is_array($this->user)) {
                // 群发模板消息
                $userList = $this->user;
            } else {
                // 单发模板消息
                $userList = [$this->user];
            }
        } else {
            throw new \Exception('缺少参数user');
        }
        return $userList;
    }

    private function getFormList($userListId)
    {
        // 获取对应用户可用的form_id
        $form = Formid::find()->where(['user_id' => $userListId])
            ->andWhere(['>=', 'created_at', date('Y-m-d H:i:s', time() - 7 * 86400)])
            ->andWhere(['>', 'remains', 0])->orderBy(['created_at' => SORT_ASC])->groupBy('user_id')->all();

        $formList = [];
        /* @var Formid[] $form */
        foreach ($form as $item) {
            $formList[$item->user_id] = $item;
        }
        return $formList;
    }

    /**
     * @param User $item
     * @param $formList
     * @param $formIdList
     * @return array
     */
    private function send($item, $formList, &$formIdList)
    {
        $data = $this->data;
        if ($this->tplClass && $this->tplClass instanceof BaseTemplate) {
            $data = $this->tplClass->adaptive($this->platform);
        }
        // 发送模板消息需要的数据
        $arg = [
            'user' => $item,
            'templateId' => $this->templateId,
            'templateTpl' => $this->templateTpl,
            'page' => $this->page,
            'data' => $data,
            'dataKey' => $this->dataKey,
            'formId' => '',
            'titleStyle' => $this->titleStyle == 2 ? 'keyword1.DATA' : '',
        ];

        // 存储发送模板消息的数据
        $newItem = [
            'user_id' => $item->id,
            'mall_id' => $item->mall_id,
            'status' => 1,
            'data' => \Yii::$app->serializer->encode($arg),
            'error' => '',
            'created_at' => mysql_timestamp(),
            'token' => $this->token
        ];
        try {
            $this->sender = $this->sender();
            if ($this->sender->is_need_form_id) {
                if (!isset($formList[$item->id]) || !$formList[$item->id]) {
                    throw new \Exception('没有有效的form_id');
                }
                $form = $formList[$item->id];
                $arg['formId'] = $form->form_id;
                $formIdList[] = $form->id;
            }
            $this->sender->sendTemplate($arg);
        } catch (\Exception $e) {
            $newItem['error'] = $e->getMessage();
            $newItem['status'] = 0;
        }
        return $newItem;
    }
}