AccountCheck.java 1.48 KB
Newer Older
2  
manxiaoqiang committed
1 2
package tkio.task;

2  
manxiaoqiang committed
3
import common.controller.ContractController;
2  
manxiaoqiang committed
4 5 6
import common.model.Contract;
import common.repository.ContractRepository;
import dic.ContractTypeEnum;
2  
manxiaoqiang committed
7 8
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
2  
manxiaoqiang committed
9 10 11 12 13 14 15 16 17 18 19 20 21
import org.springframework.beans.factory.annotation.Autowired;
import tkio.model.Account;
import tkio.repository.AccountRepository;
import util.DateUtil;
import util.ValidateUtil;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by mxq on 2018/4/23.
 */
public class AccountCheck {
2  
manxiaoqiang committed
22
    private static final Logger logger = LoggerFactory.getLogger(AccountCheck.class);
2  
manxiaoqiang committed
23 24 25 26 27 28 29
    @Autowired
    AccountRepository accountRepository;
    @Autowired
    ContractRepository contractRepository;

    public void task(){
        List<Account> accountList = accountRepository.findRootParentsByPubDate(DateUtil.getBeforeDays(30));
2  
manxiaoqiang committed
30
        logger.info("startDate :" + DateUtil.getBeforeDays(30));
2  
manxiaoqiang committed
31 32 33 34
        if(ValidateUtil.isValid(accountList)){
            List<Account> list = new ArrayList<>();
            for(Account a: accountList){
                List<Contract> contractList = contractRepository.findByPlatformAndEmail("tkio", a.getEmail(), ContractTypeEnum.MAIN.getKey());
2  
manxiaoqiang committed
35
                if(null == contractList || contractList.isEmpty()){
2  
manxiaoqiang committed
36 37 38 39 40 41 42 43 44 45 46
                    a.setStatus(0);
                    list.add(a);
                }

                if(ValidateUtil.isValid(list)){
                    accountRepository.save(list);
                }
            }
        }
    }
}