Step 1. 自建定制P6 WebService服务

Step 2. C#调用P6定制 WebService服务

近日应一个朋友的邀请提供c#调用p6 webservice的案例，无奈自己已很多年没碰过C#，上一个与此有关的项目还发生在中国人民抗日战争暨世界反法西斯战争胜利70周年，想想还是翻出了自己多年前用VisualStudio写的demo，由此整理出本文。

本文内容比较简单且核心内容也已包含，结合自己的理解只要简单修改即可运行 ...

PS：我当时使用的P6版本是 Primavera P6 EPPM R15.1, 非常经典的一个发行版

在使用C#调用P6 WebService前，你需要了解P6本身的一些特征

从开发语言来讲, Primavera 以Java为主的Web开发体系.

Web Service遵守标准规范, 可以跨开发语言调用: net/Java/Pythson etc

Primavera用到一些Java技术体系中的开源的库/组件/框架

因为P6本身Webservicef帆布的方法及用户的特殊需求，不得不使用原生功能重新发布了定制版的服务，所以以下开发的流程或有许些不同

Step 1. 自建定制P6 WebService服务

使用IntegrationAPI JAVA 编制P6对外发布的WebService服务（PS: 业务Java工程师多年前整的一个，请忽略架构是否先进）

以下是几个核心的文件内容

配置config.property

apiServerIp = 192.168.1.251
apiServerPort = 9099
username = admin
password = admin

配置applicationContext.xml，

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:p="http://www.springframework.org/schema/p"xmlns:jaxws="http://cxf.apache.org/jaxws"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"><import resource="classpath:META-INF/cxf/cxf.xml" /><import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" /><import resource="classpath:META-INF/cxf/cxf-servlet.xml" /><bean id="ws" class="com.campin.tmws.server.service.WebServiceImpl" /><jaxws:endpoint implementor="#ws" address="/activity"><!-- 配置2个服务端soap IN拦截器 --><jaxws:inInterceptors><bean class="org.apache.cxf.interceptor.LoggingInInterceptor" /><bean class="com.cnpec.tmws.server.MyAuthInterceptor" /></jaxws:inInterceptors><!-- 配置soap out拦截器 --><!-- <jaxws:outInterceptors></jaxws:outInterceptors> --></jaxws:endpoint>
</beans>

Inteface类就不介绍，重点是重写实现 WebServiceImpl

