| | |
|---|
| | | @PostMapping("/service/rest/agvCallbackService/warnCallback") |
|---|
| | | @AppAuth(memo = "AGV告警回调") |
|---|
| | | public Object taskEventStaus(@RequestBody AgvWarnCallBackParam param, HttpServletRequest request) { |
|---|
| | | log.info("AGV告警回调:{}", JSON.toJSONString(param)); |
|---|
| | | //og.info("AGV告警回调:{}", JSON.toJSONString(param)); |
|---|
| | | AppAuthUtil.auth("", param, request); |
|---|
| | | List<AgvWarnBody> agvWarnBodies = param.getData(); |
|---|
| | | // List<AgvWarnBody> agvWarnBodies = JSONArray.parseArray(data, AgvWarnBody.class); |
|---|
| | |
|---|
| | | List<AgvWarn> agvWarns = new ArrayList<>(); |
|---|
| | | List<AgvWarn> updates = new ArrayList<>(); |
|---|
| | | for (AgvWarnBody body : agvWarnBodies) { |
|---|
| | | List<AgvWarn> agvWarnList = agvWarnService.selectList(new EntityWrapper<AgvWarn>().eq("robot_code", body.getRobotCode()).eq("begin_time", body.getBeginDate()).eq("warn_content", body.getWarnContent())); |
|---|
| | | List<AgvWarn> agvWarnList = agvWarnService.selectList(new EntityWrapper<AgvWarn>().eq("robot_code", body.getRobotCode()).eq("warn_content", body.getWarnContent())); |
|---|
| | | if (Cools.isEmpty(agvWarnList)) { |
|---|
| | | agvWarn = new AgvWarn(); |
|---|
| | | agvWarn.setBeginTime(body.getBeginDate()); |
|---|
| | |
|---|
| | | |
|---|
| | | private void logPost(String param, String response, boolean success) { |
|---|
| | | apiLogService.save( |
|---|
| | | "ESS任务回调", |
|---|
| | | "ESS小车报警回调", |
|---|
| | | "/phyzwms/agv/task/event/status", |
|---|
| | | null, |
|---|
| | | null, |
|---|
