医保对接

controllers/his_api_controller.go

@@ -435,147 +435,150 @@ func (c *HisApiController) GetHisPatientInfo() {
 		prescriptions, _ = service.GetNewHisPrescription(admin.CurrentOrgId, patient_id, his_patient_id, recordDateTime, p_type)
 		last_prescriptions, _ = service.GetHisPrescription(admin.CurrentOrgId, patient_id, last_p_info.RecordDate, p_type)
 	}
-
 	sch, _ := service.GetPatientSch(patient_id, recordDateTime, admin.CurrentOrgId)
-	if sch.ID > 0 {
-		var week string
-		t := time.Now()
-		switch t.Weekday().String() {
-		case "Monday":
-			week = "周一"
-			break
-		case "Tuesday":
-			week = "周二"
-
-			break
-		case "Wednesday":
-			week = "周三"
-
-			break
-		case "Thursday":
-			week = "周四"
-
-			break
-		case "Friday":
-			week = "周五"
-
-			break
-		case "Saturday":
-			week = "周六"
-
-			break
-		case "Sunday":
-			week = "周日"
-
-			break
 
-		}
+	if admin.CurrentOrgId != 10215 {
 
-		mode_template, _ := service.GetHisPrescriptionBySchMode(sch.ModeId, patient_id, admin.CurrentOrgId)
-		temp_sch_prescriptions, _ := service.GetHisPrescriptionTemplate(mode_template.ID, admin.CurrentOrgId)
-
-		//根据推送频率组装新的数组
-		for _, item := range temp_sch_prescriptions {
-			var cus CustomTemplate
-			cus.ID = item.ID
-			cus.UserOrgId = item.UserOrgId
-			cus.PatientId = item.PatientId
-			cus.MedType = item.MedType
-			cus.RecordDate = item.RecordDate
-			cus.Type = item.Type
-			cus.PType = item.PType
-			for _, subItem := range item.HisPrescriptionAdviceTemplate {
-				if find := strings.Contains(subItem.Drug.DrugStatus, "停用"); !find {
-					if subItem.FrequencyType == 1 { //每次必推
-						cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
-					}
+		if sch.ID > 0 {
+			var week string
+			t := time.Now()
+			switch t.Weekday().String() {
+			case "Monday":
+				week = "周一"
+				break
+			case "Tuesday":
+				week = "周二"
 
-					if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 { //按照星期来推
-						cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
-					}
+				break
+			case "Wednesday":
+				week = "周三"
 
-					if subItem.FrequencyType == 2 { //按照天数频率
-						p, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
-						now := p.Unix()
-						dayStr := strconv.FormatInt(subItem.DayCount, 10)
-						dayStr2 := "-" + dayStr
-						count, _ := strconv.ParseInt(dayStr2, 10, 64)
-						oldTime := time.Now().AddDate(0, 0, int(count)).Unix()
-						advices, _ := service.FindAllHisDoctorAdviceByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.DrugId)
-						if len(advices) == 0 {
-							cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
-						}
-					}
-				}
-			}
+				break
+			case "Thursday":
+				week = "周四"
 
-			for _, subItem := range item.HisPrescriptionProjectTemplate {
+				break
+			case "Friday":
+				week = "周五"
+
+				break
+			case "Saturday":
+				week = "周六"
+
+				break
+			case "Sunday":
+				week = "周日"
+
+				break
+
+			}
 
-				if subItem.Type == 2 {
-					if subItem.XtHisProject.MedicalStatus != 1 {
-						if subItem.FrequencyType == 1 {
-							cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+			mode_template, _ := service.GetHisPrescriptionBySchMode(sch.ModeId, patient_id, admin.CurrentOrgId)
+			temp_sch_prescriptions, _ := service.GetHisPrescriptionTemplate(mode_template.ID, admin.CurrentOrgId)
+
+			//根据推送频率组装新的数组
+			for _, item := range temp_sch_prescriptions {
+				var cus CustomTemplate
+				cus.ID = item.ID
+				cus.UserOrgId = item.UserOrgId
+				cus.PatientId = item.PatientId
+				cus.MedType = item.MedType
+				cus.RecordDate = item.RecordDate
+				cus.Type = item.Type
+				cus.PType = item.PType
+				for _, subItem := range item.HisPrescriptionAdviceTemplate {
+					if find := strings.Contains(subItem.Drug.DrugStatus, "停用"); !find {
+						if subItem.FrequencyType == 1 { //每次必推
+							cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
 						}
 
-						if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 {
-							cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+						if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 { //按照星期来推
+							cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
 						}
 
-						if subItem.FrequencyType == 2 {
+						if subItem.FrequencyType == 2 { //按照天数频率
 							p, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
 							now := p.Unix()
 							dayStr := strconv.FormatInt(subItem.DayCount, 10)
 							dayStr2 := "-" + dayStr
 							count, _ := strconv.ParseInt(dayStr2, 10, 64)
 							oldTime := time.Now().AddDate(0, 0, int(count)).Unix()
-							projects, _ := service.FindAllHisProjectByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.ProjectId)
-							if len(projects) == 0 {
-								cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+							advices, _ := service.FindAllHisDoctorAdviceByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.DrugId)
+							if len(advices) == 0 {
+								cus.HisPrescriptionAdviceTemplate = append(cus.HisPrescriptionAdviceTemplate, subItem)
 							}
 						}
-
 					}
+				}
 
-				} else if subItem.Type == 3 {
-					if find := strings.Contains(subItem.GoodInfo.GoodStatus, "停用"); !find {
-						if subItem.FrequencyType == 1 {
-							cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
-						}
+				for _, subItem := range item.HisPrescriptionProjectTemplate {
+
+					if subItem.Type == 2 {
+						if subItem.XtHisProject.MedicalStatus != 1 {
+							if subItem.FrequencyType == 1 {
+								cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+							}
+
+							if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 {
+								cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+							}
+
+							if subItem.FrequencyType == 2 {
+								p, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
+								now := p.Unix()
+								dayStr := strconv.FormatInt(subItem.DayCount, 10)
+								dayStr2 := "-" + dayStr
+								count, _ := strconv.ParseInt(dayStr2, 10, 64)
+								oldTime := time.Now().AddDate(0, 0, int(count)).Unix()
+								projects, _ := service.FindAllHisProjectByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.ProjectId)
+								if len(projects) == 0 {
+									cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+								}
+							}
 
-						if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 {
-							cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
 						}
 
-						if subItem.FrequencyType == 2 {
-							p, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
-							now := p.Unix()
-							dayStr := strconv.FormatInt(subItem.DayCount, 10)
-							dayStr2 := "-" + dayStr
-							count, _ := strconv.ParseInt(dayStr2, 10, 64)
-							oldTime := time.Now().AddDate(0, 0, int(count)).Unix()
-							projects, _ := service.FindAllHisProjectByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.ProjectId)
-							if len(projects) == 0 {
+					} else if subItem.Type == 3 {
+						if find := strings.Contains(subItem.GoodInfo.GoodStatus, "停用"); !find {
+							if subItem.FrequencyType == 1 {
 								cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
 							}
+
+							if subItem.FrequencyType == 3 && strings.Index(subItem.WeekDay, week) != -1 {
+								cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+							}
+
+							if subItem.FrequencyType == 2 {
+								p, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
+								now := p.Unix()
+								dayStr := strconv.FormatInt(subItem.DayCount, 10)
+								dayStr2 := "-" + dayStr
+								count, _ := strconv.ParseInt(dayStr2, 10, 64)
+								oldTime := time.Now().AddDate(0, 0, int(count)).Unix()
+								projects, _ := service.FindAllHisProjectByTime(now, oldTime, patient_id, c.GetAdminUserInfo().CurrentOrgId, subItem.ProjectId)
+								if len(projects) == 0 {
+									cus.HisPrescriptionProjectTemplate = append(cus.HisPrescriptionProjectTemplate, subItem)
+								}
+							}
 						}
+
 					}
 
 				}
 
-			}
+				sch_prescriptions = append(sch_prescriptions, cus)
 
-			sch_prescriptions = append(sch_prescriptions, cus)
+			}
 
-		}
+			for _, item := range sch_prescriptions {
+				if len(item.HisPrescriptionProjectTemplate) == 0 {
+					item.HisPrescriptionProjectTemplate = make([]*models.HisPrescriptionProjectTemplate, 0)
+				}
+				if len(item.HisPrescriptionAdviceTemplate) == 0 {
+					item.HisPrescriptionAdviceTemplate = make([]*models.HisPrescriptionAdviceTemplate, 0)
+				}
 
-		for _, item := range sch_prescriptions {
-			if len(item.HisPrescriptionProjectTemplate) == 0 {
-				item.HisPrescriptionProjectTemplate = make([]*models.HisPrescriptionProjectTemplate, 0)
 			}
-			if len(item.HisPrescriptionAdviceTemplate) == 0 {
-				item.HisPrescriptionAdviceTemplate = make([]*models.HisPrescriptionAdviceTemplate, 0)
-			}
-
 		}
 	}
 
@@ -817,7 +820,6 @@ func (c *HisApiController) CreateHisPrescription() {
 			}
 		}
 	}
-
 	if stockConfig.IsOpen == 1 {
 		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
 			prescriptions, _ := dataBody["prescriptions"].([]interface{})
@@ -876,176 +878,173 @@ func (c *HisApiController) CreateHisPrescription() {
 		}
 	}
 
-	ch := make(chan struct{})
-	count := 2 // count 表示活动的协程个数
-
-	go func() {
-		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 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" {
-
-										prescribingNumber = advice.(map[string]interface{})["prescribing_number"].(string)
-
-									}
-
-									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.FindBaseDrugLibRecordSeven(adminInfo.CurrentOrgId, drug_id)
-									if drug.ID == 0 {
-										c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-										return
-									}
-
-									//查询药品的所有库存
-									list, _ := service.GetDrugWarehouseInfoPrescriptionSeven(drug_id, adminInfo.CurrentOrgId)
-									var total_count int64
-									for _, it := range list {
-										total_count += it.StockMaxNumber*drug.MinNumber + it.StockMinNumber
-									}
-
-									//查询该药品是否存在开药记录
-									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 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)
-										}
-									}
-								}
-							}
-						}
-					}
-				}
-			}
-		}
-		ch <- struct{}{}
-	}()
-
-	go func() {
-		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 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)
-										parsetotal, _ = strconv.ParseInt(total, 10, 64)
-									}
-									if project_type == 3 {
-										//查找该耗材的出库记录
-										goodWarehouseInfo, _ := service.GetAutoRecordByGoodId(project_id, patient_id, recordDateTime)
-										//查询该患者耗材的历史数据
-										ordProject, _ := service.GetHisProjectPrescriptionByPatientId(patient_id, recordDateTime)
-										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)
-												}
-											}
-										}
-									}
-								}
-							}
-						}
-					}
-				}
-			}
-		}
-		ch <- struct{}{}
-	}()
-
-	for range ch {
-		// 每次从ch中接收数据，表明一个活动的协程结束
-		count--
-		// 当所有活动的协程都结束时，关闭管道
-		if count == 0 {
-			close(ch)
-		}
-	}
+	//ch := make(chan struct{})
+	//count := 2 // count 表示活动的协程个数
+	//go func() {
+	//	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 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" {
+	//
+	//									prescribingNumber = advice.(map[string]interface{})["prescribing_number"].(string)
+	//
+	//								}
+	//
+	//								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.FindBaseDrugLibRecordSeven(adminInfo.CurrentOrgId, drug_id)
+	//								if drug.ID == 0 {
+	//									c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+	//									return
+	//								}
+	//
+	//								//查询药品的所有库存
+	//								list, _ := service.GetDrugWarehouseInfoPrescriptionSeven(drug_id, adminInfo.CurrentOrgId)
+	//								var total_count int64
+	//								for _, it := range list {
+	//									total_count += it.StockMaxNumber*drug.MinNumber + it.StockMinNumber
+	//								}
+	//
+	//								//查询该药品是否存在开药记录
+	//								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 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)
+	//									}
+	//								}
+	//							}
+	//						}
+	//					}
+	//				}
+	//			}
+	//		}
+	//	}
+	//	ch <- struct{}{}
+	//}()
+	//go func() {
+	//	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 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)
+	//									parsetotal, _ = strconv.ParseInt(total, 10, 64)
+	//								}
+	//								if project_type == 3 {
+	//									//查找该耗材的出库记录
+	//									goodWarehouseInfo, _ := service.GetAutoRecordByGoodId(project_id, patient_id, recordDateTime)
+	//									//查询该患者耗材的历史数据
+	//									ordProject, _ := service.GetHisProjectPrescriptionByPatientId(patient_id, recordDateTime)
+	//									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)
+	//											}
+	//										}
+	//									}
+	//								}
+	//							}
+	//						}
+	//					}
+	//				}
+	//			}
+	//		}
+	//	}
+	//	ch <- struct{}{}
+	//}()
+	//for range ch {
+	//	// 每次从ch中接收数据，表明一个活动的协程结束
+	//	count--
+	//	// 当所有活动的协程都结束时，关闭管道
+	//	if count == 0 {
+	//		close(ch)
+	//	}
+	//}
 
 	info, _ := service.FindHisPatientPrescriptionInfo(adminInfo.CurrentOrgId, patient_id, recordDateTime, p_type, his_patient_id)
 	var hpInfo models.HisPrescriptionInfo
