| | |
| | | import com.zy.asrs.entity.param.TaskCreateParam; |
| | | import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam; |
| | | import com.zy.asrs.service.*; |
| | | import com.zy.asrs.service.impl.OpenServiceImpl; |
| | | import com.zy.common.web.BaseController; |
| | | import com.zy.core.DevpThread; |
| | | import com.zy.core.cache.MessageQueue; |
| | |
| | | @PostMapping("/preStoragePallet") |
| | | public R preStoragePallet(@RequestHeader String appkey, @RequestBody PreStoragePallet preStoragePallet, HttpServletRequest request) { |
| | | auth(appkey, preStoragePallet, request); |
| | | if(Cools.isEmpty(preStoragePallet.getSite(),preStoragePallet.getLx(),preStoragePallet.getLev())) { |
| | | if(Cools.isEmpty(preStoragePallet.getSite(),preStoragePallet.getLev())) { |
| | | return R.error("åæ°ä¸å®æ´ï¼è¯·æ£æ¥ï¼" + preStoragePallet); |
| | | } |
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
| | |
| | | staProtocol = staProtocol.clone(); |
| | | } |
| | | |
| | | staProtocol.setMp((short) (preStoragePallet.getLev() > 1 ? 1 : 2)); |
| | | // staProtocol.setMp((short) (preStoragePallet.getLev() > 1 ? 1 : 2)); |
| | | staProtocol.setLev(preStoragePallet.getLev()); |
| | | staProtocol.setLx(OpenServiceImpl.getGzlx(preStoragePallet.getLx())); |
| | | // staProtocol.setLx(OpenServiceImpl.getGzlx(preStoragePallet.getLx())); |
| | | |
| | | boolean offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); |
| | | if(!offer) { |
| | |
| | | int lx = 0,mp = 0,lev = 0; |
| | | |
| | | switch (staProtocol.getSiteId()) { |
| | | case 205: lx = 16;mp = 18;lev=344;break; |
| | | case 202: lev=366;break; |
| | | case 206: lev=368;break; |
| | | case 207: lx = 24;mp = 26;lev=348;break; |
| | | case 210: lx = 36;mp = 38;lev=354;break; |
| | | case 211: lev=370;break; |
| | | case 212: lx = 44;mp = 46;lev=358;break; |
| | | default: |
| | | log.error("åç çä¿¡æ¯ç«ç¹æè¯¯ï¼{}" , staProtocol.getSiteId()); |
| | |
| | | //ä»»å¡ä¸åæåæ è¯ |
| | | boolean writeFlag = false; |
| | | while (writeCount < 5) { |
| | | OperateResult writeResult1 = siemensS7Net.Write(addressPre + lx, staProtocol.getLx()); // å·¥è£
ç±»å |
| | | OperateResult writeResult2 = siemensS7Net.Write(addressPre + mp, staProtocol.getMp()); // æ¯å¦ç ç |
| | | OperateResult writeResult3 = siemensS7Net.Write(addressPre + lev, staProtocol.getLev()); // ç ç屿° |
| | | if (writeResult1.IsSuccess && writeResult2.IsSuccess && writeResult3.IsSuccess) { |
| | | if (staProtocol.getSiteId() == 202 || staProtocol.getSiteId() == 206 || staProtocol.getSiteId() == 211) { |
| | | OperateResult writeResult3 = siemensS7Net.Write(addressPre + lev, staProtocol.getLev()); // ç ç屿° |
| | | if (writeResult3.IsSuccess) { |
| | | writeFlag = true; |
| | | log.info("ç çä¿¡æ¯åå
¥è¾é线å½ä»¤åè¿åæåã{},{},{},{}ãï¼å¹¶ä¸å读æåï¼åå
¥æ¬¡æ°={}", staProtocol.getSiteId(),staProtocol.getMp(),staProtocol.getLx(),staProtocol.getLev(), writeCount); |
| | | log.info("å
¥åºç çä¿¡æ¯åå
¥è¾é线å½ä»¤åè¿åæåã{},{},{},{}ãï¼å¹¶ä¸å读æåï¼åå
¥æ¬¡æ°={}", staProtocol.getSiteId(), staProtocol.getMp(), staProtocol.getLx(), staProtocol.getLev(), writeCount); |
| | | break; |
| | | } else { |
| | | writeCount++; |
| | | log.error("å
¥åºç çä¿¡æ¯åå
¥è¾é线å½ä»¤å¤±è´¥ãè¾é线plcç¼å·={}ï¼ç«ç¹æ°æ®={},åå
¥æ¬¡æ°={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
| | | } |
| | | } else { |
| | | writeCount++; |
| | | log.error("ç çä¿¡æ¯åå
¥è¾é线å½ä»¤å¤±è´¥ãè¾é线plcç¼å·={}ï¼ç«ç¹æ°æ®={},åå
¥æ¬¡æ°={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
| | | OperateResult writeResult1 = siemensS7Net.Write(addressPre + lx, staProtocol.getLx()); // å·¥è£
ç±»å |
| | | OperateResult writeResult2 = siemensS7Net.Write(addressPre + mp, staProtocol.getMp()); // æ¯å¦ç ç |
| | | OperateResult writeResult3 = siemensS7Net.Write(addressPre + lev, staProtocol.getLev()); // ç ç屿° |
| | | if (writeResult1.IsSuccess && writeResult2.IsSuccess && writeResult3.IsSuccess) { |
| | | writeFlag = true; |
| | | log.info("åºåºç çä¿¡æ¯åå
¥è¾é线å½ä»¤åè¿åæåã{},{},{},{}ãï¼å¹¶ä¸å读æåï¼åå
¥æ¬¡æ°={}", staProtocol.getSiteId(), staProtocol.getMp(), staProtocol.getLx(), staProtocol.getLev(), writeCount); |
| | | break; |
| | | } else { |
| | | writeCount++; |
| | | log.error("åºåºç çä¿¡æ¯åå
¥è¾é线å½ä»¤å¤±è´¥ãè¾é线plcç¼å·={}ï¼ç«ç¹æ°æ®={},åå
¥æ¬¡æ°={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); |
| | | } |
| | | } |
| | | } |
| | | |