From 16c0521d084b8470099a779a200c7a92fb550d59 Mon Sep 17 00:00:00 2001
From: "zhanglei@ap-leasing.com.cn" <zhanglei@ap-leasing.com.cn>
Date: Thu, 25 May 2023 09:30:45 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=BE=E6=AC=BE=E5=9B=9E=E6=AC=BE=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1=E6=8A=A5=E8=A1=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

---
 .../quartzmession/InsertReportFlowCount.java  | 62 +++++++++++++++++++
 1 file changed, 62 insertions(+)
 create mode 100644 src_tenwa/com/tenwa/lease/app/quartzmession/InsertReportFlowCount.java

diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/InsertReportFlowCount.java b/src_tenwa/com/tenwa/lease/app/quartzmession/InsertReportFlowCount.java
new file mode 100644
index 000000000..f191ba3ab
--- /dev/null
+++ b/src_tenwa/com/tenwa/lease/app/quartzmession/InsertReportFlowCount.java
@@ -0,0 +1,62 @@
+package com.tenwa.lease.app.quartzmession;
+
+
+import com.amarsoft.are.ARE;
+import com.amarsoft.are.jbo.JBOException;
+import com.amarsoft.are.jbo.JBOFactory;
+import com.amarsoft.are.jbo.JBOTransaction;
+import com.amarsoft.are.log.Log;
+import com.amarsoft.are.util.StringFunction;
+import com.amarsoft.awe.util.SqlObject;
+import com.amarsoft.awe.util.Transaction;
+import com.base.util.QuartzUtil;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+
+public class InsertReportFlowCount implements Job{
+
+	@Override
+	public void execute(JobExecutionContext arg0) throws JobExecutionException {
+		JBOTransaction tx=null;
+		Transaction  Sqlca=null;
+		String startime =StringFunction.getTodayNow();
+		startime = startime.substring(0, 10);
+		
+		Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId");
+		String curUserId = userId == null? "system" : userId.toString();
+		
+		try {
+			tx= JBOFactory.createJBOTransaction();
+			Sqlca=Transaction.createTransaction(tx);
+			
+			String sql="{CALL insert_flow_report()};";
+			SqlObject asql = new SqlObject(sql);
+			Sqlca.executeSQL(asql);
+				QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.Commission", "success", "³É¹¦", curUserId);
+			} catch (Exception e) {
+				QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.Commission", "success", "ʧ°Ü", curUserId);
+				logger.error(e.getMessage());
+				e.printStackTrace();
+				if(Sqlca!=null){
+			          try {
+						Sqlca.rollback();
+						Sqlca = null;
+					} catch (JBOException e1) {
+						e1.printStackTrace();
+					}
+			    }
+			}finally{
+				if(Sqlca!=null){
+			          try {
+						Sqlca.commit();
+						Sqlca.disConnect();
+						Sqlca = null;
+					} catch (JBOException e) {
+						e.printStackTrace();
+					}
+			    }
+			}
+	}
+	private static  Log logger=ARE.getLog();
+}