Q5/ws_objects/Ew_email.pbl.src/uo_email.sru

$PBExportHeader$uo_email.sru
forward
global type uo_email from nonvisualobject
end type
end forward

global type uo_email from nonvisualobject
event ue_revemail ( )
end type
global uo_email uo_email

type variables
//string fjfilepathname = 'fjtemp'
//s_email_set s_set[],cur_set
//long sumcnt
//long finishcnt 

Transaction commit_tran

Transaction fj_tran




string C_Sys_admsg_fj = 'Sys_admsg_fj'
string C_u_email_fj = 'u_email_fj'
string C_from_file = 'from_file'
end variables

forward prototypes
public function integer f_update_send (long arg_sendid, datetime arg_senddate, long arg_mailsize, ref string arg_msg)
public function integer f_check_rep (ref s_email_sendmx arg_sendmx, ref string arg_msg)
public function integer f_send (s_email_set arg_set, s_email_send arg_send, s_email_sendmx arg_sendmx, s_email_fj arg_fj, ref string arg_msg)
public function integer uf_get_send (long arg_sendid, ref s_email_send arg_s_send, ref string arg_msg)
public subroutine wf_str_replace (ref string arg_source, string arg_str1, string arg_str2)
public function integer wf_mail_gethtml (long arg_msgid, ref string arg_text, ref string arg_msg)
public function integer uf_get_sendmx (long arg_sendid, ref s_email_sendmx arg_sendmx[], ref string arg_msg)
public function integer wf_mail_getfjblob (long arg_fjid, ref blob arg_fjblob, ref string arg_msg)
public function integer uf_get_fj (long arg_relid, ref s_email_lvfj arg_lvfj[], ref string arg_msg, boolean arg_withblob)
public function integer wf_admsg_getfjblob (long arg_fjid, ref blob arg_fjblob, ref string arg_msg)
public function integer f_del (long arg_id, ref string arg_msg)
public function integer wf_ds_get_mail_set (long arg_mailid, ref s_email_set arg_set, ref string arg_msg)
public function long wf_ds_gettrunkbox (long arg_mailid)
public function long wf_ds_getsendbox (long arg_mailid)
public function string wf_ds_getuser (long arg_id)
public function string wf_ds_getaddress (long arg_id)
public function string wf_ds_getuseraddress (long arg_id)
public function integer wf_ds_move_msg_box (long arg_id, long arg_boxid, ref string arg_msg)
public function integer f_del_move_msg (long arg_id, ref string arg_msg)
public function integer f_unread (long arg_revid, ref string arg_msg)
public function integer f_read (long arg_revid, ref string arg_msg)
public function long f_save (ref s_email_send arg_send, s_email_sendmx arg_sendmx[], s_email_lvfj arg_fj[], ref string arg_msg)
public function long f_import_eml (ref s_email_send arg_send, s_email_lvfj arg_fj[], ref string arg_msg)
public function integer f_change_id (long arg_fromid, long arg_toid, ref string arg_msg)
end prototypes

event ue_revemail();//Long i
//string ls_msg
//FOR i = 1 TO sumcnt
//	IF pf_revemail(s_set[i],ls_msg) = 0 THEN
//
//	END IF
//NEXT
//
end event

public function integer f_update_send (long arg_sendid, datetime arg_senddate, long arg_mailsize, ref string arg_msg);Long rslt = 1

//UPDATE u_email_send
//	SET senddate = :arg_senddate,
//	mailsize = :arg_mailsize,
//	mailtype = 1
//	Where u_email_send.sendid = :arg_sendid
//	and not exists (select 0 from u_email_sendmx where sendid = u_email_send.sendID and status = 0)
//	using commit_tran;
//IF commit_tran.SQLCode <> 0 THEN
//	rslt = 0
//	arg_msg = '更新邮件信息失败'
//END IF

RETURN rslt

end function

public function integer f_check_rep (ref s_email_sendmx arg_sendmx, ref string arg_msg);Long cnt,rslt = 1,ll_id

cnt = 0
SELECT count(*)
	INTO :cnt
	FROM u_email_rep
	WHERE  empid = :sys_empid AND
	LTRIM(RTRIM(Lower(mailAddress))) = LTRIM(RTRIM(Lower(:arg_sendmx.revaddress))) Using commit_tran;
IF commit_tran.SQLCode <> 0 THEN
	rslt = 0
	arG_MSG = "查询联系人列表失败~n"+commit_tran.SQLErrText
	GOTO ext
END IF
IF cnt = 0 THEN
	ll_id = f_sys_scidentity(0,"u_email_rep","repID",arG_MSG,True, commit_tran) //数据commit事务)
	IF ll_id <= 0 THEN
		rslt = 0
		GOTO ext
	END IF
	INSERT INTO u_email_rep
		( repID,
		empid,
		mailname,
		mailaddress,
		Opemp,
		Opdate,
		reptype )
		VALUES ( :ll_id,
		:sys_empid,
		:arg_sendmx.revname ,
		LTRIM(RTRIM(LOWER(:arg_sendmx.revaddress))),
		:publ_operator,
		getdate(),
		1 ) Using commit_tran ;
	IF commit_tran.SQLCode <> 0 THEN
		rslt = 0
		arG_MSG = "插入联系人列表失败~n"+commit_tran.SQLErrText
		GOTO ext
	END IF
	arg_sendmx.reltype = 0
	arg_sendmx.relid = ll_id
ELSE
	IF arg_sendmx.reltype = 0 Or arg_sendmx.reltype = 3 THEN//类型为通讯录和手动的查询联系人表
		SELECT top 1 repID,
			mailname
			INTO :arg_sendmx.relid,
			:arg_sendmx.revname
			FROM u_email_rep
			WHERE  empid = :sys_empid AND
			LTRIM(RTRIM(Lower(mailAddress))) = LTRIM(RTRIM(Lower(:arg_sendmx.revaddress))) Using commit_tran;
		arg_sendmx.reltype = 0
	END IF
