Enhance surcharge management by adding support for price type filtering in SurchargeController and related services. Introduce new methods for handling redline product codes in mappers and services. Update front-end API to accommodate price type parameters in surcharge queries. Modify database schema to include redline product and country tables for improved surcharge calculations.

2026-10-09 17:30:29 +08:00
parent 380577f691
commit f1f6ddd368
34 changed files with 5196 additions and 30 deletions
@@ -0,0 +1,46 @@
+package com.bms.price.domain;
+
+import java.util.Date;
+import java.util.List;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.bms.common.core.domain.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/** Redline catalog main table redline_product */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class BmsRedlineProduct extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    private Long productId;
+    private String productCode;
+    private String productName;
+    private String serviceLevel;
+    private String cargoAttr;
+    private String destRegion;
+    private String updateNote;
+    /** TAX_INCLUDED / TAX_EXCLUDED */
+    private String taxMode;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date effectiveDate;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date expireDate;
+    /** 0 pending, 1 active, 2 expired */
+    public static final String STATUS_PENDING = "0";
+    public static final String STATUS_ACTIVE = "1";
+    public static final String STATUS_EXPIRED = "2";
+    private String status;
+    private String sourceSheet;
+    /** FK prc_price_excel_file.pef_id */
+    private Long pefId;
+    private Long tmsId;
+    private Integer countryCount;
+    private Integer surchargeCount;
+    private List<BmsRedlineProductCountry> countries;
+    /** query alias of status (0/1/2) */
+    private String effectStatus;
+    /** query: active = status in (0,1); expired = status 2 */
+    private String statusGroup;
+}
@@ -0,0 +1,49 @@
+package com.bms.price.domain;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+/** Redline country detail table redline_product_country */
+@Data
+public class BmsRedlineProductCountry implements Serializable
+{
+    private static final long serialVersionUID = 1L;
+
+    private Long detailId;
+    /** FK to product.product_id */
+    private Long productId;
+    private String productCode;
+    private String countryName;
+    private String countryCode;
+    /** prc_zone.zone_id; null when product country has no zone */
+    private Long zoneId;
+    /** e.g. Z1; null when no zone */
+    private String zoneCode;
+    /** e.g. Australia(Z1); null when no zone */
+    private String zoneName;
+    private BigDecimal weightMin;
+    private BigDecimal weightMax;
+    private BigDecimal freightPrice;
+    private BigDecimal registrationFee;
+    private String sizeLimit;
+    private String lastMile;
+    private String leadTime;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date effectiveDate;
+    /** null=open; closed to next import effective_date */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date expireDate;
+    /** 0 pending, 1 active, 2 expired */
+    private String status;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date updateTime;
+    /** query only: true = expire_date is null */
+    private Boolean openOnly;
+    /** query alias of status (0/1/2) */
+    private String effectStatus;
+}
@@ -0,0 +1,72 @@
+package com.bms.price.domain;
+
+import java.io.Serializable;
+
+/**
+ * Async product Excel import progress (Redis).
+ */
+public class BmsRedlineProductImportTask implements Serializable
+{
+    private static final long serialVersionUID = 1L;
+
+    public static final String STATUS_PENDING = "PENDING";
+    public static final String STATUS_RUNNING = "RUNNING";
+    public static final String STATUS_SUCCESS = "SUCCESS";
+    public static final String STATUS_FAIL = "FAIL";
+
+    private String taskId;
+    private String status;
+    private int percent;
+    private String message;
+    private String error;
+
+    public String getTaskId()
+    {
+        return taskId;
+    }
+
+    public void setTaskId(String taskId)
+    {
+        this.taskId = taskId;
+    }
+
+    public String getStatus()
+    {
+        return status;
+    }
+
+    public void setStatus(String status)
+    {
+        this.status = status;
+    }
+
+    public int getPercent()
+    {
+        return percent;
+    }
+
+    public void setPercent(int percent)
+    {
+        this.percent = percent;
+    }
+
+    public String getMessage()
+    {
+        return message;
+    }
+
+    public void setMessage(String message)
+    {
+        this.message = message;
+    }
+
+    public String getError()
+    {
+        return error;
+    }
+
+    public void setError(String error)
+    {
+        this.error = error;
+    }
+}
@@ -58,8 +58,10 @@ public class TmsPriceQuoteResult implements Serializable
    private BigDecimal surchargeAmount;
    /** product catalog total: base freight*weight + base registration (no package surcharge) */
    private BigDecimal productAmount;
