Subversion Repositories SmartDukaan

Rev

Rev 22416 | Rev 22476 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 22416 Rev 22471
Line 2... Line 2...
2 
 
 2 
 
3 
import java.io.File;
 3 
import java.io.File;
4 
import java.io.IOException;
 4 
import java.io.IOException;
5 
import java.lang.reflect.Type;
 5 
import java.lang.reflect.Type;
6 
import java.time.LocalDateTime;
 6 
import java.time.LocalDateTime;
- 
 
 7 
import java.util.ArrayList;
7 
import java.util.HashMap;
 8 
import java.util.HashMap;
8 
import java.util.HashSet;
 9 
import java.util.HashSet;
9 
import java.util.List;
 10 
import java.util.List;
10 
import java.util.Map;
 11 
import java.util.Map;
11 
import java.util.Set;
 12 
import java.util.Set;
Line 19... Line 20...
19 
import com.google.gson.Gson;
 20 
import com.google.gson.Gson;
20 
import com.google.gson.reflect.TypeToken;
 21 
import com.google.gson.reflect.TypeToken;
21 
import com.spice.profitmandi.common.enumuration.ContentType;
 22 
import com.spice.profitmandi.common.enumuration.ContentType;
22 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 23 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
23 
import com.spice.profitmandi.common.util.FileUtil;
 24 
import com.spice.profitmandi.common.util.FileUtil;
24 
import com.spice.profitmandi.common.util.Utils;
 - 
 
25 
import com.spice.profitmandi.dao.entity.dtr.Document;
 25 
import com.spice.profitmandi.dao.entity.dtr.Document;
26 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
 26 
import com.spice.profitmandi.dao.entity.dtr.Retailer;
27 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
 27 
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
28 
import com.spice.profitmandi.dao.entity.dtr.User;
 28 
import com.spice.profitmandi.dao.entity.dtr.User;
29 
import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
 29 
import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
30 
import com.spice.profitmandi.dao.entity.dtr.UserRole;
 30 
import com.spice.profitmandi.dao.entity.dtr.UserRole;
31 
import com.spice.profitmandi.dao.entity.user.Address;
 31 
import com.spice.profitmandi.dao.entity.user.Address;
- 
 
 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;
32 
import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
 37 
import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
33 
import com.spice.profitmandi.dao.enumuration.dtr.RetailerType;
 38 
import com.spice.profitmandi.dao.enumuration.dtr.RetailerType;
34 
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
 39 
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
35 
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 40 
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
36 
import com.spice.profitmandi.dao.repository.dtr.Mongo;
 41 
import com.spice.profitmandi.dao.repository.dtr.Mongo;
Line 38... Line 43...
38 
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 43 
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
39 
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 44 
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
40 
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 45 
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
41 
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
 46 
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
42 
import com.spice.profitmandi.dao.repository.user.AddressRepository;
 47 
import com.spice.profitmandi.dao.repository.user.AddressRepository;
- 
 
 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;
- 
 
 52 
 
- 
 
 53 
import in.shop2020.model.v1.user.CartStatus;
43 
 
 54 
 
44 
@Component
 55 
@Component
45 
public class MigrationUtil {
 56 
public class MigrationUtil {
46
57
47 
	@Autowired
 58 
	@Autowired
Line 49... Line 60...
49
60
50 
	@Autowired
 61 
	@Autowired
51 
	UserRepository userRepository;
 62 
	UserRepository userRepository;
52
63
53 
	@Autowired
 64 
	@Autowired
- 
 
 65 
	com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
- 
 
 66
- 
 
 67 
	@Autowired
- 
 
 68 
	CartRepository cartRepository;
- 
 
 69
- 
 
 70 
	@Autowired
54 
	UserAccountRepository userAccountRepository;
 71 
	UserAccountRepository userAccountRepository;
55
72
56 
	@Autowired
 73 
	@Autowired
57 
	RetailerRepository retailerRepository;
 74 
	RetailerRepository retailerRepository;
58
75
Line 63... Line 80...
63 
	AddressRepository addressRepository;
 80 
	AddressRepository addressRepository;
64
81
65 
	@Autowired
 82 
	@Autowired
66 
	RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
 83 
	RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
67
84
- 
 
 85 
	@Autowired
- 
 
 86 
	PrivateDealUserRepository privateDealUserRepository;
- 
 
