WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/user/RetailerServiceImpl.java

 import org.springframework.stereotype.Component;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomAddress;
 import com.spice.profitmandi.common.model.CustomShop;
+import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.UpdateRetailerRequest;
+import com.spice.profitmandi.common.util.StringUtils;
+import com.spice.profitmandi.common.util.Utils;
+import com.spice.profitmandi.dao.entity.dtr.DistrictMaster;
 import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
 import com.spice.profitmandi.dao.entity.dtr.Shop;
 import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.UserAccount;
 import com.spice.profitmandi.dao.entity.dtr.UserRole;
+import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.fofo.FofoStoreSequenceGeneration;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.entity.user.Cart;
+import com.spice.profitmandi.dao.entity.user.Counter;
+import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
+import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressMapping;
 import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
 import com.spice.profitmandi.dao.enumuration.dtr.RetailerType;
 import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
+import com.spice.profitmandi.dao.repository.dtr.DistrictMasterRepository;
 import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
+import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.FofoStoreSequenceGenerationRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.dtr.ShopAddressRepository;
 import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.CartRepository;
+import com.spice.profitmandi.dao.repository.user.CounterRepository;
+import com.spice.profitmandi.dao.repository.user.PrivateDealUserAddressMappingRepository;
+import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
+import in.shop2020.model.v1.inventory.StateInfo;
 import in.shop2020.model.v1.user.CartStatus;
 @Component
 public class RetailerServiceImpl implements RetailerService {
 	@Autowired
 	private DocumentRepository documentRepository;
 	@Autowired
+	private PrivateDealUserRepository privateDealUserRepository;
+	@Autowired
+	private PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
+	@Autowired
+	private CounterRepository counterRepository;
+	@Autowired
 	@Qualifier("userUserRepository")
 	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
+	@Autowired
+	private DistrictMasterRepository districtMasterRepository;
+	@Autowired
+	private FofoStoreRepository fofoStoreRepository;
+	@Autowired
+	private FofoStoreSequenceGenerationRepository fofoStoreSequenceGenerationRepository;
 	@Override
 	public Map<String, Object> getByEmailIdOrMobileNumber(String emailIdOrMobileNumber)
 			throws ProfitMandiBusinessException {
 		User user = null;
 		try{
 			user = userRepository.selectByEmailIdOrMobileNumber(emailIdOrMobileNumber);
 		}catch(ProfitMandiBusinessException profitMandiBusinessException){
+		}
 		if(user == null){
+			try{
-			user = userRepository.selectBySecondryEmailId(emailIdOrMobileNumber);
+				user = userRepository.selectBySecondryEmailId(emailIdOrMobileNumber);
+			}catch(ProfitMandiBusinessException profitMandiBusinessException){
+			}
+		}
-		List<UserRole> userRoles = userRoleRepository.selectByUserId(user.getId());
 		Map<String, Object> map = new HashMap<>();
-		map.put("user", user);
-		//map.put("retailer", retailer);
+		map.put("stateNames", Utils.getAllStateNames());
+		if(user != null){
-		map.put("userRoles", this.toString(userRoles));
-		try{
-			int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
+			List<UserRole> userRoles = userRoleRepository.selectByUserId(user.getId());
-			Retailer retailer = retailerRepository.selectById(retailerId);
+			map.put("userRoles", userRoles);
+			map.put("user", user);
-			map.put("retailer", retailer);
+			//map.put("retailer", retailer);
+			map.put("fofoRole", this.containsRoleType(userRoles, RoleType.FOFO));
+			map.put("userRoleNames", this.toString(userRoles));
 			try{
+				int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
+				Retailer retailer = retailerRepository.selectById(retailerId);
+				map.put("retailer", retailer);
+				if(this.containsRoleType(userRoles, RoleType.FOFO)){
+					try{
+						FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(retailerId);
+						map.put("fofoStore", fofoStore);
+					}catch(ProfitMandiBusinessException profitMandiBusinessException){
+						LOGGER.error("FofoStore code not found");
+					}
+				}
+				try{
+					PrivateDealUser privateDealUser = privateDealUserRepository.selectById(retailer.getId());
+					if(privateDealUser.getCounterId() != null){
+						Counter counter = counterRepository.selectById(privateDealUser.getCounterId());
+						map.put("gstNumber", counter.getGstin());
+					}
+				}catch(ProfitMandiBusinessException profitMandiBusinessException){
+					LOGGER.error("PrivateDealUser not found");
+				}
+				try{
-				int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId());
+					int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId());
-				Address retailerAddress = addressRepository.selectById(retailerAddressId);
+					Address retailerAddress = addressRepository.selectById(retailerAddressId);
-				map.put("retailerAddress", retailerAddress);
+					map.put("retailerAddress", retailerAddress);
+					StateInfo stateInfo = null;
+					try {
+						stateInfo = Utils.getStateInfo(retailerAddress.getState());
+					} catch (Exception e) {
+						e.printStackTrace();
+						//throw new ProfitMandiBusinessException();
+					}
+					List<DistrictMaster> districtMasters = districtMasterRepository.selectByStateShortName(stateInfo.getShortName());
+					map.put("districtMasters", districtMasters);
-				List<Shop> shops = shopRepository.selectByRetailerId(retailer.getId());
+					List<Shop> shops = shopRepository.selectByRetailerId(retailer.getId());
-				map.put("shops", shops);
+		     		map.put("shops", shops);
-				this.addAddress(shops);
+					this.addAddress(shops);
+				}catch(ProfitMandiBusinessException profitMandiBusinessException){
+					LOGGER.error("Retailer Registered Address not found");
+				}
 			}catch(ProfitMandiBusinessException profitMandiBusinessException){
-				LOGGER.error("Retailer Registered Address not found");
+				LOGGER.error("Retailer not found in user_account");
+			}
-		}catch(ProfitMandiBusinessException profitMandiBusinessException){
-			LOGGER.error("Retailer not found in user_account");
+		}
 		return map;
+	}
+	private boolean containsRoleType(List<UserRole> userRoles, RoleType roleType){
+		for(UserRole userRole : userRoles){
+			if(userRole.getRoleType() == roleType){
+				return true;
+			}
+		}
+		return false;
+	}
+	private List<UserRole> addRole(List<UserRole> userRoles, int userId, RoleType roleType){
+		if(userRoles == null){
+			userRoles = new ArrayList<>();
+		}
+		if(!this.containsRoleType(userRoles, roleType)){
+			UserRole userRole = new UserRole();
+			userRole.setUserId(userId);
+			userRole.setRoleType(roleType);
+			try {
+				userRoleRepository.persist(userRole);
+			} catch (ProfitMandiBusinessException e) {
+				LOGGER.error("UserRole is already exist");
+			}
+			userRoles.add(userRole);
+		}
+		return userRoles;
+	}
 	@SuppressWarnings("unchecked")
 	@Override
 	public Map<String, Object> updateRetailerDetails(UpdateRetailerRequest updateRetailerRequest)
 			throws ProfitMandiBusinessException {
 		Map<String, Object> map = this.getByEmailIdOrMobileNumber(updateRetailerRequest.getEmailIdOrMobileNumber());
 		User user = (User)map.get("user");
+		user = this.createUser(user, updateRetailerRequest);
+		map.put("user", user);
+		List<UserRole> userRoles = (List<UserRole>)map.get("userRoles");
+		userRoles = this.addRole(userRoles, user.getId(), RoleType.USER);
 		Retailer retailer = (Retailer)map.get("retailer");
-		if(retailer == null){
-			retailer = this.updateRetailer(user, retailer, updateRetailerRequest);
+		retailer = this.updateRetailer(user, retailer, updateRetailerRequest);
-			map.put("retailer", retailer);
+		map.put("retailer", retailer);
+		userRoles = this.addRole(userRoles, user.getId(), RoleType.RETAILER);
+		if(updateRetailerRequest.isFofo()){
+			userRoles = this.addRole(userRoles, user.getId(), RoleType.FOFO);
+		}
+		if(this.containsRoleType(userRoles, RoleType.FOFO)){
+		}
+		map.put("userRoles", userRoles);
+		map.put("userRoleNames", this.toString(userRoles));
 		Address retailerAddress = (Address)map.get("retailerAddress");
-		if(retailerAddress == null){
-			retailerAddress = this.updateRetailerAddress(retailerAddress, updateRetailerRequest.getAddress(), retailer.getId());
+		retailerAddress = this.updateRetailerAddress(retailerAddress, updateRetailerRequest.getAddress(), retailer.getId());
-			map.put("retailerAddress", retailerAddress);
+		map.put("retailerAddress", retailerAddress);
+		if(updateRetailerRequest.isFofo()){
+			this.createFofoStoreCodeByUserId(user.getId(), updateRetailerRequest.getDistrictName(), retailerAddress.getState());
+		}
+		this.createPrivateDealUser(user, updateRetailerRequest.isFofo(), updateRetailerRequest.getGstNumber(), retailer, retailerAddress.getId());
+		map.put("gstNumber", updateRetailerRequest.getGstNumber());
+		this.updateSaholicUser(retailer.getId(), retailerAddress.getId());
 		List<Shop> shops = (List<Shop>)map.get("shops");
 		if(shops == null){
 			shops = new ArrayList<>();
 			map.put("shops", shops);
+		}
 		this.updateRetailerShops(shops, updateRetailerRequest.getShops(), retailer.getId(), retailerAddress);
 		return map;
+	}
+	private User createUser(User user, UpdateRetailerRequest updateRetailerRequest){
+		if(user == null){
+			user = new User();
+			user.setCity("");
+			user.setPinCode(0);
+			user.setState("");
+			user.setPassword("");
+			user.setMobile_verified(false);
+			user.setReferral_url("");
+			user.setGroup_id(1);
+			user.setStatus(1);
+			user.setActivated(true);
+			user.setCreateTimestamp(LocalDateTime.now());
+			user.setUpdateTimestamp(LocalDateTime.now());
+			userRepository.persist(user);
+		}
+		user.setFirstName(updateRetailerRequest.getUserFirstName());
+		user.setLastName(updateRetailerRequest.getUserLastName());
+		user.setMobileNumber(updateRetailerRequest.getUserMobileNumber());
+		user.setEmailId(updateRetailerRequest.getUserEmailId());
+		user.setUsername(updateRetailerRequest.getUserEmailId());
+		return user;
+	}
 	private int createSaholicUser(User user, String retailerName){
 		com.spice.profitmandi.dao.entity.user.User saholicUser = null;
 		try {
 			saholicUser = userUserRepository.selectByEmailId(user.getEmailId());
 		}catch (ProfitMandiBusinessException e) {
 		if(retailer == null){
 			int saholicUserId = this.createSaholicUser(user, updateRetailerRequest.getName());
 			retailer = new Retailer();
 			retailer.setId(saholicUserId);
+		}
+		retailer.setActive(updateRetailerRequest.isActive());
 		this.createRole(user.getId(), RoleType.RETAILER);
 		retailer.setName(updateRetailerRequest.getName());
 		retailer.setNumber(updateRetailerRequest.getNumber());
 		if(updateRetailerRequest.getNumber() == null || updateRetailerRequest.getNumber().isEmpty()){
 			retailer.setType(RetailerType.UNREGISTERED_SHOP);
+		}
 		retailerRepository.persist(retailer);
 		return retailer;
+	}
+	private void updateSaholicUser(int retailerId, int retailerAddressId){
+		try {
+			com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(retailerId);
+			user.setAddressId(retailerAddressId);
+			userUserRepository.persist(user);
+		} catch (ProfitMandiBusinessException e) {
+		}
+	}
+	private void createPrivateDealUser(User user, boolean fofo, String gstNumber, Retailer retailer, int retailerAddressId){
+		PrivateDealUser privateDealUser = null;
+		try{
+			privateDealUser = privateDealUserRepository.selectById(retailer.getId());
+		}catch(ProfitMandiBusinessException profitMandiBusinessException){
+			LOGGER.error("PrivateDealUser not found");
+		}
+		 //= privateDealUserRepository.selectById(saholicUser.getId());
+		if(privateDealUser == null){
+			Integer counterId = this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(), retailer.getName(), retailerAddressId);
+			this.createPrivateDealUser(retailer.getId(), counterId, fofo);
+		}else{
+			if(privateDealUser.getCounterId() == null){
+				Integer counterId = this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(), retailer.getName(), retailerAddressId);
+				privateDealUser.setCounterId(counterId);
+				privateDealUser.setFofo(fofo);
+				privateDealUserRepository.persist(privateDealUser);
+			}else{
+				Counter counter = null;
+				try{
+					counter = counterRepository.selectById(privateDealUser.getCounterId());
+				}catch(ProfitMandiBusinessException profitMandiBusinessException){
+					LOGGER.error("Counter not found with id [{}]", privateDealUser.getCounterId());
+				}
+				if(counter == null){
+					this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(), retailer.getName(), retailerAddressId);
+				}else{
+					counter.setGstin(gstNumber);
+					counterRepository.persist(counter);
+				}
+				privateDealUser.setFofo(fofo);
+				privateDealUserRepository.persist(privateDealUser);
+			}
+		}
+		PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
+		privateDealUserAddressMapping.setUserId(retailer.getId());
+		privateDealUserAddressMapping.setAddressId(retailerAddressId);
+		privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
+	}
+	//Specifically set isFofo to true that has to be used by old system
+	private void createPrivateDealUser(int retailerId, int counterId, boolean fofo){
+		PrivateDealUser privateDealUser = new PrivateDealUser();
+		privateDealUser.setActive(true);
+		privateDealUser.setBulkShipmentAmountLimit(fofo ? 1000000 : 50000);
+		privateDealUser.setId(retailerId);
+		privateDealUser.setCounterId(counterId);
+		privateDealUser.setFofo(fofo);
+		privateDealUserRepository.persist(privateDealUser);
+	}
+	private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
+		if(gstNumber != null && !gstNumber.isEmpty()){
+			Counter counter = new Counter();
+			counter.setEmailId(emailId);
+			counter.setGstin(gstNumber);
+			counter.setMobileNumber(mobileNumber);
+			counter.setName(name);
+			counter.setAddressId(addressId);
+			counterRepository.persist(counter);
+			return counter.getId();
+		}else{
+			return null;
+		}
+	}
 	private void createRole(int userId, RoleType roleType){
 		if(!userRoleRepository.isExistByUserIdAndType(userId, roleType)){
 			UserRole userRole = new UserRole();
 			userRole.setUserId(userId);
 			userRole.setRoleType(roleType);
 				shopAddress.setShopId(shop.getId());
+			}
 			shopAddressRepository.persist(shopAddress);
 		}else{
 			Address address = addressRepository.selectById(shop.getAddressId());
+			LOGGER.info("found address : {}", address);
 			CustomAddress customAddress = customShop.getAddress();
+			LOGGER.info("requested address : {}", customAddress);
-			if(address.getName().equals(customAddress.getName()) &&
+			if(!(address.getName().equals(customAddress.getName()) &&
 				address.getLine1().equals(customAddress.getLine1()) &&
 				address.getLine2().equals(customAddress.getLine2())	&&
 				address.getCity().equals(customAddress.getCity()) &&
 				address.getPinCode().equals(customAddress.getPinCode()) &&
-				address.getState().equals(customAddress.getState())){
+				address.getState().equals(customAddress.getState()))){
 				this.updateAddress(address, customShop.getAddress());
 			}else{
 				address = new Address();
 				ShopAddress shopAddress = shopAddressRepository.selectByShopId(shop.getId());
 				this.updateAddress(address, customAddress);
 			};
 		};
 		Set<String> userRoleStrings = userRoles.stream().map(userRoleToRoleNameFunction).collect(Collectors.toSet());
 		return String.join(", ", userRoleStrings);
+	}
+	@Override
+	public void createFofoStoreCodeByUserId(int userId, String districtName, String stateName) throws ProfitMandiBusinessException {
+		User user = userRepository.selectById(userId);
+		// = userAccountRepository.selectRetailerIdByUserId(user.getId());
+		UserAccount userAccounts = userAccountRepository.selectSaholicByUserId(user.getId());
+		Retailer retailer = retailerRepository.selectById(userAccounts.getAccountKey());
+		try{
+			userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.FOFO);
+		}catch(ProfitMandiBusinessException profitMandiBusinessException){
+			throw new ProfitMandiBusinessException(ProfitMandiConstants.USER_ID, user.getId(), "USR_1013");
+		}
+		boolean foundFofoStore = false;
+		try{
+			fofoStoreRepository.selectByRetailerId(retailer.getId());
+			foundFofoStore = true;
+		}catch (ProfitMandiBusinessException profitMandiBusinessException) {
+		}
+		if(foundFofoStore){
+			throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, retailer.getId(), "USR_1014");
+		}
+		int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId());
+		Address retailerAddress = addressRepository.selectById(retailerAddressId);
+		StateInfo stateInfo = null;
+		try {
+			stateInfo = Utils.getStateInfo(retailerAddress.getState());
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			//throw new ProfitMandiBusinessException();
+		}
+		DistrictMaster districtMaster = districtMasterRepository.selectByNameAndStateShortName(districtName, stateInfo.getShortName());
+		FofoStoreSequenceGeneration fofoStoreSequenceGeneration = null;
+		boolean foundFofoStoreSequence = false;
+		try{
+			fofoStoreSequenceGeneration = fofoStoreSequenceGenerationRepository.selectByStateShortName(stateInfo.getShortName());
+			foundFofoStoreSequence = true;
+		}catch(ProfitMandiBusinessException profitMandiBusinessException){
+			fofoStoreSequenceGeneration = new FofoStoreSequenceGeneration();
+			fofoStoreSequenceGeneration.setSequence(1);
+			fofoStoreSequenceGeneration.setStateShortName(stateInfo.getShortName());
+			fofoStoreSequenceGenerationRepository.persist(fofoStoreSequenceGeneration);
+		}
+		FofoStore fofoStore = new FofoStore();
+		fofoStore.setId(retailer.getId());
+		String fofoStoreCode = StringUtils.generateFofoStoreSequence(districtMaster.getStateShortName() + districtMaster.getShortName(), fofoStoreSequenceGeneration.getSequence());
+		if(foundFofoStoreSequence){
+			fofoStoreSequenceGeneration.setSequence(fofoStoreSequenceGeneration.getSequence() + 1);
+			fofoStoreSequenceGenerationRepository.persist(fofoStoreSequenceGeneration);
+		}
+		fofoStore.setCode(fofoStoreCode);
+		fofoStoreRepository.persist(fofoStore);
+	}
+	@Override
+	public List<DistrictMaster> getAllDistrictMaster(String stateName) {
+		StateInfo stateInfo = null;
+		try {
+			stateInfo = Utils.getStateInfo(stateName);
+		} catch (Exception e) {
+			e.printStackTrace();
+			//throw new ProfitMandiBusinessException();
+		}
+		return districtMasterRepository.selectByStateShortName(stateInfo.getShortName());
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/user/RetailerServiceImpl.java – Rev 23300 → 23329