third / fw-freya

Commit 8e9596640575e7cdf67ade74baf91be84ccc59a2

Authored by 王明元
1 parent 72e0eaf9

2023年10月19日15:34:51 短视频数据落库限制时间变更

Inline Side-by-side
Showing 6 changed files with 233 additions and 371 deletions
db/freya.mv.db
View file @8e95966
No preview for this file type
db/freya.trace.db
  View file @8e95966
... ... @@ -43312,361 +43312,219 @@ SELECT * FROM ACCOUNT wehe type = 2 [42000-200]
43312 43312 2023-09-22 17:36:11 jdbc[44]: exception
43313 43313 org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "SELECT * FROM ACCOUNT WEHE TYPE[*] = 2"; SQL statement:
43314 43314 SELECT * FROM ACCOUNT wehe type = 2 [42000-200]
43315   -2023-09-28 06:09:55 jdbc[3]: exception
43316   -java.sql.SQLClientInfoException: Client info name 'ApplicationName' not supported.
43317   - at org.h2.jdbc.JdbcConnection.setClientInfo(JdbcConnection.java:1749)
43318   - at com.intellij.database.remote.jdbc.impl.RemoteConnectionImpl.setClientInfo(RemoteConnectionImpl.java:466)
43319   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
43320   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
43321   - at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
43322   - at java.base/java.lang.reflect.Method.invoke(Method.java:566)
43323   - at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:359)
43324   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200)
43325   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197)
43326   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43327   - at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196)
43328   - at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562)
43329   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796)
43330   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677)
43331   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43332   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676)
43333   - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
43334   - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
43335   - at java.base/java.lang.Thread.run(Thread.java:834)
43336   -2023-09-28 14:10:35 database: flush
43337   -org.h2.message.DbException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43338   - at org.h2.message.DbException.get(DbException.java:194)
43339   - at org.h2.message.DbException.convert(DbException.java:347)
43340   - at org.h2.mvstore.db.MVTableEngine$1.uncaughtException(MVTableEngine.java:93)
43341   - at org.h2.mvstore.MVStore.handleException(MVStore.java:2877)
43342   - at org.h2.mvstore.MVStore.panic(MVStore.java:481)
43343   - at org.h2.mvstore.MVStore.<init>(MVStore.java:402)
43344   - at org.h2.mvstore.MVStore$Builder.open(MVStore.java:3579)
43345   - at org.h2.mvstore.db.MVTableEngine$Store.open(MVTableEngine.java:170)
43346   - at org.h2.mvstore.db.MVTableEngine.init(MVTableEngine.java:103)
43347   - at org.h2.engine.Database.getPageStore(Database.java:2659)
43348   - at org.h2.engine.Database.open(Database.java:675)
43349   - at org.h2.engine.Database.openDatabase(Database.java:307)
43350   - at org.h2.engine.Database.<init>(Database.java:301)
43351   - at org.h2.engine.Engine.openSession(Engine.java:74)
43352   - at org.h2.engine.Engine.openSession(Engine.java:192)
43353   - at org.h2.engine.Engine.createSessionAndValidate(Engine.java:171)
43354   - at org.h2.engine.Engine.createSession(Engine.java:166)
43355   - at org.h2.engine.Engine.createSession(Engine.java:29)
43356   - at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:340)
43357   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:173)
43358   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:152)
43359   - at org.h2.Driver.connect(Driver.java:69)
43360   - at com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
43361   - at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:364)
43362   - at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:206)
43363   - at com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:476)
43364   - at com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:561)
43365   - at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
43366   - at com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
43367   - at org.springframework.boot.autoconfigure.h2.H2ConsoleAutoConfiguration.lambda$h2Console$0(H2ConsoleAutoConfiguration.java:67)
43368   - at org.springframework.beans.factory.support.DefaultListableBeanFactory$DependencyObjectProvider.ifAvailable(DefaultListableBeanFactory.java:2035)
43369   - at org.springframework.boot.autoconfigure.h2.H2ConsoleAutoConfiguration.h2Console(H2ConsoleAutoConfiguration.java:66)
43370   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
43371   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
43372   - at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
43373   - at java.base/java.lang.reflect.Method.invoke(Method.java:566)
43374   - at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
43375   - at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:653)
43376   - at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:638)
43377   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1352)
43378   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1195)
43379   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:582)
43380   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
43381   - at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
43382   - at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
43383   - at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
43384   - at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:213)
43385   - at org.springframework.boot.web.servlet.ServletContextInitializerBeans.getOrderedBeansOfType(ServletContextInitializerBeans.java:212)
43386   - at org.springframework.boot.web.servlet.ServletContextInitializerBeans.getOrderedBeansOfType(ServletContextInitializerBeans.java:203)
43387   - at org.springframework.boot.web.servlet.ServletContextInitializerBeans.addServletContextInitializerBeans(ServletContextInitializerBeans.java:97)
43388   - at org.springframework.boot.web.servlet.ServletContextInitializerBeans.<init>(ServletContextInitializerBeans.java:86)
43389   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.getServletContextInitializerBeans(ServletWebServerApplicationContext.java:260)
43390   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.selfInitialize(ServletWebServerApplicationContext.java:234)
43391   - at org.springframework.boot.web.embedded.tomcat.TomcatStarter.onStartup(TomcatStarter.java:53)
43392   - at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5219)
43393   - at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
43394   - at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1396)
43395   - at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1386)
43396   - at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
43397   - at org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
43398   - at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:140)
43399   - at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:919)
43400   - at org.apache.catalina.core.StandardHost.startInternal(StandardHost.java:835)
43401   - at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
43402   - at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1396)
43403   - at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1386)
43404   - at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
43405   - at org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
43406   - at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:140)
43407   - at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:919)
43408   - at org.apache.catalina.core.StandardEngine.startInternal(StandardEngine.java:263)
43409   - at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
43410   - at org.apache.catalina.core.StandardService.startInternal(StandardService.java:432)
43411   - at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
43412   - at org.apache.catalina.core.StandardServer.startInternal(StandardServer.java:927)
43413   - at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
43414   - at org.apache.catalina.startup.Tomcat.start(Tomcat.java:486)
43415   - at org.springframework.boot.web.embedded.tomcat.TomcatWebServer.initialize(TomcatWebServer.java:123)
43416   - at org.springframework.boot.web.embedded.tomcat.TomcatWebServer.<init>(TomcatWebServer.java:104)
43417   - at org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory.getTomcatWebServer(TomcatServletWebServerFactory.java:450)
43418   - at org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory.getWebServer(TomcatServletWebServerFactory.java:199)
43419   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.createWebServer(ServletWebServerApplicationContext.java:182)
43420   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.onRefresh(ServletWebServerApplicationContext.java:160)
43421   - at org.springframework.context.support.AbstractApplicationContext.__refresh(AbstractApplicationContext.java:577)
43422   - at org.springframework.context.support.AbstractApplicationContext.jrLockAndRefresh(AbstractApplicationContext.java:41002)
43423   - at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:42008)
43424   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
43425   - at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
43426   - at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:434)
43427   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:338)
43428   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343)
43429   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1332)
43430   - at cn.fw.freya.FreyaApplication.main(FreyaApplication.java:36)
43431   -Caused by: org.h2.jdbc.JdbcSQLNonTransientException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43432   - at org.h2.message.DbException.getJdbcSQLException(DbException.java:505)
43433   - at org.h2.message.DbException.getJdbcSQLException(DbException.java:429)
43434   - ... 93 more
43435   -Caused by: java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]
43436   - at org.h2.mvstore.DataUtils.newIllegalStateException(DataUtils.java:950)
43437   - at org.h2.mvstore.FileStore.open(FileStore.java:172)
43438   - at org.h2.mvstore.MVStore.<init>(MVStore.java:381)
43439   - ... 87 more
43440   -2023-09-28 14:10:37 database: flush
43441   -org.h2.message.DbException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43442   - at org.h2.message.DbException.get(DbException.java:194)
43443   - at org.h2.message.DbException.convert(DbException.java:347)
43444   - at org.h2.mvstore.db.MVTableEngine$1.uncaughtException(MVTableEngine.java:93)
43445   - at org.h2.mvstore.MVStore.handleException(MVStore.java:2877)
43446   - at org.h2.mvstore.MVStore.panic(MVStore.java:481)
43447   - at org.h2.mvstore.MVStore.<init>(MVStore.java:402)
43448   - at org.h2.mvstore.MVStore$Builder.open(MVStore.java:3579)
43449   - at org.h2.mvstore.db.MVTableEngine$Store.open(MVTableEngine.java:170)
43450   - at org.h2.mvstore.db.MVTableEngine.init(MVTableEngine.java:103)
43451   - at org.h2.engine.Database.getPageStore(Database.java:2659)
43452   - at org.h2.engine.Database.open(Database.java:675)
43453   - at org.h2.engine.Database.openDatabase(Database.java:307)
43454   - at org.h2.engine.Database.<init>(Database.java:301)
43455   - at org.h2.engine.Engine.openSession(Engine.java:74)
43456   - at org.h2.engine.Engine.openSession(Engine.java:192)
43457   - at org.h2.engine.Engine.createSessionAndValidate(Engine.java:171)
43458   - at org.h2.engine.Engine.createSession(Engine.java:166)
43459   - at org.h2.engine.Engine.createSession(Engine.java:29)
43460   - at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:340)
43461   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:173)
43462   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:152)
43463   - at org.h2.Driver.connect(Driver.java:69)
43464   - at com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
43465   - at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:364)
43466   - at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:206)
43467   - at com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:476)
43468   - at com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:561)
43469   - at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
43470   - at com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
43471   - at org.hibernate.engine.jdbc.connections.internal.DatasourceConnectionProviderImpl.getConnection(DatasourceConnectionProviderImpl.java:122)
43472   - at org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator$ConnectionProviderJdbcConnectionAccess.obtainConnection(JdbcEnvironmentInitiator.java:180)
43473   - at org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator.initiateService(JdbcEnvironmentInitiator.java:68)
43474   - at org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator.initiateService(JdbcEnvironmentInitiator.java:35)
43475   - at org.hibernate.boot.registry.internal.StandardServiceRegistryImpl.initiateService(StandardServiceRegistryImpl.java:101)
43476   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.createService(AbstractServiceRegistryImpl.java:263)
43477   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.initializeService(AbstractServiceRegistryImpl.java:237)
43478   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.getService(AbstractServiceRegistryImpl.java:214)
43479   - at org.hibernate.id.factory.internal.DefaultIdentifierGeneratorFactory.injectServices(DefaultIdentifierGeneratorFactory.java:152)
43480   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.injectDependencies(AbstractServiceRegistryImpl.java:286)
43481   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.initializeService(AbstractServiceRegistryImpl.java:243)
43482   - at org.hibernate.service.internal.AbstractServiceRegistryImpl.getService(AbstractServiceRegistryImpl.java:214)
43483   - at org.hibernate.boot.internal.InFlightMetadataCollectorImpl.<init>(InFlightMetadataCollectorImpl.java:176)
43484   - at org.hibernate.boot.model.process.spi.MetadataBuildingProcess.complete(MetadataBuildingProcess.java:127)
43485   - at org.hibernate.jpa.boot.internal.EntityManagerFactoryBuilderImpl.metadata(EntityManagerFactoryBuilderImpl.java:1224)
43486   - at org.hibernate.jpa.boot.internal.EntityManagerFactoryBuilderImpl.__build(EntityManagerFactoryBuilderImpl.java:1255)
43487   - at org.hibernate.jpa.boot.internal.EntityManagerFactoryBuilderImpl.build(EntityManagerFactoryBuilderImpl.java:40002)
43488   - at org.springframework.orm.jpa.vendor.SpringHibernateJpaPersistenceProvider.__createEntityManagerFactory(SpringHibernateJpaPersistenceProvider.java:58)
43489   - at org.springframework.orm.jpa.vendor.SpringHibernateJpaPersistenceProvider.createContainerEntityManagerFactory(SpringHibernateJpaPersistenceProvider.java:40003)
43490   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.__createNativeEntityManagerFactory(LocalContainerEntityManagerFactoryBean.java:365)
43491   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.createNativeEntityManagerFactory(LocalContainerEntityManagerFactoryBean.java:45002)
43492   - at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.buildNativeEntityManagerFactory(AbstractEntityManagerFactoryBean.java:409)
43493   - at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.afterPropertiesSet(AbstractEntityManagerFactoryBean.java:396)
43494   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.afterPropertiesSet(LocalContainerEntityManagerFactoryBean.java:341)
43495   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1863)
43496   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1800)
43497   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:620)
43498   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
43499   - at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
43500   - at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
43501   - at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
43502   - at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
43503   - at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1154)
43504   - at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:908)
43505   - at org.springframework.context.support.AbstractApplicationContext.__refresh(AbstractApplicationContext.java:583)
43506   - at org.springframework.context.support.AbstractApplicationContext.jrLockAndRefresh(AbstractApplicationContext.java:41002)
43507   - at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:42008)
43508   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
43509   - at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
43510   - at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:434)
43511   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:338)
43512   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343)
43513   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1332)
43514   - at cn.fw.freya.FreyaApplication.main(FreyaApplication.java:36)
43515   -Caused by: org.h2.jdbc.JdbcSQLNonTransientException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43516   - at org.h2.message.DbException.getJdbcSQLException(DbException.java:505)
43517   - at org.h2.message.DbException.getJdbcSQLException(DbException.java:429)
43518   - ... 73 more
43519   -Caused by: java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]
43520   - at org.h2.mvstore.DataUtils.newIllegalStateException(DataUtils.java:950)
43521   - at org.h2.mvstore.FileStore.open(FileStore.java:172)
43522   - at org.h2.mvstore.MVStore.<init>(MVStore.java:381)
43523   - ... 67 more
43524   -2023-09-28 14:10:40 database: flush
43525   -org.h2.message.DbException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43526   - at org.h2.message.DbException.get(DbException.java:194)
43527   - at org.h2.message.DbException.convert(DbException.java:347)
43528   - at org.h2.mvstore.db.MVTableEngine$1.uncaughtException(MVTableEngine.java:93)
43529   - at org.h2.mvstore.MVStore.handleException(MVStore.java:2877)
43530   - at org.h2.mvstore.MVStore.panic(MVStore.java:481)
43531   - at org.h2.mvstore.MVStore.<init>(MVStore.java:402)
43532   - at org.h2.mvstore.MVStore$Builder.open(MVStore.java:3579)
43533   - at org.h2.mvstore.db.MVTableEngine$Store.open(MVTableEngine.java:170)
43534   - at org.h2.mvstore.db.MVTableEngine.init(MVTableEngine.java:103)
43535   - at org.h2.engine.Database.getPageStore(Database.java:2659)
43536   - at org.h2.engine.Database.open(Database.java:675)
43537   - at org.h2.engine.Database.openDatabase(Database.java:307)
43538   - at org.h2.engine.Database.<init>(Database.java:301)
43539   - at org.h2.engine.Engine.openSession(Engine.java:74)
43540   - at org.h2.engine.Engine.openSession(Engine.java:192)
43541   - at org.h2.engine.Engine.createSessionAndValidate(Engine.java:171)
43542   - at org.h2.engine.Engine.createSession(Engine.java:166)
43543   - at org.h2.engine.Engine.createSession(Engine.java:29)
43544   - at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:340)
43545   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:173)
43546   - at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:152)
43547   - at org.h2.Driver.connect(Driver.java:69)
43548   - at com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
43549   - at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:364)
43550   - at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:206)
43551   - at com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:476)
43552   - at com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:561)
43553   - at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
43554   - at com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
43555   - at org.hibernate.engine.jdbc.connections.internal.DatasourceConnectionProviderImpl.getConnection(DatasourceConnectionProviderImpl.java:122)
43556   - at org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator$ConnectionProviderJdbcConnectionAccess.obtainConnection(JdbcEnvironmentInitiator.java:180)
43557   - at org.hibernate.resource.transaction.backend.jdbc.internal.DdlTransactionIsolatorNonJtaImpl.getIsolatedConnection(DdlTransactionIsolatorNonJtaImpl.java:43)
43558   - at org.hibernate.tool.schema.internal.exec.ImprovedExtractionContextImpl.getJdbcConnection(ImprovedExtractionContextImpl.java:60)
43559   - at org.hibernate.tool.schema.extract.internal.SequenceInformationExtractorLegacyImpl.extractMetadata(SequenceInformationExtractorLegacyImpl.java:40)
43560   - at org.hibernate.tool.schema.extract.internal.DatabaseInformationImpl.initializeSequences(DatabaseInformationImpl.java:65)
43561   - at org.hibernate.tool.schema.extract.internal.DatabaseInformationImpl.<init>(DatabaseInformationImpl.java:59)
43562   - at org.hibernate.tool.schema.internal.Helper.buildDatabaseInformation(Helper.java:155)
43563   - at org.hibernate.tool.schema.internal.AbstractSchemaMigrator.doMigration(AbstractSchemaMigrator.java:96)
43564   - at org.hibernate.tool.schema.spi.SchemaManagementToolCoordinator.performDatabaseAction(SchemaManagementToolCoordinator.java:184)
43565   - at org.hibernate.tool.schema.spi.SchemaManagementToolCoordinator.process(SchemaManagementToolCoordinator.java:73)
43566   - at org.hibernate.internal.SessionFactoryImpl.<init>(SessionFactoryImpl.java:318)
43567   - at org.hibernate.boot.internal.SessionFactoryBuilderImpl.__build(SessionFactoryBuilderImpl.java:468)
43568   - at org.hibernate.boot.internal.SessionFactoryBuilderImpl.build(SessionFactoryBuilderImpl.java:41010)
43569   - at org.hibernate.jpa.boot.internal.EntityManagerFactoryBuilderImpl.__build(EntityManagerFactoryBuilderImpl.java:1259)
43570   - at org.hibernate.jpa.boot.internal.EntityManagerFactoryBuilderImpl.build(EntityManagerFactoryBuilderImpl.java:40002)
43571   - at org.springframework.orm.jpa.vendor.SpringHibernateJpaPersistenceProvider.__createEntityManagerFactory(SpringHibernateJpaPersistenceProvider.java:58)
43572   - at org.springframework.orm.jpa.vendor.SpringHibernateJpaPersistenceProvider.createContainerEntityManagerFactory(SpringHibernateJpaPersistenceProvider.java:40003)
43573   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.__createNativeEntityManagerFactory(LocalContainerEntityManagerFactoryBean.java:365)
43574   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.createNativeEntityManagerFactory(LocalContainerEntityManagerFactoryBean.java:45002)
43575   - at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.buildNativeEntityManagerFactory(AbstractEntityManagerFactoryBean.java:409)
43576   - at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.afterPropertiesSet(AbstractEntityManagerFactoryBean.java:396)
43577   - at org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean.afterPropertiesSet(LocalContainerEntityManagerFactoryBean.java:341)
43578   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1863)
43579   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1800)
43580   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:620)
43581   - at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
43582   - at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
43583   - at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
43584   - at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
43585   - at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
43586   - at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1154)
43587   - at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:908)
43588   - at org.springframework.context.support.AbstractApplicationContext.__refresh(AbstractApplicationContext.java:583)
43589   - at org.springframework.context.support.AbstractApplicationContext.jrLockAndRefresh(AbstractApplicationContext.java:41002)
43590   - at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:42008)
43591   - at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
43592   - at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
43593   - at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:434)
43594   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:338)
43595   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343)
43596   - at org.springframework.boot.SpringApplication.run(SpringApplication.java:1332)
43597   - at cn.fw.freya.FreyaApplication.main(FreyaApplication.java:36)
43598   -Caused by: org.h2.jdbc.JdbcSQLNonTransientException: General error: "java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]" [50000-200]
43599   - at org.h2.message.DbException.getJdbcSQLException(DbException.java:505)
  43315 +2023-10-05 12:31:20 jdbc[31]: exception
  43316 +org.h2.jdbc.JdbcSQLNonTransientConnectionException: Database is already closed (to disable automatic closing at VM shutdown, add ";DB_CLOSE_ON_EXIT=FALSE" to the db URL) [90121-200]
  43317 + at org.h2.message.DbException.getJdbcSQLException(DbException.java:622)
