透析参数

controllers/dialysis_parameter_api_controller.go

@@ -94,6 +94,8 @@ func (this *DialysisPrameterApiController) GetDialysisParameters() {
 }
 
 func (this *DialysisPrameterApiController) GetDialysisBatchParameters() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
 	adminUser := this.GetAdminUserInfo()
 	orgId := adminUser.CurrentOrgId
 	schIDStr := this.GetString("ids")
@@ -102,11 +104,40 @@ func (this *DialysisPrameterApiController) GetDialysisBatchParameters() {
 		return
 	}
 	idStrs := strings.Split(schIDStr, ",")
-
+	startime := this.GetString("startime")
+	theTime, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
 	parameters, err := service.GetDialysisBatchParameters(idStrs, orgId)
+	var vlist []interface{}
+	var elist []interface{}
+	for _, item := range parameters {
+		//查询当前日期的病人是否存在数据
+		_, errcode := service.GetToDayDialysisPrescription(item.PatientId, orgId, theTime.Unix())
+		if errcode == gorm.ErrRecordNotFound {
+			//查询每个病人透析处方的最后一次数据
+			prescription, _ := service.GetLastDialysisPrescription(item.PatientId, orgId)
+			vlist = append(vlist, prescription)
+		} else if errcode == nil {
+			//获取当前日期
+			prescription, _ := service.GetDialysisPrescriptionList(item.PatientId, orgId, theTime.Unix())
+			vlist = append(vlist, prescription)
+		}
+
+		_, errcodes := service.GetTodayAssessmentBeforDialysis(item.PatientId, orgId, theTime.Unix())
+		if errcodes == gorm.ErrRecordNotFound {
+			//查询每个病人透前评估的最后一次数据
+			dialysis, _ := service.GetLastAssessmentBeforDialysis(item.PatientId, orgId)
+			elist = append(elist, dialysis)
+		} else if errcodes == nil {
+			dialysis, _ := service.GetAssessmentBeforDialysisByStartime(item.PatientId, orgId, theTime.Unix())
+			elist = append(elist, dialysis)
+		}
+
+	}
 	if err == nil {
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule": parameters,
+			"schedule":     parameters,
+			"prescription": vlist,
+			"dialysbefor":  elist,
 		})
 	}
 }
@@ -171,9 +202,10 @@ func (this *DialysisPrameterApiController) GetCollectList() {
 
 	//查询今日排班的病人
 	patient, err := service.GetDialysisTodaySchedulePatient(orgId, startime.Unix(), page, limit)
-
 	var vlist []interface{}
+	var clist []interface{}
 	for _, item := range patient {
+		fmt.Println("---------", item.PatientId)
 		//查询当前日期的病人是否存在数据
 		_, errcode := service.GetToDayDialysisPrescription(item.PatientId, orgId, startime.Unix())
 		if errcode == gorm.ErrRecordNotFound {
@@ -186,15 +218,27 @@ func (this *DialysisPrameterApiController) GetCollectList() {
 			vlist = append(vlist, prescription)
 		}
 
+		//查询每个病人当前日期是否存在数据
+		_, errco := service.GetAotoMaticReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+		fmt.Println("errco--------------------------", errco)
+		if errco == gorm.ErrRecordNotFound {
+			reduece, _ := service.GetMaticReduece(item.PatientId, orgId)
+			clist = append(clist, reduece)
+		} else if errco == nil {
+			reduece, _ := service.GetMaticeReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+			clist = append(clist, reduece)
+		}
 	}
 	//获取透析耗材数据
 	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
+
 	if err == nil {
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule":    schedule,
-			"total":       total,
-			"consumables": consumables,
-			"prescrption": vlist,
+			"schedule":     schedule,
+			"total":        total,
+			"consumables":  consumables,
+			"prescription": vlist,
+			"reducelist":   clist,
 		})
 	}
 }