package com.campin.tmws.server.service;import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;import javax.jws.WebService;import org.apache.log4j.Logger;import com.campin.tmws.server.bean.ActivityDetail;
import com.campin.tmws.server.bean.NewActivity;
import com.campin.tmws.server.bean.NewActivityCodeAssignment;
import com.campin.tmws.server.bean.NewActivityStep;
import com.campin.tmws.server.bean.NewProject;
import com.campin.tmws.server.bean.NewProjectDocument;
import com.campin.tmws.util.ReadConfigFile;
import com.primavera.common.value.ObjectId;
import com.primavera.integration.client.EnterpriseLoadManager;
import com.primavera.integration.client.RMIURL;
import com.primavera.integration.client.Session;
import com.primavera.integration.client.bo.BOIterator;
import com.primavera.integration.client.bo.object.Activity;
import com.primavera.integration.client.bo.object.ActivityCodeAssignment;
import com.primavera.integration.client.bo.object.OBS;
import com.primavera.integration.client.bo.object.Project;
import com.primavera.integration.client.bo.object.ActivityStep;
import com.primavera.integration.client.bo.object.Relationship;
import com.primavera.integration.client.bo.object.User;
import com.primavera.integration.client.bo.object.UserOBS;
import com.primavera.integration.client.bo.object.ProjectDocument;
import com.primavera.integration.common.DatabaseInstance;/*** * @ClassName: WebServiceImpl* @Description: TODO* @author Raining Campin Chou* @date 2015年11月02日* */
@WebService(endpointInterface = "com.campin.tmws.server.service.WebServiceInterface", serviceName = "WebServiceImpl", targetNamespace = "http://tmws.campin.com/Primavera/P6/TMWS")
public class WebServiceImpl implements WebServiceInterface {private String uname = ""; // 链接 p6 用户名private String password = ""; // 链接 p6 密码private String apiserverip = ""; // 链接 p6服务器 ip 信息private int apiserverport = 0; // 链接 p6api服务端口static Logger logger = Logger.getLogger(WebServiceImpl.class);public WebServiceImpl() {ReadConfigFile rcf = new ReadConfigFile();rcf.read();this.uname = rcf.getUsername();this.password = rcf.getPassword();this.apiserverip = rcf.getApiserverip();this.apiserverport = rcf.getApiserverport();}/*** @Title: getActivity * @Description: TODO* @param @param activityObjectId* @param @return * @return NewActivity* @throws*/public NewActivity getActivity(Integer activityObjectId) {NewActivity nactv = new NewActivity();String sWhereClause = "ObjectId =" + activityObjectId;Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] actvfields = new Activity(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<Activity> actvIter = elm.loadActivities(actvfields, sWhereClause, null);if (actvIter.hasNext()) {Activity actv = actvIter.next();nactv.setProjectId(actv.getProjectId());nactv.setProjectName(actv.getProjectName());nactv.setWBSCode(actv.getWBSCode());nactv.setWBSName(actv.getWBSName());nactv.setObjectId(actv.getObjectId().toInteger());nactv.setId(actv.getId());nactv.setName(actv.getName());// 工程公司非实际完成百分比，初定定为工期完成百分比nactv.setPercentComplete(new DecimalFormat("######0.000").format((actv.getPhysicalPercentComplete().doubleValue())));if (actv.getPlannedStartDate() != null) {nactv.setPlannedStartDate(actv.getPlannedStartDate().toString().substring(0, 10));}if (actv.getPlannedFinishDate() != null) {nactv.setPlannedFinishDate(actv.getPlannedFinishDate().toString().substring(0, 10));}if (actv.getActualStartDate() != null) {nactv.setActualStartDate(actv.getActualStartDate().toString().substring(0, 10));}if (actv.getActualFinishDate() != null) {nactv.setActualFinishDate(actv.getActualFinishDate().toString().substring(0, 10));}if (actv.getRemainingEarlyStartDate() != null && actv.getRemainingEarlyFinishDate() != null) {nactv.setRemainDay((int) ((actv.getRemainingEarlyFinishDate().getTime() - actv.getRemainingEarlyStartDate().getTime()) / (1000 * 24 * 60 * 60)) + 1);} else {nactv.setRemainDay(0);}}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return nactv;}/*** @Title: getAllActivities * @Description: TODO* @param @param username* @param @param key* @param @param projid* @param @return * @return List<NewActivity>* @throws*/@SuppressWarnings("static-access")public List<NewActivity> getAllActivities(String username, String key, Integer projid) {List<NewActivity> list = new ArrayList<NewActivity>();/*** 分多种情况组合筛选条件 1 初始化过滤作业状态和作业类型 2 过滤项目 / 项目分组 ， 一次性只能过滤查看一个项目 3* 过滤关键字，包括作业名称和作业代码*/String sWhereClause = "Status = 'In Progress'";sWhereClause += " AND Type in('Task Dependent','Resource Dependent','Start Milestone','Finish Milestone')";if (projid > 0) {sWhereClause += " AND ProjectObjectId =" + projid + " AND Status = 'In Progress'";} else {sWhereClause += " AND ProjectObjectId in(" + getProIds(username) + ")";}if (key != null) {if (key.length() > 0) {sWhereClause += " AND ( Name LIKE '%" + key + "%' OR Id LIKE '%" + key + "%')";}}// System.out.println("************* sWhereClause: "+sWhereClause);Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] actvfields = new Activity(session).getAllFields();String sOrderBy = "ProjectName Asc and PlannedStartDate Asc";EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<Activity> actvIter = elm.loadActivities(actvfields, sWhereClause, sOrderBy);while (actvIter.hasNext()) {NewActivity nactv = new NewActivity();Activity actv = actvIter.next();nactv.setProjectId(actv.getProjectId());nactv.setProjectName(actv.getProjectName());nactv.setWBSCode(actv.getWBSCode());nactv.setWBSName(actv.getWBSName());nactv.setObjectId(actv.getObjectId().toInteger());nactv.setId(actv.getId());nactv.setName(actv.getName());// 工程公司非实际完成百分比，初定定为工期完成百分比nactv.setPercentComplete(new DecimalFormat("######0.000").format(actv.getPercentComplete().doubleValue()));// nactv.setActualFinishDate(actv.getPercentComplete().doubleValue());if (actv.getPlannedStartDate() != null) {nactv.setPlannedStartDate(actv.getPlannedStartDate().toString().substring(0, 10));}if (actv.getPlannedFinishDate() != null) {nactv.setPlannedFinishDate(actv.getPlannedFinishDate().toString().substring(0, 10));}if (actv.getActualStartDate() != null) {nactv.setActualStartDate(actv.getActualStartDate().toString().substring(0, 10));}if (actv.getActualFinishDate() != null) {nactv.setActualFinishDate(actv.getActualFinishDate().toString().substring(0, 10));}if (actv.getRemainingEarlyStartDate() != null && actv.getRemainingEarlyFinishDate() != null) {nactv.setRemainDay((int) ((actv.getRemainingEarlyFinishDate().getTime() - actv.getRemainingEarlyStartDate().getTime()) / (1000 * 24 * 60 * 60)) + 1);} else {nactv.setRemainDay(0);}list.add(nactv);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** @Title: getAllActivitySizeByFilter * @Description: TODO* @param @param username* @param @param key* @param @param projid* @param @return * @return int* @throws*/// 仅限过滤查询时判断总数目用private int getAllActivitySizeByFilter(String username, String key, Integer projid) {int actvlen = 0;String sWhereClause = "Status = 'In Progress'";sWhereClause += " AND Type in('Task Dependent','Resource Dependent','Start Milestone','Finish Milestone')";if (projid > 0) {sWhereClause += " AND ProjectObjectId =" + projid;} else {sWhereClause += " AND ProjectObjectId in(" + getProIds(username) + ")";}if (key != null) {if (key.length() > 0) {sWhereClause += " AND ( Name LIKE '%" + key + "%' OR Id LIKE '%" + key + "%')";}}Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] actvfields = new Activity(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<Activity> actvIter = elm.loadActivities(actvfields, sWhereClause, null);actvlen = actvIter.getAll().length;} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return actvlen;}/*** (Not Javadoc) * <p>Title: getActivitySize</p> * <p>Description: </p> * @param username* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivitySize(java.lang.String)*/@Overridepublic int getActivitySize(String username) {int result = -2;String sWhereClause = "Name = '" + username + "'";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] userfields = new User(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();// 检验P6系统是否存在该帐号BOIterator<User> userIter = elm.loadUsers(userfields, sWhereClause, null);if (userIter.hasNext()) {result = -1;}if (result == -1) {if (getUserOBSIds(username).length() > 0) {result = getAllActivitySize(username);}}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return result;}/*** <p>Title: getActivities</p> * <p>Description: </p> * @param username* @param pageIndex* @param pageSize* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivities(java.lang.String, int, int)*/@Overridepublic List<NewActivity> getActivities(String username, int pageIndex, int pageSize) {int size = getAllActivitySize(username);// 当总页数末尾值大于 实际值时，作业罗列到实际值if (size < pageSize * pageIndex) {return getAllActivities(username, null, 0).subList(pageSize * (pageIndex - 1), size);}return getAllActivities(username, null, 0).subList(pageSize * (pageIndex - 1), pageSize * pageIndex);}//  @Overridepublic List<NewActivity> getActivitiesByFilter(String username, String key, Integer projid, int pageIndex, int pageSize) {int size = getAllActivitySizeByFilter(username, key, projid);// 当总页数末尾值大于 实际值时，作业罗列到实际值if (size < pageSize * pageIndex) {return getAllActivities(username, key, projid).subList(pageSize * (pageIndex - 1), size);}return getAllActivities(username, key, projid).subList(pageSize * (pageIndex - 1), pageSize * pageIndex);}/*** (Not Javadoc) * <p>Title: getActivityDetail</p> * <p>Description: </p> * @param activityObjectId* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivityDetail(java.lang.Integer)*/@Overridepublic ActivityDetail getActivityDetail(Integer activityObjectId) {ActivityDetail ad = new ActivityDetail();ad.setActivity(getActivity(activityObjectId));ad.setActvCodeAssSize(getActivityCodeAssignment(activityObjectId).size());// ad.setActvCodeAss(getActivityCodeAssignment(activityObjectId));ad.setDocSize(getActivityDocument(activityObjectId).size());// ad.setDocs(getProjectDocument(activityObjectId));ad.setStepSize(getActivityStep(activityObjectId).size());// ad.setSteps(getActivityStep(activityObjectId));ad.setPredecessorsSize(getActivityPredecessors(activityObjectId).size());// ad.setPredecessors(getActivityPredecessors(activityObjectId));ad.setSuccessorsSize(getActivitySuccessors(activityObjectId).size());// ad.setSuccessors(getActivitySuccessors(activityObjectId));return ad;}/*** (Not Javadoc) * <p>Title: getActivityCodeAssignment</p> * <p>Description: </p> * @param activityObjectId* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivityCodeAssignment(java.lang.Integer)*/@Overridepublic List<NewActivityCodeAssignment> getActivityCodeAssignment(Integer activityObjectId) {List<NewActivityCodeAssignment> list = new ArrayList<NewActivityCodeAssignment>();String sWhereClause = "ActivityObjectId = " + activityObjectId;Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] Assfields = new ActivityCodeAssignment(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<ActivityCodeAssignment> assIter = elm.loadActivityCodeAssignments(Assfields, sWhereClause, null);while (assIter.hasNext()) {NewActivityCodeAssignment nass = new NewActivityCodeAssignment();ActivityCodeAssignment ass = assIter.next();nass.setActivityObjectId(activityObjectId);nass.setActivityCodeTypeName(ass.getActivityName());nass.setActivityCodeValue(ass.getActivityCodeValue());nass.setActivityCodeTypeName(ass.getActivityCodeTypeName());nass.setActivityCodeDescription(ass.getActivityCodeDescription());list.add(nass);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** (Not Javadoc) * <p>Title: getActivityStep</p> * <p>Description: </p> * @param activityObjectId* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivityStep(java.lang.Integer)*/@Overridepublic List<NewActivityStep> getActivityStep(Integer activityObjectId) {List<NewActivityStep> list = new ArrayList<NewActivityStep>();// 传入条件查询参数String sWhereClause = "ActivityObjectId = " + activityObjectId;Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] stepfields = new ActivityStep(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<ActivityStep> stepIter = elm.loadActivitySteps(stepfields, sWhereClause, null);while (stepIter.hasNext()) {NewActivityStep nstep = new NewActivityStep();ActivityStep step = stepIter.next();nstep.setActivityObjectId(activityObjectId);nstep.setActivityName(step.getActivityName());nstep.setName(step.getName());nstep.setWeight(step.getWeight());nstep.setWeightPercent(step.getWeightPercent().doubleValue());nstep.setPercentComplete(step.getPercentComplete().doubleValue());list.add(nstep);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** (Not Javadoc) * <p>Title: getActivityDocument</p> * <p>Description: </p> * @param activityObjectId* @return * @see com.campin.tmws.server.service.WebServiceInterface#getActivityDocument(java.lang.Integer)*/@Overridepublic List<NewProjectDocument> getActivityDocument(Integer activityObjectId) {List<NewProjectDocument> list = new ArrayList<NewProjectDocument>();String sWhereClause = "ActivityObjectId = " + activityObjectId;Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] docfields = new ProjectDocument(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<ProjectDocument> stepIter = elm.loadProjectDocuments(docfields, sWhereClause, null);while (stepIter.hasNext()) {NewProjectDocument ndoc = new NewProjectDocument();ProjectDocument doc = stepIter.next();ndoc.setActivityObjectId(activityObjectId);ndoc.setActivityName(doc.getActivityName());ndoc.setObjectId(doc.getObjectId().toInteger());ndoc.setDocumentTitle(doc.getDocumentTitle());list.add(ndoc);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** @Title: getUserOBSIds * @Description: TODO* @param @param username* @param @return * @return String* @throws*/@SuppressWarnings("static-access")private String getUserOBSIds(String username) {// 传入条件查询参数String sWhereClause = "UserName ='" + username + "' ", ids = "";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] userOBSfields = new UserOBS(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<UserOBS> userOBSIter = elm.loadUserOBS(userOBSfields, sWhereClause, null);while (userOBSIter.hasNext()) {UserOBS ub = userOBSIter.next();ids += ub.getOBSObjectId() + ",";}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}if (ids.length() > 0) {ids = ids.substring(0, ids.length() - 1);}return ids;}/*** @Title: getOBSChirdren * @Description: TODO* @param @param username* @param @return * @return String* @throws*/public String getOBSChirdren(String username) {String ids = getUserOBSIds(username);String sWhereClause = "ParentObjectId in(" + ids + ")";ids += ",";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] obsfields = new OBS(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<OBS> ot1 = elm.loadOBS(obsfields, sWhereClause, null);OBS o1 = null;while (ot1.hasNext()) {o1 = ot1.next();ids += o1.getObjectId() + ",";// 第二次子节点BOIterator<OBS> ot2 = o1.loadOBSChildren(new String[] { "ObjectId", "Name" }, null, null);while (ot2.hasNext()) {OBS o2 = ot2.next();ids += o2.getObjectId() + ",";// 第三次子节点BOIterator<OBS> ot3 = o2.loadOBSChildren(obsfields, null, null);while (ot3.hasNext()) {OBS o3 = ot3.next();ids += o3.getObjectId() + ",";// 第四次子节点BOIterator<OBS> ot4 = o3.loadOBSChildren(obsfields, null, null);while (ot4.hasNext()) {OBS o4 = ot4.next();ids += o4.getObjectId() + ",";// 第五次子节点BOIterator<OBS> ot5 = o4.loadOBSChildren(obsfields, null, null);while (ot5.hasNext()) {OBS o5 = ot5.next();ids += o5.getObjectId() + ",";// 第六次子节点BOIterator<OBS> ot6 = o5.loadOBSChildren(obsfields, null, null);while (ot6.hasNext()) {OBS o6 = ot6.next();ids += o6.getObjectId() + ",";// 第七次子节点BOIterator<OBS> ot7 = o6.loadOBSChildren(obsfields, null, null);while (ot7.hasNext()) {OBS o7 = ot7.next();ids += o7.getObjectId() + ",";}}}}}}}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return ids = ids.substring(0, ids.length() - 1);}@SuppressWarnings("static-access")public String getProIds(String username) {// 传入条件查询参数String sWhereClause = "OBSObjectId in(" + getOBSChirdren(username) + ")", pids = "";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] projfields = new Project(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<Project> projIter = elm.loadProjects(projfields, sWhereClause, null);while (projIter.hasNext()) {pids += projIter.next().getObjectId() + ",";}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return pids.substring(0, pids.length() - 1);}/*** @Title: getProjectList * @Description: TODO* @param @param username* @param @return * @return List<NewProject>* @throws*/public List<NewProject> getProjectList(String username) {List<NewProject> list = new ArrayList<NewProject>();String sWhereClause = "OBSObjectId in(" + getOBSChirdren(username) + ")";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] projfields = new Project(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();BOIterator<Project> projIter = elm.loadProjects(projfields, sWhereClause, null);while (projIter.hasNext()) {Project p = projIter.next();NewProject np = new NewProject();np.setObjectid(p.getObjectId().toInteger());np.setId(p.getId());np.setName(p.getName());list.add(np);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** @Title: getActivityPredecessors * @Description: TODO* @param @param activityObjectId* @param @return * @return List<NewActivity>* @throws*/public List<NewActivity> getActivityPredecessors(Integer activityObjectId) {List<NewActivity> list = new ArrayList<NewActivity>();Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] rsfields = new Relationship(session).getAllFields();BOIterator<Relationship> rsIter = new Activity(session, new ObjectId(activityObjectId)).loadPredecessorRelationships(rsfields,null, null);while (rsIter.hasNext()) {Relationship re = rsIter.next();NewActivity nactv = new NewActivity();nactv.setObjectId(re.getPredecessorActivityObjectId().toInteger());nactv.setId(re.getPredecessorActivityId());nactv.setName(re.getPredecessorActivityName());nactv.setProjectId(re.getPredecessorProjectId());nactv.setWBSName(re.getPredecessorWbsName());list.add(nactv);}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return list;}/*** @Title: userValidate * @Description: TODO* @param @param username* @param @return * @return int* @throws*/private int userValidate(String username) {int result = -1;String sWhereClause = "Name = '" + username + "'";Session session = null;try {DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,apiserverport));session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),dbInstances[0].getDatabaseId(), uname, password);String[] userfields = new User(session).getAllFields();EnterpriseLoadManager elm = session.getEnterpriseLoadManager();// 检验P6系统是否存在该帐号BOIterator<User> userIter = elm.loadUsers(userfields, sWhereClause, null);while (userIter.hasNext()) {result = 0;}if (result == 0) {if (getUserOBSIds(username).length() > 0) {result = 1;}}} catch (Exception e) {e.printStackTrace();} finally {if (session != null)session.logout();}return result;}
}

