From 1b42f2bf4d1118c535938651ed0da8b7b1cfa79f Mon Sep 17 00:00:00 2001 From: zhangbb Date: Mon, 15 Jun 2020 17:24:19 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E7=94=9F=E6=88=90=E6=97=A5=E5=BF=97=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/quartzmession/AtTheEndOfContractPush.java | 7 +++++++ .../app/quartzmession/AutoFiveGradeClass.java | 14 +++++++++++++- .../lease/app/quartzmession/CalcPenaltyJob.java | 8 ++++++++ .../lease/app/quartzmession/ContractLoanPush.java | 7 +++++++ .../app/quartzmession/DeleteWechatRentPay.java | 9 ++++++++- .../DistributorMarginCompensation.java | 3 +++ .../quartzmession/DynamicPoolDetailRunBatch.java | 9 +++++++++ .../quartzmession/DynamicPoolTotalRunBatch.java | 9 +++++++++ .../tenwa/lease/app/quartzmession/FileToPush.java | 8 +++++++- .../app/quartzmession/ProductManagementReport.java | 7 +++++++ .../app/quartzmession/PushApprovalOpinions.java | 7 +++++++ .../app/quartzmession/SelectActualPaymentDate.java | 7 +++++++ .../tenwa/lease/app/quartzmession/SplitInts3.java | 7 +++++++ .../app/quartzmession/StaticDataRunBatch.java | 9 +++++++++ .../app/quartzmession/SurplusMoneyMakeSureIn.java | 10 ++++++++++ .../tenwa/lease/app/quartzmession/TaskPool.java | 7 +++++++ .../lease/app/quartzmession/WechatMessagePush.java | 9 +++++++++ 17 files changed, 134 insertions(+), 3 deletions(-) diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/AtTheEndOfContractPush.java b/src_tenwa/com/tenwa/lease/app/quartzmession/AtTheEndOfContractPush.java index a7a5f09d9..847b964dc 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/AtTheEndOfContractPush.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/AtTheEndOfContractPush.java @@ -4,6 +4,8 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; import com.tenwa.gps.HttpClientSUtil; import com.tenwa.httpclient.resources.InterfacePlatformConfigure; @@ -11,10 +13,15 @@ public class AtTheEndOfContractPush implements Job { @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("AtTheEndOfContractPush"),null,null); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.AtTheEndOfContractPush", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.AtTheEndOfContractPush", "error", "失败", curUserId); } } } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/AutoFiveGradeClass.java b/src_tenwa/com/tenwa/lease/app/quartzmession/AutoFiveGradeClass.java index 93ce9fe71..fddb3610c 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/AutoFiveGradeClass.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/AutoFiveGradeClass.java @@ -1,18 +1,30 @@ package com.tenwa.lease.app.quartzmession; +import org.quartz.JobExecutionContext; + +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; + public class AutoFiveGradeClass { - public String execute(){ + public String execute(JobExecutionContext arg0){ AutoFiveGradeClassification autoFive = new AutoFiveGradeClassification(); + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { + String result= autoFive.autoFiveGradeClassification(); if(result=="success"){ + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.AutoFiveGradeClass", "success", "成功", curUserId); return "success"; }else{ + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.AutoFiveGradeClass", "error", "失败", curUserId); return "error"; } } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.AutoFiveGradeClass", "error", "失败", curUserId); return "error"; } } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/CalcPenaltyJob.java b/src_tenwa/com/tenwa/lease/app/quartzmession/CalcPenaltyJob.java index 97f5069d4..7e0578a9d 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/CalcPenaltyJob.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/CalcPenaltyJob.java @@ -4,7 +4,10 @@ import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; import com.amarsoft.are.sql.Connection; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; + import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; @@ -23,6 +26,9 @@ public class CalcPenaltyJob implements Job { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { JBOTransaction tx; Transaction tran = null; + String startime = StringFunction.getTodayNow(); + Object userId = jobExecutionContext.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { tx = JBOFactory.createJBOTransaction(); tran = Transaction.createTransaction(tx); @@ -37,8 +43,10 @@ public class CalcPenaltyJob implements Job { callableStatement.close(); tran.commit(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CalcPenaltyJob", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CalcPenaltyJob", "error", "失败", curUserId); try { if (tran != null) { tran.rollback(); diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/ContractLoanPush.java b/src_tenwa/com/tenwa/lease/app/quartzmession/ContractLoanPush.java index c33e90a29..981e8671d 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/ContractLoanPush.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/ContractLoanPush.java @@ -4,6 +4,8 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; import com.tenwa.gps.HttpClientSUtil; import com.tenwa.httpclient.resources.InterfacePlatformConfigure; @@ -11,10 +13,15 @@ public class ContractLoanPush implements Job { @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("ContractLoanPush"),null,null); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.ContractLoanPush", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.ContractLoanPush", "error", "失败", curUserId); } } } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/DeleteWechatRentPay.java b/src_tenwa/com/tenwa/lease/app/quartzmession/DeleteWechatRentPay.java index e44d1ede0..c6bf2a591 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/DeleteWechatRentPay.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/DeleteWechatRentPay.java @@ -4,10 +4,13 @@ package com.tenwa.lease.app.quartzmession; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.SqlObject; import com.amarsoft.awe.util.Transaction; import com.amarsoft.dict.als.cache.CacheLoaderFactory; +import com.base.util.QuartzUtil; /** @@ -18,14 +21,18 @@ public class DeleteWechatRentPay implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { Transaction Sqlca=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); String deleteSql = "DELETE FROM LC_OCCUPY_RENT_LIST WHERE inputtime <= DATE_ADD(NOW(),INTERVAL -30 MINUTE) AND (flow_name='微信银联收款' OR flow_name='微信支付收款')"; SqlObject asql = new SqlObject(deleteSql); Sqlca.executeSQL(asql); Sqlca.commit(); - + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DeleteWechatRentPay", "success", "成功", curUserId); }catch(Exception e){ + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DeleteWechatRentPay", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/DistributorMarginCompensation.java b/src_tenwa/com/tenwa/lease/app/quartzmession/DistributorMarginCompensation.java index a50486627..5b3eefeee 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/DistributorMarginCompensation.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/DistributorMarginCompensation.java @@ -13,6 +13,7 @@ import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; +import com.amarsoft.are.util.StringFunction; import com.base.util.QuartzUtil; import com.tenwa.collectaudit.cache.CollectAuditInfoCache; import com.tenwa.comm.util.date.DateAssistant; @@ -29,6 +30,7 @@ public class DistributorMarginCompensation implements Job { @Override public synchronized void execute(JobExecutionContext arg0) throws JobExecutionException { JBOTransaction tx =null; + String startime = StringFunction.getTodayNow(); Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); String curUserId = userId == null? "system" : userId.toString(); String plan_date = DateAssistant.getToday(); @@ -107,6 +109,7 @@ public class DistributorMarginCompensation implements Job { QuartzUtil.insertLog(plan_date,"com.tenwa.lease.app.quartzmession.DistributorMarginCompensation", "success", "成功", curUserId); } catch (Exception e2) { + e2.printStackTrace(); QuartzUtil.insertLog(plan_date,"com.tenwa.lease.app.quartzmession.DistributorMarginCompensation", "error", "成功", curUserId); if (tx != null) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolDetailRunBatch.java b/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolDetailRunBatch.java index 83c49ad91..fcdec7e67 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolDetailRunBatch.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolDetailRunBatch.java @@ -2,13 +2,17 @@ package com.tenwa.lease.app.quartzmession; import java.text.SimpleDateFormat; import java.util.Date; + import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; /** * 1:动态池数明细表跑批 @@ -19,6 +23,9 @@ public class DynamicPoolDetailRunBatch implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { Transaction Sqlca=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ Sqlca = Transaction.createTransaction("als"); String create_time = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss").format(new Date()); @@ -32,10 +39,12 @@ public class DynamicPoolDetailRunBatch implements Job{ logger.info("动态池明细数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("动态池明细数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("动态池明细数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DynamicPoolDetailRunBatch", "success", "成功", curUserId); }catch(Exception e){ logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池明细数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池明细数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池明细数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DynamicPoolDetailRunBatch", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolTotalRunBatch.java b/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolTotalRunBatch.java index 27b81192b..37c34e5e3 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolTotalRunBatch.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolTotalRunBatch.java @@ -2,13 +2,17 @@ package com.tenwa.lease.app.quartzmession; import java.text.SimpleDateFormat; import java.util.Date; + import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; /** @@ -20,6 +24,9 @@ public class DynamicPoolTotalRunBatch implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { Transaction Sqlca=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ Sqlca = Transaction.createTransaction("als"); String create_time = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss").format(new Date()); @@ -33,10 +40,12 @@ public class DynamicPoolTotalRunBatch implements Job{ logger.info("动态池汇总数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("动态池汇总数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("动态池汇总数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DynamicPoolTotalRunBatch", "success", "成功", curUserId); }catch(Exception e){ logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池汇总数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池汇总数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<动态池汇总数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.DynamicPoolTotalRunBatch", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/FileToPush.java b/src_tenwa/com/tenwa/lease/app/quartzmession/FileToPush.java index c264fc589..ead824fb4 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/FileToPush.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/FileToPush.java @@ -4,6 +4,8 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; import com.tenwa.gps.HttpClientSUtil; import com.tenwa.httpclient.resources.InterfacePlatformConfigure; @@ -11,11 +13,15 @@ public class FileToPush implements Job { @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { - + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("FileToPush"),null,null); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.FileToPush", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.FileToPush", "error", "失败", curUserId); } } } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/ProductManagementReport.java b/src_tenwa/com/tenwa/lease/app/quartzmession/ProductManagementReport.java index b9508e8fe..5280a6e0d 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/ProductManagementReport.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/ProductManagementReport.java @@ -12,10 +12,12 @@ import org.quartz.JobExecutionException; import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.dw.ui.list.ProductsBusinessListUtil; import com.amarsoft.awe.util.SqlObject; import com.amarsoft.awe.util.Transaction; import com.amarsoft.dict.als.cache.CacheLoaderFactory; +import com.base.util.QuartzUtil; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.reckon.util.DateUtil; import com.tenwa.voucher.serviceImp.CreateVoucherServiceImpl; @@ -40,6 +42,9 @@ public class ProductManagementReport implements Job { String fact_date =""; String fact_money = ""; String distributor_name = ""; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); Sqlca.executeSQL(new SqlObject("DELETE FROM lb_product_report"));//删除原来数据 @@ -69,8 +74,10 @@ public class ProductManagementReport implements Job { } Sqlca.commit(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.ProductManagementReport", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.ProductManagementReport", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/PushApprovalOpinions.java b/src_tenwa/com/tenwa/lease/app/quartzmession/PushApprovalOpinions.java index 0b4fa66d1..d6411e1d3 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/PushApprovalOpinions.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/PushApprovalOpinions.java @@ -4,6 +4,8 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; import com.tenwa.gps.HttpClientSUtil; import com.tenwa.httpclient.resources.InterfacePlatformConfigure; @@ -11,10 +13,15 @@ public class PushApprovalOpinions implements Job { @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("PushApprovalOpinions"),null,null); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.PushApprovalOpinions", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.PushApprovalOpinions", "error", "失败", curUserId); } } } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/SelectActualPaymentDate.java b/src_tenwa/com/tenwa/lease/app/quartzmession/SelectActualPaymentDate.java index 9c53383a4..8eca5f49f 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/SelectActualPaymentDate.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/SelectActualPaymentDate.java @@ -20,7 +20,9 @@ import com.amarsoft.are.jbo.BizObjectManager; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.Configure; +import com.base.util.QuartzUtil; import com.tenwa.sdk.VO.SDKCheckPayDateBackVO; import com.tenwa.sdk.VO.SDKCheckPayDateDetail; import com.tenwa.sdk.VO.SDKInfoVO; @@ -40,6 +42,9 @@ public class SelectActualPaymentDate implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { JBOTransaction tx=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ tx = JBOFactory.createJBOTransaction(); BizObjectManager lficdtMange = JBOFactory.getBizObjectManager(LC_FUND_INCOME_CALLBACK_DETAIL_TEMP.CLASS_NAME, tx); @@ -184,7 +189,9 @@ public class SelectActualPaymentDate implements Job{ } } } + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SelectActualPaymentDate", "success", "成功", curUserId); }catch(Exception e){ + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SelectActualPaymentDate", "error", "失败", curUserId); try { tx.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/SplitInts3.java b/src_tenwa/com/tenwa/lease/app/quartzmession/SplitInts3.java index 014d7dc44..af0423c2a 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/SplitInts3.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/SplitInts3.java @@ -23,6 +23,7 @@ import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.lease.util.MonthInterestEntity; /*** @@ -35,12 +36,18 @@ public class SplitInts3 implements Job{ @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { JBOTransaction tx =null; + String startime = StringFunction.getTodayNow(); + + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ contractRentMonth(tx); contractRentQuarter(tx); tx.commit(); discountApportion(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SplitInts3", "success", "成功", curUserId); }catch(Exception e){ + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SplitInts3", "error", "失败", curUserId); try { tx.rollback(); if(tx!=null)tx=null; diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/StaticDataRunBatch.java b/src_tenwa/com/tenwa/lease/app/quartzmession/StaticDataRunBatch.java index e97d15913..1138f2716 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/StaticDataRunBatch.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/StaticDataRunBatch.java @@ -2,13 +2,17 @@ package com.tenwa.lease.app.quartzmession; import java.text.SimpleDateFormat; import java.util.Date; + import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; /** * 每月跑批静态池数据 @@ -19,6 +23,9 @@ public class StaticDataRunBatch implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { Transaction Sqlca=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ // Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); Sqlca = Transaction.createTransaction("als"); @@ -32,10 +39,12 @@ public class StaticDataRunBatch implements Job{ logger.info("静态池数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("静态池数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); logger.info("静态池数据跑批成功,《《《条数："+con+"《《《《时间:"+create_time+"《《《"+insertSql); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.StaticDataRunBatch", "success", "成功", curUserId); }catch(Exception e){ logger.info("<<<<<<<<<<<<<<<<<<<<<<静态池数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<静态池数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<静态池数据跑批定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>"); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.StaticDataRunBatch", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/SurplusMoneyMakeSureIn.java b/src_tenwa/com/tenwa/lease/app/quartzmession/SurplusMoneyMakeSureIn.java index c24c77e20..d34bd2229 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/SurplusMoneyMakeSureIn.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/SurplusMoneyMakeSureIn.java @@ -4,16 +4,21 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; + import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.Transaction; import com.amarsoft.dict.als.cache.CacheLoaderFactory; +import com.base.util.QuartzUtil; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.voucher.serviceImp.CreateVoucherServiceImpl; + import jbo.voucher.LV_VOUCHER_CONFIG; import jbo.voucher.TAX_CODE; @@ -28,6 +33,9 @@ public class SurplusMoneyMakeSureIn implements Job { Transaction Sqlca = null; String sql = ""; String EBANK_SN = ""; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try { Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); List list = new ArrayList(); @@ -62,8 +70,10 @@ public class SurplusMoneyMakeSureIn implements Job { } } Sqlca.commit(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SurplusMoneyMakeSureIn", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.SurplusMoneyMakeSureIn", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) { diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/TaskPool.java b/src_tenwa/com/tenwa/lease/app/quartzmession/TaskPool.java index 785e391ae..8bda87f50 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/TaskPool.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/TaskPool.java @@ -12,10 +12,12 @@ import com.amarsoft.app.als.sys.tools.DateUtil; import com.amarsoft.are.ARE; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.ASResultSet; import com.amarsoft.awe.util.SqlObject; import com.amarsoft.awe.util.Transaction; import com.amarsoft.context.ASUser; +import com.base.util.QuartzUtil; public class TaskPool implements Job { @@ -52,6 +54,9 @@ public class TaskPool implements Job { ASResultSet rsRole = null; ASResultSet rsUser = null; ASResultSet rsFlow = null; + String startime = StringFunction.getTodayNow(); + Object user_Id = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = user_Id == null? "system" : user_Id.toString(); try { //开启事务 tran = Transaction.createTransaction(JBOFactory.createJBOTransaction()); @@ -135,7 +140,9 @@ public class TaskPool implements Job { + Integer.parseInt(user.split("@")[4]) +" where userid = '" + user.split("@")[3] + "' and roleid = '" + roleId + "'")); } } + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.TaskPool", "success", "成功", curUserId); } catch (Exception e) { + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.TaskPool", "error", "失败", curUserId); e.printStackTrace(); try { if(tran != null) tran.rollback(); diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/WechatMessagePush.java b/src_tenwa/com/tenwa/lease/app/quartzmession/WechatMessagePush.java index 9880d3aa3..a3440afbb 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/WechatMessagePush.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/WechatMessagePush.java @@ -6,17 +6,21 @@ import java.io.OutputStreamWriter; import java.net.HttpURLConnection; import java.net.URL; import java.util.UUID; + import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; + import com.alibaba.fastjson.JSONObject; import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.util.StringFunction; import com.amarsoft.awe.util.ASResultSet; import com.amarsoft.awe.util.SqlObject; import com.amarsoft.awe.util.Transaction; import com.amarsoft.dict.als.cache.CacheLoaderFactory; +import com.base.util.QuartzUtil; import com.tenwa.httpclient.resources.WechatPropertiesUtil; import com.tenwa.util.SerialNumberUtil; @@ -29,6 +33,9 @@ public class WechatMessagePush implements Job{ public void execute(JobExecutionContext arg0) throws JobExecutionException { Transaction Sqlca=null; + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); try{ Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); // 执行还款消息推送 @@ -38,10 +45,12 @@ public class WechatMessagePush implements Job{ logger.info("还款提醒发送状态<<<<<<<<<<<<<: "+result1); logger.info("逾期还款提醒发送状态<<<<<<<<<<: "+result2); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.WechatMessagePush", "success", "成功", curUserId); }catch(Exception e){ logger.info("<<<<<<<<<<<<<<<<<<<<<<微信推送定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<微信推送定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>>"); logger.info("<<<<<<<<<<<<<<<<<<<<<<微信推送定时任务执行异常>>>>>>>>>>>>>>>>>>>>>>>"); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.WechatMessagePush", "error", "失败", curUserId); try { Sqlca.rollback(); } catch (JBOException e1) {