XT_New/controllers/dialysis_parameter_api_cont...

package controllers

import (
	"XT_New/enums"
	"XT_New/service"
	"fmt"
	"github.com/astaxie/beego"
	"github.com/jinzhu/gorm"
	"strings"
	"time"
)

type DialysisPrameterApiController struct {
	BaseAuthAPIController
}

func DialysisPrameteRoutes() {
	beego.Router("/api/dialysis/getdialysisparameters", &DialysisPrameterApiController{}, "Get:GetDialysisParameters")
	beego.Router("/api/dialysis/getdialysisbatchparameters", &DialysisPrameterApiController{}, "Get:GetDialysisBatchParameters")
	beego.Router("/api/dialysis/getwarehouseoutlist", &DialysisPrameterApiController{}, "Get:GetWareHouseOutList")
	beego.Router("/api/dialysis/getallmaterial", &DialysisPrameterApiController{}, "Get:GetAllMaterial")
	beego.Router("/api/dialysis/getcollectlist", &DialysisPrameterApiController{}, "Get:GetCollectList")
	beego.Router("/api/dialysis/getbatchcollection", &DialysisPrameterApiController{}, "Get:GetBatchCollection")
	beego.Router("/api/dialysis/getgatherlist", &DialysisPrameterApiController{}, "Get:GetGatherList")
}

func (this *DialysisPrameterApiController) GetDialysisParameters() {
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	page, _ := this.GetInt64("page")
	limit, _ := this.GetInt64("limit")
	schedulType, _ := this.GetInt64("scheduleType")
	start_time := this.GetString("start_time")
	partitionType, _ := this.GetInt64("partitionType")
	keywords := this.GetString("keyword")
	adminUserInfo := this.GetAdminUserInfo()
	theTime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
	fmt.Println("scheduletype", schedulType, start_time, partitionType, keywords, theTime.Unix())
	if len(keywords) > 0 {
		dialysisSchedule, err, total := service.GetDialysisParametersByKeyword(adminUserInfo.CurrentOrgId, keywords, schedulType, partitionType, page, limit, theTime.Unix())
		if err == nil {
			this.ServeSuccessJSON(map[string]interface{}{
				"schedule": dialysisSchedule,
				"total":    total,
			})
		} else {
			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		}
	} else {
		dialysisSchedule, err, total := service.GetDialysisParameter(adminUserInfo.CurrentOrgId, theTime.Unix(), schedulType, partitionType, page, limit)

		//查询今日排班的病人
		patient, err := service.GetDialysisTodaySchedulePatient(adminUserInfo.CurrentOrgId, theTime.Unix(), page, limit)

		var vlist []interface{}
		var elist []interface{}
		for _, item := range patient {
			//查询当前日期的病人是否存在数据
			_, errcode := service.GetToDayDialysisPrescription(item.PatientId, adminUserInfo.CurrentOrgId, theTime.Unix())
			if errcode == gorm.ErrRecordNotFound {
				//查询每个病人透析处方的最后一次数据
				prescription, _ := service.GetLastDialysisPrescription(item.PatientId, adminUserInfo.CurrentOrgId)
				vlist = append(vlist, prescription)
			} else if errcode == nil {
				//获取当前日期
				prescription, _ := service.GetDialysisPrescriptionList(item.PatientId, adminUserInfo.CurrentOrgId, theTime.Unix())
				vlist = append(vlist, prescription)
			}

			_, errcodes := service.GetTodayAssessmentBeforDialysis(item.PatientId, adminUserInfo.CurrentOrgId, theTime.Unix())
			if errcodes == gorm.ErrRecordNotFound {
				//查询每个病人透前评估的最后一次数据
				dialysis, _ := service.GetLastAssessmentBeforDialysis(item.PatientId, adminUserInfo.CurrentOrgId)
				elist = append(elist, dialysis)
			} else if errcodes == nil {
				dialysis, _ := service.GetAssessmentBeforDialysisByStartime(item.PatientId, adminUserInfo.CurrentOrgId, theTime.Unix())
				elist = append(elist, dialysis)
			}

		}

		if err == nil {
			this.ServeSuccessJSON(map[string]interface{}{
				"schedule":     dialysisSchedule,
				"total":        total,
				"prescription": vlist,
				"dialysbefor":  elist,
			})
		} else {
			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		}
	}

}

func (this *DialysisPrameterApiController) GetDialysisBatchParameters() {
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	adminUser := this.GetAdminUserInfo()
	orgId := adminUser.CurrentOrgId
	schIDStr := this.GetString("ids")
	if len(schIDStr) == 0 {
		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		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,
			"prescription": vlist,
			"dialysbefor":  elist,
		})
	}
}

func (this *DialysisPrameterApiController) GetWareHouseOutList() {

	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	start_time := this.GetString("start_time")
	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
	end_time := this.GetString("end_time")
	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
	fmt.Println(start_time, end_time)
	adminUserInfo := this.GetAdminUserInfo()
	orgId := adminUserInfo.CurrentOrgId
	wareoutlist, err := service.GetWareHouseOutList(startime.Unix(), endtime.Unix(), orgId)
	if err == nil {
		this.ServeSuccessJSON(map[string]interface{}{
			"wareoutlist": wareoutlist,
		})
	}
}

func (this *DialysisPrameterApiController) GetAllMaterial() {

	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	start_time := this.GetString("startime")
	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
	fmt.Println("开始时间", startime)
	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 23:59:59", loc)
	fmt.Println("结束时间", endtime)
	orgId := this.GetAdminUserInfo().CurrentOrgId
	material, err := service.GetAllMaterial(startime.Unix(), endtime.Unix(), orgId)
	if err == nil {
		this.ServeSuccessJSON(map[string]interface{}{
			"material": material,
		})
	}
}

func (this *DialysisPrameterApiController) GetCollectList() {

	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	limit, _ := this.GetInt64("limit")
	fmt.Println(limit)
	page, _ := this.GetInt64("page")
	fmt.Println("page", page)
	partitiontype, _ := this.GetInt64("partitionType")
	fmt.Println(partitiontype)
	scheduletype, _ := this.GetInt64("scheduleType")
	fmt.Println(scheduletype)
	start_time := this.GetString("start_time")
	fmt.Println(start_time)
	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
	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)

	//查询今日排班的病人
	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 {
			//查询每个病人透析处方的最后一次数据
			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)
		}
	}
	//获取透析耗材数据
	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 *DialysisPrameterApiController) GetBatchCollection() {
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	adminUser := this.GetAdminUserInfo()
	orgId := adminUser.CurrentOrgId
	fmt.Println(orgId)
	start_time := this.GetString("startime")
	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 23:59:59", loc)
	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,
			"prescripiton": vlist,
			"reducelist":   clist,
		})
	}
}

func (this *DialysisPrameterApiController) GetGatherList() {

	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("开始时间", 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{}{
			"warehouselist": warehouselist,
			"consumables":   consumables,
			"count":         count,
		})
	}
}