库存调拨修改

controllers/dialysis_api_controller.go

@@ -109,6 +109,8 @@ func DialysisApiRegistRouters() {
 	beego.Router("/api/schedule/excutiondoctoradvicebyid", &DialysisApiController{}, "Get:ExcutionDoctorAdviceById")
 
 	beego.Router("/api/patient/getdialysisadvicetoday", &DialysisApiController{}, "Get:GetDialysisAdviceToday")
+
+	beego.Router("/api/schedule/getmobileschedulelist", &DialysisApiController{}, "Get:GetMobileScheduleList")
 }
 
 func (c *DialysisApiController) GetQueueCall() {
@@ -654,6 +656,23 @@ func (c *DialysisApiController) PostPrescription() {
 
 		updateErr := service.UpDateDialysisPrescription(&prescription)
 
+		//修改处方
+		if adminUserInfo.CurrentOrgId == 3877 || adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 10340 {
+			// 患者的临时医嘱里查找是否有抗凝剂临时医嘱
+			advicePrescription, _ := service.GetAdvicesByPrescription(adminUserInfo.CurrentOrgId, patient, recordDate.Unix())
+			if advicePrescription.ID > 0 {
+
+				service.UpdateDoctorAdvieById(advicePrescription.ID, prescribing_number)
+
+				key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":doctor_advices"
+				redis := service.RedisClient()
+				defer redis.Close()
+				//清空key 值
+				redis.Set(key, "", time.Second)
+				keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":advice_list_all"
+				redis.Set(keyOne, "", time.Second)
+			}
+		}
 		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
 		redis := service.RedisClient()
 		defer redis.Close()
@@ -5761,3 +5780,26 @@ func (this *DialysisApiController) GetDialysisAdviceToday() {
 		return
 	}
 }
+
+func (this *DialysisApiController) GetMobileScheduleList() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	schedule, _ := service.GetMobileScheduleList(orgId)
+
+	if len(schedule) > 0 {
+		for _, its := range schedule {
+			prescription, _ := service.GetPrescriptionList(its.PatientId, its.ScheduleDate, its.UserOrgId)
+			its.DialysisPrescription = prescription
+			monitor, _ := service.GetLastMonitorRecordList(its.PatientId, its.ScheduleDate, its.UserOrgId)
+			its.MonitoringRecord = monitor
+			after, _ := service.GetLastAfter(its.PatientId, its.ScheduleDate, its.UserOrgId)
+			its.XtAssessmentAfterDislysis = after
+		}
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"schedule": schedule,
+	})
+	return
+
+}

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -1658,6 +1658,7 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 
 		//长沙南雅医院，自动生成抗凝剂的临时处方
 		if adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 9671 || adminUserInfo.Org.Id == 10340 {
+
 			advice := models.DoctorAdvice{
 				UserOrgId:             adminUserInfo.Org.Id,
 				PatientId:             id,
@@ -1734,19 +1735,20 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 				break
 			}
 			//advice.AdviceDesc = "首剂" + strconv.FormatFloat(anticoagulant_shouji, 'f', -1, 64) + "维持" + strconv.FormatFloat(anticoagulant_weichi, 'f', -1, 64) + "总量" + strconv.FormatFloat(anticoagulant_zongliang, 'f', -1, 64)
-			if appRole.UserType == 2 || appRole.UserType == 1 {
+
+			if appRole.UserType == 2 || appRole.UserType == 1 || appRole.UserType == 4 {
 				advice.AdviceDoctor = appRole.AdminUserId
 			}
 
 			// 患者的临时医嘱里查找是否有抗凝剂临时医嘱
 			advicePrescription, _ := service.GetAdvicesByPrescription(adminUserInfo.Org.Id, id, recordDate.Unix())
-			if advicePrescription.ID > 0 && (anticoagulant == 3 || anticoagulant == 5 || anticoagulant == 7) {
+			if advicePrescription.ID > 0 && (anticoagulant == 3 || anticoagulant == 6 || anticoagulant == 7) {
 				advice.AdviceName = "低分子肝素钠注射液"
 				// 修改患者临时医嘱里的抗凝剂医嘱
 				advice.ID = advicePrescription.ID
 				service.UpdateDoctorAdvice(&advice)
 			} else {
-				if anticoagulant == 3 || anticoagulant == 5 || anticoagulant == 7 {
+				if anticoagulant == 3 || anticoagulant == 6 || anticoagulant == 7 {
 					advice.AdviceName = "低分子肝素钠注射液"
 					// 新增患者临时医嘱里的抗凝剂医嘱
 					service.CreateDoctorAdvice(&advice)
@@ -1854,6 +1856,25 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 		prescription.ID = dialysisPrescription.ID
 
 		err := service.UpDateDialysisPrescription(&prescription)
+
+		//修改处方
+		if adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 9671 || adminUserInfo.Org.Id == 10340 {
+			// 患者的临时医嘱里查找是否有抗凝剂临时医嘱
+			advicePrescription, _ := service.GetAdvicesByPrescription(adminUserInfo.Org.Id, id, recordDate.Unix())
+			if advicePrescription.ID > 0 {
+
+				service.UpdateDoctorAdvieById(advicePrescription.ID, prescribing_number)
+
+				key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":doctor_advices"
+				redis := service.RedisClient()
+				defer redis.Close()
+				//清空key 值
+				redis.Set(key, "", time.Second)
+				keyOne := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":advice_list_all"
+				redis.Set(keyOne, "", time.Second)
+			}
+		}
+
 		//获取key,清空redis
 		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
 		redis := service.RedisClient()
@@ -3289,7 +3310,7 @@ func (c *DialysisAPIController) PostSolution() {
 			break
 		}
 		//advice.AdviceDesc = "首剂" + strconv.FormatFloat(anticoagulant_shouji, 'f', -1, 64) + "维持" + strconv.FormatFloat(anticoagulant_weichi, 'f', -1, 64) + "总量" + strconv.FormatFloat(anticoagulant_zongliang, 'f', -1, 64)
-		if appRole.UserType == 2 || appRole.UserType == 1 {
+		if appRole.UserType == 2 || appRole.UserType == 1 || appRole.UserType == 4 {
 			advice.AdviceDoctor = appRole.AdminUserId
 		}
 

models/schedule_models.go

@@ -647,3 +647,27 @@ type MySchedule struct {
 func (MySchedule) TableName() string {
 	return "xt_schedule"
 }
+
+type MyVmBloodSchedule 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"`
+	PartitionId               int64                      `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId                     int64                      `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId                 int64                      `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate              int64                      `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType              int64                      `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek              int64                      `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId                    int64                      `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status                    int64                      `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime               int64                      `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime               int64                      `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport                  int64                      `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	SchedualPatient           *NewMSchedualPatientVMList `gorm:"ForeignKey:PatientId" json:"patient"`
+	DialysisPrescription      DialysisPrescription       `gorm:"ForeignKey:PatientId,RecordDate;AssociationForeignKey:PatientId,ScheduleDate" json:"dialysis_prescription"`
+	XtAssessmentAfterDislysis XtAssessmentAfterDislysis  `gorm:"ForeignKey:PatientId,AssessmentDate;AssociationForeignKey:PatientId,ScheduleDate" json:"xt_assesment_after_dislysis"`
+	MonitoringRecord          MonitoringRecord           `gorm:"ForeignKey:PatientId,MonitoringDate;AssociationForeignKey:PatientId,ScheduleDate" json:"monitor_record"`
+}
+
+func (MyVmBloodSchedule) TableName() string {
+	return "xt_schedule"
+}

service/dialysis_solution_service.go

@@ -234,7 +234,7 @@ func GetDialysisAdviceSchedulist(orgID int64, schedule_type int64, partition_id
 	}
 	err = db.Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
 		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-		Preload("XtDoctorAdvice", "status = 1 AND user_org_id = ? and advice_date = ?", orgID, scheduleDate).
+		Preload("XtDoctorAdvice", "status = 1 AND user_org_id = ? and advice_date = ? and advice_type = 2", orgID, scheduleDate).
 		Preload("HisDoctorAdvice", func(db *gorm.DB) *gorm.DB {
 			return db.Where("user_org_id = ? and status = 1 and advice_date = ?", orgID, scheduleDate).Preload("Drug", "org_id =? and status = 1", orgID)
 		}).Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).Find(&schedule).Error

service/gobal_config_service.go

@@ -237,7 +237,7 @@ func UpdateHisStockPriceRecord(config *models.HisStockPriceConfig) (err error) {
 	return
 }
 
-//TODO:项目开关
+// TODO:项目开关
 func FindXTHisProjectByOrgId(org_id int64) (err error, config models.XtHisProjectConfig) {
 	err = readDb.Model(&models.XtHisProjectConfig{}).Where("status = 1 AND user_org_id = ?", org_id).Find(&config).Error
 	return
@@ -1009,3 +1009,30 @@ func GetAllBaseDrugListTwenty(orgid int64) (drug []*models.BaseDrugLibTwenty, er
 	err = XTReadDB().Model(&drug).Where("org_id = ? and status = 1 AND  find_in_set('停用',drug_status) = 0", orgid).Find(&drug).Error
 	return drug, err
 }
+
+func GetMobileScheduleList(orgid int64) (schedule []*models.MyVmBloodSchedule, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and status= 1 and schedule_date>=1667232000 and schedule_date<=1669737600", orgid).Preload("SchedualPatient", "user_org_id = ? and status = 1", orgid).Find(&schedule).Error
+	return schedule, err
+}
+
+func GetPrescriptionList(patient_id int64, schedule_date int64, user_org_id int64) (models.DialysisPrescription, error) {
+
+	prescription := models.DialysisPrescription{}
+	err := XTReadDB().Where("patient_id = ? and record_date =? and user_org_id = ? and status =1", patient_id, schedule_date, user_org_id).Find(&prescription).Error
+	return prescription, err
+}
+
+func GetLastMonitorRecordList(patient_id int64, schedule_date int64, user_org_id int64) (models.MonitoringRecord, error) {
+
+	record := models.MonitoringRecord{}
+	err := XTReadDB().Where("patient_id =? and monitoring_date = ? and user_org_id = ? and status = 1", patient_id, schedule_date, user_org_id).Last(&record).Error
+	return record, err
+}
+
+func GetLastAfter(patient_id int64, schedule_date int64, user_org_id int64) (models.XtAssessmentAfterDislysis, error) {
+
+	dislysis := models.XtAssessmentAfterDislysis{}
+	err := XTReadDB().Where("patient_id = ? and assessment_date = ? and user_org_id =? and status= 1", patient_id, schedule_date, user_org_id).Find(&dislysis).Error
+	return dislysis, err
+}