zhangjinli 3 years ago
parent fe7141ce2c
commit 2cc628c7ba

@ -136,10 +136,14 @@ public class VideoController {
public Result valid(@Validated @RequestBody VVParam param) { public Result valid(@Validated @RequestBody VVParam param) {
int id = param.getId(); int id = param.getId();
Video video = videoService.getById(id); Video video = videoService.getById(id);
if(null == video){ if (null == video) {
return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "未找到该视频"); return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "未找到该视频");
} }
Integer originEffectResult = video.getEffectResult() == null ? 0 : video.getEffectResult(); Integer originEffectResult = video.getEffectResult() == null ? 0 : video.getEffectResult();
String touser = userService.getById(video.getUserId()).getUserid();
AppMessage appMessage = new AppMessage().setTitle("传播效果审核结果")
.setUrl("pages/quest/subpage/detail/detail?id=" + video.getTaskId())
.setReceiverId(video.getUserId());
if (param.getStatus() == 3) { if (param.getStatus() == 3) {
String reason = param.getReason(); String reason = param.getReason();
if (reason == null) { if (reason == null) {
@ -151,8 +155,16 @@ public class VideoController {
if (!op) { if (!op) {
return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "无效操作"); return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "无效操作");
} }
AppMessageUtil.sendMessage(new AppMessage().setTitle("传播效果审核结果").setDescription("您的抖音传播效果审核未通过,未通过原因:" + param.getReason() + "。") appMessage.setDescription("您的抖音传播效果审核未通过,未通过原因:" + param.getReason() + "。");
.setUrl("pages/quest/subpage/detail/detail?id=" + video.getTaskId()).setReceiverId(video.getUserId())); // 企业微信消息通知
if (touser != null) {
appMessage.setTouser(touser);
List<JSONObject> content_item = new ArrayList<>();
content_item.add(new JSONObject().fluentPut("key", "审核结果").fluentPut("value", appMessage.getDescription()));
content_item.add(new JSONObject().fluentPut("key", "审核时间").fluentPut("value", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
httpUtil.qywxMessage(httpUtil.qywxGetToken(), touser, "传播效果审核", null, appMessage.getUrl(), content_item);
}
AppMessageUtil.sendMessage(appMessage);
return Result.success("", "审核拒绝完成"); return Result.success("", "审核拒绝完成");
} }
UpdateWrapper<Video> up = new UpdateWrapper<>(); UpdateWrapper<Video> up = new UpdateWrapper<>();
@ -188,18 +200,14 @@ public class VideoController {
break; break;
default: default:
} }
AppMessage appMessage = new AppMessage().setTitle("传播效果审核结果") appMessage.setDescription("恭喜您," + platForm + "传播效果审核通过,平台评定传播值为" + effectResult + "。");
.setDescription("恭喜您," + platForm + "传播效果审核通过,平台评定传播值为" + effectResult + "。")
.setUrl("pages/quest/subpage/detail/detail?id=" + video.getTaskId())
.setReceiverId(video.getUserId());
// 企业微信消息通知 // 企业微信消息通知
String touser = userService.getById(video.getUserId()).getUserid();
if (touser != null) { if (touser != null) {
appMessage.setTouser(touser); appMessage.setTouser(touser);
List<JSONObject> content_item = new ArrayList<>(); List<JSONObject> content_item = new ArrayList<>();
content_item.add(new JSONObject().fluentPut("key","审核结果").fluentPut("value",appMessage.getDescription())); content_item.add(new JSONObject().fluentPut("key", "审核结果").fluentPut("value", appMessage.getDescription()));
content_item.add(new JSONObject().fluentPut("key","审核时间").fluentPut("value",LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")))); content_item.add(new JSONObject().fluentPut("key", "审核时间").fluentPut("value", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))));
httpUtil.qywxMessage(httpUtil.qywxGetToken(),touser,"传播效果审核",null,appMessage.getUrl(),content_item); httpUtil.qywxMessage(httpUtil.qywxGetToken(), touser, "传播效果审核", null, appMessage.getUrl(), content_item);
} }
AppMessageUtil.sendMessage(appMessage); AppMessageUtil.sendMessage(appMessage);
return Result.success("", "审核完成"); return Result.success("", "审核完成");

@ -48,7 +48,8 @@ public class AppMessageController {
User user = userService.selByOpenid(openid); User user = userService.selByOpenid(openid);
QueryWrapper<AppMessage> queryWrapper = new QueryWrapper<>(); QueryWrapper<AppMessage> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("receiverId", user.getId()); queryWrapper.eq("receiverId", user.getId());
queryWrapper.orderByDesc("settled","createDate"); queryWrapper.orderByAsc("settled");
queryWrapper.orderByDesc("createDate");
return Result.success(appMessageService.page(MybatisPlusUtil.SetPage(obj), queryWrapper), "请求成功"); return Result.success(appMessageService.page(MybatisPlusUtil.SetPage(obj), queryWrapper), "请求成功");
} }

@ -67,6 +67,7 @@ public class VideoUController {
@TokenValid @TokenValid
public Result userAdd(@Validated @RequestBody UserAddParam param, @RequestHeader("token") @Parameter(name = "登录token") String token) { public Result userAdd(@Validated @RequestBody UserAddParam param, @RequestHeader("token") @Parameter(name = "登录token") String token) {
Claims claims = new JwtUtil().parseJWT(token); Claims claims = new JwtUtil().parseJWT(token);
Integer taskId = param.getId();
Integer useId = userService.selByOpenid(claims.getId()).getId(); Integer useId = userService.selByOpenid(claims.getId()).getId();
// 校验用户和用户账号 // 校验用户和用户账号
if (useId == null) { if (useId == null) {
@ -79,7 +80,7 @@ public class VideoUController {
return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "账号不可用"); return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "账号不可用");
} }
// 校验任务状态 // 校验任务状态
Integer taskStatus = userTaskService.userTaskStatus(useId, param.getId()); Integer taskStatus = userTaskService.userTaskStatus(useId,taskId);
if (taskStatus == null) { if (taskStatus == null) {
return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "用户未接受任务"); return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "用户未接受任务");
} else if (taskStatus == 0) { } else if (taskStatus == 0) {
@ -89,12 +90,12 @@ public class VideoUController {
} }
// 不支持重复提交 // 不支持重复提交
QueryWrapper<Video> queryWrapper = new QueryWrapper<>(); QueryWrapper<Video> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("userId",useId).eq("type",param.getType()); queryWrapper.eq("userId",useId).eq("taskId",taskId).eq("type",param.getType());
if(videoService.getMap(queryWrapper)!=null){ if(videoService.getMap(queryWrapper)!=null){
return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "已提交过该平台视频"); return Result.fail(HttpStatusEnum.CUSTOM_EXCEPTION, "已提交过该平台视频");
} }
videoService.save(new Video().setUserId(useId).setTaskId(param.getId()).setType(param.getType()).setUrl(param.getUrl()).setCreatAt(LocalDateTime.now()).setUpdateAt(LocalDateTime.now())); videoService.save(new Video().setUserId(useId).setTaskId(taskId).setType(param.getType()).setUrl(param.getUrl()).setCreatAt(LocalDateTime.now()).setUpdateAt(LocalDateTime.now()));
return Result.success("添加完成!"); return Result.success("添加完成!");
} }

Loading…
Cancel
Save