11月8日库存管理

controllers/his_api_controller.go

@@ -633,114 +633,132 @@ func (c *HisApiController) CreateHisPrescription() {
 
 	patient, _ := service.GetPatientByIDTwo(adminInfo.CurrentOrgId, patient_id)
 
-	//_, drugStockConfig := service.FindDrugStockAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
-	//
-	//_, 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
-	//
-	//							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)
-	//								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)
-	//							}
-	//
-	//							drug, _ := service.FindBaseDrugLibRecord(adminInfo.CurrentOrgId, drug_id)
-	//							if drug.ID == 0 {
-	//								c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-	//								return
-	//							}
-	//
-	//							if prescribingNumberUnit == drug.MinUnit {
-	//								if prescribing_number > drug.Total {
-	//									c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
-	//									//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
-	//									return
-	//								}
-	//							} else {
-	//								if prescribingNumberUnit == drug.MaxUnit {
-	//									num := prescribing_number * float64(drug.MinNumber)
-	//									if num > drug.Total {
-	//										c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
-	//										//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
-	//										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
-	//							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)
-	//							}
-	//							if project_type == 3 {
-	//								good, _ := service.FindGoodInfoByIdTwo(project_id)
-	//								if good.ID == 0 {
-	//									c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-	//									return
-	//								}
-	//								if totals > good.Total {
-	//									c.ServeDynamicFailJsonSend(good.GoodName + "库存不足")
-	//									//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
-	//									return
-	//								}
-	//
-	//							}
-	//
-	//						}
-	//					}
-	//				}
-	//			}
-	//		}
-	//	}
-	//}
+	_, drugStockConfig := service.FindDrugStockAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
+
+	_, 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
+
+								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)
+									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)
+								}
+
+								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)
+								all_count, _ := strconv.ParseFloat(totals, 64)
+								fmt.Println("all_count2323323233232", all_count)
+								if prescribingNumberUnit == drug.MinUnit {
+									if prescribing_number > all_count {
+										c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
+										//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
+										return
+									}
+								} else {
+									if prescribingNumberUnit == drug.MaxUnit {
+										num := prescribing_number * float64(drug.MinNumber)
+										if num > all_count {
+											c.ServeDynamicFailJsonSend(drug.DrugName + "库存不足")
+											//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
+											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
+								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)
+								}
+								if project_type == 3 {
+									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 {
+										c.ServeDynamicFailJsonSend(good.GoodName + "库存不足")
+
+										return
+									}
+
+								}
+
+							}
+						}
+					}
+				}
+			}
+		}
+	}
 
 	info, _ := service.FindHisPatientPrescriptionInfo(adminInfo.CurrentOrgId, patient_id, recordDateTime, p_type, his_patient_id)
 	var hpInfo models.HisPrescriptionInfo

controllers/stock_in_api_controller.go

@@ -2144,7 +2144,6 @@ func (c *StockManagerApiController) CreateCancelStock() {
 			}
 			//更改入库数量
 			errs = service.UpdateWareInfoById(item.WarehouseInfoId, item.Count)
-			break
 		}
 	}
 

service/stock_service.go

@@ -3289,6 +3289,12 @@ func FindGoodInfoByIdTwo(id int64) (goodInfo models.GoodInfo, err error) {
 	return
 }
 
+func GetGoodWarehouseInfo(good_id int64) (info []*models.WarehousingInfo, err error) {
+
+	err = readDb.Where("good_id = ? and status = 1 and stock_count<>0", good_id).Find(&info).Error
+	return info, err
+}
+
 func GetAllStockList(page int64, limit int64, startime int64, endtime int64, good_type int64, keyword string, orgid int64) (info []*models.VmWarehousingInfo, total int64, err error) {
 
 	offset := (page - 1) * limit
@@ -4358,6 +4364,12 @@ func GetDrugWarehouseInfo(id int64) (models.XtDrugWarehouseInfo, error) {
 	return info, err
 }
 
+func GetDrugWarehouseInfoPrescription(drugid int64, orgid int64) (info []*models.DrugWarehouseInfo, err error) {
+
+	err = XTReadDB().Where("drug_id = ? and org_id =? and status = 1", drugid, orgid).Find(&info).Error
+	return info, err
+}
+
 func GetDrugWarehouseInfoById(id int64) (models.XtDrugWarehouseInfo, error) {
 
 	info := models.XtDrugWarehouseInfo{}