医保对接

controllers/his_api_controller.go

@@ -327,6 +327,8 @@ func (c *HisApiController) CreateHisPrescription() {
 
 	_, 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 {}" {
@@ -383,6 +385,53 @@ func (c *HisApiController) CreateHisPrescription() {
 			}
 		}
 	}
+
+	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{})["id"] != nil || reflect.TypeOf(project.(map[string]interface{})["id"]).String() == "float64" {
+									project_id = int64(project.(map[string]interface{})["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.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
+										return
+									}
+
+								}
+
+							}
+						}
+					}
+				}
+			}
+		}
+
+	}
+
 	info, _ := service.FindHisPatientPrescriptionInfo(adminInfo.CurrentOrgId, patient_id, recordDateTime, p_type, his_patient_id)
 	var hpInfo models.HisPrescriptionInfo
 	if info.ID == 0 {
@@ -594,6 +643,7 @@ func (c *HisApiController) CreateHisPrescription() {
 								return
 							}
 							service.CreateHisProjectTwo(&p)
+
 							var randNum int
 							randNum = rand.Intn(10000) + 1000
 							timestamp := time.Now().Unix()
@@ -903,10 +953,21 @@ func (c *HisApiController) DeletePrescription() {
 	advices, _ := service.GetHisPrescriptionAdviceByID(prescription_id)
 	_, drugStockConfig := service.FindDrugStockAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
 
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
+
 	err := service.DelelteHisPrescription(prescription_id, c.GetAdminUserInfo().CurrentOrgId)
 	if err == nil {
 		if len(projects) > 0 {
 			for _, item := range projects {
+				if stockConfig.IsOpen == 1 {
+					if item.Type == 3 {
+						good, _ := service.FindGoodInfoByIdTwo(item.ProjectId)
+						f_count, _ := strconv.ParseFloat(strconv.FormatInt(item.Count, 10), 64)
+						good.Total = good.Total + f_count
+						service.UpdateGoodInfo(&good)
+					}
+				}
+
 				if item.Type == 3 { //处理透前准备耗材数量数据
 					consumables, _ := service.FindHisConsumablesByID(item.UserOrgId, item.PatientId, item.RecordDate, item.ProjectId)
 					if consumables.ID > 0 {
@@ -979,11 +1040,21 @@ func (c *HisApiController) DeleteProject() {
 	adminInfo := c.GetAdminUserInfo()
 	project, _ := service.GetHisProjectByID(id)
 	var consumable models.DialysisBeforePrepare
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
+
 	if project.ID > 0 && project.Type == 3 {
 		consumable, _ = service.FindHisConsumablesByID(adminInfo.CurrentOrgId, project.PatientId, project.RecordDate, project.ProjectId)
 	}
 	err := service.DelelteProject(id, c.GetAdminUserInfo().CurrentOrgId)
 	if err == nil {
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				f_count, _ := strconv.ParseFloat(strconv.FormatInt(project.Count, 10), 64)
+				good.Total = good.Total + f_count
+				service.UpdateGoodInfo(&good)
+			}
+		}
 		if consumable.ID > 0 {
 			consumable.Count = 0
 			service.UpdateConsumables(&consumable)
@@ -1857,6 +1928,41 @@ func (c *HisApiController) setProjectWithJSON(project *models.HisPrescriptionPro
 		project.Unit = unit
 	}
 
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(project.UserOrgId)
+
+	if project.ID == 0 {
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				f_count, _ := strconv.ParseFloat(strconv.FormatInt(project.Count, 10), 64)
+				good.Total = good.Total - f_count
+				service.UpdateGoodInfo(&good)
+			}
+		}
+
+	} else {
+		temp_project, _ := service.GetHisPrescriptionProjectByID(project.ID)
+
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				if project.Count < temp_project.Count {
+					other_count := temp_project.Count - project.Count
+					other_count_two, _ := strconv.ParseFloat(strconv.FormatInt(other_count, 10), 64)
+					good.Total = good.Total + other_count_two
+					service.UpdateGoodInfo(&good)
+				} else if project.Count > temp_project.Count {
+					other_count := project.Count - temp_project.Count
+					other_count_two, _ := strconv.ParseFloat(strconv.FormatInt(other_count, 10), 64)
+					good.Total = good.Total - other_count_two
+					service.UpdateGoodInfo(&good)
+				}
+
+			}
+		}
+
+	}
+
 	return 0
 }
 

controllers/new_mobile_api_controllers/mobile_his_api_controller.go

@@ -140,6 +140,7 @@ func (c *MobileHisApiController) DeletePrescription() {
 	projects, _ := service.GetHisPrescriptionProjectsByID(prescription_id)
 	advices, _ := service.GetHisPrescriptionAdviceByID(prescription_id)
 	_, drugStockConfig := service.FindDrugStockAutomaticReduceRecordByOrgId(c.GetMobileAdminUserInfo().Org.Id)
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetAdminUserInfo().CurrentOrgId)
 
 	err := service.DelelteHisPrescription(prescription_id, c.GetMobileAdminUserInfo().Org.Id)
 	if err == nil {
@@ -152,6 +153,15 @@ func (c *MobileHisApiController) DeletePrescription() {
 						service.UpdateConsumables(&consumables)
 					}
 				}
+
+				if stockConfig.IsOpen == 1 {
+					if item.Type == 3 {
+						good, _ := service.FindGoodInfoByIdTwo(item.ProjectId)
+						f_count, _ := strconv.ParseFloat(strconv.FormatInt(item.Count, 10), 64)
+						good.Total = good.Total + f_count
+						service.UpdateGoodInfo(&good)
+					}
+				}
 			}
 		}
 		if drugStockConfig.IsOpen == 1 {
@@ -217,8 +227,19 @@ func (c *MobileHisApiController) DeleteProject() {
 	if project.ID > 0 && project.Type == 3 {
 		consumable, _ = service.FindHisConsumablesByID(adminInfo.Org.Id, project.PatientId, project.RecordDate, project.ProjectId)
 	}
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetMobileAdminUserInfo().Org.Id)
+
 	err := service.DelelteProject(id, c.GetMobileAdminUserInfo().Org.Id)
 	if err == nil {
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				f_count, _ := strconv.ParseFloat(strconv.FormatInt(project.Count, 10), 64)
+				good.Total = good.Total + f_count
+				service.UpdateGoodInfo(&good)
+			}
+		}
+
 		if consumable.ID > 0 {
 			consumable.Count = 0
 			service.UpdateConsumables(&consumable)
@@ -265,6 +286,7 @@ func (c *MobileHisApiController) CreateHisPrescription() {
 	//校验库存总量
 
 	_, drugStockConfig := service.FindDrugStockAutomaticReduceRecordByOrgId(c.GetMobileAdminUserInfo().Org.Id)
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(c.GetMobileAdminUserInfo().Org.Id)
 
 	if drugStockConfig.IsOpen == 1 {
 		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
@@ -321,6 +343,51 @@ func (c *MobileHisApiController) CreateHisPrescription() {
 			}
 		}
 	}
+	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{})["id"] != nil || reflect.TypeOf(project.(map[string]interface{})["id"]).String() == "float64" {
+									project_id = int64(project.(map[string]interface{})["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.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOutOfStockParamWrong)
+										return
+									}
+
+								}
+
+							}
+						}
+					}
+				}
+			}
+		}
+
+	}
 
 	info, _ := service.FindPatientPrescriptionInfo(adminInfo.Org.Id, patient_id, recordDateTime, 2)
 	var hpInfo models.HisPrescriptionInfo
