Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.model.external.CatalogContentModel;

    /**

     * siteContent docs for the /external catalogMaster feed, ordered by _id.

     * sinceMillis == null: all docs. Otherwise docs whose lastModified >= since

     * OR that have no lastModified yet (pre-backfill docs stay visible).

     */

    public List<CatalogContentModel> getSiteContentPage(Long sinceMillis, int offset, int limit) {

        List<CatalogContentModel> result = new ArrayList<>();

        DB db = contentMongoClient.getDB(CONTENT);

        DBCollection collection = db.getCollection(SITE_CONTENT);

        DBCursor cursor = collection.find(siteContentSinceFilter(sinceMillis))

                .sort(new BasicDBObject("_id", 1)).skip(offset).limit(limit);

        while (cursor.hasNext()) {

            DBObject doc = cursor.next();

            try {

                long docId = ((Number) doc.get("_id")).longValue();

                // read directly off the doc: NumberLong renders as {"$numberLong":...}

                // in toJson, which gson cannot map onto a Long field

                Object lastModified = doc.get("lastModified");

                ContentPojo cp = gson.fromJson(new BasicDBObject(doc.toMap()).toJson(), ContentPojo.class);

                if (cp.getDefaultImageUrl() != null) {

                    cp.setDefaultImageUrl(cp.getDefaultImageUrl().replaceAll("saholic", "smartdukaan"));

                }

                result.add(new CatalogContentModel(docId,

                        lastModified == null ? null : ((Number) lastModified).longValue(), cp));

            } catch (Exception e) {

                // skip malformed entries

            }

        }

        cursor.close();

        return result;

    }

    public long countSiteContent(Long sinceMillis) {

        DB db = contentMongoClient.getDB(CONTENT);

        DBCollection collection = db.getCollection(SITE_CONTENT);

        return collection.count(siteContentSinceFilter(sinceMillis));

    }

    private static DBObject siteContentSinceFilter(Long sinceMillis) {

        if (sinceMillis == null) {

            return new BasicDBObject();

        }

        List<DBObject> or = new ArrayList<>();

        or.add(new BasicDBObject("lastModified", new BasicDBObject("$gte", sinceMillis)));

        or.add(new BasicDBObject("lastModified", new BasicDBObject("$exists", false)));

        return new BasicDBObject("$or", or);

    }

        // full-document replace below, so the delta-sync marker must be (re)stamped here

        dbo.put("lastModified", System.currentTimeMillis());