mock工程修改提交

ebc-mock-service/src/main/java/com/ai/bss/mock/MockApp.java

import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
/**
 * @author wangdong
@ComponentScan(basePackages = {"com.ai.bss","com.ai.abc","com.ai.ipu"})
@EnableAsync
@SpringBootApplication
@EnableScheduling
public class MockApp {
    public static void main(String[] args) throws Exception {
        SpringApplication.run(MockApp.class, args);
    }
}
}

ebc-mock-service/src/main/java/com/ai/bss/mock/controller/MockController.java

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
        return mockManageService.startMackData(sId,f,topic0,topic1);
    }
    @Scheduled(cron = "*/30 * * * * ?")
    public void startMackData() {
        mockManageService.startMackData();
    }
    /**
     * 查询历史轨迹查询
     */

ebc-mock-service/src/main/java/com/ai/bss/mock/service/impl/MockManageServiceImpl.java

import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import com.ai.bss.mock.model.MockScenarioData;
@Service
public class MockManageServiceImpl implements MockManageService {
    private static final Logger logger = LoggerFactory.getLogger(MockManageServiceImpl.class);
    @Value("${mack.data.sids}")
    private String sIds;
    @Value("${mack.data.frequency}")
    private String frequency;
	protected static Map MACK_STATUS = new HashMap();
	
    @Autowired
    private MockScenarioDataRepository mockScenarioDataRepository;
    @Autowired
    @Override
    public void startMackData()  {
        Long fre = Long.valueOf(frequency);
        String[] sIdArr = sIds.split(",");
        for (int i = 0; i < sIdArr.length; i++) {
            Long sId = Long.valueOf(sIdArr[i]);
            //        验证场景是否正在执行
            if(MACK_STATUS.get(sId)!=null){
                logger.error("场景" + sId + " 正在执行,请耐心等待...");
                continue;
            }
            //根据场景ID从数据库中查询模拟数据
            List<MockScenarioData>  mockScenarioDataList = mockScenarioDataRepository.findByScenarioIdOrderByOrderNo(sId);
            List<Long> orderNoList = mockScenarioDataRepository.findByOrderNoByScenarioId(sId);
            if(mockScenarioDataList==null || mockScenarioDataList.size()==0){
                logger.error("场景" + sId + "没有配置模拟 ，请在数据库中添加数据再执行...");
                continue;
            }
            //记录场景执行状态
            MACK_STATUS.put(sId,2);
            //异步执行模拟场景 通过IOT-DMP连接服务模拟
//        mockProcess.processMock(sId,mockScenarioDataList,frequency);
            //异步执行模拟场景  直接模拟最终数据发送到kafka
            mockProcess.processMockKafka(sId,mockScenarioDataList,orderNoList,fre,null, null);
        }
    }
    @Override
    public String  stopMackData(Long sId){
        MACK_STATUS.remove(sId);
        return "场景" + sId + " 终止执行...";

ebc-mock-service/src/main/java/com/ai/bss/mock/service/interfaces/MockManageService.java

     */
    String  startMackData(Long sId,  Long f,String topic0,String topic1) ;
    void  startMackData() ;
    /**
     * 停止执行模拟数据
     * @param sId

ebc-mock-service/src/main/resources/application.properties

kafka.producer.linger=1
kafka.producer.buffer.memory=40960
kafka.producer.topic=67message
mack.data.sids=22,25,26
mack.data.frequency=2