Subversion Repositories SmartDukaan

Rev

Rev 27861 | Rev 28024 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
22980 ashik.ali 1 
package com.spice.profitmandi.service.user;
2 
 
26528 amit.gupta 3 
import java.nio.charset.StandardCharsets;
23300 amit.gupta 4 
import java.time.LocalDateTime;
23060 ashik.ali 5 
import java.util.ArrayList;
27877 amit.gupta 6 
import java.util.Arrays;
22980 ashik.ali 7 
import java.util.HashMap;
23781 ashik.ali 8 
import java.util.HashSet;
22980 ashik.ali 9 
import java.util.List;
10 
import java.util.Map;
11 
import java.util.Set;
12 
import java.util.function.Function;
13 
import java.util.stream.Collectors;
26962 amit.gupta 14 
import java.util.stream.Stream;
22980 ashik.ali 15 
 
23781 ashik.ali 16 
import org.apache.logging.log4j.LogManager;
23568 govind 17 
import org.apache.logging.log4j.Logger;
22980 ashik.ali 18 
import org.springframework.beans.factory.annotation.Autowired;
23043 ashik.ali 19 
import org.springframework.beans.factory.annotation.Qualifier;
24349 amit.gupta 20 
import org.springframework.cache.annotation.Cacheable;
22980 ashik.ali 21 
import org.springframework.stereotype.Component;
22 
 
26528 amit.gupta 23 
import com.google.common.hash.Hashing;
22980 ashik.ali 24 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
23025 ashik.ali 25 
import com.spice.profitmandi.common.model.CustomAddress;
23509 amit.gupta 26 
import com.spice.profitmandi.common.model.CustomRetailer;
23025 ashik.ali 27 
import com.spice.profitmandi.common.model.CustomShop;
23781 ashik.ali 28 
import com.spice.profitmandi.common.model.MapWrapper;
23329 ashik.ali 29 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
23025 ashik.ali 30 
import com.spice.profitmandi.common.model.UpdateRetailerRequest;
23329 ashik.ali 31 
import com.spice.profitmandi.common.util.StringUtils;
32 
import com.spice.profitmandi.common.util.Utils;
33 
import com.spice.profitmandi.dao.entity.dtr.DistrictMaster;
22980 ashik.ali 34 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
23043 ashik.ali 35 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
23781 ashik.ali 36 
import com.spice.profitmandi.dao.entity.dtr.Role;
22980 ashik.ali 37 
import com.spice.profitmandi.dao.entity.dtr.Shop;
38 
import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
39 
import com.spice.profitmandi.dao.entity.dtr.User;
23269 ashik.ali 40 
import com.spice.profitmandi.dao.entity.dtr.UserAccount;
22980 ashik.ali 41 
import com.spice.profitmandi.dao.entity.dtr.UserRole;
23365 ashik.ali 42 
import com.spice.profitmandi.dao.entity.fofo.FofoPartnerPaymentOption;
23329 ashik.ali 43 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
23365 ashik.ali 44 
import com.spice.profitmandi.dao.entity.fofo.PaymentOption;
24349 amit.gupta 45 
import com.spice.profitmandi.dao.entity.inventory.State;
22980 ashik.ali 46 
import com.spice.profitmandi.dao.entity.user.Address;
23043 ashik.ali 47 
import com.spice.profitmandi.dao.entity.user.Cart;
23329 ashik.ali 48 
import com.spice.profitmandi.dao.entity.user.Counter;
26522 amit.gupta 49 
import com.spice.profitmandi.dao.entity.user.LoginRequestResponseModel;
23329 ashik.ali 50 
import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
51 
import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressMapping;
23063 ashik.ali 52 
import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
23106 ashik.ali 53 
import com.spice.profitmandi.dao.enumuration.dtr.RetailerType;
23136 ashik.ali 54 
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
23365 ashik.ali 55 
import com.spice.profitmandi.dao.enumuration.fofo.PaymentOptionType;
23329 ashik.ali 56 
import com.spice.profitmandi.dao.repository.dtr.DistrictMasterRepository;
22980 ashik.ali 57 
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
23329 ashik.ali 58 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
22980 ashik.ali 59 
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
60 
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
23781 ashik.ali 61 
import com.spice.profitmandi.dao.repository.dtr.RoleRepository;
22980 ashik.ali 62 
import com.spice.profitmandi.dao.repository.dtr.ShopAddressRepository;
63 
import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
64 
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
65 
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
66 
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
23365 ashik.ali 67 
import com.spice.profitmandi.dao.repository.fofo.FofoPartnerPaymentOptionRepository;
68 
import com.spice.profitmandi.dao.repository.fofo.PaymentOptionRepository;
24349 amit.gupta 69 
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
22980 ashik.ali 70 
import com.spice.profitmandi.dao.repository.user.AddressRepository;
23043 ashik.ali 71 
import com.spice.profitmandi.dao.repository.user.CartRepository;
23329 ashik.ali 72 
import com.spice.profitmandi.dao.repository.user.CounterRepository;
73 
import com.spice.profitmandi.dao.repository.user.PrivateDealUserAddressMappingRepository;
74 
import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
27877 amit.gupta 75 
import com.spice.profitmandi.service.offers.PartnerCriteria;
22980 ashik.ali 76 
 
23329 ashik.ali 77 
import in.shop2020.model.v1.inventory.StateInfo;
23043 ashik.ali 78 
import in.shop2020.model.v1.user.CartStatus;
79 
 
