zhuishuyun_quickapp/app/Http/Controllers/Channel/OfficialAccount/WechatTemplatesController.php

<?php

namespace App\Http\Controllers\Channel\OfficialAccount;

use App\Http\Controllers\Channel\BaseController as ChannelBaseController;

use App\Http\Controllers\Channel\OfficialAccount\Transformers\WechatTemplatesTransformer;
use App\Http\Controllers\Channel\OfficialAccount\Transformers\WechatTemplatesMsgTransformer;
use App\Modules\Statistic\Services\WapVisitStatService;
use Illuminate\Http\Request;
use GuzzleHttp\Client;
use App\Libs\OSS;
use App\Jobs\SendTemplate;
use App\Modules\OfficialAccount\Services\WechatTemplateService;
use App\Modules\OfficialAccount\Services\ForceSubscribeService;
use App\Modules\OfficialAccount\Services\CustomMsgService;
use App\Modules\Channel\Services\ChannelService;

class WechatTemplatesController extends ChannelBaseController
{


    /**
     * @apiDefine OfficialAccount 公众号
     */

    /**
     * @apiVersion 1.0.0
     * @api {GET} OfficialAccount/wechatTemplateMsgById 通过id获取模板消息
     * @apiGroup OfficialAccount
     * @apiName wechatTemplateMsgById
     * @apiParam   {String}  id 模板消息id.
     * @apiSuccess {String}  template_id 公众号对应模版ID.
     * @apiSuccess {String}  name 名称.
     * @apiSuccess {String}  send_time 发送时间.
     * @apiSuccess {String}  template_content 模板内容.
     * @apiSuccess {String}  redirect_url 重定向地址.
     * @apiSuccess {String}  send_appid 公众号appid.
     * @apiSuccess {String}  status 模板消息状态.
     * @apiSuccess {String}  remark 备注.
     * @apiSuccess {Number}  distribution_channel_id 分配的渠道Id.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": {
     *               "appid": "112211",
     *               "common_template_id": "qqqqq",
     *               "template_id": "wqwqwq",
     *           }
     *       }
     */

    function wechatTemplateMsgById(Request $request)
    {

        $id = $request->has('id') ? $request->input('id') : '';

        if (empty($id)) {
            return response()->error("PARAM_EMPTY");
        }

        $wechatTemplateMsg['id'] = $id;

        $wechatTemplateMsgService = WechatTemplateService::wechatTemplateMsgById($wechatTemplateMsg);

        return response()->item(new WechatTemplatesMsgTransformer(), $wechatTemplateMsgService);
    }


    /**
     * @apiVersion 1.0.0
     * @api {GET} OfficialAccount/wechatTemplateMsgBydistributionChannelId 获取推送模板消息列表
     * @apiGroup OfficialAccount
     * @apiName wechatTemplateMsgBydistributionChannelId
     * @apiSuccess {String}  id 模板消息唯一ID
     * @apiSuccess {String}  template_id 公众号对应模版ID.
     * @apiSuccess {String}  name 名称.
     * @apiSuccess {String}  send_time 发送时间.
     * @apiSuccess {String}  template_content 模板内容.
     * @apiSuccess {String}  redirect_url 重定向地址.
     * @apiSuccess {String}  send_appid 公众号appid.
     * @apiSuccess {String}  status 模板消息状态.
     * @apiSuccess {String}  remark 备注.
     * @apiSuccess {Number}  distribution_channel_id 分配的渠道Id.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": {
     *               "appid": "112211",
     *               "common_template_id": "qqqqq",
     *               "template_id": "wqwqwq",
     *           }wechatTemplateMsgBydistributionChannelId
     *       }
     */

