package com.cargo.db;

import com.cargo.model.Order;
import java.util.Collection;
import java.util.ArrayList;
import com.cargo.model.Request;
import java.sql.SQLException;
import java.sql.ResultSet;
import java.util.Iterator;
import com.cargo.model.Ware;
import com.cargo.send.Send;
import com.cargo.db.Userdb;
import com.cargo.model.User;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: MR</p>
 * @author BWM
 * @version 1.0
 */

public class Orderdb extends Conn implements Keywords {

    private int t = 0;
    private boolean iflag = false;
    private boolean sflag = false;
    private ResultSet rs = null;
    private Send send = new Send();
    private Userdb udb = new Userdb();
    //str=50+User Infomation+Commidity Information
    private String str = null;
    private Collection c = new ArrayList();
    public static final String SELECT_ORDER=SELECT + "*" + FROM + "tb_order";
    public Orderdb() {
    }

    /**
     * @param order
     * @param coll
     * @return -2 :This is not User
     * @return -1 :Order is Empty
     * @return 1 : Building Order
     * @return 2 :Send Information is success
     * @return 3 :All success
     */
    public int Change(Order order, Collection coll) {
        //查找用戶信息
        c = udb.select(udb.WHERE + "id='" + order.getUserid() + "'");
        if (c == null || c.isEmpty()) {
            return t = -2;
        } else {
            Iterator i = coll.iterator();
            if (i.hasNext()) {
                User u = new User();
                str = "50 " + u.getName() + " " + u.getAddress() + " ";
            }
        }
        //設(shè)置訂單數(shù)據(jù)
        if (coll == null || coll.isEmpty()) {
            return t = -1;
        }
        Iterator it = coll.iterator();
        while (it.hasNext()) {
            Ware ware = (Ware) it.next();
            order.setNum(ware.getNum());
            order.setCommodity(ware.getId());
            if (order.getId() != null && (order.getId().length() > 0) && order.getNum() > 0) {
                str = str + order.getCommodity() + " " + order.getNum() + " ";
                this.insert(order);
                t = 1;
                iflag = true;
            }
        }
        //發(fā)送Email
        send.Logon(order.getUserid());
        if (send.Send(order.getTime(), str)) {
            t = 2;
            sflag = true;
        }
        if (sflag & iflag) {
            t = 3;
        }
        return t;
    }

    public int insert(Order order) {
        t = insert(INSERT_INTO + "tb_order(id,userid,wareid,num,time)" + VALUES + "('" +
            order.getId() + "','" + order.getUserid() + "','" + order.getCommodity() + "'," +
            order.getNum() + ",'" + order.getTime() + "')");
        return t;
    }

    public Collection select() {
        return this.select("");
    }

    public Collection select(String sql) {
        Collection coll = new ArrayList();
        rs = getRs(SELECT_ORDER+ sql);
        try {
            while (rs.next()) {
                Order ord = new Order();
                ord.setId(rs.getString(1));
                ord.setUserid(rs.getString(2));
                ord.setCommodity(rs.getString(3));
                ord.setNum(rs.getInt(4));
                ord.setTime(rs.getString(5).substring(0, 19));
                ord.setType(rs.getInt(6));
                coll.add(ord);
            }
        } catch (SQLException ex) {
            System.out.println(sql);
            System.out.println(ex.getMessage());
        } finally {
            close();
            return coll;
        }
    }

    public Collection select(int step, int page) {
        Collection coll = new ArrayList();
        int tip = step * (page - 1);
        try {
            rs = getRs(SELECT_ORDER);
            if (tip <= 0) {
                rs.beforeFirst();
            } else {
                if (!rs.absolute(tip)) {
                    rs.beforeFirst();
                }
            }
            for (int i = 1; rs.next() && i <= step; i++) {
                Order ord = new Order();
                ord.setId(rs.getString(1));
                ord.setUserid(rs.getString(2));
                ord.setCommodity(rs.getString(3));
                ord.setNum(rs.getInt(4));
                ord.setTime(rs.getString(5).substring(0, 19));
                ord.setType(rs.getInt(6));
                coll.add(ord);
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        } finally {
            close();
            return coll;
        }
    }
}