Subversion Repositories SmartDukaan

Rev

Rev 23382 | Rev 23393 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
23365 ashik.ali 1
package com.spice.profitmandi.service.order;
22859 ashik.ali 2
 
3
import java.time.DateTimeException;
4
import java.time.LocalDate;
23202 ashik.ali 5
import java.time.LocalDateTime;
22859 ashik.ali 6
import java.util.ArrayList;
7
import java.util.HashMap;
8
import java.util.HashSet;
9
import java.util.Iterator;
10
import java.util.List;
11
import java.util.Map;
12
import java.util.Set;
22955 ashik.ali 13
import java.util.function.Function;
14
import java.util.stream.Collectors;
22859 ashik.ali 15
 
16
import org.json.JSONObject;
17
import org.slf4j.Logger;
18
import org.slf4j.LoggerFactory;
19
import org.springframework.beans.factory.annotation.Autowired;
20
import org.springframework.stereotype.Component;
21
 
23202 ashik.ali 22
import com.spice.profitmandi.common.enumuration.SearchType;
22859 ashik.ali 23
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
24
import com.spice.profitmandi.common.model.CartFofo;
25
import com.spice.profitmandi.common.model.CreateOrderRequest;
26
import com.spice.profitmandi.common.model.CustomAddress;
27
import com.spice.profitmandi.common.model.CustomCustomer;
28
import com.spice.profitmandi.common.model.CustomFofoOrderItem;
29
import com.spice.profitmandi.common.model.CustomInsurancePolicy;
30
import com.spice.profitmandi.common.model.CustomOrderItem;
31
import com.spice.profitmandi.common.model.CustomPaymentOption;
32
import com.spice.profitmandi.common.model.CustomRetailer;
33
import com.spice.profitmandi.common.model.GadgetCopsInsuranceModel;
23172 ashik.ali 34
import com.spice.profitmandi.common.model.GstRate;
22859 ashik.ali 35
import com.spice.profitmandi.common.model.ItemIdQuantityAvailability;
36
import com.spice.profitmandi.common.model.PdfModel;
37
import com.spice.profitmandi.common.model.PriceModel;
38
import com.spice.profitmandi.common.model.ProfitMandiConstants;
39
import com.spice.profitmandi.common.model.Quantity;
40
import com.spice.profitmandi.common.model.SerialNumberDetail;
41
import com.spice.profitmandi.common.util.InsuranceUtils;
42
import com.spice.profitmandi.common.util.StringUtils;
23172 ashik.ali 43
import com.spice.profitmandi.common.util.Utils;
22859 ashik.ali 44
import com.spice.profitmandi.dao.entity.catalog.Item;
45
import com.spice.profitmandi.dao.entity.dtr.GadgetCopsInsuranceCalc;
46
import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
47
import com.spice.profitmandi.dao.entity.dtr.InsuranceProvider;
48
import com.spice.profitmandi.dao.entity.dtr.PolicyNumberGenerationSequence;
49
import com.spice.profitmandi.dao.entity.dtr.Retailer;
50
import com.spice.profitmandi.dao.entity.dtr.User;
51
import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
52
import com.spice.profitmandi.dao.entity.fofo.Customer;
53
import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
54
import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
55
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
56
import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
23365 ashik.ali 57
import com.spice.profitmandi.dao.entity.fofo.FofoOrderPaymentOption;
23202 ashik.ali 58
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
22859 ashik.ali 59
import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
60
import com.spice.profitmandi.dao.entity.fofo.InvoiceNumberGenerationSequence;
61
import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
62
import com.spice.profitmandi.dao.entity.user.Address;
63
import com.spice.profitmandi.dao.entity.user.Counter;
64
import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
65
import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
66
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
23202 ashik.ali 67
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
22859 ashik.ali 68
import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
69
import com.spice.profitmandi.dao.repository.dtr.InsuranceProviderRepository;
70
import com.spice.profitmandi.dao.repository.dtr.PolicyNumberGenerationSequenceRepository;
71
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
72
import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
73
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
74
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
75
import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
76
import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;
77
import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;
78
import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
79
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
23365 ashik.ali 80
import com.spice.profitmandi.dao.repository.fofo.FofoOrderPaymentOptionRepository;
22859 ashik.ali 81
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
82
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
83
import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
84
import com.spice.profitmandi.dao.repository.fofo.PaymentOptionRepository;
85
import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
86
import com.spice.profitmandi.dao.repository.user.AddressRepository;
87
import com.spice.profitmandi.dao.repository.user.CounterRepository;
88
import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
89
import com.spice.profitmandi.service.pricing.PricingService;
90
import com.spice.profitmandi.service.scheme.SchemeService;
91
 
92
import in.shop2020.model.v1.catalog.ItemType;
93
 
