| | |
| | | import com.ld.igds.constant.BizType; |
| | | import com.ld.igds.constant.Constant; |
| | | import com.ld.igds.constant.DepotType; |
| | | import com.ld.igds.constant.RedisConst; |
| | | import com.ld.igds.grain.GrainUtil; |
| | | import com.ld.igds.grain.dto.GrainData; |
| | | import com.ld.igds.grain.dto.GrainItemInfo; |
| | | import com.ld.igds.io.notify.NotifyGrainInvoker; |
| | | import com.ld.igds.models.*; |
| | |
| | | import com.ld.igds.protocol.bhzn.grainv1.server.BhznGrainV1ServerUtils; |
| | | import com.ld.igds.util.BytesUtil; |
| | | import com.ld.igds.util.ContextUtil; |
| | | import com.ld.igds.util.RedisUtil; |
| | | import com.ld.igds.warn.WarnUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | public static final String BEAN_ID = "bhznGrainv1.analysisService"; |
| | | |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | | @Autowired |
| | | private CoreSerService coreSerService; |
| | | @Autowired |
| | |
| | | if (null != thDto) { |
| | | log.debug("-------THDto--={}", thDto.toString()); |
| | | } |
| | | |
| | | |
| | | //清空 |
| | | String key = "GRAIN_" + message.getAddr(); |
| | | contextMapGrain.put(key, null); |
| | | // 将集合解析成坐标数据 |
| | | addPoint1(temps, depotConf, ser, exeRequest, thDto, sysConf, batchId); |
| | | |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | Grain grain = new Grain(); |
| | | grain.setDepotId(depotConf.getDepotId()); |
| | | grain.setCompanyId(depotConf.getCompanyId()); |
| | |
| | | grain.setTempIn(Constant.ERROR_TEMP); |
| | | grain.setHumidityIn(Constant.ERROR_TEMP); |
| | | |
| | | //如果是油罐仓 |
| | | if(DepotType.TYPE_03.getCode().equals(depot.getDepotType())){ |
| | | GrainData tempData = (GrainData) redisUtil.get(RedisConst.buildKey(ser.getCompanyId(),RedisConst.KEY_DEPOT_HEIGHT,depot.getId())); |
| | | if(null != tempData){ |
| | | //TODO |
| | | } |
| | | } |
| | | |
| | | if (null != thDto) { |
| | | log.debug("粮情解析中获取到的温湿度信息={}", thDto.toString()); |
| | | grain.setHumidityIn(thDto.getHumidityIn()); |