XT_New/controllers/mobile_api_controllers/check_weight_api_controller.go

package mobile_api_controllers

import (
	"XT_New/enums"
	"XT_New/models"
	"XT_New/service"
	_ "XT_New/utils"
	"encoding/json"
	_ "encoding/json"
	"fmt"
	"github.com/astaxie/beego"
	_ "github.com/astaxie/beego"
	"github.com/jinzhu/gorm"
	"net/http"
	"net/url"
	"strconv"
	_ "strings"

	// "fmt"
	_ "reflect"
	"time"
)

type CheckWeightApiController struct {
	MobileBaseAPIAuthController
}

func (c *CheckWeightApiController) SaveBloodPressure() {
	id, _ := c.GetInt64("patient", 0)
	dialysistype, _ := c.GetInt64("dialysistype", 0)
	systolic_blood_pressure, _ := c.GetFloat("systolic_blood_pressure", 0)   //收缩压
	diastolic_blood_pressure, _ := c.GetFloat("diastolic_blood_pressure", 0) //舒张压
	pulse_frequency, _ := c.GetFloat("pulse_frequency", 0)                   //脉率

	if id <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	if dialysistype <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	if systolic_blood_pressure <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	if diastolic_blood_pressure <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}

	adminUserInfo := c.GetMobileAdminUserInfo()
	patient, _ := service.FindPatientByIdWithDiseases(adminUserInfo.Org.Id, id)
	if patient.ID == 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
		return
	}

	thisTime := time.Now()

	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	theAssessmentDateTime := theStartTime.Unix()

	if dialysistype == 1 {

		theEvaluation, getPEErr := service.MobileGetPredialysisEvaluationOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
		if getPEErr != nil {
			c.ErrorLog("获取透前评估失败:%v", getPEErr)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}

		var evaluation models.PredialysisEvaluation
		if theEvaluation != nil {
			evaluation = *theEvaluation
		}

		// 如果今天没有透前评估，则插入新的数据
		if theEvaluation == nil {
			evaluation.CreatedTime = time.Now().Unix()
			evaluation.Status = 1
			evaluation.AssessmentDate = theAssessmentDateTime
			evaluation.PatientId = id
			evaluation.UserOrgId = adminUserInfo.Org.Id
			// 获取上一次透前评估信息，部分数据是需要从上一次透前评估继承
			lastPredialysisEvaluation, _ := service.MobileGetLastTimePredialysisEvaluationOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
			// 获取上一次透后评估，插入本次透前评估的上次透后体重（weight_after_last_transparency）字段
			assessmentAfterDislysis, getAADErr := service.MobileGetLastTimeAssessmentAfterDislysisOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)

			if getAADErr != nil {
				c.ErrorLog("获取透后评估失败:%v", getAADErr)
				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
				return
			}

			// 获取干体重，先从干体重配置里去读，如果没有，则读取上一次透前评估的干体重
			weight, err := service.FindLastDryWeightAdjust(adminUserInfo.Org.Id, id)
			if err == gorm.ErrRecordNotFound {
				if lastPredialysisEvaluation != nil {
					evaluation.DryWeight = lastPredialysisEvaluation.DryWeight
				} else {
					evaluation.DryWeight = 0
				}
			} else {
				evaluation.DryWeight = weight.DryWeight
			}

			if assessmentAfterDislysis != nil {
				evaluation.WeightAfterLastTransparency = assessmentAfterDislysis.WeightAfter
			}

			if lastPredialysisEvaluation != nil {
				evaluation.BloodAccessPartId = lastPredialysisEvaluation.BloodAccessPartId
				evaluation.BloodAccessPartOperaId = lastPredialysisEvaluation.BloodAccessPartOperaId
				evaluation.AdditionalWeight = lastPredialysisEvaluation.AdditionalWeight // 衣物重

				//从化益达 备注默认上一次数据
				if adminUserInfo.Org.Id == 10318 {
					evaluation.Remark = lastPredialysisEvaluation.Remark
				}
			}
		} else {
			evaluation.UpdatedTime = time.Now().Unix()
		}

		evaluation.SystolicBloodPressure = systolic_blood_pressure   // 收缩压
		evaluation.DiastolicBloodPressure = diastolic_blood_pressure // 舒张压
		evaluation.PulseFrequency = pulse_frequency                  // 脉率

		evaluation.AssessmentTime = time.Now().Unix()

		err := service.UpadatePredialysisEvaluation(&evaluation)
		//记录日志
		byterequest, _ := json.Marshal(evaluation)
		assessmentBeforeDislysisLog := models.XtAssessmentBeforeDislysisLog{
			UserOrgId:   adminUserInfo.Org.Id,
			AdminUserId: adminUserInfo.AdminUser.Id,
			ErrLog:      string(byterequest),
			PatientId:   evaluation.PatientId,
			RecordDate:  evaluation.AssessmentDate,
			Ctime:       time.Now().Unix(),
			Mtime:       0,
			Status:      1,
			Source:      "物联网上传透前血压",
		}

		service.CreateBeforLog(assessmentBeforeDislysisLog)

		assessdateDateStart := thisTime.Format("2006-01-02")
		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_before_dislysis"
		redis := service.RedisClient()
		defer redis.Close()
		//清空key 值
		redis.Set(key, "", time.Second)
		keyOne := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_befores_list_all"
		redis.Set(keyOne, "", time.Second)
		keyTwo := "scheduals_" + assessdateDateStart + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
		redis.Set(keyTwo, "", time.Second)
		redis.Close()
		if err != nil {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
			return
		}

		c.ServeSuccessJSON(map[string]interface{}{
			"msg":        "ok",
			"evaluation": evaluation,
		})
		return

	} else {

		// 保存透后相关数据
		assessmentAfterDislysis, getAADErr := service.MobileGetAssessmentAfterDislysisOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)

		if getAADErr != nil {
			c.ErrorLog("获取透后评估失败:%v", getAADErr)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}

		var afterevaluation models.AssessmentAfterDislysis
		if assessmentAfterDislysis != nil {
			afterevaluation = *assessmentAfterDislysis
		}
		if assessmentAfterDislysis == nil {
			afterevaluation.CreatedTime = time.Now().Unix()
			afterevaluation.Status = 1
			afterevaluation.AssessmentDate = theAssessmentDateTime
			afterevaluation.PatientId = id
			afterevaluation.UserOrgId = adminUserInfo.Org.Id
		} else {

			afterevaluation.UpdatedTime = time.Now().Unix()
		}

		afterevaluation.SystolicBloodPressure = systolic_blood_pressure   // 收缩压
		afterevaluation.DiastolicBloodPressure = diastolic_blood_pressure // 舒张压
		afterevaluation.PulseFrequency = pulse_frequency                  // 脉率

		if adminUserInfo.Org.Id == 10138 {
			afterevaluation.LeaveOfficeMethod = assessmentAfterDislysis.LeaveOfficeMethod //离科方式
			afterevaluation.Lapse = assessmentAfterDislysis.Lapse                         //转归
			afterevaluation.Consciousness = assessmentAfterDislysis.Consciousness         //意识
			afterevaluation.Fallrisk = assessmentAfterDislysis.Fallrisk                   //跌倒风险
		}

		err := service.UpdateAssessmentAfterDislysisRecord(&afterevaluation)

		//记录日志
		byterequest, _ := json.Marshal(afterevaluation)
		afterLog := models.XtAssessmentAfterDialysisLog{
			UserOrgId:   adminUserInfo.Org.Id,
			AdminUserId: adminUserInfo.AdminUser.Id,
			ErrLog:      string(byterequest),
			PatientId:   afterevaluation.PatientId,
			RecordDate:  afterevaluation.AssessmentDate,
			Ctime:       time.Now().Unix(),
			Mtime:       0,
			Status:      1,
			Source:      "物联网上传透后血压",
		}

		service.CreateAfterDialysisLog(afterLog)

		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_after_dislysis"
		redis := service.RedisClient()
		//清空key 值
		redis.Set(key, "", time.Second)
		keyThree := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_after_dislysis_list_all"
		redis.Set(keyThree, "", time.Second)
		assessdateDateStart := thisTime.Format("2006-01-02")
		keyTwo := "scheduals_" + assessdateDateStart + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
		redis.Set(keyTwo, "", time.Second)
		defer redis.Close()
		if err == nil {
			c.ServeSuccessJSON(map[string]interface{}{
				"assessmentAfterDislysis": afterevaluation,
			})
		}
	}

}

