common.php 13.6 KB
<?php

/**
 * 首字母排序A-Z(含汉字)
 */

use app\admin\model\User;
use app\api\controller\v1\WxxcxPush;

if (!function_exists('getFirstChar')) {
    function getFirstChar($s)
    {
        $s0 = mb_substr($s, 0, 1); //获取名字的姓
        $s = iconv('UTF-8', 'gb2312', $s0); //将UTF-8转换成GB2312编码
//var_dump(ord($s0));
//     var_dump(ord($s));
        if (ord($s0) > 128) { //汉字开头,汉字没有以U、V开头的

            $asc = ord($s{0}) * 256 + ord($s{1}) - 65536;
            if ($asc >= -20319 and $asc <= -20284) return "A";
            if ($asc >= -20283 and $asc <= -19776) return "B";
            if ($asc >= -19775 and $asc <= -19219) return "C";
            if ($asc >= -19218 and $asc <= -18711) return "D";
            if ($asc >= -18710 and $asc <= -18527) return "E";
            if ($asc >= -18526 and $asc <= -18240) return "F";
            if ($asc >= -18239 and $asc <= -17760) return "G";
            if ($asc >= -17759 and $asc <= -17248) return "H";
            if ($asc >= -17247 and $asc <= -17418) return "I";
            if ($asc >= -17417 and $asc <= -16475) return "J";
            if ($asc >= -16474 and $asc <= -16213) return "K";
            if ($asc >= -16212 and $asc <= -15641) return "L";
            if ($asc >= -15640 and $asc <= -15166) return "M";
            if ($asc >= -15165 and $asc <= -14923) return "N";
            if ($asc >= -14922 and $asc <= -14915) return "O";
            if ($asc >= -14914 and $asc <= -14631) return "P";
            if ($asc >= -14630 and $asc <= -14150) return "Q";
            if ($asc >= -14149 and $asc <= -14091) return "R";
            if ($asc >= -14090 and $asc <= -13319) return "S";
            if ($asc >= -13318 and $asc <= -12839) return "T";
            if ($asc >= -12838 and $asc <= -12557) return "W";
            if ($asc >= -12556 and $asc <= -11848) return "X";
            if ($asc >= -11847 and $asc <= -11056) return "Y";
            if ($asc >= -11055 and $asc <= -10247) return "Z";
        } else if (ord($s) >= 48 && ord($s) <= 57) {//数字开头
            $aa = @iconv_substr($s, 0, 1, 'utf-8');
            switch ($aa) {
                case 1:
                    return "Y";
                case 2:
                    return "E";
                case 3:
                    return "S";
                case 4:
                    return "S";
                case 5:
                    return "W";
                case 6:
                    return "L";
                case 7:
                    return "Q";
                case 8:
                    return "B";
                case 9:
                    return "J";
                case 0:
                    return "L";
            }
        } else if (ord($s) >= 65 && ord($s) <= 90) { //大写英文开头
            return substr($s, 0, 1);
        } else if (ord($s) >= 97 && ord($s) <= 122) { //小写英文开头
            return strtoupper(substr($s, 0, 1));
        } else {
            return iconv_substr($s0, 0, 1, 'utf-8');
//中英混合的词语,不适合上面的各种情况,因此直接提取首个字符即可
        }
    }
}
if (!function_exists('http_request')) {
// curl请求
    function http_request($url, $timeout = 30, $header = array())
    {
        if (!function_exists('curl_init')) {
            throw new Exception('server not install curl');
        }
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HEADER, true);
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
        if (!empty($header)) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        }
        $data = curl_exec($ch);
        list($header, $data) = explode("\r\n\r\n", $data);
        $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        if ($http_code == 301 || $http_code == 302) {
            $matches = array();
            preg_match('/Location:(.*?)\n/', $header, $matches);
            $url = trim(array_pop($matches));
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_HEADER, false);
            $data = curl_exec($ch);
        }

        if ($data == false) {
            curl_close($ch);
        }
        @curl_close($ch);

        return $data;
    }
}

