Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
21292 ashik.ali 1
package com.spice.profitmandi.web.controller;
2
 
22495 amit.gupta 3
import java.util.Date;
21448 ashik.ali 4
import java.util.Set;
5
 
21292 ashik.ali 6
import javax.servlet.http.HttpServletRequest;
7
 
8
import org.slf4j.Logger;
9
import org.slf4j.LoggerFactory;
10
import org.springframework.beans.factory.annotation.Autowired;
22355 ashik.ali 11
import org.springframework.beans.factory.annotation.Qualifier;
21292 ashik.ali 12
import org.springframework.http.ResponseEntity;
13
import org.springframework.stereotype.Controller;
21692 amit.gupta 14
import org.springframework.transaction.annotation.Transactional;
21309 ashik.ali 15
import org.springframework.web.bind.annotation.RequestBody;
21292 ashik.ali 16
import org.springframework.web.bind.annotation.RequestMapping;
17
import org.springframework.web.bind.annotation.RequestMethod;
18
import org.springframework.web.bind.annotation.RequestParam;
19
 
20
import com.spice.profitmandi.common.ResponseCodeHolder;
21
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
22
import com.spice.profitmandi.common.model.ProfitMandiConstants;
21463 ashik.ali 23
import com.spice.profitmandi.common.model.UserInfo;
22473 ashik.ali 24
import com.spice.profitmandi.common.util.StringUtils;
25
import com.spice.profitmandi.common.util.Utils;
21740 ashik.ali 26
import com.spice.profitmandi.common.web.util.ResponseSender;
21735 ashik.ali 27
import com.spice.profitmandi.dao.entity.dtr.Brand;
22473 ashik.ali 28
import com.spice.profitmandi.dao.entity.dtr.DistrictMaster;
21735 ashik.ali 29
import com.spice.profitmandi.dao.entity.dtr.Document;
30
import com.spice.profitmandi.dao.entity.dtr.Retailer;
31
import com.spice.profitmandi.dao.entity.dtr.RetailerBrand;
32
import com.spice.profitmandi.dao.entity.dtr.RetailerRegisteredAddress;
33
import com.spice.profitmandi.dao.entity.dtr.Shop;
34
import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
35
import com.spice.profitmandi.dao.entity.dtr.User;
21768 amit.gupta 36
import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
37
import com.spice.profitmandi.dao.entity.dtr.UserRole;
22656 ashik.ali 38
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
39
import com.spice.profitmandi.dao.entity.fofo.FofoStoreSequenceGeneration;
21735 ashik.ali 40
import com.spice.profitmandi.dao.entity.user.Address;
22355 ashik.ali 41
import com.spice.profitmandi.dao.entity.user.Cart;
42
import com.spice.profitmandi.dao.entity.user.Counter;
43
import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
44
import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressId;
45
import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressMapping;
21768 amit.gupta 46
import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
47
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
22495 amit.gupta 48
import com.spice.profitmandi.dao.model.RetailerFofoInterest;
21735 ashik.ali 49
import com.spice.profitmandi.dao.repository.dtr.BrandRepository;
22473 ashik.ali 50
import com.spice.profitmandi.dao.repository.dtr.DistrictMasterRepository;
21735 ashik.ali 51
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
22473 ashik.ali 52
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
53
import com.spice.profitmandi.dao.repository.dtr.FofoStoreSequenceGenerationRepository;
22495 amit.gupta 54
import com.spice.profitmandi.dao.repository.dtr.Mongo;
21735 ashik.ali 55
import com.spice.profitmandi.dao.repository.dtr.RetailerAddressRepository;
56
import com.spice.profitmandi.dao.repository.dtr.RetailerBrandRepository;
57
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
58
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
59
import com.spice.profitmandi.dao.repository.dtr.ShopAddressRepository;
60
import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
21768 amit.gupta 61
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
21735 ashik.ali 62
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
21768 amit.gupta 63
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
21735 ashik.ali 64
import com.spice.profitmandi.dao.repository.user.AddressRepository;
22355 ashik.ali 65
import com.spice.profitmandi.dao.repository.user.CartRepository;
66
import com.spice.profitmandi.dao.repository.user.CounterRepository;
67
import com.spice.profitmandi.dao.repository.user.PrivateDealUserAddressMappingRepository;
68
import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
21431 ashik.ali 69
import com.spice.profitmandi.web.req.Category;
21426 ashik.ali 70
import com.spice.profitmandi.web.req.CreateRetailerAddressRequest;
71
import com.spice.profitmandi.web.req.CreateRetailerRequest;
72
import com.spice.profitmandi.web.req.RetailerAddBrandRequest;
21292 ashik.ali 73
 
