package com.zy.asrs.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.entity.param.EmptyPlateOutParam;
|
import com.zy.asrs.entity.param.LocDetlAdjustParam;
|
import com.zy.asrs.entity.param.StockOutParam;
|
import com.zy.asrs.service.*;
|
import com.zy.common.model.LocDto;
|
import com.zy.common.model.OrderDto;
|
import com.zy.common.model.StartupDto;
|
import com.zy.common.model.TaskDto;
|
import com.zy.common.model.enums.WorkNoType;
|
import com.zy.common.service.AgvCommonService;
|
import com.zy.common.web.BaseController;
|
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.util.Date;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.UUID;
|
|
/**
|
* Created by vincent on 2020/6/11
|
*/
|
@Slf4j
|
@Service
|
@Transactional
|
public class AgvWorkServiceImpl implements AgvWorkService {
|
|
// 工作号生成规则默认类型
|
private static final int DEFAULT_WORK_NO_TYPE = 0;
|
// 库位排号分配默认类别
|
private static final int DEFAULT_ROW_NO_TYPE = 1;
|
@Autowired
|
private AgvWaitPakinService agvWaitPakinService;
|
@Autowired
|
private AgvBasDevpService agvBasDevpService;
|
@Autowired
|
private AgvLocMastService agvLocMastService;
|
@Autowired
|
private AgvLocDetlService agvLocDetlService;
|
@Autowired
|
private AgvCommonService agvCommonService;
|
@Autowired
|
private AgvWrkMastService agvWrkMastService;
|
@Autowired
|
private AgvWrkDetlService agvWrkDetlService;
|
@Autowired
|
private MatService matService;
|
@Autowired
|
private OrderService orderService;
|
@Autowired
|
private OrderDetlService orderDetlService;
|
@Autowired
|
private AdjDetlService adjDetlService;
|
|
|
/*
|
入库
|
*/
|
@Transactional
|
public StartupDto createWaitPainWrkMastStart(List<AgvBasDevp> agvBasDevpList, Long userId) {
|
|
Date now = new Date();
|
|
agvBasDevpList.forEach(agvBasDevp -> {
|
if(Cools.isEmpty(agvBasDevp.getBarcode())){
|
throw new CoolException("选中的站点中含有未绑定托盘的站点，请重新选择");
|
}
|
|
if(!"F".equals(agvBasDevp.getLocSts())){
|
throw new CoolException("选中的站点中含有货位状态不为F.在库的站点，请重新选择");
|
}
|
|
List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("zpallet", agvBasDevp.getBarcode()));
|
|
//检索库位，选择合适的库位
|
AgvLocMast agvLocMast = agvCommonService.getLocNo(agvWaitPakinList, agvBasDevp.getFloor());
|
//生成工作档
|
//AgvWrkMast wrkMast = createWrkMast(agvBasDevp, agvLocMast, now, userId);
|
AgvWrkMast wrkMast = createWrkMast(1,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),agvBasDevp.getBarcode(),now,userId);
|
//生成工作档明细
|
//createWrkDetlReWrite(agvWaitPakinList,wrkMast,userId);
|
agvWaitPakinList.forEach(wp -> {
|
createWrkDetlReWrite(wp.getMatnr(),wrkMast.getWrkNo(),wp.getOrderNo(),wp.getBatch(),wp.getAnfme(),wp.getZpallet(),now,userId,wp.getThreeCode(),wp.getDeadTime());
|
});
|
//更新源站点信息
|
updateAgvBasDevp(agvBasDevp,"R");
|
//更新目标库位状态
|
updateAgvLocMast(agvLocMast,"S");
|
|
});
|
|
//TODO
|
return null;
|
}
|
|
/*
|
订单出库
|
*/
|
@Transactional
|
public void stockOutWrkMast(List<TaskDto> agvTaskDtos, Long userId) {
|
Date now = new Date();
|
|
agvTaskDtos.forEach(taskDto -> {
|
|
AgvLocMast agvLocMast = agvLocMastService.selectById(taskDto.getLocNo());
|
AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", taskDto.getLocNo()));
|
|
//工作档所需参数
|
double anfme = taskDto.getLocDtos().get(0).getAnfme();
|
long wrkSts = 21L;
|
String sourceLocNo = taskDto.getLocNo();
|
String targetLocNo = taskDto.getAgvStaNo();
|
String barcode = agvLocDetl.getZpallet();
|
//明细档所需参数
|
String mantr = taskDto.getLocDtos().get(0).getMatnr();
|
String orderNo = taskDto.getLocDtos().get(0).getOrderNo();
|
String batch = taskDto.getLocDtos().get(0).getBatch();
|
|
String csocode = agvLocDetl.getThreeCode();
|
String isoseq = agvLocDetl.getDeadTime();
|
|
//判断是否全板出库
|
int ioType = isPakOut(sourceLocNo,anfme) ? 101 : 103;
|
//生成工作档
|
AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,barcode,now,userId);
|
//生成工作档明细
|
createWrkDetlReWrite(mantr,wrkMast.getWrkNo(),orderNo,batch,anfme,barcode,now,userId,csocode,isoseq);
|
//修改订单信息
|
modifyOrderDetl(taskDto.getLocDtos().get(0), userId);
|
//更新源站点信息
|
String locSts = ioType == 101 ? "R" : "P";
|
updateAgvLocMast(agvLocMastService.selectById(sourceLocNo),locSts);
|
//更新目标站点状态
|
//locSts = ioType == 101 ? "S" : "Q";
|
updateAgvBasDevp(agvBasDevpService.selectById(targetLocNo),"S");
|
|
});
|
}
|
|
//拣料入库
|
@Transactional
|
public void pickIn(List<AgvWrkMast> agvWrkMastList){
|
Date now = new Date();
|
agvWrkMastList.forEach(agvWrkMast -> {
|
//修改工作党
|
agvWrkMast.setWrkSts(201L);
|
|
//根据出库类型 设置入库类型 53拣料入库 57盘点入库
|
int ioType = agvWrkMast.getIoType() == 103 ? 53 : 57;
|
|
agvWrkMast.setIoType(ioType);
|
String locNo = agvWrkMast.getLocNo();
|
agvWrkMast.setLocNo(agvWrkMast.getSourceLocNo());
|
agvWrkMast.setSourceLocNo(locNo);
|
agvWrkMast.setIoTime(now);
|
agvWrkMastService.updateById(agvWrkMast);
|
|
AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo()));
|
AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getLocNo());
|
AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no",agvLocMast.getLocNo()));
|
AgvBasDevp agvBasDevp = agvBasDevpService.selectById(agvWrkMast.getSourceLocNo());
|
|
//拣料入库
|
if(ioType == 53){
|
//修改工作党明细
|
agvWrkDetl.setAnfme(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());
|
agvWrkDetlService.update(agvWrkDetl,new EntityWrapper<AgvWrkDetl>().eq("wrk_no",agvWrkDetl.getWrkNo()));
|
//修改库存信息
|
agvLocDetl.setAnfme(agvWrkDetl.getAnfme());
|
agvLocDetlService.update(agvLocDetl,new EntityWrapper<AgvLocDetl>().eq("loc_no",agvLocDetl.getLocNo()));
|
}
|
//修改库位信息
|
updateAgvLocMast(agvLocMast,"Q");
|
//修改站点信息
|
updateAgvBasDevp(agvBasDevp,"R");
|
|
});
|
}
|
|
/*
|
盘点出库
|
*/
|
@Transactional
|
public void locCheckOut(StockOutParam param, Long userId) {
|
String station = param.getStation();
|
List<AgvBasDevp> agvBasDevpList = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>()
|
.eq("station_code", station)
|
.eq("loc_sts","O"));
|
|
if(param.getLocDetls().size() > agvBasDevpList.size()){
|
throw new CoolException("当前站点可用缓存货架数量为" + agvBasDevpList.size() + ",少于需要盘点出库库位数量，请重新选择盘点库位");
|
}
|
|
param.getLocDetls().forEach(locDetl -> {
|
AgvLocMast agvLocMast = agvLocMastService.selectById(locDetl.getLocNo());
|
AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locDetl.getLocNo()));
|
AgvBasDevp agvBasDevp = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>()
|
.eq("station_code", station)
|
.eq("loc_sts","O"));
|
Date now = new Date();
|
|
//生成工作党
|
AgvWrkMast wrkMast = createWrkMast(107, 21L, locDetl.getLocNo(), agvBasDevp.getDevNo(), agvLocDetl.getZpallet(), now, userId);
|
//生成工作明细档
|
createWrkDetlReWrite(locDetl.getMatnr(),wrkMast.getWrkNo(),null,locDetl.getBatch(),locDetl.getCount(),wrkMast.getBarcode(),now,userId,agvLocDetl.getThreeCode(),agvLocDetl.getDeadTime());
|
//修改库位信息
|
updateAgvLocMast(agvLocMast,"P");
|
//修改站点信息
|
updateAgvBasDevp(agvBasDevp,"S");
|
|
});
|
|
}
|
|
/*
|
库位移转
|
*/
|
@Transactional
|
public void locMove(String sourceLocNo, String targetLocNo, Long userId) {
|
AgvLocMast sourceLocMast = agvLocMastService.selectById(sourceLocNo);
|
AgvLocMast targetLocMast = agvLocMastService.selectById(targetLocNo);
|
AgvLocDetl sourceLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", sourceLocMast.getLocNo()));
|
|
if(!sourceLocMast.getLocSts().equals("F")){
|
throw new CoolException(sourceLocMast.getLocNo() + "源库位出库失败，状态："+sourceLocMast.getLocSts$());
|
}
|
if(!targetLocMast.getLocSts().equals("O")){
|
throw new CoolException("移转失败，目标库位状态："+targetLocMast.getLocSts$());
|
}
|
|
Date now = new Date();
|
//生成移库工作档
|
AgvWrkMast wrkMast = createWrkMast(11, 21L, sourceLocNo, targetLocNo, sourceLocDetl.getZpallet(), now, userId);
|
//生成工作党明细
|
createWrkDetlReWrite(sourceLocDetl.getMatnr(),wrkMast.getWrkNo(),null,sourceLocDetl.getBatch(),sourceLocDetl.getAnfme(),sourceLocDetl.getZpallet(),now,userId,sourceLocDetl.getThreeCode(),sourceLocDetl.getDeadTime());
|
//修改目标库位状态
|
updateAgvLocMast(targetLocMast,"S");
|
//修改原库位状态
|
updateAgvLocMast(sourceLocMast,"R");
|
}
|
|
/*
|
空板入库
|
*/
|
@Transactional
|
public String emptyPlateIn(String sourceStaion, Long userId) {
|
Date now = new Date();
|
// 源站点状态检测
|
AgvBasDevp agvBasDevp = agvBasDevpService.selectById(sourceStaion);
|
if(!agvBasDevp.getLocSts().equals("O")){
|
throw new CoolException("当前工作位状态为" + agvBasDevp.getLocSts()+",无法进行空板入库");
|
}
|
// 检索库位
|
AgvLocMast locMast = agvCommonService.getLocNo(null, agvBasDevp.getFloor());
|
// 生成工作档 10.空板入库
|
createWrkMast(10,201L,agvBasDevp.getDevNo(),locMast.getLocNo(),null,now,userId);
|
//更新源站点状态
|
updateAgvBasDevp(agvBasDevp,"R");
|
//更新目标库位状态
|
updateAgvLocMast(locMast,"S");
|
return locMast.getLocNo();
|
}
|
|
/*
|
空板出库
|
*/
|
@Transactional
|
public void emptyPlateOut(EmptyPlateOutParam param, Long userId) {
|
Date now = new Date();
|
//判断所选工作站空余工作位数量是否满足出库数量
|
List<AgvBasDevp> agvBasDevpList = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>()
|
.eq("station_code", param.getStationCode())
|
.eq("loc_sts","O"));
|
if(agvBasDevpList.size() < param.getLocNos().size()){
|
throw new CoolException("当前工作站可出库工作位数量为"+ agvBasDevpList.size() + "，小于要出库的库位数量，请重新选择出库库位");
|
}
|
param.getLocNos().forEach(locNo -> {
|
AgvLocMast agvLocMast = agvLocMastService.selectById(locNo);
|
if(!agvLocMast.getLocSts().equals("D")){
|
throw new CoolException(agvLocMast.getLocNo() + "库位状态已经不为D.空桶/空栈板，请重新选择库位进行空板出库");
|
}
|
//检索工作位
|
AgvBasDevp agvBasDevp = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>()
|
.eq("station_code", param.getStationCode())
|
.eq("loc_sts", "O"));
|
//生成工作档
|
createWrkMast(110,21L,locNo,agvBasDevp.getDevNo(),null,now,userId);
|
//修改源库位状态
|
updateAgvLocMast(agvLocMast,"R");
|
//修改目标工作位状态
|
updateAgvBasDevp(agvBasDevp,"S");
|
});
|
}
|
|
@Transactional
|
public void adjustLocDetl(LocDetlAdjustParam param, Long userId) {
|
param.integrate();
|
AgvLocMast locMast = agvLocMastService.selectById(param.getLocNo());
|
if (Cools.isEmpty(locMast)) {
|
throw new CoolException("库位不存在");
|
}
|
if (!(locMast.getLocSts().equals("F") || locMast.getLocSts().equals("D") || locMast.getLocSts().equals("O"))) {
|
throw new CoolException("当前库位不可调整！库位状态：" + locMast.getLocSts$());
|
}
|
|
Date now = new Date();
|
List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", param.getLocNo()));
|
|
List<LocDetlAdjustParam.LocDetlAdjust> list = param.getList();
|
|
// 修改数量
|
Iterator<AgvLocDetl> iterator = locDetls.iterator();
|
while (iterator.hasNext()) {
|
AgvLocDetl locDetl = iterator.next();
|
|
Iterator<LocDetlAdjustParam.LocDetlAdjust> iterator1 = list.iterator();
|
while (iterator1.hasNext()) {
|
LocDetlAdjustParam.LocDetlAdjust adjust = iterator1.next();
|
if (adjust.getCount() == 0) { continue; }
|
if (locDetl.getMatnr().equals(adjust.getMatnr()) && Cools.eq(locDetl.getBatch(), adjust.getBatch())) {
|
if (!locDetl.getAnfme().equals(adjust.getCount())) {
|
// todo 盘点记录
|
// 修改库存
|
if (!agvLocDetlService.updateAnfme(adjust.getCount(), locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch())) {
|
throw new CoolException(locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码修改数量失败");
|
}
|
// 保存调整记录
|
AdjDetl adjDetl = new AdjDetl();
|
adjDetl.setLocNo(locDetl.getLocNo());
|
adjDetl.setMatnr(locDetl.getMatnr());
|
adjDetl.setBatch(locDetl.getBatch());
|
adjDetl.setOriQty(locDetl.getAnfme());
|
adjDetl.setAdjQty(adjust.getCount());
|
adjDetl.setModiTime(now);
|
adjDetl.setModiUser(userId);
|
adjDetl.setAppeTime(now);
|
adjDetl.setAppeUser(userId);
|
|
UUID uuid = UUID.randomUUID();
|
adjDetl.setOrderNo(uuid.toString());
|
adjDetl.setCsocode(locDetl.getThreeCode());
|
adjDetl.setIsoseq(locDetl.getDeadTime());
|
|
adjDetlService.save(adjDetl, userId);
|
}
|
iterator.remove();
|
iterator1.remove();
|
}
|
}
|
}
|
|
// 删除库存
|
for (AgvLocDetl locDetl : locDetls) {
|
// todo 盘点记录
|
if (!agvLocDetlService.updateAnfme(-1.0D, locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch())) {
|
throw new CoolException("删除" + locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码库存明细失败");
|
}
|
// 保存调整记录
|
AdjDetl adjDetl = new AdjDetl();
|
adjDetl.setLocNo(locDetl.getLocNo());
|
adjDetl.setMatnr(locDetl.getMatnr());
|
adjDetl.setBatch(locDetl.getBatch());
|
adjDetl.setOriQty(locDetl.getAnfme());
|
adjDetl.setAdjQty(0.0D);
|
adjDetl.setModiTime(now);
|
adjDetl.setModiUser(userId);
|
adjDetl.setAppeTime(now);
|
adjDetl.setAppeUser(userId);
|
|
adjDetlService.save(adjDetl, userId);
|
}
|
|
// 添加库存
|
for (LocDetlAdjustParam.LocDetlAdjust adjust : list) {
|
if (adjust.getCount() == 0.0D) { continue; }
|
Mat mat = matService.selectByMatnr(adjust.getMatnr());
|
AgvLocDetl locDetl = new AgvLocDetl();
|
locDetl.sync(mat);
|
locDetl.setBatch(adjust.getBatch());
|
locDetl.setLocNo(locMast.getLocNo());
|
locDetl.setAnfme(adjust.getCount()); // 数量
|
locDetl.setModiUser(userId); // 操作人员信息
|
locDetl.setModiTime(now);
|
locDetl.setAppeUser(userId);
|
locDetl.setAppeTime(now);
|
locDetl.setThreeCode(adjust.getThreeCode());
|
locDetl.setDeadTime(adjust.getDeadTime());
|
if (!agvLocDetlService.insert(locDetl)) {
|
throw new CoolException("添加" + locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码库存明细失败");
|
}
|
// 保存调整记录
|
AdjDetl adjDetl = new AdjDetl();
|
adjDetl.setLocNo(locMast.getLocNo());
|
adjDetl.setMatnr(adjust.getMatnr());
|
adjDetl.setBatch(adjust.getBatch());
|
adjDetl.setOriQty(0.0D);
|
adjDetl.setAdjQty(adjust.getCount());
|
adjDetl.setModiTime(now);
|
adjDetl.setModiUser(userId);
|
adjDetl.setAppeTime(now);
|
adjDetl.setAppeUser(userId);
|
|
UUID uuid = UUID.randomUUID();
|
adjDetl.setOrderNo(uuid.toString());
|
adjDetl.setCsocode(locDetl.getThreeCode());
|
adjDetl.setIsoseq(locDetl.getDeadTime());
|
|
adjDetlService.save(adjDetl, userId);
|
}
|
// 修改库位状态
|
int count = agvLocDetlService.selectCount(new EntityWrapper<AgvLocDetl>().eq("loc_no", locMast.getLocNo()));
|
if (locMast.getLocSts().equals("F")) {
|
if (count == 0) {
|
locMast.setLocSts("D");
|
}
|
}
|
if (locMast.getLocSts().equals("D") || locMast.getLocSts().equals("O")) {
|
if (count > 0) {
|
locMast.setLocSts("F");
|
}
|
}
|
locMast.setModiUser(userId);
|
locMast.setModiTime(new Date());
|
if (!agvLocMastService.updateById(locMast)) {
|
throw new CoolException("更新库位状态失败");
|
}
|
}
|
|
/*
|
更新目标库位信息
|
*/
|
private void updateAgvLocMast(AgvLocMast locMast, String locSts){
|
locMast.setLocSts(locSts);
|
agvLocMastService.updateById(locMast);
|
}
|
|
/*
|
更新源站点信息
|
*/
|
private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts){
|
agvBasDevp.setLocSts(locSts);
|
agvBasDevpService.updateById(agvBasDevp);
|
}
|
|
/*
|
生成工作档明细
|
*/
|
private void createWrkDetlReWrite(String matnr, int wrkNo, String orderNo,String batch, double anfme, String zpallet, Date now, Long userId, String csocode, String isoseq){
|
Mat mat = matService.selectByMatnr(matnr);
|
if (Cools.isEmpty(mat)) {
|
throw new CoolException(matnr + "商品维护失败");
|
}
|
AgvWrkDetl wrkDetl = new AgvWrkDetl();
|
wrkDetl.sync(mat);
|
wrkDetl.setWrkNo(wrkNo);
|
wrkDetl.setOrderNo(orderNo);
|
wrkDetl.setIoTime(now);
|
wrkDetl.setBatch(batch);
|
wrkDetl.setAnfme(anfme); // 数量
|
wrkDetl.setZpallet(zpallet); // 托盘条码
|
wrkDetl.setAppeUser(userId);
|
wrkDetl.setAppeTime(now);
|
wrkDetl.setModiUser(userId);
|
wrkDetl.setModiTime(now);
|
|
wrkDetl.setThreeCode(csocode);
|
wrkDetl.setDeadTime(isoseq);
|
if (!agvWrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作明细失败");
|
}
|
}
|
|
/*
|
生成工作档明细
|
*/
|
@Deprecated
|
private void createWrkDetlReWrite(List<AgvWaitPakin> agvWaitPakinList, AgvWrkMast wrkMast, Long userId){
|
Date now = new Date();
|
agvWaitPakinList.stream().forEach(agvWaitPakin -> {
|
Mat mat = matService.selectByMatnr(agvWaitPakin.getMatnr());
|
if (Cools.isEmpty(mat)) {
|
throw new CoolException(agvWaitPakin.getMatnr() + "商品维护失败");
|
}
|
AgvWrkDetl wrkDetl = new AgvWrkDetl();
|
wrkDetl.sync(mat);
|
wrkDetl.setWrkNo(wrkMast.getWrkNo());
|
wrkDetl.setOrderNo(agvWaitPakin.getOrderNo());
|
wrkDetl.setIoTime(now);
|
wrkDetl.setBatch(agvWaitPakin.getBatch());
|
wrkDetl.setAnfme(agvWaitPakin.getAnfme()); // 数量
|
wrkDetl.setZpallet(agvWaitPakin.getZpallet()); // 托盘条码
|
wrkDetl.setAppeUser(userId);
|
wrkDetl.setAppeTime(now);
|
wrkDetl.setModiUser(userId);
|
wrkDetl.setModiTime(now);
|
if (!agvWrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作明细失败");
|
}
|
});
|
}
|
|
/*
|
生成工作档
|
*/
|
private AgvWrkMast createWrkMast(int ioType, long wrkSts, String sourceLocNo, String locNo, String barcode, Date now, Long userId){
|
AgvWrkMast wrkMast = new AgvWrkMast();
|
//生成工作号
|
int workNo = agvCommonService.getWorkNo(WorkNoType.getWorkNoType(ioType));
|
wrkMast.setWrkNo(workNo);
|
//工作状态
|
wrkMast.setWrkSts(wrkSts);
|
//入出库类型
|
wrkMast.setIoType(ioType);
|
wrkMast.setIoTime(now);
|
//优先级
|
wrkMast.setIoPri(300.0);
|
//源站点
|
wrkMast.setSourceLocNo(sourceLocNo);
|
//目标站点
|
wrkMast.setLocNo(locNo);
|
//容器编码
|
wrkMast.setBarcode(barcode);
|
// 满板：Y
|
//wrkMast.setFullPlt("Y");
|
// 拣料
|
//wrkMast.setPicking("N");
|
// 退出
|
//wrkMast.setExitMk("N");
|
// 空板
|
//wrkMast.setEmptyMk("N");
|
//wrkMast.setLinkMis("N");
|
wrkMast.setAppeUser(userId);
|
wrkMast.setAppeTime(now);
|
wrkMast.setModiUser(userId);
|
wrkMast.setModiTime(now);
|
if (!agvWrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
|
return wrkMast;
|
}
|
|
/*
|
生成工作档
|
*/
|
@Deprecated
|
private AgvWrkMast createWrkMast(AgvBasDevp agvBasDevp,AgvLocMast agvLocMast, Date now, Long userId){
|
AgvWrkMast wrkMast = new AgvWrkMast();
|
//生成工作号
|
int workNo = agvCommonService.getWorkNo(0);
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(new Date());
|
// 工作状态：201.生成入库任务ID
|
wrkMast.setWrkSts(201L);
|
// 入出库状态：1.入库
|
wrkMast.setIoType(1);
|
//生成优先级
|
wrkMast.setIoPri(300.0);
|
wrkMast.setSourceLocNo(agvBasDevp.getDevNo());
|
wrkMast.setLocNo(agvLocMast.getLocNo());
|
wrkMast.setBarcode(agvBasDevp.getBarcode());
|
// 满板：Y
|
wrkMast.setFullPlt("Y");
|
// 拣料
|
wrkMast.setPicking("N");
|
// 退出
|
wrkMast.setExitMk("N");
|
// 空板
|
wrkMast.setEmptyMk("N");
|
wrkMast.setLinkMis("N");
|
wrkMast.setAppeUser(userId);
|
wrkMast.setAppeTime(now);
|
wrkMast.setModiUser(userId);
|
wrkMast.setModiTime(now);
|
if (!agvWrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
return wrkMast;
|
}
|
|
private boolean isPakOut(String locNo, double anfme){
|
AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));
|
if(agvLocDetl.getAnfme() > anfme){
|
return false;
|
}
|
return true;
|
}
|
|
/*
|
AGV生成出库工作档后修改订单信息
|
TODO 与四项库生成出库工作档后修改订单信息整合到一起
|
*/
|
private void modifyOrderDetl(LocDto locDto, Long userId){
|
|
if (!BaseController.isJSON(locDto.getOrderNo())) {
|
//非合并出库
|
OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
|
if (orderDetl == null) {
|
orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);
|
}
|
if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {
|
throw new CoolException("修改订单明细数量失败");
|
}
|
orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
|
}else {
|
//合并出库
|
List<OrderDto> orderDtoList = JSON.parseArray(locDto.getOrderNo(), OrderDto.class);
|
|
//实际出库数量
|
Double locAnfme = locDto.getAnfme();
|
//订单实际出库数量
|
Double orderAnfme;
|
|
for (OrderDto orderDto : orderDtoList) {
|
OrderDetl orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
|
if (orderDetl == null) {
|
orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), null);
|
}
|
|
if(locAnfme > orderDetl.getAnfme()){
|
orderAnfme = orderDetl.getAnfme();
|
locAnfme -= orderAnfme;
|
}else {
|
orderAnfme = locAnfme;
|
}
|
|
if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), orderAnfme)) {
|
throw new CoolException("修改订单明细数量失败");
|
}
|
orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
|
}
|
}
|
|
|
}
|
|
}
|