-    /** redline total reserved */
+    /** redline total from redline_product_country (+ REDLINE surcharges) */
    private BigDecimal redlineAmount;
+    /** matched redline_product_country.detail_id for REDLINE surcharge scope */
+    private Long redlineCountryId;
    /** cost total (currently = product catalog amount) */
    private BigDecimal costAmount;
    /** receivable total (order bill) */
@@ -0,0 +1,99 @@
+package com.bms.price.mapper;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+import com.bms.price.domain.BmsRedlineProductCountry;
+
+/**
+ * 红线价国家明细 数据层
+ *
+ * @author bms
+ */
+public interface BmsRedlineProductCountryMapper
+{
+    public List<BmsRedlineProductCountry> selectBmsRedlineProductCountryList(BmsRedlineProductCountry country);
+
+    public int insertBmsRedlineProductCountry(BmsRedlineProductCountry country);
+
+    /** 按明细行主键更新可编辑字段（重量段/运费/挂号费/尺寸/尾程/时效/生效失效日期） */
+    public int updateBmsRedlineProductCountry(BmsRedlineProductCountry country);
+
+    /** Import overlay: update price/zone/attrs on matched country row */
+    public int updateBmsRedlineProductCountryImport(BmsRedlineProductCountry country);
+
+    public int deleteByProductId(Long productId);
+
+    public int deleteByProductCode(String productCode);
+
+    public int deleteByProductCodeAndEffectiveDate(
+        @Param("productCode") String productCode,
+        @Param("effectiveDate") Date effectiveDate);
+
+    /** Max open (expire_date is null) effective_date for product */
+    public Date selectMaxOpenEffectiveDate(@Param("productCode") String productCode);
+
+    /** Close open versions: set expire_date = newEffectiveDate where effective_date &lt; newEffectiveDate */
+    public int expireOpenByProductCode(
+        @Param("productCode") String productCode,
+        @Param("newEffectiveDate") Date newEffectiveDate);
+
+    /**
+     * Close open rows for one product + country where effective_date &lt; newEffectiveDate.
+     * Match by country_code when present, otherwise country_name.
+     */
+    public int expireOpenByProductCodeAndCountry(
+        @Param("productCode") String productCode,
+        @Param("countryCode") String countryCode,
+        @Param("countryName") String countryName,
+        @Param("newEffectiveDate") Date newEffectiveDate);
+
+    /** Recompute status from effective_date / expire_date vs today */
+    public int refreshStatusByDates();
+
+    /** Replace same-day version only */
+    public int deleteOpenByProductCodeAndEffectiveDate(
+        @Param("productCode") String productCode,
+        @Param("effectiveDate") Date effectiveDate);
+
+    /**
+     * Delete open rows for one product + country on a given effective_date (same-day replace).
+     * Needed because unique key keeps expired same-day weight bands.
+     */
+    public int deleteOpenByProductCodeAndCountryOnDate(
+        @Param("productCode") String productCode,
+        @Param("countryCode") String countryCode,
+        @Param("countryName") String countryName,
+        @Param("effectiveDate") Date effectiveDate);
+
+    /** Open country rows (expire_date is null) for product */
+    public List<BmsRedlineProductCountry> selectOpenByProductCode(@Param("productCode") String productCode);
+
+    /** Copy previously open rows into a new effective_date (caller must expire first) */
+    public int copyOpenCountries(
+        @Param("productCode") String productCode,
+        @Param("productId") Long productId,
+        @Param("effectiveDate") Date effectiveDate,
+        @Param("status") String status);
+
+    /**
+     * Match by product + country + weight + bizDate (+ optional zoneCode).
+     * When zoneCode is empty, prefer rows without zone.
+     * When zoneCode is set, require matching zone_code.
+     */
+    public BmsRedlineProductCountry selectMatchByProductCountryWeight(
+        @Param("productCode") String productCode,
+        @Param("countryCode") String countryCode,
+        @Param("countryName") String countryName,
+        @Param("zoneCode") String zoneCode,
+        @Param("weight") BigDecimal weight,
+        @Param("bizDate") Date bizDate);
+
+    /** Count product-country rows that have a zone for this product+country+bizDate */
+    public int countZonedByProductCountry(
+        @Param("productCode") String productCode,
+        @Param("countryCode") String countryCode,
+        @Param("countryName") String countryName,
+        @Param("bizDate") Date bizDate);
+}
@@ -0,0 +1,44 @@
+package com.bms.price.mapper;
+
+import java.util.Date;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+import com.bms.price.domain.BmsRedlineProduct;
+
+/**
+ * 产品主表 数据层
+ *
+ * @author bms
+ */
+public interface BmsRedlineProductMapper
+{
+    public BmsRedlineProduct selectBmsRedlineProductById(Long productId);
+
+    /** Latest row by product_code (effective_date desc) */
+    public BmsRedlineProduct selectBmsRedlineProductByCode(String productCode);
+
+    /** Unique business key: product_code + effective_date */
+    public BmsRedlineProduct selectBmsRedlineProductByCodeAndDate(@Param("productCode") String productCode,
+        @Param("effectiveDate") Date effectiveDate);
+
+    /** Product version effective on bizDate */
+    public BmsRedlineProduct selectEffectiveBmsRedlineProductByCode(@Param("productCode") String productCode,
+        @Param("bizDate") Date bizDate);
+
+    public List<BmsRedlineProduct> selectBmsRedlineProductList(BmsRedlineProduct product);
+
+    public int insertBmsRedlineProduct(BmsRedlineProduct product);
+
+    public int updateBmsRedlineProduct(BmsRedlineProduct product);
+
+    public int deleteBmsRedlineProductByIds(Long[] productIds);
+
+    /** Close previous open versions: expire_date = newEffectiveDate */
+    public int expireOpenByProductCode(
+        @Param("productCode") String productCode,
+        @Param("newEffectiveDate") Date newEffectiveDate,
+        @Param("excludeId") Long excludeId);
+
+    /** Recompute status from effective_date / expire_date vs today */
+    public int refreshStatusByDates();
+}
@@ -16,6 +16,8 @@ public interface PrcPriceExcelFileMapper
    /** Distinct PRODUCT excel files linked by product.pef_id for this product_code */
    public List<PrcPriceExcelFile> selectByProductCode(@Param("productCode") String productCode);

