Procházet zdrojové kódy

修改定时任务

java110 před 6 roky
rodič
revize
02b0ade46c

+ 27 - 1
service-api/src/main/java/com/java110/api/bmo/task/impl/TaskBMOImpl.java

@@ -74,10 +74,36 @@ public class TaskBMOImpl extends ApiBaseBMO implements ITaskBMO {
 
         Assert.listOnlyOne(taskDtos, "未找到需要修改的活动 或多条数据");
 
-
         paramInJson.putAll(BeanConvertUtil.beanCovertMap(taskDtos.get(0)));
         TaskPo taskPo = BeanConvertUtil.covertBean(paramInJson, TaskPo.class);
         super.update(dataFlowContext, taskPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK);
+
+        if (!paramInJson.containsKey("templateSpecs")) {
+            return;
+        }
+
+        JSONArray templateSpecs = paramInJson.getJSONArray("templateSpecs");
+        JSONObject specObj = null;
+        TaskAttrPo taskAttrPo = null;
+        for (int specIndex = 0; specIndex < templateSpecs.size(); specIndex++) {
+            specObj = templateSpecs.getJSONObject(specIndex);
+            if (specObj.containsKey("attrId") && !"-1".equals(specObj.getString("attrId"))) {
+                taskAttrPo = new TaskAttrPo();
+                taskAttrPo.setAttrId(specObj.getString("attrId"));
+                taskAttrPo.setTaskId(taskPo.getTaskId());
+                taskAttrPo.setValue(specObj.getString("value"));
+                taskAttrPo.setSpecCd(specObj.getString("specCd"));
+                super.update(dataFlowContext, taskAttrPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK_ATTR);
+
+                continue;
+            }
+            taskAttrPo = new TaskAttrPo();
+            taskAttrPo.setAttrId("-" + (specIndex + 1));
+            taskAttrPo.setTaskId(taskPo.getTaskId());
+            taskAttrPo.setValue(specObj.getString("value"));
+            taskAttrPo.setSpecCd(specObj.getString("specCd"));
+            super.insert(dataFlowContext, taskAttrPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_TASK_ATTR);
+        }
     }
 
 

+ 6 - 6
service-job/src/main/resources/dataSource.yml

@@ -1,9 +1,9 @@
 dataSources:
   ds0: !!com.alibaba.druid.pool.DruidDataSource
     driverClassName: com.mysql.jdbc.Driver
-    url: jdbc:mysql://139.199.97.195:3306/hc_community?useUnicode=true&characterEncoding=utf-8
-    username: demowinqi
-    password: bCYXJpfSyHKhKxye
+    url: jdbc:mysql://xx:3306/hc_community?useUnicode=true&characterEncoding=utf-8
+    username: xx
+    password: xx
     minIdle: 5
     validationQuery: SELECT 1 FROM DUAL
     initialSize: 5
@@ -22,9 +22,9 @@ dataSources:
 #    maintenanceIntervalMilliseconds: 30000
   ds1: !!com.alibaba.druid.pool.DruidDataSource
     driverClassName: com.mysql.jdbc.Driver
-    url: jdbc:mysql://139.199.97.195:3306/TT?useUnicode=true&characterEncoding=utf-8
-    username: demowinqi
-    password: bCYXJpfSyHKhKxye
+    url: jdbc:mysql://xx:3306/TT?useUnicode=true&characterEncoding=utf-8
+    username: xx
+    password: xx
     minIdle: 5
     validationQuery: SELECT 1 FROM DUAL
     initialSize: 5