func (c *CheckWeightApiController) SavePatientInfoDialysis() {
	id, _ := c.GetInt64("patient", 0)
	dialysistype, _ := c.GetInt64("dialysistype", 0)
	if id <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	if dialysistype <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}

	adminUserInfo := c.GetMobileAdminUserInfo()
	patient, _ := service.FindPatientByIdWithDiseases(adminUserInfo.Org.Id, id)
	if patient.ID == 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
		return
	}

	thisTime := time.Now()

	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	// scheduleDateEnd := thisTime.Format("2006-01-02") + " 23:59:59"
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	// theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
	theAssessmentDateTime := theStartTime.Unix()
	// endTime := theEndTime.Unix()
	// dry_weight,_ := c.GetFloat("dry_weight",0)  // 干体重
	weighing_before, _ := c.GetFloat("weighing_before", 0) // 透前体重
	dewater_amount, _ := c.GetFloat("dewater_amount", 0)   // 目标脱水量(L)

	weight_after, _ := c.GetFloat("weight_after", 0) // 透后体重
	weight_loss, _ := c.GetFloat("weight_loss", 0)   // 体重减少

	schedual, _ := service.MobileGetSchedualDetail(adminUserInfo.Org.Id, patient.ID, theStartTime.Unix())

	//dialysisSolution,_ := service.MobileGetDialysisSolutionByModeId(adminUserInfo.Org.Id,patient.ID,schedual.ModeId)

	//dialysisPrescribe, _ := service.MobileGetDialysisPrescribeByModeId(adminUserInfo.Org.Id, patient.ID, theStartTime.Unix(),schedual.ModeId)

	//dialysisPrescribe, _ := service.MobileGetDialysisPrescribeByModeId(adminUserInfo.Org.Id, patient.ID, theStartTime.Unix(),schedual.ModeId)

	//dialysisPrescribe, _ := service.MobileGetDialysisPrescribeByModeId(adminUserInfo.Org.Id, patient.ID, theStartTime.Unix(),schedual.ModeId)

	// 查询当前用户今天有没有排班，没有排班，则不处理
	// daySchedule, _ := service.GetPatientScheduleFormDay(adminUserInfo.Org.Id, theAssessmentDateTime, endTime, id)
	// if(len(daySchedule) <= 0) {
	// 	c.ServeSuccessJSON(map[string]interface{}{
	// 		"msg":        "ok",
	// 	})
	// 	return
	// }

	template, _ := service.GetOrgInfoTemplate(adminUserInfo.Org.Id)

	if template.TemplateId == 22 || template.TemplateId == 17 || template.TemplateId == 21 || template.TemplateId == 26 || template.TemplateId == 27 || template.TemplateId == 34 || template.TemplateId == 30 || template.TemplateId == 32 || template.TemplateId == 36 || template.TemplateId == 40 || template.TemplateId == 38 || template.TemplateId == 43 || template.TemplateId == 46 || template.TemplateId == 53 || template.TemplateId == 48 || adminUserInfo.Org.Id == 10345 || adminUserInfo.Org.Id == 10432 || adminUserInfo.Org.Id == 10441 || adminUserInfo.Org.Id == 10445 || adminUserInfo.Org.Id == 10138 || adminUserInfo.Org.Id == 10278 || adminUserInfo.Org.Id == 9829 || adminUserInfo.Org.Id == 10440 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 10471 {
		if adminUserInfo.Org.Id != 10447 {
			dewater_amount = dewater_amount * 1000
		}

	}

	if dewater_amount < 0 {
		dewater_amount = 0
	}

	if dialysistype == 1 {
		// 保存透前相关数据
		// 获取透析处方

		var lastDialysisPrescribe *models.DialysisPrescription
		var dialysisSolution *models.DialysisSolution
		var dialysisPrescribe *models.DialysisPrescription
		var system_dialysisPrescribe *models.SystemPrescription

		var mode_id int64
		//weightfirst, _ := service.FindLastDryWeightAdjust(adminUserInfo.Org.Id, id)
		//if weightfirst.DryWeight > weighing_before {
		//	return
		//}
		dialysisPrescribe, _ = service.MobileGetDialysisPrescribe(adminUserInfo.Org.Id, id, theAssessmentDateTime)
		if schedual != nil {
			// 获取透析模版
			dialysisSolution, _ = service.MobileGetDialysisSolutionByModeIdSix(adminUserInfo.Org.Id, id, schedual.ModeId)
			system_dialysisPrescribe, _ = service.MobileGetSystemDialysisPrescribeByModeIdSix(adminUserInfo.Org.Id, schedual.ModeId)
			lastDialysisPrescribe, _ = service.MobileGetLastDialysisPrescribeByModeIdSix(adminUserInfo.Org.Id, id, schedual.ModeId)

			//判断透析模式,针对河间咸的
			if adminUserInfo.Org.Id == 10090 {
				if dialysisSolution.ModeId != 2 && dialysisSolution.ModeId != 5 && dialysisSolution.ModeId != 12 {
					dialysisSolution.DisplaceLiquiPart = 0
					dialysisSolution.DisplaceLiquiValue = 0
				}
				if lastDialysisPrescribe.ModeId != 2 && lastDialysisPrescribe.ModeId != 5 && lastDialysisPrescribe.ModeId != 12 {
					dialysisSolution.DisplaceLiquiPart = 0
					dialysisSolution.DisplaceLiquiValue = 0
				}
			}

			mode_id = schedual.ModeId
		} else {
			// 获取透析模版
			dialysisSolution, _ = service.MobileGetDialysisSolution(adminUserInfo.Org.Id, id)

			if dialysisPrescribe == nil && dialysisSolution != nil {
				mode_id = dialysisSolution.ModeId
			}

			if dialysisPrescribe == nil && dialysisSolution == nil {
				mode_id = 0
			}
		}

		// 插入透析处方
		if dialysisPrescribe == nil && dialysisSolution != nil {
			var newprescribe models.DialysisPrescription
			newprescribe.UserOrgId = dialysisSolution.UserOrgId
			newprescribe.PatientId = dialysisSolution.PatientId
			newprescribe.Anticoagulant = dialysisSolution.Anticoagulant
			newprescribe.AnticoagulantShouji = dialysisSolution.AnticoagulantShouji
			newprescribe.AnticoagulantWeichi = dialysisSolution.AnticoagulantWeichi
			newprescribe.AnticoagulantZongliang = dialysisSolution.AnticoagulantZongliang
			newprescribe.AnticoagulantGaimingcheng = dialysisSolution.AnticoagulantGaimingcheng
			newprescribe.AnticoagulantGaijiliang = dialysisSolution.AnticoagulantGaijiliang
			newprescribe.ModeId = dialysisSolution.ModeId
			newprescribe.DialysisDuration = dialysisSolution.DialysisDuration
			newprescribe.ReplacementWay = dialysisSolution.ReplacementWay
			newprescribe.HemodialysisMachine = dialysisSolution.HemodialysisMachine
			newprescribe.BloodFilter = dialysisSolution.BloodFilter
			newprescribe.PerfusionApparatus = dialysisSolution.PerfusionApparatus
			newprescribe.BloodFlowVolume = dialysisSolution.BloodFlowVolume
			newprescribe.DisplaceLiqui = dialysisSolution.DisplaceLiqui
			newprescribe.Glucose = dialysisSolution.Glucose
			newprescribe.DialysateFlow = dialysisSolution.DialysateFlow
			newprescribe.Kalium = dialysisSolution.Kalium
			newprescribe.Sodium = dialysisSolution.Sodium
			newprescribe.Calcium = dialysisSolution.Calcium
			newprescribe.Bicarbonate = dialysisSolution.Bicarbonate
			newprescribe.DialysateTemperature = dialysisSolution.DialysateTemperature
			newprescribe.Conductivity = dialysisSolution.Conductivity
			newprescribe.BodyFluid = dialysisSolution.BodyFluid
			newprescribe.SpecialMedicine = dialysisSolution.SpecialMedicine
			newprescribe.SpecialMedicineOther = dialysisSolution.SpecialMedicineOther
			newprescribe.DisplaceLiquiPart = dialysisSolution.DisplaceLiquiPart
			newprescribe.DisplaceLiquiValue = dialysisSolution.DisplaceLiquiValue
			newprescribe.BloodAccess = dialysisSolution.BloodAccess
			newprescribe.Ultrafiltration = dialysisSolution.Ultrafiltration
			newprescribe.DialysisDurationHour = dialysisSolution.DialysisDurationHour
			newprescribe.DialysisDurationMinute = dialysisSolution.DialysisDurationMinute
			newprescribe.TargetUltrafiltration = dialysisSolution.TargetUltrafiltration
			newprescribe.DialysateFormulation = dialysisSolution.DialysateFormulation
			newprescribe.Dialyzer = dialysisSolution.Dialyzer
			newprescribe.ReplacementTotal = dialysisSolution.ReplacementTotal
			newprescribe.DialyzerPerfusionApparatus = dialysisSolution.DialyzerPerfusionApparatus
			newprescribe.DialysisIrrigation = dialysisSolution.DialysisIrrigation
			newprescribe.DialysisDialyszers = dialysisSolution.DialysisDialyszers
			newprescribe.BodyFluidOther = dialysisSolution.BodyFluidOther
			newprescribe.TargetKtv = dialysisSolution.TargetKtv

			newprescribe.CreatedTime = time.Now().Unix()
			newprescribe.UpdatedTime = time.Now().Unix()
			newprescribe.RecordDate = theAssessmentDateTime
			newprescribe.DewaterAmount = dewater_amount
			newprescribe.TargetUltrafiltration = dewater_amount
			newprescribe.PrescriptionWater = dewater_amount
			newprescribe.Chaptalization = dialysisSolution.Chaptalization
			newprescribe.PrescribingNumber = 1
			newprescribe.Status = 1
			if adminUserInfo.Org.Id != 10013 && adminUserInfo.Org.Id != 10014 {
				newprescribe.Remark = dialysisSolution.Remark
			}

			if adminUserInfo.Org.Id == 10340 {
				newprescribe.TargetUltrafiltration = 0
				newprescribe.Sodium = 138
				newprescribe.Bicarbonate = 31.1
				newprescribe.DialysateFlow = 500
			}
			// 针对新化博翔
			if adminUserInfo.Org.Id == 10447 {
				newprescribe.DisplaceLiquiPart = 1
				newprescribe.DisplaceLiquiValue = 32
				newprescribe.DialysateFlow = 500
			}

			if adminUserInfo.Org.Id == 10121 {
				newprescribe.DialysisDurationHour = 4
				newprescribe.DialysisDurationMinute = 0
				newprescribe.BloodAccess = dialysisSolution.BloodAccess
			}
			//插入透析处方
			err := service.AddSigleRecord(&newprescribe)

			//记录日志
			byterequest, _ := json.Marshal(newprescribe)
			prescriptionLog := models.XtDialysisPrescriptionLog{
				UserOrgId:   newprescribe.UserOrgId,
				Ctime:       time.Now().Unix(),
				Mtime:       0,
				ErrLog:      string(byterequest),
				AdminUserId: adminUserInfo.AdminUser.Id,
				RecordDate:  newprescribe.RecordDate,
				PatientId:   newprescribe.PatientId,
				Source:      "物联网上传",
				Status:      1,
			}

			service.CreatePrescriptionLog(prescriptionLog)

			key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
			redis := service.RedisClient()
			//清空key 值
			redis.Set(key, "", time.Second)
			keyTwo := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":prescriptions_list_all"
			redis.Set(keyTwo, "", time.Second)
			scheduleDateStartOne := thisTime.Format("2006-01-02")
			keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
			redis.Set(keyThree, "", time.Second)
			defer redis.Close()
			if err != nil {
				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
			}
		}

		if dialysisPrescribe == nil && dialysisSolution == nil {
			if lastDialysisPrescribe != nil {
				var newprescribe models.DialysisPrescription
				newprescribe.UserOrgId = lastDialysisPrescribe.UserOrgId
				newprescribe.PatientId = lastDialysisPrescribe.PatientId
				newprescribe.Anticoagulant = lastDialysisPrescribe.Anticoagulant
				newprescribe.AnticoagulantShouji = lastDialysisPrescribe.AnticoagulantShouji
				newprescribe.AnticoagulantWeichi = lastDialysisPrescribe.AnticoagulantWeichi
				newprescribe.AnticoagulantZongliang = lastDialysisPrescribe.AnticoagulantZongliang
				newprescribe.AnticoagulantGaimingcheng = lastDialysisPrescribe.AnticoagulantGaimingcheng
				newprescribe.AnticoagulantGaijiliang = lastDialysisPrescribe.AnticoagulantGaijiliang
				newprescribe.ModeId = lastDialysisPrescribe.ModeId
				newprescribe.DialysisDuration = lastDialysisPrescribe.DialysisDuration
				newprescribe.ReplacementWay = lastDialysisPrescribe.ReplacementWay
				newprescribe.HemodialysisMachine = lastDialysisPrescribe.HemodialysisMachine
				newprescribe.BloodFilter = lastDialysisPrescribe.BloodFilter
				newprescribe.PerfusionApparatus = lastDialysisPrescribe.PerfusionApparatus
				newprescribe.BloodFlowVolume = lastDialysisPrescribe.BloodFlowVolume
				newprescribe.DisplaceLiqui = lastDialysisPrescribe.DisplaceLiqui
				newprescribe.Glucose = lastDialysisPrescribe.Glucose
				newprescribe.DialysateFlow = lastDialysisPrescribe.DialysateFlow
				newprescribe.Kalium = lastDialysisPrescribe.Kalium
				newprescribe.Sodium = lastDialysisPrescribe.Sodium
				newprescribe.Calcium = lastDialysisPrescribe.Calcium
				newprescribe.Bicarbonate = lastDialysisPrescribe.Bicarbonate
				newprescribe.DialysateTemperature = lastDialysisPrescribe.DialysateTemperature
				newprescribe.Conductivity = lastDialysisPrescribe.Conductivity
				newprescribe.BodyFluid = lastDialysisPrescribe.BodyFluid
				newprescribe.SpecialMedicine = lastDialysisPrescribe.SpecialMedicine
				newprescribe.SpecialMedicineOther = lastDialysisPrescribe.SpecialMedicineOther
				newprescribe.DisplaceLiquiPart = lastDialysisPrescribe.DisplaceLiquiPart
				newprescribe.DisplaceLiquiValue = lastDialysisPrescribe.DisplaceLiquiValue
				newprescribe.BloodAccess = lastDialysisPrescribe.BloodAccess
				newprescribe.Ultrafiltration = lastDialysisPrescribe.Ultrafiltration
				newprescribe.DialysisDurationHour = lastDialysisPrescribe.DialysisDurationHour
				newprescribe.DialysisDurationMinute = lastDialysisPrescribe.DialysisDurationMinute
				newprescribe.DialysateFormulation = lastDialysisPrescribe.DialysateFormulation
				newprescribe.Dialyzer = lastDialysisPrescribe.Dialyzer
				newprescribe.ReplacementTotal = lastDialysisPrescribe.ReplacementTotal
				newprescribe.DialyzerPerfusionApparatus = lastDialysisPrescribe.DialyzerPerfusionApparatus
				newprescribe.DialysisDialyszers = lastDialysisPrescribe.DialysisDialyszers
				newprescribe.DialysisIrrigation = lastDialysisPrescribe.DialysisIrrigation
				newprescribe.BodyFluidOther = lastDialysisPrescribe.BodyFluidOther
				newprescribe.TargetKtv = lastDialysisPrescribe.TargetKtv
				newprescribe.CreatedTime = time.Now().Unix()
				newprescribe.UpdatedTime = time.Now().Unix()
				newprescribe.RecordDate = theAssessmentDateTime
				newprescribe.DewaterAmount = dewater_amount
				newprescribe.TargetUltrafiltration = dewater_amount
				newprescribe.PrescriptionWater = dewater_amount
				newprescribe.Status = 1
				if adminUserInfo.Org.Id != 10490 {
					newprescribe.Remark = lastDialysisPrescribe.Remark
				} else {
					newprescribe.Remark = ""
				}

				newprescribe.Chaptalization = lastDialysisPrescribe.Chaptalization
				newprescribe.PrescribingNumber = 1
				if adminUserInfo.Org.Id == 10340 {
					newprescribe.TargetUltrafiltration = 0
				}
				if adminUserInfo.Org.Id == 10121 {
					newprescribe.DialysisDurationHour = 4
					newprescribe.DialysisDurationMinute = 0
					newprescribe.BloodAccess = dialysisSolution.BloodAccess
				}
				err := service.AddSigleRecord(&newprescribe)

				//记录日志
				byterequest, _ := json.Marshal(newprescribe)
				prescriptionLog := models.XtDialysisPrescriptionLog{
					UserOrgId:   adminUserInfo.Org.Id,
					Ctime:       time.Now().Unix(),
					Mtime:       0,
					ErrLog:      string(byterequest),
					AdminUserId: adminUserInfo.AdminUser.Id,
					RecordDate:  newprescribe.RecordDate,
					PatientId:   id,
					Source:      "物联网上传",
					Status:      1,
				}

				service.CreatePrescriptionLog(prescriptionLog)

				key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
				redis := service.RedisClient()
				//清空key 值
				redis.Set(key, "", time.Second)
				keyTwo := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":prescriptions_list_all"
				redis.Set(keyTwo, "", time.Second)
				scheduleDateStartOne := thisTime.Format("2006-01-02")
				keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
				redis.Set(keyThree, "", time.Second)
				defer redis.Close()
				if err != nil {
					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
				}
			} else if system_dialysisPrescribe != nil {
				var newprescribe models.DialysisPrescription
				newprescribe.UserOrgId = system_dialysisPrescribe.UserOrgId
				newprescribe.PatientId = id
				newprescribe.Anticoagulant = system_dialysisPrescribe.Anticoagulant
				newprescribe.AnticoagulantShouji = system_dialysisPrescribe.AnticoagulantShouji
				newprescribe.AnticoagulantWeichi = system_dialysisPrescribe.AnticoagulantWeichi
				newprescribe.AnticoagulantZongliang = system_dialysisPrescribe.AnticoagulantZongliang
				newprescribe.AnticoagulantGaimingcheng = system_dialysisPrescribe.AnticoagulantGaimingcheng
				newprescribe.AnticoagulantGaijiliang = system_dialysisPrescribe.AnticoagulantGaijiliang
				newprescribe.ModeId = system_dialysisPrescribe.ModeId
				newprescribe.DialysisDuration = system_dialysisPrescribe.DialysisDuration
				newprescribe.ReplacementWay = system_dialysisPrescribe.ReplacementWay
				newprescribe.HemodialysisMachine = system_dialysisPrescribe.HemodialysisMachine
				newprescribe.BloodFilter = system_dialysisPrescribe.BloodFilter
				newprescribe.PerfusionApparatus = system_dialysisPrescribe.PerfusionApparatus
				newprescribe.BloodFlowVolume = system_dialysisPrescribe.BloodFlowVolume
				newprescribe.DisplaceLiqui = system_dialysisPrescribe.DisplaceLiqui
				newprescribe.Glucose = system_dialysisPrescribe.Glucose
				newprescribe.DialysateFlow = system_dialysisPrescribe.DialysateFlow
				newprescribe.Kalium = system_dialysisPrescribe.Kalium
				newprescribe.Sodium = system_dialysisPrescribe.Sodium
				newprescribe.Calcium = system_dialysisPrescribe.Calcium
				newprescribe.Bicarbonate = system_dialysisPrescribe.Bicarbonate
				newprescribe.DialysateTemperature = system_dialysisPrescribe.DialysateTemperature
				newprescribe.Conductivity = system_dialysisPrescribe.Conductivity
				newprescribe.BodyFluid = system_dialysisPrescribe.BodyFluid
				newprescribe.SpecialMedicine = system_dialysisPrescribe.SpecialMedicine
				newprescribe.SpecialMedicineOther = system_dialysisPrescribe.SpecialMedicineOther
				newprescribe.DisplaceLiquiPart = system_dialysisPrescribe.DisplaceLiquiPart
				newprescribe.DisplaceLiquiValue = system_dialysisPrescribe.DisplaceLiquiValue
				newprescribe.BloodAccess = system_dialysisPrescribe.BloodAccess
				newprescribe.Ultrafiltration = system_dialysisPrescribe.Ultrafiltration
				newprescribe.DialysisDurationHour = system_dialysisPrescribe.DialysisDurationHour
				newprescribe.DialysisDurationMinute = system_dialysisPrescribe.DialysisDurationMinute
				newprescribe.DialysateFormulation = system_dialysisPrescribe.DialysateFormulation
				newprescribe.Dialyzer = system_dialysisPrescribe.Dialyzer
				newprescribe.ReplacementTotal = system_dialysisPrescribe.ReplacementTotal
				newprescribe.DialyzerPerfusionApparatus = system_dialysisPrescribe.DialyzerPerfusionApparatus
				newprescribe.DialysisIrrigation = system_dialysisPrescribe.DialysisIrrigation
				newprescribe.DialysisDialyszers = system_dialysisPrescribe.DialysisDialyszers
				newprescribe.BodyFluidOther = system_dialysisPrescribe.BodyFluidOther
				newprescribe.TargetKtv = system_dialysisPrescribe.TargetKtv
				newprescribe.CreatedTime = time.Now().Unix()
				newprescribe.UpdatedTime = time.Now().Unix()
				newprescribe.RecordDate = theAssessmentDateTime
				newprescribe.DewaterAmount = dewater_amount
				newprescribe.TargetUltrafiltration = dewater_amount
				newprescribe.Chaptalization = lastDialysisPrescribe.Chaptalization
				newprescribe.Status = 1
				newprescribe.PrescribingNumber = 1

				if adminUserInfo.Org.Id == 10340 {
					newprescribe.TargetUltrafiltration = 0
				}
				if adminUserInfo.Org.Id == 10121 {
					newprescribe.DialysisDurationHour = 4
					newprescribe.DialysisDurationMinute = 0
					newprescribe.BloodAccess = dialysisSolution.BloodAccess
				}
				err := service.AddSigleRecord(&newprescribe)

				//记录日志
				byterequest, _ := json.Marshal(newprescribe)
				prescriptionLog := models.XtDialysisPrescriptionLog{
					UserOrgId:   adminUserInfo.Org.Id,
					Ctime:       time.Now().Unix(),
					Mtime:       0,
					ErrLog:      string(byterequest),
					AdminUserId: adminUserInfo.AdminUser.Id,
					RecordDate:  newprescribe.RecordDate,
					PatientId:   id,
					Source:      "物联网上传",
					Status:      1,
				}

				service.CreatePrescriptionLog(prescriptionLog)
				key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
				redis := service.RedisClient()
				//清空key 值
				redis.Set(key, "", time.Second)
				keyTwo := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":prescriptions_list_all"
				redis.Set(keyTwo, "", time.Second)
				scheduleDateStartOne := thisTime.Format("2006-01-02")
				keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
				redis.Set(keyThree, "", time.Second)
				defer redis.Close()
				if err != nil {
					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
				}

			} else {
				var newprescribe models.DialysisPrescription
				newprescribe.UserOrgId = adminUserInfo.Org.Id
				newprescribe.PatientId = id
				newprescribe.ModeId = mode_id
				newprescribe.CreatedTime = time.Now().Unix()
				newprescribe.UpdatedTime = time.Now().Unix()
				newprescribe.RecordDate = theAssessmentDateTime
				newprescribe.DewaterAmount = dewater_amount
				newprescribe.TargetUltrafiltration = dewater_amount
				newprescribe.Status = 1

				err := service.AddSigleRecord(&newprescribe)
				//记录日志
				byterequest, _ := json.Marshal(newprescribe)
				prescriptionLog := models.XtDialysisPrescriptionLog{
					UserOrgId:   adminUserInfo.Org.Id,
					Ctime:       time.Now().Unix(),
					Mtime:       0,
					ErrLog:      string(byterequest),
					AdminUserId: adminUserInfo.AdminUser.Id,
					RecordDate:  newprescribe.RecordDate,
					PatientId:   id,
					Source:      "物联网上传",
					Status:      1,
				}

				service.CreatePrescriptionLog(prescriptionLog)
				key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
				redis := service.RedisClient()
				//清空key 值
				redis.Set(key, "", time.Second)
				keyTwo := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":prescriptions_list_all"
				redis.Set(keyTwo, "", time.Second)
				scheduleDateStartOne := thisTime.Format("2006-01-02")
				keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
				redis.Set(keyThree, "", time.Second)
				defer redis.Close()
				if err != nil {
					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
				}
			}
		}

		if dialysisPrescribe != nil && dialysisPrescribe.TargetUltrafiltration == 0 {
			dialysisPrescribe.UpdatedTime = time.Now().Unix()
			dialysisPrescribe.RecordDate = theAssessmentDateTime
			dialysisPrescribe.DewaterAmount = dewater_amount
			dialysisPrescribe.TargetUltrafiltration = dewater_amount
			dialysisPrescribe.Status = 1
			if adminUserInfo.Org.Id == 10340 {
				dialysisPrescribe.TargetUltrafiltration = 0
			}
			updateErr := service.UpDateDialysisPrescription(dialysisPrescribe)
			//记录日志
			byterequest, _ := json.Marshal(dialysisPrescribe)
			prescriptionLog := models.XtDialysisPrescriptionLog{
				UserOrgId:   adminUserInfo.Org.Id,
				Ctime:       time.Now().Unix(),
				Mtime:       0,
				ErrLog:      string(byterequest),
				AdminUserId: adminUserInfo.AdminUser.Id,
				RecordDate:  dialysisPrescribe.RecordDate,
				PatientId:   id,
				Source:      "物联网上传",
				Status:      1,
			}

			service.CreatePrescriptionLog(prescriptionLog)
			key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
			redis := service.RedisClient()
			//清空key 值
			redis.Set(key, "", time.Second)
			keyTwo := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":prescriptions_list_all"
			redis.Set(keyTwo, "", time.Second)
			scheduleDateStartOne := thisTime.Format("2006-01-02")
			keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
			redis.Set(keyThree, "", time.Second)
			defer redis.Close()
			if updateErr != nil {
				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
			}
		}

		theEvaluation, getPEErr := service.MobileGetPredialysisEvaluationOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
		if getPEErr != nil {
			c.ErrorLog("获取透前评估失败:%v", getPEErr)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}

		var evaluation models.PredialysisEvaluation
		if theEvaluation != nil {
			evaluation = *theEvaluation
		}

		// 如果今天没有透前评估，则插入新的数据
		if theEvaluation == nil {
			evaluation.CreatedTime = time.Now().Unix()
			evaluation.Status = 1
			evaluation.AssessmentDate = theAssessmentDateTime
			evaluation.PatientId = id
			evaluation.UserOrgId = adminUserInfo.Org.Id
			// 获取上一次透前评估信息，部分数据是需要从上一次透前评估继承
			lastPredialysisEvaluation, _ := service.MobileGetLastTimePredialysisEvaluationOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
			// 获取上一次透后评估，插入本次透前评估的上次透后体重（weight_after_last_transparency）字段
			assessmentAfterDislysis, getAADErr := service.MobileGetLastTimeAssessmentAfterDislysisOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
			if getAADErr != nil {
				c.ErrorLog("获取透后评估失败:%v", getAADErr)
				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
				return
			}

			// 获取干体重，先从干体重配置里去读，如果没有，则读取上一次透前评估的干体重
			weight, err := service.FindLastDryWeightAdjust(adminUserInfo.Org.Id, id)
			if err == gorm.ErrRecordNotFound {
				if lastPredialysisEvaluation != nil {
					evaluation.DryWeight = lastPredialysisEvaluation.DryWeight
				} else {
					evaluation.DryWeight = 0
				}
			} else {
				evaluation.DryWeight = weight.DryWeight
			}

			if assessmentAfterDislysis != nil {
				evaluation.WeightAfterLastTransparency = assessmentAfterDislysis.WeightAfter
			}

			if lastPredialysisEvaluation != nil {
				evaluation.BloodAccessPartId = lastPredialysisEvaluation.BloodAccessPartId
				evaluation.BloodAccessPartOperaId = lastPredialysisEvaluation.BloodAccessPartOperaId
				evaluation.AdditionalWeight = lastPredialysisEvaluation.AdditionalWeight
				evaluation.Temperature = lastPredialysisEvaluation.Temperature
				evaluation.BreathingRate = lastPredialysisEvaluation.BreathingRate
				evaluation.Catheter = lastPredialysisEvaluation.Catheter
				evaluation.InternalFistula = lastPredialysisEvaluation.InternalFistula
				evaluation.PulseFrequency = lastPredialysisEvaluation.PulseFrequency
				evaluation.Complication = lastPredialysisEvaluation.Complication
				evaluation.LastPostDialysis = lastPredialysisEvaluation.LastPostDialysis
				evaluation.DialysisInterphase = lastPredialysisEvaluation.DialysisInterphase
				evaluation.SymptomBeforeDialysis = lastPredialysisEvaluation.SymptomBeforeDialysis
				evaluation.PunctureNeedle = lastPredialysisEvaluation.PunctureNeedle
				evaluation.PunctureWay = lastPredialysisEvaluation.PunctureWay

				evaluation.InternalFistulaSkin = lastPredialysisEvaluation.InternalFistulaSkin //血透通路皮肤情况
				evaluation.CatheterBend = lastPredialysisEvaluation.CatheterBend               //导管打折
				evaluation.IsHemorrhage = lastPredialysisEvaluation.IsHemorrhage               //出血
				evaluation.IsInfect = lastPredialysisEvaluation.IsInfect                       //感染
				evaluation.Exposed = lastPredialysisEvaluation.Exposed                         // 外漏
				evaluation.DialysisCount = lastPredialysisEvaluation.DialysisCount             //呼吸频次
				evaluation.Phinholing = lastPredialysisEvaluation.Phinholing                   //针眼

				evaluation.Remark = lastPredialysisEvaluation.Remark
				if adminUserInfo.Org.Id == 10318 || adminUserInfo.Org.Id == 10490 {
					evaluation.Remark = ""
				}
				if adminUserInfo.Org.Id == 10340 || adminUserInfo.Org.Id == 10447 {
					evaluation.BreathingRate = "20"
				}
				if adminUserInfo.Org.Id == 10445 {
					evaluation.VenousCatheterization = lastPredialysisEvaluation.VenousCatheterization
				}

				if adminUserInfo.Org.Id == 9829 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 10471 {
					evaluation.PulseFrequency = 80
				}
				if adminUserInfo.Org.Id == 10440 {
					evaluation.Temperature = 36.5
				}
				if adminUserInfo.Org.Id == 10469 {
					evaluation.Temperature = 36.5
				}
				if adminUserInfo.Org.Id == 10471 {
					evaluation.Temperature = 36.5
				}
			}
		} else {
			evaluation.UpdatedTime = time.Now().Unix()
		}

		evaluation.WeightBefore = weighing_before
		evaluation.AssessmentTime = time.Now().Unix()

		err := service.UpadatePredialysisEvaluation(&evaluation)

		//记录日志
		byterequest, _ := json.Marshal(evaluation)
		beforLog := models.XtAssessmentBeforeDislysisLog{
			UserOrgId:   adminUserInfo.Org.Id,
			Ctime:       time.Now().Unix(),
			Mtime:       0,
			ErrLog:      string(byterequest),
			AdminUserId: adminUserInfo.AdminUser.Id,
			RecordDate:  evaluation.AssessmentDate,
			PatientId:   id,
			Source:      "物联网上传",
			Status:      1,
		}

		service.CreateBeforLog(beforLog)

		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_before_dislysis"
		redis := service.RedisClient()
		//清空key 值
		redis.Set(key, "", time.Second)
		keyOne := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_befores_list_all"
		redis.Set(keyOne, "", time.Second)
		assessdateDateStart := thisTime.Format("2006-01-02")
		keyTwo := "scheduals_" + assessdateDateStart + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
		redis.Set(keyTwo, "", time.Second)
		redis.Close()
		if err != nil {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
			return
		}

		c.ServeSuccessJSON(map[string]interface{}{
			"msg":        "ok",
			"evaluation": evaluation,
		})
		return

	} else {

		// 保存透后相关数据
		assessmentAfterDislysis, getAADErr := service.MobileGetAssessmentAfterDislysisOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
		if getAADErr != nil {
			c.ErrorLog("获取透后评估失败:%v", getAADErr)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}

		var afterevaluation models.AssessmentAfterDislysis
		if assessmentAfterDislysis != nil {
			afterevaluation = *assessmentAfterDislysis
		}
		if assessmentAfterDislysis == nil {
			afterevaluation.CreatedTime = time.Now().Unix()
			afterevaluation.Status = 1
			afterevaluation.AssessmentDate = theAssessmentDateTime
			afterevaluation.PatientId = id
			afterevaluation.UserOrgId = adminUserInfo.Org.Id
		} else {

			afterevaluation.UpdatedTime = time.Now().Unix()
		}

		afterevaluation.WeightAfter = weight_after
		afterevaluation.WeightLoss = weight_loss

		if adminUserInfo.Org.Id == 10138 {
			afterevaluation.LeaveOfficeMethod = assessmentAfterDislysis.LeaveOfficeMethod //离科方式
			afterevaluation.Lapse = assessmentAfterDislysis.Lapse                         //转归
			afterevaluation.Consciousness = assessmentAfterDislysis.Consciousness         //意识
			afterevaluation.Fallrisk = assessmentAfterDislysis.Fallrisk
		}

		if adminUserInfo.Org.Id == 10307 || adminUserInfo.Org.Id == 10445 {
			afterevaluation.ActualUltrafiltration = weight_loss * 1000 //中能建的计量单位是毫升（ml）
		}
		//北方营口
		if adminUserInfo.Org.Id == 10445 {
			prescribe, _ := service.MobileGetDialysisPrescribe(adminUserInfo.Org.Id, id, theAssessmentDateTime)
			afterevaluation.ActualDisplacement = prescribe.DisplaceLiquiValue
		}

		//蓬安济民

		if adminUserInfo.Org.Id == 9829 || adminUserInfo.Org.Id == 10469 {
			afterevaluation.PulseFrequency = 80
		}

		err := service.UpdateAssessmentAfterDislysisRecord(&afterevaluation)

		//记录日志
		byterequest, _ := json.Marshal(afterevaluation)
		afterDialysisLog := models.XtAssessmentAfterDialysisLog{
			UserOrgId:   afterevaluation.UserOrgId,
			PatientId:   afterevaluation.PatientId,
			RecordDate:  afterevaluation.AssessmentDate,
			Status:      1,
			ErrLog:      string(byterequest),
			AdminUserId: adminUserInfo.AdminUser.Id,
			Ctime:       time.Now().Unix(),
			Mtime:       0,
			Source:      "物联网称重",
		}

		service.CreateAfterDialysisLog(afterDialysisLog)

		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_after_dislysis"
		redis := service.RedisClient()
		//清空key 值
		redis.Set(key, "", time.Second)
		keyThree := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_after_dislysis_list_all"
		redis.Set(keyThree, "", time.Second)
		assessdateDateStart := thisTime.Format("2006-01-02")
		keyTwo := "scheduals_" + assessdateDateStart + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
		redis.Set(keyTwo, "", time.Second)
		redis.Close()
		if err == nil {
			c.ServeSuccessJSON(map[string]interface{}{
				"assessmentAfterDislysis": afterevaluation,
			})
		}
	}
}

