自动化立体仓库 - WMS系统
zhang
2 天以前 848891274b568d3c1402da7cb0d568a65130c3a6
src/main/java/com/zy/asrs/controller/AgvOpenController.java
@@ -7,6 +7,7 @@
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.AgvBasDevp;
import com.zy.asrs.entity.AgvLocMast;
import com.zy.asrs.entity.AgvWrkMast;
import com.zy.asrs.entity.WrkMastExecute;
import com.zy.asrs.entity.param.AgvTaskCallBackParam;
@@ -44,7 +45,7 @@
 *  robot_reach:机器人到达工作站。
 *  weight:称重事件回调。
 *  rfid:RFID识别事件回调。
 *
 * <p>
 * 任务状态(status):
 *  success:成功。
 *  fail:失败。
@@ -83,12 +84,21 @@
        }
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("wrk_no", wrkNo));
        if (Cools.isEmpty(agvWrkMast)) {
            agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", param.getPodCode()));
            if (Cools.isEmpty(agvWrkMast)) {
            //agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", param.getPodCode()));
            //if (Cools.isEmpty(agvWrkMast)) {
                r = R.error("任务编号错误");
                logPost(param, JSONObject.toJSONString(r), false);
                return r;
            //}
        }
        try {
            if (!Cools.isEmpty(agvWrkMast.getBarcode()) && !Cools.isEmpty(param.getPodCode())) {
                if (!agvWrkMast.getBarcode().equals(param.getPodCode())) {
                    log.info("AGV回调的返回的托盘码和工作档托盘不一致,{}{}", agvWrkMast.getBarcode(), param.getPodCode());
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        if (agvWrkMast.getIoType().equals(121)) {
            try {
@@ -174,7 +184,6 @@
        @Transactional
        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
            //修改AGV工作档的工作状态为205.工作完成
            agvWrkMast.setWrkSts(205L);
@@ -195,6 +204,8 @@
            }
            agvWrkMast.setModiTime(new Date());
            agvWrkMastService.updateById(agvWrkMast);
        }
    },
    /**
@@ -254,13 +265,19 @@
            }
            if (agvWrkMast.getIoType() == 108 || agvWrkMast.getIoType() == 114) {
                //更新库存明细
                agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo());
                //修改源库位状态为O
                agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0);
                AgvLocMast agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvWrkMast.getSourceLocNo()));
                if(agvLocMast.getLocSts().equals("R")){
                    //更新库存明细
                    agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo(), agvWrkMast.getAppeUser());
                    //修改源库位状态为O
                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0);
                }
            } else if (agvWrkMast.getIoType() == 109 && !agvWrkMast.getSourceLocNo().substring(0, 2).equals("DB")) {
                //修改源库位状态为O
                agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0);
                AgvLocMast agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvWrkMast.getSourceLocNo()));
                if(agvLocMast.getLocSts().equals("R")){
                    //修改源库位状态为O
                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0);
                }
            }
            //if(agvWrkMast.getIoType() == 1 || agvWrkMast.getIoType() == 53 || agvWrkMast.getIoType() == 57 || agvWrkMast.getIoType() == 10){
            //    //修改源站点状态为O.空,以及解绑托盘条码
@@ -356,6 +373,15 @@
        }
    }
    public static void main(String[] args) {
        try {
            String s = null;
            System.out.println(s.equals("1"));
        }catch (Exception e){
        }
    }
}