修改

Controller/NewCommission/NewCommissionPartner.Class.php

@@ -61,7 +61,84 @@ class NewCommissionPartner extends BaseController
         
     }
     
+    public function getBalanceDetailList(){
+        $params = $this->request->getRawJson();
+        if(empty($params)){
+            $this->sendOutput('参数为空', ErrorCode::$paramError);
+        }
+        $selectParams = [];
+        $params['page'] = isset($params['page']) ? $params['page'] : 1;
+        $params['pageSize'] = isset($params['pageSize']) ? $params['pageSize'] : 10;
+        $pageParams = pageToOffset($params['page'], $params['pageSize']);
+        $selectParams['limit'] = $pageParams['limit'];
+        $selectParams['offset'] = $pageParams['offset'];
+
+        if(isset($params['search']) && !empty($params['search'])){
+            $selectParams['search'] = $params['search'];
+        }
+        $res = $this->partnerTool->getBalanceDetailList($selectParams);
+        $pageData = [
+            'pageIndex' => $params['page'],
+            'pageSize' => $params['pageSize'],
+            'pageTotal' => $res['total'],
+        ];
+        parent::sendOutput($res['data'], 0, $pageData);
+    }
     
+    public function getDetailList(){
+        $params = $this->request->getRawJson();
+        if(empty($params)){
+            $this->sendOutput('参数为空', ErrorCode::$paramError);
+        }
+        $selectParams = [];
+        $params['page'] = isset($params['page']) ? $params['page'] : 1;
+        $params['pageSize'] = isset($params['pageSize']) ? $params['pageSize'] : 10;
+        $pageParams = pageToOffset($params['page'], $params['pageSize']);
+        $selectParams['limit'] = $pageParams['limit'];
+        $selectParams['offset'] = $pageParams['offset'];
+
+        if(isset($params['search']) && !empty($params['search'])){
+            $selectParams['search'] = $params['search'];
+        }
+        $res = $this->partnerTool->getDetailList($selectParams);
+        $pageData = [
+            'pageIndex' => $params['page'],
+            'pageSize' => $params['pageSize'],
+            'pageTotal' => $res['total'],
+        ];
+        parent::sendOutput($res['data'], 0, $pageData);
+    }
     
+    public function getPartnerCashList(){
+        $params = $this->request->getRawJson();
+        if(empty($params)){
+            $this->sendOutput('参数为空', ErrorCode::$paramError);
+        }
+        $selectParams = [];
+        $params['page'] = isset($params['page']) ? $params['page'] : 1;
+        $params['pageSize'] = isset($params['pageSize']) ? $params['pageSize'] : 10;
+        $pageParams = pageToOffset($params['page'], $params['pageSize']);
+        $selectParams['limit'] = $pageParams['limit'];
+        $selectParams['offset'] = $pageParams['offset'];
 
+        if(isset($params['search']) && !empty($params['search'])){
+            $selectParams['search'] = $params['search'];
+        }
+        $res = $this->partnerTool->getPartnerCashList($selectParams);
+        $pageData = [
+            'pageIndex' => $params['page'],
+            'pageSize' => $params['pageSize'],
+            'pageTotal' => $res['total'],
+        ];
+        parent::sendOutput($res['data'], 0, $pageData);
+    }
+    
+    /**
+     * 处理提现
+     */
+    public function partnerCashAudit(){
+        
+    }
+    
+    
 }

Util/Common/PartnerTools.Class.php

