增加日志

src/main/java/com/quantgroup/asset/distribution/controller/CheckController.java

+package com.quantgroup.asset.distribution.controller;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.quantgroup.asset.distribution.model.response.GlobalResponse;
+
+import lombok.extern.slf4j.Slf4j;
+
+@RestController
+@RequestMapping("/")
+@Slf4j
+public class CheckController {
+	
+	private static Map<String,String> map = new ConcurrentHashMap<>();
+
+    @RequestMapping(value="check")
+	public ResponseEntity<String> check() {
+		if(map!=null && map.size()>0){
+			return ResponseEntity.status(HttpStatus.NOT_FOUND).build();
+		}else{
+			return ResponseEntity.status(HttpStatus.OK).build();
+		}
+	}
+	@RequestMapping(value="online")
+	public GlobalResponse online() {
+		log.info("应用上线，流量开始切入....");
+		map.clear();
+		return GlobalResponse.success();
+	}
+	@RequestMapping(value="offline")
+	public GlobalResponse offline() {
+		log.info("应用下线，流量不再切入....");
+		map.put("status", "offline");
+		return GlobalResponse.success();
+	}
+	
+	@RequestMapping(value="check_test")
+	public GlobalResponse test() {
+        return GlobalResponse.success(map);
+	}
+}

src/main/java/com/quantgroup/asset/distribution/service/asset/impl/AssetServiceImpl.java

@@ -4,6 +4,7 @@ import java.lang.reflect.Field;
 import java.math.BigDecimal;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -13,6 +14,7 @@ import org.springframework.stereotype.Service;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.google.common.base.Stopwatch;
 import com.quantgroup.asset.distribution.config.annotation.Attribute;
 import com.quantgroup.asset.distribution.constant.DistributeLogoConstants;
 import com.quantgroup.asset.distribution.exception.QGException;
@@ -54,6 +56,7 @@ public class AssetServiceImpl implements IAssetService{
 	@Override
 	public void assetsIn(AssetForm assetForm) {
 		try {
+			Stopwatch stopwatch = Stopwatch.createStarted();
 			Asset asset = assetForm.transToAsset();
 			// 获取所有资产扩展属性配置
 			List<AssetAttributeExtendConfig> assetAttributeExtendConfigList = assetAttributeExtendConfigService.getAllExtendConfig();
@@ -65,6 +68,8 @@ public class AssetServiceImpl implements IAssetService{
 			data = addAssetAttributeToData(asset, data);
 			// 资产分发
 			assetDistributeService.distribute(assetForm, asset, data, DistributeLogoConstants.FIRST);
+			log.info("资产分发完成, uuid : {}, bizNo : {}, assetNo : {}, bizChannel : {}, 耗时 : {}", assetForm.getUuid(), 
+					assetForm.getBizNo(), assetForm.getAssetNo(), assetForm.getBizChannel(), stopwatch.stop().elapsed(TimeUnit.MILLISECONDS));
 		} catch (QGException qe) {
 			log.error("资产入库分发出现错误 : {}, uuid : {}, bizChannel : {}, bizType : {}, bizNo : {}, assetNo : {} ",
 					qe.qgExceptionType.code + "->" + qe.detail, assetForm.getUuid(), 

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

@@ -36,11 +36,14 @@ import com.quantgroup.asset.distribution.service.notify.INotifyService;
 import com.quantgroup.asset.distribution.service.redis.IRedisService;
 import com.quantgroup.asset.distribution.service.rule.IRuleService;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * 资产分发Service
  * @author liwenbin
  *
  */
+@Slf4j
 @Service
 public class AssetDistributeServiceImpl implements IAssetDistributeService{
 	
@@ -89,6 +92,9 @@ public class AssetDistributeServiceImpl implements IAssetDistributeService{
 					assetDistributeRecordService.saveDistributeRecord(asset, record, distributeStatus, ruleType);
 					// 分发成功
 					if (distributeStatus) {
+						log.info("用户执行分发节点, uuid : {}, bizNo : {}, assetNo : {}, bizChannel : {}, ruleId : {}, ruleName : {}, distributeStatus : {}", 
+								assetForm.getUuid(), assetForm.getBizNo(), assetForm.getAssetNo(), assetForm.getBizChannel(), ruleConfig.getId(), ruleConfig.getAssetDistributeRuleName(),
+								distributeStatus);
 						success = true;
 						break;
 					}
@@ -99,6 +105,8 @@ public class AssetDistributeServiceImpl implements IAssetDistributeService{
 				throw new QGException(QGExceptionType.NO_DISTRIBUTE_NODE, asset.getUuid(), asset.getAssetNo(), JSON.toJSONString(record));
 			}
 		} else {
+			log.info("资产分发开关关闭，直接通知资金系统, uuid : {}, bizNo : {}, assetNo : {}, bizType : {}, bizChannel : {}", 
+					assetForm.getUuid(), assetForm.getBizNo(), assetForm.getAssetNo(), assetForm.getBizType(), assetForm.getBizChannel());
 			notifyService.notifyFundServer(assetForm);
 		}
 	}