yonyou
/
taikai2312
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善销售出库,库存采购入库,销售交货单,盘点

This commit is contained in:
张明 2025-05-21 12:46:10 +08:00
parent 5d8f068daf
commit ea487a89a7
10 changed files with 1242 additions and 160 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
ic/src/private/nc/bs/ic/m45/sign/SignBP.java Normal file
View File

@ -0,0 +1,61 @@
package nc.bs.ic.m45.sign;
import com.yonyou.cloud.ncc.plugin.entity.OperationInfo;
import nc.bs.ic.general.sign.ISignBP;
import nc.bs.ic.general.sign.ISignRuleProvider;
import nc.bs.ic.general.sign.SignBPTemplate;
import nc.bs.ic.m45.sign.rule.AfterSigningSynchronizeRuleMES;
import nc.bs.ic.m45.base.BPPlugInPoint;
import nc.bs.ic.m45.insert.rule.InsertOrSignRewritePayPlanInvoiceRule;
import nc.bs.ic.m45.sign.rule.*;
import nc.bs.ic.pub.util.DebugUtils;
import nc.bs.ic.pub.util.SagasUtils;
import nc.bs.scmpub.rule.VOSagaFrozenValidateRule;
import nc.impl.pubapp.pattern.rule.processer.AroundProcesser;
import nc.itf.ic.m45.compensate.IPurchaseInSagasCompensate;
import nc.vo.ic.m45.entity.PurchaseInVO;
import nc.vo.ic.pub.util.VOEntityUtil;
import nc.vo.scmpub.res.billtype.ICBillType;
import nccloud.bs.ic.mobile.inbound.operation.rewrite.MobAfterPurchaseInSign;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
public class SignBP implements ISignBP<PurchaseInVO>, ISignRuleProvider<PurchaseInVO> {
public SignBP() {
}
public PurchaseInVO[] sign(PurchaseInVO[] bills) {
DebugUtils.debug("purchasein-sign-begin");
SignBPTemplate<PurchaseInVO> signBP = new SignBPTemplate(BPPlugInPoint.SignAction, this);
SagasUtils.frozenAndAddSaga(bills, ICBillType.PurchaseIn.getCode(), "1", (OperationInfo) null);
Map<String, Serializable> paramMap = new HashMap();
paramMap.put("actionname", "sign_45");
paramMap.put("hid", VOEntityUtil.getPksFromAggVO(bills));
paramMap.put("vos", bills);
SagasUtils.compensate(paramMap, IPurchaseInSagasCompensate.class);
PurchaseInVO[] resultVOs = (PurchaseInVO[]) signBP.sign(bills);
DebugUtils.debug("purchasein-sign-end");
return resultVOs;
}
public void addAfterRule(PurchaseInVO[] vos, AroundProcesser<PurchaseInVO> processor) {
processor.addAfterRule(new SignRewritePayPlanConfirmDataRule());
processor.addAfterRule(new InsertOrSignRewritePayPlanInvoiceRule("1001Z01000000000F04P"));
processor.addAfterRule(new AfterRuleForRewritePUSettle());
processor.addAfterRule(new AfterRuleForPush5X());
processor.addAfterRule(new AfterSignRuleForFinanceProcess());
processor.addAfterRule(new AfterSignRuleForLiabilityProcess());
processor.addAfterRule(new MobAfterPurchaseInSign());
processor.addAfterRule(new SignM45AndRewriteCTPayPlan());
processor.addAfterRule(new SignInsertFeeDetailRule());
// Ç©×ÖºóÍÆËÍÖÁMESϵͳ
processor.addAfterRule(new AfterSigningSynchronizeRuleMES());
}
public void addBeforeRule(PurchaseInVO[] vos, AroundProcesser<PurchaseInVO> processor) {
processor.addBeforeRule(new VOSagaFrozenValidateRule(true));
processor.addBeforeRule(new BeforeRuleForCheckPU());
}
}

270
ic/src/private/nc/bs/ic/m45/sign/rule/AfterSigningSynchronizeRuleMES.java Normal file
View File

