szcollect_admin/application/common.php

<?php
use think\Db;
/**
 * 秒转换为天
 */
function get_stay_time($remain_time, $is_hour = 1, $is_minutes = 1)
{
    $day = floor($remain_time / (3600*24));
    $day = $day > 0 ? $day.'天' : '';
    $hour = floor(($remain_time % (3600*24)) / 3600);
    $hour = $hour > 0 ? $hour.'小时' : '';
    if($is_hour && $is_minutes) {
        $minutes = floor((($remain_time % (3600*24)) % 3600) / 60);
        $minutes = $minutes > 0 ? $minutes.'分钟' : '';
        return $day.$hour.$minutes;
    }

    if($hour) {
        return $day.$hour;
    }
    return $day;
}
//获取全图片地址 $image_data
function image_path($image_data){
    if(empty($image_data)){
        return $image_data;
    }
    if (strpos($image_data,'|')!==false){
        $image_res = explode('|',$image_data);
    }elseif(strpos($image_data,',')!==false){
        $image_res = explode(',',$image_data);
    }else{
        $image_res = array($image_data);
    }
    return $image_res;
}









// 获取模板区域
function get_city_area()
{
    $field=['id','pid','name'];
    $list=Db::table('store_area')->where('pid',0)->field($field)->select();
    foreach ($list as $k=>&$v){
        $v['children']= Db::table('store_area')->where('pid',$v['id'])->field($field)->select();
    }
    return $list;
}


function http_curl($url,$type='get',$res='json',$arr=''){

    $headers = array();
    //根据API的要求，定义相对应的Content-Type
    array_push($headers, "Content-Type".":"."application/x-www-form-urlencoded; charset=UTF-8;application/json");
    $curl = curl_init();
    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $type);
    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($curl, CURLOPT_FAILONERROR, false);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_HEADER, false);
    $output = curl_exec($curl);
    curl_close($curl);
    if($res=='json'){
        if($output === false){
            //请求失败，返回错误信息
            return curl_error($curl);
        }else{
            //请求成功，返回信息
            return json_decode($output,true);
        }
    }
}

// 获取物流信息
function get_delivery($send_no = 'JD0053309649641',$express_code=''){
        error_reporting(E_ALL || ~E_NOTICE);
        $AppKey     = 204008273;
        $AppSecret  ='t9PavvfCeK5v2XidwyK5pWDp8b0hzMq4';
        $AppCode    ='47f640e3529d43e28365311a530db2b7';//开通服务后 买家中心-查看AppCode
        $host = "https://wuliu.market.alicloudapi.com";//api访问链接
        $path = "/kdi";//API访问后缀
        $method = "GET";
        $body  ='';
        $headers = array();
        array_push($headers, "Authorization:APPCODE " . $AppCode);
        $querys = "no={$send_no}&type={$express_code}";  //参数写在这里
        $url = $host . $path . "?" . $querys;
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($curl, CURLOPT_FAILONERROR, false);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_HEADER, true);
        if (1 == strpos("$" . $host, "https://")) {
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        }
        $out_put = curl_exec($curl);
        $httpCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
        list($header, $body) = explode("\r\n\r\n", $out_put, 2);
        if ($httpCode == 200) {
            return json_decode($body,true)['result'];
        } else {
            return [];
        }
    }


// 元石日志
function crystal_log($user_id,$crystal,$desc,$type,$rel_id=0)
{
    $log_data = [
        'user_id' => $user_id,
        'create_at' => date('Y-m-d H:i:s'),
        'crystal' => $crystal,
        'desc' => $desc,
        'type' => $type,
        'rel_id' => $rel_id,
    ];
    Db::table('crystal_info')->insert($log_data);
}

/**
 * 判断是否为合法的身份证号码
 * @param $mobile
 * @return int
 */
function isCreditNo($vStr){
    $vCity = array(
        '11','12','13','14','15','21','22',
        '23','31','32','33','34','35','36',
        '37','41','42','43','44','45','46',
        '50','51','52','53','54','61','62',
        '63','64','65','71','81','82','91'
    );
    if (!preg_match('/^([\d]{17}[xX\d]|[\d]{15})$/', $vStr)) return false;
    if (!in_array(substr($vStr, 0, 2), $vCity)) return false;
    $vStr = preg_replace('/[xX]$/i', 'a', $vStr);
    $vLength = strlen($vStr);
    if ($vLength == 18) {
        $vBirthday = substr($vStr, 6, 4) . '-' . substr($vStr, 10, 2) . '-' . substr($vStr, 12, 2);
    } else {
        $vBirthday = '19' . substr($vStr, 6, 2) . '-' . substr($vStr, 8, 2) . '-' . substr($vStr, 10, 2);
    }
    if (date('Y-m-d', strtotime($vBirthday)) != $vBirthday) return false;
    if ($vLength == 18) {
        $vSum = 0;
        for ($i = 17 ; $i >= 0 ; $i--) {
            $vSubStr = substr($vStr, 17 - $i, 1);
            $vSum += (pow(2, $i) % 11) * (($vSubStr == 'a') ? 10 : intval($vSubStr , 11));
        }
        if($vSum % 11 != 1) return false;
    }
    return true;
}

