x

src/main/java/com/egolm/sso/services/material_master/MaterialMasterServiceImpl.java

@@ -9,104 +9,128 @@ import java.util.Map.Entry;
 
 import javax.jws.WebService;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import com.egolm.sso.config.XRException;
 import com.egolm.sso.services.CommonService;
 import com.egolm.sso.services.material_master.Z_MT_SD_001_MATERIAL_MASTER.HEADER_SENDING;
 import com.egolm.sso.services.material_master.Z_MT_SD_001_MATERIAL_MASTER.ITEM;
 import com.egolm.sso.services.material_master.Z_MT_SD_001_MATERIAL_MASTER.RECORD;
 import com.egolm.sso.util.DateUtil;
+import com.egolm.sso.util.FileUtil;
 import com.egolm.sso.util.StringUtil;
+import com.egolm.sso.util.XMLUtil;
 import com.google.gson.Gson;
 
 @Component
 @WebService(serviceName = "MaterialMasterService", targetNamespace = "http://material_master.sso.egolm.com", endpointInterface = "com.egolm.sso.services.material_master.MaterialMasterService")
 public class MaterialMasterServiceImpl implements MaterialMasterService {
 
+	private static Log logger = LogFactory.getLog(MaterialMasterService.class);
+	
 	@Autowired
 	JdbcTemplate jdbcTemplate;
 
 	@Autowired
 	CommonService common;
 	
+	@Value("${xmlRoot}")
+	private String xmlRoot;
+	
 	@Override
 	@Transactional
 	public void execute(Z_MT_SD_001_MATERIAL_MASTER Z_MT_SD_001_MATERIAL_MASTER) {
-		System.out.println(new Gson().toJson(Z_MT_SD_001_MATERIAL_MASTER));
 		Date now = new Date();
-		String today = DateUtil.formatDate(now, DateUtil.FMT_DATE);
-		
-		RECORD RECORD = Z_MT_SD_001_MATERIAL_MASTER.getRECORD();
-		HEADER_SENDING h = RECORD.getHEADER_SENDING();
-		String DIS_CODE = h.getKUNNR();
-		String DATUM = h.getDATUM();
-		String UZEIT = h.getUZEIT();
-		
-		List<ITEM> items = RECORD.getITEM();
-		
-		for(ITEM item : items) {
-			String GOODS_CODE = item.getMATNR();
-			Map<String, Object> goods = getGoods(DIS_CODE, GOODS_CODE);
-			if (goods == null) {
-				goods = new HashMap<>();
-			}
-			goods.put("DIS_CODE", DIS_CODE);
-			goods.put("DATUM", DateUtil.parseDate(DATUM, DateUtil.FMT_DATE));
-			goods.put("UZEIT", DateUtil.parseDate(UZEIT, DateUtil.FMT_TIME));
-			
-			goods.put("GOODS_CODE", GOODS_CODE);
-			goods.put("ROUGH_WEIGHT", Double.valueOf(item.getBRGEW()));
-			goods.put("NET_WEIGHT", Double.valueOf(item.getNTGEW()));
-			goods.put("WETGHT_UNIT", item.getGEWEI());
-			goods.put("CATEGORY_CODE", item.getPLINE());
-			goods.put("CREATION_DATE", DateUtil.parseDate(item.getERSDA(), DateUtil.FMT_DATE));
-			goods.put("LAST_CHANGE_DATE", DateUtil.parseDate(item.getLAEDA(), DateUtil.FMT_DATE));
-			goods.put("GOODS_NAME", item.getNORMT());
-			goods.put("VMSTA", item.getVMSTA());
-			goods.put("STKTYP", item.getSTKTYP());
-			goods.put("SPEC", item.getUMREZ());
-
-			goods.put("GOODS_NAME_EN", item.getNORMT_EN());
-			goods.put("AUMNG", item.getAUMNG());
-			goods.put("VRKME", item.getVRKME());
-			goods.put("BASE_UNIT", item.getMEINS());
-			goods.put("STATISTICS_UNIT", item.getSCHME());// （统计单位--》发货单位）
-			goods.put("LAENG", item.getLAENG());
-			goods.put("BREIT", item.getBREIT());
-			goods.put("HOEHE", item.getHOEHE());
-			goods.put("MEABM", item.getMEABM());
-			goods.put("LAENG_B", item.getLAENG_B());
-			goods.put("BREIT_B", item.getBREIT_B());
-			goods.put("HOEHE_B", item.getHOEHE_B());
-			goods.put("MEABM_B", item.getMEABM_B());
-			goods.put("PUBLIC", item.getPUBLIC());
-			goods.put("INTERNET", item.getINTERNET());
+		boolean isSuccess = true;
+		System.out.println(new Gson().toJson(Z_MT_SD_001_MATERIAL_MASTER));
+		String dateString = DateUtil.formatDate(now, DateUtil.FMT_DATE);
+		try {
+			RECORD RECORD = Z_MT_SD_001_MATERIAL_MASTER.getRECORD();
+			HEADER_SENDING h = RECORD.getHEADER_SENDING();
+			String DIS_CODE = h.getKUNNR();
+			String DATUM = h.getDATUM();
+			String UZEIT = h.getUZEIT();
 			
-			/*
-			goods.put("CATEGORY_NAME", "");// 品类名称
-			goods.put("PRODUCTION_LINE_CODE", "");// 产线(产地)编码
-			goods.put("PRODUCTION_LINE_NAME", "");// 产线(产地)名称
-			goods.put("MSTAV", "");// 停产标志2
-			goods.put("BARCODE", "");// 物料条码
-			goods.put("TAX_RATE", 0);// 税率
-			goods.put("GOODS_KEY", "");// 物料唯一码
-			goods.put("SEND_TIME", now);// 发送时间
-			goods.put("DIS_UPDATE_STATUS", "N");// 分销商更新结果（Y成功，N失败）
-			*/
+			List<ITEM> items = RECORD.getITEM();
 			
-			Long BATCHID = common.getNextval(today + "T_VEN_GOODS_BATCH_" + today);
-			String BATCH = today+"-"+BATCHID;
-			goods.put("TRACE_NO", "sapmaterialmaster" + DateUtil.formatDate(now, DateUtil.FMT_DATETIME));
-			goods.put("BATCH", BATCH);
-			goods.put("SEND_STATUS", "N");
+			for(ITEM item : items) {
+				String GOODS_CODE = item.getMATNR();
+				Map<String, Object> goods = getGoods(DIS_CODE, GOODS_CODE);
+				if (goods == null) {
+					goods = new HashMap<>();
+				}
+				goods.put("DIS_CODE", DIS_CODE);
+				goods.put("DATUM", DateUtil.parseDate(DATUM, DateUtil.FMT_DATE));
+				goods.put("UZEIT", DateUtil.parseDate(UZEIT, DateUtil.FMT_TIME));
+				
+				goods.put("GOODS_CODE", GOODS_CODE);
+				goods.put("ROUGH_WEIGHT", Double.valueOf(item.getBRGEW()));
+				goods.put("NET_WEIGHT", Double.valueOf(item.getNTGEW()));
+				goods.put("WETGHT_UNIT", item.getGEWEI());
+				goods.put("CATEGORY_CODE", item.getPLINE());
+				goods.put("CREATION_DATE", DateUtil.parseDate(item.getERSDA(), DateUtil.FMT_DATE));
+				goods.put("LAST_CHANGE_DATE", DateUtil.parseDate(item.getLAEDA(), DateUtil.FMT_DATE));
+				goods.put("GOODS_NAME", item.getNORMT());
+				goods.put("VMSTA", item.getVMSTA());
+				goods.put("STKTYP", item.getSTKTYP());
+				goods.put("SPEC", item.getUMREZ());
 
-			if (goods.get("ID") != null) {
-				updateGoods(goods);
-			} else {
-				insertGoods(goods);
+				goods.put("GOODS_NAME_EN", item.getNORMT_EN());
+				goods.put("AUMNG", item.getAUMNG());
+				goods.put("VRKME", item.getVRKME());
+				goods.put("BASE_UNIT", item.getMEINS());
+				goods.put("STATISTICS_UNIT", item.getSCHME());// （统计单位--》发货单位）
+				goods.put("LAENG", item.getLAENG());
+				goods.put("BREIT", item.getBREIT());
+				goods.put("HOEHE", item.getHOEHE());
+				goods.put("MEABM", item.getMEABM());
+				goods.put("LAENG_B", item.getLAENG_B());
+				goods.put("BREIT_B", item.getBREIT_B());
+				goods.put("HOEHE_B", item.getHOEHE_B());
+				goods.put("MEABM_B", item.getMEABM_B());
+				goods.put("PUBLIC", item.getPUBLIC());
+				goods.put("INTERNET", item.getINTERNET());
+				
+				/*
+				goods.put("CATEGORY_NAME", "");// 品类名称
+				goods.put("PRODUCTION_LINE_CODE", "");// 产线(产地)编码
+				goods.put("PRODUCTION_LINE_NAME", "");// 产线(产地)名称
+				goods.put("MSTAV", "");// 停产标志2
+				goods.put("BARCODE", "");// 物料条码
+				goods.put("TAX_RATE", 0);// 税率
+				goods.put("GOODS_KEY", "");// 物料唯一码
+				goods.put("SEND_TIME", now);// 发送时间
+				goods.put("DIS_UPDATE_STATUS", "N");// 分销商更新结果（Y成功，N失败）
+				*/
+				
+				Long BATCHID = common.getNextval(dateString + "T_VEN_GOODS_BATCH_" + dateString);
+				String BATCH = dateString+"-"+BATCHID;
+				goods.put("TRACE_NO", "sapmaterialmaster" + DateUtil.formatDate(now, DateUtil.FMT_DATETIME));
+				goods.put("BATCH", BATCH);
+				goods.put("SEND_STATUS", "N");
+
+				if (goods.get("ID") != null) {
+					updateGoods(goods);
+				} else {
+					insertGoods(goods);
+				}
+			}
+		} catch (Exception e) {
+			isSuccess = false;
+			throw new XRException("数据保存失败", e);
+		} finally {
+			String xmlName = Z_MT_SD_001_MATERIAL_MASTER.getClass().getSimpleName() + ".xml";
+			try {
+				String xml = XMLUtil.toXml(Z_MT_SD_001_MATERIAL_MASTER);
+				FileUtil.writeText(xmlRoot + "/sap/" + xmlName + "/" + DateUtil.formatDate(new Date(), DateUtil.FMT_DATE) + "/" + (isSuccess?"success":"error") + "/" + xmlName + "-" + common.getNextval(dateString + "T_VEN_GOODS_BATCH_" + dateString) + ".XML" , xml);
+			} catch (Exception e) {
+				throw new XRException("报文保存失败", e);
 			}
 		}
 	}

src/main/java/com/egolm/sso/util/XMLUtil.java

@@ -2,16 +2,18 @@ package com.egolm.sso.util;
 
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
+import java.io.StringWriter;
 
 import javax.xml.bind.JAXBContext;
 import javax.xml.bind.JAXBException;
+import javax.xml.bind.Marshaller;
 import javax.xml.bind.Unmarshaller;
 
 import com.egolm.sso.config.XRException;
 import com.thoughtworks.xstream.XStream;
 
 public class XMLUtil {
-
+	
 	public static <T> T toBean(String XML, Class<T> requireType) {
 		XStream xStream = new XStream();
 		XStream.setupDefaultSecurity(xStream);
@@ -35,5 +37,14 @@ public class XMLUtil {
 			throw new XRException("XML转换错误", e);
 		}
 	}
+
+	public static String toXml(Object obj) throws JAXBException {
+        StringWriter sw = new StringWriter();
+        JAXBContext context = JAXBContext.newInstance(obj.getClass());
+        Marshaller marshaller = context.createMarshaller();
+        marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);
+        marshaller.marshal(obj, sw);
+        return sw.toString();
+	}
 	
 }

src/main/resources/application-dev.yml

 wsUsername: test
 wsPassword: 78258c537d6e4d5fb210a57d05619fb6
+xmlRoot: xmlHistory
 SAP:
   NO009:
     CRON: 0 0 0 * * ?

src/main/resources/application-pro.yml

 wsUsername: schneider
 wsPassword: f14d4a80f823438a875b1924384c944c
+xmlRoot: xmlHistory
 SAP:
   NO009:
     CRON: 0 0 0 * * ?

src/main/resources/application-uat.yml

 wsUsername: test
 wsPassword: 78258c537d6e4d5fb210a57d05619fb6
+xmlRoot: xmlHistory
 SAP:
   NO009:
     CRON: 0 0 0 * * ?