Merge branch '20230223_xt_api_new_branch' of http://git.shengws.com/csx/XT_New into 20230223_xt_api_new_branch

controllers/patient_api_controller.go

 	beego.Router("/api/patient/findepatientdialysislongsolutions", &PatientApiController{}, "Get:GetPatientDialysisLongSolution")
 	beego.Router("/api/patient/getdialysissolutiondetaillist", &PatientApiController{}, "Get:GetDialysisSolutionDetailList")
 
+	beego.Router("/api/patient/getexportlist", &PatientApiController{}, "Get:GetExportList")
+
+}
+func (c *PatientApiController) GetExportList() {
+	startTime := c.GetString("start_time")
+	endTime := c.GetString("end_time")
+	schedulType, _ := c.GetInt64("schedul_type", 0)
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	adminUserInfo := c.GetAdminUserInfo()
+	var theStartTIme int64
+	if len(startTime) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", startTime+" 00:00:00", loc)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+
+		theStartTIme = theTime.Unix()
+	}
+
+	var theEndtTIme int64
+	if len(endTime) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", endTime+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+
+		theEndtTIme = theTime.Unix()
+	}
+	timeNowStr := time.Now().Format("2006-01-02")
+	timeNewDate, _ := utils.ParseTimeStringToTime("2006-01-02", timeNowStr)
+	schedule, _ := service.GetPatientScheudleListTwenty(adminUserInfo.CurrentOrgId, schedulType, theStartTIme, theEndtTIme, timeNewDate.Unix())
+	fmt.Println("schedule23333333333333333", schedule)
+	patientsList, _ := service.GetAllpatient(adminUserInfo.CurrentOrgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"schedule":     schedule,
+		"patientsList": patientsList,
+	})
+	return
 }
 
 // GetPatientsList 取患者列表

controllers/schedule_api_controller.go

 	beego.Router("/api/schedule/weekpanelone", &ScheduleApiController{}, "Get:GetWeekPanelsOne")
 	beego.Router("/api/schedule/schedulesone", &ScheduleApiController{}, "Get:GetScheduleOne")
 	beego.Router("/api/schedule/scheduletwo", &ScheduleApiController{}, "Get:GetScheduleTwo")
+	beego.Router("/api/schedule/getschedulethreeone", &ScheduleApiController{}, "Get:GetScheduleThreeList")
 	beego.Router("/api/schedule/postscheduletemplate", &ScheduleApiController{}, "Get:SaveScheduleTemplate")
 	beego.Router("/api/schedule/getscheduletemplate", &ScheduleApiController{}, "Get:GetScheduleTemplate")
 	beego.Router("/api/order/changefuncprint", &ScheduleApiController{}, "Get:ChangeFuncPrint")
 	theEndTime, _ := time.ParseInLocation(timeLayout, weekEndTime, loc)
 	weekStartPoint := theStarTime.Unix()
 	weekEndPoint := theEndTime.Unix()
-
 	schdules, _ := service.GetWeekScheduleThree(adminInfo.CurrentOrgId, weekStartPoint, weekEndPoint, ids, schedule_type, WeekDayIds)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"days":      days,
