package com.ruoyi.worker.controller; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.ruoyi.admin.api.entity.Agreement; import com.ruoyi.admin.api.feignClient.AdminClient; import com.ruoyi.common.core.constant.Constants; import com.ruoyi.common.core.constant.RedisConstants; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.redis.service.RedisService; import com.ruoyi.common.security.auth.AuthUtil; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.common.security.utils.SecurityUtils; import com.ruoyi.order.api.entity.WorkerOrderCountVO; import com.ruoyi.order.api.feignClient.OrderClient; import com.ruoyi.system.api.model.LoginUserInfo; import com.ruoyi.worker.entity.AppVersion; import com.ruoyi.worker.entity.MasterWorker; import com.ruoyi.worker.entity.WorkerProcess; import com.ruoyi.worker.mapper.AppMapper; import com.ruoyi.worker.request.LoginPasswordRequest; import com.ruoyi.worker.request.LoginPhoneRequest; import com.ruoyi.worker.service.MasterWorkerService; import com.ruoyi.worker.service.WorkerProcessService; import com.ruoyi.worker.vo.HomePageInfoVO; import com.ruoyi.worker.vo.OrderListVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.regex.Pattern; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; /** *

* 师傅信息表 前端控制器 *

* * @author hjl * @since 2024-06-03 */ @RestController @RequestMapping("/worker") @Api(value = "师傅端", tags = "师傅端") public class MasterWorkerController { @Resource private MasterWorkerService masterWorkerService; @Resource private TokenService tokenService; @Resource private RedisService redisService; @Resource private WorkerProcessService workerProcessService; @Resource private AdminClient adminClient; @Resource private OrderClient orderClient; @Resource private AppMapper appMapper; @PostMapping("/version/check") @ApiOperation(value = "获取最新的版本信息", tags = {"自动更新"}) public R check() { AppVersion appVersion = appMapper.selectOne(new QueryWrapper().orderByDesc("createTime").eq("is_delete", 0).last("limit 1")); // Object version = redisService.getCacheObject("version"); return R.ok(appVersion); } /** * 师傅端-密码登录 * * @param loginPasswordRequest 手机号及密码信息 */ @ApiOperation(value = "密码登录", tags = {"师傅端-登录"}) @PostMapping(value = "/passwordLogin") public R passwordLogin(@RequestBody @Validated LoginPasswordRequest loginPasswordRequest) { String phone = loginPasswordRequest.getPhone(); String password = loginPasswordRequest.getPassword(); MasterWorker worker = masterWorkerService.lambdaQuery().eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null != worker) { if (!Constants.ONE.equals(worker.getIsEnable())) { return R.notEnabled("登录失败,当前账号未启用!"); } } else { // 校验师傅是否已提交入驻申请 WorkerProcess process = workerProcessService.lambdaQuery() .eq(WorkerProcess::getPhone, phone) .eq(WorkerProcess::getIsDelete, 0) .orderByDesc(WorkerProcess::getCreateTime) .last("limit 1").one(); if (null != process) { if (Constants.ZERO.equals(process.getState())) { return R.fail("入驻申请暂未审核通过,请耐心等待!"); } else if (Constants.TWO.equals(process.getState())) { return R.fail("当前手机号未注册!"); } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } // MD5加密登录密码(新) BCryptPasswordEncoder passwordEncoder = new BCryptPasswordEncoder(); // 校验用户输入密码与加密后的密码是否匹配 boolean matches = passwordEncoder.matches(password, worker.getPassword()); if (!matches) { return R.passwordError("登录密码错误!"); } return R.ok(generateLoginToken(worker)); } /** * 师傅端-密码登录 * * @param loginPasswordRequest 手机号及密码信息 */ @ApiOperation(value = "2.0新增登录师傅切换", tags = {"2.0新增登录师傅切换"}) @PostMapping(value = "/loginApp") public R loginApp(@RequestBody LoginPasswordRequest loginPasswordRequest) { String phone = loginPasswordRequest.getPhone(); MasterWorker worker = masterWorkerService.lambdaQuery().eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null != worker) { if (!Constants.ONE.equals(worker.getIsEnable())) { return R.notEnabled("登录失败,当前账号未启用!"); } } else { // 校验师傅是否已提交入驻申请 WorkerProcess process = workerProcessService.lambdaQuery() .eq(WorkerProcess::getPhone, phone) .eq(WorkerProcess::getIsDelete, 0) .orderByDesc(WorkerProcess::getCreateTime) .last("limit 1").one(); if (null != process) { if (Constants.ZERO.equals(process.getState())) { return R.fail("入驻申请暂未审核通过,请耐心等待!"); } else if (Constants.TWO.equals(process.getState())) { return R.fail("当前手机号未注册!"); } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } return R.ok(generateLoginToken(worker)); } /** * 生成登录信息及token加密 * * @param worker 登录信息 * @return token */ private Map generateLoginToken(MasterWorker worker) { // 通知其他师傅下线 // Integer workerId = worker.getId(); // Set redisCache = redisService.getKeysPrefix(CacheConstants.LOGIN_WORKER_TOKEN_KEY); // for (Object key : redisCache) { // String strKey = String.valueOf(key); // // 根据 login_tokens:加密token 获取用户登录信息 // Object redisCacheUserInfo = redisService.getCacheObject(strKey); // LoginUserInfo redisUserInfo = JSONObject.parseObject(JSONObject.toJSONString(redisCacheUserInfo), LoginUserInfo.class); // // 单点逻辑,如果当前用户已处于登录状态并再次登录,则清除该用户上一次登录token // if (workerId.equals(redisUserInfo.getUserid())) { // ChannelHandlerContext context = NettyChannelMap.getData(String.valueOf(workerId)); // if (null != context) { // NettyWebSocketController.sendMsgToClient(context, "当前登录账号在其他设备登录!"); // } // } // } // 校验通过,生成token及过期时间 LoginUserInfo loginUserInfo = new LoginUserInfo(); loginUserInfo.setName(worker.getRealName()); loginUserInfo.setUserid(worker.getId()); loginUserInfo.setPhone(worker.getPhone()); loginUserInfo.setLoginTime(System.currentTimeMillis()); Map map = new HashMap<>(8); map.put("token", tokenService.createTokenByWorker(loginUserInfo)); map.put("userId", worker.getId()); return map; } /** * 师傅端-手机验证码登录 * * @param loginPhoneRequest 手机号及密码信息 */ @ApiOperation(value = "手机验证码登录", tags = {"师傅端-登录"}) @PostMapping(value = "/phoneCodeLogin") public R phoneCodeLogin(@RequestBody @Validated LoginPhoneRequest loginPhoneRequest) { String phone = loginPhoneRequest.getPhone(); String phoneCode = loginPhoneRequest.getPhoneCode(); // 默认验证码 123456 if (!Constants.DEFAULT_PHONE_CODE.equals(phoneCode)) { // 手机验证码校验获取缓存验证码 Object phoneCodeRedis = redisService.getCacheObject(RedisConstants.WORKER_APPLY_KEY + phone); if (null == phoneCodeRedis) { return R.errorCode("验证码错误!"); } else { // redis 验证码的value 为 code:时间戳 String rCodeAndTime = String.valueOf(phoneCodeRedis); String rCode = rCodeAndTime.split(":")[0]; if (!rCode.equalsIgnoreCase(phoneCode)) { return R.errorCode("验证码错误!"); } } } MasterWorker worker = masterWorkerService.lambdaQuery().eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null != worker) { if (!Constants.ONE.equals(worker.getIsEnable())) { return R.notEnabled("登录失败,当前账号未启用!"); } } else { // 校验师傅是否已提交入驻申请 WorkerProcess process = workerProcessService.lambdaQuery() .eq(WorkerProcess::getPhone, phone) .eq(WorkerProcess::getIsDelete, 0) .orderByDesc(WorkerProcess::getCreateTime) .last("limit 1").one(); if (null != process) { if (Constants.ZERO.equals(process.getState())) { return R.fail("入驻申请暂未审核通过,请耐心等待!"); } else if (Constants.TWO.equals(process.getState())) { return R.fail("当前手机号未注册!"); } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } else { return R.registered("当前账号未提交入驻申请,无法登录!"); } } // 校验通过,生成token及过期时间 return R.ok(generateLoginToken(worker)); } /** * 师傅端-提交入驻申请 * * @param workerProcess 入驻申请相关信息 */ @ApiOperation(value = "入驻申请", tags = {"师傅端-登录"}) @PostMapping(value = "/settledApply") public R settledApply(@RequestBody @Validated WorkerProcess workerProcess) { String phone = workerProcess.getPhone(); String phoneCode = workerProcess.getCode(); Object redisCodeObj = redisService.getCacheObject(RedisConstants.WORKER_SETTLE_KEY + phone); if (null == redisCodeObj) { return R.errorCode("验证码错误!"); } String redisCodeStr = String.valueOf(redisCodeObj).split(":")[0]; if (!String.valueOf(redisCodeStr).equalsIgnoreCase(phoneCode)) { return R.errorCode("验证码错误!"); } // 校验手机号是否已注册 MasterWorker masterWorker = masterWorkerService.lambdaQuery().eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null != masterWorker) { return R.registered("当前手机号已注册!"); } // 校验手机号是否已提交申请 WorkerProcess dbProcess = workerProcessService.lambdaQuery() .eq(WorkerProcess::getPhone, phone) .eq(WorkerProcess::getIsDelete, 0) .orderByDesc(WorkerProcess::getCreateTime).last("limit 1").one(); if (null != dbProcess) { if (Constants.ZERO.equals(dbProcess.getState())) { return R.fail("入驻申请已提交,审核未通过,请耐心等待!"); } } // 默认状态待审核 workerProcess.setState(Constants.ZERO); // 获取用户性别 String idNumber = workerProcess.getIdNumber(); // 判断身份证号码长度是否合法 if (idNumber.length() == Constants.EIGHTEEN) { // 获取身份证号码倒数第二位的数字 int genderNum = Integer.parseInt(idNumber.substring(16, 17)); // 判断性别 if (genderNum % Constants.TWO == 0) { workerProcess.setSex("女"); } else { workerProcess.setSex("男"); } } else { return R.idNumberIllegal("身份证号码不合法!"); } return workerProcessService.save(workerProcess) ? R.ok("申请成功!") : R.fail("申请失败!"); } /** * 师傅端-验证手机号 * 找回密码和修改密码都需要验证手机号 * * @param phone 验证的手机号 */ @ApiOperation(value = "找回密码/修改密码验证手机号", tags = {"师傅端-登录"}) @GetMapping(value = "/verifyPhone") @ApiImplicitParams({ @ApiImplicitParam(value = "验证手机号", name = "phone", dataType = "String", required = true), @ApiImplicitParam(value = "手机验证码", name = "phoneCode", dataType = "String", required = true) }) public R verifyPhone(@RequestParam String phone, @RequestParam String phoneCode) { // 验证码是否一致 Object redisCode = redisService.getCacheObject(RedisConstants.WORKER_APPLY_KEY + phone); if (null == redisCode) { return R.errorCode("验证码错误!"); } String redisCodeStr = String.valueOf(redisCode).split(":")[0]; if (!String.valueOf(redisCodeStr).equalsIgnoreCase(phoneCode)) { return R.errorCode("验证码错误!"); } // 手机号是否注册 MasterWorker worker = masterWorkerService.lambdaQuery() .eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null == worker) { return R.registered("该手机号未提交入驻申请!"); } return R.ok("验证成功!"); } /** * 师傅端-修改登录密码 * 找回密码和修改密码验证手机号通过后,执行修改登录密码并删除登录信息 * * @param password 新密码 */ @ApiOperation(value = "修改登录密码", tags = {"师傅端-登录"}) @GetMapping(value = "/updatePassword") @ApiImplicitParams({ @ApiImplicitParam(value = "手机号", name = "phone", dataType = "String", required = true), @ApiImplicitParam(value = "登录密码", name = "password", dataType = "String", required = true) }) public R updatePassword(@RequestParam String phone, @RequestParam String password, HttpServletRequest request) { // 密码长度至少为8位,且不能全是英文字母或数字 String regex = "^(?![0-9]+$)(?![a-zA-Z]+$)[0-9A-Za-z]{8,}$"; if (!Pattern.matches(regex, password)) { return R.passwordIllegality("密码至少8个字符,不能全是字母或数字"); } // 手机号是否已被后台软删除 MasterWorker worker = masterWorkerService.lambdaQuery().eq(MasterWorker::getPhone, phone) .eq(MasterWorker::getIsDelete, 0).one(); if (null == worker) { return R.registered("该手机号未提交入驻申请!"); } BCryptPasswordEncoder passwordEncoder = new BCryptPasswordEncoder(); String md5Password = passwordEncoder.encode(password); worker.setPassword(md5Password); // 修改成功后,删除token masterWorkerService.updateById(worker); String token = SecurityUtils.getToken(request); if (null != token) { // 删除用户缓存记录 AuthUtil.logoutByTokenWorker(token); } return R.ok(); } /** * 师傅端-首页个人信息及订单待上门信息 */ @ApiOperation(value = "首页个人信息", tags = {"师傅端-首页"}) @GetMapping(value = "/homePage") public R homePage() { LoginUserInfo loginUser = tokenService.getLoginUserByWorker(); if (null == loginUser) { return R.loginExpire("登录已失效!"); } // 师傅信息 MasterWorker masterWorker = masterWorkerService.lambdaQuery().eq(MasterWorker::getId, loginUser.getUserid()) .eq(MasterWorker::getIsDelete, 0).one(); if (null == masterWorker) { return R.registered("当前账号未注册!"); } // 订单统计 WorkerOrderCountVO orderCount = orderClient.orderStateCount(masterWorker.getId()).getData(); // 操作指导详情 Agreement agreement = adminClient.operate().getData(); if (null == agreement) { return R.fail(adminClient.operate().getMsg()); } return R.ok(new HomePageInfoVO(masterWorker, orderCount, agreement.getContent())); } /** * 师傅端-订单代办列表 */ @ApiOperation(value = "订单代办列表", tags = {"师傅端-首页"}) @GetMapping(value = "/orderNotHandle") @ApiImplicitParams({ @ApiImplicitParam(value = "师傅所在经度", name = "longitude", dataType = "String", required = true), @ApiImplicitParam(value = "师傅所在纬度", name = "latitude", dataType = "String", required = true) }) public R> orderNotHandle(@RequestParam String longitude, @RequestParam String latitude) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } return R.ok(masterWorkerService.orderNotHandle(loginWorker.getUserid(), longitude, latitude)); } @ApiOperation(value = "下拉框", tags = {"后台-下拉框"}) @GetMapping(value = "/workSelect") public R> workSelect() { List list = masterWorkerService.lambdaQuery().eq(MasterWorker::getIsEnable, 1).eq(MasterWorker::getIsDelete, 0).list(); return R.ok(list); } /** * 师傅端-订单列表-地图模式 */ @ApiOperation(value = "订单列表-地图模式", tags = {"师傅端-首页"}) @GetMapping(value = "/orderMapMode") @ApiImplicitParams({ @ApiImplicitParam(value = "师傅所在经度", name = "longitude", dataType = "String", required = true), @ApiImplicitParam(value = "师傅所在纬度", name = "latitude", dataType = "String", required = true) }) public R> orderMapMode(@RequestParam String longitude, @RequestParam String latitude) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } return R.ok(masterWorkerService.orderMapMode(loginWorker.getUserid(), longitude, latitude)); } /** * 师傅端-操作指南 */ @ApiOperation(value = "操作指南", tags = {"师傅端-首页"}) @GetMapping(value = "/guide") public R guide() { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } // 操作指导详情 Agreement agreement = adminClient.operate().getData(); if (null == agreement) { return R.fail(adminClient.operate().getMsg()); } return R.ok(agreement); } /** * 师傅端-订单代办列表 */ @ApiOperation(value = "订单置顶", tags = {"师傅端-首页"}) @GetMapping(value = "/orderTop") public R orderTop(@RequestParam String orderId) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } return orderClient.orderTop(orderId, loginWorker.getUserid()); } /** * 师傅端-登录用户详情 */ @ApiOperation(value = "登录用户详情", tags = {"师傅端-个人中心"}) @GetMapping(value = "/workerInfo") public R workerInfo() { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } return R.ok(masterWorkerService.getById(loginWorker.getUserid())); } /** * 师傅端-登录用户详情 */ @ApiOperation(value = "退出登录", tags = {"师傅端-个人中心"}) @GetMapping(value = "/logout") public R logout(HttpServletRequest request) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } String token = SecurityUtils.getToken(request); if (null != token) { // 删除用户缓存记录 AuthUtil.logoutByTokenWorker(token); } return R.ok("退出登录成功!"); } /** * 师傅端-修改头像 */ @ApiOperation(value = "修改头像", tags = {"师傅端-个人中心"}) @GetMapping(value = "/updateProfilePicture") @ApiImplicitParams({ @ApiImplicitParam(value = "头像地址", name = "profilePicture", dataType = "String", required = true) }) public R updateProfilePicture(@RequestParam String profilePicture) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } boolean update = masterWorkerService.lambdaUpdate().set(MasterWorker::getProfilePicture, profilePicture) .eq(MasterWorker::getId, loginWorker.getUserid()) .eq(MasterWorker::getIsDelete, 0).update(); return update ? R.ok("修改成功!") : R.fail("修改失败!"); } /** * 师傅端-修改姓名 */ @ApiOperation(value = "修改姓名", tags = {"师傅端-个人中心"}) @GetMapping(value = "/updateName") @ApiImplicitParams({ @ApiImplicitParam(value = "姓名", name = "name", dataType = "String", required = true) }) public R updateName(@RequestParam String name) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } boolean update = masterWorkerService.lambdaUpdate().set(MasterWorker::getRealName, name).eq(MasterWorker::getId, loginWorker.getUserid()) .eq(MasterWorker::getIsDelete, 0).update(); return update ? R.ok("修改成功!") : R.fail("修改失败!"); } /** * 师傅端-修改性别 */ @ApiOperation(value = "修改性别", tags = {"师傅端-个人中心"}) @GetMapping(value = "/updateSex") @ApiImplicitParams({ @ApiImplicitParam(value = "性别", name = "sex", dataType = "String", required = true) }) public R updateSex(@RequestParam String sex) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } boolean update = masterWorkerService.lambdaUpdate().set(MasterWorker::getSex, sex).eq(MasterWorker::getId, loginWorker.getUserid()) .eq(MasterWorker::getIsDelete, 0).update(); return update ? R.ok("修改成功!") : R.fail("修改失败!"); } /** * 师傅端-修改生日 */ @ApiOperation(value = "修改生日", tags = {"师傅端-个人中心"}) @GetMapping(value = "/updateBirthday") @ApiImplicitParams({ @ApiImplicitParam(value = "生日", name = "birthday", dataType = "Date", required = true) }) public R updateBirthday(@RequestParam String birthday) { LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } boolean update = masterWorkerService.lambdaUpdate().set(MasterWorker::getBirthday, birthday) .eq(MasterWorker::getId, loginWorker.getUserid()) .eq(MasterWorker::getIsDelete, 0).update(); return update ? R.ok("修改成功!") : R.fail("修改失败!"); } /** * 师傅端-修改手机号 */ @ApiOperation(value = "修改手机号", tags = {"师傅端-个人中心"}) @GetMapping(value = "/updatePhone") @ApiImplicitParams({ @ApiImplicitParam(value = "手机号", name = "phone", dataType = "String", required = true), @ApiImplicitParam(value = "手机验证码", name = "code", dataType = "String", required = true) }) public R updatePhone(@RequestParam String phone, @RequestParam String code, HttpServletRequest request) { if (!Constants.DEFAULT_PHONE_CODE.equals(code)) { // 验证码是否一致 Object redisCode = redisService.getCacheObject(RedisConstants.WORKER_APPLY_KEY + phone); if (null == redisCode) { return R.errorCode("验证码错误!"); } String redisCodeStr = String.valueOf(redisCode).split(":")[0]; if (!String.valueOf(redisCodeStr).equalsIgnoreCase(code)) { return R.errorCode("验证码错误!"); } } LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); if (null == loginWorker) { return R.loginExpire("登录已失效!"); } boolean update = masterWorkerService.lambdaUpdate().set(MasterWorker::getPhone, phone).eq(MasterWorker::getId, loginWorker.getUserid()) .eq(MasterWorker::getIsDelete, 0).update(); String token = SecurityUtils.getToken(request); if (null != token) { // 删除用户缓存记录 AuthUtil.logoutByTokenWorker(token); } return update ? R.ok("修改成功!") : R.fail("修改失败!"); } /** * 师傅端-修改性别 */ // @ApiOperation(value = "修改师傅实时位置", tags = {"师傅端-个人中心[2.0]"}) // @GetMapping(value = "/updateLonLat") // @ApiImplicitParams({ // @ApiImplicitParam(value = "经度", name = "workerLon", dataType = "String", required = true), // @ApiImplicitParam(value = "纬度", name = "workerLat", dataType = "String", required = true), // }) // public R updateLonLat(@RequestParam("workerLon") String workerLon, @RequestParam("workerLat") String workerLat) { // LoginUserInfo loginWorker = tokenService.getLoginUserByWorker(); // if (null == loginWorker) { // return R.loginExpire("登录已失效!"); // } // boolean update = masterWorkerService.lambdaUpdate() // .set(MasterWorker::getWorkerLon, workerLon) // .set(MasterWorker::getWorkerLat, workerLat) // .eq(MasterWorker::getId, loginWorker.getUserid()) // .eq(MasterWorker::getIsDelete, 0).update(); // return update ? R.ok("修改成功!") : R.fail("修改失败!"); // } /** * 师傅端-打电话 */ @ApiOperation(value = "打电话", tags = {"师傅端-打电话[2.0]"}) @GetMapping(value = "/workerCall") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", dataType = "String", required = true), }) public R workerCall(@RequestParam String orderId) { orderClient.call(orderId); return R.ok(); } }