wangdu_public_api/app/Console/Commands/AutoSendTrusteeShipCustomerMsg.php

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Modules\OfficialAccount\Services\BatchCustomMsgService;
use App\Modules\Book\Services\BookConfigService;
use App\Modules\OfficialAccount\Services\CustomMsgService;
use App\Modules\OfficialAccount\Services\OfficialAccountService;
use App\Modules\OfficialAccount\Models\CustomMsgSendTimeConfig;
use DB;
class AutoSendTrusteeShipCustomerMsg extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'AutoSendTrusteeShipCustomerMsg';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '自动推送托管客服消息';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */

    private $hour_begin;
    private $hour_end;

    public function handle()
    {
        $this->hour_begin = date('H:00:00');
        $this->hour_end = date('H:59:59');
        $batch_no =  '默认批次';
        //所有开启推送的渠道
        $all_channel_ids = DB::table('custom_msg_switchs_msgs')
            ->where('status',1)
            ->where('custom_category','auto_custom_trusteeship')
            ->select(DB::raw("distinct distribution_channel_id as unique_distribution_channel_id"))
            ->pluck('unique_distribution_channel_id')
            ->toArray();

        //自定义时间的渠道
        $customize_time_channel_ids = CustomMsgSendTimeConfig::where('is_enable',1)
            ->where('custom_category','auto_custom_trusteeship')
            ->whereIn('distribution_channel_id',$all_channel_ids)
            ->select(DB::raw("distinct distribution_channel_id as unique_distribution_channel_id"))
            ->pluck('unique_distribution_channel_id')
            ->toArray();

        //获取没有自定义发送时间的站点19点统一发送
        if($this->hour_begin == '19:00:00'){
            //判断今天是否已经发送过
            $today_send_status = DB::table('batch_custom_send_msgs')
                ->where('send_time','>',date('Y-m-d'))
                ->where('name','like','%'.$batch_no.'%')
                ->first();
            if(!$today_send_status){

                //需要跑的站点=  所有开启推送的站点 - 自定义时间的站点
                $channel_ids = array_diff($all_channel_ids,$customize_time_channel_ids);
                dump($batch_no);
                $this->autoSendTrusteeShipCustomerMsg($channel_ids,$batch_no);
            }

        }

        //获取有自定义发送时间且在一小时内需要创建的站点
        $channel_ids = CustomMsgSendTimeConfig::where('is_enable',1)
            ->where('custom_category','auto_custom_trusteeship')
            ->whereBetween('send_time',[$this->hour_begin,$this->hour_end])
            ->whereIn('distribution_channel_id',$all_channel_ids)
            ->where(function ($query) {
                $query->where('last_send_date','<',date('Y-m-d'))
                    ->orWhereNull('last_send_date');
            })
            ->select(DB::raw("distinct distribution_channel_id as unique_distribution_channel_id"))
            ->pluck('unique_distribution_channel_id')
            ->toArray();
        $batch_no ='自定义批次';
        dump($batch_no);
         $this->autoSendTrusteeShipCustomerMsg($channel_ids,$batch_no);
    }


    /**
     * 创建客服消息
     */
    public function autoSendTrusteeShipCustomerMsg($channel_ids,$batch_no = '')
    {
        \Log::info('autoSendTrusteeShipCustomerMsg:');
        $sexs = ['a', 'b'];
        $customMsgPrams['send_time'] = date('Y-m-d H:00:00');
        $customMsgPrams['redirect_url'] = '';
        $customMsgPrams['subscribe_time'] = 'g';// 关注1天前，有过交互的
        $customMsgPrams['trusteeship'] = '1'; // 托管
        $customMsgPrams['balance'] = 'z';
        $customMsgPrams['order_type'] = 'z';
        $customMsgPrams['category_id'] = 'z';
        $customMsgPrams['status'] = '1';
        $customMsgPrams['is_show_list'] = '0';// 分销界面不展示
        $batch_name = $batch_no;
        //设置书籍标题的站点
        $book_title_channel_ids = DB::table('custom_msg_switchs_msgs')
            ->where('status',1)
            ->where('custom_category','auto_custom_trusteeship')
            ->where('title_type','BOOK')
            ->select(DB::raw("distinct distribution_channel_id as unique_distribution_channel_id"))
            ->pluck('unique_distribution_channel_id')
            ->toArray();
        //
        dump('需要跑的站点');
        dump($channel_ids);
        dump('设置书籍标题的站点');
        dump($book_title_channel_ids);
        //带书名标题的站点
        dump('需要跑的设置书籍标题的站点');
        $book_title_channels = array_intersect($channel_ids,$book_title_channel_ids);
        dump($book_title_channels);
        dump('需要跑的带系统标题的站点');
        //带系统标题的站点
        $default_title_channels = array_diff($channel_ids,$book_title_channels);
        dump($default_title_channels);
        //带默认标题
        if ($default_title_channels) {
            dump('带系统标题');
            foreach ($sexs as $sex) {
                $customMsgPrams['content'] = $this->getMsgContent($sex, 'SYS');
                $customMsgPrams['sex'] = $sex;
                $customMsgPrams['name'] = '自动发送托管客服消息_系统标题'.date('YmdH').$batch_name;
                \Log::info($customMsgPrams);
                $batch_res = BatchCustomMsgService::addBatchCustomSendMsgs($customMsgPrams, $batch_no);
                if ($batch_res == 1) {
                    //创建客服消息
                    $this->BatchCreateCustomSendMsgs($customMsgPrams,$default_title_channels,$batch_no);
                }
            }
        }
        //带书名标题
        if ($book_title_channels) {
            dump('带书名标题');
            foreach ($sexs as $sex) {
                $customMsgPrams['content'] = $this->getMsgContent($sex, 'BOOK');
                $customMsgPrams['sex'] = $sex;
                $customMsgPrams['name'] = '自动发送托管客服消息_书名标题'.date('YmdH').$batch_name;
                \Log::info($customMsgPrams);
                $batch_res = BatchCustomMsgService::addBatchCustomSendMsgs($customMsgPrams,$batch_no);
                \Log::info('batch_res:' . $batch_res . ' batch_no:' . $batch_no);
                if ($batch_res == 1) {
                    //创建客服消息
                    $this->BatchCreateCustomSendMsgs($customMsgPrams,$book_title_channels,$batch_no);
                }
            }
        }

    }


    public function getMsgContent($sex,$title_type='')
    {
        // 男生
        if($sex == 'a'){
            $books = BookConfigService::getTrusteeShipChannelBook('','男频', 4);
        }
        // 女生
        else{
            $books = BookConfigService::getTrusteeShipChannelBook('','女频', 4);
        }
        $books = CustomMsgService::get_book_full_infos($books,$sex,$title_type);
        return json_encode($books);
    }

    public function BatchCreateCustomSendMsgs($customMsgPrams,$in_channel_ids=[],$batch_no=''){
        $customMsgPrams['batch_no'] = $batch_no;
        //按站点取其下公众号创建摸板消息
        foreach($in_channel_ids as $channel_id){
            $time_config = CustomMsgSendTimeConfig::getTimeConfig($channel_id,[
                'begin_time'=>$this->hour_begin,
                'end_time'=>$this->hour_end,
            'custom_category'=>'auto_custom_trusteeship',
            ]);
            if($time_config){
                $customMsgPrams['send_time']=date('Y-m-d').' '.$time_config->send_time;
                $time_config->last_send_date =date('Y-m-d');
                $time_config->save();
            }

            $officialAccountParams['in_channle_ids'] = [$channel_id];
            $official_accounts =  OfficialAccountService::getTrusteeshipOfficialAccountsWithParams($officialAccountParams);
            \Log::info($official_accounts);
            $customMsgPrams['distribution_channel_id'] = $channel_id;
            foreach($official_accounts as $official_account){
                $customMsgPrams['appid'] = $official_account->appid;
                \Log::info('getTrusteeshipOfficialAccounts:appid:'.$official_account->appid.' distribution_channel_id:'.$channel_id);
                //先判断在发送时间段1小时以内，有没有发起过相同的模板消息，如果有发送过，就提示用户已经创建过相同模板消息，不创建新的模板消息
                $isSendCustomer = CustomMsgService::isSendCustomerAtSameTimeAndSex($customMsgPrams);
                if (!empty($isSendCustomer)) {
                    \Log::info('isSendCustomerAtSameTime already_send:appid:'.$customMsgPrams['appid'].' distribution_channel_id:'.$customMsgPrams['distribution_channel_id']);
                    continue;
                }
                $customMsgService = CustomMsgService::addCustomSendMsgs($customMsgPrams);

            }
        }

    }

}