Subversion Repositories SmartDukaan

Rev

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

Rev 22471 Rev 22476
Line 19... Line 19...
19 
 
 19 
 
20 
import com.google.gson.Gson;
 20 
import com.google.gson.Gson;
21 
import com.google.gson.reflect.TypeToken;
 21 
import com.google.gson.reflect.TypeToken;
22 
import com.spice.profitmandi.common.enumuration.ContentType;
 22 
import com.spice.profitmandi.common.enumuration.ContentType;
23 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 23 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
- 
 
 24 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
24 
import com.spice.profitmandi.common.util.FileUtil;
 25 
import com.spice.profitmandi.common.util.FileUtil;
25 
import com.spice.profitmandi.dao.entity.dtr.Document;
 26 
import com.spice.profitmandi.dao.entity.dtr.Document;
26 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
 27 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
27 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
 28 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
28 
import com.spice.profitmandi.dao.entity.dtr.User;
 29 
import com.spice.profitmandi.dao.entity.dtr.User;
Line 211... Line 212...
211 
			foundEmailIds = userRepository.selectEmailIdsByEmailIds(emailIds);
212 
			foundEmailIds = userRepository.selectEmailIdsByEmailIds(emailIds);
212 
		}
 213 
		}
213 
		emailIds.removeAll(foundEmailIds);
 214 
		emailIds.removeAll(foundEmailIds);
