liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge branch 'dev' of http://git.legu.cc/liwei_3d/go_dreamfactory into dev

Browse Source
This commit is contained in:
liwei1dao 2022-06-13 19:23:55 +08:00
commit eefe70d23d
3 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
comm/imodule.go
View File

@ -18,4 +18,7 @@ type (
///添加多个物品到背包 (可以加物品和减物品)
AddItemsToUserPack(uId string, items map[int32]int32) (err error)
}
Imodel interface {
AddModelLogs() (err error)
}
)

8
modules/core.go
View File

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

15
modules/model/db_comp.go
View File

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