END IF

ext:
RETURN rslt




end function

public function integer f_send (s_email_set arg_set, s_email_send arg_send, s_email_sendmx arg_sendmx, s_email_fj arg_fj, ref string arg_msg);Long rslt = 1,k,l
//Blob lb_fj
//String ls_pathname[]
//Long ll_fjid ,it_max
//arg_msg = ''
//it_max = 0 
//oleobject jmail
//jmail = CREATE oleobject
//jmail.ConnectToNewObject("JMail.Message")
//jmail.Charset = 'GB2312'
//jmail.ISOEncodeHeaders = TRUE
//jmail.silent = TRUE
//jmail.Logging = TRUE
//
//jmail.FROM = arg_set.mailAddress //发件人邮箱 
//jmail.FromName = arg_set.mailuser //发件人 
//jmail.Subject = Trim(arg_send.Subject) //邮件主题 
//jmail.MailServerUserName = arg_set.mailAddress //发件邮箱登录账户 
//jmail.MailServerPassword = arg_set.mailpsw //发件邮箱用户密码 
//jmail.Priority = arg_send.Priority //优先级
////jmail.Body = Trim(arg_send.Textbody) + "~r~n" //邮件内容 
//jmail.htmlbody = string(arg_send.htmlbody)
//FOR l = 1 TO UpperBound(arg_fj.fjid)
//	if arg_fj.fjid[l] = 0 then continue
//	ll_fjid = arg_fj.fjid[l]
//	SELECTBLOB Fileblob
//	INTO :lb_fj
//	FROM u_email_fj
//	Where (fjid = :ll_fjid) using fj_tran;
//	
//	IF fj_tran.SQLCode <> 0 THEN
//		arg_msg = '下载附件失败'
//		
//		rslt = 0
//		GOTO ext
//	END IF
//	
//	it_max ++
//	ls_pathname[it_max] = sys_cur_path+fjfilepathname+'\'+arg_fj.Filename[l]
//	IF FileExists(ls_pathname[it_max])	 THEN FileDelete(ls_pathname[it_max])
//	IF f_blobtofile(ls_pathname[it_max],lb_fj,arg_msg) = 0 THEN
//		
//		rslt = 0
//		GOTO ext
//	ELSE
//		jmail.AddAttachment(ls_pathname[it_max])
//	END IF
//NEXT
//
//////添加联系人
//long ll_sent_num = 0
//if arg_send.normal_flag = 2 then
//	FOR k = 1 TO  UpperBound(arg_sendmx.revaddress) 
//		IF Trim(arg_sendmx.revaddress[k]) <> '' THEN
//			jmail.AddRecipient(Trim(arg_sendmx.revaddress[k]))
//			if not jmail.send(arg_set.smtpset) then
//				rslt = 0
//				arg_msg = arg_msg + "发送[" + Trim(arg_sendmx.revaddress[k]) + "]失败！[" + arg_set.mailAddress +  "]邮箱设置不正确或者没有连接网络~r~n"
//			else
//				// DONE : 修改收件人列表状态
//				ll_sent_num ++
//				update u_email_sendmx
//					set u_email_sendmx.status = 1
//					where u_email_sendmx.sendid = :arg_send.sendid and u_email_sendmx.printid = :arg_sendmx.printid[k] using commit_tran;
//				if commit_tran.sqlcode <> 0 then
//					rslt = 0
//					arg_msg = arg_msg + "更新收件人[" + Trim(arg_sendmx.revaddress[k]) + "]状态失败~r~n"
//				else
//					commit;
//				end if
//				
//			end if
//			jmail.ClearRecipients()
//		END IF
//	NEXT
//else
//	jmail.ClearRecipients()
//	for k = 1 to upperBound(arg_sendmx.revaddress)
//		IF Trim(arg_sendmx.revaddress[k]) <> '' THEN
////			Messagebox('', arg_sendmx.revaddress[k])
//			if arg_send.normal_flag = 0 then
//				jmail.AddRecipient(Trim(arg_sendmx.revaddress[k]))
//			elseif arg_send.normal_flag = 1 then
//				jmail.AddRecipientBCC(Trim(arg_sendmx.revaddress[k]))
//			end if
//		end if
//	next
//	
//	//// debug///////
////		oleobject stream
////		stream = CREATE oleobject
////		stream.ConnectToNewObject("Adodb.Stream")
////		stream.Type = 1
////		stream.open()
////		jmail.SaveToStream(stream)
////		stream.position = 0
////		blob lb_message
////		setnull(lb_message)
////		lb_message = stream.read(stream.size)
////		stream.close()
////		stream.disconnectobject( )
////		destroy stream
////		messagebox('', string(lb_message))
//	//// debug///////
//	
//	if not jmail.send(arg_set.smtpset) then
//		rslt = 0
//		arg_msg = arg_msg + "发送失败！[" + arg_set.mailAddress +  "]邮箱设置不正确或者没有连接网络~r~n"
//	else
//		// DONE : 修改收件人列表状态
//		for k = 1 to upperBound(arg_sendmx.revaddress)
//			ll_sent_num ++
//			update u_email_sendmx
//				set u_email_sendmx.status = 1
//				where u_email_sendmx.sendid = :arg_send.sendid and u_email_sendmx.printid = :arg_sendmx.printid[k] using commit_tran;
//			if commit_tran.sqlcode <> 0 then
//				rslt = 0
//				arg_msg = arg_msg + "更新收件人[" + Trim(arg_sendmx.revaddress[k]) + "]状态失败~r~n"
//			else
//				commit;
//			end if			
//		next				
//	end if
//	jmail.ClearRecipients()
//end if
//
//// DONE: 删除临时文件
//for l = 1 to it_max
//	IF FileExists(ls_pathname[l])	 THEN FileDelete(ls_pathname[l])
//next
//// DONE: 更改邮件状态
//if ll_sent_num > 0 then
//	if f_update_send(arg_send.sendid, jmail.date, jmail.size, arg_msg) = 0 then
//		rslt = 0
//		arg_msg = arg_msg + "更改邮件状态失败~r~n"
//		goto ext
//	end if
//else
//	rslt = 0
//	arg_msg = arg_msg + "没有更改邮件发送状态"
//	GOTO ext	
//end if
//
//
////IF jmail.Send(arg_set.smtpset) THEN //ls_host为发件邮箱服务器
////	
////	jmail.ClearAttachments()
////	jmail.ClearRecipients()
////	
////	IF f_update_send(arg_send.sendid,jmail.Date,jmail.size,arg_msg) = 0 THEN
////		rslt = 0
////		GOTO ext
////	END IF
////	
////	for l = 1 to it_max
////		IF FileExists(ls_pathname[l])	 THEN FileDelete(ls_pathname[l])
////	next
////	
////ELSE
////	arg_msg = "发送失败！[" + arg_set.mailAddress +  "]邮箱设置不正确或者没有连接网络"
////	rslt = 0
////	GOTO ext
////END IF
//
//ext: 
//jmail.Close()
//DESTROY jmail
RETURN rslt
end function

