From dfc9552392f9f973ab52e55d58a7ae2acdaeb1f3 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期日, 09 三月 2025 14:19:43 +0800
Subject: [PATCH] 四期
---
src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java | 200 ++++++++++++++++++++++++++++++++++---------------
1 files changed, 137 insertions(+), 63 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
index 7b2dde8..57823ab 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
@@ -7,7 +7,11 @@
import com.core.common.Cools;
import com.core.common.SnowflakeIdWorker;
import com.core.exception.CoolException;
-import com.zy.asrs.entity.*;
+import com.zy.asrs.constant.AsrsConstants;
+import com.zy.asrs.entity.AgvLocDetl;
+import com.zy.asrs.entity.AgvLocMast;
+import com.zy.asrs.entity.AgvWrkDetl;
+import com.zy.asrs.entity.OrderDetl;
import com.zy.asrs.mapper.AgvLocDetlMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.Utils;
@@ -54,13 +58,18 @@
List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", taskCode));
long flowId = snowflakeIdWorker.nextId();
agvWrkDetls.stream().map(agvWrkDetl -> {
- AgvLocDetl agvLocDetl = new AgvLocDetl();
- log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
- BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
- agvLocDetl.setLocNo(locNo);
- this.insert(agvLocDetl);
- // 娴佹按 -- 鏂板璁㈠崟鏄庣粏
- OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getThreeCode());
+ AgvLocDetl agvLocDetl = this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", agvWrkDetl.getMatnr()).eq("three_code", agvWrkDetl.getThreeCode()));
+ if (agvLocDetl != null) {
+ this.updateAnfme(agvLocDetl.getAnfme() + agvWrkDetl.getAnfme(), agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getBatch(), agvLocDetl.getThreeCode(), agvLocDetl.getDeadTime());
+ } else {
+ agvLocDetl = new AgvLocDetl();
+ //log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
+ BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
+ agvLocDetl.setLocNo(locNo);
+ //log.info("zc娣诲姞搴撳瓨鏃ュ織:{}", JSON.toJSON(agvLocDetl));
+ this.insert(agvLocDetl);
+ // 娴佹按 -- 鏂板璁㈠崟鏄庣粏
+ OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode());
// FlowLog flowLog = new FlowLog();
// flowLog.setFid(String.valueOf(flowId));
// flowLog.setSpare2(String.valueOf(taskCode));
@@ -86,44 +95,56 @@
// if (!flowLogService.insert(flowLog)) {
// throw new CoolException("鍚屾鍗婃垚鍝佽皟鎷ㄥ崟娴佹按璁板綍澶辫触");
// }
+ }
return agvLocDetl;
}).collect(Collectors.toList());
}
- public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq,String type) {
+ public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq, String type) {
//鏍规嵁鐗╂枡鍙峰拰鎵规鎵惧埌瀵瑰簲鐨勫簱瀛橈紝骞朵笖鎸夌収淇敼鏃堕棿鎺掑簭
Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).orderBy("modi_time");
if (type != null) {
- wrapper.notLike("loc_no", "F1");
+ if (type.equals(AsrsConstants.ERCHANG)) {
+ wrapper.notLike("loc_no", "F3");
+ } else {
+ if (matnr.startsWith("401") || matnr.startsWith("402")) {
+ //wrapper.notLike("loc_no", "F3");
+ wrapper.notLike("loc_no", "F1");
+ } else {
+ wrapper.notLike("loc_no", "F1");
+ }
+ }
}
- wapperSetCondition(wrapper,"batch",batch);
- wapperSetCondition(wrapper,"three_code",csocode);
- wapperSetCondition(wrapper,"dead_time",isoseq);
+ //涓�鐩存湁PE甯︽壒娆″瓧娈靛鑷达紝鏃犳硶鍑哄簱锛屽氨娉ㄩ噴鎺�
+ //wapperSetCondition(wrapper, "batch", batch);
+ wapperSetCondition(wrapper, "three_code", csocode);
+ //wapperSetCondition(wrapper, "dead_time", isoseq);
- if ("JG".equals(orderNo.substring(0,2))) {
- wapperSetCondition(wrapper,"process_sts","1");
+ if ("JG".equals(orderNo.substring(0, 2))) {
+ wapperSetCondition(wrapper, "process_sts", "1");
}
List<AgvLocDetl> agvLocDetls = this.selectList(wrapper);
- for (AgvLocDetl agvLocDetl: agvLocDetls) {
+
+ for (AgvLocDetl agvLocDetl : agvLocDetls) {
//鍒ゆ柇褰撳墠搴撲綅璐х墿鏄惁F鍦ㄥ簱
AgvLocMast agvLocMast = agvLocMastService.selectById(agvLocDetl.getLocNo());
- if(!"F".equals(agvLocMast.getLocSts())){
+ if (!"F".equals(agvLocMast.getLocSts())) {
continue;
}
//濡傛灉璁㈠崟鍓╀綑鍑哄簱閲忓ぇ浜�0
- if(issued > 0) {
+ if (issued > 0) {
//褰撳墠搴撲綅鐨勫簱瀛橀噺
double anfme = agvLocDetl.getAnfme();
//int ioType = anfme > issued ? 101 : 103;
anfme = anfme > issued ? issued : anfme;
//鐢ㄤ簬鏄剧ず宸ヤ綔鏄庣粏妗ｇ殑璁㈠崟鍙�
- String orderNoWrkDtel = Utils.getOrderNo(orderNo,anfme);
+ String orderNoWrkDtel = Utils.getOrderNo(orderNo, anfme);
//鏇存柊璁㈠崟鏁伴噺
- orderNo = Utils.orderMergeUpdate(orderNo,anfme);
- LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNoWrkDtel, anfme,agvLocDetl.getProcessSts());
+ orderNo = Utils.orderMergeUpdate(orderNo, anfme);
+ LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNoWrkDtel, anfme, agvLocDetl.getProcessSts());
locDto.setCsocode(csocode);
locDto.setIsoseq(isoseq);
locDto.setContainerCode(agvLocDetl.getSuppCode());
@@ -131,7 +152,39 @@
//褰撳墠搴撲綅鎵�澶勬ゼ灞�
int floor = Integer.parseInt(agvLocDetl.getLocNo().split("F")[1]);
//locDto.setAgvStaNos(queryAgvStaNosByFloor(floor));
- locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(),floor));
+ //鍥涙湡
+ //locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(), floor));
+
+ List<String> strings = agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1());
+ List<String> agvStaNos = new ArrayList<>();
+ if (agvLocDetl.getLocNo().contains("01F1")) {
+ for (String string : strings) {
+ if (string.contains("F1") || string.contains("F4")) {
+ agvStaNos.add(string);
+ }
+ }
+ } else if (agvLocDetl.getLocNo().contains("02F1")) {
+ for (String string : strings) {
+ if (string.contains("F1") || string.contains("F4")) {
+ agvStaNos.add(string);
+ }
+ }
+ } else if (agvLocDetl.getLocNo().contains("F2")) {
+ for (String string : strings) {
+ if (string.contains("F2") || string.contains("F4")) {
+ agvStaNos.add(string);
+ }
+ }
+ } else if (agvLocDetl.getLocNo().contains("F3")) {
+ for (String string : strings) {
+ if (string.contains("F3")) {
+ agvStaNos.add(string);
+ }
+ }
+ } else {
+ agvStaNos = strings;
+ }
+ locDto.setAgvStaNos(agvStaNos);
locDtoList.add(locDto);
issued -= anfme;
@@ -142,11 +195,12 @@
}
+
/*
鏇存柊搴撳瓨鏄庣粏
*/
public void updateStock(String sourceLoc, String targetLoc) {
- this.baseMapper.updateStock(sourceLoc,targetLoc);
+ this.baseMapper.updateStock(sourceLoc, targetLoc);
}
public Page<AgvLocDetl> getStockStatis(Page<AgvLocDetl> page) {
@@ -161,8 +215,19 @@
}
@Override
+ public Double getSumAnfme2(String matnr, String threeCode) {
+ return this.baseMapper.selectSumAnfmeByMatnr2(matnr, threeCode);
+ }
+
+
+ @Override
public AgvLocDetl selectItem(String locNo, String matnr, String batch, String csocode, String isoCode) {
- return this.baseMapper.selectItemByOrderNo(locNo, matnr, batch,csocode,isoCode);
+ return this.baseMapper.selectItemByOrderNo(locNo, matnr, batch, csocode, isoCode);
+ }
+
+ @Override
+ public List<AgvLocDetl> selectItem2(String locNo, String matnr, String batch, String csocode, String isoCode) {
+ return this.baseMapper.selectItemByOrderNo2(locNo, matnr, batch, csocode, isoCode);
}
@Override
@@ -176,12 +241,22 @@
}
@Override
- public Double getSumAnfmeDb(String matnr, String threeCode,Integer floor) {
- return this.baseMapper.selectSumAnfmeByMatnr2(matnr, threeCode, floor);
+ public Double getSumAnfmeProcessed2(String matnr, String threeCode) {
+ return this.baseMapper.selectSumAnfmeByMatnrProcessed2(matnr, threeCode);
}
@Override
- public Double getSumAnfmeback(String matnr, String threeCode,Integer floor) {
+ public Double getSumAnfmeDb(String matnr, String threeCode, Integer floor) {
+ return this.baseMapper.selectSumAnfmeByMatnr22(matnr, threeCode, floor);
+ }
+
+ @Override
+ public Double getSumAnfmeDb2(String matnr, String threeCode, Integer floor) {
+ return this.baseMapper.selectSumAnfmeByMatnr3(matnr, threeCode, floor);
+ }
+
+ @Override
+ public Double getSumAnfmeback(String matnr, String threeCode, Integer floor) {
return this.baseMapper.getSumAnfmeback(matnr, threeCode, floor);
}
@@ -192,7 +267,7 @@
return this.baseMapper.sum();
}
- public List<AgvLocDetl> getStockStatisExcel(){
+ public List<AgvLocDetl> getStockStatisExcel() {
return this.baseMapper.getStockStatisExcel();
}
@@ -201,20 +276,20 @@
return new ArrayList<AgvLocDetl>();
}
EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
- if(Cools.isEmpty(orderNo)){
- wrapper.like("order_no",orderNo);
+ if (Cools.isEmpty(orderNo)) {
+ wrapper.like("order_no", orderNo);
}
- if(Cools.isEmpty(matnr)){
- wrapper.like("matnr",matnr);
+ if (Cools.isEmpty(matnr)) {
+ wrapper.like("matnr", matnr);
}
- if(Cools.isEmpty(maktx)){
- wrapper.like("maktx",maktx);
+ if (Cools.isEmpty(maktx)) {
+ wrapper.like("maktx", maktx);
}
- if(Cools.isEmpty(specs)){
- wrapper.like("specs",specs);
+ if (Cools.isEmpty(specs)) {
+ wrapper.like("specs", specs);
}
- if(Cools.isEmpty()){
- wrapper.like("loc_no",locNo);
+ if (Cools.isEmpty()) {
+ wrapper.like("loc_no", locNo);
}
return this.selectList(wrapper);
}
@@ -222,42 +297,42 @@
public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch, String csocode, String isocode) {
EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
wrapper.eq("loc_no", locNo);
- Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode);
+ Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode);
if (anfme <= 0) {
- return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0;
+ return this.baseMapper.deleteLocDetl(locNo, anfme, matnr, batch, csocode, isocode) > 0;
} else {
AgvLocDetl agvLocDetl = this.selectOne(wrapper);
agvLocDetl.setAnfme(anfme);
agvLocDetl.setModiTime(new Date());
- return this.baseMapper.updateAnfme(locNo,anfme,matnr,batch,csocode,isocode) > 0;
+ return this.baseMapper.updateAnfme(locNo, anfme, matnr, batch, csocode, isocode) > 0;
}
}
public boolean updateAnfmeProcess(Double anfme, String locNo, String matnr, String batch, String csocode, String isocode, Integer process) {
EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
wrapper.eq("loc_no", locNo);
- Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode);
+ Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode);
if (anfme <= 0) {
- return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0;
+ return this.baseMapper.deleteLocDetl(locNo, anfme, matnr, batch, csocode, isocode) > 0;
} else {
AgvLocDetl agvLocDetl = this.selectOne(wrapper);
agvLocDetl.setAnfme(anfme);
agvLocDetl.setModiTime(new Date());
- return this.baseMapper.updateAnfmeProcess(locNo,anfme,matnr,batch,csocode,isocode,process) > 0;
+ return this.baseMapper.updateAnfmeProcess(locNo, anfme, matnr, batch, csocode, isocode, process) > 0;
}
}
- private void wapperSetCondition(Wrapper wrapper,String column, String condition){
- if(Cools.isEmpty(condition)){
- wrapper.andNew().eq(column,"").or().isNull(column);
- }else {
- wrapper.andNew().eq(column,condition);
+ private void wapperSetCondition(Wrapper wrapper, String column, String condition) {
+ if (Cools.isEmpty(condition)) {
+ wrapper.andNew().eq(column, "").or().isNull(column);
+ } else {
+ wrapper.andNew().eq(column, condition);
}
}
- public AgvLocDetl selectByLocNo(String locNo){
- return this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no",locNo));
+ public AgvLocDetl selectByLocNo(String locNo) {
+ return this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));
}
@Override
@@ -265,7 +340,7 @@
List<AgvLocDetl> agvLocDetls = new ArrayList<>();
taskDto.getLocDtos().forEach(locDto -> {
- AgvLocDetl agvLocDetl = this.selectByMatnrAndBatchAndCsocodeAndisoCode(locDto.getLocNo(),locDto.getMatnr(), locDto.getBatch(), locDto.getCsocode(), locDto.getIsoseq());
+ AgvLocDetl agvLocDetl = this.selectByMatnrAndBatchAndCsocodeAndisoCode(locDto.getLocNo(), locDto.getMatnr(), locDto.getBatch(), locDto.getCsocode(), locDto.getIsoseq());
agvLocDetls.add(agvLocDetl);
});
return agvLocDetls;
@@ -274,16 +349,16 @@
@Override
public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode(String locNo, String matnr, String batch, String csocode, String isocode) {
EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
- wrapper.eq("loc_no",locNo);
- Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode);
+ wrapper.eq("loc_no", locNo);
+ Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode);
return this.selectOne(wrapper);
}
@Override
- public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode2(String locNo,String orderNo, String matnr, String batch, String csocode, String isocode) {
+ public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode2(String locNo, String orderNo, String matnr, String batch, String csocode, String isocode) {
EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
- wrapper.eq("loc_no",locNo);
- Utils.confirmOnlyMat2(wrapper,orderNo,matnr,batch,csocode,isocode);
+ wrapper.eq("loc_no", locNo);
+ Utils.confirmOnlyMat2(wrapper, orderNo, matnr, batch, csocode, isocode);
return this.selectOne(wrapper);
}
@@ -299,7 +374,7 @@
@Override
public AgvLocDetl selectLocdetl(String locNo, String matnr, String batch, String csocode, String isocode) {
- return this.baseMapper.selectLocdetl(locNo,matnr,batch,csocode,isocode);
+ return this.baseMapper.selectLocdetl(locNo, matnr, batch, csocode, isocode);
}
@Override
@@ -314,8 +389,7 @@
try {
if (excelVersion == 2003) {
book = new HSSFWorkbook(inStream);
- }
- else { // 褰� excel 鏄� 2007 鏃�
+ } else { // 褰� excel 鏄� 2007 鏃�
book = new XSSFWorkbook(inStream);
}
} catch (Exception e) {
@@ -335,10 +409,10 @@
String containerCode = dataFormatter.formatCellValue(row.getCell(1));
List<AgvLocDetl> agvLocDetls = this.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("supp_code", containerCode));
- if(Cools.isEmpty(agvLocDetls)){
+ if (Cools.isEmpty(agvLocDetls)) {
log.info("搴撲綅鍙凤細" + locNo + "锛岃揣鏋剁爜锛�" + containerCode + "锛屼笉瀛樺湪鏄庣粏");
}
- if(agvLocDetls.size()>1){
+ if (agvLocDetls.size() > 1) {
log.info("搴撲綅鍙凤細" + locNo + "锛岃揣鏋剁爜锛�" + containerCode + "锛屽瓨鍦�1鏉′互涓婅褰�");
}
}
@@ -346,6 +420,6 @@
@Override
public void updateLocNo(String locNo, String sourceLoc, AgvLocDetl agvLocDetl) {
- this.baseMapper.updateLocNo(locNo,sourceLoc,agvLocDetl.getSuppCode());
+ this.baseMapper.updateLocNo(locNo, sourceLoc, agvLocDetl.getSuppCode());
}
}
--
Gitblit v1.9.1