修改图文审核的朋友圈接口

liwei2917
1 parent b1b3a24e
Showing 5 changed files with 65 additions and 36 deletions
src/main/java/com/cnlive/shenhe/api/ContentControllerApi.java
src/main/java/com/cnlive/shenhe/controller/ContentController.java
src/main/java/com/cnlive/shenhe/controller/VideosController.java
src/main/java/com/cnlive/shenhe/serviceImpl/ContentServiceImpl.java
src/main/java/com/cnlive/shenhe/serviceImpl/VideosServiceImpl.java
@@ -141,6 +141,7 @@ public class ContentControllerApi {
     		shyContent1.setSp_id(json.getInteger("spId"));//spid
     		shyContent1.setAuthor(json.getString("userId"));//用户id
     		shyContent1.setSource(json.getString("nickName"));//用户昵称
+    		shyContent1.setVideoId(json.getString("videoId"));//关联videoId
     		shyContent1.setContent_tag("moment");//图文标签
     		shyContent1.setReceive_status(CommonConst.RECEIVE_BEFORE);//领取状态
     		shyContent1.setLast_update(CommonUtils.getCurrentTime());//最后一次更新时间
@@ -171,6 +172,7 @@ public class ContentControllerApi {
     	shyContent.setSp_id(json.getInteger("spId"));//spid
     	shyContent.setAuthor(json.getString("userId"));//用户id
 		shyContent.setSource(json.getString("nickName"));//用户昵称
+		shyContent.setVideoId(json.getString("videoId"));//关联videoId
     	shyContent.setReceive_status(CommonConst.RECEIVE_BEFORE);//领取状态
     	shyContent.setLast_update(CommonUtils.getCurrentTime());//最后一次更新时间
     	boolean YorN = contentService.impotContent(shyContent);
@@ -163,7 +163,11 @@ public class ContentController {
     public ResponseBean pass(String ids, HttpSession session) {
         SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
         String userId = sessionUser.getUserId();
-        boolean success = contentService.updateState(ids,"审核通过", CommonConst.AUDIT_SUCCESS, userId);
+        boolean success =false;
+        String[] contentIds = ids.split(",");
+		for (String contentId : contentIds) {
+            success = contentService.callback(contentId,"审核通过", CommonConst.AUDIT_SUCCESS, userId);
+		}
         if (success) {
             return new ResponseBean();
         } else {
@@ -182,7 +186,11 @@ public class ContentController {
     public ResponseBean refuse(String ids,String msg, HttpSession session) {
         SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
         String userId = sessionUser.getUserId();
-        boolean success = contentService.updateState(ids,msg, CommonConst.AUDIT_REFUSE, userId);
+        boolean success =false;
+        String[] contentIds = ids.split(",");
+		for (String contentId : contentIds) {
+			 success = contentService.callback(contentId,msg, CommonConst.AUDIT_REFUSE, userId);
+		}
         if (success) {
             return new ResponseBean();
         } else {
@@ -437,31 +437,7 @@ public class VideosController {
         String[] shyVideoIds = ids.split(",");
         String showMsg = "";
         for (String shyVideoId : shyVideoIds) {
-            ShyVideos shyVideos = videosService.selectByPrimaryKey(Integer.parseInt(shyVideoId));
-            JSONObject result = null;
-            try {
-                result = Pass.auditPass(shyVideos.getVideo_id(), 4, msg, msg, shyVideos.getCallback());
-            } catch (Exception e) {
-                logger.error("视频审核失败,id==" + shyVideoId, e);
-                showMsg = showMsg + "," + shyVideos.getVideo_title() + " 拒绝请求失败";
-                break;
-            }
-            if (result == null) {
-                logger.error("视频审核失败且接口错误没有返回信息,id==" + shyVideoId);
-                showMsg = showMsg + "," + shyVideos.getVideo_title() + " 拒绝请求失败";
-                break;
-            }
-            Integer code = result.getInteger("code");
-            if (code != 0) {
-                logger.error("视频审核失败,id:{},code:{}", shyVideoId, code);
-                showMsg = showMsg + "," + shyVideos.getVideo_title() + " " + result.getString("msg");
-                break;
-            }
-            int i = videosService.updateVideo(Integer.parseInt(shyVideoId), userId,null,"", 2, msg);
-            if (i == 0) {
-                showMsg = showMsg + "," + shyVideos.getVideo_title() + " 更新失败";
-                break;
-            }
+             showMsg = videosService.repulse(shyVideoId, msg, userId);
         }
         if (CommonUtils.isNotEmpty(showMsg)) {
             responseBean.setErrorCode(ErrorEnum.ERROR.getErrorCode());
@@ -49,6 +49,8 @@ public class ContentServiceImpl {
     AuditPass Pass;
     @Autowired
     SitesServiceImpl sitesService;
+    @Autowired
+    VideosServiceImpl videosService;
     public List<ShySites> getBusiness(ShySites shySites) {
         List<ShySites> sitesList = shySitesMapper.select(shySites);
@@ -187,10 +189,8 @@ public class ContentServiceImpl {
     }
     //**********************
-	public boolean updateState(String ids, String msg, Integer state, String userId) {
-		boolean success = true;
-		String[] contentIds = ids.split(",");
-		for (String contentId : contentIds) {
+	public boolean callback(String contentId, String msg, Integer state, String userId) {
+			boolean success = true;
 			ShyContent content = shyContentMapper.selectByPrimaryKey(Integer.parseInt(contentId));
 			JSONObject result = new JSONObject();
 			try {
@@ -202,21 +202,33 @@ public class ContentServiceImpl {
 			} catch (Exception e) {
 				logger.error("图文审核回调失败，图文id:{}", content.getId());
 				success = false;
-				break;
+				return success;
 			}
 			if (result == null) {
 				logger.error("图文回调错误，且无返回信息。图文id:{}", content.getId());
 				success = false;
-				break;
+				return success;
 			} else {
 				Integer code = result.getInteger("errorCode");
-//				msg=CommonUtils.isNotEmpty(msg)?msg+",图文回调结果："+result.getString("errorMessage"):"图文回调结果："+result.getString("errorMessage");
 				if (code != 0) {
 					logger.error("图文回调错误，图文id:{}，errorCode:{},errorMessage:{}", content.getId(), code,
 							result.getString("errorMessage"));
 					success = false;
-					break;
+					return success;
+				}
+				
+				//如果当前图文是朋友圈的视频，通知点播云
+				if(CommonUtils.isNotEmpty(content.getContent_tag())
+						&&content.getContent_tag().equals("moment")
+						&&CommonUtils.isNotEmpty(content.getVideoId())
+						&&state==CommonConst.AUDIT_REFUSE){
+					String showMsg = videosService.repulse(content.getVideoId(), msg, userId);
+					if (CommonUtils.isNotEmpty(showMsg)) {
+						success = false;
+						return success;
+					}
 				}
+				
 				content.setContent_status(state);// 设置图文状态为审核后的状态
 				content.setReceive_status(CommonConst.RECEIVE_AUDIT);// 领取状态为已审核
 				content.setShenhe_msg(msg);// 设置审核消息
@@ -231,7 +243,6 @@ public class ContentServiceImpl {
 				}
 			}
-		}
 		return success;
 	}
@@ -431,5 +431,37 @@ public class VideosServiceImpl {
         }
         shyVideo.setShenhe_type(shenheType);
 	}
+	
+	
+	public String repulse(String shyVideoId,String msg,String userId){
+		 String showMsg="";
+		 ShyVideos shyVideos = videosService.selectByPrimaryKey(Integer.parseInt(shyVideoId));
+         JSONObject result = null;
+         try {
+             result = Pass.auditPass(shyVideos.getVideo_id(), 4, msg, msg, shyVideos.getCallback());
+         } catch (Exception e) {
+             logger.error("视频审核失败,id==" + shyVideoId, e);
+             showMsg = showMsg + "," + shyVideos.getVideo_title() + " 拒绝请求失败";
+             return showMsg;
+         }
+         if (result == null) {
+             logger.error("视频审核失败且接口错误没有返回信息,id==" + shyVideoId);
+             showMsg = showMsg + "," + shyVideos.getVideo_title() + " 拒绝请求失败";
+             return showMsg;
+         }
+         Integer code = result.getInteger("code");
+         if (code != 0) {
+             logger.error("视频审核失败,id:{},code:{}", shyVideoId, code);
+             showMsg = showMsg + "," + shyVideos.getVideo_title() + " " + result.getString("msg");
+             return showMsg;
+         }
+         int i = videosService.updateVideo(Integer.parseInt(shyVideoId), userId,null,"", 2, msg);
+         if (i == 0) {
+             showMsg = showMsg + "," + shyVideos.getVideo_title() + " 更新失败";
+             return showMsg;
+         }
+		
+		return showMsg;
+	}
 }