Data_Upload_Api/service/city_data_uoload_service.go

// 统计后台的 service

package service

import (
	"Data_Upload_Api/models"
	"Data_Upload_Api/models/sz"

	"github.com/jinzhu/gorm"
	"strings"
)

func GetSyncTimeByOrgId(org_id int64, sync_type int64) (sync_info models.XTSyncInfo, err error) {
	err = readDb.Model(&models.XTSyncInfo{}).Where("org_id = ? and sync_type = ? ", org_id, sync_type).Last(&sync_info).Error
	return
}

func FindAllDataUploadConfigOrgInfo(province_id int64, city_id int64, config_type int64) (data []*sz.DataUploadConfig, err error) {
	err = readDb.Model(&sz.DataUploadConfig{}).Where("status = 1 AND province_id = ? AND city_id = ? AND config_type = ?", province_id, city_id, config_type).Find(&data).Error
	return
}

func FindDataUploadOrgInfo(org_id int64, module_type int64) (data sz.DataUpload, err error) {
	err = readDb.Model(&sz.DataUpload{}).Where(" org_id = ? AND module_type = ?", org_id, module_type).Last(&data).Error
	return
}

func FindOrgData(org_id int64, sync_time int64) (org models.UserOrg, err error) {
	err = readUserDb.Model(&models.UserOrg{}).Where("status = 1 AND id = ? AND ctime > ?", org_id, sync_time).Preload("DeviceNumber", func(db *gorm.DB) *gorm.DB {
		return readDb.Where("status = 1")
	}).Find(&org).Error
	return
}
func FindOrgRolesData(org_id int64, lastUploadTime int64, nowTime int64) (role []*models.UserAdminRole, err error) {
	db := readUserDb.Model(&models.UserAdminRole{}).Where("status = 1 AND org_id = ?  ", org_id)
	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)
	err = db.Find(&role).Error
	return
}
func FindOrgPatientData(org_id int64, lastUploadTime int64, nowTime int64) (patient []*models.Patients, err error) {
	db := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ?", org_id)
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&patient).Error

	return
}

func FindOrgPatientDataOne(org_id int64) (patient []*models.Patients, err error) {
	db := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ?", org_id)
	err = db.Find(&patient).Error
	return
}

func FindOrgPatientInfectious(org_id int64, lastUploadTime int64, nowTime int64) (patient []*models.Patients, err error) {
	db := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ? AND lapseto = 2 ", org_id)
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&patient).Error
	return
}

func FindOrgDeviceNumber(org_id int64, lastUploadTime int64, nowTime int64) (devices []*models.DeviceNumber, err error) {
	db := readDb.Model(&models.DeviceNumber{}).Where("status = 1 AND org_id = ?", org_id)
	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)
	err = db.Find(&devices).Error

	return
}

func FindOrgPatientOutData(org_id int64, lastUploadTime int64, nowTime int64) (patient []*models.Patients, err error) {
	db := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ? AND lapseto = 2 ", org_id).Preload("PatientLapseto", "status = 1")
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&patient).Error
	return
}

func FindOrgScheduleData(org_id int64, lastUploadTime int64, nowTime int64) (sch []*models.Schedule, err error) {
	db := readDb.Model(&models.Schedule{}).Where("status = 1 AND user_org_id = ?", org_id).Preload("DeviceNumber", "status = 1")

	if lastUploadTime != 0 && nowTime != 0 {
		db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	}
	err = db.Find(&sch).Error
	return
}

func FindOrgDialysisPrescriptionData(org_id int64, lastUploadTime int64, nowTime int64) (ps []*models.DialysisPrescription, err error) {
	db := readDb.Model(&models.DialysisPrescription{}).Where("status = 1 AND user_org_id = ?", org_id).Preload("DialysisOrder", "status = 1")
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&ps).Error
	return
}

func FindOrgDoctorAdviceTemplateData(org_id int64, lastUploadTime int64, nowTime int64) (advice []*models.DoctorAdviceTemplate, err error) {
	db := readDb.Model(&models.DoctorAdviceTemplate{}).Where("status = 1 AND org_id = ? and advice_type = 0 ", org_id)
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&advice).Error
	return
}

func FindAssessmentBeforeDislysis(org_id int64, patient_id int64) (before models.AssessmentBeforeDislysis, err error) {
	db := readDb.Model(&models.AssessmentBeforeDislysis{}).Where("status = 1 AND user_org_id = ? and patient_id = ? ", org_id, patient_id)
	err = db.Last(&before).Error
	return
}

func FindOrgMonitorRecordData(org_id int64, lastUploadTime int64, nowTime int64) (monitor []*models.MonitoringRecord, err error) {
	db := readDb.Model(&models.MonitoringRecord{}).Where("status = 1 AND user_org_id = ?", org_id).Preload("DialysisOrder", "status = 1")
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&monitor).Error
	return
}

