package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.BasDevp;
|
import com.zy.asrs.entity.Mat;
|
import com.zy.asrs.entity.WrkDetl;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.task.core.ReturnT;
|
|
import com.zy.common.constant.MesConstant;
|
import com.zy.common.constant.OpenApiAddressConstant;
|
import com.zy.common.utils.HttpHandler;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
|
/**
|
* @author pang.jiabao
|
* @description 冠鸿龙南定时任务具体实现
|
* @createDate 2024/7/10 9:28
|
*/
|
@Slf4j
|
@Service
|
public class GhlnHandler {
|
|
@Resource
|
private WrkMastService wrkMastService;
|
|
@Resource
|
private BasDevpService basDevpService;
|
|
@Resource
|
private WrkDetlService wrkDetlService;
|
|
@Autowired
|
private ApiLogService apiLogService;
|
|
@Autowired
|
private LoginAuthHandler loginAuthHandler;
|
|
@Resource
|
private MatService matService;
|
|
/**
|
* 出库到达出库目标站时，调用AGV开放出库接口
|
*/
|
public void sendOutboundTaskToAGV() {
|
// 获取agv出库站点信息,并判断站点状态
|
BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", 305));
|
if (basDevp != null && basDevp.getWrkNo() != 0 && basDevp.getOutEnable().equals("Y")) {
|
// 判断是出库任务
|
WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo())
|
.eq("plt_type",0));
|
List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", basDevp.getWrkNo()));
|
if (wrkMast != null && wrkMast.getIoType() == 101 && !wrkDetls.isEmpty()) {
|
// 推送出库信息给agv
|
sendTaskToAgv(wrkMast,wrkDetls);
|
}
|
}
|
}
|
|
|
|
private void pushStaNoToGwcs(Integer palletizingNo, Integer staNo, Integer workNo) {
|
|
}
|
|
/**
|
* 调用AGV出库接口
|
* @param wrkMast 工作主档
|
* @param wrkDetls 工作档明细
|
*/
|
private void sendTaskToAgv(WrkMast wrkMast, List<WrkDetl> wrkDetls) {
|
|
// 调用结果
|
boolean success = false;
|
// 构造请求头
|
Map<String,Object> headers = new HashMap<>();
|
headers.put("Content-Type","application/json;charset=UTF-8");
|
|
WrkDetl wrkDetl = wrkDetls.get(0);
|
|
// 构造请求体
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("TaskNo", wrkMast.getWrkNo()); // 任务号
|
jsonObject.put("Address", ""); // 出库口
|
jsonObject.put("Model", wrkDetl.getModel()); // 型号
|
jsonObject.put("Batch", wrkDetl.getBatch()); // 批次
|
jsonObject.put("Dimension", wrkDetl.getSpecs()); // 规格
|
jsonObject.put("Weight", wrkDetl.getWeight()); // 重量
|
jsonObject.put("ProductionDate", wrkDetl.getManuDate()); // 生产日期
|
String body = jsonObject.toJSONString();
|
String response = "";
|
try {
|
response = new HttpHandler.Builder()
|
.setUri(OpenApiAddressConstant.OUT_TO_AGV_IP)
|
.setPath(OpenApiAddressConstant.OUT_TO_AGV_URL)
|
.setHeaders(headers)
|
.setJson(body)
|
.build()
|
.doPost();
|
if (!Cools.isEmpty(response)) {
|
JSONObject jsonObject1 = JSONObject.parseObject(response);
|
if ((Integer) jsonObject1.get("Code") == 200){
|
success = true;
|
}
|
} else {
|
log.error("出库请求agv接口异常接口失败！！！url：{}；request：{}；response：{}", MesConstant.URL + MesConstant.PAKIN_URL, body, response);
|
}
|
} catch (Exception e) {
|
log.error("出库请求agv接口异常：{}", e.getMessage());
|
} finally {
|
if (success) {
|
wrkMast.setPltType(1); // 是否成功给agv出库接口下发过命令，避免重复请求
|
wrkMastService.updateById(wrkMast);
|
}
|
try {
|
// 保存接口日志
|
apiLogService.save(
|
"出库请求agv",
|
MesConstant.URL + MesConstant.PAKIN_URL,
|
null,
|
"127.0.0.1",
|
jsonObject.toJSONString(),
|
response,
|
success
|
);
|
} catch (Exception e) {
|
log.error("保存出库请求agv接口日志异常", e);
|
}
|
}
|
}
|
|
/**
|
* 调用金蝶同步物料接口，增量同步每小时产生的新物料
|
*/
|
public void syncMat() {
|
|
//登录金蝶
|
ReturnT<String> start = loginAuthHandler.start();
|
|
//条件和需要获得的结果拼接
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("FormId", "BD_MATERIAL");
|
jsonObject.put("OrderString","");
|
jsonObject.put("TopRowCount",0);
|
jsonObject.put("Limit", 3000);
|
jsonObject.put("StartRow", "0");
|
jsonObject.put("SubSystemId", "");
|
// 获取当前时间
|
LocalDateTime currentDateTime = LocalDateTime.now();
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
// 获取当前时间的前一小时整点时间
|
LocalDateTime oneHourAgo = currentDateTime.minusHours(1).withMinute(0).withSecond(0).withNano(0);
|
jsonObject.put("FilterString", "FCreateDate <= '2022-08-23 13:37:00'");
|
// jsonObject.put("FilterString", "FCreateDate >= '"+oneHourAgo.format(formatter)+"' and FUseOrgId .FNumber='10004'");
|
// jsonObject.put("FilterString","FNumber = '0101010003'");
|
jsonObject.put("FieldKeys", "FNumber,FName,FCreateDate,FTypeID");
|
|
JSONObject jsonObject1 = new JSONObject();
|
jsonObject1.put("data", jsonObject);
|
String add = jsonObject1.toJSONString();
|
|
String response = "";
|
boolean success = false;
|
String url = "http://192.168.16.7";
|
String address = "K3CLOUD/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc";
|
try {
|
//获取Cookie值
|
HashMap<String, Object> headers = new HashMap<>();
|
headers.put("Cookie", start.getContent());
|
response = new HttpHandler.Builder()
|
.setHeaders(headers)
|
.setUri(url)
|
.setPath(address)
|
.setJson(add)
|
.build()
|
.doPost();
|
String[] tempstr;
|
if (!"[]".equals(response)) {
|
String[] returnstr = response.split("],");
|
int count = 0;
|
log.info("--------调用金蝶同步物料信息开始--------");
|
for (int i = 0; i < returnstr.length; i++) {
|
Mat mat = new Mat();
|
tempstr = returnstr[i].split(",");
|
if (i == 0) {
|
mat.setMatnr(tempstr[0].substring(2)); //物料编码
|
} else {
|
mat.setMatnr(tempstr[0].substring(1)); //物料编码
|
}
|
mat.setMaktx(tempstr[1]); // 物料名称
|
mat.setTagId(Long.valueOf(tempstr[3].substring(0,1))); // 物料分类
|
mat.setCreateTime(new Date());//商品创建时间
|
mat.setUpdateTime(new Date());
|
mat.setStatus(1);
|
try {
|
matService.insert(mat);
|
count++;
|
}catch (Exception e){
|
log.error("金蝶同步物料异常：{}", mat);
|
}
|
}
|
log.info("----调用金蝶同步物料信息结果：总{},成{}--------",returnstr.length, count);
|
success = true;
|
}
|
} catch (Exception e) {
|
log.error("fail", e);
|
} finally {
|
try {
|
// 保存接口日志
|
apiLogService.save(
|
"请求金蝶同步物料信息",
|
url + address,
|
null,
|
"127.0.0.1",
|
add,
|
response,
|
success
|
);
|
} catch (Exception e) {
|
log.error("", e);
|
}
|
}
|
}
|
}
|
