1

ruoyi-admin/src/main/java/com/ruoyi/web/controller/jarvis/XbMessageController.java

@@ -0,0 +1,112 @@
+package com.ruoyi.web.controller.jarvis;
+
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+
+import com.ruoyi.jarvis.domain.XbMessageItem;
+import com.ruoyi.jarvis.service.IXbMessageItemService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.ruoyi.common.annotation.Log;
+import com.ruoyi.common.core.controller.BaseController;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.enums.BusinessType;
+import com.ruoyi.jarvis.domain.XbMessage;
+import com.ruoyi.jarvis.service.IXbMessageService;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.common.core.page.TableDataInfo;
+
+/**
+ * 线报消息Controller
+ *
+ * @author ruoyi
+ */
+@RestController
+@RequestMapping("/jarvis/xbmessage")
+public class XbMessageController extends BaseController
+{
+    @Autowired
+    private IXbMessageService xbMessageService;
+    @Autowired
+    private IXbMessageItemService xbMessageItemService;
+
+    /**
+     * 查询线报消息列表
+     */
+    @GetMapping("/list")
+    public TableDataInfo list(XbMessage xbMessage)
+    {
+        startPage();
+        List<XbMessage> list = xbMessageService.selectXbMessageList(xbMessage);
+        TableDataInfo dataTable = getDataTable(list);
+        if (!dataTable.getRows().isEmpty()) {
+            @SuppressWarnings("unchecked")
+            List<XbMessage> rows = (List<XbMessage>) dataTable.getRows();
+            for (XbMessage xbMessageCache : rows) {
+                XbMessageItem item = new XbMessageItem();
+                item.setXbMessageId(xbMessageCache.getId().toString());
+                List<XbMessageItem> children = xbMessageItemService.selectXbMessageItemList(item);
+                xbMessageCache.setChildren(children);
+            }
+        }
+        return dataTable;
+    }
+
+    /**
+     * 导出线报消息列表
+     */
+    @Log(title = "线报消息", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, XbMessage xbMessage)
+    {
+        List<XbMessage> list = xbMessageService.selectXbMessageList(xbMessage);
+        ExcelUtil<XbMessage> util = new ExcelUtil<XbMessage>(XbMessage.class);
+        util.exportExcel(response, list, "线报消息数据");
+    }
+
+    /**
+     * 获取线报消息详细信息
+     */
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Integer id)
+    {
+        return success(xbMessageService.selectXbMessageById(id));
+    }
+
+    /**
+     * 新增线报消息
+     */
+    @Log(title = "线报消息", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody XbMessage xbMessage)
+    {
+        return toAjax(xbMessageService.insertXbMessage(xbMessage));
+    }
+
+    /**
+     * 修改线报消息
+     */
+    @Log(title = "线报消息", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody XbMessage xbMessage)
+    {
+        return toAjax(xbMessageService.updateXbMessage(xbMessage));
+    }
+
+    /**
+     * 删除线报消息
+     */
+    @Log(title = "线报消息", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Integer[] ids)
+    {
+        return toAjax(xbMessageService.deleteXbMessageByIds(ids));
+    }
+}

ruoyi-admin/src/main/java/com/ruoyi/web/controller/jarvis/XbMessageItemController.java

@@ -0,0 +1,98 @@
+package com.ruoyi.web.controller.jarvis;
+
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.ruoyi.common.annotation.Log;
+import com.ruoyi.common.core.controller.BaseController;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.enums.BusinessType;
+import com.ruoyi.jarvis.domain.XbMessageItem;
+import com.ruoyi.jarvis.service.IXbMessageItemService;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.common.core.page.TableDataInfo;
+
+/**
+ * 线报消息项Controller
+ *
+ * @author ruoyi
+ */
+@RestController
+@RequestMapping("/jarvis/xbmessageitem")
+public class XbMessageItemController extends BaseController
+{
+    @Autowired
+    private IXbMessageItemService xbMessageItemService;
+
+    /**
+     * 查询线报消息项列表
+     */
+    @GetMapping("/list")
+    public TableDataInfo list(XbMessageItem xbMessageItem)
+    {
+        startPage();
+        List<XbMessageItem> list = xbMessageItemService.selectXbMessageItemList(xbMessageItem);
+        TableDataInfo data = getDataTable(list);
+        return data;
+    }
+
+    /**
+     * 导出线报消息项列表
+     */
+    @Log(title = "线报消息项", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, XbMessageItem xbMessageItem)
+    {
+        List<XbMessageItem> list = xbMessageItemService.selectXbMessageItemList(xbMessageItem);
+        ExcelUtil<XbMessageItem> util = new ExcelUtil<XbMessageItem>(XbMessageItem.class);
+        util.exportExcel(response, list, "线报消息项数据");
+    }
+
+    /**
+     * 获取线报消息项详细信息
+     */
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Integer id)
+    {
+        return success(xbMessageItemService.selectXbMessageItemById(id));
+    }
+
+    /**
+     * 新增线报消息项
+     */
+    @Log(title = "线报消息项", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody XbMessageItem xbMessageItem)
+    {
+        return toAjax(xbMessageItemService.insertXbMessageItem(xbMessageItem));
+    }
+
+    /**
+     * 修改线报消息项
+     */
+    @Log(title = "线报消息项", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody XbMessageItem xbMessageItem)
+    {
+        return toAjax(xbMessageItemService.updateXbMessageItem(xbMessageItem));
+    }
+
+    /**
+     * 删除线报消息项
+     */
+    @Log(title = "线报消息项", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Integer[] ids)
+    {
+        return toAjax(xbMessageItemService.deleteXbMessageItemByIds(ids));
+    }
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/domain/XbMessage.java

