|
|
using Dapper;using Newtonsoft.Json.Converters;using Newtonsoft.Json;using Npgsql;using NPOI.SS.Formula.Functions;using System;using System.Collections.Generic;using System.Data.Common;using System.Linq;using System.Net.Http.Headers;using System.Text;using System.Threading.Tasks;using System.Text.RegularExpressions;using Shentun.Peis.PatientRegisters;using Shentun.Peis.PersonnelTypes;using Shentun.Peis.MedicalTypes;using Shentun.Peis.CustomerOrgs;using Shentun.Peis.CustomerOrgGroups;using Shentun.Peis.CustomerReports;using Shentun.Peis.CustomerOrgGroupDetails;using Shentun.Peis.CustomerOrgRegisters;using Shentun.Peis.Enums;using Shentun.Peis.Patients;using Shentun.Peis.PlugIns.PatientRegisters;
namespace Shentun.Peis.PlugIns.Extensions.PatientRegisters.Qztl{ public class ImportPatientRegisterPlugInsQztl : ImportPatientRegisterPlugInsBase { private Guid _importCustomerOrgId; private string _hospitalId; private string _aesKEY; private string _year; private CustomerOrgDto _customerOrgDto; private CustomerOrgRegisterDto _customerOrgRegisterDto; private List<PersonnelTypeDto> _personnelTypes; private List<CustomerOrgGroupDto> _customerOrgGroupDtos; private string _answerWebApiUrl;
public ImportPatientRegisterPlugInsQztl(Guid thirdInterfaceId) : base(thirdInterfaceId) {
} public ImportPatientRegisterPlugInsQztl(string parmValue) : base(parmValue) {
}
public override async Task ImportAsync() { await LoginAsync(); await InitAsync();
var qztlPatientRegisterFromInterface = await CallInterfaceServiceAsync(); if (qztlPatientRegisterFromInterface == null || !qztlPatientRegisterFromInterface.plans.Any()) { return; }
//设置导入人员信息
foreach (var patient in qztlPatientRegisterFromInterface.plans) { try { //婚姻状况
var maritalStatusId = ConvertMaritalStatus(patient.wedding); //人员类别
var personnelType = ConvertPersonnelType(patient.tjJieduan); //性别
var sexId = ConvertSex(patient.sex); //体检类别
var medicalTypeName = patient.tjpcV; MedicalTypeDto medicalTypeDto = null; if (!string.IsNullOrWhiteSpace(medicalTypeName)) { medicalTypeDto = await CallAppServiceAsync<DisplayNameInputDto, MedicalTypeDto>( "api/app/MedicalType/GetByDisplayName", new DisplayNameInputDto() { DisplayName = medicalTypeName }); if (medicalTypeDto == null) { var createMedicalTypeDto = new CreateMedicalTypeDto() { DisplayName = medicalTypeName, }; medicalTypeDto = await CallAppServiceAsync<CreateMedicalTypeDto, MedicalTypeDto>( "api/app/medical-type", new CreateMedicalTypeDto() { DisplayName = medicalTypeName }); } } //职称
var jobTitle = ConvertJobTitle(patient.gradeZwV); //职务
var jobPost = ConvertJobPost(patient.tjTab1); string workTypeV = patient.workTypeV; if (string.IsNullOrWhiteSpace(workTypeV)) { workTypeV = ""; } else { workTypeV = "," + workTypeV; } jobPost = jobPost + workTypeV; if (!string.IsNullOrWhiteSpace(jobPost) && jobPost.Length >= 10) { jobPost = jobPost.Substring(0, 10);//只能存储10个汉字
}
//查找子单位是否存在，如存在获取子单位id，如果不存在这创建子单位
var orgName = patient.orgName; var pos = orgName.IndexOf("_"); orgName = orgName.Substring(0, pos); if (string.IsNullOrWhiteSpace(patient.mobile)) { //青海省第五人民医院要强行设置为 11111111111
} var customerOrgDtos = await CallAppServiceAsync<CustomerOrgIdInputDto, List<CustomerOrgDto>>( "api/app/CustomerOrg/GetChildCustomerOrgsById", new CustomerOrgIdInputDto() { CustomerOrgId = _importCustomerOrgId }); CustomerOrgDto customerOrgDto = null; if (customerOrgDtos != null && customerOrgDtos.Any()) { customerOrgDto = customerOrgDtos.Where(o => o.DisplayName == orgName).FirstOrDefault(); } if (customerOrgDto == null) { customerOrgDto = await CallAppServiceAsync<CreateCustomerOrgDto, CustomerOrgDto>( "api/app/customerorg/create", new CreateCustomerOrgDto() { MedicalCenterId = _customerOrgDto.MedicalCenterId, ParentId = _importCustomerOrgId, DisplayName = orgName, ShortName = orgName, IsActive = 'Y', IsLock = 'Y' }); } CustomerOrgGroupDto customerOrgGroupDto; if (patient.ifFj == 1) { //复检
//加载单位分组信息
_customerOrgGroupDtos = await CallAppServiceAsync<Guid, List<CustomerOrgGroupDto>>( "api/app/customer-org-group/in-customer-org-id/" + _importCustomerOrgId.ToString() , Guid.Empty, "get"); customerOrgGroupDto = _customerOrgGroupDtos.Where(o => o.DisplayName == "复检").FirstOrDefault(); if (customerOrgGroupDto == null) { throw new Exception("没有复检这个分组"); } } else { List<string> groupNames = new List<string>(); if (patient.ifGy == 1) { groupNames.Add("高原"); } else if (patient.ifJk == 1) { groupNames.Add("健康"); } else { throw new Exception("分组名称必须是高原或健康体检二选一"); } if (patient.ifGt == 1) { groupNames.Add("高铁"); } if (patient.ifWh == 1) { groupNames.Add("职害"); } if (patient.ifCw == 1) { groupNames.Add("普速"); } if (patient.ifMain == 1) { groupNames.Add("行车"); } if (patient.ifCy == 1) { groupNames.Add("从业"); } customerOrgGroupDto = await GetCustomerOrgGroup(groupNames, sexId, maritalStatusId); } //获取病人ID
var patientRegister = new CreatePatientRegisterDto() { MedicalCenterId = _customerOrgDto.MedicalCenterId, //PatientRegisterId = null,
//PatientId = null,
IsMaxMedicalTimes = 'Y', CompleteFlag = '0', CustomerOrgId = customerOrgDto.Id, CustomerOrgRegisterId = _customerOrgRegisterDto.Id, CustomerOrgGroupId = customerOrgGroupDto.Id, PatientName = patient.personName, SexId = sexId, Age = patient.age, MaritalStatusId = maritalStatusId, MobileTelephone = patient.mobile, Planuserid = patient.id.ToString(), IdNo = patient.cardId, //PersonnelTypeId = personnelType.Id,
JobTitle = jobTitle, Remark = patient.remark, JobPost = jobPost, Remark2 = patient.tjOpinion, Remark3 = patient.fjOpinion, QztlIsFj = patient.ifFj == 1 ? 'Y' : 'N', QztlIsGt = patient.ifGt == 1 ? 'Y' : 'N', QztlIsWh = patient.ifWh == 1 ? 'Y' : 'N', QztlIsCw = patient.ifCw == 1 ? 'Y' : 'N', QztlIsMain = patient.ifMain == 1 ? 'Y' : 'N', QztlIsCy = patient.ifCy == 1 ? 'Y' : 'N', IsQztlImport = 'Y' };
if (!string.IsNullOrWhiteSpace(patient.cardId)) { var patientInfo = await CallAppServiceAsync<IdNoInputDto, PatientDto>( "api/app/patient/GetByIdNo", new IdNoInputDto() { IdNo = patient.cardId }); if (patientInfo != null) { patientRegister.PatientId = patientInfo.Id; }
}
if (medicalTypeDto != null) { patientRegister.MedicalTypeId = medicalTypeDto.Id; } if (personnelType != null) { patientRegister.PersonnelTypeId = personnelType.Id; } if (patient.ifGy == 1) { patientRegister.QztlType = '0'; } else if (patient.ifJk == 1) { } { patientRegister.QztlType = '1'; } patientRegister.RegisterCheckAsbitems = new List<CreatePatientRegisterRegisterCheckAsbitem>(); //获取分组信息
var customerOrgGroupDetailOrAsbitemDtos = await CallAppServiceAsync<Guid, List<CustomerOrgGroupDetailOrAsbitemDto>>( "api/app/customerorggroupdetail/getcustomerorggroupdetailinasbitem?CustomerOrgGroupId=" + customerOrgGroupDto.Id.ToString() , Guid.Empty, "get"); if (!customerOrgGroupDetailOrAsbitemDtos.Any()) { throw new Exception("分组未包含项目"); } foreach (var asbitem in customerOrgGroupDetailOrAsbitemDtos) { patientRegister.RegisterCheckAsbitems.Add(new CreatePatientRegisterRegisterCheckAsbitem() { AsbitemId = asbitem.AsbitemId, StandardPrice = asbitem.Price, ChargePrice = asbitem.CustomerOrgGroupDetailPrice, PayTypeFlag = '1', IsCharge = 'N', Amount = asbitem.CustomerOrgGroupDetailAmount }); } await CallAppServiceAsync<CreatePatientRegisterDto, object>( "api/PatientRegister/CreatePatientRegister", patientRegister);
var succesIds = new List<string>(); var deleteIds = new List<string>(); succesIds.Add(patientRegister.Planuserid); await AnswerOk(succesIds, deleteIds); }
catch (Exception ex) {
if (ex.Message.Contains("人员信息姓名和性别和原来的信息都不一致") || ex.Message.Contains("身份证号解析出的性别与填入的性别不一致")) { continue; }
else { throw ex; } } }
}
public async Task InitAsync() { var customerOrgIdStr = InterfaceConfig.GetSection("Interface").GetSection("单位编号").Value; _hospitalId = InterfaceConfig.GetSection("Interface").GetSection("HospitalId").Value; _aesKEY = InterfaceConfig.GetSection("Interface").GetSection("aesKEY").Value; _answerWebApiUrl = InterfaceConfig.GetSection("Interface").GetSection("AnswerWebApiUrl").Value; if (string.IsNullOrWhiteSpace(customerOrgIdStr)) { return; } if (!Guid.TryParse(customerOrgIdStr, out _importCustomerOrgId)) { throw new Exception("单位编号不正确"); } if (string.IsNullOrWhiteSpace(_hospitalId)) { throw new Exception("HospitalId参数不能为空"); } if (string.IsNullOrWhiteSpace(_aesKEY)) { throw new Exception("_aesKEY参数不能为空"); } using (DbConnection conn = new NpgsqlConnection(AppConnctionStr)) { string sql; sql = @"
SELECT id as customer_org_id, display_name as customer_org_name, parent_id , path_code from customer_org where id = @CustomerOrgId ";
var customerOrgForPlugInss = (await conn.QueryAsync<CustomerOrgForPlugIns>(sql, new { CustomerOrgId = _importCustomerOrgId })).FirstOrDefault();
if (customerOrgForPlugInss == null) { throw new Exception("单位编号不正确，找不到单位"); }
var year = customerOrgForPlugInss.CustomerOrgName.Substring( customerOrgForPlugInss.CustomerOrgName.Length - 5 , 4); if (!int.TryParse(year, out var yearNumber)) { throw new Exception("单位名称必须是以2000年这样的格式结尾"); } if (yearNumber < 2024 || yearNumber > 2050) { throw new Exception("单位名称年限范围必须在2024-2050之间"); }
_year = year; } //加载单位信息
_customerOrgDto = await CallAppServiceAsync<CustomerOrgIdInputDto, CustomerOrgDto>( "api/app/CustomerOrg/GetById", new CustomerOrgIdInputDto() { CustomerOrgId = _importCustomerOrgId, }); //加载单位登记信息
_customerOrgRegisterDto = await CallAppServiceAsync<CustomerOrgIdInputDto, CustomerOrgRegisterDto>( "api/app/CustomerOrgRegister/GetLastCustomerOrgRegisterByCustomerOrgId", new CustomerOrgIdInputDto() { CustomerOrgId = _importCustomerOrgId, }); //加载人员类别列表
_personnelTypes = await CallAppServiceAsync<string, List<PersonnelTypeDto>>("api/app/PersonnelType/GetAll", ""); }
//public
public async Task<QztlPatientRegisterFromInterface?> CallInterfaceServiceAsync() { string baseAddress = InterfaceWebApiUrl; string ary = "HospitalId=" + _hospitalId + (char)38 + "year=" + _year + (char)38 + "AesKey=" + _aesKEY; baseAddress = baseAddress + ary; using (var httpClientHandler = new HttpClientHandler()) { using (var httpClient = new HttpClient(httpClientHandler)) { httpClient.BaseAddress = new Uri(baseAddress);
httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded"));//设置accept标头，告诉JSON是可接受的响应类型
//httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", _accesToken);
IsoDateTimeConverter timeFormat = new IsoDateTimeConverter(); timeFormat.DateTimeFormat = "yyyy-MM-dd HH:mm:ss"; //var sendData = JsonConvert.SerializeObject(data, Newtonsoft.Json.Formatting.Indented, timeFormat);
using (HttpContent httpContent = new StringContent("")) { httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded"); HttpResponseMessage response = await httpClient.GetAsync(""); string result; if (!response.IsSuccessStatusCode) { result = response.Content.ReadAsStringAsync().Result; throw new Exception("http通信错误:" + response.StatusCode + ",结果:" + result); } result = await response.Content.ReadAsStringAsync();
result = result.Replace(":\"[{", ":[{").Replace("}]\"", "}]").Replace("\\", ""); if (result.IndexOf("status") < 0) { throw new Exception($"调用WebApi中无status，返回值:" + result); } QztlPatientRegisterFromInterface? resultDto = JsonConvert.DeserializeObject<QztlPatientRegisterFromInterface>(result); if (resultDto != null) { if (resultDto.status != 0) { throw new Exception($"调用WebApi失败，返回错误,消息:" + resultDto.status + resultDto.errorMsg); } //插入数据库中备份
using (DbConnection conn = new NpgsqlConnection(AppConnctionStr)) { string sql; var qztlImportDataEntity = new QztlImportDataEntity() { Id = Guid.NewGuid(), Data = result, DataType = '0', IsComplete = 'Y', CreationTime = DateTime.Now, };
sql = @"insert into qztl_import_data(id, data, data_type, is_complete,creation_time)
values(@Id, @Data, @DataType, @IsComplete,@CreationTime)";
conn.Execute(sql, qztlImportDataEntity);
} return resultDto; } return null; }
} } }
public char ConvertMaritalStatus(int maritalStatus) {
switch (maritalStatus) { case 1: return '0'; case 2: return '1'; case 3: return '4'; default: return '9'; } }
public char ConvertSex(int sex) {
switch (sex) { case 1: return 'M'; case 2: return 'F'; default: return 'U'; } }
public string ConvertJobPost(string jobPost) { if (string.IsNullOrWhiteSpace(jobPost)) { return ""; } switch (jobPost) { case "0": return "普通成员"; case "1": return "班子成员"; default: return ""; } } public string ConvertJobTitle(string jobTitle) { if (string.IsNullOrWhiteSpace(jobTitle)) { return "无"; } switch (jobTitle) { case "0": return "无"; case "1": return "科员"; case "2": return "副科"; case "3": return "正科"; case "4": return "副处"; case "5": return "正处"; case "6": return "副局"; case "7": return "正局"; default: return "无"; } }
public PersonnelTypeDto ConvertPersonnelType(int personnelType) { string personnelTypeName; switch (personnelType) { case 1: personnelTypeName = "岗前"; break; case 2: personnelTypeName = "岗中"; break; case 3: personnelTypeName = "岗后"; break; default: personnelTypeName = ""; break; } if (string.IsNullOrWhiteSpace(personnelTypeName)) { return null; } var personnelTypeDto = _personnelTypes.Where(o => o.DisplayName == personnelTypeName).FirstOrDefault(); return personnelTypeDto; }
public async Task<CustomerOrgGroupDto> GetCustomerOrgGroup(List<string> goupNames, char sexId, char maritalStatusId) { string sexName = ""; if (sexId == 'M') { sexName = "男"; } else if (sexId == 'F') { sexName = "女"; } string groupName = ""; for (var i = 0; i < goupNames.Count; i++) { if (i == 0) { groupName = goupNames[i]; } else { groupName += goupNames[i]; } } string maritalStatusName; if (maritalStatusId == '0') { maritalStatusName = "未婚"; } else { maritalStatusName = "已婚"; } if (sexName == "女") { groupName += maritalStatusName + sexName; } else { groupName += sexName; }
_customerOrgGroupDtos = await CallAppServiceAsync<Guid, List<CustomerOrgGroupDto>>( "api/app/customer-org-group/in-customer-org-id/" + _importCustomerOrgId.ToString() , Guid.Empty, "get"); var customerOrgGroup = _customerOrgGroupDtos.Where(o => o.DisplayName == groupName).FirstOrDefault(); if (customerOrgGroup != null) { return customerOrgGroup; } //-------------自动创建分组
//检测有没有单个分组
string existGroupName = ""; var createCustomerOrgGroupWithDetailDto = new CreateCustomerOrgGroupWithDetailDto() { IsMaxMedicalTimes = 'Y', CustomerOrgId = _importCustomerOrgId, DisplayName = groupName, ForSexId = sexId, AgeLowerLimit = 0, AgeUpperLimit = 200, MaritalStatusId = 'A' }; for (var i = 0; i < goupNames.Count; i++) { if (i == 0) { if (sexName == "女") { existGroupName = goupNames[i] + maritalStatusName + sexName; } else { existGroupName = goupNames[i] + maritalStatusName + sexName; } } else { existGroupName = goupNames[i]; }
_customerOrgGroupDtos = await CallAppServiceAsync<Guid, List<CustomerOrgGroupDto>>( "api/app/customerorgregister/getlistincustomerorgid?CustomerOrgId=" + _importCustomerOrgId.ToString() , Guid.Empty, "get"); customerOrgGroup = _customerOrgGroupDtos.Where(o => o.DisplayName == existGroupName).FirstOrDefault(); if (customerOrgGroup == null) { throw new Exception($"分组名{existGroupName}不存在"); }
var customerOrgGroupDetailOrAsbitemDtos = await CallAppServiceAsync<Guid, List<CustomerOrgGroupDetailOrAsbitemDto>>( "api/app/customerorggroupdetail/getcustomerorggroupdetailinasbitem?CustomerOrgGroupId=" + customerOrgGroup.Id.ToString() , Guid.Empty, "get");
foreach (var customerOrgGroupDetailOrAsbitemDto in customerOrgGroupDetailOrAsbitemDtos) { if (!createCustomerOrgGroupWithDetailDto.Details. Where(o => o.AsbitemId == customerOrgGroupDetailOrAsbitemDto.AsbitemId).ToList().Any()) { createCustomerOrgGroupWithDetailDto.Details.Add(new CreateCustomerOrgGroupDetail_Detail() { AsbitemId = customerOrgGroupDetailOrAsbitemDto.AsbitemId, Amount = customerOrgGroupDetailOrAsbitemDto.CustomerOrgGroupDetailAmount, Price = customerOrgGroupDetailOrAsbitemDto.Price, }); }
} } customerOrgGroup = await CallAppServiceAsync<CreateCustomerOrgGroupWithDetailDto, CustomerOrgGroupDto>( "api/app/CustomerOrgGroup/CreateCustomerOrgGroupWithDetail", createCustomerOrgGroupWithDetailDto); return customerOrgGroup; }
public async Task AnswerOk(List<string> successIds, List<string> deleteIds) { if (successIds == null || deleteIds == null) { return; }
if (successIds.Count == 0 && deleteIds.Count == 0) { return; } string successIdStr = ""; for (var i = 0; i < successIds.Count; i++) { if (i == 0) { successIdStr = successIds[i]; } else { successIdStr += "," + successIds[i]; } } string deleteIdStr = ""; for (var i = 0; i < deleteIds.Count; i++) { if (i == 0) { deleteIdStr = deleteIds[i]; } else { deleteIdStr += "," + deleteIds[i]; } } string baseAddress = _answerWebApiUrl;// "http://62.156.10.237:8005/health/values/SetPlanOK?";
string ary = "HospitalId=" + _hospitalId + (char)38 + "ids=" + successIdStr + (char)38 + "delids=" + deleteIdStr + (char)38 + "AesKey=" + _aesKEY; baseAddress = baseAddress + ary; using (var httpClientHandler = new HttpClientHandler()) { using (var httpClient = new HttpClient(httpClientHandler)) { httpClient.BaseAddress = new Uri(baseAddress);
httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded"));//设置accept标头，告诉JSON是可接受的响应类型
//httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", _accesToken);
IsoDateTimeConverter timeFormat = new IsoDateTimeConverter(); timeFormat.DateTimeFormat = "yyyy-MM-dd HH:mm:ss"; //var sendData = JsonConvert.SerializeObject(data, Newtonsoft.Json.Formatting.Indented, timeFormat);
using (HttpContent httpContent = new StringContent("")) { httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded"); HttpResponseMessage response = await httpClient.GetAsync(""); string result; if (!response.IsSuccessStatusCode) { result = response.Content.ReadAsStringAsync().Result; throw new Exception("http通信错误:" + response.StatusCode + ",结果:" + result); } result = await response.Content.ReadAsStringAsync();
result = result.Replace(":\"[{", ":[{").Replace("}]\"", "}]").Replace("\\", ""); if (result.IndexOf("更新ok") >= 0 || result.IndexOf("更新OK") >= 0 || result.IndexOf("更新Ok") >= 0) { return; } dynamic? resultDto = JsonConvert.DeserializeObject(result); if (resultDto != null) { if (resultDto.status != 0) { throw new Exception($"调用WebApi失败，返回错误,消息:" + resultDto.status + resultDto.errorMsg); } //插入数据库中备份
using (DbConnection conn = new NpgsqlConnection(AppConnctionStr)) { string sql; var qztlImportDataEntity = new QztlImportDataEntity() { Id = Guid.NewGuid(), Data = result, DataType = '0', IsComplete = 'Y', CreationTime = DateTime.Now, };
sql = @"insert into qztl_import_data(id, data, data_type, is_complete,creation_time)
values(@Id, @Data, @DataType, @IsComplete,@CreationTime)";
conn.Execute(sql, qztlImportDataEntity);
} return; } return; }
} } } }}
|
