diff options
author | Morgan Richomme <morgan.richomme@orange.com> | 2021-02-04 10:25:28 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2021-02-04 10:25:28 +0000 |
commit | 60e4660810c4d7961b5407dc38f4b2826d288816 (patch) | |
tree | a2e5177e3bda3297f02012ae47e294b6694812e1 /src/main/java/com/cmcc/simulator/job/ScheduleJob.java | |
parent | 804f07142c7fdd7b8a38738b80e8cb97859a4344 (diff) | |
parent | be6f49580a7bb98a13021175b8ca363ce02f57cd (diff) |
Merge "Initial code check-in core-nssmf-simulator Issue-ID: INT-1840"honolulu
Diffstat (limited to 'src/main/java/com/cmcc/simulator/job/ScheduleJob.java')
-rw-r--r-- | src/main/java/com/cmcc/simulator/job/ScheduleJob.java | 55 |
1 files changed, 55 insertions, 0 deletions
diff --git a/src/main/java/com/cmcc/simulator/job/ScheduleJob.java b/src/main/java/com/cmcc/simulator/job/ScheduleJob.java new file mode 100644 index 0000000..0a91750 --- /dev/null +++ b/src/main/java/com/cmcc/simulator/job/ScheduleJob.java @@ -0,0 +1,55 @@ +package com.cmcc.simulator.job; + +import java.util.ArrayList; +import java.util.List; + +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.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import com.alibaba.fastjson.JSONObject; +import com.cmcc.simulator.service.SimulatorService; +import com.cmcc.simulator.xml.FileReadyEvent; +import com.cmcc.simulator.xml.Utils; + +@Component +@EnableScheduling +public class ScheduleJob { + + private static final Logger logger = LoggerFactory.getLogger(ScheduleJob.class); + @Autowired + private SimulatorService service; + + @Value("${ftppath}") + private String ftpPath; + + @Scheduled(fixedDelayString = "${fixeddelay}") + public void runThird() throws Exception { + List<String> nsstIds = service.getActivatedSlices(); + if (!nsstIds.isEmpty()) { + logger.info("the snssai list is : {}", nsstIds); + service.createAMF(nsstIds); + service.createUPF(nsstIds); + service.gzipFiles(); + + List<String> list = new ArrayList<String>(); + list.add(ftpPath); + + FileReadyEvent event = new FileReadyEvent(); + event.setCreateat(Utils.getTimeFormat()); + event.setDatasource("VIM"); + event.setFileuri(list); + event.setNfvoid("10.10.10.1"); + event.setSourceid("10011001"); + + service.notify(event); + service.delFiles(); + logger.info("notify pm data success: {}", JSONObject.toJSON(event).toString()); + } + } + +} |