优化

src/custom/restcontroller/crm/agent/item/item.java

@@ -0,0 +1,241 @@
+package restcontroller.crm.agent.item;
+
+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;
+
+import java.util.ArrayList;
+
+@API(title = "美大CRM_经销商_商品管理")
+public class item extends Controller {
+
+    public item(JSONObject content) throws YosException {
+        super(content);
+    }
+
+    @API(title = "美大CRM_经销商_商品列表查询", type = API.Type.PageQuery, apiversion = R.ID2026031312441901.v1.class)
+    public String sys_enterprise_item_querylist() throws YosException {
+        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_item").setTableAlias("t1");
+        querySQL.addJoinTable(JOINTYPE.left, "plm_unit", "t2", "t1.unitid=t2.unitid", "unitname");
+        querySQL.setSiteid(siteid);
+        querySQL.setPage(pageSize, pageNumber);
+        Rows rows = querySQL.query();
+        return getSucReturnObject().setData(rows).toString();
+    }
+
+    @API(title = "美大CRM_经销商_商品详情查询", type = API.Type.Query, apiversion = R.ID2026031312515001.v1.class, params = {
+            @Param(paramname = "sys_enterprise_itemid", fieldtype = FieldType.BigInt, remarks = "企业商品ID", isrequired = true)})
+    public String sys_enterprise_item_querymain() throws YosException {
+        long sys_enterprise_itemid = content.getLongValue("sys_enterprise_itemid");
+        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_item").setTableAlias("t1");
+        querySQL.addJoinTable(JOINTYPE.left, "plm_unit", "t2", "t1.unitid=t2.unitid", "unitname");
+        querySQL.setUniqueid(sys_enterprise_itemid);
+        querySQL.setSiteid(siteid);
+        Rows rows = querySQL.query();
+        return getSucReturnObject().setData(rows).toString();
+    }
+
+    @API(title = "美大CRM_经销商_企业商品添加", apiversion = R.ID2026031313002101.v1.class, params = {
+            @Param(paramname = "itemids", fieldtype = FieldType.JSON, remarks = "货品档案表ID，[1,2,3]", isrequired = true)})
+    public String sys_enterprise_item_addfromsite() throws YosException {
+        JSONArray itemids = content.getJSONArray("itemids");// 货品档案表ID
+
+        QuerySQL sys_enterprise_itemQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_item", "itemid");
+        sys_enterprise_itemQuery.setSiteid(siteid);
+        sys_enterprise_itemQuery.setWhere("sys_enterpriseid", sys_enterpriseid);
+        sys_enterprise_itemQuery.setWhere("itemid", itemids);
+        ArrayList<Long> sys_enterprise_itemids = sys_enterprise_itemQuery.query().toArrayList("itemid", new ArrayList<>());
+
+        QuerySQL item_query = SQLFactory.createQuerySQL(this, "plm_item");
+        item_query.setSiteid(siteid);
+        item_query.setWhere("itemid", itemids);
+        RowsMap plm_itemrowsMap = item_query.query().toRowsMap("itemid");
+
+        SQLDump sqlDump = new SQLDump();
+        for (int i = 0; i < itemids.size(); i++) {
+            long itemid = itemids.getLongValue(i);
+            if (!sys_enterprise_itemids.contains(itemid) && plm_itemrowsMap.containsKey(String.valueOf(itemid))) {
+                Row itemrow = plm_itemrowsMap.get(String.valueOf(itemid)).getRow(0);
+                double packageqty = itemrow.getDouble("packageqty");
+                double safeqty = itemrow.getDouble("safeqty");
+                String remarks = itemrow.getString("remarks");
+                boolean ismodule = itemrow.getBoolean("ismodule");
+                int warrantyday = itemrow.getInteger("warrantyday");
+                String barcode = itemrow.getString("barcode");
+                boolean skucontrol = itemrow.getBoolean("skucontrol");
+                long grossweight = itemrow.getLong("grossweight");
+                long weight = itemrow.getLong("weight");
+                long unitid = itemrow.getLong("unitid");
+                String itemno = itemrow.getString("itemno");
+                String color = itemrow.getString("color");
+                String spec = itemrow.getString("spec");
+                String model = itemrow.getString("model");
+                String itemname = itemrow.getString("itemname");
+
+                InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_enterprise_item");
+                insertSQL.setValue("siteid", siteid);// 站点
+                insertSQL.setValue("itemid", itemid);// 货品档案表ID
+                insertSQL.setValue("packing_qty", packageqty);// 包装数量
+                insertSQL.setValue("safeqty", safeqty);// 安全库存
+                insertSQL.setValue("remarks", remarks);// 说明
+                insertSQL.setValue("ismodule", ismodule);// 是否配件
+                insertSQL.setValue("warrantyday", warrantyday);// 保修期（年）
+                insertSQL.setValue("barcode", barcode);// 商品条形码
+                insertSQL.setValue("skucontrol", skucontrol);// 是否单品管理
+                insertSQL.setValue("grossweight", grossweight);// 毛重(g)
+                insertSQL.setValue("weight", weight);// 净重(g)
+                insertSQL.setValue("unitid", unitid);// 计量单位
+                insertSQL.setValue("itemno", itemno);// 产品编号
+                insertSQL.setValue("prodtype", 1);// 商品类型
+                insertSQL.setValue("color", color);// 颜色
+                insertSQL.setValue("spec", spec);// 尺寸
+                insertSQL.setValue("model", model);// 型号
+                insertSQL.setValue("itemname", itemname);// 产品名称
+                insertSQL.setValue("sys_enterpriseid", sys_enterpriseid);// 合作企业档案ID
+                sqlDump.add(insertSQL);
+            }
+        }
+        sqlDump.commit();
+        return getSucReturnObject().toString();
+    }
+
+    @API(title = "美大CRM_经销商_自定义商品新增修改", apiversion = R.ID2026031312463301.v1.class, params = {
+            @Param(paramname = "sys_enterprise_itemid", fieldtype = FieldType.BigInt, remarks = "企业商品ID", isrequired = true),
+            @Param(paramname = "packing_qty", fieldtype = FieldType.Decimal, remarks = "包装数量", isrequired = true),
+            @Param(paramname = "safeqty", fieldtype = FieldType.Decimal, remarks = "安全库存", isrequired = true),
+            @Param(paramname = "remarks", fieldtype = FieldType.Varchar, remarks = "说明", isrequired = true),
+            @Param(paramname = "ismodule", fieldtype = FieldType.Smallint, remarks = "是否配件", isrequired = true),
+            @Param(paramname = "isabstract", fieldtype = FieldType.Smallint, remarks = "服务商品/虚拟商品", isrequired = true),
+            @Param(paramname = "warrantyday", fieldtype = FieldType.Int, remarks = "保修期（年）", isrequired = true),
+            @Param(paramname = "barcode", fieldtype = FieldType.Varchar, remarks = "商品条形码", isrequired = true),
+            @Param(paramname = "guid_price_cus", fieldtype = FieldType.Decimal, remarks = "指导价(站点自定义)", isrequired = true),
+            @Param(paramname = "grossweight", fieldtype = FieldType.BigInt, remarks = "毛重(g)", isrequired = true),
+            @Param(paramname = "weight", fieldtype = FieldType.BigInt, remarks = "净重(g)", isrequired = true),
+            @Param(paramname = "unitid", fieldtype = FieldType.BigInt, remarks = "计量单位", isrequired = true),
+            @Param(paramname = "itemno_cus", fieldtype = FieldType.Varchar, remarks = "站点商品编码", isrequired = true),
+            @Param(paramname = "color", fieldtype = FieldType.Varchar, remarks = "颜色", isrequired = true),
+            @Param(paramname = "spec", fieldtype = FieldType.Varchar, remarks = "尺寸", isrequired = true),
+            @Param(paramname = "model", fieldtype = FieldType.Varchar, remarks = "型号", isrequired = true),
+            @Param(paramname = "itemname", fieldtype = FieldType.Varchar, remarks = "产品名称", isrequired = true)})
+    public String sys_enterprise_item_save() throws YosException {
+        long sys_enterprise_itemid = content.getLongValue("sys_enterprise_itemid");
+        double packing_qty = content.getDoubleValue("packing_qty");// 包装数量
+        double safeqty = content.getDoubleValue("safeqty");// 安全库存
+        String remarks = content.getStringValue("remarks");// 说明
+        boolean ismodule = content.getBooleanValue("ismodule");// 是否配件
+        boolean isabstract = content.getBooleanValue("isabstract");// 服务商品/虚拟商品
+        long warrantyday = content.getLongValue("warrantyday");// 保修期（年）
+        String barcode = content.getStringValue("barcode");// 商品条形码
+        double guid_price_cus = content.getDoubleValue("guid_price_cus");// 指导价(站点自定义)
+        long grossweight = content.getLongValue("grossweight");// 毛重(g)
+        long weight = content.getLongValue("weight");// 净重(g)
+        long unitid = content.getLongValue("unitid");// 计量单位
+        String itemno_cus = content.getString("itemno_cus");// 站点商品编码
+        String color = content.getStringValue("color");// 颜色
+        String spec = content.getStringValue("spec");// 尺寸
+        String model = content.getStringValue("model");// 型号
+        String itemname = content.getStringValue("itemname");// 产品名称
+
+
+        Rows sys_enterprise_itemRows = SQLFactory.createQuerySQL(this, "sys_enterprise_item", "sys_enterprise_itemid").setSiteid(siteid).setUniqueid(sys_enterprise_itemid).query();
+        SQLDump sqldump = new SQLDump();
+        if (sys_enterprise_itemid == 0 || sys_enterprise_itemRows.isEmpty()) {
+            QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_enterprise_item").setWhere("itemno_cus", itemno_cus).setSiteid(siteid).setWhere("sys_enterpriseid", sys_enterpriseid);
+            if (querySQL.query().isNotEmpty()) {
+                return getErrReturnObject().setErrMsg("商品编码" + itemno_cus + "已存在").toString();
+            }
+
+            InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_enterprise_item");
+            insertSQL.setValue("siteid", siteid);// 站点
+            insertSQL.setValue("packing_qty", packing_qty);// 包装数量
+            insertSQL.setValue("safeqty", safeqty);// 安全库存
+            insertSQL.setValue("remarks", remarks);// 说明
+            insertSQL.setValue("ismodule", ismodule);// 是否配件
+            insertSQL.setValue("isabstract", isabstract);// 服务商品/虚拟商品
+            insertSQL.setValue("warrantyday", warrantyday);// 保修期（年）
+            insertSQL.setValue("barcode", barcode);// 商品条形码
+            insertSQL.setValue("guid_price_cus", guid_price_cus);// 指导价(站点自定义)
+            insertSQL.setValue("grossweight", grossweight);// 毛重(g)
+            insertSQL.setValue("weight", weight);// 净重(g)
+            insertSQL.setValue("unitid", unitid);// 单位名称
+            insertSQL.setValue("itemno_cus", itemno_cus);// 站点商品编码
+            insertSQL.setValue("itemno", userInfo.getAgentRow().getString("agentnum") + itemno_cus);// 产品编号
+            insertSQL.setValue("prodtype", 2);// 商品类型
+            insertSQL.setValue("color", color);// 颜色
+            insertSQL.setValue("spec", spec);// 尺寸
+            insertSQL.setValue("model", model);// 型号
+            insertSQL.setValue("itemname", itemname);// 产品名称
+            insertSQL.setValue("sys_enterpriseid", sys_enterpriseid);// 合作企业档案ID
+            sqldump.add(insertSQL);
+        } else {
+            UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sys_enterprise_item");
+            updateSQL.setValue("packing_qty", packing_qty);// 包装数量
+            updateSQL.setValue("safeqty", safeqty);// 安全库存
+            updateSQL.setValue("remarks", remarks);// 说明
+            updateSQL.setValue("ismodule", ismodule);// 是否配件
+            updateSQL.setValue("isabstract", isabstract);// 服务商品/虚拟商品
+            updateSQL.setValue("warrantyday", warrantyday);// 保修期（年）
+            updateSQL.setValue("barcode", barcode);// 商品条形码
+            updateSQL.setValue("grossweight", grossweight);// 毛重(g)
+            updateSQL.setValue("weight", weight);// 净重(g)
+            updateSQL.setValue("unitid", unitid);// 单位名称
+            updateSQL.setValue("color", color);// 颜色
+            updateSQL.setValue("spec", spec);// 尺寸
+            updateSQL.setValue("model", model);// 型号
+            updateSQL.setValue("itemname", itemname);// 产品名称
+            updateSQL.setValue("guid_price_cus", guid_price_cus);// 指导价(站点自定义)
+            updateSQL.setSiteid(siteid);
+            updateSQL.setUniqueid(sys_enterprise_itemid);
+            sqldump.add(updateSQL);
+        }
+        sqldump.commit();
+        return getSucReturnObject().toString();
+    }
+
+    @API(title = "美大CRM_经销商_商品上下架", apiversion = R.ID2026031315384901.v1.class, params = {
+            @Param(paramname = "sys_enterprise_itemids", fieldtype = FieldType.JSON, remarks = "企业商品ID，[1,2,3]", isrequired = true),
+            @Param(paramname = "isonsale", fieldtype = FieldType.Smallint, remarks = "是否上架", isrequired = true)})
+    public String sys_enterprise_item_onsale() throws YosException {
+        JSONArray sys_enterprise_itemids = content.getJSONArray("sys_enterprise_itemids");
+        boolean isonsale = content.getBooleanValue("isonsale");
+        UpdateSQL querySQL = SQLFactory.createUpdateSQL(this, "sys_enterprise_item");
+        querySQL.setSiteid(siteid);
+        querySQL.setValue("isonsale", isonsale);
+        querySQL.setWhere("sys_enterprise_itemid", sys_enterprise_itemids);
+        querySQL.update();
+        return getSucReturnObject().toString();
+    }
+
+    @API(title = "美大CRM_经销商_商品删除", apiversion = R.ID2026031712364501.v1.class, params = {
+            @Param(paramname = "sys_enterprise_itemids", fieldtype = FieldType.JSON, remarks = "企业商品ID，[1,2,3]", isrequired = true)})
+    public String sys_enterprise_item_delete() throws YosException {
+        JSONArray sys_enterprise_itemids = content.getJSONArray("sys_enterprise_itemids");
+        for (int i = 0; i < sys_enterprise_itemids.size(); i++) {
+            long sys_enterprise_itemid = sys_enterprise_itemids.getLongValue(i);
+            Rows enterprise_itemRows = SQLFactory.createQuerySQL(this, "sys_enterprise_item").setWhere("isonsale", true).setUniqueid(sys_enterprise_itemid).query();
+            if (enterprise_itemRows.isNotEmpty()) {
+                return getErrReturnObject().setErrMsg("商品" + enterprise_itemRows.getRow(0).getString("itemname") + "已上架，请先下架").toString();
+            }
+            Rows custorderitemsRows = SQLFactory.createQuerySQL(this, "sa_custorderitems").setWhere("sys_enterprise_itemid", sys_enterprise_itemid).setPage(1, 1).query();
+            if (custorderitemsRows.isNotEmpty()) {
+                return getErrReturnObject().setErrMsg("商品" + enterprise_itemRows.getRow(0).getString("itemname") + "已存在订单，无法删除").toString();
+            }
+            QuerySQL invbalQuery = SQLFactory.createQuerySQL(this, "sys_enterprise_invbal");
+            invbalQuery.setSiteid(siteid);
+            invbalQuery.setWhere("sys_enterprise_itemid", sys_enterprise_itemid);
+            if (!invbalQuery.query().isEmpty()) {
+                return getErrReturnObject().setErrMsg("该商品存在库存，不可删除！").toString();
+            }
+
+            SQLFactory.createDeleteSQL(this, "sys_enterprise_item").setSiteid(siteid).setWhere("sys_enterprise_itemid", sys_enterprise_itemid).delete();
+        }
+        return getSucReturnObject().toString();
+    }
+
+
+}