Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

package com.smartdukaan.cron.scheduled;

import java.io.IOException;

import java.io.IOException;

import java.io.Serializable;

import java.io.Serializable;

import java.sql.Timestamp;

import java.sql.Timestamp;

import java.time.Duration;

import java.time.Duration;

import java.time.LocalDate;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.LocalTime;

import org.springframework.stereotype.Component;

import org.springframework.stereotype.Component;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.transaction.annotation.Transactional;

import com.google.common.collect.Lists;

import com.google.common.collect.Lists;

import com.google.gson.Gson;

import com.google.gson.Gson;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.enumuration.RechargeStatus;

import com.spice.profitmandi.common.enumuration.RechargeStatus;

import com.spice.profitmandi.common.enumuration.ReporticoProject;

import com.spice.profitmandi.common.enumuration.ReporticoProject;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;

import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;

import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;

import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;

import com.spice.profitmandi.dao.repository.inventory.StateRepository;

import com.spice.profitmandi.dao.repository.inventory.StateRepository;

import com.spice.profitmandi.dao.repository.inventory.WarehouseRepository;

import com.spice.profitmandi.dao.repository.inventory.WarehouseRepository;

import com.spice.profitmandi.dao.repository.transaction.HdfcPaymentRepository;

import com.spice.profitmandi.dao.repository.transaction.HdfcPaymentRepository;

import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;

import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;

import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;

import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;

import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;

import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;

import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;

import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;

import com.spice.profitmandi.service.user.RetailerService;

import com.spice.profitmandi.service.user.RetailerService;

import com.spice.profitmandi.service.wallet.WalletService;

import com.spice.profitmandi.service.wallet.WalletService;

import in.shop2020.model.v1.order.OrderStatus;

import in.shop2020.model.v1.order.OrderStatus;

import in.shop2020.model.v1.order.WalletReferenceType;

import in.shop2020.model.v1.order.WalletReferenceType;

import okhttp3.OkHttpClient;

import okhttp3.OkHttpClient;

import okhttp3.Request;

import okhttp3.Request;

import okhttp3.Response;;

import okhttp3.Response;;

@Component

@Component

@Transactional(rollbackFor = Throwable.class)

@Transactional(rollbackFor = Throwable.class)

public class ScheduledTasks {

public class ScheduledTasks {

	@Autowired

	@Autowired

	private EmployeeAttendanceRepository employeeAttendanceRepository;

	private EmployeeAttendanceRepository employeeAttendanceRepository;

	@Autowired

	@Autowired

	private PartnerTypeChangeService partnerTypeChangeService;

	private PartnerTypeChangeService partnerTypeChangeService;

	@Autowired

	@Autowired

	private ActivatedImeiRepository activatedImeiRepository;

	private ActivatedImeiRepository activatedImeiRepository;

	@Autowired

	@Autowired

	private LeadRepository leadRepository;

	private LeadRepository leadRepository;

	@Autowired

	@Autowired

	private AuthRepository authRepository;

	private AuthRepository authRepository;

	public void getVendorWarehouses(int warehouseId) {

	public void getVendorWarehouses(int warehouseId) {

		LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));

		LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));

	}

	}

	public void checkCancellationMargin() throws Exception {

	public void checkCancellationMargin() throws Exception {

		LocalDateTime startDate = LocalDate.of(2021, 4, 1).atStartOfDay();

		LocalDateTime startDate = LocalDate.of(2021, 4, 1).atStartOfDay();

		List<FofoOrder> fofoOrders = fofoOrderRepository.selectCancelledBetweenSaleDate(startDate, LocalDateTime.now());

		List<FofoOrder> fofoOrders = fofoOrderRepository.selectCancelledBetweenSaleDate(startDate, LocalDateTime.now());

		LOGGER.info("Total Orders =  {}", fofoOrders.size());

		LOGGER.info("Total Orders =  {}", fofoOrders.size());

			}

			}

		}

		}

	}

	}

	public void markDelhiveryOrderDelivered() throws ProfitMandiBusinessException, IOException {

	public void markDelhiveryOrderDelivered() throws ProfitMandiBusinessException, IOException {

		List<Order> orders = orderRepository.selectOrderByProviderIdAndStatus(ProfitMandiConstants.DELHIVERY_PROVIDERID,

		List<Order> orders = orderRepository.selectOrderByProviderIdAndStatus(ProfitMandiConstants.DELHIVERY_PROVIDERID,

				OrderStatus.SHIPPED_FROM_WH);

				OrderStatus.SHIPPED_FROM_WH);

		if (!orders.isEmpty()) {

		if (!orders.isEmpty()) {