+    public List<PrcPriceExcelFile> selectByRedlineProductCode(@Param("productCode") String productCode);
+
    public int insertPrcPriceExcelFile(PrcPriceExcelFile row);

    public int updatePrcPriceExcelFile(PrcPriceExcelFile row);
@@ -0,0 +1,57 @@
+package com.bms.price.service;
+
+import java.util.Date;
+import java.util.List;
+import org.springframework.web.multipart.MultipartFile;
+import com.bms.price.domain.BmsRedlineProduct;
+import com.bms.price.domain.BmsRedlineProductCountry;
+import com.bms.price.domain.BmsRedlineProductImportTask;
+
+/**
+ * redline product list service
+ *
+ * @author bms
+ */
+public interface IBmsRedlineProductService
+{
+    public BmsRedlineProduct selectBmsRedlineProductById(Long productId);
+
+    public List<BmsRedlineProduct> selectBmsRedlineProductList(BmsRedlineProduct product);
+
+    public int insertBmsRedlineProduct(BmsRedlineProduct product);
+
+    public int updateBmsRedlineProduct(BmsRedlineProduct product);
+
+    public int updateBmsRedlineProductCountry(BmsRedlineProductCountry country);
+
+    public int deleteBmsRedlineProductByIds(Long[] productIds);
+
+    public List<BmsRedlineProductCountry> selectCountryListByProductCode(String productCode);
+
+    public List<BmsRedlineProductCountry> selectCountryListByProductCode(String productCode, Date effectiveDate);
+
+    public List<BmsRedlineProductCountry> selectCountryListByProductCode(String productCode, Date effectiveDate, Long productId);
+
+    public String importProductExcel(MultipartFile file, boolean updateSupport, String operName, Date effectiveDate) throws Exception;
+
+    public String importCountryProductExcel(MultipartFile file, String countryCode, String operName, Date effectiveDate) throws Exception;
+
+    /** Submit async all-country import; returns taskId for polling getImportTask. */
+    public String submitImportProductExcelAsync(MultipartFile file, boolean updateSupport, String operName, Date effectiveDate) throws Exception;
+
+    /** Submit async single-country import; returns taskId for polling getImportTask. */
+    public String submitImportCountryProductExcelAsync(MultipartFile file, String countryCode, String operName, Date effectiveDate) throws Exception;
+
+    /** Poll Redis progress for product import task. */
+    public BmsRedlineProductImportTask getImportTask(String taskId);
+
+    /** Sync import from bytes (used by async runner; taskId may be null). */
+    public String importProductExcel(byte[] bytes, String filename, boolean updateSupport, String operName, String taskId, Date effectiveDate) throws Exception;
+
+    /** Sync country import from bytes (used by async runner; taskId may be null). */
+    public String importCountryProductExcel(byte[] bytes, String filename, String countryCode, String operName, String taskId, Date effectiveDate) throws Exception;
+
+    public java.util.Map<String, List<BmsRedlineProductCountry>> parseQuoteExcelByProduct(MultipartFile file) throws Exception;
+
+    public java.util.Map<String, List<BmsRedlineProductCountry>> parseQuoteExcelByProduct(byte[] bytes, String filename) throws Exception;
+}
@@ -14,6 +14,8 @@ public interface IPrcPriceExcelFileService
    /** Import Excel attachments linked to this product_code via product.pef_id */
    public List<PrcPriceExcelFile> selectByProductCode(String productCode);

