|
@@ -12,7 +12,9 @@ import com.example.opc_common.util.Result;
|
|
|
import com.example.opc_da.dao.CollectorDao;
|
|
|
import com.example.opc_da.dao.InFluxDBDao;
|
|
|
import com.example.opc_da.service.CollectorService;
|
|
|
+import com.example.opc_da.util.UserUtil;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -33,6 +35,9 @@ public class CollectorServiceImpl implements CollectorService {
|
|
|
@Value("${telegraf.client.port}")
|
|
|
private String clientPort;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private UserUtil userUtil;
|
|
|
+
|
|
|
@Override
|
|
|
public Integer getCountByIp(String ip) {
|
|
|
return collectorDao.getCountByIp(ip);
|
|
@@ -62,6 +67,14 @@ public class CollectorServiceImpl implements CollectorService {
|
|
|
public Collector getCollectorInfo(Integer id) {
|
|
|
Collector collector = collectorDao.getCollectorInfo(id);
|
|
|
List<Map<String, Object>> list = collectorDao.getItemGroupByClientId(id);
|
|
|
+ String currentUserId = userUtil.getCurrentUserId();
|
|
|
+ for(int i=0;i<list.size();i++){
|
|
|
+ if(list.get(i).get("user_id").equals(currentUserId)){
|
|
|
+ list.get(i).put("isupdate",1);
|
|
|
+ }else{
|
|
|
+ list.get(i).put("isupdate",0);
|
|
|
+ }
|
|
|
+ }
|
|
|
if (Blank.notBlank(list)) {
|
|
|
collector.setItemJson(JSONUtil.parseArray(list).toJSONString(0));
|
|
|
}
|