Commit f45ad58f authored by liqin's avatar liqin 💬

Merge branch 'master' of http://111.203.232.171:8888/lee/chnmuseum-party into master

parents 1d962ee1 f22de179
...@@ -3,8 +3,10 @@ package cn.wisenergy.chnmuseum.party; ...@@ -3,8 +3,10 @@ package cn.wisenergy.chnmuseum.party;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class) @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@EnableScheduling
public class Application { public class Application {
public static void main(String[] args) { public static void main(String[] args) {
......
...@@ -206,7 +206,7 @@ class SystemOperationLogService extends ServiceImpl<SysLogMapper, SysLog> { ...@@ -206,7 +206,7 @@ class SystemOperationLogService extends ServiceImpl<SysLogMapper, SysLog> {
Audit byId = auditService.getById(auditStatusParam.getId()); Audit byId = auditService.getById(auditStatusParam.getId());
type = byId.getType(); type = byId.getType();
status=auditStatusParam.getStatus(); status=auditStatusParam.getStatus();
if ("REFUSED".equals(status)){ if (AuditStatusEnum.REFUSED.name().equals(status)){
sysLog.setOperationContent(AuditStatusEnum.REFUSED.getMsg()); sysLog.setOperationContent(AuditStatusEnum.REFUSED.getMsg());
}else { }else {
sysLog.setOperationContent(AuditStatusEnum.APPROVED_FINAL.getMsg()); sysLog.setOperationContent(AuditStatusEnum.APPROVED_FINAL.getMsg());
......
...@@ -80,7 +80,7 @@ public class GlobalExceptionAdvisor { ...@@ -80,7 +80,7 @@ public class GlobalExceptionAdvisor {
// FieldError error = bindingResult.getFieldErrors().get(i); // FieldError error = bindingResult.getFieldErrors().get(i);
// errMsg.append(error.getField()).append(":").append(error.getDefaultMessage()); // errMsg.append(error.getField()).append(":").append(error.getDefaultMessage());
// } // }
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, message); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", message);
//throw new InterfaceException(RESPONSE_CODE_ENUM.PARAM_NOT_VALID.getCode(), errMsg.toString()); //throw new InterfaceException(RESPONSE_CODE_ENUM.PARAM_NOT_VALID.getCode(), errMsg.toString());
} }
...@@ -112,12 +112,12 @@ public class GlobalExceptionAdvisor { ...@@ -112,12 +112,12 @@ public class GlobalExceptionAdvisor {
} }
} }
} }
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, msg); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", msg);
} }
@ExceptionHandler(DataAccessException.class) @ExceptionHandler(DataAccessException.class)
public cn.wisenergy.chnmuseum.party.common.validator.HttpResult dataAccessException(DataAccessException exception) { public cn.wisenergy.chnmuseum.party.common.validator.HttpResult dataAccessException(DataAccessException exception) {
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, exception.getLocalizedMessage()); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", exception.getLocalizedMessage());
} }
@ExceptionHandler(DuplicateKeyException.class) @ExceptionHandler(DuplicateKeyException.class)
...@@ -127,11 +127,11 @@ public class GlobalExceptionAdvisor { ...@@ -127,11 +127,11 @@ public class GlobalExceptionAdvisor {
String message = Splitter.on(System.lineSeparator()).trimResults().splitToList(localizedMessage).get(1); String message = Splitter.on(System.lineSeparator()).trimResults().splitToList(localizedMessage).get(1);
String substring = message.substring(message.indexOf("Exception:")); String substring = message.substring(message.indexOf("Exception:"));
if (substring.toUpperCase().contains("NAME")) { if (substring.toUpperCase().contains("NAME")) {
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, "名称已存在"); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", "名称已存在");
} else if (substring.toUpperCase().contains("CODE")) { } else if (substring.toUpperCase().contains("CODE")) {
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, "编码已存在"); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", "编码已存在");
} }
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, message); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", message);
} }
@ExceptionHandler(SQLIntegrityConstraintViolationException.class) @ExceptionHandler(SQLIntegrityConstraintViolationException.class)
...@@ -141,11 +141,11 @@ public class GlobalExceptionAdvisor { ...@@ -141,11 +141,11 @@ public class GlobalExceptionAdvisor {
String message = Splitter.on(System.lineSeparator()).trimResults().splitToList(localizedMessage).get(1); String message = Splitter.on(System.lineSeparator()).trimResults().splitToList(localizedMessage).get(1);
String substring = message.substring(message.indexOf("Exception:")); String substring = message.substring(message.indexOf("Exception:"));
if (substring.toUpperCase().contains("NAME")) { if (substring.toUpperCase().contains("NAME")) {
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, "名称已存在"); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", "名称已存在");
} else if (substring.toUpperCase().contains("CODE")) { } else if (substring.toUpperCase().contains("CODE")) {
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, "编码已存在"); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", "编码已存在");
} }
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, message); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", message);
} }
/** /**
...@@ -157,7 +157,7 @@ public class GlobalExceptionAdvisor { ...@@ -157,7 +157,7 @@ public class GlobalExceptionAdvisor {
@ExceptionHandler(HttpMessageConversionException.class) @ExceptionHandler(HttpMessageConversionException.class)
public cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpMessageConversionException(HttpMessageConversionException exception) { public cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpMessageConversionException(HttpMessageConversionException exception) {
log.error(exception.getCause().getLocalizedMessage()); log.error(exception.getCause().getLocalizedMessage());
return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(400, exception.getCause().getLocalizedMessage()); return new cn.wisenergy.chnmuseum.party.common.validator.HttpResult("400", exception.getCause().getLocalizedMessage());
} }
/** /**
...@@ -169,7 +169,7 @@ public class GlobalExceptionAdvisor { ...@@ -169,7 +169,7 @@ public class GlobalExceptionAdvisor {
@ExceptionHandler(InterfaceException.class) @ExceptionHandler(InterfaceException.class)
public cn.wisenergy.chnmuseum.party.common.validator.HttpResult handleInterfaceException(InterfaceException exception) { public cn.wisenergy.chnmuseum.party.common.validator.HttpResult handleInterfaceException(InterfaceException exception) {
cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpResult = new cn.wisenergy.chnmuseum.party.common.validator.HttpResult(); cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpResult = new cn.wisenergy.chnmuseum.party.common.validator.HttpResult();
httpResult.setResultCode(Integer.parseInt(exception.getErrorCode())); httpResult.setResultCode(exception.getErrorCode());
httpResult.setMessage(exception.getErrorMsg()); httpResult.setMessage(exception.getErrorMsg());
return httpResult; return httpResult;
} }
...@@ -209,7 +209,7 @@ public class GlobalExceptionAdvisor { ...@@ -209,7 +209,7 @@ public class GlobalExceptionAdvisor {
* @param httpResult 响应对象 * @param httpResult 响应对象
*/ */
private void addResCodeToMap(RESPONSE_CODE_ENUM responseCodeEnum, cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpResult) { private void addResCodeToMap(RESPONSE_CODE_ENUM responseCodeEnum, cn.wisenergy.chnmuseum.party.common.validator.HttpResult httpResult) {
httpResult.setResultCode(Integer.parseInt(responseCodeEnum.getResultCode())); httpResult.setResultCode(responseCodeEnum.getResultCode());
httpResult.setMessage(responseCodeEnum.getMessage()); httpResult.setMessage(responseCodeEnum.getMessage());
} }
} }
\ No newline at end of file
...@@ -2,7 +2,7 @@ package cn.wisenergy.chnmuseum.party.common.validator; ...@@ -2,7 +2,7 @@ package cn.wisenergy.chnmuseum.party.common.validator;
public class HttpResult { public class HttpResult {
// 响应的状态码 // 响应的状态码
private int resultCode; private String resultCode;
// 响应的响应信息 // 响应的响应信息
private String message; private String message;
...@@ -13,21 +13,21 @@ public class HttpResult { ...@@ -13,21 +13,21 @@ public class HttpResult {
public HttpResult() { public HttpResult() {
} }
public HttpResult(int resultCode, String message) { public HttpResult(String resultCode, String message) {
this.resultCode = resultCode; this.resultCode = resultCode;
this.message = message; this.message = message;
} }
public HttpResult(int resultCode, Object data) { public HttpResult(String resultCode, Object data) {
this.resultCode = resultCode; this.resultCode = resultCode;
this.data = data; this.data = data;
} }
public int getResultCode() { public String getResultCode() {
return resultCode; return resultCode;
} }
public void setResultCode(int resultCode) { public void setResultCode(String resultCode) {
this.resultCode = resultCode; this.resultCode = resultCode;
} }
......
...@@ -21,6 +21,7 @@ import org.springframework.data.redis.core.RedisTemplate; ...@@ -21,6 +21,7 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import javax.annotation.Resource;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
...@@ -38,7 +39,7 @@ import java.util.Map; ...@@ -38,7 +39,7 @@ import java.util.Map;
@Service @Service
public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMapper, TBoardStatistic> implements TBoardStatisticService { public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMapper, TBoardStatistic> implements TBoardStatisticService {
@Autowired @Resource
private TBoardStatisticMapper boardStatisticMapper; private TBoardStatisticMapper boardStatisticMapper;
@Autowired @Autowired
...@@ -55,15 +56,22 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe ...@@ -55,15 +56,22 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe
@Override @Override
@RedisLock(value = "boardLock",timeLock = 20 ,required = true,timeOut = 1100000) @RedisLock(value = "boardLock",timeLock = 20 ,required = true,timeOut = 1100000)
public Object boardStatisticInfo(TBoardStatistic tBoardStatistic, boolean autoUpdate) { public Object boardStatisticInfo(TBoardStatistic tBoardStatistic, boolean autoUpdate) {
// 根据用户id获取用户信息 if (tBoardStatistic!=null) {
TUser user = userService.selectById(tBoardStatistic.getUserId()); // 根据用户id获取用户信息
TUser user = userService.selectById(tBoardStatistic.getUserId());
tBoardStatistic.setOrganId(user.getOrgId()); // 用户所属机构 tBoardStatistic.setOrganId(user.getOrgId()); // 用户所属机构
tBoardStatistic.setAreaId(Integer.parseInt(user.getAreaId()));// 用户所属地区 tBoardStatistic.setAreaId(Integer.parseInt(user.getAreaId()));// 用户所属地区
if (StringUtils.isEmpty(tBoardStatistic.getPlayDate())){ if (StringUtils.isEmpty(tBoardStatistic.getPlayDate())) {
// 获取当前日期 // 获取当前日期
tBoardStatistic.setPlayDate(DateUtil.getCurrentDate("yyyyMMdd")); tBoardStatistic.setPlayDate(DateUtil.getCurrentDate("yyyyMMdd"));
}
if (null==tBoardStatistic.getPlayNumber()) {
// 获取当前日期
tBoardStatistic.setPlayNumber(1);
}
} }
List<TBoardStatistic> statisticList = new ArrayList<>(); List<TBoardStatistic> statisticList = new ArrayList<>();
String redisKey = STATISTIC_BOARD_INFO_KEY; String redisKey = STATISTIC_BOARD_INFO_KEY;
// 获取统计信息缓存数据 // 获取统计信息缓存数据
...@@ -72,10 +80,12 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe ...@@ -72,10 +80,12 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe
if (StringUtils.isNotEmpty(businessJsonArray)){ if (StringUtils.isNotEmpty(businessJsonArray)){
statisticList = JSONObject.parseArray(businessJsonArray, TBoardStatistic.class); statisticList = JSONObject.parseArray(businessJsonArray, TBoardStatistic.class);
} }
statisticList.add(tBoardStatistic); if (tBoardStatistic!=null) {
statisticList.add(tBoardStatistic);
}
redisUtil.set(redisKey, JSON.toJSON(statisticList).toString()); redisUtil.set(redisKey, JSON.toJSON(statisticList).toString());
// 统计记录数等于100 时,或者需要自动更新时 汇总统计数据 // 统计记录数等于100 时,或者需要自动更新时 汇总统计数据
if (statisticList.size() >= 100 || autoUpdate){ if (statisticList.size() >= 100 || (autoUpdate&&statisticList.size()>0)){
// 更新展板统计信息 // 更新展板统计信息
updateBoardStatisticInfo(statisticList,redisKey); updateBoardStatisticInfo(statisticList,redisKey);
} }
...@@ -186,15 +196,6 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe ...@@ -186,15 +196,6 @@ public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMappe
this.save(bs); this.save(bs);
} }
} }
// 更新展板播放排行 t_board_play_rank
// 插入
// 看板播放趋势
// 地区看板播放统计
// 播放数据概览
// 清空redis // 清空redis
redisUtil.del(redisKey); redisUtil.del(redisKey);
......
...@@ -232,6 +232,7 @@ public class AuditController extends BaseController { ...@@ -232,6 +232,7 @@ public class AuditController extends BaseController {
@ApiImplicitParam(name = "status", value = "待初审:TBC, 驳回:REFUSED,待复审:TBCA, 通过:APPROVED_FINAL", paramType = "query", dataType = "String"), @ApiImplicitParam(name = "status", value = "待初审:TBC, 驳回:REFUSED,待复审:TBCA, 通过:APPROVED_FINAL", paramType = "query", dataType = "String"),
@ApiImplicitParam(name = "type", value = "视频内容:VIDEO_CONTENT,展板内容:EXHIBITION_BOARD,学习内容:LEARNING_CONTENT", paramType = "query", dataType = "String", allowableValues = "VIDEO_CONTENT,EXHIBITION_BOARD,LEARNING_CONTENT,ACCOUNT", required = true) @ApiImplicitParam(name = "type", value = "视频内容:VIDEO_CONTENT,展板内容:EXHIBITION_BOARD,学习内容:LEARNING_CONTENT", paramType = "query", dataType = "String", allowableValues = "VIDEO_CONTENT,EXHIBITION_BOARD,LEARNING_CONTENT,ACCOUNT", required = true)
}) })
@MethodLog(operModule = OperModule.CHECKVIDEO,operType = OperType.SELECT)
public Map<String, Object> getPageAllList(String name, String status, @NotBlank(message = "type参数不能为空") String type) { public Map<String, Object> getPageAllList(String name, String status, @NotBlank(message = "type参数不能为空") String type) {
AuditStatusEnum auditStatus = null; AuditStatusEnum auditStatus = null;
AuditStatusEnum auditStatusLevel = null; AuditStatusEnum auditStatusLevel = null;
......
...@@ -2,6 +2,7 @@ package cn.wisenergy.chnmuseum.party.web.controller; ...@@ -2,6 +2,7 @@ package cn.wisenergy.chnmuseum.party.web.controller;
import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService; import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService;
import cn.wisenergy.chnmuseum.party.auth.util.JwtTokenUtil; import cn.wisenergy.chnmuseum.party.auth.util.JwtTokenUtil;
import cn.wisenergy.chnmuseum.party.common.enums.AuditOperationEnum;
import cn.wisenergy.chnmuseum.party.common.enums.FileCatEnum; import cn.wisenergy.chnmuseum.party.common.enums.FileCatEnum;
import cn.wisenergy.chnmuseum.party.common.enums.FileTypeEnum; import cn.wisenergy.chnmuseum.party.common.enums.FileTypeEnum;
import cn.wisenergy.chnmuseum.party.common.enums.LanguageEnum; import cn.wisenergy.chnmuseum.party.common.enums.LanguageEnum;
...@@ -34,6 +35,7 @@ import org.springframework.data.redis.core.StringRedisTemplate; ...@@ -34,6 +35,7 @@ import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations; import org.springframework.data.redis.core.ValueOperations;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -191,7 +193,7 @@ public class ChinaMobileRestApiController extends BaseController { ...@@ -191,7 +193,7 @@ public class ChinaMobileRestApiController extends BaseController {
resultMap.put("message", "mac地址不正确!"); resultMap.put("message", "mac地址不正确!");
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap); return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap);
} }
if ("2".equals(user.getStatus())) { if (AuditOperationEnum.DISABLE.name().equals(user.getStatus())) {
throw new DisabledAccountException("此帐号已禁用,请联系管理员!"); throw new DisabledAccountException("此帐号已禁用,请联系管理员!");
} }
...@@ -447,6 +449,17 @@ public class ChinaMobileRestApiController extends BaseController { ...@@ -447,6 +449,17 @@ public class ChinaMobileRestApiController extends BaseController {
return getFailResult(); return getFailResult();
} }
@Scheduled(cron = "0 0/5 * * * *")
public void boardStatistic(){
try {
System.out.println("定时汇总播放记录开始...");
tBoardStatisticService.boardStatisticInfo(null, true);
System.out.println("定时汇总播放记录成功...");
} catch (Exception e) {
e.printStackTrace();
}
}
@ApiImplicitParams(value = { @ApiImplicitParams(value = {
@ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"), @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"), @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
......
...@@ -3,9 +3,12 @@ package cn.wisenergy.chnmuseum.party.web.controller; ...@@ -3,9 +3,12 @@ package cn.wisenergy.chnmuseum.party.web.controller;
import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService; import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService;
import cn.wisenergy.chnmuseum.party.auth.util.JwtTokenUtil; import cn.wisenergy.chnmuseum.party.auth.util.JwtTokenUtil;
import cn.wisenergy.chnmuseum.party.common.checkcode.SpecCaptcha; import cn.wisenergy.chnmuseum.party.common.checkcode.SpecCaptcha;
import cn.wisenergy.chnmuseum.party.common.enums.AuditOperationEnum;
import cn.wisenergy.chnmuseum.party.common.enums.AuditStatusEnum;
import cn.wisenergy.chnmuseum.party.common.log.MethodLog; import cn.wisenergy.chnmuseum.party.common.log.MethodLog;
import cn.wisenergy.chnmuseum.party.common.log.OperModule; import cn.wisenergy.chnmuseum.party.common.log.OperModule;
import cn.wisenergy.chnmuseum.party.common.log.OperType; import cn.wisenergy.chnmuseum.party.common.log.OperType;
import cn.wisenergy.chnmuseum.party.model.Audit;
import cn.wisenergy.chnmuseum.party.model.Role; import cn.wisenergy.chnmuseum.party.model.Role;
import cn.wisenergy.chnmuseum.party.model.TUser; import cn.wisenergy.chnmuseum.party.model.TUser;
import cn.wisenergy.chnmuseum.party.model.Menu; import cn.wisenergy.chnmuseum.party.model.Menu;
...@@ -128,7 +131,7 @@ public class LoginController extends BaseController { ...@@ -128,7 +131,7 @@ public class LoginController extends BaseController {
ValueOperations<String, String> opsForValue = stringRedisTemplate.opsForValue(); ValueOperations<String, String> opsForValue = stringRedisTemplate.opsForValue();
if ("LOCK".equals(opsForValue.get(SHIRO_IS_LOCK + username))) { if ("LOCK".equals(opsForValue.get(SHIRO_IS_LOCK + username))) {
resultMap.put("resultCode", "500"); resultMap.put("resultCode", "500");
resultMap.put("message", "由于密码输入错误次数大于5次,12小时内帐号已禁止登录!请您联系相关管理人员,联系电话:13924551212,邮箱:325346534@zh.com。"); resultMap.put("message", "由于密码输入错误次数大于5次,12小时内帐号已禁止登录!请您联系相关管理人员。");
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap); return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap);
} }
...@@ -139,7 +142,7 @@ public class LoginController extends BaseController { ...@@ -139,7 +142,7 @@ public class LoginController extends BaseController {
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap); return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap);
} }
if ("2".equals(user.getStatus())) { if (AuditOperationEnum.DISABLE.name().equals(user.getStatus())) {
resultMap.put("resultCode", "500"); resultMap.put("resultCode", "500");
resultMap.put("message", "此帐号已禁用,请联系管理员!"); resultMap.put("message", "此帐号已禁用,请联系管理员!");
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap); return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(resultMap);
...@@ -153,7 +156,6 @@ public class LoginController extends BaseController { ...@@ -153,7 +156,6 @@ public class LoginController extends BaseController {
} }
} }
byte[] salt = user.getPasswordSalt(); byte[] salt = user.getPasswordSalt();
String s1 = new String(SHA256PasswordEncryptionService.createPasswordHash(password, salt)); String s1 = new String(SHA256PasswordEncryptionService.createPasswordHash(password, salt));
if (!new String(SHA256PasswordEncryptionService.createPasswordHash(password, salt)).equals(new String(user.getPasswordHash()))) { if (!new String(SHA256PasswordEncryptionService.createPasswordHash(password, salt)).equals(new String(user.getPasswordHash()))) {
......
...@@ -55,6 +55,7 @@ public class TBoxOperationController extends BaseController { ...@@ -55,6 +55,7 @@ public class TBoxOperationController extends BaseController {
@PostMapping("/selectPageList") @PostMapping("/selectPageList")
@RequiresPermissions("/boxOperation/selectPageList") @RequiresPermissions("/boxOperation/selectPageList")
@ApiOperation(value = "获取机顶盒基础信息分页列表", notes = "获取机顶盒基础信息分页列表") @ApiOperation(value = "获取机顶盒基础信息分页列表", notes = "获取机顶盒基础信息分页列表")
@MethodLog(operModule = OperModule.STBBASE,operType = OperType.SELECT)
public Map<String, Object> selectPageList(String organId, String areaId) { public Map<String, Object> selectPageList(String organId, String areaId) {
TUser user1 = getcurUser(); TUser user1 = getcurUser();
TUser user = new TUser(); TUser user = new TUser();
...@@ -82,6 +83,7 @@ public class TBoxOperationController extends BaseController { ...@@ -82,6 +83,7 @@ public class TBoxOperationController extends BaseController {
@PostMapping("/add") @PostMapping("/add")
@RequiresPermissions("/boxOperation/add") @RequiresPermissions("/boxOperation/add")
@ApiOperation(value = "添加机顶盒运维信息", notes = "添加机顶盒运维信息") @ApiOperation(value = "添加机顶盒运维信息", notes = "添加机顶盒运维信息")
@MethodLog(operModule = OperModule.STBOPERATION,operType = OperType.ADD)
public Map<String, Object> saveTBoxOperation(TBoxOperation tBoxOperation) { public Map<String, Object> saveTBoxOperation(TBoxOperation tBoxOperation) {
// 保存业务节点信息 // 保存业务节点信息
boolean result; boolean result;
...@@ -139,6 +141,7 @@ public class TBoxOperationController extends BaseController { ...@@ -139,6 +141,7 @@ public class TBoxOperationController extends BaseController {
@ApiImplicitParams(value = { @ApiImplicitParams(value = {
@ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String") @ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String")
}) })
@MethodLog(operModule = OperModule.STBOPERATION,operType = OperType.DELETE)
public Map<String, Object> deleteTBoxOperation(String id) { public Map<String, Object> deleteTBoxOperation(String id) {
boolean result; boolean result;
try { try {
...@@ -156,6 +159,7 @@ public class TBoxOperationController extends BaseController { ...@@ -156,6 +159,7 @@ public class TBoxOperationController extends BaseController {
@GetMapping("/getList") @GetMapping("/getList")
@RequiresPermissions("/boxOperation/getList") @RequiresPermissions("/boxOperation/getList")
@ApiOperation(value = "获取机顶盒运维信息全部列表(无分页)", notes = "获取机顶盒运维信息全部列表(无分页)") @ApiOperation(value = "获取机顶盒运维信息全部列表(无分页)", notes = "获取机顶盒运维信息全部列表(无分页)")
@MethodLog(operModule = OperModule.STBOPERATION,operType = OperType.SELECT)
public Map<String, Object> getTBoxOperationList(String status) { public Map<String, Object> getTBoxOperationList(String status) {
List<TBoxOperation> tBoxOperationList = null; List<TBoxOperation> tBoxOperationList = null;
TUser user = getcurUser(); TUser user = getcurUser();
...@@ -180,6 +184,7 @@ public class TBoxOperationController extends BaseController { ...@@ -180,6 +184,7 @@ public class TBoxOperationController extends BaseController {
@PostMapping("/getPageList") @PostMapping("/getPageList")
@RequiresPermissions("/boxOperation/getPageList") @RequiresPermissions("/boxOperation/getPageList")
@ApiOperation(value = "获取机顶盒运维信息分页列表", notes = "获取机顶盒运维信息分页列表") @ApiOperation(value = "获取机顶盒运维信息分页列表", notes = "获取机顶盒运维信息分页列表")
@MethodLog(operModule = OperModule.STBOPERATION,operType = OperType.SELECT)
public Map<String, Object> getTBoxOperationPageList(String organId, Integer status, String areaId) { public Map<String, Object> getTBoxOperationPageList(String organId, Integer status, String areaId) {
TUser user = getcurUser(); TUser user = getcurUser();
TBoxOperation tBoxOperation = new TBoxOperation(); TBoxOperation tBoxOperation = new TBoxOperation();
...@@ -209,6 +214,7 @@ public class TBoxOperationController extends BaseController { ...@@ -209,6 +214,7 @@ public class TBoxOperationController extends BaseController {
@ApiOperation(value = "获取机顶盒运维信息详情", notes = "获取机顶盒运维信息详情") @ApiOperation(value = "获取机顶盒运维信息详情", notes = "获取机顶盒运维信息详情")
@GetMapping("/getById") @GetMapping("/getById")
@RequiresPermissions("/boxOperation/getById") @RequiresPermissions("/boxOperation/getById")
@MethodLog(operModule = OperModule.STBOPERATION,operType = OperType.SELECT)
public Map<String, Object> getById(@PathVariable("id") String id) { public Map<String, Object> getById(@PathVariable("id") String id) {
TBoxOperation tBoxOperation = null; TBoxOperation tBoxOperation = null;
try { try {
......
...@@ -2,6 +2,9 @@ package cn.wisenergy.chnmuseum.party.web.controller; ...@@ -2,6 +2,9 @@ package cn.wisenergy.chnmuseum.party.web.controller;
import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService; import cn.wisenergy.chnmuseum.party.auth.SHA256PasswordEncryptionService;
import cn.wisenergy.chnmuseum.party.auth.SecureRandomSaltService; import cn.wisenergy.chnmuseum.party.auth.SecureRandomSaltService;
import cn.wisenergy.chnmuseum.party.common.log.MethodLog;
import cn.wisenergy.chnmuseum.party.common.log.OperModule;
import cn.wisenergy.chnmuseum.party.common.log.OperType;
import cn.wisenergy.chnmuseum.party.common.util.DateUtil80; import cn.wisenergy.chnmuseum.party.common.util.DateUtil80;
import cn.wisenergy.chnmuseum.party.model.TUser; import cn.wisenergy.chnmuseum.party.model.TUser;
import cn.wisenergy.chnmuseum.party.service.impl.TUserServiceImpl; import cn.wisenergy.chnmuseum.party.service.impl.TUserServiceImpl;
...@@ -62,6 +65,7 @@ public class TInteractionController extends BaseController { ...@@ -62,6 +65,7 @@ public class TInteractionController extends BaseController {
@PostMapping("/add") @PostMapping("/add")
@RequiresPermissions("/interaction/add") @RequiresPermissions("/interaction/add")
@ApiOperation(value = "添加看板互动", notes = "添加看板互动") @ApiOperation(value = "添加看板互动", notes = "添加看板互动")
@MethodLog(operModule = OperModule.INTERACTIVE,operType = OperType.ADD)
public Map<String, Object> saveTInteraction(TInteraction tInteraction) { public Map<String, Object> saveTInteraction(TInteraction tInteraction) {
// 保存业务节点信息 // 保存业务节点信息
...@@ -110,6 +114,7 @@ public class TInteractionController extends BaseController { ...@@ -110,6 +114,7 @@ public class TInteractionController extends BaseController {
@PutMapping("/update") @PutMapping("/update")
@RequiresPermissions("/interaction/update") @RequiresPermissions("/interaction/update")
@ApiOperation(value = "修改看板互动信息", notes = "修改看板互动信息") @ApiOperation(value = "修改看板互动信息", notes = "修改看板互动信息")
@MethodLog(operModule = OperModule.INTERACTIVE,operType = OperType.UPDATE)
public Map<String, Object> updateTInteraction(TInteraction tInteraction) { public Map<String, Object> updateTInteraction(TInteraction tInteraction) {
boolean flag = false; boolean flag = false;
try { try {
...@@ -132,6 +137,7 @@ public class TInteractionController extends BaseController { ...@@ -132,6 +137,7 @@ public class TInteractionController extends BaseController {
@ApiImplicitParams(value = { @ApiImplicitParams(value = {
@ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String") @ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String")
}) })
@MethodLog(operModule = OperModule.INTERACTIVE,operType = OperType.DELETE)
public Map<String, Object> deleteTInteraction(String id) { public Map<String, Object> deleteTInteraction(String id) {
boolean result = tInteractionService.removeById(id); boolean result = tInteractionService.removeById(id);
if (result) { if (result) {
...@@ -149,6 +155,7 @@ public class TInteractionController extends BaseController { ...@@ -149,6 +155,7 @@ public class TInteractionController extends BaseController {
@ApiImplicitParam(name = "orgId", value = "机构id", paramType = "query", dataType = "String") @ApiImplicitParam(name = "orgId", value = "机构id", paramType = "query", dataType = "String")
}) })
@ApiOperation(value = "获取看板互动列表", notes = "获取看板互动列表") @ApiOperation(value = "获取看板互动列表", notes = "获取看板互动列表")
@MethodLog(operModule = OperModule.INTERACTIVE,operType = OperType.SELECT)
public Map<String, Object> getTInteractionPageList(String orgId) { public Map<String, Object> getTInteractionPageList(String orgId) {
Page<TInteraction> list = null; Page<TInteraction> list = null;
try { try {
...@@ -164,6 +171,7 @@ public class TInteractionController extends BaseController { ...@@ -164,6 +171,7 @@ public class TInteractionController extends BaseController {
@ApiOperation(value = "获取看板互动详情", notes = "获取看板互动详情") @ApiOperation(value = "获取看板互动详情", notes = "获取看板互动详情")
@GetMapping("/getById") @GetMapping("/getById")
@RequiresPermissions("/interaction/getById") @RequiresPermissions("/interaction/getById")
@MethodLog(operModule = OperModule.INTERACTIVE,operType = OperType.SELECT)
public Map<String, Object> getById(String id) { public Map<String, Object> getById(String id) {
TInteraction tInteraction = null; TInteraction tInteraction = null;
try { try {
......
...@@ -69,7 +69,7 @@ public class TOrganController extends BaseController { ...@@ -69,7 +69,7 @@ public class TOrganController extends BaseController {
@PostMapping("/add") @PostMapping("/add")
@RequiresPermissions("/organ/add") @RequiresPermissions("/organ/add")
@ApiOperation(value = "添加机构", notes = "添加机构") @ApiOperation(value = "添加机构", notes = "添加机构")
// @MethodLog(operModule = OperModule.ORG,operType = OperType.ADD) @MethodLog(operModule = OperModule.ORG,operType = OperType.ADD)
public Map<String, Object> add(TOrgan organ) { public Map<String, Object> add(TOrgan organ) {
QueryWrapper<TOrgan> ew = new QueryWrapper<>(); QueryWrapper<TOrgan> ew = new QueryWrapper<>();
...@@ -104,7 +104,7 @@ public class TOrganController extends BaseController { ...@@ -104,7 +104,7 @@ public class TOrganController extends BaseController {
@PutMapping("/update") @PutMapping("/update")
@RequiresPermissions("/organ/update") @RequiresPermissions("/organ/update")
@ApiOperation(value = "update", notes = "修改机构信息") @ApiOperation(value = "update", notes = "修改机构信息")
// @MethodLog(operModule = OperModule.ORG,operType = OperType.UPDATE) @MethodLog(operModule = OperModule.ORG,operType = OperType.UPDATE)
public Map<String, Object> updateTOrgan(TOrgan tOrgan) { public Map<String, Object> updateTOrgan(TOrgan tOrgan) {
try { try {
...@@ -141,7 +141,7 @@ public class TOrganController extends BaseController { ...@@ -141,7 +141,7 @@ public class TOrganController extends BaseController {
@ApiImplicitParams(value = { @ApiImplicitParams(value = {
@ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String") @ApiImplicitParam(name = "id", value = "标识ID", paramType = "query", dataType = "String")
}) })
// @MethodLog(operModule = OperModule.ORG,operType = OperType.DELETE) @MethodLog(operModule = OperModule.ORG,operType = OperType.DELETE)
public Map<String, Object> deleteTOrgan(String id) { public Map<String, Object> deleteTOrgan(String id) {
boolean result = false; boolean result = false;
try { try {
...@@ -162,7 +162,7 @@ public class TOrganController extends BaseController { ...@@ -162,7 +162,7 @@ public class TOrganController extends BaseController {
@GetMapping("/getList") @GetMapping("/getList")
@RequiresPermissions("/organ/getList") @RequiresPermissions("/organ/getList")
@ApiOperation(value = "获取机构全部列表(无分页)", notes = "获取机构全部列表(无分页)") @ApiOperation(value = "获取机构全部列表(无分页)", notes = "获取机构全部列表(无分页)")
// @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT) @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT)
public Map<String, Object> getTOrganList() { public Map<String, Object> getTOrganList() {
TUser user = null; TUser user = null;
try { try {
...@@ -238,7 +238,7 @@ public class TOrganController extends BaseController { ...@@ -238,7 +238,7 @@ public class TOrganController extends BaseController {
@GetMapping("/getTree") @GetMapping("/getTree")
@RequiresPermissions("/organ/getTree") @RequiresPermissions("/organ/getTree")
@ApiOperation(value = "获取机构树", notes = "获取机构树") @ApiOperation(value = "获取机构树", notes = "获取机构树")
// @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT) @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT)
public Map<String, Object> getTree(String name) { public Map<String, Object> getTree(String name) {
TUser user = getcurUser(); TUser user = getcurUser();
List<TOrgan> list = new ArrayList<>(); List<TOrgan> list = new ArrayList<>();
...@@ -257,8 +257,8 @@ public class TOrganController extends BaseController { ...@@ -257,8 +257,8 @@ public class TOrganController extends BaseController {
@GetMapping("/getAreaTree") @GetMapping("/getAreaTree")
@RequiresPermissions("/organ/getAreaTree") @RequiresPermissions("/organ/getAreaTree")
@ApiOperation(value = "获取区域树", notes = "获取机构树") @ApiOperation(value = "获取区域树", notes = "获取区域树")
// @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT) @MethodLog(operModule = OperModule.ORG,operType = OperType.SELECT)
public Map<String, Object> getAreaTree() { public Map<String, Object> getAreaTree() {
List<TArea> list = null; List<TArea> list = null;
try { try {
......
...@@ -80,7 +80,7 @@ public class TUserController extends BaseController { ...@@ -80,7 +80,7 @@ public class TUserController extends BaseController {
}) })
@RequestMapping(value = "/getPageList", method = RequestMethod.GET) @RequestMapping(value = "/getPageList", method = RequestMethod.GET)
@RequiresPermissions("/user/getPageList") @RequiresPermissions("/user/getPageList")
// @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT) @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT)
public Map<String, Object> getPageList(String userName, String status, String type, String orgId, String areaId) { public Map<String, Object> getPageList(String userName, String status, String type, String orgId, String areaId) {
TUser user1 = getcurUser(); TUser user1 = getcurUser();
TUser user = new TUser(); TUser user = new TUser();
...@@ -131,7 +131,7 @@ public class TUserController extends BaseController { ...@@ -131,7 +131,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "获取用户列表") @ApiOperation(value = "获取用户列表")
@RequestMapping(value = "/getUserList", method = RequestMethod.GET) @RequestMapping(value = "/getUserList", method = RequestMethod.GET)
@RequiresPermissions("/user/getUserList") @RequiresPermissions("/user/getUserList")
// @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT) @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT)
public Map<String, Object> getUserList(String type, String status, String auditStatus) { public Map<String, Object> getUserList(String type, String status, String auditStatus) {
TUser user1 = getcurUser(); TUser user1 = getcurUser();
TUser user = new TUser(); TUser user = new TUser();
...@@ -164,7 +164,7 @@ public class TUserController extends BaseController { ...@@ -164,7 +164,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "获取用户详情", notes = "获取用户详情") @ApiOperation(value = "获取用户详情", notes = "获取用户详情")
@GetMapping("/getById") @GetMapping("/getById")
@RequiresPermissions("/user/getById") @RequiresPermissions("/user/getById")
// @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT) @MethodLog(operModule = OperModule.USER, operType = OperType.SELECT)
public Map<String, Object> getById(String id) { public Map<String, Object> getById(String id) {
try { try {
TUser tUser = userService.selectById(id); TUser tUser = userService.selectById(id);
...@@ -185,7 +185,7 @@ public class TUserController extends BaseController { ...@@ -185,7 +185,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "新增成员") @ApiOperation(value = "新增成员")
@RequestMapping(value = "/add", method = RequestMethod.POST) @RequestMapping(value = "/add", method = RequestMethod.POST)
@RequiresPermissions("/user/add") @RequiresPermissions("/user/add")
// @MethodLog(operModule = OperModule.USER, operType = OperType.ADD) @MethodLog(operModule = OperModule.USER, operType = OperType.ADD)
public Map<String, Object> add(@RequestBody TUser user) { public Map<String, Object> add(@RequestBody TUser user) {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>(); Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
try { try {
...@@ -539,7 +539,7 @@ public class TUserController extends BaseController { ...@@ -539,7 +539,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "管理员更改自己的登录密码", notes = "管理员更改自己的登录密码") @ApiOperation(value = "管理员更改自己的登录密码", notes = "管理员更改自己的登录密码")
@RequestMapping(value = "/editPwd", method = RequestMethod.PUT) @RequestMapping(value = "/editPwd", method = RequestMethod.PUT)
@RequiresPermissions("/user/editPwd") @RequiresPermissions("/user/editPwd")
@MethodLog(operModule = OperModule.USER, operType = OperType.UPDATE) @MethodLog(operModule = OperModule.CHANGEPWD, operType = OperType.CHANGE_PASSWORD)
public ResponseEntity<Map<String, Object>> editPwd(@RequestParam(value = "oldPassWord") String oldPassWord, public ResponseEntity<Map<String, Object>> editPwd(@RequestParam(value = "oldPassWord") String oldPassWord,
@RequestParam(value = "password") String password) { @RequestParam(value = "password") String password) {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>(); Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
...@@ -583,7 +583,7 @@ public class TUserController extends BaseController { ...@@ -583,7 +583,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "管理员重置密码", notes = "管理员重置密码") @ApiOperation(value = "管理员重置密码", notes = "管理员重置密码")
@RequestMapping(value = "/resetPassword", method = RequestMethod.PUT) @RequestMapping(value = "/resetPassword", method = RequestMethod.PUT)
@RequiresPermissions("/user/resetPassword") @RequiresPermissions("/user/resetPassword")
@MethodLog(operModule = OperModule.CHANGEPWD, operType = OperType.UPDATE) @MethodLog(operModule = OperModule.USER, operType = OperType.RESET_PASSWORD)
public ResponseEntity<Map<Object, Object>> resetPassword(String userId) { public ResponseEntity<Map<Object, Object>> resetPassword(String userId) {
try { try {
Map<Object, Object> map = new LinkedHashMap<>(); Map<Object, Object> map = new LinkedHashMap<>();
...@@ -615,7 +615,7 @@ public class TUserController extends BaseController { ...@@ -615,7 +615,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "新增机顶盒账号") @ApiOperation(value = "新增机顶盒账号")
@RequestMapping(value = "/boxAdd", method = RequestMethod.POST) @RequestMapping(value = "/boxAdd", method = RequestMethod.POST)
@RequiresPermissions("/user/boxAdd") @RequiresPermissions("/user/boxAdd")
// @MethodLog(operModule = OperModule.USER, operType = OperType.ADD) @MethodLog(operModule = OperModule.USER, operType = OperType.ADD)
public ResponseEntity<Map<String, Object>> BoxAdd(TUser user) { public ResponseEntity<Map<String, Object>> BoxAdd(TUser user) {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>(); Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
try { try {
...@@ -708,7 +708,7 @@ public class TUserController extends BaseController { ...@@ -708,7 +708,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "新增运维账号") @ApiOperation(value = "新增运维账号")
@RequestMapping(value = "/operationAdd", method = RequestMethod.POST) @RequestMapping(value = "/operationAdd", method = RequestMethod.POST)
@RequiresPermissions("/user/operationAdd") @RequiresPermissions("/user/operationAdd")
// @MethodLog(operModule = OperModule.USER, operType = OperType.ADD) @MethodLog(operModule = OperModule.USER, operType = OperType.ADD)
public ResponseEntity<Map<String, Object>> operationAdd(TUser user) { public ResponseEntity<Map<String, Object>> operationAdd(TUser user) {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>(); Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
try { try {
...@@ -779,7 +779,7 @@ public class TUserController extends BaseController { ...@@ -779,7 +779,7 @@ public class TUserController extends BaseController {
@ApiOperation(value = "新增统计账号") @ApiOperation(value = "新增统计账号")
@RequestMapping(value = "/statisticsAdd", method = RequestMethod.POST) @RequestMapping(value = "/statisticsAdd", method = RequestMethod.POST)
@RequiresPermissions("/user/statisticsAdd") @RequiresPermissions("/user/statisticsAdd")
// @MethodLog(operModule = OperModule.USER, operType = OperType.ADD) @MethodLog(operModule = OperModule.USER, operType = OperType.ADD)
public ResponseEntity<Map<String, Object>> statisticsAdd(TUser user) { public ResponseEntity<Map<String, Object>> statisticsAdd(TUser user) {
Map<String, Object> resultMap = new LinkedHashMap<String, Object>(); Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
try { try {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment