修正余额更新

application/api/controller/Index.php

@@ -30,9 +30,18 @@ class Index extends Api
     }
     //跟新收益
     public function upincome(){
-        $recorddata=  $this->recordModel->field('sum(income) as income ,uid as id')->where(['status'=>0])->group('uid')->select();
+
+        $maxId = $this->recordModel->max('id');
+
+        $recorddata=  $this->recordModel
+            ->field('sum(income) as income ,uid as id')
+            ->where("id", "<=", $maxId)
+            ->where(['status'=>0])
+            ->group('uid')
+            ->select();
         $temp=$userids=[];
         $returndata='1';
+        Db::startTrans();
         if($recorddata){
             $returndata='12';
             foreach ($recorddata as $key=>$val){
@@ -49,9 +58,10 @@ class Index extends Api
             if($upincome){
                 $returndata='123';
                 $this->adminModel->saveAll($upincome);
-                $this->recordModel->where(['status'=>0])->update(['status'=>1]);
+                $this->recordModel->where("id", "<=", $maxId)->where(['status'=>0])->update(['status'=>1]);
             }
         }
+        Db::commit();
         return $returndata;
     }
     /**