Subversion Repositories SmartDukaan

Rev

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