--传入的参数：inbuf
--传出的长度：outret
--传出的报文内容（新银电联网 报文体<1000 字节）,内容放到此变量：outstr
--传出的报文内容(新银电联网 报文体 >1000 字节)，内容放到游标：io_cursor
CREATE OR REPLACE PROCEDURE "CALLC_NEWBANK_CURSOR" (inbuf in varchar2,outret out number,outstr out varchar2,io_cursor out REFCURSOR_PKG.PHONE_REF_CURSOR) is
sServIp varchar2(16);
iServPort number(6);
iTimeout number(3);
sHead varchar2(6);
sMac varchar2(21);
socket utl_tcp.connection;
iLength number(6);
iRecvLen number(6);
rcvbuf varchar2(2000);
iSubLen number(6);
iGetLen number(6);
iCNT number(6);
lSeqn number(17);
iLenRcv number(6);
begin
sServIp := '172.16.2.89';
iServPort := 9217;
iTimeout := 100;
rcvbuf := '';
sMac := '';
outstr := '';
lSeqn := 0;
socket := utl_tcp.open_connection(sServIp,
iServPort,
NULL,
NULL,
NULL,
NULL,
NULL,
NULL,
iTimeout);
if utl_tcp.write_text(socket, inbuf) <> length(inbuf) then
utl_tcp.close_connection(socket);
outret := -1;
return;
end if;
utl_tcp.flush(socket);
if utl_tcp.read_text(socket, sMac, 20) <> 20 then
utl_tcp.close_connection(socket);
outret := -1;
return;
end if;
if utl_tcp.read_text(socket, sHead, 5) <> 5 then
utl_tcp.close_connection(socket);
outret := -1;
return;
end if;
iSublen:=0;
iCNT:=0;
iLength := to_number(sHead, '99999');
while iSubLen < iLength LOOP
BEGIN
iGetLen := iLength - iSubLen;
rcvbuf := '';
iCNT := iCNT + 1;
if iGetLen > 1000 then
iGetLen := 1000 ;
end if;
iRecvLen := utl_tcp.read_text(socket, rcvbuf, iGetLen);
if iRecvLen<0 then
utl_tcp.close_connection(socket);
outret := -1;
return;
end if;
iLenRcv := lengthb(rcvbuf);
if iLength>1000 then
if iCNT = 1 then
select SEQ_I_PHONE_MSG_ID.NEXTVAL into lSeqn from dual;
rcvbuf := sHead || rcvbuf;
rcvbuf := sMac || rcvbuf;
end if;
insert into i_phone_msg values(lSeqn,iCNT,sysdate,rcvbuf);
else
rcvbuf := sHead || rcvbuf;
rcvbuf := sMac || rcvbuf;
outstr := rcvbuf;
end if;
/*dbms_output.put('rcvbuf=');
dbms_output.put_line(rcvbuf);*/
iSubLen := iSubLen+iLenRcv;
END;
END LOOP;
open io_cursor FOR
select msg_seq,msg_context from i_phone_msg where msg_id = lSeqn order by msg_seq asc;
outret := iLength+5+20;
utl_tcp.close_connection(socket);
return;
EXCEPTION
when utl_tcp.NETWORK_ERROR then
outret := -1;
return ;
end CALLC_NEWBANK_CURSOR;
评论0