WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/RetailerController.java

 import java.util.Set;
 import javax.servlet.http.HttpServletRequest;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.transport.TTransportException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import com.spice.profitmandi.dao.entity.dtr.ShopAddress;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.UserAccounts;
 import com.spice.profitmandi.dao.entity.dtr.UserRole;
 import com.spice.profitmandi.dao.entity.user.Address;
+import com.spice.profitmandi.dao.entity.user.Cart;
+import com.spice.profitmandi.dao.entity.user.Counter;
+import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
+import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressId;
+import com.spice.profitmandi.dao.entity.user.PrivateDealUserAddressMapping;
 import com.spice.profitmandi.dao.enumuration.dtr.AccountType;
 import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
 import com.spice.profitmandi.dao.repository.dtr.BrandRepository;
 import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerAddressRepository;
 import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
-import com.spice.profitmandi.thrift.clients.UserClient;
+import com.spice.profitmandi.dao.repository.user.CartRepository;
+import com.spice.profitmandi.dao.repository.user.CounterRepository;
+import com.spice.profitmandi.dao.repository.user.PrivateDealUserAddressMappingRepository;
+import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
 import com.spice.profitmandi.web.req.Category;
 import com.spice.profitmandi.web.req.CreateRetailerAddressRequest;
 import com.spice.profitmandi.web.req.CreateRetailerRequest;
 import com.spice.profitmandi.web.req.RetailerAddBrandRequest;
-import in.shop2020.model.v1.user.Sex;
+import in.shop2020.model.v1.user.CartStatus;
-import in.shop2020.model.v1.user.UserContextException;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 @Controller
 public class RetailerController {
 	private static final Logger LOGGER=LoggerFactory.getLogger(RetailerController.class);
 	@Autowired
+	@Qualifier("userRepository")
 	UserRepository userRepository;
 	@Autowired
+	@Qualifier("userUserRepository")
+	com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
+	@Autowired
 	UserRoleRepository userRoleRepository;
 	@Autowired
 	ResponseSender<?> responseSender;
 	ShopAddressRepository shopAddressRepository;
 	@Autowired
 	RetailerBrandRepository retailerBrandRepository;
+	@Autowired
+	CounterRepository counterRepository;
+	@Autowired
+	PrivateDealUserRepository privateDealUserRepository;
+	@Autowired
+	PrivateDealUserAddressMappingRepository privateDealUserAddressMappingRepository;
+	@Autowired
+	CartRepository cartRepository;
 	@ApiImplicitParams({
 		@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token",
 				required = true, dataType = "string", paramType = "header")
 	})
 	@ApiOperation(value = "Create Retailer")
 	@RequestMapping(value = ProfitMandiConstants.URL_RETAILER, method=RequestMethod.POST)
