luyan
/
epmet-cloud-rizhao0920
forked from rongchao/epmet-cloud-rizhao
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

Merge branch 'dev_voice_share_point' into dev_temp

dev
zhaoqifeng 5 years ago
parent
08ea7d3bab eb863ab503
commit
aab6cefe53
16 changed files with 296 additions and 63 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      epmet-commons/epmet-commons-mybatis/src/main/java/com/epmet/commons/mybatis/service/BaseService.java
  2. 14
      epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.4__addNewRuleTemplate.sql
  3. 2
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/TopicDraftAttachmentDTO.java
  4. 8
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/CreateTopicFormDTO.java
  5. 24
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/FileDTO.java
  6. 6
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/TopicAttachmentResultDTO.java
  7. 26
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/TopicFileResultDTO.java
  8. 2
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/TopicDraftScanTaskDao.java
  9. 2
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/entity/TopicDraftAttachmentEntity.java
  10. 2
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/TopicDraftScanTaskService.java
  11. 15
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
  12. 1
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftAttachmentServiceImpl.java
  13. 6
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftScanTaskServiceImpl.java
  14. 238
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java
  15. 6
      epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/V0.0.11__topicShare.sql
  16. 5
      epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/TopicDraftScanTaskDao.xml

2
epmet-commons/epmet-commons-mybatis/src/main/java/com/epmet/commons/mybatis/service/BaseService.java
View File

@ -122,4 +122,6 @@ public interface BaseService<T> {
* @param idList 主键ID列表
*/
boolean deleteBatchIds(Collection<? extends Serializable> idList);
}

14
epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.4__addNewRuleTemplate.sql
View File

@ -24,43 +24,43 @@ VALUES
(
'3','发布话题',
'对小组内话题进行15字以上评论','publish_one_topic',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
15,'每天上限为15分',null,'day',5,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'4','参与话题',
'楼院小组内通过我有话说功能发布话题','participate_one_topic',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
6,'每天上限为6分',null,'day',2,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'5','话题被转为议题',
'小组中发布的话题被组长转为议题','topic_shifted_to_issue',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
0,'无上限',null,'day',15,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'6','话题被转为项目',
'小组中发布的话题被组长转为议题 又被网格员转为项目','topic_shifted_to_project',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
0,'无上限',null,'day',30,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'7','转话题为议题',
'将自建小组中话题转为议题','shift_topic_to_issue',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
15,'每天上限为15分',null,'day',5,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'8','邀请新人入组',
'通过话题/议题分享链接邀请新用户入组，需注册居民成功入组方能获得','invite_new_resident_into_group',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
0,'无上限',null,'day',30,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
),
(
'9','邀请入组',
'通过话题/议题分享链接邀请已注册用户入组，需通过入组审核方能获得','invite_resident_into_group',
'43addd0735230c01eedbb38d721076b0','plus',
'1','plus',
25,'每天上限为25分',null,'day',5,'time','0','0',0,'APP_USER',now(),'APP_USER',now()
)

2
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/TopicDraftAttachmentDTO.java
View File

