CMQ改造为rabbitmq

admin

2024-10-16 7fa83e5dd03f7896bd1d1e8c47f5e926ff3d4ba0

 service-push/src/main/java/com/ks/push/dao/BPushTaskDao.java

@@ -3,6 +3,7 @@
import com.ks.push.pojo.DO.BPushTask;
import com.ks.lib.common.dao.MongodbBaseDao;
import com.ks.push.pojo.Query.BPushTaskQuery;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
@@ -78,6 +79,9 @@
        Query query = getQuery(daoQuery);
        query.skip(start);
        query.limit(count);
        if (daoQuery.sortList != null) {
            query.with(Sort.by(daoQuery.sortList));
        }
        return findList(query);
    }