XT_New/service/auto_create_week_disinfecti...

package service

import (
	"XT_New/models"
	"XT_New/utils"
	"fmt"
	"github.com/jinzhu/gorm"
	"github.com/robfig/cron"
	"strconv"
	"time"
)

// cron表达式 https://www.cnblogs.com/zuxingyu/p/6023919.html
var createWeekDisinfectionCronJob *cron.Cron

func init() {
	createWeekDisinfectionCronJob = cron.New()
	spec := "0 50 23 * * ?" // 每天23点执行一次
	//spec := "0 55 23 * * ?" // 每天23点55执行一次
	//spec := "0 0 5 * * ?" // 每天23点55执行一次
	//spec := "0 */1 * * * ?" // 每1分钟执行一次
	createWeekDisinfectionCronJob.AddFunc(spec, func() {

		AutoCreateWeekDisinfectionJob()
	})
}

func BeginAutoCreateWeekDisinfectionJob() {

	createWeekDisinfectionCronJob.Start()
}

func AutoCreateWeekDisinfectionJob() {
	fmt.Println("开始执行-----------------------------------------------")
	timeStr := time.Now().Format("2006-01-02")
	timeLayout := "2006-01-02 15:04:05"
	fmt.Println("timeStr:", timeStr)
	timeStringToTime, _ := utils.ParseTimeStringToTime(timeLayout, timeStr+" 00:00:00")
	timenow := timeStringToTime.Unix()
	fmt.Println("timenow是什么", timenow)
	//查询当天排班所有机构
	org, errs := GetAllOrgID(timenow)
	fmt.Print("错误是什么", errs)
	//fmt.Println("查询有机构失败", err)
	for _, item := range org {
		//查询机构是否开启自动使用登记
		remander, errs := GetRemanderDatas(item.UserOrgId)
		fmt.Print("查询自动使用登记错误", errs)
		//开启
		if remander.IsRun == 1 {
			fmt.Println("机构id", item.UserOrgId)
			//查询当天机构的所有下机病人id
			order, _ := GetAllPatientByOrgID(item.UserOrgId, timenow)
			for _, it := range order {
				//fmt.Println("病人", it.PatientId)

				//查询病人信息
				patients, err := GetPatientInformation(it.PatientId, it.UserOrgId)
				fmt.Println("查询病人信息报错", err)
				var con = ""
				if patients.IsInfectious == 0 {
					con = ""
				}
				if patients.IsInfectious == 1 {
					con = "无"
				}
				if patients.IsInfectious == 2 {
					con = "有"
				}
				//fmt.Print("con------------------------", con)
				//	fmt.Print("传染病", patients.IsInfectious)
				//查询病人的班次
				//schedules, _ := GetAllPatientSchedule(it.PatientId, it.UserOrgId,timenow)
				schedules, _ := GetAllPatientSchedule(it.PatientId, it.UserOrgId, timenow)
				fmt.Println("班次", schedules.ScheduleType)
				//查询病人今日的透析模式
				prescription, _ := GetDialysisPrescription(it.PatientId, it.UserOrgId, timenow)
				fmt.Println("透析模式", prescription.ModeId)

				//查询病人今日透后评估数据
				dislysis, err := GetAssessmentAfterDissData(it.PatientId, it.UserOrgId, timenow)
				fmt.Println("透后评估错误", err)
				fmt.Print("透析时长", dislysis.ActualTreatmentHour+'h'+dislysis.ActualTreatmentMinute+'m'+'i'+'n')
				//			//根据床位号获取设备id
				addmacher, _ := GetEquimentID(schedules.BedId, it.UserOrgId)
				//unitype, err := strconv.ParseInt(addmacher.UnitType, 10, 64)
				fmt.Println(" 设备id", addmacher.ID)
				//根据设备id获取设备类型
				//equimentname, _ := GetAddmacher(addmacher.ID, it.UserOrgId)

				fmt.Println("班次", it.SchedualType)
				//查看该设备是否有消毒计划，无怎返回,有则添加
				plan, errplan := GetDisinfection(addmacher.UnitType, it.SchedualType, it.UserOrgId)
				fmt.Print("plan", plan)
				fmt.Println("错误是什么", errplan)
				if errplan == gorm.ErrRecordNotFound {
					fmt.Println("该设备无消毒计划")
					continue
				} else if errplan == nil {
					//fmt.Println("消毒时长", plan.DisinfecTime)
					//fmt.Println("基表消毒方式", plan.Way)
					//fmt.Println("基表消毒液", plan.MachineDisinfectant)
					//fmt.Println("液路消毒方式", plan.DisinfectanWay)
					//fmt.Println("液路消毒液", plan.Disinfectant)
					//fmt.Println("上机时间", it.StartTime)
					//fmt.Println("下机时间", it.EndTime)
					//fmt.Println("传染病", con)
					//fmt.Println("体重减少", strconv.FormatFloat(dislysis.WeightLoss, 'f', -1, 64))
					//fmt.Println("时间超滤量", strconv.FormatFloat(dislysis.ActualUltrafiltration, 'f', -1, 64))
					//fmt.Println("透析时长", strconv.FormatInt(dislysis.ActualTreatmentHour, 10))
					//查询该病人是否有记录，无记录的则添加
					information, errcode := GetInfor(it.PatientId, timenow, it.UserOrgId, it.SchedualType)
					//fmt.Println("errcode是什么", errcode)
					fmt.Println("information", information)
					if errcode == gorm.ErrRecordNotFound {
						information := models.DeviceInformation{
							Date:                  timenow,
							Zone:                  schedules.PartitionId,
							Class:                 it.SchedualType,
							BedNumber:             schedules.BedId,
							PatientId:             schedules.PatientId,
							DialysisMode:          prescription.ModeId,
							LongTime:              strconv.FormatInt(plan.DisinfecTime, 10),
							Disinfection:          1,
							DialysisConcentration: 1,
							DisinfectionStatus:    1,
							Move:                  1,
							UserOrgId:             it.UserOrgId,
							DisinfectType:         plan.Way,                 //基表消毒方式
							DisinfectantType:      plan.MachineDisinfectant, //基表消毒液
							FluidPath:             plan.DisinfectanWay,      //液路消毒方式
							Disinfectant:          plan.Disinfectant,        //液路消毒液
							Ctime:                 time.Now().Unix(),
							Status:                1,
							SignName:              it.FinishNurse,
							EquimentId:            addmacher.ID,
							DisinfectionResidue:   2,
							Bed:                   addmacher.BedNumber,
							StartTime:             it.StartTime,
							EndTime:               it.EndTime,
							Contagion:             con,
							WeightLoss:            dislysis.WeightLoss,
							Hyperfiltratio:        dislysis.ActualUltrafiltration,
							DialysisHour:          strconv.FormatInt(dislysis.ActualTreatmentHour, 10),
							MachineRun:            1,
						}
						err := CreateInformation(&information)
						fmt.Println("报错", err)
					} else if errcode == nil {

					} else {

					}
				} else {

					return
				}
			}
		}

		//关闭
		if remander.IsRun == 2 {
			fmt.Print("已关闭")
		}
	}

}

