Author: apatel
Date: Thu Jun 28 08:42:04 2007
New Revision: 551599
URL: http://svn.apache.org/viewvc?view=rev&rev=551599
Log:
first cut of RMA services.
Added:
ofbiz/trunk/specialpurpose/oagis/webapp/oagis/message/oagisEmailNotification.ftl
ofbiz/trunk/specialpurpose/oagis/widget/EmailOagisMessageScreens.xml
Modified:
ofbiz/trunk/specialpurpose/oagis/servicedef/services.xml
ofbiz/trunk/specialpurpose/oagis/src/org/ofbiz/oagis/OagisInventoryServices.java
ofbiz/trunk/specialpurpose/oagis/webapp/oagis/WEB-INF/controller.xml
Modified: ofbiz/trunk/specialpurpose/oagis/servicedef/services.xml
URL:
http://svn.apache.org/viewvc/ofbiz/trunk/specialpurpose/oagis/servicedef/services.xml?view=diff&rev=551599&r1=551598&r2=551599
==============================================================================
--- ofbiz/trunk/specialpurpose/oagis/servicedef/services.xml (original)
+++ ofbiz/trunk/specialpurpose/oagis/servicedef/services.xml Thu Jun 28
08:42:04 2007
@@ -104,5 +104,18 @@
<description>Receive Delivery</description>
<attribute name="returnId" mode="IN" type="String" optional="false"/>
</service>
+
+ <service name="receivePoAcknowledge" engine="java"
transaction-timeout="300"
+ location="org.ofbiz.oagis.OagisInventoryServices"
invoke="receivePoAcknowledgement" auth="false">
+ <description>Process PO Acknowledge message</description>
+ <implements service="serviceStreamInterface"/>
+ </service>
+
+ <service name="receiveRmaAcknowledge" engine="java"
transaction-timeout="300"
+ location="org.ofbiz.oagis.OagisInventoryServices"
invoke="receiveRmaAcknowledge" auth="false">
+ <description>Process RMA Acknowledge message</description>
+ <implements service="serviceStreamInterface"/>
+ </service>
+
</services>
Modified:
ofbiz/trunk/specialpurpose/oagis/src/org/ofbiz/oagis/OagisInventoryServices.java
URL:
http://svn.apache.org/viewvc/ofbiz/trunk/specialpurpose/oagis/src/org/ofbiz/oagis/OagisInventoryServices.java?view=diff&rev=551599&r1=551598&r2=551599
==============================================================================
---
ofbiz/trunk/specialpurpose/oagis/src/org/ofbiz/oagis/OagisInventoryServices.java
(original)
+++
ofbiz/trunk/specialpurpose/oagis/src/org/ofbiz/oagis/OagisInventoryServices.java
Thu Jun 28 08:42:04 2007
@@ -18,16 +18,659 @@
specific language governing permissions and limitations
under the License.
**/
+//import java.io.File;
+import java.io.InputStream;
+import java.io.OutputStream;
+
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.HashMap;
import java.util.Map;
+import java.util.List;
+import java.util.Iterator;
+import java.util.Date;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.text.ParseException;
+
+import javolution.util.FastList;
+import javolution.util.FastMap;
+
+import java.sql.Timestamp;
+import org.ofbiz.entity.GenericEntityException;
+import org.ofbiz.entity.util.EntityUtil;
+import org.ofbiz.base.util.Debug;
+import org.ofbiz.base.util.UtilDateTime;
+import org.ofbiz.base.util.UtilMisc;
+import org.ofbiz.base.util.UtilXml;
+import org.ofbiz.entity.GenericDelegator;
+import org.ofbiz.entity.GenericValue;
import org.ofbiz.service.DispatchContext;
+import org.ofbiz.service.GenericServiceException;
+import org.ofbiz.service.LocalDispatcher;
import org.ofbiz.service.ServiceUtil;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+
+
+
public class OagisInventoryServices {
public static final String module = OagisInventoryServices.class.getName();
public static Map syncInventory(DispatchContext ctx, Map context) {
+ InputStream in = (InputStream) context.get("inputStream");
+ OutputStream out = (OutputStream) context.get("outputStream");
+ GenericDelegator delegator = ctx.getDelegator();
+ LocalDispatcher dispatcher = ctx.getDispatcher();
+ //create a List for Storing error Information
+ List errorList = FastList.newInstance();
+ // create Map for service sendConfirmBod
+ Map sendConfirmBodCtx = FastMap.newInstance();
+
+ GenericValue contactMech = null;
+ GenericValue facilityContactMech=null;
+ GenericValue userLogin = null ;
+
+ String contactMechId = null;
+ String emailString = null;
+ String contactMechTypeId = null;
+ String errMsg = null;
+
+ try {
+ userLogin =
delegator.findByPrimaryKey("UserLogin",UtilMisc.toMap("userLoginId","admin"));
+ Document doc = UtilXml.readXmlDocument(in, true, "SyncInventory");
+ Element receiveInventoryElement = doc.getDocumentElement();
+ receiveInventoryElement.normalize();
+
+ Element docCtrlAreaElement =
UtilXml.firstChildElement(receiveInventoryElement, "N1:CNTROLAREA");
+ Element docSenderElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:SENDER");
+ Element docBsrElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:BSR");
+ String bsrVerb = UtilXml.childElementValue(docBsrElement,
"N2:VERB");
+ String bsrNoun = UtilXml.childElementValue(docBsrElement,
"N2:NOUN");
+ String bsrRevision = UtilXml.childElementValue(docBsrElement,
"N2:REVISION");
+ String logicalId = UtilXml.childElementValue(docSenderElement,
"N2:LOGICALID");
+
+ String component = UtilXml.childElementValue(docSenderElement,
"N2:COMPONENT");
+ String task = UtilXml.childElementValue(docSenderElement,
"N2:TASK");
+ String referenceId = UtilXml.childElementValue(docSenderElement,
"N2:REFERENCEID");
+ String confirmation = UtilXml.childElementValue(docSenderElement,
"N2:CONFIRMATION");
+ String language = UtilXml.childElementValue(docSenderElement,
"N2:LANGUAGE");
+ String codePage = UtilXml.childElementValue(docSenderElement,
"N2:CODEPAGE");
+ String authId = UtilXml.childElementValue(docSenderElement,
"N2:AUTHID");
+
+ Element dataAreaElement =
UtilXml.firstChildElement(receiveInventoryElement, "n:DATAAREA");
+ Element dataAreaSyncInventoryElement =
UtilXml.firstChildElement(dataAreaElement, "n:SYNC_INVENTORY");
+ Element dataAreaInventoryElement =
UtilXml.firstChildElement(dataAreaSyncInventoryElement, "n:INVENTORY");
+ String receivedDate =
UtilXml.childElementValue(dataAreaInventoryElement, "N1:DATETIMEANY");
+ Element dataAreaQuantityElement =
UtilXml.firstChildElement(dataAreaInventoryElement, "N1:QUANTITY");
+ String value = UtilXml.childElementValue(dataAreaQuantityElement,
"N2:VALUE");
+ String numOfDec =
UtilXml.childElementValue(dataAreaQuantityElement, "N2:NUMOFDEC");
+ String sign = UtilXml.childElementValue(dataAreaQuantityElement,
"N2:SIGN");
+ String uom = UtilXml.childElementValue(dataAreaQuantityElement,
"N2:UOM");
+ String item = UtilXml.childElementValue(dataAreaQuantityElement,
"N2:ITEM");
+ String itemStatus =
UtilXml.childElementValue(dataAreaQuantityElement, "N2:ITEMSTATUS");
+
+ double quantityAccepted ;
+ double quantityRejected ;
+
+ if ( sign.equals("+")) {
+ quantityAccepted = Double.parseDouble(value);
+ quantityRejected =0.0 ;
+ } else {
+ quantityRejected = Double.parseDouble(value);
+ quantityAccepted = 0.0;
+ }
+ //create Map for service receiveInventoryProduct
+
+ Map receiveInventoryCtx = FastMap.newInstance();
+ receiveInventoryCtx.put("productId",item);
+
receiveInventoryCtx.put("inventoryItemTypeId","NON_SERIAL_INV_ITEM");
+ receiveInventoryCtx.put("facilityId","WebStoreWarehouse");
+ receiveInventoryCtx.put("quantityAccepted",new
Double(quantityAccepted));
+ receiveInventoryCtx.put("quantityRejected",new
Double(quantityRejected));
+ receiveInventoryCtx.put("userLogin",userLogin);
+
+ //create Map for service getProductInventoryAvailable
+ Map gpiaCtx = FastMap.newInstance();
+ gpiaCtx.put("productId", item);
+
+ Timestamp timestamp = null;
+ timestamp = UtilDateTime.nowTimestamp();
+
+ //create Map for service createOagisMessageInfo
+ Date date = new Date();
+ DateFormat dateFormat = new
SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSS'Z'Z");
+
+ try{
+ date = dateFormat.parse(receivedDate);
+ } catch (ParseException e) {
+ Debug.logError(e, "Error parsing Date", module);
+ }
+ timestamp = new Timestamp(date.getTime());
+
+ Map oagisMessageInfoCtx= FastMap.newInstance();
+ oagisMessageInfoCtx.put("logicalId",logicalId);
+ oagisMessageInfoCtx.put("component",component);
+ oagisMessageInfoCtx.put("task",task);
+ oagisMessageInfoCtx.put("referenceId",referenceId);
+ oagisMessageInfoCtx.put("confirmation",confirmation);
+ oagisMessageInfoCtx.put("userLogin",userLogin);
+ oagisMessageInfoCtx.put("authId",authId);
+ oagisMessageInfoCtx.put("bsrVerb",bsrVerb);
+ oagisMessageInfoCtx.put("bsrNoun",bsrNoun);
+ oagisMessageInfoCtx.put("bsrRevision",bsrRevision);
+ oagisMessageInfoCtx.put("receivedDate",timestamp);
+
+ //create Map for service sendConfirmBod
+
+ sendConfirmBodCtx.put("logicalId",logicalId);
+ sendConfirmBodCtx.put("component",component);
+ sendConfirmBodCtx.put("task",task);
+ sendConfirmBodCtx.put("referenceId",referenceId);
+ sendConfirmBodCtx.put("userLogin",userLogin);
+
+ //create a Map for getting result of service
getProductInventoryAvailable
+ Map gpiaResult = FastMap.newInstance();
+
+ gpiaResult =
dispatcher.runSync("getProductInventoryAvailable",gpiaCtx );
+ Debug.logInfo("==============gpiaResult===== "+gpiaResult, module);
+
+ String availableToPromiseTotal =
gpiaResult.get("availableToPromiseTotal").toString();
+
+ try {
+ if (value.equals(availableToPromiseTotal) ) {
+ Debug.logInfo("==========Both Values are same
=====",module);
+ } else {
+ Map receiveInventoryProductResult = FastMap.newInstance();
+ //sevice for receiveInventoryProduct in InventoryItem
+ receiveInventoryProductResult =
dispatcher.runSync("receiveInventoryProduct",receiveInventoryCtx );
+
Debug.logInfo("==============receiveInventoryProductResult=====
"+receiveInventoryProductResult, module);
+ if(ServiceUtil.isError(receiveInventoryProductResult)){
+ errorList.add("Error Running Service
receiveInventoryProduct");
+ }
+ }
+ } catch(GenericServiceException gse) {
+ String errMessageForcreateOagisMessageInfo = "Error Running
Service receiveInventoryProduct";
+ Debug.logError(gse, errMessageForcreateOagisMessageInfo,
module);
+ }
+ try {
+ Map oagisMessageInfoResult = FastMap.newInstance();
+ //service for creating OagisMessageInfo
+ oagisMessageInfoResult =
dispatcher.runSync("createOagisMessageInfo", oagisMessageInfoCtx);
+ Debug.logInfo("==============oagisMessageInfoResult=====
"+oagisMessageInfoResult, module);
+ if(ServiceUtil.isError(oagisMessageInfoResult)){
+ errorList.add("Error Running Service
createOagisMessageInfo");
+ }
+ } catch(GenericServiceException gse) {
+ String errMessageForcreateOagisMessageInfo = "Error Running
Service createOagisMessageInfo";
+ Debug.logError(gse, errMessageForcreateOagisMessageInfo,
module);
+ }
+ //create List for Getting FacilityContactMech
+ List facilityContactMechs = FastList.newInstance();
+
+ facilityContactMechs = delegator.findByAnd("FacilityContactMech",
UtilMisc.toMap("facilityId", "WebStoreWarehouse"));
+ Iterator fcmIter = facilityContactMechs.iterator();
+ while(fcmIter.hasNext()) {
+ facilityContactMech = (GenericValue) fcmIter.next();
+ contactMechId = facilityContactMech.getString("contactMechId");
+ contactMech = delegator.findByPrimaryKey("ContactMech",
UtilMisc.toMap("contactMechId", contactMechId));
+ contactMechTypeId = contactMech.getString("contactMechTypeId");
+ if (contactMechTypeId.equals("EMAIL_ADDRESS")) {
+ emailString = contactMech.getString("infoString");
+ }
+ }
+ //create Map for availableToPromiseTotal
+ Map atptMap = FastMap.newInstance();
+ atptMap.put("qoh", availableToPromiseTotal);
+ //create Map for getting value of ProductStoreEmailSetting
+ GenericValue psesMap = null;
+ psesMap =
delegator.findByPrimaryKey("ProductStoreEmailSetting",
UtilMisc.toMap("productStoreId", "9001", "emailType", "PRDS_OAGIS_CONFIRM"));
+
+ if(psesMap.get("bodyScreenLocation") != null) {
+ //create a Map for services sendMailFromScreen
+ Map notifyCtx = FastMap.newInstance();
+ String fromAddress = psesMap.getString("fromAddress");
+ notifyCtx.put("sendFrom", fromAddress);
+ String ccAddress = psesMap.getString("ccAddress");
+ notifyCtx.put("sendCc", ccAddress);
+ String bccAddress = psesMap.getString("bccAddress");
+ notifyCtx.put("sendBcc", bccAddress);
+ String contentType = psesMap.getString("contentType");
+ notifyCtx.put("contentType", contentType);
+ String subject = psesMap.getString("subject");
+ notifyCtx.put("subject", subject);
+ String bodyScreenUri = psesMap.getString("bodyScreenLocation");
+ notifyCtx.put("bodyScreenUri", bodyScreenUri);
+ Map bodyParameters = FastMap.newInstance();
+ bodyParameters.put("atptMap", atptMap);
+ notifyCtx.put("bodyParameters", bodyParameters);
+ notifyCtx.put("sendTo", emailString);
+ //service for sending emailNotification
+ dispatcher.runSync("sendMailFromScreen", notifyCtx);
+ }
+ } catch (Exception e) {
+ String errMessageReceiveInventoryProduct = "Error During Entity
Interaction ";
+ Debug.logError(e, errMessageReceiveInventoryProduct, module);
+ errorList.add("Error During Entity Interaction");
+ }
+ StringBuffer successString = new StringBuffer();
+ if (errorList.size() > 0) {
+ Iterator errorListIter = errorList.iterator();
+ while (errorListIter.hasNext()) {
+ String errorMsg = (String) errorListIter.next();
+ successString.append(errorMsg);
+ if (errorListIter.hasNext()) {
+ successString.append(", ");
+ }
+ }
+ try {
+ if(successString.length() > 0){
+ //send confirm bod
+ Map scbCtx = FastMap.newInstance();
+ scbCtx =
dispatcher.runSync("sendConfirmBod",sendConfirmBodCtx );
+ Debug.logInfo("==========scbCtx======"+ scbCtx,module);
+ }
+ } catch(GenericServiceException gse) {
+ String errMessageForsendConfirmBod = gse.getMessage();
+ Debug.logError(gse, errMessageForsendConfirmBod, module);
+ }
+ }
+ return ServiceUtil.returnError("Service not Implemented");
+ }
+ public static Map receivePoAcknowledgement(DispatchContext ctx, Map
context) {
+ InputStream in = (InputStream) context.get("inputStream");
+ OutputStream out = (OutputStream) context.get("outputStream");
+ LocalDispatcher dispatcher = ctx.getDispatcher();
+ GenericDelegator delegator = ctx.getDelegator();
+ // GenericValue userLogin = (GenericValue) context.get("userLogin");
+ List errorList = FastList.newInstance();
+
+ Map sendConfirmBodCtx = FastMap.newInstance();
+
+ try {
+ GenericValue userLogin = delegator.findByPrimaryKey("UserLogin",
UtilMisc.toMap("userLoginId", "admin"));
+
+ // parse the message
+ Document doc = UtilXml.readXmlDocument(in, true,
"ReceivePoAcknowledge");
+ Element receivePoElement = doc.getDocumentElement();
+ receivePoElement.normalize();
+
+ Element docCtrlAreaElement =
UtilXml.firstChildElement(receivePoElement, "N1:CNTROLAREA");
+ Element docSenderElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:SENDER");
+ Element docBsrElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:BSR");
+
+ String bsrVerb = UtilXml.childElementValue(docBsrElement,
"N2:VERB");
+ String bsrNoun = UtilXml.childElementValue(docBsrElement,
"N2:NOUN");
+ String bsrRevision = UtilXml.childElementValue(docBsrElement,
"N2:REVISION");
+ String logicalId = UtilXml.childElementValue(docSenderElement,
"N2:LOGICALID");
+ String component = UtilXml.childElementValue(docSenderElement,
"N2:COMPONENT");
+ String task = UtilXml.childElementValue(docSenderElement,
"N2:TASK");
+ String referenceId = UtilXml.childElementValue(docSenderElement,
"N2:REFERENCEID");
+ String confirmation = UtilXml.childElementValue(docSenderElement,
"N2:CONFIRMATION");
+ String language = UtilXml.childElementValue(docSenderElement,
"N2:LANGUAGE");
+ String codePage = UtilXml.childElementValue(docSenderElement,
"N2:CODEPAGE");
+ String authId = UtilXml.childElementValue(docSenderElement,
"N2:AUTHID");
+
+ Element dataAreaElement =
UtilXml.firstChildElement(receivePoElement, "n:DATAAREA");
+ Element acknowledgeDeliveryElement =
UtilXml.firstChildElement(dataAreaElement, "n:ACKNOWLEDGE_DELIVERY");
+ Element receiptHdrElement =
UtilXml.firstChildElement(acknowledgeDeliveryElement, "n:RECEIPTHDR");
+ Element qtyElement = UtilXml.firstChildElement(receiptHdrElement,
"N1:QUANTITY");
+
+ String itemQty = UtilXml.childElementValue(qtyElement, "N2:VALUE");
+ String sign = UtilXml.childElementValue(qtyElement, "N2:SIGN");
+ String productId = UtilXml.childElementValue(receiptHdrElement,
"N2:ITEM");
+ String receivedDate = UtilXml.childElementValue(receiptHdrElement,
"N1:DATETIME");
+
+ Element invDetailElement =
UtilXml.firstChildElement(receiptHdrElement, "n:INVDETAIL");
+
+ String serialNumber = UtilXml.childElementValue(invDetailElement,
"N2:SERIALNUM");
+
+ Element documentRefElement =
UtilXml.firstChildElement(receiptHdrElement, "N1:DOCUMNTREF");
+ String orderTypeId = UtilXml.childElementValue(documentRefElement,
"N2:DOCTYPE");
+ String orderId = UtilXml.childElementValue(documentRefElement,
"N2:DOCUMENTID");
+ String lineNum = UtilXml.childElementValue(documentRefElement,
"N2:LINENUM");
+
+ // prepare map to create inventory against PO
+ Map cipCtx = new HashMap();
+ String inventoryItemTypeId = null;
+ if (serialNumber.length() == 0) {
+ inventoryItemTypeId = "NON_SERIAL_INV_ITEM";
+ }
+ else {
+ inventoryItemTypeId = "SERIALIZED_INV_ITEM";
+ cipCtx.put("serialNumber", serialNumber);
+ }
+ // sign handling for items
+ double quantityAccepted = 0.0;
+ double quantityRejected = 0.0;
+ if (sign.equals("+")) {
+ quantityAccepted = Double.parseDouble(itemQty);
+ quantityRejected= 0.0;
+ } else {
+ quantityRejected = Double.parseDouble(itemQty);
+ quantityAccepted = 0.0;
+ }
+ //prepare Map for receiveInventoryProduct
+ cipCtx.put("facilityId", "WebStoreWarehouse");
+ cipCtx.put("productId", productId);
+ cipCtx.put("inventoryItemTypeId", inventoryItemTypeId);
+ cipCtx.put("quantityAccepted", new Double(quantityAccepted));
+ cipCtx.put("quantityRejected", new Double(quantityRejected));
+ cipCtx.put("userLogin", userLogin);
+ cipCtx.put("orderId", orderId);
+ Map riResult = null;
+ Map comiResult = null;
+
+ try {
+ Debug.logInfo("==========riResult======" ,module);
+ riResult = dispatcher.runSync("receiveInventoryProduct",
cipCtx);
+ Debug.logInfo("==========riResult======"+ riResult ,module);
+ } catch (GenericServiceException gse) {
+ if(ServiceUtil.isError(riResult)){
+ errorList.add("Error running method
receiveInventoryProduct");
+ }
+ String errMessageForreceiveInventoryProduct = gse.getMessage();
+ Debug.logError(gse, errMessageForreceiveInventoryProduct,
module);
+ }
+ //prepare Map for ConfirmBod Service
+ sendConfirmBodCtx.put("logicalId",logicalId);
+ sendConfirmBodCtx.put("component",component);
+ sendConfirmBodCtx.put("task",task);
+ sendConfirmBodCtx.put("referenceId",referenceId);
+ sendConfirmBodCtx.put("userLogin",userLogin);
+ sendConfirmBodCtx.put("confirmation", confirmation);
+
+ // prepare map to store BOD information
+ Map comiCtx = new HashMap();
+
+ Date date = new Date();
+ Timestamp timestamp;
+ DateFormat dateFormat = new
SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSS'Z'Z");
+
+ try{
+ date = dateFormat.parse(receivedDate);
+ } catch (ParseException e) {
+ Debug.logError(e, "Error parsing Date", module);
+ }
+ timestamp = new Timestamp(date.getTime());
+
+ comiCtx.put("logicalId", logicalId);
+ comiCtx.put("authId", authId);
+ comiCtx.put("referenceId", referenceId);
+ comiCtx.put("receivedDate", timestamp);
+ comiCtx.put("component", component);
+ comiCtx.put("task", task);
+ comiCtx.put("outgoingMessage", "N");
+ comiCtx.put("confirmation", confirmation);
+ comiCtx.put("bsrVerb", bsrVerb);
+ comiCtx.put("bsrNoun", bsrNoun);
+ comiCtx.put("bsrRevision", bsrRevision);
+ comiCtx.put("orderId", orderId);
+ comiCtx.put("userLogin", userLogin);
+ try {
+ comiResult = dispatcher.runSync("createOagisMessageInfo",
comiCtx);
+ Debug.logInfo("==========comiResult======"+ comiResult
,module);
+ } catch (GenericServiceException gse) {
+
+ if(ServiceUtil.isError(riResult)){
+ errorList.add("Error running method
createOagisMessageInfo");
+ }
+ String errMessageForcreateOagisMessageInfo = gse.getMessage();
+ Debug.logError(gse, errMessageForcreateOagisMessageInfo,
module);
+ }
+ } catch (Exception e) {
+ String errMessageReceiveInventoryProduct = e.getMessage();
+ Debug.logError(e, errMessageReceiveInventoryProduct, module);
+ errorList.add("Error During Entity Interaction");
+ }
+ StringBuffer successString = new StringBuffer();
+ if (errorList.size() > 0) {
+ Iterator errorListIter = errorList.iterator();
+ while (errorListIter.hasNext()) {
+ String errorMsg = (String) errorListIter.next();
+ successString.append(errorMsg);
+ if (errorListIter.hasNext()) {
+ successString.append(", ");
+ }
+ }
+ try {
+ if(successString.length() > 0){
+ //send confirm bod
+ Map scbCtx = FastMap.newInstance();
+ scbCtx =
dispatcher.runSync("sendConfirmBod",sendConfirmBodCtx );
+ Debug.logInfo("==========scbCtx======"+ scbCtx,module);
+ }
+ } catch(GenericServiceException gse) {
+ String errMessageForsendConfirmBod = gse.getMessage();
+ Debug.logError(gse, errMessageForsendConfirmBod, module);
+ }
+ }
+ return ServiceUtil.returnError("Error in Processing");
+ }
+
+ public static Map receiveRmaAcknowledge(DispatchContext ctx, Map context) {
+ InputStream in = (InputStream) context.get("inputStream");
+ OutputStream out = (OutputStream) context.get("outputStream");
+ LocalDispatcher dispatcher = ctx.getDispatcher();
+ GenericDelegator delegator = ctx.getDelegator();
+ // GenericValue userLogin = (GenericValue) context.get("userLogin");
+ List errorList = FastList.newInstance();
+ //Map for confirmBod service
+ Map sendConfirmBodCtx = FastMap.newInstance();
+
+ try {
+ GenericValue userLogin = delegator.findByPrimaryKey("UserLogin",
UtilMisc.toMap("userLoginId", "admin"));
+
+ // parse the message
+ Document doc = UtilXml.readXmlDocument(in, true,
"receiveRmaAcknowledge");
+ Element receivePoElement = doc.getDocumentElement();
+ receivePoElement.normalize();
+ Element docCtrlAreaElement =
UtilXml.firstChildElement(receivePoElement, "N1:CNTROLAREA");
+ Element docSenderElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:SENDER");
+ Element docBsrElement =
UtilXml.firstChildElement(docCtrlAreaElement, "N1:BSR");
+
+ String bsrVerb = UtilXml.childElementValue(docBsrElement,
"N2:VERB");
+ String bsrNoun = UtilXml.childElementValue(docBsrElement,
"N2:NOUN");
+ String bsrRevision = UtilXml.childElementValue(docBsrElement,
"N2:REVISION");
+
+ String logicalId = UtilXml.childElementValue(docSenderElement,
"N2:LOGICALID");
+ String component = UtilXml.childElementValue(docSenderElement,
"N2:COMPONENT");
+ String task = UtilXml.childElementValue(docSenderElement,
"N2:TASK");
+ String referenceId = UtilXml.childElementValue(docSenderElement,
"N2:REFERENCEID");
+ String confirmation = UtilXml.childElementValue(docSenderElement,
"N2:CONFIRMATION");
+ String language = UtilXml.childElementValue(docSenderElement,
"N2:LANGUAGE");
+ String codePage = UtilXml.childElementValue(docSenderElement,
"N2:CODEPAGE");
+ String authId = UtilXml.childElementValue(docSenderElement,
"N2:AUTHID");
+
+ Element dataAreaElement =
UtilXml.firstChildElement(receivePoElement, "n:DATAAREA");
+ Element acknowledgeDeliveryElement =
UtilXml.firstChildElement(dataAreaElement, "n:ACKNOWLEDGE_DELIVERY");
+ Element receiptHdrElement =
UtilXml.firstChildElement(acknowledgeDeliveryElement, "n:RECEIPTHDR");
+ Element qtyElement = UtilXml.firstChildElement(receiptHdrElement,
"N1:QUANTITY");
+
+ String itemQty = UtilXml.childElementValue(qtyElement, "N2:VALUE");
+ String sign = UtilXml.childElementValue(qtyElement, "N2:SIGN");
+ String sku = UtilXml.childElementValue(receiptHdrElement,
"N2:ITEM");
+ String receivedDate = UtilXml.childElementValue(receiptHdrElement,
"N1:DATETIME");
+
+ Element invDetailElement =
UtilXml.firstChildElement(receiptHdrElement, "n:INVDETAIL");
+
+ String serialNumber = UtilXml.childElementValue(invDetailElement,
"N2:SERIALNUM");
+ String invItemStatus =
UtilXml.childElementValue(receiptHdrElement, "N2:DISPOSITN");
+
+ Element documentRefElement =
UtilXml.firstChildElement(receiptHdrElement, "N1:DOCUMNTREF");
+
+ String orderTypeId = UtilXml.childElementValue(documentRefElement,
"N2:DOCTYPE");
+ String returnId = UtilXml.childElementValue(documentRefElement,
"N2:DOCUMENTID");
+ String lineNum = UtilXml.childElementValue(documentRefElement,
"N2:LINENUM");
+
+ GenericValue returnHeader = null;
+
+ //Map Declaration
+ Map urhCtx = new HashMap();
+ Map comiCtx = new HashMap();
+ Map cipCtx = new HashMap();
+ Map urhResult = null;
+
+ String orderId = null;
+
+ if (returnId != null) {
+ returnHeader = delegator.findByPrimaryKey("ReturnHeader",
UtilMisc.toMap("returnId", returnId));
+ if
(returnHeader.getString("statusId").equals("RETURN_ACCEPTED")) {
+ urhCtx.put("returnId", returnId);
+ urhCtx.put("statusId", "RETURN_COMPLETED");
+ urhCtx.put("userLogin", userLogin);
+ try {
+ urhResult = dispatcher.runSync("updateReturnHeader",
urhCtx);
+ Debug.logInfo("==============urhResult===== " +
urhResult, module);
+
+ } catch (GenericServiceException gse) {
+ if(ServiceUtil.isError(urhResult)) {
+ errorList.add("Error running method
receiveInventoryProduct");
+ Debug.logInfo("==========urhResult======"+
urhResult, module);
+ }
+ String errMessageForcreateOagisMessageInfo = "Error
Running Service sendConfirmBod";
+ Debug.logError(gse,
errMessageForcreateOagisMessageInfo, module);
+ }
+ GenericValue returnItem =
EntityUtil.getFirst(delegator.findByAnd("ReturnItem",
UtilMisc.toMap("returnId", returnId)));
+ orderId = returnItem.getString("orderId");
+ }
+ }
+ String inventoryItemTypeId = null;
+ if (serialNumber.length() == 0) {
+ inventoryItemTypeId = "NON_SERIAL_INV_ITEM";
+ }
+ else {
+
+ inventoryItemTypeId = "SERIALIZED_INV_ITEM";
+ cipCtx.put("serialNumber", serialNumber);
+ }
+ // sign handling for items
+ double quantityAccepted = 0.0;
+ double quantityRejected = 0.0;
+ if (sign.equals("+")) {
+ quantityAccepted = Double.parseDouble(itemQty);
+ quantityRejected= 0.0;
+ } else {
+ quantityRejected = Double.parseDouble(itemQty);
+ quantityAccepted = 0.0;
+ }
+ GenericValue inventoryItem = null;
+ inventoryItem =
EntityUtil.getFirst(delegator.findByAnd("InventoryItem",
UtilMisc.toMap("serialNumber", serialNumber)));
+ Debug.logInfo("==============inventoryItem===== " + inventoryItem
, module);
+ String productId = inventoryItem.getString("productId");
+ if (productId.compareTo(sku) != 0) {
+ productId = sku;
+ }
+ if ( invItemStatus.equals("ReceivedTOAvailable") ||
invItemStatus.equals("NotAvailableTOAvailable")) {
+ cipCtx.put("statusId", "INV_AVAILABLE");
+ } else if ( invItemStatus.equals("ReceivedTONotAvailable") ||
invItemStatus.equals("AvailableTONotAvailable") ) {
+ cipCtx.put("statusId", "INV_ON_HOLD");
+ }
+
+ // prepare Map for ConfirmBod Service
+ sendConfirmBodCtx.put("logicalId",logicalId);
+ sendConfirmBodCtx.put("component",component);
+ sendConfirmBodCtx.put("task",task);
+ sendConfirmBodCtx.put("referenceId",referenceId);
+ sendConfirmBodCtx.put("userLogin",userLogin);
+
+ //prepare MAp for receiveInventoryProduct service
+ String facilityId = "WebStoreWarehouse";
+ String locationSeqId = "FAC_AVNET_AZ";
+ cipCtx.put("facilityId", facilityId);
+ cipCtx.put("locationSeqId", locationSeqId);
+ cipCtx.put("productId", productId);
+ cipCtx.put("inventoryItemTypeId", inventoryItemTypeId);
+ cipCtx.put("quantityAccepted", new Double(quantityAccepted));
+ cipCtx.put("quantityRejected", new Double(quantityRejected));
+ cipCtx.put("userLogin", userLogin);
+ cipCtx.put("ownerPartyId", "DemoCustomer");
+ Map riResult = null;
+ Map comiResult = null;
+
+ try {
+ riResult = dispatcher.runSync("receiveInventoryProduct",
cipCtx);
+ Debug.logInfo("==========riResult======"+ riResult, module);
+ } catch (GenericServiceException gse) {
+
+ if(ServiceUtil.isError(riResult)){
+ errorList.add("Error running method
receiveInventoryProduct");
+ }
+ String errMessageForreceiveInventoryProduct = gse.getMessage();
+ Debug.logError(gse, errMessageForreceiveInventoryProduct,
module);
+ }
+
+ // prepare map to store BOD informatio
+ Date date = new Date();
+ Timestamp timestamp=null;
+ DateFormat dateFormat = new
SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSS'Z'Z");
+
+ try{
+ date = dateFormat.parse(receivedDate);
+ } catch (ParseException e) {
+ Debug.logError(e, "Error parsing Date", module);
+ }
+
+ timestamp = new Timestamp(date.getTime());
+
+ comiCtx.put("logicalId", logicalId);
+ comiCtx.put("authId", authId);
+ comiCtx.put("referenceId", referenceId);
+ comiCtx.put("receivedDate", timestamp);
+ comiCtx.put("component", component);
+ comiCtx.put("task", task);
+ comiCtx.put("outgoingMessage", "N");
+ comiCtx.put("confirmation", confirmation);
+ comiCtx.put("bsrVerb", bsrVerb);
+ comiCtx.put("bsrNoun", bsrNoun);
+ comiCtx.put("bsrRevision", bsrRevision);
+ comiCtx.put("processingStatusId", "RETURN_COMPLETED");
+ comiCtx.put("returnId", returnId);
+ comiCtx.put("orderId", orderId);
+ comiCtx.put("userLogin", userLogin);
+ try {
+ comiResult = dispatcher.runSync("createOagisMessageInfo",
comiCtx);
+ Debug.logInfo("==========result======"+ comiResult,
module);
+
+ } catch (GenericServiceException gse) {
+ if(ServiceUtil.isError(comiResult)){
+ errorList.add("Error running method
createOagisMessageInfo");
+ }
+ String errMessageForcreateOagisMessageInfo = gse.getMessage();
+ Debug.logError(gse, errMessageForcreateOagisMessageInfo,
module);
+ }
+ } catch (Exception e) {
+ String errMessage = e.getMessage();
+ Debug.logError(e, errMessage, module);
+ errorList.add("Error During Entity Interaction");
+ }
+
+ StringBuffer successString = new StringBuffer();
+ if (errorList.size() > 0) {
+ Iterator errorListIter = errorList.iterator();
+ while (errorListIter.hasNext()) {
+ String errorMsg = (String) errorListIter.next();
+ successString.append(errorMsg);
+ if (errorListIter.hasNext()) {
+ successString.append(", ");
+ }
+ }
+ try {
+ if(successString.length() > 0){
+ //send confirm bod
+ Map scbCtx = FastMap.newInstance();
+ scbCtx =
dispatcher.runSync("sendConfirmBod",sendConfirmBodCtx );
+ Debug.logInfo("==========scbCtx======"+ scbCtx,module);
+ }
+ } catch(GenericServiceException gse) {
+ String errMessageForsendConfirmBod = gse.getMessage();
+ Debug.logError(gse, errMessageForsendConfirmBod, module);
+ }
+ }
return ServiceUtil.returnError("Service not Implemented");
}
-}
\ No newline at end of file
+}
Modified: ofbiz/trunk/specialpurpose/oagis/webapp/oagis/WEB-INF/controller.xml
URL:
http://svn.apache.org/viewvc/ofbiz/trunk/specialpurpose/oagis/webapp/oagis/WEB-INF/controller.xml?view=diff&rev=551599&r1=551598&r2=551599
==============================================================================
--- ofbiz/trunk/specialpurpose/oagis/webapp/oagis/WEB-INF/controller.xml
(original)
+++ ofbiz/trunk/specialpurpose/oagis/webapp/oagis/WEB-INF/controller.xml Thu
Jun 28 08:42:04 2007
@@ -198,6 +198,19 @@
<event type="stream" invoke="syncInventory"/>
<response name="success" type="none"/>
</request-map>
+
+ <request-map uri="receivePoAcknowledge">
+ <security https="true" auth="false"/>
+ <event type="stream" invoke="receivePoAcknowledge"/>
+ <response name="success" type="none"/>
+ </request-map>
+
+ <request-map uri="receiveRmaAcknowledge">
+ <security https="true" auth="false"/>
+ <event type="stream" invoke="receiveRmaAcknowledge"/>
+ <response name="success" type="none"/>
+ </request-map>
+
<!-- end of request mappings -->
Added:
ofbiz/trunk/specialpurpose/oagis/webapp/oagis/message/oagisEmailNotification.ftl
URL:
http://svn.apache.org/viewvc/ofbiz/trunk/specialpurpose/oagis/webapp/oagis/message/oagisEmailNotification.ftl?view=auto&rev=551599
==============================================================================
---
ofbiz/trunk/specialpurpose/oagis/webapp/oagis/message/oagisEmailNotification.ftl
(added)
+++
ofbiz/trunk/specialpurpose/oagis/webapp/oagis/message/oagisEmailNotification.ftl
Thu Jun 28 08:42:04 2007
@@ -0,0 +1,17 @@
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+<html xmlns="http://www.w3.org/1999/xhtml";>
+ <head>
+ <title>Oagis Recieve Inventory Email Notification</title>
+ <meta http-equiv="content-type" content="text/html;
charset=iso-8859-1">
+
+ </head>
+ <body>
+ <div class="email_wrapper">
+ <p>
+ <a href="#">Available Quantity On Hand </a>
+ </p>
+ <div style="clear:both">${atptMap?if_exists}</div>
+ <div style="height:600px"></div>
+ </div>
+ </body>
+</html>
Added: ofbiz/trunk/specialpurpose/oagis/widget/EmailOagisMessageScreens.xml
URL:
http://svn.apache.org/viewvc/ofbiz/trunk/specialpurpose/oagis/widget/EmailOagisMessageScreens.xml?view=auto&rev=551599
==============================================================================
--- ofbiz/trunk/specialpurpose/oagis/widget/EmailOagisMessageScreens.xml (added)
+++ ofbiz/trunk/specialpurpose/oagis/widget/EmailOagisMessageScreens.xml Thu
Jun 28 08:42:04 2007
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+-->
+<screens xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
xsi:noNamespaceSchemaLocation="http://ofbiz.apache.org/dtds/widget-screen.xsd";>
+ <screen name="EmailOagisMessageNotification">
+ <section>
+ <widgets>
+ <platform-specific>
+ <html>
+ <html-template
location="component://oagis/webapp/oagis//message/oagisEmailNotification.ftl"/>
+ </html>
+ </platform-specific>
+ </widgets>
+ </section>
+ </screen>
+
+</screens>