43600 43318 at org.h2.message.DbException.getJdbcSQLException(DbException.java:429)
43601   - ... 72 more
43602   -Caused by: java.lang.IllegalStateException: The file is locked: nio:D:/Users/wmy/feiweiProjects/fw-freya/db/freya.mv.db [1.4.200/7]
43603   - at org.h2.mvstore.DataUtils.newIllegalStateException(DataUtils.java:950)
43604   - at org.h2.mvstore.FileStore.open(FileStore.java:172)
43605   - at org.h2.mvstore.MVStore.<init>(MVStore.java:381)
43606   - ... 66 more
43607   -2023-09-28 14:42:35 jdbc[13]: exception
43608   -org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "DELETE *[*] FROM VIDEO_POOL WHERE ACCOUNT_NO = 'dyp92zsjjl1d'"; expected "identifier"; SQL statement:
43609   -delete * from VIDEO_POOL where ACCOUNT_NO = 'dyp92zsjjl1d' [42001-200]
43610   -2023-09-28 07:27:15 jdbc[3]: exception
43611   -java.sql.SQLClientInfoException: Client info name 'ApplicationName' not supported.
43612   - at org.h2.jdbc.JdbcConnection.setClientInfo(JdbcConnection.java:1749)
43613   - at com.intellij.database.remote.jdbc.impl.RemoteConnectionImpl.setClientInfo(RemoteConnectionImpl.java:466)
43614   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
43615   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  43319 + at org.h2.message.DbException.get(DbException.java:205)
  43320 + at org.h2.message.DbException.get(DbException.java:181)
  43321 + at org.h2.message.DbException.get(DbException.java:170)
  43322 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1514)
  43323 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1490)
  43324 + at org.h2.jdbc.JdbcConnection.prepareStatement(JdbcConnection.java:350)
  43325 + at com.zaxxer.hikari.pool.ProxyConnection.prepareStatement(ProxyConnection.java:337)
  43326 + at com.zaxxer.hikari.pool.HikariProxyConnection.prepareStatement(HikariProxyConnection.java)
  43327 + at org.apache.ibatis.executor.statement.PreparedStatementHandler.instantiateStatement(PreparedStatementHandler.java:86)
  43328 + at org.apache.ibatis.executor.statement.BaseStatementHandler.prepare(BaseStatementHandler.java:88)
  43329 + at org.apache.ibatis.executor.statement.RoutingStatementHandler.prepare(RoutingStatementHandler.java:59)
  43330 + at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:87)
  43331 + at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:62)
  43332 + at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:325)
  43333 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156)
  43334 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:136)
  43335 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:151)
  43336 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:145)
  43337 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140)
  43338 + at jdk.internal.reflect.GeneratedMethodAccessor109.invoke(Unknown Source)
