diff --git a/database/install/sys_dict_data1_i18n_zh.sql b/database/install/sys_dict_data1_i18n_zh.sql index 3649d3e0..f0695f2c 100644 --- a/database/install/sys_dict_data1_i18n_zh.sql +++ b/database/install/sys_dict_data1_i18n_zh.sql @@ -733,5 +733,7 @@ INSERT INTO `sys_dict_data` VALUES (2222, 2222, 'dictData.trace_interfaces.17', INSERT INTO `sys_dict_data` VALUES (2223, 2223, 'dictData.trace_interfaces.20', 'N20', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); INSERT INTO `sys_dict_data` VALUES (2224, 2224, 'dictData.trace_interfaces.22', 'N22', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); INSERT INTO `sys_dict_data` VALUES (2225, 2225, 'dictData.trace_interfaces.40', 'N40', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (2226, 2226, 'job.nbi.syncNRM', '定时同步网元资源数据', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (2227, 2227, 'job.nbi.syncNRM.remark', '定时同步网元资源数据任务', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); SET FOREIGN_KEY_CHECKS = 1; diff --git a/database/install/sys_dict_data2_i18n_en.sql b/database/install/sys_dict_data2_i18n_en.sql index 2a355ae0..793e970b 100644 --- a/database/install/sys_dict_data2_i18n_en.sql +++ b/database/install/sys_dict_data2_i18n_en.sql @@ -733,5 +733,7 @@ INSERT INTO `sys_dict_data` VALUES (4222, 4222, 'dictData.trace_interfaces.17', INSERT INTO `sys_dict_data` VALUES (4223, 4223, 'dictData.trace_interfaces.20', 'N20', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); INSERT INTO `sys_dict_data` VALUES (4224, 4224, 'dictData.trace_interfaces.22', 'N22', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); INSERT INTO `sys_dict_data` VALUES (4225, 4225, 'dictData.trace_interfaces.40', 'N40', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (4226, 4226, 'job.nbi.syncNRM', 'Scheduled Synchronization of NEs Resource Data', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (4227, 4227, 'job.nbi.syncNRM.remark', 'Scheduled Task for Synchronization of NEs Resource Data', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); SET FOREIGN_KEY_CHECKS = 1; diff --git a/database/install/sys_job.sql b/database/install/sys_job.sql index c8505380..dc0607f6 100644 --- a/database/install/sys_job.sql +++ b/database/install/sys_job.sql @@ -44,6 +44,6 @@ INSERT INTO `sys_job` VALUES (13, 'job.exportSMFCDR', 'SYSTEM', 'exportTable', ' INSERT INTO `sys_job` VALUES (14, 'job.exportSMSCCDR', 'SYSTEM', 'exportTable', '{\"duration\":1,\"tableName\":\"cdr_event_smsc\",\"columns\":\"id,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordType\')) as record_type,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.serviceType\')) as service_type,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.callerParty\')) as caller_party,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.calledParty\')) as called_party,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.result\')) as result,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.updateTime\')) as update_time\",\"timeCol\":\"timestamp\",\"timeUnit\":\"second\",\"extras\":\"\",\"filePath\":\"/usr/local/omc/backup/smsc_cdr\"}', '0 0 0/1 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1724309047797, ''); INSERT INTO `sys_job` VALUES (15, 'job.removeExportedFiles', 'SYSTEM', 'removeFile', '[{\"filePath\":\"/usr/local/omc/backup/operate_log\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/ims_cdr\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/smf_cdr\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/smsc_cdr\",\"maxDays\":30}]', '0 10 0 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1728634085631, ''); INSERT INTO `sys_job` VALUES (16, 'job.exportSGWCCDR', 'SYSTEM', 'exportTable', '{\"duration\":1,\"tableName\":\"cdr_event_sgwc\",\"columns\":\"id,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordType\')) as recordType,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.accessPointNameNI\')) as accessPointNameNI,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedIMSI\')) as IMSI,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedMSISDN\')) as MSISDN,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedPDPPDNAddress\')) as PdpAddress,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.duration\')) as duration,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordOpeningTime\')) as recordOpeningTime,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.chargingID\')) as chargingID,JSON_UNQUOTE(JSON_EXTRACT(cdr_json, \'$.listOfTrafficVolumes[0].dataVolumeGPRSDownlink\')) AS dataVolumeGPRSDownlink,JSON_UNQUOTE(JSON_EXTRACT(cdr_json, \'$.listOfTrafficVolumes[0].dataVolumeGPRsUplink\')) as dataVolumeGPRsUplink,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.userLocationInformation.tai.tac\')) as tac,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.userLocationInformation.ecgi.eutraCellId\')) as cellID\",\"timeCol\":\"timestamp\",\"timeUnit\":\"second\",\"extras\":\"\",\"filePath\":\"/usr/local/omc/backup/sgwc_cdr\"}', '0 0 0/1 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1724309047797, ''); -INSERT INTO `sys_job` VALUES (17, 'job.nbiNRM', 'SYSTEM', 'nbiNRM', '{}', '0 10 0 * * ?', '3', '0', '1', '1', 'system', 1698478134839, 'system', 1698478134839, ''); +INSERT INTO `sys_job` VALUES (17, 'job.nbi.syncNRM', 'SYSTEM', 'syncNbiNRM', '{}', '0 10 0 * * ?', '3', '0', '1', '1', 'system', 1698478134839, 'system', 1698478134839, 'job.nbi.syncNRM.remark'); SET FOREIGN_KEY_CHECKS = 1; diff --git a/database/upgrade/upg_sys_dict_data1_i18n_zh.sql b/database/upgrade/upg_sys_dict_data1_i18n_zh.sql index 12d26152..623b92a6 100644 --- a/database/upgrade/upg_sys_dict_data1_i18n_zh.sql +++ b/database/upgrade/upg_sys_dict_data1_i18n_zh.sql @@ -740,5 +740,7 @@ REPLACE INTO `sys_dict_data` VALUES (2222, 2222, 'dictData.trace_interfaces.17', REPLACE INTO `sys_dict_data` VALUES (2223, 2223, 'dictData.trace_interfaces.20', 'N20', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); REPLACE INTO `sys_dict_data` VALUES (2224, 2224, 'dictData.trace_interfaces.22', 'N22', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); REPLACE INTO `sys_dict_data` VALUES (2225, 2225, 'dictData.trace_interfaces.40', 'N40', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (2226, 2226, 'job.nbi.syncNRM', '定时同步网元资源数据', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (2227, 2227, 'job.nbi.syncNRM.remark', '定时同步网元资源数据任务', 'i18n_zh', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); SET FOREIGN_KEY_CHECKS = 1; diff --git a/database/upgrade/upg_sys_dict_data2_i18n_en.sql b/database/upgrade/upg_sys_dict_data2_i18n_en.sql index 632a3553..5a957f7f 100644 --- a/database/upgrade/upg_sys_dict_data2_i18n_en.sql +++ b/database/upgrade/upg_sys_dict_data2_i18n_en.sql @@ -739,5 +739,7 @@ REPLACE INTO `sys_dict_data` VALUES (4222, 4222, 'dictData.trace_interfaces.17', REPLACE INTO `sys_dict_data` VALUES (4223, 4223, 'dictData.trace_interfaces.20', 'N20', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); REPLACE INTO `sys_dict_data` VALUES (4224, 4224, 'dictData.trace_interfaces.22', 'N22', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); REPLACE INTO `sys_dict_data` VALUES (4225, 4225, 'dictData.trace_interfaces.40', 'N40', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (4226, 4226, 'job.nbi.syncNRM', 'Scheduled Synchronization of NEs Resource Data', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); +REPLACE INTO `sys_dict_data` VALUES (4227, 4227, 'job.nbi.syncNRM.remark', 'Scheduled Task for Synchronization of NEs Resource Data', 'i18n_en', '', '', '1', 'supervisor', 1721902269805, '', 0, ''); SET FOREIGN_KEY_CHECKS = 1; diff --git a/database/upgrade/upg_sys_job.sql b/database/upgrade/upg_sys_job.sql index 4365b02b..bdafdcd0 100644 --- a/database/upgrade/upg_sys_job.sql +++ b/database/upgrade/upg_sys_job.sql @@ -48,6 +48,6 @@ REPLACE INTO `sys_job` VALUES (13, 'job.exportSMFCDR', 'SYSTEM', 'exportTable', REPLACE INTO `sys_job` VALUES (14, 'job.exportSMSCCDR', 'SYSTEM', 'exportTable', '{\"duration\":1,\"tableName\":\"cdr_event_smsc\",\"columns\":\"id,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordType\')) as record_type,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.serviceType\')) as service_type,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.callerParty\')) as caller_party,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.calledParty\')) as called_party,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.result\')) as result,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.updateTime\')) as update_time\",\"timeCol\":\"timestamp\",\"timeUnit\":\"second\",\"extras\":\"\",\"filePath\":\"/usr/local/omc/backup/smsc_cdr\"}', '0 0 0/1 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1724309047797, ''); REPLACE INTO `sys_job` VALUES (15, 'job.removeExportedFiles', 'SYSTEM', 'removeFile', '[{\"filePath\":\"/usr/local/omc/backup/operate_log\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/ims_cdr\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/smf_cdr\",\"maxDays\":30},{\"filePath\":\"/usr/local/omc/backup/smsc_cdr\",\"maxDays\":30}]', '0 10 0 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1728634085631, ''); REPLACE INTO `sys_job` VALUES (16, 'job.exportSGWCCDR', 'SYSTEM', 'exportTable', '{\"duration\":1,\"tableName\":\"cdr_event_sgwc\",\"columns\":\"id,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordType\')) as recordType,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.accessPointNameNI\')) as accessPointNameNI,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedIMSI\')) as IMSI,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedMSISDN\')) as MSISDN,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.servedPDPPDNAddress\')) as PdpAddress,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.duration\')) as duration,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.recordOpeningTime\')) as recordOpeningTime,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.chargingID\')) as chargingID,JSON_UNQUOTE(JSON_EXTRACT(cdr_json, \'$.listOfTrafficVolumes[0].dataVolumeGPRSDownlink\')) AS dataVolumeGPRSDownlink,JSON_UNQUOTE(JSON_EXTRACT(cdr_json, \'$.listOfTrafficVolumes[0].dataVolumeGPRsUplink\')) as dataVolumeGPRsUplink,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.userLocationInformation.tai.tac\')) as tac,JSON_UNQUOTE(JSON_EXTRACT(cdr_json,\'$.userLocationInformation.ecgi.eutraCellId\')) as cellID\",\"timeCol\":\"timestamp\",\"timeUnit\":\"second\",\"extras\":\"\",\"filePath\":\"/usr/local/omc/backup/sgwc_cdr\"}', '0 0 0/1 * * ?', '3', '0', '1', '1', 'supervisor', 1698478134842, 'admin', 1724309047797, ''); -REPLACE INTO `sys_job` VALUES (17, 'job.nbiNRM', 'SYSTEM', 'nbiNRM', '{}', '0 10 0 * * ?', '3', '0', '1', '1', 'system', 1698478134839, 'system', 1698478134839, ''); +REPLACE INTO `sys_job` VALUES (17, 'job.nbi.syncNRM', 'SYSTEM', 'syncNbiNRM', '{}', '0 10 0 * * ?', '3', '0', '1', '1', 'system', 1698478134839, 'system', 1698478134839, 'job.nbi.syncNRM.remark'); SET FOREIGN_KEY_CHECKS = 1; \ No newline at end of file diff --git a/src/modules/crontask/processor/processor.go b/src/modules/crontask/processor/processor.go index 426e43ec..0b59194b 100644 --- a/src/modules/crontask/processor/processor.go +++ b/src/modules/crontask/processor/processor.go @@ -9,10 +9,10 @@ import ( "be.ems/src/modules/crontask/processor/genNeStateAlarm" "be.ems/src/modules/crontask/processor/getStateFromNE" processorMonitorSysResource "be.ems/src/modules/crontask/processor/monitor_sys_resource" - "be.ems/src/modules/crontask/processor/nbiNRM" processorNeConfigBackup "be.ems/src/modules/crontask/processor/ne_config_backup" processorNeDataUDM "be.ems/src/modules/crontask/processor/ne_data_udm" "be.ems/src/modules/crontask/processor/removeFile" + "be.ems/src/modules/crontask/processor/syncNbiNRM" ) // InitCronQueue 初始定时任务队列 @@ -31,5 +31,5 @@ func InitCronQueue() { cron.CreateQueue("genNeStateAlarm", genNeStateAlarm.NewProcessor) cron.CreateQueue("exportTable", exportTable.NewProcessor) cron.CreateQueue("removeFile", removeFile.NewProcessor) - cron.CreateQueue("nbiNRM", nbiNRM.NewProcessor) + cron.CreateQueue("syncNbiNRM", syncNbiNRM.NewProcessor) } diff --git a/src/modules/crontask/processor/nbiNRM/amf/schema.go b/src/modules/crontask/processor/syncNbiNRM/amf/schema.go similarity index 97% rename from src/modules/crontask/processor/nbiNRM/amf/schema.go rename to src/modules/crontask/processor/syncNbiNRM/amf/schema.go index 39b95d1f..3ed11e9d 100644 --- a/src/modules/crontask/processor/nbiNRM/amf/schema.go +++ b/src/modules/crontask/processor/syncNbiNRM/amf/schema.go @@ -1,6 +1,6 @@ package amf -import "be.ems/src/modules/crontask/processor/nbiNRM/common" +import "be.ems/src/modules/crontask/processor/syncNbiNRM/common" const ( AMF string = "AMF" // 网元类型 diff --git a/src/modules/crontask/processor/nbiNRM/common/common.go b/src/modules/crontask/processor/syncNbiNRM/common/common.go similarity index 100% rename from src/modules/crontask/processor/nbiNRM/common/common.go rename to src/modules/crontask/processor/syncNbiNRM/common/common.go diff --git a/src/modules/crontask/processor/nbiNRM/pcf/schema.go b/src/modules/crontask/processor/syncNbiNRM/pcf/schema.go similarity index 96% rename from src/modules/crontask/processor/nbiNRM/pcf/schema.go rename to src/modules/crontask/processor/syncNbiNRM/pcf/schema.go index 3fb5391e..4db15835 100644 --- a/src/modules/crontask/processor/nbiNRM/pcf/schema.go +++ b/src/modules/crontask/processor/syncNbiNRM/pcf/schema.go @@ -1,6 +1,6 @@ package pcf -import "be.ems/src/modules/crontask/processor/nbiNRM/common" +import "be.ems/src/modules/crontask/processor/syncNbiNRM/common" const ( PCF string = "PCF" // 网元类型 diff --git a/src/modules/crontask/processor/nbiNRM/smf/schema.go b/src/modules/crontask/processor/syncNbiNRM/smf/schema.go similarity index 100% rename from src/modules/crontask/processor/nbiNRM/smf/schema.go rename to src/modules/crontask/processor/syncNbiNRM/smf/schema.go diff --git a/src/modules/crontask/processor/nbiNRM/syncAmf.go b/src/modules/crontask/processor/syncNbiNRM/syncAmf.go similarity index 98% rename from src/modules/crontask/processor/nbiNRM/syncAmf.go rename to src/modules/crontask/processor/syncNbiNRM/syncAmf.go index 13622198..1f820f11 100644 --- a/src/modules/crontask/processor/nbiNRM/syncAmf.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncAmf.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" @@ -8,8 +8,8 @@ import ( "be.ems/lib/dborm" "be.ems/lib/log" - "be.ems/src/modules/crontask/processor/nbiNRM/amf" - "be.ems/src/modules/crontask/processor/nbiNRM/common" + "be.ems/src/modules/crontask/processor/syncNbiNRM/amf" + "be.ems/src/modules/crontask/processor/syncNbiNRM/common" ) // SyncAmfNbiCM 从ne_info获取AMF网元并同步数据到nbi_cm表 diff --git a/src/modules/crontask/processor/nbiNRM/nbiNRM.go b/src/modules/crontask/processor/syncNbiNRM/syncNbiNRM.go similarity index 98% rename from src/modules/crontask/processor/nbiNRM/nbiNRM.go rename to src/modules/crontask/processor/syncNbiNRM/syncNbiNRM.go index e3a64c06..5e9f57bc 100644 --- a/src/modules/crontask/processor/nbiNRM/nbiNRM.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncNbiNRM.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" diff --git a/src/modules/crontask/processor/nbiNRM/syncPcf.go b/src/modules/crontask/processor/syncNbiNRM/syncPcf.go similarity index 97% rename from src/modules/crontask/processor/nbiNRM/syncPcf.go rename to src/modules/crontask/processor/syncNbiNRM/syncPcf.go index cdfd6b1a..aab63262 100644 --- a/src/modules/crontask/processor/nbiNRM/syncPcf.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncPcf.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" @@ -7,8 +7,8 @@ import ( "be.ems/lib/dborm" "be.ems/lib/log" - "be.ems/src/modules/crontask/processor/nbiNRM/common" - "be.ems/src/modules/crontask/processor/nbiNRM/pcf" + "be.ems/src/modules/crontask/processor/syncNbiNRM/common" + "be.ems/src/modules/crontask/processor/syncNbiNRM/pcf" ) // SyncPcfNbiCM 从ne_info获取PCF网元并同步数据到nbi_cm表 diff --git a/src/modules/crontask/processor/nbiNRM/syncSmf.go b/src/modules/crontask/processor/syncNbiNRM/syncSmf.go similarity index 98% rename from src/modules/crontask/processor/nbiNRM/syncSmf.go rename to src/modules/crontask/processor/syncNbiNRM/syncSmf.go index 06415118..8e0b087f 100644 --- a/src/modules/crontask/processor/nbiNRM/syncSmf.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncSmf.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" @@ -7,8 +7,8 @@ import ( "be.ems/lib/dborm" "be.ems/lib/log" - "be.ems/src/modules/crontask/processor/nbiNRM/common" - "be.ems/src/modules/crontask/processor/nbiNRM/smf" + "be.ems/src/modules/crontask/processor/syncNbiNRM/common" + "be.ems/src/modules/crontask/processor/syncNbiNRM/smf" ) // SyncSmfNbiCM 从ne_info获取SMF网元并同步数据到nbi_cm表 diff --git a/src/modules/crontask/processor/nbiNRM/syncUdm.go b/src/modules/crontask/processor/syncNbiNRM/syncUdm.go similarity index 98% rename from src/modules/crontask/processor/nbiNRM/syncUdm.go rename to src/modules/crontask/processor/syncNbiNRM/syncUdm.go index 5ea8706b..a8e65c53 100644 --- a/src/modules/crontask/processor/nbiNRM/syncUdm.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncUdm.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" @@ -7,8 +7,8 @@ import ( "be.ems/lib/dborm" "be.ems/lib/log" - "be.ems/src/modules/crontask/processor/nbiNRM/common" - "be.ems/src/modules/crontask/processor/nbiNRM/udm" + "be.ems/src/modules/crontask/processor/syncNbiNRM/common" + "be.ems/src/modules/crontask/processor/syncNbiNRM/udm" ) // SyncUdmNbiCM 从ne_info获取UDM网元并同步数据到nbi_cm表 diff --git a/src/modules/crontask/processor/nbiNRM/syncUpf.go b/src/modules/crontask/processor/syncNbiNRM/syncUpf.go similarity index 98% rename from src/modules/crontask/processor/nbiNRM/syncUpf.go rename to src/modules/crontask/processor/syncNbiNRM/syncUpf.go index bbfe85eb..70974aec 100644 --- a/src/modules/crontask/processor/nbiNRM/syncUpf.go +++ b/src/modules/crontask/processor/syncNbiNRM/syncUpf.go @@ -1,4 +1,4 @@ -package nbiNRM +package syncNbiNRM import ( "encoding/json" @@ -7,8 +7,8 @@ import ( "be.ems/lib/dborm" "be.ems/lib/log" - "be.ems/src/modules/crontask/processor/nbiNRM/common" - "be.ems/src/modules/crontask/processor/nbiNRM/upf" + "be.ems/src/modules/crontask/processor/syncNbiNRM/common" + "be.ems/src/modules/crontask/processor/syncNbiNRM/upf" ) // SyncUpfNbiCM 从ne_info获取UPF网元并同步数据到nbi_cm表 diff --git a/src/modules/crontask/processor/nbiNRM/udm/schema.go b/src/modules/crontask/processor/syncNbiNRM/udm/schema.go similarity index 100% rename from src/modules/crontask/processor/nbiNRM/udm/schema.go rename to src/modules/crontask/processor/syncNbiNRM/udm/schema.go diff --git a/src/modules/crontask/processor/nbiNRM/upf/schema.go b/src/modules/crontask/processor/syncNbiNRM/upf/schema.go similarity index 100% rename from src/modules/crontask/processor/nbiNRM/upf/schema.go rename to src/modules/crontask/processor/syncNbiNRM/upf/schema.go