orderthread.java~64~

来自「采用web2.0技术,采用动态标签,sql语句全部存储在数据库里面.开发速度快.」· JAVA~64~ 代码 · 共 122 行

package com.sztheater.biz.service;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
import java.io.*;
import java.sql.*;
import com.sztheater.framework.util.*;
import com.sztheater.biz.order.*;
import java.util.*;

public class OrderThread extends Thread {
    private boolean blShut = false;
    public OrderThread() {
    }
    public void run()
    {
        System.out.println("start thread!");
        this.initProduct();
    }
    public int initProduct()
    {
        int iFlag = 0;
        this.DealThread();
        return iFlag;
    }
    private  void DealThread()
    {
        Thread thread = null;
        Runnable run = new Runnable()
        {
            public void  run()
            {
                boolean blShutFlag = false;
                blShutFlag = getShutFlag();
                while(blShutFlag == false)
                {
                    try
                    {
                        DealData();
                        Thread.sleep(600000);
                    }
                    catch(Exception ex)
                    {
                        ex.printStackTrace();
                    }
                   //退出线程
                   blShutFlag = getShutFlag();
                }
                return;
            }
        };
        thread = new Thread(run);
        thread.start();
    }
    private void DealData()
    {
        Connection conn = null;
        int iSuccFlag = 0,iLoopNum = 0 ,iLoop =0;
        String strMsg = null , strSQL = null;
        ArrayList resultField = null;
        HashMap aHash = null;
        String programid = null,seatid = null,id = null;
        boolean flag = false;
        try
        {
               try {
                     conn = DbFunc.getConnection(false);
                 } catch (Exception e) {
                     iSuccFlag = -90102;
                     if (conn != null) {
                         DbFunc.free(conn, iSuccFlag);
                     }
                     conn = null;
                     strMsg = "服务取数据库连接异常" + e.getMessage();
                 }
                 strSQL = "select * from t_order_cart where DATEDIFF(minute,ordertime,getdate())>=30";
                 resultField = new ArrayList();
                 DbFunc.getRecordSet( -900012, "", conn, strSQL, resultField);
                 System.out.println("resultField**" + resultField);
                 iLoopNum = resultField.size();
                 for (iLoop = 0; iLoop < iLoopNum; iLoop++) {
                     aHash = (HashMap) resultField.get(iLoop);

                     programid = (String) aHash.get("programid");
                     seatid = (String) aHash.get("seatid");
                     id = (String)aHash.get("id");
                     strSQL = "update t_ticketingseat set \n"
                              + "statusid = 0 where programid='" + programid +
                              "' \n"
                              + " and seatid='" + seatid + "' ";
                     flag = ModifyData.ModifyTicketingSeat(strSQL);
                 }
                 /*if update t_ticketingseat success then delete the t_order_cart*/
                 if (flag) {
                     strSQL = "delete from t_order_cart where id=" +
                              id + "";
                     iSuccFlag = DbFunc.runsql(strSQL);
                 }
                 } catch (Exception ex) {
                     ex.printStackTrace();
                }
    }
    private boolean getShutFlag()
    {
        return this.blShut;
    }
    private void setShutFlag(boolean blShutFlag)
    {
        this.blShut = blShutFlag;
    }
    public void shutdown()
    {
        setShutFlag(true);
    }
}