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.dto.GrainParam; import com.ld.igds.grain.dto.GrainPoint; 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.Data2002; import com.ld.igds.three.data.DataPoint; import com.ld.igds.three.data.ThreeResponse; 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.List; /** * 2002-粮情点位信息接口实现 * * @author chen */ @Service public class ThreeServiceImpl2002 implements ThreeService { @Autowired private CoreThreeService commonService; @Autowired private CoreGrainService grainService; @Autowired private ThreeUtil threeUtil; @Override public String getInterfaceId() { return ThreeConstant.API_THREE_2002; } @SuppressWarnings("unchecked") @Override public ThreeResponse execute(ThreeRequest req){ //转化请求参数 ThreeCommonParam param = JSONObject.parseObject(req.getData().toString(), ThreeCommonParam.class); //判断uid if(StringUtils.isEmpty(param.getUid())){ return ThreeRespUtil.error(ThreeCodeEnum.CODE_1005, req); } //根据uid获取三维信息 ThreeConf threeConf = commonService.getCacheThreeConfById(req.getCompanyId(), param.getUid()); if(threeConf == null){ return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询到此uid的配置信息,请联系管理员!", req); } //返回数据定义 List list = new ArrayList<>(); Data2002 data2002 = new Data2002(); //设置参数查询粮情 GrainParam grainParam = new GrainParam(); grainParam.setDepotId(threeConf.getDepotId()); grainParam.setCompanyId(threeConf.getCompanyId()); grainParam.setLimit(1); List grainList = grainService.listGrainData(grainParam); if (null == grainList || grainList.isEmpty()) { return ThreeRespUtil.success(list, req); } GrainData grainData = grainList.get(0); //设置基本粮情信息 data2002.setUid(threeConf.getUid()); data2002.setType(threeUtil.getDepotType(grainData.getCompanyId(), grainData.getDepotId())); data2002.setCable(grainData.getCable()); data2002.setCableCir(grainData.getCableCir()); data2002.setCableStart(""); data2002.setTime(grainData.getReceiveDate()); data2002.setOutT(grainData.getTempOut()); data2002.setOutH(grainData.getHumidityOut()); data2002.setInT(grainData.getTempIn()); data2002.setInH(grainData.getHumidityIn()); data2002.setMaxT(grainData.getTempMax()); data2002.setMinT(grainData.getTempMin()); data2002.setAveT(grainData.getTempAve()); data2002.setCheckUser(grainData.getCheckUser()); if(DepotType.TYPE_03.getCode().equals(data2002.getType()) && StringUtils.isNotEmpty(grainData.getOilHeight())){ data2002.setOilHeight(grainData.getOilHeight().split("-")[0]); data2002.setDepotHeight(grainData.getOilHeight().split("-")[1]); } //设置点位信息 List pointList = new ArrayList<>(); DataPoint dataPoint; for (GrainPoint point : grainData.getListPoints()) { dataPoint = new DataPoint(); dataPoint.setTemp(point.getTemp()); dataPoint.setX(point.getX()); dataPoint.setY(point.getY()); dataPoint.setZ(point.getZ()); pointList.add(dataPoint); } data2002.setPoints(pointList); list.add(data2002); return ThreeRespUtil.success(list, req); } }