blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
skyouc
4 天以前 e59dc198187db08cf208ba5e23deb722b13d8f3a 
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaveOrderRelaServiceImpl.java


@@ -1,12 +1,42 @@


package com.vincent.rsf.server.manager.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.vincent.rsf.framework.common.R;


import com.vincent.rsf.server.common.domain.BaseParam;


import com.vincent.rsf.server.common.domain.PageParam;


import com.vincent.rsf.server.manager.entity.AsnOrderItem;


import com.vincent.rsf.server.manager.mapper.WaveOrderRelaMapper;


import com.vincent.rsf.server.manager.entity.WaveOrderRela;


import com.vincent.rsf.server.manager.service.AsnOrderItemService;


import com.vincent.rsf.server.manager.service.WaveOrderRelaService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;




@Service("waveOrderRelaService")


public class WaveOrderRelaServiceImpl extends ServiceImpl<WaveOrderRelaMapper, WaveOrderRela> implements WaveOrderRelaService {




    @Autowired


    private AsnOrderItemService asnOrderItemService;






    @Override


    public R relaPage(BaseParam baseParam, Map<String, Object> params) {


        List<WaveOrderRela> orderRelas = this.baseMapper.selectList(new LambdaQueryWrapper<WaveOrderRela>()


                .eq(WaveOrderRela::getWaveId, Long.parseLong(params.get("waveId").toString())));


        if (orderRelas.isEmpty()) {


            return R.ok();


        }


        List<Long> orderIds = orderRelas.stream().map(WaveOrderRela::getOrderItemId).collect(Collectors.toList());


        PageParam<AsnOrderItem, BaseParam> pageParam = new PageParam<>(baseParam, AsnOrderItem.class);


        QueryWrapper<AsnOrderItem> wrapper = pageParam.buildWrapper(true);


        wrapper.in("id", orderIds);


        return R.ok().add(asnOrderItemService.page(pageParam, wrapper));


    }


}