消息模板controller 编写

master
3y 3 years ago
parent a8fc6f75c9
commit 0fef91dbf8

@ -452,7 +452,7 @@ services:
      - 12201:12201/udp       - 12201:12201/udp
networks: networks:
  graylog:   graylog:
    driver: bridg     driver: bridge
``` ```
这个文件里唯一需要改动的就是`ip`(本来的端口是`9000`的,我由于已经占用了`9000`端口了,所以我这里把端口改成了`9009`,你们可以随意) 这个文件里唯一需要改动的就是`ip`(本来的端口是`9000`的,我由于已经占用了`9000`端口了,所以我这里把端口改成了`9009`,你们可以随意)

@ -17,8 +17,8 @@ public enum RespStatusEnum {
/** /**
* OK * OK
*/ */
SUCCESS("00000", "操作成功"), SUCCESS("0", "操作成功"),
FAIL("00001", "操作失败"), FAIL("-1", "操作失败"),
/** /**

@ -20,7 +20,7 @@ public final class BasicResultVO<T> {
/** /**
* *
*/ */
private String code; private String status;
/** /**
* *
@ -41,7 +41,7 @@ public final class BasicResultVO<T> {
} }
public BasicResultVO(RespStatusEnum status, String msg, T data) { public BasicResultVO(RespStatusEnum status, String msg, T data) {
this.code = status.getCode(); this.status = status.getCode();
this.msg = msg; this.msg = msg;
this.data = data; this.data = data;
} }

@ -40,7 +40,7 @@ public class SendServiceImpl implements SendService {
ProcessContext process = processController.process(context); ProcessContext process = processController.process(context);
return new SendResponse(process.getResponse().getCode(), process.getResponse().getMsg()); return new SendResponse(process.getResponse().getStatus(), process.getResponse().getMsg());
} }
@Override @Override
@ -59,7 +59,7 @@ public class SendServiceImpl implements SendService {
ProcessContext process = processController.process(context); ProcessContext process = processController.process(context);
return new SendResponse(process.getResponse().getCode(), process.getResponse().getMsg()); return new SendResponse(process.getResponse().getStatus(), process.getResponse().getMsg());
} }

@ -1,78 +1,48 @@
package com.java3y.austin.controller; package com.java3y.austin.controller;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import com.java3y.austin.dao.MessageTemplateDao; import com.java3y.austin.dao.MessageTemplateDao;
import com.java3y.austin.domain.MessageTemplate; import com.java3y.austin.domain.MessageTemplate;
import com.java3y.austin.vo.BasicResultVO;
import com.java3y.austin.vo.MessageTemplateVo;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/** /**
* MessageTemplateController * Controller
*
* @author 3y * @author 3y
*/ */
@RestController @RestController
@RequestMapping("/Message") @RequestMapping("/messageTemplate")
@Api("发送消息") @Api("发送消息")
@CrossOrigin(origins = "http://localhost:3000", allowCredentials = "true")
public class MessageTemplateController { public class MessageTemplateController {
@Autowired @Autowired
private MessageTemplateDao messageTemplateDao; private MessageTemplateDao messageTemplateDao;
/** /**
* test insert * Id
* Id
*/ */
@GetMapping("/insert") @PostMapping("/save")
@ApiOperation("/插入数据") @ApiOperation("/插入数据")
public String insert() { public BasicResultVO saveOrUpdate(@RequestBody MessageTemplate messageTemplate) {
MessageTemplate messageTemplate = MessageTemplate.builder()
.name("test邮件")
.auditStatus(10)
.flowId("yyyy")
.msgStatus(10)
.idType(50)
.sendChannel(40)
.templateType(20)
.msgType(10)
.expectPushTime("0")
.msgContent("{\"content\":\"{$contentValue}\",\"title\":\"{$title}\"}")
.sendAccount(66)
.creator("yyyyc")
.updator("yyyyu")
.team("yyyt")
.proposer("yyyy22")
.auditor("yyyyyyz")
.isDeleted(0)
.created(Math.toIntExact(DateUtil.currentSeconds()))
.updated(Math.toIntExact(DateUtil.currentSeconds()))
.deduplicationTime(1)
.isNightShield(0)
.build();
MessageTemplate info = messageTemplateDao.save(messageTemplate); MessageTemplate info = messageTemplateDao.save(messageTemplate);
return BasicResultVO.success(info);
return JSON.toJSONString(info);
} }
/** /**
* test query *
*/ */
@GetMapping("/query") @GetMapping("/query")
@ApiOperation("/查找数据") @ApiOperation("/查找数据")
public String query() { public BasicResultVO queryList() {
Iterable<MessageTemplate> all = messageTemplateDao.findAll(); Iterable<MessageTemplate> all = messageTemplateDao.findAll();
for (MessageTemplate messageTemplate : all) { long count = messageTemplateDao.count();
return JSON.toJSONString(messageTemplate); MessageTemplateVo messageTemplateVo = MessageTemplateVo.builder().count(count).rows(all).build();
} return BasicResultVO.success(messageTemplateVo);
return null;
} }
} }

@ -0,0 +1,30 @@
package com.java3y.austin.vo;
import com.java3y.austin.domain.MessageTemplate;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* Vo
*
* @author 3y
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class MessageTemplateVo {
/**
*
*/
private Iterable<MessageTemplate> rows;
/**
*
*/
private Long count;
}
Loading…
Cancel
Save