@@ -1258,7 +1257,7 @@ func (c *HisApiController) CreateHisPrescription() {
 							s.HisPatientId = his_patient_id
 							s.StartTime = pTime
 
-							errcode := c.setAdviceWithJSON(&s, advice.(map[string]interface{}))
+							errcode := c.setAdviceWithJSON(&s, advice.(map[string]interface{}), adminInfo.CurrentOrgId)
 							if errcode > 0 {
 								c.ServeFailJSONWithSGJErrorCode(errcode)
 								return
@@ -3024,7 +3023,7 @@ func (c *HisApiController) setAddtionWithJSONTwo(additionalCharge *models.HisAdd
 	return 0
 }
 
-func (c *HisApiController) setAdviceWithJSON(advice *models.HisDoctorAdviceInfo, json map[string]interface{}) int {
+func (c *HisApiController) setAdviceWithJSON(advice *models.HisDoctorAdviceInfo, json map[string]interface{}, org_id int64) int {
 
 	if json["drug_name"] == nil || reflect.TypeOf(json["drug_name"]).String() != "string" {
 		utils.ErrorLog("drug_name")
@@ -3143,7 +3142,7 @@ func (c *HisApiController) setAdviceWithJSON(advice *models.HisDoctorAdviceInfo,
 					advice.StartTime = hisAdvice.StartTime
 					advice.HospApprFlag = hisAdvice.HospApprFlag
 
-					if hisAdvice.SingleDose != advice.SingleDose || hisAdvice.DeliveryWay != advice.DeliveryWay || hisAdvice.ExecutionFrequency != advice.ExecutionFrequency || hisAdvice.Day != advice.Day || hisAdvice.PrescribingNumber != advice.PrescribingNumber || hisAdvice.Price != advice.Price || hisAdvice.Remark != advice.Remark {
+					if hisAdvice.PrescribingNumberUnit != advice.PrescribingNumberUnit || hisAdvice.SingleDose != advice.SingleDose || hisAdvice.DeliveryWay != advice.DeliveryWay || hisAdvice.ExecutionFrequency != advice.ExecutionFrequency || hisAdvice.Day != advice.Day || hisAdvice.PrescribingNumber != advice.PrescribingNumber || hisAdvice.Price != advice.Price || hisAdvice.Remark != advice.Remark {
 						advice.ExecutionTime = 0
 						advice.ExecutionStaff = 0
 						advice.ExecutionState = 2
@@ -3155,6 +3154,62 @@ func (c *HisApiController) setAdviceWithJSON(advice *models.HisDoctorAdviceInfo,
 					//advice.Groupno = hisAdvice.Groupno
 
 				}
+
+				if hisAdvice.ID > 0 {
+					drug, _ := service.FindBaseDrugLibRecordSeven(org_id, hisAdvice.DrugId)
+					//查询药品的所有库存
+					list, _ := service.GetDrugWarehouseInfoPrescriptionSeven(drug.ID, org_id)
+					var total_count int64
+					for _, it := range list {
+						total_count += it.StockMaxNumber*drug.MinNumber + it.StockMinNumber
+					}
+
+					var device_number int64
+					if hisAdvice.PrescribingNumberUnit == drug.MaxUnit {
+						prescribingNumber := strconv.FormatFloat(hisAdvice.PrescribingNumber, 'f', -1, 64)
+						prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+						device_number = prescribingNumberInt * drug.MinNumber
+					}
+					if hisAdvice.PrescribingNumberUnit == drug.MinUnit {
+						prescribingNumber := strconv.FormatFloat(hisAdvice.PrescribingNumber, 'f', -1, 64)
+						prescribingNumberInt, _ := strconv.ParseInt(prescribingNumber, 10, 64)
+						device_number = prescribingNumberInt
+					}
+
+					var sum_count int64
+					//判断是否做过修改
+					if advice.PrescribingNumberUnit == drug.MaxUnit {
+
+						prescribingNumberInt, _ := strconv.ParseInt(strconv.FormatFloat(advice.PrescribingNumber, 'f', 1, 32), 10, 64)
+						sum_count = prescribingNumberInt * drug.MinNumber
+					}
+					if advice.PrescribingNumberUnit == drug.MinUnit {
+						prescribingNumberInt, _ := strconv.ParseInt(strconv.FormatFloat(advice.PrescribingNumber, 'f', 1, 32), 10, 64)
+						sum_count = prescribingNumberInt
+					}
+					fmt.Println("原先药品记录", device_number)
+					fmt.Println("现在出库数量", sum_count)
+					if device_number != sum_count {
+
+						// 查询该药品最后一次出库记录
+						druginfo, _ := service.GetLastDrugWarehouseOutByDrugId(drug.ID, advice.PatientId, advice.RecordDate)
+						//回退库存
+						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, advice.PatientId, advice.RecordDate, advice.ID)
+					}
+
+				}
 			}
 		}
 	}
@@ -3283,6 +3338,24 @@ func (c *HisApiController) setAdviceWithJSON(advice *models.HisDoctorAdviceInfo,
 }
 
 func (c *HisApiController) setProjectWithJSON(project *models.HisPrescriptionProject, json map[string]interface{}) int {
+	if json["project_id"] != nil || reflect.TypeOf(json["project_id"]).String() == "float64" {
+		project_id := int64(json["project_id"].(float64))
+		project.ProjectId = project_id
+		fmt.Println(project_id)
+		fmt.Println(project.ProjectId)
+	}
+
+	if json["type"] != nil || reflect.TypeOf(json["type"]).String() == "float64" {
+		types := int64(json["type"].(float64))
+		project.Type = types
+	}
+
+	if json["total"] != nil && reflect.TypeOf(json["total"]).String() == "string" {
+		total, _ := json["total"].(string)
+		//totals, _ := strconv.ParseInt(total, 10, 64)
+		project.Count = total
+	}
+
 	project.ExecutionStaff = 0
 	project.ExecutionState = 2
 	project.ExecutionTime = 0
@@ -3300,16 +3373,32 @@ func (c *HisApiController) setProjectWithJSON(project *models.HisPrescriptionPro
 		project.CheckState = temp_project.CheckState
 		project.CheckTime = temp_project.CheckTime
 		project.TeamId = temp_project.TeamId
-	}
-	if json["type"] != nil || reflect.TypeOf(json["type"]).String() == "float64" {
-		types := int64(json["type"].(float64))
-		project.Type = types
-	}
-	if json["project_id"] != nil || reflect.TypeOf(json["project_id"]).String() == "float64" {
-		project_id := int64(json["project_id"].(float64))
-		project.ProjectId = project_id
-		fmt.Println(project_id)
-		fmt.Println(project.ProjectId)
+
+		if id > 0 {
+			if project.Type == 3 {
+				//查找该耗材的出库记录
+				goodWarehouseInfo, _ := service.GetAutoRecordByGoodId(project.ProjectId, temp_project.PatientId, temp_project.RecordDate)
+				//查询该患者耗材的历史数据
+				//ordProject, _ := service.GetHisProjectPrescriptionByPatientId(temp_project.PatientId, temp_project.RecordDate)
+				if goodWarehouseInfo.ID > 0 {
+					//数量发生改变
+					parsetotal, _ := strconv.ParseInt(project.Count, 10, 64)
+
+					if parsetotal != goodWarehouseInfo.Count {
+						//查找今日该患者已经出库的所有耗材
+						goodList, _ := service.GetAllAutoRecordByPatient(temp_project.PatientId, temp_project.RecordDate)
+						for _, item := range goodList {
+							//回退库存
+							service.ModefyWarehouseInfo(item.Count, item.WarehouseInfotId)
+							//删除记录
+							service.DeleteAutoWarehouse(item.PatientId, item.SysRecordTime)
+						}
+					}
+				}
+			}
+
+		}
+
 	}
 
 	if json["team_id"] != nil && reflect.TypeOf(json["team_id"]).String() == "float64" {
@@ -3323,12 +3412,6 @@ func (c *HisApiController) setProjectWithJSON(project *models.HisPrescriptionPro
 		project.Price = price
 	}
 
-	if json["total"] != nil && reflect.TypeOf(json["total"]).String() == "string" {
-		total, _ := json["total"].(string)
-		//totals, _ := strconv.ParseInt(total, 10, 64)
-		project.Count = total
-	}
-
 	if json["medical_code"] != nil && reflect.TypeOf(json["medical_code"]).String() == "string" {
 		medical_code, _ := json["medical_code"].(string)
 		project.MedListCodg = medical_code

controllers/his_hospital_api_controller.go

@@ -32,6 +32,8 @@ func HisHospitalManagerApiRegistRouters() {
 	beego.Router("/api/hospitaldetail/list", &HisHospitalApiController{}, "get:GetHisHospitalDetailPatientList")
 	beego.Router("/api/hospitaldetail/info", &HisHospitalApiController{}, "get:GetHisHospitalDetailInfo")
 
+	beego.Router("/api/monthhospitaldetail/get", &HisHospitalApiController{}, "get:GetHisHospitalMonthDetailInfo")
+
 }
 
 func (c *HisHospitalApiController) GetHisHospitalPatientList() {
@@ -752,3 +754,41 @@ func (c *HisHospitalApiController) GetHisHospitalDetailInfo() {
 		"his_info":            record,
 	})
 }
+func (c *HisHospitalApiController) GetHisHospitalMonthDetailInfo() {
+	id, _ := c.GetInt64("id")
+	is_upload, _ := c.GetInt64("is_upload")
+	patient_id, _ := c.GetInt64("patient_id")
+	start_time_str := c.GetString("start_time")
+	end_time_str := c.GetString("end_time")
+
+	record, _ := service.GetInHospitalRecord(id)
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	adminInfo := c.GetAdminUserInfo()
+	theStartTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time_str+" 00:00:00", loc)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordStartTime := theStartTime.Unix()
+	theEndTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time_str+" 00:00:00", loc)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordEndTime := theEndTime.Unix()
+	//var prescriptions []*models.HisPrescription
+
+	var monthPrescriptions []*models.HisPrescription
+	if is_upload == 1 {
+		monthPrescriptions, _ = service.GetMonthUnUploadHisHospitalPrescription(adminInfo.CurrentOrgId, patient_id, recordStartTime, recordEndTime)
+	} else if is_upload == 2 {
+		monthPrescriptions, _ = service.GetMonthUploadHisHospitalPrescription(adminInfo.CurrentOrgId, patient_id, recordStartTime, recordEndTime)
+	} else {
+		monthPrescriptions, _ = service.GetAllMonthHisHospitalPrescription(adminInfo.CurrentOrgId, patient_id, recordStartTime, recordEndTime)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"month_prescriptions": monthPrescriptions,
+		"his_info":            record,
+	})
+}

service/his_hospital_service.go

@@ -397,3 +397,19 @@ func GetMonthUploadHisHospitalPrescription(org_id int64, patient_id int64, start
 		Find(&prescription).Error
 	return
 }
+
+func GetAllMonthHisHospitalPrescription(org_id int64, patient_id int64, start_time int64, end_time int64) (prescription []*models.HisPrescription, err error) {
+	err = readDb.Model(&models.HisPrescription{}).
+		Preload("HisAdditionalCharge", func(db *gorm.DB) *gorm.DB {
+			return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("XtHisAddtionConfig", "status=1")
+		}).
+		Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("HisOrderInfo", "status = 1").Preload("Drug", "status=1")
+		}).
+		Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+			return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("HisOrderInfo", "status = 1").Preload("HisProject").Preload("GoodInfo", "status=1").Preload("XtHisProjectTeam", "status = 1")
+		}).
+		Where("user_org_id = ? AND status = 1 AND patient_id = ? AND record_date <= ? AND  record_date >= ? AND p_type = 1", org_id, patient_id, end_time, start_time).
+		Find(&prescription).Error
+	return
+}