22980 ashik.ali 80 
@Component
81 
public class RetailerServiceImpl implements RetailerService {
23955 govind 82 
 
23568 govind 83 
	private static final Logger LOGGER = LogManager.getLogger(RetailerServiceImpl.class);
23955 govind 84 
 
22980 ashik.ali 85 
	@Autowired
86 
	private RetailerRepository retailerRepository;
23955 govind 87 
 
22980 ashik.ali 88 
	@Autowired
89 
	private UserAccountRepository userAccountRepository;
23955 govind 90 
 
22980 ashik.ali 91 
	@Autowired
92 
	private UserRepository userRepository;
23955 govind 93 
 
22980 ashik.ali 94 
	@Autowired
23043 ashik.ali 95 
	private CartRepository cartRepository;
23955 govind 96 
 
23043 ashik.ali 97 
	@Autowired
22980 ashik.ali 98 
	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
23955 govind 99 
 
22980 ashik.ali 100 
	@Autowired
101 
	private AddressRepository addressRepository;
23955 govind 102 
 
22980 ashik.ali 103 
	@Autowired
104 
	private ShopRepository shopRepository;
23955 govind 105 
 
22980 ashik.ali 106 
	@Autowired
107 
	private ShopAddressRepository shopAddressRepository;
23955 govind 108 
 
22980 ashik.ali 109 
	@Autowired
110 
	private UserRoleRepository userRoleRepository;
23955 govind 111 
 
22980 ashik.ali 112 
	@Autowired
113 
	private DocumentRepository documentRepository;
23955 govind 114 
 
23043 ashik.ali 115 
	@Autowired
23329 ashik.ali 116 
	private PrivateDealUserRepository privateDealUserRepository;
23955 govind 117 
 
23329 ashik.ali 118 
	@Autowired
119 
	private PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
23955 govind 120 
 
23329 ashik.ali 121 
	@Autowired
122 
	private CounterRepository counterRepository;
25295 amit.gupta 123 
 
24349 amit.gupta 124 
	@Autowired
125 
	private StateRepository stateRepository;
23955 govind 126 
 
23329 ashik.ali 127 
	@Autowired
23043 ashik.ali 128 
	@Qualifier("userUserRepository")
129 
	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
23955 govind 130 
 
23329 ashik.ali 131 
	@Autowired
132 
	private DistrictMasterRepository districtMasterRepository;
23955 govind 133 
 
23329 ashik.ali 134 
	@Autowired
135 
	private FofoStoreRepository fofoStoreRepository;
23955 govind 136 
 
23329 ashik.ali 137 
	@Autowired
23365 ashik.ali 138 
	private PaymentOptionRepository paymentOptionRepository;
23955 govind 139 
 
23365 ashik.ali 140 
	@Autowired
141 
	private FofoPartnerPaymentOptionRepository fofoPartnerPaymentOptionRepository;
23955 govind 142 
 
23842 ashik.ali 143 
	@Autowired
144 
	private RoleRepository roleRepository;
23955 govind 145 
 
22980 ashik.ali 146 
	@Override
147 
	public Map<String, Object> getByEmailIdOrMobileNumber(String emailIdOrMobileNumber)
148 
			throws ProfitMandiBusinessException {
23202 ashik.ali 149 
		User user = null;
23955 govind 150 
		try {
23202 ashik.ali 151 
			user = userRepository.selectByEmailIdOrMobileNumber(emailIdOrMobileNumber);
23955 govind 152 
		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
153 
 
23202 ashik.ali 154 
		}
23955 govind 155 
		if (user == null) {
156 
			try {
23329 ashik.ali 157 
				user = userRepository.selectBySecondryEmailId(emailIdOrMobileNumber);
23955 govind 158 
			} catch (ProfitMandiBusinessException profitMandiBusinessException) {
159 
 
23329 ashik.ali 160 
			}
23202 ashik.ali 161 
		}
22980 ashik.ali 162 
		Map<String, Object> map = new HashMap<>();
25295 amit.gupta 163 
		map.put("stateNames", stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
23955 govind 164 
 
165 
		if (user != null) {
166 
 
23329 ashik.ali 167 
			List<UserRole> userRoles = userRoleRepository.selectByUserId(user.getId());
23955 govind 168 
 
23781 ashik.ali 169 
			Role role = roleRepository.selectByName(RoleType.FOFO.toString());
23955 govind 170 
 
23329 ashik.ali 171 
			map.put("userRoles", userRoles);
172 
			map.put("user", user);
23955 govind 173 
			// map.put("retailer", retailer);
23781 ashik.ali 174 
			map.put("fofoRole", this.containsRoleType(userRoles, role.getId()));
23955 govind 175 
 
23329 ashik.ali 176 
			map.put("userRoleNames", this.toString(userRoles));
23955 govind 177 
			try {
23329 ashik.ali 178 
				int retailerId = userAccountRepository.selectRetailerIdByUserId(user.getId());
179 
				Retailer retailer = retailerRepository.selectById(retailerId);
23955 govind 180 
 
23329 ashik.ali 181 
				map.put("retailer", retailer);
23955 govind 182 
 
183 
				if (this.containsRoleType(userRoles, role.getId())) {
184 
					try {
23329 ashik.ali 185 
						FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(retailerId);
186 
						map.put("fofoStore", fofoStore);
23955 govind 187 
						// map.put("counterSize", fofoStore.getCounterSize().toString());
188 
						// LOGGER.info("fofoStore" + fofoStore);
189 
					} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 190 
						LOGGER.error("FofoStore code not found");
191 
					}
192 
				}
23955 govind 193 
 
194 
				try {
23329 ashik.ali 195 
					PrivateDealUser privateDealUser = privateDealUserRepository.selectById(retailer.getId());
23955 govind 196 
					if (privateDealUser.getCounterId() != null) {
23329 ashik.ali 197 
						Counter counter = counterRepository.selectById(privateDealUser.getCounterId());
198 
						map.put("gstNumber", counter.getGstin());
23955 govind 199 
						// LOGGER.info("gstNumber" + counter.getGstin());
23329 ashik.ali 200 
					}
23955 govind 201 
				} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 202 
					LOGGER.error("PrivateDealUser not found");
203 
				}
23955 govind 204 
				try {
205 
					int retailerAddressId = retailerRegisteredAddressRepository
206 
							.selectAddressIdByRetailerId(retailer.getId());
23329 ashik.ali 207 
					Address retailerAddress = addressRepository.selectById(retailerAddressId);
208 
					map.put("retailerAddress", retailerAddress);
24349 amit.gupta 209 
					State state = stateRepository.selectByName(retailerAddress.getState());
23955 govind 210 
					// LOGGER.info("retailerAddress.." + retailerAddress);
211 
					List<DistrictMaster> districtMasters = districtMasterRepository
24349 amit.gupta 212 
							.selectByStateShortName(state.getShortName());
23329 ashik.ali 213 
					map.put("districtMasters", districtMasters);
23955 govind 214 
					// LOGGER.info("districtMasters" + districtMasters);
23329 ashik.ali 215 
					List<Shop> shops = shopRepository.selectByRetailerId(retailer.getId());
23955 govind 216 
					map.put("shops", shops);
23329 ashik.ali 217 
					this.addAddress(shops);
23955 govind 218 
					// LOGGER.info("shops" + shops);
219 
				} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 220 
					LOGGER.error("Retailer Registered Address not found");
221 
				}
23955 govind 222 
			} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 223 
				LOGGER.error("Retailer not found in user_account");
23043 ashik.ali 224 
			}
225 
		}
23955 govind 226 
 
22980 ashik.ali 227 
		return map;
228 
	}
23955 govind 229 
 
230 
	private boolean containsRoleType(List<UserRole> userRoles, int roleId) {
231 
		for (UserRole userRole : userRoles) {
232 
			if (userRole.getRoleId() == roleId) {
23329 ashik.ali 233 
				return true;
234 
			}
235 
		}
236 
		return false;
237 
	}
23955 govind 238 
 
239 
	private List<UserRole> addRole(List<UserRole> userRoles, int userId, int roleId) {
240 
		if (userRoles == null) {
23329 ashik.ali 241 
			userRoles = new ArrayList<>();
242 
		}
23955 govind 243 
		if (!this.containsRoleType(userRoles, roleId)) {
23329 ashik.ali 244 
			UserRole userRole = new UserRole();
245 
			userRole.setUserId(userId);
23781 ashik.ali 246 
			userRole.setRoleId(roleId);
23329 ashik.ali 247 
			try {
248 
				userRoleRepository.persist(userRole);
249 
			} catch (ProfitMandiBusinessException e) {
250 
				LOGGER.error("UserRole is already exist");
251 
			}
252 
			userRoles.add(userRole);
253 
		}
254 
		return userRoles;
23955 govind 255 
 
23329 ashik.ali 256 
	}
23955 govind 257 
 
25295 amit.gupta 258 
	private List<UserRole> removeRole(List<UserRole> userRoles, int userId, int roleId) {
259 
		if (userRoles == null) {
260 
			userRoles = new ArrayList<>();
261 
			return userRoles;
262 
		}
263 
		try {
264 
			userRoles.remove(userRoleRepository.deleteByRoleUserId(userId, roleId));
265 
		} catch (Exception e) {
266 
 
267 
		}
268 
		return userRoles;
269 
 
270 
	}
271 
 
22980 ashik.ali 272 
	@SuppressWarnings("unchecked")
273 
	@Override
23025 ashik.ali 274 
	public Map<String, Object> updateRetailerDetails(UpdateRetailerRequest updateRetailerRequest)
275 
			throws ProfitMandiBusinessException {
276 
		Map<String, Object> map = this.getByEmailIdOrMobileNumber(updateRetailerRequest.getEmailIdOrMobileNumber());
23955 govind 277 
		User user = (User) map.get("user");
23329 ashik.ali 278 
		user = this.createUser(user, updateRetailerRequest);
279 
		map.put("user", user);
23955 govind 280 
		List<UserRole> userRoles = (List<UserRole>) map.get("userRoles");
23781 ashik.ali 281 
		Role roleUser = roleRepository.selectByName(RoleType.USER.toString());
282 
		userRoles = this.addRole(userRoles, user.getId(), roleUser.getId());
23955 govind 283 
		Retailer retailer = (Retailer) map.get("retailer");
23329 ashik.ali 284 
		retailer = this.updateRetailer(user, retailer, updateRetailerRequest);
285 
		map.put("retailer", retailer);
23955 govind 286 
 
23781 ashik.ali 287 
		Role roleRetailer = roleRepository.selectByName(RoleType.RETAILER.toString());
23955 govind 288 
 
23781 ashik.ali 289 
		userRoles = this.addRole(userRoles, user.getId(), roleRetailer.getId());
23955 govind 290 
 
23781 ashik.ali 291 
		Role roleFofo = roleRepository.selectByName(RoleType.FOFO.toString());
23955 govind 292 
 
293 
		if (updateRetailerRequest.isFofo()) {
23781 ashik.ali 294 
			userRoles = this.addRole(userRoles, user.getId(), roleFofo.getId());
25295 amit.gupta 295 
		} else {
296 
			userRoles = this.removeRole(userRoles, user.getId(), roleFofo.getId());
23061 ashik.ali 297 
		}
25295 amit.gupta 298 
		map.put("fofoRole", this.containsRoleType(userRoles, roleFofo.getId()));
23955 govind 299 
 
300 
		if (this.containsRoleType(userRoles, roleFofo.getId())) {
23365 ashik.ali 301 
			this.createDefaultPaymentOption(retailer.getId());
23329 ashik.ali 302 
		}
23955 govind 303 
 
23329 ashik.ali 304 
		map.put("userRoles", userRoles);
305 
		map.put("userRoleNames", this.toString(userRoles));
23955 govind 306 
 
307 
		Address retailerAddress = (Address) map.get("retailerAddress");
308 
		retailerAddress = this.updateRetailerAddress(retailerAddress, updateRetailerRequest.getAddress(),
309 
				retailer.getId());
23329 ashik.ali 310 
		map.put("retailerAddress", retailerAddress);
23955 govind 311 
 
312 
		if (updateRetailerRequest.isFofo()) {
313 
			FofoStore fofoStore = this.createFofoStoreCodeByRetailerId(retailer.getId(),
314 
					updateRetailerRequest.getDistrictName(), retailerAddress.getState(), updateRetailerRequest);
23378 ashik.ali 315 
			map.put("fofoStore", fofoStore);
25297 amit.gupta 316 
			fofoStore.setActive(updateRetailerRequest.isActive());
23061 ashik.ali 317 
		}
23955 govind 318 
 
319 
		this.createPrivateDealUser(user, updateRetailerRequest.isFofo(), updateRetailerRequest.getGstNumber(), retailer,
320 
				retailerAddress.getId());
23329 ashik.ali 321 
		map.put("gstNumber", updateRetailerRequest.getGstNumber());
322 
		this.updateSaholicUser(retailer.getId(), retailerAddress.getId());
23955 govind 323 
 
324 
		List<Shop> shops = (List<Shop>) map.get("shops");
325 
		if (shops == null) {
23060 ashik.ali 326 
			shops = new ArrayList<>();
23061 ashik.ali 327 
			map.put("shops", shops);
23060 ashik.ali 328 
		}
23079 ashik.ali 329 
		this.updateRetailerShops(shops, updateRetailerRequest.getShops(), retailer.getId(), retailerAddress);
23955 govind 330 
 
23025 ashik.ali 331 
		return map;
23955 govind 332 
 
23025 ashik.ali 333 
	}
