From 551c12a53738e35cf615f3005d14215124488600 Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期五, 05 十二月 2025 16:51:09 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/handler/CreateOutTask.java | 199 +++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 199 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/handler/CreateOutTask.java b/src/main/java/com/zy/asrs/task/handler/CreateOutTask.java
new file mode 100644
index 0000000..7f91a68
--- /dev/null
+++ b/src/main/java/com/zy/asrs/task/handler/CreateOutTask.java
@@ -0,0 +1,199 @@
+package com.zy.asrs.task.handler;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+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.service.*;
+import com.zy.asrs.utils.Utils;
+import com.zy.common.model.StartupDto;
+import com.zy.common.service.CommonService;
+import com.zy.common.utils.HttpHandler;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.concurrent.ThreadLocalRandom;
+
+@Component
+@Slf4j
+public class CreateOutTask {
+ @Value("${wcs.address.URL}")
+ private String addrs;
+ @Value("${wcs.address.createOutTask}")
+ private String outTask;
+ @Value("${wcs.address.createLocMoveTask}")
+ private String locMoveTask;
+ @Value("${wcs.address.devicesStatus}")
+ private String devicesStatus;
+ @Autowired
+ private LocMastService locMastService;
+ @Autowired
+ private LocDetlService locDetlService;
+ @Autowired
+ private WrkMastService wrkMastService;
+ @Autowired
+ private CommonService commonService;
+ @Autowired
+ private WrkDetlService wrkDetlService;
+
+ @Scheduled(cron = "0/10 * * * * ? ")
+ @Transactional
+ public void outTask(){
+ //璋冪敤wcs鎺ュ彛鑾峰彇璁惧鐘舵��
+ String statusResponse = "";
+ try {
+ statusResponse = new HttpHandler.Builder()
+ .setUri(addrs)
+ .setPath(devicesStatus)
+ .build()
+ .doPost();
+ JSONObject jsonObject = JSON.parseObject(statusResponse);
+ if (jsonObject.get("code").equals(200)){
+ log.info("璁惧姝ｅ父");
+ }
+ }catch (Exception e){
+ log.error("璁惧寮傚父");
+ }
+ log.info("寮�濮嬭皟鐢╓CS鎺ュ彛,娲惧彂鍑哄簱/绉诲簱浠诲姟");
+ Date now = new Date();
+ boolean flag= false;
+ List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "F"));
+ List<Integer> outSitelist = new ArrayList<>();
+ outSitelist.add(1152);
+ outSitelist.add(1169);
+ outSitelist.add(1177);
+ LocMast shallowLocMast = new LocMast();
+ for (LocMast locMast : locMasts) {
+ //鍒ゆ柇搴撲綅鏄惁鏈夊嚭搴撲换鍔�
+ if (!Cools.isEmpty(wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("source_loc_no",locMast.getLocNo())))){
+ continue;
+ }
+ //鍒ゆ柇鏄惁鏄繁搴撲綅 瑙﹀彂绉诲簱浠诲姟
+ if (Utils.isDeepLoc(locMast.getLocNo())) {
+ String deepLoc = locMast.getLocNo();
+ String shallowLocNo = Utils.getShallowLocNo(deepLoc);
+ shallowLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
+ if (shallowLocMast.getLocSts().equals("F") || shallowLocMast.getLocSts().equals("D")) {
+ flag = true;
+ }
+ }
+ int outSite = ThreadLocalRandom.current().nextInt(0, outSitelist.size());
+ List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
+ // 鐩爣绔欑偣鐘舵�佹娴�
+ int workNo = commonService.getWorkNo(2);
+ //鐢熸垚宸ヤ綔妗�
+ WrkMast wrkMast = new WrkMast();
+ wrkMast.setWrkNo(workNo);
+ wrkMast.setIoTime(now);
+ wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+ wrkMast.setIoType(flag ? 11 : 101); // 鍏ュ嚭搴撶姸鎬�
+ wrkMast.setIoPri(flag ? 20D : 15D); // 浼樺厛绾�
+ wrkMast.setCrnNo(locMast.getCrnNo());
+ wrkMast.setStaNo(outSitelist.get(outSite)); // 鐩爣绔�
+ wrkMast.setSourceLocNo(flag ? shallowLocMast.getLocNo() : locMast.getLocNo()); // 婧愬簱浣�
+ wrkMast.setLocNo(flag ? getMoveLocNo(locMast.getLocNo()) : ""); //鐩爣搴撲綅
+ wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+ wrkMast.setPicking("N"); // 鎷ｆ枡
+ wrkMast.setExitMk("N"); // 閫�鍑�
+ wrkMast.setEmptyMk("N"); // 绌烘澘
+ wrkMast.setLinkMis("N");
+ wrkMast.setBarcode(locMast.getBarcode());
+ wrkMast.setAppeUser(9527L); // 鎿嶄綔浜哄憳鏁版嵁
+ wrkMast.setAppeTime(now);
+ wrkMast.setModiUser(9527l);
+ wrkMast.setModiTime(now);
+ if (!wrkMastService.insert(wrkMast)) {
+ throw new CoolException("淇濆瓨宸ヤ綔妗ｅけ璐ワ紝鍑哄簱搴撲綅鍙凤細" + locMast.getLocNo());
+ }
+ // 鐢熸垚宸ヤ綔妗ｆ槑缁�
+ for (LocDetl locDetl : locDetlList) {
+ if (locDetl.getAnfme() == null || locDetl.getAnfme() <= 0.0D) {
+ continue;
+ }
+ WrkDetl wrkDetl = new WrkDetl();
+ wrkDetl.sync(locDetl);
+ wrkDetl.setOrderNo(""); // 鎵嬪姩鍑哄簱涓嶉渶瑕佸甫鍑哄簱瀛樹腑鐨勫崟鎹紪鍙�
+ wrkDetl.setWrkNo(workNo);
+ wrkDetl.setIoTime(now);
+ Double anfme = locDetl.getAnfme();
+ wrkDetl.setAnfme(anfme); // 鏁伴噺
+ wrkDetl.setAppeTime(now);
+ wrkDetl.setAppeUser(9527L);
+ wrkDetl.setModiTime(now);
+ wrkDetl.setModiUser(9527L);
+ if (!wrkDetlService.insert(wrkDetl)) {
+ throw new CoolException("淇濆瓨宸ヤ綔妗ｆ槑缁嗗け璐�");
+ }
+ }
+ String response = "";
+ StartupDto startupDto = new StartupDto();
+ startupDto.setTaskNo(wrkMast.getWrkNo());
+ startupDto.setStaNo(wrkMast.getStaNo());
+ startupDto.setLocNo(Utils.locToLocNo(wrkMast.getSourceLocNo()));
+ startupDto.setTaskPri(wrkMast.getIoPri());
+ flag = false;
+ try {
+ response = new HttpHandler.Builder()
+ .setUri(addrs)
+ .setPath(flag ? locMoveTask : outTask)
+ .setJson(JSON.toJSONString(startupDto))
+ .build()
+ .doPost();
+ JSONObject jsonObject = JSON.parseObject(response);
+ if (jsonObject.get("code").equals(200)) {
+ wrkMast.setWrkSts(12L);
+ if (!wrkMastService.updateById(wrkMast)) {
+ throw new CoolException("宸ヤ綔妗ｇ姸鎬佷慨鏀瑰け璐�,宸ヤ綔鍙�:{}" + wrkMast.getWrkNo());
+ }
+ // 淇敼搴撲綅鐘舵��: F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷ｆ枡/鐩樼偣/骞舵澘鍑哄簱涓�
+ locMast = locMastService.selectById(flag?shallowLocMast.getLocNo():locMast.getLocNo());
+ if (locMast.getLocSts().equals("F")) {
+ locMast.setLocSts("R");
+ locMast.setModiUser(9527L);
+ locMast.setModiTime(now);
+ if (!locMastService.updateById(locMast)) {
+ throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細" + locMast.getLocNo());
+ }
+ } else {
+ throw new CoolException(locMast.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+ }
+ log.info("鍑哄簱/绉诲簱浠诲姟娲惧彂鎴愬姛");
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+ }
+ }
+ }
+
+ //绉诲簱浠诲姟鎵剧┖搴撲綅 娣卞簱浣�
+ public String getMoveLocNo(String locNo){
+ LocMast targetLocMast = new LocMast();
+ int deepRow = Utils.getRow(locNo);
+ //鍏堟壘娣卞簱浣嶈繖涓�鎺掕繕鏈夋病鏈夌┖浣嶅簱
+ targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow));
+ if (targetLocMast == null){
+ targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 3));
+
+ }
+ if (targetLocMast == null){
+ targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 1));
+
+ }
+ if (targetLocMast == null){
+ targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 2));
+
+ }
+ return targetLocMast.getLocNo();
+ }
+}
--
Gitblit v1.9.1