@ -84,6 +84,8 @@ public class TopicDraftAttachmentDTO implements Serializable {
*/
private String status;
private String reason;
/**
* 语音或视频时长，秒
* */

8
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/CreateTopicFormDTO.java
View File

@ -62,17 +62,17 @@ public class CreateTopicFormDTO implements Serializable {
/**
* 图片附件
*/
private List<String> imageList;
private List<FileDTO> imageList;
/**
* 文件附件
*/
private List<String> docList;
private List<FileDTO> docList;
/**
* 语音附件
*/
private List<String> voiceList;
private List<FileDTO> voiceList;
/**
* 视频附件
*/
private List<String> videoList;
private List<FileDTO> videoList;
}

24
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/FileDTO.java
View File

@ -0,0 +1,24 @@
package com.epmet.resi.group.dto.topic.form;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @author zhaoqifeng
* @dscription
* @date 2020/12/24 14:09
*/
@NoArgsConstructor
@Data
public class FileDTO implements Serializable {
private static final long serialVersionUID = -3930520724652521552L;
private String name;
private String url;
private String type;
private String format;
private Integer size;
private Integer duration;
}

6
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/TopicAttachmentResultDTO.java
View File

@ -17,14 +17,14 @@ public class TopicAttachmentResultDTO implements Serializable {
/**
* 文件附件Url集合
*/
private LinkedList<String> docList;
private LinkedList<TopicFileResultDTO> docList;
/**
* 语音附件Url集合
*/
private LinkedList<String> voiceList;
private LinkedList<TopicFileResultDTO> voiceList;
/**
* 视频附件Url集合
*/
private LinkedList<String> videoList;
private LinkedList<TopicFileResultDTO> videoList;
}

26
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/TopicFileResultDTO.java
View File

@ -0,0 +1,26 @@
package com.epmet.resi.group.dto.topic.result;
import lombok.Data;
import java.io.Serializable;
import java.util.LinkedList;
/**
* @Author sun
* @Description 获取话题附件信息-接口返参
*/
@Data
public class TopicFileResultDTO implements Serializable {
private static final long serialVersionUID = -8606257390921799432L;
/**
* 文件Url
*/
private String url;
/**
* 语音或视频文件的时长，单位毫秒
*/
private Integer duration;
}

2
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/TopicDraftScanTaskDao.java
View File

@ -29,5 +29,5 @@ import org.apache.ibatis.annotations.Mapper;
*/
@Mapper
public interface TopicDraftScanTaskDao extends BaseDao<TopicDraftScanTaskEntity> {
void updateByTask(TopicDraftScanTaskEntity entity);
}

2
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/entity/TopicDraftAttachmentEntity.java
View File

@ -84,6 +84,8 @@ public class TopicDraftAttachmentEntity extends BaseEpmetEntity {
*/
private String status;
private String reason;
/**
* 语音或视频时长，秒
* */

2
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/TopicDraftScanTaskService.java
View File

@ -92,4 +92,6 @@ public interface TopicDraftScanTaskService extends BaseService<TopicDraftScanTas
* @date 2020-12-18
*/
void delete(String[] ids);
void updateByTask(TopicDraftScanTaskDTO dto);
}

15
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
View File

@ -1869,18 +1869,21 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
return resultDTO;
}
//2.封装数据并返回
LinkedList<String> docList = new LinkedList<>();
LinkedList<String> voiceList = new LinkedList<>();
LinkedList<String> videoList = new LinkedList<>();
LinkedList<TopicFileResultDTO> docList = new LinkedList<>();
LinkedList<TopicFileResultDTO> voiceList = new LinkedList<>();
LinkedList<TopicFileResultDTO> videoList = new LinkedList<>();
list.forEach(l->{
TopicFileResultDTO dto = new TopicFileResultDTO();
dto.setUrl(l.getAttachmentUrl());
dto.setDuration(l.getDuration());
if(TopicConstant.FILE_DOC.equals(l.getAttachmentType())){
docList.add(l.getAttachmentUrl());
docList.add(dto);
}
if(TopicConstant.FILE_VOICE.equals(l.getAttachmentType())){
voiceList.add(l.getAttachmentUrl());
voiceList.add(dto);
}
if(TopicConstant.FILE_VIDEO.equals(l.getAttachmentType())){
videoList.add(l.getAttachmentUrl());
videoList.add(dto);
}
});
resultDTO.setDocList(docList);

1
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftAttachmentServiceImpl.java
View File

@ -83,6 +83,7 @@ public class TopicDraftAttachmentServiceImpl extends BaseServiceImpl<TopicDraftA
public void save(TopicDraftAttachmentDTO dto) {
TopicDraftAttachmentEntity entity = ConvertUtils.sourceToTarget(dto, TopicDraftAttachmentEntity.class);
insert(entity);
ConvertUtils.sourceToTarget(entity, TopicDraftAttachmentDTO.class);
}
@Override

