feat:新增根据bk删除催收数据接口,催收表新增处理人字段

demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/ptc/infra/entity/CollectionDetailEntity.java

@@ -119,6 +119,10 @@ public class CollectionDetailEntity extends BaseMgrEntity<CollectionDetailEntity
     @SerializedName(value = "overdue_days")
     private String overdueDays;
 
+    /** 处理人 */
+    @SerializedName(value = "processed_by")
+    private String processedBy;
+
     public CollectionDetailEntity(String customerName, String customerNo, String contacts, String contactInformation) {
         this.customerNo = customerNo;
         this.customerName = customerName;

demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/ptc/provider/ReceivablesDetailEAIService.java

@@ -22,6 +22,9 @@ public interface ReceivablesDetailEAIService extends DWService {
     @EAIService(id = ReceivablesUtil.RECEIVABLES_TASK_UPDATE)
     DWEAIResult taskUpdate(Map<String, String> headers, String messageBody) throws Exception;
 
-    @EAIService(id = ReceivablesUtil.RECEIVABLES_TASK_GET)
+    @EAIService(id = ReceivablesUtil.RECEIVABLES_INITIAL_CREATE)
     DWEAIResult initialCreate(Map<String, String> headers, String messageBody) throws Exception;
+
+    @EAIService(id = ReceivablesUtil.RECEIVABLES_TASK_DELETE)
+    DWEAIResult taskDelete(Map<String, String> headers, String messageBody) throws Exception;
 }

demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/ptc/provider/impl/ReceivablesDetailEAIServiceImpl.java

@@ -36,4 +36,9 @@ public class ReceivablesDetailEAIServiceImpl implements ReceivablesDetailEAIServ
     public DWEAIResult initialCreate(Map<String, String> headers, String messageBody) throws Exception {
         return eaiServiceContext.execute(ReceivablesUtil.RECEIVABLES_INITIAL_CREATE,headers,messageBody);
     }
+
+    @Override
+    public DWEAIResult taskDelete(Map<String, String> headers, String messageBody) throws Exception {
+        return eaiServiceContext.execute(ReceivablesUtil.RECEIVABLES_TASK_DELETE,headers,messageBody);
+    }
 }

demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/ptc/service/receivables/ReceivablesTaskGetEAIService.java

@@ -41,7 +41,9 @@ public class ReceivablesTaskGetEAIService extends AbsEAIService {
         List<CollectionDetailEntity> collectionDetailEntities = eaiRequest.getObject("get_data", new TypeReference<List<CollectionDetailEntity>>() {});
 
         for (CollectionDetailEntity collectionDetailEntity : collectionDetailEntities) {
-            if (StringUtils.isEmpty(collectionDetailEntity.getSalesOrder())||StringUtils.isEmpty(collectionDetailEntity.getSalesOrderNumber())){
+            if (StringUtils.isEmpty(collectionDetailEntity.getSalesOrder())
+                    ||StringUtils.isEmpty(collectionDetailEntity.getSalesOrderNumber())
+                    ||StringUtils.isEmpty(collectionDetailEntity.getProcessedBy())){
                 throw new DWBusinessException("缺少必要参数");
             }
         }
@@ -55,6 +57,7 @@ public class ReceivablesTaskGetEAIService extends AbsEAIService {
                         wrapper -> wrapper
                                 .eq(CollectionDetailEntity::getSalesOrder, collectionDetailEntity.getSalesOrder())
                                 .eq(CollectionDetailEntity::getSalesOrderNumber, collectionDetailEntity.getSalesOrderNumber())
+                                .eq(CollectionDetailEntity::getProcessedBy, collectionDetailEntity.getProcessedBy())
                 );
             }
 

demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/ptc/service/receivables/ReceivablesUtil.java

@@ -13,4 +13,6 @@ public class ReceivablesUtil {
     public static final String RECEIVABLES_TASK_CREATE = "demo.ptc.athenapot.receivables.create";
 
     public static final String RECEIVABLES_INITIAL_CREATE = "demo.ptc.athenapot.receivables.initial.create";
+
+    public static final String RECEIVABLES_TASK_DELETE = "demo.ptc.athenapot.receivables.task.delete";
 }

doc/sql/app-20230912-ddl.sql

@@ -116,3 +116,6 @@ CREATE TABLE `cim_limit_credit` (
 
 -- 修改问题明细长度
 ALTER TABLE `cim_chat_file` MODIFY COLUMN `question` varchar (500);
+
+-- 催收表新增处理人
+alter table cim_collection_detail Add column processed_by varchar(32) null default '' COMMENT '处理人';