加入推荐商品定义

java110-bean/src/main/java/com/java110/dto/productLabel/ProductLabelDto.java

@@ -0,0 +1,69 @@
+package com.java110.dto.productLabel;
+
+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 ProductLabelDto extends PageDto implements Serializable {
+
+    private String labelId;
+private String productId;
+private String storeId;
+private String labelCd;
+
+
+    private Date createTime;
+
+    private String statusCd = "0";
+
+
+    public String getLabelId() {
+        return labelId;
+    }
+public void setLabelId(String labelId) {
+        this.labelId = labelId;
+    }
+public String getProductId() {
+        return productId;
+    }
+public void setProductId(String productId) {
+        this.productId = productId;
+    }
+public String getStoreId() {
+        return storeId;
+    }
+public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+public String getLabelCd() {
+        return labelCd;
+    }
+public void setLabelCd(String labelCd) {
+        this.labelCd = labelCd;
+    }
+
+
+    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/productLabel/ProductLabelPo.java

@@ -0,0 +1,54 @@
+package com.java110.po.productLabel;
+
+import java.io.Serializable;
+
+public class ProductLabelPo implements Serializable {
+
+    private String labelId;
+    private String productId;
+    private String statusCd = "0";
+    private String storeId;
+    private String labelCd;
+
+    public String getLabelId() {
+        return labelId;
+    }
+
+    public void setLabelId(String labelId) {
+        this.labelId = labelId;
+    }
+
+    public String getProductId() {
+        return productId;
+    }
+
+    public void setProductId(String productId) {
+        this.productId = productId;
+    }
+
+    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 getLabelCd() {
+        return labelCd;
+    }
+
+    public void setLabelCd(String labelCd) {
+        this.labelCd = labelCd;
+    }
+
+
+}

java110-core/src/main/java/com/java110/core/factory/GenerateCodeFactory.java

@@ -162,6 +162,7 @@ public class GenerateCodeFactory {
     public static final String CODE_PREFIX_groupId = "92";
     public static final String CODE_PREFIX_batchId = "93";
     public static final String CODE_PREFIX_statisticsId = "94";
+    public static final String CODE_PREFIX_labelId = "94";
 
 
 

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

@@ -0,0 +1,97 @@
+<?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="productLabelServiceDaoImpl">
+
+
+
+
+
+    <!-- 保存产品标签信息 add by wuxw 2018-07-03 -->
+    <insert id="saveProductLabelInfo" parameterType="Map">
+        insert into product_label(
+label_id,product_id,store_id,label_cd
+) values (
+#{labelId},#{productId},#{storeId},#{labelCd}
+)
+    </insert>
+
+
+
+    <!-- 查询产品标签信息 add by wuxw 2018-07-03 -->
+    <select id="getProductLabelInfo" parameterType="Map" resultType="Map">
+        select  t.label_id,t.label_id labelId,t.product_id,t.product_id productId,t.status_cd,t.status_cd statusCd,t.store_id,t.store_id storeId,t.label_cd,t.label_cd labelCd 
+from product_label t 
+where 1 =1 
+<if test="labelId !=null and labelId != ''">
+   and t.label_id= #{labelId}
+</if> 
+<if test="productId !=null and productId != ''">
+   and t.product_id= #{productId}
+</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="labelCd !=null and labelCd != ''">
+   and t.label_cd= #{labelCd}
+</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="updateProductLabelInfo" parameterType="Map">
+        update  product_label t set t.status_cd = #{statusCd}
+<if test="newBId != null and newBId != ''">
+,t.b_id = #{newBId}
+</if> 
+<if test="productId !=null and productId != ''">
+, t.product_id= #{productId}
+</if> 
+<if test="storeId !=null and storeId != ''">
+, t.store_id= #{storeId}
+</if> 
+<if test="labelCd !=null and labelCd != ''">
+, t.label_cd= #{labelCd}
+</if> 
+ where 1=1 <if test="labelId !=null and labelId != ''">
+and t.label_id= #{labelId}
+</if> 
+
+    </update>
+
+    <!-- 查询产品标签数量 add by wuxw 2018-07-03 -->
+     <select id="queryProductLabelsCount" parameterType="Map" resultType="Map">
+        select  count(1) count 
+from product_label t 
+where 1 =1 
+<if test="labelId !=null and labelId != ''">
+   and t.label_id= #{labelId}
+</if> 
+<if test="productId !=null and productId != ''">
+   and t.product_id= #{productId}
+</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="labelCd !=null and labelCd != ''">
+   and t.label_cd= #{labelCd}
+</if> 
+
+
+     </select>
+
+</mapper>

java110-generator/src/main/resources/newBack/template_1.json

@@ -1,35 +1,27 @@
 {
   "autoMove": true,
-  "id": "statisticsId",
-  "name": "reportFeeMonthStatistics",
-  "desc": "费用月统计",
-  "shareParam": "communityId",
-  "shareColumn": "community_id",
-  "shareName": "report",
-  "tableName": "report_fee_month_statistics",
+  "id": "labelId",
+  "name": "productLabel",
+  "desc": "产品标签",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
+  "shareName": "goods",
+  "tableName": "product_label",
   "param": {
-    "statisticsId": "statistics_id",
-    "feeYear": "fee_year",
-    "feeMonth": "fee_month",
-    "communityId": "community_id",
-    "objType": "obj_type",
-    "objId": "obj_id",
-    "objName": "obj_name",
-    "feeId": "fee_id",
-    "feeName": "fee_name",
-    "configId": "config_id",
-    "receivableAmount": "receivable_amount",
-    "receivedAmount": "received_amount",
-    "oweAmount": "owe_amount",
-    "feeCreateTime": "fee_create_time",
-    "updateTime": "update_time",
-    "remark": "remark",
+    "labelId": "label_id",
+    "productId": "product_id",
+    "storeId": "store_id",
+    "labelCd": "label_cd",
     "statusCd": "status_cd"
   },
   "required": [
     {
-      "code": "feeYear",
-      "msg": "年不能为空"
+      "code": "labelCd",
+      "msg": "标签不能为空"
+    },
+    {
+      "code": "productId",
+      "msg": "产品不能为空"
     }
   ]
 }

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

@@ -0,0 +1,52 @@
+package com.java110.intf.goods;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.productLabel.ProductLabelDto;
+import com.java110.po.productLabel.ProductLabelPo;
+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 IProductLabelInnerServiceSMO
+ * @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("/productLabelApi")
+public interface IProductLabelInnerServiceSMO {
+
+
+    @RequestMapping(value = "/saveProductLabel", method = RequestMethod.POST)
+    public int saveProductLabel(@RequestBody ProductLabelPo productLabelPo);
+
+    @RequestMapping(value = "/updateProductLabel", method = RequestMethod.POST)
+    public int updateProductLabel(@RequestBody ProductLabelPo productLabelPo);
+
+    @RequestMapping(value = "/deleteProductLabel", method = RequestMethod.POST)
+    public int deleteProductLabel(@RequestBody ProductLabelPo productLabelPo);
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     * @param productLabelDto 数据对象分享
+     * @return ProductLabelDto 对象数据
+     */
+    @RequestMapping(value = "/queryProductLabels", method = RequestMethod.POST)
+    List<ProductLabelDto> queryProductLabels(@RequestBody ProductLabelDto productLabelDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param productLabelDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryProductLabelsCount", method = RequestMethod.POST)
+    int queryProductLabelsCount(@RequestBody ProductLabelDto productLabelDto);
+}

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

@@ -7,6 +7,7 @@ import com.java110.dto.product.ProductSpecDetailDto;
 import com.java110.dto.product.ProductSpecDto;
 import com.java110.dto.productAttr.ProductAttrDto;
 import com.java110.dto.productDetail.ProductDetailDto;
+import com.java110.dto.productLabel.ProductLabelDto;
 import com.java110.dto.productSpecValue.ProductSpecValueDto;
 import com.java110.goods.bmo.product.IDeleteProductBMO;
 import com.java110.goods.bmo.product.IGetProductBMO;
@@ -20,6 +21,10 @@ import com.java110.goods.bmo.productDetail.IDeleteProductDetailBMO;
 import com.java110.goods.bmo.productDetail.IGetProductDetailBMO;
 import com.java110.goods.bmo.productDetail.ISaveProductDetailBMO;
 import com.java110.goods.bmo.productDetail.IUpdateProductDetailBMO;
+import com.java110.goods.bmo.productLabel.IDeleteProductLabelBMO;
+import com.java110.goods.bmo.productLabel.IGetProductLabelBMO;
+import com.java110.goods.bmo.productLabel.ISaveProductLabelBMO;
+import com.java110.goods.bmo.productLabel.IUpdateProductLabelBMO;
 import com.java110.goods.bmo.productSpec.IDeleteProductSpecBMO;
 import com.java110.goods.bmo.productSpec.IGetProductSpecBMO;
 import com.java110.goods.bmo.productSpec.ISaveProductSpecBMO;
@@ -37,17 +42,13 @@ import com.java110.po.product.ProductSpecDetailPo;
 import com.java110.po.product.ProductSpecPo;
 import com.java110.po.productAttr.ProductAttrPo;
 import com.java110.po.productDetail.ProductDetailPo;
+import com.java110.po.productLabel.ProductLabelPo;
 import com.java110.po.productSpecValue.ProductSpecValuePo;
 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.RequestHeader;
-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;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -57,6 +58,16 @@ import java.util.List;
 @RequestMapping(value = "/product")
 public class ProductApi {
 
+    @Autowired
+    private ISaveProductLabelBMO saveProductLabelBMOImpl;
+    @Autowired
+    private IUpdateProductLabelBMO updateProductLabelBMOImpl;
+    @Autowired
+    private IDeleteProductLabelBMO deleteProductLabelBMOImpl;
+
+    @Autowired
+    private IGetProductLabelBMO getProductLabelBMOImpl;
+
     @Autowired
     private ISaveProductBMO saveProductBMOImpl;
     @Autowired
@@ -197,7 +208,8 @@ public class ProductApi {
         JSONArray productSpecs = reqJson.containsKey("productSpecs") ? reqJson.getJSONArray("productSpecs") : null;
 
         JSONObject spec = null;
-        List<ProductSpecValuePo> productSpecValuePos = null;;
+        List<ProductSpecValuePo> productSpecValuePos = null;
+        ;
         if (productSpecs != null) {
             productSpecValuePos = new ArrayList<>();
             for (int specIndex = 0; specIndex < productSpecs.size(); specIndex++) {
@@ -211,7 +223,7 @@ public class ProductApi {
 
 
         ProductDetailPo productDetailPo = null;
-        if(reqJson.containsKey("content")) {
+        if (reqJson.containsKey("content")) {
             productDetailPo = new ProductDetailPo();
             productDetailPo.setStoreId(storeId);
             productDetailPo.setContent(reqJson.getString("content"));
@@ -657,8 +669,8 @@ public class ProductApi {
      *
      * @param reqJson
      * @return
-     * @serviceCode /productDetail/saveProductDetail
-     * @path /app/productDetail/saveProductDetail
+     * @serviceCode /product/saveProductDetail
+     * @path /app/product/saveProductDetail
      */
     @RequestMapping(value = "/saveProductDetail", method = RequestMethod.POST)
     public ResponseEntity<String> saveProductDetail(@RequestBody JSONObject reqJson,
@@ -679,8 +691,8 @@ public class ProductApi {
      *
      * @param reqJson
      * @return
-     * @serviceCode /productDetail/updateProductDetail
-     * @path /app/productDetail/updateProductDetail
+     * @serviceCode /product/updateProductDetail
+     * @path /app/product/updateProductDetail
      */
     @RequestMapping(value = "/updateProductDetail", method = RequestMethod.POST)
     public ResponseEntity<String> updateProductDetail(@RequestBody JSONObject reqJson,
@@ -702,8 +714,8 @@ public class ProductApi {
      *
      * @param reqJson
      * @return
-     * @serviceCode /productDetail/deleteProductDetail
-     * @path /app/productDetail/deleteProductDetail
+     * @serviceCode /product/deleteProductDetail
+     * @path /app/product/deleteProductDetail
      */
     @RequestMapping(value = "/deleteProductDetail", method = RequestMethod.POST)
     public ResponseEntity<String> deleteProductDetail(@RequestBody JSONObject reqJson, @RequestHeader(value = "store-id") String storeId) {
@@ -722,8 +734,8 @@ public class ProductApi {
      *
      * @param storeId 小区ID
      * @return
-     * @serviceCode /productDetail/queryProductDetail
-     * @path /app/productDetail/queryProductDetail
+     * @serviceCode /product/queryProductDetail
+     * @path /app/product/queryProductDetail
      */
     @RequestMapping(value = "/queryProductDetail", method = RequestMethod.GET)
     public ResponseEntity<String> queryProductDetail(@RequestHeader(value = "store-id") String storeId,
@@ -737,4 +749,81 @@ public class ProductApi {
         productDetailDto.setProductId(productId);
         return getProductDetailBMOImpl.get(productDetailDto);
     }
+
+
+    /**
+     * 微信保存消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /product/saveProductLabel
+     * @path /app/product/saveProductLabel
+     */
+    @RequestMapping(value = "/saveProductLabel", method = RequestMethod.POST)
+    public ResponseEntity<String> saveProductLabel(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "labelCd", "请求报文中未包含labelCd");
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+
+
+        ProductLabelPo productLabelPo = BeanConvertUtil.covertBean(reqJson, ProductLabelPo.class);
+        return saveProductLabelBMOImpl.save(productLabelPo);
+    }
+
+    /**
+     * 微信修改消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /product/updateProductLabel
+     * @path /app/product/updateProductLabel
+     */
+    @RequestMapping(value = "/updateProductLabel", method = RequestMethod.POST)
+    public ResponseEntity<String> updateProductLabel(@RequestBody JSONObject reqJson) {
+
+        Assert.hasKeyAndValue(reqJson, "labelCd", "请求报文中未包含labelCd");
+        Assert.hasKeyAndValue(reqJson, "productId", "请求报文中未包含productId");
+        Assert.hasKeyAndValue(reqJson, "labelId", "labelId不能为空");
+
+
+        ProductLabelPo productLabelPo = BeanConvertUtil.covertBean(reqJson, ProductLabelPo.class);
+        return updateProductLabelBMOImpl.update(productLabelPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @param reqJson
+     * @return
+     * @serviceCode /product/deleteProductLabel
+     * @path /app/product/deleteProductLabel
+     */
+    @RequestMapping(value = "/deleteProductLabel", method = RequestMethod.POST)
+    public ResponseEntity<String> deleteProductLabel(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityId", "小区ID不能为空");
+
+        Assert.hasKeyAndValue(reqJson, "labelId", "labelId不能为空");
+
+
+        ProductLabelPo productLabelPo = BeanConvertUtil.covertBean(reqJson, ProductLabelPo.class);
+        return deleteProductLabelBMOImpl.delete(productLabelPo);
+    }
+
+    /**
+     * 微信删除消息模板
+     *
+     * @return
+     * @serviceCode /product/queryProductLabel
+     * @path /app/product/queryProductLabel
+     */
+    @RequestMapping(value = "/queryProductLabel", method = RequestMethod.GET)
+    public ResponseEntity<String> queryProductLabel(@RequestParam(value = "labelCd", required = false) String labelCd,
+                                                    @RequestParam(value = "page") int page,
+                                                    @RequestParam(value = "row") int row) {
+        ProductLabelDto productLabelDto = new ProductLabelDto();
+        productLabelDto.setPage(page);
+        productLabelDto.setRow(row);
+        productLabelDto.setLabelCd(labelCd);
+        return getProductLabelBMOImpl.get(productLabelDto);
+    }
 }

service-goods/src/main/java/com/java110/goods/bmo/productLabel/IDeleteProductLabelBMO.java

@@ -0,0 +1,17 @@
+package com.java110.goods.bmo.productLabel;
+import com.java110.po.productLabel.ProductLabelPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IDeleteProductLabelBMO {
+
+
+    /**
+     * 修改产品标签
+     * add by wuxw
+     * @param productLabelPo
+     * @return
+     */
+    ResponseEntity<String> delete(ProductLabelPo productLabelPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/IGetProductLabelBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.productLabel;
+
+import com.java110.dto.productLabel.ProductLabelDto;
+import org.springframework.http.ResponseEntity;
+
+public interface IGetProductLabelBMO {
+
+
+    /**
+     * 查询产品标签
+     * add by wuxw
+     *
+     * @param productLabelDto
+     * @return
+     */
+    ResponseEntity<String> get(ProductLabelDto productLabelDto);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/ISaveProductLabelBMO.java

@@ -0,0 +1,19 @@
+package com.java110.goods.bmo.productLabel;
+
+import com.java110.po.productLabel.ProductLabelPo;
+import org.springframework.http.ResponseEntity;
+
+public interface ISaveProductLabelBMO {
+
+
+    /**
+     * 添加产品标签
+     * add by wuxw
+     *
+     * @param productLabelPo
+     * @return
+     */
+    ResponseEntity<String> save(ProductLabelPo productLabelPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/IUpdateProductLabelBMO.java

@@ -0,0 +1,17 @@
+package com.java110.goods.bmo.productLabel;
+import com.java110.po.productLabel.ProductLabelPo;
+import org.springframework.http.ResponseEntity;
+
+public interface IUpdateProductLabelBMO {
+
+
+    /**
+     * 修改产品标签
+     * add by wuxw
+     * @param productLabelPo
+     * @return
+     */
+    ResponseEntity<String> update(ProductLabelPo productLabelPo);
+
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/impl/DeleteProductLabelBMOImpl.java

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

service-goods/src/main/java/com/java110/goods/bmo/productLabel/impl/GetProductLabelBMOImpl.java

@@ -0,0 +1,44 @@
+package com.java110.goods.bmo.productLabel.impl;
+
+import com.java110.dto.productLabel.ProductLabelDto;
+import com.java110.goods.bmo.productLabel.IGetProductLabelBMO;
+import com.java110.intf.goods.IProductLabelInnerServiceSMO;
+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("getProductLabelBMOImpl")
+public class GetProductLabelBMOImpl implements IGetProductLabelBMO {
+
+    @Autowired
+    private IProductLabelInnerServiceSMO productLabelInnerServiceSMOImpl;
+
+    /**
+     * @param productLabelDto
+     * @return 订单服务能够接受的报文
+     */
+    public ResponseEntity<String> get(ProductLabelDto productLabelDto) {
+
+
+        int count = productLabelInnerServiceSMOImpl.queryProductLabelsCount(productLabelDto);
+
+        List<ProductLabelDto> productLabelDtos = null;
+        if (count > 0) {
+            productLabelDtos = productLabelInnerServiceSMOImpl.queryProductLabels(productLabelDto);
+        } else {
+            productLabelDtos = new ArrayList<>();
+        }
+
+        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) productLabelDto.getRow()), count, productLabelDtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        return responseEntity;
+    }
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/impl/SaveProductLabelBMOImpl.java

@@ -0,0 +1,38 @@
+package com.java110.goods.bmo.productLabel.impl;
+
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.goods.bmo.productLabel.ISaveProductLabelBMO;
+import com.java110.intf.goods.IProductLabelInnerServiceSMO;
+import com.java110.po.productLabel.ProductLabelPo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service("saveProductLabelBMOImpl")
+public class SaveProductLabelBMOImpl implements ISaveProductLabelBMO {
+
+    @Autowired
+    private IProductLabelInnerServiceSMO productLabelInnerServiceSMOImpl;
+
+    /**
+     * 添加小区信息
+     *
+     * @param productLabelPo
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> save(ProductLabelPo productLabelPo) {
+
+        productLabelPo.setLabelId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_labelId));
+        int flag = productLabelInnerServiceSMOImpl.saveProductLabel(productLabelPo);
+
+        if (flag > 0) {
+            return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

service-goods/src/main/java/com/java110/goods/bmo/productLabel/impl/UpdateProductLabelBMOImpl.java

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

service-goods/src/main/java/com/java110/goods/dao/IProductLabelServiceDao.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 IProductLabelServiceDao {
+
+
+    /**
+     * 保存 产品标签信息
+     * @param info
+     * @throws DAOException DAO异常
+     */
+    void saveProductLabelInfo(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 查询产品标签信息（instance过程）
+     * 根据bId 查询产品标签信息
+     * @param info bId 信息
+     * @return 产品标签信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getProductLabelInfo(Map info) throws DAOException;
+
+
+
+    /**
+     * 修改产品标签信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    void updateProductLabelInfo(Map info) throws DAOException;
+
+
+    /**
+     * 查询产品标签总数
+     *
+     * @param info 产品标签信息
+     * @return 产品标签数量
+     */
+    int queryProductLabelsCount(Map info);
+
+}

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

service-goods/src/main/java/com/java110/goods/smo/impl/ProductLabelInnerServiceSMOImpl.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.productLabel.ProductLabelDto;
+import com.java110.goods.dao.IProductLabelServiceDao;
+import com.java110.intf.goods.IProductLabelInnerServiceSMO;
+import com.java110.po.productLabel.ProductLabelPo;
+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 ProductLabelInnerServiceSMOImpl extends BaseServiceSMO implements IProductLabelInnerServiceSMO {
+
+    @Autowired
+    private IProductLabelServiceDao productLabelServiceDaoImpl;
+
+
+    @Override
+    public int saveProductLabel(@RequestBody ProductLabelPo productLabelPo) {
+        int saveFlag = 1;
+        productLabelServiceDaoImpl.saveProductLabelInfo(BeanConvertUtil.beanCovertMap(productLabelPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int updateProductLabel(@RequestBody ProductLabelPo productLabelPo) {
+        int saveFlag = 1;
+        productLabelServiceDaoImpl.updateProductLabelInfo(BeanConvertUtil.beanCovertMap(productLabelPo));
+        return saveFlag;
+    }
+
+    @Override
+    public int deleteProductLabel(@RequestBody ProductLabelPo productLabelPo) {
+        int saveFlag = 1;
+        productLabelPo.setStatusCd("1");
+        productLabelServiceDaoImpl.updateProductLabelInfo(BeanConvertUtil.beanCovertMap(productLabelPo));
+        return saveFlag;
+    }
+
+    @Override
+    public List<ProductLabelDto> queryProductLabels(@RequestBody ProductLabelDto productLabelDto) {
+
+        //校验是否传了 分页信息
+
+        int page = productLabelDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            productLabelDto.setPage((page - 1) * productLabelDto.getRow());
+        }
+
+        List<ProductLabelDto> productLabels = BeanConvertUtil.covertBeanList(productLabelServiceDaoImpl.getProductLabelInfo(BeanConvertUtil.beanCovertMap(productLabelDto)), ProductLabelDto.class);
+
+        return productLabels;
+    }
+
+
+    @Override
+    public int queryProductLabelsCount(@RequestBody ProductLabelDto productLabelDto) {
+        return productLabelServiceDaoImpl.queryProductLabelsCount(BeanConvertUtil.beanCovertMap(productLabelDto));
+    }
+
+    public IProductLabelServiceDao getProductLabelServiceDaoImpl() {
+        return productLabelServiceDaoImpl;
+    }
+
+    public void setProductLabelServiceDaoImpl(IProductLabelServiceDao productLabelServiceDaoImpl) {
+        this.productLabelServiceDaoImpl = productLabelServiceDaoImpl;
+    }
+}