public function integer uf_get_send (long arg_sendid, ref s_email_send arg_s_send, ref string arg_msg);integer rslt = 1
string ls_html
  SELECT u_email_msg.ID,  
  			u_email_msg.boxid,
         u_email_msg.mailID,   
         u_email_msg.mailaddress,   
         u_email_msg.mailtype,
         u_email_msg.Subject,   
         u_email_msg.Priority,   
         u_email_msg.senddate,   
         u_email_msg.Opdate,   
         u_email_msg.opemp,   
         u_email_msg.mailsize,   
			u_email_msg.sendOption,
			u_email_msg.senduser,
			u_email_msg.sendaddress,
			u_email_msg.revdate
	INTO :arg_s_send.sendid,
		  :arg_s_send.boxid,
	     :arg_s_send.mailid,
		  :arg_s_send.mailaddress,
		  :arg_s_send.mailtype,
		  :arg_s_send.Subject,
		  :arg_s_send.Priority,
		  :arg_s_send.senddate,
		  :arg_s_send.opdate,
		  :arg_s_send.opemp,
		  :arg_s_send.mailsize,
		  :arg_s_send.normal_flag,
		  :arg_s_send.senduser,
		  :arg_s_send.sendaddress,
		  :arg_s_send.revdate
    FROM u_email_msg
where u_email_msg.ID = :arg_sendID using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = "获取邮件失败,id:" + string(arg_sendid)
	goto ext
end if

if wf_mail_gethtml(arg_sendid, arg_s_send.htmlbody, arg_msg) <> 1 then
	rslt = 0
	goto ext
end if

// DONE: revlist

ext:
return rslt
end function

public subroutine wf_str_replace (ref string arg_source, string arg_str1, string arg_str2);long ll_pos
ll_pos = pos(arg_source, arg_str1, 1)
do while ll_pos > 0
	arg_source = Replace(arg_source, ll_pos, len(arg_str1), arg_str2)	
	ll_pos = pos(arg_source, arg_str1,1)
LOOP


end subroutine

public function integer wf_mail_gethtml (long arg_msgid, ref string arg_text, ref string arg_msg);int rslt = 1

long len
BLOB lb
SELECT DATALENGTH(htmlbody) INTO :len FROM u_email_msg
	WHERE ID = :arg_msgid using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '查询html长度失败,' + fj_tran.sqlerrtext
	goto ext
end if

if len = 0 then
	SELECT DATALENGTH(textbody) INTO :len FROM u_email_msg
		WHERE ID = :arg_msgid using fj_tran;
	if fj_tran.sqlcode <> 0 then
		rslt = 0
		arg_msg = '查询text长度失败,' + fj_tran.sqlerrtext
		goto ext
	end if
	if len > 2048 then
		SELECTBLOB textbody INTO :lb FROM u_email_msg
			WHERE ID = :arg_msgid using fj_tran;
		if fj_tran.sqlcode <> 0 then
			rslt = 0
			arg_msg = '查询text失败,' + fj_tran.sqlerrtext
			goto ext
		end if
		arg_text = string(lb)
		wf_str_replace(arg_text, '~r~n', '<BR>')
		wf_str_replace(arg_text, '~r', '<BR>')
		wf_str_replace(arg_text, '~n', '<BR>')
	else
		SELECT textbody INTO :arg_text FROM u_email_msg
			WHERE ID = :arg_msgid using fj_tran;
		if fj_tran.sqlcode <> 0 then
			rslt = 0
			arg_msg = '查询text失败,' + fj_tran.sqlerrtext
			goto ext
		end if
		wf_str_replace(arg_text, '~r~n', '<BR>')
		wf_str_replace(arg_text, '~r', '<BR>')
		wf_str_replace(arg_text, '~n', '<BR>')
	end if
elseif len > 2048 then
	SELECTBLOB htmlbody INTO :lb FROM u_email_msg
		WHERE ID = :arg_msgid using fj_tran;
	if fj_tran.sqlcode <> 0 then
		rslt = 0
		arg_msg = '查询html失败,' + fj_tran.sqlerrtext
		goto ext
	end if
	arg_text = string(lb)
else
	SELECT htmlbody INTO :arg_text FROM u_email_msg
		WHERE ID = :arg_msgid using fj_tran;
	if fj_tran.sqlcode <> 0 then
		rslt = 0
		arg_msg = '查询html失败,' + fj_tran.sqlerrtext
		goto ext
	end if	
end if

ext:
return rslt
end function

public function integer uf_get_sendmx (long arg_sendid, ref s_email_sendmx arg_sendmx[], ref string arg_msg);Int rslt = 1,i,NO_MXCHECK
i = 0

s_email_sendmx s_sendmx[]

