server
/
mlProject
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
39 Commits
1 Branch
567 KiB
 
Tree: e0516b7222
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'e0516b7222'
${ noResults }
mlProject/mlWechatOpen/src/main/java/com/iformall/controller/WechatWeappCodeController.java

561 lines
26 KiB
Raw Blame History 

  1. package com.iformall.controller;

  2. 

  3. import com.alibaba.fastjson.JSON;

  4. import com.google.gson.Gson;

  5. import com.google.gson.GsonBuilder;

  6. import com.google.gson.reflect.TypeToken;

  7. import com.iformall.common.ErrorCode;

  8. import com.iformall.common.Result;

  9. import com.iformall.common.ResultData;

  10. import com.iformall.domain.po.*;

  11. import com.iformall.domain.vo.WxWeappCodeStatusVo;

  12. import com.iformall.enums.*;

  13. import com.iformall.service.*;

  14. import com.iformall.service.wechat.WxOpenService;

  15. import io.swagger.annotations.Api;

  16. import io.swagger.annotations.ApiImplicitParam;

  17. import io.swagger.annotations.ApiImplicitParams;

  18. import io.swagger.annotations.ApiOperation;

  19. import me.chanjar.weixin.common.error.WxErrorException;

  20. import me.chanjar.weixin.open.api.WxOpenMaService;

  21. import me.chanjar.weixin.open.bean.ma.WxMaOpenCommitExtInfo;

  22. import me.chanjar.weixin.open.bean.message.WxOpenMaSubmitAuditMessage;

  23. import me.chanjar.weixin.open.bean.result.*;

  24. import org.apache.commons.lang3.StringUtils;

  25. import org.slf4j.Logger;

  26. import org.slf4j.LoggerFactory;

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

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

  29. 

  30. import javax.servlet.ServletOutputStream;

  31. import javax.servlet.http.HttpServletRequest;

  32. import javax.servlet.http.HttpServletResponse;

  33. import java.io.File;

  34. import java.io.FileInputStream;

  35. import java.io.IOException;

  36. import java.io.InputStream;

  37. import java.net.URLEncoder;

  38. import java.util.Date;

  39. import java.util.List;

  40. import java.util.Map;

  41. 

  42. /**

  43.  * Stormeye Wu

  44.  */

  45. @RestController

  46. @RequestMapping("/weappCode")

  47. @Api(description = "微信第三方开发平台-小程序-代码管理")

  48. public class WechatWeappCodeController {

  49.     private final Logger logger = LoggerFactory.getLogger(getClass());

  50.     @Autowired

  51.     private WxOpenService openService;

  52. 

  53.     @Autowired

  54.     private WxWeappCodeStatusService weappCodeStatusService;

  55. 

  56.     @Autowired

  57.     private WxWeappAuditStatusService weappAuditStatusService;

  58. 

  59.     @Autowired

  60.     private WxWeappReleaseStatusService weappReleaseStatusService;

  61. 

  62.     @Autowired

  63.     private WxAppinfoService appinfoService;

  64. 

  65.     @Autowired

  66.     private WxAuthorizerInfoService authorizerInfoService;

  67. 

  68.     @Autowired

  69.     private WxWeappExtSetService weappExtSetService;

  70. 

  71. 

  72.     @ApiOperation(value = "为授权的小程序帐号上传小程序代码", notes = "extInfo参考https://mp.weixin.qq.com/debug/wxadoc/dev/framework/config.html")

  73.     @PostMapping("/codeCommit")

  74.     public ResultData codeCommit(Long templateId, String userVersion, String userDesc, String extInfoStr) {

  75.         Gson gson = new GsonBuilder().create();

  76.         WxMaOpenCommitExtInfo extInfo = gson.fromJson(extInfoStr, new TypeToken<WxMaOpenCommitExtInfo>() {}.getType());

  77.         String appId = extInfo.getExtAppid();

  78. 

  79.         // 检查appId是否已授权

  80.         WxAuthorizerInfo authorizerInfo = authorizerInfoService.getByAppId(appId);

  81.         if(authorizerInfo == null) {

  82.             return new ResultData(ErrorCode.WEAPP_APPID_NOT_AUTH);

  83.         }

  84.         if(!authorizerInfo.getAuthorizationStatus().equals(EnumWxAuthorizationStatus.AUTHORIZED.getCode())) {

  85.             return new ResultData(ErrorCode.WEAPP_APPID_NOT_AUTH);

  86.         }

  87. 

  88.         WxWeappCodeStatus codeStatus = weappCodeStatusService.getByAppId(appId);

  89. 

  90.         WxAppinfo appinfo = appinfoService.getByAppId(appId);

  91. 

  92.         int iAppType = 0;

  93.         String appTypeStr = userVersion.substring(0, 1);

  94.         if(appTypeStr.equalsIgnoreCase("C"))

  95.             iAppType = EnumAppType.C.getCode();

  96.         else if(appTypeStr.equalsIgnoreCase("B"))

  97.             iAppType = EnumAppType.B.getCode();

  98. 

  99.         try {

  100.             // code提交

  101.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  102.             logger.info(extInfo.toString());

  103.             WxOpenResult openRet = openMaService.codeCommit(templateId, userVersion, userDesc, extInfo);

  104.             logger.info(openRet.toString());

  105.             boolean codeCommitStatus = false;

  106.             if (openRet.isSuccess()) {

  107.                 codeCommitStatus = true;

  108.             }

  109.             if (codeStatus == null) {

  110.                 codeStatus = new WxWeappCodeStatus();

  111.                 codeStatus.setAppId(appId);

  112.                 if (appinfo != null) {

  113.                     codeStatus.setTenantId(appinfo.getTenantId());

  114.                     codeStatus.setType(appinfo.getType());

  115.                 }

  116.                 codeStatus.setUserVersion(userVersion);

  117.                 codeStatus.setVersionDesc(userDesc);

  118.                 if(codeCommitStatus) {

  119.                     codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.SUCCESS.getCode());

  120.                 } else {

  121.                     codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.FAIL.getCode());

  122.                     codeStatus.setCodeErrCode(gson.toJson(openRet));

  123.                 }

  124.                 codeStatus.setCodeTime(new Date());

  125.                 weappCodeStatusService.saveStatus(codeStatus);

  126.             } else {

  127.                 codeStatus.setUserVersion(userVersion);

  128.                 codeStatus.setVersionDesc(userDesc);

  129.                 if(codeCommitStatus) {

  130.                     codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.SUCCESS.getCode());

  131.                 } else {

  132.                     codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.FAIL.getCode());

  133.                     codeStatus.setCodeErrCode(gson.toJson(openRet));

  134.                 }

  135.                 codeStatus.setCodeTime(new Date());

  136.                 weappCodeStatusService.updateStatus(codeStatus);

  137.             }

  138.             return new ResultData(openRet);

  139.         } catch (WxErrorException e) {

  140.             logger.error(e.getMessage());

  141.             if (codeStatus == null) {

  142.                 codeStatus = new WxWeappCodeStatus();

  143.                 codeStatus.setAppId(appId);

  144.                 if (appinfo != null) {

  145.                     codeStatus.setTenantId(appinfo.getTenantId());

  146.                     codeStatus.setType(appinfo.getType());

  147.                 }

  148.                 codeStatus.setUserVersion(userVersion);

  149.                 codeStatus.setVersionDesc(userDesc);

  150.                 codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.FAIL.getCode());

  151.                 codeStatus.setCodeErrCode(e.getMessage());

  152.                 codeStatus.setCodeTime(new Date());

  153.                 weappCodeStatusService.saveStatus(codeStatus);

  154.             } else {

  155.                 codeStatus.setUserVersion(userVersion);

  156.                 codeStatus.setVersionDesc(userDesc);

  157.                 codeStatus.setCodeStatus(EnumWeappCodeCommitStatus.FAIL.getCode());

  158.                 codeStatus.setCodeErrCode(e.getMessage());

  159.                 codeStatus.setCodeTime(new Date());

  160.                 weappCodeStatusService.updateStatus(codeStatus);

  161.             }

  162.             return new ResultData(Result.ERROR, e.getMessage());

  163.         }

  164.     }

  165. 

  166.     @ApiOperation("获取体验小程序的体验二维码")

  167.     @GetMapping("/getQrcode")

  168.     public void getQrcode(@RequestParam(value = "appId") String appId, @RequestParam(value = "pagePath") String pagePath,

  169.                           @RequestParam(value = "params", required = false) Map<String, String> params,

  170.                           HttpServletResponse response, HttpServletRequest req) {

  171.         try {

  172.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  173.             File file = openMaService.getTestQrcode(pagePath, params);

  174.             ServletOutputStream out = response.getOutputStream();

  175. 

  176.             response.reset();

  177.             response.setContentType("image/jpeg");

  178.             String agent = req.getHeader("user-agent");

  179.             String filename = "QRCode.jpg";

  180.             if (agent.contains("Firefox")) {

  181.                 response.setHeader("Content-disposition",

  182.                         "attachment; filename=" + new String(filename.getBytes("GB2312"),"ISO-8859-1"));

  183.             } else {

  184.                 response.setHeader("Content-disposition",

  185.                         "attachment; filename=" + URLEncoder.encode(filename,"UTF-8"));

  186.             }

  187.             // 循环取出流中的数据

  188.             byte[] b = new byte[1024];

  189.             int len;

  190.             InputStream inStream = new FileInputStream(file);

  191.             while ((len = inStream.read(b)) > 0)

  192.                 response.getOutputStream().write(b, 0, len);

  193.             inStream.close();

  194.         } catch (WxErrorException e) {

  195.             logger.error(e.getMessage());

  196.         } catch (IOException e) {

  197.             logger.error(e.getMessage());

  198.         }

  199.     }

  200. 

  201.     @ApiOperation("获取授权小程序帐号已设置的类目")

  202.     @GetMapping("/getCategory")

  203.     public ResultData getCategory(String appId) {

  204.         try {

  205.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  206.             WxOpenMaCategoryListResult openRet = openMaService.getCategoryList();

  207.             logger.info(openRet.toString());

  208.             return new ResultData(openRet);

  209.         } catch (WxErrorException e) {

  210.             logger.error(e.getMessage());

  211.             return new ResultData(Result.ERROR, e.getMessage());

  212.         }

  213.     }

  214. 

  215.     @ApiOperation("获取小程序的第三方提交代码的页面配置")

  216.     @GetMapping("/getPage")

  217.     public ResultData getPage(String appId) {

  218.         try {

  219.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  220.             WxOpenMaPageListResult openRet = openMaService.getPageList();

  221.             logger.info(openRet.toString());

  222.             return new ResultData(openRet);

  223.         } catch (WxErrorException e) {

  224.             logger.error(e.getMessage());

  225.             return new ResultData(Result.ERROR, e.getMessage());

  226.         }

  227.     }

  228. 

  229.     @ApiOperation("将第三方提交的代码包提交审核")

  230.     @GetMapping("/submitAudit")

  231.     @ApiImplicitParams({

  232.             @ApiImplicitParam(name = "appId", value = "appId", dataType = "String", paramType = "query", required = true),

  233.             @ApiImplicitParam(name = "version", value = "version", dataType = "String", paramType = "query")})

  234.     public ResultData submitAudit(String appId, String version) {

  235.         Gson gson = new GsonBuilder().create();

  236.         WxWeappExtSet extSetQ = new WxWeappExtSet();

  237.         extSetQ.setAppId(appId);

  238.         WxWeappExtSet extSet = weappExtSetService.getByObj(extSetQ);

  239.         if(StringUtils.isBlank(extSet.getReleaseJson())) {

  240.             logger.error("Release JSON is null");

  241.             return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL);

  242.         }

  243. 

  244.         WxWeappCodeStatusVo codeQ = new WxWeappCodeStatusVo();

  245.         codeQ.setAppId(appId);

  246.         if(StringUtils.isNotBlank(version)) {

  247.             codeQ.setUserVersion(version);

  248.         }

  249.         List<WxWeappCodeStatusVo> codeStatusList = weappCodeStatusService.getList(codeQ);

  250.         if(codeStatusList.size() == 1) {

  251.             WxWeappCodeStatusVo codeStatus = codeStatusList.get(0);

  252.             WxOpenMaSubmitAuditMessage subMessage = gson.fromJson(extSet.getReleaseJson(), new TypeToken<WxOpenMaSubmitAuditMessage>() {}.getType());

  253.             if(codeStatus != null && codeStatus.getCodeStatus().equals(EnumWeappCodeCommitStatus.SUCCESS.getCode())) {

  254.                 WxWeappAuditStatus auditStatus = weappAuditStatusService.getByAppId(appId);

  255.                 boolean submitStatus = false;

  256.                 String codeErrCode = "";

  257.                 try {

  258.                     WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  259.                     WxOpenMaSubmitAuditResult openRet = openMaService.submitAudit(subMessage);

  260.                     logger.info(openRet.toString());

  261.                     if(openRet.isSuccess()) {

  262.                         submitStatus = true;

  263.                         codeErrCode = gson.toJson(openRet);

  264.                     } else {

  265.                         submitStatus = false;

  266.                         codeErrCode = gson.toJson(openRet);

  267.                     }

  268.                 } catch (WxErrorException e) {

  269.                     logger.error(e.getMessage());

  270.                     submitStatus = false;

  271.                     codeErrCode = e.getMessage();

  272.                 }

  273. 

  274.                 if (auditStatus == null) {

  275.                     auditStatus = new WxWeappAuditStatus();

  276.                     auditStatus.setId(codeStatus.getId());

  277.                     auditStatus.setTenantId(codeStatus.getTenantId());

  278.                     auditStatus.setAppId(codeStatus.getAppId());

  279.                     auditStatus.setType(codeStatus.getType());

  280.                     auditStatus.setUserVersion(codeStatus.getUserVersion());

  281.                     auditStatus.setVersionDesc(codeStatus.getVersionDesc());

  282.                     if(submitStatus) {

  283.                         auditStatus.setAuditStatus(EnumWeappAuditStatus.AUDITING.getCode());

  284.                     } else {

  285.                         auditStatus.setAuditStatus(EnumWeappAuditStatus.FAIL.getCode());

  286.                     }

  287.                     auditStatus.setAuditErrCode(codeErrCode);

  288.                     auditStatus.setAuditTime(new Date());

  289.                     weappAuditStatusService.saveStatus(auditStatus);

  290.                 } else {

  291.                     if(!submitStatus) {

  292.                         if(!auditStatus.getUserVersion().equals(codeStatus.getUserVersion())

  293.                                 && auditStatus.getAuditStatus().equals(EnumWeappAuditStatus.AUDITING.getCode())) {

  294.                             // 提交审核失败不替换当前审核中的数据

  295.                             return new ResultData(ErrorCode.WEAPP_HAD_AUDITING);

  296.                         }

  297.                         codeStatus.setCodeStatus(EnumWeappAuditStatus.FAIL.getCode());

  298.                         codeStatus.setCodeErrCode(codeErrCode);

  299.                     } else {

  300.                         codeStatus.setCodeStatus(EnumWeappAuditStatus.AUDITING.getCode());

  301.                     }

  302.                     auditStatus.setUserVersion(codeStatus.getUserVersion());

  303.                     auditStatus.setVersionDesc(codeStatus.getVersionDesc());

  304.                     auditStatus.setAuditTime(new Date());

  305.                     weappAuditStatusService.updateStatus(auditStatus);

  306.                 }

  307.                 if(submitStatus) {

  308.                     return new ResultData(codeErrCode);

  309.                 } else {

  310.                     return new ResultData(ErrorCode.WEAPP_AUDIT_ERR);

  311.                 }

  312.             } else {

  313.                 logger.error(ErrorCode.WEAPP_CODE_COMMIT_ERR.getMessage());

  314.                 return new ResultData(ErrorCode.WEAPP_CODE_COMMIT_ERR);

  315.             }

  316.         }

  317.         return new ResultData(ErrorCode.WEAPP_CODE_COMMIT_ERR);

  318.     }

  319. 

  320.     @ApiOperation("查询某个指定版本的审核状态")

  321.     @PostMapping("/getAuditstatus")

  322.     public ResultData getAuditstatus(String appId, String auditidStr) {

  323.         Gson gson = new GsonBuilder().create();

  324.         Long auditId = Long.valueOf(auditidStr);

  325.         WxWeappAuditStatus auditStatus = weappAuditStatusService.getByAppId(appId);

  326.         if(auditStatus != null && auditStatus.getAuditid().equals(auditId)) {

  327.             try {

  328.                 WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  329.                 WxOpenMaQueryAuditResult openRet = openMaService.getAuditStatus(auditId);

  330.                 logger.info(openRet.toString());

  331.                 if (openRet.isSuccess()) {

  332.                     auditStatus.setAuditid(openRet.getAuditId());

  333.                     // 审核状态，其中0为审核成功，1为审核失败，2为审核中，3已撤回

  334.                     switch (openRet.getStatus().intValue()) {

  335.                         case 0:

  336.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.SUCCESS.getCode());

  337.                             break;

  338.                         case 1:

  339.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.FAIL.getCode());

  340.                             break;

  341.                         case 2:

  342.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.AUDITING.getCode());

  343.                             break;

  344.                         case 3:

  345.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.UNDO.getCode());

  346.                             break;

  347.                         default:

  348.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.AUDITING.getCode());

  349.                             break;

  350.                     }

  351.                     auditStatus.setAuditErrCode(gson.toJson(openRet));

  352.                     auditStatus.setAuditTime(new Date());

  353.                     weappAuditStatusService.updateStatus(auditStatus);

  354.                 }

  355.                 return new ResultData(openRet);

  356.             } catch (WxErrorException e) {

  357.                 logger.error(e.getMessage());

  358.                 return new ResultData(Result.ERROR, e.getMessage());

  359.             }

  360.         }

  361.         return new ResultData(Result.ERROR, "auditid不对应");

  362.     }

  363. 

  364.     @ApiOperation("查询最新一次提交的审核状态")

  365.     @GetMapping("/getLatestAuditstatus")

  366.     public ResultData get_latest_auditstatus(String appId) {

  367.         Gson gson = new GsonBuilder().create();

  368.         WxWeappAuditStatus auditStatus = weappAuditStatusService.getByAppId(appId);

  369.         if(auditStatus != null

  370.                 && auditStatus.getAuditStatus().equals(EnumWeappAuditStatus.AUDITING.getCode())) {

  371.             try {

  372.                 WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  373.                 WxOpenMaQueryAuditResult openRet = openMaService.getLatestAuditStatus();

  374.                 logger.info(openRet.toString());

  375.                 if (openRet.isSuccess()) {

  376.                     auditStatus.setAuditid(openRet.getAuditId());

  377.                     // 审核状态，其中0为审核成功，1为审核失败，2为审核中，3已撤回

  378.                     switch (openRet.getStatus().intValue()) {

  379.                         case 0:

  380.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.SUCCESS.getCode());

  381.                             break;

  382.                         case 1:

  383.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.FAIL.getCode());

  384.                             break;

  385.                         case 2:

  386.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.AUDITING.getCode());

  387.                             break;

  388.                         case 3:

  389.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.UNDO.getCode());

  390.                             break;

  391.                         default:

  392.                             auditStatus.setAuditStatus(EnumWeappAuditStatus.AUDITING.getCode());

  393.                             break;

  394.                     }

  395.                     auditStatus.setAuditErrCode(gson.toJson(openRet));

  396.                     auditStatus.setAuditTime(new Date());

  397.                     weappAuditStatusService.updateStatus(auditStatus);

  398.                 }

  399.                 return new ResultData(openRet);

  400.             } catch (WxErrorException e) {

  401.                 logger.error(e.getMessage());

  402.                 return new ResultData(Result.ERROR, e.getMessage());

  403.             }

  404.         } else {

  405.             return new ResultData(Result.ERROR, "审核状态不是审核中");

  406.         }

  407.     }

  408. 

  409.     @ApiOperation("发布已通过审核的小程序")

  410.     @GetMapping("/releaseAudited")

  411.     public ResultData releaesAudited(String appId) {

  412.         if(StringUtils.isBlank(appId)) {

  413.             return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL);

  414.         }

  415.         Gson gson = new GsonBuilder().create();

  416.         WxWeappAuditStatus auditStatus = weappAuditStatusService.getByAppId(appId);

  417.         if(auditStatus.getAuditStatus().equals(EnumWeappAuditStatus.SUCCESS.getCode())) {

  418.             boolean isUpdate = false;

  419.             WxWeappReleaseStatus releaseStatus = weappReleaseStatusService.getByAppId(appId);

  420.             if(releaseStatus != null) {

  421.                 // 版本已发布成功，跳过

  422.                 if(releaseStatus.getUserVersion().equals(auditStatus.getUserVersion())

  423.                         && releaseStatus.getReleaseStatus().equals(EnumWeappReleaseStatus.SUCCESS.getCode())) {

  424.                     return new ResultData(ErrorCode.WEAPP_APP_RELEASEED);

  425.                 }

  426.                 releaseStatus.setUserVersion(auditStatus.getUserVersion());

  427.                 releaseStatus.setVersionDesc(auditStatus.getVersionDesc());

  428.                 isUpdate = true;

  429.             } else {

  430.                 releaseStatus = new WxWeappReleaseStatus();

  431.                 releaseStatus.setId(auditStatus.getId());

  432.                 releaseStatus.setTenantId(auditStatus.getTenantId());

  433.                 releaseStatus.setAppId(auditStatus.getAppId());

  434.                 releaseStatus.setType(auditStatus.getType());

  435.                 releaseStatus.setUserVersion(auditStatus.getUserVersion());

  436.                 releaseStatus.setVersionDesc(auditStatus.getVersionDesc());

  437.             }

  438.             try {

  439.                 WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  440.                 WxOpenResult openRet = openMaService.releaesAudited();

  441.                 logger.info(openRet.toString());

  442.                 if(openRet.isSuccess()) {

  443.                     releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.SUCCESS.getCode());

  444.                 } else {

  445.                     if(openRet.getErrcode().equalsIgnoreCase("85052")) {  // app is already released

  446.                         releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.SUCCESS.getCode());

  447.                     } else {

  448.                         releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.FAIL.getCode());

  449.                     }

  450.                 }

  451.                 releaseStatus.setReleaseErrCode(gson.toJson(openRet));

  452.                 releaseStatus.setReleaseTime(new Date());

  453.                 if(isUpdate) {

  454.                     weappReleaseStatusService.updateStatus(releaseStatus);

  455.                 } else {

  456.                     weappReleaseStatusService.saveStatus(releaseStatus);

  457.                 }

  458.                 return new ResultData(openRet);

  459.             } catch (WxErrorException e) {

  460.                 logger.error(e.getMessage());

  461.                 if(e.getError().getErrorCode() == 85052) {

  462.                     releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.SUCCESS.getCode());

  463.                 } else {

  464.                     releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.FAIL.getCode());

  465.                 }

  466.                 releaseStatus.setReleaseErrCode(e.getMessage());

  467.                 releaseStatus.setReleaseTime(new Date());

  468.                 if(isUpdate) {

  469.                     weappReleaseStatusService.updateStatus(releaseStatus);

  470.                 } else {

  471.                     weappReleaseStatusService.saveStatus(releaseStatus);

  472.                 }

  473.                 if (e.getError().getErrorCode() == 85052) {

  474.                     return new ResultData();

  475.                 }

  476.                 return new ResultData(Result.ERROR, e.getMessage());

  477.             }

  478.         } else {

  479.             return new ResultData(ErrorCode.WEAPP_NOT_AUDITED);

  480.         }

  481.     }

  482. 

  483.     @ApiOperation("小程序版本回退")

  484.     @GetMapping("/revertCodeRelease")

  485.     public ResultData revertCodeRelease(String appId) {

  486.         Gson gson = new GsonBuilder().create();

  487.         WxWeappReleaseStatus releaseStatus = weappReleaseStatusService.getByAppId(appId);

  488.         try {

  489.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  490.             WxOpenResult openRet = openMaService.revertCodeReleaes();

  491.             logger.info(openRet.toString());

  492.             if(openRet.isSuccess()) {

  493.                 if(releaseStatus != null) {

  494.                     releaseStatus.setReleaseStatus(EnumWeappReleaseStatus.BACK.getCode());

  495.                     releaseStatus.setReleaseErrCode(gson.toJson(openRet));

  496.                     releaseStatus.setReleaseTime(new Date());

  497.                     weappReleaseStatusService.updateStatus(releaseStatus);

  498.                 }

  499.                 return new ResultData();

  500.             }

  501.             return new ResultData(openRet);

  502.         } catch (WxErrorException e) {

  503.             logger.error(e.getMessage());

  504.             return new ResultData(Result.ERROR, e.getMessage());

  505.         }

  506.     }

  507. 

  508.     @ApiOperation("查询当前设置的最低基础库版本及各版本用户占比")

  509.     @GetMapping("/getSupportVersion")

  510.     public ResultData getSupportVersion(String appId) {

  511.         try {

  512.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  513.             String openRet = openMaService.getSupportVersion();

  514.             logger.info(openRet.toString());

  515.             return new ResultData(openRet);

  516.         } catch (WxErrorException e) {

  517.             logger.error(e.getMessage());

  518.             return new ResultData(Result.ERROR, e.getMessage());

  519.         }

  520.     }

  521. 

  522.     @ApiOperation("设置最低基础库版本")

  523.     @GetMapping("/setSupportVersion")

  524.     public ResultData setSupportVersion(String appId, String version) {

  525.         try {

  526.             WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  527.             String openRet = openMaService.setSupportVersion(version);

  528.             logger.info(openRet);

  529.             return new ResultData(openRet);

  530.         } catch (WxErrorException e) {

  531.             logger.error(e.getMessage());

  532.             return new ResultData(Result.ERROR, e.getMessage());

  533.         }

  534.     }

  535. 

  536.     @ApiOperation(value = "小程序审核撤回", notes = "单个帐号每天审核撤回次数最多不超过1次，一个月不超过10次。")

  537.     @GetMapping("/undoCodeAudit")

  538.     public ResultData undoCodeAudit(String appId) {

  539.         Gson gson = new GsonBuilder().create();

  540.         WxWeappAuditStatus auditStatus = weappAuditStatusService.getByAppId(appId);

  541.         if(auditStatus != null) {

  542.             try {

  543.                 WxOpenMaService openMaService = openService.getWxOpenComponentService().getWxMaServiceByAppid(appId);

  544.                 WxOpenResult openResult = openMaService.undoCodeAudit();

  545.                 if(openResult.isSuccess()) {

  546.                     auditStatus.setAuditStatus(EnumWeappAuditStatus.UNDO.getCode());

  547.                     auditStatus.setAuditErrCode(gson.toJson(openResult));

  548.                     auditStatus.setAuditTime(new Date());

  549.                     weappAuditStatusService.updateStatus(auditStatus);

  550.                     return new ResultData("审核撤回成功");

  551.                 }

  552.                 return new ResultData(Result.ERROR, "审核撤回失败");

  553.             } catch (WxErrorException e) {

  554.                 logger.error(e.getMessage());

  555.                 return new ResultData(Result.ERROR, e.getMessage());

  556.             }

  557.         }

  558.         return new ResultData(Result.ERROR, "没有审核记录,不能撤回");

  559.     }

  560. }