94
@Component
95
public class OrderServiceImpl implements OrderService {
96
 
97
	private static final Logger LOGGER = LoggerFactory.getLogger(OrderServiceImpl.class);
98
 
99
	@Autowired
100
	private InventoryItemRepository inventoryItemRepository;
101
 
102
	@Autowired
103
	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
104
 
105
	@Autowired
106
	private InvoiceNumberGenerationSequenceRepository invoiceNumberGenerationSequenceRepository;
107
 
108
	@Autowired
109
	private CustomerRepository customerRepository;
110
 
111
	@Autowired
112
	private AddressRepository addressRepository;
113
 
114
	@Autowired
115
	private FofoLineItemRepository fofoLineItemRepository;
116
 
117
	@Autowired
118
	private FofoOrderItemRepository fofoOrderItemRepository;
119
 
120
	@Autowired
121
	private PaymentOptionRepository paymentOptionRepository;
122
 
123
	@Autowired
124
	private ScanRecordRepository scanRecordRepository;
125
 
126
	@Autowired
127
	private FofoOrderRepository fofoOrderRepository;
128
 
129
	@Autowired
130
	private RetailerRepository retailerRepository;
131
 
132
	@Autowired
133
	private UserRepository userRepository;
134
 
135
	@Autowired
136
	private UserAccountRepository userAccountRepository;
137
 
138
	@Autowired
139
	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
140
 
141
	@Autowired
142
	private CustomerAddressRepository customerAddressRepository;
143
 
144
	@Autowired
145
	private ItemRepository itemRepository;
146
 
147
	@Autowired
148
	private InsuranceProviderRepository insuranceProviderRepository;
149
 
150
	@Autowired
151
	private InsurancePolicyRepository insurancePolicyRepository;
152
 
153
	@Autowired
154
	private PolicyNumberGenerationSequenceRepository policyNumberGenerationSequenceRepository;
155
 
156
	@Autowired
157
	private PricingService pricingService;
158
 
159
	@Autowired
160
	private PrivateDealUserRepository privateDealUserRepository;
161
 
162
	@Autowired
163
	private CounterRepository counterRepository;
164
 
165
	@Autowired
23202 ashik.ali 166
	private FofoStoreRepository fofoStoreRepository;
167
 
168
	@Autowired
23365 ashik.ali 169
	private FofoOrderPaymentOptionRepository fofoOrderPaymentOptionRepository;
170
 
171
	@Autowired
22859 ashik.ali 172
	private SchemeService schemeService;
173
 
174
	@Override
175
	public int createOrder(CreateOrderRequest createOrderRequest, int fofoId) throws ProfitMandiBusinessException {
176
 
22872 ashik.ali 177
		CustomCustomer customCustomer = createOrderRequest.getCustomer();
178
 
179
		if(!StringUtils.isValidEmailAddress(customCustomer.getEmailId())){
180
			LOGGER.error("invalid customer emailId {} ", customCustomer.getEmailId());
22925 ashik.ali 181
			throw new ProfitMandiBusinessException(ProfitMandiConstants.EMAIL_ID, customCustomer.getEmailId(), "VE_1016");
22872 ashik.ali 182
		}
183
 
184
		if(!StringUtils.isValidMobile(customCustomer.getMobileNumber())){
185
			LOGGER.error("invalid customer mobileNumber {} ", customCustomer.getMobileNumber());
22925 ashik.ali 186
			throw new ProfitMandiBusinessException(ProfitMandiConstants.MOBILE_NUMBER, customCustomer.getMobileNumber(), "VE_1071");
22872 ashik.ali 187
		}
188
 
23370 ashik.ali 189
		if(!StringUtils.isValidGstNumber(customCustomer.getGstNumber())) {
23369 ashik.ali 190
			LOGGER.error("invalid customer gstNumber {} ", customCustomer.getGstNumber());
191
			throw new ProfitMandiBusinessException(ProfitMandiConstants.CUSTOMER_GST_NUMBER, customCustomer.getGstNumber(), "VE_1072");
192
		}
193
 
22859 ashik.ali 194
		Map<Integer, Integer> itemIdQuantity = new HashMap<>(); //this is for error
22872 ashik.ali 195
		Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap = new HashMap<>();
22859 ashik.ali 196
		Map<Integer, Float> lineItemPrice = new HashMap<>(); //this is for pricing error
197
 
23377 ashik.ali 198
 
199
 
22859 ashik.ali 200
		float totalAmount = 0;
201
		for(CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()){
22872 ashik.ali 202
			//itemIds.add(customFofoOrderItem.getItemId());
23377 ashik.ali 203
			Set<String> serialNumbers = this.serialNumberDetailsToSerialNumbers(customFofoOrderItem.getSerialNumberDetails());
204
			if(!serialNumbers.isEmpty() && customFofoOrderItem.getQuantity() != serialNumbers.size()){
22859 ashik.ali 205
				itemIdQuantity.put(customFofoOrderItem.getItemId(), customFofoOrderItem.getQuantity());
206
			}
207
			if(!(customFofoOrderItem.getSellingPrice() > 0)){
208
				lineItemPrice.put(customFofoOrderItem.getItemId(), customFofoOrderItem.getSellingPrice());
209
			}else{
22863 ashik.ali 210
				totalAmount = totalAmount + customFofoOrderItem.getSellingPrice() * customFofoOrderItem.getQuantity();
211
				totalAmount = totalAmount - customFofoOrderItem.getDiscountAmount() * customFofoOrderItem.getQuantity();
22859 ashik.ali 212
				for(SerialNumberDetail serialNumberDetail : customFofoOrderItem.getSerialNumberDetails()){
213
					if(serialNumberDetail.isInsurance() && serialNumberDetail.getAmount() > 0){
214
						totalAmount = totalAmount + serialNumberDetail.getAmount();
215
					}
216
				}
217
			}
218
 
22872 ashik.ali 219
			itemIdCustomFofoOrderItemMap.put(customFofoOrderItem.getItemId(), customFofoOrderItem);
22859 ashik.ali 220
		}
221
		if(!itemIdQuantity.isEmpty()){
222
			// if item quantity does not match with given serialnumbers size
223
			LOGGER.error("itemId's quantity should be equal to given serialnumber size {} ", itemIdQuantity);
22925 ashik.ali 224
			throw new ProfitMandiBusinessException("itemIdQuantity", itemIdQuantity, "FFORDR_1001");
22859 ashik.ali 225
			//return "error";
226
		}
227
 
228
		this.validatePaymentOptionsAndTotalAmount(createOrderRequest.getPaymentOptions(), totalAmount);
229
 
230
		if(!lineItemPrice.isEmpty()){
231
			// given fofo line item price must be greater than zero
232
			LOGGER.error("requested itemId's selling price must greater than 0");
22925 ashik.ali 233
			throw new ProfitMandiBusinessException(ProfitMandiConstants.PRICE, lineItemPrice, "FFORDR_1002");
22859 ashik.ali 234
		}
235
 
22872 ashik.ali 236
		List<CurrentInventorySnapshot> currentInventorySnapshots = currentInventorySnapshotRepository.selectByFofoItemIds(fofoId, itemIdCustomFofoOrderItemMap.keySet());
22859 ashik.ali 237
 
22872 ashik.ali 238
		this.validateCurrentInventorySnapshotQuantities(currentInventorySnapshots, itemIdCustomFofoOrderItemMap);
22859 ashik.ali 239
 
240
 
22872 ashik.ali 241
		List<Item> items = itemRepository.selectByIds(itemIdCustomFofoOrderItemMap.keySet());
242
		if(items.size() != itemIdCustomFofoOrderItemMap.keySet().size()){
243
			LOGGER.error("Requested ItemIds not found in catalog");
244
			// invalid itemIds 
22925 ashik.ali 245
			throw new ProfitMandiBusinessException("invalidItemIds", itemIdCustomFofoOrderItemMap.keySet(), "FFORDR_1003");
22872 ashik.ali 246
		}
247
 
22859 ashik.ali 248
		Map<Integer, Item>  itemMap = this.toItemMap(items);
249
 
250
		Set<Integer> nonSerializedItemIds = new HashSet<>();
251
		Set<String> serialNumbers = new HashSet<>();
252
		Map<String, Float> insuranceSerialNumberItemPrice = new HashMap<>();
253
		Map<String, Float> insuranceSerialNumberSaleAmount = new HashMap<>();
254
		Map<String, String> serialNumberModelName = new HashMap<>();
255
		Map<String, String> serialNumberBrand = new HashMap<>();
22872 ashik.ali 256
		for (CustomFofoOrderItem customFofoOrderItem: createOrderRequest.getFofoOrderItems()){
257
			Item item = itemMap.get(customFofoOrderItem.getItemId());
22859 ashik.ali 258
			if (item.getType().equals(ItemType.SERIALIZED)){
22872 ashik.ali 259
				for (SerialNumberDetail serialNumberDetail : customFofoOrderItem.getSerialNumberDetails()){
22859 ashik.ali 260
					serialNumbers.add(serialNumberDetail.getSerialNumber());
261
					if(serialNumberDetail.isInsurance()){
22872 ashik.ali 262
						insuranceSerialNumberItemPrice.put(serialNumberDetail.getSerialNumber(), customFofoOrderItem.getSellingPrice());
22859 ashik.ali 263
						insuranceSerialNumberSaleAmount.put(serialNumberDetail.getSerialNumber(), serialNumberDetail.getAmount());
264
						serialNumberModelName.put(serialNumberDetail.getSerialNumber(), item.getModelName());
265
						serialNumberBrand.put(serialNumberDetail.getSerialNumber(), item.getBrand());
266
					}
267
				}
268
			}
269
			else{
22872 ashik.ali 270
				nonSerializedItemIds.add(customFofoOrderItem.getItemId());
22859 ashik.ali 271
			}
272
		}
273
 
274
		Map<Integer, Set<InventoryItem>> serializedInventoryItemMap = new HashMap<>();
275
		Map<Integer, Set<InventoryItem>> nonSerializedInventoryItemMap = new HashMap<>();
23382 amit.gupta 276
		Map<Integer, List<Float>> itemIdPriceDropAmount = new HashMap<>();
277
		//Map<String, Float> serialNumberItemPrice = new HashMap<>();
22859 ashik.ali 278
 
279
		if (!serialNumbers.isEmpty()){
280
			List<InventoryItem> serializedInventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(fofoId, serialNumbers);
281
			LOGGER.info("serializedInventoryItems {}", serializedInventoryItems);
282
			for (InventoryItem inventoryItem : serializedInventoryItems){
283
				if (inventoryItem.getGoodQuantity() == 1){
284
					if (serializedInventoryItemMap.containsKey(inventoryItem.getItemId())){
285
						serializedInventoryItemMap.get(inventoryItem.getItemId()).add(inventoryItem);
23382 amit.gupta 286
						itemIdPriceDropAmount.get(inventoryItem.getItemId()).
287
						add(inventoryItem.getUnitPrice() - inventoryItem.getPriceDropAmount());
23383 ashik.ali 288
					}else{
22859 ashik.ali 289
						Set<InventoryItem> itemIdInventoryItems = new HashSet<>();
290
						itemIdInventoryItems.add(inventoryItem);
291
						serializedInventoryItemMap.put(inventoryItem.getItemId(), itemIdInventoryItems);
292
						ArrayList<Float> priceDropAmouts = new ArrayList<>();
23116 ashik.ali 293
						priceDropAmouts.add(inventoryItem.getUnitPrice() - (inventoryItem.getPriceDropAmount()));
23382 amit.gupta 294
						itemIdPriceDropAmount.put(inventoryItem.getItemId(), priceDropAmouts);
22859 ashik.ali 295
					}
296
				}
297
			}
298
		}
299
 
300
		if (!nonSerializedItemIds.isEmpty()){
301
			List<InventoryItem> nonSerializedInventoryItems = inventoryItemRepository.selectByFofoIdItemIds(fofoId, nonSerializedItemIds);
22872 ashik.ali 302
			LOGGER.info("nonSerializedInventoryItems {}", nonSerializedInventoryItems);
22859 ashik.ali 303
			for (InventoryItem it : nonSerializedInventoryItems){
304
				if (it.getGoodQuantity() > 0){
305
					if (nonSerializedInventoryItemMap.containsKey(it.getItemId())){
306
						nonSerializedInventoryItemMap.get(it.getItemId()).add(it);
23383 ashik.ali 307
					}else{
22859 ashik.ali 308
						Set<InventoryItem> tmp = new HashSet<>();
309
						tmp.add(it);
310
						nonSerializedInventoryItemMap.put(it.getItemId(), tmp);
311
					}
312
				}
313
			}
314
		}
315
 
22872 ashik.ali 316
		this.validateItemsSerializedNonSerialized(items, itemIdCustomFofoOrderItemMap);
22859 ashik.ali 317
 
318
		Map<Integer, Set<InventoryItem>> inventoryItemsToBill = new HashMap<>();
319
		Map<Integer, Integer> inventoryItemIdQuantityUsed = new HashMap<>(); //to keep track of inventoryitem quanity used for scan records insertion
320
 
321
		LOGGER.info("itemMap keys {}", itemMap.keySet());
322
		//Lets reduce quantity and decide what inventory items to use.
323
		for (Item item : items){
324
			if (item.getType().equals(ItemType.SERIALIZED)){
325
				//TODO:handle null
22872 ashik.ali 326
				if (serializedInventoryItemMap.get(item.getId()) == null || itemIdCustomFofoOrderItemMap.get(item.getId()).getSerialNumberDetails().size() != serializedInventoryItemMap.get(item.getId()).size()){
22859 ashik.ali 327
					//not enough serial numbers
328
					//LOGGER.info("serialNumbers {}", serialNumbers);
22872 ashik.ali 329
					//LOGGER.info("serializedInventoryItemMap {}", serializedInventoryItemMap);
330
					LOGGER.error("itemId {} => mismatch size of requested serial numbers", item.getId());
22955 ashik.ali 331
					Function<SerialNumberDetail, String> serialNumberDetailToSerialNumberFunction = new Function<SerialNumberDetail, String>() {
332
						@Override
333
						public String apply(SerialNumberDetail serialNumberDetail) {
334
							return serialNumberDetail.getSerialNumber();
335
						}
336
					};
337
					throw new ProfitMandiBusinessException("invalidSerialNumbers", itemIdCustomFofoOrderItemMap.get(item.getId()).getSerialNumberDetails().stream().map(serialNumberDetailToSerialNumberFunction).collect(Collectors.toList()), "FFORDR_1004");
22872 ashik.ali 338
				}
22859 ashik.ali 339
				Set<InventoryItem> inventoryItemsSerializedserialized = serializedInventoryItemMap.get(item.getId());
22872 ashik.ali 340
				for (InventoryItem inventoryItem : inventoryItemsSerializedserialized){
341
					inventoryItem.setGoodQuantity(0);
342
					inventoryItemIdQuantityUsed.put(inventoryItem.getId(), 1);
22859 ashik.ali 343
				}
344
				inventoryItemsToBill.put(item.getId(), inventoryItemsSerializedserialized);
345
			}
346
			else{
347
				Set<InventoryItem> inventoryItemsNonSerialized = nonSerializedInventoryItemMap.get(item.getId());
22872 ashik.ali 348
				int quantityToBill = itemIdCustomFofoOrderItemMap.get(item.getId()).getQuantity();
22859 ashik.ali 349
				int totalLeft = quantityToBill;
350
				Set<InventoryItem> inventoryItemsNonSerializedUsed = new HashSet<>();
351
				if (inventoryItemsNonSerialized!=null){
352
					for (InventoryItem inventoryItem : inventoryItemsNonSerialized){
353
						if (totalLeft > 0){
354
							int toUse = Math.min(totalLeft, inventoryItem.getGoodQuantity());
355
							inventoryItemIdQuantityUsed.put(inventoryItem.getId(), toUse);
356
							inventoryItem.setGoodQuantity(inventoryItem.getGoodQuantity()  - toUse);
357
							totalLeft = totalLeft - toUse;
358
							inventoryItemsNonSerializedUsed.add(inventoryItem);
359
						}
360
					}
361
				}
362
 
363
				if (totalLeft > 0){
364
					//not enough quanity for non-serialized
365
					LOGGER.error("not enough quanity for non-serialized");
22925 ashik.ali 366
					throw new ProfitMandiBusinessException("notEnoughQuantityForNonSerialized", totalLeft, "FFORDR_1005");
22859 ashik.ali 367
				}
368
				inventoryItemsToBill.put(item.getId(), inventoryItemsNonSerializedUsed);
369
			}
370
		}
371
 
22872 ashik.ali 372
		Map<Integer, PriceModel> itemIdMopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIdCustomFofoOrderItemMap.keySet(), fofoId);
22859 ashik.ali 373
 
22872 ashik.ali 374
		this.validateMopPrice(itemIdMopPriceMap, itemIdCustomFofoOrderItemMap);
23202 ashik.ali 375
 
376
		String fofoStoreCode = this.getFofoStoreCode(fofoId);
22859 ashik.ali 377
 
23202 ashik.ali 378
		InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = this.createAndGetInvoiceNumberGenerationSequence(fofoId, fofoStoreCode);
22859 ashik.ali 379
 
380
		Customer customer = this.createAndGetCustomer(customCustomer);
381
 
23191 ashik.ali 382
		CustomerAddress customerAddress = this.createCustomerAddress(customCustomer.getAddress(), customer.getId());
22859 ashik.ali 383
 
23369 ashik.ali 384
		FofoOrder fofoOrder = this.createAndGetFofoOrder(customer.getId(), customCustomer.getGstNumber(), fofoId, invoiceNumberGenerationSequence, totalAmount, customerAddress.getId());
22859 ashik.ali 385
 
386
		this.createPaymentOptions(fofoOrder.getId(), createOrderRequest.getPaymentOptions());
387
 
23172 ashik.ali 388
		int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(fofoId);
389
 
390
		Address retailerAddress = addressRepository.selectById(retailerAddressId);
391
 
392
		Integer stateId = null;
393
		if(customerAddress.getState().equals(retailerAddress.getState())){
394
			try{
395
				stateId = Long.valueOf(Utils.getStateInfo(customerAddress.getState()).getId()).intValue();
396
			}catch(Exception e){
397
				LOGGER.error("Unable to get state rates");
398
			}
399
		}
400
 
22859 ashik.ali 401
		for(CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()){
23382 amit.gupta 402
			FofoOrderItem fofoOrderItem = this.createAndGetFofoOrderItem(customFofoOrderItem, fofoOrder.getId(), itemMap, inventoryItemsToBill.get(customFofoOrderItem.getItemId()), itemIdPriceDropAmount, stateId);
22859 ashik.ali 403
 
404
			Set<InventoryItem> inventoryItems = inventoryItemsToBill.get(customFofoOrderItem.getItemId());
405
 
406
			this.createFofoLineItem(fofoOrderItem.getId(), inventoryItems, inventoryItemIdQuantityUsed);
407
 
408
			this.updateCurrentInventorySnapshot(currentInventorySnapshots, fofoId, customFofoOrderItem.getItemId(), customFofoOrderItem.getQuantity());
409
 
410
			this.updateInventoryItemsAndScanRecord(inventoryItems, fofoId, inventoryItemIdQuantityUsed);
411
		}
412
 
413
		// insurance calculation is insurance flag is enabled
414
		if(!insuranceSerialNumberItemPrice.isEmpty()){
415
			LOGGER.info("Processing for insurence for serialNumbers");
416
			Map<Float, GadgetCopsInsuranceCalc> insurancePricesMap = pricingService.getInsurancePrices(new HashSet<>(insuranceSerialNumberItemPrice.values()), ProfitMandiConstants.GADGET_COPS);
417
			InsuranceProvider insuranceProvider = insuranceProviderRepository.selectByName(ProfitMandiConstants.GADGET_COPS);
418
 
419
			this.validateInsuranceAmount(insuranceSerialNumberItemPrice, insuranceSerialNumberSaleAmount, insurancePricesMap);
420
 
22872 ashik.ali 421
			this.validateInsuranceMargin(insuranceSerialNumberItemPrice, itemIdCustomFofoOrderItemMap, itemIdMopPriceMap, insurancePricesMap, insuranceSerialNumberSaleAmount);
22859 ashik.ali 422
 
423
			LocalDate customerDateOfBirth = this.validateCustomerDateOfBirth(createOrderRequest.getCustomerDateOfBirth());
424
 
425
			for(Map.Entry<String, Float> entry : insuranceSerialNumberItemPrice.entrySet()){
426
				PolicyNumberGenerationSequence policyNumberGenerationSequence = this.createPolicyNumberGenerationSequence();
427
 
428
				InsurancePolicy insurancePolicy = this.createInsurancePolicy(
429
						invoiceNumberGenerationSequence, fofoId,
430
						insurancePricesMap.get(entry.getValue()).getDealerPrice(),
431
						insuranceSerialNumberSaleAmount.get(entry.getKey()),entry.getValue(),
432
						entry.getKey(), serialNumberModelName.get(entry.getKey()),
433
						serialNumberBrand.get(entry.getKey()), policyNumberGenerationSequence.getSequence(),
434
						insuranceProvider.getId(), customer, customerDateOfBirth, customerAddress);
435
 
436
				GadgetCopsInsuranceModel gadgetCopsInsuranceModel = this.createGadgetCopsInsuranceModel(serialNumberBrand.get(entry.getKey()), serialNumberModelName.get(entry.getKey()), entry.getKey(), customerDateOfBirth, customer, customerAddress, insurancePolicy);
437
 
438
				try{
439
					InsuranceUtils.submitToGadgetCops(gadgetCopsInsuranceModel);
440
					insurancePolicy.setPosted(true);
441
				}catch (ProfitMandiBusinessException profitMandiBusinessException) {
442
					LOGGER.info("Unable to submit insurance policy details to {}", insuranceProvider.getName(), profitMandiBusinessException);
443
				}
444
				insurancePolicyRepository.persist(insurancePolicy);
445
			}
446
		}
23365 ashik.ali 447
		schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
448
 
22859 ashik.ali 449
		return fofoOrder.getId();
450
	}
