src/main/java/com/zy/asrs/mapper/BasDevpMapper.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/service/BasDevpService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/service/impl/BasDevpServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/handler/OneLouHangJiaHandler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/mapper/BasDevpMapper.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/asrs/mapper/BasDevpMapper.java
@@ -15,4 +15,7 @@ List<Integer> getAvailableInSite(@Param("typeNo") Integer typeNo); List<Integer> getAvailableOutSite(@Param("typeNo") Integer typeNo); void updateReportSignFalse(@Param("devpNo") Integer devpNo); } src/main/java/com/zy/asrs/service/BasDevpService.java
@@ -49,4 +49,6 @@ */ BasDevp checkSiteStatusEmpty(Integer devpNo, boolean pakin); void updateReportSignFalse(Integer devpNo); } src/main/java/com/zy/asrs/service/impl/BasDevpServiceImpl.java
@@ -93,4 +93,9 @@ } return station; } @Override public void updateReportSignFalse(Integer devpNo){ baseMapper.updateReportSignFalse(devpNo); } } src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
@@ -2,8 +2,13 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.RgvOneSign; import com.zy.asrs.entity.WrkMastSta; import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.RgvOneSignService; import com.zy.asrs.service.WrkMastStaService; import com.zy.asrs.service.impl.BasDevpServiceImpl; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.OneLouHangJiaHandler; import com.zy.asrs.task.handler.RailwayPlatformHandler; @@ -24,6 +29,10 @@ private OneLouHangJiaHandler oneLouHangJiaHandler; @Autowired private WrkMastStaService wrkMastStaService; @Autowired private BasDevpService basDevpService; @Autowired private RgvOneSignService rgvOneSignService; @Scheduled(cron = "0/3 * * * * ? ") private void execute(){//退库拆码垛 @@ -46,4 +55,47 @@ } } @Scheduled(cron = "0/3 * * * * ? ") private void executeoTHER(){//131、135标记自动清除 // int[] staNos =new int[]{131,135}; int[][] staNoLists =new int[2][3]; staNoLists[0] = new int[]{131,118,119}; staNoLists[1] = new int[]{135,120,121}; int i = 0; for (int[] staNos : staNoLists){ if (i==0){ RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign")); if (rgvOneSign.getRgvOneSign()==1){//1:退库模式 i++; continue; } } boolean sign = true; int j =0; for (int staNo : staNos){ try{ BasDevp basDevp = basDevpService.selectById(staNo); if (!Cools.isEmpty(basDevp) && basDevp.getAutoing().equals("Y")){ if ( (j==0 && basDevp.getReportSign()==1 && basDevp.getLoading().equals("Y")&& basDevp.getLoadingSuper().equals("Y")) || (j!=0 && basDevp.getReportSign()==0) ){ j++; continue; } } }catch (Exception e){ log.error("131、135标记自动清除"+staNo+"站点处理失败,异常信息:"+e); } sign = false; j++; } if (sign){ basDevpService.updateReportSignFalse(staNos[0]); } i++; } } } src/main/java/com/zy/asrs/task/handler/OneLouHangJiaHandler.java
@@ -61,7 +61,7 @@ Integer staOther = getStaOther(staNoEnd); BasDevp basDevp = basDevpService.selectById(staNo); if (Cools.isEmpty(basDevp) || basDevp.getWrkNo()==0 || !basDevp.getAutoing().equals("Y") || !basDevp.getLoading().equals("Y") || !basDevp.getInEnable().equals("Y")){ || !basDevp.getAutoing().equals("Y") || !basDevp.getLoading().equals("Y") || !basDevp.getLoadingSuper().equals("Y") || !basDevp.getInEnable().equals("Y")){ return FAIL; } BasDevp basDevp131 = basDevpService.selectById(131); @@ -92,7 +92,7 @@ return FAIL; } if (basDevpEnd.getLoading().equals("Y") && basDevpEnd.getEmptyMk().equals("Y")){ if (basDevpEnd.getLoading().equals("Y") && basDevpEnd.getLoadingSuper().equals("Y") && basDevpEnd.getEmptyMk().equals("Y")){ //生成机械臂任务 TrussCombParam trussCombParam = new TrussCombParam(wrkDetl,staNoEnd); try{ @@ -115,10 +115,10 @@ log.error("桁架上位软件退库失败"+e); return FAIL; } }else if (!basDevpEnd.getLoading().equals("Y") ){ }else if (!basDevpEnd.getLoading().equals("Y") && !basDevpEnd.getLoadingSuper().equals("Y")){ Thread.sleep(1000); basDevpEnd = basDevpService.selectById(staNoEnd); if (Cools.isEmpty(basDevpEnd) || !basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getReportSign()!=0 || basDevpEnd.getLoading().equals("Y") ){ if (Cools.isEmpty(basDevpEnd) || !basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getReportSign()!=0 || basDevpEnd.getLoading().equals("Y") || basDevpEnd.getLoadingSuper().equals("Y")){ return FAIL; } WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no",staNoEnd + 19999L)); src/main/resources/mapper/BasDevpMapper.xml
@@ -69,4 +69,11 @@ group by abd.dev_no </select> <update id="updateReportSignFalse"> update man_order set report_sign = 0 where 1=1 and dev_no = #{devpNo} </update> </mapper>