更新

application/model/CActivity.php

@@ -19,11 +19,15 @@ class CActivity extends Model
         return $this->insert($data);
     }
 
-    public function getActivity()
+    /**
+     * 查询
+     * @param $field
+     * @param $params
+     * @return false|\PDOStatement|string|\think\Collection
+     */
+    public function getActivity($field,$params)
     {
-        $field = 'id,activity_start_time,activity_end_time,available,get_number';
         $params['status'] = 0;
-
         $result = Db::table($this->table)
             ->field($field)
             ->where($params)
@@ -33,7 +37,10 @@ class CActivity extends Model
     }
 
     /**
-     * 更新数据
+     * 更新
+     * @param $activity_id
+     * @param $status
+     * @return $this
      */
     public function updateStatus($activity_id,$status)
     {

application/task/controller/UpdateActivityTask.php

@@ -44,7 +44,8 @@ class UpdateActivityTask
         //
         // $res = $this->m_active->addActivity($insert);//int(1)
 
-        $active_list = $this->m_active->getActivity();
+        $field = 'id,activity_start_time,activity_end_time,available,get_number';
+        $active_list = $this->m_active->getActivity($field,[]);
         if(!$active_list){
             exit;
         }