耗材参数

controllers/dialysis_parameter_api_controller.go

@@ -22,6 +22,7 @@ func DialysisPrameteRoutes() {
 	beego.Router("/api/dialysis/getcollectlist", &DialysisPrameterApiController{}, "Get:GetCollectList")
 	beego.Router("/api/dialysis/getbatchcollection", &DialysisPrameterApiController{}, "Get:GetBatchCollection")
 	beego.Router("/api/dialysis/getgatherlist", &DialysisPrameterApiController{}, "Get:GetGatherList")
+	beego.Router("/api/dialysis/getanticoagulantcount", &DialysisPrameterApiController{}, "Get:GetAnticoagulantCount")
 }
 
 func (this *DialysisPrameterApiController) GetDialysisParameters() {
@@ -194,11 +195,12 @@ func (this *DialysisPrameterApiController) GetCollectList() {
 	start_time := this.GetString("start_time")
 	fmt.Println(start_time)
 	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	fmt.Println("startime", startime.Unix())
 	orgId := this.GetAdminUserInfo().CurrentOrgId
 	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 23:59:59", loc)
 	keyword := this.GetString("keyword")
 	//获取透析参数数据
-	schedule, err, total := service.GetCollectList(limit, page, partitiontype, scheduletype, startime.Unix(), orgId, keyword)
+	schedule, err, _ := service.GetCollectList(limit, page, partitiontype, scheduletype, startime.Unix(), orgId, keyword)
 
 	//查询今日排班的病人
 	patient, err := service.GetDialysisTodaySchedulePatient(orgId, startime.Unix(), page, limit)
@@ -232,15 +234,76 @@ func (this *DialysisPrameterApiController) GetCollectList() {
 	//获取透析耗材数据
 	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
 
-	if err == nil {
+	//if err == nil {
+	// this.ServeSuccessJSON(map[string]interface{}{
+	//   "schedule":     schedule,
+	//   "total":        total,
+	//   "consumables":  consumables,
+	//   "prescription": vlist,
+	//   "reducelist":   clist,
+	// })
+	//}
+
+	_, errors := service.FindStockOutByIsSys(orgId, 1, startime.Unix())
+
+	goodTypes, _ := service.FindAllGoodType(orgId) //two, err, i := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+
+	if errors == gorm.ErrRecordNotFound {
+
+		dialysisGoods, _, total := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+		for _, item := range dialysisGoods { //获取当天排班的每个患者的最后日期的库存使用情况
+
+			goodUser, _ := service.GetLastDialysisGoods(item.PatientId, orgId, startime.Unix())
+			lastGoodUserDetial, _ := service.GetLastDialysisBeforePrepare(item.PatientId, orgId, startime.Unix())
+			item.LastAutomaticReduceDetail = goodUser
+			item.LastDialysisBeforePrepare = lastGoodUserDetial
+		}
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule":     schedule,
-			"total":        total,
-			"consumables":  consumables,
-			"prescription": vlist,
-			"reducelist":   clist,
+			"dialysis_goods": dialysisGoods,
+			"good_type":      goodTypes,
+			"total":          total,
+			"schedule":       schedule,
+			"consumables":    consumables,
+			"prescription":   vlist,
+			"reducelist":     clist,
 		})
+		return
+
+	} else if err == nil {
+		//获取当天排班的每个患者的库存使用情况
+		dialysisGoods, err, total := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+		for _, item := range dialysisGoods { //获取当天排班的每个患者的最后日期的库存使用情况
+			goodUser, _ := service.GetLastDialysisGoods(item.PatientId, orgId, startime.Unix())
+			lastGoodUserDetial, _ := service.GetLastDialysisBeforePrepare(item.PatientId, orgId, startime.Unix())
+
+			fmt.Println(goodUser)
+			fmt.Println(lastGoodUserDetial)
+
+			item.LastAutomaticReduceDetail = goodUser
+			item.LastDialysisBeforePrepare = lastGoodUserDetial
+		}
+		if err == nil {
+			this.ServeSuccessJSON(map[string]interface{}{
+				"dialysis_goods": dialysisGoods,
+				"good_type":      goodTypes,
+				"total":          total,
+				"schedule":       schedule,
+				"consumables":    consumables,
+				"prescription":   vlist,
+				"reducelist":     clist,
+			})
+			return
+
+		} else {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+	} else if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+
 	}
+
 }
 
 func (this *DialysisPrameterApiController) GetBatchCollection() {
@@ -330,3 +393,24 @@ func (this *DialysisPrameterApiController) GetGatherList() {
 		})
 	}
 }