 87
- 
 
 88 
	@Autowired
- 
 
 89 
	PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
- 
 
 90
- 
 
 91 
	@Autowired
- 
 
 92 
	CounterRepository counterRepository;
- 
 
 93
68 
 
 94 
 
69 
	@Autowired
 95 
	@Autowired
70 
	Mongo mongoClient;
 96 
	Mongo mongoClient;
71
97
72
98
73 
	private static final Logger LOGGER = LoggerFactory.getLogger(MigrationUtil.class);
 99 
	private static final Logger LOGGER = LoggerFactory.getLogger(MigrationUtil.class);
74
100
75 
	private List<Map<String, String>> getMongoFofoDoc(){
 101 
	private List<Map<String, String>> getMongoFofoDoc(){
76 
		String fofoFormsJsonString = mongoClient.getFofoFormsJsonString();
 102 
		String fofoFormsJsonString = mongoClient.getFofoFormsJsonString();
77
- 
 
- 
 
 103 
		LOGGER.info("mongoFofoDoc {}", fofoFormsJsonString);
78 
		Gson gson = new Gson();
 104 
		Gson gson = new Gson();
79 
        Type paths = new TypeToken<List<Map<String, String>>>(){}.getType();
 105 
        Type paths = new TypeToken<List<Map<String, String>>>(){}.getType();
80 
        List<Map<String, String>> maps = gson.fromJson(fofoFormsJsonString, paths);
 106 
        List<Map<String, String>> maps = gson.fromJson(fofoFormsJsonString, paths);
81 
        return maps;
 107 
        return maps;
82 
	}
 108 
	}
Line 171... Line 197...
171 
		}
 197 
		}
172 
	}
 198 
	}
