package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.core.common.Cools;
|
import com.core.common.SpringUtils;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.Order;
|
import com.zy.asrs.entity.OrderDetl;
|
import com.zy.asrs.entity.U8Properties;
|
import com.zy.asrs.entity.result.OrderRsult;
|
import com.zy.asrs.service.ApiLogService;
|
import com.zy.asrs.service.OrderDetlService;
|
import com.zy.asrs.service.OrderService;
|
import com.zy.common.utils.HttpHandler;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.text.Format;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.Objects;
|
|
/**
|
* @author pang.jiabao
|
* @description 订单明细完成，定时上报u8
|
* @createDate 2025/9/19 9:50
|
*/
|
@Slf4j
|
@Component
|
public class AutoReportingHandler {
|
|
@Resource
|
private U8Properties u8Properties;
|
|
@Resource
|
private OrderDetlService orderDetlService;
|
|
@Resource
|
private OrderService orderService;
|
|
public void U8Reporting(OrderDetl orderDetl) {
|
|
String orderNo = orderDetl.getOrderNo();
|
Order order = orderService.selectByNo(orderNo);
|
|
if (order == null) {
|
throw new CoolException("没有找到该订单号:" + orderNo);
|
}
|
|
OrderRsult orderRsult = new OrderRsult();
|
OrderRsult.Login login = new OrderRsult.Login();
|
OrderRsult.HeadTable headTable = new OrderRsult.HeadTable();
|
OrderRsult.BodyTable bodyTable = new OrderRsult.BodyTable();
|
|
login.setSAccID(u8Properties.getSAccID()); //账套号 固定
|
login.setSUserID(u8Properties.getSUserID());//U8登陆账号 固定
|
login.setSPassword(u8Properties.getSPassword());//U8登陆密码 固定
|
login.setSServer(u8Properties.getSServer());//U8服务器地址 固定
|
orderRsult.setLogin(login);
|
|
orderRsult.setVerifier("sys");//单据类型 固定
|
orderRsult.setCommandType("关闭");//操作类型 固定
|
orderRsult.setVouchName("");//审核人 填写则自动审核
|
|
headTable.setCtvcode(orderNo);//调拨单号 默认
|
//时间
|
Date date = new Date();
|
Format formatter = new SimpleDateFormat("yyyy-MM-dd");
|
String format = formatter.format(date);
|
headTable.setDtvdate(format);//单据日期
|
headTable.setCmaker("sys");//制单人名称
|
headTable.setVt_id("89");//模板号 默认
|
headTable.setCiwhcode("1");//转入仓库编码
|
headTable.setCowhcode("1");//转出仓库编码
|
headTable.setCordcode("");//出库类别编码 默认
|
headTable.setCirdcode("");//入库类别编码 默认
|
headTable.setCodepcode("");//转出部门编码
|
headTable.setCidepcode("");//转入部门编码
|
|
bodyTable.setOrderNo(orderDetl.getOrderNo()); // 单据号
|
bodyTable.setIrowno(orderDetl.getSku());//行号
|
bodyTable.setCinvcode(orderDetl.getMatnr());//存货编码
|
bodyTable.setCtvbatch(Cools.isEmpty(orderDetl.getBatch()) ? "" : orderDetl.getBatch());//批号（特殊说明）
|
Double qty = orderDetl.getQty() - (Cools.isEmpty(orderDetl.getUnits()) ? 0 : orderDetl.getUnits());
|
bodyTable.setItvquantity(String.valueOf(qty));//完成件数
|
bodyTable.setCinposcode("1-1");//立库源货位
|
bodyTable.setCoutposcode("");//目标货位
|
bodyTable.setItrsid(orderDetl.getSku());//行主键
|
bodyTable.setEditprop("A");//状态 A 新增
|
|
ArrayList<OrderRsult.BodyTable> bodyTables = new ArrayList<>();
|
bodyTables.add(bodyTable);
|
orderRsult.setBodyTable(bodyTables);
|
|
ArrayList<OrderRsult.HeadTable> headTables = new ArrayList<>();
|
headTables.add(headTable);
|
orderRsult.setHeadTable(headTables);
|
|
String response = "";
|
boolean success = false;
|
try {
|
|
response = new HttpHandler.Builder()
|
// .setHeaders(map)
|
.setUri(u8Properties.getURL())
|
.setPath(u8Properties.getResultReportPath())
|
.setJson(JSON.toJSONString(orderRsult))
|
.build()
|
.doPost();
|
log.info("orderNo:{},matnr:{},qty:{}订单明细完成上报u8原始返回：{}",orderNo ,orderDetl.getMatnr() ,qty , response);
|
JSONObject jsonObject = JSON.parseObject(response);
|
|
if (jsonObject.getInteger("code").equals(200)) {
|
orderDetl.setUnits(qty + (Cools.isEmpty(orderDetl.getUnits()) ? 0 : orderDetl.getUnits()));
|
if (Objects.equals(orderDetl.getQty(), orderDetl.getAnfme())) {
|
orderDetl.setInspect(1);
|
}
|
orderDetlService.updateById(orderDetl);
|
success = true;
|
} else {
|
log.error("订单明细完成上报u8失败！！！url：{}；request：{}；response：{}", u8Properties.getURL() + "/" + u8Properties.getResultReportPath(), JSON.toJSONString(orderRsult), response);
|
}
|
} catch (Exception e) {
|
response = e.getMessage();
|
log.error("订单明细完成上报u8异常！！！url：{}；request：{}；response：{}", u8Properties.getURL() + "/" + u8Properties.getResultReportPath(), JSON.toJSONString(orderRsult), response);
|
} finally {
|
try {
|
// 保存接口日志
|
ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class);
|
apiLogService.save(
|
"订单完成上报u8",
|
u8Properties.getURL() + "/" + u8Properties.getResultReportPath(),
|
"",
|
"127.0.0.1",
|
JSON.toJSONString(orderRsult),
|
response,
|
success
|
);
|
} catch (Exception e) {
|
log.error("订单完成上报u8接口日志保存异常", e);
|
}
|
}
|
}
|
}
|
