diff --git a/board/board-website/src/components/ChatUI/ChatUI.vue b/board/board-website/src/components/ChatUI/ChatUI.vue index 8944fb86bfa7978a7ce8ac49af811a3ca752bf19..dfe7169df7f6d3793d4c38b6690e08291c883a85 100644 --- a/board/board-website/src/components/ChatUI/ChatUI.vue +++ b/board/board-website/src/components/ChatUI/ChatUI.vue @@ -194,7 +194,7 @@ console.log('hide'); vData.dom.classList.add('hide'); vData.dom.classList.remove('show'); - window.localStorage.removeItem(`${window.api.prefixPath}_chat`); + window.localStorage.removeItem(`${window.api.baseUrl}_chat`); }; // show chat room diff --git a/board/board-website/src/components/LayoutBase.vue b/board/board-website/src/components/LayoutBase.vue index 94c3ac7b49f7237916580113ee9787341fbdf440..22138e1f1f3a404b9fcad3639b72a41cec31e165 100644 --- a/board/board-website/src/components/LayoutBase.vue +++ b/board/board-website/src/components/LayoutBase.vue @@ -119,7 +119,7 @@ }; // open chat room const startChart = () => { - if (window.localStorage.getItem(`${window.api.prefixPath}_chat`) === 'connect') { + if (window.localStorage.getItem(`${window.api.baseUrl}_chat`) === 'connect') { nextTick(async () => { chatui.value.show(); restartWs(); @@ -129,7 +129,8 @@ const restartWs = () => { if(vData.ws) return; - const url = process.env.NODE_ENV === 'production' ? `wss://${window.api.baseUrl.replace(/http(s?):\/\//, '')}` : 'wss://xxx.wolaidai.com/board-service-04'; // ws://xxx:8080/board-service-01 // wss://xxx.wolaidai.com/board-service-01 + const protocol = window.api.baseUrl.replace(/^http/, 'ws'); + const url = process.env.NODE_ENV === 'production' ? protocol : 'wss://xxx.wolaidai.com/board-service-04'; // ws://xxx:8080/board-service-01 // wss://xxx.wolaidai.com/board-service-01 const websocket = new WebSocket(`${url}/chatserver/${userInfo.value.token}`); websocket.addEventListener('open', ev => { @@ -172,8 +173,8 @@ provide('refresh', methods.refresh); onBeforeMount(() => { - const { prefixPath } = window.api; - const asideCollapsedKey = `${prefixPath}AsideCollapsed`; + const { baseUrl } = window.api; + const asideCollapsedKey = `${baseUrl}AsideCollapsed`; // collapsed left menus const $isCollapsed = window.localStorage.getItem(asideCollapsedKey); @@ -191,7 +192,7 @@ }); // check last state - if (window.localStorage.getItem(`${prefixPath}chat`) === 'connect') { + if (window.localStorage.getItem(`${baseUrl}_chat`) === 'connect') { startChart(); } }); diff --git a/board/board-website/src/components/LayoutHeader.vue b/board/board-website/src/components/LayoutHeader.vue index 5a83ab50b1ef6b82b6c8236af7cd8745d549d5cf..2a5a5fcb344b5ecdc48b7fb30a0e4e59ef575dbe 100644 --- a/board/board-website/src/components/LayoutHeader.vue +++ b/board/board-website/src/components/LayoutHeader.vue @@ -229,7 +229,7 @@ }; // chat connection const getConnect = () => { - const key = `${window.api.prefixPath}_chat`; + const key = `${window.api.baseUrl}_chat`; const inited = window.localStorage.getItem(key); if(inited !== 'connect') { diff --git a/board/board-website/src/components/LoginDialog.vue b/board/board-website/src/components/LoginDialog.vue index f3d7dbaf7572efe58af959d0bae72d35af6459f3..1c6c97189b4ccb81d6ed3fbd9863be93bd2ad484 100644 --- a/board/board-website/src/components/LoginDialog.vue +++ b/board/board-website/src/components/LoginDialog.vue @@ -91,7 +91,7 @@ created () { this.$bus.$on('show-login-dialog', () => { // hide the chat room - window.localStorage.setItem(`${window.api.prefixPath}_chat`, 'disconnect'); + window.localStorage.setItem(`${window.api.baseUrl}_chat`, 'disconnect'); this.$store.commit('SYSTEM_INITED', false); this.form.code = ''; this.show = true; diff --git a/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/AbstractAlgorithm.java b/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/AbstractAlgorithm.java index b1c059545d736415fb65e0d0e25b80ff94f17548..15307e1649588c2563a9bc96af3bb9bcdc79d3b3 100644 --- a/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/AbstractAlgorithm.java +++ b/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/AbstractAlgorithm.java @@ -55,7 +55,7 @@ public abstract class AbstractAlgorithm { * single sigmod function */ protected PredictModel sigmod(PredictModel model) { - model.setData(1. / (1. + exp(-Double.valueOf(model.getData().toString())))); + model.setScore(1. / (1. + exp(-model.getScore()))); return model; } diff --git a/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/lr/single/LrVertPromoterAlgorithm.java b/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/lr/single/LrVertPromoterAlgorithm.java index 83de678094f84b63703832c26d243a5b3f07f576..79c96f0ca84cc8fde6c358ff5710d94790cbb405 100644 --- a/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/lr/single/LrVertPromoterAlgorithm.java +++ b/serving/serving-sdk-java/src/main/java/com/welab/wefe/serving/sdk/algorithm/lr/single/LrVertPromoterAlgorithm.java @@ -55,8 +55,8 @@ public class LrVertPromoterAlgorithm extends AbstractLrAlgorithmcom.welab.wefe common-web ${project.parent.version} - - - org.springframework.boot - spring-boot-starter-logging - - - - - org.springframework.boot - spring-boot-starter-log4j2 diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java index 524521736ed0b4c8e612420fe31ae470cdb9bc5a..1a0e225ec59a98d3e3655e3052da5eafdd401263 100644 --- a/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java +++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java @@ -156,19 +156,27 @@ public class DataSyncTask { * Sync block data */ private void startSync(long blockNumber) throws Exception { - // get block by block number - BcosBlock.Block block = BlockUtil.getBlock(this.client, new BigInteger(String.valueOf(blockNumber))); - BlockInfoBO blockInfoBO = BlockInfoParser.create(block).parse(); + for (int i = 0; i < 6; i++) { + // get block by block number + BcosBlock.Block block = BlockUtil.getBlock(this.client, new BigInteger(String.valueOf(blockNumber))); + BlockInfoBO blockInfoBO = BlockInfoParser.create(block).parse(); + + if (CollectionUtils.isEmpty(blockInfoBO.getEventBOList())) { + // retry + Thread.sleep(500); + continue; + } - BlockInfoBO filterBlockInfoBO = filterBlockInfoBO(blockInfoBO); + BlockInfoBO filterBlockInfoBO = filterBlockInfoBO(blockInfoBO); - DataProcessor.parseBlockData(filterBlockInfoBO); + DataProcessor.parseBlockData(filterBlockInfoBO); - saveBlockSyncHeight(blockInfoBO); + saveBlockSyncHeight(blockInfoBO); - saveBlockSyncContractHeight(filterBlockInfoBO); + saveBlockSyncContractHeight(filterBlockInfoBO); - saveBlockDetailInfo(blockInfoBO); + saveBlockDetailInfo(blockInfoBO); + } } /** diff --git a/union/blockchain-data-sync/src/main/resources/application.properties b/union/blockchain-data-sync/src/main/resources/application.properties new file mode 100644 index 0000000000000000000000000000000000000000..38aa3e080e225f3539289118cbd4f656568e1fd5 --- /dev/null +++ b/union/blockchain-data-sync/src/main/resources/application.properties @@ -0,0 +1,35 @@ +server.port=9527 + +server.servlet.context-path=/blockchain-data-sync + + +spring.datasource.mongodb.union.uri=mongodb://user:pwd@10.**.**.**:16016/wefe_union_dev +spring.datasource.mongodb.union.databaseName=wefe_union_dev + +spring.servlet.multipart.max-request-size=30MB +spring.servlet.multipart.max-file-size=20MB + + + + +sdk.corePoolSize=50 +sdk.maxPoolSize=100 +sdk.queueCapacity=100 +sdk.ip=10.**.**.** +sdk.channelPort=20200 +sdk.certPath=**/**/dev_config + +contract.data-sync-group-id=1 +contract.solidity-path=**/**/solidity + + +wechat.bot-url=https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key= + + + +logging.file=/data/logs/blockchain-data-sync/blockchain-data-sync.log +logging.level.root=info +logging.file.max-history=60 +logging.file.max-size=20GB +logging.pattern.console=%clr(%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) [%X{requestId}] %clr([%15.15t]){faint} %clr(%-40.40logger{39}[%F:%L]){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx} +logging.pattern.file=%d{yyyy-MM-dd HH:mm:ss.SSS} [%level] [%X{requestId}] ${PID:- } [%15.15t] %-40.40logger{39}[%F:%L] : %m%n diff --git a/union/blockchain-data-sync/src/main/resources/application.yml b/union/blockchain-data-sync/src/main/resources/application.yml deleted file mode 100644 index 74185d26aa523a2d97e081223cadf20901668739..0000000000000000000000000000000000000000 --- a/union/blockchain-data-sync/src/main/resources/application.yml +++ /dev/null @@ -1,41 +0,0 @@ -spring: - datasource: - mongodb: - uri: mongodb://wefe:********@*.1.0.*:37017/wefe_union - databaseName: wefe_union - - servlet: - multipart: - max-request-size: 30MB - max-file-size: 20MB - - -server: - port: 9527 - tomcat: - max-threads: 200 - max-connections: 10000 - servlet: - context-path: /blockchain-data-sync - -sdk: - corePoolSize: 50 - maxPoolSize: 100 - queueCapacity: 100 - ip: 10.**.**.87 - channelPort: 20200 - certPath: xx/xx/cert # cert path of relative or absolute - - -logging: - config: classpath:log4j2.xml - level: - com.welab.wefe: info - - -wechat: - bot-url: https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key= - -contract: - data-sync-group-id: 1 - solidity-path: union/blockchain-data-sync/solidity diff --git a/union/blockchain-data-sync/src/main/resources/log4j2.xml b/union/blockchain-data-sync/src/main/resources/log4j2.xml deleted file mode 100644 index f32183beafba1f351b318e2c2ecf4b26a58b08d6..0000000000000000000000000000000000000000 --- a/union/blockchain-data-sync/src/main/resources/log4j2.xml +++ /dev/null @@ -1,84 +0,0 @@ - - - - ./log - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file