FXApp/ws_objects/app_base.pbl.src/uo_checkpda.sru

$PBExportHeader$uo_checkpda.sru
forward
global type uo_checkpda from uo_transactionobject
end type
type s_p_barcode_pda from structure within uo_checkpda
end type
end forward

type s_p_barcode_pda from structure
	string		barcode
	long		wrkgrpid
	long		kind
	long		flag
	string		opemp
	datetime		opdate
	long		workgroupid
end type

global type uo_checkpda from uo_transactionobject
end type
global uo_checkpda uo_checkpda

forward prototypes
public function integer uof_outware_sale_audit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt)
public function integer uof_reallocqty_for_order_by_mtrlid (long arg_mtrlid, long arg_fpgrade, ref string arg_msg)
public function integer uof_ordermtrl_workgroup_changed (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg)
public function integer uof_reallocqty_ifpack_bak (long arg_fpgrade, ref string arg_msg)
public function integer uof_reallocqty_ifpack (long arg_fpgrade, long arg_datenum, ref string arg_msg)
public function integer uof_delallocqty (decimal arg_assignday, decimal arg_outday, ref string arg_msg)
public subroutine uf_audit_getbar (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg)
public subroutine uf_audit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg)
public subroutine uf_secaudit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg)
public subroutine uf_thraudit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg)
public subroutine uof_recmpl_mtrlware_ifpackpro_capacity (ref string arg_msg)
public function integer uof_inware_cp_audit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt)
public function integer uof_outware_scll_secaudit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt)
public function integer uof_ordermtrl_workgroup_barcode_pt (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg, boolean arg_ifcommit)
public function integer uof_ordermtrl_workgroup_barcode_pt_auto (long arg_days, ref string arg_msg)
private function integer uof_add_workgroup_qty (long arg_scid, long arg_orderid, long arg_wrkgrpid, long arg_workgroupid, datetime arg_finishdate, decimal arg_qty, ref string arg_msg, boolean arg_ifcommit)
public function integer uof_workgroup_barcode_pt (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg, boolean arg_ifcommit)
public function integer uof_update_saleoutcodestr (long arg_scid, long arg_taskid, long arg_printid, ref string arg_msg)
public function integer uof_reallocqty (boolean arg_reallocall, boolean arg_ignorout, long arg_fpgrade, ref string arg_msg)
public function integer uof_inware_cp_uof_auto_scll_p (ref string arg_msg)
public function integer uof_reconnect (ref string arg_msg)
public subroutine uof_send_buytask_jd (ref string arg_msg)
public function integer uof_order_wkp_barcode_pda_bak (boolean arg_replace, boolean arg_finishbarcode, ref string arg_msg, ref long arg_cnt, ref long arg_failcnt)
public function integer uof_order_wkp_barcode_pda (boolean arg_replace, boolean arg_finishbarcode, ref string arg_msg, ref long arg_cnt, ref long arg_failcnt)
private function integer pf_get_barcodes_notflag (ref s_p_barcode_pda arg_bars[], ref string arg_msg)
public function integer uf_cmpl_cost_balcdateint (ref string arg_msg)
public function integer uof_cmpl_warebalc_amt (long arg_storageid, long arg_balcdateint, ref string arg_msg)
public function integer uof_cmpl_mtrlcost_planprice (long arr_mtrlid[], string arr_pfcode[], string arr_status[], string arr_woodcode[], string arr_pcode[], long li_dec, boolean if_auto_copy, integer ifprice, integer ifwfjgprice, integer ifjgprice, integer ifoutcost, integer ifotherprice, integer ifeqprice, ref string ls_msg)
private function integer pf_outware_to_inwarebuy (string ls_sn, datetime dt_server, ref string arg_msg)
public function integer uof_outware_to_inwarebuy (ref string ls_msg)
end prototypes

public function integer uof_outware_sale_audit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt);
uo_outware_sale uo_ware
uo_ware = Create uo_outware_sale
uo_ware.commit_transaction = commit_transaction

datastore ds_outware
ds_outware = Create datastore
ds_outware.DataObject = 'ds_outware_sale_noaudit_pda'
ds_outware.SetTransObject(commit_transaction)

ds_outware.Retrieve()

Long ll_i
String ls_outwarecode
Long ll_scid,ll_outwareid
String ls_msg
Long ll_fail,ll_suc

FOR ll_i = 1 To ds_outware.RowCount()
	ll_scid = ds_outware.Object.scid[ll_i]
	ll_outwareid = ds_outware.Object.outwareid[ll_i]
	ls_outwarecode =  ds_outware.Object.outwarecode[ll_i]
	
	IF uo_ware.getinfo(ll_scid,ll_outwareid,ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_outwarecode + ' 审核失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	IF uo_ware.auditing(True,ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_outwarecode + ' 审核失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	ll_suc++
NEXT

arg_cnt = ll_suc
arg_failcnt = ll_fail

Destroy uo_ware
Destroy ds_outware

RETURN 1


end function

public function integer uof_reallocqty_for_order_by_mtrlid (long arg_mtrlid, long arg_fpgrade, ref string arg_msg);Int rslt = 1

uo_mtrlware_assign uo_assign
uo_assign = Create uo_mtrlware_assign
uo_assign.commit_transaction = commit_transaction

Long ll_cnt
SELECT COUNT(0) Into :ll_cnt From u_mtrldef Where mtrlid = :arg_mtrlid Using commit_transaction;
IF commit_transaction.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '检测物料是否存在失败,' + commit_transaction.SQLErrText
	GOTO ext
END IF

IF ll_cnt = 0 THEN
	rslt = 0
	arg_msg = '物料不存在,mtrlid=' + String(arg_mtrlid)
	GOTO ext
END IF

IF uo_assign.uof_adjust_order_by_mtrlid(arg_mtrlid, arg_fpgrade, Ref arg_msg) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

ext:
Destroy uo_assign
IF rslt = 1 THEN
	COMMIT Using commit_transaction;
ELSE
	ROLLBACK Using commit_transaction;
END IF
RETURN rslt



end function

public function integer uof_ordermtrl_workgroup_changed (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg);Int rslt = 1

uo_ordermtrl_workgroup uo_omw
uo_omw = Create uo_ordermtrl_workgroup
uo_omw.commit_transaction = commit_transaction

IF uo_omw.uf_begindate_changed(arg_scid, arg_orderid, arg_wrkgrpid, Ref arg_msg, False) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

GOTO ext
ext:
Destroy uo_omw
IF rslt = 1 THEN
	COMMIT Using commit_transaction;
ELSE
	ROLLBACK Using commit_transaction;
END IF
RETURN rslt

end function

public function integer uof_reallocqty_ifpack_bak (long arg_fpgrade, ref string arg_msg);Int rslt = 1

uo_mtrlware_assign uo_mtrlware_fp
uo_mtrlware_fp = Create uo_mtrlware_assign
uo_mtrlware_fp.commit_transaction = commit_transaction

Long c_assignid[], ll_c_assignid
Decimal c_fpqty[], ld_c_fpqty
Long ll_c_cnt = 0

// 取消分配
DECLARE cur1 CURSOR FOR SELECT     u_mtrlware_assign.Assignid, u_mtrlware_assign.assignqty - u_mtrlware_assign.Outqty AS fpqty
	FROM u_mtrlware_assign INNER JOIN
	u_mtrldef ON u_mtrlware_assign.mtrlid = u_mtrldef.mtrlid
	WHERE (u_mtrlware_assign.fpgrade <= :arg_fpgrade) AND (u_mtrldef.ifpack = 1) AND (u_mtrlware_assign.assigntype = 1) AND
	(u_mtrlware_assign.assignqty > u_mtrlware_assign.Outqty) AND (NOT EXISTS
	(SELECT TOP 1 1 AS Expr1
	FROM u_outware INNER JOIN
	u_outwaremx ON u_outware.scid = u_outwaremx.scid AND u_outware.outwareid = u_outwaremx.outwareid
	WHERE (u_outware.billtype = 1) AND (u_outwaremx.relid = u_mtrlware_assign.Relbillid) AND
	(u_outwaremx.relprintid = u_mtrlware_assign.relprintid) And (u_outware.flag = 0))) Using commit_transaction;
OPEN cur1;
FETCH cur1 Into :ll_c_assignid, :ld_c_fpqty;
DO WHILE commit_transaction.SQLCode = 0
	ll_c_cnt ++
	c_assignid[ll_c_cnt] = ll_c_assignid
	c_fpqty[ll_c_cnt] = ld_c_fpqty
	FETCH cur1 Into :ll_c_assignid, :ld_c_fpqty;
LOOP
CLOSE cur1;

Long ll_i
FOR ll_i = 1 To ll_c_cnt
	IF uo_mtrlware_fp.uof_assign_del(c_assignid[ll_i],&
		c_fpqty[ll_i],arg_msg,False) = 0 THEN
		rslt = 0
		GOTO ext
	END IF
NEXT

COMMIT Using commit_transaction;

Long ll_scid, arr_scid[]
Long ll_TaskID, arr_TaskID[]
Long ll_printid, arr_printid[]
Decimal ld_notfpqty, arr_notfpqty[]
Long ll_MtrlID, arr_MtrlID[]
String ls_status, arr_status[]
String ls_woodcode, arr_woodcode[]
String ls_pcode, arr_pcode[]
Long ll_cnt = 0

// 重新分配订单明细
DECLARE cur2 CURSOR FOR SELECT u_SaleTaskMx.scid, u_SaleTaskMx.TaskID, u_SaleTaskMx.printid, u_SaleTaskMx.SaleQty - u_SaleTaskMx.stopqty - u_SaleTaskMx.fpqty AS notfpqty,
	u_SaleTaskMx.MtrlID, u_SaleTaskMx.status, u_SaleTaskMx.woodcode, u_SaleTaskMx.pcode
	FROM u_SaleTaskMx INNER JOIN
	u_mtrldef ON u_SaleTaskMx.MtrlID = u_mtrldef.mtrlid INNER JOIN
	u_SaleTask ON u_SaleTaskMx.scid = u_SaleTask.scid AND u_SaleTaskMx.TaskID = u_SaleTask.TaskID
	WHERE (u_SaleTaskMx.SaleQty - u_SaleTaskMx.stopqty - u_SaleTaskMx.fpqty > 0) AND (u_mtrldef.ifpack = 1) AND (u_SaleTask.Status = 1)
	Order By u_SaleTaskMx.requiredate Using commit_transaction;
OPEN cur2;
FETCH cur2 INTO :ll_scid,
	:ll_TaskID,
	:ll_printid,
	:ld_notfpqty,
	:ll_MtrlID,
	:ls_status,
	:ls_woodcode,
	:ls_pcode;
DO WHILE commit_transaction.SQLCode = 0
	ll_cnt++
	arr_scid[ll_cnt] = ll_scid
	arr_TaskID[ll_cnt] = ll_TaskID
	arr_printid[ll_cnt] = ll_printid
	arr_notfpqty[ll_cnt] = ld_notfpqty
	arr_MtrlID[ll_cnt] = ll_MtrlID
	arr_status[ll_cnt] = ls_status
	arr_woodcode[ll_cnt] = ls_woodcode
	arr_pcode[ll_cnt] = ls_pcode
	
	FETCH cur2 INTO :ll_scid,
		:ll_TaskID,
		:ll_printid,
		:ld_notfpqty,
		:ll_MtrlID,
		:ls_status,
		:ls_woodcode,
		:ls_pcode;
LOOP
CLOSE cur2;

Long ware_l_scid, ware__scid[]
Long ware_l_mtrlwareid, ware__mtrlwareid[]
Decimal ware_d_notfpqty, ware__notfpqty[]
Long ware_cnt = 0
Long ll_j
Decimal ld_curqty
String arg_log = ''

Long ml_cnt = 0

FOR ll_i = 1 To ll_cnt
	
	// 主计划未用料审的跳过
	ml_cnt = 0
	SELECT COUNT(0)
		INTO :ml_cnt
		FROM u_order_ml
		WHERE taskscid = :arr_scid[ll_i]
		AND taskid = :arr_TaskID[ll_i]
		AND taskmxid = :arr_printid[ll_i]
		Using commit_transaction;
	IF commit_transaction.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询订单明细是否有主计划失败,' + commit_transaction.SQLErrText
		GOTO ext
	END IF
	
	IF ml_cnt <= 0 THEN // 未有主计划跳过
		CONTINUE
	END IF
	
	ml_cnt = 0
	SELECT count(0)
		INTO :ml_cnt
		FROM u_order_ml
		WHERE taskscid = :arr_scid[ll_i]
		AND taskid = :arr_TaskID[ll_i]
		AND taskmxid = :arr_printid[ll_i]
		AND (scllflag = 0 OR scllsecflag = 0)
		Using commit_transaction;
	IF commit_transaction.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询订单明细未用料审主计划失败,' + commit_transaction.SQLErrText
		GOTO ext
	END IF
	
	IF ml_cnt > 0 THEN // 主计划未用料审
		CONTINUE
	END IF
	
	// 查询可分配库存
	ware_cnt = 0
	DECLARE cur3 CURSOR FOR SELECT u_mtrlware.scid, u_mtrlware.mtrlwareid, u_mtrlware.noallocqty - u_mtrlware.allocqty AS notfpqty
		FROM u_mtrlware INNER JOIN
		u_storage ON u_mtrlware.storageid = u_storage.storageid
		WHERE (u_storage.inuse = 1) AND (u_storage.storagetype = 1) AND (u_mtrlware.scid = :arr_scid[ll_i]) AND (u_mtrlware.mtrlid = :arr_mtrlid[ll_i]) AND
		(u_mtrlware.status = :arr_status[ll_i]) And (u_mtrlware.woodcode = :arr_woodcode[ll_i]) And (u_mtrlware.pcode = :arr_pcode[ll_i]) Using commit_transaction;
	OPEN cur3;
	FETCH cur3 INTO :ware_l_scid,
		:ware_l_mtrlwareid,
		:ware_d_notfpqty;
	DO WHILE commit_transaction.SQLCode = 0
		
		ware_cnt ++
		ware__scid[ware_cnt] = ware_l_scid
		ware__mtrlwareid[ware_cnt] = ware_l_mtrlwareid
		ware__notfpqty[ware_cnt] = ware_d_notfpqty
		
		FETCH cur3 INTO :ware_l_scid,
			:ware_l_mtrlwareid,
			:ware_d_notfpqty;
	LOOP
	CLOSE cur3;
	
	
	ld_notfpqty = arr_notfpqty[ll_i]
	FOR ll_j = 1 To ware_cnt
		
		IF ld_notfpqty <= 0 THEN EXIT
		
		IF ld_notfpqty > ware__notfpqty[ll_j] THEN
			ld_curqty = ware__notfpqty[ll_j]
		ELSE
			ld_curqty = ld_notfpqty
		END IF
		
		IF ld_curqty > 0 THEN
			IF uo_mtrlware_fp.uof_assign_add(ware__scid[ll_j],ware__mtrlwareid[ll_j],1,arr_TaskID[ll_i],arr_printid[ll_i],&
				ld_curqty,0,'','','',0,2,publ_operator,arg_msg,False) = 0 THEN
				arg_log += '分配失败,' + arg_msg + '~r~n'
				GOTO _next
			END IF
			ld_notfpqty -= ld_curqty
		END IF
		
		_next:
	NEXT
	
NEXT

ext:
Destroy uo_mtrlware_fp
IF rslt = 1 THEN
	COMMIT Using commit_transaction;
ELSE
	ROLLBACK Using commit_transaction;
END IF
RETURN rslt







end function

public function integer uof_reallocqty_ifpack (long arg_fpgrade, long arg_datenum, ref string arg_msg);Int rslt = 1
Long ll_i

uo_mtrlware_assign uo_mtrlware_fp
uo_mtrlware_fp = Create uo_mtrlware_assign
uo_mtrlware_fp.commit_transaction = commit_transaction

datastore ds_refp_pack1
ds_refp_pack1 = Create datastore
ds_refp_pack1.DataObject = 'ds_pack1_refp_task'
ds_refp_pack1.SetTransObject(commit_transaction)

datastore ds_refp_pack_mx
ds_refp_pack_mx = Create datastore
ds_refp_pack_mx.DataObject = 'ds_pack1_refp_mx'
ds_refp_pack_mx.SetTransObject(commit_transaction)

Long c_assignid[], ll_c_assignid
Decimal c_fpqty[], ld_c_fpqty
Long ll_c_cnt = 0



// 取消分配
DECLARE cur1 CURSOR FOR
	SELECT u_mtrlware_assign.assignid,
	u_mtrlware_assign.assignqty - u_mtrlware_assign.outqty as fpqty
	FROM u_mtrlware_assign INNER join
	u_mtrldef on u_mtrlware_assign.mtrlid = u_mtrldef.mtrlid
	WHERE ( u_mtrlware_assign.fpgrade <= :arg_fpgrade )
	AND ( u_mtrldef.ifpack = 1 )
	AND ( u_mtrlware_assign.assigntype = 1 )
	AND ( u_mtrlware_assign.assignqty > u_mtrlware_assign.outqty )
	AND (NOT EXISTS
	(SELECT top 1 1 as expr1
	FROM u_outware INNER join
	u_outwaremx on u_outware.scid = u_outwaremx.scid
	AND u_outware.outwareid = u_outwaremx.outwareid
	WHERE ( u_outware.billtype = 1 )
	AND ( u_outwaremx.scid = u_mtrlware_assign.scid )
	AND ( u_outwaremx.relid = u_mtrlware_assign.relbillid )
	AND ( u_outwaremx.relprintid = u_mtrlware_assign.relprintid )
	And ( u_outware.flag = 0))) Using commit_transaction;
OPEN cur1;
FETCH cur1 Into :ll_c_assignid, :ld_c_fpqty;
DO WHILE commit_transaction.SQLCode = 0
	ll_c_cnt ++
	c_assignid[ll_c_cnt] = ll_c_assignid
	c_fpqty[ll_c_cnt] = ld_c_fpqty
	FETCH cur1 Into :ll_c_assignid, :ld_c_fpqty;
LOOP
CLOSE cur1;


FOR ll_i = 1 To ll_c_cnt
	IF uo_mtrlware_fp.uof_assign_del(c_assignid[ll_i],&
		c_fpqty[ll_i],arg_msg,False) = 0 THEN
		rslt = 0
		GOTO ext
	END IF
NEXT

COMMIT Using commit_transaction;
arg_msg = arg_msg + '取消分配成功:' + String(ll_c_cnt)

//订单明细用
Long ll_scid
Long ll_taskid
Long ll_printid
Decimal ld_notfpqty
Long ll_mtrlid
String ls_status
String ls_woodcode
String ls_pcode
Long ll_cnt

//库存用
Long ware_l_scid, ware_scid[]
Long ware_l_mtrlwareid, ware_mtrlwareid[]
Decimal ware_d_notfpqty, ware_notfpqty[]
Long ware_cnt = 0
Long ll_j
Decimal ld_curqty
String arg_log = ''
Long ml_cnt = 0

Boolean if_enough
Long k

// 重新分配订单明细
ll_cnt = ds_refp_pack1.Retrieve(arg_datenum)
IF ll_cnt = -1 THEN
	rslt = 0
	arg_msg += ';获取重新分配订单明细失败,' + commit_transaction.SQLErrText
	GOTO ext
END IF

ll_cnt = ds_refp_pack1.RowCount()
arg_msg = arg_msg + ';正在执行分配' + String(ll_cnt)

FOR ll_i = 1 To ll_cnt
	ll_scid = ds_refp_pack1.Object.u_saletaskmx_scid[ll_i]
	ll_taskid = ds_refp_pack1.Object.u_saletaskmx_taskid[ll_i]
	
	ds_refp_pack_mx.Retrieve(ll_scid,ll_taskid)
	
	IF ds_refp_pack_mx.RowCount() = 0 THEN
		//不齐货
		//		arg_log += '分配失败,没有明细'
		//		f_task_writelog(ll_scid,ll_taskid,arg_log)
		CONTINUE
	ELSE
		if_enough = True
		
		FOR k = 1 To ds_refp_pack_mx.RowCount()
			IF ds_refp_pack_mx.Object.notfpqty[k] > ds_refp_pack_mx.Object.warenotfpqty[k] THEN
				if_enough = False
				EXIT
			END IF
		NEXT
		
		IF Not if_enough THEN
			CONTINUE
		ELSE
			
			FOR k = 1 To ds_refp_pack_mx.RowCount()
				ll_printid = ds_refp_pack_mx.Object.u_saletaskmx_printid[k]
				
				ll_mtrlid = ds_refp_pack_mx.Object.u_saletaskmx_mtrlid[k]
				ls_status = ds_refp_pack_mx.Object.u_saletaskmx_status[k]
				ls_woodcode = ds_refp_pack_mx.Object.u_saletaskmx_woodcode[k]
				ls_pcode = ds_refp_pack_mx.Object.u_saletaskmx_pcode[k]
				ld_notfpqty = ds_refp_pack_mx.Object.notfpqty[k]
				arg_msg = arg_msg + ',' + String(ll_taskid)
				// 主计划未用料审的跳过
				ml_cnt = 0
				SELECT count(0)
					INTO :ml_cnt
					FROM u_order_ml
					WHERE u_order_ml.taskscid = :ll_scid
					AND u_order_ml.taskid = :ll_taskid
					AND u_order_ml.taskmxid = :ll_printid
					Using commit_transaction;
				IF commit_transaction.SQLCode <> 0 THEN
					rslt = 0
					arg_msg += '查询订单明细是否有主计划失败,' + commit_transaction.SQLErrText
					GOTO ext
				END IF
				
				IF ml_cnt <= 0 THEN // 未有主计划跳过
					//		If ll_taskid = 8835 Then
					//			arg_msg = arg_msg + '未有主计划跳过'
					//		End If
					CONTINUE
				END IF
				
				ml_cnt = 0
				SELECT count(0)
					INTO :ml_cnt
					FROM u_order_ml
					WHERE u_order_ml.taskscid = :ll_scid
					AND u_order_ml.taskid = :ll_taskid
					AND u_order_ml.taskmxid = :ll_printid
					AND (u_order_ml.scllflag = 0 OR u_order_ml.scllsecflag = 0)
					Using commit_transaction;
				IF commit_transaction.SQLCode <> 0 THEN
					rslt = 0
					arg_msg += '查询订单明细未用料审主计划失败,' + commit_transaction.SQLErrText
					GOTO ext
				END IF
				
				IF ml_cnt > 0 THEN // 主计划未用料审
					//		If ll_taskid = 8835 Then
					//			arg_msg = arg_msg + '主计划未用料审'
					//		End If
					CONTINUE
				END IF
				
				//	If ll_taskid = 8835 Then
				//		arg_msg = arg_msg + '正在分配'
				//	End If
				//查询可分配库存
				ware_cnt = 0
				DECLARE cur3 CURSOR FOR
					SELECT u_mtrlware.scid,
					u_mtrlware.mtrlwareid,
					u_mtrlware.noallocqty - u_mtrlware.allocqty as notfpqty
					FROM u_mtrlware INNER join
					u_storage on u_mtrlware.storageid = u_storage.storageid
					WHERE (u_storage.inuse = 1)
					AND (u_storage.storagetype = 1)
					AND (u_mtrlware.scid = :ll_scid)
					AND (u_mtrlware.mtrlid = :ll_mtrlid)
					AND (u_mtrlware.status = :ls_status)
					AND (u_mtrlware.woodcode = :ls_woodcode)
					AND (u_mtrlware.pcode = :ls_pcode)
					And (u_mtrlware.noallocqty - u_mtrlware.allocqty > 0 ) Using commit_transaction;
				OPEN cur3;
				FETCH cur3 INTO :ware_l_scid,
					:ware_l_mtrlwareid,
					:ware_d_notfpqty;
				DO WHILE commit_transaction.SQLCode = 0
					ware_cnt ++
					ware_scid[ware_cnt] = ware_l_scid
					ware_mtrlwareid[ware_cnt] = ware_l_mtrlwareid
					ware_notfpqty[ware_cnt] = ware_d_notfpqty
					
					FETCH cur3 INTO :ware_l_scid,
						:ware_l_mtrlwareid,
						:ware_d_notfpqty;
				LOOP
				CLOSE cur3;
				
				FOR ll_j = 1 To ware_cnt
					
					IF ld_notfpqty <= 0 THEN EXIT
					
					IF ld_notfpqty > ware_notfpqty[ll_j] THEN
						ld_curqty = ware_notfpqty[ll_j]
						ld_notfpqty = ld_notfpqty - ld_curqty
					ELSE
						ld_curqty = ld_notfpqty
						ld_notfpqty = 0
					END IF
					
					IF ld_curqty > 0 THEN
						
						//			If ll_taskid = 8835 Then
						//				arg_msg = arg_msg + '分配数量' + String(ld_curqty)
						//			End If
						
						IF uo_mtrlware_fp.uof_assign_add(ll_scid,&
							ware_mtrlwareid[ll_j],&
							1,&
							ll_taskid,&
							ll_printid,&
							ld_curqty,&
							0,'','','',0,2,publ_operator,arg_log,False) = 0 THEN
							arg_msg += ';分配失败,' + arg_log + '~r~n'
							GOTO _next
						END IF
					END IF
					_next:
				NEXT
			NEXT
		END IF
	END IF
NEXT

ext:
Destroy uo_mtrlware_fp
Destroy ds_refp_pack1
Destroy ds_refp_pack_mx

IF rslt = 1 THEN
	COMMIT Using commit_transaction;
ELSE
	ROLLBACK Using commit_transaction;
END IF
RETURN rslt






end function

public function integer uof_delallocqty (decimal arg_assignday, decimal arg_outday, ref string arg_msg);return f_delallocqty(arg_assignday, arg_outday, ref arg_msg)
end function

public subroutine uf_audit_getbar (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg);//====================================================================
// 事件: uo_db_ys.uf_audit_getbar()
//--------------------------------------------------------------------
// 描述: 自动审核未审的条码生成单
//--------------------------------------------------------------------
// 参数:
// 	ref	long  	arg_sec 	
// 	ref	long  	arg_fail	
// 	ref	string	arg_msg 	
//--------------------------------------------------------------------
// 返回:  (none)
//--------------------------------------------------------------------
// 作者:	lwl		日期: 2012年06月04日
//--------------------------------------------------------------------
//	LONGJOE
//--------------------------------------------------------------------
// 修改历史:
//
//====================================================================

arg_sec = 0
arg_fail = 0
arg_msg = ''

String ls_msg = ''

uo_getbar uo_get
uo_get = Create uo_getbar

Long ll_billids[], ll_billid
String ls_billcodes[], ls_billcode
Long ll_i, ll_cnt = 0

Long ll_ifpdaonly
IF arg_ifpdaonly THEN
	ll_ifpdaonly = 1
ELSE
	ll_ifpdaonly = 0
END IF

DECLARE cur1 CURSOR FOR
	SELECT getbarid, getbarcode From u_getbar Where flag = 0 And (:ll_ifpdaonly = 0 Or :ll_ifpdaonly = 1 And dscrp = '系统自动生成');
OPEN cur1;

FETCH cur1 Into :ll_billid, :ls_billcode;
DO WHILE sqlca.SQLCode = 0
	ll_cnt ++
	ll_billids[ll_cnt] = ll_billid
	ls_billcodes[ll_cnt] = ls_billcode
	FETCH cur1 Into :ll_billid, :ls_billcode;
LOOP
CLOSE cur1;

FOR ll_i = 1 To ll_cnt
	ls_msg = ''
	IF uo_get.auditing(ll_billids[ll_i],publ_operator,Ref ls_msg,True) = 1 THEN
		arg_sec++
	ELSE
		ROLLBACK;
		arg_fail++
		ls_msg = '[' + ls_billcodes[ll_i] + ']审核失败:' + ls_msg
		IF arg_msg <> '' THEN
			ls_msg = ls_msg + '~r~n'
		END IF
		arg_msg = ls_msg + arg_msg
	END IF
NEXT

Destroy uo_get







end subroutine

public subroutine uf_audit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg);uo_finish uo_finish_wg
uo_finish_wg = Create uo_finish

