he2802 4 lat temu
rodzic
commit
b99b264cef

+ 21 - 7
zhongzheng-system/src/main/java/com/zhongzheng/modules/wx/service/impl/WxPayServiceImpl.java

@@ -46,7 +46,9 @@ import com.zhongzheng.modules.polyv.service.IPolyvVideoService;
 import com.zhongzheng.modules.polyv.vo.PolyvVideoQuerVo;
 import com.zhongzheng.modules.polyv.vo.PolyvVideoVo;
 import com.zhongzheng.modules.user.bo.OrderPossessUserAddBo;
+import com.zhongzheng.modules.user.domain.User;
 import com.zhongzheng.modules.user.service.IOrderPossessUserService;
+import com.zhongzheng.modules.user.service.IUserService;
 import com.zhongzheng.modules.wx.service.IWxPayService;
 import com.zhongzheng.modules.wx.vo.WxPayVo;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -117,6 +119,9 @@ public class WxPayServiceImpl  implements IWxPayService {
     @Autowired
     private ICourseService iCourseService;
 
+    @Autowired
+    private IUserService iUserService;
+
 
     private String gzh_tokenUrl = "https://api.weixin.qq.com/cgi-bin/token";
 
@@ -242,13 +247,22 @@ public class WxPayServiceImpl  implements IWxPayService {
                 bo.setOrderSn(out_trade_no);
                 List<OrderGoodsVo> goodsList = iOrderGoodsService.queryList(bo);
                 for (OrderGoodsVo g : goodsList) {
-                    //添加入我的学习
-                    OrderPossessUserAddBo addBo = new OrderPossessUserAddBo();
-                    addBo.setUserId(order.getUserId());
-                    addBo.setPossessId(g.getGoodsId());
-                    addBo.setTypeId(g.getGoodsType());
-                    addBo.setSourceId(0);//订单来源
-                    iOrderPossessUserService.insertByAddBo(addBo);
+                    if(g.getGoodsType()==4){
+                        //充值订单
+                        UpdateWrapper<User> updateUserWrapper = new UpdateWrapper<>();
+                        updateUserWrapper.setSql("money = "+g.getGoodsPrice());
+                        updateUserWrapper.eq("user_id", order.getUserId());
+                        iUserService.update(updateUserWrapper);
+                    }else{
+                        //添加入我的学习
+                        OrderPossessUserAddBo addBo = new OrderPossessUserAddBo();
+                        addBo.setUserId(order.getUserId());
+                        addBo.setPossessId(g.getGoodsId());
+                        addBo.setTypeId(g.getGoodsType());
+                        addBo.setSourceId(0);//订单来源
+                        iOrderPossessUserService.insertByAddBo(addBo);
+                    }
+
                 }
                 //用优惠券更新状态
                 OrderCoupon orderCoupon = iOrderCouponService.queryBySn(out_trade_no);