| | |
| | | package com.ruoyi.management.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.ruoyi.common.core.utils.page.PageDTO; |
| | | import com.ruoyi.common.security.utils.SecurityUtils; |
| | | import com.ruoyi.management.domain.SlStoreManagement; |
| | | import com.ruoyi.management.domain.SlVolumeProductionCkgl; |
| | | import com.ruoyi.management.domain.SlVolumeProductionRkgl; |
| | | import com.ruoyi.management.domain.dto.VolumeProductionCkglDTO; |
| | | import com.ruoyi.management.domain.dto.getslVolumeProductionCkglQuery; |
| | | import com.ruoyi.management.domain.vo.SupplierVolumeProductionRkglVO; |
| | | import com.ruoyi.management.domain.vo.VolumeProductionCkglVO; |
| | | import com.ruoyi.management.mapper.SlStoreManagementMapper; |
| | | import com.ruoyi.management.mapper.SlVolumeProductionCkglMapper; |
| | | import com.ruoyi.management.service.SlVolumeProductionCkglService; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ruoyi.system.api.domain.SysUser; |
| | | import com.ruoyi.system.api.domain.getVolumeProductionRkQuery; |
| | | import com.ruoyi.system.api.feignClient.SysUserClient; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Set; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | */ |
| | | @Service |
| | | public class SlVolumeProductionCkglServiceImpl extends ServiceImpl<SlVolumeProductionCkglMapper, SlVolumeProductionCkgl> implements SlVolumeProductionCkglService { |
| | | @Resource |
| | | private SysUserClient sysUserClient; |
| | | |
| | | @Resource |
| | | private SlStoreManagementMapper slStoreManagementMapper; |
| | | @Override |
| | | public PageDTO<VolumeProductionCkglVO> getslVolumeProductionCkglList(getslVolumeProductionCkglQuery VolumeProductionCkglQuery) { |
| | | |
| | | Page<SlVolumeProductionCkgl> page = new Page<>(VolumeProductionCkglQuery.getPageCurr(), VolumeProductionCkglQuery.getPageSize()); |
| | | getVolumeProductionRkQuery getVolume=new getVolumeProductionRkQuery(); |
| | | getVolume.setSupplierPhone(VolumeProductionCkglQuery.getSupplierPhone()); |
| | | getVolume.setSupplierName(VolumeProductionCkglQuery.getSupplierName()); |
| | | List<SysUser> data1 = sysUserClient.getUserSupplierList(getVolume).getData(); |
| | | Set<Long> goodsSkuIdList = null; |
| | | goodsSkuIdList = data1.stream().map(SysUser::getUserId) |
| | | .collect(Collectors.toSet()); |
| | | |
| | | LambdaQueryWrapper< SlVolumeProductionCkgl> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(SlVolumeProductionCkgl::getPresentState,VolumeProductionCkglQuery.getPresentState()); |
| | | wrapper1.eq(SlVolumeProductionCkgl::getAuditStatus,VolumeProductionCkglQuery.getAuditStatus()); |
| | | if (goodsSkuIdList.size()>0){ |
| | | wrapper1.in(SlVolumeProductionCkgl::getSysId,goodsSkuIdList); |
| | | } |
| | | wrapper1.eq( SlVolumeProductionCkgl::getDelFlag,0); |
| | | wrapper1.orderByDesc(SlVolumeProductionCkgl::getCreateTime); |
| | | Page<SlVolumeProductionCkgl> page2 = this.page(page, wrapper1); |
| | | |
| | | PageDTO<VolumeProductionCkglVO> SlGoodsShelfDTO = PageDTO.of(page2, VolumeProductionCkglVO .class); |
| | | List<VolumeProductionCkglVO> list2 = SlGoodsShelfDTO.getList(); |
| | | for(VolumeProductionCkglVO list:list2){ |
| | | SysUser data = sysUserClient.getSysUser(list.getSupplierId()).getData(); |
| | | list.setNickName(data.getNickName()); |
| | | list.setPhonenumber(data.getPhonenumber()); |
| | | SlStoreManagement slStoreManagement = slStoreManagementMapper.selectById(list.getManagementId()); |
| | | list.setStoreManagementName(slStoreManagement.getStoreManagementName()); |
| | | } |
| | | return SlGoodsShelfDTO; |
| | | } |
| | | |
| | | @Override |
| | | public void addslVolumeProductionCkgl(VolumeProductionCkglDTO volumeProductionCkglDTO) { |
| | | Long userid = SecurityUtils.getUserId(); |
| | | if (volumeProductionCkglDTO.getId()!=null){ |
| | | SlVolumeProductionCkgl slVolumeProductionRkgl=new SlVolumeProductionCkgl(); |
| | | slVolumeProductionRkgl.setAttachmentUrl(volumeProductionCkglDTO.getAttachmentUrl()); |
| | | slVolumeProductionRkgl.setAuthorization(volumeProductionCkglDTO.getAuthorization()); |
| | | slVolumeProductionRkgl.setAuditStatus(1); |
| | | slVolumeProductionRkgl.setManagementId(volumeProductionCkglDTO.getManagementId()); |
| | | slVolumeProductionRkgl.setPresentState(1); |
| | | slVolumeProductionRkgl.setSource(volumeProductionCkglDTO.getSource()); |
| | | slVolumeProductionRkgl.setStartiTime(new Date()); |
| | | slVolumeProductionRkgl.setSysId(userid); |
| | | this.save(slVolumeProductionRkgl); |
| | | }else{ |
| | | SlVolumeProductionCkgl byId = this.getById(volumeProductionCkglDTO.getId()); |
| | | if (volumeProductionCkglDTO.getSource()!=null){ |
| | | byId.setSource(volumeProductionCkglDTO.getSource()); |
| | | } |
| | | if (volumeProductionCkglDTO.getAttachmentUrl()!=null){ |
| | | byId.setAttachmentUrl(volumeProductionCkglDTO.getAttachmentUrl()); |
| | | } |
| | | if (volumeProductionCkglDTO.getAuthorization()!=null){ |
| | | byId.setAuthorization(volumeProductionCkglDTO.getAuthorization()); |
| | | } |
| | | this.updateById(byId); |
| | | } |
| | | } |
| | | } |