ProductInfo Service finished

Author: csjihe

src/main/java/com/csjihe/springbootwechatordersystem/enums/ProductStatusEnum.java

@@ -0,0 +1,27 @@
+package com.csjihe.springbootwechatordersystem.enums;
+
+
+import lombok.Getter;
+
+/**
+ * Product Status
+ */
+
+@Getter
+public enum ProductStatusEnum {
+
+
+    UP(0, "在架"),
+    DOWN(0, "已下架");
+
+    private Integer code;
+
+    private String message;
+
+    ProductStatusEnum(Integer code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+
+
+}

src/main/java/com/csjihe/springbootwechatordersystem/service/ProductService.java

@@ -0,0 +1,25 @@
+package com.csjihe.springbootwechatordersystem.service;
+
+import com.csjihe.springbootwechatordersystem.dataobject.ProductInfo;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+public interface ProductService {
+
+    ProductInfo findOne(String productId);
+
+
+    /** Find all on-shelf product */
+    List<ProductInfo> findUpAll();
+
+    Page<ProductInfo> findAll(Pageable pageable);
+
+    ProductInfo save(ProductInfo productInfo);
+
+    // Increase stock
+
+
+    // Decrease stock
+}

src/main/java/com/csjihe/springbootwechatordersystem/service/implementation/ProductServiceImpl.java

@@ -0,0 +1,40 @@
+package com.csjihe.springbootwechatordersystem.service.implementation;
+
+import com.csjihe.springbootwechatordersystem.dataobject.ProductInfo;
+import com.csjihe.springbootwechatordersystem.enums.ProductStatusEnum;
+import com.csjihe.springbootwechatordersystem.repository.ProductInfoRepository;
+import com.csjihe.springbootwechatordersystem.service.ProductService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+
+@Service
+public class ProductServiceImpl implements ProductService {
+
+    @Autowired
+    private ProductInfoRepository repository;
+
+    @Override
+    public ProductInfo findOne(String productId) {
+        return repository.findOne(productId);
+    }
+
+    @Override
+    public List<ProductInfo> findUpAll() {
+        return repository.findByProductStatus(ProductStatusEnum.UP.getCode());
+    }
+
+    @Override
+    public Page<ProductInfo> findAll(Pageable pageable) {
+        return repository.findAll(pageable);
+    }
+
+    @Override
+    public ProductInfo save(ProductInfo productInfo) {
+        return repository.save(productInfo);
+    }
+}

src/test/java/com/csjihe/springbootwechatordersystem/service/implementation/ProductServiceImplTest.java

@@ -0,0 +1,65 @@
+package com.csjihe.springbootwechatordersystem.service.implementation;
+
+import com.csjihe.springbootwechatordersystem.dataobject.ProductInfo;
+import com.csjihe.springbootwechatordersystem.enums.ProductStatusEnum;
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.test.context.junit4.SpringRunner;
+
+
+import java.math.BigDecimal;
+import java.util.List;
+
+import static org.junit.Assert.*;
+
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class ProductServiceImplTest {
+
+    @Autowired
+    private ProductServiceImpl productService;
+
+    @Test
+    public void findOne() {
+        ProductInfo productInfo = productService.findOne("123456");
+        Assert.assertEquals("123456", productInfo.getProductId());
+    }
+
+    @Test
+    public void findUpAll() {
+        List<ProductInfo>  productInfoList = productService.findUpAll();
+        Assert.assertNotEquals(0, productInfoList.size());
+    }
+
+    @Test
+    public void findAll() {
+        PageRequest request = new PageRequest(0, 2);
+        Page<ProductInfo> productInfoPage = productService.findAll(request);
+        System.out.println(productInfoPage.getTotalElements());
+    }
+
+    @Test
+    public void save() {
+        ProductInfo productInfo = new ProductInfo();
+
+        productInfo.setProductId("123457");
+        productInfo.setProductName("皮皮虾");
+        productInfo.setProductPrice(new BigDecimal(3.2));
+        productInfo.setProductStock(100);
+        productInfo.setProductDescription("Good Shrimp");
+        productInfo.setProductIcon("http://xxx.jpg");
+        productInfo.setProductStatus(ProductStatusEnum.DOWN.getCode());
+        productInfo.setCategoryType(2);
+
+        ProductInfo result = productService.save(productInfo);
+        Assert.assertNotEquals(null, result);
+
+    }
+}