From 69b2db191e43e8f134a8d566387e6288f279cfd4 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 17 Oct 2024 13:59:16 +0800 Subject: [PATCH] 1 --- server/imserver/model/friend.go | 48 ++++++++++++++++----------------- 1 file changed, 23 insertions(+), 25 deletions(-) diff --git a/server/imserver/model/friend.go b/server/imserver/model/friend.go index 010a0089..62c9f01f 100644 --- a/server/imserver/model/friend.go +++ b/server/imserver/model/friend.go @@ -35,7 +35,8 @@ func (this *friend) Force(accountId1 string, accountId2 string, nowTime int64, }, func (err error, lastInsertId int64, rowsAffected int64) { cb(err, lastInsertId, rowsAffected) - this.updateAddFriendTask(accountId1, accountId2, nowTime) + this.updateAddFriendTask(accountId1, nowTime) + this.updateAddFriendTask(accountId2, nowTime) }, func (ds *f5.DataSet) bool { return true @@ -58,28 +59,25 @@ func (this *friend) DeleteSoft(accountId1 string, accountId2 string, cb) } -func (this *friend) updateAddFriendTask(accountId1 string, accountId2 string, nowTime int64) { - { - f5.GetJsStyleDb().Upsert( - constant.GAME_DB, - "t_friend_relationship", - [][]string{ - {"account_id1", accountId1}, - {"account_id2", accountId2}, - }, - [][]string{ - {"add_time", q5.ToString(nowTime)}, - {"deleted", "0"}, - }, - [][]string{ - {"account_id1", accountId1}, - {"account_id2", accountId2}, - {"add_time", q5.ToString(nowTime)}, - {"deleted", "0"}, - {"createtime", q5.ToString(nowTime)}, - {"modifytime", q5.ToString(nowTime)}, - }, - func (err error, lastInsertId int64, rowsAffected int64) { - }) - } +func (this *friend) updateAddFriendTask(accountId string, nowTime int64) { + f5.GetJsStyleDb().Upsert( + constant.GAME_DB, + "t_rookie_task_value", + [][]string{ + {"account_id", accountId}, + {"task_type", "16"}, + }, + [][]string{ + {"!value", "value + 1"}, + {"modifytime", q5.ToString(nowTime)}, + }, + [][]string{ + {"account_id", accountId}, + {"task_type", "16"}, + {"value", "1"}, + {"createtime", q5.ToString(nowTime)}, + {"modifytime", q5.ToString(nowTime)}, + }, + func (err error, lastInsertId int64, rowsAffected int64) { + }) }