Browse Source

feature-img-quan-1.0.0: 调整代码艺术家上传检测逻辑

feature-1.0-img-prototype
penny 4 years ago
parent
commit
7a9e906468
  1. 2
      bnyer-services/bnyer-file/src/main/java/com/bnyer/file/controller/SysFileController.java
  2. 8
      bnyer-services/bnyer-file/src/main/java/com/bnyer/file/service/impl/FileServiceImpl.java
  3. 2
      bnyer-services/bnyer-img/src/main/java/com/bnyer/img/constants/RedisKeyConstant.java
  4. 2
      bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/CreatorProfitService.java
  5. 8
      bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/CreatorProfitServiceImpl.java
  6. 6
      bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/UserDownloadSyncTask.java

2
bnyer-services/bnyer-file/src/main/java/com/bnyer/file/controller/SysFileController.java

@ -1,6 +1,5 @@
package com.bnyer.file.controller; package com.bnyer.file.controller;
import cn.hutool.log.Log;
import com.bnyer.common.core.domain.R; import com.bnyer.common.core.domain.R;
import com.bnyer.file.config.ImgConfig; import com.bnyer.file.config.ImgConfig;
import com.bnyer.file.dto.FileDto; import com.bnyer.file.dto.FileDto;
@ -20,7 +19,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;

8
bnyer-services/bnyer-file/src/main/java/com/bnyer/file/service/impl/FileServiceImpl.java

@ -9,10 +9,8 @@ import com.bnyer.file.service.IQiniuService;
import com.bnyer.file.service.ITikTokImage; import com.bnyer.file.service.ITikTokImage;
import com.bnyer.file.utils.ImgUtil; import com.bnyer.file.utils.ImgUtil;
import com.bnyer.file.vo.ChekFileVo; import com.bnyer.file.vo.ChekFileVo;
import com.bnyer.file.vo.TiktokImgVo;
import com.bnyer.img.api.RemoteImgService; import com.bnyer.img.api.RemoteImgService;
import com.bnyer.img.api.dto.TiktokImgMiniDto; import com.bnyer.img.api.dto.TiktokImgMiniDto;
import com.bnyer.system.api.RemoteFileService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.http.entity.ContentType; import org.apache.http.entity.ContentType;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -21,14 +19,12 @@ import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.UUID;
/** /**
* @Author: Yeman * @Author: Yeman
@ -89,7 +85,7 @@ public class FileServiceImpl implements IFileService {
@Override @Override
@Async("mySimpleAsync") @Async("mySimpleAsync")
public void checkUploadSave(FileUploadDto fileUploadDto) throws IOException { public void checkUploadSave(FileUploadDto fileUploadDto) throws IOException {
//redis累计平台用户当天下载次数,12.00后过期 //redis累计艺术家当天上传次数,12.00后过期
writeUploadTotalNum(fileUploadDto.getCreatorId()); writeUploadTotalNum(fileUploadDto.getCreatorId());
ArrayList<MultipartFile> multipartFiles = new ArrayList<>(); ArrayList<MultipartFile> multipartFiles = new ArrayList<>();
for (FileDto fileDto : fileUploadDto.getFiles()) { for (FileDto fileDto : fileUploadDto.getFiles()) {
@ -116,7 +112,7 @@ public class FileServiceImpl implements IFileService {
public void writeUploadTotalNum(Long creatorId) { public void writeUploadTotalNum(Long creatorId) {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
String date = df.format(new Date()); String date = df.format(new Date());
log.info("日期【{}】艺术家【{}】下载数+1",date,creatorId); log.info("日期【{}】艺术家【{}】上传数+1",date,creatorId);
String redisKey = RedisKeyConstant.CREATOR_UPLOAD_KEY + date; String redisKey = RedisKeyConstant.CREATOR_UPLOAD_KEY + date;
redisService.hashIncr(redisKey, creatorId.toString(), 1); redisService.hashIncr(redisKey, creatorId.toString(), 1);
} }

2
bnyer-services/bnyer-img/src/main/java/com/bnyer/img/constants/RedisKeyConstant.java

@ -100,5 +100,5 @@ public class RedisKeyConstant {
/** /**
* 艺术家上传键 * 艺术家上传键
*/ */
public static final String CREATOR_DOWNLOAD_KEY="bnyer.img.createor.download"; public static final String CREATOR_UPLOAD_KEY="bnyer.img.creator.upload:";
} }

2
bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/CreatorProfitService.java

@ -205,5 +205,5 @@ public interface CreatorProfitService {
/** /**
* 批量删除昨日艺术家上传次数 * 批量删除昨日艺术家上传次数
*/ */
void batchDeleteCreatorDownloadNum(); void batchDeleteCreatorUploadNum();
} }

8
bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/CreatorProfitServiceImpl.java

@ -389,9 +389,9 @@ public class CreatorProfitServiceImpl implements CreatorProfitService {
public boolean checkCreatorCanUpload(Long creatorId) { public boolean checkCreatorCanUpload(Long creatorId) {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
String date = df.format(new Date()); String date = df.format(new Date());
String redisKey = RedisKeyConstant.CREATOR_DOWNLOAD_KEY + date; String redisKey = RedisKeyConstant.CREATOR_UPLOAD_KEY + date;
if (redisService.hasHashKey(redisKey, creatorId.toString())) { if (redisService.hasHashKey(redisKey, creatorId.toString())) {
//存在键,判断次数,次数达标则不可下载 //存在键,判断次数,次数达标则不可上传
Integer downloadNum = redisService.getCacheMapValue(redisKey, creatorId.toString()); Integer downloadNum = redisService.getCacheMapValue(redisKey, creatorId.toString());
if (downloadNum >= 40) { if (downloadNum >= 40) {
return true; return true;
@ -405,14 +405,14 @@ public class CreatorProfitServiceImpl implements CreatorProfitService {
} }
@Override @Override
public void batchDeleteCreatorDownloadNum() { public void batchDeleteCreatorUploadNum() {
log.info("==============批量删除昨日艺术家上传次数开始!==============="); log.info("==============批量删除昨日艺术家上传次数开始!===============");
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
//获取昨日日期 //获取昨日日期
Date yesterday = new Date(startTime - 1000 * 60 * 60 * 24); Date yesterday = new Date(startTime - 1000 * 60 * 60 * 24);
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
String date = simpleDateFormat.format(yesterday); String date = simpleDateFormat.format(yesterday);
String redisKey = RedisKeyConstant.CREATOR_DOWNLOAD_KEY + date; String redisKey = RedisKeyConstant.CREATOR_UPLOAD_KEY + date;
if(redisService.hasKey(redisKey)){ if(redisService.hasKey(redisKey)){
redisService.deleteObject(redisKey); redisService.deleteObject(redisKey);
} }

6
bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/UserDownloadSyncTask.java

@ -28,9 +28,9 @@ public class UserDownloadSyncTask {
} }
@XxlJob("creatorDownloadSyncTask") @XxlJob("creatorDownloadSyncTask")
public ReturnT<String> syncCreatorDownload(String param) throws Exception { public ReturnT<String> syncCreatorUpload(String param) throws Exception {
creatorProfitService.batchDeleteCreatorDownloadNum(); creatorProfitService.batchDeleteCreatorUploadNum();
XxlJobLogger.log("{} 我执行了批量删除昨日用户下载次数任务", System.currentTimeMillis()); XxlJobLogger.log("{} 我执行了批量删除昨日用户上传次数任务", System.currentTimeMillis());
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
} }
} }

Loading…
Cancel
Save