From bc9cc84b5d074076692eedf4951584bb17f8985f Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期四, 29 一月 2026 16:38:07 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/controller/OpenController.java | 107 +++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 103 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 7370663..7028f51 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -1,7 +1,9 @@
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.ManagerAuth;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.BasStationTv;
@@ -16,6 +18,8 @@
import com.zy.asrs.utils.StationUtils;
import com.zy.asrs.utils.Utils;
import com.zy.common.utils.RedisUtil;
+import com.zy.system.entity.Announcement;
+import com.zy.system.service.AnnouncementService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
@@ -40,6 +44,8 @@
private StationUtils stationUtils;
@Autowired
private RedisUtil redisUtil;
+ @Autowired
+ private AnnouncementService announcementService;
@Value("${app.version:1.0.0}")
private String appVersion;
@@ -61,21 +67,28 @@
@GetMapping("/getLedInfos")
public R getLedInfos(HttpServletRequest request) {
+ HashMap<String, Object> map = new HashMap<>();
String remoteAddr = request.getRemoteAddr();
TvDevice tvDevice = tvDeviceService.selectOne(
new EntityWrapper<TvDevice>().eq("ip", remoteAddr));
if (tvDevice == null) {
return R.error("鏈壘鍒癐P瀵瑰簲鐨勭數瑙嗘満璁惧: " + remoteAddr);
}
+ map.put("deviceName", tvDevice.getName());
List<BasStationTv> relations = basStationTvService
.selectList(new EntityWrapper<BasStationTv>().eq("tv_id", tvDevice.getId()));
if (relations == null || relations.isEmpty()) {
- R r = R.ok();
- r.put("data", new ArrayList<>());
- return r;
+ map.put("data", new ArrayList<>());
+ return R.ok().add(map);
}
+
+ String manualError = "";
+ Object manualErrorObj = redisUtil.get(RedisKeyType.TV_MANUAL_ERROR_MSG.key);
+ if (manualErrorObj != null) {
+ manualError = String.valueOf(manualErrorObj);
+ }
List<TvDataDto> list = new ArrayList<>();
for (BasStationTv relation : relations) {
@@ -97,6 +110,12 @@
if (!Cools.isEmpty(wcsStationDto.getSystemWarning())) {
errorMsg += wcsStationDto.getSystemWarning();
}
+ if (!Cools.isEmpty(manualError)) {
+ if (!Cools.isEmpty(errorMsg)) {
+ errorMsg += "锛�";
+ }
+ errorMsg += manualError;
+ }
TvDataDto tvDataDto = new TvDataDto();
tvDataDto.setStationId(wcsStationDto.getStationId());
@@ -115,7 +134,87 @@
list.add(tvDataDto);
}
- return R.ok().add(list);
+
+ map.put("data", list);
+ return R.ok().add(map);
+ }
+
+ @GetMapping("/getError")
+ public R getError(HttpServletRequest request) {
+ Set<String> errors = new LinkedHashSet<>();
+ Object manualErrorObj = redisUtil.get(RedisKeyType.TV_MANUAL_ERROR_MSG.key);
+ String manualError = manualErrorObj == null ? "" : String.valueOf(manualErrorObj);
+ if (!Cools.isEmpty(manualError)) {
+ errors.add(manualError);
+ }
+
+ String remoteAddr = request.getRemoteAddr();
+ TvDevice tvDevice = tvDeviceService.selectOne(
+ new EntityWrapper<TvDevice>().eq("ip", remoteAddr));
+ if (tvDevice != null) {
+ List<BasStationTv> relations = basStationTvService
+ .selectList(new EntityWrapper<BasStationTv>().eq("tv_id", tvDevice.getId()));
+ if (relations != null && !relations.isEmpty()) {
+ for (BasStationTv relation : relations) {
+ WcsStationDto wcsStationDto = stationUtils.stationMap.get(relation.getStationId());
+ if (wcsStationDto == null) {
+ continue;
+ }
+ if (wcsStationDto.getLoading() != 1) {
+ continue;
+ }
+ String deviceError = "";
+ if (!Cools.isEmpty(wcsStationDto.getErrorMsg())) {
+ deviceError += wcsStationDto.getErrorMsg();
+ }
+ if (!Cools.isEmpty(wcsStationDto.getSystemWarning())) {
+ if (!Cools.isEmpty(deviceError)) {
+ deviceError += "锛�";
+ }
+ deviceError += wcsStationDto.getSystemWarning();
+ }
+ if (!Cools.isEmpty(deviceError)) {
+ errors.add(deviceError);
+ }
+ }
+ }
+ }
+
+ String errorMsg = String.join("锛�", errors);
+ Map<String, Object> result = new HashMap<>();
+ result.put("errorMsg", errorMsg);
+ return R.ok(result);
+ }
+
+ @GetMapping("/manualError/auth")
+ @ManagerAuth
+ public R getManualErrorAuth() {
+ Object manualErrorObj = redisUtil.get(RedisKeyType.TV_MANUAL_ERROR_MSG.key);
+ String manualError = manualErrorObj == null ? "" : String.valueOf(manualErrorObj);
+ Map<String, Object> result = new HashMap<>();
+ result.put("manualError", manualError);
+ return R.ok(result);
+ }
+
+ @PostMapping("/manualError/auth")
+ @ManagerAuth
+ public R setManualError(@RequestBody JSONObject param) {
+ String manualError = param.getString("manualError");
+ if (Cools.isEmpty(manualError)) {
+ redisUtil.del(RedisKeyType.TV_MANUAL_ERROR_MSG.key);
+ return R.ok();
+ }
+ redisUtil.set(RedisKeyType.TV_MANUAL_ERROR_MSG.key, manualError);
+ return R.ok();
+ }
+
+ @GetMapping("/announcement")
+ public R top5(){
+ EntityWrapper<Announcement> wrapper = new EntityWrapper<>();
+ wrapper.eq("status", 1);
+ wrapper.orderBy("create_time", false);
+ wrapper.last("limit 5");
+ return R.ok(announcementService.selectList(wrapper));
}
/**
--
Gitblit v1.9.1