    function wechatTemplateMsgBydistributionChannelId(Request $request)
    {

        // $distribution_channel_id = $request->has('distribution_channel_id') ? $request->input('distribution_channel_id') : '';

        // if(empty($distribution_channel_id)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        $distribution_channel_id = $this->getChannelId();

        $wechatTemplatesMsg['distribution_channel_id'] = $distribution_channel_id;

        $wechatTemplatesMsgServices = WechatTemplateService::wechatTemplateMsgBydistributionChannelId($wechatTemplatesMsg);
        foreach($wechatTemplatesMsgServices as $key=>$wechatTemplatesMsgService){
        	if($wechatTemplatesMsgService->is_full_send){
        		$wechatTemplatesMsgServices[$key]->user_category = '服务号全量用户';
        	}elseif($wechatTemplatesMsgService->subscribe_time == 'z' &&
        			$wechatTemplatesMsgService->sex == 'z' &&
        			$wechatTemplatesMsgService->balance == 'z' &&
        			$wechatTemplatesMsgService->order_type == 'z' &&
        			$wechatTemplatesMsgService->category_id == 'z' ){
        		$wechatTemplatesMsgServices[$key]->user_category = '追书云全部用户';
        	}else{
        		$wechatTemplatesMsgServices[$key]->user_category = '追书云标签用户';
        	}
        }
        return response()->pagination(new WechatTemplatesMsgTransformer(), $wechatTemplatesMsgServices);
    }

    /**
     * 数据统计，搜索相关
     * @param Request $request
     */
    function searchWechatTemplateMsg(Request $request)
    {
        $start_time = $request->has('start_time') ? $request->input('start_time') : '';
        $end_time = $request->has('end_time') ? $request->input('end_time') : '';
        $book_name = $request->has('book_name') ? $request->input('book_name') : '';
        $task_name = $request->has('task_name') ? $request->input('task_name') : '';

        if ($start_time < '2018-11-02') {
            \Log::info('searchWechatTemplateMsg,update_start_time:' . $start_time);
            $start_time = '2018-11-02';
        }

        $distribution_channel_id = $this->getChannelId();
        $param = [
            'distribution_channel_id' => $distribution_channel_id,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'book_name' => $book_name,
            'task_name' => $task_name
        ];
        $wechatTemplatesMsgServices = WechatTemplateService::searchWechatTemplateMsgs($param,false);

        foreach ($wechatTemplatesMsgServices as $key => $customMsgService) {
            $fromtype = 'template_' . $customMsgService->id;
            $statistics = WapVisitStatService::innerCustomerAllStats($fromtype);
            $wechatTemplatesMsgServices[$key]->uv = isset($statistics['uv']) ? $statistics['uv'] : '';
            $wechatTemplatesMsgServices[$key]->pv = isset($statistics['pv']) ? $statistics['pv'] : '';
            $wechatTemplatesMsgServices[$key]->register_user_num = isset($statistics['register_user_num']) ? $statistics['register_user_num'] : '';
            $wechatTemplatesMsgServices[$key]->pay_user_num = isset($statistics['pay_user_num']) ? $statistics['pay_user_num'] : '';
            $wechatTemplatesMsgServices[$key]->charge_amount = isset($statistics['charge_amount']) ? $statistics['charge_amount'] : '';
        }

        return response()->pagination(new WechatTemplatesMsgTransformer(), $wechatTemplatesMsgServices);
    }

    /**
     * 导出模板消息数据
     * @param Request $request
     */
    function exportWechatTemplateMsg(Request $request)
    {
        $start_time = $request->has('start_time') ? $request->input('start_time') : '';
        $end_time = $request->has('end_time') ? $request->input('end_time') : '';
        $book_name = $request->has('book_name') ? $request->input('book_name') : '';
        $task_name = $request->has('task_name') ? $request->input('task_name') : '';

        if ($start_time < '2018-11-02') {
            \Log::info('searchWechatTemplateMsg,update_start_time:' . $start_time);
            $start_time = '2018-11-02';
        }

        $distribution_channel_id = $this->getChannelId();
        $param = [
            'distribution_channel_id' => $distribution_channel_id,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'book_name' => $book_name,
            'task_name' => $task_name
        ];
        $wechatTemplatesMsgServices = WechatTemplateService::searchWechatTemplateMsgs($param,true);

        header("Content-type:application/vnd.ms-excel");
        header("Content-Disposition:attachment;filename=" . "模板消息" . date("YmdHis") . ".csv");
        echo iconv("UTF-8", "GBK", "\"类型\",\"id\",\"任务名称\",\"小说\",\"章节\",\"pv\",\"uv\",\"充值用户\",\"充值总额\"\r\n");
        foreach ($wechatTemplatesMsgServices as $key => $customMsgService) {
            $fromtype = 'template_' . $customMsgService->id;
            $statistics = WapVisitStatService::innerCustomerAllStats($fromtype);
            $uv = empty($statistics['uv']) ? 0 : $statistics['uv'];
            $pv = empty($statistics['pv']) ? 0 : $statistics['pv'];
            $pay_user_num = empty($statistics['pay_user_num']) ? 0 : $statistics['pay_user_num'];
            $charge_amount = empty($statistics['charge_amount']) ? 0 : $statistics['charge_amount'];

            echo("\"" . iconv("UTF-8", "GBK", '模板消息') . "\",");
            echo("\"" . iconv("UTF-8", "GBK", $customMsgService->id) . "\",");
            echo("\"" . iconv("UTF-8", "GBK//IGNORE", $customMsgService->name ? $customMsgService->name : '未填') . "\",");
            echo("\"" . iconv("UTF-8", "GBK//IGNORE", $customMsgService->book_name ? $customMsgService->book_name : '未填') . "\",");
            echo("\"" . iconv("UTF-8", "GBK//IGNORE", $customMsgService->chapter_name ? $customMsgService->chapter_name : '未填') . "\",");
            echo("\"" . iconv("UTF-8", "GBK", $pv) . "\",");
            echo("\"" . iconv("UTF-8", "GBK", $uv) . "\",");
            echo("\"" . iconv("UTF-8", "GBK", $pay_user_num) . "\",");
            echo("\"" . iconv("UTF-8", "GBK", $charge_amount) . "\"\r\n");
        }

        exit();
    }