if (!function_exists('insert_openid_info')) {
    /**
     * 将授权用户信息保存起来
     */
    function insert_openid_info($data)
    {
        $data['upt_time'] = time();
        $res = \think\Db::name("openid_info")->where("openid", $data['openid'])->find();
//        file_put_contents("ccc.txt", date("Y-m-d H:i:s") . json_encode($data) . PHP_EOL, FILE_APPEND);
        if (!empty($res)) {
            \think\Db::name("openid_info")->where("openid", $data['openid'])->update($data);
        } else {
            \think\Db::name("openid_info")->insertGetId($data);
        }
        return true;
    }
}
/**
 * 生成订单号
 * 重复就重新生成
 */
if (!function_exists('getOrderSn')) {
    function getOrderSn()
    {
        $orderid = date("YmdHis") . mt_rand(1000, 999999);
        $odcks = \think\Db::name('order')
            ->where(['order_no' => $orderid])
            ->find();
        while (!empty($odcks)) {
            $orderid = date("YmdHis") . mt_rand(1000, 999999);
        }
        return $orderid;
    }
}

    if(!function_exists('beingPushed')){
        /**
         * 发送模板消息
         * @return void
         * @throws \think\db\exception\DataNotFoundException
         * @throws \think\db\exception\ModelNotFoundException
         * @throws \think\exception\DbException
         */
         function SendMessage($order_id){
            $order=\think\Db::name("order")->find($order_id);
            $wxxcxpush=new WxxcxPush();
            $user=new User();
            $user=$user->find($order['user_id']);
            $res=$wxxcxpush->Message($user['wx_xcx_openid'],$order_id);
            if ($res !== false) {
                return $res;
            }
        }
    }


