Subversion Repositories SmartDukaan

Rev

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