1.e签宝接口测试

2.付款申请单表单优化

fi/fi/shkd-fi-fi-plugin/src/main/java/shkd/repc/recon/api/SignTechnologCallbackController.java

@@ -0,0 +1,82 @@
+package shkd.repc.recon.api;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import kd.bos.dataentity.entity.DynamicObjectCollection;
+import kd.bos.openapi.common.custom.annotation.ApiController;
+
+import com.drew.lang.annotations.NotNull;
+import kd.bos.dataentity.entity.DynamicObject;
+import kd.bos.openapi.common.custom.annotation.ApiParam;
+import kd.bos.openapi.common.custom.annotation.ApiPostMapping;
+import kd.bos.openapi.common.result.CustomApiResult;
+import kd.bos.orm.query.QCP;
+import kd.bos.orm.query.QFilter;
+import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.operation.SaveServiceHelper;
+import kd.bos.util.StringUtils;
+
+import java.io.Serializable;
+/**
+ * @author ：weiyunlong
+ * @date ：Created 2024/8/30 14:22
+ * @description：合同签署流程回调接口(e签宝接口文档 3.6.2.1)
+ */
+
+
+@ApiController(value = "SignTechnologCallbackController",desc = "合同签署流程回调api接口，自定义插件")
+public class SignTechnologCallbackController implements Serializable {
+
+    @ApiPostMapping(value = "/eqb_signcallback", desc = "合同签署流程回调接口")
+    public CustomApiResult<Object> eqb_signcallback
+    (@NotNull  @ApiParam(value = "入参", example = "") String str) {
+
+        CustomApiResult customApiResult = new CustomApiResult();
+        JSONObject jsonObject = JSONObject.parseObject(str);
+        //回调通知数据体
+        JSONObject callBackProcessVO = (JSONObject)jsonObject.get("callBackProcessVO");
+        if (null != callBackProcessVO) {
+            //获取合同id
+            String businessNo = (String) callBackProcessVO.get("businessNo");
+            if (StringUtils.isNotEmpty(businessNo)) {
+                DynamicObject recon_contractbill = BusinessDataServiceHelper.loadSingle("recon_contractbill",
+                        "id,billno,qeug_theothersignstatus",new QFilter[]{new QFilter("billno", QCP.equals, businessNo)});
+                if (null != recon_contractbill) {
+
+
+
+                    //待签署方列表
+                    JSONArray nextSignerList = callBackProcessVO.getJSONArray("nextSignerList");
+                    if (null != nextSignerList) {
+                        JSONObject jsonobject = (JSONObject)nextSignerList.get(0);
+                        String signStatus = jsonobject.getString("signStatus");
+                        recon_contractbill.set("qeug_theothersignstatus",signStatus);//状态
+                        SaveServiceHelper.save(new DynamicObject[]{recon_contractbill});
+                        return customApiResult ;
+                    }
+
+                    //签署方列表
+                    JSONArray signerList = callBackProcessVO.getJSONArray("signerList");
+                    if (null != signerList) {
+                        JSONObject jsonobject = (JSONObject)nextSignerList.get(0);
+                        String signStatus = jsonobject.getString("signStatus");
+                        recon_contractbill.set("qeug_theothersignstatus",signStatus);
+                        SaveServiceHelper.save(new DynamicObject[]{recon_contractbill});
+                        return customApiResult ;
+                    }
+
+                    //拒签人信息
+                    JSONObject refuseSigner = (JSONObject)callBackProcessVO.get("refuseSigner");
+                    if (null != refuseSigner) {
+                        String signStatus = refuseSigner.getString("signStatus");
+                        recon_contractbill.set("qeug_theothersignstatus",signStatus);
+                        SaveServiceHelper.save(new DynamicObject[]{recon_contractbill});
+                        return customApiResult ;
+                    }
+                }
+            }
+        }
+
+        return  customApiResult;
+    }
+}

fi/fi/shkd-fi-fi-plugin/src/main/java/shkd/repc/recon/formplugin/ReconPayreqFormPlugin.java

