Subversion Repositories SmartDukaan

Rev

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