package com.yssh.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import com.yssh.dao.DictRecordMapper;
|
import com.yssh.dao.SuYuanMapper;
|
import com.yssh.dao.ThuAccuracyMapper;
|
import com.yssh.entity.DictRecord;
|
import com.yssh.entity.MonitorPointPosition;
|
import com.yssh.entity.SuYuanMonitorData;
|
import com.yssh.entity.ThuAccuracy;
|
import com.yssh.entity.vo.ForecastAnalyseVo;
|
import com.yssh.service.ICommonService;
|
import com.yssh.service.IForecastAnalyseService;
|
import com.yssh.utils.DateUtils;
|
import com.yssh.utils.StringUtils;
|
|
import javax.annotation.Resource;
|
|
@Service
|
public class ForecastAnalyseServiceImpl implements IForecastAnalyseService{
|
@Resource
|
private ICommonService commonService;
|
|
@Resource
|
private SuYuanMapper suYuanMapper;
|
|
@Resource
|
private DictRecordMapper dictRecordMapper;
|
|
@Resource
|
private ThuAccuracyMapper thuAccuracyMapper;
|
|
@Override
|
public List<ForecastAnalyseVo> getForecastAnalyse(String name, Date beginTime, Date endTime) {
|
List<ForecastAnalyseVo> result = new ArrayList<ForecastAnalyseVo>();
|
MonitorPointPosition checkPoint = commonService.select3dCheckPointByName(name);
|
if (StringUtils.isNull(checkPoint)) {
|
return null;
|
}
|
List<DictRecord> dictRecordList = dictRecordMapper.selectByTimeDictRecordList(Long.parseLong(DateUtils.parseDateToStr(DateUtils.YYYYMMDDHH, beginTime)), Long.parseLong(DateUtils.parseDateToStr(DateUtils.YYYYMMDDHH, endTime)));
|
List<String> tableNames = new ArrayList<String>();
|
dictRecordList.forEach(r -> {tableNames.add(r.getTableName());});
|
if (StringUtils.isNotEmpty(tableNames)) {
|
List<SuYuanMonitorData> monitorDatas = suYuanMapper.getMonitorData(tableNames, checkPoint.getId());
|
monitorDatas.forEach(m -> {
|
result.add(new ForecastAnalyseVo(0.0, m.getValue(), new Long(m.getTime())));
|
});
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("name", name);
|
param.put("beginTime", beginTime);
|
param.put("endTime", endTime);
|
List<ThuAccuracy> data = thuAccuracyMapper.getForecastData(param);
|
data.forEach(s -> {
|
result.forEach(r -> {
|
if(Long.valueOf(s.getTime()).longValue() == r.getTime().longValue()){
|
r.setForecastValue(Double.valueOf(s.getValue()));
|
}
|
});
|
});
|
}
|
return result;
|
}
|
}
|
