传输到web

src/Shentun.Peis.Application/TransToWebPeis/TransToWebPeisAppService.cs

@@ -1,18 +1,146 @@
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Shentun.Peis.CustomerOrgs;
+using Shentun.Peis.DataMigrations;
+using Shentun.Peis.Enums;
+using Shentun.Peis.ItemTypes;
 using Shentun.Peis.Models;
+using Shentun.Peis.MyUser;
 using Shentun.Peis.PatientRegisters;
+using Shentun.Peis.PlugIns;
+using Shentun.Peis.RegisterCheckItems;
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using Volo.Abp.Application.Services;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Identity;
+using Volo.Abp.Uow;
 
 namespace Shentun.Peis.TransToWebPeis
 {
     public class TransToWebPeisAppService : ApplicationService
     {
-        public TransToWebPeisAppService() { }
+        private readonly IRepository<DeviceType, Guid> _deviceTypeRepository;
+        private readonly IRepository<ItemType, Guid> _itemTypeRepository;
+        private readonly ItemTypeManager _itemTypeManager;
+        private readonly IRepository<Unit, Guid> _unitRepository;
+        private readonly IRepository<MedicalType, Guid> _medicalTypeRepository;
+        private readonly IRepository<PersonnelType, Guid> _personnelTypeRepository;
+        private readonly IRepository<InvoiceItemType, Guid> _invoiceItemTypeRepository;
+        private readonly IRepository<FieldComparison, Guid> _fieldComparisonRepository;
+        private readonly IRepository<SampleType, Guid> _sampleTypeRepository;
+        private readonly IRepository<Item, Guid> _itemRepository;
+        private readonly IRepository<ReferenceRange, Guid> _referenceRangeRepository;
+        private readonly IRepository<Asbitem, Guid> _asbitemRepository;
+        private readonly IRepository<AsbitemDetail> _asbitemDetailRepository;
+        private readonly IRepository<MedicalPackage, Guid> _medicalPackageRepository;
+        private readonly IRepository<MedicalPackageDetail> _medicalPackageDetailRepository;
+        private readonly IRepository<Diagnosis, Guid> _diagnosisRepository;
+        private readonly IRepository<Suggestion, Guid> _suggestionRepository;
+        private readonly IRepository<ItemResultTemplate, Guid> _itemResultTemplateRepository;
+        private readonly IRepository<ItemResultMatch, Guid> _ItemResultMatchRepository;
+        private readonly MyUserAppService _myUserAppService;
+        private readonly IRepository<MenuInfo, Guid> _menuInfoRepository;
+        private readonly IRepository<CustomerOrg, Guid> _customerOrgRepository;
+        private readonly CustomerOrgManager _customerOrgManager;
+        private readonly IRepository<CustomerOrgRegister, Guid> _customerOrgRegisterRepository;
+        private readonly IRepository<CustomerOrgGroup, Guid> _customerOrgGroupRepository;
+        private readonly IRepository<CustomerOrgGroupDetail> _customerOrgGroupDetailRepository;
+        private readonly IRepository<Patient, Guid> _patientRepository;
+        private readonly IRepository<Nation> _nationRepository;
+        private readonly ILogger<BaseDataHandleAppService> _logger;
+        private readonly IRepository<IdentityUser, Guid> _identityUserRepository;
+        private readonly IRepository<MedicalConclusion, Guid> _medicalConclusionRepository;
+        private readonly IRepository<PatientRegister, Guid> _patientRegisterRepository;
+        private readonly IRepository<RegisterCheck, Guid> _registerCheckRepository;
+        private readonly IRepository<RegisterCheckAsbitem, Guid> _registerCheckAsbitemRepository;
+        private readonly IRepository<RegisterCheckItem> _registerCheckItemRepository;
+        private readonly RegisterCheckItemManager _registerCheckItemManager;
+        private readonly UnitOfWorkManager _unitOfWorkManager;
+        private readonly IRepository<RegisterCheckSummary, Guid> _registerCheckSummaryRepository;
+        private readonly IRepository<SumSummaryHeader, Guid> _sumSummaryHeaderRepository;
+        private readonly IRepository<SumSummaryContent, Guid> _sumSummaryContentRepository;
+        private readonly IRepository<SumSuggestionHeader, Guid> _sumSuggestionHeaderRepository;
+        private readonly IRepository<SumSuggestionContent, Guid> _sumSuggestionContentRepository;
+        private readonly IRepository<SumDiagnosis> _sumDiagnosisRepository;
+        private readonly IRepository<Report, string> _reportRepository;
+        private readonly IRepository<ReportFormat, string> _reportFormatRepository;
+        private readonly IRepository<ReportFormatTemplate, string> _reportFormatTemplateRepository;
+        private readonly IRepository<SampleGroup, Guid> _sampleGroupRepository;
+        private readonly IRepository<SampleGroupDetail> _sampleGroupDetailRepository;
+        private readonly IRepository<SysParmType> _sysParmTypeRepository;
+        private readonly IRepository<SysParm> _sysParmRepository;
+        private readonly IRepository<SysParmValue> _sysParmValueRepository;
+        private readonly IRepository<CollectItemType, Guid> _collectItemTypeRepository;
+        private readonly IRepository<PatientRegisterExter> _patientRegisterExterRepository;
+        private readonly IRepository<AsbitemGuide> _asbitemGuideRepository;
+        private readonly PatientRegisterManager _patientRegisterManager;
+        private readonly IRepository<ThirdInterface, Guid> _thirdInterfaceRepository;
+        public TransToWebPeisAppService(
+              IRepository<DeviceType, Guid> deviceTypeRepository,
+            IRepository<ItemType, Guid> itemTypeRepository,
+            ItemTypeManager itemTypeManager,
+            IRepository<Unit, Guid> unitRepository,
+            IRepository<MedicalType, Guid> medicalTypeRepository,
+            IRepository<PersonnelType, Guid> personnelTypeRepository,
+            IRepository<InvoiceItemType, Guid> invoiceItemTypeRepository,
+            IRepository<FieldComparison, Guid> fieldComparisonRepository,
+            IRepository<SampleType, Guid> sampleTypeRepository,
+            IRepository<Item, Guid> itemRepository,
+            IRepository<ReferenceRange, Guid> referenceRangeRepository,
+            IRepository<Asbitem, Guid> asbitemRepository,
+            IRepository<AsbitemDetail> asbitemDetailRepository,
+            IRepository<MedicalPackage, Guid> medicalPackageRepository,
+            IRepository<MedicalPackageDetail> medicalPackageDetailRepository,
+            IRepository<ItemResultTemplate, Guid> itemResultTemplateRepository,
+            IRepository<ItemResultMatch, Guid> itemResultMatchRepository,
+            IRepository<Diagnosis, Guid> diagnosisRepository,
+            IRepository<Suggestion, Guid> suggestionRepository,
+            MyUserAppService myUserAppService,
+            IRepository<MenuInfo, Guid> menuInfoRepository,
+            IRepository<CustomerOrg, Guid> customerOrgRepository,
+            CustomerOrgManager customerOrgManager,
+            IRepository<CustomerOrgRegister, Guid> customerOrgRegisterRepository,
+            IRepository<CustomerOrgGroup, Guid> customerOrgGroupRepository,
+            IRepository<CustomerOrgGroupDetail> customerOrgGroupDetailRepository,
+            IRepository<Nation> nationRepository,
+            IRepository<Patient, Guid> patientRepository,
+            ILogger<BaseDataHandleAppService> logger,
+            IRepository<IdentityUser, Guid> identityUserRepository,
+            IRepository<MedicalConclusion, Guid> medicalConclusionRepository,
+            IRepository<PatientRegister, Guid> patientRegisterRepository,
+            IRepository<RegisterCheck, Guid> registerCheckRepository,
+            IRepository<RegisterCheckAsbitem, Guid> registerCheckAsbitemRepository,
+            IRepository<RegisterCheckItem> registerCheckItemRepository,
+            RegisterCheckItemManager registerCheckItemManager,
+            UnitOfWorkManager unitOfWorkManager,
+            IRepository<RegisterCheckSummary, Guid> registerCheckSummaryRepository,
+            IRepository<SumSummaryHeader, Guid> sumSummaryHeaderRepository,
+            IRepository<SumSummaryContent, Guid> sumSummaryContentRepository,
+            IRepository<SumSuggestionHeader, Guid> sumSuggestionHeaderRepository,
+            IRepository<SumSuggestionContent, Guid> sumSuggestionContentRepository,
+            IRepository<SumDiagnosis> sumDiagnosisRepository,
+            IRepository<Report, string> reportRepository,
+            IRepository<ReportFormat, string> reportFormatRepository,
+            IRepository<ReportFormatTemplate, string> reportFormatTemplateRepository,
+            IRepository<SampleGroup, Guid> sampleGroupRepository,
+            IRepository<SampleGroupDetail> sampleGroupDetailRepository,
+            IRepository<SysParmType> sysParmTypeRepository,
+            IRepository<SysParm> sysParmRepository,
+            IRepository<SysParmValue> sysParmValueRepository,
+            IRepository<CollectItemType, Guid> collectItemTypeRepository,
+            IRepository<PatientRegisterExter> patientRegisterExterRepository,
+            IRepository<AsbitemGuide> asbitemGuideRepository,
+            PatientRegisterManager patientRegisterManager,
+            IRepository<ThirdInterface, Guid> thirdInterfaceRepository)
+        {
+            _thirdInterfaceRepository = thirdInterfaceRepository;
+        }
         /// <summary>
         /// 上传基础资料
         /// </summary>
@@ -23,6 +151,17 @@ namespace Shentun.Peis.TransToWebPeis
         {
             //item_type,item,asbitem,asbitem_detail,medical_package,medical_package_detail
             //diagnosis_level,diagnosis
+            var thirdInterfaces = await _thirdInterfaceRepository.GetListAsync(o => o.ThirdInterfaceType ==
+            ThirdInterfaceTypeFlag.TranToWebPeis && o.IsActive == 'Y');
+            foreach (var thirdInterface in thirdInterfaces)
+            {
+                var connectString = GetConnectionStrings(thirdInterface.ParmValue);
+                await TransItemType(connectString);
+                await TransItem(connectString);
+                await TransAsbitem(connectString);
+                await TransMedicalPackage(connectString);
+                await TransDiagnosis(connectString);
+            }
         }
         /// <summary>
         /// 上传单位信息
@@ -43,6 +182,7 @@ namespace Shentun.Peis.TransToWebPeis
             //patient,patient_register,register_check,register_check_asbitem
             //register_check_item,register_check_picture,register_check_summary,register_check_suggestion
             //sum_summary_header,sum_summary_content,sum_suggestion_header,sum_suggestion_content,sum_diagnosis,
+
         }
         /// <summary>
         /// 根据人员登记ID上传人员体检信息
@@ -50,7 +190,7 @@ namespace Shentun.Peis.TransToWebPeis
         /// <param name="input"></param>
         /// <returns></returns>
         [HttpGet("api/app/TransToWebPeis/TransPatientRegisterByPatientRegisterId")]
-        public async Task TransPatientRegisterByPatientRegisterIdAsync(PatientRegisterIdInputDto input )
+        public async Task TransPatientRegisterByPatientRegisterIdAsync(PatientRegisterIdInputDto input)
         {
 
         }
@@ -64,5 +204,41 @@ namespace Shentun.Peis.TransToWebPeis
         {
 
         }
+
+
+        private string GetConnectionStrings(string parmValue)
+        {
+            var configurationBuilder = new ConfigurationBuilder()
+          .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var interfaceConfig = configurationBuilder.Build();
+            var interfaceConnctionStr = interfaceConfig.GetSection("Interface").GetSection("ConnectionStrings").Value;
+            return interfaceConnctionStr;
+        }
+
+        private async Task TransItemType(string connectString)
+        {
+
+        }
+
+        private async Task TransItem(string connectString)
+        {
+
+        }
+
+        private async Task TransAsbitem(string connectString)
+        {
+            //asbitem,asbitem_detail
+        }
+
+        private async Task TransMedicalPackage(string connectString)
+        {
+            //medical_package,medical_package_detail
+        }
+
+        private async Task TransDiagnosis(string connectString)
+        {
+            //diagnosis_level,diagnosis
+        }
+
     }
 }