no message

services/activity_points.go

@@ -638,7 +638,24 @@ func YanXuanActivityPointsBillActivityPublishAndCancelReduce(log models.YanXuanA
 					}
 				}
 
+				pars = make([]interface{}, 0)
+				condition = ` AND activity_id = ?   `
+				pars = append(pars, activityId)
+				//获取扣点的流水记录
+				activityPointsBillList, e := models.GetCygxActivityPointsBillList(condition, pars)
+				if e != nil && e.Error() != utils.ErrNoRow() {
+					err = errors.New("GetCygxActivityPointsBillList" + e.Error())
+					return
+				}
+				mapUserBill := make(map[int]bool)
+				for _, v := range activityPointsBillList {
+					mapUserBill[v.UserId] = true
+				}
+
 				for _, user := range listSignup {
+					if !mapUserBill[user.UserId] {
+						continue // 如果用户的扣点记录不存在，那么就不进行返点处理
+					}
 					item := new(models.CygxActivityPointsBill)
 					item.ActivityId = activityId
 					item.CreateTime = time.Now()