+		"weekTitle": weekTitle,
+		"schdules":  schdules,
+		"today":     today,
+	})
+	return
+}
+
+func (c *ScheduleApiController) GetScheduleThreeList() {
+
+	week, _ := c.GetInt64("weekTime", 0) //1:last, 2:this 3:next 4 nextTwo
+
+	patitionIdStr := c.GetString("patitionid")
+
+	ids := strings.Split(patitionIdStr, ",")
+
+	schedule_type, _ := c.GetInt64("schedule_type")
 
+	adminInfo := c.GetAdminUserInfo()
+	weekDateStr := c.GetString("week_date")
+
+	WeekDayIds := strings.Split(weekDateStr, ",")
+
+	thisTime := time.Now()
+	today := thisTime.Format("2006-01-02")
+	if week < 1 || week > 4 {
+		week = 2
+	}
+	if week == 1 {
+		thisTime = thisTime.AddDate(0, 0, -7)
+	} else if week == 3 {
+		thisTime = thisTime.AddDate(0, 0, 7)
+	} else if week == 4 {
+		thisTime = thisTime.AddDate(0, 0, 14)
+	}
+
+	weekDay := int(thisTime.Weekday())
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	weekTitle := make([]string, 0)
+	days := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		indexYear, indexMonthTime, indexDay := theDay.Date()
+		indexMonth := int(indexMonthTime)
+		indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
+		weekTitle = append(weekTitle, indexWeek)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+
+	weekStartDay := thisTime.AddDate(0, 0, weekStart)
+	weekEndDay := thisTime.AddDate(0, 0, weekEnd)
+	weekStartTime := weekStartDay.Format("2006-01-02") + " 00:00:00"
+	weekEndTime := weekEndDay.Format("2006-01-02") + " 23:59:59"
+
+	timeLayout := "2006-01-02 15:04:05"
+	loc, _ := time.LoadLocation("Local")
+	theStarTime, _ := time.ParseInLocation(timeLayout, weekStartTime, loc)
+	theEndTime, _ := time.ParseInLocation(timeLayout, weekEndTime, loc)
+	weekStartPoint := theStarTime.Unix()
+	weekEndPoint := theEndTime.Unix()
+	schdules, _ := service.GetWeekScheduleFour(adminInfo.CurrentOrgId, weekStartPoint, weekEndPoint, ids, schedule_type, WeekDayIds)
+
+	if len(schdules) > 0 {
+		for _, item := range schdules {
+			listObj, _ := service.GetNextScheduleByList(item.PatientId, item.ScheduleDate, item.UserOrgId)
+			item.SchedulePatientsOne = listObj
+		}
+	}
 	c.ServeSuccessJSON(map[string]interface{}{
 		"days":      days,
 		"weekTitle": weekTitle,

controllers/sign_api_controller.go

 	"fmt"
 	"github.com/astaxie/beego"
 	"github.com/jung-kurt/gofpdf"
+	"github.com/mozillazg/go-pinyin"
 	"io/ioutil"
 	"time"
 )
 
 	beego.Router("/api/device/toautodrug", &SignApiController{}, "Get:ToAutoDrug")
 
+	beego.Router("/api/device/toautodiagnose", &SignApiController{}, "Get:ToAutoDiagnose")
+
 }
 
 // 短信服务接口
 func (this *SignApiController) UploadPrintOrder() {
 
 	fmt.Println("WOOWOWOWOWOWOWOWOWOWOWWOOWOWWO")
-	//list, _ := service.GetAllPatientNew(10567)
-	//for _, item := range list {
-	//
-	//	hans := item.Name // 要转换的汉字字符串
-	//	// 创建一个拼音转换器
-	//	p := pinyin.NewArgs()
-	//
-	//	// 将汉字转为拼音
-	//	pinyinSlice := pinyin.Pinyin(hans, p)
-	//
-	//	// 输出拼音
-	//	fmt.Println("Pinyin:", pinyinSlice)
-	//
-	//	// 获取首字母
-	//	firstLetter := ""
-	//	for _, py := range pinyinSlice {
-	//		if len(py) > 0 {
-	//			firstLetter += string(py[0][0])
-	//		}
-	//	}
-	//
-	//	item.FirstLetter = firstLetter
-	//	service.UpdatePatientNew(item.ID, item.FirstLetter)
-	//	// 输出首字母
-	//	//fmt.Println("First Letter:", firstLetter)
-	//}
+	list, _ := service.GetAllPatientNew(10587)
+	for _, item := range list {
+
+		hans := item.Name // 要转换的汉字字符串
+		// 创建一个拼音转换器
+		p := pinyin.NewArgs()
+
+		// 将汉字转为拼音
+		pinyinSlice := pinyin.Pinyin(hans, p)
+
+		// 输出拼音
+		fmt.Println("Pinyin:", pinyinSlice)
+
+		// 获取首字母
+		firstLetter := ""
+		for _, py := range pinyinSlice {
+			if len(py) > 0 {
+				firstLetter += string(py[0][0])
+			}
+		}
+
+		item.FirstLetter = firstLetter
+		service.UpdatePatientNew(item.ID, item.FirstLetter)
+		// 输出首字母
+		//fmt.Println("First Letter:", firstLetter)
+	}
 
 	//baseList, _ := service.GeteAllBaseList(10567)
 	//for _, item := range baseList {
 	//	}
 	//}
 
-	prescriptionList, _ := service.GetAllPrescriptionList(10579)
+	//prescriptionList, _ := service.GetAllPrescriptionList(10579)
 
-	for _, item := range prescriptionList {
+	list, _ := service.GetScheduleListByOrder(10579)
+
+	for _, item := range list {
+		soluton, _ := service.GetDialysisSoluton(item.PatientId, item.ModeId)
 		var DialysisMachineName string
-		if len(item.DialysisDialyszers) > 0 {
-			DialysisMachineName = item.DialysisDialyszers
-		}
-		if len(item.DialyzerPerfusionApparatus) > 0 {
-			DialysisMachineName = DialysisMachineName + "," + item.DialyzerPerfusionApparatus
+		if len(soluton.DialysisDialyszers) > 0 {
+			DialysisMachineName = soluton.DialysisDialyszers
 		}
+		//if len(soluton.DialyzerPerfusionApparatus) > 0 {
+		//	DialysisMachineName = DialysisMachineName + "," + soluton.DialyzerPerfusionApparatus
+		//}
 
-		if len(item.DialysisIrrigation) > 0 {
-			DialysisMachineName = DialysisMachineName + "," + item.DialysisIrrigation
+		if len(soluton.DialysisIrrigation) > 0 {
+			DialysisMachineName = DialysisMachineName + "," + soluton.DialysisIrrigation
 		}
 
-		if len(item.DialysisStrainer) > 0 {
-			DialysisMachineName = DialysisMachineName + "," + item.DialysisStrainer
+		if len(soluton.DialysisStrainer) > 0 {
+			DialysisMachineName = DialysisMachineName + "," + soluton.DialysisStrainer
 		}
 		DialysisMachineName = DialysisMachineName
-		service.UpdateSchPatient(item.PatientId, item.RecordDate, item.UserOrgId, DialysisMachineName)
+
+		service.UpdateDialysisSchedule(item.ID, DialysisMachineName)
 	}
+
+	//for _, item := range prescriptionList {
+	//	var DialysisMachineName string
+	//	if len(item.DialysisDialyszers) > 0 {
+	//		DialysisMachineName = item.DialysisDialyszers
+	//	}
+	//	if len(item.DialyzerPerfusionApparatus) > 0 {
+	//		DialysisMachineName = DialysisMachineName + "," + item.DialyzerPerfusionApparatus
+	//	}
+	//
+	//	if len(item.DialysisIrrigation) > 0 {
+	//		DialysisMachineName = DialysisMachineName + "," + item.DialysisIrrigation
+	//	}
+	//
+	//	if len(item.DialysisStrainer) > 0 {
+	//		DialysisMachineName = DialysisMachineName + "," + item.DialysisStrainer
+	//	}
+	//	DialysisMachineName = DialysisMachineName
+	//	service.UpdateSchPatient(item.PatientId, item.RecordDate, item.UserOrgId, DialysisMachineName)
+	//}
 	this.ServeSuccessJSON(map[string]interface{}{
 		"msg": "ok",
 	})
 }
+
+func (this *SignApiController) ToAutoDiagnose() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	list, _ := service.GetNewAllpatient(orgId)
+
+	for _, item := range list {
+		service.UpdateAllPatient(item.BloodId, item.Diagnose, item.UserOrgId)
+	}
+
+	//list, _ := service.GetAllDialysisOrder(10579)
+	//for _, item := range list {
+	//	service.UpdateScheduleByOrder(item.PatientId, item.DialysisDate, 10579, item.BedId, item.ZoneId, item.SchedualType)
+	//}
+	//this.ServeSuccessJSON(map[string]interface{}{
+	//	"msg": "ok",
+	//})
+
+}

models/device_models.go

 	return "xt_schedule"
 }
 
+type ScheduleTen 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"`
+	IsExport            int64  `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	DialysisMachineName string `gorm:"column:dialysis_machine_name" json:"dialysis_machine_name" form:"dialysis_machine_name"`
+	Remark              string `gorm:"column:remark" json:"remark" form:"remark"`
+}
+
+func (ScheduleTen) TableName() string {
+
+	return "xt_schedule"
+}
+
 type DeviceInformationss struct {
 	ID                    int64  `gorm:"column:id" json:"id" form:"id"`
 	Date                  int64  `gorm:"column:date" json:"date" form:"date"`

models/schedule_models.go

 	return "xt_schedule"
 }
 
+type ScheduleThree 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"`
+	IsExport            int64                 `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	Patient             string                `gorm:"-" json:"patient" form:"patient"`
+	DialysisMachineName string                `gorm:"column:dialysis_machine_name" json:"dialysis_machine_name" form:"dialysis_machine_name"`
+	DialysisSolution    VmDialysisSolutionOne `json:"dialysissolution" gorm:"foreignkey:PatientId,ModeId;AssociationForeignKey:PatientId,ModeId;"`
+	SchedulePatientsOne SchedulePatientsOne   `json:"next_schedule" gorm:"foreignkey:PatientId;AssociationForeignKey:PatientId;"`
+	DeviceNumber        DeviceNumber          `json:"number" gorm:"foreignkey:ID;AssociationForeignKey:BedId;"`
+}
+
+func (ScheduleThree) TableName() string {
+	return "xt_schedule"
+}
+
+type SchedulePatientsOne 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"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
+}
+
+func (SchedulePatientsOne) TableName() string {
+	return "xt_schedule"
+}
+
 type SchedulePatients 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"`

service/patient_service.go

 
 	return prescription, err
 }
+
+func GetPatientScheudleListTwenty(org_id int64, scheduel_type int64, startime int64, endtime int64, schedule_date int64) (schedule []*models.ScheduleTen, err error) {
+
+	db := XTReadDB().Model(&schedule).Where("status= 1")
+	if org_id > 0 {
+		db = db.Where("user_org_id = ?", org_id)
+	}
+	if scheduel_type > 0 {
+		db = db.Where("schedule_type =?", scheduel_type)
+	}
+	if startime > 0 {
+		db = db.Where("schedule_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("schedule_date <=?", endtime)
+	}
+
+	if startime == 0 && endtime == 0 {
+		db = db.Where("schedule_date = ?", schedule_date)
+	}
+
+	err = db.Find(&schedule).Error
+	fmt.Println("err2330230320202023", err)
+	return schedule, err
+}

service/schedule_service.go

 	return
 }
 
+func GetWeekScheduleFour(orgID int64, start, end int64, schIds []string, scheduletype int64, WeekDayIds []string) (schedules []*models.ScheduleThree, err error) {
+
+	db := readDb.Table("xt_schedule as s")
+
+	if len(schIds) > 0 {
+		db = db.Where("s.partition_id in (?)", schIds)
+	}
+	if scheduletype > 0 {
+		db = db.Where("s.schedule_type = ?", scheduletype)
+	}
+	if len(WeekDayIds) > 0 {
+		db = db.Where("s.schedule_week in(?)", WeekDayIds)
+	}
+	err = db.Preload("DeviceNumber", "status = 1 and org_id =?", orgID).
+		Preload("DialysisSolution", "status= 1 and solution_status = 1").
+		Joins("JOIN xt_patients as p ON p.id = s.patient_id").
+		Where("s.user_org_id=? and s.schedule_date>=? and s.schedule_date<=? and s.status=1", orgID, start, end).
+		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time,s.dialysis_machine_name, p.name as patient").
+		Order("updated_time asc").
+		Find(&schedules).Error
+	return
+}
+
 func GetDaySchedule(orgID, start, end, patientID int64) (schedule models.Schedule, err error) {
 	err = readDb.Model(&models.Schedule{}).Where("user_org_id=? and patient_id=? and schedule_date>=? and schedule_date<=? and status=1", orgID, patientID, start, end).First(&schedule).Error
 	return
 	return
 }
 
+func GetNextScheduleByList(patient_id int64, schedule_date int64, user_org_id int64) (models.SchedulePatientsOne, error) {
+
+	patientsOne := models.SchedulePatientsOne{}
+	err := XTReadDB().Where("patient_id = ? and schedule_date >? and user_org_id = ? and status=1", patient_id, schedule_date, user_org_id).First(&patientsOne).Error
+	return patientsOne, err
+}
+
 func GetPointSchedule(orgID, scheduleDate, scheduleWeek, scheduleType, bedId int64) (schedule models.Schedule, err error) {
 	err = readDb.Model(&models.Schedule{}).Where("user_org_id=? and schedule_date=? and bed_id=? and schedule_week=? AND schedule_type=? and status=1", orgID, scheduleDate, bedId, scheduleWeek, scheduleType).First(&schedule).Error
 

service/sign_service.go

 	err := XTWriteDB().Model(&models.XtSchedule{}).Where("patient_id =? and schedule_date =? and user_org_id =?", patient_id, schedule_date, user_org_id).Updates(map[string]interface{}{"dialysis_machine_name": DialysisMachineName}).Error
 	return err
 }
+
+func GetNewAllpatient(org_id int64) (list []*models.XtPatientsNew, err error) {
+
+	err = XTReadDB().Where("status =1 and user_org_id =9990").Find(&list).Error
+
+	return list, err
+}
+
+func UpdateAllPatient(id int64, diagose string, orgid int64) error {
+
+	err := XTWriteDB().Model(models.XtPatients{}).Where("id = ? and user_org_id = ?", id, orgid).Updates(map[string]interface{}{"diagnose": diagose}).Error
+	return err
+}
+
+func GetAllDialysisOrder(user_org_id int64) (list []*models.XtDialysisOrder, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and dialysis_date =?", 10579, 1701360000).Find(&list).Error
+
+	return list, err
+}
+
+func UpdateScheduleByOrder(patient_id int64, schedule_date int64, user_org_id int64, bed_id int64, zone_id int64, shcedule_type int64) error {
+
+	err := XTWriteDB().Model(&models.XtSchedule{}).Where("schedule_date =? and user_org_id =? and status=1 and patient_id =?", schedule_date, user_org_id, patient_id).Updates(map[string]interface{}{"bed_id": bed_id, "partition_id": zone_id, "schedule_type": shcedule_type}).Error
+	return err
+}
+
+func GetScheduleListByOrder(user_org_id int64) (list []*models.XtSchedule, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and schedule_date >=? and status =1 and schedule_date<=?", 10579, 1703260800, 1703347200).Find(&list).Error
+	return list, err
+}
+
+func GetDialysisSoluton(patient_id int64, mode_id int64) (models.DialysisSolution, error) {
+
+	solution := models.DialysisSolution{}
+	err := XTReadDB().Where("patient_id =? and mode_id =? and status =1 and solution_status = 1", patient_id, mode_id).Find(&solution).Error
+	return solution, err
+}
+
+func UpdateDialysisSchedule(id int64, dialysis_machine_name string) error {
+
+	err := XTWriteDB().Model(models.XtSchedule{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"dialysis_machine_name": dialysis_machine_name}).Error
+	return err
+}