111

controllers/admin_api_controllers/custom_api_controller.go

@@ -842,13 +842,17 @@ func (this *CustomAPIController) DeleteFollowInfo() {
 }
 func (this *CustomAPIController) CheckFollowInfo() {
 	id, _ := this.GetInt64("id")
-	follow, _ := service.FindChargeFollowInfo(id)
-	if follow.ID == 0 {
+	follow, _ := service.FindChargeFollowInfoTwo(id)
+	if len(follow) == 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
-	follow.IsCheck = 1
-	err := service.SaveChargeFollow(&follow)
+	var ids []int64
+	for _, item := range follow {
+
+		ids = append(ids, item.ID)
+	}
+	err := service.CheckChargeFollowTwo(ids)
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return

service/custom_service.go

@@ -122,11 +122,20 @@ func SaveChargeFollow(chargeFollow *models.KyyChargeFollow) (err error) {
 	return
 }
 
+func CheckChargeFollowTwo(ids []int64) (err error) {
+	err = ChargeWriteDB().Model(&models.KyyChargeFollow{}).Where("id in (?)", ids).Updates(map[string]interface{}{"is_check": 1}).Error
+	return
+}
+
 func FindChargeFollowInfo(id int64) (cf models.KyyChargeFollow, err error) {
 	err = ChargeReadDB().Model(&models.KyyChargeFollow{}).Where("id = ? AND status = 1", id).First(&cf).Error
 	return
 }
 
+func FindChargeFollowInfoTwo(id int64) (cf []models.KyyChargeFollow, err error) {
+	err = ChargeReadDB().Model(&models.KyyChargeFollow{}).Where("custom_id = ? AND status = 1", id).First(&cf).Error
+	return
+}
 func SaveChargeDemand(cd *models.KyyChargeDemand) (err error) {
 	err = ChargeWriteDB().Save(&cd).Error
 	return