Java 后台实现微信小程序不同人员生成不同小程序码并追踪扫码来源

CREATE TABLE `promoter` (  `id` bigint NOT NULL AUTO_INCREMENT,  `name` varchar(50) NOT NULL COMMENT '推广人员姓名',  `mobile` varchar(20) COMMENT '联系电话',  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,  PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `user_promoter_relation` (  `id` bigint NOT NULL AUTO_INCREMENT,  `user_id` varchar(64) NOT NULL COMMENT '小程序用户openid',  `promoter_id` bigint NOT NULL COMMENT '推广人员ID',  `first_scan_time` datetime NOT NULL COMMENT '首次扫码时间',  `last_scan_time` datetime NOT NULL COMMENT '最近扫码时间',  `scan_count` int NOT NULL DEFAULT '1' COMMENT '扫码次数',  PRIMARY KEY (`id`),  UNIQUE KEY `idx_user_promoter` (`user_id`,`promoter_id`),  KEY `idx_promoter` (`promoter_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

<dependency>    <groupId>com.github.binarywang</groupId>    <artifactId>weixin-java-miniapp</artifactId>    <version>4.1.0</version></dependency>

@Configurationpublic class WxMaConfiguration {        @Value("${wx.miniapp.appid}")    private String appid;        @Value("${wx.miniapp.secret}")    private String secret;        @Bean    public WxMaService wxMaService() {        WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();        config.setAppid(appid);        config.setSecret(secret);                WxMaService service = new WxMaServiceImpl();        service.setWxMaConfig(config);        return service;    }}

@RestController@RequestMapping("/api/qrcode")public class QrCodeController {        @Autowired    private WxMaService wxMaService;        @Autowired    private PromoterService promoterService;        /**     * 生成推广二维码     * @param promoterId 推广人员ID     * @return 二维码图片字节流     */    @GetMapping("/generate")    public void generatePromoterQrCode(@RequestParam Long promoterId,                                      HttpServletResponse response) throws IOException {        // 验证推广人员是否存在        Promoter promoter = promoterService.getById(promoterId);        if (promoter == null) {            throw new RuntimeException("推广人员不存在");        }                // 生成小程序码        String scene = "promoterId=" + promoterId;        WxMaQrcodeService qrcodeService = wxMaService.getQrcodeService();        File qrCodeFile = qrcodeService.createWxaCodeUnlimit(scene, "pages/index/index", 430, true, null, false);                // 返回图片流        response.setContentType("image/jpeg");        try (InputStream in = new FileInputStream(qrCodeFile);             OutputStream out = response.getOutputStream()) {            byte[] buffer = new byte[1024];            int len;            while ((len = in.read(buffer)) != -1) {                out.write(buffer, 0, len);            }        }    }}

@RestController@RequestMapping("/api/track")public class TrackController {        @Autowired    private UserPromoterRelationService relationService;        /**     * 记录用户扫码行为     * @param dto 包含用户信息和推广信息     * @return 操作结果     */    @PostMapping("/scan")    public Result trackScan(@RequestBody ScanTrackDTO dto) {        // 解析scene参数        String scene = dto.getScene();        Map<String, String> sceneParams = parseScene(scene);        String promoterIdStr = sceneParams.get("promoterId");                if (StringUtils.isBlank(promoterIdStr)) {            return Result.fail("缺少推广人员参数");        }                try {            Long promoterId = Long.parseLong(promoterIdStr);            relationService.recordUserScan(dto.getOpenid(), promoterId);            return Result.success();        } catch (NumberFormatException e) {            return Result.fail("推广人员参数格式错误");        }    }        private Map<String, String> parseScene(String scene) {        Map<String, String> params = new HashMap<>();        if (StringUtils.isBlank(scene)) {            return params;        }                String[] pairs = scene.split("&");        for (String pair : pairs) {            String[] kv = pair.split("=");            if (kv.length == 2) {                params.put(kv[0], kv[1]);            }        }        return params;    }}

@Servicepublic class UserPromoterRelationServiceImpl implements UserPromoterRelationService {        @Autowired    private UserPromoterRelationMapper relationMapper;        @Override    @Transactional    public void recordUserScan(String openid, Long promoterId) {        // 查询是否已有记录        UserPromoterRelation relation = relationMapper.selectByUserAndPromoter(openid, promoterId);                Date now = new Date();        if (relation == null) {            // 新建关系记录            relation = new UserPromoterRelation();            relation.setUserId(openid);            relation.setPromoterId(promoterId);            relation.setFirstScanTime(now);            relation.setLastScanTime(now);            relation.setScanCount(1);            relationMapper.insert(relation);        } else {            // 更新已有记录            relation.setLastScanTime(now);            relation.setScanCount(relation.getScanCount() + 1);            relationMapper.updateById(relation);        }    }}

App({  onLaunch: function(options) {    // 处理扫码进入的情况    if (options.scene === 1047 || options.scene === 1048 || options.scene === 1049) {      // 这些scene值表示是通过扫码进入      const scene = decodeURIComponent(options.query.scene);            // 上报扫码信息到后端      wx.request({        url: 'https://yourdomain.com/api/track/scan',        method: 'POST',        data: {          scene: scene,          openid: this.globalData.openid // 需要先获取用户openid        },        success: function(res) {          console.log('扫码记录成功', res);        }      });    }  }})

@RestController@RequestMapping("/api/stat")public class StatController {        @Autowired    private UserPromoterRelationMapper relationMapper;        /**     * 获取推广人员业绩统计     * @param promoterId 推广人员ID     * @param startDate 开始日期     * @param endDate 结束日期     * @return 统计结果     */    @GetMapping("/promoter")    public Result getPromoterStats(@RequestParam Long promoterId,                                 @RequestParam(required = false) @DateTimeFormat(pattern="yyyy-MM-dd") Date startDate,                                 @RequestParam(required = false) @DateTimeFormat(pattern="yyyy-MM-dd") Date endDate) {                // 构建查询条件        QueryWrapper<UserPromoterRelation> query = new QueryWrapper<>();        query.eq("promoter_id", promoterId);                if (startDate != null) {            query.ge("first_scan_time", startDate);        }        if (endDate != null) {            query.le("first_scan_time", endDate);        }                // 执行查询        int totalUsers = relationMapper.selectCount(query);        List<Map<String, Object>> dailyStats = relationMapper.selectDailyStatsByPromoter(promoterId, startDate, endDate);                // 返回结果        Map<String, Object> result = new HashMap<>();        result.put("totalUsers", totalUsers);        result.put("dailyStats", dailyStats);                return Result.success(result);    }}