package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.AgvLocDetl;
|
import com.zy.asrs.entity.AgvWaitPakin;
|
import com.zy.asrs.entity.AgvWrkDetl;
|
import com.zy.asrs.entity.AgvWrkMast;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.IOException;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Service
|
public class AgvWrkMastHandler extends AbstractHandler<String> {
|
|
@Autowired
|
AgvWrkMastService agvWrkMastService;
|
@Autowired
|
AgvLocMastService agvLocMastService;
|
@Autowired
|
AgvLocDetlService agvLocDetlService;
|
@Autowired
|
AgvWrkMastLogService agvWrkMastLogService;
|
@Autowired
|
AgvWrkDetlService agvWrkDetlService;
|
@Autowired
|
AgvWrkDetlLogService agvWrkDetlLogService;
|
@Autowired
|
AgvWaitPakinService agvWaitPakinService;
|
@Autowired
|
AgvWaitPakinLogService agvWaitPakinLogService;
|
@Autowired
|
OrderService orderService;
|
|
@Transactional
|
public ReturnT<String> completedPutWayWrk(AgvWrkMast agvWrkMast) {
|
int wrkNo = agvWrkMast.getWrkNo();
|
String barcode = agvWrkMast.getBarcode();
|
String orderNo = getOrderNoByWrkNo(wrkNo);
|
|
//修改工作档状态为207.库存更新完成
|
agvWrkMast.setWrkSts(207L);
|
agvWrkMastService.updateById(agvWrkMast);
|
if(agvWrkMast.getIoType() == 10){
|
// 空板入库 设置库位状态为D.空桶/空栈板
|
agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(),"D");
|
}else{
|
//修改目标库位状态为F.在库
|
agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(),"F");
|
}
|
//生成AGV工作历史档
|
agvWrkMastLogService.save(agvWrkMast);
|
//生成AGV工作明细历史档
|
agvWrkDetlLogService.save(wrkNo);
|
//类型为入库时
|
if(agvWrkMast.getIoType() == 1){
|
//更新目标库位明细
|
log.info("更新目标库位明细 agvWrkMast.getLocNo(): " + agvWrkMast.getLocNo() + ", wrkNo: " + wrkNo);
|
agvLocDetlService.addLocDetlInfo(agvWrkMast.getLocNo(),wrkNo);
|
//生成入库通知历史档
|
boolean save = agvWaitPakinLogService.save(barcode);
|
//删除入库通知档
|
log.info("删除入库通知档 supp_code: " + barcode);
|
agvWaitPakinService.delete(new EntityWrapper<AgvWaitPakin>().eq("supp_code",barcode));
|
}
|
//类型为库位移转时
|
if(agvWrkMast.getIoType() == 11){
|
//更新库存明细
|
agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(),agvWrkMast.getLocNo());
|
//修改源库位状态为O
|
agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O");
|
}
|
|
//删除AGV工作档
|
agvWrkMastService.deleteById(wrkNo);
|
//删除AGV工作明细档
|
agvWrkDetlService.delete(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",wrkNo));
|
|
if(!isJSON(orderNo)){
|
//检查订单是否已完成
|
orderService.checkComplete(orderNo);
|
}else{
|
List<Map> maps = JSONArray.parseArray(orderNo, Map.class);
|
maps.forEach(map -> {
|
String o = map.get("orderNo").toString();
|
orderService.checkComplete(o);
|
});
|
}
|
|
return SUCCESS;
|
}
|
|
|
@Transactional
|
public ReturnT<String> completedCarryWrk(AgvWrkMast agvWrkMast) {
|
int wrkNo = agvWrkMast.getWrkNo();
|
String orderNo = getOrderNoByWrkNo(wrkNo);
|
//修改工作档状态为207.库存更新完成
|
agvWrkMast.setWrkSts(207L);
|
agvWrkMastService.updateById(agvWrkMast);
|
//修改源库位状态为O
|
agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O");
|
if(agvWrkMast.getIoType() == 101){
|
//更新目标库位明细 101.出库 删除源库位库存明细
|
agvLocDetlService.delete(new EntityWrapper<AgvLocDetl>().eq("loc_no",agvWrkMast.getSourceLocNo()));
|
}
|
|
//生成AGV工作历史档
|
agvWrkMastLogService.save(agvWrkMast);
|
//生成AGV工作明细历史档
|
agvWrkDetlLogService.save(wrkNo);
|
//删除AGV工作档
|
agvWrkMastService.deleteById(wrkNo);
|
//删除AGV工作明细档
|
agvWrkDetlService.delete(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",wrkNo));
|
if(!isJSON(orderNo)){
|
//检查订单是否已完成
|
orderService.checkComplete(orderNo);
|
}else{
|
List<Map> maps = JSONArray.parseArray(orderNo, Map.class);
|
maps.forEach(map -> {
|
String o = map.get("orderNo").toString();
|
orderService.checkComplete(o);
|
});
|
}
|
return SUCCESS;
|
}
|
|
@Transactional
|
public ReturnT<String> startPutWayWrk(List<AgvWrkMast> agvWrkMastList) throws IOException {
|
|
int startWwrkCode = agvWrkMastService.startWrk(agvWrkMastList,"putaway");
|
|
int code = agvWrkMastService.containerMove(agvWrkMastList);
|
|
if(code == 0){
|
agvWrkMastList.forEach(agvWrkMast -> {
|
//202.RCS取货中
|
agvWrkMast.setWrkSts(202L);
|
agvWrkMastService.updateById(agvWrkMast);
|
if(agvWrkMast.getIoType() == 1){
|
//修改AGV入库通知档状态入出状态为Y
|
agvWaitPakinService.updateIoStatus(agvWrkMast.getWrkNo(),"Y");
|
}
|
|
});
|
//agvWrkMastService.updateBatchById(agvWrkMastList);
|
|
return SUCCESS;
|
}
|
|
return FAIL;
|
}
|
|
@Transactional
|
public ReturnT<String> startCarryWrk(List<AgvWrkMast> agvWrkMastList) throws IOException {
|
int code = agvWrkMastService.startWrk(agvWrkMastList,"carry");
|
if(code == 0){
|
agvWrkMastList.forEach(agvWrkMast -> {
|
//202.RCS取货中
|
agvWrkMast.setWrkSts(202L);
|
agvWrkMastService.updateById(agvWrkMast);
|
});
|
//agvWrkMastService.updateBatchById(agvWrkMastList);
|
|
return SUCCESS;
|
}
|
|
return FAIL;
|
}
|
|
private String getOrderNoByWrkNo(int wrkNo){
|
AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkNo));
|
if(Cools.isEmpty(agvWrkDetl)){
|
return null;
|
}
|
return agvWrkDetl.getOrderNo();
|
}
|
|
private boolean isJSON(String str) {
|
if (Cools.isEmpty(str)) {
|
return false;
|
} else {
|
str = str.trim();
|
if (str.startsWith("{") && str.endsWith("}")) {
|
return true;
|
} else if (str.startsWith("[") && str.endsWith("]")) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
}
|
}
|