long sendid, printid, reltype, relid
string revaddress, revname
DECLARE CUR_INWAERMX CURSOR FOR
	SELECT u_email_sendmx.sendid,   
         u_email_sendmx.printid,   
         u_email_sendmx.reltype,   
         u_email_sendmx.relid,   
         u_email_sendmx.revaddress,   
         u_email_sendmx.revname
    FROM u_email_sendmx   
	where u_email_sendmx.sendid = :arg_sendid using fj_tran;
OPEN CUR_INWAERMX; 
FETCH CUR_INWAERMX  INTO :sendid,   
         :printid,   
         :reltype,   
         :relid,   
         :revaddress,   
         :revname;
DO WHILE fj_tran.SQLCode = 0
	i++
	s_sendmx[i].sendid = sendid
	s_sendmx[i].printid = printid
	s_sendmx[i].reltype = reltype
	s_sendmx[i].relid = relid
	s_sendmx[i].revaddress = revaddress
	s_sendmx[i].revname = revname
	FETCH CUR_INWAERMX INTO	:sendid,   
         :printid,   
         :reltype,   
         :relid,   
         :revaddress,   
         :revname;
LOOP
CLOSE CUR_INWAERMX;

arg_sendmx = s_sendmx

RETURN rslt

end function

public function integer wf_mail_getfjblob (long arg_fjid, ref blob arg_fjblob, ref string arg_msg);int rslt = 1

SELECTBLOB fileblob INTO :arg_fjblob FROM u_email_fj
	WHERE fjid = :arg_fjid using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '获取附件失败,' + fj_tran.sqlerrtext
	goto ext
end if

ext:
return rslt
end function

public function integer uf_get_fj (long arg_relid, ref s_email_lvfj arg_lvfj[], ref string arg_msg, boolean arg_withblob);Int rslt = 1,i
i = 0
long fjid, fjtype, relid
string filename, filetype,cid

s_email_lvfj l_s_lvfj[]

DECLARE CUR_INWAERMX CURSOR FOR
	 SELECT u_email_fj.fjid,   
         u_email_fj.fjtype,   
         u_email_fj.Relid,   
         u_email_fj.filename,   
         u_email_fj.filetype ,
			 u_email_fj.cid
    FROM u_email_fj 
	where    u_email_fj.Relid = :arg_Relid using fj_tran;
OPEN CUR_INWAERMX; 
FETCH CUR_INWAERMX  INTO :fjid,   
         :fjtype,   
         :Relid,   
         :filename,    
         :filetype,
		:cid;
DO WHILE fj_tran.SQLCode = 0
	i++
	l_s_lvfj[i].fjid = fjid
	l_s_lvfj[i].fjtype = fjtype
	l_s_lvfj[i].Relid = Relid
	l_s_lvfj[i].filename = filename
	l_s_lvfj[i].filetype = C_u_email_fj
	l_s_lvfj[i].cid = cid
	FETCH CUR_INWAERMX INTO	:fjid,   
         :fjtype,   
         :Relid,   
         :filename,   
         :filetype,
		:cid;
LOOP
CLOSE CUR_INWAERMX;

if arg_withBlob then
	for i = 1 to UPPERBOUND(l_s_lvfj)
		if wf_mail_getfjblob(l_s_lvfj[i].fjid, l_s_lvfj[i].fileblob, arg_msg) <> 1 then
			rslt = 0
			goto ext
		end if
	next
end if

arg_lvfj = l_s_lvfj

ext:
RETURN rslt

end function

public function integer wf_admsg_getfjblob (long arg_fjid, ref blob arg_fjblob, ref string arg_msg);int rslt = 1

SELECTBLOB fileblob INTO :arg_fjblob FROM Sys_admsg_fj
	WHERE fjid = :arg_fjid using Commit_Tran;
if Commit_Tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '获取内部消息附件失败,' + Commit_Tran.sqlerrtext
	goto ext
end if

ext:
return rslt
end function

public function integer f_del (long arg_id, ref string arg_msg);Int rslt = 1
// fjtype : 0:发件箱 1:收件箱
// mailtype : 0:未发,未读1:已发,已读2:废件箱

DELETE FROM u_email_msg WHERE ID = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '删除邮件失败,' + fj_tran.sqlerrtext
	goto ext
end if

DELETE FROM u_email_sendmx WHERE sendid = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '删除收件人列表失败,' + fj_tran.sqlerrtext
	goto ext
end if

DELETE FROM u_email_fj WHERE relid = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '删除附件失败,' + fj_tran.sqlerrtext
	goto ext
end if

ext:
IF rslt = 0 THEN
	ROLLBACK USING fj_tran;
ELSE
	COMMIT USING fj_tran;
END IF

RETURN rslt










end function

public function integer wf_ds_get_mail_set (long arg_mailid, ref s_email_set arg_set, ref string arg_msg);int rslt = 1

SELECT mailuser, mailaddress
INTO :arg_set.mailuser, :arg_set.mailaddress
FROM u_email_set
WHERE mailID = :arg_mailid using Commit_Tran;
if Commit_Tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '查询帐号信息失败,' + Commit_Tran.sqlerrtext
	goto ext
end if

arg_set.mailid = arg_mailid

ext:
return rslt
end function

public function long wf_ds_gettrunkbox (long arg_mailid);long rslt = -1

SELECT TOP 1 boxid INTO :rslt
	FROM u_email_box
	WHERE mailid = :arg_mailid AND boxtype = '废件箱' using Commit_Tran;
if Commit_Tran.sqlcode <> 0 then
	return -1
end if
return rslt
end function

public function long wf_ds_getsendbox (long arg_mailid);long rslt = -1

SELECT TOP 1 boxid INTO :rslt
	FROM u_email_box
	WHERE mailid = :arg_mailid AND boxtype = '发件箱' using Commit_Tran;
if Commit_Tran.sqlcode <> 0 then
	return -1
end if
return rslt
end function

