通信LIMS后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
zss
2025-03-28 91ab1a15515c4c213b2ac4f777a7f20c3d0d59ad 
 inspect-server/src/main/java/com/yuanchu/mom/service/impl/WarehouseServiceImpl.java


@@ -1,18 +1,28 @@


package com.yuanchu.mom.service.impl;




import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


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


import com.yuanchu.mom.dto.HistoryDto;


import com.yuanchu.mom.dto.WarehouseCellAndSampleDto;


import com.yuanchu.mom.dto.WarehouseDto;


import com.yuanchu.mom.mapper.WarehouseCellMapper;


import com.yuanchu.mom.mapper.WarehouseHistoryMapper;


import com.yuanchu.mom.mapper.WarehouseMapper;


import com.yuanchu.mom.mapper.WarehouseShelfMapper;


import com.yuanchu.mom.pojo.Warehouse;


import com.yuanchu.mom.pojo.WarehouseHistory;


import com.yuanchu.mom.exception.ErrorException;


import com.yuanchu.mom.mapper.*;


import com.yuanchu.mom.pojo.*;


import com.yuanchu.mom.service.WarehouseCellService;


import com.yuanchu.mom.service.WarehouseService;


import lombok.AllArgsConstructor;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;




/**


* @author Administrator


@@ -32,6 +42,16 @@




    private WarehouseHistoryMapper warehouseHistoryMapper;




    private WarehouseCellService warehouseCellService;




    private InsSampleMapper insSampleMapper;




    private InsOrderStateMapper insOrderStateMapper;




    private InsProductMapper insProductMapper;




    private InsOrderMapper insOrderMapper;




    @Override


    public int addWarehouse(String name) {


        Warehouse warehouse = new Warehouse();


@@ -43,6 +63,172 @@


    public List<WarehouseDto> selectWarehouse() {


        return warehouseMapper.selectWarehouseList();


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addShelf(WarehouseShelf warehouseShelf) {


        warehouseShelfMapper.insert(warehouseShelf);


        List<WarehouseCell> cells = new ArrayList<>();


        for (int i = 1; i < warehouseShelf.getRow() + 1; i++) {


            for (int a = 1; a < warehouseShelf.getCol() + 1; a++) {


                WarehouseCell cell = new WarehouseCell();


                cell.setRow(i);


                cell.setCol(a);


                cell.setState(1);


                cell.setShelfId(warehouseShelf.getId());


                cells.add(cell);


            }


        }


        warehouseCellService.saveBatch(cells);


        return 1;


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int delWarehouse(Integer id) {


        warehouseShelfMapper.delete(Wrappers.<WarehouseShelf>lambdaUpdate().eq(WarehouseShelf::getWarehouseId, id));


        return warehouseMapper.deleteById(id);


    }




    @Override


    public int upWarehouse(Warehouse warehouse) {


        return warehouseMapper.updateById(warehouse);


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int delShelf(Integer id) {


        warehouseCellMapper.update(null ,Wrappers.<WarehouseCell>lambdaUpdate().eq(WarehouseCell::getShelfId, id).set(WarehouseCell::getState, 0));


        return warehouseShelfMapper.deleteById(id);


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int upShelf(WarehouseShelf warehouseShelf) {


        WarehouseShelf shelf = warehouseShelfMapper.selectById(warehouseShelf.getId());


        if (shelf.getCol()>=warehouseShelf.getCol() && shelf.getRow() >= warehouseShelf.getRow()) {


            //如果维护的数据小于原有的行列数可以进行修改


            warehouseCellMapper.update(null, Wrappers.<WarehouseCell>lambdaUpdate()


                    .eq(WarehouseCell::getShelfId, warehouseShelf.getId())


                    .and(true, wrapper -> wrapper.gt(WarehouseCell::getRow, warehouseShelf.getRow())


                            .or()


                            .gt(WarehouseCell::getCol, warehouseShelf.getCol()))


                    .set(WarehouseCell::getState, 0));


        }else {


            //如果维护的数据大于原有的行列数需要进行额外添加


            List<WarehouseCell> cells = new ArrayList<>();


            for (int i = 1; i < warehouseShelf.getRow() + 1; i++) {


                for (int a = 1; a < warehouseShelf.getCol() + 1; a++) {


                    WarehouseCell cell = new WarehouseCell();


                    cell.setRow(i);


                    cell.setCol(a);


                    cell.setState(1);


                    cell.setShelfId(warehouseShelf.getId());


                    WarehouseCell warehouseCell = warehouseCellMapper.selectOne(Wrappers.<WarehouseCell>lambdaQuery()


                            .eq(WarehouseCell::getShelfId, warehouseShelf.getId())


                            .eq(WarehouseCell::getRow, i)


                            .eq(WarehouseCell::getCol, a));


                    if (ObjectUtils.isNotEmpty(warehouseCell)){


                        cell.setId(warehouseCell.getId());


                    }


                    cells.add(cell);


                }


            }


            warehouseCellService.saveOrUpdateBatch(cells);


        }


        warehouseShelfMapper.updateById(warehouseShelf);


        return 0;


    }




    @Override


    public List<WarehouseCellAndSampleDto> getWarehouse(Integer shelfId,String sampleCode) {


        return warehouseCellMapper.getWarehouse(shelfId,sampleCode);


    }




    @Override


    public int inWarehouse(String trees, String sampleCode,String entrustCode) {


        String[] tree = trees.split("-");


        if(tree.length < 4){


            throw new ErrorException("库位选择错误");


        }


        List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery()


                .ne(InsOrder::getState,3)//排除撤销的订单


                .eq(InsOrder::getEntrustCode, entrustCode));


        if(insOrders.size()!=1){


            throw new ErrorException("订单编号输入有误,或者该订单编号已经撤销");


        }


        List<InsSample> samples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery()


                .eq(InsSample::getSampleCode, sampleCode)


                .eq(InsSample::getInsOrderId,insOrders.get(0).getId())


                .select(InsSample::getId,InsSample::getCellId));


        if(samples.size()!=1){


            throw new ErrorException("样品编号输入有误");


        }


        if(samples.get(0).getCellId()!=null){


            throw new ErrorException("样品 " + sampleCode + " 未出库");


        }


        WarehouseCell cell = warehouseCellMapper.selectOne(Wrappers.<WarehouseCell>lambdaQuery().eq(WarehouseCell::getShelfId, tree[1]).eq(WarehouseCell::getRow, tree[2]).eq(WarehouseCell::getCol, tree[3]).eq(WarehouseCell::getState, 1).select(WarehouseCell::getId,WarehouseCell::getRow,WarehouseCell::getCol));


        WarehouseShelf shelf = warehouseShelfMapper.selectById(tree[1]);


        Warehouse warehouse = warehouseMapper.selectById(tree[0]);


        WarehouseHistory history = new WarehouseHistory();


        history.setCellId(cell.getId());


        history.setState(1);


        history.setInsSampleId(samples.get(0).getId());


        history.setWarehouseCode(warehouse.getName()+"-"+shelf.getName()+"-"+cell.getRow()+"-"+cell.getCol());


        samples.get(0).setCellId(cell.getId());


        insSampleMapper.updateById(samples.get(0));


        return warehouseHistoryMapper.insert(history);


    }




    @Override


    public int outWarehouse(String sampleCode, boolean a,String entrustCode) {


        List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery()


                .ne(InsOrder::getState,3)//排除撤销的订单


                .eq(InsOrder::getEntrustCode, entrustCode));


        if(insOrders.size()!=1){


            throw new ErrorException("订单编号输入有误,或者该订单编号已经撤销");


        }


        List<InsSample> samples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery()


                .eq(InsSample::getSampleCode, sampleCode)


                .eq(InsSample::getInsOrderId,insOrders.get(0).getId()));


        if(samples.size()!=1){


            throw new ErrorException("样品编号输入有误");


        }


        if(samples.get(0).getCellId()==null){


            throw new ErrorException("样品 " + sampleCode + " 未入库");


        }


        WarehouseHistory history = new WarehouseHistory();


        history.setState(2);


        history.setInsSampleId(samples.get(0).getId());


        history.setCellId(samples.get(0).getCellId());


        history.setWarehouseCode(warehouseHistoryMapper.selectOne(Wrappers.<WarehouseHistory>lambdaQuery().eq(WarehouseHistory::getInsSampleId, samples.get(0).getId()).select(WarehouseHistory::getWarehouseCode).orderByDesc(WarehouseHistory::getId).last("limit 1")).getWarehouseCode());


        insSampleMapper.update(null, Wrappers.<InsSample>lambdaUpdate().eq(InsSample::getId, samples.get(0).getId()).set(InsSample::getCellId, null));


        //该订单闭环


        InsOrder insOrder = insOrders.get(0);


        insOrder.setState(4);


        insOrderMapper.updateById(insOrder);


        return warehouseHistoryMapper.insert(history);


    }




    @Override


    public Map<String, Object> getSampleRecord(Integer id) {


        InsSample insSample = insSampleMapper.selectById(id);


        List<HistoryDto> histories = warehouseHistoryMapper.getHistoryListBySampleId(id);


        Map<String, Object> map = new HashMap<>();


        Map<String, String> sampleHistory = new HashMap<>();


        WarehouseHistory history = histories.get(histories.size() - 1);


        if(history.getState() == 1){


            sampleHistory.put("date", history.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));


            sampleHistory.put("user", warehouseHistoryMapper.getUserNameById(history.getCreateUser()));


            sampleHistory.put("code", history.getWarehouseCode());


        }


        map.put("sampleHistory", sampleHistory);


        map.put("insSample", insSample);


        map.put("histories", histories);


        map.put("products", insProductMapper.getProductAndResult(id));


        return map;


    }




}