arg_sec = 0
arg_fail = 0
arg_msg = ''
String ls_msg = ''

Long ll_billid, ll_billids[]
String ls_billcode, ls_billcodes[]
Long ll_i, ll_cnt = 0
Long ll_ifpdaonly
IF arg_ifpdaonly THEN
	ll_ifpdaonly = 1
ELSE
	ll_ifpdaonly = 0
END IF

DECLARE cur1 CURSOR FOR
	SELECT finishid, finishcode From u_finish Where flag = 0 And (:ll_ifpdaonly = 0 Or :ll_ifpdaonly = 1 And dscrp = '系统自动生成');
OPEN cur1;
FETCH cur1 Into :ll_billid, :ls_billcode;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	ll_billids[ll_cnt] = ll_billid
	ls_billcodes[ll_cnt] = ls_billcode
	FETCH cur1 Into :ll_billid, :ls_billcode;
LOOP
CLOSE cur1;

FOR ll_i = 1 To ll_cnt
	IF uo_finish_wg.audit(ll_billids[ll_i], Ref ls_msg, True) = 1 THEN
		arg_sec++
	ELSE
		ROLLBACK;
		arg_fail++
		ls_msg = '[' + ls_billcodes[ll_i] + ']确认失败:' + ls_msg
		IF arg_msg <> '' THEN
			ls_msg = ls_msg + '~r~n'
		END IF
		arg_msg = ls_msg + arg_msg
	END IF
NEXT

Destroy uo_finish_wg



end subroutine

public subroutine uf_secaudit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg);uo_finish uo_finish_wg
uo_finish_wg = Create uo_finish

arg_sec = 0
arg_fail = 0
arg_msg = ''
String ls_msg = ''

Long ll_billid, ll_billids[]
String ls_billcode, ls_billcodes[]
Long ll_i, ll_cnt = 0
Long ll_ifpdaonly
IF arg_ifpdaonly THEN
	ll_ifpdaonly = 1
ELSE
	ll_ifpdaonly = 0
END IF

DECLARE cur1 CURSOR FOR
	SELECT finishid, finishcode From u_finish Where flag = 1 AND secflag = 0 And (:ll_ifpdaonly = 0 Or :ll_ifpdaonly = 1 And dscrp = '系统自动生成');
OPEN cur1;
FETCH cur1 Into :ll_billid, :ls_billcode;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	ll_billids[ll_cnt] = ll_billid
	ls_billcodes[ll_cnt] = ls_billcode
	FETCH cur1 Into :ll_billid, :ls_billcode;
LOOP
CLOSE cur1;

FOR ll_i = 1 To ll_cnt
	IF uo_finish_wg.secauditing(ll_billids[ll_i], Ref ls_msg, True) = 1 THEN
		arg_sec++
	ELSE
		ROLLBACK;
		arg_fail++
		ls_msg = '[' + ls_billcodes[ll_i] + ']仓审失败:' + ls_msg
		IF arg_msg <> '' THEN
			ls_msg = ls_msg + '~r~n'
		END IF
		arg_msg = ls_msg + arg_msg
	END IF
NEXT

Destroy uo_finish_wg


end subroutine

public subroutine uf_thraudit_finish (boolean arg_ifpdaonly, ref long arg_sec, ref long arg_fail, ref string arg_msg);uo_finish uo_finish_wg
uo_finish_wg = Create uo_finish

arg_sec = 0
arg_fail = 0
arg_msg = ''
String ls_msg = ''

Long ll_billid, ll_billids[]
String ls_billcode, ls_billcodes[]
Long ll_i, ll_cnt = 0
Long ll_ifpdaonly
IF arg_ifpdaonly THEN
	ll_ifpdaonly = 1
ELSE
	ll_ifpdaonly = 0
END IF

DECLARE cur1 CURSOR FOR
	SELECT finishid, finishcode From u_finish Where flag = 1 AND secflag = 1 AND thrflag = 0 And (:ll_ifpdaonly = 0 Or :ll_ifpdaonly = 1 And dscrp = '系统自动生成');
OPEN cur1;
FETCH cur1 Into :ll_billid, :ls_billcode;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	ll_billids[ll_cnt] = ll_billid
	ls_billcodes[ll_cnt] = ls_billcode
	FETCH cur1 Into :ll_billid, :ls_billcode;
LOOP
CLOSE cur1;

FOR ll_i = 1 To ll_cnt
	IF uo_finish_wg.thrauditing(ll_billids[ll_i], Ref ls_msg, True,0) = 1 THEN
		arg_sec++
	ELSE
		ROLLBACK;
		arg_fail++
		ls_msg = '[' + ls_billcodes[ll_i] + ']计审失败:' + ls_msg
		IF arg_msg <> '' THEN
			ls_msg = ls_msg + '~r~n'
		END IF
		arg_msg = ls_msg + arg_msg
	END IF
NEXT

Destroy uo_finish_wg


end subroutine

public subroutine uof_recmpl_mtrlware_ifpackpro_capacity (ref string arg_msg);datastore dw_pageretr

Long ll_mtrlid,ll_storageid,ll_mtrlwareid
String ls_status
Decimal ld_ref_qty
Long ll_i,ll_j,ll_scid
Int li_statusflag,li_ifpackpro
Decimal ld_capacity,ld_capacity_zj
s_mtrlcfg_expr s_pz[]
String ls_status_zj
Long ll_fail = 0,ll_suc = 0
String ls_mtrlcode

dw_pageretr = Create datastore
dw_pageretr.DataObject = 'ds_recmpl_mtrlware_capacity'
dw_pageretr.SetTransObject(sqlca)
dw_pageretr.Retrieve()

dw_pageretr.AcceptText()


FOR ll_i = 1 To dw_pageretr.RowCount()
	
	ll_mtrlid = dw_pageretr.Object.u_mtrlware_mtrlid[ll_i]
	ll_mtrlwareid = dw_pageretr.Object.u_mtrlware_mtrlwareid[ll_i]
	ls_status = dw_pageretr.Object.u_mtrlware_status[ll_i]
	ls_mtrlcode = dw_pageretr.Object.u_mtrldef_mtrlcode[ll_i]
	ll_scid = dw_pageretr.Object.u_mtrlware_scid[ll_i]
	
	SELECT capacity,statusflag,ifpackpro
		INTO :ld_capacity,:li_statusflag,:li_ifpackpro
		FROM u_mtrldef
		Where mtrlid = :ll_mtrlid ;
	IF sqlca.SQLCode <> 0 THEN
		arg_msg = arg_msg + '物料编码:'+ls_mtrlcode+' 查询资料失败,'+sqlca.SQLErrText + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	IF li_statusflag = 2 THEN
		ld_capacity = 0
		f_checkpz(ls_status,s_pz[])
		FOR ll_j = 1 To  UpperBound(s_pz)
			ls_status_zj = s_pz[ll_j].cfgname
			
			SELECT capacity
				INTO :ld_capacity_zj
				FROM u_mtrl_configure
				WHERE mtrlid = :ll_mtrlid
				And Name = :ls_status_zj;
			IF sqlca.SQLCode <> 0 THEN
				ld_capacity_zj = 0
			END IF
			
			ld_capacity = ld_capacity + ld_capacity_zj * Dec(s_pz[ll_j].qty)
			
		NEXT
	END IF
	
	IF li_ifpackpro = 0 THEN
		UPDATE u_mtrlware
			SET u_mtrlware.capacity = u_mtrlware.noallocqty * :ld_capacity
			WHERE u_mtrlware.mtrlwareid = :ll_mtrlwareid
			And u_mtrlware.scid = :ll_scid;
	ELSEIF li_ifpackpro = 1 Or li_ifpackpro = 2 THEN
		UPDATE u_mtrlware
			SET u_mtrlware.capacity = u_mtrlware.canuseqty * :ld_capacity
			WHERE u_mtrlware.mtrlwareid = :ll_mtrlwareid
			And u_mtrlware.scid = :ll_scid;
	ELSEIF li_ifpackpro = 3 Or li_ifpackpro = 4 THEN
		IF Pos(ls_status,'+') > 0 Or Pos(ls_status,'*') > 0 THEN
			UPDATE u_mtrlware
				SET u_mtrlware.capacity = u_mtrlware.canuseqty * :ld_capacity
				WHERE u_mtrlware.mtrlwareid = :ll_mtrlwareid
				And u_mtrlware.scid = :ll_scid;
		ELSE
			UPDATE u_mtrlware
				SET u_mtrlware.capacity = u_mtrlware.noallocqty * :ld_capacity
				WHERE u_mtrlware.mtrlwareid = :ll_mtrlwareid
				And u_mtrlware.scid = :ll_scid;
		END IF
	END IF
	IF sqlca.SQLCode <> 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + '编码:'+ls_mtrlcode+' 失败,~n'
		ll_fail++
		CONTINUE
	END IF
	
	ll_suc++
	COMMIT;
NEXT

IF ll_fail > 0 THEN
	arg_msg = '重算包件产品折算套数~n'+arg_msg
ELSE
	arg_msg = '重算包件产品折算套数成功:'+string(ll_suc)
END IF


end subroutine

public function integer uof_inware_cp_audit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt);Int rslt = 1

uo_inware_cp uo_ware
uo_ware = Create uo_inware_cp

datastore ds_inware
ds_inware = Create datastore

Long ll_cnt
SELECT count(0) INTO :ll_cnt
	FROM u_inware
	Where (billtype = 3) And (flag = 0) Using commit_transaction;
IF commit_transaction.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询共需要处理数据失败,' + commit_transaction.SQLErrText
	GOTO ext
END IF

arg_msg = '共有' + String(ll_cnt) + '条语句需要处理'

uo_ware.commit_transaction = commit_transaction
ds_inware.DataObject = 'ds_inware_cp_noaudit_pda'
ds_inware.SetTransObject(commit_transaction)
IF ds_inware.Retrieve() < 0 THEN
	rslt = 0
	arg_msg = arg_msg + '查询未审生产进仓单失败'
	GOTO ext
END IF

Long ll_i
String ls_inwarecode
Long ll_scid,ll_inwareid
String ls_msg
Long ll_fail,ll_suc

