anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.定时任务执行生成日志。

Browse Source
This commit is contained in:
zhangbb 2020-06-15 17:24:19 +08:00
parent 09e4a823bf
commit 1b42f2bf4d
17 changed files with 134 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src_tenwa/com/tenwa/lease/app/quartzmession/AtTheEndOfContractPush.java
View File

@ -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);
}
}
}

14
src_tenwa/com/tenwa/lease/app/quartzmession/AutoFiveGradeClass.java
View File

@ -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";
}
}

8
src_tenwa/com/tenwa/lease/app/quartzmession/CalcPenaltyJob.java
View File

@ -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();

7
src_tenwa/com/tenwa/lease/app/quartzmession/ContractLoanPush.java
View File

@ -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);
}
}
}

9
src_tenwa/com/tenwa/lease/app/quartzmession/DeleteWechatRentPay.java
View File

@ -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) {

3
src_tenwa/com/tenwa/lease/app/quartzmession/DistributorMarginCompensation.java
View File

@ -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) {

9
src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolDetailRunBatch.java
View File

@ -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) {

9
src_tenwa/com/tenwa/lease/app/quartzmession/DynamicPoolTotalRunBatch.java
View File

@ -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) {

8
src_tenwa/com/tenwa/lease/app/quartzmession/FileToPush.java
View File

@ -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);
}
}
}

7
src_tenwa/com/tenwa/lease/app/quartzmession/ProductManagementReport.java
View File

@ -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) {

7
src_tenwa/com/tenwa/lease/app/quartzmession/PushApprovalOpinions.java
View File

@ -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);
}
}
}

7
src_tenwa/com/tenwa/lease/app/quartzmession/SelectActualPaymentDate.java
View File

@ -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) {

7
src_tenwa/com/tenwa/lease/app/quartzmession/SplitInts3.java
View File

@ -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;

9
src_tenwa/com/tenwa/lease/app/quartzmession/StaticDataRunBatch.java
View File

@ -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) {

10
src_tenwa/com/tenwa/lease/app/quartzmession/SurplusMoneyMakeSureIn.java
View File

@ -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<String> list = new ArrayList<String>();
@ -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) {

7
src_tenwa/com/tenwa/lease/app/quartzmession/TaskPool.java
View File

@ -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();

9
src_tenwa/com/tenwa/lease/app/quartzmession/WechatMessagePush.java
View File

@ -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) {