package com.zy.asrs.task;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
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;
|
import java.util.List;
|
|
/**
|
* @author pang.jiabao
|
* @description 冠鸿江铜相关定时任务
|
* @createDate 2024/7/3 9:07
|
*/
|
@Slf4j
|
@Component
|
public class GhjtScheduler {
|
|
@Resource
|
private GhjtHandler ghjtHandler;
|
|
@Resource
|
private WrkMastMapper wrkMastMapper;
|
|
@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 * * * * ? ")
|
public void ckrwPushGwcs() {
|
// 查询状态为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);
|
} catch (Exception e) {
|
log.error("下发出库任务给GWCS(从出库码头到出库口)失败，异常信息：" + 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);
|
}
|
|
}
|