@@ -211,17 +255,47 @@ func (this *DialysisPrameterApiController) GetBatchCollection() {
 	schIDStr := this.GetString("ids")
 	//获取透析耗材数据
 	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
+
 	if len(schIDStr) == 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
 	idStrs := strings.Split(schIDStr, ",")
 	fmt.Println(idStrs)
+	var vlist []interface{}
+	var clist []interface{}
 	schedule, err := service.GetBatchCollection(orgId, idStrs)
+	for _, item := range schedule {
+		//查询当前日期的病人是否存在数据
+		_, errcode := service.GetToDayDialysisPrescription(item.PatientId, orgId, startime.Unix())
+		if errcode == gorm.ErrRecordNotFound {
+			//查询每个病人透析处方的最后一次数据
+			prescription, _ := service.GetLastDialysisPrescription(item.PatientId, orgId)
+			vlist = append(vlist, prescription)
+		} else if errcode == nil {
+			//获取当前日期
+			prescription, _ := service.GetDialysisPrescriptionList(item.PatientId, orgId, startime.Unix())
+			vlist = append(vlist, prescription)
+		}
+
+		//查询每个病人当前日期是否存在数据
+		_, errco := service.GetAotoMaticReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+		fmt.Println("errco", errco)
+		if errco == gorm.ErrRecordNotFound {
+			reduece, _ := service.GetMaticReduece(item.PatientId, orgId)
+			clist = append(clist, reduece)
+		} else if errco == nil {
+			reduece, _ := service.GetMaticeReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+			clist = append(clist, reduece)
+		}
+
+	}
 	if err == nil {
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule":    schedule,
-			"consumables": consumables,
+			"schedule":     schedule,
+			"consumables":  consumables,
+			"prescripiton": vlist,
+			"reducelist":   clist,
 		})
 	}
 }
