Переглянути джерело

卡、签下黑反白更新老库处理

master
huminghao 2 місяці тому
джерело
коміт
de4142922a

+ 0
- 36
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ods/ois/issue/OisCardBlackPersistRequest.java Переглянути файл

@@ -1,36 +0,0 @@
package cn.com.taiji.core.model.comm.protocol.ods.ois.issue;

import cn.com.taiji.core.entity.invw.InvwCardDetails;
import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;

import java.util.Calendar;

@Getter
@Setter
@Accessors(chain = true)
public class OisCardBlackPersistRequest extends AbstractSignTypeRequest<OisCardBlackPersistResponse> {

//发行方编号
private String issuerId;
//用户卡黑名单生成时间
private String creationTime;
//类型
private int type;
//用户卡编号
private String cardId;
//状态 1下黑,2反白
private int status;
//录入时间
private Calendar createTime;
//下黑原因
private String reason;
//下黑工号
private String staffId;

public OisCardBlackPersistRequest() {
super(OisIssueCmd.CARDBLACKPERSIST);
}
}

+ 0
- 12
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ods/ois/issue/OisCardBlackPersistResponse.java Переглянути файл

@@ -1,12 +0,0 @@
package cn.com.taiji.core.model.comm.protocol.ods.ois.issue;

import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;

@Getter
@Setter
@Accessors(chain = true)
public class OisCardBlackPersistResponse extends AbstractSignTypeResponse {
}

+ 0
- 2
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ods/ois/issue/OisIssueCmd.java Переглянути файл

