package restcontroller.crm.agent.stock; import beans.enterprise_stockbill.enterprise_Stockbill; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; import common.Controller; import common.YosException; import common.annotation.API; import common.annotation.Param; import common.data.*; import restcontroller.R; @API(title = "美大CRM_经销商_出入库单") public class stockbill extends Controller { public stockbill(JSONObject content) throws YosException { super(content); } @API(title = "美大CRM_经销商_出入库单列表查询", type = API.Type.PageQuery, apiversion = R.ID2026031715354101.v1.class) public String sys_enterprise_stockbill_querylist() throws YosException { QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill", "*").setTableAlias("t1"); querySQL.addJoinTable(QuerySQL.JOINTYPE.left, "sys_enterprise_stock", "t2", "t1.sys_enterprise_stockid=t2.sys_enterprise_stockid", "stockno", "stockname"); querySQL.addJoinTable(QuerySQL.JOINTYPE.left, "sa_customers", "t3", "t1.sa_customersid=t3.sa_customersid", "name", "phonenumber", "community"); querySQL.addJoinTable(QuerySQL.JOINTYPE.left, "sa_store", "t4", "t3.sa_storeid=t4.sa_customersid", "storeno", "storename"); querySQL.setSiteid(siteid); querySQL.setPage(pageSize, pageNumber); Rows rows = querySQL.query(); return getSucReturnObject().setData(rows).toString(); } @API(title = "美大CRM_经销商_出入库单新增修改", apiversion = R.ID2026031715451701.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "企业出入库单ID", isrequired = true), @Param(paramname = "rb", fieldtype = FieldType.Smallint, remarks = "红蓝字", isrequired = true), @Param(paramname = "type", fieldtype = FieldType.Varchar, remarks = "单据类型", isrequired = true), @Param(paramname = "typemx", fieldtype = FieldType.Varchar, remarks = "明细分类", isrequired = true), @Param(paramname = "billdate", fieldtype = FieldType.Varchar, remarks = "单据日期", isrequired = true), @Param(paramname = "remarks", fieldtype = FieldType.Varchar, remarks = "备注说明"), @Param(paramname = "sa_custorderid", fieldtype = FieldType.BigInt, remarks = "C端订单ID"), @Param(paramname = "sys_enterprise_stockid", fieldtype = FieldType.BigInt, remarks = "企业仓库ID", isrequired = true)}) public String sys_enterprise_stockbill_save() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid"); boolean rb = content.getBooleanValue("rb");// 红蓝字 String remarks = content.getStringValue("remarks");// 备注说明 long sa_custorderid = content.getLongValue("sa_custorderid");// C端订单ID String typemx = content.getStringValue("typemx");// 明细分类 String type = content.getStringValue("type");// 单据类型 long sys_enterprise_stockid = content.getLongValue("sys_enterprise_stockid");// 企业仓库ID String billdate = content.getStringValue("billdate");// 单据日期 if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("当前单据不是新建状态,不能修改").toString(); } SQLDump sqldump = new SQLDump(); if (sys_enterprise_stockbillid <= 0 || SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill", "sys_enterprise_stockbillid").setSiteid(siteid).setUniqueid(sys_enterprise_stockbillid).query().isEmpty()) { sys_enterprise_stockbillid = createTableID("sys_enterprise_stockbill"); InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_enterprise_stockbill"); insertSQL.setValue("billno", createBillCode("enterprise_stockbill"));// 单据编号 insertSQL.setValue("sa_custorderid", sa_custorderid);// C端订单ID insertSQL.setValue("sa_customersid", getCustomerid(sa_custorderid));// 客户ID insertSQL.setValue("rb", rb);// 红蓝字 insertSQL.setValue("typemx", typemx);// 明细分类 insertSQL.setValue("type", type);// 单据类型 insertSQL.setValue("billdate", billdate);// 单据日期 insertSQL.setValue("status", "新建");// 状态 insertSQL.setValue("remarks", remarks);// 备注说明 insertSQL.setValue("siteid", siteid);// 站点 insertSQL.setValue("sys_enterprise_stockid", sys_enterprise_stockid);// 企业仓库ID insertSQL.setValue("sys_enterpriseid", sys_enterpriseid);// 合作企业档案ID insertSQL.setUniqueid(sys_enterprise_stockbillid); sqldump.add(insertSQL); } else { UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sys_enterprise_stockbill"); updateSQL.setValue("sa_custorderid", sa_custorderid);// C端订单ID updateSQL.setValue("sa_customersid", getCustomerid(sa_custorderid));// 客户ID updateSQL.setValue("remarks", remarks);// 备注说明 updateSQL.setValue("typemx", typemx);// 明细分类 updateSQL.setValue("sys_enterprise_stockid", sys_enterprise_stockid);// 企业仓库ID updateSQL.setValue("billdate", billdate);// 单据日期 updateSQL.setSiteid(siteid); updateSQL.setUniqueid(sys_enterprise_stockbillid); sqldump.add(updateSQL); } sqldump.commit(); return getSucReturnObject().setData(sys_enterprise_stockbillid).toString(); } @API(title = "美大CRM_经销商_出入库单删除", apiversion = R.ID2026031715591001.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillids", fieldtype = FieldType.JSON, remarks = "出入库单ID,[1,2,3]", isrequired = true)}) public String sys_enterprise_stockbill_delete() throws YosException { JSONArray sys_enterprise_stockbillids = content.getJSONArray("sys_enterprise_stockbillids"); for (int i = 0; i < sys_enterprise_stockbillids.size(); i++) { long sys_enterprise_stockbillid = sys_enterprise_stockbillids.getLong(i); if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("单据不是新建状态,不能删除").toString(); } SQLDump sqlDump = new SQLDump(); sqlDump.add(SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill").setSiteid(siteid).setUniqueid(sys_enterprise_stockbillid)); sqlDump.add(SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill_items").setSiteid(siteid).setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid)); sqlDump.add(SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill_skus").setSiteid(siteid).setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid)); sqlDump.commit(); } return getSucReturnObject().toString(); } @API(title = "美大CRM_经销商_出入库单审核反审核", apiversion = R.ID2026031716375401.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "出入库单ID", isrequired = true), @Param(paramname = "ischeck", fieldtype = FieldType.Boolean, remarks = "1:审核,0:反审核", isrequired = true)}) public String sys_enterprise_stockbill_check() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid"); boolean ischeck = content.getBooleanValue("ischeck"); enterprise_Stockbill.check(this, sys_enterprise_stockbillid, ischeck); return getSucReturnObject().toString(); } @API(title = "美大CRM_经销商_出入库单红冲", notes = "红冲成功返回红字单据id", apiversion = R.ID2026031808321401.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "出入库单ID", isrequired = true),}) public String sys_enterprise_stockbill_hong() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid"); QuerySQL headQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill"); headQuery.setSiteid(siteid).setUniqueid(sys_enterprise_stockbillid).setWhere("sys_enterpriseid", sys_enterpriseid); Rows headrows = headQuery.query(); if (headrows.isEmpty()) { return getErrReturnObject().setErrMsg("单据不存在").toString(); } if (headrows.get(0).getInteger("rb") == 0) { return getErrReturnObject().setErrMsg("红字单据不可红冲!").toString(); } if (headrows.get(0).getString("status").equals("审核")) { return getErrReturnObject().setErrMsg("非审核状态不可红冲!").toString(); } QuerySQL detailQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_items"); detailQuery.setSiteid(siteid).setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid).setWhere("sys_enterpriseid", sys_enterpriseid); Rows detailrows = detailQuery.query(); SQLDump sqlDump = new SQLDump(); Row row = headrows.get(0); long hongheadid = createTableID("sys_enterprise_stockbill"); InsertSQL inserthead = row.getInsertSQL("sys_enterprise_stockbill"); inserthead.setValue("billno", createBillCode("enterprise_stockbill")); inserthead.setValue("rb", 0); inserthead.setValue("sourceid", sys_enterprise_stockbillid); inserthead.setValue("sourceobject", "sys_enterprise_stockbill"); inserthead.setValue("status", "新建"); inserthead.setDateValue("billdate"); inserthead.setValue("createby", username); inserthead.setDateValue("createdate"); inserthead.setValue("changeby", username); inserthead.setDateValue("changedate"); inserthead.setValue("checkby", null); inserthead.setValue("checkdate", null); inserthead.setUniqueid(hongheadid); sqlDump.add(inserthead); for (int i = 0; i < detailrows.size(); i++) { Row detailrow = detailrows.get(i); long hongdetailid = createTableID("sys_enterprise_stockbill_items"); InsertSQL insertdetail = detailrow.getInsertSQL("sys_enterprise_stockbill_items"); insertdetail.setValue("sourceid", detailrow.getLong("sys_enterprise_stockbill_itemsid")); insertdetail.setValue("sourceobject", "sys_enterprise_stockbill_items"); insertdetail.setValue("sys_enterprise_stockbillid", hongheadid); insertdetail.setValue("createby", username); insertdetail.setDateValue("createdate"); insertdetail.setValue("changeby", username); insertdetail.setDateValue("changedate"); insertdetail.setValue("hongqty", 0); insertdetail.setUniqueid(hongdetailid); sqlDump.add(insertdetail); QuerySQL codeQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_skus"); codeQuery.setWhere("sys_enterprise_stockbill_itemsid", detailrow.getLong("sys_enterprise_stockbill_itemsid")).setWhere("sys_enterpriseid", sys_enterpriseid); Rows coderows = codeQuery.query(); for (int j = 0; j < coderows.size(); j++) { Row coderow = coderows.get(j); InsertSQL insertcode = coderow.getInsertSQL("sys_enterprise_stockbill_items"); insertcode.setValue("sys_enterprise_stockbill_itemsid", hongdetailid); insertcode.setValue("sys_enterprise_stockbillid", hongheadid); insertcode.setValue("createby", username); insertcode.setDateValue("createdate"); sqlDump.add(insertcode); } } sqlDump.commit(); return getSucReturnObject().setData(hongheadid).toString(); } @API(title = "美大CRM_经销商_出入库单商品明细查询", type = API.Type.Query, apiversion = R.ID2026031715421401.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "出入库单ID", isrequired = true)}) public String sys_enterprise_stockbill_items_querylist() throws YosException { long sys_enterprise_stockbillid = content.getLong("sys_enterprise_stockbillid"); QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_items"); querySQL.setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid); querySQL.setSiteid(siteid); Rows rows = querySQL.query(); return getSucReturnObject().setData(rows).toString(); } @API(title = "美大CRM_经销商_出入库单商品明细新增修改", apiversion = R.ID2026031716051401.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "企业出入库单ID", isrequired = true), @Param(paramname = "sys_enterprise_stockbill_itemsid", fieldtype = FieldType.BigInt, remarks = "企业出入库单货品明细", isrequired = true), @Param(paramname = "sa_custorderitemsid", fieldtype = FieldType.BigInt, remarks = "C端订单商品表ID"), @Param(paramname = "sys_enterprise_itemid", fieldtype = FieldType.BigInt, remarks = "企业商品档案表ID", isrequired = true), @Param(paramname = "qty", fieldtype = FieldType.Decimal, remarks = "数量", isrequired = true), @Param(paramname = "remarks", fieldtype = FieldType.Varchar, remarks = "备注说明")}) public String sys_enterprise_stockbill_items_save() throws YosException { long sys_enterprise_stockbillid = content.getLong("sys_enterprise_stockbillid");// 企业出入库单ID long sys_enterprise_stockbill_itemsid = content.getLongValue("sys_enterprise_stockbill_itemsid"); long sa_custorderitemsid = content.getLongValue("sa_custorderitemsid");// C端订单商品表ID long sys_enterprise_itemid = content.getLongValue("sys_enterprise_itemid");// 企业商品档案表ID double qty = content.getDoubleValue("qty");// 数量 String remarks = content.getStringValue("remarks");// 备注说明 if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("当前单据不是新建状态,不能修改").toString(); } SQLDump sqldump = new SQLDump(); if (sys_enterprise_stockbill_itemsid <= 0 || SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_items", "sys_enterprise_stockbill_itemsid").setSiteid(siteid).setUniqueid(sys_enterprise_stockbill_itemsid).query().isEmpty()) { sys_enterprise_stockbill_itemsid = createTableID("sys_enterprise_stockbill_items"); InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_enterprise_stockbill_items"); insertSQL.setValue("siteid", siteid);// 站点 insertSQL.setValue("sys_enterpriseid", sys_enterpriseid);// 合作企业档案ID insertSQL.setValue("sys_enterprise_stockbillid", sys_enterprise_stockbillid);// 企业出入库单ID insertSQL.setValue("sa_custorderitemsid", sa_custorderitemsid);// C端订单商品表ID insertSQL.setValue("sys_enterprise_itemid", sys_enterprise_itemid);// 企业商品档案表ID insertSQL.setValue("hongqty", 0);// 已红冲数量 insertSQL.setValue("remarks", remarks);// 备注说明 QuerySQL itemQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_item"); itemQuery.setWhere("sys_enterprise_itemid", sys_enterprise_itemid); itemQuery.setWhere("sys_enterpriseid", sys_enterpriseid); itemQuery.setWhere("siteid", siteid); Rows itemrow = itemQuery.query(); if (itemrow.isEmpty()) { return getErrReturnObject().setErrMsg("商品档案不存在").toString(); } insertSQL.setValue("itemno", itemrow.get(0).getString("itemno"));// 产品编号 insertSQL.setValue("model", itemrow.get(0).getString("model"));// 型号 insertSQL.setValue("itemname", itemrow.get(0).getString("itemname"));// 产品名称 insertSQL.setValue("skucontrol", itemrow.get(0).getBoolean("skucontrol"));// 是否单品管理 insertSQL.setValue("qty", qty);// 数量 insertSQL.setUniqueid(sys_enterprise_stockbill_itemsid); sqldump.add(insertSQL); } else { UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sys_enterprise_stockbill_items"); updateSQL.setValue("remarks", remarks);// 备注说明 updateSQL.setValue("qty", qty);// 数量 updateSQL.setSiteid(siteid); updateSQL.setUniqueid(sys_enterprise_stockbill_itemsid); updateSQL.setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid);// 企业出入库单ID sqldump.add(updateSQL); } sqldump.commit(); updateRowno(sys_enterprise_stockbillid); return getSucReturnObject().setData(sys_enterprise_stockbill_itemsid).toString(); } @API(title = "美大CRM_经销商_出入库单商品明细删除", apiversion = R.ID2026031716132201.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "出入库单ID", isrequired = true), @Param(paramname = "sys_enterprise_stockbillids", fieldtype = FieldType.JSON, remarks = "出入库单ID,[1,2,3]", isrequired = true)}) public String sys_enterprise_stockbill_items_delete() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid"); JSONArray sys_enterprise_stockbill_itemsids = content.getJSONArray("sys_enterprise_stockbill_itemsids"); if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("当前单据不是新建状态,不能删除商品明细").toString(); } SQLDump sqlDump = new SQLDump(); sqlDump.add(SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill_items").setSiteid(siteid).setWhere("sys_enterprise_stockbill_itemsid", sys_enterprise_stockbill_itemsids)); sqlDump.add(SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill_skus").setSiteid(siteid).setWhere("sys_enterprise_stockbill_itemsid", sys_enterprise_stockbill_itemsids)); sqlDump.commit(); updateRowno(sys_enterprise_stockbillid); return getSucReturnObject().toString(); } @API(title = "美大CRM_经销商_出入库单商序列号查询", type = API.Type.PageQuery, apiversion = R.ID2026031812265301.v1.class, params = { @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "出入库单ID", isrequired = true), @Param(paramname = "sys_enterprise_stockbill_itemsid", fieldtype = FieldType.BigInt, remarks = "出入库单商品明细ID", isrequired = true)}) public String sys_enterprise_stockbill_skus_querylist() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid"); long sys_enterprise_stockbill_itemsid = content.getLongValue("sys_enterprise_stockbill_itemsid"); QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_skus"); querySQL.setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid); querySQL.setWhere("sys_enterprise_stockbill_itemsid", sys_enterprise_stockbill_itemsid); querySQL.setSiteid(siteid); querySQL.setPage(pageSize, pageNumber); Rows rows = querySQL.query(); return getSucReturnObject().setData(rows).toString(); } @API(title = "美大CRM_经销商_出入库单序列号新增", apiversion = R.ID2026031812294301.v1.class, params = { @Param(paramname = "sku", fieldtype = FieldType.Varchar, remarks = "序列号"), @Param(paramname = "sys_enterprise_stockbillid", fieldtype = FieldType.BigInt, remarks = "企业出入库单ID"), @Param(paramname = "sys_enterprise_stockbill_itemsid", fieldtype = FieldType.BigInt, remarks = "企业出入库单货品明细")}) public String sys_enterprise_stockbill_skus_insert() throws YosException { String sku = content.getStringValue("sku");// 序列号 long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid");// 企业出入库单ID long sys_enterprise_stockbill_itemsid = content.getLongValue("sys_enterprise_stockbill_itemsid");// 企业出入库单货品明细 if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("当前单据不是新建状态,不能添加序列号").toString(); } Rows skuRows = SQLFactory.createQuerySQL(this, "sa_itemsku").setSiteid(siteid).setWhere("sku", sku).query(); if (skuRows.isEmpty()) { return getErrReturnObject().setErrCode(1).setErrMsg("序列号" + sku + "不存在").toString(); } if (skuRows.get(0).getLong("sys_enterpriseid") == 0) { return getErrReturnObject().setErrCode(3).setErrMsg("序列号" + sku + "当前归属经销商错误,不可录入,请联系美大售后部门").toString(); } if (skuRows.get(0).getLong("sys_enterpriseid") != sys_enterpriseid) { return getErrReturnObject().setErrCode(2).setErrMsg("序列号" + sku + "当前归属经销商错误,是否申请调拨?").toString(); } if (SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_skus").setWhere("sku", sku).setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid).query().isEmpty()) { InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_enterprise_stockbill_skus"); insertSQL.setValue("siteid", siteid);// 站点 insertSQL.setValue("sku", sku);// 序列号 insertSQL.setValue("sys_enterprise_stockbillid", sys_enterprise_stockbillid);// 企业出入库单ID insertSQL.setValue("sys_enterprise_stockbill_itemsid", sys_enterprise_stockbill_itemsid);// 企业出入库单货品明细 insertSQL.setValue("sys_enterpriseid", sys_enterpriseid);// 合作企业档案ID insertSQL.insert(); } else { return getErrReturnObject().setErrMsg("序列号已存在").toString(); } return getSucReturnObject().toString(); } @API(title = "美大CRM_经销商_出入库单商序列号删除", apiversion = R.ID2026031812553601.v1.class, params = {}) public String sys_enterprise_stockbill_skus_delete() throws YosException { long sys_enterprise_stockbillid = content.getLongValue("sys_enterprise_stockbillid");// 企业出入库单ID long sys_enterprise_stockbill_skusid = content.getLongValue("sys_enterprise_stockbill_skusid");// 企业出入库单ID if (!getBillStatus(sys_enterprise_stockbillid).equals("新建")) { return getErrReturnObject().setErrMsg("当前单据不是新建状态,不能删除序列号").toString(); } DeleteSQL deletesku = SQLFactory.createDeleteSQL(this, "sys_enterprise_stockbill_skus"); deletesku.setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid); deletesku.setUniqueid(sys_enterprise_stockbill_skusid); deletesku.delete(); return getSucReturnObject().toString(); } public Long getCustomerid(long sa_custorderid) throws YosException { if (sa_custorderid == 0) { return 0L; } QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_custorder", "sa_customersid"); querySQL.setSiteid(siteid); querySQL.setWhere("sys_enterpriseid", sys_enterpriseid); querySQL.setUniqueid(sa_custorderid); Rows query = querySQL.query(); return query.isEmpty() ? 0L : query.getRow(0).getLong("sa_customersid"); } public String getBillStatus(long sys_enterprise_stockbillid) throws YosException { QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill", "status").setSiteid(siteid).setWhere("sys_enterpriseid", sys_enterpriseid).setUniqueid(sys_enterprise_stockbillid); Rows rows = querySQL.query(); if (!rows.isEmpty()) { return rows.get(0).getString("status"); } return ""; } /** * 出入库单行更新 * * @param sys_enterprise_stockbillid * @throws YosException */ public void updateRowno(long sys_enterprise_stockbillid) throws YosException { QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_stockbill_items", "sys_enterprise_stockbill_itemsid").setWhere("sys_enterprise_stockbillid", sys_enterprise_stockbillid); querySQL.setOrderBy("sys_enterprise_stockbill_itemsid"); SQLDump sqlDump = new SQLDump(); for (int i = 0; i < querySQL.query().size(); i++) { UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sys_enterprise_stockbill_items"); updateSQL.setSiteid(siteid); updateSQL.setUniqueid(querySQL.query().get(i).getLong("sys_enterprise_stockbill_itemsid")); updateSQL.setValue("rowno", i + 1); sqlDump.add(updateSQL); } sqlDump.commit(); } }