package com.zy.asrs.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.LocMast;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.service.*;
|
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.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.concurrent.TimeUnit;
|
@Slf4j
|
@Service
|
public class WorkServiceImpl implements WorkService {
|
|
@Autowired
|
private WrkMastService wrkMastService;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private WaitPakinService waitPakinService;
|
@Autowired
|
private WrkMastLogService wrkMastLogService;
|
@Autowired
|
private WrkDetlLogService wrkDetlLogService;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private ApiLogService apiLogService;
|
@Value("${wms.url}")
|
private String wmsUrl;
|
@Value("${wms.inboundTaskApplyPath}")
|
private String inboundTaskApplyPath;
|
@Value("${wms.movePath}")
|
private String movePath;
|
@Value("${wms.taskStatusFeedbackPath}")
|
private String taskStatusFeedbackPath;
|
|
@Override
|
@Transactional
|
public void completeWrkMast(String workNo, Long userId) {
|
WrkMast wrkMast = wrkMastService.selectById(workNo);
|
if (Cools.isEmpty(wrkMast)) {
|
throw new CoolException(workNo + "工作档不存在");
|
}
|
if (wrkMast.getWrkSts() == 4 || wrkMast.getWrkSts() == 14) {
|
throw new CoolException("当前工作档已完成");
|
}
|
// 入库 + 库位转移
|
if (wrkMast.getWrkSts() < 4 || (wrkMast.getWrkSts() > 10 && wrkMast.getIoType() == 11)) {
|
wrkMast.setWrkSts(4L);
|
// 出库
|
} else if (wrkMast.getWrkSts() > 10) {
|
wrkMast.setWrkSts(14L);
|
}
|
Date now = new Date();
|
wrkMast.setCrnStrTime(DateUtils.calculate(now, 1L, TimeUnit.SECONDS, true));
|
wrkMast.setCrnEndTime(now);
|
wrkMast.setModiTime(now);
|
wrkMast.setModiUser(userId);
|
// 完成操作人员记录
|
wrkMast.setManuType("手动完成");
|
if (!wrkMastService.updateById(wrkMast)) {
|
throw new CoolException("修改工作档失败");
|
}
|
|
HashMap<String,Object> headParam = new HashMap<>();
|
headParam.put("TaskNo",wrkMast.getTaskNo());
|
headParam.put("Result",0);//完成
|
|
try {
|
String response;
|
log.error("wcs手动完结任务上报wms={}", wrkMast);
|
|
response = new HttpHandler.Builder()
|
// .setHeaders(headParam)
|
.setUri(wmsUrl)
|
.setPath(taskStatusFeedbackPath)
|
.setJson(JSON.toJSONString(headParam))
|
.build()
|
.doPost();
|
apiLogService.save("wcs手动完成任务上报wms"
|
, wmsUrl + taskStatusFeedbackPath
|
, null
|
, "127.0.0.1"
|
, JSON.toJSONString(headParam)
|
, response
|
, true
|
);
|
} catch (Exception e) {
|
log.error("wcs手动完结任务上报wms失败={}", wrkMast);
|
log.error("wcs手动完结任务上报wms失败,报错信息：", e);
|
// throw new CoolException("wcs派发入库任务上报wms失败");
|
}
|
}
|
|
@Override
|
@Transactional
|
public void cancelWrkMast(String workNo, Long userId) {
|
Date now = new Date();
|
WrkMast wrkMast = wrkMastService.selectById(workNo);
|
|
String locNo = ""; // 待修改目标库位
|
String locSts = ""; // 待修改目标库位状态
|
// 入库取消（修改目标库位）
|
if (wrkMast.getWrkSts() < 4) {
|
locNo = wrkMast.getLocNo();
|
locSts = "O";
|
|
// 库位转移
|
if (wrkMast.getIoType() == 11) {
|
// 库位转移：源库位
|
LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
|
if (Cools.isEmpty(locMast)) {
|
throw new CoolException("取消库位转移失败，源库位不存在:" + wrkMast.getSourceLocNo());
|
}
|
locMast.setLocSts(wrkMast.getFullPlt().equalsIgnoreCase("N") ? "D" : "F");
|
locMast.setModiTime(now);
|
locMast.setModiUser(userId);
|
locMastService.updateById(locMast);
|
}
|
// 出库取消（修改源库位）
|
} else if (wrkMast.getWrkSts() > 10 && wrkMast.getWrkSts() != 14) {
|
locNo = wrkMast.getSourceLocNo();
|
// 出库 ===>> F.在库
|
if (wrkMast.getIoType() > 100 && wrkMast.getIoType() != 110) {
|
locSts = "F";
|
// 空板出库 ===>> D.空桶/空栈板
|
} else if (wrkMast.getIoType() == 110) {
|
locSts = "D";
|
// 库位转移 ===>> D.空桶/空栈板
|
} else if (wrkMast.getIoType() == 11) {
|
locSts = wrkMast.getFullPlt().equalsIgnoreCase("N") ? "D" : "F";
|
// 库位转移：目标库位
|
LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
|
if (Cools.isEmpty(locMast)) {
|
throw new CoolException("取消库位转移失败，目标库位不存在:" + wrkMast.getSourceLocNo());
|
}
|
locMast.setLocSts("O");
|
locMast.setModiTime(now);
|
locMast.setModiUser(userId);
|
locMastService.updateById(locMast);
|
}
|
} else {
|
throw new CoolException("当前工作状态无法取消");
|
}
|
// 取消操作人员记录
|
wrkMast.setManuType("手动取消");
|
wrkMast.setModiUser(userId);
|
wrkMast.setModiTime(now);
|
if (!wrkMastService.updateById(wrkMast)) {
|
throw new CoolException("取消任务失败");
|
}
|
// 保存工作主档历史档
|
if (!wrkMastLogService.save(wrkMast.getWrkNo())) {
|
throw new CoolException("保存任务历史档失败, workNo = " + wrkMast.getWrkNo());
|
}
|
|
// 删除工作主档
|
boolean wrkMastRes = wrkMastService.deleteById(wrkMast);
|
|
// 修改库位状态
|
LocMast locMast = locMastService.selectById(locNo);
|
if (Cools.isEmpty(locMast)) {
|
throw new CoolException("取消任务失败，库位不存在:" + locNo);
|
}
|
locMast.setLocSts(locSts);
|
locMast.setModiTime(now);
|
locMast.setModiUser(userId);
|
boolean locMastRes = locMastService.updateById(locMast);
|
if (!wrkMastRes || !locMastRes) {
|
throw new CoolException("保存数据失败");
|
}
|
HashMap<String,Object> headParam = new HashMap<>();
|
headParam.put("TaskNo",wrkMast.getTaskNo());
|
headParam.put("Result",1);//取消
|
|
try {
|
String response;
|
log.error("wcs手动取消任务上报wms={}", wrkMast);
|
|
response = new HttpHandler.Builder()
|
// .setHeaders(headParam)
|
.setUri(wmsUrl)
|
.setPath(taskStatusFeedbackPath)
|
.setJson(JSON.toJSONString(headParam))
|
.build()
|
.doPost();
|
apiLogService.save("wcs手动取消任务上报wms"
|
, wmsUrl + taskStatusFeedbackPath
|
, null
|
, "127.0.0.1"
|
, JSON.toJSONString(headParam)
|
, response
|
, true
|
);
|
} catch (Exception e) {
|
log.error("wcs手动取消任务上报wms失败={}", wrkMast);
|
log.error("wcs手动取消任务上报wms失败,报错信息：", e);
|
// throw new CoolException("wcs派发入库任务上报wms失败");
|
}
|
}
|
}
|
