package com.doumee.api.web;
|
|
import com.doumee.core.annotation.LoginRequired;
|
import com.doumee.core.annotation.pr.PreventRepeat;
|
import com.doumee.core.annotation.trace.Trace;
|
import com.doumee.core.constants.Constants;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.ApiResponse;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.web.response.UserResponse;
|
import com.doumee.dao.system.dto.WebLoginDTO;
|
import com.doumee.dao.system.model.SystemUser;
|
import com.doumee.jtt808.web.service.Jtt808Service;
|
import com.doumee.service.business.*;
|
import com.doumee.service.system.SystemLoginService;
|
import com.doumee.service.system.SystemUserService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.shiro.authz.annotation.RequiresPermissions;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* Created by IntelliJ IDEA.
|
*
|
* @Author : Rk
|
* @create 2023/10/9 10:15
|
*/
|
|
@Api(tags = "4、运营中心接口")
|
@Trace(exclude = true)
|
@RestController
|
@RequestMapping("/web/manger")
|
@Slf4j
|
public class ManagerApi extends ApiController{
|
|
@Autowired
|
private Jtt808Service jtt808Service;
|
|
@Autowired
|
private BikesService bikesService;
|
@Autowired
|
private SystemLoginService systemLoginService;
|
@Autowired
|
private SystemUserService systemUserService;
|
@LoginRequired
|
@PreventRepeat(limit = 10, lockTime = 10000)
|
@ApiOperation("登录管理员账号")
|
@PostMapping("/login")
|
public ApiResponse<UserResponse> login (@Validated @RequestBody WebLoginDTO dto, HttpServletRequest request) {
|
dto.setMemberId(this.getMemberId());
|
SystemUser sys =systemLoginService.loginByPasswordWx(dto, request);
|
return ApiResponse.success( memberService.getUserInfo(getMemberId()));
|
}
|
@LoginRequired
|
@PreventRepeat(limit = 10, lockTime = 10000)
|
@ApiOperation("退出管理员账号")
|
@PostMapping("/logout")
|
public ApiResponse<UserResponse> logout (HttpServletRequest request) {
|
systemLoginService.logoutWx(this.getMemberId());
|
return ApiResponse.success(memberService.getUserInfo(getMemberId()));
|
}
|
|
@PreventRepeat
|
@LoginRequired
|
@ApiOperation("电车批量上下架")
|
@GetMapping("/updateBikeStatus/batch")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true),
|
@ApiImplicitParam(paramType = "query", dataType = "String", name = "ids", value = "车辆编码集合，多个英文逗号隔开", required = true),
|
@ApiImplicitParam(paramType = "query", dataType = "Integer", name = "bikeStatus", value = "状态", required = true)
|
})
|
public ApiResponse updateBikeStatus(@RequestParam String ids, @RequestParam Integer bikeStatus) {
|
UserResponse user = this.getUserResponse();
|
if(user.getSysuser() ==null){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
String [] idArray = ids.split(",");
|
List<String> idList = new ArrayList<>();
|
for (String id : idArray) {
|
idList.add(id);
|
}
|
bikesService.updateBikeStatusBatchWx(user,idList,bikeStatus);
|
return ApiResponse.success(null);
|
}
|
@PreventRepeat
|
@LoginRequired
|
@ApiOperation("电车批量开关锁")
|
@GetMapping("/updateLockStatus/batch")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true),
|
@ApiImplicitParam(paramType = "query", dataType = "String", name = "ids", value = "车辆编码集合，多个英文逗号隔开", required = true),
|
@ApiImplicitParam(paramType = "query", dataType = "Integer", name = "lockStatus", value = "状态 0关锁 1开锁", required = true)
|
})
|
public ApiResponse<String> updateLockStatus(@RequestParam String ids, @RequestParam Integer lockStatus) {
|
UserResponse user = this.getUserResponse();
|
if(user.getSysuser() ==null){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
String [] idArray = ids.split(",");
|
List<String> idList = new ArrayList<>();
|
for (String id : idArray) {
|
idList.add(id);
|
}
|
String msg = jtt808Service.updateLockStatusBatch(user,idList,lockStatus);
|
return ApiResponse.success(msg);
|
}
|
@PreventRepeat
|
@LoginRequired
|
@ApiOperation("分页查询电车列表")
|
@PostMapping("/pageBikes")
|
public ApiResponse<PageData<Bikes>> pageBikes (@RequestBody PageWrap<Bikes> pageWrap) {
|
UserResponse user = this.getUserResponse();
|
if(user.getSysuser() ==null){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
pageWrap.getModel().setType(Constants.ONE);//查询电车列表
|
PageData<Bikes> list = bikesService.findJoinPage(pageWrap);
|
return ApiResponse.success(list);
|
}
|
|
}
|