func FindOrgMonitorRecordByLike(org_id int64, keyword string, lastUploadTime int64, nowTime int64) (monitor []*models.MonitoringRecord, err error) {
	db := readDb.Model(&models.MonitoringRecord{}).Where("status = 1 AND user_org_id = ? AND symptom like ?", org_id, keyword)
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&monitor).Error
	return
}

func FindOrgInspection(org_id int64, lastUploadTime int64, nowTime int64) (inspection []*models.XtInspection, err error) {
	db := readDb.Model(&models.XtInspection{}).Where("status = 1 AND org_id = ? ", org_id).Preload("Patients", "status = 1")
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&inspection).Error
	return
}

// 传染病查询
func FindOrgInspectionGroupOne(org_id int64, lastUploadTime int64, nowTime int64, patient_id int64) (inspection []*models.XtInspection, err error) {
	db := readDb.Model(&models.XtInspection{}).Where("status = 1 AND org_id = ? and project_id = 14 and patient_id = ?", org_id, patient_id)
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime).Group("inspect_date")
	err = db.Find(&inspection).Error
	return
}

// 传染病查询
func FindOrgInspectionGroupTwo(org_id int64, inspect_date int64, patient_id int64) (inspection []*models.XtInspection, err error) {
	db := readDb.Model(&models.XtInspection{}).Where("status = 1 AND org_id = ? and project_id = 14 and patient_id = ? and inspect_date = ?", org_id, patient_id, inspect_date)
	err = db.Find(&inspection).Error
	return
}

func FindOrgInspectionReference(org_id int64, lastUploadTime int64, nowTime int64) (inspection []*models.XtInspection, err error) {
	db := readDb.Model(&models.XtInspection{}).Where("status = 1 AND org_id = ? ", org_id).Preload("XtInspectionReference", "status = 1")
	db = db.Where("created_time >= ? AND created_time <= ?", lastUploadTime, nowTime)
	err = db.Find(&inspection).Error
	return
}

func CreateOrgRecord(rdb *gorm.DB, hospital *sz.TempHdHospital) (err error) {
	err = rdb.Model(&sz.TempHdHospital{}).Create(&hospital).Error
	return
}

func CreateUploadRecord(upload *sz.DataUpload) (err error) {
	err = writeDb.Model(&sz.DataUpload{}).Create(&upload).Error
	return
}

func FindOrgDialysisData(org_id int64, lastUploadTime int64, nowTime int64) (ps []*models.VMDialysisOrder, err error) {
	db := readDb.Model(&models.VMDialysisOrder{}).Where("status = 1 AND user_org_id = ? AND stage = 2 ", org_id).
		Preload("DeviceNumber", "status = 1").
		Preload("VMDialysisPrescription", "status = 1").
		Preload("AssessmentBeforeDislysis", "status = 1").
		Preload("AssessmentAfterDislysis", "status = 1").
		Preload("Schedule", "status = 1").
		Preload("MonitoringRecord", "status = 1")

	if lastUploadTime != 0 && nowTime != 0 {
		db = db.Where("updated_time >= ? AND updated_time <= ?", lastUploadTime, nowTime)
	}
	err = db.Find(&ps).Error
	return
}
func FindOrgDeviceZoneRecordData(org_id int64, lastUploadTime int64, nowTime int64) (zone []*models.DeviceZone, err error) {
	db := readDb.Model(&models.DeviceZone{}).Where("status = 1 AND  org_id = ?", org_id)
	if lastUploadTime != 0 && nowTime != 0 {
		db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)
	}
	err = db.Find(&zone).Error

	return
}

func FindOrgWaterMachineData(org_id int64, lastUploadTime int64, nowTime int64) (waterMachine []*models.VMDeviceAddmacher, err error) {

	db := readUserDb.Model(&models.VMDeviceAddmacher{}).Where("status = 1 AND  user_org_id = ? AND  device_type = 2", org_id)

	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)

	err = db.Find(&waterMachine).Error

	return
}

func BatchCreateWMsRecord(wms []*sz.TempHdWm, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			thisSQL := "INSERT INTO t_hd_wm (hospital_id, equipment_id, equipment_brand, equipment_model, enable_time,discarded_time,equipment_type,xgbz,create_time,update_time,sjscsj) VALUES "
			insertParams := make([]string, 0)
			insertData := make([]interface{}, 0)
			for _, wm := range wms {
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquipmentId)
				insertData = append(insertData, wm.EquipmentBrand)
				insertData = append(insertData, wm.EquipmentModel)
				insertData = append(insertData, wm.EnableTime)
				insertData = append(insertData, wm.DiscardedTime)
				insertData = append(insertData, wm.EquipmentType)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)

			}
			thisSQL += strings.Join(insertParams, ", ")
			// err = utx.Exec(thisSQL, insertData...).Error
			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
			utx.Exec(thisSQL, insertData...)
		}
		utx.Commit()
	}
	return
}

