我的资料增加是否送卡人字段

fujun / dxCard-service

Browse code 我的资料增加是否送卡人字段 master
1 parent 00b4c95 commit 6744b330a94296cb5467025954a2a61b0a625c2b YFJ authored 16 days ago

Patch

Showing 3 changed files

Ignore Space Show notes View jeecg-boot-module/jeecg-module-service/src/main/java/org/jeecg/modules/service/controller/AuthUserController.java
package org.jeecg.modules.service.controller; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.query.QueryRuleEnum; import org.jeecg.common.util.oConvertUtils; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import lombok.extern.slf4j.Slf4j; import org.jeecg.modules.service.dto.AuthUserUpdateDTO; import org.jeecg.modules.service.dto.CardApplicationDTO; import org.jeecg.modules.service.entity.AuthUser; import org.jeecg.modules.service.service.IAuthUserService; import org.jeecg.modules.service.vo.; import org.jeecg.modules.system.entity.CardApplicationCustomers; import org.jeecg.modules.system.entity.CardDeliveryPerson; import org.jeecg.modules.system.mapper.CardDeliveryPersonMapper; import org.jeecg.modules.system.service.ICardApplicationCustomersService; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.def.NormalExcelConstants; import org.jeecgframework.poi.excel.entity.ExportParams; import org.jeecgframework.poi.excel.entity.ImportParams; import org.jeecgframework.poi.excel.view.JeecgEntityExcelView; import org.jeecg.common.system.base.controller.JeecgController; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.servlet.ModelAndView; import com.alibaba.fastjson.JSON; import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.Operation; import org.jeecg.common.aspect.annotation.AutoLog; import org.apache.shiro.authz.annotation.RequiresPermissions; /** * @Description: 微信用户档案 * @Author: jeecg-boot * @Date: 2025-09-28 * @Version: V1.0 / @Tag(name="微信用户档案") @RestController @RequestMapping("/service/authUser") @Slf4j public class AuthUserController extends JeecgController<AuthUser, IAuthUserService> { @Autowired private IAuthUserService authUserService; @Autowired private ICardApplicationCustomersService cardApplicationCustomersService; @Autowired private CardDeliveryPersonMapper cardDeliveryPersonMapper; /* 我的-推荐用户列表 / @RequestMapping(value = "/recommendUser", method = RequestMethod.GET) public Result<RecommendUserVO> recommendUser(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } RecommendUserVO vo = authUserService.recommendUser(userId); return Result.OK(vo); } /** 我的-参团信息 / @RequestMapping(value = "/myGroupMemberList", method = RequestMethod.GET) public Result<List<MyGroupMemberVO>> myGroupMemberList(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } List<MyGroupMemberVO> list = authUserService.myGroupMemberList(userId); return Result.OK(list); } /** * 我的资料 / @RequestMapping(value = "/detail", method = RequestMethod.GET) public Result<AuthUserVO> detail(@RequestParam (name = "id",required=false) String id) { AuthUserVO vo = new AuthUserVO(); AuthUser authUser = authUserService.getById(id); if (authUser == null){ return Result.error("用户不存在"); } BeanUtils.copyProperties(authUser,vo); vo.setIsCardMan(false); if (authUser.getWxPhone() != null){ QueryWrapper<CardDeliveryPerson> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("phone", authUser.getWxPhone()); CardDeliveryPerson cardDeliveryPerson = cardDeliveryPersonMapper.selectOne(queryWrapper); if (cardDeliveryPerson != null){ vo.setIsCardMan(true); } } return Result.OK(vo); } @RequestMapping(value = "/update", method = RequestMethod.POST) public Result<?> update(@RequestBody AuthUserUpdateDTO authUserUpdateDTO) { AuthUser authUser = authUserService.getById(authUserUpdateDTO.getId()); authUser.setAvatar(authUserUpdateDTO.getAvatar()); authUser.setWxName(authUserUpdateDTO.getName()); authUser.setProvince(authUserUpdateDTO.getProvince()); authUser.setCity(authUserUpdateDTO.getCity()); authUser.setArea(authUserUpdateDTO.getArea()); authUser.setAddress(authUserUpdateDTO.getAddress()); authUserService.updateById(authUser); return Result.OK("修改成功"); } /* * 开卡任务 / @RequestMapping(value = "/dispatchUser", method = RequestMethod.GET) public Result<List<DispatchUserVO>> dispatchUser(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } List<DispatchUserVO> list = authUserService.dispatchUser(userId); return Result.OK(list); } /* * 开卡任务详情 / @RequestMapping(value = "/dispatchUserDetail", method = RequestMethod.GET) public Result<DispatchDetailVO> dispatchUserDetail(@RequestParam (name = "id") String id) { if (StringUtils.isBlank(id)){ return Result.error("预约单id不能为空"); } DispatchDetailVO vo = authUserService.dispatchUserDetail(id); return Result.OK(vo); } /* * 办卡 / @RequestMapping(value = "/cardApplication", method = RequestMethod.POST) public Result<?> cardApplication(@RequestBody CardApplicationDTO cardApplicationDTO) { CardApplicationCustomers cardApplicationCustomers = cardApplicationCustomersService.getById(cardApplicationDTO.getId()); if (cardApplicationCustomers == null){ return Result.error("预约单不存在"); } if (cardApplicationCustomers.getStatus().equals("2")){ return Result.error("该预约单已处理"); } cardApplicationCustomers.setStatus("2"); cardApplicationCustomers.setTransactionPhone(cardApplicationDTO.getTransactionPhone()); cardApplicationCustomers.setAmount(cardApplicationDTO.getAmount()); cardApplicationCustomersService.updateById(cardApplicationCustomers); return Result.OK("提交办卡成功"); } } package org.jeecg.modules.service.controller; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.query.QueryRuleEnum; import org.jeecg.common.util.oConvertUtils; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import lombok.extern.slf4j.Slf4j; import org.jeecg.modules.service.dto.AuthUserUpdateDTO; import org.jeecg.modules.service.dto.CardApplicationDTO; import org.jeecg.modules.service.entity.AuthUser; import org.jeecg.modules.service.service.IAuthUserService; import org.jeecg.modules.service.vo.DispatchDetailVO; import org.jeecg.modules.service.vo.DispatchUserVO; import org.jeecg.modules.service.vo.MyGroupMemberVO; import org.jeecg.modules.service.vo.RecommendUserVO; import org.jeecg.modules.system.entity.CardApplicationCustomers; import org.jeecg.modules.system.service.ICardApplicationCustomersService; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.def.NormalExcelConstants; import org.jeecgframework.poi.excel.entity.ExportParams; import org.jeecgframework.poi.excel.entity.ImportParams; import org.jeecgframework.poi.excel.view.JeecgEntityExcelView; import org.jeecg.common.system.base.controller.JeecgController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.servlet.ModelAndView; import com.alibaba.fastjson.JSON; import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.Operation; import org.jeecg.common.aspect.annotation.AutoLog; import org.apache.shiro.authz.annotation.RequiresPermissions; /** * @Description: 微信用户档案 * @Author: jeecg-boot * @Date: 2025-09-28 * @Version: V1.0 / @Tag(name="微信用户档案") @RestController @RequestMapping("/service/authUser") @Slf4j public class AuthUserController extends JeecgController<AuthUser, IAuthUserService> { @Autowired private IAuthUserService authUserService; @Autowired private ICardApplicationCustomersService cardApplicationCustomersService; /* 我的-推荐用户列表 / @RequestMapping(value = "/recommendUser", method = RequestMethod.GET) public Result<RecommendUserVO> recommendUser(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } RecommendUserVO vo = authUserService.recommendUser(userId); return Result.OK(vo); } /** 我的-参团信息 / @RequestMapping(value = "/myGroupMemberList", method = RequestMethod.GET) public Result<List<MyGroupMemberVO>> myGroupMemberList(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } List<MyGroupMemberVO> list = authUserService.myGroupMemberList(userId); return Result.OK(list); } /** * 我的资料 / @RequestMapping(value = "/detail", method = RequestMethod.GET) public Result<AuthUser> detail(@RequestParam (name = "id",required=false) String id) { AuthUser authUser = authUserService.getById(id); return Result.OK(authUser); } @RequestMapping(value = "/update", method = RequestMethod.POST) public Result<?> update(@RequestBody AuthUserUpdateDTO authUserUpdateDTO) { AuthUser authUser = authUserService.getById(authUserUpdateDTO.getId()); authUser.setAvatar(authUserUpdateDTO.getAvatar()); authUser.setWxName(authUserUpdateDTO.getName()); authUser.setProvince(authUserUpdateDTO.getProvince()); authUser.setCity(authUserUpdateDTO.getCity()); authUser.setArea(authUserUpdateDTO.getArea()); authUser.setAddress(authUserUpdateDTO.getAddress()); authUserService.updateById(authUser); return Result.OK("修改成功"); } /* * 开卡任务 / @RequestMapping(value = "/dispatchUser", method = RequestMethod.GET) public Result<List<DispatchUserVO>> dispatchUser(@RequestParam (name = "userId") String userId) { if (StringUtils.isBlank(userId)){ return Result.error("用户id不能为空"); } List<DispatchUserVO> list = authUserService.dispatchUser(userId); return Result.OK(list); } /* * 开卡任务详情 / @RequestMapping(value = "/dispatchUserDetail", method = RequestMethod.GET) public Result<DispatchDetailVO> dispatchUserDetail(@RequestParam (name = "id") String id) { if (StringUtils.isBlank(id)){ return Result.error("预约单id不能为空"); } DispatchDetailVO vo = authUserService.dispatchUserDetail(id); return Result.OK(vo); } /* * 办卡 */ @RequestMapping(value = "/cardApplication", method = RequestMethod.POST) public Result<?> cardApplication(@RequestBody CardApplicationDTO cardApplicationDTO) { CardApplicationCustomers cardApplicationCustomers = cardApplicationCustomersService.getById(cardApplicationDTO.getId()); if (cardApplicationCustomers == null){ return Result.error("预约单不存在"); } if (cardApplicationCustomers.getStatus().equals("2")){ return Result.error("该预约单已处理"); } cardApplicationCustomers.setStatus("2"); cardApplicationCustomers.setTransactionPhone(cardApplicationDTO.getTransactionPhone()); cardApplicationCustomers.setAmount(cardApplicationDTO.getAmount()); cardApplicationCustomersService.updateById(cardApplicationCustomers); return Result.OK("提交办卡成功"); } }

