package com.zy.asrs.task.kingdee.handler;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.core.common.SnowflakeIdWorker;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.service.impl.ErpSecretServiceImpl;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.asrs.utils.OrderInAndOutUtil;
|
import com.zy.erp.kingdee.entity.param.MatLoadParam;
|
import com.zy.erp.kingdee.enums.KingDeeUtilType;
|
import com.zy.common.utils.HttpHandler;
|
import com.zy.erp.kingdee.utils.KingDeeUtil;
|
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.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
|
@Service
|
@Slf4j
|
public class InboundOrderHandler extends AbstractHandler<String> {
|
@Value("${erp.address.URL}")
|
//端口
|
private String URL;
|
|
@Value("${erp.address.mataddress}")
|
//商品档案地址
|
private String matAddress;
|
@Value("${erp.address.orgaddress}")
|
//货主档案地址
|
private String orgAddress;
|
@Value("${erp.address.impurreceivebilladdress}")
|
//收料单查询
|
private String imPurreceiveBillAddress;
|
@Autowired
|
private ApiLogService apiLogService;
|
|
@Autowired
|
private LoginAuthenticationHandler loginAuthenticationHandler;
|
|
@Autowired
|
private MatService matService;
|
|
@Autowired
|
private TagService tagService;
|
|
@Autowired
|
private DocTypeService docTypeService;
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private OrderDetlService orderDetlService;
|
|
@Autowired
|
private SnowflakeIdWorker snowflakeIdWorker;
|
|
@Autowired
|
private LocOwnerService locOwnerService;
|
@Autowired
|
private ErpSecretServiceImpl erpSecretService;
|
@Value("${erp.login.accountId}")
|
private String accountId;
|
@Value("${erp.login.xAcfwIdentity}")
|
private String xAcfwIdentity;
|
@Transactional
|
public synchronized ReturnT<String> start() {
|
SimpleDateFormat sdf1=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
SimpleDateFormat sdf2=new SimpleDateFormat("yyyy-MM-dd");
|
//读取token
|
ErpSecret erpSecret = erpSecretService.selectOne(new EntityWrapper<ErpSecret>().eq("account_id", accountId));
|
|
|
for(KingDeeUtilType kingDeeUtilType : KingDeeUtilType.values()) {
|
// MatLoadParam matLoadParam = new MatLoadParam();
|
DocType docType = docTypeService.selectOne(new EntityWrapper<DocType>().eq("doc_name", kingDeeUtilType.desc));
|
if (Cools.isEmpty(docType) && !kingDeeUtilType.formId.equals("BD_MATERIAL")){
|
docType = docTypeService.selectOrAdd(kingDeeUtilType.desc, kingDeeUtilType.pakIn.equals(1));
|
}
|
String FDocumentStatus=null;
|
//条件和需要获得的结果拼接
|
JSONObject jsonObject = new JSONObject();
|
String path = null;
|
Date now = new Date();
|
//物料档案查询
|
if(kingDeeUtilType.formId.equals("BD_MATERIAL")){
|
// Mat latestMat = matService.selectLatest();
|
String latestUpdateTime = sdf1.format(docType.getUpdateTime());
|
// Tag tag = tagService.selectByName("全部", 1);
|
jsonObject.put("id", null);//id
|
jsonObject.put("number", null);//编码
|
jsonObject.put("createorg_number", null);//创建组织
|
jsonObject.put("start_createtime", "2025-01-01 00:00:00");//创建起始
|
jsonObject.put("end_createtime", sdf1.format(now));//创建截止
|
jsonObject.put("start_modifytime", latestUpdateTime);//更新起始
|
jsonObject.put("end_modifytime", sdf1.format(now));//更新截止
|
jsonObject.put("start_approvedate", "2025-01-01");//审核起始
|
jsonObject.put("end_approvedate", sdf2.format(now));//审核截止
|
jsonObject.put("status", Arrays.asList("B", "C"));//数据状态 [A:暂存, B:已提交, C:已审核]
|
path = matAddress;
|
}
|
else if(kingDeeUtilType.formId.equals("BD_RRGANIZATION")){
|
jsonObject.put("start_createtime", "2025-01-01 00:00:00");//id
|
jsonObject.put("end_createtime", sdf1.format(now));
|
jsonObject.put("id", null);
|
jsonObject.put("number", null);
|
jsonObject.put("createorg_number", null);
|
jsonObject.put("status", Arrays.asList("B", "C"));//数据状态 [A:暂存, B:已提交, C:已审核]
|
path = orgAddress;
|
}
|
else if(kingDeeUtilType.formId.equals("PUR_RECEIVEBIll")){
|
jsonObject.put("start_biztime", "2025-01-01 00:00:00");//业务起始日期
|
jsonObject.put("end_biztime", sdf1.format(now));//业务结束日期
|
jsonObject.put("billno", null);
|
jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
|
jsonObject.put("start_auditdate",null);//id
|
jsonObject.put("end_auditdate", null);
|
jsonObject.put("org_number", null);
|
jsonObject.put("supplier_number", null);
|
path = imPurreceiveBillAddress;
|
}
|
JSONObject jsonObject1 = new JSONObject();
|
jsonObject1.put("data", jsonObject);
|
jsonObject1.put("pageSize", 20);
|
jsonObject1.put("pageNo", 1);
|
String add = jsonObject1.toJSONString();
|
|
//上报
|
String response = "";
|
boolean success = false;
|
try {
|
//获取Cookie值
|
HashMap<String, Object> headers = new HashMap<>();
|
headers.put("accesstoken", erpSecret.getAccessToken());
|
headers.put("x-acgw-identity", xAcfwIdentity); // 自定义请求头
|
response = new HttpHandler.Builder()
|
.setHeaders(headers)
|
.setUri(URL)
|
.setPath(path)
|
.setJson(add)
|
.build()
|
.doPost();
|
JSONObject jsonResponse = JSON.parseObject(response);
|
if(jsonResponse.getString("errorCode").equals("401")){
|
log.error("检索失败错误信息：{}", jsonResponse.getString("message"));
|
loginAuthenticationHandler.start();
|
continue;
|
}
|
JSONArray data = jsonResponse.getJSONObject("data").getJSONArray("rows");
|
if(data.size()<=0) continue;
|
//商品档案同步
|
if (kingDeeUtilType.formId.equals("BD_MATERIAL")) {
|
Tag tag = tagService.selectByName("全部", 1);
|
// 处理分页：根据返回的totalCount和pageSize计算页数
|
int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
|
int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
|
int totalPages = (int) Math.ceil((double) totalCount / pageSize);
|
|
for (int page = 1; page <= totalPages; page++) {
|
jsonObject1.put("pageNo", page);
|
add = jsonObject1.toJSONString();
|
// 重新发起请求以获取该页的数据
|
response = new HttpHandler.Builder()
|
.setHeaders(headers)
|
.setUri(URL)
|
.setPath(path)
|
.setJson(add)
|
.build()
|
.doPost();
|
|
jsonResponse = JSON.parseObject(response);
|
data = jsonResponse.getJSONObject("data").getJSONArray("rows");
|
for (int j = 0; j < data.size(); j++) {
|
JSONObject jsonObjectNew = data.getJSONObject(j);
|
Date modifyTime = sdf1.parse(jsonObjectNew.get("modifytime").toString());
|
String matnr = jsonObjectNew.get("number").toString();
|
String name = jsonObjectNew.get("name").toString();
|
String createTime = jsonObjectNew.get("createtime").toString();
|
Double grossweight = jsonObjectNew.get("grossweight") != null ? new BigDecimal(jsonObjectNew.get("grossweight").toString()).doubleValue() : 0.0;
|
Double height = jsonObjectNew.get("height") != null ? new BigDecimal(jsonObjectNew.get("height").toString()).doubleValue() : 0.0;
|
Double width = jsonObjectNew.get("width") != null ? new BigDecimal(jsonObjectNew.get("width").toString()).doubleValue() : 0.0;
|
Double length = jsonObjectNew.get("length") != null ? new BigDecimal(jsonObjectNew.get("length").toString()).doubleValue() : 0.0;
|
|
// 生成商品档案
|
Mat mat = matService.selectByMatnr(matnr);
|
if (mat == null) {
|
mat = new Mat();
|
mat.setMatnr(matnr);
|
mat.setMaktx(name);
|
mat.setTagId(tag.getId());
|
mat.setWeight(grossweight);
|
mat.setManLength(length);
|
mat.setHeight(height);
|
mat.setWidth(width);
|
mat.setCreateTime(sdf1.parse(createTime));
|
mat.setUpdateTime(modifyTime);
|
mat.setStatus(1);
|
if (!matService.insert(mat)) {
|
callApiLogSaveMat(mat, kingDeeUtilType, "同步新物料出错！" + mat, false);
|
log.info("同步新物料出错！参数：[{}]、[{}]", mat, jsonObjectNew);
|
} else {
|
callApiLogSaveMat(mat, kingDeeUtilType, "同步新物料成功！", true);
|
success = true;
|
}
|
} else {
|
boolean isUpdated = false;
|
if (mat.getUpdateTime().compareTo(modifyTime) != 0) {
|
// 更新字段
|
if (!mat.getMaktx().equals(name)) mat.setMaktx(name);
|
if (mat.getWeight().compareTo(grossweight) != 0) mat.setWeight(grossweight);
|
if (mat.getManLength().compareTo(length) != 0) mat.setManLength(length);
|
if (mat.getHeight().compareTo(height) != 0) mat.setHeight(height);
|
if (mat.getWidth().compareTo(width) != 0) mat.setWidth(width);
|
if (mat.getCreateTime().compareTo(sdf1.parse(createTime)) != 0)
|
mat.setCreateTime(sdf1.parse(createTime));
|
mat.setUpdateTime(modifyTime);
|
isUpdated = true;
|
}
|
// 执行更新操作
|
if (isUpdated) {
|
if (!matService.updateById(mat)) {
|
callApiLogSaveMat(mat, kingDeeUtilType, "更新物料出错！" + mat, false);
|
log.info("更新物料[商品编号：{}], 更新失败！", mat.getMatnr());
|
} else {
|
callApiLogSaveMat(mat, kingDeeUtilType, "更新物料成功！", true);
|
success = true;
|
log.info("更新物料[商品编号：{}]", mat.getMatnr());
|
}
|
}
|
}
|
}
|
}
|
if(success){
|
docType.setUpdateTime(now);
|
docTypeService.updateById(docType);
|
}
|
}
|
else if(kingDeeUtilType.formId.equals("BD_RRGANIZATION")){//货主同步
|
int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
|
int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
|
int totalPages = (int) Math.ceil((double) totalCount / pageSize);
|
|
for (int page = 1; page <= totalPages; page++) {
|
jsonObject1.put("pageNo", page);
|
add = jsonObject1.toJSONString();
|
// 重新发起请求以获取该页的数据
|
response = new HttpHandler.Builder()
|
.setHeaders(headers)
|
.setUri(URL)
|
.setPath(path)
|
.setJson(add)
|
.build()
|
.doPost();
|
|
jsonResponse = JSON.parseObject(response);
|
data = jsonResponse.getJSONObject("data").getJSONArray("rows");
|
for (int j = 0; j < data.size(); j++) {
|
JSONObject jsonObjectNew = data.getJSONObject(j);
|
Date updateTime = sdf1.parse(jsonObjectNew.get("modifytime").toString());
|
String ownerUuid = jsonObjectNew.get("number").toString();
|
String owner = jsonObjectNew.get("name").toString();
|
Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString());
|
// 生成商品档案
|
LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid);
|
if (locOwner == null) {
|
locOwner = new LocOwner();
|
locOwner.setOwner(owner);
|
locOwner.setOwnerUuid(ownerUuid);
|
locOwner.setCreateTime(createTime);
|
locOwner.setUpdateTime(updateTime);
|
if (!locOwnerService.insert(locOwner)) {
|
callApiLogSaveOwner(locOwner, kingDeeUtilType, "同步新货主出错！" + locOwner, false);
|
log.info("同步新货主出错！参数：[{}]、[{}]", locOwner, jsonObjectNew);
|
} else {
|
callApiLogSaveOwner(locOwner, kingDeeUtilType, "同步新货主成功！", true);
|
success = true;
|
}
|
} else {
|
boolean isUpdated = false;
|
if (locOwner.getUpdateTime().compareTo(updateTime) != 0) {
|
// 更新字段
|
if (!locOwner.getOwner().equals(owner)) locOwner.setOwner(owner);
|
if (!locOwner.getOwnerUuid().equals(ownerUuid)) locOwner.setOwnerUuid(ownerUuid);
|
|
if (locOwner.getCreateTime().compareTo(createTime) != 0)
|
locOwner.setCreateTime(createTime);
|
locOwner.setUpdateTime(updateTime);
|
isUpdated = true;
|
}
|
// 执行更新操作
|
if (isUpdated) {
|
if (!locOwnerService.updateById(locOwner)) {
|
callApiLogSaveOwner(locOwner, kingDeeUtilType, "更新物料出错！" + locOwner, false);
|
log.info("更新货主[货主编号：{}], 更新失败！", locOwner.getOwnerUuid());
|
} else {
|
callApiLogSaveOwner(locOwner, kingDeeUtilType, "更新物料成功！", true);
|
success = true;
|
log.info("更新货主[货主编号：{}]", locOwner.getOwnerUuid());
|
}
|
}
|
}
|
}
|
}
|
}
|
// else {
|
// int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
|
// int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
|
// int totalPages = (int) Math.ceil((double) totalCount / pageSize);
|
// for (int page = 1; page <= totalPages; page++) {
|
// jsonObject1.put("pageNo", page);
|
// add = jsonObject1.toJSONString();
|
// // 重新发起请求以获取该页的数据
|
// response = new HttpHandler.Builder()
|
// .setHeaders(headers)
|
// .setUri(URL)
|
// .setPath(path)
|
// .setJson(add)
|
// .build()
|
// .doPost();
|
//
|
// jsonResponse = JSON.parseObject(response);
|
// data = jsonResponse.getJSONObject("data").getJSONArray("rows");
|
// for (int j = 0; j < data.size(); j++) {
|
// JSONObject jsonObjectNew = data.getJSONObject(j);
|
// Date updateTime = sdf1.parse(jsonObjectNew.get("modifytime").toString());
|
// String ownerUuid = jsonObjectNew.get("number").toString();
|
// String owner = jsonObjectNew.get("name").toString();
|
// Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString());
|
// String billNo = jsonObjectNew.get("billno").toString();
|
//
|
// Order order = OrderInAndOutUtil.selectByNo(kingDeeUtilType.pakIn == 1, billNo);
|
//// Order order = orderService.selectByNo(jsonArray.get(0).toString());
|
//// LocOwner locOwner = null;
|
//// if (!Cools.isEmpty(1)) {
|
//// locOwner = locOwnerService.selectById(1);
|
//// } else {
|
//// locOwner = locOwnerService.selectById(1);
|
//// }
|
// if (Cools.isEmpty(order)) {
|
// // 单据主档
|
// order = new Order(
|
// String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
|
// billNo, // 订单编号
|
// createTime, // 单据日期
|
// docType.getDocId(), // 单据类型
|
// null, // 项目编号
|
// "1", //项目名称 客户PO号
|
// null, // 调拨项目编号
|
// null, // 初始票据号
|
// null, // 票据号
|
// null, // 客户编号
|
// locOwner.getOwner(), // 客户
|
// null, // 联系方式
|
// null, // 操作人员
|
// null, // 合计金额
|
// null, // 优惠率
|
// null, // 优惠金额
|
// null, // 销售或采购费用合计
|
// null, // 实付金额
|
// null, // 付款类型
|
// null, // 业务员
|
// null, // 结算天数
|
// null, // 邮费支付类型
|
// null, // 邮费
|
// null, // 付款时间
|
// null, // 发货时间
|
// null, // 物流名称
|
// null, // 物流单号
|
// 1L, // 订单状态
|
// 1, // 状态
|
// 9527L, // 添加人员
|
// now, // 添加时间
|
// 9527L, // 修改人员
|
// now, // 修改时间
|
// null // 备注
|
// );
|
// OrderInAndOutUtil.insertOrder(kingDeeUtilType.pakIn == 1, order);
|
//
|
//// if (!orderService.insert(order)) {
|
//// if (!jsonDate.equals(docType.getCreateTime())){
|
//// callApiLogSaveOrder(order,kingDeeUtilType, "生成单据主档失败，请联系管理员"+order, false);
|
//// }
|
//// continue;
|
////// throw new CoolException("生成单据主档失败，请联系管理员");
|
//// }
|
// }
|
// //物料编码
|
// Mat mat = matService.selectByMatnr(jsonArray.get(2).toString());
|
// if (Cools.isEmpty(mat)) {
|
// if (!jsonDate.equals(docType.getCreateTime())){
|
// callApiLogSaveOrder(order,kingDeeUtilType, "编号商品检索失败，请先添加商品"+jsonArray.get(2).toString(), false);
|
// }
|
// continue;
|
// }
|
//// OrderDetl orderDetl1 = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", jsonArray.get(0).toString()).eq("matnr", jsonArray.get(2).toString()));
|
//// if (!Cools.isEmpty(orderDetl1)) {
|
//// continue;
|
//// }
|
// Order order1 = OrderInAndOutUtil.selectByNo(kingDeeUtilType.pakIn == 1, jsonArray.get(0).toString());
|
// List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(kingDeeUtilType.pakIn == 1, order1.getId());
|
// boolean sign = false;
|
// for (OrderDetl orderDetl : orderDetls){
|
// if (orderDetl.getMatnr().equals( jsonArray.get(2).toString())){
|
// sign = true;
|
// break;
|
// }
|
// }
|
// if (sign){
|
// continue;
|
// }
|
// OrderDetl orderDetl = new OrderDetl();
|
// orderDetl.sync(mat);
|
// orderDetl.setBatch(null);
|
// orderDetl.setAnfme(Double.parseDouble(jsonArray.get(5).toString()));
|
// orderDetl.setOrderId(order.getId());
|
// orderDetl.setOrderNo(order.getOrderNo());
|
// orderDetl.setCreateBy(9527L);
|
// orderDetl.setCreateTime(new Date());
|
// orderDetl.setUpdateBy(9527L);
|
// orderDetl.setUpdateTime(new Date());
|
// orderDetl.setStatus(1);
|
// orderDetl.setQty(0.0D);
|
//// if (!orderDetlService.insert(orderDetl)) {
|
//// callApiLogSaveOrder(order,kingDeeUtilType, "生成单据明细失败，请联系管理员!订单号："+order.getOrderNo(), false);
|
////// throw new CoolException("生成单据明细失败，请联系管理员");
|
//// }
|
// OrderInAndOutUtil.insertOrderDetl(kingDeeUtilType.pakIn == 1,order,orderDetl);
|
// }
|
// docTypeService.updateById(docType);
|
// }
|
// }
|
} catch (Exception e) {
|
log.error("fail", e);
|
// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
return FAIL.setMsg(e.getMessage());
|
} finally {
|
|
}
|
}
|
return SUCCESS;
|
}
|
|
public void callApiLogSaveMat(Mat mat, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
|
apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
|
"物料编号：" + mat.getMatnr() + "、物料名称：" + mat.getMaktx() + "、毛重：" + mat.getWeight()
|
+ "、长：" + mat.getManLength()
|
+ "、宽：" + mat.getWidth()
|
+ "、高：" + mat.getHeight()
|
+ "、状态：" + mat.getStatus$(),
|
response, bool);
|
}
|
|
public void callApiLogSaveOwner(LocOwner locOwner, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
|
apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
|
"货主编号：" + locOwner.getOwnerUuid() + "、货主名称：" + locOwner.getOwner(),
|
response, bool);
|
}
|
|
public void callApiLogSaveOrder(Order order, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
|
apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
|
"单据编号：" + order.getId() + "、状态：" + order.getStatus$(),
|
response, bool);
|
}
|
|
}
|
