From cccd6fc8868fecfda311b6df777b7586f52bd6e4 Mon Sep 17 00:00:00 2001 From: shoopea Date: Sat, 18 May 2019 19:21:23 +0800 Subject: [PATCH] test --- def.go | 4 ++++ sql.go | 4 ++++ workers.go | 12 ++++++++++++ 3 files changed, 20 insertions(+) diff --git a/def.go b/def.go index 669150d..3610ace 100644 --- a/def.go +++ b/def.go @@ -178,6 +178,10 @@ const ( objSubTypeMessageTimeAck = 322 objSubTypeMessageTimeReq = 323 objSubTypeMessageGo = 324 + objSubTypeMessageGoQuest = 325 + objSubTypeMessageGoArena = 326 + objSubTypeMessageArena = 327 + objSubTypeMessageTop = 328 objSubTypeJobPillage = 601 objSubTypeJobTribute = 602 objSubTypeJobStatus = 603 diff --git a/sql.go b/sql.go index 92509df..9ea0064 100644 --- a/sql.go +++ b/sql.go @@ -324,6 +324,10 @@ func initDB() { ,(` + strconv.Itoa(objSubTypeMessageTimeAck) + `, "time_ack", "Time Acknowledgment", ` + strconv.Itoa(objTypeMessage) + `) ,(` + strconv.Itoa(objSubTypeMessageTimeReq) + `, "time_req", "Time Request", ` + strconv.Itoa(objTypeMessage) + `) ,(` + strconv.Itoa(objSubTypeMessageGo) + `, "go", "Go", ` + strconv.Itoa(objTypeMessage) + `) + ,(` + strconv.Itoa(objSubTypeMessageGoQuest) + `, "go_quest", "Go quest", ` + strconv.Itoa(objTypeMessage) + `) + ,(` + strconv.Itoa(objSubTypeMessageGoArena) + `, "go_arena", "Go arena", ` + strconv.Itoa(objTypeMessage) + `) + ,(` + strconv.Itoa(objSubTypeMessageArena) + `, "arena", "Arena", ` + strconv.Itoa(objTypeMessage) + `) + ,(` + strconv.Itoa(objSubTypeMessageTop) + `, "top", "Top", ` + strconv.Itoa(objTypeMessage) + `) ,(` + strconv.Itoa(objSubTypeJobPillage) + `, "job_pillage", "Pillage job", ` + strconv.Itoa(objTypeJob) + `) ,(` + strconv.Itoa(objSubTypeJobTribute) + `, "job_tribute", "Tribute job", ` + strconv.Itoa(objTypeJob) + `) ,(` + strconv.Itoa(objSubTypeJobWithdrawal) + `, "job_withdraw", "Withdrawal job", ` + strconv.Itoa(objTypeJob) + `) diff --git a/workers.go b/workers.go index eff1fd2..0407097 100644 --- a/workers.go +++ b/workers.go @@ -144,6 +144,18 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { case objSubTypeMessageQuest: err = setObjSubTypeId(objId, objSubTypeMessageQuest) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(Quest)") + case objSubTypeMessageGoQuest: + err = setObjSubTypeId(objId, objSubTypeMessageQuest) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(GoQuest)") + case objSubTypeMessageArena: + err = setObjSubTypeId(objId, objSubTypeMessageQuest) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(Arena)") + case objSubTypeMessageGoArena: + err = setObjSubTypeId(objId, objSubTypeMessageQuest) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(GoArena)") + case objSubTypeMessageTop: + err = setObjSubTypeId(objId, objSubTypeMessageQuest) + logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(Top)") case objSubTypeMessageAuctionAnnounce: cwm := ChatWarsMessageAuctionAnnounce{ ObjID64: objId,