| Line 5... |
Line 5... |
| 5 |
import java.util.Arrays;
|
5 |
import java.util.Arrays;
|
| 6 |
import java.util.HashMap;
|
6 |
import java.util.HashMap;
|
| 7 |
import java.util.List;
|
7 |
import java.util.List;
|
| 8 |
import java.util.Map;
|
8 |
import java.util.Map;
|
| 9 |
import java.util.Set;
|
9 |
import java.util.Set;
|
| - |
|
10 |
import java.util.stream.Collectors;
|
| 10 |
|
11 |
|
| 11 |
import javax.servlet.http.HttpServletRequest;
|
12 |
import javax.servlet.http.HttpServletRequest;
|
| 12 |
|
13 |
|
| 13 |
import org.apache.logging.log4j.LogManager;
|
14 |
import org.apache.logging.log4j.LogManager;
|
| 14 |
import org.apache.logging.log4j.Logger;
|
15 |
import org.apache.logging.log4j.Logger;
|
| Line 120... |
Line 121... |
| 120 |
|
121 |
|
| 121 |
public static final Map<String, Integer> MIN_BRAND_QTY_LIMIT = new HashMap<>();
|
122 |
public static final Map<String, Integer> MIN_BRAND_QTY_LIMIT = new HashMap<>();
|
| 122 |
|
123 |
|
| 123 |
List<EscalationType> esclationType = Arrays.asList(EscalationType.L3, EscalationType.L4, EscalationType.L2);
|
124 |
List<EscalationType> esclationType = Arrays.asList(EscalationType.L3, EscalationType.L4, EscalationType.L2);
|
| 124 |
|
125 |
|
| 125 |
List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com");
|
126 |
List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com",
|
| - |
|
127 |
"niranjan.kala@smartdukaan.com", "sm@smartdukaan.com");
|
| 126 |
|
128 |
|
| 127 |
static {
|
129 |
static {
|
| 128 |
// MIN_BRAND_QTY_LIMIT.put("Realme", 10);
|
130 |
// MIN_BRAND_QTY_LIMIT.put("Realme", 10);
|
| 129 |
MIN_BRAND_QTY_LIMIT.put("Reliance", 5);
|
131 |
MIN_BRAND_QTY_LIMIT.put("Reliance", 5);
|
| 130 |
}
|
132 |
}
|
| Line 182... |
Line 184... |
| 182 |
UserCart uc = userAccountRepository.getUserCart((int) request.getAttribute("userId"));
|
184 |
UserCart uc = userAccountRepository.getUserCart((int) request.getAttribute("userId"));
|
| 183 |
cartService.addAddressToCart(uc.getCartId(), addressId);
|
185 |
cartService.addAddressToCart(uc.getCartId(), addressId);
|
| 184 |
return responseSender.ok("Address Changed successfully");
|
186 |
return responseSender.ok("Address Changed successfully");
|
| 185 |
}
|
187 |
}
|
| 186 |
|
188 |
|
| 187 |
@RequestMapping(value = "/planogram", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
189 |
@RequestMapping(value = "/byPassRequests", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 188 |
@ApiImplicitParams({
|
190 |
@ApiImplicitParams({
|
| 189 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
191 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
| 190 |
|
192 |
|
| 191 |
@ApiOperation(value = "planogram")
|
193 |
@ApiOperation(value = "byPassRequests")
|
| 192 |
public ResponseEntity<?> planogram(HttpServletRequest request, Model model) throws Exception {
|
194 |
public ResponseEntity<?> byPassRequests(HttpServletRequest request, Model model) throws Exception {
|
| 193 |
|
195 |
|
| 194 |
int userId = (int) request.getAttribute("userId");
|
196 |
int userId = (int) request.getAttribute("userId");
|
| 195 |
logger.info(" userId" + userId);
|
- |
|
| 196 |
|
197 |
|
| 197 |
User user = userRepository.selectById(userId);
|
198 |
User user = userRepository.selectById(userId);
|
| 198 |
logger.info(" user" + user);
|
- |
|
| 199 |
AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
|
199 |
AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
|
| 200 |
logger.info("authUser" + authUser);
|
- |
|
| - |
|
200 |
|
| 201 |
List<FocusedModelByPassRequest> byPassRequests = null;
|
201 |
List<FocusedModelByPassRequest> byPassRequests = null;
|
| 202 |
Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
|
- |
|
| 203 |
|
202 |
|
| 204 |
Set<Integer> authfofoIds = null;
|
203 |
Set<Integer> authfofoIds = null;
|
| - |
|
204 |
boolean actionAccess = false;
|
| - |
|
205 |
logger.info("authUser" + authUser);
|
| 205 |
|
206 |
|
| 206 |
List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId());
|
207 |
List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId()).stream()
|
| - |
|
208 |
.filter(x -> (x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES
|
| - |
|
209 |
|| x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM))
|
| - |
|
210 |
.collect(Collectors.toList());
|
| 207 |
|
211 |
|
| 208 |
if (emails.contains(authUser.getEmailId())) {
|
- |
|
| 209 |
authfofoIds = storeGuyMap.get("tarun.verma@smartdukaan.com");
|
212 |
Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
|
| 210 |
logger.info("authfofoeIds" + authfofoIds);
|
- |
|
| 211 |
|
213 |
|
| - |
|
214 |
if (emails.contains(authUser.getEmailId())) {
|
| - |
|
215 |
byPassRequests = focusedModelByPassRepository.selectByStatus(ByPassRequestStatus.PENDING);
|
| - |
|
216 |
actionAccess = true;
|
| 212 |
} else {
|
217 |
} else {
|
| - |
|
218 |
if (!positions.isEmpty()) {
|
| - |
|
219 |
for (Position ps : positions) {
|
| - |
|
220 |
if (ProfitMandiConstants.TICKET_CATEGORY_RBM == ps.getCategoryId()) {
|
| - |
|
221 |
authfofoIds = storeGuyMap.get(user.getEmailId());
|
| - |
|
222 |
logger.info("authfofoIdsw" + authfofoIds);
|
| - |
|
223 |
actionAccess = true;
|
| - |
|
224 |
break;
|
| - |
|
225 |
} else if (ProfitMandiConstants.TICKET_CATEGORY_SALES == ps.getCategoryId()) {
|
| - |
|
226 |
authfofoIds = storeGuyMap.get(user.getEmailId());
|
| - |
|
227 |
logger.info("authfofoIdsw" + authfofoIds);
|
| - |
|
228 |
actionAccess = false;
|
| - |
|
229 |
break;
|
| - |
|
230 |
}
|
| 213 |
|
231 |
|
| 214 |
for (Position ps : positions) {
|
- |
|
| 215 |
if (esclationType.contains(ps.getEscalationType())) {
|
- |
|
| 216 |
authfofoIds = storeGuyMap.get(user.getEmailId());
|
- |
|
| 217 |
logger.info("authfofoIdsw" + authfofoIds);
|
- |
|
| 218 |
|
- |
|
| 219 |
break;
|
- |
|
| 220 |
}
|
232 |
}
|
| 221 |
|
- |
|
| 222 |
}
|
233 |
}
|
| 223 |
}
|
234 |
}
|
| 224 |
logger.info("authfofoIds" + authfofoIds);
|
235 |
logger.info("authfofoIds" + authfofoIds);
|
| 225 |
if (authfofoIds != null) {
|
236 |
if (authfofoIds != null) {
|
| 226 |
byPassRequests = focusedModelByPassRepository.selectByStatusAndFofoIds(new ArrayList<>(authfofoIds),
|
237 |
byPassRequests = focusedModelByPassRepository.selectByStatusAndFofoIds(new ArrayList<>(authfofoIds),
|
| Line 240... |
Line 251... |
| 240 |
bp.setFofoId(byPassRequest.getFofoId());
|
251 |
bp.setFofoId(byPassRequest.getFofoId());
|
| 241 |
bp.setByPassRequestId(byPassRequest.getId());
|
252 |
bp.setByPassRequestId(byPassRequest.getId());
|
| 242 |
bp.setInvestmentOkDays((Long) investments.get("okDays"));
|
253 |
bp.setInvestmentOkDays((Long) investments.get("okDays"));
|
| 243 |
bp.setInvestmentShort((int) investments.get("short"));
|
254 |
bp.setInvestmentShort((int) investments.get("short"));
|
| 244 |
bp.setMobileNumber(customRetailerMap.get(byPassRequest.getFofoId()).getMobileNumber());
|
255 |
bp.setMobileNumber(customRetailerMap.get(byPassRequest.getFofoId()).getMobileNumber());
|
| - |
|
256 |
bp.setActionAccess(actionAccess);
|
| 245 |
bp.setCreateTimestamp(byPassRequest.getCreatedTimeStamp());
|
257 |
bp.setCreateTimestamp(byPassRequest.getCreatedTimeStamp());
|
| 246 |
bp.setUpdateTimestamp(byPassRequest.getUpdatedTimestamp());
|
258 |
bp.setUpdateTimestamp(byPassRequest.getUpdatedTimestamp());
|
| 247 |
byPassList.add(bp);
|
259 |
byPassList.add(bp);
|
| 248 |
|
260 |
|
| 249 |
}
|
261 |
}
|
| Line 256... |
Line 268... |
| 256 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
268 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
| 257 |
@ApiOperation(value = "Add items to cart")
|
269 |
@ApiOperation(value = "Add items to cart")
|
| 258 |
public ResponseEntity<?> addAmountToWalletRequestRejected(HttpServletRequest request,
|
270 |
public ResponseEntity<?> addAmountToWalletRequestRejected(HttpServletRequest request,
|
| 259 |
@RequestParam(name = "id", defaultValue = "0") int id, @RequestParam ByPassRequestStatus status,
|
271 |
@RequestParam(name = "id", defaultValue = "0") int id, @RequestParam ByPassRequestStatus status,
|
| 260 |
Model model) throws Exception {
|
272 |
Model model) throws Exception {
|
| - |
|
273 |
int userId = (int) request.getAttribute("userId");
|
| - |
|
274 |
|
| - |
|
275 |
User user = userRepository.selectById(userId);
|
| - |
|
276 |
AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
|
| 261 |
|
277 |
|
| 262 |
FocusedModelByPassRequest byPassRequest = focusedModelByPassRepository.selectById(id);
|
278 |
FocusedModelByPassRequest byPassRequest = focusedModelByPassRepository.selectById(id);
|
| 263 |
if (status.equals(ByPassRequestStatus.APPROVED)) {
|
279 |
if (status.equals(ByPassRequestStatus.APPROVED)) {
|
| 264 |
byPassRequest.setByPass(true);
|
280 |
byPassRequest.setByPass(true);
|
| - |
|
281 |
byPassRequest.setAuthId(authUser.getId());
|
| 265 |
byPassRequest.setStatus(ByPassRequestStatus.APPROVED);
|
282 |
byPassRequest.setStatus(ByPassRequestStatus.APPROVED);
|
| 266 |
byPassRequest.setUpdatedTimestamp(LocalDateTime.now());
|
283 |
byPassRequest.setUpdatedTimestamp(LocalDateTime.now());
|
| 267 |
} else if (status.equals(ByPassRequestStatus.REJECTED)) {
|
284 |
} else if (status.equals(ByPassRequestStatus.REJECTED)) {
|
| 268 |
byPassRequest.setByPass(false);
|
285 |
byPassRequest.setByPass(false);
|
| - |
|
286 |
byPassRequest.setAuthId(authUser.getId());
|
| 269 |
byPassRequest.setStatus(ByPassRequestStatus.REJECTED);
|
287 |
byPassRequest.setStatus(ByPassRequestStatus.REJECTED);
|
| 270 |
byPassRequest.setUpdatedTimestamp(LocalDateTime.now());
|
288 |
byPassRequest.setUpdatedTimestamp(LocalDateTime.now());
|
| 271 |
}
|
289 |
}
|
| 272 |
|
290 |
|
| 273 |
SendNotificationModel sendNotificationModel = new SendNotificationModel();
|
291 |
SendNotificationModel sendNotificationModel = new SendNotificationModel();
|