海政通
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
xuhy
8 天以前 eb23b15acb15aae43b336ecf5ffb2053bcf85464 
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TErpProcurementServiceImpl.java


@@ -1,10 +1,25 @@


package com.ruoyi.system.service.impl;




import com.ruoyi.system.model.TErpProcurement;


import com.ruoyi.system.mapper.TErpProcurementMapper;


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


import com.ruoyi.common.basic.PageInfo;


import com.ruoyi.common.core.domain.entity.SysUser;


import com.ruoyi.system.mapper.*;


import com.ruoyi.system.model.*;


import com.ruoyi.system.query.TErpGoodsQuery;


import com.ruoyi.system.query.TErpProcurementQuery;


import com.ruoyi.system.service.TErpProcurementService;


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


import com.ruoyi.system.vo.TErpProcurementDetailNextVo;


import com.ruoyi.system.vo.TErpProcurementDetailVo;


import com.ruoyi.system.vo.TErpProcurementVo;


import com.ruoyi.system.vo.ValidityPeriodWarningVo;


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.util.ArrayList;


import java.util.List;


import java.util.stream.Collectors;




/**


 * <p>


@@ -17,4 +32,111 @@


@Service


public class TErpProcurementServiceImpl extends ServiceImpl<TErpProcurementMapper, TErpProcurement> implements TErpProcurementService {




    @Resource


    private TErpProcurementGoodsMapper erpProcurementGoodsMapper;




    @Resource


    private TSysCommissionMapper sysCommissionMapper;




    @Resource


    private TCrmClinicMapper crmClinicMapper;




    @Resource


    private SysUserMapper sysUserMapper;




    @Override


    public PageInfo<TErpProcurementVo> pageList(TErpProcurementQuery query, SysUser user) {


        String sTime=null;


        String eTime =null;


        if(query.getTime()!=null && !query.getTime().isEmpty()){


            String[] split = query.getTime().split(" - ");


            sTime = split[0] + " 00:00:00";


            eTime = split[1] + " 23:59:59";


        }


        PageInfo<TErpProcurementVo> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());


        List<TErpProcurementVo> list = this.baseMapper.pageList(query,pageInfo,user,sTime,eTime);


        if(list.isEmpty()){


            return pageInfo;


        }


        List<String> ids = list.stream().map(TErpProcurementVo::getId).collect(Collectors.toList());


        List<TErpProcurementGoods> tErpProcurementGoods = erpProcurementGoodsMapper.selectList(new LambdaQueryWrapper<TErpProcurementGoods>().in(TErpProcurementGoods::getProcurementId, ids).eq(TErpProcurementGoods::getSupplierId, user.getUserId()));


        List<TSysCommission> tSysCommissions =new ArrayList<>();


        if(!tErpProcurementGoods.isEmpty()){


            List<String> collect = tErpProcurementGoods.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


            tSysCommissions = sysCommissionMapper.selectList(new LambdaQueryWrapper<TSysCommission>().in(TSysCommission::getTErpProcurementGoodsId, collect));


        }


        for (TErpProcurementVo tErpProcurementVo : list) {


            List<TErpProcurementGoods> collect = tErpProcurementGoods.stream().filter(e -> e.getProcurementId().equals(tErpProcurementVo.getId())).collect(Collectors.toList());


            int size = collect.stream().map(TErpProcurementGoods::getGoodsId).collect(Collectors.toSet()).size();


            tErpProcurementVo.setTypeNum(size);


            BigDecimal reduce = collect.stream().map(TErpProcurementGoods::getTotalPrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            tErpProcurementVo.setTotalPrice(reduce);


            if(!collect.isEmpty()){


                List<String> collect1 = collect.stream().map(TErpProcurementGoods::getId).collect(Collectors.toList());


                List<TSysCommission> collect2 = tSysCommissions.stream().filter(e -> collect1.contains(e.getTErpProcurementGoodsId())).collect(Collectors.toList());


                BigDecimal reduce1 = collect2.stream().filter(e->e.getType()==1).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                BigDecimal reduce2 = collect2.stream().filter(e->e.getType()==2).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                tErpProcurementVo.setPlatformMoney(reduce1);


                tErpProcurementVo.setSupplierMoney(reduce2);


            }




        }






        pageInfo.setRecords(list);


        return pageInfo;


    }




    @Override


    public TErpProcurementDetailVo detail(String id, SysUser user, String goodsName) {


        TErpProcurementDetailVo tErpProcurementVo = new TErpProcurementDetailVo();




        TErpProcurement tErpProcurement = this.getById(id);


        tErpProcurementVo.setId(id);


        tErpProcurementVo.setProcurementCode(tErpProcurement.getProcurementCode());


        tErpProcurementVo.setClinicId(tErpProcurement.getClinicId());




        TCrmClinic tCrmClinic = crmClinicMapper.selectById(tErpProcurement.getClinicId());


        tErpProcurementVo.setClinicName(tCrmClinic.getClinicName());


        tErpProcurementVo.setUserName(tCrmClinic.getPersonChargeName());


        SysUser sysUser = sysUserMapper.selectUserById(Long.valueOf(tErpProcurement.getCreateId()));




        tErpProcurementVo.setUserName(sysUser.getNickName());


        tErpProcurementVo.setCreateTime(tErpProcurement.getCreateTime());


        tErpProcurementVo.setUpdateTime(tErpProcurement.getUpdateTime());


        if(tErpProcurement.getWarehousingUserId()!=null){


            SysUser sysUser1 = sysUserMapper.selectUserById(Long.valueOf(tErpProcurement.getWarehousingUserId()));


            tErpProcurementVo.setOperName(sysUser1.getNickName());


        }


        tErpProcurementVo.setStatus(tErpProcurement.getStatus());


        tErpProcurementVo.setSendTime(tErpProcurement.getSendTime());




        List<TErpProcurementGoods> tErpProcurementGoods = erpProcurementGoodsMapper.selectList(new LambdaQueryWrapper<TErpProcurementGoods>().eq(TErpProcurementGoods::getProcurementId, id).like(goodsName != null && !goodsName.isEmpty(), TErpProcurementGoods::getGoodsName, goodsName).eq(TErpProcurementGoods::getSupplierId, user.getUserId()));


        if(tErpProcurementGoods.isEmpty()){


            return tErpProcurementVo;


        }




        ArrayList<TErpProcurementDetailNextVo> tErpProcurementDetailNextVos = new ArrayList<>();


        for (TErpProcurementGoods tErpProcurementGood : tErpProcurementGoods) {


            TErpProcurementDetailNextVo tErpProcurementDetailNextVo = new TErpProcurementDetailNextVo();


            tErpProcurementDetailNextVo.setGoodsName(tErpProcurementGood.getGoodsName());


            tErpProcurementDetailNextVo.setUnitName(tErpProcurementGood.getUnitName());


            tErpProcurementDetailNextVo.setNum(tErpProcurementGood.getPurchaseCount());


            tErpProcurementDetailNextVo.setTotalPrice(tErpProcurementGood.getTotalPrice());


            tErpProcurementDetailNextVo.setQuasiNumber(tErpProcurementGood.getQuasiNumber());






            List<TSysCommission> tSysCommissions = sysCommissionMapper.selectList(new LambdaQueryWrapper<TSysCommission>().eq(TSysCommission::getTErpProcurementGoodsId, tErpProcurementGood.getId()));


            if(!tSysCommissions.isEmpty()){


                BigDecimal reduce = tSysCommissions.stream().filter(e -> e.getType() == 1).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                tErpProcurementDetailNextVo.setPlatformMoney(reduce);


                BigDecimal reduce1 = tSysCommissions.stream().filter(e -> e.getType() == 2).map(TSysCommission::getMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


                tErpProcurementDetailNextVo.setSupplierMoney(reduce1);


            }


            tErpProcurementDetailNextVos.add(tErpProcurementDetailNextVo);




        }


        tErpProcurementVo.setList(tErpProcurementDetailNextVos);


        return tErpProcurementVo;


    }


}