自动化立体仓库 - WCS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
luxiaotao1123
2022-01-06 006ca71bd84497f2ff53630a3f9257f7a6e29391 
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java


@@ -4,6 +4,7 @@


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.baomidou.mybatisplus.mapper.Wrapper;


import com.core.common.Cools;


import com.core.common.DateUtils;


import com.core.exception.CoolException;


import com.zy.asrs.domain.enums.WorkNoType;


import com.zy.asrs.entity.*;


@@ -57,8 +58,8 @@


@Transactional


public class MainServiceImpl {




    @Autowired


    private RowLastnoService rowLastnoService;




    public static final long COMMAND_TIMEOUT = 5 * 1000;




    @Autowired


    private CommonService commonService;


@@ -99,10 +100,17 @@


            for (DevpSlave.Sta inSta : devp.getInSta()) {


                // 获取条码扫描仪信息


                BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode());


                if (barcodeThread == null) {


                    continue;


                }


                String barcode = barcodeThread.getBarcode();


                if(!Cools.isEmpty(barcode)) {


                    System.err.println(barcode);


                    log.info("{}号条码扫描器检测条码信息：{}", inSta.getBarcode(), barcode);


                    if("NG".endsWith(barcode) || "NoRead".equals(barcode)) {


                        continue;


                    }


                }




                // 获取入库站信息


                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());


                StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());


@@ -114,7 +122,7 @@


                // 判断是否满足入库条件


                if (staProtocol.isAutoing() && staProtocol.isLoading()


                        && staProtocol.isInEnable()


                        && !staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 0


                        && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() == 9999)


                        && staProtocol.isPakMk() && !Cools.isEmpty(barcode)) {




                    // 判断重复工作档


@@ -219,8 +227,8 @@


                    staProtocol = staProtocol.clone();


                }


                // 判断是否满足入库条件


                if (staProtocol.isAutoing() && staProtocol.isLoading()


                        && !staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 0


                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()


                        && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() == 9999)


                        && staProtocol.isPakMk()) {


                    // 判断重复工作档


                    WrkMast wrkMast = wrkMastMapper.selectPakInStep11(inSta.getStaNo());


@@ -279,14 +287,24 @@


                        || Cools.isEmpty(wrkMast.getStaNo()) || Cools.isEmpty(wrkMast.getSourceStaNo()) ) {


                        continue;


                    }




                    // 拣、盘、并 作业站转换


//                    int stnNo = 0;


//                    if (wrkMast.getStaNo() == 109) {


//                        stnNo = 127;


//                    } else if (wrkMast.getStaNo() == 113) {


//                        stnNo = 128;


//                    } else {


//                        log.error("{}号任务数据异常！", wrkMast.getWrkNo());


//                    }


                    // 获取目标站


                    Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()


                            .eq("type_no", wrkMast.getIoType() - 50)


                            .eq("stn_no", wrkMast.getStaNo()) // 作业站点 = 拣料出库的目标站


                            .eq("stn_no", pickSta.getStaNo()) // 作业站点 = 拣料出库的目标站


                            .eq("crn_no", wrkMast.getCrnNo()); // 堆垛机号


                    StaDesc staDesc = staDescService.selectOne(wrapper);


                    if (Cools.isEmpty(staDesc)) {


                        log.error("入库路径不存在");


                        log.error("入库路径不存在！type_no={},stn_no={},crn_no={}", wrkMast.getIoType(), pickSta.getStaNo(), wrkMast.getCrnNo());


                        continue;


                    }