451
 
23377 ashik.ali 452
	private Set<String> serialNumberDetailsToSerialNumbers(Set<SerialNumberDetail> serialNumberDetails){
453
		Set<String> serialNumbers = new HashSet<>();
454
		for(SerialNumberDetail serialNumberDetail : serialNumberDetails) {
455
			if(serialNumberDetail.getSerialNumber() != null && !serialNumberDetail.getSerialNumber().isEmpty()) {
456
				serialNumbers.add(serialNumberDetail.getSerialNumber());
457
			}
458
		}
459
		return serialNumbers;
460
	}
461
 
22859 ashik.ali 462
	@Override
463
	public PdfModel getInvoicePdfModel(int fofoId, int orderId) throws ProfitMandiBusinessException {
464
 
465
		FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, orderId);
466
 
467
		PdfModel pdfModel = new PdfModel();
468
		pdfModel.setAuther("profitmandi");
469
		pdfModel.setTitle("Retailer Invoice");
470
		pdfModel.setInvoiceDate(fofoOrder.getFormattedDate());
471
 
472
		// insurance calculation
22925 ashik.ali 473
		List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerIdInvoiceNumber(fofoId, fofoOrder.getInvoiceNumber());
22859 ashik.ali 474
		Set<CustomInsurancePolicy> customInsurancePolicies = new HashSet<>();
475
		final float totalInsuranceTaxRate = 18;
476
		for(InsurancePolicy insurancePolicy : insurancePolicies){
477
			float taxableInsurancePrice = insurancePolicy.getSaleAmount() / (1 + totalInsuranceTaxRate / 100);
478
			CustomInsurancePolicy customInsurancePolicy = new CustomInsurancePolicy();
479
			customInsurancePolicy.setDescription("Damage Protection Plan for device IMEI #" + insurancePolicy.getSerialNumber() + "\n Certificate No. " + insurancePolicy.getPolicyNumber());
480
			customInsurancePolicy.setHsnCode("998716");
481
			customInsurancePolicy.setRate(taxableInsurancePrice);
482
			customInsurancePolicy.setIgstRate(18);
483
			customInsurancePolicy.setIgstAmount(taxableInsurancePrice * 18 /100);
22936 amit.gupta 484
			customInsurancePolicy.setCgstRate(9);
22859 ashik.ali 485
			customInsurancePolicy.setCgstAmount(taxableInsurancePrice * 9 /100);
486
			customInsurancePolicy.setSgstRate(9);
487
			customInsurancePolicy.setSgstAmount(taxableInsurancePrice * 9 /100);
488
			customInsurancePolicy.setNetAmount(insurancePolicy.getSaleAmount());
489
			customInsurancePolicies.add(customInsurancePolicy);
490
		}
491
		pdfModel.setInsurancePolicies(customInsurancePolicies);
23001 amit.gupta 492
		List<String> tncs = new ArrayList<>();
