#

Junjie

2026-01-22 afc1bebb2eafc87ba81fb9fe39ef0386d1fb3d17

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

@@ -3,10 +3,14 @@
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.BasStation;
import com.zy.asrs.entity.BasStationTv;
import com.zy.asrs.entity.TvDevice;

import com.zy.asrs.entity.dto.TvDataDto;
import com.zy.asrs.entity.dto.WcsStationDto;
import com.zy.asrs.service.BasStationTvService;
import com.zy.asrs.service.TvDeviceService;
import com.zy.asrs.utils.StationUtils;
import com.zy.asrs.utils.Utils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
@@ -16,7 +20,6 @@
import javax.servlet.http.HttpServletRequest;

import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@RestController
@@ -26,11 +29,11 @@
    private static final String[] WEEK = {"星期日","星期一","星期二","星期三","星期四","星期五","星期六"};

    @Autowired
    private com.zy.asrs.service.TvDeviceService tvDeviceService;
    private TvDeviceService tvDeviceService;
    @Autowired
    private com.zy.asrs.service.BasStationTvService basStationTvService;
    private BasStationTvService basStationTvService;
    @Autowired
    private com.zy.asrs.service.BasStationService basStationService;
    private StationUtils stationUtils;

    @Value("${app.version:1.0.0}")
    private String appVersion;
@@ -53,14 +56,12 @@
    @GetMapping("/getLedInfos")
    public R getLedInfos(HttpServletRequest request) {
        String remoteAddr = request.getRemoteAddr();
        // 1. 根据IP查询电视机
        TvDevice tvDevice = tvDeviceService.selectOne(
                new EntityWrapper<TvDevice>().eq("ip", remoteAddr));
        if (tvDevice == null) {
            return R.error("未找到IP对应的电视机设备: " + remoteAddr);
        }

        // 2. 查询绑定的站台ID
        List<BasStationTv> relations = basStationTvService
                .selectList(new EntityWrapper<BasStationTv>().eq("tv_id", tvDevice.getId()));
        if (relations == null || relations.isEmpty()) {
@@ -69,14 +70,46 @@
            return r;
        }

        // 3. 获取站台详情
        List<Integer> stationIds = relations.stream().map(BasStationTv::getStationId)
                .collect(Collectors.toList());
        List<BasStation> stations = basStationService.selectBatchIds(stationIds);

        R r = R.ok();
        r.put("data", stations);
        return r;
        List<TvDataDto> list = new ArrayList<>();
        for (BasStationTv relation : relations) {
            WcsStationDto wcsStationDto = stationUtils.stationMap.get(relation.getStationId());

            if (wcsStationDto == null) {
                continue;
            }

            if (wcsStationDto.getLoading() != 1) {
                continue;
            }

            String errorMsg = "";
            if (!Cools.isEmpty(wcsStationDto.getErrorMsg())) {
                errorMsg +=  wcsStationDto.getErrorMsg();
            }

            if (!Cools.isEmpty(wcsStationDto.getSystemWarning())) {
                errorMsg +=  wcsStationDto.getSystemWarning();
            }

            TvDataDto tvDataDto = new TvDataDto();
            tvDataDto.setStationId(wcsStationDto.getStationId());
            tvDataDto.setTaskNo(wcsStationDto.getTaskNo());
            tvDataDto.setBarcode(wcsStationDto.getBarcode());
            tvDataDto.setErrorMsg(errorMsg);
            tvDataDto.setIoType(wcsStationDto.getIoType());
            tvDataDto.setWrkDetls(wcsStationDto.getWrkDetls());

            if (Cools.isEmpty(errorMsg)) {
                tvDataDto.setErrorCode(0);
            }else {
                tvDataDto.setErrorCode(1);
            }

            list.add(tvDataDto);
        }

        return R.ok().add(list);
    }

    /**