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

换新eoss

This commit is contained in:
fang 2025-04-14 10:36:14 +08:00
parent 409101f252
commit 49fcb39b07
2 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/CreateToDoHandler.java
View File

@ -63,16 +63,16 @@ public class CreateToDoHandler {
public boolean public boolean
sendCreateToDoNew(String messageInfo, String title, String appRecordId, String userId, String number) { sendCreateToDoNew(String messageInfo, String title, String appRecordId, String userId, String number) {
logger.info("###进入待办推送接口数据组装"); logger.info("###新eoss进入待办推送接口数据组装");
try { try {
//调用接口结果 //调用接口结果
String result = RequestClient.getInstance().callServiceNew(ToDoCenterConstant.URI_send_addNew, messageInfo); String result = RequestClient.getInstance().callServiceNew(ToDoCenterConstant.URI_send_addNew, messageInfo);
logger.info("###接口返回结果" + result); logger.info("###新eoss接口返回结果" + result);
//接口调用结果 //接口调用结果
JSONObject jsonObject = JSONObject.parseObject(result); JSONObject jsonObject = JSONObject.parseObject(result);
if (jsonObject == null) { if (jsonObject == null) {
RequestClient.getInstance().saveCreateToDoNew(title, ToDoCenterConstant.URI_send_addNew, false, result, messageInfo, appRecordId, userId, number); RequestClient.getInstance().saveCreateToDoNew(title, ToDoCenterConstant.URI_send_addNew, false, result, messageInfo, appRecordId, userId, number);
logger.info("###响应报文为空"); logger.info("###新eoss响应报文为空");
return false; return false;
} else { } else {
if (Objects.equals("success", jsonObject.getString("status"))) { if (Objects.equals("success", jsonObject.getString("status"))) {
@ -84,7 +84,7 @@ public class CreateToDoHandler {
//调用保存操作 //调用保存操作
RequestClient.getInstance().saveCreateToDoNew(title, ToDoCenterConstant.URI_send_addNew, false, result, messageInfo, appRecordId, userId, number); RequestClient.getInstance().saveCreateToDoNew(title, ToDoCenterConstant.URI_send_addNew, false, result, messageInfo, appRecordId, userId, number);
//发送失败 //发送失败
logger.error("###接口调通失败"); logger.error("###新eoss接口调通失败");
return false; return false;
} }
} }

28
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/RequestClient.java
View File

@ -195,18 +195,18 @@ public class RequestClient {
* @param number 单据编码 * @param number 单据编码
*/ */
public void saveCreateToDoNew(String title,String url, boolean isTrue,String result,String jsonMessage,String appRecordId,String userId,String number){ public void saveCreateToDoNew(String title,String url, boolean isTrue,String result,String jsonMessage,String appRecordId,String userId,String number){
logger.info("###开始调用待办保存日志方法"); logger.info("###新eoss开始调用待办保存日志方法");
StringBuffer urlStr = new StringBuffer(); StringBuffer urlStr = new StringBuffer();
urlStr.append(this.protocal).append("://").append(this.newIp); urlStr.append(this.protocal).append("://").append(this.newIp);
if (!StringUtils.isEmpty(this.newPort)) { if (!StringUtils.isEmpty(this.newPort)) {
urlStr.append(":").append(this.newPort); urlStr.append(":").append(this.newPort);
} }
urlStr.append(url);; urlStr.append(url);;
logger.info("###保存时,环境参数,protocal:"+this.protocal+",ip:"+this.newIp+",this.port:"+this.newPort); logger.info("###新eoss保存时,环境参数,protocal:"+this.protocal+",ip:"+this.newIp+",this.port:"+this.newPort);
try{ try{
DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog1"); DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog1");
logger.info("###保存日志表id"+dynamicObject.getPkValue()); logger.info("###新eoss保存日志表id"+dynamicObject.getPkValue());
dynamicObject.set("shkd_url","测试环境:"+urlStr); dynamicObject.set("shkd_url","新eoss:"+urlStr);
CodeRuleInfo codeRule = CodeRuleServiceHelper.getCodeRule(dynamicObject.getDataEntityType().getName(), dynamicObject, null); CodeRuleInfo codeRule = CodeRuleServiceHelper.getCodeRule(dynamicObject.getDataEntityType().getName(), dynamicObject, null);
dynamicObject.set("billno",CodeRuleServiceHelper.getNumber(codeRule,dynamicObject)); dynamicObject.set("billno",CodeRuleServiceHelper.getNumber(codeRule,dynamicObject));
dynamicObject.set("shkd_traceid",appRecordId); dynamicObject.set("shkd_traceid",appRecordId);
@ -221,11 +221,11 @@ public class RequestClient {
dynamicObject.set("shkd_number",number); dynamicObject.set("shkd_number",number);
} }
Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
logger.info("###保存日志表后id"+dynamicObject.getPkValue()); logger.info("###新eoss保存日志表后id"+dynamicObject.getPkValue());
logger.info("save结果"+save.toString()); logger.info("新eosssave结果"+save.toString());
logger.info("###结束调用待办保存日志方法"); logger.info("###新eoss结束调用待办保存日志方法");
}catch (Exception execution){ }catch (Exception execution){
logger.info("###保存日志失败"+execution.getMessage()); logger.info("###新eoss保存日志失败"+execution.getMessage());
} }
} }
@ -285,7 +285,7 @@ public class RequestClient {
* @param status 类型 2：已办 5：撤销 * @param status 类型 2：已办 5：撤销
*/ */
public void saveDeLToDoNew(Long appRecordId,String userId,String url,boolean isTrue,String result,String jsonMessage,String status,String number){ public void saveDeLToDoNew(Long appRecordId,String userId,String url,boolean isTrue,String result,String jsonMessage,String status,String number){
logger.info("###开始调用已办、撤销保存日志方法"); logger.info("###开始新eoss调用已办、撤销保存日志方法");
StringBuffer urlStr = new StringBuffer(); StringBuffer urlStr = new StringBuffer();
urlStr.append(this.protocal).append("://").append(this.newIp); urlStr.append(this.protocal).append("://").append(this.newIp);
if (!StringUtils.isEmpty(this.newPort)) { if (!StringUtils.isEmpty(this.newPort)) {
@ -294,7 +294,7 @@ public class RequestClient {
urlStr.append(url); urlStr.append(url);
try{ try{
DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog1"); DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog1");
dynamicObject.set("shkd_url","测试环境:"+urlStr.toString()); dynamicObject.set("shkd_url","新eoss:"+urlStr.toString());
CodeRuleInfo codeRule = CodeRuleServiceHelper.getCodeRule(dynamicObject.getDataEntityType().getName(), dynamicObject, null); CodeRuleInfo codeRule = CodeRuleServiceHelper.getCodeRule(dynamicObject.getDataEntityType().getName(), dynamicObject, null);
dynamicObject.set("billno",CodeRuleServiceHelper.getNumber(codeRule,dynamicObject)); dynamicObject.set("billno",CodeRuleServiceHelper.getNumber(codeRule,dynamicObject));
dynamicObject.set("shkd_traceid",appRecordId); dynamicObject.set("shkd_traceid",appRecordId);
@ -309,11 +309,11 @@ public class RequestClient {
dynamicObject.set("shkd_number",number); dynamicObject.set("shkd_number",number);
} }
Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); Object[] save = SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
logger.info("###保存日志表id"+dynamicObject.getPkValue()); logger.info("###新eoss保存日志表id"+dynamicObject.getPkValue());
logger.info("save结果"+save.toString()); logger.info("新eosssave结果"+save.toString());
logger.info("###结束调用已办、撤销保存日志方法"); logger.info("###新eoss结束调用已办、撤销保存日志方法");
}catch (Exception execution){ }catch (Exception execution){
logger.info("###保存日志失败"+execution.getMessage()); logger.info("###新eoss保存日志失败"+execution.getMessage());
} }
} }