开发

controllers/new_mobile_api_controllers/common_api_controller.go

@@ -573,3 +573,66 @@ func (this *CommonApiController) GetLastCheckList() {
 		"checkList": checkList,
 	})
 }
+
+func (this *CommonApiController) GetDialysisDetailById() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", id)
+	startime := this.GetString("startime")
+	fmt.Println(startime)
+	endtime := this.GetString("endtime")
+	startDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", startime)
+	fmt.Println("parseDateErr", parseDateErr)
+	statime := startDate.Unix()
+	fmt.Println("开始时间", statime)
+	endDate, _ := utils.ParseTimeStringToTime("2006-01-02", endtime)
+
+	entime := endDate.Unix()
+	fmt.Println("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patients, total, err := service.GetDialysisDetailById(id, orgId, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+		"total":    total,
+	})
+}
+
+func (this *CommonApiController) GetPrescritionByName() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	keyword := this.GetString("keyword")
+	startime := this.GetString("startime")
+	fmt.Println(startime)
+	endtime := this.GetString("endtime")
+	startDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", startime)
+	fmt.Println("parseDateErr", parseDateErr)
+	statime := startDate.Unix()
+	fmt.Println("开始时间", statime)
+	endDate, _ := utils.ParseTimeStringToTime("2006-01-02", endtime)
+
+	entime := endDate.Unix()
+	fmt.Println("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patient, total, err := service.GetPrescritionByName(orgId, keyword, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+		"total":   total,
+	})
+}

controllers/new_mobile_api_controllers/common_api_router.go

@@ -31,4 +31,6 @@ func CommonApiControllersRegisterRouters() {
 	beego.Router("/com/api/getdialysislist", &CommonApiController{}, "Get:GetDialysislist")
 	beego.Router("/com/api/getlastsort", &CommonApiController{}, "Get:GetLastSort")
 	beego.Router("/com/api/getlastchecklist", &CommonApiController{}, "Get:GetLastCheckList")
+	beego.Router("/com/api/getdialysisdetailbyid", &CommonApiController{}, "Get:GetDialysisDetailById")
+	beego.Router("/com/api/getprescriptionbyname", &CommonApiController{}, "Get:GetPrescritionByName")
 }

service/common_service.go

@@ -385,3 +385,49 @@ func GetLastCheckList(orgid int64) (models.XtCheckConfiguration, error) {
 	err := XTReadDB().Model(&configuration).Where("user_org_id = ? and status =1", orgid).Last(&configuration).Error
 	return configuration, err
 }
+
+func GetDialysisDetailById(id int64, orgid int64, startime int64, endtime int64, limit int64, page int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	if id > 0 {
+		db = db.Where("p.patient_id = ?", id)
+	}
+
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Group("p.mode_id").Select("p.mode_id,p.patient_id,s.name,s.id_card_no,s.dialysis_no,s.total_dialysis,s.user_sys_before_count").Joins("left join xt_patients as s on s.id = p.patient_id").Count(&total).Offset(offset).Limit(limit).Scan(&prescription).Error
+	return prescription, total, err
+}
+
+func GetPrescritionByName(orgid int64, keywords string, startime int64, endtime int64, limit int64, page int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	if len(keywords) > 0 {
+		likeKey := "%" + keywords + "%"
+		db = db.Where("s.name LIKE ? OR s.dialysis_no LIKE ?", likeKey, likeKey)
+	}
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Group("p.mode_id").Select("p.mode_id,p.patient_id,s.name,s.id_card_no,s.dialysis_no,s.total_dialysis,s.user_sys_before_count").Joins("left join xt_patients as s on s.id = p.patient_id").Count(&total).Offset(offset).Limit(limit).Scan(&prescription).Error
+	return prescription, total, err
+}