package com.java110.job.smo.impl;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.base.smo.BaseServiceSMO;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.data.DatabusQueueDataDto;
|
import com.java110.dto.log.LogSystemErrorDto;
|
import com.java110.dto.system.BusinessDatabusDto;
|
import com.java110.dto.data.DatabusDataDto;
|
import com.java110.dto.machine.CarInoutDto;
|
import com.java110.dto.machine.MachineDto;
|
import com.java110.dto.fee.TempCarPayOrderDto;
|
import com.java110.dto.system.Business;
|
import com.java110.intf.job.IDataBusInnerServiceSMO;
|
import com.java110.job.adapt.IDatabusAdapt;
|
import com.java110.job.adapt.hcIot.http.ISendIot;
|
import com.java110.job.databus.DatabusDataQueue;
|
import com.java110.po.log.LogSystemErrorPo;
|
import com.java110.service.smo.ISaveSystemErrorSMO;
|
import com.java110.utils.cache.DatabusCache;
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.utils.util.ExceptionUtil;
|
import com.java110.vo.ResultVo;
|
import org.slf4j.Logger;
|
import com.java110.core.log.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
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_GET_QRCODE_PROTOCOL = "getMachineQrCodeAdapt";//获取二维码
|
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";//默认设备记录适配器
|
|
@Autowired
|
private ISaveSystemErrorSMO saveSystemErrorSMOImpl;
|
|
@Autowired
|
private ISendIot sendIotImpl;
|
|
@Override
|
public boolean exchange(@RequestBody List<Business> businesses) {
|
List<BusinessDatabusDto> databusDtos = DatabusCache.getDatabuss();
|
for (Business business : businesses) {
|
doExchange(business, businesses, databusDtos);
|
}
|
return true;
|
}
|
|
@Override
|
public ResultVo openDoor(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.openDoor(reqJson);
|
|
}
|
|
@Override
|
public ResultVo closeDoor(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.closeDoor(reqJson);
|
|
}
|
|
|
@Override
|
public ResultVo getQRcode(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_GET_QRCODE_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.getQRcode(reqJson);
|
}
|
|
@Override
|
public ResultVo customCarInOut(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.customCarInOut(reqJson);
|
}
|
|
@Override
|
public ResultVo payVideo(@RequestBody MachineDto machineDto) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.payVideo(machineDto);
|
}
|
|
@Override
|
public ResultVo heartbeatVideo(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_OPEN_DOOR_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.heartbeatVideo(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 updateCarInoutCarNum(@RequestBody CarInoutDto carInoutDto) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_GET_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.updateCarInoutCarNum(carInoutDto);
|
}
|
|
@Override
|
public ResultVo getManualOpenDoorLogs(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_GET_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.getManualOpenDoorLogs(reqJson);
|
}
|
|
@Override
|
public ResultVo tempCarAuth(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_NOTIFY_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.tempCarAuth(reqJson);
|
}
|
|
@Override
|
public ResultVo getTempCarAuths(@RequestBody JSONObject reqJson) {
|
IDatabusAdapt databusAdaptImpl = ApplicationContextFactory.getBean(DEFAULT_NOTIFY_TEMP_CAR_FEE_ORDER_PROTOCOL, IDatabusAdapt.class);
|
return databusAdaptImpl.getTempCarAuths(reqJson);
|
}
|
|
|
|
@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 databusDataDto
|
* @return
|
*/
|
@Override
|
public boolean databusData(@RequestBody DatabusDataDto databusDataDto) {
|
// IDatabusAdapt databusAdaptImpl = null;
|
List<BusinessDatabusDto> databusDtos = DatabusCache.getDatabuss();
|
Business business = null;
|
List<Business> businesses = null;
|
DatabusQueueDataDto databusQueueDataDto = null;
|
String dataId = "";
|
for (BusinessDatabusDto databusDto : databusDtos) {
|
dataId = GenerateCodeFactory.getUUID();
|
try {
|
if (!databusDataDto.getBusinessTypeCd().equals(databusDto.getBusinessTypeCd())) {
|
continue;
|
}
|
businesses = new ArrayList<>();
|
business = new Business();
|
business.setData(databusDataDto.getData());
|
business.setBusinessTypeCd(databusDataDto.getBusinessTypeCd());
|
businesses.add(business);
|
databusQueueDataDto = new DatabusQueueDataDto(databusDto.getBeanName(), business, businesses);
|
databusQueueDataDto.setDataId(dataId);
|
|
//todo 存放队列中
|
DatabusDataQueue.addMsg(databusQueueDataDto);
|
|
// databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
|
// databusAdaptImpl.customExchange(customBusinessDatabusDto);
|
} catch (Exception e) {
|
logger.error("执行databus失败", e);
|
}
|
}
|
|
return true;
|
|
}
|
|
|
/**
|
* 处理业务类
|
*
|
* @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())) {
|
continue;
|
}
|
//todo 收据同步去打印处理，不然前台等不及
|
if ("payFeeReceiptAdapt".equals(databusDto.getBeanName())) {
|
databusAdaptImpl = ApplicationContextFactory.getBean(databusDto.getBeanName(), IDatabusAdapt.class);
|
databusAdaptImpl.execute(business, businesses);
|
continue;
|
}
|
//todo 存放队列中
|
DatabusDataQueue.addMsg(new DatabusQueueDataDto(databusDto.getBeanName(), business, businesses));
|
|
} catch (Exception e) {
|
logger.error("执行databus失败", e);
|
LogSystemErrorPo logSystemErrorPo = new LogSystemErrorPo();
|
logSystemErrorPo.setErrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_errId));
|
logSystemErrorPo.setErrType(LogSystemErrorDto.ERR_TYPE_DATABUS);
|
logSystemErrorPo.setMsg(ExceptionUtil.getStackTrace(e));
|
saveSystemErrorSMOImpl.saveLog(logSystemErrorPo);
|
}
|
}
|
}
|
}
|
