|
@@ -49,10 +49,10 @@ func Task(ctx context.Context) {
|
|
|
}
|
|
}
|
|
|
userList := []entity.NewUserSendLog{}
|
|
userList := []entity.NewUserSendLog{}
|
|
|
for j := 0; j < count; j += 200 {
|
|
for j := 0; j < count; j += 200 {
|
|
|
- // 分页查跟进规则查询要发送的用户
|
|
|
|
|
|
|
+ // 查跟进规则查询要发送的用户
|
|
|
err := dao.NewUserSendLog.Ctx(ctx).Where("rule_id=? and state=?", sendContent[i].RuleId, 0).Limit(200).Scan(&userList)
|
|
err := dao.NewUserSendLog.Ctx(ctx).Where("rule_id=? and state=?", sendContent[i].RuleId, 0).Limit(200).Scan(&userList)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
- g.Log().Error(ctx, "分页-获取待发送用户失败", sendContent[i].RuleId, err)
|
|
|
|
|
|
|
+ g.Log().Error(ctx, "获取待发送用户失败", sendContent[i].RuleId, err)
|
|
|
break
|
|
break
|
|
|
}
|
|
}
|
|
|
// 发送消息
|
|
// 发送消息
|
