直播功能

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/example/LiveGoodsExample.java

@@ -0,0 +1,54 @@
+package com.slodon.b2b2c.live.example;
+
+import com.slodon.b2b2c.core.response.PagerInfo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveGoodsExample implements Serializable {
+    @ApiModelProperty(value = "填入mediaID 图片 mediaID 的获取，https://developers.weixin.qq.com/doc/offiaccount/Asset_Management/New_temporary_materials.html",required = true)
+    private String coverImgUrl;
+    @ApiModelProperty(value = "商品名称，最长14个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "价格类型，1：一口价（只需要传入price，price2不传） 2：价格区间（price字段为左边界，price2字段为右边界，price和price2必传） 3：显示折扣价（price字段为原价，price2字段为现价， price和price2必传）",required = true)
+    private Integer priceType;
+    @ApiModelProperty(value = "数字，最多保留两位小数，单位元",required = true)
+    private String price;
+    @ApiModelProperty("数字，最多保留两位小数，单位元")
+    private String price2;
+    @ApiModelProperty(value = "商品详情页的小程序路径，路径参数存在 url 的，该参数的值需要进行 encode 处理再填入",required = true)
+    private String url;
+    @ApiModelProperty("当商品为第三方小程序的商品则填写为对应第三方小程序的appid，自身小程序商品则为")
+    private String thirdPartyAppid;
+    @ApiModelProperty("商户ID")
+    private String vendorId;
+    @ApiModelProperty("本地goods表商品ID")
+    private String localGoodsId;
+    @ApiModelProperty("商品间状态。0：未审核，1：审核中，2:审核通过，3审核失败")
+    private Integer auditStatus;
+
+    //==========================微信接口需要装换的参数==============================
+    @ApiModelProperty("商品ID")
+    private Integer goodsId;
+    @ApiModelProperty("审核单ID")
+    private Integer auditId;
+
+
+    //=====================mybatis需要字段============================
+    /**
+     * 排序条件，条件之间用逗号隔开，如果不传则按照goodsId倒序排列
+     */
+    private String orderBy;
+
+    /**
+     * 分组条件
+     */
+    private String groupBy;
+
+    /**
+     * 分页信息
+     */
+    private PagerInfo pager;
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/pojo/LiveGoods.java

@@ -0,0 +1,38 @@
+package com.slodon.b2b2c.live.pojo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveGoods implements Serializable {
+    @ApiModelProperty(value = "填入mediaID 图片 mediaID 的获取，https://developers.weixin.qq.com/doc/offiaccount/Asset_Management/New_temporary_materials.html",required = true)
+    private String coverImgUrl;
+    @ApiModelProperty(value = "商品名称，最长14个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "价格类型，1：一口价（只需要传入price，price2不传） 2：价格区间（price字段为左边界，price2字段为右边界，price和price2必传） 3：显示折扣价（price字段为原价，price2字段为现价， price和price2必传）",required = true)
+    private Integer priceType = 1;
+    @ApiModelProperty(value = "数字，最多保留两位小数，单位元",required = true)
+    private String price;
+    @ApiModelProperty("数字，最多保留两位小数，单位元")
+    private String price2;
+    @ApiModelProperty(value = "商品详情页的小程序路径，路径参数存在 url 的，该参数的值需要进行 encode 处理再填入",required = true)
+    private String url;
+    @ApiModelProperty("当商品为第三方小程序的商品则填写为对应第三方小程序的appid，自身小程序商品则为")
+    private String thirdPartyAppid;
+    @ApiModelProperty("商户ID")
+    private String vendorId;
+    @ApiModelProperty("本地goods表商品ID")
+    private String localGoodsId;
+    @ApiModelProperty("商品间状态。0：未审核，1：审核中，2:审核通过，3审核失败")
+    private Integer auditStatus;
+    @ApiModelProperty("商品间状态名称。0：未审核，1：审核中，2:审核通过，3审核失败")
+    private String auditStatusName;
+
+    //==========================微信接口需要装换的参数==============================
+    @ApiModelProperty("商品ID")
+    private Integer goodsId;
+    @ApiModelProperty("审核单ID")
+    private Integer auditId;
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/dao/write/live/LiveGoodsWriteMapper.java

@@ -0,0 +1,16 @@
+package com.slodon.b2b2c.dao.write.live;
+
+import com.slodon.b2b2c.core.database.BaseWriteMapper;
+import com.slodon.b2b2c.live.example.LiveGoodsExample;
+import com.slodon.b2b2c.live.pojo.LiveGoods;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface LiveGoodsWriteMapper extends BaseWriteMapper<LiveGoods, LiveGoodsExample> {
+    List<Integer> getLivesGoodsIds();
+
+    void updateLivesGoodsType(@Param("liveGoodsList") List<LiveGoods> liveGoodsList);
+
+    List<LiveGoods> getListRelation(@Param("name")String name, @Param("roomId")Integer roomId);
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/model/live/LiveGoodsModel.java

@@ -0,0 +1,61 @@
+package com.slodon.b2b2c.model.live;
+
+import com.slodon.b2b2c.core.response.PagerInfo;
+import com.slodon.b2b2c.dao.write.live.LiveGoodsWriteMapper;
+import com.slodon.b2b2c.live.dto.LiveGoodsInfoDto;
+import com.slodon.b2b2c.live.example.LiveBroadcastExample;
+import com.slodon.b2b2c.live.example.LiveGoodsExample;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
+import com.slodon.b2b2c.live.pojo.LiveGoods;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.beanutils.PropertyUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@Slf4j
+public class LiveGoodsModel {
+
+    @Autowired
+    private LiveGoodsWriteMapper liveGoodsWriteMapper;
+
+    public void addGoodsCreate(LiveGoodsInfoDto liveGoodsInfoDto) {
+
+        LiveGoods liveGoods = new LiveGoods();
+        try {
+            PropertyUtils.copyProperties(liveGoods,liveGoodsInfoDto);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        liveGoodsWriteMapper.insert(liveGoods);
+    }
+
+    public List<LiveGoods> getLivesList(LiveGoodsExample example, PagerInfo pager) {
+        List<LiveGoods> goodsList;
+        if (pager != null) {
+            pager.setRowsCount(liveGoodsWriteMapper.countByExample(example));
+            goodsList = liveGoodsWriteMapper.listPageByExample(example, pager.getStart(), pager.getPageSize());
+        } else {
+            goodsList = liveGoodsWriteMapper.listByExample(example);
+        }
+        return goodsList;
+    }
+
+    public void wxDelLiveGood(Integer goodsId) {
+        liveGoodsWriteMapper.deleteByPrimaryKey(goodsId);
+    }
+
+    public List<Integer> getLivesGoodsIds() {
+        return liveGoodsWriteMapper.getLivesGoodsIds();
+    }
+
+    public void updateLivesGoodsType(List<LiveGoods> liveGoodsList) {
+        liveGoodsWriteMapper.updateLivesGoodsType(liveGoodsList);
+    }
+
+    public List<LiveGoods> getListRelation(String name, Integer roomId) {
+        return liveGoodsWriteMapper.getListRelation(name,roomId);
+    }
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/model/live/LiveJobModel.java

@@ -0,0 +1,48 @@
+package com.slodon.b2b2c.model.live;
+
+import com.slodon.b2b2c.core.response.PagerInfo;
+import com.slodon.b2b2c.dao.write.live.LiveBroadWriteMapper;
+import com.slodon.b2b2c.live.dto.LiveBroadcastDto;
+import com.slodon.b2b2c.live.example.LiveBroadcastExample;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
+import com.slodon.b2b2c.live.vo.LivesVO;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.beanutils.PropertyUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@Slf4j
+public class LiveJobModel {
+
+    @Autowired
+    private LiveBroadWriteMapper liveBroadWriteMapper;
+
+    /**
+     * 查找需要更新状态的直播间起始位置  起始房间，0表示从第1个房间开始拉取
+     * @return
+     * @param roomId
+     */
+    public Integer getLivesNum(Integer roomId) {
+        return liveBroadWriteMapper.getLivesNum(roomId);
+    }
+
+
+    public void updateLivesType(List<LivesVO> livesVOS) {
+        liveBroadWriteMapper.updateLivesType(livesVOS);
+    }
+
+    /**
+     * 获取总数
+     * @return
+     */
+    public Integer getLiveCount() {
+        return liveBroadWriteMapper.countByExample(new LiveBroadcastExample());
+    }
+
+    public Integer getLiveRoomId() {
+        return liveBroadWriteMapper.getLiveRoomId();
+    }
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/util/ThumbnailsUtils.java

@@ -0,0 +1,53 @@
+package com.slodon.b2b2c.util;
+import net.coobird.thumbnailator.Thumbnails;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import javax.imageio.ImageIO;
+import java.awt.image.BufferedImage;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+public class ThumbnailsUtils{
+    private static final Logger logger = LoggerFactory.getLogger(ThumbnailsUtils.class);
+    /**
+     * 通过BufferedImage图片流调整图片大小
+     */
+    public static BufferedImage resizeImageOne(BufferedImage originalImage, int targetWidth, int targetHeight) throws Exception {
+        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+        Thumbnails.of(originalImage)
+                .size(targetWidth, targetHeight)
+                .outputFormat("JPEG")
+                .keepAspectRatio(false)
+                .outputQuality(1)
+                .toOutputStream(outputStream);
+        byte[] data = outputStream.toByteArray();
+        ByteArrayInputStream inputStream = new ByteArrayInputStream(data);
+        return ImageIO.read(inputStream);
+    }
+
+    /**
+     * BufferedImage图片流转byte[]数组
+     */
+    public static byte[] imageToBytes(BufferedImage bImage) {
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        try {
+            ImageIO.write(bImage, "jpg", out);
+        } catch (IOException e) {
+            logger.error("错误信息: ", e);
+        }
+        return out.toByteArray();
+    }
+    /**
+     * byte[]数组转BufferedImage图片流
+     */
+    private static BufferedImage bytesToBufferedImage(byte[] ImageByte) {
+        ByteArrayInputStream in = new ByteArrayInputStream(ImageByte);
+        BufferedImage image = null;
+        try {
+            image = ImageIO.read(in);
+        } catch (IOException e) {
+            logger.error("错误信息: ", e);
+        }
+        return image;
+    }
+}

b2b2c/b2b2c-web/src/main/resources/mapper/read/Live/LiveGoodsReadMapper.xml

@@ -0,0 +1,354 @@
+<?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="com.slodon.b2b2c.dao.write.live.LiveGoodsWriteMapper">
+  <resultMap id="resultMap" type="com.slodon.b2b2c.live.pojo.LiveGoods">
+    <id column="goodsId" property="goodsId" />
+    <result column="coverImgUrl" property="coverImgUrl" />
+    <result column="name" property="name" />
+    <result column="priceType" property="priceType" />
+    <result column="price" property="price" />
+    <result column="price2" property="price2" />
+    <result column="url" property="url" />
+    <result column="thirdPartyAppid" property="thirdPartyAppid" />
+    <result column="vendorId" property="vendorId" />
+    <result column="localGoodsId" property="localGoodsId" />
+    <result column="auditStatus" property="auditStatus" />
+    <result column="auditId" property="auditId" />
+  </resultMap>
+
+  <!--除主键外的所有字段，用于插入操作-->
+  <sql id="columns">
+    <trim suffixOverrides=",">
+      <if test="goodsId != null">
+        goodsId,
+      </if>
+      <if test="vendorId != null">
+        vendorId,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="coverImgUrl != null">
+        coverImgUrl,
+      </if>
+      <if test="priceType != null">
+        priceType,
+      </if>
+      <if test="price != null">
+        price,
+      </if>
+      <if test="price2 != null">
+        price2,
+      </if>
+      <if test="url != null">
+        url,
+      </if>
+      <if test="thirdPartyAppid != null">
+        thirdPartyAppid,
+      </if>
+      <if test="localGoodsId != null">
+        localGoodsId,
+      </if>
+      <if test="auditStatus != null">
+        auditStatus,
+      </if>
+      <if test="auditId != null">
+        auditId,
+      </if>
+    </trim>
+  </sql>
+  <!--按照主键值进行操作-->
+  <sql id="pkWhere">
+    WHERE goodsId = #{primaryKey}
+  </sql>
+  <!--操作条件-->
+  <sql id="whereCondition">
+    <if test="example != null">
+      <trim prefix="WHERE" prefixOverrides="AND|OR">
+        <if test="example.coverImgUrl != null">
+          AND coverImgUrl = #{example.coverImgUrl}
+        </if>
+        <if test="example.vendorId != null">
+          AND vendorId = #{example.vendorId}
+        </if>
+        <if test="example.name != null">
+          AND name like concat('%',#{example.name},'%')
+        </if>
+        <if test="example.priceType != null">
+          AND priceType = #{example.priceType}
+        </if>
+        <if test="example.price != null">
+          AND price = #{example.price}
+        </if>
+        <if test="example.price2 != null">
+          AND price2 = #{example.price2}
+        </if>
+        <if test="example.url != null">
+          AND url = #{example.url}
+        </if>
+        <if test="example.thirdPartyAppid != null">
+          AND thirdPartyAppid = #{example.thirdPartyAppid}
+        </if>
+        <if test="example.localGoodsId != null">
+          AND localGoodsId = #{example.localGoodsId}
+        </if>
+        <if test="example.auditStatus != null">
+          AND auditStatus = #{example.auditStatus}
+        </if>
+        <if test="example.goodsId != null">
+          AND goodsId = #{example.goodsId}
+        </if>
+        <if test="example.auditId != null">
+          AND auditId = #{example.auditId}
+        </if>
+
+      </trim>
+    </if>
+  </sql>
+  <!--排序条件-->
+  <sql id="orderBy">
+    ORDER BY goodsId DESC
+  </sql>
+  <sql id="orderByOther">
+    order by #{example.orderBy}
+  </sql>
+  <!--分组条件-->
+  <sql id="groupBy">
+    group by #{example.groupBy}
+  </sql>
+  <!--分页条件-->
+  <sql id="limit">
+    <if test="size != null and size &gt; 0">
+      limit #{startRow},#{size}
+    </if>
+  </sql>
+  <!--查询符合条件的记录数-->
+  <select id="countByExample" parameterType="com.slodon.b2b2c.live.example.LiveGoodsExample" resultType="java.lang.Integer">
+    SELECT
+      COUNT(*)
+    FROM live_goods
+    <include refid="whereCondition" />
+  </select>
+  <!--根据主键查询记录-->
+  <select id="getByPrimaryKey" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_goods
+    <include refid="pkWhere" />
+  </select>
+  <!--查询符合条件的记录(所有字段)-->
+  <select id="listByExample" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(所有字段)-->
+  <select id="listPageByExample" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--查询符合条件的记录(指定字段)-->
+  <select id="listFieldsByExample" resultMap="resultMap">
+    SELECT
+      #{fields}
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(指定字段)-->
+  <select id="listFieldsPageByExample" resultMap="resultMap">
+    SELECT
+      #{fields}
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--根据条件删除记录，可多条删除-->
+  <delete id="deleteByExample">
+    DELETE FROM live_goods
+    <include refid="whereCondition" />
+  </delete>
+  <!--根据主键删除记录-->
+  <delete id="deleteByPrimaryKey">
+    DELETE FROM live_goods
+    <include refid="pkWhere" />
+  </delete>
+  <!--插入一条记录-->
+  <insert id="insert" keyColumn="roomId" keyProperty="roomId" parameterType="com.slodon.b2b2c.live.pojo.LiveGoods" useGeneratedKeys="true">
+    INSERT INTO live_goods(
+    <include refid="columns" />
+    )
+    VALUES(
+    <trim suffixOverrides=",">
+      <if test="goodsId != null">
+        #{goodsId},
+      </if>
+      <if test="vendorId != null">
+        #{vendorId},
+      </if>
+      <if test="name != null">
+        #{name},
+      </if>
+      <if test="coverImgUrl != null">
+        #{coverImgUrl},
+      </if>
+      <if test="priceType != null">
+        #{priceType},
+      </if>
+      <if test="price != null">
+        #{price},
+      </if>
+      <if test="price2 != null">
+        #{price2},
+      </if>
+      <if test="url != null">
+        #{url},
+      </if>
+      <if test="thirdPartyAppid != null">
+        #{thirdPartyAppid},
+      </if>
+      <if test="localGoodsId != null">
+        #{localGoodsId},
+      </if>
+      <if test="auditStatus != null">
+        #{auditStatus},
+      </if>
+      <if test="auditId != null">
+        #{auditId},
+      </if>
+
+    </trim>
+    )
+  </insert>
+  <!--按条件更新记录中不为空的字段-->
+  <update id="updateByExampleSelective">
+    UPDATE live_goods
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="record.goodsId != null">
+        AND goodsId = #{record.goodsId},
+      </if>
+      <if test="record.vendorId != null">
+        AND vendorId = #{record.vendorId},
+      </if>
+      <if test="record.name != null">
+        AND name = #{record.name},
+      </if>
+      <if test="record.coverImgUrl != null">
+        AND coverImgUrl = #{record.coverImgUrl},
+      </if>
+      <if test="record.priceType != null">
+        AND priceType = #{record.priceType},
+      </if>
+      <if test="record.price != null">
+        AND price = #{record.price},
+      </if>
+      <if test="record.price2 != null">
+        AND price2 = #{record.price2},
+      </if>
+      <if test="record.url != null">
+        AND url = #{record.url},
+      </if>
+      <if test="record.thirdPartyAppid != null">
+        AND thirdPartyAppid = #{record.thirdPartyAppid},
+      </if>
+      <if test="record.localGoodsId != null">
+        AND localGoodsId = #{record.localGoodsId},
+      </if>
+      <if test="record.auditStatus != null">
+        AND auditStatus = #{record.auditStatus},
+      </if>
+      <if test="record.auditId != null">
+        AND auditId = #{record.auditId},
+      </if>
+
+    </trim>
+    <include refid="whereCondition" />
+  </update>
+  <!--按照主键更新记录中不为空的字段-->
+  <update id="updateByPrimaryKeySelective">
+    UPDATE live_goods
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="vendorId != null">
+        AND vendorId = #{vendorId},
+      </if>
+      <if test="name != null">
+        AND name = #{name},
+      </if>
+      <if test="coverImgUrl != null">
+        AND coverImgUrl = #{coverImgUrl},
+      </if>
+      <if test="priceType != null">
+        AND priceType = #{priceType},
+      </if>
+      <if test="price != null">
+        AND price = #{price},
+      </if>
+      <if test="price2 != null">
+        AND price2 = #{price2},
+      </if>
+      <if test="url != null">
+        AND url = #{url},
+      </if>
+      <if test="thirdPartyAppid != null">
+        AND thirdPartyAppid = #{thirdPartyAppid},
+      </if>
+      <if test="localGoodsId != null">
+        AND localGoodsId = #{localGoodsId},
+      </if>
+      <if test="auditStatus != null">
+        AND auditStatus = #{auditStatus},
+      </if>
+      <if test="auditId != null">
+        AND auditId = #{auditId},
+      </if>
+    </trim>
+    WHERE goodsId = #{goodsId}
+  </update>
+</mapper>

b2b2c/b2b2c-web/src/main/resources/mapper/write/Live/LiveGoodsWriteMapper.xml

@@ -0,0 +1,372 @@
+<?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="com.slodon.b2b2c.dao.write.live.LiveGoodsWriteMapper">
+  <resultMap id="resultMap" type="com.slodon.b2b2c.live.pojo.LiveGoods">
+    <id column="goodsId" property="goodsId" />
+    <result column="coverImgUrl" property="coverImgUrl" />
+    <result column="name" property="name" />
+    <result column="priceType" property="priceType" />
+    <result column="price" property="price" />
+    <result column="price2" property="price2" />
+    <result column="url" property="url" />
+    <result column="thirdPartyAppid" property="thirdPartyAppid" />
+    <result column="vendorId" property="vendorId" />
+    <result column="localGoodsId" property="localGoodsId" />
+    <result column="auditStatus" property="auditStatus" />
+    <result column="auditId" property="auditId" />
+  </resultMap>
+
+  <!--除主键外的所有字段，用于插入操作-->
+  <sql id="columns">
+    <trim suffixOverrides=",">
+      <if test="goodsId != null">
+        goodsId,
+      </if>
+      <if test="vendorId != null">
+        vendorId,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="coverImgUrl != null">
+        coverImgUrl,
+      </if>
+      <if test="priceType != null">
+        priceType,
+      </if>
+      <if test="price != null">
+        price,
+      </if>
+      <if test="price2 != null">
+        price2,
+      </if>
+      <if test="url != null">
+        url,
+      </if>
+      <if test="thirdPartyAppid != null">
+        thirdPartyAppid,
+      </if>
+      <if test="localGoodsId != null">
+        localGoodsId,
+      </if>
+      <if test="auditStatus != null">
+        auditStatus,
+      </if>
+      <if test="auditId != null">
+        auditId,
+      </if>
+    </trim>
+  </sql>
+  <!--按照主键值进行操作-->
+  <sql id="pkWhere">
+    WHERE goodsId = #{primaryKey}
+  </sql>
+  <!--操作条件-->
+  <sql id="whereCondition">
+    <if test="example != null">
+      <trim prefix="WHERE" prefixOverrides="AND|OR">
+        <if test="example.coverImgUrl != null">
+          AND coverImgUrl = #{example.coverImgUrl}
+        </if>
+        <if test="example.vendorId != null">
+          AND vendorId = #{example.vendorId}
+        </if>
+        <if test="example.name != null">
+          AND name like concat('%',#{example.name},'%')
+        </if>
+        <if test="example.priceType != null">
+          AND priceType = #{example.priceType}
+        </if>
+        <if test="example.price != null">
+          AND price = #{example.price}
+        </if>
+        <if test="example.price2 != null">
+          AND price2 = #{example.price2}
+        </if>
+        <if test="example.url != null">
+          AND url = #{example.url}
+        </if>
+        <if test="example.thirdPartyAppid != null">
+          AND thirdPartyAppid = #{example.thirdPartyAppid}
+        </if>
+        <if test="example.localGoodsId != null">
+          AND localGoodsId = #{example.localGoodsId}
+        </if>
+        <if test="example.auditStatus != null">
+          AND auditStatus = #{example.auditStatus}
+        </if>
+        <if test="example.goodsId != null">
+          AND goodsId = #{example.goodsId}
+        </if>
+        <if test="example.auditId != null">
+          AND auditId = #{example.auditId}
+        </if>
+
+      </trim>
+    </if>
+  </sql>
+  <!--排序条件-->
+  <sql id="orderBy">
+    ORDER BY goodsId DESC
+  </sql>
+  <sql id="orderByOther">
+    order by #{example.orderBy}
+  </sql>
+  <!--分组条件-->
+  <sql id="groupBy">
+    group by #{example.groupBy}
+  </sql>
+  <!--分页条件-->
+  <sql id="limit">
+    <if test="size != null and size &gt; 0">
+      limit #{startRow},#{size}
+    </if>
+  </sql>
+  <!--查询符合条件的记录数-->
+  <select id="countByExample" parameterType="com.slodon.b2b2c.live.example.LiveGoodsExample" resultType="java.lang.Integer">
+    SELECT
+    COUNT(*)
+    FROM live_goods
+    <include refid="whereCondition" />
+  </select>
+  <!--根据主键查询记录-->
+  <select id="getByPrimaryKey" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_goods
+    <include refid="pkWhere" />
+  </select>
+  <!--查询符合条件的记录(所有字段)-->
+  <select id="listByExample" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(所有字段)-->
+  <select id="listPageByExample" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--查询符合条件的记录(指定字段)-->
+  <select id="listFieldsByExample" resultMap="resultMap">
+    SELECT
+    #{fields}
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(指定字段)-->
+  <select id="listFieldsPageByExample" resultMap="resultMap">
+    SELECT
+    #{fields}
+    FROM live_goods
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+    <select id="getLivesGoodsIds" resultType="java.lang.Integer">
+        select goodsId from live_goods where auditStatus = 1
+    </select>
+  <select id="getListRelation" resultMap="resultMap">
+        select lg.* from live_goods_relation rel
+        left join live_goods lg on rel.goodsId = lg.goodsId
+        where rel.roomId = #{roomId}
+        <if test="name != null">
+          AND lg.name = #{name}
+        </if>
+  </select>
+  <!--根据条件删除记录，可多条删除-->
+  <delete id="deleteByExample">
+    DELETE FROM live_goods
+    <include refid="whereCondition" />
+  </delete>
+  <!--根据主键删除记录-->
+  <delete id="deleteByPrimaryKey">
+    DELETE FROM live_goods
+    <include refid="pkWhere" />
+  </delete>
+  <!--插入一条记录-->
+  <insert id="insert" keyColumn="roomId" keyProperty="roomId" parameterType="com.slodon.b2b2c.live.pojo.LiveGoods" useGeneratedKeys="true">
+    INSERT INTO live_goods(
+    <include refid="columns" />
+    )
+    VALUES(
+    <trim suffixOverrides=",">
+      <if test="goodsId != null">
+        #{goodsId},
+      </if>
+      <if test="vendorId != null">
+        #{vendorId},
+      </if>
+      <if test="name != null">
+        #{name},
+      </if>
+      <if test="coverImgUrl != null">
+        #{coverImgUrl},
+      </if>
+      <if test="priceType != null">
+        #{priceType},
+      </if>
+      <if test="price != null">
+        #{price},
+      </if>
+      <if test="price2 != null">
+        #{price2},
+      </if>
+      <if test="url != null">
+        #{url},
+      </if>
+      <if test="thirdPartyAppid != null">
+        #{thirdPartyAppid},
+      </if>
+      <if test="localGoodsId != null">
+        #{localGoodsId},
+      </if>
+      <if test="auditStatus != null">
+        #{auditStatus},
+      </if>
+      <if test="auditId != null">
+        #{auditId},
+      </if>
+
+    </trim>
+    )
+  </insert>
+  <!--按条件更新记录中不为空的字段-->
+  <update id="updateByExampleSelective">
+    UPDATE live_goods
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="record.goodsId != null">
+        AND goodsId = #{record.goodsId},
+      </if>
+      <if test="record.vendorId != null">
+        AND vendorId = #{record.vendorId},
+      </if>
+      <if test="record.name != null">
+        AND name = #{record.name},
+      </if>
+      <if test="record.coverImgUrl != null">
+        AND coverImgUrl = #{record.coverImgUrl},
+      </if>
+      <if test="record.priceType != null">
+        AND priceType = #{record.priceType},
+      </if>
+      <if test="record.price != null">
+        AND price = #{record.price},
+      </if>
+      <if test="record.price2 != null">
+        AND price2 = #{record.price2},
+      </if>
+      <if test="record.url != null">
+        AND url = #{record.url},
+      </if>
+      <if test="record.thirdPartyAppid != null">
+        AND thirdPartyAppid = #{record.thirdPartyAppid},
+      </if>
+      <if test="record.localGoodsId != null">
+        AND localGoodsId = #{record.localGoodsId},
+      </if>
+      <if test="record.auditStatus != null">
+        AND auditStatus = #{record.auditStatus},
+      </if>
+      <if test="record.auditId != null">
+        AND auditId = #{record.auditId},
+      </if>
+
+    </trim>
+    <include refid="whereCondition" />
+  </update>
+  <!--按照主键更新记录中不为空的字段-->
+  <update id="updateByPrimaryKeySelective">
+    UPDATE live_goods
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="vendorId != null">
+        AND vendorId = #{vendorId},
+      </if>
+      <if test="name != null">
+        AND name = #{name},
+      </if>
+      <if test="coverImgUrl != null">
+        AND coverImgUrl = #{coverImgUrl},
+      </if>
+      <if test="priceType != null">
+        AND priceType = #{priceType},
+      </if>
+      <if test="price != null">
+        AND price = #{price},
+      </if>
+      <if test="price2 != null">
+        AND price2 = #{price2},
+      </if>
+      <if test="url != null">
+        AND url = #{url},
+      </if>
+      <if test="thirdPartyAppid != null">
+        AND thirdPartyAppid = #{thirdPartyAppid},
+      </if>
+      <if test="localGoodsId != null">
+        AND localGoodsId = #{localGoodsId},
+      </if>
+      <if test="auditStatus != null">
+        AND auditStatus = #{auditStatus},
+      </if>
+      <if test="auditId != null">
+        AND auditId = #{auditId},
+      </if>
+    </trim>
+    WHERE goodsId = #{goodsId}
+  </update>
+  <update id="updateLivesGoodsType">
+    <foreach collection="liveGoodsList" item="item" index="index">
+      update live_goods set
+      auditStatus=#{item.auditStatus}
+      where goodsId = #{item.goodsId};
+    </foreach>
+  </update>
+</mapper>

b2b2c/sql/因客户要求修改的数据.sql

@@ -0,0 +1,2 @@
+-- 商品迁移
+update goods set store_id = '360003',store_name='华阳单位集采' where id in (15,44,47,48,49,50,51,53);

b2b2c/sql/项目修改语句.sql

@@ -77,4 +77,33 @@ update store_grade set price = '0.01';
 
 -- 直播不显示
 -- update sys_system_resource set state = 0 where front_path like '%/bussset_live%'
-delete from sys_system_resource where front_path like '%/bussset_live%'
+delete from sys_system_resource where front_path like '%/bussset_live%'
+
+-- 支付宝支付关闭
+update sys_setting set value = 0 where name = 'alipay_is_enable_h5';
+update sys_setting set value = 0 where name = 'alipay_is_enable_pc';
+
+-- 平台端短信消息模板 msg_member_tpl（会员）msg_store_tpl（商户）
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的售后单有新的变化，退款编号：{$afsSn}。"}' where tpl_code = 'after_sale_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"您关注的商品：{1}，马上就要开始了,请进场准备好,谢谢。"}' where tpl_code = 'appointment_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的账户于{$changeTime}发生了资金变动，描述：{$description}，当前可用金额：{$availableBalance}元，冻结金额：{$frozenBalance}元。"}' where tpl_code = 'balance_change_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您有一张优惠券将于{$expireTime}过期。"}' where tpl_code = 'coupon_expired_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的订单：{$orderSn}，已于{$deliveryTime}发货完成。"}' where tpl_code = 'goods_delivery_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的账户于{$changeTime}发生了积分变动，描述：{$description}，当前可用积分：{$availableIntegral}。"}' where tpl_code = 'integral_change_reminder';
+update msg_member_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的订单：{$orderSn}，已于{$paymentTime}付款成功。"}' where tpl_code = 'payment_success_reminder';
+
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您有新的结算单等待确认，开始时间：{$startTime}，结束时间：{$endTime}，结算单号：{$billSn}。"}' where tpl_code = 'bill_order_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的结算单平台已付款，请注意查收，结算单号：{$billSn}。"}' where tpl_code = 'bill_paid_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的商品没有通过审核。SPU：{$goodsName}。"}' where tpl_code = 'goods_audit_failure_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的商品库存不足，请及时补货。SPU：{$goodsName}，SKU：{$goodsSpec}。"}' where tpl_code = 'goods_stock_warning';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的商品{$goodsName}被违规下架，原因：{$reason}。"}' where tpl_code = 'goods_violation_off_shelf_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的退款单：{$refundSn}超期未处理，已自动同意买家退款申请。"}' where tpl_code = 'member_auto_refund_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的退货单：{$returnSn}超期未处理，已自动同意买家退货申请。"}' where tpl_code = 'member_auto_return_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您有一个退款单需要处理，退款单号：{$refundSn}。"}' where tpl_code = 'member_refund_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的退货单：{$returnSn}不处理收货超期未处理，已自动按弃货处理。"}' where tpl_code = 'member_return_auto_receive_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您有一个退货单需要处理，退货单号：{$returnSn}。"}' where tpl_code = 'member_return_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您有一个新订单需要处理，订单号：{$orderSn}。"}' where tpl_code = 'new_order_reminder';
+update msg_store_tpl set sms_content = '{"templateId":"978409","templateContent":"{$siteName}您的店铺{$storeName}将于{$expireTime}到期，请尽快续签。"}' where tpl_code = 'store_end_reminder';
+
+-- 关闭推手功能
+update vendor_resources set state = 2 where content like '%推手%';