22473 ashik.ali 74
import in.shop2020.model.v1.inventory.StateInfo;
22355 ashik.ali 75
import in.shop2020.model.v1.user.CartStatus;
21302 ashik.ali 76
import io.swagger.annotations.ApiImplicitParam;
77
import io.swagger.annotations.ApiImplicitParams;
78
import io.swagger.annotations.ApiOperation;
79
 
21292 ashik.ali 80
@Controller
22037 amit.gupta 81
@Transactional(rollbackFor=Throwable.class)
21292 ashik.ali 82
public class RetailerController {
83
 
84
	private static final Logger LOGGER=LoggerFactory.getLogger(RetailerController.class);
85
 
86
	@Autowired
22355 ashik.ali 87
	@Qualifier("userRepository")
22931 ashik.ali 88
	private UserRepository userRepository;
21463 ashik.ali 89
 
90
	@Autowired
22355 ashik.ali 91
	@Qualifier("userUserRepository")
22931 ashik.ali 92
	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
22355 ashik.ali 93
 
94
	@Autowired
22931 ashik.ali 95
	private UserRoleRepository userRoleRepository;
21768 amit.gupta 96
 
97
	@Autowired
22931 ashik.ali 98
	private ResponseSender<?> responseSender;
21440 ashik.ali 99
 
100
	@Autowired
22931 ashik.ali 101
	private RetailerRepository retailerRepository;
21292 ashik.ali 102
 
21390 ashik.ali 103
	@Autowired
22931 ashik.ali 104
	private BrandRepository brandRepository;
21390 ashik.ali 105
 
106
	@Autowired
22931 ashik.ali 107
	private AddressRepository addressRepository;
21390 ashik.ali 108
 
109
	@Autowired
22931 ashik.ali 110
	private DocumentRepository documentRepository;
21390 ashik.ali 111
 
112
	@Autowired
22931 ashik.ali 113
	private ShopRepository shopRepository;
21390 ashik.ali 114
 
115
	@Autowired
22931 ashik.ali 116
	private UserAccountRepository userAccountRepository;
21768 amit.gupta 117
 
118
	@Autowired
22931 ashik.ali 119
	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
21390 ashik.ali 120
 
121
	@Autowired
22931 ashik.ali 122
	private RetailerAddressRepository retailerAddressRepository;
21426 ashik.ali 123
 
124
	@Autowired
22931 ashik.ali 125
	private ShopAddressRepository shopAddressRepository;
21390 ashik.ali 126
 
127
	@Autowired
22931 ashik.ali 128
	private RetailerBrandRepository retailerBrandRepository;
21390 ashik.ali 129
 
22355 ashik.ali 130
	@Autowired
22931 ashik.ali 131
	private CounterRepository counterRepository;
22355 ashik.ali 132
 
133
	@Autowired
22931 ashik.ali 134
	private PrivateDealUserRepository privateDealUserRepository;
22355 ashik.ali 135
 
136
	@Autowired
22931 ashik.ali 137
	private PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
22355 ashik.ali 138
 
139
	@Autowired
22931 ashik.ali 140
	private CartRepository cartRepository;
22355 ashik.ali 141
 
22473 ashik.ali 142
	@Autowired
22931 ashik.ali 143
	private DistrictMasterRepository districtMasterRepository;
22473 ashik.ali 144
 
145
	@Autowired
22931 ashik.ali 146
	private FofoStoreRepository fofoStoreRepository;
22473 ashik.ali 147
 
148
	@Autowired
22495 amit.gupta 149
	private Mongo mongoClient;
150
 
151
	@Autowired
22931 ashik.ali 152
	private FofoStoreSequenceGenerationRepository fofoStoreSequenceGenerationRepository;
22473 ashik.ali 153
 
21302 ashik.ali 154
	@ApiImplicitParams({
155
		@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", 
156
				required = true, dataType = "string", paramType = "header")
157
	})
21309 ashik.ali 158
 
21302 ashik.ali 159
	@ApiOperation(value = "Create Retailer")