Ignore Space Show notes View

jeecg-boot-module/jeecg-module-service/src/main/java/org/jeecg/modules/service/controller/AuthUserController.java

package org.jeecg.modules.service.controller;

import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.system.query.QueryGenerator;
import org.jeecg.common.system.query.QueryRuleEnum;
import org.jeecg.common.util.oConvertUtils;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;

import org.jeecg.modules.service.dto.AuthUserUpdateDTO;
import org.jeecg.modules.service.dto.CardApplicationDTO;
import org.jeecg.modules.service.entity.AuthUser;
import org.jeecg.modules.service.service.IAuthUserService;
import org.jeecg.modules.service.vo.*;
import org.jeecg.modules.system.entity.CardApplicationCustomers;
import org.jeecg.modules.system.entity.CardDeliveryPerson;
import org.jeecg.modules.system.mapper.CardDeliveryPersonMapper;
import org.jeecg.modules.system.service.ICardApplicationCustomersService;
import org.jeecgframework.poi.excel.ExcelImportUtil;
import org.jeecgframework.poi.excel.def.NormalExcelConstants;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
import org.jeecg.common.system.base.controller.JeecgController;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.servlet.ModelAndView;
import com.alibaba.fastjson.JSON;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Operation;
import org.jeecg.common.aspect.annotation.AutoLog;
import org.apache.shiro.authz.annotation.RequiresPermissions;
/**
 * @Description: 微信用户档案
 * @Author: jeecg-boot
 * @Date:   2025-09-28
 * @Version: V1.0
 */
