| | |
|---|
| | | import cc.mrbird.febs.mall.mapper.*; |
|---|
| | | import cc.mrbird.febs.mall.service.*; |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.date.DateField; |
|---|
| | | import cn.hutool.core.date.DateTime; |
|---|
| | | import cn.hutool.core.date.DateUtil; |
|---|
| | | import cn.hutool.core.util.ObjectUtil; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import cn.hutool.crypto.SecureUtil; |
|---|
| | |
|---|
| | | private final IApiMallMemberWalletService memberWalletService; |
|---|
| | | private final MallRollPerkMapper mallRollPerkMapper; |
|---|
| | | private final IMallMoneyFlowService mallMoneyFlowService; |
|---|
| | | private final MallMemberClassMapper mallMemberClassMapper; |
|---|
| | | private final MallMemberHouseMapper mallMemberHouseMapper; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void rollSendMsg(Long orderId) { |
|---|
| | | MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(orderId); |
|---|
| | | if(ObjectUtil.isEmpty(mallOrderInfo)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | Long memberId = mallOrderInfo.getMemberId(); |
|---|
| | | MallMember mallMember = memberMapper.selectById(memberId); |
|---|
| | | if(ObjectUtil.isEmpty(mallMember)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderId); |
|---|
| | | if(CollUtil.isEmpty(mallOrderItemList)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | MallOrderItem mallOrderItem = mallOrderItemList.get(0); |
|---|
| | | String goodsName = mallOrderItem.getGoodsName(); |
|---|
| | | String skuImage = mallOrderItem.getSkuImage(); |
|---|
| | | Long goodsId = mallOrderItem.getGoodsId(); |
|---|
| | | MallGoods mallGoods = mallGoodsMapper.selectById(goodsId); |
|---|
| | | if(ObjectUtil.isEmpty(mallGoods)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | Integer isNormal = mallGoods.getIsNormal(); |
|---|
| | | if(4 == isNormal){ |
|---|
| | | //课程卷 |
|---|
| | | MallMemberClass mallMemberClass = new MallMemberClass(); |
|---|
| | | mallMemberClass.setMemberId(mallMember.getId()); |
|---|
| | | mallMemberClass.setOrderId(orderId); |
|---|
| | | mallMemberClass.setClassName(goodsName); |
|---|
| | | mallMemberClass.setClassPic(skuImage); |
|---|
| | | mallMemberClass.setClassUrl(skuImage); |
|---|
| | | mallMemberClassMapper.insert(mallMemberClass); |
|---|
| | | return; |
|---|
| | | }else if(5 == isNormal){ |
|---|
| | | //课程卷 |
|---|
| | | MallMemberHouse mallMemberHouse = new MallMemberHouse(); |
|---|
| | | mallMemberHouse.setOrderId(orderId); |
|---|
| | | mallMemberHouse.setMemberId(memberId); |
|---|
| | | mallMemberHouse.setState(1); |
|---|
| | | mallMemberHouse.setCreateTime(DateUtil.date()); |
|---|
| | | mallMemberHouse.setUpdateTime(mallOrderInfo.getUseTime()); |
|---|
| | | mallMemberHouse.setUnuseTime(DateUtil.date().offset(DateField.HOUR_OF_DAY,48)); |
|---|
| | | mallMemberHouse.setHouseName(mallGoods.getHouseName()); |
|---|
| | | mallMemberHouse.setHouseAddress(mallGoods.getHouseAddress()); |
|---|
| | | mallMemberHouseMapper.insert(mallMemberHouse); |
|---|
| | | return; |
|---|
| | | }else{ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void main(String[] args) { |
|---|
| | | |
|---|
| | | RestTemplate restTemplate = new RestTemplate(); |
|---|
| | | String accessToken = "70__DR_q_qmjcMfPQEBwmjdfJFWnpml55Bq6JK2vt9MMdcRLsHaYM1BQGFWzLUISjcFC8HAYTKOaPJH93KHNvo4KIeMZkxFF2qP66nAdygUQ6c"; |
|---|
| | | String openId = "oXL7Y6LW5KGQTbmmP5W3JljjApSo"; |
|---|
| | | String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN"; |
|---|
| | | // 创建一个StringHttpMessageConverter，并设置字符集为UTF-8 |
|---|
| | | StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8")); |
|---|
| | | stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN)); |
|---|
| | | // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中 |
|---|
| | | restTemplate.getMessageConverters().add(0, stringConverter); |
|---|
| | | // 创建HttpHeaders对象，设置Accept头部的值为"text/plain;charset=UTF-8" |
|---|
| | | HttpHeaders headers = new HttpHeaders(); |
|---|
| | | headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN)); |
|---|
| | | headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8"); |
|---|
| | | DateTime offset = DateUtil.date().offset(DateField.HOUR_OF_DAY, 48); |
|---|
| | | System.out.println(offset); |
|---|
| | | |
|---|
| | | String responseStr = restTemplate.getForObject(requrl, String.class); |
|---|
| | | net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr); |
|---|
| | | log.info("微信获取用户信息={}", json); |
|---|
| | | String nickname = json.getString("nickname"); |
|---|
| | | String headImgUrl = json.getString("headimgurl"); |
|---|
| | | System.out.println(nickname); |
|---|
| | | System.out.println(headImgUrl); |
|---|
| | | // RestTemplate restTemplate = new RestTemplate(); |
|---|
| | | // String accessToken = "70__DR_q_qmjcMfPQEBwmjdfJFWnpml55Bq6JK2vt9MMdcRLsHaYM1BQGFWzLUISjcFC8HAYTKOaPJH93KHNvo4KIeMZkxFF2qP66nAdygUQ6c"; |
|---|
| | | // String openId = "oXL7Y6LW5KGQTbmmP5W3JljjApSo"; |
|---|
| | | // String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN"; |
|---|
| | | // // 创建一个StringHttpMessageConverter，并设置字符集为UTF-8 |
|---|
| | | // StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8")); |
|---|
| | | // stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN)); |
|---|
| | | // // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中 |
|---|
| | | // restTemplate.getMessageConverters().add(0, stringConverter); |
|---|
| | | // // 创建HttpHeaders对象，设置Accept头部的值为"text/plain;charset=UTF-8" |
|---|
| | | // HttpHeaders headers = new HttpHeaders(); |
|---|
| | | // headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN)); |
|---|
| | | // headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8"); |
|---|
| | | // |
|---|
| | | // String responseStr = restTemplate.getForObject(requrl, String.class); |
|---|
| | | // net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr); |
|---|
| | | // log.info("微信获取用户信息={}", json); |
|---|
| | | // String nickname = json.getString("nickname"); |
|---|
| | | // String headImgUrl = json.getString("headimgurl"); |
|---|
| | | // System.out.println(nickname); |
|---|
| | | // System.out.println(headImgUrl); |
|---|
| | | } |
|---|
| | | } |
|---|