160
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER, method=RequestMethod.POST)
22931 ashik.ali 161
	public ResponseEntity<?> createRetailer(HttpServletRequest request, @RequestBody CreateRetailerRequest createRetailerRequest) throws ProfitMandiBusinessException{
22355 ashik.ali 162
		LOGGER.info("request received with body [{}] at url {{}}: ", createRetailerRequest, request.getRequestURL().toString());
22931 ashik.ali 163
		UserInfo userInfo = (UserInfo)request.getAttribute("userInfo");
164
		LOGGER.info("requestAttribute [userInfo={}]", userInfo);
165
		User user = userRepository.selectById(userInfo.getUserId());
166
		this.createRetailer(user, createRetailerRequest);
167
		return responseSender.ok(ResponseCodeHolder.getMessage("RTLR_OK_1000"));
168
 
21440 ashik.ali 169
	}
170
 
21768 amit.gupta 171
	private void createRetailer(User user, CreateRetailerRequest createRetailerRequest) 
22931 ashik.ali 172
			throws ProfitMandiBusinessException{
21390 ashik.ali 173
		Retailer retailer = new Retailer();
21426 ashik.ali 174
		retailer.setName(createRetailerRequest.getName());
175
		retailer.setNumber(createRetailerRequest.getNumber());
176
		retailer.setType(createRetailerRequest.getType());
177
		retailer.setMonthlySaleValue(createRetailerRequest.getMonthlySaleValue());
22732 ashik.ali 178
		retailer.setMonthlySaleVolume(createRetailerRequest.getMonthlySaleVolume());
23035 ashik.ali 179
		retailer.setPrimaryBuyingMode(createRetailerRequest.getPrimaryBuyingMode());
21426 ashik.ali 180
		retailer.setRecharge(createRetailerRequest.getLineOfBusiness().isRecharge());
181
		retailer.setMobile(createRetailerRequest.getLineOfBusiness().isMobile());
182
		retailer.setAccessories(createRetailerRequest.getLineOfBusiness().isAccessories());
21431 ashik.ali 183
		retailer.setOther1(createRetailerRequest.getLineOfBusiness().getOther1());
184
		retailer.setOther2(createRetailerRequest.getLineOfBusiness().getOther2());
22964 ashik.ali 185
		if(createRetailerRequest.getDocumentId() == 0){
186
			retailer.setDocumentId(null);
187
		}else{
23041 ashik.ali 188
			/*Document retailerDocument = documentRepository.selectById(createRetailerRequest.getDocumentId());
22964 ashik.ali 189
			if(retailerRepository.isExistByDocumentId(retailerDocument.getId())){
190
				LOGGER.error("documet is already mapped with another retailer");
191
				throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, retailerDocument.getId(), "DCMNT_1000");
23041 ashik.ali 192
			}*/
193
			retailer.setDocumentId(createRetailerRequest.getDocumentId());
194
			documentRepository.markDocumentAsPersisted(createRetailerRequest.getDocumentId());
21440 ashik.ali 195
		}
22964 ashik.ali 196
		Shop shop = new Shop();
197
		shop.setName(createRetailerRequest.getShop().getName());
198
 
199
		if(createRetailerRequest.getShop().getDocumentId() == 0){
200
			shop.setDocumentId(null);
201
		}else{
23041 ashik.ali 202
			/*final Document shopDocument = documentRepository.selectById(createRetailerRequest.getShop().getDocumentId());
22964 ashik.ali 203
			if(shopRepository.isExistByDocumentId(shopDocument.getId())){
204
				throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, shopDocument.getId(), "DCMNT_1000");
23041 ashik.ali 205
			}*/
206
			shop.setDocumentId(createRetailerRequest.getShop().getDocumentId());
207
			documentRepository.markDocumentAsPersisted(createRetailerRequest.getShop().getDocumentId());
21440 ashik.ali 208
		}
22355 ashik.ali 209
 
210
		com.spice.profitmandi.dao.entity.user.User saholicUser = null;
23042 ashik.ali 211
		boolean foundRetailerFlag = false;
22954 amit.gupta 212
		try {
213
			saholicUser = userUserRepository.selectByEmailId(user.getEmailId());
214
		}catch (ProfitMandiBusinessException e) {
215
			LOGGER.info("User doesnt exist in old system");
216
		}
22355 ashik.ali 217
		if(saholicUser == null){
218
			Cart cart = new Cart();
219
			cart.setCartStatus(CartStatus.ACTIVE);
220
			cartRepository.persist(cart);
221
			saholicUser = new com.spice.profitmandi.dao.entity.user.User();
222
			saholicUser.setEmailId(user.getEmailId());
223
			saholicUser.setName(createRetailerRequest.getName());
224
			saholicUser.setActiveCartId(cart.getId());
225
			userUserRepository.persist(saholicUser);
226
		}else{
23042 ashik.ali 227
			foundRetailerFlag = true;
22355 ashik.ali 228
		}
23042 ashik.ali 229
		Retailer foundRetailer = null;
23039 ashik.ali 230
		try{
23042 ashik.ali 231
			foundRetailer = retailerRepository.selectById(saholicUser.getId());
23039 ashik.ali 232
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
23041 ashik.ali 233
			LOGGER.info("Retailer is not registered");
23039 ashik.ali 234
		}
23042 ashik.ali 235
		if(foundRetailer != null){
236
			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, saholicUser.getEmailId(), "RTLR_1011");
237
		}
