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

global type uo_oa_demo_fj_downsave from nonvisualobject
end type
global uo_oa_demo_fj_downsave uo_oa_demo_fj_downsave

type variables
transaction  ins_tran  //数据commit事务
end variables

forward prototypes
public function integer f_down_fj (long arg_fjid, string arg_fjname, ref blob arg_fjdata, ref string arg_msg)
public function integer f_getfj (long arg_fjid, string arg_fjname, ref blob arg_fjdata, ref string arg_msg)
public function integer f_update_blob_fj (long arg_fjid, string arg_fjname, blob arg_fjbody, ref string arg_msg, boolean arg_ifcommit)
public function integer f_del_fj (long arg_demoid, ref string arg_msg, boolean arg_ifcommit)
public function integer f_save_fj (long arg_demoid, string arg_fjname, blob arg_fjbody, long arg_fjtype, integer arg_modelflag, integer arg_ifmain, ref string arg_msg, boolean arg_ifcommit)
public function integer getflowannex (long arg_demoid, ref s_oa_doc_annex arg_s_oda[])
end prototypes

public function integer f_down_fj (long arg_fjid, string arg_fjname, ref blob arg_fjdata, ref string arg_msg);Long rslt = 1,cnt
Blob ls_filedata

IF arg_fjid <= 0 THEN
	rslt = 0
	arg_msg = '下载附件失败(错误附件ID)'
	GOTO ext
END IF

IF arg_fjname = '' THEN
	rslt = 0
	arg_msg = '下载附件失败(错误附件名)'
	GOTO ext
END IF

SELECT count(*)
	INTO :cnt
	FROM oa_demo_annex
	WHERE (oa_demo_annex.AnnexNO = :arg_fjid) AND
	(oa_demo_annex.Filename = :arg_fjname)
	USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询附件信息失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

SELECTBLOB Fileblob
INTO :ls_filedata
FROM oa_demo_annex
Where  (oa_demo_annex.AnnexNO = :arg_fjid) AND
(oa_demo_annex.Filename = :arg_fjname)
USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '下载附件失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

arg_fjdata = ls_filedata

ext:
RETURN rslt

end function

public function integer f_getfj (long arg_fjid, string arg_fjname, ref blob arg_fjdata, ref string arg_msg);Long rslt = 1,cnt
Blob ls_filedata

IF arg_fjid <= 0 THEN
	rslt = 0
	arg_msg = '下载附件失败(错误附件ID)'
	GOTO ext
END IF

IF arg_fjname = '' THEN
	rslt = 0
	arg_msg = '下载附件失败(错误附件名)'
	GOTO ext
END IF

SELECT count(*)
	INTO :cnt
	FROM oa_demo_annex
	WHERE (oa_demo_annex.AnnexNO = :arg_fjid) AND
	(oa_demo_annex.Filename = :arg_fjname)
	USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询附件信息失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

SELECTBLOB Fileblob
INTO :ls_filedata
FROM oa_demo_annex
Where  (oa_demo_annex.AnnexNO = :arg_fjid) AND
(oa_demo_annex.Filename = :arg_fjname)
USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '下载附件失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

arg_fjdata = ls_filedata

ext:
RETURN rslt

end function

public function integer f_update_blob_fj (long arg_fjid, string arg_fjname, blob arg_fjbody, ref string arg_msg, boolean arg_ifcommit);//保存附件
Long rslt = 1, cnt


IF IsNull(arg_fjname) Or arg_fjname = '' THEN
	rslt = 0
	arg_msg = '保存附件失败(附件名)'
	GOTO ext
END IF

SELECT count(*)
	INTO :cnt
	FROM oa_demo_annex
	WHERE (oa_demo_annex.AnnexNO = :arg_fjid) AND
	(oa_demo_annex.Filename = :arg_fjname)
	Using ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询附件信息失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

UPDATEBLOB oa_demo_annex
Set Fileblob = :arg_fjbody
Where AnnexNO = :arg_fjid USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '因网络或其它原因保存附件失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

