Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.enumuration.FofoType;

import com.spice.profitmandi.common.model.CustomAddress;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.dao.entity.transaction.*;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.entity.user.Address;

import com.spice.profitmandi.dao.entity.user.User;

import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;

import com.spice.profitmandi.dao.repository.inventory.StateRepository;

import com.spice.profitmandi.dao.repository.user.AddressRepository;

import com.spice.profitmandi.dao.repository.user.UserRepository;

import com.spice.profitmandi.dao.repository.transaction.*;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component

public class SellerServiceImpl implements SellerService {

	@Autowired

	OrganisationRepository organisationRepository;

	@Autowired

	SellerRepository sellerRepository;

	@Autowired

	SellerWarehouseRepository sellerWarehouseRepository;

	@Autowired

	StateRepository stateRepository;

	@Autowired

	WarehouseAddressMappingRepository warehouseAddressMappingRepository;

	@Autowired

	WarehouseAddressMasterRepository warehouseAddressMasterRepository;

	@Autowired

	FofoStoreRepository fofoStoreRepository;

	@Autowired

	UserRepository userUserRepository;

	@Autowired

	AddressRepository addressRepository;

	public CustomRetailer convertToSeller(String sellerPrefix) throws ProfitMandiBusinessException {

		SellerWarehouse sellerWarehouse = sellerWarehouseRepository.selectByPrefix(sellerPrefix);

		Seller sellerInfo = sellerRepository.selectById(sellerWarehouse.getSellerId());

		Organisation organisation = organisationRepository.selectById(sellerInfo.getOrganisationId());

		CustomRetailer customRetailer = new CustomRetailer();

		customRetailer.setBusinessName(organisation.getName());

		customRetailer.setGstNumber(sellerInfo.getGstin());

		WarehouseAddressMapping warehouseAddressMapping = warehouseAddressMappingRepository.selectByWarehouseId(sellerWarehouse.getWarehouseId());

		WarehouseAddressMaster warehouseAddressMaster = warehouseAddressMasterRepository.selectById(warehouseAddressMapping.getAddressId());

		CustomAddress customAddress = new CustomAddress();

		try {

			customAddress.setState(stateRepository.selectById(warehouseAddressMaster.getStateId()).getName());

		} catch (Exception e) {

			throw new ProfitMandiBusinessException("Warehouse Address State", warehouseAddressMaster.getStateId(),

					"Problem while fetching state");

		}

		customAddress.setCity(warehouseAddressMaster.getAddress());

		customAddress.setPinCode(warehouseAddressMaster.getPin());

		customAddress.setPhoneNumber(warehouseAddressMaster.getContacNumber());

		customAddress.setName(organisation.getName());

		customRetailer.setAddress(customAddress);

		return customRetailer;

	}

	/**

	 * An INTERNAL store is the buying identity of a warehouse, so its user.address has to BE the

	 * warehouse address: order creation reads user.address for every buyer alike and no longer

	 * special-cases internal stores. Lines are split exactly as getCustomAddress() does, because

	 * that is the shape the order columns were previously filled with directly - any other split

	 * would silently change the address printed on the next invoice.

	 *

	 * No fallback to whatever the store already had: a warehouse with no address mapping is a data

	 * fault and must surface here, rather than leave an internal store quietly billing to a stale

	 * address, which is the failure this sync exists to end.

	 */

	@Override

	public int syncInternalStoreAddresses(int warehouseId) throws ProfitMandiBusinessException {

		WarehouseAddressMapping mapping = warehouseAddressMappingRepository.selectByWarehouseId(warehouseId);

		if (mapping == null) {

			throw new ProfitMandiBusinessException("Warehouse Address Mapping", warehouseId,

					"No address is mapped to this warehouse");

		}

		WarehouseAddressMaster master = warehouseAddressMasterRepository.selectById(mapping.getAddressId());

		CustomAddress warehouseAddress = master.getCustomAddress();

		String stateName;

		try {

			stateName = stateRepository.selectById(master.getStateId()).getName();

		} catch (Exception e) {

			throw new ProfitMandiBusinessException("Warehouse Address State", master.getStateId(),

					"Problem while fetching state");

		}

		int synced = 0;

		for (FofoStore store : fofoStoreRepository.selectActivePartnerByWarehouse(warehouseId)) {

			if (!FofoType.INTERNAL.equals(store.getFofoType())) {

				continue;

			}

			User user = userUserRepository.selectById(store.getId());

			Address address = addressRepository.selectById(user.getAddressId());

			address.setLine1(warehouseAddress.getLine1());

			address.setLine2(warehouseAddress.getLine2());

			address.setCity(warehouseAddress.getCity());

			address.setState(stateName);

			address.setPinCode(warehouseAddress.getPinCode());

			address.setUpdateTimestamp(LocalDateTime.now());

			addressRepository.persist(address);

			synced++;

		}

		return synced;

	}

}