23955 govind 334 
 
335 
	private void createDefaultPaymentOption(int fofoId) {
23365 ashik.ali 336 
		List<Integer> paymentOptionIds = fofoPartnerPaymentOptionRepository.selectPaymentOptionIdsByFofoId(fofoId);
23955 govind 337 
		if (paymentOptionIds.isEmpty()) {
23365 ashik.ali 338 
			PaymentOption paymentOption = null;
23955 govind 339 
			try {
23365 ashik.ali 340 
				paymentOption = paymentOptionRepository.selectByName(PaymentOptionType.CASH.toString());
23955 govind 341 
			} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23365 ashik.ali 342 
				paymentOption = new PaymentOption();
343 
				paymentOption.setName(PaymentOptionType.CASH.toString());
344 
				paymentOptionRepository.persist(paymentOption);
345 
			}
346 
			FofoPartnerPaymentOption fofoPartnerPaymentOption = new FofoPartnerPaymentOption();
347 
			fofoPartnerPaymentOption.setFofoId(fofoId);
348 
			fofoPartnerPaymentOption.setPaymentOptionId(paymentOption.getId());
349 
			fofoPartnerPaymentOptionRepository.persist(fofoPartnerPaymentOption);
350 
		}
23955 govind 351 
 
23365 ashik.ali 352 
	}
23955 govind 353 
 
354 
	private User createUser(User user, UpdateRetailerRequest updateRetailerRequest) {
355 
		if (user == null) {
23329 ashik.ali 356 
			user = new User();
357 
			user.setCity("");
358 
			user.setPinCode(0);
359 
			user.setState("");
360 
			user.setPassword("");
361 
			user.setMobile_verified(false);
362 
			user.setReferral_url("");
363 
			user.setGroup_id(1);
364 
			user.setStatus(1);
365 
			user.setActivated(true);
366 
			user.setCreateTimestamp(LocalDateTime.now());
367 
		}
24705 amit.gupta 368 
		user.setActivated(updateRetailerRequest.isActive());
23329 ashik.ali 369 
		user.setFirstName(updateRetailerRequest.getUserFirstName());
370 
		user.setLastName(updateRetailerRequest.getUserLastName());
371 
		user.setMobileNumber(updateRetailerRequest.getUserMobileNumber());
372 
		user.setEmailId(updateRetailerRequest.getUserEmailId());
373 
		user.setUsername(updateRetailerRequest.getUserEmailId());
23509 amit.gupta 374 
		user.setUpdateTimestamp(LocalDateTime.now());
375 
		userRepository.persist(user);
23329 ashik.ali 376 
		return user;
23955 govind 377 
 
23329 ashik.ali 378 
	}
23955 govind 379 
 
380 
	private int createSaholicUser(User user, String retailerName) {
23043 ashik.ali 381 
		com.spice.profitmandi.dao.entity.user.User saholicUser = null;
382 
		try {
23063 ashik.ali 383 
			saholicUser = userUserRepository.selectByEmailId(user.getEmailId());
23955 govind 384 
		} catch (ProfitMandiBusinessException e) {
23043 ashik.ali 385 
			LOGGER.info("User doesnt exist in old system");
386 
		}
23955 govind 387 
		if (saholicUser == null) {
23043 ashik.ali 388 
			Cart cart = new Cart();
389 
			cart.setCartStatus(CartStatus.ACTIVE);
390 
			cartRepository.persist(cart);
391 
			saholicUser = new com.spice.profitmandi.dao.entity.user.User();
23063 ashik.ali 392 
			saholicUser.setEmailId(user.getEmailId());
23043 ashik.ali 393 
			saholicUser.setName(retailerName);
394 
			saholicUser.setActiveCartId(cart.getId());
23300 amit.gupta 395 
			saholicUser.setCreateTimestamp(LocalDateTime.now());
23043 ashik.ali 396 
			userUserRepository.persist(saholicUser);
23955 govind 397 
 
23269 ashik.ali 398 
			UserAccount ua = new UserAccount();
399 
			ua.setAccountKey(saholicUser.getId());
400 
			ua.setUserId(user.getId());
401 
			ua.setType(AccountType.saholic);
23063 ashik.ali 402 
			userAccountRepository.persist(ua);
403 
 
23269 ashik.ali 404 
			UserAccount ua2 = new UserAccount();
405 
			ua2.setAccountKey(saholicUser.getActiveCartId());
406 
			ua2.setUserId(user.getId());
407 
			ua2.setType(AccountType.cartId);
23063 ashik.ali 408 
			userAccountRepository.persist(ua2);
23955 govind 409 
			LOGGER.info("created....");
23043 ashik.ali 410 
		}
411 
		return saholicUser.getId();
412 
	}
23955 govind 413 
 
26522 amit.gupta 414 
	private com.spice.profitmandi.dao.entity.user.User createSaholicUser(
415 
			LoginRequestResponseModel loginRequestResponseModel) {
416 
		com.spice.profitmandi.dao.entity.user.User saholicUser = null;
417 
		try {
418 
			saholicUser = userUserRepository.selectByEmailId(loginRequestResponseModel.getEmail());
419 
		} catch (ProfitMandiBusinessException e) {
420 
			LOGGER.info("User doesnt exist in old system");
421 
		}
422 
		if (saholicUser == null) {
423 
			Cart cart = new Cart();
424 
			cart.setCartStatus(CartStatus.ACTIVE);
425 
			cartRepository.persist(cart);
426 
			saholicUser = new com.spice.profitmandi.dao.entity.user.User();
26528 amit.gupta 427 
			saholicUser.setPassword(getHash256(loginRequestResponseModel.getPassword()));
26522 amit.gupta 428 
			saholicUser.setEmailId(loginRequestResponseModel.getEmail());
429 
			saholicUser.setName(loginRequestResponseModel.getCustomerName());
430 
			saholicUser.setActiveCartId(cart.getId());
431 
			saholicUser.setCreateTimestamp(LocalDateTime.now());
432 
			loginRequestResponseModel.setPassword(null);
433 
			userUserRepository.persist(saholicUser);
434 
		}
435 
		return saholicUser;
436 
	}
437 
 
23955 govind 438 
	private Retailer updateRetailer(User user, Retailer retailer, UpdateRetailerRequest updateRetailerRequest)
439 
			throws ProfitMandiBusinessException {
440 
		if (retailer == null) {
441 
			LOGGER.info("createSaholicUser.....");
23063 ashik.ali 442 
			int saholicUserId = this.createSaholicUser(user, updateRetailerRequest.getName());
23043 ashik.ali 443 
			retailer = new Retailer();
444 
			retailer.setId(saholicUserId);
445 
		}
23329 ashik.ali 446 
		retailer.setActive(updateRetailerRequest.isActive());
24704 amit.gupta 447 
		user.setActivated(updateRetailerRequest.isActive());//
23955 govind 448 
		// this.createRole(user.getId(), RoleType.RETAILER);
23025 ashik.ali 449 
		retailer.setName(updateRetailerRequest.getName());
450 
		retailer.setNumber(updateRetailerRequest.getNumber());
23955 govind 451 
		if (updateRetailerRequest.getNumber() == null || updateRetailerRequest.getNumber().isEmpty()) {
23107 ashik.ali 452 
			retailer.setType(RetailerType.UNREGISTERED_SHOP);
23955 govind 453 
		} else {
23107 ashik.ali 454 
			retailer.setType(RetailerType.GSTIN);
455 
		}
23955 govind 456 
		if (updateRetailerRequest.getDocumentId() > 0) {
457 
			if (retailer.getDocumentId() != null && retailer.getDocumentId() != updateRetailerRequest.getDocumentId()) {
24374 amit.gupta 458 
				try {
459 
					documentRepository.deleteById(retailer.getDocumentId());
25295 amit.gupta 460 
				} catch (Exception e) {
24374 amit.gupta 461 
					e.printStackTrace();
462 
				}
23489 ashik.ali 463 
			}
23497 ashik.ali 464 
			retailer.setDocumentId(updateRetailerRequest.getDocumentId());
465 
			documentRepository.markDocumentAsPersisted(updateRetailerRequest.getDocumentId());
23025 ashik.ali 466 
		}
467 
		retailerRepository.persist(retailer);
23059 ashik.ali 468 
		return retailer;
23025 ashik.ali 469 
	}
