天天看點
傳回

java項目 暢購商場 商品管理

第4章 商品管理

學習目标

能夠使用開源算法snowflake生成分布式id

完成新增和修改商品功能

完成商品稽核和上下架功能

完成删除與還原商品功能

  1. 分布式ID生成解決方案

    1.1 分布式ID生成解決方案

    1.1.1 UUID

    常見的方式。可以利用資料庫也可以利用程式生成，一般來說全球唯一。

優點：

1）簡單，代碼友善。

2）生成ID性能非常好，基本不會有性能問題。

3）全球唯一，在遇見資料遷移，系統資料合并，或者資料庫變更等情況下，可以從容應對。

缺點：

1）沒有排序，無法保證趨勢遞增。

2）UUID往往是使用字元串存儲，查詢的效率比較低。

3）存儲空間比較大，如果是海量資料庫，就需要考慮存儲量的問題。

4）傳輸資料量大

5）不可讀。

1.1.2 Redis

當使用資料庫來生成ID性能不夠要求的時候，我們可以嘗試使用Redis來生成ID。這主要依賴于Redis是單線程的，是以也可以用生成全局唯一的ID。可以用Redis的原子操作 INCR和INCRBY來實作。

優點：

1）不依賴于資料庫，靈活友善，且性能優于資料庫。

2）數字ID天然排序，對分頁或者需要排序的結果很有幫助。

缺點：

1）如果系統中沒有Redis，還需要引入新的元件，增加系統複雜度。

2）需要編碼和配置的工作量比較大。

3）網絡傳輸造成性能下降。

1.1.3 開源算法snowflake

snowflake是Twitter開源的分布式ID生成算法，結果是一個long型的ID。其核心思想是：使用41bit作為毫秒數，10bit作為機器的ID（5個bit是資料中心，5個bit的機器ID），12bit作為毫秒内的流水号（意味着每個節點在每毫秒可以産生 4096 個 ID），最後還有一個符号位，永遠是0

java項目 暢購商場 商品管理

我們在《暢購》系統中采用的就是開源算法snowflake

1.2 snowflake快速入門

1.2.1 快速入門

（1）建立工程，将資料/工具類下的IdWorker.java拷貝到工程中。

（2）編寫代碼

IdWorker idWorker=new IdWorker(1,1);
​
        for(int i=0;i<10000;i++){
            long id = idWorker.nextId();
            System.out.println(id);
        }
           
1.2.2 配置分布式ID生成器
（1）IdWorker.java拷貝到changgou_common工程com.changgou.util包中

（2）changgou_service_goods的application.yml添加配置

workerId: 0
datacenterId: 0
（3）修改GoodsApplication，增加代碼

    @Value("${workerId}")
    private Integer workerId;
​
    @Value("${datacenterId}")
    private Integer datacenterId;
​
    @Bean
    public IdWorker idWorker(){
        return new IdWorker(workerId,datacenterId);
    }
2 新增和修改商品
2.1 概念與表結構分析
2.1.1 SPU與SKU概念
SPU = Standard Product Unit  （标準産品機關）

概念 : SPU 是商品資訊聚合的最小機關，是一組可複用、易檢索的标準化資訊的集合，該集合描述了一個産品的特性。

通俗點講，屬性值、特性相同的貨品就可以稱為一個 SPU

例如：華為P30 就是一個 SPU

SKU=stock keeping unit( 庫存量機關)

SKU 即庫存進出計量的機關， 可以是以件、盒、托盤等為機關。

SKU 是實體上不可分割的最小存貨單元。在使用時要根據不同業态，不同管理模式來處理。

在服裝、鞋類商品中使用最多最普遍。

例如：華為P30 紅色 64G 就是一個 SKU

2.1.2 表結構分析
tb_spu 表 （SPU表）

字段名稱	字段含義	字段類型	字段長度	備注
id	主鍵	VARCHAR	 	 
sn	貨号	VARCHAR	 	 
name	SPU名	VARCHAR	 	 
caption	副标題	VARCHAR	 	 
brand_id	品牌ID	INT	 	 
category1_id	一級分類	INT	 	 
category2_id	二級分類	INT	 	 
category3_id	三級分類	INT	 	 
template_id	模闆ID	INT	 	 
freight_id	運費模闆id	INT	 	 
image	圖檔	VARCHAR	 	 
images	圖檔清單	VARCHAR	 	 
sale_service	售後服務	VARCHAR	 	 
introduction	介紹	TEXT	 	 
spec_items	規格清單	VARCHAR	 	 
para_items	參數清單	VARCHAR	 	 
sale_num	銷量	INT	 	 
comment_num	評論數	INT	 	 
is_marketable	是否上架	CHAR	 	 
is_enable_spec	是否啟用規格	CHAR	 	 
is_delete	是否删除	CHAR	 	 
status	稽核狀态	CHAR	 	 
tb_sku 表（SKU商品表）