@Tag(name="微信用户档案")
@RestController
@RequestMapping("/service/authUser")
@Slf4j
public class AuthUserController extends JeecgController<AuthUser, IAuthUserService> {
    @Autowired
    private IAuthUserService authUserService;

@Autowired
    private ICardApplicationCustomersService cardApplicationCustomersService;

@Autowired
    private CardDeliveryPersonMapper cardDeliveryPersonMapper;

/**
     *我的-推荐用户列表
     */
    @RequestMapping(value = "/recommendUser", method = RequestMethod.GET)
    public Result<RecommendUserVO> recommendUser(@RequestParam (name = "userId") String userId) {
        if (StringUtils.isBlank(userId)){
            return Result.error("用户id不能为空");
        }
        RecommendUserVO vo = authUserService.recommendUser(userId);
        return Result.OK(vo);
    }

/**
     *我的-参团信息
     */
    @RequestMapping(value = "/myGroupMemberList", method = RequestMethod.GET)
    public Result<List<MyGroupMemberVO>> myGroupMemberList(@RequestParam (name = "userId") String userId) {
        if (StringUtils.isBlank(userId)){
            return Result.error("用户id不能为空");
        }
        List<MyGroupMemberVO> list = authUserService.myGroupMemberList(userId);
        return Result.OK(list);
    }

/**
     * 我的资料
     */
    @RequestMapping(value = "/detail", method = RequestMethod.GET)
    public Result<AuthUserVO> detail(@RequestParam (name = "id",required=false) String id) {
        AuthUserVO vo = new AuthUserVO();
        AuthUser authUser = authUserService.getById(id);
        if (authUser == null){
            return Result.error("用户不存在");
        }
        BeanUtils.copyProperties(authUser,vo);
        vo.setIsCardMan(false);
        if (authUser.getWxPhone() != null){
            QueryWrapper<CardDeliveryPerson> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("phone", authUser.getWxPhone());
            CardDeliveryPerson cardDeliveryPerson = cardDeliveryPersonMapper.selectOne(queryWrapper);
            if (cardDeliveryPerson != null){
                vo.setIsCardMan(true);
            }
        }
        return Result.OK(vo);
    }

@RequestMapping(value = "/update", method = RequestMethod.POST)
    public Result<?> update(@RequestBody AuthUserUpdateDTO authUserUpdateDTO) {
        AuthUser authUser = authUserService.getById(authUserUpdateDTO.getId());
        authUser.setAvatar(authUserUpdateDTO.getAvatar());
        authUser.setWxName(authUserUpdateDTO.getName());
        authUser.setProvince(authUserUpdateDTO.getProvince());
        authUser.setCity(authUserUpdateDTO.getCity());
        authUser.setArea(authUserUpdateDTO.getArea());
        authUser.setAddress(authUserUpdateDTO.getAddress());
        authUserService.updateById(authUser);
        return Result.OK("修改成功");
    }

/**
     * 开卡任务
     */
    @RequestMapping(value = "/dispatchUser", method = RequestMethod.GET)
    public Result<List<DispatchUserVO>> dispatchUser(@RequestParam (name = "userId") String userId) {
        if (StringUtils.isBlank(userId)){
            return Result.error("用户id不能为空");
        }
        List<DispatchUserVO> list = authUserService.dispatchUser(userId);
        return Result.OK(list);
    }

/**
     * 开卡任务详情
     */
    @RequestMapping(value = "/dispatchUserDetail", method = RequestMethod.GET)
    public Result<DispatchDetailVO> dispatchUserDetail(@RequestParam (name = "id") String id) {
        if (StringUtils.isBlank(id)){
            return Result.error("预约单id不能为空");
        }
        DispatchDetailVO vo = authUserService.dispatchUserDetail(id);
        return Result.OK(vo);
    }

/**
     * 办卡
     */
    @RequestMapping(value = "/cardApplication", method = RequestMethod.POST)
    public Result<?> cardApplication(@RequestBody CardApplicationDTO cardApplicationDTO) {
        CardApplicationCustomers cardApplicationCustomers = cardApplicationCustomersService.getById(cardApplicationDTO.getId());
        if (cardApplicationCustomers == null){
            return Result.error("预约单不存在");
        }
        if (cardApplicationCustomers.getStatus().equals("2")){
            return Result.error("该预约单已处理");
        }
        cardApplicationCustomers.setStatus("2");
        cardApplicationCustomers.setTransactionPhone(cardApplicationDTO.getTransactionPhone());
        cardApplicationCustomers.setAmount(cardApplicationDTO.getAmount());
        cardApplicationCustomersService.updateById(cardApplicationCustomers);
        return Result.OK("提交办卡成功");
    }
}