214 
		for(Map<String, String> map : maps){
 215 
		for(Map<String, String> map : maps){
215 
			if(map.containsKey("registeredEmail1") && emailIds.contains(map.get("registeredEmail1"))){
 216 
			if(map.containsKey("registeredEmail1") && emailIds.contains(map.get("registeredEmail1"))){
- 
 
 217
- 
 
 218 
				User user = null;
- 
 
 219
- 
 
 220 
				try{
- 
 
 221 
					user = userRepository.selectByEmailId(map.get("registeredEmail1"));
- 
 
 222 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
216 
				User user = new User();
 223 
					user = new User();
217 
				user.setFirstName("");
 224 
					user.setFirstName("");
218 
				user.setLastName("");
 225 
					user.setLastName("");
219 
				user.setCity(map.containsKey("city") ? map.get("city") : "");
 226 
					user.setCity(map.containsKey("city") ? map.get("city") : "");
220 
				user.setPinCode(Integer.valueOf(map.containsKey("pincode") ? map.get("pincode") : ""));
 227 
					user.setPinCode(Integer.valueOf(map.containsKey("pincode") ? map.get("pincode") : ""));
221 
				user.setMobileNumber(map.containsKey("mobile") ? map.get("mobile") : "");
 228 
					user.setMobileNumber(map.containsKey("mobile") ? map.get("mobile") : "");
222 
				user.setEmailId(map.get("registeredEmail1"));
 229 
					user.setEmailId(map.get("registeredEmail1"));
223 
				user.setUsername(map.get("registeredEmail1"));
 230 
					user.setUsername(map.get("registeredEmail1"));
224 
				user.setPassword("");
 231 
					user.setPassword("");
225 
				user.setMobile_verified(false);
 232 
					user.setMobile_verified(false);
226 
				user.setReferral_url("");
 233 
					user.setReferral_url("");
227 
				user.setGroup_id(1);
 234 
					user.setGroup_id(1);
228 
				user.setStatus(0);
 235 
					user.setStatus(0);
229 
				user.setActivated(false);
 236 
					user.setActivated(false);
230 
				user.setCreateTimestamp(LocalDateTime.now());
 237 
					user.setCreateTimestamp(LocalDateTime.now());
231 
				user.setUpdateTimestamp(LocalDateTime.now());
 238 
					user.setUpdateTimestamp(LocalDateTime.now());
232 
				userRepository.persist(user);
 239 
					userRepository.persist(user);
- 
 
 240 
				}
- 
 
 241
233
242
234 
				//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(map.get("registeredEmail1"));
 243 
				//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(map.get("registeredEmail1"));
235
244
236 
				com.spice.profitmandi.dao.entity.user.User saholicUser = null;
 245 
				com.spice.profitmandi.dao.entity.user.User saholicUser = null;
237 
				boolean foundRetailer = false;
 246 
				boolean foundRetailer = false;
Line 247... Line 256...
247 
					userUserRepository.persist(saholicUser);
 256 
					userUserRepository.persist(saholicUser);
248 
				}else{
 257 
				}else{
249 
					foundRetailer = true;
 258 
					foundRetailer = true;
250 
				}
 259 
				}
251
260
- 
 
 261 
				Retailer retailer = null;
- 
 
 262
- 
 
 263 
				try{
- 
 
 264 
					retailer = retailerRepository.selectById(saholicUser.getId());
- 
 
 265 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 266 
					retailer = new Retailer();
- 
 
 267 
					retailer.setActive(true);
- 
 
 268 
					retailer.setFofo(true);
- 
 
 269 
					retailer.setId(saholicUser.getId());
- 
 
 270 
					retailer.setMigrated(true);
- 
 
 271 
					retailer.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
- 
 
 272 
					retailer.setType(RetailerType.GSTIN);
- 
 
 273 
					retailerRepository.persist(retailer);
- 
 
 274 
				}
252
275
253 
				Retailer retailer = new Retailer();
 - 
 
254 
				retailer.setActive(true);
 - 
 
255 
				retailer.setFofo(true);
 - 
 
256 
				retailer.setId(saholicUser.getId());
 - 
 
257 
				retailer.setMigrated(true);
 - 
 
258 
				retailer.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
 - 
 
259 
				retailer.setType(RetailerType.GSTIN);
 - 
 
260 
				retailerRepository.persist(retailer);
 - 
 
261
276
262 
				Address retailerAddress = new Address();
 277 
				Address retailerAddress = new Address();
263 
				retailerAddress.setCity(map.containsKey("city") ? map.get("city") : "");
 - 
 
264 
				retailerAddress.setCountry("India");
 - 
 
265 
				retailerAddress.setEnabled(true);
 - 
 
266 
				retailerAddress.setLandmark("");
 - 
 
267 
				retailerAddress.setLine1(map.containsKey("line1") ? map.get("line1") : "");
 - 
 
268 
				retailerAddress.setLine2(map.containsKey("line2") ? map.get("line2") : "");
 - 
 
269 
				retailerAddress.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
 - 
 
270 
				retailerAddress.setPhoneNumber(map.containsKey("mobile") ? map.get("mobile") : "");
 - 
 
271 
				retailerAddress.setPinCode(map.containsKey("pincode") ? map.get("pincode") : "");
 - 
 
272 
				retailerAddress.setState(map.containsKey("state") ? map.get("state") : "");
 - 
 
273 
				retailerAddress.setRetaierId(retailer.getId());
 - 
 
274 
				addressRepository.persist(retailerAddress);
 - 
 
275
- 
 
276 
				RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
 - 
 
277 
				retailerRegisteredAddress.setAddressId(retailerAddress.getId());
 - 
 
278 
				retailerRegisteredAddress.setRetailerId(retailer.getId());
 - 
 
279 
				retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
 - 
 
280
- 
 
281 
				UserAccounts saholicUserAccounts = new UserAccounts();
 - 
 
282 
				saholicUserAccounts.setAccount_key(String.valueOf(saholicUser.getId()));
 - 
 
283 
				saholicUserAccounts.setAccount_type(AccountType.saholic);
 - 
 
284 
				saholicUserAccounts.setUser_id(user.getId());
 - 
 
285 
				userAccountRepository.persist(saholicUserAccounts);
 - 
 
286 
				UserAccounts cartUserAccounts = new UserAccounts();
 - 
 
287 
				cartUserAccounts.setAccount_key(String.valueOf(saholicUser.getActiveCartId()));
 - 
 
288 
				cartUserAccounts.setAccount_type(AccountType.cartId);
 - 
 
289 
				cartUserAccounts.setUser_id(user.getId());
 - 
 
290 
				userAccountRepository.persist(cartUserAccounts);
 - 
 
291
278
- 
 
 279 
				List<Address> retailerAddresses = addressRepository.selectAll(retailer.getId(), 1, 100);
- 
 
 280 
				if(retailerAddresses.isEmpty()){
- 
 
 281 
					retailerAddress.setCity(map.containsKey(ProfitMandiConstants.CITY) ? map.get(ProfitMandiConstants.CITY) : "");
- 
 
 282 
					retailerAddress.setCountry("India");
- 
 
 283 
					retailerAddress.setEnabled(true);
- 
 
 284 
					retailerAddress.setLandmark("");
- 
 
 285 
					retailerAddress.setLine1(map.containsKey(ProfitMandiConstants.LINE1) ? map.get(ProfitMandiConstants.LINE1) : "");
- 
 
 286 
					retailerAddress.setLine2(map.containsKey(ProfitMandiConstants.LINE2) ? map.get(ProfitMandiConstants.LINE2) : "");
- 
 
 287 
					retailerAddress.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
- 
 
 288 
					retailerAddress.setPhoneNumber(map.containsKey("mobile") ? map.get("mobile") : "");
- 
 
 289 
					retailerAddress.setPinCode(map.containsKey("pincode") ? map.get("pincode") : "");
- 
 
 290 
					retailerAddress.setState(map.containsKey(ProfitMandiConstants.STATE) ? map.get(ProfitMandiConstants.STATE) : "");
- 
 
 291 
					retailerAddress.setRetaierId(retailer.getId());
- 
 
 292 
					addressRepository.persist(retailerAddress);
- 
 
 293 
				}
- 
 
 294
- 
 
 295
- 
 
 296 
				RetailerRegisteredAddress retailerRegisteredAddress = null;
- 
 
 297 
				try{
- 
 
 298 
					retailerRegisteredAddress = retailerRegisteredAddressRepository.selectByAddressIdAndRetailerId(retailerAddress.getId(), retailer.getId());
- 
 
 299 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 300 
					retailerRegisteredAddress = new RetailerRegisteredAddress();
- 
 
 301 
					retailerRegisteredAddress.setAddressId(retailerAddress.getId());
- 
 
 302 
					retailerRegisteredAddress.setRetailerId(retailer.getId());
- 
 
 303 
					retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
- 
 
 304 
				}
- 
 
 305
- 
 
 306
- 
 
 307 
				UserAccounts saholicUserAccounts = null;
- 
 
 308 
				try{
- 
 
 309 
					saholicUserAccounts = userAccountRepository.selectByUserIdRetailerIdAccountType(user.getId(), retailer.getId(), AccountType.saholic);
- 
 
 310 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 311 
					saholicUserAccounts = new UserAccounts();
- 
 
 312 
					saholicUserAccounts.setAccount_key(String.valueOf(saholicUser.getId()));
- 
 
 313 
					saholicUserAccounts.setAccount_type(AccountType.saholic);
- 
 
 314 
					saholicUserAccounts.setUser_id(user.getId());
- 
 
 315 
					userAccountRepository.persist(saholicUserAccounts);
- 
 
 316 
					UserAccounts cartUserAccounts = new UserAccounts();
- 
 
 317 
					cartUserAccounts.setAccount_key(String.valueOf(saholicUser.getActiveCartId()));
- 
 
 318 
					cartUserAccounts.setAccount_type(AccountType.cartId);
- 
 
 319 
					cartUserAccounts.setUser_id(user.getId());
- 
 
 320 
					userAccountRepository.persist(cartUserAccounts);
- 
 
 321 
				}
- 
 
 322
- 
 
 323
- 
 
 324 
				UserRole userRole = null;
- 
 
 325 
				try{
- 
 
 326 
					userRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.USER);
- 
 
 327 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 328 
					userRole = new UserRole();
- 
 
 329 
					userRole.setRoleType(RoleType.USER);
- 
 
 330 
					userRole.setUserId(user.getId());
- 
 
 331 
					userRoleRepository.persist(userRole);
- 
 
 332 
				}
- 
 
 333
- 
 
 334 
				UserRole retailerRole = null;
- 
 
 335 
				try{
- 
 
 336 
					retailerRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.RETAILER);
- 
 
 337 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 338 
					retailerRole = new UserRole();
- 
 
 339 
					retailerRole.setRoleType(RoleType.RETAILER);
- 
 
 340 
					retailerRole.setUserId(user.getId());
- 
 
 341 
					userRoleRepository.persist(retailerRole);
- 
 
 342 
				}
- 
 
 343
- 
 
 344 
				UserRole fofoRole = null;
- 
 
 345 
				try{
- 
 
 346 
					fofoRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.FOFO);
- 
 
 347 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
- 
 
 348 
					fofoRole = new UserRole();
- 
 
 349 
					fofoRole.setRoleType(RoleType.FOFO);
- 
 
 350 
					fofoRole.setUserId(user.getId());
- 
 
 351 
					userRoleRepository.persist(fofoRole);
- 
 
 352 
				}
292
353
293 
				if(foundRetailer){
 354 
				if(foundRetailer){
294 
					LOGGER.info("\n\n\n****retailer found\n\n\n");
 355 
					LOGGER.info("\n\n\n****retailer found\n\n\n");
295 
					PrivateDealUser privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
 356 
					PrivateDealUser privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
296 
					if(privateDealUser.getCounterId() == null){
 357 
					if(privateDealUser.getCounterId() == null){