forked from demo/example
Compare commits
4 Commits
release/10
...
persist/9.
| Author | SHA1 | Date |
|---|---|---|
 richie
|
35c6a2b2c7 | 5 years ago |
|
richie
|
eb7ea8afd6 | 5 years ago |
 yaoh.wu
|
b65318985e | 6 years ago |
|
yaoh.wu
|
1700e09a51 | 6 years ago |
202 changed files with 1236 additions and 8946 deletions
@ -1,7 +1 @@
|
||||
*.iml |
||||
.idea/ |
||||
/target/ |
||||
/download/ |
||||
/webroot/ |
||||
.DS_Store |
||||
lib/report/*.jar |
||||
@ -1,26 +1,3 @@
|
||||
# 工程配置指南 |
||||
# 文档demo代码插件 |
||||
|
||||
## 安装maven |
||||
用于构建开发工程，文档参考：http://wiki.jikexueyuan.com/project/maven/environment-setup.html |
||||
|
||||
## 安装ant |
||||
用于构建插件安装包，文档参考：http://wiki.jikexueyuan.com/project/ant/environment-setup.html |
||||
|
||||
## 配置开发工程 |
||||
直接使用IntelliJ IDEA打开这个目录即可。 |
||||
|
||||
如果需要复制jar包到webroot/WEB-INF/lib下，可以执行命令：```mvn install``` |
||||
|
||||
## 启动设计器 |
||||
如果希望正常的进行插件开发，使用```com.fr.learn.Leaner```启动设计器。 |
||||
|
||||
如果希望进行设计器调试，则使用```com.fr.learn.Leaner4Debug```启动设计器。 |
||||
|
||||
## 修改依赖的jar版本 |
||||
只需要更改pom.xml中的common-version属性即可。 |
||||
|
||||
|common-version|含义| |
||||
|--------------|----| |
||||
|10.0-RELEASE-SNAPSHOT|10.0的测试版本快照| |
||||
|10.0-SNAPSHOT|10.0的正式版本快照| |
||||
|10.0|10.0的正式版本| |
||||
## 只是为了验证文档demo代码是否能够编译，插件本身无任何作用。 |
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -1,212 +0,0 @@
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
||||
<modelVersion>4.0.0</modelVersion> |
||||
<groupId>com.fr.plugin</groupId> |
||||
<artifactId>starter</artifactId> |
||||
<version>10.0</version> |
||||
<packaging>pom</packaging> |
||||
<properties> |
||||
<common-version>10.0-RELEASE-SNAPSHOT</common-version> |
||||
<web-inf-bucket>${project.basedir}/webroot/WEB-INF</web-inf-bucket> |
||||
</properties> |
||||
<dependencies> |
||||
<!-- core包 --> |
||||
<dependency> |
||||
<groupId>com.fr.third</groupId> |
||||
<artifactId>fine-third</artifactId> |
||||
<version>${common-version}</version> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.activator</groupId> |
||||
<artifactId>fine-activator</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.core</groupId> |
||||
<artifactId>fine-core</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.webui</groupId> |
||||
<artifactId>fine-webui</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<!-- 数据源包 --> |
||||
<dependency> |
||||
<groupId>com.fr.datasource</groupId> |
||||
<artifactId>fine-datasource</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<!-- 决策平台包 --> |
||||
<dependency> |
||||
<groupId>com.fr.decision</groupId> |
||||
<artifactId>fine-decision</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.decision</groupId> |
||||
<artifactId>fine-decision-report</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<!-- 定时调度包 --> |
||||
<dependency> |
||||
<groupId>com.fr.schedule</groupId> |
||||
<artifactId>fine-schedule</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.schedule</groupId> |
||||
<artifactId>fine-schedule-report</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
|
||||
<!-- 智能日志包 --> |
||||
<dependency> |
||||
<groupId>com.fr.intelligence</groupId> |
||||
<artifactId>fine-swift</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>com.fr.intelligence</groupId> |
||||
<artifactId>fine-accumulator</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<!-- 报表引擎包 --> |
||||
<dependency> |
||||
<groupId>com.fr.report</groupId> |
||||
<artifactId>fine-report-engine</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
<!-- 设计器包 --> |
||||
<dependency> |
||||
<groupId>com.fr.report</groupId> |
||||
<artifactId>fine-report-designer</artifactId> |
||||
<version>${common-version}</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
|
||||
<!-- 远程设计用包 --> |
||||
<dependency> |
||||
<groupId>io.socket</groupId> |
||||
<artifactId>socket.io-client</artifactId> |
||||
<version>0.7.0</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
|
||||
<!-- AOP用包 --> |
||||
<dependency> |
||||
<groupId>org.aspectj</groupId> |
||||
<artifactId>aspectjrt</artifactId> |
||||
<version>1.6.9</version> |
||||
<scope>compile</scope> |
||||
</dependency> |
||||
|
||||
<!-- 设计器调试用包 --> |
||||
<dependency> |
||||
<groupId>org.swingexplorer</groupId> |
||||
<artifactId>swexpl</artifactId> |
||||
<version>2.0</version> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>org.swingexplorer</groupId> |
||||
<artifactId>swag</artifactId> |
||||
<version>1.0</version> |
||||
</dependency> |
||||
|
||||
<!-- tomcat包 --> |
||||
<dependency> |
||||
<groupId>org.apache.tomcat</groupId> |
||||
<artifactId>tomcat-catalina</artifactId> |
||||
<version>8.5.32</version> |
||||
</dependency> |
||||
|
||||
<!-- mysql驱动 --> |
||||
<dependency> |
||||
<groupId>mysql</groupId> |
||||
<artifactId>mysql-connector-java</artifactId> |
||||
<version>5.1.44</version> |
||||
</dependency> |
||||
|
||||
<dependency> |
||||
<groupId>junit</groupId> |
||||
<artifactId>junit</artifactId> |
||||
<version>4.12</version> |
||||
<scope>test</scope> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>org.easymock</groupId> |
||||
<artifactId>easymock</artifactId> |
||||
<version>3.5.1</version> |
||||
<scope>test</scope> |
||||
</dependency> |
||||
|
||||
</dependencies> |
||||
<build> |
||||
<outputDirectory>${web-inf-bucket}/classes</outputDirectory> |
||||
<plugins> |
||||
<plugin> |
||||
<artifactId>maven-compiler-plugin</artifactId> |
||||
<version>3.1</version> |
||||
<configuration> |
||||
<source>1.6</source> |
||||
<target>1.6</target> |
||||
<!--不生成target/generated-sources/annotations--> |
||||
<proc>none</proc> |
||||
</configuration> |
||||
</plugin> |
||||
<plugin> |
||||
<groupId>org.apache.maven.plugins</groupId> |
||||
<artifactId>maven-dependency-plugin</artifactId> |
||||
<executions> |
||||
<execution> |
||||
<id>copy</id> |
||||
<phase>package</phase> |
||||
<goals> |
||||
<goal>copy-dependencies</goal> |
||||
</goals> |
||||
<configuration> |
||||
<outputDirectory> |
||||
${project.basedir}/webroot/WEB-INF/lib |
||||
</outputDirectory> |
||||
</configuration> |
||||
</execution> |
||||
</executions> |
||||
</plugin> |
||||
</plugins> |
||||
</build> |
||||
<repositories> |
||||
<repository> |
||||
<id>fanruan</id> |
||||
<name>fanruan</name> |
||||
<url>http://mvn.finedevelop.com/repository/maven-public/</url> |
||||
<snapshots> |
||||
<enabled>true</enabled> |
||||
<updatePolicy>always</updatePolicy> |
||||
<checksumPolicy>warn</checksumPolicy> |
||||
</snapshots> |
||||
</repository> |
||||
</repositories> |
||||
<pluginRepositories> |
||||
<pluginRepository> |
||||
<id>fanruan</id> |
||||
<name>fanruan</name> |
||||
<url>http://mvn.finedevelop.com/repository/maven-public/</url> |
||||
<snapshots> |
||||
<enabled>true</enabled> |
||||
<updatePolicy>always</updatePolicy> |
||||
<checksumPolicy>warn</checksumPolicy> |
||||
</snapshots> |
||||
</pluginRepository> |
||||
</pluginRepositories> |
||||
</project> |
||||
@ -1,26 +0,0 @@
|
||||
# 工程配置指南 |
||||
|
||||
## 安装maven |
||||
用于构建开发工程，文档参考：http://wiki.jikexueyuan.com/project/maven/environment-setup.html |
||||
|
||||
## 安装ant |
||||
用于构建插件安装包，文档参考：http://wiki.jikexueyuan.com/project/ant/environment-setup.html |
||||
|
||||
## 配置开发工程 |
||||
直接使用IntelliJ IDEA打开这个目录即可。 |
||||
|
||||
如果需要复制jar包到webroot/WEB-INF/lib下，可以执行命令：```mvn install``` |
||||
|
||||
## 启动设计器 |
||||
如果希望正常的进行插件开发，使用```com.fr.learn.Leaner```启动设计器。 |
||||
|
||||
如果希望进行设计器调试，则使用```com.fr.learn.Leaner4Debug```启动设计器。 |
||||
|
||||
## 修改依赖的jar版本 |
||||
只需要更改pom.xml中的common-version属性即可。 |
||||
|
||||
|common-version|含义| |
||||
|--------------|----| |
||||
|10.0-RELEASE-SNAPSHOT|10.0的测试版本快照| |
||||
|10.0-SNAPSHOT|10.0的正式版本快照| |
||||
|10.0|10.0的正式版本| |
||||
@ -0,0 +1,49 @@
|
||||
package com.fr.demo; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.dav.LocalEnv; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileInputStream; |
||||
import java.io.InputStream; |
||||
import java.sql.Connection; |
||||
import java.sql.DriverManager; |
||||
import java.sql.PreparedStatement; |
||||
|
||||
public class SaveReportToDatabase { |
||||
public static void main(String[] args) { |
||||
SaveReport(); |
||||
} |
||||
|
||||
private static void SaveReport() { |
||||
try { |
||||
// 定义报表运行环境,才能执行报表
|
||||
String envpath = "D:\\FineReport_8.0\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envpath)); |
||||
// 连接数据库
|
||||
String driver = "com.mysql.jdbc.Driver"; |
||||
String url = "jdbc:mysql://112.124.109.239:3306/yourdatabase"; |
||||
String user = "yourusername"; |
||||
String pass = "yourpassword"; |
||||
Class.forName(driver); |
||||
Connection conn = DriverManager.getConnection(url, user, pass); //注意表名是否区分大小写
|
||||
conn.setAutoCommit(false); |
||||
PreparedStatement presmt = conn |
||||
.prepareStatement("INSERT INTO report VALUES(?,?)"); |
||||
// 读进需要保存入库的模板文件
|
||||
File cptfile = new File(envpath |
||||
+ "\\reportlets\\GettingStarted.cpt"); |
||||
int lens = (int) cptfile.length(); |
||||
InputStream ins = new FileInputStream(cptfile); |
||||
// 将模板保存入库
|
||||
presmt.setString(1, "GettingStarted.cpt"); // 第一个字段存放模板相对路径
|
||||
presmt.setBinaryStream(2, ins, lens); // 第二个字段存放模板文件的二进制流
|
||||
presmt.execute(); |
||||
conn.commit(); |
||||
presmt.close(); |
||||
conn.close(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
@ -1,21 +1,25 @@
|
||||
//程序网络报表
|
||||
package com.fr.demo; |
||||
|
||||
import com.fr.base.Env; |
||||
import com.fr.base.FRContext; |
||||
import com.fr.io.TemplateWorkBookIO; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.web.core.Reportlet; |
||||
import com.fr.web.request.ReportletRequest; |
||||
|
||||
import java.util.Map; |
||||
|
||||
|
||||
public class SimpleReportletDemo extends Reportlet { |
||||
public TemplateWorkBook createReport(ReportletRequest reportletrequest) { |
||||
//新建一个WorkBook对象，用于保存最终返回的报表
|
||||
|
||||
// 新建一个WorkBook对象，用于保存最终返回的报表
|
||||
Env oldEnv = FRContext.getCurrentEnv(); |
||||
TemplateWorkBook WorkBook = null; |
||||
try { |
||||
//读取模板，将模板保存为workbook对象并返回
|
||||
WorkBook = TemplateWorkBookIO.readTemplateWorkBook("//doc//Primary//Parameter//Parameter.cpt"); |
||||
// 读取模板，将模板保存为workbook对象并返回
|
||||
WorkBook = TemplateWorkBookIO.readTemplateWorkBook(oldEnv, |
||||
"\\doc\\Primary\\Parameter\\Parameter.cpt"); |
||||
} catch (Exception e) { |
||||
e.getStackTrace(); |
||||
} |
||||
@ -1,28 +1,36 @@
|
||||
// 程序网络报表中获取request中的值
|
||||
package com.fr.demo; |
||||
import java.util.Map; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.base.Parameter; |
||||
import com.fr.dav.LocalEnv; |
||||
import com.fr.general.ModuleContext; |
||||
import com.fr.io.TemplateWorkBookIO; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.report.module.EngineModule; |
||||
import com.fr.web.core.Reportlet; |
||||
import com.fr.web.request.ReportletRequest; |
||||
import com.fr.io.TemplateWorkBookIO; |
||||
import com.fr.base.Parameter; |
||||
|
||||
import java.util.Map; |
||||
|
||||
|
||||
@SuppressWarnings("unused") |
||||
public class URLParameterDemo extends Reportlet { |
||||
public TemplateWorkBook createReport(ReportletRequest reportletRequest) { |
||||
|
||||
String envPath = "D:\\FineReport_8.0\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envPath)); |
||||
ModuleContext.startModule(EngineModule.class.getName()); |
||||
// 获取外部传来的参数
|
||||
TemplateWorkBook wbTpl = null; |
||||
String countryValue = reportletRequest.getParameter("地区").toString(); |
||||
try { |
||||
wbTpl = TemplateWorkBookIO.readTemplateWorkBook( |
||||
"//doc//Primary//Parameter//Parameter.cpt"); |
||||
FRContext.getCurrentEnv(), "\\doc\\Primary\\Parameter\\Parameter.cpt"); |
||||
// 提取报表参数组，由于原模板只有country一个参数，因此直接取index为0的参数，并将外部传入的值赋给该参数
|
||||
Parameter[] ps = wbTpl.getParameters(); |
||||
ps[0].setValue(countryValue); |
||||
// 原模板定义有参数界面，参数已经从外部获得，去掉参数页面
|
||||
// 如果想要参数面板，把下面wbTpl.getReportParameterAttr().setParameterUI(null); 这句去掉就行
|
||||
// 若您想保留参数界面，则将模板设置为不延迟报表展示，再传入参数后直接根据参数值显示结果，否则还需要再次点击查询按钮
|
||||
wbTpl.getReportParameterAttr().setParameterUI(null); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
@ -1,16 +1,17 @@
|
||||
package com.fr.function; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
import java.util.Properties; |
||||
|
||||
import com.sap.conn.jco.JCoDestination; |
||||
import com.sap.conn.jco.JCoDestinationManager; |
||||
import com.sap.conn.jco.JCoException; |
||||
import com.sap.conn.jco.ext.DestinationDataProvider; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
import java.util.Properties; |
||||
|
||||
public class ConnectSAPServer { |
||||
static String ABAP_AS_POOLED = "ABAP_AS_WITH_POOL"; |
||||
|
||||
static { |
||||
Properties connectProperties = new Properties(); |
||||
connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, |
||||
@ -0,0 +1,19 @@
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.script.AbstractFunction; |
||||
|
||||
public class StringCat extends AbstractFunction { |
||||
public StringCat() { |
||||
} |
||||
|
||||
public Object run(Object[] args) { |
||||
StringBuilder result = new StringBuilder(); |
||||
|
||||
for (int i = 0; i < args.length; ++i) { |
||||
Object para = args[i]; |
||||
result.append(para.toString()); |
||||
} |
||||
|
||||
return result.toString(); |
||||
} |
||||
} |
||||
@ -0,0 +1,73 @@
|
||||
//图片在下文字在上
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.base.BaseUtils; |
||||
import com.fr.base.GraphHelper; |
||||
import com.fr.script.AbstractFunction; |
||||
import com.fr.stable.CoreGraphHelper; |
||||
|
||||
import javax.imageio.ImageIO; |
||||
import javax.swing.JFrame; |
||||
import javax.swing.JPanel; |
||||
import java.awt.Graphics2D; |
||||
import java.awt.Image; |
||||
import java.awt.image.BufferedImage; |
||||
import java.io.File; |
||||
import java.io.IOException; |
||||
|
||||
|
||||
public class StringImage extends AbstractFunction { |
||||
public Object run(Object[] args) { |
||||
Image result = null; |
||||
int p = 0; |
||||
Object[] ob = new Object[2]; |
||||
for (int i = 0; (i < args.length && p <= 1); i++) { |
||||
if (args[i] == null) { |
||||
continue; |
||||
} |
||||
ob[p] = args[i]; |
||||
p++; |
||||
|
||||
} |
||||
try { |
||||
result = initStringImage(ob[0], ob[1]); |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
return result; |
||||
} |
||||
|
||||
public Image initStringImage(Object nameOb, Object imageOb) |
||||
throws IOException { |
||||
String name = (String) nameOb; |
||||
Image image = null; |
||||
if (imageOb instanceof Image) |
||||
image = (Image) imageOb; |
||||
else |
||||
; |
||||
Image stringImage = null; |
||||
BufferedImage splashBuffedImage = CoreGraphHelper.toBufferedImage(image); |
||||
stringImage = splashBuffedImage; |
||||
Graphics2D splashG2d = splashBuffedImage.createGraphics(); |
||||
double centerX = 25; |
||||
double centerY = 25; |
||||
GraphHelper.drawString(splashG2d, name, centerX, centerY); |
||||
//
|
||||
String FilePath = "Test.png"; |
||||
File f = new File(FilePath); |
||||
ImageIO.write(splashBuffedImage, "png", f); |
||||
//
|
||||
return splashBuffedImage; |
||||
} |
||||
|
||||
public static void main(String arg[]) throws IOException { |
||||
StringImage tt = new StringImage(); |
||||
Image image = BaseUtils.readImage("D:\\1.jpg"); |
||||
String name = "12314124"; |
||||
Image aa = tt.initStringImage(name, image); |
||||
JFrame jf = new JFrame(); |
||||
JPanel jp = new JPanel(); |
||||
|
||||
} |
||||
} |
||||
@ -0,0 +1,25 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.general.ModuleContext; |
||||
import com.fr.io.importer.ExcelReportImporter; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.report.module.EngineModule; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileInputStream; |
||||
import java.io.FileOutputStream; |
||||
import java.io.OutputStream; |
||||
|
||||
public class ExcelToCpt { |
||||
public static void main(String[] args) throws Exception { |
||||
File excelFile = new File("D:\\API.xls"); |
||||
FileInputStream a = new FileInputStream(excelFile); |
||||
ModuleContext.startModule(EngineModule.class.getName()); |
||||
TemplateWorkBook tpl = new ExcelReportImporter().generateWorkBookByStream(a); |
||||
OutputStream outputStream = new FileOutputStream(new File("D:\\abc.cpt")); |
||||
((WorkBook) tpl).export(outputStream); |
||||
outputStream.close(); |
||||
ModuleContext.stopModules(); |
||||
} |
||||
} |
||||
@ -0,0 +1,43 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.dav.LocalEnv; |
||||
import com.fr.general.ModuleContext; |
||||
import com.fr.io.exporter.ExcelExporter; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.main.workbook.ResultWorkBook; |
||||
import com.fr.report.module.EngineModule; |
||||
import com.fr.stable.WriteActor; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
|
||||
|
||||
public class ExcuteDemo { |
||||
public static void main(String[] args) { |
||||
try { |
||||
// 首先需要定义执行所在的环境，这样才能正确读取数据库信息
|
||||
String envPath = "D:\\FineReport_8.0\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envPath)); |
||||
ModuleContext.startModule(EngineModule.class.getName()); |
||||
// 读取模板
|
||||
TemplateWorkBook workbook = TemplateWorkBookIO.readTemplateWorkBook(FRContext.getCurrentEnv(), "\\doc\\Primary\\Parameter\\Parameter.cpt"); |
||||
/* |
||||
* 生成参数map，注入参数与对应的值，用于执行报表 该模板中只有一个参数地区，给其赋值华北 |
||||
* 若参数在发送请求时传过来，可以通过req.getParameter(name)获得 |
||||
* 获得的参数put进map中，paraMap.put(paraname,paravalue) |
||||
*/ |
||||
java.util.Map paraMap = new java.util.HashMap(); |
||||
paraMap.put("地区", "华北"); |
||||
// 使用paraMap执行生成结果
|
||||
ResultWorkBook result = workbook.execute(paraMap, new WriteActor()); |
||||
// 使用结果如导出至excel
|
||||
FileOutputStream outputStream = new FileOutputStream(new File( |
||||
"D:\\Parameter.xls")); |
||||
ExcelExporter excelExporter = new ExcelExporter(); |
||||
excelExporter.export(outputStream, result); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,93 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.base.Parameter; |
||||
import com.fr.dav.LocalEnv; |
||||
import com.fr.general.ModuleContext; |
||||
import com.fr.io.exporter.CSVExporter; |
||||
import com.fr.io.exporter.EmbeddedTableDataExporter; |
||||
import com.fr.io.exporter.ExcelExporter; |
||||
import com.fr.io.exporter.ImageExporter; |
||||
import com.fr.io.exporter.PDFExporter; |
||||
import com.fr.io.exporter.SVGExporter; |
||||
import com.fr.io.exporter.TextExporter; |
||||
import com.fr.io.exporter.WordExporter; |
||||
import com.fr.io.exporter.excel.stream.StreamExcel2007Exporter; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.main.workbook.ResultWorkBook; |
||||
import com.fr.report.module.EngineModule; |
||||
import com.fr.stable.WriteActor; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
|
||||
|
||||
public class ExportApi { |
||||
public static void main(String[] args) { |
||||
// 定义报表运行环境,才能执行报表
|
||||
String envpath = "D:\\FineReport_8.0\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envpath)); |
||||
ModuleContext.startModule(EngineModule.class.getName()); |
||||
ResultWorkBook rworkbook = null; |
||||
try { |
||||
// 未执行模板工作薄
|
||||
WorkBook workbook = (WorkBook) TemplateWorkBookIO |
||||
.readTemplateWorkBook(FRContext.getCurrentEnv(), |
||||
"\\doc\\Primary\\Parameter\\Parameter.cpt"); |
||||
// 获取报表参数并设置值，导出内置数据集时数据集会根据参数值查询出结果从而转为内置数据集
|
||||
Parameter[] parameters = workbook.getParameters(); |
||||
parameters[0].setValue("华东"); |
||||
// 定义parametermap用于执行报表，将执行后的结果工作薄保存为rworkBook
|
||||
java.util.Map parameterMap = new java.util.HashMap(); |
||||
for (int i = 0; i < parameters.length; i++) { |
||||
parameterMap.put(parameters[i].getName(), parameters[i] |
||||
.getValue()); |
||||
} |
||||
// 定义输出流
|
||||
FileOutputStream outputStream; |
||||
// 将未执行模板工作薄导出为内置数据集模板
|
||||
outputStream = new FileOutputStream(new File("D:\\EmbExport.cpt")); |
||||
EmbeddedTableDataExporter templateExporter = new EmbeddedTableDataExporter(); |
||||
templateExporter.export(outputStream, workbook); |
||||
// 将模板工作薄导出模板文件，在导出前您可以编辑导入的模板工作薄，可参考报表调用章节
|
||||
outputStream = new FileOutputStream(new File("D:\\TmpExport.cpt")); |
||||
((WorkBook) workbook).export(outputStream); |
||||
// 将结果工作薄导出为2003Excel文件
|
||||
outputStream = new FileOutputStream(new File("D:\\ExcelExport.xls")); |
||||
ExcelExporter ExcelExport = new ExcelExporter(); |
||||
ExcelExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
// 将结果工作薄导出为Excel文件
|
||||
outputStream = new FileOutputStream(new File("D:\\ExcelExport.xlsx")); |
||||
StreamExcel2007Exporter ExcelExport1 = new StreamExcel2007Exporter(); |
||||
ExcelExport1.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
// 将结果工作薄导出为Word文件
|
||||
outputStream = new FileOutputStream(new File("D:\\WordExport.doc")); |
||||
WordExporter WordExport = new WordExporter(); |
||||
WordExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
// 将结果工作薄导出为Pdf文件
|
||||
outputStream = new FileOutputStream(new File("D:\\PdfExport.pdf")); |
||||
PDFExporter PdfExport = new PDFExporter(); |
||||
PdfExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
// 将结果工作薄导出为Txt文件（txt文件本身不支持表格、图表等，被导出模板一般为明细表）
|
||||
outputStream = new FileOutputStream(new File("D:\\TxtExport.txt")); |
||||
TextExporter TxtExport = new TextExporter(); |
||||
TxtExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
// 将结果工作薄导出为Csv文件
|
||||
outputStream = new FileOutputStream(new File("D:\\CsvExport.csv")); |
||||
CSVExporter CsvExport = new CSVExporter(); |
||||
CsvExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
//将结果工作薄导出为SVG文件
|
||||
outputStream = new FileOutputStream(new File("D:\\SvgExport.svg")); |
||||
SVGExporter SvgExport = new SVGExporter(); |
||||
SvgExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
//将结果工作薄导出为image文件
|
||||
outputStream = new FileOutputStream(new File("D:\\PngExport.png")); |
||||
ImageExporter ImageExport = new ImageExporter(); |
||||
ImageExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
outputStream.close(); |
||||
ModuleContext.stopModules(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,90 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.base.Parameter; |
||||
import com.fr.dav.LocalEnv; |
||||
import com.fr.general.ModuleContext; |
||||
import com.fr.io.exporter.ExcelExporter; |
||||
import com.fr.io.exporter.LargeDataPageExcelExporter; |
||||
import com.fr.io.exporter.PageExcel2007Exporter; |
||||
import com.fr.io.exporter.PageExcelExporter; |
||||
import com.fr.io.exporter.PageToSheetExcel2007Exporter; |
||||
import com.fr.io.exporter.PageToSheetExcelExporter; |
||||
import com.fr.io.exporter.excel.stream.StreamExcel2007Exporter; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.main.workbook.ResultWorkBook; |
||||
import com.fr.report.core.ReportUtils; |
||||
import com.fr.report.module.EngineModule; |
||||
import com.fr.stable.WriteActor; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
|
||||
|
||||
public class ExportExcel { |
||||
public static void main(String[] args) { |
||||
// 定义报表运行环境,才能执行报表
|
||||
String envpath = "D:\\FineReport_8.0\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envpath)); |
||||
ModuleContext.startModule(EngineModule.class.getName()); |
||||
ResultWorkBook rworkbook = null; |
||||
try { |
||||
// 未执行模板工作薄
|
||||
WorkBook workbook = (WorkBook) TemplateWorkBookIO |
||||
.readTemplateWorkBook(FRContext.getCurrentEnv(), |
||||
"\\doc\\Primary\\Parameter\\Parameter.cpt"); |
||||
// 获取报表参数并设置值，导出内置数据集时数据集会根据参数值查询出结果从而转为内置数据集
|
||||
Parameter[] parameters = workbook.getParameters(); |
||||
parameters[0].setValue("华东"); |
||||
// 定义parametermap用于执行报表，将执行后的结果工作薄保存为rworkBook
|
||||
java.util.Map parameterMap = new java.util.HashMap(); |
||||
for (int i = 0; i < parameters.length; i++) { |
||||
parameterMap.put(parameters[i].getName(), parameters[i] |
||||
.getValue()); |
||||
} |
||||
// 定义输出流
|
||||
FileOutputStream outputStream; |
||||
|
||||
//原样导出excel2003
|
||||
outputStream = new FileOutputStream(new File("E:\\ExcelExport.xls")); |
||||
ExcelExporter excel = new ExcelExporter(); |
||||
excel.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//原样导出excel2007
|
||||
outputStream = new FileOutputStream(new File("E:\\ExcelExport.xlsx")); |
||||
StreamExcel2007Exporter excel1 = new StreamExcel2007Exporter(); |
||||
excel.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//分页导出excel2003
|
||||
outputStream = new FileOutputStream(new File("E:\\PageExcelExport.xls")); |
||||
PageExcelExporter page = new PageExcelExporter(ReportUtils.getPaperSettingListFromWorkBook(workbook.execute(parameterMap, new WriteActor()))); |
||||
page.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//分页导出excel2007
|
||||
outputStream = new FileOutputStream(new File("E:\\PageExcelExport.xlsx")); |
||||
PageExcel2007Exporter page1 = new PageExcel2007Exporter(ReportUtils.getPaperSettingListFromWorkBook(rworkbook)); |
||||
page1.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//分页分sheet导出excel2003
|
||||
outputStream = new FileOutputStream(new File("E:\\PageSheetExcelExport.xls")); |
||||
PageToSheetExcelExporter sheet = new PageToSheetExcelExporter(ReportUtils.getPaperSettingListFromWorkBook(workbook.execute(parameterMap, new WriteActor()))); |
||||
sheet.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//分页分sheet导出excel2007
|
||||
outputStream = new FileOutputStream(new File("E:\\PageSheetExcelExport.xlsx")); |
||||
PageToSheetExcel2007Exporter sheet1 = new PageToSheetExcel2007Exporter(ReportUtils.getPaperSettingListFromWorkBook(rworkbook)); |
||||
sheet1.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
//大数据量导出
|
||||
outputStream = new FileOutputStream(new File("E:\\LargeExcelExport.zip")); |
||||
LargeDataPageExcelExporter large = new LargeDataPageExcelExporter(ReportUtils.getPaperSettingListFromWorkBook(workbook.execute(parameterMap, new WriteActor())), true); |
||||
//导出2007版outputStream = new FileOutputStream(new File("E:\\LargeExcelExport.xlsx")); excel LargeDataPageExcel2007Exporter large = new LargeDataPageExcel2007Exporter(ReportUtils.getPaperSettingListFromWorkBook(rworkbook), true);
|
||||
large.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
outputStream.close(); |
||||
ModuleContext.stopModules(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,35 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.base.Parameter; |
||||
import com.fr.dav.LocalEnv; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.print.PrintUtils; |
||||
|
||||
import java.util.HashMap; |
||||
|
||||
|
||||
public class JavaPrint { |
||||
public static void main(String[] args) { |
||||
// 定义报表运行环境,才能执行报表
|
||||
String envPath = "D:\\FineReport\\develop\\code\\build\\package\\WebReport\\WEB-INF"; |
||||
FRContext.setCurrentEnv(new LocalEnv(envPath)); |
||||
try { |
||||
TemplateWorkBook workbook = TemplateWorkBookIO.readTemplateWorkBook(FRContext.getCurrentEnv(), "GettingStarted.cpt"); |
||||
// 参数传值
|
||||
Parameter[] parameters = workbook.getParameters(); |
||||
HashMap<String, String> paraMap = new HashMap<String, String>(); |
||||
paraMap.put(parameters[0].getName(), "华北"); |
||||
|
||||
// java中调用报表打印方法
|
||||
boolean a = PrintUtils.printWorkBook("GettingStarted.cpt", paraMap, true); |
||||
if (a == false) { |
||||
System.out.println("失败啦！返回" + a); |
||||
} else { |
||||
System.out.println("成功！返回" + a); |
||||
} |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,76 @@
|
||||
package com.fr.output; |
||||
|
||||
import com.fr.data.dao.CompatiableIDFCMapper; |
||||
import com.fr.data.dao.ObjectTableMapper; |
||||
import com.fr.json.JSONException; |
||||
import com.fr.json.JSONObject; |
||||
import com.fr.schedule.output.AbstractOutputFileAction; |
||||
import com.fr.schedule.output.FTPTransmission; |
||||
import com.fr.schedule.output.OutputFileAction; |
||||
import com.fr.schedule.output.ftp.DefaultFTPTransmit; |
||||
|
||||
import java.io.File; |
||||
|
||||
public class FTPUpload extends AbstractOutputFileAction { |
||||
@Override |
||||
public ObjectTableMapper objectTableMapper2Register() { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public long getId() { |
||||
return 0; |
||||
} |
||||
|
||||
@Override |
||||
public File[] getFilesToDealWith(File[] files) { |
||||
return files; |
||||
} |
||||
|
||||
@Override |
||||
public void doFileAction(File[] files) { |
||||
FTPTransmission ftp = new FTPTransmission(); |
||||
ftp.setServerAddress("env.finedevelop.com"); |
||||
ftp.setPort(58321); |
||||
ftp.setSavePath("connie"); |
||||
ftp.setUsername("fr"); |
||||
ftp.setPassword("ilovejava"); |
||||
try { |
||||
new DefaultFTPTransmit().transmit(files, ftp.getServerAddress(), ftp.getPort(), ftp.getUsername(), ftp.getPassword(), ftp.getSavePath()); |
||||
} catch (Exception e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public CompatiableIDFCMapper getExtraOutputFileActionForeignKey() { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public boolean isEmailNotification() { |
||||
// TODO Auto-generated method stub
|
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public OutputFileAction analyzeJSON(JSONObject arg0) { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public JSONObject createJSONConfig() throws JSONException { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public String getJsonTag() { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,100 @@
|
||||
package com.fr.output; |
||||
|
||||
import com.fr.data.dao.CompatiableIDFCMapper; |
||||
import com.fr.data.dao.ObjectTableMapper; |
||||
import com.fr.json.JSONException; |
||||
import com.fr.json.JSONObject; |
||||
import com.fr.schedule.output.AbstractOutputFileAction; |
||||
import com.fr.schedule.output.OutputFileAction; |
||||
|
||||
import java.io.BufferedInputStream; |
||||
import java.io.BufferedOutputStream; |
||||
import java.io.File; |
||||
import java.io.FileInputStream; |
||||
import java.io.FileOutputStream; |
||||
import java.io.IOException; |
||||
import java.io.OutputStream; |
||||
|
||||
public class OutputExcel extends AbstractOutputFileAction { |
||||
|
||||
@Override |
||||
public File[] getFilesToDealWith(File[] files) { |
||||
return files; |
||||
} |
||||
|
||||
@Override |
||||
public void doFileAction(File[] files) { |
||||
// OutputStream out=new BufferedOutputStream(new FileOutputStream(new File(files.)));;
|
||||
System.out.println(files[0].getName()); |
||||
for (int i = 0; i < files.length; i++) { |
||||
String name = files[i].getName(); |
||||
String path = "D:/" + name; |
||||
BufferedInputStream in = null; |
||||
OutputStream out = null; |
||||
try { |
||||
out = new BufferedOutputStream(new FileOutputStream(new File(path))); |
||||
in = new BufferedInputStream(new FileInputStream(files[i])); |
||||
byte[] ba = new byte[in.available()]; |
||||
in.read(ba); |
||||
out.write(ba); |
||||
} catch (Exception e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} finally { |
||||
try { |
||||
if (in != null) { |
||||
in.close(); |
||||
} |
||||
if (out != null) { |
||||
out.close(); |
||||
} |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
|
||||
} |
||||
|
||||
} |
||||
} |
||||
|
||||
@Override |
||||
public ObjectTableMapper objectTableMapper2Register() { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public CompatiableIDFCMapper getExtraOutputFileActionForeignKey() { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public long getId() { |
||||
return 0; |
||||
} |
||||
|
||||
@Override |
||||
public boolean isEmailNotification() { |
||||
// TODO Auto-generated method stub
|
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public OutputFileAction analyzeJSON(JSONObject arg0) { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public JSONObject createJSONConfig() throws JSONException { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public String getJsonTag() { |
||||
// TODO Auto-generated method stub
|
||||
return null; |
||||
} |
||||
|
||||
} |
||||
@ -1,11 +0,0 @@
|
||||
public class SimpleService |
||||
{ |
||||
public String getGreeting(String name) |
||||
{ |
||||
return "你好 " + name; |
||||
} |
||||
public int getPrice() |
||||
{ |
||||
return new java.util.Random().nextInt(1000); |
||||
} |
||||
} |
||||
@ -1,8 +0,0 @@
|
||||
public class TestWS2TDClient { |
||||
public String[][] getTD() { |
||||
String[][] a = { { "城市", "销售员", "销售额" }, { "江苏", "Anna", "230" }, { "江苏", "Alex", "190" }, |
||||
|
||||
{ "江苏", "Jack", "320" }, { "江苏", "Apple", "210" }, { "浙江", "Faye", "150" }, { "浙江", "Sammi", "280" } }; |
||||
return a; |
||||
} |
||||
} |
||||
@ -1,111 +0,0 @@
|
||||
package com.fr; |
||||
|
||||
import com.fr.data.NetworkHelper; |
||||
import com.fr.decision.mobile.terminal.TerminalHandler; |
||||
import com.fr.decision.webservice.utils.DecisionServiceConstants; |
||||
import com.fr.decision.webservice.v10.login.LoginService; |
||||
import com.fr.general.ComparatorUtils; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.security.JwtUtils; |
||||
import com.fr.stable.StringUtils; |
||||
import com.fr.stable.web.Device; |
||||
import org.jasig.cas.client.validation.Assertion; |
||||
import javax.servlet.Filter; |
||||
import javax.servlet.FilterChain; |
||||
import javax.servlet.FilterConfig; |
||||
import javax.servlet.ServletException; |
||||
import javax.servlet.ServletRequest; |
||||
import javax.servlet.ServletResponse; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import javax.servlet.http.HttpSession; |
||||
import java.io.IOException; |
||||
|
||||
/** |
||||
* Created by Zed on 2018/9/11. |
||||
*/ |
||||
public class FrFilter implements Filter { |
||||
|
||||
public FrFilter() { |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void init(FilterConfig filterConfig) throws ServletException { |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException { |
||||
FineLoggerFactory.getLogger().info("fr cas login"); |
||||
HttpServletRequest req = (HttpServletRequest) servletRequest; |
||||
HttpServletResponse res = (HttpServletResponse) servletResponse; |
||||
HttpSession session = req.getSession(true); |
||||
FineLoggerFactory.getLogger().info("URL:" + req.getRequestURI()); |
||||
String username; |
||||
//获取cas传递过来的username
|
||||
Object object = req.getSession().getAttribute("_const_cas_assertion_"); |
||||
if (object != null) { |
||||
Assertion assertion = (Assertion) object; |
||||
username = assertion.getPrincipal().getName(); |
||||
} else { |
||||
username = (String) session.getAttribute("edu.yale.its.tp.cas.client.filter.user"); |
||||
} |
||||
|
||||
try { |
||||
//用户名为空，登录请求有问题，直接报错
|
||||
if (StringUtils.isNotEmpty(username)) { |
||||
FineLoggerFactory.getLogger().info("username:" + username); |
||||
//获取请求携带的token
|
||||
Object oldToken = session.getAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME); |
||||
|
||||
//token不存在，或者token过期了，走后台登录方法
|
||||
if (oldToken == null || !checkTokenValid(req, (String) oldToken, username)) { |
||||
login(req, res, session, username); |
||||
filterChain.doFilter(req, res); |
||||
} else { |
||||
//放行
|
||||
filterChain.doFilter(req, res); |
||||
FineLoggerFactory.getLogger().info("no need"); |
||||
} |
||||
} else { |
||||
throw new Exception("username is empty"); |
||||
} |
||||
} catch (Exception e) { |
||||
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 后台登录方法 |
||||
*/ |
||||
private void login(HttpServletRequest req, HttpServletResponse res, HttpSession session, String username) throws Exception { |
||||
String token = LoginService.getInstance().login(req, res, username); |
||||
req.setAttribute(DecisionServiceConstants.FINE_AUTH_TOKEN_NAME, token); |
||||
FineLoggerFactory.getLogger().info("fr FrFilter is over with username is ###" + username); |
||||
} |
||||
|
||||
/** |
||||
* 校验token是否有效 |
||||
*/ |
||||
private boolean checkTokenValid(HttpServletRequest req, String token, String currentUserName) { |
||||
try { |
||||
//当前登录用户和token对应的用户名不同，需要重新生成token
|
||||
if (!ComparatorUtils.equals(currentUserName, JwtUtils.parseJWT(token).getSubject())) { |
||||
FineLoggerFactory.getLogger().info("username changed：" + currentUserName); |
||||
return false; |
||||
} |
||||
Device device = NetworkHelper.getDevice(req); |
||||
LoginService.getInstance().loginStatusValid(token, TerminalHandler.getTerminal(req, device)); |
||||
return true; |
||||
} catch (Exception ignore) { |
||||
} |
||||
|
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public void destroy() { |
||||
|
||||
} |
||||
} |
||||
@ -1,60 +0,0 @@
|
||||
package com.fr; |
||||
|
||||
import com.fr.decision.authority.data.User; |
||||
import com.fr.decision.webservice.exception.user.UserNotExistException; |
||||
import com.fr.decision.webservice.v10.login.LoginService; |
||||
import com.fr.decision.webservice.v10.login.TokenResource; |
||||
import com.fr.decision.webservice.v10.user.UserService; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.stable.StringUtils; |
||||
import com.fr.web.utils.WebUtils; |
||||
import java.io.IOException; |
||||
import javax.servlet.Filter; |
||||
import javax.servlet.FilterChain; |
||||
import javax.servlet.FilterConfig; |
||||
import javax.servlet.ServletException; |
||||
import javax.servlet.ServletRequest; |
||||
import javax.servlet.ServletResponse; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
|
||||
public class FrLoginFilter implements Filter { |
||||
public FrLoginFilter() { |
||||
} |
||||
|
||||
public void init(FilterConfig filterConfig) throws ServletException { |
||||
} |
||||
|
||||
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException { |
||||
HttpServletRequest req = (HttpServletRequest)servletRequest; |
||||
HttpServletResponse res = (HttpServletResponse)servletResponse; |
||||
String username = WebUtils.getHTTPRequestParameter(req, "username"); |
||||
|
||||
try { |
||||
if (StringUtils.isNotEmpty(username)) { |
||||
FineLoggerFactory.getLogger().error("username:" + username); |
||||
User user = UserService.getInstance().getUserByUserName(username); |
||||
if (user == null) { |
||||
throw new UserNotExistException(); |
||||
} |
||||
|
||||
String oldToken = TokenResource.COOKIE.getToken(req); |
||||
if (oldToken == null) { |
||||
String token = LoginService.getInstance().login(req, res, username); |
||||
req.setAttribute("fine_auth_token", token); |
||||
filterChain.doFilter(req, res); |
||||
} else { |
||||
filterChain.doFilter(req, res); |
||||
} |
||||
} else { |
||||
filterChain.doFilter(req, res); |
||||
} |
||||
} catch (Exception var10) { |
||||
FineLoggerFactory.getLogger().error(var10.getMessage(), var10); |
||||
} |
||||
|
||||
} |
||||
|
||||
public void destroy() { |
||||
} |
||||
} |
||||
@ -1,228 +0,0 @@
|
||||
package com.fr; |
||||
|
||||
import java.security.*; |
||||
import javax.net.ssl.*; |
||||
import com.fr.third.org.hsqldb.lib.*; |
||||
import java.net.*; |
||||
import java.io.*; |
||||
import java.security.cert.CertificateException; |
||||
import java.security.cert.X509Certificate; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
|
||||
public class HttpUtil |
||||
{ |
||||
private static final String DEFAULT_CHARSET = "UTF-8"; |
||||
private static final String METHOD_POST = "POST"; |
||||
private static final String METHOD_GET = "GET"; |
||||
private static final int CONNECTTIMEOUT = 5000; |
||||
private static final int READTIMEOUT = 5000; |
||||
|
||||
private static class DefaultTrustManager implements X509TrustManager { |
||||
|
||||
@Override |
||||
public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public X509Certificate[] getAcceptedIssuers() { |
||||
return null; |
||||
} |
||||
} |
||||
private static HttpURLConnection getConnection(final URL url, final String method, final String ctype) throws IOException { |
||||
HttpURLConnection conn = null; |
||||
if ("https".equals(url.getProtocol())) { |
||||
SSLContext ctx = null; |
||||
try { |
||||
ctx = SSLContext.getInstance("TLS"); |
||||
ctx.init(new KeyManager[0], new TrustManager[] { new DefaultTrustManager() }, new SecureRandom()); |
||||
} |
||||
catch (Exception e) { |
||||
throw new IOException(e); |
||||
} |
||||
final HttpsURLConnection connHttps = (HttpsURLConnection)url.openConnection(); |
||||
connHttps.setSSLSocketFactory(ctx.getSocketFactory()); |
||||
connHttps.setHostnameVerifier(new HostnameVerifier() { |
||||
@Override |
||||
public boolean verify(String s, SSLSession sslSession) { |
||||
return true; |
||||
} |
||||
}); |
||||
conn = connHttps; |
||||
} |
||||
else { |
||||
conn = (HttpURLConnection)url.openConnection(); |
||||
} |
||||
conn.setRequestMethod(method); |
||||
conn.setDoInput(true); |
||||
conn.setDoOutput(true); |
||||
conn.setRequestProperty("User-Agent", "quantangle- apiclient-java"); |
||||
conn.setRequestProperty("Content-Type", ctype); |
||||
conn.setRequestProperty("Connection", "Keep-Alive"); |
||||
return conn; |
||||
} |
||||
|
||||
public static String doGet(final String url, final Map<String, String> params) throws IOException { |
||||
return doGet(url, params, "UTF-8"); |
||||
} |
||||
|
||||
public static String doGet(String url, final Map<String, String> params, final String charset) throws IOException { |
||||
if (StringUtil.isEmpty(url) || params == null) { |
||||
return null; |
||||
} |
||||
String response = ""; |
||||
url = url + "?" + buildQuery(params, charset); |
||||
HttpURLConnection conn = null; |
||||
final String ctype = "application/x-www-form- urlencoded;charset=" + charset; |
||||
conn = getConnection(new URL(url), "GET", ctype); |
||||
response = getResponseAsString(conn); |
||||
return response; |
||||
} |
||||
|
||||
public static String doPost(final String url, final Map<String, String> params) throws IOException { |
||||
return doPost(url, params, 5000, 5000); |
||||
} |
||||
|
||||
public static String doPost(final String url, final Map<String, String> params, final int connectTimeOut, final int readTimeOut) throws IOException { |
||||
return doPost(url, params, "UTF-8", connectTimeOut, readTimeOut); |
||||
} |
||||
|
||||
public static String doPost(final String url, final Map<String, String> params, final String charset, final int connectTimeOut, final int readTimeOut) throws IOException { |
||||
HttpURLConnection conn = null; |
||||
String response = ""; |
||||
final String ctype = "application/x-www-form- urlencoded;charset=" + charset; |
||||
conn = getConnection(new URL(url), "POST", ctype); |
||||
conn.setConnectTimeout(connectTimeOut); |
||||
conn.setReadTimeout(readTimeOut); |
||||
conn.getOutputStream().write(buildQuery(params, charset).getBytes(charset)); |
||||
response = getResponseAsString(conn); |
||||
return response; |
||||
} |
||||
|
||||
public static String buildQuery(final Map<String, String> params, final String charset) { |
||||
if (params == null || params.isEmpty()) { |
||||
return null; |
||||
} |
||||
final StringBuilder sb = new StringBuilder(); |
||||
boolean first = true; |
||||
for (final Map.Entry<String, String> entry : params.entrySet()) { |
||||
if (first) { |
||||
first = false; |
||||
} |
||||
else { |
||||
sb.append("&"); |
||||
} |
||||
final String key = entry.getKey(); |
||||
final String value = entry.getValue(); |
||||
if (!StringUtil.isEmpty(key) && !StringUtil.isEmpty(value)) { |
||||
try { |
||||
sb.append(key).append("=").append(URLEncoder.encode(value, charset)); |
||||
} |
||||
catch (UnsupportedEncodingException ex) {} |
||||
} |
||||
} |
||||
return sb.toString(); |
||||
} |
||||
|
||||
public static Map<String, String> splitQuery(final String query, final String charset) { |
||||
final Map<String, String> ret = new HashMap<String, String>(); |
||||
if (!StringUtil.isEmpty(query)) { |
||||
final String[] split2; |
||||
final String[] splits = split2 = query.split("\\&"); |
||||
for (final String split : split2) { |
||||
final String[] keyAndValue = split.split("\\="); |
||||
boolean flag = true; |
||||
for (int i = 0, len = keyAndValue.length; i < len; ++i) { |
||||
if (StringUtil.isEmpty(keyAndValue[i])) { |
||||
flag = false; |
||||
break; |
||||
} |
||||
} |
||||
if (flag && keyAndValue.length == 2) { |
||||
try { |
||||
ret.put(keyAndValue[0], URLDecoder.decode(keyAndValue[1], charset)); |
||||
} |
||||
catch (UnsupportedEncodingException ex) {} |
||||
} |
||||
} |
||||
} |
||||
return ret; |
||||
} |
||||
|
||||
private static byte[] getTextEntry(final String fieldName, final String fieldValue, final String charset) throws IOException { |
||||
final StringBuilder entry = new StringBuilder(); |
||||
entry.append("Content-Disposition:form-data;name=\""); |
||||
entry.append(fieldName); |
||||
entry.append("\"\r\nContent-Type:text/plain\r\n\r\n"); |
||||
entry.append(fieldValue); |
||||
return entry.toString().getBytes(charset); |
||||
} |
||||
|
||||
private static byte[] getFileEntry(final String fieldName, final String fileName, final String mimeType, final String charset) throws IOException { |
||||
final StringBuilder entry = new StringBuilder(); |
||||
entry.append("Content-Disposition:form-data;name=\""); |
||||
entry.append(fieldName); |
||||
entry.append("\";filename=\""); |
||||
entry.append(fileName); |
||||
entry.append("\"\r\nContent-Type:"); |
||||
entry.append(mimeType); |
||||
entry.append("\r\n\r\n"); |
||||
return entry.toString().getBytes(charset); |
||||
} |
||||
|
||||
private static String getResponseAsString(final HttpURLConnection conn) throws IOException { |
||||
final String charset = getResponseCharset(conn.getContentType()); |
||||
final InputStream es = conn.getErrorStream(); |
||||
if (es == null) { |
||||
return getStreamAsString(conn.getInputStream(), charset); |
||||
} |
||||
final String msg = getStreamAsString(es, charset); |
||||
if (StringUtil.isEmpty(msg)) { |
||||
throw new IOException("{\"" + conn.getResponseCode() + "\":\"" + conn.getResponseMessage() + "\"}"); |
||||
} |
||||
throw new IOException(msg); |
||||
} |
||||
|
||||
private static String getStreamAsString(final InputStream input, final String charset) throws IOException { |
||||
final StringBuilder sb = new StringBuilder(); |
||||
BufferedReader bf = null; |
||||
try { |
||||
bf = new BufferedReader(new InputStreamReader(input, charset)); |
||||
String str; |
||||
while ((str = bf.readLine()) != null) { |
||||
sb.append(str); |
||||
} |
||||
return sb.toString(); |
||||
} |
||||
finally { |
||||
if (bf != null) { |
||||
bf.close(); |
||||
bf = null; |
||||
} |
||||
} |
||||
} |
||||
|
||||
private static String getResponseCharset(final String ctype) { |
||||
String charset = "UTF-8"; |
||||
if (!StringUtil.isEmpty(ctype)) { |
||||
final String[] split; |
||||
final String[] params = split = ctype.split("\\;"); |
||||
for (String param : split) { |
||||
param = param.trim(); |
||||
if (param.startsWith("charset")) { |
||||
final String[] pair = param.split("\\="); |
||||
if (pair.length == 2) { |
||||
charset = pair[1].trim(); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
return charset; |
||||
} |
||||
} |
||||
@ -1,111 +0,0 @@
|
||||
package com.fr; |
||||
|
||||
import java.io.InputStream; |
||||
import java.io.OutputStream; |
||||
import java.io.PrintWriter; |
||||
import java.net.URL; |
||||
import java.net.URLConnection; |
||||
import java.security.SecureRandom; |
||||
import java.security.cert.CertificateException; |
||||
import java.security.cert.X509Certificate; |
||||
import java.util.Iterator; |
||||
import java.util.Map; |
||||
import java.util.Map.Entry; |
||||
import javax.net.ssl.HostnameVerifier; |
||||
import javax.net.ssl.HttpsURLConnection; |
||||
import javax.net.ssl.KeyManager; |
||||
import javax.net.ssl.SSLContext; |
||||
import javax.net.ssl.SSLSession; |
||||
import javax.net.ssl.TrustManager; |
||||
import javax.net.ssl.X509TrustManager; |
||||
|
||||
import org.apache.oltu.oauth2.client.HttpClient; |
||||
import org.apache.oltu.oauth2.client.request.OAuthClientRequest; |
||||
import org.apache.oltu.oauth2.client.response.OAuthClientResponse; |
||||
import org.apache.oltu.oauth2.client.response.OAuthClientResponseFactory; |
||||
import org.apache.oltu.oauth2.common.exception.OAuthProblemException; |
||||
import org.apache.oltu.oauth2.common.exception.OAuthSystemException; |
||||
import org.apache.oltu.oauth2.common.utils.OAuthUtils; |
||||
|
||||
public class SSLConnectionClient implements HttpClient { |
||||
public SSLConnectionClient() { |
||||
} |
||||
|
||||
public <T extends OAuthClientResponse> T execute(OAuthClientRequest request, Map<String, String> headers, String requestMethod, Class<T> responseClass) throws OAuthSystemException, OAuthProblemException { |
||||
String responseBody = null; |
||||
URLConnection c = null; |
||||
boolean var7 = false; |
||||
|
||||
int responseCode; |
||||
try { |
||||
URL url = new URL(request.getLocationUri()); |
||||
c = url.openConnection(); |
||||
responseCode = -1; |
||||
if (c instanceof HttpsURLConnection) { |
||||
HttpsURLConnection httpsURLConnection = (HttpsURLConnection) c; |
||||
SSLContext sslContext = SSLContext.getInstance("TLS"); |
||||
sslContext.init((KeyManager[]) null, new TrustManager[]{new TrustAnyTrustManager()}, new SecureRandom()); |
||||
httpsURLConnection.setSSLSocketFactory(sslContext.getSocketFactory()); |
||||
httpsURLConnection.setHostnameVerifier(new TrustAnyHostnameVerifier()); |
||||
if (headers != null && !headers.isEmpty()) { |
||||
Iterator var11 = headers.entrySet().iterator(); |
||||
|
||||
while (var11.hasNext()) { |
||||
Entry<String, String> header = (Entry) var11.next(); |
||||
httpsURLConnection.addRequestProperty((String) header.getKey(), (String) header.getValue()); |
||||
} |
||||
} |
||||
|
||||
if (!OAuthUtils.isEmpty(requestMethod)) { |
||||
httpsURLConnection.setRequestMethod(requestMethod); |
||||
if (requestMethod.equals("POST")) { |
||||
httpsURLConnection.setDoOutput(true); |
||||
OutputStream ost = httpsURLConnection.getOutputStream(); |
||||
PrintWriter pw = new PrintWriter(ost); |
||||
pw.print(request.getBody()); |
||||
pw.flush(); |
||||
pw.close(); |
||||
} |
||||
} else { |
||||
httpsURLConnection.setRequestMethod("GET"); |
||||
} |
||||
|
||||
httpsURLConnection.connect(); |
||||
responseCode = httpsURLConnection.getResponseCode(); |
||||
InputStream inputStream; |
||||
if (responseCode == 400) { |
||||
inputStream = httpsURLConnection.getErrorStream(); |
||||
} else { |
||||
inputStream = httpsURLConnection.getInputStream(); |
||||
} |
||||
|
||||
responseBody = OAuthUtils.saveStreamAsString(inputStream); |
||||
} |
||||
} catch (Exception var13) { |
||||
throw new OAuthSystemException(var13); |
||||
} |
||||
|
||||
return OAuthClientResponseFactory.createCustomResponse(responseBody, c.getContentType(), responseCode, responseClass); |
||||
} |
||||
|
||||
public void shutdown() { |
||||
} |
||||
|
||||
static class TrustAnyTrustManager implements X509TrustManager { |
||||
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { |
||||
} |
||||
|
||||
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { |
||||
} |
||||
|
||||
public X509Certificate[] getAcceptedIssuers() { |
||||
return new X509Certificate[]{}; |
||||
} |
||||
} |
||||
|
||||
static class TrustAnyHostnameVerifier implements HostnameVerifier { |
||||
public boolean verify(String hostname, SSLSession session) { |
||||
return true; |
||||
} |
||||
} |
||||
} |
||||
@ -1,58 +0,0 @@
|
||||
import com.fr.cert.token.JwtBuilder; |
||||
import com.fr.cert.token.Jwts; |
||||
import com.fr.cert.token.SignatureAlgorithm; |
||||
import sun.misc.BASE64Encoder; |
||||
import javax.crypto.Mac; |
||||
import javax.crypto.spec.SecretKeySpec; |
||||
import java.util.Date; |
||||
|
||||
public class Test2 { |
||||
|
||||
public static void main(String[] args) { |
||||
//数字签名有效时长
|
||||
long validTime = 30 * 60 * 1000; |
||||
//数字签名内容，以访问资源的相对路径作为内容
|
||||
String path = "GettingStarted.cpt"; |
||||
//数字签名用的HS256的密钥
|
||||
String key = createSecret(); |
||||
//生成fine_digital_signature
|
||||
String fine_digital_signature = createJwt("", "", path, validTime, key); |
||||
//输出密钥
|
||||
System.out.println(key); |
||||
//输出fine_digital_signature
|
||||
System.out.println(fine_digital_signature); |
||||
} |
||||
|
||||
private static String createJwt(String issuer, String id, String subject, long validTime, String key) { |
||||
SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256; |
||||
Date currentTime = new Date(); |
||||
Date expirationTime = new Date(currentTime.getTime() + validTime); |
||||
JwtBuilder builder = Jwts.builder() |
||||
.setIssuer(issuer) |
||||
.setSubject(subject) |
||||
.setIssuedAt(currentTime) |
||||
.setExpiration(expirationTime) |
||||
.setId(id) |
||||
.signWith(signatureAlgorithm, key); |
||||
return builder.compact(); |
||||
} |
||||
|
||||
private static String createSecret() { |
||||
try { |
||||
//secret可以自定义的
|
||||
String secret = "2222222"; |
||||
String message = ""; |
||||
Mac sha256Hmac = Mac.getInstance("HmacSHA256"); |
||||
SecretKeySpec secret_key = new SecretKeySpec(secret.getBytes(), "HmacSHA256"); |
||||
sha256Hmac.init(secret_key); |
||||
BASE64Encoder encoder = new BASE64Encoder(); |
||||
String hash = encoder.encode(sha256Hmac.doFinal(message.getBytes())); |
||||
return hash; |
||||
|
||||
} catch (Exception e) { |
||||
System.out.println(e.getMessage()); |
||||
} |
||||
return ""; |
||||
} |
||||
|
||||
} |
||||
@ -1,50 +0,0 @@
|
||||
package com.fr.data; |
||||
|
||||
import javax.servlet.http.HttpSession; |
||||
import java.io.IOException; |
||||
import java.io.PrintWriter; |
||||
import java.lang.String; |
||||
import javax.servlet.ServletException; |
||||
import javax.servlet.http.HttpServlet; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import com.fr.stable.CodeUtils; |
||||
|
||||
public class session extends HttpServlet { |
||||
public void doGet(HttpServletRequest request, |
||||
HttpServletResponse response) |
||||
throws IOException, ServletException |
||||
{ |
||||
response.setContentType("text/html; charset=gb2312"); |
||||
|
||||
PrintWriter out = response.getWriter(); |
||||
out.println("<html>"); |
||||
out.println("<body>"); |
||||
String urlid=request.getParameter("id"); //获取url通过ajax传递的值
|
||||
HttpSession session=request.getSession(true); |
||||
if(urlid==""||urlid==null){ |
||||
out.print("<form action=\""); |
||||
out.print("session\" "); |
||||
out.println("method=POST>"); |
||||
out.println("set session:<input type=text name=sessionvalue>"); |
||||
out.println("<input type=submit name=bbb value=tijiao>"); |
||||
out.println("</form>"); |
||||
if(request.getParameter("sessionvalue")!=null&&request.getParameter("sessionvalue")!=""){ |
||||
session.setAttribute("sessionname", request.getParameter("sessionvalue")); |
||||
} |
||||
} |
||||
else{ |
||||
urlid = CodeUtils.decodeText(urlid); |
||||
session.setAttribute("sessionname",urlid); //将值赋值给sessionname这个session中
|
||||
out.println("<script language='javascript'>window.close();</script>"); |
||||
} |
||||
out.println("</body>"); |
||||
out.println("</html>"); |
||||
} |
||||
public void doPost(HttpServletRequest request, |
||||
HttpServletResponse response) |
||||
throws IOException, ServletException |
||||
{ |
||||
doGet(request, response); |
||||
} |
||||
} |
||||
@ -1,19 +0,0 @@
|
||||
package com.fr.decision.privilege.encrpt;; |
||||
import com.fr.base.Base64; |
||||
import com.fr.base.ServerConfig; |
||||
import com.fr.decision.privilege.encrpt.AbstractPasswordValidator; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import java.io.UnsupportedEncodingException; |
||||
public class Base64PasswordValidator extends AbstractPasswordValidator { |
||||
public Base64PasswordValidator() { |
||||
|
||||
} |
||||
public String encode(String originText) { |
||||
try { |
||||
return Base64.encode(originText.getBytes(ServerConfig.getInstance().getServerCharset())); |
||||
} catch (UnsupportedEncodingException var3) { |
||||
FineLoggerFactory.getLogger().debug(var3.getMessage()); |
||||
return ""; |
||||
} |
||||
} |
||||
} |
||||
@ -1,14 +0,0 @@
|
||||
package com.fr.decision.privilege.encrpt; |
||||
|
||||
import com.fr.security.SecurityToolbox; |
||||
|
||||
public class CustomSHA256PasswordValidator extends AbstractPasswordValidator { |
||||
public CustomSHA256PasswordValidator() { |
||||
} |
||||
|
||||
@Override |
||||
public String encode(String originUserName, String originPassword) { //把 用户名+密码 加密成 SHA256字符
|
||||
String unionPwd = originUserName + originPassword; |
||||
return SecurityToolbox.sha256(unionPwd); |
||||
} |
||||
} |
||||
@ -1,58 +0,0 @@
|
||||
package com.fr.demo; |
||||
|
||||
import com.fr.io.utils.ResourceIOUtils; |
||||
import com.fr.web.weblet.Formlet; |
||||
import com.fr.form.main.Form; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import java.io.InputStream; |
||||
import java.sql.Blob; |
||||
import java.sql.Connection; |
||||
import java.sql.DriverManager; |
||||
import java.sql.ResultSet; |
||||
import java.sql.Statement; |
||||
import java.util.Map; |
||||
|
||||
|
||||
|
||||
public class ReadfrmFromDatabase extends Formlet { |
||||
|
||||
|
||||
public Form createForm(HttpServletRequest reportletRequest) { |
||||
|
||||
Form form= new Form(); |
||||
String name = reportletRequest.getParameter("reportname").toString(); |
||||
try { |
||||
// 定义数据连接(根据你实际数据库信息进行修改)
|
||||
String driver = "com.mysql.jdbc.Driver"; |
||||
String url = "jdbc:mysql://localhost:3306/test"; |
||||
String user = "root"; |
||||
String pass = "123456"; |
||||
Class.forName(driver); |
||||
Connection conn = DriverManager.getConnection(url, user, pass); |
||||
// 从数据库中读模板
|
||||
String sql = "select B from report where A = '" + name |
||||
+ "'"; |
||||
Statement smt = conn.createStatement(); |
||||
ResultSet rs = smt.executeQuery(sql); |
||||
while (rs.next()) { |
||||
Blob blob = rs.getBlob(1); |
||||
FineLoggerFactory.getLogger().info(blob.toString()); |
||||
InputStream ins = blob.getBinaryStream(); |
||||
form.readStream(ins); |
||||
} |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
System.out.println(ResourceIOUtils.getRealPath("assets")); |
||||
return form; |
||||
} |
||||
|
||||
@Override |
||||
public void setParameterMap(Map<String, Object> arg0) { |
||||
// TODO Auto-generated method stub
|
||||
|
||||
} |
||||
|
||||
|
||||
} |
||||
@ -1,85 +0,0 @@
|
||||
package com.fr.demo; |
||||
|
||||
import com.fr.base.operator.common.CommonOperator; |
||||
import com.fr.chart.activator.ChartBaseActivator; |
||||
import com.fr.cluster.engine.activator.standalone.StandaloneModeActivator; |
||||
import com.fr.config.activator.BaseDBActivator; |
||||
import com.fr.config.activator.ConfigurationActivator; |
||||
import com.fr.env.operator.CommonOperatorImpl; |
||||
import com.fr.general.I18nResource; |
||||
import com.fr.health.activator.ModuleHealActivator; |
||||
import com.fr.io.ResourceRepositoryActivator; |
||||
import com.fr.module.Module; |
||||
import com.fr.module.tool.ActivatorToolBox; |
||||
import com.fr.report.ReportActivator; |
||||
import com.fr.report.RestrictionActivator; |
||||
import com.fr.report.module.ReportBaseActivator; |
||||
import com.fr.report.write.WriteActivator; |
||||
import com.fr.scheduler.SchedulerActivator; |
||||
import com.fr.store.StateServiceActivator; |
||||
import com.fr.workspace.simple.SimpleWork; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileInputStream; |
||||
import java.io.InputStream; |
||||
import java.sql.Connection; |
||||
import java.sql.DriverManager; |
||||
import java.sql.PreparedStatement; |
||||
|
||||
public class SaveReportToDatabase { |
||||
public static void main(String[] args) { |
||||
SaveReport(); |
||||
} |
||||
|
||||
private static void SaveReport() { |
||||
try { |
||||
// 定义报表运行环境,用于执行报表
|
||||
Module module = ActivatorToolBox.simpleLink(new BaseDBActivator(), |
||||
new ConfigurationActivator(), |
||||
new ResourceRepositoryActivator(), |
||||
new StandaloneModeActivator(), |
||||
new ModuleHealActivator(), |
||||
new StateServiceActivator(), |
||||
new ChartBaseActivator(), |
||||
new SchedulerActivator(), |
||||
new ReportBaseActivator(), |
||||
new RestrictionActivator(), |
||||
new ReportActivator(), |
||||
new WriteActivator()); |
||||
SimpleWork.supply(CommonOperator.class, new CommonOperatorImpl()); |
||||
String envpath = "//Applications//FineReport10_325//webapps//webroot//WEB-INF";//工程路径
|
||||
SimpleWork.checkIn(envpath); |
||||
I18nResource.getInstance(); |
||||
module.start(); |
||||
|
||||
|
||||
// 连接数据库
|
||||
String driver = "com.mysql.jdbc.Driver"; |
||||
String url = "jdbc:mysql://review.finedevelop.com:3306/susie"; |
||||
String user = "root"; |
||||
String pass = "ilovejava"; |
||||
Class.forName(driver); |
||||
Connection conn = DriverManager.getConnection(url, user, pass); //注意表名是否区分大小写
|
||||
conn.setAutoCommit(false); |
||||
PreparedStatement presmt = conn |
||||
.prepareStatement("INSERT INTO report VALUES(?,?)"); |
||||
|
||||
// 读进需要保存入库的模板文件
|
||||
File cptfile = new File(envpath |
||||
+ "//reportlets//GettingStarted.cpt"); |
||||
int lens = (int) cptfile.length(); |
||||
InputStream ins = new FileInputStream(cptfile); |
||||
// 将模板保存入库
|
||||
presmt.setString(1, "GettingStarted.cpt"); // 第一个字段存放模板相对路径
|
||||
presmt.setBinaryStream(2, ins, lens); // 第二个字段存放模板文件的二进制流
|
||||
presmt.execute(); |
||||
conn.commit(); |
||||
presmt.close(); |
||||
conn.close(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} finally { |
||||
SimpleWork.checkOut(); |
||||
} |
||||
} |
||||
} |
||||
@ -1,73 +0,0 @@
|
||||
package com.fr.demo; |
||||
|
||||
import com.fr.base.FRContext; |
||||
import com.fr.base.Utils; |
||||
import com.fr.cache.Attachment; |
||||
import com.fr.data.DefinedVerifyJob; |
||||
import com.fr.data.JobValue; |
||||
import com.fr.data.Verifier; |
||||
import com.fr.general.FArray; |
||||
import com.fr.script.Calculator; |
||||
import com.fr.log.FineLoggerFactory; |
||||
|
||||
public class VerifyJobDemo2 extends DefinedVerifyJob{ |
||||
/* |
||||
* 必须要定义此私有变量,变量名可改，表示校验状态 |
||||
* 0 表示校验成功，默认校验状态位为0 |
||||
* 1 表示校验失败 |
||||
*/ |
||||
private int type = 0; |
||||
|
||||
/** |
||||
* 当模板自定义事件增加的属性 名称与下面变量有对应时，则会自动赋值于此对应变量 |
||||
*/ |
||||
private JobValue file; // JobValue对应单元格
|
||||
private JobValue yesOrno; |
||||
// private int minnum; // 如果是非单元格，则对应具体类型值
|
||||
|
||||
public void doJob(Calculator calculator) throws Exception { |
||||
/* |
||||
* 如这边提供一个简单的判断来模拟执行过程 |
||||
* 校验规则为yesOrno等于1 并且 file 上传了附件：yesOrno == 1 && file 上传附件 |
||||
* 校验不通过,提示“请上传附件” |
||||
*/ |
||||
//这个是fr打印日志的接口，如果是设计器下的话 会在日志里看到对应的日志信息打印出来
|
||||
FRContext.getLogger().error("##### start verigy####"); |
||||
int yn = 0; |
||||
if(yesOrno.getValue() instanceof Integer){ //将单元格值转为整型以便用于比较
|
||||
yn = Integer.parseInt(yesOrno.getValue().toString()); |
||||
}else { |
||||
yn = Integer.parseInt(Utils.objectToString(yesOrno.getValue())); |
||||
} |
||||
FineLoggerFactory.getLogger().error("##### yn = "+yn +"####"); |
||||
if (yn == 1) { |
||||
//判断file是否有上传文件
|
||||
if (file.getValue() instanceof FArray && ((FArray) file.getValue()).length() > 0 |
||||
&& ((FArray) file.getValue()).elementAt(0) instanceof Attachment) { |
||||
type = 0; |
||||
} else { |
||||
type = 1; |
||||
} |
||||
} else { |
||||
type = 1; |
||||
} |
||||
} |
||||
|
||||
public String getMessage() { |
||||
// 根据校验状态是成功还是失败，设置校验失败的返回信息
|
||||
if(type == 1){ |
||||
return "请上传附件"; |
||||
} |
||||
return ""; |
||||
} |
||||
public Verifier.Status getType() { |
||||
// 返回校验状态
|
||||
return Verifier.Status.parse(type); |
||||
} |
||||
|
||||
public void doFinish(Calculator arg0) throws Exception { |
||||
// TODO Auto-generated method stub
|
||||
|
||||
} |
||||
|
||||
} |
||||
@ -1,67 +0,0 @@
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.script.AbstractFunction; |
||||
import com.fr.stable.Primitive; |
||||
import java.util.Date; |
||||
import java.util.regex.Matcher; |
||||
import java.util.regex.Pattern; |
||||
|
||||
public class DateDiff extends AbstractFunction |
||||
{ |
||||
private static final long serialVersionUID = -2863679010825725885L; |
||||
public String format = null; |
||||
private Long dif = Long.valueOf(0L); |
||||
|
||||
public Object run(Object[] paramArrayOfObject) |
||||
{ |
||||
try |
||||
{ |
||||
Long localLong1 = Long.valueOf(((Date)paramArrayOfObject[0]).getTime()); |
||||
Long localLong2 = Long.valueOf(((Date)paramArrayOfObject[1]).getTime()); |
||||
this.dif = Long.valueOf(localLong2.longValue() - localLong1.longValue()); |
||||
this.format = ((String)paramArrayOfObject[2]); |
||||
replace("((?i)y)", Long.valueOf(31536000000L)); |
||||
replace("((?i)q)", Long.valueOf(7776000000L)); |
||||
replace("M", Long.valueOf(2592000000L)); |
||||
replace("((?i)w)", Long.valueOf(604800000L)); |
||||
replace("((?i)d)", Long.valueOf(86400000L)); |
||||
replace("((?i)h)", Long.valueOf(3600000L)); |
||||
replace("m", Long.valueOf(60000L)); |
||||
replace("((?i)s)", Long.valueOf(1000L)); |
||||
try |
||||
{ |
||||
return Long.valueOf(Long.parseLong(this.format)); |
||||
} |
||||
catch (Exception localException2) |
||||
{ |
||||
return this.format; |
||||
} |
||||
} |
||||
catch (Exception localException1) |
||||
{ |
||||
} |
||||
return Primitive.ERROR_VALUE; |
||||
} |
||||
|
||||
public void replace(String paramString, Long paramLong) |
||||
{ |
||||
Pattern localPattern = Pattern.compile(paramString + "\\{\\d*?\\}"); |
||||
Matcher localMatcher = localPattern.matcher(this.format); |
||||
int i = (int)(this.dif.longValue() / paramLong.longValue()); |
||||
int j = 1; |
||||
while (localMatcher.find()) |
||||
{ |
||||
String str1 = localMatcher.group(); |
||||
str1 = str1.replaceAll(paramString + "\\{", ""); |
||||
str1 = str1.replaceAll("\\}", ""); |
||||
int k = Integer.parseInt(str1); |
||||
String str2 = String.format("%0" + k + "d", new Object[] { Integer.valueOf(i) }); |
||||
if (j != 0) |
||||
{ |
||||
j = 0; |
||||
this.dif = Long.valueOf(this.dif.longValue() - i * paramLong.longValue()); |
||||
} |
||||
this.format = this.format.replaceFirst(paramString + "\\{\\d*?\\}", str2); |
||||
} |
||||
} |
||||
} |
||||
@ -1,67 +0,0 @@
|
||||
package com.fr.function; |
||||
import com.fr.script.AbstractFunction; |
||||
import com.fr.stable.Primitive; |
||||
public class FlagHtmlColor extends AbstractFunction { |
||||
public Object run(Object[] args) { |
||||
String txt=""; |
||||
String color=""; |
||||
String flag=""; |
||||
if(null==args||args.length==0){ |
||||
return Primitive.ERROR_NAME; |
||||
}else if(args.length==1){ |
||||
txt=args[0].toString(); |
||||
color="red"; |
||||
flag="N"; |
||||
}else if(args.length==2){ |
||||
txt=args[0].toString(); |
||||
color=args[1].toString(); |
||||
flag="N"; |
||||
}else{ |
||||
txt=args[0].toString(); |
||||
color=args[1].toString(); |
||||
flag=args[2].toString(); |
||||
} |
||||
String result=getHtmlStr(txt, color, flag); |
||||
return result; |
||||
} |
||||
public String getHtmlStr(String txt,String color,String flag){ |
||||
String starthtml="<font color='"+color+"'>"; |
||||
String endhtml="</font>"; |
||||
StringBuffer sb=new StringBuffer(); |
||||
int len=txt.length(); |
||||
if("N".equalsIgnoreCase(flag)){//数字
|
||||
for(int i=0;i<len;i++){ |
||||
char c=txt.charAt(i); |
||||
if(c>='0'&&c<='9'){ |
||||
String str=starthtml+c+endhtml; |
||||
sb.append(str); |
||||
}else{ |
||||
sb.append(c); |
||||
} |
||||
} |
||||
}else if("C".equalsIgnoreCase(flag)){//字母
|
||||
for(int i=0;i<len;i++){ |
||||
char c=txt.charAt(i); |
||||
if((c>='a'&&c<='z')||(c>='A'&&c<='Z')){ |
||||
String str=starthtml+c+endhtml; |
||||
sb.append(str); |
||||
}else{ |
||||
sb.append(c); |
||||
} |
||||
} |
||||
} else if("Z".equalsIgnoreCase(flag)){//中文
|
||||
for(int i=0;i<len;i++){ |
||||
char c=txt.charAt(i); |
||||
if(c >= 0x4E00 && c <= 0x9FA5){ |
||||
String str=starthtml+c+endhtml; |
||||
sb.append(str); |
||||
}else{ |
||||
sb.append(c); |
||||
} |
||||
} |
||||
}else{ |
||||
return txt; |
||||
} |
||||
return sb.toString(); |
||||
} |
||||
} |
||||
@ -1,23 +0,0 @@
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.script.AbstractFunction; |
||||
|
||||
import java.net.InetAddress; |
||||
|
||||
public class GETIP extends AbstractFunction { |
||||
|
||||
@Override |
||||
public Object run(Object[] objects) { |
||||
try { |
||||
InetAddress ia = InetAddress.getLocalHost(); |
||||
return ia.getHostAddress(); |
||||
} catch (Exception e) { |
||||
return e.getMessage(); |
||||
|
||||
} |
||||
} |
||||
|
||||
public static InetAddress getInetAddress() { |
||||
return null; |
||||
} |
||||
} |
||||
@ -1,152 +0,0 @@
|
||||
package com.fr.function; |
||||
|
||||
import java.math.BigDecimal; |
||||
|
||||
import com.fr.general.FArray; |
||||
import com.fr.general.GeneralUtils; |
||||
import com.fr.script.AbstractFunction; |
||||
|
||||
public class IRR extends AbstractFunction { |
||||
|
||||
private static final long serialVersionUID = 7634415917398642321L; |
||||
private static final String ERROR_VALUE = "#NUM!"; |
||||
|
||||
|
||||
@Override |
||||
public Object run(Object[] args) { |
||||
try{ |
||||
if(1 == args.length){ |
||||
return run( transArr( (FArray) args[0] ) ); |
||||
}else if(2 == args.length){ |
||||
return run( transArr( (FArray) args[0] ), trans( args[1] ) ); |
||||
} |
||||
}catch(Exception e){ |
||||
System.out.println(e); |
||||
} |
||||
return ERROR_VALUE; |
||||
} |
||||
|
||||
/** |
||||
* 将其他类型的数字转换为大数（保证精度） |
||||
* @param ele |
||||
* @return |
||||
*/ |
||||
private static BigDecimal trans(Object ele){ |
||||
try{ |
||||
String val = GeneralUtils.objectToString(ele); |
||||
return new BigDecimal(val); |
||||
}catch(Exception e){ |
||||
|
||||
} |
||||
return (BigDecimal) ele; |
||||
} |
||||
|
||||
/** |
||||
* 将数组转换为大数数组 |
||||
* @param in |
||||
* @return |
||||
*/ |
||||
private static FArray<BigDecimal> transArr(FArray in){ |
||||
FArray<BigDecimal> rt = new FArray<BigDecimal>(); |
||||
for(int i=0;i<in.length();i++){ |
||||
Object ele = in.elementAt(i); |
||||
rt.add(trans(ele)); |
||||
} |
||||
return rt; |
||||
} |
||||
|
||||
|
||||
private static BigDecimal run(FArray<BigDecimal> cashflow){ |
||||
return run( cashflow, new BigDecimal(0.1d) ); |
||||
} |
||||
|
||||
private static BigDecimal run(FArray<BigDecimal> cashflow,BigDecimal guess){ |
||||
BigDecimal maxrate = initRateMax(cashflow,guess); |
||||
BigDecimal minrate = initRateMin(cashflow,guess); |
||||
for( int i=0; i<Init_Max_Loop; i++ ){ |
||||
BigDecimal testrate = minrate.add(maxrate).divide( new BigDecimal(2d) ); |
||||
BigDecimal npv = NPV( cashflow, testrate ); |
||||
if( npv.abs().compareTo(Accuracy) == LESS ){ |
||||
guess = testrate; |
||||
break; |
||||
}else if( npv.compareTo(ZERO) == LESS ){ |
||||
minrate = testrate; |
||||
}else{ |
||||
maxrate = testrate; |
||||
} |
||||
} |
||||
//保留16位小数（足够精度）
|
||||
return guess.setScale(16,BigDecimal.ROUND_HALF_UP); |
||||
} |
||||
|
||||
//最小精度
|
||||
private static final BigDecimal Accuracy = new BigDecimal(0.00000001d); |
||||
//最大循环次数，excel用的是20次，不过精度只到小数点后两位，而且不一定一定能算出值，为了尽可能保证算出结果，我增加到100次，
|
||||
private static final int Init_Max_Loop = 100; |
||||
|
||||
private static final BigDecimal ZERO = new BigDecimal(0); |
||||
private static final BigDecimal ONE = new BigDecimal(1); |
||||
private static final BigDecimal Z005 = new BigDecimal(0.005d); |
||||
private static final BigDecimal Z2 = new BigDecimal(0.2d); |
||||
|
||||
private static final int GREATER = 1; |
||||
private static final int LESS = -1; |
||||
|
||||
/** |
||||
* 生成一个使NPV为负数的R作为内部收益率下限值 |
||||
* @param cashflow |
||||
* @param guess |
||||
* @return |
||||
*/ |
||||
private static BigDecimal initRateMin(FArray<BigDecimal> cashflow,BigDecimal guess){ |
||||
for( int i=0; i<Init_Max_Loop; i++ ){ |
||||
BigDecimal npv = NPV( cashflow, guess ); |
||||
|
||||
if( npv.compareTo(ZERO) == LESS ){ |
||||
return guess; |
||||
} |
||||
BigDecimal step = guess.abs().multiply( Z2 ); |
||||
guess = guess.add( step.compareTo( Z005 ) == LESS ? Z005 : step ); |
||||
} |
||||
return guess; |
||||
} |
||||
|
||||
/** |
||||
* 生成一个使NPV为正数的R作为内部收益率的上限制 |
||||
* @param cashflow |
||||
* @param guess |
||||
* @return |
||||
*/ |
||||
private static BigDecimal initRateMax(FArray<BigDecimal> cashflow,BigDecimal guess){ |
||||
for( int i=0; i<Init_Max_Loop; i++ ){ |
||||
BigDecimal npv = NPV( cashflow, guess ); |
||||
|
||||
if( npv.compareTo(ZERO) == GREATER ){ |
||||
return guess; |
||||
} |
||||
BigDecimal step = guess.abs().multiply( Z2 ); |
||||
guess = guess.subtract( step.compareTo( Z005 ) == LESS ? Z005 : step ); |
||||
} |
||||
return guess; |
||||
} |
||||
|
||||
/** |
||||
* 算NPV |
||||
* @param cashflow |
||||
* @param rate |
||||
* @return |
||||
*/ |
||||
private static BigDecimal NPV(FArray<BigDecimal> cashflow,BigDecimal rate){ |
||||
BigDecimal npv = ZERO; |
||||
BigDecimal rpowj = ONE;//(1+r)^0
|
||||
BigDecimal radd1 = rate.add(ONE);//1+r
|
||||
for( int j=0; j<cashflow.length(); j++ ){ |
||||
BigDecimal valuej = cashflow.elementAt(j); |
||||
npv = npv.add( valuej.divide( rpowj, 10, BigDecimal.ROUND_HALF_DOWN ) );// vj / (1+r)^j
|
||||
rpowj = rpowj.multiply(radd1); // (1+r)^j
|
||||
//npv += cashflow.elementAt(j) / Math.pow( 1+rate, j );
|
||||
} |
||||
return npv; |
||||
} |
||||
|
||||
} |
||||
@ -1,15 +0,0 @@
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.script.AbstractFunction; |
||||
|
||||
public class StringCat extends AbstractFunction { |
||||
public Object run(Object[] args) { |
||||
String result = ""; |
||||
Object para; |
||||
for (int i = 0; i < args.length; i++) { |
||||
para = args[i]; |
||||
result += para.toString(); |
||||
} |
||||
return result; |
||||
} |
||||
} |
||||
@ -1,59 +0,0 @@
|
||||
//图片在下文字在上
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.base.GraphHelper; |
||||
import com.fr.data.core.db.BinaryObject; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.script.AbstractFunction; |
||||
import com.fr.stable.CoreGraphHelper; |
||||
import javax.imageio.ImageIO; |
||||
import java.awt.Graphics2D; |
||||
import java.awt.Image; |
||||
import java.awt.image.BufferedImage; |
||||
import java.io.IOException; |
||||
|
||||
|
||||
/** |
||||
* 图片在下文字在上 |
||||
*/ |
||||
public class StringImage extends AbstractFunction { |
||||
@Override |
||||
public Object run(Object[] args) { |
||||
Image result = null; |
||||
int p = 0; |
||||
Object[] ob = new Object[2]; |
||||
for (int i = 0; (i < args.length && p <= 1); i++) { |
||||
if (args[i] == null) { |
||||
continue; |
||||
} |
||||
ob[p] = args[i]; |
||||
p++; |
||||
|
||||
} |
||||
|
||||
if (ob[1] instanceof BinaryObject) { |
||||
BinaryObject binaryObject = (BinaryObject) ob[1]; |
||||
try { |
||||
result = initStringImage((String) ob[0], ImageIO.read(binaryObject.getInputStream())); |
||||
} catch (IOException e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} else if (ob[1] instanceof Image) { |
||||
result = initStringImage((String) ob[0], (Image) ob[1]); |
||||
} else { |
||||
FineLoggerFactory.getLogger().warn("Unsupported type of " + ob[1].getClass()); |
||||
} |
||||
|
||||
return result; |
||||
} |
||||
|
||||
private Image initStringImage(String name, Image image) { |
||||
BufferedImage splashBuffedImage = CoreGraphHelper.toBufferedImage(image); |
||||
Graphics2D splashG2d = splashBuffedImage.createGraphics(); |
||||
double centerX = 25; |
||||
double centerY = 25; |
||||
GraphHelper.drawString(splashG2d, name, centerX, centerY); |
||||
return splashBuffedImage; |
||||
} |
||||
|
||||
} |
||||
@ -1,126 +0,0 @@
|
||||
//
|
||||
// Source code recreated from a .class file by IntelliJ IDEA
|
||||
// (powered by Fernflower decompiler)
|
||||
//
|
||||
|
||||
package com.fr.function; |
||||
|
||||
import com.fr.base.BaseUtils; |
||||
import com.fr.base.SynchronizedLiveDataModelUtils; |
||||
import com.fr.data.impl.RecursionDataModel; |
||||
import com.fr.general.FArray; |
||||
import com.fr.general.GeneralUtils; |
||||
import com.fr.general.data.DataModel; |
||||
import com.fr.invoke.Reflect; |
||||
import com.fr.script.AbstractFunction; |
||||
import com.fr.script.Calculator; |
||||
import com.fr.security.function.RestrictScript; |
||||
import com.fr.stable.Primitive; |
||||
import com.fr.stable.StringUtils; |
||||
import com.fr.stable.exception.FormulaException; |
||||
|
||||
import java.util.Map; |
||||
|
||||
@RestrictScript |
||||
public class TREENODEFINDER extends AbstractFunction { |
||||
public TREENODEFINDER() { |
||||
} |
||||
|
||||
public Object run(Object[] args) throws FormulaException { |
||||
if (!this.validateArgs(args)) { |
||||
return Primitive.ERROR_NAME; |
||||
} else { |
||||
boolean noLiveDataModel = !this.liveDataModel4ShareExists(); |
||||
DataModel dataModel = this.generateDataModel(args); |
||||
|
||||
try { |
||||
if (args.length != 2) { |
||||
return Primitive.NULL; |
||||
} |
||||
if (args[0] instanceof FArray) { |
||||
FArray nodeArray = (FArray) args[0]; |
||||
FArray result = new FArray(); |
||||
for (int i = 0; i < nodeArray.length(); i++) { |
||||
result.simpleAdd(this.run(GeneralUtils.objectToString(nodeArray.elementAt(i)), dataModel)); |
||||
} |
||||
return result; |
||||
} else { |
||||
return this.run(GeneralUtils.objectToString(args[0]), dataModel); |
||||
} |
||||
} finally { |
||||
if (noLiveDataModel && dataModel != null) { |
||||
try { |
||||
dataModel.release(); |
||||
} catch (Exception var11) { |
||||
this.log(var11.getMessage(), var11); |
||||
} |
||||
} |
||||
|
||||
} |
||||
} |
||||
} |
||||
|
||||
private boolean liveDataModel4ShareExists() { |
||||
Calculator calculatorProvider = this.getCalculator(); |
||||
if (calculatorProvider == null) { |
||||
return false; |
||||
} else { |
||||
Map var1 = (Map) calculatorProvider.getAttribute(SynchronizedLiveDataModelUtils.CUR_LIVE_RS); |
||||
return var1 != null && !var1.isEmpty(); |
||||
} |
||||
} |
||||
|
||||
public Object run(String nodeValue, DataModel dataModel) { |
||||
try { |
||||
RecursionDataModel rdm = Reflect.on(dataModel).get("dataModel"); |
||||
int treeStart = 0; |
||||
|
||||
int m; |
||||
for (m = 0; m < rdm.getColumnCount(); ++m) { |
||||
String colName = rdm.getColumnName(m); |
||||
if (colName.startsWith("FR_GEN_")) { |
||||
treeStart = m; |
||||
break; |
||||
} |
||||
} |
||||
|
||||
m = 0; |
||||
|
||||
for (int len = rdm.getRowCount(); m < len; ++m) { |
||||
int i = 0; |
||||
|
||||
for (int colCount = rdm.getColumnCount(); i < colCount; ++i) { |
||||
String value = GeneralUtils.objectToString(rdm.getValueAt(m, i)); |
||||
if (StringUtils.equals(nodeValue, value)) { |
||||
FArray array = new FArray(); |
||||
|
||||
for (int j = treeStart; j < colCount; ++j) { |
||||
String val = GeneralUtils.objectToString(rdm.getValueAt(m, j)); |
||||
if (StringUtils.isNotEmpty(val)) { |
||||
array.add(val); |
||||
} |
||||
} |
||||
|
||||
return array; |
||||
} |
||||
} |
||||
} |
||||
} catch (Exception var13) { |
||||
this.log(var13.getMessage(), var13); |
||||
} |
||||
|
||||
return Primitive.NULL; |
||||
} |
||||
|
||||
public boolean validateArgs(Object[] args) { |
||||
return args != null && args.length >= 1; |
||||
} |
||||
|
||||
public DataModel generateDataModel(Object[] args) { |
||||
return BaseUtils.getDataModelFromTableDataName(this.getCalculator(), args[1].toString()); |
||||
} |
||||
|
||||
public Type getType() { |
||||
return REPORT; |
||||
} |
||||
} |
||||
@ -1,115 +0,0 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.TableData; |
||||
import com.fr.base.operator.common.CommonOperator; |
||||
import com.fr.chart.activator.ChartBaseActivator; |
||||
import com.fr.cluster.engine.activator.standalone.StandaloneModeActivator; |
||||
import com.fr.config.activator.BaseDBActivator; |
||||
import com.fr.config.activator.ConfigurationActivator; |
||||
import com.fr.data.impl.DBTableData; |
||||
import com.fr.data.impl.NameDatabaseConnection; |
||||
import com.fr.env.operator.CommonOperatorImpl; |
||||
import com.fr.general.I18nResource; |
||||
import com.fr.general.data.TableDataColumn; |
||||
import com.fr.health.activator.ModuleHealActivator; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.module.Module; |
||||
import com.fr.module.tool.ActivatorToolBox; |
||||
import com.fr.report.ReportActivator; |
||||
import com.fr.report.RestrictionActivator; |
||||
import com.fr.report.cell.DefaultTemplateCellElement; |
||||
import com.fr.report.cell.TemplateCellElement; |
||||
import com.fr.report.cell.cellattr.core.group.DSColumn; |
||||
import com.fr.report.module.ReportBaseActivator; |
||||
import com.fr.report.worksheet.WorkSheet; |
||||
import com.fr.report.write.WriteActivator; |
||||
import com.fr.scheduler.SchedulerActivator; |
||||
import com.fr.store.StateServiceActivator; |
||||
import com.fr.workspace.simple.SimpleWork; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
import java.util.HashMap; |
||||
|
||||
public class CreateGenericTemplate { |
||||
public static void main(String[] args) throws Exception { |
||||
// 首先需要定义执行所在的环境，这样才能正确读取数据库信息
|
||||
// 定义报表运行环境,用于执行报表
|
||||
Module module = ActivatorToolBox.simpleLink(new BaseDBActivator(), |
||||
new ConfigurationActivator(), |
||||
new ResourceRepositoryActivator(), |
||||
new StandaloneModeActivator(), |
||||
new ModuleHealActivator(), |
||||
new StateServiceActivator(), |
||||
new ChartBaseActivator(), |
||||
new SchedulerActivator(), |
||||
new ReportBaseActivator(), |
||||
new RestrictionActivator(), |
||||
new ReportActivator(), |
||||
new WriteActivator()); |
||||
SimpleWork.supply(CommonOperator.class, new CommonOperatorImpl()); |
||||
String envpath = "//Applications//FineReport10_325//webapps//webroot//WEB-INF";//工程路径
|
||||
SimpleWork.checkIn(envpath); |
||||
I18nResource.getInstance(); |
||||
module.start(); |
||||
|
||||
|
||||
WorkBook wb = new WorkBook(); |
||||
//添加新的模板数据集
|
||||
TableData td = genericTableData("FRDemo", "SELECT * FROM Equipment"); |
||||
wb.putTableData("公司信息", td); |
||||
//创建第一个report 也就是sheet页
|
||||
WorkSheet report = new WorkSheet(); |
||||
wb.addReport(report); |
||||
//数据库暂时先不读，弄点假数据
|
||||
HashMap<Integer, String> map = new HashMap<Integer, String>(); |
||||
map.put(0, "Company"); |
||||
map.put(1, "Tel"); |
||||
//添加列头
|
||||
DefaultTemplateCellElement title = genericCell(0, 0, null, "这是标题"); |
||||
title.setRowSpan(2); |
||||
title.setColumnSpan(2); |
||||
report.addCellElement(title); |
||||
//添加数据列
|
||||
for (Integer key : map.keySet()) { |
||||
TemplateCellElement cellHeaer = genericCell(2, key, null, map.get(key)); |
||||
report.addCellElement(cellHeaer); |
||||
TemplateCellElement cell = genericCell(3, key, "公司信息", map.get(key)); |
||||
report.addCellElement(cell); |
||||
} |
||||
//导出模板
|
||||
FileOutputStream outputStream = new FileOutputStream(new File("//Users//susie//Downloads//company.cpt")); |
||||
wb.export(outputStream); |
||||
outputStream.close(); |
||||
module.stop(); |
||||
System.out.println("finished"); |
||||
} |
||||
/* |
||||
*生成TableData |
||||
*/ |
||||
private static TableData genericTableData(String conString, String sqlQuery) { |
||||
NameDatabaseConnection database = new NameDatabaseConnection(conString); |
||||
TableData td = new DBTableData(database, sqlQuery); |
||||
return td; |
||||
} |
||||
/** |
||||
* 添加单元格 |
||||
* row 行号 |
||||
* column 列号 |
||||
* dsName 数据集名称 如 ds1 |
||||
* 数据列名称如 ds1中的id列，则输入 id |
||||
*/ |
||||
private static DefaultTemplateCellElement genericCell(int row, int column, String dsName, String columnName) { |
||||
DefaultTemplateCellElement dtCell = new DefaultTemplateCellElement(row, column); |
||||
if (dsName != null) { |
||||
DSColumn dsColumn = new DSColumn(); |
||||
dsColumn.setDSName(dsName); |
||||
dsColumn.setColumn(TableDataColumn.createColumn(columnName)); |
||||
dtCell.setValue(dsColumn); |
||||
} else { |
||||
dtCell.setValue(columnName); |
||||
} |
||||
return dtCell; |
||||
} |
||||
} |
||||
//自动执行存储过程，从里面获取结果集结的部分等研究一下jdbc再补
|
||||
@ -1,61 +0,0 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.operator.common.CommonOperator; |
||||
import com.fr.chart.activator.ChartBaseActivator; |
||||
import com.fr.cluster.engine.activator.standalone.StandaloneModeActivator; |
||||
import com.fr.config.activator.BaseDBActivator; |
||||
import com.fr.config.activator.ConfigurationActivator; |
||||
import com.fr.env.operator.CommonOperatorImpl; |
||||
import com.fr.general.I18nResource; |
||||
import com.fr.health.activator.ModuleHealActivator; |
||||
import com.fr.io.importer.Excel2007ReportImporter; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.module.Module; |
||||
import com.fr.module.tool.ActivatorToolBox; |
||||
import com.fr.report.ReportActivator; |
||||
import com.fr.report.RestrictionActivator; |
||||
import com.fr.report.module.ReportBaseActivator; |
||||
import com.fr.report.write.WriteActivator; |
||||
import com.fr.scheduler.SchedulerActivator; |
||||
import com.fr.store.StateServiceActivator; |
||||
import com.fr.workspace.simple.SimpleWork; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileInputStream; |
||||
import java.io.FileOutputStream; |
||||
import java.io.OutputStream; |
||||
|
||||
public class ExcelToCpt { |
||||
public static void main(String[] args) throws Exception { |
||||
// 首先需要定义执行所在的环境，这样才能正确读取数据库信息
|
||||
// 定义报表运行环境,用于执行报表
|
||||
Module module = ActivatorToolBox.simpleLink(new BaseDBActivator(), |
||||
new ConfigurationActivator(), |
||||
new ResourceRepositoryActivator(), |
||||
new StandaloneModeActivator(), |
||||
new ModuleHealActivator(), |
||||
new StateServiceActivator(), |
||||
new ChartBaseActivator(), |
||||
new SchedulerActivator(), |
||||
new ReportBaseActivator(), |
||||
new RestrictionActivator(), |
||||
new ReportActivator(), |
||||
new WriteActivator()); |
||||
SimpleWork.supply(CommonOperator.class, new CommonOperatorImpl()); |
||||
String envpath = "//Applications//FineReport10_325//webapps//webroot//WEB-INF";//工程路径
|
||||
SimpleWork.checkIn(envpath); |
||||
I18nResource.getInstance(); |
||||
module.start(); |
||||
|
||||
|
||||
File excelFile = new File("//Users//susie//Downloads//aa.xlsx"); // 获取EXCEL文件
|
||||
FileInputStream a = new FileInputStream(excelFile); |
||||
|
||||
TemplateWorkBook tpl = new Excel2007ReportImporter().generateWorkBookByStream(a); |
||||
OutputStream outputStream = new FileOutputStream(new File("//Users//susie//Downloads//abc.cpt")); // 转换成cpt模板
|
||||
((WorkBook) tpl).export(outputStream); |
||||
outputStream.close(); |
||||
module.stop(); |
||||
} |
||||
} |
||||
@ -1,75 +0,0 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.operator.common.CommonOperator; |
||||
import com.fr.chart.activator.ChartBaseActivator; |
||||
import com.fr.cluster.engine.activator.standalone.StandaloneModeActivator; |
||||
import com.fr.config.activator.BaseDBActivator; |
||||
import com.fr.config.activator.ConfigurationActivator; |
||||
import com.fr.env.operator.CommonOperatorImpl; |
||||
import com.fr.general.I18nResource; |
||||
import com.fr.health.activator.ModuleHealActivator; |
||||
import com.fr.io.exporter.ExcelExporter; |
||||
import com.fr.main.TemplateWorkBook; |
||||
import com.fr.main.workbook.ResultWorkBook; |
||||
import com.fr.module.Module; |
||||
import com.fr.module.tool.ActivatorToolBox; |
||||
import com.fr.report.ReportActivator; |
||||
import com.fr.report.RestrictionActivator; |
||||
import com.fr.report.module.ReportBaseActivator; |
||||
import com.fr.report.write.WriteActivator; |
||||
import com.fr.scheduler.SchedulerActivator; |
||||
import com.fr.stable.WriteActor; |
||||
import com.fr.store.StateServiceActivator; |
||||
import com.fr.workspace.simple.SimpleWork; |
||||
|
||||
import java.io.File; |
||||
import java.io.FileOutputStream; |
||||
|
||||
|
||||
public class ExcuteDemo { |
||||
public static void main(String[] args) { |
||||
try { |
||||
// 首先需要定义执行所在的环境，这样才能正确读取数据库信息
|
||||
// 定义报表运行环境,用于执行报表
|
||||
Module module = ActivatorToolBox.simpleLink(new BaseDBActivator(), |
||||
new ConfigurationActivator(), |
||||
new ResourceRepositoryActivator(), |
||||
new StandaloneModeActivator(), |
||||
new ModuleHealActivator(), |
||||
new StateServiceActivator(), |
||||
new ChartBaseActivator(), |
||||
new SchedulerActivator(), |
||||
new ReportBaseActivator(), |
||||
new RestrictionActivator(), |
||||
new ReportActivator(), |
||||
new WriteActivator()); |
||||
SimpleWork.supply(CommonOperator.class, new CommonOperatorImpl()); |
||||
String envpath = "//Applications//FineReport10_325//webapps//webroot//WEB-INF";//工程路径
|
||||
SimpleWork.checkIn(envpath); |
||||
I18nResource.getInstance(); |
||||
module.start(); |
||||
|
||||
|
||||
// 读取模板
|
||||
TemplateWorkBook workbook = TemplateWorkBookIO.readTemplateWorkBook("//doc//Primary//Parameter//Parameter.cpt"); |
||||
/* |
||||
* 生成参数map，注入参数与对应的值，用于执行报表 该模板中只有一个参数地区，给其赋值华北 |
||||
* 若参数在发送请求时传过来，可以通过req.getParameter(name)获得 |
||||
* 获得的参数put进map中，paraMap.put(paraname,paravalue) |
||||
*/ |
||||
java.util.Map paraMap = new java.util.HashMap(); |
||||
paraMap.put("地区", "华北"); |
||||
// 使用paraMap执行生成结果
|
||||
ResultWorkBook result = workbook.execute(paraMap, new WriteActor()); |
||||
// 使用结果如导出至excel
|
||||
FileOutputStream outputStream = new FileOutputStream(new File( |
||||
"//Users//susie//Downloads//Parameter.xls")); |
||||
ExcelExporter excelExporter = new ExcelExporter(); |
||||
excelExporter.export(outputStream,result); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} finally { |
||||
SimpleWork.checkOut(); |
||||
} |
||||
} |
||||
} |
||||
@ -1,160 +0,0 @@
|
||||
package com.fr.io; |
||||
|
||||
import com.fr.base.operator.common.CommonOperator; |
||||
import com.fr.chart.activator.ChartBaseActivator; |
||||
import com.fr.cluster.engine.activator.standalone.StandaloneModeActivator; |
||||
import com.fr.config.activator.BaseDBActivator; |
||||
import com.fr.config.activator.ConfigurationActivator; |
||||
import com.fr.env.operator.CommonOperatorImpl; |
||||
import com.fr.general.I18nResource; |
||||
import com.fr.general.log.Log4jConfig; |
||||
import com.fr.general.log.parser.ExtraPatternParserManager; |
||||
import com.fr.health.activator.ModuleHealActivator; |
||||
import com.fr.io.exporter.CSVExporter; |
||||
import com.fr.io.exporter.EmbeddedTableDataExporter; |
||||
import com.fr.io.exporter.ExcelExporter; |
||||
import com.fr.io.exporter.ImageExporter; |
||||
import com.fr.io.exporter.PDFExporter; |
||||
import com.fr.io.exporter.SVGExporter; |
||||
import com.fr.io.exporter.TextExporter; |
||||
import com.fr.io.exporter.WordExporter; |
||||
import com.fr.io.exporter.excel.stream.StreamExcel2007Exporter; |
||||
import com.fr.main.impl.WorkBook; |
||||
import com.fr.module.tool.ActivatorToolBox; |
||||
import com.fr.report.ReportActivator; |
||||
import com.fr.report.RestrictionActivator; |
||||
import com.fr.report.module.ReportBaseActivator; |
||||
import com.fr.report.write.WriteActivator; |
||||
import com.fr.scheduler.SchedulerActivator; |
||||
import com.fr.stable.WriteActor; |
||||
import com.fr.stable.resource.ResourceLoader; |
||||
import com.fr.store.StateServiceActivator; |
||||
import com.fr.third.apache.log4j.Level; |
||||
import com.fr.third.apache.log4j.PropertyConfigurator; |
||||
import com.fr.workspace.simple.SimpleWork; |
||||
|
||||
import java.io.FileOutputStream; |
||||
import java.io.IOException; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
import java.util.Properties; |
||||
|
||||
|
||||
public class ExportApi { |
||||
|
||||
public static void main(String[] args) { |
||||
|
||||
initLog4j(); |
||||
|
||||
/**定义报表运行环境,用于执行报表*/ |
||||
com.fr.module.Module module = ActivatorToolBox.simpleLink(new BaseDBActivator(), |
||||
new ConfigurationActivator(), |
||||
new ResourceRepositoryActivator(), |
||||
new StandaloneModeActivator(), |
||||
new ModuleHealActivator(), |
||||
//2020.4.26jar包之前的版本，替换成StateServerActivator()
|
||||
new StateServiceActivator(), |
||||
new SchedulerActivator(), |
||||
new ReportBaseActivator(), |
||||
new RestrictionActivator(), |
||||
new ReportActivator(), |
||||
new WriteActivator(), |
||||
new ChartBaseActivator()); |
||||
SimpleWork.supply(CommonOperator.class, new CommonOperatorImpl()); |
||||
//定义工程路径
|
||||
String envpath = "D:\\javatools\\FineReport_10.0\\webapps\\webroot\\WEB-INF\\"; |
||||
SimpleWork.checkIn(envpath); |
||||
I18nResource.getInstance(); |
||||
module.start(); |
||||
|
||||
/**输出模板*/ |
||||
try { |
||||
// 定义输出的模板路径，以reportlets为根目录
|
||||
WorkBook workbook = (WorkBook) TemplateWorkBookIO.readTemplateWorkBook("GettingStarted.cpt"); |
||||
// 设置传入的参数
|
||||
Map parameterMap = new HashMap(); |
||||
parameterMap.put("地区","华东"); |
||||
|
||||
// 定义输出流
|
||||
FileOutputStream outputStream; |
||||
String outputUrl="F:\\io\\WorkBook\\"; |
||||
|
||||
/**将模板工作薄导出为内置数据集模板文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"EmbExport.cpt")); |
||||
EmbeddedTableDataExporter templateExporter = new EmbeddedTableDataExporter(); |
||||
templateExporter.export(outputStream, workbook); |
||||
|
||||
/**将模板工作薄导出为模板文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"TmpExport.cpt")); |
||||
((WorkBook) workbook).export(outputStream); |
||||
|
||||
/**将结果工作薄导出为2003Excel文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"ExcelExport2003.xls")); |
||||
ExcelExporter ExcelExport = new ExcelExporter(); |
||||
ExcelExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为2007Excel文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"ExcelExport2007.xlsx")); |
||||
StreamExcel2007Exporter ExcelExport1 = new StreamExcel2007Exporter(); |
||||
ExcelExport1.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为Word文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"WordExport.doc")); |
||||
WordExporter WordExport = new WordExporter(); |
||||
WordExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为Pdf文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"PdfExport.pdf")); |
||||
PDFExporter PdfExport = new PDFExporter(); |
||||
PdfExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为Txt文件（txt文件本身不支持表格、图表等，被导出模板一般为明细表）*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"TxtExport.txt")); |
||||
TextExporter TxtExport = new TextExporter(); |
||||
TxtExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为Csv文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"CsvExport.csv")); |
||||
CSVExporter CsvExport = new CSVExporter(); |
||||
CsvExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为SVG文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"SvgExport.svg")); |
||||
SVGExporter SvgExport = new SVGExporter(); |
||||
SvgExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
/**将结果工作薄导出为image文件*/ |
||||
outputStream = new FileOutputStream(new java.io.File(outputUrl+"PngExport.png")); |
||||
ImageExporter ImageExport = new ImageExporter(); |
||||
ImageExport.export(outputStream, workbook.execute(parameterMap, new WriteActor())); |
||||
|
||||
outputStream.close(); |
||||
module.stop(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} finally { |
||||
SimpleWork.checkOut(); |
||||
} |
||||
} |
||||
|
||||
private static void initLog4j() { |
||||
|
||||
PropertyConfigurator.configure(loadLog4jPropertiesFromJar(Level.toLevel("INFO"))); |
||||
} |
||||
|
||||
private static Properties loadLog4jPropertiesFromJar(Level level) { |
||||
|
||||
Properties properties = new Properties(); |
||||
|
||||
System.setProperty("LOG_HOME", System.getProperty("user.dir")); |
||||
System.setProperty("LOG_ROOT_LEVEL", level.toString()); |
||||
ExtraPatternParserManager.setSystemProperty(); |
||||
try { |
||||
properties.load(ResourceLoader.getResourceAsStream("/com/fr/general/log/log4j.properties", Log4jConfig.class)); |
||||
} catch (IOException ignore) { |
||||
//do nothing
|
||||
} |
||||
|
||||
return properties; |
||||
} |
||||
} |
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue