package com.zy.asrs.wms.controller; 
 | 
  
 | 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; 
 | 
import com.zy.asrs.common.domain.dto.LocDetlDto; 
 | 
import com.zy.asrs.common.domain.dto.WrkDto; 
 | 
import com.zy.asrs.common.domain.entity.MobileAdjustResult; 
 | 
import com.zy.asrs.common.domain.entity.StaDesc; 
 | 
import com.zy.asrs.common.domain.enums.WorkNoType; 
 | 
import com.zy.asrs.common.domain.param.MobileAdjustParam; 
 | 
import com.zy.asrs.common.domain.param.PickConfirmParam; 
 | 
import com.zy.asrs.common.domain.param.PickMatParam; 
 | 
import com.zy.asrs.common.openapi.entity.param.CombParam; 
 | 
import com.zy.asrs.common.sys.service.StaDescService; 
 | 
import com.zy.asrs.common.web.BaseController; 
 | 
import com.zy.asrs.common.wms.entity.*; 
 | 
import com.zy.asrs.common.wms.service.*; 
 | 
import com.zy.asrs.framework.annotations.ManagerAuth; 
 | 
import com.zy.asrs.framework.common.Cools; 
 | 
import com.zy.asrs.framework.common.R; 
 | 
import com.zy.asrs.framework.exception.CoolException; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.transaction.annotation.Transactional; 
 | 
import org.springframework.web.bind.annotation.RequestBody; 
 | 
import org.springframework.web.bind.annotation.RequestMapping; 
 | 
import org.springframework.web.bind.annotation.RequestParam; 
 | 
import org.springframework.web.bind.annotation.RestController; 
 | 
  
 | 
import java.util.*; 
 | 
import java.util.stream.Collectors; 
 | 
  
 | 
/** 
 | 
 * 移动端接口控制器 
 | 
 */ 
 | 
@RestController 
 | 
@RequestMapping("mobile") 
 | 
public class MobileController extends BaseController { 
 | 
  
 | 
    @Autowired 
 | 
    private MobileService mobileService; 
 | 
    @Autowired 
 | 
    private OrderService orderService; 
 | 
    @Autowired 
 | 
    private DocTypeService docTypeService; 
 | 
    @Autowired 
 | 
    private WrkDetlService wrkDetlService; 
 | 
    @Autowired 
 | 
    private WrkMastService wrkMastService; 
 | 
    @Autowired 
 | 
    private LocDetlService locDetlService; 
 | 
    @Autowired 
 | 
    private BasDevpService basDevpService; 
 | 
    @Autowired 
 | 
    private RolePermissionService rolePermissionService; 
 | 
    @Autowired 
 | 
    private PermissionService permissionService; 
 | 
    @Autowired 
 | 
    private LocMastService locMastService; 
 | 
    @Autowired 
 | 
    private StaDescService staDescService; 
 | 
    @Autowired 
 | 
    private OrderDetlService orderDetlService; 
 | 
    @Autowired 
 | 
    private CommonService commonService; 
 | 
    @Autowired 
 | 
    private MatService matService; 
 | 
  
