diff --git a/app/adminapi/controller/GoodsController.php b/app/adminapi/controller/GoodsController.php index 2f2694c..50f5b81 100644 --- a/app/adminapi/controller/GoodsController.php +++ b/app/adminapi/controller/GoodsController.php @@ -51,13 +51,78 @@ class GoodsController extends BaseAdminController */ public function add() { -// $params = (new GoodsValidate())->post()->goCheck('add'); - $params = $this->request->param(); - $result = GoodsLogic::add($params); - if (true === $result) { - return $this->success('添加成功', [], 1, 1); + if ($this->request->isAjax() && $this->request->isPost()) { + + $post = $this->request->post(); + $post['del'] = 0; + + //主表验证 + $result = $this->validate($post, 'app\admin\validate\Goods.add'); + if ($result !== true) { + return $this->fail($result); + } + + //单规格验证 + if ($post['spec_type'] == 1) { + $result = $this->validate($post, 'app\admin\validate\GoodsOneSpec'); + if ($result !== true) { + return $this->fail($result); + } + } + + //多规格验证 + $spec_lists = []; + if ($post['spec_type'] == 2) { + $spec_lists = $post; + + // 规格值验证长度验证 + foreach($spec_lists['spec_value_str'] as $key => $item) { + $itemArr = explode(',', $item); + foreach($itemArr as $subItem) { + if(mb_strlen($subItem) > 64) { + return $this->fail('第'. ($key+1) .'个SKU规格值超过了64个字符'); + } + } + } + + unset($spec_lists['goods_image']); + unset($spec_lists['spec_name']); + unset($spec_lists['spec_values']); + unset($spec_lists['spec_id']); + unset($spec_lists['spec_value_ids']); + $spec_lists = form_to_linear($spec_lists); + + //规格验证 + if (empty($spec_lists)) { + return $this->fail('至少添加一个规格'); + } + $result = $this->validate($post, 'app\admin\validate\GoodsMoreSpec'); + if ($result !== true) { + return $this->fail($result); + } + + //规格商品列表验证 + foreach ($spec_lists as $v) { + $result = $this->validate($v, 'app\admin\validate\GoodsMoreSpecLists'); + if ($result !== true) { + return $this->fail($result); + } + } + // 校验规格 + $total_stock = array_sum(array_column($spec_lists, 'stock')); + if ($total_stock <= 0) { + return $this->fail('至少有一个规格的库存大于0'); + } + } + + //添加商品 + $result = GoodsLogic::add($post, $spec_lists); + + if ($result !== true) { + return $this->fail('添加失败:' . $result); + } + return $this->success('添加成功'); } - return $this->fail(GoodsLogic::getError()); } diff --git a/app/adminapi/logic/GoodsLogic.php b/app/adminapi/logic/GoodsLogic.php index e5871d4..b0edeb6 100644 --- a/app/adminapi/logic/GoodsLogic.php +++ b/app/adminapi/logic/GoodsLogic.php @@ -18,6 +18,7 @@ namespace app\adminapi\logic; use app\common\model\Goods; use app\common\logic\BaseLogic; use app\common\service\UrlServer; +use think\Exception; use think\facade\Db; @@ -31,94 +32,186 @@ class GoodsLogic extends BaseLogic /** - * @notes 添加 - * @param array $params + * 添加商品 + * @param $post + * @param $spec_lists * @return bool - * @author likeadmin - * @date 2025/05/08 15:34 */ - public static function add(array $params): bool + public static function add($post, $spec_lists) { - Db::startTrans(); - try { - $id = Goods::insertGetId([ - 'name' => $params['name'], - 'code' => $params['code'], - 'first_category_id' => $params['first_category_id'], - 'second_category_id' => $params['second_category_id'], - 'third_category_id' => $params['third_category_id'], - 'brand_id' => $params['brand_id'], - 'supplier_id' => $params['supplier_id'], - 'status' => $params['status'], - 'image' => $params['image'], - 'video' => $params['video'], - 'poster' => $params['poster'], - 'remark' => $params['remark'], - 'content' => $params['content'], - 'sort' => $params['sort'], - 'sales_sum' => $params['sales_sum'], - 'virtual_sales_sum' => $params['virtual_sales_sum'], - 'click_count' => $params['click_count'], - 'virtual_click' => $params['virtual_click'], - 'spec_type' => $params['spec_type'], - 'max_price' => $params['max_price'], - 'min_price' => $params['min_price'], - 'market_price' => $params['market_price'], - 'stock' => $params['stock'], - 'stock_warn' => $params['stock_warn'], - 'is_show_stock' => $params['is_show_stock'], - 'free_shipping_type' => $params['free_shipping_type'], - 'free_shipping' => $params['free_shipping'], - 'free_shipping_template_id' => $params['free_shipping_template_id'], - 'is_commission' => $params['is_commission'], - 'first_ratio' => $params['first_ratio'], - 'second_ratio' => $params['second_ratio'], - 'three_ratio' => $params['three_ratio'], - 'is_share_bouns' => $params['is_share_bouns'], - 'region_ratio' => $params['region_ratio'], - 'shareholder_ratio' => $params['shareholder_ratio'], - 'is_new' => $params['is_new'], - 'is_best' => $params['is_best'], - 'is_like' => $params['is_like'], - 'is_team' => $params['is_team'], - 'is_integral' => $params['is_integral'], - 'is_member' => $params['is_member'], - 'give_integral_type' => $params['give_integral_type'], - 'give_integral' => $params['give_integral'], - 'is_express' => $params['is_express'], - 'is_selffetch' => $params['is_selffetch'] - ]); - foreach($params['goods_image'] as $key=>$value){ - $d['goods_id'] = $id; - $d['uri'] = $value; - Db::name("goods_image")->save($d); - } - $goods_spec_id = Db::name('goods_spec') - ->insertGetId(['goods_id' => $id, 'name' => $params['spec_name']]); - $goods_spec_value_id = Db::name('goods_spec_value') - ->insertGetId(['spec_id' => $goods_spec_id, 'goods_id' => $id, 'value' => $params['spec_value_name']]); + try { + Db::startTrans(); + $time = time(); + + //算出最大最小价格 + if ($post['spec_type'] == 1) { + $max_price = $post['one_price']; + $min_price = $post['one_price']; + $market_price = $post['one_market_price']; + $total_stock = $post['one_stock']; + } else { + $max_price = max($post['price']); + $min_price = min($post['price']); + $min_price_key = array_search($min_price,$post['price']); + $market_price = $post['market_price'][$min_price_key]; + $total_stock = array_sum($post['stock']); + } + $free_shipping = $post['free_shipping_type'] == 2 ? $post['free_shipping']: ''; + $free_shipping_template_id = $post['free_shipping_type'] == 3 ? $post['free_shipping_template_id']: ''; + + // 替换内容中图片地址 + $domain = UrlServer::getFileUrl('/'); + $post['content'] = str_replace($domain, '/', $post['content']); + + //赠送积分类型 + $give_integral_type = $post['give_integral_type'] ?? 0; + switch ($give_integral_type){ + case 1: + $give_integral = empty($post['give_integral_num']) ? 0 : $post['give_integral_num']; + break; + case 2: + $give_integral = empty($post['give_integral_ratio']) ? 0 : $post['give_integral_ratio']; + break; + default: + $give_integral = 0; + } + + $video = isset($post['video']) ? UrlServer::setFileUrl($post['video']) : ''; + + //写入主表 $data = [ - 'image' => $params['one_spec_image'], - 'goods_id' => $id, - 'spec_value_ids' => $goods_spec_value_id, - 'spec_value_str' => $params['spec_value_str'], - 'market_price' => $params['one_market_price'], - 'price' => $params['one_price'], - 'cost_price' => $params['one_cost_price'], - 'stock' => $params['one_stock'], - 'volume' => $params['one_volume'], - 'weight' => $params['one_weight'], - 'bar_code' => $params['one_bar_code'], + 'name' => $post['name'], + 'code' => $post['code'], + 'first_category_id' => $post['first_category_id'], + 'second_category_id' => $post['second_category_id'], + 'third_category_id' => $post['third_category_id'], + 'brand_id' => $post['brand_id'], + 'supplier_id' => $post['supplier_id'], + 'image' => $post['image'], + 'video' => $video, + 'poster' => $post['poster'] ?? '', + 'remark' => $post['remark'], + 'content' => $post['content'], + 'max_price' => $max_price, + 'min_price' => $min_price, + 'market_price' => $market_price, + 'stock' => $total_stock, + 'status' => $post['status'], + 'virtual_sales_sum' => $post['virtual_sales_sum'], + 'virtual_click' => $post['virtual_click'] ?? 0, + 'stock_warn' => $post['stock_warn'], + 'is_show_stock' => $post['is_show_stock'], + 'free_shipping_type' => $post['free_shipping_type'], + 'free_shipping' => $free_shipping, + 'free_shipping_template_id' => $free_shipping_template_id, + 'is_new' => isset($post['is_new']) && $post['is_new'] == 'on' ? 1 : 0, + 'is_best' => isset($post['is_best']) && $post['is_best'] == 'on' ? 1 : 0, + 'is_like' => isset($post['is_like']) && $post['is_like'] == 'on' ? 1 : 0, + 'is_integral' => $post['is_integral'], + 'is_member' => $post['is_member'], + 'give_integral_type' => $give_integral_type, + 'give_integral' => $give_integral, + 'spec_type' => $post['spec_type'], + 'create_time' => $time, + 'is_express' => isset($post['is_express']) && $post['is_express'] == 'on' ? 1 : 0, + 'is_selffetch' => isset($post['is_selffetch']) && $post['is_selffetch'] == 'on' ? 1 : 0, ]; - Db::name('goods_item') - ->insert($data); + $goods_id = Db::name('goods')->insertGetId($data); + + //写入图片表 + $data = []; + foreach ($post['goods_image'] as $k => $v) { + $data[] = [ + 'goods_id' => $goods_id, + 'uri' => $v, + ]; + } + Db::name('goods_image')->insertAll($data); + + + //写入规格表 + if ($post['spec_type'] == 1) { + //单规格写入 + $goods_spec_id = Db::name('goods_spec') + ->insertGetId(['goods_id' => $goods_id, 'name' => '默认']); + $goods_spec_value_id = Db::name('goods_spec_value') + ->insertGetId(['spec_id' => $goods_spec_id, 'goods_id' => $goods_id, 'value' => '默认']); + + $data = [ + 'image' => $post['one_spec_image'], + 'goods_id' => $goods_id, + 'spec_value_ids' => $goods_spec_value_id, + 'spec_value_str' => '默认', + 'market_price' => $post['one_market_price'], + 'price' => $post['one_price'], + 'cost_price' => $post['one_cost_price'], + 'stock' => $post['one_stock'], + 'volume' => $post['one_volume'], + 'weight' => $post['one_weight'], + 'bar_code' => $post['one_bar_code'], + ]; + Db::name('goods_item') + ->insert($data); + } else { + //多规格写入 + $goods_specs = []; + foreach ($post['spec_name'] as $k => $v) { + $temp = ['goods_id' => $goods_id, 'name' => $v]; + $goods_specs[] = $temp; + } + Db::name('goods_spec')->insertAll($goods_specs); + $goods_spec_name_key_id = Db::name('goods_spec') + ->where(['goods_id' => $goods_id]) + ->where('name', 'in', $post['spec_name']) + ->column('id', 'name'); + + $data = []; + $check_values = []; //检查规格项是否存在相同值,相同值会出现错误 + + foreach ($post['spec_values'] as $k => $v) { + $row = explode(',', $v); + foreach ($row as $k2 => $v2) { + if (in_array($v2, $check_values)) { + throw new Exception('请勿添加相同规格值'); + } + $temp = [ + 'goods_id' => $goods_id, + 'spec_id' => $goods_spec_name_key_id[$post['spec_name'][$k]], + 'value' => $v2, + ]; + $data[] = $temp; + $check_values[] = $v2; + } + } + + Db::name('goods_spec_value')->insertAll($data); + $goods_spec_name_value_id = Db::name('goods_spec_value') + ->where(['goods_id' => $goods_id]) + ->column('id', 'value'); + + foreach ($spec_lists as $k => $v) { + $spec_lists[$k]['spec_value_ids'] = ''; + $temp = explode(',', $v['spec_value_str']); + + foreach ($temp as $k2 => $v2) { + $spec_lists[$k]['spec_value_ids'] .= $goods_spec_name_value_id[$v2] . ','; + } + $spec_lists[$k]['spec_value_ids'] = trim($spec_lists[$k]['spec_value_ids'], ','); + $spec_lists[$k]['image'] = $spec_lists[$k]['spec_image']; + $spec_lists[$k]['goods_id'] = $goods_id; + unset($spec_lists[$k]['spec_image']); + unset($spec_lists[$k]['spec_id']); + unset($spec_lists[$k]['item_id']); + } + Db::name('goods_item')->insertAll($spec_lists); + } + Db::commit(); return true; - } catch (\Exception $e) { + } catch (Exception $e) { Db::rollback(); - self::setError($e->getMessage()); - return false; + return $e->getMessage(); } } diff --git a/app/common.php b/app/common.php index 5fff698..b2f5938 100755 --- a/app/common.php +++ b/app/common.php @@ -176,6 +176,37 @@ function linear_to_tree($data, $sub_key_name = 'children', $id_name = 'id', $par } return $tree; } +/** + * User: 意象信息科技 lr + * Desc: 表单多维数据转换 + * 例： + * 转换前：{"x":0,"a":[1,2,3],"b":[11,22,33],"c":[111,222,3333,444],"d":[1111,2222,3333]} + * 转换为：[{"a":1,"b":11,"c":111,"d":1111},{"a":2,"b":22,"c":222,"d":2222},{"a":3,"b":33,"c":3333,"d":3333}] + * @param $arr array 表单二维数组 + * @param $fill boolean fill为false，返回数据长度取最短，反之取最长，空值自动补充 + * @return array + */ +function form_to_linear($arr, $fill = false) +{ + $keys = []; + $count = $fill ? 0 : PHP_INT_MAX; + foreach ($arr as $k => $v) { + if (is_array($v)) { + $keys[] = $k; + $count = $fill ? max($count, count($v)) : min($count, count($v)); + } + } + if (empty($keys)) { + return []; + } + $data = []; + for ($i = 0; $i < $count; $i++) { + foreach ($keys as $v) { + $data[$i][$v] = isset($arr[$v][$i]) ? $arr[$v][$i] : null; + } + } + return $data; +} /** * 生成会员码