2.7.18

shikeyin

2024-01-11 65da8373531677b1c37a98f53eaa30c892f35e5a

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
130
131
132
133
package com.iplatform.base.controller;
 
import com.iplatform.base.Constants;
import com.iplatform.base.NotifyConstants;
import com.iplatform.base.SystemController;
import com.iplatform.base.pojo.notify.InfoParam;
import com.iplatform.base.pojo.notify.NotificationParam;
import com.iplatform.base.service.NotificationServiceImpl;
import com.iplatform.base.util.NotificationUtils;
import com.iplatform.model.po.SfNotification;
import com.iplatform.model.po.SfTemplateMessage;
import com.iplatform.model.vo.NotificationConfigVo;
import com.walker.web.ResponseValue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
 
import java.util.List;
 
/**
 * 消息通知管理，该通知仅是针对业务通知分类管理，同时能实现同步微信消息模板。
 * <pre>
 *     1)目前微信公众号消息，依赖该功能中的同步模板记录
 *     2)平台推送消息列表，请在"消息推送记录" 中查询。
 * </pre>
 * @author 时克英
 * @date 2023-08-24
 */
@RestController
@RequestMapping("/platform/system/notification")
public class NotificationController extends SystemController {
 
    private NotificationServiceImpl notificationService;
 
    @Autowired
    public NotificationController(NotificationServiceImpl notificationService){
        this.notificationService = notificationService;
    }
 
    @RequestMapping(value = "/sms/switch", method = RequestMethod.POST)
    public ResponseValue smsSwitch(Long id){
        SfNotification notification = this.notificationService.get(new SfNotification(id));
        if (notification.getIsSms().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
            return ResponseValue.error("通知没有配置短信");
        }
        if(notification.getIsSms().intValue() == NotifyConstants.SWITCH_OPEN){
            notification.setIsSms(NotifyConstants.SWITCH_COLSE);
        } else {
            notification.setIsSms(NotifyConstants.SWITCH_OPEN);
        }
        this.notificationService.update(notification);
        return ResponseValue.success();
    }
 
    @RequestMapping(value = "/routine/switch", method = RequestMethod.POST)
    public ResponseValue routineSwitch(Long id){
        SfNotification notification = this.notificationService.get(new SfNotification(id));
        if (notification.getIsRoutine().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
            return ResponseValue.error("通知没有配置小程序订阅模板");
        }
        if(notification.getIsRoutine().intValue() == NotifyConstants.SWITCH_OPEN){
            notification.setIsRoutine(NotifyConstants.SWITCH_COLSE);
        } else {
            notification.setIsRoutine(NotifyConstants.SWITCH_OPEN);
        }
        this.notificationService.update(notification);
        return ResponseValue.success();
    }
 
    @RequestMapping(value = "/wechat/switch", method = RequestMethod.POST)
    public ResponseValue wechatSwitch(Long id){
        SfNotification notification = this.notificationService.get(new SfNotification(id));
        if (notification.getIsWechat().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
            return ResponseValue.error("通知没有配置公众号模板");
        }
        if(notification.getIsWechat().intValue() == NotifyConstants.SWITCH_OPEN){
            notification.setIsWechat(NotifyConstants.SWITCH_COLSE);
        } else {
            notification.setIsWechat(NotifyConstants.SWITCH_OPEN);
        }
        this.notificationService.update(notification);
        return ResponseValue.success();
    }
 
    @RequestMapping(value = "/detail", method = RequestMethod.GET)
    public ResponseValue detail(InfoParam request){
        if(request == null || request.getId() == null){
            return ResponseValue.error(Constants.ERROR_ARGUMENT);
        }
        long id = request.getId();
        SfNotification notification = this.notificationService.get(new SfNotification(id));
        NotificationConfigVo vo = new NotificationConfigVo();
        SfTemplateMessage templateMessage = null;
 
        if (request.getDetailType().equals(NotifyConstants.DETAIL_TYPE_WECHAT)) {
            if (notification.getIsWechat().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
                return ResponseValue.error("请先配置公众号模板消息");
            }
            templateMessage = this.notificationService.get(new SfTemplateMessage(notification.getWechatId().longValue()));
            vo = NotificationUtils.acquireNotificationConfigVo(templateMessage);
            vo.setStatus(notification.getIsWechat());
 
        } else if(request.getDetailType().equals(NotifyConstants.DETAIL_TYPE_ROUTINE)){
            if (notification.getIsRoutine().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
                return ResponseValue.error("请先配置小程序订阅消息");
            }
            templateMessage = this.notificationService.get(new SfTemplateMessage(notification.getRoutineId().longValue()));
            vo = NotificationUtils.acquireNotificationConfigVo(templateMessage);
            vo.setStatus(notification.getIsRoutine());
 
        } else if(request.getDetailType().equals(NotifyConstants.DETAIL_TYPE_SMS)){
            if (notification.getIsSms().intValue() == NotifyConstants.SWITCH_NOT_EXIST) {
                return ResponseValue.error("请先配置短信模板");
            }
            templateMessage = this.notificationService.get(new SfTemplateMessage(notification.getSmsId().longValue()));
            vo = NotificationUtils.acquireNotificationConfigVo(templateMessage);
            vo.setStatus(notification.getIsSms());
        }
        return ResponseValue.success(vo);
    }
 
    @RequestMapping(value = "/list", method = RequestMethod.GET)
    public ResponseValue list(NotificationParam param){
        List<SfNotification> data = null;
        if(param == null){
            data = this.notificationService.queryList(null);
        } else {
            data = this.notificationService.queryList(param.getSendType());
        }
        return ResponseValue.success(data);
    }
}