43616 43339 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
43617 43340 at java.base/java.lang.reflect.Method.invoke(Method.java:566)
43618   - at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:359)
43619   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200)
43620   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197)
43621   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43622   - at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196)
43623   - at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562)
43624   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796)
43625   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677)
43626   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43627   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676)
43628   - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
43629   - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
43630   - at java.base/java.lang.Thread.run(Thread.java:834)
43631   -2023-09-28 07:30:14 jdbc[4]: exception
43632   -java.sql.SQLClientInfoException: Client info name 'ApplicationName' not supported.
43633   - at org.h2.jdbc.JdbcConnection.setClientInfo(JdbcConnection.java:1749)
43634   - at com.intellij.database.remote.jdbc.impl.RemoteConnectionImpl.setClientInfo(RemoteConnectionImpl.java:466)
43635   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
43636   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  43341 + at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427)
  43342 + at com.sun.proxy.$Proxy117.selectList(Unknown Source)
  43343 + at org.mybatis.spring.SqlSessionTemplate.selectList(SqlSessionTemplate.java:224)
  43344 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.executeForMany(MybatisMapperMethod.java:166)
  43345 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:77)
  43346 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148)
  43347 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43348 + at com.sun.proxy.$Proxy137.selectList(Unknown Source)
  43349 + at com.baomidou.mybatisplus.core.mapper.BaseMapper.selectOne(BaseMapper.java:172)
  43350 + at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:710)
  43351 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$DefaultMethodInvoker.invoke(MybatisMapperProxy.java:162)
  43352 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43353 + at com.sun.proxy.$Proxy137.selectOne(Unknown Source)
  43354 + at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.getOne(ServiceImpl.java:202)
  43355 + at com.baomidou.mybatisplus.extension.service.IService.getOne(IService.java:320)
  43356 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.checkDuplicate(NsSig3ServiceImpl.java:89)
  43357 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.setSig3Msg(NsSig3ServiceImpl.java:57)
  43358 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43359 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43360 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43361 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$EnhancerBySpringCGLIB$$1.setSig3Msg(<generated>)
  43362 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.handleResponseAndGetSig(CrawlNSSigMsgBizService.java:407)
  43363 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getKSSig(CrawlNSSigMsgBizService.java:352)
  43364 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getNS_sig3(CrawlNSSigMsgBizService.java:217)
  43365 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl.updateAccountMsg(KuaiShouCrawl.java:646)
  43366 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43367 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43368 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:783)
  43369 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
  43370 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43371 + at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
  43372 + at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
  43373 + at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
  43374 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
  43375 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43376 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:698)
  43377 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$EnhancerBySpringCGLIB$$2.updateAccountMsg(<generated>)
  43378 + at cn.fw.freya.service.CrawlBizService.crawlData(CrawlBizService.java:116)
  43379 + at cn.fw.freya.service.CrawlBizService$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43380 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43381 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43382 + at cn.fw.freya.service.CrawlBizService$$EnhancerBySpringCGLIB$$2.crawlData(<generated>)
  43383 + at cn.fw.freya.task.DataCaptureTask.lambda$capture$0(DataCaptureTask.java:67)
  43384 + at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
  43385 + at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
  43386 + at java.base/java.lang.Thread.run(Thread.java:829)
  43387 +2023-10-05 12:31:20 jdbc[27]: exception
  43388 +org.h2.jdbc.JdbcSQLNonTransientConnectionException: Database is already closed (to disable automatic closing at VM shutdown, add ";DB_CLOSE_ON_EXIT=FALSE" to the db URL) [90121-200]
  43389 + at org.h2.message.DbException.getJdbcSQLException(DbException.java:622)
  43390 + at org.h2.message.DbException.getJdbcSQLException(DbException.java:429)
  43391 + at org.h2.message.DbException.get(DbException.java:205)
  43392 + at org.h2.message.DbException.get(DbException.java:181)
  43393 + at org.h2.message.DbException.get(DbException.java:170)
  43394 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1514)
  43395 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1490)
  43396 + at org.h2.jdbc.JdbcConnection.prepareStatement(JdbcConnection.java:350)
  43397 + at com.zaxxer.hikari.pool.ProxyConnection.prepareStatement(ProxyConnection.java:337)
  43398 + at com.zaxxer.hikari.pool.HikariProxyConnection.prepareStatement(HikariProxyConnection.java)
  43399 + at org.apache.ibatis.executor.statement.PreparedStatementHandler.instantiateStatement(PreparedStatementHandler.java:86)
  43400 + at org.apache.ibatis.executor.statement.BaseStatementHandler.prepare(BaseStatementHandler.java:88)
  43401 + at org.apache.ibatis.executor.statement.RoutingStatementHandler.prepare(RoutingStatementHandler.java:59)
  43402 + at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:87)
  43403 + at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:62)
  43404 + at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:325)
  43405 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156)
  43406 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:136)
  43407 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:151)
  43408 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:145)
  43409 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140)
  43410 + at jdk.internal.reflect.GeneratedMethodAccessor109.invoke(Unknown Source)
