数据处理代码

This commit is contained in:
shuo.wang
2025-05-28 10:09:40 +08:00
parent 7b3b7a8aef
commit a5ad26928c
2 changed files with 15 additions and 0 deletions

View File

@@ -219,4 +219,13 @@ public class LineInfoDAO {
List<LineInfoDO> lineMobile = lineInfoMapper.getByLineIds(lineIds); List<LineInfoDO> lineMobile = lineInfoMapper.getByLineIds(lineIds);
return lineMobile.stream().filter(o->StringUtils.isNotBlank(o.getMobile())).collect(Collectors.toMap(LineInfoDO::getId, LineInfoDO::getUsername, (k1, k2)-> k1)); return lineMobile.stream().filter(o->StringUtils.isNotBlank(o.getMobile())).collect(Collectors.toMap(LineInfoDO::getId, LineInfoDO::getUsername, (k1, k2)-> k1));
} }
public List<LineInfoDO> getListByPartnerIds(List<String> partnerIds){
if(CollectionUtils.isEmpty(partnerIds)){
return Lists.newArrayList();
}
Example example = new Example(LineInfoDAO.class);
example.createCriteria().andIn("partnerId",partnerIds);
return lineInfoMapper.selectByExample(example);
}
} }

View File

@@ -55,6 +55,8 @@ public class ShopAccountServiceImpl implements ShopAccountService {
OldShopDAO oldShopDAO; OldShopDAO oldShopDAO;
@Resource @Resource
ThirdXinGuanJiaService thirdXinGuanJiaService; ThirdXinGuanJiaService thirdXinGuanJiaService;
@Resource
private LineInfoDAO lineInfoDAO;
@Override @Override
public List<ShopAccountDTO> getShopAccountByShopId(Long shopId) { public List<ShopAccountDTO> getShopAccountByShopId(Long shopId) {
@@ -368,6 +370,10 @@ public class ShopAccountServiceImpl implements ShopAccountService {
return true; return true;
} }
List<String> partnerIds = hyPartnerUserInfoDOS.stream().map(HyPartnerUserInfoDO::getPartnerId).collect(Collectors.toList()); List<String> partnerIds = hyPartnerUserInfoDOS.stream().map(HyPartnerUserInfoDO::getPartnerId).collect(Collectors.toList());
List<LineInfoDO> lineInfoDOList = lineInfoDAO.getListByPartnerIds(partnerIds);
List<Long> lineIds = lineInfoDOList.stream().map(LineInfoDO::getId).collect(Collectors.toList());
// shopInfoDAO.selectByLines();
return null; return null;
} }