(如果是JCO ver 3以上, 則必須以JcoContext.begin()與JcoContext.end()來包住兩個execute才能真正commit喔)
import lotus.domino.*;
import java.util.*;
import com.sap.mw.jco.*;
public class SAPApprove extends AgentBase {
private Session session;
private AgentContext agentContext;
private Database db;
private String sapIP,sapClient,sapAccount,sapPasswd,sapLang,sapSysNo;
private JCO.Function function;
private JCO.Function commFunct;
private JCO.Client client ;
private Log log;
private boolean isError=false;
private String errMsg="";
private String resultCode;
private String resultMsg ;
private String wgroup ;
private String ponumber ;
private JCO.Structure returnStructure;
private Document doc;
private JCO.ParameterList params;
public void init(Session session,AgentContext agentContext) throws NotesException{
try {
this.session=session;
this.agentContext=agentContext;
this.db=agentContext.getCurrentDatabase();
Document profile=db.getProfileDocument("SystemProfile",null);
sapIP=profile.getItemValueString("SAPIP");
sapClient=profile.getItemValueString("SAPClient");
sapAccount=profile.getItemValueString("SAPAccount");
sapPasswd=profile.getItemValueString("SAPPasswd");
sapLang=profile.getItemValueString("SAPCode");
sapSysNo=profile.getItemValueString("SAPSysNO");
String logPath=profile.getItemValueString("LogPath");
log = session.createLog( db.getTitle()+" 's Agent "+agentContext.getCurrentAgent().getName()+" on " + db.getServer());
log.openNotesLog(db.getServer(),logPath);
Agent agent = agentContext.getCurrentAgent();
doc = db.getDocumentByID(agent.getParameterDocID());
System.out.println("Load Profile OK.");
}catch(Exception e) {
e.printStackTrace();
try{
session.setEnvironmentVar("AgentResult","載入SAP 設定時，發生錯誤 !!");
}catch ( Exception ex){}
}
}
public void processApprove() {
boolean isok;
Item notifyitem;
try{
System.out.println("Begin JCO Connection....");
log.logAction("Begin JCO Connection....");
client = JCO.createClient(sapClient, sapAccount, sapPasswd, sapLang, sapIP, sapSysNo);
client.connect();
JCO.Repository repository = new JCO.Repository( "Notes", client );
JCO.Attributes attr = client.getAttributes();
IFunctionTemplate ftemplate = repository.getFunctionTemplate( "BAPI_ACC_ACTIVITY_ALLOC_POST" );
function = new JCO.Function( ftemplate );
params = function.getImportParameterList();
JCO.Structure structure1 = params.getStructure("DOC_HEADER");
JCO.Table table = function.getTableParameterList().getTable("DOC_ITEMS"); //it is taken from the response value of metadata
System.out.println("No of Columns: "+ table.getNumColumns());
//-----------------------------------------------------------------------------------------------------------------------------
System.out.println("Begin Load Not Procsess Documents....");
log.logAction("Begin Load Not Procsess Documents....");
if (doc != null) {
String sn="00"+doc.getItemValueString("PONumber").replaceAll("\\s+", "");
Date date = new Date();
Calendar cal = Calendar.getInstance();
cal.setTime(date);
int thismonth = cal.get(Calendar.MONTH);
int thisyear = cal.get(Calendar.YEAR);
structure1.setValue("TW00", "CO_AREA");
structure1.setValue(date, "DOCDATE");
structure1.setValue(date, "POSTGDATE");
structure1.setValue(doc.getItemValueString("DOC_HDR_TX").replaceAll("\\s+", ""), "DOC_HDR_TX");
structure1.setValue("ROOT", "USERNAME");
structure1.setValue(thismonth, "VAL_PERIOD");
structure1.setValue(thisyear, "VAL_FISYEAR");
System.out.println("Trying to execute append row");
wgroup=doc.getItemValueString("WorkGroup").replaceAll("\\s+", "");
table.appendRow(); // Add rows to internal table for OHV
table.setValue(wgroup,"SEND_CCTR");
table.setValue("OHV","ACTTYPE");
table.setValue(doc.getItemValueDouble("Amount"),"ACTVTY_QTY");
table.setValue("STD","ACTIVITYUN");
table.setValue(sn,"REC_ORDER");
table.appendRow(); // Add rows to internal table for OHF
table.setValue(wgroup,"SEND_CCTR");
table.setValue("OHF","ACTTYPE");
table.setValue(doc.getItemValueDouble("Amount"),"ACTVTY_QTY");
table.setValue("STD","ACTIVITYUN");
table.setValue(sn,"REC_ORDER");
table.appendRow(); // Add rows to internal table for LH
table.setValue(wgroup,"SEND_CCTR");
table.setValue("LH","ACTTYPE");
table.setValue(doc.getItemValueDouble("Amount"),"ACTVTY_QTY");
table.setValue("STD","ACTIVITYUN");
table.setValue(sn,"REC_ORDER");
//table.setValue(query_input_column4,new java.util.Date(query_input_column4_value));
System.out.println("Begin Process PO No: " + sn );
log.logAction("Begin ProcessPO No: " + sn );
function.getImportParameterList().setValue(structure1,"DOC_HEADER");
function.getTableParameterList().setValue(table,"DOC_ITEMS");
IFunctionTemplate ftemplate1 = repository.getFunctionTemplate( "BAPI_TRANSACTION_COMMIT" );
commFunct = new JCO.Function( ftemplate1 );
commFunct.getImportParameterList().setValue("10", "WAIT");
client.execute( function );
client.execute(commFunct);
JCO.Table returnTable1 = function.getTableParameterList().getTable("RETURN");
returnTable1.setRow(1);
String sn2 = (String)function.getExportParameterList().getValue("DOC_NO");
String sn1=returnTable1.getString("TYPE")+":"+returnTable1.getString("MESSAGE");
String ck=returnTable1.getString("TYPE");
System.out.println("FeedBack: " + sn1 );
log.logAction("FeedBack: " + sn1 );
if (ck.equals("S"))
{
System.out.println("Get Doc No: " + sn2 );
log.logAction("Get Doc No: " + sn2 );
returnStructure = (JCO.Structure)commFunct.getExportParameterList().getValue("RETURN");
String sn3=returnStructure.getString("TYPE")+":"+returnStructure.getString("MESSAGE");
System.out.println("FeedBack: " + sn3);
log.logAction("FeedBack: " + sn3);
System.out.println("Function BAPI_TRANSACTION_COMMIT executed .");
session.setEnvironmentVar("AgentResult","OK");
}
else
{
System.out.println("It's failed to create DOC....");
log.logAction("It's failedto create DOC...");
session.setEnvironmentVar("AgentResult","產生報工文件時，發生錯誤 !!");
}
log.logAction("BAPI_ACC_ACTIVITY_ALLOC_POST: " + sn);
}
}catch(java.lang.NoClassDefFoundError e){
e.printStackTrace();
try{
session.setEnvironmentVar("AgentResult","SAP 元件未安裝!!");
}catch ( Exception ex){}
}
catch(Exception e) {
e.printStackTrace();
try{
log.logError(0,e.getLocalizedMessage());
session.setEnvironmentVar("AgentResult","代理程式發生不明錯誤!!");
}catch(Exception err){}
}finally{
try{
JCO.releaseClient(client);
log.close();
}catch(Exception err){}
}
}
public void NotesMain() {
try {
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
SAPApprove sapobj=new SAPApprove();
sapobj.init(session,agentContext);
Agent agent = agentContext.getCurrentAgent();
sapobj.processApprove();
} catch(Exception e) {
e.printStackTrace();
}
}
}