@ -0,0 +1,270 @@
package nc.bs.ic.m45.sign.rule;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import nc.bs.dao.BaseDAO;
import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.jdbc.framework.processor.ColumnProcessor;
import nc.vo.bd.material.MaterialVO;
import nc.vo.bd.material.measdoc.MeasdocVO;
import nc.vo.bd.psn.PsndocVO;
import nc.vo.bd.stordoc.StordocVO;
import nc.vo.bd.supplier.SupplierVO;
import nc.vo.cmp.util.StringUtils;
import nc.vo.ic.m45.entity.PurchaseInVO;
import nc.vo.ic.m45.entity.PurchaseInBodyVO;
import nc.vo.ic.m45.entity.PurchaseInHeadVO;
import nc.vo.pub.BusinessException;
import nc.vo.pub.lang.UFDate;
import nc.vo.pub.lang.UFDouble;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.pub.SqlBuilder;
import nc.vo.vorg.DeptVersionVO;
import nccloud.pubift.commen.itf.utils.IHttpPostOtherSys;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
/**
* 采购收货单签字后推送MES系统
*/
public class AfterSigningSynchronizeRuleMES implements IRule<PurchaseInVO> {
private static final String PURCHASE_IN_URL = "/GTHINKING/AjaxService/N_CGSJJSA/102223002.ashx/CGSH_INSERT"; // 采购收货单同步接口
private static final String logginfo = "OALOG";
private static final Log obmlog = Log.getInstance(logginfo);
private static final BaseDAO dao = new BaseDAO();
@Override
public void process(PurchaseInVO[] purchaseInVOS) {
try {
if (purchaseInVOS == null || purchaseInVOS.length == 0) {
return;
}
// 检查并筛选采购收货单
List<PurchaseInVO> filteredPurchaseInVOS = checkAndFilterBills(purchaseInVOS);
if (filteredPurchaseInVOS.isEmpty()) {
return;
}
// 初始化HTTP请求工具类
IHttpPostOtherSys httpPostOtherSys = NCLocator.getInstance().lookup(IHttpPostOtherSys.class);
// 处理每个采购收货单
for (PurchaseInVO purchaseInVO : filteredPurchaseInVOS) {
PurchaseInHeadVO head = purchaseInVO.getHead();
PurchaseInBodyVO[] bodys = purchaseInVO.getBodys();
// 构建要发送的数据
JSONObject syncData = buildSyncData(head, bodys);
// 发送数据到MES系统
httpPostOtherSys.sendToExternalSystem(PURCHASE_IN_URL, syncData);
}
} catch (Exception e) {
obmlog.error("AfterSigningSynchronizeRuleMES-处理异常:" + e.getMessage(), e);
ExceptionUtils.wrappException(e);
}
}
/**
* 检查并筛选需要同步的单据
*/
private List<PurchaseInVO> checkAndFilterBills(PurchaseInVO[] purchaseInVOS) throws BusinessException {
List<PurchaseInVO> result = new ArrayList<>();
for (PurchaseInVO vo : purchaseInVOS) {
// 检查组织是否为电缆组织
if (vo.getHead() != null && "0001A110000000000677".equals(vo.getHead().getPk_org())) {
result.add(vo);
}
}
return result;
}
/**
* 构建明细数据
*/
private JSONArray buildDetailsData(PurchaseInBodyVO[] bodys) throws BusinessException {
JSONArray details = new JSONArray();
if (bodys != null) {
for (PurchaseInBodyVO body : bodys) {
JSONObject detailItem = new JSONObject();
// 收货单号（必填）
detailItem.put("orderNo", null);
// 收货单序号（必填）- 使用正确的表体字段crowno
detailItem.put("orderSn", body.getCrowno());
// 事务类型（必填）- 使用表体字段cbodytranstypecode
detailItem.put("type", null);
// 分类（必填）- H:货款, F:费用, L:劳务
detailItem.put("costOrder", null);
// 采购订单号 - 来源单据号vsourcebillcode
detailItem.put("poNo", body.getVsourcebillcode());
// 采购订单序号 - 来源单据行号vsourcerowno
detailItem.put("poSn", body.getVsourcerowno());
// 物料编码（必填）
String materialCode = transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE,
MaterialVO.PK_MATERIAL, body.getCmaterialvid());
detailItem.put("materialId", materialCode);
// 计量单位（必填）- 使用单位castunitid而不是主单位cunitid
detailItem.put("unit", transferCodeByPk(MeasdocVO.getDefaultTableName(), MeasdocVO.CODE, MeasdocVO.PK_MEASDOC, body.getCastunitid()));
// 物料批号
detailItem.put("batchNum", null);
// 制令号 - 在PurchaseInBodyVO中没有直接对应字段，可以从vdef字段获取
detailItem.put("productNum", null); // 假设vdef1存储制令号
// 换算系数（必填）
String scaleFactor = body.getVchangerate();
detailItem.put("scaleFactor", transferSpecialField(scaleFactor));
// TODO 文档必填但是没有对应关系（必填）
UFDouble taxRate = body.getNtaxrate();
detailItem.put("taxRate", taxRate != null ? taxRate.getDouble() : null);
// 应收数量（必填）- 使用nshouldassistnum
UFDouble recQty = body.getNshouldassistnum();
detailItem.put("recQty", recQty != null ? recQty.getDouble() : null);
// 主应收数量（必填）- 使用nshouldnum
UFDouble mainRecQty = body.getNshouldnum();
detailItem.put("mainRecQty", mainRecQty != null ? mainRecQty.getDouble() : null);
// 辅应收数量 - 这可能是自定义字段
detailItem.put("assitRecQty", null);
// 原币含税价格 -
UFDouble priceIncludeTax = body.getNpickupnum();
detailItem.put("priceIncludeTax", priceIncludeTax != null ? priceIncludeTax.getDouble() : null);
// 原币含税金额 - 使用norigtaxmny
UFDouble amountIncludeTax = body.getNorigtaxmny();
detailItem.put("amountIncludeTax", amountIncludeTax != null ? amountIncludeTax.getDouble() : null);
// 原币无税价格 -
UFDouble priceNoTax = body.getNorigprice();
detailItem.put("priceNoTax", priceNoTax != null ? priceNoTax.getDouble() : null);
// 原币无税金额 - 使用norigmny
UFDouble amountNoTax = body.getNqtnetprice();
detailItem.put("amountNoTax", amountNoTax != null ? amountNoTax.getDouble() : null);
// 税额 - 使用ntax
UFDouble taxAmount = body.getNtax();
detailItem.put("taxAmount", taxAmount != null ? taxAmount.getDouble() : null);
// 备注 - 使用vnotebody
detailItem.put("remark", body.getVnotebody());
// 原收货单信息
detailItem.put("oldOrderNo", null);
detailItem.put("oldOrderSn", null);
details.add(detailItem);
}
}
return details;
}
/**
* 构建符合MES系统接口规范的请求数据
*/
private JSONObject buildSyncData(PurchaseInHeadVO head, PurchaseInBodyVO[] bodys) throws BusinessException {
// 创建请求数据
JSONObject requestData = new JSONObject();
JSONObject data = new JSONObject();
// 设置收货单主表信息
// 收货单号（必填）
data.put("orderNo", head.getVbillcode());
// 收货日期
UFDate dbilldate = head.getDbilldate();
data.put("orderDate", dbilldate != null ? dbilldate.toString().substring(0, 10) : null);
// 收货类型
data.put("orderType", "P");
// 事务类型
data.put("type", null);
// 仓库编码
String storeId = transferCodeByPk(StordocVO.getDefaultTableName(), StordocVO.CODE,
StordocVO.PK_STORDOC, head.getCwarehouseid());
data.put("storeId", storeId);
// 采购部门ID（必填）- 注意：根据字段字典，采购部门字段为cdptid而不是cdeptid
String departmentId = transferCodeByPk(DeptVersionVO.getDefaultTableName(), DeptVersionVO.CODE,
DeptVersionVO.PK_VID, head.getCdptvid());
data.put("departmentId", departmentId);
// 采购员 - 采购员字段为cbizid
String purchaser = transferCodeByPk(PsndocVO.getDefaultTableName(), PsndocVO.CODE,
PsndocVO.PK_PSNDOC, head.getCbizid());
data.put("purchaser", purchaser);
// 供应商编码（必填）
String supplyId = transferCodeByPk(SupplierVO.getDefaultTableName(), SupplierVO.CODE,
SupplierVO.PK_SUPPLIER, head.getCvendorid());
data.put("supplyId", supplyId);
// 货币ID
data.put("currency", null);
// 汇率（必填）
data.put("rate", null);
// 结算方式
data.put("settleType", null);
// 开票依据
data.put("billBasis", null);
// 生成方式（必填）- P:按采购订单, Z:直接生成
data.put("genType", "P");
// 分类（必填）- N:货物, Y:费用
data.put("costOrder", "N");
// 是否退货（必填）- N:否, Y:是
data.put("returned", head.getFreplenishflag());
// 备注
data.put("remark", head.getVnote());
// 维护人信息
data.put("creatorNo", null); // 创建人
data.put("creator", head.getBillmaker()); // 制单人
data.put("creatTime", head.getDmakedate() != null ? head.getCreationtime().toString() : null); // 创建时间
// 构建明细数据
JSONArray details = buildDetailsData(bodys);
data.put("Details", details);
requestData.put("Data", data);
obmlog.debug("AfterSigningSynchronizeRuleMES-采购收货单请求数据: " + requestData.toJSONString());
return requestData;
}
/**
* 转换特殊字段 如 1/1 转换为小数 1.0
*/
private String transferSpecialField(String field) {
if (field == null || field.trim().isEmpty()) {
return null;
}
String[] split = field.split("/");
if (split.length == 2) {
String numStr = split[0].trim();
String denStr = split[1].trim();
if (denStr.equals("0")) {
return "0.00"; // 分母不能为零
}
try {
BigDecimal numerator = new BigDecimal(numStr);
BigDecimal denominator = new BigDecimal(denStr);
return numerator.divide(denominator, 2, RoundingMode.HALF_UP).toString();
} catch (NumberFormatException e) {
return field; // 非法数字，返回原字段
}
}
return field;
}
/**
* 根据主键查询编码
*/
private String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException {
if (StringUtils.isEmpty(pk)) {
return null;
}
SqlBuilder sqlBuilder = new SqlBuilder();
sqlBuilder.append(" select " + selectField);
sqlBuilder.append(" from " + tableName);
sqlBuilder.append(" where ");
sqlBuilder.append(pkField, pk);
Object o = dao.executeQuery(sqlBuilder.toString(), new ColumnProcessor());
if (o == null) {
throw new BusinessException("未查询到编码信息，sql【" + sqlBuilder + "】");
}
return o.toString();
}
}

4
ic/src/private/nc/bs/ic/m4c/sign/SignBP.java
View File

@ -50,10 +50,10 @@ public class SignBP implements ISignBP<SaleOutVO>, ISignRuleProvider<SaleOutVO>
processor.addAfterRule(new ArsubToVoucherRule());
processor.addAfterRule(new SaleOutProceedsRuleCG());
processor.addAfterRule(new MobAfterSignMessageRule());
// 销售出库 多一个步骤 先提交销售交货单 与同步销售出库单的orderNo一致
processor.addAfterRule(new SalesDeliveryOrderRuleMES());
// 销售出库 签字后 同步到MES金思维系统
processor.addAfterRule(new AfterSigningSynchronizeRuleMES());
// 盘点（审批后传MES）
// 销售出库 签字后 同步到锐制
processor.addAfterRule(new AfterSigningSynchronizeRuleRZ());
}

244
ic/src/private/nc/bs/ic/m4c/sign/rule/AfterSigningSynchronizeRuleMES.java
View File

