| | |
|---|
| | | @Value("${erp.address.scpSalreturn}") |
|---|
| | | //销售退货单 |
|---|
| | | private String scpSalreturn; |
|---|
| | | @Value("${erp.address.scpSalreturnDetl}") |
|---|
| | | //销售退货单 |
|---|
| | | private String scpSalreturnDetl; |
|---|
| | | @Value("${erp.address.imMdcMftproorder}") |
|---|
| | | //生产领料单 |
|---|
| | | private String imMdcMftproorder; |
|---|
| | |
|---|
| | | break; |
|---|
| | | case "SAL_RETURNSTOCK"://销售退货 |
|---|
| | | path = scpSalreturn; |
|---|
| | | jsonObject.put("start_modifytime", "2025-11-25 00:00:00");//业务起始日期 |
|---|
| | | jsonObject.put("modify_starttime", "2025-11-25 00:00:00");//业务起始日期 |
|---|
| | | jsonObject.put("billstatus", "B");//单据状态 |
|---|
| | | jsonObject.put("end_starttime", sdf1.format(now));//业务起始日期 |
|---|
| | | jsonObject.put("modify_endtime", sdf1.format(now));//业务起始日期 |
|---|
| | | jsonObject.put("billtype_number", "im_SalOutBill_STD_BT_S_R");//单据类型 |
|---|
| | | break; |
|---|
| | | case "PRD_PickMtrl"://生产领料单 |
|---|
| | | path = imMdcMftproorder; |
|---|
| | |
|---|
| | | 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) |
|---|
| | |
|---|
| | | |
|---|
| | | jsonResponse = JSON.parseObject(response); |
|---|
| | | data = jsonResponse.getJSONObject("data").getJSONArray("rows"); |
|---|
| | | |
|---|
| | | for (int j = 0; j < data.size(); j++) { |
|---|
| | | JSONObject jsonObjectNew = data.getJSONObject(j); |
|---|
| | | Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString()); |
|---|
| | | String billNo = jsonObjectNew.get("billno").toString();//单据编号 |
|---|
| | | String orderId = jsonObjectNew.get("id").toString(); |
|---|
| | | JSONObject detailParam = new JSONObject(); |
|---|
| | | JSONObject dataObj = new JSONObject(); |
|---|
| | | dataObj.put("billno", billNo); |
|---|
| | | detailParam.put("pageNo", 1); |
|---|
| | | detailParam.put("pageSize", 100); |
|---|
| | | detailParam.put("data", dataObj); |
|---|
| | | boolean hasNext = true; |
|---|
| | | while (hasNext) { |
|---|
| | | String reqJson = detailParam.toJSONString(); |
|---|
| | | String detailResp = new HttpHandler.Builder() |
|---|
| | | .setHeaders(headers) |
|---|
| | | .setUri(URL) |
|---|
| | | .setPath(scpSalreturnDetl) |
|---|
| | | .setJson(reqJson) |
|---|
| | | .build() |
|---|
| | | .doPost(); |
|---|
| | | JSONObject detailJson = JSON.parseObject(detailResp); |
|---|
| | | JSONObject detData = detailJson.getJSONObject("data"); |
|---|
| | | JSONArray rows = detData.getJSONArray("rows"); |
|---|
| | | // ====== 处理明细 ====== |
|---|
| | | for (int i = 0; i < rows.size(); i++) { |
|---|
| | | JSONObject jsonObjectNew2 = rows.getJSONObject(i); |
|---|
| | | Order order = orderService.selectByNo(billNo);//检索单据 |
|---|
| | | LocOwner locOwner = null; |
|---|
| | | if (Cools.isEmpty(order)) { |
|---|
| | | Date createTime = sdf1.parse(jsonObjectNew.getString("createtime")); |
|---|
| | | String billNo = jsonObjectNew.getString("billno"); |
|---|
| | | String owner = jsonObjectNew.getString("org_name"); |
|---|
| | | String ownerUuid = jsonObjectNew.getString("org_number"); |
|---|
| | | String orderId = jsonObjectNew.getString("id"); |
|---|
| | | // ========= 货主校验 ========= |
|---|
| | | LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid); |
|---|
| | | // if (locOwner == null) { |
|---|
| | | // callApiLogSaveOwner(null, kingDeeUtilType, |
|---|
| | | // "货主检索失败：" + ownerUuid + " 名称：" + owner, false); |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | |
|---|
| | | // ========= 创建订单主表 ========= |
|---|
| | | Order order = orderService.selectByNo(billNo); |
|---|
| | | if (Cools.isEmpty(order)) { |
|---|
| | | order = new Order( |
|---|
| | | // 单据主档 |
|---|
| | | order = new Order( |
|---|
| | | String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] |
|---|
| | | billNo, // 订单编号 |
|---|
| | | createTime.toString(), // 单据日期 |
|---|
| | | docType.getDocId(), // 单据类型 |
|---|
| | | null, // 项目编号 |
|---|
| | | orderId, //收料单id |
|---|
| | | null, // 调拨项目编号 |
|---|
| | | null, // 初始票据号 |
|---|
| | | null, // 票据号 |
|---|
| | | null, // 项目id |
|---|
| | | null, // 货主 |
|---|
| | | null, // 联系方式 |
|---|
| | | null, // 操作人员 |
|---|
| | | null, // 合计金额 |
|---|
| | | null, // 优惠率 |
|---|
| | | null, // 优惠金额 |
|---|
| | | null, // 销售或采购费用合计 |
|---|
| | | null, // 实付金额 |
|---|
| | | null, // 付款类型 |
|---|
| | | null, // 业务员 |
|---|
| | | null, // 结算天数 |
|---|
| | | null, // 邮费支付类型 |
|---|
| | | null, // 邮费 |
|---|
| | | null, // 付款时间 |
|---|
| | | null, // 发货时间 |
|---|
| | | null, // 物流名称 |
|---|
| | | null, // 物流单号 |
|---|
| | | 1L, // 订单状态 |
|---|
| | | 1, // 状态 |
|---|
| | | 9527L, // 添加人员 |
|---|
| | | now, // 添加时间 |
|---|
| | | 9527L, // 修改人员 |
|---|
| | | now, // 修改时间 |
|---|
| | | null, // 备注 |
|---|
| | | kingDeeUtilType.pakIn !=1?2:1 |
|---|
| | | ); |
|---|
| | | if( orderService.insert(order)){ |
|---|
| | | callApiLogSaveOrder(order, kingDeeUtilType, "创建销售退货单成功！单号：" + billNo, true); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // String suppCode = jsonObjectNew2.getString("supplier_number"); //供应商 |
|---|
| | | String suppCode = null; //供应商 |
|---|
| | | JSONArray billEntryArray = jsonObjectNew2.getJSONArray("materialentry"); |
|---|
| | | for (int k = 0; k < billEntryArray.size(); k++) { |
|---|
| | | JSONObject entry = billEntryArray.getJSONObject(k); |
|---|
| | | String matnr = entry.getString("material_number"); //物料编码，内部SKU |
|---|
| | | Double anfme = entry.getDouble("qty");//箱数 |
|---|
| | | Double totalNumItems = 0.0; |
|---|
| | | Double Totalvolume = 0.0;//总体积 |
|---|
| | | String warehouse = null;//仓库编码 |
|---|
| | | String pOrderNo = "1";//采购单号 |
|---|
| | | String s3 = "1";//客户sku（客户编号） |
|---|
| | | String s2 = "1"; //条码UPC |
|---|
| | | String memo ="1"; //备注（英文描述） |
|---|
| | | String s1 = "1"; //客户PO |
|---|
| | | // Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数 |
|---|
| | | // Double Totalvolume = entry.getDouble("eap7_decimalfield2");//总体积 |
|---|
| | | // String warehouse = entry.getString("warehouse_number");//仓库编码 |
|---|
| | | // String pOrderNo = entry.getString("eap7_textfield3");//采购单号 |
|---|
| | | // String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号） |
|---|
| | | // String s2 = entry.getString("eap7_textfield5"); //条码UPC |
|---|
| | | // String memo = entry.getString("eap7_textfield6"); //备注（英文描述） |
|---|
| | | // String s1 = entry.getString("eap7_textfield7"); //客户PO |
|---|
| | | String detlId = entry.getString("id"); //明细id |
|---|
| | | Long seq = entry.getLong("seq"); //分录行号 |
|---|
| | | // String |
|---|
| | | if(anfme == 0){ |
|---|
| | | callApiLogSaveOrder(order,kingDeeUtilType, "单据数量异常"+matnr, false); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | //物料编码 |
|---|
| | | Mat mat = matService.selectByMatnr(matnr); |
|---|
| | | if (Cools.isEmpty(mat)) { |
|---|
| | | callApiLogSaveOrder(order,kingDeeUtilType, "编号商品检索失败，请先添加商品"+matnr, false); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Order order1 = orderService.selectByNo( billNo); |
|---|
| | | List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order1.getId()); |
|---|
| | | boolean sign = false; |
|---|
| | | for (OrderDetl orderDetl : orderDetls){ |
|---|
| | | if (orderDetl.getMatnr().equals(matnr)){ |
|---|
| | | sign = true; |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (sign){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | LocSupp locSupp = null; |
|---|
| | | String supp =null; |
|---|
| | | // locSupp = locSuppService.selectByUuid(suppCode); |
|---|
| | | // if(locSupp != null){supp = locSupp.getOwner();} |
|---|
| | | OrderDetl orderDetl = new OrderDetl(); |
|---|
| | | orderDetl.sync(mat); |
|---|
| | | orderDetl.setThreeCode(detlId);//ERP明细id |
|---|
| | | orderDetl.setLineNumber(seq);//分录行号 |
|---|
| | | orderDetl.setAnfme(anfme);//总箱数 |
|---|
| | | orderDetl.setErpAnfme(anfme);//erp数据 |
|---|
| | | orderDetl.setOrderId(order.getId()); |
|---|
| | | orderDetl.setOrderNo(order.getOrderNo());//表头单据 |
|---|
| | | orderDetl.setSupp(supp);//供应商名称（货源） |
|---|
| | | orderDetl.setSuppCode(suppCode);//供应商编码 |
|---|
| | | orderDetl.setSku(matnr);//内部SKU |
|---|
| | | orderDetl.setStandby1(s1);//客户PO |
|---|
| | | orderDetl.setStandby2(s2);//条码UPC |
|---|
| | | orderDetl.setStandby3(s3);//客户SKU |
|---|
| | | orderDetl.setBoxType1(null); //货主名称 |
|---|
| | | orderDetl.setBoxType2(null);//货主编号（erp组织） |
|---|
| | | orderDetl.setBoxType3(pOrderNo);//采购单号 |
|---|
| | | orderDetl.setMemo(memo);//英文备注 |
|---|
| | | orderDetl.setVolume(Totalvolume);//总体积 |
|---|
| | | orderDetl.setSafeQty(totalNumItems);//总件数 |
|---|
| | | orderDetl.setManu(warehouse);//仓库编码 |
|---|
| | | orderDetl.setCreateBy(9527L); |
|---|
| | | orderDetl.setCreateTime(new Date()); |
|---|
| | | orderDetl.setUpdateBy(9527L); |
|---|
| | | orderDetl.setUpdateTime(new Date()); |
|---|
| | | orderDetl.setStatus(1); |
|---|
| | | orderDetl.setQty(0.0D); |
|---|
| | | orderDetlService.insert(orderDetl); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 是否还有下一页 |
|---|
| | | boolean lastPage = detData.getBoolean("lastPage"); |
|---|
| | | if (lastPage) { |
|---|
| | | hasNext = false; |
|---|
| | | } else { |
|---|
| | | // 下一页 |
|---|
| | | int currPage = detData.getIntValue("pageNo"); |
|---|
| | | detailParam.put("pageNo", currPage + 1); |
|---|
| | | String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] |
|---|
| | | billNo, // 订单编号 |
|---|
| | | createTime.toString(), // 单据日期 |
|---|
| | | docType.getDocId(), // 单据类型 |
|---|
| | | null, // 项目编号 |
|---|
| | | orderId, //收料单id |
|---|
| | | null, // 调拨项目编号 |
|---|
| | | null, // 初始票据号 |
|---|
| | | null, // 票据号 |
|---|
| | | null, // 项目id |
|---|
| | | owner, // 货主 |
|---|
| | | null, // 联系方式 |
|---|
| | | null, // 操作人员 |
|---|
| | | null, // 合计金额 |
|---|
| | | null, // 优惠率 |
|---|
| | | null, // 优惠金额 |
|---|
| | | null, // 销售或采购费用合计 |
|---|
| | | null, // 实付金额 |
|---|
| | | null, // 付款类型 |
|---|
| | | null, // 业务员 |
|---|
| | | null, // 结算天数 |
|---|
| | | null, // 邮费支付类型 |
|---|
| | | null, // 邮费 |
|---|
| | | null, // 付款时间 |
|---|
| | | null, // 发货时间 |
|---|
| | | null, // 物流名称 |
|---|
| | | null, // 物流单号 |
|---|
| | | 1L, // 订单状态 |
|---|
| | | 1, // 状态 |
|---|
| | | 9527L, // 添加人员 |
|---|
| | | now, // 添加时间 |
|---|
| | | 9527L, // 修改人员 |
|---|
| | | now, // 修改时间 |
|---|
| | | null, // 备注 |
|---|
| | | kingDeeUtilType.pakIn !=1?2:1 |
|---|
| | | ); |
|---|
| | | if (orderService.insert(order)) { |
|---|
| | | callApiLogSaveOrder(order, kingDeeUtilType, |
|---|
| | | "创建出库退货单成功！单号：" + billNo, true); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // ========= 直接从主接口取明细 billentry ========= |
|---|
| | | JSONArray billEntryArray = jsonObjectNew.getJSONArray("billentry"); |
|---|
| | | if (billEntryArray == null || billEntryArray.isEmpty()) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | for (int k = 0; k < billEntryArray.size(); k++) { |
|---|
| | | JSONObject entry = billEntryArray.getJSONObject(k); |
|---|
| | | String matnr = entry.getString("material_number"); //物料编码，内部SKU |
|---|
| | | // Double anfme = entry.getDouble("eap7_decimalfield");//箱数 |
|---|
| | | Double anfme = 1.0;//箱数 |
|---|
| | | |
|---|
| | | Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数 |
|---|
| | | Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积 |
|---|
| | | String warehouse = entry.getString("warehouse_number");//仓库编码 |
|---|
| | | String pOrderNo = entry.getString("eap7_textfield3");//采购单号 |
|---|
| | | String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号） |
|---|
| | | String s2 = entry.getString("eap7_textfield5"); //条码UPC |
|---|
| | | String memo = entry.getString("eap7_textfield6"); //备注（英文描述） |
|---|
| | | String s1 = entry.getString("eap7_textfield7"); //客户PO |
|---|
| | | String detlId = entry.getString("id"); //明细id |
|---|
| | | Long seq = entry.getLong("seq"); //分录行号 |
|---|
| | | // String suppCode = entry.getString("supplier_number"); |
|---|
| | | String suppCode = null; |
|---|
| | | if (anfme == null || anfme == 0) { |
|---|
| | | callApiLogSaveOrder(order, kingDeeUtilType, |
|---|
| | | "单据数量异常：" + matnr, false); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | // ========= 物料校验 ========= |
|---|
| | | Mat mat = matService.selectByMatnr(matnr); |
|---|
| | | if (Cools.isEmpty(mat)) { |
|---|
| | | callApiLogSaveOrder(order, kingDeeUtilType, |
|---|
| | | "商品不存在：" + matnr, false); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | // ========= 明细去重 ========= |
|---|
| | | List<OrderDetl> orderDetls = |
|---|
| | | orderDetlService.selectByOrderId(order.getId()); |
|---|
| | | |
|---|
| | | boolean exists = orderDetls.stream() |
|---|
| | | .anyMatch(o -> o.getMatnr().equals(matnr)); |
|---|
| | | if (exists) continue; |
|---|
| | | // // ========= 供应商 ========= |
|---|
| | | String supp = null; |
|---|
| | | // LocSupp locSupp = locSuppService.selectByUuid(suppCode); |
|---|
| | | // if (locSupp != null) { |
|---|
| | | // supp = locSupp.getOwner(); |
|---|
| | | // } |
|---|
| | | // ========= 保存明细 ========= |
|---|
| | | OrderDetl orderDetl = new OrderDetl(); |
|---|
| | | orderDetl.sync(mat); |
|---|
| | | orderDetl.setThreeCode(detlId); |
|---|
| | | orderDetl.setLineNumber(seq); |
|---|
| | | orderDetl.setAnfme(anfme); |
|---|
| | | orderDetl.setErpAnfme(anfme); |
|---|
| | | orderDetl.setOrderId(order.getId()); |
|---|
| | | orderDetl.setOrderNo(order.getOrderNo()); |
|---|
| | | orderDetl.setSupp(supp); |
|---|
| | | orderDetl.setSuppCode(suppCode); |
|---|
| | | orderDetl.setSku(matnr); |
|---|
| | | orderDetl.setStandby1(s1); |
|---|
| | | orderDetl.setStandby2(s2); |
|---|
| | | orderDetl.setStandby3(s3); |
|---|
| | | orderDetl.setBoxType1(owner); |
|---|
| | | orderDetl.setBoxType2(ownerUuid); |
|---|
| | | orderDetl.setBoxType3(pOrderNo); |
|---|
| | | orderDetl.setMemo(memo); |
|---|
| | | orderDetl.setVolume(totalVolume); |
|---|
| | | orderDetl.setSafeQty(totalNumItems); |
|---|
| | | orderDetl.setManu(warehouse); |
|---|
| | | orderDetl.setCreateBy(9527L); |
|---|
| | | orderDetl.setCreateTime(new Date()); |
|---|
| | | orderDetl.setUpdateBy(9527L); |
|---|
| | | orderDetl.setUpdateTime(new Date()); |
|---|
| | | orderDetl.setStatus(1); |
|---|
| | | orderDetl.setQty(0.0D); |
|---|
| | | |
|---|
| | | orderDetlService.insert(orderDetl); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | docType.setUpdateTime(now); |
|---|
| | | docTypeService.updateById(docType); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | String orderId = jsonObjectNew.getString("id"); |
|---|
| | | // ========= 货主校验 ========= |
|---|
| | | LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid); |
|---|
| | | // if (locOwner == null) { |
|---|
| | | // callApiLogSaveOwner(null, kingDeeUtilType, |
|---|
| | | // "货主检索失败：" + ownerUuid + " 名称：" + owner, false); |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | if (locOwner == null) { |
|---|
| | | callApiLogSaveOwner(null, kingDeeUtilType, |
|---|
| | | "货主检索失败：" + ownerUuid + " 名称：" + owner, false); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // ========= 创建订单主表 ========= |
|---|
| | | Order order = orderService.selectByNo(billNo); |
|---|
| | |
|---|
| | | for (int k = 0; k < billEntryArray.size(); k++) { |
|---|
| | | JSONObject entry = billEntryArray.getJSONObject(k); |
|---|
| | | String matnr = entry.getString("material_number"); //物料编码，内部SKU |
|---|
| | | Double anfme = entry.getDouble("eap7_decimalfield");//箱数 |
|---|
| | | // Double anfme = entry.getDouble("eap7_decimalfield");//箱数 |
|---|
| | | Double anfme = 1.0;//箱数 |
|---|
| | | |
|---|
| | | Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数 |
|---|
| | | Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积 |
|---|
| | | String warehouse = entry.getString("warehouse_number");//仓库编码 |
|---|
| | |
|---|
| | | String s1 = entry.getString("eap7_textfield7"); //客户PO |
|---|
| | | String detlId = entry.getString("id"); //明细id |
|---|
| | | Long seq = entry.getLong("seq"); //分录行号 |
|---|
| | | // String suppCode = entry.getString("supplier_number"); |
|---|
| | | String suppCode = null; |
|---|
| | | String suppCode = entry.getString("supplier_number"); |
|---|
| | | if (anfme == null || anfme == 0) { |
|---|
| | | callApiLogSaveOrder(order, kingDeeUtilType, |
|---|
| | | "单据数量异常：" + matnr, false); |
|---|
| | |
|---|
| | | if (exists) continue; |
|---|
| | | // // ========= 供应商 ========= |
|---|
| | | String supp = null; |
|---|
| | | // LocSupp locSupp = locSuppService.selectByUuid(suppCode); |
|---|
| | | // if (locSupp != null) { |
|---|
| | | // supp = locSupp.getOwner(); |
|---|
| | | // } |
|---|
| | | LocSupp locSupp = locSuppService.selectByUuid(suppCode); |
|---|
| | | if (locSupp != null) { |
|---|
| | | supp = locSupp.getOwner(); |
|---|
| | | } |
|---|
| | | // ========= 保存明细 ========= |
|---|
| | | OrderDetl orderDetl = new OrderDetl(); |
|---|
| | | orderDetl.sync(mat); |
|---|