package org.jeecg.modules.service.controller;

import org.jeecg.modules.service.dto.AuthUserUpdateDTO;
import org.jeecg.modules.service.dto.CardApplicationDTO;
import org.jeecg.modules.service.entity.AuthUser;
import org.jeecg.modules.service.service.IAuthUserService;
import org.jeecg.modules.service.vo.DispatchDetailVO;
import org.jeecg.modules.service.vo.DispatchUserVO;
import org.jeecg.modules.service.vo.MyGroupMemberVO;
import org.jeecg.modules.service.vo.RecommendUserVO;
import org.jeecg.modules.system.entity.CardApplicationCustomers;
import org.jeecg.modules.system.service.ICardApplicationCustomersService;
import org.jeecgframework.poi.excel.ExcelImportUtil;
import org.jeecgframework.poi.excel.def.NormalExcelConstants;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
import org.jeecg.common.system.base.controller.JeecgController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.servlet.ModelAndView;
import com.alibaba.fastjson.JSON;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Operation;
import org.jeecg.common.aspect.annotation.AutoLog;
import org.apache.shiro.authz.annotation.RequiresPermissions;
/**
 * @Description: 微信用户档案
 * @Author: jeecg-boot
 * @Date:   2025-09-28
 * @Version: V1.0
 */
