From 1b6e655f65ed53a1a718c30552eefd3f5097907e Mon Sep 17 00:00:00 2001
From: riecard <hanshaofeng@lymsh.com>
Date: Mon, 26 Sep 2016 20:54:14 +0800
Subject: [PATCH] add sync data task

---
 .../operate/web/service/SyncDataTaskService.java   | 37 ++++++++++++++++++++++
 .../main/resources/spring/applicationContext.xml   | 16 ++++++++--
 2 files changed, 51 insertions(+), 2 deletions(-)
 create mode 100644 platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java

diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java
new file mode 100644
index 0000000..ed50e26
--- /dev/null
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java
@@ -0,0 +1,37 @@
+package com.lyms.platform.operate.web.service;
+
+import com.lyms.platform.biz.service.SyncDataService;
+import com.lyms.platform.common.pojo.SyncDataModel;
+import com.lyms.platform.common.utils.MongoSyncUtil;
+import com.lyms.platform.query.SyncDataQuery;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Created by riecard on 16/9/26.
+ */
+@Service("syncDataTaskService")
+public class SyncDataTaskService {
+
+    @Autowired
+    private SyncDataService syncDataService;
+
+    public void syncData() {
+        SyncDataQuery query = new SyncDataQuery();
+        query.setStatus(1);
+        query.setLimit(1000);
+        query.setNeed("0");
+        List<SyncDataModel> list = syncDataService.querySyncData(query);
+        for (SyncDataModel model:list) {
+            if (MongoSyncUtil.sync(model.getAction(),model.getJsonData(),model.getDataId())) {
+                model.setStatus(0);
+                model.setModified(new Date());
+                syncDataService.updateSyncData(model);
+            }
+        }
+    }
+
+}
diff --git a/platform-operate-api/src/main/resources/spring/applicationContext.xml b/platform-operate-api/src/main/resources/spring/applicationContext.xml
index 5ae7718..24099c1 100644
--- a/platform-operate-api/src/main/resources/spring/applicationContext.xml
+++ b/platform-operate-api/src/main/resources/spring/applicationContext.xml
@@ -1,9 +1,15 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:context="http://www.springframework.org/schema/context"
+       xmlns:p="http://www.springframework.org/schema/p"
+       xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:cache="http://www.springframework.org/schema/cache"
+       xmlns:task="http://www.springframework.org/schema/task" xmlns:aop="http://www.springframework.org/schema/aop"
        xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd
-                           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
+                           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
+                           http://www.springframework.org/schema/tx      http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
+                           http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd
+                           http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
 
     <!-- 采用注释的方式配置bean -->
     <context:annotation-config/>
@@ -14,6 +20,7 @@
     <!-- 配置要扫描的包 -->
     <context:component-scan base-package="com.lyms.platform.biz.dal.impl"/>
     <context:component-scan base-package="com.lyms.platform.operate.web.facade"/>
+    <context:component-scan base-package="com.lyms.platform.operate.web.service"/>
     <context:component-scan base-package="com.lyms.platform.permission.*"/>
     <context:component-scan base-package="com.lymsh.platform.reportdata.model.*" />
     <context:component-scan base-package="com.lymsh.platform.reportdata.dao" />
@@ -28,6 +35,11 @@
     <!--医院单机版的时候需要打开
     <import resource="classpath:/spring/applicationContext-slave.xml"/>-->
 
+    <task:annotation-driven/>
+
+    <task:scheduled-tasks>
+        <task:scheduled ref="syncDataTaskService" method="syncData" cron="0 0/10 * * * ?"/>
+    </task:scheduled-tasks>
 
     <bean id="sessionProvider" class="com.lyms.platform.operate.web.session.SessionProvider">
         <property name="iSessionProviderMap">
-- 
1.8.3.1