devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

开发笔记 | JAVA获取微信步数+日周月排行榜的实现_java获取微信步数api

作者：Cpp五条 | 2024-03-25 08:06:43

赞

踩

java获取微信步数api

目录

功能描述

微信步数同步

获取我当日的步数

日排行，周排行，月排行榜的实现

功能描述

实现微信步数的同步(也就是获取当前的微信步数更新至数据库)

实现获取我当日的微信步数的查询

实现按照日排行，周排行，月排行榜的功能

主要思路：通过前端传递的encryptedData加密数据包，解密后得到微信步数，此文中的方式，为前端获取微信步数并将加密数据包发送后端解析。

注意的点：数据库表设计为，一个用户，一天一条步数信息，在当天，第一次获取微信步数后为新增，之后同步均为更新，在根据不同条件获取排名时，将同一个用户，处于这个时间段内的步数相加后排序得出排名。

微信步数同步

请求参数实体

  1. @Data
  2. public class StepDTO implements Serializable {
  3.  
  4.     @ApiModelProperty(value = "小程序用户id",required=true)
  5.     @NotBlank(message = "小程序用户id不能为空")
  6.     private  String  appUserId;
  7.  
  8.     @ApiModelProperty(value = "微信昵称",required=true)
  9.     @NotBlank(message = "微信昵称不能为空")
  10.     private  String  nickName;
  11.  
  12.     //前端传递的步数数据包 用于解密获取步数
  13.     @ApiModelProperty(value = "数据包",required=true)
  14.     @NotBlank(message = "前端数据包不能为空")
  15.     private String encryptedData;
  16.  
  17.     @ApiModelProperty(value = "iv" ,required=true)
  18.     @NotBlank(message = "iv不能为空")
  19.     private String iv;
  20.  
  21.     @ApiModelProperty(value = "session_key" ,required=false)
  22.     private String sessionKey;
  23.  
  24.     @ApiModelProperty(value = "步数")
  25.     private String step;
  26.  
  27. }

返回结果实体

  1. @Data
  2. public class BizStep extends BaseEntity{
  3.  
  4.     private static final long serialVersionUID = 1L;
  5.  
  6.     @ApiModelProperty(value = "小程序用户id")
  7.     private  String  appUserId;
  8.  
  9.     @ApiModelProperty(value = "微信昵称")
  10.     private  String  wechatName;
  11.  
  12.     @ApiModelProperty(value = "姓名")
  13.     private  String  name;
  14.  
  15.     @ApiModelProperty(value = "步数")
  16.     private  Integer  step;
  17.  
  18.     @ApiModelProperty(value = "头像")
  19.     private String avatar ;
  20.  
  21.     @ApiModelProperty(value = "session_key")
  22.     private String sessionKey;
  23.  
  24.     @ApiModelProperty(value = "手机号码")
  25.     private String mobile;
  26.  
  27. }

微信步数VO

  1. @Data
  2. public class WxRunDataBO {
  3.  
  4.     @ApiModelProperty("stepInfoList")
  5.     private List<StepInfoListBO> stepInfoList;
  6.  
  7.     @ApiModelProperty("stepInfoList")
  8.     private WatermarkBO watermark;
  9. }
  10.  
  11. @Data
  12. public class StepInfoListBO {
  13.  
  14.     @ApiModelProperty("timestamp")
  15.     private Long timestamp;
  16.  
  17.     @ApiModelProperty("step")
  18.     private Integer step;
  19. }

控制层

  1. @Resource
  2. private BizStepService bizStepService;
  3.  
  4. @PostMapping("/synchronize")
  5. public ResponseEntity<BizStep> uploadStep(@RequestBody @Valid StepDTO stepDTO) {
  6.             return ResultUtil.success("同步步数功",this.bizStepService.uploadStep(stepDTO));
  7. }

service