43637 43411 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
43638 43412 at java.base/java.lang.reflect.Method.invoke(Method.java:566)
43639   - at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:359)
43640   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200)
43641   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197)
43642   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43643   - at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196)
43644   - at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562)
43645   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796)
43646   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677)
43647   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43648   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676)
43649   - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
43650   - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
43651   - at java.base/java.lang.Thread.run(Thread.java:834)
43652   -2023-09-28 07:33:13 jdbc[5]: exception
43653   -java.sql.SQLClientInfoException: Client info name 'ApplicationName' not supported.
43654   - at org.h2.jdbc.JdbcConnection.setClientInfo(JdbcConnection.java:1749)
43655   - at com.intellij.database.remote.jdbc.impl.RemoteConnectionImpl.setClientInfo(RemoteConnectionImpl.java:466)
43656   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
43657   - at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  43413 + at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427)
  43414 + at com.sun.proxy.$Proxy117.selectList(Unknown Source)
  43415 + at org.mybatis.spring.SqlSessionTemplate.selectList(SqlSessionTemplate.java:224)
  43416 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.executeForMany(MybatisMapperMethod.java:166)
  43417 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:77)
  43418 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148)
  43419 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43420 + at com.sun.proxy.$Proxy137.selectList(Unknown Source)
  43421 + at com.baomidou.mybatisplus.core.mapper.BaseMapper.selectOne(BaseMapper.java:172)
  43422 + at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:710)
  43423 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$DefaultMethodInvoker.invoke(MybatisMapperProxy.java:162)
  43424 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43425 + at com.sun.proxy.$Proxy137.selectOne(Unknown Source)
  43426 + at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.getOne(ServiceImpl.java:202)
  43427 + at com.baomidou.mybatisplus.extension.service.IService.getOne(IService.java:320)
  43428 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.checkDuplicate(NsSig3ServiceImpl.java:89)
  43429 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.setSig3Msg(NsSig3ServiceImpl.java:57)
  43430 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43431 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43432 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43433 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$EnhancerBySpringCGLIB$$1.setSig3Msg(<generated>)
  43434 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.handleResponseAndGetSig(CrawlNSSigMsgBizService.java:407)
  43435 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getKSSig(CrawlNSSigMsgBizService.java:352)
  43436 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getNS_sig3(CrawlNSSigMsgBizService.java:217)
  43437 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl.updateAccountMsg(KuaiShouCrawl.java:646)
  43438 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43439 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43440 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:783)
  43441 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
  43442 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43443 + at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
  43444 + at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
  43445 + at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
  43446 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
  43447 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43448 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:698)
  43449 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$EnhancerBySpringCGLIB$$2.updateAccountMsg(<generated>)
  43450 + at cn.fw.freya.service.CrawlBizService.crawlData(CrawlBizService.java:116)
  43451 + at cn.fw.freya.service.CrawlBizService$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43452 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43453 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43454 + at cn.fw.freya.service.CrawlBizService$$EnhancerBySpringCGLIB$$2.crawlData(<generated>)
  43455 + at cn.fw.freya.task.DataCaptureTask.lambda$capture$0(DataCaptureTask.java:67)
  43456 + at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
  43457 + at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
  43458 + at java.base/java.lang.Thread.run(Thread.java:829)
  43459 +2023-10-05 12:31:20 jdbc[25]: exception
  43460 +org.h2.jdbc.JdbcSQLNonTransientConnectionException: Database is already closed (to disable automatic closing at VM shutdown, add ";DB_CLOSE_ON_EXIT=FALSE" to the db URL) [90121-200]
  43461 + at org.h2.message.DbException.getJdbcSQLException(DbException.java:622)
  43462 + at org.h2.message.DbException.getJdbcSQLException(DbException.java:429)
  43463 + at org.h2.message.DbException.get(DbException.java:205)
  43464 + at org.h2.message.DbException.get(DbException.java:181)
  43465 + at org.h2.message.DbException.get(DbException.java:170)
  43466 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1514)
  43467 + at org.h2.jdbc.JdbcConnection.checkClosed(JdbcConnection.java:1490)
  43468 + at org.h2.jdbc.JdbcConnection.prepareStatement(JdbcConnection.java:350)
  43469 + at com.zaxxer.hikari.pool.ProxyConnection.prepareStatement(ProxyConnection.java:337)
  43470 + at com.zaxxer.hikari.pool.HikariProxyConnection.prepareStatement(HikariProxyConnection.java)
  43471 + at org.apache.ibatis.executor.statement.PreparedStatementHandler.instantiateStatement(PreparedStatementHandler.java:86)
  43472 + at org.apache.ibatis.executor.statement.BaseStatementHandler.prepare(BaseStatementHandler.java:88)
  43473 + at org.apache.ibatis.executor.statement.RoutingStatementHandler.prepare(RoutingStatementHandler.java:59)
  43474 + at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:87)
  43475 + at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:62)
  43476 + at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:325)
  43477 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156)
  43478 + at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:136)
  43479 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:151)
  43480 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:145)
  43481 + at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140)
  43482 + at jdk.internal.reflect.GeneratedMethodAccessor109.invoke(Unknown Source)
