项目交接洛阳短信平台方案

1、洛阳建设方案说明：因为MAS 每天凌晨会重启，故在MAS 服务器设置了定时计划任务每天凌晨00:05 定时调用 kettle 根路径下的mas.bat，执行抽取数据到MAS 服务器的JOB。1.洛阳内网端1.1 在 42 建立待发数据库(T)，用户在使用时，只需要在该数据库数据即可。数据库用户信息如下表：1.2kettle 方案设计1.2.1 JOB建立Job（抽取数据为文件并上传到FTP），包含以下组件START：重复，时间间隔，20 秒执行一次。Evaluate rows number in a table（检查表中是否有数据）：检查SMSSENDTASK 表中是否有数据，没有的话不执行以

2、后的组件。避免生成空的 XML 文件。Transformation(抽取 142 数据为文件并备份)：抽取 142 的数据为文件并备份。Put a file with FTP(将文件上传到FTP)：IP=59，username=luoy，password=luoL6，本地目录=D:T_SMSSENDTASK，勾选属性remove filesafter transferal，remote directory=/1.2.2 TRAN表输入（抽取 142 上的待发表）：将 142 上表 SMSSENDTASK 查出来传递给XML输出及备份抽走的数据两个步骤。XML 输出：文件名称=D:T_SMSSE

3、NDTASK_masfile，扩展=.xml，在文件名中包含日期=勾选，在文件名中包含时间=勾选。注：字段中eger 格式的数据要设定格式为#,否则string 转换成整形。文件的时候会报错，不能讲数据库用户名说明sysoracle管理员用户lytlyt业务用户kettlekettle 方案库表输出（备份抽走的数据）：将抽取的数据输出到XML 同时备份到SMSSENDTASK_BAK 中。删除（删除抽走的数据）：根据AP_SEQ_ID 字段删除SMSSENDTASK 表中的数据。1.3 表信息1.3.1SMSSENDTASK待发表create table SMSSENDTASK(AP_SEQ_

4、IDNUMBER(10) not null,REQFLAGNUMBER(11),SM_IDVARCHAR2(50),MSG_IDVARCHAR2(50),PK_TOTALNUMBER(11),PK_NUMBERNUMBER(11),REG_DELIVERY NUMBER(11),MSG_LEVELNUMBER(11),SEVICE_IDCHAR(10),FEE_USERTYPE NUMBER(8),FEE_TERM_ID VARCHAR2(32),FEE_TERM_TYPE NUMBER(11),TP_NUMBER(11),TP_UDHINUMBER(11),MSG_FMTNUMBER(11)

5、,MSG_SRCVARCHAR2(6),FEE_TYPECHAR(2),FEE_CODECHAR(6),VALID_TIMEDATE,AT_TIMEDATE,REP_TIMESNUMBER(11),SENDED_TIMES NUMBER(11),REP_ERVAL NUMBER(11),SRC_IDVARCHAR2(21),DESTUSR_TLNUMBER(11),DEST_TERM_ID VARCHAR2(3300),DEST_TERM_TYPE NUMBER(11),MSG_LENNUMBER(11),MSG_CONTENT VARCHAR2(4000),LINKIDVARCHAR2(20

6、),RESERVEVARCHAR2(8),SND_TIMEDATE,SNDRESULTNUMBER(8),QUERY_TYPENUMBER(8),QUERY_CODEVARCHAR2(10),USERIDVARCHAR2(20),TITLEVARCHAR2(500),SVR_FLAGVARCHAR2(50),SND_TYPENUMBER(1),APP_SRC_IDVARCHAR2(21),SEND_METHOD VARCHAR2(50),PARA_1VARCHAR2(200),PARA_2VARCHAR2(200),PARA_3VARCHAR2(200),PARA_4VARCHAR2(200)

7、,PARA_5VARCHAR2(200),F_TYPEVARCHAR2(100),BIZ_IDVARCHAR2(100),SUB_BIZ_IDVARCHAR2(100),BIZ_SEQIDVARCHAR2(100),APP_IDVARCHAR2(10),DB_FLAGNUMBER(1),FLAGVARCHAR2(2)tablespaceTpctfree 10initrans 1maxtrans 255storage(initial 64minextents 1maxextents unlimited);- Add comments to the columnscomment on column

8、 SMSSENDTASK.AP_SEQ_IDis 应用序列号,需要从sequen表中把tbname=smssendtask 的中的seq+1,然后再放入该字段;comment on column SMSSENDTASK.REQFLAGis 命令类型;comment on column SMSSENDTASK.MSG_IDis 消息 ID 网关返回生成;comment on column SMSSENDTASK.PK_TOTALis 相同Msg_Id 的信息总条数;comment on column SMSSENDTASK.PK_NUMBERis 相同Msg_Id 的信息序号;comment o

9、n column SMSSENDTASK.REG_DELIVERYis 状态标志;comment on column SMSSENDTASK.MSG_LEVELis 信息级别;comment on column SMSSENDTASK.SEVICE_IDis 业务标识;comment on column SMSSENDTASK.FEE_TERM_IDis 被计费用户的号码;comment on column SMSSENDTASK.FEE_TERM_TYPEis 被计费用户的号码类型;comment on column SMSSENDTASK.TP_is GSM 协议类型;comment on

