月度归档 2016年4月26日

今天把微擎的分销系统整合到独立开发的影院模块，进行了多项的测试，并且把测试的结果写起来：

过程是这样的，用户在独立开发的影院系统里进行下单，支付成功在回调的时候，调用分销数据的写入：

1：分销中心必须为开启状态；

2：分销的等级必须开启

在这顺便讨论下问题，如有三级分销A->B->C->D

如果开启的为三级，那么ABC都会获取对应的返佣规则（对于D来说，1级=C；2级=B；3级=A）；

假设佣金的规则为：1级10%；2级8%；3级5%；

D用户购买了100元的产品

A获取5元；B获取8元；C获取10元

由于订单是独立在影院系统的，所以需要同步写入一份订单数据到微擎的三级分销order即可！

附上一个扩展类库

直接调用get_shop_sysset()方法，并且带上需要的参数

class IPanYing{

/**
* 判断公众号数据是否对应，因为一个用户可以有多个公众号！权限判断！
* @param unknown $uniacid
* @param unknown $uid
* @return boolean
*/
private function get_uni_account_user($uniacid,$uid){
$sql=”SELECT * FROM `”.$this->pre.”uni_account_users` WHERE `uniacid`='”.(int)$uniacid.”‘ AND `uid`='”.(int)$uid.”‘”;
$data = $this->pdo->query($sql);
$data = $data->fetch(PDO::FETCH_ASSOC);
if (!empty($data)){
return true;
} else {
return false;
}
}

/**
* 获取当前公众号的plugins
* @param unknown $appid
* @return unknown
*/
private function get_ewei_shop_sysset($appid){
$sql = “SELECT plugins FROM `”.$this->pre.”ewei_shop_sysset` WHERE `uniacid` = ‘”.(int)$appid.”‘”;
$data = $this->pdo->query($sql);
$data = $data->fetch(PDO::FETCH_ASSOC);
return $data[‘plugins’];
}

/**
* 查看商家是否开启了公众号模块状
* @param unknown $appid
* @param unknown $uid
*/
private function get_rule($appid){
$sql = “SELECT * FROM `”.$this->pre.”rule` WHERE `uniacid` = ‘”.(int)$appid.”‘ AND `module`=’cover'”;
$data = $this->pdo->query($sql);
return $data->fetch(PDO::FETCH_ASSOC);
}

private $openid; #-记录当前的用户ID

/**
*
* @param unknown $appid #-公众号唯一ID
* @param unknown $uid #-商家的唯一ID
* @param unknown $openid #-发起订单的用户ID，私有成员不同
* @param unknown $money #-金额
* @param unknown $orders #-订单数据
*/
function get_shop_sysset($appid,$uid,$openid,$money,$orders){
if ($this->get_uni_account_user($appid, $uid)){ #-判断是否合法，即根据用户ID再判断公众号
$status = $this->get_rule($appid); #-判断三级分销是否已经为启用的状态
$this->openid= $openid; //获取当前的用户OPENID；
if ($status[‘status’]==1 || $status[‘status’]==’1′){ #-如果有打开分销系统
$plugins = unserialize($this->get_ewei_shop_sysset($appid)); #-提取分销的数据
$level = $plugins[‘commission’][‘level’];
$temp_agentid = $this->getagentid($appid); #-获取临时的上级ID，因为要写入订单数据的
$this->setOrder($orders, $money, $appid, $temp_agentid); #-写入一份订单数据
$order_id = $this->pdo->lastInsertId(); #-获取当前的订单ID
$commission = array();
if ($level>0){ #-如果大于0表示开启了佣金
$default_money = 100; #-测试的时候使用的默认金额，否则使用$money
for ($i=1;$i<=$level;$i++){ #-最大的次数字
$text = ‘commission’.$i; #-获取需要循环提取的字段
$temp_data = $plugins[‘commission’][$text]*0.01; #-提取对应字段值的VALUE并且转化成百分比
$commission[$i] = intval($default_money*$temp_data); #-获取完整的佣金数据,只保留整数
#-如果需要小数后两位使用round()方法
}
for ($o=1;$o<=3;$o++){
if (isset($commission[$o]) && !empty($commission[$o])){

} else {
$commission[$o]=’0.00′;
}
}
$this->setOrderGoods($appid, $order_id, $money, ‘电影票level=’.$level,$commission);
} else {
for ($o=1;$o<=3;$o++){
$commission[$o]=’0.00′;
}
$this->setOrderGoods($appid, $order_id, $money, ‘电影票level=’.$level,$commission);
}
} else {

}
}
}

private function setOrderGoods($appid,$order_id,$price,$optionname,$commission){
$sql = “INSERT INTO `”.$this->pre.”ewei_shop_order_goods`
SET `uniacid` = ‘”.(int)$appid.”‘,
`orderid` = ‘”.(int)$order_id.”‘,
`goodsid` = ‘0’,
`price` = ‘”.$price.”‘,
`total` = ‘1’,
`optionid` = ‘0’,
`createtime` = ‘”.time().”‘,
`optionname` = ‘”.$optionname.”‘,
`commission1` = ‘”.$this->orderCommission($commission[1]).”‘,
`applytime1` = ‘0’,
`checktime1` = ‘0’,
`paytime1` = ‘”.time().”‘,
`invalidtime1` = ‘0’,
`deletetime1` = ‘0’,
`status1` =’0′,
`content1` =’NULL’,
`commission2` = ‘”.$this->orderCommission($commission[2]).”‘,
`applytime2` = ‘0’,
`checktime2` = ‘0’,
`paytime2` = ‘”.time().”‘,
`invalidtime2` = ‘0’,
`deletetime2` = ‘0’,
`status2` =’0′,
`content2` =’NULL’,
`commission3` = ‘”.$this->orderCommission($commission[3]).”‘,
`applytime3` = ‘0’,
`checktime3` = ‘0’,
`paytime3` = ‘”.time().”‘,
`invalidtime3` = ‘0’,
`deletetime3` = ‘0’,
`status3` =’0′,
`content3` =’NULL’,
`realprice` = ‘”.$price.”‘”;
$this->pdo->exec($sql);
}

/**
* 根据金额进行序列化
* @param unknown $money
* @return unknown
*/
private function orderCommission($money){
$arr[‘default’]=”$money”;
$text = serialize($arr);
return $text;
}

/**
* 写入订单数据
* @param unknown $order
* @param unknown $money
* @param unknown $appid
* @param unknown $agentid
*/
private function setOrder($order,$money,$appid,$agentid){
$sql=”INSERT INTO `”.$this->pre.”ewei_shop_order`
SET `uniacid`='”.(int)$appid.”‘,
`openid` = ‘”.$this->openid.”‘,
`agentid` = ‘”.(int)$agentid.”‘,
`ordersn` = ‘”.$order[‘out_trade_no’].”‘,
`price` = ‘”.$money.”‘,
`goodsprice` = ‘”.$money.”‘,
`discountprice` = ‘0.00’,
`status` =’3′,
`paytype` = ’21’,
`addressid` = ‘”.(int)$this->getAdders($appid).”‘,
`dispatchprice` = ‘0.00’,
`dispatchid` = ‘0’,
`createtime` = ‘”.time().”‘,
`dispatchtype` =’0′,
`carrier` =’a:0:{}’,
`refundid` =’0′,
`iscomment` =’0′,
`creditadd` =’0′,
`deleted` =’0′,
`userdeleted` = ‘0’,
`finishtime` = ‘0’,
`paytime` ='”.time().”‘,
`sendtime` =’0′,
`fetchtime` =’0’,
`cash` = ‘0’,
`canceltime` =’NULL’,
`cancelpaytime` =’0′,
`refundtime` =’0′,
`isverify` = ‘0’,
`verified` =’0′,
`verifytime` =’0′,
`verifystoreid` =’0′,
`deductprice` =’0.00′,
`deductcredit` =’0′,
`deductcredit2` = ‘0.00’,
`deductenough` =’0.00′”;
$this->pdo->exec($sql);
}

/**
* 根据公众号ID和用户OPENID获取订单地址ID
* @param unknown $appid
* @return unknown
*/
private function getAdders($appid){
$sql = “SELECT id FROM `”.$this->pre.”ewei_shop_member_address` WHERE `uniacid`='”.(int)$appid.”‘ AND `openid` = ‘”.$this->openid.”‘”;
$data = $this->pdo->query($sql);
$data = $data->fetch(PDO::FETCH_ASSOC);
return $data[‘id’];
}

/**
* 根据公众号唯一ID和用户的唯一OPENID，提取出上一级
* @param unknown $appid
* @return unknown
*/
private function getagentid($appid){
$sql = “SELECT agentid FROM `”.$this->pre.”ewei_shop_member`
WHERE `uniacid` = ‘”.(int)$appid.”‘ AND `openid` = ‘”.$this->openid.”‘”;
$data = $this->pdo->query($sql);
$data = $data->fetch(PDO::FETCH_ASSOC);
return $data[‘agentid’];
}

}

