| | |
| | | package com.vincent.rsf.server.manager.service.impl; |
| | | |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.vincent.rsf.framework.exception.CoolException; |
| | | import com.vincent.rsf.server.manager.controller.params.DeviceSiteParame; |
| | | import com.vincent.rsf.server.manager.entity.BasDevice; |
| | | import com.vincent.rsf.server.manager.entity.BasStation; |
| | | import com.vincent.rsf.server.manager.mapper.DeviceSiteMapper; |
| | | import com.vincent.rsf.server.manager.entity.DeviceSite; |
| | |
| | | List<String> targets = Arrays.asList(StringUtils.split(param.getTarget(), ",")); |
| | | List<DeviceSite> deviceSites = new ArrayList<>(); |
| | | for (String site : sites) { |
| | | BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, site)); |
| | | BasStation basStation = basStationService.getById(site); |
| | | if (null == basStation) { |
| | | throw new CoolException("初始化失败: 站点未找到!!"); |
| | | } |
| | | for (String deviceSite : dvSites) { |
| | | BasStation basStation2 = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, deviceSite)); |
| | | BasStation basStation2 = basStationService.getById(deviceSite); |
| | | if (null == basStation2) { |
| | | throw new CoolException("初始化失败: 作业站点未找到!!"); |
| | | } |
| | |
| | | for (String target : targets) { |
| | | DeviceSite site1 = new DeviceSite(); |
| | | site1.setType(id + "") |
| | | .setSite(site) |
| | | .setSite(basStation.getStationName()) |
| | | .setDevice(param.getDeviceType()) |
| | | .setDeviceSite(deviceSite) |
| | | .setDeviceSite(basStation2.getStationName()) |
| | | .setTarget(target) |
| | | .setDeviceCode(param.getDeviceCode()) |
| | | .setChannel(param.getChannel()) |