package com.szwl.handle.response; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.szwl.constant.OperationType; import com.szwl.model.entity.MessageLog; import com.szwl.model.entity.TEquipment; import com.szwl.service.TEquipmentService; import org.springframework.stereotype.Component; import javax.annotation.Resource; @Component public class OfflineProcessor implements ResponseProcessor { @Resource private TEquipmentService tEquipmentService; @Override public void process(MessageLog messageLog) { Integer statusCode = messageLog.getStatusCode(); if (statusCode == 200) { Integer direction = messageLog.getDirection(); String clientId = messageLog.getClientId(); String responseContent = messageLog.getResponseContent(); LambdaQueryWrapper query = Wrappers.lambdaQuery(); query.eq(TEquipment::getClientId, clientId); TEquipment equipment = tEquipmentService.getOne(query); if (equipment != null) { equipment.setClientId(equipment.getClientId() + "xxx"); tEquipmentService.updateById(equipment); } } } @Override public String getSupportedOperationType() { return OperationType.OFFLINE.getCode(); } }