| | |
| | | package com.zy.asrs.controller; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.core.annotations.AppAuth; |
| | | import com.core.common.Cools; |
| | |
| | | @AppAuth(memo = "ESS任务回调") |
| | | public R taskEventStaus(@RequestBody AgvTaskCallBackParam param, HttpServletRequest request){ |
| | | |
| | | //save api log (appkey 后续添加) |
| | | AppAuthUtil.auth("test-appkey",param, request); |
| | | apiLogService.save( |
| | | "ESS任务回调", |
| | | "/tzskwms/agv/task/event/status", |
| | | null, |
| | | null, |
| | | JSON.toJSONString(JSONObject.toJSONString(param)), |
| | | null, |
| | | true |
| | | ); |
| | | |
| | | AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("wrk_no", param.getTaskCode())); |
| | | |
| | | //save api log (appkey 后续添加) |
| | | |
| | | AppAuthUtil.auth("",param, request); |
| | | int wrkNo = Integer.parseInt(param.getTaskCode()); |
| | | if(wrkNo < 0){ |
| | | wrkNo = -wrkNo; |
| | | } |
| | | AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("wrk_no", wrkNo)); |
| | | if(Cools.isEmpty(agvWrkMast)){ |
| | | return R.error("任务编号错误"); |
| | | } |
| | | |
| | | if(!checkParam(param,agvWrkMast)){ |
| | | return R.error("任务参数与工作档参数不符合"); |
| | | } |
| | | |
| | | AgvTask agvTask = AgvTask.valueOf(param.getEventType()); |
| | |
| | | return R.ok(); |
| | | } |
| | | |
| | | private boolean checkParam(AgvTaskCallBackParam param, AgvWrkMast agvWrkMast){ |
| | | if(!agvWrkMast.getLocNo().equals(param.getLocationCode())){ |
| | | return false; |
| | | } |
| | | if(!agvWrkMast.getSourceLocNo().equals(param.getStationCode())){ |
| | | return false; |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | } |
| | | |