@Tag(name="微信用户档案")
@RestController
@RequestMapping("/service/authUser")
@Slf4j
public class AuthUserController extends JeecgController<AuthUser, IAuthUserService> {
    @Autowired
    private IAuthUserService authUserService;

@Autowired
    private ICardApplicationCustomersService cardApplicationCustomersService;

/**
     * 我的资料
     */
    @RequestMapping(value = "/detail", method = RequestMethod.GET)
    public Result<AuthUser> detail(@RequestParam (name = "id",required=false) String id) {
        AuthUser authUser = authUserService.getById(id);
        return Result.OK(authUser);
    }

Ignore Space Show notes View jeecg-boot-module/jeecg-module-service/src/main/java/org/jeecg/modules/service/controller/WxController.java
package org.jeecg.modules.service.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.system.vo.SysUserCacheInfo; import org.jeecg.common.util.RedisUtil; import org.jeecg.common.util.RestUtil; import org.jeecg.modules.service.dto.UserLoginDTO; import org.jeecg.modules.service.entity.AuthUser; import org.jeecg.modules.service.mapper.AuthUserMapper; import org.jeecg.modules.service.vo.UserLoginVO; import org.jeecg.modules.system.entity.CardDeliveryPerson; import org.jeecg.modules.system.entity.SysUser; import org.jeecg.modules.system.mapper.CardDeliveryPersonMapper; import org.jeecg.modules.system.mapper.SysUserMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.HashMap; import java.util.Map; /** * @program: jeecg-boot * @description: * @author: Mr.Yang * @create: 2025-09-25 15:32 / @RestController @RequestMapping("/wx/thirdLogin") @Slf4j public class WxController{ @Resource private AuthUserMapper authUserMapper; @Resource private CardDeliveryPersonMapper cardDeliveryPersonMapper; @Resource private RedisUtil redisUtil; private final String WX_APP_ID = "wx7f0c544b5fa55113"; private final String WX_APP_SECRET = "f5edf152445004bb7d28455f4aedd663"; / * 请求示例：wxCode：ynce， * mCode：076bc6152ffaedb4e03a318b6ca6d9851136487b907f0266154d40b7a1adcf18， * jsCode：0e1nhLFa1vC8WH0OqvHa1Ze0dW3nhLFQ * @param dto * @return / @PostMapping("/loginWxApplet") public Result<UserLoginVO> login(@RequestBody UserLoginDTO dto) { log.info("微信用户登录"); if (StringUtils.isEmpty(dto.getmCode())){ return Result.error("mCode不能为空"); } if (StringUtils.isEmpty(dto.getJsCode())){ return Result.error("jsCode不能为空"); } //微信登录 AuthUser authUser = wxLogin(dto); if (authUser == null){ return Result.error("登录失败"); } UserLoginVO userLoginVO = new UserLoginVO(); userLoginVO.setOpenid(authUser.getOpenId()); QueryWrapper<CardDeliveryPerson> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("phone", authUser.getWxPhone()); CardDeliveryPerson cardDeliveryPerson = cardDeliveryPersonMapper.selectOne(queryWrapper); if (cardDeliveryPerson == null){ userLoginVO.setIsCardMan(false); authUser.setIsCardMan(false); }else { userLoginVO.setIsCardMan(true); authUser.setIsCardMan(true); } userLoginVO.setAuthUser(JSONObject.parseObject(JSON.toJSONString(authUser))); return Result.OK(userLoginVO); } public AuthUser wxLogin(UserLoginDTO dto) { //调用微信接口服务，获取openId String openId = getOpenId(dto.getJsCode()); AuthUser authUser = authUserMapper.getUserByOpenId(openId); if (authUser == null){ String phone = getWxPhone(dto.getmCode()); if (StringUtils.isBlank(phone)) { throw new JeecgBootException("没有获取到电话"); } //处理新用户 authUser = new AuthUser(); authUser.setOpenId(openId); authUser.setWxPhone(phone); authUserMapper.insert(authUser); authUser = authUserMapper.getUserByOpenId(openId); } return authUser; } private String getOpenId(String code) { // 请求地址 String url = "https://api.weixin.qq.com/sns/jscode2session"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.TEXT_PLAIN); System.out.println("请求地址：" + url); JSONObject params = new JSONObject(); params.put("grant_type", "authorization_code"); params.put("appid", WX_APP_ID); params.put("secret", WX_APP_SECRET); params.put("js_code", code); // 利用 RestUtil 请求该url ResponseEntity<String> result = RestUtil.request(url, HttpMethod.GET, headers, params, null, String.class); if (result != null && result.getBody() != null) { System.out.println("返回结果：" + result.getBody()); } else { System.out.println("查询失败"); } return (String) JSON.parseObject(result.getBody()).get("openid"); } private String getWxPhone(String mCode) { // 请求地址 String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); System.out.println("请求地址：" + url); JSONObject postParams = new JSONObject(); postParams.put("code", mCode); JSONObject getParams = new JSONObject(); getParams.put("access_token", getWxAccessToken()); // 利用 RestUtil 请求该url ResponseEntity<String> result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class); if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) { System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString()); } else { //accessToken失效，删除token，重新请求 redisUtil.del("sys:wx:access_token"); getParams.put("access_token", getWxAccessToken()); result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class); if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) { System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString()); } else { throw new JeecgBootException("请求失败：" + JSON.toJSONString(result)); } } return JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber").toString(); } private String getWxAccessToken() { // 请求地址 String url = "https://api.weixin.qq.com/cgi-bin/token"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); // 请求方式是 POST 代表提交新增数据 HttpMethod method = HttpMethod.GET; System.out.println("请求地址：" + url); System.out.println("请求方式：" + method); JSONObject params = new JSONObject(); params.put("grant_type", "client_credential"); params.put("appid", WX_APP_ID); params.put("secret", WX_APP_SECRET); // 利用 RestUtil 请求该url ResponseEntity<JSONObject> result = RestUtil.request(url, method, headers, params, null, JSONObject.class); if (result != null && result.getBody() != null) { System.out.println("返回结果：" + result.getBody().toJSONString()); } else { System.out.println("查询失败"); } String accessToken = result.getBody().get("access_token").toString(); if (StringUtils.isNotBlank(accessToken)) { redisUtil.set("sys:wx:access_token", accessToken, 3600L); return accessToken; } else { throw new JeecgBootException("查询失败"); } } } package org.jeecg.modules.service.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.system.vo.SysUserCacheInfo; import org.jeecg.common.util.RedisUtil; import org.jeecg.common.util.RestUtil; import org.jeecg.modules.service.dto.UserLoginDTO; import org.jeecg.modules.service.entity.AuthUser; import org.jeecg.modules.service.mapper.AuthUserMapper; import org.jeecg.modules.service.vo.UserLoginVO; import org.jeecg.modules.system.entity.CardDeliveryPerson; import org.jeecg.modules.system.entity.SysUser; import org.jeecg.modules.system.mapper.CardDeliveryPersonMapper; import org.jeecg.modules.system.mapper.SysUserMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.HashMap; import java.util.Map; /* * @program: jeecg-boot * @description: * @author: Mr.Yang * @create: 2025-09-25 15:32 / @RestController @RequestMapping("/wx/thirdLogin") @Slf4j public class WxController{ @Resource private AuthUserMapper authUserMapper; @Resource private SysUserMapper sysUserMapper; @Resource private CardDeliveryPersonMapper cardDeliveryPersonMapper; @Resource private RedisUtil redisUtil; private final String WX_APP_ID = "wx7f0c544b5fa55113"; private final String WX_APP_SECRET = "f5edf152445004bb7d28455f4aedd663"; / * 请求示例：wxCode：ynce， * mCode：076bc6152ffaedb4e03a318b6ca6d9851136487b907f0266154d40b7a1adcf18， * jsCode：0e1nhLFa1vC8WH0OqvHa1Ze0dW3nhLFQ * @param dto * @return */ @PostMapping("/loginWxApplet") public Result<UserLoginVO> login(@RequestBody UserLoginDTO dto) { log.info("微信用户登录"); if (StringUtils.isEmpty(dto.getmCode())){ return Result.error("mCode不能为空"); } if (StringUtils.isEmpty(dto.getJsCode())){ return Result.error("jsCode不能为空"); } //微信登录 AuthUser authUser = wxLogin(dto); if (authUser == null){ return Result.error("登录失败"); } UserLoginVO userLoginVO = new UserLoginVO(); userLoginVO.setOpenid(authUser.getOpenId()); QueryWrapper<CardDeliveryPerson> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("phone", authUser.getWxPhone()); CardDeliveryPerson cardDeliveryPerson = cardDeliveryPersonMapper.selectOne(queryWrapper); if (cardDeliveryPerson == null){ userLoginVO.setIsCardMan(false); authUser.setIsCardMan(false); }else { userLoginVO.setIsCardMan(true); authUser.setIsCardMan(true); } userLoginVO.setAuthUser(JSONObject.parseObject(JSON.toJSONString(authUser))); return Result.OK(userLoginVO); } public AuthUser wxLogin(UserLoginDTO dto) { //调用微信接口服务，获取openId String openId = getOpenId(dto.getJsCode()); AuthUser authUser = authUserMapper.getUserByOpenId(openId); if (authUser == null){ String phone = getWxPhone(dto.getmCode()); if (StringUtils.isBlank(phone)) { throw new JeecgBootException("没有获取到电话"); } //处理新用户 authUser = new AuthUser(); authUser.setOpenId(openId); authUser.setWxPhone(phone); authUserMapper.insert(authUser); authUser = authUserMapper.getUserByOpenId(openId); } return authUser; } private String getOpenId(String code) { // 请求地址 String url = "https://api.weixin.qq.com/sns/jscode2session"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.TEXT_PLAIN); System.out.println("请求地址：" + url); JSONObject params = new JSONObject(); params.put("grant_type", "authorization_code"); params.put("appid", WX_APP_ID); params.put("secret", WX_APP_SECRET); params.put("js_code", code); // 利用 RestUtil 请求该url ResponseEntity<String> result = RestUtil.request(url, HttpMethod.GET, headers, params, null, String.class); if (result != null && result.getBody() != null) { System.out.println("返回结果：" + result.getBody()); } else { System.out.println("查询失败"); } return (String) JSON.parseObject(result.getBody()).get("openid"); } private String getWxPhone(String mCode) { // 请求地址 String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); System.out.println("请求地址：" + url); JSONObject postParams = new JSONObject(); postParams.put("code", mCode); JSONObject getParams = new JSONObject(); getParams.put("access_token", getWxAccessToken()); // 利用 RestUtil 请求该url ResponseEntity<String> result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class); if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) { System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString()); } else { //accessToken失效，删除token，重新请求 redisUtil.del("sys:wx:access_token"); getParams.put("access_token", getWxAccessToken()); result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class); if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) { System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString()); } else { throw new JeecgBootException("请求失败：" + JSON.toJSONString(result)); } } return JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber").toString(); } private String getWxAccessToken() { // 请求地址 String url = "https://api.weixin.qq.com/cgi-bin/token"; // 请求 Header （用于传递Token） HttpHeaders headers = new HttpHeaders(); // 请求方式是 POST 代表提交新增数据 HttpMethod method = HttpMethod.GET; System.out.println("请求地址：" + url); System.out.println("请求方式：" + method); JSONObject params = new JSONObject(); params.put("grant_type", "client_credential"); params.put("appid", WX_APP_ID); params.put("secret", WX_APP_SECRET); // 利用 RestUtil 请求该url ResponseEntity<JSONObject> result = RestUtil.request(url, method, headers, params, null, JSONObject.class); if (result != null && result.getBody() != null) { System.out.println("返回结果：" + result.getBody().toJSONString()); } else { System.out.println("查询失败"); } String accessToken = result.getBody().get("access_token").toString(); if (StringUtils.isNotBlank(accessToken)) { redisUtil.set("sys:wx:access_token", accessToken, 3600L); return accessToken; } else { throw new JeecgBootException("查询失败"); } } }

Ignore Space Show notes View

jeecg-boot-module/jeecg-module-service/src/main/java/org/jeecg/modules/service/controller/WxController.java

package org.jeecg.modules.service.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.exception.JeecgBootException;
import org.jeecg.common.system.vo.SysUserCacheInfo;
import org.jeecg.common.util.RedisUtil;
import org.jeecg.common.util.RestUtil;
import org.jeecg.modules.service.dto.UserLoginDTO;
import org.jeecg.modules.service.entity.AuthUser;
import org.jeecg.modules.service.mapper.AuthUserMapper;
import org.jeecg.modules.service.vo.UserLoginVO;
import org.jeecg.modules.system.entity.CardDeliveryPerson;
import org.jeecg.modules.system.entity.SysUser;
import org.jeecg.modules.system.mapper.CardDeliveryPersonMapper;
import org.jeecg.modules.system.mapper.SysUserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.Map;

/**
 * @program: jeecg-boot
 * @description:
 * @author: Mr.Yang
 * @create: 2025-09-25 15:32
 **/
@RestController
@RequestMapping("/wx/thirdLogin")
@Slf4j
public class WxController{

@Resource
    private AuthUserMapper authUserMapper;

@Resource
    private CardDeliveryPersonMapper cardDeliveryPersonMapper;

@Resource
    private RedisUtil redisUtil;

private final String WX_APP_ID = "wx7f0c544b5fa55113";

private final String WX_APP_SECRET = "f5edf152445004bb7d28455f4aedd663";

/**
     * 请求示例：wxCode：ynce，
     * mCode：076bc6152ffaedb4e03a318b6ca6d9851136487b907f0266154d40b7a1adcf18，
     * jsCode：0e1nhLFa1vC8WH0OqvHa1Ze0dW3nhLFQ
     * @param dto
     * @return
     */
    @PostMapping("/loginWxApplet")
    public Result<UserLoginVO> login(@RequestBody UserLoginDTO dto) {
        log.info("微信用户登录");
        if (StringUtils.isEmpty(dto.getmCode())){
            return Result.error("mCode不能为空");
        }
        if (StringUtils.isEmpty(dto.getJsCode())){
            return Result.error("jsCode不能为空");
        }
        //微信登录
        AuthUser authUser = wxLogin(dto);
        if (authUser == null){
            return Result.error("登录失败");
        }
        UserLoginVO userLoginVO = new UserLoginVO();
        userLoginVO.setOpenid(authUser.getOpenId());

QueryWrapper<CardDeliveryPerson> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("phone", authUser.getWxPhone());
        CardDeliveryPerson cardDeliveryPerson = cardDeliveryPersonMapper.selectOne(queryWrapper);
        if (cardDeliveryPerson == null){
            userLoginVO.setIsCardMan(false);
            authUser.setIsCardMan(false);
        }else {
            userLoginVO.setIsCardMan(true);
            authUser.setIsCardMan(true);
        }
        userLoginVO.setAuthUser(JSONObject.parseObject(JSON.toJSONString(authUser)));

return Result.OK(userLoginVO);
    }

public AuthUser wxLogin(UserLoginDTO dto) {
        //调用微信接口服务，获取openId
        String openId = getOpenId(dto.getJsCode());
        AuthUser authUser = authUserMapper.getUserByOpenId(openId);
        if (authUser == null){
            String phone = getWxPhone(dto.getmCode());

if (StringUtils.isBlank(phone)) {
                throw new JeecgBootException("没有获取到电话");
            }
            //处理新用户
            authUser = new AuthUser();
            authUser.setOpenId(openId);
            authUser.setWxPhone(phone);
            authUserMapper.insert(authUser);

authUser = authUserMapper.getUserByOpenId(openId);
        }
        return authUser;
    }

private String getOpenId(String code) {
        // 请求地址
        String url = "https://api.weixin.qq.com/sns/jscode2session";
        // 请求 Header （用于传递Token）
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.TEXT_PLAIN);

System.out.println("请求地址：" + url);
        JSONObject params = new JSONObject();
        params.put("grant_type", "authorization_code");
        params.put("appid", WX_APP_ID);
        params.put("secret", WX_APP_SECRET);
        params.put("js_code", code);

// 利用 RestUtil 请求该url
        ResponseEntity<String> result = RestUtil.request(url, HttpMethod.GET, headers, params, null, String.class);

if (result != null && result.getBody() != null) {
            System.out.println("返回结果：" + result.getBody());
        } else {
            System.out.println("查询失败");
        }
        return (String) JSON.parseObject(result.getBody()).get("openid");
    }

private String getWxPhone(String mCode) {
        // 请求地址
        String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber";

// 请求 Header （用于传递Token）
        HttpHeaders headers = new HttpHeaders();

System.out.println("请求地址：" + url);

JSONObject postParams = new JSONObject();
        postParams.put("code", mCode);
        JSONObject getParams = new JSONObject();
        getParams.put("access_token", getWxAccessToken());

// 利用 RestUtil 请求该url
        ResponseEntity<String> result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class);
        if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) {
            System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString());
        } else {
            //accessToken失效，删除token，重新请求
            redisUtil.del("sys:wx:access_token");
            getParams.put("access_token", getWxAccessToken());
            result = RestUtil.request(url, HttpMethod.POST, headers, getParams, postParams, String.class);
            if (result != null && result.getBody() != null && JSON.parseObject(result.getBody()).get("phone_info") != null && JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber") != null) {
                System.out.println("返回结果：" + JSON.parseObject(result.getBody()).toJSONString());
            } else {
                throw new JeecgBootException("请求失败：" + JSON.toJSONString(result));
            }
        }

return JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber").toString();
    }

private String getWxAccessToken() {

// 请求地址
        String url = "https://api.weixin.qq.com/cgi-bin/token";
        // 请求 Header （用于传递Token）
        HttpHeaders headers = new HttpHeaders();
        // 请求方式是 POST 代表提交新增数据
        HttpMethod method = HttpMethod.GET;

System.out.println("请求地址：" + url);
        System.out.println("请求方式：" + method);

JSONObject params = new JSONObject();
        params.put("grant_type", "client_credential");
        params.put("appid", WX_APP_ID);
        params.put("secret", WX_APP_SECRET);

// 利用 RestUtil 请求该url
        ResponseEntity<JSONObject> result = RestUtil.request(url, method, headers, params, null, JSONObject.class);
        if (result != null && result.getBody() != null) {
            System.out.println("返回结果：" + result.getBody().toJSONString());
        } else {
            System.out.println("查询失败");
        }
        String accessToken = result.getBody().get("access_token").toString();
        if (StringUtils.isNotBlank(accessToken)) {
            redisUtil.set("sys:wx:access_token", accessToken, 3600L);
            return accessToken;
        } else {
            throw new JeecgBootException("查询失败");
        }
    }
}

package org.jeecg.modules.service.controller;

import java.util.HashMap;
import java.util.Map;