+
+func (this *DialysisPrameterApiController) GetAnticoagulantCount() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	fmt.Println(orgId)
+	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)
+	fmt.Println("开始时间2222", startime)
+	fmt.Println("结束时间3333", endtime)
+	//统计抗凝剂数据
+	count, err := service.GetAnticoagulantCount(startime.Unix(), endtime.Unix(), orgId)
+	if err == nil {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"count": count,
+		})
+	}
+}

controllers/mobile_api_controllers/login_api_controller.go

@@ -33,8 +33,8 @@ func (this *LoginAPIController) LoginByPwd() {
 		return
 	}
 	ip := utils.GetIP(this.Ctx.Request)
-	//ssoDomain := beego.AppConfig.String("sso_domain")
-	ssoDomain := "http://localhost:8091"
+	ssoDomain := beego.AppConfig.String("sso_domain")
+	//ssoDomain := "http://localhost:8091"
 	api := ssoDomain + "/m/login/pwd"
 	values := make(url.Values)
 	values.Set("mobile", mobile)

controllers/new_mobile_api_controllers/dialysis_parameter_api_controller.go

@@ -153,7 +153,7 @@ func (this *DialysisParamerterApiController) GetMobileCollectList() {
 	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 23:59:59", loc)
 	keyword := this.GetString("keyword")
 	//获取透析参数数据
-	schedule, err, total := service.GetCollectList(limit, page, partitiontype, scheduletype, startime.Unix(), orgId, keyword)
+	schedule, err, _ := service.GetCollectList(limit, page, partitiontype, scheduletype, startime.Unix(), orgId, keyword)
 	//查询今日排班的病人
 	patient, err := service.GetDialysisTodaySchedulePatient(orgId, startime.Unix(), page, limit)
 	var vlist []interface{}
@@ -184,15 +184,75 @@ func (this *DialysisParamerterApiController) GetMobileCollectList() {
 	}
 	//获取透析耗材数据
 	consumables, err := service.GetDialysisConsumables(startime.Unix(), endtime.Unix(), orgId)
-	if err == nil {
+
+	_, errors := service.FindStockOutByIsSys(orgId, 1, startime.Unix())
+
+	goodTypes, _ := service.FindAllGoodType(orgId) //two, err, i := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+
+	if errors == gorm.ErrRecordNotFound {
+
+		dialysisGoods, _, total := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+		for _, item := range dialysisGoods { //获取当天排班的每个患者的最后日期的库存使用情况
+
+			goodUser, _ := service.GetLastDialysisGoods(item.PatientId, orgId, startime.Unix())
+			lastGoodUserDetial, _ := service.GetLastDialysisBeforePrepare(item.PatientId, orgId, startime.Unix())
+			item.LastAutomaticReduceDetail = goodUser
+			item.LastDialysisBeforePrepare = lastGoodUserDetial
+		}
 		this.ServeSuccessJSON(map[string]interface{}{
-			"schedule":     schedule,
-			"total":        total,
-			"consumables":  consumables,
-			"prescription": vlist,
-			"reducelist":   clist,
+			"dialysis_goods": dialysisGoods,
+			"good_type":      goodTypes,
+			"total":          total,
+			"schedule":       schedule,
+			"consumables":    consumables,
+			"prescription":   vlist,
+			"reducelist":     clist,
 		})
+		return
+
+	} else if err == nil {
+		//获取当天排班的每个患者的库存使用情况
+		dialysisGoods, err, total := service.PCGetDialysisGoodsTwo(orgId, startime.Unix(), scheduletype, partitiontype, page, limit, keyword)
+		for _, item := range dialysisGoods { //获取当天排班的每个患者的最后日期的库存使用情况
+			goodUser, _ := service.GetLastDialysisGoods(item.PatientId, orgId, startime.Unix())
+			lastGoodUserDetial, _ := service.GetLastDialysisBeforePrepare(item.PatientId, orgId, startime.Unix())
+
+			fmt.Println(goodUser)
+			fmt.Println(lastGoodUserDetial)
+
+			item.LastAutomaticReduceDetail = goodUser
+			item.LastDialysisBeforePrepare = lastGoodUserDetial
+		}
+		if err == nil {
+			this.ServeSuccessJSON(map[string]interface{}{
+				"dialysis_goods": dialysisGoods,
+				"good_type":      goodTypes,
+				"total":          total,
+				"schedule":       schedule,
+				"consumables":    consumables,
+				"prescription":   vlist,
+				"reducelist":     clist,
+			})
+			return
+
+		} else {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+	} else if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+
 	}
+	//if err == nil {
+	//	this.ServeSuccessJSON(map[string]interface{}{
+	//		"schedule":     schedule,
+	//		"total":        total,
+	//		"consumables":  consumables,
+	//		"prescription": vlist,
+	//		"reducelist":   clist,
+	//	})
+	//}
 }
 
 func (this *DialysisParamerterApiController) GetMobileGatherList() {

service/dialysis_parameter_service.go

@@ -302,3 +302,72 @@ func GetMaticeReduceByPatientId(patientid int64, orgid int64, startime int64, en
 	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
 }
+
+func PCGetDialysisGoodsTwo(orgID int64, scheduleDate int64, schedule_type int64, partition_id int64, page int64, limit int64, keywords string) ([]*MDialysisGoodsVM, error, int64) {
+	var vms []*MDialysisGoodsVM
+	var total int64
+
+	db := readDb.
+		Model(&models.Schedule{}).
+		Select("patient_id,mode_id").
+		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+		Preload("DialysisBeforePrepare", 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 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 record_time = ?  AND count > 0", orgID, scheduleDate)
+		}).Where("xt_schedule.status = 1 AND xt_schedule.user_org_id = ?", orgID)
+
+	if scheduleDate != 0 {
+		db = db.Where("schedule_date = ?", scheduleDate)
+	}
+	if len(keywords) != 0 {
+		keywords = "%" + keywords + "%"
+		db = db.Joins("JOIN xt_patients AS patient ON patient.id=xt_schedule.patient_id AND patient.status = 1 AND patient.user_org_id = ? AND patient.name Like ?", orgID, keywords)
+	} else {
+		if schedule_type != 0 {
+			db = db.Where("schedule_type = ?", schedule_type)
+		}
+		if partition_id != 0 {
+			db = db.Where("partition_id = ?", partition_id)
+		}
+
+		db = db.Count(&total)
+		offset := (page - 1) * limit
+
+		db = db.Offset(offset).Limit(limit)
+
+	}
+
+	err := db.Find(&vms).Error
+
+	return vms, err, total
+}
+
+func PCGetDialysisGoodsThree(orgID int64, scheduleDate int64) ([]*MDialysisGoodsVM, error) {
+
+	var vms []*MDialysisGoodsVM
+
+	db := readDb.
+		Model(&models.Schedule{}).
+		Select("patient_id,mode_id").
+		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+		Preload("DialysisBeforePrepare", 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 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 record_time = ?  AND count > 0", orgID, scheduleDate)
+		}).Where("xt_schedule.status = 1 AND xt_schedule.user_org_id = ?", orgID)
+
+	if scheduleDate != 0 {
+		db = db.Where("schedule_date = ?", scheduleDate)
+	}
+
+	err = db.Find(&vms).Error
+
+	return vms, err
+}