hemall.terabimsoft.com.cn/app/common/services/MessageService.php

<?php

namespace app\common\services;

use app\common\events\message\SendMessageEvent;
use app\common\facades\EasyWeChat;
use app\common\models\AccountWechats;
use app\common\models\Member;
use app\common\models\notice\MessageTemp;
use app\common\models\TemplateMessageRecord;
use app\Jobs\DispatchesJobs;
use app\Jobs\MessageNoticeJob;
use Exception;
use app\Jobs\MiniMessageNoticeJob;
use app\common\models\FormId;
class MessageService
{

    /**
     * 消息推送，暂时使用，需要优化
     *
     * @param int $member_id
     * @param int $template_id
     * @param array $params
     * @param string $url
     * @return bool
     */
    public function push($member_id, $temp_id, array $params, $url='', $uniacid='')
    {
        if ($uniacid) {
            \Setting::$uniqueAccountId = \YunShop::app()->uniacid = $uniacid;
        } else{
            \Setting::$uniqueAccountId = \YunShop::app()->uniacid;
        }
        
        if(\Setting::get('shop.notice.toggle') == false){
            return false;
        }

        if (!$member_id || !$temp_id) {
            return false;
        }

        $temp = MessageTemp::withoutGlobalScopes(['uniacid'])->whereId($temp_id)->first();

        if (!$temp) {
            return false;
        }
        $template_id = $temp->template_id;

        if (!$template_id) {
            \Log::error("微信消息推送：MessageTemp::template_id参数不存在");
            return false;
        }

        $send_msg = $this->getSendMsg($temp, $params);

        $memberModel = $this->getMemberModel($member_id);

        if (!$memberModel) {
            return false;
        }

        $config = $this->getConfiguration($uniacid);

        try {
			if(empty($url)){
				$url = $temp->news_link;//todo 没有链接就是用模板设置的链接
			}
			$app = EasyWeChat::officialAccount($config);
			$userService = $app->user;
			$user = $userService->get($memberModel->hasOneFans->openid);
			if ($user['subscribe'] != 1  && $user->subscribe != 1) {
				\Log::debug('微信消息推送：用户未关注公众号',$user);
				return false;
			}
			$app->template_message->send([
				'touser' => $memberModel->hasOneFans->openid,
				'template_id' => $template_id,
				'url' => $url,
				'data' => $send_msg,
			]);

        } catch (Exception $error) {

            TemplateMessageRecord::create([
                'uniacid' => \YunShop::app()->uniacid,
                'member_id' => $member_id,
                'template_id' => $template_id,
                'url' => $url?:'无',
                'openid' => $memberModel->hasOneFans->openid ?: 0,
                'data' => json_encode($send_msg),
                'send_time' => time(),
                'status' => -1,
                'extend_data' => $error->getMessage(),
            ]);

            return true;
        }

        return true;
    }


    /**
     * 会员信息
     *
     * @param $member_id
     * @return bool
     */
    private function getMemberModel($member_id)
    {
        if (!$member_id) {
            \Log::error("微信消息推送：uid参数不存在");
            return false;
        }

        $memberModel = Member::whereUid($member_id)->with([
            'hasOneFans' => function($q) {
                $q->uniacid();
            }])->first();

        if (!isset($memberModel)) {
            \Log::error("微信消息推送：未找到uid:{$member_id}的用户");
            return false;
        }
        if (!$memberModel->isFollow()) {
            \Log::error("微信消息推送：会员uid:{$member_id}未关注公众号");
            return false;
        }
        if (!$memberModel->hasOneFans->openid) {
            \Log::error("微信消息推送：会员uid:{$member_id} 没有openid");
            return false;
        }

        return $memberModel;
    }


    /**
     * 获取公众号配置信息
     *
     * @return array|bool
     */
    public function getConfiguration($uniacid)
    {
        if ($uniacid) {
            \Setting::$uniqueAccountId = \YunShop::app()->uniacid = $uniacid;
        } else{
            \Setting::$uniqueAccountId = \YunShop::app()->uniacid;
        }

        $accountWechat = AccountWechats::getAccountByUniacid(\YunShop::app()->uniacid);

        if (!isset($accountWechat)) {
            \Log::error("微信消息推送：未找到uniacid:{$uniacid}的配置信息");
            return false;
        }

        return ['app_id' => $accountWechat->key, 'secret' => $accountWechat->secret];
    }

    private function getSendMsg($temp, $params)
    {
        $msg = [
            'first' => [
                'value' => $this->replaceTemplate($temp->first, $params),
                'color' => $temp->first_color
            ],
            'remark' => [
                'value' => $this->replaceTemplate($temp->remark, $params),
                'color' => $temp->remark_color
            ]
        ];
        foreach ($temp->data as $row) {
            $msg[$row['keywords']] = [
                'value' => $this->replaceTemplate($row['value'], $params),
                'color' => $row['color']
            ];
        }

        return $msg;
    }

