This commit is contained in:
aozhiwei 2024-06-26 16:01:42 +08:00
parent 1d2a5c140e
commit 28d84edfce
2 changed files with 3 additions and 71 deletions

View File

@ -1,69 +0,0 @@
package model
import (
"q5"
"f5"
"main/constant"
)
type inbox struct {
}
var Inbox = new(inbox)
func (this *inbox) Mark(accountId string, mailId int64, nowTime int64, expireTime int32) error {
var result error
f5.GetGoStyleDb().Upsert(
constant.MAIL_DB,
"t_inbox",
[][]string{
{"account_id", accountId},
{"mail_id", q5.ToString(mailId)},
},
[][]string{
{"state", q5.ToString(constant.INBOX_STATE_READ)},
{"expiretime", q5.ToString(expireTime)},
{"modifytime", q5.ToString(nowTime)},
},
[][]string{
{"account_id", accountId},
{"mail_id", q5.ToString(mailId)},
{"state", q5.ToString(constant.INBOX_STATE_READ)},
{"expiretime", q5.ToString(expireTime)},
{"createtime", q5.ToString(nowTime)},
{"modifytime", q5.ToString(nowTime)},
},
func (err error, lastInsertId int64, rowsAffected int64) {
result = err
})
return result
}
func (this *inbox) Delete(accountId string, mailId int64, nowTime int64, expireTime int32) error {
var result error
f5.GetGoStyleDb().Upsert(
constant.MAIL_DB,
"t_inbox",
[][]string{
{"account_id", accountId},
{"mail_id", q5.ToString(mailId)},
},
[][]string{
{"state", q5.ToString(constant.INBOX_STATE_DELETED)},
{"expiretime", q5.ToString(expireTime)},
{"modifytime", q5.ToString(nowTime)},
},
[][]string{
{"account_id", accountId},
{"mail_id", q5.ToString(mailId)},
{"state", q5.ToString(constant.INBOX_STATE_DELETED)},
{"expiretime", q5.ToString(expireTime)},
{"createtime", q5.ToString(nowTime)},
{"modifytime", q5.ToString(nowTime)},
},
func (err error, lastInsertId int64, rowsAffected int64) {
result = err
})
return result
}

View File

@ -6,7 +6,7 @@ import (
type table struct {
NftServerCluster *NftServerClusterTable
NftDb *NftDbTable
//NftDb *NftDbTable
Config *ConfigTable
NftHomeMeta *NftHomeMetaTable
//Contract *ContractTable
@ -18,10 +18,11 @@ var Table = f5.New(func(this *table) {
this.PrimKey = "instance_id"
})
/*
this.NftDb = f5.New(func(this *NftDbTable) {
this.FileName = "../config/nftdb.mysql.json"
this.PrimKey = ""
})
})*/
this.Config = f5.New(func(this *ConfigTable) {
this.FileName = "../config/config.json"