 | 
    @RequestMapping("/pda/WarehouseIn") 
 | 
    @ManagerAuth 
 | 
    public R WarehouseIn(@RequestParam String locNo,@RequestParam String barcode){ 
 | 
        return mobileService.WarehouseIn(locNo,barcode,getHostId()); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pda/WarehouseOut") 
 | 
    @ManagerAuth 
 | 
    public R WarehouseOut(@RequestBody CombParam combParam){ 
 | 
        return mobileService.WarehouseOut(combParam,getHostId()); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/menu/pda/auth") 
 | 
    @ManagerAuth 
 | 
    public R menuPda(){ 
 | 
        List<RolePermission> rolePermissions; 
 | 
        Long roleId = getUser().getRoleId(); 
 | 
        rolePermissions = rolePermissionService.list(new LambdaQueryWrapper<RolePermission>().eq(RolePermission::getRoleId, getHostId())); 
 | 
  
 | 
        if (Cools.isEmpty(rolePermissions)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        List<Long> collect = rolePermissions.stream().map(RolePermission::getPermissionId).distinct().collect(Collectors.toList()); 
 | 
        List<Permission> permissions = permissionService.listByIds(collect); 
 | 
        return R.ok().add(permissions); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 入库制令检测  -- 指令在库存里面借用批号字段batch 
 | 
     * 1.可正常入库 
 | 
     * 2.库存包含相同制令货物,是否进行补货 
 | 
     * 3.工作档存在正在入库任务,拒绝入库 
 | 
     */ 
 | 
    @RequestMapping("/pda/decrees/check") 
 | 
    @ManagerAuth 
 | 
    public R pdaDecreesCheck(@RequestParam String decrees){ 
 | 
        if (Cools.isEmpty(decrees)) { 
 | 
            return R.error("制令不能为空"); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        //查询是否有库存 
 | 
        List<LocDetl> list = locDetlService.list(new LambdaQueryWrapper<LocDetl>().eq(LocDetl::getBatch, decrees)); 
 | 
        //查询是否有正在工作的工作档 
 | 
        List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getBatch, decrees)); 
 | 
        HashMap<String, Object> map = new HashMap<>(); 
 | 
        if(list.isEmpty() && wrkDetls.isEmpty()){ 
 | 
            map.put("status", 1);//可正常入库 
 | 
        } else if (!wrkDetls.isEmpty()) { 
 | 
            map.put("status", 3);//存在工作档,拒绝入库 
 | 
        } else { 
 | 
            //获取库存最少的一条记录 
 | 
            Double anfme = 999999999D; 
 | 
            LocDetl miniLocDetl = null; 
 | 
            for (LocDetl locDetl : list) { 
 | 
                if (locDetl.getAnfme() < anfme) { 
 | 
                    anfme = locDetl.getAnfme(); 
 | 
                    miniLocDetl = locDetl; 
 | 
                } 
 | 
            } 
 | 
  
 | 
            map.put("status", 2);//库存包含相同制令货物,是否进行补货 
 | 
            map.put("data", miniLocDetl);//库存信息 
 | 
        } 
 | 
        return R.ok().add(map); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 根据单号检索单据数据 
 | 
     */ 
 | 
    @RequestMapping("/order/search/orderNo/auth") 
 | 
    @ManagerAuth 
 | 
    public R orderSearchByBarcode(@RequestParam String orderNo){ 
 | 
        Order order = orderService.selectByNo(orderNo, getHostId()); 
 | 
        if (order == null) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        DocType docType = docTypeService.getById(order.getDocType()); 
 | 
        if (docType.getPakin() == null || docType.getPakin() != 1) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        if (order.getSettle() > 2) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        List<OrderDetl> orderDetls = orderService.selectWorkingDetls(order.getId()); 
 | 
        if (Cools.isEmpty(orderDetls)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        return R.ok().add(orderDetls); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/comb/auth") 
 | 
    @ManagerAuth(memo = "组托") 
 | 
    public R comb(@RequestBody CombParam combParam){ 
 | 
        mobileService.comb(combParam, getUserId(), getHostId()); 
 | 
        return R.ok("组托成功"); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pakout/query/auth") 
 | 
    @ManagerAuth 
 | 
    @Deprecated 
 | 
    public R pakoutQuery(@RequestParam(required = false) String barcode, 
 | 
                         @RequestParam(required = false) Integer staNo, 
 | 
                         @RequestParam(required = false) String matnr){ 
 | 
        if (Cools.isEmpty(barcode) && Cools.isEmpty(matnr)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        if (!Cools.isEmpty(barcode)) { 
 | 
            List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getZpallet, barcode).eq(WrkDetl::getHostId, hostId)); 
 | 
            return R.ok().add(wrkDetls); 
 | 
        } 
 | 
        if (!Cools.isEmpty(matnr)) { 
 | 
            if (!Cools.isEmpty(staNo)) { 
 | 
                List<WrkDetl> wrkDetls = wrkDetlService.selectPakoutQuery(staNo, matnr, hostId); 
 | 
                return R.ok().add(wrkDetls); 
 | 
            } 
 | 
        } 
 | 
        return R.ok(); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 出库确认 - 扫托盘码 
 | 
     * 1.全板 返回 101 
 | 
     * 2.拣料 返回 103 
 | 
     */ 
 | 
    @RequestMapping("/pakout/confirm/barcode/auth") 
 | 
    @ManagerAuth 
 | 
    public R pakoutQueryByBarcode(@RequestParam(required = false) String barcode){ 
 | 
        if (Cools.isEmpty(barcode)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        WrkMast wrkMast = wrkMastService.selectByBarcode(barcode, hostId); 
 | 
        if (wrkMast != null) { 
 | 
            List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getWrkNo, wrkMast.getWrkNo()).eq(WrkDetl::getHostId, hostId)); 
 | 
            // 去除已出库确认的明细 
 | 
            wrkDetls.removeIf(wrkDetl -> wrkDetl.getInspect() != null && wrkDetl.getInspect() != 0); 
 | 
            return R.ok().add(Cools.add("wrkNo", wrkMast.getWrkNo()).add("ioType", wrkMast.getIoType()).add("list", wrkDetls)); 
 | 
        } 
 | 
        return R.ok(); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 出库确认 - 拣料出库 - 选择具体条码商品 
 | 
     */ 
 | 
    @RequestMapping("/pakout/confirm/pick/auth") 
 | 
    @ManagerAuth 
 | 
    public R pakoutQueryByBarcode(@RequestParam(required = false) Integer wrkNo 
 | 
            , @RequestParam(required = false) String matnr){ 
 | 
        if (Cools.isEmpty(wrkNo)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        if (Cools.isEmpty(matnr)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        WrkMast wrkMast = wrkMastService.getOne(new LambdaQueryWrapper<WrkMast>().eq(WrkMast::getWrkNo, wrkNo).eq(WrkMast::getHostId, hostId)); 
 | 
        if (wrkMast == null) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        String orderNo = null; 
 | 
        List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getWrkNo, wrkMast.getWrkNo()).eq(WrkDetl::getHostId, hostId)); 
 | 
        for (WrkDetl wrkDetl : wrkDetls) { 
 | 
            if (Cools.isEmpty(orderNo)) { 
 | 
                orderNo = wrkDetl.getOrderNo(); 
 | 
            } 
 | 
            if ((wrkDetl.getMatnr() + "-" + wrkDetl.getBatch()).equals(matnr)) { 
 | 
                return R.ok().add(wrkDetl); 
 | 
            } 
 | 
        } 
 | 
        // 替换 明细 
 | 
        List<LocDetl> locDetls = locDetlService.list(new LambdaQueryWrapper<LocDetl>().eq(LocDetl::getLocNo, wrkMast.getSourceLocNo()).eq(LocDetl::getHostId, hostId)); 
 | 
        for (LocDetl locDetl : locDetls) { 
 | 
            if ((locDetl.getMatnr() + "-" + locDetl.getBatch()).equals(matnr)) { 
 | 
                WrkDetl wrkDetl = new WrkDetl(); 
 | 
                wrkDetl.sync(locDetl); 
 | 
                wrkDetl.setOrderNo(orderNo); 
 | 
                wrkDetl.setIoTime(wrkMast.getIoTime()); 
 | 
                wrkDetl.setWrkNo(wrkNo); 
 | 
                return R.ok().add(wrkDetl); 
 | 
            } 
 | 
        } 
 | 
        return R.error("系统错误,条码不存在"); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pakout/confirm/auth") 
 | 
    @ManagerAuth 
 | 
    @Transactional 
 | 
    public R pakoutConfirm(@RequestBody List<WrkDetl> list) { 
 | 
        if (Cools.isEmpty(list)) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        Set<Integer> wrkNos = new HashSet<>(); 
 | 
        List<WrkDto> dtos = new ArrayList<>(); 
 | 
        for (WrkDetl wrkDetl : list) { 
 | 
            if (wrkNos.contains(wrkDetl.getWrkNo())) { 
 | 
                for (WrkDto dto : dtos) { 
 | 
                    if (dto.getWrkNo().equals(wrkDetl.getWrkNo())) { 
 | 
                        dto.getWrkDetls().add(wrkDetl); 
 | 
                        break; 
 | 
                    } 
 | 
                } 
 | 
            } else { 
 | 
                wrkNos.add(wrkDetl.getWrkNo()); 
 | 
                dtos.add(new WrkDto(wrkDetl.getWrkNo(), wrkDetl)); 
 | 
            } 
 | 
        } 
 | 
  
 | 
        for (WrkDto dto : dtos) { 
 | 
            WrkMast wrkMast = wrkMastService.getOne(new LambdaQueryWrapper<WrkMast>().eq(WrkMast::getWrkNo, dto.getWrkNo()).eq(WrkMast::getHostId, hostId)); 
 | 
            if (wrkMast != null) { 
 | 
                // 101 
 | 
                if (wrkMast.getIoType() == 101) { 
 | 
                    for (WrkDetl wrkDetl : dto.getWrkDetls()) { 
 | 
                        wrkDetlService.updateInspect(wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), hostId); 
 | 
                    } 
 | 
                } 
 | 
                // 103 
 | 
                if (wrkMast.getIoType() == 103) { 
 | 
                    if (!wrkDetlService.remove(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getWrkNo, wrkMast.getWrkNo()).eq(WrkDetl::getHostId, hostId))) { 
 | 
                        throw new CoolException("拣料出库确认失败"); 
 | 
                    } 
 | 
                    for (WrkDetl wrkDetl : dto.getWrkDetls()) { 
 | 
                        wrkDetl.setInspect(1); 
 | 
                        if (!wrkDetlService.save(wrkDetl)) { 
 | 
                            throw new CoolException("拣料出库确认失败"); 
 | 
                        } 
 | 
                    } 
 | 
                } 
 | 
            } 
 | 
        } 
 | 
  
 | 
        for (Integer wrkNo : wrkNos) { 
 | 
            WrkMast wrkMast = wrkMastService.getOne(new LambdaQueryWrapper<WrkMast>().eq(WrkMast::getWrkNo, wrkNo).eq(WrkMast::getHostId, hostId)); 
 | 
            if (wrkMast.getWrkSts() == 14 && (Cools.isEmpty(wrkMast.getInvWh()) || wrkMast.getInvWh().equals("N"))) { 
 | 
                List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getWrkNo, wrkNo).eq(WrkDetl::getHostId, hostId)); 
 | 
                boolean complete = true; 
 | 
                for (WrkDetl wrkDetl : wrkDetls) { 
 | 
                    if (wrkDetl.getInspect() == null || wrkDetl.getInspect() == 0) { 
 | 
                        complete = false; 
 | 
                        break; 
 | 
                    } 
 | 
                } 
 | 
                if (complete) { 
 | 
                    wrkMast.setInvWh("Y"); 
 | 
                    wrkMast.setModiTime(new Date()); 
 | 
                    if (!wrkMastService.updateById(wrkMast)) { 
 | 
                        throw new CoolException("修改工作档" + wrkNo + "失败"); 
 | 
                    } 
 | 
                } 
 | 
            } 
 | 
        } 
 | 
        return R.ok("完成确认"); 
 | 
    } 
 | 
  
 | 
    // 盘点 ---------------------------------------------------------------------------------------------------- 
 | 
  
 | 
    @RequestMapping("/checkDetl/auth") 
 | 
    @ManagerAuth 
 | 
    public R getCheckDetl(@RequestParam(required = false) Integer staNo) { 
 | 
        if (null == staNo || staNo == 0) { 
 | 
            return R.ok(); 
 | 
        } 
 | 
        Long hostId = getHostId(); 
 | 
        BasDevp basDevp = basDevpService.getOne(new LambdaQueryWrapper<BasDevp>().eq(BasDevp::getDevNo, staNo).eq(BasDevp::getHostId, hostId)); 
 | 
        if (null != basDevp && basDevp.getWrkNo() != null) { 
 | 
            WrkMast wrkMast = wrkMastService.getOne(new LambdaQueryWrapper<WrkMast>().eq(WrkMast::getWrkNo, basDevp.getWrkNo()).eq(WrkMast::getHostId, hostId)); 
 | 
            if (wrkMast != null && wrkMast.getIoType() == 107) { 
 | 
                List<WrkDetl> wrkDetls = wrkDetlService.list(new LambdaQueryWrapper<WrkDetl>().eq(WrkDetl::getWrkNo, wrkMast.getWrkNo()).eq(WrkDetl::getHostId, hostId)); 
 | 
                if (!Cools.isEmpty(wrkDetls)) { 
 | 
                    MobileAdjustResult result = new MobileAdjustResult(); 
 | 
                    result.setStaNo(staNo); 
 | 
                    result.setWrkNo(wrkMast.getWrkNo()); 
 | 
                    result.setWrkDetls(wrkDetls); 
 | 
                    return R.ok().add(result); 
 | 
                } 
 | 
            } 
 | 
        } 
 | 
        return R.ok(); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/adjust/auth") 
 | 
    @ManagerAuth(memo = "盘点") 
 | 
    public R adjust(@RequestBody MobileAdjustParam combParam){ 
 | 
        mobileService.adjust(combParam, getUserId(), getHostId()); 
 | 
        return R.ok("盘点成功"); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/loc/f/list") 
 | 
    @ManagerAuth(memo = "获取在库库位") 
 | 
    public R locNoF(@RequestParam(required = false) String locNo){ 
 | 
        LambdaQueryWrapper<LocMast> wrapper = new LambdaQueryWrapper<LocMast>() 
 | 
                .eq(LocMast::getLocSts, "F") 
 | 
                .eq(LocMast::getHostId, getHostId()); 
 | 
        if (!Cools.isEmpty(locNo)) { 
 | 
            wrapper.like(LocMast::getLocNo, locNo); 
 | 
        } 
 | 
        List<LocMast> list = locMastService.list(wrapper); 
 | 
        return R.ok().add(list); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pick/sta/list") 
 | 
    @ManagerAuth(memo = "获取并板站") 
 | 
    public R pickSta(){ 
 | 
        List<StaDesc> list = staDescService.list(new LambdaQueryWrapper<StaDesc>() 
 | 
                .eq(StaDesc::getTypeNo, 104) 
 | 
                .eq(StaDesc::getHostId, getHostId())); 
 | 
        return R.ok().add(list); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pick/mat/list") 
 | 
    @ManagerAuth(memo = "获取并板物料") 
 | 
    public R pickMats(@RequestParam(required = false) String matnr){ 
 | 
        List<DocType> docTypes = docTypeService.list(new LambdaQueryWrapper<DocType>().like(DocType::getDocName, "入库")); 
 | 
        ArrayList<Long> typeList = new ArrayList<>(); 
 | 
        for (DocType docType : docTypes) { 
 | 
            typeList.add(docType.getDocId()); 
 | 
        } 
 | 
  
 | 
        LambdaQueryWrapper<Order> wrapper = new LambdaQueryWrapper<>(); 
 | 
        wrapper.eq(Order::getStatus, 1); 
 | 
        wrapper.eq(Order::getHostId, getHostId()); 
 | 
        wrapper.in(Order::getDocType, typeList); 
 | 
        List<Order> orders = orderService.list(wrapper); 
 | 
  
 | 
        ArrayList<Long> orderIds = new ArrayList<>(); 
 | 
        for (Order order : orders) { 
 | 
            orderIds.add(order.getId()); 
 | 
        } 
 | 
  
 | 
        //搜索明细 
 | 
        LambdaQueryWrapper<OrderDetl> wrapper1 = new LambdaQueryWrapper<>(); 
 | 
        wrapper1.eq(OrderDetl::getStatus, 1); 
 | 
        wrapper1.eq(OrderDetl::getHostId, getHostId()); 
 | 
        wrapper1.in(OrderDetl::getOrderId, orderIds); 
 | 
        if (!Cools.isEmpty(matnr)) { 
 | 
            wrapper1.like(OrderDetl::getMatnr, matnr); 
 | 
        } 
 | 
  
 | 
        List<OrderDetl> list = orderDetlService.list(wrapper1); 
 | 
  
 | 
        ArrayList<PickMatParam> maps = new ArrayList<>(); 
 | 
        for (OrderDetl orderDetl : list) { 
 | 
            //剩余可用数量 
 | 
            double count = orderDetl.getAnfme() - orderDetl.getWorkQty(); 
 | 
            if (count <= 0) { 
 | 
                continue; 
 | 
            } 
 | 
  
 | 
            PickMatParam matParam = new PickMatParam(); 
 | 
            matParam.setMatnr(orderDetl.getMatnr()); 
 | 
            matParam.setBatch(orderDetl.getBatch()); 
 | 
            matParam.setOrderNo(orderDetl.getOrderNo()); 
 | 
            matParam.setOrderId(orderDetl.getOrderId()); 
 | 
            matParam.setCount(count); 
 | 
            matParam.setUseCount(0D); 
 | 
            maps.add(matParam); 
 | 
        } 
 | 
        return R.ok().add(maps); 
 | 
    } 
 | 
  
 | 
    @RequestMapping("/pick/in") 
 | 
    @ManagerAuth(memo = "并板入库") 
 | 
    @Transactional 
 | 
    public R pickConfirm(@RequestBody PickConfirmParam param){ 
 | 
        LocMast locMast = locMastService.getOne(new LambdaQueryWrapper<LocMast>() 
 | 
                .eq(LocMast::getLocNo, param.getLocNo()) 
 | 
                .eq(LocMast::getHostId, getHostId())); 
 | 
        if (!locMast.getLocSts().equals("F")) { 
 | 
            return R.error("库位状态不是在库"); 
 | 
        } 
 | 
  
 | 
        StaDesc staDesc = staDescService.getOne(new LambdaQueryWrapper<StaDesc>() 
 | 
                .eq(StaDesc::getTypeNo, 104) 
 | 
                .eq(StaDesc::getStnNo, param.getStaNo()) 
 | 
                .eq(StaDesc::getHostId, getHostId())); 
 | 
        if (staDesc == null) { 
 | 
            return R.error("站点不存在"); 
 | 
        } 
 | 
  
 | 
        //检验传参是否和订单明细匹配 
 | 
        for (PickMatParam matParam : param.getList()) { 
 | 
            LambdaQueryWrapper<OrderDetl> wrapper = new LambdaQueryWrapper<OrderDetl>() 
 | 
                    .eq(OrderDetl::getOrderNo, matParam.getOrderNo()) 
 | 
                    .eq(OrderDetl::getHostId, getHostId()) 
 | 
                    .eq(OrderDetl::getStatus, 1) 
 | 
                    .eq(OrderDetl::getMatnr, matParam.getMatnr()); 
 | 
            if (!Cools.isEmpty(matParam.getBatch())) { 
 | 
                wrapper.eq(OrderDetl::getBatch, matParam.getBatch()); 
 | 
            } 
 | 
            OrderDetl orderDetl = orderDetlService.getOne(wrapper); 
 | 
            if (orderDetl == null) { 
 | 
                return R.error("物料数据不存在"); 
 | 
            } 
 | 
  
 | 
            //剩余可用数量 
 | 
            double count = orderDetl.getAnfme() - orderDetl.getWorkQty(); 
 | 
            if (matParam.getCount() != count) { 
 | 
                return R.error("物料数据已过期"); 
 | 
            } 
 | 
  
 | 
            if (matParam.getUseCount() > count) { 
 | 
                return R.error("可用数量不足"); 
 | 
            } 
 | 
        } 
 | 
  
 | 
        Date now = new Date(); 
 | 
        // 生成工作号 
 | 
        int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(104)); 
 | 
        // 生成工作档 
 | 
        WrkMast wrkMast = new WrkMast(); 
 | 
        wrkMast.setWrkNo(workNo); 
 | 
        wrkMast.setIoTime(now); 
 | 
        wrkMast.setWrkSts(101L); // 工作状态:101.生成出库 
 | 
        wrkMast.setIoType(104); // 入出库状态 
 | 
        wrkMast.setIoPri(13D); // 优先级:13 
 | 
        wrkMast.setSourceStaNo(staDesc.getDeviceStn()); // 源站 
 | 
        wrkMast.setStaNo(staDesc.getStnNo()); // 目标站 
 | 
        wrkMast.setSourceLocNo(param.getLocNo()); // 源库位 
 | 
        wrkMast.setFullPlt("Y"); // 满板:Y 
 | 
        wrkMast.setPicking("Y"); // 拣料 
 | 
        wrkMast.setExitMk("N"); // 退出 
 | 
        wrkMast.setEmptyMk("N"); // 空板 
 | 
        wrkMast.setBarcode(locMast.getBarcode()); 
 | 
        wrkMast.setAppeUser(String.valueOf(getUserId())); // 操作人员数据 
 | 
        wrkMast.setAppeTime(now); 
 | 
        wrkMast.setModiUser(String.valueOf(getUserId())); 
 | 
        wrkMast.setModiTime(now); 
 | 
        wrkMast.setHostId(getHostId()); 
 | 
        wrkMast.setCrnNo(staDesc.getDeviceNo()); 
 | 
        if (!wrkMastService.save(wrkMast)) { 
 | 
            throw new CoolException("保存工作档失败,出库库位号:" + param.getLocNo()); 
 | 
        } 
 | 
        // 生成工作档明细 
 | 
        for (PickMatParam matParam : param.getList()) { 
 | 
            LambdaQueryWrapper<Mat> wrapper = new LambdaQueryWrapper<>(); 
 | 
            wrapper.eq(Mat::getHostId, getHostId()); 
 | 
            wrapper.eq(Mat::getStatus, 1); 
 | 
            wrapper.eq(Mat::getMatnr, matParam.getMatnr()); 
 | 
            Mat mat = matService.getOne(wrapper); 
 | 
            if (mat == null) { 
 | 
                throw new CoolException("保存工作档失败,物料信息不存在:" + matParam.getMatnr()); 
 | 
            } 
 | 
  
 | 
            WrkDetl wrkDetl = new WrkDetl(); 
 | 
            wrkDetl.sync(mat); 
 | 
            wrkDetl.setOrderNo(matParam.getOrderNo()); 
 | 
            wrkDetl.setWrkNo(workNo); 
 | 
            wrkDetl.setIoTime(now); 
 | 
            wrkDetl.setAnfme(matParam.getUseCount()); // 数量 
 | 
            wrkDetl.setAppeTime(now); 
 | 
            wrkDetl.setAppeUser(getUserId()); 
 | 
            wrkDetl.setModiTime(now); 
 | 
            wrkDetl.setModiUser(getUserId()); 
 | 
            wrkDetl.setHostId(getHostId()); 
 | 
            wrkDetl.setWrkMastId(wrkMast.getId()); 
 | 
            if (!wrkDetlService.save(wrkDetl)) { 
 | 
                throw new CoolException("保存工作档明细失败"); 
 | 
            } 
 | 
  
 | 
            //更新订单工作数量 
 | 
            orderDetlService.increaseWorkQtyByOrderNo(matParam.getOrderNo(), matParam.getMatnr(), matParam.getBatch(), matParam.getUseCount(), getHostId()); 
 | 
        } 
 | 
        // 修改库位状态:   F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中 
 | 
        locMast = locMastService.getOne(new LambdaQueryWrapper<LocMast>().eq(LocMast::getLocNo, param.getLocNo()).eq(LocMast::getHostId, getHostId())); 
 | 
        if (locMast.getLocSts().equals("F")) { 
 | 
            locMast.setLocSts("P"); 
 | 
            locMast.setModiUser(getUserId()); 
 | 
            locMast.setModiTime(now); 
 | 
            if (!locMastService.updateById(locMast)) { 
 | 
                throw new CoolException("预约库位状态失败,库位号:" + param.getLocNo()); 
 | 
            } 
 | 
        } else { 
 | 
            throw new CoolException(param.getLocNo() + "库位不是在库状态"); 
 | 
        } 
 | 
  
 | 
        return R.ok(); 
 | 
    } 
 | 
  
 | 
} 
 |