22355 ashik.ali 238
		//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(user.getEmailId()); 
239
		retailer.setId(saholicUser.getId());
21440 ashik.ali 240
		retailerRepository.persist(retailer);
22355 ashik.ali 241
 
22965 ashik.ali 242
		shop.setRetailerId(retailer.getId());
23041 ashik.ali 243
		//LOGGER.info("Shop is persisting ... [{}]",shop);
22965 ashik.ali 244
		shopRepository.persist(shop);
22964 ashik.ali 245
 
21448 ashik.ali 246
		this.addBrandWithRetailer(retailer.getId(), createRetailerRequest.getCategories());
21440 ashik.ali 247
		final Address addressRetailer = this.createAddress(createRetailerRequest.getAddress());
21706 amit.gupta 248
		addressRetailer.setRetaierId(retailer.getId());
22041 amit.gupta 249
		addressRepository.persist(addressRetailer);
22355 ashik.ali 250
 
21440 ashik.ali 251
		final RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
252
		retailerRegisteredAddress.setRetailerId(retailer.getId());
253
		retailerRegisteredAddress.setAddressId(addressRetailer.getId());
254
		retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
21463 ashik.ali 255
		if(!createRetailerRequest.isShopAddressSameAsRetailerAddress() && createRetailerRequest.getAddress() == null){
256
			throw new ProfitMandiBusinessException(ProfitMandiConstants.ADDRESS, "", "");
21440 ashik.ali 257
		}
21463 ashik.ali 258
		if(createRetailerRequest.isShopAddressSameAsRetailerAddress()){
259
			ShopAddress shopAddress = new ShopAddress();
260
			shopAddress.setShopId(shop.getId());
261
			shopAddress.setAddressId(addressRetailer.getId());
262
			shopAddressRepository.persist(shopAddress);
263
		}else{
264
			final Address addressShop = this.createAddress(createRetailerRequest.getShop().getAddress());
22855 amit.gupta 265
			addressShop.setRetaierId(retailer.getId());
22041 amit.gupta 266
			addressRepository.persist(addressShop);
21463 ashik.ali 267
			ShopAddress shopAddress = new ShopAddress();
268
			shopAddress.setShopId(shop.getId());
269
			shopAddress.setAddressId(addressShop.getId());
270
			shopAddressRepository.persist(shopAddress);
271
		}
21768 amit.gupta 272
		UserAccounts ua = new UserAccounts();
22355 ashik.ali 273
		ua.setAccount_key(String.valueOf(saholicUser.getId()));
21768 amit.gupta 274
		ua.setUser_id(user.getId());
21769 amit.gupta 275
		ua.setAccount_type(AccountType.saholic);
21768 amit.gupta 276
		userAccountRepository.persist(ua);
277
 
278
		UserAccounts ua2 = new UserAccounts();
279
		ua2.setAccount_key(String.valueOf(saholicUser.getActiveCartId()));
280
		ua2.setUser_id(user.getId());
281
		ua2.setAccount_type(AccountType.cartId);
282
		userAccountRepository.persist(ua2);
283
 
284
		UserRole ur = new UserRole();
22011 ashik.ali 285
		ur.setRoleType(RoleType.RETAILER);
21768 amit.gupta 286
		ur.setUserId(user.getId());
287
		userRoleRepository.persist(ur);
22355 ashik.ali 288
 
