java110 před 5 roky
rodič
revize
18c0ad848c
18 změnil soubory, kde provedl 950 přidání a 10 odebrání
  1. 90 0
      java110-bean/src/main/java/com/java110/dto/storeCart/StoreCartDto.java
  2. 81 0
      java110-bean/src/main/java/com/java110/po/storeCart/StoreCartPo.java
  3. 1 0
      java110-core/src/main/java/com/java110/core/factory/GenerateCodeFactory.java
  4. 124 0
      java110-db/src/main/resources/mapper/goods/StoreCartServiceDaoImplMapper.xml
  5. 21 10
      java110-generator/src/main/resources/newBack/template_1.json
  6. 52 0
      java110-interface/src/main/java/com/java110/intf/goods/IStoreCartInnerServiceSMO.java
  7. 115 0
      service-goods/src/main/java/com/java110/goods/api/StoreCartApi.java
  8. 17 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/IDeleteStoreCartBMO.java
  9. 19 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/IGetStoreCartBMO.java
  10. 19 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/ISaveStoreCartBMO.java
  11. 19 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/IUpdateStoreCartBMO.java
  12. 34 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/DeleteStoreCartBMOImpl.java
  13. 44 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/GetStoreCartBMOImpl.java
  14. 38 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/SaveStoreCartBMOImpl.java
  15. 34 0
      service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/UpdateStoreCartBMOImpl.java
  16. 61 0
      service-goods/src/main/java/com/java110/goods/dao/IStoreCartServiceDao.java
  17. 98 0
      service-goods/src/main/java/com/java110/goods/dao/impl/StoreCartServiceDaoImpl.java
  18. 83 0
      service-goods/src/main/java/com/java110/goods/smo/impl/StoreCartInnerServiceSMOImpl.java

+ 90 - 0
java110-bean/src/main/java/com/java110/dto/storeCart/StoreCartDto.java

@@ -0,0 +1,90 @@
+package com.java110.dto.storeCart;
+
+import com.java110.dto.PageDto;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @ClassName FloorDto
+ * @Description 购物车数据层封装
+ * @Author wuxw
+ * @Date 2019/4/24 8:52
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+public class StoreCartDto extends PageDto implements Serializable {
+
+    private String valueId;
+private String productId;
+private String cartId;
+private String personId;
+private String state;
+private String storeId;
+private String cartNum;
+
+
+    private Date createTime;
+
+    private String statusCd = "0";
+
+
+    public String getValueId() {
+        return valueId;
+    }
+public void setValueId(String valueId) {
+        this.valueId = valueId;
+    }
+public String getProductId() {
+        return productId;
+    }
+public void setProductId(String productId) {
+        this.productId = productId;
+    }
+public String getCartId() {
+        return cartId;
+    }
+public void setCartId(String cartId) {
+        this.cartId = cartId;
+    }
+public String getPersonId() {
+        return personId;
+    }
+public void setPersonId(String personId) {
+        this.personId = personId;
+    }
+public String getState() {
+        return state;
+    }
+public void setState(String state) {
+        this.state = state;
+    }
+public String getStoreId() {
+        return storeId;
+    }
+public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+public String getCartNum() {
+        return cartNum;
+    }
+public void setCartNum(String cartNum) {
+        this.cartNum = cartNum;
+    }
+
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public String getStatusCd() {
+        return statusCd;
+    }
+
+    public void setStatusCd(String statusCd) {
+        this.statusCd = statusCd;
+    }
+}

+ 81 - 0
java110-bean/src/main/java/com/java110/po/storeCart/StoreCartPo.java

