From ea68e8f8c00c0178037a9f1cc6dc1663bde913b8 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 03 七月 2021 17:49:35 +0800
Subject: [PATCH] 推送服务完善

---
 service-push/src/main/java/com/ks/push/service/remote/BPushTaskServiceImpl.java |    9 +++++++--
 1 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/service-push/src/main/java/com/ks/push/service/remote/BPushTaskServiceImpl.java b/service-push/src/main/java/com/ks/push/service/remote/BPushTaskServiceImpl.java
index 007fd50..76d9ff0 100644
--- a/service-push/src/main/java/com/ks/push/service/remote/BPushTaskServiceImpl.java
+++ b/service-push/src/main/java/com/ks/push/service/remote/BPushTaskServiceImpl.java
@@ -9,8 +9,11 @@
 import com.ks.push.pojo.Query.BPushTaskQuery;
 import com.ks.push.service.BPushTaskService;
 import org.apache.dubbo.config.annotation.Service;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 
 import javax.annotation.Resource;
+import java.util.ArrayList;
 import java.util.List;
 
 @Service(version = "1.0")
@@ -36,14 +39,16 @@
         return bPushTaskDao.get(taskId);
     }
 
+
     @Override
     public List<BPushTask> list(BPushTaskQuery query, int page, int pageSize) {
-        return null;
+
+        return bPushTaskDao.list(query, (page - 1) * pageSize, pageSize);
     }
 
     @Override
     public long count(BPushTaskQuery query) {
-        return 0;
+        return bPushTaskDao.count(query);
     }
 
     @Override

--
Gitblit v1.8.0