Compare commits
No commits in common. "e51c4eea7f81d38af354d2980e918b3fd093e126" and "7176a2a3bf08ec494ccac373bd797023bec6f152" have entirely different histories.
e51c4eea7f
...
7176a2a3bf
@ -1,7 +1,6 @@
|
|||||||
package com.cim.idm.service;
|
package com.cim.idm.service;
|
||||||
|
|
||||||
|
|
||||||
import com.cim.idm.framework.data.EventInfo;
|
|
||||||
import com.cim.idm.wmsextend.generic.errorHandler.CustomException;
|
import com.cim.idm.wmsextend.generic.errorHandler.CustomException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -18,14 +17,4 @@ public interface QMSService {
|
|||||||
*/
|
*/
|
||||||
String PreIQCInfoSend (String receiveActNo, String siteName, String opCode, String erpFactory) throws CustomException;
|
String PreIQCInfoSend (String receiveActNo, String siteName, String opCode, String erpFactory) throws CustomException;
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调用QMS质检接口
|
|
||||||
* @param sendQMSUrl QMS质检url
|
|
||||||
* @param sendQMSJson QMS质检报文
|
|
||||||
* @return QMS返回状态码
|
|
||||||
* @throws CustomException
|
|
||||||
*/
|
|
||||||
String sendQMSByUrlJson (String sendQMSUrl,String sendQMSJson, EventInfo eventInfo) throws CustomException;
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSONArray;
|
|||||||
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import com.cim.idm.data.ErpMessageLog;
|
import com.cim.idm.data.ErpMessageLog;
|
||||||
import com.cim.idm.framework.IDMFrameServiceProxy;
|
import com.cim.idm.framework.IDMFrameServiceProxy;
|
||||||
import com.cim.idm.framework.data.EventInfo;
|
|
||||||
import com.cim.idm.framework.util.time.TimeStampUtil;
|
import com.cim.idm.framework.util.time.TimeStampUtil;
|
||||||
import com.cim.idm.service.QMSService;
|
import com.cim.idm.service.QMSService;
|
||||||
import com.cim.idm.util.MessageLogUtil;
|
import com.cim.idm.util.MessageLogUtil;
|
||||||
@ -569,41 +568,4 @@ public class QMSServiceImpl implements QMSService{
|
|||||||
return code;
|
return code;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 质检信息发送QMS
|
|
||||||
* @throws CustomException
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public String sendQMSByUrlJson(String sendQMSUrl, String sendQMSJson, EventInfo eventInfo) throws CustomException {
|
|
||||||
String httpPost = NCHttpUtil.httpPost(baseUrl + sendQMSUrl, sendQMSJson);
|
|
||||||
org.json.JSONObject jsonObject = new org.json.JSONObject(httpPost);
|
|
||||||
String code = jsonObject.getString("code");
|
|
||||||
String msg = "";
|
|
||||||
if (!"200".equals(code)) {
|
|
||||||
msg = jsonObject.getString("msg");
|
|
||||||
}
|
|
||||||
// String msg = jsonObject.getString("msg");
|
|
||||||
//JSONObject object = (JSONObject) jsonObject.get("data");
|
|
||||||
Thread t = new Thread(new Runnable(){
|
|
||||||
public void run(){
|
|
||||||
// run方法具体重写
|
|
||||||
UUID uuid = UUID.randomUUID();
|
|
||||||
ErpMessageLog erplog = new ErpMessageLog();
|
|
||||||
erplog.setEventUser("");
|
|
||||||
erplog.setServerName("WmsToQMS");
|
|
||||||
erplog.setEventName(eventInfo.getEventName());
|
|
||||||
erplog.setId(uuid.toString());
|
|
||||||
erplog.setInterfaceTime(ConvertUtil.getCurrTime("yyyy-MM-dd HH:mm:ss"));
|
|
||||||
erplog.setMessageId(UUID.randomUUID().toString());
|
|
||||||
erplog.setSendMsg(sendQMSJson);
|
|
||||||
erplog.setReturnMsg2(httpPost.toString());
|
|
||||||
erplog.setResultCode(code);
|
|
||||||
MessageLogUtil.writeMessageLog(erplog);
|
|
||||||
}});
|
|
||||||
t.start();
|
|
||||||
return msg;
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -2609,7 +2609,7 @@ public class ToSAPServiceImpl {
|
|||||||
//过账日期
|
//过账日期
|
||||||
body.put("BUDAT", budatData);
|
body.put("BUDAT", budatData);
|
||||||
//凭证日期
|
//凭证日期
|
||||||
body.put("BLDAT", budatData);
|
body.put("BLDAT", TimeStampUtil.getCurrentTime("yyyyMMdd"));
|
||||||
//凭证抬头文本
|
//凭证抬头文本
|
||||||
body.put("BKTXT", uniqueID);
|
body.put("BKTXT", uniqueID);
|
||||||
//用户名
|
//用户名
|
||||||
|
@ -15,11 +15,9 @@ import com.cim.idm.mwmsextend.materialpacking.service.MaterialPackingServiceUtil
|
|||||||
import com.cim.idm.mwmsextend.materialshiprequest.service.MaterialShipRequestServiceImpl;
|
import com.cim.idm.mwmsextend.materialshiprequest.service.MaterialShipRequestServiceImpl;
|
||||||
import com.cim.idm.service.ChargeSplitService;
|
import com.cim.idm.service.ChargeSplitService;
|
||||||
import com.cim.idm.service.InvoiceService;
|
import com.cim.idm.service.InvoiceService;
|
||||||
import com.cim.idm.service.QMSService;
|
|
||||||
import com.cim.idm.service.impl.MESServiceImpl;
|
import com.cim.idm.service.impl.MESServiceImpl;
|
||||||
import com.cim.idm.service.impl.ToSAPServiceImpl;
|
import com.cim.idm.service.impl.ToSAPServiceImpl;
|
||||||
import com.cim.idm.util.MessageLogUtil;
|
import com.cim.idm.util.MessageLogUtil;
|
||||||
import com.cim.idm.util.NCHttpUtil;
|
|
||||||
import com.cim.idm.util.ToSAPMessageUtil;
|
import com.cim.idm.util.ToSAPMessageUtil;
|
||||||
import com.cim.idm.utils.AjaxResult;
|
import com.cim.idm.utils.AjaxResult;
|
||||||
import com.cim.idm.utils.CodeGenerator;
|
import com.cim.idm.utils.CodeGenerator;
|
||||||
@ -41,9 +39,7 @@ import com.cim.idm.wmspackage.materialreceivetactdetail.management.data.Material
|
|||||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||||
import com.fasterxml.jackson.databind.JsonMappingException;
|
import com.fasterxml.jackson.databind.JsonMappingException;
|
||||||
import groovy.lang.Lazy;
|
import groovy.lang.Lazy;
|
||||||
import io.micrometer.core.instrument.util.StringUtils;
|
|
||||||
import org.apache.commons.collections4.MapUtils;
|
import org.apache.commons.collections4.MapUtils;
|
||||||
import org.quartz.SimpleTrigger;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
@ -62,8 +58,7 @@ public class InvoiceServiceImpl implements InvoiceService {
|
|||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private ToSAPServiceImpl toSAPService;
|
private ToSAPServiceImpl toSAPService;
|
||||||
@Autowired
|
|
||||||
private QMSService qmsService;
|
|
||||||
@Autowired
|
@Autowired
|
||||||
@Lazy
|
@Lazy
|
||||||
private ChargeSplitService chargeSplitService;
|
private ChargeSplitService chargeSplitService;
|
||||||
@ -3438,11 +3433,6 @@ public class InvoiceServiceImpl implements InvoiceService {
|
|||||||
// billCode=toSAPService.saleStockOut_NEW(shipRequestName, "SDK", eventUser,materialPackingKeyList);
|
// billCode=toSAPService.saleStockOut_NEW(shipRequestName, "SDK", eventUser,materialPackingKeyList);
|
||||||
billCode=saleStockOut_NEW(shipRequestName, "SDK", eventUser,materialPackingKeyList,commitDate);
|
billCode=saleStockOut_NEW(shipRequestName, "SDK", eventUser,materialPackingKeyList,commitDate);
|
||||||
untils.SaveUnDoInfo_ForSap(materialPackingKeyList, billCode, makeEventInfo);
|
untils.SaveUnDoInfo_ForSap(materialPackingKeyList, billCode, makeEventInfo);
|
||||||
//单据类型等于ZLF0-ZLF9,物料编码以7开头都属于成品胶水需要调用QMS质检接口
|
|
||||||
String message = checkShipRequestTypeSendIQC(commitDate, siteName ,shipRequestName, makeEventInfo, materialPackingKeyList);
|
|
||||||
if (StringUtils.isNotEmpty(message)) {
|
|
||||||
throw new CustomException(message);
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "08": // 委外
|
case "08": // 委外
|
||||||
case "OEM": // 委外
|
case "OEM": // 委外
|
||||||
@ -3578,99 +3568,4 @@ public class InvoiceServiceImpl implements InvoiceService {
|
|||||||
String sendData = MainData.toJSONString();
|
String sendData = MainData.toJSONString();
|
||||||
return sendData;
|
return sendData;
|
||||||
}
|
}
|
||||||
|
|
||||||
public String checkShipRequestTypeSendIQC(String shippingDate,String siteName, String shipRequestName, EventInfo eventInfo, List<String> materialPackingNameList) throws Exception {
|
|
||||||
String message = "";
|
|
||||||
JSONArray jsonArray = new JSONArray();
|
|
||||||
Map<String, JSONObject> jsonObjectMap = new HashMap<>();
|
|
||||||
String sql=" SELECT \n" +
|
|
||||||
"MP.SITENAME,\n" +
|
|
||||||
"MP.SHIPREQUESTNAME,\n" +
|
|
||||||
"MP.MATERIALSPECNAME,\n" +
|
|
||||||
"MP.MATERIALPACKINGNAME,\n" +
|
|
||||||
"MP.REMARK,\n" +
|
|
||||||
"MP.CHARGE,\n" +
|
|
||||||
"MP.SDKTRUEID,\n" +
|
|
||||||
"MS.DESC_CN\n" +
|
|
||||||
"FROM\n" +
|
|
||||||
"MATERIALPACKING MP \n" +
|
|
||||||
"LEFT JOIN MATERIALSPEC MS ON MP.SITENAME = MS.SITENAME AND MP.MATERIALSPECNAME = MS.MATERIALSPECNAME\n" +
|
|
||||||
"WHERE\n" +
|
|
||||||
"MP.SITENAME =:SITENAME\n" +
|
|
||||||
"AND MP.SHIPREQUESTNAME =:SHIPREQUESTNAME\n" +
|
|
||||||
"AND MP.MATERIALPACKINGNAME IN (:BOXLIST)\n" +
|
|
||||||
"AND MP.MATERIALSPECNAME LIKE '7%' ";
|
|
||||||
|
|
||||||
Map<String, Object> hashMap = new HashMap<String, Object>();
|
|
||||||
hashMap.put("SHIPREQUESTNAME", shipRequestName);
|
|
||||||
hashMap.put("SITENAME", siteName);
|
|
||||||
hashMap.put("BOXLIST", materialPackingNameList);
|
|
||||||
List<Map<String, Object>> queryForList = IDMFrameServiceProxy.getSqlTemplate().queryForList(sql.toString(), hashMap);
|
|
||||||
if (!queryForList.isEmpty()){
|
|
||||||
|
|
||||||
for (int i = 0; i < queryForList.size(); i++) {
|
|
||||||
String source = "wms";
|
|
||||||
String deliveryNumber = queryForList.get(i).get("SHIPREQUESTNAME") == null ? "" : queryForList.get(i).get("SHIPREQUESTNAME").toString();
|
|
||||||
String materialCode = queryForList.get(i).get("MATERIALSPECNAME") == null ? "" : queryForList.get(i).get("MATERIALSPECNAME").toString();
|
|
||||||
String materialName = queryForList.get(i).get("DESC_CN") == null ? "" : queryForList.get(i).get("DESC_CN").toString();
|
|
||||||
String specification = queryForList.get(i).get("SDKTRUEID") == null ? "" : queryForList.get(i).get("SDKTRUEID").toString();
|
|
||||||
String materialPackingName = queryForList.get(i).get("MATERIALPACKINGNAME") == null ? "" : queryForList.get(i).get("MATERIALPACKINGNAME").toString();
|
|
||||||
if (jsonObjectMap.containsKey(materialName)){
|
|
||||||
JSONObject jsonObject = jsonObjectMap.get(materialName);
|
|
||||||
String shipmentBatch = jsonObject.getString("shipmentBatch");
|
|
||||||
jsonObject.put("shipmentBatch",shipmentBatch + "," + materialPackingName);
|
|
||||||
}else {
|
|
||||||
JSONObject jsonObject = new JSONObject(true);
|
|
||||||
//必传字段
|
|
||||||
jsonObject.put("source", source);
|
|
||||||
//出货日期,取页面上的过账日期
|
|
||||||
jsonObject.put("shippingDate", shippingDate);
|
|
||||||
// 发货单号
|
|
||||||
jsonObject.put("deliveryNumber", deliveryNumber);
|
|
||||||
// 料号
|
|
||||||
jsonObject.put("materialCode", materialCode);
|
|
||||||
// 发货品名
|
|
||||||
jsonObject.put("materialName", materialName);
|
|
||||||
// 规格
|
|
||||||
jsonObject.put("specification", specification);
|
|
||||||
//发货批次号
|
|
||||||
jsonObject.put("shipmentBatch", materialPackingName);
|
|
||||||
jsonObjectMap.put(materialName, jsonObject);
|
|
||||||
//非必传字段
|
|
||||||
/**
|
|
||||||
* String inspectionNumber = queryForList.get(i).get("SHIPREQUESTNAME") == null ? "" : queryForList.get(i).get("SHIPREQUESTNAME").toString();
|
|
||||||
* String quantity = queryForList.get(i).get("MATERIALQUANTITY") == null ? "" : queryForList.get(i).get("MATERIALQUANTITY").toString();
|
|
||||||
* String inspectBatch = queryForList.get(i).get("CHARGE") == null ? "" : queryForList.get(i).get("CHARGE").toString();
|
|
||||||
* String samplingQuantity = queryForList.get(i).get("") == null ? "" : queryForList.get(i).get("").toString();
|
|
||||||
* String samplingSpecification = queryForList.get(i).get("") == null ? "" : queryForList.get(i).get("").toString();
|
|
||||||
* String remark = queryForList.get(i).get("REMARK") == null ? "" : queryForList.get(i).get("REMARK").toString();
|
|
||||||
* String materialGroup = queryForList.get(i).get("MATERIALPROCESSGROUPNAME") == null ? "" : queryForList.get(i).get("MATERIALPROCESSGROUPNAME").toString();
|
|
||||||
// 发货数量
|
|
||||||
jsonObject.put("quantity", quantity);
|
|
||||||
// 客户名称
|
|
||||||
jsonObject.put("customName", customName);
|
|
||||||
// 客户代码
|
|
||||||
jsonObject.put("customCode", customCode);
|
|
||||||
// 检验单号
|
|
||||||
jsonObject.put("inspectionNumber", inspectionNumber);
|
|
||||||
//检验批号
|
|
||||||
jsonObject.put("inspectBatch", inspectBatch);
|
|
||||||
|
|
||||||
// 抽检数量
|
|
||||||
jsonObject.put("samplingQuantity", samplingQuantity);
|
|
||||||
// 抽检规格
|
|
||||||
jsonObject.put("samplingSpecification", samplingSpecification);
|
|
||||||
// 备注
|
|
||||||
jsonObject.put("remark", remark);
|
|
||||||
// 物料组
|
|
||||||
jsonObject.put("materialGroup", materialGroup);
|
|
||||||
*/
|
|
||||||
}
|
|
||||||
}
|
|
||||||
jsonArray.addAll(jsonObjectMap.values());
|
|
||||||
String jsonArrayJSONString = jsonArray.toJSONString();
|
|
||||||
message = qmsService.sendQMSByUrlJson(jsonArrayJSONString, "/opc/addShipmentInspection",eventInfo);
|
|
||||||
}
|
|
||||||
return message;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user