From b2944a93ac3fedc21c57479b7329822b0cb4a23e Mon Sep 17 00:00:00 2001
From: nidapeng <jp@doumee.com>
Date: 星期二, 23 四月 2024 10:50:41 +0800
Subject: [PATCH] 最新版本
---
server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java | 31 +++++++++++++++++++++++++------
server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Empower.java | 3 +++
2 files changed, 28 insertions(+), 6 deletions(-)
diff --git a/server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Empower.java b/server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Empower.java
index 17d3289..476a335 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Empower.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Empower.java
@@ -160,6 +160,9 @@
@ApiModelProperty(value = "娴峰悍璁惧鍦ㄧ嚎鐘舵��")
@TableField(exist = false)
private Integer deviceOnline;
+ @ApiModelProperty(value = "娴峰悍璁惧鏄惁宸插垹闄�")
+ @TableField(exist = false)
+ private Integer deviceDeleted;
@ApiModelProperty(value = "浜哄憳娴峰悍缂栫爜")
@TableField(exist = false)
private String memberHkId;
diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java
index 46323fb..92687f1 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java
@@ -4,8 +4,6 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.doumee.biz.system.SystemDictDataBiz;
-import com.doumee.core.constants.ResponseStatus;
-import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.HKResponseCode;
import com.doumee.core.haikang.model.param.BaseListPageResponse;
@@ -19,14 +17,14 @@
import com.doumee.dao.business.MemberCardMapper;
import com.doumee.dao.business.MemberMapper;
import com.doumee.dao.business.join.EmpowerJoinMapper;
-import com.doumee.dao.business.join.VisitsJoinMapper;
-import com.doumee.dao.business.model.*;
+import com.doumee.dao.business.model.Device;
+import com.doumee.dao.business.model.Empower;
+import com.doumee.dao.business.model.Member;
+import com.doumee.dao.business.model.MemberCard;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
@@ -551,9 +549,16 @@
List<Empower> successList = new ArrayList<>();
List<Empower> errorList = new ArrayList<>();
List<Empower> waitList = new ArrayList<>();
+ List<Empower> cancelList = new ArrayList<>();
List<Empower> faceErrorList = new ArrayList<>();
for(Empower c : list) {
//鍚戜换鍔℃坊鍔犱汉鍛樸�佽澶囦俊鎭暟鎹�
+ if (Constants.equalsInteger(c.getDeviceDeleted(),Constants.ONE) ||
+ (Constants.equalsInteger(c.getMemberDeleted(), Constants.ONE) &&
+ Constants.equalsInteger(c.getMemberHkStatus(), Constants.ONE))){
+ cancelList.add(c);
+ continue;
+ }
if(c.getDeviceOnline() !=null && Constants.equalsInteger(c.getDeviceOnline(),0)){
waitList.add(c);
continue;
@@ -615,6 +620,20 @@
empowerMapper.updateById(update);
}
}
+ if(cancelList.size()>0){
+ for(Empower model : cancelList){
+ Empower update = new Empower();
+ update.setId(model.getId());
+ update.setSendDate(date);
+ update.setEditDate(date);
+ update.setHkId(taskId);
+ update.setFailFlag(Constants.ONE);
+ update.setSendStatus(Constants.EmpowerStatus.cancel);
+ update.setRemark( "璁惧鎴栦汉鍛樺凡鍒犻櫎锛屽彇娑堜笅鍙�");
+ update.setSendInfo( "璁惧鎴栦汉鍛樺凡鍒犻櫎锛屽彇娑堜笅鍙�");
+ empowerMapper.updateById(update);
+ }
+ }
if(faceErrorList.size()>0){
for(Empower model : faceErrorList){
Empower update = new Empower();
--
Gitblit v1.9.3