由于无聊玩玩改代码，结果发现，公众号无法调用oAuth；

file:///web/source/mc/passport.ctrl.php

OAUTH协议为用户资源的授权提供了一个安全的、开放而又简易的标准。与以往的授权方式不同之处是OAUTH的授权不会使第三方触及到用户的帐号信息（如用户名与密码），即第三方无需使用用户的用户名与密码就可以申请获得该用户资源的授权，因此OAUTH是安全的。oAuth是Open Authorization的简写。

来说说问题吧：

每一个公众号都有个唯一的uniacid唯一参数值，在创建完成之后，写入扩展表：uni_settings

有这么一个字段：oauth

字段值：a:2:{s:4:”host”;s:0:””;s:7:”account”;i:26;}

host=其他域名的，account=对应的oauth参数组合URL；

再来看看URL需要的参数

后台访问的时候，会GET个do=oauth，执行该方法

if($do == ‘oauth’) {
uni_user_permission_check(‘mc_passport_oauth’);
$_W[‘page’][‘title’] = ‘公众平台oAuth选项 – 会员中心’;

$where = ”;
$params = array();
if(empty($_W[‘isfounder’])) {
$where = ” WHERE `uniacid` IN (SELECT `uniacid` FROM ” . tablename(‘uni_account_users’) . ” WHERE `uid`=:uid)”;
$params[‘:uid’] = $_W[‘uid’];
}
$sql = “SELECT * FROM ” . tablename(‘uni_account’) . $where;

$uniaccounts = pdo_fetchall($sql, $params);
$accounts = array();
if(!empty($uniaccounts)) {
foreach($uniaccounts as $uniaccount) {
$accountlist = uni_accounts($uniaccount[‘uniacid’]);
if(!empty($accountlist)) {
foreach($accountlist as $account) {
if(!empty($account[‘key’]) && !empty($account[‘secret’]) && in_array($account[‘level’], array(4))) {
$accounts[$account[‘acid’]] = $account[‘name’];
}
}
}
}
}
…..次处省略N个字符……
}