字段名稱	字段含義	字段類型	字段長度	備注
id	商品id	VARCHAR	 	 
sn	商品條碼	VARCHAR	 	 
name	SKU名稱	VARCHAR	 	 
price	價格（分）	INT	 	 
num	庫存數量	INT	 	 
alert_num	庫存預警數量	INT	 	 
image	商品圖檔	VARCHAR	 	 
images	商品圖檔清單	VARCHAR	 	 
weight	重量（克）	INT	 	 
create_time	建立時間	DATETIME	 	 
update_time	更新時間	DATETIME	 	 
spu_id	SPUID	BIGINT	 	 
category_id	類目ID	INT	 	 
category_name	類目名稱	VARCHAR	 	 
brand_name	品牌名稱	VARCHAR	 	 
spec	規格	VARCHAR	 	 
sale_num	銷量	INT	 	 
comment_num	評論數	INT	 	 
status	商品狀态 1-正常，2-下架，3-删除	CHAR	 	 
 

2.2 實作思路
前端傳遞給後端的資料格式 是一個spu對象和sku清單組成的對象

```java
{
    "spu": {
        "name": "這個是商品名稱",
        "caption": "這個是副标題",
        "brandId": 12,
        "category1Id": 558,
        "category2Id": 559,
        "category3Id": 560,
        "freightId": 10,
        "image": "http://www.changgou.com/image/1.jpg",
         "images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
        "introduction": "這個是商品詳情，html代碼",
         "paraItems": "{'出廠年份':'2019','贈品':'充電器'}",
        "saleService": "七天包退,閃電退貨",
        "sn": "020102331",
        "specItems":  "{'顔色':['紅','綠'],'機身記憶體':['64G','8G']}",
        "templateId": 42
    },
    "skuList": [{
        "sn": "10192010292",
         "num": 100,
         "alertNum": 20,
         "price": 900000,
         "spec": "{'顔色':'紅','機身記憶體':'64G'}",
         "image": "http://www.changgou.com/image/1.jpg",
         "images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
        "status": "1",
        "weight": 130
    },
    {
        "sn": "10192010293",
         "num": 100,
         "alertNum": 20,
         "price": 600000,
         "spec": "{'顔色':'藍','機身記憶體':'128G'}",
         "image": "http://www.changgou.com/image/1.jpg",
         "images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
        "status": "1",
        "weight": 130
    }
  ]
}

2.3 代碼實作

2.3.1 SPU與SKU清單的儲存

代碼實作：

（1）changgou_service_goods_api工程建立組合實體類Goods

public class Goods implements Serializable {

​

private Spu spu;

private List skuList;

​

public Spu getSpu() {

return spu;

}

​

public void setSpu(Spu spu) {

this.spu = spu;

}

​

public List getSkuList() {

return skuList;

}

​

public void setSkuList(List skuList) {

this.skuList = skuList;

}

}

（2）changgou_service_goods工程SpuService新增方法add(Goods goods)

void add(Goods goods);

（3）changgou_service_goods工程SpuServiceImpl實作此方法

@Autowired

private CategoryMapper categoryMapper;

​

@Autowired

private SkuMapper skuMapper;

​

@Autowired

private BrandMapper brandMapper;

​

@Autowired

private IdWorker idWorker;

​

private void saveSkuList(Goods goods){

//擷取spu對象

Spu spu = goods.getSpu();

//目前日期

Date date = new Date();

//擷取品牌對象

Brand brand = brandMapper.selectByPrimaryKey(spu.getBrandId());

//擷取分類對象

Category category = categoryMapper.selectByPrimaryKey(spu.getCategory3Id());

//擷取sku集合對象

List skuList = goods.getSkuList();

if (skuList != null) {

for (Sku sku : skuList) {

//設定sku主鍵ID

sku.setId(String.valueOf(idWorker.nextId()));

//設定sku規格

if (sku.getSpec() == null || “”.equals(sku.getSpec())) {

sku.setSpec("{}");

}

//設定sku名稱(商品名稱 + 規格)

String name = spu.getName();

//将規格json字元串轉換成Map

Map<String, String> specMap = JSON.parseObject(sku.getSpec(), Map.class);

if (specMap != null && specMap.size() > 0) {

for(String value : specMap.values()){

name += " "+ value;

}

}

​

sku.setName(name);//名稱

sku.setSpuId(spu.getId());//設定spu的ID

sku.setCreateTime(date);//建立日期

sku.setUpdateTime(date);//修改日期

sku.setCategoryId(category.getId());//商品分類ID

sku.setCategoryName(category.getName());//商品分類名稱

sku.setBrandName(brand.getName());//品牌名稱

skuMapper.insertSelective(sku);//插入sku表資料

}

}

}

（3）修改SpuController的add方法

@PostMapping

public Result add(@RequestBody Goods goods){

spuService.add(goods);

return new Result(true,StatusCode.OK,“添加成功”);

}

2.3.2 品牌與分類關聯

實作思路：

将分類ID與SPU的品牌ID 一起插入到tb_category_brand表中

（1）建立實體類

@Table(name=“tb_category_brand”)

public class CategoryBrand implements Serializable {

​

@Id

private Integer categoryId;

​

@Id

private Integer brandId;

​

​

public Integer getCategoryId() {

return categoryId;

}

​

public void setCategoryId(Integer categoryId) {

this.categoryId = categoryId;

}

​

public Integer getBrandId() {

return brandId;

}

​

public void setBrandId(Integer brandId) {

this.brandId = brandId;

}

}

這個表是聯合主鍵，是以templateId和brandId都有@Id注解

（2）建立資料通路接口

public interface CategoryBrandMapper extends Mapper {

}

（3）SpuServiceImpl引入

@Autowired
private CategoryBrandMapper categoryBrandMapper;

（4）修改SpuServiceImpl的saveSkuList方法，添加分類與品牌之間的關聯, 修改後代碼如下:

private void saveSkuList(Goods goods) {

//擷取spu對象

Spu spu = goods.getSpu();

//目前日期

Date date = new Date();

//擷取品牌對象

Brand brand = brandMapper.selectByPrimaryKey(spu.getBrandId());

//擷取分類對象

Category category = categoryMapper.selectByPrimaryKey(spu.getCategory3Id());

​

CategoryBrand categoryBrand = new CategoryBrand();

categoryBrand.setBrandId(spu.getBrandId());

categoryBrand.setCategoryId(spu.getCategory3Id());

int count = categoryBrandMapper.selectCount(categoryBrand);

//判斷是否有這個品牌和分類的關系資料

if(count == 0) {

//如果沒有關系資料則添加品牌和分類關系資料

categoryBrandMapper.insert(categoryBrand);

}

​

//擷取sku集合對象

List skuList = goods.getSkuList();

if (skuList != null) {

for (Sku sku : skuList) {

//設定sku主鍵ID

sku.setId(String.valueOf(idWorker.nextId()));

//設定sku規格

if (sku.getSpec() == null || “”.equals(sku.getSpec())) {

sku.setSpec("{}");

}

//設定sku名稱(商品名稱 + 規格)

String name = spu.getName();

//将規格json字元串轉換成Map

Map<String, String> specMap = JSON.parseObject(sku.getSpec(), Map.class);

if (specMap != null && specMap.size() > 0) {

for(String value : specMap.values()){

name += " "+ value;

}

}

​

sku.setName(name);//名稱

sku.setSpuId(spu.getId());//設定spu的ID

sku.setCreateTime(date);//建立日期

sku.setUpdateTime(date);//修改日期

sku.setCategoryId(category.getId());//商品分類ID

sku.setCategoryName(category.getName());//商品分類名稱

sku.setBrandName(brand.getName());//品牌名稱

skuMapper.insertSelective(sku);//插入sku表資料

}

}

}

2.3.3 根據ID查詢商品

需求：根據id 查詢SPU和SKU清單 ，顯示效果如下：

{

“spu”: {

“brandId”: 8557,

“caption”: “111”,

“category1Id”: 558,

“category2Id”: 559,

“category3Id”: 560,

“commentNum”: 0,

“freightId”: 0,

“id”: 149187842867993,

“image”: “”,

“images”: “[{“color”:“銀白色”,“url”:”//img11.360buyimg.com/n7/jfs/t30040/100/1290632710/208879/1f7e2225/5cdd0d92Nb78895a6.jpg"}]",

“introduction”: “這是測試手機資料”,

“isDelete”: 0,

“isEnableSpec”: “0”,

“isMarketable”: “0”,

“name”: “黑馬智能手機”,

“paraItems”: “”,

“saleNum”: 0,

“saleService”: “”,

“sn”: “”,

“specItems”: “{“顔色”:[“金色”,“黑色”,“藍色”],“版本”:[“6GB+64GB”]}”,

“status”: “0”,

“templateId”: 42

},

“skuList”: [{

“alertNum”: 100,

“commentNum”: 0,

“image”: “https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp”,

“images”: “https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp”,

“num”: 100,

“price”: 90000,

“saleNum”: 0,

“sn”: “”,

“spec”: “{‘顔色’: ‘藍色’}”,

“status”: “1”,

“weight”: 10

},{

“alertNum”: 100,

“commentNum”: 0,

“image”: “https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp”,

“images”: “https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp”,

“num”: 100,

“price”: 80000,

“saleNum”: 0,

“sn”: “”,

“spec”: “{‘顔色’: ‘黑色’}”,

“status”: “1”,

“weight”: 10

}

]

}

代碼實作：

（1）changgou_service_goods工程SpuService新增方法定義

/**
 * 根據ID查詢商品
 * @param id
 * @return
 */
public Goods findGoodsById(String id);

（2）changgou_service_goods工程SpuServiceImpl實作此方法

/**
 * 根據ID查詢商品
 * @param id
 * @return
 */
public Goods findGoodsById(String id){
    //查詢spu
    Spu spu = spuMapper.selectByPrimaryKey(id);

​

//查詢SKU 清單

Example example=new Example(Sku.class);

Example.Criteria criteria = example.createCriteria();

criteria.andEqualTo(“spuId”,id);

List skuList = skuMapper.selectByExample(example);

​

//封裝，傳回

Goods goods=new Goods();

goods.setSpu(spu);

goods.setSkuList(skuList);

return goods;

}

（3）修改SpuController的findById方法

@GetMapping("/{id}")
public Result findById(@PathVariable String id){
    Goods goods = spuService.findGoodsById(id);
    return new Result(true,StatusCode.OK,"查詢成功",goods);
}

2.3.4 儲存修改

（1）changgou_service_goods工程SpuService新增方法定義

/***
 * 修改資料
 * @param spu
 */
void update(Goods goods);

（2）changgou_service_goods工程SpuServiceImpl實作此方法

​

@Override

public void update(Goods goods ) {

//取出spu部分

Spu spu = goods.getSpu();

spuMapper.updateByPrimaryKey(spu);

//删除原sku清單

Example example=new Example(Sku.class);

Example.Criteria criteria = example.createCriteria();

criteria.andEqualTo(“spuId”,spu.getId());

skuMapper.deleteByExample(example);

​

saveSkuList(goods);//儲存sku清單

}

（3）修改SpuController的update方法

/***
 * 修改資料
 * @param goods
 * @param id
 * @return
 */
@PutMapping(value="/{id}")
public Result update(@RequestBody Goods goods,@PathVariable String id){
    spuService.update(goods);
    return new Result(true,StatusCode.OK,"修改成功");
}

3 商品稽核與上下架

3.1 需求分析

商品新增後，稽核狀态為0（未稽核），預設為下架狀态。

稽核商品，需要校驗是否是被删除的商品，如果未删除則修改稽核狀态為1，并自動上架

下架商品，需要校驗是否是被删除的商品，如果未删除則修改上架狀态為0

上架商品，需要稽核狀态為1,如果為1,則更改上下架狀态為1

3.2 實作思路

（1）按照ID查詢SPU資訊

（2）判斷修改稽核、上架下架狀态

（3）儲存SPU

3.3 代碼實作

3.3.1 商品稽核

需要校驗是否是被删除的商品，如果未删除則修改稽核狀态為1，并自動上架

（1）SpuService新增方法

/**
 * 稽核
 * @param id
 */
public void audit(String id);

（2）SpuServiceImpl實作方法

@Transactional

public void audit(String id) {

//查詢spu對象

Spu spu = spuMapper.selectByPrimaryKey(id);

if (spu == null){

throw new RuntimeException(“目前商品不存在”);

}

//判斷目前spu是否處于删除狀态

if (“1”.equals(spu.getIsDelete())){

throw new RuntimeException(“目前商品處于删除狀态”);

}

//不處于删除狀态,修改稽核狀态為1,上下架狀态為1

spu.setStatus(“1”);

spu.setIsMarketable(“1”);

//執行修改操作

spuMapper.updateByPrimaryKeySelective(spu);

}

（2）SpuController新增方法

/**
 * 稽核
 * @param id
 * @return
 */
@PutMapping("/audit/{id}")
public Result audit(@PathVariable String id){
    spuService.audit(id);
    return new Result();
}

3.3.2 下架商品

校驗是否是被删除的商品，如果未删除則修改上架狀态為0

（1）SpuService新增方法

/**
 * 下架商品
 * @param id
 */
public void pull(String id);

（2）SpuServiceImpl實作方法

@Transactional

public void pull(String id) {

//查詢spu

Spu spu = spuMapper.selectByPrimaryKey(id);

if (spu == null){

throw new RuntimeException(“目前商品不存在”);

}

//判斷目前商品是否處于删除狀态

if (“1”.equals(spu.getIsDelete())){

throw new RuntimeException(“目前商品處于删除狀态”);

}

//商品處于未删除狀态的話,則修改上下架狀态為已下架(0)

spu.setIsMarketable(“0”);

spuMapper.updateByPrimaryKeySelective(spu);

}

（2）SpuController新增方法

/**
 * 下架
 * @param id
 * @return
 */
@PutMapping("/pull/{id}")
public Result pull(@PathVariable String id){
    spuService.pull(id);
    return new Result();
}

3.3.3 上架商品

必須是通過稽核的商品才能上架

（1）SpuService新增方法

/**
 * 上架商品
 * @param id
 */
public void put(String id);

（2）SpuServiceImpl 實作此方法

/**
 * 上架商品
 * @param id
 */
@Override
public void put(String id) {
    Spu spu = spuMapper.selectByPrimaryKey(id);
    if(!spu.getStatus().equals("1")){
        throw new RuntimeException("未通過稽核的商品不能上架！");
    }
    spu.setIsMarketable("1");//上架狀态
    spuMapper.updateByPrimaryKeySelective(spu);
}

（3）SpuController新增方法

/**
 * 上架
 * @param id
 * @return
 */
@PutMapping("/put/{id}")
public Result put(@PathVariable String id){
    spuService.put(id);
    return new Result();
}

4 删除與還原商品

4.1 需求分析

商品清單中的删除商品功能，并非真正的删除(實體删除)，而是采用邏輯删除将删除标記的字段設定為1.

在資源回收筒中有還原商品的功能，将删除标記的字段設定為0

在資源回收筒中有删除商品的功能，是真正的實體删除,将資料從資料庫中删除掉。

4.2 實作思路

商品清單中的删除商品,執行邏輯删除，修改spu表is_delete字段為1

商品資源回收筒中的還原商品,修改spu表is_delete字段為0

商品資源回收筒中的删除商品,執行delete操作,進行實體删除

4.3 代碼實作

4.3.1 邏輯删除商品

修改SpuServiceImpl的delete方法

/**
 * 删除
 * @param id
 */
@Override
public void delete(String id){
    Spu spu = spuMapper.selectByPrimaryKey(id);
    //檢查是否下架的商品
    if(!spu.getIsMarketable().equals("0")){
        throw new RuntimeException("必須先下架再删除！");
    }
    spu.setIsDelete("1");//删除
    spu.setStatus("0");//未稽核
    spuMapper.updateByPrimaryKeySelective(spu);
}

4.3.2 還原被删除的商品

（1）SpuService新增方法

/**
 * 恢複資料
 * @param id
 */
public void restore(String id);

（2）SpuServiceImpl實作此方法

/**
 * 恢複資料
 * @param id
 */
@Override
public void restore(String id) {
    Spu spu = spuMapper.selectByPrimaryKey(id);
    //檢查是否删除的商品
    if(!spu.getIsDelete().equals("1")){
        throw new RuntimeException("此商品未删除！");
    }
    spu.setIsDelete("0");//未删除
    spu.setStatus("0");//未稽核
    spuMapper.updateByPrimaryKeySelective(spu);
}

（3）SpuController新增方法

/**
 * 恢複資料
 * @param id
 * @return
 */
@PutMapping("/restore/{id}")
public Result restore(@PathVariable String id){
    spuService.restore(id);
    return new Result();
}

4.3.3 實體删除商品

判斷必須邏輯删除商品才能實體删除

（1）SpuService 新增方法

/**
 * 實體删除
 * @param id
 */
public void realDelete(String id);

（2）SpuServiceImpl 實作方法

@Override
public void realDelete(String id) {
    Spu spu = spuMapper.selectByPrimaryKey(id);
    //檢查是否删除的商品
    if(!spu.getIsDelete().equals("1")){
        throw new RuntimeException("此商品未删除！");
    }
    spuMapper.deleteByPrimaryKey(id);
    
}

（3）SpuController新增方法

​

@DeleteMapping("/realDelete/{id}")

public Result realDelete(@PathVariable String id){

spuService.realDelete(id);

return new Result();

}

Java實戰項目 java 暢購商場 商品管理 實戰項目
上一篇: 各大搜尋引擎送出入口
下一篇: 搜尋引擎送出入口收集

繼續閱讀