<?php
namespace apps\drp\controllers;
use apps\base\controllers\FrontendController;
class UserController extends FrontendController {
public $weObj;
private $wechat;
protected $user_id;
protected $action;
protected $back_act = '';
private $drp = null;
/**
* 构造函数
*/
public function __construct() {
parent::__construct();
// 属性赋值
$this->user_id = $_SESSION['user_id'];
$this->action = ACTION_NAME;
$this->con = CONTROLLER_NAME;
$this->app = APP_NAME ;
if($this->app == 'drp' & & $this->con == 'user' & & $this->action == 'index'){
}elseif($this->app == 'drp'){
$filter = 1;
$this->assign('filter', $filter);
}
$this->checkLogin();
// 分销商信息
$this->drp = get_drp($this->user_id);
// 用户信息
$info = get_user_default($this->user_id);
$this->assign('drp', $this->drp);
$this->assign('info', $info);
}
/**
* 未登录验证
*/
private function checkLogin() {
// 是否登陆
if(!$this->user_id){
$url = urlencode(__HOST__ . $_SERVER['REQUEST_URI']);
if(IS_POST) {
$url = urlencode($_SERVER['HTTP_REFERER']);
}
ecs_header("Location: ".U('user/login/index',array('back_act'=>$url)));
exit;
}
// 分销状态
$drp_audit_status = drp_audit_status($this->user_id);
// 不是分销商
if(!$drp_audit_status){
ecs_header("Location: ".(U('drp/index/index')));
exit;
}
}
public function actionIndex(){
$sql = "SELECT user_money FROM " .$GLOBALS['ecs']->table('users').
" WHERE user_id = '$this->user_id'";
$surplus_amount = $GLOBALS['db']->getOne($sql); //可提佣金
$totals = $this->get_drp_money(0); //累计佣金
$today_total = $this->get_drp_money(1); //今日收入
$total_amount = $this->get_drp_money(2); //总销售额
$this->assign('surplus_amount', $surplus_amount);
$select_url = U('drp/index/category');
$this->assign('select_url', $select_url);
$url = U('drp/shop/index',array('id'=>$this->drp['drp_id'],'u'=>$_SESSION['user_id']));//我的微店
$this->assign('url', $url);
$sql="SELECT value FROM {pre}drp_config WHERE code='withdraw'";
$withdraw=$this->db->getOne($sql);
$this->assign('withdraw', $this->htmlOut($withdraw));
$this->assign('totals', $totals[0]['totals']?$totals[0]['totals']:0);
$this->assign('today_total', $today_total[0]['totals']?$today_total[0]['totals']:0);
$this->assign('total_amount', $total_amount[0]['totals']?$total_amount[0]['totals']:0);
$this->assign('page_title', '分销中心');
$category = get_child_tree();
$sql = "SELECT cat_id FROM " . $GLOBALS['ecs']->table('drp_shop') .
" WHERE user_id = $this->user_id";
$res = $GLOBALS['db']->getOne($sql);
$res = explode(',',$res);
$sql = "select cat_id from {pre}cat_recommend where recommend_type = 3";
$recommend = $GLOBALS['db']->getAll($sql);
$ress = array();
foreach ($recommend as $kk => $vv){
$ress[] = $vv['cat_id'];
}
foreach ($category as $k => $v){
if(in_array($category[$k]['id'],$ress)){
if(in_array($v['id'],$res)){
$category[$k]['is_drp'] = 1;
}else{
$category[$k]['is_drp'] = 0;
}
}else{
unset($category[$k]);
}
}
$this->assign('category', array_slice($category,0,5));
$this->assign('uid',$this->user_id);
$this->display('distribution_user');
}
private function get_drp_money($type){
if($type === 0){
$where = "";
}else{
if($type === 1){
$nowtime = gmtime();
$t = getdate($nowtime);
$today_zero_time = mktime(0, 0, 0, $t['mon'], $t['mday'], $t['year']);
$where = " AND time >= $today_zero_time";
}else{
$sql = "SELECT sum(goods_amount) as totals FROM " . $GLOBALS['ecs']->table('order_info') . " o" .
" LEFT JOIN " . $GLOBALS['ecs']->table('affiliate_log') . " a ON o.order_id = a.order_id" .
" WHERE a.user_id = " . $_SESSION['user_id'];
return $GLOBALS['db']->query($sql);
}
}
$sql = "SELECT sum(money) as totals FROM " . $GLOBALS['ecs']->table('affiliate_log') .
" WHERE user_id = " . $_SESSION['user_id'] .
"$where";
return $GLOBALS['db']->query($sql);
}
// 佣金明细
public function actionDrplog(){
$sql = "SELECT order_id FROM " . $GLOBALS['ecs']->table('drp_log') . " ORDER BY log_id DESC" ;
$last_oid = $GLOBALS['db']->getOne($sql);
$last_oid = $last_oid?$last_oid:0;
$sql = "SELECT o.order_id FROM {pre}order_info " ." o".
" LEFT JOIN".$GLOBALS['ecs']->table('users')." u ON o.user_id = u.user_id".
" WHERE o.user_id > 0 AND (u.parent_id > 0 AND o.is_separate = 0 OR o.is_separate > 0) ".
" and o.order_id > $last_oid" ;
$up_oid = $GLOBALS['db']->getAll($sql);
$affiliate = unserialize($GLOBALS['_CFG']['affiliate']);
empty($affiliate) & & $affiliate = array();
if($up_oid){
$separate_by = $affiliate['config']['separate_by'];
$affiliate['config']['level_point_all'] = (float)$affiliate['config']['level_point_all'];
$affiliate['config']['level_money_all'] = (float)$affiliate['config']['level_money_all'];
if ($affiliate['config']['level_point_all'])
{
$affiliate['config']['level_point_all'] /= 100;
}
if ($affiliate['config']['level_money_all'])
{
$affiliate['config']['level_money_all'] /= 100;
}
foreach ($up_oid as $kk => $vv){
$row = $GLOBALS['db']->getRow("SELECT o.order_sn, o.parent_id, o.is_separate, (o.goods_amount - o.discount) AS goods_amount, o.user_id FROM " . $GLOBALS['ecs']->table('order_info') . " o".
" LEFT JOIN " . $GLOBALS['ecs']->table('users') . " u ON o.user_id = u.user_id".
" WHERE order_id = ".$vv['order_id']);
$is = $row['is_separate'];
$money = round($affiliate['config']['level_money_all'] * $row['goods_amount'],2);
$integral = integral_to_give(array('order_id' => $vv['order_id'], 'extension_code' => ''));
$point = round($affiliate['config']['level_point_all'] * intval($integral['rank_points']), 0);
$num = count($affiliate['item']);
for ($i=0; $i < $num; $i++)
{
$affiliate['item'][$i]['level_point'] = (float)$affiliate['item'][$i]['level_point'];
$affiliate['item'][$i]['level_money'] = (float)$affiliate['item'][$i]['level_money'];
if ($affiliate['item'][$i]['level_point'])
{
$perp = ($affiliate['item'][$i]['level_point']/ 100);
}
if ($affiliate['item'][$i]['level_money'])
{
$per = ($affiliate['item'][$i]['level_money'] /100);
}
$setmoney = round($money * $per, 2);
$setpoint = round($point * $perp, 0);
$row = $GLOBALS['db']->getRow("SELECT o.parent_id as user_id,u.user_name FROM " . $GLOBALS['ecs']->table('users') . " o" .
" LEFT JOIN" . $GLOBALS['ecs']->table('users') . " u ON o.parent_id = u.user_id".
" WHERE o.user_id = '$row[user_id]'"
);
$this->writeDrpLog($vv['order_id'], $row['user_id'], $row['user_name'], $setmoney, $setpoint, $i,$is,$separate_by);
}
}
}
$sql = "SELECT o.order_id FROM {pre}order_info as o " .
" LEFT JOIN {pre}drp_log as d ON d.order_id = o.order_id AND o.is_separate != d.is_separate";
//order_info order_id不在drp——log的id 自营的
$up_oid = $GLOBALS['db']->getAll($sql);
$affiliate = unserialize($GLOBALS['_CFG']['affiliate']);
empty($affiliate) & & $affiliate = array();
if($up_oid){
foreach ($up_oid as $kk => $vv){
$row = $GLOBALS['db']->getRow("SELECT o.order_sn, o.parent_id, o.is_separate, (o.goods_amount - o.discount) AS goods_amount, o.user_id FROM " . $GLOBALS['ecs']->table('order_info') . " o".
" LEFT JOIN " . $GLOBALS['ecs']->table('users') . " u ON o.user_id = u.user_id".
" WHERE order_id = ".$vv['order_id']);
$is = $row['is_separate'];
$num = count($affiliate['item']);
for ($i=0; $i < $num; $i++)
{
$row = $GLOBALS['db']->getRow("SELECT o.parent_id as user_id,u.user_name FROM " . $GLOBALS['ecs']->table('users') . " o" .
" LEFT JOIN" . $GLOBALS['ecs']->table('users') . " u ON o.parent_id = u.user_id".
" WHERE o.user_id = '$row[user_id]'"
);
$this->upDrpLog($vv['order_id'],$is);
}
}
}
$page = I('post.page', 1, 'intval');
$size = '10';
$status = I('status',2,'intval');
if($status == 2){
//全部
$where = "";
}else {
//已分成 OR 等待处理
$where = " AND a.is_separate = " . $status . "";
}
if(IS_AJAX){
$sql = "SELECT o.order_sn, a.time,a.user_id,a.time,a.money,a.point,a.separate_type,IFNULL(w.nickname,u.user_name),a.is_separate FROM " . $GLOBALS['ecs']->table('drp_log') . " a".
" LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " o ON o.order_id = a.order_id" .
" LEFT JOIN".$GLOBALS['ecs']->table('users')." u ON o.user_id = u.user_id".
" LEFT JOIN".$GLOBALS['ecs']->table('wechat_user')." w ON w.ect_uid = u.user_id".
" WHERE a.user_id = $_SESSION[user_id] AND o.pay_status = 2".
" $where ".
" ORDER BY o.order_id DESC";
$resall = $GLOBALS['db']->query($sql);
$countall =count($resall);
$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
foreach ($res as $k => $v){
$res[$k]['time'] = date("Y-m-d ",($v['time']+date('Z')));
$res[$k]['is_separate'] = ($v['is_separate'] == '1')?'已分成':'等待处理';
}
die(json_encode(array('list' => $res, 'totalPage' => ceil($countall/$size))));
}
$this->assign('page_title', '佣金明细');
$this->display('distribution_money');
}
//分类
public function actionCategory(){
$page = I('post.page', 1, 'intval');
$size = '5';
$status = I('status')?I('status'):0;;
$category = get_child_tree();
$sql = "SELECT cat_id FROM " . $GLOBALS['ecs']->table('drp_shop') .
" WHERE user_id = $this->user_id";
$res = $GLOBALS['db']->getOne($sql);
$res = explode(',',$res);
foreach ($category as $k => $v){
if(in_array($v['id'],$res)){
$category[$k]['is_drp'] = 1;
}else{
$category[$k]['is_drp'] = 0;
}
}
if(IS_AJAX){
if($status == 0){
foreach ($category as $ke => $val){
if($val['is_drp'] == 1){
unset($category[$ke]);
}
}
}
if($status == 1){
foreach ($category as $ke => $val){
if($val['is_drp'] == 0){
unset($category[$ke]);
}
}
}
die(json_encode(array('category'=>$category,'totalPage'=>1)));
}
$this->assign('page_title', '全部分类');
$this->display('distribution_shop');
}
//AJAX修改分类
public function actionAjaxeditcat(){
$cat_id = I('cat_id');
if(IS_POST){
$sql = "SELECT cat_id FROM " . $GLOBALS['ecs']->table('drp_shop') .
" WHERE user_id = $this->user_id";
$res = $GLOBALS['db']->getOne($sql);
$array = explode(',',$res);
if(in_array($cat_id,$array)){
foreach ($array as $k => $v){
if($v == $cat_id){
unset($array[$k]);
}
}
$res = implode(",",$array);
}else{
$res = $res . $cat_id .",";
}
$data['cat_id'] = $res;
$where['user_id'] = $_SESSION['user_id'];
$this->model->table('drp_shop')->data($data)->where($where)->update();
echo json_encode(array('status'=>1));
}
}
/**
* 我的名片
*/
public function actionUserCard() {
$uid = I('request.u');
$uid = empty($uid) ? $_SESSION['user_id'] : $uid;
$info = get_drp($uid);
$this->assign('info', $info);
$url = 'http://'.$_SERVER['HTTP_HOST'].U('shop/index',array('id'=>$info['drp_id'],'u'=>$this->user_id));
//二维码内容
$str = '';
// 纠错级别：L、M、Q、H
$errorCorrectionLevel = 'L';
// 点的大小：1到10
$matrixPointSize = 4;
$file = ROOT_PATH.'data/attached/qrcode/';
$name = 'userid_'.$this->user_id.$errorCorrectionLevel . $matrixPointSize . '.png';
if(!file_exists($name)) {
$filename = $file . $name;
$code = \libraries\QRcode::png($url, $filename, $errorCorrectionLevel, $matrixPointSize, 2);
}
$this->assign('ewm', __ROOT__.'data/attached/qrcode/'.$name);
$this->assign('page_title',$info['username'].'的名片');
$this->display('distribution_card');
// $this->actionGetConfig();
/* if(is_object($this->weObj) & & !empty($uid)) {
//获取店铺信息
$info = get_drp($uid);
//临时二维码
$path = ROOT_PATH.'data/attached/qrcode/card_'.$uid.'.png';
if(!file_exists($path) || (strtotime("-28 day")-@filectime($path))>0) {
//删除过期图片
@unlink ($path);
$ticket = $this->weObj->getQRCode((int)$uid, 0, 2592000);
$img = $this->weObj->getQRUrl($ticket['ticket']);
//保存图片到本地
$contents = \libraries\Http::doGet($img);
file_put_contents($path, $contents);
}
$this->assign('ewm', __ROOT__.'data/attached/qrcode/card_'.$uid.'.png');
//SDK
$access_token = $this->weObj->checkAuth($this->wechat['appid'],$this->wechat['appsecret']);
$ticket = $this->weObj->getJsTicket($this->wechat['appid']);
$time = gmtime()+8*3600;
$url = "jsapi_ticket=".$ticket."&noncestr=ectouch×tamp=".$time."&url="."http://".$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI'];
$arr = array(
'share_url' => U('user/card',array('uid'=>$uid)),
'imgUrl' => $info['headimgurl'],
'title' => $info['shop_name'],
'desc' => '新道新承诺,双盈大家乐!',
'appid' => $this->wechat['appid'],
'noncestr' => 'ectouch', //任意改动
'timestamp' => $time,
'signature' => sha1($url)
);
$this->assign('info', $info);
$this->assign('wx',$arr);
$this->assign('page_title',$info['username'].'的名片');
$this->display('distribution_card');
}else{
$this->redirect(U('user/index'));
}*/
}
/*
* 团队
*/
public function actionTeam() {
if(IS_AJAX) {
$uid = I('user_id') ? I('user_id'): $this->user_id;
$page = I('page', 1) - 1;
$limit = " LIMIT $page,6";
$sql = "SELECT s.status, s.audit, u.user_id, IFNULL(u.user_name, w.nickname) as name, w.headimgurl, FROM_UNIXTIME(u.reg_time, '%Y-%m-%d') as time,
IFNULL((select sum(log.money) as money from {pre}affiliate_log as log left join {pre}order_info as o
on log.order_id=o.order_id where o.user_id=u.user_id and log.user_id=".$uid."),0) as money
FROM {pre}users as u
LEFT JOIN {pre}wechat_user as w ON u.user_id=w.ect_uid
LEFT JOIN {pre}drp_shop as s ON u.user_id=s.user_id
WHERE s.status=1 and s.audit=1 and u.parent_id='$uid'
ORDER BY u.reg_time desc". $limit;
$next = $this->model->query($sql);
//所有记录
$list = $this->model->query($sql);
die(json_encode(array('info'=>$next, 'uid'=>$uid, 'totalPage'=>ceil(count($list)/6))));
}
$this->assign('page_title','我的团队');
$this->assign('next_id',I('user_id',''));
$this->display('distribution_team');
}
/*
* 从下线获取的佣金-详情
*/
public function actionTeamDetail() {
$uid = I('uid','');
if(empty($uid)) {
$this->redirect(U('drp/user/index'));
}
$sql = "SELECT u.user_id, IFNULL(u.user_name, w.nickname) as name, w.headimgurl, FROM_UNIXTIME(u.reg_time, '%Y-%m-%d') as time,
IFNULL((select sum(sl.money) from {pre}affiliate_log as sl
left join {pre}order_info as so on sl.order_id=so.order_id
where so.user_id='$uid' and sl.user_id='$this->user_id'),0) as sum_money,
IFNULL((select sum(nl.money) from {pre}affiliate_log as nl
left join {pre}order_info as no on nl.order_id=no.order_id
where nl.time>'".mktime(0,0,0)."' and no.user_id='$uid' and nl.user_id='$this->user_id'),0) as now_money,
(select count(h.user_id) from {pre}users as h LEFT JOIN {pre}drp_shop as s on s.user_id=h.user_id where s.status=1 and s.audit=1 and parent_id='$uid' ) as next_num
FROM {pre}users as u
LEFT JOIN {pre}wechat_user as w ON u.user_id=w.ect_uid
WHERE u.user_id='$uid'";
$this->assign('info',$this->db->getRow($sql));
$shopid = model()->table('drp_shop')->field('id')->where(array('user_id'=>$uid, 'status'=>1,'audit'=>1))->find();
$this->assign('shopid',$shopid['id']);
$this->assign('page_title','团队详情');
$this->display('distribution_team_detail');
}
//新手必看
public function actionNew(){
$sql = "SELECT a.title,a.content FROM " . $GLOBALS['ecs']->table('article') . " a".
" LEFT JOIN " . $GLOBALS['ecs']->table('article_cat') . " o ON o.cat_id = a.cat_id" .
" WHERE a.is_open = 1 and o.cat_id = 1000 order by a.add_time desc ";
$drp_article = $this->db->query($sql);
foreach( $drp_article as $k=>$v){
$drp_article[$k]['order'] = ($k+1);
}
$this->assign('drp_article', $drp_article);
$this->assign('page_title', '新手必看');
$this->display('distribution_new');
}
/*
* 排行榜
*/
public function actionRankList() {
$uid = I('uid') ? I('uid'): $this->user_id;
$all =$GLOBALS['cache']->get('ranklist'.$uid);
if(!$all) {
$sql = "SELECT d.user_id, w.nickname, w.headimgurl, u.user_name,
IFNULL((select sum(money) from {pre}affiliate_log where user_id=d.user_id),0) as money
FROM {pre}drp_shop as d
LEFT JOIN {pre}users as u ON d.user_id=u.user_id
LEFT JOIN {pre}wechat_user as w ON d.user_id=w.ect_uid
LEFT JOIN {pre}affiliate_log as log ON log.user_id=d.user_id
where d.audit=1 and d.status=1
GROUP BY d.user_id
ORDER BY money desc ";
$all = $this->model->query($sql);
if ($all) {
foreach ($all as $key => $val) {
if ($key === 0) {
$all[$key]['img'] = __TPL__ . 'img/fx-one.png';
} else if ($key === 1) {
$all[$key]['img'] = __TPL__ . 'img/fx-two.png';
} else if ($key === 2) {
$all[$key]['img'] = __TPL__ . 'img/fx-stree.png';
} else {
$all[$key]['span'] = $key + 1;
}
}
$GLOBALS['cache']->set('ranklist' . $uid, $all);
}
}
if(IS_AJAX) {
$page = I('page',1,'intval')-1;
//总条数
$list = array_slice($all,$page*6,6);
die(json_encode(array('list' => $list, 'totalPage' => ceil(count($all) / 6))));
}
//用户排名
$rank = copy_array_column($all,'user_id');
$rank = array_search($uid,$rank);
$rank = $rank === false ? '--' : $rank+1;
$this->assign('rank',$rank);
$this->assign('page_title','分销排行');
$this->display('distribution_ranklist');
}
/**
* 获取公众号配置
*
* @param string $orgid
* @return array
*/
private function actionGetConfig() {
$orgid = $this->model->table('wechat')->field('orgid')->one();
$wxinfo = model()->table('wechat')
->field('id, token, appid, appsecret, encodingaeskey')
->where(array('orgid'=>$orgid, 'status'=>1))
->find();
$this->wechat = $wxinfo;
if (!empty($wxinfo)) {
$this->weObj = new \vendor\Wechat($wxinfo);
}
}
/**
* 店铺设置
*/
public function actionShopConfig() {
$sql="SELECT * FROM {pre}drp_shop WHERE user_id=$this->user_id";
$drp_info=$this->db->getRow($sql);
$info=array();
$info['shop_name']= $drp_info['shop_name'];
$info['real_name']= $drp_info['real_name'];
$info['qq']= $drp_info['qq'];
if(empty($drp_info['shop_img'])){
$info['shop_img']=__TPL__.'img/user-shop.png';
}else{
$info['shop_img'] ='./data/attached/drp_logo/' . $drp_info['shop_img'];
}
$info['mobile']= $drp_info['mobile'];
$this->assign('info',$info);
if (IS_POST) {
$data = I('');
if($data['mobile']){
$preg=preg_match('#^13[\d]{9}$|^14[5,7]{1}\d{8}$|^15[^4]{1}\d{8}$|^17[0,6,7,8]{1}\d{8}$|^18[\d]{9}$#', $data['mobile']) ? true : false;
if($preg==FALSE){
show_message('手机号码格式不正确');
}
}
if (empty($data['shop_name'])) {
show_message('店铺名不能为空');
}
if (empty($data['real_name'])) {
show_message('真实姓名不能为空');
}
if (empty($data['mobile'])) {
show_message('手机号码不能为空');
}
if (!empty($_FILES['shop_img']['name'])) {
$result =$this->ectouchUpload('shop_img','drp_logo');
if ($result['error'] > 0) {
show_message($result['message']);
}
$data['shop_img'] = $result['message']['shop_img']['savename'];
}
$where['user_id'] = $_SESSION['user_id'];
$this->model->table('drp_shop')->data($data)->where($where)->update();
show_message('修改成功', '分销中心', U('drp/user/index'),'success');
}
$this->assign('page_title','店铺设置');
$this->display('shop_config');
}
/*
* 分销订单列表
* */
public function actionOrder()
{
$sql = "SELECT order_id FROM " . $GLOBALS['ecs']->table('drp_log') . " ORDER BY log_id DESC" ;
$last_oid = $GLOBALS['db']->getOne($sql);
$last_oid = $last_oid?$last_oid:0;
$sql = "SELECT o.order_id FROM {pre}order_info " ." o".
" LEFT JOIN".$GLOBALS['ecs']->table('users')." u ON o.user_id = u.user_id".
" WHERE o.user_id > 0 AND (u.parent_id > 0 AND o.is_separate = 0 OR o.is_separate > 0) ".
" and o.order_id > $last_oid" ;
$up_oid = $GLOBALS['db']->getAll($sql);
$affiliate = unserialize($GLOBALS['_CFG']['affiliate']);
empty($affiliate) & & $affiliate = array();
if($up_oid){
$separate_by = $affiliate['config']['separate_by'];
$affiliate['config']['level_point_all'] = (float)$affiliate['config']['level_point_all'];
$affiliate['config']['level_money_all'] = (float)$affiliate['config']['level_money_all'];
if ($affiliate['config']['level_point_all'])
{
$affiliate['config']['level_point_all'] /= 100;
}
if ($affiliate['config']['level_money_all'])
{
$affiliate['config']['level_money_all'] /= 100;
}
foreach ($up_oid as $kk => $vv){
$oid = (int)$vv['order_id'];
$row = $GLOBALS['db']->getRow("SELECT o.order_sn, o.parent_id, o.is_separate, (o.goods_amount - o.discount) AS goods_amount, o.user_id FROM " . $GLOBALS['ecs']->table('order_info') . " o".
" LEFT JOIN " . $GLOBALS['ecs']->table('users') . " u ON o.user_id = u.user_id".
" WHERE order_id = '$oid'");
$is = $row['is_separate'];
$money = round($affiliate['config']['level_money_all'] * $row['goods_amount'],2);
$integral = integral_to_give(array('order_id' => $oid, 'extension_code' => ''));
$point = round($affiliate['config']['level_point_all'] * intval($integral['rank_points']), 0);
$num = count($affiliate['item']);
for ($i=0; $i < $num; $i++)
{
$affiliate['item'][$i]['level_point'] = (float)$affiliate['item'][$i]['level_point'];
$affiliate['item'][$i]['level_money'] = (float)$affiliate['item'][$i]['level_money'];
if ($affiliate['item'][$i]['level_point'])
{
$perp = ($affiliate['item'][$i]['level_point']/ 100);
}
if ($affiliate['item'][$i]['level_money'])
{
$per = ($affiliate['item'][$i]['level_money']/ 100);
}
$setmoney = round($money * $per, 2);
$setpoint = round($point * $perp, 0);
$row = $GLOBALS['db']->getRow("SELECT o.parent_id as user_id,u.user_name FROM " . $GLOBALS['ecs']->table('users') . " o" .
" LEFT JOIN" . $GLOBALS['ecs']->table('users') . " u ON o.parent_id = u.user_id".
" WHERE o.user_id = '$row[user_id]'"
);
$this->writeDrpLog($oid, $row['user_id'], $row['user_name'], $setmoney, $setpoint, $i,$is,$separate_by);
}
}
}
$sql = "SELECT o.order_id FROM {pre}order_info as o " .
" LEFT JOIN {pre}drp_log as d ON d.order_id = o.order_id AND o.is_separate != d.is_separate";
//order_info order_id不在drp——log的id 自营的
$up_oid = $GLOBALS['db']->getAll($sql);
$affiliate = unserialize($GLOBALS['_CFG']['affiliate']);
empty($affiliate) & & $affiliate = array();
if($up_oid){
foreach ($up_oid as $kk => $vv){
$row = $GLOBALS['db']->getRow("SELECT o.order_sn, o.parent_id, o.is_separate, (o.goods_amount - o.discount) AS goods_amount, o.user_id FROM " . $GLOBALS['ecs']->table('order_info') . " o".
" LEFT JOIN " . $GLOBALS['ecs']->table('users') . " u ON o.user_id = u.user_id".
" WHERE order_id = ".$vv['order_id']);
$is = $row['is_separate'];
$num = count($affiliate['item']);
for ($i=0; $i < $num; $i++)
{
$row = $GLOBALS['db']->getRow("SELECT o.parent_id as user_id,u.user_name FROM " . $GLOBALS['ecs']->table('users') . " o" .
" LEFT JOIN" . $GLOBALS['ecs']->table('users') . " u ON o.parent_id = u.user_id".
" WHERE o.user_id = '$row[user_id]'"
);
$this->upDrpLog($vv['order_id'],$is);
}
}
}
$page = I('post.page', 1, 'intval');
$size = '5';
$status = I('status',2,'intval');
if($status == 2){
//全部
$where = "";
}else {
//已分成 OR 等待处理
$where = " AND o.is_separate = " . $status . "";
}
if(IS_AJAX){
$sql = "SELECT o.*, a.money, IFNULL(w.nickname,u.user_name) as user_name, a.point, a.drp_level FROM " . $GLOBALS['ecs']->table('drp_log') . " a".
" LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " o ON o.order_id = a.order_id" .
" LEFT JOIN".$GLOBALS['ecs']->table('users')." u ON o.user_id = u.user_id".
" LEFT JOIN".$GLOBALS['ecs']->table('wechat_user')." w ON w.ect_uid = u.user_id".
" WHERE a.user_id = $_SESSION[user_id] AND o.pay_status = 2".
" $where ".
" ORDER BY order_id DESC";
$resall = $GLOBALS['db']->query($sql);
$countall =count($resall);
$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
if ($res) {
foreach ($res as $key => $value) {
$level_per = ((float)$affiliate['item'][$value['drp_level']]['level_money'])*($affiliate['config']['level_money_all']);
$level_per = $level_per/100;
$goods_list = $this->getOrderGoods($value['order_id']);
$total_goods_price = 0;
foreach ($goods_list as $key => $val) {
$goods_list[$key]['price'] = $val['goods_price'];
$goods_list[$key]['subtotal'] = price_format($value['total_fee'], false);
$goods_list[$key]['goods_number'] = $val['goods_number'];
$goods_list[$key]['goods_thumb'] = get_image_path($val['goods_thumb']);
$goods_list[$key]['url'] = U('goods/index/index',array('id'=>$val['goods_id']));
$goods_list[$key]['this_good_drpmoney'] = (round($val['goods_price']*$level_per/100,2));
$total_goods_price += $val['goods_price'];
$goods_list[$key]['this_good_per'] = $level_per."%";
}
foreach ($goods_list as $key => $val) {
$goods_list[$key]['goods_price'] = price_format($val['goods_price'], false);
}
$orders[] = array(
'user_name' => $value['user_name'],
'order_sn' => $value['order_sn'],
'order_time' => date("Y-m-d H:i:s",$value['add_time']+date('Z')),
'url' => U('drp/user/order_detail', array('order_id' => $value['order_id'])),
'is_separate' => $value['is_separate'],
'goods' => $goods_list,
'goods_count' => $goods_list?count($goods_list):0,
'total_orders_drpmoney' => price_format((round($value['goods_amount']*$level_per/100,2)), false),
'this_good_per' => $level_per."%"
);
}
}
die(json_encode(array('orders'=>$orders,'totalPage'=>ceil($countall/$size))));
}
$this->assign('page_title', "分销订单");
$this->display('drp_orders');
}
private function writeDrpLog($oid, $uid, $username, $money, $point,$i,$is, $separate_by)
{
$time = gmtime();
$sql = "INSERT INTO " . $GLOBALS['ecs']->table('drp_log') . "( order_id, user_id, user_name, time, money, point, drp_level,is_separate, separate_type)".
" VALUES ( '$oid', '$uid', '$username', '$time', '$money', '$point','$i','$is', $separate_by)";
if ($oid)
{
$GLOBALS['db']->query($sql);
}
}
private function upDrpLog($oid, $is)
{
$time = gmtime();
$sql = "UPDATE {pre}drp_log SET `is_separate` = $is WHERE order_id = $oid ";
if ($oid)
{
$GLOBALS['db']->query($sql);
}
}
public function actionOrderdetail(){
$oid = (int)$_REQUEST['order_id'];
$sql = "SELECT o.*, a.money, IFNULL(w.nickname,u.user_name) as user_name, a.point, a.drp_level FROM " . $GLOBALS['ecs']->table('drp_log') . " a".
" LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " o ON o.order_id = a.order_id" .
" LEFT JOIN".$GLOBALS['ecs']->table('users')." u ON o.user_id = u.user_id".
" LEFT JOIN".$GLOBALS['ecs']->table('wechat_user')." w ON w.ect_uid = u.user_id".
" WHERE a.user_id = $_SESSION[user_id] AND o.order_id = $oid AND o.pay_status = 2";
$res = $GLOBALS['db']->getRow($sql);
if(!$res){
ecs_header("Location: ".(U('drp/user/index')));
}
$goods_list = $this->getOrderGoods($res['order_id']);
$affiliate = unserialize($GLOBALS['_CFG']['affiliate']);
empty($affiliate) & & $affiliate = array();
$level_per = ((float)$affiliate['item'][$res['drp_level']]['level_money'])*($affiliate['config']['level_money_all'] /= 100);
foreach ($goods_list as $key => $val) {
$goods_list[$key]['price'] = $val['goods_price'];
$goods_list[$key]['goods_number'] = $val['goods_number'];
$goods_list[$key]['goods_thumb'] = get_image_path($val['goods_thumb']);
$goods_list[$key]['goods_url'] = U('goods/index/index', array('id' => $val['goods_id']));
}
foreach ($goods_list as $key => $val) {
$goods_list[$key]['this_good_drpmoney'] = (round($val['goods_price']*$level_per/100,2));
$goods_list[$key]['this_good_per'] = $level_per."%";
$goods_list[$key]['goods_price'] = price_format($val['goods_price'], false);
}
$orders = array(
'user_name' => $res['user_name'],
'order_sn' => $res['order_sn'],
'order_time' => date("Y-m-d H:i:s",($res['add_time']+date('Z'))),
'is_separate' => $res['is_separate'],
'goods' => $goods_list,
'goods_count' => $goods_list?count($goods_list):0,
'total_orders_drpmoney' => price_format((($res['goods_amount']-$res['discount'])*$level_per/100), false),
'this_good_per' => $level_per."%"
);
$this->assign('order', $orders);
$this->assign('page_title', '分销订单详情');
$this->display('drp_order_detail');
}
private function getOrderGoods($order_id = 0){
if($order_id > 0){
$sql = "select og.rec_id,og.goods_id,og.goods_name,og.goods_attr,og.goods_number,og.goods_price, g.goods_thumb from {pre}order_goods as og join {pre}goods as g on og.goods_id = g.goods_id where og.order_id=$order_id";
$goodsArr = model()->query($sql);
return $goodsArr;
}
}
/**
* html代码输出
*/
private function htmlOut($str)
{
if (function_exists('htmlspecialchars_decode')) {
$str = htmlspecialchars_decode($str);
} else {
$str = html_entity_decode($str);
}
$str = stripslashes($str);
return $str;
}
}