/**
 * @program: jeecg-boot
 * @description:
 * @author: Mr.Yang
 * @create: 2025-09-25 15:32
 **/
@RestController
@RequestMapping("/wx/thirdLogin")
@Slf4j
public class WxController{

@Resource
    private AuthUserMapper authUserMapper;

@Resource
    private SysUserMapper sysUserMapper;

@Resource
    private CardDeliveryPersonMapper cardDeliveryPersonMapper;

@Resource
    private RedisUtil redisUtil;

private final String WX_APP_ID = "wx7f0c544b5fa55113";

private final String WX_APP_SECRET = "f5edf152445004bb7d28455f4aedd663";

return Result.OK(userLoginVO);
    }

authUser = authUserMapper.getUserByOpenId(openId);
        }
        return authUser;
    }

// 利用 RestUtil 请求该url
        ResponseEntity<String> result = RestUtil.request(url, HttpMethod.GET, headers, params, null, String.class);

private String getWxPhone(String mCode) {
        // 请求地址
        String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber";

// 请求 Header （用于传递Token）
        HttpHeaders headers = new HttpHeaders();

System.out.println("请求地址：" + url);

JSONObject postParams = new JSONObject();
        postParams.put("code", mCode);
        JSONObject getParams = new JSONObject();
        getParams.put("access_token", getWxAccessToken());

return JSON.parseObject(result.getBody()).getJSONObject("phone_info").get("phoneNumber").toString();
    }

private String getWxAccessToken() {

System.out.println("请求地址：" + url);
        System.out.println("请求方式：" + method);

JSONObject params = new JSONObject();
        params.put("grant_type", "client_credential");
        params.put("appid", WX_APP_ID);
        params.put("secret", WX_APP_SECRET);

Ignore Space Show notes View jeecg-boot-module/jeecg-module-service/src/main/java/org/jeecg/modules/service/vo/AuthUserVO.java 0 → 100644
package org.jeecg.modules.service.vo; import lombok.Data; import org.jeecg.modules.service.entity.AuthUser; import java.io.Serializable; /** * @program: jeecg-boot * @description: * @author: Mr.Yang * @create: 2025-10-11 15:40 / @Data public class AuthUserVO extends AuthUser implements Serializable{ / * 是否送卡人 */ private Boolean isCardMan; }

Show line notes below