CUCU2/src/custom/restcontroller/webmanage/site/site.java

package restcontroller.webmanage.site;

import com.alibaba.fastjson.JSONObject;
import common.Controller;
import common.YosException;
import common.annotation.API;
import common.annotation.CACHEING;
import common.annotation.CACHEING_CLEAN;
import common.annotation.cm;
import common.data.Row;
import common.data.Rows;
import common.data.RowsMap;
import common.data.SQLFactory;
import org.apache.commons.collections4.bag.SynchronizedSortedBag;
import org.apache.commons.lang.StringUtils;

import java.util.ArrayList;

@API(title = "企业站点管理")
public class site extends Controller {
    public site(JSONObject content) throws YosException {
        super(content);
    }

    @API(title = "站点信息查询")
    @CACHEING
    public String querySite() throws YosException {
        Row row = dbConnect.runSqlQuery(0, "select siteuid,siteid,sitename,enterprisename from sys_site where siteid='" + siteid + "'");
        row.put("attinfos", getAttachmentUrl("sys_site", row.getLong("siteuid")));
        return getSucReturnObject().setData(row).toString();
    }

    @API(title = "站点基础信息更新")
    @CACHEING_CLEAN(cms = {@cm(clazz = site.class, method = {"querySite"})})
    public String updateSite() throws YosException {
        String sitename = content.getString("sitename", "sys_site");
        String enterprisename = content.getString("enterprisename", "sys_site");
        dbConnect.runSqlUpdate("update sys_site set sitename='" + sitename + "',enterprisename='" + enterprisename + "' where siteid='" + siteid + "'");
        return querySite();
    }

