backend_code/src/main/java/com/template/services/impl/SmartFaceDiscernServiceImpl.java

package com.template.services.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.template.common.utils.*;
import com.template.config.ScheduleConfig;
import com.template.model.pojo.SmartFaceDiscern;
import com.template.mapper.SmartFaceDiscernMapper;
import com.template.model.pojo.SmartNotification;
import com.template.model.pojo.SmartUser;
import com.template.services.SmartFaceDiscernService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.template.services.SmartNotificationService;
import com.template.services.SmartUserService;
import com.tencentcloudapi.lighthouse.v20200324.models.TotalPrice;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

import static com.template.common.utils.AesTestOne.decrypt;

/**
 * <p>
 * 服务实现类
 * </p>
 *
 * @author ceshi
 * @since 2024-01-18
 */
@Service
public class SmartFaceDiscernServiceImpl extends ServiceImpl<SmartFaceDiscernMapper, SmartFaceDiscern> implements SmartFaceDiscernService {
    @Autowired
    SmartUserService smartUserService;

    @Autowired
    SmartNotificationService smartNotificationService;

    @Resource
    private ScheduleConfig scheduleConfig;


    //    static String appid = "sc5efc60f2bd373df9";
    static String appid = "sc1eb792c1ea3237e9";
    //    static String appSecret = "fe0d767a2a394d1b81ccda6fc0ce5ecc";
    static String appSecret = "61afd794ed3244e995c5e894e5788193";
    //    static String schoolCode = "SL1701743624375793";
    static String schoolCode = "SL1704880825203963";

