jiangjiazhi / regional-platform

Authored by jiangjiazhi over 8 years ago

Exists in master and in 8 other branches

Showing 3 changed files with 24 additions and 0 deletions

...	...	@@ -12,6 +12,14 @@
12	12	public interface ISieveDao {
13	13
14	14	/**
	15	+ * 统计行数
	16	+ *
	17	+ * @param mongoQuery
	18	+ * @return
	19	+ */
	20	+ long count(MongoQuery mongoQuery);
	21	+
	22	+ /**
15	23	* 增加产筛结果
16	24	*
17	25	* @param sieveResultModel

...	...	@@ -21,6 +21,16 @@
21	21	*/
22	22	@Repository("sieveDao")
23	23	public class SieveDaoImpl extends BaseMongoDAOImpl<SieveResultModel> implements ISieveDao {
	24	+
	25	+ /**
	26	+ * 统计行数
	27	+ *
	28	+ * @param mongoQuery
	29	+ * @return
	30	+ */
	31	+ public long count(MongoQuery mongoQuery){
	32	+ return mongoTemplate.count(mongoQuery.convertToMongoQuery(),SieveModel.class);
	33	+ }
24	34	@Override
25	35	public SieveResultModel addSieveResult(SieveResultModel sieveResultModel) {
26	36	sieveResultModel.setModified(new Date());

...	...	@@ -12,6 +12,7 @@
12	12	import com.lyms.platform.query.SieveQuery;
13	13	import com.lyms.platform.query.SieveResultQuery;
14	14	import org.apache.commons.collections.CollectionUtils;
	15	+import org.apache.commons.lang.StringUtils;
15	16	import org.springframework.beans.factory.annotation.Autowired;
16	17	import org.springframework.data.domain.Sort;
17	18	import org.springframework.stereotype.Service;
...	...	@@ -60,6 +61,11 @@
60	61	iSieveDao.update(mongoQuery,sieveResultModel);
61	62	}
62	63	public List<SieveModel> queryList(SieveQuery sieveQuery) {
	64	+ MongoQuery mongoQuery = sieveQuery.convertToQuery();
	65	+ if (StringUtils.isNotEmpty(sieveQuery.getNeed())) {
	66	+ sieveQuery.mysqlBuild((int)iSieveDao.count(sieveQuery.convertToQuery()));
	67	+ mongoQuery.start(sieveQuery.getOffset()).end(sieveQuery.getLimit());
	68	+ }
63	69	return iSieveDao.queryList(sieveQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created"));
64	70	}
65	71