@@ -0,0 +1,233 @@
+package com.ruoyi.jarvis.domain;
+
+import org.springframework.data.annotation.Transient;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ *
+ * @TableName xb_message
+ */
+public class XbMessage {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     *
+     */
+    private Date createDate;
+
+    /**
+     *
+     */
+    private String skuid;
+
+    /**
+     * 线报原消息
+     */
+    private String tipOriginalMessage;
+
+    /**
+     * 来源
+     */
+    private String fromWxid;
+
+    /**
+     * 线报消息首行内容
+     */
+    private String firstLine;
+
+    /**
+     * 第一个商品的标题
+     */
+    private String firstSkuName;
+
+    /**
+     * 第一个线报商品的价格
+     */
+    private Double firstPrice;
+
+    public List<XbMessageItem> getChildren() {
+        if (children == null) {
+            children = new java.util.ArrayList<>();
+        }
+        return children;
+    }
+
+    public void setChildren(List<XbMessageItem> children) {
+        this.children = children;
+    }
+
+    @Transient
+    private List<XbMessageItem> children;
+
+    /**
+     *
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     *
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    /**
+     *
+     */
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    /**
+     *
+     */
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    /**
+     *
+     */
+    public String getSkuid() {
+        return skuid;
+    }
+
+    /**
+     *
+     */
+    public void setSkuid(String skuid) {
+        this.skuid = skuid;
+    }
+
+    /**
+     * 线报原消息
+     */
+    public String getTipOriginalMessage() {
+        return tipOriginalMessage;
+    }
+
+    /**
+     * 线报原消息
+     */
+    public void setTipOriginalMessage(String tipOriginalMessage) {
+        this.tipOriginalMessage = tipOriginalMessage;
+    }
+
+    /**
+     * 来源
+     */
+    public String getFromWxid() {
+        return fromWxid;
+    }
+
+    /**
+     * 来源
+     */
+    public void setFromWxid(String fromWxid) {
+        this.fromWxid = fromWxid;
+    }
+
+    /**
+     * 线报消息首行内容
+     */
+    public String getFirstLine() {
+        return firstLine;
+    }
+
+    /**
+     * 线报消息首行内容
+     */
+    public void setFirstLine(String firstLine) {
+        this.firstLine = firstLine;
+    }
+
+    /**
+     * 第一个商品的标题
+     */
+    public String getFirstSkuName() {
+        return firstSkuName;
+    }
+
+    /**
+     * 第一个商品的标题
+     */
+    public void setFirstSkuName(String firstSkuName) {
+        this.firstSkuName = firstSkuName;
+    }
+
+    /**
+     * 第一个线报商品的价格
+     */
+    public Double getFirstPrice() {
+        return firstPrice;
+    }
+
+    /**
+     * 第一个线报商品的价格
+     */
+    public void setFirstPrice(Double firstPrice) {
+        this.firstPrice = firstPrice;
+    }
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        XbMessage other = (XbMessage) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCreateDate() == null ? other.getCreateDate() == null : this.getCreateDate().equals(other.getCreateDate()))
+            && (this.getSkuid() == null ? other.getSkuid() == null : this.getSkuid().equals(other.getSkuid()))
+            && (this.getTipOriginalMessage() == null ? other.getTipOriginalMessage() == null : this.getTipOriginalMessage().equals(other.getTipOriginalMessage()))
+            && (this.getFromWxid() == null ? other.getFromWxid() == null : this.getFromWxid().equals(other.getFromWxid()))
+            && (this.getFirstLine() == null ? other.getFirstLine() == null : this.getFirstLine().equals(other.getFirstLine()))
+            && (this.getFirstSkuName() == null ? other.getFirstSkuName() == null : this.getFirstSkuName().equals(other.getFirstSkuName()))
+            && (this.getFirstPrice() == null ? other.getFirstPrice() == null : this.getFirstPrice().equals(other.getFirstPrice()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCreateDate() == null) ? 0 : getCreateDate().hashCode());
+        result = prime * result + ((getSkuid() == null) ? 0 : getSkuid().hashCode());
+        result = prime * result + ((getTipOriginalMessage() == null) ? 0 : getTipOriginalMessage().hashCode());
+        result = prime * result + ((getFromWxid() == null) ? 0 : getFromWxid().hashCode());
+        result = prime * result + ((getFirstLine() == null) ? 0 : getFirstLine().hashCode());
+        result = prime * result + ((getFirstSkuName() == null) ? 0 : getFirstSkuName().hashCode());
+        result = prime * result + ((getFirstPrice() == null) ? 0 : getFirstPrice().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", createDate=").append(createDate);
+        sb.append(", skuid=").append(skuid);
+        sb.append(", tipOriginalMessage=").append(tipOriginalMessage);
+        sb.append(", fromWxid=").append(fromWxid);
+        sb.append(", firstLine=").append(firstLine);
+        sb.append(", firstSkuName=").append(firstSkuName);
+        sb.append(", firstPrice=").append(firstPrice);
+        sb.append("]");
+        return sb.toString();
+    }
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/domain/XbMessageItem.java

