更新

controllers/sg/his_api_controller.go

@@ -34,6 +34,7 @@ import (
 	"syscall"
 	"time"
 	"unsafe"
+	"github.com/go-ole/go-ole"
 )
 
 type HisApiController struct {
@@ -5895,7 +5896,7 @@ func SaleStock(org_id int64, pre models.HisPrescription, drug *models.DrugFlow,
 
 	}
 
-	if org_id == 10610 || org_id == 10278 || org_id == 10138 || org_id == 10537 || org_id == 10028 {
+	if org_id == 10610 || org_id == 10278 || org_id == 10138 || org_id == 10537 || org_id == 10028 || org_id == 10191 {
 
 		if drug.HisDoctorAdviceInfo.BaseDrugLib.IsZeroFlag == 1 {
 			struct3505.TrdnFlag = "1"
@@ -28559,7 +28560,7 @@ func (c *HisApiController) GetRegisterInfo() {
 					}
 					var result string
 					var requestLog string
-					if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" {
+					if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882"  || miConfig.Code == "H44090200998"{
 						var hisPrescription []*models.HisPrescription
 						res3101 := Checkgd3101ForOne(c, patient.ID, his, admin_user_id, "1", record_time, hisPrescription, department)
 						if res3101.Infcode == 0 {
@@ -32220,7 +32221,7 @@ func (c *HisApiController) GetUploadInfo() {
 					}
 					result2, src_resquest = service.Gdyb2207(his.PsnNo, his.Number, chrg_bchno, cert_no, insutype, allTotal, miConfig.OrgName, roles.UserName, miConfig.Code, his.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, med_type, his.IdCardType, tempOrder.FulamtOwnpayAmt, tempOrder.OverlmtSelfPay, tempOrder.PreselfpayAmt, tempOrder.InscpScpAmt, his.IdType, acct_used_flag, "", admin_user_id)
 				} else {
-					if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" {
+					if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" ||  miConfig.Code == "H44090200998"{
 						result3101 := Checkgd3102(c, id, his_patient_id, admin_user_id, "7", tempOrder.ID)
 						if result3101.Infcode == 0 {
 							if len(result3101.Output.Result) > 0 {
@@ -34245,7 +34246,7 @@ func (c *HisApiController) GetPreUploadInfo() {
 						res.Infcode = infocode
 
 					} else {
-						if miConfig.Code == "H44030903432" || miConfig.Code == "H44030501364" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" {
+						if miConfig.Code == "H44030903432" || miConfig.Code == "H44030501364" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" || miConfig.Code == "H44090200998" {
 							result3101 := Checkgd3101(c, id, his_patient_id, admin_user_id, "2", record_time, prescriptions)
 							if result3101.Infcode == 0 {
 								if len(result3101.Output.Result) > 0 {
@@ -35947,7 +35948,7 @@ func (c *HisApiController) GetPreUploadInfo() {
 
 							psn_info, _ := service.GetPsnByPatientId(his.PatientId)
 							allTotal = fmt.Sprintf("%.2f", total_two)
-							if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" {
+							if miConfig.Code == "H44030501364" || miConfig.Code == "H44030903432" || miConfig.Code == "H44030500255" || miConfig.Code == "H44082500483" || miConfig.Code == "H44030702287" || miConfig.Code == "H44030304882" || miConfig.Code == "H44090200998" {
 
 								result3101 := Checkgd3102(c, id, his_patient_id, admin_user_id, "6", order.ID)
 								if result3101.Infcode == 0 {

main.go

@@ -77,6 +77,8 @@ func main() {
 
 	//深圳百霖
 	//GetblBatchSettleList()
+	//GetblpgBatchSettleList()
+
 	//GetblbrBatchSettleList()
 	//深圳百霖贝尔
 	//GetblbrBatchSettleList()
@@ -707,10 +709,231 @@ type ResultSeventeen struct {
 //
 func GetblBatchSettleList() {
 	org_id, _ := beego.AppConfig.Int64("org_id")
-	org_id = 10610
+	org_id = 9504
 	var orders []*models.HisOrder
 	//var orders []*models.HisOrderError
 	orders, _ = service.GetAllHisOrder10138()
+	for _, item := range orders {
+		order_id := item.ID
+		order, _ := service.GetHisOrderByIDTwo(order_id)
+		if order.MedType == "14" {
+			his, _ := service.GetHisPatientByNumber(order.MdtrtId)
+			var patientPrescription models.HisPrescriptionInfo
+			patientPrescription, _ = service.FindLastPatientPrescriptionInfo(order.UserOrgId, order.PatientId, order.SettleAccountsDate)
+			doctor_info, _ := service.GetAdminUserInfoByID(order.UserOrgId, patientPrescription.DoctorId)
+			department, _ := service.GetDepartMentDetail(patientPrescription.Departments)
+			miConfig, _ := service.FindMedicalInsuranceInfo(order.UserOrgId)
+			var configTwo []*models.HisXtDiagnoseConfig
+			diagnosis_idstwo := strings.Split(his.Diagnosis, ",")
+			curRoles, _ := service.GetAdminUserInfoByID(org_id, 5488)
+			for _, item := range diagnosis_idstwo {
+				id, _ := strconv.ParseInt(item, 10, 64)
+				diagnosisConfig, _ := service.FindDiagnoseById(id)
+				configTwo = append(configTwo, &diagnosisConfig)
+			}
+			patient, _ := service.GetPatientByIDTwo(9504, order.PatientId)
+
+			sickConfig, _ := service.FindSickById(his.SickType)
+			//if order.MedType == "1111" || order.MedType == "1112" {
+			//	order.MedType = "11"
+			//}
+			service.Gdyb2203d(his.PsnNo, his.Number, doctor_info.UserName, department.Name, miConfig.OrgName, "14", doctor_info.DoctorNumber, miConfig.Code, his.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, sickConfig.ContentCode, sickConfig.ClassName, curRoles.UserName, configTwo, time.Unix(his.RecordDate, 0).Format("2006-01-02 15:04:05"))
+
+			depart, _ := service.GetDepartMentDetail(curRoles.DepartmentId)
+			pre, _ := service.GetNewHisPrescriptionByNumber(order.Number)
+			doctor, _ := service.GetAdminUserInfoByID(org_id, pre.Creator)
+			if order.ID == 0 {
+				return
+			}
+			if his.BalanceAccountsType == 2 {
+				continue
+			}
+
+			ID := strconv.FormatInt(int64(order.ID), 10)
+
+			struct4101 := service.Struct4101{
+				PsnNo:          order.PsnNo,
+				MdtrtId:        order.MdtrtId,
+				SetlId:         order.SetlId,
+				PsnName:        order.PsnName,
+				Gend:           order.Gend,
+				Brdy:           his.Brdy,
+				Age:            his.Age,
+				Naty:           order.Naty,
+				PatnCertType:   order.PsnCertType,
+				Certno:         order.Certno,
+				Prfs:           "90",
+				ConerName:      "",
+				PatnRlts:       "",
+				ConerAddr:      "",
+				ConerTel:       "",
+				HiType:         order.Insutype,
+				Insuplc:        his.InsuplcAdmdvs,
+				MaindiagFlag:   "1",
+				BillCode:       "000"+ID,
+				BillNo:         "000"+ID,
+				BizSn:          order.Number,
+				PsnSelfPay:     order.PsnPartAmt,
+				PsnOwnPay:      order.PsnPartAmt,
+				AcctPay:        order.AcctPay,
+				PsnCashpay:     order.PsnCashPay,
+				HiPaymtd:       "1",
+				Hsorg:          his.InsuplcAdmdvs,
+				HsorgOpter:     his.InsuplcAdmdvs,
+				MedinsFillPsn:  curRoles.UserName,
+				MedinsFillDept: depart.Name,
+				IptMedType:     "2",
+				CurAddr:        patient.HomeAddress,
+			}
+
+			struct4101.SetlBegnDate = order.SetlTime
+			struct4101.SetlEndDate = order.SetlTime
+
+			var rf []CustomFundPay
+			json.Unmarshal([]byte(order.SetlDetail), &rf)
+
+			//var tempFunPays []service.CustomStruct
+			//var tempFunPay610100 service.CustomStruct
+
+			//for _, item := range rf {
+			//	if item.FundPayType == "610100" {
+			//		tempFunPay610100.FundPayamt, _ = decimal.NewFromFloat(tempFunPay610100.FundPayamt).Add(decimal.NewFromFloat(item.FundPayamt)).Float64()
+			//		tempFunPay610100.FundPayType = item.FundPayType
+			//	} else {
+			//		var tempFunPay service.CustomStruct
+			//		tempFunPay.FundPayamt = item.FundPayamt
+			//		tempFunPay.FundPayType = item.FundPayType
+			//		tempFunPays = append(tempFunPays, tempFunPay)
+			//	}
+			//}
+			//tempFunPays = append(tempFunPays, tempFunPay610100)
+			//struct4101.CustomStruct = tempFunPays
+
+			var tempDiaginfos []service.DiaginfoStructTwo
+			var tempOpspdiseinfo2 service.OpspdiseinfoStruct
+			var tempOpspdiseinfos []service.OpspdiseinfoStruct
+
+			diagnosis_ids := strings.Split(his.Diagnosis, ",")
+			var config []*models.HisXtDiagnoseConfig
+			for _, item := range diagnosis_ids {
+				id, _ := strconv.ParseInt(item, 10, 64)
+				if id == 24 {
+
+					diagnosisConfig, _ := service.FindDiagnoseById(id)
+					config = append(config, &diagnosisConfig)
+				}
+
+			}
+
+			for _, item := range diagnosis_ids {
+
+				id, _ := strconv.ParseInt(item, 10, 64)
+				if id != 24 {
+					diagnosisConfig, _ := service.FindDiagnoseById(id)
+					config = append(config, &diagnosisConfig)
+				}
+
+			}
+
+			for index, item := range config {
+				if index == 0 {
+					var tempDiaginfo service.DiaginfoStructTwo
+					tempDiaginfo.DiagCode = item.CountryCode
+					tempDiaginfo.DiagName = item.CountryContentName
+					tempDiaginfo.DiagType = "1"
+					tempDiaginfo.MaindiagFlag = "1"
+					tempDiaginfos = append(tempDiaginfos, tempDiaginfo)
+				} else {
+
+					var tempDiaginfo service.DiaginfoStructTwo
+					tempDiaginfo.DiagCode = item.CountryCode
+					tempDiaginfo.DiagName = item.CountryContentName
+					tempDiaginfo.DiagType = "1"
+					tempDiaginfo.MaindiagFlag = "0"
+					tempDiaginfos = append(tempDiaginfos, tempDiaginfo)
+				}
+			}
+			struct4101.Diseinfo = tempDiaginfos
+			sickConfigTwo, _ := service.FindSickById(his.SickType)
+			tempOpspdiseinfo2.DiagCode = sickConfigTwo.ContentCode
+			tempOpspdiseinfo2.DiagName = sickConfigTwo.CountryContentName
+			tempOpspdiseinfo2.OprnOprtCode = ""
+			tempOpspdiseinfo2.OprnOprtName = ""
+			tempOpspdiseinfos = append(tempOpspdiseinfos, tempOpspdiseinfo2)
+			struct4101.OpspdiseinfoStruct = tempOpspdiseinfos
+			time_arr := strings.Split(order.SetlTime, " ")
+			struct4101.AdmTime = time_arr[0]
+			struct4101.AdmEndTime = time_arr[0]
+			struct4101.DoctorName = doctor.UserName
+			struct4101.DoctorCode = doctor.DoctorNumber
+
+			struct4101.Ntly = "CHN"
+			struct4101.AdmCaty = "A03.06"
+			var res ResultSeventeen
+
+			result, request := service.Gdyb4101For10138(struct4101, miConfig.SecretKey, miConfig.OrgName, curRoles.UserName, miConfig.Code, his.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, org_id)
+			fmt.Println(result)
+			saveLog(result, request, "4101A", "清单上传")
+			var dat map[string]interface{}
+			if err := json.Unmarshal([]byte(result), &dat); err == nil {
+				fmt.Println(dat)
+			} else {
+				fmt.Println(err)
+			}
+			userJSONBytes, _ := json.Marshal(dat)
+			if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+				//utils.ErrorLog("解析失败：%v", err)
+				//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				//adminUser := c.GetAdminUserInfo()
+				errlog := &models.HisOrderError{
+					UserOrgId: org_id,
+					Ctime:     time.Now().Unix(),
+					Mtime:     time.Now().Unix(),
+					ErrMsg:    res.ErrMsg + "解析失败",
+					Status:    1,
+					PatientId: order_id,
+					Stage:     10138600,
+				}
+				service.CreateErrMsgLog(errlog)
+				continue
+			}
+
+			if res.Infcode != 0 {
+				//adminUser := c.GetAdminUserInfo()
+				errlog := &models.HisOrderError{
+					UserOrgId: org_id,
+					Ctime:     time.Now().Unix(),
+					Mtime:     time.Now().Unix(),
+					ErrMsg:    res.ErrMsg,
+					Status:    1,
+					PatientId: order_id,
+					Stage:     10138600,
+				}
+				service.CreateErrMsgLog(errlog)
+				continue
+			} else {
+				hisFundSettleListResult := &models.HisFundSettleListResult{
+					Number:    res.Output.SetlListId,
+					Status:    1,
+					Ctime:     time.Now().Unix(),
+					Mtime:     time.Now().Unix(),
+					UserOrgId: org_id,
+					IsUpload:  1,
+					OrderId:   order_id,
+				}
+				service.CreateUploadRecord(hisFundSettleListResult)
+				continue
+			}
+		}
+	}
+}
+
+func GetblpgBatchSettleList() {
+	org_id, _ := beego.AppConfig.Int64("org_id")
+	org_id = 10610
+	var orders []*models.HisOrder
+	//var orders []*models.HisOrderError
+	orders, _ = service.GetAllHisOrder10610()
 	for _, item := range orders {
 		order_id := item.ID
 		order, _ := service.GetHisOrderByIDTwo(order_id)
@@ -746,6 +969,8 @@ func GetblBatchSettleList() {
 			if his.BalanceAccountsType == 2 {
 				continue
 			}
+			ID := strconv.FormatInt(int64(order.ID), 10)
+
 			struct4101 := service.Struct4101{
 				PsnNo:          order.PsnNo,
 				MdtrtId:        order.MdtrtId,
@@ -765,8 +990,8 @@ func GetblBatchSettleList() {
 				HiType:         order.Insutype,
 				Insuplc:        his.InsuplcAdmdvs,
 				MaindiagFlag:   "1",
-				BillCode:       order.SetlId,
-				BillNo:         order.SetlId,
+				BillCode:      "000" +ID,
+				BillNo:        "000" +ID,
 				BizSn:          order.Number,
 				PsnSelfPay:     order.PsnPartAmt,
 				PsnOwnPay:      order.PsnPartAmt,
@@ -963,7 +1188,10 @@ func GetblbrBatchSettleList() {
 			}
 			if his.BalanceAccountsType == 2 {
 				continue
+
 			}
+			ID := strconv.FormatInt(int64(order.ID), 10)
+
 			struct4101 := service.Struct4101{
 				PsnNo:          order.PsnNo,
 				MdtrtId:        order.MdtrtId,
@@ -983,8 +1211,8 @@ func GetblbrBatchSettleList() {
 				HiType:         order.Insutype,
 				Insuplc:        his.InsuplcAdmdvs,
 				MaindiagFlag:   "1",
-				BillCode:       order.SetlId,
-				BillNo:         order.SetlId,
+				BillCode:      "000" +ID,
+				BillNo:        "000" +ID,
 				BizSn:          order.Number,
 				PsnSelfPay:     order.PsnPartAmt,
 				PsnOwnPay:      order.PsnPartAmt,

service/his_service.go

@@ -1570,7 +1570,12 @@ func GetAllHisOrder10106(org_id int64) (his []*models.HisOrder, err error) {
 	return
 }
 func GetAllHisOrder10138() (his []*models.HisOrder, err error) {
-	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = 10610  AND status = 1  AND  order_status = 2 AND  setl_id <> '' AND setl_time >= '2024-12-01 00:00:00'  and mdtrt_id not like '%out%'").Order("setl_time asc").Find(&his).Error
+	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = 9504  AND status = 1  AND  order_status = 2 AND  setl_id <> '' AND setl_time >= '2025-02-01 00:00:00'  and mdtrt_id not like '%out%'").Order("setl_time asc").Find(&his).Error
+	fmt.Println(err)
+	return
+}
+func GetAllHisOrder10610() (his []*models.HisOrder, err error) {
+	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = 10610  AND status = 1  AND  order_status = 2 AND  setl_id <> '' AND setl_time >= '2025-01-01 00:00:00'  and mdtrt_id not like '%out%'").Order("setl_time asc").Find(&his).Error
 	fmt.Println(err)
 	return
 }
@@ -1581,7 +1586,7 @@ func GetOrderError10138() (order []*models.HisOrderError, err error) {
 
 func GetAllHisOrder10278() (his []*models.HisOrder, err error) {
 
-	err = readDb.Model(&models.HisOrder{}).Where(" user_org_id = 10278  AND status = 1  AND  order_status = 2 AND setl_id <> ''  AND setl_time >= '2024-12-01 00:00:00'  and mdtrt_id not like '%out%'").Order("setl_time asc").Find(&his).Error
+	err = readDb.Model(&models.HisOrder{}).Where(" user_org_id = 10278  AND status = 1  AND  order_status = 2 AND setl_id <> ''  AND setl_time >= '2025-01-01 00:00:00'  and mdtrt_id not like '%out%'").Order("setl_time asc").Find(&his).Error
 	fmt.Println(err)
 	return
 }
@@ -1806,7 +1811,12 @@ func GetNewDrugFlowInforTenone(start_system_time int64, end_system_time int64, o
 	}).Preload("NewDrugWarehouseInfo", "status = 1").Find(&flows).Error
 	return
 }
-
+func GetNewDrugFlowInforTentwo(start_system_time int64, end_system_time int64, org_id int64) (flows []*models.DrugFlow, err error) {
+	err = readDb.Model(&models.DrugFlow{}).Joins("join his_doctor_advice_info info on info.patient_id = xt_drug_flow.patient_id and info.drug_id = xt_drug_flow.drug_id and info.record_date = xt_drug_flow.system_time").Where("xt_drug_flow.user_org_id = ? and xt_drug_flow.status = 1 and xt_drug_flow.sale_date = ?", org_id,"2025-03-02").Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 and drug_code <> ''").Preload("BaseDrugLib", "status=1")
+	}).Preload("NewDrugWarehouseInfo", "status = 1").Find(&flows).Error
+	return
+}
 func GetHisPrescriptionByID(id int64) (pre models.HisPrescription) {
 	err = readDb.Model(&models.HisPrescription{}).Where("id = ? and status = 1", id).Find(&pre).Error
 	return

service/hn_service.go

@@ -1984,8 +1984,10 @@ func Hnyb3505(struct3505 models.Struct3505) (string, string) {
 		fmt.Println(err.Error())
 		return err.Error(), ""
 	}
+	timestamp2 := time.Now().UnixNano() / int64(time.Millisecond)
+
 	struct3505.RequestUrl = struct3505.RequestUrl + "3505"
-	return HNHttpRequest(struct3505.RequestUrl, struct3505.AccessKey, struct3505.SecretKey, timestamp, string(bytesData), "3505"), string(bytesData)
+	return HNHttpRequest(struct3505.RequestUrl, struct3505.AccessKey, struct3505.SecretKey, timestamp2, string(bytesData), "3505"), string(bytesData)
 
 }