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.model.entity.TEquipmentDesc;
import com.szwl.service.TEquipmentDescService;
import com.szwl.service.TEquipmentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Slf4j
@Component
public class BanPaperMoneyProcessor implements ResponseProcessor{

    @Resource
    private TEquipmentService tEquipmentService;

    @Resource
    private TEquipmentDescService tEquipmentDescService;
    @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 tEquipment = tEquipmentService.getOne(query);
            if (tEquipment != null) {
                TEquipmentDesc equipmentDesc = tEquipmentDescService.getById(tEquipment.getId());
                equipmentDesc.setBanPaper(responseContent.equals("1"));
                tEquipmentDescService.updateById(equipmentDesc);
            }
        }
    }

    @Override
    public String getSupportedOperationType() {
        return OperationType.BAN_PAPER_MONEY.getCode();
    }
}