#1。档案同步2，任务状态上报，3设备状态读取，4心跳，5wms手动完成取消任务

lty

18 小时以前 caa7a2327123cc070ae16ad802983c04e296ff11

 src/main/java/com/zy/asrs/controller/OpenController.java

@@ -1,11 +1,16 @@
package com.zy.asrs.controller;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.annotations.AppAuth;
import com.core.annotations.ManagerAuth;
import com.core.common.*;
import com.core.exception.CoolException;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.param.*;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.WorkService;
import com.zy.asrs.service.impl.WrkMastServiceImpl;
import com.zy.common.model.DetlDto;
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
@@ -16,6 +21,8 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.HashMap;

/**
 * Created by vincent on 2022/4/8
@@ -34,6 +41,10 @@

    @Autowired
    private OpenService openService;
    @Autowired
    private WorkService workService;
    @Autowired
    private WrkMastServiceImpl wrkMastService;

    @PostMapping("/order/matSync/default/v2")
//    @AppAuth(memo = "商品信息同步接口")
@@ -249,6 +260,9 @@
        if (Cools.isEmpty(param.getStaNo())) {
            return R.error("分拣点位[staNo]不能为空");
        }
        if (Cools.isEmpty(param.getBindingTags())) {
            return R.error("分拣绑定类别[bindingTags]不能为空");
        }
        openService.taskArmReport(param);
        return R.ok();
    }
@@ -397,4 +411,59 @@
        return R.ok().add(taskArmWorkOrderSign);
    }


    /**
     * 分拣线上报接收
     */
    @PostMapping("/agv/task/v1")
    @AppAuth(memo = "AGV上报接收")
    public synchronized R TaskAgvReport(@RequestHeader(required = false) String appkey,
                                        @RequestBody TaskAgvReportParam param,
                                        HttpServletRequest request) {
        auth(appkey, param, request);
        if (Cools.isEmpty(param)) {
            return R.parse(BaseRes.PARAM);
        }
        if (Cools.isEmpty(param.getReqCode())) {
            return R.error("WMS任务号[reqCode]不能为空");
        }
        String reqCode = param.getReqCode();
        String[] split = reqCode.split("-");
        param.setTaskNo(Integer.parseInt(split[0]));
//        if (Cools.isEmpty(param.getTimestamp())) {
//            return R.error("RGV任务号[timestamp]不能为空");
//        }
        boolean taskAgvReport = openService.TaskAgvReport(param);
        if (taskAgvReport){
            return R.ok();
        }
        return R.error("任务号不存在");
    }

    /**
     * 心跳接口
     */
    @PostMapping("/wmsHeartbeat")
    public R heartbeat(@RequestBody Map<String, Object> param) {
        if (param != null && param.get("timeStamp") != null) {
            return R.ok("操作成功");
        }
        return R.error("失败");
    }

    @RequestMapping("/taskCancel")
    @ManagerAuth(memo = "手动处理工作档")
    public R handControlWrkMast(@RequestHeader(required = false) String appkey,@RequestBody TaskCancelParam taskCancelParam,HttpServletRequest request){
        auth(appkey, taskCancelParam, request);

        if (taskCancelParam.getTaskStatus() == 2) {
            workService.completeWrkMast(taskCancelParam.getTaskNo(),null);
            return R.ok("工作档已完成");
        } else if (taskCancelParam.getTaskStatus() == 1) {
            workService.cancelWrkMast(taskCancelParam.getTaskNo(), null);
            return R.ok("工作档已取消");
        }
        return R.ok();
    }

}