forked from kidgrow-microservices-platform
blame | history | patch | commit | commitdiff | ignore whitespace
luliqiang
2020-08-22 d53a83cf17751b6b270286a0a18ed281261b4625 
 kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/ConsumptionRecordServiceImpl.java


@@ -20,9 +20,9 @@


import org.apache.commons.collections4.MapUtils;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.amqp.rabbit.annotation.RabbitListener;


import org.springframework.amqp.rabbit.core.RabbitTemplate;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




@@ -53,7 +53,8 @@


    private RabbitTemplate rabbitTemplate;




    private static final Logger logger = LoggerFactory.getLogger(ConsumptionRecordServiceImpl.class);




    @Value("${spring.profiles.active}")


    private String envName;


    /**


     * 列表


     *


@@ -670,7 +671,7 @@


     * 发消息到消息队列


     * @return


     */


    @RabbitListener(queues = "BoneAgeEvaluationData")


    //@RabbitListener(queues = "BoneAgeEvaluationData")


    private void MessageToBI(ConsumptionRequest consumptionRequest)


    {


        //发消息到队列


@@ -678,6 +679,8 @@


                "\",\"departmentId\":\"" + consumptionRequest.getDepartmentId() +


                "\",\"doctorId\":\"" + consumptionRequest.getDoctorId() +


                "\",\"date\":\"" + DateUtils.formatDate(new Date(),"yyyy-MM-dd")+"\"}";


        rabbitTemplate.convertAndSend(ConsumptionConstant.EXCHANGE_DATA, ConsumptionConstant.ROUTINGKEY_DATA, context);


        rabbitTemplate.convertAndSend(ConsumptionConstant.EXCHANGE_DATA, ConsumptionConstant.ROUTINGKEY_DATA+envName, context);




        log.error("骨龄评价扣费消息已发送："+context);


    }


}