23955 govind 470 
 
471 
	private void updateSaholicUser(int retailerId, int retailerAddressId) {
23329 ashik.ali 472 
		try {
473 
			com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(retailerId);
474 
			user.setAddressId(retailerAddressId);
475 
		} catch (ProfitMandiBusinessException e) {
23955 govind 476 
 
23329 ashik.ali 477 
		}
478 
	}
23955 govind 479 
 
480 
	private void createPrivateDealUser(User user, boolean fofo, String gstNumber, Retailer retailer,
481 
			int retailerAddressId) {
23329 ashik.ali 482 
		PrivateDealUser privateDealUser = null;
23955 govind 483 
		try {
23329 ashik.ali 484 
			privateDealUser = privateDealUserRepository.selectById(retailer.getId());
23955 govind 485 
		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 486 
			LOGGER.error("PrivateDealUser not found");
487 
		}
23955 govind 488 
 
489 
		// = privateDealUserRepository.selectById(saholicUser.getId());
490 
		if (privateDealUser == null) {
491 
			Integer counterId = this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(),
492 
					retailer.getName(), retailerAddressId);
23473 ashik.ali 493 
			try {
494 
				this.createPrivateDealUser(retailer.getId(), counterId, fofo);
23955 govind 495 
			} catch (Exception e) {
23473 ashik.ali 496 
				LOGGER.error("ERROR : ", e);
497 
			}
23955 govind 498 
		} else {
499 
			if (privateDealUser.getCounterId() == null) {
500 
				Integer counterId = this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(),
501 
						retailer.getName(), retailerAddressId);
23329 ashik.ali 502 
				privateDealUser.setCounterId(counterId);
503 
				privateDealUser.setFofo(fofo);
504 
				privateDealUserRepository.persist(privateDealUser);
23955 govind 505 
			} else {
23329 ashik.ali 506 
				Counter counter = null;
23955 govind 507 
				try {
23329 ashik.ali 508 
					counter = counterRepository.selectById(privateDealUser.getCounterId());
23955 govind 509 
				} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 510 
					LOGGER.error("Counter not found with id [{}]", privateDealUser.getCounterId());
511 
				}
23955 govind 512 
				if (counter == null) {
513 
					this.createCounter(user.getEmailId(), gstNumber, user.getMobileNumber(), retailer.getName(),
514 
							retailerAddressId);
515 
				} else {
23329 ashik.ali 516 
					counter.setGstin(gstNumber);
517 
					counterRepository.persist(counter);
518 
				}
519 
				privateDealUser.setFofo(fofo);
520 
				privateDealUserRepository.persist(privateDealUser);
521 
			}
522 
		}
23955 govind 523 
 
23329 ashik.ali 524 
		PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
525 
		privateDealUserAddressMapping.setUserId(retailer.getId());
526 
		privateDealUserAddressMapping.setAddressId(retailerAddressId);
527 
		privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
528 
	}
23955 govind 529 
 
530 
	// Specifically set isFofo to true that has to be used by old system
531 
	private void createPrivateDealUser(int retailerId, int counterId, boolean fofo) {
23329 ashik.ali 532 
		PrivateDealUser privateDealUser = new PrivateDealUser();
533 
		privateDealUser.setActive(true);
534 
		privateDealUser.setBulkShipmentAmountLimit(fofo ? 1000000 : 50000);
535 
		privateDealUser.setId(retailerId);
536 
		privateDealUser.setCounterId(counterId);
537 
		privateDealUser.setFofo(fofo);
538 
		privateDealUserRepository.persist(privateDealUser);
539 
	}
23955 govind 540 
 
541 
	private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId) {
542 
		if (gstNumber != null && !gstNumber.isEmpty()) {
23329 ashik.ali 543 
			Counter counter = new Counter();
544 
			counter.setEmailId(emailId);
545 
			counter.setGstin(gstNumber);
546 
			counter.setMobileNumber(mobileNumber);
547 
			counter.setName(name);
548 
			counter.setAddressId(addressId);
549 
			counterRepository.persist(counter);
550 
			return counter.getId();
23955 govind 551 
		} else {
23329 ashik.ali 552 
			return null;
553 
		}
554 
	}
23955 govind 555 
 
556 
	private Address updateRetailerAddress(Address address, CustomAddress customAddress, int retailerId)
557 
			throws ProfitMandiBusinessException {
558 
		if (address == null) {
23043 ashik.ali 559 
			address = new Address();
560 
			address.setRetaierId(retailerId);
561 
			this.updateAddress(address, customAddress);
23955 govind 562 
			// addressRepository.persist(addressRetailer);
563 
 
23043 ashik.ali 564 
			final RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
565 
			retailerRegisteredAddress.setRetailerId(retailerId);
566 
			retailerRegisteredAddress.setAddressId(address.getId());
567 
			retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
23955 govind 568 
		} else {
569 
			this.updateAddress(address, customAddress);
570 
			RetailerRegisteredAddress retailerRegisteredAddress = retailerRegisteredAddressRepository
571 
					.selectByRetailerId(retailerId);
572 
			retailerRegisteredAddress.setAddressId(address.getId());
573 
			retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
23043 ashik.ali 574 
		}
23059 ashik.ali 575 
		return address;
23043 ashik.ali 576 
	}
23955 govind 577 
 
27411 amit.gupta 578 
	private void updateAddress(Address address, CustomAddress customAddress) throws ProfitMandiBusinessException {
23025 ashik.ali 579 
		address.setName(customAddress.getName());
23829 amit.gupta 580 
		address.setPhoneNumber(customAddress.getPhoneNumber());
23025 ashik.ali 581 
		address.setLine1(customAddress.getLine1());
582 
		address.setLine2(customAddress.getLine2());
583 
		address.setCity(customAddress.getCity());
584 
		address.setPinCode(customAddress.getPinCode());
27411 amit.gupta 585 
		State state = stateRepository.selectByName(customAddress.getState());
27877 amit.gupta 586 
		if (state == null) {
587 
			throw new ProfitMandiBusinessException("State name", "Invalid State - Pls Contact Technology",
588 
					"Invalid State - Pls Contact Technology");
27411 amit.gupta 589 
		}
590 
		address.setState(state.getName());
23025 ashik.ali 591 
		addressRepository.persist(address);
23955 govind 592 
		LOGGER.info("Address Updated" + address);
23025 ashik.ali 593 
	}
23955 govind 594 
 
595 
	private void updateRetailerShops(List<Shop> shops, Set<CustomShop> customShops, int retailerId,
596 
			Address sameAsRetailerAddressValue) throws ProfitMandiBusinessException {
597 
		if (shops.isEmpty()) {
598 
			for (CustomShop customShop : customShops) {
23043 ashik.ali 599 
				Shop shop = new Shop();
23079 ashik.ali 600 
				this.createOrUpdateShop(shop, customShop, retailerId, sameAsRetailerAddressValue);
23043 ashik.ali 601 
				shops.add(shop);
602 
			}
23955 govind 603 
		} else {
604 
			for (Shop shop : shops) {
605 
				for (CustomShop customShop : customShops) {
606 
					if (shop.getId() == customShop.getShopId()) {
23079 ashik.ali 607 
						this.createOrUpdateShop(shop, customShop, retailerId, sameAsRetailerAddressValue);
23025 ashik.ali 608 
					}
609 
				}
610 
			}
23955 govind 611 
			for (CustomShop customShop : customShops) {
612 
				if (customShop.getShopId() == 0) {
23043 ashik.ali 613 
					Shop shop = new Shop();
23079 ashik.ali 614 
					this.createOrUpdateShop(shop, customShop, retailerId, sameAsRetailerAddressValue);
23043 ashik.ali 615 
					shops.add(shop);
616 
				}
617 
			}
23025 ashik.ali 618 
		}
619 
	}
23955 govind 620 
 