43658 43483 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
43659 43484 at java.base/java.lang.reflect.Method.invoke(Method.java:566)
43660   - at java.rmi/sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:359)
43661   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:200)
43662   - at java.rmi/sun.rmi.transport.Transport$1.run(Transport.java:197)
43663   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43664   - at java.rmi/sun.rmi.transport.Transport.serviceCall(Transport.java:196)
43665   - at java.rmi/sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:562)
43666   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:796)
43667   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:677)
43668   - at java.base/java.security.AccessController.doPrivileged(Native Method)
43669   - at java.rmi/sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:676)
43670   - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
43671   - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
43672   - at java.base/java.lang.Thread.run(Thread.java:834)
  43485 + at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427)
  43486 + at com.sun.proxy.$Proxy117.selectList(Unknown Source)
  43487 + at org.mybatis.spring.SqlSessionTemplate.selectList(SqlSessionTemplate.java:224)
  43488 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.executeForMany(MybatisMapperMethod.java:166)
  43489 + at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:77)
  43490 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148)
  43491 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43492 + at com.sun.proxy.$Proxy137.selectList(Unknown Source)
  43493 + at com.baomidou.mybatisplus.core.mapper.BaseMapper.selectOne(BaseMapper.java:172)
  43494 + at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:710)
  43495 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$DefaultMethodInvoker.invoke(MybatisMapperProxy.java:162)
  43496 + at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
  43497 + at com.sun.proxy.$Proxy137.selectOne(Unknown Source)
  43498 + at com.baomidou.mybatisplus.extension.service.impl.ServiceImpl.getOne(ServiceImpl.java:202)
  43499 + at com.baomidou.mybatisplus.extension.service.IService.getOne(IService.java:320)
  43500 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.checkDuplicate(NsSig3ServiceImpl.java:89)
  43501 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl.setSig3Msg(NsSig3ServiceImpl.java:57)
  43502 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43503 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43504 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43505 + at cn.fw.freya.service.data.impl.NsSig3ServiceImpl$$EnhancerBySpringCGLIB$$1.setSig3Msg(<generated>)
  43506 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.handleResponseAndGetSig(CrawlNSSigMsgBizService.java:407)
  43507 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getKSSig(CrawlNSSigMsgBizService.java:352)
  43508 + at cn.fw.freya.service.crawl.CrawlNSSigMsgBizService.getNS_sig3(CrawlNSSigMsgBizService.java:217)
  43509 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl.updateAccountMsg(KuaiShouCrawl.java:646)
  43510 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43511 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43512 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:783)
  43513 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
  43514 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43515 + at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
  43516 + at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
  43517 + at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
  43518 + at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
  43519 + at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
  43520 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:698)
  43521 + at cn.fw.freya.service.crawl.impl.KuaiShouCrawl$$EnhancerBySpringCGLIB$$2.updateAccountMsg(<generated>)
  43522 + at cn.fw.freya.service.CrawlBizService.crawlData(CrawlBizService.java:116)
  43523 + at cn.fw.freya.service.CrawlBizService$$FastClassBySpringCGLIB$$1.invoke(<generated>)
  43524 + at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
  43525 + at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
  43526 + at cn.fw.freya.service.CrawlBizService$$EnhancerBySpringCGLIB$$2.crawlData(<generated>)
  43527 + at cn.fw.freya.task.DataCaptureTask.lambda$capture$0(DataCaptureTask.java:67)
  43528 + at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
  43529 + at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
  43530 + at java.base/java.lang.Thread.run(Thread.java:829)
