| Line 5... |
Line 5... |
| 5 |
import java.util.Arrays;
|
5 |
import java.util.Arrays;
|
| 6 |
import java.util.HashMap;
|
6 |
import java.util.HashMap;
|
| 7 |
import java.util.Iterator;
|
7 |
import java.util.Iterator;
|
| 8 |
import java.util.List;
|
8 |
import java.util.List;
|
| 9 |
import java.util.Map;
|
9 |
import java.util.Map;
|
| - |
|
10 |
import java.util.Set;
|
| 10 |
|
11 |
|
| 11 |
import org.apache.http.conn.HttpHostConnectException;
|
12 |
import org.apache.http.conn.HttpHostConnectException;
|
| 12 |
import org.apache.logging.log4j.LogManager;
|
13 |
import org.apache.logging.log4j.LogManager;
|
| 13 |
import org.apache.logging.log4j.Logger;
|
14 |
import org.apache.logging.log4j.Logger;
|
| 14 |
import org.springframework.beans.factory.annotation.Autowired;
|
15 |
import org.springframework.beans.factory.annotation.Autowired;
|
| Line 31... |
Line 32... |
| 31 |
import com.spice.profitmandi.dao.entity.dtr.User;
|
32 |
import com.spice.profitmandi.dao.entity.dtr.User;
|
| 32 |
import com.spice.profitmandi.dao.entity.user.Promoter;
|
33 |
import com.spice.profitmandi.dao.entity.user.Promoter;
|
| 33 |
import com.spice.profitmandi.dao.enumuration.dtr.Gender;
|
34 |
import com.spice.profitmandi.dao.enumuration.dtr.Gender;
|
| 34 |
import com.spice.profitmandi.dao.enumuration.dtr.SocialType;
|
35 |
import com.spice.profitmandi.dao.enumuration.dtr.SocialType;
|
| 35 |
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
|
36 |
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
|
| 36 |
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
|
37 |
import com.spice.profitmandi.dao.repository.cs.CsService;
|
| 37 |
import com.spice.profitmandi.dao.repository.dtr.SocialUserRepository;
|
38 |
import com.spice.profitmandi.dao.repository.dtr.SocialUserRepository;
|
| 38 |
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
|
39 |
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
|
| 39 |
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
|
40 |
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
|
| 40 |
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
|
41 |
import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;
|
| 41 |
import com.spice.profitmandi.dao.repository.user.PromoterRepository;
|
42 |
import com.spice.profitmandi.dao.repository.user.PromoterRepository;
|
| Line 75... |
Line 76... |
| 75 |
@Autowired
|
76 |
@Autowired
|
| 76 |
private PromoterRepository promoterRepository;
|
77 |
private PromoterRepository promoterRepository;
|
| 77 |
|
78 |
|
| 78 |
@Autowired
|
79 |
@Autowired
|
| 79 |
private UserAccountRepository userAccountRepository;
|
80 |
private UserAccountRepository userAccountRepository;
|
| - |
|
81 |
|
| - |
|
82 |
@Autowired
|
| - |
|
83 |
private CsService csService;
|
| 80 |
|
84 |
|
| 81 |
@Autowired
|
85 |
@Autowired
|
| 82 |
private RestClient restClient;
|
86 |
private RestClient restClient;
|
| 83 |
@Autowired
|
87 |
@Autowired
|
| 84 |
private RetailerService retailerService;
|
88 |
private RetailerService retailerService;
|
| Line 165... |
Line 169... |
| 165 |
}
|
169 |
}
|
| 166 |
int retailerId;
|
170 |
int retailerId;
|
| 167 |
try {
|
171 |
try {
|
| 168 |
retailerId = userAccountRepository.selectRetailerIdByUserId(registeredUser.getId());
|
172 |
retailerId = userAccountRepository.selectRetailerIdByUserId(registeredUser.getId());
|
| 169 |
} catch (Exception e) {
|
173 |
} catch (Exception e) {
|
| - |
|
174 |
Set<Integer> authUserPartnerSet = csService.getAuthUserPartnerIdMapping().get(authUser.getEmailId());
|
| - |
|
175 |
if(authUserPartnerSet.size() > 0) {
|
| - |
|
176 |
retailerId = authUserPartnerSet.stream().findFirst().get();
|
| - |
|
177 |
} else {
|
| 170 |
com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectByEmailId(Utils.SYSTEM_PARTNER);
|
178 |
com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectByEmailId(Utils.SYSTEM_PARTNER);
|
| 171 |
retailerId = user.getId();
|
179 |
retailerId = user.getId();
|
| - |
|
180 |
}
|
| 172 |
}
|
181 |
}
|
| 173 |
responseMap.put(ProfitMandiConstants.TOKEN,
|
182 |
responseMap.put(ProfitMandiConstants.TOKEN,
|
| 174 |
JWTUtil.create(socialUser.getEmailId(), registeredUser.getId(), retailerId, roleTypes));
|
183 |
JWTUtil.create(socialUser.getEmailId(), registeredUser.getId(), retailerId, roleTypes));
|
| 175 |
LOGGER.info(
|
184 |
LOGGER.info(
|
| 176 |
"Param value for socialUser.getEmailId(), registeredUser.getId(), retailerId, roleTypes are {}, {}, {} and {}",
|
185 |
"Param value for socialUser.getEmailId(), registeredUser.getId(), retailerId, roleTypes are {}, {}, {} and {}",
|