Subversion Repositories SmartDukaan

Rev

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