@@ -247,7 +321,7 @@ func (this *DialysisPrameterApiController) GetGatherList() {
 
 	//统计抗凝剂数据
 	count, err := service.GetAnticoagulantCount(startime.Unix(), endtime.Unix(), orgId)
-	fmt.Println("er--------------------------------------", count)
+
 	if err == nil {
 		this.ServeSuccessJSON(map[string]interface{}{
 			"warehouselist": warehouselist,

controllers/new_mobile_api_controllers/dialysis_parameter_api_controller.go

@@ -5,6 +5,7 @@ import (
 	"XT_New/enums"
 	"XT_New/service"
 	"fmt"
+	"github.com/jinzhu/gorm"
 	"time"
 )
 
@@ -55,10 +56,40 @@ func (this *DialysisParamerterApiController) GetMobileDialysisParameters() {
 		}
 	} else {
 		dialysisSchedule, err, total := service.GetDialysisParameter(orgid, theTime.Unix(), scheduleType, partitionType, page, limit)
+		//查询今日排班的病人
+		patient, err := service.GetDialysisTodaySchedulePatient(orgid, theTime.Unix(), page, limit)
+		var vlist []interface{}
+		var elist []interface{}
+		for _, item := range patient {
+			//查询当前日期的病人是否存在数据
+			_, errcode := service.GetToDayDialysisPrescription(item.PatientId, orgid, theTime.Unix())
+			if errcode == gorm.ErrRecordNotFound {
+				//查询每个病人透析处方的最后一次数据
+				prescription, _ := service.GetLastDialysisPrescription(item.PatientId, orgid)
+				vlist = append(vlist, prescription)
+			} else if errcode == nil {
+				//获取当前日期
+				prescription, _ := service.GetDialysisPrescriptionList(item.PatientId, orgid, theTime.Unix())
+				vlist = append(vlist, prescription)
+			}
+
+			_, errcodes := service.GetTodayAssessmentBeforDialysis(item.PatientId, orgid, theTime.Unix())
+			if errcodes == gorm.ErrRecordNotFound {
+				//查询每个病人透前评估的最后一次数据
+				dialysis, _ := service.GetLastAssessmentBeforDialysis(item.PatientId, orgid)
+				elist = append(elist, dialysis)
+			} else if errcodes == nil {
+				dialysis, _ := service.GetAssessmentBeforDialysisByStartime(item.PatientId, orgid, theTime.Unix())
+				elist = append(elist, dialysis)
+			}
+
+		}
 		if err == nil {
 			this.ServeSuccessJSON(map[string]interface{}{
-				"schedule": dialysisSchedule,
-				"total":    total,
+				"schedule":     dialysisSchedule,
+				"total":        total,
+				"prescription": vlist,
+				"dialysbefor":  elist,
 			})
 		} else {
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
@@ -123,13 +154,72 @@ func (this *DialysisParamerterApiController) GetMobileCollectList() {
 	keyword := this.GetString("keyword")
 	//获取透析参数数据
 	schedule, err, total := service.GetCollectList(limit, page, partitiontype, scheduletype, startime.Unix(), orgId, keyword)
+	//查询今日排班的病人
+	patient, err := service.GetDialysisTodaySchedulePatient(orgId, startime.Unix(), page, limit)
+	var vlist []interface{}
+	var clist []interface{}
+	for _, item := range patient {
+
+		//查询当前日期的病人是否存在数据
+		_, errcode := service.GetToDayDialysisPrescription(item.PatientId, orgId, startime.Unix())
+		if errcode == gorm.ErrRecordNotFound {
+			//查询每个病人透析处方的最后一次数据
+			prescription, _ := service.GetLastDialysisPrescription(item.PatientId, orgId)
+			vlist = append(vlist, prescription)
+		} else if errcode == nil {
+			//获取当前日期
+			prescription, _ := service.GetDialysisPrescriptionList(item.PatientId, orgId, startime.Unix())
+			vlist = append(vlist, prescription)
+		}
+
+		//查询每个病人当前日期是否存在数据
+		_, errco := service.GetAotoMaticReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+		if errco == gorm.ErrRecordNotFound {
+			reduece, _ := service.GetMaticReduece(item.PatientId, orgId)
+			clist = append(clist, reduece)
+		} else if errco == nil {
+			reduece, _ := service.GetMaticeReduceByPatientId(item.PatientId, orgId, startime.Unix(), endtime.Unix())
+			clist = append(clist, reduece)
+		}
+	}
+	//获取透析耗材数据
+	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
+	if err == nil {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"schedule":     schedule,
+			"total":        total,
+			"consumables":  consumables,
+			"prescription": vlist,
+			"reducelist":   clist,
+		})
+	}
+}
+
+func (this *DialysisParamerterApiController) GetMobileGatherList() {
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgId := adminUserInfo.Org.Id
+	fmt.Println("开始时间", startime)
+	fmt.Println("结束时间", endtime)
+	warehouselist, err := service.GetWareHouseOutList(startime.Unix(), endtime.Unix(), orgId)
+
 	//获取透析耗材数据
 	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
+
+	//统计抗凝剂数据
+	count, err := service.GetAnticoagulantCount(startime.Unix(), endtime.Unix(), orgId)
+
 	if err == nil {
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule":    schedule,
-			"total":       total,
-			"consumables": consumables,
+			"warehouselist": warehouselist,
+			"consumables":   consumables,
+			"count":         count,
 		})
 	}
 }

controllers/new_mobile_api_controllers/dialysis_parameter_api_router.go

@@ -11,4 +11,5 @@ func DialysisParameterApiControllersRegisterRouters() {
 	beego.Router("/m/api/getmobilewarehouseoutlist", &DialysisParamerterApiController{}, "Get:GetMobileWareHouseOutList")
 	beego.Router("/m/api/getallmobilematerial", &DialysisParamerterApiController{}, "Get:GetAllMobileMaterial")
 	beego.Router("/m/api/getmobilecollectlist", &DialysisParamerterApiController{}, "Get:GetMobileCollectList")
+	beego.Router("/m/api/getmobilegatherlist", &DialysisParamerterApiController{}, "Get:GetMobileGatherList")
 }

models/dialysis_parameter_models.go

@@ -81,3 +81,22 @@ type DialysisPrescriptionCount struct {
 	RecordDate    int64 `gorm:"column:record_date" json:"record_date" form:"record_date"`
 	Anticoagulant int64 `gorm:"column:anticoagulant" json:"anticoagulant" form:"anticoagulant"`
 }
+
+type BloodAutomaticReduceDetail struct {
+	ID                      int64  `gorm:"column:id" json:"id" form:"id"`
+	WarehouseOutId          int64  `gorm:"column:warehouse_out_id" json:"warehouse_out_id" form:"warehouse_out_id"`
+	WarehouseOutOrderNumber string `gorm:"column:warehouse_out_order_number" json:"warehouse_out_order_number" form:"warehouse_out_order_number"`
+	PatientId               int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Ctime                   int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime                   int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status                  int64  `gorm:"column:status" json:"status" form:"status"`
+	RecordTime              int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	OrgId                   int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	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"`
+}
+
+func (BloodAutomaticReduceDetail) TableName() string {
+	return "xt_automatic_reduce_detail"
+}

service/dialysis_parameter_service.go

@@ -178,7 +178,7 @@ func GetDialysisConsumables(startime int64, endtime int64, orgid int64) (reduced
 	if orgid > 0 {
 		db = db.Where("x.org_id =?", orgid)
 	}
-	err = db.Select("x.patient_id,f.count,x.good_id,x.good_type_id,t.specification_name,s.type_name").Joins("left join xt_good_information as t on t.id = x.good_id").Where("t.org_id = ? and t.status = 1", orgid).Joins("left join xt_goods_type as s on s.id = x.good_type_id").Joins("left join xt_warehouse_out_info as f on f.id = x.warehouse_out_id").Scan(&reducedetail).Error
+	err = db.Select("x.patient_id,x.count,x.good_id,x.good_type_id,t.specification_name,s.type_name").Joins("left join xt_good_information as t on t.id = x.good_id").Where("t.org_id = ? and t.status = 1", orgid).Joins("left join xt_goods_type as s on s.id = x.good_type_id").Joins("left join xt_warehouse_out_info as f on f.id = x.warehouse_out_id").Scan(&reducedetail).Error
 	return reducedetail, err
 }
 
@@ -204,7 +204,7 @@ func GetAnticoagulantCount(startime int64, endtime int64, orgid int64) (prescrip
 
 	db := XTReadDB().Table("xt_dialysis_prescription as x").Where("x.status = 1")
 	if orgid > 0 {
-		db = db.Where("x.user_org_id = ?", orgid)
+		db = db.Where("x.user_org_id = ? and x.anticoagulant <> 0", orgid)
 	}
 	if startime > 0 {
 		db = db.Where("x.record_date >= ?", startime)
@@ -274,3 +274,31 @@ func GetAssessmentBeforDialysisByStartime(patientid int64, orgid int64, startime
 	err := XTReadDB().Model(&evaluation).Where("patient_id = ? and user_org_id = ? and assessment_date = ? and status = 1", patientid, orgid, startime).Find(&evaluation).Error
 	return evaluation, err
 }
+
+func GetAotoMaticReduceByPatientId(patientid int64, orgid int64, startime int64, endtime int64) (*models.BloodAutomaticReduceDetail, error) {
+
+	detail := models.BloodAutomaticReduceDetail{}
+	err := XTReadDB().Model(&detail).Where("patient_id = ? and org_id =? and record_time >=? and record_time <=? and status = 1", patientid, orgid, startime, endtime).Find(&detail).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &detail, nil
+}
+
+func GetMaticReduece(patientid int64, orgid int64) (models.BloodAutomaticReduceDetail, error) {
+
+	detail := models.BloodAutomaticReduceDetail{}
+	err := XTReadDB().Model(&detail).Where("patient_id = ? and org_id= ?  and status = 1", patientid, orgid).Last(&detail).Error
+
+	return detail, err
+}
+
+func GetMaticeReduceByPatientId(patientid int64, orgid int64, startime int64, endtime int64) (models.BloodAutomaticReduceDetail, error) {
+
+	detail := models.BloodAutomaticReduceDetail{}
+	err := XTReadDB().Model(&detail).Where("patient_id = ? and org_id = ? and record_time >=? and record_time<=? and status =1", patientid, orgid, startime, endtime).Find(&detail).Error
+	return detail, err
+}