493
		tncs.add("I agree that goods received are in good working condition");
494
		tncs.add("Goods once sold cannot be exchanged or taken back");
495
		tncs.add("Warranty for the goods received by me is the responsibility of the manufacturer only.");
496
        if(pdfModel.getInsurancePolicies() != null && pdfModel.getInsurancePolicies().size() > 0) {
23370 ashik.ali 497
        		tncs.add("Damage protection provided is the responisibility of Protection Provider only");
23001 amit.gupta 498
        }
499
		pdfModel.setTncs(tncs);
22859 ashik.ali 500
		Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
501
		CustomCustomer customCustomer = new CustomCustomer();
502
		customCustomer.setFirstName(customer.getFirstName());
503
		customCustomer.setLastName(customer.getLastName());
504
		customCustomer.setEmailId(customer.getEmailId());
505
		customCustomer.setMobileNumber(customer.getMobileNumber());
23370 ashik.ali 506
		customCustomer.setGstNumber(fofoOrder.getCustomerGstNumber());
22859 ashik.ali 507
		CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId()); 
508
		customCustomer.setAddress(this.createCustomAddress(customerAddress));
509
		pdfModel.setCustomer(customCustomer);
510
		pdfModel.setInvoiceNumber(fofoOrder.getInvoiceNumber());
511
		pdfModel.setTotalAmount(fofoOrder.getTotalAmount());
512
 
513
		Retailer retailer = retailerRepository.selectById(fofoId);
514
		PrivateDealUser privateDealUser = null;
515
		try{
516
			privateDealUser = privateDealUserRepository.selectById(retailer.getId());
517
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
518
			LOGGER.error("Private Deal User not found : ", profitMandiBusinessException);
519
		}
520
 
521
		User user = userRepository.selectById(userAccountRepository.selectUserIdByRetailerId(retailer.getId()));
522
		CustomRetailer customRetailer = new CustomRetailer();
523
		customRetailer.setBusinessName(retailer.getName());
524
		customRetailer.setMobileNumber(user.getMobileNumber());
22933 ashik.ali 525
		//customRetailer.setTinNumber(retailer.getNumber());
22859 ashik.ali 526
		if(privateDealUser == null){
527
			customRetailer.setGstNumber(null);
528
		}else{
529
			if(null != privateDealUser.getCounterId()){
530
				Counter counter = counterRepository.selectById(privateDealUser.getCounterId());
531
				customRetailer.setGstNumber(counter.getGstin());
532
			}else{
533
				customRetailer.setGstNumber(null);
534
			}
535
		}
536
		Address retailerAddress = addressRepository.selectById(retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId()));
537
		customRetailer.setAddress(this.createCustomAddress(retailerAddress));
538
		pdfModel.setRetailer(customRetailer);
22925 ashik.ali 539
		List<FofoOrderItem> fofoOrderItems = this.getByOrderId(fofoOrder.getId());
22859 ashik.ali 540
 
541
		Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();
542
		for(FofoOrderItem fofoOrderItem : fofoOrderItems){
543
			CustomOrderItem customFofoOrderItem = new CustomOrderItem();
544
			float totalTaxRate = fofoOrderItem.getIgstRate() + fofoOrderItem.getSgstRate() + fofoOrderItem.getCgstRate();
545
			float taxableSellingPrice = fofoOrderItem.getSellingPrice() / (1 + totalTaxRate / 100);
546
			float taxableDiscountPrice = fofoOrderItem.getDiscount() / (1 + totalTaxRate / 100);
547
 
548
			customFofoOrderItem.setAmount(fofoOrderItem.getQuantity() * (taxableSellingPrice - taxableDiscountPrice));
23377 ashik.ali 549
			customFofoOrderItem.setDescription(fofoOrderItem.getBrand() + " " + fofoOrderItem.getModelName() + " " + fofoOrderItem.getModelNumber() + "-" + fofoOrderItem.getColor());
550
			Set<String> serialNumbers = this.toSerialNumbers(fofoOrderItem.getFofoLineItems());
551
			//LOGGER.info("serialNumbers {}", serialNumbers);
552
			//LOGGER.info("serialNumbers is empty {}", serialNumbers.isEmpty());
553
			if(!serialNumbers.isEmpty()) {
554
				customFofoOrderItem.setDescription(customFofoOrderItem.getDescription() + "\n IMEIS - " + String.join(", ", serialNumbers));
555
			}
22859 ashik.ali 556
			customFofoOrderItem.setRate(taxableSellingPrice);
557
			customFofoOrderItem.setDiscount(taxableDiscountPrice);
558
			customFofoOrderItem.setQuantity(fofoOrderItem.getQuantity());
559
			customFofoOrderItem.setNetAmount((fofoOrderItem.getSellingPrice()-fofoOrderItem.getDiscount())*fofoOrderItem.getQuantity());
560
			float igstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getIgstRate()) / 100;
561
			float cgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getCgstRate()) / 100;
562
			float sgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getSgstRate()) / 100;
563
			customFofoOrderItem.setIgstRate(fofoOrderItem.getIgstRate());
564
			customFofoOrderItem.setIgstAmount(igstAmount);
565
			customFofoOrderItem.setCgstRate(fofoOrderItem.getCgstRate());
566
			customFofoOrderItem.setCgstAmount(cgstAmount);
567
			customFofoOrderItem.setSgstRate(fofoOrderItem.getSgstRate());
568
			customFofoOrderItem.setSgstAmount(sgstAmount);
569
			customFofoOrderItem.setHsnCode(fofoOrderItem.getHsnCode());
570
			customerFofoOrderItems.add(customFofoOrderItem);
571
		}
572
		pdfModel.setOrderItems(customerFofoOrderItems);
573
		return pdfModel;
574
	}
575
 
576
	public String getBillingAddress(CustomerAddress customerAddress) {
577
		StringBuilder address = new StringBuilder();
578
		if ((customerAddress.getLine1() != null) && (!customerAddress.getLine1().isEmpty())) {
579
			address.append(customerAddress.getLine1());
580
			address.append(", ");
581
		}
582
 
583
		if ((customerAddress.getLine2() != null) && (!customerAddress.getLine2().isEmpty())) {
584
			address.append(customerAddress.getLine2());
585
			address.append(", ");
586
		}
587
 
588
		if ((customerAddress.getLandmark() != null) && (!customerAddress.getLandmark().isEmpty())) {
589
			address.append(customerAddress.getLandmark());
590
			address.append(", ");
591
		}
592
 
593
		if ((customerAddress.getCity() != null) && (!customerAddress.getCity().isEmpty())) {
594
			address.append(customerAddress.getCity());
595
			address.append(", ");
596
		}
597
 
598
		if ((customerAddress.getState() != null) && (!customerAddress.getState().isEmpty())) {
599
			address.append(customerAddress.getState());
600
		}
601
 
602
		if ((customerAddress.getPinCode() != null) && (!customerAddress.getPinCode().isEmpty())) {
603
			address.append("- ");
604
			address.append(customerAddress.getPinCode());
605
		}
606
 
607
		return address.toString();
608
	}
609
 
610
	@Override
611
	public List<CartFofo> cartCheckout(String cartJson) throws ProfitMandiBusinessException{
612
		try{
613
			JSONObject cartObject = new JSONObject(cartJson);
614
			Iterator<?> keys = cartObject.keys();
615
 
616
			Set<Integer> itemIds = new HashSet<>();
617
			List<CartFofo> cartItems = new ArrayList<CartFofo>();
618
 
619
			while( keys.hasNext() ) {
620
				String key = (String)keys.next();
621
				if ( cartObject.get(key) instanceof JSONObject ) {
622
					LOGGER.info(cartObject.get(key).toString());
623
				}
624
				CartFofo cf = new CartFofo();
625
				cf.setItemId(cartObject.getJSONObject(key).getInt("itemId"));
626
				cf.setQuantity(cartObject.getJSONObject(key).getInt("quantity"));
627
 
628
				if (cf.getQuantity() <= 0){
629
					continue;
630
				}
631
				cartItems.add(cf);
632
				itemIds.add(cartObject.getJSONObject(key).getInt("itemId"));
633
			}
634
			Map<Integer, Item>  itemMap = new HashMap<Integer, Item>();
635
			if (itemIds.size() > 0){
636
				List<Item> items = itemRepository.selectByIds(itemIds);
637
				for (Item i : items){
638
					itemMap.put(i.getId(), i);
639
				}
640
 
641
			}
642
			for (CartFofo cf : cartItems){
643
				Item i = itemMap.get(cf.getItemId());
644
				if (i == null){
645
					continue;
646
				}
647
				cf.setDisplayName(getValidName(i.getBrand())+" "+getValidName(i.getModelName())+" "+getValidName(i.getModelNumber())+" "+getValidName(i.getColor()).replaceAll("\\s+", " "));
648
				cf.setItemType(i.getType());
649
			}
650
			return cartItems;
651
		}catch (Exception e) {
652
			LOGGER.error("Unable to Prepare cart to place order...", e);
22925 ashik.ali 653
			throw new ProfitMandiBusinessException("cartData", cartJson, "FFORDR_1006");
22859 ashik.ali 654
		}
655
	}
656
 
23202 ashik.ali 657
	@Override
