宣教信息

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -515,6 +515,8 @@ func (this *NewDialysisApiController) GetPatientDetail() {
 	id, _ := this.GetInt64("id")
 	//获取病人详情信息
 	detail, err := service.GetPatientDetailTwo(id)
+	//获取传染病详情
+	diseases := service.GetPatientDiseasesTwo(detail.BloodId)
 	//获取血透医嘱管理
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
@@ -522,6 +524,7 @@ func (this *NewDialysisApiController) GetPatientDetail() {
 	}
 	this.ServeSuccessJSON(map[string]interface{}{
 		"patientDetail": detail,
+		"diseases":      diseases,
 	})
 }
 
@@ -766,3 +769,98 @@ func (this *NewDialysisApiController) GetlongDialysisrecord() {
 		"total":          total,
 	})
 }
+
+func (this *NewDialysisApiController) GetRescuerecord() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	rescuerecord, total, err := service.GetRescuerecord(patient.BloodId, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"rescuerecord": rescuerecord,
+		"total":        total,
+	})
+}
+
+func (this *NewDialysisApiController) GetScheduling() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	mode_type, _ := this.GetInt64("mode_types")
+	fmt.Print("透析模式", mode_type)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	scheduling, total, err := service.GetScheduling(patient.BloodId, startime, endtime, limit, page, orgid, mode_type)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"scheduling": scheduling,
+		"total":      total,
+	})
+}
+
+func (this *NewDialysisApiController) GetEducation() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	education, total, err := service.GetEducation(patient.BloodId, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"education": education,
+		"total":     total,
+	})
+}

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -47,4 +47,7 @@ func NewMobileAPIControllersRegisterRouters() {
 	beego.Router("/m/api/patient/deletedryweight", &NewDialysisApiController{}, "Delete:DeleteDryWeight")
 	beego.Router("/m/api/patient/getdryweightdetail", &NewDialysisApiController{}, "Get:GetDryWeightDetail")
 	beego.Router("/m/api/patient/getlongdialysisrecord", &NewDialysisApiController{}, "Get:GetlongDialysisrecord")
+	beego.Router("/m/api/patient/getrescuerecord", &NewDialysisApiController{}, "Get:GetRescuerecord")
+	beego.Router("/m/api/patient/getscheduling", &NewDialysisApiController{}, "Get:GetScheduling")
+	beego.Router("/m/api/patient/geteducation", &NewDialysisApiController{}, "Get:GetEducation")
 }

models/patient_models.go

@@ -615,3 +615,17 @@ func (PatientCourseOfDisease) TableName() string {
 
 	return "xt_patient_course_of_disease"
 }
