测试环境MQ收到订单状态也通知业务流

src/main/java/com/quantgroup/asset/distribution/service/distribute/impl/AssetDistributeRecordServiceImpl.java

@@ -5,6 +5,7 @@ import java.util.List;
 import java.util.Set;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
@@ -34,6 +35,8 @@ public class AssetDistributeRecordServiceImpl implements IAssetDistributeRecordS
 	private IAssetDistributeRecordRepository assetDistributeRecordRepository;
 	@Autowired
 	private IRedisService<Integer> redisService;
+	@Value("${isDebug}")
+	private Boolean isDebug;
 		
 	/**
 	 * 不能改成异步，防止save的时候record被清空
@@ -71,6 +74,7 @@ public class AssetDistributeRecordServiceImpl implements IAssetDistributeRecordS
 	public void updateAssetDistributeStatus(String bizNo, int status) {
 		AssetDistributeRecord assetDistributeRecord = assetDistributeRecordRepository.findByBizNoOrderByCreatedAtDescLimitOne(bizNo);
 		if (assetDistributeRecord == null) {
+			if (isDebug) { return; }
 			log.info("资产分发记录更改状态未找到订单, bizNo : {}, status : {}", bizNo, status);
 			throw new QGException(QGExceptionType.NOT_FOUND_FUND_SERVER_RESULT_BIZNO, bizNo, status);
 		} else {

src/main/java/com/quantgroup/asset/distribution/service/notify/impl/NotifyServiceImpl.java

@@ -53,7 +53,7 @@ public class NotifyServiceImpl implements INotifyService{
 	@Override
 	public void notifyBusinessFlow(String bizNo, FundingResult fundingResult, String nextOperateDate) {
 		try {
-			if (isDebug) { return; }
+//			if (isDebug) { return; } 测试环境也保证通知
 			log.info("通知业务流系统订单终态开始, bizNo : {}, fundingResult : {}, nextOperateDate : {}", bizNo, fundingResult.name(), nextOperateDate);
 			String response = httpService.post(businessFlowURL + "/ex/inner/accept_info", new HashMap<String, String>(){{
 				put("applyNo", bizNo);