| | |
| | | package com.zy.asrs.task; |
| | | |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.zy.asrs.entity.Order; |
| | | import com.zy.asrs.entity.OrderDetl; |
| | | import com.zy.asrs.entity.WrkMast; |
| | | import com.zy.asrs.mapper.OrderDetlMapper; |
| | | import com.zy.asrs.mapper.OrderMapper; |
| | | import com.zy.asrs.mapper.WrkMastMapper; |
| | | import com.zy.asrs.task.handler.GhjtHandler; |
| | | import com.zy.system.entity.Config; |
| | | import com.zy.system.mapper.ConfigMapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | |
| | | @Resource |
| | | private OrderMapper orderMapper; |
| | | |
| | | @Resource |
| | | private ConfigMapper configMapper; |
| | | |
| | | @Resource |
| | | private OrderDetlMapper orderDetlMapper; |
| | | |
| | | // 自动备货(根据出库单,把要出的货提前放到靠近出库口位置) |
| | | // 定时任务获取待备货订单明细->获取堆垛机对应的源库位,获取备货区库位->生成移库任务11-> |
| | | // 执行移库任务12->入库完成4->更新工作档定时任务中更新订单备货状态和订单明细备货状态5->转储历史 |
| | | @Scheduled(cron = "0/10 * * * * ?") |
| | | public void autoStockUp() { |
| | | // 查询自动备货配置 |
| | | Config config = configMapper.selectConfigByCode("auto_stock_up"); |
| | | if (config == null || config.getStatus() == 0) { |
| | | return; |
| | | } |
| | | // 查询出库申请单中没有备货的订单明细的包装组号 |
| | | List<String> list = orderMapper.selectStockUpOrderDetl(); |
| | | if (list.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | ghjtHandler.autoStockUpHandler(list, Integer.parseInt(config.getValue())); |
| | | |
| | | } |
| | | |
| | | // 下发出库任务给GWCS(从出库码头到出库口) |
| | | // @Scheduled(cron = "0/2 * * * * ? ") |
| | | @Scheduled(cron = "0/2 * * * * ? ") |
| | | public void ckrwPushGwcs() { |
| | | // 查询状态为13的工作档 |
| | | List<WrkMast> wrkMasts = wrkMastMapper.selectList(new EntityWrapper<WrkMast>().eq("io_type", 101).eq("wrk_sts", 13)); |
| | | List<WrkMast> wrkMasts = wrkMastMapper.selectList(new EntityWrapper<WrkMast>().in("io_type", 101,103,107,110,3,12,109).eq("wrk_sts", 13)); |
| | | for (WrkMast wrkMast : wrkMasts) { |
| | | try { |
| | | ghjtHandler.startCkrwPushGwcs(wrkMast); |
| | |
| | | } |
| | | } |
| | | |
| | | // 出库订单完成则上报MES |
| | | // @Scheduled(cron = "0/4 * * * * ? ") |
| | | public void OutBoundCompleteReport() { |
| | | // 查询出库订单状态为4.已完成 |
| | | List<Order> orders = orderMapper.selectComplete(); |
| | | for (Order order : orders) { |
| | | try { |
| | | ghjtHandler.OutBoundCompleteReport(order); |
| | | } catch (Exception e) { |
| | | log.error("出库订单完成则上报MES失败,异常信息:" + e); |
| | | // 自动跨巷道移库 |
| | | // 配置开启->获取单据明细->获取源库位目标库位->生成移库任务->取消任务回滚单据-> |
| | | // wcs出库到堆垛机出库口->gwms给gwcs推送目标站1->gwcs到达堆垛机入库口请求入库->堆垛机执行入库->入库完成->更新单据状态 |
| | | // 11->12->13->1->2->3->4->5 |
| | | @Scheduled(cron = "0/10 * * * * ?") |
| | | public void autoMoveLoc() { |
| | | // 查询跨巷道移库配置 |
| | | Config config = configMapper.selectConfigByCode("auto_move_loc"); |
| | | if (config == null || config.getStatus() == 0) { |
| | | return; |
| | | } |
| | | // 查询待移库的单据明细 |
| | | List<OrderDetl> orderDetlList = orderDetlMapper.selectMoveLocDetl(); |
| | | if (orderDetlList.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | ghjtHandler.autoMoveLoc(orderDetlList); |
| | | } |
| | | |
| | | // 空闲理货 |
| | | // 配置开启->查询可用桁架->获取到能理货的两个木箱->生成两个木箱的理货任务和组盘点的入库任务 |
| | | // wcs出库到堆垛机出库口->推送给gwms去桁架命令->到达理货桁架请求zms拆垛规则->返回拆垛规则gwcs执行拆垛->拆垛完成请求zwms->返回去叠盘/回库/组盘点入库命令->gwcs到达入库口请求入库->堆垛机执行入库 |
| | | // 11->12->13->2->42->52->2->3->4->5 // 回库 |
| | | // ->15 // 去叠盘 |
| | | // ->1->2->3->4->5 // 组盘点入库 |
| | | @Scheduled(cron = "0/10 * * * * ? ") |
| | | public void autoTallyGoods() { |
| | | |
| | | // 系统配置界面启用 |
| | | Config config = configMapper.selectConfigByCode("auto_tally_goods"); |
| | | if (config == null || config.getStatus() == 0) { |
| | | return; |
| | | } |
| | | |
| | | // 标记哪一套桁架能用 |
| | | int flag = 0; |
| | | |
| | | // 分别查询两套桁架是否存在任务 |
| | | Integer count = wrkMastMapper.selectCount(new EntityWrapper<WrkMast>().eq("source_sta_no", 3046).or().in("sta_no", 3045, 3044)); |
| | | if (count == 0) { |
| | | flag = 1; |
| | | } else { |
| | | count = wrkMastMapper.selectCount(new EntityWrapper<WrkMast>().in("source_sta_no", 3042).or().in("sta_no", 3041, 3040)); |
| | | if (count == 0) { |
| | | flag = 2; |
| | | } |
| | | } |
| | | |
| | | // 没有找到可用桁架,桁架都都存在任务 |
| | | if (flag == 0) { |
| | | return; |
| | | } |
| | | |
| | | // 指定桁架生成理货任务 |
| | | ghjtHandler.autoTallyGoods(flag); |
| | | } |
| | | |
| | | } |