+    List<PrcPriceExcelFile> selectByRedlineProductCode(String productCode);
+
    /**
     * Persist uploaded Excel under upload/price/excel and insert metadata row.
     *
@@ -13,6 +13,8 @@ public interface IPrcSurchargeRelService
    /** 查询某产品已关联的附加费（含附加费与明细展示字段） */
    public List<PrcSurchargeRel> selectRelByProductCode(String productCode);

+    public List<PrcSurchargeRel> selectRelByProductCode(String productCode, String priceType);
+
    public List<PrcSurchargeRel> selectPrcSurchargeRelList(PrcSurchargeRel rel);

    public int insertPrcSurchargeRel(PrcSurchargeRel rel);
@@ -48,6 +48,17 @@ public class PrcPriceExcelFileServiceImpl implements IPrcPriceExcelFileService
        return list == null ? Collections.emptyList() : list;
    }

+    @Override
+    public List<PrcPriceExcelFile> selectByRedlineProductCode(String productCode)
+    {
+        if (productCode == null || productCode.trim().isEmpty())
+        {
+            return java.util.Collections.emptyList();
+        }
+        List<PrcPriceExcelFile> list = excelFileMapper.selectByRedlineProductCode(productCode.trim());
+        return list == null ? java.util.Collections.emptyList() : list;
+    }
+
    @Override
    public PrcPriceExcelFile saveImportExcel(String excelType, Date effectiveTime, byte[] bytes,
        String filename, String operName) throws Exception
@@ -23,30 +23,20 @@ public class PrcSurchargeRelServiceImpl implements IPrcSurchargeRelService

    @Override
    public List<PrcSurchargeRel> selectRelByProductCode(String productCode)
+    {
+        return selectRelByProductCode(productCode, PrcSurchargeRel.PRICE_TYPE_PRODUCT);
+    }
+
+    @Override
+    public List<PrcSurchargeRel> selectRelByProductCode(String productCode, String priceType)
    {
        PrcSurchargeRel query = new PrcSurchargeRel();
        query.setProductCode(productCode);
-        List<PrcSurchargeRel> list = relMapper.selectPrcSurchargeRelList(query);
-        if (list == null || list.isEmpty())
+        if (StringUtils.isNotEmpty(priceType))
        {
-            return list;
+            query.setPriceType(priceType.trim().toUpperCase());
        }
-        // Product drawer: PRODUCT + REDLINE only (SALES binds psp_id/psd_id)
-        List<PrcSurchargeRel> filtered = new java.util.ArrayList<PrcSurchargeRel>();
-        for (PrcSurchargeRel rel : list)
-        {
-            if (rel == null)
-            {
-                continue;
-            }
-            String type = rel.getPriceType();
-            if (StringUtils.isEmpty(type) || PrcSurchargeRel.PRICE_TYPE_PRODUCT.equals(type)
-                || PrcSurchargeRel.PRICE_TYPE_REDLINE.equals(type))
-            {
-                filtered.add(rel);
-            }
-        }
-        return filtered;
+        return relMapper.selectPrcSurchargeRelList(query);
    }

    @Override