    /**
     * @apiVersion 1.0.0
     * @api {GET} OfficialAccount/forceUserCountByTemplatePrams 通过参数获取用户
     * @apiGroup OfficialAccount
     * @apiName wechatTemplateMsgById
     * @apiParam   {String}  subscribe_time 关注时间（a:5天内，b:5-15天，c:15-30天，d:30天以上，z:不限）
     * @apiParam {String}  sex 性别（a:男，b：女，z:不限）
     * @apiParam {String}  order_type 付费情况（a:未付费，b：已付费，c:VIP用户，z:不限）
     * @apiParam {String}  balance 账户余额.（a:低于500，b:500-2000，c:2000-5000，z:不限）
     * @apiParam {String}  category_id 书籍分类.（分类id,z:不限）
     * @apiSuccess {String}  num 用户数量.
     * @apiSuccessExample {json} Success-Response:
     *
     *  {
     *      "code": 0,
     *      "msg": "",
     *      "data": {
     *          "num": 20
     *      }
     *  }
     */

    function forceUserCountByTemplatePrams(Request $request)
    {
        // dd(11);
        $distribution_channel_id = $this->getChannelId();

        $subscribe_time = $request->has('subscribe_time') ? $request->input('subscribe_time') : '';

        if (empty($subscribe_time)) {
            return response()->error("PARAM_EMPTY");
        }

        $appids = $request->has('appids') ? $request->input('appids') : '';

        if (empty($appids)) {
            return response()->error("PARAM_EMPTY");
        }

        $sex = $request->has('sex') ? $request->input('sex') : '';

        if (empty($sex)) {
            return response()->error("PARAM_EMPTY");
        }

        $balance = $request->has('balance') ? $request->input('balance') : '';

        if (empty($balance)) {
            return response()->error("PARAM_EMPTY");
        }

        $order_type = $request->has('order_type') ? $request->input('order_type') : '';

        if (empty($order_type)) {
            return response()->error("PARAM_EMPTY");
        }

        $category_id = $request->has('category_id') ? $request->input('category_id') : '';

        if (empty($category_id)) {
            return response()->error("PARAM_EMPTY");
        }

        $appidArray = explode(',', $appids);
        $usernum = 0;
        for ($j = 0; $j < count($appidArray); $j++) {
            $skip = 0;
            $usernum = 0;

            while ($skip <= 2500000) {
                \Log::info('-------------模板消息-----分页取强关用户，目前页数----------' . $skip);
                $users = ForceSubscribeService::forceUserCountByTemplatePrams($appidArray[$j], $distribution_channel_id, $subscribe_time, $sex, $balance, $category_id, $order_type, $skip);
                \Log::info('-----------------实际发送模板消息用户数量-------------' . count($users));
                if (count($users) > 0) {

                    $usernum += count($users);

                } else {

                    break;

                }

                $skip += count($users);
            }
        }


        return response()->success(['num' => $usernum]);
    }


