diff --git a/api/controllers/plan/Syt.php b/api/controllers/plan/Syt.php
index 928463af..d0e64eb5 100644
--- a/api/controllers/plan/Syt.php
+++ b/api/controllers/plan/Syt.php
@@ -481,34 +481,28 @@ class Syt extends CI_Controller
 
     public function up_kpi_count(){
         $this->load->model('market/market_sylive_activity_kpidata_model','mdSytActivityKpiData');
+        $this->load->model('market/market_sylive_groups_user_model', 'groups_user_model');
         $this->load->library('market/sylive2_entity');
         $page = $this->input->get('page');
         $size = $this->input->get('size');
         $kpi = $this->input->get('kpi');
         $activityId = $this->input->get('activityId');
-        $cfUserId = $this->input->get('cfUserId');
 
         !$page && $page = 1;
         !$size && $size = 20;
 
         $where = [
             'activityId' => $activityId,
-            'kpi' => $kpi,
         ];
 
-        if($cfUserId){
-            $this->sylive2_entity->kpi_count($activityId,$kpi,$cfUserId);
-            echo "执行成功:{$val['id']}<br>";
-        }else{
-            $rows = $this->mdSytActivityKpiData->select($where,'id desc',$page,$size,'id,activityId,cfUserId');
-            if($rows){
-                foreach ($rows as $key => $val) {
-                    $val['cfUserId'] && $this->sylive2_entity->kpi_count($activityId,$kpi,$val['cfUserId']);
-                    echo "执行成功:{$val['id']}<br>";
-                }
-            }else{
-                echo '执行结束';
+        $rows = $this->groups_user_model->select($where,'id desc',$page,$size);
+        if($rows){
+            foreach ($rows as $key => $val) {
+                $this->sylive2_entity->kpi_count($activityId,$kpi,$val['userId']);
+                echo "执行成功:{$val['id']}<br>";
             }
+        }else{
+            echo '执行结束';
         }
     }