| Line 2... |
Line 2... |
| 2 |
|
2 |
|
| 3 |
import java.lang.reflect.Type;
|
3 |
import java.lang.reflect.Type;
|
| 4 |
import java.util.ArrayList;
|
4 |
import java.util.ArrayList;
|
| 5 |
import java.util.Arrays;
|
5 |
import java.util.Arrays;
|
| 6 |
import java.util.HashMap;
|
6 |
import java.util.HashMap;
|
| - |
|
7 |
import java.util.Iterator;
|
| 7 |
import java.util.List;
|
8 |
import java.util.List;
|
| 8 |
import java.util.Map;
|
9 |
import java.util.Map;
|
| 9 |
import java.util.stream.Collectors;
|
10 |
import java.util.stream.Collectors;
|
| 10 |
|
11 |
|
| 11 |
import org.apache.logging.log4j.LogManager;
|
12 |
import org.apache.logging.log4j.LogManager;
|
| Line 46... |
Line 47... |
| 46 |
private static final String NOTIFICATION_CAMPAIGNS = "notificationcampaigns";
|
47 |
private static final String NOTIFICATION_CAMPAIGNS = "notificationcampaigns";
|
| 47 |
private static final String USER_DB = "User";
|
48 |
private static final String USER_DB = "User";
|
| 48 |
private static final int MONGO_PORT = 27017;
|
49 |
private static final int MONGO_PORT = 27017;
|
| 49 |
|
50 |
|
| 50 |
private static final Gson gson = new Gson();
|
51 |
private static final Gson gson = new Gson();
|
| 51 |
|
- |
|
| - |
|
52 |
private static final List<String> BLOCKED_BRANDS = Arrays.asList("Realme");
|
| 52 |
public static final Map<Integer, List<String>> PARTNER_BLoCKED_BRANDS = new HashMap<>();
|
53 |
public static final Map<Integer, List<String>> PARTNER_BLoCKED_BRANDS = new HashMap<>();
|
| - |
|
54 |
public static final Map<Integer, List<String>> PARTNER_ALLOWED_BRANDS = new HashMap<>();
|
| - |
|
55 |
|
| 53 |
|
56 |
|
| 54 |
static {
|
57 |
static {
|
| 55 |
PARTNER_BLoCKED_BRANDS.put(175135597, Arrays.asList("Vivo"));
|
58 |
PARTNER_BLoCKED_BRANDS.put(175135597, Arrays.asList("Vivo"));
|
| 56 |
PARTNER_BLoCKED_BRANDS.put(175135183, Arrays.asList("Vivo"));
|
59 |
PARTNER_BLoCKED_BRANDS.put(175135183, Arrays.asList("Vivo"));
|
| 57 |
PARTNER_BLoCKED_BRANDS.put(175137445, Arrays.asList("Vivo"));
|
60 |
PARTNER_BLoCKED_BRANDS.put(175137445, Arrays.asList("Vivo"));
|
| Line 78... |
Line 81... |
| 78 |
PARTNER_BLoCKED_BRANDS.put(175138637, Arrays.asList("Vivo"));
|
81 |
PARTNER_BLoCKED_BRANDS.put(175138637, Arrays.asList("Vivo"));
|
| 79 |
// PARTNER_BLoCKED_BRANDS.put(175138814,Arrays.asList("Vivo"));
|
82 |
// PARTNER_BLoCKED_BRANDS.put(175138814,Arrays.asList("Vivo"));
|
| 80 |
//PARTNER_BLoCKED_BRANDS.put(175138833, Arrays.asList("Vivo"));
|
83 |
//PARTNER_BLoCKED_BRANDS.put(175138833, Arrays.asList("Vivo"));
|
| 81 |
//Durga Enterprises
|
84 |
//Durga Enterprises
|
| 82 |
//PARTNER_BLoCKED_BRANDS.put(175138832, Arrays.asList("Vivo"));
|
85 |
//PARTNER_BLoCKED_BRANDS.put(175138832, Arrays.asList("Vivo"));
|
| - |
|
86 |
PARTNER_ALLOWED_BRANDS.put(172157716, Arrays.asList("Realme"));
|
| - |
|
87 |
PARTNER_ALLOWED_BRANDS.put(175135227, Arrays.asList("Realme"));
|
| - |
|
88 |
PARTNER_ALLOWED_BRANDS.put(175135707, Arrays.asList("Realme"));
|
| - |
|
89 |
PARTNER_ALLOWED_BRANDS.put(175135923, Arrays.asList("Realme"));
|
| - |
|
90 |
PARTNER_ALLOWED_BRANDS.put(175138372, Arrays.asList("Realme"));
|
| - |
|
91 |
PARTNER_ALLOWED_BRANDS.put(175138520, Arrays.asList("Realme"));
|
| - |
|
92 |
PARTNER_ALLOWED_BRANDS.put(175138522, Arrays.asList("Realme"));
|
| - |
|
93 |
PARTNER_ALLOWED_BRANDS.put(175138541, Arrays.asList("Realme"));
|
| - |
|
94 |
PARTNER_ALLOWED_BRANDS.put(175138674, Arrays.asList("Realme"));
|
| - |
|
95 |
PARTNER_ALLOWED_BRANDS.put(175138716, Arrays.asList("Realme"));
|
| - |
|
96 |
PARTNER_ALLOWED_BRANDS.put(175138801, Arrays.asList("Realme"));
|
| - |
|
97 |
PARTNER_ALLOWED_BRANDS.put(175138812, Arrays.asList("Realme"));
|
| - |
|
98 |
PARTNER_ALLOWED_BRANDS.put(175138813, Arrays.asList("Realme"));
|
| - |
|
99 |
PARTNER_ALLOWED_BRANDS.put(175138814, Arrays.asList("Realme"));
|
| - |
|
100 |
PARTNER_ALLOWED_BRANDS.put(175138816, Arrays.asList("Realme"));
|
| - |
|
101 |
PARTNER_ALLOWED_BRANDS.put(175138820, Arrays.asList("Realme"));
|
| - |
|
102 |
PARTNER_ALLOWED_BRANDS.put(175138836, Arrays.asList("Realme"));
|
| - |
|
103 |
PARTNER_ALLOWED_BRANDS.put(175138838, Arrays.asList("Realme"));
|
| - |
|
104 |
PARTNER_ALLOWED_BRANDS.put(175138840, Arrays.asList("Realme"));
|
| - |
|
105 |
PARTNER_ALLOWED_BRANDS.put(175138842, Arrays.asList("Realme"));
|
| - |
|
106 |
PARTNER_ALLOWED_BRANDS.put(175138843, Arrays.asList("Realme"));
|
| - |
|
107 |
PARTNER_ALLOWED_BRANDS.put(175138847, Arrays.asList("Realme"));
|
| - |
|
108 |
PARTNER_ALLOWED_BRANDS.put(175138858, Arrays.asList("Realme"));
|
| - |
|
109 |
PARTNER_ALLOWED_BRANDS.put(175138859, Arrays.asList("Realme"));
|
| - |
|
110 |
PARTNER_ALLOWED_BRANDS.put(175138860, Arrays.asList("Realme"));
|
| - |
|
111 |
PARTNER_ALLOWED_BRANDS.put(175138862, Arrays.asList("Realme"));
|
| - |
|
112 |
PARTNER_ALLOWED_BRANDS.put(175138863, Arrays.asList("Realme"));
|
| - |
|
113 |
PARTNER_ALLOWED_BRANDS.put(175138865, Arrays.asList("Realme"));
|
| - |
|
114 |
PARTNER_ALLOWED_BRANDS.put(175138868, Arrays.asList("Realme"));
|
| 83 |
|
115 |
|
| 84 |
}
|
116 |
}
|
| 85 |
|
117 |
|
| 86 |
private MongoClient mongoClient;
|
118 |
private MongoClient mongoClient;
|
| 87 |
private MongoClient contentMongoClient;
|
119 |
private MongoClient contentMongoClient;
|
| Line 112... |
Line 144... |
| 112 |
return cp;
|
144 |
return cp;
|
| 113 |
}
|
145 |
}
|
| 114 |
|
146 |
|
| 115 |
public List<DBObject> getMongoBrands(int fofoId, String email, int categoryId) {
|
147 |
public List<DBObject> getMongoBrands(int fofoId, String email, int categoryId) {
|
| 116 |
List<DBObject> brandsDisplay = this.getBrandsToDisplay(categoryId);
|
148 |
List<DBObject> brandsDisplay = this.getBrandsToDisplay(categoryId);
|
| - |
|
149 |
Iterator<DBObject> brandsDisplayIterator = brandsDisplay.iterator();
|
| - |
|
150 |
List<String> partnerAllowedBrands = PARTNER_ALLOWED_BRANDS.get(fofoId);
|
| - |
|
151 |
while(brandsDisplayIterator.hasNext()) {
|
| - |
|
152 |
String brand = brandsDisplayIterator.next().get("name").toString();
|
| - |
|
153 |
if(BLOCKED_BRANDS.contains(brand)) {
|
| - |
|
154 |
if(partnerAllowedBrands == null || !partnerAllowedBrands.contains(brand)) {
|
| - |
|
155 |
brandsDisplayIterator.remove();
|
| - |
|
156 |
}
|
| - |
|
157 |
}
|
| - |
|
158 |
}
|
| 117 |
if (PARTNER_BLoCKED_BRANDS.containsKey(fofoId)) {
|
159 |
if (PARTNER_BLoCKED_BRANDS.containsKey(fofoId)) {
|
| 118 |
List<String> blockedBrands = PARTNER_BLoCKED_BRANDS.get(fofoId);
|
160 |
List<String> blockedBrands = PARTNER_BLoCKED_BRANDS.get(fofoId);
|
| 119 |
brandsDisplay = brandsDisplay.stream().filter(x -> !blockedBrands.contains(x.get("name")))
|
161 |
brandsDisplay = brandsDisplay.stream().filter(x -> !blockedBrands.contains(x.get("name")))
|
| 120 |
.collect(Collectors.toList());
|
162 |
.collect(Collectors.toList());
|
| 121 |
}
|
163 |
}
|