Subversion Repositories SmartDukaan

Rev

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