特别注入
This commit is contained in:
parent
f44f7571ba
commit
1311d4fdff
@ -4,11 +4,11 @@ import cn.hutool.core.date.DateUtil;
|
|||||||
import com.alibaba.nacos.api.exception.NacosException;
|
import com.alibaba.nacos.api.exception.NacosException;
|
||||||
import com.xhpc.common.api.dto.ChargingStationDto;
|
import com.xhpc.common.api.dto.ChargingStationDto;
|
||||||
import com.xhpc.common.enums.StationDeviceEnum;
|
import com.xhpc.common.enums.StationDeviceEnum;
|
||||||
|
import com.xhpc.mapper.XhpcDeviceMessageMapper;
|
||||||
import com.xhpc.pp.domain.ServiceField;
|
import com.xhpc.pp.domain.ServiceField;
|
||||||
import com.xhpc.pp.domain.XhpcDeviceMessage;
|
import com.xhpc.pp.domain.XhpcDeviceMessage;
|
||||||
import com.xhpc.pp.logic.FieldLogic;
|
import com.xhpc.pp.logic.FieldLogic;
|
||||||
import com.xhpc.pp.logic.ServiceMainLogic;
|
import com.xhpc.pp.logic.ServiceMainLogic;
|
||||||
import com.xhpc.mapper.XhpcDeviceMessageMapper;
|
|
||||||
import com.xhpc.pp.tx.ServiceParameter;
|
import com.xhpc.pp.tx.ServiceParameter;
|
||||||
import com.xhpc.pp.tx.ServiceResult;
|
import com.xhpc.pp.tx.ServiceResult;
|
||||||
import com.xhpc.pp.tx.TxException;
|
import com.xhpc.pp.tx.TxException;
|
||||||
@ -21,7 +21,6 @@ import org.quickserver.net.server.ClientHandler;
|
|||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
|
||||||
@ -51,15 +50,13 @@ public class ChargingPileBinaryHandler implements ClientBinaryHandler {
|
|||||||
// private static final String DATA_TYPE_HEX = "hex";
|
// private static final String DATA_TYPE_HEX = "hex";
|
||||||
|
|
||||||
private final ServiceMainLogic servicemainLogic;
|
private final ServiceMainLogic servicemainLogic;
|
||||||
|
private final XhpcDeviceMessageMapper xhpcDeviceMessageMapper;
|
||||||
|
|
||||||
@Resource
|
|
||||||
XhpcDeviceMessageMapper deviceMessageMapper;
|
|
||||||
|
|
||||||
|
|
||||||
public ChargingPileBinaryHandler() {
|
public ChargingPileBinaryHandler() {
|
||||||
|
|
||||||
servicemainLogic = SpringContextHolder.getBean("ServiceMainLogic");
|
servicemainLogic = SpringContextHolder.getBean("ServiceMainLogic");
|
||||||
|
xhpcDeviceMessageMapper = SpringContextHolder.getBean(XhpcDeviceMessageMapper.class);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@ -130,7 +127,7 @@ public class ChargingPileBinaryHandler implements ClientBinaryHandler {
|
|||||||
deviceMessage.setStatus(0);
|
deviceMessage.setStatus(0);
|
||||||
deviceMessage.setContent(HexUtils.toString(result.getBinary()));
|
deviceMessage.setContent(HexUtils.toString(result.getBinary()));
|
||||||
deviceMessage.setChargeOrderNo((String) req.get("orderNo"));
|
deviceMessage.setChargeOrderNo((String) req.get("orderNo"));
|
||||||
deviceMessageMapper.insertByDomain(deviceMessage);
|
xhpcDeviceMessageMapper.insertByDomain(deviceMessage);
|
||||||
}
|
}
|
||||||
if (SERVICE_HB.equals(serviceName) && OK.equals(resultCode)) {
|
if (SERVICE_HB.equals(serviceName) && OK.equals(resultCode)) {
|
||||||
Boolean tcfg = (Boolean) cachePile.get("tcfg");
|
Boolean tcfg = (Boolean) cachePile.get("tcfg");
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user