|
Передача письма с вложением. Готовое решение
#38544489
Ссылка:
Ссылка на сообщение:
Ссылка с названием темы:
|
|
|
|
Доработал процедуру получения почты, теперь не падает и не виснет при больших входящих письмах
GET_MAIL
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
141.
142.
143.
144.
145.
146.
147.
148.
149.
150.
151.
152.
153.
154.
155.
156.
157.
158.
159.
160.
161.
162.
163.
164.
165.
166.
PROCEDURE GET_MAIL(mail_id number,lines number default null) IS
answer varchar2(32767);
content_bufer varchar2(32767);
cnt number;
bytes number;
status varchar2(25);
message_body clob;
hdr_flag boolean;
hdr_entity varchar2(255);
hdr_entity_value varchar2(32717);
boundary varchar2(128);
part_header_flag boolean:=false;
any_boundary_found boolean:=false;
any_boundary_found_close boolean:=false;
BEGIN
IF MAIL_PKG.protocol != MAIL_PKG.POP3 THEN
RAISE_APPLICATION_ERROR(-20000,'This feauture is not realised yet in proto '||MAIL_PKG.protocol);
END IF;
CMD(c,'LIST '||mail_id,status,answer); -- get message size
MAILBOX(mail_id).bytes:=to_number(trim(substr(answer,instr(answer,' '))));
IF MAILBOX(mail_id).bytes >= 1048576 THEN
PDEBUG('BUG: Message '|| mail_id ||' over 1Mb, ' || MAILBOX(mail_id).bytes || ' bytes' ,mail_pkg.debug_errors);
END IF;
CMD(c,CASE WHEN lines is NULL THEN 'RETR '||mail_id ELSE 'TOP '||mail_id||' 10' END,status,answer); -- read message headers
BEGIN
hdr_entity:='';hdr_entity_value:='';
hdr_flag := true;
if lines<>0 or lines is null then
MAILBOX(mail_id).message:='';
MAILBOX(mail_id).attachments := t_attachments();
end if;
dbms_lob.createtemporary(lob_loc => MAILBOX(mail_id).message, cache => true, dur => dbms_lob.call);
LOOP
answer :=utl_tcp.get_line(c, TRUE); -- read result
EXIT WHEN answer = '.';
IF answer IS NULL THEN hdr_flag := false; END IF;
IF hdr_flag THEN
IF ascii(substr(answer,0,1)) NOT IN (9,32) THEN
hdr_entity := substr(answer,1,instr(answer,':')-1);
MAILBOX(mail_id).HDR(hdr_entity):='';
hdr_entity_value := substr(answer,instr(answer,':')+2);
ELSE
hdr_entity_value := substr(answer,2);
END IF;
PDEBUG('HDR:'|| answer);
MAILBOX(mail_id).HDR(hdr_entity):= MAILBOX(mail_id).HDR(hdr_entity)
|| MIME_DECODE(hdr_entity_value);
IF hdr_entity = 'Content-Type' THEN
if instr(answer,'boundary="')>0 then
extract_value(boundary,answer,'boundary');
end if;
END IF;
ELSE
any_boundary_found := false;
any_boundary_found_close := false;
IF MAILBOX(mail_id).attachments.count>0 THEN
FOR incls IN MAILBOX(mail_id).attachments.first .. MAILBOX(mail_id).attachments.last
LOOP
if answer = '--' || MAILBOX(mail_id).attachments(incls).boundary then
any_boundary_found := true;
end if;
if answer = '--' || MAILBOX(mail_id).attachments(incls).boundary || '--' then
any_boundary_found_close := true;
end if;
END LOOP;
END IF;
if length(answer)=0 and length(content_bufer)>0 then
DBMS_LOB.APPEND ( MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).content, content_bufer);
end if;
if boundary is not null and
( answer = '--' || boundary
or
any_boundary_found
)
then
part_header_flag:=true;
MAILBOX(mail_id).attachments.extend();
dbms_lob.createtemporary(lob_loc => MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).content, cache => true, dur => dbms_lob.call);
elsif boundary is not null and
( answer = '--' || boundary || '--'
or
any_boundary_found_close
)
then
null;
elsif part_header_flag and answer is null then
part_header_flag:=false;
else
IF part_header_flag THEN
IF ascii(substr(answer,0,1)) NOT IN (9,32) THEN
hdr_entity := substr(answer,1,instr(answer,':')-1);
MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).HDR(hdr_entity):='';
hdr_entity_value := substr(answer,instr(answer,':')+2);
ELSE
hdr_entity_value := substr(answer,2);
END IF;
MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).HDR(hdr_entity):=
MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).HDR(hdr_entity)
|| MIME_DECODE(hdr_entity_value);
IF hdr_entity = 'Content-Type' THEN
extract_value(MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).boundary,answer,'boundary');
extract_value(MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).charset,answer,'charset');
-- PDEBUG(MAILBOX(mail_id).includes(MAILBOX(mail_id).includes.last).charset,mail_pkg.debug_messages);
ELSIF hdr_entity = 'Content-Transfer-Encoding' THEN
MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).ContentTransferEncoding := hdr_entity_value;
END IF;
ELSE
-- BUG: BIG messages is very slow and prc can get "[SYS/PERM] Fatal error: Lost connection to input stream"
-- IF MAILBOX(mail_id).bytes < 1048576 THEN
IF MAILBOX(mail_id).attachments.count>0 THEN
if length(answer)>0 then
if length(content_bufer||answer) >= 32767 then
DBMS_LOB.APPEND ( MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).content, content_bufer);
content_bufer := PARSE_LINE( answer
,MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).ContentTransferEncoding
,MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).charset);
else
content_bufer := content_bufer||PARSE_LINE( answer
,MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).ContentTransferEncoding
,MAILBOX(mail_id).attachments(MAILBOX(mail_id).attachments.last).charset);
end if;
end if;
ELSE
IF length(answer)>0 THEN
DBMS_LOB.APPEND (MAILBOX(mail_id).message,answer);
END IF;
END IF;
-- END IF;
END IF;
PDEBUG(CASE part_header_flag WHEN TRUE THEN 'H' ELSE 'B' END || '-BODY:'||answer);
end if;
END IF;
END LOOP;
EXCEPTION
WHEN OTHERS THEN
PDEBUG('ERR: GET MESSAGE ' ||mail_id || ' ERROR ',mail_pkg.debug_errors);
RAISE;
END;
IF MAILBOX(mail_id).HDR.EXISTS('From') THEN
MAILBOX(mail_id).MailFrom := MAILBOX(mail_id).HDR('From');
END IF;
IF MAILBOX(mail_id).HDR.EXISTS('MailTo') THEN
MAILBOX(mail_id).MailTo := MAILBOX(mail_id).HDR('To');
END IF;
IF MAILBOX(mail_id).HDR.EXISTS('Return-Path') THEN
MAILBOX(mail_id).ReturnPath := MAILBOX(mail_id).HDR('Return-Path');
END IF;
IF MAILBOX(mail_id).HDR.EXISTS('Subject') THEN
MAILBOX(mail_id).Subject := MAILBOX(mail_id).HDR('Subject');
END IF;
IF MAILBOX(mail_id).HDR.EXISTS('Date') THEN
BEGIN
MAILBOX(mail_id).MailDate := TO_TIMESTAMP_TZ(MAILBOX(mail_id).HDR('Date'),'Dy, DD Mon YYYY HH24:MI:SS TZHTZM','NLS_DATE_LANGUAGE = ''american''');
EXCEPTION WHEN OTHERS THEN NULL; END;
END IF;
END;
|
|
|
