package cn.huge.module.griddata.service;
|
|
import cn.huge.base.common.bo.R;
|
import cn.huge.base.common.utils.DateUtils;
|
import cn.huge.module.client.api.impl.CaseClientImpl;
|
import cn.huge.module.griddata.dao.mapper.CaseInfoMapper;
|
import cn.huge.module.griddata.dao.mapper.CaseInfoUnfoldMapper;
|
import cn.huge.module.griddata.domain.CaseAgent;
|
import cn.huge.module.griddata.domain.CaseInfo;
|
import cn.huge.module.griddata.domain.CaseInfoUnfold;
|
import cn.huge.module.griddata.domain.CasePerson;
|
import cn.huge.module.griddata.domain.vo.CaseVo;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.ibatis.annotations.Case;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service
|
@Slf4j
|
public class GridDataSyncService {
|
@Resource
|
private CaseInfoMapper caseInfoMapper;
|
@Resource
|
private CaseInfoUnfoldMapper caseInfoUnfoldMapper;
|
@Resource
|
private CaseClientImpl caseClient;
|
@Resource
|
private CaseInfoService caseInfoService;
|
@Resource
|
private CaseInfoUnfoldService caseInfoUnfoldService;
|
@Resource
|
private CasePersonService casePersonService;
|
@Resource
|
private CaseAgentService caseAgentService;
|
|
// public R<CaseInfo> getData() {
|
// CaseInfo lastCaseInfo = caseInfoMapper.getLastCaseInfo();
|
// log.info("xsd：{}",lastCaseInfo.getCreateTime());
|
// return R.ok(lastCaseInfo);
|
// }
|
//
|
// public R<CaseInfo> getData2() {
|
// CaseVo caseVo = new CaseVo();
|
// caseVo.setLastTime("2024-12-24 09:43:13");
|
// caseVo.setType(1);
|
// List<CaseInfo> caseInfoList = caseClient.getCaseInfo(caseVo);
|
// List<CaseInfo> insert = new ArrayList<>();
|
// insert.add(caseInfoList.get(1));
|
// log.info("xsd：{}",insert.get(0));
|
// caseInfoService.saveOrUpdateBatch(insert, insert.size());
|
// return R.ok(caseInfoList.get(1));
|
// }
|
|
// @Scheduled(cron = "0 0/1 * * * ?")
|
@Transactional(rollbackFor = Exception.class)
|
public int syncData() {
|
int count = 0;
|
log.info("xsdcreateTime:{}", 1);
|
CaseInfo lastCaseInfo = caseInfoMapper.getLastCaseInfo();
|
log.info("xsdcreateTime:{}", 2);
|
String createTime = lastCaseInfo.getCreateTime();
|
log.info("xsdcreateTime:{}", createTime);
|
CaseVo caseVo = new CaseVo();
|
caseVo.setLastTime(createTime);
|
caseVo.setType(1);
|
List<CaseInfo> caseInfoList = caseClient.getCaseInfo(caseVo);
|
log.info("xsdcaseInfoList:{}", caseInfoList.size());
|
caseVo.setType(2);
|
List<CaseInfo> caseInfoUpdateList = caseClient.getCaseInfo(caseVo);
|
log.info("xsdcaseInfoUpdateList:{}", caseInfoUpdateList.size());
|
if (caseInfoList != null && caseInfoList.size() > 0)
|
caseInfoService.saveOrUpdateBatch(caseInfoList, caseInfoList.size());
|
if (caseInfoUpdateList != null && caseInfoUpdateList.size() > 0)
|
caseInfoService.updateBatchById(caseInfoUpdateList, caseInfoUpdateList.size());
|
|
List<CaseInfoUnfold> caseInfoUnfoldList = new ArrayList<>();
|
List<CasePerson> casePersonList = new ArrayList<>();
|
List<CaseAgent> caseAgentList = new ArrayList<>();
|
for (CaseInfo caseInfo : caseInfoList) {
|
caseInfoUnfoldList.addAll(caseClient.getCaseInfoUnfold(caseInfo.getId()));
|
casePersonList.addAll(caseClient.getCasePerson(caseInfo.getId()));
|
caseAgentList.addAll(caseClient.getCaseAgent(caseInfo.getId()));
|
}
|
log.info("xsdinsert:{}", caseInfoUnfoldList.size());
|
log.info("xsdinsert:{}", casePersonList.size());
|
log.info("xsdinsert:{}", caseAgentList.size());
|
//插入案子
|
if (caseInfoUnfoldList.size() > 0)
|
caseInfoUnfoldService.saveOrUpdateBatch(caseInfoUnfoldList, caseInfoUnfoldList.size());
|
if (caseAgentList.size() > 0)
|
caseAgentService.saveOrUpdateBatch(caseAgentList, caseAgentList.size());
|
if (casePersonList.size() > 0)
|
casePersonService.saveOrUpdateBatch(casePersonList, casePersonList.size());
|
|
|
//获取需要更新的案子
|
log.info("xsdupdate:{}", caseInfoUpdateList.size());
|
for (CaseInfo caseInfo : caseInfoUpdateList) {
|
List<CaseInfoUnfold> caseInfoUnfoldList1 = caseClient.getCaseInfoUnfold(caseInfo.getId());
|
if (caseInfoUnfoldList1 != null && caseInfoUnfoldList1.size() > 0) {
|
CaseInfoUnfold caseInfoUnfold = caseInfoUnfoldList1.get(0);
|
caseInfoUnfoldMapper.updateById(caseInfoUnfold);
|
}
|
}
|
//更新案子
|
return lastCaseInfo.getStatus();
|
}
|
|
}
|
