| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.HttpStatus; |
| | | import org.springframework.http.ResponseEntity; |
| | | import org.springframework.web.bind.annotation.CrossOrigin; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.PathVariable; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RestController; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.genersoft.iot.vmp.gb28181.bean.Device; |
| | | import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander; |
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
| | | |
| | | @CrossOrigin |
| | | @RestController |
| | | @RequestMapping("/api") |
| | | public class PlayController { |
| | |
| | | @Autowired |
| | | private IVideoManagerStorager storager; |
| | | |
| | | @GetMapping("/play/{deviceId}_{channelId}") |
| | | @GetMapping("/play/{deviceId}/{channelId}") |
| | | public ResponseEntity<String> play(@PathVariable String deviceId,@PathVariable String channelId){ |
| | | |
| | | Device device = storager.queryVideoDevice(deviceId); |
| | |
| | | } |
| | | |
| | | if(ssrc!=null) { |
| | | return new ResponseEntity<String>(ssrc,HttpStatus.OK); |
| | | JSONObject json = new JSONObject(); |
| | | json.put("ssrc", ssrc); |
| | | return new ResponseEntity<String>(json.toString(),HttpStatus.OK); |
| | | } else { |
| | | logger.warn("设备预览API调用失败!"); |
| | | return new ResponseEntity<String>(HttpStatus.INTERNAL_SERVER_ERROR); |
| | | } |
| | | } |
| | | |
| | | @PostMapping("/play/{ssrc}/stop") |
| | | public ResponseEntity<String> playStop(@PathVariable String ssrc){ |
| | | |
| | | cmder.streamByeCmd(ssrc); |
| | | |
| | | if (logger.isDebugEnabled()) { |
| | | logger.debug(String.format("设备预览停止API调用,ssrc:%s", ssrc)); |
| | | } |
| | | |
| | | if(ssrc!=null) { |
| | | JSONObject json = new JSONObject(); |
| | | json.put("ssrc", ssrc); |
| | | return new ResponseEntity<String>(json.toString(),HttpStatus.OK); |
| | | } else { |
| | | logger.warn("设备预览停止API调用失败!"); |
| | | return new ResponseEntity<String>(HttpStatus.INTERNAL_SERVER_ERROR); |
| | | } |
| | | } |
| | | } |