设备添加和查询

whyclxw

2024-08-28 ab22d13dc756468dc649ced639dfd3dec321e515

设备添加和查询

 src/main/java/com/whyc/controller/BattgroupBaojigroupController.java

New file
@@ -0,0 +1,29 @@
package com.whyc.controller;

import com.whyc.dto.Response;
import com.whyc.pojo.db_lithium_ram_db.DevInf;
import com.whyc.service.BaojigroupService;
import com.whyc.service.BattgroupBaojigroupService;
import com.whyc.service.DevInfService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@RestController
@Api(tags = "包机组管理")
@RequestMapping("baoji")
public class BattgroupBaojigroupController {
    @Autowired
    private BattgroupBaojigroupService groupService;

    @Autowired
    private BaojigroupService baojiService;


    @ApiOperation(value = "包机组下添加设备")
    @PostMapping("addBaoji")
    public Response addBaoji(@RequestParam String baojiName){
        return baojiService.addBaoji(baojiName);
    }
}

 src/main/java/com/whyc/mapper/BaojigroupMapper.java

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.db_user.Baojigroup;

public interface BaojigroupMapper extends CustomMapper<Baojigroup>{
}

 src/main/java/com/whyc/mapper/BattgroupBaojigroupMapper.java

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.db_user.BattgroupBaojigroup;

public interface BattgroupBaojigroupMapper extends CustomMapper<BattgroupBaojigroup>{
}

 src/main/java/com/whyc/service/BaojigroupService.java

New file
@@ -0,0 +1,21 @@
package com.whyc.service;

import com.whyc.dto.Response;
import com.whyc.mapper.BaojigroupMapper;
import com.whyc.pojo.db_user.Baojigroup;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class BaojigroupService {
    @Autowired(required = false)
    private BaojigroupMapper mapper;

    //包机组下添加设备
    public Response addBaoji(String baojiName) {
        Baojigroup baojigroup=new Baojigroup();
        baojigroup.setBaojiGroupName(baojiName);
        int bl=mapper.insert(baojigroup);
        return new Response().set(1,bl>0);
    }
}

 src/main/java/com/whyc/service/BattgroupBaojigroupService.java

New file
@@ -0,0 +1,7 @@
package com.whyc.service;

import org.springframework.stereotype.Service;

@Service
public class BattgroupBaojigroupService {
}

 src/main/java/com/whyc/webSocket/DevInfSocket.java

@@ -5,7 +5,6 @@
import com.whyc.dto.Response;
import com.whyc.pojo.db_user.UserInf;
import com.whyc.service.DevInfService;
import com.whyc.service.UserInfService;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -14,13 +13,7 @@
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;


/**
 * 设备实时连接信息