public function string wf_ds_getuser (long arg_id);string rslt = ''

long ll_cnt
SELECT COUNT(0) INTO :ll_cnt FROM u_email_sendmx 
	WHERE sendid = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	return rslt
end if

if ll_cnt = 0 then
	return rslt
end if

string revname
declare cur1 CURSOR FOR
	SELECT revname FROM u_email_sendmx
	WHERE sendid = :arg_id ORDER BY printid using fj_tran;
open cur1;
fetch cur1 INTO :revname;
do while fj_tran.sqlcode = 0
	rslt = rslt + revname + ';'
	fetch cur1 INTO :revname;
LOOP
close cur1;

rslt = left(rslt, len(rslt) - 1)
return rslt

end function

public function string wf_ds_getaddress (long arg_id);string rslt = ''

long ll_cnt
SELECT COUNT(0) INTO :ll_cnt FROM u_email_sendmx 
	WHERE sendid = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	return rslt
end if

if ll_cnt = 0 then
	return rslt
end if

string revname
declare cur1 CURSOR FOR
	SELECT revaddress FROM u_email_sendmx
	WHERE sendid = :arg_id ORDER BY printid using fj_tran;
open cur1;
fetch cur1 INTO :revname;
do while fj_tran.sqlcode = 0
	rslt = rslt + revname + ';'
	fetch cur1 INTO :revname;
LOOP
close cur1;

rslt = left(rslt, len(rslt) - 1)
return rslt

end function

public function string wf_ds_getuseraddress (long arg_id);string rslt = ''

long ll_cnt
SELECT COUNT(0) INTO :ll_cnt FROM u_email_sendmx 
	WHERE sendid = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	return rslt
end if

if ll_cnt = 0 then
	return rslt
end if

string revname
declare cur1 CURSOR FOR
	SELECT revname + '<' + revaddress + '>' as address FROM u_email_sendmx
	WHERE sendid = :arg_id ORDER BY printid using fj_tran;
open cur1;
fetch cur1 INTO :revname;
do while fj_tran.sqlcode = 0
	rslt = rslt + revname + ';'
	fetch cur1 INTO :revname;
LOOP
close cur1;

rslt = left(rslt, len(rslt) - 1)
return rslt

end function

public function integer wf_ds_move_msg_box (long arg_id, long arg_boxid, ref string arg_msg);int rslt = 1

long mailid
SELECT mailid INTO :mailid
	FROM u_email_box WHERE boxid = :arg_boxid using Commit_Tran;
if Commit_Tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '查询邮箱所属帐号失败,' + Commit_Tran.sqlerrtext
	goto ext
end if

UPDATE u_email_msg SET boxid = :arg_boxid, mailid = :mailid
	WHERE ID = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '移动邮件失败,' + fj_tran.sqlerrtext
	goto ext
end if

if fj_tran.SQLNRows <> 1 then
	rslt = 0
	arg_msg = '原邮件已经不存在'
	goto ext
end if

ext:
if rslt = 0 then
	rollback using fj_tran;
else
	commit using fj_tran;
end if
return rslt
end function

public function integer f_del_move_msg (long arg_id, ref string arg_msg);int rslt = 1

long mailid, boxid
SELECT mailid, boxid INTO :mailid, :boxid
	FROM u_email_msg WHERE ID = :arg_id using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '查询邮件失败,邮件可能不存在,' + fj_tran.sqlerrtext
	goto ext
end if

long trunkboxid
trunkboxid = wf_ds_gettrunkbox(mailid)
if trunkboxid <= 0 then
	rslt = 0
	arg_msg = '获取默认废件箱失败'
	goto ext
end if

if boxid = trunkboxid then
	if f_del(arg_id, arg_msg) <> 1 then
		rslt = 0
		goto ext
	end if
else
	if wf_ds_move_msg_box(arg_id, trunkboxid, arg_msg) <> 1 then
		rslt = 0
		goto ext
	end if
end if
ext:
if rslt = 0 then
	rollback using fj_tran;
else
	commit using fj_tran;
end if
return rslt
end function

public function integer f_unread (long arg_revid, ref string arg_msg);Long rslt = 1

UPDATE u_email_msg
	SET status = '未读'
	Where u_email_msg.ID = :arg_revid using fj_tran;
IF fj_tran.SQLCode <> 0 THEN
	rslt = 0
	arG_MSG = "更新收件标记失败~n"+fj_tran.SQLErrText
	GOTO ext
END IF

ext:
IF rslt = 0 THEN
	ROLLBACK using fj_tran;
ELSE
	COMMIT using fj_tran;
END IF
RETURN rslt




end function

public function integer f_read (long arg_revid, ref string arg_msg);Long rslt = 1

UPDATE u_email_msg
	SET status = '已读'
	Where u_email_msg.ID = :arg_revid using fj_tran;
IF fj_tran.SQLCode <> 0 THEN
	rslt = 0
	arG_MSG = "更新收件标记失败~n"+fj_tran.SQLErrText
	GOTO ext
END IF

ext:
IF rslt = 0 THEN
	ROLLBACK using fj_tran;
ELSE
	COMMIT using fj_tran;
END IF
RETURN rslt




end function

public function long f_save (ref s_email_send arg_send, s_email_sendmx arg_sendmx[], s_email_lvfj arg_fj[], ref string arg_msg);Int rslt = 1
Long i,totalSize = 0
Long cnt,ll_id = 0
Long ll_fjid
String ls_msg

Boolean has_copy = False

COMMIT Using fj_tran;
fj_tran.AutoCommit = True


IF UpperBound(arg_fj) > 0 THEN
	FOR cnt = 1 To UpperBound(arg_fj)
		
		totalSize+= arg_fj[cnt].filesize
		IF totalSize > 100*1024*1024 THEN
			//附件超过100M
			rslt = 0
			arg_msg = '附件大于100m,不能发送!'
			GOTO ext
		END IF
	NEXT
	//	MessageBox('',String(totalSize))
