1、修改交易记录

src/main/java/com/dk/oauth/mapper/TradeMapper.java

@@ -20,6 +20,8 @@ public interface TradeMapper extends BaseMapper<Trade> {
 
     List<TradeResponse> selectTrade(Trade t);
 
+    TradeResponse selectTradeByNo(Trade t);
+
     Long countByCond(Trade t);
 
     /**

src/main/java/com/dk/oauth/service/wxapi/basic/WechatPayService.java

@@ -130,14 +130,14 @@ public class WechatPayService {
         UserLogin byWxid = userMapper.getByWxid(info.getOpenid());
         log.info("微信用户----------" + byWxid);
         // 获取交易记录
-        List<TradeResponse> tradeList = tradeMapper.selectTrade(new Trade().setTradeNo(info.getOutTradeNo()));
-        if(tradeList == null || tradeList.size() == 0){
+        TradeResponse tradeResponse = tradeMapper.selectTradeByNo(new Trade().setTradeNo(info.getOutTradeNo()));
+        if(tradeResponse == null){
             throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(),
                     ErrorCodeEnum.NO_FIND_TRADE.getMessage());
         }
         // 更新交易记录状态
         Trade trade = new Trade();
-        trade.setTradeId(tradeList.get(0).getTradeId());
+        trade.setTradeId(tradeResponse.getTradeId());
         trade.setWxTradeNo(info.getTransactionId());
         trade.setTradeStatus(Constant.TradeStatus.EFFECTIVE.getName());
         tradeMapper.updateById(trade);
@@ -146,7 +146,7 @@ public class WechatPayService {
         log.info("交易记录----------" + trade);
 //        企业
         Company comp = new Company();
-        comp.setCpId(tradeList.get(0).getCpId());
+        comp.setCpId(tradeResponse.getCpId());
         companyMapper.updateCompanyLicense(comp);
         log.info("交易记录-企业更新----------" + comp);
         return ResponseResultUtil.success();

src/main/resources/mapper/TradeMapper.xml

@@ -116,6 +116,14 @@
         <include refid="Condition"/>
     </select>
 
+    <!-- 查询表t_cp_trade，根据交易单号查数据 -->
+    <select id="selectTradeByNo" resultMap="BaseResultMap">
+        SELECT
+        <include refid="Base_Column_List"/>
+        FROM dkic_a.t_cp_trade t
+        WHERE t.trade_no = #{tradeNo}
+    </select>
+
 
     <insert id="insertBatch">
         insert into dkic_a.t_cp_trade