|
@@ -4,13 +4,7 @@ import com.lantone.common.dto.AbnormalLogDTO;
|
|
|
import com.lantone.common.dto.LoginLogDTO;
|
|
|
import com.lantone.common.dto.OperationLogDTO;
|
|
|
import com.lantone.common.util.AddressUtils;
|
|
|
-import com.lantone.dblayermbg.facade.AbnormalLogFacade;
|
|
|
-import com.lantone.dblayermbg.facade.DataAuthFacade;
|
|
|
-import com.lantone.dblayermbg.facade.DictionaryInfoFacade;
|
|
|
-import com.lantone.dblayermbg.facade.HospitalSetFacade;
|
|
|
-import com.lantone.dblayermbg.facade.LoginLogFacade;
|
|
|
-import com.lantone.dblayermbg.facade.OperationLogFacade;
|
|
|
-import com.lantone.dblayermbg.facade.ResourceFacade;
|
|
|
+import com.lantone.message.client.SecurityService;
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.amqp.core.Message;
|
|
@@ -28,31 +22,19 @@ import org.springframework.stereotype.Component;
|
|
|
public class MessageReceiver {
|
|
|
|
|
|
@Autowired
|
|
|
- private DictionaryInfoFacade dictionaryInfoFacade;
|
|
|
- @Autowired
|
|
|
- private HospitalSetFacade hospitalSetFacade;
|
|
|
- @Autowired
|
|
|
- private ResourceFacade resourceFacade;
|
|
|
- @Autowired
|
|
|
- private LoginLogFacade loginLogFacade;
|
|
|
- @Autowired
|
|
|
- private OperationLogFacade operationLogFacade;
|
|
|
- @Autowired
|
|
|
- private AbnormalLogFacade abnormalLogFacade;
|
|
|
- @Autowired
|
|
|
- private DataAuthFacade dataAuthFacade;
|
|
|
+ private SecurityService securityService;
|
|
|
|
|
|
|
|
|
@RabbitListener(queues = "emrais.redis.cache.refresh.queue", ackMode = "MANUAL")
|
|
|
public void RedisCacheRefreshHandle(String type, Message message, Channel channel) throws Exception {
|
|
|
- if (type.equals(DictionaryInfoFacade.class.getSimpleName())) {
|
|
|
- dictionaryInfoFacade.initDicMap();
|
|
|
- } else if (type.equals(HospitalSetFacade.class.getSimpleName())) {
|
|
|
- hospitalSetFacade.initHospitalSetMap();
|
|
|
- } else if (type.equals(ResourceFacade.class.getSimpleName())) {
|
|
|
- resourceFacade.initResourceRolesMap();
|
|
|
- } else if (type.equals(DataAuthFacade.class.getSimpleName())) {
|
|
|
- dataAuthFacade.initUserDataAuth();
|
|
|
+ if (type.equals("initDicMap")) {
|
|
|
+ securityService.initDicMap();
|
|
|
+ } else if (type.equals("initHospitalSetMap")) {
|
|
|
+ securityService.initHospitalSetMap();
|
|
|
+ } else if (type.equals("initResourceRolesMap")) {
|
|
|
+ securityService.initResourceRolesMap();
|
|
|
+ } else if (type.equals("initUserDataAuth")) {
|
|
|
+ securityService.initUserDataAuth();
|
|
|
}
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|
|
@@ -60,20 +42,20 @@ public class MessageReceiver {
|
|
|
@RabbitListener(queues = "emrais.login.success.record.queue", ackMode = "MANUAL")
|
|
|
public void sendLogSuccessMessageHandle(LoginLogDTO loginLog, Message message, Channel channel) throws Exception {
|
|
|
loginLog.setLoginAddress(AddressUtils.getRealAddressByIP(loginLog.getLoginIp()));
|
|
|
- loginLogFacade.getBaseMapper().addLoginLog(loginLog);
|
|
|
+ securityService.addLoginLog(loginLog);
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|
|
|
|
|
|
@RabbitListener(queues = "emrais.oper.log.record.queue", ackMode = "MANUAL")
|
|
|
public void sendOperLogRecordMessage(OperationLogDTO operationLog, Message message, Channel channel) throws Exception {
|
|
|
operationLog.setOperationAddress(AddressUtils.getRealAddressByIP(operationLog.getOperationIp()));
|
|
|
- operationLogFacade.getBaseMapper().addOperLog(operationLog);
|
|
|
+ securityService.addOperLog(operationLog);
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|
|
|
|
|
|
@RabbitListener(queues = "emrais.oper.error.record.queue", ackMode = "MANUAL")
|
|
|
public void sendOperErrorRecordMessage(AbnormalLogDTO abnormalLogDTO, Message message, Channel channel) throws Exception {
|
|
|
- abnormalLogFacade.getBaseMapper().addOperErrorLog(abnormalLogDTO);
|
|
|
+ securityService.addOperErrorLog(abnormalLogDTO);
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|
|
|
|