调度计划生成dat文件修改

src/main/java/sys/sc/task/CreatDatDailyTask.java

@@ -42,85 +42,87 @@ public class CreatDatDailyTask extends AbstractTask {
 
     @Override
     public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
+        //获取调度参数
+        String frequency= (String) map.get("frequency");
         //取已审核的数据
         QFilter filter=new QFilter("status", QCP.equals,"C");
         //数据表基础资料
         DynamicObject[] tableDy=BusinessDataServiceHelper
                 .load(nckd_tablebasic,"id,nckd_tableentry,nckd_isable,nckd_entrycode,nckd_dooperation,number,nckd_biazppnum,creatdat",new QFilter[]{filter});
         log.info("----------------------读取数据表基础资料-------------------");
-        for (DynamicObject item:tableDy)
+        for (DynamicObject item:tableDy) {
-        {
+            //参数执行频率等于表的执行频率则生成文件
-            log.info("-------------------------获取服务器连接-----------------");
+            if (frequency.equals(item.getString("nckd_dooperation"))) {
-            List<String> fileList=new ArrayList<>();
+                log.info("-------------------------获取服务器连接-----------------");
-            //获取表字段当前分录
+                List<String> fileList=new ArrayList<>();
-            DynamicObjectCollection dynamicObjectCollection=item.getDynamicObjectCollection("nckd_tableentry");
+                //获取表字段当前分录
-            for (DynamicObject itemmen:dynamicObjectCollection) {
+                DynamicObjectCollection dynamicObjectCollection=item.getDynamicObjectCollection("nckd_tableentry");
-                //将打勾的字段导出
+                for (DynamicObject itemmen:dynamicObjectCollection) {
-                if (itemmen.getBoolean("nckd_isable")) {
+                    //将打勾的字段导出
-                    //需要导入的标识写入list中
+                    if (itemmen.getBoolean("nckd_isable")) {
-                    fileList.add(itemmen.getString("nckd_entrycode"));
+                        //需要导入的标识写入list中
+                        fileList.add(itemmen.getString("nckd_entrycode"));
+                    }
                 }
-            }
+                //获取当前选择的表名
-            //任务执行频率
+                String tablenumber=item.getString("number");
-            String nckd_dooperation=item.getString("nckd_dooperation");
+                //业务编码
-            //获取当前选择的表名
+                String bizappnum=item.getString("nckd_biazppnum");
-            String tablenumber=item.getString("number");
+                //接口配置信息获取
-            //业务编码
+                //读取接口配置信息获取
-            String bizappnum=item.getString("nckd_biazppnum");
+                InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("creatdat");
-            //接口配置信息获取
+                //服务器路径
-            //读取接口配置信息获取
+                String nckd_url=interFaceImgUtils.getServerUrl();
-            InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("creatdat");
+                //分割符号
-            //服务器路径
+                String spiltsign=interFaceImgUtils.getServerSplit();
-            String nckd_url=interFaceImgUtils.getServerUrl();
+                //结束符号
-            //分割符号
+                String endsign=interFaceImgUtils.getServerEndsign();
-            String spiltsign=interFaceImgUtils.getServerSplit();
-            //结束符号
-            String endsign=interFaceImgUtils.getServerEndsign();
-            //上传文件到服务器中
-            //服务器端口
-            String host=interFaceImgUtils.getServerName();
-            //服务器用户名
-            String username=interFaceImgUtils.getServerUser();
-            //服务器密码
-            String password=interFaceImgUtils.getServerPassword();
-            //服务器路径
-            //服务器端口号
-            int port= interFaceImgUtils.getProt();
-            try {
                 //上传文件到服务器中
-                SftpClient sftpClient=new SftpClient(host,username,password,port);
+                //服务器端口
-                //获取服务器连接
+                String host=interFaceImgUtils.getServerName();
-                sftpClient.connect();
+                //服务器用户名
-                //创建文件夹，为当天日期
+                String username=interFaceImgUtils.getServerUser();
-                Date currentDate=new Date();
+                //服务器密码
-                //设置日期格式
+                String password=interFaceImgUtils.getServerPassword();
-                SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
+                //服务器路径
-                String dateStr=sf.format(currentDate);
+                //服务器端口号
-                String filePathWithDate=nckd_url+dateStr;
+                int port= interFaceImgUtils.getProt();
-                //创建文件夹，名为当前日期
+                try {
-                sftpClient.creatDir(filePathWithDate);
+                    //上传文件到服务器中
-                //临时文件
+                    SftpClient sftpClient=new SftpClient(host,username,password,port);
-                File localFile = File.createTempFile(tablenumber, ".dat");
+                    //获取服务器连接
-                File dest=new File(localFile.getParent()+File.separator+tablenumber.toUpperCase()+".dat");
+                    sftpClient.connect();
-                //重命名文件
+                    //创建文件夹，为当天日期
-                localFile.renameTo(dest);
+                    Date currentDate=new Date();
-                //文件写入
+                    //设置日期格式
-                DatFileCreatUtils datFileCreatUtils=new DatFileCreatUtils(tablenumber,bizappnum,fileList,dest.getAbsolutePath(),spiltsign,endsign);
+                    SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
-                //生成dat文件到本地
+                    String dateStr=sf.format(currentDate);
-                datFileCreatUtils.creatDatFile();
+                    String filePathWithDate=nckd_url+dateStr;
-                //从本地传文件到服务器
+                    //创建文件夹，名为当前日期
-                sftpClient.fileCreat(dest.getAbsolutePath(),filePathWithDate);
+                    sftpClient.creatDir(filePathWithDate);
-                //上传后删除临时文件
+                    //临时文件
-                localFile.delete();
+                    File localFile = File.createTempFile(tablenumber, ".dat");
-                dest.delete();
+                    File dest=new File(localFile.getParent()+File.separator+tablenumber.toUpperCase()+".dat");
-                //关闭连接
+                    //重命名文件
-                sftpClient.disconnect();
+                    localFile.renameTo(dest);
-            } catch (IOException e) {
+                    //文件写入
-                throw new RuntimeException(e);
+                    DatFileCreatUtils datFileCreatUtils=new DatFileCreatUtils(tablenumber,bizappnum,fileList,dest.getAbsolutePath(),spiltsign,endsign);
-            } catch (SftpException e) {
+                    //生成dat文件到本地
-                throw new RuntimeException(e);
+                    datFileCreatUtils.creatDatFile();
-            } catch (Exception e) {
+                    //从本地传文件到服务器
-                throw new RuntimeException(e);
+                    sftpClient.fileCreat(dest.getAbsolutePath(),filePathWithDate);
+                    //上传后删除临时文件
+                    localFile.delete();
+                    dest.delete();
+                    //关闭连接
+                    sftpClient.disconnect();
+                } catch (IOException e) {
+                    throw new RuntimeException(e);
+                } catch (SftpException e) {
+                    throw new RuntimeException(e);
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
             }
         }
     }