gaoyixia/application/common/model/UserMessage.php

<?php
namespace app\common\model;
use think\Model;
use JPush\Client;
use function Symfony\Component\String\b;

require_once env('root_path').'vendor/jpush/jpush/autoload.php';
// 会员消息
class UserMessage extends Model
{
    // ['$module'=>['$type'=>['title'=>'标题','msg'=>['$msg_key'=>'','$msg_key'=>'']]]
    static $type_desc = [
        'video'=>[
            1=>['title'=>'视频投稿','msg'=>['视频投稿成功请等待审核'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'视频审核','msg'=>['恭喜您视频审核成功','抱歉啦视频审核失败~~'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到回复','msg'=>['有会员评论了您的回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到评论','msg'=>['有会员评论了您的视频'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            5=>['title'=>'订阅消息','msg'=>['您追更的视频有更新'],'channel'=>['xiaomi'=>"108238",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
            ],// 视频
        'article'=>[
            1=>['title'=>'图文投稿','msg'=>['图文投稿成功请等待审核'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'图文审核','msg'=>['恭喜您图文审核成功','抱歉啦图文审核失败~~'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到回复','msg'=>['有会员评论了您的回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到评论','msg'=>['有会员评论了您的图文'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            5=>['title'=>'订阅消息','msg'=>['您订阅的图文有更新'],'channel'=>['xiaomi'=>"108238",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
            ],//图文
        'datum'=>[
            1=>['title'=>'资料投稿','msg'=>['资料投稿成功请等待审核'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'资料审核','msg'=>['恭喜您资料审核成功','抱歉啦资料审核失败~~'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到回复','msg'=>['有会员评论了您的回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到评论','msg'=>['有会员评论了您的资料'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            5=>['title'=>'订阅消息','msg'=>['您订阅的资料有更新'],'channel'=>['xiaomi'=>"108238",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
            ],// 资料
        'supplier'=>[
            1=>['title'=>'产品投稿','msg'=>['产品投稿成功请等待审核'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'产品审核','msg'=>['恭喜您产品审核成功','抱歉啦产品审核失败~~'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到回复','msg'=>['有会员评论了您的回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到评论','msg'=>['有会员评论了您的产品'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            5=>['title'=>'订阅消息','msg'=>['您订阅的产品有更新'],'channel'=>['xiaomi'=>"108238",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
        ],//供应商产品
        'activity'=>[
            1=>['title'=>'活动审核','msg'=>['恭喜您报名审核成功','抱歉啦报名审核失败~~','恭喜您报名成功'],'channel'=>['xiaomi'=>"108239",'huawei'=>'EXPRESS','oppo'=>'order']],
            2=>['title'=>'变更通知','msg'=>['活动有变更'],'channel'=>['xiaomi'=>"108239",'huawei'=>'EXPRESS','oppo'=>'order']],
            3=>['title'=>'活动提醒','msg'=>['活动有变更'],'channel'=>['xiaomi'=>"108239",'huawei'=>'EXPRESS','oppo'=>'order']],
            4=>['title'=>'活动订单','msg'=>['未支付订单提醒','活动订单申请退款','订单退款通知'],'channel'=>['xiaomi'=>"108239",'huawei'=>'EXPRESS','oppo'=>'order']],
            5=>['title'=>'活动发票','msg'=>['您的电子发票已开票','您的订单发票已发货'],'channel'=>['xiaomi'=>"108239",'huawei'=>'EXPRESS','oppo'=>'order']],
            ],// 活动
        'demand'=>[
            1=>['title'=>'需求投稿','msg'=>['需求投稿成功请等待审核'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'需求审核','msg'=>['恭喜您需求审核成功','抱歉啦需求审核失败~~'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到回复','msg'=>['有会员评论了您的回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到评论','msg'=>['有会员评论了您的需求'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
        ],// 需求
        'forum'=>[
            1=>['title'=>'问提投稿','msg'=>['问答投稿成功'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            2=>['title'=>'问提审核','msg'=>['恭喜您问提审核成功','抱歉啦问答审核失败'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            3=>['title'=>'收到评论','msg'=>['有会员评论了您的答案'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            4=>['title'=>'收到回复','msg'=>['有会员回复了您的评论'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
            5=>['title'=>'收到答案','msg'=>['有会员回答了您的问题'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],// 回答
            6=>['title'=>'订阅消息','msg'=>['关注问答新回复'],'channel'=>['xiaomi'=>"108237",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
            7=>['title'=>'收到评论','msg'=>['有会员评论了您的问题'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message']],
        ],// 问答
        'press'=>[
            1=>['title'=>'收到回复','msg'=>['有会员回复了您的评论'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'news']],
            2=>['title'=>'收到评论','msg'=>['有会员评论了您的新闻'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'news']],
        ],// 新闻
        'mall'=>[

        ],// 商城
        'feedback'=>[
            1=>['title'=>'反馈内容回复','msg'=>['平台回复了您的反馈'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'news']],
        ],// 反馈
        'user' =>[
            1=>['title'=>'反馈内容回复','msg'=>['平台回复了您的反馈'],'channel'=>['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'news']],
        ],// 会员管理
        'recruit'=>[
            5=>['title'=>'订阅消息','msg'=>['您订阅的招聘有更新'],'channel'=>['xiaomi'=>"108237",'huawei'=>'SUBSCRIPTION','oppo'=>'subscribe']],
        ],// 招聘
    ];

    /**
     * 发送会员消息
     * @param $to_user  发送给谁
     * @param $module  模块
     * @param $type   模块类型
     * @param $msg_key 内容key[msg的key]
     * @param $from_user  哪个会员发送的
     * @param $rel_id   关联的id
     * @param $content   内容
     * @param $children_id   模块详情id
     * @param $series_id   模块系列id
     * @param string $content
     */
    public static function sendUserMessage($to_user,$module,$type,$msg_key,$from_user,$rel_id,$content = '',$children_id= 0,$series_id=0)
    {
        if($to_user == 1 || !$to_user) return true;

        $message = [
            'user_id'=>$to_user,
            'from_user'=>$from_user,
            'content'=> $content ? $content : static::$type_desc[$module][$type]['msg'][$msg_key] ,
            'relation_id'=>$rel_id,
            'children_id'=>$children_id,
            'type_id'=>$type,
            'module'=>$module,
            'jg_type'=>0,
            'title'=>static::$type_desc[$module][$type]['title'],
        ];
        //var_dump($message);
        $from_name = User::where('id',$from_user)->value('name');
        switch ($module) {
            case 'video':
                if((in_array($type,[3,4]) && PlatformSwitch::checkSwitch($to_user,$children_id,7)) || (in_array($type,[5])  && PlatformSwitch::checkSwitch($to_user,$series_id,2)) ) {
                    $message['jg_type'] = 1;
                    $res = static::Jpush($to_user,$message['content'],$module,$type,$series_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }
                break;
            case 'article':
                if((in_array($type,[3,4]) && PlatformSwitch::checkSwitch($to_user,$children_id,8)) || (in_array($type,[5])  && PlatformSwitch::checkSwitch($to_user,$series_id,3)))
                {
                    $message['jg_type'] = 1;
                    $res = static::Jpush($to_user,$message['content'],$module,$type,$series_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }

                break;
            case 'datum':
                if((in_array($type,[3,4]) && PlatformSwitch::checkSwitch($to_user,$children_id,9)) || (in_array($type,[5])  && PlatformSwitch::checkSwitch($to_user,$series_id,4)) ) {
                    $message['jg_type'] = 1;
                    $res =  static::Jpush($to_user,$message['content'],$module,$type,$series_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }
                break;
            case 'forum':
                if((in_array($type,[3,4,5,6,7]) && PlatformSwitch::checkSwitch($to_user,$rel_id,1))) {
                    $message['jg_type'] = 1;
                    $res =  static::Jpush($to_user,$message['content'],$module,$type,$rel_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }

                break;
            case 'supplier':
                if((in_array($type,[3,4]) && PlatformSwitch::checkSwitch($to_user,$rel_id,11)) || (in_array($type,[5])  && PlatformSwitch::checkSwitch($to_user,$series_id,5))) {
                    $message['jg_type'] = 1;
                    $res =  static::Jpush($to_user,$message['content'],$module,$type,$rel_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }
                break;
            case 'activity':
                $message['jg_type'] = 1;
                $res =  static::Jpush($to_user,$message['content'],$module,$type,$rel_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                break;
            case 'demand':
                if(in_array($type,[3,4])) {
                    $message['jg_type'] = 1;
                    $res =  static::Jpush($to_user,$message['content'],$module,$type,$rel_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                    $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                }
                break;
            case 'recruit':
                $message['jg_type'] = 1;
                $res =  static::Jpush($to_user,$message['content'],$module,$type,$rel_id,$children_id,static::$type_desc[$module][$type]['channel'],['title'=>static::$type_desc[$module][$type]['title']]);
                $message['jg_res']  = is_array($res) ? json_encode($res) :$res;
                break;

        }
        self::create($message);
        // 哪些模块中的某些类型需要极光推送
    }

    public static function Jpush($user_id = 0,$alert = '',$module='',$type='',$rel_id='',$children_id=0,$channel=[],$ext = []){
        // 消息分类
        $title = isset($ext['title'] ) && $ext['title'] ? $ext['title'] : '消息通知';
        if(empty($channel)) $channel = ['xiaomi'=>"108237",'huawei'=>'IM','oppo'=>'message'];
        $appKey = '02a7faefd91c8a6a446a6a14';
        $masterSecret = 'ba2e100db997024d9b6e5d35';
        $client = new Client($appKey, $masterSecret,null);
        $push_payload = $client->push()
            ->setPlatform(array('ios', 'android'))
            ->addAlias(strval($user_id))
            ->iosNotification($alert, array(
                'badge' => '+1',
                'content-available' => true,
                'mutable-content' => true,
                'category' => 'jiguang',
                'extras' => array(
                    'key' => 'value',
                    'module' => $module,
                    'type' => $type,
                    'rel_id' => $rel_id,
                    'children_id' => $children_id
                ),
            ))->androidNotification($alert, array(
                'title' => $title,
                'badge_add_num' => 1,
                'badge_class' => 'com.hdl.gaogao.activity.SplashActivity',
                // 'builder_id' => 2,
                'extras' => array(
                    'module' => $module,
                    'type' => $type,
                    'rel_id' => $rel_id,
                    'children_id'=>$children_id
                ),
            ))->options([
                "classification"=> 1,
                'third_party_channel'=>[
                    'vivo'   => ['callback_id'=>"637",'classification'=>1,'category'=>''],
                    'xiaomi' => ['channel_id'=>$channel['xiaomi']],
                    'huawei' => ['importance'=>'NORMAL','category'=>$channel['huawei']],
                    'oppo'   => ['channel_id'=>$channel['oppo']]
                ],
                'apns_production' => false,// false 开发环境 ，true 生产环境
            ]);

        try {
           // var_dump($push_payload);
            $response = $push_payload->send();
            return $response;
        } catch  (\JPush\Exceptions\APIConnectionException $e) {
            return $e;
        } catch (\JPush\Exceptions\APIRequestException $e) {
            return $e;
        }
    }

    /**
     * 获取消息未读数量
     * @param $user_id  发送给谁
     * @param $module  模块
     * @param $type   模块类型
     * @param $msg_key 内容key[msg的key]
     */
    public static function getUnreadNum($user_id,$module,$type)
    {
        return static::where(['user_id'=>$user_id,'module'=>$module,'type_id'=>$type,'is_deleted'=>0,'is_read'=>0])->count();
    }



}