ext:
IF rslt = 0 THEN
	ROLLBACK Using ins_tran;
ELSEIF arg_ifcommit THEN
	COMMIT Using ins_tran;
END IF
RETURN rslt




end function

public function integer f_del_fj (long arg_demoid, ref string arg_msg, boolean arg_ifcommit);Long rslt = 1,cnt
Blob ls_filedata

IF arg_demoid <= 0 THEN
	rslt = 0
	arg_msg = '下载附件失败(错误附件ID)'
	GOTO ext
END IF

delete from oa_demo_annex
where demoid = :arg_demoid
	USING ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '因网络或其它原因保存附件失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

ext:
if rslt = 0 then
	rollback USING ins_tran;
elseif arg_ifcommit then 
	commit USING ins_tran;
end if
	
RETURN rslt

end function

public function integer f_save_fj (long arg_demoid, string arg_fjname, blob arg_fjbody, long arg_fjtype, integer arg_modelflag, integer arg_ifmain, ref string arg_msg, boolean arg_ifcommit);//保存附件
Long rslt = 1
Long ls_newid
IF arg_demoid <= 0 THEN
	rslt = 0
	arg_msg = '保存附件失败(公文ID)'
	GOTO ext
END IF

IF IsNull(arg_fjname) Or arg_fjname = '' THEN
	rslt = 0
	IF IsNull(arg_fjname) THEN
		arg_msg = '保存附件失败(附件名) null'
	ELSE
		arg_msg = '保存附件失败(附件名) 空'
	END IF
	GOTO ext
END IF



ls_newid = f_sys_scidentity(0,"oa_demo_annex","AnnexNO",arg_msg,True,id_sqlca)
IF ls_newid <= 0 THEN
	rslt = 0
	GOTO ext
END IF

INSERT INTO oa_demo_annex
	( demoid,
	AnnexNO,
	Filename,
	Filetype,
	modelflag,
	ifmain)
	VALUES ( :arg_demoid,
	:ls_newid,
	:arg_fjname,
	:arg_fjtype,
	:arg_modelflag,
	:arg_ifmain)
	Using ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '因网络或其它原因保存附件失败>>'+ins_tran.SQLErrText
	GOTO ext
ELSE
	COMMIT Using ins_tran;
END IF

UpdateBlob oa_demo_annex
Set Fileblob = :arg_fjbody
Where AnnexNO = :ls_newid Using ins_tran;
IF ins_tran.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '因网络或其它原因保存附件失败>>'+ins_tran.SQLErrText
	GOTO ext
END IF

COMMIT Using ins_tran;

ext:
RETURN rslt




end function

public function integer getflowannex (long arg_demoid, ref s_oa_doc_annex arg_s_oda[]);//GetFlowAnnex

Integer rslt = 1
String arg_msg



Long i,ll_i,ll_row
Blob lb_FileData

s_oa_doc_annex s_oda[]


i = 1
Declare cur_mx Cursor For
	Select   AnnexNo,
	Filename,
	Filetype,
	ifmain,
	modelflag
	From oa_demo_annex
	Where demoid = :arg_demoid;
	
Open cur_mx;
Fetch cur_mx Into :s_oda[i].AnnexNo,
	:s_oda[i].FileName,
	:s_oda[i].Filetype,
	:s_oda[i].ifmain,
	:s_oda[i].modelflag;
Do While sqlca.SQLCode = 0
	
	
	If f_down_fj(  s_oda[i].AnnexNo, s_oda[i].Filename, lb_FileData, arg_msg) = 0 Then
		rslt = 0
		Goto ext
	End If
	
	s_oda[i].FileBlob = lb_FileData
	
	i++
	Fetch cur_mx Into :s_oda[i].AnnexNo,
		:s_oda[i].FileName,
		:s_oda[i].Filetype,
		:s_oda[i].ifmain,
		:s_oda[i].modelflag;
Loop

Close cur_mx;

For i = 1 To UpperBound(s_oda) - 1
	arg_s_oda[i] = s_oda[i]
Next

ext:
Return rslt






end function

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

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