加入团购商品规格功能

java110-bean/src/main/java/com/java110/dto/groupBuyProductSpec/GroupBuyProductSpecDto.java

@@ -0,0 +1,90 @@
+package com.java110.dto.groupBuyProductSpec;
+
+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 GroupBuyProductSpecDto extends PageDto implements Serializable {
+
+    private String specId;
+private String groupSales;
+private String productId;
+private String groupPrice;
+private String defaultShow;
+private String storeId;
+private String groupStock;
+
+
+    private Date createTime;
+
+    private String statusCd = "0";
+
+
+    public String getSpecId() {
+        return specId;
+    }
+public void setSpecId(String specId) {
+        this.specId = specId;
+    }
+public String getGroupSales() {
+        return groupSales;
+    }
+public void setGroupSales(String groupSales) {
+        this.groupSales = groupSales;
+    }
+public String getProductId() {
+        return productId;
+    }
+public void setProductId(String productId) {
+        this.productId = productId;
+    }
+public String getGroupPrice() {
+        return groupPrice;
+    }
+public void setGroupPrice(String groupPrice) {
+        this.groupPrice = groupPrice;
+    }
+public String getDefaultShow() {
+        return defaultShow;
+    }
+public void setDefaultShow(String defaultShow) {
+        this.defaultShow = defaultShow;
+    }
+public String getStoreId() {
+        return storeId;
+    }
+public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+public String getGroupStock() {
+        return groupStock;
+    }
+public void setGroupStock(String groupStock) {
+        this.groupStock = groupStock;
+    }
+
+
+    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;
+    }
+}

java110-bean/src/main/java/com/java110/po/groupBuyProductSpec/GroupBuyProductSpecPo.java

@@ -0,0 +1,67 @@
+package com.java110.po.groupBuyProductSpec;
+
+import java.io.Serializable;
+import java.util.Date;
+
+public class GroupBuyProductSpecPo implements Serializable {
+
+    private String specId;
+private String groupSales;
+private String productId;
+private String groupPrice;
+private String defaultShow;
+private String statusCd = "0";
+private String storeId;
+private String groupStock;
+public String getSpecId() {
+        return specId;
+    }
+public void setSpecId(String specId) {
+        this.specId = specId;
+    }
+public String getGroupSales() {
+        return groupSales;
+    }
+public void setGroupSales(String groupSales) {
+        this.groupSales = groupSales;
+    }
+public String getProductId() {
+        return productId;
+    }
+public void setProductId(String productId) {
+        this.productId = productId;
+    }
+public String getGroupPrice() {
+        return groupPrice;
+    }
+public void setGroupPrice(String groupPrice) {
+        this.groupPrice = groupPrice;
+    }
+public String getDefaultShow() {
+        return defaultShow;
+    }
+public void setDefaultShow(String defaultShow) {
+        this.defaultShow = defaultShow;
+    }
+public String getStatusCd() {
+        return statusCd;
+    }
+public void setStatusCd(String statusCd) {
+        this.statusCd = statusCd;
+    }
+public String getStoreId() {
+        return storeId;
+    }
+public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+public String getGroupStock() {
+        return groupStock;
+    }
+public void setGroupStock(String groupStock) {
+        this.groupStock = groupStock;
+    }
+
+
+
+}

java110-db/src/main/resources/mapper/goods/GroupBuyProductSpecServiceDaoImplMapper.xml

