package com.cargo.crotrol;

import org.apache.struts.action.*;
import javax.servlet.http.*;
import com.cargo.filter.Line;
import java.util.Collection;
import java.util.ArrayList;
import java.sql.ResultSet;
import com.cargo.db.Conn;
import com.cargo.db.Userdb;
import com.cargo.model.User;
import java.util.Iterator;
import com.cargo.db.Keywords;
import java.sql.SQLException;

/**
 * User.address:在這里用來儲蓄消費總金額
 * User.tel:在這里用來儲蓄排序名次
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: MR</p>
 * @author BWM
 * @version 1.0
 */
public class ClientAction extends Action implements Keywords {
    private ActionForward forward = new ActionForward();
    private Line line = new Line();
    private Conn db = new Conn();
    private ResultSet rs;
    private Userdb userdb = new Userdb();
    //統計用戶消費
    private Collection coll;
    //獲取用戶信息
    private Collection ucoll;
    //壘加之后的信息
    private Collection ccoll;
    public ActionForward perform(ActionMapping actionMapping, ActionForm actionForm,
            HttpServletRequest request, HttpServletResponse httpServletResponse) {
        forward = line.down("id", actionMapping, request, "errors");
        if (forward != null && forward.getName().equals("errors")) {
            return forward;
        }
        //統計當前用戶的銷售額
        String sql = SELECT + "userid,price,num" + FROM + "tb_ware as a,tb_order as b" + WHERE +
                     "wareid=a.id order by userid";
        rs = db.getRs(sql);
        String userid = "";
        float flsum = (float) 0;
        try {
            coll = new ArrayList();
            while (rs.next()) {

                if (rs.getString(1).equals(userid)) {
                    flsum += rs.getFloat(2) * rs.getInt(3);
                } else {
                    User user = new User();
                    user.setUserid(userid);
                    user.setAddress(new Float(flsum).toString());
                    if (userid != null && userid.length() > 0) {
                        coll.add(user);
                    }
                    userid = rs.getString(1);
                    flsum = rs.getFloat(2) * rs.getInt(3);
                }
            }
            User user = new User();
            user.setUserid(userid);
            user.setAddress(new Float(flsum).toString());
            coll.add(user);
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
            System.out.println(sql);
        }
        db.close();
        //根據coll中的值獲取用戶信息
        ccoll = new ArrayList();
        ucoll = new ArrayList();
        if (coll != null && !coll.isEmpty()) {
            Iterator it = coll.iterator();
            while (it.hasNext()) {
                User user = (User) it.next();
                ucoll = userdb.select(WHERE + "id='" + user.getUserid() + "'");
                if (ucoll != null && !ucoll.isEmpty()) {
                    Iterator uit = ucoll.iterator();
                    if (uit.hasNext()) {
                        User uuser = (User) uit.next();
                        user.setName(uuser.getName());
                        user.setArea(uuser.getArea());
                    }
                }
                ccoll.add(user);
            }
        }
        //排序
        ucoll = new ArrayList();
        User remove = new User();
        remove.setAddress("0");
        float f1, f2;
        int t=ccoll.size();
        //控制前place=10名
        for (int i = 0; i <PLACE&&i<t; i++) {
            if (ccoll != null && !ccoll.isEmpty()) {
                Iterator it = ccoll.iterator();
                while (it.hasNext()) {
                    User u = (User) it.next();
                    f1 = new Float(u.getAddress()).floatValue();
                    f2 = new Float(remove.getAddress()).floatValue();
                    if (f1 >= f2) {
                        remove = u;
                        remove.setPlace(i+1);
                    }
                }
            }
            ucoll.add(remove);
            ccoll.remove(remove);
            remove = new User();
            remove.setAddress("0");
        }
        request.setAttribute("client", ucoll);
        return actionMapping.findForward("success");
    }
}