@ -8,6 +8,7 @@ import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.jdbc.framework.processor.ColumnProcessor;
import nc.vo.bd.currtype.CurrtypeVO;
import nc.vo.bd.cust.CustomerVO;
import nc.vo.bd.material.MaterialVO;
import nc.vo.bd.material.measdoc.MeasdocVO;
@ -20,9 +21,13 @@ import nc.vo.ic.m4c.entity.SaleOutVO;
import nc.vo.org.DeptVO;
import nc.vo.pub.BusinessException;
import nc.vo.pub.lang.UFDate;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.pub.SqlBuilder;
import nccloud.pubift.commen.itf.utils.IHttpPostOtherSys;
import net.sf.mpxj.primavera.schema.CurrencyType;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
@ -31,10 +36,9 @@ import java.text.SimpleDateFormat;
*/
public class AfterSigningSynchronizeRuleMES implements IRule<SaleOutVO> {
private static final String SALE_OUT_URL = "/GTHINKING/AjaxService/N_MISPRO/SaleOrderOutbound.ashx/SaveData"; // 销售出库登记接口
private static final SimpleDateFormat dateTimeFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
private static final String logginfo = "OALOG";
private static final Log obmlog = Log.getInstance(logginfo);
private static BaseDAO dao = new BaseDAO();
private static final BaseDAO dao = new BaseDAO();
public AfterSigningSynchronizeRuleMES() {
}
@ -55,14 +59,12 @@ public class AfterSigningSynchronizeRuleMES implements IRule<SaleOutVO> {
JSONObject syncData = buildSyncData(hvo, bvos);
if (syncData != null) {
// 发送数据到金思维系统（使用HttpPostOtherSysImpl处理网络请求）
String mesResponse = httpPostOtherSys.callMes(SALE_OUT_URL, syncData);
obmlog.debug("AfterSigningSynchronizeRule-金思维系统响应: " + mesResponse);
// 解析响应，处理结果
processResponse(hvo.getVbillcode(), mesResponse);
httpPostOtherSys.sendToExternalSystem(SALE_OUT_URL, syncData);
}
}
} catch (Exception e) {
obmlog.error("AfterSigningSynchronizeRule-处理异常:" + e.getMessage(), e);
ExceptionUtils.wrappException(e);
}
}
@ -77,128 +79,118 @@ public class AfterSigningSynchronizeRuleMES implements IRule<SaleOutVO> {
return null;
}
JSONObject requestData = new JSONObject();
requestData.put("operation_type", "I");
JSONObject info = new JSONObject();
// 主表数据 - 根据字典字段映射
info.put("orderNo", hvo.getVbillcode()); // 提货单ID - 单据号(vbillcode)
JSONObject dataObj = new JSONObject();
// 主表数据 - 需要手输入
dataObj.put("orderNo", hvo.getVbillcode()); // 收货单号 - 单据号(vbillcode)
// 日期格式转换
UFDate dbilldate = hvo.getDbilldate();
info.put("orderDate", dbilldate.toString()); // 提单日期 - 单据日期(dbilldate)
info.put("planDate", dbilldate.toString()); // 计划日期 - 使用同样的单据日期
info.put("actureDate", dbilldate.toString());
info.put("genType", null);
info.put("type", "XSCK");
dataObj.put("orderDate", dbilldate.toString().substring(0, 10)); // 收货日期 - 单据日期(dbilldate)，格式：yyyy-MM-dd
dataObj.put("planDate", dbilldate.toString().substring(0, 10)); // 计划日期 - 单据日期(dbilldate)，格式：yyyy-MM-dd
dataObj.put("actureDate", dbilldate.toString().substring(0, 10)); // 实际日期 - 单据日期(dbilldate)，格式：yyyy-MM-dd
dataObj.put("orderType", null); // 收货类型 - 无对应字段
dataObj.put("type", "XSCK"); // 事务类型 - 销售出库
// 部门ID - 部门(cdptvid)
info.put("departmentId", transferCodeByPk(DeptVO.getDefaultTableName(), DeptVO.CODE, DeptVO.PK_DEPT, hvo.getCdptvid()));
// 仓库ID - 仓库(cwarehouseid)
info.put("storeId", transferCodeByPk(RackVO.getDefaultTableName(), RackVO.CODE, RackVO.PK_RACK, hvo.getCwarehouseid()));
// TODO
info.put("exRate", null);
info.put("sType", "N"); // 发出默认值
info.put("billing", "Y"); // 出具发票默认值
info.put("billingBasis", "S"); // 开票依据默认值
info.put("effDate", null);
info.put("consignStoreId", null); // 寄售仓库ID
info.put("consignType", null); // 寄售事务类型
info.put("operatorNo", null); // 经办人工号 - 制单人(billmaker)
info.put("operatorName", null); // 经办人
// 保管员 - 库管员(cwhsmanagerid)
info.put("storeKeeper", transferCodeByPk(PsndocVO.getDefaultTableName(), PsndocVO.CODE, PsndocVO.PK_PSNDOC, hvo.getCwhsmanagerid()));
// 保管员ID - 库管员(cwhsmanagerid)
info.put("cwhsmanagerid", transferCodeByPk(PsndocVO.getDefaultTableName(), PsndocVO.CODE, PsndocVO.PK_PSNDOC, hvo.getCwhsmanagerid()));
// 客户ID - 订单客户(ccustomerid)
info.put("customId", transferCodeByPk(CustomerVO.getDefaultTableName(), CustomerVO.CODE, CustomerVO.PK_CUSTOMER, hvo.getCcustomerid()));
info.put("mark", "Y"); // 生成标志默认值
info.put("remark", hvo.getVnote()); // 备注 - 备注(vnote)
// 构建details明细数组
dataObj.put("departmentId", transferCodeByPk(DeptVO.getDefaultTableName(),
DeptVO.CODE, DeptVO.PK_DEPT, hvo.getCdptvid())); // 采购部门ID
// 仓库编码 - 仓库(cwarehouseid)
dataObj.put("storeId", transferCodeByPk(RackVO.getDefaultTableName(),
RackVO.CODE, RackVO.PK_RACK, hvo.getCwarehouseid())); // 仓库编码
// 采购员 - 业务员(cbizpersonid)
dataObj.put("purchaser", transferCodeByPk(PsndocVO.getDefaultTableName(),
PsndocVO.CODE, PsndocVO.PK_PSNDOC, hvo.getCbizid()));
// 客户ID - 订单客户(ccustomerid)，这里因为是采购所以用供应商映射
dataObj.put("supplyId", transferCodeByPk(CustomerVO.getDefaultTableName(),
CustomerVO.CODE, CustomerVO.PK_CUSTOMER, hvo.getCcustomerid()));
// 发出
dataObj.put("sType", "N");
//出具发票
dataObj.put("billing", "Y");
//开票依据
dataObj.put("billingBasis", "S");
//有效日期
dataObj.put("effDate", null);
//寄售仓库ID
dataObj.put("consignStoreId", null);
//寄售事务类型
dataObj.put("consignType", null);
//经办人工号
dataObj.put("operatorNo", null);
//经办人
dataObj.put("operatorName", null);
//保管员
dataObj.put("storeKeeper", null);
//客户ID
dataObj.put("customId", transferCodeByPk(CustomerVO.getDefaultTableName(), CustomerVO.CODE, CustomerVO.PK_CUSTOMER, hvo.getCcustomerid()));
//生成标志
dataObj.put("mark", "Y");
//备注
dataObj.put("remark", hvo.getVnote());
// 构建Details明细数组
JSONArray details = new JSONArray();
if (bvos != null) {
for (SaleOutBodyVO bvo : bvos) {
JSONObject detail = new JSONObject();
detail.put("orderNo", hvo.getVbillcode()); // 提货单ID - 单据号(vbillcode)
detail.put("sequenceNum", bvo.getCrowno());
// 来源单据信息 - 根据字典正确映射
detail.put("saleOrderNo", null); // SOID - 来源单据号(vsourcebillcode)
detail.put("saleSequenceNum", null); // SO序号 - 来源单据行号(vsourcerowno)
detail.put("allocationNum", null); // 分配号
// 物料ID - 物料(cmaterialoid)
detail.put("materialId", transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, bvo.getCmaterialoid()));
// 计量单位 - 主单位(cunitid)
detail.put("unit", transferCodeByPk(MeasdocVO.getDefaultTableName(), MeasdocVO.CODE, MeasdocVO.PK_MEASDOC, bvo.getCunitid()));
detail.put("productNum", null);
// 库位 - 货位(clocationid)
detail.put("storageId", transferCodeByPk(RackVO.getDefaultTableName(), RackVO.CODE, RackVO.PK_RACK, bvo.getClocationid()));
// 物料批号 - 批次号(vbatchcode)
detail.put("batchNum", bvo.getVbatchcode());
detail.put("scaleFactor", bvo.getVchangerate());
// 应发数量和实发数量
detail.put("issuedQty", bvo.getNshouldassistnum()); // 应发数量(nshouldassistnum)
detail.put("mIssuedQty", bvo.getNshouldnum()); // 主应发数量(nshouldnum)
detail.put("actQry", bvo.getNassistnum()); // 实发数量(nassistnum)
detail.put("mActQry", bvo.getNnum()); // 主实发数量(nnum)
detail.put("assistActQry", null); // 辅助实发数量(nassistnum)
// 客户信息
// 客户ID - 客户(casscustid)
detail.put("customId", transferCodeByPk(CustomerVO.getDefaultTableName(), CustomerVO.CODE, CustomerVO.PK_CUSTOMER, bvo.getCasscustid()));
// 供应商信息
// 供应商ID - 供应商(cvendorid)
detail.put("supplierId", transferCodeByPk(SupplierVO.getDefaultTableName(), SupplierVO.CODE, SupplierVO.PK_SUPPLIER, bvo.getCvendorid()));
detail.put("color", null);
// 生产日期
detail.put("manufactureDate", null); // 生产日期(dproducedate)
detail.put("properties", null);
detail.put("remark", bvo.getVnotebody()); // 备注 - 行备注(vnotebody)
// 汇率
dataObj.put("exRate", bvo.getNchangestdrate());
JSONObject detail = new JSONObject();
detail.put("orderNo", hvo.getVbillcode()); // 提货单ID - 单据号(vbillcode) - 必填
detail.put("sequenceNum", bvo.getCrowno()); // 提货单序号 - 行号(crowno) - 必填
detail.put("type", "XSCK"); // 事务类型 - 默认XSCK
// 来源单据信息
detail.put("saleOrderNo", bvo.getVsourcebillcode()); // SOID - 来源单据号(vsourcebillcode)
detail.put("saleSequenceNum", bvo.getVsourcerowno()); // SO序号 - 来源单据行号(vsourcerowno)
detail.put("allocationNum", null); // 分配号
// 物料信息 - 必填
detail.put("materialId", transferCodeByPk(MaterialVO.getDefaultTableName(),
MaterialVO.CODE, MaterialVO.PK_MATERIAL, bvo.getCmaterialoid())); // 物料ID - 必填
detail.put("unit", transferCodeByPk(MeasdocVO.getDefaultTableName(),
MeasdocVO.CODE, MeasdocVO.PK_MEASDOC, bvo.getCunitid())); // 计量单位 - 必填
detail.put("productNum", null); // 制令号
// 库位 - 必填
detail.put("storageId", transferCodeByPk(RackVO.getDefaultTableName(),
RackVO.CODE, RackVO.PK_RACK, bvo.getClocationid())); // 库位 - 必填
detail.put("batchNum", bvo.getVbatchcode()); // 物料批号 - 必填
detail.put("scaleFactor", transferSpecialField(bvo.getVchangerate())); // 换算系数 - 必填
// 数量信息 - 必填
detail.put("issuedQty", bvo.getNshouldassistnum()); // 应发数量 - 必填
detail.put("mIssuedQty", bvo.getNshouldnum()); // 主应发数量 - 必填
detail.put("actQry", bvo.getNassistnum()); // 实发数量 - 必填
detail.put("mActQry", bvo.getNnum()); // 主实发数量 - 必填
detail.put("assistActQry", bvo.getNassistnum()); // 辅助实发数量 - 必填
// 客户和供应商信息
detail.put("customId", transferCodeByPk(CustomerVO.getDefaultTableName(),
CustomerVO.CODE, CustomerVO.PK_CUSTOMER, bvo.getCasscustid())); // 客户ID
detail.put("supplierId", transferCodeByPk(SupplierVO.getDefaultTableName(),
SupplierVO.CODE, SupplierVO.PK_SUPPLIER, bvo.getCvendorid())); // 供应商ID
detail.put("manufactureDate", bvo.getDproducedate()); // 生产日期
detail.put("color", null); // 颜色
detail.put("properties", null);
detail.put("remark", bvo.getVnotebody()); // 备注 - 行备注(vnotebody)
details.add(detail);
}
}
info.put("details", details);
// 将info对象添加到请求数据中
requestData.put("info", info);
requestData.put("operation_type", "I");
requestData.put("info", dataObj);
dataObj.put("details", details);
return requestData;
}
/**
* 安全获取字符串值，防止空指针异常
*/
private String getStringValue(Object value) {
return value == null ? "" : value.toString();
}
/**
* 处理金思维系统响应
*/
private void processResponse(String vbillcode, String response) {
if (StringUtils.isEmpty(response)) {
obmlog.error("AfterSigningSynchronizeRule-响应为空，单据号: " + vbillcode);
return;
}
try {
JSONObject respObj = JSONObject.parseObject(response);
JSONObject result = respObj.getJSONObject("result");
if (result != null) {
boolean success = result.getBooleanValue("success");
String message = result.getString("message");
String errorMessage = result.getString("errorMessage");
String orderNo = result.getString("orderNo");
if (success) {
obmlog.info("AfterSigningSynchronizeRule-同步成功，单据号: " + vbillcode + ", 返回单号: " + orderNo + ", 消息: " + message);
} else {
obmlog.error("AfterSigningSynchronizeRule-同步失败，单据号: " + vbillcode + ", 错误: " + errorMessage);
throw new BusinessException("同步到金思维系统失败: " + errorMessage);
}
}
} catch (Exception e) {
obmlog.error("AfterSigningSynchronizeRule-处理响应异常: " + e.getMessage(), e);
}
}
private String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException {
if (nc.vo.cmp.util.StringUtils.isEmpty(pk)) {
return null;
@ -214,4 +206,28 @@ public class AfterSigningSynchronizeRuleMES implements IRule<SaleOutVO> {
}
return o.toString();
}
private String transferSpecialField(String field) {
if (field == null || field.trim().isEmpty()) {
return null;
}
String[] split = field.split("/");
if (split.length == 2) {
String numStr = split[0].trim();
String denStr = split[1].trim();
if (denStr.equals("0")) {
return "0.00"; // 分母不能为零
}
try {
BigDecimal numerator = new BigDecimal(numStr);
BigDecimal denominator = new BigDecimal(denStr);
return numerator.divide(denominator, 2, RoundingMode.HALF_UP).toString();
} catch (NumberFormatException e) {
return field; // 非法数字，返回原字段
}
}
return field;
}
}

