$PBExportHeader$uo_saletask_import.sru forward global type uo_saletask_import from nonvisualobject end type end forward global type uo_saletask_import from nonvisualobject end type global uo_saletask_import uo_saletask_import type variables int uo_option_price_rmb Int uo_option_m_msttake /////测试 datawindow ins_dw_test1 end variables forward prototypes public function integer uf_reset (ref s_saletask_import arg_s_import, ref string arg_msg) private function string pf_getid (string arg_ctg, datetime arg_dt, boolean if_commit, transaction arg_transaction) public function integer uf_save_saletask_import (ref s_saletask_import arg_s_import, ref string arg_msg, boolean arg_if_commit) public function integer uf_del (long arg_im_type, string arg_im_id, ref string arg_msg, boolean arg_if_commit) public function integer uf_getinfo (long arg_im_type, string arg_im_id, ref s_saletask_import arg_s_import, ref string arg_msg) public function integer uf_check (s_saletask_import arg_s_import, ref string arg_msg) public function integer uf_taobao_unload (ref string arg_im_ids[], ref string arg_msg) public subroutine uf_fill_taobao (ref s_saletask_import arg_s_import) public subroutine uf_fill (ref s_saletask_import arg_s_import) public function integer uf_accepts (long arg_scid, long arg_im_type, string arg_ids[], long arg_audit, long arg_priceflag, ref string arg_msg) public function integer uf_retrieve_newprice (long arg_im_type, string arg_im_id, ref decimal arg_newprice, ref decimal arg_rebate, ref string arg_msg, boolean arg_ifcommit) public subroutine uf_fill_mtrl (ref s_saletask_import arg_s_import) public function integer uf_csv_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg) public function integer uf_xml_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg) public function integer uf_xls_to_import_sny (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg) public function integer uf_xls_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg) public function integer uof_add_saletask (long arg_im_type[], string arg_im_id[], long arg_scid, long arg_taskid, ref string arg_msg, boolean arg_ifcommit) public function integer uf_accept_taobao (string arg_tid, ref string arg_msg, ref string arg_taskcode) public function integer uf_save_saletask_jiayu (string arg_filename, ref string arg_msg) end prototypes public function integer uf_reset (ref s_saletask_import arg_s_import, ref string arg_msg);Int rslt = 1 IF IsNull(arg_s_import.im_type) THEN arg_s_import.im_type = 0 IF IsNull(arg_s_import.im_id) THEN arg_s_import.im_id = '' IF IsNull(arg_s_import.moneyname) THEN arg_s_import.moneyname = '' IF IsNull(arg_s_import.moneyid) THEN arg_s_import.moneyid = 0 IF IsNull(arg_s_import.mrate) THEN arg_s_import.mrate = 0 IF IsNull(arg_s_import.taskdate) THEN arg_s_import.taskdate = DateTime(Today()) IF IsNull(arg_s_import.tasktype) THEN arg_s_import.tasktype = '' IF IsNull(arg_s_import.typeid) THEN arg_s_import.typeid = 0 IF IsNull(arg_s_import.cuscode) THEN arg_s_import.cuscode = '' IF IsNull(arg_s_import.cusname) THEN arg_s_import.cusname = '' IF IsNull(arg_s_import.level_str) THEN arg_s_import.level_str = '' IF IsNull(arg_s_import.level) THEN arg_s_import.level = 0 IF IsNull(arg_s_import.cusid) THEN arg_s_import.cusid = 0 IF IsNull(arg_s_import.cus_address) THEN arg_s_import.cus_address = '' IF IsNull(arg_s_import.rel_rep) THEN arg_s_import.rel_rep = '' IF IsNull(arg_s_import.cus_tele) THEN arg_s_import.cus_tele = '' IF IsNull(arg_s_import.cus_fax) THEN arg_s_import.cus_fax = '' IF IsNull(arg_s_import.freight) THEN arg_s_import.freight = '' IF IsNull(arg_s_import.freight_tele) THEN arg_s_import.freight_tele = '' IF IsNull(arg_s_import.assign_emp) THEN arg_s_import.assign_emp = '' IF IsNull(arg_s_import.upname) THEN arg_s_import.upname = '' IF IsNull(arg_s_import.banktype) THEN arg_s_import.banktype = '' IF IsNull(arg_s_import.banktypeid) THEN arg_s_import.banktypeid = 0 IF IsNull(arg_s_import.damt) THEN arg_s_import.damt = 0 IF IsNull(arg_s_import.relcode) THEN arg_s_import.relcode = '' IF IsNull(arg_s_import.paytype) THEN arg_s_import.paytype = '' IF IsNull(arg_s_import.otheramt) THEN arg_s_import.otheramt = 0 IF IsNull(arg_s_import.dscrp2) THEN arg_s_import.dscrp2 = '' IF IsNull(arg_s_import.dscrp) THEN arg_s_import.dscrp = '' IF IsNull(arg_s_import.dscrp3) THEN arg_s_import.dscrp3 = '' IF IsNull(arg_s_import.outtypestr) THEN arg_s_import.outtypestr = '' IF IsNull(arg_s_import.mtrlcode) THEN arg_s_import.mtrlcode = '' IF IsNull(arg_s_import.mtrlname) THEN arg_s_import.mtrlname = '' IF IsNull(arg_s_import.mtrlid) THEN arg_s_import.mtrlid = 0 IF IsNull(arg_s_import.unit) THEN arg_s_import.unit = '' IF IsNull(arg_s_import.saleqty) THEN arg_s_import.saleqty = 0 IF IsNull(arg_s_import.pricetype) THEN arg_s_import.pricetype = '' IF IsNull(arg_s_import.enprice) THEN arg_s_import.enprice = 0 IF IsNull(arg_s_import.rebate) THEN arg_s_import.rebate = 0 IF IsNull(arg_s_import.taxrate) THEN arg_s_import.taxrate = 0 IF IsNull(arg_s_import.requiredate) THEN arg_s_import.requiredate = DateTime(Today()) IF IsNull(arg_s_import.status) THEN arg_s_import.status = '' IF IsNull(arg_s_import.woodcode) THEN arg_s_import.woodcode = '' IF IsNull(arg_s_import.pcode) THEN arg_s_import.pcode = '' IF IsNull(arg_s_import.mxdscrp) THEN arg_s_import.mxdscrp = '' IF IsNull(arg_s_import.mxdscrp2) THEN arg_s_import.mxdscrp2 = '' IF IsNull(arg_s_import.mtrlcuscode) THEN arg_s_import.mtrlcuscode = '' IF IsNull(arg_s_import.tid) THEN arg_s_import.tid = '' IF IsNull(arg_s_import.im_userid) THEN arg_s_import.im_userid = '' IF IsNull(arg_s_import.trade_status) THEN arg_s_import.trade_status = '' IF IsNull(arg_s_import.props) THEN arg_s_import.props = '' IF IsNull(arg_s_import.trade_no) THEN arg_s_import.trade_no = '' IF IsNull(arg_s_import.shortname) THEN arg_s_import.shortname = '' IF IsNull(arg_s_import.shopname) THEN arg_s_import.shopname = '' IF IsNull(arg_s_import.transcode) THEN arg_s_import.transcode = '' IF IsNull(arg_s_import.transcom) THEN arg_s_import.transcom = '' IF IsNull(arg_s_import.trans_amt) THEN arg_s_import.trans_amt = 0 RETURN rslt end function private function string pf_getid (string arg_ctg, datetime arg_dt, boolean if_commit, transaction arg_transaction);String rslt = '' Long ll_nmbr arg_ctg = Upper(arg_ctg) arg_dt = DateTime(Date(arg_dt), Time(0)) UPDATE u_bsnno_aps SET nmbr = nmbr + 1 WHERE opDate = :arg_dt AND typecode = :arg_ctg AND scid = 0 And status = 0 Using arg_transaction; IF arg_transaction.SQLCode <> 0 THEN ROLLBACK Using arg_transaction ; rslt = "err" GOTO ext END IF IF arg_transaction.SQLNRows = 0 THEN INSERT INTO u_bsnno_aps(scid, opdate, typecode, nmbr, status) Values (0, :arg_dt, :arg_ctg, 1, 0) Using arg_transaction; IF arg_transaction.SQLCode <> 0 THEN ROLLBACK Using arg_transaction ; rslt = "err" GOTO ext END IF END IF SELECT nmbr INTO :ll_nmbr FROM u_bsnno_aps WHERE opDate = :arg_dt AND typecode = :arg_ctg AND scid = 0 And status = 0 Using arg_transaction; IF arg_transaction.SQLCode <> 0 THEN ROLLBACK Using arg_transaction ; rslt = "err" GOTO ext END IF rslt = arg_ctg + String(arg_dt, 'yyMMdd') + String(ll_nmbr, '000') IF rslt = '' THEN rslt = 'err' IF if_commit And rslt <> "err" THEN COMMIT Using arg_transaction; END IF ext: RETURN rslt end function public function integer uf_save_saletask_import (ref s_saletask_import arg_s_import, ref string arg_msg, boolean arg_if_commit);Int rslt = 1 String ls_newid String ls_ctg Long ll_cnt Long ll_accept_flag String ls_taskcode Long ll_taskcnt IF uf_reset(arg_s_import, arg_msg) <> 1 THEN rslt = 0 GOTO ext END IF IF arg_s_import.im_id = '' Or arg_s_import.im_id = '0' THEN CHOOSE CASE arg_s_import.im_type CASE 0 ls_ctg = 'MD' CASE ELSE rslt = 0 arg_msg = '未定义类型' + String(arg_s_import.im_type) GOTO ext END CHOOSE ls_newid = pf_getid(ls_ctg, DateTime(Today(), Now()), False, sqlca) IF ls_newid = 'err' THEN rslt = 0 arg_msg = '获取唯一码失败' GOTO ext END IF arg_s_import.im_id = ls_newid END IF SELECT COUNT(0) INTO :ll_cnt FROM eb_saletask_import WHERE im_type = :arg_s_import.im_type And im_id = :arg_s_import.im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询订单导入的数量失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_cnt = 0 THEN Decimal ls_1stnewprice = 0 Decimal ls_1stzqrate = 0 uo_saletask_spi.uof_getprice_saletask(arg_s_import,ls_1stnewprice,ls_1stzqrate,arg_msg) INSERT INTO eb_saletask_import (im_type, im_id, moneyname, moneyid, mrate, taskdate, tasktype, typeid, cuscode, cusname, level_str, level, cusid, cus_address, rel_rep, cus_tele, cus_fax, freight, freight_tele, Assign_Emp, upname, banktype, banktypeid, damt, relcode, paytype, otheramt, dscrp2, dscrp, dscrp3, outtypestr, mtrlcode, mtrlname, mtrlid, unit, saleqty, pricetype, enprice, rebate, taxrate, requiredate, status, woodcode, pcode, mxdscrp, mxdscrp2, mtrlcuscode, tid, im_userid, trade_status, props, trade_no, moddate, new_price, new_rebate, shortname, shopname, paydate, outdate, transcode, transcom, confirmdate, createdate, trans_amt) VALUES (:arg_s_import.im_type, :arg_s_import.im_id, :arg_s_import.moneyname, :arg_s_import.moneyid, :arg_s_import.mrate, :arg_s_import.taskdate, :arg_s_import.tasktype, :arg_s_import.typeid, :arg_s_import.cuscode, :arg_s_import.cusname, :arg_s_import.level_str, :arg_s_import.level, :arg_s_import.cusid, :arg_s_import.cus_address, :arg_s_import.rel_rep, :arg_s_import.cus_tele, :arg_s_import.cus_fax, :arg_s_import.freight, :arg_s_import.freight_tele, :arg_s_import.Assign_Emp, :arg_s_import.upname, :arg_s_import.banktype, :arg_s_import.banktypeid, :arg_s_import.damt, :arg_s_import.relcode, :arg_s_import.paytype, :arg_s_import.otheramt, :arg_s_import.dscrp2, :arg_s_import.dscrp, :arg_s_import.dscrp3, :arg_s_import.outtypestr, :arg_s_import.mtrlcode, :arg_s_import.mtrlname, :arg_s_import.mtrlid, :arg_s_import.unit, :arg_s_import.saleqty, :arg_s_import.pricetype, :arg_s_import.enprice, :arg_s_import.rebate, :arg_s_import.taxrate, :arg_s_import.requiredate, :arg_s_import.status, :arg_s_import.woodcode, :arg_s_import.pcode, :arg_s_import.mxdscrp, :arg_s_import.mxdscrp2, :arg_s_import.mtrlcuscode, :arg_s_import.tid, :arg_s_import.im_userid, :arg_s_import.trade_status, :arg_s_import.props, :arg_s_import.trade_no, :arg_s_import.moddate, :ls_1stnewprice, :ls_1stzqrate, :arg_s_import.shortname, :arg_s_import.shopname, :arg_s_import.paydate, :arg_s_import.outdate, :arg_s_import.transcode, :arg_s_import.transcom, :arg_s_import.confirmdate, :arg_s_import.createdate, :arg_s_import.trans_amt); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '插入订单导入表失败,' + sqlca.SQLErrText GOTO ext END IF ELSE SELECT accept_flag, taskcode INTO :ll_accept_flag, :ls_taskcode FROM eb_saletask_import WHERE (im_type = :arg_s_import.im_type) And (im_id = :arg_s_import.im_id); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询临时订单接受信息失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_accept_flag = 1 THEN SELECT COUNT(0) INTO :ll_taskcnt FROM u_saletask Where taskcode = :ls_taskcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询是否存在旧订单失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_taskcnt > 0 THEN rslt = 0 arg_msg = '已经生成订单['+ls_taskcode+']不能修改,请删除旧订单' GOTO ext END IF END IF UPDATE eb_saletask_import SET moneyname = :arg_s_import.moneyname, moneyid = :arg_s_import.moneyid, mrate = :arg_s_import.mrate, taskdate = :arg_s_import.taskdate, tasktype = :arg_s_import.tasktype, typeid = :arg_s_import.typeid, cuscode = :arg_s_import.cuscode, cusname = :arg_s_import.cusname, level_str = :arg_s_import.level_str, level = :arg_s_import.level, cusid = :arg_s_import.cusid, cus_address = :arg_s_import.cus_address, rel_rep = :arg_s_import.rel_rep, cus_tele = :arg_s_import.cus_tele, cus_fax = :arg_s_import.cus_fax, freight = :arg_s_import.freight, freight_tele = :arg_s_import.freight_tele, Assign_Emp = :arg_s_import.Assign_Emp, upname = :arg_s_import.upname, banktype = :arg_s_import.banktype, banktypeid = :arg_s_import.banktypeid, damt = :arg_s_import.damt, relcode = :arg_s_import.relcode, paytype = :arg_s_import.paytype, otheramt = :arg_s_import.otheramt, dscrp2 = :arg_s_import.dscrp2, dscrp = :arg_s_import.dscrp, dscrp3 = :arg_s_import.dscrp3, outtypestr = :arg_s_import.outtypestr, mtrlcode = :arg_s_import.mtrlcode, mtrlname = :arg_s_import.mtrlname, mtrlid = :arg_s_import.mtrlid, unit = :arg_s_import.unit, saleqty = :arg_s_import.saleqty, pricetype = :arg_s_import.pricetype, enprice = :arg_s_import.enprice, rebate = :arg_s_import.rebate, taxrate = :arg_s_import.taxrate, requiredate = :arg_s_import.requiredate, status = :arg_s_import.status, woodcode = :arg_s_import.woodcode, pcode = :arg_s_import.pcode, mxdscrp = :arg_s_import.mxdscrp, mxdscrp2 = :arg_s_import.mxdscrp2, mtrlcuscode = :arg_s_import.mtrlcuscode, moddate = :arg_s_import.moddate WHERE (im_type = :arg_s_import.im_type) And (im_id = :arg_s_import.im_id); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '更新订单导入表失败,' + sqlca.SQLErrText GOTO ext END IF END IF ext: IF arg_if_commit THEN IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF END IF RETURN rslt end function public function integer uf_del (long arg_im_type, string arg_im_id, ref string arg_msg, boolean arg_if_commit);Int rslt = 1 Long ll_taskcnt String ls_taskcode Long ll_accept_flag SELECT accept_flag,taskcode INTO :ll_accept_flag, :ls_taskcode FROM eb_saletask_import WHERE im_type = :arg_im_type And im_id = :arg_im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询临时订单接受标记失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_accept_flag = 1 THEN SELECT COUNT(0) INTO :ll_taskcnt FROM u_saletask Where taskcode = :ls_taskcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询是否存在旧订单失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_taskcnt > 0 THEN rslt = 0 arg_msg = '已经生成订单['+ls_taskcode+']不能删除,请删除旧订单' GOTO ext END IF END IF DELETE FROM eb_saletask_import WHERE im_type = :arg_im_type And im_id = :arg_im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '删除临时订单失败,' + sqlca.SQLErrText GOTO ext END IF ext: IF arg_if_commit THEN IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF END IF RETURN rslt end function public function integer uf_getinfo (long arg_im_type, string arg_im_id, ref s_saletask_import arg_s_import, ref string arg_msg);Int rslt = 1 s_saletask_import s_empty arg_s_import = s_empty SELECT im_type, im_id, moneyname, moneyid, mrate, taskdate, tasktype, typeid, cuscode, cusname, level_str, level, cusid, cus_address, rel_rep, cus_tele, cus_fax, freight, freight_tele, assign_emp, upname, banktype, banktypeid, damt, relcode, paytype, otheramt, dscrp2, dscrp, dscrp3, outtypestr, mtrlcode, mtrlname, mtrlid, unit, saleqty, pricetype, enprice, rebate, taxrate, requiredate, status, woodcode, pcode, mxdscrp, mxdscrp2, mtrlcuscode, accept_flag, accept_emp, accept_date, tid, im_userid, trade_status, props, trade_no, moddate, acptcnt, shortname, shopname, paydate, outdate, transcode, transcom, confirmdate, createdate, trans_amt INTO :arg_s_import.im_type, :arg_s_import.im_id, :arg_s_import.moneyname, :arg_s_import.moneyid, :arg_s_import.mrate, :arg_s_import.taskdate, :arg_s_import.tasktype, :arg_s_import.typeid, :arg_s_import.cuscode, :arg_s_import.cusname, :arg_s_import.level_str, :arg_s_import.level, :arg_s_import.cusid, :arg_s_import.cus_address, :arg_s_import.rel_rep, :arg_s_import.cus_tele, :arg_s_import.cus_fax, :arg_s_import.freight, :arg_s_import.freight_tele, :arg_s_import.assign_emp, :arg_s_import.upname, :arg_s_import.banktype, :arg_s_import.banktypeid, :arg_s_import.damt, :arg_s_import.relcode, :arg_s_import.paytype, :arg_s_import.otheramt, :arg_s_import.dscrp2, :arg_s_import.dscrp, :arg_s_import.dscrp3, :arg_s_import.outtypestr, :arg_s_import.mtrlcode, :arg_s_import.mtrlname, :arg_s_import.mtrlid, :arg_s_import.unit, :arg_s_import.saleqty, :arg_s_import.pricetype, :arg_s_import.enprice, :arg_s_import.rebate, :arg_s_import.taxrate, :arg_s_import.requiredate, :arg_s_import.status, :arg_s_import.woodcode, :arg_s_import.pcode, :arg_s_import.mxdscrp, :arg_s_import.mxdscrp2, :arg_s_import.mtrlcuscode, :arg_s_import.accept_flag, :arg_s_import.accept_emp, :arg_s_import.accept_date, :arg_s_import.tid, :arg_s_import.im_userid, :arg_s_import.trade_status, :arg_s_import.props, :arg_s_import.trade_no, :arg_s_import.moddate, :arg_s_import.acptcnt, :arg_s_import.shortname, :arg_s_import.shopname, :arg_s_import.paydate, :arg_s_import.outdate, :arg_s_import.transcode, :arg_s_import.transcom, :arg_s_import.confirmdate, :arg_s_import.createdate, :arg_s_import.trans_amt FROM eb_saletask_import WHERE im_type = :arg_im_type And im_id = :arg_im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询临时订单信息失败,' + sqlca.SQLErrText GOTO ext END IF ext: RETURN rslt end function public function integer uf_check (s_saletask_import arg_s_import, ref string arg_msg);int rslt = 1 return rslt end function public function integer uf_taobao_unload (ref string arg_im_ids[], ref string arg_msg);Int rslt = 1 Long i Long ll_cnt Long j = 0 String ls_im_ids[] String ls_im_id DateTime ld_moddate Long ll_pos FOR i = 1 To UpperBound(arg_im_ids) ll_pos = Pos(arg_im_ids[i], ';') IF ll_pos > 0 THEN ls_im_id = Mid(arg_im_ids[i], 1, ll_pos - 1) ld_moddate = DateTime(Date(Mid(arg_im_ids[i], ll_pos + 1, 10)), Time(Mid(arg_im_ids[i], ll_pos + 11))) SELECT COUNT(0) INTO :ll_cnt FROM eb_saletask_import Where im_type = 5 And tid = :ls_im_id And moddate >= :ld_moddate; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询已经下淘宝订单失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_cnt = 0 THEN j++ ls_im_ids[j] = ls_im_id END IF ELSE SELECT COUNT(0) INTO :ll_cnt FROM eb_saletask_import Where im_type = 5 And tid = :arg_im_ids[i]; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询已经下淘宝订单失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_cnt = 0 THEN j++ ls_im_ids[j] = arg_im_ids[i] END IF END IF NEXT arg_im_ids = ls_im_ids ext: RETURN rslt end function public subroutine uf_fill_taobao (ref s_saletask_import arg_s_import);Long ll_dfmoneyid = 0 Long ll_dftypeid = 0 Long ll_dflevel = 4 Long ll_dfcusid = 0 Long ll_dfbanktypeid = 0 Long ll_dfmtrlid = 0 uo_ljlib_taobao_comapp uo_app uo_app = Create uo_ljlib_taobao_comapp String im_userid = '' im_userid = uo_app.uf_getname() Destroy uo_app Long UserID = 0 IF im_userid <> '' THEN SELECT top 1 userid INTO :UserID FROM eb_user Where im_type = 5 And im_userid = :im_userid; IF UserID > 0 THEN SELECT moneyid, typeid, level, banktypeid INTO :ll_dfmoneyid, :ll_dftypeid, :ll_dflevel, :ll_dfbanktypeid FROM eb_user Where UserID = :UserID; END IF END IF SELECT moneyid INTO :arg_s_import.moneyid FROM cw_currency Where Name = :arg_s_import.moneyname; IF sqlca.SQLCode <> 0 THEN arg_s_import.moneyid = ll_dfmoneyid END IF SELECT typeid INTO :arg_s_import.typeid FROM u_saletype Where typename = :arg_s_import.tasktype; IF sqlca.SQLCode <> 0 THEN arg_s_import.typeid = ll_dftypeid END IF IF Pos(arg_s_import.level_str, '最高') > 0 Or Pos(arg_s_import.level_str, '0') > 0 THEN arg_s_import.Level = 0 ELSEIF Pos(arg_s_import.level_str, '较高') > 0 Or Pos(arg_s_import.level_str, '1') > 0 THEN arg_s_import.Level = 1 ELSEIF Pos(arg_s_import.level_str, '普通') > 0 Or Pos(arg_s_import.level_str, '2') > 0 THEN arg_s_import.Level = 2 ELSEIF Pos(arg_s_import.level_str, '较低') > 0 Or Pos(arg_s_import.level_str, '3') > 0 THEN arg_s_import.Level = 3 ELSEIF Pos(arg_s_import.level_str, '最低') > 0 Or Pos(arg_s_import.level_str, '4') > 0 THEN arg_s_import.Level = 4 ELSE arg_s_import.Level = ll_dflevel END IF SELECT cusid INTO :arg_s_import.cusid FROM u_cust Where cuscode = :arg_s_import.cuscode; IF sqlca.SQLCode <> 0 THEN arg_s_import.cusid = ll_dfcusid END IF SELECT banktypeid INTO :arg_s_import.banktypeid FROM cw_banktype Where banktypename = :arg_s_import.banktype; IF sqlca.SQLCode <> 0 THEN arg_s_import.banktypeid = ll_dfbanktypeid END IF //SELECT mtrlid // INTO :arg_s_import.mtrlid // FROM eb_import_mtrlname // WHERE im_type = 5 // And im_id = :arg_s_import.mtrlcode; //IF sqlca.SQLCode <> 0 THEN // arg_s_import.mtrlid = ll_dfmtrlid //END IF uf_fill_mtrl(arg_s_import) end subroutine public subroutine uf_fill (ref s_saletask_import arg_s_import); SELECT moneyid INTO :arg_s_import.moneyid FROM cw_currency Where Name = :arg_s_import.moneyname; IF sqlca.SQLCode <> 0 THEN arg_s_import.moneyid = 0 END IF SELECT typeid INTO :arg_s_import.typeid FROM u_saletype Where typename = :arg_s_import.tasktype; IF sqlca.SQLCode <> 0 THEN arg_s_import.typeid = 0 END IF IF Pos(arg_s_import.level_str, '最高') > 0 Or Pos(arg_s_import.level_str, '0') > 0 THEN arg_s_import.Level = 0 ELSEIF Pos(arg_s_import.level_str, '较高') > 0 Or Pos(arg_s_import.level_str, '1') > 0 THEN arg_s_import.Level = 1 ELSEIF Pos(arg_s_import.level_str, '普通') > 0 Or Pos(arg_s_import.level_str, '2') > 0 THEN arg_s_import.Level = 2 ELSEIF Pos(arg_s_import.level_str, '较低') > 0 Or Pos(arg_s_import.level_str, '3') > 0 THEN arg_s_import.Level = 3 ELSEIF Pos(arg_s_import.level_str, '最低') > 0 Or Pos(arg_s_import.level_str, '4') > 0 THEN arg_s_import.Level = 4 END IF SELECT cusid INTO :arg_s_import.cusid FROM u_cust Where cuscode = :arg_s_import.cuscode; IF sqlca.SQLCode <> 0 THEN arg_s_import.cusid = 0 END IF SELECT banktypeid INTO :arg_s_import.banktypeid FROM cw_banktype Where banktypename = :arg_s_import.banktype; IF sqlca.SQLCode <> 0 THEN arg_s_import.banktypeid = 0 END IF uf_fill_mtrl(arg_s_import) end subroutine public function integer uf_accepts (long arg_scid, long arg_im_type, string arg_ids[], long arg_audit, long arg_priceflag, ref string arg_msg);Int rslt = 1 String ls_msg = '' Long i,j,k Long ll_accept_flag Long ll_taskcnt String ls_taskcode s_saletask_import s_import[], s_empty[] FOR i = 1 To UpperBound(arg_ids) IF uf_getinfo(arg_im_type, arg_ids[i], s_import[i], arg_msg) <> 1 THEN rslt = 0 GOTO ext END IF NEXT s_saletask_import_arr bills[], empty_arr Long cnt = 0 String ls_ids = '' Long ll_taskid // 汇总订单 IF arg_im_type = 5 THEN // 淘宝 FOR i = 1 To UpperBound(s_import) FOR j = 1 To UpperBound(bills) IF bills[j].mx[1].tid = s_import[i].tid THEN // 根据订单号汇总 EXIT END IF NEXT IF j > UpperBound(bills) THEN cnt++ bills[cnt] = empty_arr bills[cnt].arg_ifpricelist = (arg_priceflag = 1) bills[cnt].mx[1] = s_import[i] ELSE k = UpperBound(bills[j].mx) + 1 bills[j].mx[k] = s_import[i] END IF NEXT ELSE FOR i = 1 To UpperBound(s_import) FOR j = 1 To UpperBound(bills) IF bills[j].mx[1].cusid = s_import[i].cusid & And bills[j].mx[1].relcode = s_import[i].relcode & And bills[j].mx[1].cus_address = s_import[i].cus_address & And bills[j].mx[1].rel_rep = s_import[i].rel_rep & And bills[j].mx[1].cus_tele = s_import[i].cus_tele THEN // 根据客户汇总 EXIT END IF NEXT IF j > UpperBound(bills) THEN cnt++ bills[cnt] = empty_arr bills[cnt].arg_ifpricelist = (arg_priceflag = 1) bills[cnt].mx[1] = s_import[i] ELSE k = UpperBound(bills[j].mx) + 1 bills[j].mx[k] = s_import[i] END IF NEXT END IF Long ll_ok // 生成订单 FOR i = 1 To UpperBound(bills) ll_ok = 1 // 检查 ls_ids = '' FOR j = 1 To UpperBound(bills[i].mx) IF j = 1 THEN ls_ids = bills[i].mx[j].im_id ELSE ls_ids += ',' + bills[i].mx[j].im_id END IF SELECT accept_flag, taskcode INTO :ll_accept_flag, :ls_taskcode FROM eb_saletask_import WHERE (im_type = :arg_im_type) And (im_id = :bills[i].mx[j].im_id); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '查询临时订单接受信息失败,' + sqlca.SQLErrText ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF IF ll_accept_flag = 1 THEN SELECT COUNT(0) INTO :ll_taskcnt FROM u_saletask Where taskcode = :ls_taskcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '查询是否存在旧订单失败,' + sqlca.SQLErrText ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF IF ll_taskcnt > 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '已经生成订单['+ls_taskcode+']不能再接受,请删除旧订单' ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF END IF UPDATE eb_saletask_import SET accept_flag = 1, accept_emp = :publ_operator, accept_date = GETDATE(), acptcnt = acptcnt + 1 WHERE im_type = :arg_im_type And im_id = :bills[i].mx[j].im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '更新接受标记失败,' + sqlca.SQLErrText ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF IF sqlca.SQLNRows = 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '临时订单已经被删除,请刷新后再试~r~n' ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF NEXT ls_taskcode = '' IF uo_saletask_spi.uf_save_saletask(arg_scid, bills[i], Ref ll_taskid, Ref ls_taskcode, Ref arg_msg, False) <> 1 THEN rslt = 0 ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF FOR j = 1 To UpperBound(bills[i].mx) UPDATE eb_saletask_import SET taskcode = :ls_taskcode WHERE im_type = :arg_im_type And im_id = :bills[i].mx[j].im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = bills[i].mx[j].im_id + '更新订单号失败,' + sqlca.SQLErrText ll_ok = 0 ls_msg += arg_msg + '~r~n' GOTO _next END IF NEXT // arrcnt++ // arr_scid[arrcnt] = arg_scid // arr_taskid[arrcnt] = ll_taskid // arr_taskcode[arrcnt] = ls_taskcode ls_msg += ls_ids + '成功生成订单['+ls_taskcode+']' COMMIT; IF arg_audit = 1 THEN IF uo_saletask_spi.uf_audit_saletask(arg_scid, ll_taskid, Ref arg_msg, False) <> 1 THEN rslt = 0 ll_ok = 0 ls_msg += ',但审核失败,' + arg_msg + '~r~n' GOTO _next END IF ls_msg += ',并审核成功' END IF ls_msg += '~r~n' _next: IF ll_ok = 1 THEN COMMIT; ELSE ROLLBACK; END IF NEXT //IF arg_audit = 1 THEN // FOR i = 1 To UpperBound(arr_scid) // ll_ok = 1 // // IF uo_saletask_spi.uf_audit_saletask(arr_scid[i], arr_taskid[i], Ref arg_msg, False) <> 1 THEN // rslt = 0 // ll_ok = 0 // ls_msg += arr_taskcode[i] + '审核失败,' + arg_msg + '~r~n' // GOTO _nexta // END IF // // _nexta: // IF ll_ok = 1 THEN // COMMIT; // ELSE // ROLLBACK; // END IF // // NEXT //END IF ext: arg_msg = ls_msg IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF RETURN rslt end function public function integer uf_retrieve_newprice (long arg_im_type, string arg_im_id, ref decimal arg_newprice, ref decimal arg_rebate, ref string arg_msg, boolean arg_ifcommit);Int rslt = 1 Long ll_cnt Long ll_accept_flag String ls_taskcode Long ll_taskcnt Decimal ls_1stnewprice = 0 Decimal ls_1stzqrate = 0 s_saletask_import arg_s_import SELECT accept_flag, taskcode, moneyid, cusid, mtrlid, status, woodcode, pcode, typeid, mrate, unit INTO :ll_accept_flag, :ls_taskcode, :arg_s_import.moneyid, :arg_s_import.cusid, :arg_s_import.mtrlid, :arg_s_import.status, :arg_s_import.woodcode, :arg_s_import.pcode, :arg_s_import.typeid, :arg_s_import.mrate, :arg_s_import.unit FROM eb_saletask_import WHERE (im_type = :arg_im_type) And (im_id = :arg_im_id); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询临时订单接受信息失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_accept_flag = 1 THEN SELECT COUNT(0) INTO :ll_taskcnt FROM u_saletask Where taskcode = :ls_taskcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询是否存在旧订单失败,' + sqlca.SQLErrText GOTO ext END IF IF ll_taskcnt > 0 THEN rslt = 0 arg_msg = '已经生成订单['+ls_taskcode+']不能修改,请删除旧订单' GOTO ext END IF END IF IF arg_s_import.mrate = 0 THEN rslt = 0 arg_msg = '汇率为0' GOTO ext END IF IF uo_saletask_spi.uof_getprice_saletask(arg_s_import,ls_1stnewprice,ls_1stzqrate,arg_msg) <= 0 THEN rslt = 0 GOTO ext END IF UPDATE eb_saletask_import SET new_price = :ls_1stnewprice, new_rebate = :ls_1stzqrate WHERE (im_type = :arg_im_type) And (im_id = :arg_im_id); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '更新临时订单最新价与折扣失败,' + sqlca.SQLErrText GOTO ext END IF arg_newprice = ls_1stnewprice arg_rebate = ls_1stzqrate ext: IF arg_ifcommit THEN IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF END IF RETURN rslt end function public subroutine uf_fill_mtrl (ref s_saletask_import arg_s_import);// 查询物料ID，并填写配置 Int rslt = 1 String arg_msg String ls_mtrlcode String ls_dscrpmx2 ls_mtrlcode = arg_s_import.mtrlcode ls_dscrpmx2 = arg_s_import.props String props Long mx_flag, mtrlid = 0 String status_name, woodcode_name, pcode_name Long status_flag, woodcode_flag, pcode_flag String ls_status = '', ls_woodcode = '', ls_pcode = '' String ls_pros uo_keyvaluecollection lo_keys lo_keys = Create uo_keyvaluecollection uo_keyvaluecollection lo_pros lo_pros = Create uo_keyvaluecollection uo_strhelper uo_str uo_str = Create uo_strhelper SELECT props, mx_flag INTO :props, :mx_flag FROM eb_import_mtrlname WHERE im_type = :arg_s_import.im_type And im_id = :ls_mtrlcode; IF sqlca.SQLCode <> 0 THEN SELECT mtrlid INTO :mtrlid FROM u_mtrldef Where mtrlcode = :ls_mtrlcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 GOTO ext END IF rslt = 1 GOTO ext END IF String ls_keyvalues[], ls_keyvalue[] Long i uo_str.split(ls_dscrpmx2, ";", ls_keyvalues) FOR i = 1 To UpperBound(ls_keyvalues) uo_str.split(ls_keyvalues[i], ":", ls_keyvalue) IF ls_keyvalue[1] <> '' And UpperBound(ls_keyvalue) > 1 THEN IF Not lo_keys.uf_haskey(ls_keyvalue[1]) THEN lo_keys.uf_add(ls_keyvalue[1], ls_keyvalue[2]) END IF END IF NEXT uo_str.split(props, ";", ls_keyvalues) FOR i = 1 To UpperBound(ls_keyvalues) uo_str.split(ls_keyvalues[i], ":", ls_keyvalue) IF ls_keyvalue[1] <> '' And UpperBound(ls_keyvalue) > 1 THEN IF Not lo_keys.uf_haskey(ls_keyvalue[1]) THEN lo_keys.uf_add(ls_keyvalue[1], ls_keyvalue[2]) END IF END IF NEXT IF mx_flag = 0 THEN SELECT mtrlid, status_name, woodcode_name, pcode_name INTO :mtrlid, :status_name, :woodcode_name, :pcode_name FROM eb_import_mtrlname WHERE im_type = :arg_s_import.im_type And im_id = :ls_mtrlcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询配置映射属性失败,' + sqlca.SQLErrText GOTO ext END IF SELECT statusflag, woodcodeflag, pcodeflag INTO :status_flag, :woodcode_flag, :pcode_flag FROM u_mtrldef Where mtrlid = :mtrlid; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询物料配置选项失败,' + sqlca.SQLErrText GOTO ext END IF IF status_flag <> 3 And status_name <> '' THEN ls_status = lo_keys.uf_getvalue(status_name) IF IsNull(ls_status) THEN ls_status = '' END IF IF woodcode_flag <> 3 And woodcode_name <> '' THEN ls_woodcode = lo_keys.uf_getvalue(woodcode_name) IF IsNull(ls_woodcode) THEN ls_woodcode = '' END IF IF pcode_flag <> 3 And pcode_name <> '' THEN ls_pcode = lo_keys.uf_getvalue(pcode_name) IF IsNull(ls_pcode) THEN ls_pcode = '' END IF ELSE DECLARE cur1 CURSOR FOR SELECT pros FROM eb_import_mtrlnamemx WHERE im_type = :arg_s_import.im_type And im_id = :ls_mtrlcode; OPEN cur1; FETCH cur1 Into :ls_pros; DO WHILE sqlca.SQLCode = 0 uo_str.split(ls_pros, ";", ls_keyvalues) FOR i = 1 To UpperBound(ls_keyvalues) uo_str.split(ls_keyvalues[i], ":", ls_keyvalue) IF ls_keyvalue[1] <> '' And UpperBound(ls_keyvalue) > 1 THEN IF Not lo_pros.uf_haskey(ls_keyvalue[1]) THEN lo_pros.uf_add(ls_keyvalue[1], ls_keyvalue[2]) END IF END IF NEXT IF lo_keys.uf_include(lo_pros) THEN GOTO _close lo_pros.uf_clear() ls_pros = '' FETCH cur1 Into :ls_pros; LOOP _close: CLOSE cur1; IF IsNull(ls_pros) THEN rslt = 0 GOTO ext END IF IF ls_pros = '' THEN rslt = 0 GOTO ext END IF SELECT mtrlid, status_name, woodcode_name, pcode_name INTO :mtrlid, :status_name, :woodcode_name, :pcode_name FROM eb_import_mtrlnamemx WHERE im_type = :arg_s_import.im_type AND im_id = :ls_mtrlcode And pros = :ls_pros; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询配置映射属性失败,' + sqlca.SQLErrText GOTO ext END IF SELECT statusflag, woodcodeflag, pcodeflag INTO :status_flag, :woodcode_flag, :pcode_flag FROM u_mtrldef Where mtrlid = :mtrlid; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询物料配置选项失败,' + sqlca.SQLErrText GOTO ext END IF IF status_flag <> 3 And status_name <> '' THEN ls_status = lo_keys.uf_getvalue(status_name) IF IsNull(ls_status) THEN ls_status = '' END IF IF woodcode_flag <> 3 And woodcode_name <> '' THEN ls_woodcode = lo_keys.uf_getvalue(woodcode_name) IF IsNull(ls_woodcode) THEN ls_woodcode = '' END IF IF pcode_flag <> 3 And pcode_name <> '' THEN ls_pcode = lo_keys.uf_getvalue(pcode_name) IF IsNull(ls_pcode) THEN ls_pcode = '' END IF END IF ext: Destroy lo_keys Destroy lo_pros Destroy uo_str IF rslt = 1 THEN arg_s_import.mtrlid = mtrlid arg_s_import.status = ls_status arg_s_import.woodcode = ls_woodcode arg_s_import.pcode = ls_pcode ELSE arg_s_import.mtrlid = 0 arg_s_import.status = '' arg_s_import.woodcode = '' arg_s_import.pcode = '' END IF end subroutine public function integer uf_csv_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg);Int rslt = 1 String ls_dscrp IF Not FileExists(arg_filepath) THEN rslt = 0 arg_msg = '文件' + arg_filepath + '不存在' GOTO ext END IF Long ll_pos, ll_pos2 ll_pos = Pos(arg_filepath, '\') IF ll_pos > 0 THEN ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) DO WHILE ll_pos2 > 0 ll_pos = ll_pos2 ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) LOOP ls_dscrp = Mid(arg_filepath, ll_pos + 1) ELSE ls_dscrp = arg_filepath END IF datastore ds_col100 /////////////建立映射//////////////////// // ds_col100 = Create datastore ds_col100.DataObject = 'dw_col100' ds_col100.ImportFile(CSV!, arg_filepath) datastore arg_dw arg_dw = Create datastore arg_dw.DataObject = 'dw_saletask_import_xls_taobao' Long ll_s_col_count = 100 Long ll_d_col_count ll_d_col_count = Long(arg_dw.Object.datawindow.Column.Count) Long ll_map[] // 目标表与原表的映射，0为没有映射 String ls_colType[] // 目标表列类型 Long col_d, col_s FOR col_d = 1 To ll_d_col_count String ls_col_title, ls_col_name ls_col_name = arg_dw.Describe('#' + String(col_d) + '.Name') ls_colType[col_d] = arg_dw.Describe('#' + String(col_d) + '.ColType') ls_col_title = arg_dw.Describe(ls_col_name + '_t.Text') ll_map[col_d] = 0 FOR col_s = 1 To ll_s_col_count String ls_s_title ls_s_title = ds_col100.GetItemString(1, col_s) IF Lower(Trim(ls_col_title)) = Lower(Trim(ls_s_title)) THEN ll_map[col_d] = col_s EXIT END IF NEXT NEXT Long row_s, row_d String ls_lastmtrlcode = '' FOR row_s = 2 To ds_col100.RowCount( ) IF Trim(ds_col100.GetItemString(row_s, 1),True) <> Trim(ds_col100.GetItemString(row_s - 1, 1),True) Or Trim(ds_col100.GetItemString(row_s, 2),True) <> Trim(ds_col100.GetItemString(row_s - 1, 2),True) THEN row_d = arg_dw.InsertRow(0) ELSE ls_lastmtrlcode = Trim(ds_col100.GetItemString(row_s - 1, 3),True) IF ls_lastmtrlcode <> '-' THEN IF arg_dw.RowsCopy(row_d, row_d, Primary!, arg_dw, row_d + 1, Primary!) = 1 THEN row_d++ arg_dw.Object.trans_amt[row_d] = 0 END IF END IF END IF FOR col_d = 1 To ll_d_col_count IF ll_map[col_d] = 0 THEN CONTINUE Any Value String ls_value ls_value = Trim(ds_col100.GetItemString(row_s, ll_map[col_d]),True) IF ls_value = '' Or ls_value = '-' THEN CONTINUE IF Lower(Left(ls_colType[col_d], 4)) = 'char' THEN Value = ls_value ELSEIF Lower(Left(ls_colType[col_d], 4)) = 'long' Or Lower(Left(ls_colType[col_d], 3)) = 'int' Or Lower(Left(ls_colType[col_d], 3)) = 'num' Or Lower(Left(ls_colType[col_d], 5)) = 'ulong' THEN Value = Long(ls_value) ELSEIF Lower(Left(ls_colType[col_d], 4)) = 'deci' Or Lower(Left(ls_colType[col_d], 4)) = 'real' THEN Value = Dec(ls_value) ELSEIF Lower(Left(ls_colType[col_d], 4)) = 'date' THEN Value = DateTime(Date(Left(ls_value, 10)), Time(Mid(ls_value, 12))) END IF arg_dw.SetItem(row_d, col_d, Value) NEXT NEXT Destroy ds_col100 Long i s_saletask_import s_empty String ls_lastid = '' Long ll_cnt = 0 FOR i = 1 To arg_dw.RowCount() arg_import[i] = s_empty arg_import[i].im_type = 0 arg_import[i].moneyname = arg_dw.Object.moneyname[i] arg_import[i].mrate = arg_dw.Object.mrate[i] arg_import[i].taskdate = arg_dw.Object.taskdate[i] arg_import[i].tasktype = arg_dw.Object.tasktype[i] arg_import[i].cuscode = arg_dw.Object.cuscode[i] arg_import[i].cusname = arg_dw.Object.cusname[i] arg_import[i].level_str = arg_dw.Object.level_str[i] arg_import[i].cus_address = arg_dw.Object.cus_address[i] arg_import[i].rel_rep = arg_dw.Object.rel_rep[i] arg_import[i].cus_tele = arg_dw.Object.cus_tele[i] arg_import[i].cus_fax = arg_dw.Object.cus_fax[i] arg_import[i].freight = arg_dw.Object.freight[i] arg_import[i].freight_tele = arg_dw.Object.freight_tele[i] arg_import[i].assign_emp = arg_dw.Object.assign_emp[i] arg_import[i].upname = arg_dw.Object.upname[i] arg_import[i].banktype = arg_dw.Object.banktype[i] arg_import[i].damt = arg_dw.Object.damt[i] arg_import[i].relcode = arg_dw.Object.relcode[i] arg_import[i].paytype = arg_dw.Object.paytype[i] arg_import[i].otheramt = arg_dw.Object.otheramt[i] arg_import[i].dscrp2 = arg_dw.Object.dscrp2[i] arg_import[i].dscrp = ls_dscrp arg_import[i].dscrp3 = arg_dw.Object.dscrp3[i] arg_import[i].outtypestr = arg_dw.Object.outtypestr[i] arg_import[i].mtrlcode = arg_dw.Object.mtrlcode[i] arg_import[i].mtrlname = arg_dw.Object.mtrlname[i] arg_import[i].unit = arg_dw.Object.unit[i] arg_import[i].saleqty = arg_dw.Object.saleqty[i] arg_import[i].pricetype = arg_dw.Object.pricetype[i] IF arg_dw.Object.trans_amt[i] > 0 THEN arg_import[i].enprice = (arg_dw.Object.enprice[i] * arg_dw.Object.saleqty[i] + arg_dw.Object.trans_amt[i]) / arg_dw.Object.saleqty[i] ELSE arg_import[i].enprice = arg_dw.Object.enprice[i] END IF arg_import[i].rebate = arg_dw.Object.rebate[i] arg_import[i].taxrate = arg_dw.Object.taxrate[i] arg_import[i].requiredate = arg_dw.Object.requiredate[i] arg_import[i].status = arg_dw.Object.status[i] arg_import[i].woodcode = arg_dw.Object.woodcode[i] arg_import[i].pcode = arg_dw.Object.pcode[i] arg_import[i].mxdscrp = arg_dw.Object.mxdscrp[i] arg_import[i].mxdscrp2 = arg_dw.Object.mxdscrp2[i] arg_import[i].mtrlcuscode = arg_dw.Object.mtrlcuscode[i] arg_import[i].im_id = arg_dw.Object.im_id[i] arg_import[i].trade_status = arg_dw.Object.trade_status[i] arg_import[i].tid = arg_dw.Object.tid[i] arg_import[i].props = arg_dw.Object.props[i] arg_import[i].trade_no = arg_dw.Object.trade_no[i] IF arg_import[i].rebate = 0 THEN arg_import[i].rebate = 1 IF arg_import[i].mrate = 0 THEN arg_import[i].mrate = 1 IF IsNull(arg_import[i].relcode) Or arg_import[i].relcode = '' THEN IF IsNull(arg_import[i].im_id) Or arg_import[i].im_id = '' THEN arg_import[i].relcode = arg_import[i].tid ELSE arg_import[i].relcode = arg_import[i].im_id END IF END IF IF arg_import[i].im_id = ls_lastid THEN ll_cnt ++ ELSE ll_cnt = 0 END IF IF ll_cnt > 0 THEN arg_import[i].im_id = arg_import[i].im_id + '-' + String(ll_cnt) END IF ls_lastid = arg_dw.Object.im_id[i] uf_fill(arg_import[i]) NEXT Destroy arg_dw ext: RETURN rslt end function public function integer uf_xml_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg);Int rslt = 1 pbdom_builder builder pbdom_document doc pbdom_element root SetNull(builder) SetNull(doc) SetNull(root) IF Not FileExists(arg_filepath) THEN rslt = 0 arg_msg = '文件' + arg_filepath + '不存在' GOTO ext END IF builder = Create pbdom_builder doc = builder.buildfromfile(arg_filepath) root = doc.getrootelement() pbdom_element cur s_saletask_import ls_task cur = root.getchildelement('币种') IF Not IsNull(cur) THEN ls_task.moneyname = cur.GetTextTrim() END IF cur = root.getchildelement('汇率') IF Not IsNull(cur) THEN ls_task.mrate = Dec(cur.GetTextTrim()) END IF cur = root.getchildelement('订单日期') IF Not IsNull(cur) THEN ls_task.taskdate = DateTime(Date(cur.gettexttrim())) END IF cur = root.getchildelement('交货日期') IF Not IsNull(cur) THEN ls_task.requiredate = DateTime(Date(cur.gettexttrim())) END IF cur = root.getchildelement('分类') IF Not IsNull(cur) THEN ls_task.tasktype = cur.gettexttrim() END IF cur = root.getchildelement('客户编号') IF Not IsNull(cur) THEN ls_task.cuscode = cur.gettexttrim() END IF cur = root.getchildelement('客户名称') IF Not IsNull(cur) THEN ls_task.cusname = cur.gettexttrim() END IF cur = root.getchildelement('优先级') IF Not IsNull(cur) THEN ls_task.level_str = cur.gettexttrim() END IF cur = root.getchildelement('客户地址') IF Not IsNull(cur) THEN ls_task.cus_address = cur.gettexttrim() END IF cur = root.getchildelement('联系人') IF Not IsNull(cur) THEN ls_task.rel_rep = cur.gettexttrim() END IF cur = root.getchildelement('客户电话') IF Not IsNull(cur) THEN ls_task.cus_tele = cur.gettexttrim() END IF cur = root.getchildelement('货运部') IF Not IsNull(cur) THEN ls_task.freight = cur.gettexttrim() END IF cur = root.getchildelement('电话') IF Not IsNull(cur) THEN ls_task.freight_tele = cur.gettexttrim() END IF cur = root.getchildelement('业务员') IF Not IsNull(cur) THEN ls_task.assign_emp = cur.gettexttrim() END IF cur = root.getchildelement('结算方式') IF Not IsNull(cur) THEN ls_task.banktype = cur.gettexttrim() END IF cur = root.getchildelement('订金') IF Not IsNull(cur) THEN ls_task.damt = Dec(cur.gettexttrim()) END IF cur = root.getchildelement('相关号码') IF Not IsNull(cur) THEN ls_task.relcode = cur.gettexttrim() END IF cur = root.getchildelement('交货方式') IF Not IsNull(cur) THEN ls_task.paytype = cur.gettexttrim() END IF cur = root.getchildelement('优惠金额') IF Not IsNull(cur) THEN ls_task.otheramt = Dec(cur.gettexttrim()) END IF cur = root.getchildelement('生产备注') IF Not IsNull(cur) THEN ls_task.dscrp2 = cur.gettexttrim() END IF cur = root.getchildelement('备注') IF Not IsNull(cur) THEN ls_task.dscrp = cur.gettexttrim() END IF Long ll_num = 1 Long i = 0 i = upperbound(arg_import) pbdom_element curmx cur = root.getchildelement('产品' + String(ll_num)) DO WHILE Not IsNull(cur) i++ arg_import[i] = ls_task arg_import[i].im_type = 0 curmx = cur.getchildelement('产品编号') IF Not IsNull(curmx) THEN arg_import[i].mtrlcode = curmx.gettexttrim() END IF curmx = cur.getchildelement('产品名称') IF Not IsNull(curmx) THEN arg_import[i].mtrlname = curmx.gettexttrim() END IF curmx = cur.getchildelement('配置') IF Not IsNull(curmx) THEN arg_import[i].status = curmx.gettexttrim() END IF curmx = cur.getchildelement('配置1') IF Not IsNull(curmx) THEN arg_import[i].woodcode = curmx.gettexttrim() END IF curmx = cur.getchildelement('配置2') IF Not IsNull(curmx) THEN arg_import[i].pcode = curmx.gettexttrim() END IF curmx = cur.getchildelement('单位') IF Not IsNull(curmx) THEN arg_import[i].unit = curmx.gettexttrim() END IF curmx = cur.getchildelement('数量') IF Not IsNull(curmx) THEN arg_import[i].saleqty = Dec(curmx.gettexttrim()) END IF curmx = cur.getchildelement('单价') IF Not IsNull(curmx) THEN arg_import[i].enprice = Dec(curmx.gettexttrim()) END IF curmx = cur.getchildelement('折扣') IF Not IsNull(curmx) THEN arg_import[i].rebate = Dec(curmx.gettexttrim()) END IF curmx = cur.getchildelement('交货日期') IF Not IsNull(curmx) THEN arg_import[i].requiredate = DateTime(Date(curmx.gettexttrim())) END IF curmx = cur.getchildelement('明细备注') IF Not IsNull(curmx) THEN arg_import[i].mxdscrp = curmx.gettexttrim() END IF uf_fill(arg_import[i]) ll_num++ cur = root.getchildelement('产品' + String(ll_num)) LOOP ext: IF Not IsNull(doc) THEN Destroy doc END IF IF Not IsNull(builder) THEN Destroy builder END IF RETURN rslt end function public function integer uf_xls_to_import_sny (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg);Int rslt = 1 datastore arg_dw arg_dw = Create datastore arg_dw.DataObject = 'dw_saletask_import_xls_taobao1' IF f_xls_import_to_dw(arg_filepath, arg_dw, arg_msg) <> 1 THEN rslt = 0 GOTO ext END IF String ls_dscrp Long ll_pos, ll_pos2 ll_pos = Pos(arg_filepath, '\') IF ll_pos > 0 THEN ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) DO WHILE ll_pos2 > 0 ll_pos = ll_pos2 ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) LOOP ls_dscrp = Mid(arg_filepath, ll_pos + 1) ELSE ls_dscrp = arg_filepath END IF Long i string ls_lastid = '' long ll_cnt = 0 s_saletask_import s_empty FOR i = 1 To arg_dw.RowCount() arg_import[i] = s_empty arg_import[i].im_type = 0 arg_import[i].moneyname = arg_dw.Object.moneyname[i] arg_import[i].mrate = arg_dw.Object.mrate[i] arg_import[i].taskdate = arg_dw.Object.taskdate[i] arg_import[i].tasktype = arg_dw.Object.tasktype[i] arg_import[i].cuscode = arg_dw.Object.cuscode[i] arg_import[i].cusname = arg_dw.Object.cusname[i] arg_import[i].level_str = arg_dw.Object.level_str[i] arg_import[i].cus_address = arg_dw.Object.cus_address[i] arg_import[i].rel_rep = arg_dw.Object.rel_rep[i] arg_import[i].cus_tele = arg_dw.Object.cus_tele[i] arg_import[i].cus_fax = arg_dw.Object.cus_fax[i] arg_import[i].freight = arg_dw.Object.freight[i] arg_import[i].freight_tele = arg_dw.Object.freight_tele[i] arg_import[i].assign_emp = arg_dw.Object.assign_emp[i] arg_import[i].upname = arg_dw.Object.upname[i] arg_import[i].banktype = arg_dw.Object.banktype[i] arg_import[i].damt = arg_dw.Object.damt[i] arg_import[i].relcode = arg_dw.Object.relcode[i] arg_import[i].paytype = arg_dw.Object.paytype[i] arg_import[i].otheramt = arg_dw.Object.otheramt[i] arg_import[i].dscrp2 = arg_dw.Object.dscrp2[i] arg_import[i].dscrp = ls_dscrp arg_import[i].dscrp3 = arg_dw.Object.dscrp3[i] arg_import[i].outtypestr = arg_dw.Object.outtypestr[i] arg_import[i].mtrlcode = arg_dw.Object.mtrlcode[i] arg_import[i].mtrlname = arg_dw.Object.mtrlname[i] arg_import[i].unit = arg_dw.Object.unit[i] arg_import[i].saleqty = arg_dw.Object.saleqty[i] arg_import[i].pricetype = arg_dw.Object.pricetype[i] IF arg_dw.Object.trans_amt[i] > 0 THEN arg_import[i].enprice = (arg_dw.Object.enprice[i] * arg_dw.Object.saleqty[i] + arg_dw.Object.trans_amt[i]) / arg_dw.Object.saleqty[i] ELSE arg_import[i].enprice = arg_dw.Object.enprice[i] END IF arg_import[i].rebate = arg_dw.Object.rebate[i] arg_import[i].taxrate = arg_dw.Object.taxrate[i] arg_import[i].requiredate = arg_dw.Object.requiredate[i] arg_import[i].status = arg_dw.Object.status[i] arg_import[i].woodcode = arg_dw.Object.woodcode[i] arg_import[i].pcode = arg_dw.Object.pcode[i] arg_import[i].mxdscrp = arg_dw.Object.mxdscrp[i] arg_import[i].mxdscrp2 = arg_dw.Object.mxdscrp2[i] arg_import[i].mtrlcuscode = arg_dw.Object.mtrlcuscode[i] arg_import[i].im_id = arg_dw.Object.im_id[i] arg_import[i].trade_status = arg_dw.Object.trade_status[i] arg_import[i].tid = arg_dw.Object.tid[i] arg_import[i].props = arg_dw.Object.props[i] arg_import[i].trade_no = arg_dw.Object.trade_no[i] arg_import[i].trans_amt = arg_dw.Object.trans_amt[i] arg_import[i].shortname = arg_dw.Object.shortname[i] arg_import[i].shopname = arg_dw.Object.shopname[i] arg_import[i].paydate = arg_dw.Object.paydate[i] arg_import[i].outdate = arg_dw.Object.outdate[i] arg_import[i].transcode = arg_dw.Object.transcode[i] arg_import[i].transcom = arg_dw.Object.transcom[i] arg_import[i].confirmdate = arg_dw.Object.confirmdate[i] arg_import[i].createdate = arg_dw.Object.createdate[i] IF arg_import[i].rebate = 0 THEN arg_import[i].rebate = 1 IF arg_import[i].mrate = 0 THEN arg_import[i].mrate = 1 IF IsNull(arg_import[i].relcode) Or arg_import[i].relcode = '' THEN IF IsNull(arg_import[i].im_id) Or arg_import[i].im_id = '' THEN arg_import[i].relcode = arg_import[i].tid ELSE arg_import[i].relcode = arg_import[i].im_id END IF END IF IF arg_import[i].im_id = ls_lastid THEN ll_cnt ++ ELSE ll_cnt = 0 END IF IF ll_cnt > 0 THEN arg_import[i].im_id = arg_import[i].im_id + '-' + String(ll_cnt) END IF ls_lastid = arg_dw.Object.im_id[i] uf_fill(arg_import[i]) NEXT ext: Destroy arg_dw RETURN rslt end function public function integer uf_xls_to_import (string arg_filepath, ref s_saletask_import arg_import[], ref string arg_msg);Int rslt = 1 datastore arg_dw arg_dw = Create datastore arg_dw.DataObject = 'dw_saletask_import_xls' IF f_xls_import_to_dw(arg_filepath, arg_dw, arg_msg) <> 1 THEN rslt = 0 GOTO ext END IF String ls_dscrp Long ll_pos, ll_pos2 ll_pos = Pos(arg_filepath, '\') IF ll_pos > 0 THEN ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) DO WHILE ll_pos2 > 0 ll_pos = ll_pos2 ll_pos2 = Pos(arg_filepath, '\', ll_pos + 1) LOOP ls_dscrp = Mid(arg_filepath, ll_pos + 1) ELSE ls_dscrp = arg_filepath END IF Long i s_saletask_import s_empty FOR i = 1 To arg_dw.RowCount() arg_import[i] = s_empty arg_import[i].im_type = 0 arg_import[i].moneyname = arg_dw.Object.moneyname[i] arg_import[i].mrate = arg_dw.Object.mrate[i] arg_import[i].taskdate = arg_dw.Object.taskdate[i] arg_import[i].tasktype = arg_dw.Object.tasktype[i] arg_import[i].cuscode = arg_dw.Object.cuscode[i] arg_import[i].cusname = arg_dw.Object.cusname[i] arg_import[i].level_str = arg_dw.Object.level_str[i] arg_import[i].cus_address = arg_dw.Object.cus_address[i] arg_import[i].rel_rep = arg_dw.Object.rel_rep[i] arg_import[i].cus_tele = arg_dw.Object.cus_tele[i] arg_import[i].cus_fax = arg_dw.Object.cus_fax[i] arg_import[i].freight = arg_dw.Object.freight[i] arg_import[i].freight_tele = arg_dw.Object.freight_tele[i] arg_import[i].assign_emp = arg_dw.Object.assign_emp[i] arg_import[i].upname = arg_dw.Object.upname[i] arg_import[i].banktype = arg_dw.Object.banktype[i] arg_import[i].damt = arg_dw.Object.damt[i] arg_import[i].relcode = arg_dw.Object.relcode[i] arg_import[i].paytype = arg_dw.Object.paytype[i] arg_import[i].otheramt = arg_dw.Object.otheramt[i] arg_import[i].dscrp2 = arg_dw.Object.dscrp2[i] arg_import[i].dscrp = ls_dscrp arg_import[i].dscrp3 = arg_dw.Object.dscrp3[i] arg_import[i].outtypestr = arg_dw.Object.outtypestr[i] arg_import[i].mtrlcode = arg_dw.Object.mtrlcode[i] arg_import[i].mtrlname = arg_dw.Object.mtrlname[i] arg_import[i].unit = arg_dw.Object.unit[i] arg_import[i].saleqty = arg_dw.Object.saleqty[i] arg_import[i].pricetype = arg_dw.Object.pricetype[i] arg_import[i].enprice = arg_dw.Object.enprice[i] arg_import[i].rebate = arg_dw.Object.rebate[i] arg_import[i].taxrate = arg_dw.Object.taxrate[i] arg_import[i].requiredate = arg_dw.Object.requiredate[i] arg_import[i].status = arg_dw.Object.status[i] arg_import[i].woodcode = arg_dw.Object.woodcode[i] arg_import[i].pcode = arg_dw.Object.pcode[i] arg_import[i].mxdscrp = arg_dw.Object.mxdscrp[i] arg_import[i].mxdscrp2 = arg_dw.Object.mxdscrp2[i] arg_import[i].mtrlcuscode = arg_dw.Object.mtrlcuscode[i] uf_fill(arg_import[i]) NEXT ext: Destroy arg_dw RETURN rslt end function public function integer uof_add_saletask (long arg_im_type[], string arg_im_id[], long arg_scid, long arg_taskid, ref string arg_msg, boolean arg_ifcommit);Int li_status Int rslt = 1 //uo_cusprice uo_price //uo_price = create uo_cusprice // //If uo_option_price_rmb = -1000 Then // arg_msg = '选项:[238]销售单价按人民币单价折算,读取初始默认值失败,操作取消!' // rslt = 0 // Goto ext //End If // // //If uo_option_m_msttake = -1000 Then // arg_msg = '选项:[045]系统使用多币种应收帐,读取初始默认值失败,操作取消!' // rslt = 0 // Goto ext //End If // //decimal ls_1stnewprice,ls_1stzqrate //Decimal ld_saleqty, ld_rebate,ld_enprice,ld_taxrate //Long ll_mtrlid //String ls_mxdscrp, ls_mxdscrp2, ls_status, ls_woodcode, ls_pcode, ls_mtrlcuscode , ls_outtypestr,ls_pricetype //DateTime ldt_requiredate //Decimal mrate,ld_fprice,ld_enacprice,ld_acprice //Long ll_printid //Long ll_i,ll_statusflag //Decimal ld_msttakeamt,ld_new_price,ld_plprice,ld_net_weight_f,ld_gross_weight_f,ld_cubage_f //Decimal ld_capacity,ld_capacity_zj //String ls_pfcode,ls_status_zj,ls_taskcode //Long ll_j //long ll_moneyid,ll_cusid,ll_typeid //s_mtrlcfg_expr s_pz[] // //Select status,mrate,taskcode,moneyid,cusid,typeid // Into :li_status,:mrate,:ls_taskcode,:ll_moneyid,:ll_cusid,:ll_typeid // From u_saletask // Where scid = :arg_scid // And taskid = :arg_taskid; //If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '查询订单状态失败,'+sqlca.SQLErrText // Goto ext //End If // //If li_status <> 0 Then // rslt = 0 // arg_msg = '订单只能在待审核状态下才能增加明细' // Goto ext //End If // //Select max(printid) Into :ll_printid // From u_saletaskmx // Where scid = :arg_scid // And taskid = :arg_taskid; //If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '查询订单明细最大序号失败,'+sqlca.SQLErrText // Goto ext //End If // //For ll_i = 1 To UpperBound(arg_im_id) // Select saleqty, // mtrlid, // mxdscrp, // mxdscrp2, // rebate, // status, // woodcode, // pcode, // mtrlcuscode, // enprice, // outtypestr, // requiredate, // pricetype, // taxrate, // new_price // Into :ld_saleqty, // :ll_mtrlid, // :ls_mxdscrp, // :ls_mxdscrp2, // :ld_rebate, // :ls_status, // :ls_woodcode, // :ls_pcode, // :ls_mtrlcuscode, // :ld_enprice, // :ls_outtypestr, // :ldt_requiredate, // :ls_pricetype, // :ld_taxrate, // :ld_new_price // From eb_saletask_import // Where im_type = :arg_im_type[ll_i] // And im_id = :arg_im_id[ll_i]; // If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '查询外部订单信息失败,imtype:'+String(arg_im_type[ll_i])+',im_id:'+String(arg_im_id[ll_i])+'~r~n'+sqlca.SQLErrText // Goto ext // End If // // IF uo_price.uof_getprice_saletask(ll_moneyid,ll_cusid,ll_mtrlid,ls_status,ls_woodcode,ls_pcode,0,0,0,0,ll_typeid,ls_1stnewprice,ls_1stzqrate,arg_msg) <> 0 THEN // ld_enprice = ls_1stnewprice // ld_rebate = ls_1stzqrate // end if // // If uo_option_price_rmb = 0 Then // ld_fprice = ld_enprice * mrate // // If mrate = 0 Then // ld_enacprice = ld_fprice * ld_rebate // Else // ld_enacprice = ld_fprice * ld_rebate / mrate // End If // // ld_acprice = ld_fprice * ld_rebate // // Else // ld_fprice = Round(ld_enprice * mrate,2) // // If mrate = 0 Then // ld_enacprice = Round(ld_fprice * ld_rebate,2) // Else // ld_enacprice = Round(ld_fprice * ld_rebate / mrate,2) // End If // // ld_acprice = Round(ld_fprice * ld_rebate,2) // // End If // // If uo_option_m_msttake = 1 Then //使用多币种 // ld_msttakeamt = ld_msttakeamt + Round(ld_enprice * ld_saleqty * ld_rebate,2) // Else // 系统不使用多币种,转换为人民币 // ld_msttakeamt = ld_msttakeamt + Round(ld_enprice * mrate * ld_saleqty * ld_rebate,2) // End If // // ll_printid++ // // f_get_planprice_mtrl(ll_mtrlid,ls_status,ls_woodcode,ls_pcode,ld_plprice) // ls_pfcode = f_get_dft_pf(ll_mtrlid) // // f_get_mtrl_weight(ll_mtrlid,ls_status,ld_net_weight_f,ld_gross_weight_f,ld_cubage_f) // // Select statusflag,capacity // Into :ll_statusflag,:ld_capacity // From u_mtrldef // Where mtrlid = :ll_mtrlid; // If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '查询产品信息失败,mtrlid:'+String(ll_mtrlid) +'~r~n' +sqlca.SQLErrText // Goto ext // End If // // If ll_statusflag = 2 And ls_status <> '' 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 * capaparm // 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 // // Insert Into u_saletaskmx // ( scid, // saleqty, // price, // plprice, // mtrlid, // taskid, // mxdscrp, // mxdscrp2, // fprice, // rebate, // status, // printid, // woodcode, // pcode, // mtrlcuscode, // enprice, // outtypestr, // dftsaleprice, // requiredate, // pfcode, // pricetype, // capacity, // nprice, // taxrate, // enacprice, // net_weight, // gross_weight, // cubage) // Values (:arg_scid, // :ld_saleqty, // :ld_acprice, // :ld_plprice, // :ll_mtrlid, // :arg_taskid, // :ls_mxdscrp, // :ls_mxdscrp2, // :ld_fprice, // :ld_rebate, // :ls_status, // :ll_printid, // :ls_woodcode, // :ls_pcode, // :ls_mtrlcuscode, // :ld_enprice, // :ls_outtypestr, // :ld_enprice, // :ldt_requiredate, // :ls_pfcode, // :ls_pricetype, // :ld_capacity, // :ld_new_price, // :ld_taxrate, // :ld_enacprice, // :ld_net_weight_f, // :ld_gross_weight_f, // :ld_cubage_f) ; // If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '增加订单明细失败,'+sqlca.SQLErrText // Goto ext // End If // // //更新外部订单已接收信息 // Update eb_saletask_import // Set accept_flag = 1, // accept_emp = :publ_operator, // accept_date = GETDATE(), // acptcnt = acptcnt + 1, // taskcode = :ls_taskcode // Where im_type = :arg_im_type[ll_i] // And im_id = :arg_im_id[ll_i]; // If sqlca.SQLCode <> 0 Then // rslt = 0 // arg_msg = '更新外部订单已接收状态失败,'+sqlca.SQLErrText // Goto ext // End If // //Next // ////更新订单应收金额,修改人,修改时间 //Update u_saletask // Set msttakeamt = msttakeamt + :ld_msttakeamt, // modemp = :publ_operator, // moddate = getdate() // Where scid = :arg_scid // And taskid = :arg_taskid; //If sqlca.SQLCode <> 0 Then // 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 // //destroy uo_price Return rslt end function public function integer uf_accept_taobao (string arg_tid, ref string arg_msg, ref string arg_taskcode);Int rslt = 1 s_saletask_import_arr curbill s_saletask_import mx Long i = 0 DECLARE cur1 CURSOR FOR SELECT eb_saletask_import.dscrp, eb_saletask_import.dscrp2, eb_saletask_import.taskdate, eb_saletask_import.damt, eb_saletask_import.otheramt, eb_saletask_import.relcode, eb_saletask_import.freight, eb_saletask_import.freight_tele, eb_saletask_import.cus_address, eb_saletask_import.cus_tele, eb_saletask_import.cus_fax, eb_saletask_import.rel_rep, eb_saletask_import.dscrp3, eb_saletask_import.im_id, eb_saletask_import.mtrlid, eb_saletask_import.saleqty, tb_order.payment / tb_order.num AS enprice, eb_saletask_import.rebate, eb_saletask_import.mxdscrp, eb_saletask_import.mxdscrp2, eb_saletask_import.status, eb_saletask_import.woodcode, eb_saletask_import.pcode, eb_saletask_import.mtrlcuscode, eb_saletask_import.outtypestr, eb_saletask_import.pricetype, eb_saletask_import.taxrate, eb_saletask_import.accept_flag, eb_saletask_import.taskcode FROM eb_saletask_import INNER JOIN tb_order ON eb_saletask_import.im_id = tb_order.oid WHERE (eb_saletask_import.im_type = 5) AND (eb_saletask_import.tid = :arg_tid) AND (eb_saletask_import.trade_status = 'WAIT_SELLER_SEND_GOODS') Order By eb_saletask_import.im_id; OPEN cur1; FETCH cur1 INTO :mx.dscrp,:mx.dscrp2,:mx.taskdate,:mx.damt,:mx.otheramt,:mx.relcode, :mx.freight,:mx.freight_tele,:mx.cus_address,:mx.cus_tele,:mx.cus_fax, :mx.rel_rep,:mx.dscrp3,:mx.im_id,:mx.mtrlid,:mx.saleqty,:mx.enprice,:mx.rebate,:mx.mxdscrp, :mx.mxdscrp2,:mx.status,:mx.woodcode,:mx.pcode,:mx.mtrlcuscode,:mx.outtypestr, :mx.pricetype,:mx.taxrate,:mx.accept_flag,:mx.taskcode; DO WHILE sqlca.SQLCode = 0 i++ curbill.mx[i] = mx FETCH cur1 INTO :mx.dscrp,:mx.dscrp2,:mx.taskdate,:mx.damt,:mx.otheramt,:mx.relcode, :mx.freight,:mx.freight_tele,:mx.cus_address,:mx.cus_tele,:mx.cus_fax, :mx.rel_rep,:mx.dscrp3,:mx.im_id,:mx.mtrlid,:mx.saleqty,:mx.enprice,:mx.rebate,:mx.mxdscrp, :mx.mxdscrp2,:mx.status,:mx.woodcode,:mx.pcode,:mx.mtrlcuscode,:mx.outtypestr, :mx.pricetype,:mx.taxrate,:mx.accept_flag,:mx.taskcode; LOOP CLOSE cur1; IF i = 0 THEN rslt = 0 arg_msg = '淘宝订单['+arg_tid+']不存在' GOTO ext END IF Long cnt = 0 FOR i = 1 To UpperBound(curbill.mx) mx = curbill.mx[i] if mx.cus_address = '' then rslt = 0 arg_msg = '淘宝订单['+arg_tid+']收货地址不能为空' goto ext end if IF mx.accept_flag = 1 THEN cnt = 0 SELECT COUNT(0) INTO :cnt FROM u_saletask Where taskcode = :mx.taskcode; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询ERP订单['+mx.taskcode+']是否存在失败,' + sqlca.SQLErrText GOTO ext END IF IF cnt > 0 THEN rslt = 0 arg_msg = '已生成ERP订单['+mx.taskcode+'],不能重复生成' GOTO ext END IF END IF SELECT mtrlcode INTO :curbill.mx[i].mtrlcode FROM u_mtrldef Where mtrlid = :mx.mtrlid; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询ERP物料编码失败,' + sqlca.SQLErrText GOTO ext END IF UPDATE eb_saletask_import SET accept_flag = 1, accept_emp = :publ_operator, accept_date = GETDATE(), acptcnt = acptcnt + 1 WHERE im_type = 5 AND im_id = :mx.im_id And stopflag = 0 AND directsend = 0; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = mx.im_id + '更新接受标记失败,' + sqlca.SQLErrText GOTO ext END IF IF sqlca.SQLNRows = 0 THEN rslt = 0 arg_msg = mx.im_id + '临时订单已经被删除或中止,请刷新后再试~r~n' GOTO ext END IF NEXT Decimal ld_mx_sum SELECT SUM(tb_order.payment) INTO :ld_mx_sum FROM eb_saletask_import INNER JOIN tb_order ON eb_saletask_import.im_id = tb_order.oid WHERE (eb_saletask_import.im_type = 5) AND (eb_saletask_import.tid = :arg_tid); IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询订单商品总金额失败,' + sqlca.SQLErrText GOTO ext END IF decimal ld_payment, ld_post_fee SELECT payment, post_fee into :ld_payment, :ld_post_fee FROM tb_trade WHERE (tid = :arg_tid); if sqlca.sqlcode <> 0 then rslt = 0 arg_msg = '查询淘宝订单实付金额与邮费失败,' + sqlca.sqlerrtext goto ext end if curbill.mx[1].otheramt = ld_mx_sum + ld_post_fee - ld_payment curbill.mx[1].post_fee = ld_post_fee IF uo_saletask_spi.uf_fill_taobao_saletask_info(curbill.mx[1], Ref arg_msg) <> 1 THEN rslt = 0 GOTO ext END IF FOR i = 2 To UpperBound(curbill.mx) curbill.mx[i].requiredate = curbill.mx[1].requiredate NEXT Long ll_taskid = 0 String ls_taskcode = '' IF uo_saletask_spi.uf_save_saletask(curbill.mx[1].scid, curbill, Ref ll_taskid, Ref ls_taskcode, Ref arg_msg, False) <> 1 THEN rslt = 0 GOTO ext END IF FOR i = 1 To UpperBound(curbill.mx) UPDATE eb_saletask_import SET taskcode = :ls_taskcode WHERE im_type = 5 And im_id = :curbill.mx[i].im_id; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = curbill.mx[i].im_id + '更新订单号失败,' + sqlca.SQLErrText GOTO ext END IF NEXT arg_taskcode = ls_taskcode ext: IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF RETURN rslt end function public function integer uf_save_saletask_jiayu (string arg_filename, ref string arg_msg);// 直接将嘉韵 灵通打单格式 导入销售订单 // 1. 将csv文件转成DW Int rslt = 1 datastore dw_1 dw_1 = Create datastore // 2. 逐行处理，物料编码不为空，订单号为空的是与上一单同一订单的 uo_saletask obj_saletask obj_saletask = Create uo_saletask obj_saletask.commit_transaction = sqlca dw_1.DataObject = 'dw_col100' dw_1.ImportFile(CSV!, arg_filename) if isvalid(ins_dw_test1) then ins_dw_test1.DataObject = dw_1.DataObject ins_dw_test1.Reset() dw_1.RowsCopy(1, dw_1.RowCount(), primary!, ins_dw_test1, 1, primary!) end if Long i, j String ls_tid = '' String ls_mtrlcode = '' s_saletask_import s_mx s_saletask_import arr_billmx[] Long cnt = 0 Decimal mxtotalamt String ls_assign_emp, ls_paytype Long ll_typeid, ll_cusid, ll_banktypeid, ll_moneyid Decimal ld_mrate SELECT top 1 assign_emp, paytype, typeid, cusid, banktypeid, moneyid, mrate INTO :ls_assign_emp, :ls_paytype, :ll_typeid, :ll_cusid, :ll_banktypeid, :ll_moneyid, :ld_mrate FROM eb_user Where im_type = 5; IF sqlca.SQLCode <> 0 THEN rslt = 0 arg_msg = '查询淘宝默认设置失败,' + sqlca.SQLErrText GOTO ext END IF FOR i = 2 To dw_1.RowCount() ls_mtrlcode = Trim(dw_1.GetItemString(i, 16), true) IF ls_mtrlcode = '' THEN EXIT END IF s_mx.tid = Trim(dw_1.GetItemString(i, 1), true) s_mx.trade_status = Trim(dw_1.GetItemString(i, 2), true) s_mx.cuscode = Trim(dw_1.GetItemString(i, 3), true) s_mx.transcom = Trim(dw_1.GetItemString(i, 5), true) s_mx.transcode = Trim(dw_1.GetItemString(i, 6), true) s_mx.rel_rep = Trim(dw_1.GetItemString(i, 7), true) s_mx.cus_fax = Trim(dw_1.GetItemString(i, 8), true) s_mx.cus_tele = Trim(dw_1.GetItemString(i, 9), true) s_mx.cus_address = Trim(dw_1.GetItemString(i, 10), true) + Trim(dw_1.GetItemString(i, 11), true) + Trim(dw_1.GetItemString(i, 12), true) + Trim(dw_1.GetItemString(i, 13), true) s_mx.mtrlname = Trim(dw_1.GetItemString(i, 15), true) s_mx.mtrlcode = Trim(dw_1.GetItemString(i, 16), true) s_mx.props = Trim(dw_1.GetItemString(i, 17), true) s_mx.saleqty = Dec(Trim(dw_1.GetItemString(i, 18), true)) s_mx.enprice = Dec(Trim(dw_1.GetItemString(i, 19), true)) s_mx.totalamt = Dec(Trim(dw_1.GetItemString(i, 21), true)) + Dec(Trim(dw_1.GetItemString(i, 22), true)) s_mx.mxdscrp = Trim(dw_1.GetItemString(i, 25), true) s_mx.mxdscrp2 = Trim(dw_1.GetItemString(i, 26), true) s_mx.dscrp = Trim(dw_1.GetItemString(i, 25), true) s_mx.dscrp2 = Trim(dw_1.GetItemString(i, 26), true) s_mx.rebate = 1 IF s_mx.tid <> '' THEN // 当前行是新一张单的开始 // 保存上一张单 IF cnt > 0 THEN mxtotalamt = 0 FOR j = 1 To cnt arr_billmx[j].rebate = 0 arr_billmx[j].status = '' arr_billmx[j].woodcode = '' arr_billmx[j].pcode = '' arr_billmx[j].mtrlcuscode = '' arr_billmx[j].taxrate = 0 SELECT mtrlid INTO :arr_billmx[j].mtrlid FROM u_mtrldef Where mtrlcode = :arr_billmx[j].mtrlcode; if sqlca.sqlcode <> 0 then rslt = 0 arg_msg = arr_billmx[1].tid + '查询物料编码失败,'+arr_billmx[j].mtrlcode+',' + arg_msg GOTO ext end if mxtotalamt += arr_billmx[j].saleqty * arr_billmx[j].enprice NEXT arr_billmx[1].otheramt = mxtotalamt - s_mx.totalamt IF obj_saletask.newbegin(0,arg_msg) = 0 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '新建订单失败,' + arg_msg GOTO ext END IF obj_saletask.requiredate = DateTime(Today(),Now()) obj_saletask.assign_emp = ls_assign_emp //obj_saletask.upname = arg_bill.mx[1].upname obj_saletask.Kind = ll_typeid obj_saletask.cusid = ll_cusid obj_saletask.dscrp = arr_billmx[1].dscrp obj_saletask.dscrp2 = arr_billmx[1].dscrp2 obj_saletask.taskdate = DateTime(Today(),Now()) obj_saletask.banktypeid = ll_banktypeid obj_saletask.moneyid = ll_moneyid obj_saletask.damt = 0 obj_saletask.otheramt = arr_billmx[1].otheramt obj_saletask.relcode = arr_billmx[1].tid obj_saletask.paytype = ls_paytype obj_saletask.freight = arr_billmx[1].transcom obj_saletask.freight_tele = '' obj_saletask.cus_address = arr_billmx[1].cus_address obj_saletask.cus_tele = arr_billmx[1].cus_tele obj_saletask.cus_fax = arr_billmx[1].cus_fax obj_saletask.mrate = ld_mrate //obj_saletask.typeid = arg_bill.mx[1].typeid obj_saletask.rel_rep = arr_billmx[1].rel_rep //obj_saletask.Level = arg_bill.mx[1].Level obj_saletask.dscrp3 = '' FOR j = 1 To cnt IF obj_saletask.acceptmx(arr_billmx[j].mtrlid,& arr_billmx[j].saleqty,& 0 /*orderqty*/ ,& 0 /*buyqty*/ ,& arr_billmx[j].enprice,& 1 /*rebate*/ ,& 0 /*planprice*/ ,& arr_billmx[j].mxdscrp,& arr_billmx[j].mtrlcode,& arr_billmx[j].status,& arr_billmx[j].woodcode,& arr_billmx[j].pcode,& arr_billmx[j].mtrlcuscode,& j,& 0 /*outtype*/ ,& arg_msg,& '' /*unit*/ ,& arr_billmx[j].taxrate /*rate*/ ,& '' /*formula*/ ,& 0 /*addqty*/ ,& arr_billmx[j].mxdscrp2,& 0 /*needwfjgqty*/,& '' /*plancode*/,& 0 /*tax*/) = 0 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '添加订单明细失败,' + arg_msg GOTO ext END IF NEXT // s_saletask_itemmx s_item //费用项目 // IF arg_bill.mx[1].post_fee <> 0 THEN // s_item.printid = 1 // s_item.itemid = arg_bill.mx[1].itemid // s_item.amt = arg_bill.mx[1].post_fee // s_item.amtyfh = 0 // s_item.mxdscrp = '' // s_item.itype = 1 // IF obj_saletask.acceptmx_item(s_item, arg_msg) = 0 THEN // rslt = 0 // arg_msg = arr_billmx[1].tid + '添加订单费用明细失败,' + arg_msg // GOTO ext // END IF // END IF IF obj_saletask.savesubmit(publ_operator,arg_msg,False) <> 1 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '保存订单失败,' + arg_msg GOTO ext END IF IF obj_saletask.save_end(arg_msg,False) = 0 THEN //保存费用项目 rslt = 0 arg_msg = arr_billmx[1].tid + '保存订单费用明细失败,' + arg_msg GOTO ext END IF END IF cnt = 0 END IF cnt ++ arr_billmx[cnt] = s_mx NEXT IF cnt > 0 THEN mxtotalamt = 0 FOR j = 1 To cnt arr_billmx[j].rebate = 0 arr_billmx[j].status = '' arr_billmx[j].woodcode = '' arr_billmx[j].pcode = '' arr_billmx[j].mtrlcuscode = '' arr_billmx[j].taxrate = 0 SELECT mtrlid INTO :arr_billmx[j].mtrlid FROM u_mtrldef Where mtrlcode = :arr_billmx[j].mtrlcode; mxtotalamt += arr_billmx[j].saleqty * arr_billmx[j].enprice NEXT arr_billmx[1].otheramt = mxtotalamt - s_mx.totalamt IF obj_saletask.newbegin(0,arg_msg) = 0 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '新建订单失败,' + arg_msg GOTO ext END IF obj_saletask.requiredate = DateTime(Today(),Now()) obj_saletask.assign_emp = ls_assign_emp //obj_saletask.upname = arg_bill.mx[1].upname obj_saletask.Kind = ll_typeid obj_saletask.cusid = ll_cusid obj_saletask.dscrp = arr_billmx[1].dscrp obj_saletask.dscrp2 = arr_billmx[1].dscrp2 obj_saletask.taskdate = DateTime(Today(),Now()) obj_saletask.banktypeid = ll_banktypeid obj_saletask.moneyid = ll_moneyid obj_saletask.damt = 0 obj_saletask.otheramt = arr_billmx[1].otheramt obj_saletask.relcode = arr_billmx[1].tid obj_saletask.paytype = ls_paytype obj_saletask.freight = arr_billmx[1].transcom obj_saletask.freight_tele = '' obj_saletask.cus_address = arr_billmx[1].cus_address obj_saletask.cus_tele = arr_billmx[1].cus_tele obj_saletask.cus_fax = arr_billmx[1].cus_fax obj_saletask.mrate = ld_mrate //obj_saletask.typeid = arg_bill.mx[1].typeid obj_saletask.rel_rep = arr_billmx[1].rel_rep //obj_saletask.Level = arg_bill.mx[1].Level obj_saletask.dscrp3 = '' FOR j = 1 To cnt IF obj_saletask.acceptmx(arr_billmx[j].mtrlid,& arr_billmx[j].saleqty,& 0 /*orderqty*/ ,& 0 /*buyqty*/ ,& arr_billmx[j].enprice,& 1 /*rebate*/ ,& 0 /*planprice*/ ,& arr_billmx[j].mxdscrp,& arr_billmx[j].mtrlcode,& arr_billmx[j].status,& arr_billmx[j].woodcode,& arr_billmx[j].pcode,& arr_billmx[j].mtrlcuscode,& j,& 0 /*outtype*/ ,& arg_msg,& '' /*unit*/ ,& arr_billmx[j].taxrate /*rate*/ ,& '' /*formula*/ ,& 0 /*addqty*/ ,& arr_billmx[j].mxdscrp2,& 0 /*needwfjgqty*/,& '' /*plancode*/,& 0 /*tax*/) = 0 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '添加订单明细失败,' + arg_msg GOTO ext END IF NEXT // s_saletask_itemmx s_item //费用项目 // IF arg_bill.mx[1].post_fee <> 0 THEN // s_item.printid = 1 // s_item.itemid = arg_bill.mx[1].itemid // s_item.amt = arg_bill.mx[1].post_fee // s_item.amtyfh = 0 // s_item.mxdscrp = '' // s_item.itype = 1 // IF obj_saletask.acceptmx_item(s_item, arg_msg) = 0 THEN // rslt = 0 // arg_msg = arr_billmx[1].tid + '添加订单费用明细失败,' + arg_msg // GOTO ext // END IF // END IF IF obj_saletask.savesubmit(publ_operator,arg_msg,False) <> 1 THEN rslt = 0 arg_msg = arr_billmx[1].tid + '保存订单失败,' + arg_msg GOTO ext END IF IF obj_saletask.save_end(arg_msg,False) = 0 THEN //保存费用项目 rslt = 0 arg_msg = arr_billmx[1].tid + '保存订单费用明细失败,' + arg_msg GOTO ext END IF END IF // 3.保存订单 ext: Destroy dw_1 Destroy obj_saletask IF rslt = 1 THEN COMMIT; ELSE ROLLBACK; END IF RETURN rslt end function on uo_saletask_import.create call super::create TriggerEvent( this, "constructor" ) end on on uo_saletask_import.destroy TriggerEvent( this, "destructor" ) call super::destroy end on event constructor;//String arg_msg //String str_optionvalue // //str_optionvalue = '' //f_get_sys_option_value('238',str_optionvalue,arg_msg) //uo_option_price_rmb = Long(str_optionvalue) // //str_optionvalue = '' //f_get_sys_option_value('045',str_optionvalue,arg_msg) //uo_option_m_msttake = Long(str_optionvalue) end event