@@ -14,8 +14,6 @@ public enum OisIssueCmd implements SignServiceCommand {
OBUDETAILSSAVE("签库存保存", OisObuDetailsSaveRequest.class),
ORDERSAVE("订单保存", OisOrderSaveRequest.class),
BASICDATAUPDATE("基础数据变更", OisBasicDataUpdateRequest.class),
CARDBLACKPERSIST("卡下黑持久化操作",OisCardBlackPersistRequest.class),
OBUBLACKPERSIST("签下黑持久化操作",OisObuBlackPersistRequest.class),
;

private final String value;

+ 0
- 37
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ods/ois/issue/OisObuBlackPersistRequest.java Переглянути файл

@@ -1,37 +0,0 @@
package cn.com.taiji.core.model.comm.protocol.ods.ois.issue;

import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;

import java.time.LocalDateTime;

@Getter
@Setter
@Accessors(chain = true)
public class OisObuBlackPersistRequest extends AbstractSignTypeRequest<OisObuBlackPersistResponse> {

//发行方编号
private String issuerId;
//OBU黑名单生成时间
private String creationTime;
//用户卡白名单生成时间
private String releaseTime;
//OBU序号编码
private String obuId;
//类型
private Integer type;
//状态
private Integer status;// 1拉黑 2反白
//录入时间
private LocalDateTime createTime;
//下黑工号
private String staffId;
//下黑原因
private String reason;

public OisObuBlackPersistRequest() {
super(OisIssueCmd.OBUBLACKPERSIST);
}
}

+ 0
- 12
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ods/ois/issue/OisObuBlackPersistResponse.java Переглянути файл

@@ -1,12 +0,0 @@
package cn.com.taiji.core.model.comm.protocol.ods.ois.issue;

import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;

@Getter
@Setter
@Accessors(chain = true)
public class OisObuBlackPersistResponse extends AbstractSignTypeResponse {
}

+ 0
- 8
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/handler/OisIssueServiceHandler.java Переглянути файл

@@ -38,10 +38,6 @@ public class OisIssueServiceHandler extends AbstractOdsServiceHandler<OisIssueCm
private OrderSaveManager orderSaveManager;
@Autowired
private BasicDataUpdateManager basicDataUpdateManager;
@Autowired
private CardBlackPersistManager cardBlackPersistManager;
@Autowired
private ObuBlackPersistManager obuBlackPersistManager;

public OisIssueServiceHandler() {
super(OdsServiceType.OISISSUE);
@@ -68,10 +64,6 @@ public class OisIssueServiceHandler extends AbstractOdsServiceHandler<OisIssueCm
return orderSaveManager.serviceHandle((OisOrderSaveRequest) request);
case BASICDATAUPDATE:
return basicDataUpdateManager.serviceHandle((OisBasicDataUpdateRequest) request);
case CARDBLACKPERSIST:
return cardBlackPersistManager.serviceHandle((OisCardBlackPersistRequest) request);
case OBUBLACKPERSIST:
return obuBlackPersistManager.serviceHandle((OisObuBlackPersistRequest) request);
default:
throw FileProtocolSystemError.NOT_SUPPORT.toHandleException(jsonReq.getIfCode());
}

+ 0
- 17
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/ois/issue/CardBlackPersistManager.java Переглянути файл

@@ -1,17 +0,0 @@
package cn.com.taiji.ods.manager.ois.issue;

import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistResponse;

/**
* @Auther: humh
* @Description:
* @Date: 2025/7/10 20:41
* @email: huminghao@mail.taiji.com.cn
* @version: 1.0
*/
public interface CardBlackPersistManager {
OisCardBlackPersistResponse serviceHandle(OisCardBlackPersistRequest request) throws ServiceHandleException;
}

+ 0
- 61
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/ois/issue/CardBlackPersistManagerImpl.java Переглянути файл

@@ -1,61 +0,0 @@
package cn.com.taiji.ods.manager.ois.issue;

import cn.com.taiji.common.manager.AbstractManager;
import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.entity.basic.QtkBlackCard;
import cn.com.taiji.core.entity.dict.basic.CardBlackType;
import cn.com.taiji.core.entity.log.OdsInterfaceLog;
import cn.com.taiji.core.manager.comm.LogManager;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisBasicDataUpdateRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisBasicDataUpdateResponse;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistResponse;
import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;
import cn.com.taiji.core.repo.jpa.log.OdsInterfaceLogRepo;
import cn.com.taiji.ods.entity.dsi.*;
import cn.com.taiji.ods.repo.jpa.dsi.*;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
public class CardBlackPersistManagerImpl extends AbstractManager implements CardBlackPersistManager, LogManager<OisCardBlackPersistRequest, OisCardBlackPersistResponse, OdsInterfaceLog> {

@Autowired
private DsiBlackCardRepo dsiBlackCardRepo;
@Autowired
private OdsInterfaceLogRepo logRepo;

@Override
@Transactional(rollbackFor = Exception.class)
public OisCardBlackPersistResponse serviceHandle(OisCardBlackPersistRequest req) throws ServiceHandleException {
try {
long begin = System.currentTimeMillis();
if (req.getStatus() == 1){
DsiBlackCard dsiBlackCard = copyProperties(req, new DsiBlackCard());
dsiBlackCardRepo.save(dsiBlackCard);
}else if (req.getStatus() == 2){
List<DsiBlackCard> dsiBlackCardList = dsiBlackCardRepo.listCardBlack(req.getCardId(), req.getType());

}else {
throw GlyServiceError.FORMAT_ERROR.toHandleException("下黑、反白类型异常!");
}


return onSuccess(req, new OisCardBlackPersistResponse(), OdsInterfaceLog.class, System.currentTimeMillis() - begin);
} catch (Exception e) {
logger.error("异常",e);
throw exception(req, OdsInterfaceLog.class, e.getMessage());
}

}

@Override
public void doSaveLog(OisCardBlackPersistRequest request, OisCardBlackPersistResponse response, OdsInterfaceLog log) {
logger.info("enter do save log");
logRepo.persist(log);
}
}

+ 0
- 17
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/ois/issue/ObuBlackPersistManager.java Переглянути файл

@@ -1,17 +0,0 @@
package cn.com.taiji.ods.manager.ois.issue;

import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisObuBlackPersistRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisObuBlackPersistResponse;

/**
* @Auther: humh
* @Description:
* @Date: 2025/7/10 20:41
* @email: huminghao@mail.taiji.com.cn
* @version: 1.0
*/
public interface ObuBlackPersistManager {
OisObuBlackPersistResponse serviceHandle(OisObuBlackPersistRequest request) throws ServiceHandleException;
}

+ 0
- 46
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/ois/issue/ObuBlackPersistManagerImpl.java Переглянути файл

@@ -1,46 +0,0 @@
package cn.com.taiji.ods.manager.ois.issue;

import cn.com.taiji.common.manager.AbstractManager;
import cn.com.taiji.common.manager.net.http.ServiceHandleException;
import cn.com.taiji.core.entity.log.OdsInterfaceLog;
import cn.com.taiji.core.manager.comm.LogManager;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisCardBlackPersistResponse;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisObuBlackPersistRequest;
import cn.com.taiji.core.model.comm.protocol.ods.ois.issue.OisObuBlackPersistResponse;
import cn.com.taiji.core.repo.jpa.log.OdsInterfaceLogRepo;
import cn.com.taiji.ods.repo.jpa.dsi.DsiBlackCardHisRepo;
import cn.com.taiji.ods.repo.jpa.dsi.DsiBlackCardRepo;
import cn.com.taiji.ods.repo.jpa.dsi.DsiBlackObuRepo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class ObuBlackPersistManagerImpl extends AbstractManager implements ObuBlackPersistManager, LogManager<OisObuBlackPersistRequest, OisObuBlackPersistResponse, OdsInterfaceLog> {

@Autowired
private DsiBlackObuRepo dsiBlackObuRepo;
@Autowired
private OdsInterfaceLogRepo logRepo;

@Override
@Transactional(rollbackFor = Exception.class)
public OisObuBlackPersistResponse serviceHandle(OisObuBlackPersistRequest req) throws ServiceHandleException {
try {
long begin = System.currentTimeMillis();

return onSuccess(req, new OisObuBlackPersistResponse(), OdsInterfaceLog.class, System.currentTimeMillis() - begin);
} catch (Exception e) {
logger.error("异常",e);
throw exception(req, OdsInterfaceLog.class, e.getMessage());
}

}

@Override
public void doSaveLog(OisObuBlackPersistRequest request, OisObuBlackPersistResponse response, OdsInterfaceLog log) {
logger.info("enter do save log");
logRepo.persist(log);
}
}

Завантаження…
Відмінити
Зберегти