|
@@ -356,6 +356,7 @@ namespace GxPress.Service.Implement.Reply
|
|
|
using (var tran = new TransactionScope())
|
|
|
{
|
|
|
var intList = new List<int>();
|
|
|
+ //话题本/笔记本点赞
|
|
|
var sql = $@"SELECT
|
|
|
a.Id
|
|
|
FROM
|
|
@@ -369,7 +370,7 @@ namespace GxPress.Service.Implement.Reply
|
|
|
INNER JOIN
|
|
|
tede_middle e ON e.MiddleId = b.Id
|
|
|
WHERE
|
|
|
- a.TypeValue = 4 AND e.IsDelete = 0
|
|
|
+ a.TypeValue in({AllTypeConst.Note.GetHashCode()},{AllTypeConst.TopicNote.GetHashCode()}) AND e.IsDelete = 0
|
|
|
AND a.CommentId = 0
|
|
|
AND e.UserId = b.UserId
|
|
|
AND a.AnalyzeType = 1
|
|
@@ -378,6 +379,7 @@ namespace GxPress.Service.Implement.Reply
|
|
|
var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
|
|
|
var connection = database.GetConnection();
|
|
|
intList.AddRange(await connection.QueryAsync<int>(sql));
|
|
|
+ //小组话题 通知 笔记 评论点赞
|
|
|
sql = $@"
|
|
|
SELECT
|
|
|
b.Id
|
|
@@ -390,11 +392,12 @@ namespace GxPress.Service.Implement.Reply
|
|
|
INNER JOIN
|
|
|
tede_user d ON d.Id = a.UserId
|
|
|
WHERE
|
|
|
- a.TypeValue IN ({AllTypeConst.Topic.GetHashCode()},{AllTypeConst.Notice.GetHashCode()},{AllTypeConst.Note.GetHashCode()})
|
|
|
+ a.TypeValue IN ({AllTypeConst.Topic.GetHashCode()},{AllTypeConst.Notice.GetHashCode()},{AllTypeConst.Note.GetHashCode()},{AllTypeConst.TopicNote.GetHashCode()})
|
|
|
AND a.UserId ={userId}
|
|
|
AND b.AnalyzeType = 2
|
|
|
AND b.IsRead = 0";
|
|
|
intList.AddRange(await connection.QueryAsync<int>(sql));
|
|
|
+ //通知点赞
|
|
|
sql = $@"
|
|
|
SELECT
|
|
|
a.Id
|