DeviceController.java 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408
  1. package cn.efunbox.audio.controller;
  2. //import cn.efunbox.audio.clients.UserFeign;
  3. import cn.efunbox.audio.clients.AudioHttp;
  4. import cn.efunbox.audio.clients.UserHttp;
  5. import cn.efunbox.audio.entity.Channel;
  6. import cn.efunbox.audio.entity.Device;
  7. import cn.efunbox.audio.service.ChannelService;
  8. import cn.efunbox.audio.service.DeviceService;
  9. import cn.efunbox.audio.utils.ApiCode;
  10. import cn.efunbox.audio.utils.Encrypt;
  11. import cn.efunbox.audio.utils.HttpUtil;
  12. import com.alibaba.fastjson.JSONArray;
  13. import com.alibaba.fastjson.JSONObject;
  14. import lombok.extern.slf4j.Slf4j;
  15. import org.apache.commons.lang3.StringUtils;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.beans.factory.annotation.Value;
  18. import org.springframework.data.domain.Page;
  19. import org.springframework.web.bind.annotation.RequestMapping;
  20. import org.springframework.web.bind.annotation.RequestMethod;
  21. import org.springframework.web.bind.annotation.RequestParam;
  22. import org.springframework.web.bind.annotation.RestController;
  23. import javax.servlet.http.HttpServletRequest;
  24. import javax.servlet.http.HttpServletResponse;
  25. import java.nio.charset.StandardCharsets;
  26. import java.sql.Timestamp;
  27. import java.util.*;
  28. /**
  29. * Created by yao on 17-9-26.
  30. */
  31. @RestController
  32. @Slf4j
  33. @RequestMapping(value = "/device")
  34. public class DeviceController {
  35. @Autowired
  36. DeviceService deviceService;
  37. @Autowired
  38. ChannelService channelService;
  39. // @Autowired
  40. // UserFeign userFeign;
  41. @Autowired
  42. UserHttp userHttp;
  43. @Autowired
  44. AudioHttp audioHttp;
  45. @Value("${iaas.user.register}")
  46. private String urlRegister;
  47. @Value("${iaas.user.audio.bizCode}")
  48. private String bizCode;
  49. @Value("${iaas.user.audio.appCode}")
  50. private String appCode;
  51. @Value("${iaas.user.audio.platform}")
  52. private String platform;
  53. @Value("${iaas.user.audio.os}")
  54. private String os;
  55. @Value("${iaas.user.audio.appVer}")
  56. private String appVer;
  57. @Value("${iaas.user.audio.terminal}")
  58. private String terminal;
  59. @Value("${iaas.user.audio.entryType}")
  60. private String entryType;
  61. @Value("${interface.sign.key}")
  62. private String signKey;
  63. @RequestMapping(value = "/feign")
  64. public void Feigh(HttpServletRequest request, HttpServletResponse response,
  65. @RequestParam("idChannel")String idChannel, @RequestParam("mobile")String mobile){
  66. String res = audioHttp.SearchByIdResource("653f6a0c-b997-11e7-9771-080027fcfc4b");
  67. System.out.println(res);
  68. Map map = JSONObject.parseObject(res);
  69. if(map.get("code").toString().equalsIgnoreCase("200")){
  70. map = JSONObject.parseObject(map.get("data").toString());
  71. JSONArray array = JSONArray.parseArray(map.get("audios").toString());
  72. map = JSONObject.parseObject(array.get(0).toString());
  73. String path = map.get("path").toString();
  74. System.out.println(path);
  75. }
  76. // String ip = HttpUtil.getIpAddress(request);
  77. // System.out.println("start:"+ip);
  78. // String res = userHttp.Register(UUID.randomUUID().toString().substring(0, 31),
  79. // idChannel, ip, mobile, mobile);
  80. // String res = userFeign.Register(
  81. //// "application/json",
  82. // bizCode,
  83. //// UUID.randomUUID().toString().substring(0, 31),
  84. // "8723-4327-64238-asdkja",
  85. // appCode,
  86. // platform,
  87. // os,
  88. // "1111",
  89. // "123.126.111.3",
  90. // appVer,
  91. // terminal,
  92. // mobile,
  93. // entryType,
  94. // "123456",
  95. // "",
  96. // ""
  97. // );
  98. // System.out.println(res);
  99. // Map map = JSONObject.parseObject(res);
  100. // HttpUtil.responseOkData(request, response, map);
  101. // System.out.println("res:"+res);
  102. // String res = userFeign.getUser("c26ceb09-4e85-40ba-a81d-1535d142cc43");
  103. // System.out.println(res);
  104. }
  105. @RequestMapping(value = "/token" ,method = RequestMethod.POST)
  106. public void Login(HttpServletRequest request, HttpServletResponse response, @RequestParam long id, @RequestParam String token){
  107. Device device = deviceService.Login(id, token);
  108. if(device==null){
  109. HttpUtil.responseApiCode(request, response, ApiCode.INVALID_TOKEN);
  110. return;
  111. }
  112. device.setIaas_eid("");
  113. device.setIaas_name("");
  114. device.setIaas_uid("");
  115. device.setIaas_token("");
  116. device.setIaas_pwd("");
  117. device.setTokenOld("");
  118. HttpUtil.responseOkData(request, response, device);
  119. return;
  120. }
  121. @RequestMapping(value = "/register" ,method = RequestMethod.POST)
  122. public void Register(HttpServletRequest request, HttpServletResponse response){
  123. String idChannel = request.getParameter("idChannel");
  124. String idDevice = request.getParameter("idDevice");
  125. if(idChannel==null || idDevice==null){
  126. HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
  127. return;
  128. }
  129. if(deviceService.CheckRegister(Long.valueOf(idChannel), idDevice)) {
  130. HttpUtil.responseApiCode(request, response, ApiCode.RECORD_EXIST);
  131. return;
  132. }
  133. Channel channel = channelService.SearchById(Long.valueOf(idChannel));
  134. if(Objects.isNull(channel)){
  135. HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
  136. return;
  137. }
  138. //向云平台注册设备
  139. String ip = HttpUtil.getIpAddress(request);
  140. System.out.println("start:"+ip);
  141. String res = userHttp.Register(UUID.randomUUID().toString().substring(0, 31),
  142. idChannel, ip, idDevice, idDevice);
  143. System.out.println(res);
  144. Map mapRes = JSONObject.parseObject(res);
  145. System.out.println(mapRes.toString());
  146. if(Integer.valueOf(mapRes.get("code").toString())!=200){
  147. HttpUtil.responseApiCode(request, response, ApiCode.RECORD_EXIST);
  148. return;
  149. }
  150. mapRes = JSONObject.parseObject(mapRes.get("data").toString());
  151. Device device = deviceService.Register(Long.valueOf(idChannel), idDevice);
  152. if(device!=null){
  153. //记录云平台的账号信息
  154. device.setIaas_eid(mapRes.get("eid").toString());
  155. device.setIaas_uid(mapRes.get("uid").toString());
  156. device.setIaas_name(idDevice);
  157. device.setIaas_pwd(idDevice);
  158. device.setIaas_token(mapRes.get("token").toString());
  159. device.setIaas_expiration(new Timestamp(Long.valueOf(mapRes.get("expiration").toString())));
  160. device = deviceService.Update(device);
  161. device.setIaas_eid("");
  162. device.setIaas_name("");
  163. device.setIaas_uid("");
  164. device.setIaas_token("");
  165. device.setIaas_pwd("");
  166. device.setTokenOld("");
  167. HttpUtil.responseOkData(request, response, device);
  168. }
  169. return;
  170. }
  171. @RequestMapping(value = "/token",method = RequestMethod.GET)
  172. public void token(HttpServletRequest request, HttpServletResponse response){
  173. String idChannel = request.getParameter("idChannel");
  174. String idDevice = request.getParameter("idDevice");
  175. String sign = request.getParameter("sign");
  176. if(StringUtils.isBlank(idChannel) || StringUtils.isBlank(idDevice) || StringUtils.isBlank(sign)){
  177. HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
  178. return;
  179. }
  180. Map<String,String> param = new HashMap<>();
  181. param.put("idChannel",idChannel);
  182. param.put("idDevice",idDevice);
  183. String test = Encrypt.createSHA256Sign(param,signKey);
  184. if (!sign.equalsIgnoreCase(test)) {
  185. HttpUtil.responseApiCode(request, response, ApiCode.SIGN_FAIL);
  186. return;
  187. }
  188. Channel channel = channelService.SearchById(Long.valueOf(idChannel));
  189. if(Objects.isNull(channel)){
  190. HttpUtil.responseApiCode(request, response, ApiCode.CHANNEL_NOT_FOUND_ERROR);
  191. return;
  192. }
  193. Device device = deviceService.findToken(Long.valueOf(idChannel), idDevice);
  194. if(Objects.isNull(device)){
  195. HttpUtil.responseApiCode(request, response, ApiCode.NO_REGISTER_FAIL);
  196. return;
  197. }
  198. device.setIaas_eid("");
  199. device.setIaas_name("");
  200. device.setIaas_uid("");
  201. device.setIaas_token("");
  202. device.setIaas_pwd("");
  203. device.setTokenOld("");
  204. HttpUtil.responseOkData(request, response, device);
  205. return;
  206. }
  207. @RequestMapping(value = "/v2/token",method = RequestMethod.GET)
  208. public void tokenV2(HttpServletRequest request, HttpServletResponse response){
  209. String idChannel = request.getParameter("idChannel");
  210. String idDevice = request.getParameter("idDevice");
  211. String ts = request.getParameter("ts");
  212. String sign = request.getParameter("sign");
  213. if(StringUtils.isBlank(idChannel) || StringUtils.isBlank(idDevice) || StringUtils.isBlank(sign)){
  214. HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
  215. return;
  216. }
  217. Map<String,String> param = new HashMap<>();
  218. param.put("idChannel",idChannel);
  219. param.put("idDevice",idDevice);
  220. param.put("ts",ts);
  221. String signStr = Encrypt.createHMACSHA256(param,signKey);
  222. String decode = new String(Base64.getDecoder().decode(sign), StandardCharsets.UTF_8);
  223. if (!signStr.equalsIgnoreCase(decode)) {
  224. HttpUtil.responseApiCode(request, response, ApiCode.SIGN_FAIL);
  225. return;
  226. }
  227. Channel channel = channelService.SearchById(Long.valueOf(idChannel));
  228. if(Objects.isNull(channel)){
  229. HttpUtil.responseApiCode(request, response, ApiCode.CHANNEL_NOT_FOUND_ERROR);
  230. return;
  231. }
  232. Device device = deviceService.findToken(Long.valueOf(idChannel), idDevice);
  233. if(Objects.isNull(device)){
  234. HttpUtil.responseApiCode(request, response, ApiCode.NO_REGISTER_FAIL);
  235. return;
  236. }
  237. device.setIaas_eid("");
  238. device.setIaas_name("");
  239. device.setIaas_uid("");
  240. device.setIaas_token("");
  241. device.setIaas_pwd("");
  242. device.setTokenOld("");
  243. HttpUtil.responseOkData(request, response, device);
  244. return;
  245. }
  246. // @RequestMapping(value = "/register" ,method = RequestMethod.POST)
  247. // public Map Register(HttpServletRequest request, @RequestBody Device device){
  248. // Map map = new HashMap<>();
  249. // if(device.getIdChannel()==null || device.getIdDevice()==null){
  250. // map.put("code", ApiCode.PARAMETER_ERROR.getCode());
  251. // map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
  252. // return map;
  253. // }
  254. // if(deviceService.CheckRegister(device.getIdChannel(), device.getIdDevice())){
  255. // map.put("code", ApiCode.RECORD_EXIST.getCode());
  256. // map.put("msg", ApiCode.RECORD_EXIST.getMessage());
  257. // return map;
  258. // }
  259. // List<Channel> channelList = channelService.SearchById(device.getIdChannel());
  260. // if(channelList==null || channelList.size()<1){
  261. // map.put("code", ApiCode.PARAMETER_ERROR.getCode());
  262. // map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
  263. // return map;
  264. // }
  265. // device = deviceService.Register(device.getIdChannel(), device.getIdDevice());
  266. // if(device!=null){
  267. // map.put("code", ApiCode.OK.getCode());
  268. // Map data = new HashMap<>();
  269. // data.put("id", device.getId());
  270. // data.put("token", device.getTokenNew());
  271. // map.put("data", data);
  272. // }
  273. //
  274. // return map;
  275. // }
  276. /**
  277. * 搜索已注册的设备
  278. * @param request
  279. * @param response
  280. */
  281. @RequestMapping(value = "/search" ,method = RequestMethod.POST)
  282. public void Search(HttpServletRequest request, HttpServletResponse response){
  283. String idDevice = request.getParameter("idDevice");
  284. String idChannel = request.getParameter("idChannel");
  285. String start = request.getParameter("start");
  286. String end = request.getParameter("end");
  287. String page = request.getParameter("page");
  288. String size = request.getParameter("size");
  289. if(page==null || page.length()<1)
  290. page = "0";
  291. if(size==null || size.length()<1)
  292. size = "0";
  293. Map<String,Object> map = new HashMap<>();
  294. if((idDevice==null || idDevice.length()==0) && (idChannel==null || idChannel.length()==0)){
  295. Page<Device> pageRes = null;
  296. if((start==null || start.length()==0) || (end==null || end.length()==0))
  297. pageRes = deviceService.SearchAll(Integer.valueOf(page), Integer.valueOf(size));
  298. else
  299. pageRes = deviceService.SearchAll(Integer.valueOf(page), Integer.valueOf(size), Timestamp.valueOf(start), Timestamp.valueOf(end));
  300. for(int i=0; i<pageRes.getNumberOfElements(); i++){
  301. pageRes.getContent().get(i).setTokenNew("");
  302. pageRes.getContent().get(i).setTokenOld("");
  303. }
  304. map.put("data", pageRes.getContent());
  305. map.put("size", pageRes.getNumberOfElements());
  306. map.put("total", pageRes.getTotalElements());
  307. }else{
  308. if(idDevice==null || idDevice.length()==0)
  309. idDevice = "0";
  310. if(idChannel==null || idChannel.length()==0)
  311. idChannel = "0";
  312. Page<Device> pageRes = null;
  313. if((start==null || start.length()==0) || (end==null || end.length()==0))
  314. pageRes = deviceService.Search(Long.valueOf(idChannel), idDevice, Integer.valueOf(page), Integer.valueOf(size));
  315. else
  316. pageRes = deviceService.Search(Long.valueOf(idChannel), idDevice, Integer.valueOf(page), Integer.valueOf(size), Timestamp.valueOf(start), Timestamp.valueOf(end));
  317. for(int i=0; i<pageRes.getNumberOfElements(); i++){
  318. System.out.println("i:"+i);
  319. pageRes.getContent().get(i).setTokenNew("");
  320. pageRes.getContent().get(i).setTokenOld("");
  321. }
  322. map.put("data", pageRes.getContent());
  323. map.put("size", pageRes.getNumberOfElements());
  324. map.put("total", pageRes.getTotalElements());
  325. }
  326. HttpUtil.responseOkData(request, response, map);
  327. return;
  328. }
  329. // @RequestMapping(value = "/update", method = RequestMethod.POST)
  330. // public void Update(HttpServletRequest request, HttpServletResponse response, @RequestBody Device device){
  331. // Device deviceOld = deviceService.GetOne(device.getId());
  332. // if(deviceOld==null){
  333. // HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
  334. // return;
  335. // }
  336. // device = (Device)Common.CopyValue(device, deviceOld);
  337. // device = deviceService.Update(device);
  338. // HttpUtil.responseOutWithJson(request, response, device);
  339. // return;
  340. // }
  341. //
  342. // @RequestMapping(value = "/delete", method = RequestMethod.POST)
  343. // public void Delete(HttpServletRequest request, HttpServletResponse response){
  344. // String idDevice = request.getParameter("idDevice");
  345. // deviceService.Delete(Long.valueOf(idDevice));
  346. // HttpUtil.responseOk(request, response);
  347. // return;
  348. // }
  349. @RequestMapping(value = "/findAlbum", method = RequestMethod.GET)
  350. public void findAlbum(HttpServletRequest request, HttpServletResponse response, String id){
  351. Map<String,Object> map = new HashMap<>();
  352. map.put("albums", deviceService.findAlbum(id));
  353. HttpUtil.responseOkData(request, response, map);
  354. }
  355. }