+
+type XtPatientsInfectiousDiseases struct {
+	ID          int64 `gorm:"column:id" json:"id" form:"id"`
+	PatientId   int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	DiseaseId   int64 `gorm:"column:disease_id" json:"disease_id" form:"disease_id"`
+	Status      int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (XtPatientsInfectiousDiseases) TableName() string {
+
+	return "xt_patients_infectious_diseases"
+}

models/user_models.go

@@ -337,3 +337,85 @@ func (XtDialysisSolution) TableName() string {
 
 	return "xt_dialysis_prescription"
 }
+
+type XtPatientRescueRecords struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId      int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Recorder   int64  `gorm:"column:recorder" json:"recorder" form:"recorder"`
+	RecordTime int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	Content    string `gorm:"column:content" json:"content" form:"content"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime      int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime      int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	UserName   string `gorm:"column:user_name" json:"user_name" form:"user_name"`
+}
+
+type XtPatientRescueRecord struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId      int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Recorder   int64  `gorm:"column:recorder" json:"recorder" form:"recorder"`
+	RecordTime int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	Content    string `gorm:"column:content" json:"content" form:"content"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime      int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime      int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtPatientRescueRecord) TableName() string {
+
+	return "xt_patient_rescue_record"
+}
+
+type XtSchedules struct {
+	ID           int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId    int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PartitionId  int64  `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId        int64  `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId    int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate int64  `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType int64  `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek int64  `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId       int64  `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status       int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime  int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Number       string `gorm:"column:number" json:"number"`
+	Name         string `gorm:"column:name" json:"name"`
+}
+
+func (XtSchedules) TableName() string {
+
+	return "xt_schedule"
+}
+
+type XtTreatmentSummary struct {
+	ID                int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId         int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId         int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	AssessmentDate    int64  `gorm:"column:assessment_date" json:"assessment_date" form:"assessment_date"`
+	DialysisOrderId   int64  `gorm:"column:dialysis_order_id" json:"dialysis_order_id" form:"dialysis_order_id"`
+	Mission           string `gorm:"column:mission" json:"mission" form:"mission"`
+	DialysisSummary   string `gorm:"column:dialysis_summary" json:"dialysis_summary" form:"dialysis_summary"`
+	Change            int64  `gorm:"column:change" json:"change" form:"change"`
+	SjNurse           int64  `gorm:"column:sj_nurse" json:"sj_nurse" form:"sj_nurse"`
+	ZlNurse           int64  `gorm:"column:zl_nurse" json:"zl_nurse" form:"zl_nurse"`
+	HdNurse           int64  `gorm:"column:hd_nurse" json:"hd_nurse" form:"hd_nurse"`
+	XjNurse           int64  `gorm:"column:xj_nurse" json:"xj_nurse" form:"xj_nurse"`
+	ZlDoctor          int64  `gorm:"column:zl_doctor" json:"zl_doctor" form:"zl_doctor"`
+	ChannelImage      string `gorm:"column:channel_image" json:"channel_image" form:"channel_image"`
+	Puncture          string `gorm:"column:puncture" json:"puncture" form:"puncture"`
+	PunctureNeedle    string `gorm:"column:puncture_needle" json:"puncture_needle" form:"puncture_needle"`
+	PunctureDirection string `gorm:"column:puncture_direction" json:"puncture_direction" form:"puncture_direction"`
+	Status            int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime       int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime       int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Creater           int64  `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier          int64  `gorm:"column:modifier" json:"modifier" form:"modifier"`
+}
+
+func (XtTreatmentSummary) TableName() string {
+
+	return "xt_treatment_summary"
+}

routers/router.go

@@ -12,7 +12,7 @@ import (
 func init() {
 	beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
 		// AllowAllOrigins:  true,
-		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://xt.test.shengws.com", "https://xt.test.shengws.com", "http://xt.test.sgjyun.com", "https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com"},
+		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://localhost:9531", "http://xt.test.shengws.com", "http://new_mobile.test.sgjyun.com", "https://xt.test.shengws.com", "http://xt.test.sgjyun.com", "https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com"},
 		//AllowOrigins:     []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://xt.test.shengws.com","https://xt.test.shengws.com", "http://xt.test.sgjyun.com","https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com","https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com","http://mobile.sgjyun.com","http://mobile.kuyicloud.com"},
 		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
 		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type", "X-XSRF-TOKEN", "Permission"},

service/patientmanage_service.go

@@ -236,6 +236,19 @@ func GetPatientDetailTwo(id int64) (models.XtPatientsNew, error) {
 	return patients, err
 }
 
+func GetPatientDiseasesTwo(id int64) []int64 {
+	var dis []models.XtPatientsInfectiousDiseases
+	ids := make([]int64, 0)
+	err := XTReadDB().Model(&models.XtPatientsInfectiousDiseases{}).Where("patient_id = ? and status = 1", id).Find(&dis).Error
+	if err != nil || len(dis) == 0 {
+		return ids
+	}
+	for _, item := range dis {
+		ids = append(ids, item.DiseaseId)
+	}
+	return ids
+}
+
 func CreatePatientTwo(patient *models.Patients, contagions []int64, diseases []int64) (err error) {
 
 	user, _ := GetSgjUserByMobild(patient.Phone)
@@ -526,3 +539,67 @@ func GetlongDialysisrecord(patientid int64, startime int64, endtime int64, limit
 
 	return
 }
+
+func GetRescuerecord(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (rescuerecord []*models.XtPatientRescueRecords, total int64, err error) {
+	db := XTReadDB().Table("xt_patient_rescue_record as x").Where("x.status = 1")
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.record_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.record_time <= ?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.record_time desc").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.status,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Scan(&rescuerecord).Error
+	return
+}
+
+func GetScheduling(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64, modeType int64) (schedules []*models.XtSchedules, total int64, err error) {
+	db := XTReadDB().Table("xt_schedule as x").Where("x.status = 1")
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.schedule_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.schedule_date <= ?", endtime)
+	}
+	if modeType > 0 {
+		db = db.Where("x.mode_id = ?", modeType)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.schedule_date desc").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.user_org_id,x.partition_id,x.bed_id,x.patient_id,x.schedule_date,x.schedule_type,x.schedule_week,x.mode_id,x.status,x.created_time,x.updated_time,s.number,z.name").Joins("left join xt_device_number as s on s.id = x.bed_id").Joins("left join xt_device_zone as z on z.id = x.partition_id").Scan(&schedules).Error
+	return
+}
+
+func GetEducation(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (treatment []*models.XtTreatmentSummary, total int64, err error) {
+
+	db := XTReadDB().Table("xt_treatment_summary as x").Where("x.status = 1")
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.assessment_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.assessment_date <= ?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.assessment_date").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.user_org_id,x.patient_id,x.assessment_date,x.dialysis_order_id,x.mission,x.dialysis_summary,x.change,x.sj_nurse,x.zl_nurse,x.hd_nurse,x.xj_nurse,x.zl_doctor,x.channel_image,x.puncture,x.puncture_needle,x.puncture_direction,x.status,x.created_time,x.updated_time,x.creater,x.modifier").Scan(&treatment).Error
+	return
+}