耗材参数

controllers/dialysis_api_controller.go

@@ -244,6 +244,8 @@ func (c *DialysisApiController) PostPrescription() {
 	//fmt.Println("下机前推注鱼精蛋白",push_the_protamine)
 	// var prescription_doctor int64
 	blood := c.GetString("blood")
+	dialysis_dialyszers := c.GetString("dialysis_dialyszers")
+	dialysis_irrigation := c.GetString("dialysis_irrigation")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.CurrentOrgId)
 
@@ -322,7 +324,9 @@ func (c *DialysisApiController) PostPrescription() {
 		PreImpulse:                 preImpules,
 		AnticoagulantStopTimeHour:  anticoagulant_stop_time_hour,
 		AnticoagulantStopTimeMin:   anticoagulant_stop_time_min,
-		Blood: blood,
+		Blood:                      blood,
+		DialysisDialyszers:         dialysis_dialyszers,
+		DialysisIrrigation:         dialysis_irrigation,
 	}
 
 	if appRole.UserType == 2 || appRole.UserType == 1 {
@@ -489,6 +493,8 @@ func (c *DialysisApiController) PostSoulution() {
 	anticoagulant_stop_time_hour, _ := c.GetInt64("anticoagulant_stop_time_hour", 0)
 	anticoagulant_stop_time_min, _ := c.GetInt64("anticoagulant_stop_time_min", 0)
 	blood := c.GetString("blood")
+	dialysis_dialyszers := c.GetString("dialysis_dialyszers")
+	dialysis_irrigation := c.GetString("dialysis_irrigation")
 	var prescription_doctor int64
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 
@@ -578,7 +584,9 @@ func (c *DialysisApiController) PostSoulution() {
 
 		AnticoagulantStopTimeHour: anticoagulant_stop_time_hour,
 		AnticoagulantStopTimeMin:  anticoagulant_stop_time_min,
-		Blood: blood,
+		Blood:                     blood,
+		DialysisIrrigation:        dialysis_irrigation,
+		DialysisDialyszers:        dialysis_dialyszers,
 	}
 
 	_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(patient, recordDate.Unix(), adminUserInfo.CurrentOrgId)
@@ -1140,6 +1148,11 @@ func (c *DialysisApiController) PostAssessmentBeforeDislysis() {
 	urine_volume, _ := c.GetFloat("urine_volume", 0)
 	special_treatment := c.GetString("special_treatment")
 	catheter_maintenance := c.GetString("catheter_maintenance")
+	thrombusType := c.GetString("thromubus_type")
+	thrombusInt, _ := strconv.ParseInt(thrombusType, 10, 64)
+	thrombus_a := c.GetString("thromubus_a")
+	thrombus_av := c.GetString("thrombus_av")
+	thrombus_v := c.GetString("thromubus_v")
 	assessmentBeforeDislysis := models.PredialysisEvaluation{
 		DialysisCount:                  dialysis_count,
 		EmergencyTreatment:             emergency_treatment,
@@ -1197,6 +1210,10 @@ func (c *DialysisApiController) PostAssessmentBeforeDislysis() {
 		UrineVolume:                    urine_volume,
 		SpecialTreatment:               special_treatment,
 		CatheterMaintenance:            catheter_maintenance,
+		ThromubusType:                  thrombusInt,
+		ThrombusAv:                     thrombus_av,
+		ThromubusA:                     thrombus_a,
+		ThromubusV:                     thrombus_v,
 	}
 
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
@@ -1547,9 +1564,11 @@ func (c *DialysisApiController) GetDeviceList() {
 func (c *DialysisApiController) GetAllDeviceZone() {
 	adminUserInfo := c.GetAdminUserInfo()
 	err, zone := service.GetAllDeviceZone(adminUserInfo.CurrentOrgId)
+	dics, _, err := service.GetDrugWayDics(adminUserInfo.CurrentOrgId)
 	if err == nil {
 		c.ServeSuccessJSON(map[string]interface{}{
 			"zone": zone,
+			"dics": dics,
 		})
 	}
 
@@ -2295,6 +2314,7 @@ func (c *DialysisApiController) GetDialysisOrder() {
 	dialysisway, err := service.FindDialysisWay(adminUserInfo.CurrentOrgId, patientInfo.ID, xttime)
 	//获取临时医嘱
 	doctorAdvice, _ := service.FindDoctorOrder(adminUserInfo.CurrentOrgId, patientInfo.ID, xttime)
+	config, err := service.GetHisDoctorConfig(adminUserInfo.CurrentOrgId)
 
 	//获取医嘱内容
 	doctor, err := service.FindDoctor(doctorAdvice.AdviceDoctor, adminUserInfo.CurrentAppId, adminUserInfo.CurrentOrgId)
@@ -2347,38 +2367,79 @@ func (c *DialysisApiController) GetDialysisOrder() {
 	firstMonthDate := firstmonth.Unix()
 	//获取当前月份的病人透析次数
 	dialysiscount, err := service.GetDialysisCountByPatientId(firstMonthDate, xttime, patientInfo.ID, adminUserInfo.CurrentOrgId)
-	c.ServeSuccessJSON(map[string]interface{}{
-		"xtdate":                    xtdate,
-		"users":                     adminUser,
-		"patientInfo":               patientInfo,
-		"PredialysisEvaluation":     PredialysisEvaluation,
-		"AssessmentAfterDislysis":   AssessmentAfterDislysis,
-		"dialysisPrescription":      dialysisPrescription,
-		"advices":                   DoctorAdvice,
-		"monitors":                  Record,
-		"summary":                   TreatmentSummary,
-		"receiverTreatmentAccess":   receiverTreatmentAccess,
-		"dialysisOrder":             dialysisOrder,
-		"operators":                 operators,
-		"org_template_info":         templateInfo,
-		"check":                     check,
-		"schedule":                  schedule,
-		"dialysisway":               dialysisway,
-		"order":                     order,
-		"doctorAdvice":              doctorAdvice,
-		"doctor":                    doctor,
-		"nurse":                     nurse,
-		"doctorAdevieInfo":          doctorAdevieInfo,
-		"total":                     total,
-		"startNuse":                 startNuse,
-		"DoctorName":                DoctorName,
-		"assessmentAfterDislysis":   assessmentAfterDislysis,
-		"predialysName":             predialysName,
-		"FinishNuse":                FinishNuse,
-		"lastPredialysisEvaluation": lastPredialysisEvaluation,
-		"dialysiscount":             dialysiscount,
-		"last_order":                lastOrder,
-	})
+
+	//获取his数据
+	hisAdvice, err := service.GetHisDoctorPatientById(adminUserInfo.CurrentOrgId, patientInfo.ID, xttime)
+	if config.IsOpen == 1 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"xtdate":                    xtdate,
+			"users":                     adminUser,
+			"patientInfo":               patientInfo,
+			"PredialysisEvaluation":     PredialysisEvaluation,
+			"AssessmentAfterDislysis":   AssessmentAfterDislysis,
+			"dialysisPrescription":      dialysisPrescription,
+			"advices":                   hisAdvice,
+			"monitors":                  Record,
+			"summary":                   TreatmentSummary,
+			"receiverTreatmentAccess":   receiverTreatmentAccess,
+			"dialysisOrder":             dialysisOrder,
+			"operators":                 operators,
+			"org_template_info":         templateInfo,
+			"check":                     check,
+			"schedule":                  schedule,
+			"dialysisway":               dialysisway,
+			"order":                     order,
+			"doctorAdvice":              doctorAdvice,
+			"doctor":                    doctor,
+			"nurse":                     nurse,
+			"doctorAdevieInfo":          doctorAdevieInfo,
+			"total":                     total,
+			"startNuse":                 startNuse,
+			"DoctorName":                DoctorName,
+			"assessmentAfterDislysis":   assessmentAfterDislysis,
+			"predialysName":             predialysName,
+			"FinishNuse":                FinishNuse,
+			"lastPredialysisEvaluation": lastPredialysisEvaluation,
+			"dialysiscount":             dialysiscount,
+			"last_order":                lastOrder,
+		})
+
+	}
+	if config.IsOpen == 0 || config.IsOpen == 2 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"xtdate":                    xtdate,
+			"users":                     adminUser,
+			"patientInfo":               patientInfo,
+			"PredialysisEvaluation":     PredialysisEvaluation,
+			"AssessmentAfterDislysis":   AssessmentAfterDislysis,
+			"dialysisPrescription":      dialysisPrescription,
+			"advices":                   DoctorAdvice,
+			"monitors":                  Record,
+			"summary":                   TreatmentSummary,
+			"receiverTreatmentAccess":   receiverTreatmentAccess,
+			"dialysisOrder":             dialysisOrder,
+			"operators":                 operators,
+			"org_template_info":         templateInfo,
+			"check":                     check,
+			"schedule":                  schedule,
+			"dialysisway":               dialysisway,
+			"order":                     order,
+			"doctorAdvice":              doctorAdvice,
+			"doctor":                    doctor,
+			"nurse":                     nurse,
+			"doctorAdevieInfo":          doctorAdevieInfo,
+			"total":                     total,
+			"startNuse":                 startNuse,
+			"DoctorName":                DoctorName,
+			"assessmentAfterDislysis":   assessmentAfterDislysis,
+			"predialysName":             predialysName,
+			"FinishNuse":                FinishNuse,
+			"lastPredialysisEvaluation": lastPredialysisEvaluation,
+			"dialysiscount":             dialysiscount,
+			"last_order":                lastOrder,
+		})
+
+	}
 
 }
 

controllers/dialysis_record_api_controller.go

@@ -267,6 +267,11 @@ func (this *DialysisRecordAPIController) DialysisSchedule() {
 
 	_, is_open_config := service.FindXTHisRecordByOrgId(adminInfo.CurrentOrgId)
 
+	//获取耗材类型
+	stockType, _ := service.GetStockType(adminInfo.CurrentOrgId)
+
+	prepare, _ := service.GetDialyStockOut(adminInfo.CurrentOrgId, date.Unix(), patientID)
+
 	var his_advices []*models.HisDoctorAdviceInfo
 	if is_open_config.IsOpen == 1 {
 		his_advices, _ = service.GetAllHisDoctorAdvice(adminInfo.CurrentOrgId, patientID, date.Unix())
@@ -298,6 +303,8 @@ func (this *DialysisRecordAPIController) DialysisSchedule() {
 		"system_prescribe":            systemDialysisPrescribe,
 		"his_advices":                 his_advices,
 		"is_open_config":              is_open_config,
+		"stockType":                   stockType,
+		"prepare":                     prepare,
 	}
 	this.ServeSuccessJSON(returnData)
 

controllers/doctors_api_controller.go

@@ -33,6 +33,7 @@ func (c *DoctorsApiController) ScheduleAdvices() {
 	schedualDate := c.GetString("date")
 	adviceType, _ := c.GetInt("advice_type")
 	patientType, _ := c.GetInt("patient_type")
+	delivery_way := c.GetString("delivery_way")
 
 	if adviceType != 1 && adviceType != 3 && adviceType != 2 {
 		adviceType = 0
@@ -52,8 +53,8 @@ func (c *DoctorsApiController) ScheduleAdvices() {
 	adminUserInfo := c.GetAdminUserInfo()
 	orgID := adminUserInfo.CurrentOrgId
 
-	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminUserInfo.AdminUser.Id)
-	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix())
+	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminUserInfo.AdminUser.Id, delivery_way)
+	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix(), delivery_way)
 	config, _ := service.GetHisDoctorConfig(orgID)
 	adminUser, _ := service.GetAllAdminUsers(orgID, adminUserInfo.CurrentAppId)
 	if err != nil {

controllers/drug_stock_api_contorller.go

@@ -1417,7 +1417,7 @@ func (c *StockDrugApiController) EditDrugWarehouseOut() {
 					sys_record_time := int64(items["sys_record_time"].(float64))
 
 					warehouseOutInfo := &models.DrugWarehouseOutInfo{
-						ID: id,
+						ID:                      id,
 						WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 						WarehouseOutId:          warehouseOut.ID,
 						DrugId:                  drug_id,
@@ -1866,9 +1866,34 @@ func (c *StockDrugApiController) GetDrugQueryInfo() {
 	page, _ := c.GetInt64("page", -1)
 	limit, _ := c.GetInt64("limit", -1)
 	keyword := c.GetString("keyword")
+	drug_category, _ := c.GetInt64("drug_category")
+	start_time := c.GetString("start_time")
+	end_time := c.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
 
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			fmt.Println(err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
 	adminUserInfo := c.GetAdminUserInfo()
-	list, total, err := service.FindAllDrugStockInfo(adminUserInfo.CurrentOrgId, page, limit, keyword)
+	list, total, err := service.FindAllDrugStockInfo(adminUserInfo.CurrentOrgId, page, limit, keyword, drug_category, startTime, endTime)
 	if err == nil {
 		c.ServeSuccessJSON(map[string]interface{}{
 			"list":  list,

controllers/mobile_api_controllers/check_weight_api_controller.go

@@ -13,7 +13,7 @@ import (
 	"net/http"
 	"net/url"
 	"strconv"
-	_"strings"
+	_ "strings"
 
 	// "fmt"
 	_ "reflect"
@@ -619,20 +619,26 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 			}
 
 			if lastPredialysisEvaluation != nil {
-				evaluation.BloodAccessPartId = lastPredialysisEvaluation.BloodAccessPartId
-				evaluation.BloodAccessPartOperaId = lastPredialysisEvaluation.BloodAccessPartOperaId
-				evaluation.AdditionalWeight = lastPredialysisEvaluation.AdditionalWeight
-				evaluation.Temperature = lastPredialysisEvaluation.Temperature
-				evaluation.BreathingRate = lastPredialysisEvaluation.BreathingRate
-				evaluation.Catheter = lastPredialysisEvaluation.Catheter
-				evaluation.InternalFistula = lastPredialysisEvaluation.InternalFistula
-				evaluation.PulseFrequency = lastPredialysisEvaluation.PulseFrequency
-				evaluation.Complication = lastPredialysisEvaluation.Complication
-				evaluation.LastPostDialysis = lastPredialysisEvaluation.LastPostDialysis
-				evaluation.DialysisInterphase = lastPredialysisEvaluation.DialysisInterphase
-				evaluation.SymptomBeforeDialysis = lastPredialysisEvaluation.SymptomBeforeDialysis
-				evaluation.PunctureNeedle = lastPredialysisEvaluation.PunctureNeedle
-				evaluation.PunctureWay = lastPredialysisEvaluation.PunctureWay
+				evaluation.BloodAccessPartId = lastPredialysisEvaluation.BloodAccessPartId           //血管通路部位
+				evaluation.BloodAccessPartOperaId = lastPredialysisEvaluation.BloodAccessPartOperaId //血管通路
+				evaluation.AdditionalWeight = lastPredialysisEvaluation.AdditionalWeight             //衣物重
+				evaluation.Temperature = lastPredialysisEvaluation.Temperature                       //温度
+				evaluation.BreathingRate = lastPredialysisEvaluation.BreathingRate                   //呼吸
+				evaluation.Catheter = lastPredialysisEvaluation.Catheter                             //导管
+				evaluation.InternalFistula = lastPredialysisEvaluation.InternalFistula               //内瘘
+				evaluation.PulseFrequency = lastPredialysisEvaluation.PulseFrequency                 //脉搏
+				evaluation.Complication = lastPredialysisEvaluation.Complication                     //并发症
+				evaluation.LastPostDialysis = lastPredialysisEvaluation.LastPostDialysis             //前次透析后症状
+				evaluation.DialysisInterphase = lastPredialysisEvaluation.DialysisInterphase         //透析期间
+				evaluation.SymptomBeforeDialysis = lastPredialysisEvaluation.SymptomBeforeDialysis   //透析前症状
+				evaluation.PunctureNeedle = lastPredialysisEvaluation.PunctureNeedle                 //穿刺针
+				evaluation.PunctureWay = lastPredialysisEvaluation.PunctureWay                       //穿刺方法
+
+				evaluation.InternalFistulaSkin = lastPredialysisEvaluation.InternalFistulaSkin //血透通路皮肤情况
+				evaluation.CatheterBend = lastPredialysisEvaluation.CatheterBend               //导管打折
+				evaluation.IsHemorrhage = lastPredialysisEvaluation.IsHemorrhage               //出血
+				evaluation.IsInfect = lastPredialysisEvaluation.IsInfect                       //感染
+				evaluation.Exposed = lastPredialysisEvaluation.Exposed                         // 外漏
 
 			}
 		} else {
@@ -696,41 +702,41 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 	}
 }
 
-func (c *CheckWeightApiController) SetSyncTime(){
+func (c *CheckWeightApiController) SetSyncTime() {
 	sn := c.GetString("sn")
-	if len(sn)  > 0 {
+	if len(sn) > 0 {
 		redis := service.RedisClient()
 		defer redis.Close()
-		redis.Set(sn, 0,0)
+		redis.Set(sn, 0, 0)
 	}
 	serviceTime := time.Now().Unix()
 	c.ServeSuccessJSON(map[string]interface{}{
-		"status": 	1,
+		"status":      1,
 		"servicetime": serviceTime,
 	})
 }
 
 func (c *CheckWeightApiController) GetPatientList() {
-	ftype,_ := c.GetInt64("type",0)
+	ftype, _ := c.GetInt64("type", 0)
 	sn := c.GetString("sn")
 	syncTime := int64(0)
 
 	redis := service.RedisClient()
 	defer redis.Close()
-	if len(sn)  > 0 {
+	if len(sn) > 0 {
 		syncTimeStr, _ := redis.Get(sn).Result()
-		syncTime,_ = strconv.ParseInt(syncTimeStr, 10, 64)
+		syncTime, _ = strconv.ParseInt(syncTimeStr, 10, 64)
 	}
 
 	if ftype == 1 {
 		timeNow := time.Now().Unix()
-		redis.Set(sn, timeNow,0)
+		redis.Set(sn, timeNow, 0)
 	}
 
 	adminUserInfo := c.GetMobileAdminUserInfo()
 	need_update := 0
 	patientList, total, error := service.GetPatientListByUpdateTime(adminUserInfo.Org.Id, int64(syncTime))
-	if len(patientList)  > 0 {
+	if len(patientList) > 0 {
 		need_update = 1
 	}
 	if error != nil {
@@ -740,7 +746,7 @@ func (c *CheckWeightApiController) GetPatientList() {
 	}
 	serviceTime := time.Now().Unix()
 	c.ServeSuccessJSON(map[string]interface{}{
-		"need_update" : need_update,
+		"need_update": need_update,
 		"patientlist": patientList,
 		"total":       total,
 		"servicetime": serviceTime,
@@ -779,7 +785,7 @@ func (c *CheckWeightApiController) GetPatientListForSchedules() {
 }
 
 func (c *CheckWeightApiController) GetPatientListForSchedulesFind() {
-	patient_name := c.GetString("patient_name")                   //脉率
+	patient_name := c.GetString("patient_name") //脉率
 	thisTime := time.Now()
 	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
 	timeLayout := "2006-01-02 15:04:05"
@@ -810,8 +816,8 @@ func (c *CheckWeightApiController) GetPatientListForSchedulesFind() {
 			"servicetime": serviceTime,
 		})
 	} else {
-		patientList, total, error := service.GetPatientListBySchedulesFind(adminUserInfo.Org.Id, syncTime,patient_name)
-		patientSchedule := make([]map[string]interface{},0)
+		patientList, total, error := service.GetPatientListBySchedulesFind(adminUserInfo.Org.Id, syncTime, patient_name)
+		patientSchedule := make([]map[string]interface{}, 0)
 		for _, item := range patientList {
 			if item.Patient.ID > 0 {
 				patientTemp := make(map[string]interface{})
@@ -922,12 +928,12 @@ func (c *CheckWeightApiController) GetPatientInfoDialysis() {
 		}
 
 		// 排队叫号的签到
-		go func (){
+		go func() {
 			ssoDomain := beego.AppConfig.String("call_domain")
 			api := ssoDomain + "/index/patientsign/" + strconv.FormatInt(adminUserInfo.Org.Id, 10) + "/" + strconv.FormatInt(id, 10)
 			values := make(url.Values)
 			http.PostForm(api, values)
-		} ()
+		}()
 	} else {
 		nextSchedule, _ := service.GetNextSchedule(adminUserInfo.Org.Id, endTime, id)
 		if len(nextSchedule) <= 0 {

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -248,7 +248,7 @@ func (this *DialysisAPIController) DialysisRecord() {
 	}
 
 	schedual, getSchedualErr := service.MobileGetSchedualDetail(adminInfo.Org.Id, patientID, date.Unix())
-	// this.TraceLog("==================================%+v", schedual)
+
 	if getSchedualErr != nil {
 		this.ErrorLog("获取患者排班信息失败:%v", getSchedualErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
@@ -369,6 +369,9 @@ func (this *DialysisAPIController) DialysisRecord() {
 
 	_, is_open_config := service.FindXTHisRecordByOrgId(adminInfo.Org.Id)
 
+	stockType, _ := service.GetStockType(adminInfo.Org.Id)
+
+	prepare, _ := service.GetDialyStockOut(adminInfo.Org.Id, date.Unix(), patientID)
 	var his_advices []*models.HisDoctorAdviceInfo
 	if is_open_config.IsOpen == 1 {
 		his_advices, _ = service.GetAllHisDoctorAdvice(adminInfo.Org.Id, patientID, date.Unix())
@@ -421,6 +424,8 @@ func (this *DialysisAPIController) DialysisRecord() {
 		"system_prescription":            systemDialysisPrescribe,
 		"his_advices":                    his_advices,
 		"is_open_config":                 is_open_config,
+		"stockType":                      stockType,
+		"prepare":                        prepare,
 	}
 	this.ServeSuccessJSON(returnData)
 }
@@ -1054,6 +1059,8 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 	anticoagulant_stop_time_hour, _ := c.GetInt64("anticoagulant_stop_time_hour", 0)
 	anticoagulant_stop_time_min, _ := c.GetInt64("anticoagulant_stop_time_min", 0)
 	blood := c.GetString("blood")
+	dialysis_dialyszers := c.GetString("dialysis_dialyszers")
+	dialysis_irrigation := c.GetString("dialysis_irrigation")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.Org.Id, adminUserInfo.AdminUser.Id, adminUserInfo.App.Id)
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.Org.Id)
 	//
@@ -1137,6 +1144,8 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 		AnticoagulantStopTimeHour:  anticoagulant_stop_time_hour,
 		AnticoagulantStopTimeMin:   anticoagulant_stop_time_min,
 		Blood:                      blood,
+		DialysisDialyszers:         dialysis_dialyszers,
+		DialysisIrrigation:         dialysis_irrigation,
 	}
 
 	_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(id, recordDate.Unix(), adminUserInfo.Org.Id)
@@ -1829,6 +1838,8 @@ func (c *DialysisAPIController) PostSolution() {
 	anticoagulant_stop_time_hour, _ := c.GetInt64("anticoagulant_stop_time_hour", 0)
 	anticoagulant_stop_time_min, _ := c.GetInt64("anticoagulant_stop_time_min", 0)
 	blood := c.GetString("blood")
+	dialysis_dialyszers := c.GetString("dialysis_dialyszers")
+	dialysis_irrigation := c.GetString("dialysis_irrigation")
 	if mode_id > 0 {
 		service.ModifyScheduleMode(mode_id, patient.ID, recordDate.Unix(), adminUserInfo.Org.Id)
 	}
@@ -1913,6 +1924,8 @@ func (c *DialysisAPIController) PostSolution() {
 		AnticoagulantStopTimeMin:  anticoagulant_stop_time_min,
 		AnticoagulantStopTimeHour: anticoagulant_stop_time_hour,
 		Blood:                     blood,
+		DialysisDialyszers:        dialysis_dialyszers,
+		DialysisIrrigation:        dialysis_irrigation,
 	}
 
 	_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(id, recordDate.Unix(), adminUserInfo.Org.Id)
@@ -2981,7 +2994,8 @@ func (c *DialysisAPIController) CreateConsumables() {
 				}
 
 				count, _ := strconv.ParseInt(items["count"].(string), 10, 64)
-
+				//commdity_code := items["commdity_code"].(string)
+				//fmt.Println("新建22222222222222",commdity_code)
 				adminUser := c.GetMobileAdminUserInfo()
 				prepare := &models.DialysisBeforePrepare{
 					UserOrgId:  adminUser.Org.Id,
@@ -2994,6 +3008,7 @@ func (c *DialysisAPIController) CreateConsumables() {
 					Mtime:      time.Now().Unix(),
 					Creater:    adminUser.AdminUser.Id,
 					Modifier:   0,
+					//CommdityCode:commdity_code,
 				}
 				record_count := service.FindDialysisBeforePrepare(prepare.PatientId, prepare.GoodId, prepare.GoodTypeId, adminUser.Org.Id, record_time)
 				if record_count == 0 {
@@ -3072,6 +3087,8 @@ func (c *DialysisAPIController) CreateConsumables() {
 				}
 				ctime := int64(items["ctime"].(float64))
 
+				//commdity_code := items["commdity_code"].(string)
+				//fmt.Println("commdityecode22222222222222222222",commdity_code)
 				prepare := &models.DialysisBeforePrepare{
 					ID:         id,
 					UserOrgId:  adminUser.Org.Id,
@@ -3085,6 +3102,7 @@ func (c *DialysisAPIController) CreateConsumables() {
 					Creater:    creater,
 					Modifier:   adminUser.AdminUser.Id,
 					Status:     1,
+					//CommdityCode: commdity_code,
 				}
 				updateBeforePrepares = append(updateBeforePrepares, prepare)
 
@@ -3381,7 +3399,8 @@ func (c *DialysisAPIController) EditConsumables() {
 						return
 					}
 					ctime := int64(items["ctime"].(float64))
-
+					//commdity_code := items["commdity_code"].(string)
+					//fmt.Println("commdityecode22222222222222222222",commdity_code)
 					adminUser := c.GetMobileAdminUserInfo()
 					prepare := &models.DialysisBeforePrepare{
 						ID:         id,
@@ -3396,6 +3415,7 @@ func (c *DialysisAPIController) EditConsumables() {
 						Creater:    creater,
 						Modifier:   adminUser.AdminUser.Id,
 						Status:     1,
+						//CommdityCode: commdity_code,
 					}
 					beforePrepares = append(beforePrepares, prepare)
 
@@ -3432,7 +3452,8 @@ func (c *DialysisAPIController) EditConsumables() {
 					}
 
 					count, _ := strconv.ParseInt(items["count"].(string), 10, 64)
-
+					//commdity_code := items["commdity_code"].(string)
+					//fmt.Println("commdityecode22222222222222222222",commdity_code)
 					adminUser := c.GetMobileAdminUserInfo()
 					prepare := &models.DialysisBeforePrepare{
 						UserOrgId:  adminUser.Org.Id,
@@ -3445,6 +3466,7 @@ func (c *DialysisAPIController) EditConsumables() {
 						Mtime:      time.Now().Unix(),
 						Creater:    adminUser.AdminUser.Id,
 						Modifier:   0,
+						//CommdityCode:commdity_code,
 					}
 					newBeforePrepares = append(newBeforePrepares, prepare)
 
@@ -4258,6 +4280,7 @@ func (c *DialysisAPIController) CreateOtherStockOutInfo() {
 						GoodTypeId:              item.GoodTypeId,
 						Count:                   item.Count,
 					}
+
 					service.AddSigleAutoReduceRecordInfo(details)
 				}
 			}

controllers/mobile_api_controllers/doctor_advice_api_controller.go

@@ -19,7 +19,7 @@ func (this *DoctorAdviceAPIController) ScheduleAdvices() {
 	schedualDate := this.GetString("date")
 	adviceType, _ := this.GetInt("advice_type")
 	patientType, _ := this.GetInt("patient_type")
-
+	delivery_way := this.GetString("delivery_way")
 	if adviceType != 1 && adviceType != 3 && adviceType != 2 {
 		adviceType = 0
 	}
@@ -38,10 +38,10 @@ func (this *DoctorAdviceAPIController) ScheduleAdvices() {
 	adminInfo := this.GetMobileAdminUserInfo()
 	orgID := adminInfo.Org.Id
 
-	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminInfo.AdminUser.Id)
+	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminInfo.AdminUser.Id, delivery_way)
 	//获取his医嘱数据
 	fmt.Println("date.un222222", date.Unix())
-	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix())
+	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix(), delivery_way)
 	config, _ := service.GetHisDoctorConfig(orgID)
 	adminUser, _ := service.GetAllAdminUsers(orgID, adminInfo.App.Id)
 	if err != nil {

controllers/mobile_api_controllers/patient_api_controller.go

@@ -2363,6 +2363,27 @@ func predialysisEvaluationFormData(evaluation *models.PredialysisEvaluation, dat
 		evaluation.CatheterMaintenance = catheter_maintenance
 	}
 
+	if dataBody["thromubus_type"] != nil && reflect.TypeOf(dataBody["thromubus_type"]).String() == "float64" {
+
+		thromubusType := int64(dataBody["thromubus_type"].(float64))
+
+		evaluation.ThromubusType = thromubusType
+	}
+
+	if dataBody["thrombus_av"] != nil && reflect.TypeOf(dataBody["thrombus_av"]).String() == "string" {
+		thrombus_av := dataBody["thrombus_av"].(string)
+		evaluation.ThrombusAv = thrombus_av
+	}
+
+	if dataBody["thromubus_a"] != nil && reflect.TypeOf(dataBody["thromubus_a"]).String() == "string" {
+		thromubus_a := dataBody["thromubus_a"].(string)
+		evaluation.ThromubusA = thromubus_a
+	}
+
+	if dataBody["thromubus_v"] != nil && reflect.TypeOf(dataBody["thromubus_v"]).String() == "string" {
+		thromubus_v := dataBody["thromubus_v"].(string)
+		evaluation.ThromubusV = thromubus_v
+	}
 	return
 }
 
@@ -2686,6 +2707,7 @@ func (c *PatientApiController) GetRecords() {
 func (c *PatientApiController) GetPatientMonitor() {
 	partition, _ := c.GetInt64("partition")
 	monitorDate := c.GetString("date")
+	patient_id, _ := c.GetInt64("patient_id")
 
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
@@ -2700,10 +2722,16 @@ func (c *PatientApiController) GetPatientMonitor() {
 	}
 	adminInfo := c.GetMobileAdminUserInfo()
 	orgID := adminInfo.Org.Id
-	monitor, err := service.GetMonitorRecord(orgID, theStartTime, partition)
+	monitor, err := service.GetMonitorRecord(orgID, theStartTime, partition, patient_id)
+	//获取患者的透析次数
+	count, err := service.GetDialysisCount(orgID, partition)
+
+	patients, err := service.GetAllpatient(orgID)
 	if err == nil {
 		c.ServeSuccessJSON(map[string]interface{}{
-			"monitor": monitor,
+			"monitor":      monitor,
+			"patientCount": count,
+			"patients":     patients,
 		})
 	} else {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
@@ -2904,23 +2932,48 @@ func (c *PatientApiController) GetPrintDialysisOrder() {
 	check, _ := service.FindDoubleCheckById(adminUserInfo.Org.Id, patientInfo.ID, xttime)
 
 	dialysiscount, err := service.GetDialysisCountByPatientId(firstMonthDate, xttime, patientInfo.ID, adminUserInfo.Org.Id)
-	c.ServeSuccessJSON(map[string]interface{}{
-		"users":                   adminUser,
-		"patientInfo":             patientInfo,
-		"PredialysisEvaluation":   PredialysisEvaluation,
-		"AssessmentAfterDislysis": AssessmentAfterDislysis,
-		"dialysisPrescription":    dialysisPrescription,
-		"advices":                 DoctorAdvice,
-		"monitors":                Record,
-		"summary":                 TreatmentSummary,
-		"receiverTreatmentAccess": receiverTreatmentAccess,
-		"dialysisOrder":           dialysisOrder,
-		"operators":               operators,
-		"org_template_info":       templateInfo,
-		"check":                   check,
-		"dialysiscount":           dialysiscount,
-		"last_order":              last_order,
-	})
+
+	config, err := service.GetHisDoctorConfig(adminUserInfo.Org.Id)
+	hisAdvice, err := service.GetHisDoctorPatientById(adminUserInfo.Org.Id, patientInfo.ID, xttime)
+	if config.IsOpen == 1 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"users":                   adminUser,
+			"patientInfo":             patientInfo,
+			"PredialysisEvaluation":   PredialysisEvaluation,
+			"AssessmentAfterDislysis": AssessmentAfterDislysis,
+			"dialysisPrescription":    dialysisPrescription,
+			"advices":                 hisAdvice,
+			"monitors":                Record,
+			"summary":                 TreatmentSummary,
+			"receiverTreatmentAccess": receiverTreatmentAccess,
+			"dialysisOrder":           dialysisOrder,
+			"operators":               operators,
+			"org_template_info":       templateInfo,
+			"check":                   check,
+			"dialysiscount":           dialysiscount,
+			"last_order":              last_order,
+		})
+	}
+
+	if config.IsOpen == 0 || config.IsOpen == 2 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"users":                   adminUser,
+			"patientInfo":             patientInfo,
+			"PredialysisEvaluation":   PredialysisEvaluation,
+			"AssessmentAfterDislysis": AssessmentAfterDislysis,
+			"dialysisPrescription":    dialysisPrescription,
+			"advices":                 DoctorAdvice,
+			"monitors":                Record,
+			"summary":                 TreatmentSummary,
+			"receiverTreatmentAccess": receiverTreatmentAccess,
+			"dialysisOrder":           dialysisOrder,
+			"operators":               operators,
+			"org_template_info":       templateInfo,
+			"check":                   check,
+			"dialysiscount":           dialysiscount,
+			"last_order":              last_order,
+		})
+	}
 
 }
 

controllers/stock_in_api_controller.go

@@ -65,6 +65,8 @@ func StockManagerApiRegistRouters() {
 	beego.Router("/api/warehouseout/user", &StockManagerApiController{}, "get:GetUserDetailInfo")
 
 	beego.Router("/api/warehouseout/postsearchstock", &StockManagerApiController{}, "Get:PostSearchStock")
+
+	beego.Router("/api/warehouseout/getoutstocktotalcount", &StockManagerApiController{}, "Get:GetOutStockTotalCount")
 }
 
 func (c *StockManagerApiController) CreateWarehouse() {
@@ -1965,7 +1967,6 @@ func (this *StockManagerApiController) GetUserDetailInfo() {
 func (this *StockManagerApiController) PostSearchStock() {
 
 	keyword := this.GetString("keyword")
-	fmt.Println("keyword2222222222222", keyword)
 	adminUserInfo := this.GetAdminUserInfo()
 	orgId := adminUserInfo.CurrentOrgId
 	stock, err := service.PostSearchStock(keyword, orgId)
@@ -1976,3 +1977,16 @@ func (this *StockManagerApiController) PostSearchStock() {
 		"stock": stock,
 	})
 }
+
+func (this *StockManagerApiController) GetOutStockTotalCount() {
+
+	warehouseOutTime, _ := this.GetInt64("warehouse_out_time")
+	adminUserInfo := this.GetAdminUserInfo()
+	stockCount, err := service.GetOutStockTotalCount(warehouseOutTime, adminUserInfo.CurrentOrgId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeleteFail)
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"stockCount": stockCount,
+	})
+}

models/dialysis.go

@@ -276,6 +276,10 @@ type PredialysisEvaluation struct {
 	Edema                          string  `gorm:"column:edema" json:"edema" form:"edema"`
 	SpecialTreatment               string  `gorm:"column:special_treatment" json:"special_treatment" form:"special_treatment"`
 	CatheterMaintenance            string  `gorm:"column:catheter_maintenance" json:"catheter_maintenance" form:"catheter_maintenance"`
+	ThromubusType                  int64   `gorm:"column:thromubus_type" json:"thromubus_type" form:"thromubus_type"`
+	ThrombusAv                     string  `gorm:"column:thrombus_av" json:"thrombus_av" form:"thrombus_av"`
+	ThromubusA                     string  `gorm:"column:thromubus_a" json:"thromubus_a" form:"thromubus_a"`
+	ThromubusV                     string  `gorm:"column:thromubus_v" json:"thromubus_v" form:"thromubus_v"`
 }
 
 func (PredialysisEvaluation) TableName() string {
@@ -940,18 +944,19 @@ type UserAdminRoles struct {
 }
 
 type DialysisBeforePrepare 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"`
-	PatientId  int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	RecordDate int64 `gorm:"column:record_date" json:"record_date" form:"record_date"`
-	GoodId     int64 `gorm:"column:good_id" json:"good_id" form:"good_id"`
-	GoodTypeId int64 `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
-	Count      int64 `gorm:"column:count" json:"count" form:"count"`
-	Ctime      int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
-	Mtime      int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
-	Creater    int64 `gorm:"column:creater" json:"creater" form:"creater"`
-	Modifier   int64 `gorm:"column:modifier" json:"modifier" form:"modifier"`
-	Status     int64 `gorm:"column:status" json:"status" form:"status"`
+	ID           int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId    int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId    int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	RecordDate   int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	GoodId       int64  `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	GoodTypeId   int64  `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
+	Count        int64  `gorm:"column:count" json:"count" form:"count"`
+	Ctime        int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime        int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Creater      int64  `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier     int64  `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	Status       int64  `gorm:"column:status" json:"status" form:"status"`
+	CommdityCode string `gorm:"column:commdity_code" json:"commdity_code" form:"commdity_code"`
 }
 
 func (DialysisBeforePrepare) TableName() string {
@@ -977,3 +982,20 @@ type QueueCallConfig struct {
 func (QueueCallConfig) TableName() string {
 	return "xt_queue_call_config"
 }
+
+type XtDialysisBeforePrepare 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"`
+	PatientId         int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	RecordDate        int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	GoodId            int64  `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	GoodTypeId        int64  `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
+	Count             int64  `gorm:"column:count" json:"count" form:"count"`
+	Ctime             int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime             int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Creater           int64  `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier          int64  `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	Status            int64  `gorm:"column:status" json:"status" form:"status"`
+	CommdityCode      string `gorm:"column:commdity_code" json:"commdity_code" form:"commdity_code"`
+	SpecificationName string `gorm:"column:specification_name" json:"specification_name" form:"specification_name"`
+}

models/dialysis_parameter_models.go

@@ -148,3 +148,8 @@ type PredialysisEvaluationParameter struct {
 func (PredialysisEvaluationParameter) TableName() string {
 	return "xt_assessment_before_dislysis"
 }
+
+type NewXtAutomaticReduceDetail struct {
+	GoodId int64 `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	Count  int64 `gorm:"column:count" json:"count" form:"count"`
+}

models/good_models.go

@@ -68,6 +68,7 @@ type GoodInfo struct {
 	Agent                  string    `gorm:"column:agent" json:"agent" form:"agent"`
 	GoodNumber             string    `gorm:"column:good_number" json:"good_number" form:"good_number"`
 	GoodsType              GoodsType `gorm:"ForeignKey:ID;AssociationForeignKey:GoodTypeId" json:"type"`
+	CommdityCode           string    `gorm:"column:commdity_code" json:"commdity_code" form:"commdity_code"`
 }
 
 func (GoodInfo) TableName() string {

models/new_monitor.go

@@ -20,7 +20,7 @@ type NewVMMonitorDialysisSchedule struct {
 	Prescription             VMDialysisPrescription    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"prescription"`
 	AssessmentBeforeDislysis VMPredialysisEvaluation   `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_before_dislysis"`
 	AssessmentAfterDislysis  VMAssessmentAfterDislysis `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_after_dislysis"`
-	MonitoringRecord         []VMMonitoringRecord      `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"monitoring_record"`
+	MonitoringRecord         []VMMonitoringRecord      `gorm:"ForeignKey:PatientId,MonitoringDate;AssociationForeignKey:PatientId,ScheduleDate" json:"monitoring_record"`
 }
 
 func (NewVMMonitorDialysisSchedule) TableName() string {
@@ -28,11 +28,12 @@ func (NewVMMonitorDialysisSchedule) TableName() string {
 }
 
 type VMMonitorPatients 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"`
-	Name       string `gorm:"column:name" json:"name" form:"name"`
-	Status     int64  `gorm:"column:status" json:"status" form:"status"`
-	DialysisNo string `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	ID                 int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId          int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Name               string `gorm:"column:name" json:"name" form:"name"`
+	Status             int64  `gorm:"column:status" json:"status" form:"status"`
+	DialysisNo         string `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	UserSysBeforeCount int64  `gorm:"column:user_sys_before_count" json:"user_sys_before_count" form:"user_sys_before_count"`
 }
 
 func (VMMonitorPatients) TableName() string {

models/patient_models.go

@@ -225,6 +225,8 @@ type DialysisPrescription struct {
 	AnticoagulantStopTimeMin   int64         `gorm:"column:anticoagulant_stop_time_min" json:"anticoagulant_stop_time_min" form:"anticoagulant_stop_time_min"`
 	AnticoagulantStopTimeHour  int64         `gorm:"column:anticoagulant_stop_time_hour" json:"anticoagulant_stop_time_hour" form:"anticoagulant_stop_time_hour"`
 	Blood                      string        `gorm:"column:blood" json:"blood"`
+	DialysisDialyszers         string        `gorm:"column:dialysis_dialyszers" json:"dialysis_dialyszers" form:"dialysis_dialyszers"`
+	DialysisIrrigation         string        `gorm:"column:dialysis_irrigation" json:"dialysis_irrigation" form:"dialysis_irrigation"`
 }
 
 func (DialysisPrescription) TableName() string {

service/dialysis_service.go

@@ -1055,11 +1055,11 @@ func CreateDialysisBeforePrepare(beforePrepares []*models.DialysisBeforePrepare)
 	if len(beforePrepares) > 0 {
 		utx := writeDb.Begin()
 		if len(beforePrepares) > 0 {
-			thisSQL := "INSERT INTO dialysis_before_prepare (user_org_id, patient_id, record_date, good_id, good_type_id,count,ctime,mtime,creater,modifier,status) VALUES "
+			thisSQL := "INSERT INTO dialysis_before_prepare (user_org_id, patient_id, record_date, good_id, good_type_id,count,ctime,mtime,creater,modifier,status,commdity_code) VALUES "
 			insertParams := make([]string, 0)
 			insertData := make([]interface{}, 0)
 			for _, prepare := range beforePrepares {
-				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
+				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?)")
 				insertData = append(insertData, prepare.UserOrgId)
 				insertData = append(insertData, prepare.PatientId)
 				insertData = append(insertData, prepare.RecordDate)
@@ -1071,7 +1071,7 @@ func CreateDialysisBeforePrepare(beforePrepares []*models.DialysisBeforePrepare)
 				insertData = append(insertData, prepare.Creater)
 				insertData = append(insertData, prepare.Modifier)
 				insertData = append(insertData, 1)
-
+				insertData = append(insertData, prepare.CommdityCode)
 			}
 			thisSQL += strings.Join(insertParams, ", ")
 			err = utx.Exec(thisSQL, insertData...).Error
@@ -1094,7 +1094,7 @@ func UpdateDialysisBeforePrepare(info *models.DialysisBeforePrepare) (err error)
 func UpdateDialysisBeforePrepareTwo(info *models.DialysisBeforePrepare) (err error) {
 	err = writeDb.Model(&models.DialysisBeforePrepare{}).
 		Where("status = 1 AND good_id = ? AND good_type_id = ? AND patient_id = ? AND user_org_id = ? AND record_date = ?", info.GoodId, info.GoodTypeId, info.PatientId, info.UserOrgId, info.RecordDate).
-		Updates(map[string]interface{}{"count": info.Count, "updated_time": time.Now().Unix(), "modifier": info.Modifier}).Error
+		Updates(map[string]interface{}{"count": info.Count, "updated_time": time.Now().Unix(), "modifier": info.Modifier, "commdity_code": info.CommdityCode}).Error
 
 	return err
 }

service/drug_stock_service.go

@@ -90,17 +90,56 @@ func (DrugStockInfo) TableName() string {
 	return "xt_base_drug"
 }
 
-func FindAllDrugStockInfo(orgId int64, page int64, limit int64, keyword string) (list []*DrugStockInfo, total int64, err error) {
+func FindAllDrugStockInfo(orgId int64, page int64, limit int64, keyword string, drugCategory int64, startTime int64, endTime int64) (list []*DrugStockInfo, total int64, err error) {
 	db := readDb.Model(&DrugStockInfo{})
-	db = db.Where("xt_base_drug.org_id = ? AND xt_base_drug.status = 1", orgId)
-	db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
-		return db.Where("org_id = ? AND status = 1", orgId)
-	})
-	db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1", orgId)
-	db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
-		return db.Where("org_id = ? AND status = 1", orgId)
-	})
-	db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1", orgId)
+	if drugCategory > 0 {
+		db = db.Where("xt_base_drug.org_id = ? AND xt_base_drug.status = 1 AND xt_base_drug.drug_category = ?", orgId, drugCategory)
+	} else {
+		db = db.Where("xt_base_drug.org_id = ? AND xt_base_drug.status = 1", orgId)
+	}
+
+	if startTime > 0 {
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and ctime >=?", orgId, startTime)
+		})
+		db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1 and ctime>=?", orgId, startTime)
+		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and sys_record_time>=?", orgId, startTime)
+		})
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1 and ctime>=?", orgId, startTime)
+	} else {
+
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+		db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1", orgId)
+		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1", orgId)
+	}
+
+	if endTime > 0 {
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and ctime>=? and ctime <=?", orgId, startTime, endTime)
+		})
+		db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1 and ctime>=? and ctime<=?", orgId, startTime, endTime)
+		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and sys_record_time<=?", orgId, endTime)
+		})
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1 and ctime >=? and ctime<=?", orgId, startTime, endTime)
+	} else {
+
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+		db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1", orgId)
+		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1", orgId)
+	}
+
 	if len(keyword) > 0 {
 		likeKey := "%" + keyword + "%"
 		db = db.Where("xt_base_drug.drug_name LIKE ? OR xt_base_drug.drug_spec LIKE ?", likeKey, likeKey)

service/manage_service.go

@@ -901,7 +901,7 @@ func GetTimeLastData(equitid int64, orgId int64) (models.DeviceInformation, erro
 }
 
 func GetAllpatient(orgid int64) (patients []*models.Patients, err error) {
-	err = XTReadDB().Where("user_org_id = ?", orgid).Find(&patients).Error
+	err = XTReadDB().Where("user_org_id = ? and status = 1", orgid).Find(&patients).Error
 	return patients, err
 }
 

service/mobile_dialysis_service.go

@@ -777,7 +777,7 @@ func (MDoctorAdviceVM) TableName() string {
 	return "xt_doctor_advice"
 }
 
-func MobileGetScheduleDoctorAdvices(orgID int64, scheduleDate int64, adviceType int, patientType int, adminUserId int64) ([]*MScheduleDoctorAdviceVM, error) {
+func MobileGetScheduleDoctorAdvices(orgID int64, scheduleDate int64, adviceType int, patientType int, adminUserId int64, deliverWay string) ([]*MScheduleDoctorAdviceVM, error) {
 	var vms []*MScheduleDoctorAdviceVM
 	adviceWhere := ""
 	fmt.Println("advicetype", adviceType)
@@ -826,13 +826,26 @@ func MobileGetScheduleDoctorAdvices(orgID int64, scheduleDate int64, adviceType
 			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate)
 		}
 
-	} else if adviceType == 2 {
+	} else if adviceType == 2 && len(deliverWay) > 0 {
 		if patientType == 0 {
-			adviceWhere = "status = 1 AND user_org_id = ? AND advice_type = 2 AND record_date = ?  "
+			adviceWhere = "status = 1 AND user_org_id = ? AND advice_type = 2 AND record_date = ? and delivery_way = ?"
+			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate, deliverWay)
+
+		} else if patientType == 1 {
+			adviceWhere = "status = 1 AND user_org_id = ? AND record_date = ? AND advice_type = 2 AND advice_doctor = ?  and delivery_way = ? "
+			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate, adminUserId, deliverWay)
+		} else if patientType == 2 {
+			adviceWhere = "status = 1 AND user_org_id = ? AND record_date = ? AND advice_type = 2  AND execution_staff = 0 and delivery_way = ?"
+			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate, deliverWay)
+		}
+
+	} else if adviceType == 2 && len(deliverWay) <= 0 {
+		if patientType == 0 {
+			adviceWhere = "status = 1 AND user_org_id = ? AND advice_type = 2 AND record_date = ?"
 			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate)
 
 		} else if patientType == 1 {
-			adviceWhere = "status = 1 AND user_org_id = ? AND record_date = ? AND advice_type = 2 AND advice_doctor = ? "
+			adviceWhere = "status = 1 AND user_org_id = ? AND record_date = ? AND advice_type = 2 AND advice_doctor = ?"
 			adviceCondition = append(adviceCondition, adviceWhere, orgID, scheduleDate, adminUserId)
 		} else if patientType == 2 {
 			adviceWhere = "status = 1 AND user_org_id = ? AND record_date = ? AND advice_type = 2  AND execution_staff = 0"
@@ -860,26 +873,43 @@ func MobileGetScheduleDoctorAdvices(orgID int64, scheduleDate int64, adviceType
 	return vms, err
 }
 
-func GetHisDoctorAdvices(orgID int64, scheduleDate int64) ([]*HisMScheduleDoctorAdviceVM, error) {
+func GetHisDoctorAdvices(orgID int64, scheduleDate int64, deliverWay string) ([]*HisMScheduleDoctorAdviceVM, error) {
 
 	var vms []*HisMScheduleDoctorAdviceVM
-
-	db := readDb.
-		Table("xt_schedule").
-		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-			return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-		}).
-		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-		Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ?", orgID, scheduleDate).
-		Where("status = 1 AND user_org_id = ?", orgID)
-	if scheduleDate != 0 {
-		db = db.Where("schedule_date = ?", scheduleDate)
+	if len(deliverWay) > 0 {
+		db := readDb.
+			Table("xt_schedule").
+			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+				return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+			}).
+			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+			Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ? and delivery_way = ?", orgID, scheduleDate, deliverWay).
+			Where("status = 1 AND user_org_id = ?", orgID)
+		if scheduleDate != 0 {
+			db = db.Where("schedule_date = ?", scheduleDate)
+		}
+		err = db.Find(&vms).Error
+	} else {
+		db := readDb.
+			Table("xt_schedule").
+			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+				return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+			}).
+			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+			Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ?", orgID, scheduleDate).
+			Where("status = 1 AND user_org_id = ?", orgID)
+		if scheduleDate != 0 {
+			db = db.Where("schedule_date = ?", scheduleDate)
+		}
+		err = db.Find(&vms).Error
 	}
 
-	err := db.Find(&vms).Error
 	return vms, err
 }
 
@@ -1499,7 +1529,7 @@ func MobileGetDialysisGoods(orgID int64, scheduleDate int64, schedule_type int64
 			return db.Preload("VMGoodInfo", "status = 1 AND org_id = ?", orgID).Preload("GoodsType", "status = 1 AND (org_id = ? OR org_id = 0) ", orgID).Where("status = 1 AND user_org_id = ? AND record_date = ?  AND count > 0 ", orgID, scheduleDate)
 		}).
 		Preload("AutomaticReduceDetail", func(db *gorm.DB) *gorm.DB {
-			return db.Preload("VMGoodInfo", "status = 1 AND org_id = ? ", orgID).Preload("GoodsType", "status = 1 AND (org_id = ? OR org_id = 0)  ", orgID).Where("status = 1 AND org_id = ? AND count > 0 AND record_time >= ? AND record_time <= ?  ", orgID, scheduleDate, end_time)
+			return db.Preload("VMGoodInfo", "status = 1 AND org_id = ? ", orgID).Preload("GoodsType", "status = 1 AND (org_id = ? OR org_id = 0)  ", orgID).Where("status = 1 AND org_id = ? AND count > 0 AND record_time >= ? AND record_time <= ?  ", orgID, scheduleDate, end_time).Group("patient_id,good_id")
 		}).Where("sch.status = 1 AND sch.user_org_id = ?", orgID)
 	if scheduleDate != 0 {
 		db = db.Where("schedule_date = ?", scheduleDate)
@@ -1680,3 +1710,19 @@ func GetHisDoctorConfig(orgid int64) (models.XtHisConfig, error) {
 	err := XTReadDB().Model(&config).Where("user_org_id = ? and status =1", orgid).Find(&config).Error
 	return config, err
 }
+
+func GetHisDoctorPatientById(orgid int64, patientid int64, recordtime int64) (advice []*models.HisDoctorAdviceInfo, err error) {
+
+	db := XTReadDB().Table("his_doctor_advice_info as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if patientid > 0 {
+		db = db.Where("x.patient_id =?", patientid)
+	}
+	if recordtime > 0 {
+		db = db.Where("x.advice_date = ?", recordtime)
+	}
+	err = db.Select("x.id,x.user_org_id,x.patient_id,x.his_patient_id,x.advice_type,x.advice_date,x.start_time,x.advice_name,x.advice_desc,x.reminder_date,x.single_dose,x.single_dose_unit,x.single_dose_unit,x.prescribing_number_unit,x.prescribing_number,x.delivery_way,x.execution_frequency,x.advice_doctor,x.status,x.advice_affirm,x.remark,x.stop_time,x.stop_reason,x.stop_doctor,x.stop_state,x.parent_id,x.execution_time,x.execution_staff,x.checker,x.record_date,x.dialysis_order_id,x.check_time,x.check_state,x.drug_spec,x.drug_spec_unit,x.groupno,x.remind_type,x.frequency_type,x.day_count,x.week_day,x.template_id,x.modifier,x.drug_id,x.price,x.prescription_id,x.med_list_codg,x.feedetl_sn,x.day").Find(&advice).Error
+	return advice, err
+}

service/patient_service.go

@@ -82,9 +82,9 @@ func GetAllPatientList(orgID int64) (patients []*models.Patients, total int64, e
 
 func GetPatientListByUpdateTime(orgID int64, syncTime int64) (patients []*models.PatientListForFaceList, total int64, err error) {
 	db := readDb.Model(&models.PatientListForFaceList{}).Where("user_org_id=?  AND  status=1  AND  avatar <> 'https://images.shengws.com/201809182128222.png' AND avatar <> 'https://images.shengws.com/201809182128111.png' AND avatar <> ''", orgID)
-	
-		db = db.Where("updated_time >= ?", syncTime)
-	
+
+	db = db.Where("updated_time >= ?", syncTime)
+
 	err = db.Count(&total).Find(&patients).Error
 	return
 }
@@ -1013,28 +1013,58 @@ func GetPatientScheduleList(orgID int64, patientID int64, page int64, limit int6
 	return
 }
 
-func GetMonitorRecord(orgID int64, date int64, partition int64) ([]*models.NewVMMonitorDialysisSchedule, error) {
+func GetMonitorRecord(orgID int64, date int64, partition int64, patientId int64) ([]*models.NewVMMonitorDialysisSchedule, error) {
 	var mds []*models.NewVMMonitorDialysisSchedule
-	db := readDb.
-		Model(&models.NewVMMonitorDialysisSchedule{}).
-		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-		Preload("DeviceZone", "status = 1 AND org_id = ?", orgID).
-		Preload("TreatmentMode", "status = 1").
-		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, date).
-		Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ?", orgID, date).
-		Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ? ", orgID, date).
-		Preload("MonitoringRecord", "status = 1 AND  user_org_id = ? AND monitoring_date = ?", orgID, date).
-		Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, date).
-		Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
-		Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
-		Where("status = 1 AND user_org_id = ?", orgID)
-	if date != 0 {
-		db = db.Where("schedule_date = ? ", date)
-	}
-	if partition != 0 {
-		db = db.Where("partition_id = ? ", partition)
+
+	if patientId == 0 {
+		db := readDb.
+			Model(&models.NewVMMonitorDialysisSchedule{}).
+			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+			Preload("DeviceZone", "status = 1 AND org_id = ?", orgID).
+			Preload("TreatmentMode", "status = 1").
+			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, date).
+			Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ?", orgID, date).
+			Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ? ", orgID, date).
+			Preload("MonitoringRecord", "status = 1 AND  user_org_id = ? AND monitoring_date = ?", orgID, date).
+			Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, date).
+			Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
+			Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
+			Where("status = 1 AND user_org_id = ?", orgID)
+		if date != 0 {
+			db = db.Where("schedule_date = ? ", date)
+		}
+		if partition != 0 {
+			db = db.Where("partition_id = ? ", partition)
+		}
+		err := db.Find(&mds).Error
+		fmt.Println("err", err)
+	}
+
+	if patientId > 0 {
+		db := readDb.Table("xt_schedule as x").Where("x.status = 1")
+		db = db.
+			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+			Preload("TreatmentMode", "status = 1").
+			Preload("Prescription", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
+			Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ?", orgID, patientId).
+			Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ? ", orgID, patientId).
+			Preload("MonitoringRecord", "status = 1 AND  user_org_id = ?  AND patient_id = ?", orgID, patientId).
+			Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
+			Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
+			Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
+			Where("status = 1 AND user_org_id = ?", orgID)
+		if partition != 0 {
+			db = db.Where("partition_id = ? ", partition)
+		}
+
+		db = db.Where("schedule_date <= ? ", time.Now().Unix())
+
+		db = db.Where("patient_id = ?", patientId)
+		db = db.Order("schedule_date desc")
+		err := db.Find(&mds).Error
+		fmt.Println("err", err)
 	}
-	err := db.Find(&mds).Error
+
 	return mds, err
 }
 
@@ -1424,3 +1454,16 @@ func CreateHisGroupAdvice(orgId int64, advices []*models.HisGroupAdvice, groupNo
 	tx.Commit()
 	return
 }
+
+func GetDialysisCount(orgid int64, partitionid int64) (order []*models.BloodDialysisOrderCount, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_order as o")
+	if partitionid == 0 {
+		db.Raw("select count(o.id) as count,o.patient_id from xt_dialysis_order as o left join xt_schedule as x on x.patient_id = o.patient_id where o.status =1 and o.user_org_id = ? and  x.schedule_date = o.dialysis_date and x.status = 1", orgid).Group("o.patient_id").Scan(&order)
+	}
+
+	if partitionid > 0 {
+		db.Raw("select count(o.id) as count,o.patient_id from xt_dialysis_order as o left join xt_schedule as x on x.patient_id = o.patient_id where o.status =1  and o.user_org_id = ? and x.partition_id = ? and  x.schedule_date = o.dialysis_date and x.status = 1", orgid, partitionid).Group("o.patient_id").Scan(&order)
+	}
+	return order, err
+}

service/stock_service.go

@@ -1155,11 +1155,20 @@ func FindAllStockInfo(orgId int64, page int64, limit int64, keyword string, star
 
 	db := readDb.Model(&models.StockInfo{})
 	if startime > 0 {
+
 		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
 			return db.Where("org_id = ? AND status = 1 and sys_record_time>=?", orgId, startime)
 		})
 	}
+
+	if startime == 0 || endtime == 0 {
+		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+	}
+
 	if endtime > 0 {
+
 		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
 			return db.Where("org_id = ? AND status = 1 and sys_record_time<=?", orgId, endtime)
 		})
@@ -1167,19 +1176,36 @@ func FindAllStockInfo(orgId int64, page int64, limit int64, keyword string, star
 
 	db = db.Where("xt_good_information.org_id = ? AND xt_good_information.status = 1", orgId)
 	db = db.Group("xt_good_information.id")
-	db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
-		return db.Where("org_id = ? AND status = 1", orgId)
-	})
+	if startime == 0 || endtime == 0 {
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1", orgId)
+		})
+	}
+
+	if startime > 0 {
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and ctime >= ?", orgId, startime)
+		})
+	}
+
+	if endtime > 0 {
+		db = db.Preload("QueryWarehousingInfo", func(db *gorm.DB) *gorm.DB {
+			return db.Where("org_id = ? AND status = 1 and ctime>=? and ctime <= ?", orgId, startime, endtime)
+		})
+	}
 
 	db = db.Preload("QuerySalesReturnInfo", "org_id = ? AND status = 1", orgId)
 
 	if startime == 0 || endtime == 0 {
-		db = db.Preload("QueryWarehouseOutInfo", func(db *gorm.DB) *gorm.DB {
-			return db.Where("org_id = ? AND status = 1", orgId)
-		})
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1", orgId)
+	}
+	if startime > 0 {
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1 and ctime >=?", orgId, startime)
+	}
+	if endtime > 0 {
+		db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1 and ctime >=? and ctime<=?", orgId, startime, endtime)
 	}
 
