wangdu_wechat/app/Modules/Channel/Services/ChannelService.php

<?php
/**
 * Created by PhpStorm.
 * User: hp
 * Date: 2017/12/2
 * Time: 15:56
 */

namespace App\Modules\Channel\Services;

use App\Modules\OfficialAccount\Models\DistributionSelfDefineConfig;

use App\Modules\Channel\Models\Channel;
use App\Modules\Finance\Services\FinanceService;
use App\Modules\SendOrder\Services\SendOrderService;
use App\Modules\Trade\Services\PayMerchantService;
use DB;

class ChannelService
{
    /**
     * 获取所有渠道
     * @param array $params
     * @return mixed
     */
    static function getAllChannels($params = [])
    {
        return Channel::getAllChannels($params);
    }

    /**
     * 根据手机号码获取
     * @return mixed
     */
    static function getByPhone($phone)
    {
        return Channel::getByPhone($phone);
    }

    /**
     * 根据名称获取id
     * @param $nickName
     * @return mixed
     */
    static function getIdByNickName($nickName)
    {
        return Channel::getIdByNickName($nickName);
    }

    /**
     * 根据账号ID获取渠道列表
     * @return mixed
     */
    static function getByChannelUserId($channel_user_id)
    {
        return Channel::getByChannelUserId($channel_user_id);
    }
    
    /**
     * 删除站点
     * @param unknown_type $distribution_channel_id
     * @param unknown_type $channel_user_id
     */
    static function deleteChannel($distribution_channel_id, $channel_user_id)
    {
    	return Channel::deleteChannel($distribution_channel_id, $channel_user_id);
    }
    

    /**
     * 根据渠道id获取
     * @return mixed
     */
    static function getById($id)
    {
        return Channel::getById($id);
    }

    /**
     * 根据渠道id获取渠道名称
     * @return mixed
     */
    static function getChannelNameById($id)
    {
        if (empty($id)) {
            return '';
        }
        return Channel::getChannelNameById($id);
    }

    /**
     * 根据渠道id获取渠道用户id
     * @return mixed
     */
    static function getUserIdById($id)
    {
        if (empty($id)) {
            return 0;
        }
        return Channel::getUserIdById($id);
    }


    /**
     * 根据渠道id获取渠道昵称
     * @param $id
     * @return string
     */
    static function getChannelNicknameById($id)
    {
        if (empty($id)) {
            return "";
        }
        $result = Channel::getChannelNicknameById($id);
        if (empty($result)) {
            return "";
        }
        return $result['nickname'];
    }
    /**
     * 根据渠道id获取渠道昵称
     * @param $id
     * @return string
     */
    static function getChannelCompanyNameById($id)
    {
        if (empty($id)) {
            return "";
        }
        $result = Channel::getChannelCompanyNameById($id);

        return $result;
    }

    /**
     * 获取渠道对应的支付渠道
     * @param $id
     * @return string
     */
    static function getChannelBankSourceById($id)
    {
        //TODO 获取渠道对应的支付渠道
        $channel = self::getById($id);
        if (!empty($channel) && $channel['pay_merchant_id'] > 0) {
            $payMerchant = PayMerchantService::getPayMerchantSingle($channel['pay_merchant_id']);
            if (!empty($payMerchant) && !empty($payMerchant['source'])) {
                return $payMerchant['source'];
            }
        }
        return config('common.tonglianpay');
    }

    /**
     * 创建渠道
     * @param  array $params ['password','name','pay_type','nickname','latest_login_ip','latest_login_time','remark','register_ip','channel_user_id']
     * @return object
     */
    static function createChannel($params)
    {
        return Channel::createChannel($params);
    }

    /**
     * 获取渠道统计数据
     */
    static function getChannelData()
    {
        //获取所有的渠道
        $channels = Channel::getAllChannels();
        //获取所有渠道账户余额总额(可提现金额总额)
        $avaliableBalanceAll = FinanceService::getChannelAccountBalanceAll();
        //所有充值总则
//        $chargeAllAmount = TradeSevices::getChannelPriceCountAll();
        if (empty($channels)) {
            foreach ($channels as $channelItem) {
                $channelId = $channelItem->id;
                //获取渠道下的账户余额
                $channelAvaliableBalance = FinanceService::getChannelAccountBalance($channelId);
                //获取渠道下的充值总额
//                $channelChargeAllAmount = Trade::getChannelPriceCountSingle($channelId);
                //获取渠道下的总派单数
                $sendOrderCount = SendOrderService::getPromotionCountByChannelId($channelId);
            }
        }
    }


    /**
     * 修改渠道密码
     * @param  string $phone 手机号码
     * @param  string $password 加密后密码
     * @return boolen
     */
    static function modifyPassword($phone, $password)
    {
        return Channel::modifyPassword($phone, $password);
    }

