From 63a4cdef68c885872a22e1242b8afb41185ece9f Mon Sep 17 00:00:00 2001 From: lihao Date: Thu, 8 May 2025 14:42:12 +0800 Subject: [PATCH] =?UTF-8?q?erp=E5=90=8C=E6=AD=A5=E9=94=80=E5=94=AE?= =?UTF-8?q?=E5=8F=91=E7=A5=A8=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nc/bs/uapbd/task/InvoiceTaskPlugin.java | 56 +++++++++---------- 1 file changed, 28 insertions(+), 28 deletions(-) diff --git a/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java b/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java index 96e1c5b..f85e406 100644 --- a/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java +++ b/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java @@ -20,7 +20,7 @@ public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ @Override public PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException { // TODO Auto-generated method stub - Logger.error("---start----任务开始运行--"); + Logger.error("---start----ʼ--"); try { BaseDAO dao = new BaseDAO(); String sql = " SELECT sscivm_invoice.pk_invoice,so_saleinvoice.csaleinvoiceid,so_saleinvoice.vbillcode billcode, sscivm_invoice.fphm, " + @@ -39,53 +39,53 @@ public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ Logger.error("---alData------"+al); if(al.size() > 0) { for(HashMap sscivm_invoice : al) { - Object pk_invoice = sscivm_invoice.get("pk_invoice"); //bip发票主键 - Object csaleinvoiceid = sscivm_invoice.get("csaleinvoiceid"); //销售发票id - Object billcode = sscivm_invoice.get("billcode"); //销售发票编码 - Object billno = sscivm_invoice.get("billno"); //bip单据编码编码 + Object pk_invoice = sscivm_invoice.get("pk_invoice"); //bipƱ 0001A1100000004Y7DWZ + Object csaleinvoiceid = sscivm_invoice.get("csaleinvoiceid"); //۷Ʊid + Object billcode = sscivm_invoice.get("billcode"); //۷Ʊ + Object billno = sscivm_invoice.get("billno"); //bipݱ Object fphm = sscivm_invoice.get("fphm"); Object Gmfmc = sscivm_invoice.get("Gmfmc"); Object Jshj = sscivm_invoice.get("Jshj"); Object viewurl = sscivm_invoice.get("viewurl"); String ctcode=""; - HYSuperDMO dmo = new HYSuperDMO(); - IVApplogVO[] ivApplogVO=(IVApplogVO[]) dmo.queryByWhereClause(IVApplogVO.class, "fphm='"+fphm+"' and dr=0 "); - Logger.error("---ivApplogVO------"+ivApplogVO); - if(ivApplogVO!=null&&ivApplogVO.length>0) { - ivApplogVO[0].getLyid();//开票申请单主键 - IVApplicationHeadVO ivApplicationHeadVO =(IVApplicationHeadVO) dmo.queryByPrimaryKey(IVApplicationHeadVO.class, ivApplogVO[0].getLyid()); - ctcode=ivApplicationHeadVO.getDef2();//合同号 - } - Object url = ctcode+"_"+Gmfmc+"_"+fphm+"_"+Jshj + ".pdf"; +// HYSuperDMO dmo = new HYSuperDMO(); +// IVApplogVO[] ivApplogVO=(IVApplogVO[]) dmo.queryByWhereClause(IVApplogVO.class, "fphm='"+fphm+"' and dr=0 "); +// Logger.error("---ivApplogVO------"+ivApplogVO); +// if(ivApplogVO!=null&&ivApplogVO.length>0) { +// ivApplogVO[0].getLyid();//Ʊ뵥 +// IVApplicationHeadVO ivApplicationHeadVO =(IVApplicationHeadVO) dmo.queryByPrimaryKey(IVApplicationHeadVO.class, ivApplogVO[0].getLyid()); +// ctcode=ivApplicationHeadVO.getDef2();//ͬ +// } +// Object url = ctcode+"_"+Gmfmc+"_"+fphm+"_"+Jshj + ".pdf"; /** - * 回写逻辑： - * 1.修改发票关联关系单据编码 - * 2.ERP销售发票回传，根据销售发票id，回写发票号和单据编号 - * 3.根据销售发票id 回写下游应收单表头表体发票号 - * 4.查询销售发票下游单据，如果有将下游单据表体字段【来源单据号】更新成新的发票号 + * д߼ + * 1.޸ķƱϵݱ + * 2.ERP۷Ʊش۷ƱidдƱź͵ݱ + * 3.۷Ʊid дӦյͷ巢Ʊ + * 4.ѯ۷ƱεݣнεݱֶΡԴݺš³µķƱ */ - //手动开启事务 + //ֶ TransactionFactory.getTMProxy().begin(3,0); - //修改发票信息单据号 + //޸ķƱϢݺ String sscivmSql = "UPDATE sscivm_invoice set billno = '" + fphm +"' where pk_invoice = '"+ pk_invoice +"'"; dao.executeUpdate(sscivmSql); Logger.error("---sscivmSqlExecute------"+sscivmSql); - //修改发票关联关系单据编码 + //޸ķƱϵݱ String sirSql = "UPDATE sscivm_invoice_relation set billno = '" + fphm +"' where pk_invoice = '"+ pk_invoice +"' and billid = '"+ csaleinvoiceid +"'"; dao.executeUpdate(sirSql); Logger.error("---sirSqlExecute------"+sirSql); - //ERP销售发票回传，根据销售发票id，回写发票号和单据编号 + //ERP۷Ʊش۷ƱidдƱź͵ݱ String sSaleSql = "UPDATE so_saleinvoice set vdef20 = 'Y' , vdef13 = '" + fphm + "', vbillcode = '" + fphm +"' where csaleinvoiceid = '" + csaleinvoiceid + "'"; dao.executeUpdate(sSaleSql); Logger.error("---sSaleSqlExecute------"+sSaleSql); - //根据销售发票id 回写下游应收单表头发票号 + //۷Ʊid дӦյͷƱ String recBillSql = "MERGE INTO ar_recbill a USING (select DISTINCT pk_recbill,top_billid,top_billtype from ar_recitem) b ON ( a.pk_recbill = b.pk_recbill AND b.top_billid = '" + csaleinvoiceid + "' AND b.top_billtype = '32' ) \n" + "WHEN MATCHED THEN\n" + "UPDATE \n" + "SET a.invoiceno = '" + fphm + "'"; dao.executeUpdate(recBillSql); Logger.error("---recBillSqlExecute------"+recBillSql); - //根据销售发票id 回写下游应收单表体发票号 + //۷Ʊid дӦյ巢Ʊ String recItemSql = "UPDATE ar_recitem \n" + "SET invoiceno = '" + fphm + "' \n" + "WHERE\n" + @@ -93,7 +93,7 @@ public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ "AND top_billtype = '32'"; dao.executeUpdate(recItemSql); Logger.error("---recItemSqlExecute------"+recItemSql); - //查询销售发票下游单据，如果有将下游单据表体字段【来源单据号】更新成新的发票号 + //ѯ۷ƱεݣнεݱֶΡԴݺš³µķƱ String saleOutSql = "UPDATE ic_saleout_b \n" + "SET vsourcebillcode = '"+ fphm +"' \n" + "WHERE\n" + @@ -101,7 +101,7 @@ public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ "AND csourcebillhid = '" + csaleinvoiceid +"'"; dao.executeUpdate(saleOutSql); Logger.error("---saleOutSqlExecute------"+saleOutSql); - //正常结束 + // TransactionFactory.getTMProxy().end(null); } @@ -109,7 +109,7 @@ public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ } } catch(Exception e) { e.printStackTrace(); - //异常回滚 + //쳣ع TransactionFactory.getTMProxy().end(e); Logger.error("writeBack Error: ",e); }