Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
22125 ashik.ali 1 
package com.spice.profitmandi.dao.util;
2 
 
3 
import java.io.File;
22178 amit.gupta 4 
import java.io.IOException;
22125 ashik.ali 5 
import java.lang.reflect.Type;
22352 ashik.ali 6 
import java.time.LocalDateTime;
22125 ashik.ali 7 
import java.util.HashMap;
22352 ashik.ali 8 
import java.util.HashSet;
22125 ashik.ali 9 
import java.util.List;
10 
import java.util.Map;
22352 ashik.ali 11 
import java.util.Set;
22125 ashik.ali 12 
 
22178 amit.gupta 13 
import org.apache.commons.io.FileUtils;
22125 ashik.ali 14 
import org.slf4j.Logger;
15 
import org.slf4j.LoggerFactory;
16 
import org.springframework.beans.factory.annotation.Autowired;
17 
import org.springframework.stereotype.Component;
18 
 
19 
import com.google.gson.Gson;
20 
import com.google.gson.reflect.TypeToken;
21 
import com.spice.profitmandi.common.enumuration.ContentType;
22 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
22476 ashik.ali 23 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
22125 ashik.ali 24 
import com.spice.profitmandi.common.util.FileUtil;
25 
import com.spice.profitmandi.dao.entity.dtr.Document;
22352 ashik.ali 26 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
27 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
23066 ashik.ali 28 
import com.spice.profitmandi.dao.entity.dtr.Shop;
29 
import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
22352 ashik.ali 30 
import com.spice.profitmandi.dao.entity.dtr.User;
23269 ashik.ali 31 
import com.spice.profitmandi.dao.entity.dtr.UserAccount;
22352 ashik.ali 32 
import com.spice.profitmandi.dao.entity.dtr.UserRole;
33 
import com.spice.profitmandi.dao.entity.user.Address;
22471 ashik.ali 34 
import com.spice.profitmandi.dao.entity.user.Cart;
35 
import com.spice.profitmandi.dao.entity.user.Counter;
36 
import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
37 
import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressId;
38 
import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressMapping;
22352 ashik.ali 39 
import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
40 
import com.spice.profitmandi.dao.enumuration.dtr.RetailerType;
41 
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
22125 ashik.ali 42 
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
43 
import com.spice.profitmandi.dao.repository.dtr.Mongo;
22352 ashik.ali 44 
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
45 
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
23066 ashik.ali 46 
import com.spice.profitmandi.dao.repository.dtr.ShopAddressRepository;
47 
import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
22352 ashik.ali 48 
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
49 
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
50 
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
51 
import com.spice.profitmandi.dao.repository.user.AddressRepository;
22471 ashik.ali 52 
import com.spice.profitmandi.dao.repository.user.CartRepository;
53 
import com.spice.profitmandi.dao.repository.user.CounterRepository;
54 
import com.spice.profitmandi.dao.repository.user.PrivateDealUserAddressMappingRepository;
55 
import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
22125 ashik.ali 56 
 
22471 ashik.ali 57 
import in.shop2020.model.v1.user.CartStatus;
58 
 
