webman-admin修改进入后台默认路由 PHP
默认进入后台为 /app/admin
修改其他复杂入口,例如 /app/abc3ksncvl
项目配置 config/route.php 里添加
use plugin\admin\app\controller\IndexController;
Route::any('/abc3ksncvl', [IndexController::class, 'index']);
webman/push 统计在线人数 PHP
自定义进程定时获取在线人数广播给所有在线用户
process/Status.php
<?php
namespace process;
use app\Request;
use Webman\Push\Api;
use Workerman\Timer;
use Workerman\Worker;
use think\facade\Db;
class Status
{
public function __construct()
{
Timer::add(3, function () {
$this->status();
});
}
public function status()
{
static $user_count = 0, $page_count = 0;
$api = new Api(
'http://127.0.0.1:3232',
config('plugin.webman.push.app.app_key'),
config('plugin.webman.push.app.app_secret')
);
$result = $api->get('/channels', ['filter_by_prefix' => 'user', 'info' => 'subscription_count']);
if (!$result || $result['status'] != 200) {
return;
}
$channels = $result['result']['channels'];
$user_count_now = count($channels);
$page_count_now = 0;
foreach ($channels as $channel) {
$page_count_now += $channel['subscription_count'];
}
if ($page_count_now == $page_count && $user_count_now === $user_count) {
return;
}
$user_count = $user_count_now;
$page_count = $page_count_now;
$api->trigger('online-page', 'update_online_status', "当前<b>$user_count</b>人在线,共打开<b>$page_count</b>个页面");
}
}
自定义进程配置文件
config/process.php
<?php
use Workerman\Worker;
return [
// ...其它配置...
'status' => [
'handler' => process\Status::class
]
];
前端js代码
var connection = new Push({
url: 'wss://xxx.com',
app_key: 'xxxx',
});
function update_online_status(status) {
$('#online_status').html(status);
}
var online_channel = connection.subscribe('online-page');
online_channel.on('update_online_status', update_online_status);
var user_channel = connection.subscribe('user-<?=session()->getId()?>');
user_channel.on('update_online_status', update_online_status);
以上是实现类似workerman站点底部实时在线统计的代码
微擎企业付款到用户 PHP
public function sendMoney($openid, $money, $re_user_name = '', $desc = '', $trade_no = '')
{
global $_W;
$paysetting = uni_setting($_W['uniacid'], array('payment'));
$wechatpay = $paysetting['payment']['wechat'];
$account_info = $_W['account'];
$mchid = $wechatpay['mchid'];
$key = $wechatpay['apikey'];
$appid = $account_info['key'];
$desc = isset($desc) ? $desc : '余额提现';
$money = $money * 100;
$pars = array();
$pars['mch_appid'] = $appid;
$pars['mchid'] = $mchid;
$pars['nonce_str'] = random(32);
$pars['partner_trade_no'] = empty($trade_no) ? $mchid . date('Ymd') . rand(1000000000, 9999999999) : $trade_no;
$pars['openid'] = $openid;
if (empty($re_user_name)) {
$pars['check_name'] = 'NO_CHECK';
} else {
$pars['check_name'] = 'FORCE_CHECK';
$pars['re_user_name'] = $re_user_name;
}
// NO_CHECK:不校验真实姓名
// FORCE_CHECK:强校验真实姓名(未实名认证的用户会校验失败,无法转账)
// OPTION_CHECK:针对已实名认证的用户才校验真实姓名(未实名认证用户不校验,可以转账成功)
$pars['amount'] = $money;
$pars['desc'] = $desc;
// $pars['spbill_create_ip'] = isset($wechat['ip']) ? $wechat['ip'] : $_SERVER['SERVER_ADDR'];
$pars['spbill_create_ip'] = gethostbyname($_SERVER["SERVER_NAME"]);
// $pars['spbill_create_ip'] = $_SERVER['SERVER_ADDR'];
ksort($pars, SORT_STRING);
$string1 = '';
foreach ($pars as $k => $v) {
$string1 .= "{$k}={$v}&";
}
$string1 .= "key={$key}";
$pars['sign'] = strtoupper(md5($string1));
$xml = array2xml($pars);
$extras = array();
$path_cert = IA_ROOT . '/addons/weisrc_dish/cert/apiclient_cert_' . $_W['uniacid'] . '.pem';
$path_key = IA_ROOT . '/addons/weisrc_dish/cert/apiclient_key_' . $_W['uniacid'] . '.pem';
$path_rootca = IA_ROOT . '/addons/weisrc_dish/cert/rootca_' . $_W['uniacid'] . '.pem';
$extras['CURLOPT_CAINFO'] = $path_rootca;
$extras['CURLOPT_SSLCERT'] = $path_cert;
$extras['CURLOPT_SSLKEY'] = $path_key;
load()->func('communication');
$procResult = null;
$url = "https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers";
$response = ihttp_request($url, $xml, $extras);
if ($response['code'] == 200) {
$responseObj = simplexml_load_string($response['content'], 'SimpleXMLElement', LIBXML_NOCDATA);
$responseObj = (array)$responseObj;
$return['code'] = $responseObj['return_code'];
$return['result_code'] = $responseObj['result_code'];
$return['err_code'] = $responseObj['err_code'];
$return['msg'] = $responseObj['return_msg'];
$return['trade_no'] = $pars['partner_trade_no'];
$return['payment_no'] = $responseObj['payment_no'];
if ($responseObj['result_code'] != 'SUCCESS') {
print_r($responseObj);
exit;
}
return $return;
} else {
echo '证书错误:';
print_r($response);
exit;
}
}
//发放红包
public function sendRedPack($openid, $money, $send_name = '余额提现', $act_name = '余额提现', $wishing = '祝您生活愉快', $trade_no
= '')
{
global $_W;
$paysetting = uni_setting($_W['uniacid'], array('payment'));
$wechatpay = $paysetting['payment']['wechat'];
$account_info = $_W['account'];
$mchid = $wechatpay['mchid'];
$key = $wechatpay['apikey'];
$appid = $account_info['key'];
$money = $money * 100;
$num = 1;
$url = "https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack";
$pars = array();
$pars['wxappid'] = $appid;
$pars['mch_id'] = $mchid;
$pars['nonce_str'] = random(32);
$pars['mch_billno'] = empty($trade_no) ? $mchid . date('Ymd') . rand(1000000000, 9999999999) : $trade_no;
$pars['send_name'] = $send_name;
$pars['re_openid'] = $openid;
$pars['total_amount'] = $money;
$pars['total_num'] = $num;
$pars['wishing'] = $wishing;
// $pars['client_ip'] = isset($wechat['ip']) ? $wechat['ip'] : $_SERVER['SERVER_ADDR'];
$pars['client_ip'] = $_SERVER['SERVER_ADDR'];
$pars['act_name'] = $act_name;
$pars['remark'] = $act_name;
ksort($pars, SORT_STRING);
$string1 = '';
foreach ($pars as $k => $v) {
$string1 .= "{$k}={$v}&";
}
$string1 .= "key={$key}";
$pars['sign'] = strtoupper(md5($string1));
$xml = array2xml($pars);
$extras = array();
$path_cert = IA_ROOT . '/addons/weisrc_dish/cert/apiclient_cert_' . $_W['uniacid'] . '.pem';
$path_key = IA_ROOT . '/addons/weisrc_dish/cert/apiclient_key_' . $_W['uniacid'] . '.pem';
$path_rootca = IA_ROOT . '/addons/weisrc_dish/cert/rootca_' . $_W['uniacid'] . '.pem';
$extras['CURLOPT_CAINFO'] = $path_rootca;
$extras['CURLOPT_SSLCERT'] = $path_cert;
$extras['CURLOPT_SSLKEY'] = $path_key;
load()->func('communication');
$procResult = null;
$response = ihttp_request($url, $xml, $extras);
if ($response['code'] == 200) {
$responseObj = simplexml_load_string($response['content'], 'SimpleXMLElement', LIBXML_NOCDATA);
$responseObj = (array)$responseObj;
$return['code'] = $responseObj['return_code'];
$return['result_code'] = $responseObj['result_code'];
$return['err_code'] = $responseObj['err_code'];
$return['msg'] = $responseObj['return_msg'];
$return['trade_no'] = $pars['mch_billno']; //返回订单号 用于重试
return $return;
}
}
PHP 递归生成子级数据 PHP
public function doMobileWenzhang_cbt(){
global $_GPC,$_W;
$wzid=$_GPC['wzid'];
$wzinfo=pdo_get('huoban_wenzhang',array('id'=>$wzid));
//递归查询下级访问用户
$list=pdo_fetchall("select * from ".tablename('huoban_readers')." where `zhuafanum`=1 and wzid={$wzid} ");
foreach ($list as $k=>$v){
$list[$k]['childs']=$this->cbt_dgsj($v['openid'],$v['wzid']);
}
echo "<pre/>";
var_dump($list);die;
echo json_encode(array('list'=>$list));
}
function cbt_dgsj($openid,$wzid){
//echo "1<br/>";
//echo "<pre/>";
$xjlist=pdo_fetchall("select * from ".tablename('huoban_readers')." where fromuser='{$openid}' and wzid={$wzid} ");
//var_dump($xjlist);
if(!empty($xjlist)){
foreach ($xjlist as $k=>$v){
//var_dump($xjlist);
$res=$this->cbt_dgsj($v['openid'],$v['wzid']);
$xjlist[$k]['childs']=$res;
}
/*echo "1<br/><pre/>";
var_dump($xjlist);*/
return $xjlist;
}
//var_dump($list);die;
return $xjlist;
}
PHP 文件写入数组 PHP
文件写入函数
file_put_contents(file,data,mode,context)
参数 描述 file 必需。规定要写入数据的文件。如果文件不存在,则创建一个新文件。 data 可选。规定要写入文件的数据。可以是字符串、数组或数据流。 mode 可选。规定如何打开/写入文件。可能的值: FILE_USE_INCLUDE_PATH、FILE_APPEND、LOCK_EX 。context可选。规定文件句柄的环境。 context 是一套可以修改流的行为的选项。若使用 null,则忽略。
$arr = array(
'name'=>'张三'
)
$str = var_export($arr,TRUE);
file_put_contents($filename,$str);