Commit 49b0fd31c3d50f8b0f4f14c98e9b38ea144f8985

Authored by 王言钊
1 parent ea9898ed

优化直播、朋友圈、直播申请api

src/main/java/com/cnlive/shenhe/api/ContentControllerApi.java
@@ -148,29 +148,29 @@ public class ContentControllerApi { @@ -148,29 +148,29 @@ public class ContentControllerApi {
148 //获取生活圈内容的类型 1:图片 2:视频 3:分享 148 //获取生活圈内容的类型 1:图片 2:视频 3:分享
149 Integer contentType = json.getInteger("contentType"); 149 Integer contentType = json.getInteger("contentType");
150 //内容图片地址 150 //内容图片地址
151 - String contentImageUrl = ""; 151 + StringBuilder contentImageUrl = new StringBuilder();
152 if (contentType != null && contentType == 1) { 152 if (contentType != null && contentType == 1) {
153 //朋友圈分享的内容的url 153 //朋友圈分享的内容的url
154 JSONArray contentImageUrlList = JSONObject.parseArray(json.getString("contentImageUrl")); 154 JSONArray contentImageUrlList = JSONObject.parseArray(json.getString("contentImageUrl"));
155 for (int i = 0; i < contentImageUrlList.size(); i++) { 155 for (int i = 0; i < contentImageUrlList.size(); i++) {
156 JSONObject contentImageUrlMap = contentImageUrlList.getJSONObject(i); 156 JSONObject contentImageUrlMap = contentImageUrlList.getJSONObject(i);
157 - contentImageUrl += contentImageUrlMap.getString("imageUrl") + ","; 157 + contentImageUrl.append(contentImageUrlMap.getString("imageUrl")).append(",");
158 } 158 }
159 //去掉最后一个逗号 159 //去掉最后一个逗号
160 - contentImageUrl = contentImageUrl.substring(0, contentImageUrl.length() - 1); 160 + contentImageUrl = new StringBuilder(contentImageUrl.substring(0, contentImageUrl.length() - 1));
161 } else { 161 } else {
162 - contentImageUrl = json.getString("contentImageUrl"); 162 + contentImageUrl = new StringBuilder(json.getString("contentImageUrl"));
163 } 163 }
164 if (contentList.size() > 0) { 164 if (contentList.size() > 0) {
165 //朋友圈存在则更新 165 //朋友圈存在则更新
166 ShyContent shyContent1 = contentList.get(0); 166 ShyContent shyContent1 = contentList.get(0);
167 - yorN = saveOrUpdateMoment(json, shyContent1, shenheType, contentImageUrl); 167 + yorN = saveOrUpdateMoment(json, shyContent1, shenheType, contentImageUrl.toString());
168 logger.info("朋友圈接口更新操作:{}", momentId); 168 logger.info("朋友圈接口更新操作:{}", momentId);
169 } else { 169 } else {
170 //当前朋友圈内容的审核状态,先发后审 170 //当前朋友圈内容的审核状态,先发后审
171 shyContent.setContent_status(1); 171 shyContent.setContent_status(1);
172 //朋友圈不存在直接保存 172 //朋友圈不存在直接保存
173 - yorN = saveOrUpdateMoment(json, shyContent, shenheType, contentImageUrl); 173 + yorN = saveOrUpdateMoment(json, shyContent, shenheType, contentImageUrl.toString());
174 logger.info("朋友圈接口保存操作:{}", momentId); 174 logger.info("朋友圈接口保存操作:{}", momentId);
175 } 175 }
176 if (yorN) { 176 if (yorN) {
src/main/java/com/cnlive/shenhe/api/LiveApplyControllerApi.java
@@ -13,7 +13,6 @@ import org.springframework.web.bind.annotation.PostMapping; @@ -13,7 +13,6 @@ import org.springframework.web.bind.annotation.PostMapping;
13 import org.springframework.web.bind.annotation.RequestMapping; 13 import org.springframework.web.bind.annotation.RequestMapping;
14 import org.springframework.web.bind.annotation.ResponseBody; 14 import org.springframework.web.bind.annotation.ResponseBody;
15 15
16 -import java.sql.Timestamp;  
17 import java.util.Date; 16 import java.util.Date;
18 import java.util.List; 17 import java.util.List;
19 18
@@ -50,16 +49,10 @@ public class LiveApplyControllerApi { @@ -50,16 +49,10 @@ public class LiveApplyControllerApi {
50 } 49 }
51 //预计开始时间 50 //预计开始时间
52 String startTime = json.getString("preStartTime"); 51 String startTime = json.getString("preStartTime");
53 - Date timestampStart = null;  
54 - if (CommonUtils.isNotEmpty(startTime)) {  
55 - timestampStart = new Timestamp(Long.parseLong(startTime));  
56 - } 52 + Date timestampStart = CommonUtils.getStartAndEndTime(startTime);
57 //预计结束时间 53 //预计结束时间
58 String endTime = json.getString("preEndTime"); 54 String endTime = json.getString("preEndTime");
59 - Date timestampEnd = null;  
60 - if (CommonUtils.isNotEmpty(endTime)) {  
61 - timestampEnd = new Timestamp(Long.parseLong(endTime));  
62 - } 55 + Date timestampEnd =CommonUtils.getStartAndEndTime(endTime);
63 ShyLiveapply shyliveApply = new ShyLiveapply(); 56 ShyLiveapply shyliveApply = new ShyLiveapply();
64 //得到直播活动id去查询是否已有 57 //得到直播活动id去查询是否已有
65 shyliveApply.setActivity_id(activityId); 58 shyliveApply.setActivity_id(activityId);
@@ -127,15 +120,15 @@ public class LiveApplyControllerApi { @@ -127,15 +120,15 @@ public class LiveApplyControllerApi {
127 //内容简述 120 //内容简述
128 shyliveApply.setSimple_content(json.getString("simpleContent")); 121 shyliveApply.setSimple_content(json.getString("simpleContent"));
129 //要点报备:0品牌植入 1广告植入 2商品推销 3网家家独家麦标 122 //要点报备:0品牌植入 1广告植入 2商品推销 3网家家独家麦标
130 - shyliveApply.setPoint_key(json.getString("keys").equals("") ? "无" : json.getString("keys")); 123 + shyliveApply.setPoint_key("".equals(json.getString("keys")) ? "无" : json.getString("keys"));
131 //直播地点 124 //直播地点
132 shyliveApply.setLive_place(json.getString("livePlace")); 125 shyliveApply.setLive_place(json.getString("livePlace"));
133 //推流地址 126 //推流地址
134 shyliveApply.setPush_url(json.getString("pushUrl")); 127 shyliveApply.setPush_url(json.getString("pushUrl"));
135 //拉流地址 128 //拉流地址
136 - shyliveApply.setPull_url(json.getString("pullUrl").equals("") ? "无拉流地址" : json.getString("pullUrl")); 129 + shyliveApply.setPull_url("".equals(json.getString("pullUrl")) ? "无拉流地址" : json.getString("pullUrl"));
137 //拉流来源 130 //拉流来源
138 - shyliveApply.setPull_source(json.getString("pullSource").equals("") ? "无来源" : json.getString("pullSource")); 131 + shyliveApply.setPull_source("".equals(json.getString("pullSource")) ? "无来源" : json.getString("pullSource"));
139 //播出平台及通道:0网家家 1CNLive网站 2@TV互动电视 132 //播出平台及通道:0网家家 1CNLive网站 2@TV互动电视
140 shyliveApply.setPlatforms(json.getString("platforms")); 133 shyliveApply.setPlatforms(json.getString("platforms"));
141 //设置回调地址 134 //设置回调地址
src/main/java/com/cnlive/shenhe/api/LiveControllerApi.java
@@ -14,7 +14,6 @@ import org.springframework.web.bind.annotation.PostMapping; @@ -14,7 +14,6 @@ import org.springframework.web.bind.annotation.PostMapping;
14 import org.springframework.web.bind.annotation.RequestMapping; 14 import org.springframework.web.bind.annotation.RequestMapping;
15 import org.springframework.web.bind.annotation.ResponseBody; 15 import org.springframework.web.bind.annotation.ResponseBody;
16 16
17 -import java.sql.Timestamp;  
18 import java.util.Date; 17 import java.util.Date;
19 import java.util.List; 18 import java.util.List;
20 19
@@ -49,28 +48,16 @@ public class LiveControllerApi { @@ -49,28 +48,16 @@ public class LiveControllerApi {
49 String channelId = json.getString("channelId"); 48 String channelId = json.getString("channelId");
50 //开始时间 49 //开始时间
51 String startTime = json.getString("startTime"); 50 String startTime = json.getString("startTime");
52 - Date timestampStart = null;  
53 - if (CommonUtils.isNotEmpty(startTime)) {  
54 - timestampStart = new Timestamp(Long.parseLong(startTime));  
55 - } 51 + Date timestampStart = CommonUtils.getStartAndEndTime(startTime);
56 //结束时间 52 //结束时间
57 String endTime = json.getString("endTime"); 53 String endTime = json.getString("endTime");
58 - Date timestampEnd = null;  
59 - if (CommonUtils.isNotEmpty(endTime)) {  
60 - timestampEnd = new Timestamp(Long.parseLong(endTime));  
61 - } 54 + Date timestampEnd = CommonUtils.getStartAndEndTime(endTime);
62 //预计开始时间 55 //预计开始时间
63 String preStartTime = json.getString("preStartTime"); 56 String preStartTime = json.getString("preStartTime");
64 - Date preTimestampStart = null;  
65 - if (CommonUtils.isNotEmpty(preStartTime)) {  
66 - preTimestampStart = new Timestamp(Long.parseLong(preStartTime));  
67 - } 57 + Date preTimestampStart = CommonUtils.getStartAndEndTime(preStartTime);
68 //预计结束时间 58 //预计结束时间
69 String preEndTime = json.getString("preEndTime"); 59 String preEndTime = json.getString("preEndTime");
70 - Date preTimestampEnd = null;  
71 - if (CommonUtils.isNotEmpty(preEndTime)) {  
72 - preTimestampEnd = new Timestamp(Long.parseLong(preEndTime));  
73 - } 60 + Date preTimestampEnd = CommonUtils.getStartAndEndTime(preEndTime);
74 ShyLive shyLive = new ShyLive(); 61 ShyLive shyLive = new ShyLive();
75 //得到直播活动id去查询是否已有 62 //得到直播活动id去查询是否已有
76 shyLive.setActivity_id(activityId); 63 shyLive.setActivity_id(activityId);
src/main/java/com/cnlive/shenhe/utils/CommonUtils.java
@@ -576,4 +576,16 @@ public class CommonUtils { @@ -576,4 +576,16 @@ public class CommonUtils {
576 } 576 }
577 return dateTime; 577 return dateTime;
578 } 578 }
  579 +
  580 + /**
  581 + * 获取直播、直播申请中的预计开始、结束时间
  582 + *
  583 + * @return
  584 + */
  585 + public static Date getStartAndEndTime(String preStartAndEndTime) {
  586 + if (CommonUtils.isNotEmpty(preStartAndEndTime)) {
  587 + return new Timestamp(Long.parseLong(preStartAndEndTime));
  588 + }
  589 + return null;
  590 + }
579 } 591 }