update 一个圈圈

rule/one_circles/one_circles_sign_in_green_energy_settlement.go

@@ -46,6 +46,7 @@ func SettlementSignInGreenEnergy(engine *xorm.Engine, masterId string, ch *rabbi
 			break
 		}
 
+		var ids []int64
 		for _, v := range list {
 			//TODO::推入rabbitmq 异步处理
 			ch.Publish(md.OneCirclesExchange, md.OneCirclesStructForSignIn{
@@ -53,6 +54,13 @@ func SettlementSignInGreenEnergy(engine *xorm.Engine, masterId string, ch *rabbi
 				Uid:      v.Uid,
 				Id:       v.Id,
 			}, md.OneCirclesRoutKeyForSignIn)
+			ids = append(ids, v.Id)
+		}
+		//6、更新 `one_circles_green_energy_sign_in` 中的 is_completed 状态
+		if len(ids) > 0 {
+			_, err = engine.In("id", ids).Update(&model.OneCirclesGreenEnergySignIn{
+				IsCompleted: 1,
+			})
 		}
 		page++
 		time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000)))
@@ -176,10 +184,6 @@ func HandleSettlementSignInGreenEnergy(engine *xorm.Engine, masterId string, id
 		}
 	}
 
-	//6、更新 `one_circles_green_energy_sign_in` 中的 is_completed 状态
-	_, err = engine.Where("id = ?", id).Update(&model.OneCirclesGreenEnergySignIn{
-		IsCompleted: 1,
-	})
 	if err != nil {
 		_ = session.Rollback()
 		fmt.Println("err:::::1111", err)