    @API(title = "站点参数信息查询")
    @CACHEING
    public String querySite_Parameter() throws YosException {
        Rows rows = dbConnect.runSqlQuery("select * from sys_site_parameter where siteid='" + siteid + "'");
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("找不到站点参数").toString();
        }
        long sys_enterpriseid = 0;
        Rows sys_enterpriseRows = dbConnect.runSqlQuery("select sys_enterpriseid from sys_enterprise where siteid='" + siteid + "' and ismain=1");
        if (sys_enterpriseRows.isNotEmpty()) {
            sys_enterpriseid = sys_enterpriseRows.get(0).getLong("sys_enterpriseid");
        } else {
            sys_enterpriseid = createTableID("sys_enterprise");
            SQLFactory sys_enterpriseinsert = new SQLFactory(this, "企业新增");
            sys_enterpriseinsert.addParameter("sys_enterpriseid", sys_enterpriseid);
            sys_enterpriseinsert.addParameter("siteid", siteid);
            sys_enterpriseinsert.addParameter("enterprisename", siteid);
            sys_enterpriseinsert.addParameter("userid", userid);
            sys_enterpriseinsert.addParameter("username", username);
            dbConnect.runSqlUpdate(sys_enterpriseinsert.getSQL());
        }
        rows.get(0).put("sys_enterpriseid", sys_enterpriseid);
        return getSucReturnObject().setData(rows.get(0)).toString();
    }

    @API(title = "站点参数信息更新")
    @CACHEING_CLEAN(cms = {@cm(clazz = site.class, method = {"querySite_Parameter"})})
    public String updateSite_Parameter() throws YosException {
//        boolean password_neednum = content.getBooleanValue("password_neednum");//密码是否需要数值
//        boolean password_needspecialchar = content.getBooleanValue("password_needspecialchar");//密码是否需要特殊字符
//        int password_length = content.getInteger("password_length");//密码长度
//        boolean password_needcapital = content.getBooleanValue("password_needcapital");//密码是否需要大写英文字母
//        boolean password_needlowercase = content.getBooleanValue("password_needlowercase");//密码是否需要小写英文字母
//        boolean loginmode_phonenumber = content.getBooleanValue("loginmode_phonenumber");//是否开启短信验证码登陆
//        boolean loginmode_wechat = content.getBooleanValue("loginmode_wechat");//是否开启微信验证登陆
//        boolean loginmode_account = content.getBooleanValue("loginmode_account");//是否账号密码登陆
//
//        boolean remind_showdialog = content.getBooleanValue("remind_showdialog");//是否弹窗提醒
//        boolean remind_mail = content.getBooleanValue("remind_mail");//是否邮件提醒
//
//        SQLFactory sqlFactory = new SQLFactory(this, "修改站点参数");
//        sqlFactory.addParameter("changeuserid", userid);
//        sqlFactory.addParameter("changeby", username);
//        sqlFactory.addParameter("password_neednum", password_neednum);
//        sqlFactory.addParameter("password_needspecialchar", password_needspecialchar);
//        sqlFactory.addParameter("password_length", password_length);
//        sqlFactory.addParameter("password_needcapital", password_needcapital);
//        sqlFactory.addParameter("password_needlowercase", password_needlowercase);
//        sqlFactory.addParameter("loginmode_phonenumber", loginmode_phonenumber);
//        sqlFactory.addParameter("loginmode_wechat", loginmode_wechat);
//        sqlFactory.addParameter("loginmode_account", loginmode_account);
//        sqlFactory.addParameter("remind_showdialog", remind_showdialog);
//        sqlFactory.addParameter("remind_mail", remind_mail);
//        sqlFactory.addParameter("siteid", siteid);

        RowsMap tableColumnsMap = getTableColumns("sys_site_parameter");
        tableColumnsMap.remove("changeuserid");
        tableColumnsMap.remove("changeby");
        tableColumnsMap.remove("changedate");
        tableColumnsMap.remove("siteid");

        if (content.containsKey("isrebate") && content.getString("isrebate").equals("1")) {
            if (dbConnect.runSqlQuery("SELECT 1 from sa_rebatecategory WHERE  siteid='" + siteid + "'").isEmpty()) {
                return getErrReturnObject().setErrMsg("营销大类未设置,无法开启自动返利结算").toString();
            }
            if (dbConnect.runSqlQuery("SELECT 1 from sa_rebatescheme WHERE isused=1 and siteid='" + siteid + "'").isEmpty()) {
                return getErrReturnObject().setErrMsg("未找到启用状态的返利方案").toString();
            }
        }


        StringBuffer updateSQl = new StringBuffer();
        updateSQl.append("update sys_site_parameter set changeuserid=" + userid + ",changeby='" + username + "',changedate=now()");
        boolean isupdate = false;
        for (String key : content.keySet()) {
            if (tableColumnsMap.containsKey(key)) {
                isupdate = true;
                String column_type = tableColumnsMap.get(key).get(0).getString("column_type").toLowerCase();
                switch (column_type) {
                    case "decimal": {
                        updateSQl.append("," + key + "='" + content.getBigDecimal(key).floatValue() + "'");
                        break;
                    }
                    case "int": {
                        updateSQl.append("," + key + "=" + content.getIntValue(key));
                        break;
                    }
                    case "bigint": {
                        updateSQl.append("," + key + "=" + content.getLongValue(key));
                        break;
                    }
                    case "smallint": {
                        updateSQl.append("," + key + "=" + content.getIntValue(key));
                        break;
                    }
                    default: {
                        updateSQl.append("," + key + "='" + content.getString(key) + "'");
                        break;
                    }
                }
            }
        }
        updateSQl.append(" where siteid='" + siteid + "'");
        if (isupdate) {
            dbConnect.runSqlUpdate(updateSQl.toString());
        }
        ArrayList<String> sqlList = new ArrayList<>();
        if(StringUtils.isNotBlank(content.getString("defaultlevelprice"))){
            Rows itemrows = dbConnect.runSqlQuery("select t1.itemid,t2.price from plm_item t1 inner join sa_itemprice t2 on t1.itemid = t2.itemid AND t1.siteid = t2.siteid and t2.pricegrade='"+content.getString("defaultlevelprice")+"' where ifnull(t1.saleprice,0)=0 and t1.siteid='"+siteid+"'");
            for (Row row :itemrows){
                System.err.println("update plm_item set saleprice="+row.getBigDecimal("price")+" where itemid="+row.getLong("itemid"));
                sqlList.add("update plm_item set saleprice="+row.getBigDecimal("price")+" where itemid="+row.getLong("itemid"));
            }
        }
        dbConnect.runSqlUpdate(sqlList);
        return querySite_Parameter();
    }

    @API(title = "站点账号默认密码设置")
    public String updateSite_defaultpassword() throws YosException {
        String password_default = content.getString("password_default");//新账号默认密码
        dbConnect.runSqlUpdate("update sys_site_parameter set changeuserid='" + userid + "' , password_default='" + password_default + "' where siteid='" + siteid + "'");
        return getSucReturnObject().toString();
    }
}