658
	public Map<String, Object> getSaleHistory(int fofoId, SearchType searchType, String searchValue, String startTimeString,
659
			String endTimeString, int offset, int limit) throws ProfitMandiBusinessException {
660
		LocalDateTime startDateTime = StringUtils.toDateTime(startTimeString);
661
		LocalDateTime endDateTime = StringUtils.toDateTime(endTimeString);
662
		long countItems = 0;
663
		List<FofoOrder> fofoOrders = new ArrayList<>();
664
 
665
		if(searchType == SearchType.CUSTOMER_MOBILE_NUMBER && !searchValue.isEmpty()){
666
			fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerMobileNumber(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
667
			countItems = fofoOrderRepository.selectCountByCustomerMobileNumber(fofoId, searchValue, startDateTime, endDateTime);
668
		}else if(searchType == SearchType.CUSTOMER_NAME && !searchValue.isEmpty()){
669
			fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerName(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
670
			countItems = fofoOrderRepository.selectCountByCustomerName(fofoId, searchValue, startDateTime, endDateTime);
671
		}else if(searchType == SearchType.IMEI && !searchValue.isEmpty()){
672
			fofoOrders = fofoOrderRepository.selectByFofoIdAndSerialNumber(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
673
			countItems = fofoOrderRepository.selectCountBySerialNumber(fofoId, searchValue, startDateTime, endDateTime);
674
		}else if(searchType == SearchType.ITEM_NAME && !searchValue.isEmpty()){
675
			fofoOrders = fofoOrderRepository.selectByFofoIdAndItemName(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
676
			countItems = fofoOrderRepository.selectCountByItemName(fofoId, searchValue, startDateTime, endDateTime);
677
		}else{
678
			fofoOrders = fofoOrderRepository.selectByFofoId(fofoId, startDateTime, endDateTime, offset, limit);
23297 ashik.ali 679
			countItems = fofoOrderRepository.selectCountByFofoId(fofoId, startDateTime, endDateTime);
23202 ashik.ali 680
		}
681
		Map<String, Object> map = new HashMap<>();
682
 
683
		map.put("saleHistories", fofoOrders);
684
		map.put("start", offset + 1);
685
		map.put("size", countItems);
686
		map.put("searchType", searchType);
23351 ashik.ali 687
		map.put("searchTypes", SearchType.values());
23202 ashik.ali 688
		map.put(ProfitMandiConstants.START_TIME, startTimeString);
689
		map.put(ProfitMandiConstants.END_TIME, endTimeString);
690
		if (fofoOrders.size() < limit){
691
			map.put("end", offset + fofoOrders.size());
692
		}
693
		else{
694
			map.put("end", offset + limit);
695
		}
696
		return map;
697
	}
698
 
699
	@Override
700
	public Map<String, Object> getSaleHistoryPaginated(int fofoId, SearchType searchType, String searchValue, String startTimeString,
701
			String endTimeString, int offset, int limit) throws ProfitMandiBusinessException {
702
		LocalDateTime startDateTime = StringUtils.toDateTime(startTimeString);
703
		LocalDateTime endDateTime = StringUtils.toDateTime(endTimeString);
704
		List<FofoOrder> fofoOrders = new ArrayList<>();
705
 
706
		if(searchType == SearchType.CUSTOMER_MOBILE_NUMBER && !searchValue.isEmpty()){
707
			fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerMobileNumber(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
708
		}else if(searchType == SearchType.CUSTOMER_NAME && !searchValue.isEmpty()){
709
			fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerName(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
710
		}else if(searchType == SearchType.IMEI && !searchValue.isEmpty()){
711
			fofoOrders = fofoOrderRepository.selectByFofoIdAndSerialNumber(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
712
		}else if(searchType == SearchType.ITEM_NAME && !searchValue.isEmpty()){
713
			fofoOrders = fofoOrderRepository.selectByFofoIdAndItemName(fofoId, searchValue, startDateTime, endDateTime, offset, limit);
714
		}else{
715
			fofoOrders = fofoOrderRepository.selectByFofoId(fofoId, startDateTime, endDateTime, offset, limit);
716
		}
717
		Map<String, Object> map = new HashMap<>();
718
 
719
		map.put("saleHistories", fofoOrders);
720
		return map;
721
	}
722
 
723
	private String getFofoStoreCode(int fofoId) throws ProfitMandiBusinessException{
724
		FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
23370 ashik.ali 725
		return fofoStore.getCode();
23202 ashik.ali 726
	}
727
 
728
 
23191 ashik.ali 729
	private CustomerAddress createCustomerAddress(CustomAddress customAddress, int customerId){
730
		CustomerAddress customerAddress = null;
731
		try{
732
			//CustomAddress customAddress = customCustomer.getAddress();
733
			customerAddress = customerAddressRepository.selectByParams(
734
					customAddress.getName(), customAddress.getLine1(), customAddress.getLine2(),
735
					customAddress.getLandmark(),customAddress.getCity(), customAddress.getPinCode(),
736
					customAddress.getState(), customAddress.getPhoneNumber(), customAddress.getCountry(), customerId);
737
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
738
			LOGGER.warn("Customer address not found : ", profitMandiBusinessException);
739
			customerAddress = new CustomerAddress();
740
			this.setCustomerAddress(customerAddress, customAddress);
741
			customerAddress.setCustomerId(customerId);
742
		}
743
		customerAddressRepository.persist(customerAddress);
744
		return customerAddress;
745
	}
746
 
22859 ashik.ali 747
	private String getValidName(String name){
748
		return name!=null?name:"";
749
	}
750
 
751
	private Set<String> toSerialNumbers(Set<FofoLineItem> fofoLineItems){
23377 ashik.ali 752
		Set<String> serialNumbers = new HashSet<>();
753
		for(FofoLineItem fofoLineItem : fofoLineItems) {
23381 amit.gupta 754
			if(fofoLineItem.getSerialNumber() != null && !fofoLineItem.getSerialNumber().isEmpty()) {
23377 ashik.ali 755
				serialNumbers.add(fofoLineItem.getSerialNumber());
22955 ashik.ali 756
			}
23377 ashik.ali 757
		}
758
		return serialNumbers;
22859 ashik.ali 759
	}
760
 
761
 
762
	private PolicyNumberGenerationSequence createPolicyNumberGenerationSequence(){
763
		PolicyNumberGenerationSequence policyNumberGenerationSequence = null;
764
		try{
765
			policyNumberGenerationSequence = policyNumberGenerationSequenceRepository.select();
766
			policyNumberGenerationSequence.setSequence(policyNumberGenerationSequence.getSequence() + 1);
767
			policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);
768
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
769
			policyNumberGenerationSequence = new PolicyNumberGenerationSequence();
770
			policyNumberGenerationSequence.setSequence(1);
771
			policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);
772
		}
773
		return policyNumberGenerationSequence;
774
	}
775
 
776
	private GadgetCopsInsuranceModel createGadgetCopsInsuranceModel(String brand, String modelName, String serialNumber, LocalDate customerDateOfBirth, Customer customer, CustomerAddress customerAddress, InsurancePolicy insurancePolicy){
777
		GadgetCopsInsuranceModel gadgetCopsInsuranceModel = new GadgetCopsInsuranceModel();
778
		gadgetCopsInsuranceModel.setBrand(brand);
779
		gadgetCopsInsuranceModel.setModelName(modelName);
780
		gadgetCopsInsuranceModel.setSerialNumber(serialNumber);
781
		gadgetCopsInsuranceModel.setCustomerFirstName(customer.getFirstName());
782
		gadgetCopsInsuranceModel.setCustomerLastName(customer.getLastName());
783
		gadgetCopsInsuranceModel.setCustomerDateOfBirth(customerDateOfBirth);
784
		gadgetCopsInsuranceModel.setCustomerMobileNumber(customer.getMobileNumber());
785
		gadgetCopsInsuranceModel.setCustomerEmailId(customer.getEmailId());
786
		gadgetCopsInsuranceModel.setCustomerAddress1(customerAddress.getLine1());
787
		gadgetCopsInsuranceModel.setCustomerAddress2(customerAddress.getLine2());
788
		gadgetCopsInsuranceModel.setCustomerCity(customerAddress.getCity());
789
		gadgetCopsInsuranceModel.setCustomerPinCode(customerAddress.getPinCode());
790
		gadgetCopsInsuranceModel.setCustomerState(customerAddress.getState());
791
		gadgetCopsInsuranceModel.setPrice(insurancePolicy.getSellingPrice());
792
		gadgetCopsInsuranceModel.setInvoiceNumber(insurancePolicy.getInvoiceNumber());
793
		gadgetCopsInsuranceModel.setPolicyNumber(insurancePolicy.getPolicyNumber());
794
		return gadgetCopsInsuranceModel;
795
	}
796
 
797
	private InsurancePolicy createInsurancePolicy(InvoiceNumberGenerationSequence invoiceNumberGenerationSequence, int retailerId, float purchaseAmount, float saleAmount, float sellingPrice, String serialNumber, String modelName, String brand, int policyNumberGenerationSequence, int insuranceProviderId, Customer customer, LocalDate customerDateOfBirth, CustomerAddress customerAddress){
798
		InsurancePolicy insurancePolicy = new InsurancePolicy();
799
		insurancePolicy.setInvoiceNumber(invoiceNumberGenerationSequence.getPrefix() + invoiceNumberGenerationSequence.getSequence());
800
		insurancePolicy.setRetailerId(retailerId);
801
		insurancePolicy.setPurchaseAmount(purchaseAmount);
802
		insurancePolicy.setSaleAmount(saleAmount);
803
		insurancePolicy.setSellingPrice(sellingPrice);
804
		insurancePolicy.setSerialNumber(serialNumber);
805
		insurancePolicy.setModelName(modelName);
806
		insurancePolicy.setBrand(brand);
807
		insurancePolicy.setPolicyNumber(StringUtils.generatePolicyNumber(ProfitMandiConstants.POLICY_NUMBER_PREFIX, policyNumberGenerationSequence));
808
		insurancePolicy.setProviderId(insuranceProviderId);
809
		insurancePolicy.setCustomerFirstName(customer.getFirstName());
810
		insurancePolicy.setCustomerLastName(customer.getLastName());
811
		insurancePolicy.setCustomerMobileNumber(customer.getMobileNumber());
812
		insurancePolicy.setCustomerEmailId(customer.getEmailId());
813
		insurancePolicy.setCustomerDateOfBirth(customerDateOfBirth);
814
		insurancePolicy.setCustomerAddress1(customerAddress.getLine1());
815
		insurancePolicy.setCustomerAddress2(customerAddress.getLine2());
816
		insurancePolicy.setCustomerCity(customerAddress.getCity());
817
		insurancePolicy.setCustomerPinCode(customerAddress.getPinCode());
818
		insurancePolicy.setCustomerState(customerAddress.getState());
819
		return insurancePolicy;
820
	}
821
 
22872 ashik.ali 822
	private void validateInsuranceMargin(Map<String, Float> insuranceSerialNumberItemPrice, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap, Map<Integer, PriceModel> itemIdMopPriceMap, Map<Float, GadgetCopsInsuranceCalc> insurancePricesMap, Map<String, Float> insuranceSerialNumberSaleAmount) throws ProfitMandiBusinessException{
22859 ashik.ali 823
		Map<Float, Float> invalidInsuranceMarginAmount = new HashMap<>();
824
		for(Map.Entry<String, Float> entry : insuranceSerialNumberItemPrice.entrySet()){
22872 ashik.ali 825
			int itemId = this.getItemIdFromSerialNumber(itemIdCustomFofoOrderItemMap, entry.getKey());
22859 ashik.ali 826
			float itemPurchasePrice = itemIdMopPriceMap.get(itemId).getPrice();
827
			float itemSellingPrice = entry.getValue();
828
			float itemMargin = itemSellingPrice - itemPurchasePrice;
829
			float insurancePurchasePrice = insurancePricesMap.get(entry.getValue()).getDealerPrice();
830
			float insuranceSellingPrice = insuranceSerialNumberSaleAmount.get(entry.getKey());
831
			float insuranceMargin = insuranceSellingPrice - insurancePurchasePrice;
832
			if(insuranceMargin < (itemMargin * 30 / 100)){
833
				invalidInsuranceMarginAmount.put(insuranceMargin, (itemMargin * 30 / 100));
834
			}
835
		}
836
		if(!invalidInsuranceMarginAmount.isEmpty()){
837
			LOGGER.error("insurance marging should be greater than equal to item profit margin insuranceMarginItemIdMargin {}", invalidInsuranceMarginAmount);
22925 ashik.ali 838
			throw new ProfitMandiBusinessException("invalidInsuranceMarginAmount", invalidInsuranceMarginAmount, "FFORDR_1007");
22859 ashik.ali 839
		}
840
	}
841
 
842
	private void validateInsuranceAmount(Map<String, Float> insuranceSerialNumberItemPrice, Map<String, Float> insuranceSerialNumberSaleAmount, Map<Float, GadgetCopsInsuranceCalc> insurancePricesMap) throws ProfitMandiBusinessException{
843
		Map<Float, Float> invalidInsurancePurchaseSaleAmount = new HashMap<>();
844
		Map<Float, Float> invalidInsuranceSalePurchaseAmount = new HashMap<>();
845
		for(Map.Entry<String, Float> entry : insuranceSerialNumberItemPrice.entrySet()){
846
			if(insuranceSerialNumberSaleAmount.get(entry.getKey()) < insurancePricesMap.get(entry.getValue()).getDealerPrice()){
847
				invalidInsurancePurchaseSaleAmount.put(insurancePricesMap.get(entry.getValue()).getDealerPrice(), insuranceSerialNumberSaleAmount.get(entry.getKey()));
848
			}
849
 
850
			if(insuranceSerialNumberSaleAmount.get(entry.getKey()) > insurancePricesMap.get(entry.getValue()).getSellingPrice()){
851
				invalidInsuranceSalePurchaseAmount.put(insuranceSerialNumberSaleAmount.get(entry.getKey()), insurancePricesMap.get(entry.getValue()).getDealerPrice());
852
			}
853
		}
854
 
855
		// insurance sale amount can not be lesser than insurance purchase amount
856
		if(!invalidInsurancePurchaseSaleAmount.isEmpty()){
857
			LOGGER.error("Invalid Insurance prices [{}], insurance sale amount can not be lesser than insurance purchase amount", invalidInsurancePurchaseSaleAmount);
22925 ashik.ali 858
			throw new ProfitMandiBusinessException("invalidInsurancePurchaseSaleAmount", invalidInsurancePurchaseSaleAmount, "FFORDR_1008");
22859 ashik.ali 859
		}
860
 
861
		if(!invalidInsuranceSalePurchaseAmount.isEmpty()){
862
			LOGGER.error("Invalid Insurance prices [{}], insurance sale amount can not be greater than than insurance max amount", invalidInsuranceSalePurchaseAmount);
22925 ashik.ali 863
			throw new ProfitMandiBusinessException("invalidInsuranceSalePurchaseAmount", invalidInsuranceSalePurchaseAmount, "FFORDR_1009");
22859 ashik.ali 864
		}
865
	}
866
 
22872 ashik.ali 867
	private void validateMopPrice(Map<Integer, PriceModel> itemIdMopPriceMap, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoLineItemMap) throws ProfitMandiBusinessException{
22859 ashik.ali 868
		Map<Integer, Float> invalidMopItemIdPriceMap = new HashMap<>();
869
		Map<Integer, Float> invalidDiscountAmountMap = new HashMap<>();
870
		//Map<Integer, PriceModel> itemIdMopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIds, fofoId);
871
		for(Map.Entry<Integer, PriceModel> entry : itemIdMopPriceMap.entrySet()){
22872 ashik.ali 872
			CustomFofoOrderItem customFofoOrderItem = itemIdCustomFofoLineItemMap.get(entry.getKey());
873
			if(entry.getValue().getPrice() < Float.MAX_VALUE && customFofoOrderItem.getSellingPrice() < entry.getValue().getPrice()){
874
				invalidMopItemIdPriceMap.put(entry.getKey(), customFofoOrderItem.getSellingPrice());
22859 ashik.ali 875
			}
22872 ashik.ali 876
			if(entry.getValue().isMop() && customFofoOrderItem.getDiscountAmount() > entry.getValue().getMaxDiscountAmount()){
877
				invalidDiscountAmountMap.put(entry.getKey(), customFofoOrderItem.getDiscountAmount());
878
			}
22859 ashik.ali 879
		}
880
 
881
		if(!invalidMopItemIdPriceMap.isEmpty()){
882
			LOGGER.error("Invalid itemIds selling prices{} should be greater than mop prices {}", invalidMopItemIdPriceMap, itemIdMopPriceMap);
22925 ashik.ali 883
			throw new ProfitMandiBusinessException("invalidMopItemIdPrice", invalidMopItemIdPriceMap, "FFORDR_1010");
22859 ashik.ali 884
		}
885
 
886
		if(!invalidMopItemIdPriceMap.isEmpty()){
887
			LOGGER.error("Invalid itemIds discount amounts {} should be less than maxDiscount prices {}", invalidDiscountAmountMap, itemIdMopPriceMap);
22925 ashik.ali 888
			throw new ProfitMandiBusinessException("invalidMopItemIdPrice", invalidDiscountAmountMap, "FFORDR_1011");
22859 ashik.ali 889
		}
890
	}
891
 
892
	private LocalDate validateCustomerDateOfBirth(String customerDateOfBirthString) throws ProfitMandiBusinessException{
893
		LocalDate customerDateOfBirth = null;
894
		try{
895
			customerDateOfBirth = StringUtils.toDate(customerDateOfBirthString);
896
		}catch(DateTimeException dateTimeException){
897
			LOGGER.error("Unable to parse dateOfBirth", dateTimeException);
22925 ashik.ali 898
			throw new ProfitMandiBusinessException("dateOfBirth", customerDateOfBirthString, "FFORDR_1012");
22859 ashik.ali 899
		}
900
		return customerDateOfBirth;
901
	}
902
 
903
	private void updateInventoryItemsAndScanRecord(Set<InventoryItem> inventoryItems, int fofoId, Map<Integer, Integer> inventoryItemQuantityUsed){
904
		for(InventoryItem inventoryItem : inventoryItems){
905
			inventoryItem.setLastScanType(ScanType.SALE);
906
			inventoryItemRepository.persist(inventoryItem);
907
			ScanRecord scanRecord = new ScanRecord();
908
			scanRecord.setInventoryItemId(inventoryItem.getId());
909
			scanRecord.setFofoId(fofoId);
910
			//correct this
911
			scanRecord.setQuantity(inventoryItemQuantityUsed.get(inventoryItem.getId()));
912
			scanRecord.setType(ScanType.SALE);
913
			scanRecordRepository.persist(scanRecord);
914
		}
915
	}
916
 
917
	private void createFofoLineItem(int fofoOrderItemId, Set<InventoryItem> inventoryItems, Map<Integer, Integer> inventoryItemIdQuantityUsed){
918
		for(InventoryItem inventoryItem : inventoryItems){
919
			FofoLineItem fofoLineItem = new FofoLineItem();
920
			fofoLineItem.setFofoOrderItemId(fofoOrderItemId);
921
			fofoLineItem.setSerialNumber(inventoryItem.getSerialNumber());
922
			fofoLineItem.setInventoryItemId(inventoryItem.getId());
923
			fofoLineItem.setQuantity(inventoryItemIdQuantityUsed.get(inventoryItem.getId()));
924
			fofoLineItemRepository.persist(fofoLineItem);
925
		}
926
	}
927
 
23382 amit.gupta 928
	private FofoOrderItem createAndGetFofoOrderItem(CustomFofoOrderItem customFofoOrderItem, int fofoOrderId, Map<Integer, Item> itemMap, Set<InventoryItem> inventoryItems, Map<Integer, List<Float>> itemIdPriceDropAmount, Integer stateId) throws ProfitMandiBusinessException{
22859 ashik.ali 929
		FofoOrderItem fofoOrderItem = new FofoOrderItem();
930
		fofoOrderItem.setItemId(customFofoOrderItem.getItemId());
931
		fofoOrderItem.setQuantity(customFofoOrderItem.getQuantity());
932
		fofoOrderItem.setSellingPrice(customFofoOrderItem.getSellingPrice());
933
		fofoOrderItem.setOrderId(fofoOrderId);
934
		fofoOrderItem.setDp(customFofoOrderItem.getSellingPrice());
935
		fofoOrderItem.setDiscount(customFofoOrderItem.getDiscountAmount());
936
		Item item = itemMap.get(customFofoOrderItem.getItemId());
23172 ashik.ali 937
		Map<Integer, GstRate> itemIdStateTaxRateMap = null;
938
		Map<Integer, Float> itemIdIgstTaxRateMap = null;
939
		if(stateId != null){
940
			itemIdStateTaxRateMap = Utils.getStateTaxRate(new ArrayList<>(itemMap.keySet()), stateId);
941
		}else{
942
			itemIdIgstTaxRateMap = Utils.getIgstTaxRate(new ArrayList<>(itemMap.keySet()));
943
		}
22859 ashik.ali 944
		for(InventoryItem inventoryItem : inventoryItems){
23172 ashik.ali 945
			if(stateId == null){
946
				fofoOrderItem.setIgstRate(itemIdIgstTaxRateMap.get(inventoryItem.getItemId()));
947
			}else{
948
				fofoOrderItem.setCgstRate(itemIdStateTaxRateMap.get(inventoryItem.getItemId()).getCgstRate());
949
				fofoOrderItem.setSgstRate(itemIdStateTaxRateMap.get(inventoryItem.getItemId()).getSgstRate());
950
			}
23382 amit.gupta 951
 
22859 ashik.ali 952
			fofoOrderItem.setHsnCode(inventoryItem.getHsnCode());
953
			break;
954
		}
23382 amit.gupta 955
		List<Float> priceDropAmounts = itemIdPriceDropAmount.get(customFofoOrderItem.getItemId());
956
		float cost = 0;
23383 ashik.ali 957
		if (priceDropAmounts != null){
23382 amit.gupta 958
			for (Float pda : priceDropAmounts){
959
				cost = cost + pda;
960
			}
961
		}else{
962
			cost = customFofoOrderItem.getSellingPrice() * customFofoOrderItem.getQuantity();
963
		}
964
		fofoOrderItem.setCost(cost);
22859 ashik.ali 965
		fofoOrderItem.setBrand(item.getBrand());
966
		fofoOrderItem.setModelName(item.getModelName());
967
		fofoOrderItem.setModelNumber(item.getModelNumber());
968
		fofoOrderItem.setColor(item.getColor());
969
		fofoOrderItemRepository.persist(fofoOrderItem);
970
		return fofoOrderItem;
971
	}
972
 
973
	private void updateCurrentInventorySnapshot(List<CurrentInventorySnapshot> currentInventorySnapshots, int fofoId, int itemId, int quantity) throws ProfitMandiBusinessException{
974
		for(CurrentInventorySnapshot currentInventorySnapshot : currentInventorySnapshots){
975
			if(currentInventorySnapshot.getItemId() == itemId && currentInventorySnapshot.getFofoId() == fofoId){
976
				currentInventorySnapshotRepository.updateAvailabilityByItemIdAndFofoId(itemId, fofoId, currentInventorySnapshot.getAvailability() - quantity);
977
			}
978
		}
979
	}
980
 
23365 ashik.ali 981
	private void createPaymentOptions(int fofoOrderId, Set<CustomPaymentOption> customPaymentOptions) throws ProfitMandiBusinessException{
22859 ashik.ali 982
		for(CustomPaymentOption customPaymentOption : customPaymentOptions){
23371 ashik.ali 983
			if(customPaymentOption.getAmount() > 0) {
984
				FofoOrderPaymentOption fofoOrderPaymentOption = new FofoOrderPaymentOption();
985
				fofoOrderPaymentOption.setFofoOrderId(fofoOrderId);
986
				fofoOrderPaymentOption.setPaymentOptionId(customPaymentOption.getPaymentOptionId());
987
				fofoOrderPaymentOption.setAmount(customPaymentOption.getAmount());
988
				fofoOrderPaymentOptionRepository.persist(fofoOrderPaymentOption);
989
			}
22859 ashik.ali 990
		}
991
	}
992
 
23369 ashik.ali 993
	private FofoOrder createAndGetFofoOrder(int customerId, String customerGstNumber, int fofoId, InvoiceNumberGenerationSequence invoiceNumberGenerationSequence, float totalAmount, int customerAddressId){
22859 ashik.ali 994
		FofoOrder fofoOrder = new FofoOrder();
23369 ashik.ali 995
		fofoOrder.setCustomerGstNumber(customerGstNumber);
22859 ashik.ali 996
		fofoOrder.setCustomerId(customerId);
997
		fofoOrder.setFofoId(fofoId);
23370 ashik.ali 998
		fofoOrder.setInvoiceNumber(invoiceNumberGenerationSequence.getPrefix() + "/" + invoiceNumberGenerationSequence.getSequence());
22859 ashik.ali 999
		fofoOrder.setTotalAmount(totalAmount);
1000
		fofoOrder.setCustomerAddressId(customerAddressId);
1001
		fofoOrderRepository.persist(fofoOrder);
1002
		return fofoOrder;
1003
	}
1004
 
1005
	private Customer createAndGetCustomer(CustomCustomer customCustomer) throws ProfitMandiBusinessException{
1006
		Customer customer = null;
1007
		try{
1008
			customer = customerRepository.selectByMobileNumber(customCustomer.getMobileNumber());
1009
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
1010
			LOGGER.error("Error : ", profitMandiBusinessException);
1011
			customer = new Customer();
1012
		}
23190 ashik.ali 1013
		customer.setFirstName(customCustomer.getFirstName());
1014
		customer.setLastName(customCustomer.getLastName());
1015
		customer.setEmailId(customCustomer.getEmailId());
1016
		customer.setMobileNumber(customCustomer.getMobileNumber());
1017
		customerRepository.persist(customer);
22859 ashik.ali 1018
		return customer;
1019
	}
1020
 
23202 ashik.ali 1021
	private InvoiceNumberGenerationSequence createAndGetInvoiceNumberGenerationSequence(int fofoId, String fofoStoreCode){
22859 ashik.ali 1022
		InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = null;
1023
		try{
1024
			invoiceNumberGenerationSequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoId);
1025
			invoiceNumberGenerationSequence.setSequence(invoiceNumberGenerationSequence.getSequence() + 1);
1026
		}catch(ProfitMandiBusinessException profitMandiBusinessException){
1027
			invoiceNumberGenerationSequence = new InvoiceNumberGenerationSequence();
1028
			invoiceNumberGenerationSequence.setFofoId(fofoId);
23370 ashik.ali 1029
			invoiceNumberGenerationSequence.setPrefix(fofoStoreCode);
22859 ashik.ali 1030
			invoiceNumberGenerationSequence.setSequence(1);
1031
		}
1032
		invoiceNumberGenerationSequenceRepository.persist(invoiceNumberGenerationSequence);
1033
		return invoiceNumberGenerationSequence;
1034
	}
1035
 
22872 ashik.ali 1036
	private void validateItemsSerializedNonSerialized(List<Item> items, Map<Integer, CustomFofoOrderItem> customFofoOrderItemMap) throws ProfitMandiBusinessException{
22859 ashik.ali 1037
 		List<Integer> invalidItemIdSerialNumbers = new ArrayList<Integer>();
1038
		List<Integer> itemIdNonSerializedSerialNumbers = new ArrayList<Integer>();
1039
		for (Item i : items){
22872 ashik.ali 1040
			CustomFofoOrderItem customFofoOrderItem = customFofoOrderItemMap.get(i.getId());
1041
			if (i.getType().equals(ItemType.SERIALIZED)){
1042
				if (customFofoOrderItem == null || customFofoOrderItem.getSerialNumberDetails().isEmpty()){
1043
					invalidItemIdSerialNumbers.add(i.getId());
22859 ashik.ali 1044
				}
23202 ashik.ali 1045
			}else{
23377 ashik.ali 1046
				Set<String> serialNumbers = this.serialNumberDetailsToSerialNumbers(customFofoOrderItem.getSerialNumberDetails());
1047
				if (customFofoOrderItem == null || !serialNumbers.isEmpty()){
22872 ashik.ali 1048
					itemIdNonSerializedSerialNumbers.add(i.getId());
22859 ashik.ali 1049
				}
1050
			}
1051
		}
1052
 
1053
		if(!invalidItemIdSerialNumbers.isEmpty()){
1054
			LOGGER.error("Invalid itemId's serialNumbers for serialized{}", invalidItemIdSerialNumbers);
1055
			// itemId's are serialized you are saying these are not serialized
22925 ashik.ali 1056
			throw new ProfitMandiBusinessException("invalidItemIdSerialNumbers", invalidItemIdSerialNumbers, "FFORDR_1013");
22859 ashik.ali 1057
		}
1058
 
1059
		if(!itemIdNonSerializedSerialNumbers.isEmpty()){
1060
			LOGGER.error("Invalid itemId's serialNumbers for non serialized{}", itemIdNonSerializedSerialNumbers);
1061
			// itemId's are non serialized you are saying these are serialized
22925 ashik.ali 1062
			throw new ProfitMandiBusinessException("itemIdNonSerializedSerialNumbers", itemIdNonSerializedSerialNumbers, "FFORDR_1014");
22859 ashik.ali 1063
		}
1064
	}
1065
 
22872 ashik.ali 1066
	private void validateCurrentInventorySnapshotQuantities(List<CurrentInventorySnapshot> currentInventorySnapshots, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap) throws ProfitMandiBusinessException{
1067
		if(itemIdCustomFofoOrderItemMap.keySet().size() != currentInventorySnapshots.size()){
22859 ashik.ali 1068
			throw new ProfitMandiBusinessException("quantiiesSize", currentInventorySnapshots.size(), "");
1069
		}
1070
		List<ItemIdQuantityAvailability> itemIdQuantityAvailabilities = new ArrayList<>(); //this is for error
1071
		LOGGER.info("currentInventorySnapshots "+currentInventorySnapshots);
22872 ashik.ali 1072
		LOGGER.info("CustomFofoLineItemMap {}", itemIdCustomFofoOrderItemMap);
22859 ashik.ali 1073
		for(CurrentInventorySnapshot currentInventorySnapshot : currentInventorySnapshots){
22872 ashik.ali 1074
			CustomFofoOrderItem customFofoOrderItem = itemIdCustomFofoOrderItemMap.get(currentInventorySnapshot.getItemId());
1075
			LOGGER.info("customFofoOrderItem {}", customFofoOrderItem);
1076
			if(customFofoOrderItem.getQuantity() > currentInventorySnapshot.getAvailability()){
22859 ashik.ali 1077
					ItemIdQuantityAvailability itemIdQuantityAvailability = new ItemIdQuantityAvailability();
1078
					itemIdQuantityAvailability.setItemId(customFofoOrderItem.getItemId());
1079
					Quantity quantity = new Quantity();
1080
					quantity.setAvailable(currentInventorySnapshot.getAvailability());
1081
					quantity.setRequested(customFofoOrderItem.getQuantity());
1082
					itemIdQuantityAvailability.setQuantity(quantity);
1083
					itemIdQuantityAvailabilities.add(itemIdQuantityAvailability);
1084
				}
1085
 
1086
		}
1087
 
1088
 
1089
 
1090
		if(!itemIdQuantityAvailabilities.isEmpty()){
1091
			// itemIdQuantity request is not valid
1092
			LOGGER.error("Requested quantities should not be greater than currently available quantities {}", itemIdQuantityAvailabilities);
22925 ashik.ali 1093
			throw new ProfitMandiBusinessException("itemIdQuantityAvailabilities", itemIdQuantityAvailabilities, "FFORDR_1015");
22859 ashik.ali 1094
		}
1095
	}
1096
 
22872 ashik.ali 1097
	private int getItemIdFromSerialNumber(Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap, String serialNumber){
1098
		int itemId = 0;
1099
		for(Map.Entry<Integer, CustomFofoOrderItem> entry : itemIdCustomFofoOrderItemMap.entrySet()){
1100
			Set<SerialNumberDetail> serialNumberDetails = entry.getValue().getSerialNumberDetails();
1101
			for(SerialNumberDetail serialNumberDetail : serialNumberDetails){
1102
				if(serialNumberDetail.getSerialNumber().equals(serialNumber)){
1103
					itemId = entry.getKey();
1104
					break;
1105
				}
22859 ashik.ali 1106
			}
1107
		}
22872 ashik.ali 1108
		return itemId;
22859 ashik.ali 1109
	}
1110
 
1111
	private Map<Integer, Item> toItemMap(List<Item> items){
22955 ashik.ali 1112
		Function<Item, Integer> itemIdFunction = new Function<Item, Integer>() {
1113
			@Override
1114
			public Integer apply(Item item) {
1115
				return item.getId();
1116
			}
1117
		};
1118
		Function<Item, Item> itemFunction = new Function<Item, Item>() {
1119
			@Override
1120
			public Item apply(Item item) {
1121
				return item;
1122
			}
1123
		};
1124
		return items.stream().collect(Collectors.toMap(itemIdFunction, itemFunction));
22859 ashik.ali 1125
	}
1126
 
23190 ashik.ali 1127
	private void setCustomerAddress(CustomerAddress customerAddress, CustomAddress customAddress){
22859 ashik.ali 1128
		customerAddress.setName(customAddress.getName());
1129
		customerAddress.setLine1(customAddress.getLine1());
1130
		customerAddress.setLine2(customAddress.getLine2());
1131
		customerAddress.setLandmark(customAddress.getLandmark());
1132
		customerAddress.setCity(customAddress.getCity());
1133
		customerAddress.setPinCode(customAddress.getPinCode());
1134
		customerAddress.setState(customAddress.getState());
1135
		customerAddress.setCountry(customAddress.getCountry());
1136
		customerAddress.setPhoneNumber(customAddress.getPhoneNumber());
1137
	}
1138
 
1139
	private CustomAddress createCustomAddress(Address address){
1140
		CustomAddress customAddress = new CustomAddress();
1141
		customAddress.setName(address.getName());
1142
		customAddress.setLine1(address.getLine1());
1143
		customAddress.setLine2(address.getLine2());
1144
		customAddress.setLandmark(address.getLandmark());
1145
		customAddress.setCity(address.getCity());
1146
		customAddress.setPinCode(address.getPinCode());
1147
		customAddress.setState(address.getState());
1148
		customAddress.setCountry(address.getCountry());
1149
		customAddress.setPhoneNumber(address.getPhoneNumber());
1150
		return customAddress;
1151
	}
1152
 
1153
	private CustomAddress createCustomAddress(CustomerAddress customerAddress){
1154
		CustomAddress customAddress = new CustomAddress();
1155
		customAddress.setName(customerAddress.getName());
1156
		customAddress.setLine1(customerAddress.getLine1());
1157
		customAddress.setLine2(customerAddress.getLine2());
1158
		customAddress.setLandmark(customerAddress.getLandmark());
1159
		customAddress.setCity(customerAddress.getCity());
1160
		customAddress.setPinCode(customerAddress.getPinCode());
1161
		customAddress.setState(customerAddress.getState());
1162
		customAddress.setCountry(customerAddress.getCountry());
1163
		customAddress.setPhoneNumber(customerAddress.getPhoneNumber());
1164
		return customAddress;
1165
	}
1166
 
1167
	private void validatePaymentOptionsAndTotalAmount(Set<CustomPaymentOption> customPaymentOptions, float totalAmount) throws ProfitMandiBusinessException
1168
	{
23365 ashik.ali 1169
		Set<Integer> paymentOptionIds = new HashSet<>();
1170
 
22859 ashik.ali 1171
		float calculatedAmount = 0;
1172
		for(CustomPaymentOption customPaymentOption : customPaymentOptions){
23365 ashik.ali 1173
			paymentOptionIds.add(customPaymentOption.getPaymentOptionId());
1174
			calculatedAmount = calculatedAmount + customPaymentOption.getAmount();
22859 ashik.ali 1175
		}
1176
		if(calculatedAmount != totalAmount){
22863 ashik.ali 1177
			LOGGER.warn("Error occured while validating payment options amount[{}] != TotalAmount [{}]", calculatedAmount, totalAmount);
22925 ashik.ali 1178
			throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_CALCULATED_AMOUNT, calculatedAmount, "FFORDR_1016");
22859 ashik.ali 1179
		}
23365 ashik.ali 1180
 
1181
		List<Integer> foundPaymentOptionIds = paymentOptionRepository.selectIdsByIds(paymentOptionIds);
1182
		if(foundPaymentOptionIds.size() != paymentOptionIds.size()) {
1183
			paymentOptionIds.removeAll(foundPaymentOptionIds);
1184
			throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_ID, paymentOptionIds, "FFORDR_1017");
1185
		}
22859 ashik.ali 1186
	}
22925 ashik.ali 1187
 
1188
	@Override
1189
	public List<FofoOrderItem> getByOrderId(int orderId) throws ProfitMandiBusinessException {
1190
		List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(orderId);
1191
		if(!fofoOrderItems.isEmpty()){
1192
			List<FofoOrderItem> newFofoOrderItems = new ArrayList<>();
1193
			Map<Integer, Set<FofoLineItem>> fofoOrderItemIdFofoLineItemsMap = this.toFofoOrderItemIdFofoLineItems(fofoOrderItems);
1194
			Iterator<FofoOrderItem> fofoOrderItemsIterator = fofoOrderItems.iterator();
1195
			while(fofoOrderItemsIterator.hasNext()){
1196
				FofoOrderItem fofoOrderItem = fofoOrderItemsIterator.next();
1197
				fofoOrderItem.setFofoLineItems(fofoOrderItemIdFofoLineItemsMap.get(fofoOrderItem.getId()));
1198
				newFofoOrderItems.add(fofoOrderItem);
1199
				fofoOrderItemsIterator.remove();
1200
			}
1201
			fofoOrderItems = newFofoOrderItems;
1202
		}
1203
		return fofoOrderItems;
1204
	}
1205
 
1206
	private Set<Integer> toFofoOrderItemIds(List<FofoOrderItem> fofoOrderItems){
22955 ashik.ali 1207
		Function<FofoOrderItem, Integer> fofoOrderItemToFofoOrderItemIdFunction = new Function<FofoOrderItem, Integer>() {
1208
			@Override
1209
			public Integer apply(FofoOrderItem fofoOrderItem) {
1210
				return fofoOrderItem.getId();
1211
			}
1212
		};
1213
		return fofoOrderItems.stream().map(fofoOrderItemToFofoOrderItemIdFunction).collect(Collectors.toSet());
22925 ashik.ali 1214
	}
1215
 
1216
	private Map<Integer, Set<FofoLineItem>> toFofoOrderItemIdFofoLineItems(List<FofoOrderItem> fofoOrderItems){
1217
		Set<Integer> fofoOrderItemIds = this.toFofoOrderItemIds(fofoOrderItems);
1218
		List<FofoLineItem> fofoLineItems = fofoLineItemRepository.selectByFofoOrderItemIds(fofoOrderItemIds);
1219
		Map<Integer, Set<FofoLineItem>> fofoOrderItemIdFofoLineItemsMap = new HashMap<>();
1220
		for(FofoLineItem fofoLineItem : fofoLineItems){
1221
			if(!fofoOrderItemIdFofoLineItemsMap.containsKey(fofoLineItem.getFofoOrderItemId())){
1222
				Set<FofoLineItem> fofoLineItems2 = new HashSet<>();
1223
				fofoLineItems2.add(fofoLineItem);
1224
				fofoOrderItemIdFofoLineItemsMap.put(fofoLineItem.getFofoOrderItemId(), fofoLineItems2);
1225
			}else{
1226
				fofoOrderItemIdFofoLineItemsMap.get(fofoLineItem.getFofoOrderItemId()).add(fofoLineItem);
1227
			}
1228
		}
1229
		return fofoOrderItemIdFofoLineItemsMap;
1230
	}
22859 ashik.ali 1231
 
1232
}