| Line 74... |
Line 74... |
| 74 |
*/
|
74 |
*/
|
| 75 |
@Controller
|
75 |
@Controller
|
| 76 |
@Transactional(rollbackFor = Throwable.class)
|
76 |
@Transactional(rollbackFor = Throwable.class)
|
| 77 |
public class UserController {
|
77 |
public class UserController {
|
| 78 |
|
78 |
|
| 79 |
@Autowired
|
79 |
@Autowired
|
| 80 |
private ResponseSender<?> responseSender;
|
80 |
private ResponseSender<?> responseSender;
|
| 81 |
|
81 |
|
| 82 |
private static final Logger LOGGER = LogManager.getLogger(UserController.class);
|
82 |
private static final Logger LOGGER = LogManager.getLogger(UserController.class);
|
| 83 |
|
83 |
|
| 84 |
@Value("${notifications.api.host}")
|
84 |
@Value("${notifications.api.host}")
|
| 85 |
private String nodeHost;
|
85 |
private String nodeHost;
|
| 86 |
|
86 |
|
| 87 |
@Autowired
|
87 |
@Autowired
|
| 88 |
private MobileAppSettingsRepository mobileAppSettingsRepository;
|
88 |
private MobileAppSettingsRepository mobileAppSettingsRepository;
|
| 89 |
|
89 |
|
| 90 |
@Value("${notifications.api.port}")
|
90 |
@Value("${notifications.api.port}")
|
| 91 |
private int nodePort;
|
91 |
private int nodePort;
|
| 92 |
|
92 |
|
| 93 |
@Value("${admin.token}")
|
93 |
@Value("${admin.token}")
|
| 94 |
private String validAdminToken;
|
94 |
private String validAdminToken;
|
| 95 |
|
95 |
|
| 96 |
@Autowired
|
96 |
@Autowired
|
| 97 |
private UserRepository userRepository;
|
97 |
private UserRepository userRepository;
|
| 98 |
|
98 |
|
| 99 |
@Autowired
|
99 |
@Autowired
|
| 100 |
private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
|
100 |
private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
|
| 101 |
|
101 |
|
| 102 |
@Autowired
|
102 |
@Autowired
|
| 103 |
private RetailerRepository retailerRepository;
|
103 |
private RetailerRepository retailerRepository;
|
| 104 |
|
104 |
|
| 105 |
@Autowired
|
105 |
@Autowired
|
| 106 |
private UserRoleRepository userRoleRepository;
|
106 |
private UserRoleRepository userRoleRepository;
|
| 107 |
|
107 |
|
| 108 |
@Autowired
|
108 |
@Autowired
|
| 109 |
private PartnerTypeChangeService partnerTypeChangeService;
|
109 |
private PartnerTypeChangeService partnerTypeChangeService;
|
| 110 |
|
110 |
|
| 111 |
@Autowired
|
111 |
@Autowired
|
| 112 |
private UserAccountRepository userAccountRepository;
|
112 |
private UserAccountRepository userAccountRepository;
|
| 113 |
|
113 |
|
| 114 |
@Autowired
|
114 |
@Autowired
|
| 115 |
private AuthService authService;
|
115 |
private AuthService authService;
|
| 116 |
|
116 |
|
| 117 |
@Autowired
|
117 |
@Autowired
|
| 118 |
private AddressRepository addressRepository;
|
118 |
private AddressRepository addressRepository;
|
| 119 |
|
119 |
|
| 120 |
@Autowired
|
120 |
@Autowired
|
| 121 |
private GoogleLoginProcessor googleLoginProcessor;
|
121 |
private GoogleLoginProcessor googleLoginProcessor;
|
| 122 |
|
122 |
|
| 123 |
@Autowired
|
123 |
@Autowired
|
| 124 |
private UserService userService;
|
124 |
private UserService userService;
|
| 125 |
|
125 |
|
| 126 |
@Autowired
|
126 |
@Autowired
|
| 127 |
private CsService csService;
|
127 |
private CsService csService;
|
| 128 |
|
128 |
|
| 129 |
@Autowired
|
129 |
@Autowired
|
| 130 |
private RestClient restClient;
|
130 |
private RestClient restClient;
|
| 131 |
|
131 |
|
| 132 |
@Autowired
|
132 |
@Autowired
|
| 133 |
private RoleManager roleManager;
|
133 |
private RoleManager roleManager;
|
| 134 |
|
134 |
|
| 135 |
@Autowired
|
135 |
@Autowired
|
| 136 |
private RoleRepository roleRepository;
|
136 |
private RoleRepository roleRepository;
|
| 137 |
|
137 |
|
| 138 |
@Autowired
|
138 |
@Autowired
|
| 139 |
private AuthRepository authRepository;
|
139 |
private AuthRepository authRepository;
|
| 140 |
|
140 |
|
| 141 |
@Autowired
|
141 |
@Autowired
|
| 142 |
private ObjectMapper objectMapper;
|
142 |
private ObjectMapper objectMapper;
|
| 143 |
|
143 |
|
| 144 |
@Autowired
|
144 |
@Autowired
|
| 145 |
private RetailerService retailerService;
|
145 |
private RetailerService retailerService;
|
| 146 |
|
146 |
|
| 147 |
@Autowired
|
147 |
@Autowired
|
| 148 |
private RefferalRepository refferalRepository;
|
148 |
private RefferalRepository refferalRepository;
|
| 149 |
|
149 |
|
| 150 |
@Autowired
|
150 |
@Autowired
|
| 151 |
private PromoterRepository promoterRepository;
|
151 |
private PromoterRepository promoterRepository;
|
| 152 |
|
152 |
|
| 153 |
@Autowired
|
153 |
@Autowired
|
| 154 |
JavaMailSender mailSender;
|
154 |
JavaMailSender mailSender;
|
| 155 |
|
155 |
|
| 156 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_GOOGLE_LOGIN, method = RequestMethod.POST)
|
156 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_GOOGLE_LOGIN, method = RequestMethod.POST)
|
| 157 |
public ResponseEntity<?> googleLogin(HttpServletRequest request, @RequestBody GoogleLoginRequest googleLoginRequest)
|
157 |
public ResponseEntity<?> googleLogin(HttpServletRequest request, @RequestBody GoogleLoginRequest googleLoginRequest)
|
| 158 |
throws Exception {
|
158 |
throws Exception {
|
| 159 |
String email = googleLoginProcessor.process(googleLoginRequest.getToken());
|
159 |
String email = googleLoginProcessor.process(googleLoginRequest.getToken());
|
| 160 |
return responseSender.ok(getAuthTokenMap(email));
|
160 |
return responseSender.ok(getAuthTokenMap(email));
|
| 161 |
}
|
161 |
}
|
| 162 |
|
162 |
|
| 163 |
private Map<String, Object> getAuthTokenMap(String email) throws Exception {
|
163 |
private Map<String, Object> getAuthTokenMap(String email) throws Exception {
|
| 164 |
String name = authService.getNameByEmailId(email);
|
164 |
String name = authService.getNameByEmailId(email);
|
| 165 |
|
165 |
|
| 166 |
Map<String, Object> responseMap = new HashMap<>(2);
|
166 |
Map<String, Object> responseMap = new HashMap<>(2);
|
| 167 |
LOGGER.info("User Name from getNameByEmailId({}) is {}", email, name);
|
167 |
LOGGER.info("User Name from getNameByEmailId({}) is {}", email, name);
|
| 168 |
if (name != null) {
|
168 |
if (name != null) {
|
| 169 |
User registeredUser = null;
|
169 |
User registeredUser = null;
|
| 170 |
AuthUser authUser = authRepository.selectByGmailId(email);
|
170 |
AuthUser authUser = authRepository.selectByGmailId(email);
|
| 171 |
if (authUser != null) {
|
171 |
if (authUser != null) {
|
| 172 |
registeredUser = userRepository.selectByEmailId(authUser.getEmailId());
|
172 |
registeredUser = userRepository.selectByEmailId(authUser.getEmailId());
|
| 173 |
} else if (promoterRepository.selectMappedByEmailId(email) != null) {
|
173 |
} else if (promoterRepository.selectMappedByEmailId(email) != null) {
|
| 174 |
Promoter promoter = promoterRepository.selectMappedByEmailId(email);
|
174 |
Promoter promoter = promoterRepository.selectMappedByEmailId(email);
|
| 175 |
int userId = userAccountRepository.selectUserIdByRetailerId(promoter.getRetailerId());
|
175 |
int userId = userAccountRepository.selectUserIdByRetailerId(promoter.getRetailerId());
|
| 176 |
registeredUser = userRepository.selectById(userId);
|
176 |
registeredUser = userRepository.selectById(userId);
|
| 177 |
} else if (userRepository.isExistBySecondryEmailId(email)) {
|
177 |
} else if (userRepository.isExistBySecondryEmailId(email)) {
|
| 178 |
registeredUser = userRepository.selectBySecondryEmailId(email);
|
178 |
registeredUser = userRepository.selectBySecondryEmailId(email);
|
| 179 |
}
|
179 |
}
|
| 180 |
LOGGER.info("4");
|
180 |
LOGGER.info("4");
|
| 181 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(registeredUser.getId());
|
181 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(registeredUser.getId());
|
| 182 |
String[] roleTypes = new String[roleIds.size()];
|
182 |
String[] roleTypes = new String[roleIds.size()];
|
| 183 |
int index = 0;
|
183 |
int index = 0;
|
| 184 |
for (int roleId : roleIds) {
|
184 |
for (int roleId : roleIds) {
|
| 185 |
roleTypes[index++] = String.valueOf(roleId);
|
185 |
roleTypes[index++] = String.valueOf(roleId);
|
| 186 |
}
|
186 |
}
|
| 187 |
int retailerId;
|
187 |
int retailerId;
|
| 188 |
try {
|
188 |
try {
|
| 189 |
retailerId = userAccountRepository.selectRetailerIdByUserId(registeredUser.getId());
|
189 |
retailerId = userAccountRepository.selectRetailerIdByUserId(registeredUser.getId());
|
| 190 |
} catch (Exception e) {
|
190 |
} catch (Exception e) {
|
| 191 |
Set<Integer> authUserPartnerSet = csService.getAuthUserPartnerIdMapping().get(authUser.getEmailId());
|
191 |
Set<Integer> authUserPartnerSet = csService.getAuthUserPartnerIdMapping().get(authUser.getEmailId());
|
| 192 |
if (authUserPartnerSet != null && authUserPartnerSet.size() > 0) {
|
192 |
if (authUserPartnerSet != null && authUserPartnerSet.size() > 0) {
|
| 193 |
retailerId = authUserPartnerSet.stream().findFirst().get();
|
193 |
retailerId = authUserPartnerSet.stream().findFirst().get();
|
| 194 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(retailerId);
|
194 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(retailerId);
|
| 195 |
retailerId = ProfitMandiConstants.WAREHOUSE_NSSPL_PARTNER_MAP.get(fs.getWarehouseId());
|
195 |
retailerId = ProfitMandiConstants.WAREHOUSE_NSSPL_PARTNER_MAP.get(fs.getWarehouseId());
|
| 196 |
} else {
|
196 |
} else {
|
| 197 |
com.spice.profitmandi.dao.entity.user.User user = userUserRepository
|
197 |
com.spice.profitmandi.dao.entity.user.User user = userUserRepository
|
| 198 |
.selectByEmailId(Utils.SYSTEM_PARTNER);
|
198 |
.selectByEmailId(Utils.SYSTEM_PARTNER);
|
| 199 |
retailerId = user.getId();
|
199 |
retailerId = user.getId();
|
| 200 |
}
|
200 |
}
|
| 201 |
}
|
201 |
}
|
| 202 |
responseMap.put(ProfitMandiConstants.TOKEN,
|
202 |
responseMap.put(ProfitMandiConstants.TOKEN,
|
| 203 |
JWTUtil.create(email, registeredUser.getId(), retailerId, roleTypes));
|
203 |
JWTUtil.create(email, registeredUser.getId(), retailerId, roleTypes));
|
| 204 |
LOGGER.info("Param value for email, registeredUser.getId(), retailerId, roleTypes are {}, {}, {} and {}",
|
204 |
LOGGER.info("Param value for email, registeredUser.getId(), retailerId, roleTypes are {}, {}, {} and {}",
|
| 205 |
email, registeredUser.getId(), retailerId, Arrays.asList(roleTypes));
|
205 |
email, registeredUser.getId(), retailerId, Arrays.asList(roleTypes));
|
| 206 |
responseMap.put(ProfitMandiConstants.REGISTERED, true);
|
206 |
responseMap.put(ProfitMandiConstants.REGISTERED, true);
|
| 207 |
return responseMap;
|
207 |
return responseMap;
|
| 208 |
}
|
208 |
}
|
| 209 |
|
209 |
|
| 210 |
User user = null;
|
210 |
User user = null;
|
| 211 |
try {
|
211 |
try {
|
| 212 |
user = userRepository.selectByEmailId(email);
|
212 |
user = userRepository.selectByEmailId(email);
|
| 213 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
213 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
| 214 |
|
214 |
|
| 215 |
}
|
215 |
}
|
| 216 |
if (user == null) {
|
216 |
if (user == null) {
|
| 217 |
try {
|
217 |
try {
|
| 218 |
user = userRepository.selectByEmailId(email);
|
218 |
user = userRepository.selectByEmailId(email);
|
| 219 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
219 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
| 220 |
responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(email));
|
220 |
responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(email));
|
| 221 |
responseMap.put(ProfitMandiConstants.REGISTERED, false);
|
221 |
responseMap.put(ProfitMandiConstants.REGISTERED, false);
|
| 222 |
}
|
222 |
}
|
| 223 |
} else {
|
223 |
} else {
|
| 224 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
|
224 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
|
| 225 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
|
225 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
|
| 226 |
String[] roleTypes = new String[roleIds.size()];
|
226 |
String[] roleTypes = new String[roleIds.size()];
|
| 227 |
int index = 0;
|
227 |
int index = 0;
|
| 228 |
for (int roleId : roleIds) {
|
228 |
for (int roleId : roleIds) {
|
| 229 |
roleTypes[index++] = String.valueOf(roleId);
|
229 |
roleTypes[index++] = String.valueOf(roleId);
|
| 230 |
}
|
230 |
}
|
| 231 |
responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(user.getId(), retailerId, roleTypes));
|
231 |
responseMap.put(ProfitMandiConstants.TOKEN, JWTUtil.create(user.getId(), retailerId, roleTypes));
|
| 232 |
responseMap.put(ProfitMandiConstants.REGISTERED, true);
|
232 |
responseMap.put(ProfitMandiConstants.REGISTERED, true);
|
| 233 |
}
|
233 |
}
|
| 234 |
|
234 |
|
| 235 |
return responseMap;
|
235 |
return responseMap;
|
| 236 |
}
|
236 |
}
|
| 237 |
|
237 |
|
| 238 |
@RequestMapping(value = "/store/token/{storeCode}", method = RequestMethod.GET)
|
238 |
@RequestMapping(value = "/store/token/{storeCode}", method = RequestMethod.GET)
|
| 239 |
public ResponseEntity<?> googleLogin(HttpServletRequest request, @PathVariable String storeCode)
|
239 |
public ResponseEntity<?> googleLogin(HttpServletRequest request, @PathVariable String storeCode)
|
| 240 |
throws ProfitMandiBusinessException {
|
240 |
throws ProfitMandiBusinessException {
|
| 241 |
LOGGER.info("StoreCode {}", storeCode);
|
241 |
LOGGER.info("StoreCode {}", storeCode);
|
| 242 |
return responseSender.ok(googleLoginProcessor.processStore(storeCode));
|
242 |
return responseSender.ok(googleLoginProcessor.processStore(storeCode));
|
| 243 |
}
|
243 |
}
|
| 244 |
|
244 |
|
| 245 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_TOKEN_IS_EXPIRED, method = RequestMethod.GET)
|
245 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_TOKEN_IS_EXPIRED, method = RequestMethod.GET)
|
| 246 |
public ResponseEntity<?> tokenIsExpired(HttpServletRequest request, @RequestParam(name = "token") String token)
|
246 |
public ResponseEntity<?> tokenIsExpired(HttpServletRequest request, @RequestParam(name = "token") String token)
|
| 247 |
throws ProfitMandiBusinessException {
|
247 |
throws ProfitMandiBusinessException {
|
| 248 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
248 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 249 |
return responseSender.ok(JWTUtil.isExpired(token));
|
249 |
return responseSender.ok(JWTUtil.isExpired(token));
|
| 250 |
}
|
250 |
}
|
| 251 |
|
251 |
|
| 252 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_DETAIL_BY_TOKEN, method = RequestMethod.GET)
|
252 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_DETAIL_BY_TOKEN, method = RequestMethod.GET)
|
| 253 |
@ApiImplicitParams({
|
253 |
@ApiImplicitParams({
|
| 254 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
254 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 255 |
public ResponseEntity<?> tokenInfo(HttpServletRequest request) throws Throwable {
|
255 |
public ResponseEntity<?> tokenInfo(HttpServletRequest request) throws Throwable {
|
| 256 |
Map<String, Object> responseMap = new HashMap<>();
|
256 |
Map<String, Object> responseMap = new HashMap<>();
|
| 257 |
UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
|
257 |
UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
|
| 258 |
LOGGER.info("userinfo1 {}", userInfo);
|
258 |
LOGGER.info("userinfo1 {}", userInfo);
|
| 259 |
User user = null;
|
259 |
User user = null;
|
| 260 |
if (userInfo.getUserId() > -1) {
|
260 |
if (userInfo.getUserId() > -1) {
|
| 261 |
user = userRepository.selectById(userInfo.getUserId());
|
261 |
user = userRepository.selectById(userInfo.getUserId());
|
| 262 |
String city = user.getCity();
|
262 |
String city = user.getCity();
|
| 263 |
|
263 |
|
| 264 |
if (!(userInfo.getEmail() == null || user.getEmailId().indexOf("@smartdukaan.com") == -1)) {
|
264 |
if (!(userInfo.getEmail() == null || user.getEmailId().indexOf("@smartdukaan.com") == -1)) {
|
| 265 |
String userName = null;
|
265 |
String userName = null;
|
| 266 |
if (user.getSecondryEmailId() != null && user.getSecondryEmailId().equals(userInfo.getEmail())) {
|
266 |
if (user.getSecondryEmailId() != null && user.getSecondryEmailId().equals(userInfo.getEmail())) {
|
| 267 |
|
267 |
|
| 268 |
userName = user.getFirstName() + " " + user.getLastName();
|
268 |
userName = user.getFirstName() + " " + user.getLastName();
|
| 269 |
} else {
|
269 |
} else {
|
| 270 |
AuthUser authUser = authRepository.selectByGmailId(userInfo.getEmail());
|
270 |
AuthUser authUser = authRepository.selectByGmailId(userInfo.getEmail());
|
| 271 |
LOGGER.info("authUser {}", authUser);
|
271 |
LOGGER.info("authUser {}", authUser);
|
| 272 |
if (authUser == null || !authUser.isActive()) {
|
272 |
if (authUser == null || !authUser.isActive()) {
|
| 273 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
|
273 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
|
| 274 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
274 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
| 275 |
return responseSender.ok(responseMap);
|
275 |
return responseSender.ok(responseMap);
|
| 276 |
}
|
276 |
}
|
| 277 |
userName = authUser.getName();
|
277 |
userName = authUser.getName();
|
| 278 |
}
|
278 |
}
|
| 279 |
responseMap.put(ProfitMandiConstants.USER_ID, userInfo.getUserId());
|
279 |
responseMap.put(ProfitMandiConstants.USER_ID, userInfo.getUserId());
|
| 280 |
responseMap.put(ProfitMandiConstants.USER_NAME, userName);
|
280 |
responseMap.put(ProfitMandiConstants.USER_NAME, userName);
|
| 281 |
responseMap.put(ProfitMandiConstants.USER_STATUS, "fofoAssociate");
|
281 |
responseMap.put(ProfitMandiConstants.USER_STATUS, "fofoAssociate");
|
| 282 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
282 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
| 283 |
responseMap.put("storeUrl", "");
|
283 |
responseMap.put("storeUrl", "");
|
| 284 |
return responseSender.ok(responseMap);
|
284 |
return responseSender.ok(responseMap);
|
| 285 |
}
|
285 |
}
|
| 286 |
} else {
|
286 |
} else {
|
| 287 |
try {
|
287 |
try {
|
| 288 |
|
288 |
|
| 289 |
LOGGER.info("userinfo4 {}", userInfo);
|
289 |
LOGGER.info("userinfo4 {}", userInfo);
|
| 290 |
user = userRepository.selectByEmailId(userInfo.getEmail());
|
290 |
user = userRepository.selectByEmailId(userInfo.getEmail());
|
| 291 |
} catch (ProfitMandiBusinessException e1) {
|
291 |
} catch (ProfitMandiBusinessException e1) {
|
| 292 |
}
|
292 |
}
|
| 293 |
if (user == null) {
|
293 |
if (user == null) {
|
| 294 |
try {
|
294 |
try {
|
| 295 |
LOGGER.info("userinfo8 {}", userInfo);
|
295 |
LOGGER.info("userinfo8 {}", userInfo);
|
| 296 |
user = userRepository.selectBySecondryEmailId(userInfo.getEmail());
|
296 |
user = userRepository.selectBySecondryEmailId(userInfo.getEmail());
|
| 297 |
} catch (ProfitMandiBusinessException e1) {
|
297 |
} catch (ProfitMandiBusinessException e1) {
|
| 298 |
LOGGER.info("Uneregistered user", userInfo.getEmail());
|
298 |
LOGGER.info("Uneregistered user", userInfo.getEmail());
|
| 299 |
}
|
299 |
}
|
| 300 |
}
|
300 |
}
|
| 301 |
}
|
301 |
}
|
| 302 |
if (user != null) {
|
302 |
if (user != null) {
|
| 303 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
|
303 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
|
| 304 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, user.getEmailId());
|
304 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, user.getEmailId());
|
| 305 |
responseMap.put(ProfitMandiConstants.USER_ID, user.getId());
|
305 |
responseMap.put(ProfitMandiConstants.USER_ID, user.getId());
|
| 306 |
responseMap.put(ProfitMandiConstants.USER_NAME, user.getFirstName() + " " + user.getLastName());
|
306 |
responseMap.put(ProfitMandiConstants.USER_NAME, user.getFirstName() + " " + user.getLastName());
|
| 307 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
|
307 |
List<Integer> roleIds = userRoleRepository.selectRoleIdsByUserId(user.getId());
|
| 308 |
// LOGGER.info("userRoles {} ", userRoles);
|
308 |
// LOGGER.info("userRoles {} ", userRoles);
|
| 309 |
|
309 |
|
| 310 |
// generate new token if roles have been updated
|
310 |
// generate new token if roles have been updated
|
| 311 |
if (userInfo.getRoleIds() == null || roleIds.size() != userInfo.getRoleIds().size()) {
|
311 |
if (userInfo.getRoleIds() == null || roleIds.size() != userInfo.getRoleIds().size()) {
|
| 312 |
String[] roleIdStrings = new String[roleIds.size()];
|
312 |
String[] roleIdStrings = new String[roleIds.size()];
|
| 313 |
int index = 0;
|
313 |
int index = 0;
|
| 314 |
for (int roleId : roleIds) {
|
314 |
for (int roleId : roleIds) {
|
| 315 |
roleIdStrings[index++] = String.valueOf(roleId);
|
315 |
roleIdStrings[index++] = String.valueOf(roleId);
|
| 316 |
}
|
316 |
}
|
| 317 |
String newToken = JWTUtil.create(user.getId(), retailerId, roleIdStrings);
|
317 |
String newToken = JWTUtil.create(user.getId(), retailerId, roleIdStrings);
|
| 318 |
responseMap.put("newAuthToken", newToken);
|
318 |
responseMap.put("newAuthToken", newToken);
|
| 319 |
}
|
319 |
}
|
| 320 |
// if user is retailer
|
320 |
// if user is retailer
|
| 321 |
Set<Integer> roleIdsSet = new HashSet<Integer>(roleIds);
|
321 |
Set<Integer> roleIdsSet = new HashSet<Integer>(roleIds);
|
| 322 |
if (roleManager.isRetailer(roleIdsSet)) {
|
322 |
if (roleManager.isRetailer(roleIdsSet)) {
|
| 323 |
UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
|
323 |
UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
|
| 324 |
Retailer retailer = retailerRepository.selectById(uc.getUserId());
|
324 |
Retailer retailer = retailerRepository.selectById(uc.getUserId());
|
| 325 |
com.spice.profitmandi.dao.entity.user.User saholicUser = userUserRepository.selectById(uc.getUserId());
|
325 |
com.spice.profitmandi.dao.entity.user.User saholicUser = userUserRepository.selectById(uc.getUserId());
|
| 326 |
if (saholicUser.getAddressId() != null) {
|
326 |
if (saholicUser.getAddressId() != null) {
|
| 327 |
Address address = addressRepository.selectById(saholicUser.getAddressId());
|
327 |
Address address = addressRepository.selectById(saholicUser.getAddressId());
|
| 328 |
responseMap.put(ProfitMandiConstants.ADDRESS, address);
|
328 |
responseMap.put(ProfitMandiConstants.ADDRESS, address);
|
| 329 |
}
|
329 |
}
|
| 330 |
// if retailer is activated 1 then verified retailer
|
330 |
// if retailer is activated 1 then verified retailer
|
| 331 |
// else if migrated is 1 then old retailer
|
331 |
// else if migrated is 1 then old retailer
|
| 332 |
// also lets incoporte old process i.e is user is activated then also retailer
|
332 |
// also lets incoporte old process i.e is user is activated then also retailer
|
| 333 |
// is verified retailer
|
333 |
// is verified retailer
|
| 334 |
// else retailer is not verifed
|
334 |
// else retailer is not verifed
|
| 335 |
if (retailer.isActive() || user.isActivated()) {
|
335 |
if (retailer.isActive() || user.isActivated()) {
|
| 336 |
if (roleManager.isPartner(roleIdsSet)) {
|
336 |
if (roleManager.isPartner(roleIdsSet)) {
|
| 337 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.FOFO.getValue());
|
337 |
FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(saholicUser.getId());
|
| 338 |
responseMap.put("storeUrl", retailerService.getAllFofoRetailerIdUrlMap().get(uc.getUserId()));
|
338 |
if (fofoStore.isActive()) {
|
| 339 |
responseMap.put("timelineStatus", this.getTimeLineStatus(uc.getUserId()));
|
339 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.FOFO.getValue());
|
| 340 |
} else {
|
340 |
responseMap.put("storeUrl", retailerService.getAllFofoRetailerIdUrlMap().get(uc.getUserId()));
|
| 341 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
|
341 |
responseMap.put("timelineStatus", this.getTimeLineStatus(uc.getUserId()));
|
| 342 |
}
|
342 |
} else {
|
| 343 |
} else if (retailer.isMigrated()) {
|
343 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
|
| 344 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.RETAILER.getValue());
|
344 |
}
|
| 345 |
} else {
|
345 |
} else {
|
| 346 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_VERIFIED_RETAILER.getValue());
|
346 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.VERIFIED_RETAILER.getValue());
|
| 347 |
}
|
347 |
}
|
| 348 |
} else if (roleManager.isUser(roleIdsSet)) {
|
348 |
} else if (retailer.isMigrated()) {
|
| 349 |
responseMap.put("userInfo", getRegisteredUserInfo(user));
|
349 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.RETAILER.getValue());
|
| 350 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.REGISTERED.getValue());
|
350 |
} else {
|
| 351 |
}
|
351 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_VERIFIED_RETAILER.getValue());
|
| 352 |
} else {
|
352 |
}
|
| 353 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
|
353 |
} else if (roleManager.isUser(roleIdsSet)) {
|
| 354 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
354 |
responseMap.put("userInfo", getRegisteredUserInfo(user));
|
| 355 |
}
|
355 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.REGISTERED.getValue());
|
| 356 |
|
356 |
}
|
| 357 |
return responseSender.ok(responseMap);
|
357 |
} else {
|
| 358 |
}
|
358 |
responseMap.put(ProfitMandiConstants.USER_STATUS, UserStatus.NOT_REGISTERED.getValue());
|
| 359 |
|
359 |
responseMap.put(ProfitMandiConstants.EMAIL_ID, userInfo.getEmail());
|
| 360 |
@Autowired
|
360 |
}
|
| 361 |
FofoStoreRepository fofoStoreRepository;
|
361 |
|
| 362 |
@Autowired
|
362 |
return responseSender.ok(responseMap);
|
| 363 |
PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
|
363 |
}
|
| 364 |
@Autowired
|
364 |
|
| 365 |
StoreTimelineTatService storeTimelineTatService;
|
365 |
@Autowired
|
| 366 |
|
366 |
FofoStoreRepository fofoStoreRepository;
|
| 367 |
private boolean getTimeLineStatus(int fofoId) throws ProfitMandiBusinessException {
|
367 |
@Autowired
|
| 368 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);
|
368 |
PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
|
| 369 |
PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
|
369 |
@Autowired
|
| 370 |
boolean status = true;
|
370 |
StoreTimelineTatService storeTimelineTatService;
|
| 371 |
if (partnerOnBoardingPanel != null) {
|
371 |
|
| 372 |
|
372 |
private boolean getTimeLineStatus(int fofoId) throws ProfitMandiBusinessException {
|
| 373 |
status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
|
373 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);
|
| 374 |
}
|
374 |
PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
|
| 375 |
|
375 |
boolean status = true;
|
| 376 |
LOGGER.info("status" + status);
|
376 |
if (partnerOnBoardingPanel != null) {
|
| 377 |
return status;
|
377 |
|
| 378 |
}
|
378 |
status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
|
| 379 |
|
379 |
}
|
| 380 |
private RegisteredUserInfo getRegisteredUserInfo(User user) throws Throwable {
|
380 |
|
| 381 |
RegisteredUserInfo ri = new RegisteredUserInfo();
|
381 |
LOGGER.info("status" + status);
|
| 382 |
ri.setCity(user.getCity());
|
382 |
return status;
|
| 383 |
ri.setFirstName(user.getFirstName());
|
383 |
}
|
| 384 |
ri.setLastName(user.getLastName());
|
384 |
|
| 385 |
ri.setPhone(user.getMobileNumber());
|
385 |
private RegisteredUserInfo getRegisteredUserInfo(User user) throws Throwable {
|
| 386 |
ri.setPinCode(user.getPinCode());
|
386 |
RegisteredUserInfo ri = new RegisteredUserInfo();
|
| 387 |
ri.setState(user.getState());
|
387 |
ri.setCity(user.getCity());
|
| 388 |
return ri;
|
388 |
ri.setFirstName(user.getFirstName());
|
| 389 |
}
|
389 |
ri.setLastName(user.getLastName());
|
| 390 |
|
390 |
ri.setPhone(user.getMobileNumber());
|
| 391 |
@RequestMapping(value = ProfitMandiConstants.URL_USER, method = RequestMethod.POST)
|
391 |
ri.setPinCode(user.getPinCode());
|
| 392 |
@ApiImplicitParams({
|
392 |
ri.setState(user.getState());
|
| 393 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
393 |
return ri;
|
| 394 |
public ResponseEntity<?> createUser(HttpServletRequest request, @RequestBody UserRequest userRequest)
|
394 |
}
|
| 395 |
throws ProfitMandiBusinessException {
|
395 |
|
| 396 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
396 |
@RequestMapping(value = ProfitMandiConstants.URL_USER, method = RequestMethod.POST)
|
| 397 |
User user = new User();
|
397 |
@ApiImplicitParams({
|
| 398 |
user.setFirstName(userRequest.getFirstName());
|
398 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 399 |
user.setLastName(userRequest.getLastName());
|
399 |
public ResponseEntity<?> createUser(HttpServletRequest request, @RequestBody UserRequest userRequest)
|
| 400 |
user.setCity(userRequest.getCity());
|
400 |
throws ProfitMandiBusinessException {
|
| 401 |
user.setPinCode(Integer.valueOf(userRequest.getPinCode()));
|
401 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 402 |
user.setState(userRequest.getState());
|
402 |
User user = new User();
|
| 403 |
user.setMobileNumber(userRequest.getMobieNumber());
|
403 |
user.setFirstName(userRequest.getFirstName());
|
| 404 |
user.setEmailId(userRequest.getEmailId());
|
404 |
user.setLastName(userRequest.getLastName());
|
| 405 |
user.setUsername("");
|
405 |
user.setCity(userRequest.getCity());
|
| 406 |
user.setPassword("");
|
406 |
user.setPinCode(Integer.valueOf(userRequest.getPinCode()));
|
| 407 |
user.setMobile_verified(false);
|
407 |
user.setState(userRequest.getState());
|
| 408 |
user.setReferral_url("");
|
408 |
user.setMobileNumber(userRequest.getMobieNumber());
|
| 409 |
user.setGroup_id(1);
|
409 |
user.setEmailId(userRequest.getEmailId());
|
| 410 |
user.setStatus(1);
|
410 |
user.setUsername("");
|
| 411 |
user.setActivated(false);
|
411 |
user.setPassword("");
|
| 412 |
user.setCreateTimestamp(LocalDateTime.now());
|
412 |
user.setMobile_verified(false);
|
| 413 |
user.setUpdateTimestamp(LocalDateTime.now());
|
413 |
user.setReferral_url("");
|
| 414 |
userRepository.persist(user);
|
414 |
user.setGroup_id(1);
|
| 415 |
Role role = roleRepository.selectByName(RoleType.USER.toString());
|
415 |
user.setStatus(1);
|
| 416 |
UserRole userRole = new UserRole();
|
416 |
user.setActivated(false);
|
| 417 |
userRole.setRoleId(role.getId());
|
417 |
user.setCreateTimestamp(LocalDateTime.now());
|
| 418 |
userRole.setUserId(user.getId());
|
418 |
user.setUpdateTimestamp(LocalDateTime.now());
|
| 419 |
userRoleRepository.persist(userRole);
|
419 |
userRepository.persist(user);
|
| 420 |
return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1000"));
|
420 |
Role role = roleRepository.selectByName(RoleType.USER.toString());
|
| 421 |
|
421 |
UserRole userRole = new UserRole();
|
| 422 |
}
|
422 |
userRole.setRoleId(role.getId());
|
| 423 |
|
423 |
userRole.setUserId(user.getId());
|
| 424 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ID, method = RequestMethod.GET)
|
424 |
userRoleRepository.persist(userRole);
|
| 425 |
public ResponseEntity<?> getById(HttpServletRequest request, @RequestParam(name = "id") int id)
|
425 |
return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1000"));
|
| 426 |
throws ProfitMandiBusinessException {
|
426 |
|
| 427 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
427 |
}
|
| 428 |
return responseSender.ok(userRepository.selectById(id));
|
428 |
|
| 429 |
}
|
429 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ID, method = RequestMethod.GET)
|
| 430 |
|
430 |
public ResponseEntity<?> getById(HttpServletRequest request, @RequestParam(name = "id") int id)
|
| 431 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_MOBILE_NUMBER, method = RequestMethod.GET)
|
431 |
throws ProfitMandiBusinessException {
|
| 432 |
public ResponseEntity<?> getByMobileNumber(HttpServletRequest request,
|
432 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 433 |
@RequestParam(name = "mobileNumber") String mobileNumber) throws ProfitMandiBusinessException {
|
433 |
return responseSender.ok(userRepository.selectById(id));
|
| 434 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
434 |
}
|
| 435 |
return responseSender.ok(userRepository.selectByMobileNumber(mobileNumber));
|
435 |
|
| 436 |
}
|
436 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_MOBILE_NUMBER, method = RequestMethod.GET)
|
| 437 |
|
437 |
public ResponseEntity<?> getByMobileNumber(HttpServletRequest request,
|
| 438 |
@ApiImplicitParams({
|
438 |
@RequestParam(name = "mobileNumber") String mobileNumber) throws ProfitMandiBusinessException {
|
| 439 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
439 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 440 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ACTIVATE, method = RequestMethod.POST)
|
440 |
return responseSender.ok(userRepository.selectByMobileNumber(mobileNumber));
|
| 441 |
public ResponseEntity<?> activateUser(HttpServletRequest request,
|
441 |
}
|
| 442 |
@RequestParam(name = "activationCode") String activationCode) throws Throwable {
|
442 |
|
| 443 |
int userId = (int) request.getAttribute("userId");
|
443 |
@ApiImplicitParams({
|
| 444 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
444 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 445 |
return responseSender.ok(userService.updateActivation(userId, uc.getUserId(), activationCode));
|
445 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ACTIVATE, method = RequestMethod.POST)
|
| 446 |
}
|
446 |
public ResponseEntity<?> activateUser(HttpServletRequest request,
|
| 447 |
|
447 |
@RequestParam(name = "activationCode") String activationCode) throws Throwable {
|
| 448 |
/*
|
448 |
int userId = (int) request.getAttribute("userId");
|
| 449 |
* @ApiImplicitParams({
|
449 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
| 450 |
*
|
450 |
return responseSender.ok(userService.updateActivation(userId, uc.getUserId(), activationCode));
|
| 451 |
* @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true,
|
451 |
}
|
| 452 |
* dataType = "string", paramType = "header") })
|
452 |
|
| 453 |
*
|
453 |
/*
|
| 454 |
* @RequestMapping(value = ProfitMandiConstants.URL_USER_NOTIFICATIONS, method =
|
454 |
* @ApiImplicitParams({
|
| 455 |
* RequestMethod.GET) public ResponseEntity<?>
|
455 |
*
|
| 456 |
* getNofitications(HttpServletRequest request,
|
456 |
* @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true,
|
| 457 |
*
|
457 |
* dataType = "string", paramType = "header") })
|
| 458 |
* @RequestParam(name = "androidId") String androidId, @RequestParam(name =
|
458 |
*
|
| 459 |
* "pageNumber") int pageNumber,
|
459 |
* @RequestMapping(value = ProfitMandiConstants.URL_USER_NOTIFICATIONS, method =
|
| 460 |
*
|
460 |
* RequestMethod.GET) public ResponseEntity<?>
|
| 461 |
* @RequestParam(name = "pageSize") int pageSize) throws
|
461 |
* getNofitications(HttpServletRequest request,
|
| 462 |
* ProfitMandiBusinessException { int userId = (int)
|
462 |
*
|
| 463 |
* request.getAttribute("userId"); String restResponse = null; Map<String,
|
463 |
* @RequestParam(name = "androidId") String androidId, @RequestParam(name =
|
| 464 |
* String> params = new HashMap<>();
|
464 |
* "pageNumber") int pageNumber,
|
| 465 |
*
|
465 |
*
|
| 466 |
* String uri = "/getAllNotifications"; params.put("user_id", userId + "");
|
466 |
* @RequestParam(name = "pageSize") int pageSize) throws
|
| 467 |
* params.put("android_id", androidId); params.put("limit", pageSize + "");
|
467 |
* ProfitMandiBusinessException { int userId = (int)
|
| 468 |
* params.put("offset", "" + ((pageNumber - 1) * pageSize)); try { restResponse
|
468 |
* request.getAttribute("userId"); String restResponse = null; Map<String,
|
| 469 |
* = restClient.get(SchemeType.HTTP, nodeHost, nodePort, uri, params); } catch
|
469 |
* String> params = new HashMap<>();
|
| 470 |
* (HttpHostConnectException e) { throw new ProfitMandiBusinessException("", "",
|
470 |
*
|
| 471 |
* "Could not Connect to host"); }
|
471 |
* String uri = "/getAllNotifications"; params.put("user_id", userId + "");
|
| 472 |
*
|
472 |
* params.put("android_id", androidId); params.put("limit", pageSize + "");
|
| 473 |
* JsonArray result_json = Json.parse(restResponse).asArray();
|
473 |
* params.put("offset", "" + ((pageNumber - 1) * pageSize)); try { restResponse
|
| 474 |
*
|
474 |
* = restClient.get(SchemeType.HTTP, nodeHost, nodePort, uri, params); } catch
|
| 475 |
* List<Notification> notifications = new ArrayList<>();
|
475 |
* (HttpHostConnectException e) { throw new ProfitMandiBusinessException("", "",
|
| 476 |
*
|
476 |
* "Could not Connect to host"); }
|
| 477 |
* for (JsonValue j : result_json) {
|
477 |
*
|
| 478 |
* notifications.add(toNotifiaction(j.asObject())); }
|
478 |
* JsonArray result_json = Json.parse(restResponse).asArray();
|
| 479 |
*
|
479 |
*
|
| 480 |
* return responseSender.ok(notifications); }
|
480 |
* List<Notification> notifications = new ArrayList<>();
|
| 481 |
*
|
481 |
*
|
| 482 |
* private Notification toNotifiaction(JsonObject jsonObject) { Notification n =
|
482 |
* for (JsonValue j : result_json) {
|
| 483 |
* (Notification) (new Gson().fromJson(jsonObject.toString(),
|
483 |
* notifications.add(toNotifiaction(j.asObject())); }
|
| 484 |
* Notification.class)); if (n.getStatus().equals("opened") ||
|
484 |
*
|
| 485 |
* n.getStatus().equals("referrer") || n.getStatus().equals("seen")) {
|
485 |
* return responseSender.ok(notifications); }
|
| 486 |
* n.setSeen(true); } return n; }
|
486 |
*
|
| 487 |
*/
|
487 |
* private Notification toNotifiaction(JsonObject jsonObject) { Notification n =
|
| 488 |
|
488 |
* (Notification) (new Gson().fromJson(jsonObject.toString(),
|
| 489 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_IS_EXIST_MOBILE_NUMBER, method = RequestMethod.GET)
|
489 |
* Notification.class)); if (n.getStatus().equals("opened") ||
|
| 490 |
public ResponseEntity<?> isMobileNumberExist(HttpServletRequest request,
|
490 |
* n.getStatus().equals("referrer") || n.getStatus().equals("seen")) {
|
| 491 |
@RequestParam(name = "mobileNumber") String mobileNumber) {
|
491 |
* n.setSeen(true); } return n; }
|
| 492 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
492 |
*/
|
| 493 |
return responseSender.ok(userRepository.isExistByMobileNumber(mobileNumber));
|
493 |
|
| 494 |
}
|
494 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_IS_EXIST_MOBILE_NUMBER, method = RequestMethod.GET)
|
| 495 |
|
495 |
public ResponseEntity<?> isMobileNumberExist(HttpServletRequest request,
|
| 496 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_EMAIL_ID, method = RequestMethod.GET)
|
496 |
@RequestParam(name = "mobileNumber") String mobileNumber) {
|
| 497 |
public ResponseEntity<?> getByEmailId(HttpServletRequest request, @RequestParam(name = "emailId") String emailId)
|
497 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 498 |
throws ProfitMandiBusinessException {
|
498 |
return responseSender.ok(userRepository.isExistByMobileNumber(mobileNumber));
|
| 499 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
499 |
}
|
| 500 |
User user = null;
|
500 |
|
| 501 |
try {
|
501 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_EMAIL_ID, method = RequestMethod.GET)
|
| 502 |
user = userRepository.selectByEmailId(emailId);
|
502 |
public ResponseEntity<?> getByEmailId(HttpServletRequest request, @RequestParam(name = "emailId") String emailId)
|
| 503 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
503 |
throws ProfitMandiBusinessException {
|
| 504 |
user = userRepository.selectBySecondryEmailId(emailId);
|
504 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 505 |
}
|
505 |
User user = null;
|
| 506 |
return responseSender.ok(user);
|
506 |
try {
|
| 507 |
}
|
507 |
user = userRepository.selectByEmailId(emailId);
|
| 508 |
|
508 |
} catch (ProfitMandiBusinessException profitMandiBusinessException) {
|
| 509 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ROLE_ALL, method = RequestMethod.GET)
|
509 |
user = userRepository.selectBySecondryEmailId(emailId);
|
| 510 |
public ResponseEntity<?> getAllRoles(HttpServletRequest request, @RequestParam(name = "id") int id) {
|
510 |
}
|
| 511 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
511 |
return responseSender.ok(user);
|
| 512 |
return responseSender.ok(userRoleRepository.selectRolesByUserId(id));
|
512 |
}
|
| 513 |
}
|
513 |
|
| 514 |
|
514 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_ROLE_ALL, method = RequestMethod.GET)
|
| 515 |
@ApiImplicitParams({
|
515 |
public ResponseEntity<?> getAllRoles(HttpServletRequest request, @RequestParam(name = "id") int id) {
|
| 516 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
516 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 517 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID_AND_FOFO_STORE_CODE, method = RequestMethod.GET)
|
517 |
return responseSender.ok(userRoleRepository.selectRolesByUserId(id));
|
| 518 |
public ResponseEntity<?> getSecondryEmailAndStoreCode(HttpServletRequest request)
|
518 |
}
|
| 519 |
throws ProfitMandiBusinessException {
|
519 |
|
| 520 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
520 |
@ApiImplicitParams({
|
| 521 |
int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
|
521 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 522 |
return responseSender.ok(userService.getEmailsAndFofoStoreCodeByUserId(userId));
|
522 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID_AND_FOFO_STORE_CODE, method = RequestMethod.GET)
|
| 523 |
}
|
523 |
public ResponseEntity<?> getSecondryEmailAndStoreCode(HttpServletRequest request)
|
| 524 |
|
524 |
throws ProfitMandiBusinessException {
|
| 525 |
@ApiImplicitParams({
|
525 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 526 |
@ApiImplicitParam(name = "Auth-Token", value = "-Token", required = true, dataType = "string", paramType = "header") })
|
526 |
int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
|
| 527 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID, method = RequestMethod.PUT)
|
527 |
return responseSender.ok(userService.getEmailsAndFofoStoreCodeByUserId(userId));
|
| 528 |
public ResponseEntity<?> updateSecondryEmailId(HttpServletRequest request,
|
528 |
}
|
| 529 |
@RequestParam(name = ProfitMandiConstants.SECONDRY_EMAIL_ID) String secondryEmailId) throws Throwable {
|
529 |
|
| 530 |
int userId = (int) request.getAttribute("userId");
|
530 |
@ApiImplicitParams({
|
| 531 |
User user = userRepository.selectById(userId);
|
531 |
@ApiImplicitParam(name = "Auth-Token", value = "-Token", required = true, dataType = "string", paramType = "header")})
|
| 532 |
user.setSecondryEmailId(secondryEmailId);
|
532 |
@RequestMapping(value = ProfitMandiConstants.URL_USER_SECONDRY_EMAIL_ID, method = RequestMethod.PUT)
|
| 533 |
userRepository.persist(user);
|
533 |
public ResponseEntity<?> updateSecondryEmailId(HttpServletRequest request,
|
| 534 |
return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1001"));
|
534 |
@RequestParam(name = ProfitMandiConstants.SECONDRY_EMAIL_ID) String secondryEmailId) throws Throwable {
|
| 535 |
}
|
535 |
int userId = (int) request.getAttribute("userId");
|
| 536 |
|
536 |
User user = userRepository.selectById(userId);
|
| 537 |
@RequestMapping(value = ProfitMandiConstants.URL_ADMIN_TOKEN, method = RequestMethod.POST)
|
537 |
user.setSecondryEmailId(secondryEmailId);
|
| 538 |
public ResponseEntity<?> getAdminToken(HttpServletRequest request,
|
538 |
userRepository.persist(user);
|
| 539 |
@RequestParam(name = "adminToken") String adminToken, @RequestParam(name = "emailId") String emailId)
|
539 |
return responseSender.ok(ResponseCodeHolder.getMessage("USR_OK_1001"));
|
| 540 |
throws Exception {
|
540 |
}
|
| 541 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
541 |
|
| 542 |
if (!adminToken.equals(validAdminToken)) {
|
542 |
@RequestMapping(value = ProfitMandiConstants.URL_ADMIN_TOKEN, method = RequestMethod.POST)
|
| 543 |
return responseSender.forbidden(null);
|
543 |
public ResponseEntity<?> getAdminToken(HttpServletRequest request,
|
| 544 |
}
|
544 |
@RequestParam(name = "adminToken") String adminToken, @RequestParam(name = "emailId") String emailId)
|
| 545 |
|
545 |
throws Exception {
|
| 546 |
return responseSender.ok(this.getAuthTokenMap(emailId));
|
546 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
| 547 |
|
547 |
if (!adminToken.equals(validAdminToken)) {
|
| 548 |
}
|
548 |
return responseSender.forbidden(null);
|
| 549 |
|
549 |
}
|
| 550 |
@RequestMapping(value = "/mobileappsettings")
|
550 |
|
| 551 |
public ResponseEntity<?> mobileAppSettings(HttpServletRequest request, @RequestParam(name = "t") int timestamp,
|
551 |
return responseSender.ok(this.getAuthTokenMap(emailId));
|
| 552 |
@RequestParam(name = "imeinumber") String imeinumber)
|
552 |
|
| 553 |
throws ProfitMandiBusinessException, ClientProtocolException, IOException {
|
553 |
}
|
| 554 |
|
554 |
|
| 555 |
final String uri = "http://192.168.158.89/mobileappsettings?t=" + timestamp + "&imeinumber=" + imeinumber;
|
555 |
@RequestMapping(value = "/mobileappsettings")
|
| 556 |
final String BASIC_AUTH = "Basic " + Base64.getEncoder().encodeToString("dtr:dtr18Feb2015".getBytes());
|
556 |
public ResponseEntity<?> mobileAppSettings(HttpServletRequest request, @RequestParam(name = "t") int timestamp,
|
| 557 |
Map<String, String> headers = new HashMap<>();
|
557 |
@RequestParam(name = "imeinumber") String imeinumber)
|
| 558 |
Map<String, String> params = new HashMap<>();
|
558 |
throws ProfitMandiBusinessException, ClientProtocolException, IOException {
|
| 559 |
headers.put("Authorization", BASIC_AUTH);
|
559 |
|
| 560 |
if (timestamp == 0) {
|
560 |
final String uri = "http://192.168.158.89/mobileappsettings?t=" + timestamp + "&imeinumber=" + imeinumber;
|
| 561 |
return responseSender.ok(OrderController.APP_SETTINGS);
|
561 |
final String BASIC_AUTH = "Basic " + Base64.getEncoder().encodeToString("dtr:dtr18Feb2015".getBytes());
|
| 562 |
} else {
|
562 |
Map<String, String> headers = new HashMap<>();
|
| 563 |
return responseSender.ok(OrderController.APP_SETTINGS_BLANK);
|
563 |
Map<String, String> params = new HashMap<>();
|
| 564 |
}
|
564 |
headers.put("Authorization", BASIC_AUTH);
|
| 565 |
}
|
565 |
if (timestamp == 0) {
|
| 566 |
|
566 |
return responseSender.ok(OrderController.APP_SETTINGS);
|
| 567 |
@RequestMapping(value = "/mobileappsettings1", method = RequestMethod.POST)
|
567 |
} else {
|
| 568 |
public ResponseEntity<?> mobileAppSettings1(HttpServletRequest request, @RequestParam(name = "t") int timestamp,
|
568 |
return responseSender.ok(OrderController.APP_SETTINGS_BLANK);
|
| 569 |
@RequestParam(name = "imeinumber") String imeinumber)
|
569 |
}
|
| 570 |
throws ProfitMandiBusinessException, ClientProtocolException, IOException {
|
570 |
}
|
| 571 |
LocalDateTime settingsLastUpdated = LocalDateTime.ofEpochSecond(timestamp, 0, ZoneOffset.ofHoursMinutes(5, 30));
|
571 |
|
| 572 |
List<MobileAppSetting> mobileAppSettings = mobileAppSettingsRepository.getSettingAftera(settingsLastUpdated);
|
572 |
@RequestMapping(value = "/mobileappsettings1", method = RequestMethod.POST)
|
| 573 |
|
573 |
public ResponseEntity<?> mobileAppSettings1(HttpServletRequest request, @RequestParam(name = "t") int timestamp,
|
| 574 |
List<MobileAppSettingsWrapper> mobileSettingsWrappersList = mobileAppSettings.stream()
|
574 |
@RequestParam(name = "imeinumber") String imeinumber)
|
| 575 |
.map(x -> new MobileAppSettingsWrapper(x)).collect(Collectors.toList());
|
575 |
throws ProfitMandiBusinessException, ClientProtocolException, IOException {
|
| 576 |
SettingsWrapper wrapper = new SettingsWrapper(mobileSettingsWrappersList);
|
576 |
LocalDateTime settingsLastUpdated = LocalDateTime.ofEpochSecond(timestamp, 0, ZoneOffset.ofHoursMinutes(5, 30));
|
| 577 |
|
577 |
List<MobileAppSetting> mobileAppSettings = mobileAppSettingsRepository.getSettingAftera(settingsLastUpdated);
|
| 578 |
LOGGER.info("Wrapper {}", wrapper);
|
578 |
|
| 579 |
return responseSender.ok(objectMapper.writeValueAsString(wrapper));
|
579 |
List<MobileAppSettingsWrapper> mobileSettingsWrappersList = mobileAppSettings.stream()
|
| 580 |
}
|
580 |
.map(x -> new MobileAppSettingsWrapper(x)).collect(Collectors.toList());
|
| 581 |
|
581 |
SettingsWrapper wrapper = new SettingsWrapper(mobileSettingsWrappersList);
|
| 582 |
@RequestMapping(value = "/getPartners", method = RequestMethod.GET)
|
582 |
|
| 583 |
@ApiImplicitParams({
|
583 |
LOGGER.info("Wrapper {}", wrapper);
|
| 584 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
584 |
return responseSender.ok(objectMapper.writeValueAsString(wrapper));
|
| 585 |
public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
|
585 |
}
|
| 586 |
@RequestParam(value = "offset") int offset, @RequestParam(value = "limit") int limit)
|
586 |
|
| 587 |
throws ProfitMandiBusinessException {
|
587 |
@RequestMapping(value = "/getPartners", method = RequestMethod.GET)
|
| 588 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
588 |
@ApiImplicitParams({
|
| 589 |
|
589 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 590 |
Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
|
590 |
public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
|
| 591 |
|
591 |
@RequestParam(value = "offset") int offset, @RequestParam(value = "limit") int limit)
|
| 592 |
Set<String> emails = storeGuyMap.get(authUser.getEmailId().toLowerCase());
|
592 |
throws ProfitMandiBusinessException {
|
| 593 |
LOGGER.info("emails" + emails);
|
593 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
| 594 |
List<User> users = userRepository.selectAllByEmails(new ArrayList<>(emails), offset, limit);
|
594 |
|
| 595 |
List<Partner> partners = new ArrayList<>();
|
595 |
Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
|
| 596 |
for (User user : users) {
|
596 |
|
| 597 |
|
597 |
Set<String> emails = storeGuyMap.get(authUser.getEmailId().toLowerCase());
|
| 598 |
UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
|
598 |
LOGGER.info("emails" + emails);
|
| 599 |
com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
|
599 |
List<User> users = userRepository.selectAllByEmails(new ArrayList<>(emails), offset, limit);
|
| 600 |
CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
|
600 |
List<Partner> partners = new ArrayList<>();
|
| 601 |
|
601 |
for (User user : users) {
|
| 602 |
Partner partner = new Partner();
|
602 |
|
| 603 |
partner.setBusinessName(customRetailer.getBusinessName());
|
603 |
UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
|
| 604 |
partner.setPartnerId(customRetailer.getPartnerId());
|
604 |
com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
|
| 605 |
partner.setCartId(customRetailer.getCartId());
|
605 |
CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
|
| 606 |
partner.setEmail(customRetailer.getEmail());
|
606 |
|
| 607 |
partner.setGstNumber(customRetailer.getGstNumber());
|
607 |
Partner partner = new Partner();
|
| 608 |
partner.setDisplayName(customRetailer.getDisplayName());
|
608 |
partner.setBusinessName(customRetailer.getBusinessName());
|
| 609 |
partner.setCity(customRetailer.getAddress().getCity());
|
609 |
partner.setPartnerId(customRetailer.getPartnerId());
|
| 610 |
partner.setUserId(user.getId());
|
610 |
partner.setCartId(customRetailer.getCartId());
|
| 611 |
partners.add(partner);
|
611 |
partner.setEmail(customRetailer.getEmail());
|
| 612 |
}
|
612 |
partner.setGstNumber(customRetailer.getGstNumber());
|
| 613 |
LOGGER.info("partners" + partners);
|
613 |
partner.setDisplayName(customRetailer.getDisplayName());
|
| 614 |
return responseSender.ok(partners);
|
614 |
partner.setCity(customRetailer.getAddress().getCity());
|
| 615 |
}
|
615 |
partner.setUserId(user.getId());
|
| 616 |
|
616 |
partners.add(partner);
|
| 617 |
@RequestMapping(value = "/user/refferal", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
617 |
}
|
| 618 |
@ApiImplicitParams({
|
618 |
LOGGER.info("partners" + partners);
|
| 619 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
619 |
return responseSender.ok(partners);
|
| 620 |
public ResponseEntity<?> RefferalUser(HttpServletRequest request,
|
620 |
}
|
| 621 |
@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
|
621 |
|
| 622 |
Refferal refferal = new Refferal();
|
622 |
@RequestMapping(value = "/user/refferal", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 623 |
refferal.setFirstName(createRefferalRequest.getFirstName());
|
623 |
@ApiImplicitParams({
|
| 624 |
refferal.setLastName(createRefferalRequest.getLastName());
|
624 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 625 |
refferal.setMobile(createRefferalRequest.getMobile());
|
625 |
public ResponseEntity<?> RefferalUser(HttpServletRequest request,
|
| 626 |
refferal.setState(createRefferalRequest.getState());
|
626 |
@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
|
| 627 |
refferal.setCity(createRefferalRequest.getCity());
|
627 |
Refferal refferal = new Refferal();
|
| 628 |
refferal.setCreatedTimestamp(LocalDateTime.now());
|
628 |
refferal.setFirstName(createRefferalRequest.getFirstName());
|
| 629 |
refferal.setUpdatedTimestamp(LocalDateTime.now());
|
629 |
refferal.setLastName(createRefferalRequest.getLastName());
|
| 630 |
refferal.setStatus(RefferalStatus.pending);
|
630 |
refferal.setMobile(createRefferalRequest.getMobile());
|
| 631 |
if (createRefferalRequest.isFofoAssociate()) {
|
631 |
refferal.setState(createRefferalRequest.getState());
|
| 632 |
AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
|
632 |
refferal.setCity(createRefferalRequest.getCity());
|
| 633 |
if (authUser == null) {
|
633 |
refferal.setCreatedTimestamp(LocalDateTime.now());
|
| 634 |
Promoter promoter = promoterRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
|
634 |
refferal.setUpdatedTimestamp(LocalDateTime.now());
|
| 635 |
refferal.setRefereeName(promoter.getName());
|
635 |
refferal.setStatus(RefferalStatus.pending);
|
| 636 |
refferal.setRefereeEmail(promoter.getEmail());
|
636 |
if (createRefferalRequest.isFofoAssociate()) {
|
| 637 |
refferal.setRefereeMobile(promoter.getMobile());
|
637 |
AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
|
| 638 |
} else {
|
638 |
if (authUser == null) {
|
| 639 |
refferal.setRefereeName(authUser.getFirstName());
|
639 |
Promoter promoter = promoterRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
|
| 640 |
refferal.setRefereeEmail(authUser.getGmailId());
|
640 |
refferal.setRefereeName(promoter.getName());
|
| 641 |
refferal.setRefereeMobile(authUser.getMobileNumber());
|
641 |
refferal.setRefereeEmail(promoter.getEmail());
|
| 642 |
}
|
642 |
refferal.setRefereeMobile(promoter.getMobile());
|
| 643 |
} else {
|
643 |
} else {
|
| 644 |
User user = userRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
|
644 |
refferal.setRefereeName(authUser.getFirstName());
|
| 645 |
refferal.setRefereeName(user.getFirstName());
|
645 |
refferal.setRefereeEmail(authUser.getGmailId());
|
| 646 |
refferal.setRefereeEmail(user.getEmailId());
|
646 |
refferal.setRefereeMobile(authUser.getMobileNumber());
|
| 647 |
refferal.setRefereeMobile(user.getMobileNumber());
|
647 |
}
|
| 648 |
}
|
648 |
} else {
|
| 649 |
|
649 |
User user = userRepository.selectByEmailId(createRefferalRequest.getReffereeEmail());
|
| 650 |
refferalRepository.persist(refferal);
|
650 |
refferal.setRefereeName(user.getFirstName());
|
| 651 |
|
651 |
refferal.setRefereeEmail(user.getEmailId());
|
| 652 |
List<PartnerOnBoardingPanel> pobs = partnerOnBoardingPanelRepository
|
652 |
refferal.setRefereeMobile(user.getMobileNumber());
|
| 653 |
.selectAllByPhoneNumber((Long.parseLong(refferal.getMobile())));
|
653 |
}
|
| 654 |
|
654 |
|
| 655 |
if (!pobs.isEmpty()) {
|
655 |
refferalRepository.persist(refferal);
|
| 656 |
|
656 |
|
| 657 |
List<PartnerOnBoardingStatus> ponbStatus = pobs.stream().map(x -> x.getStatus())
|
657 |
List<PartnerOnBoardingPanel> pobs = partnerOnBoardingPanelRepository
|
| 658 |
.collect(Collectors.toList());
|
658 |
.selectAllByPhoneNumber((Long.parseLong(refferal.getMobile())));
|
| 659 |
|
659 |
|
| 660 |
if (ponbStatus.contains(PartnerOnBoardingStatus.open)) {
|
660 |
if (!pobs.isEmpty()) {
|
| 661 |
refferal.setStatus(RefferalStatus.rejected);
|
661 |
|
| 662 |
refferal.setRejectedReason("This is already a Smartdukaan Partner.");
|
662 |
List<PartnerOnBoardingStatus> ponbStatus = pobs.stream().map(x -> x.getStatus())
|
| 663 |
} else if (ponbStatus.contains(PartnerOnBoardingStatus.pending)) {
|
663 |
.collect(Collectors.toList());
|
| 664 |
refferal.setStatus(RefferalStatus.rejected);
|
664 |
|
| 665 |
refferal.setRejectedReason("This is already a Smartdukaan Partner.");
|
665 |
if (ponbStatus.contains(PartnerOnBoardingStatus.open)) {
|
| 666 |
} else {
|
666 |
refferal.setStatus(RefferalStatus.rejected);
|
| 667 |
this.sendEmailToValidate(refferal);
|
667 |
refferal.setRejectedReason("This is already a Smartdukaan Partner.");
|
| 668 |
}
|
668 |
} else if (ponbStatus.contains(PartnerOnBoardingStatus.pending)) {
|
| 669 |
|
669 |
refferal.setStatus(RefferalStatus.rejected);
|
| 670 |
} else {
|
670 |
refferal.setRejectedReason("This is already a Smartdukaan Partner.");
|
| 671 |
|
671 |
} else {
|
| 672 |
this.sendEmailToValidate(refferal);
|
672 |
this.sendEmailToValidate(refferal);
|
| 673 |
|
673 |
}
|
| 674 |
}
|
674 |
|
| 675 |
return responseSender.ok(true);
|
675 |
} else {
|
| 676 |
}
|
676 |
|
| 677 |
|
677 |
this.sendEmailToValidate(refferal);
|
| 678 |
private void sendEmailToValidate(Refferal refferal) throws MessagingException, UnsupportedEncodingException {
|
678 |
|
| 679 |
|
679 |
}
|
| 680 |
String subject = "Referral Validate Request for " + refferal.getRefereeEmail();
|
680 |
return responseSender.ok(true);
|
| 681 |
String messageText = this.getMessageForReferral(refferal);
|
681 |
}
|
| 682 |
MimeMessage message = mailSender.createMimeMessage();
|
682 |
|
| 683 |
MimeMessageHelper helper = new MimeMessageHelper(message, true);
|
683 |
private void sendEmailToValidate(Refferal refferal) throws MessagingException, UnsupportedEncodingException {
|
| 684 |
String[] email = { "kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com" };
|
684 |
|
| 685 |
helper.setSubject(subject);
|
685 |
String subject = "Referral Validate Request for " + refferal.getRefereeEmail();
|
| 686 |
helper.setText(messageText, true);
|
686 |
String messageText = this.getMessageForReferral(refferal);
|
| 687 |
helper.setTo(email);
|
687 |
MimeMessage message = mailSender.createMimeMessage();
|
| 688 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
688 |
MimeMessageHelper helper = new MimeMessageHelper(message, true);
|
| 689 |
helper.setFrom(senderAddress);
|
689 |
String[] email = {"kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com"};
|
| 690 |
mailSender.send(message);
|
690 |
helper.setSubject(subject);
|
| 691 |
|
691 |
helper.setText(messageText, true);
|
| 692 |
}
|
692 |
helper.setTo(email);
|
| 693 |
|
693 |
InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
|
| 694 |
private String getMessageForReferral(Refferal referral) {
|
694 |
helper.setFrom(senderAddress);
|
| 695 |
|
695 |
mailSender.send(message);
|
| 696 |
StringBuilder sb = new StringBuilder();
|
696 |
|
| 697 |
sb.append("<html><body><p>Alert</p><p> Referral Requests:-</p>"
|
697 |
}
|
| 698 |
+ "<br/><table style='border:1px solid black ;padding: 5px';>");
|
698 |
|
| 699 |
sb.append("<tbody>\n" + " <tr>\n"
|
699 |
private String getMessageForReferral(Refferal referral) {
|
| 700 |
+ " <th style='border:1px solid black;padding: 5px'>RefereeName</th>\n"
|
700 |
|
| 701 |
+ " <th style='border:1px solid black;padding: 5px'>Referee Email</th>\n"
|
701 |
StringBuilder sb = new StringBuilder();
|
| 702 |
+ " <th style='border:1px solid black;padding: 5px'>Referral Name</th>\n"
|
702 |
sb.append("<html><body><p>Alert</p><p> Referral Requests:-</p>"
|
| 703 |
+ " <th style='border:1px solid black;padding: 5px'>Refferal Mobile</th>\n"
|
703 |
+ "<br/><table style='border:1px solid black ;padding: 5px';>");
|
| 704 |
+ " <th style='border:1px solid black;padding: 5px'>city</th>\n"
|
704 |
sb.append("<tbody>\n" + " <tr>\n"
|
| 705 |
+ " <th style='border:1px solid black;padding: 5px'>state</th>\n"
|
705 |
+ " <th style='border:1px solid black;padding: 5px'>RefereeName</th>\n"
|
| 706 |
+ " </tr>");
|
706 |
+ " <th style='border:1px solid black;padding: 5px'>Referee Email</th>\n"
|
| 707 |
|
707 |
+ " <th style='border:1px solid black;padding: 5px'>Referral Name</th>\n"
|
| 708 |
sb.append("<tr>");
|
708 |
+ " <th style='border:1px solid black;padding: 5px'>Refferal Mobile</th>\n"
|
| 709 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeName() + "</td>");
|
709 |
+ " <th style='border:1px solid black;padding: 5px'>city</th>\n"
|
| 710 |
|
710 |
+ " <th style='border:1px solid black;padding: 5px'>state</th>\n"
|
| 711 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeEmail() + "</td>");
|
711 |
+ " </tr>");
|
| 712 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getFirstName() + "</td>");
|
712 |
|
| 713 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getMobile() + "</td>");
|
713 |
sb.append("<tr>");
|
| 714 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getCity() + "</td>");
|
714 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeName() + "</td>");
|
| 715 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getState() + "</td>");
|
715 |
|
| 716 |
|
716 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getRefereeEmail() + "</td>");
|
| 717 |
sb.append("</tr>");
|
717 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getFirstName() + "</td>");
|
| 718 |
|
718 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getMobile() + "</td>");
|
| 719 |
sb.append("</tbody></table></body></html>");
|
719 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getCity() + "</td>");
|
| 720 |
|
720 |
sb.append("<td style='border:1px solid black;padding: 5px'>" + referral.getState() + "</td>");
|
| 721 |
return sb.toString();
|
721 |
|
| 722 |
}
|
722 |
sb.append("</tr>");
|
| 723 |
|
723 |
|
| 724 |
@RequestMapping(value = "/user/refferalAmount", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
724 |
sb.append("</tbody></table></body></html>");
|
| 725 |
@ApiImplicitParams({
|
725 |
|
| 726 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
726 |
return sb.toString();
|
| 727 |
public ResponseEntity<?> RefferalAmount(HttpServletRequest request, @RequestParam String refereeEmail)
|
727 |
}
|
| 728 |
throws Exception {
|
728 |
|
| 729 |
LocalDateTime ldt = LocalDate.now().atStartOfDay().withDayOfMonth(16);
|
729 |
@RequestMapping(value = "/user/refferalAmount", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 730 |
DateRangeModel drm = new DateRangeModel();
|
730 |
@ApiImplicitParams({
|
| 731 |
List<RefferalEarningModel> refferAmountModel = new ArrayList<RefferalEarningModel>();
|
731 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 732 |
RefferalEarningModel rfm = new RefferalEarningModel();
|
732 |
public ResponseEntity<?> RefferalAmount(HttpServletRequest request, @RequestParam String refereeEmail)
|
| 733 |
long currentMonthEstimaterefferal = 0;
|
733 |
throws Exception {
|
| 734 |
long currentMonthConfirmedrefferal = 0;
|
734 |
LocalDateTime ldt = LocalDate.now().atStartOfDay().withDayOfMonth(16);
|
| 735 |
if (LocalDateTime.now().isBefore(ldt)) {
|
735 |
DateRangeModel drm = new DateRangeModel();
|
| 736 |
List<Refferal> allPendingRefferalBeforeCurrentMonth = refferalRepository
|
736 |
List<RefferalEarningModel> refferAmountModel = new ArrayList<RefferalEarningModel>();
|
| 737 |
.selectByEmailIdAndStatusAndbeforeCurrentMonth(refereeEmail, RefferalStatus.pending);
|
737 |
RefferalEarningModel rfm = new RefferalEarningModel();
|
| 738 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
738 |
long currentMonthEstimaterefferal = 0;
|
| 739 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(1));
|
739 |
long currentMonthConfirmedrefferal = 0;
|
| 740 |
|
740 |
if (LocalDateTime.now().isBefore(ldt)) {
|
| 741 |
List<Refferal> previousMonthapprovedRefferalAfterSixteen = refferalRepository
|
741 |
List<Refferal> allPendingRefferalBeforeCurrentMonth = refferalRepository
|
| 742 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
742 |
.selectByEmailIdAndStatusAndbeforeCurrentMonth(refereeEmail, RefferalStatus.pending);
|
| 743 |
List<Refferal> previousMonthtransferredRefferalAfterSixteen = refferalRepository
|
743 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
| 744 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
744 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(1));
|
| 745 |
|
745 |
|
| 746 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
|
746 |
List<Refferal> previousMonthapprovedRefferalAfterSixteen = refferalRepository
|
| 747 |
drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
747 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
| 748 |
|
748 |
List<Refferal> previousMonthtransferredRefferalAfterSixteen = refferalRepository
|
| 749 |
List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
|
749 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
| 750 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
750 |
|
| 751 |
List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
|
751 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
|
| 752 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
752 |
drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
| 753 |
long pendingRefferalBeforeCurrentMonth = allPendingRefferalBeforeCurrentMonth.size();
|
753 |
|
| 754 |
long previousapprovedRefferalAfterSixteen = previousMonthapprovedRefferalAfterSixteen.size();
|
754 |
List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
|
| 755 |
long previoustransferredRefferalAfterSixteen = previousMonthtransferredRefferalAfterSixteen.size();
|
755 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
| 756 |
long previousapprovedRefferalbeforeSixteen = previousMonthapprovedRefferalbeforeSixteen.size();
|
756 |
List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
|
| 757 |
long previoustransferredRefferalbeforeSixteen = previousMonthtransferredRefferalbeforeSixteen.size();
|
757 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
| 758 |
long previousMonthEstimateRefferal = pendingRefferalBeforeCurrentMonth
|
758 |
long pendingRefferalBeforeCurrentMonth = allPendingRefferalBeforeCurrentMonth.size();
|
| 759 |
+ previousapprovedRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen;
|
759 |
long previousapprovedRefferalAfterSixteen = previousMonthapprovedRefferalAfterSixteen.size();
|
| 760 |
long previousMonthConfirmedRefferal = previousapprovedRefferalAfterSixteen
|
760 |
long previoustransferredRefferalAfterSixteen = previousMonthtransferredRefferalAfterSixteen.size();
|
| 761 |
+ previoustransferredRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen
|
761 |
long previousapprovedRefferalbeforeSixteen = previousMonthapprovedRefferalbeforeSixteen.size();
|
| 762 |
+ previoustransferredRefferalbeforeSixteen;
|
762 |
long previoustransferredRefferalbeforeSixteen = previousMonthtransferredRefferalbeforeSixteen.size();
|
| 763 |
rfm = refferAmountEarning(pendingRefferalBeforeCurrentMonth, previousMonthConfirmedRefferal,
|
763 |
long previousMonthEstimateRefferal = pendingRefferalBeforeCurrentMonth
|
| 764 |
YearMonth.now().minusMonths(1));
|
764 |
+ previousapprovedRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen;
|
| 765 |
refferAmountModel.add(rfm);
|
765 |
long previousMonthConfirmedRefferal = previousapprovedRefferalAfterSixteen
|
| 766 |
LOGGER.info("previousMonthPendingApprovedRefferal" + previousMonthEstimateRefferal);
|
766 |
+ previoustransferredRefferalAfterSixteen + previousapprovedRefferalbeforeSixteen
|
| 767 |
LOGGER.info("previousMonthApprovedTransfferedRefferal" + previousMonthConfirmedRefferal);
|
767 |
+ previoustransferredRefferalbeforeSixteen;
|
| 768 |
|
768 |
rfm = refferAmountEarning(pendingRefferalBeforeCurrentMonth, previousMonthConfirmedRefferal,
|
| 769 |
List<Refferal> pendingofCurrentMonth = refferalRepository
|
769 |
YearMonth.now().minusMonths(1));
|
| 770 |
.selectByEmailIdAndStatusAndBetweenDates(refereeEmail, RefferalStatus.pending, YearMonth.now());
|
770 |
refferAmountModel.add(rfm);
|
| 771 |
List<Refferal> approvedofCurrentMonth = refferalRepository.selectByEmailIdAndStatusAndDatesBetweenTimestamp(
|
771 |
LOGGER.info("previousMonthPendingApprovedRefferal" + previousMonthEstimateRefferal);
|
| 772 |
refereeEmail, RefferalStatus.approved, YearMonth.now());
|
772 |
LOGGER.info("previousMonthApprovedTransfferedRefferal" + previousMonthConfirmedRefferal);
|
| 773 |
List<Refferal> transferredofCurrentMonth = refferalRepository
|
773 |
|
| 774 |
.selectByEmailIdAndStatusAndDatesBetweenTimestamp(refereeEmail, RefferalStatus.transferred,
|
774 |
List<Refferal> pendingofCurrentMonth = refferalRepository
|
| 775 |
YearMonth.now());
|
775 |
.selectByEmailIdAndStatusAndBetweenDates(refereeEmail, RefferalStatus.pending, YearMonth.now());
|
| 776 |
LOGGER.info("pendingofCurrentMonth" + pendingofCurrentMonth);
|
776 |
List<Refferal> approvedofCurrentMonth = refferalRepository.selectByEmailIdAndStatusAndDatesBetweenTimestamp(
|
| 777 |
long pendingofCurrentMonthCount = pendingofCurrentMonth.size();
|
777 |
refereeEmail, RefferalStatus.approved, YearMonth.now());
|
| 778 |
currentMonthEstimaterefferal = pendingofCurrentMonth.size() + approvedofCurrentMonth.size();
|
778 |
List<Refferal> transferredofCurrentMonth = refferalRepository
|
| 779 |
currentMonthConfirmedrefferal = approvedofCurrentMonth.size() + transferredofCurrentMonth.size();
|
779 |
.selectByEmailIdAndStatusAndDatesBetweenTimestamp(refereeEmail, RefferalStatus.transferred,
|
| 780 |
|
780 |
YearMonth.now());
|
| 781 |
rfm = refferAmountEarning(pendingofCurrentMonthCount, currentMonthConfirmedrefferal, YearMonth.now());
|
781 |
LOGGER.info("pendingofCurrentMonth" + pendingofCurrentMonth);
|
| 782 |
|
782 |
long pendingofCurrentMonthCount = pendingofCurrentMonth.size();
|
| 783 |
refferAmountModel.add(rfm);
|
783 |
currentMonthEstimaterefferal = pendingofCurrentMonth.size() + approvedofCurrentMonth.size();
|
| 784 |
|
784 |
currentMonthConfirmedrefferal = approvedofCurrentMonth.size() + transferredofCurrentMonth.size();
|
| 785 |
} else if (LocalDateTime.now().isAfter(ldt)) {
|
785 |
|
| 786 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
|
786 |
rfm = refferAmountEarning(pendingofCurrentMonthCount, currentMonthConfirmedrefferal, YearMonth.now());
|
| 787 |
drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
787 |
|
| 788 |
|
788 |
refferAmountModel.add(rfm);
|
| 789 |
List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
|
789 |
|
| 790 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
790 |
} else if (LocalDateTime.now().isAfter(ldt)) {
|
| 791 |
List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
|
791 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
|
| 792 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
792 |
drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
| 793 |
|
793 |
|
| 794 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
794 |
List<Refferal> previousMonthapprovedRefferalbeforeSixteen = refferalRepository
|
| 795 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
|
795 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
| 796 |
|
796 |
List<Refferal> previousMonthtransferredRefferalbeforeSixteen = refferalRepository
|
| 797 |
List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
|
797 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
| 798 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
798 |
|
| 799 |
|
799 |
drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
|
| 800 |
LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
|
800 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
|
| 801 |
|
801 |
|
| 802 |
List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
|
802 |
List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
|
| 803 |
.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
|
803 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
| 804 |
List<Refferal> previousAndcurrentMonthtransferredRefferal = refferalRepository
|
804 |
|
| 805 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
805 |
LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
|
| 806 |
List<Refferal> preCurrMonthtransferred = previousAndcurrentMonthtransferredRefferal.stream()
|
806 |
|
| 807 |
.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
|
807 |
List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
|
| 808 |
|
808 |
.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
|
| 809 |
long approvedRefferal = previousMonthapprovedRefferalbeforeSixteen.size()
|
809 |
List<Refferal> previousAndcurrentMonthtransferredRefferal = refferalRepository
|
| 810 |
+ previousMonthtransferredRefferalbeforeSixteen.size() + preCurrMonthapproved.size()
|
810 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
| 811 |
+ preCurrMonthtransferred.size();
|
811 |
List<Refferal> preCurrMonthtransferred = previousAndcurrentMonthtransferredRefferal.stream()
|
| 812 |
rfm = new RefferalEarningModel();
|
812 |
.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
|
| 813 |
rfm.setActualEarning(approvedRefferal * 5000);
|
813 |
|
| 814 |
|
814 |
long approvedRefferal = previousMonthapprovedRefferalbeforeSixteen.size()
|
| 815 |
rfm.setYearMonth(YearMonth.now().minusMonths(1));
|
815 |
+ previousMonthtransferredRefferalbeforeSixteen.size() + preCurrMonthapproved.size()
|
| 816 |
rfm.setPendingRefferal(0);
|
816 |
+ preCurrMonthtransferred.size();
|
| 817 |
rfm.setApprovedRefferal(approvedRefferal);
|
817 |
rfm = new RefferalEarningModel();
|
| 818 |
refferAmountModel.add(rfm);
|
818 |
rfm.setActualEarning(approvedRefferal * 5000);
|
| 819 |
List<Refferal> allpendingRefferal = refferalRepository.selectByEmailIdAndStatus(refereeEmail,
|
819 |
|
| 820 |
RefferalStatus.pending);
|
820 |
rfm.setYearMonth(YearMonth.now().minusMonths(1));
|
| 821 |
LOGGER.info("allpendingRefferal" + allpendingRefferal);
|
821 |
rfm.setPendingRefferal(0);
|
| 822 |
|
822 |
rfm.setApprovedRefferal(approvedRefferal);
|
| 823 |
drm.setStartDate(LocalDateTime.now().withDayOfMonth(16));
|
823 |
refferAmountModel.add(rfm);
|
| 824 |
drm.setEndDate(LocalDateTime.now().plusMonths(1).withDayOfMonth(1));
|
824 |
List<Refferal> allpendingRefferal = refferalRepository.selectByEmailIdAndStatus(refereeEmail,
|
| 825 |
|
825 |
RefferalStatus.pending);
|
| 826 |
List<Refferal> currentMonthapprovedRefferalAfterSixteen = refferalRepository
|
826 |
LOGGER.info("allpendingRefferal" + allpendingRefferal);
|
| 827 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
827 |
|
| 828 |
List<Refferal> currentMonthtransferredRefferalAfterSixteen = refferalRepository
|
828 |
drm.setStartDate(LocalDateTime.now().withDayOfMonth(16));
|
| 829 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
829 |
drm.setEndDate(LocalDateTime.now().plusMonths(1).withDayOfMonth(1));
|
| 830 |
LOGGER.info("currentMonthapprovedRefferalAfterSixteen" + currentMonthapprovedRefferalAfterSixteen);
|
830 |
|
| 831 |
drm.setStartDate(LocalDateTime.now().withDayOfMonth(1));
|
831 |
List<Refferal> currentMonthapprovedRefferalAfterSixteen = refferalRepository
|
| 832 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
|
832 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.approved, drm);
|
| 833 |
|
833 |
List<Refferal> currentMonthtransferredRefferalAfterSixteen = refferalRepository
|
| 834 |
List<Refferal> currentMonthapprovedRefferalbeforeSixteen = refferalRepository
|
834 |
.selectByEmailIdAndStatusAndDateRange(refereeEmail, RefferalStatus.transferred, drm);
|
| 835 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
835 |
LOGGER.info("currentMonthapprovedRefferalAfterSixteen" + currentMonthapprovedRefferalAfterSixteen);
|
| 836 |
List<Refferal> currentMonthtransferredRefferalbeforeSixteen = refferalRepository
|
836 |
drm.setStartDate(LocalDateTime.now().withDayOfMonth(1));
|
| 837 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
837 |
drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
|
| 838 |
LOGGER.info("currentMonthapprovedRefferalbeforeSixteen" + currentMonthapprovedRefferalbeforeSixteen);
|
838 |
|
| 839 |
long pendingrefferalcount = allpendingRefferal.size();
|
839 |
List<Refferal> currentMonthapprovedRefferalbeforeSixteen = refferalRepository
|
| 840 |
currentMonthConfirmedrefferal = currentMonthapprovedRefferalAfterSixteen.size()
|
840 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.approved, drm);
|
| 841 |
+ currentMonthtransferredRefferalAfterSixteen.size()
|
841 |
List<Refferal> currentMonthtransferredRefferalbeforeSixteen = refferalRepository
|
| 842 |
+ currentMonthapprovedRefferalbeforeSixteen.size()
|
842 |
.selectByEmailIdAndStatusAndDateRanges(refereeEmail, RefferalStatus.transferred, drm);
|
| 843 |
+ currentMonthtransferredRefferalbeforeSixteen.size();
|
843 |
LOGGER.info("currentMonthapprovedRefferalbeforeSixteen" + currentMonthapprovedRefferalbeforeSixteen);
|
| 844 |
|
844 |
long pendingrefferalcount = allpendingRefferal.size();
|
| 845 |
rfm = refferAmountEarning(pendingrefferalcount, currentMonthConfirmedrefferal, YearMonth.now());
|
845 |
currentMonthConfirmedrefferal = currentMonthapprovedRefferalAfterSixteen.size()
|
| 846 |
refferAmountModel.add(rfm);
|
846 |
+ currentMonthtransferredRefferalAfterSixteen.size()
|
| 847 |
LOGGER.info("currentMonthpendingApprovedrefferal" + currentMonthEstimaterefferal);
|
847 |
+ currentMonthapprovedRefferalbeforeSixteen.size()
|
| 848 |
|
848 |
+ currentMonthtransferredRefferalbeforeSixteen.size();
|
| 849 |
LOGGER.info("currentMonthapprovedTransferredrefferal" + currentMonthConfirmedrefferal);
|
849 |
|
| 850 |
|
850 |
rfm = refferAmountEarning(pendingrefferalcount, currentMonthConfirmedrefferal, YearMonth.now());
|
| 851 |
}
|
851 |
refferAmountModel.add(rfm);
|
| 852 |
RefferalEarning re = new RefferalEarning();
|
852 |
LOGGER.info("currentMonthpendingApprovedrefferal" + currentMonthEstimaterefferal);
|
| 853 |
re.setTimestamp(LocalDateTime.now());
|
853 |
|
| 854 |
re.setRefferalEarningModel(refferAmountModel);
|
854 |
LOGGER.info("currentMonthapprovedTransferredrefferal" + currentMonthConfirmedrefferal);
|
| 855 |
return responseSender.ok(re);
|
855 |
|
| 856 |
}
|
856 |
}
|
| 857 |
|
857 |
RefferalEarning re = new RefferalEarning();
|
| 858 |
private RefferalEarningModel refferAmountEarning(long pendingRefferalValue, long confirmedRefferalValue,
|
858 |
re.setTimestamp(LocalDateTime.now());
|
| 859 |
YearMonth yearMonth) {
|
859 |
re.setRefferalEarningModel(refferAmountModel);
|
| 860 |
RefferalEarningModel rfm = new RefferalEarningModel();
|
860 |
return responseSender.ok(re);
|
| 861 |
rfm.setYearMonth(yearMonth);
|
861 |
}
|
| 862 |
rfm.setPendingRefferal(pendingRefferalValue);
|
862 |
|
| 863 |
rfm.setApprovedRefferal(confirmedRefferalValue);
|
863 |
private RefferalEarningModel refferAmountEarning(long pendingRefferalValue, long confirmedRefferalValue,
|
| 864 |
long estimateRefferalValue = pendingRefferalValue + confirmedRefferalValue;
|
864 |
YearMonth yearMonth) {
|
| 865 |
|
865 |
RefferalEarningModel rfm = new RefferalEarningModel();
|
| 866 |
rfm.setMaximumEarning(estimateRefferalValue * 5000);
|
866 |
rfm.setYearMonth(yearMonth);
|
| 867 |
|
867 |
rfm.setPendingRefferal(pendingRefferalValue);
|
| 868 |
rfm.setMinimumEarning(confirmedRefferalValue * 5000);
|
868 |
rfm.setApprovedRefferal(confirmedRefferalValue);
|
| 869 |
|
869 |
long estimateRefferalValue = pendingRefferalValue + confirmedRefferalValue;
|
| 870 |
return rfm;
|
870 |
|
| 871 |
}
|
871 |
rfm.setMaximumEarning(estimateRefferalValue * 5000);
|
| 872 |
|
872 |
|
| 873 |
@RequestMapping(value = "/user/getReferals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
873 |
rfm.setMinimumEarning(confirmedRefferalValue * 5000);
|
| 874 |
@ApiImplicitParams({
|
874 |
|
| 875 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
875 |
return rfm;
|
| 876 |
public ResponseEntity<?> getReferals(HttpServletRequest request, @RequestParam RefferalStatus status)
|
876 |
}
|
| 877 |
throws Exception {
|
877 |
|
| 878 |
int userId = (int) request.getAttribute("userId");
|
878 |
@RequestMapping(value = "/user/getReferals", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 879 |
|
879 |
@ApiImplicitParams({
|
| 880 |
User user = userRepository.selectById(userId);
|
880 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 881 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
881 |
public ResponseEntity<?> getReferals(HttpServletRequest request, @RequestParam RefferalStatus status)
|
| 882 |
|
882 |
throws Exception {
|
| 883 |
List<Refferal> refferals = refferalRepository.selectByEmailIdAndStatus(user.getEmailId(), status);
|
883 |
int userId = (int) request.getAttribute("userId");
|
| 884 |
return responseSender.ok(refferals);
|
884 |
|
| 885 |
}
|
885 |
User user = userRepository.selectById(userId);
|
| 886 |
|
886 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
| 887 |
@RequestMapping(value = "/user/partnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
887 |
|
| 888 |
@ApiImplicitParams({
|
888 |
List<Refferal> refferals = refferalRepository.selectByEmailIdAndStatus(user.getEmailId(), status);
|
| 889 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
889 |
return responseSender.ok(refferals);
|
| 890 |
public ResponseEntity<?> PartnerTarget(HttpServletRequest request) throws Exception {
|
890 |
}
|
| 891 |
int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
|
891 |
|
| 892 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(userId);
|
892 |
@RequestMapping(value = "/user/partnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 893 |
PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(retailerId, LocalDate.now());
|
893 |
@ApiImplicitParams({
|
| 894 |
|
894 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| 895 |
return responseSender.ok(partnerType);
|
895 |
public ResponseEntity<?> PartnerTarget(HttpServletRequest request) throws Exception {
|
| 896 |
}
|
896 |
int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
|
| 897 |
|
897 |
int retailerId = userAccountRepository.selectRetailerIdByUserId(userId);
|
| 898 |
@RequestMapping(value = "/user/authUser", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
898 |
PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(retailerId, LocalDate.now());
|
| 899 |
@ApiImplicitParams({
|
899 |
|
| 900 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
900 |
return responseSender.ok(partnerType);
|
| 901 |
public ResponseEntity<?> authUserDetail(HttpServletRequest request, @RequestParam int userId) throws Exception {
|
901 |
}
|
| 902 |
User user = userRepository.selectById(userId);
|
902 |
|
| 903 |
AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
|
903 |
@RequestMapping(value = "/user/authUser", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 904 |
return responseSender.ok(authUser);
|
904 |
@ApiImplicitParams({
|
| 905 |
}
|
905 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
|
| - |
|
906 |
public ResponseEntity<?> authUserDetail(HttpServletRequest request, @RequestParam int userId) throws Exception {
|
| - |
|
907 |
User user = userRepository.selectById(userId);
|
| - |
|
908 |
AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
|
| - |
|
909 |
return responseSender.ok(authUser);
|
| - |
|
910 |
}
|
| 906 |
|
911 |
|
| 907 |
}
|
912 |
}
|
| 908 |
|
913 |
|
| 909 |
class MobileAppSettingsWrapper {
|
914 |
class MobileAppSettingsWrapper {
|
| 910 |
@JsonProperty(value = "Mobileappsetting")
|
915 |
@JsonProperty(value = "Mobileappsetting")
|
| 911 |
private MobileAppSetting mobileAppSettings;
|
916 |
private MobileAppSetting mobileAppSettings;
|
| 912 |
|
917 |
|
| 913 |
public MobileAppSettingsWrapper(MobileAppSetting mobileAppSettings) {
|
918 |
public MobileAppSettingsWrapper(MobileAppSetting mobileAppSettings) {
|
| 914 |
super();
|
919 |
super();
|
| 915 |
this.mobileAppSettings = mobileAppSettings;
|
920 |
this.mobileAppSettings = mobileAppSettings;
|
| 916 |
}
|
921 |
}
|
| 917 |
|
922 |
|
| 918 |
public MobileAppSetting getMobileAppSettings() {
|
923 |
public MobileAppSetting getMobileAppSettings() {
|
| 919 |
return mobileAppSettings;
|
924 |
return mobileAppSettings;
|
| 920 |
}
|
925 |
}
|
| 921 |
|
926 |
|
| 922 |
public void setMobileAppSettings(MobileAppSetting mobileAppSettings) {
|
927 |
public void setMobileAppSettings(MobileAppSetting mobileAppSettings) {
|
| 923 |
this.mobileAppSettings = mobileAppSettings;
|
928 |
this.mobileAppSettings = mobileAppSettings;
|
| 924 |
}
|
929 |
}
|
| 925 |
|
930 |
|
| 926 |
@Override
|
931 |
@Override
|
| 927 |
public String toString() {
|
932 |
public String toString() {
|
| 928 |
return "MobileAppSettingsWrapper [mobileAppSettings=" + mobileAppSettings + "]";
|
933 |
return "MobileAppSettingsWrapper [mobileAppSettings=" + mobileAppSettings + "]";
|
| 929 |
}
|
934 |
}
|
| 930 |
|
935 |
|
| 931 |
}
|
936 |
}
|
| 932 |
|
937 |
|
| 933 |
class SettingsWrapper {
|
938 |
class SettingsWrapper {
|
| 934 |
private List<MobileAppSettingsWrapper> settings;
|
939 |
private List<MobileAppSettingsWrapper> settings;
|
| 935 |
|
940 |
|
| 936 |
public SettingsWrapper(List<MobileAppSettingsWrapper> settings) {
|
941 |
public SettingsWrapper(List<MobileAppSettingsWrapper> settings) {
|
| 937 |
super();
|
942 |
super();
|
| 938 |
this.settings = settings;
|
943 |
this.settings = settings;
|
| 939 |
}
|
944 |
}
|
| 940 |
|
945 |
|
| 941 |
@Override
|
946 |
@Override
|
| 942 |
public String toString() {
|
947 |
public String toString() {
|
| 943 |
return "SettingsWrapper [settings=" + settings + "]";
|
948 |
return "SettingsWrapper [settings=" + settings + "]";
|
| 944 |
}
|
949 |
}
|
| 945 |
|
950 |
|
| 946 |
public List<MobileAppSettingsWrapper> getSettings() {
|
951 |
public List<MobileAppSettingsWrapper> getSettings() {
|
| 947 |
return settings;
|
952 |
return settings;
|
| 948 |
}
|
953 |
}
|
| 949 |
|
954 |
|
| 950 |
public void setSettings(List<MobileAppSettingsWrapper> settings) {
|
955 |
public void setSettings(List<MobileAppSettingsWrapper> settings) {
|
| 951 |
this.settings = settings;
|
956 |
this.settings = settings;
|
| 952 |
}
|
957 |
}
|
| 953 |
|
958 |
|
| 954 |
}
|
959 |
}
|