2024/6/17

conf/app.conf

 appname = 血透
 httpport = 9531
-runmode = prod
+runmode = dev
 #dev/prod
 
 #

controllers/base_api_controller.go

 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10697 //机构id
+		subscibe.OrgId = 9671 //机构id
 		subscibe.PeriodStart = 1547447814
 		subscibe.PeriodEnd = 1550039814
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10697 //机构id小英9675或4
-		adminUserInfo.CurrentAppId = 18217 //4
+		adminUserInfo.CurrentOrgId = 9671 //机构id小英9675或4
+		adminUserInfo.CurrentAppId = 3244 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
 		this.SetSession("admin_user_info", &adminUserInfo)
 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10697 //机构id小英9675或4
+		subscibe.OrgId = 9671 //机构id小英9675或4
 		subscibe.PeriodStart = 1538035409
 		subscibe.PeriodEnd = 1569571409
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10697 //机构id小英9675或4
-		adminUserInfo.CurrentAppId = 18217 //4
+		adminUserInfo.CurrentOrgId = 9671 //机构id小英9675或4
+		adminUserInfo.CurrentAppId = 3244 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
 		this.SetSession("admin_user_info", &adminUserInfo)

controllers/dialysis_api_controller.go

 	beego.Router("/api/patient/getdialysistotalcount", &DialysisApiController{}, "Get:GetDialysisTotalCount")
 
 	beego.Router("/api/schedule/getdialysisproject", &DialysisApiController{}, "Get:GetDialysisProject")
+
 }
 
 func (c *DialysisApiController) GetQueueCall() {

controllers/mobile_api_controllers/patient_api_controller.go

 
 	project, _ := service.FindHisProjectById(adminInfo.Org.Id, project_id)
 
+	//针对舒和
+	if adminInfo.Org.Id == 10644 {
+		if project.StartTime > theTime.Unix() {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAdviceExceBeforeStart)
+			return
+		}
+	}
+
 	if project.Type == 3 {
 		good, _ := service.GetGoodInformationByGoodId(project.ProjectId)
 		if good.IsUser != 1 {

controllers/patient_api_controller.go

 
 	beego.Router("/api/patient/gettreamentplan", &PatientApiController{}, "Get:GetTreatMentPlanList")
 
+	beego.Router("/api/patient/getpatientbypatientid", &PatientApiController{}, "Get:GetPatientByPatientId")
+
+	beego.Router("/api/patient/savepatientlapse", &PatientApiController{}, "Post:SavePatientLapse")
+
+	beego.Router("/api/patient/getpatientlapsorecord", &PatientApiController{}, "Get:GetPatientLapsorecord")
+
+	beego.Router("/api/patient/getpatientlapserecord", &DialysisApiController{}, "Get:GetPatientLapseRecord")
+
+	beego.Router("/api/patient/updatepatientlapserecord", &DialysisApiController{}, "Post:UpdatePatientLapseRecord")
+
+	beego.Router("/api/patient/deletepatientlapsorecord", &DialysisApiController{}, "Get:DeletePatientLapseRecord")
+
 }
 func (c *PatientApiController) GetExportList() {
 	startTime := c.GetString("start_time")
 		"treamentPlan": treamentPlan,
 	})
 }
+
+func (c *PatientApiController) GetPatientByPatientId() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	id, _ := c.GetInt64("id")
+
+	patients, _ := service.GetPatientByIDOne(orgId, id)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+	})
+}
+
+func (c *PatientApiController) SavePatientLapse() {
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println(err)
+
+	patient_id := int64(dataBody["patient_id"].(float64))
+
+	admin_user_id := int64(dataBody["admin_user_id"].(float64))
+
+	lapse_class := int64(dataBody["lapse_class"].(float64))
+
+	lapse_type := int64(dataBody["lapse_type"].(float64))
+
+	lapse_reason := dataBody["lapse_reason"].(string)
+
+	start_time := dataBody["record_date"].(string)
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	remark := dataBody["remark"].(string)
+
+	org_id := c.GetAdminUserInfo().CurrentOrgId
+
+	record := models.XtPatientLaspseRecord{
+		PatientId:   patient_id,
+		RecordDate:  startTime,
+		LapseDate:   startTime,
+		LapseType:   lapse_type,
+		LapseClass:  lapse_class,
+		LapseReason: lapse_reason,
+		AdminUserId: admin_user_id,
+		Remark:      remark,
+		UserOrgId:   org_id,
+		Ctime:       time.Now().Unix(),
+		Mtime:       time.Now().Unix(),
+		Status:      1,
+	}
+
+	//病人转出
+	if lapse_type == 1 {
+		service.UpdateScheduleByDeathTime(patient_id, startTime)
+		service.UpdateScheduleItemByPatientId(patient_id)
+	}
+	service.CreatePatientRecord(record)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"record": record,
+	})
+
+}
+
+func (c *PatientApiController) GetPatientLapsorecord() {
+
+	id, _ := c.GetInt64("id")
+
+	lapsorecord, _ := service.GetPatientLapsorecord(id)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"lapsorecord": lapsorecord,
+	})
+}
+
+func (this *DialysisApiController) GetPatientLapseRecord() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	limit, _ := this.GetInt64("limit")
+
+	page, _ := this.GetInt64("page")
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	record, total, _ := service.GetPatientLapseRecord(patient_id, limit, page, orgId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"record": record,
+		"total":  total,
+	})
+}
+
+func (c *DialysisApiController) UpdatePatientLapseRecord() {
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println(err)
+
+	patient_id := int64(dataBody["patient_id"].(float64))
+
+	admin_user_id := int64(dataBody["admin_user_id"].(float64))
+
+	lapse_class := int64(dataBody["lapse_class"].(float64))
+
+	lapse_type := int64(dataBody["lapse_type"].(float64))
+
+	lapse_reason := dataBody["lapse_reason"].(string)
+
+	start_time := dataBody["record_date"].(string)
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	remark := dataBody["remark"].(string)
+
+	id := int64(dataBody["id"].(float64))
+
+	org_id := c.GetAdminUserInfo().CurrentOrgId
+
+	record := models.XtPatientLaspseRecord{
+		ID:          id,
+		PatientId:   patient_id,
+		RecordDate:  startTime,
+		LapseDate:   startTime,
+		LapseType:   lapse_type,
+		LapseClass:  lapse_class,
+		LapseReason: lapse_reason,
+		AdminUserId: admin_user_id,
+		Remark:      remark,
+		UserOrgId:   org_id,
+		Ctime:       time.Now().Unix(),
+		Mtime:       time.Now().Unix(),
+		Status:      1,
+	}
+
+	//病人转出
+	if lapse_type == 1 {
+		service.UpdateScheduleByDeathTime(patient_id, startTime)
+		service.UpdateScheduleItemByPatientId(patient_id)
+	}
+
+	service.SavePatientLapseRecord(record)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"record": record,
+	})
+}
+
+func (c *DialysisApiController) DeletePatientLapseRecord() {
+
+	id, _ := c.GetInt64("id")
+
+	service.DeletePatientLapseRecord(id)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "删除成功",
+	})
+
+}

