czg_team/video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/test' into test

Browse Source
This commit is contained in:
Tankaikai
2024-12-24 14:51:05 +08:00
parent ebbd658ffb 310f5b831c
commit 6477e48b44
3 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/com/sqx/modules/callback/UniCallBackController.java
View File

@@ -1,14 +1,10 @@
package com.sqx.modules.callback; package com.sqx.modules.callback;
import com.sqx.common.utils.Result;
import com.sqx.modules.callback.dao.UniAdCallBackDTO; import com.sqx.modules.callback.dao.UniAdCallBackDTO;
import com.sqx.modules.callback.service.UniAdCallbackRecordService; import com.sqx.modules.callback.service.UniAdCallbackRecordService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController @RestController
@RequestMapping("/uniCallBack") @RequestMapping("/uniCallBack")
@@ -21,8 +17,18 @@ public class UniCallBackController {
} }
@GetMapping("/adCallBack") @GetMapping("/adCallBack")
public ResponseEntity<?> adCallBack(@RequestBody UniAdCallBackDTO callBackDTO) { public ResponseEntity<?> adCallBack(@RequestParam String adpid, @RequestParam String provider,
log.info("接收到uni-ad广告完播回调，回调信息: {}", callBackDTO); @RequestParam String platform, @RequestParam String sign, @RequestParam String trans_id,
return ResponseEntity.ok(uniCallBackService.adCallBack(callBackDTO)); @RequestParam String user_id, @RequestParam(required = false) String extra) {
UniAdCallBackDTO dto = new UniAdCallBackDTO();
dto.setAdpid(adpid);
dto.setProvider(provider);
dto.setPlatform(platform);
dto.setSign(sign);
dto.setTrans_id(trans_id);
dto.setUser_id(user_id);
dto.setExtra(extra);
log.info("接收到uni-ad广告完播回调，回调信息: {}", dto);
return ResponseEntity.ok(uniCallBackService.adCallBack(dto));
} }
} }

2
src/main/java/com/sqx/modules/callback/service/impl/UniAdCallbackRecordServiceImpl.java
View File

@@ -115,7 +115,7 @@ public class UniAdCallbackRecordServiceImpl extends ServiceImpl<UniAdCallbackRec
return respData; return respData;
} }
redisService.setFreeWatchTime(callbackRecord.getUserId(), Integer.valueOf(info.getValue()), true); redisService.setFreeWatchTime(callbackRecord.getUserId(), Integer.parseInt(info.getValue()) * 60, true);
save(callbackRecord); save(callbackRecord);
respData.put("isValid", true); respData.put("isValid", true);
return respData; return respData;

2
src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java
View File

@@ -113,7 +113,7 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cour
// 购买次数超过，设置redis标识 // 购买次数超过，设置redis标识
if (count >= Integer.parseInt(needCountCommonInfo.getValue())) { if (count >= Integer.parseInt(needCountCommonInfo.getValue())) {
redisServiceImpl.setFreeWatchTime(userId, Integer.parseInt(freeTimeCommonInfo.getValue()), false); redisServiceImpl.setFreeWatchTime(userId, Integer.parseInt(freeTimeCommonInfo.getValue()) * 60, false);
// 触发计时 // 触发计时
redisServiceImpl.getFreeWatchTimeIsExpire(userId); redisServiceImpl.getFreeWatchTimeIsExpire(userId);
isExpire = false; isExpire = false;