fix

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

@@ -10,6 +10,7 @@ import org.springframework.stereotype.Service;
 
 import com.alibaba.fastjson.JSON;
 import com.quantgroup.asset.distribution.model.form.AssetForm;
+import com.quantgroup.asset.distribution.service.alarm.IAlarmService;
 import com.quantgroup.asset.distribution.service.distribute.IDistributeFailLogService;
 import com.quantgroup.asset.distribution.service.httpclient.IHttpService;
 import com.quantgroup.asset.distribution.service.notify.INotifyService;
@@ -27,6 +28,8 @@ public class NotifyServiceImpl implements INotifyService{
 	private IHttpService httpService;
 	@Autowired
 	private IDistributeFailLogService distributeFailLogService;
+	@Autowired
+	private IAlarmService alarmService;
 	
 	@Async
 	@Override
@@ -42,6 +45,9 @@ public class NotifyServiceImpl implements INotifyService{
 			log.info("通知资金系统结果结束, uuid : {}, bizNo : {}, assetNo : {}, callbackUrl : {}, assetForm : {}, response : {}", assetForm.getUuid(), assetForm.getBizNo(), assetForm.getAssetNo(), assetForm.getCallbackUrl(), JSON.toJSONString(assetForm), JSON.toJSONString(response));
 			if(response==null || response.size()==0 || !"200".equals(response.get("statusCode")) || "error".equals(response.get("response"))) {
 				distributeFailLogService.saveDistributeFailLog(assetForm, "通知资金系统失败.");
+				alarmService.dingtalkAlarm("Warn", "资产入库分发通知资金系统失败", "bizChannel : " + assetForm.getBizChannel()
+					+ " , bizType : " + assetForm.getBizType() + " , bizNo : " + assetForm.getBizNo()
+					+ " , assetNo : " + assetForm.getAssetNo() + " , uuid : " + assetForm.getUuid());
 			}
 		} catch (Exception e) {
 			log.info("通知资金系统结果异常, uuid : {}, bizNo : {}, assetNo : {}, callbackUrl : {}, assetForm : {}", assetForm.getUuid(), assetForm.getBizNo(), assetForm.getAssetNo(), assetForm.getCallbackUrl(), JSON.toJSONString(assetForm), e);