if (!function_exists('beingPushed')) {
    /**
     * 小程序模板推送选择类型
     * @param $type @模板类型
     * @param $openid @接收人ID
     * @param $page @跳转页面
     * @param $temp @具体提醒参数
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    function beingPushed($type, $openid, $page, $temp)
    {

        $data = [];
        $data['touser'] = $openid;
        $data['page'] = $page;
        //模板内容,格式形如 { "key1": { "value": any }, "key2": { "value": any } }
        switch ($type) {
            case 1:
                //待审批事项提醒(新版本的长期订阅)
                $data['template_id'] = "ws6bz6-WyHHA-upU2oRzc_C5toDUexe9ZicQ-ITtImA";
                $data['data'] = [
                    "thing10" => [
                        'value' =>$temp['value1'],//审核状态(待处理)
                    ],
                    "thing12" => [
                        'value' => $temp['value2'],//申请人(测试黄超)
                    ],

                    "thing8" => [
                        'value' => $temp['value3'],//原因(入州报备审核)
                    ]
                ];
                break;
            case 2:
                //审核结果通知(新版本的长期订阅)
                $data['template_id'] = "Qt2xqfH8uQyTm1A0ReNxeybtAydAhfhi4HinnyB5f0s";
                $data['data'] = [
                    "thing1" => [
                        'value' => $temp['value1'],//提醒内容(已审核)
                    ],
//                    "name1" => [
//                        'value' => $temp['value2'],//审核人
//                    ],
                    "thing4" => [
                        'value' => $temp['value3'],//提示说明
                    ]
                ];
                break;
            case 3:
                //待审批事项提醒(老版本的一次性订阅)
                $data['template_id'] = "vVOonN76AFjxgz77iG-hcWrH6HJ-vPGKyIyAK0VzPIk";
                $data['data'] = [
                    "thing1" => [
                        'value' => $temp['value1'],//待办事项
                    ],
                    "thing4" => [
                        'value' => $temp['value2'],//流程状态
                    ],
                    "thing2" => [
                        'value' => $temp['value3'],//申请人
                    ],
                    "time3" => [
                        'value' => $temp['value4'],//申请时间
                    ],
                    "thing5" => [
                        'value' => $temp['value5'],//备注描述
                    ]
                ];
                break;
            case 4:
                //审核结果通知(老版本的一次性订阅)
                $data['template_id'] = "yJRK0DZFuEPqaWwyS0DegT0r2p5be0bm2eE59oroGME";
                $data['data'] = [
                    "phrase2" => [
                        'value' => $temp['value1'],//审核结果
                    ],
                    "name1" => [
                        'value' => $temp['value2'],//审核人
                    ],
                    "date4" => [
                        'value' => $temp['value3'],//审批时间
                    ]
                ];
                break;
            case 5:
                //预约结果通知
                $data['template_id'] = "oczyQ_SabASMQRRhDedXRGUEzCAuGh1xBw8sp2HVPvQ";
                $data['data'] = [
                    "thing1" => [
                        'value' => $temp['value1'],//备注
                    ],
                    "thing2" => [
                        'value' =>$temp['value2'],//日期
                    ],
                    "number3" => [
                        'value' => $temp['value3'],//就诊人
                    ],
                    "time4" => [
                        'value' => $temp['value4'],//就诊人
                    ],
                    "thing6" => [
                        'value' => $temp['value5'],//就诊人
                    ]
                ];
                break;
        }

        return sendSubscribeMessage($data);
    }
}

if (!function_exists('sendSubscribeMessage')) {
    /**
     * 小程序订阅消息推送
     * @param $data
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    function sendSubscribeMessage($data)
    {
        //access_token
        $access_token = getAccessToken();

        //请求url
        $url = 'https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=' . $access_token;

        //file_put_contents('notify.txt',$data.PHP_EOL,FILE_APPEND);
        //跳转小程序类型:developer为开发版;trial为体验版;formal为正式版;默认为正式版
        $data['miniprogram_state'] = 'formal';

        return curlPost($url, json_encode($data));
    }
}

if (!function_exists('getAccessToken')) {
    /**
     * 获取access_token
     * @return mixed
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    function getAccessToken()
    {
        $wx_xcx_token = \think\Db::name("wechat_token")->where("type", "wx_xcx")->find();
        if (empty($wx_xcx_token) || empty($wx_xcx_token['access_token']) || $wx_xcx_token['over_time'] <= time()) {
            //微信小程序失效
            //当前时间戳
            $now_time = strtotime(date('Y-m-d H:i:s', time()));

            //获取新的access_token
            $appid = config("site.wxxcx_AppID");
            $secret = config("site.wxxcx_AppSecret");
            $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" . $appid . "&secret=" . $secret;
            $res = json_decode(file_get_contents($url), true);

            $access_token = $res['access_token'];
            if (!empty($access_token)) {
                $time = time();
                $update_data = [
                    "access_token" => $access_token,
                    "over_time" => $time + 7200,
                    "type" => "wx_xcx",
                    "updatetime" => $time
                ];
                if (!empty($wx_xcx_token)) {
                    //更新
                    \think\Db::name("wechat_token")->where("id", $wx_xcx_token['id'])->update($update_data);
                } else {
                    //新增
                    \think\Db::name("wechat_token")->insertGetId($update_data);
                }
            }
        } else {
            $access_token = $wx_xcx_token['access_token'];
        }
        return $access_token;
    }
}

if (!function_exists('curlPost')) {
    /**
     * 发送post请求
     */
    function curlPost($url, $data)
    {
        $ch = curl_init();
        $params[CURLOPT_URL] = $url;    //请求url地址
        $params[CURLOPT_HEADER] = FALSE; //是否返回响应头信息
        $params[CURLOPT_SSL_VERIFYPEER] = false;
        $params[CURLOPT_SSL_VERIFYHOST] = false;
        $params[CURLOPT_RETURNTRANSFER] = true; //是否将结果返回
        $params[CURLOPT_POST] = true;
        $params[CURLOPT_POSTFIELDS] = $data;
        curl_setopt_array($ch, $params); //传入curl参数
        $content = curl_exec($ch); //执行
//    file_put_contents('notify.txt', $content . date('Y-m-d H:i:s', time()) . PHP_EOL, FILE_APPEND);
        curl_close($ch); //关闭连接
        return $content;
    }
}

if (!function_exists('array_callback')) {
    /**
     * 20190729 kevin
     * 规范数据返回函数
     * @param unknown $state
     * @param unknown $msg
     * @param unknown $data
     * @return multitype:unknown
     */
    function array_callback($state = true, $msg = '', $data = array())
    {
        return array('state' => $state, 'msg' => $msg, 'data' => $data);
    }
}