package com.hoten.util;

import com.hoten.communicate.info.*;
import com.hoten.db.*;
import java.sql.*;
import java.util.*;

/**
 * DBCommon 用于封裝公共數據庫操作的類
 * 主要方法： RecordMO()          記錄MO信息(ws_mo)
 *          RecordMT()          記錄MT信息(由table決定)
 *          getActiveGame()     獲取用戶當前處于活動狀態的游戲信息
 *          getSpecifiedGame    獲取用戶指定游戲信息
 *          ChangeUserStatus()  改變用戶游戲狀態信息
 */
public class DBCommon {
    /**
     * 通過傳遞MOInfo類實例，記錄MO信息(ws_mo)
     * @param moInfo MOInfo
     * @throws Exception
     */
    public synchronized static void SaveMO(MOInfo moInfo, DBAccess dba) throws
        Exception {
        StringBuffer sbSql = new StringBuffer(300); //使用StringBuffer 能提高系統的性能
        sbSql.append("insert into ");
        sbSql.append(moInfo.getTable());
        if (moInfo.getTable().equals("AHYD"))
            sbSql.append("(time,mobile,bz,msg) values('");
        else
            sbSql.append("(time,mobile,bz,msg,area) values('");
        sbSql.append(moInfo.getTime());
        sbSql.append("','");
        sbSql.append(moInfo.getMobile());
        sbSql.append("','");
        sbSql.append(moInfo.getBZ());
        sbSql.append("','");
        if (moInfo.getMsg() != null)
            sbSql.append(Chinese.toDatabase(moInfo.getMsg()));
        if (moInfo.getTable().equals("AHYD"))
            sbSql.append("')");
        else {
            sbSql.append("','");
            sbSql.append(moInfo.getArea());
            sbSql.append("')");
        }
        dba.update(sbSql.toString());
        sbSql = null;
    }

    /**
     * 通過傳遞MTInfo類實例，記錄MT信息(由table域決定存放地)
     * @param mtinfo MTInfo
     * @throws Exception
     */
    public static void RecodeMT(int state, MTInfo mtInfo, DBAccess dba,
                                String table) throws Exception {
        StringBuffer sbSql = new StringBuffer(300); //使用StringBuffer 能提高系統的性能
        if (mtInfo.getArea() == null)
            mtInfo.setArea("JSYD");

        if (mtInfo.getBZ1().equals("YZ")) {
            if (state != 0) {
                sbSql.append("insert into sendinfo_fail (xh,qqfssj,jtly,sjhm,msg,zt,fee,bz1,bz2,bz3,bz4,area) values('");
                sbSql.append(mtInfo.getXH());
                sbSql.append("','");
                sbSql.append(CTime.getTime(CTime.YYMMDDhhmm));
                sbSql.append("','");
                sbSql.append(mtInfo.getJTLY());
                sbSql.append("','");
                sbSql.append(mtInfo.getSJHM());
                sbSql.append("','");
                sbSql.append(mtInfo.getXXNR());
                sbSql.append("','");
                sbSql.append(state);
                sbSql.append("','");
                sbSql.append(mtInfo.getFee());
                if (mtInfo.getBZ1() != null)
                    sbSql.append(mtInfo.getBZ1());
                sbSql.append("','");
                if (mtInfo.getYWDM() != null)
                    sbSql.append(mtInfo.getYWDM());
                sbSql.append("','");
                if (mtInfo.getFlagFee() != null)
                    sbSql.append(mtInfo.getFlagFee());
                sbSql.append("','");
                if (mtInfo.getYWDM() != null)
                    sbSql.append(mtInfo.getYWDM());
                sbSql.append("','");
                sbSql.append(mtInfo.getArea());
                sbSql.append("')");
            }
        }
        else {
            sbSql.append("insert into ");
            sbSql.append(table);
            if (table.equals("ui_sendinfo"))
                sbSql.append(
                    "(xh,xxly,jtly,xxlx,qqfssj,sjhm,zt,NRXH,fee,bz1,bz2,bz3,bz4,area) values('");
            else
                sbSql.append(
                    "(xh,xxly,jtly,xxlx,qqfssj,sjhm,zt,NRXH,fee,bz1,bz2,bz3,bz4) values('");
            sbSql.append(mtInfo.getXH());
            sbSql.append("','");
            if (mtInfo.getXXLY() != null)
                sbSql.append(mtInfo.getXXLY());
            sbSql.append("','");
            if (mtInfo.getJTLY() != null)
                sbSql.append(mtInfo.getJTLY());
            sbSql.append("','");
            if (mtInfo.getXXLX() != null)
                sbSql.append(mtInfo.getXXLX());
            sbSql.append("','");
            if (mtInfo.getQQFSSJ() != null)
                sbSql.append(CTime.getTime(CTime.YYMMDDhhmm));
            sbSql.append("','");
            if (mtInfo.getSJHM() != null)
                sbSql.append(mtInfo.getSJHM());
            sbSql.append("','");
            sbSql.append(state);
            sbSql.append("','");
            if (mtInfo.getNRXH() != null)
                sbSql.append(mtInfo.getNRXH());
            sbSql.append("','");
            if (mtInfo.getFee() != null)
                sbSql.append(mtInfo.getFee());
            sbSql.append("','");
            if (mtInfo.getBZ1() != null)
                sbSql.append(mtInfo.getBZ1());
            sbSql.append("','");
            if (mtInfo.getYWDM() != null)
                sbSql.append(mtInfo.getYWDM());
            sbSql.append("','");
            if (mtInfo.getFlagFee() != null)
                sbSql.append(mtInfo.getFlagFee());
            sbSql.append("','");
            if (mtInfo.getYWDM() != null)
                sbSql.append(mtInfo.getYWDM());
            if (table.equals("ui_sendinfo")) {
                sbSql.append("','");
                sbSql.append(mtInfo.getArea());
            }
            sbSql.append("')");
        }

        try {
            dba.update(sbSql.toString());
        }
        catch (Exception ex) {
            Log.printEvent(sbSql.toString(), ".\\log\\sql.log");
        }
        sbSql = null;
    }
}