FormulaUtils.java 78 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797
  1. package com.mixsmart.utils;
  2. import cn.hutool.core.date.DatePattern;
  3. import cn.hutool.core.date.DateTime;
  4. import cn.hutool.log.StaticLog;
  5. import com.alibaba.fastjson.JSON;
  6. import com.alibaba.fastjson.JSONArray;
  7. import com.alibaba.fastjson.JSONObject;
  8. import com.alibaba.fastjson.annotation.JSONField;
  9. import com.itextpdf.text.pdf.PdfReader;
  10. import com.itextpdf.text.pdf.parser.*;
  11. import com.jfireel.expression.Expression;
  12. import org.apache.commons.lang.math.NumberUtils;
  13. import org.apache.http.*;
  14. import org.apache.http.client.HttpClient;
  15. import org.apache.http.client.entity.UrlEncodedFormEntity;
  16. import org.apache.http.client.methods.HttpGet;
  17. import org.apache.http.client.methods.HttpPost;
  18. import org.apache.http.entity.StringEntity;
  19. import org.apache.http.impl.client.HttpClientBuilder;
  20. import org.apache.http.impl.client.HttpClients;
  21. import org.apache.http.message.BasicNameValuePair;
  22. import org.apache.http.util.EntityUtils;
  23. import org.apache.poi.hssf.usermodel.HSSFDataFormatter;
  24. import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
  25. import org.apache.poi.ss.usermodel.*;
  26. import java.awt.Color;
  27. import org.jfree.chart.ChartFactory;
  28. import org.jfree.chart.ChartPanel;
  29. import org.jfree.chart.ChartUtils;
  30. import org.jfree.chart.JFreeChart;
  31. import org.jfree.chart.axis.*;
  32. import org.jfree.chart.plot.*;
  33. import org.jfree.chart.renderer.category.BarRenderer;
  34. import org.jfree.chart.renderer.category.LineAndShapeRenderer;
  35. import org.jfree.chart.renderer.xy.XYLineAndShapeRenderer;
  36. import org.jfree.chart.renderer.xy.XYSplineRenderer;
  37. import org.jfree.chart.title.TextTitle;
  38. import org.jfree.data.category.CategoryDataset;
  39. import org.jfree.data.category.DefaultCategoryDataset;
  40. import org.jfree.data.xy.XYSeries;
  41. import org.jfree.data.xy.XYSeriesCollection;
  42. import org.jsoup.Jsoup;
  43. import org.jsoup.nodes.Document;
  44. import org.jsoup.nodes.Element;
  45. import org.jsoup.select.Elements;
  46. import org.springblade.common.constant.CommonConstant;
  47. import org.springblade.common.utils.BaseUtils;
  48. import org.springblade.common.utils.SnowFlakeUtil;
  49. import org.springblade.common.utils.SystemUtils;
  50. import org.springblade.core.tool.utils.*;
  51. import org.springblade.manager.bean.TableInfo;
  52. import org.springblade.manager.dto.*;
  53. import org.springblade.manager.entity.Formula;
  54. import org.springblade.manager.entity.WbsTreeContract;
  55. import org.springblade.manager.formula.NodeTable;
  56. import org.springblade.manager.formula.impl.CompositeDataAccess;
  57. import org.springblade.manager.formula.impl.TableElementConverter;
  58. import org.springblade.manager.utils.FileUtils;
  59. import org.springblade.manager.vo.*;
  60. import org.springblade.system.cache.ParamCache;
  61. import org.springframework.core.annotation.AnnotationUtils;
  62. import reactor.core.publisher.Mono;
  63. import javax.imageio.ImageIO;
  64. import java.awt.*;
  65. import java.awt.Font;
  66. import java.awt.Shape;
  67. import java.awt.geom.Ellipse2D;
  68. import java.awt.geom.Rectangle2D;
  69. import java.awt.image.BufferedImage;
  70. import java.io.*;
  71. import java.lang.annotation.Annotation;
  72. import java.lang.reflect.Field;
  73. import java.math.BigDecimal;
  74. import java.nio.charset.StandardCharsets;
  75. import java.security.MessageDigest;
  76. import java.security.NoSuchAlgorithmException;
  77. import java.util.*;
  78. import java.util.List;
  79. import java.util.concurrent.ThreadLocalRandom;
  80. import java.util.concurrent.atomic.AtomicInteger;
  81. import java.util.function.BiFunction;
  82. import java.util.function.Function;
  83. import java.util.regex.Matcher;
  84. import java.util.regex.Pattern;
  85. import java.util.stream.Collectors;
  86. import java.util.stream.IntStream;
  87. import java.util.stream.Stream;
  88. import static java.util.regex.Pattern.*;
  89. /**
  90. * @author yangyj
  91. * @Date 2022/7/14 15:55
  92. * @description 公式工具类
  93. */
  94. public class FormulaUtils {
  95. public static final String ELE_CODE_REG= "(?<=E\\[)[^]]+(?=])";
  96. public static final Pattern P = Pattern.compile(ELE_CODE_REG);
  97. /**元素标识*/
  98. public final static String E="E";
  99. /*确定各个元素在计算时的步长,算法:step=最长单元格数/当前元素单元格数*/
  100. public static LinkedHashMap<String,FormData> step(List<FormData> ele){
  101. LinkedHashMap<String,FormData> fdMap =new LinkedHashMap<>();
  102. FormData maxFormData = Collections.max(ele, Comparator.comparingInt((FormData ef)->ef.getValues().size()));
  103. FormData minFormData = Collections.min(ele, Comparator.comparingInt((FormData ef)->ef.getValues().size()));
  104. if (maxFormData.getValues().size() != minFormData.getValues().size()) {
  105. int baseLength = maxFormData.getValues().size();
  106. for (FormData formData : ele) {
  107. formData.setStep(baseLength / formData.getValues().size());
  108. }
  109. }
  110. ele.forEach(e->{
  111. fdMap.put(e.getCode(),e);
  112. });
  113. return fdMap;
  114. }
  115. /*确定公式执行环境变量*/
  116. public static List<LocalVariable> slice2Local(String f, LinkedHashMap<String,FormData> fdMap, TableElementConverter tec){
  117. CompositeDataAccess cda = new CompositeDataAccess(fdMap);
  118. List<LocalVariable> local= new ArrayList<>();
  119. while (cda.hasNext()){
  120. LinkedHashMap<String,ElementData> tip= cda.next();
  121. Map<String, Object> variable = new HashMap<>(tec.constantMap);
  122. @SuppressWarnings("unchecked")
  123. Map<String,Object> em= (Map<String, Object>) variable.computeIfAbsent(E, k->new HashMap<>());
  124. Integer index= new ArrayList<>(tip.values()).get(0).getIndex();
  125. for(Map.Entry<String,ElementData> se:tip.entrySet()){
  126. Object value=se.getValue().getValue();
  127. if(CustomFunction.isNumber(value)){
  128. if(StringUtils.isDouble(value)||f.contains("/")){
  129. em.put(se.getKey(),Double.parseDouble(value.toString()));
  130. }else{
  131. em.put(se.getKey(),StringUtils.handleObj2Integer(value));
  132. }
  133. }else{
  134. em.put(se.getKey(),StringUtils.handleNull(value).replaceAll("[ ]+","").trim());
  135. }
  136. }
  137. local.add(new LocalVariable(index,f,variable));
  138. }
  139. return local;
  140. }
  141. public static void putEle(String f,List<FormData> ele,Map<String, Object> currentMap,FormData fd){
  142. @SuppressWarnings("unchecked")
  143. Map<String,Object> em = (Map<String, Object>) currentMap.computeIfAbsent(E,(k)-> new HashMap<>());
  144. /*如果输入输出元素都是1对1*/
  145. if(f.split("[/+\\-*]").length>1&&!f.contains("{}")&&ele.stream().map(e->e.getCoordsList().size()).max(Comparator.comparingInt(e->e)).orElse(1)==1&&fd.getCoordsList().size()==1){
  146. ele.forEach(e->{
  147. Object value=e.getValues().get(0).getValue();
  148. if(CustomFunction.isNumber(value)){
  149. if(StringUtils.isDouble(value)||f.contains("/")){
  150. em.put(e.getCode(), Double.parseDouble(value.toString()));
  151. }else{
  152. em.put(e.getCode(),StringUtils.handleObj2Integer(value));
  153. }
  154. }else{
  155. em.put(e.getCode(),value);
  156. }
  157. });
  158. }else{
  159. ele.forEach(e-> em.put(e.getCode(),e.getRawValue()));
  160. }
  161. }
  162. public static final Random RD = new Random();
  163. public static Map<String,Object> triangleSquare(Object ranges){
  164. Map<String,Object> map =new HashMap<>();
  165. if(StringUtils.isEmpty(ranges)){
  166. //z的默认取值范围
  167. ranges="(0,15)";
  168. }
  169. Matcher m = RegexUtils.matcher("(\\-?\\d+)(\\D)(\\+?\\d+)",ranges.toString());
  170. if(m.find()) {
  171. int min = StringUtils.handObj2Integer(m.group(1));
  172. int max = StringUtils.handObj2Integer(m.group(3));
  173. Integer[] r = pythagorean(min, max);
  174. map.put("X", String.valueOf(r[0]));
  175. map.put("Y", String.valueOf(r[1]));
  176. map.put("Z", String.valueOf(r[2]));
  177. }
  178. return map;
  179. }
  180. /* public static void main(String[] args) {
  181. IntStream.range(0,10).boxed().forEach(i->{
  182. System.out.println(triangleSquare("-5,5"));
  183. });
  184. }*/
  185. /**
  186. * @Description 字符串相似度
  187. * @Param [s1, s2]
  188. * @return double
  189. * @Author yangyj
  190. * @Date 2023.04.12 18:01
  191. **/
  192. public static double getJaccardSimilarity(String s1, String s2) {
  193. Set<Character> set1 = new HashSet<>();
  194. Set<Character> set2 = new HashSet<>();
  195. for (char c : s1.toCharArray()) {
  196. set1.add(c);
  197. }
  198. for (char c : s2.toCharArray()) {
  199. set2.add(c);
  200. }
  201. Set<Character> intersection = new HashSet<>(set1);
  202. intersection.retainAll(set2);
  203. Set<Character> union = new HashSet<>(set1);
  204. union.addAll(set2);
  205. return (double) intersection.size() / union.size();
  206. }
  207. public static Double similarity(String s1,String s2){
  208. return getJaccardSimilarity(parseItemName(s1),parseItemName(s2));
  209. }
  210. /**
  211. * result[0]^2+result[1]^2=result[2]^2 result[] 元素均为正整数
  212. */
  213. public static Integer[] pythagorean(Integer min,Integer max){
  214. Integer[] result = null;
  215. List<Integer[]> list = new ArrayList<>();
  216. for(int i=1;i<=max;i++){
  217. for(int j=1;j<=max;j++){
  218. double tmp = Math.sqrt(Math.pow(i,2)+Math.pow(j,2));
  219. int z= (int) Math.round(tmp);
  220. if(min<z&&z<=max){
  221. Integer[] arr = new Integer[]{RD.nextBoolean()?i:-i,RD.nextBoolean()?j:-j,z};
  222. list.add(arr);
  223. }
  224. }
  225. }
  226. if(ListUtils.isNotEmpty(list)){
  227. Random rm = new Random();
  228. result = list.get(rm.nextInt(list.size()));
  229. }
  230. return result;
  231. }
  232. /*public static void main(String[] args) {
  233. FormData fd = new FormData();
  234. fd.setEName("1111");
  235. List<ElementData> list = new ArrayList<>();
  236. list.add(new ElementData(1,1,1));
  237. test(fd);
  238. System.out.println(fd.getEName());
  239. }*/
  240. /**写人元素数据,每个元素都是一个集合,每页的单元格数量乘以页数就是总长度*/
  241. public static void write(FormData fd, Object data){
  242. write(fd,data,false);
  243. }
  244. public static void write(FormData fd, Object data,Boolean retainEmpty ){
  245. if(Func.isEmpty(fd.getValues())){
  246. /*无定位信息不写入*/
  247. return;
  248. }
  249. try {
  250. /*一个单元格且存在多张,全部设置为自动拓展 20230816*/
  251. if(fd.getCoordsList().size()==1&&fd.getValues().size()>1&&fd.getFormula()!=null){
  252. fd.getFormula().setOutm(Formula.FULL);
  253. }
  254. /*写入前清空内容*/
  255. fd.getValues().forEach(t->t.setValue(null));
  256. if(data instanceof List){
  257. List<Object> values = (List<Object>) data;
  258. if(!retainEmpty){
  259. /*不包含空白内容*/
  260. values=values.stream().filter(StringUtils::isNotEmpty).collect(Collectors.toList());
  261. }
  262. if(values.size()>fd.getValues().size()){
  263. if(fd.getCoordsList().size()==1){
  264. /*元素只绑定了一个单元格的情况*/
  265. if(values.stream().filter(CustomFunction::containsZH).anyMatch(e->e.toString().contains("\n"))){
  266. fd.getValues().get(0).setValue(values.stream().filter(Objects::nonNull).map(Object::toString).collect(Collectors.joining()));
  267. }else{
  268. /*日期类型的元素只获取最后一个非空*/
  269. if(StringUtils.isEquals(4,fd.getEType())){
  270. fd.getValues().get(0).setValue(values.stream().filter(StringUtils::isNotEmpty).reduce((first, second) -> second).orElse(null));
  271. }else if(values.stream().filter(StringUtils::isNotEmpty).distinct().count()==1L){
  272. /*如果输入元素全是是一样的内容,则输入出元素则每个单元格也写入一样的内容*/
  273. values.stream().filter(StringUtils::isNotEmpty).findFirst().ifPresent(t->{
  274. for(int n=0;n<fd.getValues().size();n++){
  275. fd.getValues().get(n).setValue(t);
  276. }
  277. });
  278. }else{
  279. fd.getValues().get(0).setValue(values.stream().filter(StringUtils::isNotEmpty).map(StringUtils::handleNull).collect(Collectors.joining("、")));
  280. }
  281. }
  282. }else{
  283. for(int n=0;n<fd.getValues().size();n++){
  284. fd.getValues().get(n).setValue(values.get(n));
  285. }
  286. List<Object> overList=values.stream().skip(fd.getValues().size()).collect(Collectors.toList());
  287. List<Coords> coordsList = fd.getCoordsList();
  288. int addPage=(int)Math.ceil((double)overList.size()/(double)coordsList.size());
  289. fd.setAddPages(addPage);
  290. ElementData last =fd.getValues().get(fd.getValues().size()-1);
  291. int indexBase=last.getIndex()+1;
  292. List<ElementData> addList= new ArrayList<>();
  293. for(int i=0;i<addPage;i++){
  294. for(int j=0;j<coordsList.size();j++){
  295. /*超页就尽管写进去,格式化阶段再加表*/
  296. Coords coords = coordsList.get(j);
  297. Object v=null;
  298. int st=i*coordsList.size()+j;
  299. if(st<overList.size()){
  300. v= overList.get(st);
  301. }
  302. addList.add(new ElementData(indexBase+i,last.getGroupId(),v,coords.getX(),coords.getY()));
  303. }
  304. }
  305. fd.getValues().addAll(addList);
  306. }
  307. }else{
  308. for (int n = 0; n < values.size(); n++) {
  309. fd.getValues().get(n).setValue(values.get(n));
  310. }
  311. }
  312. }else{
  313. if(fd.getFormula()!=null&&Formula.FULL.equals(fd.getFormula().getOutm())){
  314. /*填充策略*/
  315. fd.getValues().forEach(e->e.setValue(data));
  316. }else{
  317. fd.getValues().get(0).setValue(data);
  318. }
  319. }
  320. fd.setUpdate(1);
  321. }catch (Exception e){
  322. e.printStackTrace();
  323. }
  324. }
  325. public static final String TBN_FN="TBN";
  326. /*把模型类转换成共识配置选项*/
  327. public static List<WbsFormElementVO> toElementVos(Class<?> clazz) {
  328. return DataModel.toElementVos(clazz);
  329. }
  330. public static String getEleKey(Class<?> clazz, String fieldName){
  331. try {
  332. Field field = clazz.getDeclaredField(fieldName);
  333. String TBN = (String) clazz.getField(TBN_FN).get(null);
  334. JSONField jf = AnnotationUtils.findAnnotation(field, JSONField.class);
  335. if (jf != null) {
  336. return TBN+StringPool.COLON+jf.name();
  337. }
  338. } catch (Exception e) {
  339. e.printStackTrace();
  340. }
  341. return StringPool.EMPTY;
  342. }
  343. public static JSONField getJSONField(Class<?> clazz, String fieldName){
  344. try {
  345. Field field = clazz.getDeclaredField(fieldName);
  346. String TBN = (String) clazz.getField(TBN_FN).get(null);
  347. JSONField jf = AnnotationUtils.findAnnotation(field, JSONField.class);
  348. if (jf != null) {
  349. return jf;
  350. }
  351. } catch (Exception e) {
  352. e.printStackTrace();
  353. }
  354. return null;
  355. }
  356. /*获取指定模型的页码元素*/
  357. public static String getPageCode(Class<?> clazz){
  358. return getEleKey(clazz,"pageCount");
  359. }
  360. public static String getPageTotal(Class<?> clazz){
  361. return getEleKey(clazz,"pageTotal");
  362. }
  363. public static String getPageIndex(Class<?> clazz){
  364. return getEleKey(clazz,"pageIndex");
  365. }
  366. public static JSONField getPageFormat(Class<?> clazz){
  367. return getJSONField(clazz,"pageCount");
  368. }
  369. /*根据数据模型实例生成带数据的元素,用于修改*/
  370. public static <T> LinkedHashMap<String,FormData> toFormDataMap(T bean){
  371. LinkedHashMap<String,FormData> result = new LinkedHashMap<>();
  372. if(bean!=null){
  373. try {
  374. @SuppressWarnings("unchecked")
  375. Map<String,String> map= JSON.parseObject(JSON.toJSONString(bean),Map.class);
  376. Class<?> clazz=bean.getClass();
  377. String TBN = (String) clazz.getField(TBN_FN).get(null);
  378. for (Field field : clazz.getDeclaredFields()) {
  379. JSONField jf = field.getAnnotation(JSONField.class);
  380. if (jf != null) {
  381. FormData fd = new FormData();
  382. fd.setCode(TBN+ StringPool.COLON +jf.name());
  383. fd.setEName(jf.label());
  384. fd.getValues().add(new ElementData(0,0,map.get(fd.getKey()),0,0));
  385. fd.getCoordsList().add(new Coords("0","0"));
  386. result.put(fd.getCode(),fd);
  387. }
  388. }
  389. }catch (Exception e){
  390. e.printStackTrace();
  391. }
  392. }
  393. return result;
  394. }
  395. /*根据数据模型建立空元素,待写入数据*/
  396. public static <T> LinkedHashMap<String,FormData> toFormDataMap(Class<T> clazz){
  397. LinkedHashMap<String,FormData> result = new LinkedHashMap<>();
  398. try {
  399. String TBN = (String) clazz.getField(TBN_FN).get(null);
  400. for (Field field : clazz.getDeclaredFields()) {
  401. JSONField jf = field.getAnnotation(JSONField.class);
  402. if (jf != null) {
  403. FormData fd = new FormData();
  404. fd.setCode(TBN+ StringPool.COLON +jf.name());
  405. fd.setEName(jf.label());
  406. fd.getCoordsList().add(new Coords("0","0"));
  407. result.put(fd.getCode(),fd);
  408. }
  409. }
  410. }catch (Exception e){
  411. e.printStackTrace();
  412. }
  413. return result;
  414. }
  415. /*把结果数据回写到元素*/
  416. public static<T>void put2FormData( LinkedHashMap<String,FormData> fdm,Map<String,Function<List<T>,List<Object>>> functionMap,List<T> dataList){
  417. fdm.values().stream()
  418. .filter(fd -> functionMap.containsKey(fd.getCode()))
  419. .forEach(fd -> {
  420. List<Object> raw = functionMap.get(fd.getCode()).apply(dataList);
  421. raw.stream().map(ElementData::new).forEach(fd.getValues()::add);
  422. });
  423. }
  424. /*根据数据模型对象,生成数据集合按字段获取数据的函数*/
  425. public static <T> Map<String, Function<List<T>, List<Object>>> fieldDataFcMap(Class<?> clazz) {
  426. Map<String, Function<T, Object>> fieldMap = functionMapBuilder(clazz);
  427. Map<String, Function<List<T>, List<Object>>> functionMap = new HashMap<>();
  428. for (Map.Entry<String, Function<T, Object>> functionEntry : fieldMap.entrySet()) {
  429. Function<List<T>, List<Object>> mapper = list -> list.stream().map(functionEntry.getValue()).collect(Collectors.toList());
  430. functionMap.put(functionEntry.getKey(), mapper);
  431. }
  432. return functionMap;
  433. }
  434. /*数据模型按字段生成内容获取函数*/
  435. public static <T> Map<String,Function<T,Object>> functionMapBuilder(Class<?> clazz){
  436. Map<String, Function<T, Object>> functionMap = new HashMap<>();
  437. try {
  438. String tbn=clazz.getField(TBN_FN).get(null).toString();
  439. for (Field field : clazz.getDeclaredFields()) {
  440. JSONField jf = field.getAnnotation(JSONField.class);
  441. if(jf!=null) {
  442. /*ordinal<=100的情况下才会生成动态行字段输出函数*/
  443. if(jf.ordinal()<=100) {
  444. String key = tbn + StringPool.COLON + jf.name();
  445. String fieldName = field.getName();
  446. Function<T, Object> function = getFunction(clazz, fieldName);
  447. functionMap.put(key, function);
  448. }
  449. }
  450. }
  451. }catch (Exception e){
  452. e.printStackTrace();
  453. }
  454. return functionMap;
  455. }
  456. private static <T> Function<T, Object> getFunction(Class<?> clazz, String fieldName) {
  457. return certificate -> {
  458. try {
  459. Field field = clazz.getDeclaredField(fieldName);
  460. field.setAccessible(true);
  461. return field.get(certificate);
  462. } catch (Exception e) {
  463. e.printStackTrace();
  464. return null;
  465. }
  466. };
  467. }
  468. /*list转TreeNode*/
  469. public static <K,T> Map<K, TreeNode<T>> list2TreeNode(Function<TreeNode<T>,K> keyMapper,List<T> list,Function<T,TreeNode<T>> fc,Function<TreeNode<T>,K> classifier){
  470. Map<K, TreeNode<T>> mTreeMap = new HashMap<>();
  471. if (Func.isNotEmpty(list)) {
  472. for (T mt : list) {
  473. try {
  474. TreeNode<T> treeNode = fc.apply(mt);
  475. mTreeMap.put(keyMapper.apply(treeNode), treeNode);
  476. }catch (Exception e){
  477. e.printStackTrace();
  478. }
  479. }
  480. Map<K, List<TreeNode<T>>> group = mTreeMap.values().stream().collect(Collectors.groupingBy(classifier));
  481. group.forEach((k, v) -> {
  482. TreeNode<T> parent = mTreeMap.get(k);
  483. if (parent != null) {
  484. v = v.stream().sorted(Comparator.comparingInt(TreeNode::getSort)).collect(Collectors.toList());
  485. parent.setChildren(v);
  486. v.forEach(e -> e.setParent(parent));
  487. }
  488. });
  489. }
  490. return mTreeMap;
  491. }
  492. /*TreeNode 排序*/
  493. public static <T> void treeNodeSort(int base,TreeNode<T> top){
  494. top.setSort(base);
  495. if(top.hasChildren()){
  496. for(TreeNode<T> child:top.getChildren()){
  497. child.setSort(base++);
  498. }
  499. }
  500. }
  501. /*回溯标记*/
  502. public static <T> void treeNodeChecked( TreeNode<T> tmp){
  503. int loop = 10;
  504. do{
  505. if(tmp.isChecked()) {
  506. /*已经检出则停止循环*/
  507. loop=0;
  508. }else{
  509. tmp.setChecked(true);
  510. tmp=tmp.getParent();
  511. }
  512. }while (tmp!=null&&loop-->0);
  513. }
  514. /*获取层级链*/
  515. public static <T> List<T> treeNodeChains( TreeNode<T> tmp){
  516. List<T> result = new ArrayList<>();
  517. int loop = 10;
  518. do{
  519. /*不包括顶层*/
  520. if(tmp.getParentId()!=0L) {
  521. result.add(tmp.getValue());
  522. }
  523. tmp=tmp.getParent();
  524. }while (tmp!=null&&loop-->0);
  525. Collections.reverse(result);
  526. return result;
  527. }
  528. /**从元素名称中解析项目名称,细化项目匹配用*/
  529. public static String parseItemName(String eName){
  530. if (StringUtils.isEmpty(eName)) {
  531. return eName;
  532. }
  533. String str = eName.replaceAll("\\s", "");
  534. Pattern pattern = compile("[((][^\\u4e00-\\u9fa5]+[))]|_+");
  535. String[] candidate = pattern.split(str);
  536. /*非中文非罗马数字1到10*/
  537. String regex = "[^\\u4e00-\\u9fa5\\u2160-\\u2169))((]+";
  538. Pattern p = compile(regex);
  539. return Arrays.stream(candidate)
  540. .filter(s -> !isContainKeywords(s))
  541. .map(s -> filterString(s, p))
  542. .collect(Collectors.joining());
  543. }
  544. /*A15检查内容专用*/
  545. public static String checkItemName(String eName){
  546. if (StringUtils.isEmpty(eName)) {
  547. return eName;
  548. }
  549. /*分割字符串,选取第一个匹配的子串*/
  550. String str = eName.replaceAll("\\s", "");
  551. Pattern pattern = compile("[((][^\\u4e00-\\u9fa5]+[))]|_+");
  552. String[] candidate = pattern.split(str);
  553. String regex = "[^\\u4e00-\\u9fa5]+";
  554. return Arrays.stream(candidate).map(s->s.replaceAll(regex,"")).distinct().filter(StringUtils::isNotEmpty).filter(s->!isContainKeywords2(s)).findFirst().orElse("");
  555. }
  556. private static String filterString(String s, Pattern p) {
  557. s=s.replaceAll("【[^【】]+】","");
  558. Matcher matcher = p.matcher(s);
  559. return matcher.replaceAll("").replaceAll(getRegex(), "").replaceAll("(设计|合格).*","");
  560. }
  561. private static String getRegex() {
  562. return "(在合格标准内|满足设计要求|质量评定|评定|判定|项目|总数|抽测|实测|偏差|尺量|关键|一般)";
  563. }
  564. private static boolean isContainKeywords(String s) {
  565. List<String> keywords = Arrays.asList( ":", "个","附录","抽查","测","求","小于","大于","检查","仪","按","不","各","记录","检验","且","规定","值或实","≤","≥","平均");
  566. return keywords.stream().anyMatch(s::contains);
  567. }
  568. private static boolean isContainKeywords2(String s) {
  569. List<String> keywords = Arrays.asList( "项目","检查","附录","记录","检验结果","结果");
  570. return keywords.stream().anyMatch(s::contains);
  571. }
  572. /**回归·测试变量*/
  573. public static List<String> itemNames =Arrays.asList(
  574. ""
  575. ,"压 实 度 (%)下路床 特重、极重交通荷载等级 设计值"
  576. ,"1△_压 实 度 (%)_下路床_轻、中及重交通 荷载等级_0.3m~0.8m_≧96_≧95_≧94_实测值或实测偏差值"
  577. ,"1△_压 实 度 (%)_下路提_轻、中及重交通 荷载等级_&gt;1.5m_≧93_≧92_≧90_实测值或实测偏差值"
  578. ,"1△_压 实 度 (%)_上路提_轻、中及重交通 荷载等级_0.8m~1.5m_≧94_≧94_≧93_实测值或实测偏差值"
  579. ,"压 实 度 (%)下路提 轻、中及重交通荷载等级 设计值"
  580. ,"压 实 度 (%)下路床 特重、极重交通荷载等级 合格率"
  581. ,"压 实 度 (%)下路提 轻、中及重交通荷载等级\t合格率"
  582. ,"5△_保护层 厚度 (mm)_基础、锚碇、墩台身、墩柱_±10_实测值或实测偏差值"
  583. ,"钢筋骨架尺寸宽、高或直径 (mm)_尺量:按骨架总数30%抽测_±5_实测值或实测偏差值"
  584. ,"钢筋骨架尺寸长 (mm)_±10_尺量:按骨架总数30%抽测_实测值或实测偏差值"
  585. , "受力钢筋间距 (mm)同排 梁、板、拱肋及拱上建筑 设计值"
  586. ,"受力钢筋间距 (mm)同排 梁、板、拱肋及拱上建筑 合格率"
  587. ," 箍筋、构造钢筋、螺旋筋间距(mm) 设计值"
  588. ,"箍筋、构造钢筋、螺旋筋间距(mm) 合格率"
  589. ,"实测项目_桩位 (mm)_群桩_≤100_质量评定_合格判定"
  590. ,"实测项目_桩位 (mm)_群桩_≤100_实测值或实测偏差值"
  591. ,"实测项目_桩位 (mm)_排架桩_实测值或实测偏差值"
  592. ,"实测项目_桩位 (mm)_排架桩_质量评定_合格判定"
  593. ,"实测项目_桩位 (mm)_群桩_≤100_质量评定_合格率(%)"
  594. ,"实测项目_桩位 (mm)_排架桩_质量评定_合格率(%)"
  595. ,"3△_支座高程(mm)_满足设计要求;设 计未要求时±5_水准仪:测每支座中心线_实测值或实测偏差值"
  596. ,"基底承载力(KPa)_不小于设计_直观或动力触探试验_实测值或实测偏差值"
  597. ,"实 测 项 目_花卉数量_满足设计要求_实测值或实测偏差值"
  598. ,"实 测 项 目_2△_草坪、草本地被覆盖率(%)_取弃土场绿 地_≥90_实测值或实测偏差值"
  599. ,"轴线偏位(mm)_全站仪:20m检查3点_实测值或实测偏差值"
  600. ,"1△_基材混合物喷射厚度(mm)_设计厚度±10_实测值或实测偏差值"
  601. ,"1△_混凝土强度 (MPA)_在合格标准内_按附录D检查_实测值或实测偏差值"
  602. ,"边坡坡度_不陡于设计值_水准仪:每200m测2点,且不少于5点_实测值或实测偏差值"
  603. ,"几何尺寸(mm)_±50_尺量:长、宽、高、壁厚各2点_实测值或实测偏差值"
  604. ,"4△_桩长(mm)_不小于设计_查施工记录_实测值或偏差值"
  605. ,"单桩每延米喷粉 (浆)量_不小于设计_查施工记录_实测值或偏差值"
  606. ,"搭接宽度(mm)_≥150【纵向】_尺量:抽查2%_实测值或实测偏差值",
  607. "搭接宽度(mm)_≥50(横向)_尺量:抽查2%_实测值或实测偏差值"
  608. ,"竖直度(mm)_挖孔桩_0.5%桩长,且≤200_铅锤线:每桩检测_实测值或实测偏差值"
  609. , "2△_压浆压力值 (Mpa)_满足施工技术 规范规定_查油压表读书;每管道检查_实测值或实测偏差值"
  610. , "基底承载力(KPa)_不小于设计_实测值或实测偏差值"
  611. ,"1△_受力钢筋间距 (mm)_两排以上间距_±5_实测值或实测偏差值"
  612. ,"1△梁(板)长度 (mm)_±5_实测值或实测偏差值"
  613. ,"墙面平整度(mm)_施工缝、变形缝处≤20_实测值或实测偏差值"
  614. ,"基底承载力(KPa)_不小于设计_实测值或实测偏差值"
  615. ,"1△_拱部超挖(mm)_Ⅱ、Ⅲ、Ⅳ级围岩(中硬岩 、软岩)_平均150,最大250_实测值或实测偏差值"
  616. ,"实 测 项 目_关键项目_压实度(%)_上路堤_轻、中及重交通荷载等级_0.8~1.5m_≥94_≥94_≥93_检查情况 (实测值)"
  617. ,"表面平整度(mm)_片石_≤35_检验结果"
  618. );
  619. /* public static void main(String[] args) {
  620. // itemNames.stream().map(FormulaUtils::parseItemName).forEach(System.out::println);
  621. itemNames.stream().map(FormulaUtils::checkItemName).forEach(System.out::println);
  622. }*/
  623. public static Object getValue(Cell cell) {
  624. if (cell != null) {
  625. switch (cell.getCellTypeEnum()) {
  626. case STRING:
  627. return cell.getStringCellValue() == null ? null : cell.getStringCellValue().trim();
  628. case NUMERIC:
  629. HSSFDataFormatter dataFormatter = new HSSFDataFormatter();
  630. return dataFormatter.formatCellValue(cell);
  631. case BOOLEAN:
  632. return cell.getBooleanCellValue();
  633. case ERROR:
  634. return cell.getErrorCellValue();
  635. case FORMULA:
  636. try {
  637. return cell.getStringCellValue();
  638. } catch (IllegalStateException e) {
  639. return "";
  640. }
  641. default:
  642. cell.setCellType(CellType.STRING);
  643. return cell.getStringCellValue() == null ? null : cell.getStringCellValue().trim();
  644. }
  645. }
  646. return null;
  647. }
  648. public static List<ElementData> getElementDataList(String coords,String values){
  649. if(StringUtils.isNotEmpty(coords,values)){
  650. List<Coords> coordsList = Stream.of(coords).flatMap(s -> Arrays.stream(s.split(";"))).map(s -> {
  651. String[] xy = s.split("_");
  652. return new Coords(xy[1], xy[0]);
  653. }).collect(Collectors.toList());
  654. return str2ElementData(values,coordsList,null,null);
  655. }
  656. return Collections.emptyList();
  657. }
  658. public static List<ElementData> str2ElementData(String pg, List<Coords> coordsList ,String code,Integer index){
  659. List<ElementData> eds = new ArrayList<>();
  660. if(StringUtils.isNotEmpty(pg)&&ListUtils.isNotEmpty(coordsList)) {
  661. if(code==null){
  662. code="code";
  663. }
  664. if(index==null){
  665. index=1;
  666. }
  667. String[] val = pg.split("☆");
  668. Map<String, Object> tmpMap = new LinkedHashMap<>();
  669. for (String s : val) {
  670. String[] t = s.split("_\\^_");
  671. String[] c = t[1].split("_");
  672. tmpMap.put(StringUtils.join(code, 0, index, Func.toInt(c[1]), Func.toInt(c[0]), StringPool.AT), t[0]);
  673. }
  674. for (Coords c : coordsList) {
  675. Object data = null;
  676. String key = StringUtils.join(code, 0, index, c.getX(), c.getY(), StringPool.AT);
  677. if (tmpMap.containsKey(key)) {
  678. data = tmpMap.get(key);
  679. }
  680. eds.add(new ElementData(index, 0, data, c.getX(), c.getY()));
  681. }
  682. }
  683. return eds;
  684. }
  685. /**
  686. * @Description Poi 动态执行公式 测试
  687. * @Param [url]
  688. * @Author yangyj
  689. * @Date 2023.05.05 14:28
  690. **/
  691. public static void evaluateFormulaCell(String url) {
  692. try {
  693. url="C:/Users/yangyj/Desktop/test.xlsx";
  694. Workbook workbook = WorkbookFactory.create(new File(url));
  695. Sheet sheet = workbook.getSheetAt(0);
  696. Cell cell = sheet.getRow(0).getCell(0);
  697. FormulaEvaluator evaluator = workbook.getCreationHelper().createFormulaEvaluator();
  698. CellType cellType = evaluator.evaluateFormulaCellEnum(cell);
  699. if (cellType == CellType.NUMERIC) {
  700. double value = cell.getNumericCellValue();
  701. System.out.println("公式计算结果:" + value);
  702. } else if (cellType == CellType.STRING) {
  703. String value = cell.getStringCellValue();
  704. System.out.println("公式计算结果:" + value);
  705. }
  706. cell.setCellFormula("B1+C1+D1");
  707. evaluator.clearAllCachedResultValues();
  708. cellType = evaluator.evaluateFormulaCellEnum(cell);
  709. if (cellType == CellType.NUMERIC) {
  710. double value = cell.getNumericCellValue();
  711. System.out.println("公式计算结果:" + value);
  712. } else if (cellType == CellType.STRING) {
  713. String value = cell.getStringCellValue();
  714. System.out.println("公式计算结果:" + value);
  715. }
  716. }catch (IOException | InvalidFormatException e){
  717. e.printStackTrace();
  718. }
  719. }
  720. public static Map<String, String> getElementCell(String uri){
  721. return getElementCell(uri,null,null);
  722. }
  723. public static Map<String, String> getElementCell(String uri,String key) {
  724. return getElementCell(uri,key,null);
  725. }
  726. public static Map<String, String> getElementCell(String uri,String key,Document document) {
  727. try {
  728. String filter=" [keyname]";
  729. if(Func.isNotBlank(key)){
  730. filter="[keyname^="+key+"__]";
  731. }
  732. if(document==null){
  733. InputStream inputStreamByUrl = FileUtils.getInputStreamByUrl(uri);
  734. document=Jsoup.parse(IoUtil.readToString(inputStreamByUrl));
  735. }
  736. Map<String,String> result= document
  737. .select("table").first()
  738. .select(filter).stream()
  739. .map(d -> d.attr("keyname")).filter(StringUtils::isNotEmpty).map(e -> e.split("__"))
  740. .collect(
  741. Collectors.toMap(
  742. b -> b[0],
  743. b -> b[1],
  744. (v1, v2) -> v1 + ";" + v2
  745. )
  746. );
  747. if(result.size()>0){
  748. for(Map.Entry<String,String> entry:result.entrySet()){
  749. entry.setValue(FormulaUtils.coordsSorted(entry.getValue()));
  750. }
  751. }
  752. return result;
  753. }catch (Exception e){
  754. e.printStackTrace();
  755. return new HashMap<>();
  756. }
  757. }
  758. public static Map<String, String> getElementExcelCoords(String uri){
  759. return getElementExcelCoords(uri,null,null);
  760. }
  761. public static Map<String, String> getElementExcelCoords(Document document){
  762. return getElementExcelCoords(null,null,document);
  763. }
  764. public static Map<String, String> getElementExcelCoords(String uri,String key,Document document){
  765. try {
  766. String filter=" [keyname]";
  767. if(Func.isNotBlank(key)){
  768. filter="[keyname^="+key+"__]";
  769. }
  770. if(document==null){
  771. InputStream inputStreamByUrl = FileUtils.getInputStreamByUrl(uri);
  772. document=Jsoup.parse(IoUtil.readToString(inputStreamByUrl));
  773. }
  774. Map<String,String> result= document
  775. .select("table").first()
  776. .select(filter).stream()
  777. .filter(d -> Func.isNotEmpty(d.attr("keyname"))).filter(StringUtils::isNotEmpty).map(e ->new String[]{e.attr("keyname").split("__")[0],e.attr("y1")+"_"+e.attr("x1")})
  778. .collect(
  779. Collectors.toMap(
  780. b -> b[0],
  781. b -> b[1],
  782. (v1, v2) -> v1 + ";" + v2
  783. )
  784. );
  785. if(result.size()>0){
  786. for(Map.Entry<String,String> entry:result.entrySet()){
  787. entry.setValue(FormulaUtils.coordsSorted(entry.getValue()));
  788. }
  789. }
  790. return result;
  791. }catch (Exception e){
  792. e.printStackTrace();
  793. return new HashMap<>();
  794. }
  795. }
  796. /* public static void main(String[] args) {
  797. String uri="C:\\www\\wwwroot\\Users\\hongchuangyanfa\\Desktop\\privateUrl\\1661661730033369088.html";
  798. getElementExcelCoords(uri,"",null);
  799. System.out.println();
  800. }*/
  801. /*解析html里的电签关键字*/
  802. public static Map<String,String> getESignMap(Document document){
  803. Map<String,String> result = new HashMap<>();
  804. if(document!=null) {
  805. Elements list = document.getElementsByAttribute("dqid");
  806. if (list != null && !list.isEmpty()) {
  807. list.stream().forEach(e -> {
  808. String dqid = e.attr("dqid");
  809. int y1=0;
  810. int x1=0;
  811. if (!e.hasAttr("y1") && !e.hasAttr("x1")&&e.children().size()>0) {
  812. Element element = e.children().get(0);
  813. y1 = Func.toInt(element.attr("y1"));
  814. x1 = Func.toInt(element.attr("x1"));
  815. }else {
  816. y1 = Func.toInt(e.attr("y1"));
  817. x1 = Func.toInt(e.attr("x1"));
  818. }
  819. result.put(y1+"_"+x1,dqid);
  820. });
  821. }
  822. }
  823. return result;
  824. }
  825. public static List<ElementData> setScale(Integer scale, List<ElementData> data){
  826. if(scale==null){
  827. scale=StringUtils.getScale(data.stream().map(ElementData::getValue).filter(StringUtils::isDouble).collect(Collectors.toList()));
  828. }
  829. Integer finalScale = scale;
  830. return data.stream().peek(e->{if(StringUtils.isDouble(e.getValue())){e.setValue(StringUtils.number2StringZero(e.getValue(),finalScale));}}).collect(Collectors.toList());
  831. }
  832. /**
  833. * @Description 定位信息排序
  834. * @Param [coords]
  835. * @return java.lang.String
  836. * @Author yangyj
  837. * @Date 2023.07.11 15:39
  838. **/
  839. public static String coordsSorted(String coords){
  840. if(StringUtils.isNotEmpty(coords)){
  841. List<String> dataList=Arrays.asList(coords.split(";"));
  842. if(dataList.size()>2){
  843. LinkedList<Integer> list=dataList.stream().map(e->e.split("_")[1]).distinct().map(Integer::parseInt).sorted(Comparator.comparingInt(e->e)).collect(Collectors.toCollection(LinkedList::new));
  844. if(list.getLast()-list.getFirst()>list.size()-1){
  845. coords=dataList.stream()
  846. .sorted(Comparator.comparingInt((String str) -> Integer.parseInt(str.split("_")[1]))
  847. .thenComparingInt(str -> Integer.parseInt(str.split("_")[0])))
  848. .collect(Collectors.joining(";"));
  849. }
  850. }
  851. }
  852. return coords;
  853. }
  854. public static String coordsSorted2(String coords){
  855. if(StringUtils.isNotEmpty(coords)){
  856. List<String> dataList=Arrays.asList(coords.split(";"));
  857. if(dataList.size()>2){
  858. /*判断分区:根据行列长度*/
  859. List<Integer> row =dataList.stream().map(e->e.split("_")[0]).distinct().map(Integer::parseInt).collect(Collectors.toList());
  860. List<Integer> column=dataList.stream().map(e->e.split("_")[1]).distinct().map(Integer::parseInt).collect(Collectors.toList());
  861. if(row.size()>=column.size()){
  862. /*纵向*/
  863. if(column.size()>1){
  864. List<List<Integer>> consecutiveGroups = IntStream.range(0, column.size())
  865. .boxed()
  866. .collect(Collectors.collectingAndThen(
  867. Collectors.groupingBy(
  868. i -> i - column.get(i),
  869. LinkedHashMap::new,
  870. Collectors.mapping(column::get, Collectors.toList())
  871. ),
  872. map -> new ArrayList<>(map.values())
  873. ));
  874. }
  875. }
  876. /* 确定区内方向:*/
  877. }
  878. }
  879. return coords;
  880. }
  881. /* public static void main(String[] args) {
  882. List<Integer> column = Arrays.asList(1, 2, 3, 5, 6, 7, 9, 11, 17);
  883. List<List<Integer>> consecutiveGroups = IntStream.range(0, column.size())
  884. .boxed()
  885. .collect(Collectors.collectingAndThen(
  886. Collectors.groupingBy(
  887. i -> i - column.get(i),
  888. LinkedHashMap::new,
  889. Collectors.mapping(column::get, Collectors.toList())
  890. ),
  891. map -> new ArrayList<>(map.values())
  892. ));
  893. AtomicInteger i = new AtomicInteger(column.get(0));
  894. List<List<Integer>> consecutiveGroups2= new ArrayList<>(column.stream().collect(Collectors.groupingBy(e -> e - i.getAndSet(e) > 1, LinkedHashMap::new, Collectors.toList())).values());
  895. System.out.println();
  896. }*/
  897. public static List<Object> slice(List<LocalVariable> local, String formula){
  898. int min =0;
  899. List<Object> result = new ArrayList<>();
  900. try {
  901. pretreatment(local,formula);
  902. List<Object> r= local.stream().map(e-> {
  903. /*所有依赖元素的内容必须非空才进行计算,否则返回空值*/
  904. return e.hasEmptyElementValue()?"": Expression.parse(e.getFormula()).calculate(e.getCurrentMap()).toString();
  905. }).collect(Collectors.toList());
  906. if(CollectionUtil.isNotEmpty(r)&&r.stream().anyMatch(StringUtils::isNotEmpty)){
  907. result.addAll(r);
  908. }
  909. }catch (Exception e){
  910. StaticLog.error("公式:{},执行出错",formula);
  911. }
  912. return result;
  913. }
  914. public static void pretreatment(List<LocalVariable> local,String formula){
  915. formula=StringUtils.removeMultiSpace(formula);
  916. if(formula.contains("LIST")){
  917. Matcher m=RegexUtils.matcher("\\(([^)]*)\\)/LIST",formula);
  918. while (m.find()){
  919. List<String> codes=getCodeList(m.group(1).replaceAll("[+-]",","));
  920. local=local.stream().peek(e->{
  921. @SuppressWarnings("unckecked")
  922. Map<String,Object> map = (Map<String, Object>) e.getCurrentMap().getOrDefault("E",new HashMap<>());
  923. int listSize=(int)codes.stream().filter(c->StringUtils.isNotEmpty(map.get(c))).count();
  924. if(listSize<=0||listSize>codes.size()){
  925. listSize=codes.size();
  926. }
  927. map.put("LIST",listSize);
  928. }).collect(Collectors.toList());
  929. }
  930. }
  931. }
  932. /**从方法参数中获取全部code*/
  933. public static List<String> getCodeList(String param){
  934. List<String> list = new ArrayList<>();
  935. if(StringUtils.isNotEmpty(param)){
  936. Arrays.stream(param.split(",")).forEach(s->{
  937. list.add(s.replaceAll("[E\\[\\]']",""));
  938. });
  939. }
  940. return list;
  941. }
  942. /**从时间段中获取最后一个日期*/
  943. static final String RANGE_DATE_REG="^\\[(\\d{4}[年.\\-]\\d{2}[月.\\-]\\d{2}[日]?),\\s+(\\d{4}[年.\\-]\\d{2}[月.\\-]\\d{2}[日]?)]$";
  944. public static String range2end(String t){
  945. if(t!=null&&Pattern.matches(RANGE_DATE_REG,t)){
  946. t=t.replaceAll("^\\[|]$","").split(",")[1].trim();
  947. }
  948. return t;
  949. }
  950. public static List<String> duration2date(String duration){
  951. try {
  952. if (duration != null && Pattern.matches(RANGE_DATE_REG, duration)) {
  953. return Arrays.stream(duration.replaceAll("^\\[|]$", "").split(",")).map(String::trim).map(s -> new DateTime(s).toString(DatePattern.NORM_DATE_PATTERN)).collect(Collectors.toList());
  954. }
  955. return Collections.singletonList(new DateTime(duration).toString(DatePattern.NORM_DATE_PATTERN));
  956. }catch (Exception e){
  957. return Collections.singletonList(new DateTime().toString(DatePattern.NORM_DATE_PATTERN));
  958. }
  959. }
  960. public static FormData createFormDataFast(String name,String code,String values,String coords){
  961. if(StringUtils.isNotEmpty(code,name)){
  962. if(StringUtils.isNotEmpty(coords)) {
  963. /*定位信息存在才合法*/
  964. List<Coords> coordsList = Stream.of(coords).flatMap(s -> Arrays.stream(s.split(";"))).map(s -> {
  965. String[] xy = s.split("_");
  966. return new Coords(xy[1], xy[0]);
  967. }).collect(Collectors.toList());
  968. List<ElementData> eds = new ArrayList<>();
  969. if (StringUtils.isNotEmpty(values)) {
  970. String[] pages = values.split(";;");
  971. for (int index = 0; index < pages.length; index++) {
  972. String pg = pages[index];
  973. if (Func.isNotBlank(pg)) {
  974. String[] val = pg.split("☆");
  975. Map<String, Object> tmpMap = new LinkedHashMap<>();
  976. for (String s : val) {
  977. String[] t = s.split("_\\^_");
  978. String[] c = t[1].split("_");
  979. tmpMap.put(StringUtils.join(code, 0, index, Func.toInt(c[1]), Func.toInt(c[0]), StringPool.AT), t[0]);
  980. }
  981. for (Coords c : coordsList) {
  982. Object data = null;
  983. String key = StringUtils.join(code, 0, index, c.getX(), c.getY(), StringPool.AT);
  984. if (tmpMap.containsKey(key)) {
  985. data = tmpMap.get(key);
  986. }
  987. eds.add(new ElementData(index, 0, data, c.getX(), c.getY()));
  988. }
  989. }
  990. }
  991. } else {
  992. eds = coordsList.stream().map(c -> new ElementData(0, 0, null, c.getX(), c.getY())).collect(Collectors.toList());
  993. }
  994. FormData one = new FormData(code, eds, null, coords);
  995. one.setEName(name);
  996. /*备份原始数据,用于更新比较*/
  997. one.init();
  998. return one;
  999. }
  1000. }
  1001. return null;
  1002. }
  1003. public static void mainT(String[] args) throws IOException {
  1004. XYSeries series = new XYSeries("每月实际完成");
  1005. series.add(10.2, 1.82);
  1006. series.add(11.9, 1.86);
  1007. series.add(15.9, 1.87);
  1008. series.add(19.3, 1.85);
  1009. series.add(20.3, 1.80);
  1010. XYSeriesCollection dataset = new XYSeriesCollection();
  1011. dataset.addSeries(series);
  1012. JFreeChart chart = ChartFactory.createXYLineChart(
  1013. "按月进度", // 标题
  1014. "X", // 横轴标题
  1015. "Y", // 纵轴标题
  1016. dataset, // 数据集
  1017. PlotOrientation.VERTICAL, // 图表方向
  1018. true, // 是否显示图例
  1019. false, // 是否生成工具提示
  1020. false // 是否生成URL链接
  1021. );
  1022. // 设置字体
  1023. Font titleFont = new Font("SimSun", Font.PLAIN, 18); // 指定使用宋体字体
  1024. Font axisFont = new Font("SimSun", Font.PLAIN, 12); // 指定使用宋体字体
  1025. // 设置标题字体
  1026. TextTitle title = chart.getTitle();
  1027. title.setFont(titleFont);
  1028. XYPlot plot = (XYPlot) chart.getPlot();
  1029. XYSplineRenderer renderer = new XYSplineRenderer();
  1030. plot.setRenderer(renderer);
  1031. plot.setBackgroundPaint(Color.WHITE);
  1032. // Set the line stroke and shape for the renderer
  1033. renderer.setSeriesStroke(0, new BasicStroke(2.0f));
  1034. Shape circle = new Ellipse2D.Double(-3, -3, 6, 6);
  1035. renderer.setSeriesShape(0, circle);
  1036. renderer.setSeriesPaint(0, Color.BLUE);
  1037. // 自定义 X 轴刻度
  1038. NumberAxis domainAxis = (NumberAxis) plot.getDomainAxis();
  1039. domainAxis.setTickUnit(new NumberTickUnit(5)); // 设置刻度间隔
  1040. domainAxis.setRange(0.0, 25); // 设置轴的范围
  1041. // 自定义 Y 轴刻度
  1042. NumberAxis rangeAxis = (NumberAxis) plot.getRangeAxis();
  1043. rangeAxis.setTickUnit(new NumberTickUnit(0.01)); // 设置刻度间隔
  1044. rangeAxis.setRange(1.79, 1.90); // 设置轴的范围
  1045. // 添加横杠
  1046. for(int i=175;i<190;i++){
  1047. ValueMarker marker = new ValueMarker((double) i /100);
  1048. marker.setPaint(Color.BLUE); // 横杠的颜色
  1049. plot.addRangeMarker(marker);
  1050. }
  1051. ChartPanel chartPanel = new ChartPanel(chart);
  1052. chartPanel.setPreferredSize(new Dimension(500, 400));
  1053. // 保存图表为图片
  1054. int width = 800;
  1055. int height = 600;
  1056. ChartUtils.saveChartAsPNG(new File("C:/Users/yangyj/Desktop/Swap_space/poi_statistics.png"), chart, width, height);
  1057. }
  1058. private static CategoryDataset createDataset( double[] actualProgress, double[] plannedProgress) {
  1059. String[] months = {"一月", "二月", "三月", "四月", "五月", "六月", "七月", "八月", "九月", "十月", "十一月", "十二月"};
  1060. /* int[] actualProgress = {10, 15, 18, 27, 35, 48};
  1061. int[] plannedProgress = {10, 15, 20, 25, 30, 35};*/
  1062. DefaultCategoryDataset dataset = new DefaultCategoryDataset();
  1063. for (int i = 0; i < actualProgress.length; i++) {
  1064. dataset.addValue(actualProgress[i], "实际进度", months[i]);
  1065. }
  1066. for (int i = 0; i < plannedProgress.length; i++) {
  1067. dataset.addValue(plannedProgress[i], "计划进度", months[i]);
  1068. }
  1069. return dataset;
  1070. }
  1071. private static JFreeChart createChart(CategoryDataset dataset) {
  1072. JFreeChart chart = ChartFactory.createBarChart(
  1073. "施工进度对比图",
  1074. "月份",
  1075. "进度 (%)",
  1076. dataset,
  1077. PlotOrientation.VERTICAL,
  1078. true,
  1079. true,
  1080. false
  1081. );
  1082. CategoryPlot plot = (CategoryPlot) chart.getPlot();
  1083. // 设置中文字体以避免乱码
  1084. Font font = new Font("宋体", Font.PLAIN, 12);
  1085. chart.getTitle().setFont(font);
  1086. plot.getDomainAxis().setTickLabelFont(font);
  1087. plot.getDomainAxis().setLabelFont(font);
  1088. plot.getRangeAxis().setTickLabelFont(font);
  1089. plot.getRangeAxis().setLabelFont(font);
  1090. chart.getLegend().setItemFont(font);
  1091. plot.setDomainAxis(new CategoryAxis("月份"));
  1092. plot.setRangeAxis(new NumberAxis("进度 (%)"));
  1093. BarRenderer barRenderer = new BarRenderer();
  1094. barRenderer.setSeriesPaint(0, new Color(0, 0, 255));
  1095. barRenderer.setSeriesPaint(1, new Color(0, 255, 0));
  1096. plot.setRenderer(barRenderer);
  1097. // 添加第二个数据集,绘制为曲线
  1098. DefaultCategoryDataset lineDataset = new DefaultCategoryDataset();
  1099. String[] months = {"一月", "二月", "三月", "四月", "五月", "六月"};
  1100. int[] actualProgress = {10, 15, 18, 27, 35, 48};
  1101. int[] plannedProgress = {10, 15, 20, 25, 30, 35};
  1102. for (int i = 0; i < actualProgress.length; i++) {
  1103. lineDataset.addValue(actualProgress[i], "实际进度", months[i]);
  1104. }
  1105. for (int i = 0; i < plannedProgress.length; i++) {
  1106. lineDataset.addValue(plannedProgress[i], "计划进度", months[i]);
  1107. }
  1108. plot.setDataset(1, lineDataset);
  1109. plot.mapDatasetToRangeAxis(1, 0);
  1110. LineAndShapeRenderer lineRenderer = new LineAndShapeRenderer();
  1111. lineRenderer.setSeriesPaint(0, new Color(255, 0, 0));
  1112. lineRenderer.setSeriesPaint(1, new Color(255, 165, 0));
  1113. plot.setRenderer(1, lineRenderer);
  1114. // 设置 X 轴标签
  1115. CategoryAxis domainAxis = plot.getDomainAxis();
  1116. domainAxis.setCategoryLabelPositions(
  1117. org.jfree.chart.axis.CategoryLabelPositions.createUpRotationLabelPositions(Math.PI / 4.0)
  1118. );
  1119. // 设置 Y 轴范围
  1120. ValueAxis rangeAxis = plot.getRangeAxis();
  1121. rangeAxis.setRange(0, 100);
  1122. return chart;
  1123. }
  1124. public static void mainT2(String[] args) {
  1125. double[] actualProgress = {10, 15, 18, 27, 35, 48};
  1126. double[] plannedProgress = {10, 15, 20, 25, 30, 35};
  1127. CategoryDataset dataset = createDataset(actualProgress,plannedProgress);
  1128. JFreeChart chart = createChart(dataset);
  1129. try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
  1130. BufferedImage bufferedImage = chart.createBufferedImage(800, 600);
  1131. ImageIO.write(bufferedImage, "png", out);
  1132. FileOutputStream fos = new FileOutputStream("C:/Users/yangyj/Desktop/Swap_space/poi_statistics.png");
  1133. fos.write(out.toByteArray());
  1134. } catch (IOException e) {
  1135. e.printStackTrace();
  1136. }
  1137. /* try {
  1138. ChartUtils.saveChartAsPNG(new File("C:/Users/yangyj/Desktop/Swap_space/poi_statistics.png"), chart, 800, 600);
  1139. // 保存图表到内存
  1140. } catch (Exception e) {
  1141. e.printStackTrace();
  1142. }*/
  1143. }
  1144. public static String getSysLocalFileUrl() {
  1145. String file_path = ParamCache.getValue(CommonConstant.SYS_LOCAL_URL);
  1146. if (org.springblade.common.utils.SystemUtils.isMacOs()) {
  1147. file_path = "/Users/hongchuangyanfa/Desktop/";
  1148. } else if (SystemUtils.isWindows()) {
  1149. file_path = "C://upload//";
  1150. }
  1151. return file_path;
  1152. }
  1153. public static byte[] chapterScheduleChart( double[] actualProgress ,double[] plannedProgress){
  1154. CategoryDataset dataset = createDataset(actualProgress,plannedProgress);
  1155. JFreeChart chart = createChart(dataset);
  1156. try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
  1157. ChartUtils.writeChartAsPNG(out, chart, 800, 600);
  1158. return out.toByteArray();
  1159. } catch (IOException e) {
  1160. e.printStackTrace();
  1161. }
  1162. return null;
  1163. }
  1164. public static String chapterScheduleChartUrl( double[] actual ,double[] planned){
  1165. /*CategoryDataset dataset = createDataset(actualProgress,plannedProgress);
  1166. JFreeChart chart = createChart(dataset);*/
  1167. try {
  1168. JFreeChart chart =chartTest(actual,planned);
  1169. String path= getSysLocalFileUrl() + "/pdf//"+SnowFlakeUtil.getId()+".png";
  1170. ChartUtils.saveChartAsPNG(new File(path), chart, 800, 600);
  1171. return path;
  1172. } catch (Exception e) {
  1173. e.printStackTrace();
  1174. }
  1175. return null;
  1176. }
  1177. public static JFreeChart chartTest(double[] actualProgressData ,double[] plannedProgressData) throws IOException {
  1178. // 创建数据集
  1179. XYSeries actualProgress = new XYSeries("实际进度");
  1180. XYSeries plannedProgress = new XYSeries("计划进度");
  1181. /* // 数据
  1182. double[][] actualProgressData = {{1, 10}, {2, 15}, {3, 18}, {4, 27}, {5, 35}, {6, 48}};
  1183. double[][] plannedProgressData = {{1, 10}, {2, 15}, {3, 20}, {4, 25}, {5, 30}, {6, 35}};*/
  1184. // 填充数据集
  1185. for (int i = 0; i < actualProgressData.length; i++) {
  1186. actualProgress.add(i, actualProgressData[i]);
  1187. plannedProgress.add(i, plannedProgressData[i]);
  1188. }
  1189. XYSeriesCollection dataset = new XYSeriesCollection();
  1190. dataset.addSeries(actualProgress);
  1191. dataset.addSeries(plannedProgress);
  1192. // 创建图表
  1193. JFreeChart chart = ChartFactory.createXYLineChart(
  1194. "施工进度对比图", // 标题
  1195. "日期进度 (%)", // X轴标签
  1196. "完成量 (%)", // Y轴标签
  1197. dataset, // 数据集
  1198. org.jfree.chart.plot.PlotOrientation.VERTICAL, // 方向
  1199. true, // 显示图例
  1200. true, // 生成工具
  1201. false // 生成URL
  1202. );
  1203. // 设置中文字体以避免乱码
  1204. Font font = new Font("宋体", Font.PLAIN, 12);
  1205. chart.getTitle().setFont(font);
  1206. chart.getLegend().setItemFont(font);
  1207. XYPlot plot = chart.getXYPlot();
  1208. plot.setDomainGridlinesVisible(true);
  1209. plot.setRangeGridlinesVisible(true);
  1210. plot.setDomainGridlinePaint(Color.LIGHT_GRAY);
  1211. plot.setRangeGridlinePaint(Color.LIGHT_GRAY);
  1212. plot.setBackgroundPaint(Color.WHITE);
  1213. XYLineAndShapeRenderer renderer = new XYLineAndShapeRenderer();
  1214. renderer.setSeriesPaint(0, Color.BLUE);
  1215. renderer.setSeriesPaint(1, Color.GREEN);
  1216. plot.setRenderer(renderer);
  1217. /* // 设置主X轴
  1218. NumberAxis domainAxis = new NumberAxis("日期进度 (%)");
  1219. domainAxis.setRange(0, 100);
  1220. domainAxis.setTickUnit(new NumberTickUnit(10));
  1221. domainAxis.setTickLabelFont(font);
  1222. domainAxis.setLabelFont(font);*/
  1223. // 设置顶部的月份轴
  1224. String[] months = {"一月", "二月", "三月", "四月", "五月", "六月", "七月", "八月", "九月", "十月", "十一月", "十二月"};
  1225. SymbolAxis monthAxis = new SymbolAxis("月份", months);
  1226. monthAxis.setTickLabelFont(font);
  1227. monthAxis.setLabelFont(font);
  1228. monthAxis.setRange(0, 11); // 设置范围来适应月份标签
  1229. plot.setDomainAxis(monthAxis);
  1230. // 设置Y轴的范围
  1231. NumberAxis rangeAxis = (NumberAxis) plot.getRangeAxis();
  1232. rangeAxis.setRange(0, 100); // Y轴从0到100
  1233. rangeAxis.setTickUnit(new NumberTickUnit(10));
  1234. rangeAxis.setLabelFont(font);
  1235. rangeAxis.setTickLabelFont(font);
  1236. /* // 添加月份轴
  1237. plot.setRangeAxis(2, monthAxis);
  1238. plot.mapDatasetToDomainAxis(0, 1); // 将数据映射到月份轴*/
  1239. return chart;
  1240. }
  1241. /**字符串sha256映射*/
  1242. public static String sha256(String input) {
  1243. try {
  1244. MessageDigest digest = MessageDigest.getInstance("SHA-256");
  1245. byte[] encodedHash = digest.digest(input.getBytes(StandardCharsets.UTF_8));
  1246. StringBuilder hexString = new StringBuilder();
  1247. for (byte b : encodedHash) {
  1248. String hex = Integer.toHexString(0xff & b);
  1249. if (hex.length() == 1) {
  1250. hexString.append('0');
  1251. }
  1252. hexString.append(hex);
  1253. }
  1254. return hexString.toString();
  1255. } catch (NoSuchAlgorithmException e) {
  1256. e.printStackTrace();
  1257. }
  1258. return "";
  1259. }
  1260. /**根据步长获取字符*/
  1261. public static String getEveryNthChar(String input, int step) {
  1262. StringBuilder result = new StringBuilder();
  1263. for (int i = 0; i < input.length(); i += step) {
  1264. result.append(input.charAt(i));
  1265. }
  1266. return result.toString();
  1267. }
  1268. /**最大循环次数*/
  1269. public static int MAX_LOOP=20;
  1270. /**
  1271. * @Description 当前提交表单数据公式执行最小影响元素范围
  1272. * @Param [curTableNames:当前提交页面对应表编号, processFds:当前工序包含的所有元素]
  1273. * @Author yangyj
  1274. * @Date 2023.10.09 15:26
  1275. **/
  1276. public static List<FormData> registerFd(List<String> curTableNames, List<FormData> processFds){
  1277. Map<Boolean,List<FormData>> group = processFds.stream().collect(Collectors.partitioningBy(e->curTableNames.contains(e.getTableName())));
  1278. List<FormData> curFormDatas =group.get(true);
  1279. /*提交叶包含元素*/
  1280. List<FormData> initiator= new ArrayList<>(curFormDatas);
  1281. List<FormData> other=group.get(false);
  1282. /*当前提交页元素影响到的元素都要重新执行公式*/
  1283. pick(curFormDatas,other,curFormDatas,fds->fds.stream().map(FormData::getCode).collect(Collectors.toSet()));
  1284. /*当前提交页的元素公式依赖加载*/
  1285. pick(initiator,other,curFormDatas,fds->fds.stream().filter(f->f.executable()&&f.getFormula().getRely()!=null).flatMap(f->f.getFormula().getRelyList().stream()).collect(Collectors.toSet()));
  1286. return curFormDatas;
  1287. }
  1288. /**
  1289. * @Description 调训符合条件的元素
  1290. * @Param [initiator 初始集合, other 待选集合, curFormDatas 结果集, function:挑选方法]
  1291. * @Author yangyj
  1292. * @Date 2023.10.12 14:53
  1293. **/
  1294. public static void pick(List<FormData> initiator,List<FormData> other,List<FormData> curFormDatas ,Function<List<FormData>,Set<String>> function){
  1295. List<FormData> curFormDatasAdd=new ArrayList<>(initiator);
  1296. int loop=0;
  1297. do{
  1298. loop++;
  1299. Set<String> codeSet= function.apply(curFormDatasAdd);
  1300. Map<Boolean,List<FormData>> groupTmp = other.stream().collect(Collectors.partitioningBy(e->codeSet.contains(e.getCode())));
  1301. curFormDatasAdd=groupTmp.get(true);
  1302. if(curFormDatasAdd.isEmpty()){
  1303. loop=MAX_LOOP;
  1304. }else{
  1305. curFormDatas.addAll(curFormDatasAdd);
  1306. }
  1307. other=groupTmp.get(false);
  1308. }while (!other.isEmpty()&&loop<MAX_LOOP);
  1309. }
  1310. /**最小加载页面,只要包含当前提交元素的页面都需要加载*/
  1311. public static Map<String,List<Long>> relatedPages(List<FormData> curFormDatas ,List<NodeTable> tableAll){
  1312. Set<String> initTableNames= curFormDatas.stream().map(FormData::getTableName).collect(Collectors.toSet());
  1313. return tableAll.stream().filter(e->initTableNames.contains(e.getInitTableName())).collect(Collectors.groupingBy(NodeTable::getInitTableName,Collectors.mapping(NodeTable::getPKeyId,Collectors.toList())));
  1314. }
  1315. /*比较两组单元格内容是否一样*/
  1316. public static boolean compareElementDataList(List<ElementData> before ,List<ElementData> cur){
  1317. if(Func.isNotEmpty(before)&&Func.isNotEmpty(cur)&&before.size()==cur.size()){
  1318. String sa= before.stream().map(ElementData::stringValue).collect(Collectors.joining());
  1319. String sc= cur.stream().map(ElementData::stringValue).collect(Collectors.joining());
  1320. return sa.equals(sc);
  1321. }
  1322. return false;
  1323. }
  1324. /**分割treeCode*/
  1325. public static List<String> treeCodeSplit(String treeCode){
  1326. List<String> result = new ArrayList<>();
  1327. if(Func.isNotBlank(treeCode)){
  1328. /*字符总长度*/
  1329. int max =treeCode.length()-3,
  1330. /*累计字符长度字符*/
  1331. sum=0,
  1332. /*第几次循环*/
  1333. count=0;
  1334. do{
  1335. result.add(treeCode.substring(0, sum+=Math.min(3,++count)));
  1336. }while (sum<max&&count<MAX_LOOP);
  1337. }
  1338. return result;
  1339. }
  1340. /* public static void main(String[] args) {
  1341. System.out.println(milestone("k8+120.23"));
  1342. }*/
  1343. /*从测点名称中获取里程*/
  1344. public static Double milestone(String s){
  1345. Pattern pattern=Pattern.compile("(?i)K(\\d+)\\+([\\d.]+)");
  1346. Matcher matcher = pattern.matcher(s);
  1347. if(matcher.find()){
  1348. return Double.parseDouble(matcher.group(1))*1000+ Double.parseDouble(matcher.group(2));
  1349. }
  1350. return null;
  1351. }
  1352. public static void sort( List<FormData> list,int n){
  1353. /*System.out.println("剩余计算次数:"+n+"次");*/
  1354. if(move(list)&&n>0){
  1355. sort(list,--n);
  1356. }
  1357. }
  1358. public static Boolean move( List<FormData> list){
  1359. for(int i=0;i<list.size();i++){
  1360. FormData f=list.get(i);
  1361. Matcher m =P.matcher(f.getFormula().getFormula());
  1362. List<String> cp = new ArrayList<>();
  1363. while (m.find()){
  1364. cp.add(m.group());
  1365. }
  1366. Map<Boolean,List<FormData>> map= list.stream().skip(i+1).collect(Collectors.partitioningBy(e->cp.contains(e.getCode())));
  1367. List<FormData> match =map.get(true);
  1368. if(CollectionUtil.isNotEmpty(match)){
  1369. for(FormData r:match){
  1370. list.remove(r);
  1371. }
  1372. list.addAll(0,match);
  1373. return true;
  1374. }
  1375. }
  1376. return false;
  1377. }
  1378. public static void relyParse(Formula f){
  1379. if(Func.isNotBlank(f.getFormula())){
  1380. List<String> l = new ArrayList<>();
  1381. Matcher m = P.matcher(f.getFormula());
  1382. while (m.find()){
  1383. String tmp =m.group().replaceAll("'","");
  1384. String cp=tmp;
  1385. if(tmp.indexOf(StringPool.COLON)!=tmp.lastIndexOf(StringPool.COLON)){
  1386. tmp=tmp.substring(tmp.indexOf(":")+1);
  1387. /*移除跨节点标识*/
  1388. f.setFormula(f.getFormula().replace(cp,tmp));
  1389. }
  1390. l.add(tmp);
  1391. }
  1392. if(l.size()>0){
  1393. f.setRely(String.join(",", l));
  1394. }else{
  1395. f.setRely("");
  1396. }
  1397. }
  1398. }
  1399. /*复制表页*/
  1400. public static WbsTreeContract copyPage(WbsTreeContract origin){
  1401. WbsTreeContract target = new WbsTreeContract();
  1402. BeanUtil.copy(origin, target);
  1403. target.setPKeyId(SnowFlakeUtil.getId());
  1404. target.setCreateTime(new Date());
  1405. String nodeName = origin.getNodeName();
  1406. String[] oldName = nodeName.split("__");
  1407. if (oldName.length>1) {
  1408. nodeName = oldName[0] + "__" + (Integer.parseInt(oldName[1]) + 1);
  1409. } else {
  1410. nodeName = nodeName + "__" + 1;
  1411. }
  1412. target.setNodeName(nodeName);
  1413. target.setIsCopeTab(2);
  1414. target.setIsTabPdf(1); // pdf 不能预览
  1415. target.setIsBussShow(1); // 是否隐藏表
  1416. target.setTabFileType(1);//没有上传附件
  1417. target.setPdfUrl("");
  1418. return target;
  1419. }
  1420. public static String recovery(List<ElementData> dataList) {
  1421. if (Func.isNotEmpty(dataList)) {
  1422. return dataList.stream().filter(e -> !e.isEmpty()).map(e -> e.stringValue() + "_^_" + e.getY() + "_" + e.getX()).collect(Collectors.joining("☆"));
  1423. }
  1424. return "";
  1425. }
  1426. private static final Map<Character, Integer> CHINESE_TO_ARABIC = new HashMap<>();
  1427. static {
  1428. CHINESE_TO_ARABIC.put('零', 0);
  1429. CHINESE_TO_ARABIC.put('一', 1);
  1430. CHINESE_TO_ARABIC.put('二', 2);
  1431. CHINESE_TO_ARABIC.put('三', 3);
  1432. CHINESE_TO_ARABIC.put('四', 4);
  1433. CHINESE_TO_ARABIC.put('五', 5);
  1434. CHINESE_TO_ARABIC.put('六', 6);
  1435. CHINESE_TO_ARABIC.put('七', 7);
  1436. CHINESE_TO_ARABIC.put('八', 8);
  1437. CHINESE_TO_ARABIC.put('九', 9);
  1438. CHINESE_TO_ARABIC.put('十', 10);
  1439. CHINESE_TO_ARABIC.put('百', 100);
  1440. CHINESE_TO_ARABIC.put('千', 1000);
  1441. CHINESE_TO_ARABIC.put('万', 10000);
  1442. }
  1443. public static int chineseToArabic(String chineseNumber) {
  1444. int result = 0;
  1445. int multiplier = 1;
  1446. for (int i = chineseNumber.length() - 1; i >= 0; i--) {
  1447. char c = chineseNumber.charAt(i);
  1448. if (CHINESE_TO_ARABIC.containsKey(c)) {
  1449. int value = CHINESE_TO_ARABIC.get(c);
  1450. if(value!=0&&value%10==0&&i!=0){
  1451. multiplier=value;
  1452. }else{
  1453. result=result+value*multiplier;
  1454. }
  1455. } else {
  1456. throw new IllegalArgumentException("Invalid Chinese numeral: " + c);
  1457. }
  1458. }
  1459. return result;
  1460. }
  1461. /*public static void main(String[] args) {
  1462. *//* System.out.println(chineseToArabic("二十九"));
  1463. System.out.println(chineseToArabic("一"));
  1464. System.out.println(chineseToArabic("十一"));*//*
  1465. System.out.println(chineseToArabic("十"));
  1466. *//* System.out.println(chineseToArabic("一百二十"));
  1467. System.out.println(chineseToArabic("一百二十二"));
  1468. System.out.println(chineseToArabic("一百零二"));*//*
  1469. }*/
  1470. /*获取引用code的元素*/
  1471. public static Stream<FormData> beRelyFrom( Map<String, FormData> formDataMap ,String code){
  1472. return formDataMap.values().stream().filter(e->e.executable()&& code.equals(e.getFormula().getRely()));
  1473. }
  1474. public static Stream<FormData> beRelyFrom( Map<String, FormData> formDataMap ,String tableNumber ,String keys){
  1475. Set<String> keySet = Arrays.stream(keys.split(",")).map(s->tableNumber+":"+s.trim()).collect(Collectors.toSet());
  1476. return formDataMap.values().stream().filter(e->e.executable()&& keySet.contains(e.getFormula().getRely()));
  1477. }
  1478. /*根据code查找元素 */
  1479. public static Optional<FormData> elementFindByCode( Map<String, FormData> formDataMap ,String code){
  1480. return formDataMap.values().stream().filter(e->code.equals(e.getCode())).findAny();
  1481. }
  1482. /*根据key查找元素 ,用于元素范围在同一张表情况*/
  1483. public static Optional<FormData> elementFindByKey( Map<String, FormData> fdm ,String key){
  1484. return fdm.values().stream().filter(e->key.equals(e.getCode().split(":")[1])).findAny();
  1485. }
  1486. /*创建T集合的指定字段fb的合计方法*/
  1487. public static <T> Function<List<T>, String> createSumFunction(Function<T,BigDecimal> fb) {
  1488. return (pl) -> pl.stream()
  1489. .map(fb)
  1490. .reduce(BigDecimal.ZERO, BigDecimal::add)
  1491. .toString();
  1492. }
  1493. public static List<TableInfo> getTableInfoList(JSONArray dataArray) {
  1494. if (dataArray != null && !dataArray.isEmpty()) {
  1495. List<TableInfo> result = new ArrayList<>();
  1496. for (int m = 0; m < dataArray.size(); m++) {
  1497. TableInfo tableInfo = new TableInfo();
  1498. com.alibaba.fastjson.JSONObject dataInfo2 = dataArray.getJSONObject(m);
  1499. //
  1500. tableInfo.setContractId(dataInfo2.getString("contractId"));
  1501. tableInfo.setPkeyId(dataInfo2.getString("pkeyId"));
  1502. tableInfo.setProjectId(dataInfo2.getString("projectId"));
  1503. //huangjn 填报的类型,施工或监理
  1504. tableInfo.setClassify(dataInfo2.getString("classify"));
  1505. //设置首件信息
  1506. setFirstData(dataInfo2, tableInfo);
  1507. //设置日志信息
  1508. setTheLogData(dataInfo2, tableInfo);
  1509. dataInfo2.fluentRemove("contractId")
  1510. .fluentRemove("pkeyId")
  1511. .fluentRemove("p_key_id")
  1512. .fluentRemove("projectId")
  1513. .fluentRemove("classify")
  1514. .fluentRemove("pickerKey")
  1515. .fluentRemove("id")
  1516. .fluentRemove("isFirst")
  1517. .fluentRemove("firstNodeId")
  1518. .fluentRemove("isTheLog")
  1519. .fluentRemove("theLogId")
  1520. .fluentRemove("linkTabIds")
  1521. .fluentRemove("recordTime")
  1522. .fluentRemove("businessId")
  1523. .fluentRemove("sourceUrl")
  1524. .fluentRemove("pdfUrl")
  1525. .fluentRemove("firstFileName")
  1526. .fluentRemove("");
  1527. // 计算数据
  1528. LinkedHashMap<String, List<String>> dataMap = dataInfo2.keySet().stream().filter(e -> e.contains("__")).collect(Collectors.groupingBy(e -> e.split("__")[0], LinkedHashMap<String, List<String>>::new, Collectors.toList()));
  1529. LinkedHashMap<String, String> dataMap2 = new LinkedHashMap<>();
  1530. // 字段组合
  1531. for (String k : dataMap.keySet()) {
  1532. if (dataMap.get(k).size() > 1 && !dataMap.get(k).contains("000Z")) {
  1533. String[] ziduan = dataMap.get(k).toArray(new String[]{});
  1534. String temp = "";
  1535. for (int i = 0; i < ziduan.length - 1; i++) {
  1536. for (int j = 0; j < ziduan.length - i - 1; j++) {
  1537. Integer tr = Integer.parseInt((ziduan[j].split("__")[1]).split("_")[0]);
  1538. Integer td = Integer.parseInt(ziduan[j].split("__")[1].split("_")[1]);
  1539. Integer tr_1 = Integer.parseInt(ziduan[j + 1].split("__")[1].split("_")[0]);
  1540. Integer td_1 = Integer.parseInt(ziduan[j + 1].split("__")[1].split("_")[1]);
  1541. if (tr > tr_1 && td.equals(td_1)) { //纵向排序
  1542. temp = ziduan[j];
  1543. ziduan[j] = ziduan[j + 1];
  1544. ziduan[j + 1] = temp;
  1545. }
  1546. }
  1547. }
  1548. String lastStr = dataInfo2.getString(ziduan[0]) + "_^_" + ziduan[0].split("__")[1];
  1549. for (int i = 1; i < ziduan.length; i++) {
  1550. String keyData = dataInfo2.getString(ziduan[i]);
  1551. if (org.apache.commons.lang.StringUtils.isNotEmpty(keyData) && !keyData.equals("")) {
  1552. lastStr += "☆" + dataInfo2.getString(ziduan[i]) + "_^_" + ziduan[i].split("__")[1];
  1553. }
  1554. }
  1555. dataMap2.put(k, lastStr);
  1556. } else {
  1557. String dataVal = dataInfo2.getString(dataMap.get(k).get(0));
  1558. if (org.apache.commons.lang.StringUtils.isNotEmpty(dataVal)) {
  1559. if (dataVal.contains("Ljava")) {
  1560. Object o = dataInfo2.get(dataMap.get(k).get(0));
  1561. dataVal = JSON.toJSONString(o).replace("\"", "");
  1562. }
  1563. dataMap2.put(k, dataVal + "_^_" + dataMap.get(k).get(0).split("__")[1]);
  1564. }
  1565. }
  1566. }
  1567. dataInfo2.put("p_key_id", tableInfo.getPkeyId());
  1568. dataInfo2.put("classify",tableInfo.getClassify());
  1569. dataInfo2.put("contractId",tableInfo.getContractId());
  1570. dataInfo2.put("projectId",tableInfo.getProjectId());
  1571. tableInfo.setDataMap(dataMap2);
  1572. result.add(tableInfo);
  1573. }
  1574. return result;
  1575. }
  1576. return null;
  1577. }
  1578. public static void setFirstData(com.alibaba.fastjson.JSONObject dataInfo2, TableInfo tableInfo) {
  1579. //huangjn 判断是否是首件
  1580. if (dataInfo2.containsKey("isFirst")) {
  1581. tableInfo.setIsFirst(dataInfo2.getString("isFirst"));
  1582. }
  1583. //huangjn 判断是否是首件
  1584. //首件资料绑定的节点
  1585. if (dataInfo2.containsKey("firstNodeId")) {
  1586. tableInfo.setFirstNodeId(dataInfo2.getString("firstNodeId"));
  1587. }
  1588. //首件ID(编辑时有值,新增时为空)
  1589. if (dataInfo2.containsKey("firstId")) {
  1590. tableInfo.setFirstId(dataInfo2.getString("firstId"));
  1591. }
  1592. //源文件
  1593. if (dataInfo2.containsKey("sourceUrl")) {
  1594. tableInfo.setSourceUrl(dataInfo2.getString("sourceUrl"));
  1595. }
  1596. //pdfUrl
  1597. if (dataInfo2.containsKey("pdfUrl")) {
  1598. tableInfo.setPdfUrl(dataInfo2.getString("pdfUrl"));
  1599. }
  1600. //文件名称
  1601. if (dataInfo2.containsKey("firstFileName")) {
  1602. tableInfo.setFirstFileName(dataInfo2.getString("firstFileName"));
  1603. }
  1604. //关联的信息
  1605. if (dataInfo2.containsKey("linkProcessList")) {
  1606. tableInfo.setLinkProcessList(dataInfo2.getJSONArray("linkProcessList"));
  1607. }
  1608. }
  1609. public static void setTheLogData(JSONObject dataInfo2, TableInfo tableInfo) {
  1610. //huangjn 判断是否是日志
  1611. if (dataInfo2.containsKey("isTheLog")) {
  1612. tableInfo.setIsTheLog(dataInfo2.getString("isTheLog"));
  1613. }
  1614. //huangjn 判断是否是日志
  1615. //huangjn 日志ID
  1616. if (dataInfo2.containsKey("theLogId")) {
  1617. tableInfo.setTheLogId(dataInfo2.getString("theLogId"));
  1618. }
  1619. //huangjn 日志ID
  1620. //huangjn 日志勾选的工序
  1621. if (dataInfo2.containsKey("linkTabIds")) {
  1622. tableInfo.setLinkTabIds(dataInfo2.getJSONArray("linkTabIds"));
  1623. }
  1624. //huangjn 日志勾选的工序
  1625. //huangjn 日志所选时间
  1626. if (dataInfo2.containsKey("recordTime")) {
  1627. tableInfo.setRecordTime(dataInfo2.getString("recordTime"));
  1628. }
  1629. //huangjn 日志所选时间
  1630. //huangjn 每份填报数据的id,目前日志专用
  1631. if (dataInfo2.containsKey("id")) {
  1632. tableInfo.setBusinessId(dataInfo2.getString("id"));
  1633. }
  1634. //huangjn 每份填报数据的id,目前日志专用
  1635. }
  1636. }