//
//func GetAllOrgID(status int64) (org []*models.Org, err error) {
//
//	err = UserReadDB().Where("status = ?", status).Find(&org).Error
//
//	return org, err
//}

// 查询当天有排班的所有机构
func GetAllOrgID(time int64) (schedule []*models.XtSchedule, err error) {

	err = XTReadDB().Raw("select user_org_id,id,partition_id,bed_id,patient_id,schedule_date,schedule_type,schedule_week,mode_id from xt_schedule where schedule_date = ?  group by user_org_id", time).Scan(&schedule).Error

	return schedule, err
}

func GetAllPatientByOrgID(orgid int64, timenow int64) (order []*models.DialysisOrder, err error) {

	err = XTReadDB().Where("user_org_id = ? AND dialysis_date = ? AND stage = 2 AND status = ?", orgid, timenow, 1).Find(&order).Error
	return order, err
}

func CreateInformation(information *models.DeviceInformation) error {
	err := UserWriteDB().Create(&information).Error
	return err
}

func GetAllPatientSchedule(patientid int64, orgID int64, timenow int64) (models.Schedule, error) {
	schedules := models.Schedule{}
	err := XTReadDB().Where("patient_id = ? AND user_org_id = ? AND schedule_date = ?", patientid, orgID, timenow).Find(&schedules).Error
	return schedules, err
}

func GetInfor(patientid int64, timenow int64, orgid int64, class int64) (*models.DeviceInformation, error) {
	var pre models.DeviceInformation
	var err error
	err = readUserDb.Model(&pre).Where("patient_id = ? AND date = ? AND user_org_id = ? AND class = ? AND status = 1", patientid, timenow, orgid, class).Find(&pre).Error
	if err == gorm.ErrRecordNotFound {
		return nil, err
	}
	if err != nil {
		return nil, err
	}
	return &pre, nil
}

func GetDisinfection(equitType int64, scheduleType int64, orgID int64) (*models.DevicePlan, error) {
	var plan models.DevicePlan
	var err error
	err = readUserDb.Model(&plan).Where("device_type = ? AND classtime = ? AND user_org_id = ? AND status = 1", equitType, scheduleType, orgID).Find(&plan).Error
	if err == gorm.ErrRecordNotFound {
		return nil, err
	}
	if err != nil {
		return nil, err
	}
	return &plan, nil
}

func GetDialysisPrescription(patientid int64, orgID int64, timenow int64) (models.DialysisPrescription, error) {
	prescription := models.DialysisPrescription{}
	err := XTReadDB().Model(&prescription).Where("patient_id = ? AND user_org_id = ? AND record_date = ?", patientid, orgID, timenow).Find(&prescription).Error
	return prescription, err
}

func GetAssessmentAfterDissData(patientid int64, orgID int64, timenow int64) (models.XtAssessmentAfterDislysis, error) {
	dislysis := models.XtAssessmentAfterDislysis{}
	err := XTReadDB().Where("patient_id = ? AND user_org_id = ? AND assessment_date = ?", patientid, orgID, timenow).Find(&dislysis).Error
	return dislysis, err
}

func GetEquimentID(bedId int64, orgID int64) (models.DeviceAddmacher, error) {
	addmacher := models.DeviceAddmacher{}
	err := readUserDb.Model(&addmacher).Where("bed_id = ? AND user_org_id = ? AND status = ?", bedId, orgID, 1).Find(&addmacher).Error
	return addmacher, err
}

func GetAddmacher(equitmentid int64, orgid int64) (models.DeviceEquimentname, error) {
	equimentname := models.DeviceEquimentname{}
	err := readUserDb.Model(&equimentname).Where("equitment_id = ? AND user_org_id = ? AND status = 1", equitmentid, orgid).Find(&equimentname).Error
	return equimentname, err
}

func GetPatientInformation(id int64, orgid int64) (models.Patients, error) {
	patients := models.Patients{}
	err := XTReadDB().Where("id = ? AND user_org_id = ?", id, orgid).Find(&patients).Error
	return patients, err
}

func GetRemanderDatas(orgid int64) (remander models.DeviceRemander, err error) {

	err = UserReadDB().Model(&models.DeviceRemander{}).Where("user_org_id = ? and status = 1", orgid).Find(&remander).Error
	return
}