    /**
     * @apiVersion 1.0.0
     * @api {POST} OfficialAccount/addWechatTemplateMsg 发送模板消息
     * @apiGroup OfficialAccount
     * @apiName addWechatTemplateMsg
     * @apiParam {String}  appid 公众号的appid.
     * @apiParam {String}  common_template_id 公共模版的ID.
     * @apiParam {String}  name 名称.
     * @apiParam {String}  send_time 发送时间.
     * @apiParam {String}  template_content 模板内容.
     * @apiParam {String}  redirect_url 重定向地址.
     * @apiParam {String}  [remark] 备注.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": []
     *       }
     */

    function addWechatTemplateMsg(Request $request)
    {

        $appid = $request->has('appid') ? $request->input('appid') : '';

        if (empty($appid)) {
            return response()->error("PARAM_EMPTY");
        }

        $common_template_id = $request->has('common_template_id') ? $request->input('common_template_id') : '';

        if (empty($common_template_id)) {
            return response()->error("PARAM_EMPTY");
        }


        $name = $request->has('name') ? $request->input('name') : '';

        if (empty($name)) {
            return response()->error("PARAM_EMPTY");
        }

        $send_time = $request->has('send_time') ? $request->input('send_time') : '';

        if (empty($send_time)) {
            return response()->error("PARAM_EMPTY");
        }

        $template_content = $request->has('template_content') ? $request->input('template_content') : '';

        if (empty($template_content)) {
            return response()->error("PARAM_EMPTY");
        }

        $redirect_url = $request->has('redirect_url') ? $request->input('redirect_url') : '';

        if (empty($redirect_url)) {
            return response()->error("PARAM_EMPTY");
        }

        $distribution_channel_id = $this->getChannelId();

        $remark = $request->has('remark') ? $request->input('remark') : '';


        $subscribe_time = $request->has('subscribe_time') ? $request->input('subscribe_time') : '';

        if (empty($subscribe_time)) {
            return response()->error("PARAM_EMPTY");
        }

        $sex = $request->has('sex') ? $request->input('sex') : '';

        if (empty($sex)) {
            return response()->error("PARAM_EMPTY");
        }

        $balance = $request->has('balance') ? $request->input('balance') : '';

        if (empty($balance)) {
            return response()->error("PARAM_EMPTY");
        }

        $order_type = $request->has('order_type') ? $request->input('order_type') : '';

        if (empty($order_type)) {
            return response()->error("PARAM_EMPTY");
        }

        $category_id = $request->has('category_id') ? $request->input('category_id') : '';

        if (empty($category_id)) {
            return response()->error("PARAM_EMPTY");
        }
        $is_full_send = $request->has('is_full_send') ? $request->input('is_full_send') : '0';

        $is_activity = $request->has('is_activity') ? $request->input('is_activity') : '0';
        $description = $request->has('description') ? $request->input('description') : '';
        $book_name = $request->has('book_name') ? $request->input('book_name') : '';
        $chapter_name = $request->has('chapter_name') ? $request->input('chapter_name') : '';
        if ($is_activity == '0') {
            if (empty($book_name)) {
                return response()->error("PARAM_EMPTY");
            }
            if (empty($chapter_name)) {
                return response()->error("PARAM_EMPTY");
            }
        }
        
        // 判断权限
//         $add_priv = ChannelService::check_channel_company_priv($distribution_channel_id,'add_wechat_template');
//         if(!empty($add_priv)){
//         	\Log::info('wechat_template_is_open:'.$distribution_channel_id);
//         }else{
//         	\Log::info('wechat_template_not_open:'.$distribution_channel_id);
        	 
//         	return response()->error("NOT_ENABLE_TEMPLATE_SEND");
        	
//         	if ($is_full_send) {
//         		return response()->error("NOT_ENABLE_FULL_SEND");
//         	}
//         	if($subscribe_time=='z' && $sex=='z' && $balance=='z' && $order_type=='z' && $category_id=='z' ){
//         		return response()->error("NOT_ENABLE_FULL_SEND");
//         	}
//         }


        $wechatTemplateMsgs['appid'] = $appid;
        $wechatTemplateMsgs['common_template_id'] = $common_template_id;
        $wechatTemplateMsgs['name'] = $name;
        $wechatTemplateMsgs['send_time'] = $send_time;
        $wechatTemplateMsgs['is_activity'] = $is_activity;
        $wechatTemplateMsgs['template_content'] = $template_content;
        $wechatTemplateMsgs['redirect_url'] = $redirect_url;
        $wechatTemplateMsgs['distribution_channel_id'] = $distribution_channel_id;
        $wechatTemplateMsgs['is_full_send'] = $is_full_send;
        $wechatTemplateMsgs['remark'] = $remark;
        $wechatTemplateMsgs['description'] = $description;
        $wechatTemplateMsgs['book_name'] = $book_name;
        $wechatTemplateMsgs['chapter_name'] = $chapter_name;
        $wechatTemplateMsgs['subscribe_time'] = $subscribe_time;
        $wechatTemplateMsgs['sex'] = $sex;
        $wechatTemplateMsgs['balance'] = $balance;
        $wechatTemplateMsgs['order_type'] = $order_type;
        $wechatTemplateMsgs['category_id'] = $category_id;

        //先判断在发送时间段1小时以内，有没有发起过相同的模板消息，如果有发送过，就提示用户已经创建过相同模板消息，不创建新的模板消息

        // $isSendTemplate = WechatTemplateService::isSendTemplateAtSameTime($wechatTemplateMsgs);
        // if (!empty($isSendTemplate)) {

        //     return response()->error('TEMPLATE_DOUBLE_FAILED');
        // }

        $resultStatus = WechatTemplateService::addWechatTemplateMsg($wechatTemplateMsgs);

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATES_NOT_FOUND');
        } elseif ($resultStatus == 3) {
            return response()->error('TEMPLATE_DOUBLE_FAILED');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }

    }


    /**
     * @apiVersion 1.0.0
     * @api {GET} OfficialAccount/delWechatTemplateMsg 删除模板消息
     * @apiGroup OfficialAccount
     * @apiName delWechatTemplateMsg
     * @apiParam   {String}  id 模板消息id.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": {
     *           }
     *       }
     */

    function delWechatTemplateMsg(Request $request)
    {

        $id = $request->has('id') ? $request->input('id') : '';

        if (empty($id)) {
            return response()->error("PARAM_EMPTY");
        }

        $wechatTemplateMsg['id'] = $id;

        $resultStatus = WechatTemplateService::delWechatTemplateMsg($wechatTemplateMsg);

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATES_NOT_FOUND');
        } elseif ($resultStatus == 4) {
            return response()->error('TEMPLATEMSG_IS_SEDDING');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }

    }


    /**
     * @apiVersion 1.0.0
     * @api {POST} OfficialAccount/testAddWechatTemplateMsg 单个用户测试发送模板消息
     * @apiGroup OfficialAccount
     * @apiName testAddWechatTemplateMsg
     * @apiParam {String}  uid 用户uid.
     * @apiParam {String}  common_template_id 公共模版的ID.
     * @apiParam {String}  name 名称.
     * @apiParam {String}  template_content 模板内容.
     * @apiParam {String}  redirect_url 重定向地址.
     * @apiParam {String}  [remark] 备注.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": []
     *       }
     */

    function testAddWechatTemplateMsg(Request $request)
    {


        \Log::info('channel_testAddWechatTemplateMsg');
        $uid = $request->has('uid') ? $request->input('uid') : '';

        if (empty($uid)) {
            return response()->error("PARAM_EMPTY");
        }

        $common_template_id = $request->has('common_template_id') ? $request->input('common_template_id') : '';

        if (empty($common_template_id)) {
            return response()->error("PARAM_EMPTY");
        }

        $name = $request->has('name') ? $request->input('name') : '';

        if (empty($name)) {
            return response()->error("PARAM_EMPTY");
        }

        $appid = $request->has('appid') ? $request->input('appid') : '';

        if (empty($appid)) {
            return response()->error("PARAM_EMPTY");
        }

        $template_content = $request->has('template_content') ? $request->input('template_content') : '';

        if (empty($template_content)) {
            return response()->error("PARAM_EMPTY");
        }

        $redirect_url = $request->has('redirect_url') ? $request->input('redirect_url') : '';

        if (empty($redirect_url)) {
            return response()->error("PARAM_EMPTY");
        }


        $distribution_channel_id = $this->getChannelId();

        $remark = $request->has('remark') ? $request->input('remark') : '';


        // $subscribe_time = $request->has('subscribe_time') ? $request->input('subscribe_time') : '';

        // if(empty($subscribe_time)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        // $sex = $request->has('sex') ? $request->input('sex') : '';

        // if(empty($sex)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        // $balance = $request->has('balance') ? $request->input('balance') : '';

        // if(empty($balance)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        // $order_type = $request->has('order_type') ? $request->input('order_type') : '';

        // if(empty($order_type)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        // $category_id = $request->has('category_id') ? $request->input('category_id') : '';

        // if(empty($category_id)) {
        //     return response()->error("PARAM_EMPTY");
        // }


        $wechatTemplateMsgs['uid'] = $uid;
        $wechatTemplateMsgs['common_template_id'] = $common_template_id;
        $wechatTemplateMsgs['name'] = $name;
        $wechatTemplateMsgs['appid'] = $appid;
        $wechatTemplateMsgs['template_content'] = $template_content;
        $wechatTemplateMsgs['redirect_url'] = $redirect_url;
        $wechatTemplateMsgs['distribution_channel_id'] = $distribution_channel_id;
        $wechatTemplateMsgs['remark'] = $remark;

        // $wechatTemplateMsgs['subscribe_time'] = $subscribe_time;
        // $wechatTemplateMsgs['sex'] = $sex;
        // $wechatTemplateMsgs['balance'] = $balance;
        // $wechatTemplateMsgs['order_type'] = $order_type;
        // $wechatTemplateMsgs['category_id'] = $category_id;

        \Log::info($wechatTemplateMsgs);

        \Log::info('======================add_template_send======================' . "\n");
        $resultStatus = WechatTemplateService::testAddWechatTemplateMsg($wechatTemplateMsgs);

        \Log::info('======================add_news_send======================' . "\n");
//         CustomMsgService::sendUnpaid();

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATES_NOT_FOUND');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }

    }


    /**
     * @apiVersion 1.0.0
     * @api {POST} OfficialAccount/updateWechatTemplateStatus 更新模板消息任务状态
     * @apiGroup OfficialAccount
     * @apiName updateWechatTemplateStatus
     * @apiParam {String}  id 模板消息唯一id.
     * @apiParam {String}  status 模板消息状态.1待发送、2发送中、3已发送、4已停止、0失败
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": []
     *       }
     */

    function updateWechatTemplateStatus(Request $request)
    {

        $id = $request->has('id') ? $request->input('id') : '';

        if (empty($id)) {
            return response()->error("PARAM_EMPTY");
        }

        $status = $request->has('status') ? $request->input('status') : '';

        if (empty($status)) {
            return response()->error("PARAM_EMPTY");
        }

        $wechatTemplate['id'] = $id;

        $wechatTemplate['status'] = $status;

        $resultStatus = WechatTemplateService::wechatTemplateStatusChange($wechatTemplate);

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATESMSG_NOT_FOUND');
        } elseif ($resultStatus == 4) {
            return response()->error('TEMPLATEMSG_IS_SEDDING');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }

    }

    /**
     * @apiVersion 1.0.0
     * @api {POST} OfficialAccount/stopsSendWechatTemplate 停止发送模板消息
     * @apiGroup OfficialAccount
     * @apiName stopsSendWechatTemplate
     * @apiParam {String}  id 模板消息唯一id.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": []
     *       }
     */

    function stopsSendWechatTemplate(Request $request)
    {

        $id = $request->has('id') ? $request->input('id') : '';

        if (empty($id)) {
            return response()->error("PARAM_EMPTY");
        }


        $wechatTemplate['id'] = $id;

        $wechatTemplate['status'] = '4';

        $resultStatus = WechatTemplateService::wechatTemplateStatusChange($wechatTemplate);

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATESMSG_NOT_FOUND');
        } elseif ($resultStatus == 4) {
            return response()->error('TEMPLATEMSG_IS_SEDDING');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }

    }


    /**
     * @apiVersion 1.0.0
     * @api {POST} OfficialAccount/updateWechatTemplateMsgById 更新模板消息内容
     * @apiGroup OfficialAccount
     * @apiName updateWechatTemplateMsgById
     * @apiParam {String}  id 模板消息唯一id.
     * @apiParam {String}  appid 标题.
     * @apiParam {String}  common_template_id 标题.
     * @apiParam {String}  name 标题.
     * @apiParam {String}  send_time 发送时间.
     * @apiParam {String}  template_content 内容.
     * @apiParam {String}  redirect_url 重定向地址.
     * @apiParam {String}  [remark] 备注.
     * @apiParam {String}  subscribe_time 关注时间.
     * @apiParam {String}  sex 性别.
     * @apiParam {String}  balance 账户余额.
     * @apiParam {String}  order_type 订单状态.
     * @apiParam {String}  category_id 小说分类.
     * @apiSuccessExample {json} Success-Response:
     *
     *       {
     *           "code": 0,
     *           "msg": "",
     *           "data": []
     *       }
     */

    function updateWechatTemplateMsgById(Request $request)
    {

        $appid = $request->has('appid') ? $request->input('appid') : '';

        if (empty($appid)) {
            return response()->error("PARAM_EMPTY");
        }

        $common_template_id = $request->has('common_template_id') ? $request->input('common_template_id') : '';

        if (empty($common_template_id)) {
            return response()->error("PARAM_EMPTY");
        }


        $name = $request->has('name') ? $request->input('name') : '';

        if (empty($name)) {
            return response()->error("PARAM_EMPTY");
        }

        $send_time = $request->has('send_time') ? $request->input('send_time') : '';

        if (empty($send_time)) {
            return response()->error("PARAM_EMPTY");
        }

        $template_content = $request->has('template_content') ? $request->input('template_content') : '';

        if (empty($template_content)) {
            return response()->error("PARAM_EMPTY");
        }

        $redirect_url = $request->has('redirect_url') ? $request->input('redirect_url') : '';

        if (empty($redirect_url)) {
            return response()->error("PARAM_EMPTY");
        }

        $is_full_send = $request->has('is_full_send') ? $request->input('is_full_send') : '0';

        $distribution_channel_id = $this->getChannelId();

        $remark = $request->has('remark') ? $request->input('remark') : '';


        $subscribe_time = $request->has('subscribe_time') ? $request->input('subscribe_time') : '';

        if (empty($subscribe_time)) {
            return response()->error("PARAM_EMPTY");
        }

        $sex = $request->has('sex') ? $request->input('sex') : '';

        if (empty($sex)) {
            return response()->error("PARAM_EMPTY");
        }

        $balance = $request->has('balance') ? $request->input('balance') : '';

        if (empty($balance)) {
            return response()->error("PARAM_EMPTY");
        }

        $order_type = $request->has('order_type') ? $request->input('order_type') : '';

        if (empty($order_type)) {
            return response()->error("PARAM_EMPTY");
        }

        $category_id = $request->has('category_id') ? $request->input('category_id') : '';

        if (empty($category_id)) {
            return response()->error("PARAM_EMPTY");
        }

        $id = $request->has('id') ? $request->input('id') : '';

        if (empty($id)) {
            return response()->error("PARAM_EMPTY");
        }
        $is_activity = $request->has('is_activity') ? $request->input('is_activity') : '0';
        $description = $request->has('description') ? $request->input('description') : '';
        $chapter_name = $request->has('chapter_name') ? $request->input('chapter_name') : '';
        $book_name = $request->has('book_name') ? $request->input('book_name') : '';
        if ($is_activity == '0') {
            if (empty($book_name)) {
                return response()->error("PARAM_EMPTY");
            }
            if (empty($chapter_name)) {
                return response()->error("PARAM_EMPTY");
            }
        }
        
        // 判断权限
//         $add_priv = ChannelService::check_channel_company_priv($distribution_channel_id,'add_wechat_template');
//         if(!empty($add_priv)){
//         	\Log::info('wechat_template_is_open:'.$distribution_channel_id);
//         }else{
//         	\Log::info('wechat_template_not_open:'.$distribution_channel_id);
        	 
//         	return response()->error("NOT_ENABLE_TEMPLATE_SEND");
        	 
//         	if ($is_full_send) {
//         		return response()->error("NOT_ENABLE_FULL_SEND");
//         	}
//         	if($subscribe_time=='z' && $sex=='z' && $balance=='z' && $order_type=='z' && $category_id=='z' ){
//         		return response()->error("NOT_ENABLE_FULL_SEND");
//         	}
//         }


        $wechatTemplateMsgs['appid'] = $appid;
        $wechatTemplateMsgs['common_template_id'] = $common_template_id;
        $wechatTemplateMsgs['name'] = $name;
        $wechatTemplateMsgs['send_time'] = $send_time;
        $wechatTemplateMsgs['is_full_send'] = $is_full_send;
        $wechatTemplateMsgs['is_activity'] = $is_activity;
        $wechatTemplateMsgs['template_content'] = $template_content;
        $wechatTemplateMsgs['redirect_url'] = $redirect_url;
        $wechatTemplateMsgs['distribution_channel_id'] = $distribution_channel_id;
        $wechatTemplateMsgs['remark'] = $remark;
        $wechatTemplateMsgs['description'] = $description;
        $wechatTemplateMsgs['book_name'] = $book_name;
        $wechatTemplateMsgs['chapter_name'] = $chapter_name;
        $wechatTemplateMsgs['id'] = $id;

        $wechatTemplateMsgs['subscribe_time'] = $subscribe_time;
        $wechatTemplateMsgs['sex'] = $sex;
        $wechatTemplateMsgs['balance'] = $balance;
        $wechatTemplateMsgs['order_type'] = $order_type;
        $wechatTemplateMsgs['category_id'] = $category_id;

        $resultStatus = WechatTemplateService::updateWechatTemplateMsgById($wechatTemplateMsgs);

        if ($resultStatus == 1) {
            return response()->success();
        } elseif ($resultStatus == 2) {
            return response()->error('TEMEPATES_NOT_FOUND');
        } elseif ($resultStatus == 3) {
            return response()->error('TEMPLATE_DOUBLE_FAILED');
        } elseif ($resultStatus == 4) {
            return response()->error('TEMPLATEMSG_IS_SEDDING');
        } elseif ($resultStatus == 0) {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        } else {
            return response()->error('TEMEPATES_UNSUCCESSFUL');
        }


        // $id = $request->has('id') ? $request->input('id') : '';

        // if(empty($id)) {
        //     return response()->error("PARAM_EMPTY");
        // }

        // $status = $request->has('status') ? $request->input('status') : '';

        // $name = $request->has('name') ? $request->input('name') : '';

        // $send_time = $request->has('send_time') ? $request->input('send_time') : '';

        // $template_content = $request->has('template_content') ? $request->input('template_content') : '';

        // $redirect_url = $request->has('redirect_url') ? $request->input('redirect_url') : '';

        // $remark = $request->has('remark') ? $request->input('remark') : '';

        // $wechatTemplate['id'] = $id;
        // $wechatTemplate['status'] = $status;
        // $wechatTemplate['name'] = $name;
        // $wechatTemplate['send_time'] = $send_time;
        // $wechatTemplate['template_content'] = $template_content;
        // $wechatTemplate['redirect_url'] = $redirect_url;
        // $wechatTemplate['remark'] = $remark;

        // $resultStatus = WechatTemplateService::updateWechatTemplateMsgById($wechatTemplate);

        // if ($resultStatus == 1) {
        //     return response()->success();
        // }elseif ($resultStatus == 2) {
        //     return response()->error('TEMEPATESMSG_NOT_FOUND');
        // }elseif ($resultStatus == 0) {
        //     return response()->error('TEMEPATES_UNSUCCESSFUL');
        // }else{
        //     return response()->error('TEMEPATES_UNSUCCESSFUL');
        // }
    }

    //内部测试RebitMQ用
    function testRebitMQ(Request $request)
    {

        WechatTemplateService::test_add_template_task();
        return response()->success();

    }


    //检查模板状态
    function checkTemplateStatus(Request $request)
    {
        $distribution_channel_id = $this->getChannelId();
        $appid = $request->has('appid') ? $request->input('appid') : '';

        if (empty($appid)) {
            return response()->error("PARAM_EMPTY");
        }
        $appids = explode(',', $appid);
        if (count($appids) > 1) {
            \Log::info('checkTemplateStatus_appid_num_limit:' . $distribution_channel_id);
            return response()->error("CHECK_TEMPLATE_LIMIT_NUM");
        }

        //

        $common_template_id = $request->has('common_template_id') ? $request->input('common_template_id') : '';

        if (empty($common_template_id)) {
            return response()->error("PARAM_EMPTY");
        }

        $result = WechatTemplateService::checkTemplateStatus($appids, $common_template_id);
        return response()->success($result['msg']);

    }


}