//package com.base.track.mq.service;
//
//import com.base.orbit.mq.model.BaseHeadMqDTO;
//import com.base.orbit.mq.topics.TopicConst;
//import com.base.orbit.utils.DateUtils;
//import com.base.track.mq.MqProducer;
//import com.base.track.mq.model.TrackBodyMqResultDTO;
//import com.base.track.mq.model.TrackMqResultDTO;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Service;
//
//import javax.annotation.Resource;
//
//@Service
//public class TrackMqResultService {
//    @Resource
//    MqProducer mqProducer;
//
//    @Async
//    public void sendcount(String filePath,String type){
//        //  消息头
//        BaseHeadMqDTO messageHeader = new BaseHeadMqDTO();
//        String createTime = DateUtils.dateTimeNow();
//        messageHeader.setCreationTime(createTime);
//        messageHeader.setOriginator("JCPT");
//        messageHeader.setRecipient("YKSC");
//        messageHeader.setMessageType("GDJS");
//        messageHeader.setMessageId(messageHeader.getMessageType() + "_" + messageHeader.getOriginator() + "_" + messageHeader.getCreationTime());
//
//        //消息体
//        TrackBodyMqResultDTO trackBodyMqResultDTO=new TrackBodyMqResultDTO();
//        trackBodyMqResultDTO.setFileDataType(type);
//        trackBodyMqResultDTO.setFilePath(filePath);
//
//        TrackMqResultDTO trackMqResultDTO=new TrackMqResultDTO();
//        mqProducer.push(TopicConst.YKSC_JCPT,"data",trackMqResultDTO);
//    }
//}
