package com.zy.asrs.task.kingdee.handler;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.toolkit.CollectionUtils;
|
import com.zy.asrs.entity.Order;
|
import com.zy.asrs.entity.OrderDetl;
|
import com.zy.asrs.entity.OrderDetlPakin;
|
import com.zy.asrs.entity.OrderPakin;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.service.impl.ErpSecretServiceImpl;
|
import com.zy.asrs.service.impl.OrderDetlPakinServiceImpl;
|
import com.zy.asrs.service.impl.OrderDetlServiceImpl;
|
import com.zy.asrs.service.impl.OrderPakinServiceImpl;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
public class AutoTransferOutHandler extends AbstractHandler<String> {
|
@Autowired
|
private OrderService orderService;
|
@Autowired
|
private ApiLogService apiLogService;
|
@Autowired
|
private DocTypeService docTypeService;
|
@Autowired
|
private LoginAuthenticationHandler loginAuthenticationHandler;
|
@Autowired
|
private ErpSecretServiceImpl erpSecretService;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private MatService matService;
|
@Autowired
|
private OrderDetlPakinServiceImpl orderDetlPakinService;
|
@Autowired
|
private OrderDetlServiceImpl orderDetlService;
|
@Autowired
|
private OrderPakinServiceImpl orderPakinServiceImpl;
|
@Autowired
|
private OrderPakinServiceImpl orderPakinService;
|
|
@Transactional(rollbackFor = Exception.class)
|
public ReturnT<String> start(OrderPakin orderPakin) {
|
JSONObject logData = new JSONObject();
|
String responseMsg = "";
|
boolean apiSuccess = false;
|
Order orderNew = null;
|
try {
|
logData.put("orderNo", orderPakin.getOrderNo());
|
logData.put("operation", "生成出库单");
|
logData.put("source", "入库单转出库单");
|
logData.put("startTime", System.currentTimeMillis());
|
|
orderNew = new Order(orderPakin);
|
orderNew.setDocType(23L);
|
orderNew.setOrderNo(orderPakin.getOrderNo() + "ZHCK");
|
orderNew.setSettle(65L);
|
|
// 插入出库主单
|
orderService.insert(orderNew);
|
|
List<OrderDetlPakin> pakinDetails = orderDetlPakinService.selectList(
|
new EntityWrapper<OrderDetlPakin>().eq("order_no", orderPakin.getOrderNo())
|
);
|
|
boolean hasInsertFailed = false;
|
|
if (CollectionUtils.isNotEmpty(pakinDetails)) {
|
for (OrderDetlPakin pd : pakinDetails) {
|
OrderDetl od = new OrderDetl(pd);
|
od.setOrderId(orderNew.getId());
|
|
boolean insertSuccess = orderDetlService.insert(od);
|
if (!insertSuccess) {
|
hasInsertFailed = true;
|
log.warn("出库明细插入失败：出库单号={}, 物料={}",
|
orderNew.getOrderNo(), pd.getMatnr());
|
}
|
}
|
}
|
|
// 根据明细插入结果更新状态
|
if (!hasInsertFailed) {
|
orderNew.setSettle(4L); // 出库单成功状态
|
orderPakin.setSettle(4L); // 原入库单更新状态（视业务是否需要）
|
orderService.updateById(orderNew);
|
orderPakinService.updateById(orderPakin); // 注意：这里用了 orderPakinService
|
|
apiSuccess = true;
|
responseMsg = String.format("成功生成出库单：%s，共 %d 条明细",
|
orderNew.getOrderNo(), pakinDetails.size());
|
log.info(responseMsg);
|
} else {
|
responseMsg = "部分出库明细插入失败，订单号：" + orderNew.getOrderNo();
|
log.error(responseMsg);
|
throw new RuntimeException("部分明细插入失败，触发事务回滚");
|
}
|
|
} catch (Exception e) {
|
apiSuccess = false;
|
responseMsg = "生成出库单失败：" + e.getMessage();
|
log.error("生成出库单失败，入库单号：{}，原因：{}", orderPakin.getOrderNo(), e.getMessage(), e);
|
|
// 如果你希望失败时不回滚，可以注释掉下面这行
|
throw e; // ← 保持事务回滚（推荐）
|
|
} finally {
|
// 无论成功失败，都记录日志
|
logData.put("endTime", System.currentTimeMillis());
|
logData.put("durationMs", logData.getLongValue("endTime") - logData.getLongValue("startTime"));
|
logData.put("success", apiSuccess);
|
logData.put("message", responseMsg);
|
logData.put("outOrderNo", orderNew != null ? orderNew.getOrderNo() : "未生成");
|
|
saveApiLog(logData, responseMsg, apiSuccess);
|
}
|
|
return apiSuccess ? SUCCESS : FAIL;
|
}
|
|
private void saveApiLog(JSONObject add, String response, boolean success) {
|
try {
|
apiLogService.save(
|
"货主转换出库上报",
|
"AutoTransferHandler",
|
null,
|
"127.0.0.1",
|
add.toJSONString(),
|
response,
|
success
|
);
|
} catch (Exception e) {
|
log.error("接口日志保存失败", e);
|
}
|
}
|
|
}
|