    private function replaceTemplate($str, $datas = array())
    {
        foreach ($datas as $row ) {
            $str = str_replace('[' . $row['name'] . ']', $row['value'], $str);
        }
        return $str;
    }








    /*todo 一下代码需要重构，重新分化类功能 2018-03-23 yitian*/

    /**
     * 发送微信模板消息
     *
     * @param $templateId
     * @param $data
     * @param $uid
     * @param string $uniacid
     * @param string $url
     * @return bool
     */
    public static function MiniNotice($templateId, $data, $uid, $uniacid = '', $url = '',$scene = '')
    {
        \Log::debug('==============miniApp===================',[$templateId,$data,$uid]);

       // $res = AccountWechats::getAccountByUniacid(\YunShop::app()->uniacid);
        $res = \Setting::get('plugin.min_app');
        $options = [
            'app_id' => $res['key'],
            'secret' => $res['secret'],
        ];
        $member = Member::whereUid($uid)->first();
        if (!isset($member)) {
            \Log::error("小程序消息推送失败,未找到uid:{$uid}的用户");
            return false;
        }

        if(empty($scene)){
            $createTime = $member->hasOneMiniApp->formId_create_time;
            $time=strtotime (date("Y-m-d H:i:s")); //当前时间
            $minute=floor(($time-$createTime) % (86400/60));
            \Log::info('小程序消息推送时间',$createTime."----".$time."----".$minute);
            if ($minute > 10080 && empty($createTime)){ 
                \Log::error("小程序消息推送失败,formId失效");
                return false;
            }
            // $scene = $member->hasOneMiniApp->formId;
            // $pieces = explode("#", $scene);
            // $scene = array_shift($pieces);//获取首个元素并删除
            // $str = implode("#", $pieces);
            // MemberMiniAppModel::where('member_id',$uid)->uniacid()->update(['formId'=>$str]);
            $scene = FormId::orderBy('addtime','desc')->first();
            $scene = empty($scene) ? array() : $scene->toArray();
            \Log::info('小程序scene',$scene);
        }
        \Log::info('小程序消息scene',$scene);
        if(empty($scene)){
            \Log::error("小程序消息推送失败,formId失效");
            return false;
        }
        $job = new MiniMessageNoticeJob($options, $templateId, $data,$member->hasOneMiniApp->openid, $url,$scene['formid'] );
        DispatchesJobs::dispatch($job,DispatchesJobs::LOW);
        FormId::where('id',$scene['id'])->delete();//删除formid减少消耗
    }

    public static function notice($templateId, $data, $uid, $uniacid = '', $url = '',$miniApp = [])
    {
        if (\Setting::get('shop.notice.toggle') == false) {
            return false;
        }

        $member = Member::whereUid($uid)->first();
        if (!isset($member)) {
            \Log::error("微信消息推送失败,未找到uid:{$uid}的用户");
            return false;
        }

        if (!$member->isFollow()) {
            return false;
        }
        $job = new MessageNoticeJob($templateId, $data, $member->hasOneFans->openid, $url);

        DispatchesJobs::dispatch($job,DispatchesJobs::LOW);
    }


    public static function getWechatTemplates()
    {
        $app = app('wechat');
        $notice = $app->notice;
        return $notice->getPrivateTemplates();
    }

    /**
     * 验证"模板消息ID" 是否有效
     * @param $template_id
     * @return array
     */
    public static function verifyTemplateId($template_id)
    {
        $templates = self::getWechatTemplates()->get('template_list');
        if (!isset($templates)) {
            return [
                'status' => -1,
                'msg' => '任务处理通知模板id错误'
            ];
        }
        $template = collect($templates)->where('template_id', $template_id)->first();
        if (!isset($template)) {
            return [
                'status' => -1,
                'msg' => '任务处理通知模板id错误'
            ];
        }
        return [
            'status' => 1
        ];
    }

    /**
     * 发送微信"客服消息"
     * @param $openid
     * @param $data
     * 文本消息: $data = new Text(['content' => 'Hello']);
     * 图文消息:
     * $data = new News([
     * 'title' => 'your_title',
     * 'image' => 'your_image',
     * 'description' => 'your_description',
     * 'url' => 'your_url',
     * ]);
     */
    public static function sendCustomerServiceNotice($openid, $data)
    {
        $app = app('wechat');
        if (array_key_exists('content', $data)) {
            $data = new Text($data); //发送文本消息
        } else {
            $data = new News($data); //发送图文消息
        }
        $app->staff->message($data)->to($openid)->send();
    }
}