go通用查询框架UiSimpleRequest， UiSimpleR UiSimpleQ定制请求响应

本文介绍了一个基于Go语言的通用请求响应处理框架UiSimple主要包含以下核心组件 请求响应结构体 UiSimpleRequest基础请求结构包含分页参数、数据过滤等通用功能 UiSimpleR响应结构继承请求结构并扩展分页转换功能 UiSimpleQR组合请求参数和响应数据的复合结构 核心功能 支持分页查询和结果转换 提供数据范围过滤功能 内置错误处理机制 支持Excel/HTML/PDF导出功能 包含通用ID生成方法 扩展功能 审计状态管理 数据排序处理 结果映射转换 报表生成导出UiSimpleE请求响应都是E实体UiSimpleQ 请求QUiSimpleR 响应是RUiSimpleQR Q,R请求响应UiSimpleE type UiSimpleRequest[P generaliface.GoPkey, E generaliface.IBaseModel[P]] struct { *generaldao.BaseDao[P, E] // QueryRequest[P, E] Param E json:param SimpleParam beforQuery func() json:- DataScopeFilter *dbscope.DataScopeFilter common.BaseService Err error json:- PagePtrConvert pagefacade.PagePtrFacade[E, E] json:- }响应type UiSimpleR[E generaliface.IBaseModel[int64], R any] struct { UiSimpleRequest[int64, E] pagefacade.PagePtrFacade[E, R] }type UiSimpleE[E generaliface.IBaseModel[int64]] UiSimpleR[E, E] type UiSimpleER[E generaliface.IBaseModel[int64], R any] UiSimpleR[E, E]请求请示响应 type UiSimpleQR[Q any, E generaliface.IBaseModel[int64], R any] struct { UiSimpleR[E, R] Query Q json:param }请求type UiSimpleQ[Q any, E generaliface.IBaseModel[int64]] UiSimpleQR[Q, E, E]type UiAdminStudyRequest struct { basedto.BaseEntity uiframe.UiSimpleQR[opcdto.StatParam, *coachentity.OpcCoachAdmin, *coachentity.UiCoachResult] }func (self *UiAdminStudyRequest) UiList2Result() *pagemodel.PageResult[*coachentity.UiCoachResult] { if err : self.FromUser(); err ! nil { return self.FailRErr(err) } self.Param.OpcId self.User.OpcId return self.PageTo(self.List()) }type UiSimpleR[E generaliface.IBaseModel[int64], R any] struct { UiSimpleRequest[int64, E] pagefacade.PagePtrFacade[E, R] } func NewUiSimpleR[E generaliface.IBaseModel[int64], R any]() *UiSimpleR[E, R] { return UiSimpleR[E, R]{} } func (self *UiSimpleR[E, R]) DbSelectModelR(sql string, params ...any) *pagemodel.PageResult[R] { var ret self.BaseDao.DbSelectPageResult(sql, params...) return self.PageTo(ret) } func (self *UiSimpleR[E, R]) QueryModelR(pagesize ...int) *pagemodel.PageResult[R] { var ret self.QueryModel(pagesize...) return self.PageTo(ret) } func (self *UiSimpleR[E, R]) FailRMsg(msg string) *pagemodel.PageResult[R] { return pagemodel.PageResultFailUser[R](msg) } func (self *UiSimpleR[E, R]) FailRErr(err error) *pagemodel.PageResult[R] { return pagemodel.PageResultFailUser[R](err.Error()) }type UiSimpleRequest[P generaliface.GoPkey, E generaliface.IBaseModel[P]] struct { *generaldao.BaseDao[P, E] // QueryRequest[P, E] Param E json:param SimpleParam beforQuery func() json:- DataScopeFilter *dbscope.DataScopeFilter common.BaseService Err error json:- PagePtrConvert pagefacade.PagePtrFacade[E, E] json:- } // type QueryRequest[P generaliface.GoPkey, E generaliface.IBaseModel[P]] struct { // Param E json:param // SimpleParam // } func NewUiSimpleRequest[P generaliface.GoPkey, E generaliface.IBaseModel[P]]() *UiQueryRequest[P, E] { var req UiQueryRequest[P, E]{} req.Param req.NewOfPtrType() req.InitProxy(req) return req } func (self *UiSimpleRequest[P, E]) NewDao() *generaldao.BaseDao[P, E] { return generaldao.Default[P, E]() } func (self *UiSimpleRequest[P, E]) InitDao() *UiSimpleRequest[P, E] { if self.DataScopeFilter nil { self.DataScopeFilter dbscope.FindBeanDataScopeFilter() } if self.IsNilValue(self.Param) { self.Param self.NewOfType() } if self.BaseDao nil { self.BaseDao generaldao.Default[P, E]() } if self.PageSize 0 { self.PageSize 10 self.PageCurrent 1 } if self.Tabler() nil { var entity self.NewOfType() self.PageDbRequest.SetTabler(entity) self.PageDbRequest.TableName entity.TableName() } return self } func (self *UiSimpleRequest[P, E]) BeforeQuery() func() { return self.beforQuery } func (self *UiSimpleRequest[P, E]) SetBeforeQuery(q func()) { self.beforQuery q } func (self *UiSimpleRequest[P, E]) BuildOrderBys() *UiSimpleRequest[P, E] { if !self.IfUiOrderBys() { return self } var orderList strings.Split(self.OrderBys, ,) for i : range orderList { var bys strings.Split(orderList[i], |) if len(bys) 1 { bys append(bys, asc) } self.OrderBy(bys[0], bys[1]) } return self } func (self *UiSimpleRequest[P, E]) BuildRequest() *UiSimpleRequest[P, E] { self.InitDao() self.PageDbRequest.PageSize self.PageSize self.PageDbRequest.PageCurrent self.PageCurrent self.BuildOrderBys() return self } func (self *UiSimpleRequest[P, E]) IfKeyword() bool { return self.keywordFields ! self.Keyword ! } func (self *UiSimpleRequest[P, E]) ResultUserFailMsg(msg string) *basedto.IchubResult { return basedto.ResultCodeMsg(apiconst.SystemMsg_Code_START, msg) } func (self *UiSimpleRequest[P, E]) ResultUserSystemMsg(msg string) *basedto.IchubResult { return basedto.ResultCodeMsg(apiconst.UserMsg_Code_START, msg) } func (self *UiSimpleRequest[P, E]) BuildOrderBysDao(dao *pagedb.PageDbRequest) *UiSimpleRequest[P, E] { if self.IfUiOrderBys() { self.PageDbRequest.OrderBys []*dto.OrderByDto{} var orderList strings.Split(self.OrderBys, ,) for i : range orderList { var bys strings.Split(orderList[i], |) if len(bys) 1 { bys append(bys, asc) } //self.OrderBy(bys[0], bys[1]) dao.OrderBys append(dao.OrderBys, dto.OrderByDto{ Field: bys[0], Sort: bys[1], }) } } return self } func (self *UiSimpleRequest[P, E]) QueryModel2Report(sizes ...int) *pagemodel.PageResult[E] { if sizes nil || len(sizes) 0 { sizes []int{self.PageSize} } self.BuildRequest() self.BeforeQuery()() if self.OrderBys { self.OrderByDesc(id) } var ret self.QueryModel(sizes[0]) if ret.ExistRecord() { lo.ForEach(ret.Data, func(item E, index int) { item.Fill() }) } return ret } func (self *UiSimpleRequest[P, E]) GetAllFields(i any) []string { // 获取反射值 v : reflect.ValueOf(i) // 如果是指针获取指向的值 if v.Kind() reflect.Ptr { v v.Elem() } // 获取类型 t : v.Type() var names make([]string, 0) // 遍历所有字段 for i : 0; i v.NumField(); i { field : t.Field(i) value : v.Field(i) names append(names, field.Name) fmt.Printf( 字段名: %s, 类型: %s, 值: %v, 标签: %s\n, field.Name, field.Type, value.Interface(), field.Tag) } return names } func (self *UiSimpleRequest[P, E]) GetAllFields2LcFirst(i any) []string { var fields self.GetAllFields(i) for i : range fields { fields[i] stringutils.Lcfirst(fields[i]) } return fields } func (self *UiSimpleRequest[P, E]) GeneralMakeNoGra() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(G) } func (self *UiSimpleRequest[P, E]) GeneralMakeNoKbase() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(K) } func (self *UiSimpleRequest[P, E]) GeneralMakeNoKbaseLine() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(S) //step } func (self *UiSimpleRequest[P, E]) GeneralMakeNoItemBank() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(B) } func (self *UiSimpleRequest[P, E]) GeneralMakeNoItemLine() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(I) } func (self *UiSimpleRequest[P, E]) GeneralMakeNoItemOption() string { return strtool.FindBeanIdGenerator().GeneralMakeNo(O) } func (self *UiSimpleRequest[P, E]) GeneralMakeNoDefault() string { return strtool.FindBeanIdGenerator().GeneralMakeNo() } func (self *UiSimpleRequest[P, E]) GeneralMakeNo(pre string) string { return strtool.FindBeanIdGenerator().GeneralMakeNo(pre) } func (self *UiSimpleRequest[P, E]) UiQueryModel() *pagemodel.PageResult[E] { if self.beforQuery ! nil { self.beforQuery() } var ret self.QueryModel() lo.ForEach(ret.Data, func(item E, index int) { item.Fill() }) return ret } func (self *UiSimpleRequest[P, E]) List() *pagemodel.PageResult[E] { self.BuildRequest() self.BeforeQuery()() if self.IfUiOrderBysNotExist() { self.OrderByDesc(id) } var ret self.QueryModel() lo.ForEach(ret.Data, func(item E, index int) { item.Fill() }) return ret } func (self *UiSimpleRequest[P, E]) Ret2KeyMap(ret *pagemodel.PageResult[E]) map[P]E { var keyMap make(map[P]E) lo.ForEach(ret.Data, func(item E, index int) { keyMap[item.PkeyValue()] item }) return keyMap } func (self *UiSimpleRequest[P, E]) Ret2KeyMapRet(ret *pagemodel.PageResult[E]) *pagemodel.IchubResult[map[P]E] { var keyMap self.Ret2KeyMap(ret) return pagemodel.ResultOk(keyMap, true) } func (self *UiSimpleRequest[P, E]) UiUpdateAuditStatus(ap auditiface.AuditIface[P]) *basedto.IchubResult { return ap.UiUpdateAuditStatus(self.UpdateMap2NewResult) } func (self *UiSimpleRequest[P, E]) ActiveUpdateFunc(ap auditiface.AuditIface[P]) *basedto.IchubResult { return ap.ActiveUpdateFunc(self.UpdateMap2NewResult) } func (self *UiSimpleRequest[P, E]) Publish(ap auditiface.AuditIface[P]) *basedto.IchubResult { return ap.Publish(self.UpdateMap2NewResult) } func (self *UiSimpleRequest[P, E]) Withdraw(ap auditiface.AuditIface[P]) *basedto.IchubResult { return ap.Withdraw(self.UpdateMap2NewResult) } func (self *UiSimpleRequest[P, E]) PrePublish(ap auditiface.AuditIface[P]) *basedto.IchubResult { return ap.PrePublish(self.UpdateMap2NewResult) } func (self *UiSimpleRequest[P, E]) IfAggComputing(ret *pagemodel.PageResult[E]) bool { return ret.IsSuccess() ret.DataAgg nil self.IfAgg } func (self *UiSimpleRequest[P, E]) IfAggWaiting(ret *pagemodel.PageResult[E]) { var w 2000 * time.Second for w 0 { time.Sleep(100 * time.Millisecond) w - 100 if ret.DataAgg ! nil { break } } } func (self *UiSimpleRequest[P, E]) ExportReport(c *gin.Context, headers []*goexcel.ExcelHeader, sizes ...int) *pagemodel.PageResult[E] { var ret self.QueryModel2Report(sizes...) if ret.IsFailed() { return ret } var goexcelFrame goexcelframe.FindBeanGoexcelFrame() goexcelFrame.Prepare(self.Param, ret.MapDefault().Data) goexcelFrame.Headers headers var err goexcelFrame.ExportFile(c) if err ! nil { ret.FailError(err) return ret } var excelResult goexcel.FindBeanExcelResult().FromHeader(goexcelFrame.GoexecelFile) ret.DataExtend excelResult return ret } func (self *UiSimpleRequest[P, E]) ParseTable(ireportTable gotag.IreportTable) error { ireportTable.SetTabler(self.Param) var err ireportTable.ParseTable(ireportTable) if ireportTable.GetReportMeta().GetPageSize() 0 { ireportTable.GetReportMeta().SetPageSize(self.PageSize) } return err } func (self *UiSimpleRequest[P, E]) ExportFile2Ret(c *gin.Context, ireportTable gotag.IreportTable) *pagemodel.PageResult[E] { if err : self.ParseTable(ireportTable); err ! nil { return self.PageResultFail(err.Error()) } var ret self.QueryModel2Report(ireportTable.GetPageSize()) if ret.IsFailed() { golog.Error(ret) return ret } var expRet goexcelframe.FindBeanGoexcelFrame().ExportFile2Ret(c, ret.MapDefault().Data, ireportTable) ret.IchubResult *expRet return ret } func (self *UiSimpleRequest[P, E]) ExportDefault(c *gin.Context) *pagemodel.PageResult[E] { var table gotag.ExportTable[E]{} table.E self.NewOfPtrType() return self.ExportFile2Ret(c, table) } func (self *UiSimpleRequest[P, E]) ExportDefaultHtml(c *gin.Context) *pagemodel.PageResult[E] { var table gotag.ExportTable[E]{} table.E self.NewOfPtrType() return self.ExportFile2Ret2Html(c, table) } func (self *UiSimpleRequest[P, E]) ExportFile2Ret2Html(c *gin.Context, ireportTable gotag.IreportTable) *pagemodel.PageResult[E] { var ret self.ExportFile2Ret(c, ireportTable) if ret.IsSuccess() { var excelResult ret.DataExtend.(*goexcel.ExcelResult) var req excel2html.HtmlData{ Title: excelResult.Title, InputExcelFile: excelResult.FilePath, } err : excel2html.FindBeanExcel2Html().ConvertToHtml(req) if err ! nil { ret.FailError(err) return ret } ret.DataExtend req golog.Info(✅ 转换完成: , req.OutPath) } return ret } func (self *UiSimpleRequest[P, E]) ExportFile2Pdf(c *gin.Context, ireportTable gotag.IreportTable) *pagemodel.PageResult[E] { var ret self.ExportFile2Ret2Html(c, ireportTable) if ret.IsFailed() { return ret } var excelResult ret.DataExtend.(*excel2html.HtmlData) var req excel2html.Hrml2PdfData{ InputHtmlContent: excelResult.OutHtmlContent, InputHtmlFile: excelResult.InputExcelFile, } rets : excel2html.FindBeanExcel2Html().ConvertToPdf(req) if rets.IsFailed() { return self.PageResultFail(rets.Msg) } return ret } func (self *UiSimpleRequest[P, E]) ExportHtmlDefault(c *gin.Context) *pagemodel.PageResult[E] { var table gotag.ExportTable[E]{} table.E self.NewOfPtrType() return self.ExportFile2Ret2Html(c, table) } func (self *UiSimpleRequest[P, E]) SortRet(rets *pagemodel.PageResult[E]) { sort.Slice(rets.Data, func(i, j int) bool { return rets.Data[i].PkeyValue() rets.Data[j].PkeyValue() }) } func (self *UiSimpleRequest[P, E]) FromUser() error { if self.User nil { return fmt.Errorf(user is nil) } self.OpcId self.User.OpcId return nil } func (self *UiSimpleRequest[P, E]) FailMsg(msg string) *basedto.IchubResult { return basedto.ResultCodeMsg(apiconst.SystemMsg_Code_START, msg) } func (self *UiSimpleRequest[P, E]) FailErr(err error) *basedto.IchubResult { return basedto.ResultCodeMsg(apiconst.UserMsg_Code_START, err.Error()) } func (self *UiSimpleRequest[P, E]) FailPageMsg(msg string) *pagemodel.PageResult[E] { return pagemodel.PageResultFailUser[E](msg) } func (self *UiSimpleRequest[P, E]) FailPageErr(err error) *pagemodel.PageResult[E] { return pagemodel.PageResultFailUser[E](err.Error()) } func (self *UiSimpleRequest[P, E]) FailMapMsg(msg string) *pagemodel.PageResult[map[string]any] { return pagemodel.PageResultFailUser[map[string]any](msg) } func (self *UiSimpleRequest[P, E]) FailMapErr(err error) *pagemodel.PageResult[map[string]any] { return pagemodel.PageResultFailUser[map[string]any](err.Error()) }