func BatchCreateStaffRecord(staffs []*sz.TempHdStaff, rdb *gorm.DB) (err error) {
	if len(staffs) > 0 {
		utx := rdb
		if len(staffs) > 0 {
			id_no := 429001198701091670
			for _, info := range staffs {
				thisSQL := "INSERT INTO t_hd_staff (hospital_id,staff_id, id_no,id_type,staff_name,  position,  staff_status, staff_no, permanent_type, in_date ,create_time, update_time, sjscsj, xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?)")

				insertData = append(insertData, info.HospitalId)
				insertData = append(insertData, info.StaffId)
				insertData = append(insertData, id_no)
				insertData = append(insertData, "01")
				insertData = append(insertData, info.StaffName)
				insertData = append(insertData, info.Position)
				insertData = append(insertData, "0")
				insertData = append(insertData, info.StaffId)
				insertData = append(insertData, info.PermanentType)
				insertData = append(insertData, "2019-09-01")
				insertData = append(insertData, info.CreateTime)
				insertData = append(insertData, info.UpdateTime)
				insertData = append(insertData, info.Sjscsj)
				insertData = append(insertData, info.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
				id_no++
			}

		}
		// utx.Commit()
	}
	return
}

func BatchCreatePatinet(patients []*sz.TempHdPatient, rdb *gorm.DB) (err error) {
	if len(patients) > 0 {
		utx := rdb
		if len(patients) > 0 {

			for _, info := range patients {
				thisSQL := "INSERT INTO t_hd_patient ( hospital_id, patient_nk,  card_no,  card_type,  id_no, id_type, patient_name, gender, born_date, diagnosis_summary, is_crf, pay_method, local_insurance, dialysis_start_time, local_start_time, outpatient_no, hospitalized_no, xgbz, create_time, update_time, sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, info.HospitalId)
				insertData = append(insertData, info.PatientNk)
				insertData = append(insertData, info.CardNo)
				insertData = append(insertData, info.CardType)
				insertData = append(insertData, info.IdNo)
				insertData = append(insertData, info.IdType)
				insertData = append(insertData, info.PatientName)
				insertData = append(insertData, info.Gender)
				insertData = append(insertData, info.BornDate)
				insertData = append(insertData, info.DiagnosisSummary)
				insertData = append(insertData, info.IsCrf)
				insertData = append(insertData, "02")
				insertData = append(insertData, "1")
				insertData = append(insertData, info.DialysisStartTime)
				insertData = append(insertData, info.LocalStartTime)
				insertData = append(insertData, info.OutpatientNo)
				insertData = append(insertData, info.HospitalizedNo)
				insertData = append(insertData, info.Xgbz)
				insertData = append(insertData, info.CreateTime)
				insertData = append(insertData, info.UpdateTime)
				insertData = append(insertData, info.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

		}
		// utx.Commit()
	}
	return
}

func BatchCreateSchedual(patients []*sz.TempHdShift, rdb *gorm.DB) (err error) {
	if len(patients) > 0 {
		utx := rdb
		if len(patients) > 0 {
			for _, info := range patients {
				thisSQL := "INSERT INTO t_hd_shift (ps_id, hospital_id, patient_nk, schedule_date, shift_type,sickbed_no,schedule_status,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, info.PsId)
				insertData = append(insertData, info.HospitalId)
				insertData = append(insertData, info.PatientNk)
				insertData = append(insertData, info.ScheduleDate)
				insertData = append(insertData, info.ShiftType)
				insertData = append(insertData, info.SickbedNo)
				insertData = append(insertData, info.ScheduleStatus)
				insertData = append(insertData, info.CreateTime)
				insertData = append(insertData, info.Sjscsj)
				insertData = append(insertData, info.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

		}
		// utx.Commit()
	}
	return
}

func BatchCreatePs(patients []*sz.TempHdPs, rdb *gorm.DB) (err error) {
	if len(patients) > 0 {
		utx := rdb
		if len(patients) > 0 {
			thisSQL := "INSERT INTO t_hd_ps (prescribe_id,hospital_id,patient_nk,rrt_type,rrt_type_name,dialysis_frequency,frequency_unit,prescribe_time,create_time,sjscsj,xgbz) VALUES "
			insertParams := make([]string, 0)
			insertData := make([]interface{}, 0)
			for _, info := range patients {
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, info.PrescribeId)
				insertData = append(insertData, info.HospitalId)
				insertData = append(insertData, info.PatientNk)
				insertData = append(insertData, info.RrtType)
				insertData = append(insertData, info.RrtTypeName)
				insertData = append(insertData, info.DialysisFrequency)
				insertData = append(insertData, info.FrequencyUnit)
				insertData = append(insertData, info.PrescribeTime)
				insertData = append(insertData, info.CreateTime)
				insertData = append(insertData, info.Sjscsj)
				insertData = append(insertData, info.Xgbz)

			}
			thisSQL += strings.Join(insertParams, ", ")
			// err = utx.Exec(thisSQL, insertData...).Error
			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
			utx.Exec(thisSQL, insertData...)
		}
		// utx.Commit()
	}
	return
}

func BatchCreatePsOther(ps *sz.TempHdPs, rdb *gorm.DB) (err error) {
	err = rdb.Create(&ps).Error
	return err
}

func BatchCreatePsm(psms []*sz.TempHdPsMedicine, rdb *gorm.DB) (err error) {
	if len(psms) > 0 {
		utx := rdb
		if len(psms) > 0 {

			for _, psm := range psms {
				thisSQL := "INSERT INTO t_hd_ps_medicine (hospital_id, medicine_type_id,medicine_id,create_time,sjscsj,xgbz,sn) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?)")
				insertData = append(insertData, psm.HospitalId)
				insertData = append(insertData, psm.MedicineTypeId)
				insertData = append(insertData, psm.MedicineId)
				insertData = append(insertData, psm.CreateTime)
				insertData = append(insertData, psm.Sjscsj)
				insertData = append(insertData, psm.Xgbz)
				insertData = append(insertData, psm.Sn)
				thisSQL += strings.Join(insertParams, ", ")
				// err = utx.Exec(thisSQL, insertData...).Error
				utx.Exec(thisSQL, insertData...)
			}

			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func BatchCreateDialysis(psms []*sz.TempHdDialysis, rdb *gorm.DB) (err error) {
	if len(psms) > 0 {
		utx := rdb
		if len(psms) > 0 {

			for _, psm := range psms {
				thisSQL := "INSERT INTO t_hd_dialysis (dialysis_id,hospital_id,patient_nk,ps_id,dialysis_date,sickbed_no,division_id,equipment_id,mix_dialysis,ufv,total_treat_duration,is_hospitalization,is_emergency,is_perioperative_period,before_sbp,before_dbp,after_sbp,after_dbp,before_weight,after_weight,up_nurse_id,down_nurse_id,check_nurse_id,puncture_nurse_id,start_time,end_time,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, psm.DialysisId)
				insertData = append(insertData, psm.HospitalId)
				insertData = append(insertData, psm.PatientNk)
				insertData = append(insertData, psm.PsId)
				insertData = append(insertData, psm.DialysisDate)
				insertData = append(insertData, psm.SickbedNo)
				insertData = append(insertData, psm.DivisionId)
				insertData = append(insertData, psm.EquipmentId)
				insertData = append(insertData, psm.MixDialysis)
				insertData = append(insertData, psm.Ufv)
				insertData = append(insertData, psm.TotalTreatDuration)
				insertData = append(insertData, psm.IsHospitalization)
				insertData = append(insertData, psm.IsEmergency)
				insertData = append(insertData, psm.IsPerioperativePeriod)
				insertData = append(insertData, psm.BeforeSbp)
				insertData = append(insertData, psm.BeforeDbp)
				insertData = append(insertData, psm.AfterSbp)
				insertData = append(insertData, psm.AfterDbp)
				insertData = append(insertData, psm.BeforeWeight)
				insertData = append(insertData, psm.AfterWeight)
				insertData = append(insertData, psm.UpNurseId)
				insertData = append(insertData, psm.DownNurseId)
				insertData = append(insertData, psm.CheckNurseId)
				insertData = append(insertData, psm.PunctureNurseId)
				insertData = append(insertData, psm.StartTime)
				insertData = append(insertData, psm.EndTime)
				insertData = append(insertData, psm.CreateTime)
				insertData = append(insertData, psm.Sjscsj)
				insertData = append(insertData, psm.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)

			}

			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func BatchCreatePatientOut(patientOuts []*sz.TempHdPatientOut, rdb *gorm.DB) (err error) {
	if len(patientOuts) > 0 {
		utx := rdb
		if len(patientOuts) > 0 {
			thisSQL := "INSERT INTO t_hd_patient_quit (sn,hospital_id,patient_nk,sequelae_date,sequelae_type,create_time,death_reason,ext_reason,sjscsj,xgbz) VALUES "
			insertParams := make([]string, 0)
			insertData := make([]interface{}, 0)
			for _, out := range patientOuts {
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, out.Sn)
				insertData = append(insertData, out.HospitalId)
				insertData = append(insertData, out.PatientNk)
				insertData = append(insertData, out.SequelaeDate)
				insertData = append(insertData, out.SequelaeType)
				insertData = append(insertData, out.CreateTime)
				insertData = append(insertData, out.DeathReason)
				insertData = append(insertData, out.ExtReason)
				insertData = append(insertData, out.Sjscsj)
				insertData = append(insertData, out.Xgbz)

			}
			thisSQL += strings.Join(insertParams, ", ")
			utx.Exec(thisSQL, insertData...)
			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func BatchCreateDoctorsAdvice(advices []*sz.TempHdDoctorsAdvice, rdb *gorm.DB) (err error) {
	if len(advices) > 0 {
		utx := rdb
		if len(advices) > 0 {
			for _, advice := range advices {
				thisSQL := "INSERT INTO t_hd_doctors_advice (medical_order_id, hospital_id,dialysis_id,order_type,patient_nk,dialysis_duration,blood_vol,anticoagulant,create_time,sjscsj,xgbz,rrt_type,rrt_type_name,dry_weight) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, advice.MedicalOrderId)
				insertData = append(insertData, advice.HospitalId)
				insertData = append(insertData, advice.DialysisId)
				insertData = append(insertData, advice.OrderType)
				insertData = append(insertData, advice.PatientNk)
				insertData = append(insertData, advice.DialysisDuration)
				insertData = append(insertData, advice.BloodVol)
				insertData = append(insertData, advice.Anticoagulant)
				insertData = append(insertData, advice.CreateTime)
				insertData = append(insertData, advice.Sjscsj)
				insertData = append(insertData, advice.Xgbz)
				insertData = append(insertData, advice.RrtType)
				insertData = append(insertData, advice.RrtTypeName)
				insertData = append(insertData, advice.DryWeight)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func BatchCreateMonitor(advices []*sz.TempHdMiddle, rdb *gorm.DB) (err error) {
	if len(advices) > 0 {
		utx := rdb
		if len(advices) > 0 {

			for _, advice := range advices {
				thisSQL := "INSERT INTO t_hd_middle (sn,hospital_id, patient_nk,dialysis_id,monitor_time,sbp,dbp,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, advice.Sn)
				insertData = append(insertData, advice.HospitalId)
				insertData = append(insertData, advice.PatientNk)
				insertData = append(insertData, advice.DialysisId)
				insertData = append(insertData, advice.MonitorTime)
				insertData = append(insertData, advice.Sbp)
				insertData = append(insertData, advice.Dbp)
				insertData = append(insertData, advice.CreateTime)
				insertData = append(insertData, advice.Sjscsj)
				insertData = append(insertData, advice.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func FindOrgOtherMachineData(org_id int64, lastUploadTime int64, nowTime int64) (waterMachine []*models.VMDeviceAddmacher, err error) {

	db := readUserDb.Model(&models.VMDeviceAddmacher{}).Where("status = 1 AND  user_org_id = ? AND (device_type = 1 OR device_type = 3)", org_id)

	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)

	err = db.Find(&waterMachine).Error

	return
}

func FindOrgMachineRepairData(org_id int64, lastUploadTime int64, nowTime int64) (waterMachine []*models.DeviceRepair, err error) {
	db := readUserDb.Model(&models.DeviceRepair{}).Where("status = 1 AND  user_org_id = ?", org_id).Preload("VMDeviceAddmacher", "status = 1")
	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)
	err = db.Find(&waterMachine).Error
	return
}

func BatchCreateOtherMachineRecord(wms []*sz.TempHdOtherMachine, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {

			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_other_machine (hospital_id, equipment_id, equipment_brand, equipment_model, enable_time,status,equipment_type,xgbz,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquipmentId)
				insertData = append(insertData, wm.EquipmentBrand)
				insertData = append(insertData, wm.EquipmentModel)
				insertData = append(insertData, wm.EnableTime)
				insertData = append(insertData, wm.Status)
				insertData = append(insertData, wm.EquipmentType)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

		}
		// utx.Commit()
	}
	return
}

func BatchCreateMainTain(maintain []*sz.TempHdMaintain, rdb *gorm.DB) (err error) {
	if len(maintain) > 0 {
		utx := rdb
		if len(maintain) > 0 {
			thisSQL := "INSERT INTO t_hd_maintain (hospital_id, equipment_id, equipment_type, repair_time, xgbz,create_time,sjscsj) VALUES "
			insertParams := make([]string, 0)
			insertData := make([]interface{}, 0)
			for _, wm := range maintain {
				insertParams = append(insertParams, "(?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquipmentId)
				insertData = append(insertData, wm.EquipmentType)
				insertData = append(insertData, wm.RepairTime)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
			}
			thisSQL += strings.Join(insertParams, ", ")
			utx.Exec(thisSQL, insertData...)
			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func FindOrgMachineData(org_id int64, lastUploadTime int64, nowTime int64) (waterMachine []*models.VMDeviceAddmacher, err error) {
	db := readUserDb.Model(&models.VMDeviceAddmacher{}).Where("status = 1 AND  user_org_id = ?", org_id).Preload("DeviceNumber", func(db *gorm.DB) *gorm.DB {
		return readDb.Model(&models.DeviceNumber{}).Where("status = 1")
	})

	db = db.Where("ctime >= ? AND ctime <= ?", lastUploadTime, nowTime)

	err = db.Find(&waterMachine).Error

	return
}

func BatchCreateHDMRecord(wms []*sz.TempHdDm, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {

			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_dm (hospital_id, equipment_id,sickbed_no,sickbed_type ,equipment_brand, equipment_model, enable_time,status,equipment_type, xgbz,bbp,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquipmentId)
				insertData = append(insertData, wm.SickbedNo)
				insertData = append(insertData, wm.SickbedType)
				insertData = append(insertData, wm.EquipmentBrand)
				insertData = append(insertData, wm.EquipmentModel)
				insertData = append(insertData, wm.EnableTime)
				insertData = append(insertData, wm.Status)
				insertData = append(insertData, wm.EquipmentType)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.Bbp)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)

				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

			// if err != nil {
			// 	utx.Rollback()
			// 	return
			// }
		}
		// utx.Commit()
	}
	return
}

func CreateHDDivision(wms []*sz.TempHdDivision, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_division (division_id,hospital_id, division_name,division_type, xgbz,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.DivisionId)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.DivisionName)
				insertData = append(insertData, wm.DivisionType)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)

				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}

		}
	}
	return
}

func CreateAccess(wms []*sz.TempHdAccess, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_access (access_id,hospital_id,patient_nk,access_type,access_type_name,access_status,setup_date,first_use_time,xgbz,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.AccessId)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.AccessType)
				insertData = append(insertData, wm.AccessTypeName)
				insertData = append(insertData, wm.AccessStatus)
				insertData = append(insertData, wm.SetupDate)
				insertData = append(insertData, wm.FirstUseTime)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateSickbed(wms []*sz.TempHdSickbed, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_sickbed (sickbed_no,hospital_id,division_id,sickbed_code,sickbed_type,xgbz,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.SickbedNo)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.DivisionId)
				insertData = append(insertData, wm.SickbedCode)
				insertData = append(insertData, wm.SickbedType)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateDiagnosis(wms []*sz.TempHdDiagnosis, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_diagnosis (diagnosis_id,hospital_id,patient_nk,diagnosis_time,diagnosis_type,diagnosis_type_item,diagnosis_type_detail,xgbz,create_time,update_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.DiagnosisId)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.DiagnosisTime)
				insertData = append(insertData, wm.DiagnosisType)
				insertData = append(insertData, wm.DiagnosisTypeItem)
				insertData = append(insertData, wm.DiagnosisTypeDetail)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateInfection(wms []*sz.TempHdInfection, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_infection (sn,hospital_id,patient_nk,hbv,hcv,rpr,hiv,hbsag,hbsab,hbeag,hbeab,hbcab,check_date,doctor_id,xgbz,create_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.Hbv)
				insertData = append(insertData, wm.Hcv)
				insertData = append(insertData, wm.Rpr)
				insertData = append(insertData, wm.Hiv)
				insertData = append(insertData, wm.Hbsag)
				insertData = append(insertData, wm.Hbsab)
				insertData = append(insertData, wm.Hbeag)
				insertData = append(insertData, wm.Hbeab)
				insertData = append(insertData, wm.Hbcab)
				insertData = append(insertData, wm.CheckDate)
				insertData = append(insertData, wm.DoctorId)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateComplication(wms []*sz.TempHdComplication, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_complication (sn,hospital_id,patient_nk,dialysis_id,monitor_id,neopathy_time,neopathy_type,neopathy_desc,xgbz,create_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.DialysisId)
				insertData = append(insertData, wm.MonitorId)
				insertData = append(insertData, wm.NeopathyTime)
				insertData = append(insertData, wm.NeopathyType)
				insertData = append(insertData, wm.NeopathyDesc)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateLisReport(wms []*sz.TempHdLisReport, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_lis_report (lab_sno,hospital_id,patient_nk,report_date,check_date,jz_no,mz_flag,zy_no,mz_no,department_code,department_name,card_no,card_type,patient_name,dep_code,dep_name,inspected_type,report_categry,application_name,application_type,check_name,check_item_name,check_item_code,record_ccount,check_result,diagnose_name,xgbz,create_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.LabSno)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.ReportDate)
				insertData = append(insertData, wm.CheckDate)
				insertData = append(insertData, wm.JzNo)
				insertData = append(insertData, wm.MzFlag)
				insertData = append(insertData, wm.ZyNo)
				insertData = append(insertData, wm.MzNo)
				insertData = append(insertData, wm.DepartmentCode)
				insertData = append(insertData, wm.DepartmentName)
				insertData = append(insertData, wm.CardNo)
				insertData = append(insertData, wm.CardType)
				insertData = append(insertData, wm.PatientName)
				insertData = append(insertData, wm.DepCode)
				insertData = append(insertData, wm.DepName)
				insertData = append(insertData, wm.InspectedType)
				insertData = append(insertData, wm.ReportCategry)
				insertData = append(insertData, wm.ApplicationName)
				insertData = append(insertData, wm.ApplicationType)
				insertData = append(insertData, wm.CheckName)
				insertData = append(insertData, wm.CheckItemName)
				insertData = append(insertData, wm.CheckItemCode)
				insertData = append(insertData, wm.RecordCcount)
				insertData = append(insertData, wm.CheckResult)
				insertData = append(insertData, wm.DiagnoseName)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateLisIndicators(wms []*sz.TempHdLisIndicators, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_lis_indicators (inspected_result_no,hospital_id,lab_sno,report_date,check_date,inspected_indicate,inspected_item_en_name,inspected_item_cn_name,inspected_result_desc,inspected_result_value,inspected_result_unit,ref_range,unit_type,inspected_result,xgbz,create_time,sjscsj) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.InspectedResultNo)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.LabSno)
				insertData = append(insertData, wm.ReportDate)
				insertData = append(insertData, wm.CheckDate)
				insertData = append(insertData, wm.InspectedIndicate)
				insertData = append(insertData, wm.InspectedItemEnName)
				insertData = append(insertData, wm.InspectedItemCnName)
				insertData = append(insertData, wm.InspectedResultDesc)
				insertData = append(insertData, wm.InspectedResultValue)
				insertData = append(insertData, wm.InspectedResultUnit)
				insertData = append(insertData, wm.RefRange)
				insertData = append(insertData, wm.UnitType)
				insertData = append(insertData, wm.InspectedResult)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgCulture(org_id int64, lastUploadTime int64, nowTime int64) (culture []*models.XtDeviceCulture, err error) {

	err = UserReadDB().Model(&culture).Where("status = 1 and user_org_id = ? and speling_date>=? and speling_date<=?", org_id, lastUploadTime, nowTime).Find(&culture).Error
	return culture, err
}

func CreateLisCulture(wms []*sz.TempHdLisCulture, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_dm_dialysate_bc (sn,hospital_id,equipment_id,inspection_time,is_qualified,is_substitution_qualified,case_order,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.IsSubstitutionQualified)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgDialysate(org_id int64, lastUploadTime int64, nowTime int64) (dialysate []*models.XtDeviceDialysate, err error) {

	err = UserReadDB().Model(&dialysate).Where("status = 1 and user_org_id = ? and sampling_date>=? and sampling_date<=?", org_id, lastUploadTime, nowTime).Find(&dialysate).Error
	return dialysate, err
}

func CreateLisDialysate(wms []*sz.TempHdLisDialysate, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_dm_dialysate_en (sn,hospital_id,equipment_id,inspection_time,is_qualified,case_order,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgArialDetection(org_id int64, lastUploadTime int64, nowTime int64) (airdetection []*models.XtAerialDetection, err error) {

	err = XTReadDB().Model(&airdetection).Where("user_org_id = ? and status=1 and created_time>=? and created_time<=?", org_id, lastUploadTime, nowTime).Find(&airdetection).Error
	return airdetection, err
}

func CreateAirDisinfect(wms []*sz.TempHdLisAirDisinfect, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_air_disinfect (sn,hospital_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgBodyDetection(org_id int64, lastUploadTime int64, nowTime int64) (body []*models.XtBodyDetection, err error) {
	err = XTReadDB().Model(&body).Where("user_org_id = ? and status=1 and created_time>=? and created_time<=?", org_id, lastUploadTime, nowTime).Find(&body).Error
	return body, err
}

func CreateBodyDisinfect(wms []*sz.TempHdLisBodyDisinfect, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_surface_disinfect (sn,hospital_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgWaterFc(org_id int64, lastUploadTime int64, nowTime int64) (water []*models.XtDeviceWater, err error) {

	err = UserReadDB().Model(&water).Where("user_org_id = ? and status = 1 and sampling_date>=? and sampling_date<=?", org_id, lastUploadTime, nowTime).Find(&water).Error
	return water, err
}

func CreateWaterFc(wms []*sz.TempHdLisWaterFc, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_fc(sn,hospital_id,equitpment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgWaterNc(org_id int64, lastUploadTime int64, nowTime int64) (water []*models.XtDeviceOxygenates, err error) {

	err = UserReadDB().Model(&water).Where("user_org_id = ? and status = 1 and sampling_date>=? and sampling_date<=?", org_id, lastUploadTime, nowTime).Find(&water).Error
	return water, err
}

func CreateWaterNc(wms []*sz.TempHdLisWaterNc, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_nc(sn,hospital_id,equitpment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgWaterPh(org_id int64, lastUploadTime int64, nowTime int64) (water []*models.XtDevicePh, err error) {

	err = UserReadDB().Model(&water).Where("user_org_id = ? and sampling_date>? and sampling_date<=?", org_id, lastUploadTime, nowTime).Find(&water).Error
	return water, err
}

func CreateWaterPh(wms []*sz.TempHdLisWaterPh, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_ph(sn,hospital_id,equitpment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgWaterWh(org_id int64, lastUploadTime int64, nowTime int64) (water []*models.XtDeviceHadwater, err error) {

	err = UserReadDB().Model(&water).Where("user_org_id = ? and sampling_date>=? and sampling_date<=? and status =1", org_id, lastUploadTime, nowTime).Find(&water).Error
	return water, err
}

func CreateWaterWh(wms []*sz.TempHdLisWaterWh, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_wh(sn,hospital_id,equitpment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,create_time,sjscsj,xgbz,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgHdCi(org_id int64, lastUploadTime int64, nowTime int64) (access []*models.XtPatientVascularAccess, err error) {

	err = XTReadDB().Model(&access).Where("user_org_id = ? and start_time>=? and start_time<=? and access_project = 2 and status =1", org_id, lastUploadTime, nowTime).Find(&access).Error
	return access, err
}

func CreateHdCi(wms []*sz.TempHdCi, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_ci(infect_sn,hospital_id,patient_nk,access_id,ci_type,blood_culture,infection_date,create_time,sjscsj,xgbz) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.InfectSn)
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.AccessId)
				insertData = append(insertData, wm.CiType)
				insertData = append(insertData, wm.BloodCulture)
				insertData = append(insertData, wm.InfectionDate)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func FindOrgHdCiOutCome(org_id int64, lastUploadTime int64, nowTime int64) (access []*models.XtPatientVascularAccess, err error) {

	err = XTReadDB().Model(&access).Where("user_org_id = ? and start_time>=? and start_time<=? and access_project = 2 and status =1", org_id, lastUploadTime, nowTime).Find(&access).Error
	return access, err
}

func CreateHdCiOutCome(wms []*sz.TempHdCiOutCome, rdb *gorm.DB) (err error) {

	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_ci_outcome(hospital_id,sn,infect_sn,patient_nk,sequelae_type,sjscsj,xgbz,create_time,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.InfectSn)
				insertData = append(insertData, wm.PatientNk)
				insertData = append(insertData, wm.SequelaeType)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateLisWaterBc(wms []*sz.TempHdLisWaterBc, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_bc (hospital_id,sn,equipment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,sjscsj,xgbz,create_time,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}

func CreateLisWaterEn(wms []*sz.TempHdLisWaterEn, rdb *gorm.DB) (err error) {
	if len(wms) > 0 {
		utx := rdb
		if len(wms) > 0 {
			for _, wm := range wms {
				thisSQL := "INSERT INTO t_hd_water_en (hospital_id,sn,equipment_id,water_type,inspection_org_id,inspection_time,is_qualified,inspected_value,case_order,sjscsj,xgbz,create_time,update_time) VALUES "
				insertParams := make([]string, 0)
				insertData := make([]interface{}, 0)
				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?)")
				insertData = append(insertData, wm.HospitalId)
				insertData = append(insertData, wm.Sn)
				insertData = append(insertData, wm.EquitmentId)
				insertData = append(insertData, wm.WaterType)
				insertData = append(insertData, wm.InspectionOrgId)
				insertData = append(insertData, wm.InspectionTime)
				insertData = append(insertData, wm.IsQualified)
				insertData = append(insertData, wm.InspectedValue)
				insertData = append(insertData, wm.CaseOrder)
				insertData = append(insertData, wm.Sjscsj)
				insertData = append(insertData, wm.Xgbz)
				insertData = append(insertData, wm.CreateTime)
				insertData = append(insertData, wm.UpdateTime)
				thisSQL += strings.Join(insertParams, ", ")
				utx.Exec(thisSQL, insertData...)
			}
		}
	}
	return
}