@@ -377,7 +395,7 @@


                    }


                    //  判断堆垛机状态等待确认


                    if (crnProtocol.modeType == CrnModeType.AUTO && crnProtocol.getTaskNo().equals(wrkMast.getWrkNo().shortValue())


                            && crnProtocol.getTaskFinish() == 1  // todo:luxiaotao 等待确认


                            && crnProtocol.statusType == CrnStatusType.WAITING


                            && crnProtocol.forkPosType == CrnForkPosType.HOME) {




                        // 命令下发区 --------------------------------------------------------------------------


@@ -409,8 +427,7 @@


    /**


     * 入出库  ===>>  堆垛机入出库作业下发


     */


    @Async


    public void crnIoExecute(){


    public synchronized void crnIoExecute(){


        for (CrnSlave crn : slaveProperties.getCrn()) {


            // 获取堆垛机信息


            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());


@@ -452,7 +469,6 @@


    /**


     * 入库  ===>>  堆垛机站到库位


     */


    @Async


    public void crnStnToLoc(CrnSlave slave, CrnProtocol crnProtocol){


        for (CrnSlave.CrnStn crnStn : slave.getCrnInStn()) {


            boolean flag = false;


@@ -478,9 +494,9 @@


                continue;


            }


            // 获取工作状态为2（设备上走）的入库工作档


            WrkMast wrkMast = wrkMastMapper.selectPakInStep2(slave.getId(), staProtocol.getWorkNo().intValue());


            WrkMast wrkMast = wrkMastMapper.selectPakInStep2(slave.getId(), staProtocol.getWorkNo().intValue(), crnStn.getStaNo());


            if(null == wrkMast) {


                log.error("查询无待入库数据--wrk_sts=2, 工作号={}", staProtocol.getWorkNo());


//                log.error("查询无待入库数据--wrk_sts=2, 工作号={}", staProtocol.getWorkNo());


                continue;


            }


            // 获取库位信息


@@ -499,6 +515,11 @@


                continue;


            }




            // 已经存在吊车执行任务时，则过滤


            if (wrkMastMapper.selectWorking(slave.getId()) != null) {


                return;


            }




            // 命令下发区 --------------------------------------------------------------------------


            CrnCommand crnCommand = new CrnCommand();


            crnCommand.setCrnNo(slave.getId()); // 堆垛机编号


@@ -514,6 +535,19 @@


            if (!MessageQueue.offer(SlaveType.Crn, wrkMast.getCrnNo(), new Task(2, crnCommand))) {


                log.error("堆垛机命令下发失败，堆垛机号={}，任务数据={}", wrkMast.getCrnNo(), JSON.toJSON(crnCommand));


            } else {




//                long startTime = System.currentTimeMillis();


//                while ((System.currentTimeMillis() - startTime) < COMMAND_TIMEOUT) {


//


//                    if (true) {


//                        break;


//                    }


//


//                    try{


//                        Thread.sleep(500);


//                    }catch(Exception ignore){}


//                }




                // 修改工作档状态 2.设备上走 => 3.吊车入库中


                Date now = new Date();


                wrkMast.setWrkSts(3L);


@@ -529,11 +563,10 @@


    /**


     * 出库  ===>>  库位到堆垛机站


     */


    @Async


    public void locToCrnStn(CrnSlave slave, CrnProtocol crnProtocol){


        for (CrnSlave.CrnStn crnStn : slave.getCrnOutStn()) {


            // 获取工作状态为11（生成出库ID）的出库工作档


            WrkMast wrkMast = wrkMastMapper.selectPakOutStep1(slave.getId());


            WrkMast wrkMast = wrkMastMapper.selectPakOutStep1(slave.getId(), crnStn.getStaNo());


            if (wrkMast == null) {


                continue;


            }


@@ -573,8 +606,8 @@


                }




                // 双深库位且浅库位有货，则需先对浅库位进行库位移转


                if (Utils.isDeepLoc(slaveProperties, wrkMast.getLocNo())) {


                    String shallowLocNo = Utils.getShallowLoc(slaveProperties, wrkMast.getLocNo());


                if (Utils.isDeepLoc(slaveProperties, wrkMast.getSourceLocNo())) {


                    String shallowLocNo = Utils.getShallowLoc(slaveProperties, wrkMast.getSourceLocNo());


                    LocMast shallowLoc = locMastService.selectById(shallowLocNo);


                    // O.空库位、Q.拣料/盘点/并板再入库、S.入库预约、X.禁用 直接搬！


                    if (shallowLoc.getLocSts().equals("P") || shallowLoc.getLocSts().equals("R")) {


@@ -599,6 +632,11 @@


                        }


                        continue;


                    }


                }




                // 已经存在吊车执行任务时，则过滤


                if (wrkMastMapper.selectWorking(slave.getId()) != null) {


                    return;


                }




                // 1.堆垛机开始移动


@@ -632,7 +670,7 @@


    /**


     * 库位移转


     */


    public synchronized void locToLoc(CrnSlave slave, CrnProtocol crnProtocol){


    public void locToLoc(CrnSlave slave, CrnProtocol crnProtocol){


        // 获取工作档信息


        WrkMast wrkMast = wrkMastMapper.selectLocMove(slave.getId());


        if (null == wrkMast) {


@@ -662,6 +700,11 @@




        // 堆垛机控制过滤


        if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {


            return;


        }




        // 已经存在吊车执行任务时，则过滤


        if (wrkMastMapper.selectLocMoving(slave.getId()) != null) {


            return;


        }




@@ -703,8 +746,7 @@


            CrnProtocol crnProtocol = crnThread.getCrnProtocol();


            if (crnProtocol == null) { continue; }


            //  状态：等待确认 并且  任务完成位 = 1


            if (crnProtocol.getTaskFinish() == 1    // todo:luxiaotao 等待确认


                    && crnProtocol.getTaskNo() != 0) {


            if (crnProtocol.statusType == CrnStatusType.WAITING && crnProtocol.getTaskNo() != 0) {


                // 获取入库待确认工作档


                WrkMast wrkMast = wrkMastMapper.selectPakInStep3(crnProtocol.getTaskNo().intValue());


                if (wrkMast == null) {


@@ -750,13 +792,13 @@


                    BasErrLog latest = basErrLogService.findLatestByTaskNo(crn.getId(), crnProtocol.getTaskNo().intValue());


                    // 有异常


                    if (latest == null) {


                        if (crnProtocol.getAlarm1() != null && crnProtocol.getAlarm1() > 0) {


                        if (crnProtocol.getAlarm() != null && crnProtocol.getAlarm() > 0) {


                            WrkMast wrkMast = wrkMastMapper.selectById(crnProtocol.getTaskNo());


                            if (wrkMast == null) {


                                continue;


                            }


                            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());


                            String errName = crnError==null? String.valueOf(crnProtocol.getAlarm1()):crnError.getErrName();


                            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm());


                            String errName = crnError==null? String.valueOf(crnProtocol.getAlarm()):crnError.getErrName();


                            BasErrLog basErrLog = new BasErrLog(


                                    null,    // 编号


                                    wrkMast.getWrkNo(),    // 工作号


@@ -771,7 +813,7 @@


                                    wrkMast.getSourceStaNo(),    // 源站


                                    wrkMast.getSourceLocNo(),    // 源库位


                                    wrkMast.getBarcode(),    // 条码


                                    crnProtocol.getAlarm1(),    // 异常码


                                    (int) crnProtocol.getAlarm(),    // 异常码


                                    errName,    // 异常


                                    1,    // 异常情况


                                    now,    // 添加时间


@@ -786,7 +828,7 @@


                        }


                    } else {


                        // 异常修复


                        if (crnProtocol.getAlarm1() == null || crnProtocol.getAlarm1() == 0) {


                        if (crnProtocol.getAlarm() == null || crnProtocol.getAlarm() == 0) {


                            latest.setEndTime(now);


                            latest.setUpdateTime(now);


                            latest.setStatus(2);


@@ -799,11 +841,11 @@


                } else {


                    BasErrLog latest = basErrLogService.findLatest(crn.getId());


                    // 有异常


                    if (crnProtocol.getAlarm1() != null && crnProtocol.getAlarm1() > 0) {


                    if (crnProtocol.getAlarm() != null && crnProtocol.getAlarm() > 0) {


                        // 记录新异常


                        if (latest == null || (latest.getErrCode() != crnProtocol.getAlarm1().intValue())) {


                            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());


                            String errName = crnError==null? String.valueOf(crnProtocol.getAlarm1()):crnError.getErrName();


                        if (latest == null || (latest.getErrCode() != crnProtocol.getAlarm().intValue())) {


                            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm());


                            String errName = crnError==null? String.valueOf(crnProtocol.getAlarm()):crnError.getErrName();


                            BasErrLog basErrLog = new BasErrLog(


                                    null,    // 编号


                                    null,    // 工作号


@@ -818,7 +860,7 @@


                                    null,    // 源站


                                    null,    // 源库位


                                    null,    // 条码


                                    crnProtocol.getAlarm1(),    // 异常码


                                    (int)crnProtocol.getAlarm(),    // 异常码


                                    errName,    // 异常


                                    1,    // 异常情况


                                    now,    // 添加时间


@@ -870,7 +912,7 @@


                }


                // 站点条件判断


                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()


                        && staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 0 && staProtocol.isPakMk()) {


                        && staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() == 9999 || staProtocol.getWorkNo() == 9990 || staProtocol.getWorkNo() == 9997) && staProtocol.isPakMk()) {


                    // 检索库位


                    LocTypeDto locTypeDto = new LocTypeDto(staProtocol);


                    StartupDto startupDto = commonService.getLocNo(1, 10, emptyInSta.getStaNo(), null, locTypeDto, 0);


@@ -1050,7 +1092,7 @@


            // 获取led线程


            LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getDevpPlcId());


            // led显示默认内容


            if (!ledThread.isResetStatus() && reset) {


            if (reset) {


                if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(2, new ArrayList<>()))) {


                    log.error("{}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort());


                }


@@ -1149,77 +1191,138 @@


    /**


     * 堆垛机演示  ===>> 库位移转


     */


    @Async


    public void crnDemoOfLocMove(Integer crn){


        for (int i = 0; i < 5; i++) {


    public synchronized void crnDemoOfLocMove1(){


        for (CrnSlave crn : slaveProperties.getCrn()) {


            if (!crn.getDemo()) { continue; }   // 必须为演示状态




            LocMast sourceLoc = locMastService.queryDemoSourceLoc(crn);


            LocMast loc = locMastService.queryDemoLoc(crn);


            if (null == sourceLoc || null == loc) {


                break;


            }


            String sourceLocNo = sourceLoc.getLocNo();


            String locNo = loc.getLocNo();


            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());


            CrnProtocol crnProtocol = crnThread.getCrnProtocol();


            if (crnProtocol == null) { continue; }




            // 获取工作号


            int workNo = commonService.getWorkNo(WorkNoType.PICK.type);


            // 保存工作档


            WrkMast wrkMast = new WrkMast();


            wrkMast.setWrkNo(workNo);


            wrkMast.setIoTime(new Date());


            wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID


            wrkMast.setIoType(11); // 入出库状态： 11.库格移载


            wrkMast.setIoPri(13D);


            wrkMast.setCrnNo(crn);


            wrkMast.setSourceLocNo(sourceLocNo); // 源库位


            wrkMast.setLocNo(locNo); // 目标库位


            wrkMast.setFullPlt("N"); // 满板：Y


            wrkMast.setPicking("N"); // 拣料


            wrkMast.setExitMk("N"); // 退出


            wrkMast.setEmptyMk(sourceLoc.getLocSts().equals("D")?"Y":"N"); // 空板


            wrkMast.setBarcode(sourceLoc.getBarcode()); // 托盘码


            wrkMast.setLinkMis("N");


            wrkMast.setAppeTime(new Date());


            wrkMast.setModiTime(new Date());


            int res = wrkMastMapper.insert(wrkMast);


            if (res == 0) {


                throw new CoolException("保存工作档失败");


            }


            // 工作档明细保存


            List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", sourceLocNo));


            for (LocDetl locDetl : locDetls) {


                WrkDetl wrkDetl = new WrkDetl();


                wrkDetl.setWrkNo(workNo);


                wrkDetl.setIoTime(new Date());


                wrkDetl.setAnfme(locDetl.getAnfme());


                VersionUtils.setWrkDetl(wrkDetl, locDetl); // 版本控制


                wrkDetl.setAppeTime(new Date());


                wrkDetl.setModiTime(new Date());


                if (!wrkDetlService.insert(wrkDetl)) {


                    throw new CoolException("保存工作档明细失败");


            // 只有当堆垛机空闲 并且 无任务时才继续执行


            if (crnProtocol.getStatusType() == CrnStatusType.IDLE && crnProtocol.getTaskNo() == 0 && crnProtocol.getModeType() == CrnModeType.AUTO) {


                // 获取移库工作档信息


                WrkMast wrkMast = wrkMastMapper.selectLocMove(crn.getId());


                if (null != wrkMast) { continue; }




                LocMast sourceLoc = locMastService.queryDemoSourceLoc(crn.getId());


                LocMast loc = locMastService.queryDemoLoc(crn.getId());


                if (null == sourceLoc || null == loc) { continue; }




                String sourceLocNo = sourceLoc.getLocNo();


                String locNo = loc.getLocNo();




                // 获取工作号


                int workNo = commonService.getWorkNo(WorkNoType.PICK.type);


                // 保存工作档


                wrkMast = new WrkMast();


                wrkMast.setWrkNo(workNo);


                wrkMast.setIoTime(new Date());


                wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID


                wrkMast.setIoType(11); // 入出库状态： 11.库格移载


                wrkMast.setIoPri(13D);


                wrkMast.setCrnNo(crn.getId());


                wrkMast.setSourceLocNo(sourceLocNo); // 源库位


                wrkMast.setLocNo(locNo); // 目标库位


                wrkMast.setFullPlt("N"); // 满板：Y


                wrkMast.setPicking("N"); // 拣料


                wrkMast.setExitMk("N"); // 退出


                wrkMast.setEmptyMk(sourceLoc.getLocSts().equals("D")?"Y":"N"); // 空板


                wrkMast.setBarcode(sourceLoc.getBarcode()); // 托盘码


                wrkMast.setLinkMis("N");


                wrkMast.setAppeTime(new Date());


                wrkMast.setModiTime(new Date());


                int res = wrkMastMapper.insert(wrkMast);


                if (res == 0) {


                    throw new CoolException("保存工作档失败");


                }


            }


            // 修改源库位状态


            if (sourceLoc.getLocSts().equals("D") || sourceLoc.getLocSts().equals("F")) {


                sourceLoc.setLocSts("R"); // R.出库预约


                sourceLoc.setModiTime(new Date());


                if (!locMastService.updateById(sourceLoc)){


                    throw new CoolException("更新源库位状态失败");


                // 工作档明细保存


                List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", sourceLocNo));


                for (LocDetl locDetl : locDetls) {


                    WrkDetl wrkDetl = new WrkDetl();


                    wrkDetl.setWrkNo(workNo);


                    wrkDetl.setIoTime(new Date());


                    wrkDetl.setAnfme(locDetl.getAnfme());


                    VersionUtils.setWrkDetl(wrkDetl, locDetl); // 版本控制


                    wrkDetl.setAppeTime(new Date());


                    wrkDetl.setModiTime(new Date());


                    if (!wrkDetlService.insert(wrkDetl)) {


                        throw new CoolException("保存工作档明细失败");


                    }


                }


            } else {


                throw new CoolException("源库位出库失败");


            }


            // 修改目标库位状态


            if (loc.getLocSts().equals("O")) {


                loc.setLocSts("S"); // S.入库预约


                loc.setModiTime(new Date());


                if (!locMastService.updateById(loc)) {


                    throw new CoolException("更新目标库位状态失败");


                // 修改源库位状态


                if (sourceLoc.getLocSts().equals("D") || sourceLoc.getLocSts().equals("F")) {


                    sourceLoc.setLocSts("R"); // R.出库预约


                    sourceLoc.setModiTime(new Date());


                    if (!locMastService.updateById(sourceLoc)){


                        throw new CoolException("更新源库位状态失败");


                    }


                } else {


                    throw new CoolException("源库位出库失败");


                }


            } else {


                throw new CoolException("移转失败");


                // 修改目标库位状态


                if (loc.getLocSts().equals("O")) {


                    loc.setLocSts("S"); // S.入库预约


                    loc.setModiTime(new Date());


                    if (!locMastService.updateById(loc)) {


                        throw new CoolException("更新目标库位状态失败");


                    }


                } else {


                    throw new CoolException("移转失败");


                }




            }




        }


    }




    /**


     * 堆垛机命令下发后，异步修改工作档状态


     */


    public synchronized void crnIoWrkMast(){


        for (CrnSlave crn : slaveProperties.getCrn()) {


            // 获取堆垛机信息


            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());


            CrnProtocol crnProtocol = crnThread.getCrnProtocol();


            if (crnProtocol == null) {


                continue;


            }


            Date now = new Date();


            // 堆垛机正在运行


            if (crnProtocol.getStatusType() != CrnStatusType.IDLE && crnProtocol.getTaskNo() != 0 && crnProtocol.getModeType() == CrnModeType.AUTO) {


                // 获取工作档


                WrkMast wrkMast = wrkMastMapper.selectById(crnProtocol.getTaskNo());


                if (wrkMast == null) { continue; }


                // 入库


                if (wrkMast.getWrkSts() == 1 || wrkMast.getWrkSts() == 2) {


                    log.warn("堆垛机非空闲情况下，开始修改工作档状态。[id:{},时间：{}] >>>>> 堆垛机当前状态为：{}。任务号:{}", crn.getId(), DateUtils.convert(now, DateUtils.yyyyMMddHHmmsssss_F), crnProtocol.getStatusType().desc, crnProtocol.getTaskNo());


                    // 修改工作档状态 2.设备上走 => 3.吊车入库中


                    wrkMast.setWrkSts(3L);


                    wrkMast.setCrnStrTime(now);


                    wrkMast.setModiTime(now);


                    if (wrkMastMapper.updateById(wrkMast) == 0) {


                        log.error("修改工作档状态 2.设备上走 => 3.吊车入库中 失败！！，工作号={}", wrkMast.getWrkNo());


                    }


                    log.warn("修改工作档状态成功。[时间：{}] >>>>> 任务号:{}",  DateUtils.convert(now, DateUtils.yyyyMMddHHmmsssss_F),  wrkMast.getWrkNo());


                }


                // 出库、移库


                if (wrkMast.getWrkSts() == 11) {


                    log.warn("堆垛机非空闲情况下，开始修改工作档状态。[id:{},时间：{}] >>>>> 堆垛机当前状态为：{}。任务号:{}", crn.getId(), DateUtils.convert(now, DateUtils.yyyyMMddHHmmsssss_F), crnProtocol.getStatusType().desc, crnProtocol.getTaskNo());


                    // 修改工作档状态 11.生成出库ID => 12.吊车出库中


                    wrkMast.setWrkSts(12L);


                    wrkMast.setCrnStrTime(now);


                    wrkMast.setModiTime(now);


                    if (wrkMastMapper.updateById(wrkMast) == 0) {


                        log.error("修改工作档状态 11.生成出库ID => 12.吊车出库中 失败！！，工作号={}", wrkMast.getWrkNo());


                    }


                    log.warn("修改工作档状态成功。[时间：{}] >>>>> 任务号:{}",  DateUtils.convert(now, DateUtils.yyyyMMddHHmmsssss_F),  wrkMast.getWrkNo());


                }






            }




        }


    }






}