Subversion Repositories SmartDukaan

Rev

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

Rev 30315 Rev 30352
Line 2... Line 2...
2
 
2
 
3
import com.spice.profitmandi.dao.model.ImeiActivationTimestampModel;
3
import com.spice.profitmandi.dao.model.ImeiActivationTimestampModel;
4
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
4
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
5
import org.springframework.beans.factory.annotation.Autowired;
5
import org.springframework.beans.factory.annotation.Autowired;
6
import org.springframework.stereotype.Component;
6
import org.springframework.stereotype.Component;
7
import org.springframework.transaction.annotation.Isolation;
-
 
8
import org.springframework.transaction.annotation.Propagation;
-
 
9
import org.springframework.transaction.annotation.Transactional;
7
import org.springframework.transaction.annotation.Transactional;
10
 
8
 
11
import java.util.List;
9
import java.util.List;
12
import java.util.stream.Collectors;
10
import java.util.stream.Collectors;
13
 
11
 
14
@Component
12
@Component
15
@Transactional(propagation = Propagation.NEVER, isolation = Isolation.READ_UNCOMMITTED)
13
@Transactional(rollbackFor = Throwable.class)
16
public class StandAlone {
14
public class StandAlone {
17
 
15
 
18
	@Autowired
16
	@Autowired
19
	OppoImeiActivationService oppoImeiActivationService;
17
	private OppoImeiActivationService oppoImeiActivationService;
20
 
18
 
21
	@Autowired
19
	@Autowired
22
	ActivatedImeiRepository activatedImeiRepository;
20
	private ActivatedImeiRepository activatedImeiRepository;
23
 
21
 
24
	public void checkOppoImeiStatus() throws Exception {
22
	public void checkOppoImeiStatus() throws Exception {
-
 
23
		//Bring just 25 imeis in 1 go
25
		List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationByBrand("Oppo");
24
		List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationByBrand("Oppo");
26
		List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
25
		List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
27
		int imeisCount = 100;
-
 
28
		for (int i = 0; i < (imeis.size() / imeisCount) + 1; i++) {
-
 
29
			List<String> subList = imeis.subList(i * imeisCount, Math.min((i + 1) * imeisCount, imeis.size()));
-
 
30
			oppoImeiActivationService.updateActivationDate(subList);
26
		oppoImeiActivationService.updateActivationDate(imeis);
31
			System.out.println("run completed for 100 imeis --- " + i);
-
 
32
			System.out.println(subList);
-
 
33
			//break;
-
 
34
		}
-
 
35
	}
27
	}
36
}
28
}
37
29