// 实名认证
function user_certification($id_card,$name){
    $host = "http://checkone.market.alicloudapi.com";
    $path = "/chinadatapay/1882";
    $method = "POST";
    $appcode = "30be8bdcc65842919980a8276ffc4995";
    $headers = array();
    array_push($headers, "Authorization:APPCODE " . $appcode);
    //根据API的要求，定义相对应的Content-Type
    array_push($headers, "Content-Type".":"."application/x-www-form-urlencoded; charset=UTF-8");

    $bodys = "idcard=".$id_card."&name=".$name;
    $url = $host . $path;

    $curl = curl_init();
    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($curl, CURLOPT_FAILONERROR, false);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_HEADER, false);
    if (1 == strpos("$".$host, "https://"))
    {
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    }
    curl_setopt($curl, CURLOPT_POSTFIELDS, $bodys);
    $res = curl_exec($curl);
    dump($res);die;
    if($res){
        $res = json_decode($res,true);
        if($res['data']['result'] == 1){
           return 1;
        }else{
            return 0;
        }
    }else{
       return 0;
    }
}




function shoucang(){
    $host = "http://180.76.141.31:8888/cz/call";
    $method = "POST";
    $headers = array();
    array_push($headers, "Content-Type".":"."application/json; charset=UTF-8");
    $bodys = array(
        'key' => 'test2',
        'userkey' => '12344',
        'product' => json_encode(array('name'=>'test','count'=>7))
    );
    $curl = curl_init();
    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($curl, CURLOPT_URL, $host);
    curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($curl, CURLOPT_FAILONERROR, false);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_HEADER, false);
    if (1 == strpos("$".$host, "https://"))
    {
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    }
    curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($bodys));
    $res = curl_exec($curl);
    var_dump($res);exit();
}




/**
 * 获取大师提前分钟数
 */
function getAdvanceMinutes(){
    return   Db::name('system_config')->where('name','advance_minutes')->value('value');
}

/**
 * 获取自动取消分钟数
 */
function getCancelTime(){
    return Db::name('system_config')->where('name','cancel_time')->value('value');
}


/**
 * 用户信息存入redis hash
 */
function setMemberInfoHash($member_id){
    $info = Db::name('store_member')->where('id',$member_id)->find();
    $redis = new \think\cache\driver\Redis();
    $array = ['member'.$member_id=>json_encode($info)];
    $redis->hMSet('memberInfo',$array);
}


/**
 * redis获取用户信息
 */
function getMemberInfoHash($member_id){
    $redis = new \think\cache\driver\Redis();
    $info = $redis->hGet('memberInfo','member'.$member_id);
    if (!$info){
        $info = Db::name('store_member')->where('id',$member_id)->find();
        $array = ['member'.$member_id=>json_encode($info)];
        $redis->hMSet('memberInfo',$array);
    }else{
        $info = json_decode($info,true);
    }
    return $info;
}



/**
 * 用户抢购卡数量存入redis 字符串
 */
function setMembercard($member_id){
    $snap_card = Db::name('store_member')->where('id',$member_id)->value('snap_card');
    $redis = new \think\cache\driver\Redis();
    $redis->set('membercard_'.$member_id,$snap_card);
}

/**
 * 获取用户抢购卡数量
 */
function getMembercard($member_id){
    $redis = new \think\cache\driver\Redis();
    $count = $redis->get('membercard_'.$member_id);
    if (empty($count) && $count!=0){
        $count = Db::name('store_member')->where('id',$member_id)->value('snap_card');
        $redis->set('membercard_'.$member_id,$count);
    }
    return $count;
}

/**
 * 获取藏品库存
 */
function getCollectionInventory($id){
    $redis = new \think\cache\driver\Redis();
    $count = $redis->get('collection_count_'.$id);
    if (empty($count) && $count!=0){
        $count = Db::name('store_collection')->where('id',$id)->value('now_inventory');
        $redis->set('collection_count_'.$id,$count);
    }
    return $count;
}

/**
 * 减掉藏品库存
 */
function loseCollectionInventory($id,$num){
    $redis = new \think\cache\driver\Redis();
    $redis->Decrby('collection_count_'.$id,$num);
}

/**
 * 加藏品库存
 */
function addCollectionInventory($id,$num){
    $redis = new \think\cache\driver\Redis();
    $redis->Incrby('collection_count_'.$id,$num);
}


