package com.yeshi.fanli.service.impl.user;
|
|
import java.math.BigDecimal;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
|
import com.yeshi.fanli.controller.client.UserInfoController;
|
import com.yeshi.fanli.dao.mybatis.AccountMessageMapper;
|
import com.yeshi.fanli.entity.bus.user.AccountMessage;
|
import com.yeshi.fanli.entity.bus.user.BindingAccount;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.exception.PushException;
|
import com.yeshi.fanli.service.inter.push.PushService;
|
import com.yeshi.fanli.service.inter.user.UserNotificationService;
|
import com.yeshi.fanli.util.Constant;
|
|
@Service
|
public class UserNotificationServiceImpl implements UserNotificationService {
|
@Resource
|
private AccountMessageMapper accountMessageMapper;
|
|
@Resource
|
private PushService pushService;
|
|
@Override
|
public void newerHongBao(Long uid, BigDecimal money) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getNewerHongbaoTitle(),
|
Constant.znxConfig.getNewerHongbaoMsg().replace("[金额]", money.toString()));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void orderFanliRecieved(Long uid, String orderId, BigDecimal money) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getOrderFanliRecieveTitle(), Constant.znxConfig
|
.getOrderFanliRecieveMsg().replace("[订单号]", orderId).replace("[金额]", money.toString()));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void tiChengRecieved(Long uid, BigDecimal money) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getShareInviteMoneyRecieveTitle(),
|
Constant.znxConfig.getShareInviteMoneyRecieveMsg().replace("[金额]", money.toString()));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void orderFanliStatisticed(Long uid, String orderId) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getFanliOrderStatisticedTitle(),
|
Constant.znxConfig.getFanliOrderStatisticedMsg().replace("[订单号]", orderId));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void tiChengStatisticed(Long uid, String orderId, BigDecimal money) {
|
orderId = orderId.substring(0, orderId.length() - 6) + "******";
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getTichengOrderStatisticedTitle(), Constant.znxConfig
|
.getTichengOrderStatisticedMsg().replace("[订单号]", orderId).replace("[金额]", money.toString()));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void weiQuanFanli(Long uid, String orderId, BigDecimal money) {
|
// 只发送站内信
|
AccountMessage am = new AccountMessage();
|
am.setContent(Constant.znxConfig.getWeiquanDrawbackFanliMsg().replace("[订单号]", orderId).replace("[金额]",
|
money.toString()));
|
am.setCreateTime(System.currentTimeMillis());
|
am.setIsOpen(false);
|
am.setTitle(Constant.znxConfig.getWeiquanDrawbackFanliTitle());
|
am.setUserInfo(new UserInfo(uid));
|
accountMessageMapper.insertSelective(am);
|
}
|
|
@Override
|
public void weiQuanTiCheng(Long uid, String orderId, BigDecimal money) {
|
orderId = orderId.substring(0, orderId.length() - 6) + "******";
|
AccountMessage am = new AccountMessage();
|
am.setContent(Constant.znxConfig.getWeiquanDrawbackShareMsg().replace("[订单号]", orderId).replace("[金额]",
|
money.toString()));
|
am.setCreateTime(System.currentTimeMillis());
|
am.setIsOpen(false);
|
am.setTitle(Constant.znxConfig.getWeiquanDrawbackShareTitle());
|
am.setUserInfo(new UserInfo(uid));
|
accountMessageMapper.insertSelective(am);
|
}
|
|
@Override
|
public void extractApply(Long uid) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getExtractApplayTitle(),
|
Constant.znxConfig.getExtractApplayMsg());
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void extractTransferFail(Long uid, String time) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getExtractTransferFailTitle(),
|
Constant.znxConfig.getExtractTransferFailMsg().replace("[时间]", time));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void extractWrong(Long uid, String time) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getExtractWrongTitle(),
|
Constant.znxConfig.getExtractWrongMsg().replace("[时间]", time));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void extractSuccess(Long uid, String time) {
|
try {
|
pushService.pushZNX(uid, Constant.znxConfig.getExtractSuccessTitle(),
|
Constant.znxConfig.getExtractSuccessMsg().replace("[时间]", time));
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public void alipayAccountValidRight(Long uid, BigDecimal money, String account) {
|
BindingAccount ba = new BindingAccount();
|
ba.setAccount(account);
|
ba.setName("**");
|
ba = UserInfoController.filterBindingAccount(ba);
|
AccountMessage am = new AccountMessage();
|
am.setContent(Constant.znxConfig.getAlipayAccountValidMsg().replace("[账号]", ba.getAccount()).replace("[金额]",
|
money.toString()));
|
am.setCreateTime(System.currentTimeMillis());
|
am.setIsOpen(false);
|
am.setTitle(Constant.znxConfig.getAlipayAccountValidTitle());
|
am.setUserInfo(new UserInfo(uid));
|
accountMessageMapper.insertSelective(am);
|
}
|
|
}
|
