fix 添加余额到账短信提醒

netflix-common/src/main/java/com/cyksj/common/constant/Constant.java

@@ -134,4 +134,6 @@ public interface Constant {
 	 * 特殊格式平台邮箱
 	 */
 	String SPECIAL_GOODS_ACCOUNT_IMPORT_KEY = "special_goods_account_import_key";
+
+	String BALANCE_NOTIFY_MSG = "恭喜您 %s元余额已到账 购买时可抵现 快去使用吧！【银河录像局】";
 }

netflix-dao/src/main/java/com/cyksj/model/entity/UserBalanceSourceRecord.java

@@ -23,6 +23,7 @@ public class UserBalanceSourceRecord extends BaseEntity{
 	@Getter
 	public enum Source {
 		payment("下单"),
+		balance("余额支付"),
 		refund("订单退款"),
 		close("订单关闭"),
 		clear_valid("车票未到期清除"),

netflix-service/src/main/java/com/cyksj/service/mange/impl/CmsOrderDonServiceImpl.java

@@ -587,7 +587,7 @@ public class CmsOrderDonServiceImpl extends ServiceImpl<OrderDonMapper,OrderDon>
             }
             //若存在余额支付，退还余额
             if (orderDon.getBalance().compareTo(BigDecimal.ZERO) > 0) {
-                userBenefitsService.addUserBalance(orderDon.getUserId(), orderDon.getBalance(), UserBalanceSourceRecord.Source.refund);
+                userBenefitsService.addUserBalance(orderDon.getUserId(), orderDon.getBalance(), UserBalanceSourceRecord.Source.balance);
             }
             try {
                 marketFrontService.subSpecificChanceNum(orderDon.getUserId(), orderDon.getId(), orderDon.getGoodsId(), orderDon.getUpdateTime());

netflix-service/src/main/java/com/cyksj/service/user/impl/UserBenefitsServiceImpl.java

@@ -1,11 +1,14 @@
 package com.cyksj.service.user.impl;
 
+import com.cyksj.common.EnvCommonService;
+import com.cyksj.common.constant.Constant;
 import com.cyksj.mapper.DistributeOrdersDeductPointsRecordMapper;
 import com.cyksj.mapper.UserBalanceSourceRecordMapper;
 import com.cyksj.mapper.UserMapper;
 import com.cyksj.model.entity.DistributeOrdersDeductPointsRecord;
 import com.cyksj.model.entity.User;
 import com.cyksj.model.entity.UserBalanceSourceRecord;
+import com.cyksj.service.sms.SmsService;
 import com.cyksj.service.user.UserBenefitsService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.dao.DuplicateKeyException;
@@ -28,6 +31,10 @@ public class UserBenefitsServiceImpl implements UserBenefitsService {
 
 	private final UserBalanceSourceRecordMapper userBalanceSourceRecordMapper;
 
+	private final EnvCommonService envCommonService;
+
+	private final SmsService smsService;
+
 	@Override
 	public void deductDistributePoints(Long orderId, Long userId, BigDecimal deductPoints) {
 		if (deductPoints.compareTo(BigDecimal.ZERO) <= 0) {
@@ -72,6 +79,16 @@ public class UserBenefitsServiceImpl implements UserBenefitsService {
 			Integer success = userMapper.addUserBalance(user.getId(), balance, addBalance);
 			if (success == 1) {
 				recordBalanceBySource(userId, addBalance, source);
+				if (envCommonService.isPrdEnv()) {
+					if (source != UserBalanceSourceRecord.Source.close && source != UserBalanceSourceRecord.Source.balance) {
+						try {
+							//短信到账提醒
+							String msg = String.format(Constant.BALANCE_NOTIFY_MSG, addBalance.divide(BigDecimal.valueOf(100)));
+							smsService.sendSmsToRelationUser(userId, msg);
+						} catch (Exception e) {
+						}
+					}
+				}
 				break;
 			}
 		}