package com.dji.sample.droneairport.service.impl; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; //import com.alibaba.fastjson.JSON; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.dji.sample.common.model.ResponseResult; import com.dji.sample.component.redis.RedisOpsUtils; import com.dji.sample.droneairport.dao.DeviceExpanSionMapper; import com.dji.sample.droneairport.model.Entity.DeviceExpanSionEntity; import com.dji.sample.droneairport.model.dto.*; import com.dji.sample.droneairport.model.param.ReturnTaskParam; import com.dji.sample.droneairport.service.RegistService; import com.dji.sample.droneairport.utils.AuthUtil; import com.dji.sample.droneairport.utils.SM2.Utils; import com.dji.sample.droneairport.utils.SM4Util; import com.dji.sample.manage.dao.IDeviceMapper; import com.dji.sample.manage.model.entity.DeviceEntity; import com.dji.sample.manage.model.receiver.OsdSubDeviceReceiver; import com.dji.sample.manage.service.IDeviceRedisService; import com.dji.sample.patches.dao.GetPatchesMapper; import com.dji.sample.patches.dao.TaskInfoMapper; import com.dji.sample.patches.model.entity.LotInfo; import com.dji.sample.patches.model.entity.TaskInfo; import com.dji.sample.patches.utils.TimerUtil; import com.dji.sample.wayline.dao.IWaylineFileMapper; import com.dji.sample.wayline.dao.IWaylineJobMapper; import com.dji.sample.wayline.model.entity.WaylineFileEntity; import com.dji.sample.wayline.model.entity.WaylineJobEntity; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.bouncycastle.crypto.InvalidCipherTextException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.*; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; import org.springframework.web.multipart.MultipartFile; import java.io.File; import java.io.IOException; import java.security.NoSuchAlgorithmException; import java.util.*; import java.util.stream.Collectors; import static com.dji.sample.droneairport.utils.TaskAllocator.assignTasks; import static com.dji.sample.patches.utils.TimerUtil.getCurrentTimestampPlus8Hours; @Service public class RegistServiceImpl implements RegistService { private final RestTemplate restTemplate = new RestTemplate(); private final ObjectMapper objectMapper = new ObjectMapper(); @Autowired private IDeviceRedisService redisService; @Autowired private DeviceExpanSionMapper expanSionMapper; @Autowired private TaskInfoMapper taskInfoMapper; @Autowired private GetPatchesMapper patchesMapper; @Autowired private TimerUtil timerUtil; @Autowired private IDeviceMapper deviceMapper; @Autowired private IWaylineJobMapper waylineJobMapper; @Autowired private IWaylineFileMapper fileMapper; public String registPort(DeviceExpanSionEntity airport) { try { RegistDto registDto = airportEntityToDto(airport); // 构建请求体 String jsonBody = buildRequestBody(registDto); // 设置请求头 String base64 = SM4Util.encrypt("jsimjrby3wqb7dbq", jsonBody); // 设置请求头 HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.setAccept(List.of(MediaType.APPLICATION_JSON, MediaType.TEXT_PLAIN, MediaType.ALL)); headers.set("Accept-Language", "zh-CN,zh;q=0.9"); headers.setConnection("keep-alive"); headers.set("x-lc-token", AuthUtil.getToken()); headers.set("x-lc-secret", Utils.hexToBase64(Utils.encrypt("jsimjrby3wqb7dbq", "044D6061FC08A19D3F32CEAA8CF6679B40500008FD741FC26DE7E50AEBF3A9115D47274437730EADEDAEF0CCC4853C5F0B35B30C6AEA83A5F6FBCA4ABEAC9E3B98"))); // 构建请求实体 HttpEntity requestEntity = new HttpEntity<>(base64, headers); // 发送请求 ResponseEntity response = restTemplate.exchange( "https://xcx.geoway.com.cn:8033/v1/droneAirport/RegistService", HttpMethod.POST, requestEntity, String.class); return response.getBody(); } catch (Exception e) { // 异常处理 throw new IllegalArgumentException("Request failed: " + e.getMessage(), e); } } private String buildRequestBody(RegistDto dto) { try { return objectMapper.writeValueAsString(dto); } catch (JsonProcessingException e) { throw new RuntimeException("数据有误", e); } } @Override public String addDrone(String workspaceId) { try { DeviceExpanSionEntity airport = expanSionMapper.selectOne(new LambdaQueryWrapper() .eq(DeviceExpanSionEntity::getWorkspaceId, workspaceId) .eq(DeviceExpanSionEntity::getType, 0)); DeviceExpanSionEntity drone = expanSionMapper.selectOne(new LambdaQueryWrapper() .eq(DeviceExpanSionEntity::getWorkspaceId, workspaceId) .eq(DeviceExpanSionEntity::getType, 1)); AddDeviceDto dto = deviceEntityToDto(drone); // 构建请求体 String jsonBody = buildRequestBody(dto); String base64 = SM4Util.encrypt("jsimjrby3wqb7dbq", jsonBody); String secret = enSM2("jsimjrby3wqb7dbq", "044D6061FC08A19D3F32CEAA8CF6679B40500008FD741FC26DE7E50AEBF3A9115D47274437730EADEDAEF0CCC4853C5F0B35B30C6AEA83A5F6FBCA4ABEAC9E3B98"); // 设置请求头 HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.setAccept(List.of(MediaType.APPLICATION_JSON, MediaType.TEXT_PLAIN, MediaType.ALL)); headers.set("Accept-Language", "zh-CN,zh;q=0.9"); headers.setConnection("keep-alive"); headers.set("x-lc-token", AuthUtil.getToken()); headers.set("x-lc-secret", secret); // 构建请求实体 HttpEntity requestEntity = new HttpEntity<>(base64, headers); // 发送请求 RestTemplate restTemplate = new RestTemplate(); String response = restTemplate.postForObject("https://xcx.geoway.com.cn:8033/v1/droneAirport/addDevice", requestEntity, String.class); registPort(airport); return response; } catch (Exception e) { // 异常处理 throw new IllegalArgumentException("Request failed: " + e.getMessage(), e); } } @Override public ResponseResult getDroneState(String deviceId) throws Exception { DroneStateDto data = getAirportFromCache(deviceId); String json = JSON.toJSONString(data); String SM4Screct = SM4Util.encrypt("jsimjrby3wqb7dbq", json); String SM2Screct = enSM2(SM4Screct, "23E57DA1E4AB865CCBC325B668762207DEF74345B782237808AE0BABDF26734D"); return ResponseResult.success(SM2Screct); } @Override public ResponseResult authorization(String base64, String Secret) throws Exception { String sm4Secrect = deSM2(Secret, "23E57DA1E4AB865CCBC325B668762207DEF74345B782237808AE0BABDF26734D"); String decryptedJson = SM4Util.decrypt(sm4Secrect, base64); JSONObject jsonObject = new JSONObject(decryptedJson); String deviceId = jsonObject.getStr("deviceid"); boolean online = redisService.checkDeviceOnline(deviceId); if (online) { return ResponseResult.success(200, "无人机机场授权成功！", "", ""); } return ResponseResult.error(500, "无人机机场授权失败！"); } @Override public ReturnTaskParam AddTask(String base64, String Secret, String username) throws Exception { ReturnTaskParam param = new ReturnTaskParam(); String taskId = UUID.randomUUID().toString(); String traceid = UUID.randomUUID().toString(); String sm4Secrect = deSM2(Secret, "23E57DA1E4AB865CCBC325B668762207DEF74345B782237808AE0BABDF26734D"); String decryptedJson = SM4Util.decrypt(sm4Secrect, base64); JSONObject jsonObject = new JSONObject(decryptedJson); AddTaskDto addTaskDto = jsonToDto(jsonObject); TaskInfo taskInfo = new TaskInfo(); List listx = convertStringToList(addTaskDto.getDeviceid()); taskInfo.setId(traceid); taskInfo.setTaskId(taskId); taskInfo.setName(addTaskDto.getBizidname()); taskInfo.setDeviceIds(addTaskDto.getDeviceid()); taskInfo.setCreateUser(username); param.setTraceId(traceid); taskInfoMapper.insert(taskInfo); // 转换 TaskListDto 为 LotInfo List lotInfos = new ArrayList<>(); List tasklist = addTaskDto.getTasklist(); for (TaskListDto taskListDto : tasklist) { LotInfo lotInfo = convertToLotInfo(taskListDto); lotInfo.setTaskId(taskId); lotInfo.setType(0); lotInfo.setTaskName(addTaskDto.getBizidname()); lotInfo.setUserName(username); lotInfos.add(lotInfo); patchesMapper.insert(lotInfo); } // 获取机场信息 List airports = getAirportsBySn(listx); List airportTasks = assignTasks(airports, lotInfos); // 处理并插入图斑到数据库 processAndInsertTasks(airportTasks); // 根据机场位置生成航线任务 for (AirportTasks airportTask : airportTasks) { Airport airport = airportTask.getAirport(); List lotInfosForAirport = airportTask.getTasks(); if (!lotInfosForAirport.isEmpty()) { String waylineName = TimerUtil.getTimeName(); MultipartFile multipartFile = timerUtil.getFile(waylineName, lotInfosForAirport, airport.getLat(), airport.getLon()); WaylineFileEntity waylineFile = timerUtil.backWayline(multipartFile, waylineName, airport.getWorkspaceId(), username); Long time = getCurrentTimestampPlus8Hours(14); List> listOfLists = new ArrayList<>(); List sublist = new ArrayList<>(); sublist.add(time); listOfLists.add(sublist); List lists1 = new ArrayList<>(); lists1.add(time); String times = TimerUtil.convertTimestampToFormattedString(time); param.setWaylineId(taskId); timerUtil.sendPostWithParameters(waylineName, waylineFile.getWaylineId(), times, lists1, listOfLists, taskId+"~"+airport.getWorkspaceId(),airport.getDockSn()); timerUtil.updatePatchesStatu(lotInfosForAirport); } } return param; } @Override public ReturnTaskParam updateTask(String base64, String Secret, String username) throws Exception { ReturnTaskParam param = new ReturnTaskParam(); String traceid = UUID.randomUUID().toString(); String sm4Secrect = deSM2(Secret, "23E57DA1E4AB865CCBC325B668762207DEF74345B782237808AE0BABDF26734D"); String decryptedJson = SM4Util.decrypt(sm4Secrect, base64); JSONObject jsonObject = new JSONObject(decryptedJson); UpdataTaskDto addTaskDto = UpjsonToDto(jsonObject); String taskId = addTaskDto.getTaskid(); String Bizidname=getBizidnameByTask(taskId); delPatchesByTaskId(taskId); delTaskInfo(taskId); delWaylineJob(taskId); TaskInfo taskInfo = new TaskInfo(); List listx = convertStringToList(addTaskDto.getDeviceid()); taskInfo.setId(traceid); taskInfo.setTaskId(taskId); taskInfo.setName(Bizidname); taskInfo.setDeviceIds(addTaskDto.getDeviceid()); taskInfo.setCreateUser(username); param.setTraceId(traceid); taskInfoMapper.insert(taskInfo); // 转换 TaskListDto 为 LotInfo List lotInfos = new ArrayList<>(); List tasklist = addTaskDto.getTasklist(); for (TaskListDto taskListDto : tasklist) { LotInfo lotInfo = convertToLotInfo(taskListDto); lotInfo.setTaskId(taskId); lotInfo.setType(0); lotInfo.setTaskName(Bizidname); lotInfo.setUserName(username); lotInfos.add(lotInfo); patchesMapper.insert(lotInfo); } // 获取机场信息 List airports = getAirportsBySn(listx); List airportTasks = assignTasks(airports, lotInfos); // 处理并插入图斑到数据库 processAndInsertTasks(airportTasks); // 根据机场位置生成航线任务 for (AirportTasks airportTask : airportTasks) { Airport airport = airportTask.getAirport(); List lotInfosForAirport = airportTask.getTasks(); if (!lotInfosForAirport.isEmpty()) { String waylineName = TimerUtil.getTimeName(); MultipartFile multipartFile = timerUtil.getFile(waylineName, lotInfosForAirport, airport.getLat(), airport.getLon()); WaylineFileEntity waylineFile = timerUtil.backWayline(multipartFile, waylineName, airport.getWorkspaceId(), username); // 将为规划的图斑状态更新为已规划 Long time = getCurrentTimestampPlus8Hours(14); List> listOfLists = new ArrayList<>(); List sublist = new ArrayList<>(); sublist.add(time); listOfLists.add(sublist); List lists1 = new ArrayList<>(); lists1.add(time); String times = TimerUtil.convertTimestampToFormattedString(time); param.setWaylineId(taskId); timerUtil.sendPostWithParameters(waylineName, waylineFile.getWaylineId(), times, lists1, listOfLists, airport.getWorkspaceId()+"~"+taskId,airport.getDockSn()); timerUtil.updatePatchesStatu(lotInfosForAirport); } } return param; } @Override public ResponseResult cancelTask(String taskId) { LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.like(WaylineJobEntity::getJobId, taskId) .set(WaylineJobEntity::getStatus, 4); waylineJobMapper.update(null, updateWrapper); return null; } public void processAndInsertTasks(List airportTasks) { for (AirportTasks airportTasksEntry : airportTasks) { Airport airport = airportTasksEntry.getAirport(); List tasks = airportTasksEntry.getTasks(); // 处理每个任务 for (LotInfo lotInfo : tasks) { lotInfo.setWorkspaceId(airport.getWorkspaceId()); // 设置 workspaceId patchesMapper.updateById(lotInfo); } } } @Override public ResponseResult queryTaskStatus(String taskid) { WaylineJobEntity jobEntity = waylineJobMapper.selectOne(new LambdaQueryWrapper().eq(WaylineJobEntity::getJobId, taskid)); if (jobEntity == null) { return ResponseResult.error(201, "查询无人机机场任务状态失败！"); } int code = jobEntity.getStatus(); //1: 待执行; 2: 执行中; 3: 完成; 4: 取消; 5: 失败 if (code == 1) { return ResponseResult.success(200, "查询无人机机场任务状态成功！", "", ""); } else if (code == 2) { return ResponseResult.success(202, "查询无人机机场任务状态成功！", "", ""); } else if (code == 3) { return ResponseResult.success(203, "查询无人机机场任务状态成功！", "", ""); } else if (code == 4) { return ResponseResult.success(204, "查询无人机机场任务状态成功！", "", ""); } else if (code == 5) { return ResponseResult.success(205, "查询无人机机场任务状态成功！", "", ""); } return null; } private static final String BASE_DIR = "src/main/resources/tmp"; /** * 根据任务 ID 查找对应的 DB 文件路径 * * @param taskId 任务 ID * @return 匹配的 DB 文件路径列表 */ public List findDbFilesByTaskId(String taskId) { List dbFilePaths = new ArrayList<>(); File baseDir = new File(BASE_DIR); // 检查基础目录是否存在 if (!baseDir.exists() || !baseDir.isDirectory()) { throw new IllegalStateException("Base directory does not exist or is not a directory."); } // 遍历基础目录下的所有文件夹 File[] subDirs = baseDir.listFiles(File::isDirectory); if (subDirs != null) { for (File subDir : subDirs) { // 如果文件夹名称包含任务 ID，则查找该文件夹中的 DB 文件 if (subDir.getName().contains(taskId)) { File[] files = subDir.listFiles((dir, name) -> name.endsWith(".db")); if (files != null) { for (File file : files) { dbFilePaths.add(file.getAbsolutePath()); } } } } } return dbFilePaths; } public void delPatchesByTaskId(String taskId) { patchesMapper.delete(new LambdaUpdateWrapper().eq(LotInfo::getTaskId, taskId)); } public void delTaskInfo(String taskId){ taskInfoMapper.delete(new LambdaUpdateWrapper().eq(TaskInfo::getTaskId, taskId)); } private String buildRequestBody(AddDeviceDto dto) { try { return objectMapper.writeValueAsString(dto); } catch (JsonProcessingException e) { throw new RuntimeException("数据有误", e); } } public String getWorkspaceId(String devicesn) { DeviceEntity entity = deviceMapper.selectOne(new LambdaQueryWrapper() .eq(DeviceEntity::getDeviceSn, devicesn)); return entity.getWorkspaceId(); } public String getBizidnameByTask(String taskId){ TaskInfo taskInfo= taskInfoMapper.selectOne(new LambdaQueryWrapper().eq(TaskInfo::getTaskId, taskId)); return taskInfo.getName(); } public static String enSM2(String data, String pubKey) throws InvalidCipherTextException, IOException { String encrypt = Utils.encrypt(data, pubKey); encrypt = Utils.hexToBase64(encrypt); return encrypt; } public static String deSM2(String Base64, String priKey) throws Exception { String hex = Utils.convertBase64ToHex(Base64); return Utils.decrypt(hex, priKey); } public static Map createKey() throws NoSuchAlgorithmException { Map keyPair = Utils.createKeyPair(); Map newKey = new HashMap<>(); newKey.put("publicKey", keyPair.get("pbcky")); newKey.put("privateKey", keyPair.get("pveky")); return newKey; } public AddDeviceDto deviceEntityToDto(DeviceExpanSionEntity entity) { AddDeviceDto.AddDeviceDtoBuilder builder = AddDeviceDto.builder(); if (entity != null) { builder.brand(entity.getBrand()) .height(entity.getHeight()) .longitude(entity.getLongitude()) .latitude(entity.getLatitude()) .radius(entity.getRadius()) .regioncode(entity.getRegioncode()) .deviceid(entity.getDeviceSn()) .model(entity.getModel()) .build(); } return builder.build(); } public RegistDto airportEntityToDto(DeviceExpanSionEntity entity) { RegistDto.RegistDtoBuilder builder = RegistDto.builder(); if (entity != null) { builder.serviceUrl(entity.getServiceUrl()) .contacts(entity.getContracts()) .phone(entity.getPhone()) .liveStreamPluginUrl(entity.getLiveStreamPluginUrl()) .build(); } return builder.build(); } public String getDroneFromCache(String sn) { String key = "osd:" + sn; return RedisOpsUtils.get(key).toString(); } public void delWaylineJob(String taskId) { waylineJobMapper.delete(new LambdaQueryWrapper().like(WaylineJobEntity::getJobId, taskId)); } public DroneStateDto getAirportFromCache(String deviceId) { String receiver = getDroneFromCache(deviceId); double gimbalYaw =0.0; double gimbalPitch=0.0; com.alibaba.fastjson.JSONObject jsonObject = JSON.parseObject(receiver); double latitude = jsonObject.getDoubleValue("latitude"); double longitude = jsonObject.getDoubleValue("longitude"); int modeCode = jsonObject.getInteger("mode_code"); double elevation = jsonObject.getDoubleValue("elevation"); double height = jsonObject.getDoubleValue("height"); com.alibaba.fastjson.JSONArray payloads = jsonObject.getJSONArray("payloads"); if (payloads != null && payloads.size() > 1) { com.alibaba.fastjson.JSONArray payloadArray = payloads.getJSONArray(1); for (int i = 0; i < payloadArray.size(); i++) { com.alibaba.fastjson.JSONObject payload = payloadArray.getJSONObject(i); gimbalYaw = payload.getDoubleValue("gimbal_yaw"); gimbalPitch = payload.getDoubleValue("gimbal_pitch"); } } com.alibaba.fastjson.JSONObject battery = jsonObject.getJSONObject("battery"); int batteryCapacityPercent = battery.getInteger("capacity_percent"); DroneStateDto.DroneStateDtoBuilder builder = DroneStateDto.builder(); builder.gimbalYal(gimbalYaw) .gimbalPitch(gimbalPitch) .batteryCapacityPercent(batteryCapacityPercent) .height(height) .latitude(latitude) .longitude(longitude) .modeCode(modeCode) .elevation(elevation) .gpsState(3); return builder.build(); } public static AddTaskDto jsonToDto(JSONObject jsonObject) { AddTaskDto dto = new AddTaskDto(); String deviceid = jsonObject.getStr("deviceid"); dto.setDeviceid(deviceid); dto.setBizidname(jsonObject.getStr("bizidname")); JSONArray taskListArray = jsonObject.getJSONArray("tasklist"); if (taskListArray != null) { List taskList = new ArrayList<>(); for (int i = 0; i < taskListArray.size(); i++) { JSONObject taskObject = taskListArray.getJSONObject(i); if (taskObject != null) { TaskListDto task = new TaskListDto(); task.bsm = taskObject.getStr("bsm"); task.xzqdm = taskObject.getStr("xzqdm"); task.dkbh = taskObject.getStr("dkbh"); task.dklx = taskObject.getStr("dklx"); task.zdkbh = taskObject.getStr("zdkbh"); task.dkmc = taskObject.getStr("dkmc"); task.dkmj = taskObject.getDouble("dkmj"); task.dkfw = taskObject.getStr("dkfw"); task.bz = taskObject.getStr("bz"); taskList.add(task); } } dto.tasklist = taskList; } return dto; } public static UpdataTaskDto UpjsonToDto(JSONObject jsonObject) { UpdataTaskDto dto = new UpdataTaskDto(); String deviceid = jsonObject.getStr("deviceid"); String taskid = jsonObject.getStr("taskid"); dto.setDeviceid(deviceid); dto.setTaskid(taskid); JSONArray taskListArray = jsonObject.getJSONArray("tasklist"); if (taskListArray != null) { List taskList = new ArrayList<>(); for (int i = 0; i < taskListArray.size(); i++) { JSONObject taskObject = taskListArray.getJSONObject(i); if (taskObject != null) { TaskListDto task = new TaskListDto(); task.bsm = taskObject.getStr("bsm"); task.xzqdm = taskObject.getStr("xzqdm"); task.dkbh = taskObject.getStr("dkbh"); task.dklx = taskObject.getStr("dklx"); task.zdkbh = taskObject.getStr("zdkbh"); task.dkmc = taskObject.getStr("dkmc"); task.dkmj = taskObject.getDouble("dkmj"); task.dkfw = taskObject.getStr("dkfw"); task.bz = taskObject.getStr("bz"); taskList.add(task); } } dto.tasklist = taskList; } return dto; } public static LotInfo convertToLotInfo(TaskListDto taskListDto) { if (taskListDto == null) { return null; } return LotInfo.builder() .bsm(taskListDto.bsm) .dklx(taskListDto.dklx) .xzqdm(taskListDto.xzqdm) .dkbh(taskListDto.dkbh) .dkmc(taskListDto.dkmc) .dkmj(taskListDto.dkmj) .dkfw(taskListDto.dkfw) .bz(taskListDto.bz) .build(); } public List getAirportsBySn(List snList) { List airports = new ArrayList<>(); // 查询所有设备 List entities = expanSionMapper.selectList( new LambdaQueryWrapper().in(DeviceExpanSionEntity::getDeviceSn, snList) ); // 使用一个Map来存储SN和经纬度的对应关系 Map entityMap = new HashMap<>(); for (DeviceExpanSionEntity entity : entities) { entityMap.put(entity.getDeviceSn(), entity); } // 遍历SN列表，创建Airport对象 for (String sn : snList) { DeviceExpanSionEntity entity = entityMap.get(sn); if (entity != null) { DeviceEntity deviceEntity = deviceMapper.selectOne(new LambdaQueryWrapper().eq(DeviceEntity::getChildSn,sn)); Airport airport = new Airport(entity.getWorkspaceId(),deviceEntity.getDeviceSn(),entity.getLatitude(), entity.getLongitude()); airports.add(airport); } } return airports; } public static List convertStringToList(String input) { // 使用 Hutool 解析字符串 JSONArray jsonArray = JSONUtil.parseArray(input); // 将 JSONArray 转换为 List return jsonArray.stream() .map(Object::toString) .collect(Collectors.toList()); } public void updateTaskInfo(String traceid, String taskId, String deviceIds, String username) { TaskInfo taskInfo = new TaskInfo(); taskInfo.setId(traceid); taskInfo.setTaskId(taskId); taskInfo.setDeviceIds(deviceIds); taskInfo.setCreateUser(username); LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(TaskInfo::getId, traceid); updateWrapper.eq(TaskInfo::getTaskId, taskId); // 执行更新操作 taskInfoMapper.update(taskInfo, updateWrapper); } public void updateJob(String jobid, String waylineId) { LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(WaylineJobEntity::getJobId, jobid) .set(WaylineJobEntity::getFileId, waylineId); // 调用 update 方法进行更新操作 waylineJobMapper.update(null, updateWrapper); } }