package com.poson.aspz;
import java.io.File;
import java.rmi.RemoteException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import org.apache.log4j.Logger;
import com.poson.aspz.db.TranContext;
import com.poson.aspz.util.Config;
import com.poson.aspz.util.Const;
import com.poson.aspz.util.MyLoger;
import com.poson.aspz.util.Util;
import java.net.MalformedURLException;
import ws.clinet.axis2.WebSoapBindingImplServiceCallbackHandler;
import ws.clinet.axis2.WebSoapBindingImplServiceStub;
import java.sql.Connection;
import java.sql.DriverManager;
public class OnTimeCreditIntf extends Thread
{
private boolean bSuperUser = false;
private boolean working = false;
private String planXMLFileFN = "";
private String path = "";
private String staffNo = "";
private String pswd = "";
private String staffId = "";
private String siteId = "";
private String areaId = "";
private TranContext myDBTrans = null;
private String curCreatePZDate = "";
protected Connection conn;
//private static Log log = LogFactory.getLog(Worker.class);
//private static MyLoger log = new MyLoger();
private Logger logger = Logger.getLogger(OnTimeCreditIntf.class);
public OnTimeCreditIntf()
{
}
public Connection getConnection() {
try {
conn = DriverManager.getConnection(Const.CONFIG_XML_DB_URL);
return conn;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
/**
* 建立连接
* @param driver
* @param url
* @param user
* @param password
* @return
*/
public Connection getConnection(String driver, String url, String user, String password) {
try {
Class.forName(driver);
conn = DriverManager.getConnection(url, user, password);
return conn;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
public List getBJOnTimeCreditIntfSumbit() throws SQLException
{
ArrayList list = new ArrayList();
ResultSet rs = null;
StringBuffer strSql = new StringBuffer();
strSql.append(" SELECT TRIM(ORDER_SERIAL_NBR) ORDER_SERIAL_NBR, ");
strSql.append(" TRIM(OWE_BUSINESS_TYPE_ID) OWE_BUSINESS_TYPE_ID,TRIM(STAFF_ID) STAFF_ID, ");
strSql.append(" TRIM(SERV_ID) SERV_ID,TO_CHAR(CREATED_DATE, 'yyyymmddhhmmss') CREATED_DATE,TO_CHAR(COMPLETED_DATE, 'yyyymmddhhmmss') COMPLETED_DATE, ");
strSql.append(" TRIM(STATE) STATE,TO_CHAR(STATE_DATE, 'yyyymmddhhmmss') STATE_DATE,TRIM(PROCESS_COUNT) PROCESS_COUNT, ");
strSql.append(" TRIM(PRE_SERV_STATE) PRE_SERV_STATE,TRIM(REMARK) REMARK,TRIM(CHARGE) CHARGE,TRIM(BALANCE) BALANCE, ");
strSql.append(" TRIM(CREDIT) CREDIT,TRIM(OWE_TASK_ITEM_ID) OWE_TASK_ITEM_ID ");
strSql.append(" FROM A_WORK_ORDER ");
strSql.append(" WHERE STATE='P0C' AND ROWNUM<500 ORDER BY ORDER_SERIAL_NBR ");
rs = myDBTrans.executeQuery(strSql.toString());
while (rs.next())
{
HashMap planInfo = new HashMap();
planInfo.put("ORDER_SERIAL_NBR",rs.getString("ORDER_SERIAL_NBR"));
planInfo.put("OWE_BUSINESS_TYPE_ID",rs.getString("OWE_BUSINESS_TYPE_ID"));
planInfo.put("STAFF_ID",rs.getString("STAFF_ID"));
planInfo.put("SERV_ID",rs.getString("SERV_ID"));
planInfo.put("CREATED_DATE",rs.getString("CREATED_DATE"));
planInfo.put("COMPLETED_DATE",rs.getString("COMPLETED_DATE"));
planInfo.put("STATE",rs.getString("STATE"));
planInfo.put("STATE_DATE",rs.getString("STATE_DATE"));
planInfo.put("PROCESS_COUNT",rs.getString("PROCESS_COUNT"));
planInfo.put("PRE_SERV_STATE",rs.getString("PRE_SERV_STATE"));
planInfo.put("REMARK",rs.getString("REMARK"));
planInfo.put("CHARGE",rs.getString("CHARGE"));
planInfo.put("BALANCE",rs.getString("BALANCE"));
planInfo.put("CREDIT",rs.getString("CREDIT"));
planInfo.put("OWE_TASK_ITEM_ID",rs.getString("OWE_TASK_ITEM_ID"));
list.add(planInfo);
}
if (rs != null) {
rs.close();
rs = null;
}
return list;
}
// public void updateBJOnTimeCreditIntfPlan(String requestId,String serial) throws SQLException
// {
// ResultSet rs = null;
// StringBuffer strSql = new StringBuffer();
// strSql.append(" UPDATE A_WORK_ORDER SET STATE='P0P',REMARK='处理成功',SERIAL='" + serial + "'");
// strSql.append(" WHERE ORDER_SERIAL_NBR= " + requestId);
// rs = myDBTrans.executeQuery(strSql.toString());
// }
public void deleteBJOnTimeCreditIntfPlan(String requestId) throws SQLException
{
StringBuffer strSql = new StringBuffer();
strSql.append(" DELETE FROM A_WORK_ORDER ");
strSql.append(" WHERE ORDER_SERIAL_NBR= " + requestId);
myDBTrans.doBatch(strSql.toString());
}
public void insertBJOnTimeAWorkOrderLog(String requestId,String serial) throws SQLException
{
StringBuffer strSql = new StringBuffer();
strSql.append(" INSERT INTO A_WORK_ORDER_LOG (order_serial_nbr,owe_business_type_id,staff_id, ");
strSql.append(" serv_id,created_date,completed_date,state,state_date,process_count,pre_serv_state,remark,");
strSql.append(" tran_manual_date,hd_staff_id,charge,balance,credit,owe_task_item_id,SERIAL) ");
strSql.append(" select order_serial_nbr,owe_business_type_id,staff_id, " );
strSql.append(" serv_id,created_date,completed_date,'P0P',sysdate,process_count,pre_serv_state,remark,");
strSql.append(" null,null,charge,balance,credit,owe_task_item_id,'" +serial + "' from A_WORK_ORDER ");
strSql.append(" WHERE ORDER_SERIAL_NBR= " + requestId);
myDBTrans.doBatch(strSql.toString());
}
public void updateBJOnTimeCreditFailPlan(String requestId,String error, String serial) throws SQLException
{
StringBuffer strSql = new StringBuffer();
strSql.append(" UPDATE A_WORK_ORDER SET STATE='P0E',state_date=sysdate,REMARK='" + error + "',SERIAL='" + serial + "'");
strSql.append(" WHERE ORDER_SERIAL_NBR= " + requestId);
myDBTrans.doBatch(strSql.toString());
}
public OnTimeCreditIntf(String staffNo, String pswd, String path, String planXMLFileFN){
// if(this.conn == null) {
// this.conn = this.getConnection();
// this.conn.setAutoCommit(true);
// }
this.staffNo = staffNo;
this.pswd = pswd;
this.path = path;
this.planXMLFileFN = path + File.separator + planXMLFileFN;
// 启动数据库连接
myDBTrans = new TranContext();
}
public boolean isWorking() {
return working;
}
public void setWorking(boolean working) {
this.working = working;
}
public void run()
{
// 开始无限循环工作
long times = 0;
int sleepTime = 60;
while (working)
{
try
{
List curSubmitReport = getBJOnTimeCreditIntfSumbit();
String xmlFileName = Util.getAppTopFolderPath() + Const.CONFIG_XML_FILE_NAME;
Config config = new Config(xmlFileName);
sleepTime = config.sleep;
for (int n = 0; n < curSubmitReport.size(); n++)
{
try
{
Date curDate = new Date();
HashMap planInfo = (HashMap) curSubmitReport.get(n);
String requestId = (String) planInfo.get("ORDER_SERIAL_NBR");
String servId = (String) planInfo.get("SERV_ID");
String synType = (String) planInfo.get("OWE_BUSINESS_TYPE_ID");
String stateTime = (String) planInfo.get("STATE_DATE");
String curBalance = (String) planInfo.get("BALANCE");
String creditValue = (String) planInfo.get("CREDIT");
String random = String.valueOf(Math.random()).substring(2,10);
Date currentTime=new Date();
SimpleDateFormat formatter=new SimpleDateFormat("yyyyMMddHHmmss");
String time=formatter.format(currentTime);
String serial = time + random + "10" + "02";
WebSoapBindingImplServiceStub.OnTimeCreditControlReq onTimeCreditControlReq = new WebSoapBindingImplServiceStub.OnTimeCreditControlReq();
WebSoapBindingImplServiceStub.OnTimeCreditControl onTimeCreditControl = new WebSoapBindingImplServiceStub.OnTimeCreditControl();
onTimeCreditControlReq.setRequestId(serial);
onTimeCreditControlReq.setServId(servId);
onTimeCreditControlReq.setStateTime(stateTime);
onTimeCreditControlReq.setSynType(Integer.parseInt(synType));
onTimeCreditControlReq.setInterfaceId("");
onTimeCreditControlReq.setCurBalance(curBalance);
onTimeCreditControlReq.setCreditValue(creditValue);
onTimeCreditControl.setIn0(onTimeCreditControlReq);
logger.info("**OnTimeCreditControl**请求参数如下:"
+ "\n RequestId(请求流水): " + onTimeCreditControlReq.getRequestId()
+ "\n ServId(用户标识): " + onTimeCreditControlReq.getServId()
+ "\n SynType(同步类型): " + onTimeCreditControlReq.getSynType()
+ "\n curBalance(实时结余): " + onTimeCreditControlReq.getCurBalance()
+ "\n creditValue(用户信用度): " + onTimeCreditControlReq.getCreditValue()
+ "\n StateTime(状态时间): " + onTimeCreditControlReq.getStateTime());
String result = callOnTimeCreditIntfWebServices(onTimeCreditControl,config);
if("0".equals(result))
{
insertBJOnTimeAWorkOrderLog(requestId,serial);
deleteBJOnTimeCreditIntfPlan(requestId);
logger.info("=========OnTimeCreditControl successful,servId:"+servId+"=========");
}
else
{
myDBTrans.roolback();
updateBJOnTimeCreditFailPlan(requestId,result,serial);
logger.info("=========OnTimeCreditControl failure,servId:"+servId+"当前流水执行失败！！！" );
}
myDBTrans.commit();
// 关闭数据集
try
{
myDBTrans.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
catch (RuntimeException e)
{
logger.info("=========failure=========当前条目计划执行失败！！！" );
e.printStackTrace();
myDBTrans.roolback();
myDBTrans.close();
}
}
}
catch(Exception ex)
{
ex.printStackTrace();
Util.outPutInfo("未知错误发生" + ex.getMessage());
}
// 关闭数据集
try
{
myDBTrans.close();
}
catch (Exception e)
{
e.printStackTrace();
}
// 睡眠一段时间后再工作
try
{
sleep(sleepTime);
myDBTrans.freeCon();
myDBTrans.initConnection();
}
catch(InterruptedException e)
{
Util.outPutInfo("线程睡眠被打断,程序继续执行: " + e.getMessage());
e.printStackTrace();
}
}
}
private String callOnTimeCreditIntfWebServices(WebSoapBindingImplServiceStub.OnTimeCreditControl onTimeCreditControlReq,Config config)
{
try
{
WebSoapBindingImplServiceStub stub = new WebSoapBindingImplServiceStub(config.wsEndpoint);
WebSoapBindingImplServiceStub.OnTimeCreditControlResponse onTimeCreditControlResp = stub.onTimeCreditControl(onTimeCreditControlReq);
logger.info("result is: \n"+onTimeCreditControlResp.getOnTimeCreditControlReturn().getResult());
String result = onTimeCreditControlResp.getOnTimeCreditControlReturn().getResult();
if("0".equals(result)) return "0";
else return onTimeCreditControlResp.getOnTimeCreditControlReturn().getErrorMessage();
}
catch(Exception e)
{
e.printStackTrace();
return "5000";
}
}
public static void main(String[] args)
{
String path = Util.getAppTopFolderPath();
String user = "jlz";
String pswd = "1q2w3e4r";
Thread thread = new OnTimeCreditIntf(user, pswd, path, Const.SUBMIT_PLAN_XML_FILE_NAME);
thread.setDaemon(false);
((OnTimeCreditIntf) thread).setWorking(true);
thread.start();
// 主线程进入无限睡眠状态，其创建的子线程 thread 继续工作
try
{
Thread.sleep(Long.MAX_VALUE);
}
catch(InterruptedException e)
{
System.out.println("主线睡眠状态被打断，程序继续执行...\n" + e.getMessage());
}
// 当主线程睡眠被打断时，程序结束，并设置子线程状态，让其在完成必要工作后也结束
((OnTimeCreditIntf) thread).setWorking(false);
}
}
相关推荐
VB6 多线程技术，已经测试。稳定、方便、实用的VB6多线程技术（附老马的ActiveX多线程示例）
MFC窗口程序多线程示例 MFC窗口程序多线程示例 MFC窗口程序多线程示例
等线程示例学习等线程示例学习等线程示例学习等线程示例学习等线程示例学习等线程示例学习
C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例C#多线程示例
bcb_多线程示例，学习笔记 MutilThread(生产者与消费者) 线程协调工作示例
delphi7写的简单的多线程是示例，平时开发了解使用
Java中的多线程有三种实现方式： 1.继承Thread类，重写run方法。Thread本质上也是一个实现了Runnable的实例，他代表一个线程的实例，并且启动线程的唯一方法就是通过Thread...本示例演示和wait和sleep、线程锁的使用。
一个很完整的例子来介绍java的多线程，对初学者有不错的借鉴意义
本示例主要演示C++11下的多线程运算，可以加速，对于一些高性能的程序，可以参考
关于c#多线程示例
Delphi多线程完整示例源码，附完整源码及编译好的示例程序。代码风格简单实用，线程回调函数清晰易懂
pb 11.5 多线程 示例
线程示例WorkerThread_demo，线程示例WorkerThread_demo， 线程示例WorkerThread_demo，
QT开线程示例
powerbuilder 多线程示例 演示了参数如何从可视界面传递到子线程，计算结果返回到可视界面
多线程示例Test.多线程示多线程示例Test.jar例Test.jarjar
QT线程示例,QT线程示例，QT线程示例，QT线程示例
多线程示例C++，包含详细的操作文档和示例代码已经调试成功