621 
	private void createOrUpdateShop(Shop shop, CustomShop customShop, int retailerId,
622 
			Address sameAsRetailerAddressValue) throws ProfitMandiBusinessException {
23043 ashik.ali 623 
		shop.setRetailerId(retailerId);
624 
		shop.setName(customShop.getName());
23955 govind 625 
		if (customShop.getDocumentId() > 0) {
626 
			if (shop.getDocumentId() != null && shop.getDocumentId() != customShop.getDocumentId()) {
24374 amit.gupta 627 
				try {
628 
					documentRepository.deleteById(shop.getDocumentId());
25295 amit.gupta 629 
				} catch (Exception e) {
24374 amit.gupta 630 
					e.printStackTrace();
631 
				}
23489 ashik.ali 632 
			}
23497 ashik.ali 633 
			shop.setDocumentId(customShop.getDocumentId());
634 
			documentRepository.markDocumentAsPersisted(customShop.getDocumentId());
23043 ashik.ali 635 
		}
23955 govind 636 
		if (shop.getAddressId() == null) {
23079 ashik.ali 637 
			Address address = null;
23955 govind 638 
			if (customShop.isSameAsRetailerAddress()) {
23079 ashik.ali 639 
				address = sameAsRetailerAddressValue;
23955 govind 640 
			} else {
641 
				// shop.setDocumentId(customShop.getDocumentId());
23079 ashik.ali 642 
				address = new Address();
643 
				this.updateAddress(address, customShop.getAddress());
644 
			}
23043 ashik.ali 645 
			shop.setAddressId(address.getId());
646 
			shop.setAddress(address);
647 
			shopRepository.persist(shop);
23131 ashik.ali 648 
			ShopAddress shopAddress = null;
23955 govind 649 
			try {
23131 ashik.ali 650 
				shopAddress = shopAddressRepository.selectByShopId(shop.getId());
651 
				shopAddress.setAddressId(address.getId());
23955 govind 652 
			} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23131 ashik.ali 653 
				shopAddress = new ShopAddress();
654 
				shopAddress.setAddressId(address.getId());
655 
				shopAddress.setShopId(shop.getId());
656 
			}
23043 ashik.ali 657 
			shopAddressRepository.persist(shopAddress);
23955 govind 658 
		} else {
24375 amit.gupta 659 
			Address address = null;
660 
			try {
661 
				address = addressRepository.selectById(shop.getAddressId());
662 
				CustomAddress customAddress = customShop.getAddress();
663 
				if (!(address.getName().equals(customAddress.getName())
664 
						&& address.getLine1().equals(customAddress.getLine1())
665 
						&& address.getLine2().equals(customAddress.getLine2())
666 
						&& address.getCity().equals(customAddress.getCity())
667 
						&& address.getPinCode().equals(customAddress.getPinCode())
668 
						&& address.getState().equals(customAddress.getState()))) {
669 
					address = new Address();
670 
					ShopAddress shopAddress = shopAddressRepository.selectByShopId(shop.getId());
671 
					this.updateAddress(address, customAddress);
672 
					shopAddress.setAddressId(address.getId());
673 
					shopAddressRepository.persist(shopAddress);
674 
					shop.setAddress(address);
675 
					shopRepository.persist(shop);
676 
				}
25295 amit.gupta 677 
			} catch (Exception e) {
24375 amit.gupta 678 
				if (customShop.isSameAsRetailerAddress()) {
679 
					address = sameAsRetailerAddressValue;
680 
				} else {
681 
					// shop.setDocumentId(customShop.getDocumentId());
682 
					address = new Address();
683 
					this.updateAddress(address, customShop.getAddress());
684 
				}
685 
				shop.setAddressId(address.getId());
686 
				shop.setAddress(address);
687 
				shopRepository.persist(shop);
688 
				ShopAddress shopAddress = null;
689 
				try {
690 
					shopAddress = shopAddressRepository.selectByShopId(shop.getId());
691 
					shopAddress.setAddressId(address.getId());
692 
				} catch (ProfitMandiBusinessException profitMandiBusinessException) {
693 
					shopAddress = new ShopAddress();
694 
					shopAddress.setAddressId(address.getId());
695 
					shopAddress.setShopId(shop.getId());
696 
				}
25295 amit.gupta 697 
				shopAddressRepository.persist(shopAddress);
698 
			}
23955 govind 699 
 
23043 ashik.ali 700 
		}
23955 govind 701 
 
23043 ashik.ali 702 
	}
23955 govind 703 
 
704 
	private void addAddress(List<Shop> shops) {
22980 ashik.ali 705 
		Set<Integer> shopIds = this.toShopIds(shops);
23955 govind 706 
		if (shopIds.isEmpty()) {
22980 ashik.ali 707 
			return;
708 
		}
709 
		List<ShopAddress> shopAddresses = shopAddressRepository.selectByShopIds(shopIds);
710 
		Map<Integer, Address> addressIdAddressMap = this.toAddressIdAddressMap(shopAddresses);
23955 govind 711 
 
712 
		for (Shop shop : shops) {
22980 ashik.ali 713 
			shop.setAddress(addressIdAddressMap.get(shop.getAddressId()));
714 
		}
715 
	}
716 
 
23955 govind 717 
	private Map<Integer, Address> toAddressIdAddressMap(List<ShopAddress> shopAddresses) {
22980 ashik.ali 718 
		Map<Integer, Address> addressIdAddressMap = new HashMap<>();
719 
		List<Integer> addressIds = this.toAddressIds(shopAddresses);
720 
		List<Address> addresses = addressRepository.selectByIds(addressIds);
23955 govind 721 
		for (Address address : addresses) {
22980 ashik.ali 722 
			addressIdAddressMap.put(address.getId(), address);
723 
		}
724 
		return addressIdAddressMap;
725 
	}
23955 govind 726 
 
727 
	private List<Integer> toAddressIds(List<ShopAddress> shopAddresses) {
728 
		Function<ShopAddress, Integer> shopAddressToAddressIdFunction = new Function<ShopAddress, Integer>() {
22980 ashik.ali 729 
			@Override
730 
			public Integer apply(ShopAddress shopAddress) {
731 
				return shopAddress.getAddressId();
732 
			}
733 
		};
734 
		return shopAddresses.stream().map(shopAddressToAddressIdFunction).collect(Collectors.toList());
735 
	}
23955 govind 736 
 
737 
	private Set<Integer> toShopIds(List<Shop> shops) {
738 
		Function<Shop, Integer> shopToAddressIdFunction = new Function<Shop, Integer>() {
22980 ashik.ali 739 
			@Override
740 
			public Integer apply(Shop shop) {
741 
				return shop.getId();
742 
			}
743 
		};
744 
		return shops.stream().map(shopToAddressIdFunction).collect(Collectors.toSet());
745 
	}
23955 govind 746 
 
747 
	private String toString(List<UserRole> userRoles) {
23781 ashik.ali 748 
		Set<Integer> roleIds = new HashSet<>();
23955 govind 749 
		for (UserRole userRole : userRoles) {
23781 ashik.ali 750 
			roleIds.add(userRole.getRoleId());
751 
		}
752 
		List<Role> roles = roleRepository.selectByIds(roleIds);
23955 govind 753 
		Function<Role, String> roleToNameFunction = new Function<Role, String>() {
23781 ashik.ali 754 
			public String apply(Role role) {
755 
				return String.valueOf(role.getName());
22980 ashik.ali 756 
			};
757 
		};
23781 ashik.ali 758 
		Set<String> userRoleStrings = roles.stream().map(roleToNameFunction).collect(Collectors.toSet());
22980 ashik.ali 759 
		return String.join(", ", userRoleStrings);
760 
	}
23955 govind 761 
 
762 
	private FofoStore createFofoStoreCodeByRetailerId(int retailerId, String districtName, String stateName,
763 
			UpdateRetailerRequest updateRetailerRequest) throws ProfitMandiBusinessException {
23378 ashik.ali 764 
		FofoStore fofoStore = null;
23955 govind 765 
		try {
23378 ashik.ali 766 
			fofoStore = fofoStoreRepository.selectByRetailerId(retailerId);
23955 govind 767 
		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
768 
 
23378 ashik.ali 769 
		}
23955 govind 770 
 
771 
		if (fofoStore != null) {
772 
			fofoStore.setCounterSize(updateRetailerRequest.getCountersize());
773 
			fofoStore.setMinimumInvestment(updateRetailerRequest.getMinInvestment());
26209 tejbeer 774 
			fofoStore.setWarehouseId(updateRetailerRequest.getWarehouseId());
23955 govind 775 
			fofoStoreRepository.persist(fofoStore);
776 
 
777 
		} else {
23378 ashik.ali 778 
			int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailerId);
779 
			Address retailerAddress = addressRepository.selectById(retailerAddressId);
23955 govind 780 
 
23378 ashik.ali 781 
			StateInfo stateInfo = null;
782 
			try {
783 
				stateInfo = Utils.getStateInfo(retailerAddress.getState());
784 
			} catch (Exception e) {
785 
				// TODO Auto-generated catch block
786 
				e.printStackTrace();
23955 govind 787 
				// throw new ProfitMandiBusinessException();
23378 ashik.ali 788 
			}
23955 govind 789 
			DistrictMaster districtMaster = districtMasterRepository.selectByNameAndStateShortName(districtName,
790 
					stateInfo.getShortName());
791 
 
23378 ashik.ali 792 
			fofoStore = new FofoStore();
793 
			fofoStore.setId(retailerId);
24023 amit.gupta 794 
			fofoStore.setCounterSize(updateRetailerRequest.getCountersize());
795 
			fofoStore.setMinimumInvestment(updateRetailerRequest.getMinInvestment());
26209 tejbeer 796 
			fofoStore.setWarehouseId(updateRetailerRequest.getWarehouseId());
23786 amit.gupta 797 
			String latestStoreCode = fofoStoreRepository.selectLatestStore().getCode();
798 
			int latestCodeCounter = Integer.parseInt(latestStoreCode.replaceAll("[A-Z]", ""));
23955 govind 799 
			String fofoStoreCode = StringUtils.generateFofoStoreSequence(
800 
					districtMaster.getStateShortName() + districtMaster.getShortName(), latestCodeCounter + 1);
23378 ashik.ali 801 
			fofoStore.setCode(fofoStoreCode);
802 
			fofoStoreRepository.persist(fofoStore);
803 
		}
