宿迁北京网站建设,凡客网登录,免费自助站制作在线,天津企业网站推广方法不是所有设备都是TCP连接模式#xff0c;有读文件的、读数据库的设备#xff0c;为此还需要一个客户端仪器接口程序#xff0c;面向接口编程是一个良好的思想#xff0c;他使得调用者和接口实现者不用绑定太死#xff0c;只要双方按约定实现即可。
仪器有读文件的、写文件…不是所有设备都是TCP连接模式有读文件的、读数据库的设备为此还需要一个客户端仪器接口程序面向接口编程是一个良好的思想他使得调用者和接口实现者不用绑定太死只要双方按约定实现即可。
仪器有读文件的、写文件的、读数据库的、写数据库的、定时取图的等从PDF提取数据的、从Excel提取数据、读csv等。虽然很繁杂但是对业务解析大家是固定的都是要解析数据行再把数据存入LIS。所以可以抽取接口把繁杂的文件和数据库操作留给主程序把业务解析操作留给接口实现类。
初步效果
配置对象对接JSON的配置通过配置控制主程序行为
package JRTMachineImpl.Base;/*** 用来配置仪器接口的行为去和配置串匹配通过配置控制行为*/
public class ConfDto {/*** 构造,避免为null*/public ConfDto(){MachID;Type;Address;UpTime30000;DealProcess;Para;UpPara;PreDealClass;UPPreDealClass;BakPath;PathRegex;ReadFileModel;IsDBLooseKey;ReadFileLeavelModel;OtherPara;CopyFile;ExcelSheetIndex;RowSplitChar;WaringDealNum;DBChangeUpLoadWaringNum;NotSaveLog;DemoImageClass;StableTime8000;SleepTime2000;Encoding;WriteEncoding;ImgPixelFormat;ImgZipWidthHeight;ImgCutRate;ImgAddSuffix;ExcludeFile;MachName;AutoClipboardImg;PDFImageModel;PDFCutPageRectImage;}/*** 仪器主键*/public String MachID;/*** 监听类型*/public String Type;/*** 监听地址*/public String Address;/*** 上传定时间隔*/public int UpTime;/*** 处理程序类*/public String DealProcess;/*** 参数*/public String Para;/*** 上传前处理参数*/public String UpPara;/*** 前处理类类全名,动态库名*/public String PreDealClass;/*** 上传前处理类类全名,动态库名*/public String UPPreDealClass;/*** 备份路径*/public String BakPath;/*** 读取文件一级目录正则表达式没有读取全部文件夹有内容按正则表达式读取符合的文件夹对日期表示的约定$y1 $y2 $y3 $y4表示年的1234位$M1 $M2表示月的12位$d1 $d2表示日的12位。例如$y1$y2$y3$y4$M1$M2$d1$d2.**/public String PathRegex;/*** 读取文件模式0读完删除1读取变化的,读完不删,2监听到变化后不整个读取从上次最后行读取行数小于最后行从头读取*/public String ReadFileModel;/*** 数据库监听比对模式是否是宽松型主键1的话存一个主键多条记录日志数据串和全部日志不同才上传检验否则不上传*/public String IsDBLooseKey;/*** 读取文件层级模式0读取子级1仅读取一级目录*/public String ReadFileLeavelModel;/*** 其他参数供前处理使用*/public String OtherPara;/*** 拷贝文件参数*/public String CopyFile;/*** 读取Excel的页索引*/public String ExcelSheetIndex;/*** 读数据库一行数据多列之间的分隔符不配置为~*/public String RowSplitChar;/*** 调用保存数据警告次数一天内一次运行调用次数到达数量后将弹窗警告*/public String WaringDealNum;/*** 数据库变化模式数据变化触发警告的次数防止主键不唯一重复传输*/public String DBChangeUpLoadWaringNum;/*** 监听是否放弃保存数据文件日志1:是否则默认保存到C盘10天或者按配置的BakPath路径备份完成新老并行。默认读取和上传日志在C:\LISMachineLogMian、上传日志在UP文件夹*/public String NotSaveLog;/*** 默认选图和截图上传图片的类别*/public String DemoImageClass;/*** 最后修改时间和当前时间的秒数用来确定文件是否处于稳定状态单位秒。为正数用当前电脑时间和文 件最后修改时间差比较。为负数的话第一次文件都不读用两次文件的时间差比较*/public String StableTime;/*** 每一轮循环后休眠的时间单位毫秒*/public String SleepTime;/*** 读取文本的编码格式空默认系统编码可为:ASCII、Default、Unicode、UTF32、UTF7、UTF8*/public String Encoding;/*** 写文本的编码格式空默认系统编码可为:ASCII、Default、Unicode、UTF32、UTF7、UTF8*/public String WriteEncoding;/*** 上传图片的图像深度默认原图上传自己画的为32深度。可以指定24就采用24深度在上传图片前转换*/public String ImgPixelFormat;/*** 上传图片的图像要压缩的宽高格式230*200*/public String ImgZipWidthHeight;/*** 上传图片的图像要截取的宽高格式1*0.7*/public String ImgCutRate;/*** 上传图片添加的后缀带点*/public String ImgAddSuffix;/*** 排除文件*/public String ExcludeFile;/*** 仪器名字*/public String MachName;/*** 自动监听粘贴板图片*/public String AutoClipboardImg;/*** 空得到所有图。0只取小图1只取大图*/public String PDFImageModel;/*** PDF解析处理的一页图片是否切割矩形小图 1切割0不切割*/public String PDFCutPageRectImage;
}
前处理接口重要
package JRTMachineImpl.Base;import JRTMachineImpl.Base.ConfDto;import java.util.Map;/*** 往检验上传数据之前调用的处理接口任何要给LIS上传数据的处理类实现该接口主程序会把数据一行行抛给接口方法处理* 接口不需要关心主程序的实现主程序不用关心具体的业务处理*/
public interface IPreDeal {/*** 前处理** param conf 监听配置* param result 结果串* param index 当前文件的第几行* param fileName 当前读取的文件全名* return 是否继续后处理true是false否*/boolean PreDeal(ConfDto conf, String result, int index, String fileName);/*** 数据库前处理** param conf 监听配置* param row 结果Map* param index 当前文件的第几行* return 是否继续后处理true是false否*/boolean PreDealDataBase(ConfDto conf, Map row, int index);
}
上传前处理接口重要
package JRTMachineImpl.Base;import JRTMachineImpl.Base.ConfDto;
import JRTMachineImpl.Base.CmdDto;import java.util.Map;/*** 往检验上传数据之前调用的处理接口根据虚拟M返回的命令执行。任何要给仪器上传的仪器接口实现该接口主程序会按时间配置定时执行虚拟M查询数据逻辑后调用该接口。*/
public interface IUpPreDeal {/*** 上传前处理** param conf 监听配置* param key 操作键不为空成功就调用处理类的SetFlag方法设置状态* param cmd 要执行的命令* return 是否继续后处理true是false否*/boolean UPPreDeal(ConfDto conf, String key, CmdDto cmd);
}
定时执行接口
package JRTMachineImpl.Base;import JRTMachineImpl.Base.ConfDto;/*** 定时执行的接口定时取图等实现。任何要实现定制执行逻辑的对象实现此接口主程序会按配置时间定时调用该接口来达到定时执行固定逻辑。*/
public interface ITimer {/*** 执行任务* param conf*/void Action(ConfDto conf);
}
基础类
package JRTMachineImpl.Base;import JRTMachineImpl.WebService.OutValue;
import JRTMachineImpl.Util.LogUtils;
import JRTMachineImpl.Base.CmdDto;import java.util.List;/*** 实现基础逻辑保存数据存图片路径上传文件执行命令等*/
public class BaseDeal {/*** 保存数据** param conf 配置* param data 数据* param epis 流水* param index 序号* param fileName 文件全名* param DBColName 数据库列名* return* throws Exception*/public String SaveData(JRTMachineImpl.Base.ConfDto conf, String data, String epis, int index, String fileName, String DBColName) throws Exception {//得到配置的处理程序处理数据try {LogUtils.WriteSecurityLog(开始调用保存 conf.DealProcess .SaveData 参数:P0: conf.MachID P1: data P2:);LogUtils.WriteDebugLog(开始调用 conf.DealProcess .SaveData 参数:P0: conf.MachID P1: data P2: epis);//索引int rowCount;//类名String className conf.DealProcess;//方法名String funcName SaveData;//创建参数对象JRTMachineImpl.WebService.Parameters param new JRTMachineImpl.WebService.Parameters();//仪器主键param.P0 conf.MachID;//结果param.P1 data;//流水号param.P2 epis;//文件名param.P3 fileName;//文件名param.P4 DBColName;//读文件序号param.P5 String.valueOf(index);//写日志LogUtils.WriteDebugLog(保存 conf.MachID ,数据 data ,流水号 epis);OutValue session new OutValue();OutValue out new OutValue();//序列号保存配置数据String objStr JRTMachineImpl.WebService.WebGetData.GetData(, className, funcName, param, session, out);LogUtils.WriteDebugLog(调用结束);LogUtils.WriteDebugLog(保存返回 objStr);LogUtils.WriteSecurityLog(保存返回 objStr);//返回就认为返回的命令列表if (objStr ! ) {LogUtils.WriteDebugLog(处理返回消息);ListCmdDto cmdList JRTMachineImpl.Util.JsonDealUtil.Json2List(objStr, CmdDto.class);ExecCommand(cmdList, conf);LogUtils.WriteDebugLog(处理返回消息结束);}//设置调用次数//SetDealNum();} catch (Exception ex) {LogUtils.WriteExceptionLog(获得数据处理程序失败, ex);throw ex;}return ;}/*** 执行命令** param cmdList 要执行的命令列表* param conf 配置*/public void ExecCommand(ListCmdDto cmdList, JRTMachineImpl.Base.ConfDto conf) {//把取图写文件执行SQL等约定成命令来简化程序逻辑}
}
主程序模型
这样监听的基础就打下了
