info

code/wnq/nckd-wnq01-wnq-scm/src/main/java/nckd/poc602/plugin/task/PurContractHaveNotJGSDTask.java

@@ -7,15 +7,20 @@ import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
+import org.apache.commons.lang3.StringUtils;
+
 import kd.bos.context.RequestContext;
 import kd.bos.dataentity.OperateOption;
 import kd.bos.dataentity.entity.DynamicObject;
 import kd.bos.dataentity.entity.DynamicObjectCollection;
 import kd.bos.dataentity.metadata.dynamicobject.DynamicObjectType;
+import kd.bos.dataentity.serialization.SerializationUtils;
 import kd.bos.entity.EntityMetadataCache;
 import kd.bos.entity.MainEntityType;
 import kd.bos.entity.operate.result.OperationResult;
 import kd.bos.exception.KDException;
+import kd.bos.logging.Log;
+import kd.bos.logging.LogFactory;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
 import kd.bos.schedule.executor.AbstractTask;
@@ -30,6 +35,7 @@ import kd.bos.servicehelper.operation.OperationServiceHelper;
  * @date : 2025-4-26
  */
 public class PurContractHaveNotJGSDTask extends AbstractTask {
+	protected static Log logger = LogFactory.getLog(PurContractHaveNotJGSDTask.class);
     @Override
     public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
         //1、从销售合同变跟单中查询所有已审核&变更原因=A：价格审定，获取所有
@@ -41,7 +47,7 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
             Object billno = saleData.get("billno");
             xshtbillnos.add(billno);
         }
-        
+        logger.info("PurContractHaveNotJGSDTask-xshtbillnos:" + xshtbillnos);
         if (!xshtbillnos.isEmpty()) {
         	Map<String,String> xsht2cghtbillno = new HashMap<>();
         	Map<String,Set<String>> xsht2cght = new HashMap<>();
@@ -55,7 +61,8 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
             	xsht2cghtbillno.put(xshtbillno, billno);
             	cghtbillnos.add(billno);
             }
-
+            logger.info("PurContractHaveNotJGSDTask-cghtbillnos:" + cghtbillnos);
+            logger.info("PurContractHaveNotJGSDTask-xsht2cghtbillno:" + xsht2cghtbillno);
             if(!cghtbillnos.isEmpty()) {
             	QFilter qcghtbg = new QFilter("billstatus", QCP.equals, "C");
             	qcghtbg.and("billno", QCP.in, cghtbillnos);
@@ -67,7 +74,9 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
                         cghtbillnos.remove(billno);
                     }
                 }
+                logger.info("PurContractHaveNotJGSDTask-cghtbillnos2:" + cghtbillnos);
             }
+            logger.info("PurContractHaveNotJGSDTask-cghtbillnos3:" + cghtbillnos);
             StringBuffer bf = new StringBuffer();
             if(!cghtbillnos.isEmpty()) {
             	
@@ -82,6 +91,7 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
             			cgs.add(cghtbillno);
             		}
             	}
+            	logger.info("PurContractHaveNotJGSDTask-xsht2cght:" + xsht2cght);
             	
             	for(String xsht : xsht2cght.keySet()) {
             		Set<String> cght = xsht2cght.get(xsht);
@@ -91,13 +101,16 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
             		bf.append(cght.toString());
             		bf.append(System.lineSeparator());
             	}
-            }
-        	this.buildBGYJD("xshtbillnos=" + xshtbillnos + ",cghtbillnos=" + cghtbillnos + ",xsht2cghtbillno=" + xsht2cghtbillno +
-        			",xsht2cght=" + xsht2cght + "," + bf.toString());
+            	logger.info("PurContractHaveNotJGSDTask-bf:" + bf);
+            	if(StringUtils.isNotBlank(bf.toString())) {
+            		this.buildBGYJD(bf.toString());
+            	}
+            }	
         }
     }
     
     private void buildBGYJD(String error) {
+    	logger.info("PurContractHaveNotJGSDTask-buildBGYJD");
 		String entityNumSupplier = "nckd_cght_bg_yjd";
 		DynamicObject yjd = BusinessDataServiceHelper.newDynamicObject(entityNumSupplier);
 		//结算组织
@@ -118,5 +131,9 @@ public class PurContractHaveNotJGSDTask extends AbstractTask {
 				sRet = OperationServiceHelper.executeOperate("audit","nckd_cght_bg_yjd",yjdobs,OperateOption.create());
 			}
 		}
+		logger.info("PurContractHaveNotJGSDTask-isSuccess：" + sRet.isSuccess());
+		logger.info("PurContractHaveNotJGSDTask-getMessage：" + sRet.getMessage());
+		
+		logger.info("PurContractHaveNotJGSDTask-getAllErrorInfo：" + SerializationUtils.toJsonString(sRet.getAllErrorInfo()));
     }
 }