END IF
s_email_set s_set
IF wf_ds_get_mail_set(arg_send.mailid, s_set, arg_msg) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

arg_send.mailAddress = s_set.mailAddress
arg_send.senduser = s_set.mailuser
arg_send.sendaddress = s_set.mailAddress
IF arg_send.NTFlag = 1 THEN
	arg_send.NTMail = arg_send.mailAddress
END IF
IF arg_send.sendid = 0 THEN
	ll_id = f_sys_scidentity(0,"u_email_msg","ID",arg_msg,True, commit_tran) //数据commit事务)
	IF ll_id <= 0 THEN
		rslt = 0
		GOTO ext
	END IF
	
	arg_send.boxid = wf_ds_getsendbox(arg_send.mailid)
	IF arg_send.boxid = -1 THEN
		rslt = 0
		arg_msg = '获取默认发件箱失败'
		GOTO ext
	END IF
	
	
	INSERT INTO u_email_msg
		( ID,
		boxid,
		mailID,
		mailaddress,
		mailtype,
		Subject,
		Priority,
		//		senddate,
		Opdate,
		opemp,
		mailsize,
		SendOption,
		textbody,
		htmlbody,
		senduser,
		sendaddress,
		ntflag,
		ntname,
		ntmail
		
		)
		VALUES ( :ll_id,
		:arg_send.boxid,
		:arg_send.mailID,
		:arg_send.mailaddress,
		:arg_send.mailtype,
		:arg_send.Subject,
		:arg_send.Priority,
		//		:arg_send.senddate,
		getdate(),
		:publ_operator,
		:arg_send.mailsize,
		:arg_send.normal_flag,
		:arg_send.textbody,
		:arg_send.htmlbody,
		:s_set.mailuser,
		:s_set.mailAddress,
		:arg_send.ntflag,
		:arg_send.ntname,
		:arg_send.NTMail)  Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = "插入发送邮件失败~n"+fj_tran.SQLErrText
		GOTO ext
	END IF
	///////// //
	IF arg_send.senddate > DateTime(Today(),Now()) THEN
		UPDATE u_email_msg Set senddate = :arg_send.senddate,mailtype='定时发件'  where ID=:ll_id Using fj_tran;
	END IF
	
	/////// //
	
	
	IF  UpperBound(arg_sendmx) = 0 THEN
		rslt = 0
		arg_msg = "发送邮件收件人不能为空~n"
		GOTO ext
	END IF
	
	FOR i = 1 To UpperBound(arg_sendmx)
		INSERT INTO u_email_sendmx
			( sendid,
			printid,
			reltype,
			relid,
			revaddress,
			revname ,
			repname,
			addtype)
			VALUES ( :ll_id,
			:arg_sendmx[i].printid,
			:arg_sendmx[i].reltype,
			:arg_sendmx[i].relid,
			:arg_sendmx[i].revaddress,
			:arg_sendmx[i].revname ,
			:arg_sendmx[i].repname,
			:arg_sendmx[i].addtype
			)  Using fj_tran;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = "插入发送邮件收件人明细失败~n"+fj_tran.SQLErrText
			GOTO ext
		END IF
	NEXT
	
	//	IF  UpperBound(arg_fj.Filename) = 0 THEN GOTO ext
	FOR i = 1 To UpperBound(arg_fj)
		ll_fjid  = f_sys_scidentity(0,"u_email_fj","fjid",arg_msg,True, commit_tran) //数据commit事务)
		IF ll_fjid <= 0 THEN
			rslt = 0
			GOTO ext
		END IF
		
		// DONE filesize
		IF arg_fj[i].FileType = C_Sys_admsg_fj THEN
			IF wf_admsg_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 THEN
				rslt = 0
				GOTO ext
			END IF
		ELSEIF arg_fj[i].FileType = C_u_email_fj THEN
			IF wf_mail_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 THEN
				rslt = 0
				GOTO ext
			END IF
		ELSEIF arg_fj[i].FileType = C_from_file THEN
			
		END IF
		
		arg_fj[i].filesize = Len(arg_fj[i].fileblob)
		
		
		INSERT INTO u_email_fj
			(	fjid,
			fjtype,
			Relid,
			filename,
			filesize,
			cid
			) VALUES
			( :ll_fjid,
			0,
			:ll_id,
			:arg_fj[i].filename,
			:arg_fj[i].filesize,
			:arg_fj[i].cid
			) Using fj_tran;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
			GOTO ext
		END IF
		
		IF   arg_fj[i].filesize  >   0   THEN
			COMMIT Using fj_tran;
			UpdateBlob u_email_fj
			Set fileblob = :arg_fj[i].fileblob
			Where fjid = :ll_fjid Using fj_tran;
			IF fj_tran.SQLCode <> 0 THEN
				rslt = 0
				arg_msg = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
				GOTO ext
			END IF
			COMMIT Using fj_tran;
		END IF
	NEXT
	
	arg_send.sendid = ll_id
	