23042 ashik.ali 289
		if(foundRetailerFlag){
22355 ashik.ali 290
			LOGGER.info("\n\n\n****retailer found\n\n\n");
22604 ashik.ali 291
			PrivateDealUser privateDealUser = null;
292
			try{
293
				privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
294
			}catch(ProfitMandiBusinessException profitMandiBusinessException){
295
				LOGGER.error("PrivateDealUser not found : ", profitMandiBusinessException);
296
			}
22503 amit.gupta 297
			if(privateDealUser == null) {
298
				privateDealUser = new PrivateDealUser();
299
				privateDealUser.setActive(true);
300
				privateDealUser.setBulkShipmentAmountLimit(50000);
301
				privateDealUser.setId(saholicUser.getId());
302
				privateDealUserRepository.persist(privateDealUser);
303
				PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
304
				PrivateDealUserAddressId privateDealUserAddressId = new PrivateDealUserAddressId();
305
				privateDealUserAddressId.setUserId(retailer.getId());
306
				privateDealUserAddressId.setAddressId(addressRetailer.getId());
307
				privateDealUserAddressMapping.setId(privateDealUserAddressId);
308
				privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
309
			}
22355 ashik.ali 310
			if(privateDealUser.getCounterId() == null){
311
				Integer counterId = this.createCounter(user.getEmailId(), createRetailerRequest.getGstNumber(), user.getMobileNumber(), retailer.getName(), addressRetailer.getId());
312
				privateDealUser.setCounterId(counterId);
313
				privateDealUserRepository.persist(privateDealUser);
314
			}
315
		}else{
316
			LOGGER.info("retailer not found");
317
			//gst number intergration with counter
318
			Integer counterId = this.createCounter(user.getEmailId(), createRetailerRequest.getGstNumber(), user.getMobileNumber(), retailer.getName(), addressRetailer.getId());
319
 
320
 
22604 ashik.ali 321
			PrivateDealUser privateDealUser = null;
322
			try{
323
				privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
324
			}catch(ProfitMandiBusinessException profitMandiBusinessException){
22875 amit.gupta 325
				LOGGER.warn("PrivateDealUser not found");
22604 ashik.ali 326
			}
327
 
22355 ashik.ali 328
			if(privateDealUser != null){
329
				//LOGGER.info("PrivateDealUser found with id [{}]", saholicUser.getId());
330
				privateDealUser.setCounterId(counterId);
331
				privateDealUserRepository.update(privateDealUser);
332
			}else{	
22875 amit.gupta 333
				LOGGER.info("PrivateDealUser not found with id [{}], creating it", saholicUser.getId());
22355 ashik.ali 334
				privateDealUser = new PrivateDealUser();
335
				privateDealUser.setActive(true);
336
				privateDealUser.setBulkShipmentAmountLimit(50000);
337
				privateDealUser.setId(saholicUser.getId());
338
				privateDealUser.setCounterId(counterId);
339
				privateDealUserRepository.persist(privateDealUser);
340
			}
341
			PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
342
			PrivateDealUserAddressId privateDealUserAddressId = new PrivateDealUserAddressId();
343
			privateDealUserAddressId.setUserId(retailer.getId());
344
			privateDealUserAddressId.setAddressId(addressRetailer.getId());
345
			privateDealUserAddressMapping.setId(privateDealUserAddressId);
346
			privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
347
 
348
			saholicUser.setAddressId(addressRetailer.getId());
349
			userUserRepository.persist(saholicUser);
350
		}
21292 ashik.ali 351
	}
352
 
22355 ashik.ali 353
	private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
354
		if(gstNumber != null && !gstNumber.isEmpty()){
355
			Counter counter = new Counter();
356
			counter.setEmailId(emailId);
357
			counter.setGstin(gstNumber);
358
			counter.setMobileNumber(mobileNumber);
359
			counter.setName(name);
360
			counter.setAddressId(addressId);
361
			counterRepository.persist(counter);
362
			return counter.getId();
363
		}else{
364
			return null;
365
		}
21463 ashik.ali 366
	}
22355 ashik.ali 367
 
368
 
21448 ashik.ali 369
	private void addBrandWithRetailer(int retailerId, Set<Category> categories)
370
		throws ProfitMandiBusinessException{
371
		for(Category category : categories){
372
			for(com.spice.profitmandi.web.req.Brand brandModel : category.getBrands()){
373
				Brand brand = brandRepository.selectByIdAndName(brandModel.getId(), brandModel.getName());
374
				final RetailerBrand retailerBrand = new RetailerBrand();
375
				retailerBrand.setRetailerId(retailerId);
376
				retailerBrand.setBrandId(brand.getId());
377
				retailerBrandRepository.persist(retailerBrand);
378
			}
379
		}
380
	}
22524 ashik.ali 381
 
382
	@ApiOperation(value = "Create Fofo Store")