271
ic/src/private/nc/bs/ic/m4c/sign/rule/SalesDeliveryOrderRuleMES.java Normal file
View File

@ -0,0 +1,271 @@
package nc.bs.ic.m4c.sign.rule;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import nc.bs.dao.BaseDAO;
import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.jdbc.framework.processor.ColumnProcessor;
import nc.vo.bd.currtype.CurrtypeVO;
import nc.vo.bd.cust.CustomerVO;
import nc.vo.bd.material.MaterialVO;
import nc.vo.bd.material.measdoc.MeasdocVO;
import nc.vo.bd.psn.PsndocVO;
import nc.vo.bd.rack.RackVO;
import nc.vo.bd.supplier.SupplierVO;
import nc.vo.ic.m4c.entity.SaleOutBodyVO;
import nc.vo.ic.m4c.entity.SaleOutHeadVO;
import nc.vo.ic.m4c.entity.SaleOutVO;
import nc.vo.org.DeptVO;
import nc.vo.pub.BusinessException;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.pub.SqlBuilder;
import nc.vo.vorg.DeptVersionVO;
import nccloud.pubift.commen.itf.utils.IHttpPostOtherSys;
import java.math.BigDecimal;
import java.math.RoundingMode;
/**
* 销售交货单(BIP无) 推送至MES
*/
public class SalesDeliveryOrderRuleMES implements IRule<SaleOutVO> {
private static final BaseDAO dao = new BaseDAO();
// MES系统API接口地址
private static final String MES_API_URL = "/GTHINKING/AjaxService/N_MISPRO/SalesDeliveryOrder.ashx/SaveData";
// 删除销售交货单接口地址
private static final String MES_DELETE_API_URL = "/GTHINKING/AjaxService/N_XSSJJSA/102397002.ashx/SOTH_DELETE";
private static final Log obmlog = Log.getInstance("OALOG");
@Override
public void process(SaleOutVO[] saleOutVOS) {
try {
if (saleOutVOS == null || saleOutVOS.length == 0) {
return;
}
// 初始化HTTP请求工具类
IHttpPostOtherSys httpPostOtherSys = NCLocator.getInstance().lookup(IHttpPostOtherSys.class);
// 处理每个销售交货单
for (SaleOutVO saleOutVO : saleOutVOS) {
SaleOutHeadVO hvo = (SaleOutHeadVO) saleOutVO.getParentVO();
SaleOutBodyVO[] bvos = (SaleOutBodyVO[]) saleOutVO.getChildrenVO();
// 构建要发送的数据
JSONObject syncData = buildSyncData(hvo, bvos);
if (syncData != null) {
// 每次新增销售交货单之前 先删除 然后再新增
String orderNo = hvo.getVbillcode();
boolean flag = deleteSalesDeliveryOrder(orderNo);
if (flag) {
// 发送数据到MES系统
obmlog.debug("SalesDeliveryOrderRuleMES-准备发送销售交货单数据: " + hvo.getVbillcode());
httpPostOtherSys.sendToExternalSystem(MES_API_URL, syncData);
}
}
}
} catch (Exception e) {
obmlog.error("SalesDeliveryOrderRuleMES-处理异常:" + e.getMessage(), e);
ExceptionUtils.wrappException(e);
}
}
/**
* 构建符合MES系统接口规范的请求数据
*/
private JSONObject buildSyncData(SaleOutHeadVO hvo, SaleOutBodyVO[] bvos) throws BusinessException {
obmlog.debug("SalesDeliveryOrderRuleMES-开始处理销售交货单: " + hvo.getVbillcode());
// 检查组织是否符合条件
if (!hvo.getPk_org().equals("0001A110000000000677")) {
obmlog.debug("SalesDeliveryOrderRuleMES-跳过处理销售交货单,因为此单据组织非电缆: " + hvo.getVbillcode());
return null;
}
JSONObject requestData = new JSONObject();
JSONObject info = new JSONObject();
// 主表数据 - 所有字段处理
// 必填字段
info.put("orderNo", hvo.getVbillcode()); // 必填：交货单号
info.put("orderDate", hvo.getDbilldate() == null ? null : hvo.getDbilldate().toString().substring(0, 10)); // 必填：TODO 开单日期，格式：yyyy-MM-dd
info.put("deliveryDate", hvo.getDbilldate() == null ? null : hvo.getDbilldate().toString().substring(0, 10)); // 必填： TODO 计划发货日期，暂用单据日期
// 客户ID - 订单客户(ccustomerid)
info.put("customId", transferCodeByPk(CustomerVO.getDefaultTableName(),
CustomerVO.CODE, CustomerVO.PK_CUSTOMER, hvo.getCcustomerid())); // 必填：客户编码
// 开票单位编码
info.put("invoicingUnit", null); // 必填：TODO 开票单位编码，无对应字段
// 销售部门编码
info.put("departmentId", transferCodeByPk(DeptVersionVO.getDefaultTableName(),
DeptVersionVO.CODE, DeptVersionVO.PK_VID, hvo.getCdptvid())); // 必填：销售部门编码
// 销售员
info.put("seller", transferCodeByPk(PsndocVO.getDefaultTableName(),
PsndocVO.CODE, PsndocVO.PK_PSNDOC, hvo.getCbiztype())); // 必填：TODO 销售员
info.put("exchangeRate", null); // 必填：TODO 汇率，无对应字段 销售出库也没有
info.put("invoicingBasis", "S"); // 必填：开票依据
info.put("settlementType", null); // 必填：TODO 结算方式，无对应字段
// 仓库编码
info.put("warehouseId", transferCodeByPk(RackVO.getDefaultTableName(),
RackVO.CODE, RackVO.PK_RACK, hvo.getCwarehouseid())); // 必填：仓库编码
info.put("type", "XSJH"); // 必填：事务类型，销售交货
info.put("genType", null); // 必填：TODO 生成方式，无对应字段
info.put("returned", null); // 必填：TODO 是否退货，无对应字段
// 非必填字段
info.put("transportMode", null); // 运输方式
info.put("deliveryAddress", null); // 收货地点
info.put("contacts", null); // 联系人
info.put("contactNum", null); // 联系电话
info.put("originalNo", null); // 原交货单号
info.put("remark", hvo.getVnote()); // 备注
info.put("creatorNo", null); // 维护人工号
info.put("creator", null); // 维护人
info.put("creatTime", null); // 维护时间
// 构建明细数组
JSONArray details = new JSONArray();
if (bvos != null) {
for (SaleOutBodyVO bvo : bvos) {
JSONObject detail = new JSONObject();
// 表头字段需要表体字段
// 必填：货币编码
info.put("currency", transferCodeByPk(CurrtypeVO.getDefaultTableName(),
CurrtypeVO.CODE, CurrtypeVO.PK_CURRTYPE, bvo.getCorigcurrencyid()));
// 必填字段
detail.put("orderNo", hvo.getVbillcode()); // 必填：交货单号
detail.put("orderSn", bvo.getCrowno()); // 必填：TODO 交货单序号
// 生成方式为按订单时必填
detail.put("soOrderNo", bvo.getVsourcebillcode()); // TODO 销售订单号
detail.put("soSequenceNum", bvo.getVsourcerowno()); // TODO 销售订单序号
// 物料编码
detail.put("materialId", transferCodeByPk(MaterialVO.getDefaultTableName(),
MaterialVO.CODE, MaterialVO.PK_MATERIAL, bvo.getCmaterialoid())); // 必填：物料编码
// 计量单位
detail.put("unit", transferCodeByPk(MeasdocVO.getDefaultTableName(),
MeasdocVO.CODE, MeasdocVO.PK_MEASDOC, bvo.getCunitid())); // 必填：计量单位
detail.put("scaleFactor", transferSpecialField(bvo.getVchangerate())); // 必填：换算系数
detail.put("taxRate", bvo.getNtaxrate()); // 必填：税率
detail.put("recQty", bvo.getNshouldassistnum()); // 必填：应收数量
detail.put("mainRecQty", bvo.getNshouldnum()); // 必填：TODO 主应收数量
// 非必填字段
detail.put("batchNum", null); // 物料批号
detail.put("productNum", null); // 制令号
detail.put("assitRecQty", null); // 辅应收数量
detail.put("priceIncludeTax", null); // 原币含税价格
detail.put("amountIncludeTax", null); // 原币含税金额
detail.put("taxAmount", null); // 税额
detail.put("remark", null); // 备注
details.add(detail);
}
}
info.put("Details", details);
// 将info对象添加到请求数据中
requestData.put("Data", info);
return requestData;
}
/**
* 根据主键获取对应的编码
*/
private String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException {
if (pk == null || pk.trim().isEmpty()) {
return null;
}
SqlBuilder sqlBuilder = new SqlBuilder();
sqlBuilder.append(" select " + selectField);
sqlBuilder.append(" from " + tableName);
sqlBuilder.append(" where ");
sqlBuilder.append(pkField, pk);
Object o = dao.executeQuery(sqlBuilder.toString(), new ColumnProcessor());
if (o == null) {
throw new BusinessException("未查询到编码信息，sql【" + sqlBuilder + "】");
}
return o.toString();
}
/**
* 删除第三方系统中的销售交货单
*
* @param orderNo 要删除的销售交货单号
* @return 删除操作是否成功
* @throws BusinessException 业务异常
*/
public boolean deleteSalesDeliveryOrder(String orderNo) throws BusinessException {
try {
if (orderNo == null || orderNo.trim().isEmpty()) {
throw new BusinessException("销售交货单号不能为空");
}
obmlog.debug("SalesDeliveryOrderRuleMES-准备删除第三方系统销售交货单: " + orderNo);
// 构建请求数据
JSONObject requestData = new JSONObject();
JSONObject dataObj = new JSONObject();
dataObj.put("orderNo", orderNo);
requestData.put("Data", dataObj);
// 初始化HTTP请求工具类
IHttpPostOtherSys httpPostOtherSys = NCLocator.getInstance().lookup(IHttpPostOtherSys.class);
// 发送删除请求
String response = httpPostOtherSys.callMes(MES_DELETE_API_URL, requestData);
obmlog.debug("SalesDeliveryOrderRuleMES-删除请求返回结果: " + response);
// 解析返回结果
JSONObject jsonResponse = JSONObject.parseObject(response);
boolean isSuccess = jsonResponse.getBooleanValue("Success");
String errorMessage = jsonResponse.getString("ErrorMessage");
if (!isSuccess) {
obmlog.error("SalesDeliveryOrderRuleMES-删除销售交货单失败: " + orderNo + ", 错误信息: " + errorMessage);
throw new BusinessException("删除销售交货单失败: " + (errorMessage != null ? errorMessage : "未知错误"));
}
obmlog.debug("SalesDeliveryOrderRuleMES-成功删除销售交货单: " + orderNo);
return true;
} catch (Exception e) {
obmlog.error("SalesDeliveryOrderRuleMES-删除销售交货单异常:" + e.getMessage(), e);
throw new BusinessException("删除销售交货单时发生异常: " + e.getMessage(), e);
}
}
private String transferSpecialField(String field) {
if (field == null || field.trim().isEmpty()) {
return null;
}
String[] split = field.split("/");
if (split.length == 2) {
String numStr = split[0].trim();
String denStr = split[1].trim();
if (denStr.equals("0")) {
return "0.00"; // 分母不能为零
}
try {
BigDecimal numerator = new BigDecimal(numStr);
BigDecimal denominator = new BigDecimal(denStr);
return numerator.divide(denominator, 2, RoundingMode.HALF_UP).toString();
} catch (NumberFormatException e) {
return field; // 非法数字，返回原字段
}
}
return field;
}
}

