|
@@ -138,7 +138,7 @@ func (jm *JobManager) FilterPayUserAndSaveDb(ctx context.Context, value interfac
|
|
|
return nil
|
|
return nil
|
|
|
}
|
|
}
|
|
|
operationTime = time.Unix(msg.TimeStamp, 0).Format(time.DateTime)
|
|
operationTime = time.Unix(msg.TimeStamp, 0).Format(time.DateTime)
|
|
|
- sql += `(mogUserId,register_time,phone,bind_phone_date,create_time)VALUES (?,?,?,?,?)ON DUPLICATE KEY UPDATE phone=?, bind_phone_date=?`
|
|
|
|
|
|
|
+ sql += `(mogUserId,register_time,bind_phone_date,create_time)VALUES (?,?,?,?,?)ON DUPLICATE KEY UPDATE bind_phone_date=?`
|
|
|
val = append(val, msg.MgoUserID, jm.GetAndCacheRegisterDate(msg.MgoUserID), msg.Phone, operationTime, now, msg.Phone, operationTime)
|
|
val = append(val, msg.MgoUserID, jm.GetAndCacheRegisterDate(msg.MgoUserID), msg.Phone, operationTime, now, msg.Phone, operationTime)
|
|
|
} else if msg, ok := value.(*public.NewActiveMsg); ok {
|
|
} else if msg, ok := value.(*public.NewActiveMsg); ok {
|
|
|
if jm.payUser.Contains(msg.MgoUserID) {
|
|
if jm.payUser.Contains(msg.MgoUserID) {
|