10、 column SMSSENDTASK.TP_UDHIis GSM 协议类型;comment on column SMSSENDTASK.MSG_FMTis 信息格式;comment on column SMSSENDTASK.MSG_SRCis 信息内容来源;comment on column SMSSENDTASK.FEE_CODEis 资费代码;comment on column SMSSENDTASK.VALID_TIMEis 存活有效期;comment on column SMSSENDTASK.AT_TIMEis 定时发送时间;comment on column SMSSENDTA

11、SK.REP_TIMESis 重发次数;comment on column SMSSENDTASK.SENDED_TIMESis 已经发送次数;comment on column SMSSENDTASK.REP_ERVALis 重发间隔;comment on column SMSSENDTASK.SRC_IDis 源号码;comment on column SMSSENDTASK.DESTUSR_TLis 接收信息的用户数量;comment on column SMSSENDTASK.DEST_TERM_IDis 接收的MSISDN 号码(号);comment on column SMSSEN

12、DTASK.DEST_TERM_TYPEis 接收的用户的号码类型;comment on column SMSSENDTASK.MSG_LENis 信息长度;comment on column SMSSENDTASK.MSG_CONTENTis 信息内容;comment on column SMSSENDTASK.RESERVEis 保留字段;comment on column SMSSENDTASK.SND_TIMEis 发送时间;comment on column SMSSENDTASK.QUERY_TYPEis 查询类别;comment on column SMSSENDTASK.QUE

13、RY_CODEis 查询码;comment on column SMSSENDTASK.USERIDis MAS 中的发送用户 ID;comment on column SMSSENDTASK.SND_TYPEis 发送类型 0-普通1-批量2-批量分发;comment on column SMSSENDTASK.APP_SRC_IDis 应用源号码;comment on column SMSSENDTASK.F_TYPEis 接口类型;comment on column SMSSENDTASK.BIZ_IDis 业务id;comment on column SMSSENDTASK.SUB_B

14、IZ_IDis 子业务id;comment on column SMSSENDTASK.BIZ_SEQIDis 业务序号;comment on column SMSSENDTASK.APP_IDis 应用 ID;comment on column SMSSENDTASK.DB_FLAGis 数据库插件是否处理标记 0:未处理,1:回执处理,2:状态回执处理;- Create/Recreate primary, unique and foreign key constrasalter table SMSSENDTASKadd constraPK_SST primary key (AP_SEQ_I

15、D)using indextablespaceTpctfree 10initrans 2maxtrans 255storage(initial 64Kminextents 1maxextents unlimited);1.3.2SMSSENDTASK备份抽成文件的数据相比于 SMSSENDTASK 增加字段 IN_TIME（date），用户数据抽成文件具体时间。1.4 其他INSERTO smssendtask VALUES(sst_seq.nextval, 4, , ,1, 1, 1,0, MHA4910101, 0, , null, 0, 0, 15, 447336, 01, , null

16、,null, null, 0, null, 106573379110, 1, , 0, null, 市局测试123456, ,null,sysdate, null, null, null, admin, null, null, 0, null, normal, null, null, 1, null, null,mas, mutisend, , , 0007, 0, null);只需要执行该SQL，修改其中调用机号和内容两个字段即可。2.省厅端2.1 在 1（71）建立待发数据库(T)，用户在使用时，MAS 服务器从该库抽取待发数据。数据库用户信息如下表：2.2kettle 方案2.2.1JO

17、BSTART：重复，时间间隔，20 秒执行一次。Transformation（XML 数据）：XML 数据待表和备份表。数据库用户名说明sysoracle管理员用户t业务用户kettlekettle 方案库Copy or move result filenames:将remove source filenames from=勾选。过的XML 文件移动到备份文件夹，action=move，2.2.2TRANXML 文件，将数据SMSSENDTASK 表和SMSSENDTASK_IN_BAK 表Get data from XML(XML 文件)：file or directory=F:lywsga

18、stftpnw_to_ww，regular express=masfile.*.xml。XML 配置的loop path 是ROWS/ROW/，而不是根节点注意：表）：将数据SMSSENDTASK 表。表输出（待）：将数据到SMSENDTASK_IN_BAK 表，增加字段表输出（备份IN_TIME 用于的的数据什么时候到 171 上待表的。2.2.3 表信息SMSSENDTASK：待表，MAS 服务器从该表抽数据。SMSSEDNTAKS_IN_BAK：增加字段 IN_TIME 用于到 171的数据什么时候上待表的。SMSSENDTASK_OUT_BAK：修改字段名 USERID 为UID，增加字段 OUT_TIME，用于记录数据时什么时间抽取到MAS 的。3.MAS 服务器端3.1 在该服务器上没有建表，kettle 信息都在 1:1521 上。MAS桌面地址：0:9937，用户名：administrator/LYSGAJlyyd!)*MAS 数