@@ -0,0 +1,81 @@
+package com.java110.po.storeCart;
+
+import java.io.Serializable;
+
+public class StoreCartPo implements Serializable {
+
+    private String valueId;
+    private String productId;
+    private String cartId;
+    private String personId;
+    private String statusCd = "0";
+    private String state;
+    private String storeId;
+    private String cartNum;
+
+    public String getValueId() {
+        return valueId;
+    }
+
+    public void setValueId(String valueId) {
+        this.valueId = valueId;
+    }
+
+    public String getProductId() {
+        return productId;
+    }
+
+    public void setProductId(String productId) {
+        this.productId = productId;
+    }
+
+    public String getCartId() {
+        return cartId;
+    }
+
+    public void setCartId(String cartId) {
+        this.cartId = cartId;
+    }
+
+    public String getPersonId() {
+        return personId;
+    }
+
+    public void setPersonId(String personId) {
+        this.personId = personId;
+    }
+
+    public String getStatusCd() {
+        return statusCd;
+    }
+
+    public void setStatusCd(String statusCd) {
+        this.statusCd = statusCd;
+    }
+
+    public String getState() {
+        return state;
+    }
+
+    public void setState(String state) {
+        this.state = state;
+    }
+
+    public String getStoreId() {
+        return storeId;
+    }
+
+    public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+
+    public String getCartNum() {
+        return cartNum;
+    }
+
+    public void setCartNum(String cartNum) {
+        this.cartNum = cartNum;
+    }
+
+
+}

+ 1 - 0
java110-core/src/main/java/com/java110/core/factory/GenerateCodeFactory.java