@@ -0,0 +1,348 @@
+package com.ruoyi.jarvis.domain;
+
+import java.util.Date;
+
+/**
+ *
+ * @TableName xb_message_item
+ */
+public class XbMessageItem {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     *
+     */
+    private Date createDate;
+
+    /**
+     *
+     */
+    private String skuid;
+
+    /**
+     * 主表id
+     */
+    private String xbMessageId;
+
+    /**
+     * jd_union_open_goods_query_responce.queryResult的完整JSON
+     */
+    private String jsonQueryResult;
+
+    /**
+     * couponInfo.couponList
+     */
+    private String jsonCouponList;
+
+    /**
+     * spuid
+     */
+    private String spuid;
+
+    /**
+     * skuName
+     */
+    private String skuName;
+
+    /**
+     * shopInfo
+     */
+    private String jsonShopInfo;
+
+    /**
+     * priceInfo
+     */
+    private String priceInfo;
+
+    /**
+     * commissionInfo
+     */
+    private String jsonCommissionInfo;
+
+    /**
+     * imageList
+     */
+    private String jsonImageList;
+
+    /**
+     * owner
+     */
+    private String owner;
+
+    /**
+     * categoryInfo
+     */
+    private String jsonCategoryInfo;
+
+    /**
+     *
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     *
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    /**
+     *
+     */
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    /**
+     *
+     */
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    /**
+     *
+     */
+    public String getSkuid() {
+        return skuid;
+    }
+
+    /**
+     *
+     */
+    public void setSkuid(String skuid) {
+        this.skuid = skuid;
+    }
+
+    /**
+     * 主表id
+     */
+    public String getXbMessageId() {
+        return xbMessageId;
+    }
+
+    /**
+     * 主表id
+     */
+    public void setXbMessageId(String xbMessageId) {
+        this.xbMessageId = xbMessageId;
+    }
+
+    /**
+     * jd_union_open_goods_query_responce.queryResult的完整JSON
+     */
+    public String getJsonQueryResult() {
+        return jsonQueryResult;
+    }
+
+    /**
+     * jd_union_open_goods_query_responce.queryResult的完整JSON
+     */
+    public void setJsonQueryResult(String jsonQueryResult) {
+        this.jsonQueryResult = jsonQueryResult;
+    }
+
+    /**
+     * couponInfo.couponList
+     */
+    public String getJsonCouponList() {
+        return jsonCouponList;
+    }
+
+    /**
+     * couponInfo.couponList
+     */
+    public void setJsonCouponList(String jsonCouponList) {
+        this.jsonCouponList = jsonCouponList;
+    }
+
+    /**
+     * spuid
+     */
+    public String getSpuid() {
+        return spuid;
+    }
+
+    /**
+     * spuid
+     */
+    public void setSpuid(String spuid) {
+        this.spuid = spuid;
+    }
+
+    /**
+     * skuName
+     */
+    public String getSkuName() {
+        return skuName;
+    }
+
+    /**
+     * skuName
+     */
+    public void setSkuName(String skuName) {
+        this.skuName = skuName;
+    }
+
+    /**
+     * shopInfo
+     */
+    public String getJsonShopInfo() {
+        return jsonShopInfo;
+    }
+
+    /**
+     * shopInfo
+     */
+    public void setJsonShopInfo(String jsonShopInfo) {
+        this.jsonShopInfo = jsonShopInfo;
+    }
+
+    /**
+     * priceInfo
+     */
+    public String getPriceInfo() {
+        return priceInfo;
+    }
+
+    /**
+     * priceInfo
+     */
+    public void setPriceInfo(String priceInfo) {
+        this.priceInfo = priceInfo;
+    }
+
+    /**
+     * commissionInfo
+     */
+    public String getJsonCommissionInfo() {
+        return jsonCommissionInfo;
+    }
+
+    /**
+     * commissionInfo
+     */
+    public void setJsonCommissionInfo(String jsonCommissionInfo) {
+        this.jsonCommissionInfo = jsonCommissionInfo;
+    }
+
+    /**
+     * imageList
+     */
+    public String getJsonImageList() {
+        return jsonImageList;
+    }
+
+    /**
+     * imageList
+     */
+    public void setJsonImageList(String jsonImageList) {
+        this.jsonImageList = jsonImageList;
+    }
+
+    /**
+     * owner
+     */
+    public String getOwner() {
+        return owner;
+    }
+
+    /**
+     * owner
+     */
+    public void setOwner(String owner) {
+        this.owner = owner;
+    }
+
+    /**
+     * categoryInfo
+     */
+    public String getJsonCategoryInfo() {
+        return jsonCategoryInfo;
+    }
+
+    /**
+     * categoryInfo
+     */
+    public void setJsonCategoryInfo(String jsonCategoryInfo) {
+        this.jsonCategoryInfo = jsonCategoryInfo;
+    }
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        XbMessageItem other = (XbMessageItem) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCreateDate() == null ? other.getCreateDate() == null : this.getCreateDate().equals(other.getCreateDate()))
+            && (this.getSkuid() == null ? other.getSkuid() == null : this.getSkuid().equals(other.getSkuid()))
+            && (this.getXbMessageId() == null ? other.getXbMessageId() == null : this.getXbMessageId().equals(other.getXbMessageId()))
+            && (this.getJsonQueryResult() == null ? other.getJsonQueryResult() == null : this.getJsonQueryResult().equals(other.getJsonQueryResult()))
+            && (this.getJsonCouponList() == null ? other.getJsonCouponList() == null : this.getJsonCouponList().equals(other.getJsonCouponList()))
+            && (this.getSpuid() == null ? other.getSpuid() == null : this.getSpuid().equals(other.getSpuid()))
+            && (this.getSkuName() == null ? other.getSkuName() == null : this.getSkuName().equals(other.getSkuName()))
+            && (this.getJsonShopInfo() == null ? other.getJsonShopInfo() == null : this.getJsonShopInfo().equals(other.getJsonShopInfo()))
+            && (this.getPriceInfo() == null ? other.getPriceInfo() == null : this.getPriceInfo().equals(other.getPriceInfo()))
+            && (this.getJsonCommissionInfo() == null ? other.getJsonCommissionInfo() == null : this.getJsonCommissionInfo().equals(other.getJsonCommissionInfo()))
+            && (this.getJsonImageList() == null ? other.getJsonImageList() == null : this.getJsonImageList().equals(other.getJsonImageList()))
+            && (this.getOwner() == null ? other.getOwner() == null : this.getOwner().equals(other.getOwner()))
+            && (this.getJsonCategoryInfo() == null ? other.getJsonCategoryInfo() == null : this.getJsonCategoryInfo().equals(other.getJsonCategoryInfo()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCreateDate() == null) ? 0 : getCreateDate().hashCode());
+        result = prime * result + ((getSkuid() == null) ? 0 : getSkuid().hashCode());
+        result = prime * result + ((getXbMessageId() == null) ? 0 : getXbMessageId().hashCode());
+        result = prime * result + ((getJsonQueryResult() == null) ? 0 : getJsonQueryResult().hashCode());
+        result = prime * result + ((getJsonCouponList() == null) ? 0 : getJsonCouponList().hashCode());
+        result = prime * result + ((getSpuid() == null) ? 0 : getSpuid().hashCode());
+        result = prime * result + ((getSkuName() == null) ? 0 : getSkuName().hashCode());
+        result = prime * result + ((getJsonShopInfo() == null) ? 0 : getJsonShopInfo().hashCode());
+        result = prime * result + ((getPriceInfo() == null) ? 0 : getPriceInfo().hashCode());
+        result = prime * result + ((getJsonCommissionInfo() == null) ? 0 : getJsonCommissionInfo().hashCode());
+        result = prime * result + ((getJsonImageList() == null) ? 0 : getJsonImageList().hashCode());
+        result = prime * result + ((getOwner() == null) ? 0 : getOwner().hashCode());
+        result = prime * result + ((getJsonCategoryInfo() == null) ? 0 : getJsonCategoryInfo().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", createDate=").append(createDate);
+        sb.append(", skuid=").append(skuid);
+        sb.append(", xbMessageId=").append(xbMessageId);
+        sb.append(", jsonQueryResult=").append(jsonQueryResult);
+        sb.append(", jsonCouponList=").append(jsonCouponList);
+        sb.append(", spuid=").append(spuid);
+        sb.append(", skuName=").append(skuName);
+        sb.append(", jsonShopInfo=").append(jsonShopInfo);
+        sb.append(", priceInfo=").append(priceInfo);
+        sb.append(", jsonCommissionInfo=").append(jsonCommissionInfo);
+        sb.append(", jsonImageList=").append(jsonImageList);
+        sb.append(", owner=").append(owner);
+        sb.append(", jsonCategoryInfo=").append(jsonCategoryInfo);
+        sb.append("]");
+        return sb.toString();
+    }
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/mapper/XbMessageItemMapper.java

