Subversion Repositories SmartDukaan

Rev

Rev 30659 | Rev 30685 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 30659 Rev 30660
Line 100... Line 100...
100 
import java.io.File;
 100 
import java.io.File;
101 
import java.io.FileInputStream;
 101 
import java.io.FileInputStream;
102 
import java.io.IOException;
 102 
import java.io.IOException;
103 
import java.time.LocalDate;
 103 
import java.time.LocalDate;
104 
import java.time.LocalDateTime;
 104 
import java.time.LocalDateTime;
105 
import java.time.LocalTime;
 - 
 
106 
import java.time.Month;
 105 
import java.time.Month;
107 
import java.time.temporal.ChronoUnit;
 106 
import java.time.temporal.ChronoUnit;
108 
import java.util.*;
 107 
import java.util.*;
109 
import java.util.concurrent.TimeUnit;
 108 
import java.util.concurrent.TimeUnit;
110 
import java.util.stream.Collectors;
 109 
import java.util.stream.Collectors;
Line 306... Line 305...
306 
			endDate = startDate.plusMonths(1);
 305 
			endDate = startDate.plusMonths(1);
307 
		}
 306 
		}
308 
		samsungIMEIActivationService.getActivationsBetweenNew(startDate, endDate);
 307 
		samsungIMEIActivationService.getActivationsBetweenNew(startDate, endDate);
309 
	}
 308 
	}
310 
 
 309 
 
311 
	public void migarateLineItemsToNewTable() throws Exception {
 - 
 
312 
		LOGGER.info("Before Migrated LineItems Successfully");
 - 
 
313 
		int lineItemImeiId = 0;
 - 
 
314 
		LocalDateTime startDate = null;
 - 
 
315 
		try {
 - 
 
316 
			lineItemImeiId = lineItemImeisRepository.selectMaxId();
 - 
 
317 
			LineItem lineItem = lineItemRepository
 - 
 
318 
					.selectById(lineItemImeisRepository.selectById(lineItemImeiId).getLineItemId());
 - 
 
319 
			Order order = orderRepository.selectById(lineItem.getOrderId());
 - 
 
320 
			startDate = order.getBillingTimestamp();
 - 
 
321 
		} catch (Exception e) {
 - 
 
322 
			LOGGER.info("Running before first time");
 - 
 
323 
			startDate = LocalDateTime.of(LocalDate.of(2017, 7, 1), LocalTime.MIDNIGHT);
 - 
 
324 
		}
 - 
 
325 
		List<Order> orders = orderRepository.selectAllByBillingDatesBetween(startDate, LocalDateTime.now());
 - 
 
326 
		Collections.reverse(orders);
 - 
 
327 
 
 - 
 
328 
		for (Order order : orders) {
 - 
 
329 
			try {
 - 
 
330 
				String serialNumbers = order.getLineItem().getSerialNumber();
 - 
 
331 
				if (!StringUtils.isEmpty(serialNumbers)) {
 - 
 
332 
					List<String> serialNumberList = Arrays.asList(serialNumbers.split(","));
 - 
 
333 
					for (String serialNumber : serialNumberList) {
 - 
 
334 
						int lineItemId = order.getLineItem().getId();
 - 
 
335 
						LineItemImei lineItemImei = new LineItemImei();
 - 
 
336 
						lineItemImei.setSerialNumber(serialNumber);
 - 
 
337 
						lineItemImei.setLineItemId(lineItemId);
 - 
 
338 
						lineItemImeisRepository.persist(lineItemImei);
 - 
 
339 
					}
 - 
 
340 
				} else {
 - 
 
341 
					LOGGER.info("Serial Numbers dont exist for Order {}", order.getId());
 - 
 
342 
				}
 - 
 
343 
			} catch (Exception e) {
 - 
 
344 
				LOGGER.info("Error occurred while creating lineitem imei {}, because of {}", order.getId(),
 - 
 
345 
						e.getMessage());
 - 
 
346 
			}
 - 
 
347 
		}
 - 
 
348 
		LOGGER.info("Migrated LineItems Successfully");
 - 
 
349 
	}
 - 
 
350 
 
 - 
 
351 
	public void cancelOrder(List<String> invoiceNumbers) throws Exception {
 310 
	public void cancelOrder(List<String> invoiceNumbers) throws Exception {
352 
		orderService.cancelOrder(invoiceNumbers);
 311 
		orderService.cancelOrder(invoiceNumbers);
353 
	}
 312 
	}
354 
 
 313 
 
355 
	@Autowired
 314 
	@Autowired
Line 1486... Line 1445...
1486 
	}
 1445 
	}
1487 
 
 1446 
 
1488 
	@Autowired
 1447 
	@Autowired
1489 
	SaholicReservationSnapshotRepository saholicReservationSnapshotRepository;
 1448 
	SaholicReservationSnapshotRepository saholicReservationSnapshotRepository;
1490 
 
 1449 
 
1491 
	@Autowired
 - 
 
1492 
	SaholicInventoryService saholicInventoryService;
 - 
 
1493 
 
 - 
 
1494 
	public void fixReservations() throws Exception {
 1450 
	public void fixReservations() throws Exception {
1495 
		// Clear all Reservations
 1451 
		// Clear all Reservations
1496 
		saholicInventorySnapshotRepository.selectAll().stream().forEach(x -> x.setReserved(0));
 1452 
		saholicInventorySnapshotRepository.selectAll().stream().forEach(x -> x.setReserved(0));
1497 
		saholicReservationSnapshotRepository.selectAll().forEach(x -> saholicReservationSnapshotRepository.delete(x));
 1453 
		saholicReservationSnapshotRepository.selectAll().forEach(x -> saholicReservationSnapshotRepository.delete(x));
1498 
		List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(
 1454 
		List<Order> orders = orderRepository.selectAllOrderDatesBetweenByStatus(