删除的数据未同步

Tools/Flyinsono.DBCopy.Tool/Service/MigrateService.Course.cs

@@ -215,7 +215,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                             Name = courseItem.Name,
                             CourseIntro = courseItem.Information,
                             TeacherCode = courseItem.Teacher?.Id ?? string.Empty,
-                            Poster = GetFileUrl(courseItem.Poster),
+                            Poster = ConvertToJpg(courseItem.Poster),
                             Status = status,
                             StartTime = courseItem.StarTime,
                             Duration = courseItem.Duration,
@@ -440,7 +440,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                             UpdateTime = courseItem.UpdateTime,
                             Name = courseItem.Title,
                             VideoToken = fileUrl,
-                            Poster = GetFileUrl(courseItem.PosterToken),
+                            Poster = ConvertToJpg(courseItem.PosterToken),
                             Duration = courseItem.Duration,
                             VideoSize = courseItem.Size,
                             CreatorCode = courseItem.CreatorId,
@@ -460,7 +460,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                             Name = courseItem.Title,
                             CourseIntro = courseItem.Description,
                             TeacherCode = courseItem.CreatorId,
-                            Poster = GetFileUrl(courseItem.PosterToken),
+                            Poster = ConvertToJpg(courseItem.PosterToken),
                             Status = CourseStatusEnum.Approved,
                             StartTime = courseItem.CreateTime,
                             Duration = courseItem.Duration,
@@ -1495,7 +1495,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                                                     QuestionCode = studentAnswerDetail.SubjectId,
                                                     QuestionType = QuestionTypeEnum.ShortAnswer,
                                                     Answer = "",
-                                                    Files = new List<string>() { GetFileUrl(studentAnswerItem.ImageToken) },
+                                                    Files = new List<string>() { ConvertToJpg(studentAnswerItem.ImageToken) },
                                                     OptionCodeList = new List<string>(),
                                                     IsCorrect = isCorrect,
                                                     Score = scoreItem
@@ -1661,9 +1661,9 @@ namespace Flyinsono.DBCopy.Tool.Service
                             UpdateTime = teachingTerminalItem.UpdateTime,
                             Application = teachingTerminalItem.Application,
                             UserCode = teachingTerminalItem.OwnerId,
-                            PreviewUrl = GetFileUrl(teachingTerminalItem.PreviewImageFileToken),
+                            PreviewUrl = ConvertToJpg(teachingTerminalItem.PreviewImageFileToken),
                             ImageUrl = defaultFile,
-                            CoverImageUrl = GetFileUrl(teachingTerminalItem.PreviewImageFileToken),
+                            CoverImageUrl = ConvertToJpg(teachingTerminalItem.PreviewImageFileToken),
                             OriginImageUrl = defaultFile,
                             FileDataType = fileDataType,
                             IsDelete = teachingTerminalItem.IsDeleted

Tools/Flyinsono.DBCopy.Tool/Service/MigrateService.cs

@@ -1397,7 +1397,7 @@ namespace Flyinsono.DBCopy.Tool.Service
             //获取上次同步到的时间
             var builder = Builders<ConsultationRecords>.Filter;
             var startTime = GetFactBeginTime(_migrateRecord.StartTime, _migrateRecord.EndTime);
-            var filter = builder.Where(x => x.IsDeleted == false && x.Id == "FEF44DD5F41C438ABB2AC6845F920CF3" && ((x.CreateTime > startTime && x.CreateTime <= _migrateRecord.EndTime) || (x.UpdateTime > startTime && x.UpdateTime <= _migrateRecord.EndTime)));
+            var filter = builder.Where(x => x.IsDeleted == false && ((x.CreateTime > startTime && x.CreateTime <= _migrateRecord.EndTime) || (x.UpdateTime > startTime && x.UpdateTime <= _migrateRecord.EndTime)));
             var consultations = _consultationRecordDBRepository.GetTerminalRecords(filter).OrderByDescending(x => x.CreateTime).ToList();
             OnMigrate("consultations", consultations, SendConsultations, syncType, 1000);
             consultations.Clear();
@@ -1500,7 +1500,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                                 var consultationFileDTO = new ConsultationFileDTO();
                                 consultationFileDTO.FileDataType = RemedicalFileDataTypeEnum.VinnoVidSingle;
                                 consultationFileDTO.SourceUrl = GetFileUrl(item);
-                                consultationFileDTO.PreviewImageUrl = GetFileUrl(item);
+                                consultationFileDTO.PreviewImageUrl = ConvertToJpg(item);
                                 syncReportInfoRequest.ConsultationFileList.Add(consultationFileDTO);
                             }
                         }
@@ -1511,7 +1511,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                                 var consultationFileDTO = new ConsultationFileDTO();
                                 consultationFileDTO.FileDataType = RemedicalFileDataTypeEnum.VinnoVidMovie;
                                 consultationFileDTO.SourceUrl = GetFileUrl(item.VideoToken);
-                                consultationFileDTO.PreviewImageUrl = GetFileUrl(item.PreviewImageToken);
+                                consultationFileDTO.PreviewImageUrl = ConvertToJpg(item.PreviewImageToken);
                                 syncReportInfoRequest.ConsultationFileList.Add(consultationFileDTO);
                             }
                         }
@@ -1522,9 +1522,9 @@ namespace Flyinsono.DBCopy.Tool.Service
                                 var consultationFileDTO = new ConsultationFileDTO();
                                 consultationFileDTO.FileDataType = item.GraphicType == 0 ? RemedicalFileDataTypeEnum.ThirdVidSingle : RemedicalFileDataTypeEnum.ThirdVidMovie;
                                 consultationFileDTO.SourceUrl = GetFileUrl(item.GraphicToken);
-                                consultationFileDTO.PreviewImageUrl = GetFileUrl(item.PreviewGraphicToken);
+                                consultationFileDTO.PreviewImageUrl = ConvertToJpg(item.PreviewGraphicToken);
+                                consultationFileDTO.CreateTime = (consultation.UpdateTime <= DateTime.MinValue ? consultation.CreateTime : consultation.UpdateTime);
                                 syncReportInfoRequest.ConsultationFileList.Add(consultationFileDTO);
-
                             }
                         }
                         if (consultation.PreFileItems != null && consultation.PreFileItems.Any())
@@ -1534,7 +1534,7 @@ namespace Flyinsono.DBCopy.Tool.Service
                                 var consultationFileDTO = new ConsultationFileDTO();
                                 consultationFileDTO.FileDataType = item.FileType == 0 ? RemedicalFileDataTypeEnum.ThirdVidSingle : RemedicalFileDataTypeEnum.ThirdVidMovie;
                                 consultationFileDTO.SourceUrl = GetFileUrl(item.OriginalFileUrl);
-                                consultationFileDTO.PreviewImageUrl = GetFileUrl(item.ThumbnailUrl);
+                                consultationFileDTO.PreviewImageUrl = ConvertToJpg(item.ThumbnailUrl);
                                 syncReportInfoRequest.ConsultationFileList.Add(consultationFileDTO);
                             }
                         }