szwlServer/src/main/java/com/szwl/controller/AlarmRecordIndexController.java

package com.szwl.controller;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.szwl.model.dto.AlarmRecordVo;
import com.szwl.model.entity.TAdmin;
import com.szwl.model.entity.TAlarmRecord;
import com.szwl.model.entity.TEquipment;
import com.szwl.model.utils.MailUtil;
import com.szwl.model.utils.YunPianSms;
import com.szwl.service.TAdminService;
import com.szwl.service.TAlarmRecordService;
import com.szwl.service.TEquipmentService;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Controller("appAlarmRecordController")
@RequestMapping("/api/app_alarmRecord/alarmRecodeIndex")
public class AlarmRecordIndexController {

    @Autowired
    private TAlarmRecordService alarmRecordService;

    @Autowired
    private TEquipmentService equipmentService;

    @Autowired
    private TAdminService adminService;

    private static final String appid = "07784f5fedb508046c841b391005b7de";
    /**
     * 添加报警记录
     */
    @RequestMapping(value = "/addAlarmRecord.htm", method = RequestMethod.POST, produces = "text/html;charset=utf-8")
    @ResponseBody
    public String addAlarmRecord(@RequestBody AlarmRecordVo alarmRecordVo) {


        TAlarmRecord alarmRecord = new TAlarmRecord();

        String clientId = alarmRecordVo.getClientId();
        LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
        query.eq(TEquipment::getClientId,clientId);
        List<TEquipment> list = equipmentService.list(query);
        TEquipment equipment = list.get(0);
        if (equipment == null) {
            return "添加报警记录失败";
        }
        Integer type = equipment.getType();
        Long adminId = equipment.getAdminId();
        Long equipmentId = equipment.getId();
        String name = equipment.getName();
        String adminUserName = equipment.getAdminUserName();
        alarmRecord.setEquipmentId(equipmentId);
        alarmRecord.setName(name);
        alarmRecord.setAdminLevel(equipment.getAdminLevel());
        alarmRecord.setClientId(clientId);
        alarmRecord.setType(type);
        alarmRecord.setAdminId(adminId);
        alarmRecord.setCreateDate(new Date());
        alarmRecord.setModifyDate(new Date());
        alarmRecord.setAdminUserName(adminUserName);
        String alarmContent = alarmRecordVo.getAlarmContent();
        alarmRecord.setAlarmContent(alarmContent);
        alarmRecord.setRemark(alarmRecordVo.getRemark());
        alarmRecord.setOccurrenceTime(alarmRecordVo.getOccurrenceTime());
        alarmRecord.setIsEliminate(0);
        alarmRecordService.save(alarmRecord);
        TAdmin admin = adminService.getById(adminId);
        String email = admin.getEmail();
        String ifForeign = admin.getIfForeign();
        String companyType = admin.getCompanyType();
        String messageReceiver = equipment.getMessageReceiver();
        if(ifForeign.equals("1")){
            String subject = "Error message from Magic Candy Machine";
            StringBuffer contnet = new StringBuffer();
            String str1="Dear customer<br>" +
                    "<br>" +
                    "This is an automatic-sent mail to inform you that there is an error occurred on one of your Magic Candy machines, please kindly check the detail as below.<br>" +
                    "<br>" +
                    " Machine name:";
            String str2="<br>" +" Time&Date:";
            String str3="<br>"+" Error Message:";
            String str4= "<br>" +" <br>You don't have to reply this mail . What you need to do is to follow the instructions on the touch screen to clear the error and recover the machine. If there is any question or more information you need . Please do not be hesitated to contact your distributor.<br>" +
                    "<br>" +
                    " Thank you for choosing our machine!<br>" +
                    "<br>" +
                    "<br>" +
                    "Best Regards.<br>" +
                    "Magic Candy Service Team";
            contnet.append(str1).append(name).append(str2).append(alarmRecordVo.getOccurrenceTime()).append(str3).append(alarmContent).append(str4);
            if(StringUtils.isNotEmpty(messageReceiver)) {
                String[] split = messageReceiver.split(",");
                for (String s : split) {
                    new MailUtil().send(s,subject,contnet.toString());
                }
                return "报警记录添加成功";
            } else {
                if(email!=null){
                    new MailUtil().send(email,subject,contnet.toString());
                    return "报警记录添加成功";
                }else {
                    return "email is null";
                }
            }
        }
        String result = null;
        try {
            if (!"二次曲棍".equals(alarmContent)) {
                if (StringUtils.isNotEmpty(messageReceiver)) {
                    String[] split = messageReceiver.split(",");
                    for (int i = 0; i < split.length; i++) {
                        if (StringUtils.isNotEmpty(split[i])) {
//                            Long id = alarmRecord.getId();
//                            String mess = ";序号："+String.valueOf(id);
                            if (StringUtils.isNotEmpty(companyType) && companyType.equals("1")) {
                                // 如果是七云科技的用户
                                result = YunPianSms.sendSms(appid, getSCMessage(alarmContent, name, clientId.substring(clientId.length() - 6)), split[i]);
                            } else {
                                // 如果是申泽智能的用户
                                result = YunPianSms.sendSms(appid, getMessage(alarmContent, name, clientId.substring(clientId.length() - 6)), split[i]);
                            }
                        }
                    }
                }
            }

        } catch (Exception e) {
        }
        return "报警记录添加成功";
    }