-	db = db.Preload("QueryCancelStockInfo", "org_id = ? AND status = 1", orgId)
 	db = db.Preload("GoodsType", "org_id = ? AND status = 1", orgId)
 
 	if len(keyword) > 0 {
@@ -2098,3 +2124,42 @@ func GetStockType(orgid int64) (goodstype []*models.GoodsTypeOne, err error) {
 		Preload("GoodInfo", "org_id = ? and status = 1", orgid).Find(&goodstype).Error
 	return goodstype, err
 }
+
+func GetDialyStockOut(orgid int64, recordtime int64, patientId int64) (prepare []*models.XtDialysisBeforePrepare, err error) {
+
+	db := XTReadDB().Table("dialysis_before_prepare as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if recordtime > 0 {
+		db = db.Where("x.record_date = ?", recordtime)
+	}
+	if patientId > 0 {
+		db = db.Where("x.patient_id = ?", patientId)
+	}
+	err = db.Select("x.id,x.user_org_id,x.patient_id,x.record_date,x.good_id,x.good_type_id,x.count,x.commdity_code,t.specification_name").Joins("left join xt_good_information as t on t.id = x.good_id and t.org_id = ? and t.status = 1", orgid).Scan(&prepare).Error
+	return prepare, err
+}
+
+func GetAutoReduceRecordInfoById(orgid int64, recordtime int64, goodid int64, goodtypeid int64) (*models.XtAutomaticReduceDetail, error) {
+
+	detail := models.XtAutomaticReduceDetail{}
+	err := XTReadDB().Model(&detail).Where("org_id = ? and record_time = ? and good_id = ? and good_type_id = ? and status =1", orgid, recordtime, goodid, goodtypeid).Find(&detail).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &detail, nil
+}
+
+func GetOutStockTotalCount(wareouttime int64, orgid int64) (autoMatic []*models.NewXtAutomaticReduceDetail, err error) {
+
+	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time = ? and `status` = 1)  as b GROUP BY good_id", orgid, wareouttime).Scan(&autoMatic).Error
+
+	return autoMatic, err
+
+}