| Line 5... |
Line 5... |
| 5 |
import java.util.HashMap;
|
5 |
import java.util.HashMap;
|
| 6 |
import java.util.HashSet;
|
6 |
import java.util.HashSet;
|
| 7 |
import java.util.List;
|
7 |
import java.util.List;
|
| 8 |
import java.util.Map;
|
8 |
import java.util.Map;
|
| 9 |
import java.util.Set;
|
9 |
import java.util.Set;
|
| 10 |
import java.util.stream.Collectors;
|
- |
|
| 11 |
|
10 |
|
| 12 |
import org.apache.logging.log4j.LogManager;
|
11 |
import org.apache.logging.log4j.LogManager;
|
| 13 |
import org.apache.logging.log4j.Logger;
|
12 |
import org.apache.logging.log4j.Logger;
|
| 14 |
import org.springframework.beans.factory.annotation.Autowired;
|
13 |
import org.springframework.beans.factory.annotation.Autowired;
|
| 15 |
import org.springframework.beans.factory.annotation.Qualifier;
|
14 |
import org.springframework.beans.factory.annotation.Qualifier;
|
| Line 47... |
Line 46... |
| 47 |
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
|
46 |
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
|
| 48 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
|
47 |
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
|
| 49 |
import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
|
48 |
import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
|
| 50 |
import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
|
49 |
import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
|
| 51 |
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
|
50 |
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
|
| - |
|
51 |
import com.spice.profitmandi.service.authentication.RoleManager;
|
| 52 |
import com.spice.profitmandi.service.order.OrderService;
|
52 |
import com.spice.profitmandi.service.order.OrderService;
|
| 53 |
import com.spice.profitmandi.service.wallet.WalletService;
|
53 |
import com.spice.profitmandi.service.wallet.WalletService;
|
| 54 |
|
54 |
|
| 55 |
import in.shop2020.model.v1.catalog.ItemType;
|
55 |
import in.shop2020.model.v1.catalog.ItemType;
|
| 56 |
import in.shop2020.model.v1.order.WalletReferenceType;
|
56 |
import in.shop2020.model.v1.order.WalletReferenceType;
|
| Line 69... |
Line 69... |
| 69 |
|
69 |
|
| 70 |
@Autowired
|
70 |
@Autowired
|
| 71 |
private SchemeRepository schemeRepository;
|
71 |
private SchemeRepository schemeRepository;
|
| 72 |
|
72 |
|
| 73 |
@Autowired
|
73 |
@Autowired
|
| - |
|
74 |
private RoleManager roleManager;
|
| - |
|
75 |
|
| - |
|
76 |
@Autowired
|
| 74 |
private RetailerRepository retailerRepository;
|
77 |
private RetailerRepository retailerRepository;
|
| 75 |
|
78 |
|
| 76 |
@Autowired
|
79 |
@Autowired
|
| 77 |
private RetailerSchemeRepository retailerSchemeRepository;
|
80 |
private RetailerSchemeRepository retailerSchemeRepository;
|
| 78 |
|
81 |
|
| Line 838... |
Line 841... |
| 838 |
public Map<String, Object> getSchemes(Set<Integer> roleIds, int offset, int limit)
|
841 |
public Map<String, Object> getSchemes(Set<Integer> roleIds, int offset, int limit)
|
| 839 |
throws ProfitMandiBusinessException {
|
842 |
throws ProfitMandiBusinessException {
|
| 840 |
Map<String, Object> map = new HashMap<>();
|
843 |
Map<String, Object> map = new HashMap<>();
|
| 841 |
List<Scheme> schemes = null;
|
844 |
List<Scheme> schemes = null;
|
| 842 |
long size = 0;
|
845 |
long size = 0;
|
| 843 |
Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
|
- |
|
| 844 |
if (roleIds.contains(role.getId())) {
|
846 |
if (roleManager.isAdmin(roleIds)) {
|
| 845 |
schemes = schemeRepository.selectAll(offset, limit);
|
847 |
schemes = schemeRepository.selectAll(offset, limit);
|
| 846 |
size = schemeRepository.selectAllCount();
|
848 |
size = schemeRepository.selectAllCount();
|
| 847 |
} else {
|
849 |
} else {
|
| 848 |
schemes = schemeRepository.selectActiveAll(offset, limit);
|
850 |
schemes = schemeRepository.selectActiveAll(offset, limit);
|
| 849 |
size = schemeRepository.selectAllActiveCount();
|
851 |
size = schemeRepository.selectAllActiveCount();
|
| Line 862... |
Line 864... |
| 862 |
@Override
|
864 |
@Override
|
| 863 |
public List<Scheme> getPaginatedSchemes(Set<Integer> roleIds, int offset, int limit)
|
865 |
public List<Scheme> getPaginatedSchemes(Set<Integer> roleIds, int offset, int limit)
|
| 864 |
throws ProfitMandiBusinessException {
|
866 |
throws ProfitMandiBusinessException {
|
| 865 |
LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
|
867 |
LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
|
| 866 |
List<Scheme> schemes = null;
|
868 |
List<Scheme> schemes = null;
|
| 867 |
Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
|
- |
|
| 868 |
if (roleIds.contains(role.getId())) {
|
869 |
if (roleManager.isAdmin(roleIds)) {
|
| 869 |
schemes = schemeRepository.selectAll(offset, limit);
|
870 |
schemes = schemeRepository.selectAll(offset, limit);
|
| 870 |
} else {
|
871 |
} else {
|
| 871 |
schemes = schemeRepository.selectActiveAll(offset, limit);
|
872 |
schemes = schemeRepository.selectActiveAll(offset, limit);
|
| 872 |
}
|
873 |
}
|
| 873 |
return schemes;
|
874 |
return schemes;
|