XT_New/service/qcd_service.go

package service

import (
	"XT_New/models"
	"fmt"
	"time"
)

type DialysisTotalDataStruct struct {
	Date   string `json:"date"`
	Number string `json:"number"`
	ModeID string `json:"mode_id"`
}

func GetDialysisTotalData(orgID, page, limit, lapseto, statisticalMethod, modeID, startTime, endTime int64, isStartTime, isEndTime bool) (dtd []*DialysisTotalDataStruct, ttd []*DialysisTotalDataStruct, total int64, err error) {
	db := readDb

	sql := "s.mode_id, from_unixtime(s.schedule_date, '%Y%m%d') as date, count(s.schedule_date) as number"
	datesql := "s.schedule_date as date"
	group := "from_unixtime(s.schedule_date, '%Y%m%d')"

	db = db.Table("xt_schedule as s")
	if statisticalMethod == 1 {
		db = db.Joins("JOIN xt_dialysis_order as o ON o.user_org_id =? and o.patient_id=s.patient_id and o.dialysis_date=s.schedule_date and o.status=1", orgID)
	}
	db = db.Where("s.user_org_id=?", orgID)
	if modeID > 0 {
		db = db.Where("s.mode_id=?", modeID)
	}
	if isStartTime {
		db = db.Where("s.schedule_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("s.schedule_date<=?", endTime)
	}
	db = db.Where("s.status=1")

	if lapseto > 0 {
		joinString := "JOIN xt_patients as p ON o.patient_id=p.id and p.lapseto=? and p.status=1"
		joinParams := make([]interface{}, 0)
		joinParams = append(joinParams, lapseto)
		if orgID > 0 {
			joinString += " AND p.user_org_id=?"
			joinParams = append(joinParams, orgID)
		}

		db = db.Joins(joinString, joinParams...)
	}

	err = db.Select("s.mode_id, count(s.mode_id) as number").Group("s.mode_id").Order("s.mode_id asc").Find(&ttd).Error
	if err != nil {
		return
	}

	offset := (page - 1) * limit

	var ds []*DialysisTotalDataStruct
	err = db.Select(datesql).Group(group).Count(&total).Order("date asc").Offset(offset).Limit(limit).Find(&ds).Error
	if err != nil {
		return
	}

	dates := make([]string, 0)
	if len(ds) > 0 {
		for _, d := range ds {
			dates = append(dates, d.Date)
		}

		db = db.Where("s.schedule_date IN (?)", dates)

	}

	err = db.Select(sql).Group(group + ", s.mode_id").Order("date asc, mode_id").Find(&dtd).Error
	return
}

type PIInspectionPageStruct struct {
	PatientID   int64 `json:"patient_id"`
	InspectDate int64 `json:"inspect_date"`
}

type PIInspectionProjectCountStruct struct {
	Count int64 `json:"count"`
}

func GetProcessIndicatorsData(orgID, page, limit, lapseto, dialysisAge, projectID, startTime, endTime int64, isStartTime, isEndTime bool) (inspections []*models.Inspection, references []*models.InspectionReference, patients []*models.Patients, counts []*PIInspectionProjectCountStruct, total int64, err error) {
	err = readDb.Table("xt_inspection_reference").Find(&references).Error
	if err != nil || len(references) == 0 {
		return
	}

	projects := make(map[int64]int64, 0)
	for _, reference := range references {
		if _, exist := projects[reference.ProjectId]; !exist {
			projects[reference.ProjectId] = reference.ProjectId
		}
	}
	projectLen := len(projects)

	countSQL := "SELECT count(distinct project_id) as projects FROM xt_inspection as i "
	countParams := make([]interface{}, 0)
	if dialysisAge > 0 || lapseto > 0 {
		countSQL += " JOIN xt_patients as p ON i.patient_id=p.id"
		if orgID > 0 {
			countSQL += " and p.user_org_id=?"
			countParams = append(countParams, orgID)
		}
		if lapseto > 0 {
			countSQL += " and p.lapseto=?"
			countParams = append(countParams, lapseto)
		}
		if dialysisAge > 0 {
			loc, _ := time.LoadLocation("Local")
			nowTime := time.Now()
			nowDay := nowTime.Format("2006-01-02")
			dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)

			if err != nil {
				return inspections, references, patients, counts, total, err
			}
			timePoint := dayTime.AddDate(0, -3, 0).Unix()
			if dialysisAge == 1 {
				countSQL += " and p.first_dialysis_date<>0 AND p.first_dialysis_date <= ?"
				countParams = append(countParams, timePoint)
			} else {
				countSQL += " and p.first_dialysis_date<>0 AND p.first_dialysis_date > ?"
				countParams = append(countParams, timePoint)
			}
		}
	}

	countSQL += " WHERE i.status=1"
	if orgID > 0 {
		countSQL += " AND i.org_id=?"
		countParams = append(countParams, orgID)
	}
	if projectID > 0 {
		countSQL += " AND i.project_id=?"
		countParams = append(countParams, projectID)
	}
	if isStartTime {
		countSQL += " AND i.inspect_date>=?"
		countParams = append(countParams, startTime)
	}
	if isEndTime {
		countSQL += " AND i.inspect_date<=?"
		countParams = append(countParams, endTime)
	}
	countParams = append(countParams, projectLen)

	err = readDb.Raw("SELECT COUNT(*) as count from ("+countSQL+" GROUP BY inspect_date, patient_id) as t where t.projects<?", countParams...).Scan(&counts).Error
	if err != nil {
		return
	}

	db := readDb.Table("xt_inspection as i")
	if orgID > 0 {
		db = db.Where("i.org_id=?", orgID)
	}
	if projectID > 0 {
		db = db.Where("i.project_id=?", projectID)
	}
	if isStartTime {
		db = db.Where("i.inspect_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("i.inspect_date<=?", endTime)
	}
	db = db.Where("i.status=1")

	if dialysisAge > 0 || lapseto > 0 {
		joinString := "JOIN xt_patients as p ON i.patient_id=p.id"
		joinParams := make([]interface{}, 0)
		if orgID > 0 {
			joinString += " and p.user_org_id=?"
			joinParams = append(joinParams, orgID)
		}

		if lapseto > 0 {
			joinString += " and p.lapseto=?"
			joinParams = append(joinParams, lapseto)
		}
		if dialysisAge > 0 {
			loc, _ := time.LoadLocation("Local")
			nowTime := time.Now()
			nowDay := nowTime.Format("2006-01-02")
			dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
			if err != nil {
				return inspections, references, patients, counts, total, err
			}
			timePoint := dayTime.AddDate(0, -3, 0).Unix()
			if dialysisAge == 1 {
				joinString += " and p.first_dialysis_date<>0 AND p.first_dialysis_date <= ?"
				joinParams = append(joinParams, timePoint)
			} else {
				joinString += " and p.first_dialysis_date<>0 AND p.first_dialysis_date > ?"
				joinParams = append(joinParams, timePoint)
			}
		}

		db = db.Joins(joinString, joinParams...)
	}

	offset := (page - 1) * limit

	var ds []*PIInspectionPageStruct
	err = db.Select("i.patient_id, i.inspect_date").Group("inspect_date, patient_id").Count(&total).Order("inspect_date desc, i.created_time desc, i.id asc, patient_id asc").Offset(offset).Limit(limit).Find(&ds).Error
	if err != nil {
		return
	}

	dates := make([]int64, 0)
	ids := make([]int64, 0)
	if len(ds) > 0 {
		for _, d := range ds {
			dates = append(dates, d.InspectDate)
			ids = append(ids, d.PatientID)
		}

		db = db.Where("i.inspect_date IN (?)", dates).Where("i.patient_id IN (?)", ids)
	}

	err = db.Select("i.id, i.patient_id, org_id, i.project_id, i.item_id, i.item_name, i.project_name, i.inspect_type, i.inspect_value, i.inspect_date, i.status, i.created_time, i.updated_time").Order("inspect_date desc, created_time desc, id asc, patient_id asc").Find(&inspections).Error
	if err != nil {
		return
	}

	if len(ids) > 0 {
		err = readDb.Table("xt_patients").Where("id IN (?)", ids).Find(&patients).Error
		if err != nil {
			return
		}
	}

	return
}

func GetOICData(orgID, page, limit, lapseto, dialysisAge, projectID, itemID, startTime, endTime int64, isStartTime, isEndTime bool) (inspections []*models.Inspection, references []*models.InspectionReference, patients []*models.Patients, counts []*PIInspectionProjectCountStruct, total int64, err error) {
	err = readDb.Table("xt_inspection_reference").Order("project_id").Find(&references).Error
	if err != nil || len(references) == 0 {
		return
	}

	countSQL := "SELECT count(distinct i.project_id) as projects FROM xt_inspection as i "
	countParams := make([]interface{}, 0)
	countSQL += " JOIN xt_inspection_reference as ir ON ir.id=i.item_id and ir.project_id=i.project_id"

	if dialysisAge > 0 || lapseto > 0 {
		countSQL += " JOIN xt_patients as p ON i.patient_id=p.id"
		if orgID > 0 {
			countSQL += " and p.user_org_id=?"
			countParams = append(countParams, orgID)
		}
		if lapseto > 0 {
			countSQL += " and p.lapseto=?"
			countParams = append(countParams, lapseto)
		}
		if dialysisAge > 0 {
			loc, _ := time.LoadLocation("Local")
			nowTime := time.Now()
			nowDay := nowTime.Format("2006-01-02")
			dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
			if err != nil {
				return inspections, references, patients, counts, total, err
			}
			timePoint := dayTime.AddDate(0, -3, 0).Unix()
			if dialysisAge == 1 {
				countSQL += " and p.first_dialysis_date<>0 AND p.first_dialysis_date <= ?"
				countParams = append(countParams, timePoint)
			} else {
				countSQL += " and p.first_dialysis_date<>0 AND p.first_dialysis_date > ?"
				countParams = append(countParams, timePoint)
			}
		}
	}

	countSQL += " WHERE i.status=1"
	if orgID > 0 {
		countSQL += " AND i.org_id=?"
		countParams = append(countParams, orgID)
	}
	if projectID > 0 {
		countSQL += " AND i.project_id=?"
		countParams = append(countParams, projectID)
	}
	if isStartTime {
		countSQL += " AND i.inspect_date>=?"
		countParams = append(countParams, startTime)
	}
	if isEndTime {
		countSQL += " AND i.inspect_date<=?"
		countParams = append(countParams, endTime)
	}
	countSQL += " AND ((i.inspect_type=1 AND (CONVERT(i.inspect_value, DECIMAL)<CONVERT(ir.range_min, DECIMAL) OR CONVERT(i.inspect_value, DECIMAL)>CONVERT(ir.range_max, DECIMAL))) OR (i.inspect_type=2 AND i.inspect_value<>ir.range_value))"

	err = readDb.Raw("SELECT COUNT(*) as count from ("+countSQL+" GROUP BY inspect_date, patient_id) as t ", countParams...).Scan(&counts).Error
	if err != nil {
		return
	}

	db := readDb.Table("xt_inspection as i")
	if orgID > 0 {
		db = db.Where("i.org_id=?", orgID)
	}
	if projectID > 0 {
		db = db.Where("i.project_id=?", projectID)
	}
	if itemID > 0 {
		db = db.Where("i.item_id=?", itemID)
	}
	if isStartTime {
		db = db.Where("i.inspect_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("i.inspect_date<=?", endTime)
	}
	db = db.Where("i.status=1")

	if dialysisAge > 0 || lapseto > 0 {
		joinString := "JOIN xt_patients as p ON i.patient_id=p.id"
		joinParams := make([]interface{}, 0)
		if orgID > 0 {
			joinString += " and p.user_org_id=?"
			joinParams = append(joinParams, orgID)
		}

		if lapseto > 0 {
			joinString += " and p.lapseto=?"
			joinParams = append(joinParams, lapseto)
		}
		if dialysisAge > 0 {
			loc, _ := time.LoadLocation("Local")
			nowTime := time.Now()
			nowDay := nowTime.Format("2006-01-02")
			dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
			if err != nil {
				return inspections, references, patients, counts, total, err
			}
			timePoint := dayTime.AddDate(0, -3, 0).Unix()
			if dialysisAge == 1 {
				joinString += " and p.first_dialysis_date<>0 AND p.first_dialysis_date <= ?"
				joinParams = append(joinParams, timePoint)
			} else {
				joinString += " and p.first_dialysis_date<>0 AND p.first_dialysis_date > ?"
				joinParams = append(joinParams, timePoint)
			}
		}

		db = db.Joins(joinString, joinParams...)
	}

	offset := (page - 1) * limit

	var ds []*PIInspectionPageStruct
	err = db.Select("i.patient_id, i.inspect_date").Group("inspect_date, patient_id").Count(&total).Order("inspect_date desc, i.created_time desc, i.id asc, patient_id asc").Offset(offset).Limit(limit).Find(&ds).Error
	if err != nil {
		return
	}

	dates := make([]int64, 0)
	ids := make([]int64, 0)
	if len(ds) > 0 {
		for _, d := range ds {
			dates = append(dates, d.InspectDate)
			ids = append(ids, d.PatientID)
		}

		db = db.Where("i.inspect_date IN (?)", dates).Where("i.patient_id IN (?)", ids)
	}

	err = db.Select("i.id, i.patient_id, org_id, i.project_id, i.item_id, i.item_name, i.project_name, i.inspect_type, i.inspect_value, i.inspect_date, i.status, i.created_time, i.updated_time").Order("inspect_date desc, created_time desc, id asc, patient_id asc").Find(&inspections).Error
	if err != nil {
		return
	}

	if len(ids) > 0 {
		err = readDb.Table("xt_patients").Where("id IN (?)", ids).Find(&patients).Error
		if err != nil {
			return
		}
	}

	return
}

func GetOIQData(orgID, page, limit, projectID, startTime, endTime int64, isStartTime, isEndTime bool, searchKey string) (inspections []*models.Inspection, references []*models.InspectionReference, patients []*models.Patients, total int64, err error) {
	err = readDb.Table("xt_inspection_reference").Order("project_id").Find(&references).Error
	if err != nil || len(references) == 0 {
		return
	}
	if projectID <= 0 {
		projectID = references[0].ProjectId
	}

	db := readDb.Table("xt_inspection as i")
	if orgID > 0 {
		db = db.Where("i.org_id=?", orgID)
	}
	if projectID > 0 {
		db = db.Where("i.project_id=?", projectID)
	}
	if isStartTime {
		db = db.Where("i.inspect_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("i.inspect_date<=?", endTime)
	}

	if len(searchKey) > 0 {
		searchKey = "%" + searchKey + "%"
		joinString := "JOIN xt_patients as p ON i.patient_id=p.id AND (p.name LIKE ? OR p.dialysis_no LIKE ?)"
		joinParams := make([]interface{}, 0)
		joinParams = append(joinParams, searchKey)
		joinParams = append(joinParams, searchKey)
		db = db.Joins(joinString, joinParams...)

		db = db.Where("p.name LIKE ? OR p.dialysis_no LIKE ?", searchKey, searchKey)
	}
	db = db.Where("i.status=1")

	offset := (page - 1) * limit

	var ds []*PIInspectionPageStruct
	err = db.Select("i.patient_id, i.inspect_date").Group("inspect_date, patient_id").Count(&total).Order("inspect_date desc, i.created_time desc, i.id asc, patient_id asc").Offset(offset).Limit(limit).Find(&ds).Error
	if err != nil {
		return
	}

	dates := make([]int64, 0)
	ids := make([]int64, 0)
	if len(ds) > 0 {
		for _, d := range ds {
			dates = append(dates, d.InspectDate)
			ids = append(ids, d.PatientID)
		}

		db = db.Where("i.inspect_date IN (?)", dates).Where("i.patient_id IN (?)", ids)
	}

	err = db.Select("i.id, i.patient_id, org_id, i.project_id, i.item_id, i.item_name, i.project_name, i.inspect_type, i.inspect_value, i.inspect_date, i.status, i.created_time, i.updated_time").Order("inspect_date desc, created_time desc, id asc, patient_id asc").Find(&inspections).Error
	if err != nil {
		return
	}

	if len(ids) > 0 {
		err = readDb.Table("xt_patients").Where("id IN (?)", ids).Find(&patients).Error
		if err != nil {
			return
		}
	}

	return
}

func GetPATotalData(orgID, page, limit, lapseto, source, age, startTime, endTime int64, isStartTime, isEndTime bool, searchKey string) (patients []*models.Patients, lapsetoOut, lapsetoIn, total int64, err error) {
	db := readDb.Table("xt_patients").Where("status=1")
	if orgID > 0 {
		db = db.Where("user_org_id=?", orgID)
	}
	if lapseto > 0 {
		db = db.Where("lapseto=?", lapseto)
	}
	if source > 0 {
		if source == 1 || source == 2 {
			db = db.Where("source=?", source)
		} else {
			db = db.Where("source NOT IN (1,2)")
		}
	}

	loc, _ := time.LoadLocation("Local")
	nowTime := time.Now()
	nowDay := nowTime.Format("2006-01-02")
	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
	if err != nil {
		return
	}
	var timeStartPoint int64
	var timeEndPoint int64

	if age == 1 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-30, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
	} else if age == 2 {
		timeStartPoint = dayTime.AddDate(-30, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-40, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
	} else if age == 3 {
		timeStartPoint = dayTime.AddDate(-40, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
	} else if age == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("birthday>? or birthday<=?", timeStartPoint, timeEndPoint)
	}
	if isStartTime {
		db = db.Where("created_time>=?", startTime)
	}
	if isEndTime {
		db = db.Where("created_time<=?", endTime)
	}
	if len(searchKey) > 0 {
		searchKey = "%" + searchKey + "%"
		db = db.Where("name LIKE ? OR dialysis_no LIKE ? ", searchKey, searchKey)
	}

	offset := (page - 1) * limit
	err = db.Count(&total).Order("id desc").Offset(offset).Limit(limit).Find(&patients).Error
	if err != nil {
		return
	}

	err = db.Where("lapseto=1").Count(&lapsetoIn).Error
	if err != nil {
		return
	}
	lapsetoOut = total - lapsetoIn

	return
}

type PADialysisAgePieDataStruct struct {
	Age   int64 `json:"age"`
	Count int64 `json:"count"`
}

func GetPADialysisAgeData(orgID, page, limit, lapseto, age, dialysisAge, startTime, endTime int64, isStartTime, isEndTime bool) (patients []*models.Patients, counts []*PADialysisAgePieDataStruct, total int64, err error) {

	loc, _ := time.LoadLocation("Local")
	nowTime := time.Now()
	nowDay := nowTime.Format("2006-01-02")
	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
	if err != nil {
		return
	}
	var timeStartPoint int64
	var timeEndPoint int64
	oneYearPoint := dayTime.AddDate(-1, 0, 0).Unix()
	fiveYearPoint := dayTime.AddDate(-5, 0, 0).Unix()
	tenYearPoint := dayTime.AddDate(-10, 0, 0).Unix()
	twentyYearPoint := dayTime.AddDate(-20, 0, 0).Unix()

	db := readDb.Table("xt_patients").Where("status=1")
	countSQL := "SELECT nnd AS 'age',COUNT(*) AS 'count' FROM(" +
		"SELECT " +
		"CASE " +
		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? THEN '1'" +
		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '2'" +
		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '3'" +
		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '4'" +
		" WHEN first_dialysis_date<>0 AND first_dialysis_date<=? THEN '5'" +
		" ELSE '0'" +
		"END AS nnd FROM xt_patients WHERE status=1"
	countParams := make([]interface{}, 0)
	countParams = append(countParams, oneYearPoint)
	countParams = append(countParams, fiveYearPoint)
	countParams = append(countParams, oneYearPoint)
	countParams = append(countParams, tenYearPoint)
	countParams = append(countParams, fiveYearPoint)
	countParams = append(countParams, twentyYearPoint)
	countParams = append(countParams, tenYearPoint)
	countParams = append(countParams, twentyYearPoint)

	if orgID > 0 {
		db = db.Where("user_org_id=?", orgID)
		countSQL += " AND user_org_id=?"
		countParams = append(countParams, orgID)
	}
	if lapseto > 0 {
		db = db.Where("lapseto=?", lapseto)
		countSQL += " AND lapseto=?"
		countParams = append(countParams, lapseto)
	}

	if age == 1 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-30, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (birthday>? and birthday<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 2 {
		timeStartPoint = dayTime.AddDate(-30, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-40, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (birthday>? and birthday<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 3 {
		timeStartPoint = dayTime.AddDate(-40, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("birthday>? and birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (birthday>? and birthday<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("birthday>? or birthday<=?", timeStartPoint, timeEndPoint)
		countSQL += " AND (birthday>? or birthday<=?)"
		countParams = append(countParams, timeStartPoint)
		countParams = append(countParams, timeEndPoint)
	}

	if dialysisAge == 1 {
		timeStartPoint = dayTime.AddDate(-1, 0, 0).Unix()
		db = db.Where("first_dialysis_date>?", timeStartPoint)
		db = db.Where("first_dialysis_date<>0")
		countSQL += " AND (first_dialysis_date<>0 AND first_dialysis_date>?)"
		countParams = append(countParams, timeStartPoint)
	} else if dialysisAge == 2 {
		timeStartPoint = dayTime.AddDate(-1, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-5, 0, 0).Unix()
		db = db.Where("first_dialysis_date<>0")
		db = db.Where("first_dialysis_date>? and first_dialysis_date<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (first_dialysis_date<>0 AND first_dialysis_date>? and first_dialysis_date<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if dialysisAge == 3 {
		timeStartPoint = dayTime.AddDate(-5, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-10, 0, 0).Unix()
		db = db.Where("first_dialysis_date<>0")
		db = db.Where("first_dialysis_date>? and first_dialysis_date<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (first_dialysis_date<>0 AND first_dialysis_date>? and first_dialysis_date<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if dialysisAge == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-20, 0, 0).Unix()
		db = db.Where("first_dialysis_date<>0")
		db = db.Where("first_dialysis_date>? and first_dialysis_date<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND (first_dialysis_date<>0 AND first_dialysis_date>? and first_dialysis_date<=?)"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if dialysisAge == 5 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		db = db.Where("first_dialysis_date<>0")
		db = db.Where("first_dialysis_date<=?", timeStartPoint)
		countSQL += " AND (first_dialysis_date<>0 AND first_dialysis_date<=?)"
		countParams = append(countParams, timeStartPoint)
	}

	if isStartTime {
		db = db.Where("created_time>=?", startTime)
		countSQL += " AND (created_time>=?)"
		countParams = append(countParams, startTime)
	}
	if isEndTime {
		db = db.Where("created_time<=?", endTime)
		countSQL += " AND (created_time<=?)"
		countParams = append(countParams, endTime)
	}
	countSQL += ")a GROUP BY nnd"
	err = readDb.Raw(countSQL, countParams...).Scan(&counts).Error
	if err != nil {
		return
	}

	offset := (page - 1) * limit
	err = db.Count(&total).Order("id desc").Offset(offset).Limit(limit).Find(&patients).Error
	if err != nil {
		return
	}

	return
}

type PAWeightDataStruct struct {
	models.Schedule

	Patient                  *models.Patients                `json:"patient" gorm:"foreignkey:PatientId;"`
	AssessmentAfterDislysis  *models.AssessmentAfterDislysis `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_after_dislysis"`
	AssessmentBeforeDislysis *models.PredialysisEvaluation   `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_before_dislysis"`
}

type PAWeightPieDataStruct struct {
	Weight int64 `json:"weight"`
	Count  int64 `json:"count"`
}

func (PAWeightDataStruct) TableName() string {
	return "xt_schedule"
}

func GetPAWeightData(orgID, page, limit, lapseto, age, startTime, endTime int64, isStartTime, isEndTime bool) (weight []*PAWeightDataStruct, dryweight []*PAWeightPieDataStruct, weightincrease []*PAWeightPieDataStruct, afterweight []*PAWeightPieDataStruct, total int64, err error) {
	loc, _ := time.LoadLocation("Local")
	nowTime := time.Now()
	nowDay := nowTime.Format("2006-01-02")
	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
	if err != nil {
		return
	}
	var timeStartPoint int64
	var timeEndPoint int64

	dryCountSQL := "SELECT nnd AS 'weight',COUNT(*) AS 'count' FROM(" +
		"SELECT " +
		"CASE " +
		" WHEN abd.dry_weight<>0 and abd.dry_weight<40 THEN '1'" +
		" WHEN abd.dry_weight>=40 && abd.dry_weight<50 THEN '2'" +
		" WHEN abd.dry_weight>=50 && abd.dry_weight<60 THEN '3'" +
		" WHEN abd.dry_weight>=60 && abd.dry_weight<70 THEN '4'" +
		" WHEN abd.dry_weight>=70  THEN '5'" +
		" ELSE '0'" +
		"END AS nnd FROM xt_assessment_before_dislysis as abd JOIN xt_patients as p ON p.id=abd.patient_id and p.user_org_id=? WHERE p.status=1"
	dryCountParams := make([]interface{}, 0)
	dryCountParams = append(dryCountParams, orgID)

	increaseCountSQL := "SELECT nnd AS 'weight',COUNT(*) AS 'count' FROM(" +
		"SELECT " +
		"CASE " +
		" WHEN (abd.weight_before-abd.dry_weight)<1 THEN '1'" +
		" WHEN (abd.weight_before-abd.dry_weight)>=1 && (abd.weight_before-abd.dry_weight)<2 THEN '2'" +
		" WHEN (abd.weight_before-abd.dry_weight)>=2 && (abd.weight_before-abd.dry_weight)<3 THEN '3'" +
		" WHEN (abd.weight_before-abd.dry_weight)>=3 && (abd.weight_before-abd.dry_weight)<4 THEN '4'" +
		" WHEN (abd.weight_before-abd.dry_weight)>=4 THEN '5'" +
		" ELSE '0'" +
		"END AS nnd FROM xt_assessment_before_dislysis as abd JOIN xt_patients as p ON p.id=abd.patient_id and p.user_org_id=? WHERE p.status=1"
	increaseCountParams := make([]interface{}, 0)
	increaseCountParams = append(increaseCountParams, orgID)

	afterCountSQL := "SELECT nnd AS 'weight',COUNT(*) AS 'count' FROM(" +
		"SELECT " +
		"CASE " +
		" WHEN afd.weight_after<>0 and afd.weight_after<40 THEN '1'" +
		" WHEN afd.weight_after>=40 && afd.weight_after<50 THEN '2'" +
		" WHEN afd.weight_after>=50 && afd.weight_after<60 THEN '3'" +
		" WHEN afd.weight_after>=60 && afd.weight_after<70 THEN '4'" +
		" WHEN afd.weight_after>=70  THEN '5'" +
		" ELSE '0'" +
		"END AS nnd FROM xt_assessment_after_dislysis as afd JOIN xt_patients as p ON p.id=afd.patient_id and p.user_org_id=? WHERE p.status=1"
	afterCountParams := make([]interface{}, 0)
	afterCountParams = append(afterCountParams, orgID)

	db := readDb.Table("xt_schedule as c").Joins("JOIN xt_patients as p ON p.id=c.patient_id and p.user_org_id=?", orgID)
	if lapseto > 0 {
		db = db.Where("p.lapseto=?", lapseto)
		dryCountSQL += " AND p.lapseto=?"
		dryCountParams = append(dryCountParams, lapseto)
		increaseCountSQL += " AND p.lapseto=?"
		increaseCountParams = append(increaseCountParams, lapseto)
		afterCountSQL += " AND p.lapseto=?"
		afterCountParams = append(afterCountParams, lapseto)
	}

	if age == 1 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-30, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		dryCountSQL += " AND p.birthday>? and p.birthday<=?"
		dryCountParams = append(dryCountParams, timeEndPoint, timeStartPoint)
		increaseCountSQL += " AND p.birthday>? and p.birthday<=?"
		increaseCountParams = append(increaseCountParams, timeEndPoint, timeStartPoint)
		afterCountSQL += " AND p.birthday>? and p.birthday<=?"
		afterCountParams = append(afterCountParams, timeEndPoint, timeStartPoint)
	} else if age == 2 {
		timeStartPoint = dayTime.AddDate(-30, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-40, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		dryCountSQL += " AND p.birthday>? and p.birthday<=?"
		dryCountParams = append(dryCountParams, timeEndPoint, timeStartPoint)
		increaseCountSQL += " AND p.birthday>? and p.birthday<=?"
		increaseCountParams = append(increaseCountParams, timeEndPoint, timeStartPoint)
		afterCountSQL += " AND p.birthday>? and p.birthday<=?"
		afterCountParams = append(afterCountParams, timeEndPoint, timeStartPoint)
	} else if age == 3 {
		timeStartPoint = dayTime.AddDate(-40, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		dryCountSQL += " AND p.birthday>? and p.birthday<=?"
		dryCountParams = append(dryCountParams, timeEndPoint, timeStartPoint)
		increaseCountSQL += " AND p.birthday>? and p.birthday<=?"
		increaseCountParams = append(increaseCountParams, timeEndPoint, timeStartPoint)
		afterCountSQL += " AND p.birthday>? and p.birthday<=?"
		afterCountParams = append(afterCountParams, timeEndPoint, timeStartPoint)
	} else if age == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? or p.birthday<=?", timeStartPoint, timeEndPoint)
		dryCountSQL += " AND (p.birthday>? or p.birthday<=?)"
		dryCountParams = append(dryCountParams, timeStartPoint, timeEndPoint)
		increaseCountSQL += " AND (p.birthday>? or p.birthday<=?)"
		increaseCountParams = append(increaseCountParams, timeStartPoint, timeEndPoint)
		afterCountSQL += " AND (p.birthday>? or p.birthday<=?)"
		afterCountParams = append(afterCountParams, timeStartPoint, timeEndPoint)
	}

	if isStartTime {
		db = db.Where("c.schedule_date>=?", startTime)
		dryCountSQL += " AND abd.assessment_date>=?"
		dryCountParams = append(dryCountParams, startTime)
		increaseCountSQL += " AND abd.assessment_date>=?"
		increaseCountParams = append(increaseCountParams, startTime)
		afterCountSQL += " AND afd.assessment_date>=?"
		afterCountParams = append(afterCountParams, startTime)
	}
	if isEndTime {
		db = db.Where("c.schedule_date<=?", endTime)
		dryCountSQL += " AND abd.assessment_date<=?"
		dryCountParams = append(dryCountParams, endTime)
		increaseCountSQL += " AND abd.assessment_date<=?"
		increaseCountParams = append(increaseCountParams, endTime)
		afterCountSQL += " AND afd.assessment_date<=?"
		afterCountParams = append(afterCountParams, endTime)
	}

	dryCountSQL += ")a GROUP BY nnd"
	err = readDb.Raw(dryCountSQL, dryCountParams...).Scan(&dryweight).Error
	if err != nil {
		return
	}

	increaseCountSQL += ")a GROUP BY nnd"
	err = readDb.Raw(increaseCountSQL, increaseCountParams...).Scan(&weightincrease).Error
	if err != nil {
		return
	}

	afterCountSQL += ")a GROUP BY nnd"
	err = readDb.Raw(afterCountSQL, afterCountParams...).Scan(&afterweight).Error
	if err != nil {
		return
	}

	db = db.Where("c.status=1")

	offset := (page - 1) * limit
	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date desc, c.schedule_type desc, c.id desc").Count(&total).Offset(offset).Limit(limit).Find(&weight).Error
	return
}

type PABloodPressureDataStruct struct {
	models.Schedule

	Patient                  *models.Patients                `json:"patient" gorm:"foreignkey:PatientId;"`
	AssessmentAfterDislysis  *models.AssessmentAfterDislysis `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_after_dislysis"`
	AssessmentBeforeDislysis *models.PredialysisEvaluation   `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_before_dislysis"`
	MonitoringRecord         []*models.MonitoringRecord      `gorm:"ForeignKey:MonitoringDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"monitor_records"`
}

func (PABloodPressureDataStruct) TableName() string {
	return "xt_schedule"
}

type PABloodPressurePieDataStruct struct {
	Blood int64 `json:"blood"`
	Count int64 `json:"count"`
}

func GetPABloodPressureData(orgID, page, limit, lapseto, dialysisStage, startTime, endTime int64, isStartTime, isEndTime bool) (bloodPressures []*PABloodPressureDataStruct, bps []*PABloodPressurePieDataStruct, total int64, err error) {

	db := readDb.Table("xt_schedule as c").Joins("JOIN xt_patients as p ON p.id=c.patient_id and p.user_org_id=?", orgID)

	countSQL := "SELECT lmr.* from xt_monitoring_record as lmr JOIN xt_patients as p ON p.id=lmr.patient_id and p.user_org_id=? "
	countParams := make([]interface{}, 0)
	countParams = append(countParams, orgID)

	if dialysisStage == 1 {
		db = db.Joins("JOIN xt_assessment_before_dislysis as abd ON abd.patient_id=c.patient_id and abd.assessment_date=c.schedule_date and abd.user_org_id=?", orgID)
		countSQL += "JOIN xt_assessment_before_dislysis as abd ON abd.patient_id=lmr.patient_id and abd.assessment_date=lmr.monitoring_date and abd.user_org_id=?"
		countParams = append(countParams, orgID)
	} else if dialysisStage == 2 {
		db = db.Joins("JOIN xt_assessment_after_dislysis as aad ON aad.patient_id=c.patient_id and aad.assessment_date=c.schedule_date and aad.user_org_id=?", orgID)
		countSQL += "JOIN xt_assessment_after_dislysis as aad ON aad.patient_id=lmr.patient_id and aad.assessment_date=lmr.monitoring_date and aad.user_org_id=?"
		countParams = append(countParams, orgID)
	}

	countSQL += " WHERE lmr.user_org_id=? AND lmr.status=1"
	countParams = append(countParams, orgID)

	if lapseto > 0 {
		db = db.Where("p.lapseto=?", lapseto)
		countSQL += " AND p.lapseto=?"
		countParams = append(countParams, lapseto)
	}

	if isStartTime {
		db = db.Where("c.schedule_date>=?", startTime)
		countSQL += " AND lmr.monitoring_date>=?"
		countParams = append(countParams, startTime)
	}
	if isEndTime {
		db = db.Where("c.schedule_date<=?", endTime)
		countSQL += " AND lmr.monitoring_date<=?"
		countParams = append(countParams, endTime)
	}
	countSQL += "  order by lmr.systolic_blood_pressure desc, lmr.diastolic_blood_pressure desc"
	lastSQL := "SELECT nnd as 'blood' ,COUNT(*) AS 'count' FROM(" +
		"SELECT " +
		"CASE " +
		" WHEN systolic_blood_pressure<>0 && diastolic_blood_pressure <> 0 && systolic_blood_pressure<140 && diastolic_blood_pressure<90 THEN '1'" +
		" WHEN systolic_blood_pressure>=160 && diastolic_blood_pressure>=100 THEN '2'" +
		" WHEN systolic_blood_pressure<160 && systolic_blood_pressure>=140 && diastolic_blood_pressure<100 && diastolic_blood_pressure>=90 THEN '3'" +
		" ELSE '0' " +
		"END AS nnd FROM (" + countSQL + ") b group by monitoring_date, patient_id)a GROUP BY nnd"
	err = readDb.Raw(lastSQL, countParams...).Find(&bps).Error
	if err != nil {
		return
	}

	db = db.Where("c.status=1")

	offset := (page - 1) * limit
	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("MonitoringRecord", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date desc, c.schedule_type desc, c.id desc").Count(&total).Offset(offset).Limit(limit).Find(&bloodPressures).Error
	return
}

type PAComplicationDataStruct struct {
	models.Schedule

	Patient                  *models.Patients                `json:"patient" gorm:"foreignkey:PatientId;"`
	AssessmentAfterDislysis  *models.AssessmentAfterDislysis `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_after_dislysis"`
	AssessmentBeforeDislysis *models.PredialysisEvaluation   `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_before_dislysis"`
}

type PAComplicationPieDataStruct struct {
	Complication int64  `json:"complication"`
	Name         string `json:"name"`
	Count        int64  `json:"count"`
}

func GetPAComplicationData(orgID, page, limit, age, statisticalState, startTime, endTime int64, isStartTime, isEndTime bool) (complications []*PAComplicationDataStruct, pcps []*PAComplicationPieDataStruct, total int64, err error) {
	db := readDb.Table("xt_schedule as c").Joins("JOIN xt_patients as p ON p.id=c.patient_id and p.user_org_id=?", orgID)
	if statisticalState == 1 {
		db = db.Joins("JOIN xt_assessment_before_dislysis as abd ON abd.patient_id=c.patient_id and abd.assessment_date=c.schedule_date and abd.user_org_id=?", orgID)
	} else if statisticalState == 2 {
		db = db.Joins("JOIN xt_assessment_after_dislysis as aad ON aad.patient_id=c.patient_id and aad.assessment_date=c.schedule_date and aad.user_org_id=?", orgID)
	} else {
		return
	}

	var dc models.Dataconfig
	err = readDb.Model(&models.Dataconfig{}).Where("module='hemodialysis' AND field_name='complication'").First(&dc).Error
	if err != nil {
		return
	}

	ComplicationsMap := make([]map[string]interface{}, 0)
	if dc.ID > 0 {
		var dcs []*models.Dataconfig
		err = readDb.Model(&models.Dataconfig{}).Where("parent_id=? and org_id in (0,?) and status = 1 ", dc.ID, orgID).Order("orders desc, id asc").Find(&dcs).Error
		if err != nil {
			return
		}

		if len(dcs) > 0 {
			for _, item := range dcs {
				mapItem := map[string]interface{}{"id": item.ID, "name": item.Name}
				ComplicationsMap = append(ComplicationsMap, mapItem)
			}

		}
	}

	sqlMap := make(map[int64]string, 0)
	countParamsMap := make(map[int64][]interface{}, 0)
	for _, citem := range ComplicationsMap {
		mapID := citem["id"].(int64)
		mapName := citem["name"].(string)
		countParamsMap[mapID] = make([]interface{}, 0)
		sqlMap[mapID] = fmt.Sprintf(" SELECT COUNT(ad.id) as count, '%d' AS complication, '%s' AS `name` FROM ", mapID, mapName)
		if statisticalState == 1 {
			sqlMap[mapID] += "xt_assessment_before_dislysis AS ad"
		} else {
			sqlMap[mapID] += "xt_assessment_after_dislysis AS ad"
		}
		likeKeyMap := make([]interface{}, 0)
		likeKeyMap = append(likeKeyMap, mapName)
		likeKeyMap = append(likeKeyMap, mapName+",%")
		likeKeyMap = append(likeKeyMap, "%,"+mapName)
		likeKeyMap = append(likeKeyMap, "%,"+mapName+",%")
		sqlMap[mapID] += " JOIN xt_patients as p ON p.id=ad.patient_id and p.user_org_id=? WHERE ad.user_org_id=? AND (complication = ? OR complication LIKE ? OR complication LIKE ? OR complication LIKE ?)"
		countParamsMap[mapID] = append(countParamsMap[mapID], orgID)
		countParamsMap[mapID] = append(countParamsMap[mapID], orgID)
		countParamsMap[mapID] = append(countParamsMap[mapID], likeKeyMap...)

	}

	loc, _ := time.LoadLocation("Local")
	nowTime := time.Now()
	nowDay := nowTime.Format("2006-01-02")
	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
	if err != nil {
		return
	}
	var timeStartPoint int64
	var timeEndPoint int64

	if age == 1 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-30, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		for key := range sqlMap {
			sqlMap[key] += " AND p.birthday>? and p.birthday<=?"
			countParamsMap[key] = append(countParamsMap[key], timeEndPoint)
			countParamsMap[key] = append(countParamsMap[key], timeStartPoint)
		}
	} else if age == 2 {
		timeStartPoint = dayTime.AddDate(-30, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-40, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		for key := range sqlMap {
			sqlMap[key] += " AND p.birthday>? and p.birthday<=?"
			countParamsMap[key] = append(countParamsMap[key], timeEndPoint)
			countParamsMap[key] = append(countParamsMap[key], timeStartPoint)
		}
	} else if age == 3 {
		timeStartPoint = dayTime.AddDate(-40, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		for key := range sqlMap {
			sqlMap[key] += " AND p.birthday>? and p.birthday<=?"
			countParamsMap[key] = append(countParamsMap[key], timeEndPoint)
			countParamsMap[key] = append(countParamsMap[key], timeStartPoint)
		}
	} else if age == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? or p.birthday<=?", timeStartPoint, timeEndPoint)
		for key := range sqlMap {
			sqlMap[key] += " AND (p.birthday>? or p.birthday<=?)"
			countParamsMap[key] = append(countParamsMap[key], timeStartPoint)
			countParamsMap[key] = append(countParamsMap[key], timeEndPoint)
		}
	}

	if isStartTime {
		db = db.Where("c.schedule_date>=?", startTime)
		for key := range sqlMap {
			sqlMap[key] += " AND ad.assessment_date>=?"
			countParamsMap[key] = append(countParamsMap[key], startTime)
		}
	}
	if isEndTime {
		db = db.Where("c.schedule_date<=?", endTime)
		for key := range sqlMap {
			sqlMap[key] += " AND ad.assessment_date<=?"
			countParamsMap[key] = append(countParamsMap[key], endTime)
		}
	}

	db = db.Where("c.status=1")
	for key := range sqlMap {
		sqlMap[key] += " AND ad.status=1"
		var pcp []*PAComplicationPieDataStruct
		err = readDb.Raw(sqlMap[key], countParamsMap[key]...).Find(&pcp).Error
		if err != nil {
			return
		}
		for _, item := range pcp {
			pcps = append(pcps, item)
		}
	}

	offset := (page - 1) * limit
	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date desc, c.schedule_type desc, c.id desc").Count(&total).Offset(offset).Limit(limit).Find(&complications).Error
	return
}

type PADiseasesCountPieStruct struct {
	Diseases int64 `json:"diseases"`
	Count    int64 `json:"count"`
}

func GetPAInfectiousDiseasesData(orgID, page, limit, lapseto, age, diseasesID, startTime, endTime int64, isStartTime, isEndTime bool) (patients []*models.Patients, dsp []*PADiseasesCountPieStruct, total int64, err error) {
	loc, _ := time.LoadLocation("Local")
	nowTime := time.Now()
	nowDay := nowTime.Format("2006-01-02")
	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
	if err != nil {
		return
	}
	var timeStartPoint int64
	var timeEndPoint int64

	db := readDb.Table("xt_patients as p")

	countSQL := "SELECT count(pid.id) as count, pid.disease_id as diseases FROM xt_patients as p JOIN xt_patients_infectious_diseases as pid ON pid.patient_id=p.id"
	countParams := make([]interface{}, 0)

	if diseasesID > 0 {
		db = db.Joins("JOIN xt_patients_infectious_diseases as pid ON pid.patient_id=p.id AND pid.disease_id=? AND pid.status=1", diseasesID)
		countSQL += " AND pid.disease_id=? "
		countParams = append(countParams, diseasesID)
	}
	countSQL += " AND pid.status=1 WHERE p.user_org_id = ? AND p.status=1"
	countParams = append(countParams, orgID)

	db = db.Where("p.user_org_id = ? AND p.status=1", orgID)
	if lapseto > 0 {
		db = db.Where("p.lapseto=?", lapseto)
		countSQL += " AND p.lapseto=?"
		countParams = append(countParams, lapseto)
	}

	if age == 1 {
		timeStartPoint = dayTime.AddDate(-20, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-30, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND p.birthday>? and p.birthday<=?"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 2 {
		timeStartPoint = dayTime.AddDate(-30, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-40, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND p.birthday>? and p.birthday<=?"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 3 {
		timeStartPoint = dayTime.AddDate(-40, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? and p.birthday<=?", timeEndPoint, timeStartPoint)
		countSQL += " AND p.birthday>? and p.birthday<=?"
		countParams = append(countParams, timeEndPoint)
		countParams = append(countParams, timeStartPoint)
	} else if age == 4 {
		timeStartPoint = dayTime.AddDate(-10, 0, 0).Unix()
		timeEndPoint = dayTime.AddDate(-50, 0, 0).Unix()
		db = db.Where("p.birthday>? or p.birthday<=?", timeStartPoint, timeEndPoint)
		countSQL += " AND (p.birthday>? or p.birthday<=?)"
		countParams = append(countParams, timeStartPoint)
		countParams = append(countParams, timeEndPoint)
	}

	if isStartTime {
		db = db.Where("p.created_time>=?", startTime)
		countSQL += " AND p.created_time>=?"
		countParams = append(countParams, startTime)
	}
	if isEndTime {
		db = db.Where("p.created_time<=?", endTime)
		countSQL += " AND p.created_time<=?"
		countParams = append(countParams, endTime)
	}

	countSQL += " GROUP BY pid.disease_id"
	err = readDb.Raw(countSQL, countParams...).Find(&dsp).Error
	if err != nil {
		return
	}

	offset := (page - 1) * limit
	err = db.Select("p.id, p.user_org_id, p.user_id, p.avatar, p.patient_type, p.dialysis_no, p.admission_number, p.source, p.lapseto, p.partition_id, p.bed_id, p.name, p.alias, p.gender, p.nation, p.native_place, p.marital_status, p.id_card_no, p.birthday, p.reimbursement_way_id, p.health_care_type, p.health_care_no, p.health_care_due_date, p.height, p.blood_type, p.rh, p.health_care_due_alert_date, p.education_level, p.profession, p.phone, p.home_telephone, p.relative_phone, p.relative_relations, p.home_address, p.work_unit, p.unit_address, p.children, p.receiving_date, p.is_hospital_first_dialysis, p.first_dialysis_date, p.first_dialysis_hospital, p.predialysis_condition, p.pre_hospital_dialysis_frequency, p.pre_hospital_dialysis_times, p.hospital_first_dialysis_date, p.induction_period, p.initial_dialysis, p.total_dialysis, p.attending_doctor_id, p.head_nurse_id, p.evaluate, p.diagnose, p.remark, p.registrars_id, p.registrars, p.qr_code, p.binding_state, p.patient_complains, p.present_history, p.past_history, p.temperature, p.pulse, p.respiratory, p.sbp, p.dbp, p.status, p.created_time, p.updated_time").
		Preload("Contagions", "status = 1").
		Count(&total).Order("p.id desc").Offset(offset).Limit(limit).Find(&patients).Error

	if err != nil {
		return
	}

	return
}

func GetPersonLapsetoData(orgID, patientID, page, limit int64) (*models.Patients, []*models.PatientLapseto, int64, error) {
	var patient models.Patients
	var pls []*models.PatientLapseto
	var total int64
	var err error

	err = readDb.Model(&models.Patients{}).Where("user_org_id =? and id=?", orgID, patientID).First(&patient).Error
	if patient.ID == 0 {
		return nil, pls, total, err
	}
	offset := (page - 1) * limit
	err = readDb.Model(&models.PatientLapseto{}).Where("patient_id=? and status=1", patientID).Count(&total).Offset(offset).Limit(limit).Order("lapseto_time desc, id desc").Find(&pls).Error
	if err != nil {
		return nil, pls, total, err
	}
	return &patient, pls, total, err
}

func GetPersonWeightData(orgID, patientID, page, limit, startTime, endTime int64, isStartTime, isEndTime bool) (*models.Patients, []*PAWeightDataStruct, []*PAWeightDataStruct, int64, error) {
	var patient models.Patients
	var weight []*PAWeightDataStruct
	var pie []*PAWeightDataStruct
	var total int64
	var err error
	err = readDb.Model(&models.Patients{}).Where("user_org_id =? and id=?", orgID, patientID).First(&patient).Error
	if patient.ID == 0 {
		return nil, weight, pie, total, err
	}

	db := readDb.Table("xt_schedule as c").Joins("JOIN xt_patients as p ON p.id=c.patient_id and p.user_org_id=? and p.id=?", orgID, patientID)

	db = db.Where("c.patient_id=?", patientID)
	if isStartTime {
		db = db.Where("c.schedule_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("c.schedule_date<=?", endTime)
	}

	db = db.Where("c.status=1")

	offset := (page - 1) * limit
	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date desc, c.schedule_type desc, c.id desc").Count(&total).Offset(offset).Limit(limit).Find(&weight).Error
	if err != nil {
		return nil, weight, pie, total, err
	}

	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date asc, c.schedule_type asc, c.id asc").Find(&pie).Error
	if err != nil {
		return nil, weight, pie, total, err
	}
	return &patient, weight, pie, total, err
}

func GetPersonBloodPressureData(orgID, patientID, page, limit, startTime, endTime int64, isStartTime, isEndTime bool) (*models.Patients, []*PABloodPressureDataStruct, []*PABloodPressureDataStruct, int64, error) {
	var patient models.Patients
	var bloodPressures []*PABloodPressureDataStruct
	var lines []*PABloodPressureDataStruct
	var total int64
	var err error
	err = readDb.Model(&models.Patients{}).Where("user_org_id =? and id=?", orgID, patientID).First(&patient).Error
	if patient.ID == 0 {
		return nil, bloodPressures, lines, total, err
	}

	db := readDb.Table("xt_schedule as c").Joins("JOIN xt_patients as p ON p.id=c.patient_id and p.user_org_id=? and c.patient_id=? and p.id = ?", orgID, patientID, patientID)

	if isStartTime {
		db = db.Where("c.schedule_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("c.schedule_date<=?", endTime)
	}

	db = db.Where("c.patient_id=? AND c.status=1", patientID)

	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("MonitoringRecord", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date asc, c.schedule_type asc, c.id asc").Find(&lines).Error
	if err != nil {
		return &patient, bloodPressures, lines, total, err
	}

	offset := (page - 1) * limit
	err = db.Select("c.id, c.user_org_id, c.partition_id, c.bed_id, c.patient_id, c.schedule_date, c.schedule_type, c.schedule_week, c.mode_id, c.status, c.created_time, c.updated_time").
		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentAfterDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("AssessmentBeforeDislysis", "user_org_id = ? AND status = 1", orgID).
		Preload("MonitoringRecord", "user_org_id = ? AND status = 1", orgID).
		Order("c.schedule_date desc, c.schedule_type desc, c.id desc").Count(&total).Offset(offset).Limit(limit).Find(&bloodPressures).Error
	return &patient, bloodPressures, lines, total, err
}

func GetPersonICData(orgID, patientID, page, limit int64) (*models.Patients, []*models.Inspection, []*models.InspectionReference, int64, error) {
	var patient models.Patients
	var inspections []*models.Inspection
	var references []*models.InspectionReference
	var total int64
	var err error
	err = readDb.Model(&models.Patients{}).Where("user_org_id =? and id=?", orgID, patientID).First(&patient).Error
	if patient.ID == 0 {
		return nil, inspections, references, total, err
	}

	err = readDb.Table("xt_inspection_reference").Order("project_id").Find(&references).Error
	if err != nil || len(references) == 0 {
		return nil, inspections, references, total, err
	}

	db := readDb.Table("xt_inspection as i").Where("i.patient_id=?", patientID)
	if orgID > 0 {
		db = db.Where("i.org_id=?", orgID)
	}
	db = db.Where("i.status=1")

	offset := (page - 1) * limit

	var ds []*PIInspectionPageStruct
	err = db.Select("i.inspect_date").Group("inspect_date").Count(&total).Order("inspect_date desc, i.created_time desc, i.id asc").Offset(offset).Limit(limit).Find(&ds).Error
	if err != nil {
		return nil, inspections, references, total, err
	}

	dates := make([]int64, 0)
	if len(ds) > 0 {
		for _, d := range ds {
			dates = append(dates, d.InspectDate)
		}

		db = db.Where("i.inspect_date IN (?)", dates)
	}

	err = db.Select("i.id, i.patient_id, org_id, i.project_id, i.item_id, i.item_name, i.project_name, i.inspect_type, i.inspect_value, i.inspect_date, i.status, i.created_time, i.updated_time").Order("inspect_date desc, created_time desc, id asc, patient_id asc").Find(&inspections).Error
	if err != nil {
		return nil, inspections, references, total, err
	}

	return &patient, inspections, references, total, err
}

func GetPersonAdviceData(orgID, patientID, page, limit, adviceType, medicalType, startTime, endTime int64, isStartTime, isEndTime bool) (*models.Patients, []*models.DoctorAdvice, int64, error) {
	var patient models.Patients
	var advices []*models.DoctorAdvice
	var total int64
	var err error
	err = readDb.Model(&models.Patients{}).Where("user_org_id =? and id=?", orgID, patientID).First(&patient).Error
	if patient.ID == 0 {
		return nil, advices, total, err
	}

	db := readDb.Table("xt_doctor_advice as da").Where("da.patient_id=? and da.delivery_way='口服'", patientID)
	if orgID > 0 {
		db = db.Where("da.user_org_id=?", orgID)
	}

	db = db.Where("da.status=1")

	if adviceType > 0 {
		db = db.Where("da.advice_type=?", adviceType)
	} else {
		db = db.Where("da.advice_type IN (1,2)")
	}

	if isStartTime {
		db = db.Where("da.advice_date>=?", startTime)
	}
	if isEndTime {
		db = db.Where("da.advice_date<=?", endTime)
	}

	offset := (page - 1) * limit

	var groups []*models.DoctorAdvice
	err = db.Select("da.id, da.user_org_id, da.patient_id, da.advice_type, da.advice_date, da.record_date, da.start_time, da.advice_name, da.advice_desc, da.reminder_date, da.drug_spec, da.drug_spec_unit, da.single_dose, da.single_dose_unit, da.prescribing_number, da.prescribing_number_unit, da.delivery_way, da.execution_frequency, da.advice_doctor, da.status, da.created_time,da.updated_time, da.advice_affirm, da.remark, da.stop_time, da.stop_reason, da.stop_doctor, da.stop_state, da.parent_id, da.execution_time, da.execution_staff, da.execution_state, da.checker, da.check_state, da.check_time, da.groupno, IF(da.parent_id > 0, da.parent_id, da.id) as advice_order").Group("da.groupno").Count(&total).Order("da.start_time desc, da.groupno desc, advice_order desc, da.id asc").Offset(offset).Limit(limit).Find(&groups).Error
	if err != nil {
		return nil, advices, total, err
	}

	if len(groups) > 0 {
		gs := make([]int64, 0)
		for _, g := range groups {
			gs = append(gs, g.GroupNo)
		}
		db = db.Where("da.groupno IN (?)", gs)
	}

	err = db.Select("da.id, da.user_org_id, da.patient_id, da.advice_type, da.advice_date, da.record_date, da.start_time, da.advice_name, da.advice_desc, da.reminder_date, da.drug_spec, da.drug_spec_unit, da.single_dose, da.single_dose_unit, da.prescribing_number, da.prescribing_number_unit, da.delivery_way, da.execution_frequency, da.advice_doctor, da.status, da.created_time,da.updated_time, da.advice_affirm, da.remark, da.stop_time, da.stop_reason, da.stop_doctor, da.stop_state, da.parent_id, da.execution_time, da.execution_staff, da.execution_state, da.checker, da.check_state, da.check_time, da.groupno, IF(da.parent_id > 0, da.parent_id, da.id) as advice_order").Order("da.start_time desc, da.groupno desc, advice_order desc, da.id asc").Find(&advices).Error
	if err != nil {
		return nil, advices, total, err
	}

	return &patient, advices, total, err
}