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")