TDS-Java主控编写文档.doc

TDS Developers GuideTDS Java主控开发文档（TDS 1.0）产品研发部2012年11月文档信息及修订记录项目名称项目编号文档密级内部项目经理项目总监文档主送文档抄送修 订 人修订日期修订说明版本号马超2011-11-25 初稿1.0填写说明：1、 项目名称、项目编号、项目经理、项目总监按照本项目实际情况填写。2、 文档密级是该文档允许扩散的范围。对于交通银行，机密文件必须由信息科技部经理室批准方可借阅；秘密文件必须由项目负责人批准方可借阅；内部文件经一般授权后可由在项目组内部传阅；公开文件不需经过授权，可自由进行阅读。对于棠棣公司，机密文件、秘密文件必须由银行产品事业部经理室批准方可借阅；内部文件经一般授权后可由在公司内部和项目组内部传阅；公开文件不需经过授权，可自由进行阅读。3、 文档主送是指该文档应该主送的对象，双方项目总监、项目经理是该文档必须主送的对象之一。4、 文档抄送是指该文档应该抄送的对象，项目管理组是该文档应该抄送的对象之一。5、 版本号是指该文档的版本次序号，该文档首次发布时可确定为1.0，如果在上一版的基础上有细微的调整和修改，则可在小数点后次版本号加1；如果该文档内容总体上有重大变化或增加/删除了重要章节，则小数点主版本号加1。 目录1TDS Java主控开发41.1注解使用说明41.2主控编写注意41.3主控部署说明51.3.1生成的类存放51.3.2注意事项121 TDS Java主控开发 TDS平台是棠棣中间业务平台的简称。 该平台主要用于银行和第三方支付相关系统的基础平台，在此基础之上可用于如下平台或系统的架构：综合前置平台、设备前置平台、通讯前置平台、中间业务平台、支付结算业务平台、第三方支付网关等。其中中间业务平台，用于实现银行方面的代收公共事业费，代理财政支付，财政非税代收等功能；支付结算业务平台，用于实现同城电子交换业务，电子商业汇票，现代化支付系统等功能。1.1 注解使用说明定义方式：注解1：Data示例：Data String phone； Data注解表示为Etf字段注解2：tangdi.engine.DB 使用说明：在交易定义上使用，则交易可以直接进行DB数据库操作注解3：AroundInvoke注解的方法，将在交易调用前后调用；注解4：code（“交易码”）注解的方法，即为主控交易1.2 主控编写注意常使用的方法已经在TdAtcForJava.jar中定义过，编辑器中开发时，新建主控文件后，将会自动生成一段代码，包括import常用的jar包方法；原子函数调用，用户直接Atc.方法名即可；普通表达式的调用，引入表达式包后，即可使用静态表达式函数进行处理；用户也可以自定义自己的方法，在主控类中自由使用；1.3 主控部署说明1.3.1 生成的类存放用户在IDE开发环境中，编写完成自己的Java主控后，编译器会自动生成classes文件夹，将文件夹copy到TDS实例的app应用下即可；在app.xml里配置：注意事项：1：natures里添加javaengine；2：transactions交易节点中，配置新增加的class配置用 配置，写法：包名全路径+文件名示例： xyService.Proxypackage xyService;import java.util.List;import javax.annotation.PreDestroy;import erceptor.AroundInvoke;import erceptor.InvocationContext;import mons.lang.StringUtils;import org.dom4j.Element;import tangdi.annotations.Code;import tangdi.atc.Atc;import tangdi.engine.context.Etf;import tangdi.engine.context.Msg;import tangdi.log.ILog;tangdi.engine.DB/* * # Proxy.java Create on 2012-1-10 上午9:55:46 * * 类功能说明: * 代理商信息管理 * * Copyright: Copyright(c) 2012 * * * Company: 上海棠棣 * * Version 1.0 * Author 王龙军 * */public class Proxy PreDestroyvoid pre() AroundInvokepublic Object around(InvocationContext ic) throws Exception Msg.dump();Object obj = ceed();Msg.dump(); / return obj;/* * code 466701 * 代理商信息添加 * param logger */Code(466701)erceptor.Logpublic void createRole(ILog logger) try String sql = insert into PRYPROXY(AGE_MERCH_ID,AGE_PWD,AGE_NAME,ADDRESS,POST_CODE,FLAG,EMAIL,COMM_PER,TELEPHONE,IP_LIMIT,AGE_DATE,SET_PER,LAST_DATE,LAST_PER,DESCRIPTIONS) values(+ Etf.getChildValue(AGE_MERCH_ID)+ ,+ Etf.getChildValue(AGE_PWD)+ ,+ Etf.getChildValue(AGE_NAME)+ ,+ Etf.getChildValue(ADDRESS)+ ,+ Etf.getChildValue(POST_CODE)+ ,+ Etf.getChildValue(FLAG)+ ,+ Etf.getChildValue(EMAIL)+ ,+ Etf.getChildValue(COMM_PER)+ ,+ Etf.getChildValue(TELEPHONE)+ ,+ Etf.getChildValue(IP_LIMIT)+ ,+ Etf.getChildValue(AGE_DATE)+ ,+ Etf.getChildValue(SET_PER)+ ,+ Etf.getChildValue(LAST_SAFT_DATE)+ ,+ Etf.getChildValue(LAST_SAFT_PER)+ ,+ Etf.getChildValue(DESCRIPTIONS) + );(%s, sql);(%s, 执行数据库添加操作);int count = Atc.ExecSql(null, sql);if (count = 0) Etf.setChildValue(MsgTyp, N);Etf.setChildValue(RspCod, 00000);Etf.setChildValue(RspMsg, 修改成功);if (count = 2) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0003);Etf.setChildValue(RspMsg, 执行本函数后改变数据表记录数为0);return;if (count = 3) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0002);Etf.setChildValue(RspMsg, 违反数据唯一性); catch (Exception ex) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0005);Etf.setChildValue(RspMsg, 数据库字段不一致);/* * code 466702 * 代理商信息删除:伪删除 * param logger */Code(466702)erceptor.Logpublic void delPry(ILog logger) try String sql = update PRYPROXY set FLAG=+ Etf.getChildValue(FLAG) + where AGE_MERCH_ID=+ Etf.getChildValue(AGE_MERCH_ID) + ;int count = Atc.ExecSql(null, sql);if (count = 0) Etf.setChildValue(MsgTyp, N);Etf.setChildValue(RspCod, 00000);Etf.setChildValue(RspMsg, 修改成功);if (count = 2) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0003);Etf.setChildValue(RspMsg, 执行本函数后改变数据表记录数为0);return; catch (Exception ex) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0005);Etf.setChildValue(RspMsg, 数据库字段不一致);/* * code 466703 * 代理商信息修改 * param logger */Code(466703)erceptor.Logpublic void updatePry(ILog logger) try String sql = update PRYPROXY set AGE_PWD=+ Etf.getChildValue(AGE_PWD) + ,AGE_NAME=+ Etf.getChildValue(AGE_NAME) + ,ADDRESS=+ Etf.getChildValue(ADDRESS) + ,POST_CODE=+ Etf.getChildValue(POST_CODE) + ,FLAG=+ Etf.getChildValue(FLAG) + ,EMAIL=+ Etf.getChildValue(EMAIL) + ,COMM_PER=+ Etf.getChildValue(COMM_PER) + ,TELEPHONE=+ Etf.getChildValue(TELEPHONE) + ,IP_LIMIT=+ Etf.getChildValue(IP_LIMIT) + ,AGE_DATE=+ Etf.getChildValue(AGE_DATE) + ,SET_PER=+ Etf.getChildValue(SET_PER) + ,LAST_DATE=+ Etf.getChildValue(LAST_SAFT_DATE) + ,LAST_PER=+ Etf.getChildValue(LAST_SAFT_PER) + ,DESCRIPTIONS=+ Etf.getChildValue(DESCRIPTIONS)+ where AGE_MERCH_ID=+ Etf.getChildValue(AGE_MERCH_ID) + ;int count = Atc.ExecSql(null, sql);if (count = 0) Etf.setChildValue(MsgTyp, N);Etf.setChildValue(RspCod, 00000);Etf.setChildValue(RspMsg, 修改成功);if (count = 2) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0003);Etf.setChildValue(RspMsg, 执行本函数后改变数据表记录数为0);return; catch (Exception ex) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0005);Etf.setChildValue(RspMsg, 数据库字段不一致);/* * code 466704 * 代理商信息查询 按名称，代理商商户号，启用状态查询 * param logger */Code(466704)erceptor.Logpublic void selectPry(ILog logger) try StringBuffer sql = new StringBuffer(select AGE_MERCH_ID,AGE_PWD,AGE_NAME,ADDRESS,POST_CODE,FLAG,EMAIL,COMM_PER,TELEPHONE,IP_LIMIT,AGE_DATE,SET_PER,LAST_DATE,LAST_PER,DESCRIPTIONS from PRYPROXY where 1=1);String idname = Etf.getChildValue(AGE_MERCH_ID);String flag = Etf.getChildValue(FLAG);String agename = Etf.getChildValue(AGE_NAME);(agename=%s, agename);(idname=%s, idname);(falg=%s, flag);if (StringUtils.isNotEmpty(idname) if (StringUtils.isNotEmpty(flag) if (StringUtils.isNotEmpty(agename) sql.append( and AGE_MERCH_ID= + idname+ and AGE_NAME= + agename + and FLAG=+ flag + ); else sql.append( and AGE_MERCH_ID= + idname+ and FLAG= + flag + ); else if (StringUtils.isNotEmpty(agename) sql.append( and AGE_MERCH_ID= + idname+ and AGE_NAME= + agename + ); else sql.append( and AGE_MERCH_ID= + idname + ); else if (StringUtils.isNotEmpty(flag) if (StringUtils.isNotEmpty(agename) sql = sql.append( and AGE_NAME= + agename+ and FLAG= + flag + ); else sql = sql.append( and FLAG= + flag + ); else if (StringUtils.isNotEmpty(agename) sql = sql.append( and AGE_NAME= + agename + );(sql=%s, sql.toString();int result = Atc.QueryInGroup(sql.toString(), null, 10);if (result = 0) Etf.setChildValue(MsgTyp, N);Etf.setChildValue(RspCod, 00000);Etf.setChildValue(RspMsg, 查询成功); else if (result = 2) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0004);Etf.setChildValue(RspMsg, 无记录); else Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0001);Etf.setChildValue(RspMsg, 查询失败); catch (Exception e) / TODO Auto-generated catch blocke.printStackTrace();/* * code 466705 * 代理商信息浏览 * param logger */Code(466705)erceptor.Logpublic void findPry(ILog logger) String sql = select AGE_MERCH_ID,AGE_PWD,AGE_NAME,ADDRESS,POST_CODE,FLAG,EMAIL,COMM_PER,TELEPHONE,IP_LIMIT,AGE_DATE,SET_PER,LAST_DATE,LAST_PER,DESCRIPTIONS from PRYPROXY;try int result = Atc.QueryInGroup(sql, null, count);if (result = 0) Etf.setChildValue(MsgTyp, N);Etf.setChildValue(RspCod, 00000);Etf.setChildValue(RspMsg, 查询成功); else if (result = 2) Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0004);Etf.setChildValue(RspMsg, 无记录); else Etf.setChildValue(MsgTyp, E);Etf.setChildValue(RspCod, P0001);Etf.setChildValue(RspMsg, 查询失败