md_YOS/src/custom/restcontroller/sale/creditbill/creditbilldetail.java

package restcontroller.sale.creditbill;

import beans.data.BatchDeleteErr;
import com.alibaba.fastjson.JSONArray;
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.data.QuerySQL;
import common.data.Rows;
import common.data.SQLFactory;
import restcontroller.R;

import java.util.ArrayList;


@API(title = "信用额度调整单表体")
public class creditbilldetail extends Controller {

    public creditbilldetail(JSONObject arg0) throws YosException {
        super(arg0);
        // TODO Auto-generated constructor stub
    }

    @API(title = "信用额度调整单表体新增更新", apiversion = R.ID20230104100203.v1.class,intervaltime = 200)
    @CACHEING_CLEAN(apiversions = {R.ID20221008164203.v1.class, R.ID20230104100903.v1.class})
    public String insertormodify_creditbilldetail() throws YosException {
        Long sa_creditbillid = content.getLong("sa_creditbillid");
        JSONArray enterpriseinfos = content.getJSONArray("enterpriseinfos");
        ArrayList<String> sqlList = new ArrayList<>();
        Rows rowscount = dbConnect.runSqlQuery(
                "select status,sa_creditbillid from sa_creditbill where sa_creditbillid=" + sa_creditbillid);
        if (!rowscount.isEmpty()) {
            if (!rowscount.get(0).getString("status").equals("新建")) {
                return getErrReturnObject().setErrMsg("非新建状态的信用额度调整单无法新增修改").toString();
            }
        }
        int i = 0;
        long[] sa_creditbilldetailid = createTableID("sa_creditbilldetail", enterpriseinfos.size());
        for (Object obj : enterpriseinfos) {
            JSONObject enterpriseinfo = (JSONObject) obj;
            if (enterpriseinfo.getLong("sa_creditbilldetailid") <= 0 || dbConnect.runSqlQuery(
                            "select sa_creditbilldetailid from sa_creditbilldetail where sa_creditbilldetailid="
                                    + enterpriseinfo.getLong("sa_creditbilldetailid"))
                    .isEmpty()) {
                SQLFactory saleFactory = new SQLFactory(this, "信用额度调整单表体新增");
                saleFactory.addParameter("siteid", siteid);
                saleFactory.addParameter("sa_creditbilldetailid", sa_creditbilldetailid[i]);
                saleFactory.addParameter("sa_creditbillid", sa_creditbillid);
                saleFactory.addParameter("sys_enterpriseid", enterpriseinfo.getLong("sys_enterpriseid"));
                saleFactory.addParameter("sa_accountclassid", enterpriseinfo.getLong("sa_accountclassid"));
                saleFactory.addParameter("creditquota", enterpriseinfo.getBigDecimal("creditquota"));
                saleFactory.addParameter("oldcreditquota", enterpriseinfo.getBigDecimal("oldcreditquota"));
                saleFactory.addParameter("remarks", enterpriseinfo.getStringValue("remarks"));
                sqlList.add(saleFactory.getSQL());

                i++;
            } else {
                SQLFactory saleFactory = new SQLFactory(this, "信用额度调整单表体更新");
                saleFactory.addParameter("sa_creditbilldetailid", enterpriseinfo.getLong("sa_creditbilldetailid"));
                saleFactory.addParameter("siteid", siteid);
                saleFactory.addParameter("sys_enterpriseid", enterpriseinfo.getLong("sys_enterpriseid"));
                saleFactory.addParameter("sa_accountclassid", enterpriseinfo.getLong("sa_accountclassid"));
                saleFactory.addParameter("creditquota", enterpriseinfo.getBigDecimal("creditquota"));
                saleFactory.addParameter("remarks", enterpriseinfo.getStringValue("remarks"));
                sqlList.add(saleFactory.getSQL());
            }

        }

        dbConnect.runSqlUpdate(sqlList);
        return queryCreditbilldetailList();
    }

    @API(title = "信用额度调整单表体列表查询", apiversion = R.ID20230104100903.v1.class)
    @CACHEING
    public String queryCreditbilldetailList() throws YosException {
        /*
         * 过滤条件设置
         */
        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("t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t2.phonenumber like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t2.abbreviation like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t3.accountname like'%").append(whereObject.getString("condition")).append("%' ");
                where.append("or t3.accountno like'%").append(whereObject.getString("condition")).append("%' ");
                where.append(")");
            }
        }
        Long sa_creditbillid = content.getLong("sa_creditbillid");
//        SQLFactory sqlFactory = new SQLFactory(this, "信用额度调整单表体查询", pageSize, pageNumber, pageSorting);
//        sqlFactory.addParameter_SQL("where", where);
//        sqlFactory.addParameter("sa_creditbillid", sa_creditbillid);
//        sqlFactory.addParameter("siteid", siteid);
//        Rows rows = dbConnect.runSqlQuery(sqlFactory);
        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_creditbilldetail", "sa_creditbilldetailid", "sa_creditbillid",
                "sys_enterpriseid","sa_accountclassid","creditquota","oldcreditquota");
        querySQL.setTableAlias("t1");
        querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t1.sys_enterpriseid=t2.sys_enterpriseid and t1.siteid=t2.siteid","enterprisename","abbreviation","phonenumber");
        querySQL.addJoinTable(JOINTYPE.left, "sa_accountclass", "t3", "t1.sa_accountclassid=t3.sa_accountclassid and t1.siteid=t3.siteid and t3.isused=1","accountno","accountname");
        querySQL.setSiteid(siteid);
        querySQL.setWhere("t1.sa_creditbillid",sa_creditbillid);
        querySQL.setWhere(where);
        querySQL.setPage(pageSize, pageNumber);
        Rows rows = querySQL.query();

        return getSucReturnObject().setData(rows).toString();
    }

    @API(title = "删除明细", apiversion = R.ID20230104101003.v1.class)
    @CACHEING_CLEAN(apiversions = {R.ID20221008164203.v1.class, R.ID20230104100903.v1.class})
    public String deletemx() throws YosException {

        JSONArray sa_creditbilldetailids = content.getJSONArray("sa_creditbilldetailids");
        BatchDeleteErr batchDeleteErr = BatchDeleteErr.create(this, sa_creditbilldetailids.size());
        for (Object o : sa_creditbilldetailids) {
            long sa_creditbilldetailid = Long.parseLong(o.toString());
            Rows RowsStatus = dbConnect.runSqlQuery(
                    "select t1.sa_creditbilldetailid,t2.status,t1.sa_creditbillid from sa_creditbilldetail t1 left join sa_creditbill t2 on t1.sa_creditbillid=t2.sa_creditbillid and t1.siteid=t2.siteid where t1.siteid='"
                            + siteid + "' and t1.sa_creditbilldetailid='" + sa_creditbilldetailid + "'");

            if (RowsStatus.isNotEmpty()) {
                if (!RowsStatus.get(0).getString("status").equals("新建")) {
                    batchDeleteErr.addErr(sa_creditbilldetailid, "非新建状态的信用额度调整单明细无法删除");
                    continue;
                }
            }
            ArrayList<String> list = new ArrayList<>();
            list.add("delete from sa_creditbilldetail where siteid='" + siteid
                    + "' and sa_creditbilldetailid=" + sa_creditbilldetailid);

            dbConnect.runSqlUpdate(list);
        }
        return batchDeleteErr.getReturnObject().toString();
    }

}