    private String getMessage(String content, String name, String clientId) {
        String message = "【申泽智能】您好,机器" + content + ",机器名:" + name + ",设备号:" + clientId;
        return message;
    }

    private String getSCMessage(String content, String name, String clientId) {
        String message = "【七云科技】您好，机器报警：" + content + "，机器名：" + name + "，设备编号：" + clientId + "。";
        return message;
    }

    /**
     * 获取系统时间
     */
    @RequestMapping(value = "/getTime", method = RequestMethod.GET, produces = "text/html;charset=utf-8")
    @ResponseBody
    public String getTime() {
        Date date = new Date();
        SimpleDateFormat sformat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//日期格式
        return sformat.format(date);
    }

    /**
     * 机器将要到期
     *
     * @param clientId
     * @return
     */
    @GetMapping(value = "/alarmDate", produces = "text/html;charset=utf-8")
    @ResponseBody
    public String endDate(String clientId){
        LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
        query.eq(TEquipment::getClientId,clientId);
        List<TEquipment> list = equipmentService.list(query);
        TEquipment equipment = list.get(0);
        Date endDate = equipment.getEndDate();
        long endDateTime = endDate.getTime();
        long time = System.currentTimeMillis();
        if(endDateTime>time){
            if(endDateTime-time<=3*24*3600*1000L){
                //发短信
                String result = null;
                try {
                    String messageReceiver = equipment.getMessageReceiver();
                    if (StringUtils.isNotEmpty(messageReceiver)) {
                        String[] split = messageReceiver.split(",");
                        for (int i = 0; i < split.length; i++) {
                            if (StringUtils.isNotEmpty(split[i])) {
                                result = YunPianSms.sendSms(appid, getMessage("使用时间即将到期", equipment.getName(), clientId), split[i]);
                            }
                        }
                    }
                } catch (Exception e) {
//                    logger.info("短信发送结果:" + result);
                }
            }
        }else{
//            return JsonMessage.success("已过期");
            return "已过期";
        }

//        return JsonMessage.success("success");
        return "success";
    }

    /**
     * 更改报警状态  消除
     *
     * @param
     * @return
     */
    @GetMapping(value = "/eliminate.htm", produces = "text/html;charset=utf-8")
    @ResponseBody
    public String eliminate(String id){
        TAlarmRecord alarmRecord = alarmRecordService.getById(Long.valueOf(id));
        alarmRecord.setIsEliminate(1);
        alarmRecordService.updateById(alarmRecord);
//        return JsonMessage.success("success");
        return "success";
    }
}