src/main/java/fi/cas/task/PayQueryStatusTast.java

@@ -43,7 +43,7 @@ public class PayQueryStatusTast extends AbstractTask {
                     boolean isupdate = false;
                     if ("FIN0000".equals(errcode)) {//已查询到，不代表支付成功
                         String zfstatus = bodyinfo.getString("status");
-                        String errormsg =bodyinfo.getString("errormsg");
+                        String errormsg =bodyinfo.getString("remark3");
                         if("U".equals(zfstatus)){//在途
                             //判断原因是否有变化
                            String sbyy =  dataEntity.getString("nckd_sbyy");
@@ -54,7 +54,7 @@ public class PayQueryStatusTast extends AbstractTask {
                            }
                         }else if("S".equals(zfstatus)){//成功
                             dataEntity.set("nckd_paystatus",3);
-                            dataEntity.set("nckd_sbyy",errormsg);//错误信息更新
+                            dataEntity.set("nckd_sbyy","支付成功");//错误信息更新
                             isupdate = true;
                         }else if("F".equals(zfstatus)){//失败
                             dataEntity.set("nckd_paystatus",4);//支付失败

src/main/java/fi/cas/task/PayUpadteStatusTask.java

@@ -3,12 +3,14 @@ package fi.cas.task;
 import com.alibaba.druid.support.logging.Log;
 import com.alibaba.druid.support.logging.LogFactory;
 import kd.bos.context.RequestContext;
+import kd.bos.dataentity.OperateOption;
 import kd.bos.dataentity.entity.DynamicObject;
 import kd.bos.exception.KDException;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
 import kd.bos.schedule.executor.AbstractTask;
 import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.operation.OperationServiceHelper;
 import kd.bos.servicehelper.operation.SaveServiceHelper;
 
 import java.util.Map;
@@ -21,9 +23,6 @@ public class PayUpadteStatusTask  extends AbstractTask {
         filter.and("nckd_paystatus", QCP.equals, 3);
         filter.and("nckd_fkcs", QCP.large_than, 0);
         DynamicObject[] payinfos = BusinessDataServiceHelper.load("cas_paybill","billno,billstatus,nckd_paystatus,nckd_sbyy,nckd_fqqdrq,nckd_fkcs,nckd_bbh", new QFilter[] {filter});
-        for (DynamicObject dataEntity : payinfos) {
-            dataEntity.set("billstatus","D");
-        }
-        SaveServiceHelper.save(payinfos);
+        OperationServiceHelper.executeOperate("pay","cas_paybill",payinfos, OperateOption.create());
     }
 }