|
@@ -22,7 +22,7 @@ import java.util.*;
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 付款状态回写srm调度任务类
|
|
|
|
|
|
+ * 付款状态回写srm调度任务类,同步付款状态至SRM的预付、付款申请
|
|
* @author wanghaiwu_kd
|
|
* @author wanghaiwu_kd
|
|
* @date 2025/05/15
|
|
* @date 2025/05/15
|
|
*/
|
|
*/
|
|
@@ -34,9 +34,6 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
writeBackPublicBill(requestContext, map);
|
|
writeBackPublicBill(requestContext, map);
|
|
//预付单回写
|
|
//预付单回写
|
|
writeBackPrepayBill(requestContext, map);
|
|
writeBackPrepayBill(requestContext, map);
|
|
-
|
|
|
|
-
|
|
|
|
-
|
|
|
|
}
|
|
}
|
|
|
|
|
|
private void writeBackPublicBill(RequestContext requestContext, Map<String, Object> map){
|
|
private void writeBackPublicBill(RequestContext requestContext, Map<String, Object> map){
|
|
@@ -56,6 +53,9 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
DynamicObjectType type = EntityMetadataCache.getDataEntityType(entityName);
|
|
DynamicObjectType type = EntityMetadataCache.getDataEntityType(entityName);
|
|
//先找到批量的pkid
|
|
//先找到批量的pkid
|
|
List<Object> list = QueryServiceHelper.queryPrimaryKeys(entityName, filter.toArray(), null, Integer.MAX_VALUE);
|
|
List<Object> list = QueryServiceHelper.queryPrimaryKeys(entityName, filter.toArray(), null, Integer.MAX_VALUE);
|
|
|
|
+
|
|
|
|
+ logger.info("查询到" + list.size() + "条符合条件的对公报销单:" + list.toString());
|
|
|
|
+
|
|
//根据pkid找到完整的对象
|
|
//根据pkid找到完整的对象
|
|
DynamicObject[] billEntities = BusinessDataServiceHelper.load(list.toArray(), type);
|
|
DynamicObject[] billEntities = BusinessDataServiceHelper.load(list.toArray(), type);
|
|
|
|
|
|
@@ -66,6 +66,8 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
String srmBillNo = payBillEntity.getString("nckd_srmbillno");
|
|
String srmBillNo = payBillEntity.getString("nckd_srmbillno");
|
|
String paymentDate = "";
|
|
String paymentDate = "";
|
|
|
|
|
|
|
|
+ logger.info("处理对公报销单:" + billno + ",srm单据号:" + srmBillNo);
|
|
|
|
+
|
|
if(payBillEntity.getDate("head_paydate") != null){
|
|
if(payBillEntity.getDate("head_paydate") != null){
|
|
paymentDate = CommonHelperUtils.getDateFormatString(payBillEntity.getDate("head_paydate"), pattern);
|
|
paymentDate = CommonHelperUtils.getDateFormatString(payBillEntity.getDate("head_paydate"), pattern);
|
|
}
|
|
}
|
|
@@ -82,6 +84,8 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
StringBuffer errMessage = new StringBuffer();
|
|
StringBuffer errMessage = new StringBuffer();
|
|
Map<String, String> returnMap = SRMHelperUtils.writeBackPayResulst(srmBillNo, paymentDate, paymentAmount);
|
|
Map<String, String> returnMap = SRMHelperUtils.writeBackPayResulst(srmBillNo, paymentDate, paymentAmount);
|
|
|
|
|
|
|
|
+ logger.info("付款单支付状态回写结果:" + returnMap.toString());
|
|
|
|
+
|
|
if(returnMap != null){
|
|
if(returnMap != null){
|
|
if("1".equals(returnMap.get("code"))){
|
|
if("1".equals(returnMap.get("code"))){
|
|
if(errMessage.length() > 0){
|
|
if(errMessage.length() > 0){
|
|
@@ -122,6 +126,9 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
DynamicObjectType type = EntityMetadataCache.getDataEntityType(entityName);
|
|
DynamicObjectType type = EntityMetadataCache.getDataEntityType(entityName);
|
|
//先找到批量的pkid
|
|
//先找到批量的pkid
|
|
List<Object> list = QueryServiceHelper.queryPrimaryKeys(entityName, filter.toArray(), null, Integer.MAX_VALUE);
|
|
List<Object> list = QueryServiceHelper.queryPrimaryKeys(entityName, filter.toArray(), null, Integer.MAX_VALUE);
|
|
|
|
+
|
|
|
|
+ logger.info("查询到" + list.size() + "条符合条件的预付单:" + list.toString());
|
|
|
|
+
|
|
//根据pkid找到完整的对象
|
|
//根据pkid找到完整的对象
|
|
DynamicObject[] billEntities = BusinessDataServiceHelper.load(list.toArray(), type);
|
|
DynamicObject[] billEntities = BusinessDataServiceHelper.load(list.toArray(), type);
|
|
|
|
|
|
@@ -132,6 +139,8 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
String srmBillNo = payBillEntity.getString("nckd_srmbillno");
|
|
String srmBillNo = payBillEntity.getString("nckd_srmbillno");
|
|
String paymentDate = "";
|
|
String paymentDate = "";
|
|
|
|
|
|
|
|
+ logger.info("处理预付单:" + billno + ",srm单据号:" + srmBillNo);
|
|
|
|
+
|
|
if(payBillEntity.getDate("head_paydate") != null){
|
|
if(payBillEntity.getDate("head_paydate") != null){
|
|
paymentDate = CommonHelperUtils.getDateFormatString(payBillEntity.getDate("head_paydate"), pattern);
|
|
paymentDate = CommonHelperUtils.getDateFormatString(payBillEntity.getDate("head_paydate"), pattern);
|
|
}
|
|
}
|
|
@@ -148,12 +157,15 @@ public class WriteBackPayResult2SRMTask extends AbstractTask implements StopTask
|
|
StringBuffer errMessage = new StringBuffer();
|
|
StringBuffer errMessage = new StringBuffer();
|
|
Map<String, String> returnMap = SRMHelperUtils.writeBackPayResulst(srmBillNo, paymentDate, paymentAmount);
|
|
Map<String, String> returnMap = SRMHelperUtils.writeBackPayResulst(srmBillNo, paymentDate, paymentAmount);
|
|
|
|
|
|
|
|
+ logger.info("预付单支付状态回写结果:" + returnMap.toString());
|
|
|
|
+
|
|
if(returnMap != null){
|
|
if(returnMap != null){
|
|
if("1".equals(returnMap.get("code"))){
|
|
if("1".equals(returnMap.get("code"))){
|
|
if(errMessage.length() > 0){
|
|
if(errMessage.length() > 0){
|
|
errMessage.append(",");
|
|
errMessage.append(",");
|
|
}
|
|
}
|
|
logger.info("预付单(" + billno + ", " + srmBillNo + ")回写失败," + returnMap.get("msg"));
|
|
logger.info("预付单(" + billno + ", " + srmBillNo + ")回写失败," + returnMap.get("msg"));
|
|
|
|
+
|
|
payBillEntity.set("nckd_srmstatus", "4");
|
|
payBillEntity.set("nckd_srmstatus", "4");
|
|
} else {
|
|
} else {
|
|
payBillEntity.set("nckd_srmstatus", "3");
|
|
payBillEntity.set("nckd_srmstatus", "3");
|