|  |  |  | 
|---|
|  |  |  | import com.core.common.Cools; | 
|---|
|  |  |  | import com.core.common.DateUtils; | 
|---|
|  |  |  | import com.core.common.SpringUtils; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasCrnErrorLog; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasCrnOpt; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasCrnp; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasDevpErrorLog; | 
|---|
|  |  |  | import com.zy.asrs.service.BasCrnErrorLogService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasCrnOptService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasCrnpService; | 
|---|
|  |  |  | import com.zy.asrs.service.BasDevpErrorLogService; | 
|---|
|  |  |  | import com.zy.common.utils.News; | 
|---|
|  |  |  | import com.zy.core.CrnThread; | 
|---|
|  |  |  | import com.zy.core.cache.MessageQueue; | 
|---|
|  |  |  | 
|---|
|  |  |  | private void readStatus(){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | OperateResultExOne<byte[]> result = siemensNet.Read("DB101.0", (short) 56); | 
|---|
|  |  |  | OperateResultExOne<byte[]> resultErr = siemensNet.Read("DB64.0", (short) 7); | 
|---|
|  |  |  | if (result.IsSuccess) { | 
|---|
|  |  |  | if (null == crnProtocol) { | 
|---|
|  |  |  | crnProtocol = new CrnProtocol(); | 
|---|
|  |  |  | 
|---|
|  |  |  | crnProtocol.setxDuration(siemensNet.getByteTransform().TransSingle(result.Content, 48)); | 
|---|
|  |  |  | crnProtocol.setyDuration(siemensNet.getByteTransform().TransSingle(result.Content, 52)); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | boolean[] statusSign = siemensNet.getByteTransform().TransBool(resultErr.Content, 0, 7); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | crnProtocol.setIbDriveFault(statusSign[0]);       // 行走变频器故障 | 
|---|
|  |  |  | crnProtocol.setIbSupplyFault(statusSign[1]);      // 提供变频器故障 | 
|---|
|  |  |  | crnProtocol.setIbForkDriveFault(statusSign[2]);   // 货叉变频器故障 | 
|---|
|  |  |  | crnProtocol.setIbDriveCircuitFault(statusSign[3]); // 行走断路器故障 | 
|---|
|  |  |  | crnProtocol.setIbLiftCircuitFault(statusSign[4]); // 提升断路器故障 | 
|---|
|  |  |  | crnProtocol.setIbForkCircuitFault(statusSign[5]); // 货叉断路器故障 | 
|---|
|  |  |  | crnProtocol.setIbForwardLimit(statusSign[6]);     // 前进限位 | 
|---|
|  |  |  | crnProtocol.setIbReverseLimit(statusSign[7]);     // 后退限位 | 
|---|
|  |  |  | crnProtocol.setIbDriveStart(statusSign[8]);       // 行走原点 | 
|---|
|  |  |  | crnProtocol.setIbForwardBrakeSpeed(statusSign[9]); // 前进强制低速 | 
|---|
|  |  |  | crnProtocol.setIbReverseBrakeSpeed(statusSign[10]); // 后退强制低速 | 
|---|
|  |  |  | crnProtocol.setIbUpLimit(statusSign[11]);          // 上升限位 | 
|---|
|  |  |  | crnProtocol.setIbDownLimit(statusSign[12]);        // 下限限位 | 
|---|
|  |  |  | crnProtocol.setIbUpOrigin(statusSign[13]);         // 提升原点 | 
|---|
|  |  |  | crnProtocol.setIbUpBrakeSpeed(statusSign[14]);     // 上升强制低速 | 
|---|
|  |  |  | crnProtocol.setIbDownBrakeSpeed(statusSign[15]);   // 下降强制低速 | 
|---|
|  |  |  | crnProtocol.setIbPlatformSignal(statusSign[16]);   // 载货台探货 | 
|---|
|  |  |  | crnProtocol.setIbForkMidSignal(statusSign[17]);    // 货叉中位信号 | 
|---|
|  |  |  | crnProtocol.setIbForkLeftLimit(statusSign[18]);    // 货叉左极限 | 
|---|
|  |  |  | crnProtocol.setIbForkRightLimit(statusSign[19]);   // 货叉右极限 | 
|---|
|  |  |  | crnProtocol.setIbFrontOverLimit(statusSign[20]);   // 前超限 | 
|---|
|  |  |  | crnProtocol.setIbRearOverLimit(statusSign[21]);    // 后超限 | 
|---|
|  |  |  | crnProtocol.setIbLeftOverLimit(statusSign[22]);    // 左超限 | 
|---|
|  |  |  | crnProtocol.setIbRightOverLimit(statusSign[23]);   // 右超限 | 
|---|
|  |  |  | crnProtocol.setIbHighOverLimit1(statusSign[24]);   // 高超限1 | 
|---|
|  |  |  | crnProtocol.setIbHighOverLimit2(statusSign[25]);   // 高超限2 | 
|---|
|  |  |  | crnProtocol.setIbHighOverLimit3(statusSign[26]);   // 高超限3 | 
|---|
|  |  |  | crnProtocol.setIbOneExtendLeftLoad1(statusSign[27]); // 一伸左侧探货1 | 
|---|
|  |  |  | crnProtocol.setIbOneExtendLeftLoad2(statusSign[28]); // 一伸左侧探货2 | 
|---|
|  |  |  | crnProtocol.setIbOneExtendRightLoad1(statusSign[29]); // 一伸右侧探货1 | 
|---|
|  |  |  | crnProtocol.setIbOneExtendRightLoad2(statusSign[30]); // 一伸右侧探货2 | 
|---|
|  |  |  | crnProtocol.setIbTwoExtendLeftLoad1(statusSign[31]); // 二伸左侧探货1 | 
|---|
|  |  |  | crnProtocol.setIbTwoExtendLeftLoad2(statusSign[32]); // 二伸左侧探货2 | 
|---|
|  |  |  | crnProtocol.setIbTwoExtendRightLoad1(statusSign[33]); // 二伸右侧探货1 | 
|---|
|  |  |  | crnProtocol.setIbTwoExtendRightLoad2(statusSign[34]); // 二伸右侧探货2 | 
|---|
|  |  |  | crnProtocol.setIbSpeedSignal1(statusSign[35]);      // 超速信号1 | 
|---|
|  |  |  | crnProtocol.setIbSpeedSignal2(statusSign[36]);      // 超速信号2 | 
|---|
|  |  |  | crnProtocol.setIbOverweightSignal1(statusSign[37]); // 超重信号1 | 
|---|
|  |  |  | crnProtocol.setIbOverweightSignal2(statusSign[38]); // 超重信号2 | 
|---|
|  |  |  | crnProtocol.setIbRopeReleaseSignal1(statusSign[39]); // 松绳信号1 | 
|---|
|  |  |  | crnProtocol.setIbRopeReleaseSignal2(statusSign[40]); // 松绳信号2 | 
|---|
|  |  |  | crnProtocol.setIbSafetyClamp(statusSign[41]);       // 安全钳 | 
|---|
|  |  |  | crnProtocol.setIbTightener(statusSign[42]);         // 张紧器 | 
|---|
|  |  |  | crnProtocol.setIbSpeedLimiter(statusSign[43]);      // 限速器 | 
|---|
|  |  |  | crnProtocol.setIbSafetyDoorOpen(statusSign[44]);    // 安全门打开 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(crnProtocol.getStatus() == 99){ | 
|---|
|  |  |  | crnProtocol.setErrorMk(true);//若存在异常触发写入 | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | crnProtocol.setWriteMk(true);//无异常后才能继续写入 | 
|---|
|  |  |  | crnProtocol.setErrorMk(false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | OutputQueue.CRN.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 复位信号 | 
|---|
|  |  |  | 
|---|
|  |  |  | BasCrnp basCrnp = new BasCrnp(); | 
|---|
|  |  |  | basCrnp.setCrnNo(slave.getId()); | 
|---|
|  |  |  | basCrnp.setCrnSts((int)crnProtocol.getMode()); | 
|---|
|  |  |  | if(crnProtocol.isWriteMk() && crnProtocol.isErrorMk()){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | // 日志记录异常情况 | 
|---|
|  |  |  | BasCrnErrorLog basCrnErrorLogs; | 
|---|
|  |  |  | basCrnErrorLogs = crnProtocol.toSqlModelError(); | 
|---|
|  |  |  | BasCrnErrorLogService basCrnErrorLogService = SpringUtils.getBean(BasCrnErrorLogService.class); | 
|---|
|  |  |  | basCrnErrorLogService.insert(basCrnErrorLogs); | 
|---|
|  |  |  | crnProtocol.setWriteMk(false); | 
|---|
|  |  |  | } catch (Exception ignore) { | 
|---|
|  |  |  | log.error(ignore.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!basCrnpService.updateById(crnProtocol.toSqlModel(basCrnp))){ | 
|---|
|  |  |  | News.error("SiemensCrn"+" - 3"+" - 堆垛机plc数据库更新失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()); | 
|---|
|  |  |  | } | 
|---|