diff --git a/box-bps/src/main/java/com/ruoyi/bps/mapper/ExpressInfoMapper.java b/box-bps/src/main/java/com/ruoyi/bps/mapper/ExpressInfoMapper.java index 9abb35afb..0d8fcd6a5 100644 --- a/box-bps/src/main/java/com/ruoyi/bps/mapper/ExpressInfoMapper.java +++ b/box-bps/src/main/java/com/ruoyi/bps/mapper/ExpressInfoMapper.java @@ -48,7 +48,7 @@ public interface ExpressInfoMapper /** * 删除快递信息 - * + * * @param message 快递信息ID * @return 结果 */ @@ -69,4 +69,14 @@ public interface ExpressInfoMapper * @return 结果 */ public int batchInsertExpressInfo(List expressInfoList); + + + /** + * 删除快递信息 + * + * @param queryId 快递信息queryId + * @return 结果 + */ + public int deleteExpressInfoByQueryId(String queryId); + } diff --git a/box-bps/src/main/java/com/ruoyi/bps/service/impl/ExpImportQueryServiceImpl.java b/box-bps/src/main/java/com/ruoyi/bps/service/impl/ExpImportQueryServiceImpl.java index 7ab9b07e7..c3f4e28a7 100644 --- a/box-bps/src/main/java/com/ruoyi/bps/service/impl/ExpImportQueryServiceImpl.java +++ b/box-bps/src/main/java/com/ruoyi/bps/service/impl/ExpImportQueryServiceImpl.java @@ -10,11 +10,13 @@ import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.text.Convert; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.ShiroUtils; +import com.ruoyi.common.utils.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; /** @@ -92,6 +94,10 @@ public class ExpImportQueryServiceImpl implements IExpImportQueryService @Override public int deleteExpImportQueryByIds(String ids) { + for(String str:Arrays.asList(ids.split(","))) + { + expressInfoMapper.deleteExpressInfoByQueryId(str); + } return expImportQueryMapper.deleteExpImportQueryByIds(Convert.toStrArray(ids)); } @@ -130,8 +136,19 @@ public class ExpImportQueryServiceImpl implements IExpImportQueryService ei.setQueryTime(queryTime); //expressInfoService.insertExpressInfo(ei); expressInfoListForInsert.add(ei); + /* for(int i=1;i<1001;i++){ //测试批量插入效率用时打开Mark,产生5万条数据。 + expressInfoListForInsert.add(ei); + }*/ + } + int size= expressInfoListForInsert.size(); + List expressInfos= new ArrayList<>(); + for(int i=1;i<=size;i++){ + expressInfos.add(expressInfoListForInsert.get(i-1)); + if( (i%400==0 ) ||i== size) { + expressInfoMapper.batchInsertExpressInfo(expressInfos); + expressInfos.clear(); + } } - expressInfoMapper.batchInsertExpressInfo(expressInfoListForInsert); //将本次excel导入查询记录到数据表exp_import_query expImportQuery.setQueryTime(queryTime); expImportQuery.setQueryLoginName(ShiroUtils.getLoginName()); diff --git a/box-bps/src/main/resources/mapper/bps/ExpressInfoMapper.xml b/box-bps/src/main/resources/mapper/bps/ExpressInfoMapper.xml index 5f01579ef..5d9416346 100644 --- a/box-bps/src/main/resources/mapper/bps/ExpressInfoMapper.xml +++ b/box-bps/src/main/resources/mapper/bps/ExpressInfoMapper.xml @@ -130,8 +130,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - delete from expressInfo where message in - + delete from expressInfo where sid in + #{sid} @@ -148,4 +148,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + + delete from expressInfo where queryId in (select queryId from exp_import_query where sid= #{sid}) + + + \ No newline at end of file