22125 ashik.ali 59 
@Component
22352 ashik.ali 60 
public class MigrationUtil {
22125 ashik.ali 61 
 
62 
	@Autowired
22868 ashik.ali 63 
	private DocumentRepository documentRepository;
22125 ashik.ali 64 
 
22352 ashik.ali 65 
	@Autowired
22868 ashik.ali 66 
	private UserRepository userRepository;
22352 ashik.ali 67 
 
68 
	@Autowired
22868 ashik.ali 69 
	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
22471 ashik.ali 70 
 
71 
	@Autowired
22868 ashik.ali 72 
	private CartRepository cartRepository;
22471 ashik.ali 73 
 
74 
	@Autowired
22868 ashik.ali 75 
	private UserAccountRepository userAccountRepository;
22352 ashik.ali 76 
 
77 
	@Autowired
22868 ashik.ali 78 
	private RetailerRepository retailerRepository;
22352 ashik.ali 79 
 
80 
	@Autowired
22868 ashik.ali 81 
	private UserRoleRepository userRoleRepository;
22352 ashik.ali 82 
 
83 
	@Autowired
22868 ashik.ali 84 
	private AddressRepository addressRepository;
22352 ashik.ali 85 
 
86 
	@Autowired
22868 ashik.ali 87 
	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
22352 ashik.ali 88 
 
22471 ashik.ali 89 
	@Autowired
22868 ashik.ali 90 
	private PrivateDealUserRepository privateDealUserRepository;
22471 ashik.ali 91 
 
92 
	@Autowired
22868 ashik.ali 93 
	private PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
22471 ashik.ali 94 
 
95 
	@Autowired
22868 ashik.ali 96 
	private CounterRepository counterRepository;
22471 ashik.ali 97 
 
22162 amit.gupta 98 
	@Autowired
23066 ashik.ali 99 
	private ShopRepository shopRepository;
100 
 
101 
	@Autowired
102 
	private ShopAddressRepository shopAddressRepository;
103 
 
104 
	@Autowired
22868 ashik.ali 105 
	private Mongo mongoClient;
22162 amit.gupta 106 
 
107 
 
22352 ashik.ali 108 
	private static final Logger LOGGER = LoggerFactory.getLogger(MigrationUtil.class);
22125 ashik.ali 109 
 
22352 ashik.ali 110 
	private List<Map<String, String>> getMongoFofoDoc(){
22162 amit.gupta 111 
		String fofoFormsJsonString = mongoClient.getFofoFormsJsonString();
22471 ashik.ali 112 
		LOGGER.info("mongoFofoDoc {}", fofoFormsJsonString);
22125 ashik.ali 113 
		Gson gson = new Gson();
114 
        Type paths = new TypeToken<List<Map<String, String>>>(){}.getType();
115 
        List<Map<String, String>> maps = gson.fromJson(fofoFormsJsonString, paths);
22352 ashik.ali 116 
        return maps;
117 
	}
118 
 
119 
	public void migrateMongoDocToDocumentId() throws ProfitMandiBusinessException{
120 
		List<Map<String, String>> maps = this.getMongoFofoDoc();
121 
        Map<Integer, Map<String, Integer>> fofoIdPathMap = new HashMap<>();
22125 ashik.ali 122 
 
123 
        for(Map<String, String> map : maps){
124 
        	int id = 0;
125 
        	Map<String, Integer> pathMap = new HashMap<>();
126 
        	for(Map.Entry<String, String> entry : map.entrySet()){
127 
        		if(entry.getKey().equals("_id")){
22181 amit.gupta 128 
        			id = (int)Double.parseDouble(entry.getValue());
22125 ashik.ali 129 
        		}
130 
        		if(entry.getValue().startsWith("/hsps-docs/")){
131 
 
132 
        			Document document = new Document();
133 
 
134 
        			try{
22178 amit.gupta 135 
        				File srcFile = new File(entry.getValue());
136 
        				String destFileName = entry.getValue().substring(entry.getValue().lastIndexOf('/') + 1);
137 
        				String destFilePath = "/uploads/";
22182 amit.gupta 138 
        				File destFile = new File(destFilePath + destFileName);
22178 amit.gupta 139 
        				FileUtils.copyFile(srcFile, destFile);
140 
        				ContentType contentType = FileUtil.detectFileType(srcFile);
22125 ashik.ali 141 
        				document.setContentType(contentType);
22178 amit.gupta 142 
        				document.setName(destFileName);
143 
        				document.setPath(destFilePath);
22125 ashik.ali 144 
        				document.setPersisted(true);
22178 amit.gupta 145 
        				document.setSize(srcFile.length());
22125 ashik.ali 146 
        				documentRepository.persist(document);
147 
        				pathMap.put(entry.getKey(), document.getId());
22178 amit.gupta 148 
        			}catch(IOException ioException) {
149 
        				LOGGER.info("IOException occurred");
22125 ashik.ali 150 
        			}
151 
        		}
152 
        	}
153 
        	if(!pathMap.isEmpty()){
154 
        		fofoIdPathMap.put(id, pathMap);
155 
        	}
156 
        }
157 
 
158 
        LOGGER.info("fofoIdPathMap {}", fofoIdPathMap);
159 
        for(Map.Entry<Integer, Map<String, Integer>> entry : fofoIdPathMap.entrySet()){
22162 amit.gupta 160 
        	mongoClient.updateColumnsById(entry.getValue(), entry.getKey());
22125 ashik.ali 161 
        }
162 
 
163 
	}
22352 ashik.ali 164 
 
23269 ashik.ali 165 
	private Set<Integer> toRetailerIds(List<UserAccount> userAccounts){
22868 ashik.ali 166 
		Set<Integer> retailerIds = new HashSet<>();
23269 ashik.ali 167 
		for(UserAccount saholicUserAccount : userAccounts){
168 
			int retailerId = saholicUserAccount.getAccountKey();
22868 ashik.ali 169 
			retailerIds.add(retailerId);
170 
		}
171 
		return retailerIds;
172 
	}
173 
 
23269 ashik.ali 174 
	private Set<Integer> toUserIds(List<UserAccount> userAccounts, Set<Integer> retailerIds){
22868 ashik.ali 175 
		Set<Integer> userIds = new HashSet<>();
23269 ashik.ali 176 
		for(UserAccount saholicUserAccount : userAccounts){
177 
			int retailerId = saholicUserAccount.getAccountKey();
22868 ashik.ali 178 
			if(retailerIds.contains(retailerId)){
23269 ashik.ali 179 
				userIds.add(saholicUserAccount.getUserId());
22416 amit.gupta 180 
			}
22868 ashik.ali 181 
		}
182 
		return userIds;
183 
	}
184 
 
185 
	public void migrateUserToRetailer(){
186 
 
23269 ashik.ali 187 
		List<UserAccount> saholicUserAccounts = userAccountRepository.selectAllSaholicByUserIds(new HashSet<>(userRepository.selectIdAll()));
22868 ashik.ali 188 
		if(saholicUserAccounts.isEmpty()){
189 
			return;
190 
		}
191 
		Set<Integer> retailerIds = this.toRetailerIds(saholicUserAccounts);
192 
		List<Integer> foundRetailerIds = retailerRepository.selectIdsByIds(retailerIds);
193 
		retailerIds.removeAll(foundRetailerIds);
194 
		for(int retailerId : retailerIds){
22416 amit.gupta 195 
			Retailer retailer = new Retailer();
22352 ashik.ali 196 
			try {
22416 amit.gupta 197 
				retailer.setId(retailerId);
198 
				retailer.setMigrated(true);
22352 ashik.ali 199 
				retailerRepository.persist(retailer);
22868 ashik.ali 200 
				LOGGER.info("Retailer migrated {}", retailerId);
22352 ashik.ali 201 
			} catch (ProfitMandiBusinessException e) {
202 
				LOGGER.info("Error occured while commiting retailer");
203 
				e.printStackTrace();
204 
			}
22868 ashik.ali 205 
		}
206 
 
207 
		Set<Integer> userIds = this.toUserIds(saholicUserAccounts, retailerIds);
208 
 
22886 ashik.ali 209 
		if(userIds.isEmpty()){
210 
			return;
211 
		}
22868 ashik.ali 212 
		List<Integer> foundRetailerRoleUserIds = userRoleRepository.selectUserIdsByUserIdsAndRoleType(userIds, RoleType.RETAILER);
213 
 
214 
		Set<Integer> notFoundRetailerRoleUserIds = new HashSet<>(userIds);
215 
		notFoundRetailerRoleUserIds.removeAll(foundRetailerRoleUserIds);
216 
 
217 
		for(int userId : notFoundRetailerRoleUserIds){
218 
			UserRole retailerRole = new UserRole();
219 
			retailerRole.setRoleType(RoleType.RETAILER);
220 
			retailerRole.setUserId(userId);
221 
			try {
222 
				userRoleRepository.persist(retailerRole);
223 
				LOGGER.info("UserId {} with Retailer Role migrated", userId);
224 
			} catch (ProfitMandiBusinessException e) {
225 
				e.printStackTrace();
22352 ashik.ali 226 
			}
22868 ashik.ali 227 
		}
228 
 
229 
		List<Integer> foundUserRoleUserIds = userRoleRepository.selectUserIdsByUserIdsAndRoleType(userIds, RoleType.USER);
230 
 
231 
		Set<Integer> notFoundUserRoleUserIds = new HashSet<>(userIds);
232 
		notFoundUserRoleUserIds.removeAll(foundUserRoleUserIds);
233 
 
234 
		for(int userId : notFoundUserRoleUserIds){
235 
			UserRole userRole = new UserRole();
236 
			userRole.setRoleType(RoleType.USER);
237 
			userRole.setUserId(userId);
238 
			try {
239 
				userRoleRepository.persist(userRole);
240 
				LOGGER.info("UserId {} with User Role migrated", userId);
241 
			} catch (ProfitMandiBusinessException e) {
242 
				e.printStackTrace();
22352 ashik.ali 243 
			}
244 
		}
22868 ashik.ali 245 
 
22352 ashik.ali 246 
	}
247 
 
248 
	public void migrateMongoDocToRetailer() throws ProfitMandiBusinessException{
249 
		List<Map<String, String>> maps = this.getMongoFofoDoc();
22471 ashik.ali 250 
		//LOGGER.info("mongoFofoDocs {}", maps);
22352 ashik.ali 251 
		for(Map<String, String> map : maps){
252 
			if(map.containsKey("registeredEmail1")){
253 
 
22476 ashik.ali 254 
				User user = null;
255 
 
256 
				try{
257 
					user = userRepository.selectByEmailId(map.get("registeredEmail1"));
258 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
23202 ashik.ali 259 
				}
260 
				if(user == null){
22476 ashik.ali 261 
					user = new User();
262 
					user.setFirstName("");
263 
					user.setLastName("");
264 
					user.setCity(map.containsKey("city") ? map.get("city") : "");
265 
					user.setPinCode(Integer.valueOf(map.containsKey("pincode") ? map.get("pincode") : ""));
266 
					user.setMobileNumber(map.containsKey("mobile") ? map.get("mobile") : "");
267 
					user.setEmailId(map.get("registeredEmail1"));
268 
					user.setUsername(map.get("registeredEmail1"));
269 
					user.setPassword("");
270 
					user.setMobile_verified(false);
271 
					user.setReferral_url("");
272 
					user.setGroup_id(1);
22504 amit.gupta 273 
					user.setStatus(1);
23300 amit.gupta 274 
					user.setActivated(true);
22476 ashik.ali 275 
					user.setCreateTimestamp(LocalDateTime.now());
276 
					user.setUpdateTimestamp(LocalDateTime.now());
277 
					userRepository.persist(user);
278 
				}
279 
 
280 
 
22471 ashik.ali 281 
				//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(map.get("registeredEmail1"));
22352 ashik.ali 282 
 
22471 ashik.ali 283 
				com.spice.profitmandi.dao.entity.user.User saholicUser = null;
284 
				boolean foundRetailer = false;
23067 ashik.ali 285 
				try{
286 
					saholicUser = userUserRepository.selectByEmailId(user.getEmailId());
287 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
288 
 
289 
				}
22471 ashik.ali 290 
				if(saholicUser == null){
291 
					Cart cart = new Cart();
292 
					cart.setCartStatus(CartStatus.ACTIVE);
293 
					cartRepository.persist(cart);
294 
					saholicUser = new com.spice.profitmandi.dao.entity.user.User();
295 
					saholicUser.setEmailId(user.getEmailId());
296 
					saholicUser.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
297 
					saholicUser.setActiveCartId(cart.getId());
23300 amit.gupta 298 
					saholicUser.setCreateTimestamp(LocalDateTime.now());
22471 ashik.ali 299 
					userUserRepository.persist(saholicUser);
300 
				}else{
301 
					foundRetailer = true;
302 
				}
303 
 
22476 ashik.ali 304 
				Retailer retailer = null;
22471 ashik.ali 305 
 
22476 ashik.ali 306 
				try{
307 
					retailer = retailerRepository.selectById(saholicUser.getId());
308 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
309 
					retailer = new Retailer();
310 
					retailer.setActive(true);
311 
					retailer.setId(saholicUser.getId());
312 
					retailer.setMigrated(true);
313 
					retailer.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
314 
					retailer.setType(RetailerType.GSTIN);
315 
					retailerRepository.persist(retailer);
316 
				}
22352 ashik.ali 317 
 
22476 ashik.ali 318 
 
22352 ashik.ali 319 
				Address retailerAddress = new Address();
320 
 
22476 ashik.ali 321 
				List<Address> retailerAddresses = addressRepository.selectAll(retailer.getId(), 1, 100);
322 
				if(retailerAddresses.isEmpty()){
323 
					retailerAddress.setCity(map.containsKey(ProfitMandiConstants.CITY) ? map.get(ProfitMandiConstants.CITY) : "");
324 
					retailerAddress.setCountry("India");
325 
					retailerAddress.setEnabled(true);
326 
					retailerAddress.setLandmark("");
327 
					retailerAddress.setLine1(map.containsKey(ProfitMandiConstants.LINE1) ? map.get(ProfitMandiConstants.LINE1) : "");
328 
					retailerAddress.setLine2(map.containsKey(ProfitMandiConstants.LINE2) ? map.get(ProfitMandiConstants.LINE2) : "");
329 
					retailerAddress.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
330 
					retailerAddress.setPhoneNumber(map.containsKey("mobile") ? map.get("mobile") : "");
331 
					retailerAddress.setPinCode(map.containsKey("pincode") ? map.get("pincode") : "");
332 
					retailerAddress.setState(map.containsKey(ProfitMandiConstants.STATE) ? map.get(ProfitMandiConstants.STATE) : "");
333 
					retailerAddress.setRetaierId(retailer.getId());
334 
					addressRepository.persist(retailerAddress);
335 
				}
22352 ashik.ali 336 
 
337 
 
22476 ashik.ali 338 
				RetailerRegisteredAddress retailerRegisteredAddress = null;
339 
				try{
340 
					retailerRegisteredAddress = retailerRegisteredAddressRepository.selectByAddressIdAndRetailerId(retailerAddress.getId(), retailer.getId());
23075 ashik.ali 341 
					//retailerRegisteredAddress = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId());
22476 ashik.ali 342 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
343 
					retailerRegisteredAddress = new RetailerRegisteredAddress();
344 
					retailerRegisteredAddress.setAddressId(retailerAddress.getId());
345 
					retailerRegisteredAddress.setRetailerId(retailer.getId());
346 
					retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
347 
				}
22471 ashik.ali 348 
 
22476 ashik.ali 349 
 
23066 ashik.ali 350 
				List<Shop> shops = shopRepository.selectByRetailerId(retailer.getId());
351 
				if(shops.isEmpty()){
352 
					Shop shop = new Shop();
353 
					shop.setName(retailer.getName());
354 
					shop.setAddressId(retailerAddress.getId());
355 
					shop.setDocumentId(retailer.getDocumentId());
356 
					shop.setRetailerId(retailer.getId());
357 
					shopRepository.persist(shop);
358 
					ShopAddress shopAddress = new ShopAddress();
359 
					shopAddress.setAddressId(retailerAddress.getId());
360 
					shopAddress.setShopId(shop.getId());
361 
					shopAddressRepository.persist(shopAddress);
362 
				}
363 
 
23269 ashik.ali 364 
				UserAccount saholicUserAccounts = null;
22476 ashik.ali 365 
				try{
366 
					saholicUserAccounts = userAccountRepository.selectByUserIdRetailerIdAccountType(user.getId(), retailer.getId(), AccountType.saholic);
367 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
23269 ashik.ali 368 
					saholicUserAccounts = new UserAccount();
369 
					saholicUserAccounts.setAccountKey(saholicUser.getId());
370 
					saholicUserAccounts.setType(AccountType.saholic);
371 
					saholicUserAccounts.setUserId(user.getId());
22476 ashik.ali 372 
					userAccountRepository.persist(saholicUserAccounts);
23269 ashik.ali 373 
					UserAccount cartUserAccounts = new UserAccount();
374 
					cartUserAccounts.setAccountKey(saholicUser.getActiveCartId());
375 
					cartUserAccounts.setType(AccountType.cartId);
376 
					cartUserAccounts.setUserId(user.getId());
22476 ashik.ali 377 
					userAccountRepository.persist(cartUserAccounts);
378 
				}
379 
 
380 
 
381 
				UserRole userRole = null;
382 
				try{
383 
					userRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.USER);
384 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
385 
					userRole = new UserRole();
386 
					userRole.setRoleType(RoleType.USER);
387 
					userRole.setUserId(user.getId());
388 
					userRoleRepository.persist(userRole);
389 
				}
390 
 
391 
				UserRole retailerRole = null;
392 
				try{
393 
					retailerRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.RETAILER);
394 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
395 
					retailerRole = new UserRole();
396 
					retailerRole.setRoleType(RoleType.RETAILER);
397 
					retailerRole.setUserId(user.getId());
398 
					userRoleRepository.persist(retailerRole);
399 
				}
400 
 
401 
				UserRole fofoRole = null;
402 
				try{
403 
					fofoRole = userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.FOFO);
404 
				}catch(ProfitMandiBusinessException profitMandiBusinessException){
405 
					fofoRole = new UserRole();
406 
					fofoRole.setRoleType(RoleType.FOFO);
407 
					fofoRole.setUserId(user.getId());
408 
					userRoleRepository.persist(fofoRole);
409 
				}
410 
 
22471 ashik.ali 411 
				if(foundRetailer){
412 
					LOGGER.info("\n\n\n****retailer found\n\n\n");
22608 ashik.ali 413 
					PrivateDealUser privateDealUser = null;
414 
					try{
415 
						privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
416 
					}catch(ProfitMandiBusinessException profitMandiBusinessException){
417 
						LOGGER.error("PrivateDealUser not found : ", profitMandiBusinessException);
418 
					}
23066 ashik.ali 419 
 
22608 ashik.ali 420 
					 //= privateDealUserRepository.selectById(saholicUser.getId());
421 
					if(privateDealUser == null){
22471 ashik.ali 422 
						Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
22608 ashik.ali 423 
						this.createPrivateDealUser(saholicUser.getId(), counterId);
424 
					}else{
425 
						if(privateDealUser.getCounterId() == null){
426 
							Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
427 
							privateDealUser.setCounterId(counterId);
23066 ashik.ali 428 
							privateDealUser.setFofo(true);
22608 ashik.ali 429 
							privateDealUserRepository.persist(privateDealUser);
430 
						}
22471 ashik.ali 431 
					}
432 
				}else{
433 
					LOGGER.info("retailer not found");
434 
					//gst number intergration with counter
435 
					Integer counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
22608 ashik.ali 436 
					PrivateDealUser privateDealUser = null;
437 
					try{
438 
						privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
439 
					}catch(ProfitMandiBusinessException profitMandiBusinessException){
440 
						LOGGER.error("PrivateDealUser not found : ", profitMandiBusinessException);
441 
					}
442 
					/* //= privateDealUserRepository.selectById(saholicUser.getId());
443 
					if(privateDealUser == null){
444 
						int counterId = this.createCounter(user.getEmailId(), map.get("gst"), user.getMobileNumber(), retailer.getName(), retailerAddress.getId());
445 
						this.createPrivateDealUser(saholicUser.getId(), counterId);
446 
					}*/
22471 ashik.ali 447 
 
22608 ashik.ali 448 
 
22471 ashik.ali 449 
					if(privateDealUser != null){
450 
						//LOGGER.info("PrivateDealUser found with id [{}]", saholicUser.getId());
451 
						privateDealUser.setCounterId(counterId);
23066 ashik.ali 452 
						privateDealUser.setFofo(true);
22471 ashik.ali 453 
						privateDealUserRepository.update(privateDealUser);
454 
					}else{
455 
						LOGGER.info("PrivateDealUser not found with id [{}]", saholicUser.getId());
22608 ashik.ali 456 
						this.createPrivateDealUser(saholicUser.getId(), counterId);
22471 ashik.ali 457 
					}
458 
					PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
459 
					PrivateDealUserAddressId privateDealUserAddressId = new PrivateDealUserAddressId();
460 
					privateDealUserAddressId.setUserId(retailer.getId());
461 
					privateDealUserAddressId.setAddressId(retailerAddress.getId());
462 
					privateDealUserAddressMapping.setId(privateDealUserAddressId);
463 
					privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
464 
 
465 
					saholicUser.setAddressId(retailerAddress.getId());
466 
					userUserRepository.persist(saholicUser);
467 
				}
22352 ashik.ali 468 
			}
22471 ashik.ali 469 
 
22352 ashik.ali 470 
		}
22471 ashik.ali 471 
 
472 
 
22352 ashik.ali 473 
	}
474 
 
22716 amit.gupta 475 
	//Specifically set isFofo to true that has to be used by old system
22608 ashik.ali 476 
	private void createPrivateDealUser(int retailerId, int counterId){
477 
		PrivateDealUser privateDealUser = new PrivateDealUser();
478 
		privateDealUser.setActive(true);
479 
		privateDealUser.setBulkShipmentAmountLimit(50000);
480 
		privateDealUser.setId(retailerId);
481 
		privateDealUser.setCounterId(counterId);
23066 ashik.ali 482 
		privateDealUser.setFofo(true);
22608 ashik.ali 483 
		privateDealUserRepository.persist(privateDealUser);
484 
	}
485 
 
22471 ashik.ali 486 
	private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
487 
		if(gstNumber != null && !gstNumber.isEmpty()){
488 
			Counter counter = new Counter();
489 
			counter.setEmailId(emailId);
490 
			counter.setGstin(gstNumber);
491 
			counter.setMobileNumber(mobileNumber);
492 
			counter.setName(name);
493 
			counter.setAddressId(addressId);
23300 amit.gupta 494 
			counter.setCreatedOn(LocalDateTime.now());
22471 ashik.ali 495 
			counterRepository.persist(counter);
496 
			return counter.getId();
497 
		}else{
498 
			return null;
499 
		}
500 
	}
501 
 
22352 ashik.ali 502 
	public void migratePrivateDealToRetailer(){
503 
 
504 
	}
22125 ashik.ali 505 
}