库存流水展示

controllers/mobile_api_controllers/check_weight_api_controller.go

@@ -674,7 +674,7 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 				evaluation.Phinholing = lastPredialysisEvaluation.Phinholing                   //针眼
 				evaluation.Remark = lastPredialysisEvaluation.Remark
 				if adminUserInfo.Org.Id == 10318 {
-					evaluation.Remark = "患者已确认无发热，无流行病学接触史"
+					evaluation.Remark = ""
 				}
 				if adminUserInfo.Org.Id == 10340 || adminUserInfo.Org.Id == 10447 {
 					evaluation.BreathingRate = "20"

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -1772,7 +1772,7 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 				}
 
 				if schedulePatient.ScheduleType == 2 {
-					advice.StartTime = recordDate.Unix() + 11*60*60
+					advice.StartTime = recordDate.Unix() + 10*60*60
 				}
 			}
 			// 抗凝剂名称
@@ -2818,6 +2818,13 @@ func (this *DialysisAPIController) StartDialysis() {
 				value, _ := strconv.ParseFloat(fmt.Sprintf("%.3f", prescription.TargetUltrafiltration/float64(totalMin)*60), 6)
 				ultrafiltration_rate = value
 			}
+
+			//针对
+			if adminUserInfo.Org.Id == 10471 || adminUserInfo.Org.Id == 3877 {
+
+				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration / float64(totalMin) * 60 * 1000)
+				ultrafiltration_rate = ultrafiltration_rate / 1000
+			}
 		}
 	}
 
@@ -3402,7 +3409,7 @@ func (c *DialysisAPIController) PostSolution() {
 			}
 
 			if schedulePatient.ScheduleType == 2 {
-				advice.StartTime = recordDate.Unix() + 11*60*60
+				advice.StartTime = recordDate.Unix() + 10*60*60
 			}
 		}
 		// 抗凝剂名称
@@ -3683,11 +3690,18 @@ func (this *DialysisAPIController) GetLastMonitorRecordTody() {
 				record.UltrafiltrationRate = ultrafiltration_rate
 			}
 
-			if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10340 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 9829 || adminInfo.Org.Id == 10440 || adminInfo.Org.Id == 10469 || adminInfo.Org.Id == 10471 {
+			if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10340 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 9829 || adminInfo.Org.Id == 10440 || adminInfo.Org.Id == 10469 {
 				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration * 60 / 1000 / float64(totalMin) * 1000)
 
 				record.UltrafiltrationRate = ultrafiltration_rate
 			}
+
+			if adminInfo.Org.Id == 10471 {
+
+				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration / float64(totalMin) * 60 * 1000)
+				record.UltrafiltrationRate = ultrafiltration_rate / 1000
+
+			}
 			//if template.TemplateId == 47 {
 			//	ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration * 60 / float64(totalMin))
 			//	record.UltrafiltrationRate = ultrafiltration_rate
@@ -3714,15 +3728,22 @@ func (this *DialysisAPIController) GetLastMonitorRecordTody() {
 	}
 
 	//长沙南雅