func (c *CheckWeightApiController) SetSyncTime() {
	sn := c.GetString("sn")
	if len(sn) > 0 {
		redis := service.RedisClient()
		defer redis.Close()
		redis.Set(sn, 0, 0)
	}
	serviceTime := time.Now().Unix()
	c.ServeSuccessJSON(map[string]interface{}{
		"status":      1,
		"servicetime": serviceTime,
	})
}

func (c *CheckWeightApiController) GetPatientList() {
	ftype, _ := c.GetInt64("type", 0)
	sn := c.GetString("sn")
	syncTime := int64(0)

	redis := service.RedisClient()
	defer redis.Close()
	if len(sn) > 0 {
		syncTimeStr, _ := redis.Get(sn).Result()
		syncTime, _ = strconv.ParseInt(syncTimeStr, 10, 64)
	}

	if ftype == 1 {
		timeNow := time.Now().Unix()
		redis.Set(sn, timeNow, 0)
	}

	adminUserInfo := c.GetMobileAdminUserInfo()

	patientList, total, error := service.GetPatientListByUpdateTime(adminUserInfo.Org.Id, int64(syncTime))
	need_update := 0
	if syncTime == 0 {
		need_update = 1
	}
	if error != nil {
		c.ErrorLog("获取病人列表失败:%v", error)
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
	serviceTime := time.Now().Unix()
	c.ServeSuccessJSON(map[string]interface{}{
		"need_update": need_update,
		"patientlist": patientList,
		"total":       total,
		"servicetime": serviceTime,
	})
}

func (c *CheckWeightApiController) GetPatientListForSchedules() {
	thisTime := time.Now()
	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	syncTime := theStartTime.Unix()
	adminUserInfo := c.GetMobileAdminUserInfo()
	patientList, total, error := service.GetPatientListBySchedules(adminUserInfo.Org.Id, syncTime)
	patientSchedule := make([]map[string]interface{}, 0)
	for _, item := range patientList {
		patientTemp := make(map[string]interface{})
		patientTemp["patient_id"] = item.PatientId
		patientTemp["patient_name"] = item.Patient.Name
		patientTemp["schedule_type"] = item.ScheduleType
		patientSchedule = append(patientSchedule, patientTemp)
	}

	if error != nil {
		c.ErrorLog("获取病人列表失败:%v", error)
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
	serviceTime := time.Now().Unix()
	c.ServeSuccessJSON(map[string]interface{}{
		"patientlist": patientSchedule,
		"total":       total,
		"servicetime": serviceTime,
	})
}

func (c *CheckWeightApiController) GetPatientListForSchedulesFind() {
	patient_name := c.GetString("patient_name") //脉率
	thisTime := time.Now()
	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	syncTime := theStartTime.Unix()
	adminUserInfo := c.GetMobileAdminUserInfo()
	if len(patient_name) == 0 {
		patientList, total, error := service.GetPatientListBySchedules(adminUserInfo.Org.Id, syncTime)
		patientSchedule := make([]map[string]interface{}, 0)
		for _, item := range patientList {
			patientTemp := make(map[string]interface{})
			patientTemp["patient_id"] = item.PatientId
			patientTemp["patient_name"] = item.Patient.Name
			patientTemp["schedule_type"] = item.ScheduleType
			patientSchedule = append(patientSchedule, patientTemp)
		}

		if error != nil {
			c.ErrorLog("获取病人列表失败:%v", error)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}
		serviceTime := time.Now().Unix()
		c.ServeSuccessJSON(map[string]interface{}{
			"patientlist": patientSchedule,
			"total":       total,
			"servicetime": serviceTime,
		})
	} else {
		patientList, total, error := service.GetPatientListBySchedulesFind(adminUserInfo.Org.Id, syncTime, patient_name)
		patientSchedule := make([]map[string]interface{}, 0)
		for _, item := range patientList {
			if item.Patient.ID > 0 {
				patientTemp := make(map[string]interface{})
				patientTemp["patient_id"] = item.PatientId
				patientTemp["patient_name"] = item.Patient.Name
				patientTemp["schedule_type"] = item.ScheduleType
				patientSchedule = append(patientSchedule, patientTemp)
			}
		}

		if error != nil {
			c.ErrorLog("获取病人列表失败:%v", error)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}

		serviceTime := time.Now().Unix()
		c.ServeSuccessJSON(map[string]interface{}{
			"patientlist": patientSchedule,
			"total":       total,
			"servicetime": serviceTime,
		})
	}
}

func (c *CheckWeightApiController) GetPatientListById() {
	patientId, _ := c.GetInt64("patient_id", 0)
	if patientId <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}

	adminUserInfo := c.GetMobileAdminUserInfo()
	patient, error := service.GetPatientListById(adminUserInfo.Org.Id, patientId)
	if error != nil {
		c.ErrorLog("获取病人详情失败:%v", error)
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
	c.ServeSuccessJSON(map[string]interface{}{
		"patientinfo": patient,
	})
}

func (c *CheckWeightApiController) GetPatientInfoDialysis() {
	id, _ := c.GetInt64("patient", 0)
	if id <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	adminUserInfo := c.GetMobileAdminUserInfo()
	patient, _ := service.FindPatientByIdWithDiseases(adminUserInfo.Org.Id, id)
	if patient.ID <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
		return
	}

	var dialysisinfo map[string]interface{}
	dialysisinfo = make(map[string]interface{})

	dialysisinfo["id"] = patient.ID
	dialysisinfo["name"] = patient.Name
	dialysisinfo["dialysis_no"] = patient.DialysisNo

	thisTime := time.Now()

	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	scheduleDateEnd := thisTime.Format("2006-01-02") + " 23:59:59"
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
	startTime := theStartTime.Unix()
	endTime := theEndTime.Unix()

	// 判断当前用户是透析前还是透析后
	var dialysistype int

	_, dialysisOrder := service.FindDialysisRecordById(adminUserInfo.Org.Id, id, startTime)
	if dialysisOrder == nil {
		dialysistype = 1
	} else {
		dialysistype = 2
	}

	// 获取当前或者下次排班信息
	var sc map[string]interface{}
	sc = make(map[string]interface{})
	if dialysistype == 1 {
		daySchedule, _ := service.GetPatientScheduleFormDay(adminUserInfo.Org.Id, startTime, endTime, id)
		if len(daySchedule) <= 0 {
			sc["code"] = 1
			sc["msg"] = "抱歉，您今天没有排版！"
			sc["mode"] = 0
			sc["data"] = daySchedule
		} else {
			if daySchedule[0].Schedule.ID > 0 {
				sc["code"] = 0
				sc["msg"] = ""
				sc["mode"] = daySchedule[0].Schedule.ModeId
				sc["data"] = daySchedule
			} else {
				sc["code"] = 1
				sc["msg"] = "抱歉，您今天没有排版！"
				sc["mode"] = 0
				sc["data"] = daySchedule
			}
		}

		// 排队叫号的签到
		go func() {
			ssoDomain := beego.AppConfig.String("call_domain")
			api := ssoDomain + "/index/patientsign/" + strconv.FormatInt(adminUserInfo.Org.Id, 10) + "/" + strconv.FormatInt(id, 10)
			values := make(url.Values)
			http.PostForm(api, values)
		}()
	} else {
		nextSchedule, _ := service.GetNextSchedule(adminUserInfo.Org.Id, endTime, id)
		if len(nextSchedule) <= 0 {
			sc["code"] = 1
			sc["msg"] = "抱歉，您后续没有排版！"
			sc["mode"] = 0
			sc["data"] = nextSchedule
		} else {
			if nextSchedule[0].Schedule.ID > 0 {
				sc["code"] = 0
				sc["msg"] = ""
				sc["mode"] = nextSchedule[0].Schedule.ModeId
				sc["data"] = nextSchedule
			} else {
				sc["code"] = 1
				sc["msg"] = "抱歉，您后续没有排版！"
				sc["mode"] = 0
				sc["data"] = nextSchedule
			}
		}
	}

	switch sc["mode"] {
	case 1:
		sc["mode"] = "HD"
	case 2:
		sc["mode"] = "HDF"
	case 3:
		sc["mode"] = "HD+HP"
	case 4:
		sc["mode"] = "HP"
	case 5:
		sc["mode"] = "HF"
	case 6:
		sc["mode"] = "SCUF"
	case 7:
		sc["mode"] = "IUF"
	case 8:
		sc["mode"] = "HFHD"
	case 9:
		sc["mode"] = "HFHD+HP"
	case 10:
		sc["mode"] = "PHF"
	case 11:
		sc["mode"] = "HFR"
	case 12:
		sc["mode"] = "HDF+HP"
	case 13:
		sc["mode"] = "CRRT"
	case 14:
		sc["mode"] = "腹水回输"
	case 15:
		sc["mode"] = "HD前置换"
	case 16:
		sc["mode"] = "HD后置换"
	case 17:
		sc["mode"] = "HDF前置换"
	case 18:
		sc["mode"] = "HDF后置换"
	default:
		sc["mode"] = "HD"
	}

	// 获取患者透前干体重或者获取患者透前体重
	var dry_weight map[string]interface{}
	dry_weight = make(map[string]interface{})
	var after_dry_weight map[string]interface{}
	after_dry_weight = make(map[string]interface{})
	if dialysistype == 1 {

		lastPredialysisEvaluation, getLPEErr := service.MobileGetLastTimePredialysisEvaluation(adminUserInfo.Org.Id, id, endTime)
		weight, err := service.FindLastDryWeightAdjust(adminUserInfo.Org.Id, id)
		if err == gorm.ErrRecordNotFound {
			if getLPEErr != nil {
				dry_weight["code"] = 1
				dry_weight["dry_weight"] = nil
			} else {
				if lastPredialysisEvaluation == nil {
					dry_weight["code"] = 1
					dry_weight["dry_weight"] = nil
				} else {
					// 传输的干体重实际为干体重加上衣服重
					dry_weight["code"] = 0
					dry_weight["dry_weight"] = lastPredialysisEvaluation.DryWeight + lastPredialysisEvaluation.AdditionalWeight
				}
			}
		} else {
			if err != nil {
				dry_weight["code"] = 1
				dry_weight["dry_weight"] = nil
			} else {
				dry_weight["code"] = 0
				if getLPEErr != nil {
					dry_weight["code"] = 0
					dry_weight["dry_weight"] = weight.DryWeight
				} else {
					if lastPredialysisEvaluation == nil {
						dry_weight["code"] = 1
						dry_weight["dry_weight"] = weight.DryWeight
					} else {
						// 传输的干体重实际为干体重加上衣服重
						dry_weight["code"] = 0
						dry_weight["dry_weight"] = weight.DryWeight + lastPredialysisEvaluation.AdditionalWeight
					}
				}
			}
		}

	} else {
		predialysisEvaluation, getPEErr := service.MobileGetPredialysisEvaluation(adminUserInfo.Org.Id, id, startTime)
		if getPEErr != nil {
			dry_weight["code"] = 1
			dry_weight["dry_weight"] = nil
		} else {
			if predialysisEvaluation == nil {
				dry_weight["code"] = 1
				dry_weight["dry_weight"] = nil
			} else {
				dry_weight["code"] = 0
				dry_weight["dry_weight"] = predialysisEvaluation.WeightBefore
			}
		}

		lastPredialysisEvaluation, getLPEErr := service.MobileGetLastTimePredialysisEvaluation(adminUserInfo.Org.Id, id, endTime)
		weight, err := service.FindLastDryWeightAdjust(adminUserInfo.Org.Id, id)
		if err == gorm.ErrRecordNotFound {
			if getLPEErr != nil {
				after_dry_weight["code"] = 1
				after_dry_weight["dry_weight"] = nil
			} else {
				if lastPredialysisEvaluation == nil {
					after_dry_weight["code"] = 1
					after_dry_weight["dry_weight"] = nil
				} else {
					// 传输的干体重实际为干体重加上衣服重
					after_dry_weight["code"] = 0
					after_dry_weight["dry_weight"] = lastPredialysisEvaluation.DryWeight + lastPredialysisEvaluation.AdditionalWeight
				}
			}
		} else {
			if err != nil {
				after_dry_weight["code"] = 1
				after_dry_weight["dry_weight"] = nil
			} else {
				after_dry_weight["code"] = 0
				if getLPEErr != nil {
					after_dry_weight["code"] = 0
					after_dry_weight["dry_weight"] = weight.DryWeight
				} else {
					if lastPredialysisEvaluation == nil {
						after_dry_weight["code"] = 1
						after_dry_weight["dry_weight"] = weight.DryWeight
					} else {
						// 传输的干体重实际为干体重加上衣服重
						after_dry_weight["code"] = 0
						after_dry_weight["dry_weight"] = weight.DryWeight + lastPredialysisEvaluation.AdditionalWeight
					}
				}
			}
		}
	}

	c.ServeSuccessJSON(map[string]interface{}{
		"dialysistype":     dialysistype,
		"patient":          dialysisinfo,
		"schedule":         sc,
		"dryweight":        dry_weight,
		"after_dry_weight": after_dry_weight,
	})
	return
}
func (c *CheckWeightApiController) GetPatientInfoBeforeDialysis() {
	id, _ := c.GetInt64("patient", 0)
	if id <= 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	adminUserInfo := c.GetMobileAdminUserInfo()
	patient, _ := service.FindPatientByIdWithDiseases(adminUserInfo.Org.Id, id)
	if patient.ID == 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
		return
	}

	var dialysisinfo map[string]interface{}
	dialysisinfo = make(map[string]interface{})

	dialysisinfo["id"] = patient.ID
	dialysisinfo["name"] = patient.Name
	dialysisinfo["dialysis_no"] = patient.DialysisNo

	thisTime := time.Now()

	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
	scheduleDateEnd := thisTime.Format("2006-01-02") + " 23:59:59"
	fmt.Println(scheduleDateStart, scheduleDateEnd)
	timeLayout := "2006-01-02 15:04:05"
	loc, _ := time.LoadLocation("Local")
	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
	theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
	fmt.Println(theStartTime, theEndTime)
	startTime := theStartTime.Unix()
	endTime := theEndTime.Unix()

	var sc map[string]interface{}
	sc = make(map[string]interface{})
	//一天只有排班一次
	daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, startTime, endTime, id)
	if daySchedule.ID > 0 {
		switch daySchedule.ModeId {
		case 1:
			sc["mode"] = "HD"
		case 2:
			sc["mode"] = "HDF"
		case 3:
			sc["mode"] = "HD+HP"
		case 4:
			sc["mode"] = "HP"
		case 5:
			sc["mode"] = "HF"
		case 6:
			sc["mode"] = "SCUF"
		case 7:
			sc["mode"] = "IUF"
		case 8:
			sc["mode"] = "HFHD"
		case 9:
			sc["mode"] = "HFHD+HP"
		case 10:
			sc["mode"] = "PHF"
		case 11:
			sc["mode"] = "HFR"
		case 12:
			sc["mode"] = "HDF+HP"
		case 13:
			sc["mode"] = "CRRT"
		case 14:
			sc["mode"] = "腹水回输"
		case 15:
			sc["mode"] = "HD前置换"
		case 16:
			sc["mode"] = "HD后置换"
		case 17:
			sc["mode"] = "HDF前置换"
		case 18:
			sc["mode"] = "HDF后置换"
		default:
			sc["mode"] = "HD"
		}
		sc["code"] = 0
		sc["msg"] = ""
		sc["data"] = daySchedule
	} else {
		sc["code"] = 1
		sc["msg"] = "抱歉，您今天没有排版！"
		sc["mode"] = ""
		sc["data"] = daySchedule
	}

	fmt.Println(sc)

	type dryWeight struct {
		code       int
		dry_weight float64
	}

	var dry_weight map[string]interface{}
	dry_weight = make(map[string]interface{})

	lastPredialysisEvaluation, getLPEErr := service.MobileGetLastTimePredialysisEvaluation(adminUserInfo.Org.Id, id, startTime)
	if getLPEErr != nil {
		dry_weight["code"] = 1
		dry_weight["dry_weight"] = nil
	} else {
		if lastPredialysisEvaluation == nil {
			dry_weight["code"] = 1
			dry_weight["dry_weight"] = nil
		} else {
			dry_weight["code"] = 0
			dry_weight["dry_weight"] = lastPredialysisEvaluation.DryWeight
		}
	}

	c.ServeSuccessJSON(map[string]interface{}{
		"patient":   dialysisinfo,
		"schedule":  sc,
		"dryweight": dry_weight,
	})
	return
}