@@ -163,6 +163,7 @@ public class GenerateCodeFactory {
     public static final String CODE_PREFIX_batchId = "93";
     public static final String CODE_PREFIX_statisticsId = "94";
     public static final String CODE_PREFIX_labelId = "94";
+    public static final String CODE_PREFIX_cartId = "95";
 
 
 

+ 124 - 0
java110-db/src/main/resources/mapper/goods/StoreCartServiceDaoImplMapper.xml

@@ -0,0 +1,124 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="storeCartServiceDaoImpl">
+
+
+
+
+
+    <!-- 保存购物车信息 add by wuxw 2018-07-03 -->
+    <insert id="saveStoreCartInfo" parameterType="Map">
+        insert into store_cart(
+value_id,product_id,cart_id,person_id,state,store_id,cart_num
+) values (
+#{valueId},#{productId},#{cartId},#{personId},#{state},#{storeId},#{cartNum}
+)
+    </insert>
+
+
+
+    <!-- 查询购物车信息 add by wuxw 2018-07-03 -->
+    <select id="getStoreCartInfo" parameterType="Map" resultType="Map">
+        select  t.value_id,t.value_id valueId,t.product_id,t.product_id productId,t.cart_id,t.cart_id cartId,t.person_id,t.person_id personId,t.status_cd,t.status_cd statusCd,t.state,t.store_id,t.store_id storeId,t.cart_num,t.cart_num cartNum 
+from store_cart t 
+where 1 =1 
+<if test="valueId !=null and valueId != ''">
+   and t.value_id= #{valueId}
+</if> 
+<if test="productId !=null and productId != ''">
+   and t.product_id= #{productId}
+</if> 
+<if test="cartId !=null and cartId != ''">
+   and t.cart_id= #{cartId}
+</if> 
+<if test="personId !=null and personId != ''">
+   and t.person_id= #{personId}
+</if> 
+<if test="statusCd !=null and statusCd != ''">
+   and t.status_cd= #{statusCd}
+</if> 
+<if test="state !=null and state != ''">
+   and t.state= #{state}
+</if> 
+<if test="storeId !=null and storeId != ''">
+   and t.store_id= #{storeId}
+</if> 
+<if test="cartNum !=null and cartNum != ''">
+   and t.cart_num= #{cartNum}
+</if> 
+order by t.create_time desc
+<if test="page != -1 and page != null ">
+   limit #{page}, #{row}
+</if> 
+
+    </select>
+
+
+
+
+    <!-- 修改购物车信息 add by wuxw 2018-07-03 -->
+    <update id="updateStoreCartInfo" parameterType="Map">
+        update  store_cart t set t.status_cd = #{statusCd}
+<if test="newBId != null and newBId != ''">
+,t.b_id = #{newBId}
+</if> 
+<if test="valueId !=null and valueId != ''">
+, t.value_id= #{valueId}
+</if> 
+<if test="productId !=null and productId != ''">
+, t.product_id= #{productId}
+</if> 
+<if test="personId !=null and personId != ''">
+, t.person_id= #{personId}
+</if> 
+<if test="state !=null and state != ''">
+, t.state= #{state}
+</if> 
+<if test="storeId !=null and storeId != ''">
+, t.store_id= #{storeId}
+</if> 
+<if test="cartNum !=null and cartNum != ''">
+, t.cart_num= #{cartNum}
+</if> 
+ where 1=1 <if test="cartId !=null and cartId != ''">
+and t.cart_id= #{cartId}
+</if> 
+
+    </update>
+
+    <!-- 查询购物车数量 add by wuxw 2018-07-03 -->
+     <select id="queryStoreCartsCount" parameterType="Map" resultType="Map">
+        select  count(1) count 
+from store_cart t 
+where 1 =1 
+<if test="valueId !=null and valueId != ''">
+   and t.value_id= #{valueId}
+</if> 
+<if test="productId !=null and productId != ''">
+   and t.product_id= #{productId}
+</if> 
+<if test="cartId !=null and cartId != ''">
+   and t.cart_id= #{cartId}
+</if> 
+<if test="personId !=null and personId != ''">
+   and t.person_id= #{personId}
+</if> 
+<if test="statusCd !=null and statusCd != ''">
+   and t.status_cd= #{statusCd}
+</if> 
+<if test="state !=null and state != ''">
+   and t.state= #{state}
+</if> 
+<if test="storeId !=null and storeId != ''">
+   and t.store_id= #{storeId}
+</if> 
+<if test="cartNum !=null and cartNum != ''">
+   and t.cart_num= #{cartNum}
+</if> 
+
+
+     </select>
+
+</mapper>

+ 21 - 10
java110-generator/src/main/resources/newBack/template_1.json

@@ -1,27 +1,38 @@
 {
   "autoMove": true,
-  "id": "labelId",
-  "name": "productLabel",
-  "desc": "产品标签",
+  "id": "cartId",
+  "name": "storeCart",
+  "desc": "购物车",
   "shareParam": "storeId",
   "shareColumn": "store_id",
   "shareName": "goods",
-  "tableName": "product_label",
+  "tableName": "store_cart",
   "param": {
-    "labelId": "label_id",
+    "cartId": "cart_id",
     "productId": "product_id",
     "storeId": "store_id",
-    "labelCd": "label_cd",
+    "valueId": "value_id",
+    "personId": "person_id",
+    "cartNum": "cart_num",
+    "state": "state",
     "statusCd": "status_cd"
   },
   "required": [
-    {
-      "code": "labelCd",
-      "msg": "标签不能为空"
-    },
     {
       "code": "productId",
       "msg": "产品不能为空"
+    },
+    {
+      "code": "valueId",
+      "msg": "规格值不能为空"
+    },
+    {
+      "code": "personId",
+      "msg": "用户ID不能为空"
+    },
+    {
+      "code": "cartNum",
+      "msg": "产品数量不能为空"
     }
   ]
 }

+ 52 - 0
java110-interface/src/main/java/com/java110/intf/goods/IStoreCartInnerServiceSMO.java

@@ -0,0 +1,52 @@
+package com.java110.intf.goods;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.storeCart.StoreCartDto;
+import com.java110.po.storeCart.StoreCartPo;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+
+/**
+ * @ClassName IStoreCartInnerServiceSMO
+ * @Description 购物车接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "goods-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/storeCartApi")
+public interface IStoreCartInnerServiceSMO {
+
+
+    @RequestMapping(value = "/saveStoreCart", method = RequestMethod.POST)
+    public int saveStoreCart(@RequestBody StoreCartPo storeCartPo);
+
+    @RequestMapping(value = "/updateStoreCart", method = RequestMethod.POST)
+    public int updateStoreCart(@RequestBody StoreCartPo storeCartPo);
+
+    @RequestMapping(value = "/deleteStoreCart", method = RequestMethod.POST)
+    public int deleteStoreCart(@RequestBody StoreCartPo storeCartPo);
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     * @param storeCartDto 数据对象分享
+     * @return StoreCartDto 对象数据
+     */
+    @RequestMapping(value = "/queryStoreCarts", method = RequestMethod.POST)
+    List<StoreCartDto> queryStoreCarts(@RequestBody StoreCartDto storeCartDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param storeCartDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryStoreCartsCount", method = RequestMethod.POST)
+    int queryStoreCartsCount(@RequestBody StoreCartDto storeCartDto);
+}

+ 115 - 0
service-goods/src/main/java/com/java110/goods/api/StoreCartApi.java

@@ -0,0 +1,115 @@
+package com.java110.goods.api;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.dto.storeCart.StoreCartDto;
+import com.java110.goods.bmo.storeCart.IDeleteStoreCartBMO;
+import com.java110.goods.bmo.storeCart.IGetStoreCartBMO;
+import com.java110.goods.bmo.storeCart.ISaveStoreCartBMO;
+import com.java110.goods.bmo.storeCart.IUpdateStoreCartBMO;
+import com.java110.po.storeCart.StoreCartPo;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@RestController
+@RequestMapping(value = "/storeCart")
+public class StoreCartApi {
+
+    @Autowired
+    private ISaveStoreCartBMO saveStoreCartBMOImpl;
+    @Autowired
+    private IUpdateStoreCartBMO updateStoreCartBMOImpl;
+    @Autowired
+    private IDeleteStoreCartBMO deleteStoreCartBMOImpl;
+
+    @Autowired
+    private IGetStoreCartBMO getStoreCartBMOImpl;
+
+    /**
+     * 微信保存消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /storeCart/saveStoreCart
+     * @path /app/storeCart/saveStoreCart
+     */
+    @RequestMapping(value = "/saveStoreCart", method = RequestMethod.POST)
+    public ResponseEntity<String> saveStoreCart(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+        Assert.hasKeyAndValue(reqJson, "valueId", "请求报文中未包含valueId");
+        Assert.hasKeyAndValue(reqJson, "personId", "请求报文中未包含personId");
+        Assert.hasKeyAndValue(reqJson, "cartNum", "请求报文中未包含cartNum");
+
+
+        StoreCartPo storeCartPo = BeanConvertUtil.covertBean(reqJson, StoreCartPo.class);
+        return saveStoreCartBMOImpl.save(storeCartPo);
+    }
+
+    /**
+     * 微信修改消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /storeCart/updateStoreCart
+     * @path /app/storeCart/updateStoreCart
+     */
+    @RequestMapping(value = "/updateStoreCart", method = RequestMethod.POST)
+    public ResponseEntity<String> updateStoreCart(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+        Assert.hasKeyAndValue(reqJson, "valueId", "请求报文中未包含valueId");
+        Assert.hasKeyAndValue(reqJson, "personId", "请求报文中未包含personId");
+        Assert.hasKeyAndValue(reqJson, "cartNum", "请求报文中未包含cartNum");
+        Assert.hasKeyAndValue(reqJson, "cartId", "cartId不能为空");
+
+
+        StoreCartPo storeCartPo = BeanConvertUtil.covertBean(reqJson, StoreCartPo.class);
+        return updateStoreCartBMOImpl.update(storeCartPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /storeCart/deleteStoreCart
+     * @path /app/storeCart/deleteStoreCart
+     */
+    @RequestMapping(value = "/deleteStoreCart", method = RequestMethod.POST)
+    public ResponseEntity<String> deleteStoreCart(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityId", "小区ID不能为空");
+
+        Assert.hasKeyAndValue(reqJson, "cartId", "cartId不能为空");
+
+
+        StoreCartPo storeCartPo = BeanConvertUtil.covertBean(reqJson, StoreCartPo.class);
+        return deleteStoreCartBMOImpl.delete(storeCartPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @param communityId 小区ID
+     * @return
+     * @serviceCode /storeCart/queryStoreCart
+     * @path /app/storeCart/queryStoreCart
+     */
+    @RequestMapping(value = "/queryStoreCart", method = RequestMethod.GET)
+    public ResponseEntity<String> queryStoreCart(@RequestParam(value = "communityId") String communityId,
+                                                 @RequestParam(value = "page") int page,
+                                                 @RequestParam(value = "row") int row) {
+        StoreCartDto storeCartDto = new StoreCartDto();
+        storeCartDto.setPage(page);
+        storeCartDto.setRow(row);
+        //storeCartDto.setCommunityId(communityId);
+        return getStoreCartBMOImpl.get(storeCartDto);
+    }
+}

+ 17 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/IDeleteStoreCartBMO.java

@@ -0,0 +1,17 @@
+package com.java110.goods.bmo.storeCart;
+import com.java110.po.storeCart.StoreCartPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IDeleteStoreCartBMO {
+
+
+    /**
+     * 修改购物车
+     * add by wuxw
+     * @param storeCartPo
+     * @return
+     */
+    ResponseEntity<String> delete(StoreCartPo storeCartPo);
+
+
+}

+ 19 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/IGetStoreCartBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.storeCart;
+
+import com.java110.dto.storeCart.StoreCartDto;
+import org.springframework.http.ResponseEntity;
+
+public interface IGetStoreCartBMO {
+
+
+    /**
+     * 查询购物车
+     * add by wuxw
+     *
+     * @param storeCartDto
+     * @return
+     */
+    ResponseEntity<String> get(StoreCartDto storeCartDto);
+
+
+}

+ 19 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/ISaveStoreCartBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.storeCart;
+
+import com.java110.po.storeCart.StoreCartPo;
+import org.springframework.http.ResponseEntity;
+
+public interface ISaveStoreCartBMO {
+
+
+    /**
+     * 添加购物车
+     * add by wuxw
+     *
+     * @param storeCartPo
+     * @return
+     */
+    ResponseEntity<String> save(StoreCartPo storeCartPo);
+
+
+}

+ 19 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/IUpdateStoreCartBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.storeCart;
+
+import com.java110.po.storeCart.StoreCartPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IUpdateStoreCartBMO {
+
+
+    /**
+     * 修改购物车
+     * add by wuxw
+     *
+     * @param storeCartPo
+     * @return
+     */
+    ResponseEntity<String> update(StoreCartPo storeCartPo);
+
+
+}

+ 34 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/DeleteStoreCartBMOImpl.java

@@ -0,0 +1,34 @@
+package com.java110.goods.bmo.storeCart.impl;
+
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.goods.bmo.storeCart.IDeleteStoreCartBMO;
+import com.java110.intf.goods.IStoreCartInnerServiceSMO;
+import com.java110.po.storeCart.StoreCartPo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service("deleteStoreCartBMOImpl")
+public class DeleteStoreCartBMOImpl implements IDeleteStoreCartBMO {
+
+    @Autowired
+    private IStoreCartInnerServiceSMO storeCartInnerServiceSMOImpl;
+
+    /**
+     * @param storeCartPo 数据
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> delete(StoreCartPo storeCartPo) {
+
+        int flag = storeCartInnerServiceSMOImpl.deleteStoreCart(storeCartPo);
+
+        if (flag > 0) {
+            return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

+ 44 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/GetStoreCartBMOImpl.java

@@ -0,0 +1,44 @@
+package com.java110.goods.bmo.storeCart.impl;
+
+import com.java110.dto.storeCart.StoreCartDto;
+import com.java110.goods.bmo.storeCart.IGetStoreCartBMO;
+import com.java110.intf.goods.IStoreCartInnerServiceSMO;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service("getStoreCartBMOImpl")
+public class GetStoreCartBMOImpl implements IGetStoreCartBMO {
+
+    @Autowired
+    private IStoreCartInnerServiceSMO storeCartInnerServiceSMOImpl;
+
+    /**
+     * @param storeCartDto
+     * @return 订单服务能够接受的报文
+     */
+    public ResponseEntity<String> get(StoreCartDto storeCartDto) {
+
+
+        int count = storeCartInnerServiceSMOImpl.queryStoreCartsCount(storeCartDto);
+
+        List<StoreCartDto> storeCartDtos = null;
+        if (count > 0) {
+            storeCartDtos = storeCartInnerServiceSMOImpl.queryStoreCarts(storeCartDto);
+        } else {
+            storeCartDtos = new ArrayList<>();
+        }
+
+        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) storeCartDto.getRow()), count, storeCartDtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        return responseEntity;
+    }
+
+}

+ 38 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/SaveStoreCartBMOImpl.java

@@ -0,0 +1,38 @@
+package com.java110.goods.bmo.storeCart.impl;
+
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.goods.bmo.storeCart.ISaveStoreCartBMO;
+import com.java110.intf.goods.IStoreCartInnerServiceSMO;
+import com.java110.po.storeCart.StoreCartPo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service("saveStoreCartBMOImpl")
+public class SaveStoreCartBMOImpl implements ISaveStoreCartBMO {
+
+    @Autowired
+    private IStoreCartInnerServiceSMO storeCartInnerServiceSMOImpl;
+
+    /**
+     * 添加小区信息
+     *
+     * @param storeCartPo
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> save(StoreCartPo storeCartPo) {
+
+        storeCartPo.setCartId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_cartId));
+        int flag = storeCartInnerServiceSMOImpl.saveStoreCart(storeCartPo);
+
+        if (flag > 0) {
+            return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

+ 34 - 0
service-goods/src/main/java/com/java110/goods/bmo/storeCart/impl/UpdateStoreCartBMOImpl.java

@@ -0,0 +1,34 @@
+package com.java110.goods.bmo.storeCart.impl;
+
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.goods.bmo.storeCart.IUpdateStoreCartBMO;
+import com.java110.intf.goods.IStoreCartInnerServiceSMO;
+import com.java110.po.storeCart.StoreCartPo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service("updateStoreCartBMOImpl")
+public class UpdateStoreCartBMOImpl implements IUpdateStoreCartBMO {
+
+    @Autowired
+    private IStoreCartInnerServiceSMO storeCartInnerServiceSMOImpl;
+
+    /**
+     * @param storeCartPo
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> update(StoreCartPo storeCartPo) {
+
+        int flag = storeCartInnerServiceSMOImpl.updateStoreCart(storeCartPo);
+
+        if (flag > 0) {
+            return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

+ 61 - 0
service-goods/src/main/java/com/java110/goods/dao/IStoreCartServiceDao.java

@@ -0,0 +1,61 @@
+package com.java110.goods.dao;
+
+
+import com.java110.utils.exception.DAOException;
+import com.java110.entity.merchant.BoMerchant;
+import com.java110.entity.merchant.BoMerchantAttr;
+import com.java110.entity.merchant.Merchant;
+import com.java110.entity.merchant.MerchantAttr;
+
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 购物车组件内部之间使用,没有给外围系统提供服务能力
+ * 购物车服务接口类,要求全部以字符串传输,方便微服务化
+ * 新建客户,修改客户,删除客户,查询客户等功能
+ *
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IStoreCartServiceDao {
+
+
+    /**
+     * 保存 购物车信息
+     * @param info
+     * @throws DAOException DAO异常
+     */
+    void saveStoreCartInfo(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 查询购物车信息(instance过程)
+     * 根据bId 查询购物车信息
+     * @param info bId 信息
+     * @return 购物车信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getStoreCartInfo(Map info) throws DAOException;
+
+
+
+    /**
+     * 修改购物车信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    void updateStoreCartInfo(Map info) throws DAOException;
+
+
+    /**
+     * 查询购物车总数
+     *
+     * @param info 购物车信息
+     * @return 购物车数量
+     */
+    int queryStoreCartsCount(Map info);
+
+}

+ 98 - 0
service-goods/src/main/java/com/java110/goods/dao/impl/StoreCartServiceDaoImpl.java

@@ -0,0 +1,98 @@
+package com.java110.goods.dao.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.DAOException;
+import com.java110.utils.util.DateUtil;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.goods.dao.IStoreCartServiceDao;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 购物车服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("storeCartServiceDaoImpl")
+//@Transactional
+public class StoreCartServiceDaoImpl extends BaseServiceDao implements IStoreCartServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(StoreCartServiceDaoImpl.class);
+
+
+
+
+
+    /**
+     * 保存购物车信息 到 instance
+     * @param info   bId 信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void saveStoreCartInfo(Map info) throws DAOException {
+        logger.debug("保存购物车信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.insert("storeCartServiceDaoImpl.saveStoreCartInfo",info);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存购物车信息Instance数据失败:"+ JSONObject.toJSONString(info));
+        }
+    }
+
+
+    /**
+     * 查询购物车信息(instance)
+     * @param info bId 信息
+     * @return List<Map>
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public List<Map> getStoreCartInfo(Map info) throws DAOException {
+        logger.debug("查询购物车信息 入参 info : {}",info);
+
+        List<Map> businessStoreCartInfos = sqlSessionTemplate.selectList("storeCartServiceDaoImpl.getStoreCartInfo",info);
+
+        return businessStoreCartInfos;
+    }
+
+
+    /**
+     * 修改购物车信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void updateStoreCartInfo(Map info) throws DAOException {
+        logger.debug("修改购物车信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.update("storeCartServiceDaoImpl.updateStoreCartInfo",info);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改购物车信息Instance数据失败:"+ JSONObject.toJSONString(info));
+        }
+    }
+
+     /**
+     * 查询购物车数量
+     * @param info 购物车信息
+     * @return 购物车数量
+     */
+    @Override
+    public int queryStoreCartsCount(Map info) {
+        logger.debug("查询购物车数据 入参 info : {}",info);
+
+        List<Map> businessStoreCartInfos = sqlSessionTemplate.selectList("storeCartServiceDaoImpl.queryStoreCartsCount", info);
+        if (businessStoreCartInfos.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(businessStoreCartInfos.get(0).get("count").toString());
+    }
+
+
+}

+ 83 - 0
service-goods/src/main/java/com/java110/goods/smo/impl/StoreCartInnerServiceSMOImpl.java

@@ -0,0 +1,83 @@
+package com.java110.goods.smo.impl;
+
+
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.dto.PageDto;
+import com.java110.dto.storeCart.StoreCartDto;
+import com.java110.goods.dao.IStoreCartServiceDao;
+import com.java110.intf.goods.IStoreCartInnerServiceSMO;
+import com.java110.po.storeCart.StoreCartPo;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @ClassName FloorInnerServiceSMOImpl
+ * @Description 购物车内部服务实现类
+ * @Author wuxw
+ * @Date 2019/4/24 9:20
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@RestController
+public class StoreCartInnerServiceSMOImpl extends BaseServiceSMO implements IStoreCartInnerServiceSMO {
+
+    @Autowired
+    private IStoreCartServiceDao storeCartServiceDaoImpl;
+
+
+    @Override
+    public int saveStoreCart(@RequestBody StoreCartPo storeCartPo) {
+        int saveFlag = 1;
+        storeCartServiceDaoImpl.saveStoreCartInfo(BeanConvertUtil.beanCovertMap(storeCartPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int updateStoreCart(@RequestBody StoreCartPo storeCartPo) {
+        int saveFlag = 1;
+        storeCartServiceDaoImpl.updateStoreCartInfo(BeanConvertUtil.beanCovertMap(storeCartPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int deleteStoreCart(@RequestBody StoreCartPo storeCartPo) {
+        int saveFlag = 1;
+        storeCartPo.setStatusCd("1");
+        storeCartServiceDaoImpl.updateStoreCartInfo(BeanConvertUtil.beanCovertMap(storeCartPo));
+        return saveFlag;
+    }
+
+    @Override
+    public List<StoreCartDto> queryStoreCarts(@RequestBody StoreCartDto storeCartDto) {
+
+        //校验是否传了 分页信息
+
+        int page = storeCartDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            storeCartDto.setPage((page - 1) * storeCartDto.getRow());
+        }
+
+        List<StoreCartDto> storeCarts = BeanConvertUtil.covertBeanList(storeCartServiceDaoImpl.getStoreCartInfo(BeanConvertUtil.beanCovertMap(storeCartDto)), StoreCartDto.class);
+
+        return storeCarts;
+    }
+
+
+    @Override
+    public int queryStoreCartsCount(@RequestBody StoreCartDto storeCartDto) {
+        return storeCartServiceDaoImpl.queryStoreCartsCount(BeanConvertUtil.beanCovertMap(storeCartDto));
+    }
+
+    public IStoreCartServiceDao getStoreCartServiceDaoImpl() {
+        return storeCartServiceDaoImpl;
+    }
+
+    public void setStoreCartServiceDaoImpl(IStoreCartServiceDao storeCartServiceDaoImpl) {
+        this.storeCartServiceDaoImpl = storeCartServiceDaoImpl;
+    }
+}