    /**
     * 获取渠道列表
     * @param $id 渠道ID
     * @param $params []
     *                  name:渠道名称 可选
     *                  nickname:渠道昵称 可选
     *                  pay_merchant_id: 支付通道 可选
     *                  distribution_manages_id: 管理员 可选
     *                  phone:电话 可选
     *                  person_in_charge_name:负责人 可选
     *                  remark:备注 可选
     *                  is_enabled: 是否开通 0:未审核； 1:审核通过
     * @return mixed
     */
    public static function updateChannelData($id, $params = [])
    {
        return Channel::updateChannelData($id, $params);
    }

    /**
     * 获取渠道列表
     * @param $params []
     *                  channel_id:渠道ID 可选
     *                  channel_name:渠道名称 可选
     *                  search_name: 搜索名称
     *                  start_date:开始时间 可选
     *                  end_date:结束时间 可选
     *                  is_enabled: 是否开通 0:未审核； 1:审核通过
     *                  distribution_manages_id: 管理员 可选
     * @param $isAll
     * @return mixed
     */
    public static function getChannelList($params = [], $isAll = '')
    {
        return Channel::getChannelList($params, $isAll);
    }

    /**
     * 获取当前渠道经理下所有渠道ID
     * @param $distribution_manages_id
     * @return mixed
     */
    public static function getChannelIdList($distribution_manages_id = '')
    {
        return Channel::getChannelIdList($distribution_manages_id);
    }

    public static function getSourceName($source)
    {
        if (config('common.tonglianpay') == $source) {
            return "通联支付";

        } else if (config('common.lianlianpay') == $source) {
            return "连连支付";

        } else if (config('common.officialpay') == $source) {
            return "官方支付";

        }
        return "";
    }

    static function getDefault($channel_user_id)
    {
        return Channel::getDefault($channel_user_id);
    }

    /**
     * 通过渠道ID、用户ID获取渠道
     */
    static function getUserChannel($distribution_channle_id, $channel_user_id)
    {
        return Channel::getUserChannel($distribution_channle_id, $channel_user_id);
    }

    /**
     * 获取用户下所有渠道ID
     * @param $channel_user_id
     */
    static function getUserChannelIds($channel_user_id)
    {
        return Channel::getUserChannelIds($channel_user_id);
    }

    static function getUserChannelIdsV2($channel_user_id)
    {
        return Channel::where('channel_user_id', $channel_user_id)->get()->pluck('id')->toArray();
    }

    /**
     * 设置站点别名
     */
    static function setChannelSiteNickName($distribution_channle_id, $nick_name)
    {
        return Channel::where('id', $distribution_channle_id)->update(['site_nick_name' => $nick_name]);
    }

    /**
     * 通过DistributionManagesId获取
     */
    static function getByDistributionManagesId($distribution_manage_id)
    {
        return Channel::getByDistributionManagesId($distribution_manage_id);
    }
    
    /**
     * 更新外站开关
     * @return mixed
     */
    static function updateDistributionOuterSiteSwitch($distribution_channel_id,$status)
    {
    	return Channel::updateDistributionOuterSiteSwitch($distribution_channel_id,$status);
    }
    
    /**
     * 更新老年站点开关
     * @return mixed
     */
    static function updateDistributionOldUserSiteSwitch($distribution_channel_id,$status)
    {
    	return Channel::updateDistributionOldUserSiteSwitch($distribution_channel_id,$status);
    }
    
    
    /**
     * 获取渠道信息
     * @return mixed
     */
    static function getDistributionChannel($distribution_channel_id)
    {
    	return Channel::getDistributionChannel($distribution_channel_id);
    }
    
    /**
     * 获取渠道信息
     * @return mixed
     */
    static function getDistributionChannelSwitchByCategory($distribution_channel_id,$category)
    {
    	return DistributionSelfDefineConfig::getDistributionSelfDefineConfig($distribution_channel_id,$category);
    }
    
    /**
     * 获取渠道信息
     * @return mixed
     */
    static function getDistributionChannelSwitchByCategoryAndCompany($company_id,$category)
    {
    	return DistributionSelfDefineConfig::getDistributionChannelSwitchByCategoryAndCompany($company_id,$category);
    }
    
    // 判断渠道的某个分类的 按照公司的权限
    static function check_channel_company_priv($distribution_channel_id,$category){
    	$distribution = self::getDistributionChannel($distribution_channel_id);
    	$channel_user_id = isset($distribution->channel_user_id)?$distribution->channel_user_id:'';
    	$channel_user = ChannelUserService::getById($channel_user_id);
    	$company_id = isset($channel_user->company_id)?$channel_user->company_id:'';
    	 
    	\Log::info('check_channel_company_priv:category:'.$category.' distribution_channel_id:'.$distribution_channel_id.' channel_user_id:'.$channel_user_id.' company_id:'.$company_id);
    	return self::getDistributionChannelSwitchByCategoryAndCompany($company_id,$category);
    }
    
