Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import com.spice.profitmandi.dao.model.ImeiActivationTimestampModel;

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

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import org.springframework.transaction.annotation.Isolation;

import org.springframework.transaction.annotation.Propagation;

import org.springframework.transaction.annotation.Transactional;

import java.util.List;

import java.util.stream.Collectors;

@Component

@Transactional(propagation = Propagation.NEVER, isolation = Isolation.READ_UNCOMMITTED)

public class StandAlone {

	@Autowired

	OppoImeiActivationService oppoImeiActivationService;

	@Autowired

	ActivatedImeiRepository activatedImeiRepository;

	public void checkOppoImeiStatus() throws Exception {

		List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationByBrand("Oppo");

		List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());

		int imeisCount = 10;

		for (int i = 0; i < (imeis.size() / imeisCount) + 1; i++) {

			List<String> subList = imeis.subList(i * imeisCount, Math.min((i + 1) * imeisCount, imeis.size()));

			oppoImeiActivationService.updateActivationDate(subList);

			System.out.println("run completed for 100 imeis --- " + i);

			System.out.println(subList);

			//break;

		}

	}

}