@@ -777,7 +777,7 @@ class PartnerTools{
         $sql = "select {$field} from {$newCommissionPartnerTableName} p "
         . "left join {$userCenterTableName} u on u.id = p.userCenterId "
         . "left join {$customerTableName} c on c.id = p.customerId";
-        $whereSql = 'p.deleteStatus = 5';
+        $whereSql = ' where p.deleteStatus = 5 ';
         if(isset($params['search'])){
             $whereSql .= ' and (u.mobile like "%'.$params['search'].'%" or c.name like "%'.$params['search'].'%") ';
         }
@@ -800,6 +800,124 @@ class PartnerTools{
         return ['data'=>$data,'total'=>($total) ? intval($total) : 0];
     }
     
+    /**
+     * 获取合伙人余额明细列表
+     * @param type $params
+     */
+    public function getBalanceDetailList($params = []){
+        $customerTableName = 'qianniao_customer_'.$this->enterpriseId;
+        $userCenterTableName = 'qianniao_user_center';
+//        $newCommissionPartnerTableName = 'qianniao_new_commission_partner_'.$this->enterpriseId;
+        $newCommissionBalanceDetailTableName = 'qianniao_new_commission_balance_detail_'.$this->enterpriseId;
+        //查询数据
+        $field = "p.*,u.mobile,c.name,c.avatar";
+        $sql = "select {$field} from {$newCommissionBalanceDetailTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.user_center_id "
+        . "left join {$customerTableName} c on c.id = p.customer_id";
+        $whereSql = ' where p.id>0 ';
+        if(isset($params['search'])){
+            $whereSql .= ' and (u.mobile like "%'.$params['search'].'%" or c.name like "%'.$params['search'].'%") ';
+        }
+        $orderSql = ' order by p.id desc ';
+        $limitSql = ' limit '.$params['offset'].','.$params['limit'];
+        $querySql = $sql.$whereSql.$orderSql.$limitSql;
+        $data = $this->dbNewCommissionPartner->query($querySql);
+        if(empty($data)){
+            $data=[];
+        }
+        //查询总数
+        $countSql = "select count(*) as `count` from {$newCommissionBalanceDetailTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.user_center_id "
+        . "left join {$customerTableName} c on c.id = p.customer_id";
+        $countData = $this->dbNewCommissionPartner->query($countSql.$whereSql);
+        $total = 0;
+        if(!empty($countData)){
+            $total =array_shift($countData)['count'];
+        }
+        return ['data'=>$data,'total'=>($total) ? intval($total) : 0];
+    }
+    /**
+     * 获取合伙人佣金记录
+     * @param type $params
+     */
+    public function getDetailList($params = []){
+        $customerTableName = 'qianniao_customer_'.$this->enterpriseId;
+        $userCenterTableName = 'qianniao_user_center';
+//        $newCommissionPartnerTableName = 'qianniao_new_commission_partner_'.$this->enterpriseId;
+//        $newCommissionBalanceDetailTableName = 'qianniao_new_commission_balance_detail_'.$this->enterpriseId;
+        $newCommissionDetailTableName = 'qianniao_new_commission_detail_'.$this->enterpriseId;
+        //查询数据
+        $field = "p.*,u.mobile,c.name,c.avatar,c2.name as sourceName,c2.userCenterId as sourceUserCenterId ";
+        $sql = "select {$field} from {$newCommissionDetailTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.userCenterId "
+        . "left join {$customerTableName} c on c.id = p.customerId "
+        . "left join {$customerTableName} c2 on c2.id = p.sourceCustomerId";
+        
+        $whereSql = ' where p.id>0 ';
+        if(isset($params['search'])){
+            $whereSql .= ' and (u.mobile like "%'.$params['search'].'%" or c.name like "%'.$params['search'].'%") ';
+        }
+        $orderSql = ' order by p.id desc ';
+        $limitSql = ' limit '.$params['offset'].','.$params['limit'];
+        $querySql = $sql.$whereSql.$orderSql.$limitSql;
+        $data = $this->dbNewCommissionPartner->query($querySql);
+        if(empty($data)){
+            $data=[];
+        }
+        //查询总数
+        $countSql = "select count(*) as `count` from {$newCommissionDetailTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.userCenterId "
+        . "left join {$customerTableName} c on c.id = p.customerId "
+        . "left join {$customerTableName} c2 on c2.id = p.sourceCustomerId";
+        $countData = $this->dbNewCommissionPartner->query($countSql.$whereSql);
+        $total = 0;
+        if(!empty($countData)){
+            $total =array_shift($countData)['count'];
+        }
+        return ['data'=>$data,'total'=>($total) ? intval($total) : 0];
+    }
+    
+    /**
+     * 获取提现记录
+     * @param type $params
+     */
+    public function getPartnerCashList($params = []){
+        $customerTableName = 'qianniao_customer_'.$this->enterpriseId;
+        $userCenterTableName = 'qianniao_user_center';
+//        $newCommissionPartnerTableName = 'qianniao_new_commission_partner_'.$this->enterpriseId;
+//        $newCommissionBalanceDetailTableName = 'qianniao_new_commission_balance_detail_'.$this->enterpriseId;
+//        $newCommissionDetailTableName = 'qianniao_new_commission_detail_'.$this->enterpriseId;
+        $newCommissionCashTableName = 'qianniao_new_commission_cash_'.$this->enterpriseId;
+        //查询数据
+        $field = "p.*,u.mobile,c.name,c.avatar ";
+        $sql = "select {$field} from {$newCommissionCashTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.user_center_id "
+        . "left join {$customerTableName} c on c.id = p.customer_id ";
+        
+        $whereSql = ' where p.id>0 ';
+        if(isset($params['search'])){
+            $whereSql .= ' and (u.mobile like "%'.$params['search'].'%" or c.name like "%'.$params['search'].'%") ';
+        }
+        $orderSql = ' order by p.id desc ';
+        $limitSql = ' limit '.$params['offset'].','.$params['limit'];
+        $querySql = $sql.$whereSql.$orderSql.$limitSql;
+        $data = $this->dbNewCommissionPartner->query($querySql);
+        if(empty($data)){
+            $data=[];
+        }
+        //查询总数
+        $countSql = "select count(*) as `count` from {$newCommissionCashTableName} p "
+        . "left join {$userCenterTableName} u on u.id = p.user_center_id "
+        . "left join {$customerTableName} c on c.id = p.customer_id ";
+        $countData = $this->dbNewCommissionPartner->query($countSql.$whereSql);
+        $total = 0;
+        if(!empty($countData)){
+            $total =array_shift($countData)['count'];
+        }
+        return ['data'=>$data,'total'=>($total) ? intval($total) : 0];
+    }
+    
+