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

提交人：陈绍鑫 

日期：2025/01/07 11：30
内容:日志类型
This commit is contained in:
陈绍鑫 2026-01-07 10:11:18 +08:00
parent 5f52dfee7b
commit cac859d2e2
2 changed files with 175 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/tsgxApiMappingBillPlugin.java
View File

@ -109,17 +109,14 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
} }
DynamicObjectCollection shkd_mapping = shkd_apimapping.getDynamicObjectCollection("shkd_mapping"); DynamicObjectCollection shkd_mapping = shkd_apimapping.getDynamicObjectCollection("shkd_mapping");
for (DynamicObject bei_elecreceiptid : bei_elecreceiptids) { for (DynamicObject bei_elecreceiptid : bei_elecreceiptids) {
DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceiptid.getLong("id"), sourcebillnumber); DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceiptid.getLong("id"), sourcebillnumber);
String saveRequestBody=getJSON(bei_elecreceipt,shkd_mapping);//请求json String saveRequestBody=getJSON(bei_elecreceipt,shkd_mapping);//请求json
logger.info("单据"+bei_elecreceipt.getString("billno")+"推送json："+saveRequestBody); logger.info("单据"+bei_elecreceipt.getString("billno")+"推送json："+saveRequestBody);
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
String res=""; String res="";
switch (shkd_jrrzxx){ if ("1".equals(shkd_jrrzxx)){
case "1":
case "2":
case "3":
case "4":
res = doPost(shkd_url,headMap,saveRequestBody,null); res = doPost(shkd_url,headMap,saveRequestBody,null);
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res); logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果 JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
@ -144,15 +141,69 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
} }
} }
} }
break; } else if ("2".equals(shkd_jrrzxx)) {//只记录失败的
case "5": res = doPost(shkd_url,headMap,saveRequestBody,null);
res=""; logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
String flag = otherIsJsonRS.getString("flag");
if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败
resultMap.put("shkd_issuccess",false);//是否成功 resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false); bei_elecreceipt.set("shkd_sfcgtsgx",false);
break; }else {
default: JSONArray datas = otherIsJsonRS.getJSONArray("data");
System.out.println("无效的选项"); if (datas==null){
break; resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}else {
JSONObject data = datas.getJSONObject(0);
String dataflag = data.getString("FLAG");
if ("0".equals(dataflag)||"null".equals(dataflag)||dataflag==null){
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}
}
}
if ((Boolean) resultMap.get("shkd_issuccess")){
continue;
}
}else if ("3".equals(shkd_jrrzxx)) {//只记录成功的
res = doPost(shkd_url,headMap,saveRequestBody,null);
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
String flag = otherIsJsonRS.getString("flag");
if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
JSONArray datas = otherIsJsonRS.getJSONArray("data");
if (datas==null){
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}else {
JSONObject data = datas.getJSONObject(0);
String dataflag = data.getString("FLAG");
if ("0".equals(dataflag)||"null".equals(dataflag)||dataflag==null){
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}
}
}
if ((Boolean) resultMap.get("shkd_issuccess")){
}else {
continue;
}
}else if ("4".equals(shkd_jrrzxx)) {//不记录
continue;
}else if ("5".equals(shkd_jrrzxx)) {//只记录不推送
resultMap.put("shkd_issuccess",false);//是否成功
}else {
continue;
} }
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回json："+res); logger.info("单据"+bei_elecreceipt.getString("billno")+"返回json："+res);
@ -512,4 +563,6 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
return save; return save;
} }
} }

76
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/SharePushTaskPlugin.java
View File

@ -111,16 +111,14 @@ public class SharePushTaskPlugin extends AbstractTask {
logger.info("单据"+bei_elecreceipt.getString("billno")+"推送json："+saveRequestBody); logger.info("单据"+bei_elecreceipt.getString("billno")+"推送json："+saveRequestBody);
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
String res=""; String res="";
switch (shkd_jrrzxx){ if ("1".equals(shkd_jrrzxx)){
case "1":
case "2":
case "3":
case "4":
res = doPost(shkd_url,headMap,saveRequestBody,null); res = doPost(shkd_url,headMap,saveRequestBody,null);
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果 JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
String flag = otherIsJsonRS.getString("flag"); String flag = otherIsJsonRS.getString("flag");
if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败 if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败
resultMap.put("shkd_issuccess",false);//是否成功 resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else { }else {
JSONArray datas = otherIsJsonRS.getJSONArray("data"); JSONArray datas = otherIsJsonRS.getJSONArray("data");
if (datas==null){ if (datas==null){
@ -138,15 +136,69 @@ public class SharePushTaskPlugin extends AbstractTask {
} }
} }
} }
break; } else if ("2".equals(shkd_jrrzxx)) {//只记录失败的
case "5": res = doPost(shkd_url,headMap,saveRequestBody,null);
res=""; logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
String flag = otherIsJsonRS.getString("flag");
if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败
resultMap.put("shkd_issuccess",false);//是否成功 resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false); bei_elecreceipt.set("shkd_sfcgtsgx",false);
break; }else {
default: JSONArray datas = otherIsJsonRS.getJSONArray("data");
System.out.println("无效的选项"); if (datas==null){
break; resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}else {
JSONObject data = datas.getJSONObject(0);
String dataflag = data.getString("FLAG");
if ("0".equals(dataflag)||"null".equals(dataflag)||dataflag==null){
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}
}
}
if ((Boolean) resultMap.get("shkd_issuccess")){
continue;
}
}else if ("3".equals(shkd_jrrzxx)) {//只记录成功的
res = doPost(shkd_url,headMap,saveRequestBody,null);
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回信息："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
String flag = otherIsJsonRS.getString("flag");
if ("0".equals(flag)||"null".equals(flag)||flag==null||"false".equals(flag)){//失败
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
JSONArray datas = otherIsJsonRS.getJSONArray("data");
if (datas==null){
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}else {
JSONObject data = datas.getJSONObject(0);
String dataflag = data.getString("FLAG");
if ("0".equals(dataflag)||"null".equals(dataflag)||dataflag==null){
resultMap.put("shkd_issuccess",false);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",false);
}else {
resultMap.put("shkd_issuccess",true);//是否成功
bei_elecreceipt.set("shkd_sfcgtsgx",true);
}
}
}
if ((Boolean) resultMap.get("shkd_issuccess")){
}else {
continue;
}
}else if ("4".equals(shkd_jrrzxx)) {//不记录
continue;
}else if ("5".equals(shkd_jrrzxx)) {//只记录不推送
resultMap.put("shkd_issuccess",false);//是否成功
}else {
continue;
} }
logger.info("单据"+bei_elecreceipt.getString("billno")+"返回json："+res); logger.info("单据"+bei_elecreceipt.getString("billno")+"返回json："+res);