md_YOS/src/custom/restcontroller/webmanage/saletool/orderclue/ordercluerule.java

package restcontroller.webmanage.saletool.orderclue;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import common.Controller;
import common.YosException;
import common.annotation.API;
import common.data.*;
import common.data.db.SQLList;
import restcontroller.R;

public class ordercluerule extends Controller {

    public ordercluerule(JSONObject arg0) throws YosException {
        super(arg0);
    }

    @API(title = "销售线索分配规则-列表查询", apiversion = R.ID2026020914525201.v1.class)
    public String queryOrdercluerule() throws YosException {
        Rows rows = SQLFactory.createQuerySQL(this, "sat_ordercluerule").setSiteid(siteid).query();
        if (rows.isEmpty()) {
            SQLFactory.createInsertSQL(this, "sat_ordercluerule").insert();
            rows = SQLFactory.createQuerySQL(this, "sat_ordercluerule").setSiteid(siteid).query();
        }
        return getSucReturnObject().setData(rows).toString();
    }

    @API(title = "销售线索分配规则-明细查询", apiversion = R.ID2026020914530501.v1.class)
    public String queryOrderclueruledetail() throws YosException {
        QuerySQL orderclue_areaQuery = SQLFactory.createQuerySQL(this, "sat_orderclue_area", "sat_orderclue_areaid", "sys_enterpriseid").setTableAlias("t1");
        orderclue_areaQuery.addJoinTable(JOINTYPE.inner, "sys_enterprise", "t2", "sys_enterpriseid =:sys_enterpriseid", "enterprisename", "province", "city", "county", "address", "phonenumber", "contact", "abbreviation");
        orderclue_areaQuery.addJoinTable(JOINTYPE.inner, "sa_agents", "t3", "sys_enterpriseid=:sys_enterpriseid", "agentnum", "signingstate", "status", "signingstate");
        orderclue_areaQuery.setWhere("cluetype", "经销商");
        orderclue_areaQuery.setSiteid(siteid);
        orderclue_areaQuery.setPage(pageSize, pageNumber);
        Rows rowsdetail = orderclue_areaQuery.query();

        QuerySQL tradefieldQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_tradefield", "sys_enterpriseid").setTableAlias("t1");
        tradefieldQuery.addJoinTable(JOINTYPE.left, "sa_salearea", "t2", "t1.sa_saleareaid=t2.sa_saleareaid", "areaname");
        tradefieldQuery.setSiteid(siteid);
        tradefieldQuery.setWhere("sys_enterpriseid", rowsdetail.toArrayList("sys_enterpriseid"));
        RowsMap rowsMap = tradefieldQuery.query().toRowsMap("sys_enterpriseid");

        for (Row row : rowsdetail) {
            long sys_enterpriseid = row.getLong("sys_enterpriseid");
            if (rowsMap.containsKey(String.valueOf(sys_enterpriseid))) {
                row.put("areaname", rowsMap.get(String.valueOf(sys_enterpriseid)).get(0).getString("areaname"));
            } else {
                row.put("areaname", "");
            }
        }
        return getSucReturnObject().setData(rowsdetail).toString();
    }

    @API(title = "销售线索分配规则-更新", apiversion = R.ID2026020914531701.v1.class)
    public String updateOrderclueruleMain() throws YosException {
        Long sat_orderclueruleid = content.getLong("sat_orderclueruleid");
        Rows rows = dbConnect.runSqlQuery("select sat_orderclueruleid FROM sat_ordercluerule WHERE siteid = '" + siteid + "' AND sat_orderclueruleid = '" + sat_orderclueruleid + "'");
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("销售线索分配规则不存在，无法更新").toString();
        }
        UpdateSQL orderclueruleUpdate = SQLFactory.createUpdateSQL(this, "sat_ordercluerule");
        orderclueruleUpdate.setValue("autodistribution", content.getBooleanValue("autodistribution"));
        orderclueruleUpdate.setValue("cluelife", content.getInteger("cluelife"));
        orderclueruleUpdate.setValue("linklife", content.getInteger("linklife"));
        orderclueruleUpdate.setValue("sat_orderclueruleid", sat_orderclueruleid);
        orderclueruleUpdate.update();
        return getSucReturnObject().toString();
    }

    @API(title = "销售线索分配规则-经销商添加查询", apiversion = R.ID20221101095002.v1.class)
    public String queryEnterprise() throws YosException {
        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_agents", "agentnum", "status", "signingstate", "salearea").setTableAlias("t1");
        querySQL.addJoinTable(JOINTYPE.inner, "sys_enterprise", "t2", "sys_enterpriseid=:sys_enterpriseid", "sys_enterpriseid", "enterprisename", "province", "city", "county", "address", "phonenumber", "contact", "abbreviation");
        querySQL.setPage(pageSize, pageNumber).setSiteid(siteid);
        querySQL.setWhere("not exists(select * from sat_orderclue_area t3 where t1.sys_enterpriseid=t3.sys_enterpriseid and t1.siteid=t3.siteid)");
        Rows rows = querySQL.query();
        return getSucReturnObject().setData(rows).toString();
    }

    @API(title = "销售线索分配规则-销售线索规则分配范围新增", apiversion = R.ID2026020914533401.v1.class)
    public String insertOrderclueruleArea() throws YosException {
        JSONArray sat_orderclue_areas = content.getJSONArray("sat_orderclue_areas");
        SQLList sqlDump = new SQLList();
        for (Object object : sat_orderclue_areas) {
            JSONObject jsonobject = (JSONObject) object;
            InsertSQL orderclue_areainsert = SQLFactory.createInsertSQL(this, "sat_orderclue_area");
            orderclue_areainsert.setValue("cluetype", content.getString("cluetype"));
            orderclue_areainsert.setValue("hrid", jsonobject.getLongValue("hrid"));
            orderclue_areainsert.setValue("sys_enterpriseid", jsonobject.getLongValue("sys_enterpriseid"));
            sqlDump.add(orderclue_areainsert);
        }
        if (!sqlDump.isEmpty()) {
            sqlDump.commit(this);
            return queryOrderclueruledetail();
        } else {
            return getErrReturnObject().toString();
        }
    }

    @API(title = "销售线索分配规则-规则删除", apiversion = R.ID20221101100602.v1.class)
    public String deletemx() throws YosException {
        Long sat_orderclue_areaid = content.getLong("sat_orderclue_areaid");
        SQLFactory.createDeleteSQL(this, "sat_orderclue_area").setUniqueid(sat_orderclue_areaid).delete();
        return getSucReturnObject().toString();
    }
}