From 239c45db8ad50662dca83d5baf72c9f2d98d4fae Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 10 May 2019 19:33:29 +0800
Subject: [PATCH] test

---
 def.go |  4 ++++
 sql.go | 31 +++++++++++++++++++++++++++++++
 2 files changed, 35 insertions(+)

diff --git a/def.go b/def.go
index ef13bd8..77f4529 100644
--- a/def.go
+++ b/def.go
@@ -66,6 +66,9 @@ type JobPayloadRescanMsg struct {
 	MsgID64 int64 `json:"msg_id"`
 }
 
+type JobPayloadRescanAllMsg struct {
+}
+
 const (
 	objTypeUser      = 1
 	objTypeGuild     = 2
@@ -100,6 +103,7 @@ const (
 	objSubTypeJobWithdrawal          = 604
 	objSubTypeJobGStock              = 605
 	objSubTypeJobRescanMsg           = 606
+	objSubTypeJobRescanAllMsg        = 607
 	objSubTypeItemResource           = 701
 	objSubTypeItemAlch               = 702
 	objSubTypeItemMisc               = 703
diff --git a/sql.go b/sql.go
index e2c66d7..4bbaa49 100644
--- a/sql.go
+++ b/sql.go
@@ -1324,6 +1324,37 @@ func insertMsgAuctionAnnounce(m *ChatWarsMessageAuctionAnnounce) error {
 	return nil
 }
 
+func createJob(job_type_id int32, payload []byte) error {
+	/*
+		res, err := db.Exec(`INSERT INTO obj (obj_type_id, obj_sub_type_id)
+							          VALUES (` + strconv.Itoa(objTypeMessage) + `,` + strconv.Itoa(objSubTypeMessageUnknown) + `);`)
+		if err != nil {
+			return 0, err
+		}
+
+		objId, err := res.LastInsertId()
+		if err != nil {
+			return 0, err
+		}
+
+		stmt, err := db.Prepare(`INSERT INTO obj_msg	(obj_id, msg_id, chat_id, user_id, sender_user_id, date, text)
+								 VALUES 				(?,      ?,      ?,       ?,       ?,              ?,    ?);`)
+		if err != nil {
+			return 0, err
+		}
+		defer stmt.Close()
+
+		_, err = stmt.Exec(objId, m.ID64, m.ChatID64, m.UserID64, m.SenderUserID64, m.Date, m.Text)
+		if err != nil {
+			return 0, err
+		}
+
+		return objId, nil
+	*/
+	return nil
+
+}
+
 func loadMsgParsingRules() (m map[int]MessageParsingRule, err error) {
 	var (
 		id        int32