@@ -25,6 +25,7 @@ import com.bms.customer.customerinfo.domain.BmsCustomer;
 import com.bms.customer.customerinfo.mapper.BmsCustomerMapper;
 import com.bms.price.domain.BmsProduct;
 import com.bms.price.domain.BmsProductCountry;
+import com.bms.price.domain.BmsRedlineProductCountry;
 import com.bms.price.domain.PrcCustomerPriceSet;
 import com.bms.price.domain.PrcPriceSet;
 import com.bms.price.domain.PrcPriceSetDetail;
@@ -42,6 +43,7 @@ import com.bms.price.domain.vo.TmsPriceQuoteResult;
 import com.bms.price.enums.BillCustomerActiveStatus;
 import com.bms.price.mapper.BmsProductCountryMapper;
 import com.bms.price.mapper.BmsProductMapper;
+import com.bms.price.mapper.BmsRedlineProductCountryMapper;
 import com.bms.price.mapper.PrcCustomerPriceSetMapper;
 import com.bms.price.mapper.PrcPriceSetDetailMapper;
 import com.bms.price.mapper.PrcPriceSetMapper;
@@ -94,6 +96,9 @@ public class TmsPriceQuoteServiceImpl implements ITmsPriceQuoteService
    @Autowired
    private BmsProductCountryMapper productCountryMapper;

+    @Autowired
+    private BmsRedlineProductCountryMapper redlineProductCountryMapper;
+
    @Autowired
    private BmsProductMapper productMapper;

@@ -874,6 +879,7 @@ public class TmsPriceQuoteServiceImpl implements ITmsPriceQuoteService
        r.setRoundMode(mode);
        r.setFromCache(false);
        fillProductAmountAndPay(r, catalog, weight, rm, mode);
+        fillRedlineAmount(r, weight, rm);
        return r;
    }

@@ -929,6 +935,7 @@ public class TmsPriceQuoteServiceImpl implements ITmsPriceQuoteService
        r.setRoundMode(mode);
        r.setFromCache(false);
        fillProductAmountAndPay(r, base, weight, rm, mode);
+        fillRedlineAmount(r, weight, rm);
        return r;
    }

@@ -961,6 +968,30 @@ public class TmsPriceQuoteServiceImpl implements ITmsPriceQuoteService
        r.setPayFeeDetails(payLines);
    }

+    /**
+     * Redline catalog amount from redline_product_country (same match keys as product catalog).
+     */
+    private void fillRedlineAmount(TmsPriceQuoteResult r, BigDecimal weight, RoundingMode rm)
+    {
+        if (r == null || weight == null || StringUtils.isEmpty(r.getProductCode()))
+        {
+            return;
+        }
+        BmsRedlineProductCountry base = redlineProductCountryMapper.selectMatchByProductCountryWeight(
+            r.getProductCode(), r.getCountryCode(), r.getCountryName(), r.getZoneCode(), weight, null);
+        if (base == null || base.getFreightPrice() == null)
+        {
+            return;
+        }
+        if (base.getDetailId() != null)
+        {
+            r.setRedlineCountryId(base.getDetailId());
+        }
+        BigDecimal baseReg = base.getRegistrationFee() == null ? BigDecimal.ZERO : base.getRegistrationFee();
+        BigDecimal freight = base.getFreightPrice().multiply(weight).setScale(2, rm);
+        r.setRedlineAmount(freight.add(baseReg).setScale(2, rm));
+    }
+
    private void applySurchargesAndFees(TmsPriceQuoteResult result)
    {
        BigDecimal freightAmount = nvl(result.getFreightAmount());
@@ -1140,6 +1171,10 @@ public class TmsPriceQuoteServiceImpl implements ITmsPriceQuoteService
        {
            return true;
        }
+        if (PrcSurchargeRel.PRICE_TYPE_REDLINE.equals(rel.getPriceType()))
+        {
+            return result.getRedlineCountryId() != null && rel.getDetailId().equals(result.getRedlineCountryId());
+        }
        return result.getProductCountryId() != null && rel.getDetailId().equals(result.getProductCountryId());
    }

