diff --git a/server/imserver_new/friend/friendmgr.go b/server/imserver_new/friend/friendmgr.go index a425b1b5..de262fdc 100644 --- a/server/imserver_new/friend/friendmgr.go +++ b/server/imserver_new/friend/friendmgr.go @@ -293,26 +293,7 @@ func (this *friendMgr) AsyncAddBlack(senderId string, targetId string, cb func(i cb(1, "") return } - nowTime := f5.GetApp().GetNowSeconds() - f5.GetJsStyleDb().Upsert( - constant.FRIEND_DB, - "t_friend_blacklist", - [][]string{ - {"sender_id", senderId}, - {"block_id", targetId}, - }, - [][]string{ - {"deleted", q5.ToString(0)}, - {"add_time", q5.ToString(nowTime)}, - }, - [][]string{ - {"sender_id", senderId}, - {"block_id", targetId}, - {"deleted", q5.ToString(0)}, - {"add_time", q5.ToString(nowTime)}, - {"createtime", q5.ToString(nowTime)}, - {"modifytime", q5.ToString(nowTime)}, - }, + model.FriendBlack.Force(senderId, targetId, func (err error, lastInsertId int64, rowsAffected int64) { if err != nil { cb(1, "") diff --git a/server/imserver_new/model/friend_black.go b/server/imserver_new/model/friend_black.go new file mode 100644 index 00000000..86629c9c --- /dev/null +++ b/server/imserver_new/model/friend_black.go @@ -0,0 +1,38 @@ +package model + +import ( + "q5" + "f5" + "main/constant" +) + +type friendBlack struct { + +} + +var FriendBlack = new (friendBlack) + +func (this *friendBlack) Force(senderId string, targetId string, + cb func (error, int64, int64)) { + nowTime := f5.GetApp().GetNowSeconds() + f5.GetJsStyleDb().Upsert( + constant.FRIEND_DB, + "t_friend_blacklist", + [][]string{ + {"sender_id", senderId}, + {"block_id", targetId}, + }, + [][]string{ + {"deleted", q5.ToString(0)}, + {"add_time", q5.ToString(nowTime)}, + }, + [][]string{ + {"sender_id", senderId}, + {"block_id", targetId}, + {"deleted", q5.ToString(0)}, + {"add_time", q5.ToString(nowTime)}, + {"createtime", q5.ToString(nowTime)}, + {"modifytime", q5.ToString(nowTime)}, + }, + cb) +}