package com.sunda.spmswms.service.impl; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.sunda.spmscommon.ResponseResult; import com.sunda.spmscommon.entity.ZSapOrgClient; import com.sunda.spmscommon.feign.IFeignServiceCommon; import com.sunda.spmscommon.mapper.ZSapOrgClientMapper; import com.sunda.spmscommon.service.ISysLogService; import com.sunda.spmscommon.utils.DataToPage; import com.sunda.spmswms.entity.*; import com.sunda.spmswms.mapper.*; import com.sunda.spmswms.service.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; 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 org.springframework.transaction.interceptor.TransactionAspectSupport; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import static com.sunda.spmscommon.Constans.*; /** *

* SAP交货单表头服务实现类 *

* * @author Wayne * @since 2021-03-22 */ @Slf4j @Service public class SapDeliveryNoteServiceImpl extends ServiceImpl implements ISapDeliveryNoteService { @Autowired SapDeliveryNoteMapper sapDeliveryNoteMapper; @Autowired SapDeliveryNoteDtlMapper sapDeliveryNoteDtlMapper; @Autowired IWhsStorageService iWhsStorageService; @Autowired SapPackageNoteMapper sapPackageNoteMapper; @Autowired SapBoxNoteMapper sapBoxNoteMapper; @Autowired SapBoxNoteDtlMapper sapBoxNoteDtlMapper; @Autowired WhsStorageInventoryMapper whsStorageInventoryMapper; @Autowired ISapBoxNoteDtlService iSapBoxNoteDtlService; @Autowired IWhsInventoryInfoService iWhsInventoryInfoService; @Autowired IShelfOnTaskService iShelfOnTaskService; @Autowired IWhsOperateLogService iWhsOperateLogService; @Autowired ISapDeliveryNoteLogService iSapDeliveryNoteLogService; @Autowired IShelfOnTaskDtlService iShelfOnTaskDtlService; @Value("${all.sap.client}") private String allSapClient; @Autowired IFeignServiceCommon iFeignServiceCommon; @Autowired ISysLogService iSysLogService; @Autowired ZSapOrgClientMapper zSapOrgClientMapper; @Value("${zxd.sap.client}") private String sapClient; /** * { * "documentDate": "2021-04-16", * "pdaSn": "WebClient", * "sapBoxNote": [ * { * "boxNote": "ZX-10215800021-0202", * "boxQtyReceived": 1, * "storageUuid": "b95946ac1dab42b79ade3438acb0b53a", * "remarks":"Your remarks" * } * ], * "sapDeliveryNote": { * "deliveryNoteSap": "1180066380", * "mobileType": "101", * "spmsStatus": "6" * } * } */ @Override @Transactional(rollbackFor = Exception.class) public ResponseResult sapDeliveryNoteRecX(JSONObject doc, String userId) throws Exception { // try { String pdaSn = doc.containsKey("pdaSn") ? doc.getString("pdaSn") : "WebClient"; JSONObject sapDeliveryNote = doc.getJSONObject("sapDeliveryNote"); JSONArray sapBoxNote = doc.getJSONArray("sapBoxNote"); if (null == sapDeliveryNote || null == sapBoxNote) { return ResponseResult.error("sapDeliveryNote and sapBoxNote is mandatory required"); } // 1. 调用备件来货确认验收接口,验证收货 ResponseResult checkSapDeliveryNoteResult = checkSapDeliveryNote(userId, doc); if (null == checkSapDeliveryNoteResult || checkSapDeliveryNoteResult.getCode() != 200) { return ResponseResult.error("确认验收失败"); } // 验证收货成功 // 2. 完成上架任务表头更新 String deliveryNoteSap = sapDeliveryNote.getString("deliveryNoteSap"); ShelfOnTask shelfOnTask = iShelfOnTaskService.completeShelfOnTask(userId, deliveryNoteSap, pdaSn, "1","1","3"); if (null == shelfOnTask) { // 上架任务表头更新失败 return ResponseResult.error("Error when update Shelf On tasks"); } //3. 更新上架任务详情 String shelfOnUuid = shelfOnTask.getUuid(); JSONArray shelfOnTaskDtl = new JSONArray(); for (int i = 0; i < sapBoxNote.size(); i++) { JSONObject oObj = sapBoxNote.getJSONObject(i); JSONObject jobj = new JSONObject(); jobj.put("boxNote", oObj.getString("boxNote")); jobj.put("storageUuid", oObj.getString("storageUuid")); jobj.put("boxQtyReceived", StringUtils.isNotEmpty(oObj.getString("boxQtyReceived"))?oObj.getDouble("boxQtyReceived"):0); jobj.put("deliveryNoteSap", deliveryNoteSap); shelfOnTaskDtl.add(jobj); } if (null == shelfOnUuid || null == shelfOnTaskDtl) { return ResponseResult.error("shelfOnUuid and shelfOnTaskDtl is mandatory required"); } return iShelfOnTaskDtlService.completeShelfOnTaskDtlByBoxNote(shelfOnUuid, shelfOnTaskDtl, userId); // } catch (Exception e) { // e.printStackTrace(); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return ResponseResult.error("更新交货单信息失败"); // } } /** * 贸易货一步收化接口 * { * "SapDeliveryNote": { * "deliveryNoteSap": "1180066308", * "spmsStatus": "6", * "documentDate": "20210417", * "postingDate": "20210417", * "mobileType": "101", * "remarks": "remarks for this sapn DN" * }, * "SapDeliveryNoteDtl": [ * { * "deliveryNoteSap": "1180066308", * "deliveryNoteSapItem": 10, * "materialNo": "130010159", * "deliveryQty": 200, * "receivedQty": 200, * "actualQtySales": 200, * "storageUuidList": [ * { * "storageUuid": "64eaf8633b3e4b8aa276970f2e31785b", * "qty": 100 * }, * { * "storageUuid": "64eaf8633b3e4b8aa276970f2e31785c", * "qty": 100 * } * ] * } * ] * } */ @Override @Transactional(rollbackFor = Exception.class) public ResponseResult sapDeliveryNoteRecM(JSONObject jsonObject, String userId) throws Exception { // try { JSONObject SapDeliveryNote = jsonObject.getJSONObject("SapDeliveryNote"); JSONArray SapDeliveryNoteDtl = jsonObject.getJSONArray("SapDeliveryNoteDtl"); if (null == SapDeliveryNote || null == SapDeliveryNoteDtl || SapDeliveryNoteDtl.size() == 0) { return ResponseResult.error("SapDeliveryNote and SapDeliveryNoteDtl are mandatory required"); } /** * 完成表头更新 * 1. deliveryNoteSap, SAP DN单号，必须 * 2. spmsStatus, 表单当前状态，必须 * 3. remarks, 收货单备注，可选 * 4. documentDate, 凭证日期-开始处理日期,可选 * 5. postingDate, 过账日期-提交SAP日期,可选 * 6. mobileType, 移动类型,可选 */ String deliveryNoteSap = SapDeliveryNote.getString("deliveryNoteSap"); String spmsStatus = SapDeliveryNote.getString("spmsStatus"); String remarks = SapDeliveryNote.getString("remarks"); String operateUser = SapDeliveryNote.getString("operateUser"); String documentDate = SapDeliveryNote.getString("documentDate"); String postingDate = SapDeliveryNote.getString("postingDate"); String mobileType = SapDeliveryNote.getString("mobileType"); ResponseResult sapDNUpdateResult = updateSapDeliveryNote(deliveryNoteSap, spmsStatus, remarks, documentDate, postingDate, mobileType, userId, operateUser); if (sapDNUpdateResult.getCode() != 200) { // 表头更新失败，返回 throw new Exception("sapDeliveryNoteRecM 贸易货一步收货接口表头状态更新错误"); } /** * 更新交货单行项目、库存信息(贸易货) * */ ResponseResult sapDNDtlUpdateResult = updateSapDeliveryNoteDtl(jsonObject, userId); if (sapDNDtlUpdateResult.getCode() != 200) { // 更新交货单行项目失败，返回 throw new Exception("sapDeliveryNoteRecM 贸易货一步收货接口行项目更新错误"); } return sapDNDtlUpdateResult; // } catch (Exception e) { // e.printStackTrace(); // System.out.println("======= insertSapDeliveryNote " + e); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return ResponseResult.error(); // } } // 据据DN单号获取全部的入库单数据 @Override public Map getOrderReceiveDatabySapDN(String deliveryNoteSap) { if (StringUtils.isEmpty(deliveryNoteSap)) { return null; } SapDeliveryNote sapDN = sapDeliveryNoteMapper.selectOne(new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap)); if (sapDN == null) { return null; } String packageNote = sapDN.getPackageNote(); Map deliveryData = new HashMap(); deliveryData.put("sapDN", sapDN); if (null == packageNote || "".equals(packageNote)) { // 贸易货，从SAP_DELIVERY_NOTE_DTL获取行数据 //List sapDeliveryNoteDtls = sapDeliveryNoteDtlMapper.selectList(new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap)); List> sapDeliveryNoteDtls = this.baseMapper.sapDeliveryNoteDtls(deliveryNoteSap); deliveryData.put("sapDeliveryNoteDtls", sapDeliveryNoteDtls); } else { // 备件货，从SAP_BOX_NOTE获取行数据 List sapBoxNotes = sapBoxNoteMapper.selectList(new QueryWrapper().eq("PACKAGE_NOTE", packageNote)); deliveryData.put("sapBoxNotes", sapBoxNotes); } return deliveryData; } // 根据条件查询sapDN单 @SuppressWarnings({ "unchecked", "rawtypes" }) @Override public Map getSapDeliveryNote(String userId, JSONObject searchCriteria) { String werks = StringUtils.isNotEmpty(searchCriteria.getString("werks")) ? searchCriteria.getString("werks"):null; String whsLocationCode = StringUtils.isNotEmpty(searchCriteria.getString("whsLocationCode")) ? searchCriteria.getString("whsLocationCode") : null; String deliveryNoteSap = StringUtils.isNotEmpty(searchCriteria.getString("deliveryNoteSap")) ? searchCriteria.getString("deliveryNoteSap"):null; String deliveryType = StringUtils.isNotEmpty(searchCriteria.getString("deliveryType")) ? searchCriteria.getString("deliveryType") : null; String deliveryNoteSrm = StringUtils.isNotEmpty(searchCriteria.getString("deliveryNoteSrm")) ? searchCriteria.getString("deliveryNoteSrm") : null; String spmsMark = StringUtils.isNotEmpty(searchCriteria.getString("spmsMark")) ? searchCriteria.getString("spmsMark") : null; String spmsStatus = StringUtils.isNotEmpty(searchCriteria.getString("spmsStatus")) ? searchCriteria.getString("spmsStatus") : null; String supplierCode = StringUtils.isNotEmpty(searchCriteria.getString("supplierCode")) ? searchCriteria.getString("supplierCode") : null; String plaStartDate = StringUtils.isNotEmpty(searchCriteria.getString("plaStartDate")) ? searchCriteria.getString("plaStartDate") : null; String plaEndDate = StringUtils.isNotEmpty(searchCriteria.getString("plaEndDate")) ? searchCriteria.getString("plaEndDate") : null; String sapVoucherNumber=StringUtils.isNotEmpty(searchCriteria.getString("sapVoucherNumber")) ? searchCriteria.getString("sapVoucherNumber") : null; int pageNo = StringUtils.isNotEmpty(searchCriteria.getString("pageNo")) ? searchCriteria.getIntValue("pageNo") : 1; int pageSize = StringUtils.isNotEmpty(searchCriteria.getString("pageSize")) ? searchCriteria.getIntValue("pageSize") : 20; List werksList = searchCriteria.containsKey("werksList") ? (List) searchCriteria.getJSONArray("werksList") : null; //默认查收货入库的数据（单据类型（DO=转储入库；DN=收货入库）） String businessType = searchCriteria.get("businessType")!=null?searchCriteria.getString("businessType"):null; // 如果指定了deliveryNoteSap，首先查询此deliveryNoteSap是否存在，若不存在，调用sap接口刷新数据 if(StringUtils.isNotEmpty(deliveryNoteSap)){ SapDeliveryNote sapDeliveryNote=this.baseMapper.selectOne(new QueryWrapper().eq("DELIVERY_NOTE_SAP",deliveryNoteSap)); if(null==sapDeliveryNote){ ResponseResult sapReturnedData = getNonExistSapDeliveryNote(deliveryNoteSap,"", userId, werks,businessType); if (sapReturnedData.getCode() != 200){ Map map = new HashMap<>(); map.put("sapReturnedData", sapReturnedData.getData().get("sapReturnedData").toString()); map.put("dataToSap", sapReturnedData.getData().get("dataToSap").toString()); return map; } } } List> sapDN = new ArrayList<>(); PageHelper.startPage(pageNo, pageSize); if ("M".equals(spmsMark)) { sapDN = sapDeliveryNoteMapper.getSapDeliverNoteM(userId, deliveryNoteSap, deliveryType, deliveryNoteSrm, spmsMark, supplierCode, plaStartDate, plaEndDate, spmsStatus,sapVoucherNumber,werks,whsLocationCode,businessType); } else { sapDN = sapDeliveryNoteMapper.getSapDeliverNote(userId, deliveryNoteSap, deliveryType, deliveryNoteSrm, spmsMark, supplierCode, plaStartDate, plaEndDate, spmsStatus,sapVoucherNumber,werks,whsLocationCode,businessType,werksList); } PageInfo> pageData = new PageInfo<>(sapDN); Map pageInfo = new HashMap<>(); pageInfo.put("records", pageData.getList()); pageInfo.put("total", pageData.getTotal()); pageInfo.put("size", pageData.getSize()); pageInfo.put("current", pageData.getPageNum()); pageInfo.put("pages", pageData.getPages()); return pageInfo; } public ResponseResult getNonExistSapDeliveryNote(String deliveryNoteSap,String status, String userId, String werks,String businessType) { // 根据工厂查询SAP Clinet String sapClinet1 = ""; List selectList = zSapOrgClientMapper.selectList(new QueryWrapper().eq("WERKS", werks)); if (CollectionUtils.isNotEmpty(selectList)) { sapClinet1 = "SAP-"+selectList.get(0).getZmandt(); } else { return ResponseResult.error("工厂："+werks+"未找到对应的SAP Clinet"); } if("DO".equals(businessType)){ JSONObject dataToSap = new JSONObject(); JSONObject REQUEST = new JSONObject(); JSONObject ESB_ATTRS = new JSONObject(); JSONObject REQUEST_DATA = new JSONObject(); JSONObject Head = new JSONObject(); ESB_ATTRS.put("App_ID", "SPMS"); ESB_ATTRS.put("Application_ID", "00020000000002"); ESB_ATTRS.put("Transaction_ID", UUID.randomUUID().toString()); ESB_ATTRS.put("Target_ID", sapClient);//固定装箱单client Head.put("VBELN", deliveryNoteSap); Head.put("WERKS", werks); Head.put("MANDT", selectList.get(0).getZmandt()); Head.put("TYPE_D", "03"); Head.put("SYSTEM_IN", "SPMS"); Head.put("ZBS", ""); Map structures = new HashMap<>(); structures.put("IS_DATA", Head); REQUEST_DATA.put("structures", structures); REQUEST_DATA.put("Operation", "ZZXD_IF_SPMS_03"); REQUEST_DATA.put("Type", "ZZXD_IF_SPMS_03"); REQUEST.put("ESB_ATTRS", ESB_ATTRS); REQUEST.put("REQUEST_DATA", REQUEST_DATA); dataToSap.put("REQUEST", REQUEST); try { String message = iFeignServiceCommon.sendRestToSapCommon(dataToSap); if (StringUtils.isEmpty(message)) { return ResponseResult.error(); } JSONObject returnData = JSONObject.parseObject(message).getJSONObject("RESPONSE").getJSONObject("RETURN_DATA"); if ("S".equals(returnData.getJSONObject("ES_RETURN").getString("TYPE"))){ Map headMap = new HashMap(); Map noteMap = new HashMap(); /** ET_REL —— 装箱单关系表 */ JSONArray ET_REL = returnData.getJSONArray("ET_REL"); if (ET_REL != null){ int zxdSize = ET_REL.size(); if (zxdSize > 0){ /** 装箱单信息表 */ for (int i = 0; i < zxdSize; i ++){ JSONObject doc = ET_REL.getJSONObject(i); String XDNUM = doc.getString("XDNUM");//装箱单号 String ZDECABNO = doc.getString("ZDECABNO");//柜号 String VBELN = doc.getString("VBELN");//交货单号 String POSNR = doc.getString("POSNR");//交货单行号 String EBELN = doc.getString("EBELN");//采购订单号 String EBELP = doc.getString("EBELP");//采购订单行号 String PACKAGE_CODE = doc.getString("PACKAGE_CODE");//箱码 String MANDT1 = doc.getString("MANDT1");//DN客户端 String MANDT2 = doc.getString("MANDT2");//PO客户端 JSONObject deliveryNoteInfo = new JSONObject(); deliveryNoteInfo.put("XDNUM", XDNUM); deliveryNoteInfo.put("ZDECABNO", ZDECABNO); deliveryNoteInfo.put("PACKAGE_CODE", PACKAGE_CODE); deliveryNoteInfo.put("MANDT1", MANDT1); deliveryNoteInfo.put("MANDT2", MANDT2); deliveryNoteInfo.put("EBELN", EBELN); deliveryNoteInfo.put("EBELP", EBELP); headMap.put(VBELN, deliveryNoteInfo); noteMap.put(VBELN+"_"+POSNR, deliveryNoteInfo); } } // 装箱单号 XDNUM // 装箱单行号 ZPOSNR // 柜号 ZDECABNO // Client标识 MANDT // 交货单号 VBELN // 交货单行号 POSNR // Client标识 MANDT // 采购订单号 EBELN // 采购订单行号 EBELP // 箱码 PACKAGE_CODE // 序号 SERIAL // 物料 MATNR // 需求来源号 DEMAND_NO // 需求来源行号 DEMAND_POSNR // 需求人 DEMANDER // 出库数量 GNCKSL // 单位 MEINS // 业务标识返回 BUS_SIGN // Client标识 MANDT } JSONArray ET_DN = returnData.getJSONArray("ET_DN"); if(ET_DN!=null && ET_DN.size()>0){ for (int i = 0; i < ET_DN.size(); i++) { //System.out.println("=======" + IT_LIPS.size() + " " + i + " SAP 交货单行项目信息 " + IT_LIPS.get(i).toString()); JSONObject json = JSONObject.parseObject(ET_DN.get(i).toString()); if (StringUtils.isNotEmpty(json.toString())) { JSONObject dninfo = noteMap.get(json.getString("VBELN")+"_"+json.getString("POSNR")); SapDeliveryNoteDtl deliveryNoteDtl = new SapDeliveryNoteDtl(); deliveryNoteDtl.setDeliveryNoteSap(json.getString("VBELN"));//SAP交货单号 deliveryNoteDtl.setDeliveryNoteSapItem(Integer.parseInt(json.getString("POSNR")));//SAP交货单行号 deliveryNoteDtl.setMaterialNo(json.getString("MATNR"));//物料编号 deliveryNoteDtl.setDeliveryQty(Double.parseDouble(json.getString("LFIMG")));//交货数量 deliveryNoteDtl.setDeliveryUnit(json.getString("MEINS"));//基本单位 deliveryNoteDtl.setWerks(json.getString("WERKS"));//工厂 deliveryNoteDtl.setWhsLocationCode(json.getString("LGORT"));//库存地点 deliveryNoteDtl.setQtySales(StringUtils.isEmpty(json.getString("ALMNG")) ? 0.0 : json.getDoubleValue("ALMNG"));//销售单位应收数量 deliveryNoteDtl.setUnitSales(json.getString("VRKME"));//销售单位 deliveryNoteDtl.setItemStatus(String.valueOf(0));//交货单行项目状态 deliveryNoteDtl.setMandtDn(dninfo.getString("MANDT1"));// DN客户端 deliveryNoteDtl.setMandt(dninfo.getString("MANDT2"));// PO客户端 deliveryNoteDtl.setOrderNumber(dninfo.get("EBELN")!=null ?dninfo.getString("EBELN"):null); deliveryNoteDtl.setOrderItem(dninfo.get("EBELP")!=null ?dninfo.getString("EBELP"):null); String VBELN = json.getString("VBELN");// String WERKS_V = json.getString("WERKS_V");//发货工厂 String WERKS = json.getString("WERKS");//收货工厂 String MANDT = json.getString("MANDT");//客户端 if(headMap.get(VBELN)!=null){//存在装箱单与交货单的关系 JSONObject deliveryNoteInfo = headMap.get(VBELN); deliveryNoteInfo.put("WERKS_V", WERKS_V); deliveryNoteInfo.put("WERKS", WERKS); deliveryNoteInfo.put("VBELN", VBELN); deliveryNoteInfo.put("MANDT", MANDT); headMap.put(VBELN, deliveryNoteInfo); } // deliveryNoteDtl.setPurchaseGroup(json.getString("ZEKGRP"));//采购组 // deliveryNoteDtl.setPurchaseGroupName(json.getString("ZEKNAM"));//采购组名称 // deliveryNoteDtl.setOverDeliveryLimit(StringUtils.isNotEmpty(json.getString("UEBTO")) ? Double.parseDouble(json.getString("UEBTO")) : 0);//过量交货限制 // deliveryNoteDtl.setUnderDeliveryLimit(StringUtils.isNotEmpty(json.getString("UNTTO")) ? Double.parseDouble(json.getString("UNTTO")) : 0);//交货不足限制 // deliveryNoteDtl.setUnlimited(json.getString("UEBTK"));//无限制 // deliveryNoteDtl.setWerksXq(json.getString("WERKS_XQ"));//需求工厂 // // 交货单号 VBELN // 交货单行号 POSNR // 收货工厂 WERKS // 收货仓库 LGORT // 物料号 MATNR // 数量 LFIMG // 基本单位 MEINS // 件数 ALMNG // 销售单位 VRKME // 发货工厂 WERKS_V QueryWrapper queryWrapper = new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNoteDtl.getDeliveryNoteSap()) .eq("DELIVERY_NOTE_SAP_ITEM", deliveryNoteDtl.getDeliveryNoteSapItem()); if (sapDeliveryNoteDtlMapper.selectOne(queryWrapper) != null) { sapDeliveryNoteDtlMapper.update(deliveryNoteDtl, queryWrapper); } else { sapDeliveryNoteDtlMapper.insert(deliveryNoteDtl); } } } } headMap.forEach((key,value)->{ //System.out.println("=======" + IT_LIKP.size() + " " + i + " SAP 交货单表头信息 " + IT_LIKP.get(i).toString()); JSONObject json = value; if (StringUtils.isNotEmpty(json.toString())) { SapDeliveryNote deliveryNote = new SapDeliveryNote(); deliveryNote.setBusinessType("DO"); deliveryNote.setDeliveryNoteSap(json.getString("VBELN"));//SAP交货单号 deliveryNote.setPackageNote(json.getString("PACKAGE_CODE"));//包装单号 deliveryNote.setDeliveryType(json.getString("LFART"));//交货类型 deliveryNote.setSpmsMark(json.getString("ZSPMS"));//SPMS标识（SAP提供-X表示备件货，M-表示贸易货） // deliveryNote.setPlannedArrivalDate(json.getString("LFDAT"));//计划到货时间 // deliveryNote.setDeliveryNoteSrm(json.getString("LIFEX"));//SRM送货单号 // deliveryNote.setCreateDateSap(json.getString("ERDAT"));//SAP创建日期 // deliveryNote.setSupplierCode(json.getString("LIFNR"));//供应商编号 deliveryNote.setMandt(json.getString("MANDT")); if (this.baseMapper.selectOne(new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())) != null) { this.baseMapper.update(deliveryNote, new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())); } else { this.baseMapper.insert(deliveryNote); } } }); // /** 交货单表头 */ // JSONArray IT_LIKP = doc.getJSONArray("IT_LIKP"); // /** 交货单行项目 */ // JSONArray IT_LIPS = doc.getJSONArray("IT_LIPS"); // /** 交货单表头供应商信息 */ // JSONArray IT_LIFNR = doc.getJSONArray("IT_LIFNR"); // // /** 包装单号表 */ // JSONArray IT_HEAD = doc.getJSONArray("IT_HEAD"); // /** 箱码表表头 */ // JSONArray IT_XHEAD = doc.getJSONArray("IT_XHEAD"); // /** 箱码行项目 */ // JSONArray IT_ITME = doc.getJSONArray("IT_ITME"); // // insertDNTitle(IT_LIKP); // insertDNDtl(IT_LIPS); // insertDNSupplier(IT_LIFNR); // // insertSapPackageNote(IT_HEAD); // insertSapBoxNote(IT_XHEAD); // insertSapBoxNoteDtl(IT_ITME); iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE, JSONObject.parseObject(message).toJSONString(), dataToSap.toJSONString()); return ResponseResult.success(); }else { iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE_ERROR, JSONObject.parseObject(message).toJSONString(), dataToSap.toJSONString()); return ResponseResult.error().add("dataToSap", dataToSap).add("sapReturnedData", JSONObject.parseObject(message)); } } catch (Exception e) { e.printStackTrace(); return ResponseResult.error(); } }else{ String json = "{\n" + " \"REQUEST\": {\n" + " \"ESB_ATTRS\": {\n" + " \"App_ID\": \"SPMS\", \n" + " \"Application_ID\": \"00020000000002\", \n" + " \"Target_ID\": " + "\"" + sapClinet1 + "\",\n" + " \"Transaction_ID\": " + "\"" + UUID.randomUUID() + "\"" + " }, \n" + " \"REQUEST_DATA\": {\n" + " \"fileds\": {\n" + " \"I_VBELN\": " + "\"" + deliveryNoteSap + "\",\n" + " \"I_WERKS\": " + "\"" + werks + "\",\n" + " \"I_STATUS\": " + "\"" + status + "\"\n" + " }, \n" + " \"Operation\": \"Z_SPMS_GETDN\", \n" + " \"Type\": \"GETDN\"\n" + " }\n" + " }\n" + "}"; try { String message = iFeignServiceCommon.sendRestToSapCommon(JSONObject.parseObject(json)); if (StringUtils.isEmpty(message)) { return ResponseResult.error(); } log.info("============Z_SPMS_GETDN:" + message); JSONObject doc = JSONObject.parseObject(message).getJSONObject("RESPONSE").getJSONObject("RETURN_DATA"); if (doc.containsKey("O_TYPE") && "S".equals(doc.getString("O_TYPE"))){ /** 更新交货单表头、供应商、行项目等信息 */ insertSapDeliveryNote(doc); iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE, JSONObject.parseObject(message).toJSONString(), JSONObject.parseObject(json).toJSONString()); return ResponseResult.success(); }else { iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE_ERROR, JSONObject.parseObject(message).toJSONString(), JSONObject.parseObject(json).toJSONString()); return ResponseResult.error().add("dataToSap", JSONObject.parseObject(json)).add("sapReturnedData", JSONObject.parseObject(message)); } } catch (Exception e) { e.printStackTrace(); return ResponseResult.error(); } } } @Override public Map getSapDeliveryNotePda(String userId, JSONObject searchCriteria) { String whsLocationCode = StringUtils.isNotEmpty(searchCriteria.getString("whsLocationCode")) ? searchCriteria.getString("whsLocationCode") : null; String deliveryNoteSap = StringUtils.isNotEmpty(searchCriteria.getString("deliveryNoteSap")) ? searchCriteria.getString("deliveryNoteSap"):null; String deliveryType = StringUtils.isNotEmpty(searchCriteria.getString("deliveryType")) ? searchCriteria.getString("deliveryType") : null; String deliveryNoteSrm = StringUtils.isNotEmpty(searchCriteria.getString("deliveryNoteSrm")) ? searchCriteria.getString("deliveryNoteSrm") : null; String spmsMark = StringUtils.isNotEmpty(searchCriteria.getString("spmsMark")) ? searchCriteria.getString("spmsMark") : null; String spmsStatus = StringUtils.isNotEmpty(searchCriteria.getString("spmsStatus")) ? searchCriteria.getString("spmsStatus") : null; String supplierCode = StringUtils.isNotEmpty(searchCriteria.getString("supplierCode")) ? searchCriteria.getString("supplierCode") : null; String plaStartDate = StringUtils.isNotEmpty(searchCriteria.getString("plaStartDate")) ? searchCriteria.getString("plaStartDate") : null; String plaEndDate = StringUtils.isNotEmpty(searchCriteria.getString("plaEndDate")) ? searchCriteria.getString("plaEndDate") : null; String sapVoucherNumber=StringUtils.isNotEmpty(searchCriteria.getString("sapVoucherNumber")) ? searchCriteria.getString("sapVoucherNumber") : null; int pageNo = StringUtils.isNotEmpty(searchCriteria.getString("pageNo")) ? searchCriteria.getIntValue("pageNo") : 1; int pageSize = StringUtils.isNotEmpty(searchCriteria.getString("pageSize")) ? searchCriteria.getIntValue("pageSize") : 20; List werksList = searchCriteria.containsKey("werksList") ? (List) searchCriteria.getJSONArray("werksList") : null; //默认查收货入库的数据（单据类型（DO=转储入库；DN=收货入库）） String businessType = searchCriteria.get("businessType")!=null?searchCriteria.getString("businessType"):null; // 如果指定了deliveryNoteSap，首先查询此deliveryNoteSap是否存在，若不存在，调用sap接口刷新数据 if(StringUtils.isNotEmpty(deliveryNoteSap)){ SapDeliveryNote sapDeliveryNote=this.baseMapper.selectOne(new QueryWrapper().eq("DELIVERY_NOTE_SAP",deliveryNoteSap)); if(null==sapDeliveryNote){ ResponseResult sapReturnedData = getNonExistSapDeliveryNotePda(deliveryNoteSap,"", userId,businessType); if (sapReturnedData.getCode() != 200){ Map map = new HashMap<>(); map.put("sapReturnedData", sapReturnedData.getData().get("sapReturnedData").toString()); map.put("dataToSap", sapReturnedData.getData().get("dataToSap").toString()); return map; } } } List> sapDN = new ArrayList<>(); PageHelper.startPage(pageNo, pageSize); if ("M".equals(spmsMark)) { sapDN = sapDeliveryNoteMapper.getSapDeliverNoteM(userId, deliveryNoteSap, deliveryType, deliveryNoteSrm, spmsMark, supplierCode, plaStartDate, plaEndDate, spmsStatus,sapVoucherNumber,null,whsLocationCode,businessType); } else { sapDN = sapDeliveryNoteMapper.getSapDeliverNote(userId, deliveryNoteSap, deliveryType, deliveryNoteSrm, spmsMark, supplierCode, plaStartDate, plaEndDate, spmsStatus,sapVoucherNumber,null,whsLocationCode,businessType,werksList); } PageInfo> pageData = new PageInfo<>(sapDN); Map pageInfo = new HashMap<>(); pageInfo.put("records", pageData.getList()); pageInfo.put("total", pageData.getTotal()); pageInfo.put("size", pageData.getSize()); pageInfo.put("current", pageData.getPageNum()); pageInfo.put("pages", pageData.getPages()); return pageInfo; } public ResponseResult getNonExistSapDeliveryNotePda(String deliveryNoteSap,String status, String userId, String businessType) { String[] sapClients = allSapClient.split(","); for (int s = 0; s < sapClients.length; s++) { if ("DO".equals(businessType)) { // JSONObject dataToSap = new JSONObject(); // JSONObject REQUEST = new JSONObject(); // JSONObject ESB_ATTRS = new JSONObject(); // JSONObject REQUEST_DATA = new JSONObject(); // JSONObject Head = new JSONObject(); // ESB_ATTRS.put("App_ID", "SPMS"); // ESB_ATTRS.put("Application_ID", "00020000000002"); // ESB_ATTRS.put("Transaction_ID", UUID.randomUUID().toString()); // ESB_ATTRS.put("Target_ID", sapClient);//固定装箱单client // Head.put("VBELN", deliveryNoteSap); //// Head.put("WERKS", werks); //// Head.put("MANDT", selectList.get(0).getZmandt()); // Head.put("TYPE_D", "03"); // Head.put("SYSTEM_IN", "SPMS"); // Head.put("ZBS", ""); // Map structures = new HashMap<>(); // structures.put("IS_DATA", Head); // REQUEST_DATA.put("structures", structures); // REQUEST_DATA.put("Operation", "ZZXD_IF_SPMS_03"); // REQUEST_DATA.put("Type", "ZZXD_IF_SPMS_03"); // // REQUEST.put("ESB_ATTRS", ESB_ATTRS); // REQUEST.put("REQUEST_DATA", REQUEST_DATA); // dataToSap.put("REQUEST", REQUEST); // try { // String message = iFeignServiceCommon.sendRestToSapCommon(dataToSap); // if (StringUtils.isEmpty(message)) { // return ResponseResult.error(); // } // JSONObject returnData = JSONObject.parseObject(message).getJSONObject("RESPONSE").getJSONObject("RETURN_DATA"); // if ("S".equals(returnData.getJSONObject("ES_RETURN").getString("TYPE"))) { // // Map headMap = new HashMap(); // Map noteMap = new HashMap(); // // /** ET_REL —— 装箱单关系表 */ // JSONArray ET_REL = returnData.getJSONArray("ET_REL"); // if (ET_REL != null) { // // int zxdSize = ET_REL.size(); // if (zxdSize > 0) { // /** 装箱单信息表 */ // for (int i = 0; i < zxdSize; i++) { // JSONObject doc = ET_REL.getJSONObject(i); // String XDNUM = doc.getString("XDNUM");//装箱单号 // String ZDECABNO = doc.getString("ZDECABNO");//柜号 // String VBELN = doc.getString("VBELN");//交货单号 // String POSNR = doc.getString("POSNR");//交货单行号 // String EBELN = doc.getString("EBELN");//采购订单号 // String EBELP = doc.getString("EBELP");//采购订单行号 // String PACKAGE_CODE = doc.getString("PACKAGE_CODE");//箱码 // String MANDT1 = doc.getString("MANDT1");//DN客户端 // String MANDT2 = doc.getString("MANDT2");//PO客户端 // JSONObject deliveryNoteInfo = new JSONObject(); // deliveryNoteInfo.put("XDNUM", XDNUM); // deliveryNoteInfo.put("ZDECABNO", ZDECABNO); // deliveryNoteInfo.put("PACKAGE_CODE", PACKAGE_CODE); // deliveryNoteInfo.put("MANDT1", MANDT1); // deliveryNoteInfo.put("MANDT2", MANDT2); // deliveryNoteInfo.put("EBELN", EBELN); // deliveryNoteInfo.put("EBELP", EBELP); // headMap.put(VBELN, deliveryNoteInfo); // noteMap.put(VBELN + "_" + POSNR, deliveryNoteInfo); // } // } // //// 装箱单号 XDNUM //// 装箱单行号 ZPOSNR //// 柜号 ZDECABNO //// Client标识 MANDT //// 交货单号 VBELN //// 交货单行号 POSNR //// Client标识 MANDT //// 采购订单号 EBELN //// 采购订单行号 EBELP //// 箱码 PACKAGE_CODE //// 序号 SERIAL //// 物料 MATNR //// 需求来源号 DEMAND_NO //// 需求来源行号 DEMAND_POSNR //// 需求人 DEMANDER //// 出库数量 GNCKSL //// 单位 MEINS //// 业务标识返回 BUS_SIGN //// Client标识 MANDT // // } // // JSONArray ET_DN = returnData.getJSONArray("ET_DN"); // if (ET_DN != null && ET_DN.size() > 0) { // for (int i = 0; i < ET_DN.size(); i++) { // //System.out.println("=======" + IT_LIPS.size() + " " + i + " SAP 交货单行项目信息 " + IT_LIPS.get(i).toString()); // JSONObject json = JSONObject.parseObject(ET_DN.get(i).toString()); // if (StringUtils.isNotEmpty(json.toString())) { // JSONObject dninfo = noteMap.get(json.getString("VBELN") + "_" + json.getString("POSNR")); // SapDeliveryNoteDtl deliveryNoteDtl = new SapDeliveryNoteDtl(); // deliveryNoteDtl.setDeliveryNoteSap(json.getString("VBELN"));//SAP交货单号 // deliveryNoteDtl.setDeliveryNoteSapItem(Integer.parseInt(json.getString("POSNR")));//SAP交货单行号 // deliveryNoteDtl.setMaterialNo(json.getString("MATNR"));//物料编号 // deliveryNoteDtl.setDeliveryQty(Double.parseDouble(json.getString("LFIMG")));//交货数量 // deliveryNoteDtl.setDeliveryUnit(json.getString("MEINS"));//基本单位 // deliveryNoteDtl.setWerks(json.getString("WERKS"));//工厂 // deliveryNoteDtl.setWhsLocationCode(json.getString("LGORT"));//库存地点 // deliveryNoteDtl.setQtySales(StringUtils.isEmpty(json.getString("ALMNG")) ? 0.0 : json.getDoubleValue("ALMNG"));//销售单位应收数量 // deliveryNoteDtl.setUnitSales(json.getString("VRKME"));//销售单位 // deliveryNoteDtl.setItemStatus(String.valueOf(0));//交货单行项目状态 // deliveryNoteDtl.setMandtDn(dninfo.getString("MANDT1"));// DN客户端 // deliveryNoteDtl.setMandt(dninfo.getString("MANDT2"));// PO客户端 // deliveryNoteDtl.setOrderNumber(dninfo.get("EBELN") != null ? dninfo.getString("EBELN") : null); // deliveryNoteDtl.setOrderItem(dninfo.get("EBELP") != null ? dninfo.getString("EBELP") : null); // // String VBELN = json.getString("VBELN");// // String WERKS_V = json.getString("WERKS_V");//发货工厂 // String WERKS = json.getString("WERKS");//收货工厂 // String MANDT = json.getString("MANDT");//客户端 // if (headMap.get(VBELN) != null) {//存在装箱单与交货单的关系 // JSONObject deliveryNoteInfo = headMap.get(VBELN); // deliveryNoteInfo.put("WERKS_V", WERKS_V); // deliveryNoteInfo.put("WERKS", WERKS); // deliveryNoteInfo.put("VBELN", VBELN); // deliveryNoteInfo.put("MANDT", MANDT); // headMap.put(VBELN, deliveryNoteInfo); // } // // //// deliveryNoteDtl.setPurchaseGroup(json.getString("ZEKGRP"));//采购组 //// deliveryNoteDtl.setPurchaseGroupName(json.getString("ZEKNAM"));//采购组名称 //// deliveryNoteDtl.setOverDeliveryLimit(StringUtils.isNotEmpty(json.getString("UEBTO")) ? Double.parseDouble(json.getString("UEBTO")) : 0);//过量交货限制 //// deliveryNoteDtl.setUnderDeliveryLimit(StringUtils.isNotEmpty(json.getString("UNTTO")) ? Double.parseDouble(json.getString("UNTTO")) : 0);//交货不足限制 //// deliveryNoteDtl.setUnlimited(json.getString("UEBTK"));//无限制 //// deliveryNoteDtl.setWerksXq(json.getString("WERKS_XQ"));//需求工厂 //// // //// 交货单号 VBELN //// 交货单行号 POSNR //// 收货工厂 WERKS //// 收货仓库 LGORT //// 物料号 MATNR //// 数量 LFIMG //// 基本单位 MEINS //// 件数 ALMNG //// 销售单位 VRKME //// 发货工厂 WERKS_V // // QueryWrapper queryWrapper = new QueryWrapper() // .eq("DELIVERY_NOTE_SAP", deliveryNoteDtl.getDeliveryNoteSap()) // .eq("DELIVERY_NOTE_SAP_ITEM", deliveryNoteDtl.getDeliveryNoteSapItem()); // if (sapDeliveryNoteDtlMapper.selectOne(queryWrapper) != null) { // sapDeliveryNoteDtlMapper.update(deliveryNoteDtl, queryWrapper); // } else { // sapDeliveryNoteDtlMapper.insert(deliveryNoteDtl); // } // } // } // } // // // headMap.forEach((key, value) -> { // //System.out.println("=======" + IT_LIKP.size() + " " + i + " SAP 交货单表头信息 " + IT_LIKP.get(i).toString()); // JSONObject json = value; // if (StringUtils.isNotEmpty(json.toString())) { // SapDeliveryNote deliveryNote = new SapDeliveryNote(); // deliveryNote.setBusinessType("DO"); // deliveryNote.setDeliveryNoteSap(json.getString("VBELN"));//SAP交货单号 // deliveryNote.setPackageNote(json.getString("PACKAGE_CODE"));//包装单号 // // deliveryNote.setDeliveryType(json.getString("LFART"));//交货类型 // deliveryNote.setSpmsMark(json.getString("ZSPMS"));//SPMS标识（SAP提供-X表示备件货，M-表示贸易货） //// deliveryNote.setPlannedArrivalDate(json.getString("LFDAT"));//计划到货时间 //// deliveryNote.setDeliveryNoteSrm(json.getString("LIFEX"));//SRM送货单号 //// deliveryNote.setCreateDateSap(json.getString("ERDAT"));//SAP创建日期 //// deliveryNote.setSupplierCode(json.getString("LIFNR"));//供应商编号 // deliveryNote.setMandt(json.getString("MANDT")); // if (this.baseMapper.selectOne(new QueryWrapper() // .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())) != null) { // this.baseMapper.update(deliveryNote, new QueryWrapper() // .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())); // } else { // this.baseMapper.insert(deliveryNote); // } // // } // }); // // //// /** 交货单表头 */ //// JSONArray IT_LIKP = doc.getJSONArray("IT_LIKP"); //// /** 交货单行项目 */ //// JSONArray IT_LIPS = doc.getJSONArray("IT_LIPS"); //// /** 交货单表头供应商信息 */ //// JSONArray IT_LIFNR = doc.getJSONArray("IT_LIFNR"); //// //// /** 包装单号表 */ //// JSONArray IT_HEAD = doc.getJSONArray("IT_HEAD"); //// /** 箱码表表头 */ //// JSONArray IT_XHEAD = doc.getJSONArray("IT_XHEAD"); //// /** 箱码行项目 */ //// JSONArray IT_ITME = doc.getJSONArray("IT_ITME"); //// //// insertDNTitle(IT_LIKP); //// insertDNDtl(IT_LIPS); //// insertDNSupplier(IT_LIFNR); //// //// insertSapPackageNote(IT_HEAD); //// insertSapBoxNote(IT_XHEAD); //// insertSapBoxNoteDtl(IT_ITME); // // iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE, JSONObject.parseObject(message).toJSONString(), dataToSap.toJSONString()); // return ResponseResult.success(); // } else { // iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE_ERROR, JSONObject.parseObject(message).toJSONString(), dataToSap.toJSONString()); // return ResponseResult.error().add("dataToSap", dataToSap).add("sapReturnedData", JSONObject.parseObject(message)); // } // } catch (Exception e) { // e.printStackTrace(); // return ResponseResult.error(); // } } else { String json = "{\n" + " \"REQUEST\": {\n" + " \"ESB_ATTRS\": {\n" + " \"App_ID\": \"SPMS\", \n" + " \"Application_ID\": \"00020000000002\", \n" + " \"Target_ID\": " + "\"" + sapClients[s] + "\",\n" + " \"Transaction_ID\": " + "\"" + UUID.randomUUID() + "\"" + " }, \n" + " \"REQUEST_DATA\": {\n" + " \"fileds\": {\n" + " \"I_VBELN\": " + "\"" + deliveryNoteSap + "\",\n" + " \"I_STATUS\": " + "\"" + status + "\"\n" + " }, \n" + " \"Operation\": \"Z_SPMS_GETDN_NEW\", \n" + " \"Type\": \"GETDN\"\n" + " }\n" + " }\n" + "}"; try { String message = iFeignServiceCommon.sendRestToSapCommon(JSONObject.parseObject(json)); // if (StringUtils.isEmpty(message)) { // return ResponseResult.error(); // } log.info("============Z_SPMS_GETDN:" + message); JSONObject doc = JSONObject.parseObject(message).getJSONObject("RESPONSE").getJSONObject("RETURN_DATA"); if (doc.containsKey("O_TYPE") && "S".equals(doc.getString("O_TYPE"))) { /** 更新交货单表头、供应商、行项目等信息 */ insertSapDeliveryNote(doc); iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE, JSONObject.parseObject(message).toJSONString(), JSONObject.parseObject(json).toJSONString()); // return ResponseResult.success(); } else { iSapDeliveryNoteLogService.insertSapRequestRecord(deliveryNoteSap, userId, UPDATE_DELIVERY_NOTE_ERROR, JSONObject.parseObject(message).toJSONString(), JSONObject.parseObject(json).toJSONString()); // return ResponseResult.error().add("dataToSap", JSONObject.parseObject(json)).add("sapReturnedData", JSONObject.parseObject(message)); } } catch (Exception e) { e.printStackTrace(); return ResponseResult.error(); } } } return ResponseResult.success(); } // 更新sapDN @Override @Transactional(rollbackFor = Exception.class) public synchronized ResponseResult updateSapDeliveryNote(String deliveryNoteSap, String spmsStatus, String remarks, String documentDate, String postingDate, String mobileType, String userId, String operateUser) throws Exception { /** 贸易货确认收货之前判断：送货单表字段包装单号为空，则判断如果物料本身是备件，就不让操作； */ ResponseResult checkResult = checkDataFormat(deliveryNoteSap, spmsStatus); if (checkResult.getCode() != 200){ return checkResult; } // try { SapDeliveryNote sapDeliveryNote = new SapDeliveryNote(); sapDeliveryNote.setSpmsStatus(spmsStatus); sapDeliveryNote.setRemarks(remarks); sapDeliveryNote.setDocumentDate(documentDate); sapDeliveryNote.setPostingDate(postingDate); sapDeliveryNote.setMobileType(mobileType); sapDeliveryNote.setUserId(userId); if (StringUtils.isNotEmpty(operateUser)){ sapDeliveryNote.setOperateUser(operateUser); } QueryWrapper queryWrapper = new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNoteSap); int resp = this.baseMapper.update(sapDeliveryNote, queryWrapper); if (resp > 0) { addSapDeliveryNoteLog(spmsStatus, deliveryNoteSap, userId); return ResponseResult.success(); } return ResponseResult.error(); // } catch (Exception e) { // e.printStackTrace(); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return ResponseResult.error(); // } } /** 贸易货确认收货之前判断：送货单表字段包装单号为空，则判断如果物料本身是备件，就不让操作； */ ResponseResult checkDataFormat(String deliveryNoteSap, String spmsStatus){ if (StringUtils.isEmpty(deliveryNoteSap) || StringUtils.isEmpty(spmsStatus)){ return ResponseResult.error("请求参数错误请重试"); } SapDeliveryNote sapDeliveryNote = this.baseMapper.selectOne(new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap)); if (sapDeliveryNote == null){ return ResponseResult.error("交货单信息不存在"); } /** 包装单号为空则交货单为贸易货，获取贸易货的行数据，及物料本身信息数据判断是否能收货 */ if (StringUtils.isEmpty(sapDeliveryNote.getPackageNote()) && StringUtils.isEmpty(sapDeliveryNote.getSpmsStatus())){ List> mapList = this.baseMapper.getDeliveryNoteInfo(deliveryNoteSap); for (Map map : mapList){ if (map.get("spmsMark") != null && "X".equals(map.get("spmsMark").toString())){ return ResponseResult.error().add("error", "贸易货交货单" + deliveryNoteSap + "中存在备件物料" + map.get("materialNo").toString() + "，请检查数据是否正确"); } } } return ResponseResult.success(); } /** * SAP交货单表头状态更新日志记录: 2-下发到PDA; 3-收货中; 6-已验收待上传SAP; 7-提交SAP失败; 8-提交SAP完成; 11-关闭; 7，8 不会在此处调用。 */ void addSapDeliveryNoteLog(String spmsStatus, String deliveryNoteSap, String userId) { if ("1".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE1); } if ("2".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE2); } if ("3".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE3); } if ("6".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE6); } if ("11".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE11); } } /** * 贸易货交货单更新接口————更新交货单行项目信息，以及贸易货库存信息 * { * "SapDeliveryNoteDtl": [{ * "deliveryNoteSap": "1180066360", * "deliveryNoteSapItem": 10, * "materialNo": "130010159", * "deliveryQty": 2, * "receivedQty": 2, * "actualQtySales":2, * "itemStatus":"1", * "storageUuidList": [{ * "storageUuid": "64eaf8633b3e4b8aa276970f2e31785b", * "qty": 1 * }] * }] * } * * @param doc * @return */ @Override @Transactional(rollbackFor = Exception.class) public ResponseResult updateSapDeliveryNoteDtl(JSONObject doc, String userId) throws Exception { if (!doc.containsKey("SapDeliveryNoteDtl") || doc.getJSONArray("SapDeliveryNoteDtl").size() == 0) { return ResponseResult.error("请求参数错误"); } // try { JSONArray array = doc.getJSONArray("SapDeliveryNoteDtl"); for (int i = 0; i < array.size(); i++) { JSONObject obj = array.getJSONObject(i); SapDeliveryNoteDtl sapDeliveryNoteDtl = new SapDeliveryNoteDtl(); QueryWrapper queryWrapper = new QueryWrapper() .eq("DELIVERY_NOTE_SAP", obj.getString("deliveryNoteSap")) .eq("DELIVERY_NOTE_SAP_ITEM", obj.getString("deliveryNoteSapItem")); sapDeliveryNoteDtl.setReceivedQty(StringUtils.isEmpty(obj.getString("receivedQty")) ? 0 : Double.parseDouble(obj.getString("receivedQty"))); sapDeliveryNoteDtl.setActualQtySales(StringUtils.isEmpty(obj.getString("actualQtySales")) ? 0 : obj.getDoubleValue("actualQtySales")); sapDeliveryNoteDtl.setItemStatus(obj.getString("itemStatus")); sapDeliveryNoteDtl.setRemarks(obj.getString("remarks")); sapDeliveryNoteDtl.setUnitSales(obj.getString("unitSales")); String strStorageUuidList = obj.getJSONArray("storageUuidList").toJSONString(); sapDeliveryNoteDtl.setTempStorage(strStorageUuidList); /** 贸易货————根据交货单号和行号，更新交货单行项目指定行实收数量字段；交货单行项目实收数量更新成功才能执行库存更新操作； */ int resp = sapDeliveryNoteDtlMapper.update(sapDeliveryNoteDtl, queryWrapper); if (resp > 0) { /** 更新贸易货库存信息 */ String materialNo = obj.getString("materialNo"); JSONArray storageUuidList = obj.getJSONArray("storageUuidList"); String deliveryNoteSapItem = obj.getString("deliveryNoteSapItem"); /** 一个物料存入多个储位，需要每个储位单独查询是否已有该物料库存然后写入 */ if (storageUuidList.size() > 0) { for (int item = 0; item < storageUuidList.size(); item++) { String storageUuid = storageUuidList.getJSONObject(item).getString("storageUuid"); double qty = Double.parseDouble(storageUuidList.getJSONObject(item).getString("qty")); if (qty != 0) { /** 如果该物料在该储位已经存在，则更新对应储位下物料的库存数量；如果不存在，则新建一条储位-物料-数量的数据； */ QueryWrapper wrapper = new QueryWrapper().eq("UUID", storageUuid).eq("MATERIAL_NO", materialNo); WhsStorageInventory storageInventory = whsStorageInventoryMapper.selectOne(wrapper); WhsStorageInventory whsStorageInventory = new WhsStorageInventory(); if (storageInventory != null) { whsStorageInventory.setQuantity(storageInventory.getQuantity() + qty); whsStorageInventory.setAvailableQty(storageInventory.getAvailableQty() + qty); /** 物料在对应储位已存在数据，则更新库存数量和可用数量； */ whsStorageInventoryMapper.update(whsStorageInventory, wrapper); } else { whsStorageInventory.setUuid(storageUuid); whsStorageInventory.setMaterialNo(materialNo); whsStorageInventory.setQuantity(qty); whsStorageInventory.setAvailableQty(qty); /** 物料在对应储位不存在数据，则新建一条储位-物料-数量的数据； */ whsStorageInventoryMapper.insert(whsStorageInventory); } WhsStorage whsStorage = iWhsStorageService.getWhsStorageByUuid(storageUuid); /** 记录自管仓贸易货按物料上架增加储位库存日志 */ iWhsOperateLogService.insertWhsOperateLogMS(storageUuid, materialNo, qty, obj.getString("deliveryNoteSap"), TRADE_GOODS_INTO_STORAGE, userId, whsStorage.getWerks(), whsStorage.getWhsLocationCode(), deliveryNoteSapItem); } } } } else { return ResponseResult.error("更新行项目数据失败"); } } /** 添加更新储位库存的日志记录，交货单号取行项目里第一行交货单号即可 */ iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(array.getJSONObject(0).getString("deliveryNoteSap"), userId, UPDATE_STORAGE_INVENTORY); /** 添加更新交货单详情的日志记录，交货单号取行项目里第一行交货单号即可 */ iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(array.getJSONObject(0).getString("deliveryNoteSap"), userId, UPDATE_SAP_DELIVERY_NOTE_DTL); return ResponseResult.success(); // } catch (Exception e) { // e.printStackTrace(); // System.out.println("======= insertSapDeliveryNote " + e); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return ResponseResult.error(); // } } /*** * { * "sapBoxNotes": [{ * "boxNote": "ZX-10218300001-0202", * "boxQtyReceived": 1, * "storageUuid": "b95946ac1dab42b79ade3438acb0b53h", * "qty": 1, * "itemStatus": "1" * }] * } * 备件货收货更新箱码信息 * @param doc * @return */ // @Override // @Transactional(rollbackFor = Exception.class) // public ResponseResult updateSapBoxNote(JSONObject doc) { // if (!doc.containsKey("sapBoxNotes") || doc.getJSONArray("sapBoxNotes").size() == 0){ // return ResponseResult.error("请求参数错误"); // } // try { // JSONArray sapBoxNotes = doc.getJSONArray("sapBoxNotes"); // for (int i = 0; i < sapBoxNotes.size(); i++){ // JSONObject object = sapBoxNotes.getJSONObject(i); // SapBoxNote sapBoxNote = new SapBoxNote(); // sapBoxNote.setBoxQtyReceived(StringUtils.isEmpty(object.getString("boxQtyReceived")) ? null : Integer.parseInt(object.getString("boxQtyReceived"))); // sapBoxNote.setItemStatus(StringUtils.isEmpty(object.getString("itemStatus")) ? null : object.getString("itemStatus")); // /** 更新箱码实收数量、状态 */ // int resp = sapBoxNoteMapper.update(sapBoxNote, new QueryWrapper().eq("BOX_NOTE", object.getString("boxNote"))); // /** 更新箱码库存。备件货按箱码存储，储位 uuid + 箱码可做唯一性 */ // if (StringUtils.isNotEmpty(object.getString("qty")) && StringUtils.isNotEmpty(object.getString("storageUuid"))){ // QueryWrapper queryWrapper = new QueryWrapper() // .eq("UUID", object.getString("storageUuid")).eq("BOX_NOTE", object.getString("boxNote")); // WhsStorageInventory whsStorageInventory = new WhsStorageInventory(); // whsStorageInventory.setUuid(object.getString("storageUuid")); // whsStorageInventory.setBoxNote(object.getString("boxNote")); // whsStorageInventory.setQuantity(Double.parseDouble(object.getString("qty"))); // if (whsStorageInventoryMapper.selectOne(queryWrapper) == null){ // /** 备件货按箱码存储，每个箱子的箱码数量都是 1，可用库存字段忽略直接使用库存数量字段——QUANTITY */ // whsStorageInventoryMapper.insert(whsStorageInventory); // } else { // /** 防止多次提交，箱码数量都是 1，此处仅做更新操作 */ // whsStorageInventoryMapper.update(whsStorageInventory, queryWrapper); // } // } // } // return ResponseResult.success(); // }catch (Exception e){ // System.out.println("======= insertSapDeliveryNote " + e); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return ResponseResult.error(); // } // } /** * { * "deliveryNoteSap": "1180066360", * "plaEndDate": "20210414", * "plaStartDate": "20210301", * "spmsStatus":"3", * "pageNo": "1", * "pageSize": "20" * } * * @param doc * @return */ @Override public Map getSpDeliveryNoteTask(String userId, JSONObject doc) { String deliveryNoteSap = StringUtils.isNotEmpty(doc.getString("deliveryNoteSap")) ? doc.getString("deliveryNoteSap") : null; String plaStartDate = StringUtils.isNotEmpty(doc.getString("plaStartDate")) ? doc.getString("plaStartDate") : null; String plaEndDate = StringUtils.isNotEmpty(doc.getString("plaEndDate")) ? doc.getString("plaEndDate") : null; String spmsStatus = StringUtils.isNotEmpty(doc.getString("spmsStatus")) ? doc.getString("spmsStatus") : null; int pageNo = StringUtils.isNotEmpty(doc.getString("pageNo")) ? doc.getInteger("pageNo") : 1; int pageSize = StringUtils.isNotEmpty(doc.getString("pageSize")) ? doc.getInteger("pageSize") : 20; PageHelper.startPage(pageNo, pageSize); //默认查收货入库的数据（单据类型（DO=转储入库；DN=收货入库）） String businessType = doc.get("businessType")!=null?doc.getString("businessType"):null; List> sapDeliveryNote = this.baseMapper.getSpDeliveryNoteTask(userId, deliveryNoteSap, plaStartDate, plaEndDate, spmsStatus,businessType); DataToPage dataToPage = new DataToPage(); return dataToPage.toPageData(sapDeliveryNote); } /** 单据状态控制：0-待到货；1-已到货；2-下发到PDA；3-收货中；4-待上架；5-上架中；6-已验收待上传SAP；7-提交SAP失败；8-提交SAP完成；9-回撤重新入库；10-部分完成；11-关闭； * 关闭/开启自管仓交货单，关闭单据 operateType = 0，开启单据 operateType = 1； * 关闭单据状态变化：null 或 0 —— 11；开启单据状态变化：11 —— 0； * */ @Override public synchronized ResponseResult closeOrOpenSapDeliveryNote(String deliveryNoteSap, String operateType, String userId) { if (StringUtils.isEmpty(deliveryNoteSap) || StringUtils.isEmpty(operateType)){ return ResponseResult.error("请求参数错误"); } if (!"0".equals(operateType) && !"1".equals(operateType)){ return ResponseResult.error("请求参数错误"); } QueryWrapper queryWrapper = new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap); SapDeliveryNote sapDeliveryNote = this.baseMapper.selectOne(queryWrapper); if (sapDeliveryNote == null){ return ResponseResult.error("查询该交货单不存在"); } String spmsStatus = sapDeliveryNote.getSpmsStatus(); if ("0".equals(operateType)){ if (StringUtils.isEmpty(spmsStatus) || "0".equals(spmsStatus)){ sapDeliveryNote.setSpmsStatus("11"); this.baseMapper.update(sapDeliveryNote, queryWrapper); iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, UPDATE_SAP_DELIVERY_NOTE11); return ResponseResult.success().add("sapDeliveryNote", this.baseMapper.selectOne(queryWrapper)); } else { return ResponseResult.error("交货单当前状态禁止关闭操作"); } } else { if (StringUtils.isEmpty(spmsStatus)){ return ResponseResult.error("交货单当前状态禁止开启操作"); } if (!"11".equals(spmsStatus)){ return ResponseResult.error("交货单当前状态禁止开启操作"); } sapDeliveryNote.setSpmsStatus("0"); this.baseMapper.update(sapDeliveryNote, queryWrapper); iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, "已开启"); return ResponseResult.success().add("sapDeliveryNote", this.baseMapper.selectOne(queryWrapper)); } } @Override public synchronized ResponseResult revokeSapDeliveryNote(String deliveryNoteSap, String userId) { if (StringUtils.isEmpty(deliveryNoteSap)){ return ResponseResult.error("请求参数错误"); } QueryWrapper queryWrapper = new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap); SapDeliveryNote sapDeliveryNote = this.baseMapper.selectOne(queryWrapper); if (sapDeliveryNote == null){ return ResponseResult.error("查询该交货单不存在"); } String spmsStatus = sapDeliveryNote.getSpmsStatus(); if (StringUtils.isEmpty(spmsStatus)){ return ResponseResult.error("交货单当前状态禁止撤销操作"); } if (!"3".equals(spmsStatus)){ return ResponseResult.error("交货单当前状态禁止撤销操作"); } // 查询交货单是否还有分批收货单未进行关闭 List batchList = this.baseMapper.selectBatchReceipt(deliveryNoteSap); if (!CollectionUtils.isEmpty(batchList)) { return ResponseResult.error("交货单还有关联的入库单未关闭，请关闭入库单后在进行撤销操作"); } sapDeliveryNote.setSpmsStatus("0"); this.baseMapper.update(sapDeliveryNote, queryWrapper); iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, "撤销"); return ResponseResult.success().add("sapDeliveryNote", this.baseMapper.selectOne(queryWrapper)); } @Override @Transactional(rollbackFor = Exception.class) /** 获取来自 SAP 系统的送货单交货单任务——自管仓入库任务等信息并更新相关数据 */ public void insertSapDeliveryNote(JSONObject doc) throws Exception { /** 交货单表头 */ JSONArray IT_LIKP = doc.getJSONArray("IT_LIKP"); /** 交货单行项目 */ JSONArray IT_LIPS = doc.getJSONArray("IT_LIPS"); /** 交货单表头供应商信息 */ JSONArray IT_LIFNR = doc.getJSONArray("IT_LIFNR"); /** 包装单号表 */ JSONArray IT_HEAD = doc.getJSONArray("IT_HEAD"); /** 箱码表表头 */ JSONArray IT_XHEAD = doc.getJSONArray("IT_XHEAD"); /** 箱码行项目 */ JSONArray IT_ITME = doc.getJSONArray("IT_ITME"); insertDNTitle(IT_LIKP); insertDNDtl(IT_LIPS); insertDNSupplier(IT_LIFNR); insertSapPackageNote(IT_HEAD); insertSapBoxNote(IT_XHEAD); insertSapBoxNoteDtl(IT_ITME); } void insertDNTitle(JSONArray IT_LIKP) { SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); for (int i = 0; i < IT_LIKP.size(); i++) { JSONObject json = JSONObject.parseObject(IT_LIKP.get(i).toString()); if (StringUtils.isNotEmpty(json.toString())) { SapDeliveryNote deliveryNote = new SapDeliveryNote(); deliveryNote.setBusinessType("DN"); deliveryNote.setDeliveryNoteSap(json.getString("VBELN")); // 计划到货时间 if (StringUtils.isNotEmpty(json.getString("LFDAT"))) { Long lfdat = Long.valueOf(json.getString("LFDAT")); Date newDate = new Date(lfdat); deliveryNote.setPlannedArrivalDate(sdf.format(newDate)); } deliveryNote.setDeliveryNoteSrm(json.getString("LIFEX")); deliveryNote.setDeliveryType(json.getString("LFART")); deliveryNote.setSpmsMark(json.getString("ZSPMS")); // SAP创建日期 if (StringUtils.isNotEmpty(json.getString("ERDAT"))) { Long erdat = Long.valueOf(json.getString("ERDAT")); Date newDate = new Date(erdat); deliveryNote.setCreateDateSap(sdf.format(newDate)); } deliveryNote.setSupplierCode(StringUtils.isNotEmpty(json.getString("LIFNR")) ? json.getString("LIFNR").replaceAll("^(0+)", "") : ""); deliveryNote.setPackageNote(json.getString("PACKAGE_NO")); deliveryNote.setMandt(json.getString("MANDT")); if (this.baseMapper.selectOne(new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())) != null) { this.baseMapper.update(deliveryNote, new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap())); } else { this.baseMapper.insert(deliveryNote); } } } } void insertDNDtl(JSONArray IT_LIPS) { for (int i = 0; i < IT_LIPS.size(); i++) { JSONObject json = JSONObject.parseObject(IT_LIPS.get(i).toString()); if (StringUtils.isNotEmpty(json.toString())) { SapDeliveryNoteDtl deliveryNoteDtl = new SapDeliveryNoteDtl(); deliveryNoteDtl.setDeliveryNoteSap(json.getString("VBELN")); deliveryNoteDtl.setDeliveryNoteSapItem(Integer.parseInt(json.getString("POSNR"))); deliveryNoteDtl.setPurchaseGroup(json.getString("ZEKGRP")); deliveryNoteDtl.setPurchaseGroupName(json.getString("ZEKNAM")); deliveryNoteDtl.setMaterialNo(json.getString("MATNR")); //deliveryNoteDtl.setDeliveryQty(Double.parseDouble(json.getString("LFIMG"))); /** 用字段LGMNG（基本单位数量）替换LFIMG（销售单位数量） ———— 20210817 */ deliveryNoteDtl.setDeliveryQty(Double.parseDouble(json.getString("LGMNG"))); //deliveryNoteDtl.setDeliveryUnit(json.getString("VRKME")); /** 用字段MEINS基本单位替换VRKME；DeliveryUnit固定存基本单位； */ deliveryNoteDtl.setDeliveryUnit(json.getString("MEINS")); deliveryNoteDtl.setWerks(json.getString("WERKS")); deliveryNoteDtl.setWhsLocationCode(json.getString("LGORT")); deliveryNoteDtl.setOrderNumber(json.getString("VGBEL")); deliveryNoteDtl.setOrderItem(json.getString("VGPOS")); deliveryNoteDtl.setOverDeliveryLimit(StringUtils.isNotEmpty(json.getString("UEBTO")) ? Double.parseDouble(json.getString("UEBTO")) : 0); deliveryNoteDtl.setUnderDeliveryLimit(StringUtils.isNotEmpty(json.getString("UNTTO")) ? Double.parseDouble(json.getString("UNTTO")) : 0); deliveryNoteDtl.setUnlimited(json.getString("UEBTK")); deliveryNoteDtl.setItemStatus(String.valueOf(0)); deliveryNoteDtl.setWerksXq(json.getString("WERKS_XQ")); deliveryNoteDtl.setQtySales(StringUtils.isEmpty(json.getString("QTY_SALES")) ? 0.0 : json.getDoubleValue("QTY_SALES")); deliveryNoteDtl.setUnitSales(json.getString("UNIT_SALES")); deliveryNoteDtl.setMandt(json.getString("MANDT")); QueryWrapper queryWrapper = new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNoteDtl.getDeliveryNoteSap()) .eq("DELIVERY_NOTE_SAP_ITEM", deliveryNoteDtl.getDeliveryNoteSapItem()); if (sapDeliveryNoteDtlMapper.selectOne(queryWrapper) != null) { sapDeliveryNoteDtlMapper.update(deliveryNoteDtl, queryWrapper); } else { sapDeliveryNoteDtlMapper.insert(deliveryNoteDtl); } } } } void insertDNSupplier(JSONArray IT_LIFNR) { for (int i = 0; i < IT_LIFNR.size(); i++) { JSONObject json = JSONObject.parseObject(IT_LIFNR.get(i).toString()); if (StringUtils.isNotEmpty(json.toString())) { SapDeliveryNote deliveryNote = new SapDeliveryNote(); deliveryNote.setDeliveryNoteSap(json.getString("VBELN")); deliveryNote.setSupplierCode(StringUtils.isNotEmpty(json.getString("LIFNR")) ? json.getString("LIFNR").replaceAll("^(0+)", "") : ""); deliveryNote.setSupplierDesc(json.getString("ZTEXT")); QueryWrapper queryWrapper = new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNote.getDeliveryNoteSap()); if (this.baseMapper.selectOne(queryWrapper) != null) { this.baseMapper.update(deliveryNote, queryWrapper); } else { this.baseMapper.insert(deliveryNote); } } } } void insertSapPackageNote(JSONArray IT_HEAD) { if (IT_HEAD.size() > 0) { for (int i = 0; i < IT_HEAD.size(); i++) { JSONObject json = IT_HEAD.getJSONObject(i); if (StringUtils.isNotEmpty(json.toString())) { SapPackageNote packageNote = new SapPackageNote(); packageNote.setPackageNote(json.getString("PACKAGE_NO")); packageNote.setDeliveryNoteSrm(json.getString("SRM_DN")); packageNote.setDeliveryNoteSap(json.getString("SAP_DN")); packageNote.setSupplierCode(json.getString("LIFNR")); packageNote.setTotalVolume(StringUtils.isEmpty(json.getString("VOLUM_T")) ? 0.000 : Double.parseDouble(json.getString("VOLUM_T"))); packageNote.setTotalWeight(StringUtils.isEmpty(json.getString("BRGEW_T")) ? 0.000 : Double.parseDouble(json.getString("BRGEW_T"))); packageNote.setLoadBeginTime(json.getString("ZXDATE_F")); packageNote.setLoadEndTime(json.getString("ZXDATE_T")); packageNote.setTransporter(json.getString("YSR")); packageNote.setContractorInfo(json.getString("CYRLXFS")); packageNote.setReceiver(json.getString("SHR")); packageNote.setReceiverInfo(json.getString("SHRLXFS")); packageNote.setReceivingAddress(json.getString("SHDZ")); packageNote.setSpmsContractNote(json.getString("SPMS_CONTRACT_NO")); packageNote.setSpmsMark(json.getString("SPMS_FLG")); packageNote.setMandt(json.getString("MANDT")); QueryWrapper queryWrapper = new QueryWrapper().eq("PACKAGE_NOTE", json.getString("PACKAGE_NO")); if (sapPackageNoteMapper.selectOne(queryWrapper) != null) { sapPackageNoteMapper.update(packageNote, queryWrapper); } else { sapPackageNoteMapper.insert(packageNote); } } } } } void insertSapBoxNote(JSONArray IT_XHEAD) { if (IT_XHEAD.size() > 0) { for (int i = 0; i < IT_XHEAD.size(); i++) { JSONObject json = IT_XHEAD.getJSONObject(i); if (StringUtils.isNotEmpty(json.toString())) { SapBoxNote sapBoxNote = new SapBoxNote(); sapBoxNote.setPackageNote(json.getString("PACKAGE_NO")); sapBoxNote.setBoxNote(json.getString("PACKAGE_CODE")); sapBoxNote.setBoxMaterialName(json.getString("OUTER_BOX_TEXTURE")); sapBoxNote.setTotalQty(StringUtils.isEmpty(json.getString("TOTAL_QTY")) ? 0 : Double.valueOf(json.getString("TOTAL_QTY")).intValue()); sapBoxNote.setBoxGrossWeight(StringUtils.isEmpty(json.getString("BOX_BRGEW")) ? 0.000 : Double.parseDouble(json.getString("BOX_BRGEW"))); sapBoxNote.setBoxVolume(StringUtils.isEmpty(json.getString("BOX_VOLUM")) ? 0.000 : Double.parseDouble(json.getString("BOX_VOLUM"))); sapBoxNote.setBoxLength(StringUtils.isEmpty(json.getString("LENGTH")) ? 0.000 : Double.parseDouble(json.getString("LENGTH"))); sapBoxNote.setBoxWidth(StringUtils.isEmpty(json.getString("WIDTH")) ? 0.000 : Double.parseDouble(json.getString("WIDTH"))); sapBoxNote.setBoxHeight(StringUtils.isEmpty(json.getString("HEIGHT")) ? 0.000 : Double.parseDouble(json.getString("HEIGHT"))); sapBoxNote.setBoxColor(json.getString("COLOR")); sapBoxNote.setMandt(json.getString("MANDT")); sapBoxNote.setItemStatus(String.valueOf(0)); QueryWrapper queryWrapper = new QueryWrapper().eq("BOX_NOTE", json.getString("PACKAGE_CODE")); if (sapBoxNoteMapper.selectOne(queryWrapper) != null) { sapBoxNoteMapper.update(sapBoxNote, queryWrapper); } else { sapBoxNoteMapper.insert(sapBoxNote); } } } } } void insertSapBoxNoteDtl(JSONArray IT_ITME) { if (IT_ITME.size() > 0) { for (int i = 0; i < IT_ITME.size(); i++) { JSONObject json = IT_ITME.getJSONObject(i); if (StringUtils.isNotEmpty(json.toString())) { SapBoxNoteDtl sapBoxNoteDtl = new SapBoxNoteDtl(); sapBoxNoteDtl.setPackageNote(json.getString("PACKAGE_NO")); sapBoxNoteDtl.setItem(StringUtils.isEmpty(json.getString("SERIAL")) ? null : Integer.parseInt(json.getString("SERIAL"))); sapBoxNoteDtl.setBoxNote(json.getString("PACKAGE_CODE")); sapBoxNoteDtl.setPackagePosnr(StringUtils.isEmpty(json.getString("PACKAGE_POSNR")) ? null : Integer.parseInt(json.getString("PACKAGE_POSNR"))); sapBoxNoteDtl.setMaterialNo(StringUtils.isNotEmpty(json.getString("MATNR")) ? json.getString("MATNR").replaceAll("^(0+)", "") : ""); sapBoxNoteDtl.setSpecs(json.getString("SPECS")); sapBoxNoteDtl.setQuantity(StringUtils.isEmpty(json.getString("MENGE")) ? 0.000 : Double.parseDouble(json.getString("MENGE"))); sapBoxNoteDtl.setBasicUnit(json.getString("MEINS")); sapBoxNoteDtl.setSrmContractNo(json.getString("SRM_CONTRACT_NO")); sapBoxNoteDtl.setPurchaseNo(json.getString("EBELN")); sapBoxNoteDtl.setPurchaseNoItem(StringUtils.isEmpty(json.getString("EBELP")) ? null : Integer.parseInt(json.getString("EBELP"))); sapBoxNoteDtl.setDeliveryNoteSap(json.getString("VBELN")); sapBoxNoteDtl.setDeliveryNoteSapItem(StringUtils.isEmpty(json.getString("POSNR")) ? null : Integer.parseInt(json.getString("POSNR"))); sapBoxNoteDtl.setDemandNo(json.getString("DEMAND_NO")); sapBoxNoteDtl.setDemandNoItem(StringUtils.isEmpty(json.getString("DEMAND_POSNR")) ? null : Integer.parseInt(json.getString("DEMAND_POSNR"))); sapBoxNoteDtl.setDemander(json.getString("DEMANDER")); sapBoxNoteDtl.setRemark(json.getString("MARK")); sapBoxNoteDtl.setMandt(json.getString("MANDT")); sapBoxNoteDtl.setGrossWeight(StringUtils.isEmpty(json.getString("BRGEW")) ? 0.000 : Double.parseDouble(json.getString("BRGEW"))); sapBoxNoteDtl.setNetWeight(StringUtils.isEmpty(json.getString("NTGEW")) ? 0.000 : Double.parseDouble(json.getString("NTGEW"))); sapBoxNoteDtl.setDomesticQtyReceivable(StringUtils.isEmpty(json.getString("GNSHSL")) ? null : Double.parseDouble(json.getString("GNSHSL"))); //sapBoxNoteDtl.setDomesticQtyReceived(StringUtils.isEmpty(json.getString("GNSJSL")) ? null : Double.parseDouble(json.getString("GNSJSL"))); //sapBoxNoteDtl.setOverseaQtyReceived(StringUtils.isEmpty(json.getString("HWSHSL")) ? null : Double.parseDouble(json.getString("HWSHSL"))); QueryWrapper queryWrapper = new QueryWrapper() .eq("BOX_NOTE", json.getString("PACKAGE_CODE")) .eq("ITEM", json.getString("SERIAL")); if (sapBoxNoteDtlMapper.selectOne(queryWrapper) != null) { sapBoxNoteDtlMapper.update(sapBoxNoteDtl, queryWrapper); } else { sapBoxNoteDtlMapper.insert(sapBoxNoteDtl); } } } } } /*** * 根据交货单号获取交货单表头及明细信息，提交给SAP * @param deliveryNoteSap * @return */ @Override public synchronized Map getDnDataToSap(String deliveryNoteSap, String postingDate, String userId, String remarks, String operateUser) { if (StringUtils.isEmpty(deliveryNoteSap)) { return null; } try { Map map = new HashMap<>(); SapDeliveryNote sapDeliveryNote = this.baseMapper.selectOne(new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap)); /** 提交前交货单状态需为 6 - 已验收待上传SAP 或 7 - 提交SAP失败；不为 6 或 7 的返回空。提交SAP前将过账日期 - postingDate 字段写入该条数据 */ if (sapDeliveryNote != null && ("6".equals(sapDeliveryNote.getSpmsStatus()) || "7".equals(sapDeliveryNote.getSpmsStatus()))) { /** 将 postingDate 字段写入该条数据 */ sapDeliveryNote.setPostingDate(postingDate); if (StringUtils.isNotEmpty(remarks)){ sapDeliveryNote.setRemarks(remarks); } if (StringUtils.isNotEmpty(operateUser)){ sapDeliveryNote.setOperateUser(operateUser); } int resp = this.baseMapper.update(sapDeliveryNote, new QueryWrapper().eq("DELIVERY_NOTE_SAP", deliveryNoteSap)); if (resp <= 0) { return null; } /** 提交SAP 和重新提交SAP 记录日志信息 */ insertSapDnLog(deliveryNoteSap, sapDeliveryNote.getSpmsStatus(), userId); Map Head = new HashMap<>(); List> Items = new ArrayList<>(); /** sapDeliveryNoteDtlList 用于存储贸易货交货单行项目数据 */ List> sapDeliveryNoteDtlList = new ArrayList<>(); /** sapBoxNoteDtlList 用于存储备件货由箱码明细数据转换成的交货行项目数据 */ List> sapBoxNoteDtlList = new ArrayList<>(); /** Head.put("xblnr", StringUtils.isNotEmpty(sapDeliveryNote.getDeliveryNoteSrm()) ? sapDeliveryNote.getDeliveryNoteSrm() : ""); ZZXD_IF_SPMS_04 回写SAP传值 xblnr 也传值 DELIVERY_NOTE_SAP ———— 20210906 wayne */ Head.put("XBLNR", StringUtils.isNotEmpty(sapDeliveryNote.getDeliveryNoteSap()) ? sapDeliveryNote.getDeliveryNoteSap() : ""); Head.put("VBELN", StringUtils.isNotEmpty(sapDeliveryNote.getDeliveryNoteSap()) ? sapDeliveryNote.getDeliveryNoteSap() : ""); Head.put("VBELN_IM", StringUtils.isNotEmpty(sapDeliveryNote.getDeliveryNoteSap()) ? sapDeliveryNote.getDeliveryNoteSap() : ""); Head.put("BLDAT", StringUtils.isNotEmpty(sapDeliveryNote.getDocumentDate()) ? sapDeliveryNote.getDocumentDate().replaceAll("-", "") : ""); Head.put("MANDT_PO", StringUtils.isNotEmpty(sapDeliveryNote.getMandt()) ? sapDeliveryNote.getMandt() : ""); Head.put("LYDJH", StringUtils.isNotEmpty(sapDeliveryNote.getDeliveryNoteSap()) ? sapDeliveryNote.getDeliveryNoteSap() : ""); Head.put("SHLX", "A"); //Head.put("budat", StringUtils.isNotEmpty(sapDeliveryNote.getPostingDate()) ? sapDeliveryNote.getPostingDate() : ""); Head.put("BUDAT", postingDate.replaceAll("-", "")); Head.put("CREATEDBY", StringUtils.isNotEmpty(sapDeliveryNote.getUserId()) ? sapDeliveryNote.getUserId() : ""); //移动类型采购入库 101；免费入库511； Head.put("BWART", StringUtils.isNotEmpty(sapDeliveryNote.getMobileType()) ? sapDeliveryNote.getMobileType() : "101"); Head.put("BKTXT", StringUtils.isNotEmpty(sapDeliveryNote.getRemarks()) ? sapDeliveryNote.getRemarks() : " "); // SimpleDateFormat simp = new SimpleDateFormat("yyyy:MM:ddHH:mm:ss:SS");//月日时分秒毫秒 // String serialNumber=simp.format(new Date()).replace(":","" ); // Head.put("SPMSID", "SPMS"+serialNumber); /** sapDeliveryNote.getPackageNote() 为空贸易货；不为空备件货；*/ if (StringUtils.isEmpty(sapDeliveryNote.getPackageNote())) { /** 实际收货数量字段值为空的不会被提交，查询条件还需完善 */ /** sapDeliveryNoteDtlList = sapDeliveryNoteDtlMapper.selectList(new QueryWrapper() .eq("DELIVERY_NOTE_SAP", deliveryNoteSap).gt("RECEIVED_QTY", 0)); ———— 20210908 取值修改，基本单位不取 SAP_DELIVERY_NOTE_DTL.DELIVERY_UNIT 改取物料的基本单位； */ sapDeliveryNoteDtlList = sapDeliveryNoteDtlMapper.getDeliveryNoteDtlToSap(deliveryNoteSap); if (sapDeliveryNoteDtlList.size() == 0) { return null; } for (Map sapDeliveryNoteDtl : sapDeliveryNoteDtlList) { Map Item = new HashMap<>(); Item.put("VBELN_IM", sapDeliveryNoteDtl.get("deliveryNoteSap").toString()); Item.put("VBELP_IM", String.valueOf(sapDeliveryNoteDtl.get("deliveryNoteSapItem"))); Item.put("MATNR", sapDeliveryNoteDtl.get("materialNo").toString()); Item.put("BSTMG", sapDeliveryNoteDtl.get("receivedQty").toString()); Item.put("BSTME", sapDeliveryNoteDtl.get("basicUnit").toString()); Item.put("WERKS", sapDeliveryNoteDtl.get("werks").toString()); Item.put("LGORT", sapDeliveryNoteDtl.get("whsLocationCode").toString()); Item.put("SGTXT", sapDeliveryNoteDtl.get("remarks") == null ? " " : sapDeliveryNoteDtl.get("remarks").toString()); Items.add(Item); } } else { sapBoxNoteDtlList = this.baseMapper.getBoxNoteDtlToSap(deliveryNoteSap); if (sapBoxNoteDtlList.size() == 0) { return null; } for (Map sapBoxNoteMaterial : sapBoxNoteDtlList) { Map Item = new HashMap<>(); Item.put("VBELN_IM", sapBoxNoteMaterial.get("deliveryNoteSap").toString()); Item.put("VBELP_IM", sapBoxNoteMaterial.get("deliveryNoteSapItem").toString()); Item.put("MATNR", sapBoxNoteMaterial.get("materialNo").toString()); Item.put("BSTMG", sapBoxNoteMaterial.get("domesticQtyReceived").toString()); Item.put("BSTME", sapBoxNoteMaterial.get("basicUnit").toString()); Item.put("WERKS", sapBoxNoteMaterial.get("werks").toString()); Item.put("LGORT", sapBoxNoteMaterial.get("whsLocationCode").toString()); /** sgtxt - 项目文本。备件按箱存储，交货单一行可能跨越多个箱子，无法留存备注信息。 */ Item.put("SGTXT", " "); Items.add(Item); } } map.put("Head", Head); map.put("Items", Items); return ZZXD_IF_SPMS_04(map); } return null; } catch (Exception e) { e.printStackTrace(); return null; } } /** * 根据交货单提交前状态判断交货但是提交SAP 还是重提SAP，然后记录单据操作日志。 */ void insertSapDnLog(String deliveryNoteSap, String spmsStatus, String userId) { if ("6".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, SUBMIT_SAP_DELIVERY_NOTE_SAP); } if ("7".equals(spmsStatus)) { iSapDeliveryNoteLogService.insertSapDeliveryNoteLogM(deliveryNoteSap, userId, RESUBMIT_SAP_DELIVERY_NOTE_SAP); } } public Map ZZXD_IF_SPMS_04(Map map) { String mqUuid = UUID.randomUUID().toString(); JSONObject doc = new JSONObject(); JSONObject REQUEST = new JSONObject(); JSONObject ESB_ATTRS = new JSONObject(); JSONObject REQUEST_DATA = new JSONObject(); ESB_ATTRS.put("Application_ID", "00020000000002"); ESB_ATTRS.put("Transaction_ID", mqUuid); ESB_ATTRS.put("App_ID", "SPMS"); ESB_ATTRS.put("Target_ID", sapClient);//装箱单的接口只推送到装箱单的client REQUEST_DATA.put("Operation", "ZZXD_IF_SPMS_04"); REQUEST_DATA.put("Type", "ZZXD_IF_SPMS_04"); // REQUEST_DATA.put("Head", map.get("Head")); // REQUEST_DATA.put("Items", map.get("Items")); Map tables = new HashMap<>(); List