article

src/Hotline.Api/Controllers/ArticleController.cs

@@ -201,7 +201,7 @@ namespace Hotline.Api.Controllers
                         readGroup.IsTimeOut = false;
                     await _circularReadGroupRepository.UpdateAsync(readGroup, HttpContext.RequestAborted);
                     //处理计数
-                    await _circularRecordDomainService.RecordUserHandle(_sessionContext.RequiredUserId, false, HttpContext.RequestAborted);
+                    await _circularRecordDomainService.RecordUserHandle(_sessionContext.RequiredUserId, false,cancellationToken : HttpContext.RequestAborted);
                 }
             }
             else
@@ -218,7 +218,7 @@ namespace Hotline.Api.Controllers
                         readGroup.IsTimeOut = false;
                     await _circularReadGroupRepository.UpdateAsync(readGroup, HttpContext.RequestAborted);
                     //处理部门计数
-                    await _circularRecordDomainService.RecordOrgHandle(_sessionContext.RequiredOrgId, false, HttpContext.RequestAborted);
+                    await _circularRecordDomainService.RecordOrgHandle(_sessionContext.RequiredOrgId, false, cancellationToken: HttpContext.RequestAborted);
                 }
             }
             return _mapper.Map<CircularDto>(model);

src/Hotline/Article/CircularRecordDomainService.cs

@@ -11,7 +11,7 @@ namespace Hotline.Article
         {
               _circularRecordRepository = circularRecordRepository;
         }
-        public async Task RecordUserHandle(string userId, bool isAdd, CancellationToken cancellationToken)
+        public async Task RecordUserHandle(string userId, bool isAdd,int count = 1, CancellationToken cancellationToken= default)
         {
             var userRecord = await _circularRecordRepository.GetAsync(x => x.UserId == userId);
             if (isAdd)
@@ -20,7 +20,7 @@ namespace Hotline.Article
                 {
                     if (userRecord.RecordCount>0)
                     {
-                        userRecord.RecordCount++;
+                        userRecord.RecordCount = userRecord.RecordCount+count;
                     }
                     await _circularRecordRepository.UpdateAsync(userRecord);
                 }
@@ -39,7 +39,7 @@ namespace Hotline.Article
                 {
                     if (userRecord.RecordCount > 0)
                     {
-                        userRecord.RecordCount--;
+                        userRecord.RecordCount = userRecord.RecordCount-count;
                     }
                     else
                     {
@@ -49,7 +49,7 @@ namespace Hotline.Article
             }
         }
 
-        public async Task RecordOrgHandle(string orgId, bool isAdd, CancellationToken cancellationToken)
+        public async Task RecordOrgHandle(string orgId, bool isAdd,int count =1, CancellationToken cancellationToken = default)
         {
             var orgRecord = await _circularRecordRepository.GetAsync(x => x.OrgId == orgId);
             if (isAdd)
@@ -58,7 +58,7 @@ namespace Hotline.Article
                 {
                     if (orgRecord.RecordCount > 0)
                     {
-                        orgRecord.RecordCount++;
+                        orgRecord.RecordCount = orgRecord.RecordCount + count;
                     }
                     await _circularRecordRepository.UpdateAsync(orgRecord);
                 }
@@ -77,7 +77,7 @@ namespace Hotline.Article
                 {
                     if (orgRecord.RecordCount > 0)
                     {
-                        orgRecord.RecordCount--;
+                        orgRecord.RecordCount = orgRecord.RecordCount - count;
                     }
                     else
                     {

src/Hotline/Article/ICircularRecordDomainService.cs

@@ -3,8 +3,8 @@ namespace Hotline.Article
 {
     public interface ICircularRecordDomainService
     {
-        Task RecordUserHandle(string userId,bool isAdd,CancellationToken cancellationToken);
+        Task RecordUserHandle(string userId,bool isAdd,int count = 1,CancellationToken cancellationToken = default);
 
-        Task RecordOrgHandle(string orgId, bool isAdd, CancellationToken cancellationToken);
+        Task RecordOrgHandle(string orgId, bool isAdd, int count = 1, CancellationToken cancellationToken= default);
     }
 }