医保对接

controllers/his_api_controller.go

@@ -710,6 +710,234 @@ func (c *HisApiController) CreateHisPrescription() {
 
 	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
 
+	if drugStockConfig.IsOpen == 1 {
+		//校验库存总量
+		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
+			prescriptions, _ := dataBody["prescriptions"].([]interface{})
+			if len(prescriptions) > 0 {
+				for _, item := range prescriptions {
+					items := item.(map[string]interface{})
+					if items["advices"] != nil && reflect.TypeOf(items["advices"]).String() == "[]interface {}" {
+						advices := items["advices"].([]interface{})
+						if len(advices) > 0 {
+							for _, advice := range advices {
+								var drug_id int64
+								var prescribing_number float64
+								var prescribingNumberUnit string
+								var prescribingNumber string
+								var adviceId int64
+								if advice.(map[string]interface{})["id"] != nil || reflect.TypeOf(advice.(map[string]interface{})["id"]).String() == "float64" {
+									drug_id = int64(advice.(map[string]interface{})["id"].(float64))
+								}
+								if advice.(map[string]interface{})["prescribing_number"] != nil || reflect.TypeOf(advice.(map[string]interface{})["prescribing_number"]).String() == "string" {
+									//prescribing_number = advice.(map[string]interface{})["prescribing_number"].(string)
+									prescribing_number_str := advice.(map[string]interface{})["prescribing_number"].(string)
+									prescribingNumber = advice.(map[string]interface{})["prescribing_number"].(string)
+									prescribing_number, _ = strconv.ParseFloat(prescribing_number_str, 64)
+
+								}
+
+								if advice.(map[string]interface{})["prescribing_number_unit"] != nil && reflect.TypeOf(advice.(map[string]interface{})["prescribing_number_unit"]).String() == "string" {
+									prescribingNumberUnit, _ = advice.(map[string]interface{})["prescribing_number_unit"].(string)
+								}
+
+								if advice.(map[string]interface{})["advice_id"] != nil || reflect.TypeOf(advice.(map[string]interface{})["advice_id"]).String() == "float64" {
+									adviceId = int64(advice.(map[string]interface{})["advice_id"].(float64))
+								}
+
+								drug, _ := service.FindBaseDrugLibRecord(adminInfo.CurrentOrgId, drug_id)
+								if drug.ID == 0 {
+									c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+									return
+								}
+
+								//查询药品的所有库存
+								list, _ := service.GetDrugWarehouseInfoPrescription(drug_id, adminInfo.CurrentOrgId)
+								var total_count int64
+								for _, it := range list {
+									total_count += it.StockMaxNumber*drug.MinNumber + it.StockMinNumber
+								}
+								totals := strconv.FormatInt(total_count, 10)
+								//查询该药品是否存在开药记录
+								advicelist, _ := service.GetHisAdviceListByDrugIdEight(drug_id, patient_id, recordDateTime, adviceId)
+								//修改处方
+								if advicelist.ID > 0 {
+									var device_number int64
+									if advicelist.PrescribingNumberUnit == drug.MaxUnit {
+										prescribingNumber := strconv.FormatFloat(advicelist.PrescribingNumber, 'f', -1, 64)
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+										device_number = prescribingNumberInt * drug.MinNumber
+									}
+									if advicelist.PrescribingNumberUnit == drug.MinUnit {
+										prescribingNumber := strconv.FormatFloat(advicelist.PrescribingNumber, 'f', -1, 64)
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+										device_number = prescribingNumberInt
+									}
+
+									var number_count int64
+									if prescribingNumberUnit == drug.MaxUnit {
+										prescribingNumber := strconv.FormatFloat(advicelist.PrescribingNumber, 'f', -1, 64)
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+										number_count = prescribingNumberInt * drug.MinNumber
+									}
+									if prescribingNumberUnit == drug.MinUnit {
+										prescribingNumber := strconv.FormatFloat(advicelist.PrescribingNumber, 'f', -1, 64)
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+										number_count = prescribingNumberInt
+									}
+									//如果修改的数量大于之前修改的数量
+									if (number_count - device_number) > 0 {
+										//如果修改的差数量 大于库存数量
+										if (number_count - device_number) > total_count {
+											c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
+											return
+										}
+									}
+
+									var sum_count int64
+									//判断是否做过修改
+									if prescribingNumberUnit == drug.MaxUnit {
+
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+
+										sum_count = prescribingNumberInt * drug.MinNumber
+									}
+									if prescribingNumberUnit == drug.MinUnit {
+										prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+										sum_count = prescribingNumberInt
+									}
+									fmt.Println("原先药品记录", device_number)
+									fmt.Println("现在出库数量", sum_count)
+									if device_number != sum_count {
+
+										// 查询该药品最后一次出库记录
+										druginfo, _ := service.GetLastDrugWarehouseOutByDrugId(drug_id, patient_id, recordDateTime)
+										//回退库存
+										if druginfo.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
+											service.ModefyDrugByWarehouseInfo(druginfo.WarehouseInfoId, druginfo.Count)
+										}
+										if druginfo.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
+											service.ModefyDrugByWarehouseInfoOne(druginfo.WarehouseInfoId, druginfo.Count)
+										}
+
+										if druginfo.CountUnit == drug.MaxUnit && druginfo.CountUnit == drug.MinUnit && drug.MaxUnit == drug.MinUnit {
+											service.ModefyDrugByWarehouseInfo(druginfo.WarehouseInfoId, druginfo.Count)
+										}
+
+										//删除记录
+										service.DeleteDrugAutoWarehouseSeven(drug_id, patient_id, recordDateTime, adviceId)
+									}
+
+								}
+
+								//新增处方
+								if advicelist.ID == 0 {
+									all_count, _ := strconv.ParseFloat(totals, 64)
+									if prescribingNumberUnit == drug.MinUnit {
+										if prescribing_number > all_count {
+											c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
+											return
+										}
+									} else {
+										if prescribingNumberUnit == drug.MaxUnit {
+											num := prescribing_number * float64(drug.MinNumber)
+											if num > all_count {
+												c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
+												return
+											}
+										}
+									}
+								}
+							}
+
+						}
+					}
+				}
+			}
+		}
+	}
+	if stockConfig.IsOpen == 1 {
+		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
+			prescriptions, _ := dataBody["prescriptions"].([]interface{})
+			if len(prescriptions) > 0 {
+				for _, item := range prescriptions {
+					items := item.(map[string]interface{})
+					if items["project"] != nil && reflect.TypeOf(items["project"]).String() == "[]interface {}" {
+						projects := items["project"].([]interface{})
+						if len(projects) > 0 {
+							for _, project := range projects {
+								var project_id int64
+								var project_type int64
+								var totals float64
+								var parsetotal int64
+								if project.(map[string]interface{})["project_id"] != nil || reflect.TypeOf(project.(map[string]interface{})["project_id"]).String() == "float64" {
+									project_id = int64(project.(map[string]interface{})["project_id"].(float64))
+								}
+								if project.(map[string]interface{})["type"] != nil || reflect.TypeOf(project.(map[string]interface{})["type"]).String() == "float64" {
+									project_type = int64(project.(map[string]interface{})["type"].(float64))
+								}
+								if project.(map[string]interface{})["total"] != nil || reflect.TypeOf(project.(map[string]interface{})["total"]).String() == "string" {
+									total, _ := project.(map[string]interface{})["total"].(string)
+
+									totals, _ = strconv.ParseFloat(total, 64)
+									parsetotal, _ = strconv.ParseInt(total, 10, 64)
+								}
+								if project_type == 3 {
+
+									//查找该耗材的出库记录
+									goodWarehouseInfo, _ := service.GetAutoRecordByGoodId(project_id, patient_id, recordDateTime)
+									fmt.Println("出库数量00000000000000000000000", parsetotal)
+									fmt.Println("已经出库数量0000000000000000000", goodWarehouseInfo.Count)
+
+									//查询该患者耗材的历史数据
+									ordProject, _ := service.GetHisProjectPrescriptionByPatientId(patient_id, recordDateTime)
+									fmt.Println("长度1", len(ordProject))
+									fmt.Println("新长度", len(projects))
+									if goodWarehouseInfo.ID > 0 {
+										//数量发生改变
+										if parsetotal != goodWarehouseInfo.Count || len(ordProject) != len(projects) {
+											//查找今日该患者已经出库的所有耗材
+											goodList, _ := service.GetAllAutoRecordByPatient(patient_id, recordDateTime)
+											for _, item := range goodList {
+												//回退库存
+												service.ModefyWarehouseInfo(item.Count, item.WarehouseInfotId)
+												//删除记录
+												service.DeleteAutoWarehouse(item.PatientId, item.SysRecordTime)
+											}
+
+										}
+
+									}
+									if goodWarehouseInfo.ID == 0 {
+										good, _ := service.FindGoodInfoByIdTwo(project_id)
+										if good.ID == 0 {
+											c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+											return
+										}
+										//查询耗材库存
+										list, _ := service.GetGoodWarehouseInfo(project_id)
+										var stock_count int64
+										for _, it := range list {
+											stock_count += it.StockCount
+										}
+										stock_counts := strconv.FormatInt(stock_count, 10)
+										stock_total_count, _ := strconv.ParseFloat(stock_counts, 64)
+										if totals > stock_total_count {
+											fmt.Println("hh23323233233332323332323323322323")
+											c.ServeDynamicFailJsonSend(good.GoodName + "库存不足")
+											return
+										}
+									}
+								}
+
+							}
+						}
+					}
+				}
+			}
+		}
+	}
+
 	ch := make(chan struct{})
 	count := 3 // count 表示活动的协程个数