读取日志信息 并更新对应的db

sys/cache/mail.go

@@ -1,30 +0,0 @@
-package cache
-
-import (
-	"go_dreamfactory/pb"
-	"go_dreamfactory/sys/db"
-)
-
-// 邮件暂时不写redis
-const ( //Redis
-	Redis_MailCache string = "mail:%s"
-)
-
-type IMail interface {
-	QueryUserMail(uId string) (mail []*pb.DB_MailData, err error)
-}
-
-// 查询玩家邮件数据
-func (this *Cache) QueryUserMail(uId string) (mail []*pb.DB_MailData, err error) {
-	// var result []interface{}
-	// if result, err = this.redis.HGetAll(fmt.Sprintf(Redis_MailCache, uId), reflect.TypeOf(&pb.DB_MailData{})); err != nil {
-	// 	return
-	// } else {
-	// 	mail = make([]*pb.DB_MailData, len(result))
-	// 	for i, v := range result {
-	// 		mail[i] = v.(*pb.DB_MailData)
-	// 	}
-	// }
-	mail, _ = db.Defsys.Mail_QueryUserMail(uId)
-	return
-}

sys/db/model.go

@@ -0,0 +1,84 @@
+package db
+
+import (
+	"errors"
+	"go_dreamfactory/lego/core"
+	"go_dreamfactory/lego/sys/log"
+
+	"go.mongodb.org/mongo-driver/bson"
+)
+
+type Autogenerated struct {
+	ID  string `json:"_id"`
+	UID string `json:"uid"`
+	Act string `json:"act"` // insert update delete
+	D   []interface{}
+}
+
+// type data struct {
+// 	Table      string
+// 	Wheremap   [map[string]]interface{} // 如果是insert 条件就是nil del 只有条件
+// 	Modifymap  map[string]map[string]interface{}
+// 	insertData []interface{}
+// }
+
+type QueryStruct struct {
+	Selector bson.M
+	Query    bson.M
+}
+
+const (
+	DB_ModelTable core.SqlTable = "model"
+)
+
+type IModel interface {
+	Model_UpdateDBBylog() (err error)                    // 读取日志并更新对应的表
+	Model_InsertDBBylog(data *Autogenerated) (err error) // 插入日志
+	Model_UpdateUserDataByUid(uid string) (err error)    // 读取指定玩家信息到db中
+}
+
+func (this *DB) Mail_UpdateDBBylog() (err error) {
+	data := &Autogenerated{}
+	this.mgo.FindOneAndDelete(DB_ModelTable, bson.M{}).Decode(data) // 查找最新的一条并且删除
+
+	log.Debugf("======= insert log : %+v =======", data)
+	if data.Act == "insert" {
+		query := data.D[1].([]interface{})
+
+		_, err := this.mgo.InsertMany(data.D[0].(core.SqlTable), query)
+		if err != nil {
+			log.Errorf("insert %s db err:%v", data.D[0].(core.SqlTable), err)
+		}
+	} else if data.Act == "delete" {
+
+		_, err := this.mgo.DeleteMany(data.D[0].(core.SqlTable), data.D[1].(map[string]interface{}))
+		if err != nil {
+			log.Errorf("delete %s db err:%v", data.D[0].(core.SqlTable), err)
+		}
+	} else { // update
+		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")
+		}
+		where := data.D[1].(map[string]interface{})
+		_obj := &QueryStruct{}
+		for k, v := range where {
+			_obj.Selector[k] = v
+		}
+		query := data.D[2].(map[string]interface{})
+		for k, v := range query {
+			_obj.Query[k] = v
+		}
+		this.mgo.FindOneAndUpdate(data.D[0].(core.SqlTable), _obj.Selector, _obj.Query)
+	}
+	return
+}
+
+func (this *DB) Model_InsertDBBylog(data *Autogenerated) (err error) {
+
+	_, err = this.mgo.InsertOne(DB_ModelTable, data)
+	if err != nil {
+		log.Errorf("insert model db err %v", err)
+	}
+	return err
+}