wangdu_wechat/app/Http/Controllers/Queue/Template/AddTextsTasksController.php

<?php
 
namespace App\Http\Controllers\Queue\Template;
 
use Illuminate\Http\Request;
use App\Http\Requests;
use App\Jobs\SendTexts;
use App\Http\Controllers\Controller;
use App\Http\Models\WechatTemplateSendInfo;
use Carbon\Carbon;
use App\Http\Controllers\Wechat\Staff\TextsWorksController;

class AddTextsTasksController extends Controller
{
	public function add_texts_task(){
		$data = array();
		$data['openid'] = 'oMF1twu7TSSFcV2snbAmvZ5t96D4';
		$data['appid'] = 'wxb2aaa55b088f12e9';
		
// 		$data['openid'] = 'oAcqg1LRHNKN2jaEkJ5v56HOwPEQ';
// 		$data['appid'] = 'wxdbc486f1b4f6a8c3';
		
		$data['content'] = <<<EOT
		你好啊3323，<a href="www.baidu.com">woca</a>
woha
woca
	  nima
EOT;
// 		$data['content'] = json_encode($data['content']);
		$data['type'] = 'last_task';// last_task,one_task
		$data['task_id'] = 1;
		$data['send_time'] = date("Y-m-d H:i:s");
		$send_data=array(
			'send_time'=>date("Y-m-d H:i:s"),
			'data' => $data
		);
		
		v('add_texts_task_data:');v($send_data);
		$delay = 0;

// 		v('delay:'.$delay);die();
		$job = (new SendTexts($send_data))->onConnection('rabbitmq')->delay($delay)->onQueue('send_texts_list');
		
		dispatch($job);

	}
	
	public function test_send_texts(){
		$data = array();
		$data['openid'] = 'oAcqg1LRHNKN2jaEkJ5v56HOwPEQ';
		$data['appid'] = 'wxdbc486f1b4f6a8c3';
		$data['content'] = '你好，<a href="www.baidu.com">woca</a>\n\nwoha';
		$data['type'] = 'last_task';// last_task,one_task
		$data['task_id'] = 3;
		$data['send_time'] = date("Y-m-d H:i:s");

		v('test_send_template_data:');v($data);
		$TemplateWork = new TextsWorksController($data);
		$TemplateWork->do_work();
	}

}