CUCU2/src/custom/restcontroller/webmanage/sale/logistics/LSALogistics.java

package restcontroller.webmanage.sale.logistics;

import beans.datacontrllog.DataContrlLog;
import beans.order.Order;
import beans.parameter.Parameter;
import beans.remind.Remind;
import beans.salearea.SaleArea;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.huaweicloud.sdk.meeting.v1.model.SearchQosHistoryMeetingsRequest;
import common.Controller;
import common.YosException;
import common.annotation.API;
import common.annotation.CACHEING;
import common.annotation.CACHEING_CLEAN;
import common.data.*;
import restcontroller.R;
import restcontroller.sale.promotion.promotion;

import java.math.BigDecimal;
import java.util.ArrayList;

import static restcontroller.webmanage.sale.logistics.LSALogisticsHelper.*;

/**
 * 物流单(LSA)
 */
public class LSALogistics extends Controller {
    /**
     * 构造函数
     *
     * @param content
     */
    public LSALogistics(JSONObject content) throws YosException {
        super(content);
    }

    @API(title = "新增或更新", apiversion = R.ID20230719165802.v1.class)
    @CACHEING_CLEAN(apiClass = {LSALogistics.class})
    public String insertOrUpdate() throws YosException {
        //物流单ID
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");
        //经销商编号（选择经销商）
        Long sys_enterpriseid = content.getLong("sys_enterpriseid");
        //出入库表货品明细
        JSONArray items = content.getJSONArray("items");
        String billdate = content.getStringValue("billdate");
        if(billdate.equals("")){
            return getErrReturnObject().setErrMsg("单据日期不能为空").toString();
        }

        ArrayList<String> sqlList = new ArrayList<>();
        if (sys_enterpriseid <= 0 || isEnterpriseEmpty(this)) {
            return getErrReturnObject().setErrMsg("未选择企业").toString();
        }
        Rows rows = LSALogisticsHelper.getLogisticsRows(this);

        if (sa_logisticsid <= 0 || rows.isEmpty()) {
            sa_logisticsid = createTableID("sa_logistics");
            sqlList.add(insert(this, sa_logisticsid).getSQL());
            sqlList.add(DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "新增", "物流单-新增:" + sa_logisticsid).getSQL());
            content.put("sa_logisticsid", sa_logisticsid);
        } else {
            if (!rows.get(0).getString("status").equals("新建")) {
                return getErrReturnObject().setErrMsg("该物流单为非新建状态，无法更改").toString();
            }
            sqlList.add(update(this, sa_logisticsid).getSQL());
            sqlList.add(DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "更新", "物流单-更新:" + sa_logisticsid).getSQL());
        }

        //更新送货列表
        ArrayList<Long> st_stockbill_itemsids = new ArrayList<>();
        for (Object obj : items) {
            JSONObject object = (JSONObject) obj;
            Long st_stockbill_itemsid = object.getLongValue("st_stockbill_itemsid");
            BigDecimal qty = object.getBigDecimalValue("qty");
            if (isStockbillItemsEmpty(this, st_stockbill_itemsid)) {
                System.err.println("出库单不存在");
                return getErrReturnObject().setErrMsg("出库单不存在").toString();
            }
            if (isOut(this, st_stockbill_itemsid, qty)) {
                return getErrReturnObject().setErrMsg("超出最大可送货数量").toString();
            }
            if (isLogisticsItemEmpty(this, st_stockbill_itemsid)) {
                sqlList.add(insertLogisticsItem(this, object).getSQL());
            } else {
                sqlList.add(updateLogisticsItem(this, object).getSQL());
            }
            st_stockbill_itemsids.add(st_stockbill_itemsid);
        }
        dbConnect.runSqlUpdate(sqlList);
        //删除送货
        if (st_stockbill_itemsids.size() > 0) {
            deleteLogisticsItem(this, st_stockbill_itemsids);
        }
        return detail();
    }

    @API(title = "添加送货明细", apiversion = R.ID20230720141602.v1.class)
    @CACHEING_CLEAN(apiClass = {LSALogistics.class})
    public String addMX() throws YosException {
        //物流单ID
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");
        //出入库表货品明细
        JSONArray items = content.getJSONArray("items");

        ArrayList<String> sqlList = new ArrayList<>();
        for (Object obj : items) {
            JSONObject object = (JSONObject) obj;
            Long st_stockbill_itemsid = object.getLongValue("st_stockbill_itemsid");
            BigDecimal qty = object.getBigDecimalValue("qty");
            if (isStockbillItemsEmpty(this, st_stockbill_itemsid)) {
                System.err.println("出库单不存在");
                return getErrReturnObject().setErrMsg("出库单不存在").toString();
            }
            if (isOut(this, st_stockbill_itemsid, qty)) {
                return getErrReturnObject().setErrMsg("超出最大可送货数量").toString();
            }
            if (isLogisticsItemEmpty(this, st_stockbill_itemsid)) {
                sqlList.add(insertLogisticsItem(this, object).getSQL());
            } else {
                sqlList.add(updateLogisticsItem(this, object).getSQL());
            }
        }
        dbConnect.runSqlUpdate(sqlList);
        return getSucReturnObject().toString();
    }

    @API(title = "删除送货明细", apiversion = R.ID20230720141902.v1.class)
    @CACHEING_CLEAN(apiClass = {LSALogistics.class})
    public String delete() throws YosException {
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");
        Rows rows = LSALogisticsHelper.getLogisticsRows(this);
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("数据不存在").toString();
        }
        if (!"新建".equals(rows.get(0).getString("status"))) {
            return getErrReturnObject().setErrMsg("非新建状态无法删除").toString();
        }

        JSONArray sa_logistics_itemsids = content.getJSONArray("sa_logistics_itemsids");
        String sql = "DELETE from sa_logistics_items where sa_logistics_itemsid in " + sa_logistics_itemsids + " and siteid='" + siteid + "'";
        sql = sql.replace("[", "(").replace("]", ")");
        dbConnect.runSqlUpdate(sql);


        return getSucReturnObject().toString();
    }

    @API(title = "送货明细列表", apiversion = R.ID20230720141702.v1.class)
    @CACHEING
    public String selectMXList() throws YosException {
        //物流单ID
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");

        pageSorting = pageSorting.equals("''") ? "rowno" : pageSorting;

        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_logistics_items");
        querySQL.setTableAlias("t1");

        querySQL.addJoinTable(JOINTYPE.left, "st_stockbill_items", "t2", "t2.st_stockbill_itemsid=t1.st_stockbill_itemsid and t2.siteid=t1.siteid",
                "rowno", "itemid", "unit", "price", "amount", "remarks");
        querySQL.addJoinTable(JOINTYPE.left, "st_stockbill", "t3", "t3.st_stockbillid =t2.st_stockbillid and t3.siteid=t2.siteid",
                "billno");
        querySQL.addJoinTable(JOINTYPE.left, "plm_item", "t4", "t4.itemid =t2.itemid and t4.siteid=t2.siteid",
                "spec","itemno", "itemname", "model");
        querySQL.setWhere("t1.sa_logisticsid=" + sa_logisticsid);
        querySQL.setWhere("t1.siteid='" + siteid + "'");
        querySQL.setPage(pageSize, pageNumber).setOrderBy(pageSorting);
        Rows rows = querySQL.query();

        ArrayList<Long> ids = rows.toArrayList("itemid", new ArrayList<>());
        // 封面cover
        RowsMap coverRowsMap = getAttachmentUrl("plm_item", ids, "cover");
        for (Row row : rows) {
            Rows coverRows = coverRowsMap.get(row.getString("itemid"));
            if (coverRows.isEmpty()) {
                row.put("cover", "");
            } else {
                row.put("cover", coverRows.get(0).getString("url"));
            }
        }

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

    @API(title = "选择送货明细列表", apiversion = R.ID20230720141802.v1.class)
    public String selectChooseMXList() 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 (t3.itemname like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t2.billno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t3.itemno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t3.spec like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t3.model like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t1.remarks like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t6.sonum like '%").append(whereObject.getString("condition")).append("%')");
            }
        }
        //物流单ID
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");
        Long sys_enterpriseid = content.getLongValue("sys_enterpriseid");

        pageSorting = pageSorting.equals("''") ? "t1.rowno" : pageSorting;

        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "st_stockbill_items",
                "st_stockbill_itemsid","unit","amount","remarks");
        querySQL.setTableAlias("t1");
        querySQL.addJoinTable(JOINTYPE.left, "st_stockbill", "t2", "t2.st_stockbillid =t1.st_stockbillid and t2.siteid=t1.siteid",
                "billno");
        querySQL.addJoinTable(JOINTYPE.left, "plm_item", "t3", "t3.itemid =t1.itemid and t3.siteid=t1.siteid",
                "spec","itemno", "itemname", "model");
        querySQL.addJoinTable(JOINTYPE.left, "sa_dispatch_items", "t4", "t4.sa_dispatch_itemsid = t1.sa_dispatch_itemsid AND t4.siteid = t1.siteid");
        querySQL.addJoinTable(JOINTYPE.left, "sa_orderitems", "t5", "t5.sa_orderitemsid=t4.sa_orderitemsid and t5.siteid=t4.siteid");
        querySQL.addJoinTable(JOINTYPE.left, "sa_order", "t6", "t6.sa_orderid=t5.sa_orderid and t6.siteid=t5.siteid","sonum");
        querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t7", "t7.sys_enterpriseid=t2.sys_enterpriseid and t7.siteid=t2.siteid","agentnum");

        querySQL.addQueryFields("price","t1.amount/t1.qty");
        querySQL.addQueryFields("qty","t1.qty-ifnull(t1.transportqty,0)");
        querySQL.setWhere("t1.siteid='" + siteid + "'");
        querySQL.setWhere("t2.sys_enterpriseid=" + sys_enterpriseid);
        querySQL.setWhere("t2.status='审核'");
        querySQL.setWhere("ifnull(t1.transportqty,0)<t1.qty");
        querySQL.setWhere("NOT EXISTS(SELECT 1 from sa_logistics_items WHERE sa_logisticsid=" + sa_logisticsid + " and st_stockbill_itemsid=t1.st_stockbill_itemsid)");
        querySQL.setWhere("exists(select 1 from st_stockbill_items s1 left join (select st_stockbill_itemsid,t1.siteid,sum(qty) yifaqty from sa_logistics_items t1 inner join sa_logistics t2 on t1.sa_logisticsid=t2.sa_logisticsid and t1.siteid=t2.siteid  where t2.status='审核' group by st_stockbill_itemsid,t1.siteid) s2 on s1.st_stockbill_itemsid=s2.st_stockbill_itemsid and s1.siteid=s2.siteid where s1.qty>ifnull(s2.yifaqty,0) and s1.st_stockbill_itemsid=t1.st_stockbill_itemsid)");

        querySQL.setWhere(where.toString());
        querySQL.setPage(pageSize, pageNumber).setOrderBy(pageSorting);
         System.out.println(querySQL.getSQL());
        Rows rows = querySQL.query();


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

    @API(title = "物流单详情", apiversion = R.ID20230720142002.v1.class)
    @CACHEING
    public String detail() throws YosException {
        //物流单ID
        Long sa_logisticsid = content.getLongValue("sa_logisticsid");
        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_logistics");
        querySQL.setTableAlias("t1");

        querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t2.sys_enterpriseid=t1.sys_enterpriseid and t2.siteid=t1.siteid",
                "t2.enterprisename");
        querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t3", "t3.sys_enterpriseid=t2.sys_enterpriseid and t3.siteid=t2.siteid",
                "t3.agentnum");
        querySQL.addJoinTable(JOINTYPE.left, "sa_logiscomp", "t4", "t4.sa_logiscompid=t1.sa_logiscompid and t4.siteid=t1.siteid",
                "t4.kd100id");
        querySQL.addQueryFields("logiscomp_name", "t4.name");
        querySQL.setWhere("t1.sa_logisticsid=" + sa_logisticsid);
        querySQL.setWhere("t1.siteid='" + siteid + "'");
        Rows rows = querySQL.query();
        Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
        row.putIfAbsent("billdate", "");
        row.putIfAbsent("checkdate", "");
        row.putIfAbsent("receivedate", "");

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

    @API(title = "物流单列表", apiversion = R.ID20230720142102.v1.class)
    @CACHEING
    public String selectList() 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 (t1.billno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t1.logisticno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t1.remarks like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t3.agentnum like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t2.enterprisename like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t4.name like '%").append(whereObject.getString("condition")).append("%')");
            }
            if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
                where.append(" and t1.billdate >='").append(whereObject.getString("begindate")).append(" 00:00:00'");
            }
            if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
                where.append(" and t1.billdate <='").append(whereObject.getString("enddate")).append(" 23:59:59'");
            }
            if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
                where.append(" and t1.status = '").append(whereObject.getString("status")).append("'");
            }
        }

        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_logistics");
        querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t2.sys_enterpriseid=t1.sys_enterpriseid and t2.siteid=t1.siteid",
                "t2.enterprisename");
        querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t3", "t3.sys_enterpriseid=t2.sys_enterpriseid and t3.siteid=t2.siteid",
                "t3.agentnum");
        querySQL.addJoinTable(JOINTYPE.left, "sa_logiscomp", "t4", "t4.sa_logiscompid=t1.sa_logiscompid and t4.siteid=t1.siteid",
                "t4.kd100id");
        querySQL.addQueryFields("logiscomp_name", "t4.name");
        querySQL.setWhere("t1.siteid='" + siteid + "'");
        if (sys_enterpriseid > 0) {
            querySQL.setWhere("t1.sys_enterpriseid='" + sys_enterpriseid + "'");
            querySQL.setWhere("t1.status !='新建'");
        }
        querySQL.setWhere(where.toString());
        querySQL.setPage(pageSize,pageNumber).setOrderBy(pageSorting).setTableAlias("t1");
        Rows rows = querySQL.query();

        for (Row row : rows) {
            row.putIfAbsent("billdate", "");
            row.putIfAbsent("checkdate", "");
            row.putIfAbsent("receivedate", "");
        }

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

    @API(title = "物流单列表(区域经理)", apiversion = R.ID20231030093503.v1.class)
    @CACHEING
    public String selectListManager() 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 (t1.billno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t1.logisticno like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t1.remarks like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t3.agentnum like '%").append(whereObject.getString("condition")).append("%'");
                where.append("or t2.enterprisename like '%").append(whereObject.getString("condition")).append("%')");
            }
            if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
                where.append(" and t1.billdate >='").append(whereObject.getString("begindate")).append(" 00:00:00'");
            }
            if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
                where.append(" and t1.billdate <='").append(whereObject.getString("enddate")).append(" 23:59:59'");
            }
            if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
                where.append(" and t1.status = '").append(whereObject.getString("status")).append("'");
            }
        }
        SQLFactory areasqlFactory = new SQLFactory(new promotion(content), "区域经理查询下属营销区域");
        areasqlFactory.addParameter("siteid", siteid);
        areasqlFactory.addParameter("hrid", hrid);
        Rows arearows = dbConnect.runSqlQuery(areasqlFactory);
        ArrayList<Long> arrayList =arearows.toArrayList("sa_saleareaid", new ArrayList<Long>());
        arrayList.addAll(SaleArea.getSubSaleAreaIds(this, arrayList));

        String sql = " and t1.sys_enterpriseid in (select sys_enterpriseid from sys_enterprise_tradefield where sa_saleareaid in "+arrayList+")";
        sql = sql.replace("[", "(").replace("]", ")");
        where.append(sql);



        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_logistics");
        querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t2.sys_enterpriseid=t1.sys_enterpriseid and t2.siteid=t1.siteid",
                "t2.enterprisename");
        querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t3", "t3.sys_enterpriseid=t2.sys_enterpriseid and t3.siteid=t2.siteid",
                "t3.agentnum");
        querySQL.addJoinTable(JOINTYPE.left, "sa_logiscomp", "t4", "t4.sa_logiscompid=t1.sa_logiscompid and t4.siteid=t1.siteid",
                "t4.kd100id");
        querySQL.addQueryFields("logiscomp_name", "t4.name");
        querySQL.setWhere("t1.siteid='" + siteid + "'");
        querySQL.setWhere(where.toString());
        querySQL.setPage(pageSize,pageNumber).setOrderBy(pageSorting).setTableAlias("t1");
        Rows rows = querySQL.query();

        for (Row row : rows) {
            row.putIfAbsent("billdate", "");
            row.putIfAbsent("checkdate", "");
            row.putIfAbsent("receivedate", "");
        }

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


    @API(title = "收货、取消收货", apiversion = R.ID20230721104302.v1.class)
    @CACHEING_CLEAN(apiClass = {LSALogistics.class})
    public String receive() throws YosException {
        ArrayList<String> sqlList = new ArrayList<>();
        Long sa_logisticsid = content.getLong("sa_logisticsid");
        Rows rows = LSALogisticsHelper.getLogisticsRows(this);
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("请选择物流单").toString();
        }
        SQLFactory sqlFactory = new SQLFactory(this, "物流单确认收货");
        if (rows.get(0).getString("status").equals("新建")) {
            return getErrReturnObject().setErrMsg("该物流单为新建状态,无法确认收货与取消收货").toString();
        } else if (rows.get(0).getString("status").equals("收货")) {
            String sql = DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "取消收货", "物流单取消收货:" + sa_logisticsid).getSQL();
            sqlList.add(sql);
            sqlFactory = new SQLFactory(this, "物流单取消收货");
        } else {
            String sql = DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "收货", "物流单收货:" + sa_logisticsid).getSQL();
            sqlList.add(sql);
        }
        sqlFactory.addParameter("siteid", siteid);
        sqlFactory.addParameter("sa_logisticsid", sa_logisticsid);
        sqlFactory.addParameter("userid", userid);
        sqlFactory.addParameter("username", username);
        sqlList.add(sqlFactory.getSQL());
        dbConnect.runSqlUpdate(sqlList);
        return getSucReturnObject().toString();


    }


    //TODO 审核时必填字段？
    @API(title = "审核、反审核", apiversion = R.ID20230721110502.v1.class)
    @CACHEING_CLEAN(apiversions = {R.ID20221122132804.v1.class, R.ID20221122133004.v1.class, R.ID20221114135303.v1.class, R.ID20230219093203.v1.class})
    public String checkOrUncheck() throws YosException {
        Long sa_logisticsid = content.getLong("sa_logisticsid");
        ArrayList<String> sqlList = new ArrayList<>();

        Rows rows = LSALogisticsHelper.getLogisticsRows(this);
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("请选择物流单").toString();
        }
        Row logisticsRow = rows.get(0);
        String billno = logisticsRow.getString("billno");
        String status = logisticsRow.getString("status");
        if ("收货".equals(status)) {
            return getErrReturnObject().setErrMsg("该物流单为收货状态,无法审核与反审核").toString();
        }

        SQLFactory sqlFactory = new SQLFactory(this, "物流单审核");
        if (status.equals("审核")) {
            sqlFactory = new SQLFactory(this, "物流单反审核");
            sqlList.add(DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "反审核", "反审核:" + sa_logisticsid).getSQL());
            Rows itemsrows = dbConnect.runSqlQuery("SELECT * from sa_logistics_items WHERE sa_logisticsid=" + sa_logisticsid + " and siteid='" + siteid + "'");
            for (Row item : itemsrows) {
                Long st_stockbill_itemsid = item.getLong("st_stockbill_itemsid");
                BigDecimal qty = item.getBigDecimal("qty");
                sqlList.add("UPDATE st_stockbill_items SET transportqty=ifnull(transportqty,0)-" + qty + " WHERE st_stockbill_itemsid=" + st_stockbill_itemsid + " and siteid='" + siteid + "'");
            }
        }
        if (status.equals("新建")) {

            Rows itemsrows = dbConnect.runSqlQuery("SELECT * from sa_logistics_items WHERE sa_logisticsid=" + sa_logisticsid + " and siteid='" + siteid + "'");
            for (Row item : itemsrows) {
                Long st_stockbill_itemsid = item.getLong("st_stockbill_itemsid");
                BigDecimal qty = item.getBigDecimal("qty");
                if (isOut(this, st_stockbill_itemsid, qty)) {
                    return getErrReturnObject().setErrMsg("超出最大可送货数量").toString();
                }
                sqlList.add("UPDATE st_stockbill_items SET transportqty=ifnull(transportqty,0)+" + qty + " WHERE st_stockbill_itemsid=" + st_stockbill_itemsid + " and siteid='" + siteid + "'");
            }

            sqlList.add(DataContrlLog.createLog(this, "sa_logistics", sa_logisticsid, "审核", "审核:" + sa_logisticsid).getSQL());


            Rows dispatchRows = dbConnect.runSqlQuery("SELECT sa_orderid FROM st_stockbill_items t1 INNER JOIN sa_logistics_items t2 ON t2.st_stockbill_itemsid=t1.st_stockbill_itemsid AND t2.siteid=t1.siteid WHERE t2.sa_logisticsid=" + sa_logisticsid + " AND t2.siteid='" + siteid + "'");
            Long sa_orderid = 0L;
            if (dispatchRows.isNotEmpty()) {
                sa_orderid = dispatchRows.get(0).getLong("sa_orderid");
            }
            String sonum = "";
            Rows orderRows = Order.getOrderRows(this, sa_orderid);
            Long sys_enterpriseid = 0L;
            if (orderRows.isNotEmpty()) {
                sonum = orderRows.get(0).getString("sonum");
                sys_enterpriseid = orderRows.get(0).getLong("sys_enterpriseid");
            }
            sendMsg("您的订单【" + sonum + "】已发货，物流单号【" + billno + "】 !", sa_orderid, sys_enterpriseid);
        }
        sqlFactory.addParameter("userid", userid);
        sqlFactory.addParameter("username", username);
        sqlFactory.addParameter("siteid", siteid);
        sqlFactory.addParameter("sa_logisticsid", sa_logisticsid);
        sqlList.add(sqlFactory.getSQL());
        dbConnect.runSqlUpdate(sqlList);
        return getSucReturnObject().toString();


    }

    public void sendMsg(String content, Long sa_orderid, Long sys_enterpriseid) throws YosException {

        ArrayList<Long> userList = getEnterpriseHrs(sys_enterpriseid).toArrayList("userid", new ArrayList<>());
        Remind remind = new Remind(this);
        remind.setTitle("物流消息");
        remind.setContent(content);
        remind.setType("应用");
        remind.setObjectid(sa_orderid);
        remind.setObjectname("sa_order");
        remind.setTouserid(userList);
        remind.createSys_message();
    }
}