    // 判断渠道的某个分类的 按照登录账号的权限
    static function check_channel_account_priv($distribution_channel_id,$category){
    	$distribution = self::getDistributionChannel($distribution_channel_id);
    	$channel_user_id = isset($distribution->channel_user_id)?$distribution->channel_user_id:'';
    	$channel_user = ChannelUserService::getById($channel_user_id);
    	$account = isset($channel_user->phone)?$channel_user->phone:'';
    
    	\Log::info('check_channel_company_priv:category:'.$category.' distribution_channel_id:'.$distribution_channel_id.' channel_user_id:'.$channel_user_id.' account:'.$account);
    	return self::getDistributionChannelSwitchByCategoryAndAccount($account,$category);
    }
    
    static function getDistributionChannelSwitchByCategoryAndAccount($account,$category)
    {
    	return DistributionSelfDefineConfig::getDistributionChannelSwitchByCategoryAndAccount($account,$category);
    }
    
    /**
     * 根据站点属性，转换对应的回复链接
     */
    static function convertChannelReplyUrl($is_outer_site,$appid,$openid,$content,$fromwhere='',$keyword='')
    {
    	if(!$is_outer_site) return $content;
    	$matchs = [];
    	$from_where_str = '&fromwhere='.$fromwhere;
        if ($keyword) $keyword = '&fromtype='.$keyword;
    	\Log::Info('convertChannelReplyUrl_before:appid'.$appid.' openid:'.$openid.' is_outer_site:'.$is_outer_site.' fromwhere:'.$fromwhere);
    	$new_content = $content;
//     	\Log::Info('$content');\Log::Info($content);
    	// 图文模式
    	if(is_array($new_content)){
    		foreach ($new_content as $key=>$one_content){
    			if(isset($new_content[$key]['url']) && !empty($new_content[$key]['url'])){
    				if(strpos($new_content[$key]['url'],'?') > -1){
    					$new_content[$key]['url'] = $new_content[$key]['url'].'&appid='.$appid.'&openid='.$openid.$from_where_str;
    				}else{
    					$new_content[$key]['url'] = $new_content[$key]['url'].'?appid='.$appid.'&openid='.$openid.$from_where_str;
    				}
    			}
    		}
    	}
    	// 文字模式
    	else{
//     		preg_match_all('/href=\"(.*)\"/u', $content, $matchs1);
//     		$matchs1 = isset($matchs1[1])?$matchs1[1]:[];
//     		preg_match_all('/href=\'(.*)\'/u', $content, $matchs2);
//     		$matchs2 = isset($matchs2[1])?$matchs2[1]:[];
//     		$matchs_all = array_merge($matchs1,$matchs2);
    		
    		// 
    		preg_match_all("/<a(s*[^>]+s*)href=([\"|']?)([^\"'>\s]+)([\"|']?)/ies",$content,$matchs);
    		$matchs_all = isset($matchs[3])?$matchs[3]:[];
    		\Log::info('$matchs_all');\Log::info($matchs_all);
    		
    		if(!empty($matchs_all)){
    			foreach($matchs_all as $match){
    				$match = str_replace(array('\r','\n'),"",$match);// 兼容换行
    				$match = trim($match);
    				$new_url = $url  = $match;
    				 
    				if(strpos($url,'?') > -1){
    					$new_url = $url.'&appid='.$appid.'&openid='.$openid.$from_where_str.$keyword;
    				}else{
    					$new_url = $url.'?appid='.$appid.'&openid='.$openid.$from_where_str.$keyword;
    				}
    				// 小链接可能多次被替换，所以一定要引号结尾
    				$new_content = str_replace($url.'\n"',$new_url.'"',$new_content);
    				$new_content = str_replace($url."\n'",$new_url."'",$new_content);
    				$new_content = str_replace($url.'"',$new_url.'"',$new_content);
    				$new_content = str_replace($url."'",$new_url."'",$new_content);
    			}
    		}
    	}
    	
    	\Log::Info('convertChannelReplyUrl_after:appid'.$appid.' openid:'.$openid);
    	\Log::Info('$new_content');\Log::Info($new_content);
    	return $new_content;
    }

    static function getContentByUrl($url)
    {
        $ch = curl_init();
        $timeout = 10; // set to zero for no timeout
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/34.0.1847.131 Safari/537.36');
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
        $html = curl_exec($ch);
        return $html;
    }

    public static function getChannelCompanyInfo($distribution_channel_id){
        return Channel::select(DB::raw("companies.*"))
            ->leftjoin('channel_users','channel_users.id','=','distribution_channels.channel_user_id')
            ->leftjoin('companies','companies.id','=','channel_users.company_id')
            ->where('distribution_channels.id',$distribution_channel_id)
            ->first();
    }
    
    public static function getChannelCompanySex($distribution_channel_id){
    	$company =  Channel::select(DB::raw("companies.*"))
    	->leftjoin('channel_users','channel_users.id','=','distribution_channels.channel_user_id')
    	->leftjoin('companies','companies.id','=','channel_users.company_id')
    	->where('distribution_channels.id',$distribution_channel_id)
    	->first();
    	// 1男 2女 3混合
    	$sex = isset($company->fans_gender)?$company->fans_gender:'3';
    	return $sex;
    }

}