383
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_FOFO_FOFO_STORE, method=RequestMethod.POST)
384
	public ResponseEntity<?> createFofoStore(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.DISTRICT_NAME) String districtName) throws ProfitMandiBusinessException, Exception{
22931 ashik.ali 385
		UserInfo userInfo = (UserInfo)request.getAttribute("userInfo");
386
		LOGGER.info("requestAttribute [userInfo={}]", userInfo);
387
		User user = userRepository.selectById(userInfo.getUserId());
388
		// = userAccountRepository.selectRetailerIdByUserId(user.getId());
389
		UserAccounts userAccounts = userAccountRepository.selectSaholicByUserId(user.getId());
390
		Retailer retailer = retailerRepository.selectById(Integer.parseInt(userAccounts.getAccount_key()));
22524 ashik.ali 391
		try{
22931 ashik.ali 392
			userRoleRepository.selectByUserIdAndRoleType(user.getId(), RoleType.FOFO);
393
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
394
			throw new ProfitMandiBusinessException(ProfitMandiConstants.USER_ID, user.getId(), "USR_1013");
395
		}
396
 
397
		boolean foundFofoStore = false;
398
		try{
399
			fofoStoreRepository.selectByRetailerId(retailer.getId());
400
			foundFofoStore = true;
401
		}catch (ProfitMandiBusinessException profitMandiBusinessException) {
22604 ashik.ali 402
 
22524 ashik.ali 403
		}
22931 ashik.ali 404
 
405
		if(foundFofoStore){
406
			throw new ProfitMandiBusinessException(ProfitMandiConstants.RETAILER_ID, retailer.getId(), "USR_1014");
407
		}			
408
 
409
		int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId());
410
		Address retailerAddress = addressRepository.selectById(retailerAddressId);
411
 
412
		StateInfo stateInfo = Utils.getStateInfo(retailerAddress.getState());
413
		DistrictMaster districtMaster = districtMasterRepository.selectByNameAndStateShortName(districtName, stateInfo.getShortName());
414
		FofoStoreSequenceGeneration fofoStoreSequenceGeneration = null;
415
		boolean foundFofoStoreSequence = false;
416
		try{
417
			fofoStoreSequenceGeneration = fofoStoreSequenceGenerationRepository.selectByStateShortName(stateInfo.getShortName());
418
			foundFofoStoreSequence = true;
419
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
420
			fofoStoreSequenceGeneration = new FofoStoreSequenceGeneration();
421
			fofoStoreSequenceGeneration.setSequence(1);
422
			fofoStoreSequenceGeneration.setStateShortName(stateInfo.getShortName());
423
			fofoStoreSequenceGenerationRepository.persist(fofoStoreSequenceGeneration);
424
		}
425
 
426
		FofoStore fofoStore = new FofoStore();
427
		fofoStore.setId(retailer.getId());
428
		String fofoStoreCode = StringUtils.generateFofoStoreSequence(districtMaster.getStateShortName() + districtMaster.getShortName(), fofoStoreSequenceGeneration.getSequence());
429
		if(foundFofoStoreSequence){
430
			fofoStoreSequenceGeneration.setSequence(fofoStoreSequenceGeneration.getSequence() + 1);
431
			fofoStoreSequenceGenerationRepository.persist(fofoStoreSequenceGeneration);
432
		}
433
		fofoStore.setCode(fofoStoreCode);
434
		fofoStoreRepository.persist(fofoStore);
435
 
436
		return responseSender.ok(ResponseCodeHolder.getMessage("RTLR_OK_1003"));
437
 
22524 ashik.ali 438
	}
439
 
21292 ashik.ali 440
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ALL,method=RequestMethod.GET)
21496 ashik.ali 441
	public ResponseEntity<?> getAll(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.PAGE_NUMBER) int pageNumber, @RequestParam(name = ProfitMandiConstants.PAGE_SIZE) int pageSize){
21292 ashik.ali 442
		LOGGER.info("requested url : "+request.getRequestURL().toString());
21496 ashik.ali 443
		return responseSender.ok(retailerRepository.selectAll(pageNumber, pageSize));
21292 ashik.ali 444
	}
445
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ID, method=RequestMethod.GET)
22931 ashik.ali 446
	public ResponseEntity<?> getById(HttpServletRequest request, @RequestParam(name = "id") int id) throws ProfitMandiBusinessException{
21292 ashik.ali 447
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 448
		return responseSender.ok(retailerRepository.selectById(id));
21292 ashik.ali 449
	}
450
 
451
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_NAME, method=RequestMethod.GET)
22931 ashik.ali 452
	public ResponseEntity<?> getByName(HttpServletRequest request, @RequestParam(name = "name") String name) throws ProfitMandiBusinessException{
21292 ashik.ali 453
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 454
		return responseSender.ok(retailerRepository.selectByName(name));
21292 ashik.ali 455
	}
456
 
457
 