@@ -0,0 +1,146 @@
+package shkd.repc.recon.formplugin;
+
+import com.grapecity.documents.excel.D;
+import kd.bos.bill.BillShowParameter;
+import kd.bos.bill.OperationStatus;
+import kd.bos.coderule.api.CodeRuleInfo;
+import kd.bos.dataentity.entity.DynamicObject;
+import kd.bos.dataentity.entity.DynamicObjectCollection;
+import kd.bos.form.CloseCallBack;
+import kd.bos.form.ShowType;
+import kd.bos.form.events.AfterDoOperationEventArgs;
+import kd.bos.form.plugin.AbstractFormPlugin;
+import kd.bos.orm.query.QCP;
+import kd.bos.orm.query.QFilter;
+import kd.bos.servicehelper.AttachmentServiceHelper;
+import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.coderule.CodeRuleServiceHelper;
+import kd.bos.servicehelper.operation.SaveServiceHelper;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 付款申请单表单插件
+ * qeug_recon_payreqbill_ext
+ */
+public class ReconPayreqFormPlugin extends AbstractFormPlugin {
+
+    @Override
+    public void afterDoOperation(AfterDoOperationEventArgs args) {
+        super.afterDoOperation(args);
+
+        String operateKey = args.getOperateKey();
+        switch (operateKey){
+            //发票识别
+            case "qeug_invoicedistinguish":
+
+                DynamicObject dataEntity = this.getView().getModel().getDataEntity();
+                List<Map<String, Object>> attachments = AttachmentServiceHelper.getAttachments("recon_payreqbill",
+                                        dataEntity.getPkValue(), "qeug_attachmentpanelap");
+                if (attachments.size() <= 0) {
+                    this.getView().showTipNotification("请先上传发票附件");
+                    return;
+                }
+                //发票信息分录
+                DynamicObjectCollection invoiceentry = this.getView().getModel().getEntryEntity("invoiceentry");
+                if (invoiceentry.size() > 0) {
+                    this.getView().showTipNotification("请先删除发票信息数据后，再进行发票识别");
+                    return;
+                }
+                // TODO:  调取OA发票识别接口
+                boolean b = true;
+                //成功--新增分录行
+                if (b) {
+                    //发票信息分录
+                    for (int i = 0; i < attachments.size(); i++) {
+                        invoiceentry.addNew();
+                        //todo:模仿标品新增字段,为接口返回数据反写分录做准备
+                        this.getModel().setValue("qeug_invoicecode", "FKHM-0904-0001",i);//发票代码
+                        this.getModel().setValue("qeug_invoiceno", "FKHM-0904-0001",i);//发票号码
+                        this.getModel().setValue("qeug_amount", 10000,i);//价税合计
+                        this.getModel().setValue("qeug_attainformation", "发票识别:"+attachments.get(i).get("name"),i);
+                        this.getModel().setValue("qeug_invoicestatus", 0,i);//发票验真/重状态
+                    }
+                    this.getView().updateView("invoiceentry");
+                    this.getView().showSuccessNotification("发票识别成功");
+                }else {
+                    //失败--提示失败信息
+                    this.getView().showTipNotification("发票识别失败:请上传有效发票");
+                }
+
+                break;
+            //发票验真验重
+            case "qeug_invoicecheck":
+                //todo: 发票验真验重接口
+                // 根据接口情况打包分录数据去OA验真验重---遍历调取接口还是汇总集合调取接口
+                boolean bb = true;
+                //成功--新增分录行
+                if (bb) {
+                    this.getView().showSuccessNotification("发票验真验重接口");
+                    //验真验重接口调通--生成发票登记单据(recon_invoicebill)
+                    DynamicObject recon_invoicebill1 = BusinessDataServiceHelper.newDynamicObject("recon_invoicebill");
+                    DynamicObject recon_invoicebill = BusinessDataServiceHelper.loadSingle("2031274535679975424", "recon_invoicebill");
+                    recon_invoicebill.set("billstatus","A");//单据状态
+                    //所属组织
+                    DynamicObject org = BusinessDataServiceHelper.loadSingle("bos_org", new QFilter[]{new QFilter("number", QCP.equals, "DOBE")});
+                    if (null != org) {
+                        recon_invoicebill.set("org",org);
+                    }
+                    //发票号码  invoiceno
+//                    recon_invoicebill.set("invoiceno",System.currentTimeMillis());//----编码规则待维护
+                    recon_invoicebill.set("invoiceno","FKHM-0904-0001");//----编码规则待维护
+                    //发票编码
+                    recon_invoicebill.set("billno","测试数据勿删!!");//----编码规则待维护
+
+                    //付款申请单 payreqentrys
+                    DynamicObjectCollection payreqentrys = recon_invoicebill.getDynamicObjectCollection("payreqentrys");
+                    payreqentrys.clear();
+                    DynamicObject payreqentry = payreqentrys.addNew();
+                    payreqentry.set("fbasedataid", this.getView().getModel().getDataEntity());
+
+                    //todo:若接口返回汇总
+                    //发票_明细
+                    DynamicObjectCollection invoiceentrs = recon_invoicebill.getDynamicObjectCollection("invoiceentry");
+                    invoiceentrs.clear();
+                    DynamicObject invoiceentr = invoiceentrs.addNew();
+                    invoiceentr.set("entry_notaxamt",100000);
+                    //todo:若接口返回明细--遍历新增发票明细分录
+
+                    Object[] save = SaveServiceHelper.save(new DynamicObject[]{recon_invoicebill});
+                    //如果 成功生成发票登记的单子,反写分录状态为完成
+                    if (save.length > 0) {
+                        //发票信息分录
+                        DynamicObjectCollection invoiceentrys = this.getView().getModel().getEntryEntity("invoiceentry");
+                        if (invoiceentrys.size() > 0) {
+                            for (DynamicObject invoiceent : invoiceentrys) {
+                                //根据发票号码进行过滤
+                                String qeug_invoiceno = invoiceent.getString("qeug_invoiceno");//分录中的发票号码
+                                //todo:付款申请单发票信息分录行的发票号码 == 发票登记单头发票号码
+                                if (qeug_invoiceno.equals(recon_invoicebill.getString("invoiceno"))) {
+                                    System.out.println();
+                                    invoiceent.set("qeug_invoicestatus",1);//发票状态(验真/重)--------已完成
+                                }
+                            }
+                            this.getView().updateView("invoiceentry");
+//                            SaveServiceHelper.save(new DynamicObject[]{this.getView().getModel().getDataEntity()});
+                        }
+                    }
+                    System.out.println("");
+                }else {
+                    //失败--提示失败信息
+                    this.getView().showTipNotification("发票验真验重失败:请检查发票明细信息是否正确");
+                }
+                break;
+            case "deleteinvoiceentry":
+                //用户在删除发票明细时，如果当前发票已经生成发票登记单，一并删除掉
+                //
+                break;
+            default:
+                break;
+        }
+
+    }
+}
+//                    CodeRuleInfo codeRule = CodeRuleServiceHelper.getCodeRule("recon_invoicebill", recon_invoicebill, null);

