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

    目录

    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 
    1. apiServerIp = 192.168.1.251
    2. apiServerPort = 9099
    3. username = admin
    4. password = admin
    • 配置applicationContext.xml，
    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	xmlns:context="http://www.springframework.org/schema/context"
    4. 	xmlns:p="http://www.springframework.org/schema/p"
    5. 	xmlns:jaxws="http://cxf.apache.org/jaxws"
    6. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    7. 	xsi:schemaLocation="http://www.springframework.org/schema/beans
    8.     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    9.     http://www.springframework.org/schema/context
    10.     http://www.springframework.org/schema/context/spring-context-3.0.xsd
    11.     http://cxf.apache.org/jaxws 
    12.     http://cxf.apache.org/schemas/jaxws.xsd">
    13.  
    14. 	<import resource="classpath:META-INF/cxf/cxf.xml" />
    15. 	<import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" />
    16. 	<import resource="classpath:META-INF/cxf/cxf-servlet.xml" />
    17.  
    18. 	<bean id="ws" class="com.campin.tmws.server.service.WebServiceImpl" />
    19.  
    20. 	<jaxws:endpoint implementor="#ws" address="/activity">
    21. 		
    22. 		<jaxws:inInterceptors>
    23. 			<bean class="org.apache.cxf.interceptor.LoggingInInterceptor" />
    24. 			<bean class="com.cnpec.tmws.server.MyAuthInterceptor" />
    25. 		jaxws:inInterceptors>
    26. 		
    27. 		
    28. 	jaxws:endpoint>
    29. beans>
    •  Inteface类就不介绍，重点是重写实现 WebServiceImpl
    1. package com.campin.tmws.server.service;
    2.  
    3. import java.text.DecimalFormat;
    4. import java.util.ArrayList;
    5. import java.util.Date;
    6. import java.util.List;
    7.  
    8. import javax.jws.WebService;
    9.  
    10. import org.apache.log4j.Logger;
    11.  
    12. import com.campin.tmws.server.bean.ActivityDetail;
    13. import com.campin.tmws.server.bean.NewActivity;
    14. import com.campin.tmws.server.bean.NewActivityCodeAssignment;
    15. import com.campin.tmws.server.bean.NewActivityStep;
    16. import com.campin.tmws.server.bean.NewProject;
    17. import com.campin.tmws.server.bean.NewProjectDocument;
    18. import com.campin.tmws.util.ReadConfigFile;
    19. import com.primavera.common.value.ObjectId;
    20. import com.primavera.integration.client.EnterpriseLoadManager;
    21. import com.primavera.integration.client.RMIURL;
    22. import com.primavera.integration.client.Session;
    23. import com.primavera.integration.client.bo.BOIterator;
    24. import com.primavera.integration.client.bo.object.Activity;
    25. import com.primavera.integration.client.bo.object.ActivityCodeAssignment;
    26. import com.primavera.integration.client.bo.object.OBS;
    27. import com.primavera.integration.client.bo.object.Project;
    28. import com.primavera.integration.client.bo.object.ActivityStep;
    29. import com.primavera.integration.client.bo.object.Relationship;
    30. import com.primavera.integration.client.bo.object.User;
    31. import com.primavera.integration.client.bo.object.UserOBS;
    32. import com.primavera.integration.client.bo.object.ProjectDocument;
    33. import com.primavera.integration.common.DatabaseInstance;
    34.  
    35. /**
    36.  * 
    37.  * @ClassName: WebServiceImpl
    38.  * @Description: TODO
    39.  * @author Raining Campin Chou
    40.  * @date 2015年11月02日
    41.  * 
    42.  */
    43. @WebService(endpointInterface = "com.campin.tmws.server.service.WebServiceInterface", serviceName = "WebServiceImpl", targetNamespace = "http://tmws.campin.com/Primavera/P6/TMWS")
    44. public class WebServiceImpl implements WebServiceInterface {
    45.  
    46. 	private String uname = ""; // 链接 p6 用户名
    47. 	private String password = ""; // 链接 p6 密码
    48. 	private String apiserverip = ""; // 链接 p6服务器 ip 信息
    49. 	private int apiserverport = 0; // 链接 p6api服务端口
    50.  
    51. 	static Logger logger = Logger.getLogger(WebServiceImpl.class);
    52.  
    53. 	public WebServiceImpl() {
    54. 		ReadConfigFile rcf = new ReadConfigFile();
    55. 		rcf.read();
    56. 		this.uname = rcf.getUsername();
    57. 		this.password = rcf.getPassword();
    58. 		this.apiserverip = rcf.getApiserverip();
    59. 		this.apiserverport = rcf.getApiserverport();
    60. 	}
    61.  
    62.  
    63. 	/**
    64. 	 * @Title: getActivity 
    65. 	 * @Description: TODO
    66. 	 * @param @param activityObjectId
    67. 	 * @param @return 
    68. 	 * @return NewActivity
    69. 	 * @throws
    70. 	 */
    71. 	public NewActivity getActivity(Integer activityObjectId) {
    72. 		NewActivity nactv = new NewActivity();
    73.  
    74. 		String sWhereClause = "ObjectId =" + activityObjectId;
    75. 		Session session = null;
    76. 		try {
    77. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    78. 					apiserverport));
    79. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    80. 					dbInstances[0].getDatabaseId(), uname, password);
    81. 			String[] actvfields = new Activity(session).getAllFields();
    82.  
    83. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    84. 			BOIterator actvIter = elm.loadActivities(actvfields, sWhereClause, null);
    85.  
    86. 			if (actvIter.hasNext()) {
    87. 				Activity actv = actvIter.next();
    88. 				nactv.setProjectId(actv.getProjectId());
    89. 				nactv.setProjectName(actv.getProjectName());
    90. 				nactv.setWBSCode(actv.getWBSCode());
    91. 				nactv.setWBSName(actv.getWBSName());
    92. 				nactv.setObjectId(actv.getObjectId().toInteger());
    93. 				nactv.setId(actv.getId());
    94. 				nactv.setName(actv.getName());
    95.  
    96. 				// 工程公司非实际完成百分比，初定定为工期完成百分比
    97. 				nactv.setPercentComplete(new DecimalFormat("######0.000").format((actv.getPhysicalPercentComplete().doubleValue())));
    98.  
    99. 				if (actv.getPlannedStartDate() != null) {
    100. 					nactv.setPlannedStartDate(actv.getPlannedStartDate().toString().substring(0, 10));
    101. 				}
    102. 				if (actv.getPlannedFinishDate() != null) {
    103. 					nactv.setPlannedFinishDate(actv.getPlannedFinishDate().toString().substring(0, 10));
    104. 				}
    105. 				if (actv.getActualStartDate() != null) {
    106. 					nactv.setActualStartDate(actv.getActualStartDate().toString().substring(0, 10));
    107. 				}
    108. 				if (actv.getActualFinishDate() != null) {
    109. 					nactv.setActualFinishDate(actv.getActualFinishDate().toString().substring(0, 10));
    110. 				}
    111. 				if (actv.getRemainingEarlyStartDate() != null && actv.getRemainingEarlyFinishDate() != null) {
    112. 					nactv.setRemainDay((int) ((actv.getRemainingEarlyFinishDate().getTime() - actv.getRemainingEarlyStartDate().getTime()) / (1000 * 24 * 60 * 60)) + 1);
    113. 				} else {
    114. 					nactv.setRemainDay(0);
    115. 				}
    116. 			}
    117. 		} catch (Exception e) {
    118. 			e.printStackTrace();
    119. 		} finally {
    120. 			if (session != null)
    121. 				session.logout();
    122. 		}
    123. 		return nactv;
    124. 	}
    125.  
    126. 	/**
    127. 	 * @Title: getAllActivities 
    128. 	 * @Description: TODO
    129. 	 * @param @param username
    130. 	 * @param @param key
    131. 	 * @param @param projid
    132. 	 * @param @return 
    133. 	 * @return List
    134. 	 * @throws
    135. 	 */
    136. 	@SuppressWarnings("static-access")
    137. 	public List getAllActivities(String username, String key, Integer projid) {
    138. 		List list = new ArrayList();
    139. 		/**
    140. 		 * 分多种情况组合筛选条件 1 初始化过滤作业状态和作业类型 2 过滤项目 / 项目分组 ， 一次性只能过滤查看一个项目 3
    141. 		 * 过滤关键字，包括作业名称和作业代码
    142. 		 */
    143. 		String sWhereClause = "Status = 'In Progress'";
    144. 		sWhereClause += " AND Type in('Task Dependent','Resource Dependent','Start Milestone','Finish Milestone')";
    145. 		if (projid > 0) {
    146. 			sWhereClause += " AND ProjectObjectId =" + projid + " AND Status = 'In Progress'";
    147. 		} else {
    148. 			sWhereClause += " AND ProjectObjectId in(" + getProIds(username) + ")";
    149. 		}
    150. 		if (key != null) {
    151. 			if (key.length() > 0) {
    152. 				sWhereClause += " AND ( Name LIKE '%" + key + "%' OR Id LIKE '%" + key + "%')";
    153. 			}
    154. 		}
    155. 		// System.out.println("************* sWhereClause: "+sWhereClause);
    156.  
    157. 		Session session = null;
    158. 		try {
    159. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    160. 					apiserverport));
    161. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    162. 					dbInstances[0].getDatabaseId(), uname, password);
    163. 			String[] actvfields = new Activity(session).getAllFields();
    164.  
    165. 			String sOrderBy = "ProjectName Asc and PlannedStartDate Asc";
    166. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    167. 			BOIterator actvIter = elm.loadActivities(actvfields, sWhereClause, sOrderBy);
    168.  
    169. 			while (actvIter.hasNext()) {
    170. 				NewActivity nactv = new NewActivity();
    171. 				Activity actv = actvIter.next();
    172. 				nactv.setProjectId(actv.getProjectId());
    173. 				nactv.setProjectName(actv.getProjectName());
    174. 				nactv.setWBSCode(actv.getWBSCode());
    175. 				nactv.setWBSName(actv.getWBSName());
    176. 				nactv.setObjectId(actv.getObjectId().toInteger());
    177. 				nactv.setId(actv.getId());
    178. 				nactv.setName(actv.getName());
    179.  
    180. 				// 工程公司非实际完成百分比，初定定为工期完成百分比
    181. 				nactv.setPercentComplete(new DecimalFormat("######0.000").format(actv.getPercentComplete().doubleValue()));
    182.  
    183. 				// nactv.setActualFinishDate(actv.getPercentComplete().doubleValue());
    184.  
    185. 				if (actv.getPlannedStartDate() != null) {
    186. 					nactv.setPlannedStartDate(actv.getPlannedStartDate().toString().substring(0, 10));
    187. 				}
    188. 				if (actv.getPlannedFinishDate() != null) {
    189. 					nactv.setPlannedFinishDate(actv.getPlannedFinishDate().toString().substring(0, 10));
    190. 				}
    191. 				if (actv.getActualStartDate() != null) {
    192. 					nactv.setActualStartDate(actv.getActualStartDate().toString().substring(0, 10));
    193. 				}
    194. 				if (actv.getActualFinishDate() != null) {
    195. 					nactv.setActualFinishDate(actv.getActualFinishDate().toString().substring(0, 10));
    196. 				}
    197. 				if (actv.getRemainingEarlyStartDate() != null && actv.getRemainingEarlyFinishDate() != null) {
    198. 					nactv.setRemainDay((int) ((actv.getRemainingEarlyFinishDate().getTime() - actv.getRemainingEarlyStartDate().getTime()) / (1000 * 24 * 60 * 60)) + 1);
    199. 				} else {
    200. 					nactv.setRemainDay(0);
    201. 				}
    202.  
    203. 				list.add(nactv);
    204. 			}
    205. 		} catch (Exception e) {
    206. 			e.printStackTrace();
    207. 		} finally {
    208. 			if (session != null)
    209. 				session.logout();
    210. 		}
    211. 		return list;
    212. 	}
    213.  
    214.  
    215. 	/**
    216. 	 * @Title: getAllActivitySizeByFilter 
    217. 	 * @Description: TODO
    218. 	 * @param @param username
    219. 	 * @param @param key
    220. 	 * @param @param projid
    221. 	 * @param @return 
    222. 	 * @return int
    223. 	 * @throws
    224. 	 */
    225. 	// 仅限过滤查询时判断总数目用
    226. 	private int getAllActivitySizeByFilter(String username, String key, Integer projid) {
    227. 		int actvlen = 0;
    228. 		String sWhereClause = "Status = 'In Progress'";
    229. 		sWhereClause += " AND Type in('Task Dependent','Resource Dependent','Start Milestone','Finish Milestone')";
    230. 		if (projid > 0) {
    231. 			sWhereClause += " AND ProjectObjectId =" + projid;
    232. 		} else {
    233. 			sWhereClause += " AND ProjectObjectId in(" + getProIds(username) + ")";
    234. 		}
    235. 		if (key != null) {
    236. 			if (key.length() > 0) {
    237. 				sWhereClause += " AND ( Name LIKE '%" + key + "%' OR Id LIKE '%" + key + "%')";
    238. 			}
    239. 		}
    240. 		Session session = null;
    241. 		try {
    242. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    243. 					apiserverport));
    244. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    245. 					dbInstances[0].getDatabaseId(), uname, password);
    246. 			String[] actvfields = new Activity(session).getAllFields();
    247.  
    248. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    249. 			BOIterator actvIter = elm.loadActivities(actvfields, sWhereClause, null);
    250.  
    251. 			actvlen = actvIter.getAll().length;
    252. 		} catch (Exception e) {
    253. 			e.printStackTrace();
    254. 		} finally {
    255. 			if (session != null)
    256. 				session.logout();
    257. 		}
    258. 		return actvlen;
    259. 	}
    260.  
    261. 	/**
    262. 	 * (Not Javadoc) 
    263. 	 * 
      Title: getActivitySize
       
    264. 	 * 
      Description: 
       
    265. 	 * @param username
    266. 	 * @return 
    267. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivitySize(java.lang.String)
    268. 	 */
    269. 	@Override
    270. 	public int getActivitySize(String username) {
    271. 		int result = -2;
    272. 		String sWhereClause = "Name = '" + username + "'";
    273. 		Session session = null;
    274. 		try {
    275. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    276. 					apiserverport));
    277. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    278. 					dbInstances[0].getDatabaseId(), uname, password);
    279. 			String[] userfields = new User(session).getAllFields();
    280.  
    281. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    282. 			// 检验P6系统是否存在该帐号
    283. 			BOIterator userIter = elm.loadUsers(userfields, sWhereClause, null);
    284.  
    285. 			if (userIter.hasNext()) {
    286. 				result = -1;
    287. 			}
    288. 			if (result == -1) {
    289. 				if (getUserOBSIds(username).length() > 0) {
    290. 					result = getAllActivitySize(username);
    291. 				}
    292. 			}
    293. 		} catch (Exception e) {
    294. 			e.printStackTrace();
    295. 		} finally {
    296. 			if (session != null)
    297. 				session.logout();
    298. 		}
    299. 		return result;
    300. 	}
    301.  
    302.  
    303. 	/**
    304. 	 * 
      Title: getActivities
       
    305. 	 * 
      Description: 
       
    306. 	 * @param username
    307. 	 * @param pageIndex
    308. 	 * @param pageSize
    309. 	 * @return 
    310. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivities(java.lang.String, int, int)
    311. 	 */
    312. 	@Override
    313. 	public List getActivities(String username, int pageIndex, int pageSize) {
    314. 		int size = getAllActivitySize(username);
    315. 		// 当总页数末尾值大于 实际值时，作业罗列到实际值
    316. 		if (size < pageSize * pageIndex) {
    317. 			return getAllActivities(username, null, 0).subList(pageSize * (pageIndex - 1), size);
    318. 		}
    319. 		return getAllActivities(username, null, 0).subList(pageSize * (pageIndex - 1), pageSize * pageIndex);
    320. 	}
    321.  
    322. //	@Override
    323. 	public List getActivitiesByFilter(String username, String key, Integer projid, int pageIndex, int pageSize) {
    324. 		int size = getAllActivitySizeByFilter(username, key, projid);
    325. 		// 当总页数末尾值大于 实际值时，作业罗列到实际值
    326. 		if (size < pageSize * pageIndex) {
    327. 			return getAllActivities(username, key, projid).subList(pageSize * (pageIndex - 1), size);
    328. 		}
    329. 		return getAllActivities(username, key, projid).subList(pageSize * (pageIndex - 1), pageSize * pageIndex);
    330. 	}
    331.  
    332. 	/**
    333. 	 * (Not Javadoc) 
    334. 	 * 
      Title: getActivityDetail
       
    335. 	 * 
      Description: 
       
    336. 	 * @param activityObjectId
    337. 	 * @return 
    338. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivityDetail(java.lang.Integer)
    339. 	 */
    340. 	@Override
    341. 	public ActivityDetail getActivityDetail(Integer activityObjectId) {
    342. 		ActivityDetail ad = new ActivityDetail();
    343. 		ad.setActivity(getActivity(activityObjectId));
    344. 		ad.setActvCodeAssSize(getActivityCodeAssignment(activityObjectId).size());
    345. 		// ad.setActvCodeAss(getActivityCodeAssignment(activityObjectId));
    346.  
    347. 		ad.setDocSize(getActivityDocument(activityObjectId).size());
    348. 		// ad.setDocs(getProjectDocument(activityObjectId));
    349.  
    350. 		ad.setStepSize(getActivityStep(activityObjectId).size());
    351. 		// ad.setSteps(getActivityStep(activityObjectId));
    352.  
    353. 		ad.setPredecessorsSize(getActivityPredecessors(activityObjectId).size());
    354. 		// ad.setPredecessors(getActivityPredecessors(activityObjectId));
    355.  
    356. 		ad.setSuccessorsSize(getActivitySuccessors(activityObjectId).size());
    357. 		// ad.setSuccessors(getActivitySuccessors(activityObjectId));
    358. 		return ad;
    359. 	}
    360.  
    361. 	/**
    362. 	 * (Not Javadoc) 
    363. 	 * 
      Title: getActivityCodeAssignment
       
    364. 	 * 
      Description: 
       
    365. 	 * @param activityObjectId
    366. 	 * @return 
    367. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivityCodeAssignment(java.lang.Integer)
    368. 	 */
    369. 	@Override
    370. 	public List getActivityCodeAssignment(Integer activityObjectId) {
    371. 		List list = new ArrayList();
    372.  
    373. 		String sWhereClause = "ActivityObjectId = " + activityObjectId;
    374. 		Session session = null;
    375. 		try {
    376. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    377. 					apiserverport));
    378. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    379. 					dbInstances[0].getDatabaseId(), uname, password);
    380. 			String[] Assfields = new ActivityCodeAssignment(session).getAllFields();
    381.  
    382. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    383. 			BOIterator assIter = elm.loadActivityCodeAssignments(Assfields, sWhereClause, null);
    384.  
    385. 			while (assIter.hasNext()) {
    386. 				NewActivityCodeAssignment nass = new NewActivityCodeAssignment();
    387. 				ActivityCodeAssignment ass = assIter.next();
    388. 				nass.setActivityObjectId(activityObjectId);
    389. 				nass.setActivityCodeTypeName(ass.getActivityName());
    390. 				nass.setActivityCodeValue(ass.getActivityCodeValue());
    391. 				nass.setActivityCodeTypeName(ass.getActivityCodeTypeName());
    392. 				nass.setActivityCodeDescription(ass.getActivityCodeDescription());
    393.  
    394. 				list.add(nass);
    395. 			}
    396. 		} catch (Exception e) {
    397. 			e.printStackTrace();
    398. 		} finally {
    399. 			if (session != null)
    400. 				session.logout();
    401. 		}
    402. 		return list;
    403. 	}
    404.  
    405. 	/**
    406. 	 * (Not Javadoc) 
    407. 	 * 
      Title: getActivityStep
       
    408. 	 * 
      Description: 
       
    409. 	 * @param activityObjectId
    410. 	 * @return 
    411. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivityStep(java.lang.Integer)
    412. 	 */
    413. 	@Override
    414. 	public List getActivityStep(Integer activityObjectId) {
    415. 		List list = new ArrayList();
    416. 		// 传入条件查询参数
    417. 		String sWhereClause = "ActivityObjectId = " + activityObjectId;
    418. 		Session session = null;
    419. 		try {
    420. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    421. 					apiserverport));
    422. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    423. 					dbInstances[0].getDatabaseId(), uname, password);
    424. 			String[] stepfields = new ActivityStep(session).getAllFields();
    425.  
    426. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    427. 			BOIterator stepIter = elm.loadActivitySteps(stepfields, sWhereClause, null);
    428.  
    429. 			while (stepIter.hasNext()) {
    430. 				NewActivityStep nstep = new NewActivityStep();
    431. 				ActivityStep step = stepIter.next();
    432. 				nstep.setActivityObjectId(activityObjectId);
    433. 				nstep.setActivityName(step.getActivityName());
    434. 				nstep.setName(step.getName());
    435. 				nstep.setWeight(step.getWeight());
    436. 				nstep.setWeightPercent(step.getWeightPercent().doubleValue());
    437. 				nstep.setPercentComplete(step.getPercentComplete().doubleValue());
    438.  
    439. 				list.add(nstep);
    440. 			}
    441. 		} catch (Exception e) {
    442. 			e.printStackTrace();
    443. 		} finally {
    444. 			if (session != null)
    445. 				session.logout();
    446. 		}
    447. 		return list;
    448. 	}
    449.  
    450. 	/**
    451. 	 * (Not Javadoc) 
    452. 	 * 
      Title: getActivityDocument
       
    453. 	 * 
      Description: 
       
    454. 	 * @param activityObjectId
    455. 	 * @return 
    456. 	 * @see com.campin.tmws.server.service.WebServiceInterface#getActivityDocument(java.lang.Integer)
    457. 	 */
    458. 	@Override
    459. 	public List getActivityDocument(Integer activityObjectId) {
    460. 		List list = new ArrayList();
    461. 		String sWhereClause = "ActivityObjectId = " + activityObjectId;
    462. 		Session session = null;
    463. 		try {
    464. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    465. 					apiserverport));
    466. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    467. 					dbInstances[0].getDatabaseId(), uname, password);
    468. 			String[] docfields = new ProjectDocument(session).getAllFields();
    469.  
    470. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    471. 			BOIterator stepIter = elm.loadProjectDocuments(docfields, sWhereClause, null);
    472.  
    473. 			while (stepIter.hasNext()) {
    474. 				NewProjectDocument ndoc = new NewProjectDocument();
    475. 				ProjectDocument doc = stepIter.next();
    476. 				ndoc.setActivityObjectId(activityObjectId);
    477. 				ndoc.setActivityName(doc.getActivityName());
    478. 				ndoc.setObjectId(doc.getObjectId().toInteger());
    479. 				ndoc.setDocumentTitle(doc.getDocumentTitle());
    480.  
    481. 				list.add(ndoc);
    482. 			}
    483. 		} catch (Exception e) {
    484. 			e.printStackTrace();
    485. 		} finally {
    486. 			if (session != null)
    487. 				session.logout();
    488. 		}
    489.  
    490. 		return list;
    491. 	}
    492.  
    493. 	/**
    494. 	 * @Title: getUserOBSIds 
    495. 	 * @Description: TODO
    496. 	 * @param @param username
    497. 	 * @param @return 
    498. 	 * @return String
    499. 	 * @throws
    500. 	 */
    501. 	@SuppressWarnings("static-access")
    502. 	private String getUserOBSIds(String username) {
    503. 		// 传入条件查询参数
    504. 		String sWhereClause = "UserName ='" + username + "' ", ids = "";
    505. 		Session session = null;
    506. 		try {
    507. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    508. 					apiserverport));
    509. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    510. 					dbInstances[0].getDatabaseId(), uname, password);
    511. 			String[] userOBSfields = new UserOBS(session).getAllFields();
    512.  
    513. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    514. 			BOIterator userOBSIter = elm.loadUserOBS(userOBSfields, sWhereClause, null);
    515.  
    516. 			while (userOBSIter.hasNext()) {
    517. 				UserOBS ub = userOBSIter.next();
    518. 				ids += ub.getOBSObjectId() + ",";
    519. 			}
    520. 		} catch (Exception e) {
    521. 			e.printStackTrace();
    522. 		} finally {
    523. 			if (session != null)
    524. 				session.logout();
    525. 		}
    526.  
    527. 		if (ids.length() > 0) {
    528. 			ids = ids.substring(0, ids.length() - 1);
    529. 		}
    530. 		return ids;
    531. 	}
    532.  
    533. 	/**
    534. 	 * @Title: getOBSChirdren 
    535. 	 * @Description: TODO
    536. 	 * @param @param username
    537. 	 * @param @return 
    538. 	 * @return String
    539. 	 * @throws
    540. 	 */
    541. 	public String getOBSChirdren(String username) {
    542. 		String ids = getUserOBSIds(username);
    543. 		String sWhereClause = "ParentObjectId in(" + ids + ")";
    544. 		ids += ",";
    545. 		Session session = null;
    546. 		try {
    547. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    548. 					apiserverport));
    549. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    550. 					dbInstances[0].getDatabaseId(), uname, password);
    551. 			String[] obsfields = new OBS(session).getAllFields();
    552.  
    553. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    554. 			BOIterator ot1 = elm.loadOBS(obsfields, sWhereClause, null);
    555. 			OBS o1 = null;
    556. 			while (ot1.hasNext()) {
    557. 				o1 = ot1.next();
    558. 				ids += o1.getObjectId() + ",";
    559.  
    560. 				// 第二次子节点
    561. 				BOIterator ot2 = o1.loadOBSChildren(new String[] { "ObjectId", "Name" }, null, null);
    562. 				while (ot2.hasNext()) {
    563. 					OBS o2 = ot2.next();
    564. 					ids += o2.getObjectId() + ",";
    565.  
    566. 					// 第三次子节点
    567. 					BOIterator ot3 = o2.loadOBSChildren(obsfields, null, null);
    568. 					while (ot3.hasNext()) {
    569. 						OBS o3 = ot3.next();
    570. 						ids += o3.getObjectId() + ",";
    571.  
    572. 						// 第四次子节点
    573. 						BOIterator ot4 = o3.loadOBSChildren(obsfields, null, null);
    574. 						while (ot4.hasNext()) {
    575. 							OBS o4 = ot4.next();
    576. 							ids += o4.getObjectId() + ",";
    577.  
    578. 							// 第五次子节点
    579. 							BOIterator ot5 = o4.loadOBSChildren(obsfields, null, null);
    580. 							while (ot5.hasNext()) {
    581. 								OBS o5 = ot5.next();
    582. 								ids += o5.getObjectId() + ",";
    583.  
    584. 								// 第六次子节点
    585. 								BOIterator ot6 = o5.loadOBSChildren(obsfields, null, null);
    586. 								while (ot6.hasNext()) {
    587. 									OBS o6 = ot6.next();
    588. 									ids += o6.getObjectId() + ",";
    589.  
    590. 									// 第七次子节点
    591. 									BOIterator ot7 = o6.loadOBSChildren(obsfields, null, null);
    592. 									while (ot7.hasNext()) {
    593. 										OBS o7 = ot7.next();
    594. 										ids += o7.getObjectId() + ",";
    595. 									}
    596. 								}
    597. 							}
    598. 						}
    599. 					}
    600. 				}
    601. 			}
    602. 		} catch (Exception e) {
    603. 			e.printStackTrace();
    604. 		} finally {
    605. 			if (session != null)
    606. 				session.logout();
    607. 		}
    608. 		return ids = ids.substring(0, ids.length() - 1);
    609. 	}
    610.  
    611. 	@SuppressWarnings("static-access")
    612. 	public String getProIds(String username) {
    613. 		// 传入条件查询参数
    614. 		String sWhereClause = "OBSObjectId in(" + getOBSChirdren(username) + ")", pids = "";
    615. 		Session session = null;
    616. 		try {
    617. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    618. 					apiserverport));
    619. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    620. 					dbInstances[0].getDatabaseId(), uname, password);
    621. 			String[] projfields = new Project(session).getAllFields();
    622.  
    623. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    624. 			BOIterator projIter = elm.loadProjects(projfields, sWhereClause, null);
    625.  
    626. 			while (projIter.hasNext()) {
    627. 				pids += projIter.next().getObjectId() + ",";
    628. 			}
    629. 		} catch (Exception e) {
    630. 			e.printStackTrace();
    631. 		} finally {
    632. 			if (session != null)
    633. 				session.logout();
    634. 		}
    635.  
    636. 		return pids.substring(0, pids.length() - 1);
    637. 	}
    638.  
    639. 	/**
    640. 	 * @Title: getProjectList 
    641. 	 * @Description: TODO
    642. 	 * @param @param username
    643. 	 * @param @return 
    644. 	 * @return List
    645. 	 * @throws
    646. 	 */
    647. 	public List getProjectList(String username) {
    648. 		List list = new ArrayList();
    649. 		String sWhereClause = "OBSObjectId in(" + getOBSChirdren(username) + ")";
    650. 		Session session = null;
    651. 		try {
    652. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    653. 					apiserverport));
    654. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    655. 					dbInstances[0].getDatabaseId(), uname, password);
    656. 			String[] projfields = new Project(session).getAllFields();
    657.  
    658. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    659. 			BOIterator projIter = elm.loadProjects(projfields, sWhereClause, null);
    660.  
    661. 			while (projIter.hasNext()) {
    662. 				Project p = projIter.next();
    663. 				NewProject np = new NewProject();
    664. 				np.setObjectid(p.getObjectId().toInteger());
    665. 				np.setId(p.getId());
    666. 				np.setName(p.getName());
    667.  
    668. 				list.add(np);
    669. 			}
    670. 		} catch (Exception e) {
    671. 			e.printStackTrace();
    672. 		} finally {
    673. 			if (session != null)
    674. 				session.logout();
    675. 		}
    676.  
    677. 		return list;
    678. 	}
    679.  
    680. 	/**
    681. 	 * @Title: getActivityPredecessors 
    682. 	 * @Description: TODO
    683. 	 * @param @param activityObjectId
    684. 	 * @param @return 
    685. 	 * @return List
    686. 	 * @throws
    687. 	 */
    688. 	public List getActivityPredecessors(Integer activityObjectId) {
    689. 		List list = new ArrayList();
    690. 		Session session = null;
    691. 		try {
    692. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    693. 					apiserverport));
    694. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    695. 					dbInstances[0].getDatabaseId(), uname, password);
    696. 			String[] rsfields = new Relationship(session).getAllFields();
    697.  
    698. 			BOIterator rsIter = new Activity(session, new ObjectId(activityObjectId)).loadPredecessorRelationships(rsfields,
    699. 					null, null);
    700.  
    701. 			while (rsIter.hasNext()) {
    702. 				Relationship re = rsIter.next();
    703. 				NewActivity nactv = new NewActivity();
    704. 				nactv.setObjectId(re.getPredecessorActivityObjectId().toInteger());
    705. 				nactv.setId(re.getPredecessorActivityId());
    706. 				nactv.setName(re.getPredecessorActivityName());
    707. 				nactv.setProjectId(re.getPredecessorProjectId());
    708. 				nactv.setWBSName(re.getPredecessorWbsName());
    709.  
    710. 				list.add(nactv);
    711. 			}
    712. 		} catch (Exception e) {
    713. 			e.printStackTrace();
    714. 		} finally {
    715. 			if (session != null)
    716. 				session.logout();
    717. 		}
    718. 		return list;
    719. 	}
    720.  
    721. 	/**
    722. 	 * @Title: userValidate 
    723. 	 * @Description: TODO
    724. 	 * @param @param username
    725. 	 * @param @return 
    726. 	 * @return int
    727. 	 * @throws
    728. 	 */
    729. 	private int userValidate(String username) {
    730. 		int result = -1;
    731. 		String sWhereClause = "Name = '" + username + "'";
    732. 		Session session = null;
    733. 		try {
    734. 			DatabaseInstance[] dbInstances = Session.getDatabaseInstances(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip,
    735. 					apiserverport));
    736. 			session = Session.login(RMIURL.getRmiUrl(RMIURL.STANDARD_RMI_SERVICE, apiserverip, apiserverport),
    737. 					dbInstances[0].getDatabaseId(), uname, password);
    738. 			String[] userfields = new User(session).getAllFields();
    739.  
    740. 			EnterpriseLoadManager elm = session.getEnterpriseLoadManager();
    741. 			// 检验P6系统是否存在该帐号
    742. 			BOIterator userIter = elm.loadUsers(userfields, sWhereClause, null);
    743.  
    744. 			while (userIter.hasNext()) {
    745. 				result = 0;
    746. 			}
    747. 			if (result == 0) {
    748. 				if (getUserOBSIds(username).length() > 0) {
    749. 					result = 1;
    750. 				}
    751. 			}
    752. 		} catch (Exception e) {
    753. 			e.printStackTrace();
    754. 		} finally {
    755. 			if (session != null)
    756. 				session.logout();
    757. 		}
    758. 		return result;
    759. 	}
    760. }

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

     

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

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

    直接引用接口方法

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

    1. using wsdemo.P6EPSWBSWebService;
    2. using wsdemo.P6ProjectWebService;
    3. using wsdemo.P6ActivityService;
    4.  
    5. namespace wsdemo
    6. {
    7.     public partial class epsdemo : System.Web.UI.Page
    8.     {
    9.         protected void Page_Load(object sender, EventArgs e)
    10.         {
    11.             
    12.             // 测试方法1（demo），根据项目代码获取项目名称
    13.             EPSWBSWebService epsService = new EPSWBSWebService();
    14.             Response.Write(epsService.demo("CS-Plan") + "
      "      );
    15.             P6EPSWBSWebService.NewEPS[] epss = epsService.loadEPS("kping");
    16.             for (int i = 0; i < epss.Length; i++)
    17.             {
    18.                 Response.Write(" --------------- 
      "      );
    19.                 Response.Write(" | EPS编号：" + epss[i].objectId);
    20.                 Response.Write(" | EPS编码：" + epss[i].id);
    21.                 Response.Write(" | EPS名称：" + epss[i].name);
    22.             }
    23.  
    24.              测试方法2（loadProjectByUser），根据用户登录名查询其所能看到的project
    25.             //ProjectWebService projservice = new ProjectWebService();
    26.             //P6ProjectWebService.NewProject[] projs = projservice.loadProjectByUser("kping");
    27.             //for (int i = 0; i < projs.Length; i++)
    28.             //{
    29.             //    Response.Write(" 项目加载测试--------------- 
      ");
    30.             //    Response.Write(" | 项目编号：" + projs[i].objectId);
    31.             //    Response.Write(" | 项目编码：" + projs[i].id);
    32.             //    Response.Write(" | 项目名称：" + projs[i].name);
    33.             //}
    34.  
    35.              测试方法3（loadAllActivities），根据查询某项目下所有作业信息
    36.             //ActivityWebService actvservice = new ActivityWebService();
    37.             //NewActivity[] actvs = actvservice.loadAllActivities(null, null, 644, true);
    38.             //for (int i = 0; i < actvs.Length; i++) {
    39.             //    Response.Write(" 项目加载测试--------------- 
      ");
    40.             //    Response.Write(" | 作业编号：" + actvs[i].objectId);
    41.             //    Response.Write(" | 作业编码：" + actvs[i].id);
    42.             //    Response.Write(" | 作业名称：" + actvs[i].name);
    43.             //    Response.Write(" | 作业计划开始：" + actvs[i].plannedStartDate);
    44.             //    Response.Write(" | 作业计划完成：" + actvs[i].plannedFinishDate);
    45.             //    Response.Write(" | 作业WBS编号：" + actvs[i].WBSObjectId);
    46.             //    Response.Write(" | 作业项目编号：" + actvs[i].projectObjectId);
    47.             //}
    48.  
    49.              测试方法4（updateActivity），修改作业信息
    50.             //NewActivityDetail a1 = actvservice.getActivityDetail(51992, true);
    51.             //a1.activity.name = "ABCDEFGG";
    52.             //a1.activity.plannedStartDate = "2016-03-10";
    53.             //Response.Write("name2： " + a1.activity.name);
    54.             //actvservice.updateActivity(a1.activity);
    55.  
    56.              测试方法5（addActivityDirect），增加作业信息
    57.             //NewActivity new1 = new NewActivity();
    58.             //new1.objectId = 160322003;;
    59.             //new1.WBSObjectId = 11391;
    60.             //new1.name = "测试号";
    61.             //new1.id = "AX001002004";
    62.             //new1.name = "测试作业名称2";
    63.             //new1.plannedStartDate = "2016-01-01";
    64.             //new1.plannedFinishDate = "2016-01-06";
    65.             //new1.actualStartDate = "2016-01-02";
    66.             //actvservice.addActivityDirect(new1);
    67.         }
    68.     }
    69. }

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

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

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

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

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

  • 相关阅读:
    分享66个Python管理系统源代码总有一个是你想要的
    C# WPF入门学习主线篇（三十三）—— 使用ICommand实现命令绑定
    Vue2与Vue3实例的深入比较：响应式系统、模板编译和性能分析
    spoof_call的分析与改进
    Python 08学习之文件操作
    高级篇之ENC1V2新用法USB/RS232串口转Visca-Over-IP
    QGIS添加在线底图
    JDBC学习笔记（2）事务
    第三章 解析python中opencv，matpoltlib与pillow对JPG和PNG读取和写入(工具)
    k8s存储卷 PV和PVC
  • 原文地址：https://blog.csdn.net/kping0306/article/details/127738584