@@ -0,0 +1,122 @@
+<?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="groupBuyProductSpecServiceDaoImpl">
+
+
+    <!-- 保存拼团产品规格信息 add by wuxw 2018-07-03 -->
+    <insert id="saveGroupBuyProductSpecInfo" parameterType="Map">
+        insert into group_buy_product_spec(
+        spec_id,group_sales,product_id,group_price,default_show,store_id,group_stock
+        ) values (
+        #{specId},#{groupSales},#{productId},#{groupPrice},#{defaultShow},#{storeId},#{groupStock}
+        )
+    </insert>
+
+
+    <!-- 查询拼团产品规格信息 add by wuxw 2018-07-03 -->
+    <select id="getGroupBuyProductSpecInfo" parameterType="Map" resultType="Map">
+        select t.spec_id,t.spec_id specId,t.group_sales,t.group_sales groupSales,t.product_id,t.product_id
+        productId,t.group_price,t.group_price groupPrice,t.default_show,t.default_show
+        defaultShow,t.status_cd,t.status_cd statusCd,t.store_id,t.store_id storeId,t.group_stock,t.group_stock
+        groupStock
+        from group_buy_product_spec t
+        where 1 =1
+        <if test="specId !=null and specId != ''">
+            and t.spec_id= #{specId}
+        </if>
+        <if test="groupSales !=null and groupSales != ''">
+            and t.group_sales= #{groupSales}
+        </if>
+        <if test="productId !=null and productId != ''">
+            and t.product_id= #{productId}
+        </if>
+        <if test="groupPrice !=null and groupPrice != ''">
+            and t.group_price= #{groupPrice}
+        </if>
+        <if test="defaultShow !=null and defaultShow != ''">
+            and t.default_show= #{defaultShow}
+        </if>
+        <if test="statusCd !=null and statusCd != ''">
+            and t.status_cd= #{statusCd}
+        </if>
+        <if test="storeId !=null and storeId != ''">
+            and t.store_id= #{storeId}
+        </if>
+        <if test="groupStock !=null and groupStock != ''">
+            and t.group_stock= #{groupStock}
+        </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="updateGroupBuyProductSpecInfo" parameterType="Map">
+        update group_buy_product_spec t set t.status_cd = #{statusCd}
+        <if test="newBId != null and newBId != ''">
+            ,t.b_id = #{newBId}
+        </if>
+        <if test="groupSales !=null and groupSales != ''">
+            , t.group_sales= #{groupSales}
+        </if>
+        <if test="productId !=null and productId != ''">
+            , t.product_id= #{productId}
+        </if>
+        <if test="groupPrice !=null and groupPrice != ''">
+            , t.group_price= #{groupPrice}
+        </if>
+        <if test="defaultShow !=null and defaultShow != ''">
+            , t.default_show= #{defaultShow}
+        </if>
+        <if test="storeId !=null and storeId != ''">
+            , t.store_id= #{storeId}
+        </if>
+        <if test="groupStock !=null and groupStock != ''">
+            , t.group_stock= #{groupStock}
+        </if>
+        where 1=1
+        <if test="specId !=null and specId != ''">
+            and t.spec_id= #{specId}
+        </if>
+
+    </update>
+
+    <!-- 查询拼团产品规格数量 add by wuxw 2018-07-03 -->
+    <select id="queryGroupBuyProductSpecsCount" parameterType="Map" resultType="Map">
+        select count(1) count
+        from group_buy_product_spec t
+        where 1 =1
+        <if test="specId !=null and specId != ''">
+            and t.spec_id= #{specId}
+        </if>
+        <if test="groupSales !=null and groupSales != ''">
+            and t.group_sales= #{groupSales}
+        </if>
+        <if test="productId !=null and productId != ''">
+            and t.product_id= #{productId}
+        </if>
+        <if test="groupPrice !=null and groupPrice != ''">
+            and t.group_price= #{groupPrice}
+        </if>
+        <if test="defaultShow !=null and defaultShow != ''">
+            and t.default_show= #{defaultShow}
+        </if>
+        <if test="statusCd !=null and statusCd != ''">
+            and t.status_cd= #{statusCd}
+        </if>
+        <if test="storeId !=null and storeId != ''">
+            and t.store_id= #{storeId}
+        </if>
+        <if test="groupStock !=null and groupStock != ''">
+            and t.group_stock= #{groupStock}
+        </if>
+
+
+    </select>
+
+</mapper>

java110-interface/src/main/java/com/java110/intf/goods/IGroupBuyProductSpecInnerServiceSMO.java

