朋友圈

liwei2917
1 parent 56785d77
Showing 3 changed files with 22 additions and 8 deletions
src/main/java/com/cnlive/shenhe/api/ContentControllerApi.java
src/main/java/com/cnlive/shenhe/serviceImpl/ContentServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/AuditPass.java
@@ -139,6 +139,8 @@ public class ContentControllerApi {
     		shyContent1.setCallback(json.getString("callbackUrl"));//回调地址
     		shyContent1.setContent_url(json.getString("pageUrl"));//朋友圈分享的url
     		shyContent1.setSp_id(json.getInteger("spId"));//spid
+    		shyContent1.setAuthor(json.getString("userId"));//用户id
+    		shyContent1.setSource(json.getString("nickName"));//用户昵称
     		shyContent1.setContent_tag("moment");//图文标签
     		shyContent1.setReceive_status(CommonConst.RECEIVE_BEFORE);//领取状态
     		shyContent1.setLast_update(CommonUtils.getCurrentTime());//最后一次更新时间
@@ -156,7 +158,7 @@ public class ContentControllerApi {
     	shyContent.setTitle(json.getString("title"));//标题
     	shyContent.setTitle_image(json.getString("image"));//用户头像
     	shyContent.setShenhe_type(CommonConst.AUDIT_TYPE_USER);//审核类型是人工
-    	shyContent.setContent_status(0);//当前朋友圈内容的审核状态
+    	shyContent.setContent_status(1);//当前朋友圈内容的审核状态，先发后审
     	String contentTime = json.getString("createTime");//创建时间
     	if (CommonUtils.isNotEmpty(contentTime)) {
     		Date timestamp = CommonUtils.getTimestamp(contentTime, "yyyy-MM-dd HH:mm:ss");
@@ -167,6 +169,8 @@ public class ContentControllerApi {
     	shyContent.setCallback(json.getString("callbackUrl"));//回调地址
     	shyContent.setContent_url(json.getString("pageUrl"));//朋友圈分享的url
     	shyContent.setSp_id(json.getInteger("spId"));//spid
+    	shyContent.setAuthor(json.getString("userId"));//用户id
+		shyContent.setSource(json.getString("nickName"));//用户昵称
     	shyContent.setReceive_status(CommonConst.RECEIVE_BEFORE);//领取状态
     	shyContent.setLast_update(CommonUtils.getCurrentTime());//最后一次更新时间
     	boolean YorN = contentService.impotContent(shyContent);
@@ -193,14 +193,12 @@ public class ContentServiceImpl {
 		for (String contentId : contentIds) {
 			ShyContent content = shyContentMapper.selectByPrimaryKey(Integer.parseInt(contentId));
 			JSONObject result = new JSONObject();
-//			String type = "fabu";// 1、fabu，2、xiaxian，3、shanchu
-//			if (state == 2) {
-//				type = "xiaxian";
-//			} else if (state == 3) {
-//				type = "shanchu";
-//			}
 			try {
-				result = Pass.contentPass(content.getContent_id(), state+"", msg, content.getCallback());
+				if(CommonUtils.isNotEmpty(content.getContent_tag())&&content.getContent_tag().equals("content")){
+					result = Pass.contentPass(content.getContent_id(), state+"", msg, content.getCallback());
+				}else if(CommonUtils.isNotEmpty(content.getContent_tag())&&content.getContent_tag().equals("moment")){
+					result = Pass.momentPass(content.getContent_id(), state, msg, content.getCallback(),content.getAuthor());
+				}
 			} catch (Exception e) {
 				logger.error("图文审核回调失败，图文id:{}", content.getId());
 				success = false;
@@ -107,4 +107,16 @@ public class AuditPass {
         Map<String, String> post = httpUtil.post(URL);
         return JSONObject.parseObject(post.get("result"));
     }
+	public JSONObject momentPass(String content_id, Integer state, String msg, String callback, String userId) {
+		logger.info("朋友圈回调：content_id:{},state:{},msg:{},userId:{}", content_id, state, msg,userId);
+		JSONObject json=new JSONObject();
+		json.put("userId",userId );
+		json.put("momentId",content_id );
+		json.put("status",state );
+		json.put("msg", msg);
+		String httpUtilResult = HttpClientUtils.HttpPostWithJson(callback, json.toString());
+		logger.info("朋友圈返回数据，httpUtilResult=====" + httpUtilResult);
+        JSONObject result = JSONObject.parseObject(httpUtilResult);
+		return result;
+	}
 }