-	if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 10469 || adminInfo.Org.Id == 10471 {
+	if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 10469 {
 
 		if ultrafiltration_rate > 0 {
 			ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
-
+			fmt.Println("ultrafiltration_volume", ultrafiltration_volume)
 			record.UltrafiltrationVolume = ultrafiltration_volume
 		}
 
 	}
+
+	if adminInfo.Org.Id == 10471 {
+
+		ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
+		fmt.Println("ultrafiltration_volume", ultrafiltration_volume)
+		record.UltrafiltrationVolume = ultrafiltration_volume / 1000
+	}
 	//长沙南雅累计血容量自动计算
 	//if adminInfo.Org.Id == 10340 || adminInfo.Org.Id == 9671 ||  adminInfo.Org.Id == 3877{
 	//	record.AccumulatedBloodVolume = (record.BloodFlowVolume - 25) * (math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime)/3600) * 60) / 1000
@@ -4265,9 +4286,10 @@ func (c *DialysisAPIController) GetLongAdviceOne() {
 		//开启推送提醒逻辑    提交长期处方的时候，弹起长期医嘱推送
 		var advice_three []*models.DoctorAdvice
 
-		//fmt.Println("theStartTime23434343433434433443434343434334", theStartTime)
 		advices, err := service.GetLastLongAdviceByGroupNo(adminUserInfo.Org.Id, patient_id, theStartTime)
+
 		advices_two, err := service.GetLastLongAdviceByGroupNoThree(adminUserInfo.Org.Id, patient_id, theStartTime)
+
 		for _, advice := range advices {
 			if advice.FrequencyType == 3 {
 				t := time.Now()

controllers/mobile_api_controllers/patient_api_controller.go

@@ -701,7 +701,7 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 				if isHasWay {
 					var total int64
 					var prescribing_number_total int64
-					fmt.Println("advicesssssssssssssssss", len(advices))
+
 					for _, item := range advices {
 						if item.Way == 1 {
 							houseConfig, _ := service.GetAllStoreHouseConfig(item.UserOrgId)
@@ -1132,6 +1132,7 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 						}
 					}
 					if total_count == drug_count {
+
 						advice, _ := service.FindHisDoctorAdviceById(adminInfo.Org.Id, item.ID)
 						c.ServeSuccessJSON(map[string]interface{}{
 							"msg":    "1",
@@ -1170,7 +1171,17 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 						}
 
 						if medical.IsUse == 1 {
-
+							drugError := models.XtDrugError{
+								UserOrgId:  adminInfo.Org.Id,
+								DrugId:     item.DrugId,
+								RecordDate: item.AdviceDate,
+								PatientId:  item.PatientId,
+								Remark:     "零用药品",
+								Status:     1,
+								Ctime:      time.Now().Unix(),
+								Mtime:      0,
+							}
+							service.CreateDrugError(drugError)
 							if (list.Count*medical.MinNumber + list.StockMinNumber) == 0 {
 								c.ServeSuccessJSON(map[string]interface{}{
 									"msg":    "1",
@@ -1181,6 +1192,17 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 							}
 						}
 						if medical.IsUse != 1 {
+							drugError := models.XtDrugError{
+								UserOrgId:  adminInfo.Org.Id,
+								DrugId:     item.DrugId,
+								RecordDate: item.AdviceDate,
+								PatientId:  item.PatientId,
+								Remark:     "药品库存不足",
+								Status:     1,
+								Ctime:      time.Now().Unix(),
+								Mtime:      0,
+							}
+							service.CreateDrugError(drugError)
 							if (list.Count*medical.MinNumber + list.StockMinNumber) == 0 {
 								c.ServeSuccessJSON(map[string]interface{}{
 									"msg":    "3",
@@ -1190,6 +1212,17 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 								return
 							}
 							if prescribing_number_total > total {
+								drugError := models.XtDrugError{
+									UserOrgId:  adminInfo.Org.Id,
+									DrugId:     item.DrugId,
+									RecordDate: item.AdviceDate,
+									PatientId:  item.PatientId,
+									Remark:     "出库数量大于库存",
+									Status:     1,
+									Ctime:      time.Now().Unix(),
+									Mtime:      0,
+								}
+								service.CreateDrugError(drugError)
 								c.ServeSuccessJSON(map[string]interface{}{
 									"msg":    "2",
 									"advice": advice,

controllers/pharmacy_controller.go

@@ -165,7 +165,7 @@ func (this *PharmacyController) IssuedDrug() {
 		etime = stime + 86399
 	}
 
-	if orgid == 10164 || orgid == 3877 || orgid == 10188 || orgid == 10217 || orgid == 9671 {
+	if orgid == 10164 || orgid == 3877 || orgid == 10188 || orgid == 10217 || orgid == 9671 || orgid == 10387 {
 
 		//获取排班班次
 		schedule, _ := service.GetSchedulePatientId(stime, etime, orgid, shift, partition)
@@ -189,7 +189,7 @@ func (this *PharmacyController) IssuedDrug() {
 		})
 	}
 
-	if orgid != 10164 && orgid == 3877 && orgid != 10188 && orgid != 10217 && orgid != 9671 {
+	if orgid != 10164 && orgid == 3877 && orgid != 10188 && orgid != 10217 && orgid != 9671 && orgid != 10387 {
 		//查询表里当天的数据
 		var flist []*models.TmpPatient
 		flist, err = service.GetTodayDrug(stime, etime, orgid, 1, keyword)
@@ -245,7 +245,7 @@ func (this *PharmacyController) WaitingDrug() {
 		etime = stime + 86399
 	}
 
-	if orgid != 9671 && orgid != 10188 && orgid != 10217 && orgid != 3877 && orgid != 10164 {
+	if orgid != 9671 && orgid != 10188 && orgid != 10217 && orgid != 3877 && orgid != 10164 && orgid != 10387 {
 		//查询表里当天的数据
 		var flist []*models.TmpPatient
 		flist, err = service.GetTodayDrug(stime, etime, orgid, 0, keyword)
@@ -269,7 +269,7 @@ func (this *PharmacyController) WaitingDrug() {
 	}
 
 	//当天已发药的人数
-	if orgid == 9671 || orgid == 10188 || orgid == 10217 || orgid == 3877 || orgid == 10164 {
+	if orgid == 9671 || orgid == 10188 || orgid == 10217 || orgid == 3877 || orgid == 10164 || orgid == 10387 {
 
 		//获取排班班次
 		schedule, _ := service.GetSchedulePatientId(stime, etime, orgid, shift, partition)
@@ -368,35 +368,37 @@ func (this *PharmacyController) DispensingMedicine() {
 		var total int64
 		var prescribing_number_total int64
 		for _, item := range advicelist {
-			houseConfig, _ := service.GetAllStoreHouseConfig(orgid)
-			//查询该药品是否有库存
-			list, _ := service.GetDrugTotalCountTwenty(item.DrugId, item.UserOrgId, houseConfig.DrugStorehouseOut)
-
 			//查询改药品信息
 			medical, _ := service.GetBaseDrugMedical(item.DrugId)
-			//判断单位是否相等
-			if medical.MaxUnit == item.PrescribingNumberUnit {
-				prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
-				count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
-				//转化为最小单位
-				total = list.Count*medical.MinNumber + list.StockMinNumber
-				prescribing_number_total = count * medical.MinNumber
-			}
-			if medical.MinUnit == item.PrescribingNumberUnit {
-				prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
-				count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
-				total = list.Count*medical.MinNumber + list.StockMinNumber
-				prescribing_number_total = count
-			}
+			if medical.IsPharmacy == 1 {
+				houseConfig, _ := service.GetAllStoreHouseConfig(orgid)
+				//查询该药品是否有库存
+				list, _ := service.GetDrugTotalCountTwenty(item.DrugId, item.UserOrgId, houseConfig.DrugStorehouseOut)
+
+				//判断单位是否相等
+				if medical.MaxUnit == item.PrescribingNumberUnit {
+					prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
+					count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
+					//转化为最小单位
+					total = list.Count*medical.MinNumber + list.StockMinNumber
+					prescribing_number_total = count * medical.MinNumber
+				}
+				if medical.MinUnit == item.PrescribingNumberUnit {
+					prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
+					count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
+					total = list.Count*medical.MinNumber + list.StockMinNumber
+					prescribing_number_total = count
+				}
 
-			if medical.IsUse != 1 {
-				//如果出库数量大于库存数量
-				if prescribing_number_total > total {
-					err := fmt.Errorf(service.FindDrugsName(item.DrugId) + "库存不足")
-					if err != nil {
-						utils.ErrorLog(err.Error())
-						this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
-						return
+				if medical.IsUse != 1 {
+					//如果出库数量大于库存数量
+					if prescribing_number_total > total {
+						err := fmt.Errorf(service.FindDrugsName(item.DrugId) + "库存不足")
+						if err != nil {
+							utils.ErrorLog(err.Error())
+							this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
+							return
+						}
 					}
 				}
 			}
@@ -405,11 +407,29 @@ func (this *PharmacyController) DispensingMedicine() {
 	}
 
 	err = service.DispensingMedicine(orgid, patient_id, stime, etime, creater)
+
+	if orgid == 10387 || orgid == 3877 {
+		advicelist, _ := service.FindeHisAdviceDocAdvice(orgid, patient_id, stime, etime)
+		if len(advicelist) > 0 {
+			for _, item := range advicelist {
+				//查询改药品信息
+				medical, _ := service.GetBaseDrugMedical(item.DrugId)
+				if medical.IsPharmacy == 1 {
+					flow, _ := service.GetFlow(item.DrugId, item.AdviceDate, orgid, item.PatientId)
+					if len(flow) > 0 {
+						service.UpdateAdviceFlow(item.ID)
+					}
+				}
+			}
+
+		}
+	}
 	if err != nil {
 		utils.ErrorLog(err.Error())
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
 		return
 	}
+
 	this.ServeSuccessJSON(map[string]interface{}{
 		"list": "操作成功",
 	})

models/drug_stock.go

@@ -709,3 +709,19 @@ type DrugWarehouseOutInfoNight struct {
 func (DrugWarehouseOutInfoNight) TableName() string {
 	return "xt_drug_warehouse_out_info"
 }
+
+type XtDrugError struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId  int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	DrugId     int64  `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
+	RecordDate int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Remark     string `gorm:"column:remark" json:"remark" form:"remark"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime      int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime      int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtDrugError) TableName() string {
+	return "xt_drug_error"
+}

service/drug_pharmacy_management_service.go

@@ -1647,3 +1647,10 @@ func GetPharmacyConfig(orgid int64) (models.PharmacyConfig, error) {
 
 	return config, err
 }
+
+func CreateDrugError(drugError models.XtDrugError) error {
+
+	err := XTWriteDB().Create(&drugError).Error
+
+	return err
+}

service/pharmacy_service.go

@@ -2019,3 +2019,14 @@ func FindeHisAdviceDocAdvice(orgid int64, patient_id int64, stime int64, etime i
 
 	return advice, err
 }
+
+func GetFlow(drug_id int64, system_time int64, org_id int64, patient_id int64) (flow []*models.DrugFlow, err error) {
+
+	err = XTWriteDB().Where("drug_id = ? and system_time =? and user_org_id = ? and status = 1 and patient_id =?", drug_id, system_time, org_id, patient_id).Find(&flow).Error
+	return flow, err
+}
+
+func UpdateAdviceFlow(id int64) error {
+	err := XTWriteDB().Model(&models.HisDoctorAdviceInfo{}).Where("id = ? and status = 1 and is_medicine =0", id).Update(map[string]interface{}{"is_medicine": 1}).Error
+	return err
+}