业务层

  1. @Resource
  2. @Lazy
  3. private AccountClient accountClient;
  4. @Resource
  5. private BizStepMapper bizStepMapper;
  6.  
  7. @Transactional(rollbackFor = Exception.class)
  8. public BizStep uploadStep(StepDTO stepDTO) {
  9.     Assert.isTrue(LocalTime.now().isBefore(LocalTime.parse("22:00:00")), "每日同步步数截止时间为22:00");
  10.     //获取微信用户数据 此处的目的为获取用户的sessionKey
  11.     WxUser wxUser = accountClient.getById(stepDTO.getAppUserId());
  12.     stepDTO.setSessionKey(wxUser.getSessionKey());
  13.     //获取用户步数
  14.     String step = this.decryptWeChatStep(stepDTO);
  15.     BizStep bizStep = new BizStep();
  16.     //step入库
  17.     if (StrUtil.isNotBlank(step)) {
  18.         LocalDateTime localDateTime = LocalDateTime.now();
  19.         String today = DateTimeFormatter.ofPattern("yyyy-MM-dd").format(localDateTime);
  20.         bizStep = 
  21.         this.getOne(Wrappers.lambdaQuery(BizStep.class).eq(BizStep::getAppUserId, 
  22.         stepDTO.getAppUserId())
  23.             .apply("to_char(created_date,'yyyy-MM-dd') = {0}", today));
  24.             if (null != bizStep) {
  25.                 //如果今天舒徐不为空则更新
  26.                 bizStep.setStep(Integer.valueOf(step));
  27.                 this.updateById(bizStep);
  28.                 //入果用户头像更改，需要更新历史数据的头像 保持一致性
  29.                 if (!wxUser.getAvatar().equals(bizStep.getAvatar())) {
  30.                     this.update(Wrappers.lambdaUpdate(BizStep.class).eq(BizStep::getAppUserId, stepDTO.getAppUserId())
  31.                             .set(BizStep::getAvatar, wxUser.getAvatar()));
  32.                 }
  33.                 //保持昵称的一致性 如果昵称改变保持历史数据的一致
  34.                 if (!wxUser.getNickName().equals(bizStep.getName())) {
  35.                     this.update(Wrappers.lambdaUpdate(BizStep.class).eq(BizStep::getAppUserId, stepDTO.getAppUserId())
  36.                             .set(BizStep::getName, wxUser.getNickName()));
  37.                 }
  38.             } else {
  39.                 BizStep newBizStep = new BizStep();
  40.                 //如果今天数据为空则新增
  41.                 newBizStep.setAppUserId(stepDTO.getAppUserId());
  42.                 newBizStep.setWechatName(wxUser.getNickName());
  43.                 newBizStep.setName(wxUser.getNickName());
  44.                 newBizStep.setAvatar(wxUser.getAvatar());
  45.                 newBizStep.setSessionKey(wxUser.getSessionKey());
  46.                 newBizStep.setStep(Integer.valueOf(step));
  47.                 newBizStep.setMobile(wxUser.getMobile());
  48.                 this.save(newBizStep);
  49.                 return newBizStep;
  50.             }
  51.         }
  52.         return bizStep;
  53.     }
  54.  
  55. /**
  56.      * 微信步数同步
  57.      *
  58.      * @param stepDTO
  59.      * @return
  60.      */
  61.     public String decryptWeChatStep(StepDTO stepDTO) {
  62.         String step = "0";
  63.         byte[] encrypData = Base64.decodeBase64(stepDTO.getEncryptedData());
  64.         byte[] ivData = Base64.decodeBase64(stepDTO.getIv());
  65.         byte[] sessionKeyB = Base64.decodeBase64(stepDTO.getSessionKey());
  66.  
  67.         try {
  68.             AlgorithmParameterSpec ivSpec = new IvParameterSpec(ivData);
  69.             Cipher cipher = Cipher.getInstance(TRANSFORMATION);
  70.             SecretKeySpec keySpec = new SecretKeySpec(sessionKeyB, AES);
  71.             cipher.init(Cipher.DECRYPT_MODE, keySpec, ivSpec);
  72.             byte[] doFinal = cipher.doFinal(encrypData);
  73.             String result = new String(doFinal);
  74.             WxRunDataBO wxRunDataBO = JSON.parseObject(result, WxRunDataBO.class);
  75.             List<StepInfoListBO> stepInfoList = wxRunDataBO.getStepInfoList();
  76.             Assert.isTrue(stepInfoList.size() > 0, "微信没有您今日的步数");
  77.             StepInfoListBO stepInfoListBO = stepInfoList.get(stepInfoList.size() - 1);
  78.             log.info("stepInfoListBO={}", stepInfoListBO);
  79.             Long timestamp = stepInfoListBO.getTimestamp();
  80.             step = String.valueOf(stepInfoListBO.getStep());
  81.             log.info("step={}", step);
  82.         } catch (Exception e) {
  83.             log.error("解析步数报错", e);
  84.             throw new IllegalArgumentException("微信步数解析异常");
  85.         }
  86.         return step;
  87.     }