@@ -0,0 +1,97 @@
+package com.bms.price.task;
+
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import com.bms.common.core.redis.RedisCache;
+import com.bms.common.utils.StringUtils;
+import com.bms.price.domain.BmsRedlineProductImportTask;
+import com.bms.price.service.IBmsRedlineProductService;
+
+/**
+ * Async runner for product Excel import (avoids HTTP timeout on large workbooks).
+ */
+@Component
+public class BmsRedlineProductImportAsyncRunner
+{
+    private static final Logger log = LoggerFactory.getLogger(BmsRedlineProductImportAsyncRunner.class);
+
+    public static final String CACHE_KEY_PREFIX = "price:redline:import:task:";
+    public static final int TTL_MINUTES = 60;
+
+    @Autowired
+    private IBmsRedlineProductService productService;
+
+    @Autowired
+    private RedisCache redisCache;
+
+    /** Background all-country (Weishi catalog) import. */
+    @Async("threadPoolTaskExecutor")
+    public void runImportAll(String taskId, byte[] bytes, String filename, boolean updateSupport, String operName,
+        Date effectiveDate)
+    {
+        try
+        {
+            put(taskId, BmsRedlineProductImportTask.STATUS_RUNNING, 5, "parsing excel", null);
+            String message = productService.importProductExcel(bytes, filename, updateSupport, operName, taskId,
+                effectiveDate);
+            put(taskId, BmsRedlineProductImportTask.STATUS_SUCCESS, 100, message, null);
+            log.info("async product import done, taskId={}", taskId);
+        }
+        catch (Exception e)
+        {
+            log.error("async product import failed, taskId={}", taskId, e);
+            put(taskId, BmsRedlineProductImportTask.STATUS_FAIL, 100, "failed", errorMessage(e));
+        }
+    }
+
+    /** Background single-country cost-sheet import. */
+    @Async("threadPoolTaskExecutor")
+    public void runImportCountry(String taskId, byte[] bytes, String filename, String countryCode, String operName,
+        Date effectiveDate)
+    {
+        try
+        {
+            put(taskId, BmsRedlineProductImportTask.STATUS_RUNNING, 5, "parsing excel", null);
+            String message = productService.importCountryProductExcel(bytes, filename, countryCode, operName, taskId,
+                effectiveDate);
+            put(taskId, BmsRedlineProductImportTask.STATUS_SUCCESS, 100, message, null);
+            log.info("async product country import done, taskId={}, country={}", taskId, countryCode);
+        }
+        catch (Exception e)
+        {
+            log.error("async product country import failed, taskId={}, country={}", taskId, countryCode, e);
+            put(taskId, BmsRedlineProductImportTask.STATUS_FAIL, 100, "failed", errorMessage(e));
+        }
+    }
+
+    public void put(String taskId, String status, int percent, String message, String error)
+    {
+        BmsRedlineProductImportTask task = new BmsRedlineProductImportTask();
+        task.setTaskId(taskId);
+        task.setStatus(status);
+        task.setPercent(percent);
+        task.setMessage(message);
+        task.setError(error);
+        redisCache.setCacheObject(CACHE_KEY_PREFIX + taskId, task, TTL_MINUTES, TimeUnit.MINUTES);
+    }
+
+    public BmsRedlineProductImportTask get(String taskId)
+    {
+        return redisCache.getCacheObject(CACHE_KEY_PREFIX + taskId);
+    }
+
+    private static String errorMessage(Exception e)
+    {
+        String msg = e.getMessage();
+        if (StringUtils.isEmpty(msg))
+        {
+            msg = e.getClass().getSimpleName();
+        }
+        return msg;
+    }
+}