package com.ld.igds.protocol.zldz.analysis; import com.ld.igds.common.CoreCommonService; import com.ld.igds.common.dto.THDto; import com.ld.igds.constant.BizType; import com.ld.igds.constant.Constant; import com.ld.igds.constant.DepotType; import com.ld.igds.grain.GrainUtil; import com.ld.igds.grain.dto.GrainItemInfo; import com.ld.igds.io.notify.NotifyGrainInvoker; import com.ld.igds.io.constant.OrderRespEnum; import com.ld.igds.io.request.BaseRequest; import com.ld.igds.models.DepotConf; import com.ld.igds.models.DeviceSer; import com.ld.igds.models.DicSysConf; import com.ld.igds.models.Grain; import com.ld.igds.order.ExeOrderService; import com.ld.igds.order.data.ExeRequest; import com.ld.igds.protocol.zldz.analysis.message.ReMessage; import com.ld.igds.protocol.zldz.command.RemoteGrainServiceImpl; import com.ld.igds.protocol.zldz.task.CommandReSendService; import com.ld.igds.protocol.zldz.util.ServerUtils; import com.ld.igds.th.CoreThService; import com.ld.igds.util.BytesUtil; import com.ld.igds.util.ContextUtil; import com.ld.igds.warn.WarnUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 粮情解析 * * @author Andy */ @Slf4j @Component(AnalysisGrain.BEAN_ID) public class AnalysisGrain { public static final String BEAN_ID = "zldz.analysisGrain"; @Autowired private CoreCommonService commonService; @Autowired private CoreThService thService; @Autowired private ExeOrderService exeOrderService; @Autowired private GrainUtil grainUtil; @Autowired private NotifyGrainInvoker notifyGrainInvoker; @Autowired private RemoteGrainServiceImpl remoteGrainService; @Autowired private CommandReSendService commandReSendService; @Autowired private WarnUtils warnUtils; public static Map> contextMap = new HashMap<>(); public static double ERROR_CHECK_TAG = -100.0; public static double FAULT_CHECK_TAG = 85.0; public static double ERROR_CHECK_TAG2 = 50; public static double MAX_TEMP = -50.0; public static double MIN_TEMP = 50.0; /** * 后台发送请求后，终端的响应 * * @param reMessage * @param ser */ public void analysis8815(ReMessage reMessage, DeviceSer ser) { BaseRequest request = new BaseRequest(); request.setSerId(ser.getId()); request.setCompanyId(ser.getCompanyId()); request.setIp(reMessage.getIp()); request.setPort(reMessage.getPort()); request.setSerName(ser.getName()); remoteGrainService.reply8815(request); } /** * 接收到粮情的回复 * * @param reMessage * @param ser */ public void reply8817(ReMessage reMessage, DeviceSer ser) { String bodyMsg = reMessage.getBody().getContent(); log.info("分机------>>>平台：收到的粮情信息-{}-{}-{}", ser.getCompanyId(), ser.getName(), reMessage.getStrMsg()); // Step1根据需要简化需要的信息 String ua = bodyMsg.substring(0 * 2, 1 * 2); log.debug("获取到的电压信息，系统不保留={}", ua); // 总包数 // int sumPacket = BytesUtil.hexToInt(bodyMsg.substring(1 * 2, 1 * 2 + 1 // * 2)); // 当前包 String hexCurPacket = bodyMsg.substring(2 * 2, 2 * 2 + 1 * 2); // int curPacket = BytesUtil.hexToInt(hexCurPacket); BaseRequest request = new BaseRequest(); request.setSerId(ser.getId()); request.setCompanyId(ser.getCompanyId()); request.setIp(reMessage.getIp()); request.setPort(reMessage.getPort()); request.setSerName(ser.getName()); remoteGrainService.reply8817(request, hexCurPacket); } @Transactional public void analysis8817(ReMessage msg, DeviceSer ser) { // 接到信息回复--主机 reply8817(msg, ser); // 首先获取到系统参数，判断是否需要批次自动优化 DicSysConf sysConf = commonService.getCacheSysConf(ser.getCompanyId()); List list = exeOrderService.getInProgressOrderBySerId(BizType.GRAIN.getCode(), ser.getId()); if (null == list || list.isEmpty()) { String info = "粮情解析失败:分机=" + ser.getName() + "没有获取到所属仓库信息。"; log.error("分机------>>>平台：" + info); notifyGrainInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.GRAIN, info); return; } ExeRequest exeRequest = list.get(0); log.info("获取粮情命令信息={}", exeRequest); DepotConf depotConf = commonService.getCacheDepotConf( exeRequest.getCompanyId(), exeRequest.getDepotId()); if (null == depotConf) { String info = "粮情解析失败:分机=" + ser.getName() + "没有获取到粮情参数配置信息。"; log.error("分机------>>>平台：" + info); notifyGrainInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.GRAIN, info); return; } analysisStep(depotConf, msg, ser, exeRequest, sysConf); } /** * 开始解析 * * @param ser * @param msg * @throws Exception */ private void analysisStep(DepotConf depotConf, ReMessage msg, DeviceSer ser, ExeRequest exeRequest, DicSysConf sysConf) { // 粮情的批次号重新根据频率调整 msg.setBatchId(ContextUtil.getBatchIdByFireq(depotConf.getGrainFreq())); String bodyMsg = msg.getBody().getContent(); log.debug("{}-{}=收到的粮情信息={}", ser.getCompanyId(), ser.getName(), msg.getStrMsg()); // Step1根据需要简化需要的信息 String ua = bodyMsg.substring(0 * 2, 1 * 2); log.debug("获取到的电压信息，系统不保留={}", ua); // 总包数 int sumPacket = BytesUtil.hexToInt(bodyMsg.substring(1 * 2, 1 * 2 + 1 * 2)); // 当前包 String hexCurPacket = bodyMsg.substring(2 * 2, 2 * 2 + 1 * 2); int curPacket = BytesUtil.hexToInt(hexCurPacket); log.debug("分机={},包总数={},当前包={}", ser.getName(), sumPacket, curPacket); // 粮食温度信息 String grainStr = bodyMsg.substring(3 * 2); String contextKey = this.buildContextKey(msg, depotConf.getDepotId()); String curKey = this.buildCurKey(msg, curPacket); Map curMap = contextMap.get(contextKey); if (null == curMap) { curMap = new HashMap<>(); contextMap.put(contextKey, curMap); } contextMap.get(contextKey).put(curKey, grainStr); // 数据准备好，开始执行解析 if (curPacket == sumPacket) { analysisStep0(depotConf, msg, ser, exeRequest, contextKey, sumPacket, sysConf); log.info("分机------>>>平台：命令类型=8817--粮情全部收到，开始解析-{}-{}", ser.getCompanyId(), ser.getName()); // 清除命令 commandReSendService.cleanKey(msg.getCompanyId(), msg.getIp(), msg.getPort(), ServerUtils.MSG_TYPE_8817); } } private void analysisStep0(DepotConf depotConf, ReMessage msg, DeviceSer ser, ExeRequest exeRequest, String contextKey, int sumPacket, DicSysConf sysConf) { Map curMap = contextMap.get(contextKey); List depotConfs = null; // 一分机多仓，把起始列放到最大进行采集 if (Constant.YN_Y.equals(sysConf.getGrainMoreTag())) { depotConfs = commonService.getCacheDepotConfBySerId2( depotConf.getCompanyId(), ser.getId()); } if (null == depotConfs) {// 一个分机1个仓 if (DepotType.TYPE_02.getCode().equals(depotConf.getDepotType())) { analysisStep2(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else if (DepotType.TYPE_04.getCode().equals(depotConf.getDepotType())) { analysisStep2(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else { analysisStep1(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } return; } // 一分几多仓情况，考虑单仓采集和多仓采集 // 单仓采集时候数据从0返回 if (StringUtils.isEmpty(exeRequest.getDepotIds())) { depotConf.setCableEnd(depotConf.getCableEnd() - depotConf.getCableStart() + 1); depotConf.setCableStart(ser.getCableStart()); if (DepotType.TYPE_02.getCode().equals(depotConf.getDepotType())) { analysisStep2(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else if (DepotType.TYPE_04.getCode().equals(depotConf.getDepotType())) { analysisStep2(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else { analysisStep1(depotConf, msg, ser, exeRequest, curMap, sumPacket, sysConf); } return; } // 批量采集所有关联一起采集，遍历执行 for (DepotConf depotConfTemp : depotConfs) { if (DepotType.TYPE_02.getCode().equals(depotConfTemp.getDepotType())) { analysisStep2(depotConfTemp, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else if (DepotType.TYPE_04.getCode().equals(depotConfTemp.getDepotType())) { analysisStep2(depotConfTemp, msg, ser, exeRequest, curMap, sumPacket, sysConf); } else { analysisStep1(depotConfTemp, msg, ser, exeRequest, curMap, sumPacket, sysConf); } } } /** * 圆筒仓的粮情解析 * * @param depotConf * @param msg * @param ser * @param exeRequest * @param packetMap * @param sumPackets */ private void analysisStep2(DepotConf depotConf, ReMessage msg, DeviceSer ser, ExeRequest exeRequest, Map packetMap, int sumPackets, DicSysConf sysConf) { if (StringUtils.isEmpty(depotConf.getCableRule()) || StringUtils.isEmpty(depotConf.getCableCir())) { log.error("分机------>>>平台：当前仓库：{}-{}，没有没有配置布线规则，无法解析粮情信息……", ser.getCompanyId(), depotConf.getDepotName()); return; } String[] cableRuleAtt = depotConf.getCableRule().split("-"); String[] cableCirAtt = depotConf.getCableCir().split("-"); if (cableRuleAtt.length != cableCirAtt.length) { log.error("分机------>>>平台：当前仓库：{}-{}，布线规则不正确，无法解析粮情信息……", ser.getCompanyId(), depotConf.getDepotName()); return; } //避免空指针 if (null == depotConf.getCableCone()) depotConf.setCableCone(Constant.CABLE_CONE_0); // 获取最大的层配置--默认每一圈都一样 int layMax = Integer.valueOf(cableCirAtt[0]); for (int i = 0; i < cableCirAtt.length; i++) { if (Integer.valueOf(cableCirAtt[i]) >= layMax) layMax = Integer.valueOf(cableCirAtt[i]); } // 获取完整的粮情包信息 String strPoints = ""; for (int i = 1; i <= sumPackets; i++) { strPoints += packetMap.get(buildCurKey(msg, i)); } log.info("------筒仓完整的粮情报文={}------", strPoints); int sumNum = 0, cableZ = 1;// sumNum 共多少根电缆；cableZ 层的最大值，锥形仓补齐最大层 for (int i = 0; i < cableCirAtt.length; i++) { if (Integer.valueOf(cableCirAtt[i]) > cableZ) { cableZ = Integer.valueOf(cableCirAtt[i]); } sumNum += Integer.valueOf(cableRuleAtt[i]); } // 根据层行列获取指定长度 int start = 4 * (depotConf.getCableStart() - ser.getCableStart()) * cableZ; int len = 4 * cableZ * sumNum; strPoints = strPoints.substring(start, start + len); log.info("分机------>>>平台：返回粮情完整信息，所属组织={}，分机={}", ser.getCompanyId(), ser.getName()); // 将粮情解析成数组 List temps = new ArrayList<>(); double tempValue; String temp; int curLay = 1;//所在层从1开始 int curRoot = 1;//所在根 int curCir = 1;//所在圈 int cirLay = 1;//当前圈的层 for (int i = 0; i < strPoints.length() / 4; i++) { temp = strPoints.substring(i * 4, i * 4 + 4); if (temp == null) { temp = "0000"; } tempValue = BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) / 10.0; //非正常值 if (tempValue > ERROR_CHECK_TAG2) { tempValue = Constant.ERROR_TEMP; } // 故障值处理 if (tempValue >= FAULT_CHECK_TAG) { tempValue = Constant.FAULT_TEMP; } // 备用值 if (tempValue == ERROR_CHECK_TAG) { tempValue = Constant.ERROR_TEMP; //验证是不是锥形仓补偿值 curLay = (i % layMax) + 1; curRoot = (i / layMax) + 1; curCir = getCurCir(curRoot, cableRuleAtt); cirLay = Integer.valueOf(cableCirAtt[curCir - 1]); //比如配置了5层但是当前是6层，说明当前点为补偿点 if (curLay > cirLay) { tempValue = Constant.ADD_TEMP; //判断是不是上锥形，将补点转移到上方 if (Constant.CABLE_CONE_1.equals(depotConf.getCableCone())) { int index = i - curLay - 1; temps.add(index, tempValue); }else { temps.add(tempValue); } } else { temps.add(tempValue); } } else { temps.add(tempValue); } } log.debug("-------CheckGrainRequest--={}", exeRequest.toString()); THDto thDto = thService.getCacheTH(exeRequest.getCompanyId(), exeRequest.getTempSerId(), exeRequest.getThConf()); if (null != thDto) { log.debug("-------THDto--={}", thDto.toString()); } // 将集合解析成坐标数据 addPoint2(temps, msg, depotConf, exeRequest, thDto, sysConf); } /** * 获取当前跟所在圈 * * @param curRoot * @param cableRuleAtt * @return */ private int getCurCir(int curRoot, String[] cableRuleAtt) { int sum = 0; for (int i = 0; i < cableRuleAtt.length; i++) { sum += Integer.valueOf(cableRuleAtt[i]); if (curRoot <= sum) return i + 1; } return 1; } /** * 平方仓的解析，解析需要考虑当前是否启用的一分机多仓 * * @param depotConf * @param msg * @param ser * @param exeRequest * @param packetMap * @param sumPackets */ private void analysisStep1(DepotConf depotConf, ReMessage msg, DeviceSer ser, ExeRequest exeRequest, Map packetMap, int sumPackets, DicSysConf sysConf) { // 获取完整的粮情包信息 String strPoints = ""; for (int i = 1; i <= sumPackets; i++) { strPoints += packetMap.get(buildCurKey(msg, i)); } String[] attCable = depotConf.getCableRule().split("-"); int cableZ = Integer.valueOf(attCable[0]); int cableY = Integer.valueOf(attCable[1]); int cableX = Integer.valueOf(attCable[2]); // 根据层行列获取指定长度 int start = 4 * (depotConf.getCableStart() - ser.getCableStart()) * cableZ * cableY; int len = 4 * cableZ * cableY * cableX; log.info("分机------>>>平台：返回粮情完整信息，所属组织={}，分机={}", ser.getCompanyId(), ser.getName()); strPoints = strPoints.substring(start, start + len); // 将粮情解析成数组 List temps = new ArrayList<>(); double tempValue; String temp; for (int i = 0; i < strPoints.length() / 4; i++) { temp = strPoints.substring(i * 4, i * 4 + 4); if (temp == null) { temp = "0000"; } tempValue = BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) / 10.0; // 说明解析的数据有问题 if (tempValue == ERROR_CHECK_TAG || tempValue == ERROR_CHECK_TAG2) { tempValue = Constant.ERROR_TEMP; } // 故障值处理 if (tempValue >= FAULT_CHECK_TAG) { tempValue = Constant.FAULT_TEMP; } temps.add(tempValue); } log.debug("-------CheckGrainRequest--={}", exeRequest.toString()); THDto thDto = thService.getCacheTH(exeRequest.getCompanyId(), exeRequest.getTempSerId(), exeRequest.getThConf()); if (null != thDto) { log.debug("-------THDto--={}", thDto.toString()); } // 将集合解析成坐标数据 addPoint1(temps, msg, depotConf, ser, exeRequest, thDto, sysConf); } private String buildCurKey(ReMessage msg, int curPacket) { return msg.getSourceId() + "_" + curPacket; } private String buildContextKey(ReMessage msg, String depotId) { return msg.getCompanyId() + "_" + msg.getSourceId() + "_" + depotId; } /** * 平房仓，解析第二步，解析到坐标数据 * * @param temps * @throws Exception */ private void addPoint1(List temps, ReMessage msg, DepotConf depotConf, DeviceSer ser, ExeRequest exeRequest, THDto thDto, DicSysConf sysConf) { //根据电缆起始方位和布线方向，对粮情数据进行调整 if (null != depotConf.getStartOrientation()) { temps = reversalGrainPoint(temps, depotConf); } //若起点点位为底部，则将粮情数据进行翻转 if (null != depotConf.getStartPoint() && Constant.GRAIN_START_POINT_BELOW.equals(depotConf.getStartPoint())) { temps = grainUtil.reversalUpAndDown(temps, depotConf.getCableRule()); } //若配置层行转换，则将粮情数据进行层行转换 if (StringUtils.isNotEmpty(depotConf.getStartConvert())) { temps = convertGrainPoint(temps, depotConf); String[] cableRule = depotConf.getCableRule().split("-"); //转换层行列配置 if(Constant.GRAIN_CONVERT_CLOCKWISE.equals(depotConf.getStartConvert()) || Constant.GRAIN_CONVERT_ANTICLOCKWISE.equals(depotConf.getStartConvert())){ depotConf.setCableRule(Integer.valueOf(cableRule[1]) + "-" + Integer.valueOf(cableRule[0]) + "-" + Integer.valueOf(cableRule[2])); } } String[] attCable = depotConf.getCableRule().split("-"); int cableZ = Integer.valueOf(attCable[0]); int cableY = Integer.valueOf(attCable[1]); int cableX = Integer.valueOf(attCable[2]); Grain grain = new Grain(); grain.setDepotId(depotConf.getDepotId()); grain.setCompanyId(depotConf.getCompanyId()); grain.setCable(depotConf.getCableRule()); grain.setBatchId(msg.getBatchId()); grain.setTempIn(Constant.ERROR_TEMP); grain.setHumidityIn(Constant.ERROR_TEMP); if (null != thDto) { log.debug("粮情解析中获取到的温湿度信息={}", thDto.toString()); grain.setHumidityIn(thDto.getHumidityIn()); grain.setTempIn(thDto.getTempIn()); } grain.setReceiveDate(msg.getReceiveDate()); grain.setRemark("粮温正常"); // 获取缓存中的命令信息 grain.setCheckUser(exeRequest.getExeUser()); double max = MAX_TEMP, min = MIN_TEMP, sumT = 0.0, sumNum = cableX * cableY * cableZ; // 校验和实现统计，生成采集点信息 List listGrainItems = new ArrayList<>(); int i = 1; for (Double temp : temps) { if (temp == Constant.ERROR_TEMP || temp == Constant.FAULT_TEMP || temp == Constant.ADD_TEMP) { sumNum--; } else { sumT += temp; if (temp > max) { max = temp; } if (temp < min) { min = temp; } } listGrainItems.add(new GrainItemInfo(i, temp)); i++; } if (sumNum == 0) { sumNum = 1; grain.setRemark("当前粮情采集异常"); } //过滤比较用的最大最小值 if(max == MAX_TEMP){ max = 0.0; } if(min == MIN_TEMP){ min = 0.0; } if (null != depotConf.getTempMax() && max > depotConf.getTempMax()) { grain.setRemark("仓库配置高温警告值：" + depotConf.getTempMax() + "，当前检测高温值：" + max); warnUtils.addGrainWarn(depotConf, grain); } grain.setTempAve(sumT / sumNum); grain.setTempMax(max); grain.setTempMin(min); grain.setPoints(StringUtils.join(temps, ",")); String depotIds = exeRequest.getDepotIds(); boolean notifyWeb = true; if (null != depotIds && depotIds.indexOf(depotConf.getDepotId()) == -1) { notifyWeb = false; } // 用户封装好数据即可 notifyGrainInvoker.analysisSuccess(grain, listGrainItems, depotConf, sysConf, notifyWeb, exeRequest); } /** * 圆筒仓解析步骤 * * @param temps * @param msg * @param depotConf * @param exeRequest * @param thDto */ private void addPoint2(List temps, ReMessage msg, DepotConf depotConf, ExeRequest exeRequest, THDto thDto, DicSysConf sysConf) { Grain grain = new Grain(); grain.setDepotId(depotConf.getDepotId()); grain.setCompanyId(depotConf.getCompanyId()); grain.setCable(depotConf.getCableRule()); grain.setCableCir(depotConf.getCableCir()); grain.setBatchId(msg.getBatchId()); grain.setTempIn(Constant.ERROR_TEMP); grain.setHumidityIn(Constant.ERROR_TEMP); if (null != thDto) { log.debug("粮情解析中获取到的温湿度信息={}", thDto.toString()); grain.setHumidityIn(thDto.getHumidityIn()); grain.setTempIn(thDto.getTempIn()); } grain.setReceiveDate(msg.getReceiveDate()); grain.setRemark("粮温正常"); grain.setCheckUser(exeRequest.getExeUser()); double max = MAX_TEMP, min = MIN_TEMP, sumT = 0.0; int sumNum = temps.size(); List listGrainItems = new ArrayList<>(); int i = 1; for (Double temp : temps) { if (temp == Constant.ERROR_TEMP || temp == Constant.FAULT_TEMP || temp == Constant.ADD_TEMP) { sumNum--; } else { sumT += temp; if (temp > max) { max = temp; } if (temp < min) { min = temp; } } listGrainItems.add(new GrainItemInfo(i, temp)); i++; } if (sumNum == 0) { sumNum = 1; grain.setRemark("当前粮情采集异常"); } //过滤比较用的最大最小值 if(max == MAX_TEMP){ max = 0.0; } if(min == MIN_TEMP){ min = 0.0; } if (null != depotConf.getTempMax() && max > depotConf.getTempMax()) { grain.setRemark("仓库配置高温警告值：" + depotConf.getTempMax() + "，当前检测高温值：" + max); warnUtils.addGrainWarn(depotConf, grain); } grain.setTempAve(sumT / sumNum); grain.setTempMax(max); grain.setTempMin(min); grain.setPoints(StringUtils.join(temps, ",")); String depotIds = exeRequest.getDepotIds(); boolean notifyWeb = true; if (null != depotIds && depotIds.indexOf(depotConf.getDepotId()) == -1) { notifyWeb = false; } // 用户封装好数据即可 notifyGrainInvoker.analysisSuccess(grain, listGrainItems, depotConf, sysConf, notifyWeb, exeRequest); } private List convertGrainPoint(List temps, DepotConf conf) { if (Constant.GRAIN_CONVERT_DEFAULT.equals(conf.getStartConvert())) { //若层行转换为默认，则直接返回 return temps; } //顺时针转换 if(Constant.GRAIN_CONVERT_CLOCKWISE.equals(conf.getStartConvert())){ return grainUtil.convertRight(temps, conf.getCableRule()); } //逆时针转换 if(Constant.GRAIN_CONVERT_ANTICLOCKWISE.equals(conf.getStartConvert())){ return grainUtil.convertLeft(temps, conf.getCableRule()); } return temps; } private List reversalGrainPoint(List temps, DepotConf conf) { if (StringUtils.isEmpty(conf.getStartOrientation())) { //若起始方位为空，则默认起始方位和方向，直接返回 return temps; } //起始方位为右边时 if (Constant.GRAIN_START_ORIENTATION_RIGHT.equals(conf.getStartOrientation())) { if (StringUtils.isEmpty(conf.getStartDirection())) { //右边起始，默认纵向布线，直接返回 return temps; } if (Constant.GRAIN_START_DIRECTION_TRANSVERSE.equals(conf.getStartDirection())) { //右边起始，横向布线 return grainUtil.reversalRight1(temps, conf.getCableRule()); } //右边起始，默认纵向布线，直接返回 return temps; } //起始方位为右上时 if (Constant.GRAIN_START_ORIENTATION_RIGHT_UP.equals(conf.getStartOrientation())) { if (StringUtils.isEmpty(conf.getStartDirection())) { //右上起始，默认纵向布线 return grainUtil.reversalRightUp2(temps, conf.getCableRule()); } if (Constant.GRAIN_START_DIRECTION_TRANSVERSE.equals(conf.getStartDirection())) { //右上起始，横向布线 return grainUtil.reversalRightUp1(temps, conf.getCableRule()); } //右上起始，默认纵向布线 return grainUtil.reversalRightUp2(temps, conf.getCableRule()); } //起始方位为左边时 if (Constant.GRAIN_START_ORIENTATION_LEFT.equals(conf.getStartOrientation())) { if (StringUtils.isEmpty(conf.getStartDirection())) { //左边起始，默认纵向布线 return grainUtil.reversalLeft2(temps, conf.getCableRule()); } if (Constant.GRAIN_START_DIRECTION_TRANSVERSE.equals(conf.getStartDirection())) { //左边起始，横向布线 return grainUtil.reversalLeft1(temps, conf.getCableRule()); } //左边起始，默认纵向布线 return grainUtil.reversalLeft2(temps, conf.getCableRule()); } //起始方位为左上时 if (Constant.GRAIN_START_ORIENTATION_LEFT_UP.equals(conf.getStartOrientation())) { if (StringUtils.isEmpty(conf.getStartDirection())) { //左上起始，默认纵向布线 return grainUtil.reversalLeftUp2(temps, conf.getCableRule()); } if (Constant.GRAIN_START_DIRECTION_TRANSVERSE.equals(conf.getStartDirection())) { //左上起始，横向布线 return grainUtil.reversalLeftUp1(temps, conf.getCableRule()); } //左上起始，默认纵向布线 return grainUtil.reversalLeftUp2(temps, conf.getCableRule()); } return temps; } }