在这特别注意：uni_accounts($uniaccount[‘uniacid’])方法

原型是：

function uni_accounts($uniacid = 0) {
global $_W;
$uniacid = empty($uniacid) ? $_W[‘uniacid’] : intval($uniacid);
$accounts = pdo_fetchall(“SELECT w.*, a.type, a.isconnect FROM ” . tablename(‘account’) . ” a INNER JOIN ” . tablename(‘account_wechats’) . ” w USING(acid) WHERE a.uniacid = :uniacid ORDER BY a.acid ASC”, array(‘:uniacid’ => $uniacid), ‘acid’);
return $accounts;
}

该方法里获取的值，是account_wechats里的数据，里面有个level，必须=4，否则将无法调用！

顺便给个方法：

if(!empty($uniaccounts)) {
foreach($uniaccounts as $uniaccount) {
$accountlist = uni_accounts($uniaccount[‘uniacid’]);
if(!empty($accountlist)) {
foreach($accountlist as $account) {
$arr=array(
‘2’ => 2,
‘3’ => 3,
‘4’ => 4,
);
if(!empty($account[‘key’]) && !empty($account[‘secret’]) && in_array($account[‘level’], $arr)) {
$accounts[$account[‘acid’]] = $account[‘name’];
}
}
}
}
}

这样就只提取2-4等级的了

JSAUTH也一样，文件位置：file:///web/source/profile/jsauth.ctrl.php

if(!empty($uniaccounts)) {
foreach($uniaccounts as $uniaccount) {
$accountlist = uni_accounts($uniaccount[‘uniacid’]);
if(!empty($accountlist)) {
foreach($accountlist as $account) {
if(!empty($account[‘key’])
&& !empty($account[‘secret’])
&& in_array($account[‘level’], array(2, 3, 4))) {
$accounts[$account[‘acid’]] = $account[‘name’];
}
}
}
}
}

开发PHP的时候，如果从数据库中提取的数据需要进行字符串的截取（比如文章的标题）；

如果只是截取英文和数字，那简单的很，substr()方法就可以，附加3个参数：

1->需要截取的字符；

2->开始位置；

3->结束位置；

开始和结束位置如果为负数，即表示从尾端截取上来。

可是在截取UTF8的中文就好麻烦了，这时候，就需要使用到MB类库的mb_substr()方法了

首先请确保服务器的PHP是否开起了MB类库的扩展

使用方法：mb_substr(string,leng_head,leng_end,type);

前面3个和substr一样，关键最后面多了一个type，即截取的字符串的类型，通用一般为：utf-8

如：mb_substr(‘我是清心醉，一个网站全栈架构师’,3,15,’utf-8′);