szwlServer/src/main/java/com/szwl/handle/response/OfflineProcessor.java

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<TEquipment> 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();
    }
}