458
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ID,method=RequestMethod.DELETE)
22931 ashik.ali 459
	public ResponseEntity<?> removeById(HttpServletRequest request, @RequestParam(name = "id") int id) throws ProfitMandiBusinessException{
21292 ashik.ali 460
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 461
		retailerRepository.deleteById(id);
462
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
21292 ashik.ali 463
	}
464
 
21426 ashik.ali 465
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_SHOP_ADD, method=RequestMethod.POST)
22931 ashik.ali 466
	public ResponseEntity<?> addShop(HttpServletRequest request, @RequestBody com.spice.profitmandi.web.req.Shop createShop, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21426 ashik.ali 467
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 468
		Document document = documentRepository.selectById(createShop.getDocumentId());
469
		if(shopRepository.isExistByDocumentId(createShop.getDocumentId())){
470
			LOGGER.error("documet is already mapped with another shop");
471
			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "");
21426 ashik.ali 472
		}
22931 ashik.ali 473
		retailerRepository.selectById(retailerId);
474
		Shop shop = new Shop();
475
		shop.setRetailerId(retailerId);
476
		Address address = this.createAddress(createShop.getAddress());
477
		addressRepository.persist(address);
478
		shop.setAddressId(address.getId());
479
		shop.setDocumentId(document.getId());
480
		shopRepository.persist(shop);
481
		ShopAddress shopAddress = new ShopAddress();
482
		shopAddress.setAddressId(address.getId());
483
		shopAddress.setShopId(shop.getId());
484
		shopAddressRepository.persist(shopAddress);
485
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
486
 
21426 ashik.ali 487
	}
488
 
489
 
21302 ashik.ali 490
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_SHOP_REMOVE, method=RequestMethod.DELETE)
22931 ashik.ali 491
	public ResponseEntity<?> removeShop(HttpServletRequest request, @RequestParam(name = "shopId") int shopId, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21292 ashik.ali 492
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 493
		retailerRepository.removeShop(shopId, retailerId);
494
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
21292 ashik.ali 495
	}
496
 
21426 ashik.ali 497
	private Address createAddress(com.spice.profitmandi.web.req.Address createAddress){
498
		Address address = new Address();
499
		address.setName(createAddress.getName());
500
		address.setLine1(createAddress.getLine1());
501
		address.setLine2(createAddress.getLine2());
502
		address.setLandmark(createAddress.getLandmark());
503
		address.setCity(createAddress.getCity());
504
		address.setState(createAddress.getState());
505
		address.setPinCode(createAddress.getPinCode());
506
		address.setCountry(createAddress.getCountry());
507
		address.setPhoneNumber(createAddress.getPhoneNumber());
21706 amit.gupta 508
 
21426 ashik.ali 509
		return address;
510
	}
21440 ashik.ali 511
 
21426 ashik.ali 512
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ADDRESS_ADD, method=RequestMethod.POST)
22931 ashik.ali 513
	public ResponseEntity<?> addAddress(HttpServletRequest request, @RequestBody CreateRetailerAddressRequest createRetailerAddress) throws ProfitMandiBusinessException{
21426 ashik.ali 514
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 515
		retailerRepository.addAddress(this.createAddress(createRetailerAddress.getAddress()), createRetailerAddress.getRetailerId());
516
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
517
 
21426 ashik.ali 518
	}
21292 ashik.ali 519
 
21426 ashik.ali 520
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ADDRESS_REMOVE, method=RequestMethod.DELETE)
22931 ashik.ali 521
	public ResponseEntity<?> removeAddress(HttpServletRequest request, @RequestParam(name = "addressId") int addressId, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21426 ashik.ali 522
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 523
		retailerRepository.removeAddress(addressId, retailerId);
524
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
21426 ashik.ali 525
	}
526
 
527
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_BRAND_ADD, method=RequestMethod.POST)
22931 ashik.ali 528
	public ResponseEntity<?> addBrand(HttpServletRequest request, @RequestBody RetailerAddBrandRequest retailerAddBrandRequest) throws ProfitMandiBusinessException{
21426 ashik.ali 529
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 530
		retailerRepository.selectById(retailerAddBrandRequest.getRetailerId());
531
		this.addBrandWithRetailer(retailerAddBrandRequest.getRetailerId(), retailerAddBrandRequest.getCategories());
532
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
533
 
21426 ashik.ali 534
	}
535
 