@@ -0,0 +1,60 @@
+package com.ruoyi.jarvis.mapper;
+
+import java.util.List;
+import com.ruoyi.jarvis.domain.XbMessageItem;
+
+/**
+ * 线报消息项Mapper接口
+ *
+ * @author ruoyi
+ */
+public interface XbMessageItemMapper
+{
+    /**
+     * 查询线报消息项
+     *
+     * @param id 线报消息项主键
+     * @return 线报消息项
+     */
+    public XbMessageItem selectXbMessageItemById(Integer id);
+
+    /**
+     * 查询线报消息项列表
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 线报消息项集合
+     */
+    public List<XbMessageItem> selectXbMessageItemList(XbMessageItem xbMessageItem);
+
+    /**
+     * 新增线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    public int insertXbMessageItem(XbMessageItem xbMessageItem);
+
+    /**
+     * 修改线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    public int updateXbMessageItem(XbMessageItem xbMessageItem);
+
+    /**
+     * 删除线报消息项
+     *
+     * @param id 线报消息项主键
+     * @return 结果
+     */
+    public int deleteXbMessageItemById(Integer id);
+
+    /**
+     * 批量删除线报消息项
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteXbMessageItemByIds(Integer[] ids);
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/mapper/XbMessageMapper.java

@@ -0,0 +1,60 @@
+package com.ruoyi.jarvis.mapper;
+
+import java.util.List;
+import com.ruoyi.jarvis.domain.XbMessage;
+
+/**
+ * 线报消息Mapper接口
+ *
+ * @author ruoyi
+ */
+public interface XbMessageMapper
+{
+    /**
+     * 查询线报消息
+     *
+     * @param id 线报消息主键
+     * @return 线报消息
+     */
+    public XbMessage selectXbMessageById(Integer id);
+
+    /**
+     * 查询线报消息列表
+     *
+     * @param xbMessage 线报消息
+     * @return 线报消息集合
+     */
+    public List<XbMessage> selectXbMessageList(XbMessage xbMessage);
+
+    /**
+     * 新增线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    public int insertXbMessage(XbMessage xbMessage);
+
+    /**
+     * 修改线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    public int updateXbMessage(XbMessage xbMessage);
+
+    /**
+     * 删除线报消息
+     *
+     * @param id 线报消息主键
+     * @return 结果
+     */
+    public int deleteXbMessageById(Integer id);
+
+    /**
+     * 批量删除线报消息
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteXbMessageByIds(Integer[] ids);
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/service/IXbMessageItemService.java

@@ -0,0 +1,61 @@
+package com.ruoyi.jarvis.service;
+
+import java.util.List;
+import com.ruoyi.jarvis.domain.XbMessageItem;
+
+/**
+ * 线报消息项Service接口
+ *
+ * @author ruoyi
+ */
+public interface IXbMessageItemService
+{
+    /**
+     * 查询线报消息项
+     *
+     * @param id 线报消息项主键
+     * @return 线报消息项
+     */
+    public XbMessageItem selectXbMessageItemById(Integer id);
+
+    /**
+     * 查询线报消息项列表
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 线报消息项集合
+     */
+    public List<XbMessageItem> selectXbMessageItemList(XbMessageItem xbMessageItem);
+
+    /**
+     * 新增线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    public int insertXbMessageItem(XbMessageItem xbMessageItem);
+
+    /**
+     * 修改线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    public int updateXbMessageItem(XbMessageItem xbMessageItem);
+
+    /**
+     * 批量删除线报消息项
+     *
+     * @param ids 需要删除的线报消息项主键
+     * @return 结果
+     */
+    public int deleteXbMessageItemByIds(Integer[] ids);
+
+    /**
+     * 删除线报消息项信息
+     *
+     * @param id 线报消息项主键
+     * @return 结果
+     */
+    public int deleteXbMessageItemById(Integer id);
+
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/service/IXbMessageService.java

@@ -0,0 +1,60 @@
+package com.ruoyi.jarvis.service;
+
+import java.util.List;
+import com.ruoyi.jarvis.domain.XbMessage;
+
+/**
+ * 线报消息Service接口
+ *
+ * @author ruoyi
+ */
+public interface IXbMessageService
+{
+    /**
+     * 查询线报消息
+     *
+     * @param id 线报消息主键
+     * @return 线报消息
+     */
+    public XbMessage selectXbMessageById(Integer id);
+
+    /**
+     * 查询线报消息列表
+     *
+     * @param xbMessage 线报消息
+     * @return 线报消息集合
+     */
+    public List<XbMessage> selectXbMessageList(XbMessage xbMessage);
+
+    /**
+     * 新增线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    public int insertXbMessage(XbMessage xbMessage);
+
+    /**
+     * 修改线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    public int updateXbMessage(XbMessage xbMessage);
+
+    /**
+     * 批量删除线报消息
+     *
+     * @param ids 需要删除的线报消息主键
+     * @return 结果
+     */
+    public int deleteXbMessageByIds(Integer[] ids);
+
+    /**
+     * 删除线报消息信息
+     *
+     * @param id 线报消息主键
+     * @return 结果
+     */
+    public int deleteXbMessageById(Integer id);
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/XbMessageItemServiceImpl.java

@@ -0,0 +1,94 @@
+package com.ruoyi.jarvis.service.impl;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.ruoyi.jarvis.mapper.XbMessageItemMapper;
+import com.ruoyi.jarvis.domain.XbMessageItem;
+import com.ruoyi.jarvis.service.IXbMessageItemService;
+
+/**
+ * 线报消息项Service业务层处理
+ *
+ * @author ruoyi
+ */
+@Service
+public class XbMessageItemServiceImpl implements IXbMessageItemService
+{
+    @Autowired
+    private XbMessageItemMapper xbMessageItemMapper;
+
+    /**
+     * 查询线报消息项
+     *
+     * @param id 线报消息项主键
+     * @return 线报消息项
+     */
+    @Override
+    public XbMessageItem selectXbMessageItemById(Integer id)
+    {
+        return xbMessageItemMapper.selectXbMessageItemById(id);
+    }
+
+    /**
+     * 查询线报消息项列表
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 线报消息项
+     */
+    @Override
+    public List<XbMessageItem> selectXbMessageItemList(XbMessageItem xbMessageItem)
+    {
+        return xbMessageItemMapper.selectXbMessageItemList(xbMessageItem);
+    }
+
+    /**
+     * 新增线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    @Override
+    public int insertXbMessageItem(XbMessageItem xbMessageItem)
+    {
+        return xbMessageItemMapper.insertXbMessageItem(xbMessageItem);
+    }
+
+    /**
+     * 修改线报消息项
+     *
+     * @param xbMessageItem 线报消息项
+     * @return 结果
+     */
+    @Override
+    public int updateXbMessageItem(XbMessageItem xbMessageItem)
+    {
+        return xbMessageItemMapper.updateXbMessageItem(xbMessageItem);
+    }
+
+    /**
+     * 批量删除线报消息项
+     *
+     * @param ids 需要删除的线报消息项主键
+     * @return 结果
+     */
+    @Override
+    public int deleteXbMessageItemByIds(Integer[] ids)
+    {
+        return xbMessageItemMapper.deleteXbMessageItemByIds(ids);
+    }
+
+    /**
+     * 删除线报消息项信息
+     *
+     * @param id 线报消息项主键
+     * @return 结果
+     */
+    @Override
+    public int deleteXbMessageItemById(Integer id)
+    {
+        return xbMessageItemMapper.deleteXbMessageItemById(id);
+    }
+
+
+}

ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/XbMessageServiceImpl.java

@@ -0,0 +1,92 @@
+package com.ruoyi.jarvis.service.impl;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.ruoyi.jarvis.mapper.XbMessageMapper;
+import com.ruoyi.jarvis.domain.XbMessage;
+import com.ruoyi.jarvis.service.IXbMessageService;
+
+/**
+ * 线报消息Service业务层处理
+ *
+ * @author ruoyi
+ */
+@Service
+public class XbMessageServiceImpl implements IXbMessageService
+{
+    @Autowired
+    private XbMessageMapper xbMessageMapper;
+
+    /**
+     * 查询线报消息
+     *
+     * @param id 线报消息主键
+     * @return 线报消息
+     */
+    @Override
+    public XbMessage selectXbMessageById(Integer id)
+    {
+        return xbMessageMapper.selectXbMessageById(id);
+    }
+
+    /**
+     * 查询线报消息列表
+     *
+     * @param xbMessage 线报消息
+     * @return 线报消息
+     */
+    @Override
+    public List<XbMessage> selectXbMessageList(XbMessage xbMessage)
+    {
+        return xbMessageMapper.selectXbMessageList(xbMessage);
+    }
+
+    /**
+     * 新增线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    @Override
+    public int insertXbMessage(XbMessage xbMessage)
+    {
+        return xbMessageMapper.insertXbMessage(xbMessage);
+    }
+
+    /**
+     * 修改线报消息
+     *
+     * @param xbMessage 线报消息
+     * @return 结果
+     */
+    @Override
+    public int updateXbMessage(XbMessage xbMessage)
+    {
+        return xbMessageMapper.updateXbMessage(xbMessage);
+    }
+
+    /**
+     * 批量删除线报消息
+     *
+     * @param ids 需要删除的线报消息主键
+     * @return 结果
+     */
+    @Override
+    public int deleteXbMessageByIds(Integer[] ids)
+    {
+        return xbMessageMapper.deleteXbMessageByIds(ids);
+    }
+
+    /**
+     * 删除线报消息信息
+     *
+     * @param id 线报消息主键
+     * @return 结果
+     */
+    @Override
+    public int deleteXbMessageById(Integer id)
+    {
+        return xbMessageMapper.deleteXbMessageById(id);
+    }
+}

ruoyi-system/src/main/resources/mapper/jarvis/XbMessageItemMapper.xml

@@ -0,0 +1,117 @@
+<?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.ruoyi.jarvis.mapper.XbMessageItemMapper">
+
+    <resultMap type="XbMessageItem" id="XbMessageItemResult">
+        <result property="id" column="id"/>
+        <result property="createDate" column="create_date"/>
+        <result property="skuid" column="skuid"/>
+        <result property="xbMessageId" column="xb_message_id"/>
+        <result property="jsonQueryResult" column="json_query_result"/>
+        <result property="jsonCouponList" column="json_coupon_list"/>
+        <result property="spuid" column="spuid"/>
+        <result property="skuName" column="sku_name"/>
+        <result property="jsonShopInfo" column="json_shop_info"/>
+        <result property="priceInfo" column="price_info"/>
+        <result property="jsonCommissionInfo" column="json_commission_info"/>
+        <result property="jsonImageList" column="json_image_list"/>
+        <result property="owner" column="owner"/>
+        <result property="jsonCategoryInfo" column="json_category_info"/>
+    </resultMap>
+
+    <sql id="selectXbMessageItemVo">
+        select id, create_date, skuid, xb_message_id, json_query_result, json_coupon_list, spuid, sku_name, json_shop_info, price_info, json_commission_info, json_image_list, owner, json_category_info from xb_message_item
+    </sql>
+
+    <select id="selectXbMessageItemList" parameterType="XbMessageItem" resultMap="XbMessageItemResult">
+        <include refid="selectXbMessageItemVo"/>
+        <where>
+            <if test="createDate != null">and create_date = #{createDate}</if>
+            <if test="skuid != null and skuid != ''">and skuid = #{skuid}</if>
+            <if test="xbMessageId != null and xbMessageId != ''">and xb_message_id = #{xbMessageId}</if>
+            <if test="jsonQueryResult != null and jsonQueryResult != ''">and json_query_result = #{jsonQueryResult}</if>
+            <if test="jsonCouponList != null and jsonCouponList != ''">and json_coupon_list = #{jsonCouponList}</if>
+            <if test="spuid != null and spuid != ''">and spuid = #{spuid}</if>
+            <if test="skuName != null and skuName != ''">and sku_name = #{skuName}</if>
+            <if test="jsonShopInfo != null and jsonShopInfo != ''">and json_shop_info = #{jsonShopInfo}</if>
+            <if test="priceInfo != null and priceInfo != ''">and price_info = #{priceInfo}</if>
+            <if test="jsonCommissionInfo != null and jsonCommissionInfo != ''">and json_commission_info = #{jsonCommissionInfo}</if>
+            <if test="jsonImageList != null and jsonImageList != ''">and json_image_list = #{jsonImageList}</if>
+            <if test="owner != null and owner != ''">and owner = #{owner}</if>
+            <if test="jsonCategoryInfo != null and jsonCategoryInfo != ''">and json_category_info = #{jsonCategoryInfo}</if>
+        </where>
+    </select>
+
+    <select id="selectXbMessageItemById" parameterType="Integer" resultMap="XbMessageItemResult">
+        <include refid="selectXbMessageItemVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertXbMessageItem" parameterType="XbMessageItem" useGeneratedKeys="true" keyProperty="id">
+        insert into xb_message_item
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="createDate != null">create_date,</if>
+            <if test="skuid != null and skuid != ''">skuid,</if>
+            <if test="xbMessageId != null and xbMessageId != ''">xb_message_id,</if>
+            <if test="jsonQueryResult != null and jsonQueryResult != ''">json_query_result,</if>
+            <if test="jsonCouponList != null and jsonCouponList != ''">json_coupon_list,</if>
+            <if test="spuid != null and spuid != ''">spuid,</if>
+            <if test="skuName != null and skuName != ''">sku_name,</if>
+            <if test="jsonShopInfo != null and jsonShopInfo != ''">json_shop_info,</if>
+            <if test="priceInfo != null and priceInfo != ''">price_info,</if>
+            <if test="jsonCommissionInfo != null and jsonCommissionInfo != ''">json_commission_info,</if>
+            <if test="jsonImageList != null and jsonImageList != ''">json_image_list,</if>
+            <if test="owner != null and owner != ''">owner,</if>
+            <if test="jsonCategoryInfo != null and jsonCategoryInfo != ''">json_category_info,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="createDate != null">#{createDate},</if>
+            <if test="skuid != null and skuid != ''">#{skuid},</if>
+            <if test="xbMessageId != null and xbMessageId != ''">#{xbMessageId},</if>
+            <if test="jsonQueryResult != null and jsonQueryResult != ''">#{jsonQueryResult},</if>
+            <if test="jsonCouponList != null and jsonCouponList != ''">#{jsonCouponList},</if>
+            <if test="spuid != null and spuid != ''">#{spuid},</if>
+            <if test="skuName != null and skuName != ''">#{skuName},</if>
+            <if test="jsonShopInfo != null and jsonShopInfo != ''">#{jsonShopInfo},</if>
+            <if test="priceInfo != null and priceInfo != ''">#{priceInfo},</if>
+            <if test="jsonCommissionInfo != null and jsonCommissionInfo != ''">#{jsonCommissionInfo},</if>
+            <if test="jsonImageList != null and jsonImageList != ''">#{jsonImageList},</if>
+            <if test="owner != null and owner != ''">#{owner},</if>
+            <if test="jsonCategoryInfo != null and jsonCategoryInfo != ''">#{jsonCategoryInfo},</if>
+        </trim>
+    </insert>
+
+    <update id="updateXbMessageItem" parameterType="XbMessageItem">
+        update xb_message_item
+        <set>
+            <if test="createDate != null">create_date = #{createDate},</if>
+            <if test="skuid != null and skuid != ''">skuid = #{skuid},</if>
+            <if test="xbMessageId != null and xbMessageId != ''">xb_message_id = #{xbMessageId},</if>
+            <if test="jsonQueryResult != null and jsonQueryResult != ''">json_query_result = #{jsonQueryResult},</if>
+            <if test="jsonCouponList != null and jsonCouponList != ''">json_coupon_list = #{jsonCouponList},</if>
+            <if test="spuid != null and spuid != ''">spuid = #{spuid},</if>
+            <if test="skuName != null and skuName != ''">sku_name = #{skuName},</if>
+            <if test="jsonShopInfo != null and jsonShopInfo != ''">json_shop_info = #{jsonShopInfo},</if>
+            <if test="priceInfo != null and priceInfo != ''">price_info = #{priceInfo},</if>
+            <if test="jsonCommissionInfo != null and jsonCommissionInfo != ''">json_commission_info = #{jsonCommissionInfo},</if>
+            <if test="jsonImageList != null and jsonImageList != ''">json_image_list = #{jsonImageList},</if>
+            <if test="owner != null and owner != ''">owner = #{owner},</if>
+            <if test="jsonCategoryInfo != null and jsonCategoryInfo != ''">json_category_info = #{jsonCategoryInfo},</if>
+        </set>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteXbMessageItemById" parameterType="Integer">
+        delete from xb_message_item where id = #{id}
+    </delete>
+
+    <delete id="deleteXbMessageItemByIds" parameterType="String">
+        delete from xb_message_item where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+</mapper>

ruoyi-system/src/main/resources/mapper/jarvis/XbMessageMapper.xml

@@ -0,0 +1,88 @@
+<?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.ruoyi.jarvis.mapper.XbMessageMapper">
+
+    <resultMap type="XbMessage" id="XbMessageResult">
+        <result property="id" column="id"/>
+        <result property="createDate" column="create_date"/>
+        <result property="skuid" column="skuid"/>
+        <result property="tipOriginalMessage" column="tip_original_message"/>
+        <result property="fromWxid" column="from_wxid"/>
+        <result property="firstLine" column="first_line"/>
+        <result property="firstSkuName" column="first_sku_name"/>
+        <result property="firstPrice" column="first_price"/>
+    </resultMap>
+
+    <sql id="selectXbMessageVo">
+        select id, create_date, skuid, tip_original_message, from_wxid, first_line, first_sku_name, first_price from xb_message
+    </sql>
+
+    <select id="selectXbMessageList" parameterType="XbMessage" resultMap="XbMessageResult">
+        <include refid="selectXbMessageVo"/>
+        <where>
+            <if test="createDate != null">and create_date = #{createDate}</if>
+            <if test="skuid != null and skuid != ''">and skuid = #{skuid}</if>
+            <if test="tipOriginalMessage != null and tipOriginalMessage != ''">and tip_original_message = #{tipOriginalMessage}</if>
+            <if test="fromWxid != null and fromWxid != ''">and from_wxid = #{fromWxid}</if>
+            <if test="firstLine != null and firstLine != ''">and first_line = #{firstLine}</if>
+            <if test="firstSkuName != null and firstSkuName != ''">and first_sku_name = #{firstSkuName}</if>
+            <if test="firstPrice != null">and first_price = #{firstPrice}</if>
+        </where>
+        order by create_date desc
+    </select>
+
+    <select id="selectXbMessageById" parameterType="Integer" resultMap="XbMessageResult">
+        <include refid="selectXbMessageVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertXbMessage" parameterType="XbMessage" useGeneratedKeys="true" keyProperty="id">
+        insert into xb_message
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="createDate != null">create_date,</if>
+            <if test="skuid != null and skuid != ''">skuid,</if>
+            <if test="tipOriginalMessage != null and tipOriginalMessage != ''">tip_original_message,</if>
+            <if test="fromWxid != null and fromWxid != ''">from_wxid,</if>
+            <if test="firstLine != null and firstLine != ''">first_line,</if>
+            <if test="firstSkuName != null and firstSkuName != ''">first_sku_name,</if>
+            <if test="firstPrice != null">first_price,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="createDate != null">#{createDate},</if>
+            <if test="skuid != null and skuid != ''">#{skuid},</if>
+            <if test="tipOriginalMessage != null and tipOriginalMessage != ''">#{tipOriginalMessage},</if>
+            <if test="fromWxid != null and fromWxid != ''">#{fromWxid},</if>
+            <if test="firstLine != null and firstLine != ''">#{firstLine},</if>
+            <if test="firstSkuName != null and firstSkuName != ''">#{firstSkuName},</if>
+            <if test="firstPrice != null">#{firstPrice},</if>
+        </trim>
+    </insert>
+
+    <update id="updateXbMessage" parameterType="XbMessage">
+        update xb_message
+        <set>
+            <if test="createDate != null">create_date = #{createDate},</if>
+            <if test="skuid != null and skuid != ''">skuid = #{skuid},</if>
+            <if test="tipOriginalMessage != null and tipOriginalMessage != ''">tip_original_message = #{tipOriginalMessage},</if>
+            <if test="fromWxid != null and fromWxid != ''">from_wxid = #{fromWxid},</if>
+            <if test="firstLine != null and firstLine != ''">first_line = #{firstLine},</if>
+            <if test="firstSkuName != null and firstSkuName != ''">first_sku_name = #{firstSkuName},</if>
+            <if test="firstPrice != null">first_price = #{firstPrice},</if>
+        </set>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteXbMessageById" parameterType="Integer">
+        delete from xb_message where id = #{id}
+    </delete>
+
+    <delete id="deleteXbMessageByIds" parameterType="String">
+        delete from xb_message where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+</mapper>