玩湃
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
22 小时以前 5dc40fcd64b0513150f1d8335ab849e6d8cdc28e 
 cloud-server-account/src/main/java/com/dsh/account/controller/AppUserController.java


@@ -1,33 +1,61 @@


package com.dsh.account.controller;




import com.alibaba.nacos.common.utils.Md5Utils;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.dsh.account.dto.BindDto;


import com.dsh.account.dto.IntroduceUserQuery;


import com.dsh.account.dto.SelectDto;


import com.dsh.account.dto.UpdateInfoDto;


import com.dsh.account.entity.*;


import com.dsh.account.model.*;


import com.dsh.account.entity.IntroduceUser;


import com.dsh.account.entity.TAppGift;


import com.dsh.account.entity.TAppUser;


import com.dsh.account.entity.TCourseInfoRecord;


import com.dsh.account.entity.TStudent;


import com.dsh.account.entity.UserIntegralChanges;


import com.dsh.account.model.AddAppUserVo;


import com.dsh.account.model.AdvertisementChangeStateDTO;


import com.dsh.account.model.AppUserByNameAndPhoneDTO;


import com.dsh.account.model.AppUserIdsByCityName;


import com.dsh.account.model.JoinPlayPaiVo;


import com.dsh.account.model.LoginSMSCodeVo;


import com.dsh.account.model.LoginWeChatVo;


import com.dsh.account.model.QueryByNamePhone;


import com.dsh.account.model.query.appUserQuery.QueryAppUser;


import com.dsh.account.model.vo.QueryAppUserVO;


import com.dsh.account.service.*;


import com.dsh.account.service.IVipPaymentService;


import com.dsh.account.service.TAppGiftService;


import com.dsh.account.service.TAppUserService;


import com.dsh.account.service.TCourseInfoRecordService;


import com.dsh.account.service.TStudentService;


import com.dsh.account.service.UserIntegralChangesService;


import com.dsh.account.util.PayMoneyUtil;


import com.dsh.account.util.ResultUtil;


import com.dsh.account.util.TokenUtil;


import com.dsh.account.util.ToolUtil;


import com.dsh.account.util.wx.WxV3PayConfig;


import com.wechat.pay.contrib.apache.httpclient.util.AesUtil;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import io.swagger.models.auth.In;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.*;


import org.springframework.web.bind.annotation.GetMapping;


import org.springframework.web.bind.annotation.PathVariable;


import org.springframework.web.bind.annotation.PostMapping;


import org.springframework.web.bind.annotation.RequestBody;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.ResponseBody;


import org.springframework.web.bind.annotation.RestController;




import javax.servlet.http.HttpServletRequest;


import javax.servlet.http.HttpServletResponse;


import java.io.BufferedReader;


import java.io.PrintWriter;


import java.util.*;


import java.nio.charset.StandardCharsets;


import java.util.ArrayList;


import java.util.Date;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;




/**


@@ -175,7 +203,8 @@


    @ResponseBody


    @GetMapping("/base/appUser/getAppUserByPhone/{phone}")


    public TAppUser getAppUserByPhone(@PathVariable("phone") String phone) {


        TAppUser appUser = appUserService.getOne(new QueryWrapper<TAppUser>().eq("phone", phone));


        TAppUser appUser = appUserService.getOne(new QueryWrapper<TAppUser>().eq("phone", phone)


                .eq("state",1));


        return appUser;


    }




@@ -429,6 +458,51 @@






    /**


     * 购买年度会员支付微信回调V3版本回调


     *


     * @param request


     * @param response


     */


    @ResponseBody


    @PostMapping("/base/appUser/addVipPaymentWeChatCallback1")


    public void addVipPaymentWeChatCallback1(HttpServletRequest request, HttpServletResponse response) {


        try {


            System.err.println("微信回调");


            System.err.println("请求" + request);


            BufferedReader reader = request.getReader();


            String string1 = reader.toString();


            System.err.println("请求reader" + string1);


            StringBuilder requestBody = new StringBuilder();


            String line;


            while ((line = reader.readLine()) != null) {


                requestBody.append(line);


            }


            System.err.println("全部请求体" + requestBody);


            JSONObject jsonObject = JSONObject.parseObject(requestBody.toString());


            JSONObject resource = jsonObject.getJSONObject("resource");




            AesUtil aesUtil = new AesUtil(WxV3PayConfig.apiV3Key.getBytes(StandardCharsets.UTF_8));


            String decryptedData = aesUtil.decryptToString(resource.getString("associated_data").getBytes(StandardCharsets.UTF_8), resource.getString("nonce").getBytes(StandardCharsets.UTF_8),


                    resource.getString("ciphertext"));


            System.err.println("微信解密的字符串信息" + decryptedData);


            JSONObject jsonInfo = (JSONObject) JSONObject.parse(decryptedData);


            String out_trade_no = jsonInfo.getString("out_trade_no");


            String transaction_id = jsonInfo.getString("transaction_id");


            String trade_state = jsonInfo.getString("trade_state");


            if (trade_state.equals("SUCCESS")) {


                ResultUtil resultUtil = vipPaymentService.addVipPaymentCallback(out_trade_no, transaction_id);


                if (resultUtil.getCode() == 200) {


                    PrintWriter out = response.getWriter();


                    out.write("SUCCESS");


                    out.flush();


                    out.close();


                }


            }


        } catch (Exception e) {


            e.printStackTrace();


        }


    }


    /**


     * 购买年度会员支付微信回调


     *


     * @param request


@@ -455,7 +529,6 @@


            e.printStackTrace();


        }


    }






    /**


     * 购买年度会员支付支付宝回调


@@ -503,7 +576,17 @@


            return null;


        }


    }




    /**


     * 根据用户id获取用户信息


     *


     * @param appUserIdList


     * @return


     */


    @ResponseBody


    @PostMapping("/base/appUser/queryAppUserBatch")


    List<TAppUser> queryAppUserBatch(@RequestBody List<Integer> appUserIdList){


        return appUserService.listByIds(appUserIdList);


    }




    @Autowired


    private UserIntegralChangesService userIntegralChangesService;