536
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_BRAND_REMOVE, method=RequestMethod.DELETE)
22931 ashik.ali 537
	public ResponseEntity<?> removeBrand(HttpServletRequest request, @RequestParam(name = "brandId") int brandId, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21426 ashik.ali 538
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 539
		brandRepository.selectById(brandId);
540
		retailerRepository.selectById(retailerId);
541
		retailerBrandRepository.deleteByRetailerAndBrandId(retailerId, brandId);
542
		return responseSender.ok(ResponseCodeHolder.getMessage("API_OK_1001"));
543
 
21426 ashik.ali 544
	}
545
 
546
 
21448 ashik.ali 547
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_DOCUMENT, method=RequestMethod.GET)
22931 ashik.ali 548
	public ResponseEntity<?> getDocumentById(HttpServletRequest request, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21426 ashik.ali 549
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 550
		return responseSender.ok(retailerRepository.selectDocumentById(retailerId));
551
 
21426 ashik.ali 552
	}
553
 
21448 ashik.ali 554
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_REGISTERED_ADDRESS, method=RequestMethod.GET)
22931 ashik.ali 555
	public ResponseEntity<?> getRegisteredAddressById(HttpServletRequest request, @RequestParam(name = "retailerId") int retailerId) throws ProfitMandiBusinessException{
21448 ashik.ali 556
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 557
		return responseSender.ok(retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailerId));
558
 
21448 ashik.ali 559
	}
560
 
21426 ashik.ali 561
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_SHOP_ALL, method=RequestMethod.GET)
22931 ashik.ali 562
	public ResponseEntity<?> getAllShops(HttpServletRequest request, @RequestParam(name = "id") int id)throws ProfitMandiBusinessException{
21426 ashik.ali 563
		LOGGER.info("requested url : "+request.getRequestURL().toString());
22931 ashik.ali 564
		return responseSender.ok(shopRepository.selectByRetailerId(id));
565
 
21426 ashik.ali 566
	}
567
 
568
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_ADDRESS_ALL, method=RequestMethod.GET)
21431 ashik.ali 569
	public ResponseEntity<?> getAllAddresses(HttpServletRequest request, @RequestParam(name = "id") int id){
21426 ashik.ali 570
		LOGGER.info("requested url : "+request.getRequestURL().toString());
21440 ashik.ali 571
		return responseSender.ok(retailerAddressRepository.selectAddressesByRetailerId(id));
21426 ashik.ali 572
	}
573
 
574
 
575
	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER_BRAND_ALL, method=RequestMethod.GET)
21431 ashik.ali 576
	public ResponseEntity<?> getAllBrads(HttpServletRequest request, @RequestParam(name = "id") int id){
21426 ashik.ali 577
		LOGGER.info("requested url : "+request.getRequestURL().toString());
21440 ashik.ali 578
		return responseSender.ok(retailerBrandRepository.selectBrandNamesByRetailerId(id));
21426 ashik.ali 579
	}
22495 amit.gupta 580
 
581
	@RequestMapping(value = "/retailer/showFofoInterest", method=RequestMethod.GET)
22931 ashik.ali 582
	public ResponseEntity<?> showFofoInterest(HttpServletRequest request) throws ProfitMandiBusinessException{
22495 amit.gupta 583
		UserInfo userInfo = (UserInfo)request.getAttribute("userInfo");
584
		User user = userRepository.selectById(userInfo.getUserId());
585
		RetailerFofoInterest retailerInterest = new RetailerFofoInterest();
586
		retailerInterest.setCity(user.getCity());
587
		retailerInterest.setMobile(user.getMobileNumber());
588
		retailerInterest.setPinCode(user.getPinCode());
589
		retailerInterest.setUserId(userInfo.getUserId());
22876 amit.gupta 590
		if(user.getPinCode()!=null){
591
			retailerInterest.setPinCode(user.getPinCode());
592
		}
22495 amit.gupta 593
		retailerInterest.setInterestShownOn(new Date());
594
		LOGGER.info("requested url : "+request.getRequestURL().toString());
595
		return responseSender.ok(mongoClient.saveRetailerInterestOnFofo(retailerInterest));
596
	}
597
 
598
	@RequestMapping(value = "/retailer/hasRetailerShownInterest", method=RequestMethod.GET)
599
	public ResponseEntity<?> getAllBrads(HttpServletRequest request) throws Throwable{
600
		UserInfo userInfo = (UserInfo)request.getAttribute("userInfo");
601
		LOGGER.info("requested url : "+request.getRequestURL().toString());
602
		return responseSender.ok(mongoClient.hasRetailerShownInterest(userInfo.getUserId()));
603
	}
21426 ashik.ali 604
 
21292 ashik.ali 605
}