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 {
                WarehouseAddressMaster master = this.mappedAddress(warehouseId);
                String stateName = this.stateName(master);

                int synced = 0;
                for (FofoStore store : fofoStoreRepository.selectActivePartnerByWarehouse(warehouseId)) {
                        if (!FofoType.INTERNAL.equals(store.getFofoType())) {
                                continue;
                        }
                        this.applyAddress(store, master, stateName);
                        synced++;
                }
                return synced;
        }

        @Override
        public void syncInternalStoreAddress(FofoStore store) throws ProfitMandiBusinessException {
                if (!FofoType.INTERNAL.equals(store.getFofoType())) {
                        return;
                }
                WarehouseAddressMaster master = this.mappedAddress(store.getWarehouseId());
                this.applyAddress(store, master, this.stateName(master));
        }

        private WarehouseAddressMaster mappedAddress(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");
                }
                return warehouseAddressMasterRepository.selectById(mapping.getAddressId());
        }

        private String stateName(WarehouseAddressMaster master) throws ProfitMandiBusinessException {
                try {
                        return stateRepository.selectById(master.getStateId()).getName();
                } catch (Exception e) {
                        throw new ProfitMandiBusinessException("Warehouse Address State", master.getStateId(),
                                        "Problem while fetching state");
                }
        }

        private void applyAddress(FofoStore store, WarehouseAddressMaster master, String stateName)
                        throws ProfitMandiBusinessException {
                CustomAddress warehouseAddress = master.getCustomAddress();
                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);
        }
}