修改中心调研 isJoin

IRaCIS.Core.Application/Service/Allocation/VisitTaskHelpeService.cs

@@ -55,7 +55,7 @@ namespace IRaCIS.Core.Application.Service
         public VisitTaskHelpeService(IRepository<VisitTask> visitTaskRepository, IRepository<Trial> trialRepository, IEasyCachingProvider provider,
              IRepository<SubjectVisit> subjectVisitRepository,
              IRepository<ReadModule> readModuleRepository,
-                IRepository<ReadingTaskQuestionAnswer> readingTaskQuestionAnswerRepository,
+             IRepository<ReadingTaskQuestionAnswer> readingTaskQuestionAnswerRepository,
                     IRepository<ReadingTableAnswerRowInfo> readingTableAnswerRowInfoRepository,
                        IRepository<ReadingTableQuestionAnswer> readingTableQuestionAnswerRepository,
                            IRepository<ReadingTableQuestionTrial> readingTableQuestionTrialRepository,

IRaCIS.Core.Application/Service/SiteSurvey/TrialSiteSurveyService.cs

@@ -729,17 +729,18 @@ namespace IRaCIS.Core.Application.Contracts
 
 
                         sysUserInfo = newUser;
+
                     }
 
+                    await _trialSiteUserSurveyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Id, u => new TrialSiteUserSurvey() { IsGenerateSuccess = true, SystemUserId = sysUserInfo.Id });
+
                 }
 
+                // 
 
                 //发送邮件的时候需要用到该字段
                 item.SystemUserId = sysUserInfo.Id;
 
-                await _trialSiteUserSurveyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Id, u => new TrialSiteUserSurvey() { IsGenerateSuccess = true, SystemUserId = sysUserInfo.Id });
-
-
             }
 
             await _trialSiteUserSurveyRepository.SaveChangesAsync();
@@ -784,10 +785,11 @@ namespace IRaCIS.Core.Application.Contracts
                 await _userRepository.BatchUpdateNoTrackingAsync(t => t.Id == userId, u => new User() { Status = UserStateEnum.Enable });
 
 
-
+                await _trialSiteUserSurveyRepository.UpdatePartialFromQueryAsync(t => t.Id == userInfo.Id, u => new TrialSiteUserSurvey() { IsJoin = true });
             }
 
             await _trialSiteSurveyRepository.UpdatePartialFromQueryAsync(t => t.Id == trialSiteSurvey.Id && t.State == TrialSiteSurveyEnum.SPMApproved, u => new TrialSiteSurvey() { State = TrialSiteSurveyEnum.PMCreatedAndLock, ReviewerUserId = _userInfo.Id, ReviewerTime = DateTime.Now });
+          
             await _userRepository.SaveChangesAsync();
 
             return ResponseOutput.Ok();

IRaCIS.Core.Application/TestService.cs

@@ -2,6 +2,7 @@
 using IRaCIS.Core.Application.ViewModel;
 using IRaCIS.Core.Domain.Share;
 using IRaCIS.Core.Infrastructure;
+using MassTransit;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
@@ -171,9 +172,19 @@ namespace IRaCIS.Application.Services
 
 
         [AllowAnonymous]
-        public async Task testwwwww([FromServices] IWebHostEnvironment env)
+        public async Task<List<Guid>> testwwwww([FromServices] IWebHostEnvironment env)
         {
-            await Task.CompletedTask;
+            int count = 200;
+
+            var list=new List<Guid>();
+
+            for (int i = 0; i < count; i++)
+            {
+                Guid guid = NewId.NextGuid();
+                list.Add(guid);
+            }
+
+            return list;
         }