#

野心家

2025-03-14 e2d6a43d4f7d083233896755573d2c55444fb66f

 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -233,6 +233,7 @@
                                            MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                            HashMap<String, Object> hashMap = new HashMap<>();
                                            hashMap.put("TaskNo", taskWrk.getTaskNo());
                                            Boolean bool = false;
                                            try {
                                                //开始上报,任务开始时，WCS回调WMS
                                                response = new HttpHandler.Builder()
@@ -242,10 +243,14 @@
                                                        .build()
                                                        .doPost();
                                                JSONObject jsonObject1 = JSON.parseObject(response);
                                                Boolean bool = false;

                                                if (jsonObject1.get("ReturnStatus").equals(0)) {
                                                    bool = true;
                                                }

                                            } catch (Exception e) {

                                            }finally {
                                                apiLogService.save("wcs开始入库任务上报wms"
                                                        , wmsUrl + TaskExecCallback
                                                        , null
@@ -254,8 +259,6 @@
                                                        , response
                                                        , bool
                                                );
                                            } catch (Exception e) {

                                            }
                                        }
                                    } else {
@@ -355,7 +358,7 @@
                            if (offer) {
                                log.info("下发输送线任务成功：taskWrk:" + JSON.toJSONString(taskWrk));
                                taskWrk.setStatus(5);
                                taskWrk.setWrkSts(14);
                                taskWrk.setWrkSts(16);
                                taskWrkService.updateById(taskWrk);

                            } else {
@@ -441,7 +444,7 @@

                    if(jsonObject.get("code").equals(200)){
                        bool = true;
                        taskWrk.setStatus(TaskStatusType.DISTRIBUTE.id);//派发状态
//                        taskWrk.setStatus(TaskStatusType.DISTRIBUTE.id);//派发状态
                        taskWrk.setAssignTime(new Date());//派发时间
                        taskWrk.setWrkSts(3);//工作状态 3.成功下发入库任务给RCS
                        taskWrk.setCrnNo(staDesc.getCrnNo());//堆垛机号
@@ -518,6 +521,46 @@
                            break;
                        }

                        String mbz=taskWrk.getTargetPoint().substring(5);

                        HashMap<String, Object> hashMap = new HashMap<>();
                        hashMap.put("taskNo",taskWrk.getTaskNo());//wms任务号
                        hashMap.put("sourceStaNo",staDetl.getDevNo());//源站点
                        hashMap.put("staNo",Integer.parseInt(mbz)+"");//目标站
                        hashMap.put("locNo",taskWrk.getTargetPoint());//目标库位
                        String response = "";
                        Boolean bool = false;
                        try {
                            //开始上报,出库任务开始时，WCS回调WMS
                            response = new HttpHandler.Builder()
                                    .setUri(wcsUrl)
                                    .setPath(wcsInboundTaskApplyPath)
                                    .setJson(JSON.toJSONString(hashMap))
                                    .build()
                                    .doPost();
                            JSONObject jsonObject = JSON.parseObject(response);

                            if(jsonObject.get("code").equals(200)){
                                bool = true;
//                        taskWrk.setStatus(TaskStatusType.DISTRIBUTE.id);//派发状态
                                taskWrk.setAssignTime(new Date());//派发时间
                                taskWrk.setWrkSts(3);//工作状态 3.成功下发入库任务给RCS
                                taskWrk.setCrnNo(staDesc.getCrnNo());//堆垛机号
                                taskWrk.setModiTime(new Date());
                                taskWrk.setModiUser(9988L);
                            }
                        } catch (Exception e) {
                        }finally {
                            apiLogService.save("wcs派发出库任务给RCS"
                                    , wcsUrl + wcsInboundTaskApplyPath
                                    , null
                                    , "127.0.0.1"
                                    , JSON.toJSONString(hashMap)
                                    , response
                                    , bool
                            );
                        }

                        try {
                            // 修改工作档状态 11.生成出库ID => 12.吊车出库中
                            Date now = new Date();