ELSE
	
	ll_id = f_sys_scidentity(0,"u_email_msg","ID",arg_msg,True, commit_tran) //数据commit事务)
	IF ll_id <= 0 THEN
		rslt = 0
		GOTO ext
	END IF
	
	// 备份邮件
	INSERT INTO u_email_msg
		(ID, boxid, mailid, mailaddress, subject, mailsize, textbody, htmlbody, orgdata, senduser, sendaddress, sendOption, priority, senddate, opdate, opemp,
		revdate, tuid, mailtype, status)
		SELECT     :ll_id AS Expr1, boxid, mailid, mailaddress, subject, mailsize, textbody, htmlbody, orgdata, senduser, sendaddress, sendOption, priority, senddate,
		opdate, opemp, revdate, tuid, mailtype, status
		FROM         u_email_msg AS u_email_msg_1
		Where     (ID = :arg_send.sendid) Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '备份邮件失败,' + fj_tran.SQLErrText
		f_del(ll_id, ls_msg)
		GOTO ext
	END IF
	
	// 备份发件明细
	INSERT INTO u_email_sendmx
		(sendid, printid, reltype, relid, revaddress, revname, dscrp, status)
		SELECT     :ll_id AS Expr1, printid, reltype, relid, revaddress, revname, dscrp, status
		FROM         u_email_sendmx AS u_email_sendmx_1
		Where     (sendid = :arg_send.sendid) Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '备份邮件明细失败,' + fj_tran.SQLErrText
		f_del(ll_id, ls_msg)
		GOTO ext
	END IF
	
	// 备份附件
	Long arr_fjid[]
	i = 0
	DECLARE cur1 CURSOR FOR
		SELECT fjid FROM u_email_fj
		Where relid = :arg_send.sendid Using fj_tran;
	OPEN cur1;
	FETCH cur1 Into :ll_fjid;
	DO WHILE fj_tran.SQLCode = 0
		i++
		arr_fjid[i] = ll_fjid
		FETCH cur1 Into :ll_fjid;
	LOOP
	CLOSE cur1;
	
	FOR i = 1 To UpperBound(arr_fjid)
		ll_fjid  = f_sys_scidentity(0,"u_email_fj","fjid",arg_msg,True, commit_tran) //数据commit事务)
		IF ll_fjid <= 0 THEN
			rslt = 0
			f_del(ll_id, ls_msg)
			GOTO ext
		END IF
		
		INSERT INTO u_email_fj
			(fjid, fjtype, Relid, filename, fileblob, filesize, filetype)
			SELECT     :ll_fjid AS Expr1, fjtype, :ll_id, filename, fileblob, filesize, filetype
			FROM         u_email_fj AS u_email_fj_1
			Where     (fjid = :arr_fjid[i]) Using fj_tran;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = '备份附件失败,' + fj_tran.SQLErrText
			f_del(ll_id, ls_msg)
			GOTO ext
		END IF
		
	NEXT
	
	has_copy = True
	
	
	UPDATE u_email_msg
		SET mailID = :arg_send.mailID,
		boxid = :arg_send.boxid,
		mailaddress = :arg_send.mailaddress,
		Subject = :arg_send.Subject,
		Priority = :arg_send.Priority,
		Opdate = getdate(),
		opemp = :publ_operator,
		mailsize = :arg_send.mailsize,
		mailtype = :arg_send.mailtype,
		sendOption = :arg_send.normal_flag,
		textbody = :arg_send.textbody,
		htmlbody = :arg_send.htmlbody,
		senduser = :s_set.mailuser,
		sendaddress = :s_set.mailaddress
		Where ID = :ll_id Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = "更新发送邮件失败~n"+fj_tran.SQLErrText
		GOTO ext
	END IF
	
	DELETE FROM u_email_sendmx
		Where sendid = :ll_id Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = "删除发送邮件收件人明细失败~n"+fj_tran.SQLErrText
		GOTO ext
	END IF
	
	IF  UpperBound(arg_sendmx) = 0 THEN
		rslt = 0
		arg_msg = '没有收件人'
		GOTO ext
	END IF
	
	FOR i = 1 To UpperBound(arg_sendmx)
		
		INSERT INTO u_email_sendmx
			( sendid,
			printid,
			reltype,
			relid,
			revaddress,
			revname ,
			addtype
			)
			VALUES ( :ll_id,
			:arg_sendmx[i].printid,
			:arg_sendmx[i].reltype,
			:arg_sendmx[i].relid,
			:arg_sendmx[i].revaddress,
			:arg_sendmx[i].revname,
			:arg_sendmx[i].addtype
			) Using fj_tran ;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = "插入发送邮件收件人明细失败~n"+fj_tran.SQLErrText
			GOTO ext
		END IF
	NEXT
	
	DELETE FROM u_email_fj
		Where relid = :ll_id Using fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = "删除发送邮件的附件明细失败~n"+fj_tran.SQLErrText
		GOTO ext
	END IF
	
	//	IF  UpperBound(arg_fj.Filename) = 0 THEN GOTO ext
	FOR i = 1 To UpperBound(arg_fj)
		ll_fjid  = f_sys_scidentity(0,"u_email_fj","fjid",arg_msg,True, commit_tran) //数据commit事务)
		IF ll_fjid <= 0 THEN
			rslt = 0
			GOTO ext
		END IF
		
		// DONE filesize
		IF arg_fj[i].FileType = C_Sys_admsg_fj THEN
			IF wf_admsg_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 THEN
				rslt = 0
				GOTO ext
			END IF
		ELSEIF arg_fj[i].FileType = C_u_email_fj THEN
			IF wf_mail_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 THEN
				rslt = 0
				GOTO ext
			END IF
		ELSEIF arg_fj[i].FileType = C_from_file THEN
			
		END IF
		
		arg_fj[i].filesize = Len(arg_fj[i].fileblob)
		
		//////////// //
		INSERT INTO u_email_fj
			(	fjid,
			fjtype,
			Relid,
			filename,
			filesize,
			cid
			) VALUES
			( :ll_fjid,
			0,
			:ll_id,
			:arg_fj[i].filename,
			:arg_fj[i].filesize,
			:arg_fj[i].cid
			) Using fj_tran;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
			GOTO ext
		ELSE
			COMMIT Using fj_tran;
		END IF
		
		IF   arg_fj[i].filesize  > 0   THEN
			UpdateBlob u_email_fj
			Set fileblob = :arg_fj[i].fileblob
			Where fjid = :ll_fjid Using fj_tran;
			IF fj_tran.SQLCode <> 0 THEN
				rslt = 0
				arg_msg = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
				GOTO ext
			END IF
		END IF
	NEXT
	
	fj_tran.AutoCommit = False
	f_del(arg_send.sendid, ls_msg)
	f_change_id(ll_id, arg_send.sendid, ls_msg)
	
END IF