以上完成编程后，最终发布定制服务如下，这里WebService用的是传统的SOAP协议

Step 2. C#调用P6定制 WebService服务

以上定制服务顺利发布之后，后续的操作就简单多了，打开VisualStudio直接新建项目

直接引用接口方法

用C语言输出要显示的内容即可

using wsdemo.P6EPSWBSWebService;
using wsdemo.P6ProjectWebService;
using wsdemo.P6ActivityService;namespace wsdemo
{public partial class epsdemo : System.Web.UI.Page{protected void Page_Load(object sender, EventArgs e){// 测试方法1（demo），根据项目代码获取项目名称EPSWBSWebService epsService = new EPSWBSWebService();Response.Write(epsService.demo("CS-Plan") + "<br/>");P6EPSWBSWebService.NewEPS[] epss = epsService.loadEPS("kping");for (int i = 0; i < epss.Length; i++){Response.Write(" --------------- <br/>");Response.Write(" | EPS编号：" + epss[i].objectId);Response.Write(" | EPS编码：" + epss[i].id);Response.Write(" | EPS名称：" + epss[i].name);}测试方法2（loadProjectByUser），根据用户登录名查询其所能看到的project//ProjectWebService projservice = new ProjectWebService();//P6ProjectWebService.NewProject[] projs = projservice.loadProjectByUser("kping");//for (int i = 0; i < projs.Length; i++)//{//    Response.Write(" 项目加载测试--------------- <br/>");//    Response.Write(" | 项目编号：" + projs[i].objectId);//    Response.Write(" | 项目编码：" + projs[i].id);//    Response.Write(" | 项目名称：" + projs[i].name);//}测试方法3（loadAllActivities），根据查询某项目下所有作业信息//ActivityWebService actvservice = new ActivityWebService();//NewActivity[] actvs = actvservice.loadAllActivities(null, null, 644, true);//for (int i = 0; i < actvs.Length; i++) {//    Response.Write(" 项目加载测试--------------- <br/>");//    Response.Write(" | 作业编号：" + actvs[i].objectId);//    Response.Write(" | 作业编码：" + actvs[i].id);//    Response.Write(" | 作业名称：" + actvs[i].name);//    Response.Write(" | 作业计划开始：" + actvs[i].plannedStartDate);//    Response.Write(" | 作业计划完成：" + actvs[i].plannedFinishDate);//    Response.Write(" | 作业WBS编号：" + actvs[i].WBSObjectId);//    Response.Write(" | 作业项目编号：" + actvs[i].projectObjectId);//}测试方法4（updateActivity），修改作业信息//NewActivityDetail a1 = actvservice.getActivityDetail(51992, true);//a1.activity.name = "ABCDEFGG";//a1.activity.plannedStartDate = "2016-03-10";//Response.Write("name2： " + a1.activity.name);//actvservice.updateActivity(a1.activity);测试方法5（addActivityDirect），增加作业信息//NewActivity new1 = new NewActivity();//new1.objectId = 160322003;;//new1.WBSObjectId = 11391;//new1.name = "测试号";//new1.id = "AX001002004";//new1.name = "测试作业名称2";//new1.plannedStartDate = "2016-01-01";//new1.plannedFinishDate = "2016-01-06";//new1.actualStartDate = "2016-01-02";//actvservice.addActivityDirect(new1);}}
}

以上代码运行即可打印出所连接P6的所有项目名称信息

PS：笔者非专职程序员，以上案例项目源码考虑特殊原因无法提供

还是那句话，这个行业的分享不多，希望更多感兴趣的朋友一同参与，探讨或合作 !

本人可提供Oracle 多种产品技术服务，包括产品的部署和维护及培训，欢迎与我取得联系！

如何联系蚕豆哥_蚕豆哥的博客-CSDN博客https://campin.blog.csdn.net/article/details/52950969

使用C#调用P6 Primavera WebService(自建服务IntegrationAPI)相关推荐

axis2 java.net.url_axis,axis2调用.net的webservice
package testClick.src.test;import javax.xml.namespace.QName;import org.apache.axiom.om.OMAbstractFac ...
android模拟器webservice,已解决：android 模拟器调用本地的webservice 引用不到
背景,需要自己用 java 写一个 webservice, 然后写一个 android的客户端去调用它. 我这里折腾了2天,最后终于调成功了.以图为证. 要点: 1, MyEclipse开发webs ...
.NET调用JAVA的WebService方法
调用WebService,最简单的办法当然是直接添加WEB引用,然后自动产生代理类,但是在调用JAVA的WebService时并没有这么简单,特别是对于SoapHeader的处理,在网上也有相关资料, ...
php 如何利用 soap调用.Net的WebService asmx文件
原文:php 如何利用 soap调用.Net的WebService asmx文件最近,帮一个同行测试用.net写的WebService接口,C#调用通过,现在需要测试一下php版本对它的调用,经过各 ...
设置maxJsonLength，解决ajax通过POST方式调用.net的webService时，数据过长时服务器返回500错误的问题
设置maxJsonLength,解决ajax通过POST方式调用.net的webService时,数据过长时服务器返回500错误的问题参考文章: (1)设置maxJsonLength,解决ajax通 ...
ScriptManager调用无参数WebService
在工程中添加一个 webservice 使用默认的红色部分为后添加为了要让ScriptManager识别这个WEBSERVICE WebService.cs using System; using ...
关于安卓调用C#的WebService上传图片问题（不使用ksoap2）
============问题描述============ 小弟初学安卓开发.最近需要做一个图片上传的功能. 我是用java开发安卓,调用C#的WebService.在网上找到一大堆资料,几乎全部是用k ...
java调用第三方的webservice应用实例
互联网上面有很多的免费webService服务,我们可以调用这些免费的WebService服务,将一些其他网站的内容信息集成到我们的Web应用中显示. 一些常用的webservice网站的链接地址: ...
php调用.net webservice,PHP调用.NET的WebService 简单实例
这篇文章主要介绍了使用PHP调用.NET的WebService的一个简单实例,十分的简单,有需要的小伙伴可以自己扩展下,如有疑问请留言. 创建一个C#的web service,这个就不多说了,我用vs ...
jQuery Ajax 方法调用 Asp.Net WebService 的详细例子
这很常用,搜索了一下博客园的"找找看"和谷歌,看到大部分都是转载于一两篇文章(而且来源还不是博客园),有的是简单的说一点无法运行,给初学者的调试和学习带来不方便,我在这里将jQue ...

使用C#调用P6 Primavera WebService(自建服务IntegrationAPI)

Step 1. 自建定制P6 WebService服务

Step 2. C#调用P6定制 WebService服务

使用C#调用P6 Primavera WebService(自建服务IntegrationAPI)相关推荐

最新文章

热门文章