公众号消息通知提现成功

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/dao/MessageDao.java

@@ -22,6 +22,13 @@ public interface MessageDao {
     int insertSystemMessage(SystemMessageDO messageDO);
 
     /**
+     * 修改系统消息
+     * @param messageDO
+     * @return
+     */
+    int updateSystemMessage(SystemMessageDO messageDO);
+
+    /**
      * 根据ID查询系统消息
      * @param id
      * @return

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/xzsz/impl/WithdrawalServiceImpl.java

@@ -5,14 +5,14 @@ import com.mmc.iuav.general.CodeUtil;
 import com.mmc.iuav.page.PageResult;
 import com.mmc.iuav.response.ResultBody;
 import com.mmc.iuav.response.ResultEnum;
+import com.mmc.iuav.user.controller.WxController;
 import com.mmc.iuav.user.dao.RealNameAuthDao;
 import com.mmc.iuav.user.dao.UserServiceDao;
+import com.mmc.iuav.user.dao.UserSubInfoDao;
 import com.mmc.iuav.user.dao.wallet.PayWalletDao;
 import com.mmc.iuav.user.dao.xzsz.WithdrawalDao;
 import com.mmc.iuav.user.dao.xzsz.XzDao;
-import com.mmc.iuav.user.entity.RealNameAuthDO;
-import com.mmc.iuav.user.entity.XzAuthDO;
-import com.mmc.iuav.user.entity.XzWithdrawalApplyDO;
+import com.mmc.iuav.user.entity.*;
 import com.mmc.iuav.user.entity.wallet.PayWalletDO;
 import com.mmc.iuav.user.entity.wallet.WithdrawalLogDO;
 import com.mmc.iuav.user.enums.WithdrawalApplyStatus;
@@ -24,8 +24,10 @@ import com.mmc.iuav.user.model.dto.wallet.WithdrawalApplyDTO;
 import com.mmc.iuav.user.model.dto.xzsz.CashPoolingDTO;
 import com.mmc.iuav.user.model.qo.wallet.WalletFlowQO;
 import com.mmc.iuav.user.model.qo.wallet.WithdrawalApplyQO;
+import com.mmc.iuav.user.model.vo.WxMsgVO;
 import com.mmc.iuav.user.model.vo.XzWithdrawalVO;
 import com.mmc.iuav.user.model.vo.wallet.ApplyWithdrawalVO;
+import com.mmc.iuav.user.service.WxService;
 import com.mmc.iuav.user.service.xzsz.WithdrawalService;
 import com.mmc.iuav.user.service.xzsz.XzService;
 import com.mmc.iuav.user.util.SmsUtil;
@@ -40,6 +42,7 @@ import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -69,6 +72,12 @@ public class WithdrawalServiceImpl implements WithdrawalService {
     @Autowired
     private UserServiceDao userServiceDao;
 
+    @Autowired
+    private WxService wxService;
+
+    @Autowired
+    private UserSubInfoDao userSubInfoDao;
+
     @Override
     @Transactional
     public ResultBody apply(ApplyWithdrawalVO applyWithdrawalVO, Integer userAccountId) {
@@ -241,9 +250,21 @@ public class WithdrawalServiceImpl implements WithdrawalService {
         }
         String userPhone = userServiceDao.getUserPhoneByUserId(applyInfo.getUserAccountId());
         SmsUtil.sendPassWithdrawalApply(userPhone);
+
+        // 公众号消息通知提现成功
+        WxMsgVO ws = new WxMsgVO();
+        String unionId = userServiceDao.getUserAccountById(applyInfo.getUserAccountId()).getUnionId();
+        // 查询对应的openId(touser)
+        String touser = userSubInfoDao.getUserSubInfoByUnionId(unionId).getOpenId();
+        JSONObject jsonObject = spellMsg(applyInfo.getEmpName(), applyInfo.getPayAmount(), applyInfo.getPayAccount());
+        ws.setTouser(touser);
+        ws.setTemplateId("y6PHvZownxqR5hf4dSXaa2Lp1jeq3ccytd6G-kUQla4");
+        ws.setDataObject(jsonObject);
+        wxService.sendSubTemplateMsg(ws);
         return ResultBody.success();
     }
 
+
     @Transactional(rollbackFor = Exception.class)
     public int rollbackPayWallet(XzWithdrawalApplyDO applyInfo, PayWalletDO wallet) {
         // 生成提现流水编号
@@ -281,4 +302,30 @@ public class WithdrawalServiceImpl implements WithdrawalService {
         cashAmountDTO.setCashPoolAmount(cashPoolingDTO.getAvailableBalance());
         return cashAmountDTO;
     }
+
+    public JSONObject spellMsg(String empName, Double payAmount, String payAccount){
+        JSONObject data=new JSONObject();
+
+        //提现商户：{{keyword1.DATA}}
+        JSONObject keyword1=new JSONObject();
+        keyword1.put("value",empName);
+        data.put("keyword1",keyword1);
+
+        //提现金额：{{keyword2.DATA}}
+        JSONObject keyword2=new JSONObject();
+        keyword2.put("value",payAmount);
+        data.put("keyword2",keyword2);
+
+        //提现账户：{{keyword3.DATA}}
+        JSONObject keyword3=new JSONObject();
+        keyword3.put("value",payAccount);
+        data.put("keyword3",keyword3);
+
+        //处理时间：{{keyword4.DATA}}
+        JSONObject keyword4=new JSONObject();
+        keyword4.put("value",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+        data.put("keyword4",keyword4);
+        return data;
+    }
+
 }

csm-service/cms-service-user/src/main/resources/mapper/MessageDao.xml

@@ -72,5 +72,15 @@
         set is_deleted = 1, deleted_time = NOW()
         where message_id = #{messageId}
     </update>
+    <update id="updateSystemMessage">
+        UPDATE message
+        <set>
+            <if test="subject != null">subject,</if>
+            <if test="content != null">content</if>
+        </set>
+        <where>
+            id = #{id}
+        </where>
+    </update>
 
 </mapper>