package com.xiaopeng.account.controller;
|
|
|
import com.alibaba.fastjson2.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.xiaopeng.account.service.IUserSubscribeMessageService;
|
import com.xiaopeng.account.vo.UserSubscribeMessageVo;
|
import com.xiaopeng.api.dto.account.ThirdInfoResVo;
|
import com.xiaopeng.api.dto.account.ThirdInfoVo;
|
import com.xiaopeng.api.dto.account.UserResourcesDto;
|
import com.xiaopeng.api.feignClient.account.SSOClient;
|
import com.xiaopeng.api.feignClient.account.ThirdClient;
|
import com.xiaopeng.api.feignClient.pushMessage.SubscribeMessageClient;
|
import com.xiaopeng.api.model.account.UserSubscribeMessage;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.utils.StringUtils;
|
import com.xiaopeng.unifiedverification.interceptor.XpClientCheck;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.List;
|
|
@Slf4j
|
@RestController
|
@RequestMapping("")
|
public class UserSubscribeMessageController {
|
|
@Resource
|
private IUserSubscribeMessageService userSubscribeMessageService;
|
|
@Resource
|
private SubscribeMessageClient subscribeMessageClient;
|
|
@Resource
|
private ThirdClient thirdClient;
|
|
@Value("${third.appid}")
|
private String appId;
|
|
|
|
@PostMapping("/api/v1/mini-program/subscribeMessage/saveUserSubscribeMessage")
|
@ApiOperation(value = "授权消息模板", tags = {"小程序-优惠券"})
|
@XpClientCheck(checkToken = false, checkOtpToken = true)
|
public R<?> saveUserSubscribeMessage(@RequestBody UserSubscribeMessageVo vo, HttpServletRequest request){
|
String uid = request.getHeader("XP-Uid");
|
ThirdInfoResVo userResourcesDto = thirdClient.thirdInfo(appId, Long.valueOf(uid), 3);
|
log.info("调用三方获取用户openid {}", JSON.toJSONString(userResourcesDto));
|
if(null == userResourcesDto){
|
return R.fail("获取openid失败");
|
}
|
if(0 != userResourcesDto.getCode()){
|
return R.fail("获取openid失败：{}", userResourcesDto.getMsg());
|
}
|
ThirdInfoVo thirdInfoVo = userResourcesDto.getData();
|
if(null != thirdInfoVo){
|
List<String> templateIds = vo.getTemplateIds();
|
userSubscribeMessageService.remove(new LambdaQueryWrapper<UserSubscribeMessage>()
|
.eq(UserSubscribeMessage::getUserId, uid).in(UserSubscribeMessage::getTemplateId, templateIds));
|
for (String templateId : templateIds) {
|
UserSubscribeMessage userSubscribeMessage = new UserSubscribeMessage();
|
userSubscribeMessage.setUserId(Long.valueOf(uid));
|
userSubscribeMessage.setTemplateId(templateId);
|
userSubscribeMessage.setStatus(1);
|
userSubscribeMessage.setOpenId(thirdInfoVo.getThirdId());
|
userSubscribeMessage.setDeleted(false);
|
userSubscribeMessageService.save(userSubscribeMessage);
|
}
|
}
|
return R.ok();
|
}
|
|
|
@GetMapping("/logan/inner/v1/subscribeMessage/getUserOpenId/{uid}")
|
public R<String> getUserOpenId(@PathVariable("uid") Integer uid){
|
UserSubscribeMessage one = userSubscribeMessageService.getOne(new LambdaQueryWrapper<UserSubscribeMessage>()
|
.eq(UserSubscribeMessage::getUserId, uid).last(" limit 1"));
|
return R.ok(null != one ? one.getOpenId() : "");
|
}
|
}
|
