package com.ld.igds.three.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.common.CoreThreeService;
|
import com.ld.igds.constant.DepotType;
|
import com.ld.igds.grain.dto.GrainData;
|
import com.ld.igds.grain.service.CoreGrainService;
|
import com.ld.igds.models.ThreeConf;
|
import com.ld.igds.three.ThreeCodeEnum;
|
import com.ld.igds.three.ThreeConstant;
|
import com.ld.igds.three.data.Data2001;
|
import com.ld.igds.three.data.ThreeResponse;
|
import com.ld.igds.three.mapper.ThreeMapper;
|
import com.ld.igds.three.param.ThreeCommonParam;
|
import com.ld.igds.three.param.ThreeRequest;
|
import com.ld.igds.three.service.ThreeService;
|
import com.ld.igds.three.util.ThreeRespUtil;
|
import com.ld.igds.three.util.ThreeUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 2001-仓库粮情接口实现
|
*
|
* @author chen
|
*/
|
@Service
|
public class ThreeServiceImpl2001 implements ThreeService {
|
|
@Autowired
|
private CoreThreeService commonService;
|
@Autowired
|
private ThreeMapper threeMapper;
|
@Autowired
|
private CoreGrainService grainService;
|
@Autowired
|
private ThreeUtil threeUtil;
|
|
@Override
|
public String getInterfaceId() {
|
return ThreeConstant.API_THREE_2001;
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public ThreeResponse<Object> execute(ThreeRequest<JSONObject> req){
|
//转化请求参数
|
ThreeCommonParam param = JSONObject.parseObject(req.getData().toString(), ThreeCommonParam.class);
|
|
//判断uid
|
if(StringUtils.isEmpty(param.getUid())){
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1005, req);
|
}
|
|
List<Data2001> list = new ArrayList<>();
|
Data2001 data2001;
|
//缓存获取粮情信息
|
Map<String, GrainData> grainMap = grainService.getCacheGrainDateMap(req.getCompanyId(), req.getDeptId());
|
if(grainMap == null){
|
//从数据库获取
|
grainMap = getGrainAll(req.getCompanyId());
|
}
|
|
if(grainMap.isEmpty()){
|
return ThreeRespUtil.success(list, req);
|
}
|
|
//根据uid判断查询所有仓库粮情还是单个仓库粮情
|
if(ThreeConstant.REQUEST_UID.equals(param.getUid())){
|
//获取全部三维配置信息
|
List<ThreeConf> threeList = commonService.getCacheThreeAll(req.getCompanyId());
|
if(threeList == null || threeList.isEmpty()){
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询相关三维配置信息，请联系管理员！", req);
|
}
|
|
//返回数据处理
|
for (ThreeConf threeConf : threeList) {
|
if(StringUtils.isEmpty(threeConf.getDeviceId()) &&
|
StringUtils.isNotEmpty(threeConf.getDepotId())){
|
GrainData grainData = grainMap.get(threeConf.getDepotId());
|
if(grainData != null){
|
data2001 = getData(grainData, threeConf.getUid());
|
list.add(data2001);
|
}
|
}
|
}
|
}else {
|
//根据uid获取三维配置信息
|
ThreeConf threeConf = commonService.getCacheThreeConfById(req.getCompanyId(), param.getUid());
|
if(threeConf == null){
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询到此uid的配置信息，请联系管理员！", req);
|
}
|
|
GrainData grainData = grainMap.get(threeConf.getDepotId());
|
if(grainData != null){
|
data2001 = getData(grainData, threeConf.getUid());
|
list.add(data2001);
|
}
|
|
}
|
return ThreeRespUtil.success(list, req);
|
}
|
|
/**
|
* 数据封装
|
* @param grainData
|
* @param uid
|
* @return
|
*/
|
private Data2001 getData(GrainData grainData, String uid){
|
Data2001 data = new Data2001();
|
|
data.setUid(uid);
|
data.setType(threeUtil.getDepotType(grainData.getCompanyId(), grainData.getDepotId()));
|
data.setTime(grainData.getReceiveDate());
|
data.setOutT(grainData.getTempOut());
|
data.setOutH(grainData.getHumidityOut());
|
data.setInT(grainData.getTempIn());
|
data.setInH(grainData.getHumidityIn());
|
data.setMaxT(grainData.getTempMax());
|
data.setMinT(grainData.getTempMin());
|
data.setAveT(grainData.getTempAve());
|
if(DepotType.TYPE_03.getCode().equals(data.getType()) && StringUtils.isNotEmpty(grainData.getOilHeight())){
|
data.setOilHeight(grainData.getOilHeight().split("-")[0]);
|
data.setDepotHeight(grainData.getOilHeight().split("-")[1]);
|
}
|
data.setCheckUser(grainData.getCheckUser());
|
|
return data;
|
}
|
|
/**
|
* 从数据库查询粮情，并转为map集合
|
* @param companyId
|
* @return
|
*/
|
private Map<String, GrainData> getGrainAll(String companyId){
|
|
List<GrainData> grainAll = threeMapper.getGrainAll(companyId);
|
|
Map<String, GrainData> map = new HashMap<>();
|
|
if(grainAll != null && grainAll.size() > 0){
|
for (GrainData grainData : grainAll) {
|
map.put(grainData.getDepotId(),grainData);
|
}
|
}
|
return map;
|
}
|
|
}
|
