杜方 / CYTAndroid4.0

package com.ectrip.cyt.db;

import java.util.ArrayList;

import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;

import com.ectrip.cyt.bean.ConfigBean;
import com.ectrip.cyt.config.MyApp;

public class DbManager {
	/**
	 * 获取配置文件
	 */
	public  static ArrayList<ConfigBean> GetConfigs() {
		ArrayList<ConfigBean> products = new ArrayList<ConfigBean>();
		synchronized (MyApp.getInstance().getDb()) {
			try {
				Cursor c = MyApp.getInstance().getDb()
						.rawQuery("SELECT * FROM ec_configs", null);
				for (int i = 0; i < c.getCount(); i++) {
					c.moveToPosition(i);
					products.add(new ConfigBean(c.getString(0), c.getString(1),
							c.getString(2), c.getString(3), c.getString(4), c
							.getString(5), c.getInt(6)));
				}
				c.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			return products;
		}
	}

	public static void InsertConfig(String ec_id, String ec_ip,
									String ec_passwd, String ec_mac, String ec_key, String ec_name,
									int ec_isPrint) {
		synchronized (MyApp.getInstance().getDb()) {
			try {
				MyApp.getInstance()
						.getDb()
						.execSQL(
								"INSERT OR REPLACE INTO ec_configs (ec_cid,ec_ip, ec_passwd, ec_mac,ec_key,ec_name,ec_isPrint) VALUES(?,?,?,?,?,?,?)",
								new Object[] { ec_id, ec_ip, ec_passwd, ec_mac,
										ec_key, ec_name, ec_isPrint });
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	// update ec_contacts set ec_name=?,ec_tel=? where ec_id=?

	/**
	 * 修改配置文件
	 */
	public static void ModifyConfig(ConfigBean bean) {
		synchronized (MyApp.getInstance().getDb()) {
			try {
				MyApp.getInstance()
						.getDb()
						.execSQL(
								"update ec_configs set ec_ip=?, ec_passwd=?, ec_mac=?, ec_key=? ,ec_name=?,ec_isPrint=? where ec_cid=?",
								new Object[] { bean.getEc_ip(),
										bean.getEc_passwd(), bean.getEc_mac(),
										bean.getEc_identity(), bean.getEc_signkey(),
										bean.getEc_isPrint(), bean.getEc_id() });
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 插入配置文件
	 */
	public static void InsertConfig(ConfigBean bean) {
		InsertConfig(bean.getEc_id(), bean.getEc_ip(), bean.getEc_passwd(),
				bean.getEc_mac(), bean.getEc_identity(), bean.getEc_signkey(),
				bean.getEc_isPrint());
	}

	/**
	 */
	public static void ClearConfig() {
		synchronized (MyApp.getInstance().getDb()) {
			try {
				MyApp.getInstance().getDb().execSQL("DELETE FROM ec_configs");
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 插入打印过的票
	 */
	public static void insertPrint(String time, String content,
								   String ec_order_number) {
		synchronized (MyApp.getInstance().getDb()) {
			SQLiteDatabase db = MyApp.getInstance().getDb();
			// 开启事务
			db.beginTransaction();
			try {
				MyApp.getInstance()
						.getDb()
						.execSQL(
								"INSERT OR REPLACE INTO ec_save_print (ec_time, ec_content,ec_order_id) "
										+ "VALUES(?,?,?)",
								new Object[] { time, content, ec_order_number });
				// 设置事务标志为成功，当结束事务时就会提交事务
				db.setTransactionSuccessful();
			} finally {
				// 结束事务
				db.endTransaction();
			}
		}
	}

	/**
	 * 修改打印的票
	 */
	public static void ModifyPrint(String time, String content,
								   String ec_order_number) {
		synchronized (MyApp.getInstance().getDb()) {
			SQLiteDatabase db = MyApp.getInstance().getDb();
			// 开启事务
			db.beginTransaction();
			try {
				MyApp.getInstance()
						.getDb()
						.execSQL(
								"update ec_save_print set ec_time=?, ec_content=? where ec_order_id=?",
								new Object[] { time, content, ec_order_number });
				// 设置事务标志为成功，当结束事务时就会提交事务
				db.setTransactionSuccessful();
			} finally {
				// 结束事务
				db.endTransaction();
			}
		}
	}

	/**
	 * 删除某一时间段内的数据
	 */
	public static void deletePrint(String time) {
		synchronized (MyApp.getInstance().getDb()) {
			try {
				String strsql = "delete from ec_save_print where ec_time like '"
						+ time + "%'";
				MyApp.getInstance().getDb().execSQL(strsql);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 根据订单号查询数据
	 */
	public static String queryOrderNumber(String orderId) {
		String content = null;
		synchronized (MyApp.getInstance().getDb()) {
			try {
				Cursor cursor = MyApp
						.getInstance()
						.getDb()
						.rawQuery(
								"select * from ec_save_print where ec_order_id like ?",
								new String[] { "%" + orderId + "%" });

				if (cursor.moveToFirst()) {
					content = cursor.getString(cursor
							.getColumnIndex("ec_content"));
				}
				cursor.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		return content;
	}

	/**
	 * 删除指定时间以内的数据
	 */
	public static void regularDelect(String date) {
		String sql = "delete FROM ec_save_print WHERE ec_time<'" + date + "'";
		synchronized (MyApp.getInstance().getDb()) {
			try {
				MyApp.getInstance().getDb().execSQL(sql);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}