收佣日期统计

application/index/controller/Finance.php

@@ -1008,7 +1008,7 @@ class Finance extends Basic
         $check     = new VipService();
         $data      = $this->params["commission_date"];
 
-        $add_arr = $update_arr = $log_data = [];
+        $add_arr = $update_arr = $log_data = $real_income_id = [];
         $i       = $j = 0;
         foreach ($data as $item) {
             if (!isset($item['practical_fee']) || !isset($item['cash']) || !isset($item['service_charge']) ||
@@ -1087,6 +1087,10 @@ class Finance extends Basic
                     'create_time' => $bargain_data['create_time'],
                 ];
             }
+
+            if (!empty($item['real_income_id'])) {
+                $real_income_id[] = $item['real_income_id'];
+            }
         }
 
         if ($j > 0) {
@@ -1113,6 +1117,15 @@ class Finance extends Basic
                 $update_data['agent_id']  = $v['agent_id'];
                 $this->m_bargain->updateBargainById($v['bargain_id'], $update_data);
                 $this->updatePerformanceData($v['agent_id'], $v['create_time'], $v['store_id'], $v['district_id']);
+
+                //todo 收佣日期统计
+                if (!empty($real_income_id)) {
+                    $m_real = new ORealIncome();
+                    $income_time = $m_real->getBargainTaxesColumn('income_time', ['id'=> ['in', array_unique($real_income_id)]]);
+                    foreach ($income_time as $v2) {
+                        $this->updatePerformanceData($v['agent_id'], $v2, $v['store_id'], $v['district_id']);
+                    }
+                }
             }
         }
         // $data = $m_partial->addCommission($this->params, $this->userId);

application/model/ORealIncome.php

@@ -37,6 +37,17 @@ class ORealIncome extends BaseModel
             ->select();
     }
 
+    /**
+     * @param int $field
+     * @param array $where
+     * @return array
+     */
+    public function getBargainTaxesColumn($field, array $where) {
+        return $this->field($field)
+            ->where($where)
+            ->column($field);
+    }
+
     /**
      * @param string $field
      * @param $where