| 25899 |
tejbeer |
1 |
package com.spice.profitmandi.web.controller;
|
|
|
2 |
|
|
|
3 |
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
|
| 25952 |
tejbeer |
4 |
import com.spice.profitmandi.common.model.CustomRetailer;
|
| 27117 |
tejbeer |
5 |
import com.spice.profitmandi.common.model.ProfitMandiConstants;
|
| 25899 |
tejbeer |
6 |
import com.spice.profitmandi.common.web.util.ResponseSender;
|
|
|
7 |
import com.spice.profitmandi.dao.entity.auth.AuthUser;
|
| 30077 |
tejbeer |
8 |
import com.spice.profitmandi.dao.entity.auth.PartnerCollectionPlan;
|
|
|
9 |
import com.spice.profitmandi.dao.entity.auth.PartnerSecondaryPlan;
|
| 25899 |
tejbeer |
10 |
import com.spice.profitmandi.dao.entity.dtr.User;
|
| 25952 |
tejbeer |
11 |
import com.spice.profitmandi.dao.entity.dtr.UserAccount;
|
| 28935 |
tejbeer |
12 |
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
|
| 30087 |
tejbeer |
13 |
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
|
| 28935 |
tejbeer |
14 |
import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
|
| 25952 |
tejbeer |
15 |
import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
|
|
|
16 |
import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
|
| 25899 |
tejbeer |
17 |
import com.spice.profitmandi.dao.entity.user.Lead;
|
|
|
18 |
import com.spice.profitmandi.dao.entity.user.LeadActivity;
|
| 25952 |
tejbeer |
19 |
import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeActivityStatus;
|
|
|
20 |
import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeVisitStatus;
|
| 25899 |
tejbeer |
21 |
import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
|
| 28935 |
tejbeer |
22 |
import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;
|
| 30280 |
amit.gupta |
23 |
import com.spice.profitmandi.dao.model.*;
|
| 25899 |
tejbeer |
24 |
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
|
| 30104 |
tejbeer |
25 |
import com.spice.profitmandi.dao.repository.auth.AuthUserPartnerMappingRepository;
|
| 30077 |
tejbeer |
26 |
import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
|
|
|
27 |
import com.spice.profitmandi.dao.repository.auth.PartnerSecondaryPlanRepository;
|
| 25952 |
tejbeer |
28 |
import com.spice.profitmandi.dao.repository.cs.CsService;
|
| 30077 |
tejbeer |
29 |
import com.spice.profitmandi.dao.repository.cs.PositionRepository;
|
| 30280 |
amit.gupta |
30 |
import com.spice.profitmandi.dao.repository.dtr.*;
|
| 30087 |
tejbeer |
31 |
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
|
| 30077 |
tejbeer |
32 |
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
|
|
|
33 |
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
|
| 25952 |
tejbeer |
34 |
import com.spice.profitmandi.service.user.RetailerService;
|
| 28935 |
tejbeer |
35 |
import com.spice.profitmandi.service.user.StoreTimelineTatService;
|
| 25952 |
tejbeer |
36 |
import com.spice.profitmandi.web.req.CreateFranchiseeRequest;
|
|
|
37 |
import com.spice.profitmandi.web.res.Partner;
|
| 25899 |
tejbeer |
38 |
import io.swagger.annotations.ApiImplicitParam;
|
|
|
39 |
import io.swagger.annotations.ApiImplicitParams;
|
| 30280 |
amit.gupta |
40 |
import org.apache.logging.log4j.LogManager;
|
|
|
41 |
import org.apache.logging.log4j.Logger;
|
|
|
42 |
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
43 |
import org.springframework.format.annotation.DateTimeFormat;
|
|
|
44 |
import org.springframework.http.MediaType;
|
|
|
45 |
import org.springframework.http.ResponseEntity;
|
|
|
46 |
import org.springframework.stereotype.Controller;
|
|
|
47 |
import org.springframework.transaction.annotation.Transactional;
|
|
|
48 |
import org.springframework.ui.Model;
|
|
|
49 |
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
50 |
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
51 |
import org.springframework.web.bind.annotation.RequestMethod;
|
|
|
52 |
import org.springframework.web.bind.annotation.RequestParam;
|
| 25899 |
tejbeer |
53 |
|
| 30280 |
amit.gupta |
54 |
import javax.servlet.http.HttpServletRequest;
|
|
|
55 |
import java.time.LocalDate;
|
|
|
56 |
import java.time.LocalDateTime;
|
|
|
57 |
import java.util.*;
|
|
|
58 |
import java.util.Map.Entry;
|
|
|
59 |
import java.util.stream.Collectors;
|
|
|
60 |
|
| 25899 |
tejbeer |
61 |
@Controller
|
|
|
62 |
@Transactional(rollbackFor = Throwable.class)
|
|
|
63 |
public class LeadController {
|
|
|
64 |
private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
|
|
|
65 |
@Autowired
|
|
|
66 |
private ResponseSender<?> responseSender;
|
|
|
67 |
|
|
|
68 |
@Autowired
|
|
|
69 |
private AuthRepository authRepository;
|
|
|
70 |
|
|
|
71 |
@Autowired
|
|
|
72 |
private LeadRepository leadRepository;
|
|
|
73 |
|
|
|
74 |
@Autowired
|
| 25952 |
tejbeer |
75 |
private CsService csService;
|
|
|
76 |
|
|
|
77 |
@Autowired
|
|
|
78 |
private UserRepository userRepository;
|
|
|
79 |
|
|
|
80 |
@Autowired
|
|
|
81 |
private UserAccountRepository userAccountRepository;
|
|
|
82 |
|
|
|
83 |
@Autowired
|
|
|
84 |
private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
|
|
|
85 |
|
|
|
86 |
@Autowired
|
|
|
87 |
private RetailerService retailerService;
|
|
|
88 |
|
|
|
89 |
@Autowired
|
| 25899 |
tejbeer |
90 |
private LeadActivityRepository leadActivityRepository;
|
|
|
91 |
|
| 25952 |
tejbeer |
92 |
@Autowired
|
|
|
93 |
private FranchiseeVisitRepository franchiseeVisitRepository;
|
|
|
94 |
|
|
|
95 |
@Autowired
|
|
|
96 |
private FranchiseeActivityRepository franchiseeActivityRepository;
|
|
|
97 |
|
| 28935 |
tejbeer |
98 |
@Autowired
|
|
|
99 |
private PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
|
|
|
100 |
|
|
|
101 |
@Autowired
|
|
|
102 |
private FofoStoreRepository fofoStoreRepository;
|
|
|
103 |
|
|
|
104 |
@Autowired
|
|
|
105 |
private StoreTimelineTatService storeTimelineTatService;
|
|
|
106 |
|
| 25899 |
tejbeer |
107 |
@RequestMapping(value = "/lead", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
108 |
@ApiImplicitParams({
|
|
|
109 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
110 |
public ResponseEntity<?> LeadUser(HttpServletRequest request,
|
|
|
111 |
@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
|
|
|
112 |
Lead lead = new Lead();
|
|
|
113 |
lead.setFirstName(createRefferalRequest.getFirstName());
|
|
|
114 |
lead.setLastName(createRefferalRequest.getLastName());
|
|
|
115 |
lead.setLeadMobile(createRefferalRequest.getMobile());
|
|
|
116 |
lead.setState(createRefferalRequest.getState());
|
|
|
117 |
lead.setCity(createRefferalRequest.getCity());
|
|
|
118 |
lead.setAddress(createRefferalRequest.getAddress());
|
|
|
119 |
lead.setCreatedTimestamp(LocalDateTime.now());
|
|
|
120 |
lead.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
121 |
lead.setStatus(createRefferalRequest.getStatus());
|
| 25979 |
tejbeer |
122 |
lead.setSource(createRefferalRequest.getSource());
|
| 28201 |
tejbeer |
123 |
lead.setNotinterestedReason(createRefferalRequest.getReason());
|
| 26244 |
tejbeer |
124 |
if (createRefferalRequest.getColorCheck() == true) {
|
|
|
125 |
lead.setColor("Green");
|
|
|
126 |
} else {
|
|
|
127 |
lead.setColor("Yellow");
|
|
|
128 |
}
|
| 25900 |
amit.gupta |
129 |
AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
|
|
|
130 |
String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
|
|
|
131 |
lead.setCreatedBy(authUserName);
|
|
|
132 |
lead.setAuthId(authUser.getId());
|
| 25981 |
tejbeer |
133 |
lead.setAssignTo(authUser.getId());
|
| 25899 |
tejbeer |
134 |
|
|
|
135 |
leadRepository.persist(lead);
|
|
|
136 |
LeadActivity leadActivity = new LeadActivity();
|
|
|
137 |
leadActivity.setLeadId(lead.getId());
|
|
|
138 |
leadActivity.setRemark(createRefferalRequest.getRemark());
|
|
|
139 |
|
|
|
140 |
if (createRefferalRequest.getStatus().equals(LeadStatus.followUp)) {
|
|
|
141 |
leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
|
| 26958 |
tejbeer |
142 |
leadActivity.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
|
| 27025 |
tejbeer |
143 |
lead.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
|
| 25899 |
tejbeer |
144 |
} else {
|
|
|
145 |
leadActivity.setSchelduleTimestamp(null);
|
| 26958 |
tejbeer |
146 |
leadActivity.setClosureTimestamp(null);
|
| 27025 |
tejbeer |
147 |
lead.setClosureTimestamp(null);
|
| 25899 |
tejbeer |
148 |
}
|
|
|
149 |
leadActivity.setCreatedTimestamp(LocalDateTime.now());
|
|
|
150 |
leadActivityRepository.persist(leadActivity);
|
|
|
151 |
|
|
|
152 |
return responseSender.ok(true);
|
|
|
153 |
}
|
|
|
154 |
|
|
|
155 |
@RequestMapping(value = "/lead-description", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
156 |
@ApiImplicitParams({
|
|
|
157 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
158 |
public ResponseEntity<?> leadDescription(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
|
| 29331 |
tejbeer |
159 |
@RequestParam(name = "status") LeadStatus status) throws ProfitMandiBusinessException {
|
| 25899 |
tejbeer |
160 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
| 29434 |
amit.gupta |
161 |
List<Lead> leads = null;
|
| 30280 |
amit.gupta |
162 |
leads = leadRepository.selectByAssignAuthIdAndStatus(authUser.getId(), status);
|
| 29434 |
amit.gupta |
163 |
if (status.equals(LeadStatus.followUp)) {
|
| 30280 |
amit.gupta |
164 |
/*leads = leadRepository.selectLeadsScheduledBetweenDate(Arrays.asList(authUser.getId()),
|
|
|
165 |
LocalDate.now().atStartOfDay().minusDays(30), LocalDate.now().plusDays(30).atTime(LocalTime.MAX));*/
|
|
|
166 |
Collections.reverse(leads);
|
| 29434 |
amit.gupta |
167 |
}
|
| 25979 |
tejbeer |
168 |
|
| 25899 |
tejbeer |
169 |
return responseSender.ok(leads);
|
|
|
170 |
|
|
|
171 |
}
|
|
|
172 |
|
|
|
173 |
@RequestMapping(value = "/getlead", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
174 |
@ApiImplicitParams({
|
|
|
175 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
176 |
public ResponseEntity<?> getLead(HttpServletRequest request, @RequestParam(name = "id") int id)
|
|
|
177 |
throws ProfitMandiBusinessException {
|
|
|
178 |
|
|
|
179 |
List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(id);
|
| 29317 |
tejbeer |
180 |
Lead lead = leadRepository.selectById(id);
|
|
|
181 |
lead.setLeadActivities(leadActivities);
|
|
|
182 |
return responseSender.ok(lead);
|
| 25899 |
tejbeer |
183 |
|
|
|
184 |
}
|
|
|
185 |
|
| 25948 |
amit.gupta |
186 |
@RequestMapping(value = "/leadUpdate", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
| 25899 |
tejbeer |
187 |
@ApiImplicitParams({
|
|
|
188 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
189 |
public ResponseEntity<?> leadUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
|
| 26244 |
tejbeer |
190 |
@RequestParam(name = "status") LeadStatus status, @RequestParam(name = "colorCheck") Boolean colorCheck,
|
| 28201 |
tejbeer |
191 |
@RequestParam(name = "remark") String remark, @RequestParam(name = "reason") String reason,
|
| 26958 |
tejbeer |
192 |
@RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp,
|
|
|
193 |
@RequestParam(name = "closureTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime closureTimestamp)
|
| 25899 |
tejbeer |
194 |
throws ProfitMandiBusinessException {
|
|
|
195 |
|
|
|
196 |
Lead lead = leadRepository.selectById(id);
|
|
|
197 |
|
|
|
198 |
LeadActivity leadActivity = new LeadActivity();
|
| 26250 |
tejbeer |
199 |
lead.setStatus(status);
|
| 28201 |
tejbeer |
200 |
lead.setNotinterestedReason(reason);
|
| 26250 |
tejbeer |
201 |
leadActivity.setRemark(remark);
|
|
|
202 |
leadActivity.setLeadId(id);
|
|
|
203 |
leadActivity.setCreatedTimestamp(LocalDateTime.now());
|
|
|
204 |
leadActivity.setSchelduleTimestamp(null);
|
| 26958 |
tejbeer |
205 |
leadActivity.setClosureTimestamp(null);
|
| 26250 |
tejbeer |
206 |
lead.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
207 |
if (colorCheck == true) {
|
|
|
208 |
lead.setColor("Green");
|
|
|
209 |
} else {
|
|
|
210 |
lead.setColor("Yellow");
|
|
|
211 |
}
|
|
|
212 |
if (status == LeadStatus.followUp) {
|
| 25899 |
tejbeer |
213 |
|
|
|
214 |
leadActivity.setSchelduleTimestamp(schelduleTimestamp);
|
| 26958 |
tejbeer |
215 |
leadActivity.setClosureTimestamp(closureTimestamp);
|
| 27025 |
tejbeer |
216 |
lead.setClosureTimestamp(closureTimestamp);
|
| 26250 |
tejbeer |
217 |
|
| 25899 |
tejbeer |
218 |
} else {
|
| 26250 |
tejbeer |
219 |
|
| 25899 |
tejbeer |
220 |
leadActivity.setSchelduleTimestamp(null);
|
| 26958 |
tejbeer |
221 |
leadActivity.setClosureTimestamp(null);
|
| 27025 |
tejbeer |
222 |
lead.setClosureTimestamp(null);
|
| 26244 |
tejbeer |
223 |
|
| 25899 |
tejbeer |
224 |
}
|
| 26250 |
tejbeer |
225 |
leadActivityRepository.persist(leadActivity);
|
| 25899 |
tejbeer |
226 |
return responseSender.ok(true);
|
|
|
227 |
|
|
|
228 |
}
|
| 25952 |
tejbeer |
229 |
|
| 27117 |
tejbeer |
230 |
@RequestMapping(value = ProfitMandiConstants.URL_NEW_LEAD, method = RequestMethod.POST)
|
|
|
231 |
public ResponseEntity<?> newLead(HttpServletRequest request,
|
| 27597 |
amit.gupta |
232 |
@RequestBody CreateRefferalRequest createRefferalRequest) throws ProfitMandiBusinessException {
|
| 27117 |
tejbeer |
233 |
LOGGER.info("requested url : " + request.getRequestURL().toString());
|
|
|
234 |
Lead lead = new Lead();
|
|
|
235 |
lead.setAddress(createRefferalRequest.getCity());
|
| 27625 |
tejbeer |
236 |
Long.parseLong(createRefferalRequest.getMobile());
|
| 28201 |
tejbeer |
237 |
if (createRefferalRequest.getMobile().length() != 10) {
|
|
|
238 |
throw new ProfitMandiBusinessException("Mobile Number", createRefferalRequest.getMobile(),
|
|
|
239 |
"Number should be of 10 digits");
|
| 27597 |
amit.gupta |
240 |
}
|
| 27117 |
tejbeer |
241 |
lead.setLeadMobile(createRefferalRequest.getMobile());
|
|
|
242 |
lead.setCity(createRefferalRequest.getCity());
|
|
|
243 |
lead.setState(createRefferalRequest.getState());
|
|
|
244 |
lead.setLastName(createRefferalRequest.getLastName());
|
|
|
245 |
if (lead.getState().equals("Uttar Pradesh")) {
|
| 29276 |
amit.gupta |
246 |
lead.setAssignTo(53);
|
| 27117 |
tejbeer |
247 |
} else if (lead.getState().equals("Haryana")) {
|
| 29276 |
amit.gupta |
248 |
lead.setAssignTo(53);
|
| 27117 |
tejbeer |
249 |
} else if (lead.getState().equals("Delhi")) {
|
| 29276 |
amit.gupta |
250 |
lead.setAssignTo(53);
|
| 27117 |
tejbeer |
251 |
} else {
|
| 28201 |
tejbeer |
252 |
// Assign to sm
|
| 27992 |
amit.gupta |
253 |
lead.setAssignTo(53);
|
| 28201 |
tejbeer |
254 |
// Assign to neha
|
|
|
255 |
// lead.setAssignTo(1);
|
| 27117 |
tejbeer |
256 |
}
|
|
|
257 |
lead.setAuthId(lead.getAssignTo());
|
|
|
258 |
lead.setCreatedBy("daily-sync");
|
|
|
259 |
lead.setSource("SD-WEB");
|
|
|
260 |
lead.setFirstName(createRefferalRequest.getFirstName());
|
|
|
261 |
lead.setStatus(LeadStatus.followUp);
|
|
|
262 |
lead.setColor("yellow");
|
|
|
263 |
lead.setCreatedTimestamp(LocalDateTime.now());
|
|
|
264 |
lead.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
265 |
leadRepository.persist(lead);
|
|
|
266 |
|
|
|
267 |
return responseSender.ok(true);
|
|
|
268 |
|
|
|
269 |
}
|
|
|
270 |
|
| 25952 |
tejbeer |
271 |
@RequestMapping(value = "/getPartnersList", method = RequestMethod.GET)
|
|
|
272 |
@ApiImplicitParams({
|
|
|
273 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
274 |
public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId)
|
|
|
275 |
throws ProfitMandiBusinessException {
|
|
|
276 |
|
| 25973 |
tejbeer |
277 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
| 25952 |
tejbeer |
278 |
|
|
|
279 |
Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
|
|
|
280 |
|
| 30077 |
tejbeer |
281 |
Set<String> emails = storeGuyMap.get("ankit.bhatia@smartdukaan.com");
|
| 25952 |
tejbeer |
282 |
LOGGER.info("emails" + emails);
|
|
|
283 |
List<User> users = userRepository.selectAllByEmailIds(new ArrayList<>(emails));
|
|
|
284 |
List<Partner> partners = new ArrayList<>();
|
|
|
285 |
for (User user : users) {
|
|
|
286 |
|
|
|
287 |
UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
|
|
|
288 |
com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
|
|
|
289 |
CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
|
|
|
290 |
|
|
|
291 |
Partner partner = new Partner();
|
|
|
292 |
partner.setBusinessName(customRetailer.getBusinessName());
|
|
|
293 |
partner.setPartnerId(customRetailer.getPartnerId());
|
|
|
294 |
partner.setCartId(customRetailer.getCartId());
|
|
|
295 |
partner.setEmail(customRetailer.getEmail());
|
|
|
296 |
partner.setGstNumber(customRetailer.getGstNumber());
|
|
|
297 |
partner.setDisplayName(customRetailer.getDisplayName());
|
|
|
298 |
partner.setCity(customRetailer.getAddress().getCity());
|
|
|
299 |
partner.setUserId(user.getId());
|
|
|
300 |
partners.add(partner);
|
|
|
301 |
}
|
|
|
302 |
LOGGER.info("partners" + partners);
|
|
|
303 |
return responseSender.ok(partners);
|
|
|
304 |
}
|
|
|
305 |
|
|
|
306 |
@RequestMapping(value = "/franchise-first-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
307 |
@ApiImplicitParams({
|
|
|
308 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
309 |
public ResponseEntity<?> FranchiseFirstVisit(HttpServletRequest request,
|
|
|
310 |
@RequestBody CreateFranchiseeRequest createFranchiseeRequest) throws Exception {
|
|
|
311 |
|
|
|
312 |
FranchiseeVisit franchiseeVisit = new FranchiseeVisit();
|
|
|
313 |
franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
|
|
|
314 |
CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
|
|
|
315 |
|
|
|
316 |
franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
|
|
|
317 |
franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
|
|
|
318 |
franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
|
|
|
319 |
franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
320 |
franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
|
|
|
321 |
franchiseeVisit.setSchelduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
|
|
|
322 |
// change
|
| 25973 |
tejbeer |
323 |
AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
|
| 25952 |
tejbeer |
324 |
|
|
|
325 |
String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
|
|
|
326 |
franchiseeVisit.setCreatedBy(authUserName);
|
|
|
327 |
franchiseeVisit.setAuthId(authUser.getId());
|
|
|
328 |
|
|
|
329 |
franchiseeVisitRepository.persist(franchiseeVisit);
|
|
|
330 |
|
|
|
331 |
return responseSender.ok(true);
|
|
|
332 |
}
|
|
|
333 |
|
|
|
334 |
@RequestMapping(value = "/franchise-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
335 |
@ApiImplicitParams({
|
|
|
336 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
337 |
public ResponseEntity<?> FranchiseVisit(HttpServletRequest request,
|
|
|
338 |
@RequestBody CreateFranchiseeRequest createFranchiseeRequest) throws Exception {
|
|
|
339 |
|
|
|
340 |
FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(createFranchiseeRequest.getId());
|
|
|
341 |
franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
|
|
|
342 |
CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
|
|
|
343 |
|
|
|
344 |
franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
|
|
|
345 |
franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
|
|
|
346 |
franchiseeVisit.setPartnerRemark(createFranchiseeRequest.getPartnerRemark());
|
|
|
347 |
franchiseeVisit.setOutsideVisibity(createFranchiseeRequest.getOutsideVisibity());
|
|
|
348 |
franchiseeVisit.setInstoreVisibility(createFranchiseeRequest.getInstoreVisibility());
|
|
|
349 |
franchiseeVisit.setOutsideStock(createFranchiseeRequest.getOutsideStock());
|
|
|
350 |
franchiseeVisit.setSystemKnowledge(createFranchiseeRequest.getSystemKnowledge());
|
|
|
351 |
franchiseeVisit.setWorkingDevice(createFranchiseeRequest.getWorkingDevice());
|
|
|
352 |
franchiseeVisit.setWorkingPrinter(createFranchiseeRequest.getWorkingPrinter());
|
|
|
353 |
franchiseeVisit.setCarryBags(createFranchiseeRequest.getCarryBags());
|
|
|
354 |
franchiseeVisit.setSmartdukaanTshirt(createFranchiseeRequest.getSmartdukaanTshirt());
|
|
|
355 |
franchiseeVisit.setLatestDummies(createFranchiseeRequest.getLatestDummies());
|
|
|
356 |
franchiseeVisit.setInvestment(createFranchiseeRequest.getInvestment());
|
|
|
357 |
franchiseeVisit.setMtd(createFranchiseeRequest.getMtd());
|
|
|
358 |
franchiseeVisit.setHygiene(createFranchiseeRequest.getHygiene());
|
|
|
359 |
franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
|
|
|
360 |
franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
361 |
if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
|
|
|
362 |
franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
|
|
|
363 |
} else {
|
|
|
364 |
franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
|
|
|
365 |
}
|
|
|
366 |
|
|
|
367 |
// AuthUser authUser =
|
|
|
368 |
// authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
|
|
|
369 |
// change
|
| 25973 |
tejbeer |
370 |
AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
|
| 25952 |
tejbeer |
371 |
|
|
|
372 |
String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
|
|
|
373 |
franchiseeVisit.setCreatedBy(authUserName);
|
|
|
374 |
franchiseeVisit.setAuthId(authUser.getId());
|
|
|
375 |
|
|
|
376 |
franchiseeVisitRepository.persist(franchiseeVisit);
|
|
|
377 |
|
|
|
378 |
FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
|
|
|
379 |
franchiseeActivity.setAction(createFranchiseeRequest.getAction());
|
|
|
380 |
franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
|
|
|
381 |
franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
|
|
|
382 |
if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
|
|
|
383 |
franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getSchelduleTimestamp());
|
|
|
384 |
} else {
|
|
|
385 |
franchiseeActivity.setSchelduleTimestamp(null);
|
|
|
386 |
}
|
|
|
387 |
franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
|
|
|
388 |
franchiseeActivityRepository.persist(franchiseeActivity);
|
|
|
389 |
|
|
|
390 |
franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
|
|
|
391 |
return responseSender.ok(true);
|
|
|
392 |
}
|
|
|
393 |
|
|
|
394 |
@RequestMapping(value = "/getFranchiseVisit", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
395 |
@ApiImplicitParams({
|
|
|
396 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
397 |
public ResponseEntity<?> getFranchiseVisit(HttpServletRequest request,
|
|
|
398 |
@RequestParam(name = "gmailId") String gmailId, @RequestParam(name = "status") FranchiseeVisitStatus status,
|
|
|
399 |
@RequestParam(name = "offset", defaultValue = "0") int offset,
|
|
|
400 |
@RequestParam(name = "limit", defaultValue = "10") int limit) throws ProfitMandiBusinessException {
|
| 25973 |
tejbeer |
401 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
| 25952 |
tejbeer |
402 |
|
|
|
403 |
List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectByAuthIdAndStatus(authUser.getId(),
|
|
|
404 |
status, offset, limit);
|
|
|
405 |
|
|
|
406 |
for (FranchiseeVisit fv : franchiseeVisits) {
|
|
|
407 |
if (fv.getFranchiseActivityId() != 0) {
|
|
|
408 |
FranchiseeActivity fA = franchiseeActivityRepository.selectById(fv.getFranchiseActivityId());
|
|
|
409 |
fv.setFranchiseeActivity(fA);
|
|
|
410 |
}
|
|
|
411 |
}
|
|
|
412 |
|
|
|
413 |
return responseSender.ok(franchiseeVisits);
|
|
|
414 |
|
|
|
415 |
}
|
|
|
416 |
|
|
|
417 |
@RequestMapping(value = "/getFranchiseActivity", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
418 |
@ApiImplicitParams({
|
|
|
419 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
420 |
public ResponseEntity<?> getFranchiseActivity(HttpServletRequest request, @RequestParam(name = "id") int id)
|
|
|
421 |
throws ProfitMandiBusinessException {
|
|
|
422 |
|
|
|
423 |
List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository.selectByFranchiseeVisitId(id);
|
|
|
424 |
|
|
|
425 |
return responseSender.ok(franchiseeActivities);
|
|
|
426 |
|
|
|
427 |
}
|
|
|
428 |
|
|
|
429 |
@RequestMapping(value = "/getFranchiseeInfo", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
430 |
@ApiImplicitParams({
|
|
|
431 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
432 |
public ResponseEntity<?> getFranchiseeInfo(HttpServletRequest request, @RequestParam(name = "id") int id)
|
|
|
433 |
throws ProfitMandiBusinessException {
|
|
|
434 |
FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
|
|
|
435 |
|
|
|
436 |
return responseSender.ok(franchiseeVisit);
|
|
|
437 |
|
|
|
438 |
}
|
|
|
439 |
|
|
|
440 |
@RequestMapping(value = "/franchise-visit-update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
441 |
@ApiImplicitParams({
|
|
|
442 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
443 |
public ResponseEntity<?> franchiseVisitUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
|
|
|
444 |
@RequestParam(name = "action") FranchiseeActivityStatus action,
|
|
|
445 |
@RequestParam(name = "resolution") String resolution,
|
|
|
446 |
@RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp)
|
|
|
447 |
throws ProfitMandiBusinessException {
|
|
|
448 |
FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
|
|
|
449 |
|
|
|
450 |
FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
|
|
|
451 |
|
|
|
452 |
if (action == FranchiseeActivityStatus.FOLLOWUP) {
|
|
|
453 |
franchiseeActivity.setResolution(resolution);
|
|
|
454 |
franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
|
|
|
455 |
franchiseeActivity.setAction(action);
|
|
|
456 |
franchiseeActivity.setSchelduleTimestamp(schelduleTimestamp);
|
|
|
457 |
franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
|
|
|
458 |
franchiseeActivityRepository.persist(franchiseeActivity);
|
|
|
459 |
franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
|
|
|
460 |
franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
|
|
|
461 |
franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
462 |
franchiseeVisitRepository.persist(franchiseeVisit);
|
|
|
463 |
|
|
|
464 |
} else {
|
|
|
465 |
franchiseeActivity.setResolution(resolution);
|
|
|
466 |
franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
|
|
|
467 |
franchiseeActivity.setAction(action);
|
|
|
468 |
franchiseeActivity.setSchelduleTimestamp(null);
|
|
|
469 |
franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
|
|
|
470 |
franchiseeActivityRepository.persist(franchiseeActivity);
|
|
|
471 |
franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
|
|
|
472 |
franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
|
|
|
473 |
franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
474 |
franchiseeVisitRepository.persist(franchiseeVisit);
|
|
|
475 |
|
|
|
476 |
}
|
|
|
477 |
|
|
|
478 |
return responseSender.ok(true);
|
|
|
479 |
|
|
|
480 |
}
|
| 28935 |
tejbeer |
481 |
|
|
|
482 |
@RequestMapping(value = "/onBoardingTimelineStatus", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
483 |
@ApiImplicitParams({
|
|
|
484 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
485 |
public ResponseEntity<?> onBoardingTimelineStatus(HttpServletRequest request, Model model)
|
|
|
486 |
throws ProfitMandiBusinessException {
|
|
|
487 |
int userId = (int) request.getAttribute("userId");
|
|
|
488 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
|
|
489 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
|
|
|
490 |
PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
|
|
|
491 |
Map<StoreTimeline, OnBoardingTimelineModel> timelineStatus = null;
|
|
|
492 |
LOGGER.info("partnerOnBoardingPanel" + partnerOnBoardingPanel);
|
|
|
493 |
if (partnerOnBoardingPanel != null) {
|
|
|
494 |
|
|
|
495 |
timelineStatus = storeTimelineTatService.getTimeline(partnerOnBoardingPanel.getId());
|
|
|
496 |
}
|
|
|
497 |
List<OnBoardingTimelineModel> onBoardingModel = new ArrayList<>();
|
|
|
498 |
if (timelineStatus != null) {
|
|
|
499 |
onBoardingModel = timelineStatus.values().stream().skip(2).map(x -> x).collect(Collectors.toList());
|
|
|
500 |
}
|
|
|
501 |
return responseSender.ok(onBoardingModel);
|
|
|
502 |
|
|
|
503 |
}
|
| 28982 |
tejbeer |
504 |
|
|
|
505 |
@RequestMapping(value = "/onBoardingTimelineVisibility", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
506 |
@ApiImplicitParams({
|
|
|
507 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
508 |
public ResponseEntity<?> onBoardingTimelineVisibility(HttpServletRequest request, Model model)
|
|
|
509 |
throws ProfitMandiBusinessException {
|
|
|
510 |
int userId = (int) request.getAttribute("userId");
|
|
|
511 |
UserCart uc = userAccountRepository.getUserCart(userId);
|
|
|
512 |
|
|
|
513 |
FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
|
|
|
514 |
PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
|
|
|
515 |
boolean status = true;
|
|
|
516 |
if (partnerOnBoardingPanel != null) {
|
|
|
517 |
|
|
|
518 |
status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
|
|
|
519 |
}
|
|
|
520 |
|
| 28983 |
tejbeer |
521 |
LOGGER.info("status" + status);
|
|
|
522 |
|
| 28982 |
tejbeer |
523 |
return responseSender.ok(status);
|
|
|
524 |
|
|
|
525 |
}
|
| 30077 |
tejbeer |
526 |
|
|
|
527 |
@Autowired
|
|
|
528 |
private OrderRepository orderRepository;
|
|
|
529 |
|
|
|
530 |
@Autowired
|
|
|
531 |
private PositionRepository positionRepository;
|
|
|
532 |
|
|
|
533 |
@Autowired
|
|
|
534 |
private UserWalletRepository userWalletRepository;
|
|
|
535 |
|
|
|
536 |
@Autowired
|
|
|
537 |
private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
|
|
|
538 |
|
|
|
539 |
@Autowired
|
|
|
540 |
private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;
|
|
|
541 |
|
| 30087 |
tejbeer |
542 |
@Autowired
|
|
|
543 |
private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
|
|
|
544 |
|
| 30104 |
tejbeer |
545 |
@Autowired
|
|
|
546 |
private AuthUserPartnerMappingRepository authUserPartnerMappingRepository;
|
|
|
547 |
|
| 30077 |
tejbeer |
548 |
@RequestMapping(value = "/getPartnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
549 |
@ApiImplicitParams({
|
|
|
550 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
551 |
public ResponseEntity<?> getPartnerTarget(HttpServletRequest request,
|
| 30087 |
tejbeer |
552 |
@RequestParam(name = "gmailId") String gmailId, @RequestParam String dayValue)
|
|
|
553 |
throws ProfitMandiBusinessException {
|
| 30077 |
tejbeer |
554 |
|
|
|
555 |
AuthUser authUser = authRepository.selectByGmailId(gmailId);
|
|
|
556 |
|
| 30104 |
tejbeer |
557 |
Set<Integer> fofoIds = authUserPartnerMappingRepository.selectByAuthId(authUser.getId()).stream()
|
|
|
558 |
.map(x -> x.getFofoId()).collect(Collectors.toSet());
|
| 30077 |
tejbeer |
559 |
|
| 30104 |
tejbeer |
560 |
if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
|
|
|
561 |
|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")) {
|
| 30077 |
tejbeer |
562 |
|
| 30104 |
tejbeer |
563 |
fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> !x.isInternal() && x.isActive())
|
|
|
564 |
.map(x -> x.getId()).collect(Collectors.toSet());
|
| 30078 |
tejbeer |
565 |
|
| 30104 |
tejbeer |
566 |
}
|
|
|
567 |
|
| 30174 |
tejbeer |
568 |
if (authUser.getEmailId().equals("mohit.gulati@smartdukaan.com")
|
|
|
569 |
|| authUser.getEmailId().equals("manish.gupta@smartdukaan.com")) {
|
|
|
570 |
|
|
|
571 |
Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
|
|
|
572 |
|
|
|
573 |
fofoIds = storeGuyMap.get(authUser.getEmailId());
|
|
|
574 |
|
|
|
575 |
}
|
|
|
576 |
|
| 30205 |
tejbeer |
577 |
List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Itel", "Almost New", "Others");
|
| 30077 |
tejbeer |
578 |
float totalPartnerTargetSecondary = 0;
|
|
|
579 |
float totalPartnerTargetCollection = 0;
|
|
|
580 |
float totalPartnerAchievementSecondary = 0;
|
|
|
581 |
float totalPartnerAchievementCollection = 0;
|
|
|
582 |
TargetModel tm = new TargetModel();
|
| 30087 |
tejbeer |
583 |
Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
|
| 30077 |
tejbeer |
584 |
|
|
|
585 |
List<PartnerTargetAchievementModel> ptams = new ArrayList<>();
|
|
|
586 |
|
|
|
587 |
if (fofoIds.size() > 0 && fofoIds != null) {
|
| 30087 |
tejbeer |
588 |
List<Integer> fofoIdl = new ArrayList<>(fofoIds);
|
|
|
589 |
List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIdl).stream()
|
|
|
590 |
.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
|
| 30077 |
tejbeer |
591 |
|
|
|
592 |
LocalDateTime startDate = LocalDate.now().atStartOfDay();
|
|
|
593 |
|
| 30087 |
tejbeer |
594 |
if (dayValue.equals("previous")) {
|
|
|
595 |
startDate = LocalDate.now().minusDays(1).atStartOfDay();
|
| 30138 |
tejbeer |
596 |
|
| 30087 |
tejbeer |
597 |
}
|
|
|
598 |
|
|
|
599 |
List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
|
| 30149 |
tejbeer |
600 |
.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));
|
| 30087 |
tejbeer |
601 |
if (!partnerDailyInvestments.isEmpty()) {
|
|
|
602 |
partnerDailyInvestmentMap = partnerDailyInvestments.stream()
|
|
|
603 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
|
|
604 |
}
|
|
|
605 |
|
| 30077 |
tejbeer |
606 |
Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(fofoIdList);
|
|
|
607 |
|
|
|
608 |
Map<Integer, PartnerCollectionPlanModel> collectionPlans = userWalletRepository
|
| 30137 |
tejbeer |
609 |
.getPartnerWiseTargetCollections(fofoIdList, startDate).stream()
|
| 30077 |
tejbeer |
610 |
.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
|
|
|
611 |
|
|
|
612 |
LOGGER.info("collectionPlans {}", collectionPlans);
|
|
|
613 |
|
|
|
614 |
Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondayPlans = orderRepository
|
| 30110 |
tejbeer |
615 |
.selectPartnerSecondaryGroupByBrand(fofoIdList, startDate.toLocalDate()).stream()
|
| 30077 |
tejbeer |
616 |
.collect(Collectors.groupingBy(x -> x.getFofoId()));
|
|
|
617 |
|
|
|
618 |
LOGGER.info("partnerSecondayPlans {}", partnerSecondayPlans);
|
|
|
619 |
for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
|
|
|
620 |
int fofoId = customRetailerEntry.getKey();
|
|
|
621 |
CustomRetailer customRetailer = customRetailerEntry.getValue();
|
|
|
622 |
float totalSecondaryPlan = 0;
|
|
|
623 |
float totalSecondaryAchivement = 0;
|
|
|
624 |
|
|
|
625 |
PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();
|
|
|
626 |
ptam.setFofoId(fofoId);
|
|
|
627 |
ptam.setBusinessName(customRetailer.getBusinessName());
|
|
|
628 |
|
| 30087 |
tejbeer |
629 |
if (partnerDailyInvestmentMap.get(fofoId) != null) {
|
|
|
630 |
ptam.setWalletAmount(partnerDailyInvestmentMap.get(fofoId).getWalletAmount());
|
|
|
631 |
ptam.setShortInvestment(partnerDailyInvestmentMap.get(fofoId).getShortInvestment());
|
|
|
632 |
}
|
|
|
633 |
|
| 30077 |
tejbeer |
634 |
if (collectionPlans.get(fofoId) != null) {
|
| 30137 |
tejbeer |
635 |
PartnerCollectionPlanModel collectionPlan = collectionPlans.get(fofoId);
|
|
|
636 |
|
|
|
637 |
Integer authId = collectionPlan.getAuthId();
|
| 30087 |
tejbeer |
638 |
LOGGER.info("authId" + authId);
|
|
|
639 |
if (authId != null && authId == authUser.getId()) {
|
| 30077 |
tejbeer |
640 |
|
| 30137 |
tejbeer |
641 |
if (collectionPlan.getTargetPlan() != null && collectionPlan.getCommittedDate() != null) {
|
|
|
642 |
|
|
|
643 |
if (collectionPlan.getCommittedDate().isEqual(startDate)) {
|
|
|
644 |
totalPartnerTargetCollection += collectionPlan.getTargetPlan();
|
|
|
645 |
}
|
| 30087 |
tejbeer |
646 |
}
|
| 30137 |
tejbeer |
647 |
if (collectionPlan.getAchievementPlan() != null) {
|
|
|
648 |
totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
|
| 30087 |
tejbeer |
649 |
}
|
|
|
650 |
|
|
|
651 |
}
|
|
|
652 |
|
|
|
653 |
if (authId != null && authId != authUser.getId()) {
|
|
|
654 |
ptam.setAuthUser(authRepository.selectById(authId));
|
|
|
655 |
ptam.setCollectionColor("red");
|
|
|
656 |
}
|
|
|
657 |
if (collectionPlans.get(fofoId).getTargetPlan() != null) {
|
|
|
658 |
|
| 30137 |
tejbeer |
659 |
ptam.setCollectionTarget(collectionPlan.getTargetPlan());
|
| 30087 |
tejbeer |
660 |
}
|
|
|
661 |
|
|
|
662 |
if (collectionPlans.get(fofoId).getAchievementPlan() != null) {
|
| 30137 |
tejbeer |
663 |
ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
|
| 30087 |
tejbeer |
664 |
}
|
| 30137 |
tejbeer |
665 |
|
|
|
666 |
if (collectionPlan.getCommittedDate() != null) {
|
|
|
667 |
|
|
|
668 |
ptam.setCollectionCommitmentDate(collectionPlan.getCommittedDate().toLocalDate());
|
|
|
669 |
}
|
| 30077 |
tejbeer |
670 |
}
|
|
|
671 |
|
|
|
672 |
PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;
|
| 30087 |
tejbeer |
673 |
Map<String, PartnerSecondaryPlanModel> secondaryModelMap = new HashMap<>();
|
| 30077 |
tejbeer |
674 |
if (partnerSecondayPlans.get(fofoId) != null) {
|
| 30087 |
tejbeer |
675 |
|
| 30077 |
tejbeer |
676 |
long otherBrandSecondary = 0;
|
|
|
677 |
for (PartnerSecondaryPlanModel pspm : partnerSecondayPlans.get(fofoId)) {
|
| 30087 |
tejbeer |
678 |
Integer authId = pspm.getAuthId();
|
| 30077 |
tejbeer |
679 |
if (!brands.contains(pspm.getBrand())) {
|
| 30087 |
tejbeer |
680 |
if (pspm.getAchievementPlan() != null) {
|
|
|
681 |
otherBrandSecondary += pspm.getAchievementPlan();
|
|
|
682 |
}
|
| 30077 |
tejbeer |
683 |
} else {
|
|
|
684 |
otherPartnerSecondaryPlanModel = pspm;
|
|
|
685 |
}
|
| 30087 |
tejbeer |
686 |
|
|
|
687 |
if (pspm.getTargetPlan() != null) {
|
|
|
688 |
totalSecondaryPlan += pspm.getTargetPlan();
|
|
|
689 |
}
|
|
|
690 |
|
|
|
691 |
if (pspm.getAchievementPlan() != null) {
|
|
|
692 |
totalSecondaryAchivement += pspm.getAchievementPlan();
|
|
|
693 |
}
|
| 30137 |
tejbeer |
694 |
|
|
|
695 |
if (pspm.getCommittedDate() != null) {
|
|
|
696 |
|
|
|
697 |
ptam.setSecondaryCommitmentDate(pspm.getCommittedDate().toLocalDate());
|
|
|
698 |
}
|
| 30087 |
tejbeer |
699 |
if (authId != null && authId == authUser.getId()) {
|
|
|
700 |
|
| 30137 |
tejbeer |
701 |
if (pspm.getTargetPlan() != null && pspm.getCommittedDate() != null) {
|
| 30087 |
tejbeer |
702 |
|
| 30137 |
tejbeer |
703 |
if (pspm.getCommittedDate().isEqual(startDate)) {
|
|
|
704 |
totalPartnerTargetSecondary += pspm.getTargetPlan();
|
|
|
705 |
}
|
| 30087 |
tejbeer |
706 |
}
|
|
|
707 |
|
|
|
708 |
if (pspm.getAchievementPlan() != null) {
|
|
|
709 |
totalPartnerAchievementSecondary += pspm.getAchievementPlan();
|
|
|
710 |
}
|
|
|
711 |
|
|
|
712 |
}
|
| 30077 |
tejbeer |
713 |
}
|
|
|
714 |
if (otherPartnerSecondaryPlanModel != null) {
|
|
|
715 |
otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);
|
|
|
716 |
}
|
| 30087 |
tejbeer |
717 |
secondaryModelMap = partnerSecondayPlans.get(fofoId).stream()
|
| 30077 |
tejbeer |
718 |
.filter(x -> brands.contains(x.getBrand()))
|
|
|
719 |
.collect(Collectors.toMap(x -> x.getBrand(), x -> x));
|
|
|
720 |
|
|
|
721 |
if (secondaryModelMap.containsKey("Others")) {
|
|
|
722 |
PartnerSecondaryPlanModel psp = secondaryModelMap.get("Others");
|
|
|
723 |
psp.setAchievementPlan(otherBrandSecondary);
|
|
|
724 |
} else {
|
| 30087 |
tejbeer |
725 |
secondaryModelMap.put("Others", new PartnerSecondaryPlanModel(fofoId, "Others", (long) 0,
|
| 30137 |
tejbeer |
726 |
otherBrandSecondary, authUser.getId(), null));
|
| 30077 |
tejbeer |
727 |
}
|
|
|
728 |
for (String brand : brands) {
|
|
|
729 |
if (!secondaryModelMap.containsKey(brand)) {
|
| 30137 |
tejbeer |
730 |
secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, (long) 0,
|
|
|
731 |
(long) 0, authUser.getId(), null));
|
| 30077 |
tejbeer |
732 |
}
|
|
|
733 |
}
|
|
|
734 |
|
| 30087 |
tejbeer |
735 |
for (Entry<String, PartnerSecondaryPlanModel> secondaryModelEntry : secondaryModelMap.entrySet()) {
|
|
|
736 |
Integer authId = secondaryModelEntry.getValue().getAuthId();
|
|
|
737 |
if (authId != null && authId != authUser.getId()) {
|
|
|
738 |
secondaryModelEntry.getValue().setAuthUser(authRepository.selectById(authId));
|
|
|
739 |
ptam.setSecondaryColor("red");
|
|
|
740 |
}
|
|
|
741 |
|
|
|
742 |
}
|
|
|
743 |
|
| 30077 |
tejbeer |
744 |
ptam.setPartnerSecondaryModel(secondaryModelMap);
|
|
|
745 |
ptam.setTotalSecondaryPlan(totalSecondaryPlan);
|
| 30087 |
tejbeer |
746 |
ptam.setTotalSecondaryAchievement(totalSecondaryAchivement);
|
| 30077 |
tejbeer |
747 |
|
| 30087 |
tejbeer |
748 |
} else {
|
|
|
749 |
for (String brand : brands) {
|
|
|
750 |
PartnerSecondaryPlanModel pspm = new PartnerSecondaryPlanModel();
|
|
|
751 |
pspm.setAchievementPlan((long) 0);
|
|
|
752 |
pspm.setTargetPlan((long) 0);
|
|
|
753 |
pspm.setBrand(brand);
|
|
|
754 |
pspm.setFofoId(fofoId);
|
|
|
755 |
secondaryModelMap.put(brand, pspm);
|
|
|
756 |
}
|
|
|
757 |
ptam.setPartnerSecondaryModel(secondaryModelMap);
|
| 30077 |
tejbeer |
758 |
}
|
|
|
759 |
|
| 30078 |
tejbeer |
760 |
ptams.add(ptam);
|
|
|
761 |
|
| 30077 |
tejbeer |
762 |
}
|
|
|
763 |
|
|
|
764 |
tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
|
|
|
765 |
tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
|
|
|
766 |
tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
|
|
|
767 |
tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
|
|
|
768 |
|
| 30087 |
tejbeer |
769 |
tm.setTargetAchievement(ptams.stream()
|
|
|
770 |
.sorted(Comparator.comparing(PartnerTargetAchievementModel::getShortInvestment).reversed())
|
|
|
771 |
.collect(Collectors.toList()));
|
|
|
772 |
|
| 30077 |
tejbeer |
773 |
}
|
|
|
774 |
|
|
|
775 |
return responseSender.ok(tm);
|
|
|
776 |
|
|
|
777 |
}
|
|
|
778 |
|
|
|
779 |
@RequestMapping(value = "/target", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
|
|
|
780 |
@ApiImplicitParams({
|
|
|
781 |
@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
|
|
|
782 |
public ResponseEntity<?> createPartnerTarget(HttpServletRequest request,
|
|
|
783 |
@RequestBody PartnerTargetAchievementModel ptam) throws ProfitMandiBusinessException {
|
|
|
784 |
|
| 30089 |
tejbeer |
785 |
LOGGER.info("ptam" + ptam);
|
|
|
786 |
|
| 30087 |
tejbeer |
787 |
AuthUser authUser = authRepository.selectByGmailId(ptam.getCreatedBy());
|
| 30077 |
tejbeer |
788 |
|
| 30137 |
tejbeer |
789 |
if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
|
|
|
790 |
|| ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
|
|
|
791 |
PartnerCollectionPlan partnerCollectionPlan = partnerCollectionPlanRepository
|
|
|
792 |
.selectByLocalDate(LocalDate.now(), ptam.getFofoId(), true);
|
|
|
793 |
LOGGER.info("pcp" + partnerCollectionPlan);
|
| 30077 |
tejbeer |
794 |
|
| 30137 |
tejbeer |
795 |
if (partnerCollectionPlan == null) {
|
|
|
796 |
if (ptam.getCollectionTarget() > 0) {
|
| 30087 |
tejbeer |
797 |
|
| 30137 |
tejbeer |
798 |
partnerCollectionPlan = new PartnerCollectionPlan();
|
|
|
799 |
partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
|
|
|
800 |
partnerCollectionPlan.setAuthId(authUser.getId());
|
|
|
801 |
partnerCollectionPlan.setFofoId(ptam.getFofoId());
|
|
|
802 |
partnerCollectionPlan.setActive(true);
|
|
|
803 |
partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
|
|
|
804 |
partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
805 |
partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
|
|
|
806 |
partnerCollectionPlanRepository.persist(partnerCollectionPlan);
|
|
|
807 |
}
|
| 30087 |
tejbeer |
808 |
|
| 30137 |
tejbeer |
809 |
} else {
|
| 30087 |
tejbeer |
810 |
|
| 30137 |
tejbeer |
811 |
if (partnerCollectionPlan.getCollectionPlan() != ptam.getCollectionTarget()) {
|
|
|
812 |
float totalCollectionPlan = partnerCollectionPlan.getCollectionPlan() + 10000;
|
|
|
813 |
if (authUser.getId() == partnerCollectionPlan.getAuthId()) {
|
| 30087 |
tejbeer |
814 |
|
| 30185 |
tejbeer |
815 |
if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
|
|
|
816 |
|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
|
|
|
817 |
|| ptam.getCollectionTarget() >= totalCollectionPlan) {
|
| 30137 |
tejbeer |
818 |
partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
|
|
|
819 |
partnerCollectionPlan.setActive(true);
|
|
|
820 |
partnerCollectionPlan
|
|
|
821 |
.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
|
|
|
822 |
partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
823 |
} else {
|
|
|
824 |
throw new ProfitMandiBusinessException("collection target", "",
|
|
|
825 |
"collection target should be more than " + totalCollectionPlan);
|
|
|
826 |
}
|
| 30087 |
tejbeer |
827 |
|
|
|
828 |
} else {
|
| 30137 |
tejbeer |
829 |
|
| 30185 |
tejbeer |
830 |
if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
|
|
|
831 |
|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
|
|
|
832 |
|| ptam.getCollectionTarget() >= totalCollectionPlan) {
|
| 30137 |
tejbeer |
833 |
|
|
|
834 |
partnerCollectionPlan.setActive(false);
|
|
|
835 |
partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
836 |
partnerCollectionPlan = new PartnerCollectionPlan();
|
|
|
837 |
partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
|
|
|
838 |
partnerCollectionPlan.setAuthId(authUser.getId());
|
|
|
839 |
partnerCollectionPlan.setFofoId(ptam.getFofoId());
|
|
|
840 |
partnerCollectionPlan.setActive(true);
|
|
|
841 |
partnerCollectionPlan
|
|
|
842 |
.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
|
|
|
843 |
partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
|
|
|
844 |
partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
845 |
partnerCollectionPlanRepository.persist(partnerCollectionPlan);
|
|
|
846 |
} else {
|
|
|
847 |
throw new ProfitMandiBusinessException("collection target", "",
|
|
|
848 |
"collection target should be more than " + totalCollectionPlan);
|
|
|
849 |
}
|
| 30087 |
tejbeer |
850 |
}
|
|
|
851 |
}
|
| 30137 |
tejbeer |
852 |
|
| 30146 |
tejbeer |
853 |
if ((LocalDate.now().atStartOfDay().equals(ptam.getCollectionCommitmentDate().atStartOfDay())
|
|
|
854 |
|| ptam.getCollectionCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
|
| 30137 |
tejbeer |
855 |
&& partnerCollectionPlan.getCollectionPlan() == ptam.getCollectionTarget()) {
|
|
|
856 |
partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
|
|
|
857 |
partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
858 |
}
|
| 30087 |
tejbeer |
859 |
}
|
| 30137 |
tejbeer |
860 |
} else {
|
|
|
861 |
throw new ProfitMandiBusinessException("Date", "",
|
| 30138 |
tejbeer |
862 |
"you can't select the back date " + ptam.getCollectionCommitmentDate());
|
| 30077 |
tejbeer |
863 |
}
|
|
|
864 |
|
|
|
865 |
for (Entry<String, PartnerSecondaryPlanModel> pspm : ptam.getPartnerSecondaryModel().entrySet()) {
|
| 30087 |
tejbeer |
866 |
|
| 30137 |
tejbeer |
867 |
if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
|
|
|
868 |
|| ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
|
|
|
869 |
PartnerSecondaryPlanModel plan = pspm.getValue();
|
|
|
870 |
PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),
|
|
|
871 |
LocalDate.now(), ptam.getFofoId(), true);
|
|
|
872 |
LOGGER.info("psp" + psp);
|
| 30087 |
tejbeer |
873 |
|
| 30137 |
tejbeer |
874 |
if (psp == null) {
|
|
|
875 |
if (plan.getTargetPlan() > 0) {
|
| 30087 |
tejbeer |
876 |
|
| 30137 |
tejbeer |
877 |
psp = new PartnerSecondaryPlan();
|
|
|
878 |
psp.setAuthId(authUser.getId());
|
|
|
879 |
psp.setBrand(pspm.getKey());
|
|
|
880 |
psp.setFofoId(pspm.getValue().getFofoId());
|
|
|
881 |
psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
|
|
|
882 |
psp.setCreateTimestamp(LocalDateTime.now());
|
|
|
883 |
psp.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
884 |
psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
|
|
|
885 |
psp.setActive(true);
|
|
|
886 |
partnerSecondaryPlanRepository.persist(psp);
|
|
|
887 |
}
|
| 30087 |
tejbeer |
888 |
|
| 30137 |
tejbeer |
889 |
} else {
|
|
|
890 |
if (plan.getTargetPlan() != psp.getSecondaryPlan()) {
|
|
|
891 |
float totalSecondaryPlan = psp.getSecondaryPlan() + 10000;
|
|
|
892 |
if (authUser.getId() == plan.getAuthId()) {
|
| 30185 |
tejbeer |
893 |
if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
|
|
|
894 |
|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
|
|
|
895 |
|| plan.getTargetPlan() >= totalSecondaryPlan) {
|
| 30137 |
tejbeer |
896 |
psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
|
|
|
897 |
psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
|
|
|
898 |
psp.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
899 |
psp.setActive(true);
|
|
|
900 |
} else {
|
|
|
901 |
throw new ProfitMandiBusinessException("secondary target", "",
|
|
|
902 |
"secondary target should be more than " + totalSecondaryPlan);
|
|
|
903 |
}
|
| 30087 |
tejbeer |
904 |
|
| 30137 |
tejbeer |
905 |
} else {
|
| 30087 |
tejbeer |
906 |
|
| 30185 |
tejbeer |
907 |
if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
|
|
|
908 |
|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
|
|
|
909 |
|| plan.getTargetPlan() >= totalSecondaryPlan) {
|
| 30087 |
tejbeer |
910 |
|
| 30137 |
tejbeer |
911 |
psp.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
912 |
psp.setActive(false);
|
|
|
913 |
psp = new PartnerSecondaryPlan();
|
|
|
914 |
psp.setAuthId(authUser.getId());
|
|
|
915 |
psp.setBrand(pspm.getKey());
|
|
|
916 |
psp.setFofoId(pspm.getValue().getFofoId());
|
|
|
917 |
psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
|
|
|
918 |
psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
|
|
|
919 |
psp.setCreateTimestamp(LocalDateTime.now());
|
|
|
920 |
psp.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
921 |
psp.setActive(true);
|
|
|
922 |
partnerSecondaryPlanRepository.persist(psp);
|
|
|
923 |
} else {
|
|
|
924 |
throw new ProfitMandiBusinessException("secondary target", "",
|
|
|
925 |
"secondary target should be more than " + totalSecondaryPlan);
|
|
|
926 |
}
|
| 30087 |
tejbeer |
927 |
}
|
|
|
928 |
}
|
| 30137 |
tejbeer |
929 |
|
| 30146 |
tejbeer |
930 |
if ((LocalDate.now().atStartOfDay().equals(ptam.getSecondaryCommitmentDate().atStartOfDay())
|
|
|
931 |
|| ptam.getSecondaryCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
|
| 30137 |
tejbeer |
932 |
&& plan.getTargetPlan() == psp.getSecondaryPlan()) {
|
|
|
933 |
psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
|
|
|
934 |
psp.setUpdatedTimestamp(LocalDateTime.now());
|
|
|
935 |
}
|
|
|
936 |
|
| 30087 |
tejbeer |
937 |
}
|
| 30137 |
tejbeer |
938 |
} else {
|
|
|
939 |
throw new ProfitMandiBusinessException("Date", "",
|
| 30138 |
tejbeer |
940 |
"you can't select the back date " + ptam.getSecondaryCommitmentDate());
|
| 30077 |
tejbeer |
941 |
}
|
| 30137 |
tejbeer |
942 |
|
| 30077 |
tejbeer |
943 |
}
|
|
|
944 |
|
|
|
945 |
return responseSender.ok(true);
|
| 30137 |
tejbeer |
946 |
|
| 30077 |
tejbeer |
947 |
}
|
|
|
948 |
|
|
|
949 |
}
|