From a04ed04d33324d0c5360f98fefec50cd8757ab1c Mon Sep 17 00:00:00 2001
From: jiangjiazhi <jiangjiazhi@lymsh.com>
Date: Thu, 25 Aug 2016 09:14:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B0=E7=94=B5=E5=AD=90?=
 =?UTF-8?q?=E7=97=85=E5=8E=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/lyms/platform/biz/dal/ISieveDao.java     |  8 ++++++++
 .../main/java/com/lyms/platform/biz/dal/impl/SieveDaoImpl.java | 10 ++++++++++
 .../main/java/com/lyms/platform/biz/service/SieveService.java  |  6 ++++++
 3 files changed, 24 insertions(+)

diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISieveDao.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISieveDao.java
index 8bfcf96..d09cebd 100644
--- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISieveDao.java
+++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISieveDao.java
@@ -12,6 +12,14 @@ import java.util.List;
 public interface ISieveDao {
 
     /**
+     * 统计行数
+     *
+     * @param mongoQuery
+     * @return
+     */
+    long count(MongoQuery mongoQuery);
+
+    /**
      * 增加产筛结果
      *
      * @param sieveResultModel
diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SieveDaoImpl.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SieveDaoImpl.java
index 969619c..3d11599 100644
--- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SieveDaoImpl.java
+++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SieveDaoImpl.java
@@ -21,6 +21,16 @@ import java.util.List;
  */
 @Repository("sieveDao")
 public class SieveDaoImpl extends BaseMongoDAOImpl<SieveResultModel> implements ISieveDao {
+
+    /**
+     * 统计行数
+     *
+     * @param mongoQuery
+     * @return
+     */
+   public long count(MongoQuery mongoQuery){
+       return mongoTemplate.count(mongoQuery.convertToMongoQuery(),SieveModel.class);
+    }
     @Override
     public SieveResultModel addSieveResult(SieveResultModel sieveResultModel) {
         sieveResultModel.setModified(new Date());
diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SieveService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SieveService.java
index 1e7d7ce..8f17767 100644
--- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SieveService.java
+++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SieveService.java
@@ -12,6 +12,7 @@ import com.lyms.platform.query.SieveApplyOrderQuery;
 import com.lyms.platform.query.SieveQuery;
 import com.lyms.platform.query.SieveResultQuery;
 import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
@@ -60,6 +61,11 @@ public class SieveService {
         iSieveDao.update(mongoQuery,sieveResultModel);
     }
     public List<SieveModel> queryList(SieveQuery sieveQuery) {
+        MongoQuery mongoQuery = sieveQuery.convertToQuery();
+        if (StringUtils.isNotEmpty(sieveQuery.getNeed())) {
+            sieveQuery.mysqlBuild((int)iSieveDao.count(sieveQuery.convertToQuery()));
+            mongoQuery.start(sieveQuery.getOffset()).end(sieveQuery.getLimit());
+        }
         return iSieveDao.queryList(sieveQuery.convertToQuery().addOrder(Sort.Direction.DESC, "created"));
     }
 
-- 
1.8.3.1