@@ -0,0 +1,53 @@
+package com.java110.intf;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.groupBuyProductSpec.GroupBuyProductSpecDto;
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+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 IGroupBuyProductSpecInnerServiceSMO
+ * @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("/groupBuyProductSpecApi")
+public interface IGroupBuyProductSpecInnerServiceSMO {
+
+
+    @RequestMapping(value = "/saveGroupBuyProductSpec", method = RequestMethod.POST)
+    public int saveGroupBuyProductSpec(@RequestBody GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+    @RequestMapping(value = "/updateGroupBuyProductSpec", method = RequestMethod.POST)
+    public int updateGroupBuyProductSpec(@RequestBody  GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+    @RequestMapping(value = "/deleteGroupBuyProductSpec", method = RequestMethod.POST)
+    public int deleteGroupBuyProductSpec(@RequestBody  GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     *
+     * @param groupBuyProductSpecDto 数据对象分享
+     * @return GroupBuyProductSpecDto 对象数据
+     */
+    @RequestMapping(value = "/queryGroupBuyProductSpecs", method = RequestMethod.POST)
+    List<GroupBuyProductSpecDto> queryGroupBuyProductSpecs(@RequestBody GroupBuyProductSpecDto groupBuyProductSpecDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param groupBuyProductSpecDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryGroupBuyProductSpecsCount", method = RequestMethod.POST)
+    int queryGroupBuyProductSpecsCount(@RequestBody GroupBuyProductSpecDto groupBuyProductSpecDto);
+}

service-goods/src/main/java/com/java110/goods/api/GroupBuyProductApi.java

@@ -2,16 +2,22 @@ package com.java110.store.api;
 
 import com.alibaba.fastjson.JSONObject;
 import com.java110.dto.groupBuyProduct.GroupBuyProductDto;
+import com.java110.dto.groupBuyProductSpec.GroupBuyProductSpecDto;
 import com.java110.dto.groupBuySetting.GroupBuySettingDto;
 import com.java110.goods.bmo.groupBuyProduct.IDeleteGroupBuyProductBMO;
 import com.java110.goods.bmo.groupBuyProduct.IGetGroupBuyProductBMO;
 import com.java110.goods.bmo.groupBuyProduct.ISaveGroupBuyProductBMO;
 import com.java110.goods.bmo.groupBuyProduct.IUpdateGroupBuyProductBMO;
+import com.java110.goods.bmo.groupBuyProductSpec.IDeleteGroupBuyProductSpecBMO;
+import com.java110.goods.bmo.groupBuyProductSpec.IGetGroupBuyProductSpecBMO;
+import com.java110.goods.bmo.groupBuyProductSpec.ISaveGroupBuyProductSpecBMO;
+import com.java110.goods.bmo.groupBuyProductSpec.IUpdateGroupBuyProductSpecBMO;
 import com.java110.goods.bmo.groupBuySetting.IDeleteGroupBuySettingBMO;
 import com.java110.goods.bmo.groupBuySetting.IGetGroupBuySettingBMO;
 import com.java110.goods.bmo.groupBuySetting.ISaveGroupBuySettingBMO;
 import com.java110.goods.bmo.groupBuySetting.IUpdateGroupBuySettingBMO;
 import com.java110.po.groupBuyProduct.GroupBuyProductPo;
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
 import com.java110.po.groupBuySetting.GroupBuySettingPo;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.BeanConvertUtil;
@@ -44,6 +50,18 @@ public class GroupBuyProductApi {
     @Autowired
     private IGetGroupBuySettingBMO getGroupBuySettingBMOImpl;
 
+
+    @Autowired
+    private ISaveGroupBuyProductSpecBMO saveGroupBuyProductSpecBMOImpl;
+    @Autowired
+    private IUpdateGroupBuyProductSpecBMO updateGroupBuyProductSpecBMOImpl;
+    @Autowired
+    private IDeleteGroupBuyProductSpecBMO deleteGroupBuyProductSpecBMOImpl;
+
+    @Autowired
+    private IGetGroupBuyProductSpecBMO getGroupBuyProductSpecBMOImpl;
+
+
     /**
      * 微信保存消息模板
      *
@@ -209,4 +227,85 @@ public class GroupBuyProductApi {
         groupBuySettingDto.setStoreId(storeId);
         return getGroupBuySettingBMOImpl.get(groupBuySettingDto);
     }
+
+    /**
+     * 微信保存消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /groupBuyProductSpec/saveGroupBuyProductSpec
+     * @path /app/groupBuyProductSpec/saveGroupBuyProductSpec
+     */
+    @RequestMapping(value = "/saveGroupBuyProductSpec", method = RequestMethod.POST)
+    public ResponseEntity<String> saveGroupBuyProductSpec(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "groupStock", "请求报文中未包含groupStock");
+        Assert.hasKeyAndValue(reqJson, "groupSales", "请求报文中未包含groupSales");
+        Assert.hasKeyAndValue(reqJson, "defaultShow", "请求报文中未包含defaultShow");
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+
+
+        GroupBuyProductSpecPo groupBuyProductSpecPo = BeanConvertUtil.covertBean(reqJson, GroupBuyProductSpecPo.class);
+        return saveGroupBuyProductSpecBMOImpl.save(groupBuyProductSpecPo);
+    }
+
+    /**
+     * 微信修改消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /groupBuyProductSpec/updateGroupBuyProductSpec
+     * @path /app/groupBuyProductSpec/updateGroupBuyProductSpec
+     */
+    @RequestMapping(value = "/updateGroupBuyProductSpec", method = RequestMethod.POST)
+    public ResponseEntity<String> updateGroupBuyProductSpec(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "groupStock", "请求报文中未包含groupStock");
+        Assert.hasKeyAndValue(reqJson, "groupSales", "请求报文中未包含groupSales");
+        Assert.hasKeyAndValue(reqJson, "defaultShow", "请求报文中未包含defaultShow");
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+        Assert.hasKeyAndValue(reqJson, "specId", "specId不能为空");
+
+
+        GroupBuyProductSpecPo groupBuyProductSpecPo = BeanConvertUtil.covertBean(reqJson, GroupBuyProductSpecPo.class);
+        return updateGroupBuyProductSpecBMOImpl.update(groupBuyProductSpecPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /groupBuyProductSpec/deleteGroupBuyProductSpec
+     * @path /app/groupBuyProductSpec/deleteGroupBuyProductSpec
+     */
+    @RequestMapping(value = "/deleteGroupBuyProductSpec", method = RequestMethod.POST)
+    public ResponseEntity<String> deleteGroupBuyProductSpec(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityId", "小区ID不能为空");
+
+        Assert.hasKeyAndValue(reqJson, "specId", "specId不能为空");
+
+
+        GroupBuyProductSpecPo groupBuyProductSpecPo = BeanConvertUtil.covertBean(reqJson, GroupBuyProductSpecPo.class);
+        return deleteGroupBuyProductSpecBMOImpl.delete(groupBuyProductSpecPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @param storeId 小区ID
+     * @return
+     * @serviceCode /groupBuyProductSpec/queryGroupBuyProductSpec
+     * @path /app/groupBuyProductSpec/queryGroupBuyProductSpec
+     */
+    @RequestMapping(value = "/queryGroupBuyProductSpec", method = RequestMethod.GET)
+    public ResponseEntity<String> queryGroupBuyProductSpec(@RequestHeader(value = "store-id") String storeId,
+                                                           @RequestParam(value = "page") int page,
+                                                           @RequestParam(value = "row") int row) {
+        GroupBuyProductSpecDto groupBuyProductSpecDto = new GroupBuyProductSpecDto();
+        groupBuyProductSpecDto.setPage(page);
+        groupBuyProductSpecDto.setRow(row);
+        groupBuyProductSpecDto.setStoreId(storeId);
+        return getGroupBuyProductSpecBMOImpl.get(groupBuyProductSpecDto);
+    }
 }

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/IDeleteGroupBuyProductSpecBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.groupBuyProductSpec;
+
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IDeleteGroupBuyProductSpecBMO {
+
+
+    /**
+     * 修改拼团产品规格
+     * add by wuxw
+     *
+     * @param groupBuyProductSpecPo
+     * @return
+     */
+    ResponseEntity<String> delete(GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/IGetGroupBuyProductSpecBMO.java

@@ -0,0 +1,16 @@
+package com.java110.goods.bmo.groupBuyProductSpec;
+import com.java110.dto.groupBuyProductSpec.GroupBuyProductSpecDto;
+import org.springframework.http.ResponseEntity;
+public interface IGetGroupBuyProductSpecBMO {
+
+
+    /**
+     * 查询拼团产品规格
+     * add by wuxw
+     * @param  groupBuyProductSpecDto
+     * @return
+     */
+    ResponseEntity<String> get(GroupBuyProductSpecDto groupBuyProductSpecDto);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/ISaveGroupBuyProductSpecBMO.java

@@ -0,0 +1,17 @@
+package com.java110.goods.bmo.groupBuyProductSpec;
+
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+import org.springframework.http.ResponseEntity;
+public interface ISaveGroupBuyProductSpecBMO {
+
+
+    /**
+     * 添加拼团产品规格
+     * add by wuxw
+     * @param groupBuyProductSpecPo
+     * @return
+     */
+    ResponseEntity<String> save(GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/IUpdateGroupBuyProductSpecBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.groupBuyProductSpec;
+
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IUpdateGroupBuyProductSpecBMO {
+
+
+    /**
+     * 修改拼团产品规格
+     * add by wuxw
+     *
+     * @param groupBuyProductSpecPo
+     * @return
+     */
+    ResponseEntity<String> update(GroupBuyProductSpecPo groupBuyProductSpecPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/impl/DeleteGroupBuyProductSpecBMOImpl.java

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

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/impl/GetGroupBuyProductSpecBMOImpl.java

@@ -0,0 +1,44 @@
+package com.java110.goods.bmo.groupBuyProductSpec.impl;
+
+import com.java110.dto.groupBuyProductSpec.GroupBuyProductSpecDto;
+import com.java110.goods.bmo.groupBuyProductSpec.IGetGroupBuyProductSpecBMO;
+import com.java110.intf.IGroupBuyProductSpecInnerServiceSMO;
+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("getGroupBuyProductSpecBMOImpl")
+public class GetGroupBuyProductSpecBMOImpl implements IGetGroupBuyProductSpecBMO {
+
+    @Autowired
+    private IGroupBuyProductSpecInnerServiceSMO groupBuyProductSpecInnerServiceSMOImpl;
+
+    /**
+     * @param groupBuyProductSpecDto
+     * @return 订单服务能够接受的报文
+     */
+    public ResponseEntity<String> get(GroupBuyProductSpecDto groupBuyProductSpecDto) {
+
+
+        int count = groupBuyProductSpecInnerServiceSMOImpl.queryGroupBuyProductSpecsCount(groupBuyProductSpecDto);
+
+        List<GroupBuyProductSpecDto> groupBuyProductSpecDtos = null;
+        if (count > 0) {
+            groupBuyProductSpecDtos = groupBuyProductSpecInnerServiceSMOImpl.queryGroupBuyProductSpecs(groupBuyProductSpecDto);
+        } else {
+            groupBuyProductSpecDtos = new ArrayList<>();
+        }
+
+        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) groupBuyProductSpecDto.getRow()), count, groupBuyProductSpecDtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        return responseEntity;
+    }
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/impl/SaveGroupBuyProductSpecBMOImpl.java

@@ -0,0 +1,38 @@
+package com.java110.goods.bmo.groupBuyProductSpec.impl;
+
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.goods.bmo.groupBuyProductSpec.ISaveGroupBuyProductSpecBMO;
+import com.java110.intf.IGroupBuyProductSpecInnerServiceSMO;
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service("saveGroupBuyProductSpecBMOImpl")
+public class SaveGroupBuyProductSpecBMOImpl implements ISaveGroupBuyProductSpecBMO {
+
+    @Autowired
+    private IGroupBuyProductSpecInnerServiceSMO groupBuyProductSpecInnerServiceSMOImpl;
+
+    /**
+     * 添加小区信息
+     *
+     * @param groupBuyProductSpecPo
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> save(GroupBuyProductSpecPo groupBuyProductSpecPo) {
+
+        groupBuyProductSpecPo.setSpecId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_specId));
+        int flag = groupBuyProductSpecInnerServiceSMOImpl.saveGroupBuyProductSpec(groupBuyProductSpecPo);
+
+        if (flag > 0) {
+            return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

service-goods/src/main/java/com/java110/goods/bmo/groupBuyProductSpec/impl/UpdateGroupBuyProductSpecBMOImpl.java

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

service-goods/src/main/java/com/java110/goods/dao/IGroupBuyProductSpecServiceDao.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 IGroupBuyProductSpecServiceDao {
+
+
+    /**
+     * 保存 拼团产品规格信息
+     * @param info
+     * @throws DAOException DAO异常
+     */
+    void saveGroupBuyProductSpecInfo(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 查询拼团产品规格信息（instance过程）
+     * 根据bId 查询拼团产品规格信息
+     * @param info bId 信息
+     * @return 拼团产品规格信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getGroupBuyProductSpecInfo(Map info) throws DAOException;
+
+
+
+    /**
+     * 修改拼团产品规格信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    void updateGroupBuyProductSpecInfo(Map info) throws DAOException;
+
+
+    /**
+     * 查询拼团产品规格总数
+     *
+     * @param info 拼团产品规格信息
+     * @return 拼团产品规格数量
+     */
+    int queryGroupBuyProductSpecsCount(Map info);
+
+}

service-goods/src/main/java/com/java110/goods/dao/impl/GroupBuyProductSpecServiceDaoImpl.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.IGroupBuyProductSpecServiceDao;
+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("groupBuyProductSpecServiceDaoImpl")
+//@Transactional
+public class GroupBuyProductSpecServiceDaoImpl extends BaseServiceDao implements IGroupBuyProductSpecServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(GroupBuyProductSpecServiceDaoImpl.class);
+
+
+
+
+
+    /**
+     * 保存拼团产品规格信息 到 instance
+     * @param info   bId 信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void saveGroupBuyProductSpecInfo(Map info) throws DAOException {
+        logger.debug("保存拼团产品规格信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.insert("groupBuyProductSpecServiceDaoImpl.saveGroupBuyProductSpecInfo",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> getGroupBuyProductSpecInfo(Map info) throws DAOException {
+        logger.debug("查询拼团产品规格信息 入参 info : {}",info);
+
+        List<Map> businessGroupBuyProductSpecInfos = sqlSessionTemplate.selectList("groupBuyProductSpecServiceDaoImpl.getGroupBuyProductSpecInfo",info);
+
+        return businessGroupBuyProductSpecInfos;
+    }
+
+
+    /**
+     * 修改拼团产品规格信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void updateGroupBuyProductSpecInfo(Map info) throws DAOException {
+        logger.debug("修改拼团产品规格信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.update("groupBuyProductSpecServiceDaoImpl.updateGroupBuyProductSpecInfo",info);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改拼团产品规格信息Instance数据失败："+ JSONObject.toJSONString(info));
+        }
+    }
+
+     /**
+     * 查询拼团产品规格数量
+     * @param info 拼团产品规格信息
+     * @return 拼团产品规格数量
+     */
+    @Override
+    public int queryGroupBuyProductSpecsCount(Map info) {
+        logger.debug("查询拼团产品规格数据 入参 info : {}",info);
+
+        List<Map> businessGroupBuyProductSpecInfos = sqlSessionTemplate.selectList("groupBuyProductSpecServiceDaoImpl.queryGroupBuyProductSpecsCount", info);
+        if (businessGroupBuyProductSpecInfos.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(businessGroupBuyProductSpecInfos.get(0).get("count").toString());
+    }
+
+
+}

service-goods/src/main/java/com/java110/goods/smo/impl/GroupBuyProductSpecInnerServiceSMOImpl.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.groupBuyProductSpec.GroupBuyProductSpecDto;
+import com.java110.goods.dao.IGroupBuyProductSpecServiceDao;
+import com.java110.intf.IGroupBuyProductSpecInnerServiceSMO;
+import com.java110.po.groupBuyProductSpec.GroupBuyProductSpecPo;
+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 GroupBuyProductSpecInnerServiceSMOImpl extends BaseServiceSMO implements IGroupBuyProductSpecInnerServiceSMO {
+
+    @Autowired
+    private IGroupBuyProductSpecServiceDao groupBuyProductSpecServiceDaoImpl;
+
+
+    @Override
+    public int saveGroupBuyProductSpec(@RequestBody GroupBuyProductSpecPo groupBuyProductSpecPo) {
+        int saveFlag = 1;
+        groupBuyProductSpecServiceDaoImpl.saveGroupBuyProductSpecInfo(BeanConvertUtil.beanCovertMap(groupBuyProductSpecPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int updateGroupBuyProductSpec(@RequestBody GroupBuyProductSpecPo groupBuyProductSpecPo) {
+        int saveFlag = 1;
+        groupBuyProductSpecServiceDaoImpl.updateGroupBuyProductSpecInfo(BeanConvertUtil.beanCovertMap(groupBuyProductSpecPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int deleteGroupBuyProductSpec(@RequestBody GroupBuyProductSpecPo groupBuyProductSpecPo) {
+        int saveFlag = 1;
+        groupBuyProductSpecPo.setStatusCd("1");
+        groupBuyProductSpecServiceDaoImpl.updateGroupBuyProductSpecInfo(BeanConvertUtil.beanCovertMap(groupBuyProductSpecPo));
+        return saveFlag;
+    }
+
+    @Override
+    public List<GroupBuyProductSpecDto> queryGroupBuyProductSpecs(@RequestBody GroupBuyProductSpecDto groupBuyProductSpecDto) {
+
+        //校验是否传了 分页信息
+
+        int page = groupBuyProductSpecDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            groupBuyProductSpecDto.setPage((page - 1) * groupBuyProductSpecDto.getRow());
+        }
+
+        List<GroupBuyProductSpecDto> groupBuyProductSpecs = BeanConvertUtil.covertBeanList(groupBuyProductSpecServiceDaoImpl.getGroupBuyProductSpecInfo(BeanConvertUtil.beanCovertMap(groupBuyProductSpecDto)), GroupBuyProductSpecDto.class);
+
+        return groupBuyProductSpecs;
+    }
+
+
+    @Override
+    public int queryGroupBuyProductSpecsCount(@RequestBody GroupBuyProductSpecDto groupBuyProductSpecDto) {
+        return groupBuyProductSpecServiceDaoImpl.queryGroupBuyProductSpecsCount(BeanConvertUtil.beanCovertMap(groupBuyProductSpecDto));
+    }
+
+    public IGroupBuyProductSpecServiceDao getGroupBuyProductSpecServiceDaoImpl() {
+        return groupBuyProductSpecServiceDaoImpl;
+    }
+
+    public void setGroupBuyProductSpecServiceDaoImpl(IGroupBuyProductSpecServiceDao groupBuyProductSpecServiceDaoImpl) {
+        this.groupBuyProductSpecServiceDaoImpl = groupBuyProductSpecServiceDaoImpl;
+    }
+}