|  |  |  | 
|---|
|  |  |  | package com.genersoft.iot.vmp.vmanager.server; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson.JSON; | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.VManageBootstrap; | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSON; | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSONObject; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.common.SystemAllInfo; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.common.VersionPo; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.conf.SipConfig; | 
|---|
|  |  |  | 
|---|
|  |  |  | import com.genersoft.iot.vmp.service.*; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.service.bean.MediaServerLoad; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.utils.SpringBeanFactory; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.vmanager.bean.ErrorCode; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.vmanager.bean.ResourceBaceInfo; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.vmanager.bean.ResourceInfo; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.vmanager.bean.SystemConfigInfo; | 
|---|
|  |  |  | import gov.nist.javax.sip.SipStackImpl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import io.swagger.v3.oas.annotations.Operation; | 
|---|
|  |  |  | import io.swagger.v3.oas.annotations.Parameter; | 
|---|
|  |  |  | import io.swagger.v3.oas.annotations.tags.Tag; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Value; | 
|---|
|  |  |  | import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; | 
|---|
|  |  |  | import org.springframework.util.ObjectUtils; | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.*; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import javax.sip.ListeningPoint; | 
|---|
|  |  |  | import javax.sip.ObjectInUseException; | 
|---|
|  |  |  | import javax.sip.SipProvider; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.ArrayList; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @SuppressWarnings("rawtypes") | 
|---|
|  |  |  | @Tag(name = "服务控制") | 
|---|
|  |  |  | @CrossOrigin | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RestController | 
|---|
|  |  |  | @RequestMapping("/api/server") | 
|---|
|  |  |  | public class ServerController { | 
|---|
|  |  |  | 
|---|
|  |  |  | @Value("${server.port}") | 
|---|
|  |  |  | private int serverPort; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ThreadPoolTaskExecutor taskExecutor; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private IRedisCatchStorage redisCatchStorage; | 
|---|
|  |  |  | 
|---|
|  |  |  | MediaServerItem mediaServerItemInDatabase = mediaServerService.getOne(mediaServerItem.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (mediaServerItemInDatabase != null) { | 
|---|
|  |  |  | if (ObjectUtils.isEmpty(mediaServerItemInDatabase.getSendRtpPortRange()) && ObjectUtils.isEmpty(mediaServerItem.getSendRtpPortRange())) { | 
|---|
|  |  |  | mediaServerItem.setSendRtpPortRange("30000,30500"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | mediaServerService.update(mediaServerItem); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | if (ObjectUtils.isEmpty(mediaServerItem.getSendRtpPortRange())) { | 
|---|
|  |  |  | mediaServerItem.setSendRtpPortRange("30000,30500"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | mediaServerService.add(mediaServerItem); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|