package com.panzhihua.service_community.message;
|
|
import com.panzhihua.common.model.vos.LoginUserInfoVO;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.community.acid.ComActAcidRecordVO;
|
import com.panzhihua.common.service.user.UserService;
|
import com.panzhihua.common.utlis.StringUtils;
|
import com.panzhihua.common.utlis.WxUtil;
|
import com.panzhihua.common.utlis.WxXCXTempSend;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author zzj
|
*/
|
@Component
|
public class AcidMessage {
|
public static final String DELAYED_QUEUE="huacheng.acid.queue";
|
@Resource
|
private UserService userService;
|
@RabbitListener(queues=DELAYED_QUEUE)
|
public void doTemplate(ComActAcidRecordVO comActAcidRecordVO) throws Exception {
|
R<LoginUserInfoVO> loginUserInfoVOR= userService.getUserInfoByUserId(comActAcidRecordVO.getUserId().toString());
|
LoginUserInfoVO loginUserInfoVO=loginUserInfoVOR.getData();
|
if(loginUserInfoVO!=null&& StringUtils.isNotEmpty(loginUserInfoVO.getOpenid())){
|
WxXCXTempSend util = new WxXCXTempSend();
|
String accessToken = util.getAppAccessToken();
|
WxUtil.sendSubscribeTXTZ(loginUserInfoVO.getOpenid(),accessToken,"pov2BTQ_uILduT5OoVKubeS2dibbZ_p79cy5AMb_BGE");
|
}
|
}
|
}
|
