微调代码

This commit is contained in:
2020-05-22 22:25:21 +08:00
parent b400ac6482
commit 8729724ed8
4 changed files with 16 additions and 18 deletions

View File

@@ -96,17 +96,17 @@ open class MongoGenericQuery<TView>(var template: MongoTemplate, var logger: ILo
} else 0 } else 0
} }
override fun paging(params: PagingParam): PagingData<TView> { override fun paging(param: PagingParam): PagingData<TView> {
this.check() this.check()
return if (this.clazz != null) { return if (this.clazz != null) {
val query = Query() val query = Query()
val fields = this.clazz!!.fields() val fields = this.clazz!!.fields()
val result = PagingData<TView>(params.page, params.size) val result = PagingData<TView>(param.page, param.size)
query.where(params.parameters, this.clazz!!) result.total = this.count(param.parameters)
result.total = this.count(params.parameters) query.where(param.parameters, this.clazz!!)
query.select(fields.toTypedArray()) query.select(fields.toTypedArray())
query.with(order(params.orderBy)) query.with(order(param.orderBy))
query.skip(params.index).limit(params.size) query.skip(param.index).limit(param.size)
result.data = this.template.find(query, this.clazz!!, this.collection) result.data = this.template.find(query, this.clazz!!, this.collection)
result result
} else PagingData(1, 10) } else PagingData(1, 10)

View File

@@ -47,17 +47,15 @@ open class MongoQuery(var repo: MongoTemplate, var logger: ILogger? = null) : IQ
return this.repo.count(query.where(params, clazz), this.collection(clazz)).toInt() return this.repo.count(query.where(params, clazz), this.collection(clazz)).toInt()
} }
override fun <TView> paging(params: PagingParam, clazz: Class<TView>): PagingData<TView> { override fun <TView> paging(param: PagingParam, clazz: Class<TView>): PagingData<TView> {
val fields = clazz.fields() val fields = clazz.fields()
val result = PagingData<TView>(1, 10) val result = PagingData<TView>(param.page, param.size)
result.size = params.size result.total = this.count(param.parameters, clazz)
result.page = params.page
val query = Query() val query = Query()
query.where(params.parameters, clazz) query.where(param.parameters, clazz)
result.total = this.count(params.parameters, clazz)
query.select(fields.toTypedArray()) query.select(fields.toTypedArray())
query.with(order(params.orderBy)) query.with(order(param.orderBy))
query.skip(params.index).limit(params.size) query.skip(param.index).limit(param.size)
result.data = this.repo.find(query, clazz, this.collection(clazz)) result.data = this.repo.find(query, clazz, this.collection(clazz))
return result return result
} }

View File

@@ -35,8 +35,8 @@ interface IGenericQuery<TView, TKey> {
/** /**
* 根据实体类条件查询所有符合条件记录(分页查询) * 根据实体类条件查询所有符合条件记录(分页查询)
* *
* @param params 分页条件 * @param param 分页条件
* @return 分页数据 * @return 分页数据
*/ */
fun paging(params: PagingParam): PagingData<TView> fun paging(param: PagingParam): PagingData<TView>
} }

View File

@@ -33,8 +33,8 @@ interface IQuery {
/** /**
* 根据实体类条件查询所有符合条件记录(分页查询) * 根据实体类条件查询所有符合条件记录(分页查询)
* *
* @param params 分页条件 * @param param 分页条件
* @return 分页数据 * @return 分页数据
*/ */
fun <TView> paging(params: PagingParam, clazz: Class<TView>): PagingData<TView> fun <TView> paging(param: PagingParam, clazz: Class<TView>): PagingData<TView>
} }