TransactionLogApi.java
5.41 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package com.java110.common.api;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.bmo.transactionLog.IDeleteTransactionLogBMO;
import com.java110.common.bmo.transactionLog.IGetTransactionLogBMO;
import com.java110.common.bmo.transactionLog.ISaveTransactionLogBMO;
import com.java110.common.bmo.transactionLog.IUpdateTransactionLogBMO;
import com.java110.common.bmo.transactionLogMessage.IGetTransactionLogMessageBMO;
import com.java110.dto.log.TransactionLogDto;
import com.java110.dto.log.TransactionLogMessageDto;
import com.java110.po.log.TransactionLogPo;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping(value = "/transactionLog")
public class TransactionLogApi {
@Autowired
private ISaveTransactionLogBMO saveTransactionLogBMOImpl;
@Autowired
private IUpdateTransactionLogBMO updateTransactionLogBMOImpl;
@Autowired
private IDeleteTransactionLogBMO deleteTransactionLogBMOImpl;
@Autowired
private IGetTransactionLogBMO getTransactionLogBMOImpl;
@Autowired
private IGetTransactionLogMessageBMO getTransactionLogMessageBMOImpl;
/**
* 微信保存消息模板
*
* @param reqJson
* @return
* @serviceCode /transactionLog/saveTransactionLog
* @path /app/transactionLog/saveTransactionLog
*/
@RequestMapping(value = "/saveTransactionLog", method = RequestMethod.POST)
public ResponseEntity<String> saveTransactionLog(@RequestBody JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "serviceCode", "请求报文中未包含serviceCode");
TransactionLogPo transactionLogPo = BeanConvertUtil.covertBean(reqJson, TransactionLogPo.class);
return saveTransactionLogBMOImpl.save(transactionLogPo);
}
/**
* 微信修改消息模板
*
* @param reqJson
* @return
* @serviceCode /transactionLog/updateTransactionLog
* @path /app/transactionLog/updateTransactionLog
*/
@RequestMapping(value = "/updateTransactionLog", method = RequestMethod.POST)
public ResponseEntity<String> updateTransactionLog(@RequestBody JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "serviceCode", "请求报文中未包含serviceCode");
Assert.hasKeyAndValue(reqJson, "logId", "logId不能为空");
TransactionLogPo transactionLogPo = BeanConvertUtil.covertBean(reqJson, TransactionLogPo.class);
return updateTransactionLogBMOImpl.update(transactionLogPo);
}
/**
* 微信删除消息模板
*
* @param reqJson
* @return
* @serviceCode /transactionLog/deleteTransactionLog
* @path /app/transactionLog/deleteTransactionLog
*/
@RequestMapping(value = "/deleteTransactionLog", method = RequestMethod.POST)
public ResponseEntity<String> deleteTransactionLog(@RequestBody JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "communityId", "项目ID不能为空");
Assert.hasKeyAndValue(reqJson, "logId", "logId不能为空");
TransactionLogPo transactionLogPo = BeanConvertUtil.covertBean(reqJson, TransactionLogPo.class);
return deleteTransactionLogBMOImpl.delete(transactionLogPo);
}
/**
* 微信删除消息模板
*
* @param serviceCode 服务编码
* @return
* @serviceCode /transactionLog/queryTransactionLog
* @path /app/transactionLog/queryTransactionLog
*/
@RequestMapping(value = "/queryTransactionLog", method = RequestMethod.GET)
public ResponseEntity<String> queryTransactionLog(@RequestParam(value = "serviceCode", required = false) String serviceCode,
@RequestParam(value = "appId", required = false) String appId,
@RequestParam(value = "transactionId", required = false) String transactionId,
@RequestParam(value = "page") int page,
@RequestParam(value = "row") int row) {
TransactionLogDto transactionLogDto = new TransactionLogDto();
transactionLogDto.setPage(page);
transactionLogDto.setRow(row);
transactionLogDto.setServiceCode(serviceCode);
transactionLogDto.setAppId(appId);
transactionLogDto.setTransactionId(transactionId);
return getTransactionLogBMOImpl.get(transactionLogDto);
}
/**
* 微信删除消息模板
*
* @param logId 日志ID
* @return
* @serviceCode /transactionLog/queryTransactionLogMessage
* @path /app/transactionLog/queryTransactionLogMessage
*/
@RequestMapping(value = "/queryTransactionLogMessage", method = RequestMethod.GET)
public ResponseEntity<String> queryTransactionLogMessage(@RequestParam(value = "logId") String logId) {
TransactionLogMessageDto transactionLogMessageDto = new TransactionLogMessageDto();
transactionLogMessageDto.setLogId(logId);
return getTransactionLogMessageBMOImpl.get(transactionLogMessageDto);
}
}