获取我当日的步数

入参实体（结果实体同上BizStep）

  1. @Data
  2. public class MineStepDTO {
  3.  
  4.     @ApiModelProperty(value = "小程序用户id",required=true)
  5.     @NotBlank(message = "小程序用户id不能为空")
  6.     private  String  appUserId;
  7. }

controller层

  1. @PostMapping("/getStep")
  2. @ApiOperation(value = "获取我当天的步数" , notes = "")
  3. @PreAuthorize("hasRole('MINI_APP')")
  4. public ResponseEntity<BizStep> getMineStep(@RequestBody @Valid MineStepDTO mineStepDTO) {
  5.     return ResultUtil.success(this.bizStepService.getMineStep(mineStepDTO));
  6. }

 service

对我方步数表的查询

  1. public BizStep getMineStep(MineStepDTO mineStepDTO) {
  2.     LocalDateTime localDateTime = LocalDateTime.now();
  3.     String today = DateTimeFormatter.ofPattern("yyyy-MM-dd").format(localDateTime);
  4.     BizStep bizStep = this.getOne(Wrappers.lambdaQuery(BizStep.class).eq(BizStep::getAppUserId, mineStepDTO.getAppUserId())
  5.                 .apply("to_char(created_date,'yyyy-MM-dd') = {0}", today));
  6.      if (null == bizStep) {
  7.          //如果今日无数据 返回0步
  8.          BizStep newBizStep = new BizStep();
  9.          //如果今天数据为空则新增
  10.          newBizStep.setAppUserId(mineStepDTO.getAppUserId());
  11.          newBizStep.setStep(0);
  12.          return newBizStep;
  13.  
  14.         }
  15.      return bizStep;
  16. }

日排行，周排行，月排行榜的实现

请求实体

  1. @Data
  2. public class RankDTO implements Serializable {
  3.  
  4.     @ApiModelProperty(value = "排序方式 月month 周week 日day", required = true)
  5.     @NotBlank(message = "请选择排序方式")
  6.     private String type;
  7.  
  8.     @ApiModelProperty(value = "小程序用户id", required = true)
  9.     @NotBlank(message = "小程序用户id不能为空")
  10.     private String appUserId;
  11.  
  12.     //当前页，默认第一页
  13.     @ApiModelProperty(value = "当前页")
  14.     private Integer currPage = 1;
  15.  
  16.     //每页记录数，默认为10
  17.     @ApiModelProperty(value = "显示条数")
  18.     private Integer size = 100000;
  19.  
  20. }

 controller

  1. @PostMapping("/rank")
  2. public ResponseEntity<List<StepRankVO>> getRank(@RequestBody @Valid RankDTO rankDTO) {
  3.     return ResultUtil.success(this.bizStepService.getRank(rankDTO));
  4. }