fi/fi/shkd-fi-fi-plugin/src/main/java/shkd/repc/recon/opplugin/TestOPPlugin.java

@@ -1,19 +1,23 @@
 package shkd.repc.recon.opplugin;
 
 import com.alibaba.fastjson.JSONObject;
+import kd.bos.dataentity.entity.DynamicObject;
+import kd.bos.entity.operate.result.OperateErrorInfo;
 import kd.bos.entity.plugin.AbstractOperationServicePlugIn;
 import kd.bos.entity.plugin.args.AfterOperationArgs;
+import kd.bos.entity.validate.ErrorLevel;
 import kd.bos.logging.Log;
 import kd.bos.logging.LogFactory;
-import kd.bos.mvc.list.AttachmentModel;
 import kd.bos.util.HttpClientUtils;
 import kd.bos.util.StringUtils;
-
+import org.apache.commons.net.util.Base64;
-import java.io.IOException;
+//import java.util.Base64;
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.nio.charset.StandardCharsets;
 import java.util.*;
 
 /**
- * @description：
  */
 public class TestOPPlugin extends AbstractOperationServicePlugIn {
 
@@ -25,43 +29,128 @@ public class TestOPPlugin extends AbstractOperationServicePlugIn {
 
         String operationKey = e.getOperationKey();
         if ("submit".equals(operationKey)) {
+
+            for (DynamicObject dataEntity : e.getDataEntities()) {
+
 //            String url = System.getProperty("efms.infcompany.url.ip");
 //            logger.info("url");
-            /**
+            /*
-             * ---------------------生成上传文件链接----------------------------
+              ---------------------生成上传文件链接----------------------------
              */
+                try {
                 String linkUrl  = "http://172.31.254.241:8869/file/v1/generateUploadUrl";
-            //TODO:请求头 2.2.1
+                //TODO:  一.请求头(2.2.1)  二.requestID
-            Map<String, String> linkHeader = new HashMap<>();
+
-            linkHeader.put("Content-Type", "application/json");
                 //生成上传文件链接接口请求体
                 JSONObject linkBody = new JSONObject();
                 linkBody.put("expire",5);
-            linkBody.put("requestID", "550E8400E29B11D4A716446655440000");
+                linkBody.put("requestID", "4A6F3B4E5C2D1A9F8E7B6C5D4A3B2C1E");
-            linkBody.put("type", 0);
+                linkBody.put("type", 1);
+
                 //获取上传链接类型，0-上传文件并分割，适用于100M以内的pdf文件。1-上传文件，适用于大于100M的pdf文件，以及其他类型的文件：ofd、doc、docx、xls、xlsx、jpg、jpeg、png、zip、rar。
-            try {
+                Map<String, String> linkHeader = new HashMap<>();
+                //body,项目密钥进行加密(HmacSHA256进行数据加密)
+                String secret  = linkBody.toJSONString();
+                String message ="B69RSfJJ5yJ6gizo";
+
+//                //import org.apache.commons.net.util.Base64;
+//                Mac sha256_HMAC = Mac.getInstance("HmacSHA256");
+//                SecretKeySpec secretKey = new SecretKeySpec(secret.getBytes(),"HmacSHA256");
+//                sha256_HMAC.init(secretKey);
+//                byte[] hash = sha256_HMAC.doFinal(message.getBytes());
+//                String encodeStr = Base64.encodeBase64String(hash);//Ew6TnQg1i+e6GomCPBSoXfX+UFqmKy1AnP6gVKJrrQM=\r\n
+
+                //import java.util.Base64;
+//                SecretKeySpec secretKey = new SecretKeySpec(message.getBytes(),"HmacSHA256");
+//                sha256_HMAC.init(secretKey);
+//                byte[] hash = sha256_HMAC.doFinal(secret.getBytes());
+//                String encodeStr = Base64.getEncoder().encodeToString(hash);//a7FxNRJsu5q0quFSF84R0eOhAiXYXoKvrrPw2o/JwbM=
+
+
+//                String encodestr16 = byte2Hex(hash);//130e939d08358be7ba1a89823c14a85df5fe505aa62b2d409cfea054a26bad03  //6bb17135126cbb9ab4aae15217ce11d1e3a10225d85e82afaeb3f0da8fc9c1b3
+
+                String HMACsha256  = calculateHMACSHA256(secret, message);//130e939d08358be7ba1a89823c14a85df5fe505aa62b2d409cfea054a26bad03
+                String HMACsha256s = calculateHMACSHA256(message,secret );//6bb17135126cbb9ab4aae15217ce11d1e3a10225d85e82afaeb3f0da8fc9c1b3
+
+
+                linkHeader.put("Content-Type", "application/json");
+                linkHeader.put("x-timevale-project-id", "1000000");
+                linkHeader.put("x-timevale-signature", "4c45b39ebe42818aa90001849dffda622c9894454bc6d68c03aff67c55730661");
+
+
+
                 String linkPostjson = HttpClientUtils.postjson(linkUrl, linkHeader,linkBody.toJSONString());
                     if (StringUtils.isNotEmpty(linkPostjson)) {
-                    /**
-                     * ---------------------上传文件----------------------------
-                     */
-                    String uploadUrl  = linkPostjson;
-                    //TODO:请求头 2.2.1
-                    Map<String, String> uploadHeader = new HashMap<>();
-                    linkHeader.put("Content-Type", "application/json");
-                    //生成上传文件链接接口请求体
-                    JSONObject uploadBody = new JSONObject();
-                    linkBody.put("file",new AttachmentModel());//附件
 
-                    String uploadPostjson = HttpClientUtils.postjson(uploadUrl, uploadHeader,uploadBody.toJSONString());
+                    JSONObject jsonObject = JSONObject.parseObject(linkPostjson);
-                    if ("success".equals(uploadPostjson)) {
+                    String messages = jsonObject.getString("message");
-                        //上传成功
+
+                    OperateErrorInfo operateErrorInfo = new OperateErrorInfo();
+                    operateErrorInfo.setMessage(messages);
+                    operateErrorInfo.setErrorLevel(ErrorLevel.Error.name());
+                    operateErrorInfo.setPkValue(dataEntity.getPkValue());
+                    this.operationResult.addErrorInfo(operateErrorInfo);
+//                    /*
+//                      ---------------------上传文件----------------------------
+//                     */
+//                    //TODO:请求头 2.2.1
+//                    Map<String, String> uploadHeader = new HashMap<>();
+//                    linkHeader.put("Content-Type", "multipart/form-data");
+//                    //生成上传文件链接接口请求体
+//                    JSONObject uploadBody = new JSONObject();
+//                    linkBody.put("file",new AttachmentModel());//附件
+//
+//                    String uploadPostjson = HttpClientUtils.postjson(linkPostjson, uploadHeader,uploadBody.toJSONString());
+//                    switch (uploadPostjson) {
+//                        case "success":
+//                            //上传成功
+//                            break;
+//                        default:
+//                            break;
+//                    }
                     }
-                }
+                } catch (Exception ex) {
-            } catch (IOException ex) {
+                    OperateErrorInfo operateErrorInfo = new OperateErrorInfo();
-                throw new RuntimeException(ex);
+                    operateErrorInfo.setMessage(ex.getMessage());
+                    operateErrorInfo.setErrorLevel(ErrorLevel.Error.name());
+                    operateErrorInfo.setPkValue(dataEntity.getPkValue());
+                    this.operationResult.addErrorInfo(operateErrorInfo);
                 }
             }
         }
     }
+
+    private static String byte2Hex(byte[] bytes){
+        StringBuffer stringBuffer = new StringBuffer();
+        String temp = null;
+        for(int i=0 ; i < bytes.length; i++) {
+            temp = Integer.toHexString(bytes[i] & 0xFF);
+            //1得到一位的进行补0操作
+            if (temp.length() == 1) {
+                stringBuffer.append("0");
+            }
+            stringBuffer.append(temp);
+        }
+        return stringBuffer.toString();
+    }
+
+    public static String calculateHMACSHA256(String key, String message) {
+        try {
+            Mac mac = Mac.getInstance("HmacSHA256");
+            SecretKeySpec secretKeySpec = new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
+            mac.init(secretKeySpec);
+            byte[] hmac = mac.doFinal(message.getBytes(StandardCharsets.UTF_8));
+            StringBuilder sb = new StringBuilder();
+            for (byte b : hmac) {
+                sb.append(String.format("%02x", b));
+            }
+            return sb.toString();
+        }catch(Exception e){
+            e.printStackTrace();
+        }
+        return null;
+
+    }
+}
+//                String[] split = encodeStr.split("=", 4);
+//                String s = split[0];