package beans.accountbalance; import beans.remind.Remind; import com.alibaba.fastjson.JSONObject; import common.BaseClass; import common.Controller; import common.YosException; import common.data.Rows; import common.data.SQLFactory; import org.apache.commons.lang.StringUtils; import restcontroller.webmanage.executorService.Executor; import java.math.BigDecimal; import java.util.ArrayList; import java.util.HashMap; public class Accountbalance extends BaseClass { /** * @param controller * @param sys_enterpriseid //企业id * @param sa_accountclassid //营销账户id * @return AccountbalanceEntity //营销账户实体（可用余额（getCanuseamount）,账户余额(getBalance),信用额度(getCreditquota)） * @throws YosException */ public static AccountbalanceEntity getAccountbalance(Controller controller, long sys_enterpriseid, long sa_accountclassid) throws YosException { SQLFactory sqlFactory = new SQLFactory(new Accountbalance(), "账户余额查询"); sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); sqlFactory.addParameter("siteid", controller.siteid); Rows rows = controller.dbConnect.runSqlQuery(sqlFactory.getSQL()); AccountbalanceEntity accountbalanceEntity = new AccountbalanceEntity(); if (!rows.isEmpty()) { accountbalanceEntity.setBalance(rows.get(0).getBigDecimal("balance")); accountbalanceEntity.setCreditquota(rows.get(0).getBigDecimal("creditquota")); accountbalanceEntity.setDiscountamount(rows.get(0).getBigDecimal("discountamount")); accountbalanceEntity.setFreezamount(rows.get(0).getBigDecimal("freezamount")); accountbalanceEntity.setCanuseamount(rows.get(0).getBigDecimal("balance").add(rows.get(0).getBigDecimal("creditquota")).add(rows.get(0).getBigDecimal("discountamount")).subtract(rows.get(0).getBigDecimal("freezamount"))); } return accountbalanceEntity; } /** * 判断当前账户余额是否足够 * * @param controller * @param sys_enterpriseid * @param sa_accountclassid * @param amount * @return * @throws YosException */ public static boolean judgeBalance(Controller controller, long sys_enterpriseid, long sa_accountclassid, BigDecimal amount) throws YosException { AccountbalanceEntity accountbalanceEntity = getAccountbalance(controller, sys_enterpriseid, sa_accountclassid); BigDecimal canuseamount = accountbalanceEntity.getCanuseamount(); if (canuseamount != null) { if (canuseamount.compareTo(amount) == 1 || canuseamount.compareTo(amount) == 0) { return true; } else { return false; } } else { return false; } } /** * 返回不足金额 * * @param controller * @param sys_enterpriseid * @param sa_accountclassid * @param amount * @return * @throws YosException */ public static BigDecimal InsufficientBalance(Controller controller, long sys_enterpriseid, long sa_accountclassid, BigDecimal amount) throws YosException { AccountbalanceEntity accountbalanceEntity = getAccountbalance(controller, sys_enterpriseid, sa_accountclassid); BigDecimal canuseamount = accountbalanceEntity.getCanuseamount(); if (canuseamount != null) { if (canuseamount.compareTo(amount) == 1 || canuseamount.compareTo(amount) == 0) { return BigDecimal.ZERO; } else { return amount.subtract(canuseamount); } } else { return amount; } } /** * 创建收入凭证(返回SQL) * * @param controller * @param sys_enterpriseid 企业id * @param sa_accountclassid 账户id * @param cashbillEntity 收支凭证实体 * @param ischeck 是否审核 * @return * @throws YosException */ public static JSONObject createCashbillIncome(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck, boolean isupdatek3flag) throws YosException { ArrayList sqlList = new ArrayList<>(); long sa_cashbillid = controller.createTableID("sa_cashbill"); String billcode = controller.createBillCode("cashbill"); SQLFactory sqlFactory = new SQLFactory(new Accountbalance(), "收支凭证新增"); sqlFactory.addParameter("billno", billcode); sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); sqlFactory.addParameter("type", 1); sqlFactory.addParameter("siteid", controller.siteid); sqlFactory.addParameter("remarks", cashbillEntity.getRemarks()); sqlFactory.addParameter("amount", cashbillEntity.getAmount()); sqlFactory.addParameter("discountamount", cashbillEntity.getDiscountamountamount()); sqlFactory.addParameter("sa_cashbillid", sa_cashbillid); sqlFactory.addParameter("userid", controller.userid); sqlFactory.addParameter("username", controller.username); sqlFactory.addParameter("ownertable", cashbillEntity.getOwnertable()); sqlFactory.addParameter("ownerid", cashbillEntity.getOwnerid()); sqlFactory.addParameter("source", cashbillEntity.getSource()); sqlFactory.addParameter("sourcenote", cashbillEntity.getSourcenote()); sqlFactory.addParameter("sa_cashbillid_rebate", "null"); sqlFactory.addParameter("class", cashbillEntity.getType()); sqlFactory.addParameter("subclass", cashbillEntity.getTypemx()); sqlFactory.addParameter("period", cashbillEntity.getPeriod()); if (ischeck) { BigDecimal balance = BigDecimal.ZERO; //当前账户余额 sqlFactory.addParameter("status", "审核"); if (isupdatek3flag) { sqlFactory.addParameter("updatek3flag", "0"); } else { sqlFactory.addParameter("updatek3flag", ""); } sqlFactory.addParameter("checkby", StringUtils.isBlank(controller.username) ? "autocheck" : controller.username); sqlFactory.addParameter_SQL("checkdate", "CURRENT_TIME"); // 审核逻辑判断 Rows rowsaccountbalance = controller.dbConnect.runSqlQuery( "select sa_accountbalanceid,balance,creditquota,discountamount from sa_accountbalance where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); if (rowsaccountbalance.isEmpty()) { SQLFactory accountbalanceaddSqlFactory = new SQLFactory(new Accountbalance(), "营销账户余额新增"); accountbalanceaddSqlFactory.addParameter("sa_accountbalanceid", controller.createTableID("sa_accountbalance")); accountbalanceaddSqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); accountbalanceaddSqlFactory.addParameter("sa_accountclassid", sa_accountclassid); accountbalanceaddSqlFactory.addParameter("siteid", controller.siteid); accountbalanceaddSqlFactory.addParameter("balance", cashbillEntity.getAmount()); accountbalanceaddSqlFactory.addParameter("discountamount", cashbillEntity.getDiscountamountamount()); accountbalanceaddSqlFactory.addParameter("userid", controller.userid); accountbalanceaddSqlFactory.addParameter("username", controller.username); balance = cashbillEntity.getAmount(); sqlList.add(accountbalanceaddSqlFactory.getSQL()); } else { BigDecimal newbalance = cashbillEntity.getAmount().add(rowsaccountbalance.get(0).getBigDecimal("balance")); BigDecimal newdiscountamount = cashbillEntity.getDiscountamountamount().add(rowsaccountbalance.get(0).getBigDecimal("discountamount")); sqlList.add("update sa_accountbalance set balance='" + newbalance + "',discountamount='"+newdiscountamount+"',changedate=CURRENT_TIME,changeby ='" + controller.username + "',changeuserid='" + controller.userid + "' where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); balance = newbalance; } sqlFactory.addParameter("balance", balance); Rows accountclassrows = controller.dbConnect.runSqlQuery("select * from sa_accountclass where siteid='" + controller.siteid + "' and sa_accountclassid=" + sa_accountclassid); if (!accountclassrows.isEmpty()) { String content = "您的" + accountclassrows.get(0).getString("accountname") + "已收入【" + cashbillEntity.getAmount() + "】元"; new Accountbalance().sendMsg(controller, content, cashbillEntity.getOwnerid(), sys_enterpriseid); } } else { sqlFactory.addParameter("status", "新建"); sqlFactory.addParameter("checkby", "null"); sqlFactory.addParameter("checkdate", "null"); sqlFactory.addParameter("updatek3flag", ""); sqlFactory.addParameter("balance", 0); } sqlList.add(sqlFactory.getSQL()); JSONObject jsonObject = new JSONObject(); jsonObject.put("sa_cashbillid", sa_cashbillid); jsonObject.put("sqlList", sqlList); return jsonObject; } /** * 创建支出凭证(返回SQL) * * @param controller * @param sys_enterpriseid 企业id * @param sa_accountclassid 账户id * @param cashbillEntity 收支凭证实体 * @param ischeck 是否审核 * @return * @throws YosException */ public static JSONObject createCashbillPay(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck) throws YosException { ArrayList sqlList = new ArrayList<>(); long sa_cashbillid = controller.createTableID("sa_cashbill"); String billcode = controller.createBillCode("cashbill"); SQLFactory sqlFactory = new SQLFactory(new Accountbalance(), "收支凭证新增"); sqlFactory.addParameter("billno", billcode); sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); sqlFactory.addParameter("type", 0); sqlFactory.addParameter("siteid", controller.siteid); sqlFactory.addParameter("remarks", cashbillEntity.getRemarks()); sqlFactory.addParameter("amount", cashbillEntity.getAmount()); sqlFactory.addParameter("discountamount", cashbillEntity.getDiscountamountamount()); sqlFactory.addParameter("sa_cashbillid", sa_cashbillid); sqlFactory.addParameter("userid", controller.userid); sqlFactory.addParameter("username", controller.username); sqlFactory.addParameter("ownertable", cashbillEntity.getOwnertable()); sqlFactory.addParameter("ownerid", cashbillEntity.getOwnerid()); sqlFactory.addParameter("source", cashbillEntity.getSource()); sqlFactory.addParameter("sourcenote", cashbillEntity.getSourcenote()); sqlFactory.addParameter("class", cashbillEntity.getType()); sqlFactory.addParameter("subclass", cashbillEntity.getTypemx()); sqlFactory.addParameter("sa_cashbillid_rebate", "null"); sqlFactory.addParameter("updatek3flag", ""); sqlFactory.addParameter("period", cashbillEntity.getPeriod()); if (ischeck) { BigDecimal balance = BigDecimal.ZERO; //当前账户余额 sqlFactory.addParameter("status", "审核"); sqlFactory.addParameter("checkby", controller.username); sqlFactory.addParameter_SQL("checkdate", "CURRENT_TIME"); // 审核逻辑判断 Rows rowsaccountbalance = controller.dbConnect.runSqlQuery( "select sa_accountbalanceid,balance,creditquota,discountamount from sa_accountbalance where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); if (rowsaccountbalance.isEmpty()) { // SQLFactory sqlFactory = new SQLFactory(this, "营销账户余额新增"); // sqlFactory.addParameter("sa_accountbalanceid", createTableID("sa_accountbalance")); // sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); // sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); // sqlFactory.addParameter("siteid", siteid); // sqlFactory.addParameter("balance", -rows.get(0).getLong("amount")); // sqlFactory.addParameter("userid", userid); // sqlFactory.addParameter("username", username); // sqlList.add(sqlFactory.getSQL()); throw new YosException(false, "该营销账户不存在，支出凭证无法审核"); } else { BigDecimal canuseamount = rowsaccountbalance.get(0).getBigDecimal("creditquota").add(rowsaccountbalance.get(0).getBigDecimal("balance")).add(rowsaccountbalance.get(0).getBigDecimal("discountamount")); if ((cashbillEntity.getAmount().add(cashbillEntity.getDiscountamountamount())).compareTo(canuseamount) == 1) { throw new YosException(false, "该营销账户可用余额不足，支出凭证无法审核"); } BigDecimal newbalance = rowsaccountbalance.get(0).getBigDecimal("balance").subtract(cashbillEntity.getAmount()); BigDecimal newdiscountamount = rowsaccountbalance.get(0).getBigDecimal("discountamount").subtract(cashbillEntity.getDiscountamountamount()); sqlList.add("update sa_accountbalance set balance='" + newbalance + "',discountamount='"+newdiscountamount+"',changedate=CURRENT_TIME,changeby ='" + controller.username + "',changeuserid='" + controller.userid + "' where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); balance = newbalance; } sqlFactory.addParameter("balance", balance); Rows accountclassrows = controller.dbConnect.runSqlQuery("select * from sa_accountclass where siteid='" + controller.siteid + "' and sa_accountclassid=" + sa_accountclassid); if (!accountclassrows.isEmpty()) { String content = "您的" + accountclassrows.get(0).getString("accountname") + "已支出【" + cashbillEntity.getAmount() + "】元"; new Accountbalance().sendMsg(controller, content, cashbillEntity.getOwnerid(), sys_enterpriseid); } } else { sqlFactory.addParameter("status", "新建"); sqlFactory.addParameter("checkby", ""); sqlFactory.addParameter("checkdate", ""); sqlFactory.addParameter("balance", 0); sqlFactory.addParameter("updatek3flag", ""); } sqlList.add(sqlFactory.getSQL()); JSONObject jsonObject = new JSONObject(); jsonObject.put("sa_cashbillid", sa_cashbillid); jsonObject.put("sqlList", sqlList); return jsonObject; } //订单手动关闭专用 public static JSONObject createCashbillPay2(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck) throws YosException { ArrayList sqlList = new ArrayList<>(); long sa_cashbillid = controller.createTableID("sa_cashbill"); String billcode = controller.createBillCode("cashbill"); SQLFactory sqlFactory = new SQLFactory(new Accountbalance(), "收支凭证新增"); sqlFactory.addParameter("billno", billcode); sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); sqlFactory.addParameter("type", 0); sqlFactory.addParameter("siteid", controller.siteid); sqlFactory.addParameter("remarks", cashbillEntity.getRemarks()); sqlFactory.addParameter("amount", cashbillEntity.getAmount()); sqlFactory.addParameter("discountamount", cashbillEntity.getDiscountamountamount()); sqlFactory.addParameter("sa_cashbillid", sa_cashbillid); sqlFactory.addParameter("userid", controller.userid); sqlFactory.addParameter("username", controller.username); sqlFactory.addParameter("ownertable", cashbillEntity.getOwnertable()); sqlFactory.addParameter("ownerid", cashbillEntity.getOwnerid()); sqlFactory.addParameter("source", cashbillEntity.getSource()); sqlFactory.addParameter("sourcenote", cashbillEntity.getSourcenote()); sqlFactory.addParameter("class", cashbillEntity.getType()); sqlFactory.addParameter("subclass", cashbillEntity.getTypemx()); sqlFactory.addParameter("sa_cashbillid_rebate", "null"); sqlFactory.addParameter("updatek3flag", ""); sqlFactory.addParameter("period", cashbillEntity.getPeriod()); if (ischeck) { BigDecimal balance = BigDecimal.ZERO; //当前账户余额 sqlFactory.addParameter("status", "审核"); sqlFactory.addParameter("checkby", controller.username); sqlFactory.addParameter_SQL("checkdate", "CURRENT_TIME"); // 审核逻辑判断 Rows rowsaccountbalance = controller.dbConnect.runSqlQuery( "select sa_accountbalanceid,balance,creditquota from sa_accountbalance where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); if (rowsaccountbalance.isEmpty()) { // SQLFactory sqlFactory = new SQLFactory(this, "营销账户余额新增"); // sqlFactory.addParameter("sa_accountbalanceid", createTableID("sa_accountbalance")); // sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); // sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); // sqlFactory.addParameter("siteid", siteid); // sqlFactory.addParameter("balance", -rows.get(0).getLong("amount")); // sqlFactory.addParameter("userid", userid); // sqlFactory.addParameter("username", username); // sqlList.add(sqlFactory.getSQL()); throw new YosException(false, "该营销账户不存在，支出凭证无法审核"); } else { // BigDecimal canuseamount = rowsaccountbalance.get(0).getBigDecimal("creditquota").add(rowsaccountbalance.get(0).getBigDecimal("balance")); // if (cashbillEntity.getAmount().compareTo(canuseamount) == 1) { // throw new YosException(false, "该营销账户可用余额不足，支出凭证无法审核"); // } BigDecimal newbalance = rowsaccountbalance.get(0).getBigDecimal("balance").subtract(cashbillEntity.getAmount()); BigDecimal newdiscountamount = rowsaccountbalance.get(0).getBigDecimal("discountamount").subtract(cashbillEntity.getDiscountamountamount()); sqlList.add("update sa_accountbalance set balance='" + newbalance + "',discountamount='"+newdiscountamount+"',changedate=CURRENT_TIME,changeby ='" + controller.username + "',changeuserid='" + controller.userid + "' where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); balance = newbalance; } sqlFactory.addParameter("balance", balance); Rows accountclassrows = controller.dbConnect.runSqlQuery("select * from sa_accountclass where siteid='" + controller.siteid + "' and sa_accountclassid=" + sa_accountclassid); if (!accountclassrows.isEmpty()) { String content = "您的" + accountclassrows.get(0).getString("accountname") + "已支出【" + cashbillEntity.getAmount() + "】元"; new Accountbalance().sendMsg(controller, content, cashbillEntity.getOwnerid(), sys_enterpriseid); } } else { sqlFactory.addParameter("status", "新建"); sqlFactory.addParameter("checkby", ""); sqlFactory.addParameter("checkdate", ""); sqlFactory.addParameter("balance", 0); sqlFactory.addParameter("updatek3flag", ""); } sqlList.add(sqlFactory.getSQL()); JSONObject jsonObject = new JSONObject(); jsonObject.put("sa_cashbillid", sa_cashbillid); jsonObject.put("sqlList", sqlList); return jsonObject; } public static JSONObject createCashbillPay(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck, Long sa_cashbillid_rebate) throws YosException { ArrayList sqlList = new ArrayList<>(); long sa_cashbillid = controller.createTableID("sa_cashbill"); String billcode = controller.createBillCode("cashbill"); SQLFactory sqlFactory = new SQLFactory(new Accountbalance(), "收支凭证新增"); sqlFactory.addParameter("billno", billcode); sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid); sqlFactory.addParameter("sa_accountclassid", sa_accountclassid); sqlFactory.addParameter("type", 0); sqlFactory.addParameter("siteid", controller.siteid); sqlFactory.addParameter("remarks", cashbillEntity.getRemarks()); sqlFactory.addParameter("amount", cashbillEntity.getAmount()); sqlFactory.addParameter("discountamount", cashbillEntity.getDiscountamountamount()); sqlFactory.addParameter("sa_cashbillid", sa_cashbillid); sqlFactory.addParameter("userid", controller.userid); sqlFactory.addParameter("username", controller.username); sqlFactory.addParameter("ownertable", cashbillEntity.getOwnertable()); sqlFactory.addParameter("ownerid", cashbillEntity.getOwnerid()); sqlFactory.addParameter("source", cashbillEntity.getSource()); sqlFactory.addParameter("sourcenote", cashbillEntity.getSourcenote()); sqlFactory.addParameter("sa_cashbillid_rebate", sa_cashbillid_rebate); sqlFactory.addParameter("class", cashbillEntity.getType()); sqlFactory.addParameter("subclass", cashbillEntity.getTypemx()); sqlFactory.addParameter("period", cashbillEntity.getPeriod()); if (ischeck) { BigDecimal balance = BigDecimal.ZERO; //当前账户余额 sqlFactory.addParameter("status", "审核"); sqlFactory.addParameter("checkby", controller.username); sqlFactory.addParameter_SQL("checkdate", "CURRENT_TIME"); // 审核逻辑判断 Rows rowsaccountbalance = controller.dbConnect.runSqlQuery( "select sa_accountbalanceid,balance,creditquota from sa_accountbalance where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); if (rowsaccountbalance.isEmpty()) { throw new YosException(false, "该营销账户不存在，支出凭证无法审核"); } else { BigDecimal canuseamount = rowsaccountbalance.get(0).getBigDecimal("creditquota").add(rowsaccountbalance.get(0).getBigDecimal("balance")); if (cashbillEntity.getAmount().compareTo(canuseamount) == 1 ) { throw new YosException(false, "该营销账户可用余额不足，支出凭证无法审核"); } BigDecimal newbalance = rowsaccountbalance.get(0).getBigDecimal("balance").subtract(cashbillEntity.getAmount()); BigDecimal newdiscountamount = rowsaccountbalance.get(0).getBigDecimal("discountamount").subtract(cashbillEntity.getDiscountamountamount()); sqlList.add("update sa_accountbalance set balance='" + newbalance + "',discountamount='"+newdiscountamount+"',changedate=CURRENT_TIME,changeby ='" + controller.username + "',changeuserid='" + controller.userid + "' where sys_enterpriseid ='" + sys_enterpriseid + "' and sa_accountclassid='" + sa_accountclassid + "' and siteid='" + controller.siteid + "'"); balance = newbalance; } sqlFactory.addParameter("balance", balance); Rows accountclassrows = controller.dbConnect.runSqlQuery("select * from sa_accountclass where siteid='" + controller.siteid + "' and sa_accountclassid=" + sa_accountclassid); if (!accountclassrows.isEmpty()) { String content = "您的" + accountclassrows.get(0).getString("accountname") + "已支出【" + cashbillEntity.getAmount() + "】元"; new Accountbalance().sendMsg(controller, content, cashbillEntity.getOwnerid(), sys_enterpriseid); } } else { sqlFactory.addParameter("status", "新建"); sqlFactory.addParameter("checkby", ""); sqlFactory.addParameter("checkdate", ""); sqlFactory.addParameter("balance", 0); } sqlList.add(sqlFactory.getSQL()); JSONObject jsonObject = new JSONObject(); jsonObject.put("sa_cashbillid", sa_cashbillid); jsonObject.put("sqlList", sqlList); return jsonObject; } /** * 创建收入凭证(直接执行SQL语句) * * @param controller * @param sys_enterpriseid 企业id * @param sa_accountclassid 账户id * @param cashbillEntity 凭证实体 * @param ischeck 是否审核 * @throws YosException */ public static void createCashbillIncomeWithoutSQL(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck, boolean isupdatek3flag) throws YosException { JSONObject jsonObject = createCashbillIncome(controller, sys_enterpriseid, sa_accountclassid, cashbillEntity, ischeck, isupdatek3flag); controller.dbConnect.runSqlUpdate(new ArrayList<>(jsonObject.getJSONArray("sqlList").toJavaList(String.class))); if (ischeck) { remindSend(controller, sys_enterpriseid, jsonObject.getLong("sa_cashbillid")); } } /** * 创建支出凭证(直接执行SQL语句) * * @param controller * @param sys_enterpriseid 企业id * @param sa_accountclassid 账户id * @param cashbillEntity 凭证实体 * @param ischeck 是否审核 * @throws YosException */ public static void createCashbillPayWithoutSQL(Controller controller, long sys_enterpriseid, long sa_accountclassid, CashbillEntity cashbillEntity, boolean ischeck) throws YosException { JSONObject jsonObject = createCashbillPay(controller, sys_enterpriseid, sa_accountclassid, cashbillEntity, ischeck); controller.dbConnect.runSqlUpdate(new ArrayList<>(jsonObject.getJSONArray("sqlList").toJavaList(String.class))); if (ischeck) { remindSend(controller, sys_enterpriseid, jsonObject.getLong("sa_cashbillid")); } } /** * 查询企业审核通过的有效期内的返利金余额 * * @param controller * @param sys_enterpriseid * @return * @throws YosException */ public static BigDecimal getRebateBalance(Controller controller, Long sys_enterpriseid) throws YosException { Rows rows = controller.dbConnect.runSqlQuery("SELECT sum(rebate_balance) rebate_balance from sa_cashbill WHERE class='返利金' and STATUS ='审核' and rebate_enddate>=CURRENT_TIME and sys_enterpriseid= " + sys_enterpriseid + " and siteid ='" + controller.siteid + "'"); return rows.get(0).getBigDecimal("rebate_balance"); } /** * 更新经销商装修返利表金额 * * @param controller * @param sys_enterpriseid * @param isrebateupdate * @param amount * @return * @throws YosException */ public static ArrayList rebateupdate(Controller controller, Long sys_enterpriseid, boolean isrebateupdate, BigDecimal amount) throws YosException { ArrayList sqlList = new ArrayList<>(); Rows rows = controller.dbConnect.runSqlQuery("SELECT * from sa_agentdecorationtrebate where sys_enterpriseid= " + sys_enterpriseid + " and siteid ='" + controller.siteid + "'"); if (!rows.isEmpty()) { if (isrebateupdate) { sqlList.add("update sa_agentdecorationtrebate set balance=" + rows.get(0).getBigDecimal("balance").subtract(amount) + " where sa_agentdecorationtrebateid=" + rows.get(0).getLong("sa_agentdecorationtrebateid") + " and siteid ='" + controller.siteid + "'"); } else { sqlList.add("update sa_agentdecorationtrebate set balance=" + rows.get(0).getBigDecimal("balance").add(amount) + " where sa_agentdecorationtrebateid=" + rows.get(0).getLong("sa_agentdecorationtrebateid") + " and siteid ='" + controller.siteid + "'"); } } return sqlList; } public void sendMsg(Controller controller, String content, Long sa_orderid, Long sys_enterpriseid) throws YosException { ArrayList userList = getEnterpriseHrs(sys_enterpriseid, controller.siteid).toArrayList("userid", new ArrayList<>()); Remind remind = new Remind(controller); remind.setTitle("凭证消息"); remind.setContent(content); remind.setType("应用"); remind.setObjectid(sa_orderid); remind.setObjectname("sa_order"); remind.setTouserid(userList); remind.createSys_message(); } public void sendMsg(String siteid, String content, Long sa_orderid, Long sys_enterpriseid) throws YosException { ArrayList userList = getEnterpriseHrs(sys_enterpriseid, siteid).toArrayList("userid", new ArrayList<>()); Remind remind = new Remind(siteid); remind.setTitle("凭证消息"); remind.setContent(content); remind.setType("应用"); remind.setObjectid(sa_orderid); remind.setObjectname("sa_order"); remind.setTouserid(userList); remind.createSys_message(); } public static void remindSend(Controller controller, Long sys_enterpriseid, Long sa_cashbillid) throws YosException { if (sa_cashbillid != 0) { String siteid = controller.siteid; Rows enterpriseHrRows = controller.dbConnect.runSqlQuery("select userid from sys_enterprise_hr where siteid='" + siteid + "' and isleader=1 and sys_enterpriseid=" + sys_enterpriseid); ArrayList extraUserList = enterpriseHrRows.toArrayList("userid", new ArrayList<>()); HashMap extradata = new HashMap<>(); extradata.put("extraUserList", extraUserList); Executor.sendEml(controller, "cashbill_check", sa_cashbillid, siteid, extradata); } } }