From fab292eb6f5a177262fa98c73bb424eacbc508a3 Mon Sep 17 00:00:00 2001 From: "1378012178@qq.com" <1378012178@qq.com> Date: Thu, 5 Mar 2026 14:58:19 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=B0=8F=E7=A8=8B=E5=BA=8F=E9=95=BF?= =?UTF-8?q?=E8=80=85=E7=AB=AF-=E5=AE=A1=E6=A0=B8=E7=95=8C=E9=9D=A2?= =?UTF-8?q?=E6=8E=92=E5=BA=8F=202=E3=80=81pad=E6=9C=8D=E5=8A=A1=E6=8C=87?= =?UTF-8?q?=E4=BB=A4=E6=89=8B=E5=8A=A8=E6=8B=8D=E7=85=A7/=E5=BD=95?= =?UTF-8?q?=E5=83=8F:=E5=AD=90=E8=A1=A8=E6=95=B0=E6=8D=AE=E5=A4=84?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/CameraInfoServiceImpl.java | 1485 +++++++++-------- .../DirectiveAppraisalController.java | 3 +- .../impl/DirectiveOrderPadServiceImpl.java | 21 + 3 files changed, 779 insertions(+), 730 deletions(-) diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoServiceImpl.java index 8b0ffb9f..b2be1ed9 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoServiceImpl.java @@ -41,7 +41,7 @@ import static java.lang.Thread.sleep; /** * @Description: 护理单元-物联管理-摄像头信息 * @Author: jeecg-boot - * @Date: 2025-01-17 + * @Date: 2025-01-17 * @Version: V1.0 */ @Service @@ -61,17 +61,19 @@ public class CameraInfoServiceImpl extends ServiceImpl findPage(Page page, CameraInfo cameraInfo){ - return baseMapper.findPage(page,cameraInfo); + public IPage findPage(Page page, CameraInfo cameraInfo) { + return baseMapper.findPage(page, cameraInfo); } - public List findModelList(CameraInfo cameraInfo){ + public List findModelList(CameraInfo cameraInfo) { List modelList = Lists.newArrayList(); List list = baseMapper.findList(cameraInfo); for (int i = 0; i < list.size(); i++) { @@ -84,26 +86,29 @@ public class CameraInfoServiceImpl extends ServiceImpl findAllList(){ + public List findAllList() { return baseMapper.findAllList(); } /** * 获取护理单元信息 + * * @return */ - public IPage findNuPage(Page page, CameraInfo cameraInfo){ - return baseMapper.findNuPage(page,cameraInfo); + public IPage findNuPage(Page page, CameraInfo cameraInfo) { + return baseMapper.findNuPage(page, cameraInfo); } /** * 调用接口-修改tums摄像头名称 + * * @param cameraInfo * @return */ - public Result modifyDeviceDetails(CameraInfo cameraInfo){ + public Result modifyDeviceDetails(CameraInfo cameraInfo) { String id = cameraInfo.getDeviceIndex(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -112,30 +117,32 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ + if (jsonObject.getInt("error_code").equals(0)) { + JSONObject result = (JSONObject) jsonObject.get("result"); + if (result.getInt("total") > 0) { JSONArray list = result.getJSONArray("list"); - for(int i=0;i getIpcCapability(CameraInfo cameraInfo){ + public Result getIpcCapability(CameraInfo cameraInfo) { JSONObject capability = new JSONObject(); String id = cameraInfo.getDeviceIndex(); StringBuffer paramsSb = new StringBuffer(); @@ -254,9 +265,9 @@ public class CameraInfoServiceImpl extends ServiceImpl syncProjectIpcDevice(CameraInfo cameraInfo){ + public Result syncProjectIpcDevice(CameraInfo cameraInfo) { StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"start\"").append(":0").append(","); @@ -285,43 +296,44 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ + if (jsonObject.getInt("error_code").equals(0)) { + JSONObject result = (JSONObject) jsonObject.get("result"); + if (result.getInt("total") > 0) { JSONArray list = result.getJSONArray("list"); - for(int i=0;i getImageCommon(Map map){ + public Result getImageCommon(Map map) { String id = map.get("deviceIndex").toString(); String type = map.get("type").toString(); StringBuffer sb = new StringBuffer(); @@ -414,37 +428,37 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result setImageCommon(Map map) { String id = map.get("deviceIndex").toString(); String type = map.get("type").toString(); - Map paramMap = (Map)map.get("param"); + Map paramMap = (Map) map.get("param"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"devId\"").append(":").append("\"").append(id).append("\"").append(","); @@ -477,8 +491,8 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ - cstr = cstr.substring(0,cstr.length()-1); + if (cstr.length() > 0) { + cstr = cstr.substring(0, cstr.length() - 1); } sb.append(cstr); sb.append("}"); @@ -488,34 +502,34 @@ public class CameraInfoServiceImpl extends ServiceImpl getOsdCapability(Map map){ + public Result getOsdCapability(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -543,36 +557,36 @@ public class CameraInfoServiceImpl extends ServiceImpl getOsd(Map map){ + public Result getOsd(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -601,35 +615,35 @@ public class CameraInfoServiceImpl extends ServiceImpl setOsd(Map map){ + public Result setOsd(Map map) { String id = map.get("deviceIndex").toString(); String dateEnabled = map.get("dateEnabled").toString(); String weekEnabled = map.get("weekEnabled").toString(); @@ -673,34 +687,34 @@ public class CameraInfoServiceImpl extends ServiceImpl getVideoParams(Map map){ + public Result getVideoParams(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -731,213 +745,213 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result setVideoParams(Map map) { String id = map.get("deviceIndex").toString(); - Map mainMap = (Map)map.get("main"); - Map minorMap = (Map)map.get("minor"); + Map mainMap = (Map) map.get("main"); + Map minorMap = (Map) map.get("minor"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"devId\"").append(":").append("\"").append(id).append("\"").append(","); @@ -970,8 +984,8 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ - mainStr = mainStr.substring(0,mainStr.length()-1); + if (mainStr.length() > 0) { + mainStr = mainStr.substring(0, mainStr.length() - 1); } sb.append(mainStr); sb.append("},"); @@ -985,8 +999,8 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ - minorStr = minorStr.substring(0,minorStr.length()-1); + if (minorStr.length() > 0) { + minorStr = minorStr.substring(0, minorStr.length() - 1); } sb.append(minorStr); sb.append("}"); @@ -996,34 +1010,34 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result configRecovery(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -1053,34 +1067,34 @@ public class CameraInfoServiceImpl extends ServiceImpl> getPreviewUrl(CameraInfo cameraInfo){ - Map map = new HashMap<>(); - map.put("url",""); - map.put("backupUrl",""); - map.put("wsUrl",""); - map.put("wssUrl",""); + public Result> getPreviewUrl(CameraInfo cameraInfo) { + Map map = new HashMap<>(); + map.put("url", ""); + map.put("backupUrl", ""); + map.put("wsUrl", ""); + map.put("wssUrl", ""); String id = cameraInfo.getDeviceIndex(); int streamType = cameraInfo.getStreamType(); StringBuffer addPreviewSb = new StringBuffer(); @@ -1107,10 +1122,10 @@ public class CameraInfoServiceImpl extends ServiceImpl getPreviewUrl(String id,int streamType,String sessionId){ - Map map = new HashMap<>(); - map.put("url",""); - map.put("backupUrl",""); - map.put("wsUrl",""); - map.put("wssUrl",""); + private Map getPreviewUrl(String id, int streamType, String sessionId) { + Map map = new HashMap<>(); + map.put("url", ""); + map.put("backupUrl", ""); + map.put("wsUrl", ""); + map.put("wssUrl", ""); StringBuffer getPreviewSb = new StringBuffer(); getPreviewSb.append("{"); getPreviewSb.append("\"id\"").append(":").append("\"").append(id).append("\"").append(","); @@ -1138,34 +1154,34 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ - idsStr = idsStr.substring(0,idsStr.length()-1); + if (idsStr.length() > 0) { + idsStr = idsStr.substring(0, idsStr.length() - 1); } StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"devIds\"").append(":").append("[").append(idsStr).append("],"); sb.append("\"storageList\"").append(":").append("["); sb.append("{"); - if(cameraInfo.getStorageDevId()!=null&&!cameraInfo.getStorageDevId().equals("")){ + if (cameraInfo.getStorageDevId() != null && !cameraInfo.getStorageDevId().equals("")) { //存储设备ID sb.append("\"storageDevId\"").append(":").append(cameraInfo.getStorageDevId()).append(","); - if(cameraInfo.getStorageDevId().equals("0")){ + if (cameraInfo.getStorageDevId().equals("0")) { sb.append("\"storageType\"").append(":").append("1").append(","); - }else{ + } else { sb.append("\"storageType\"").append(":").append("2").append(","); } } @@ -1291,15 +1307,15 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ - idsStr = idsStr.substring(0,idsStr.length()-1); + if (idsStr.length() > 0) { + idsStr = idsStr.substring(0, idsStr.length() - 1); } StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -1362,15 +1378,15 @@ public class CameraInfoServiceImpl extends ServiceImpl getRecordCfgs(CameraInfo cameraInfo,Integer pageNo,Integer pageSize) throws Exception{ + public IPage getRecordCfgs(CameraInfo cameraInfo, Integer pageNo, Integer pageSize) throws Exception { IPage page = new Page<>(); page.setSize(pageSize); page.setCurrent(pageNo); - if(cameraInfo.getProjectId()==null||cameraInfo.getProjectId().equals("")){ + if (cameraInfo.getProjectId() == null || cameraInfo.getProjectId().equals("")) { return page; } - if(cameraInfo.getRegionId()==null||cameraInfo.getRegionId().equals("")){ + if (cameraInfo.getRegionId() == null || cameraInfo.getRegionId().equals("")) { return page; } StringBuffer sb = new StringBuffer(); sb.append("{"); - sb.append("\"start\"").append(":").append((pageNo-1)*pageSize).append(","); + sb.append("\"start\"").append(":").append((pageNo - 1) * pageSize).append(","); sb.append("\"limit\"").append(":").append(pageSize).append(","); sb.append("\"filterAnd\"").append(":").append("{"); sb.append("\"projectId\"").append(":").append("\"").append(cameraInfo.getProjectId()).append("\","); @@ -1409,16 +1425,16 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ + if (total > 0) { List list = Lists.newArrayList(); JSONArray array = result.getJSONArray("list"); - for(int i=0;i getTamperDet(Map map){ + public Result getTamperDet(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -1507,36 +1523,36 @@ public class CameraInfoServiceImpl extends ServiceImpl setTamperDet(Map map){ + public Result setTamperDet(Map map) { String id = map.get("deviceIndex").toString(); String enabled = map.get("enabled").toString(); StringBuffer sb = new StringBuffer(); @@ -1559,7 +1575,7 @@ public class CameraInfoServiceImpl extends ServiceImpl getTamperNotif(Map map){ + public Result getTamperNotif(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -1626,35 +1642,35 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result setTamperNotif(Map map) { String id = map.get("deviceIndex").toString(); String msgPushEnabled = map.get("msgPushEnabled").toString(); String lightAlarmEnabled = map.get("lightAlarmEnabled").toString(); @@ -1695,34 +1711,34 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result testAudio(Map map) { String devId = map.get("deviceIndex").toString(); String id = map.get("id").toString(); String force = map.get("force").toString(); @@ -1755,34 +1771,34 @@ public class CameraInfoServiceImpl extends ServiceImpl getAlarmInfo(Map map){ + public Result getAlarmInfo(Map map) { String id = map.get("deviceIndex").toString(); StringBuffer sb = new StringBuffer(); sb.append("{"); @@ -1810,36 +1826,36 @@ public class CameraInfoServiceImpl extends ServiceImpl setAlarmInfo(Map map){ + public Result setAlarmInfo(Map map) { String id = map.get("deviceIndex").toString(); String type = map.get("type").toString(); String enabled = map.get("enabled").toString(); @@ -1863,10 +1879,10 @@ public class CameraInfoServiceImpl extends ServiceImpl getAlarmPlan(Map map){ + public Result getAlarmPlan(Map map) { String id = map.get("deviceIndex").toString(); String type = map.get("type").toString(); StringBuffer sb = new StringBuffer(); @@ -1925,10 +1941,10 @@ public class CameraInfoServiceImpl extends ServiceImpl map){ + public Result setAlarmPlan(Map map) { String id = map.get("deviceIndex").toString(); String type = map.get("type").toString(); - Map alarmPlan = (Map)map.get("alarmPlan"); + Map alarmPlan = (Map) map.get("alarmPlan"); String monday = alarmPlan.get("monday").toString(); String tuesday = alarmPlan.get("tuesday").toString(); String wednesday = alarmPlan.get("wednesday").toString(); @@ -1995,10 +2011,10 @@ public class CameraInfoServiceImpl extends ServiceImpl searchYear(String videoDevId,String year){ - Map map = new HashMap<>(); + public Map searchYear(String videoDevId, String year) { + Map map = new HashMap<>(); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("[{"); @@ -2065,11 +2082,11 @@ public class CameraInfoServiceImpl extends ServiceImpl=pageSize){ - int more = getVideoTotal(deviceIndex,parentId,dataDate,pageNo+1,pageSize); + if (total >= pageSize) { + int more = getVideoTotal(deviceIndex, parentId, dataDate, pageNo + 1, pageSize); count = count + more; } } @@ -2128,24 +2145,24 @@ public class CameraInfoServiceImpl extends ServiceImpl> searchVideo(Integer pageNo, Integer pageSize, CameraInfo cameraInfo){ + public Result> searchVideo(Integer pageNo, Integer pageSize, CameraInfo cameraInfo) { Page page = new Page(pageNo, pageSize); String deviceIndex = cameraInfo.getDeviceIndex(); String parentId = cameraInfo.getParentId(); String dataDate = cameraInfo.getDataDate(); - dataDate = dataDate.replaceAll("-",""); - int totalCount = getVideoTotal(deviceIndex,parentId,dataDate,1,800); + dataDate = dataDate.replaceAll("-", ""); + int totalCount = getVideoTotal(deviceIndex, parentId, dataDate, 1, 800); page = new Page(pageNo, pageSize, totalCount); - int startIdx = (pageNo-1)*pageSize; - int endIdx = pageNo*pageSize-1; + int startIdx = (pageNo - 1) * pageSize; + int endIdx = pageNo * pageSize - 1; StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("[{"); sb.append("\"videoDevId\"").append(":").append("\"").append(deviceIndex).append("\","); - if(parentId!=null&&!parentId.equals("")&&!parentId.equals("0")){ + if (parentId != null && !parentId.equals("") && !parentId.equals("0")) { //存储设备ID sb.append("\"storageDevId\"").append(":").append("\"").append(parentId).append("\""); - }else{ + } else { //SK卡,取自身设备ID sb.append("\"storageDevId\"").append(":").append("\"").append(deviceIndex).append("\""); } @@ -2157,13 +2174,13 @@ public class CameraInfoServiceImpl extends ServiceImpl0){ + if (total > 0) { List list = Lists.newArrayList(); JSONArray videos = result.getJSONArray("videos"); - JSONObject videoJson = (JSONObject)videos.get(0); + JSONObject videoJson = (JSONObject) videos.get(0); String videoDevId = videoJson.getStr("videoDevId"); String storageDevId = videoJson.getStr("storageDevId"); String channelId = videoJson.getStr("channelId"); @@ -2175,7 +2192,7 @@ public class CameraInfoServiceImpl extends ServiceImpl getStoragesById(CameraInfo cameraInfo){ - Map map = new HashMap<>(); - map.put("error","0"); + public Map getStoragesById(CameraInfo cameraInfo) { + Map map = new HashMap<>(); + map.put("error", "0"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"devIds\"").append(":").append("[\"").append(cameraInfo.getDeviceIndex()).append("\"]"); @@ -2236,18 +2254,18 @@ public class CameraInfoServiceImpl extends ServiceImpl ciList = Lists.newArrayList(); JSONArray list = jsonObject.getJSONArray("result"); - for(int i=0;i addPlaybackChn(CameraInfo cameraInfo){ - Map map = new HashMap<>(); - map.put("error","0"); + public Map addPlaybackChn(CameraInfo cameraInfo) { + Map map = new HashMap<>(); + map.put("error", "0"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("[{"); @@ -2309,11 +2328,11 @@ public class CameraInfoServiceImpl extends ServiceImpl ciList = Lists.newArrayList(); JSONArray list = jsonObject.getJSONArray("result"); - for(int i=0;i getPlaybackUrl(CameraInfo cameraInfo,int counter){ - Map map = new HashMap<>(); - map.put("error","0"); + public Map getPlaybackUrl(CameraInfo cameraInfo, int counter) { + Map map = new HashMap<>(); + map.put("error", "0"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("[{"); @@ -2368,17 +2388,17 @@ public class CameraInfoServiceImpl extends ServiceImpl ciList = Lists.newArrayList(); JSONArray list = jsonObject.getJSONArray("result"); - for(int i=0;i10){ - deletePlaybackChn(cameraInfo.getVideoDevId(),cameraInfo.getSessionId()); - map.put("error",errCode); + if (counter > 10) { + deletePlaybackChn(cameraInfo.getVideoDevId(), cameraInfo.getSessionId()); + map.put("error", errCode); break; } sleep(1000); - map = getPlaybackUrl(cameraInfo,++counter); + map = getPlaybackUrl(cameraInfo, ++counter); return map; } catch (InterruptedException e) { e.printStackTrace(); } - }else{ - System.out.println("getPlaybackUrl:"+errCode); + } else { + System.out.println("getPlaybackUrl:" + errCode); } } - map.put("data",ciList); - }else if(errorCode.equals("-80703")){ + map.put("data", ciList); + } else if (errorCode.equals("-80703")) { try { - if(counter>10){ - deletePlaybackChn(cameraInfo.getVideoDevId(),cameraInfo.getSessionId()); + if (counter > 10) { + deletePlaybackChn(cameraInfo.getVideoDevId(), cameraInfo.getSessionId()); } sleep(1000); - map = getPlaybackUrl(cameraInfo,++counter); + map = getPlaybackUrl(cameraInfo, ++counter); } catch (InterruptedException e) { e.printStackTrace(); } - }else{ + } else { String errorMsg = ""; - try{ + try { ErrorCode errorVo = errorCodeService.getByCode(errorCode); errorMsg = errorVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errorMsg = errorCode; } - updateDeviceStatus(cameraInfo.getVideoDevId(),errorCode); - map.put("error",errorCode); - log.info("getPlaybackUrl:{}",errorMsg); + updateDeviceStatus(cameraInfo.getVideoDevId(), errorCode); + map.put("error", errorCode); + log.info("getPlaybackUrl:{}", errorMsg); } return map; } @Override - public Result> getPlaybackUrlList(CameraInfo cameraInfo){ - Map map = new HashMap<>(); + public Result> getPlaybackUrlList(CameraInfo cameraInfo) { + Map map = new HashMap<>(); String errorMsgs = ""; List dataList = Lists.newArrayList(); - Map chnMap = addPlaybackChn(cameraInfo); + Map chnMap = addPlaybackChn(cameraInfo); String chnError = chnMap.get("error").toString(); - if(chnError.equals("0")){ - List chnList = (List)chnMap.get("data"); - if(chnList!=null&&chnList.size()>0){ + if (chnError.equals("0")) { + List chnList = (List) chnMap.get("data"); + if (chnList != null && chnList.size() > 0) { TumsConfig tumsConfig = tumsConfigMapper.getByCode(); - for(int j=0;j playbackMap = getPlaybackUrl(chn,1); + Map playbackMap = getPlaybackUrl(chn, 1); String pbError = playbackMap.get("error").toString(); - if(pbError.equals("0")){ - List pbList = (List)playbackMap.get("data"); - if(pbList!=null&&pbList.size()>0){ - for(int k=0;k pbList = (List) playbackMap.get("data"); + if (pbList != null && pbList.size() > 0) { + for (int k = 0; k < pbList.size(); k++) { CameraInfo pb = pbList.get(k); pb.setQueryAddress(tumsConfig.getTumsUrl()); dataList.add(pb); } } - }else{ + } else { String errMsg = ""; - try{ + try { ErrorCode errVo = errorCodeService.getByCode(pbError); errMsg = errVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errMsg = pbError; } - errorMsgs = errorMsgs+ "
获取回放通道时:"+errMsg+"
"; + errorMsgs = errorMsgs + "
获取回放通道时:" + errMsg + "
"; } } } - }else{ + } else { String errMsg = ""; - try{ + try { ErrorCode errVo = errorCodeService.getByCode(chnError); errMsg = errVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errMsg = chnError; } - errorMsgs = errorMsgs+ "
添加回放通道时:"+errMsg+"
"; + errorMsgs = errorMsgs + "
添加回放通道时:" + errMsg + "
"; } - map.put("error",errorMsgs); - map.put("data",dataList); + map.put("error", errorMsgs); + map.put("data", dataList); return Result.ok(map); } /** * 删除某一回放通道 + * * @param videoDevId * @param sessionId */ - public void deletePlaybackChn(String videoDevId,String sessionId){ + public void deletePlaybackChn(String videoDevId, String sessionId) { StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("["); @@ -2513,27 +2534,27 @@ public class CameraInfoServiceImpl extends ServiceImpl deletePlaybackChn(CameraInfo cameraInfo){ + public Result deletePlaybackChn(CameraInfo cameraInfo) { String errorMsgs = ""; String sessions = cameraInfo.getSessionId(); - if(sessions!=null&&!sessions.equals("")){ + if (sessions != null && !sessions.equals("")) { String[] sessionIds = sessions.split(","); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"id\"").append(":").append("["); - for(int i=0;isessionId为"+sessionId+"的回放通道删除失败,原因:"+errMsg+""; + errorMsgs = errorMsgs + "
sessionId为" + sessionId + "的回放通道删除失败,原因:" + errMsg + "
"; } } - }else{ + } else { String errMsg = ""; - try{ + try { ErrorCode errVo = errorCodeService.getByCode(errorCode); errMsg = errVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errMsg = errorCode; } errorMsgs = errorMsgs + errMsg; - log.info("deletePlaybackChn:{}",errorMsgs); + log.info("deletePlaybackChn:{}", errorMsgs); } - if(errorMsgs.equals("")){ + if (errorMsgs.equals("")) { return Result.error(errorMsgs); - }else{ + } else { return Result.OK(""); } } @@ -2601,13 +2622,14 @@ public class CameraInfoServiceImpl extends ServiceImpl getMultitransUrl(CameraInfo cameraInfo,int counter){ - Map map = new HashMap<>(); - map.put("error","0"); - map.put("error","0"); + public Map getMultitransUrl(CameraInfo cameraInfo, int counter) { + Map map = new HashMap<>(); + map.put("error", "0"); + map.put("error", "0"); StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"devId\"").append(":").append("\"").append(cameraInfo.getVideoDevId()).append("\""); @@ -2615,7 +2637,7 @@ public class CameraInfoServiceImpl extends ServiceImpl10){ - map.put("error",errorCode); + if (counter > 10) { + map.put("error", errorCode); return map; } sleep(1000); - map = getMultitransUrl(cameraInfo,++counter); + map = getMultitransUrl(cameraInfo, ++counter); } catch (InterruptedException e) { e.printStackTrace(); } - }else{ + } else { String errorMsg = ""; - try{ + try { ErrorCode errorVo = errorCodeService.getByCode(errorCode); errorMsg = errorVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errorMsg = errorCode; } - updateDeviceStatus(cameraInfo.getVideoDevId(),errorCode); - map.put("error",errorCode); - log.info("getMultitransUrl:{}",errorMsg); + updateDeviceStatus(cameraInfo.getVideoDevId(), errorCode); + map.put("error", errorCode); + log.info("getMultitransUrl:{}", errorMsg); } return map; } /** * 获取nvmp设备双向通信URL + * * @param cameraInfo * @return */ @Override - public Result getMultitransUrl(CameraInfo cameraInfo) throws Exception{ + public Result getMultitransUrl(CameraInfo cameraInfo) throws Exception { String errorMsgs = ""; - Map multitransMap = getMultitransUrl(cameraInfo,1); + Map multitransMap = getMultitransUrl(cameraInfo, 1); String multitransError = multitransMap.get("error").toString(); - if(multitransError.equals("0")){ + if (multitransError.equals("0")) { TumsConfig tumsConfig = tumsConfigMapper.getByCode(); - CameraInfo entity = (CameraInfo)multitransMap.get("data"); + CameraInfo entity = (CameraInfo) multitransMap.get("data"); entity.setQueryAddress(tumsConfig.getTumsUrl()); return Result.OK(entity); - }else{ + } else { String errorMsg = ""; - try{ + try { ErrorCode errorVo = errorCodeService.getByCode(multitransError); errorMsg = errorVo.getErrorMsg(); - }catch (Exception e){ + } catch (Exception e) { errorMsg = multitransError; } - updateDeviceStatus(cameraInfo.getVideoDevId(),multitransError); - errorMsgs = errorMsgs+ "
获取nvmp设备双向通信URL:"+errorMsg+"
"; + updateDeviceStatus(cameraInfo.getVideoDevId(), multitransError); + errorMsgs = errorMsgs + "
获取nvmp设备双向通信URL:" + errorMsg + "
"; return Result.error(errorMsgs); } } /** * 回放视频转mp4上传 + * * @param cameraInfo * @return */ @Override - public Result uploadToServer(CameraInfo cameraInfo){ + public Result uploadToServer(CameraInfo cameraInfo) { String ftpUsername = ""; String ftpPassword = ""; String ftpUploadpath = ""; String ftpIp = ""; String ftpPort = ""; CameraInfo entity = baseMapper.getByDeviceId(cameraInfo); - if(entity.getFtpIp()!=null&&!entity.getFtpIp().equals("")){ + if (entity.getFtpIp() != null && !entity.getFtpIp().equals("")) { ftpIp = entity.getFtpIp(); ftpPort = entity.getFtpPort(); ftpUsername = entity.getFtpUsername(); ftpPassword = entity.getFtpPassword(); ftpUploadpath = entity.getFtpUploadpath(); - }else{ + } else { TumsConfig tumsConfig = tumsConfigMapper.getByCode(); ftpIp = tumsConfig.getFtpIp(); ftpPort = tumsConfig.getFtpPort(); @@ -2708,7 +2732,7 @@ public class CameraInfoServiceImpl extends ServiceImpl stopUploadToServer(CameraInfo cameraInfo){ + public Result stopUploadToServer(CameraInfo cameraInfo) { StringBuffer sb = new StringBuffer(); sb.append("{"); sb.append("\"taskId\"").append(":").append("\"").append(cameraInfo.getTaskId()).append("\""); @@ -2776,28 +2801,29 @@ public class CameraInfoServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("nu_id",nuId); + queryWrapper.eq("nu_id", nuId); List tplinkList = baseMapper.selectList(queryWrapper); - if(tplinkList.size() == 0){ + if (tplinkList.size() == 0) { return "error"; } - String fileName = nuId +"-"+DateUtils.formatDate(new Date(),"yyyyMMddHHmmss"); - String year = DateUtils.formatDate(new Date(),"yyyy"); - String month = DateUtils.formatDate(new Date(),"MM"); - String day = DateUtils.formatDate(new Date(),"dd"); + String fileName = nuId + "-" + DateUtils.formatDate(new Date(), "yyyyMMddHHmmss"); + String year = DateUtils.formatDate(new Date(), "yyyy"); + String month = DateUtils.formatDate(new Date(), "MM"); + String day = DateUtils.formatDate(new Date(), "dd"); CameraInfo tplinkInfo = tplinkList.get(0); CameraInfo cameraInfo = new CameraInfo(); cameraInfo.setDeviceIndex(tplinkInfo.getDeviceIndex()); cameraInfo.setParentId(tplinkInfo.getParentId()); cameraInfo.setFileName(fileName); cameraInfo.setVideoType("1"); - cameraInfo.setFtpUploadpath("/upFiles101/"+year+month+day+"/fwxm/tplinkVideo"); + cameraInfo.setFtpUploadpath(uploadpath + "/" + year + month + day + "/fwxm/tplinkVideo"); cameraInfo.setStartTime(startTime); cameraInfo.setEndTime(endTime); try { @@ -2916,6 +2944,7 @@ public class CameraInfoServiceImpl extends ServiceImpl getCameraInfoList() { List list = baseMapper.findAllList(); - List listDto =BeanUtil.copyToList(list, CameraInfoEntity.class); + List listDto = BeanUtil.copyToList(list, CameraInfoEntity.class); return listDto; } - public String mkdirsFolder(String folderPath){ + public String mkdirsFolder(String folderPath) { // 创建File对象 File folder = new File(folderPath); String ctxPath = uploadpath; diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/appraisal/controller/DirectiveAppraisalController.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/appraisal/controller/DirectiveAppraisalController.java index c1216d44..a183f512 100644 --- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/appraisal/controller/DirectiveAppraisalController.java +++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/appraisal/controller/DirectiveAppraisalController.java @@ -74,8 +74,7 @@ public class DirectiveAppraisalController extends JeecgController page = new Page(pageNo, pageSize); //排序:先撤回的放前面 再是未考核的 再是应该执行时间倒序 - queryWrapper.orderByAsc("CASE WHEN revocation IS NOT NULL AND revocation != '' THEN 0 ELSE 1 END"); - queryWrapper.orderByAsc("CASE WHEN status = 0 THEN 0 ELSE 1 END"); + queryWrapper.orderByAsc("CASE WHEN status = 4 THEN 0 WHEN status = 1 THEN 1 WHEN status = 2 THEN 999 WHEN status = 3 THEN 999 ELSE 999 END"); queryWrapper.orderByDesc("start_time"); IPage pageList = directiveAppraisalService.page(page, queryWrapper); diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/service/impl/DirectiveOrderPadServiceImpl.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/service/impl/DirectiveOrderPadServiceImpl.java index f90af904..620e575f 100644 --- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/service/impl/DirectiveOrderPadServiceImpl.java +++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/service/impl/DirectiveOrderPadServiceImpl.java @@ -14,6 +14,7 @@ import com.nu.modules.biz.order.entity.DirectiveOrderInfo; import com.nu.modules.biz.order.mapper.DirectiveOrderBizLogMapper; import com.nu.modules.biz.order.mapper.DirectiveOrderMapper; import com.nu.modules.biz.order.mapper.DirectiveOrderInfoMapper; +import com.nu.modules.biz.order.service.IDirectiveOrderInfoService; import com.nu.modules.biz.order.service.IDirectiveOrderService; import com.nu.modules.directiveorder.api.IDirectiveOrderLogApi; import com.nu.modules.order.api.IDirectiveOrderApi; @@ -49,6 +50,8 @@ public class DirectiveOrderPadServiceImpl extends ServiceImpl queryList(DirectiveOrderInfoEntity dto) { @@ -208,10 +211,19 @@ public class DirectiveOrderPadServiceImpl extends ServiceImpl editSubMp4(DirectiveOrderEntity directiveOrderEntity) { + //主表 DirectiveOrder directiveOrder = new DirectiveOrder(); directiveOrder.setId(directiveOrderEntity.getId()); directiveOrder.setManuallyMp4Path(directiveOrderEntity.getManuallyMp4Path()); directiveOrderService.updateById(directiveOrder); + + //子表 + DirectiveOrderInfo directiveOrderInfo = new DirectiveOrderInfo(); + directiveOrderInfo.setManuallyMp4Path(directiveOrderEntity.getManuallyMp4Path()); + UpdateWrapper uw = new UpdateWrapper<>(); + uw.eq("main_id",directiveOrderEntity.getId()); + directiveOrderInfoService.update(directiveOrderInfo,uw); + Map map = new HashMap<>(); map.put("success", true); map.put("message", "操作成功"); @@ -220,10 +232,19 @@ public class DirectiveOrderPadServiceImpl extends ServiceImpl editSubPicPath(DirectiveOrderEntity directiveOrderEntity) { + //主表 DirectiveOrder directiveOrder = new DirectiveOrder(); directiveOrder.setId(directiveOrderEntity.getId()); directiveOrder.setManuallyPicPath(directiveOrderEntity.getManuallyPicPath()); directiveOrderService.updateById(directiveOrder); + + //子表 + DirectiveOrderInfo directiveOrderInfo = new DirectiveOrderInfo(); + directiveOrderInfo.setManuallyPicPath(directiveOrderEntity.getManuallyPicPath()); + UpdateWrapper uw = new UpdateWrapper<>(); + uw.eq("main_id",directiveOrderEntity.getId()); + directiveOrderInfoService.update(directiveOrderInfo,uw); + Map map = new HashMap<>(); map.put("success", true); map.put("message", "操作成功");