23955 govind 804 
 
23378 ashik.ali 805 
		return fofoStore;
806 
	}
23955 govind 807 
 
23329 ashik.ali 808 
	@Override
23955 govind 809 
	public FofoStore createFofoStoreCodeByUserId(int userId, String districtName, String stateName,
810 
			UpdateRetailerRequest updateRetailerRequest) throws ProfitMandiBusinessException {
23329 ashik.ali 811 
		User user = userRepository.selectById(userId);
812 
		// = userAccountRepository.selectRetailerIdByUserId(user.getId());
813 
		UserAccount userAccounts = userAccountRepository.selectSaholicByUserId(user.getId());
814 
		Retailer retailer = retailerRepository.selectById(userAccounts.getAccountKey());
23781 ashik.ali 815 
		Role roleFofo = roleRepository.selectByName(RoleType.FOFO.toString());
23955 govind 816 
		try {
23781 ashik.ali 817 
			userRoleRepository.selectByUserIdAndRoleId(user.getId(), roleFofo.getId());
23955 govind 818 
		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
23329 ashik.ali 819 
			throw new ProfitMandiBusinessException(ProfitMandiConstants.USER_ID, user.getId(), "USR_1013");
820 
		}
23955 govind 821 
		return this.createFofoStoreCodeByRetailerId(retailer.getId(), districtName, stateName, updateRetailerRequest);
822 
 
23329 ashik.ali 823 
	}
23955 govind 824 
 
23329 ashik.ali 825 
	@Override
826 
	public List<DistrictMaster> getAllDistrictMaster(String stateName) {
827 
		StateInfo stateInfo = null;
828 
		try {
829 
			stateInfo = Utils.getStateInfo(stateName);
830 
		} catch (Exception e) {
831 
			e.printStackTrace();
23955 govind 832 
			// throw new ProfitMandiBusinessException();
23329 ashik.ali 833 
		}
834 
		return districtMasterRepository.selectByStateShortName(stateInfo.getShortName());
835 
	}
22980 ashik.ali 836 
 
23509 amit.gupta 837 
	@Override
838 
	public Map<Integer, CustomRetailer> getFofoRetailers(List<Integer> fofoIds) {
839 
		List<com.spice.profitmandi.dao.entity.user.User> saholicUsers = userUserRepository.selectByIds(fofoIds);
25295 amit.gupta 840 
		Map<Integer, com.spice.profitmandi.dao.entity.user.User> userAddressMap = saholicUsers.stream()
841 
				.filter(x -> x.getAddressId() != null).collect(Collectors.toMap(x -> x.getAddressId(), x -> x));
23903 amit.gupta 842 
		List<Address> addresses = addressRepository.selectByIds(new ArrayList<>(userAddressMap.keySet()));
23509 amit.gupta 843 
		Map<Integer, CustomRetailer> customRetailersMap = new HashMap<>();
25295 amit.gupta 844 
		for (Address address : addresses) {
23903 amit.gupta 845 
			com.spice.profitmandi.dao.entity.user.User user = userAddressMap.get(address.getId());
23509 amit.gupta 846 
			CustomRetailer customRetailer = new CustomRetailer();
23903 amit.gupta 847 
			customRetailer.setEmail(user.getEmailId());
23509 amit.gupta 848 
			customRetailer.setBusinessName(address.getName());
849 
			customRetailer.setMobileNumber(address.getPhoneNumber());
23532 amit.gupta 850 
			try {
26151 amit.gupta 851 
				FofoStore fs = fofoStoreRepository.selectByRetailerId(address.getRetaierId());
852 
				customRetailer.setCode(fs.getCode());
853 
				customRetailer.setWarehouseId(fs.getWarehouseId());
26977 amit.gupta 854 
				customRetailer.setPartnerId(fs.getId());
26125 amit.gupta 855 
			} catch (Exception e) {
856 
				continue;
857 
			}
858 
			try {
23796 amit.gupta 859 
				customRetailer.setCartId(user.getActiveCartId());
23532 amit.gupta 860 
				PrivateDealUser pdu = privateDealUserRepository.selectById(address.getRetaierId());
861 
				Counter counter = counterRepository.selectById(pdu.getCounterId());
862 
				customRetailer.setGstNumber(counter.getGstin());
23955 govind 863 
			} catch (Exception e) {
23532 amit.gupta 864 
				customRetailer.setGstNumber(null);
865 
			}
866 
			CustomAddress address1 = new CustomAddress();
867 
			address1.setCity(address.getCity());
868 
			address1.setState(address.getState());
869 
			address1.setLine1(address.getLine1());
870 
			address1.setLine2(address.getLine2());
871 
			address1.setPinCode(address.getPinCode());
872 
			address1.setName(address.getName());
873 
			customRetailer.setAddress(address1);
26522 amit.gupta 874 
			customRetailer.setDisplayName(
875 
					customRetailer.getBusinessName() + "-" + customRetailer.getCode() + "- " + address1.getCity());
26977 amit.gupta 876 
			customRetailersMap.put(customRetailer.getPartnerId(), customRetailer);
23509 amit.gupta 877 
		}
878 
		return customRetailersMap;
879 
	}
25295 amit.gupta 880 
 
23781 ashik.ali 881 
	@Override
25295 amit.gupta 882 
	public CustomRetailer getFofoRetailer(int fofoId) throws ProfitMandiBusinessException {
23957 tejbeer 883 
		com.spice.profitmandi.dao.entity.user.User saholicUser = userUserRepository.selectById(fofoId);
26089 amit.gupta 884 
		FofoStore store = fofoStoreRepository.selectByRetailerId(fofoId);
23957 tejbeer 885 
		Address address = null;
886 
		try {
887 
			address = addressRepository.selectById(saholicUser.getAddressId());
888 
		} catch (ProfitMandiBusinessException e1) {
889 
			// TODO Auto-generated catch block
890 
			e1.printStackTrace();
891 
		}
892 
		Map<Integer, CustomRetailer> customRetailersMap = new HashMap<>();
25295 amit.gupta 893 
		CustomRetailer customRetailer = new CustomRetailer();
894 
		customRetailer.setEmail(saholicUser.getEmailId());
895 
		customRetailer.setBusinessName(address.getName());
896 
		customRetailer.setMobileNumber(address.getPhoneNumber());
897 
		try {
898 
			customRetailer.setCartId(saholicUser.getActiveCartId());
899 
			PrivateDealUser pdu = privateDealUserRepository.selectById(address.getRetaierId());
900 
			Counter counter = counterRepository.selectById(pdu.getCounterId());
901 
			customRetailer.setGstNumber(counter.getGstin());
902 
		} catch (Exception e) {
903 
			customRetailer.setGstNumber(null);
904 
		}
905 
		CustomAddress address1 = new CustomAddress();
906 
		address1.setCity(address.getCity());
907 
		address1.setState(address.getState());
908 
		address1.setLine1(address.getLine1());
909 
		address1.setLine2(address.getLine2());
910 
		address1.setPinCode(address.getPinCode());
26653 amit.gupta 911 
		address1.setPhoneNumber(address.getPhoneNumber());
25295 amit.gupta 912 
		address1.setName(address.getName());
26125 amit.gupta 913 
		customRetailer.setDisplayName(address.getName() + " - " + address.getCity());
25295 amit.gupta 914 
		customRetailer.setAddress(address1);
915 
		customRetailer.setPartnerId(address.getRetaierId());
26089 amit.gupta 916 
		customRetailer.setCode(store.getCode());
26112 amit.gupta 917 
		customRetailer.setWarehouseId(store.getWarehouseId());
25295 amit.gupta 918 
		customRetailersMap.put(address.getRetaierId(), customRetailer);
23957 tejbeer 919 
		return customRetailer;
25295 amit.gupta 920 
 
23957 tejbeer 921 
	}
