瀏覽代碼

添加导入kuaishou_reward_base_info

zhaoxian 11 月之前
父節點
當前提交
f2c55fdb49

+ 111 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/entity/KuaishouRewardBaseInfo.java

@@ -0,0 +1,111 @@
+package com.ruixuan.isc.entity;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+@Data
+public class KuaishouRewardBaseInfo {
+
+    /**
+     * $column.columnComment
+     */
+    private Long id;
+
+    /**
+     * 商品id
+     */
+    private Long itemId;
+
+    /**
+     * 商品名称
+     */
+    private String itemTitle;
+
+    /**
+     * 达人ID
+     */
+    private Long promoterId;
+
+    /**
+     * 达人名称
+     */
+    private String promoterName;
+
+    /**
+     * 商品创建人ID
+     */
+    private Long itemCreateId;
+
+    /**
+     * 商品创建人姓名
+     */
+    private String itemCreateName;
+
+    /**
+     * 达人创建人ID
+     */
+    private Long promoterCreateId;
+
+    /**
+     * 达人创建人姓名
+     */
+    private String promoterCreateName;
+
+    /**
+     * 日期
+     */
+    private String statDate;
+
+    /**
+     * 当前结算单量
+     */
+    private Long currentSettlementNum;
+
+    /**
+     * 累计结算单量
+     */
+    private Long totalSettlementNum;
+
+    /**
+     * 结算单价
+     */
+    private BigDecimal settlementPrice;
+
+    /**
+     * 主播奖励金额
+     */
+    private BigDecimal anchorAmount;
+
+    /**
+     * 推荐人奖励金额
+     */
+    private BigDecimal referenceAmount;
+
+    /**
+     * 累计结算金额
+     */
+    private BigDecimal totalAmount;
+
+    /**
+     * 备注
+     */
+    private String remarks;
+
+    public KuaishouRewardBaseInfo() {
+    }
+
+    public KuaishouRewardBaseInfo(JSONObject obj) {
+        this.setPromoterId(obj.getLong("0"));//达人ID
+        this.setPromoterName(obj.getString("1"));//达人昵称
+        this.setItemId(obj.getLong("2"));//商品id
+        this.setItemTitle(obj.getString("3"));//商品名称
+        this.setTotalSettlementNum(obj.getLong("4"));//订单总量
+        this.setCurrentSettlementNum(obj.getLong("5"));//已结单量
+        this.setCurrentSettlementNum(obj.getLong("6"));//应结单量
+        this.setSettlementPrice(obj.getBigDecimal("7"));//结算单价
+        this.setAnchorAmount(obj.getBigDecimal("8"));//奖励
+        this.setStatDate(obj.getString("9"));//日期
+    }
+}

+ 20 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/mapper/KuaishouRewardBaseInfoMapper.java

@@ -0,0 +1,20 @@
+package com.ruixuan.isc.mapper;
+
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.ruixuan.isc.entity.KuaishouItemCollectSampleExpress;
+import com.ruixuan.isc.entity.KuaishouItemCollectSampleLog;
+import com.ruixuan.isc.entity.KuaishouItemCollectSamples;
+import com.ruixuan.isc.entity.KuaishouRewardBaseInfo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+
+public interface KuaishouRewardBaseInfoMapper {
+
+    void replaceBatchRewardBaseInfo(@Param("infoList") List<KuaishouRewardBaseInfo> infoList);
+}
+

+ 13 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/IKuaishouRewardBaseInfoService.java

@@ -0,0 +1,13 @@
+package com.ruixuan.isc.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruixuan.common.core.domain.ResultResponse;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+import java.util.Map;
+
+public interface IKuaishouRewardBaseInfoService {
+
+    ResultResponse insertRewardBaseInfoByExcel(MultipartFile file) throws Exception;
+}

+ 46 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouRewardBaseInfoServiceImpl.java

@@ -0,0 +1,46 @@
+package com.ruixuan.isc.service.impl;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruixuan.common.core.domain.ResultResponse;
+import com.ruixuan.common.utils.Check;
+import com.ruixuan.data.utils.LiveDataExcelUtils;
+import com.ruixuan.isc.entity.KuaishouRewardBaseInfo;
+import com.ruixuan.isc.mapper.KuaishouRewardBaseInfoMapper;
+import com.ruixuan.isc.service.IKuaishouRewardBaseInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Service
+public class KuaishouRewardBaseInfoServiceImpl implements IKuaishouRewardBaseInfoService {
+    @Autowired
+    private KuaishouRewardBaseInfoMapper kuaishouRewardBaseInfoMapper;
+
+
+    @Override
+    public ResultResponse insertRewardBaseInfoByExcel(MultipartFile file) throws Exception {
+        String fileName = file.getOriginalFilename();
+        List<JSONObject> list = LiveDataExcelUtils.analysisFile(file, fileName);
+        if (!Check.isNull(list)) {
+            List<KuaishouRewardBaseInfo> infoList = new ArrayList<>();
+            for (JSONObject o : list) {
+                if ("达人ID".equals(o.getString("0"))) {
+                    continue;
+                }
+                KuaishouRewardBaseInfo baseInfo = new KuaishouRewardBaseInfo(o);
+                infoList.add(baseInfo);
+            }
+
+            if (!Check.isNull(infoList)) {
+                kuaishouRewardBaseInfoMapper.replaceBatchRewardBaseInfo(infoList);
+            }
+        }
+        return ResultResponse.success();
+    }
+}
+

+ 43 - 0
ruixuan-live/src/main/resources/mapper/isc/KuaishouRewardBaseInfoMapper.xml

@@ -0,0 +1,43 @@
+<?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.ruixuan.isc.mapper.KuaishouRewardBaseInfoMapper">
+
+    <insert id="replaceBatchRewardBaseInfo">
+        replace into
+        kuaishou_reward_base_info
+        (
+        item_id,
+        item_title,
+        promoter_id,
+        promoter_name,
+        stat_date,
+        current_settlement_num,
+        total_settlement_num,
+        settlement_price,
+        anchor_amount,
+        reference_amount,
+        total_amount,
+        remarks
+        )
+        values
+        <foreach collection="infoList" item="info" separator=",">
+            (
+            #{info.itemId},
+            #{info.itemTitle},
+            #{info.promoterId},
+            #{info.promoterName},
+            #{info.statDate},
+            #{info.currentSettlementNum},
+            #{info.totalSettlementNum},
+            #{info.settlementPrice},
+            #{info.anchorAmount},
+            #{info.referenceAmount},
+            #{info.totalAmount},
+            #{info.remarks}
+            )
+        </foreach>
+    </insert>
+
+</mapper>