java110
2023-01-29 01ae4444d62fbd0c09942ffbd66c79bac2057ca9
service-fee/src/main/java/com/java110/fee/smo/impl/FeeServiceSMOImpl.java
old mode 100644 new mode 100755
@@ -18,7 +18,7 @@
import com.java110.entity.center.DataFlowLog;
import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.java110.core.log.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -73,7 +73,7 @@
    private void saveLogMessage(BusinessServiceDataFlow businessServiceDataFlow) {
        try {
            if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_LOG_ON_OFF))) {
            if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH,MappingConstant.KEY_LOG_ON_OFF))) {
                for (DataFlowLog dataFlowLog : businessServiceDataFlow.getLogDatas()) {
                    KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_LOG_NAME, "", JSONObject.toJSONString(dataFlowLog));
                }