<?php
namespace App\Http\Controllers\Manage\OfficialAccount;
use App\Http\Controllers\Manage\BaseController;
use App\Modules\OfficialAccount\Services\CustomMsgService;
use App\Modules\OfficialAccount\Services\BatchCustomMsgService;
use App\Modules\OfficialAccount\Services\ForceSubscribeService;
use App\Modules\OfficialAccount\Services\OfficialAccountService;
use App\Modules\OfficialAccount\Models\OfficialAccount;
use App\Http\Controllers\Manage\OfficialAccount\Transformers\CustomSendMsgsTransformers;
use App\Http\Controllers\Manage\OfficialAccount\Transformers\BatchCustomSendMsgsTransformers;
use Illuminate\Http\Request;
use GuzzleHttp\Client;
use Hashids;
use App\Modules\Book\Services\BookConfigService;
use App\Modules\Statistic\Services\SendStatistics;
class CustomMsgController extends BaseController
{
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/customSendMsgsByTrusteeship 全部发送客服消息列表获取
* @apiGroup OfficialAccount
* @apiName customSendMsgsByTrusteeship
*/
function customSendMsgsByTrusteeship(Request $request) {
\Log::info('customSendMsgsByTrusteeship');
$param = array();
$param['trusteeship'] = 1;
$customMsgServices = CustomMsgService::customSendMsgsByTrusteeship($param);
// 统计
foreach($customMsgServices as $key=>$customMsgService){
$temp_customMsgService = $customMsgService;
$customMsgService->pv = '';
$customMsgService->uv = '';
$customMsgService->total_order_num = '';
$customMsgService->suc_order_num = '';
$customMsgService->order_suc_rate = '';
$pv = $uv = $total_order_num = $suc_order_num = $order_suc_rate = array();
for($i=1;$i<=4;$i++){
$temp_statistics= $this->get_custom_msg_statistics($temp_customMsgService,$i);
$pv[$i] = $temp_statistics->pv;
$uv[$i] = $temp_statistics->uv;
$total_order_num[$i] = $temp_statistics->total_order_num;
$suc_order_num[$i] = $temp_statistics->suc_order_num;
$order_suc_rate[$i] = $temp_statistics->order_suc_rate;
$success_order_sum[$i] = $temp_statistics->success_order_sum;
}
// 解析bid,非贪婪匹配
$matches = array();
preg_match_all('/bid=(.*?)&cid/', $customMsgService->content, $matches);
$bids = isset($matches[1])?$matches[1]:array();
$simple_bids = $book_names = array();
$j = 1;
if(!empty($bids)){
foreach($bids as $bid){
$simple_bid = Hashids::decode($bid);
if(isset($simple_bid[0]) && !empty($simple_bid[0])){
$simple_bids[$j] = $simple_bid[0];
$book = BookConfigService::getBookById($simple_bid[0]);
$book_names[$j] = isset($book->book_name)?$book->book_name:'';
$j++;
}
}
}
$customMsgService->bids = json_encode($simple_bids);
$customMsgService->book_names = json_encode($book_names);
$customMsgService->pv = json_encode($pv);
$customMsgService->uv = json_encode($uv);
$customMsgService->total_order_num = json_encode($total_order_num);
$customMsgService->suc_order_num = json_encode($suc_order_num);
$customMsgService->order_suc_rate = json_encode($order_suc_rate);
$customMsgService->success_order_sum = json_encode($success_order_sum);
// 公众号名称
$official_account = OfficialAccount::officialAccountByAppid($customMsgService->appid);
$customMsgService->official_account_name = isset($official_account->nickname)?$official_account->nickname:'';
$customMsgServices[$key] = $customMsgService;
}
if (!empty($customMsgServices)) {
return response()->pagination(new CustomSendMsgsTransformers(), $customMsgServices);
}else{
return response()->success(['data'=>0]);
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/customSendMsgsByTrusteeshipAndBacthNo 发送客服消息列表获取
* @apiGroup OfficialAccount
* @apiName customSendMsgsByTrusteeshipAndBacthNo
* @apiParam {String} batch_no 批次id.
*/
function customSendMsgsByTrusteeshipAndBacthNo(Request $request) {
$batch_no = $request->has('batch_no') ? $request->input('batch_no') : '';
if(empty($batch_no)) {
return response()->error("PARAM_EMPTY");
}
$param = array();
$param['trusteeship'] = 1;
$param['batch_no'] = $batch_no;
$customMsgService = CustomMsgService::customSendMsgsByTrusteeshipAndBacthNo($param);
if (!empty($customMsgService)) {
return response()->collection(new CustomSendMsgsTransformers(), $customMsgService);
}else{
return response()->success(['data'=>0]);
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/batchCustomMsgsList 获取批次客服消息列表
* @apiGroup OfficialAccount
* @apiName batchCustomMsgsList
*/
function batchCustomMsgsList(Request $request) {
\Log::info('batchCustomMsgsList_start:');
$batchCustomMsgs = BatchCustomMsgService::batchCustomMsgList();
\Log::info($batchCustomMsgs);
foreach($batchCustomMsgs as $batch_key=>$batchCustomMsg){
// 得到渠道列表
$param = array();
$param['trusteeship'] = 1;
$param['batch_no'] = $batchCustomMsg->id;
\Log::info('batchCustomMsgsList:id:'.$batchCustomMsg->id);
$child_custom_msgs = CustomMsgService::customSendMsgsByTrusteeshipAndBacthNo($param);
$pv = $uv = $pay_user_num = $total_order_num = $suc_order_num = $order_suc_rate = $success_order_sum = array();
$simple_bids = $book_names = array();
// 子渠道汇总，统计到每本书的级别
foreach($child_custom_msgs as $key=>$customMsgService){
// \Log::info('key:'.$key);
$temp_customMsgService = $customMsgService;
for($i=1;$i<=4;$i++){
$temp_statistics= $this->get_custom_msg_statistics($temp_customMsgService,$i);
// init
if(!isset($pv[$i])) {
$pv[$i] = $uv[$i] = $pay_user_num[$i] = $total_order_num[$i] = $suc_order_num[$i]=$order_suc_rate[$i]=$success_order_sum[$i]=0;
}
$pv[$i] += $temp_statistics->pv;
$uv[$i] += $temp_statistics->uv;
$pay_user_num[$i] += $temp_statistics->pay_user_num;
$total_order_num[$i] += $temp_statistics->total_order_num;
$suc_order_num[$i] += $temp_statistics->suc_order_num;
$order_suc_rate[$i] += $temp_statistics->order_suc_rate;
$success_order_sum[$i] += $temp_statistics->success_order_sum;
break;
}
// 同1批次，内容一致
if($key == 0){
\Log::info('key0');
// \Log::info($customMsgService);
// 解析bid,非贪婪匹配
$matches = array();
preg_match_all('/bid=(.*?)&cid/', $customMsgService->content, $matches);
$bids = isset($matches[1])?$matches[1]:array();
$j = 1;
if(!empty($bids)){
foreach($bids as $bid){
$simple_bid = Hashids::decode($bid);
if(isset($simple_bid[0]) && !empty($simple_bid[0])){
$simple_bids[$j] = $simple_bid[0];
$book = BookConfigService::getBookById($simple_bid[0]);
$book_names[$j] = isset($book->book_name)?$book->book_name:'';
$j++;
}
}
}
}
$batchCustomMsg->user_num += $customMsgService->user_num;
}
$batchCustomMsg->pv = json_encode($pv);
$batchCustomMsg->uv = json_encode($uv);
$batchCustomMsg->pay_user_num = json_encode($pay_user_num);
$batchCustomMsg->total_order_num = json_encode($total_order_num);
$batchCustomMsg->suc_order_num = json_encode($suc_order_num);
$batchCustomMsg->order_suc_rate = json_encode($order_suc_rate);
$batchCustomMsg->success_order_sum = json_encode($success_order_sum);
$batchCustomMsg->bids = json_encode($simple_bids);
$batchCustomMsg->book_names = json_encode($book_names);
$batchCustomMsgs[$batch_key] = $batchCustomMsg;
}
if (!empty($batchCustomMsgs)) {
return response()->pagination(new BatchCustomSendMsgsTransformers(), $batchCustomMsgs);
}else{
return response()->success(['data'=>0]);
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/batchCustomMsgById 通过ID获取指定批次客服消息
* @apiGroup OfficialAccount
* @apiName batchCustomMsgById
* @apiParam {String} id 批次id.
*/
function batchCustomMsgById(Request $request) {
$id = $request->has('id') ? $request->input('id') : '';
if(empty($id)) {
return response()->error("PARAM_EMPTY");
}
\Log::info('batchCustomMsgById:'.$id);
$param = array();
$param['id'] = $id;
$batchCustomMsgService = BatchCustomMsgService::batchCustomMsgById($param);
// \Log::info($batchCustomMsgService);
if (!empty($batchCustomMsgService)) {
return response()->item(new BatchCustomSendMsgsTransformers(), $batchCustomMsgService);
}else{
return response()->success(['data'=>0]);
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/updateBatchCustomSendMsgStatusById 更新发送客服消息
* @apiGroup OfficialAccount
* @apiName updateBatchCustomSendMsgStatusById
* @apiParam {String} id 客服消息批次id.
* @apiParam {String} status 状态 1待发送 3发送成功 4删除 8发送中 .
* @apiParam {String} del_flag 是否删除：1是 0否.
* @apiSuccessExample {json} Success-Response:
*
* {
* "code": 0,
* "msg": "",
* "data": {
* }
* }
*/
function updateBatchCustomSendMsgStatusById(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");
}
$del_flag = $request->has('del_flag') ? $request->input('del_flag') : '0';
\Log::info('updateBatchCustomSendMsgStatusById_start,id:'.$id.' status:'.$status.' $del_flag:'.$del_flag);
$param = array();
$param['id'] = $id;
$param['status'] = $status;
$param['del_flag'] = $del_flag;
$batch_res = BatchCustomMsgService::updateBatchCustomSendMsgStatusById($param);
// 循环子消息
$param = array();
$param['trusteeship'] = 1;
$param['batch_no'] = $id;
$customMsgServices = CustomMsgService::customSendMsgsByTrusteeshipAndBacthNo($param);
// \Log::info($customMsgServices);
if(!empty($customMsgServices)){
foreach($customMsgServices as $customMsgService){
\Log::info('stopBatchCustomSendMsgsById_single:'.json_encode($customMsgService));
$customMsgService = CustomMsgService::updateCustomSendMsgsStatusMulty($customMsgService->id,$status,$del_flag);
}
}
if ($batch_res == 1) {
return response()->success();
}else {
return response()->error('CUSTOMS_SETTING_FAILED');
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/batchAddCustomSendMsgs 批量添加客服消息
* @apiGroup OfficialAccount
* @apiName batchAddCustomSendMsgs
* @apiParam {String} name 客服消息标题.
* @apiParam {String} send_time 客服消息发送时间.
* @apiParam {String} content 客服消息内容. 格式：[[{"title":"横眉冷对千夫指，俯首甘为孺子牛"},{"description":"横眉冷对千夫指，俯首甘为孺子牛"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}],[{"title":"来他家做佣人半年，结果天天被男主人这样！"},{"description":"来他家做佣人半年，结果天天被男主人这样！"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}]]
* @apiParam {String} redirect_url 点击消息重定向地址.
* @apiParam {String} sex 用户性别.
* @apiSuccessExample {json} Success-Response:
*
* {
* "code": 0,
* "msg": "",
* "data": []
* }
*/
function batchAddCustomSendMsgs(Request $request) {
\Log::info('manage_batchAddCustomSendMsgs_start');
\Log::info($request->all());
$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");
}
$content = $request->has('content') ? $request->input('content') : '';
if(empty($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");
}
$sex = $request->has('sex') ? $request->input('sex') : '';
if(empty($sex)) {
return response()->error("PARAM_EMPTY");
}
$customMsgPrams['name'] = $name;
$customMsgPrams['send_time'] = $send_time;
$customMsgPrams['content'] = json_encode($content);
$customMsgPrams['redirect_url'] = $redirect_url;
$customMsgPrams['sex'] = $sex;
$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';// 分销界面不展示
\Log::info($customMsgPrams);
$batch_no = '';
$batch_res = BatchCustomMsgService::addBatchCustomSendMsgs($customMsgPrams,$batch_no);
\Log::info('$batch_res:'.$batch_res.' $batch_no:'.$batch_no);
if($batch_res == 1){
$customMsgPrams['batch_no'] = $batch_no;
$official_accounts = OfficialAccountService::getTrusteeshipOfficialAccounts();
\Log::info('getTrusteeshipOfficialAccounts');
// \Log::info($official_accounts);
foreach($official_accounts as $official_account){
$customMsgPrams['appid'] = $official_account->appid;
$customMsgPrams['distribution_channel_id'] = $official_account->distribution_channel_id;
\Log::info('getTrusteeshipOfficialAccounts:appid:'.$official_account->appid.' distribution_channel_id:'.$official_account->distribution_channel_id);
//先判断在发送时间段1小时以内，有没有发起过相同的模板消息，如果有发送过，就提示用户已经创建过相同模板消息，不创建新的模板消息
$isSendCustomer = CustomMsgService::isSendCustomerAtSameTime($customMsgPrams);
if (!empty($isSendCustomer)) {
\Log::info('isSendCustomerAtSameTime already_send:appid:'.$customMsgPrams['appid'].' distribution_channel_id:'.$customMsgPrams['distribution_channel_id']);
continue;
}
$customMsgService = CustomMsgService::addCustomSendMsgs($customMsgPrams);
}
}
if ($batch_res == 1) {
return response()->success();
}elseif ($batch_res == 2) {
return response()->error('CUSTOMS_SEND_FAILED');
}elseif ($batch_res == 3) {
return response()->error('CUSTOMS_DOUBLE_FAILED');
}elseif ($batch_res == 4) {
return response()->error('CUSTOMS_DOUBLE_FAILED');
}elseif ($batch_res == 0) {
return response()->error('CUSTOMS_SEND_FAILED');
}
else{
return response()->error('CUSTOMS_SEND_FAILED');
}
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/editCustomSendMsgs 编辑客服消息
* @apiGroup OfficialAccount
* @apiName editCustomSendMsgs
* @apiParam {String} appid 服务号，英文逗号隔开.
* @apiParam {String} distribution_channel_id 渠道号.
* @apiParam {String} name 客服消息标题.
* @apiParam {String} send_time 客服消息发送时间.
* @apiParam {String} content 客服消息内容. 格式：[[{"title":"横眉冷对千夫指，俯首甘为孺子牛"},{"description":"横眉冷对千夫指，俯首甘为孺子牛"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}],[{"title":"来他家做佣人半年，结果天天被男主人这样！"},{"description":"来他家做佣人半年，结果天天被男主人这样！"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}]]
* @apiParam {String} redirect_url 点击消息重定向地址.
* @apiParam {String} sex 用户性别.
* @apiParam {String} id id.
* @apiSuccessExample {json} Success-Response:
*
* {
* "code": 0,
* "msg": "",
* "data": []
* }
*/
// 批量编辑暂时不支持，逻辑复杂
function editCustomSendMsgs(Request $request) {
\Log::info('editCustomSendMsgs_start');
\Log::info($request->all());
return response()->error("PARAM_EMPTY");
}
/**
* @apiVersion 1.0.0
* @api {GET} OfficialAccount/testAddCustomSendMsgs 测试向单个用户发送客服消息
* @apiGroup OfficialAccount
* @apiName testAddCustomSendMsgs
* @apiParam {String} uid 用户id或者openid.
* @apiParam {String} name 客服消息标题.
* @apiParam {String} content 客服消息内容. 格式：[[{"title":"横眉冷对千夫指，俯首甘为孺子牛"},{"description":"横眉冷对千夫指，俯首甘为孺子牛"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}],[{"title":"来他家做佣人半年，结果天天被男主人这样！"},{"description":"来他家做佣人半年，结果天天被男主人这样！"},{"url":"http://www.baidu.com"},{"image":"https://ss1.baidu.com/6ONXsjip0QIZ8tyhnq/it/u=314110819,2721402218&fm=173&s=91B3C23586024F4D0235ECFB0300C036&w=550&h=550&img.JPEG"}]]
* @apiParam {String} redirect_url 点击消息重定向地址.
* @apiSuccessExample {json} Success-Response:
*
* {
* "code": 0,
* "msg": "",
* "data": []
* }
*/
function testAddCustomSendMsgs(Request $request) {
\Log::info('testAddCustomSendMsgs_start');
\Log::info($request->all());
$name = $request->has('name') ? $request->input('name') : '';
if(empty($name)) {
return response()->error("PARAM_EMPTY");
}
$content = $request->has('content') ? $request->input('content') : '';
if(empty($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");
}
$uid = $request->has('uid') ? $request->input('uid') : '';
if(empty($uid)) {
return response()->error("PARAM_EMPTY");
}
$customMsgPrams['name'] = $name;
$customMsgPrams['redirect_url'] = $redirect_url;
$customMsgPrams['uid'] = $uid;
$customMsgPrams['distribution_channel_id'] = 14;// 线上改为14
$customMsgPrams['appid'] = 'wxb2aaa55b088f12e9,wxdbc486f1b4f6a8c3';
// 测试发送加上域名
foreach($content as $key=>$_content){
// \Log::info($_content);
$url = env('PROTOCOL').'://site'.encodeDistributionChannelId($customMsgPrams['distribution_channel_id']).'.'.env('CUSTOM_HOST').'.com'.$_content[2]['url'];
\Log::info('key:'.$key.' url:'.$url);
$content[$key][2]['url'] = $url;
}
$customMsgPrams['content'] = json_encode($content);
$customMsgService = CustomMsgService::testAddCustomSendMsgs($customMsgPrams);
if ($customMsgService == 1) {
return response()->success();
}elseif ($customMsgService == 2) {
return response()->error('CUSTOMS_SEND_FAILED');
}elseif ($customMsgService == 0) {
return response()->error('CUSTOMS_SEND_FAILED');
}else{
return response()->error('CUSTOMS_SEND_FAILED');
}
}
public static function get_custom_msg_statistics($customMsgService,$num){
$start_date = date('Y-m-d',strtotime('-7 day'));
$end_date = date('Y-m-d',strtotime('+1 day'));
$stat_type = 'custom_'.$customMsgService->id.'_'.$num;
// \Log::info('get_custom_msg_statistics:'.$customMsgService->distribution_channel_id.' start_date:'.$start_date.' end_date:'.$end_date.' stat_type:'.$stat_type);
$user_pay_stat = SendStatistics::getWechatMsgUseRecord($customMsgService->distribution_channel_id,$stat_type,$start_date,$end_date);
// \Log::info('get_custom_msg_statistics:');\Log::info($user_pay_stat);
$customMsgService->uv = isset($user_pay_stat['uv'])?$user_pay_stat['uv']:0;
$customMsgService->pv = isset($user_pay_stat['pv'])?$user_pay_stat['pv']:0;
$customMsgService->pay_user_num = isset($user_pay_stat['user_num'])?$user_pay_stat['user_num']:0;
$customMsgService->total_order_num = isset($user_pay_stat['order_count'])?$user_pay_stat['order_count']:0;
$customMsgService->suc_order_num = isset($user_pay_stat['success_order_count'])?$user_pay_stat['success_order_count']:0;
$customMsgService->success_order_sum = isset($user_pay_stat['success_order_sum'])?$user_pay_stat['success_order_sum']:0;
if(isset($customMsgService->total_order_num) && $customMsgService->total_order_num > 0){
$customMsgService->order_suc_rate = round(100*$customMsgService->suc_order_num/$customMsgService->total_order_num,2);
}else{
$customMsgService->order_suc_rate = 0;
}
return $customMsgService;
}
}