    private Integer page = 1;
    private Integer size = 50;

//    @Scheduled(cron = "0 0/50 * * * ? ")
    @Async
    @Scheduled(cron = "0 0 0/1 * * ? ")
    public void baiS() {
        if(scheduleConfig.getIsOpen().equals("1")){
            try {
                getFaceDiscern(page, size);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }


    }


    public void getFaceDiscern(Integer pageindex, Integer pagesize) throws Exception {
//        String url = "http://schoolopenapi.szymzh.com/openapi/record/searchrecord";
        String url = "https://schoolopenapi.ymiot.net/openapi/record/searchrecord";

        JSONObject jsonObject = new JSONObject();
        jsonObject.put("appid", appid);
        String timestamp = TimeExchange.DateNowTimeStamo();
        jsonObject.put("timestamp", timestamp);
        jsonObject.put("schoolno", schoolCode);
        JSONObject data = new JSONObject();
        data.put("pageindex", pageindex + "");
        data.put("pagesize", pagesize + "");

//        时间
        DateTimeFormatter dateTimeFormatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
//        LocalDateTime now = LocalDateTime.now();
//        LocalDateTime stateTime = now.withHour(0).withMinute(0).withSecond(0);
//        LocalDateTime endTime = now.withHour(23).withMinute(59).withSecond(59);
        LocalDateTime endTime = LocalDateTime.now().withMinute(0).withSecond(0);
        LocalDateTime stateTime = endTime.minusHours(1);


//        开始时间
        data.put("record_begintime", stateTime.format(dateTimeFormatter1));
//        data.put("record_begintime", "2024-01-22 00:00:00");
//        结束时间
        data.put("record_endtime", endTime.format(dateTimeFormatter1));
//        data.put("record_endtime", "2024-01-22 23:59:59");

        String dataString = data.toJSONString();

//        加密
        String aesStr = URLEncoder.encode(AesTestOne.encrypt(dataString, appSecret), "UTF-8");

        jsonObject.put("data", aesStr);

        String stringA = "appid=" + appid + "&data=" + dataString + "&schoolno=" + schoolCode + "&timestamp=" + timestamp + "&key=" + appSecret;

        String sign = CommonUtil.MD5(stringA);

        jsonObject.put("sign", sign);

        String s = RequestUtils.httpPost(url, jsonObject.toJSONString());
        JSONObject jsonObject1 = JSONObject.parseObject(s);
        String data1 = jsonObject1.getString("data");
        // URL解码
        String decodedUrl = URLDecoder.decode(data1, "UTF-8");

        String decrypt = decrypt(decodedUrl, appSecret);
//        logger.info("decrypt = " + decrypt);
        if (ObjectUtils.isNotEmpty(decrypt)&& decrypt!="") {
            JSONObject jsonObject2 = JSONObject.parseObject(decrypt);

            if (ObjectUtils.isNotEmpty(jsonObject2)) {

//            获取总数
                Integer total = Integer.valueOf(jsonObject2.getString("total"));
 //               logger.info("total = " + total);
                Integer totalPage=total/pagesize+ 1;
                if (totalPage>=pageindex) {
                    page = pageindex + 1;
                    save(jsonObject2);
                    getFaceDiscern(page, size);
                } else {
                    page = 1;
                }

            }

        }
    }

    public void save(JSONObject jsonObject2) throws Exception {
        DateTimeFormatter dateTimeFormatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        JSONArray data2 = jsonObject2.getJSONArray("data");
//              去重
        HashSet<SmartFaceDiscern> smartFaceDiscerns = new HashSet<>();
        for (int i = 0; i < data2.size(); i++) {
            JSONObject jsonObject3 = data2.getJSONObject(i);
            SmartFaceDiscern smartFaceDiscern = new SmartFaceDiscern();

//                事件
            String deviceName = jsonObject3.getString("device_name");
            smartFaceDiscern.setType(deviceName);

//                地点
            String deviceArea = jsonObject3.getString("device_area");
            smartFaceDiscern.setLocation(deviceArea);

//                图片
            String recordPhoto = jsonObject3.getString("record_photo");
            smartFaceDiscern.setImage(recordPhoto);

//                时间
            String recordAddtime = jsonObject3.getString("record_addtime");
            smartFaceDiscern.setDateTime(recordAddtime);

//                名字
            String student_name = jsonObject3.getString("student_name");
            smartFaceDiscern.setName(student_name);
//                 学号
            String student_number = jsonObject3.getString("student_number");
//                编号
            String student_no = jsonObject3.getString("student_no");


            LambdaQueryWrapper<SmartUser> wrapper = new LambdaQueryWrapper<>();
            wrapper.eq(SmartUser::getBsStudentNo, student_no);
            wrapper.eq(SmartUser::getName, student_name);
            SmartUser smartUser = smartUserService.getOne(wrapper);

            if (ObjectUtils.isNotEmpty(smartUser)) {
                smartFaceDiscern.setUserId(smartUser.getId());
            } else {
                smartFaceDiscern.setUserId(0);
            }

            smartFaceDiscerns.add(smartFaceDiscern);
        }

        for (SmartFaceDiscern smartFaceDiscern : smartFaceDiscerns) {
            Integer userId = smartFaceDiscern.getUserId();
            String deviceName = smartFaceDiscern.getType();
            String deviceArea = smartFaceDiscern.getLocation();
            String recordPhoto = smartFaceDiscern.getImage();
            String recordAddtime = smartFaceDiscern.getDateTime();
            String student_name = smartFaceDiscern.getName();
            if (userId != 0) {
                //                    判断是否已经添加
                LambdaQueryWrapper<SmartFaceDiscern> wrapperFD = new LambdaQueryWrapper<>();
                wrapperFD.eq(SmartFaceDiscern::getDateTime, smartFaceDiscern.getDateTime())
                        .eq(SmartFaceDiscern::getUserId, userId);
                List<SmartFaceDiscern> list = this.list(wrapperFD);

                if (ObjectUtils.isEmpty(list) && list.size() == 0) {
                    this.save(smartFaceDiscern);


//                        通过学生id找到关联的家长affiliate,并找到公众号,如果openid为空则不传
                    List<SmartUser> userList = smartUserService.getAffiliateList(userId);
                    if (ObjectUtils.isNotEmpty(userList) && userList.size() > 0) {
                        SmartUser smartUser = smartUserService.getById(userId);

                        for (SmartUser user : userList) {
                            String gzhOpenId = user.getGzhOpenId();
                            if (ObjectUtils.isNotEmpty(gzhOpenId)) {
                                String pushType = "";
                                if (deviceName.contains("进校")) {
                                    pushType = "进入大门";
                                } else if (deviceName.contains("出校")) {
                                    pushType = "离开大门";
                                }

                                //                        时间格式是 yyyy-MM-dd HH:mm:ss，当前时间格式有问题

                                LocalDateTime date = LocalDateTime.now();
                                String format = date.format(dateTimeFormatter1);

                                //                    公众号信息推送
                                Message2.send(gzhOpenId, pushType, deviceArea, format);

                                SmartNotification smartNotification = new SmartNotification();
                                smartNotification.setUserId(smartUser.getId());
                                smartNotification.setUserName(smartUser.getName());
                                smartNotification.setTypeName(pushType);
                                smartNotification.setLocation(deviceArea);
                                smartNotification.setImage(recordPhoto);
                                smartNotification.setDateTime(recordAddtime);
                                smartNotification.setType(2);

                                smartNotificationService.save(smartNotification);

                            }

                        }

                    }

                }

            } else {

                smartFaceDiscern.setUserId(0);

//                    判断是否已经添加
                LambdaQueryWrapper<SmartFaceDiscern> wrapperFD = new LambdaQueryWrapper<>();
                wrapperFD.eq(SmartFaceDiscern::getDateTime, recordAddtime)
                        .eq(SmartFaceDiscern::getName, student_name)
                        .eq(SmartFaceDiscern::getType, deviceName);
                List<SmartFaceDiscern> list = this.list(wrapperFD);

                if (ObjectUtils.isEmpty(list) && list.size() == 0) {
                    this.save(smartFaceDiscern);
                }

            }
        }
    }


    @Override
    public List<SmartFaceDiscern> track(String stateTime, String endTime, Integer id) {

        LambdaQueryWrapper<SmartFaceDiscern> wrapper = new LambdaQueryWrapper<>();
        wrapper.between(SmartFaceDiscern::getDateTime, stateTime, endTime)
                .eq(SmartFaceDiscern::getUserId, id)
                .orderByDesc(SmartFaceDiscern::getDateTime);

        List<SmartFaceDiscern> list = this.list(wrapper);

        return list;
    }
}