6
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftScanTaskServiceImpl.java
View File

@ -96,4 +96,10 @@ public class TopicDraftScanTaskServiceImpl extends BaseServiceImpl<TopicDraftSca
baseDao.deleteBatchIds(Arrays.asList(ids));
}
@Override
public void updateByTask(TopicDraftScanTaskDTO dto) {
TopicDraftScanTaskEntity entity = ConvertUtils.sourceToTarget(dto, TopicDraftScanTaskEntity.class);
baseDao.updateByTask(entity);
}
}

238
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java
View File

@ -17,24 +17,26 @@
package com.epmet.modules.topic.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
import com.epmet.commons.tools.constant.FieldConstant;
import com.epmet.commons.tools.constant.MqConstant;
import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.dto.form.mq.MqBaseMsgDTO;
import com.epmet.commons.tools.dto.form.mq.eventmsg.BasePointEventMsg;
import com.epmet.commons.tools.enums.EventEnum;
import com.epmet.commons.tools.exception.EpmetErrorCode;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.scan.param.ImgScanParamDTO;
import com.epmet.commons.tools.scan.param.ImgTaskDTO;
import com.epmet.commons.tools.scan.param.TextScanParamDTO;
import com.epmet.commons.tools.scan.param.TextTaskDTO;
import com.epmet.commons.tools.scan.param.*;
import com.epmet.commons.tools.scan.result.AsyncScanResult;
import com.epmet.commons.tools.scan.result.AsyncScanTaskDTO;
import com.epmet.commons.tools.scan.result.SyncScanResult;
import com.epmet.commons.tools.scan.result.VoiceResultDTO;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.DateUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.utils.ScanContentUtils;
import com.epmet.commons.tools.utils.*;
import com.epmet.dto.result.AllGridsByUserIdResultDTO;
import com.epmet.feign.GovOrgOpenFeignClient;
import com.epmet.modules.feign.EpmetUserFeignClient;
@ -53,6 +55,7 @@ import com.epmet.modules.topic.dao.TopicDraftDao;
import com.epmet.modules.topic.entity.*;
import com.epmet.modules.topic.service.TopicDraftAttachmentService;
import com.epmet.modules.topic.service.TopicDraftOperationService;
import com.epmet.modules.topic.service.TopicDraftScanTaskService;
import com.epmet.modules.topic.service.TopicDraftService;
import com.epmet.modules.utils.ModuleConstant;
import com.epmet.resi.group.constant.MemberStateConstant;
@ -61,10 +64,10 @@ import com.epmet.resi.group.dto.group.ResiGroupInfoRedisDTO;
import com.epmet.resi.group.dto.group.ResiGroupStatisticalInfoRedisDTO;
import com.epmet.resi.group.dto.member.ResiGroupMemberDTO;
import com.epmet.resi.group.dto.member.ResiGroupMemberInfoRedisDTO;
import com.epmet.resi.group.dto.topic.ResiTopicDTO;
import com.epmet.resi.group.dto.topic.TopicDraftAttachmentDTO;
import com.epmet.resi.group.dto.topic.TopicDraftDTO;
import com.epmet.resi.group.dto.topic.TopicDraftOperationDTO;
import com.epmet.resi.group.dto.topic.TopicDraftScanTaskDTO;
import com.epmet.resi.group.dto.topic.form.*;
import com.epmet.resi.group.dto.topic.result.DraftDetailResultDTO;
import com.epmet.resi.group.dto.topic.result.MyAuditingListResultDTO;
@ -96,6 +99,12 @@ import java.util.stream.Collectors;
public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicDraftEntity> implements TopicDraftService {
private static Logger logger = LoggerFactory.getLogger(TopicDraftServiceImpl.class);
private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
.setNameFormat("TopicDraftService-pool-%d").build();
private ExecutorService threadPool = new ThreadPoolExecutor(1, 1,
1L, TimeUnit.MINUTES,
new LinkedBlockingQueue<>(500), namedThreadFactory, new ThreadPoolExecutor.CallerRunsPolicy());
@Autowired
private GovOrgOpenFeignClient govOrgOpenFeignClient;
@ -132,6 +141,8 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
private TopicDraftOperationService topicDraftOperationService;
@Autowired
private ResiGroupMemberRedis resiGroupMemberRedis;
@Autowired
private TopicDraftScanTaskService topicDraftScanTaskService;
@Value("${openapi.scan.server.url}")
private String scanApiUrl;
@ -139,6 +150,10 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
private String textSyncScanMethod;
@Value("${openapi.scan.method.imgSyncScan}")
private String imgSyncScanMethod;
@Value("${openapi.scan.method.voiceAsyncScan}")
private String voiceAsyncScanMethod;
@Value("${openapi.scan.method.voiceResults}")
private String voiceResultsMethod;
@Override
public PageData<TopicDraftDTO> page(Map<String, Object> params) {
@ -234,6 +249,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
* @date 2020/12/17 15:49
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void createTopic(TokenDto tokenDto, CreateTopicFormDTO formDTO) {
if(StringUtils.isEmpty(formDTO.getTopicContent()) && CollectionUtils.isEmpty(formDTO.getVideoList())) {
//话题内容和语音不能同时为空
@ -259,32 +275,42 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
old.setIsSee(NumConstant.ONE_STR);
baseDao.updateById(old);
}
List<ImgTaskDTO> imageDTOList = new ArrayList<>();
if(CollectionUtils.isNotEmpty(formDTO.getImageList())){
TopicDraftAttachmentDTO attachment = new TopicDraftAttachmentDTO();
int sort = 0;
for(String url : formDTO.getImageList()){
attachment.setAttachmentUrl(url);
for(FileDTO file : formDTO.getImageList()){
attachment.setAttachmentUrl(file.getUrl());
attachment.setTopicDraftId(topic.getId());
attachment.setCreatedBy(tokenDto.getUserId());
attachment.setAttachmentFormat(url.substring(url.lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setAttachmentFormat(file.getUrl().substring(file.getUrl().lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setSort(sort++);
attachment.setAttachmentType("image");
topicDraftAttachmentService.save(attachment);
ImgTaskDTO task = new ImgTaskDTO();
task.setDataId(attachment.getId());
task.setUrl(file.getUrl());
imageDTOList.add(task);
}
}
List<VoiceTaskDTO> voiceDTOList = new ArrayList<>();
if(CollectionUtils.isNotEmpty(formDTO.getVideoList())){
TopicDraftAttachmentDTO attachment = new TopicDraftAttachmentDTO();
int sort = 0;
for(String url : formDTO.getVideoList()){
attachment.setAttachmentUrl(url);
for(FileDTO file : formDTO.getVideoList()){
attachment.setAttachmentUrl(file.getUrl());
attachment.setTopicDraftId(topic.getId());
attachment.setCreatedBy(tokenDto.getUserId());
attachment.setAttachmentFormat(url.substring(url.lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setAttachmentFormat(file.getUrl().substring(file.getUrl().lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setSort(sort++);
attachment.setAttachmentType("image");
attachment.setAttachmentType("voice");
topicDraftAttachmentService.save(attachment);
VoiceTaskDTO task = new VoiceTaskDTO();
task.setDataId(attachment.getId());
task.setUrl(file.getUrl());
voiceDTOList.add(task);
}
}
@ -313,7 +339,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
TopicDraftEntity draftEntity = new TopicDraftEntity();
draftEntity.setId(topic.getId());
draftEntity.setDraftStatus(TopicConstant.BLOCK);
draftEntity.setDraftReason("内容审核失败");
draftEntity.setDraftReason("话题存在违规内容");
baseDao.updateById(draftEntity);
//话题操作记录
TopicDraftOperationDTO operationDTO = new TopicDraftOperationDTO();
@ -328,14 +354,9 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
}
}
//创建话题图片审核
if (CollectionUtils.isNotEmpty(formDTO.getImageList())){
if (CollectionUtils.isNotEmpty(imageDTOList)){
ImgScanParamDTO imgScanParamDTO = new ImgScanParamDTO();
formDTO.getImageList().forEach(url -> {
ImgTaskDTO task = new ImgTaskDTO();
task.setDataId(UUID.randomUUID().toString().replace("-", ""));
task.setUrl(url);
imgScanParamDTO.getTasks().add(task);
});
imgScanParamDTO.setTasks(imageDTOList);
Result<SyncScanResult> imgScanResult = ScanContentUtils.imgSyncScan(scanApiUrl.concat(imgSyncScanMethod), imgScanParamDTO);
if (!imgScanResult.success()){
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode());
@ -345,7 +366,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
TopicDraftEntity draftEntity = new TopicDraftEntity();
draftEntity.setId(topic.getId());
draftEntity.setDraftStatus(TopicConstant.BLOCK);
draftEntity.setDraftReason("图片审核失败");
draftEntity.setDraftReason("图片存在违规内容");
baseDao.updateById(draftEntity);
//话题操作记录
TopicDraftOperationDTO operationDTO = new TopicDraftOperationDTO();
@ -355,21 +376,116 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
topicDraftOperationService.save(operationDTO);
throw new RenException(EpmetErrorCode.IMG_SCAN_FAILED.getCode());
}
if(CollectionUtils.isNotEmpty(imgScanResult.getData().getSuccessDataIds())) {
imgScanResult.getData().getSuccessDataIds().forEach(item -> {
TopicDraftAttachmentDTO dto = new TopicDraftAttachmentDTO();
dto.setId(item);
dto.setStatus(TopicConstant.AUTO_PASSED);
topicDraftAttachmentService.update(dto);
});
}
if(CollectionUtils.isNotEmpty(imgScanResult.getData().getFailDataIds())) {
imgScanResult.getData().getFailDataIds().forEach(item -> {
TopicDraftAttachmentDTO dto = new TopicDraftAttachmentDTO();
dto.setId(item);
dto.setStatus(TopicConstant.BLOCK);
dto.setReason("图片存在违规内容");
topicDraftAttachmentService.update(dto);
});
}
}
}
//TODO 创建话题语音审核
if (CollectionUtils.isNotEmpty(formDTO.getVideoList())){
ImgScanParamDTO imgScanParamDTO = new ImgScanParamDTO();
formDTO.getVideoList().forEach(url -> {
ImgTaskDTO task = new ImgTaskDTO();
task.setDataId(UUID.randomUUID().toString().replace("-", ""));
task.setUrl(url);
imgScanParamDTO.getTasks().add(task);
//TODO 根据返回值，
});
//创建话题语音审核
if (CollectionUtils.isNotEmpty(voiceDTOList)){
VoiceScanParamDTO voiceScanParamDTO = new VoiceScanParamDTO();
voiceScanParamDTO.setTasks(voiceDTOList);
voiceScanParamDTO.setOpenCallBack(false);
Result<AsyncScanResult> voiceScanResult = ScanContentUtils.voiceAsyncScan(scanApiUrl.concat(voiceAsyncScanMethod), voiceScanParamDTO);
if (!voiceScanResult.success() || !voiceScanResult.getData().isAllSuccess()){
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode());
} else {
List<AsyncScanTaskDTO> taskList = voiceScanResult.getData().getSuccessTasks();
List<String> taskIds = taskList.stream().map(AsyncScanTaskDTO :: getTaskId).collect(Collectors.toList());
//提交记录存入task表
List<TopicDraftScanTaskEntity> scanTaskEntityList = taskList.stream().map(item -> {
TopicDraftScanTaskEntity taskEntity = new TopicDraftScanTaskEntity();
taskEntity.setCustomerId(formDTO.getCustomerId());
taskEntity.setTopicDraftId(topic.getId());
taskEntity.setTopicDraftAttachmentId(item.getDataId());
taskEntity.setTaskId(item.getTaskId());
taskEntity.setStatus(TopicConstant.AUDITING);
taskEntity.setAttachmentType(TopicConstant.VOICE);
return taskEntity;
}).collect(Collectors.toList());
topicDraftScanTaskService.insertBatch(scanTaskEntityList);
//轮询
threadPool.submit(() -> {
while (true) {
Result<List<VoiceResultDTO>> voiceResults = ScanContentUtils.voiceResults(scanApiUrl.concat(voiceResultsMethod), taskIds);
if (voiceResults.success()) {
boolean isAllPass = true;
List<VoiceResultDTO> list = voiceResults.getData();
for (VoiceResultDTO item : list) {
if (TopicConstant.REVIEW.equals(item.getSuggestion())) {
//结果不确定
TopicDraftAttachmentDTO dto = new TopicDraftAttachmentDTO();
dto.setId(item.getDataId());
dto.setStatus(TopicConstant.REVIEW);
dto.setReason(item.getLabelDesc());
topicDraftAttachmentService.update(dto);
TopicDraftScanTaskDTO taskDTO = new TopicDraftScanTaskDTO();
taskDTO.setTaskId(item.getTaskId());
taskDTO.setStatus(TopicConstant.REVIEW);
topicDraftScanTaskService.updateByTask(taskDTO);
isAllPass = false;
} else if (TopicConstant.BLOCK.equals(item.getSuggestion())) {
//结果违规
TopicDraftAttachmentDTO dto = new TopicDraftAttachmentDTO();
dto.setId(item.getDataId());
dto.setStatus(TopicConstant.BLOCK);
dto.setReason(item.getLabelDesc());
topicDraftAttachmentService.update(dto);
TopicDraftScanTaskDTO taskDTO = new TopicDraftScanTaskDTO();
taskDTO.setTaskId(item.getTaskId());
taskDTO.setStatus(TopicConstant.BLOCK);
topicDraftScanTaskService.updateByTask(taskDTO);
isAllPass = false;
} else {
//审核通过
TopicDraftAttachmentDTO dto = new TopicDraftAttachmentDTO();
dto.setId(item.getDataId());
dto.setStatus(TopicConstant.AUTO_PASSED);
dto.setReason(item.getLabelDesc());
topicDraftAttachmentService.update(dto);
TopicDraftScanTaskDTO taskDTO = new TopicDraftScanTaskDTO();
taskDTO.setTaskId(item.getTaskId());
taskDTO.setStatus(TopicConstant.AUTO_PASSED);
topicDraftScanTaskService.updateByTask(taskDTO);
}
//审核通过，发布话题
if(isAllPass) {
saveTopic(tokenDto, formDTO, topic.getId());
}
}
break;
}
try {
Thread.sleep(600000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
} else {
//TODO 话题草稿状态为 auto_passed: 自动通过
//话题草稿状态为 auto_passed: 自动通过
//更新话题状态block
TopicDraftEntity draftEntity = new TopicDraftEntity();
draftEntity.setId(topic.getId());
@ -512,6 +628,8 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
voiceList.forEach(item -> item.setStatus(TopicConstant.APPROVED));
topicDraftAttachmentService.updateBatchById(ConvertUtils.sourceToTarget(voiceList, TopicDraftAttachmentEntity.class));
}
//发送积分
sendMqMsg(draft.getCreatedBy(), draft.getCustomerId());
}
//记录操作记录
TopicDraftOperationDTO operationDTO = new TopicDraftOperationDTO();
@ -553,17 +671,31 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
if(CollectionUtils.isNotEmpty(formDTO.getImageList())){
ResiTopicAttachmentEntity attachment = new ResiTopicAttachmentEntity();
int sort = 0;
for(String url : formDTO.getImageList()){
attachment.setAttachmentUrl(url);
for(FileDTO file : formDTO.getImageList()){
attachment.setAttachmentUrl(file.getUrl());
attachment.setTopicId(topic.getId());
attachment.setCreatedBy(tokenDto.getUserId());
attachment.setAttachmentFormat(url.substring(url.lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setAttachmentFormat(file.getUrl().substring(file.getUrl().lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setSort(sort++);
attachment.setAttachmentType("image");
resiTopicAttachmentDao.insertOne(attachment);
}
}
if(CollectionUtils.isNotEmpty(formDTO.getVoiceList())){
ResiTopicAttachmentEntity attachment = new ResiTopicAttachmentEntity();
int sort = 0;
for(FileDTO file : formDTO.getVoiceList()){
attachment.setAttachmentUrl(file.getUrl());
attachment.setTopicId(topic.getId());
attachment.setCreatedBy(tokenDto.getUserId());
attachment.setAttachmentFormat(file.getUrl().substring(file.getUrl().lastIndexOf(".") + NumConstant.ONE).toLowerCase());
attachment.setSort(sort++);
attachment.setAttachmentType("voice");
resiTopicAttachmentDao.insertOne(attachment);
}
}
//3.话题操作记录
ResiTopicOperationEntity operation = new ResiTopicOperationEntity();
operation.setTopicId(topic.getId());
@ -605,6 +737,30 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
draftEntity.setId(draftId);
draftEntity.setTopicId(topic.getId());
baseDao.updateById(draftEntity);
sendMqMsg(tokenDto.getUserId(), formDTO.getCustomerId());
}
private void sendMqMsg(String userId, String customerId) {
//6.发送积分
MqBaseMsgDTO mqBaseMsgDTO=new MqBaseMsgDTO();
//mq的事件类型
mqBaseMsgDTO.setEventClass(EventEnum.PUBLISH_ONE_TOPIC.getEventClass());
//事件code
mqBaseMsgDTO.setEventTag(EventEnum.PUBLISH_ONE_TOPIC.getEventTag());
List<BasePointEventMsg> actPointEventMsgList=new ArrayList<>();
BasePointEventMsg actPointEventMsg=new BasePointEventMsg();
actPointEventMsg.setCustomerId(customerId);
actPointEventMsg.setUserId(userId);
actPointEventMsg.setActionFlag(MqConstant.PLUS);
actPointEventMsg.setIsCommon(false);
actPointEventMsgList.add(actPointEventMsg);
mqBaseMsgDTO.setMsg(JSON.toJSONString(actPointEventMsgList));
Result mqResult = SendMqMsgUtils.sendMsg(mqBaseMsgDTO);
if(!mqResult.success()){
logger.error("发表话题积分添加失败");
}
}

6
epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/V0.0.11__topicShare.sql
View File

@ -37,4 +37,8 @@ CREATE TABLE `topic_share_link_visit_record`
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8mb4 COMMENT ='话题分享链接访问记录表';
DEFAULT CHARSET = utf8mb4 COMMENT ='话题分享链接访问记录表';
ALTER TABLE `topic_draft_attachment`
ADD COLUMN `REASON` varchar(255) NULL COMMENT '失败原因' AFTER `STATUS`;

5
epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/TopicDraftScanTaskDao.xml
View File

@ -18,6 +18,11 @@
<result property="updatedBy" column="UPDATED_BY"/>
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<update id="updateByTask">
update topic_draft_scan_task set
`STATUS` = #{status}
WHERE TASK_ID = #{taskId}
</update>
</mapper>
Write Preview
Loading…
Cancel
Save