撤销成交报告同步所有人的业绩

application/index/controller/Finance.php

@@ -1938,7 +1938,7 @@ class Finance extends Basic
         if ($result) {
             $code = 200;
             $this->editRecordLog($this->params['bargain_id'], '[撤销成交报告]', 3); //日志记录
-            $this->updatePerformance($this->params['bargain_id']);
+            $this->updatePerformanceAll($this->params['bargain_id']);
 
             $bargain_data                  = $this->m_bargain->getBargainDetail('order_id,order_no,agent_id', [ 'id' => $this->params['bargain_id'] ]);
             $financial_data['bargain_id']  = $this->params['bargain_id'];
@@ -1990,6 +1990,29 @@ class Finance extends Basic
         return true;
     }
 
+    /**
+     * 更新多人业绩
+     *
+     * @param int $bargain_id
+     * @return bool
+     */
+    private function updatePerformanceAll(int $bargain_id = 0): bool
+    {
+        $where = [];
+        if ($bargain_id) {
+            $where['b.id'] = $bargain_id;
+        }
+        if (!empty($where)) {
+            //获取被修改人信息
+            $m_agent    = new AAgents();
+            $agent_data = $m_agent->agentBargainAll('a.id,a.store_id,a.district_id,b.create_time', $where);
+            foreach ($agent_data as $v) {
+                $this->updatePerformanceData($v['id'], $v['create_time'], $v['store_id'],$v['district_id']);
+            }
+        }
+        return true;
+    }
+
     private function updatePerformanceData($id, $create_time, $store_id, $district_id) {
         //更新业绩统计
         $sum = new ResultsSummaryNewTask();

application/model/AAgents.php

@@ -1221,6 +1221,24 @@ class AAgents extends BaseModel
         return $data;
     }
 
+    /**
+     * @param $field
+     * @param $where
+     * @return array|false|\PDOStatement|string|\think\Model
+     */
+    public function agentBargainAll($field, $where) {
+        try {
+            $data = $this->alias('a')
+                ->field($field)
+                ->join('o_bargain b', 'a.id = b.agent_id', 'left')
+                ->where($where)
+                ->select();
+        } catch (\Exception $e) {
+            $data = [];
+        }
+        return $data;
+    }
+
     /**
      * 获取绑定号码
      *