|  |  |  | 
|---|
|  |  |  | import com.core.common.DateUtils; | 
|---|
|  |  |  | import com.core.common.SpringUtils; | 
|---|
|  |  |  | import com.core.exception.CoolException; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasDevp; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasRgv; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasRgvMap; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasRgvOpt; | 
|---|
|  |  |  | import com.zy.asrs.service.BasDevpService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasRgvMapService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasRgvOptService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasRgvService; | 
|---|
|  |  |  | import com.zy.asrs.entity.*; | 
|---|
|  |  |  | import com.zy.asrs.service.*; | 
|---|
|  |  |  | import com.zy.common.utils.News; | 
|---|
|  |  |  | import com.zy.core.RgvThread2; | 
|---|
|  |  |  | import com.zy.core.ThreadHandler; | 
|---|
|  |  |  | 
|---|
|  |  |  | private void readStatus(){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | OperateResultExOne<byte[]> result = siemensNet.Read("DB101.0", (short) 38); | 
|---|
|  |  |  | OperateResultExOne<byte[]> result = siemensNet.Read("DB101.0", (short) 42); | 
|---|
|  |  |  | if (result.IsSuccess) { | 
|---|
|  |  |  | if (null == rgvProtocol) { | 
|---|
|  |  |  | rgvProtocol = new RgvProtocol(); | 
|---|
|  |  |  | 
|---|
|  |  |  | rgvProtocol.setErr10(status3[1]); | 
|---|
|  |  |  | rgvProtocol.setErr11(status3[2]); | 
|---|
|  |  |  | rgvProtocol.setErr12(status3[3]); | 
|---|
|  |  |  | boolean[] statusErr = siemensNet.getByteTransform().TransBool(result.Content, 36, 6); | 
|---|
|  |  |  | rgvProtocol.setEmergencyStop(statusErr[0]);       // 急停触发 | 
|---|
|  |  |  | rgvProtocol.setSlot1EmptyNoData(statusErr[1]);   // 1号位有物无资料 | 
|---|
|  |  |  | rgvProtocol.setSlot2EmptyNoData(statusErr[2]);   // 2号位有物无资料 | 
|---|
|  |  |  | rgvProtocol.setCommandErrorChainConflict(statusErr[3]); // 命令错误走链条冲突 | 
|---|
|  |  |  | rgvProtocol.setTargetPositionIssue(statusErr[4]); // 目标位下发错误 | 
|---|
|  |  |  | rgvProtocol.setTravelInverterError(statusErr[5]); // 走行变频器异常 | 
|---|
|  |  |  | rgvProtocol.setPhotoelectric1Error(statusErr[6]); // 1号光电异常 | 
|---|
|  |  |  | rgvProtocol.setPhotoelectric2Error(statusErr[7]); // 2号光电异常 | 
|---|
|  |  |  | rgvProtocol.setTimeoutConnectionWithLine(statusErr[8]); // 与输线时接超时 | 
|---|
|  |  |  | rgvProtocol.setLeftRollerTimeout(statusErr[9]);    // 左侧滚筒运行超时 | 
|---|
|  |  |  | rgvProtocol.setRightRollerTimeout(statusErr[10]);   // 右侧滚筒运行超时 | 
|---|
|  |  |  | rgvProtocol.setRgvRunTimeout(statusErr[11]);        // rgv运行超时 | 
|---|
|  |  |  | rgvProtocol.setPosition1ChainInverterError(statusErr[12]); // 1号工位链条变频器异常 | 
|---|
|  |  |  | rgvProtocol.setPosition2ChainInverterError(statusErr[13]); // 2号工位链条变频器异常 | 
|---|
|  |  |  | rgvProtocol.setFrontRearLimit(statusErr[14]);      // 前后极限位 | 
|---|
|  |  |  | rgvProtocol.setEmergencyButton(statusErr[15]);     // 急停按钮 | 
|---|
|  |  |  | rgvProtocol.setForwardButton(statusErr[16]);       // 前进按钮 | 
|---|
|  |  |  | rgvProtocol.setReverseButton(statusErr[17]);       // 后退按钮 | 
|---|
|  |  |  | rgvProtocol.setLocalRemote(statusErr[18]);         // 本地/远程 | 
|---|
|  |  |  | rgvProtocol.setReset(statusErr[19]);               // 复位 | 
|---|
|  |  |  | rgvProtocol.setTravelBrakeSwitch(statusErr[20]);   // 走行抱闸开关钮 | 
|---|
|  |  |  | rgvProtocol.setTravelSpeedLimitPhotoelectric(statusErr[21]); // 走行强制减速光电 | 
|---|
|  |  |  | rgvProtocol.setLeftOverlimit1(statusErr[22]);      // 左超限 1 | 
|---|
|  |  |  | rgvProtocol.setRightOverlimit1(statusErr[23]);     // 右超限 1 | 
|---|
|  |  |  | rgvProtocol.setLeftAtPosition1(statusErr[24]);     // 左到位 1 | 
|---|
|  |  |  | rgvProtocol.setRightAtPosition1(statusErr[25]);    // 右到位 1 | 
|---|
|  |  |  | rgvProtocol.setChainForward1(statusErr[26]);       // 链条前进 1 | 
|---|
|  |  |  | rgvProtocol.setChainReverse1(statusErr[27]);       // 链条后退 1 | 
|---|
|  |  |  | rgvProtocol.setInverterAlarm(statusErr[28]);       // 变频器报警 | 
|---|
|  |  |  | rgvProtocol.setLeftOverlimit2(statusErr[29]);      // 左超限 2 | 
|---|
|  |  |  | rgvProtocol.setRightOverlimit2(statusErr[30]);     // 右超限 2 | 
|---|
|  |  |  | rgvProtocol.setLeftAtPosition2(statusErr[31]);     // 左到位 2 | 
|---|
|  |  |  | rgvProtocol.setRightAtPosition2(statusErr[32]);    // 右到位 2 | 
|---|
|  |  |  | rgvProtocol.setCargoSpeedReduction(statusErr[33]); // 货物减速 | 
|---|
|  |  |  | rgvProtocol.setConveyorInverterAlarm2(statusErr[34]); // 输送变频器报警 2 | 
|---|
|  |  |  | rgvProtocol.setRightConveyor2(statusErr[35]);      // 右输送 2 | 
|---|
|  |  |  | rgvProtocol.setLeftConveyor2(statusErr[36]);       // 左输送 2 | 
|---|
|  |  |  | if(rgvProtocol.getStatus() == 99){ | 
|---|
|  |  |  | rgvProtocol.setErrorMk(true);//若存在异常触发写入 | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | rgvProtocol.setWriteMk(true);//无异常后才能继续写入 | 
|---|
|  |  |  | rgvProtocol.setErrorMk(false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //                BasRgvMapService basRgvMapService = SpringUtils.getBean(BasRgvMapService.class); | 
|---|
|  |  |  | OutputQueue.RGV.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功", DateUtils.convert(new Date()), slave.getId())); | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | 
|---|
|  |  |  | BasRgv basRgv = new BasRgv(); | 
|---|
|  |  |  | basRgv.setRgvNo(slave.getId()); | 
|---|
|  |  |  | basRgv.setRgvSts((int)rgvProtocol.getMode()); | 
|---|
|  |  |  | if(rgvProtocol.isWriteMk() && rgvProtocol.isErrorMk()){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | // 日志记录异常情况 | 
|---|
|  |  |  | BasRgvErrorLog basRgvErrorLogs; | 
|---|
|  |  |  | basRgvErrorLogs = rgvProtocol.toSqlModelError(); | 
|---|
|  |  |  | BasRgvErrorLogService basRgvErrorLogService = SpringUtils.getBean(BasRgvErrorLogService.class); | 
|---|
|  |  |  | basRgvErrorLogService.insert(basRgvErrorLogs); | 
|---|
|  |  |  | rgvProtocol.setWriteMk(false); | 
|---|
|  |  |  | } catch (Exception ignore) { | 
|---|
|  |  |  | log.error(ignore.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!basRgvService.updateById(rgvProtocol.toSqlModel(basRgv))){ | 
|---|
|  |  |  | log.error("RGV plc数据库更新失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()); | 
|---|
|  |  |  | } | 
|---|