| | |
|---|
| | | import com.java110.core.context.BusinessServiceDataFlow; |
|---|
| | | import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing; |
|---|
| | | import com.java110.core.factory.DataFlowFactory; |
|---|
| | | import com.java110.entity.center.DataFlowLinksCost; |
|---|
| | | import com.java110.entity.center.DataFlowLog; |
|---|
| | | import com.java110.dto.system.DataFlowLinksCost; |
|---|
| | | import com.java110.dto.system.DataFlowLog; |
|---|
| | | import com.java110.oa.smo.IOaServiceSMO; |
|---|
| | | import com.java110.utils.cache.MappingCache; |
|---|
| | | import com.java110.utils.constant.KafkaConstant; |
|---|
| | |
|---|
| | | */ |
|---|
| | | private void saveCostTimeLogMessage(BusinessServiceDataFlow businessServiceDataFlow) { |
|---|
| | | try { |
|---|
| | | if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.KEY_COST_TIME_ON_OFF))) { |
|---|
| | | if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH,MappingConstant.KEY_COST_TIME_ON_OFF))) { |
|---|
| | | List<DataFlowLinksCost> dataFlowLinksCosts = businessServiceDataFlow.getLinksCostDates(); |
|---|
| | | JSONObject costDate = new JSONObject(); |
|---|
| | | JSONArray costDates = new JSONArray(); |
|---|