models/patient_models.go

 
 	return "xt_treatment_plan"
 }
+
+type XtPatientLaspseRecord struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	PatientId   int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	RecordDate  int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	LapseDate   int64  `gorm:"column:lapse_date" json:"lapse_date" form:"lapse_date"`
+	LapseType   int64  `gorm:"column:lapse_type" json:"lapse_type" form:"lapse_type"`
+	LapseClass  int64  `gorm:"column:lapse_class" json:"lapse_class" form:"lapse_class"`
+	LapseReason string `gorm:"column:lapse_reason" json:"lapse_reason" form:"lapse_reason"`
+	AdminUserId int64  `gorm:"column:admin_user_id" json:"admin_user_id" form:"admin_user_id"`
+	Remark      string `gorm:"column:remark" json:"remark" form:"remark"`
+	UserOrgId   int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Ctime       int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime       int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status      int64  `gorm:"column:status" json:"status" form:"status"`
+}
+
+func (XtPatientLaspseRecord) TableName() string {
+
+	return "xt_patient_laspse_record"
+}

service/patient_service.go

 }
 
 func UpdateScheduleByDeathTime(patientid int64, shcheduledate int64) error {
-	err := XTWriteDB().Model(models.XtSchedule{}).Where("patient_id = ? and schedule_date > ?", patientid, shcheduledate).Updates(map[string]interface{}{"status": 12}).Error
+	err := XTWriteDB().Model(models.XtSchedule{}).Where("patient_id = ? and schedule_date > ? and status=1", patientid, shcheduledate).Updates(map[string]interface{}{"status": 0}).Error
 	return err
 }
 
 
 	return doctorAdviceOne, err
 }
+
+func CreatePatientRecord(record models.XtPatientLaspseRecord) error {
+
+	err := XTWriteDB().Create(&record).Error
+
+	return err
+}
+
+func GetPatientLapseRecord(patient_id int64, limit int64, page int64, user_org_id int64) (record []*models.XtPatientLaspseRecord, total int64, err error) {
+
+	db := XTReadDB().Model(&record).Where("status=1")
+	offset := (page - 1) * limit
+	if patient_id > 0 {
+		db = db.Where("patient_id = ?", patient_id)
+	}
+	if user_org_id > 0 {
+		db = db.Where("user_org_id = ?", user_org_id)
+	}
+	err = db.Count(&total).Offset(offset).Limit(limit).Find(&record).Error
+
+	return record, total, err
+}
+
+func GetPatientLapsorecord(id int64) (models.XtPatientLaspseRecord, error) {
+
+	laspseRecord := models.XtPatientLaspseRecord{}
+
+	err := XTReadDB().Where("id = ? and status= 1", id).Find(&laspseRecord).Error
+
+	return laspseRecord, err
+}
+
+func SavePatientLapseRecord(record models.XtPatientLaspseRecord) error {
+
+	err := XTWriteDB().Save(&record).Error
+
+	return err
+}
+
+func DeletePatientLapseRecord(id int64) error {
+
+	record := models.XtPatientLaspseRecord{}
+
+	err := XTWriteDB().Model(&record).Where("id = ? and status=1", id).Updates(map[string]interface{}{"status": 0}).Error
+
+	return err
+}