173
199
174 
	public void migrateMongoDocToRetailer() throws ProfitMandiBusinessException{
 200 
	public void migrateMongoDocToRetailer() throws ProfitMandiBusinessException{
175 
		List<Map<String, String>> maps = this.getMongoFofoDoc();
 201 
		List<Map<String, String>> maps = this.getMongoFofoDoc();
- 
 
 202 
		//LOGGER.info("mongoFofoDocs {}", maps);
176 
		Set<String> emailIds = new HashSet<>();
 203 
		Set<String> emailIds = new HashSet<>();
177 
		for(Map<String, String> map : maps){
 204 
		for(Map<String, String> map : maps){
178 
			if(map.containsKey("registeredEmail1")){
 205 
			if(map.containsKey("registeredEmail1")){
179 
				emailIds.add(map.get("registeredEmail1"));
 206 
				emailIds.add(map.get("registeredEmail1"));
180 
			}
 207 
			}
181 
		}
 208 
		}
- 
 
 209 
		List<String> foundEmailIds = new ArrayList<>();
- 
 
 210 
		if(!emailIds.isEmpty()){
182 
		List<String> foundEmailIds = userRepository.selectEmailIdsByEmailIds(emailIds);
 211 
			foundEmailIds = userRepository.selectEmailIdsByEmailIds(emailIds);
- 
 
 212 
		}
183 
		emailIds.removeAll(foundEmailIds);
 213 
		emailIds.removeAll(foundEmailIds);
184 
		for(Map<String, String> map : maps){
 214 
		for(Map<String, String> map : maps){
185 
			if(map.containsKey("registeredEmail1") && emailIds.contains(map.get("registeredEmail1"))){
 215 
			if(map.containsKey("registeredEmail1") && emailIds.contains(map.get("registeredEmail1"))){
186 
				User user = new User();
 216 
				User user = new User();
187 
				user.setFirstName("");
 217 
				user.setFirstName("");
Line 199... Line 229...
199 
				user.setActivated(false);
 229 
				user.setActivated(false);
200 
				user.setCreateTimestamp(LocalDateTime.now());
 230 
				user.setCreateTimestamp(LocalDateTime.now());
201 
				user.setUpdateTimestamp(LocalDateTime.now());
 231 
				user.setUpdateTimestamp(LocalDateTime.now());
202 
				userRepository.persist(user);
 232 
				userRepository.persist(user);
203
233
204 
				in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(map.get("registeredEmail1"));
 234 
				//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(map.get("registeredEmail1"));
- 
 
 235
- 
 
 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
205
252
206 
				Retailer retailer = new Retailer();
 253 
				Retailer retailer = new Retailer();
207 
				retailer.setActive(true);
 254 
				retailer.setActive(true);
208 
				retailer.setFofo(true);
 255 
				retailer.setFofo(true);
209 
				retailer.setId(Long.valueOf(saholicUser.getUserId()).intValue());
 256 
				retailer.setId(saholicUser.getId());
210 
				retailer.setMigrated(true);
 257 
				retailer.setMigrated(true);
211 
				retailer.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
 258 
				retailer.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
212 
				retailer.setType(RetailerType.GSTIN);
 259 
				retailer.setType(RetailerType.GSTIN);
213 
				retailerRepository.persist(retailer);
 260 
				retailerRepository.persist(retailer);
214
261
Line 221... Line 268...
221 
				retailerAddress.setLine2(map.containsKey("line2") ? map.get("line2") : "");
 268 
				retailerAddress.setLine2(map.containsKey("line2") ? map.get("line2") : "");
222 
				retailerAddress.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
 269 
				retailerAddress.setName(map.containsKey("registeredBusinessName") ? map.get("registeredBusinessName") : "");
223 
				retailerAddress.setPhoneNumber(map.containsKey("mobile") ? map.get("mobile") : "");
 270 
				retailerAddress.setPhoneNumber(map.containsKey("mobile") ? map.get("mobile") : "");
224 
				retailerAddress.setPinCode(map.containsKey("pincode") ? map.get("pincode") : "");
 271 
				retailerAddress.setPinCode(map.containsKey("pincode") ? map.get("pincode") : "");
225 
				retailerAddress.setState(map.containsKey("state") ? map.get("state") : "");
 272 
				retailerAddress.setState(map.containsKey("state") ? map.get("state") : "");
- 
 
 273 
				retailerAddress.setRetaierId(retailer.getId());
226 
				addressRepository.persist(retailerAddress);
 274 
				addressRepository.persist(retailerAddress);
227
275
228 
				RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
 276 
				RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
229 
				retailerRegisteredAddress.setAddressId(retailerAddress.getId());
 277 
				retailerRegisteredAddress.setAddressId(retailerAddress.getId());
230 
				retailerRegisteredAddress.setRetailerId(retailer.getId());
 278 
				retailerRegisteredAddress.setRetailerId(retailer.getId());
231 
				retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
 279 
				retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
232
280
233 
				UserAccounts saholicUserAccounts = new UserAccounts();
 281 
				UserAccounts saholicUserAccounts = new UserAccounts();
234 
				saholicUserAccounts.setAccount_key(String.valueOf(saholicUser.getUserId()));
 282 
				saholicUserAccounts.setAccount_key(String.valueOf(saholicUser.getId()));
235 
				saholicUserAccounts.setAccount_type(AccountType.saholic);
 283 
				saholicUserAccounts.setAccount_type(AccountType.saholic);
236 
				saholicUserAccounts.setUser_id(user.getId());
 284 
				saholicUserAccounts.setUser_id(user.getId());
237 
				userAccountRepository.persist(saholicUserAccounts);
 285 
				userAccountRepository.persist(saholicUserAccounts);
238 
				UserAccounts cartUserAccounts = new UserAccounts();
 286 
				UserAccounts cartUserAccounts = new UserAccounts();
239 
				cartUserAccounts.setAccount_key(String.valueOf(saholicUser.getActiveCartId()));
 287 
				cartUserAccounts.setAccount_key(String.valueOf(saholicUser.getActiveCartId()));
240 
				cartUserAccounts.setAccount_type(AccountType.cartId);
 288 
				cartUserAccounts.setAccount_type(AccountType.cartId);
241 
				cartUserAccounts.setUser_id(user.getId());
 289 
				cartUserAccounts.setUser_id(user.getId());
242 
				userAccountRepository.persist(cartUserAccounts);
 290 
				userAccountRepository.persist(cartUserAccounts);
243
291
- 
 
 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 
				}
244 
			}
 331 
			}
- 
 
 332
- 
 
 333 
		}
- 
 
 334
- 
 
 335
- 
 
 336 
	}
- 
 
 337
- 
 
 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;
245 
		}
 350 
		}
246 
	}
 351 
	}
247
352
248 
	public void migratePrivateDealToRetailer(){
 353 
	public void migratePrivateDealToRetailer(){
249
354