From c4b7eb0821312740c17c9eaada5afb012ac5ca34 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 25 一月 2024 10:04:14 +0800
Subject: [PATCH] 开发业务接口
---
server/platform/src/main/java/com/doumee/task/ScheduleTool.java | 9 +++++++++
server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java | 33 +++++++++++++++++++++++++++++++++
server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java | 2 ++
3 files changed, 44 insertions(+), 0 deletions(-)
diff --git a/server/platform/src/main/java/com/doumee/task/ScheduleTool.java b/server/platform/src/main/java/com/doumee/task/ScheduleTool.java
index 075cf61..3edcc84 100644
--- a/server/platform/src/main/java/com/doumee/task/ScheduleTool.java
+++ b/server/platform/src/main/java/com/doumee/task/ScheduleTool.java
@@ -39,6 +39,15 @@
/**
* @throws Exception
*/
+ @Scheduled(fixedDelay= 60*1000*60,initialDelay = 30000)
+ public void deal() throws Exception {
+ log.info("==============瀹氭椂鏌ヨ浼佷笟鐢靛瓙绛剧缃茬姸鎬�=======start======");
+ insuranceApplyService.dealWaitSignedData();
+ log.info("==============瀹氭椂鏌ヨ浼佷笟鐢靛瓙绛剧缃茬姸鎬�======end=======");
+ }
+ /**
+ * @throws Exception
+ */
@Scheduled(fixedDelay= 60*1000,initialDelay = 30000)
public void dealComSigIdStatus() throws Exception {
log.info("==============瀹氭椂涓婁紶寰呬笂浼犵殑浼佷笟鐢靛瓙鍗扮珷鏁版嵁=======start======");
diff --git a/server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java b/server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java
index facba13..5c27915 100644
--- a/server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java
+++ b/server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java
@@ -125,4 +125,6 @@
String getSignLink(Integer id);
void dealSignResult(NotifyDataReq data);
+
+ void dealWaitSignedData();
}
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java
index 57e08ea..a966bdd 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java
@@ -409,6 +409,39 @@
}
@Override
+ public void dealWaitSignedData(){
+ List<InsuranceApply> applyList = insuranceApplyMapper.selectList(new QueryWrapper<InsuranceApply>().lambda()
+ .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE)
+ .isNotNull(InsuranceApply::getSignApplyNo));
+ if(applyList !=null && applyList.size()>0 ){
+ for(InsuranceApply model : applyList){
+ String link = signService.linkFile(model.getSignApplyNo());
+ String fileUrl = uploadSignFile(link);
+ if(StringUtils.isBlank(fileUrl)){
+ //濡傛灉涓嬭浇澶辫触锛屾竻闄ゅ悎鍚岋紝涓嬫绛剧珷閲嶆柊鐢熸垚鏂板悎鍚�
+ return;
+ }
+ uploadSignedFileDo(model,fileUrl);
+ return;
+ }
+ }
+ List<ApplyChange> chagneList = applyChangeMapper.selectList(new QueryWrapper<ApplyChange>().lambda()
+ .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD)
+ .isNotNull(ApplyChange::getSignApplyNo));
+ if(chagneList !=null && chagneList.size()>0 ){
+ for(ApplyChange model : chagneList){
+ String link = signService.linkFile(model.getSignApplyNo());
+ String fileUrl = uploadSignFile(link);
+ if(StringUtils.isBlank(fileUrl)){
+ //濡傛灉涓嬭浇澶辫触锛屾竻闄ゅ悎鍚岋紝涓嬫绛剧珷閲嶆柊鐢熸垚鏂板悎鍚�
+ return;
+ }
+ uploadChangeSignedFileDo(model,fileUrl);
+ return;
+ }
+ }
+ }
+ @Override
public void dealSignResult(NotifyDataReq data){
if(data.getApplyNo() == null ){
throw new BusinessException(ResponseStatus.BAD_REQUEST);
--
Gitblit v1.9.3