... ...
src/main/java/cn/fw/freya/service/crawl/impl/BilibiliCrawl.java
  View file @8e95966
... ... @@ -133,11 +133,12 @@ public class BilibiliCrawl implements CrawlStrategy {
133 133 @Override
134 134 @Transactional
135 135 public List<VideoPool> getAllVideoMsg(String accountNo) throws IOException {
136   - List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(new Date()));
  136 + Date now = new Date();
  137 + List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(now));
137 138 if (Objects.nonNull(hasFoundVideo)) {
138 139 return hasFoundVideo;
139 140 }
140   - Date previousDay = DateUtil.getPreviousDay(new Date());
  141 + Date previousDay = DateUtil.minusDays(now, 1);
141 142 Integer currentPage = 0;
142 143 Integer pageSize = 20;
143 144 Integer total;
... ... @@ -192,7 +193,7 @@ public class BilibiliCrawl implements CrawlStrategy {
192 193 .likeCount(Optional.ofNullable(stat.getInteger("like")).orElse(0))// 点赞数
193 194 .commentCount(Optional.ofNullable(stat.getInteger("reply")).orElse(0))// 评论数
194 195 .accountNo(accountNo)
195   - .reportDate(new Date())
  196 + .reportDate(now)
196 197 .publishTime(new Date(Archive.getLong("ctime") * 1000))// 发布时间
197 198 .videoUrl("https://www.bilibili.com/video/" + videoId)// 视频播放地址
198 199 .type(this.getType().getValue())
... ... @@ -206,7 +207,7 @@ public class BilibiliCrawl implements CrawlStrategy {
206 207 });
207 208 try {
208 209 if (!videoPoolList.isEmpty()) {
209   - Date endTime = DateUtil.getThisDayMaxTime(previousDay);
  210 + Date endTime = DateUtil.dayEnd(now);
210 211 videoPoolDao.saveAll(videoPoolList.stream()
211 212 .filter(r -> r.getPublishTime().compareTo(endTime) <= 0)
212 213 .collect(Collectors.toList()));// 将收集到的视频信息保存
... ... @@ -215,7 +216,7 @@ public class BilibiliCrawl implements CrawlStrategy {
215 216 .accountNo(accountNo)
216 217 .type(this.getType().getValue())
217 218 .resourceType(ResourceTypeEnum.VIDEO.getValue())
218   - .reportDate(new Date())
  219 + .reportDate(now)
219 220 .build();
220 221 videoPoolDao.save(nullVideo);
221 222 ArrayList<VideoPool> nullList = new ArrayList<>();
... ...
src/main/java/cn/fw/freya/service/crawl/impl/DongCheDiCrawl.java
  View file @8e95966
... ... @@ -173,11 +173,12 @@ public class DongCheDiCrawl implements CrawlStrategy {
173 173 @Override
174 174 @Transactional
175 175 public List<VideoPool> getAllVideoMsg(String accountNo) {
176   - List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(new Date()));
  176 + Date now = new Date();
  177 + List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(now));
177 178 if (Objects.nonNull(hasFoundVideo)) {
178 179 return hasFoundVideo;
179 180 }
180   - Date previousDay = DateUtil.getPreviousDay(new Date());
  181 + Date previousDay = DateUtil.minusDays(now, 1);
181 182 JSONObject response = this.getJRTTResource(accountNo, 2);
182 183 assert response != null;
183 184 JSONArray videoJsonArray = Optional.ofNullable(response.getJSONArray("item_datas")).orElse(new JSONArray());// 获取[视频]数据数组
... ... @@ -218,7 +219,7 @@ public class DongCheDiCrawl implements CrawlStrategy {
218 219 .likeCount(Optional.ofNullable(DCSObj.getInteger("digg_count")).orElse(0))// 点赞数
219 220 .commentCount(Optional.ofNullable(DCSObj.getInteger("comment_count")).orElse(0))// 评论数
220 221 .accountNo(accountNo)
221   - .reportDate(new Date())
  222 + .reportDate(now)
222 223 .publishTime(new Date(obj.getLong("create_time") * 1000L))// 发布时间
223 224 .videoUrl("https://www.ixigua.com/" + videoId)// 播放地址
224 225 .type(this.getType().getValue())
... ... @@ -231,7 +232,7 @@ public class DongCheDiCrawl implements CrawlStrategy {
231 232 });
232 233 try {
233 234 if (!videoPoolList.isEmpty()) {
234   - Date endTime = DateUtil.getThisDayMaxTime(previousDay);
  235 + Date endTime = DateUtil.dayEnd(now);
235 236 videoPoolDao.saveAll(videoPoolList.stream()
236 237 .filter(r -> r.getPublishTime().compareTo(endTime) <= 0)
237 238 .collect(Collectors.toList()));// 将收集到的视频信息保存
... ... @@ -240,7 +241,7 @@ public class DongCheDiCrawl implements CrawlStrategy {
240 241 .accountNo(accountNo)
241 242 .type(this.getType().getValue())
242 243 .resourceType(ResourceTypeEnum.VIDEO.getValue())
243   - .reportDate(new Date())
  244 + .reportDate(now)
244 245 .build();
245 246 videoPoolDao.save(nullVideo);
246 247 ArrayList<VideoPool> nullList = new ArrayList<>();
... ...
src/main/java/cn/fw/freya/service/crawl/impl/DouYinCrawl.java
  View file @8e95966
... ... @@ -156,11 +156,12 @@ public class DouYinCrawl implements CrawlStrategy {
156 156 @Override
157 157 @Transactional
158 158 public List<VideoPool> getAllVideoMsg(String accountNo) {
159   - List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(new Date()));
  159 + Date now = new Date();
  160 + List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(now));
160 161 if (Objects.nonNull(hasFoundVideo)) {
161 162 return hasFoundVideo;
162 163 }
163   - Date previousDay = DateUtil.getPreviousDay(new Date());
  164 + Date previousDay = DateUtil.minusDays(now, 1);
164 165 JSONObject obj = this.getVideoDataOriginal(accountNo);
165 166 if (Objects.isNull(obj))
166 167 return null;
... ... @@ -221,12 +222,12 @@ public class DouYinCrawl implements CrawlStrategy {
221 222 .likeCount(Optional.ofNullable(statistics.getInteger("digg_count")).orElse(0))
222 223 .accountNo(accountNo)
223 224 .playCount(Optional.ofNullable(statistics.getInteger("play_count")).orElse(0))
224   - .reportDate(new Date())
  225 + .reportDate(now)
225 226 .resourceType(jsonObj.getBoolean("is_live_replay") ? 2 : 1)
226 227 .shareCount(Optional.ofNullable(statistics.getInteger("share_count")).orElse(0))
227 228 .title(Optional.ofNullable(jsonObj.getString("desc")).orElse(""))
228 229 .type(this.getType().getValue())
229   - .publishTime(new Date(Optional.ofNullable(jsonObj.getLong("create_time")).orElse(new Date().getTime()) * 1000))
  230 + .publishTime(new Date(Optional.ofNullable(jsonObj.getLong("create_time")).orElse(now.getTime()) * 1000))
230 231 .newFansUserCnt(Optional.ofNullable(summarizeData.getInteger("new_fans_count")).orElse(0))
231 232 .videoUrl(playUrl)
232 233 .videoId(videoId)
... ... @@ -241,7 +242,7 @@ public class DouYinCrawl implements CrawlStrategy {
241 242 .accountNo(accountNo)
242 243 .type(this.getType().getValue())
243 244 .resourceType(ResourceTypeEnum.VIDEO.getValue())
244   - .reportDate(new Date())
  245 + .reportDate(now)
245 246 .build()
246 247 );
247 248 log.info(LocalDate.now() + " 总共获取到" + videoPoolList.size() + "条抖音视频信息");
... ...
src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java
  View file @8e95966
... ... @@ -333,11 +333,12 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
333 333 @Override
334 334 @Transactional
335 335 public List<VideoPool> getAllVideoMsg(String accountNo) throws IOException {
336   - List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(new Date()));
  336 + Date now = new Date();
  337 + List<VideoPool> hasFoundVideo = common.getHasFoundVideo(accountNo, this.getType().getValue(), DateUtil.dayBegin(now));
337 338 if (Objects.nonNull(hasFoundVideo)) {
338 339 return hasFoundVideo;
339 340 }
340   - Date previousDay = DateUtil.getPreviousDay(new Date());
  341 + Date previousDay = DateUtil.minusDays(now, 1);
341 342 int page = 1;
342 343 Integer total;
343 344 JSONArray videoJsonArray = new JSONArray();
... ... @@ -392,7 +393,7 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
392 393 .likeCount(Optional.ofNullable(obj.getInteger("likeCount")).orElse(0))//
393 394 .commentCount(Optional.ofNullable(obj.getInteger("commentCount")).orElse(0))//
394 395 .accountNo(accountNo)
395   - .reportDate(new Date())
  396 + .reportDate(now)
396 397 .publishTime(PublicUtil.parseDate(obj.getString("publishTime")))//
397 398 .videoUrl("https://www.kuaishou.com/short-video/" + obj.getString("workId"))
398 399 .type(this.getType().getValue())
... ... @@ -407,7 +408,7 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
407 408 });
408 409 try {
409 410 if (!videoPoolList.isEmpty()) {
410   - Date endTime = DateUtil.getThisDayMaxTime(previousDay);
  411 + Date endTime = DateUtil.dayEnd(now);
411 412 videoPoolDao.saveAll(videoPoolList.stream()
412 413 .filter(r -> r.getPublishTime().compareTo(endTime) <= 0)
413 414 .collect(Collectors.toList()));// 将收集到的视频信息保存
... ... @@ -416,7 +417,7 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
416 417 .accountNo(accountNo)
417 418 .type(this.getType().getValue())
418 419 .resourceType(ResourceTypeEnum.VIDEO.getValue())
419   - .reportDate(new Date())
  420 + .reportDate(now)
420 421 .build();
421 422 videoPoolDao.save(nullVideo);
422 423 ArrayList<VideoPool> nullList = new ArrayList<>();
... ...