Commit 592fc817 by liyanlin

修复dc_semi_daily_stock表唯一键冲突的问题

parent 9bd94162
...@@ -15,5 +15,5 @@ import java.util.List; ...@@ -15,5 +15,5 @@ import java.util.List;
*/ */
public interface IDcBaseFinanceEbayService extends IService<DcBaseFinanceEbay> { public interface IDcBaseFinanceEbayService extends IService<DcBaseFinanceEbay> {
void BatchInsertIgnoreExist(List<DcBaseFinanceEbay> list); void InsertAllIgnoreExist(List<DcBaseFinanceEbay> list);
} }
...@@ -24,7 +24,7 @@ public class DcBaseFinanceEbayServiceImpl extends ServiceImpl<DcBaseFinanceEbayM ...@@ -24,7 +24,7 @@ public class DcBaseFinanceEbayServiceImpl extends ServiceImpl<DcBaseFinanceEbayM
private DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper; private DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper;
@Override @Override
public void BatchInsertIgnoreExist(List<DcBaseFinanceEbay> list) { public void InsertAllIgnoreExist(List<DcBaseFinanceEbay> list) {
dcBaseFinanceEbayMapper.BatchInsertIgnoreExist(list); dcBaseFinanceEbayMapper.BatchInsertIgnoreExist(list);
} }
} }
...@@ -20,7 +20,7 @@ import java.util.Date; ...@@ -20,7 +20,7 @@ import java.util.Date;
*/ */
public interface DcSemiDailyStockMapper extends BaseMapper<DcSemiDailyStock> { public interface DcSemiDailyStockMapper extends BaseMapper<DcSemiDailyStock> {
@Insert("insert into dc_semi_daily_stock(day,inventory_amount,sku_code,sku_name,stock_quantity,price,warehouse_id,warehouse_name,redundancy_stock) " + @Insert("insert ignore into dc_semi_daily_stock(day,inventory_amount,sku_code,sku_name,stock_quantity,price,warehouse_id,warehouse_name,redundancy_stock) " +
"select #{lastDay},l.final_stock * ifnull(ol.price,0),l.sku_code,l.sku_name,l.final_stock,ifnull(ol.price,0),l.warehouse_id,l.warehouse_name," + "select #{lastDay},l.final_stock * ifnull(ol.price,0),l.sku_code,l.sku_name,l.final_stock,ifnull(ol.price,0),l.warehouse_id,l.warehouse_name," +
"case when l.redundancy_stock is null then 0 when l.redundancy_stock < 0 then 0 else l.redundancy_stock end " + "case when l.redundancy_stock is null then 0 when l.redundancy_stock < 0 then 0 else l.redundancy_stock end " +
"from dc_semi_stock_log l left join dc_semi_supplier_offer_log ol on l.sku_code = ol.sku_code") "from dc_semi_stock_log l left join dc_semi_supplier_offer_log ol on l.sku_code = ol.sku_code")
......
...@@ -39,6 +39,6 @@ public class EbayFinanceWriter implements ItemWriter<DcBaseFinanceEbay> { ...@@ -39,6 +39,6 @@ public class EbayFinanceWriter implements ItemWriter<DcBaseFinanceEbay> {
Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(DcBaseFinanceEbay::getRefNumber))) Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(DcBaseFinanceEbay::getRefNumber)))
, ArrayList::new) , ArrayList::new)
); );
dcBaseFinanceEbayService.BatchInsertIgnoreExist(list); dcBaseFinanceEbayService.InsertAllIgnoreExist(list);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment