Kaynağa Gözat

后台任务修改

9060 9 ay önce
ebeveyn
işleme
9d489ccfea

+ 8 - 4
src/com/kingdee/eas/custom/shuiyou/task/TaskExecuteFacadeControllerBean.java

@@ -54,7 +54,10 @@ public class TaskExecuteFacadeControllerBean extends AbstractTaskExecuteFacadeCo
                 sc.add(new SelectorItemInfo("url"));
                 sc.add(new SelectorItemInfo("requestId"));
                 sc.add(new SelectorItemInfo("requestType"));
-                sc.add(new SelectorItemInfo("param"));
+                sc.add(new SelectorItemInfo("requestParam.id"));
+                sc.add(new SelectorItemInfo("requestParam.paramContent"));
+                sc.add(new SelectorItemInfo("requestResult.id"));
+                sc.add(new SelectorItemInfo("requestResult.resultContent"));
                 sc.add(new SelectorItemInfo("requestState"));
                 sc.add(new SelectorItemInfo("name"));
                 sc.add(new SelectorItemInfo("osfServiceName"));
@@ -68,11 +71,12 @@ public class TaskExecuteFacadeControllerBean extends AbstractTaskExecuteFacadeCo
                 TaskCollection taskCollection = iTask.getTaskCollection(viewInfo);
                 //¸üÐÂ״̬Ϊ½øÐÐÖÐ
                 size = taskCollection.size();
+                SelectorItemCollection scUp = new SelectorItemCollection();
+                scUp.add(new SelectorItemInfo("requestState"));
+                scUp.add(new SelectorItemInfo("state"));
                 for(int i=0;i<size;i++) {
                     TaskInfo taskInfo = taskCollection.get(i);
-                    SelectorItemCollection scUp = new SelectorItemCollection();
-                    scUp.add(new SelectorItemInfo("requestState"));
-                    scUp.add(new SelectorItemInfo("state"));
+
                     taskInfo.setRequestState(RequestStateEnum.Ongoing);
                     taskInfo.setState(TaskStateEnum.RUNNING);
                     iTask.updatePartial(taskInfo,scUp);

+ 31 - 18
src/com/kingdee/eas/custom/shuiyou/uitls/SYUtilsFacadeControllerBean.java

@@ -1,10 +1,9 @@
 package com.kingdee.eas.custom.shuiyou.uitls;
 
-import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
-import com.google.common.collect.Maps;
+
 import com.kingdee.bos.dao.IObjectPK;
 import com.kingdee.bos.util.BOSUuid;
 import com.kingdee.eas.base.permission.UserInfo;
@@ -18,25 +17,13 @@ import org.apache.log4j.Logger;
 
 import javax.crypto.Mac;
 import javax.crypto.spec.SecretKeySpec;
-import javax.ejb.*;
-import java.io.FileInputStream;
+
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
-import java.rmi.RemoteException;
+
 import com.kingdee.bos.*;
-import com.kingdee.bos.util.BOSObjectType;
-import com.kingdee.bos.metadata.IMetaDataPK;
-import com.kingdee.bos.metadata.rule.RuleExecutor;
-import com.kingdee.bos.metadata.MetaDataPK;
-//import com.kingdee.bos.metadata.entity.EntityViewInfo;
-import com.kingdee.bos.framework.ejb.AbstractEntityControllerBean;
-import com.kingdee.bos.framework.ejb.AbstractBizControllerBean;
-//import com.kingdee.bos.dao.IObjectPK;
-import com.kingdee.bos.dao.IObjectValue;
-import com.kingdee.bos.dao.IObjectCollection;
-import com.kingdee.bos.service.ServiceContext;
-import com.kingdee.bos.service.IServiceContext;
+
 
 import java.security.InvalidKeyException;
 import java.security.NoSuchAlgorithmException;
@@ -48,6 +35,17 @@ import java.lang.String;
 
 public class SYUtilsFacadeControllerBean extends AbstractSYUtilsFacadeControllerBean
 {
+    /**
+     * 添加任务
+     * @param ctx
+     * @param url 请求地址
+     * @param requestId 请求id
+     * @param osfServiceName 回调osf服务名
+     * @param backParam 回调参数
+     * @param catalog 任务类型
+     * @return
+     * @throws BOSException
+     */
     @Override
     protected String _backTask(Context ctx, String url, String requestId, String osfServiceName, String backParam,TaskCatalogEnum catalog) throws BOSException {
         super._backTask(ctx, url, requestId, osfServiceName, backParam,catalog);
@@ -83,7 +81,14 @@ public class SYUtilsFacadeControllerBean extends AbstractSYUtilsFacadeController
         }
         return taskInfo.getId().toString();
     }
-
+    /**
+     * 发起post请求
+     * @param ctx
+     * @param url
+     * @param param
+     * @return
+     * @throws BOSException
+     */
     @Override
     protected String _post(Context ctx, String url, String param) throws BOSException {
         super._post(ctx, url, param);
@@ -146,6 +151,14 @@ public class SYUtilsFacadeControllerBean extends AbstractSYUtilsFacadeController
         return result;
     }
 
+    /**
+     * 发起get请求
+     * @param ctx
+     * @param url
+     * @param param
+     * @return
+     * @throws BOSException
+     */
     @Override
     protected String _get(Context ctx, String url, String param) throws BOSException {
         super._get(ctx, url, param);