package com.cnd3b.restcontroller.enterprise.activity;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cnd3b.common.Controller;
import com.cnd3b.common.D3bException;
import com.cnd3b.common.data.Row;
import com.cnd3b.common.data.Rows;
import com.cnd3b.common.data.RowsMap;
import com.cnd3b.common.data.SQLFactory;
import p2.pao.PaoRemote;
import p2.pao.PaoSetRemote;
import p2.util.P2Exception;

/**
 * 展会活动访客注册表
 */
public class activitysignup extends Controller {
    public activitysignup(JSONObject content) {
        super(content);
    }

    /**
     * 查询注册信息
     *
     * @return
     */
    public String getsignupmsglist() {
        /**
         * 过滤条件设置
         */
        StringBuffer where = new StringBuffer(" 1=1 ");
        if (content.containsKey("where")) {
            JSONObject whereObject = content.getJSONObject("where");
            if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
                where.append(" and(");
                where.append("t1.fcompname like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t1.fname like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t1.fphonenumber like'%").append(whereObject.getString("condition")).append("%' ");
                where.append(")");
            }
        }
        long tactivityid = content.getLong("tactivityid");
        SQLFactory signuplistsql = new SQLFactory(this, "访客登记信息查询", pageSize, pageNumber, "t1.createdate desc");
        signuplistsql.addParameter("siteid", siteid);
        signuplistsql.addParameter("tactivityid", tactivityid);
        signuplistsql.addParameter_SQL("where", where);
        Rows signuprows = dbConnect.runSqlQuery(signuplistsql);

        SQLFactory visitlistsql = new SQLFactory(this, "访客入场信息查询");
        visitlistsql.addParameter("siteid", siteid);
        visitlistsql.addParameter_in("tactivitysignupid", signuprows.toArrayList("tactivitysignupid"));
        RowsMap visitlistrows = dbConnect.runSqlQuery(visitlistsql).toRowsMap("tactivitysignupid");

        for (Row signuprow : signuprows) {
            Rows visitrows = visitlistrows.get(signuprow.getString("tactivitysignupid"));
            signuprow.put("visittimes", visitrows.size());
            signuprow.put("visitmsg", visitrows);
            String fquestionnaire = signuprow.getString("fquestionnaire");
            if (fquestionnaire == null || fquestionnaire.equalsIgnoreCase("")) {
                signuprow.put("fquestionnaire", "[]");
            } else {
                signuprow.put("fquestionnaire", JSONArray.parse(signuprow.getString("fquestionnaire")));
            }
        }
        return getSucReturnObject().setDataByPaging(signuprows).toString();
    }


    /**
     * 访客查询入场信息
     *
     * @return
     */
    public String getvisitmsglist() {
        long tactivityid = content.getLong("tactivityid");
        SQLFactory signuplistsql = new SQLFactory(this, "入场信息列表查询", pageSize, pageNumber, "t1.createdate desc");
        signuplistsql.addParameter("siteid", siteid);
        signuplistsql.addParameter("tactivityid", tactivityid);
        Rows signuprows = dbConnect.runSqlQuery(signuplistsql);
        return getSucReturnObject().setDataByPaging(signuprows).toString();
    }
}