wenlukang1
/
CTSK_DEV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: wenlukang1:b9359ec2e2f16e55de24905d87b79aebccc20e7f
Branches Tags
wenlukang1:main
...
compare: wenlukang1:55a09ee1af214c86dc09215302548c52f056573f
Branches Tags
wenlukang1:main

3 Commits
b9359ec2e2 ... 55a09ee1af

Author SHA1 Message Date
陈绍鑫 55a09ee1af 提交人：陈绍鑫 
日期：2025/01/09 17：30
内容:推送共享优化
 2026-01-19 17:19:19 +08:00
陈绍鑫 4f54c65a08 Merge remote-tracking branch 'origin/main' into main 
# Conflicts:
#	sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/ShareOPPlugin.java
 2026-01-19 17:17:50 +08:00
陈绍鑫 c76e93047d 提交人：陈绍鑫 
日期：2025/01/09 17：30
内容:推送共享优化
 2026-01-19 17:16:43 +08:00
1 changed files with 47 additions and 1 deletions
Show Stats Expand all files Collapse all files

48
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/ShareOPPlugin.java
View File

@ -17,6 +17,7 @@ import kd.bos.orm.query.QFilter;
import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper;
import shkd.sys.sys.mservice.ApiService;
import shkd.sys.sys.utils.EmptyUtil;
import java.util.*;
@ -39,6 +40,9 @@ public class ShareOPPlugin extends AbstractOperationServicePlugIn {
e.getFieldKeys().add("id");
e.getFieldKeys().add("billno");
e.getFieldKeys().add("shkd_lctszt");
e.getFieldKeys().add("shkd_businessname");
e.getFieldKeys().add("shkd_businessid");
e.getFieldKeys().add("shkd_businessnumber");
}
public void onAddValidators(AddValidatorsEventArgs e) {
@ -79,13 +83,55 @@ public class ShareOPPlugin extends AbstractOperationServicePlugIn {
if (resError(flag)) {//失败
String msg = otherIsJsonRS.getString("msg");
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "接口返回接收失败原因：" + msg, ErrorLevel.Error);
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "返回接收失败原因：" + msg, ErrorLevel.Error);
continue;
} else {
String status = otherIsJsonRS.getString("status");
/*
* 0=共享不存在该单据,1=共享存在该单据,2=共享已删除
* */
if (!Arrays.asList("0","2").contains(status)){
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "共享存在对应单据不允许操作", ErrorLevel.Error);
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "共享存在对应单据不允许删除", ErrorLevel.Error);
continue;
}
}
}
String shkd_businessname = dynamicObject.getString("shkd_businessname");//推送系统
String shkd_businessnumber = dynamicObject.getString("shkd_businessnumber");//推送单据编码
String shkd_businessid = dynamicObject.getString("shkd_businessid");//推送单据ID
if ("GX".equals(shkd_businessname)&& !EmptyUtil.isEmpty(shkd_businessnumber)){
JSONObject otherIsJson = new JSONObject();
otherIsJson.put("SrcDocID",shkd_businessid);
otherIsJson.put("SrcDocNo",shkd_businessnumber);
String saveRequestBody = otherIsJson.toJSONString();
DynamicObject shkd_apimapping = BusinessDataServiceHelper.loadSingle(shkd_apimappingid.getLong("id"), "shkd_apimapping");
Map<String, Object> headMap = new HashMap<>();
DynamicObjectCollection shkdHeade = shkd_apimapping.getDynamicObjectCollection("shkd_heade");
for (DynamicObject head : shkdHeade) {
headMap.put(head.getString("shkd_headcsm"), head.getString("shkd_headcsz"));
}
String shkd_url = shkd_apimapping.getString("shkd_url");
String res = doPost(shkd_url, headMap, saveRequestBody, null);
JSONObject otherIsJsonRS = null;//获取返回结果
try {
otherIsJsonRS = JSONObject.parseObject(res);
} catch (Exception e) {
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "返回res转换json出错：" + res, ErrorLevel.Error);
continue;
}
String flag = otherIsJsonRS.getString("flag");
if (resError(flag)) {//失败
String msg = otherIsJsonRS.getString("msg");
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "返回接收失败原因：" + msg, ErrorLevel.Error);
continue;
} else {
String status = otherIsJsonRS.getString("status");
/*
* 0=共享不存在该单据,1=共享存在该单据,2=共享已删除
* */
if (!Arrays.asList("0","2").contains(status)){
this.addMessage(dataEntity,"单据" + dynamicObject.getString("billno") + "共享存在对应单据不允许删除", ErrorLevel.Error);
continue;
}
}
}