package com.java110.job.smo.impl;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.base.smo.BaseServiceSMO;
|
import com.java110.dto.businessDatabus.BusinessDatabusDto;
|
import com.java110.dto.businessDatabus.CustomBusinessDatabusDto;
|
import com.java110.dto.tempCarFeeConfig.TempCarPayOrderDto;
|
import com.java110.entity.order.Business;
|
import com.java110.intf.job.IDataBusInnerServiceSMO;
|
import com.java110.job.adapt.IDatabusAdapt;
|
import com.java110.utils.cache.DatabusCache;
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.vo.ResultVo;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.List;
|
|
/**
|
* @ClassName FloorInnerServiceSMOImpl
|
* @Description 定时任务属性内部服务实现类
|
* @Author wuxw
|
* @Date 2019/4/24 9:20
|
* @Version 1.0
|
* add by wuxw 2019/4/24
|
**/
|
@RestController
|
public class DataBusInnerServiceSMOImpl extends BaseServiceSMO implements IDataBusInnerServiceSMO {
|
private static final Logger logger = LoggerFactory.getLogger(DataBusInnerServiceSMOImpl.class);
|
|
public static final String DEFAULT_OPEN_DOOR_PROTOCOL = "openDoorAdapt";//吸墨门禁
|
public static final String DEFAULT_START_MACHINE_PROTOCOL = "restartMachineAdapt";//吸墨门禁
|
public static final String DEFAULT_RESEND_IOT_PROTOCOL = "reSendIotAdapt";//重新送数据
|
public static final String DEFAULT_GET_TEMP_CAR_FEE_ORDER_PROTOCOL = "getTempCarFeeOrderAdapt";//重新送数据
|
public static final String DEFAULT_NOTIFY_TEMP_CAR_FEE_ORDER_PROTOCOL = "notifyTempCarFeeOrderAdapt";//重新送数据
|
public static final String DEFAULT_DEFAULT_SEND_MACHINE_RECORD = "defaultSendMachineRecordAdapt";//默认设备记录适配器
|
|
|
@Override
|
public boolean exchange(@RequestBody List<Business> businesses) {
|
List<BusinessDatabusDto> databusDtos = DatabusCache.getDatabuss();
|
for (Business business : businesses) {
|
doExchange(business, businesses, databusDtos);
|
}
|
return false;
|
}
|
|
@Override
|
public ResultVo openDoor(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.openDoor(reqJson);
|
|
}
|
|
@Override
|
public ResultVo restartMachine(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_START_MACHINE_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.restartMachine(reqJson);
|
|
}
|
|
@Override
|
public ResultVo resendIot(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_RESEND_IOT_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.reSendToIot(reqJson);
|
|
}
|
|
@Override
|
public ResultVo getTempCarFeeOrder(@RequestBody TempCarPayOrderDto tempCarPayOrderDto) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_GET_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.getTempCarFeeOrder(tempCarPayOrderDto);
|
}
|
|
@Override
|
public ResultVo notifyTempCarFeeOrder(@RequestBody TempCarPayOrderDto tempCarPayOrderDto) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_NOTIFY_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.notifyTempCarFeeOrder(tempCarPayOrderDto);
|
}
|
|
/**
|
* 门禁开门记录
|
*
|
* @param customBusinessDatabusDto
|
* @return
|
*/
|
@Override
|
public void customExchange(@RequestBody CustomBusinessDatabusDto customBusinessDatabusDto) {
|
IDatabusAdapt databusAdaptImpl = null;
|
List<BusinessDatabusDto> databusDtos = DatabusCache.getDatabuss();
|
for (BusinessDatabusDto databusDto : databusDtos) {
|
try {
|
if (customBusinessDatabusDto.getBusinessTypeCd().equals(databusDto.getBusinessTypeCd())) {
|
databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
|
databusAdaptImpl.customExchange(customBusinessDatabusDto);
|
}
|
} catch (Exception e) {
|
logger.error("执行databus失败", e);
|
}
|
}
|
}
|
|
/**
|
* 处理业务类
|
*
|
* @param business 当前业务
|
* @param businesses 全部业务
|
* @param databusDtos databus
|
*/
|
private void doExchange(Business business, List<Business> businesses, List<BusinessDatabusDto> databusDtos) {
|
IDatabusAdapt databusAdaptImpl = null;
|
for (BusinessDatabusDto databusDto : databusDtos) {
|
try {
|
if (business.getBusinessTypeCd().equals(databusDto.getBusinessTypeCd())) {
|
databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
|
databusAdaptImpl.execute(business, businesses);
|
}
|
} catch (Exception e) {
|
logger.error("执行databus失败", e);
|
}
|
}
|
}
|
}
|