26125 amit.gupta 922 
 
25383 tejbeer 923 
	@Override
27877 amit.gupta 924 
	public Map<Integer, CustomRetailer> getFofoRetailerUserId(List<Integer> fofoIds) {
25383 tejbeer 925 
		List<com.spice.profitmandi.dao.entity.user.User> saholicUsers = userUserRepository.selectByIds(fofoIds);
926 
		Map<Integer, com.spice.profitmandi.dao.entity.user.User> userAddressMap = saholicUsers.stream()
927 
				.filter(x -> x.getAddressId() != null).collect(Collectors.toMap(x -> x.getAddressId(), x -> x));
928 
		List<Address> addresses = addressRepository.selectByIds(new ArrayList<>(userAddressMap.keySet()));
929 
		Map<Integer, CustomRetailer> customRetailersMap = new HashMap<>();
930 
		for (Address address : addresses) {
931 
			com.spice.profitmandi.dao.entity.user.User user = userAddressMap.get(address.getId());
932 
			CustomRetailer customRetailer = new CustomRetailer();
933 
			customRetailer.setEmail(user.getEmailId());
934 
			customRetailer.setBusinessName(address.getName());
935 
			customRetailer.setMobileNumber(address.getPhoneNumber());
27877 amit.gupta 936 
			int userId = 0;
25383 tejbeer 937 
			try {
27877 amit.gupta 938 
				userId = userAccountRepository.selectUserIdByRetailerId(user.getId());
939 
			} catch(ProfitMandiBusinessException e) {
940 
				continue;
941 
			}
942 
			try {
25383 tejbeer 943 
				customRetailer.setCartId(user.getActiveCartId());
944 
				PrivateDealUser pdu = privateDealUserRepository.selectById(address.getRetaierId());
945 
				Counter counter = counterRepository.selectById(pdu.getCounterId());
946 
				customRetailer.setGstNumber(counter.getGstin());
947 
			} catch (Exception e) {
948 
				customRetailer.setGstNumber(null);
949 
			}
950 
			CustomAddress address1 = new CustomAddress();
951 
			address1.setCity(address.getCity());
952 
			address1.setState(address.getState());
953 
			address1.setLine1(address.getLine1());
954 
			address1.setLine2(address.getLine2());
955 
			address1.setPinCode(address.getPinCode());
956 
			address1.setName(address.getName());
957 
			customRetailer.setAddress(address1);
958 
			customRetailer.setPartnerId(address.getRetaierId());
959 
			customRetailer.setDisplayName(customRetailer.getBusinessName() + "-" + address1.getCity());
960 
			customRetailersMap.put(userId, customRetailer);
961 
		}
962 
		return customRetailersMap;
963 
	}
25295 amit.gupta 964 
 
23957 tejbeer 965 
	@Override
23781 ashik.ali 966 
	public Map<Integer, String> getAllFofoRetailerIdEmailIdMap() {
967 
		Role roleFofo = null;
968 
		try {
969 
			roleFofo = roleRepository.selectByName(RoleType.FOFO.toString());
970 
		} catch (ProfitMandiBusinessException e) {
971 
			// TODO Auto-generated catch block
972 
			e.printStackTrace();
973 
		}
974 
		Role roleRetailer = null;
975 
		try {
976 
			roleRetailer = roleRepository.selectByName(RoleType.RETAILER.toString());
977 
		} catch (ProfitMandiBusinessException e) {
978 
			// TODO Auto-generated catch block
979 
			e.printStackTrace();
980 
		}
981 
		Set<Integer> roleIds = new HashSet<>();
982 
		roleIds.add(roleFofo.getId());
983 
		roleIds.add(roleRetailer.getId());
984 
		List<Integer> userIds = userRoleRepository.selectUserIdsByRoleIds(roleIds);
985 
		List<User> users = userRepository.selectAllByIds(new HashSet<>(userIds));
986 
		Map<Integer, Integer> userIdRetailerIdMap = this.getUserIdRetailerIdMap(userIds);
987 
		Map<Integer, String> retailerIdEmailIdMap = new HashMap<>();
23955 govind 988 
		for (User user : users) {
23781 ashik.ali 989 
			retailerIdEmailIdMap.put(userIdRetailerIdMap.get(user.getId()), user.getEmailId());
990 
		}
991 
		return retailerIdEmailIdMap;
992 
	}
23955 govind 993 
 
994 
	private Map<Integer, Integer> getUserIdRetailerIdMap(List<Integer> userIds) {
23781 ashik.ali 995 
		List<UserAccount> userAccounts = userAccountRepository.selectAllSaholicByUserIds(new HashSet<>(userIds));
996 
		Map<Integer, Integer> userIdRetailerIdMap = new HashMap<>();
23955 govind 997 
		for (UserAccount userAccount : userAccounts) {
23781 ashik.ali 998 
			userIdRetailerIdMap.put(userAccount.getUserId(), userAccount.getAccountKey());
999 
		}
1000 
		return userIdRetailerIdMap;
1001 
	}
25295 amit.gupta 1002 
 
1003 
	private Map<Integer, String> getUserIdEmailIdMap(Set<Integer> userIds) {
23880 ashik.ali 1004 
		List<User> users = userRepository.selectAllByIds(userIds);
1005 
		Map<Integer, String> userIdEmailIdMap = new HashMap<>();
23955 govind 1006 
		for (User user : users) {
23880 ashik.ali 1007 
			userIdEmailIdMap.put(user.getId(), user.getEmailId());
1008 
		}
1009 
		return userIdEmailIdMap;
1010 
	}
23509 amit.gupta 1011 
 
23880 ashik.ali 1012 
	@Override
1013 
	public Map<Integer, String> getAllFofoRetailerIdEmailIdMap(Set<Integer> retailerIds) {
1014 
		List<UserAccount> userAccounts = userAccountRepository.selectAllSaholicByRetailerIds(retailerIds);
1015 
		Set<Integer> userIds = new HashSet<>();
23955 govind 1016 
		for (UserAccount userAccount : userAccounts) {
23880 ashik.ali 1017 
			userIds.add(userAccount.getUserId());
1018 
		}
1019 
		Map<Integer, String> retailerIdEmailIdMap = new HashMap<>();
1020 
		Map<Integer, String> userIdEmailIdMap = this.getUserIdEmailIdMap(userIds);
23955 govind 1021 
		for (UserAccount userAccount : userAccounts) {
23880 ashik.ali 1022 
			retailerIdEmailIdMap.put(userAccount.getAccountKey(), userIdEmailIdMap.get(userAccount.getUserId()));
1023 
		}
1024 
		return retailerIdEmailIdMap;
1025 
	}
25295 amit.gupta 1026 
 
24168 amit.gupta 1027 
	@Override
24349 amit.gupta 1028 
	public Map<Integer, String> getAllFofoRetailerIdNameMap(List<Integer> storeIds) {
24168 amit.gupta 1029 
		Map<Integer, CustomRetailer> retailersMap = this.getFofoRetailers(storeIds);
1030 
		Map<Integer, String> retailerIdNameMap = new HashMap<>();
25295 amit.gupta 1031 
		for (Map.Entry<Integer, CustomRetailer> entry : retailersMap.entrySet()) {
1032 
			retailerIdNameMap.put(entry.getKey(),
1033 
					entry.getValue().getBusinessName() + "-" + entry.getValue().getAddress().getCity());
24168 amit.gupta 1034 
		}
1035 
		return retailerIdNameMap;
1036 
	}
1037 
 
1038 
	@Override
1039 
	public Map<Integer, String> getAllFofoRetailerIdNameMap() {
24349 amit.gupta 1040 
		List<FofoStore> stores = fofoStoreRepository.selectAll();
25295 amit.gupta 1041 
		List<Integer> storeIds = stores.stream().map(x -> x.getId()).collect(Collectors.toList());
24349 amit.gupta 1042 
		return this.getAllFofoRetailerIdNameMap(storeIds);
1043 
	}
1044 
 
1045 
	@Override
1046 
	public List<MapWrapper<Integer, String>> getAllFofoRetailerIdNameList() {
1047 
		List<MapWrapper<Integer, String>> mapWrappers = new ArrayList<>();
24168 amit.gupta 1048 
		// TODO Auto-generated method stub
24349 amit.gupta 1049 
		Map<Integer, String> fofoIdNameMap = this.getAllFofoRetailerIdNameMap();
25295 amit.gupta 1050 
		fofoIdNameMap.forEach((fofoId, name) -> {
24349 amit.gupta 1051 
			MapWrapper<Integer, String> idWrapper = new MapWrapper<>();
1052 
			idWrapper.setKey(fofoId);
1053 
			idWrapper.setValue(name);
1054 
			mapWrappers.add(idWrapper);
1055 
		});
1056 
		return mapWrappers;
1057 
	}
1058 
 
1059 
	@Override
