diff --git a/modules/caravan/module.go b/modules/caravan/module.go index f06b0ac35..ff018553a 100644 --- a/modules/caravan/module.go +++ b/modules/caravan/module.go @@ -225,7 +225,7 @@ func (this *Caravan) refreshCaravanCityInfo(uid string, caravan *pb.DBCaravan) { // 校验随机事件是否超时 func (this *Caravan) CheckCaravanTask(session comm.IUserSession, data *pb.DBCaravan) (bTimeOut bool) { - if data.Eventid != 0 { + if data.Tasktime != 0 { if list, err := this.configure.GetCaravanEventById(data.Eventid); err == nil { // 校验任务是否超时 if configure.Now().Unix()-data.Tasktime > int64(list.Eventtime) { //TODO 任务超时 通知任务模块处理 并清理相关数据 @@ -238,6 +238,14 @@ func (this *Caravan) CheckCaravanTask(session comm.IUserSession, data *pb.DBCara } this.CleanCaravanTask(session.GetUserId(), data) //任务超时 清理任务数据 + data.Eventid = 0 + data.Tasktime = 0 + data.Eventid = 0 + update := make(map[string]interface{}) + update["eventid"] = data.Eventid + update["tasktime"] = data.Tasktime + update["eventid"] = data.Eventid + this.modelCaravan.modifyCaravanDataByObjId(session.GetUserId(), update) // 任务超时发送任务失败推送 resp := &pb.CaravanTaskCompletePush{} resp.Data = data