55
ic/src/private/nc/bs/ic/m4r/approve/rule/AfterApprovingSynchronizeRuleMES.java
View File

@ -3,7 +3,6 @@ package nc.bs.ic.m4r.approve.rule;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.yonyou.cloud.utils.StringUtils;
import nc.bs.dao.BaseDAO;
import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log;
@ -21,17 +20,17 @@ import nc.vo.org.DeptVO;
import nc.vo.pub.BusinessException;
import nc.vo.pub.lang.UFDate;
import nc.vo.pub.lang.UFDouble;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.pub.SqlBuilder;
import nc.vo.vorg.DeptVersionVO;
import nccloud.pubift.commen.itf.utils.IHttpPostOtherSys;
import java.text.SimpleDateFormat;
/**
* 盘点（审批后传MES）
*/
public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
private static final String INV_COUNT_URL = "/GTHINKING/AjaxService/U20231172_N_XSSJJSA/102397009.ashx/KCPD_INSERT"; // 盘点单同步接口
private static final String INV_COUNT_URL = "/GTHINKING/AjaxService/N_KCSJJS/101527005.ashx/KCPD_INSERT"; // 盘点单同步接口
private static final String logginfo = "OALOG";
private static final Log obmlog = Log.getInstance(logginfo);
private static final BaseDAO dao = new BaseDAO();
@ -58,15 +57,13 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
if (syncData != null) {
// 发送数据到金思维系统（使用HttpPostOtherSysImpl处理网络请求）
String mesResponse = httpPostOtherSys.callMes(INV_COUNT_URL, syncData);
obmlog.debug("AfterApprovingSynchronizeRule-金思维系统响应: " + mesResponse);
httpPostOtherSys.sendToExternalSystem(INV_COUNT_URL, syncData);
// 解析响应，处理结果
processResponse(hvo.getVbillcode(), mesResponse);
}
}
} catch (Exception e) {
obmlog.error("AfterApprovingSynchronizeRule-处理异常:" + e.getMessage(), e);
ExceptionUtils.wrappException(e);
}
}
@ -82,6 +79,7 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
}
// 按照新规范构建请求数据
JSONObject requestBody = new JSONObject();
JSONObject requestData = new JSONObject();
// 盘点主信息 盘点单号 为空时自动生成
@ -92,7 +90,7 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
requestData.put("CKID", warehouseCode);
// 盘点部门编码
String deptCode = transferCodeByPk(DeptVO.getDefaultTableName(), DeptVO.CODE, DeptVO.PK_DEPT, hvo.getCdptvid());
String deptCode = transferCodeByPk(DeptVersionVO.getDefaultTableName(), DeptVersionVO.CODE, DeptVersionVO.PK_VID, hvo.getCdptvid());
requestData.put("BMID", deptCode);
// 盘点人
requestData.put("PDR", getStringValue(hvo.getCountoperator()));
@ -115,11 +113,12 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
// 获取序号并转换为浮点数
String crownStr = bvo.getCrowno();
try {
detail.put("XH", Double.parseDouble(crownStr)); // 序号 - 必填
// 序号
detail.put("XH", Double.parseDouble(crownStr));
} catch (NumberFormatException e) {
detail.put("XH", null); // 默认序号
detail.put("XH", null);
}
// 物料编码 - 必填
// 物料编码
detail.put("WLID", transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE, MaterialVO.PK_MATERIAL, bvo.getCmaterialvid()));
// 货位
detail.put("KW", transferCodeByPk(RackVO.getDefaultTableName(), RackVO.CODE, RackVO.PK_RACK, bvo.getClocationid()));
@ -160,8 +159,9 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
}
}
requestData.put("DETAILS", details);
requestBody.put("KCPD", requestData);
return requestData;
return requestBody;
}
/**
@ -171,35 +171,6 @@ public class AfterApprovingSynchronizeRuleMES implements IRule<InvCountBillVO> {
return value == null ? "" : value.toString();
}
/**
* 处理金思维系统响应
*/
private void processResponse(String vbillcode, String response) {
if (StringUtils.isEmpty(response)) {
obmlog.error("AfterApprovingSynchronizeRule-响应为空，单据号: " + vbillcode);
return;
}
try {
JSONObject respObj = JSONObject.parseObject(response);
JSONObject result = respObj.getJSONObject("result");
if (result != null) {
boolean success = result.getBooleanValue("success");
String message = result.getString("message");
String errorMessage = result.getString("errorMessage");
String orderNo = result.getString("orderNo");
if (success) {
obmlog.info("AfterApprovingSynchronizeRule-同步成功，单据号: " + vbillcode + ", 返回单号: " + orderNo + ", 消息: " + message);
} else {
obmlog.error("AfterApprovingSynchronizeRule-同步失败，单据号: " + vbillcode + ", 错误: " + errorMessage);
throw new BusinessException("同步到金思维系统失败: " + errorMessage);
}
}
} catch (Exception e) {
obmlog.error("AfterApprovingSynchronizeRule-处理响应异常: " + e.getMessage(), e);
}
}
private String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException {
if (nc.vo.cmp.util.StringUtils.isEmpty(pk)) {

2
ic/src/private/nccloud/pubift/commen/impl/utils/HttpPostOtherSysImpl.java
View File

@ -26,12 +26,12 @@ public class HttpPostOtherSysImpl implements IHttpPostOtherSys {
private static final String CLIENT_TYPE = "S";
private static final String EP_ID = "";
private static final String LOGIN_URL = "/GTHINKING/AjaxService/N_MISPRO/100208057.ashx/Login";
private static final String LOG_INFO_NAME = "OALOG";
private static final Log obmlog = Log.getInstance(LOG_INFO_NAME);
@Override
public String callMes(String url, JSONObject json) {
// String leip = SysParaInitQuery.getParaString(PubEnv.getPk_group(), "LEIP");
String mesip = "http://192.168.29.32";
String baseurl = mesip + url;
String tokenValue = this.getMESToken(mesip);

1
ic/src/public/nccloud/pubift/commen/itf/utils/IHttpPostOtherSys.java
View File

@ -24,5 +24,4 @@ public interface IHttpPostOtherSys {
* 发送数据到外部系统
*/
public void sendToExternalSystem(String apiPaht, Map<String, Object> requestData) throws BusinessException;
}

271
so/src/private/nc/bs/so/m30/rule/approve/AfterApprovingSynchronizeRuleMES.java Normal file
View File

@ -0,0 +1,271 @@
package nc.bs.so.m30.rule.approve;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import nc.bs.dao.BaseDAO;
import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.jdbc.framework.processor.ColumnProcessor;
import nc.vo.bd.balatype.BalaTypeVO;
import nc.vo.bd.currtype.CurrtypeVO;
import nc.vo.bd.cust.CustomerVO;
import nc.vo.bd.material.MaterialVO;
import nc.vo.bd.material.measdoc.MeasdocVO;
import nc.vo.bd.psn.PsndocVO;
import nc.vo.cmp.util.StringUtils;
import nc.vo.org.DeptVO;
import nc.vo.pub.BusinessException;
import nc.vo.pub.billtype.BilltypeVO;
import nc.vo.pub.lang.UFDate;
import nc.vo.pub.lang.UFDouble;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.pub.SqlBuilder;
import nc.vo.so.m30.entity.SaleOrderVO;
import nc.vo.so.m30.entity.SaleOrderHVO;
import nc.vo.so.m30.entity.SaleOrderBVO;
import nc.vo.vorg.DeptVersionVO;
import nccloud.bs.sc.scadjust.beforeedit.rule.head.Psndoc;
import nccloud.pubift.commen.itf.utils.IHttpPostOtherSys;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
/**
* 销售订单审批后推送MES金思维系统
*/
public class AfterApprovingSynchronizeRuleMES implements IRule<SaleOrderVO> {
private static final String SALE_ORDER_URL = "/GTHINKING/AjaxService/N_XSSJJSA/102397000.ashx/XSDD_INSERT"; // 销售订单同步接口
private static final String logginfo = "OALOG";
private static final Log obmlog = Log.getInstance(logginfo);
private static final BaseDAO dao = new BaseDAO();
public AfterApprovingSynchronizeRuleMES() {
}
@Override
public void process(SaleOrderVO[] saleOrderVOs) {
try {
if (saleOrderVOs == null || saleOrderVOs.length == 0) {
return;
}
// 初始化HTTP请求工具类
IHttpPostOtherSys httpPostOtherSys = NCLocator.getInstance().lookup(IHttpPostOtherSys.class);
// 处理每个销售订单
for (SaleOrderVO saleOrderVO : saleOrderVOs) {
SaleOrderHVO head = saleOrderVO.getParentVO();
SaleOrderBVO[] bodys = saleOrderVO.getChildrenVO();
// 构建要发送的数据
JSONObject syncData = buildSyncData(head, bodys);
if (syncData != null) {
// 发送数据到金思维系统
httpPostOtherSys.sendToExternalSystem(SALE_ORDER_URL, syncData);
}
}
} catch (Exception e) {
obmlog.error("AfterApprovingSynchronizeRuleMES-处理异常:" + e.getMessage(), e);
ExceptionUtils.wrappException(e);
}
}
/**
* 构建符合金思维系统接口规范的请求数据
*/
private JSONObject buildSyncData(SaleOrderHVO head, SaleOrderBVO[] bodys) throws BusinessException {
obmlog.debug("AfterApprovingSynchronizeRuleMES-开始处理销售订单: " + head.getVbillcode());
// 检查组织、单据类型等限制条件
if (!checkOrderValidForSync(head)) {
obmlog.debug("AfterApprovingSynchronizeRule-跳过处理销售订单,因为此单据组织非电缆: " + head.getVbillcode());
return null;
}
// 创建请求数据
JSONObject requestData = new JSONObject();
JSONObject data = new JSONObject();
// 销售订单号 这里超长了 改为手动输入
data.put("orderNo", head.getVbillcode());
// 客户订单号
data.put("customOrderNo", null);
// 订单日期（必填，格式为YYYY-MM-DD）
UFDate dbilldate = head.getDbilldate();
data.put("orderDate", dbilldate != null ? dbilldate.toString().substring(0, 10) : null);
// 订单类别（非必填）
data.put("orderType", transferCodeByPk(BilltypeVO.TABLENAME, BilltypeVO.PK_BILLTYPECODE, BilltypeVO.PK_BILLTYPE_ID, head.getCtrantypeid()));
// 生成方式
data.put("generation", "Z");
// 客户编码（必填，最大长度8）
String customerCode = transferCodeByPk(CustomerVO.getDefaultTableName(), CustomerVO.CODE,
CustomerVO.PK_CUSTOMER, head.getCcustomerid());
data.put("customId", customerCode);
data.put("seller", transferCodeByPk(PsndocVO.getDefaultTableName(), PsndocVO.NAME, PsndocVO.PK_PSNDOC, head.getCemployeeid()));
// 销售部门编码（必填，最大长度8）
String deptCode = transferCodeByPk(DeptVersionVO.getDefaultTableName(), DeptVersionVO.CODE,
DeptVersionVO.PK_VID, head.getCdeptvid());
data.put("departmentId", deptCode);
// 联系人（非必填）
data.put("contacts", null);
// 联系电话（非必填）
data.put("contactNum", null);
// "X"或"S" 这里只翻译了code 还需要判断
data.put("settlementType", transferCodeByPk(BalaTypeVO.getDefaultTableName(), BalaTypeVO.CODE, BalaTypeVO.PK_BALATYPE, head.getCbalancetypeid()));
// 货币（必填，最大长度3）
String currencyCode = transferCodeByPk(CurrtypeVO.getDefaultTableName(), CurrtypeVO.CODE, CurrtypeVO.PK_CURRTYPE, head.getCorigcurrencyid());
data.put("currency", currencyCode);
// 其他非必填字段一律设为null
data.put("priceListId", null);
data.put("invoicingUnit", transferCodeByPk(CustomerVO.getDefaultTableName(), CustomerVO.CODE, CustomerVO.PK_CUSTOMER, head.getCinvoicecustid()));
data.put("contractNo", null);
data.put("projectNo", null);
data.put("salesAreaId", null);
data.put("deliveryAreaId", null);
data.put("discount", null);
data.put("paymentType", null);
data.put("warranty", null);
data.put("retentionAmount", null);
data.put("prepayment", null);
data.put("payment", null);
data.put("salesChannels", null);
data.put("transportMode", null);
data.put("transportProxy", null);
data.put("packing", null);
data.put("deliveryAddress", null);
data.put("labelDemand", null);
data.put("skillsDemand", null);
data.put("contractType", null);
data.put("deliveryRemarks", null);
data.put("remarks", head.getVnote());
// 构建明细数据 - 只填必填字段
JSONArray details = new JSONArray();
if (bodys != null) {
for (SaleOrderBVO body : bodys) {
JSONObject detailItem = new JSONObject();
// 以下字段需要表体的字段
// 需求日期 表体dreceivedate
UFDate dreceivedate = body.getDreceivedate();
data.put("demandDate", dreceivedate != null ? dreceivedate.toString().substring(0, 10) : null);
// 计划发货日期 表体dsenddate
UFDate dsenddate = body.getDsenddate();
data.put("deliveryDate", dsenddate != null ? dsenddate.toString().substring(0, 10) : null);
// 汇率 表体nexchangerate
data.put("exchangeRate", body.getVchangerate() != null ? transferSpecialField(body.getVchangerate()) : null);
// 以下表体所需字段
// 序号
detailItem.put("sequenceNum", body.getCrowno());
// 合同序号
detailItem.put("contractNum", null);
// 物料编码
String materialCode = transferCodeByPk(MaterialVO.getDefaultTableName(), MaterialVO.CODE,
MaterialVO.PK_MATERIAL, body.getCmaterialvid());
detailItem.put("materialId", materialCode);
// 计量单位
detailItem.put("unit", transferCodeByPk(MeasdocVO.getDefaultTableName(), MeasdocVO.CODE, MeasdocVO.PK_MEASDOC, body.getCunitid()));
// 换算系数
detailItem.put("scaleFactor", body.getVchangerate() != null ? transferSpecialField(body.getVchangerate()) : null);
// 增值税率
UFDouble taxRate = body.getNtaxrate();
detailItem.put("vatRate", taxRate != null ? taxRate.toString() : null);
// 需求数量
UFDouble num = body.getNastnum();
detailItem.put("quantity", num != null ? num.getDouble() : null);
// 主需求数量
UFDouble mainNum = body.getNnum();
detailItem.put("mainQuantity", mainNum != null ? mainNum.getDouble() : null);
// 含税价格
UFDouble taxPrice = body.getNqtorigtaxprice();
detailItem.put("price", taxPrice != null ? taxPrice.getDouble() : null);
// 含税金额
UFDouble taxAmount = body.getNorigtaxmny();
detailItem.put("amount", taxAmount != null ? taxAmount.getDouble() : null);
// 无税单价
UFDouble noTaxPrice = body.getNqtorigprice();
detailItem.put("noTaxPrice", noTaxPrice != null ? noTaxPrice.getDouble() : null);
// 无税金额
UFDouble noTaxAmount = body.getNorigmny();
detailItem.put("noTaxAmount", noTaxAmount != null ? noTaxAmount.getDouble() : null);
UFDate dreceivedate1 = body.getDreceivedate();
detailItem.put("demandDate", dreceivedate1 != null ? dreceivedate1.toString().substring(0, 10) : null);
UFDate dsenddate1 = body.getDsenddate();
detailItem.put("deliveryDate", dsenddate1 != null ? dsenddate1.toString().substring(0, 10) : null);
// 其他非必填字段设为null
detailItem.put("productNum", null);
detailItem.put("factoryId", null);
detailItem.put("customMtId", null);
detailItem.put("customNo", null);
detailItem.put("customSN", null);
detailItem.put("remarks", null);
details.add(detailItem);
}
}
data.put("DETAILS", details);
requestData.put("Data", data);
return requestData;
}
/**
* 检查订单是否符合同步条件
*/
private boolean checkOrderValidForSync(SaleOrderHVO head) {
if (!head.getPk_org().equals("0001A110000000000677")) {
obmlog.debug("AfterApprovingSynchronizeRule-跳过处理销售出库单,因为此单据组织非电缆: " + head.getVbillcode());
return true;
}
return false;
}
/**
* 转换特殊字段 如 1/1 转换为小数 1.0
*/
private String transferSpecialField(String field) {
if (field == null || field.trim().isEmpty()) {
return null;
}
String[] split = field.split("/");
if (split.length == 2) {
String numStr = split[0].trim();
String denStr = split[1].trim();
if (denStr.equals("0")) {
return "0.00"; // 分母不能为零
}
try {
BigDecimal numerator = new BigDecimal(numStr);
BigDecimal denominator = new BigDecimal(denStr);
return numerator.divide(denominator, 2, RoundingMode.HALF_UP).toString();
} catch (NumberFormatException e) {
return field; // 非法数字，返回原字段
}
}
return field;
}
/**
* 根据主键查询编码
*/
private String transferCodeByPk(String tableName, String selectField, String pkField, String pk) throws BusinessException {
if (pk == null || pk.trim().isEmpty()) {
return null;
}
SqlBuilder sqlBuilder = new SqlBuilder();
sqlBuilder.append(" select " + selectField);
sqlBuilder.append(" from " + tableName);
sqlBuilder.append(" where ");
sqlBuilder.append(pkField, pk);
Object o = dao.executeQuery(sqlBuilder.toString(), new ColumnProcessor());
if (o == null) {
throw new BusinessException("未查询到编码信息，sql【" + sqlBuilder + "】");
}
return o.toString();
}
}

223
so/src/private/nc/impl/so/m30/action/main/ApproveSaleOrderAction.java Normal file
View File

@ -0,0 +1,223 @@
package nc.impl.so.m30.action.main;
import nc.bs.framework.common.NCLocator;
import nc.bs.pub.action.N_30_APPROVE;
import nc.bs.scmpub.rule.VOSagaFrozenValidateRule;
import nc.bs.so.m30.maintain.rule.delete.RewritePromotePriceDeleteRule;
import nc.bs.so.m30.plugin.Action30PlugInPoint;
import nc.bs.so.m30.rule.approve.*;
import nc.bs.so.m30.rule.atp.SaleOrderVOATPAfterRule;
import nc.bs.so.m30.rule.atp.SaleOrderVOATPBeforeRule;
import nc.bs.so.m30.rule.credit.RenovateARByHidsBeginRule;
import nc.bs.so.m30.rule.credit.RenovateARByHidsEndRule;
import nc.bs.so.m30.rule.m35.ArsubOffsetAfterApproveRule;
import nc.bs.so.m30.rule.me.SaleOrderVOApproveAfterRule;
import nc.impl.pubapp.pattern.data.bill.BillQuery;
import nc.impl.pubapp.pattern.data.vo.VOUpdate;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.impl.pubapp.pattern.rule.processer.AroundProcesser;
import nc.itf.scmpub.reference.uap.group.SysInitGroupQuery;
import nc.vo.credit.engrossmaintain.pub.action.M30EngrossAction;
import nc.vo.ml.NCLangRes4VoTransl;
import nc.vo.pub.BusinessException;
import nc.vo.pub.lang.UFBoolean;
import nc.vo.pubapp.AppContext;
import nc.vo.pubapp.pattern.exception.ExceptionUtils;
import nc.vo.pubapp.pattern.log.TimeLog;
import nc.vo.scmpub.msg.rule.UpdateMsgStatusRule;
import nc.vo.scmpub.res.billtype.SOBillType;
import nc.vo.scmpub.util.AppInfoContext;
import nc.vo.so.m30.entity.SaleOrderBVO;
import nc.vo.so.m30.entity.SaleOrderHVO;
import nc.vo.so.m30.entity.SaleOrderVO;
import nc.vo.so.pub.enumeration.BillStatus;
import nc.vo.so.pub.rule.SOPfStatusChgRule;
import nccloud.bs.so.mobile.saleorder.operation.rule.MobAfterApproveMessageRule;
import nccloud.commons.lang.ArrayUtils;
import nccloud.nc.vo.pub.pf.BusFlowInfoVO;
import nccloud.pubitf.riart.businesstype.IPFBusinessTypeService;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class ApproveSaleOrderAction {
public ApproveSaleOrderAction() {
}
public Object approve(SaleOrderVO[] bills, N_30_APPROVE script) {
Object ret = null;
try {
AroundProcesser<SaleOrderVO> processer = new AroundProcesser(Action30PlugInPoint.ApproveAction);
TimeLog.logStart();
this.setAppInfoContext();
this.addBeforeRule(processer);
processer.before(bills);
TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0162"));
ret = script.procActionFlow(script.getPfParameterVO());
SaleOrderVO[] newbills = script.getVos();
this.updateNewBillStatus(newbills);
TimeLog.logStart();
Integer newbillstatus = newbills[0].getParentVO().getFstatusflag();
String ctranstype = newbills[0].getParentVO().getVtrantypecode();
this.addAfterRule(processer, newbillstatus, ctranstype);
processer.after(newbills);
TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0163"));
String[] pk_so_sales = new String[0];
for (SaleOrderVO svo : newbills) {
pk_so_sales = (String[]) ArrayUtils.add(pk_so_sales, svo.getParentVO().getCsaleorderid());
}
newbills = (SaleOrderVO[]) (new BillQuery(SaleOrderVO.class)).query(pk_so_sales);
if (null == ret) {
ret = newbills;
}
} catch (Exception ex) {
ExceptionUtils.wrappException(ex);
}
return ret;
}
private void updateNewBillStatus(SaleOrderVO[] newbills) {
new HashMap();
List<String> pk_org = new ArrayList();
for (SaleOrderVO vo : newbills) {
for (SaleOrderBVO bvo : vo.getChildrenVO()) {
String csettleorgid = bvo.getCsettleorgid();
if (!pk_org.contains(csettleorgid)) {
pk_org.add(csettleorgid);
}
}
}
Map<String, Boolean> isEnable = SysInitGroupQuery.isRMEnabled(pk_org);
for (SaleOrderVO vo : newbills) {
List<SaleOrderBVO> newbvo = new ArrayList();
for (SaleOrderBVO bvo : vo.getChildrenVO()) {
String csettleorgid = bvo.getCsettleorgid();
if (!isEnable.isEmpty() && !(Boolean) isEnable.get(csettleorgid)) {
bvo.setRmcontractbflag(UFBoolean.TRUE);
} else {
newbvo.add(bvo);
}
}
}
SOPfStatusChgRule statuschgrule = new SOPfStatusChgRule();
SaleOrderHVO[] updateheads = new SaleOrderHVO[newbills.length];
List<SaleOrderBVO> listbody = new ArrayList();
int i = 0;
for (SaleOrderVO ordervo : newbills) {
statuschgrule.changePfToBillStatus(ordervo);
updateheads[i++] = ordervo.getParentVO();
for (SaleOrderBVO bvo : ordervo.getChildrenVO()) {
listbody.add(bvo);
}
}
String[] headupname = new String[]{"fstatusflag"};
VOUpdate<SaleOrderHVO> headupsrv = new VOUpdate();
headupsrv.update(updateheads, headupname);
String[] bodyupname = new String[]{"frowstatus", "rmcontractbflag"};
VOUpdate<SaleOrderBVO> bodyupsrv = new VOUpdate();
SaleOrderBVO[] updatebodys = (SaleOrderBVO[]) listbody.toArray(new SaleOrderBVO[listbody.size()]);
bodyupsrv.update(updatebodys, bodyupname);
}
private void addAfterRule(AroundProcesser<SaleOrderVO> processer, Integer newbillstatus, String ctranstype) {
IRule<SaleOrderVO> rule = null;
if (SysInitGroupQuery.isCREDITEnabled()) {
IRule<SaleOrderVO> var6 = new RenovateARByHidsEndRule(M30EngrossAction.M30Approve);
processer.addAfterRule(var6);
}
boolean icEnable = SysInitGroupQuery.isICEnabled();
if (icEnable) {
IRule<SaleOrderVO> var7 = new SaleOrderVOATPAfterRule();
processer.addAfterRule(var7);
}
IRule<SaleOrderVO> var8 = new ArsubOffsetAfterApproveRule();
processer.addAfterRule(var8);
if (BillStatus.AUDIT.equalsValue(newbillstatus)) {
IRule<SaleOrderVO> var9 = new ApproveStateRule();
processer.addAfterRule(var9);
if (this.isExistDelivery(ctranstype)) {
processer.addAfterRule(new SendMsgToDeliveryRule());
}
}
if (BillStatus.NOPASS.equalsValue(newbillstatus) && SysInitGroupQuery.isPRICEEnabled()) {
IRule<SaleOrderVO> var10 = new RewritePromotePriceDeleteRule();
processer.addAfterRule(var10);
}
IRule<SaleOrderVO> var11 = new SaleOrderVOApproveAfterRule();
processer.addAfterRule(var11);
processer.addAfterRule(new MobAfterApproveMessageRule());
processer.addAfterRule(new SaleOrderCreateRmBeforeRule());
// ÔÚÉóÅúºóÍÆË͵½MESϵͳ
processer.addAfterRule(new AfterApprovingSynchronizeRuleMES());
}
private boolean isExistDelivery(String ctranstype) {
IPFBusinessTypeService pfservice = (IPFBusinessTypeService) NCLocator.getInstance().lookup(IPFBusinessTypeService.class);
BusFlowInfoVO[] refbillinfos = null;
String groupId = AppContext.getInstance().getPkGroup();
String userId = AppContext.getInstance().getPkUser();
try {
refbillinfos = pfservice.getDownstreamInfo(SOBillType.Order.getCode(), ctranstype, groupId, userId, true);
String delieverycode = SOBillType.Delivery.getCode();
for (BusFlowInfoVO info : refbillinfos) {
if (delieverycode.equals(info.getBilltype())) {
return true;
}
}
return false;
} catch (BusinessException e) {
ExceptionUtils.wrappException(e);
return false;
}
}
private void addBeforeRule(AroundProcesser<SaleOrderVO> processer) {
IRule<SaleOrderVO> rule = new VOSagaFrozenValidateRule();
processer.addBeforeRule(rule);
IRule<SaleOrderVO> var4 = new CheckApprovableRule();
processer.addBeforeRule(var4);
if (SysInitGroupQuery.isCREDITEnabled()) {
IRule<SaleOrderVO> var5 = new RenovateARByHidsBeginRule(M30EngrossAction.M30Approve);
processer.addBeforeRule(var5);
}
boolean icEnable = SysInitGroupQuery.isICEnabled();
if (icEnable) {
IRule<SaleOrderVO> var6 = new SaleOrderVOATPBeforeRule();
processer.addBeforeRule(var6);
}
IRule<SaleOrderVO> var7 = new BusiLog();
processer.addBeforeRule(var7);
processer.addBeforeRule(new UpdateMsgStatusRule("csaleorderid"));
}
private void setAppInfoContext() {
String buttonCode = AppInfoContext.getBtnCode();
if ("".equals(buttonCode) || null == buttonCode) {
AppInfoContext.setBtnCode("appoveCenter");
}
}
}