From 4fad9b294ec8522c165df99ef64125ed979aab13 Mon Sep 17 00:00:00 2001 From: lxl <1542470468@qq.com> Date: Tue, 23 Jul 2024 10:26:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=A8=E9=87=8F=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pur/cosmic/plugin/demo/EmailSender.java | 45 ++++ .../pur/cosmic/plugin/demo/TestSignXK.java | 30 +++ .../cosmic/plugin/form/ShkdListPlugin.java | 63 +++++ .../cosmic/plugin/form/ShkdXQBillPlugin.java | 234 ++++++++++++++++++ .../plugin/form/ToTrdSysPageFormPlugin.java | 53 ++++ .../pur/cosmic/plugin/form/XQSignHelper.java | 94 +++++++ .../plugin/form/XhlAdjpstbillPlugin.java | 70 ++++++ .../form/XhlDailyReimbursePlugin001.java | 123 +++++++++ .../form/XhlDailyReimbursePlugin02.java | 67 +++++ .../plugin/operate/XhlAuditOpPlugin.java | 133 ++++++++++ .../pur/cosmic/plugin/operate/xqconvert.java | 29 +++ .../pur/cosmic/plugin/util/SendEmailUtil.java | 74 ++++++ .../plugin/workflow/XhlWorkFlowPlugin.java | 89 +++++++ 13 files changed, 1104 insertions(+) create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/EmailSender.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/TestSignXK.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdListPlugin.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdXQBillPlugin.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ToTrdSysPageFormPlugin.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XQSignHelper.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlAdjpstbillPlugin.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin001.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin02.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/XhlAuditOpPlugin.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/xqconvert.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/util/SendEmailUtil.java create mode 100644 pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/workflow/XhlWorkFlowPlugin.java diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/EmailSender.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/EmailSender.java new file mode 100644 index 0000000..0084ac1 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/EmailSender.java @@ -0,0 +1,45 @@ +package q79l.pur.cosmic.plugin.demo; + +import java.util.Properties; +import javax.mail.Message; +import javax.mail.MessagingException; +import javax.mail.Session; +import javax.mail.Transport; +import javax.mail.internet.InternetAddress; +import javax.mail.internet.MimeMessage; + +public class EmailSender { + private String fromEmail; + private String password; + private String host; + private int port; + + public EmailSender(String fromEmail, String password, String host, int port) { + this.fromEmail = fromEmail; + this.password = password; + this.host = host; + this.port = port; + } + + public void sendEmail(String toEmail, String subject, String content) throws MessagingException { + Properties properties = new Properties(); + properties.put("mail.smtp.auth", "true"); + properties.put("mail.smtp.starttls.enable", "true"); + properties.put("mail.smtp.host", host); + properties.put("mail.smtp.port", port); + + Session session = Session.getInstance(properties, new javax.mail.Authenticator() { + protected javax.mail.PasswordAuthentication getPasswordAuthentication() { + return new javax.mail.PasswordAuthentication(fromEmail, password); + } + }); + + Message message = new MimeMessage(session); + message.setFrom(new InternetAddress(fromEmail)); + message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(toEmail)); + message.setSubject(subject); + message.setText(content); + + Transport.send(message); + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/TestSignXK.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/TestSignXK.java new file mode 100644 index 0000000..9f42cce --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/demo/TestSignXK.java @@ -0,0 +1,30 @@ +package q79l.pur.cosmic.plugin.demo; + +import q79l.pur.cosmic.plugin.form.SignHelper; + +import javax.mail.MessagingException; +import java.io.UnsupportedEncodingException; + +public class TestSignXK { + + public static void main(String[] args) throws UnsupportedEncodingException { +// String url = SignHelper.JumpPurchaseOrderList("伍平"); + String fromEmail = "srm.service@xingqikeji.com"; // 你的阿里云邮箱地址 + String password = "SRM@xq123"; // 你的阿里云邮箱密码 + String host = "smtp.xingqikeji.com"; // 阿里云SMTP服务器地址 + int port = 465; // 阿里云SMTP服务器端口 + + EmailSender emailSender = new EmailSender(fromEmail, password, host, port); + String toEmail = "1542470468@qq.com"; // 收件人邮箱地址 + String subject = "Test Email"; // 邮件主题 + String content = "Hello, this is a test email sent from Java using Aliyun email service."; // 邮件内容 + + try { + emailSender.sendEmail(toEmail, subject, content); + System.out.println("Email sent successfully!"); + } catch (MessagingException e) { + e.printStackTrace(); + System.out.println("Failed to send email."); + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdListPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdListPlugin.java new file mode 100644 index 0000000..9f76fe3 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdListPlugin.java @@ -0,0 +1,63 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.form.ConfirmCallBackListener; +import kd.bos.form.MessageBoxOptions; +import kd.bos.form.control.events.ItemClickEvent; +import kd.bos.list.BillList; +import kd.bos.list.IListView; +import kd.bos.list.plugin.AbstractListPlugin; +import net.sf.json.JSONObject; + +import java.util.EventObject; + +public class ShkdListPlugin extends AbstractListPlugin { + + @Override + public void registerListener(EventObject e) { + // TODO 自动生成的方法存根 + super.registerListener(e); + this.addItemClickListeners("toolbarap"); + } + + + @Override + public void itemClick(ItemClickEvent evt) { + + String key = evt.getItemKey(); + String entityName = ((IListView) this.getView()).getBillFormId(); + BillList billList = this.getControl("billlistap"); + //获取选中的ids + Object[] ids = billList.getSelectedRows().getPrimaryKeyValues();//选中行单据id集合 + JSONObject js = new JSONObject(); + /** + * {"dbid":"61cd78fbc6aa78","username":"zhangsan", + * "appid":"BMMailApprovalApp","signeddata":"230bff1feb781****3458d30f37f17c824a8a5f30417608ca2ccfe1140bec9f2", + * "timestamp":"1649726187","lcid":"2052","origintype":"SimPas", + * "entryrole":"","formid":"","formtype":"","pkid":"","openmode":null} + */ + long timeMillis = System.currentTimeMillis(); + js.put("dbid","");//数据中心的ID + js.put("username","");//用户名称 + js.put("appid","");//应用程序ID + js.put("signeddata","");// + js.put("timestamp",String.valueOf(timeMillis));//时间戳 + js.put("lcid","2052");//语言ID，中文2052（默认），英文1033，繁体3076 + js.put("origintype","SimPas");//XT=云之家集成（同时要求entryrole=XT）；SimPas=简单通行证集成 + js.put("entryrole","");//验证权限的入口角色 + js.put("formid","");//登录后默认打开功能的表单id + js.put("formtype","bill");//单据：bill或空, 列表：list, 万能报表：wnreport, 直接sql报表：sqlreport, 系统报表：sysreport， 树形报表：treereport, 移动报表：movereport， 动态表单：dynamicform + js.put("pkid","");//formid对应表单的主键；formtype为list时忽略，formtype为bill时起作用，如果为空表示新增状态 + js.put("openmode","");//登陆后打开指定功能单据的模式，空白=原有主控模式，Single=单独打开指定单据（没有主控功能，仅HTML5端支持 + if ("shkd_url".equals(key)) { +// for (Object id : ids) { +// String result = ListPluginImpl.impl(key, billList, id, entityName); +// if (StringUtils.isNotBlank(null)) { +// this.getView().openUrl(result); +// } else { + ConfirmCallBackListener confirmCallBackListener = new ConfirmCallBackListener("shkd_url", this); + this.getView().showConfirm("不允许跳转", MessageBoxOptions.OK, confirmCallBackListener); +// } +// } + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdXQBillPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdXQBillPlugin.java new file mode 100644 index 0000000..ef4994b --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ShkdXQBillPlugin.java @@ -0,0 +1,234 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.bill.AbstractBillPlugIn; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.entity.datamodel.IBillModel; +import kd.bos.fileservice.FileServiceFactory; +import kd.bos.form.ConfirmCallBackListener; +import kd.bos.form.MessageBoxOptions; +import kd.bos.form.control.events.ItemClickEvent; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.AttachmentServiceHelper; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.web.actions.utils.FilePathUtil; +import org.apache.commons.lang3.StringUtils; + +import javax.activation.DataHandler; +import javax.activation.DataSource; +import javax.mail.*; +import javax.mail.internet.InternetAddress; +import javax.mail.internet.MimeBodyPart; +import javax.mail.internet.MimeMessage; +import javax.mail.internet.MimeMultipart; +import javax.mail.util.ByteArrayDataSource; +import java.io.InputStream; +import java.net.URLDecoder; +import java.security.Security; +import java.util.*; + +public class ShkdXQBillPlugin extends AbstractBillPlugIn { + + private static Log log = LogFactory.getLog(ShkdXQBillPlugin.class); + + @Override + public void registerListener(EventObject e) { + // TODO 自动生成的方法存根 + super.registerListener(e); + this.addItemClickListeners("tbmain"); + this.addItemClickListeners("toolbarap"); + } + + static String emailText = "你好：\n" + + "\n" + + "\n" + + "1. 附件是《采购合同》，请确认无误后务必盖章回传电子版（后续银行付款需要查看审核），并将合同盖章原件寄给我（需要说明一下，以后单笔订单总金额大于3000元的，请将盖章原件每个月汇总一次邮寄过来，邮寄地址见下方签名；小于3000元的，只要求盖章回传即可）。\n" + + "\n" + + "2． 产品交付日期：期望交期2024年7月13日，请邮件回复是否可在此日期交付。\n" + + "\n" + + "3. 交货需要您提供：《产品合格证》、《材质证明》、《出厂检验报告》，包装发货前拍视频及照片留存，发货后提供物流单号【我司建议发货物流选择顺丰/跨越/德邦,以免造成不必要的货物丢失事故，因物流而导致的物料丢失问题，我司将不会负责】。\n" + + "\n" + + "4. 供应商发票规格，数量，单位均需按我司合同内容开票，如不一致，我司有权要求供应商重开发票。\n" + + "\n" + + "5. 包装及外观要求： 附件为激光打标内容(序列号会在发货前提供)，需要按照此模板来打印。包装需要双层抽真空包装，针对激光件和球阀。\n" + + "\n" + + " \n" + + "\n" + + "注意：\n" + + "\n" + + "1、订单收到后请在2个工作日内回传。\n" + + "\n" + + "2、发货前请以邮件形式提前告知运单号和发货清单，方便采购通知仓库收货，到货超过一周未通知采购，仓库会进行退货处理。\n" + + "\n" + + "3、开票前一定要提前对账，电子发票请发采购员邮箱，纸质发票请邮寄给采购员，地址见签名。\n" + + "\n" + + "4、付款前请提供发票。\n" + + "\n" + + "请关注以上规定，以免影响财务结算导致延期付款。\n" + + "\n" + + "谢谢配合。\n" + + "\n" + + " \n" + + "\n" + + " \n" + + "\n" + + " \n" + + "\n" + + "需要图纸加工的零件，请务必严格核对订单图纸版本号和图纸内版本号一致；如不一致，请即刻联系星奇要正确版本号图纸。"; + @Override + public void itemClick(ItemClickEvent evt) { + + String key = evt.getItemKey(); + IBillModel model = (IBillModel) this.getModel(); + String entityName = model.getDataEntityType().toString(); + DynamicObject entity = model.getDataEntity(); + Object id = entity.getPkValue(); + + //发送邮件二开 + if ("shkd_sendemail".equals(key)) { + List> attachmentpanel = AttachmentServiceHelper.getAttachments(entityName, id, "attachmentpanel"); +// Object receivingsupplierid = this.getModel().getValue("supplier"); +// if(receivingsupplierid != null){ +// DynamicObject supplier = (DynamicObject)receivingsupplierid; +// //电子邮箱 +// Object postal_code = supplier.get("postal_code"); +// //联系人分录 +// DynamicObjectCollection entry_linkman = supplier.getDynamicObjectCollection("entry_linkman"); +// //联系人分录-邮箱 +// Object email = entry_linkman.get(0).get("email"); +// } + Multipart multipart = new MimeMultipart(); + int i = 0; + if(attachmentpanel.size()>0){ + for (Map stringObjectMap : attachmentpanel) { + String url = stringObjectMap.get("url").toString(); + String[] split = url.split("path="); + String path = split[1]; + Object type = stringObjectMap.get("type"); + Object name = stringObjectMap.get("name"); + String nametype = name+"."+type; + System.out.println("path:"+path+"type:"+type); + try { + String downLoadUrl = kd.bos.login.utils.StringUtils.getStringValue(url); + String pathurl = downLoadUrl.substring(downLoadUrl.indexOf("path=") + "path=".length()); + pathurl = URLDecoder.decode(pathurl, "UTF-8"); + if(path.indexOf('&')>0){ + pathurl = pathurl.substring(0,pathurl.indexOf('&')); + } + downLoadUrl = FilePathUtil.dealPath(pathurl, "attach"); + InputStream inputStream = FileServiceFactory.getAttachmentFileService().getInputStream(downLoadUrl); +// //将附件转换成byte数组 +// file = urltobyte(path); +// bytelist.add(file); +// //附件名的list +// attachmentNames.add(nametype); + // 创建多部分内容 + // 添加邮件正文 + BodyPart messageBodyPart = new MimeBodyPart(); + if(i == 0){ + messageBodyPart.setText(emailText); + ++i; + } + multipart.addBodyPart(messageBodyPart); + // 添加附件 + messageBodyPart = new MimeBodyPart(); + DataSource dataSource=new ByteArrayDataSource(inputStream, "application/octet-stream"); + messageBodyPart.setDataHandler(new DataHandler(dataSource)); + messageBodyPart.setFileName(nametype); + multipart.addBodyPart(messageBodyPart); + } catch (Exception e) { + log.error(e); + } + } + }else{ + try { + BodyPart messageBodyPart = new MimeBodyPart(); + messageBodyPart.setText(emailText); + multipart.addBodyPart(messageBodyPart); + } catch (MessagingException e) { + throw new RuntimeException(e); + } + } + sendMail(multipart); + this.getView().showTipNotification("发送成功！"); + } + super.itemClick(evt); + } + + public static void sendMail(Multipart multipart){ + Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider()); + final String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory"; + // 设置邮件服务器属性 + Map emailMap = getEmailMap(); + String host = emailMap.get("host"); + String port = emailMap.get("port"); + String auth = emailMap.get("auth"); + String enable = emailMap.get("enable"); + String username = emailMap.get("username"); + String password = emailMap.get("password"); + String toemail = emailMap.get("toemail"); + log.info("emailMap"+emailMap); + Properties properties = new Properties(); + + + properties.setProperty("mail.smtp.host", host);//smtp服务器地址 + //props.setProperty("mail.smtp.port", "25");//非加密端口 + // 使用ssl加密方式，进行如下配置： + properties.setProperty("mail.smtp.socketFactory.class", SSL_FACTORY); + properties.setProperty("mail.smtp.socketFactory.fallback", "false"); + properties.setProperty("mail.smtp.socketFactory.port", port); + + properties.setProperty("mail.smtp.auth", "true");//表示SMTP发送邮件，需要进行身份验证 + properties.setProperty("mail.smtp.from", username);//mailfrom 参数 + properties.setProperty("mail.user",username);//发件人的账号 + properties.setProperty("mail.password",password);// 发件人的账号的密码，如果开启三方客户端安全密码请使用新生产的密码 + + // 创建认证对象 + Authenticator authenticator = new Authenticator() { + protected PasswordAuthentication getPasswordAuthentication() { + return new PasswordAuthentication(username, password); + } + }; + + // 获取邮件会话对象 + Session session = Session.getDefaultInstance(properties, authenticator); + log.info("获取邮件会话对象Properties"+session.getProperties()); + try { + // 创建邮件对象 + MimeMessage message = new MimeMessage(session); + message.setFrom(new InternetAddress(username)); + message.addRecipient(Message.RecipientType.TO, new InternetAddress(toemail)); + message.setSubject("带附件的邮件"); + + message.setContent(multipart); + log.info("发送邮件前"); + // 发送邮件 + Transport transport = session.getTransport("smtp"); + transport.connect(host,username,password); + log.info("发送邮件中"); + transport.sendMessage(message,message.getRecipients(Message.RecipientType.TO)); + transport.close(); +// Transport.send(message); + + log.info("发送邮件后"); + } catch (MessagingException e) { + e.printStackTrace(); + log.info("发送失败",e); + log.info(e.toString()); + } + } + + public static Map getEmailMap(){ + + Map map = new HashMap(); + DynamicObject[] shkd_image = BusinessDataServiceHelper.load("shkd_email", "shkd_value,name", new QFilter[]{}); + for (DynamicObject str:shkd_image) { + String name = str.getString("name"); + String shkd_textfield = str.getString("shkd_value"); + map.put(name,shkd_textfield); + } + return map; + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ToTrdSysPageFormPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ToTrdSysPageFormPlugin.java new file mode 100644 index 0000000..878132c --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/ToTrdSysPageFormPlugin.java @@ -0,0 +1,53 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.context.RequestContext; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.utils.StringUtils; +import kd.bos.form.ConfirmCallBackListener; +import kd.bos.form.MessageBoxOptions; +import kd.bos.form.control.IFrame; +import kd.bos.form.events.PreOpenFormEventArgs; +import kd.bos.form.plugin.AbstractFormPlugin; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; + +import java.io.UnsupportedEncodingException; +import java.util.EventObject; + +/** + * 点击苍穹应用菜单单点登录第三方系统并打开页面 + * @author kingdee + * + */ +public class ToTrdSysPageFormPlugin extends AbstractFormPlugin { + + // 展示第三方系统页面的IFrame控件 + private static final String KEY_IFRAME_TRDSYSPAGE = "shkd_iframeap"; + + @Override + public void preOpenForm(PreOpenFormEventArgs e) { + + // 取消打开页面 + e.setCancel(true); + super.preOpenForm(e); + } + + @Override + public void afterBindData(EventObject e) { + super.afterBindData(e); + // 为IFrame控件设置URL + IFrame iFrame = this.getView().getControl(KEY_IFRAME_TRDSYSPAGE); + String userId = RequestContext.get().getUserId(); + long l = Long.parseLong(userId); +// QFilter qFilter = new QFilter("id", QCP.equals,l); +// DynamicObject user = BusinessDataServiceHelper.loadSingle("bos_user","name",qFilter.toArray()); +// String name = user.getString("name"); + try { + String url = XQSignHelper.JumpPurchaseOrderList("系统实施"); + iFrame.setSrc(url); + } catch (UnsupportedEncodingException ex) { + throw new RuntimeException(ex); + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XQSignHelper.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XQSignHelper.java new file mode 100644 index 0000000..96be17e --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XQSignHelper.java @@ -0,0 +1,94 @@ +package q79l.pur.cosmic.plugin.form; + +import java.io.UnsupportedEncodingException; + +import java.nio.charset.StandardCharsets; +import java.util.Arrays; + +import com.alibaba.fastjson.JSONObject; +import kd.bos.dataentity.serialization.SerializationUtils; +import java.util.Base64; + +import org.apache.commons.codec.digest.DigestUtils; + + +public class XQSignHelper { + + /** + * + * @param usserName + * @return跳转采购订单列表 + * @throws UnsupportedEncodingException + */ + public static String JumpPurchaseOrderList(String usserName) throws UnsupportedEncodingException { + String dbId = "66681f2cfe8985";// 数据中心ID +// String usserName = "系统实施";// 用户名称 + String appId = "284568_72bp7ZuGQqqWTU8J223C0aWHVv4WQtOu";// 第三方系统应用Id + String appSecret = "019b5075692d4ca7af470b3bcd6ee2ea";// 第三方系统应用秘钥 + long currentTime = System.currentTimeMillis() / 1000; + String timestamp = Long.toString(currentTime); + String origintype = "SimPas"; + String entryrole = ""; + String formid = "PUR_PurchaseOrder"; + String formtype = "list"; + String pkid = ""; + String openmode = "Single"; + String[] strArray = { dbId, usserName, appId, appSecret, timestamp }; + Arrays.sort(strArray); + String combStr = null; + for (int i = 0; i < strArray.length; i++) { + if (combStr == null || combStr == "") { + combStr = strArray[i]; + } else { + combStr = combStr + strArray[i]; + } + } + byte[] strByte = combStr.getBytes("UTF-8"); + + byte[] strSign = DigestUtils.sha(strByte); + + String sign = bytesToHexString(strSign); + + JSONObject jsonObject = new JSONObject(); + jsonObject.put("dbId",dbId); + jsonObject.put("username",usserName); + jsonObject.put("appId",appId); + jsonObject.put("signeddata",sign); + jsonObject.put("timestamp",timestamp); + jsonObject.put("lcid","2052"); + jsonObject.put("origintype",origintype); + jsonObject.put("entryrole",entryrole); + jsonObject.put("formid",formid); + jsonObject.put("formtype",formtype); + jsonObject.put("pkid",pkid); + String urlPara = SerializationUtils.toJsonString(jsonObject); +// String urlPara = String.format("|%s|%s|%s|%s|%s|%s|%s|%s|%s|%s|%s", dbId, usserName, appId, sign, timestamp, "2052",origintype,entryrole,formid,formtype,pkid); + System.out.println("urlPara:"+urlPara); + urlPara = java.net.URLEncoder.encode(urlPara, "UTF-8"); + String encodedJson = Base64.getEncoder().encodeToString(urlPara.getBytes(StandardCharsets.UTF_8)); + String url = "http://222.71.193.253:8098/K3Cloud/html5/Index.aspx?ud=" + urlPara;// Silverlight入口链接 + + System.out.println(url); + return url; + } + + + + + + public static String bytesToHexString(byte[] src) { + StringBuilder stringBuilder = new StringBuilder(); + if (src == null || src.length <= 0) { + return null; + } + for (int i = 0; i < src.length; i++) { + int v = src[i] & 0xFF; + String hv = Integer.toHexString(v); + if (hv.length() < 2) { + stringBuilder.append(0); + } + stringBuilder.append(hv); + } + return stringBuilder.toString(); + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlAdjpstbillPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlAdjpstbillPlugin.java new file mode 100644 index 0000000..4891ac3 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlAdjpstbillPlugin.java @@ -0,0 +1,70 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.dataentity.utils.StringUtils; +import kd.bos.form.events.BeforeDoOperationEventArgs; +import kd.bos.form.operate.FormOperate; +import kd.bos.form.plugin.AbstractFormPlugin; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.servicehelper.BusinessDataServiceHelper; + +import java.util.ArrayList; +import java.util.List; + +public class XhlAdjpstbillPlugin extends AbstractFormPlugin { + + private final static Log logger = LogFactory.getLog(XhlAdjpstbillPlugin.class); + + @Override + public void beforeDoOperation(BeforeDoOperationEventArgs args) { + super.beforeDoOperation(args); + FormOperate operate = (FormOperate)args.getSource(); + String entityId = this.getView().getEntityId(); + if( StringUtils.equals(operate.getOperateKey(), "submit")){ + //对公报销单或借款单 + if(entityId.equals("bgm_adjpstbill") || entityId.equals("er_dailyloanbill")){ + Object departmenttes = this.getModel().getValue("department"); + logger.info("departmenttes:"+departmenttes.toString()); + Object id = this.getModel().getValue("id"); + DynamicObject department1 = BusinessDataServiceHelper.loadSingle(id, entityId, "id,department"); + if(department1 != null){ + DynamicObject department = department1.getDynamicObject("department"); + if(department != null){ + Object id1 = department.get("id"); + logger.info("departmentid:"+id1); + Object o = department.get("name.zh_CN"); + Object o1 = department.get("name"); + logger.info("departmentnamezh_CN:"+o+"departmentname"+o1); + DynamicObject org = BusinessDataServiceHelper.loadSingle(id1, "bos_org", "name"); + if(org != null){ + Object name = org.get("name"); + logger.info("name:"+name); + DynamicObjectCollection entryentity = this.getModel().getEntryEntity("entryentity"); + List orgnums = new ArrayList(); + if (entryentity.size()>0){ + int i = 0; + for (DynamicObject dynamicObject : entryentity) { + DynamicObject adjentity = dynamicObject.getDynamicObject("adjentity"); + String number = adjentity.getString("number"); + String substring = number.substring(0, 3); + logger.info("预算组织编码:"+number+"截取前三位字符："+substring); + if(i == 0){ + orgnums.add(substring); + ++i; + }else{ + if(!orgnums.contains(substring)){ + this.getView().showMessage("预算组织所属公司不是同一家，请重新选择"); + args.setCancel(true); + } + } + } + } + } + } + } + } + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin001.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin001.java new file mode 100644 index 0000000..6c3d25c --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin001.java @@ -0,0 +1,123 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.bill.AbstractBillPlugIn; +import kd.bos.dataentity.OperateOption; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.entity.operate.OperateOptionConst; +import kd.bos.entity.operate.result.OperateErrorInfo; +import kd.bos.entity.operate.result.OperationResult; +import kd.bos.entity.validate.ValidateResult; +import kd.bos.entity.validate.ValidateResultCollection; +import kd.bos.form.events.AfterDoOperationEventArgs; + +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.botp.BFTrackerServiceHelper; +import kd.bos.servicehelper.operation.OperationServiceHelper; +import kd.sdk.plugin.Plugin; + +import java.util.ArrayList; +import java.util.HashSet; +import java.util.List; +import java.util.Map; + + +public class XhlDailyReimbursePlugin001 extends AbstractBillPlugIn implements Plugin { + + private final static Log logger = LogFactory.getLog(XhlDailyReimbursePlugin001.class); + + + + /** + * + * @param afterDoOperationEventArgs + * + */ + @Override + public void afterDoOperation(AfterDoOperationEventArgs afterDoOperationEventArgs) { + super.afterDoOperation(afterDoOperationEventArgs); + String operateKey = afterDoOperationEventArgs.getOperateKey(); + logger.info("新浩隆-afterDoOperation"+operateKey); + if(operateKey.equals("audit")){ + logger.info("新浩隆-调用二开审核方法"); + String entityId = this.getView().getEntityId(); + Object id = this.getModel().getValue("id"); + Long[] ids = new Long[1]; + ids[0] = Long.parseLong(id.toString()); + Map> sourceBills = BFTrackerServiceHelper.findSourceBills(entityId, ids); + logger.info("新浩隆-调用二开审核方法：sourceBills"+sourceBills); + if(sourceBills != null) { + HashSet longs = sourceBills.get("er_dailyapplybill"); + if(longs != null){ + Object[] idss = longs.toArray(); + DynamicObject dailyapplybillType = BusinessDataServiceHelper.newDynamicObject("er_dailyapplybill"); + DynamicObject[] srcdatas = BusinessDataServiceHelper.load(idss,dailyapplybillType.getDynamicObjectType()); + logger.info("新浩隆-调用二开审核方法：srcdatas数量："+srcdatas.length); + OperateOption option= OperateOption.create(); + option.setVariableValue(OperateOptionConst.IGNOREWARN, String.valueOf(true)); // 不执行警告级别校验器 + OperationResult operationResult = OperationServiceHelper.executeOperate("closebill", "er_dailyapplybill", srcdatas, option); + List errors = new ArrayList(); + if(operationResult.isSuccess()){ + logger.info("新浩隆-执行成功，"); + logger.info("新浩隆-执行成功，"+operationResult.getMessage()); + }else{ + ValidateResultCollection validateResult = operationResult.getValidateResult(); + for (int j = 0; j < validateResult.errorSize(); j++) { + List validateErrors = validateResult.getValidateErrors(); + for (int k = 0; k < validateErrors.size(); k++) { + ValidateResult errinfo = validateErrors.get(k); + List allErrorInfo = errinfo.getAllErrorInfo(); + for (int l = 0; l < allErrorInfo.size(); l++) { + errors.add(allErrorInfo.get(l).getMessage()); + } + } + } + logger.info("新浩隆-执行失败，"); + logger.info("新浩隆-执行失败，"+errors); + } + } + } + } + else if(operateKey.equals("unaudit") || operateKey.equals("noapprive")){ + logger.info("新浩隆-调用二开驳回、审核不通过方法"); + String entityId = this.getView().getEntityId(); + Object id = this.getModel().getValue("id"); + Long[] ids = new Long[1]; + ids[0] = Long.parseLong(id.toString()); + Map> sourceBills = BFTrackerServiceHelper.findSourceBills(entityId, ids); + logger.info("新浩隆-调用二开驳回、审核不通过方法：sourceBills"+sourceBills); + if(sourceBills != null) { + HashSet longs = sourceBills.get("er_dailyapplybill"); + if(longs != null){ + Object[] idss = longs.toArray(); + DynamicObject dailyapplybillType = BusinessDataServiceHelper.newDynamicObject("er_dailyapplybill"); + DynamicObject[] srcdatas = BusinessDataServiceHelper.load(idss,dailyapplybillType.getDynamicObjectType()); + logger.info("新浩隆-调用二开驳回、审核不通过方法：srcdatas数量："+srcdatas.length); + OperateOption option= OperateOption.create(); + option.setVariableValue(OperateOptionConst.IGNOREWARN, String.valueOf(true)); // 不执行警告级别校验器 + OperationResult operationResult = OperationServiceHelper.executeOperate("submit1", "er_dailyapplybill", srcdatas, option); + List errors = new ArrayList(); + if(operationResult.isSuccess()){ + logger.info("新浩隆-执行成功，"); + logger.info("新浩隆-执行成功，"+operationResult.getMessage()); + }else{ + ValidateResultCollection validateResult = operationResult.getValidateResult(); + for (int j = 0; j < validateResult.errorSize(); j++) { + List validateErrors = validateResult.getValidateErrors(); + for (int k = 0; k < validateErrors.size(); k++) { + ValidateResult errinfo = validateErrors.get(k); + List allErrorInfo = errinfo.getAllErrorInfo(); + for (int l = 0; l < allErrorInfo.size(); l++) { + errors.add(allErrorInfo.get(l).getMessage()); + } + } + } + logger.info("新浩隆-执行失败，"); + logger.info("新浩隆-执行失败，"+errors); + } + } + } + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin02.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin02.java new file mode 100644 index 0000000..c76ab28 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/form/XhlDailyReimbursePlugin02.java @@ -0,0 +1,67 @@ +package q79l.pur.cosmic.plugin.form; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.dataentity.utils.StringUtils; +import kd.bos.form.events.BeforeDoOperationEventArgs; +import kd.bos.form.operate.FormOperate; +import kd.bos.form.plugin.AbstractFormPlugin; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; + +import java.util.ArrayList; +import java.util.List; + +public class XhlDailyReimbursePlugin02 extends AbstractFormPlugin { + + private final static Log logger = LogFactory.getLog(XhlDailyReimbursePlugin02.class); + + /** + * + * @param args + * 处理报销单关联申请选择申请单时不允许选择已被关联的申请单 + */ + @Override + public void beforeDoOperation(BeforeDoOperationEventArgs args) { + super.beforeDoOperation(args); + logger.info("新浩隆-beforeDoOperation"); + FormOperate operate = (FormOperate)args.getSource(); + logger.info("新浩隆-beforeDoOperation"+operate.getOperateKey()); + String entityId = this.getView().getEntityId(); + Object id = this.getModel().getValue("id"); + logger.info("新浩隆-id"+id); + Long[] ids = new Long[1]; + ids[0] = Long.parseLong(id.toString()); + if( StringUtils.equals(operate.getOperateKey(), "save") || StringUtils.equals(operate.getOperateKey(), "submit")){ + logger.info("新浩隆-调用二开保存提交"); + DynamicObjectCollection writeoffapplys = this.getModel().getEntryEntity("writeoffapply"); + logger.info("新浩隆-调用二开保存提交，writeoffapplys："+writeoffapplys.size()); + List applybillnos = new ArrayList(); + for (DynamicObject writeoffapply : writeoffapplys) { + String applybillno = writeoffapply.getString("applybillno"); + applybillnos.add(applybillno); + } + QFilter qFilter = new QFilter("writeoffapply.applybillno", QCP.in,applybillnos); + DynamicObject[] load = BusinessDataServiceHelper.load("er_dailyreimbursebill", "id,writeoffapply,writeoffapply.applybillno", qFilter.toArray()); + logger.info("新浩隆-调用二开保存提交，load："+load.length); + if(load.length>0){ + for (DynamicObject dynamicObject : load) { + if(!id.equals(dynamicObject.get("id"))){ + DynamicObjectCollection writeoffapply = dynamicObject.getDynamicObjectCollection("writeoffapply"); + for (DynamicObject object : writeoffapply) { + Object applybillno = object.get("applybillno"); + logger.info("新浩隆-调用二开保存提交，applybillno："+applybillno); + if (applybillnos.contains(applybillno.toString())){ + this.getView().showMessage("此申请单已被关联，请重选"+applybillno); + args.setCancel(true); + } + } + } + } + } + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/XhlAuditOpPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/XhlAuditOpPlugin.java new file mode 100644 index 0000000..caff6d5 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/XhlAuditOpPlugin.java @@ -0,0 +1,133 @@ +package q79l.pur.cosmic.plugin.operate; + +import kd.bos.dataentity.OperateOption; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.entity.MainEntityType; +import kd.bos.entity.operate.OperateOptionConst; +import kd.bos.entity.operate.result.OperateErrorInfo; +import kd.bos.entity.operate.result.OperationResult; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.AddValidatorsEventArgs; +import kd.bos.entity.plugin.PreparePropertysEventArgs; +import kd.bos.entity.plugin.args.EndOperationTransactionArgs; +import kd.bos.entity.validate.ValidateResult; +import kd.bos.entity.validate.ValidateResultCollection; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.botp.BFTrackerServiceHelper; +import kd.bos.servicehelper.operation.OperationServiceHelper; + +import java.util.ArrayList; +import java.util.HashSet; +import java.util.List; +import java.util.Map; + +public class XhlAuditOpPlugin extends AbstractOperationServicePlugIn { + private final static Log logger = LogFactory.getLog(XhlAuditOpPlugin.class); + @Override + public void onPreparePropertys(PreparePropertysEventArgs e) { + super.onPreparePropertys(e); + List fieldKeys = e.getFieldKeys(); + fieldKeys.addAll(this.billEntityType.getAllFields().keySet()); + } + @Override + public void onAddValidators(AddValidatorsEventArgs e) { + super.onAddValidators(e); + } + + @Override + public void endOperationTransaction(EndOperationTransactionArgs e) { + super.endOperationTransaction(e); + MainEntityType entityType = this.billEntityType; + String entityName = entityType.getName(); + DynamicObject[] entities = e.getDataEntities(); + String operationKey = e.getOperationKey(); + if(operationKey.equals("audit")){ + logger.info("新浩隆-调用二开审核方法"); + Long[] ids = new Long[entities.length]; + for (DynamicObject entity : entities) { + int k = 0; + Object id = entity.getPkValue(); + ids[k] = Long.parseLong(id.toString()); + ++k; + } + Map> sourceBills = BFTrackerServiceHelper.findSourceBills(entityName, ids); + logger.info("新浩隆-调用二开审核方法：sourceBills"+sourceBills); + if(sourceBills != null) { + HashSet longs = sourceBills.get("er_dailyapplybill"); + if(longs != null){ + Object[] idss = longs.toArray(); + DynamicObject dailyapplybillType = BusinessDataServiceHelper.newDynamicObject("er_dailyapplybill"); + DynamicObject[] srcdatas = BusinessDataServiceHelper.load(idss,dailyapplybillType.getDynamicObjectType()); + logger.info("新浩隆-调用二开审核方法：srcdatas数量："+srcdatas.length); + OperateOption option= OperateOption.create(); + option.setVariableValue(OperateOptionConst.IGNOREWARN, String.valueOf(true)); // 不执行警告级别校验器 + OperationResult operationResult = OperationServiceHelper.executeOperate("closebill", "er_dailyapplybill", srcdatas, option); + List errors = new ArrayList(); + if(operationResult.isSuccess()){ + logger.info("新浩隆-执行成功，"); + logger.info("新浩隆-执行成功，"+operationResult.getMessage()); + }else{ + ValidateResultCollection validateResult = operationResult.getValidateResult(); + for (int j = 0; j < validateResult.errorSize(); j++) { + List validateErrors = validateResult.getValidateErrors(); + for (int k = 0; k < validateErrors.size(); k++) { + ValidateResult errinfo = validateErrors.get(k); + List allErrorInfo = errinfo.getAllErrorInfo(); + for (int l = 0; l < allErrorInfo.size(); l++) { + errors.add(allErrorInfo.get(l).getMessage()); + } + } + } + logger.info("新浩隆-执行失败，"); + logger.info("新浩隆-执行失败，"+errors); + } + } + } + } + else if(operationKey.equals("unaudit") || operationKey.equals("noapprive")){ + logger.info("新浩隆-调用二开驳回、审核不通过方法"); + Long[] ids = new Long[entities.length]; + for (DynamicObject entity : entities) { + int k = 0; + Object id = entity.getPkValue(); + ids[k] = Long.parseLong(id.toString()); + ++k; + } + Map> sourceBills = BFTrackerServiceHelper.findSourceBills(entityName, ids); + logger.info("新浩隆-调用二开驳回、审核不通过方法：sourceBills"+sourceBills); + if(sourceBills != null) { + HashSet longs = sourceBills.get("er_dailyapplybill"); + if(longs != null){ + Object[] idss = longs.toArray(); + DynamicObject dailyapplybillType = BusinessDataServiceHelper.newDynamicObject("er_dailyapplybill"); + DynamicObject[] srcdatas = BusinessDataServiceHelper.load(idss,dailyapplybillType.getDynamicObjectType()); + logger.info("新浩隆-调用二开驳回、审核不通过方法：srcdatas数量："+srcdatas.length); + OperateOption option= OperateOption.create(); + option.setVariableValue(OperateOptionConst.IGNOREWARN, String.valueOf(true)); // 不执行警告级别校验器 + OperationResult operationResult = OperationServiceHelper.executeOperate("submit1", "er_dailyapplybill", srcdatas, option); + List errors = new ArrayList(); + if(operationResult.isSuccess()){ + logger.info("新浩隆-执行成功，"); + logger.info("新浩隆-执行成功，"+operationResult.getMessage()); + }else{ + ValidateResultCollection validateResult = operationResult.getValidateResult(); + for (int j = 0; j < validateResult.errorSize(); j++) { + List validateErrors = validateResult.getValidateErrors(); + for (int k = 0; k < validateErrors.size(); k++) { + ValidateResult errinfo = validateErrors.get(k); + List allErrorInfo = errinfo.getAllErrorInfo(); + for (int l = 0; l < allErrorInfo.size(); l++) { + errors.add(allErrorInfo.get(l).getMessage()); + } + } + } + logger.info("新浩隆-执行失败，"); + logger.info("新浩隆-执行失败，"+errors); + } + } + } + } + } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/xqconvert.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/xqconvert.java new file mode 100644 index 0000000..7617a76 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/operate/xqconvert.java @@ -0,0 +1,29 @@ +package q79l.pur.cosmic.plugin.operate; + +import kd.sdk.scm.pur.extpoint.IBatchStockSupport; + +import java.util.LinkedHashMap; +import java.util.Map; + +public class xqconvert implements IBatchStockSupport{ + @Override + public Map assembleExtHeadPro() { + //表头塞值 + Map extPro = new LinkedHashMap<>(16); + //终止原因 + extPro.put("shkd_remark", "F_XQZD_Remarks"); + //研发项目 + extPro.put("shkd_yfxm", "F_XQZD_YFXM"); + //需求人 + extPro.put("shkd_xqr", "F_XQZD_XQR"); + return extPro; + } + +// @Override +// public Map assembleExtPro() { +// //分录塞值 +// Map extPro = new LinkedHashMap<>(16); +// extPro.put("kdtest_cardNum", "F_PAEZ_DRIVERPHONE"); +// return extPro; +// } +} diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/util/SendEmailUtil.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/util/SendEmailUtil.java new file mode 100644 index 0000000..9576dee --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/util/SendEmailUtil.java @@ -0,0 +1,74 @@ +package q79l.pur.cosmic.plugin.util; + +import javax.mail.*; +import javax.mail.internet.InternetAddress; +import javax.mail.internet.MimeMessage; +import java.util.Properties; + +public class SendEmailUtil { + + // 发件人电子邮箱 + static String from = "xxx@qq.com"; + + // 发件人邮箱密码（这里以授权码为例，非邮箱登录密码） + static String password = "xxx"; + + // 邮件发送服务器的SMTP地址 + static String host = "smtp.qq.com"; + + // 邮件的接收者电子邮箱 + static String to = "xxx@qq.com"; + + public static void sendEmail(){ + + Session session = CreateSession(); + try { + // 创建默认的 MimeMessage 对象 + MimeMessage message = new MimeMessage(session); + + // 设置 From: 头部头字段 + message.setFrom(new InternetAddress(from)); + + // 设置 To: 头部头字段 + message.addRecipient(Message.RecipientType.TO, new InternetAddress(to)); + + // 设置 Subject: 头部头字段 + message.setSubject("这是邮件的主题"); + + // 现在设置实际消息 + message.setText("这是邮件的正文"); + + + + // 发送消息 + Transport.send(message); + System.out.println("邮件发送成功..."); + + } catch (MessagingException mex) { + mex.printStackTrace(); + } + } + + + public static Session CreateSession(){ + + + // 获取系统属性 + Properties properties = System.getProperties(); + + // 设置邮件服务器 + properties.put("mail.smtp.host", host); + properties.put("mail.smtp.port", "465"); // SSL端口号，如果是TLS则是587 + properties.put("mail.smtp.auth", "true"); + properties.put("mail.smtp.ssl.enable", "true"); // 要求使用SSL + + // 获取默认session对象 + Session session = Session.getInstance(properties, new javax.mail.Authenticator() { + protected PasswordAuthentication getPasswordAuthentication() { + return new PasswordAuthentication(from, password); + } + }); + return session; + } +} + diff --git a/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/workflow/XhlWorkFlowPlugin.java b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/workflow/XhlWorkFlowPlugin.java new file mode 100644 index 0000000..dde7fe5 --- /dev/null +++ b/pur/q79l-pur-cosmic/src/main/java/q79l/pur/cosmic/plugin/workflow/XhlWorkFlowPlugin.java @@ -0,0 +1,89 @@ +package q79l.pur.cosmic.plugin.workflow; + + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.DispatchServiceHelper; +import kd.bos.workflow.api.AgentExecution; +import kd.bos.workflow.engine.extitf.IWorkflowPlugin; +import kd.sdk.plugin.Plugin; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + + +public class XhlWorkFlowPlugin implements Plugin, IWorkflowPlugin { + + private static final Log log = LogFactory.getLog(XhlWorkFlowPlugin.class); + + @Override + public void notify(AgentExecution execution) { + IWorkflowPlugin.super.notify(execution); + log.info("进notify方法"); + String entityNumber = execution.getEntityNumber();//单据标识 + String billId = execution.getBusinessKey();//单据id + String handleState = execution.getCurrentTask().getHandleState();//审核状态：批准approve 拒绝reject + String currentName = execution.getCurrentFlowElement().getName(); + log.info("notify方法handleState参数："+handleState); + log.info("notify方法billId参数："+billId); + log.info("notify方法entityNumber参数："+entityNumber); + if("approve".equals(handleState)) { + DynamicObject bill = BusinessDataServiceHelper.loadSingle(billId, entityNumber); + + DynamicObject eborgid = bill.getDynamicObject("eborgid"); + Object id = eborgid.get("id"); + QFilter qFilter = new QFilter("id", QCP.equals,id); + DynamicObject org = BusinessDataServiceHelper.loadSingle("epm_entitymembertree","number",qFilter.toArray()); + String number = org.getString("number"); + log.info("预算组织id："+id); + log.info("预算组织number："+number); + Map params = new HashMap<>(); + List priodNumbers = new ArrayList(); + priodNumbers.add("FY2024.M01"); + priodNumbers.add("FY2024.M02"); + priodNumbers.add("FY2024.M03"); + priodNumbers.add("FY2024.M04"); + priodNumbers.add("FY2024.M05"); + priodNumbers.add("FY2024.M06"); + priodNumbers.add("FY2024.M07"); + priodNumbers.add("FY2024.M08"); + priodNumbers.add("FY2024.M09"); + priodNumbers.add("FY2024.M10"); + priodNumbers.add("FY2024.M11"); + priodNumbers.add("FY2024.M12"); + priodNumbers.add("FY2025.M01"); + priodNumbers.add("FY2025.M02"); + priodNumbers.add("FY2025.M03"); + priodNumbers.add("FY2025.M04"); + priodNumbers.add("FY2025.M05"); + priodNumbers.add("FY2025.M06"); + priodNumbers.add("FY2025.M07"); + priodNumbers.add("FY2025.M08"); + priodNumbers.add("FY2025.M09"); + priodNumbers.add("FY2025.M10"); + priodNumbers.add("FY2025.M11"); + priodNumbers.add("FY2025.M12"); + priodNumbers.add("FY2026.M01"); + List datatypeNumbers = new ArrayList(); + datatypeNumbers.add("Budget"); + List entityNumbers = new ArrayList(); + entityNumbers.add(number); + params.put("modelNumber","001");//String-体系编码 + params.put("businessModelNumber","AunnalBudget");//String-业务模型编码 + params.put("priodNumbers",priodNumbers);//List-预算期间编码集合（明细成员） + params.put("datatypeNumbers",datatypeNumbers);//List-数据类型编码集合（明细成员） + params.put("srcVersion","VNone");//String-源版本（明细成员） + params.put("targetVersion","KZBB");//String-目标版本（明细成员） + params.put("entityNumbers",entityNumbers);//List-执行组织编码集合（明细成员） + log.info("版本复制接口入参："+params); + Object o = DispatchServiceHelper.invokeBizService("epm", "eb", "VersionCopyApiService", "copyExecuteV1", new Object[]{params}); + log.info("版本复制接口返回值："+o.toString()); + } + } +}