Subversion Repositories SmartDukaan

Rev

Rev 32482 | Rev 35390 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 32482 Rev 35236
Line 5... Line 5...
5 
import com.mongodb.*;
 5 
import com.mongodb.*;
6 
import com.mongodb.client.AggregateIterable;
 6 
import com.mongodb.client.AggregateIterable;
7 
import com.mongodb.client.MongoCollection;
 7 
import com.mongodb.client.MongoCollection;
8 
import com.mongodb.client.MongoDatabase;
 8 
import com.mongodb.client.MongoDatabase;
9 
import com.mongodb.util.JSON;
 9 
import com.mongodb.util.JSON;
10 
import com.spice.profitmandi.common.util.Utils;
 - 
 
11 
import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;
 10 
import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;
12 
import com.spice.profitmandi.dao.model.ContentPojo;
 11 
import com.spice.profitmandi.dao.model.ContentPojo;
13 
import com.spice.profitmandi.dao.model.FofoForm;
 12 
import com.spice.profitmandi.dao.model.FofoForm;
14 
import com.spice.profitmandi.dao.model.RetailerFofoInterest;
 13 
import com.spice.profitmandi.dao.model.RetailerFofoInterest;
15 
import org.apache.logging.log4j.LogManager;
 14 
import org.apache.logging.log4j.LogManager;
16 
import org.apache.logging.log4j.Logger;
 15 
import org.apache.logging.log4j.Logger;
17 
import org.bson.Document;
 16 
import org.bson.Document;
18 
import org.json.JSONObject;
 17 
import org.json.JSONObject;
19 
import org.springframework.beans.factory.annotation.Autowired;
 - 
 
20 
 
 18 
 
21 
import java.lang.reflect.Type;
 19 
import java.lang.reflect.Type;
- 
 
 20 
import java.util.ArrayList;
- 
 
 21 
import java.util.Arrays;
22 
import java.util.*;
 22 
import java.util.List;
23 
import java.util.stream.Collectors;
 23 
import java.util.Map;
24 
 
 24 
 
25 
public class Mongo {
 25 
public class Mongo {
26 
 
 26 
 
27 
    private static final Logger LOGGER = LogManager.getLogger(Mongo.class);
 27 
    private static final Logger LOGGER = LogManager.getLogger(Mongo.class);
28 
 
 28 
 
Line 39... Line 39...
39 
    private static final String USER_DB = "User";
 39 
    private static final String USER_DB = "User";
40 
    private static final int MONGO_PORT = 27017;
 40 
    private static final int MONGO_PORT = 27017;
41 
 
 41 
 
42 
    private static final Gson gson = new Gson();
 42 
    private static final Gson gson = new Gson();
43 
 
 43 
 
44 
    @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
 - 
 
45 
    @Autowired
 - 
 
46 
    private RetailerBlockBrandsRepository retailerBlockBrandsRepository;
 - 
 
47 
 
 - 
 
48 
    private MongoClient mongoClient;
 44 
    private MongoClient mongoClient;
49 
    private MongoClient contentMongoClient;
 45 
    private MongoClient contentMongoClient;
50 
 
 46 
 
51 
    public Mongo(String mongoHost, String contentMongoHost) {
 47 
    public Mongo(String mongoHost, String contentMongoHost) {
52 
        try {
 48 
        try {
Line 76... Line 72...
76 
        //LOGGER.info("cp" + cp);
 72 
        //LOGGER.info("cp" + cp);
77 
 
 73 
 
78 
        return cp;
 74 
        return cp;
79 
    }
 75 
    }
80 
 
 76 
 
81 
    public List<DBObject> getMongoBrands(int fofoId, String email, int categoryId) {
 - 
 
82 
        List<DBObject> brandsDisplay = this.getBrandsToDisplay(categoryId);
 - 
 
83 
        if (fofoId == Utils.SYSTEM_PARTNER_ID) {
 - 
 
84 
            return brandsDisplay;
 - 
 
85 
        }
 - 
 
86 
        List<String> blockedBrands = retailerBlockBrandsRepository.selectAllByRetailer(fofoId).stream()
 - 
 
87 
                .map(x -> x.getBlockBrands()).collect(Collectors.toList());
 - 
 
88 
        brandsDisplay = brandsDisplay.stream().filter(x -> !blockedBrands.contains(x.get("name")))
 - 
 
89 
                .collect(Collectors.toList());
 - 
 
90 
 
 - 
 
91 
        //LOGGER.info("brandsDisplay" + brandsDisplay);
 - 
 
92 
        return brandsDisplay;
 - 
 
93 
    }
 - 
 
94 
 
 - 
 
95 
    public ContentPojo getEntityByName(String name) throws Exception {
 77 
    public ContentPojo getEntityByName(String name) throws Exception {
96 
        //LOGGER.info("Name --- {}", name);
 78 
        //LOGGER.info("Name --- {}", name);
97 
        DB db = contentMongoClient.getDB(CONTENT);
 79 
        DB db = contentMongoClient.getDB(CONTENT);
98 
        DBCollection collection = db.getCollection(SITE_CONTENT);
 80 
        DBCollection collection = db.getCollection(SITE_CONTENT);
99 
        BasicDBObject obj = new BasicDBObject();
 81 
        BasicDBObject obj = new BasicDBObject();