/**
 * 用户购买藏品排名更新
 */
function saveRanking($id){
    $redis = new \think\cache\driver\Redis();
    $redis->Incr('ranking'.$id);
}

/**
 * 获取用户购买藏品排名更新
 */
function getRanking($id){
    $redis = new \think\cache\driver\Redis();
    $count =  $redis->get('ranking'.$id);
    if (empty($count)){
        $redis->set('ranking'.$id,0);
    }
    $count = empty($count) ? 0 : $count;
    return $count;
}


/**
 * 藏品信息存入redis hash
 */
function setCollectionInfoHash($id){
    $info = Db::name('store_collection')->where('id',$id)->find();
    $redis = new \think\cache\driver\Redis();
    $array = ['collection'.$id=>json_encode($info)];
    $redis->hMSet('collectionInfo',$array);
}

/**
 * 获取藏品信息
 */
function getCollectionInfoHash($id)
{
    $redis = new \think\cache\driver\Redis();
    $info = $redis->hGet('collectionInfo','collection'.$id);
    if (!$info){
        $info = Db::name('store_collection')->where('id',$id)->find();
        $array = ['collection'.$id=>json_encode($info)];
        $redis->hMSet('collectionInfo',$array);
    }else{
        $info = json_decode($info,true);
    }
    return $info;
}

function retrunWxConfig(){
    $config = [
        'app_id' => 'wxa79190389d57c04b',
        'mch_id' =>'1623066512',
        'key' =>'qwertyuiopASDFGHJKLZXCVBNM123456',
       // 'sub_mch_id'=>'1612529165'
    ];

    return $config;
}

/**
 * 获取排名
 */
function getTag($id,$now,$num){
    $len = strlen($num);
    $re = 'XX'.$id.'#';
    switch ($len){
        case 1:
            $re = $re.'0'.$now;
            break;
        case 2:
            if ($now<10){
                $re = $re.'0'.$now;
            }else{
                $re = $re.$now;
            }
            break;
        case 3:
            if ($now<10){
                $re = $re.'00'.$now;
            }elseif ($now>=10 && $now<100){
                $re = $re.'0'.$now;
            }else{
                $re = $re.$now;
            }
            break;
        case 4:
            if ($now<10){
                $re = $re.'000'.$now;
            }elseif ($now>=10 && $now<100){
                $re = $re.'00'.$now;
            }elseif ($now>=100 && $now<1000){
                $re = $re.'0'.$now;
            }else{
                $re = $re.$now;
            }
            break;
        case 5:
            if ($now<10){
                $re = $re.'0000'.$now;
            }elseif ($now>=10 && $now<100){
                $re = $re.'000'.$now;
            }elseif ($now>=100 && $now<1000){
                $re = $re.'00'.$now;
            }elseif ($now>=1000 && $now<10000){
                $re = $re.'0'.$now;
            }else{
                $re = $re.$now;
            }
            break;
        case 6:
            if ($now<10){
                $re = $re.'00000'.$now;
            }elseif ($now>=10 && $now<100){
                $re = $re.'0000'.$now;
            }elseif ($now>=100 && $now<1000){
                $re = $re.'000'.$now;
            }elseif ($now>=1000 && $now<10000){
                $re = $re.'00'.$now;
            }elseif ($now>=10000 && $now<100000){
                $re = $re.'0'.$now;
            }else{
                $re = $re.$now;
            }
            break;
    }
    $re = $re.'/'.$num;
    return $re;
}

/**
 * 变更会员积分等
 * @param int $money    余额
 * @param int $user_id  会员ID
 * @param string $memo  备注
 */
function memberMoneyChange($num, $type , $m_id, $title, $pm = 0)
{
    $member = Db::name('store_member')->where('id',$m_id)->find();
    switch ($type){
        case 1:    //积分
            $before = $member['integral'];
            if ($pm==1)
                $after = $member['integral']+$num;
            else
                $after = $member['integral']-$num;

            $update_data = ['integral'=>$after];
            break;
        case 2:   //抢购卡
            $before = $member['snap_card'];
            if ($pm==1)
                $after = $member['snap_card']+$num;
            else
                $after = $member['snap_card']-$num;

            $update_data = ['snap_card'=>$after];
            break;
    }
    Db::startTrans();
    try {
        Db::name('store_member')->where('id',$m_id)->update($update_data);
        $data = [
            'm_id'=>$m_id,
            'type'=>$type,
            'pm'=>$pm,
            'title'=>$title,
            'change_money'=>$num,
            'before'=>$before,
            'after'=>$after
        ];
        Db::name('store_member_log')->insert($data);
        Db::commit();
        return true;
    }catch (\Exception $e){
        Db::rollback();
        return false;
    }
}