project

mydemo/src/main/java/com/saraad/common/util/IdWorker.java

@@ -95,6 +95,9 @@ public class IdWorker {
      *  @Time2017-6-8 15:02:29
      */
     public static long generateId() {
+        //未初始化swquence时生成Id会报空指针,若未初始化,默认机器码为100初始化
+        if(null == sequence)
+            init(100);
         try {
             while (true) {
                 //序号+1

mydemo/src/main/java/com/saraad/controller/TestController.java

@@ -49,6 +49,11 @@ public class TestController {
         return productService.queryAll();
     }
 
+    @ApiOperation("测试新增")
+    @PostMapping("/addTest")
+    public BaseResponse addTest(@RequestBody ProductVo productVo){
+        return productService.addTest(productVo);
+    }
 
 
 

mydemo/src/main/java/com/saraad/dao/ProductDao.java

@@ -27,9 +27,15 @@ public class ProductDao {
 
     static {
         ArrayList<ProductVo> products = new ArrayList<>();
-        products.add(new ProductVo(IdWorker.generateId(), "product_01", "10001", "初始商品1"));
-        products.add(new ProductVo(IdWorker.generateId(), "product_02", "10002", "初始商品2"));
-        products.add(new ProductVo(IdWorker.generateId(), "product_03", "10003", "初始商品3"));
+        try {
+            products.add(new ProductVo(IdWorker.generateId(), "product_01", "10001", "初始商品1"));
+            Thread.sleep(1);
+            products.add(new ProductVo(IdWorker.generateId(), "product_02", "10002", "初始商品2"));
+            Thread.sleep(1);
+            products.add(new ProductVo(IdWorker.generateId(), "product_03", "10003", "初始商品3"));
+        } catch (InterruptedException e) {
+
+        }
         list = products;
     }
 
@@ -44,7 +50,14 @@ public class ProductDao {
         if (null == productVo) return 0;
         if (null == productVo.getId()) return 0;
         //查看当前id的productVo是否已存在
+//        Stream<ProductVo> stream = list.stream().filter(p -> p.getId().longValue() == productVo.getId().longValue());
+//        List<ProductVo> exsitList = stream.collect(Collectors.toList());
         List<ProductVo> exsitList = list.stream().filter(p -> p.getId().longValue() == productVo.getId().longValue()).collect(Collectors.toList());
+//        ArrayList<ProductVo> exsitList = new ArrayList<>();
+//        for (ProductVo vo : list) {
+//            if (productVo.getId().longValue() == vo.getId().longValue())
+//                exsitList.add(vo);
+//        }
         if (!CollectionUtils.isEmpty(exsitList))
             return 0;
         list.add(productVo);

mydemo/src/main/java/com/saraad/service/ProductService.java

@@ -57,4 +57,18 @@ public class ProductService {
         return new BaseResponse(Version.VERSION_1.getCode(), StatusEnum.STATUS_100.getCode(),StatusEnum.STATUS_100.getMesssage(),list);
     }
 
+    /**
+     * add
+     * @param productVo
+     * @return
+     */
+    public BaseResponse addTest(ProductVo productVo){
+//        productVo.setId(IdWorker.generateId());
+        Integer res = productDao.add(productVo);
+        if (1 == res){
+            return new BaseResponse(Version.VERSION_1.getCode(), StatusEnum.STATUS_100.getCode(),StatusEnum.STATUS_100.getMesssage());
+        }
+        return new BaseResponse(Version.VERSION_1.getCode(), StatusEnum.STATUS_101.getCode(),StatusEnum.STATUS_101.getMesssage());
+    }
+
 }

mydemo/src/main/resources/application-dev.yml

+#服务端口,路径
 server:
   port: 7777
   context-path: /product
+#服务名
 spring:
   application:
     name: product
+#swagger配置
 swagger:
   basepackage: "com.saraad.controller"
   title: "Product Service"
\ No newline at end of file