入账提醒

lift-common/src/main/java/cn/com/ty/lift/common/model/PushMessage.java

@@ -96,6 +96,20 @@ public class PushMessage implements Serializable {
         return create("撤销专家处罚", content);
     }
     
+    private static PushMessage bookedRemind(String content) {
+        return create("入账提醒", content);
+    }
+    
+    /**
+     * 入账提醒
+     * 移动端
+     */
+    public static PushMessage bookedRemindToCharge(String amount) {
+        String message = "您有%s元已到账";
+        String content = String.format(message,amount);
+        return bookedRemind(content);
+    }
+    
     /**
      * 专家惩罚
      * 移动端

lift-ud-service/src/main/java/cn/com/ty/lift/ud/chat/service/impl/LiftCaseServiceImpl.java

@@ -591,9 +591,14 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
         byUserId.setAdoptCounts(byUserId.getAdoptCounts() == null ? 1 : (byUserId.getAdoptCounts() + 1));
         userInfoMapper.updateById(byUserId);
 
+        
         PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(selectById.getChargerId().toString());
+        // 用户确认
         PushMessage pushMessage = PushMessage.orderChargeStatus("用户已确认");
         pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+        // 入账提醒
+        PushMessage pushMessage1 = PushMessage.bookedRemindToCharge(total.toString());
+        pushMessage1.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
 
         return RestResponse.success("success");
     }
@@ -698,6 +703,10 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
                     iUserAccountService.getPushUserInfoByUserId(selectById.getChargerId().toString());
             PushMessage pushMessage = PushMessage.orderChargeStatus("用戶已确认打卡");
             pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+            
+            // 入账提醒
+            PushMessage pushMessage1 = PushMessage.bookedRemindToCharge(travelFree.toString());
+            pushMessage1.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
 
             return RestResponse.success("success");
         } else {
@@ -708,6 +717,7 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
     @Override
     public RestResponse refusedExperts(Long id) {
         LiftCaseEntity liftCaseEntity = caseMapper.selectById(id);
+        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(liftCaseEntity.getCreateUserId().toString());
         if (liftCaseEntity.getAcceptStatus() == 2) {
             return RestResponse.fail("订单已拒绝");
         }
@@ -730,6 +740,10 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
             ube.setFlowNum(liftCaseEntity.getOrderSerialNumber());
             ube.setAmount(liftCaseEntity.getPayCost() == null ? BigDecimal.ZERO : liftCaseEntity.getPayCost());
             userBillMapper.insert(ube);
+            
+            // 入账提醒
+            PushMessage pushMessage1 = PushMessage.bookedRemindToCharge((liftCaseEntity.getPayCost() == null ? BigDecimal.ZERO : liftCaseEntity.getPayCost()).toString());
+            pushMessage1.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
         }
         // 清除房间
         chatSessionMapper.delete(new QueryWrapper<ChatSessionEntity>()
@@ -745,9 +759,9 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
         // 修改诊单状态
         caseMapper.refusedExperts(id);
         // 推送消息
-        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(liftCaseEntity.getCreateUserId().toString());
         PushMessage pushMessage = PushMessage.orderChargeStatus("已拒绝");
         pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+        
 
         return RestResponse.success("success");
     }
@@ -1031,6 +1045,13 @@ public class LiftCaseServiceImpl extends ServiceImpl<LiftCaseMapper, LiftCaseEnt
             ube.setFlowNum(liftCaseEntity.getOrderSerialNumber());
             ube.setAmount(liftCaseEntity.getPayCost() == null ? BigDecimal.ZERO : liftCaseEntity.getPayCost());
             userBillMapper.insert(ube);
+            
+            PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(liftCaseEntity.getChargerId().toString());
+            // 入账提醒
+            PushMessage pushMessage = PushMessage.bookedRemindToCharge((liftCaseEntity.getPayCost() == null ? BigDecimal.ZERO : liftCaseEntity.getPayCost()).toString());
+            pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+
+            return RestResponse.success("success");
         }
         // 清除房间
         chatSessionMapper.delete(new QueryWrapper<ChatSessionEntity>()

lift-ud-service/src/main/java/cn/com/ty/lift/ud/pay/service/impl/AlipayServiceImpl.java

@@ -363,6 +363,11 @@ public class AlipayServiceImpl implements AlipayService {
         // 修改余额
         userInfoMapper.rechargePayBalance(questionBankEntity.getExpert(), reward);
 
+        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(questionBankEntity.getExpert().toString());
+        // 入账提醒
+        PushMessage pushMessage = PushMessage.bookedRemindToCharge(reward.toString());
+        pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+        
         // 用户自己也要记录流水
         UserBillEntity billEntity = new UserBillEntity();
         billEntity.setAmount(new BigDecimal(totalAmount));
@@ -465,6 +470,11 @@ public class AlipayServiceImpl implements AlipayService {
         // 修改余额
         userInfoMapper.rechargePayBalance(videoEntity.getUserId(), reward);
 
+        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(videoEntity.getUserId().toString());
+        // 入账提醒
+        PushMessage pushMessage = PushMessage.bookedRemindToCharge(reward.toString());
+        pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+        
         // 用户自己也要记录流水
         UserBillEntity billEntity = new UserBillEntity();
         billEntity.setAmount(new BigDecimal(totalAmount));

lift-ud-service/src/main/java/cn/com/ty/lift/ud/pay/service/impl/WxpayServiceImpl.java

@@ -412,6 +412,10 @@ public class WxpayServiceImpl implements WxpayService {
         userBillService.save(userBillEntity);
         // 修改余额
         userInfoMapper.rechargePayBalance(questionBankEntity.getExpert(), amount);
+        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(questionBankEntity.getExpert().toString());
+        // 入账提醒
+        PushMessage pushMessage = PushMessage.bookedRemindToCharge(amount.toString());
+        pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
 
         // 用户自己也要记录流水
         UserBillEntity billEntity = new UserBillEntity();
@@ -502,6 +506,11 @@ public class WxpayServiceImpl implements WxpayService {
         // 修改余额
         userInfoMapper.rechargePayBalance(videoEntity.getUserId(), amount);
 
+        PushUserInfo pushUserInfo = iUserAccountService.getPushUserInfoByUserId(videoEntity.getUserId().toString());
+        // 入账提醒
+        PushMessage pushMessage = PushMessage.bookedRemindToCharge(amount.toString());
+        pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfo);
+        
         // 用户自己也要记录流水
         UserBillEntity billEntity = new UserBillEntity();
         billEntity.setAmount(reward);