FOR ll_i = 1 To ds_inware.RowCount()
	ll_scid = ds_inware.Object.scid[ll_i]
	ll_inwareid = ds_inware.Object.inwareid[ll_i]
	ls_inwarecode =  ds_inware.Object.inwarecode[ll_i]
	
	IF uo_ware.getinfo(ll_scid,ll_inwareid,ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_inwarecode + ' 审核失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	IF uo_ware.auditing(True,ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_inwarecode + ' 审核失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	ll_suc++
NEXT
arg_cnt = ll_suc
arg_failcnt = ll_fail

ext:
Destroy uo_ware
Destroy ds_inware

RETURN rslt




end function

public function integer uof_outware_scll_secaudit (ref string arg_msg, ref long arg_cnt, ref long arg_failcnt);Int rslt = 1

uo_outware_scll uo_ware
uo_ware = Create uo_outware_scll

Long ll_cnt
SELECT count(0)
	INTO :ll_cnt
	FROM u_outware
	Where (billtype = 3) And (flag = 1) And (secflag = 0) Using commit_transaction;
IF commit_transaction.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询共需要处理数据失败,' + commit_transaction.SQLErrText
	GOTO ext
END IF

arg_msg = '共有' + String(ll_cnt) + '条语句需要处理'

uo_ware.commit_transaction = commit_transaction

Long ll_scid, ll_outwareid
Long arr_scid[], arr_outwareid[]
String ls_outwarecode
String arr_outwarecode[]

ll_cnt = 0
DECLARE cur1 CURSOR FOR
	SELECT scid, outwareid, outwarecode
	FROM u_outware
	Where (billtype = 3) And (flag = 1) And (secflag = 0) Using commit_transaction;
OPEN cur1;
FETCH cur1 Into :ll_scid, :ll_outwareid, :ls_outwarecode;
DO WHILE commit_transaction.SQLCode = 0
	ll_cnt++
	arr_scid[ll_cnt] = ll_scid
	arr_outwareid[ll_cnt] = ll_outwareid
	arr_outwarecode[ll_cnt] = ls_outwarecode
	FETCH cur1 Into :ll_scid, :ll_outwareid, :ls_outwarecode;
LOOP
CLOSE cur1;

Long ll_i
String ls_msg
Long ll_fail,ll_suc

FOR ll_i = 1 To ll_cnt
	ll_scid = arr_scid[ll_i]
	ll_outwareid = arr_outwareid[ll_i]
	ls_outwarecode =  arr_outwarecode[ll_i]
	
	IF uo_ware.getinfo(ll_scid,ll_outwareid,ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_outwarecode + ' 查询失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	IF uo_ware.uof_auto_secaudit(ls_msg) = 0 THEN
		ROLLBACK;
		arg_msg = arg_msg + ls_outwarecode + ' 二审失败,'+ls_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
	
	ll_suc++
NEXT
arg_cnt = ll_suc
arg_failcnt = ll_fail

ext:
Destroy uo_ware

RETURN rslt







end function

public function integer uof_ordermtrl_workgroup_barcode_pt (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg, boolean arg_ifcommit);Int rslt = 1

Long ll_cnt = 0
DateTime ld_sdate, arr_sdate[]

Long ll_jdtype
SELECT jdtype
	INTO :ll_jdtype
	FROM u_sc_workgroup
	Where wrkgrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询工组进度生成模式失败,' + sqlca.SQLErrText
	GOTO ext
END IF

IF ll_jdtype <> 6 THEN
	GOTO ext
END IF

UPDATE u_OrderMtrl_workgroup
	SET finishqty = 0,
	finishflag = 0,
	finishdate = NULL
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And wrkgrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '1.更新工组进度失败,' + sqlca.SQLErrText
	GOTO ext
END IF

UPDATE u_ordermtrl_workgroup_barcode
	SET ptflag = 0,
	ptdate = NULL
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And swkpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '2.更新配套标记失败,' + sqlca.SQLErrText
	GOTO ext
END IF

DELETE FROM u_OrderMtrl_workgroup_date
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And wrkgrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '3.删除工组日进度失败,' + sqlca.SQLErrText
	GOTO ext
END IF

IF uof_workgroup_barcode_pt(arg_scid, arg_orderid, arg_wrkgrpid, arg_msg, False) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

GOTO ext
ext:
IF arg_ifcommit THEN
	IF rslt = 1 THEN
		COMMIT;
	ELSE
		ROLLBACK;
	END IF
END IF

RETURN rslt
























end function

public function integer uof_ordermtrl_workgroup_barcode_pt_auto (long arg_days, ref string arg_msg);Int rslt = 1

Long ll_scid, arr_scid[]
Long ll_orderid, arr_orderid[]
Long ll_wrkgrpid, arr_wrkgrpid[]
Long ll_cnt = 0

DateTime dt_server

SELECT top 1 getdate()
	INTO :dt_server
	From u_user;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询服务器时间失败,' + sqlca.SQLErrText
	GOTO ext
END IF

dt_server = DateTime(Date(dt_server), Time(0))

dt_server = DateTime(RelativeDate(Date(dt_server), - arg_days), Time(0))

DECLARE cur1 CURSOR FOR
	SELECT DISTINCT u_ordermtrl_workgroup_barcode.scid, u_ordermtrl_workgroup_barcode.orderid, u_ordermtrl_workgroup_barcode.swkpid
	FROM u_ordermtrl_workgroup_barcode INNER JOIN
	u_Order_ml ON u_ordermtrl_workgroup_barcode.scid = u_Order_ml.scid AND
	u_ordermtrl_workgroup_barcode.orderid = u_Order_ml.OrderID INNER JOIN
	u_OrderMtrl_workgroup_tree ON u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup_tree.scid AND
	u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup_tree.orderid AND
	u_ordermtrl_workgroup_barcode.printid = u_OrderMtrl_workgroup_tree.printid INNER JOIN
	u_OrderMtrl_workgroup ON u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup.scid AND
	u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup.orderid AND
	u_ordermtrl_workgroup_barcode.swkpid = u_OrderMtrl_workgroup.wrkGrpid
	Where (u_ordermtrl_workgroup_barcode.sflag = 1) And (u_ordermtrl_workgroup_barcode.sdate >= :dt_server) And (u_OrderMtrl_workgroup_tree.iflast = 0);
OPEN cur1;
FETCH cur1 Into :ll_scid, :ll_orderid, :ll_wrkgrpid;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	arr_scid[ll_cnt] = ll_scid
	arr_orderid[ll_cnt] = ll_orderid
	arr_wrkgrpid[ll_cnt] = ll_wrkgrpid
	FETCH cur1 Into :ll_scid, :ll_orderid, :ll_wrkgrpid;
LOOP
CLOSE cur1;

Long i
String ls_msg
arg_msg = ''
FOR i = 1 To ll_cnt
	IF uof_ordermtrl_workgroup_barcode_pt(arr_scid[i], arr_orderid[i], arr_wrkgrpid[i], ls_msg, True) <> 1 THEN
		arg_msg = arg_msg + ls_msg + '~r~n'
	END IF
NEXT
IF arg_msg <> '' THEN
	rslt = 0
END IF
ext:
RETURN rslt

end function

private function integer uof_add_workgroup_qty (long arg_scid, long arg_orderid, long arg_wrkgrpid, long arg_workgroupid, datetime arg_finishdate, decimal arg_qty, ref string arg_msg, boolean arg_ifcommit);//更新工组进度完成数
Int rslt = 1
String ls_ordercode
String ls_mtrlcode
Decimal ld_orderqty,ld_acmpqty,ld_trueqty
DateTime null_dt
SetNull(null_dt)

DateTime dt_fdate

IF arg_orderid <= 0 THEN
	rslt = 0
	arg_msg = '错误的计划唯一码'
	GOTO ext
END IF

SELECT ordercode INTO :ls_ordercode
	FROM u_Order_ml
	WHERE OrderID = :arg_orderid
	And scid = :arg_scid;
IF sqlca.SQLCode <> 0 THEN
	arg_msg = '查询生产计划编号失败'
	rslt = 0
	GOTO ext
END IF

SELECT u_mtrldef.mtrlcode ,
	u_order_ml.orderqty,
	u_order_ml.acmpqty
	INTO :ls_mtrlcode,
	:ld_orderqty,
	:ld_acmpqty
	FROM u_mtrldef,u_order_ml
	WHERE u_order_ml.mtrlid = u_mtrldef.mtrlid
	AND u_order_ml.scid = :arg_scid
	And u_Order_ml.OrderID = :arg_orderid;
IF sqlca.SQLCode <> 0 THEN
	arg_msg = '查询物料编号失败'
	rslt = 0
	GOTO ext
END IF

//arg_wrkgrpid:源工组; 
Decimal not_finishqty
SELECT isnull(sum(orderqty - finishqty - stopqty),0)
	INTO :not_finishqty
	FROM u_OrderMtrl_workgroup
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	AND wrkGrpid = :arg_wrkgrpid
	Using sqlca;
IF sqlca.SQLCode <> 0 THEN
	arg_msg = ',查询物料:'+ls_mtrlcode+'源工组未完成数量失败,原因:'+sqlca.SQLErrText
	rslt = 0
	GOTO ext
END IF

IF arg_qty > not_finishqty THEN
	//	arg_msg = '物料:'+ls_mtrlcode+'当前数量'+String(arg_qty,'#,##0.0###')+' > 工组未完成数量'+String(not_finishqty,'#,##0.0###')+',不能审核'
	//	rslt = 0
	//	GOTO ext
	arg_qty = not_finishqty
END IF

Long ll_owrkgrpid, arr_owrkgrpid[]
String ls_wkpname, arr_wkpname[]
Long ll_workgroupid, arr_workgroupid[]
Decimal ld_ufqty, arr_ufqty[]
Long ll_cnt = 0

DECLARE cur1 CURSOR FOR
	SELECT owrkgrpid, wkpname, workgroupid, orderqty - finishqty - stopqty
	FROM u_OrderMtrl_workgroup
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	AND wrkGrpid = :arg_wrkgrpid
	AND workgroupid = :arg_workgroupid
	UNION
	SELECT owrkgrpid, wkpname, workgroupid, orderqty - finishqty - stopqty
	FROM u_OrderMtrl_workgroup
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	AND wrkGrpid = :arg_wrkgrpid
	And workgroupid <> :arg_workgroupid;
OPEN cur1;
FETCH cur1 Into :ll_owrkgrpid, :ls_wkpname, :ll_workgroupid, :ld_ufqty;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	arr_owrkgrpid[ll_cnt] = ll_owrkgrpid
	arr_wkpname[ll_cnt] = ls_wkpname
	arr_workgroupid[ll_cnt] = ll_workgroupid
	arr_ufqty[ll_cnt] = ld_ufqty
	FETCH cur1 Into :ll_owrkgrpid, :ls_wkpname, :ll_workgroupid, :ld_ufqty;
LOOP
CLOSE cur1;

Long i
Decimal ld_addqty
ld_addqty = arg_qty
FOR i = 1 To ll_cnt
	ll_owrkgrpid = arr_owrkgrpid[i]
	ls_wkpname = arr_wkpname[i]
	ll_workgroupid = arr_workgroupid[i]
	ld_ufqty = arr_ufqty[i]
	
	IF ld_addqty <= 0 THEN
		EXIT
	END IF
	
	IF ld_addqty >= ld_ufqty THEN
		UPDATE u_OrderMtrl_workgroup
			SET finishqty = finishqty + :ld_ufqty,
			finishflag = 1,
			finishdate = :arg_finishdate
			WHERE scid = :arg_scid
			AND orderid = :arg_orderid
			AND wrkgrpid = :arg_wrkgrpid
			AND owrkgrpid = :ll_owrkgrpid
			AND wkpname = :ls_wkpname
			And workgroupid = :ll_workgroupid;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg = '更新物料:'+ls_mtrlcode+'源工组未完成数量失败,原因:'+sqlca.SQLErrText
			rslt = 0
			GOTO ext
		END IF
		ld_addqty = ld_addqty - ld_ufqty
	ELSE
		UPDATE u_OrderMtrl_workgroup
			SET finishqty = finishqty + :ld_addqty
			WHERE scid = :arg_scid
			AND orderid = :arg_orderid
			AND wrkgrpid = :arg_wrkgrpid
			AND owrkgrpid = :ll_owrkgrpid
			AND wkpname = :ls_wkpname
			And workgroupid = :ll_workgroupid;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg = '更新物料:'+ls_mtrlcode+'源工组未完成数量失败,原因:'+sqlca.SQLErrText
			rslt = 0
			GOTO ext
		END IF
		ld_addqty = 0
	END IF
NEXT

Decimal ld_sumorderqty
SELECT isnull(sum(orderqty),0)
	INTO :ld_sumorderqty
	FROM u_OrderMtrl_workgroup
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And wrkGrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询物料:'+ls_mtrlcode+'计划数失败,' + sqlca.SQLErrText
	GOTO ext
END IF

Decimal ld_sumfqty
SELECT isnull(sum(fqty),0)
	INTO :ld_sumfqty
	FROM u_OrderMtrl_workgroup_date
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And wrkGrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询物料:'+ls_mtrlcode+'已完成数失败,' + sqlca.SQLErrText
	GOTO ext
END IF

ld_addqty = arg_qty
IF ld_addqty + ld_sumfqty > ld_sumorderqty THEN
	ld_addqty = ld_sumorderqty - ld_sumfqty
END IF

dt_fdate = DateTime(Date(arg_finishdate), Time(0))
UPDATE u_OrderMtrl_workgroup_date
	SET fqty = fqty + :ld_addqty
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	AND wrkgrpid = :arg_wrkgrpid
	And fdate = :dt_fdate;
IF sqlca.SQLCode = 0 THEN
	IF sqlca.SQLNRows = 0 THEN
		INSERT INTO u_OrderMtrl_workgroup_date
			(scid,orderid,wrkgrpid,fdate,fqty)
			VALUES
			(:arg_scid,:arg_orderid,:arg_wrkgrpid,:dt_fdate,:ld_addqty);
		IF sqlca.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = '插入工组当天进度失败,'+sqlca.SQLErrText
			GOTO ext
		END IF
	END IF
ELSE
	rslt = 0
	arg_msg = '更新工组当天进度失败,'+sqlca.SQLErrText
	GOTO ext
END IF

ext:
IF rslt = 0 THEN
	ROLLBACK;
ELSEIF rslt = 1 And arg_ifcommit THEN
	COMMIT;
END IF
RETURN rslt
















end function

public function integer uof_workgroup_barcode_pt (long arg_scid, long arg_orderid, long arg_wrkgrpid, ref string arg_msg, boolean arg_ifcommit);Int rslt = 1

Long ll_cnt = 0
DateTime ld_sdate, arr_sdate[]
Long ll_jdtype
SELECT jdtype
	INTO :ll_jdtype
	FROM u_sc_workgroup
	Where wrkgrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询工组进度生成模式失败,' + sqlca.SQLErrText
	GOTO ext
END IF

IF ll_jdtype <> 6 THEN
	GOTO ext
END IF

UPDATE u_OrderMtrl_workgroup
	SET finishqty = finishqty
	WHERE scid = :arg_scid
	AND orderid = :arg_orderid
	And wrkgrpid = :arg_wrkgrpid;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '锁住工组进度失败,' + sqlca.SQLErrText
	GOTO ext
END IF


DECLARE cur1 CURSOR FOR
	SELECT DISTINCT CAST(CONVERT(varchar(10), sdate, 120) AS datetime) AS sdate
	FROM u_ordermtrl_workgroup_barcode
	WHERE (scid = :arg_scid)
	AND (orderid = :arg_orderid)
	AND (swkpid = :arg_wrkgrpid)
	AND (sflag = 1)
	AND (ptflag = 0)
	Order By sdate;
OPEN cur1;
FETCH cur1 Into :ld_sdate;
DO WHILE sqlca.SQLCode = 0
	ll_cnt++
	arr_sdate[ll_cnt] = ld_sdate
	FETCH cur1 Into :ld_sdate;
LOOP
CLOSE cur1;
Long i,j,k
Decimal ld_qty1, ld_qty2, ld_addqty

Long ll_printid, arr_printid[]
Long ll_gycnt

Long ll_pid, arr_pid[]
Decimal ld_qty, arr_qty[]
Long ll_ptflag, arr_ptflag[]
Long ll_bcnt

FOR i = 1 To ll_cnt
	ld_sdate = DateTime(RelativeDate(Date(arr_sdate[i]), 1))
	ld_qty1 = 0
	ld_qty2 = 0
	
	SELECT ISNULL(MIN(sqty),0)
		INTO :ld_qty1
		FROM (SELECT SUM(CASE WHEN (ptflag = 1) AND (ptdate < :ld_sdate) THEN qty ELSE 0 END) AS sqty, printid
		FROM u_ordermtrl_workgroup_barcode
		WHERE (scid = :arg_scid)
		AND (orderid = :arg_orderid)
		AND (swkpid = :arg_wrkgrpid)
		Group By printid) AS vvv;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询已配套数失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
	SELECT ISNULL(MIN(sqty),0)
		INTO :ld_qty2
		FROM (SELECT SUM(CASE WHEN (sflag = 1) AND (sdate < :ld_sdate) THEN qty ELSE 0 END) AS sqty, printid
		FROM u_ordermtrl_workgroup_barcode
		WHERE (scid = :arg_scid)
		AND (orderid = :arg_orderid)
		AND (swkpid = :arg_wrkgrpid)
		Group By printid) AS vvv;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询已配套数失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
	
	
	IF ld_qty2 - ld_qty1 > 0 THEN
		ll_gycnt = 0
		DECLARE cur2 CURSOR FOR
			SELECT printid
			FROM u_OrderMtrl_workgroup_tree
			WHERE scid = :arg_scid
			AND orderid = :arg_orderid
			And swkpid = :arg_wrkgrpid;
		OPEN cur2;
		FETCH cur2 Into :ll_printid;
		DO WHILE sqlca.SQLCode = 0
			ll_gycnt++
			arr_printid[ll_gycnt] = ll_printid
			FETCH cur2 Into :ll_printid;
		LOOP
		CLOSE cur2;
		
		FOR j = 1 To ll_gycnt
			ld_addqty = ld_qty2
			ll_bcnt = 0
			DECLARE cur3 CURSOR FOR
				SELECT pid, qty, ptflag
				FROM u_ordermtrl_workgroup_barcode
				WHERE scid = :arg_scid
				AND orderid = :arg_orderid
				AND printid = :arr_printid[j]
				AND sflag = 1
				AND sdate < :ld_sdate
				Order By ptflag Desc, sdate;
			OPEN cur3;
			FETCH cur3 Into :ll_pid, :ld_qty, :ll_ptflag;
			DO WHILE sqlca.SQLCode = 0
				ll_bcnt++
				arr_pid[ll_bcnt] = ll_pid
				arr_qty[ll_bcnt] = ld_qty
				arr_ptflag[ll_bcnt] = ll_ptflag
				FETCH cur3 Into :ll_pid, :ld_qty, :ll_ptflag;
			LOOP
			CLOSE cur3;
			
			FOR k = 1 To ll_bcnt
				IF ld_addqty <= 0 THEN
					EXIT
				END IF
				
				ld_addqty -= arr_qty[k]
				
				IF arr_ptflag[k] = 0 THEN
					UPDATE u_ordermtrl_workgroup_barcode
						SET ptflag = 1, ptdate = :arr_sdate[i]
						WHERE scid = :arg_scid
						AND orderid = :arg_orderid
						AND printid = :arr_printid[j]
						And pid = :arr_pid[k];
					IF sqlca.SQLCode <> 0 THEN
						rslt = 0
						arg_msg = '更新配套标记失败,' + sqlca.SQLErrText
						GOTO ext
					END IF
				END IF
			NEXT
		NEXT
		
		ld_addqty = ld_qty2 - ld_qty1
		
		IF uof_add_workgroup_qty(arg_scid, arg_orderid, arg_wrkgrpid, 0, arr_sdate[i], ld_addqty, arg_msg, False) <> 1 THEN
			rslt = 0
			GOTO ext
		END IF
	END IF
NEXT

GOTO ext
ext:
IF arg_ifcommit THEN
	IF rslt = 1 THEN
		COMMIT;
	ELSE
		ROLLBACK;
	END IF
END IF

RETURN rslt
























end function

public function integer uof_update_saleoutcodestr (long arg_scid, long arg_taskid, long arg_printid, ref string arg_msg);return f_update_saleoutcodestr(arg_scid, arg_taskid, arg_printid, true, arg_msg)
end function

public function integer uof_reallocqty (boolean arg_reallocall, boolean arg_ignorout, long arg_fpgrade, ref string arg_msg);TRY
	RETURN f_reallocqty_yyx(arg_reallocall, arg_ignorout, arg_fpgrade, Ref arg_msg)
Catch (throwable ex)
	arg_msg = ex.Text
	RETURN 0
END TRY
end function

public function integer uof_inware_cp_uof_auto_scll_p (ref string arg_msg);Int rslt = 1

uo_inware_cp uo_ware
uo_ware = Create uo_inware_cp

uo_ware.commit_transaction = commit_transaction
IF uo_ware.uof_auto_scll_p(Ref arg_msg) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

ext:
Destroy uo_ware
RETURN rslt

end function

public function integer uof_reconnect (ref string arg_msg);Int rslt = 1

DISCONNECT Using id_sqlca;
CONNECT Using id_sqlca;
IF id_sqlca.SQLCode < 0 THEN
	rslt = 0
	arg_msg = 'ID连接数据库失败,' + id_sqlca.SQLErrText
	GOTO ext
END IF

DISCONNECT;
CONNECT;
IF sqlca.SQLCode < 0 THEN
	rslt = 0
	arg_msg = '连接数据库失败,' + sqlca.SQLErrText
	GOTO ext
END IF

ext:
RETURN rslt

end function

public subroutine uof_send_buytask_jd (ref string arg_msg);uo_saletask_jdbll uo_bll
uo_bll = create uo_saletask_jdbll

uo_bll.uf_send_buytask_jd(arg_msg)

destroy uo_bll
end subroutine

public function integer uof_order_wkp_barcode_pda_bak (boolean arg_replace, boolean arg_finishbarcode, ref string arg_msg, ref long arg_cnt, ref long arg_failcnt);//====================================================================
// 事件: .f_order_wkp_barcode_pda()
//--------------------------------------------------------------------
// 描述:
//--------------------------------------------------------------------
// 参数:
// 	value    	boolean	arg_replace	优先完成时间较早的计划
// 	reference	string 	arg_msg    	
// 	reference	long   	arg_cnt    	
// 	reference	long   	arg_failcnt	
//--------------------------------------------------------------------
// 返回:  integer
//--------------------------------------------------------------------
// 作者:	lwl		日期: 2012年02月24日
//--------------------------------------------------------------------
//	LONGJOE
//--------------------------------------------------------------------
// 修改历史:
//
//====================================================================


Int rslt = 1
Long ll_i,ll_j,ll_k,ll_l,ll_m
Long ll_wrkgrpid
String ls_barcode
Long ll_swkpid,ll_owkpid
Int li_sflag,li_oflag
Long ll_scid,ll_orderid,ll_printid
Long ll_printid_tree
Int li_kind
Long ll_pid
DateTime ldt_opdate
String ls_opemp
Decimal ld_packqty
Long ll_row
DateTime server_dt,ldt_fdate
Decimal ld_addqty
String ls_wkpname
String ls_relname,ls_partname
String ls_p_barcode
Decimal ld_min_orderqty,ld_sum_fqty
Decimal ld_maxqty, ld_finishqty
String ls_bar_relname, ls_bar_partname

Long ll_f_mtrlid
String ls_f_status ,ls_f_woodcode,ls_f_pcode
Long ll_f_swkpid, ll_f_owkpid
String ls_f_relname,ls_f_partname
Long ll_f_scid,ll_f_orderid
DateTime ld_f_requiredate
Long cnt
Long ll_ifrel, ll_storageid, ll_cusid
String ls_plancode, ls_mtrlcuscode, ls_location
Long ll_f_printid,ll_f_pid

Long ll_r_scid,ll_r_orderid,ll_r_printid,ll_r_pid
String ls_r_barcode

Long ll_scid_tmp
Long ll_orderid_tmp

Long ll_suc,ll_fail
Long ll_sqty,ll_oqty
Long ll_getbarid
Long ll_r_getbarid

Long ll_workgroupid

Long ll_scid_ds,ll_orderid_ds,ll_swkpid_ds,ll_workgroupid_ds
Decimal ld_minsqty_ds

Long ll_workgroupid_up,ll_owrkGrpid_up
String ls_wkpname_up
Decimal ld_update_qty,ld_orderqty_ds,ld_stopqty_ds,ld_finishqty_ds
Long ll_row_wkp

String ls_orderstr_arr[]
Long ll_rowcnt
Long ll_mxbt
Long ls_p
Long ll_mxbt_wrk
Long ll_scid_arr[],ll_orderid_arr[],ll_wrkgrpid_arr[],ll_scid_wkp[],ll_orderid_wkp[]

Decimal ld_minsqty

Long ll_workgroupid_p
Int li_barcode_check
Decimal ld_qty

String arg_barcode[]
Long arg_wrkgrpid[]
DateTime arg_opdate[]

Long arg_mxbt = 0

Decimal ld_ld_minsqty

Long ls_printid

String ls_msg

ll_mxbt = 0
ll_mxbt_wrk = 0
ll_suc = 0
ll_fail = 0
Int ll_oldfail = 0

uo_sc_task_finish sc_task
sc_task = Create uo_sc_task_finish

datastore ds_pda
ds_pda = Create datastore
ds_pda.DataObject = 'ds_order_wkp_barcode_pda'
ds_pda.SetTransObject(sqlca)

datastore ds_update_wrk
ds_update_wrk = Create datastore
ds_update_wrk.DataObject = 'ds_barcode_update_ordermtrl_workgroup_id'
ds_update_wrk.SetTransObject(sqlca)

datastore ds_order_wkp
ds_order_wkp = Create datastore
ds_order_wkp.DataObject = 'ds_barcode_order_wkp_workgroupid'
ds_order_wkp.SetTransObject(sqlca)

datastore ds_relname
ds_relname = Create datastore
ds_relname.DataObject = 'ds_cmp_date_barcode_relname'
ds_relname.SetTransObject(sqlca)

datastore ds_mx
ds_mx = Create datastore
ds_mx.DataObject = 'ds_cmp_date_barcode_mx'
ds_mx.SetTransObject(sqlca)

ll_row = ds_pda.Retrieve()

IF ll_row = -1 THEN
	IF f_re_conect(arg_msg) = 0 THEN
		rslt = 0
		arg_msg = '重库数据库失败,' + arg_msg
		GOTO ext
	END IF
	ll_row = ds_pda.Retrieve()
	IF ll_row = -1 THEN
		arg_msg = '查询未处理条码失败,' + sqlca.SQLErrText
		rslt = 0
		GOTO ext
	END IF
END IF


SELECT Top 1 getdate() Into :server_dt From u_user;
//取得系统时间,借用操作员表
IF sqlca.SQLCode <> 0 THEN
	arg_msg = '查询日期失败,'+sqlca.SQLErrText
	ROLLBACK;
	rslt = 0
	GOTO ext
END IF

ldt_fdate = DateTime(Date(server_dt),Time(0))

FOR ll_i = 1 To ll_row
	
	// 临时处理 重连数据库
	IF ll_fail - ll_oldfail >= 5 THEN
		DISCONNECT;
		CONNECT;
	END IF
	
	ls_barcode = ds_pda.Object.barcode[ll_i]
	ll_wrkgrpid = ds_pda.Object.wrkgrpid[ll_i]
	li_kind = ds_pda.Object.Kind[ll_i]
	ldt_opdate = ds_pda.Object.opdate[ll_i]
	ls_opemp = ds_pda.Object.opemp[ll_i]
	ll_workgroupid = ds_pda.Object.workgroupid[ll_i]
	
	UPDATE u_order_wkp_barcode_pda
		SET flag = 1
		WHERE barcode = :ls_barcode
		AND wrkgrpid = :ll_wrkgrpid
		AND Kind = :li_kind
		And flag <> 1;
	IF sqlca.SQLCode <> 0 THEN
		arg_msg += '更新条码状态失败,'+sqlca.SQLErrText
		GOTO _failandnext
	END IF
	
	IF sqlca.SQLNRows = 0 THEN
		CONTINUE
	END IF
	
	SELECT barcode_check
		INTO :li_barcode_check
		FROM u_sc_workgroup
		Where wrkgrpid = :ll_wrkgrpid;
	IF sqlca.SQLCode <> 0 THEN li_barcode_check = 0
	
	ll_r_orderid = 0
	IF li_kind = 0 THEN // 完工模式
		//按顺序查找同工的最早条码
		SELECT u_Order_ml.mtrlid,
			u_Order_ml.status_mode,
			u_Order_ml.woodcode,
			u_Order_ml.pcode,
			u_ordermtrl_workgroup_barcode.swkpid,
			u_ordermtrl_workgroup_barcode.owkpid,
			u_ordermtrl_workgroup_barcode.relname,
			u_ordermtrl_workgroup_barcode.partname,
			u_ordermtrl_workgroup_barcode.scid,
			u_ordermtrl_workgroup_barcode.orderid,
			u_OrderMtrl_workgroup.requiredate,
			u_ordermtrl_workgroup_barcode.printid,
			u_ordermtrl_workgroup_barcode.pid
			INTO :ll_f_mtrlid,
			:ls_f_status,
			:ls_f_woodcode,
			:ls_f_pcode,
			:ll_f_swkpid,
			:ll_f_owkpid,
			:ls_f_relname,
			:ls_f_partname,
			:ll_f_scid,
			:ll_f_orderid,
			:ld_f_requiredate,
			:ll_f_printid,
			:ll_f_pid
			FROM u_ordermtrl_workgroup_barcode INNER JOIN
			u_Order_ml ON u_ordermtrl_workgroup_barcode.scid = u_Order_ml.scid AND
			u_ordermtrl_workgroup_barcode.orderid = u_Order_ml.OrderID INNER JOIN
			u_OrderMtrl_workgroup ON
			u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup.scid AND
			u_ordermtrl_workgroup_barcode.swkpid = u_OrderMtrl_workgroup.wrkGrpid AND
			u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup.orderid
			WHERE u_ordermtrl_workgroup_barcode.barcode = :ls_barcode
			And u_ordermtrl_workgroup_barcode.swkpid = :ll_wrkgrpid;
		IF sqlca.SQLCode <> 0 THEN
			//			ROLLBACK;
			//			arg_msg = '查询条码 '+ls_barcode+' 相关信息失败,'+sqlca.SQLErrText
			//			ll_fail++
			//			CONTINUE
			GOTO _update_data
		END IF
		
		cnt = 0
		
		SELECT count(0) INTO :cnt
			FROM u_ordermtrl_workgroup_barcode INNER JOIN
			u_Order_ml ON u_ordermtrl_workgroup_barcode.scid = u_Order_ml.scid AND
			u_ordermtrl_workgroup_barcode.orderid = u_Order_ml.OrderID INNER JOIN
			u_OrderMtrl_workgroup ON
			u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup.scid AND
			u_ordermtrl_workgroup_barcode.swkpid = u_OrderMtrl_workgroup.wrkGrpid AND
			u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup.orderid
			WHERE u_Order_ml.mtrlid = :ll_f_mtrlid AND
			u_Order_ml.status_mode = :ls_f_status AND
			u_Order_ml.woodcode = :ls_f_woodcode AND
			u_Order_ml.pcode = :ls_f_pcode AND
			u_ordermtrl_workgroup_barcode.swkpid  = :ll_f_swkpid AND
			u_ordermtrl_workgroup_barcode.owkpid = :ll_f_owkpid AND
			u_ordermtrl_workgroup_barcode.relname = :ls_f_relname AND
			u_ordermtrl_workgroup_barcode.partname = :ls_f_partname AND
			u_ordermtrl_workgroup_barcode.orderid <> :ll_f_orderid AND
			u_OrderMtrl_workgroup.requiredate < :ld_f_requiredate AND
			u_ordermtrl_workgroup_barcode.sflag = 0 AND
			u_Order_ml.status = 1 ;
		IF sqlca.SQLCode <> 0 THEN
			ROLLBACK;
			//			arg_msg = '查询条码 '+ls_barcode+' 相同部件未完成情况失败,'+sqlca.SQLErrText
			//			ll_fail++
			//			CONTINUE
			ll_r_scid = 0
			ll_r_orderid = 0
			ll_r_printid = 0
			ll_r_pid = 0
			GOTO _update_data
		END IF
		
		
		IF cnt > 0 And arg_replace THEN
			SELECT top 1 u_ordermtrl_workgroup_barcode.scid,
				u_ordermtrl_workgroup_barcode.orderid,
				u_ordermtrl_workgroup_barcode.printid,
				u_ordermtrl_workgroup_barcode.pid,
				u_ordermtrl_workgroup_barcode.barcode
				INTO :ll_r_scid,
				:ll_r_orderid,
				:ll_r_printid,
				:ll_r_pid,
				:ls_r_barcode
				FROM u_ordermtrl_workgroup_barcode INNER JOIN
				u_Order_ml ON u_ordermtrl_workgroup_barcode.scid = u_Order_ml.scid AND
				u_ordermtrl_workgroup_barcode.orderid = u_Order_ml.OrderID INNER JOIN
				u_OrderMtrl_workgroup ON
				u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup.scid AND
				u_ordermtrl_workgroup_barcode.swkpid = u_OrderMtrl_workgroup.wrkGrpid AND
				u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup.orderid
				WHERE u_Order_ml.mtrlid = :ll_f_mtrlid AND
				u_Order_ml.status_mode = :ls_f_status AND
				u_Order_ml.woodcode = :ls_f_woodcode AND
				u_Order_ml.pcode = :ls_f_pcode AND
				u_ordermtrl_workgroup_barcode.swkpid  = :ll_f_swkpid AND
				u_ordermtrl_workgroup_barcode.owkpid = :ll_f_owkpid AND
				u_ordermtrl_workgroup_barcode.relname = :ls_f_relname AND
				u_ordermtrl_workgroup_barcode.partname = :ls_f_partname AND
				u_ordermtrl_workgroup_barcode.orderid <> :ll_f_orderid AND
				u_OrderMtrl_workgroup.requiredate < :ld_f_requiredate AND
				u_ordermtrl_workgroup_barcode.sflag = 0 AND
				u_Order_ml.status = 1
				Order By u_OrderMtrl_workgroup.requiredate;
			IF sqlca.SQLCode <> 0 THEN
				ROLLBACK;
				//				arg_msg = '查询条码 '+ls_barcode+' 相同部件未完成情况失败2,'+sqlca.SQLErrText
				//				ll_fail++
				//				CONTINUE
				ll_r_scid = 0
				ll_r_orderid = 0
				ll_r_printid = 0
				ll_r_pid = 0
				GOTO _update_data
			END IF
			
			ll_scid_tmp = ll_r_scid - 100000000
			ll_orderid_tmp = ll_r_orderid - 100000000
			
			
			UPDATE u_ordermtrl_workgroup_barcode
				SET scid = :ll_scid_tmp,
				orderid = :ll_orderid_tmp
				WHERE scid = :ll_r_scid
				AND orderid = :ll_r_orderid
				AND barcode = :ls_r_barcode
				And pid = :ll_r_pid;
			IF sqlca.SQLCode <> 0 THEN
				ROLLBACK;
				//				arg_msg = '更新条码 '+ls_barcode+' 信息失败 ,'+sqlca.SQLErrText
				//				ll_fail++
				//				CONTINUE
				ll_r_scid = 0
				ll_r_orderid = 0
				ll_r_printid = 0
				ll_r_pid = 0
				GOTO _update_data
			END IF
			
			//			UPDATE u_ordermtrl_workgroup_barcode
			//				SET barcode = :ls_barcode
			//				WHERE scid = :ll_r_scid
			//				AND orderid = :ll_r_orderid
			//				AND barcode = :ls_r_barcode;
			//			IF sqlca.SQLCode <> 0 THEN
			//				ROLLBACK;
			//				arg_msg = '更新条码 '+ls_barcode+' 信息失败 ,'+sqlca.SQLErrText
			//				ll_fail++
			//				CONTINUE
			//			END IF
			
			UPDATE u_ordermtrl_workgroup_barcode
				SET scid = :ll_r_scid,
				orderid = :ll_r_orderid,
				pid = :ll_r_pid
				WHERE scid = :ll_f_scid
				AND orderid = :ll_f_orderid
				AND barcode = :ls_barcode
				And pid = :ll_f_pid;
			IF sqlca.SQLCode <> 0 THEN
				ROLLBACK;
				//				arg_msg = '更新条码 '+ls_barcode + '对应更换条码 '+ls_r_barcode+' 信息失败_1,'+sqlca.SQLErrText
				//				ll_fail++
				//				CONTINUE
				ll_r_scid = 0
				ll_r_orderid = 0
				ll_r_printid = 0
				ll_r_pid = 0
				GOTO _update_data
			END IF
			
			UPDATE u_ordermtrl_workgroup_barcode
				SET scid = :ll_f_scid,
				orderid = :ll_f_orderid,
				pid = :ll_f_pid
				WHERE scid = :ll_scid_tmp
				And orderid = :ll_orderid_tmp;
			IF sqlca.SQLCode <> 0 THEN
				ROLLBACK;
				//				arg_msg = '更新条码 '+ls_barcode + '对应更换条码 '+ls_r_barcode+' 信息失败_2,'+sqlca.SQLErrText
				//				ll_fail++
				//				CONTINUE
				ll_r_scid = 0
				ll_r_orderid = 0
				ll_r_printid = 0
				ll_r_pid = 0
				GOTO _update_data
			END IF
		END IF
		
		
		_update_data:
		
		SELECT COUNT(0)
			INTO :cnt
			FROM u_ordermtrl_workgroup_barcode
			WHERE barcode = :ls_barcode
			AND swkpid = :ll_wrkgrpid
			And sflag = 0;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '1.0查询条码 '+ls_barcode+' 未完成数失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		IF cnt <= 0 THEN
			GOTO _okandnext
		END IF
		
		SELECT top 1 scid,
			orderid,
			printid,
			swkpid,
			owkpid,
			sflag,
			oflag,
			pid,
			relname,
			partname,
			workgroupid,
			qty
			INTO :ll_scid,
			:ll_orderid,
			:ll_printid,
			:ll_swkpid,
			:ll_owkpid,
			:li_sflag,
			:li_oflag,
			:ll_pid,
			:ls_bar_relname,
			:ls_bar_partname,
			:ll_workgroupid_p,
			:ld_qty
			FROM u_ordermtrl_workgroup_barcode
			WHERE barcode = :ls_barcode
			AND swkpid = :ll_wrkgrpid
			AND sflag = 0
			Order By printid Desc;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '1.0查询条码 '+ls_barcode+' 相关信息失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		//不严格限制工作中心或条码本身没有指定工作中心,则程序为条码匹配工作中心
		IF li_barcode_check = 0 Or ll_workgroupid_p = 0  THEN
			
			//20111013 应急处理
			UPDATE u_OrderMtrl_workgroup_barcode
				SET u_ordermtrl_workgroup_barcode.workgroupid = u_OrderMtrl_workgroup.workgroupid
				FROM u_ordermtrl_workgroup_barcode INNER JOIN
				u_OrderMtrl_workgroup ON
				u_ordermtrl_workgroup_barcode.scid = u_OrderMtrl_workgroup.scid AND
				u_ordermtrl_workgroup_barcode.orderid = u_OrderMtrl_workgroup.orderid AND
				u_ordermtrl_workgroup_barcode.swkpid = u_OrderMtrl_workgroup.wrkGrpid AND
				u_ordermtrl_workgroup_barcode.workgroupid <> u_OrderMtrl_workgroup.workgroupid
				WHERE u_ordermtrl_workgroup_barcode.scid = :ll_scid
				AND u_ordermtrl_workgroup_barcode.orderid = :ll_orderid
				And u_ordermtrl_workgroup_barcode.workgroupid <> u_OrderMtrl_workgroup.workgroupid;
			//
			
			SELECT count(*) INTO :cnt
				FROM u_OrderMtrl_workgroup
				WHERE scid = :ll_scid
				AND orderid = :ll_orderid
				AND wrkgrpid  = :ll_swkpid
				And workgroupid = :ll_workgroupid;
			IF sqlca.SQLCode <> 0 THEN
				cnt = 0
			END IF
			
			IF cnt = 0 THEN
				
				SELECT COUNT(0)
					INTO :cnt
					FROM u_OrderMtrl_workgroup
					WHERE scid = :ll_scid
					AND orderid = :ll_orderid
					And wrkgrpid  = :ll_swkpid;
				IF sqlca.SQLCode <> 0 THEN
					arg_msg += '2.查询条码 '+ls_barcode+' 相关生产计划工组数量失败,'+sqlca.SQLErrText
					GOTO _failandnext
				END IF
				
				IF cnt = 0 THEN
					GOTO _okandnext
				END IF
				
				SELECT top 1 workgroupid
					INTO :ll_workgroupid
					FROM u_OrderMtrl_workgroup
					WHERE scid = :ll_scid
					AND orderid = :ll_orderid
					And wrkgrpid  = :ll_swkpid;
				IF sqlca.SQLCode <> 0 THEN
					arg_msg += '2.查询条码 '+ls_barcode+' 相关生产计划工组进度信息失败,'+sqlca.SQLErrText
					GOTO _failandnext
				END IF
			END IF
		ELSE
			IF ll_workgroupid_p <> ll_workgroupid THEN
				arg_msg += '条码 '+ls_barcode+' 所属工作中心与当前选择的工作中心不符,'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
		END IF
		
		
		UPDATE u_ordermtrl_workgroup_barcode
			SET sflag = 1,
			sdate = :ldt_opdate,
			semp = :ls_opemp,
			workgroupid = :ll_workgroupid
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND printid = :ll_printid
			And pid = :ll_pid;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新条码完成状态失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		//		SELECT sum(sflag*qty),sum(oflag*qty)
		//			INTO :ll_sqty,:ll_oqty
		//			FROM u_ordermtrl_workgroup_barcode
		//			WHERE scid = :ll_scid
		//			AND orderid = :ll_orderid
		//			And printid = :ll_printid;
		//		IF sqlca.SQLCode <> 0 THEN
		//			ROLLBACK;
		//			arg_msg = '查询工组完成进度失败,'+sqlca.SQLErrText
		//			ll_fail++
		//			CONTINUE
		//		END IF
		
		SELECT printid INTO :ll_printid_tree
			FROM  u_OrderMtrl_workgroup_tree
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND relname = :ls_bar_relname
			AND partname = :ls_bar_partname
			AND workgroupid = :ll_workgroupid
			And orderqty > sqty ;
		IF sqlca.SQLCode <> 0 THEN
			SELECT top 1 printid
				INTO :ll_printid_tree
				FROM  u_OrderMtrl_workgroup_tree
				WHERE scid = :ll_scid
				AND orderid = :ll_orderid
				AND relname = :ls_bar_relname
				AND partname = :ls_bar_partname
				And orderqty > sqty ;
			IF sqlca.SQLCode <> 0 THEN
				ll_printid_tree = ll_printid
			END IF
		END IF
		
		UPDATE u_OrderMtrl_workgroup_tree
			SET u_ordermtrl_workgroup_tree.sqty = case when u_ordermtrl_workgroup_tree.sqty + :ld_qty > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else u_ordermtrl_workgroup_tree.sqty + :ld_qty END,
			u_ordermtrl_workgroup_tree.sdate = :ldt_opdate
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			And printid = :ll_printid_tree;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新工组条码进度已完成数失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		
		IF ll_r_orderid > 0 THEN
			
			UPDATE u_OrderMtrl_workgroup_tree
				SET u_OrderMtrl_workgroup_tree.sqty = case when isnull(a.sqty,0) > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else isnull(a.sqty,0) END,
				u_OrderMtrl_workgroup_tree.oqty = case when isnull(a.oqty,0) > u_ordermtrl_workgroup_tree.orderqty then  u_ordermtrl_workgroup_tree.orderqty else isnull(a.oqty,0) END
				FROM u_OrderMtrl_workgroup_tree INNER JOIN
				(SELECT SUM(sflag*qty) AS sqty, SUM(oflag*qty) AS oqty, scid, orderid, printid
				FROM u_ordermtrl_workgroup_barcode
				WHERE scid = :ll_f_scid
				AND orderid = :ll_f_orderid
				GROUP BY scid, orderid, printid) a ON
				u_OrderMtrl_workgroup_tree.scid = a.scid AND
				u_OrderMtrl_workgroup_tree.orderid = a.orderid AND
				u_OrderMtrl_workgroup_tree.printid = a.printid
				WHERE u_OrderMtrl_workgroup_tree.scid = :ll_f_scid
				And u_OrderMtrl_workgroup_tree.orderid = :ll_f_orderid;
			IF sqlca.SQLCode <> 0 THEN
				arg_msg += '更新工组条码进度已完成数失败(原计划),'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
			
			UPDATE u_OrderMtrl_workgroup_tree
				SET u_OrderMtrl_workgroup_tree.sqty = case when isnull(a.sqty,0) > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else isnull(a.sqty,0) END,
				u_OrderMtrl_workgroup_tree.oqty = case when isnull(a.oqty,0) > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else isnull(a.oqty,0) END
				FROM u_OrderMtrl_workgroup_tree INNER JOIN
				(SELECT SUM(sflag*qty) AS sqty, SUM(oflag*qty) AS oqty, scid, orderid, printid
				FROM u_ordermtrl_workgroup_barcode
				WHERE scid = :ll_f_scid
				AND orderid = :ll_f_orderid
				GROUP BY scid, orderid, printid) a ON
				u_OrderMtrl_workgroup_tree.scid = a.scid AND
				u_OrderMtrl_workgroup_tree.orderid = a.orderid AND
				u_OrderMtrl_workgroup_tree.printid = a.printid
				WHERE u_OrderMtrl_workgroup_tree.scid = :ll_r_scid
				And u_OrderMtrl_workgroup_tree.orderid = :ll_r_orderid;
			IF sqlca.SQLCode <> 0 THEN
				arg_msg += '更新工组条码进度已完成数失败(新替换计划),'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
		END IF
		
		arg_mxbt++
		arg_barcode[arg_mxbt] = ls_barcode
		arg_wrkgrpid[arg_mxbt] = ll_wrkgrpid
		arg_opdate[arg_mxbt] = ldt_opdate
		
		
	ELSEIF li_kind = 1 THEN // 接收模式
		SELECT scid,
			orderid,
			printid,
			swkpid,
			owkpid,
			sflag,
			oflag,
			pid,
			relname,
			partname,
			qty
			INTO :ll_scid,
			:ll_orderid,
			:ll_printid,
			:ll_swkpid,
			:ll_owkpid,
			:li_sflag,
			:li_oflag,
			:ll_pid,
			:ls_bar_relname,
			:ls_bar_partname,
			:ld_qty
			FROM u_ordermtrl_workgroup_barcode
			WHERE barcode = :ls_barcode
			And owkpid = :ll_wrkgrpid;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '3.查询条码 '+ls_barcode+' 相关信息失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		UPDATE u_ordermtrl_workgroup_barcode
			SET oflag = 1,
			odate = :ldt_opdate,
			oemp = :ls_opemp
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND printid = :ll_printid
			And pid = :ll_pid;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新条码接收状态失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		
		SELECT top 1 printid
			INTO :ll_printid_tree
			FROM  u_OrderMtrl_workgroup_tree
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND relname = :ls_bar_relname
			AND partname = :ls_bar_partname
			And sqty > oqty ;
		IF sqlca.SQLCode <> 0 THEN
			ll_printid_tree = ll_printid
		END IF
		
		UPDATE u_OrderMtrl_workgroup_tree
			SET u_ordermtrl_workgroup_tree.oqty = case when u_ordermtrl_workgroup_tree.oqty + :ld_qty > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else u_ordermtrl_workgroup_tree.oqty + :ld_qty END ,
			u_ordermtrl_workgroup_tree.odate =  :ldt_opdate
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND printid = :ll_printid_tree
			And u_OrderMtrl_workgroup_tree.oqty < u_OrderMtrl_workgroup_tree.orderqty;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新工组条码进度已接收数失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
	ELSE // Marker:  最后工组完工
		SELECT u_mtrlware_mx.getbarid,
			u_getbar.orderid,
			u_Order_ml.mtrlid,
			u_Order_ml.status_mode,
			u_Order_ml.woodcode,
			u_Order_ml.pcode,
			u_OrderMtrl_workgroup.wrkGrpid,
			u_OrderMtrl_workgroup.wkpname,
			u_OrderMtrl_workgroup.requiredate,
			u_getbar.scid,
			u_mtrlware_mx.packqty * u_mtrlware_mx.qty AS packqty,
			u_getbar.ifrel,
			u_getbar.storageid,
			u_getbar.cusid,
			u_getbar.plancode,
			u_getbar.mtrlcuscode,
			u_getbar.location
			INTO :ll_getbarid,
			:ll_orderid,
			:ll_f_mtrlid,
			:ls_f_status,
			:ls_f_woodcode,
			:ls_f_pcode,
			:ll_wrkgrpid,
			:ls_wkpname,
			:ld_f_requiredate,
			:ll_scid,
			:ld_packqty,
			:ll_ifrel,
			:ll_storageid,
			:ll_cusid,
			:ls_plancode,
			:ls_mtrlcuscode,
			:ls_location
			FROM u_mtrlware_mx INNER JOIN
			u_getbar ON u_mtrlware_mx.getbarid = u_getbar.getbarid INNER JOIN
			u_Order_ml ON u_getbar.scid = u_Order_ml.scid AND u_getbar.orderid = u_Order_ml.OrderID INNER JOIN
			u_OrderMtrl_workgroup ON u_Order_ml.scid = u_OrderMtrl_workgroup.scid AND u_Order_ml.OrderID = u_OrderMtrl_workgroup.orderid AND
			u_OrderMtrl_workgroup.iflast = 1
			Where (u_mtrlware_mx.barcode = :ls_barcode);
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '4.查询条码 '+ls_barcode+' 相关信息失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		IF arg_replace THEN
			SELECT COUNT(0)
				INTO :cnt
				FROM u_mtrlware_mx INNER JOIN
				u_getbar ON u_mtrlware_mx.getbarid = u_getbar.getbarid INNER JOIN
				u_Order_ml ON u_getbar.scid = u_Order_ml.scid AND u_getbar.orderid = u_Order_ml.OrderID INNER JOIN
				u_OrderMtrl_workgroup ON u_Order_ml.scid = u_OrderMtrl_workgroup.scid AND u_Order_ml.OrderID = u_OrderMtrl_workgroup.orderid AND
				u_OrderMtrl_workgroup.iflast = 1
				WHERE (u_mtrlware_mx.getbarid <> :ll_getbarid)
				AND (u_Order_ml.status_mode = :ls_f_status)
				AND (u_OrderMtrl_workgroup.wkpname = :ls_wkpname)
				AND (u_OrderMtrl_workgroup.wrkGrpid = :ll_wrkgrpid)
				AND (u_Order_ml.pcode = :ls_f_pcode)
				AND (u_Order_ml.woodcode = :ls_f_woodcode)
				AND (u_Order_ml.mtrlid = :ll_f_mtrlid)
				AND (NOT EXISTS
				(SELECT 1
				FROM u_order_wkp_barcode_pda
				WHERE (barcode = u_mtrlware_mx.barcode) AND (kind = 2)))
				AND (u_OrderMtrl_workgroup.requiredate < :ld_f_requiredate)
				AND (u_getbar.orderid <> :ll_orderid)
				AND (u_mtrlware_mx.packqty * u_mtrlware_mx.qty = :ld_packqty)
				AND (u_getbar.ifrel = :ll_ifrel)
				AND (u_getbar.storageid = :ll_storageid)
				AND (u_getbar.cusid = :ll_cusid)
				AND (u_getbar.plancode = :ls_plancode)
				AND (u_getbar.mtrlcuscode = :ls_mtrlcuscode)
				AND (u_getbar.Location = :ls_location)
				And (u_mtrlware_mx.inflag = 0);
			IF sqlca.SQLCode <> 0 THEN
				arg_msg += '查询可替换最后工组失败,'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
			
			IF cnt > 0 THEN
				
				SELECT TOP 1 u_mtrlware_mx.getbarid,
					u_mtrlware_mx.barcode,
					u_getbar.scid,
					u_getbar.orderid
					INTO :ll_r_getbarid,
					:ls_r_barcode,
					:ll_r_scid,
					:ll_r_orderid
					FROM u_mtrlware_mx INNER JOIN
					u_getbar ON u_mtrlware_mx.getbarid = u_getbar.getbarid INNER JOIN
					u_Order_ml ON u_getbar.scid = u_Order_ml.scid AND u_getbar.orderid = u_Order_ml.OrderID INNER JOIN
					u_OrderMtrl_workgroup ON u_Order_ml.scid = u_OrderMtrl_workgroup.scid AND u_Order_ml.OrderID = u_OrderMtrl_workgroup.orderid AND
					u_OrderMtrl_workgroup.iflast = 1
					WHERE (u_mtrlware_mx.getbarid <> :ll_getbarid)
					AND (u_Order_ml.status_mode = :ls_f_status)
					AND (u_OrderMtrl_workgroup.wkpname = :ls_wkpname)
					AND (u_OrderMtrl_workgroup.wrkGrpid = :ll_wrkgrpid)
					AND (u_Order_ml.pcode = :ls_f_pcode)
					AND (u_Order_ml.woodcode = :ls_f_woodcode)
					AND (u_Order_ml.mtrlid = :ll_f_mtrlid)
					AND (NOT EXISTS
					(SELECT 1
					FROM u_order_wkp_barcode_pda
					WHERE (barcode = u_mtrlware_mx.barcode) AND (kind = 2)))
					AND (u_OrderMtrl_workgroup.requiredate < :ld_f_requiredate)
					AND (u_getbar.orderid <> :ll_orderid)
					AND (u_mtrlware_mx.packqty * u_mtrlware_mx.qty = :ld_packqty)
					AND (u_getbar.ifrel = :ll_ifrel)
					AND (u_getbar.storageid = :ll_storageid)
					AND (u_getbar.cusid = :ll_cusid)
					AND (u_getbar.plancode = :ls_plancode)
					AND (u_getbar.mtrlcuscode = :ls_mtrlcuscode)
					AND (u_getbar.Location = :ls_location)
					And (u_mtrlware_mx.inflag = 0);
				IF sqlca.SQLCode <> 0 THEN
					arg_msg += '查询可替换信息失败,'+sqlca.SQLErrText
					GOTO _failandnext
				END IF
				
				UPDATE u_mtrlware_mx SET
					getbarid = :ll_r_getbarid,
					scid = :ll_r_scid,
					orderid = :ll_r_orderid
					Where barcode = :ls_barcode;
				IF sqlca.SQLCode <> 0 THEN
					arg_msg += '更改当前条码的条码生成单失败,'+sqlca.SQLErrText
					GOTO _failandnext
				END IF
				
				UPDATE u_mtrlware_mx SET
					getbarid = :ll_getbarid,
					scid = :ll_scid,
					orderid = :ll_orderid
					Where barcode = :ls_r_barcode;
				IF sqlca.SQLCode <> 0 THEN
					arg_msg += '更改被替换条码的条码生成单失败,'+sqlca.SQLErrText
					GOTO _failandnext
				END IF
				
				ll_scid = ll_r_scid
				ll_orderid = ll_r_orderid
				
			END IF
			
		END IF
		
		//		SELECT TOP 1 u_ordermtrl_workgroup_barcode.barcode
		//			INTO :ls_p_barcode
		//			FROM u_ordermtrl_workgroup_barcode INNER JOIN
		//			u_ordermtrl_workgroup_barcode AS u_ordermtrl_workgroup_barcode_p ON
		//			u_ordermtrl_workgroup_barcode.scid = u_ordermtrl_workgroup_barcode_p.scid AND
		//			u_ordermtrl_workgroup_barcode.orderid = u_ordermtrl_workgroup_barcode_p.orderid AND
		//			u_ordermtrl_workgroup_barcode.swkpid = u_ordermtrl_workgroup_barcode_p.owkpid AND
		//			u_ordermtrl_workgroup_barcode.barcode = u_ordermtrl_workgroup_barcode_p.barcode
		//			WHERE (u_ordermtrl_workgroup_barcode_p.oflag = 1)
		//			AND (u_ordermtrl_workgroup_barcode_p.ptflag = 1)
		//			AND (u_ordermtrl_workgroup_barcode.swkpid = :ll_wrkgrpid)
		//			AND (u_ordermtrl_workgroup_barcode.scid = :ll_scid)
		//			AND (u_ordermtrl_workgroup_barcode.orderid = :ll_orderid)
		//			And (u_ordermtrl_workgroup_barcode.ptflag = 0);
		//		IF sqlca.SQLCode <> 0 THEN
		//			arg_msg += '查询最后工组未配对部件条码失败,'+sqlca.SQLErrText
		//			GOTO _failandnext
		//		END IF
		//		
		//		UPDATE u_ordermtrl_workgroup_barcode SET sflag = 1, ptflag = 1
		//			WHERE barcode = :ls_p_barcode
		//			AND swkpid = :ll_wrkgrpid
		//			AND orderid = :ll_orderid
		//			AND scid = :ll_scid
		//			And ptflag = 0;
		//		IF sqlca.SQLCode <> 0 THEN
		//			arg_msg += '更新最后工组未配对部件条码失败,'+sqlca.SQLErrText
		//			GOTO _failandnext
		//		END IF
		//		
		//		IF sqlca.SQLNRows <> 1 THEN
		//			arg_msg += '更新最后工组未配对部件条码失败,条码已被更新'
		//			GOTO _failandnext
		//		END IF
		
		SELECT isnull(MIN(finishqty),0)
			INTO :ld_maxqty
			FROM u_OrderMtrl_workgroup
			WHERE (scid = :ll_scid)
			AND (orderid = :ll_orderid)
			And (owrkGrpid = :ll_wrkgrpid);
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '查询最后工组可完成数失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		IF ld_maxqty > 0 THEN
			SELECT finishqty
				INTO :ld_finishqty
				FROM u_OrderMtrl_workgroup
				WHERE scid = :ll_scid
				AND orderid = :ll_orderid
				AND wrkgrpid = :ll_wrkgrpid
				And iflast = 1;
			IF sqlca.SQLCode <> 0 THEN
				arg_msg += '查询最后工组已完成数失败,'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
			
			IF ld_finishqty + ld_packqty > ld_maxqty THEN
				arg_msg += '上工组未配套,上工组配套数:' + String(ld_maxqty,'#,##0.#####') + ',已完成数:' + String(ld_finishqty,'#,##0.#####') + ',本次完成数:' + String(ld_packqty,'#,##0.#####')
				GOTO _failandnext
			END IF
			
		END IF
		
		UPDATE u_OrderMtrl_workgroup_tree
			SET u_ordermtrl_workgroup_tree.sqty = case when u_ordermtrl_workgroup_tree.sqty + :ld_packqty > u_ordermtrl_workgroup_tree.orderqty then u_ordermtrl_workgroup_tree.orderqty else u_ordermtrl_workgroup_tree.sqty + :ld_packqty END ,
			u_ordermtrl_workgroup_tree.sdate =  :ldt_opdate
			WHERE scid = :ll_scid
			AND orderid = :ll_orderid
			AND iflast = 1
			And u_OrderMtrl_workgroup_tree.sqty < u_OrderMtrl_workgroup_tree.orderqty;
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新最后工组已完成数失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
		
		arg_mxbt++
		arg_barcode[arg_mxbt] = ls_barcode
		arg_wrkgrpid[arg_mxbt] = ll_wrkgrpid
		arg_opdate[arg_mxbt] = ldt_opdate
		
	END IF
	
	
	_okandnext:
	
	IF li_kind <> 2 THEN
		
		//			SELECT sum(s_qty.minsqty)
		//				INTO :ld_addqty
		//				FROM u_OrderMtrl_workgroup INNER JOIN
		//				(SELECT scid, orderid, swkpid, MIN(sqty) AS minsqty
		//				FROM (SELECT scid, orderid, swkpid, SUM(sflag) AS sqty, relname,
		//				partname
		//				FROM u_ordermtrl_workgroup_barcode
		//				WHERE sflag = 1
		//				AND CONVERT(varchar(10), sdate, 120) = CONVERT(varchar(10), :ldt_fdate, 120)
		//				GROUP BY scid, orderid, swkpid,  relname, partname) a
		//				GROUP BY scid, orderid, swkpid) s_qty ON
		//				u_OrderMtrl_workgroup.scid = s_qty.scid AND
		//				u_OrderMtrl_workgroup.orderid = s_qty.orderid AND
		//				u_OrderMtrl_workgroup.wrkGrpid = s_qty.swkpid
		//				WHERE (u_OrderMtrl_workgroup.scid = :ll_scid)
		//				AND (u_OrderMtrl_workgroup.orderid = :ll_orderid)
		//				AND (u_OrderMtrl_workgroup.wrkgrpid = :ll_wrkgrpid)
		//				And (u_OrderMtrl_workgroup.iflast = 0);
		//			IF sqlca.SQLCode <> 0 THEN
		//				ld_addqty = 0
		//			END IF
		//			
		//			IF ld_addqty > 0 THEN
		//				UPDATE u_OrderMtrl_workgroup_date
		//					SET fqty = :ld_addqty
		//					WHERE scid = :ll_scid
		//					AND orderid = :ll_orderid
		//					AND wrkgrpid = :ll_wrkgrpid
		//					And fdate = :ldt_fdate;
		//				IF sqlca.SQLCode = 0 THEN
		//					IF sqlca.SQLNRows = 0 THEN
		//						INSERT INTO u_OrderMtrl_workgroup_date
		//							(scid,orderid,wrkgrpid,fdate,fqty)
		//							VALUES
		//							(:ll_scid,:ll_orderid,:ll_wrkgrpid,:ldt_fdate,:ld_addqty);
		//						IF sqlca.SQLCode <> 0 THEN
		//							ROLLBACK;
		//							arg_msg = '更新工组当天进度失败,'+sqlca.SQLErrText
		//							ll_fail++
		//							CONTINUE
		//						END IF
		//					END IF
		//				ELSE
		//					ROLLBACK;
		//					arg_msg = '更新工组当天进度失败,'+sqlca.SQLErrText
		//					ll_fail++
		//					CONTINUE
		//				END IF
		//			END IF
		IF li_kind = 0 THEN
			FOR ls_p = 1 To ll_mxbt
				IF ll_orderid = ll_orderid_arr[ls_p] And ll_scid = ll_scid_arr[ls_p] THEN
					GOTO _find_wrk
				END IF
			NEXT
			ll_mxbt++
			ls_orderstr_arr[ll_mxbt] = String(ll_orderid)+'_'+String(ll_scid)
			ll_orderid_arr[ll_mxbt] = ll_orderid
			ll_scid_arr[ll_mxbt] = ll_scid
			
			_find_wrk:
			FOR ls_p = 1 To ll_mxbt_wrk
				IF ll_orderid = ll_orderid_wkp[ls_p] And ll_scid = ll_scid_wkp[ls_p] And ll_wrkgrpid = ll_wrkgrpid_arr[ls_p] THEN
					GOTO _find_end
				END IF
			NEXT
			ll_mxbt_wrk++
			ll_orderid_wkp[ll_mxbt_wrk] = ll_orderid
			ll_scid_wkp[ll_mxbt_wrk] = ll_scid
			ll_wrkgrpid_arr[ll_mxbt_wrk] = ll_wrkgrpid
			
			_find_end:
		END IF
		
		
		
		
		//		
		//		UPDATE u_OrderMtrl_workgroup
		//			SET u_OrderMtrl_workgroup.finishqty = s_qty.minsqty
		//			FROM u_OrderMtrl_workgroup INNER JOIN
		//			(SELECT scid, orderid, swkpid,  workgroupid,MIN(sqty) AS minsqty
		//			FROM (SELECT scid, orderid, swkpid,workgroupid, SUM(sflag) AS sqty, relname,
		//			partname
		//			FROM u_ordermtrl_workgroup_barcode
		//			GROUP BY scid, orderid, swkpid,  relname, partname,workgroupid) a
		//			GROUP BY scid, orderid, swkpid,workgroupid) s_qty ON
		//			u_OrderMtrl_workgroup.scid = s_qty.scid AND
		//			u_OrderMtrl_workgroup.orderid = s_qty.orderid AND
		//			u_OrderMtrl_workgroup.wrkGrpid = s_qty.swkpid and
		//			u_OrderMtrl_workgroup.workgroupid = s_qty.workgroupid
		//			WHERE (u_OrderMtrl_workgroup.scid = :ll_scid)
		//			AND (u_OrderMtrl_workgroup.orderid = :ll_orderid)
		//			And (u_OrderMtrl_workgroup.iflast = 0);
		//		IF sqlca.SQLCode <> 0 THEN
		//			ROLLBACK;
		//			arg_msg = '更新工组进度失败,'+sqlca.SQLErrText
		//			ll_fail++
		//			CONTINUE
		//		END IF
		
	ELSE
		IF ld_packqty > 0 THEN
			UPDATE u_OrderMtrl_workgroup_date
				SET fqty = fqty + :ld_packqty
				WHERE scid = :ll_scid
				AND orderid = :ll_orderid
				AND wrkgrpid = :ll_wrkgrpid
				And fdate = :ldt_fdate;
			IF sqlca.SQLCode = 0 THEN
				IF sqlca.SQLNRows = 0 THEN
					INSERT INTO u_OrderMtrl_workgroup_date
						(scid,orderid,wrkgrpid,fdate,fqty)
						VALUES
						(:ll_scid,:ll_orderid,:ll_wrkgrpid,:ldt_fdate,:ld_packqty);
					IF sqlca.SQLCode <> 0 THEN
						arg_msg += '更新工组当天进度失败,'+sqlca.SQLErrText
						GOTO _failandnext
					END IF
				END IF
			ELSE
				arg_msg += '更新工组当天进度失败,'+sqlca.SQLErrText
				GOTO _failandnext
			END IF
		END IF
		
		UPDATE u_OrderMtrl_workgroup
			SET u_OrderMtrl_workgroup.finishqty = case when u_OrderMtrl_workgroup.finishqty + :ld_packqty  >  u_OrderMtrl_workgroup.orderqty then u_OrderMtrl_workgroup.orderqty else  u_OrderMtrl_workgroup.finishqty + :ld_packqty END
			FROM u_OrderMtrl_workgroup INNER JOIN
			u_sc_workgroup ON
			u_OrderMtrl_workgroup.wrkGrpid = u_sc_workgroup.wrkGrpid
			WHERE (u_OrderMtrl_workgroup.scid = :ll_scid)
			AND (u_OrderMtrl_workgroup.orderid = :ll_orderid)
			AND (u_OrderMtrl_workgroup.iflast = 1)
			AND (u_sc_workgroup.jdtype = 6)
			And (u_OrderMtrl_workgroup.finishqty < u_OrderMtrl_workgroup.orderqty);
		IF sqlca.SQLCode <> 0 THEN
			arg_msg += '更新工组进度失败,'+sqlca.SQLErrText
			GOTO _failandnext
		END IF
	END IF
	
	UPDATE u_OrderMtrl_workgroup
		SET finishflag = 1,finishdate = :server_dt
		WHERE orderid = :ll_orderid
		AND scid = :ll_scid
		And orderqty <= finishqty + stopqty;
	IF sqlca.SQLCode <> 0 THEN
		arg_msg += '更新工组完成状态失败,'+sqlca.SQLErrText
		GOTO _failandnext
	END IF
	
	COMMIT;
	ll_suc++
	CONTINUE
	
	_failandnext:
	ROLLBACK;
	ll_fail++
	
	UPDATE u_order_wkp_barcode_pda
		SET flag = 2
		WHERE barcode = :ls_barcode
		AND wrkgrpid = :ll_wrkgrpid
		And Kind = :li_kind;
	IF sqlca.SQLCode <> 0 THEN
		arg_msg += '更新条码错误状态失败,'+sqlca.SQLErrText
		ROLLBACK;
	ELSE
		COMMIT;
	END IF
	
	
	CONTINUE
	
	
NEXT

FOR ll_k = 1 To ll_mxbt_wrk
	IF uof_workgroup_barcode_pt(ll_scid_wkp[ll_k], ll_orderid_wkp[ll_k], ll_wrkgrpid_arr[ll_k], ls_msg, True) <> 1 THEN
		arg_msg += '工组自动配套失败,' + ls_msg
	END IF
NEXT

IF arg_finishbarcode THEN
	IF sc_task.uf_finishbarcode(arg_wrkgrpid, arg_barcode, arg_opdate, ls_msg) <> 1 THEN
		rslt = 0
		arg_msg += '生成工序完工单失败,' + ls_msg
		GOTO ext
	END IF
END IF

ext:
Destroy sc_task
Destroy ds_order_wkp
Destroy ds_update_wrk
Destroy ds_relname
Destroy ds_mx
Destroy ds_pda
arg_cnt = ll_suc
arg_failcnt = ll_fail


RETURN  rslt




end function

public function integer uof_order_wkp_barcode_pda (boolean arg_replace, boolean arg_finishbarcode, ref string arg_msg, ref long arg_cnt, ref long arg_failcnt);//====================================================================
// 事件: .f_order_wkp_barcode_pda()
//--------------------------------------------------------------------
// 描述:
//--------------------------------------------------------------------
// 参数:
// 	value    	boolean	arg_replace	优先完成时间较早的计划
// 	reference	string 	arg_msg    	
// 	reference	long   	arg_cnt    	
// 	reference	long   	arg_failcnt	
//--------------------------------------------------------------------
// 返回:  integer
//--------------------------------------------------------------------
// 作者:	lwl		日期: 2012年02月24日
//--------------------------------------------------------------------
//	LONGJOE
//--------------------------------------------------------------------
// 修改历史:
//
//====================================================================


Int rslt = 1

s_p_barcode_pda arr_bars[]

String arg_barcode[]
Long arg_wrkgrpid[]
DateTime arg_opdate[]
Long j = 0

uo_partbarcode uo_bar
uo_bar = Create uo_partbarcode

uo_sc_task_finish sc_task
sc_task = Create uo_sc_task_finish

IF pf_get_barcodes_notflag(Ref arr_bars, Ref arg_msg) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

arg_cnt = 0
arg_failcnt = 0



Long i
String ls_msg
FOR i = 1 To UpperBound(arr_bars)
	UPDATE u_order_wkp_barcode_pda
		SET flag = 1
		WHERE barcode = :arr_bars[i].barcode
		AND wrkgrpid = :arr_bars[i].wrkgrpid
		AND kind = :arr_bars[i].kind
		And flag = :arr_bars[i].flag;
	IF sqlca.SQLCode <> 0 THEN
		ls_msg = '更新PDA部件条码标记失败,' + sqlca.SQLErrText
		GOTO _failt
	END IF
	
	IF sqlca.SQLNRows <= 0 THEN
		ls_msg = '条码被其它任务占用,本任务终止'
		GOTO _failt
	END IF
	
	IF arr_bars[i].Kind = 0 THEN
		IF uo_bar.uf_finish_barcode(arr_bars[i].wrkgrpid, arr_bars[i].barcode, arr_bars[i].opemp, arr_bars[i].opdate, arr_bars[i].workgroupid, arg_replace, Ref ls_msg, False) <> 1 THEN
			GOTO _failt
		END IF
	ELSEIF arr_bars[i].Kind = 1 THEN
		IF uo_bar.uf_o_barcode(arr_bars[i].wrkgrpid, arr_bars[i].barcode, arr_bars[i].opemp, arr_bars[i].opdate, Ref ls_msg, False) <> 1 THEN
			GOTO _failt
		END IF
	ELSEIF arr_bars[i].Kind = 2 THEN
		IF uo_bar.uf_finish_barcode_last(arr_bars[i].wrkgrpid, arr_bars[i].barcode, arr_bars[i].opdate, arg_replace, Ref ls_msg, False) <> 1 THEN
			GOTO _failt
		END IF
	END IF
	
	arg_cnt++
	COMMIT;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '事务提交失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
	IF arg_finishbarcode And (arr_bars[i].Kind = 0 Or arr_bars[i].Kind = 2) THEN
		j++
		arg_barcode[j] = arr_bars[i].barcode
		arg_wrkgrpid[j] = arr_bars[i].wrkgrpid
		arg_opdate[j] = arr_bars[i].opdate
	END IF
	
	CONTINUE
	
	_failt:
	arg_failcnt ++
	ROLLBACK;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '事务回滚失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	arg_msg += ls_msg
	UPDATE u_order_wkp_barcode_pda
		SET errmsg = :ls_msg,
		flag = 2
		WHERE barcode = :arr_bars[i].barcode
		AND wrkgrpid = :arr_bars[i].wrkgrpid
		And Kind = :arr_bars[i].Kind
		And flag = :arr_bars[i].flag;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '更新PDA部件条码错误信息失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	COMMIT;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '事务提交失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
NEXT

ext:

IF arg_finishbarcode AND UpperBound(arg_barcode) > 0 THEN
	IF sc_task.uf_finishbarcode(arg_wrkgrpid, arg_barcode, arg_opdate, ls_msg) <> 1 THEN
		rslt = 0
		arg_msg = '生成工序完工单失败,' + ls_msg
	END IF
END IF

Destroy uo_bar
Destroy sc_task
RETURN  rslt

















end function

private function integer pf_get_barcodes_notflag (ref s_p_barcode_pda arg_bars[], ref string arg_msg);// 获取所有未处理的条码
Int rslt = 1

s_p_barcode_pda arr_bars[]
Long i = 0

String barcode,opemp
Long wrkgrpid,Kind,flag,workgroupid
DateTime opdate

DECLARE cur1 CURSOR FOR SELECT barcode,wrkgrpid,kind,flag,opemp,opdate,workgroupid
	FROM u_order_wkp_barcode_pda
	Where flag <> 1;
OPEN cur1;
FETCH cur1 Into :barcode,:wrkgrpid,:Kind,:flag,:opemp,:opdate,:workgroupid;
DO WHILE sqlca.SQLCode = 0
	i++
	arr_bars[i].barcode = barcode
	arr_bars[i].wrkgrpid = wrkgrpid
	arr_bars[i].Kind = Kind
	arr_bars[i].flag = flag
	arr_bars[i].opemp = opemp
	arr_bars[i].opdate = opdate
	arr_bars[i].workgroupid = workgroupid
	FETCH cur1 Into :barcode,:wrkgrpid,:Kind,:flag,:opemp,:opdate,:workgroupid;
LOOP
CLOSE cur1;

arg_bars = arr_bars

RETURN rslt

end function

public function integer uf_cmpl_cost_balcdateint (ref string arg_msg);//If MessageBox('确认','本功能将按各仓库最近一次结存数据为目标重算,为确保重算成本的准确,请尽量把各仓库同时结存'+'~r~n'+'确定要继续执行本功能?',question!,yesno!) = 2 Then Return

datastore ds_warebalc
ds_warebalc = Create datastore
ds_warebalc.DataObject = 'ds_cmpl_cost_balcdateint_warebalc'
ds_warebalc.SetTransObject(sqlca)


datastore ds_mtrlcost
ds_mtrlcost = Create datastore
ds_mtrlcost.DataObject = 'ds_rp_mtrlprice'
ds_mtrlcost.SetTransObject(sqlca)

datastore ds_inwaremx
ds_inwaremx = Create datastore
ds_inwaremx.DataObject = 'ds_inwaremx_cmpl_balcdateint'
ds_inwaremx.SetTransObject(sqlca)





Int li_status_step = 0 //当前步骤
s_mtrlprice_mx arg_s_mx[],arg_s_empty[]
Long ll_i,ll_j
Long ll_storageid,ll_balcdateint,ll_mtrlid,ll_sptid,ll_scid,ll_mtrlwareid
String ls_status,ls_woodcode,ls_pcode,ls_plancode,ls_mtrlcuscode,ls_location

Decimal ld_inqty,ld_inamt,ld_cost,ld_bgqty,ld_bgamt
Decimal ld_inqty_sum,ld_inamt_sum

String ls_storagename,ls_mtrlcode,ls_mtrlname

//String arg_msg
Int rslt

Int li_statusflag,li_woodcodeflag,li_pcodeflag
String ls_status_config,ls_woodcode_config,ls_pcode_config
String ls_pfcode
Decimal ld_price,ld_wfjgprice,ld_outcost,ld_wageprice,ld_otherprice,ld_eqprice,ld_outcost_self
Long sumdate
Int li_dec
String ls_msg
Long ll_fail
Long ll_row
String ls_findstr
//开始
//ins_ifstart = 1

//p_1.PictureName = 'waiting.jpg'
//st_per_1.Visible = False
//hpb_1.Visible = False
//st_msg_1.Visible = False
//p_2.PictureName = 'waiting.jpg'
//st_per_2.Visible = False
//hpb_2.Visible = False
//st_msg_2.Visible = False
//p_3.PictureName = 'waiting.jpg'
//st_per_3.Visible = False
//st_msg_3.Visible = False
//p_4.PictureName = 'waiting.jpg'
//st_per_4.Visible = False
//hpb_4.Visible = False
//st_msg_4.Visible = False
//
//p_5.PictureName = 'waiting.jpg'
//st_per_5.Visible = False
//st_msg_5.Visible = False


li_dec = 2

uo_cmplcost uo_cmpl
uo_cmpl = Create uo_cmplcost


rslt = 1

//1.计算采购物料成本价

li_status_step = 1

ds_warebalc.Retrieve(2)

ds_inwaremx.Retrieve(2)

//p_1.PictureName = 'doing.jpg'
//hpb_1.MinPosition = 0
//hpb_1.MaxPosition = ds_warebalc.RowCount()
//hpb_1.Position = 0
//
//hpb_1.Visible = True
//st_per_1.Visible = True

For ll_i = 1 To ds_warebalc.RowCount()
	ll_storageid = ds_warebalc.Object.storageid[ll_i]
	ll_balcdateint = ds_warebalc.Object.balcdateint[ll_i]
	ll_mtrlid = ds_warebalc.Object.mtrlid[ll_i]
	ll_sptid = ds_warebalc.Object.sptid[ll_i]
	ls_status = ds_warebalc.Object.status[ll_i]
	ls_woodcode = ds_warebalc.Object.woodcode[ll_i]
	ls_pcode = ds_warebalc.Object.pcode[ll_i]
	ls_plancode = ds_warebalc.Object.plancode[ll_i]
	ls_mtrlcuscode = ds_warebalc.Object.mtrlcuscode[ll_i]
	ls_location = ds_warebalc.Object.Location[ll_i]
	ld_bgqty = ds_warebalc.Object.bgqty[ll_i]
	ld_bgamt = ds_warebalc.Object.bgamt[ll_i]
	ll_scid = ds_warebalc.Object.scid[ll_i]
	ls_storagename = ds_warebalc.Object.storagename[ll_i]
	ls_mtrlcode = ds_warebalc.Object.mtrlcode[ll_i]
	ls_mtrlname = ds_warebalc.Object.mtrlname[ll_i]
	ll_mtrlwareid = ds_warebalc.Object.mtrlwareid[ll_i]
	
	ls_findstr = 'balcdateint = '+String(ll_balcdateint) + ' and storageid = '+String(ll_storageid)
	ls_findstr = ls_findstr + ' and mtrlid = '+String(ll_mtrlid) + ' and status = "'+ls_status+'" '
	ls_findstr = ls_findstr + ' and woodcode = "'+ ls_woodcode + '" and pcode = "'+ls_pcode+'" '
	ls_findstr = ls_findstr + ' and plancode = "'+ ls_plancode + '" and mtrlcuscode = "'+ls_mtrlcuscode+'" '
	ls_findstr = ls_findstr + ' and location = "'+ ls_location + '" and scid = '+String(ll_scid)
	
	
	ll_row = ds_inwaremx.Find(ls_findstr,1,ds_inwaremx.RowCount())
	
	If ll_row > 0 Then
		ld_inamt = ds_inwaremx.Object.inamt[ll_row]
		ld_inqty = ds_inwaremx.Object.inqty[ll_row]
		
		ds_inwaremx.DeleteRow(ll_row)
	Else
		ld_inamt = 0
		ld_inqty = 0
	End If
	
	//	SELECT sum(u_inwaremx.cost * u_inwaremx.qty),
	//		sum(u_inwaremx.qty)
	//		INTO :ld_inamt,
	//		:ld_inqty
	//		FROM u_inware INNER JOIN
	//		u_inwaremx ON u_inware.scid = u_inwaremx.scid AND
	//		u_inware.inwareid = u_inwaremx.inwareid
	//		WHERE (u_inware.balcdateint  = :ll_balcdateint)
	//		AND (u_inware.thflag = 0)
	//		AND (u_inware.storageid = :ll_storageid)
	//		AND (u_inwaremx.mtrlid = :ll_mtrlid)
	//		AND (u_inwaremx.status = :ls_status)
	//		AND (u_inwaremx.woodcode = :ls_woodcode)
	//		AND (u_inwaremx.pcode = :ls_pcode)
	//		AND (u_inwaremx.plancode = :ls_plancode)
	//		AND (u_inwaremx.mtrlcuscode = :ls_mtrlcuscode)
	//		AND (u_inwaremx.Location = :ls_location)
	//		And (u_inware.scid = :ll_scid);
	//	IF sqlca.SQLCode <> 0 THEN
	//		ld_inamt = 0
	//		ld_inqty = 0
	//	END IF
	
	If IsNull(ld_inamt) Then ld_inamt = 0
	If IsNull(ld_inqty) Then ld_inqty = 0
	
	If ld_bgamt < 0 Then
		If ld_inqty > 0 Then
			ld_bgamt = ld_bgqty * (ld_inamt / ld_inqty)
		Else
			Select top 1 cost
				Into :ld_cost
				From u_mtrlware
				Where scid = :ll_scid
				And mtrlwareid = :ll_mtrlwareid;
			If sqlca.SQLCode <> 0 Then
				ld_cost = 0
			End If
			
			ld_bgamt = ld_bgqty * ld_cost
		End If
	End If
	
	If ld_bgqty + ld_inqty <> 0 Then
		ld_cost = (ld_bgamt + ld_inamt) / (ld_bgqty + ld_inqty)
	End If
	
	If ld_bgqty + ld_inqty <> 0 Then
		ld_cost = (ld_bgamt + ld_inamt) / (ld_bgqty + ld_inqty)
	End If
	
	If (ld_bgqty + ld_inqty = 0) Or ld_cost < 0 Then
		Select top 1 cost
			Into :ld_cost
			From u_mtrlware
			Where scid = :ll_scid
			And mtrlwareid = :ll_mtrlwareid;
		If sqlca.SQLCode <> 0 Then
			ld_cost = 0
		End If
	End If
	
	If IsNull(ld_cost)  Then ld_cost = 0
	
	Update u_inwaremx
		Set u_inwaremx.cost = :ld_cost
		From u_inware Inner JOIN
		u_inwaremx ON u_inware.scid = u_inwaremx.scid And
		u_inware.inwareid = u_inwaremx.inwareid
		Where (u_inware.balcdateint  = :ll_balcdateint)
		And (u_inware.thflag = 1)
		And (u_inware.storageid = :ll_storageid)
		And (u_inwaremx.mtrlid = :ll_mtrlid)
		And (u_inwaremx.status = :ls_status)
		And (u_inwaremx.woodcode = :ls_woodcode)
		And (u_inwaremx.pcode = :ls_pcode)
		And (u_inwaremx.plancode = :ls_plancode)
		And (u_inwaremx.mtrlcuscode = :ls_mtrlcuscode)
		And (u_inwaremx.Location = :ls_location)
		And (u_inware.scid = :ll_scid);
	If sqlca.SQLCode <> 0 Then
		rslt = 0
		arg_msg = '更新退货单成本价失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	//更新当前仓库结存表的期间进仓
	Select isnull(sum(u_inwaremx.qty),0),
		isnull(sum(round(u_inwaremx.cost * u_inwaremx.qty,2)),0)
		Into :ld_inqty_sum,
		:ld_inamt_sum
		From u_inware Inner JOIN
		u_inwaremx ON u_inware.scid = u_inwaremx.scid And
		u_inware.inwareid = u_inwaremx.inwareid
		Where (u_inware.balcdateint  = :ll_balcdateint)
		And (u_inware.storageid = :ll_storageid)
		And (u_inwaremx.mtrlid = :ll_mtrlid)
		And (u_inwaremx.status = :ls_status)
		And (u_inwaremx.woodcode = :ls_woodcode)
		And (u_inwaremx.pcode = :ls_pcode)
		And (u_inwaremx.plancode = :ls_plancode)
		And (u_inwaremx.mtrlcuscode = :ls_mtrlcuscode)
		And (u_inwaremx.Location = :ls_location)
		And (u_inware.scid = :ll_scid);
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '查询期间进仓失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	
	//	ld_inamt_sum = Round(ld_inqty * ld_cost,2)
	//	ld_inqty_sum = ld_inqty
	
	If IsNull(ld_inqty_sum)  Then ld_inqty_sum = 0
	If IsNull(ld_inamt_sum)  Then ld_inamt_sum = 0
	
	
	Update u_warebalc
		Set u_warebalc.incqty = :ld_inqty_sum,
		u_warebalc.incamt = :ld_inamt_sum,
		u_warebalc.bgamt = :ld_bgamt
		Where u_warebalc.scid = :ll_scid
		And u_warebalc.balcdateint = :ll_balcdateint
		And u_warebalc.mtrlwareid = :ll_mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表期间进数量金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	If ld_bgqty + ld_inqty_sum <> 0 Then
		ld_cost = (ld_bgamt + ld_inamt_sum) / (ld_bgqty + ld_inqty_sum)
		
		If ld_cost > 0 Then
			Update u_mtrlware
				Set cost = :ld_cost,
				wareamt = :ld_cost * noallocqty
				Where scid = :ll_scid
				And mtrlwareid = :ll_mtrlwareid;
			If sqlca.SQLCode = -1 Then
				rslt = 0
				arg_msg = '更新库存成本价失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
				Goto ext
			End If
		End If
		
	End If
	
	//更新当前仓库所有出仓明细的成本价
	Update u_outwaremx
		Set u_outwaremx.cost = :ld_cost,
		u_outwaremx.costamt = :ld_cost * qty
		From u_outwaremx Inner JOIN
		u_outware ON u_outwaremx.scid = u_outware.scid And
		u_outwaremx.outwareid = u_outware.outwareid
		Where u_outwaremx.scid = :ll_scid
		And u_outwaremx.mtrlwareid = :ll_mtrlwareid
		And u_outware.balcdateint = :ll_balcdateint;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新出仓单成本价失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	
	Update u_warebalc
		Set u_warebalc.desamt = v_outwaremx.desamt
		From u_warebalc Inner JOIN
		(Select u_outwaremx.scid, u_outwaremx.mtrlwareid, u_outware.balcdateint,
		SUM(u_outwaremx.costamt) AS desamt
		From u_outware Inner JOIN
		u_outwaremx ON u_outware.scid = u_outwaremx.scid And
		u_outware.outwareid = u_outwaremx.outwareid
		Where u_outwaremx.scid = :ll_scid
		And u_outwaremx.mtrlwareid = :ll_mtrlwareid
		And u_outware.balcdateint = :ll_balcdateint
		Group By u_outwaremx.scid, u_outwaremx.mtrlwareid, u_outware.balcdateint)
		v_outwaremx ON u_warebalc.scid = v_outwaremx.scid And
		u_warebalc.balcdateint = v_outwaremx.balcdateint And
		u_warebalc.mtrlwareid = v_outwaremx.mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表期间出金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	//重算一次结余数量,结余金额,并得出新的成本价
	Update u_warebalc
		Set balcqty = bgqty + incqty - desqty,
		balcamt = bgamt + incamt - desamt
		Where u_warebalc.scid = :ll_scid
		And u_warebalc.balcdateint = :ll_balcdateint
		And u_warebalc.mtrlwareid = :ll_mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表结余数量金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	Commit;
	
//	hpb_1.Position = ll_i
//	st_per_1.Text = String(ll_i/ds_warebalc.RowCount(),'0.0%')
Next

//hpb_1.Visible = False
//st_per_1.Visible = False
//p_1.PictureName = 'done.jpg'

//2.统计产品最新成本
li_status_step = 2

//p_2.PictureName = 'doing.jpg'


Insert Into u_mtrlprice_sum
	(mtrlid,
	status,
	woodcode,
	pcode,
	pfcode,
	sumdate)
	Select u_mtrl_configure.Mtrlid,
	u_mtrl_configure.name,
	'' AS woodcode,
	'' AS pcode,
	u_mtrl_configure.name ,
	0
	From u_mtrl_configure Inner JOIN
	u_mtrldef ON u_mtrl_configure.Mtrlid = u_mtrldef.mtrlid
	Where (u_mtrldef.statusflag = 2) And (Not Exists
	(Select *
	From u_mtrlprice_sum
	Where mtrlid = u_mtrl_configure.mtrlid And status = u_mtrl_configure.name And
	woodcode = '' And pcode = ''));
If sqlca.SQLCode = -1 Then
	rslt = 0
	arg_msg = '插入新增的组合配置到统计列表失败,'+sqlca.SQLErrText
	Goto ext
End If

Insert Into u_mtrlprice_sum
	(mtrlid,
	status,
	woodcode,
	pcode,
	pfcode,
	sumdate)
	Select u_mtrldef.mtrlid,
	CASE statusflag WHEN 4 THEN status_config ELSE '' End AS status,
	CASE woodcodeflag WHEN 4 THEN woodcode_config ELSE '' End AS woodcode,
	CASE pcodeflag WHEN 4 THEN pcode_config ELSE '' End AS pcode,
	u_mtrl_pf.pfcode,
	0
	From u_mtrldef Inner JOIN
	u_mtrl_pf ON u_mtrldef.mtrlid = u_mtrl_pf.Mtrlid
	Where (u_mtrldef.statusflag <> 2) And (u_mtrl_pf.Ifdft = 1) And (Not Exists
	(Select *
	From u_mtrlprice_sum
	Where mtrlid = u_mtrldef.mtrlid And
	status = CASE statusflag WHEN 4 THEN status_config ELSE '' End And
	woodcode = CASE woodcodeflag WHEN 4 THEN woodcode_config ELSE '' End
	And pcode = Case pcodeflag WHEN 4 Then pcode_config Else '' End));
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '插入新增的产品及物料到统计列表失败,'+sqlca.SQLErrText
	Goto ext
End If


Insert Into u_mtrlprice_sum
	(mtrlid,
	status,
	woodcode,
	pcode,
	pfcode,
	sumdate)
	Select DISTINCT
	u_Order_ml.mtrlid,
	u_Order_ml.status_mode,
	u_Order_ml.woodcode,
	u_Order_ml.pcode,
	CASE u_mtrldef.statusflag WHEN 2 THEN u_Order_ml.status_mode ELSE u_order_ml.pfcode
	End AS pfcode,
	0
	From u_Order_ml Inner JOIN
	u_mtrldef ON u_Order_ml.mtrlid = u_mtrldef.mtrlid
	Where (Not Exists
	(Select *
	From u_mtrlprice_sum
	Where mtrlid = u_order_ml.mtrlid And status = u_Order_ml.status_mode And
	woodcode = u_Order_ml.woodcode And pcode = u_Order_ml.pcode)) And
	(u_Order_ml.status <> 0) And (u_mtrldef.statusflag = 4 Or u_mtrldef.woodcodeflag = 4 Or u_mtrldef.pcodeflag = 4);
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '插入生产中涉及到的新部件选配产品到统计列表失败,'+sqlca.SQLErrText
	Goto ext
End If

Commit;

ds_mtrlcost.Retrieve(0,'',1)

sumdate = Year(Date(Today())) * 10000 + Month(Date(Today())) * 100 + Day(Date(Today()))

/// //
//hpb_2.MinPosition = 0
//hpb_2.MaxPosition = ds_mtrlcost.RowCount()
//hpb_2.Position = 0
//
//hpb_2.Visible = True
//st_per_2.Visible = True
//

For ll_i = 1 To ds_mtrlcost.RowCount()
//	hpb_2.Position = ll_i
//	st_per_2.Text = String(ll_i/ds_mtrlcost.RowCount(),'0.0%')
	
	
	
	ll_mtrlid = ds_mtrlcost.Object.mtrlid[ll_i]
	ls_mtrlcode = ds_mtrlcost.Object.mtrlcode[ll_i]
	ls_pfcode = ds_mtrlcost.Object.u_mtrlprice_sum_pfcode[ll_i]
	ll_scid = ds_mtrlcost.Object.u_mtrldef_scid[ll_i]
	ls_status = ds_mtrlcost.Object.status[ll_i]
	ls_woodcode = ds_mtrlcost.Object.woodcode[ll_i]
	ls_pcode = ds_mtrlcost.Object.pcode[ll_i]
	
	li_statusflag = ds_mtrlcost.Object.statusflag[ll_i]
	li_woodcodeflag = ds_mtrlcost.Object.woodcodeflag[ll_i]
	li_pcodeflag = ds_mtrlcost.Object.pcodeflag[ll_i]
	ls_status_config = ds_mtrlcost.Object.status_config[ll_i]
	ls_woodcode_config = ds_mtrlcost.Object.woodcode_config[ll_i]
	ls_pcode_config = ds_mtrlcost.Object.pcode_config[ll_i]
	
	
	If ls_pfcode = '' Then Continue
	
	ld_price = 0
	ld_wfjgprice = 0
	ld_outcost_self = 0
	ld_outcost = 0
	ld_wageprice = 0
	ld_otherprice = 0
	ld_eqprice = 0
	
	arg_msg = ''
	
	uo_cmpl.deep = 0
	uo_cmpl.ifcmpl_1 = True
	uo_cmpl.ins_cnt = 0
	
	arg_s_mx = arg_s_empty
	
	If (li_statusflag = 4 And ls_status <> ls_status_config Or &
		li_woodcodeflag = 4 And ls_woodcode <> ls_woodcode_config Or &
		li_pcodeflag = 4 And ls_pcode <> ls_pcode_config) Then
		
		If uo_cmpl.uof_get_cost_dz(1,ll_mtrlid,ls_status,ls_woodcode,ls_pcode,ld_price,ld_wfjgprice,ld_outcost,ld_wageprice,ld_eqprice,arg_msg,arg_s_mx) = 0 Then
			arg_msg = '物料:'+ls_mtrlcode+'取成本失败,'+arg_msg
			ls_msg = ls_msg + arg_msg + '~n'
			ll_fail++
			Continue
			
			ld_price = 0
			ld_wfjgprice = 0
			ld_outcost = 0
			ld_wageprice = 0
			ld_eqprice = 0
		End If
	Else
		If uo_cmpl.uof_get_cost(1,ll_scid,ll_mtrlid,ls_mtrlcode,ls_pfcode,1,1,ld_price,ld_wfjgprice,ld_outcost,ld_wageprice,ld_eqprice,0,arg_msg,arg_s_mx,1) = 0 Then
			arg_msg = '物料:'+ls_mtrlcode+'取成本失败,'+arg_msg
			ls_msg = ls_msg + arg_msg + '~n'
			ll_fail++
			Continue
			
			ld_price = 0
			ld_wfjgprice = 0
			ld_outcost = 0
			ld_wageprice = 0
			ld_eqprice = 0
		End If
	End If
	
	ld_price = Round(ld_price,li_dec)
	ld_wfjgprice = Round(ld_wfjgprice,li_dec)
	ld_outcost = Round(ld_outcost,li_dec)
	ld_wageprice = Round(ld_wageprice,li_dec)
	ld_eqprice = Round(ld_eqprice,li_dec)
	
	
	Select top 1 otherprice Into :ld_otherprice
		From u_mtrlprice_sum
		Where mtrlid = :ll_mtrlid
		And pfcode = :ls_pfcode
		And sumdate < :sumdate
		And status = :ls_status
		And woodcode = :ls_woodcode
		And pcode = :ls_pcode
		Order By sumdate Desc;
	If sqlca.SQLCode <> 0 Then
		arg_msg = '物料:'+ls_mtrlcode+'取上次附加成本失败,'+arg_msg
		ls_msg = ls_msg + arg_msg + '~n'
		ll_fail++
		Continue
	End If
	
	If IsNull(ld_otherprice) Then ld_otherprice = 0
	
	
	Update u_mtrlprice_sum
		Set price = :ld_price,
		cost = :ld_price + :ld_wfjgprice + :ld_wageprice + :ld_outcost + :ld_otherprice + :ld_eqprice,
		wfjgprice = :ld_wfjgprice,
		jgprice = :ld_wageprice,
		outcost = :ld_outcost,
		otherprice = :ld_otherprice,
		eqprice = :ld_eqprice,
		dscrp = :arg_msg,
		sumdate = :sumdate
		Where mtrlid = :ll_mtrlid
		And pfcode = :ls_pfcode
		And (sumdate = :sumdate Or sumdate = 0 )
		And status = :ls_status
		And woodcode = :ls_woodcode
		And pcode = :ls_pcode;
	If sqlca.SQLCode = 0 Then
		If sqlca.SQLNRows = 0 Then
			Insert Into u_mtrlprice_sum
				(sumdate,
				pfcode,
				mtrlid,
				price,
				cost,
				wfjgprice,
				jgprice,
				eqprice,
				outcost,
				otherprice,
				dscrp,
				status,
				woodcode,
				pcode)
				Values(:sumdate,
				:ls_pfcode,
				:ll_mtrlid,
				:ld_price,
				:ld_price + :ld_wfjgprice + :ld_wageprice + :ld_outcost + :ld_eqprice,
				:ld_wfjgprice,
				:ld_wageprice,
				:ld_eqprice,
				:ld_outcost,
				:ld_otherprice,
				:arg_msg,
				:ls_status,
				:ls_woodcode,
				:ls_pcode);
			If sqlca.SQLCode <> 0 Then
				arg_msg = '新增物料:'+ls_mtrlcode+'成本失败,'+sqlca.SQLErrText
				ls_msg = ls_msg + arg_msg + '~n'
				ll_fail++
				Continue
			End If
		End If
	Else
		arg_msg = '更新物料:'+ls_mtrlcode+'成本失败,'+sqlca.SQLErrText
		ls_msg = ls_msg + arg_msg + '~n'
		ll_fail++
		Continue
	End If
	
	Delete From u_mtrlprice_mx
		Where mtrlid = :ll_mtrlid
		And pfcode = :ls_pfcode
		And status = :ls_status
		And woodcode = :ls_woodcode
		And pcode = :ls_pcode;
	If sqlca.SQLCode <> 0 Then
		Rollback;
		arg_msg = '删除物料:'+ls_mtrlcode+'原成本组成明细失败,'+sqlca.SQLErrText
		ls_msg = ls_msg + arg_msg + '~n'
		ll_fail++
		Continue
	End If
	
	For ll_j = 1 To UpperBound(arg_s_mx)
		Update u_mtrlprice_mx
			Set price = price + :arg_s_mx[ll_j].price,
			wfjgprice = wfjgprice + :arg_s_mx[ll_j].wfjgprice,
			jgprice = jgprice + :arg_s_mx[ll_j].jgprice,
			outcost = outcost + :arg_s_mx[ll_j].outcost,
			eqprice = eqprice + :arg_s_mx[ll_j].eqprice,
			qty = qty + :arg_s_mx[ll_j].qty
			Where mtrlid = :ll_mtrlid
			And pfcode = :ls_pfcode
			And status = :ls_status
			And woodcode = :ls_woodcode
			And pcode = :ls_pcode
			And sonmtrlid = :arg_s_mx[ll_j].sonmtrlid;
		If sqlca.SQLCode = 0 Then
			If sqlca.SQLNRows = 0 Then
				Insert Into u_mtrlprice_mx
					(mtrlid,
					pfcode,
					status,
					woodcode,
					pcode,
					sonmtrlid,
					price,
					wfjgprice,
					jgprice,
					outcost,
					eqprice,
					qty)
					Values (:ll_mtrlid,
					:ls_pfcode,
					:ls_status,
					:ls_woodcode,
					:ls_pcode,
					:arg_s_mx[ll_j].sonmtrlid,
					:arg_s_mx[ll_j].price,
					:arg_s_mx[ll_j].wfjgprice,
					:arg_s_mx[ll_j].jgprice,
					:arg_s_mx[ll_j].outcost,
					:arg_s_mx[ll_j].eqprice,
					:arg_s_mx[ll_j].qty);
				If sqlca.SQLCode <> 0 Then
					Rollback;
					arg_msg = '物料:'+ls_mtrlcode+'插入成本组成明细失败,'+sqlca.SQLErrText
					ls_msg = ls_msg + arg_msg + '~n'
					ll_fail++
					Goto _next
				End If
			End If
		Else
			Rollback;
			arg_msg = '更新物料:'+ls_mtrlcode+'成本组成明细失败,'+sqlca.SQLErrText
			ls_msg = ls_msg + arg_msg + '~n'
			ll_fail++
			Goto _next
		End If
		
	Next
	
	Commit;
	_next:
Next

//hpb_2.Visible = False
//st_per_2.Visible = False
//p_2.PictureName = 'done.jpg'


//3.更新成品进仓单成本价
li_status_step = 3


//p_3.PictureName = 'doing.jpg'
//st_per_3.Visible = True


Update u_inwaremx
	Set u_inwaremx.cost = isnull(v_cost.cost,0),
	u_inwaremx.fprice = isnull(v_cost.cost,0),
	u_inwaremx.uprice = isnull(v_cost.cost,0),
	u_inwaremx.enprice = isnull(v_cost.cost,0),
	u_inwaremx.enprice_tax = isnull(v_cost.cost,0),
	u_inwaremx.enprice_notax = isnull(v_cost.cost,0),
	u_inwaremx.price = isnull(v_cost.cost,0)
	From u_inwaremx Inner JOIN
	u_inware ON u_inwaremx.scid = u_inware.scid And
	u_inwaremx.inwareid = u_inware.inwareid Inner JOIN
	(Select DISTINCT Storageid, MAX(balcdateint) AS balcdateint
	From u_warebalc
	Where (balcdateint > 0)
	Group By Storageid) v_balcint ON u_inware.storageid = v_balcint.Storageid And
	u_inware.balcdateint = v_balcint.balcdateint Inner JOIN
	(Select u_mtrlprice_sum.mtrlid, u_mtrlprice_sum.status,
	u_mtrlprice_sum.woodcode, u_mtrlprice_sum.pcode,
	MAX(u_mtrlprice_sum.cost) AS cost
	From u_mtrlprice_sum Inner JOIN
	(Select MAX(sumdate) AS sumdate, mtrlid, pfcode, status, woodcode,pcode
	From u_mtrlprice_sum
	Group By mtrlid, pfcode, status, woodcode, pcode) v_mtrlid_sumdate ON
	u_mtrlprice_sum.pcode = v_mtrlid_sumdate.pcode COLLATE Chinese_PRC_CI_AS
	And
	u_mtrlprice_sum.woodcode = v_mtrlid_sumdate.woodcode COLLATE Chinese_PRC_CI_AS
	And
	u_mtrlprice_sum.status = v_mtrlid_sumdate.status COLLATE Chinese_PRC_CI_AS
	And u_mtrlprice_sum.mtrlid = v_mtrlid_sumdate.mtrlid And
	u_mtrlprice_sum.pfcode = v_mtrlid_sumdate.pfcode And
	u_mtrlprice_sum.sumdate = v_mtrlid_sumdate.sumdate
	Group By u_mtrlprice_sum.mtrlid, u_mtrlprice_sum.status,
	u_mtrlprice_sum.woodcode, u_mtrlprice_sum.pcode) v_cost ON
	u_inwaremx.mtrlid = v_cost.mtrlid And u_inwaremx.status = v_cost.status And
	u_inwaremx.woodcode = v_cost.woodcode And
	u_inwaremx.pcode = v_cost.pcode
	Where (u_inware.billtype <> 1);
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '更新生产进仓单单价及成本价失败,'+sqlca.SQLErrText
	Goto ext
End If

Commit;

//st_per_3.Visible = False
//p_3.PictureName = 'done.jpg'


//4.更新产品结存表成本价,库存成本价
li_status_step = 4


ds_warebalc.Retrieve(30)
ds_inwaremx.Retrieve(30)


//p_4.PictureName = 'doing.jpg'
//hpb_4.MinPosition = 0
//hpb_4.MaxPosition = ds_warebalc.RowCount()
//hpb_4.Position = 0
//
//hpb_4.Visible = True
//st_per_4.Visible = True



For ll_i = 1 To ds_warebalc.RowCount()
	ll_storageid = ds_warebalc.Object.storageid[ll_i]
	ll_balcdateint = ds_warebalc.Object.balcdateint[ll_i]
	ll_mtrlid = ds_warebalc.Object.mtrlid[ll_i]
	ll_sptid = ds_warebalc.Object.sptid[ll_i]
	ls_status = ds_warebalc.Object.status[ll_i]
	ls_woodcode = ds_warebalc.Object.woodcode[ll_i]
	ls_pcode = ds_warebalc.Object.pcode[ll_i]
	ls_plancode = ds_warebalc.Object.plancode[ll_i]
	ls_mtrlcuscode = ds_warebalc.Object.mtrlcuscode[ll_i]
	ls_location = ds_warebalc.Object.Location[ll_i]
	ld_bgqty = ds_warebalc.Object.bgqty[ll_i]
	ld_bgamt = ds_warebalc.Object.bgamt[ll_i]
	ll_scid = ds_warebalc.Object.scid[ll_i]
	ls_storagename = ds_warebalc.Object.storagename[ll_i]
	ls_mtrlcode = ds_warebalc.Object.mtrlcode[ll_i]
	ls_mtrlname = ds_warebalc.Object.mtrlname[ll_i]
	ll_mtrlwareid = ds_warebalc.Object.mtrlwareid[ll_i]
	
	//	SELECT sum(u_inwaremx.cost * u_inwaremx.qty),
	//		sum(u_inwaremx.qty)
	//		INTO :ld_inamt,
	//		:ld_inqty
	//		FROM u_inware INNER JOIN
	//		u_inwaremx ON u_inware.scid = u_inwaremx.scid AND
	//		u_inware.inwareid = u_inwaremx.inwareid
	//		WHERE (u_inware.balcdateint  = :ll_balcdateint)
	//		AND (u_inware.storageid = :ll_storageid)
	//		AND (u_inwaremx.mtrlid = :ll_mtrlid)
	//		AND (u_inwaremx.status = :ls_status)
	//		AND (u_inwaremx.woodcode = :ls_woodcode)
	//		AND (u_inwaremx.pcode = :ls_pcode)
	//		AND (u_inwaremx.plancode = :ls_plancode)
	//		AND (u_inwaremx.mtrlcuscode = :ls_mtrlcuscode)
	//		AND (u_inwaremx.Location = :ls_location)
	//		And (u_inware.scid = :ll_scid);
	//	IF sqlca.SQLCode <> 0 THEN
	//		ld_inamt = 0
	//		ld_inqty = 0
	//	END IF
	
	
	ls_findstr = 'balcdateint = '+String(ll_balcdateint) + ' and storageid = '+String(ll_storageid)
	ls_findstr = ls_findstr + ' and mtrlid = '+String(ll_mtrlid) + ' and status = "'+ls_status+'" '
	ls_findstr = ls_findstr + ' and woodcode = "'+ ls_woodcode + '" and pcode = "'+ls_pcode+'" '
	ls_findstr = ls_findstr + ' and plancode = "'+ ls_plancode + '" and mtrlcuscode = "'+ls_mtrlcuscode+'" '
	ls_findstr = ls_findstr + ' and location = "'+ ls_location + '" and scid = '+String(ll_scid)
	
	
	ll_row = ds_inwaremx.Find(ls_findstr,1,ds_inwaremx.RowCount())
	
	If ll_row > 0 Then
		ld_inamt = ds_inwaremx.Object.inamt[ll_row]
		ld_inqty = ds_inwaremx.Object.inqty[ll_row]
		ds_inwaremx.DeleteRow(ll_row)
	Else
		ld_inamt = 0
		ld_inqty = 0
	End If
	
	If IsNull(ld_inamt) Then ld_inamt = 0
	If IsNull(ld_inqty) Then ld_inqty = 0
	
	If ld_bgamt < 0 Then
		If ld_inqty > 0 Then
			ld_bgamt = ld_bgqty * (ld_inamt / ld_inqty)
		Else
			Select top 1 cost
				Into :ld_cost
				From u_mtrlware
				Where scid = :ll_scid
				And mtrlwareid = :ll_mtrlwareid;
			If sqlca.SQLCode <> 0 Then
				ld_cost = 0
			End If
			
			ld_bgamt = ld_bgqty * ld_cost
		End If
	End If
	
	If ld_bgqty + ld_inqty <> 0 Then
		ld_cost = (ld_bgamt + ld_inamt) / (ld_bgqty + ld_inqty)
	End If
	
	If (ld_bgqty + ld_inqty = 0) Or ld_cost < 0 Then
		Select top 1 cost
			Into :ld_cost
			From u_mtrlware
			Where scid = :ll_scid
			And mtrlwareid = :ll_mtrlwareid;
		If sqlca.SQLCode <> 0 Then
			ld_cost = 0
		End If
	End If
	
	If IsNull(ld_cost)  Then ld_cost = 0
	
	
	
	//更新当前仓库结存表的期间进仓
	//	SELECT isnull(sum(u_inwaremx.qty),0),
	//		isnull(sum(round(u_inwaremx.cost * u_inwaremx.qty,2)),0)
	//		INTO :ld_inqty_sum,
	//		:ld_inamt_sum
	//		FROM u_inware INNER JOIN
	//		u_inwaremx ON u_inware.scid = u_inwaremx.scid AND
	//		u_inware.inwareid = u_inwaremx.inwareid
	//		WHERE (u_inware.balcdateint  = :ll_balcdateint)
	//		AND (u_inware.storageid = :ll_storageid)
	//		AND (u_inwaremx.mtrlid = :ll_mtrlid)
	//		AND (u_inwaremx.status = :ls_status)
	//		AND (u_inwaremx.woodcode = :ls_woodcode)
	//		AND (u_inwaremx.pcode = :ls_pcode)
	//		AND (u_inwaremx.plancode = :ls_plancode)
	//		AND (u_inwaremx.mtrlcuscode = :ls_mtrlcuscode)
	//		AND (u_inwaremx.Location = :ls_location)
	//		And (u_inware.scid = :ll_scid);
	//	IF sqlca.SQLCode = -1 THEN
	//		rslt = 0
	//		arg_msg = '查询期间进仓失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
	//		GOTO ext
	//	END IF
	
	
	ld_inqty_sum =  ld_inqty
	ld_inamt_sum =  ld_inamt
	
	
	If IsNull(ld_inqty_sum)  Then ld_inqty_sum = 0
	If IsNull(ld_inamt_sum)  Then ld_inamt_sum = 0
	
	
	Update u_warebalc
		Set u_warebalc.incqty = :ld_inqty_sum,
		u_warebalc.incamt = :ld_inamt_sum,
		u_warebalc.bgamt = :ld_bgamt
		Where u_warebalc.scid = :ll_scid
		And u_warebalc.balcdateint = :ll_balcdateint
		And u_warebalc.mtrlwareid = :ll_mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表期间进数量金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	//更新当前仓库所有出仓明细的成本价
	Update u_outwaremx
		Set u_outwaremx.cost = :ld_cost,
		u_outwaremx.costamt = :ld_cost * qty
		From u_outwaremx Inner JOIN
		u_outware ON u_outwaremx.scid = u_outware.scid And
		u_outwaremx.outwareid = u_outware.outwareid
		Where u_outwaremx.scid = :ll_scid
		And u_outwaremx.mtrlwareid = :ll_mtrlwareid
		And u_outware.balcdateint = :ll_balcdateint;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新出仓单成本价失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	Update u_warebalc
		Set u_warebalc.desamt = v_outwaremx.desamt
		From u_warebalc Inner JOIN
		(Select u_outwaremx.scid, u_outwaremx.mtrlwareid, u_outware.balcdateint,
		SUM(u_outwaremx.costamt) AS desamt
		From u_outware Inner JOIN
		u_outwaremx ON u_outware.scid = u_outwaremx.scid And
		u_outware.outwareid = u_outwaremx.outwareid
		Where u_outwaremx.scid = :ll_scid
		And u_outwaremx.mtrlwareid = :ll_mtrlwareid
		And u_outware.balcdateint = :ll_balcdateint
		Group By u_outwaremx.scid, u_outwaremx.mtrlwareid, u_outware.balcdateint)
		v_outwaremx ON u_warebalc.scid = v_outwaremx.scid And
		u_warebalc.balcdateint = v_outwaremx.balcdateint And
		u_warebalc.mtrlwareid = v_outwaremx.mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表期间出金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	//重算一次结余数量,结余金额,并得出新的成本价
	Update u_warebalc
		Set balcqty = bgqty + incqty - desqty,
		balcamt = bgamt + incamt - desamt
		Where u_warebalc.scid = :ll_scid
		And u_warebalc.balcdateint = :ll_balcdateint
		And u_warebalc.mtrlwareid = :ll_mtrlwareid;
	If sqlca.SQLCode = -1 Then
		rslt = 0
		arg_msg = '更新结存表结余数量金额失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
		Goto ext
	End If
	
	
	If ld_bgqty + ld_inqty_sum <> 0 Then
		ld_cost = (ld_bgamt + ld_inamt_sum) / (ld_bgqty + ld_inqty_sum)
		
		If ld_cost > 0 Then
			Update u_mtrlware
				Set cost = :ld_cost,
				wareamt = :ld_cost * noallocqty
				Where scid = :ll_scid
				And mtrlwareid = :ll_mtrlwareid;
			If sqlca.SQLCode = -1 Then
				rslt = 0
				arg_msg = '更新库存成本价失败,仓库:'+ls_storagename+',物料:['+ls_mtrlcode+']'+ls_mtrlname + '~r~n'  +sqlca.SQLErrText
				Goto ext
			End If
		End If
		
	End If
	
	Commit;
	
//	hpb_4.Position = ll_i
//	st_per_4.Text = String(ll_i/ds_warebalc.RowCount(),'0.0%')
Next

//hpb_4.Visible = False
//st_per_4.Visible = False
//p_4.PictureName = 'done.jpg'


//5.按最近结存的结余金额更新本期期初
li_status_step = 5


//p_5.PictureName = 'doing.jpg'
//st_per_5.Visible = True


Update u_warebalc
	Set u_warebalc.bgqty = v_last.balcqty,
	u_warebalc.bgamt = v_last.balcamt
	From u_warebalc Inner JOIN
	(Select u_warebalc.scid, u_warebalc.balcdateint, u_warebalc.mtrlwareid,
	u_warebalc.balcqty, u_warebalc.balcamt
	From u_warebalc Inner JOIN
	(Select DISTINCT Storageid, MAX(balcdateint) AS balcdateint
	From u_warebalc
	Where (balcdateint > 0)
	Group By Storageid) v_balcint ON
	u_warebalc.Storageid = v_balcint.Storageid And
	u_warebalc.balcdateint = v_balcint.balcdateint) v_last ON
	u_warebalc.scid = v_last.scid And
	u_warebalc.mtrlwareid = v_last.mtrlwareid Inner JOIN
	u_mtrldef ON u_warebalc.mtrlid = u_mtrldef.mtrlid Inner JOIN
	u_storage ON u_warebalc.Storageid = u_storage.storageid
	Where (u_warebalc.balcdateint = 0)
	And ( u_warebalc.bgqty <> v_last.balcqty  Or  u_warebalc.bgamt <> v_last.balcamt);
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '按最近结存的结余金额更新本期期初失败,'+sqlca.SQLErrText
	Goto ext
End If

Update u_warebalc
	Set balcqty = bgqty +  incqty - desqty,
	balcamt = bgamt + incamt - desamt
	Where (balcdateint = 0)
	And (balcqty <> bgqty +  incqty - desqty Or balcamt <> bgamt + incamt - desamt);
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '按最近结存的结余金额更新本期结余失败,'+sqlca.SQLErrText
	Goto ext
End If


//更新指令单领用明细金额
Update u_OrderRqMtrl_scll
	Set  u_OrderRqMtrl_scll.costamt = v_outware.cost * u_OrderRqMtrl_scll.DstrQty
	From u_OrderRqMtrl_scll Inner JOIN
	(Select u_outware.scid, u_outwaremx.relid AS orderid,
	u_outware.relid AS wrkgrpid, u_outwaremx.mtrlid, u_outwaremx.status,
	u_outwaremx.woodcode, u_outwaremx.pcode, SUM(u_outwaremx.costamt)
	/ SUM(u_outwaremx.qty) AS cost
	From u_outwaremx Inner JOIN
	u_outware ON u_outwaremx.scid = u_outware.scid And
	u_outwaremx.outwareid = u_outware.outwareid Inner JOIN
	(Select DISTINCT Storageid, MAX(balcdateint) AS balcdateint
	From u_warebalc
	Where (balcdateint > 0)
	Group By Storageid) v_balcint ON
	u_outware.StorageID = v_balcint.Storageid And
	u_outware.balcdateint = v_balcint.balcdateint
	Where (u_outware.billtype = 3) And (u_outwaremx.relid > 0) And
	(u_outwaremx.qty > 0) And (u_outwaremx.cost > 0)
	Group By u_outware.scid, u_outwaremx.relid, u_outware.relid,
	u_outwaremx.mtrlid, u_outwaremx.status, u_outwaremx.woodcode,
	u_outwaremx.pcode
	Having (SUM(u_outwaremx.qty) > 0)) v_outware ON
	u_OrderRqMtrl_scll.scid = v_outware.scid And
	u_OrderRqMtrl_scll.OrderID = v_outware.orderid And
	u_OrderRqMtrl_scll.MtrlID = v_outware.mtrlid And
	u_OrderRqMtrl_scll.wrkGrpid = v_outware.wrkgrpid And
	u_OrderRqMtrl_scll.status = v_outware.status COLLATE Chinese_PRC_CI_AS And
	u_OrderRqMtrl_scll.woodcode = v_outware.woodcode COLLATE Chinese_PRC_CI_AS And
	u_OrderRqMtrl_scll.pcode = v_outware.pcode COLLATE Chinese_PRC_CI_AS
	Where v_outware.cost > 0
	And u_OrderRqMtrl_scll.costamt <> v_outware.cost * u_OrderRqMtrl_scll.DstrQty ;
If sqlca.SQLCode <> 0 Then
	rslt = 0
	arg_msg = '更新指令单领用明细金额失败,'+sqlca.SQLErrText
	Goto ext
End If

Commit;

//st_per_5.Visible = False
//p_5.PictureName = 'done.jpg'

ext:

Destroy ds_warebalc
Destroy ds_mtrlcost
Destroy ds_inwaremx
Destroy uo_cmpl

If rslt = 0 Then
	Rollback;
	
//	If li_status_step = 1 Then
//		p_1.PictureName = 'wrong.jpg'
//		st_per_1.Visible = False
//		hpb_1.Visible = False
//		st_msg_1.Text = arg_msg
//	ElseIf li_status_step = 2 Then
//		p_2.PictureName = 'wrong.jpg'
//		st_per_2.Visible = False
//		hpb_2.Visible = False
//		st_msg_2.Text = arg_msg
//	ElseIf li_status_step = 3 Then
//		p_3.PictureName = 'wrong.jpg'
//		st_per_3.Visible = False
//		st_msg_3.Text = arg_msg
//	ElseIf li_status_step = 4 Then
//		p_4.PictureName = 'wrong.jpg'
//		st_per_4.Visible = False
//		hpb_4.Visible = False
//		st_msg_4.Text = arg_msg
//	ElseIf li_status_step = 5 Then
//		p_5.PictureName = 'wrong.jpg'
//		st_per_5.Visible = False
//		st_msg_5.Text = arg_msg
//	End If
	
	f_setsysoplog('按月重算产品成本','按月重算产品成本失败,原因:'+arg_msg,ls_msg,True)
	
Else
	f_setsysoplog('按月重算产品成本','按月重算产品成本成功',ls_msg,True)
	
//	MessageBox('系统提示','重算完成')
	
End If

//ins_ifstart = 0

return rslt


end function

public function integer uof_cmpl_warebalc_amt (long arg_storageid, long arg_balcdateint, ref string arg_msg);uo_warebalc_cmpl uo_cmpl
uo_cmpl = Create uo_warebalc_cmpl

Int rslt = 1

rslt = uo_cmpl.uof_cmpl_warebalc_amt(arg_storageid, arg_balcdateint, Ref arg_msg)

Destroy uo_cmpl
RETURN rslt

end function

public function integer uof_cmpl_mtrlcost_planprice (long arr_mtrlid[], string arr_pfcode[], string arr_status[], string arr_woodcode[], string arr_pcode[], long li_dec, boolean if_auto_copy, integer ifprice, integer ifwfjgprice, integer ifjgprice, integer ifoutcost, integer ifotherprice, integer ifeqprice, ref string ls_msg);Int rslt = 1
Long ll_fail = 0
Long i
ls_msg = ''
String arg_msg
uo_cmplcost uo_cmpl
uo_cmpl = Create uo_cmplcost

FOR i = 1 To UpperBound(arr_mtrlid)
	IF arr_pfcode[i] = '' THEN CONTINUE
	arg_msg = ''
	IF uo_cmpl.uof_cmpl_mtrlcost(arr_mtrlid[i], arr_pfcode[i], arr_status[i], arr_woodcode[i], arr_pcode[i], li_dec, if_auto_copy,&
		ifprice, ifwfjgprice, ifjgprice, ifoutcost, ifotherprice, ifeqprice, Ref arg_msg) <> 1 THEN
		ls_msg = ls_msg + arg_msg + '~r~n'
		ll_fail++
		CONTINUE
	END IF
NEXT

Destroy uo_cmpl
IF ll_fail > 0 THEN
	rslt = 0
	ls_msg = "统计失败:~r~n" + ls_msg
ELSE
	ls_msg = "统计成功"
END IF
RETURN rslt

end function

private function integer pf_outware_to_inwarebuy (string ls_sn, datetime dt_server, ref string arg_msg);Int rslt = 1

Long ll_scid
String ls_sccode, ls_outwarecode, ls_banktypename, ls_moneyname
Long ll_banktypeid, ll_moneyid
String ls_cuscode, ls_sendsccode // 供应商
Long ll_sptid // 供应商
Long ll_storageid = 0

Long ll_printid, arr_printid[], arr_ll_empty[]
Long j = 0, cnt = 0, i = 0

String ls_sptmtrlcode, ls_status, ls_woodcode, ls_pcode, ls_plancode, ls_unit, ls_mtrlcuscode
String ls_fiebrelcode
Long ll_mtrlid
Long ll_ifrel, ll_relid, ll_relprintid
String ls_mtrlcode
Decimal ld_qty, ld_enprice, ld_rebate

Decimal ld_amt
String ls_itemname, ls_itemcode, ls_mxdscrp
Long ll_itemid

String ls_inwarecode
Long ll_inwareid

s_getbar arg_s_gb, s_empty
Long ll_sptmtrlid, arr_sptmtrlid[]
String arr_status[], arr_woodcode[], arr_pcode[]
Dec ld_packqty, arr_packqty[], ld_num, arr_num[]
String ls_barcode

uo_inware_buy uo_ware
uo_ware = Create uo_inware_buy
uo_ware.commit_transaction = sqlca

uo_getbar uo_get
uo_get = Create uo_getbar

SELECT LJFIEB_packet.ReceiveSCcode,
	LJFIEB_tempoutware.outwarecode,
	cuscomm_s.CusCode,
	LJFIEB_packet.SendSCcode,
	LJFIEB_tempoutware.banktypename,
	LJFIEB_tempoutware.moneyname
	
	INTO :ls_sccode, :ls_outwarecode, :ls_cuscode, :ls_sendsccode, :ls_banktypename, :ls_moneyname
	FROM LJFIEB_packet INNER JOIN
	LJFIEB_tempoutware ON LJFIEB_packet.SerialNum = LJFIEB_tempoutware.serialnum  INNER JOIN
	LJFIEB_CusComm AS cuscomm_s ON LJFIEB_packet.SendCusCommID = cuscomm_s.CusCommID
	WHERE LJFIEB_packet.SerialNum = :ls_sn
	Using sys_email_sqlca;
IF sys_email_sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询接收分部编码失败,' + sys_email_sqlca.SQLErrText
	GOTO ext
END IF

SELECT scid
	INTO :ll_scid
	FROM u_scdef
	Where sccode = :ls_sccode;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询接收分部失败,编码['+ls_sccode+'],' + sqlca.SQLErrText
	GOTO ext
END IF

SELECT sptid, banktypeid
	INTO :ll_sptid, :ll_banktypeid
	FROM u_spt
	WHERE  commcode = :ls_cuscode
	And commsccode = :ls_sendsccode;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询发送供应商['+ls_cuscode+']['+ls_sendsccode+']失败,' + sqlca.SQLErrText
	GOTO ext
END IF

//SELECT banktypeid
//	INTO :ll_banktypeid
//	FROM cw_banktype
//	Where inuse = 1 And banktype = 1 And banktypename = :ls_banktypename;
//IF sqlca.SQLCode <> 0 THEN
//	rslt = 0
//	arg_msg = '查询结算方式['+ls_banktypename+']失败,' + sqlca.SQLErrText
//	GOTO ext
//END IF

SELECT moneyid INTO :ll_moneyid
	FROM cw_currency
	Where Name = :ls_moneyname;
IF sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询币种['+ls_moneyname+']失败,' + sqlca.SQLErrText
	GOTO ext
END IF

IF uo_ware.newbegin(ll_scid,1,arg_msg) = 0 THEN
	rslt = 0
	GOTO ext
END IF

uo_ware.indate =  dt_server // 发生时间
uo_ware.inrep  = publ_operator // 经手人
uo_ware.part   = ls_outwarecode
uo_ware.dscrp  = ''
uo_ware.storageid  = ll_storageid // DONE: dw_uc.Object.storageid[uc_row]
uo_ware.sptid = ll_sptid
uo_ware.otheramt = 0
uo_ware.relint_1 = ll_banktypeid
uo_ware.relid  = 0
uo_ware.thflag = 0
uo_ware.moneyid =  ll_moneyid
uo_ware.mrate =  f_get_mrate(ll_moneyid)

arr_printid = arr_ll_empty
j = 0

DECLARE cur2 CURSOR FOR
	SELECT printid
	FROM LJFIEB_tempoutwaremx
	WHERE (serialnum = :ls_sn)
	ORDER BY printid
	Using sys_email_sqlca;
OPEN cur2;
FETCH cur2 Into :ll_printid;
DO WHILE sys_email_sqlca.SQLCode = 0
	j++
	arr_printid[j] = ll_printid
	FETCH cur2 Into :ll_printid;
LOOP
CLOSE cur2;

FOR j = 1 To UpperBound(arr_printid)
	ll_printid = arr_printid[j]
	
	SELECT sptmtrlcode, status, woodcode, pcode, plancode, unit, qty, enprice, rebate, fiebrelcode, mtrlcuscode
		
		INTO :ls_sptmtrlcode, :ls_status, :ls_woodcode, :ls_pcode, :ls_plancode, :ls_unit, :ld_qty, :ld_enprice, :ld_rebate, :ls_fiebrelcode, :ls_mtrlcuscode
		FROM LJFIEB_tempoutwaremx
		WHERE (serialnum = :ls_sn)
		AND (printid = :ll_printid)
		Using sys_email_sqlca;
	IF sys_email_sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询对方发货单明细失败,' + sys_email_sqlca.SQLErrText
		GOTO ext
	END IF
	
	SELECT u_sptmtrlname.mtrlid,
		u_mtrldef.mtrlcode
		INTO :ll_mtrlid,
		:ls_mtrlcode
		FROM u_sptmtrlname INNER JOIN
		u_mtrldef ON u_sptmtrlname.mtrlid = u_mtrldef.mtrlid
		WHERE u_sptmtrlname.sptid = :ll_sptid
		And u_sptmtrlname.sptmtrlcode = :ls_sptmtrlcode;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询供应商物料['+ls_sptmtrlcode+']本地对应物料失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
	ll_ifrel = 0
	ll_relid = 0
	ll_relprintid = 0
	IF ls_fiebrelcode <> '' And ll_mtrlid > 0 THEN
		SELECT top 1  u_buyTaskMx.TaskID, u_buyTaskMx.printid
			INTO :ll_relid,:ll_relprintid
			FROM u_buyTask INNER JOIN
			u_buyTaskMx ON u_buyTask.scid = u_buyTaskMx.scid AND
			u_buyTask.TaskID = u_buyTaskMx.TaskID
			WHERE u_buyTask.taskcode = :ls_fiebrelcode
			AND u_buyTaskMx.mtrlid = :ll_mtrlid
			AND u_buyTaskMx.status = :ls_status
			AND u_buyTaskMx.woodcode = :ls_woodcode
			And u_buyTaskMx.pcode = :ls_pcode;
		IF sqlca.SQLCode <> 0 THEN
			ll_ifrel = 0
			ll_relid = 0
			ll_relprintid = 0
		ELSE
			ll_ifrel = 1
		END IF
	END IF
	
	IF ll_storageid = 0 THEN // 取第一个物料的默认存放仓库
		SELECT top 1 storageid
			INTO :ll_storageid
			FROM u_mtrl_storage
			WHERE mtrlid = :ll_mtrlid
			Order By dft Desc;
		IF sqlca.SQLCode <> 0 THEN
			ll_storageid = 0
		ELSE
			uo_ware.storageid = ll_storageid
		END IF
	END IF
	
	IF uo_ware.acceptmx(j,&
		ll_mtrlid,&
		ls_mtrlcode,&
		ls_plancode,&
		ls_status,&
		ld_qty,&
		ld_enprice,&
		ld_rebate,&
		'',&
		arg_msg,0,&
		ll_relid,&
		ll_ifrel,&
		ls_woodcode,&
		ls_pcode,&
		0,&
		ls_unit,&
		1,&
		ld_qty,&
		ll_relprintid,&
		ld_qty,&
		'','',&
		0,&
		0,&
		ls_mtrlcuscode,&
		'',&
		ld_qty,&
		0) = 0 THEN
		rslt = 0
		GOTO ext
	END IF
	
NEXT

IF uo_ware.uf_cmp_mxmx(arg_msg) <> 1 THEN
	rslt = 0
	GOTO ext
END IF

arr_printid = arr_ll_empty
j = 0

DECLARE cur3 CURSOR FOR
	SELECT printid
	FROM LJFIEB_tempoutware_itemmx
	WHERE (serialnum = :ls_sn)
	ORDER BY printid
	Using sys_email_sqlca;
FETCH cur3 Into :ll_printid;
DO WHILE sys_email_sqlca.SQLCode = 0
	j++
	arr_printid[j] = ll_printid
	FETCH cur3 Into :ll_printid;
LOOP
CLOSE cur3;

FOR j = 1 To UpperBound(arr_printid)
	ll_printid = arr_printid[j]
	
	SELECT amt, itemname, mxdscrp
		INTO :ld_amt, :ls_itemname, :ls_mxdscrp
		FROM LJFIEB_tempoutware_itemmx
		WHERE (serialnum = :ls_sn)
		AND (printid = :ll_printid)
		Using sys_email_sqlca;
	IF sys_email_sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询对方销售发货单费用明细失败,' + sys_email_sqlca.SQLErrText
		GOTO ext
	END IF
	
	SELECT itemid,
		itemcode
		INTO :ll_itemid,
		:ls_itemcode
		FROM u_itemdef
		Where itemname = :ls_itemname;
	IF sqlca.SQLCode <> 0 THEN
		rslt = 0
		arg_msg = '查询费用明细项目['+ls_itemname+']对应本地收支项目失败,' + sqlca.SQLErrText
		GOTO ext
	END IF
	
	IF uo_ware.acceptmx_item(j,&
		ll_itemid,&
		ld_amt,&
		ls_mxdscrp,&
		arg_msg) = 0 THEN
		rslt = 0
		GOTO ext
	END IF
NEXT

IF uo_ware.Save(False,arg_msg) = 0 THEN
	rslt = 0
	GOTO ext
END IF

ls_inwarecode = uo_ware.inwarecode
ll_inwareid = uo_ware.inwareid

UPDATE LJFIEB_tempoutware
	SET relreissuecode = :ls_inwarecode,
	flag = 1,
	ConfirmTime = getdate(),
	ConfirmUser = :publ_operator
	Where SerialNum = :ls_sn Using sys_email_sqlca;
IF sys_email_sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '更新相关单号失败,'+sys_email_sqlca.SQLErrText
	GOTO ext
END IF

//更新本地通信记录
UPDATE LJFIEB_packet
	SET status = 6,
	Complete =  1,
	ConfirmTime = getdate(),
	ConfirmUser = :publ_operator
	Where SerialNum = :ls_sn Using sys_email_sqlca;
IF sys_email_sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '更新本地通信记录失败,'+sys_email_sqlca.SQLErrText
	GOTO ext
END IF

// DONE: 如果有条码，则生成条码生成单
SELECT count(0)
	INTO :cnt
	FROM LJFIEB_tempoutwaremx_mx_barcode
	WHERE serialnum = :ls_sn
	Using sys_email_sqlca;
IF sys_email_sqlca.SQLCode <> 0 THEN
	rslt = 0
	arg_msg = '查询接收条码数量失败,' + sys_email_sqlca.SQLErrText
	GOTO ext
END IF

IF cnt > 0 THEN
	
	i = 0
	arg_s_gb = s_empty
	
	DECLARE cur4 CURSOR FOR
		SELECT qty, mtrlid, status, woodcode, pcode, COUNT(0)
		FROM LJFIEB_tempoutwaremx_mx_barcode
		WHERE serialnum = :ls_sn
		GROUP BY qty, mtrlid, status, woodcode, pcode
		Using sys_email_sqlca;
	OPEN cur4;
	FETCH cur4 Into :ld_packqty, :ll_sptmtrlid, :ls_status, :ls_woodcode, :ls_pcode, :ld_num;
	DO WHILE sys_email_sqlca.SQLCode = 0
		i++
		arr_packqty[i] = ld_packqty
		arr_sptmtrlid[i] = ll_sptmtrlid
		arr_status[i] = ls_status
		arr_woodcode[i] = ls_woodcode
		arr_pcode[i] = ls_pcode
		arr_num[i] = ld_num
		FETCH cur4 Into :ld_packqty, :ll_sptmtrlid, :ls_status, :ls_woodcode, :ls_pcode, :ld_num;
	LOOP
	CLOSE cur4;
	
	FOR i = 1 To UpperBound(arr_sptmtrlid)
		ld_packqty = arr_packqty[i]
		ll_sptmtrlid = arr_sptmtrlid[i]
		ls_status = arr_status[i]
		ls_woodcode = arr_woodcode[i]
		ls_pcode = arr_pcode[i]
		ld_num = arr_num[i]
		
		SELECT top 1 sptmtrlcode
			INTO :ls_sptmtrlcode
			FROM LJFIEB_tempoutwaremx
			WHERE  serialnum = :ls_sn
			AND mtrlid = :ll_sptmtrlid
			Using sys_email_sqlca;
		IF sys_email_sqlca.SQLCode <> 0 THEN
			SELECT top 1 sptmtrlcode
				INTO :ls_sptmtrlcode
				FROM LJFIEB_tempoutwaremx_mx
				WHERE serialnum = :ls_sn
				AND mtrlid = :ll_sptmtrlid
				Using sys_email_sqlca;
			IF sys_email_sqlca.SQLCode <> 0 THEN
				rslt = 0
				arg_msg = '查询条码对应的供应商物料编码失败'
				GOTO ext
			END IF
		END IF
		
		SELECT u_sptmtrlname.mtrlid,
			u_mtrldef.mtrlcode
			INTO :ll_mtrlid,
			:ls_mtrlcode
			FROM u_sptmtrlname INNER JOIN
			u_mtrldef ON u_sptmtrlname.mtrlid = u_mtrldef.mtrlid
			WHERE u_sptmtrlname.sptid = :ll_sptid
			And u_sptmtrlname.sptmtrlcode = :ls_sptmtrlcode;
		IF sqlca.SQLCode <> 0 THEN
			rslt = 0
			arg_msg = '2.查询供应商物料['+ls_sptmtrlcode+']本地对应物料失败,' + sqlca.SQLErrText
			GOTO ext
		END IF
		
		arg_s_gb.scid = ll_scid
		arg_s_gb.getbarid = 0
		arg_s_gb.getbardate = DateTime(Today(), Now())
		arg_s_gb.ifrel = 3
		arg_s_gb.orderid = 0
		arg_s_gb.storageid = ll_storageid
		arg_s_gb.mtrlid = ll_mtrlid
		arg_s_gb.cusid = 0
		arg_s_gb.plancode   = ''
		arg_s_gb.status  = ls_status
		arg_s_gb.woodcode  = ls_woodcode
		arg_s_gb.pcode = ls_pcode
		arg_s_gb.mtrlcuscode = ''
		arg_s_gb.Location = ''
		arg_s_gb.packqty = ld_packqty
		arg_s_gb.qty = ld_packqty * ld_num
		arg_s_gb.dscrp  = ''
		arg_s_gb.dscrp2  = ''
		arg_s_gb.reason  = ''
		arg_s_gb.buytaskprintid = 0
		
		arg_s_gb.uqty = 0
		arg_s_gb.packuqty = 0
		arg_s_gb.rate = 0
		
		j = 0
		DECLARE cur5 CURSOR FOR
			SELECT barcode
			FROM LJFIEB_tempoutwaremx_mx_barcode
			WHERE serialnum = :ls_sn
			AND qty = :ld_packqty
			AND mtrlid = :ll_sptmtrlid
			AND status = :ls_status
			AND woodcode = :ls_woodcode
			AND pcode = :ls_pcode
			Using sys_email_sqlca;
		OPEN cur5;
		FETCH cur5 Into :ls_barcode;
		DO WHILE sys_email_sqlca.SQLCode = 0
			j++
			arg_s_gb.arg_s_mx[j].barcode = ls_barcode
			arg_s_gb.arg_s_mx[j].packqty = ld_packqty
			arg_s_gb.arg_s_mx[j].packuqty = 0
			arg_s_gb.arg_s_mx[j].rate = 0
			arg_s_gb.arg_s_mx[j].qty = 0
			arg_s_gb.arg_s_mx[j].mxdscrp = ''
			arg_s_gb.arg_s_mx[j].mxdscrp2 = ''
			arg_s_gb.arg_s_mx[j].mxdscrp3 = ''
			arg_s_gb.arg_s_mx[j].mxdscrp4 = ''
			
			INSERT INTO U_inwaremx_mx_barcode
				(billtype
				,scid
				,inwareid
				,barcode
				,qty)
				VALUES
				(1
				,:ll_scid
				,:ll_inwareid
				,:ls_barcode
				,:ld_packqty);
			IF sqlca.SQLCode <> 0 THEN
				rslt = 0
				arg_msg = '插入采购收货单条码明细失败,' + sqlca.SQLErrText
				GOTO ext
			END IF
			
			FETCH cur5 Into :ls_barcode;
		LOOP
		CLOSE cur5;
		
		IF uo_get.Save(arg_s_gb,publ_operator,arg_msg,False) = 0 THEN
			rslt = 0
			GOTO ext
		END IF
		
		IF uo_get.auditing(uo_get.uo_getbarid, publ_operator,arg_msg, False) = 0 THEN
			rslt = 0
			GOTO ext
		END IF
		
	NEXT
	
END IF

// 生成采购收货单并审核
IF uo_ware.getinfo(ll_scid,ll_inwareid,arg_msg) = 0 THEN
	rslt = 0
	GOTO ext
END IF

IF uo_ware.auditing(True,arg_msg) = 0 THEN
	rslt = 0
	GOTO ext
END IF

ext:
Destroy uo_ware
Destroy uo_get
IF rslt = 1 THEN
	COMMIT;
	COMMIT Using sys_email_sqlca;
ELSE
	ROLLBACK;
	ROLLBACK Using sys_email_sqlca;
	IF IsNull(arg_msg) THEN
		arg_msg = 'pf_outware_to_inwarebuy错误信息为null'
	END IF
END IF
RETURN rslt




end function

public function integer uof_outware_to_inwarebuy (ref string ls_msg);// DONE: 将未接收的发货单转成采购收货单

Int rslt = 1

String arr_sn[], ls_sn
Long i = 0
DateTime dt_server

ls_msg = ''

IF IsNull(sys_email_sqlca) THEN
	rslt = 0
	ls_msg = '请设置邮件数据库'
	GOTO ext
END IF

IF sys_email_sqlca.DBHandle() <= 0 THEN
	rslt = 0
	ls_msg = '邮件数据库连接失败,请检查'
	GOTO ext
END IF

DECLARE cur1 CURSOR FOR
	SELECT LJFIEB_packet.SerialNum
	FROM LJFIEB_packet INNER JOIN
	LJFIEB_CusComm AS cuscomm_s ON LJFIEB_packet.SendCusCommID = cuscomm_s.CusCommID INNER JOIN
	LJFIEB_CusComm AS CusComm_r ON LJFIEB_packet.ReceiveCusCommID = CusComm_r.CusCommID INNER JOIN
	LJFIEB_tempoutware ON LJFIEB_packet.SerialNum = LJFIEB_tempoutware.serialnum
	WHERE (CusComm_r.CusType = 0)
	AND (LJFIEB_packet.BillType = 4)
	AND (LJFIEB_packet.Complete = 0)
	Using sys_email_sqlca;
	
OPEN cur1;
FETCH cur1 Into :ls_sn;
DO WHILE sys_email_sqlca.SQLCode = 0
	i++
	arr_sn[i] = ls_sn
	FETCH cur1 Into :ls_sn;
LOOP
CLOSE cur1;

SELECT top 1 getdate()
	INTO :dt_server
	From u_user;
IF sqlca.SQLCode <> 0 THEN
	ls_msg = '查询服务器时间失败,' + sqlca.SQLErrText
	GOTO ext
END IF

String arg_msg = ''
Long sec = 0, fail = 0

FOR i = 1 To UpperBound(arr_sn)
	ls_sn = arr_sn[i]
	arg_msg = ''
	TRY
		IF pf_outware_to_inwarebuy(ls_sn, dt_server, Ref arg_msg) <> 1 THEN
			ls_msg = ls_msg + arg_msg + '~r~n'
			fail ++
		ELSE
			sec ++
		END IF
	Catch (RuntimeError ex)
		ls_msg = ls_msg + ex.Text + '~r~n'
		fail ++
	END TRY
NEXT

ls_msg = '成功:'+String(sec)+'失败:'+String(fail)+',' + ls_msg
ext:
IF IsNull(ls_msg) THEN
	ls_msg = 'uof_outware_to_inwarebuy未知错误导至错误信息为null'
END IF
RETURN rslt

end function

on uo_checkpda.create
call super::create
end on

on uo_checkpda.destroy
call super::destroy
end on