27124 amit.gupta 1060 
	@Cacheable(value = "retailerNames", cacheManager = "oneDayCacheManager")
26962 amit.gupta 1061 
	public Map<Integer, CustomRetailer> getFofoRetailers(boolean activeOnly) {
24349 amit.gupta 1062 
		// TODO Auto-generated method stub
26962 amit.gupta 1063 
		Stream<FofoStore> storeStream = fofoStoreRepository.selectAll().stream();
27861 tejbeer 1064 
		if (activeOnly) {
1065 
			storeStream = storeStream.filter(x -> x.isActive());
26962 amit.gupta 1066 
		}
1067 
		List<Integer> storeIds = storeStream.map(x -> x.getId()).collect(Collectors.toList());
24349 amit.gupta 1068 
		return this.getFofoRetailers(storeIds);
24168 amit.gupta 1069 
	}
25295 amit.gupta 1070 
 
26522 amit.gupta 1071 
	@Override
27861 tejbeer 1072 
	@Cacheable(value = "retailerNames", cacheManager = "oneDayCacheManager")
1073 
	public Map<Integer, CustomRetailer> getAllFofoRetailers() {
1074 
		// TODO Auto-generated method stub
1075 
		Stream<FofoStore> storeStream = fofoStoreRepository.selectAll().stream();
1076 
 
1077 
		List<Integer> storeIds = storeStream.map(x -> x.getId()).collect(Collectors.toList());
1078 
		return this.getFofoRetailers(storeIds);
1079 
	}
1080 
 
1081 
	@Override
26522 amit.gupta 1082 
	public LoginRequestResponseModel registerWebUser(LoginRequestResponseModel loginRequestModel)
1083 
			throws ProfitMandiBusinessException {
1084 
 
1085 
		com.spice.profitmandi.dao.entity.user.User saholicUser = this.createSaholicUser(loginRequestModel);
1086 
		loginRequestModel.setUserId(saholicUser.getId());
1087 
 
1088 
		this.createRetailerAddress(loginRequestModel);
1089 
 
1090 
		this.createPrivateDealUser(loginRequestModel);
1091 
		this.updateSaholicUser(saholicUser.getId(), loginRequestModel.getBusinessAddress().getId());
1092 
 
1093 
		return loginRequestModel;
1094 
 
1095 
	}
1096 
 
1097 
	private void createPrivateDealUser(LoginRequestResponseModel loginRequestModel) {
1098 
 
1099 
		Integer counterId = this.createCounter(loginRequestModel.getEmail(), loginRequestModel.getGstNumber(),
1100 
				loginRequestModel.getBusinessAddress().getPhoneNumber(),
1101 
				loginRequestModel.getBusinessAddress().getName(), loginRequestModel.getBusinessAddress().getId());
1102 
		try {
1103 
			this.createPrivateDealUser(loginRequestModel.getUserId(), counterId, false);
1104 
		} catch (Exception e) {
1105 
			LOGGER.error("ERROR : ", e);
1106 
		}
1107 
 
1108 
		PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
1109 
		privateDealUserAddressMapping.setUserId(loginRequestModel.getUserId());
1110 
		privateDealUserAddressMapping.setAddressId(loginRequestModel.getBusinessAddress().getId());
1111 
		privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
1112 
 
1113 
	}
1114 
 
1115 
	private void createRetailerAddress(LoginRequestResponseModel loginRequestResponseModel)
1116 
			throws ProfitMandiBusinessException {
1117 
		Address businessAddress = loginRequestResponseModel.getBusinessAddress();
1118 
		businessAddress.setRetaierId(loginRequestResponseModel.getUserId());
1119 
		addressRepository.persist(businessAddress);
1120 
	}
26536 amit.gupta 1121 
 
26528 amit.gupta 1122 
	private String getHash256(String originalString) {
26533 amit.gupta 1123 
		String hashString = Hashing.sha256().hashString(originalString, StandardCharsets.UTF_8).toString();
1124 
		LOGGER.info("Hash String {}", hashString);
1125 
		return hashString;
26528 amit.gupta 1126 
	}
26533 amit.gupta 1127 
 
1128 
	@Override
26536 amit.gupta 1129 
	@Cacheable(value = "fofoIdUrl", cacheManager = "oneDayCacheManager")
26533 amit.gupta 1130 
	public Map<Integer, String> getAllFofoRetailerIdUrlMap() {
26536 amit.gupta 1131 
		Map<Integer, String> fofoRetailerUrlMap = new HashMap<>();
1132 
		List<FofoStore> stores = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive())
1133 
				.collect(Collectors.toList());
1134 
		Map<Integer, com.spice.profitmandi.dao.entity.user.User> userMap = userUserRepository
1135 
				.selectByIds(stores.stream().map(x -> x.getId()).collect(Collectors.toList())).stream()
1136 
				.collect(Collectors.toMap(x -> x.getId(), x -> x));
1137 
		for (FofoStore store : stores) {
26537 amit.gupta 1138 
			LOGGER.info("Store is {}", store);
26544 amit.gupta 1139 
			String districtShortName = store.getCode().replaceAll("\\d+", "").substring(2);
26593 amit.gupta 1140 
			String stateShortName = store.getCode().replaceAll("\\d+", "").substring(0, 2);
26539 amit.gupta 1141 
			DistrictMaster districtMaster = null;
26544 amit.gupta 1142 
			LOGGER.info("Store shortname is {}", districtShortName);
26593 amit.gupta 1143 
			districtMaster = districtMasterRepository.selectByShortnameNameAndStateShortName(districtShortName,
1144 
					stateShortName);
26543 amit.gupta 1145 
			if (districtMaster == null) {
26544 amit.gupta 1146 
				districtMaster = districtMasterRepository.selectByShortnameNameAndStateShortName("FB", "HR");
26539 amit.gupta 1147 
			}
26542 amit.gupta 1148 
			LOGGER.info("Store id - {}", store.getId());
26536 amit.gupta 1149 
			com.spice.profitmandi.dao.entity.user.User user = userMap.get(store.getId());
1150 
			String urlString = districtMaster.getStateShortName() + "/"
27877 amit.gupta 1151 
					+ Utils.getHyphenatedString(districtMaster.getName()) + "/" + store.getCode();
26536 amit.gupta 1152 
			fofoRetailerUrlMap.put(store.getId(), urlString);
26541 amit.gupta 1153 
			LOGGER.info("Store is {} end", store);
26536 amit.gupta 1154 
 
1155 
		}
1156 
		return fofoRetailerUrlMap;
26533 amit.gupta 1157 
	}
1158 
 
1159 
	@Override
26590 amit.gupta 1160 
	@Cacheable(value = "storeCodeRetailerMap", cacheManager = "oneDayCacheManager")
1161 
	public Map<String, Integer> getStoreCodeRetailerMap() {
26533 amit.gupta 1162 
		Map<Integer, String> map = this.getAllFofoRetailerIdUrlMap();
26596 amit.gupta 1163 
		Map<String, Integer> returnMap = map.entrySet().stream().collect(Collectors.toMap(x -> {
26593 amit.gupta 1164 
			String[] splitString = x.getValue().split("/");
27877 amit.gupta 1165 
			return splitString[splitString.length - 1];
26593 amit.gupta 1166 
		}, x -> x.getKey()));
26596 amit.gupta 1167 
		LOGGER.info("returnMap {}", returnMap);
1168 
		return returnMap;
26533 amit.gupta 1169 
	}
27877 amit.gupta 1170 
 
1171 
	@Override
1172 
	public String getPartnerCriteriaString(PartnerCriteria partnerCriteria) {
1173 
 
1174 
		StringBuilder sb = new StringBuilder();
1175 
		if (partnerCriteria.getFofoIds().size() > 0) {
1176 
			List<Integer> fofoIds = partnerCriteria.getFofoIds();
1177 
			Map<Integer, CustomRetailer> customRetailers = this.getFofoRetailerUserId(fofoIds);
1178 
			List<String> businessNames = customRetailers.values().stream().map(x->x.getBusinessName()).collect(Collectors.toList());
1179 
			sb.append(String.join(", ", businessNames));
1180 
 
1181 
		} else {
1182 
			sb.append("All");
1183 
			if(partnerCriteria.getPartnerTypes().size() > 0) {
1184 
				sb.append(" ").append(String.join(", ", partnerCriteria.getPartnerTypes().stream().map(x->x.getValue()).collect(Collectors.toList())));
1185 
			}
1186 
			sb.append(" partners ");
1187 
			if(partnerCriteria.getRegionIds().size() > 0) {
1188 
				sb.append("from ");
1189 
				sb.append(String.join(", ", partnerCriteria.getRegionIds().stream().map(x-> ProfitMandiConstants.WAREHOUSE_MAP.get(x)).collect(Collectors.toList())));
1190 
			}
1191 
		}
1192 
		return sb.toString();
1193 
	}
22980 ashik.ali 1194 
}