zhuishuyun_quickapp/app/Modules/User/Services/ForceSubscribeUserIService.php

<?php
/**
 * Created by PhpStorm.
 * User: z-yang
 * Date: 2019/3/26
 * Time: 15:09
 */

namespace App\Modules\User\Services;

use App\Modules\OfficialAccount\Models\ForceSubscribeUsers;
use App\Modules\OfficialAccount\Models\OfficialAccount;
use Redis;

class ForceSubscribeUserIService
{

    public static function subscribes($uid,$distribution_channel_id,$send_order_id){
        $subscribe_info = self::getUserSubscribes($uid);
        //没关注
        if($subscribe_info->isNotEmpty() &&
            $subscribe_info->search(function ($item,$k)use ($send_order_id) {  return $item->send_order_id == $send_order_id;}) !== false ){
            return ['is_subscribed'=>true,'appid'=>''];
        }
        $subscribe_appdis = $subscribe_info->pluck('appid')->all();
        echo '$subscribe_appdis'.PHP_EOL;
        print_r($subscribe_appdis);
        $useable_appdis = self::getOfficialAccount($distribution_channel_id);
        echo '$useable_appdis'.PHP_EOL;
        print_r($useable_appdis);
        //没有可用的公众号
        if(empty($useable_appdis)) return ['is_subscribed'=>true,'appid'=>''];
        echo '2222222222222222222222'.PHP_EOL;
        $appids = collect($useable_appdis)->diff($subscribe_appdis)->toArray();
        if($appids){
            echo '33333333333333333333'.PHP_EOL;
            return ['is_subscribed'=>false,'appid'=>$appids[0]];
        }
        return ['is_subscribed'=>true,'appid'=>''];
    }

    //用户强关公众号
    public static function getUserSubscribes($uid){
       return  ForceSubscribeUsers::where('uid',$uid)->where('is_subscribed',1)->select('appid','send_order_id')->get();
    }

    //可用公众号
    public static function getOfficialAccount($distribution_channel_id){
        $result =  OfficialAccount::where('distribution_channel_id',$distribution_channel_id)
            ->where('is_auth',1)
            ->where('is_enabled',1)
            ->where('subscribe_top_num','>',0)
            ->where('subscribe_day_maximum','>',0)
            ->orderBy('sort_no', 'desc')
            ->select('appid','subscribe_top_num','subscribe_day_maximum')
            ->get();
        if($result->isEmpty()) return [];
        $data = [];
        foreach ($result as $value){
            $fans_stats = self::getOfficialAccountFanStats($value->appid);
            {
                $fans_stats['day_fans'] < $value->subscribe_day_maximum
                && $fans_stats['all_fans'] < $value->subscribe_top_num && array_push($data,$value->appid);
            }
        }
        return $data;
    }

    //粉丝数
    public static function getOfficialAccountFanStats($appid){
        $total_fans_cancel_nums = (int)Redis::hget('day_appid_fans_nums_appid:cancel:' . $appid, 'total');

        $total_fan_info = Redis::hmget('day_appid_fans_nums_appid:add:' . $appid,['total',date('Y-m-d')]);
        $total_fans_add_nums = $total_fan_info[0]?$total_fan_info[0]:0;
        $day_fans = $total_fan_info[1]?$total_fan_info[1]:0;
        $all_fans = $total_fans_add_nums - $total_fans_cancel_nums;
        return compact('day_fans','all_fans');
    }

    public static function getForceSubscribeByUidOpenid($uid) {
        $user_info = UserService::getById($uid);
        if($user_info) {
           $force_subs_info = ForceSubscribeUsers::where('openid',$user_info->openid)->orderBy('id','asc')->first();
           return $force_subs_info;
        }
        return false;
    }
}