Song/xkrs_ms
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

!52 公众号开发

Browse Source 
Merge pull request !52 from 德仔/develop
This commit is contained in:
德仔
2021-02-01 09:22:19 +08:00
committed by Gitee
parent f067b96170 90030b76f6
commit 91870bb4a2
16 changed files with 1283 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
stdiet-admin/src/main/java/com/stdiet/web/controller/common/CommonController.java
View File

@ -3,10 +3,15 @@ package com.stdiet.web.controller.common;
import com.stdiet.common.config.RuoYiConfig;
import com.stdiet.common.constant.Constants;
import com.stdiet.common.core.domain.AjaxResult;
import com.stdiet.common.core.redis.RedisCache;
import com.stdiet.common.utils.StringUtils;
import com.stdiet.common.utils.file.FileUploadUtils;
import com.stdiet.common.utils.file.FileUtils;
import com.stdiet.custom.domain.wechat.WxAccessToken;
import com.stdiet.custom.domain.wechat.WxFileUploadResult;
import com.stdiet.custom.utils.WxTokenUtils;
import com.stdiet.framework.config.ServerConfig;
import org.aspectj.weaver.loadtime.Aj;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@ -17,6 +22,7 @@ import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.concurrent.TimeUnit;
/**
* 通用请求处理
@ -30,6 +36,9 @@ public class CommonController {
@Autowired
private ServerConfig serverConfig;
@Autowired
private RedisCache redisCache;
/**
* 通用下载请求
*
@ -98,6 +107,39 @@ public class CommonController {
}
}
/**
* 通用上传请求(无需登录认证)
*/
@PostMapping("/common/wxAccountUpload")
public AjaxResult wxAccountUpload(MultipartFile file) throws Exception {
try {
// 上传文件路径
String filePath = RuoYiConfig.getUploadPath();
// 上传并返回新文件名称
String fileName = FileUploadUtils.upload(filePath, file);
String url = serverConfig.getUrl() + fileName;
String accessToken = redisCache.getCacheObject(WxTokenUtils.KEY_ACCESS_TOKEN);
if (StringUtils.isEmpty(accessToken)) {
WxAccessToken wxAccessToken = WxTokenUtils.fetchAccessToken();
redisCache.setCacheObject(WxTokenUtils.KEY_ACCESS_TOKEN, wxAccessToken.getAccessToken(), wxAccessToken.getExpiresIn(), TimeUnit.SECONDS);
}
WxFileUploadResult result = WxTokenUtils.uploadImage(filePath, accessToken);
if(result == null) {
return AjaxResult.error("上传微信失败");
}
AjaxResult ajax = AjaxResult.success();
ajax.put("fileName", fileName);
ajax.put("mediaId", result.getMediaId());
ajax.put("url", url);
return ajax;
} catch (Exception e) {
return AjaxResult.error(e.getMessage());
}
}
/**
* 本地资源通用下载
*/

133
stdiet-admin/src/main/java/com/stdiet/web/controller/custom/SysWxSaleAccountController.java Normal file
View File

@ -0,0 +1,133 @@
package com.stdiet.web.controller.custom;
import com.stdiet.common.annotation.Log;
import com.stdiet.common.config.RuoYiConfig;
import com.stdiet.common.core.controller.BaseController;
import com.stdiet.common.core.domain.AjaxResult;
import com.stdiet.common.core.page.TableDataInfo;
import com.stdiet.common.core.redis.RedisCache;
import com.stdiet.common.enums.BusinessType;
import com.stdiet.common.utils.StringUtils;
import com.stdiet.common.utils.file.FileUploadUtils;
import com.stdiet.common.utils.poi.ExcelUtil;
import com.stdiet.custom.domain.SysWxSaleAccount;
import com.stdiet.custom.domain.wechat.WxAccessToken;
import com.stdiet.custom.domain.wechat.WxFileUploadResult;
import com.stdiet.custom.service.ISysWxSaleAccountService;
import com.stdiet.custom.utils.WxTokenUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
* 微信销售账号Controller
*
* @author wonder
* @date 2021-01-29
*/
@RestController
@RequestMapping("/custom/WxAccount")
public class SysWxSaleAccountController extends BaseController {
@Autowired
private ISysWxSaleAccountService sysWxSaleAccountService;
@Autowired
private RedisCache redisCache;
/**
* 查询微信销售账号列表
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:list')")
@GetMapping("/list")
public TableDataInfo list(SysWxSaleAccount sysWxSaleAccount) {
startPage();
List<SysWxSaleAccount> list = sysWxSaleAccountService.selectSysWxSaleAccountList(sysWxSaleAccount);
return getDataTable(list);
}
/**
* 导出微信销售账号列表
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:export')")
@Log(title = "微信销售账号", businessType = BusinessType.EXPORT)
@GetMapping("/export")
public AjaxResult export(SysWxSaleAccount sysWxSaleAccount) {
List<SysWxSaleAccount> list = sysWxSaleAccountService.selectSysWxSaleAccountList(sysWxSaleAccount);
ExcelUtil<SysWxSaleAccount> util = new ExcelUtil<SysWxSaleAccount>(SysWxSaleAccount.class);
return util.exportExcel(list, "WxAccount");
}
/**
* 获取微信销售账号详细信息
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id) {
return AjaxResult.success(sysWxSaleAccountService.selectSysWxSaleAccountById(id));
}
/**
* 新增微信销售账号
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:add')")
@Log(title = "微信销售账号", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody SysWxSaleAccount sysWxSaleAccount) {
return toAjax(sysWxSaleAccountService.insertSysWxSaleAccount(sysWxSaleAccount));
}
/**
* 修改微信销售账号
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:edit')")
@Log(title = "微信销售账号", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody SysWxSaleAccount sysWxSaleAccount) {
return toAjax(sysWxSaleAccountService.updateSysWxSaleAccount(sysWxSaleAccount));
}
/**
* 删除微信销售账号
*/
@PreAuthorize("@ss.hasPermi('custom:WxAccount:remove')")
@Log(title = "微信销售账号", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids) {
return toAjax(sysWxSaleAccountService.deleteSysWxSaleAccountByIds(ids));
}
@PostMapping("/upload")
public AjaxResult uploadFile(@RequestParam("file") MultipartFile file, SysWxSaleAccount sysWxSaleAccount) throws Exception {
try {
// 上传文件路径
String filePath = RuoYiConfig.getUploadPath();
// 上传并返回新文件名称
String fileName = FileUploadUtils.upload(filePath, file);
sysWxSaleAccount.setImgUrl(fileName);
String accessToken = redisCache.getCacheObject(WxTokenUtils.KEY_ACCESS_TOKEN);
if (StringUtils.isEmpty(accessToken)) {
WxAccessToken wxAccessToken = WxTokenUtils.fetchAccessToken();
redisCache.setCacheObject(WxTokenUtils.KEY_ACCESS_TOKEN, wxAccessToken.getAccessToken(), wxAccessToken.getExpiresIn(), TimeUnit.SECONDS);
}
WxFileUploadResult result = WxTokenUtils.uploadImage(fileName, accessToken);
if (StringUtils.isNotNull(result)) {
sysWxSaleAccount.setMediaId(result.getMediaId());
return toAjax(sysWxSaleAccountService.insertSysWxSaleAccount(sysWxSaleAccount));
}
return AjaxResult.error("empty");
} catch (Exception e) {
return AjaxResult.error(e.getMessage());
}
}
}