service

  1.  public StepRankVO getRank(RankDTO rankDTO) {
  2.         StepRankVO stepRankVO = new StepRankVO();
  3.         //时间条件
  4.         String startDate = "";
  5.         String endDate = "";
  6.         SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  7.         Calendar calendar = Calendar.getInstance();
  8.         calendar.setTimeInMillis(System.currentTimeMillis());
  9.  
  10.         if (MONTH.equals(rankDTO.getType())) {
  11.             calendar.add(Calendar.MONTH, 0);
  12.             calendar.set(Calendar.DAY_OF_MONTH, 1);
  13.             startDate = dateFormat.format(calendar.getTime()) + " 00:00:00";
  14.             calendar.add(Calendar.MONTH, 1);
  15.             calendar.set(Calendar.DAY_OF_MONTH, 0);
  16.             endDate = dateFormat.format(calendar.getTime()) + " 23:59:59";
  17.         }
  18.         if (WEEK.equals(rankDTO.getType())) {
  19.             calendar.setFirstDayOfWeek(Calendar.MONDAY);
  20.             calendar.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY);
  21.             startDate = dateFormat.format(calendar.getTime()) + " 00:00:00";
  22.             calendar.set(Calendar.DAY_OF_WEEK, Calendar.SUNDAY);
  23.             endDate = dateFormat.format(calendar.getTime()) + " 23:59:59";
  24.         }
  25.         if (DAY.equals(rankDTO.getType())) {
  26.             calendar.add(Calendar.DATE, 0);
  27.             String today = dateFormat.format(calendar.getTime());
  28.             startDate = today + " 00:00:00";
  29.             endDate = today + " 23:59:59";
  30.         }
  31.         Page<RankResultVO> ranks = this.bizStepMapper.getRank(new Page<>(rankDTO.getCurrPage(), rankDTO.getSize()), startDate, endDate);
  32.         if (CollectionUtil.isNotEmpty(ranks.getRecords())) {
  33.             stepRankVO.setRankList(ranks.getRecords());
  34.             RankResultVO myRankVO = new RankResultVO();
  35.             List<RankResultVO> myRank = ranks.getRecords().stream().filter(e -> rankDTO.getAppUserId().equals(e.getAppUserId())).collect(Collectors.toList());
  36.             if (CollectionUtil.isNotEmpty(myRank)) {
  37.                 BeanUtils.copyProperties(myRank.get(0), myRankVO);
  38.             }
  39.             stepRankVO.setMine(myRankVO);
  40.  
  41.         }
  42.  
  43.         return stepRankVO;
  44.     }

mapper

  1. @Mapper
  2. public interface BizStepMapper extends BaseMapper<BizStep> {
  3.  
  4.     Page<RankResultVO> getRank(Page<RankResultVO> page, @Param("startDate") String startDate, @Param("endDate") String endDate);
  5.  
  6. }

xml

  1.  <select id="getRank" resultType="com.vo.mp.RankResultVO">
  2.         SELECT
  3.         rank ( ) over ( ORDER BY t.step DESC ) AS rank,
  4.         t.step,
  5.         t.app_user_id,
  6.         t.NAME,
  7.         t.avatar
  8.         FROM
  9.         (
  10.         SELECT
  11.         sum( a.step ) AS step,
  12.         a.app_user_id,
  13.         a.NAME,
  14.         a.avatar
  15.         FROM
  16.         ssyy_biz_step a
  17.         where
  18.         to_char(created_date,'yyyy-MM-dd HH24:MI:ss') <![CDATA[>=]]>  #{startDate}
  19.         and
  20.         to_char(created_date,'yyyy-MM-dd HH24:MI:ss')<![CDATA[<=]]> #{endDate}
  21.         GROUP BY
  22.         a.app_user_id,
  23.         a.NAME,
  24.         a.avatar
  25.         ) t
  26.     </select>

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/308167
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号