#

zwl

2025-07-19 6193eddf242c4b879402367704b8b5b2e8df84a4

 src/main/java/com/zy/asrs/task/AssignTasksRCSScheduler.java

@@ -32,35 +32,41 @@
    private String wcsmovePath;
    @Value("${wcs.outboundTaskRequest}")
    private String wcsoutboundTaskRequest;
    @Value("${wcs.inboundTaskApplyPathWcs}")
    private String inboundTaskApplyPathWcs;
    @Value("${wms.TaskExecCallback}")
    private String TaskExecCallback;
    @Value("${wms.taskStatusFeedbackPath}")
    private String taskStatusFeedbackPath;

    /**
     * 自动派发出库任务给RCS
     * 自动派发任务给RCS
     *
     * @throws IOException
     */
    @Scheduled(cron = "0/3 * * * * ? ")
    public void execute() throws IOException {
        if(true){
        if(false){
            List<TaskWrk> taskWrks=taskWrkService.selectList(new EntityWrapper<TaskWrk>()
                    .eq("wrk_sts",1).eq("io_type",3));
                    .eq("wrk_sts",1));
            for(TaskWrk taskWrk:taskWrks){
                HashMap<String, Object> headParam = new HashMap<>();
                String response = "";
                Boolean bool = false;
                String dz="";
                if(taskWrk.getIoType()==2){
                if(taskWrk.getIoType()==1){//入库
                    dz=inboundTaskApplyPathWcs;
                    headParam.put("sourceStaNo", taskWrk.getStartPoint());//源站
                    headParam.put("staNo", taskWrk.getTargetPoint());//目标站
                }else if(taskWrk.getIoType()==2){//出库
                    dz=wcsoutboundTaskRequest;
                }else{
                }else if(taskWrk.getIoType()==3){//移库
                    dz=wcsmovePath;
                    headParam.put("sourceLocNo",taskWrk.getStartPoint());//源库位
                }
                try {
                    headParam.put("taskNo", taskWrk.getTaskNo());
                    headParam.put("sourceLocNo",taskWrk.getStartPoint());//源库位
                    headParam.put("locNo",taskWrk.getTargetPoint());//目标库位
                    headParam.put("locNo",taskWrk.getOriginTargetPoint());//目标库位
                    log.info("wcs派发任务给RCS出库={}", taskWrk);
                    response = new HttpHandler.Builder()
                            // .setHeaders(headParam)
@@ -71,8 +77,14 @@
                            .doPost();
                    JSONObject jsonObject = JSON.parseObject(response);
                    if(jsonObject.get("code").equals(200)){
                        //派发出库任务给RCS==>成功下发出库任务
                        taskWrk.setWrkSts(2);
                        //派发任务给RCS==>成功下发出库任务
                        if(taskWrk.getIoType()==1){
                            taskWrk.setWrkSts(3);
                        }else if(taskWrk.getIoType()==2){
                            taskWrk.setWrkSts(12);
                        }else if(taskWrk.getIoType()==3){
                            taskWrk.setWrkSts(3);
                        }
                        taskWrkService.updateById(taskWrk);
                        bool = true;
                    }