package com.ld.igds.three.service.impl; import com.alibaba.fastjson.JSONObject; import com.ld.igds.common.CoreThreeService; import com.ld.igds.gas.dto.GasData; import com.ld.igds.models.ThreeConf; import com.ld.igds.three.ThreeCodeEnum; import com.ld.igds.three.ThreeConstant; import com.ld.igds.three.data.Data2003; 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 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; /** * 2003-气体信息接口实现 * * @author chen */ @Service public class ThreeServiceImpl2003 implements ThreeService { @Autowired private CoreThreeService commonService; @Autowired private ThreeMapper threeMapper; @Override public String getInterfaceId() { return ThreeConstant.API_THREE_2003; } @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); } //返回数据定义 List list = new ArrayList<>(); Data2003 data2003; //获取所有仓库气体信息(每个仓库取最新的一条) Map gasMap = getGasAll(req.getCompanyId()); if(gasMap.isEmpty()){ return ThreeRespUtil.success(list, req); } //根据uid判断查询所有仓库气体还是单个仓库气体 if(ThreeConstant.REQUEST_UID.equals(param.getUid())){ //获取全部三维配置信息 List 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())){ GasData gasData = gasMap.get(threeConf.getDepotId()); if(gasData != null){ data2003 = getData(gasData, threeConf.getUid()); list.add(data2003); } } } }else { //根据uid获取三维配置信息 ThreeConf threeConf = commonService.getCacheThreeConfById(req.getCompanyId(), param.getUid()); if(threeConf == null){ return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询到此uid的配置信息,请联系管理员!", req); } GasData gasData = gasMap.get(threeConf.getDepotId()); if(gasData != null){ data2003 = getData(gasData, threeConf.getUid()); list.add(data2003); } } return ThreeRespUtil.success(list, req); } /** * 数据封装 * @param gasData * @param uid * @return */ private Data2003 getData(GasData gasData, String uid){ Data2003 data = new Data2003(); data.setUid(uid); data.setTime(gasData.getReceiveDate()); data.setCo2(gasData.getPerCo2()); data.setO2(gasData.getPerO2()); data.setPh3(gasData.getPerPh3()); data.setN2(gasData.getPerN2()); data.setMaxCo2(gasData.getPerCo2Max()); data.setMinCo2(gasData.getPerCo2Min()); data.setMaxO2(gasData.getPerO2Max()); data.setMinO2(gasData.getPerO2Min()); data.setMaxPh3(gasData.getPerPh3Max()); data.setMinPh3(gasData.getPerPh3Min()); data.setMaxN2(gasData.getPerN2Max()); data.setMinN2(gasData.getPerN2Min()); return data; } /** * 从数据库查询气体,并转为map集合 * @param companyId * @return */ private Map getGasAll(String companyId){ List grainAll = threeMapper.getGasAll(companyId); Map map = new HashMap<>(); if(grainAll != null && grainAll.size() > 0){ for (GasData gasData : grainAll) { map.put(gasData.getDepotId(),gasData); } } return map; } }