backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决微信推送服务器配置问题

Browse Source
This commit is contained in:
liyj 2025-09-20 10:15:36 +08:00
parent df4e5c26b1
commit 8ef1760b9d
3 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mall-account/src/main/java/com/suisung/mall/account/controller/mobile/WeiXinController.java
View File

@ -145,22 +145,16 @@ public class WeiXinController extends BaseControllerImpl {
@ApiOperation(value = "小程序回调", notes = "小程序回调") @ApiOperation(value = "小程序回调", notes = "小程序回调")
@RequestMapping(value = "/xcxCallBack", method = RequestMethod.GET) @RequestMapping(value = "/xcxCallBack", method = RequestMethod.GET)
public CommonResult xcxCallBack(@RequestParam(value = "signature",required = false) String signature, public String xcxCallBack(@RequestParam(value = "signature",required = false) String signature,
@RequestParam(value = "timestamp",required = false) String timestamp, @RequestParam(value = "timestamp",required = false) String timestamp,
@RequestParam(value = "nonce",required = false) String nonce, @RequestParam(value = "nonce",required = false) String nonce,
@RequestParam(value = "echostr",required = false) String echostr) { @RequestParam(value = "echostr",required = false) String echostr) {
if(StringUtils.isEmpty(signature) || StringUtils.isEmpty(timestamp) || StringUtils.isEmpty(nonce) || StringUtils.isEmpty(echostr) ) {
return CommonResult.success("校验成功");//todo 配置好消息链接改回来，腾讯服务器测试提交没有发送参数，导致报错
}
boolean checked=weiXinService.checkSignature(timestamp, nonce, signature); boolean checked=weiXinService.checkSignature(timestamp, nonce, signature);
if(checked){ if(checked){
return CommonResult.success("校验成功");
}
if(!checked){
return CommonResult.failed("校验失败");
}
accountUserBindConnectService.bindTmplId(echostr); accountUserBindConnectService.bindTmplId(echostr);
return CommonResult.success("小程序订阅消息模板绑定成功"); return echostr;
}
return "fail";
} }
} }

2
mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBindConnectService.java
View File

@ -93,5 +93,5 @@ public interface AccountUserBindConnectService extends IBaseService<AccountUserB
long getAllBindCount(Integer bind_type,String bindTmpl); long getAllBindCount(Integer bind_type,String bindTmpl);
boolean bindTmplId(String jsonObjectStr); void bindTmplId(String jsonObjectStr);
} }

7
mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java
View File

@ -25,6 +25,7 @@ import com.suisung.mall.core.web.service.impl.BaseServiceImpl;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DuplicateKeyException; import org.springframework.dao.DuplicateKeyException;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -526,12 +527,13 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
} }
@Override @Override
public boolean bindTmplId(String jsonObjectStr) { @Async
public void bindTmplId(String jsonObjectStr) {
JSONObject jsonObject= null; JSONObject jsonObject= null;
try { try {
jsonObject= JSONUtil.parseObj(jsonObjectStr); jsonObject= JSONUtil.parseObj(jsonObjectStr);
}catch (RuntimeException e) { }catch (RuntimeException e) {
throw new ApiException("非json数据"); log.info("错误信息--{}",e.getMessage());
} }
String openId=jsonObject.getStr("FromUserName");//用户openid String openId=jsonObject.getStr("FromUserName");//用户openid
QueryWrapper<AccountUserBindConnect> queryWrapper = new QueryWrapper<>(); QueryWrapper<AccountUserBindConnect> queryWrapper = new QueryWrapper<>();
@ -552,7 +554,6 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
} }
} }
} }
return true;
} }