ext:
fj_tran.AutoCommit = False
IF rslt = 0 THEN
	IF arg_send.sendid = 0 And ll_id > 0 THEN
		f_del(ll_id, ls_msg)
	END IF
	
	IF has_copy And arg_send.sendid > 0 THEN
		f_del(ll_id, ls_msg)
	END IF
	
ELSE
	
END IF
RETURN rslt




end function

public function long f_import_eml (ref s_email_send arg_send, s_email_lvfj arg_fj[], ref string arg_msg);Int rslt = 1
Long i
Long cnt,ll_id = 0
long ll_fjid
string ls_msg


IF arg_send.sendid = 0 THEN
	ll_id = f_sys_scidentity(0,"u_email_msg","ID",arG_MSG,TRUE, commit_tran) //数据commit事务)
	IF ll_id <= 0 THEN
		rslt = 0
		GOTO ext
	END IF

	INSERT INTO u_email_msg
		( ID,
		boxid,
		mailID,
		mailaddress,
		mailtype,
		Subject,
		Priority,
		//		senddate,
		Opdate,
		opemp,
		mailsize,
		SendOption,
		textbody,
		htmlbody,
		senduser,
		sendaddress,
		status,
		revdate)
		VALUES ( :ll_id,
		:arg_send.boxid,
		:arg_send.mailID,
		:arg_send.mailaddress,
		:arg_send.mailtype,
		:arg_send.Subject,
		:arg_send.Priority,
		//		:arg_send.senddate,
		getdate(),
		:publ_operator,
		:arg_send.mailsize,
		:arg_send.normal_flag,
		:arg_send.textbody,
		:arg_send.htmlbody,
		:arg_send.senduser,
		:arg_send.sendaddress,
		:arg_send.status,
		GETDATE())  USING fj_tran;
	IF fj_tran.SQLCode <> 0 THEN
		rslt = 0
		arG_MSG = "插入发送邮件失败~n"+fj_tran.SQLErrText
		GOTO ext
	END IF
	
	commit using fj_tran;
	UPDATEBLOB u_email_msg set orgdata = :arg_send.orgdata WHERE id = :ll_id using fj_tran;
	if fj_tran.sqlcode <> 0 then
		rslt = 0
		arg_msg = '更新原始数据失败,' + fj_tran.sqlerrtext
		goto ext
	end if
	commit using fj_tran;
	
	//	IF  UpperBound(arg_fj.Filename) = 0 THEN GOTO ext
	FOR i = 1 TO UpperBound(arg_fj)
		ll_fjid  = f_sys_scidentity(0,"u_email_fj","fjid",arG_MSG,TRUE, commit_tran) //数据commit事务)
		IF ll_fjid <= 0 THEN
			rslt = 0
			GOTO ext
		END IF
		
		// DONE filesize
		if arg_fj[i].filetype = C_Sys_admsg_fj then
			if wf_admsg_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 then
				rslt = 0
				goto ext
			end if
		elseif arg_fj[i].filetype = C_u_email_fj then
			if wf_mail_getfjblob(arg_fj[i].fjid, arg_fj[i].fileblob, arg_msg) <> 1 then
				rslt = 0
				goto ext
			end if
		elseif arg_fj[i].filetype = C_from_file then
			
		end if
		
		arg_fj[i].filesize = len(arg_fj[i].fileblob)
		
		INSERT INTO u_email_fj
			(	fjid,
			fjtype,
			Relid,
			filename,
			filesize,
			cid
			) VALUES
			( :ll_fjid,
			0,
			:ll_id,
			:arg_fj[i].filename,
			:arg_fj[i].filesize,
			:arg_fj[i].cid
			) USING fj_tran;
		IF fj_tran.SQLCode <> 0 THEN
			rslt = 0
			arG_MSG = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
			GOTO ext
		END IF
		
		IF   arg_fj[i].filesize  >   0   THEN
			COMMIT USING fj_tran;
			UPDATEBLOB u_email_fj
			Set fileblob = :arg_fj[i].fileblob
			Where fjid = :ll_fjid USING fj_tran;
			IF fj_tran.SQLCode <> 0 THEN
				rslt = 0
				arG_MSG = "插入发送邮件的附件明细失败~n"+fj_tran.SQLErrText
				GOTO ext
			END IF
			Commit using fj_tran;
		END IF
	NEXT
			
	arg_send.sendid = ll_id

ELSE
	rslt = 0
	arg_msg = '导入邮件必须新建邮件'
	goto ext
END IF

ext:
IF rslt = 0 THEN
	ROLLBACK USING commit_tran;
	ROLLBACK USING fj_tran;
	if arg_send.sendid = 0 AND ll_id > 0 then
		f_del(ll_id, ls_msg)
	end if
ELSE
	COMMIT USING commit_tran;
	COMMIT USING fj_tran;
END IF
RETURN rslt

end function

public function integer f_change_id (long arg_fromid, long arg_toid, ref string arg_msg);int rslt = 1

UPDATE u_email_msg SET ID = :arg_toid WHERE ID = :arg_fromid using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '更新邮件ID失败,' + fj_tran.sqlerrtext
	goto ext
end if

UPDATE u_email_sendmx SET sendid = :arg_toid WHERE sendid = :arg_fromid using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '更新邮件明细sendid失败,' + fj_tran.sqlerrtext
	goto ext
end if

UPDATE u_email_fj SET Relid = :arg_toid WHERE Relid = :arg_fromid using fj_tran;
if fj_tran.sqlcode <> 0 then
	rslt = 0
	arg_msg = '更新附件相关失败,' + fj_tran.sqlerrtext
	goto ext
end if

ext:
if rslt = 0 then
	rollback using fj_tran;
else
	commit using fj_tran;
end if

return rslt
end function

on uo_email.create
call super::create
TriggerEvent( this, "constructor" )
end on

on uo_email.destroy
TriggerEvent( this, "destructor" )
call super::destroy
end on