package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.entity.result.WorkIssuedResult;
|
import com.zy.asrs.entity.result.WrkPriority;
|
import com.zy.asrs.service.ApiLogService;
|
import com.zy.asrs.service.WrkMastService;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.asrs.utils.Utils;
|
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.text.DateFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
@Transactional
|
public class WCSReportHandler extends AbstractHandler<String> {
|
@Value("${wcs-slave.url}")
|
private String url;
|
@Value("${wcs-slave.workIssued}")
|
private String workIssued;
|
@Value("${wcs-slave.priority}")
|
private String priority;
|
@Value("${wcs-slave.inDevp}")
|
private String inDevp;
|
@Value("${wcs-slave.outDevp}")
|
private String outDevp;
|
@Value("${wcs-slave.warehouse}")
|
private String warehouse;
|
static String namespace = null;
|
@Autowired
|
private ApiLogService apiLogService;
|
@Autowired
|
private WrkMastService wrkMastService;
|
|
public ReturnT<String> start(WrkMast wrkMast,int i) {
|
WorkIssuedResult workIssuedResult = new WorkIssuedResult();
|
|
Date date = new Date();
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String groupId = dateFormat.format(date)+"-"+i;
|
workIssuedResult.setGroupId(groupId);//组号
|
workIssuedResult.setMsgTime(dateFormat.format(date));
|
workIssuedResult.setWarehouse("ZYNMG");
|
|
List<WorkIssuedResult.Tasks> tasks = new ArrayList<>();
|
WorkIssuedResult.Tasks task = new WorkIssuedResult.Tasks();
|
task.setTaskId(wrkMast.getWrkNo().toString());
|
task.setBarCode(wrkMast.getBarcode());
|
// task.setOrder(i);
|
task.setOrder(wrkMast.getIoPri().intValue());
|
String LocNo = null;
|
String sourceLocNo = null;
|
//优先级排序 15.出库>14.入库>13.空板出库>12.空板入库>11.移库
|
if(wrkMast.getIoType() == 1 || wrkMast.getIoType() == 53 || wrkMast.getIoType() == 57){//入库
|
workIssuedResult.setPriorityCode(14);//优先级
|
task.setTaskType(0);//入库
|
task.setStartNode(inDevp);
|
LocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getLocNo()),Utils.getBay(wrkMast.getLocNo()),Utils.getLev(wrkMast.getLocNo()));
|
task.setEndNode(LocNo);//目标库位
|
task.setCargoSize(null);
|
switch (wrkMast.getIoType()){
|
case 1: namespace= "全板入库下发";break;
|
case 53: namespace= "拣料再入库下发";break;
|
case 57: namespace= "盘点再入库下发";break;
|
}
|
|
}else if(wrkMast.getIoType() == 10 ){//空板入库
|
workIssuedResult.setPriorityCode(12);//优先级
|
task.setTaskType(0);//入库
|
task.setStartNode(inDevp);
|
LocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getLocNo()),Utils.getBay(wrkMast.getLocNo()),Utils.getLev(wrkMast.getLocNo()));
|
task.setEndNode(LocNo);//目标库位
|
task.setCargoSize(null);
|
namespace = "空板入库";
|
|
}else if(wrkMast.getIoType() == 101 || wrkMast.getIoType() == 103 || wrkMast.getIoType() == 107){//出库
|
workIssuedResult.setPriorityCode(15);//优先级
|
task.setTaskType(1);//出库
|
sourceLocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getSourceLocNo()),Utils.getBay(wrkMast.getSourceLocNo()),Utils.getLev(wrkMast.getSourceLocNo()));
|
task.setStartNode(sourceLocNo);//源库位
|
task.setEndNode(outDevp);
|
task.setCargoSize(null);
|
switch (wrkMast.getIoType()){
|
case 101: namespace= "全板出库下发";break;
|
case 103: namespace= "拣料出库下发";break;
|
case 107: namespace= "盘点出库下发";break;
|
}
|
|
}else if(wrkMast.getIoType() == 11){//移库
|
workIssuedResult.setPriorityCode(11);//优先级
|
task.setTaskType(2);//移库
|
sourceLocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getSourceLocNo()),Utils.getBay(wrkMast.getSourceLocNo()),Utils.getLev(wrkMast.getSourceLocNo()));
|
LocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getLocNo()),Utils.getBay(wrkMast.getLocNo()),Utils.getLev(wrkMast.getLocNo()));
|
task.setStartNode(sourceLocNo);//源库位
|
task.setEndNode(LocNo);//目标库位
|
task.setCargoSize(null);
|
namespace = "移库下发";
|
} else {//空板出库
|
workIssuedResult.setPriorityCode(13);//优先级
|
task.setTaskType(1);//出库
|
sourceLocNo = Utils.getLocNoToWcs(Utils.getRow(wrkMast.getSourceLocNo()),Utils.getBay(wrkMast.getSourceLocNo()),Utils.getLev(wrkMast.getSourceLocNo()));
|
task.setStartNode(sourceLocNo);//源库位
|
task.setEndNode(outDevp);
|
task.setCargoSize(null);
|
namespace = "空板出库下发";
|
}
|
tasks.add(task);
|
workIssuedResult.setTasks(tasks);
|
String response = "";
|
boolean success = false;
|
try {
|
response = new HttpHandler.Builder()
|
.setUri(url)
|
.setPath(workIssued)
|
.setJson(JSON.toJSONString(workIssuedResult))
|
.build()
|
.doPost();
|
JSONObject jsonObject = JSON.parseObject(response);
|
if (jsonObject.getInteger("returnStatus").equals(0)) {
|
success = true;
|
wrkMast.setWrkSts(1L);
|
wrkMastService.updateById(wrkMast);
|
} else {
|
log.error("{}}下发任务给wcs失败！！！url：{}；request：{}；response：{}",namespace, url+"/"+workIssued, JSON.toJSONString(workIssuedResult), response);
|
throw new CoolException("wms下发任务给wcs失败");
|
}
|
} catch (Exception e) {
|
log.error("fail", e);
|
// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
return FAIL.setMsg(e.getMessage());
|
} finally {
|
try {
|
// 保存接口日志
|
apiLogService.save(
|
namespace,
|
url+"/"+workIssued,
|
null,
|
"127.0.0.1",
|
JSON.toJSONString(workIssuedResult),
|
response,
|
success
|
);
|
} catch (Exception e) { log.error("", e); }
|
}
|
|
return null;
|
}
|
|
//任务优先级调整 调用wcs接口 通知wcs
|
public ReturnT<String> notice(WrkMast wrkMast) {
|
WrkPriority wrkPriority = new WrkPriority();
|
Date date = new Date();
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
wrkPriority.setTaskId(wrkMast.getWrkNo().toString()); // 任务号
|
wrkPriority.setWarehouse(warehouse); // 仓库编码
|
wrkPriority.setPriorityCode(wrkMast.getIoPri().intValue()); // 优先级
|
wrkPriority.setMsgTime(dateFormat.format(date)); // 调整时间
|
|
String response = "";
|
boolean success = false;
|
try {
|
response = new HttpHandler.Builder()
|
.setUri(url)
|
.setPath(priority)
|
.setJson(JSON.toJSONString(wrkPriority))
|
.build()
|
.doPost();
|
JSONObject jsonObject = JSON.parseObject(response);
|
if (jsonObject.getInteger("returnStatus").equals(0)) {
|
success = true;
|
wrkMast.setWrkSts(1L);
|
wrkMastService.updateById(wrkMast);
|
} else {
|
log.error("wms调整优先级下发给wcs失败！！！url：{}；request：{}；response：{}", url + "/" + workIssued, JSON.toJSONString(wrkPriority), response);
|
throw new CoolException("wms调整优先级下发给wcs失败");
|
}
|
} catch (Exception e) {
|
log.error("fail", e);
|
return FAIL.setMsg(e.getMessage());
|
} finally {
|
try {
|
// 保存接口日志
|
apiLogService.save(
|
"wms调整优先级下发给wcs",
|
url + "/" + workIssued,
|
null,
|
"127.0.0.1",
|
JSON.toJSONString(wrkPriority),
|
response,
|
success
|
);
|
} catch (Exception e) {
|
log.error("", e);
|
}
|
}
|
return null;
|
}
|
}
|
