| Line 23... |
Line 23... |
| 23 |
import com.spice.profitmandi.common.model.ProfitMandiConstants;
|
23 |
import com.spice.profitmandi.common.model.ProfitMandiConstants;
|
| 24 |
import com.spice.profitmandi.common.util.FileUtil;
|
24 |
import com.spice.profitmandi.common.util.FileUtil;
|
| 25 |
import com.spice.profitmandi.dao.entity.dtr.Document;
|
25 |
import com.spice.profitmandi.dao.entity.dtr.Document;
|
| 26 |
import com.spice.profitmandi.dao.entity.dtr.Retailer;
|
26 |
import com.spice.profitmandi.dao.entity.dtr.Retailer;
|
| 27 |
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
|
27 |
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
|
| - |
|
28 |
import com.spice.profitmandi.dao.entity.dtr.Shop;
|
| - |
|
29 |
import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
|
| 28 |
import com.spice.profitmandi.dao.entity.dtr.User;
|
30 |
import com.spice.profitmandi.dao.entity.dtr.User;
|
| 29 |
import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
|
31 |
import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
|
| 30 |
import com.spice.profitmandi.dao.entity.dtr.UserRole;
|
32 |
import com.spice.profitmandi.dao.entity.dtr.UserRole;
|
| 31 |
import com.spice.profitmandi.dao.entity.user.Address;
|
33 |
import com.spice.profitmandi.dao.entity.user.Address;
|
| 32 |
import com.spice.profitmandi.dao.entity.user.Cart;
|
34 |
import com.spice.profitmandi.dao.entity.user.Cart;
|
| Line 39... |
Line 41... |
| 39 |
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
|
41 |
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
|
| 40 |
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
|
42 |
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
|
| 41 |
import com.spice.profitmandi.dao.repository.dtr.Mongo;
|
43 |
import com.spice.profitmandi.dao.repository.dtr.Mongo;
|
| 42 |
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
|
44 |
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
|
| 43 |
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
|
45 |
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
|
| - |
|
46 |
import com.spice.profitmandi.dao.repository.dtr.ShopAddressRepository;
|
| - |
|
47 |
import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
|
| 44 |
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
|
48 |
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
|
| 45 |
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
|
49 |
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
|
| 46 |
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
|
50 |
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
|
| 47 |
import com.spice.profitmandi.dao.repository.user.AddressRepository;
|
51 |
import com.spice.profitmandi.dao.repository.user.AddressRepository;
|
| 48 |
import com.spice.profitmandi.dao.repository.user.CartRepository;
|
52 |
import com.spice.profitmandi.dao.repository.user.CartRepository;
|
| Line 90... |
Line 94... |
| 90 |
|
94 |
|
| 91 |
@Autowired
|
95 |
@Autowired
|
| 92 |
private CounterRepository counterRepository;
|
96 |
private CounterRepository counterRepository;
|
| 93 |
|
97 |
|
| 94 |
@Autowired
|
98 |
@Autowired
|
| - |
|
99 |
private ShopRepository shopRepository;
|
| - |
|
100 |
|
| - |
|
101 |
@Autowired
|
| - |
|
102 |
private ShopAddressRepository shopAddressRepository;
|
| - |
|
103 |
|
| - |
|
104 |
@Autowired
|
| 95 |
private Mongo mongoClient;
|
105 |
private Mongo mongoClient;
|
| 96 |
|
106 |
|
| 97 |
|
107 |
|
| 98 |
private static final Logger LOGGER = LoggerFactory.getLogger(MigrationUtil.class);
|
108 |
private static final Logger LOGGER = LoggerFactory.getLogger(MigrationUtil.class);
|
| 99 |
|
109 |
|
| Line 327... |
Line 337... |
| 327 |
retailerRegisteredAddress.setRetailerId(retailer.getId());
|
337 |
retailerRegisteredAddress.setRetailerId(retailer.getId());
|
| 328 |
retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
|
338 |
retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
|
| 329 |
}
|
339 |
}
|
| 330 |
|
340 |
|
| 331 |
|
341 |
|
| - |
|
342 |
List<Shop> shops = shopRepository.selectByRetailerId(retailer.getId());
|
| - |
|
343 |
if(shops.isEmpty()){
|
| - |
|
344 |
Shop shop = new Shop();
|
| - |
|
345 |
shop.setName(retailer.getName());
|
| - |
|
346 |
shop.setAddressId(retailerAddress.getId());
|
| - |
|
347 |
shop.setDocumentId(retailer.getDocumentId());
|
| - |
|
348 |
shop.setRetailerId(retailer.getId());
|
| - |
|
349 |
shopRepository.persist(shop);
|
| - |
|
350 |
ShopAddress shopAddress = new ShopAddress();
|
| - |
|
351 |
shopAddress.setAddressId(retailerAddress.getId());
|
| - |
|
352 |
shopAddress.setShopId(shop.getId());
|
| - |
|
353 |
shopAddressRepository.persist(shopAddress);
|
| - |
|
354 |
}
|
| - |
|
355 |
|
| 332 |
UserAccounts saholicUserAccounts = null;
|
356 |
UserAccounts saholicUserAccounts = null;
|
| 333 |
try{
|
357 |
try{
|
| 334 |
saholicUserAccounts = userAccountRepository.selectByUserIdRetailerIdAccountType(user.getId(), retailer.getId(), AccountType.saholic);
|
358 |
saholicUserAccounts = userAccountRepository.selectByUserIdRetailerIdAccountType(user.getId(), retailer.getId(), AccountType.saholic);
|
| 335 |
}catch(ProfitMandiBusinessException profitMandiBusinessException){
|
359 |
}catch(ProfitMandiBusinessException profitMandiBusinessException){
|
| 336 |
saholicUserAccounts = new UserAccounts();
|
360 |
saholicUserAccounts = new UserAccounts();
|
| Line 382... |
Line 406... |
| 382 |
try{
|
406 |
try{
|
| 383 |
privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
|
407 |
privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
|
| 384 |
}catch(ProfitMandiBusinessException profitMandiBusinessException){
|
408 |
}catch(ProfitMandiBusinessException profitMandiBusinessException){
|
| 385 |
LOGGER.error("PrivateDealUser not found : ", profitMandiBusinessException);
|
409 |
LOGGER.error("PrivateDealUser not found : ", profitMandiBusinessException);
|
| 386 |
}
|
410 |
}
|
| - |
|
411 |
|
| 387 |
//= privateDealUserRepository.selectById(saholicUser.getId());
|
412 |
//= privateDealUserRepository.selectById(saholicUser.getId());
|
| 388 |
if(privateDealUser == null){
|
413 |
if(privateDealUser == null){
|
| 389 |
Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
|
414 |
Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
|
| 390 |
this.createPrivateDealUser(saholicUser.getId(), counterId);
|
415 |
this.createPrivateDealUser(saholicUser.getId(), counterId);
|
| 391 |
}else{
|
416 |
}else{
|
| 392 |
if(privateDealUser.getCounterId() == null){
|
417 |
if(privateDealUser.getCounterId() == null){
|
| 393 |
Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
|
418 |
Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
|
| 394 |
privateDealUser.setCounterId(counterId);
|
419 |
privateDealUser.setCounterId(counterId);
|
| - |
|
420 |
privateDealUser.setFofo(true);
|
| 395 |
privateDealUserRepository.persist(privateDealUser);
|
421 |
privateDealUserRepository.persist(privateDealUser);
|
| 396 |
}
|
422 |
}
|
| 397 |
}
|
423 |
}
|
| 398 |
}else{
|
424 |
}else{
|
| 399 |
LOGGER.info("retailer not found");
|
425 |
LOGGER.info("retailer not found");
|
| Line 413... |
Line 439... |
| 413 |
|
439 |
|
| 414 |
|
440 |
|
| 415 |
if(privateDealUser != null){
|
441 |
if(privateDealUser != null){
|
| 416 |
//LOGGER.info("PrivateDealUser found with id [{}]", saholicUser.getId());
|
442 |
//LOGGER.info("PrivateDealUser found with id [{}]", saholicUser.getId());
|
| 417 |
privateDealUser.setCounterId(counterId);
|
443 |
privateDealUser.setCounterId(counterId);
|
| - |
|
444 |
privateDealUser.setFofo(true);
|
| 418 |
privateDealUserRepository.update(privateDealUser);
|
445 |
privateDealUserRepository.update(privateDealUser);
|
| 419 |
}else{
|
446 |
}else{
|
| 420 |
LOGGER.info("PrivateDealUser not found with id [{}]", saholicUser.getId());
|
447 |
LOGGER.info("PrivateDealUser not found with id [{}]", saholicUser.getId());
|
| 421 |
this.createPrivateDealUser(saholicUser.getId(), counterId);
|
448 |
this.createPrivateDealUser(saholicUser.getId(), counterId);
|
| 422 |
}
|
449 |
}
|
| Line 442... |
Line 469... |
| 442 |
PrivateDealUser privateDealUser = new PrivateDealUser();
|
469 |
PrivateDealUser privateDealUser = new PrivateDealUser();
|
| 443 |
privateDealUser.setActive(true);
|
470 |
privateDealUser.setActive(true);
|
| 444 |
privateDealUser.setBulkShipmentAmountLimit(50000);
|
471 |
privateDealUser.setBulkShipmentAmountLimit(50000);
|
| 445 |
privateDealUser.setId(retailerId);
|
472 |
privateDealUser.setId(retailerId);
|
| 446 |
privateDealUser.setCounterId(counterId);
|
473 |
privateDealUser.setCounterId(counterId);
|
| 447 |
//privateDealUser.setFofo(true);
|
474 |
privateDealUser.setFofo(true);
|
| 448 |
privateDealUserRepository.persist(privateDealUser);
|
475 |
privateDealUserRepository.persist(privateDealUser);
|
| 449 |
}
|
476 |
}
|
| 450 |
|
477 |
|
| 451 |
private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
|
478 |
private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
|
| 452 |
if(gstNumber != null && !gstNumber.isEmpty()){
|
479 |
if(gstNumber != null && !gstNumber.isEmpty()){
|