package com.fdkankan.manage.task;

import com.fdkankan.manage.entity.*;
import com.fdkankan.manage.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class TaskService {
    @Autowired
    IJyUserService jyUserService;
    @Autowired
    ICaseService caseService;
    @Autowired
    ICaseOverviewService caseOverviewService;
    @Autowired
    ICaseTabulationService caseTabulationService;
    @Autowired
    ICaseFusionService caseFusionService;

    @PostConstruct
    public void task(){
        updateCasePlatformId();
        updateCaseOverviewPlatformId();
        updateCaseTabulationPlatformId();
        updateCaseFusionPlatformId();
        updateCaseFusionLat();
        updateCaseFusionTitle();
    }




    private void updateCasePlatformId() {
        List<Case> list = caseService.list();
        for (Case aCase : list) {
            if(aCase.getPlatformId() == null){
                JyUser jyUser = jyUserService.getBySysId(aCase.getSysUserId());
                if(jyUser != null && jyUser.getPlatformId() != null){
                    caseService.updatePlatformIdById(aCase.getCaseId(),jyUser.getPlatformId());
                }
            }
        }
    }


    private void updateCaseOverviewPlatformId() {
        List<CaseOverview> list = caseOverviewService.list();
        List<Integer> caseIds = list.stream().filter(e->e.getSysUserId()== null).map(CaseOverview::getCaseId).collect(Collectors.toList());
        List<Case> cases = caseService.listByIds(caseIds);
        for (Case aCase : cases) {
            caseOverviewService.updatePlatformIdByCase(aCase.getCaseId(),aCase.getSysUserId(),aCase.getPlatformId());
        }
    }

    private void updateCaseTabulationPlatformId() {
        List<CaseTabulation> list = caseTabulationService.list();
        List<Integer> caseIds = list.stream().filter(e->e.getSysUserId()== null).map(CaseTabulation::getCaseId).collect(Collectors.toList());
        List<Case> cases = caseService.listByIds(caseIds);
        for (Case aCase : cases) {
            caseTabulationService.updatePlatformIdByCase(aCase.getCaseId(),aCase.getSysUserId(),aCase.getPlatformId());
        }
    }

    private void updateCaseFusionPlatformId() {
        List<CaseFusion> list = caseFusionService.list();
        List<Integer> caseIds = list.stream().filter(e->e.getSysUserId()== null).map(CaseFusion::getCaseId).collect(Collectors.toList());
        List<Case> cases = caseService.listByIds(caseIds);
        for (Case aCase : cases) {
            caseFusionService.updatePlatformIdByCase(aCase.getCaseId(),aCase.getSysUserId(),aCase.getPlatformId());
        }
    }

    private void updateCaseFusionLat() {
        List<CaseFusion> list = caseFusionService.list();
        List<Integer> caseIds = list.stream().filter(e->e.getLatAndLong()== null).map(CaseFusion::getCaseId).collect(Collectors.toList());
        List<Case> cases = caseService.listByIds(caseIds);
        for (Case aCase : cases) {
            caseFusionService.updateCaseFusionLat(aCase.getCaseId(),aCase.getLatAndLong());
        }
    }
    private void updateCaseFusionTitle() {
        List<CaseFusion> list = caseFusionService.list();
        List<Integer> caseIds = list.stream().filter(e->e.getFusionTitle()== null).map(CaseFusion::getCaseId).collect(Collectors.toList());
        List<Case> cases = caseService.listByIds(caseIds);
        for (Case aCase : cases) {
            caseFusionService.updateCaseFusionTitle(aCase.getCaseId(),aCase.getCaseTitle());
        }
    }
}