-	public ResponseEntity<?> createRetailer(HttpServletRequest request, @RequestBody CreateRetailerRequest createRetailerRequest){
+	public ResponseEntity<?> createRetailer(HttpServletRequest request, @RequestBody CreateRetailerRequest createRetailerRequest) throws ProfitMandiBusinessException{
-		LOGGER.info("requested url : "+request.getRequestURL().toString());
+		LOGGER.info("request received with body [{}] at url {{}}: ", createRetailerRequest, request.getRequestURL().toString());
 		try{
 			UserInfo userInfo = (UserInfo)request.getAttribute("userInfo");
+			LOGGER.info("requestAttribute [userInfo={}]", userInfo);
 			User user = userRepository.selectById(userInfo.getUserId());
 			this.createRetailer(user, createRetailerRequest);
 			return responseSender.ok(ResponseCodeHolder.getMessage("RTLR_OK_1000"));
 		}catch (ProfitMandiBusinessException profitMandiBusinessException) {
 			LOGGER.error("ProfitMandi error: ", profitMandiBusinessException);
+			throw profitMandiBusinessException;
-			return responseSender.badRequest(profitMandiBusinessException);
+			//return responseSender.badRequest(profitMandiBusinessException);
+		}
+	}
 	private void createRetailer(User user, CreateRetailerRequest createRetailerRequest)
 			throws ProfitMandiBusinessException{
 		documentRepository.markDocumentAsPersisted(retailerDocument.getId());
 		if(retailerRepository.isExistByNumberAndType(retailer.getNumber(), retailer.getType())){
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.NUMBER + ", " + ProfitMandiConstants.TYPE, retailer.getNumber() + ", " + retailer.getType(), "RTLR_1001");
+		}
 		documentRepository.markDocumentAsPersisted(shopDocument.getId());
+		com.spice.profitmandi.dao.entity.user.User saholicUser = null;
+		boolean foundRetailer = false;
+		saholicUser = userUserRepository.selectByEmailId(user.getEmailId());
+		if(saholicUser == null){
+			Cart cart = new Cart();
+			cart.setCartStatus(CartStatus.ACTIVE);
+			cartRepository.persist(cart);
+			saholicUser = new com.spice.profitmandi.dao.entity.user.User();
+			saholicUser.setEmailId(user.getEmailId());
+			saholicUser.setName(createRetailerRequest.getName());
+			saholicUser.setActiveCartId(cart.getId());
+			userUserRepository.persist(saholicUser);
+		}else{
+			foundRetailer = true;
+		}
-		in.shop2020.model.v1.user.User saholicUser = this.createSaholicUser(user.getEmailId());
+		//in.shop2020.model.v1.user.User saholicUser = Utils.createSaholicUser(user.getEmailId());
-		retailer.setId((int)saholicUser.getUserId());
+		retailer.setId(saholicUser.getId());
 		retailerRepository.persist(retailer);
 		Shop shop = new Shop();
 		shop.setName(createRetailerRequest.getShop().getName());
 		shop.setDocumentId(shopDocument.getId());
 		shop.setRetailerId(retailer.getId());
 		shopRepository.persist(shop);
 		this.addBrandWithRetailer(retailer.getId(), createRetailerRequest.getCategories());
 		final Address addressRetailer = this.createAddress(createRetailerRequest.getAddress());
 		addressRetailer.setRetaierId(retailer.getId());
 		addressRepository.persist(addressRetailer);
 		final RetailerRegisteredAddress retailerRegisteredAddress = new RetailerRegisteredAddress();
 		retailerRegisteredAddress.setRetailerId(retailer.getId());
 		retailerRegisteredAddress.setAddressId(addressRetailer.getId());
 		retailerRegisteredAddressRepository.persist(retailerRegisteredAddress);
 		if(!createRetailerRequest.isShopAddressSameAsRetailerAddress() && createRetailerRequest.getAddress() == null){
 			shopAddress.setShopId(shop.getId());
 			shopAddress.setAddressId(addressShop.getId());
 			shopAddressRepository.persist(shopAddress);
+		}
 		UserAccounts ua = new UserAccounts();
-		ua.setAccount_key(String.valueOf(saholicUser.getUserId()));
+		ua.setAccount_key(String.valueOf(saholicUser.getId()));
 		ua.setUser_id(user.getId());
 		ua.setAccount_type(AccountType.saholic);
 		userAccountRepository.persist(ua);
 		UserAccounts ua2 = new UserAccounts();
 		UserRole ur = new UserRole();
 		ur.setRoleType(RoleType.RETAILER);
 		ur.setUserId(user.getId());
 		userRoleRepository.persist(ur);
+		if(foundRetailer){
+			LOGGER.info("\n\n\n****retailer found\n\n\n");
+			PrivateDealUser privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
+			if(privateDealUser.getCounterId() == null){
+				Integer counterId = this.createCounter(user.getEmailId(), createRetailerRequest.getGstNumber(), user.getMobileNumber(), retailer.getName(), addressRetailer.getId());
+				privateDealUser.setCounterId(counterId);
+				privateDealUserRepository.persist(privateDealUser);
+			}
+		}else{
+			LOGGER.info("retailer not found");
+			//gst number intergration with counter
+			Integer counterId = this.createCounter(user.getEmailId(), createRetailerRequest.getGstNumber(), user.getMobileNumber(), retailer.getName(), addressRetailer.getId());
+				PrivateDealUser privateDealUser = privateDealUserRepository.selectById(saholicUser.getId());
+			if(privateDealUser != null){
+				//LOGGER.info("PrivateDealUser found with id [{}]", saholicUser.getId());
+				privateDealUser.setCounterId(counterId);
+				privateDealUserRepository.update(privateDealUser);
+			}else{
+				LOGGER.info("PrivateDealUser not found with id [{}]", saholicUser.getId());
+				privateDealUser = new PrivateDealUser();
+				privateDealUser.setActive(true);
+				privateDealUser.setBulkShipmentAmountLimit(50000);
+				privateDealUser.setId(saholicUser.getId());
+				privateDealUser.setCounterId(counterId);
+				privateDealUserRepository.persist(privateDealUser);
+			}
+			PrivateDealUserAddressMapping privateDealUserAddressMapping = new PrivateDealUserAddressMapping();
+			PrivateDealUserAddressId privateDealUserAddressId = new PrivateDealUserAddressId();
+			privateDealUserAddressId.setUserId(retailer.getId());
+			privateDealUserAddressId.setAddressId(addressRetailer.getId());
+			privateDealUserAddressMapping.setId(privateDealUserAddressId);
+			privateDealUserAddressMappingRepository.persist(privateDealUserAddressMapping);
+			saholicUser.setAddressId(addressRetailer.getId());
+			userUserRepository.persist(saholicUser);
+		}
+	}
-	private in.shop2020.model.v1.user.User createSaholicUser(String emailId) throws ProfitMandiBusinessException{
+	private Integer createCounter(String emailId, String gstNumber, String mobileNumber, String name, int addressId){
-		in.shop2020.model.v1.user.User user = new in.shop2020.model.v1.user.User();
+		if(gstNumber != null && !gstNumber.isEmpty()){
-		user.setEmail(emailId);
-		user.setPassword("");
+			Counter counter = new Counter();
-		user.setCommunicationEmail(emailId);
+			counter.setEmailId(emailId);
-		user.setSex(Sex.WONT_SAY);
+			counter.setGstin(gstNumber);
-		try {
-			UserClient userContextServiceClient = new UserClient();
-			in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();
-			user = userClient.createUser(user);
+			counter.setMobileNumber(mobileNumber);
-			return user;
+			counter.setName(name);
-		}catch (UserContextException ux){
+			counter.setAddressId(addressId);
-			LOGGER.error("Unable to register user: " + ux.getMessage());
-			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, emailId, "");
-		} catch (TTransportException e) {
+			counterRepository.persist(counter);
-			LOGGER.error("Unable to register user." + e);
+			return counter.getId();
-			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, emailId, "");
-		}catch (TException e) {
+		}else{
-			LOGGER.error("Unable to register user." + e);
+			return null;
-			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, emailId, "");
 		}
+	}
 	private void addBrandWithRetailer(int retailerId, Set<Category> categories)
 		throws ProfitMandiBusinessException{
 		for(Category category : categories){
 			for(com.spice.profitmandi.web.req.Brand brandModel : category.getBrands()){
 				Brand brand = brandRepository.selectByIdAndName(brandModel.getId(), brandModel.getName());

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/RetailerController.java – Rev 22273 → 22355