From 00e1f09d1ce3ed8ab3a9976d7b7af7ef558625af Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期日, 15 十月 2023 16:41:21 +0800
Subject: [PATCH] AGV工作档取消和完成
---
src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java | 173 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 173 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
index 89e92c9..b8cbc8f 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
@@ -1,11 +1,184 @@
package com.zy.asrs.service.impl;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.core.common.Cools;
import com.zy.asrs.entity.AgvBasDevp;
+import com.zy.asrs.entity.AgvWaitPakin;
+import com.zy.asrs.entity.AgvWrkDetl;
+import com.zy.asrs.entity.AgvWrkMast;
import com.zy.asrs.mapper.AgvBasDevpMapper;
import com.zy.asrs.service.AgvBasDevpService;
+import com.zy.asrs.service.AgvWaitPakinService;
+import com.zy.asrs.service.AgvWrkDetlService;
+import com.zy.asrs.service.AgvWrkMastService;
+import com.zy.common.model.AgvBasDevpDto;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.*;
+import java.util.stream.Collectors;
@Service
+@Transactional
public class AgvBasDevpServiceImpl extends ServiceImpl<AgvBasDevpMapper, AgvBasDevp> implements AgvBasDevpService {
+
+ @Autowired
+ AgvBasDevpMapper agvBasDevpMapper;
+ @Autowired
+ AgvWrkMastService agvWrkMastService;
+ @Autowired
+ AgvWrkDetlService agvWrkDetlService;
+ @Autowired
+ AgvWaitPakinService agvWaitPakinService;
+
+ public void clearBasDevp(){
+ agvBasDevpMapper.deleteAll();
+ }
+
+ public void initBasDevp(){
+
+ //鍒濆鍖�1妤肩紦瀛樿揣鏋剁珯鐐� 2鎺�5鍒�3灞�
+ this.insertBatch(getCacheBasDevpList(1,2,1,5,1,3,1));
+ //鍒濆鍖�3妤肩紦瀛樿揣鏋剁珯鐐� 3鎺�5鍒�3灞�
+ this.insertBatch(getCacheBasDevpList(5,7,1,5,1,3,3));
+ //鍒濆鍖�3妤艰緭閫佺嚎宸ヤ綔绔欑偣 4涓珯鐐�
+ this.insertBatch(getLineBasDevpList());
+
+ }
+
+ private List<AgvBasDevp> getLineBasDevpList(){
+ List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
+ Date now = new Date();
+ for(int row=1; row<=4; row++){
+ agvBasDevpList.add(getAgvBasDevp(row,1,1,3,"N",now));
+ }
+ return agvBasDevpList;
+ }
+
+ //鏍规嵁鎺掑垪灞傝幏鍙朅GV缂撳瓨璐ф灦绔欑偣鍒楄〃
+ private List<AgvBasDevp> getCacheBasDevpList(int rowIndex, int rowMax, int bayIndex, int bayMax, int levIndex, int levMax, int floor){
+ List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
+ Date now = new Date();
+ for(int row=rowIndex; row<=rowMax; row++){
+ for(int bay=bayIndex; bay<=bayMax; bay++){
+ for(int lev=levIndex; lev<=levMax; lev++){
+ agvBasDevpList.add(getAgvBasDevp(row,bay,lev,floor,"Y",now));
+ }
+ }
+ }
+
+ return agvBasDevpList;
+ }
+
+ private AgvBasDevp getAgvBasDevp(int row, int bay, int lev, int floor, String cacheShelves, Date now){
+ AgvBasDevp agvBasDevp = new AgvBasDevp();
+ String devNo = "CS-" + floor + "0" + row + "-00" + bay + "-0" + lev + "@" + floor;
+ String stationCode = "CS-" + floor + "0" + row;
+ agvBasDevp.setDevNo(devNo);
+ agvBasDevp.setStationCode(stationCode);
+ agvBasDevp.setLocSts("O");
+ agvBasDevp.setCacheShelves(cacheShelves);
+ agvBasDevp.setFloor(floor);
+ agvBasDevp.setModiTime(now);
+ agvBasDevp.setAppeTime(now);
+ return agvBasDevp;
+ }
+
+ public void updateLocStsAndBarcodeByDevNo(String devNo, String locSts, String barcode){
+
+ AgvBasDevp agvBasDevp = this.selectById(devNo);
+ agvBasDevp.setLocSts(locSts);
+ agvBasDevp.setBarcode(barcode);
+ this.updateById(agvBasDevp);
+ }
+
+ public Map<String, Object> getAgvBasDevpDtoByStationCode(String stationCode) {
+
+ List<Map<String, Object>> body = new ArrayList<>();
+ for(int i=3; i>=1; i--){
+ List<AgvBasDevp> agvBasDevpList = this.selectList(new EntityWrapper<AgvBasDevp>()
+ .eq("station_code", stationCode)
+ .like("dev_no","0"+ i +"@"));
+
+ Map<String, Object> map = new HashMap<>();
+
+ List<AgvBasDevpDto> agvBasDevpDtoList = agvBasDevpList.stream().map(agvBasDevp -> {
+ AgvBasDevpDto agvBasDevpDto = new AgvBasDevpDto();
+ BeanUtils.copyProperties(agvBasDevp, agvBasDevpDto);
+
+ //濡傛灉宸ヤ綔浣嶇姸鎬佷负0.绌哄簱浣�,鍒欑洿鎺ヨ繑鍥�
+ if("O".equals(agvBasDevpDto.getLocSts())){
+ return agvBasDevpDto;
+ }
+
+ AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>()
+ .eq("loc_no", agvBasDevpDto.getDevNo())
+ .or().eq("source_loc_no",agvBasDevpDto.getDevNo()));
+
+ agvBasDevpDto.setAgvWrkMast(agvWrkMast);
+
+ if("F".equals(agvBasDevpDto.getLocSts()) || "R".equals(agvBasDevpDto.getLocSts())){
+ AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectOne(new EntityWrapper<AgvWaitPakin>()
+ .eq("supp_code", agvBasDevpDto.getBarcode()));
+
+ agvBasDevpDto.setAgvWaitPakin(agvWaitPakin);
+
+ if(Cools.isEmpty(agvWaitPakin)){
+ AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().
+ eq("wrk_no",agvWrkMast.getWrkNo()));
+
+ agvBasDevpDto.setAgvWrkDetl(agvWrkDetl);
+ }
+ }
+
+ if(!Cools.isEmpty(agvWrkMast)){
+ setFlagForAgvBasDevpDto(agvWrkMast,agvBasDevpDto);
+ }
+
+ return agvBasDevpDto;
+
+ }).collect(Collectors.toList());
+
+ map.put("loc",agvBasDevpDtoList);
+ body.add(map);
+ }
+
+ Map<String, Object> result = new HashMap<>();
+ result.put("body", body);
+
+ return result;
+ }
+
+ private void setFlagForAgvBasDevpDto(AgvWrkMast agvWrkMast, AgvBasDevpDto agvBasDevpDto){
+ //褰撳伐浣滄。绫诲瀷涓�101.鍑哄簱 骞朵笖 宸ヤ綔浣嶇姸鎬佷负F.鍦ㄥ簱鏃讹紝鏄剧ず瀹瑰櫒绂诲満鎸夐挳
+ if(agvWrkMast.getIoType() == 101 && "F".equals(agvBasDevpDto.getLocSts())){
+ agvBasDevpDto.setContainerMoveOutFlag(true);
+ }
+
+ //褰撳伐浣滄。绫诲瀷涓�101.鍑哄簱 骞朵笖 宸ヤ綔浣嶇姸鎬佷负F.鍦ㄥ簱鏃讹紝鏄剧ず瀹瑰櫒绂诲満鎸夐挳
+ if(agvWrkMast.getIoType() == 110 && "D".equals(agvBasDevpDto.getLocSts())){
+ agvBasDevpDto.setContainerMoveOutFlag(true);
+ }
+
+ //褰撳伐浣滄。绫诲瀷涓�103.鎷ｆ枡鍑哄簱 骞朵笖 宸ヤ綔浣嶇姸鎬佷负F.鍦ㄥ簱鏃讹紝鏄剧ず鎷ｆ枡/鐩樼偣鍏ュ簱鎸夐挳
+ if(agvWrkMast.getIoType() == 103 && "F".equals(agvBasDevpDto.getLocSts())){
+ agvBasDevpDto.setPickInFlag(true);
+ }
+ //褰撳伐浣滄。绫诲瀷涓�107.鐩樼偣鍑哄簱 骞朵笖 宸ヤ綔浣嶇姸鎬佷负F.鍦ㄥ簱鏃讹紝鏄剧ず鎷ｆ枡/鐩樼偣鍏ュ簱鎸夐挳
+ if(agvWrkMast.getIoType() == 107 && "F".equals(agvBasDevpDto.getLocSts())){
+ agvBasDevpDto.setPickInFlag(true);
+ }
+ }
+
+ public List<String> getAvailableEmptyInSite() {
+ return this.baseMapper.getAvailableEmptyInSite();
+ }
+
+ public AgvBasDevp getByDevNo(String devNo) {
+ return this.selectOne(new EntityWrapper<AgvBasDevp>().eq("dev_no",devNo));
+ }
+
}
--
Gitblit v1.9.1