|
@@ -57,11 +57,11 @@ func LotteryDrawTask(msg *model.Message) {
|
|
|
//判断用户是否存在
|
|
//判断用户是否存在
|
|
|
data, ok := db.Mgo.FindById("user", msg.E_userId, `{"l_registedate":1,"s_phone":1,"s_m_phone":1}`)
|
|
data, ok := db.Mgo.FindById("user", msg.E_userId, `{"l_registedate":1,"s_phone":1,"s_m_phone":1}`)
|
|
|
if data == nil || len(*data) == 0 || !ok {
|
|
if data == nil || len(*data) == 0 || !ok {
|
|
|
- logger.Info(fmt.Sprintf("未找到用户%s, %v。", msg.E_userId, msgBody.TaskInfoId))
|
|
|
|
|
|
|
+ logger.Info(fmt.Sprintf("未找到用户:%s, 任务id:%d。", msg.E_userId, msgBody.TaskInfoId))
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
//任务信息
|
|
//任务信息
|
|
|
- taskInfos := db.Mysql.SelectBySql(fmt.Sprintf("SELECT lti.*,ai.start_time,ai.end_time FROM %s lti LEFT JOIN %s ai ON lti.active_id = ai.id WHERE lti.active_id = ? AND lti.id = ? AND ai.end_time >= NOW() ORDER BY lti.create_date ORDER BY lti.create_date DESC", tableTaskInfo, tableActivityInfo), msgBody.ActiveId, msgBody.TaskInfoId)
|
|
|
|
|
|
|
+ taskInfos := db.Mysql.SelectBySql(fmt.Sprintf("SELECT lti.*,ai.start_time,ai.end_time FROM %s lti LEFT JOIN %s ai ON lti.active_id = ai.id WHERE lti.active_id = ? AND lti.id = ? AND ai.end_time >= NOW() ORDER BY lti.create_date DESC", tableTaskInfo, tableActivityInfo), msgBody.ActiveId, msgBody.TaskInfoId)
|
|
|
if taskInfos == nil || len(*taskInfos) == 0 {
|
|
if taskInfos == nil || len(*taskInfos) == 0 {
|
|
|
logger.Info(fmt.Sprintf("没有当前需要完成的任务信息：%v", msgBody))
|
|
logger.Info(fmt.Sprintf("没有当前需要完成的任务信息：%v", msgBody))
|
|
|
return
|
|
return
|