@@ -527,6 +594,7 @@ func (c *MobileHisApiController) CreateHisPrescription() {
 								return
 							}
 							service.CreateHisProjectTwo(&p)
+
 							var randNum int
 							randNum = rand.Intn(10000) + 1000
 							timestamp := time.Now().Unix()
@@ -878,6 +946,42 @@ func (c *MobileHisApiController) setProjectWithJSON(project *models.HisPrescript
 		unit, _ := json["unit"].(string)
 		project.Unit = unit
 	}
+
+	_, stockConfig := service.FindAutomaticReduceRecordByOrgId(project.UserOrgId)
+
+	if project.ID == 0 {
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				f_count, _ := strconv.ParseFloat(strconv.FormatInt(project.Count, 10), 64)
+				good.Total = good.Total - f_count
+				service.UpdateGoodInfo(&good)
+			}
+		}
+
+	} else {
+		temp_project, _ := service.GetHisPrescriptionProjectByID(project.ID)
+
+		if stockConfig.IsOpen == 1 {
+			if project.Type == 3 {
+				good, _ := service.FindGoodInfoByIdTwo(project.ProjectId)
+				if project.Count < temp_project.Count {
+					other_count := temp_project.Count - project.Count
+					other_count_two, _ := strconv.ParseFloat(strconv.FormatInt(other_count, 10), 64)
+					good.Total = good.Total + other_count_two
+					service.UpdateGoodInfo(&good)
+				} else if project.Count > temp_project.Count {
+					other_count := project.Count - temp_project.Count
+					other_count_two, _ := strconv.ParseFloat(strconv.FormatInt(other_count, 10), 64)
+					good.Total = good.Total - other_count_two
+					service.UpdateGoodInfo(&good)
+				}
+
+			}
+		}
+
+	}
+
 	return 0
 }
 func (c *MobileHisApiController) GetHisPatientList() {

models/good_models.go

@@ -76,6 +76,7 @@ type GoodInfo struct {
 	PackingPrice                float64   `gorm:"column:packing_price" json:"packing_price" form:"packing_price"`
 	DefaultCountUnit            string    `gorm:"column:default_count_unit" json:"default_count_unit" form:"default_count_unit"`
 	MinUnit                     string    `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
+	Total                       float64   `gorm:"column:total" json:"total" form:"total"`
 }
 
 func (GoodInfo) TableName() string {

models/stock_models.go

@@ -263,6 +263,7 @@ type WarehousingGoodInfo struct {
 	Manufacturers     Manufacturer `gorm:"ForeignKey:Manufacturer;AssociationForeignKey:ID" json:"manufacturers"`
 	Dealers           Dealer       `gorm:"ForeignKey:Dealer;AssociationForeignKey:ID" json:"dealers"`
 	BuyPrice          float64      `gorm:"column:buy_price" json:"buy_price"`
+	Total             float64      `gorm:"column:total" json:"total" form:"total"`
 }
 
 func (WarehousingGoodInfo) TableName() string {

service/his_service.go

@@ -1870,3 +1870,8 @@ func GetHisPrescriptionAdviceByID(id int64) (advices []*models.HisDoctorAdviceIn
 	err = readDb.Model(&models.HisDoctorAdviceInfo{}).Where("prescription_id = ? AND status = 1", id).Find(&advices).Error
 	return
 }
+
+func UpdateGoodInfo(good_info *models.GoodInfo) (err error) {
+	err = writeDb.Save(&good_info).Error
+	return
+}

service/mobile_dialysis_service.go

@@ -1500,12 +1500,13 @@ func (GoodsType) TableName() string {
 }
 
 type VMGoodInfo struct {
-	ID                int64  `gorm:"column:id" json:"id"`
-	SpecificationName string `gorm:"column:specification_name" json:"specification_name"`
-	GoodTypeId        int64  `gorm:"column:good_type_id" json:"good_type_id"`
-	OrgId             int64  `gorm:"column:org_id" json:"org_id"`
-	GoodName          string `gorm:"column:good_name" json:"good_name" form:"good_name"`
-	GoodUnit          int64  `gorm:"column:good_unit" json:"good_unit" form:"good_unit"`
+	ID                int64   `gorm:"column:id" json:"id"`
+	SpecificationName string  `gorm:"column:specification_name" json:"specification_name"`
+	GoodTypeId        int64   `gorm:"column:good_type_id" json:"good_type_id"`
+	OrgId             int64   `gorm:"column:org_id" json:"org_id"`
+	GoodName          string  `gorm:"column:good_name" json:"good_name" form:"good_name"`
+	GoodUnit          int64   `gorm:"column:good_unit" json:"good_unit" form:"good_unit"`
+	Total             float64 `gorm:"column:total" json:"total" form:"total"`
 }
 
 func (VMGoodInfo) TableName() string {

service/stock_service.go

@@ -2726,3 +2726,8 @@ func GetAutoDialysisBefor(goodid int64, goodtypeid int64, patientid int64, orgid
 	}
 	return &autoreduece, nil
 }
+
+func FindGoodInfoByIdTwo(id int64) (goodInfo models.GoodInfo, err error) {
+	err = readDb.Model(&models.GoodInfo{}).Where("id = ? AND status = 1", id).First(&goodInfo).Error
+	return
+}