From 0ab655b9c4663e84b0c851ea8e6227fe4fc94acf Mon Sep 17 00:00:00 2001
From: meixiongfeng <766881921@qq.com>
Date: Mon, 13 Jun 2022 18:03:35 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E6=93=8D=E4=BD=9C?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E5=AE=9A=E4=B9=89=E6=9E=9A=E4=B8=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 comm/imodule.go          |  3 +++
 modules/core.go          |  8 ++++++++
 modules/model/db_comp.go | 15 +++++++++++----
 3 files changed, 22 insertions(+), 4 deletions(-)

diff --git a/comm/imodule.go b/comm/imodule.go
index b1dae9bd5..ca189ce05 100644
--- a/comm/imodule.go
+++ b/comm/imodule.go
@@ -18,4 +18,7 @@ type (
 		///添加多个物品到背包 (可以加物品和减物品)
 		AddItemsToUserPack(uId string, items map[int32]int32) (err error)
 	}
+	Imodel interface {
+		AddModelLogs() (err error)
+	}
 )
diff --git a/modules/core.go b/modules/core.go
index b0befc809..67c01759c 100644
--- a/modules/core.go
+++ b/modules/core.go
@@ -17,3 +17,11 @@ type (
 		SendMsgToUsers(mainType, subType string, msg proto.Message, user ...*pb.Cache_UserData) (err error)
 	}
 )
+
+type LogHandleType string
+
+const (
+	LogHandleType_Insert LogHandleType = "insert"
+	LogHandleType_Update LogHandleType = "update"
+	LogHandleType_Delete LogHandleType = "delete"
+)
diff --git a/modules/model/db_comp.go b/modules/model/db_comp.go
index 09c04d01a..fa8ad297b 100644
--- a/modules/model/db_comp.go
+++ b/modules/model/db_comp.go
@@ -7,6 +7,7 @@ import (
 	"go_dreamfactory/lego/core/cbase"
 	"go_dreamfactory/lego/sys/log"
 	"go_dreamfactory/lego/sys/mgo"
+	"go_dreamfactory/modules"
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo/options"
@@ -27,6 +28,12 @@ type Autogenerated struct {
 	D   []interface{}
 }
 
+// type data struct {
+// 	Table     string
+// 	Wheremap  map[string]interface{} // 如果是insert 条件就是nil del 只有条件
+// 	Modifymap map[string]map[string]interface{}
+// }
+
 type QueryStruct struct {
 	Selector bson.M
 	Query    bson.M
@@ -59,7 +66,7 @@ func (this *DB_Comp) Model_UpdateDBBylog() (err error) {
 		}
 
 		log.Debugf("======= insert log : %+v =======", data)
-		if data.Act == "insert" {
+		if data.Act == string(modules.LogHandleType_Insert) {
 			if len(data.D) < 2 { // 参数校验
 				log.Errorf("parameter len _id : %s,uid : %s d.len:%v", data.ID, data.UID, len(data.D))
 				return errors.New("parameter len err")
@@ -69,7 +76,7 @@ func (this *DB_Comp) Model_UpdateDBBylog() (err error) {
 			if err != nil {
 				log.Errorf("insert %s db err:%v", data.D[0].(core.SqlTable), err)
 			}
-		} else if data.Act == "delete" {
+		} else if data.Act == string(modules.LogHandleType_Delete) {
 			if len(data.D) < 2 { // 参数校验
 				log.Errorf("parameter len _id : %s,uid : %s d.len:%v", data.ID, data.UID, len(data.D))
 				return errors.New("parameter len err")
@@ -129,7 +136,7 @@ func (this *DB_Comp) Model_UpdateUserDataByUid(uid string) (err error) {
 		}
 
 		log.Debugf("======= insert log : %+v =======", data)
-		if data.Act == "insert" {
+		if data.Act == string(modules.LogHandleType_Insert) {
 			if len(data.D) < 2 { // 参数校验
 				log.Errorf("parameter len _id : %s,uid : %s d.len:%v", data.ID, data.UID, len(data.D))
 				return errors.New("parameter len err")
@@ -139,7 +146,7 @@ func (this *DB_Comp) Model_UpdateUserDataByUid(uid string) (err error) {
 			if err != nil {
 				log.Errorf("insert %s db err:%v", data.D[0].(core.SqlTable), err)
 			}
-		} else if data.Act == "delete" {
+		} else if data.Act == string(modules.LogHandleType_Delete) {
 			if len(data.D) < 2 { // 参数校验
 				log.Errorf("parameter len _id : %s,uid : %s d.len:%v", data.ID, data.UID, len(data.D))
 				return errors.New("parameter len err")