无感考勤

陶汉栋
1 parent 3009e2ac
Showing 21 changed files with 564 additions and 102 deletions Show diff stats
cloud/dahua/src/main/java/com/example/dahua/MyTask.java
cloud/dahua/src/main/java/com/example/dahua/Test.java
cloud/dahua/src/main/java/com/example/dahua/control/UserControl.java
cloud/dahua/src/main/java/com/example/dahua/dao/UserDao.java
cloud/dahua/src/main/java/com/example/dahua/service/UserService.java
cloud/dahua/src/main/java/com/example/dahua/service/imp/UserServiceImp.java
cloud/dahua/src/main/java/com/example/dahua/utils/BaiduUtils.java
cloud/dahua/src/main/resources/mapper/usermapper.xml
cloud/haikang/src/main/java/com/sincere/haikang/SchduleTask.java
cloud/haikang/src/main/java/com/sincere/haikang/Test.java
cloud/haikang/src/main/java/com/sincere/haikang/bean/SIngleCardBean.java
cloud/haikangface/src/main/java/com/sincere/haikangface/CMSServer.java
cloud/haikangface/src/main/java/com/sincere/haikangface/QieTuClass.java
cloud/haikangface/src/main/java/com/sincere/haikangface/async/SendUserAsync.java
cloud/haikangface/src/main/java/com/sincere/haikangface/bean/BaiduFaceRecorder.java
cloud/haikangface/src/main/java/com/sincere/haikangface/bean/TeacherBean.java
cloud/haikangface/src/main/java/com/sincere/haikangface/control/UserControl.java
cloud/haikangface/src/main/java/com/sincere/haikangface/dao/UserDao.java
cloud/haikangface/src/main/java/com/sincere/haikangface/mqtt/MqttManager.java
cloud/haikangface/src/main/java/com/sincere/haikangface/utils/AlarmUtils.java
@@ -66,9 +66,9 @@ public class MyTask implements ApplicationRunner {
     public void run(ApplicationArguments args) throws Exception {
 //        121.40.109.21
-        LoginModule.init(disConnect, haveReConnect);   // 打开工程，初始化
+//        LoginModule.init(disConnect, haveReConnect);   // 打开工程，初始化
-        autoRegister();//自注册
+//        autoRegister();//自注册
 //        System.out.println(" sendRecordDao:"+sendRecordDao.getSenSuccess());
     }
@@ -16,8 +16,13 @@ public class Test {
     public static void main(String[] args) {
+        String url = "E:\\wwwhtdocs\\SmartCampus\\face17e5\\School112\\Student\\saa.png";
-        Test test = new Test();
+        url = url.substring(url.indexOf("School")+6,url.indexOf("\\Student"));
+
+        System.out.println("url:"+url);
+
+        /*Test test = new Test();
         File file = new File("C:\\Users\\Administrator\\Documents\\专业.txt");
@@ -37,7 +42,7 @@ public class Test {
             e.printStackTrace();
         } catch (IOException e) {
             e.printStackTrace();
-        }
+        }*/
     }
@@ -62,7 +62,7 @@ public class UserControl {
     @RequestMapping(value = "sendPermission", method = RequestMethod.POST)
     @ApiOperation(value = "设置权限")
     public boolean sendPermission(@RequestBody PermissionBean permissionBean) {
-        return  HttpUtils.sendPermission(permissionBean);
+        return HttpUtils.sendPermission(permissionBean);
     }
     @RequestMapping(value = "imgsSend", method = RequestMethod.GET)
@@ -116,7 +116,29 @@ public class UserControl {
     @ApiOperation("在线活体检测")
     public boolean checkFace(@RequestParam("url") String httpurl) {
-       return BaiduUtils.getBaiduUtils().checkImg(httpurl);
+        boolean check = BaiduUtils.getBaiduUtils().checkImg(httpurl);
+
+        if (check) {
+            File file = new File(httpurl);
+
+            String userCode = file.getName().split("\\.")[0];
+
+            String schoolId = "";
+
+            if (httpurl.contains("Student")) {
+                schoolId = httpurl.substring(httpurl.indexOf("School") + 6, httpurl.indexOf("\\Student"));
+            } else if (httpurl.contains("Teacher")) {
+                schoolId = httpurl.substring(httpurl.indexOf("School") + 6, httpurl.indexOf("\\Teacher"));
+            }
+            System.out.println("choolId:" + schoolId + "userCode:" + userCode);
+            if (!StringUtils.isEmpty(schoolId) && !StringUtils.isEmpty(userCode)) {
+                String userId = userService.getUserId(userCode, schoolId);
+                BaiduUtils.getBaiduUtils().addFace(new File(httpurl), schoolId, userId, userId);
+                FileUtils.getInstance().writeLogs("人脸添加成功:" + userId, "人脸添加成功.txt");
+            }
+        }
+
+        return check;
     }
@@ -133,4 +133,8 @@ public interface UserDao {
     @Select("select * from SZ_V_School_Teacher where user_id = #{userId}")
     List<TeacherBean> getTeaWithUserId(@Param("userId")String userId);
+
+    @Select("select Top(1) user_id from SZ_V_School_Student where studentcode = #{studentcode}")
+    String getStuWithCode(@Param("studentcode") String code);
+
 }
@@ -3,10 +3,7 @@ package com.example.dahua.service;
 import com.example.dahua.bean.AttendanceBean;
 import com.example.dahua.bean.PermissionBean;
 import com.example.dahua.bean.UserInfoBean;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.web.multipart.MultipartFile;
-import java.io.File;
 import java.util.List;
 public interface UserService {
@@ -57,4 +54,7 @@ public interface UserService {
      */
     boolean sendPermission(PermissionBean permissionBean);
+    String getUserId(String code,String schoolId);
+
+
 }
@@ -117,4 +117,23 @@ public class UserServiceImp implements UserService {
         return false;
     }
+    @Override
+    public String getUserId(String code,String schoolId) {
+
+       String userId = "";
+
+
+       userId = userDao.getStuWithCode(code);
+
+       if (StringUtils.isEmpty(userId)){
+
+           TeacherBean teacherBean = userDao.getTeacher(schoolId,code);
+           userId = teacherBean.getUser_id();
+
+       }
+
+        return userId;
+    }
+
+
 }
 package com.example.dahua.utils;
+import com.alibaba.fastjson.JSON;
 import com.example.dahua.async.ImageUtils;
 import com.example.dahua.lib.CompressPic;
 import org.json.JSONArray;
@@ -9,10 +10,7 @@ import javax.imageio.stream.FileImageInputStream;
 import java.io.*;
 import java.net.HttpURLConnection;
 import java.net.URL;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 public class BaiduUtils {
@@ -107,6 +105,21 @@ public class BaiduUtils {
         return true;
     }
+    /**
+     * 注册人脸到百度
+     * @param file
+     */
+    private void addToBaidu(File file) {
+
+        //学籍号或者教职工编号
+        String userCode = file.getName().split("\\.")[0];
+
+
+
+//        BaiduUtils.getBaiduUtils().addFace(file,)
+
+    }
+
     //图片到byte数组
     public byte[] image2byte(String path) {
         byte[] data = null;
@@ -208,4 +221,71 @@ public class BaiduUtils {
         return null;
     }
+
+    //注册人脸
+    public String addFace(File img, String group_id, String user_id, String userInfo) {
+
+        String url = "https://aip.baidubce.com/rest/2.0/face/v3/faceset/user/add";
+
+
+        try {
+            Map<String, Object> map = new HashMap<>();
+            map.put("image", Base64Util.encode(InputStream2ByteArray(img.getAbsolutePath())));
+            map.put("group_id", group_id);
+            map.put("user_id", user_id);
+            map.put("user_info", userInfo);
+//            map.put("liveness_control", "NORMAL");
+            map.put("image_type", "BASE64");
+            map.put("quality_control", "NORMAL");
+
+            String param = GsonUtils.toJson(map);
+
+            // 注意这里仅为了简化编码每一次请求都去获取access_token，线上环境access_token有过期时间， 客户端可自行缓存，过期后重新获取。
+
+            String result = HttpUtil.post(url, getAuth(), "application/json", param);
+            System.out.println(result);
+            com.alibaba.fastjson.JSONObject jsonObject = JSON.parseObject(result);
+            String error_msg = jsonObject.getString("error_msg");
+            if (error_msg.equals("SUCCESS")) {
+
+//                com.alibaba.fastjson.JSONObject faceResult = jsonObject.getJSONObject("result");
+
+//                FacerecordBean facerecordBean = new FacerecordBean();
+//
+//                facerecordBean.setFace_token(faceResult.getString("face_token"));
+//                facerecordBean.setGroup_id(group_id);
+//                facerecordBean.setIntime(simpleDateFormat.format(new Date()));
+//                facerecordBean.setUser_id(user_id);
+//
+//                facerecordService.addFacerecord(facerecordBean);
+                return "注册成功";
+            } else {
+                return error_msg;
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    private byte[] InputStream2ByteArray(String filePath) throws IOException {
+
+        InputStream in = new FileInputStream(filePath);
+        byte[] data = toByteArray(in);
+        in.close();
+
+        return data;
+    }
+
+    private byte[] toByteArray(InputStream in) throws IOException {
+
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        byte[] buffer = new byte[1024 * 4];
+        int n = 0;
+        while ((n = in.read(buffer)) != -1) {
+            out.write(buffer, 0, n);
+        }
+        return out.toByteArray();
+    }
 }
@@ -18,5 +18,6 @@
     </select>
-    
+
+
 </mapper>
 \ No newline at end of file
@@ -2,6 +2,7 @@ package com.sincere.haikang;
 import com.sincere.haikang.async.SendUserAsync;
 import com.sincere.haikang.bean.AttendanceBean;
+import com.sincere.haikang.bean.SIngleCardBean;
 import com.sincere.haikang.bean.StudentBean;
 import com.sincere.haikang.dao.DeviceDao;
 import com.sincere.haikang.dao.UserDao;
@@ -22,7 +23,9 @@ import org.springframework.util.StringUtils;
 import org.springframework.web.client.RestTemplate;
 import java.io.*;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 @Component
@@ -129,10 +132,13 @@ public class SchduleTask {
         String clientIds = "";
         for (int i = 0; i < attendanceBeans.size(); i++) {
             if (i < attendanceBeans.size() - 1) {
-                if (attendanceBeans.get(i).getClint_type().equals("22")) {
+                AttendanceBean attendanceBean = attendanceBeans.get(i);
+                System.out.println("attendanceBean:"+attendanceBean.toString());
+                String clint_type = attendanceBean.getClint_type();
+                if (null!=clint_type&&clint_type.equals("22")) {
                     type = 22;
                     clientIds += attendanceBeans.get(i).getClint_id() + ",";
-                } else if (attendanceBeans.get(i).getClint_type().equals("18")) {
+                } else if (null!=clint_type&&clint_type.equals("18")) {
                     type = 18;
                     clientIds += attendanceBeans.get(i).getClint_id();
                 }
@@ -167,13 +173,46 @@ public class SchduleTask {
         int SchoolId = studentBean.getSchoolId();
         String card = TextUtils.isEmpty(studentBean.getCard()) ? studentBean.getOldCard() : studentBean.getCard();
         if (!TextUtils.isEmpty(card)) {
-            RestTemplate restTemplate = new RestTemplate();
-            HttpHeaders headers = new HttpHeaders();
-            headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
-            String url = "http://campus.myjxt.com/api/OneCard/SendSingle?SchoolId=" + SchoolId + "&Card=" + card + "&ClassId=" + studentBean.getClassId();
-            System.out.println("下发卡号url:" + url);
-            ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
-            System.out.println("下发卡号:" + responseEntity.getBody());
+
+          List<AttendanceBean> attendanceBeans =  deviceDao.getAttendancesWithSchoolId(SchoolId);
+
+            for (int i = 0; i < attendanceBeans.size(); i++) {
+
+                AttendanceBean attendanceBean = attendanceBeans.get(i);
+
+                String clint_type = attendanceBean.getClint_type();
+
+                if (null!=clint_type&&clint_type.equals("6")){
+
+                    SIngleCardBean sIngleCardBean = new SIngleCardBean();
+
+                    sIngleCardBean.setCardNo(card);
+                    sIngleCardBean.setEndTime("2050-09-04T00:52:22.510Z");
+                    sIngleCardBean.setId("5");
+                    sIngleCardBean.setShiduan("2");
+                    sIngleCardBean.setSn(attendanceBean.getClint_id());
+                    sIngleCardBean.setStartTime(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'").format(new Date()));
+                    sIngleCardBean.setType("1");
+
+                    RestTemplate restTemplate = new RestTemplate();
+                    HttpHeaders headers = new HttpHeaders();
+                    MediaType mediaType = MediaType.parseMediaType(MediaType.APPLICATION_JSON_UTF8_VALUE);
+                    headers.setContentType(mediaType);
+//                    String url = "http://campus.myjxt.com/api/OneCard/SendSingle?SchoolId=" + SchoolId + "&Card=" + card + "&ClassId=" + studentBean.getClassId();
+//                    System.out.println("下发卡号url:" + url);
+//                    ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
+//                    System.out.println("下发卡号:" + responseEntity.getBody());
+                    System.out.println("sIngleCardBean:"+sIngleCardBean.toString());
+                    String url = "http://121.40.109.21:9000/setSignalCardInfo";
+                    HttpEntity<SIngleCardBean> httpEntity = new HttpEntity<>(sIngleCardBean,headers);
+                   ResponseEntity<String> responseEntity = restTemplate.postForEntity(url,httpEntity,String.class);
+                    System.out.println("下发卡号:" + responseEntity.getBody());
+
+
+                }
+
+            }
+
         }
@@ -0,0 +1,17 @@
+package com.sincere.haikang;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+public class Test {
+    static int i ;
+
+    public static void main(String[] args) {
+
+        int num = 2147483647 ;
+        long temp = num + 2L ;
+        System.out.println(num) ;
+
+    }
+
+}
@@ -0,0 +1,89 @@
+package com.sincere.haikang.bean;
+
+import java.io.Serializable;
+
+public class SIngleCardBean implements Serializable {
+
+    private String cardNo;
+
+    private String endTime;
+
+    private String id;
+
+    private String shiduan;
+
+    private String sn;
+
+    private String startTime;
+
+    private String type;
+
+    public String getCardNo() {
+        return cardNo;
+    }
+
+    public void setCardNo(String cardNo) {
+        this.cardNo = cardNo;
+    }
+
+    public String getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(String endTime) {
+        this.endTime = endTime;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getShiduan() {
+        return shiduan;
+    }
+
+    public void setShiduan(String shiduan) {
+        this.shiduan = shiduan;
+    }
+
+    public String getSn() {
+        return sn;
+    }
+
+    public void setSn(String sn) {
+        this.sn = sn;
+    }
+
+    public String getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(String startTime) {
+        this.startTime = startTime;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    @Override
+    public String toString() {
+        return "SIngleCardBean{" +
+                "cardNo='" + cardNo + '\'' +
+                ", endTime='" + endTime + '\'' +
+                ", id='" + id + '\'' +
+                ", shiduan='" + shiduan + '\'' +
+                ", sn='" + sn + '\'' +
+                ", startTime='" + startTime + '\'' +
+                ", type='" + type + '\'' +
+                '}';
+    }
+}
@@ -57,20 +57,24 @@ public class CMSServer implements ApplicationRunner {
     @Autowired
     UserDao userDao;
-
     @Autowired
     SendRecordDao sendRecordDao;
     //114.55.30.100
     //120.26.116.253
-//    private String ip_cloud = "120.26.116.253";
-//    private String ip_cloud = "192.168.71.242";
-            private String ip_cloud = "114.55.30.100";
+    private String ip_cloud = "120.26.116.253";
+//            private String ip_cloud = "172.16.2.43";
+//    private String ip_cloudQJ = "120.27.221.31";//枪机的图片和报警监听地址
+//    private String ip_cloud = "114.55.30.100";
+//    private String ip_cloud = "120.27.221.31";
+//    private String ip_cloud = "121.40.109.21";
+
     private String ip;
     {
         try {
             ip = InetAddress.getLocalHost().getHostAddress();
+//            ip=ip_cloud;
 //            ip_cloud = ip;
         } catch (UnknownHostException e) {
             e.printStackTrace();
@@ -91,6 +95,15 @@ public class CMSServer implements ApplicationRunner {
         //初始化报警监听
         initAlarm();
+     /*   String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+        BaiduFaceRecorder baiduFaceRecorder = new BaiduFaceRecorder();
+        baiduFaceRecorder.setName("name");
+        baiduFaceRecorder.setScore("11");
+        baiduFaceRecorder.setTime(time);
+        baiduFaceRecorder.setUserImgUrl("22");
+        baiduFaceRecorder.setUploadImgUrl("22");
+        userDao.insertBaiduFaceRecorder(baiduFaceRecorder);*/
+
     }
     static HCEHomeCMS hCEhomeCMS = HCEHomeCMS.INSTANCE;
@@ -112,8 +125,8 @@ public class CMSServer implements ApplicationRunner {
             fRegisterCallBack = new FRegisterCallBack();
         }
         hCEhomeCMS.NET_ECMS_SetLogToFile(3, "C:/Ehomejavademo/EHomeSDKLog", false);
-
         struCMSListenPara.struAddress.szIP = ip.getBytes();
+//        System.out.println("ip--------------------------------------------:"+ip);
         struCMSListenPara.struAddress.wPort = 7660;
         struCMSListenPara.fnCB = fRegisterCallBack;
@@ -182,6 +195,9 @@ public class CMSServer implements ApplicationRunner {
 //                byte[] byIP = ip.getBytes();
                 byte[] byIP = ip_cloud.getBytes();
+
+//                if (deviceId.startsWith("qj")) byIP = ip_cloudQJ.getBytes();
+
                 System.arraycopy(byIP, 0, pInBuffer.struUDPAlarmSever.szIP, 0, byIP.length);
                 // TODO: 2020/8/27 人脸机类型为0
                 pInBuffer.dwAlarmServerType = 0; //报警服务器类型：0- 只支持UDP协议上报，1- 支持UDP、TCP两种协议上报
@@ -302,9 +318,10 @@ public class CMSServer implements ApplicationRunner {
     public class PSS_Storage_Callback implements HCEHomeSS.EHomeSSStorageCallBack {
         public boolean invoke(NativeLong iHandle, String pFileName, Pointer pFileBuf, int dwFileLen, Pointer pFilePath, Pointer pUser) {
-            log.error("图片进来:{}" , pFileName);
+//            log.error("图片进来:{}", pFileName);
             String strPath = "C://EhomePicServer/";
 //            System.out.println("pFileName:" + pFileName);
+            FileUtils.getInstance().writeLogs("文件名:" + pFileName, FileUtils.fileName);
             pFileName = pFileName.replace("_", "");
             boolean isZhuaPai = false;
             if (pFileName.contains("-")) {//人脸抓拍机抓拍到的图片
@@ -315,7 +332,6 @@ public class CMSServer implements ApplicationRunner {
             }
             String strFilePath = strPath + pFileName;
-            FileUtils.getInstance().writeLogs("文件名:" + pFileName, FileUtils.fileName);
             //保存抓拍到的人脸图片，比对通过后的图片资源
 //            System.out.println("文件保存回调函数：" + strFilePath);
@@ -348,6 +364,7 @@ public class CMSServer implements ApplicationRunner {
                     fout.write(bytes);
                     fout.close();
+//                    if (ip_cloud.equals(ip_cloudQJ))
                     sendToKB(strFilePathFile);
                 } catch (FileNotFoundException e) {
@@ -369,6 +386,8 @@ public class CMSServer implements ApplicationRunner {
         }
     }
+    Map<String, Long> userMap = new HashMap<>();
+
     /**
      * 发送人脸到看板
      *
@@ -377,69 +396,109 @@ public class CMSServer implements ApplicationRunner {
     public void sendToKB(File strFilePathFile) {
         try {
-        log.error("开始识别.....");
-        String url = "http://120.26.116.253:9214/baiduapi/search/16";
-
-        RestTemplate restTemplate = new RestTemplate();
-
-        HttpHeaders headers = new HttpHeaders();
-        MediaType mediaType = MediaType.parseMediaType(MediaType.MULTIPART_FORM_DATA_VALUE);
-        headers.setContentType(mediaType);
-        MultiValueMap<String, Object> multiValueMap = new LinkedMultiValueMap<>();
-        FileSystemResource fileSystemResource = new FileSystemResource(strFilePathFile);
-
-        multiValueMap.add("file ", fileSystemResource);
-        HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(multiValueMap, headers);
-
-        ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, httpEntity, String.class);
-            log.error("识别结果:{}" , responseEntity.getBody());
-        JSONObject jsonObject = JSON.parseObject(responseEntity.getBody());
-
-       String face = jsonObject.getString("data");
-       if (face.startsWith("face"))return;
-
-        JSONObject data = jsonObject.getJSONObject("data");
-        String error_msg = data.getString("error_msg");
-
-        if (error_msg.equals("SUCCESS")) {//识别成功
-            JSONObject result = data.getJSONObject("result");
-            JSONArray user_list = result.getJSONArray("user_list");
-
-            if (user_list != null && user_list.size() > 0) {
-
-                for (int i = 0; i < user_list.size(); i++) {
-                    JSONObject user = user_list.getJSONObject(i);
-
-                    String user_id = user.getString("user_id");
-                    String score = user.getString("score");
-                    double sc = Double.valueOf(score.split("\\.")[0]);
-                    if (sc >= 60) {
-                        System.out.println("user_id:" + user_id);
-                        TeacherBean teacherBean = userDao.getTeacherWithUserId1(user_id);
-                        if (null != teacherBean) {
-                            if (TextUtils.isEmpty(teacherBean.getTeacer_num()))teacherBean.setTeacer_num(user_id);
-                            MqtUtils.getInstance().sendMsg("09EA8EB5142F2964", 1, teacherBean.toString());
+            log.error("开始识别.....");
+            String url = "http://120.26.116.253:9214/baiduapi/search/16";
+
+            RestTemplate restTemplate = new RestTemplate();
+
+            HttpHeaders headers = new HttpHeaders();
+            MediaType mediaType = MediaType.parseMediaType(MediaType.MULTIPART_FORM_DATA_VALUE);
+            headers.setContentType(mediaType);
+            MultiValueMap<String, Object> multiValueMap = new LinkedMultiValueMap<>();
+            FileSystemResource fileSystemResource = new FileSystemResource(strFilePathFile);
+
+            multiValueMap.add("file ", fileSystemResource);
+            HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(multiValueMap, headers);
+
+            ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, httpEntity, String.class);
+//            log.error("识别结果:{}", responseEntity.getBody());
+            JSONObject jsonObject = JSON.parseObject(responseEntity.getBody());
+
+            String face = jsonObject.getString("data");
+            if (face.startsWith("face")||face.startsWith("pic")) return;
+
+            JSONObject data = jsonObject.getJSONObject("data");
+            String error_msg = data.getString("error_msg");
+
+            if (error_msg.equals("SUCCESS")) {//识别成功
+                JSONObject result = data.getJSONObject("result");
+                JSONArray user_list = result.getJSONArray("user_list");
+
+                if (user_list != null && user_list.size() > 0) {
+
+                    for (int i = 0; i < user_list.size(); i++) {
+                        JSONObject user = user_list.getJSONObject(i);
+
+                        String user_id = user.getString("user_id");
+                        String score = user.getString("score");
+                        double sc = Double.valueOf(score.split("\\.")[0]);
+                        if (sc >= 60) {
+                            System.out.println("user_id:" + user_id);
+                            TeacherBean teacherBean = userDao.getTeacherWithUserId1(user_id);
+
+                            if (null != teacherBean) {
+                                String date = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
+                                String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+                                BaiduFaceRecorder baiduFaceRecorder = new BaiduFaceRecorder();
+                                baiduFaceRecorder.setName(teacherBean.getName());
+                                baiduFaceRecorder.setScore(sc+"");
+                                baiduFaceRecorder.setTime(time);
+                                baiduFaceRecorder.setUserImgUrl(teacherBean.getFace());
+                                baiduFaceRecorder.setUploadImgUrl(strFilePathFile.getAbsolutePath().contains(date)?
+                                        "http://" + ip_cloud + ":8081/kms/services/rest/dataInfoService/downloadFile?id="+strFilePathFile.getName().substring(0,strFilePathFile.getName().indexOf(date)):strFilePathFile.getAbsolutePath());
+                                baiduFaceRecorder.setUserId(user_id);
+                                userDao.insertBaiduFaceRecorder(baiduFaceRecorder);
+
+                                if (TextUtils.isEmpty(teacherBean.getTeacer_num())) teacherBean.setTeacer_num(user_id);
+                                teacherBean.setTime(time);
+
+                                if (userMap.containsKey(user_id)) {
+
+                                    long value = userMap.get(user_id);
+                                    if ((System.currentTimeMillis() - value) / 1000 > 6) {
+                                        userMap.put(user_id, System.currentTimeMillis());
+                                        MqtUtils.getInstance().sendMsg("09EA8EB5142F2964", 1, teacherBean.toString());
+                                        log.error("发送成功.....");
+                                    }
+
+                                } else {
+                                    userMap.put(user_id, System.currentTimeMillis());
+                                    MqtUtils.getInstance().sendMsg("09EA8EB5142F2964", 1, teacherBean.toString());
+                                    log.error("发送成功.....");
+                                }
+
+//                                strFilePathFile.deleteOnExit();
+                            } else {
+                                System.out.println("用户身份信息不存在");
+                                sendNoPersonImg(strFilePathFile);
+                            }
                         } else {
-                            System.out.println("用户身份信息不存在");
+                            System.out.println("用户身份信息不存在" + score);
+                            sendNoPersonImg(strFilePathFile);
                         }
-                    }else {
-                        System.out.println("用户身份信息不存在"+score);
+
                     }
                 }
-
+            } else {
+                System.out.println("识别失败:" + error_msg);
             }
-        } else {
-            System.out.println("识别失败:" + error_msg);
-        }
-        log.error("发送成功.....");
 //        System.out.println("responseEntity:"+responseEntity.getBody());
-        }catch (Exception e){
+        } catch (Exception e) {
             e.printStackTrace();
         }
     }
+    private void sendNoPersonImg(File strFilePathFile) {
+        String imgName = strFilePathFile.getName();
+        String date = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
+        if (imgName.contains(date)) {
+            String imgId = imgName.substring(0, imgName.indexOf(date));
+            MqtUtils.getInstance().sendMsg("09EA8EB5142F2964", 2, "http://" + ip_cloud + ":8081/kms/services/rest/dataInfoService/downloadFile?id=" + imgId);
+        }
+    }
+
     HCEHomeAlarm.NET_EHOME_ALARM_LISTEN_PARAM net_ehome_alarm_listen_param = new HCEHomeAlarm.NET_EHOME_ALARM_LISTEN_PARAM();
     EHomeMsgCallBack cbEHomeMsgCallBack;
     ;//报警监听回调函数实现
@@ -507,9 +566,9 @@ public class CMSServer implements ApplicationRunner {
                 String strXML = new String(strXMLData.byValue);
 //                System.out.println(strXML);
-//                log.error("报警监听:{}",strXML);
+//                log.error("报警监听:{}", strXML);
                 if (null == alarmUtils) {
-                    alarmUtils = new AlarmUtils(deviceDao);
+                    alarmUtils = new AlarmUtils(deviceDao,userDao);
                     alarmUtils.setCallBack(new AlarmUtils.AlarmCallBack() {
                         @Override
                         public void callBack(String minorType, String deviceID, String cardNo, String time, String picDataUrlId, String currTemperature) {
@@ -563,7 +622,7 @@ public class CMSServer implements ApplicationRunner {
                 cardNo = sendRecoderUtils.getCard(card);
                 StudentBean studentBean = userDao.getStudentWithCard(cardNo);
-                log.error("studentBean:{}",studentBean);
+                log.error("studentBean:{}", studentBean);
                 if (null != studentBean) {
                     FileUtils.getInstance().writeLogs(studentBean.getName() + " " + cardNo, FileUtils.facerecoder);
@@ -589,9 +648,9 @@ public class CMSServer implements ApplicationRunner {
                     isTeacher(cardNo, deviceID);
                 }
-                if (deviceID.startsWith("qj")) {//枪击 用来抓拍人脸考勤用
-                    initQJ(deviceID, cardNo, studentBean == null);
-                }
+//                if (deviceID.startsWith("qj")) {//枪击 用来抓拍人脸考勤用
+//                    initQJ(deviceID, cardNo, studentBean == null);
+//                }
             }
@@ -614,12 +673,12 @@ public class CMSServer implements ApplicationRunner {
     public void isTeacher(String cardNo, String deviceID) {
         List<String> devLists = userDao.getDeviceRoomRelation(deviceID);
-        log.error("cardNo:{},devLists{}",cardNo,devLists);
+        log.error("cardNo:{},devLists{}", cardNo, devLists);
         if (null != devLists && devLists.size() > 0) {
             StudentBean teacher = userDao.getTeacherWithCard(cardNo);
-            FileUtils.getInstance().writeLogs("teacher:" + teacher+"----"+cardNo, "教师点名.txt");
+            FileUtils.getInstance().writeLogs("teacher:" + teacher + "----" + cardNo, "教师点名.txt");
             if (null != teacher) {
                 String url = String.format("http://campus.myjxt.com/api/RollCall/AddRollCallPersonnelRecord?userId=%s&deviceId=%s", teacher.getUser_id(), deviceID);
 package com.sincere.haikangface;
+import com.sincere.haikangface.mqtt.MqtUtils;
 import com.sincere.haikangface.utils.ApiUtil;
 import com.sun.imageio.plugins.common.ImageUtil;
 import org.json.JSONArray;
@@ -11,13 +12,21 @@ import java.awt.image.FilteredImageSource;
 import java.awt.image.ImageFilter;
 import java.io.File;
 import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 public class QieTuClass extends JFrame {
     public static void main(String[] args) {
+        String imgName = "43539917634D4EED364DEC87D8DEC2462020-09-01.jpg";
+        String date = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
+        if (imgName.contains(date)) {
+            String imgId = imgName.substring(0, imgName.indexOf(date));
+            System.out.println("imgId:"+imgId);
+        }
-        new QieTuClass();
+//        new QieTuClass();
     }
@@ -48,6 +48,7 @@ public class SendUserAsync {
         if (check) {//合格
             //根据设备是5603 还是新设备
             String employeeNo = "";
+            boolean result = cmsServer.createImgPath(srcFile, picUrl, card, startTime, endTime, validTimeEnabled, name, deviceId, userType, employeeNo);
             if (deviceId.contains("ymzx") || deviceId.contains("5607") || deviceId.contains("5671") || deviceId.contains("5604")) {
                 long lon = Long.parseLong(card);
                 //十六进制卡号
@@ -67,15 +68,14 @@ public class SendUserAsync {
                     } else
                         employeeNo = studentBean.getStudent_id();
                 }
-//                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardTemplate(), "设置卡权限计划模板");
-//                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardWeekPlan(), "卡权限周计划");
-//                for (int i = 0; i < 7; i++) {
-//                    cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardWeekPlanTime(HKXmlUtils.getInstance().SetCardWeekPlanTimes("00:00:00", "23:00:00"), "" + i), "设置卡权限周计划时间");
-//                }
-//                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardRightCfg(card), "设置卡权限");
+                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardTemplate(), "设置卡权限计划模板");
+                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardWeekPlan(), "卡权限周计划");
+                for (int i = 0; i < 7; i++) {
+                    cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardWeekPlanTime(HKXmlUtils.getInstance().SetCardWeekPlanTimes("00:00:00", "23:00:00"), "" + i), "设置卡权限周计划时间");
+                }
+                cmsServer.SetCardWeekPlan(deviceId, card, userType, HKXmlUtils.getInstance().SetCardRightCfg(card), "设置卡权限");
             }
-            boolean result = cmsServer.createImgPath(srcFile, picUrl, card, startTime, endTime, validTimeEnabled, name, deviceId, userType, employeeNo);
         } else {//不合格
             sendRecoderUtils.sendFail(sendRecordDao, card, srcFile, deviceId, userDao, "人脸照片不合格", userType);
         }
@@ -0,0 +1,78 @@
+package com.sincere.haikangface.bean;
+
+import java.io.Serializable;
+
+public class BaiduFaceRecorder implements Serializable {
+
+   private String name;
+
+   private String userId;
+
+   private String score;
+
+   private String time;
+
+   private String uploadImgUrl;
+
+   private String userImgUrl;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getScore() {
+        return score;
+    }
+
+    public void setScore(String score) {
+        this.score = score;
+    }
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
+    public String getUploadImgUrl() {
+        return uploadImgUrl;
+    }
+
+    public void setUploadImgUrl(String uploadImgUrl) {
+        this.uploadImgUrl = uploadImgUrl;
+    }
+
+    public String getUserImgUrl() {
+        return userImgUrl;
+    }
+
+    public void setUserImgUrl(String userImgUrl) {
+        this.userImgUrl = userImgUrl;
+    }
+
+    @Override
+    public String toString() {
+        return "BaiduFaceRecorder{" +
+                "name='" + name + '\'' +
+                ", userId='" + userId + '\'' +
+                ", score='" + score + '\'' +
+                ", time='" + time + '\'' +
+                ", uploadImgUrl='" + uploadImgUrl + '\'' +
+                ", userImgUrl='" + userImgUrl + '\'' +
+                '}';
+    }
+}
@@ -12,6 +12,16 @@ public class TeacherBean implements Serializable {
     private String face;
+    private String time;
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
     public String getTeacher_num() {
         return teacher_num;
     }
@@ -57,6 +67,7 @@ public class TeacherBean implements Serializable {
         return "{\"name\":\"" + name + '\"' +
                 ", \"teacher_num\":\"" + teacher_num + '\"' +
                 ", \"num\":\"" + num + '\"' +
+                ",\"time\":\""+time+'\"'+
                 ", \"face\":\"" + face + '\"' +"}";
     }
 }
@@ -348,9 +348,8 @@ public class UserControl {
     @RequestMapping(value = "getCard", method = RequestMethod.GET)
     @ApiOperation("获取设备人脸是否存在")
     public boolean getCard(@RequestParam("deviceId") String deviceId, @RequestParam("card") String card) {
-        cmsServer.getFace(deviceId, Long.parseLong(getCard(card), 16) + "");
 //        HttpUtil.getCard(deviceId,card);
-        return true;
+        return cmsServer.getFace(deviceId, Long.parseLong(getCard(card), 16) + "");
     }
     @RequestMapping(value = "IsDeviceOnline", method = RequestMethod.GET)
@@ -248,5 +248,6 @@ public interface UserDao {
     List<String> getDeviceRoomRelation(@Param("clint_id") String clint_id);
+    void insertBaiduFaceRecorder(BaiduFaceRecorder baiduFaceRecorder);
 }
@@ -3,6 +3,7 @@ package com.sincere.haikangface.mqtt;
 import org.eclipse.paho.client.mqttv3.*;
 import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+import java.io.UnsupportedEncodingException;
 import java.security.InvalidKeyException;
 import java.security.NoSuchAlgorithmException;
@@ -112,7 +113,12 @@ public class MqttManager {
         String recvClientId = groupId + "@@@" + deviceId;
         final String p2pSendTopic = topic + "/p2p/" + recvClientId;
         String content = "{\"cmd\":\"" + cmd + "\",\"clientId\":\"\",\"data\": " + msg + "}";
-        MqttMessage message = new MqttMessage(content.getBytes());
+        MqttMessage message = null;
+        try {
+            message = new MqttMessage(content.getBytes("GB2312"));
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
         message.setQos(qosLevel);
         System.out.println("发送内容:" + p2pSendTopic + " msg:---------" + msg);
         if (null != mqttClient) {
 package com.sincere.haikangface.utils;
+import com.sincere.haikangface.bean.BaiduFaceRecorder;
 import com.sincere.haikangface.bean.FaceWaterRecoder;
 import com.sincere.haikangface.dao.DeviceDao;
+import com.sincere.haikangface.dao.UserDao;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
@@ -17,6 +19,8 @@ public class AlarmUtils {
     private DeviceDao deviceDao;
+    private UserDao userDao;
+
     private AlarmCallBack alarmCallBack;
 //    public static AlarmUtils getInstance(DeviceDao deviceDao) {
@@ -28,8 +32,9 @@ public class AlarmUtils {
 //        return alarmUtils;
 //    }
-    public AlarmUtils(DeviceDao deviceDao) {
+    public AlarmUtils(DeviceDao deviceDao, UserDao userDao) {
         this.deviceDao = deviceDao;
+        this.userDao = userDao;
     }
     public void setCallBack(AlarmCallBack alarmCallBack) {
@@ -41,9 +46,22 @@ public class AlarmUtils {
     }
     public void deleAlarm(String strXML) {
-
+        System.out.println("人脸抓拍机:" + strXML);
         if (strXML.contains("FACESNAPREPORT")) {//人脸抓拍机器
+//            System.out.println("人脸抓拍机:" + strXML);
+            BaiduFaceRecorder baiduFaceRecorder = new BaiduFaceRecorder();
+            baiduFaceRecorder.setUploadImgUrl(strXML);
+            baiduFaceRecorder.setTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+            userDao.insertBaiduFaceRecorder(baiduFaceRecorder);
+
+            String deviceId = strXML.substring(strXML.indexOf("DeviceID"),strXML.lastIndexOf("DeviceID")).trim();
+            deviceId = deviceId.replace("DeviceID>","");
+            deviceId = deviceId.replace("</","");
+
+//            if (null != alarmCallBack)
+//                alarmCallBack.callBack(minorType, deviceID, cardNo, time, picDataUrlId, currTemperature);
+
         } else {//人脸识别
             //主类型
@@ -22,4 +22,9 @@
         select clint_id from SZ_DeviceRoomRelation where clint_id = #{clint_id} and state = 1;
     </select>
+    <insert id="insertBaiduFaceRecorder" parameterType="com.sincere.haikangface.bean.BaiduFaceRecorder">
+
+        insert into BaiduFaceRecorder values (#{name},#{userId},#{score},#{time},#{uploadImgUrl},#{userImgUrl})
+
+    </insert>
 </mapper>
	@@ -66,9 +66,9 @@ public class MyTask implements ApplicationRunner {		@@ -66,9 +66,9 @@ public class MyTask implements ApplicationRunner {
66	public void run(ApplicationArguments args) throws Exception {	66	public void run(ApplicationArguments args) throws Exception {
67	// 121.40.109.21	67	// 121.40.109.21
68		68
69	- LoginModule.init(disConnect, haveReConnect); // 打开工程，初始化	69	+// LoginModule.init(disConnect, haveReConnect); // 打开工程，初始化
70		70
71	- autoRegister();//自注册	71	+// autoRegister();//自注册
72		72
73	// System.out.println(" sendRecordDao:"+sendRecordDao.getSenSuccess());	73	// System.out.println(" sendRecordDao:"+sendRecordDao.getSenSuccess());
74	}	74	}
	@@ -62,7 +62,7 @@ public class UserControl {		@@ -62,7 +62,7 @@ public class UserControl {
62	@RequestMapping(value = "sendPermission", method = RequestMethod.POST)	62	@RequestMapping(value = "sendPermission", method = RequestMethod.POST)
63	@ApiOperation(value = "设置权限")	63	@ApiOperation(value = "设置权限")
64	public boolean sendPermission(@RequestBody PermissionBean permissionBean) {	64	public boolean sendPermission(@RequestBody PermissionBean permissionBean) {
65	- return HttpUtils.sendPermission(permissionBean);	65	+ return HttpUtils.sendPermission(permissionBean);
66	}	66	}
67		67
68	@RequestMapping(value = "imgsSend", method = RequestMethod.GET)	68	@RequestMapping(value = "imgsSend", method = RequestMethod.GET)
	@@ -116,7 +116,29 @@ public class UserControl {		@@ -116,7 +116,29 @@ public class UserControl {
116	@ApiOperation("在线活体检测")	116	@ApiOperation("在线活体检测")
117	public boolean checkFace(@RequestParam("url") String httpurl) {	117	public boolean checkFace(@RequestParam("url") String httpurl) {
118		118
119	- return BaiduUtils.getBaiduUtils().checkImg(httpurl);	119	+ boolean check = BaiduUtils.getBaiduUtils().checkImg(httpurl);
		120	+
		121	+ if (check) {
		122	+ File file = new File(httpurl);
		123	+
		124	+ String userCode = file.getName().split("\\.")[0];
		125	+
		126	+ String schoolId = "";
		127	+
		128	+ if (httpurl.contains("Student")) {
		129	+ schoolId = httpurl.substring(httpurl.indexOf("School") + 6, httpurl.indexOf("\\Student"));
		130	+ } else if (httpurl.contains("Teacher")) {
		131	+ schoolId = httpurl.substring(httpurl.indexOf("School") + 6, httpurl.indexOf("\\Teacher"));
		132	+ }
		133	+ System.out.println("choolId:" + schoolId + "userCode:" + userCode);
		134	+ if (!StringUtils.isEmpty(schoolId) && !StringUtils.isEmpty(userCode)) {
		135	+ String userId = userService.getUserId(userCode, schoolId);
		136	+ BaiduUtils.getBaiduUtils().addFace(new File(httpurl), schoolId, userId, userId);
		137	+ FileUtils.getInstance().writeLogs("人脸添加成功:" + userId, "人脸添加成功.txt");
		138	+ }
		139	+ }
		140	+
		141	+ return check;
120		142
121	}	143	}
122		144
	@@ -133,4 +133,8 @@ public interface UserDao {		@@ -133,4 +133,8 @@ public interface UserDao {
133		133
134	@Select("select * from SZ_V_School_Teacher where user_id = #{userId}")	134	@Select("select * from SZ_V_School_Teacher where user_id = #{userId}")
135	List<TeacherBean> getTeaWithUserId(@Param("userId")String userId);	135	List<TeacherBean> getTeaWithUserId(@Param("userId")String userId);
		136	+
		137	+ @Select("select Top(1) user_id from SZ_V_School_Student where studentcode = #{studentcode}")
		138	+ String getStuWithCode(@Param("studentcode") String code);
		139	+
136	}	140	}
	@@ -117,4 +117,23 @@ public class UserServiceImp implements UserService {		@@ -117,4 +117,23 @@ public class UserServiceImp implements UserService {
117	return false;	117	return false;
118	}	118	}
119		119
		120	+ @Override
		121	+ public String getUserId(String code,String schoolId) {
		122	+
		123	+ String userId = "";
		124	+
		125	+
		126	+ userId = userDao.getStuWithCode(code);
		127	+
		128	+ if (StringUtils.isEmpty(userId)){
		129	+
		130	+ TeacherBean teacherBean = userDao.getTeacher(schoolId,code);
		131	+ userId = teacherBean.getUser_id();
		132	+
		133	+ }
		134	+
		135	+ return userId;
		136	+ }
		137	+
		138	+
120	}	139	}
1	package com.example.dahua.utils;	1	package com.example.dahua.utils;
2		2
		3	+import com.alibaba.fastjson.JSON;
3	import com.example.dahua.async.ImageUtils;	4	import com.example.dahua.async.ImageUtils;
4	import com.example.dahua.lib.CompressPic;	5	import com.example.dahua.lib.CompressPic;
5	import org.json.JSONArray;	6	import org.json.JSONArray;
	@@ -9,10 +10,7 @@ import javax.imageio.stream.FileImageInputStream;		@@ -9,10 +10,7 @@ import javax.imageio.stream.FileImageInputStream;
9	import java.io.*;	10	import java.io.*;
10	import java.net.HttpURLConnection;	11	import java.net.HttpURLConnection;
11	import java.net.URL;	12	import java.net.URL;
12	-import java.util.ArrayList;
13	-import java.util.HashMap;
14	-import java.util.List;
15	-import java.util.Map;	13	+import java.util.*;
16		14
17	public class BaiduUtils {	15	public class BaiduUtils {
18		16
	@@ -107,6 +105,21 @@ public class BaiduUtils {		@@ -107,6 +105,21 @@ public class BaiduUtils {
107	return true;	105	return true;
108	}	106	}
109		107
		108	+ /**
		109	+ * 注册人脸到百度
		110	+ * @param file
		111	+ */
		112	+ private void addToBaidu(File file) {
		113	+
		114	+ //学籍号或者教职工编号
		115	+ String userCode = file.getName().split("\\.")[0];
		116	+
		117	+
		118	+
		119	+// BaiduUtils.getBaiduUtils().addFace(file,)
		120	+
		121	+ }
		122	+
110	//图片到byte数组	123	//图片到byte数组
111	public byte[] image2byte(String path) {	124	public byte[] image2byte(String path) {
112	byte[] data = null;	125	byte[] data = null;
	@@ -208,4 +221,71 @@ public class BaiduUtils {		@@ -208,4 +221,71 @@ public class BaiduUtils {
208	return null;	221	return null;
209	}	222	}
210		223
		224	+
		225	+ //注册人脸
		226	+ public String addFace(File img, String group_id, String user_id, String userInfo) {
		227	+
		228	+ String url = "https://aip.baidubce.com/rest/2.0/face/v3/faceset/user/add";
		229	+
		230	+
		231	+ try {
		232	+ Map<String, Object> map = new HashMap<>();
		233	+ map.put("image", Base64Util.encode(InputStream2ByteArray(img.getAbsolutePath())));
		234	+ map.put("group_id", group_id);
		235	+ map.put("user_id", user_id);
		236	+ map.put("user_info", userInfo);
		237	+// map.put("liveness_control", "NORMAL");
		238	+ map.put("image_type", "BASE64");
		239	+ map.put("quality_control", "NORMAL");
		240	+
		241	+ String param = GsonUtils.toJson(map);
		242	+
		243	+ // 注意这里仅为了简化编码每一次请求都去获取access_token，线上环境access_token有过期时间，客户端可自行缓存，过期后重新获取。
		244	+
		245	+ String result = HttpUtil.post(url, getAuth(), "application/json", param);
		246	+ System.out.println(result);
		247	+ com.alibaba.fastjson.JSONObject jsonObject = JSON.parseObject(result);
		248	+ String error_msg = jsonObject.getString("error_msg");
		249	+ if (error_msg.equals("SUCCESS")) {
		250	+
		251	+// com.alibaba.fastjson.JSONObject faceResult = jsonObject.getJSONObject("result");
		252	+
		253	+// FacerecordBean facerecordBean = new FacerecordBean();
		254	+//
		255	+// facerecordBean.setFace_token(faceResult.getString("face_token"));
		256	+// facerecordBean.setGroup_id(group_id);
		257	+// facerecordBean.setIntime(simpleDateFormat.format(new Date()));
		258	+// facerecordBean.setUser_id(user_id);
		259	+//
		260	+// facerecordService.addFacerecord(facerecordBean);
		261	+ return "注册成功";
		262	+ } else {
		263	+ return error_msg;
		264	+ }
		265	+
		266	+ } catch (Exception e) {
		267	+ e.printStackTrace();
		268	+ }
		269	+ return "";
		270	+ }
		271	+
		272	+ private byte[] InputStream2ByteArray(String filePath) throws IOException {
		273	+
		274	+ InputStream in = new FileInputStream(filePath);
		275	+ byte[] data = toByteArray(in);
		276	+ in.close();
		277	+
		278	+ return data;
		279	+ }
		280	+
		281	+ private byte[] toByteArray(InputStream in) throws IOException {
		282	+
		283	+ ByteArrayOutputStream out = new ByteArrayOutputStream();
		284	+ byte[] buffer = new byte[1024 * 4];
		285	+ int n = 0;
		286	+ while ((n = in.read(buffer)) != -1) {
		287	+ out.write(buffer, 0, n);
		288	+ }
		289	+ return out.toByteArray();
		290	+ }
211	}	291	}
	@@ -18,5 +18,6 @@		@@ -18,5 +18,6 @@
18		18
19	</select>	19	</select>
20		20
21	-	21	+
		22	+
22	</mapper>	23	</mapper>
23	\ No newline at end of file	24	\ No newline at end of file
	@@ -2,6 +2,7 @@ package com.sincere.haikang;		@@ -2,6 +2,7 @@ package com.sincere.haikang;
2		2
3	import com.sincere.haikang.async.SendUserAsync;	3	import com.sincere.haikang.async.SendUserAsync;
4	import com.sincere.haikang.bean.AttendanceBean;	4	import com.sincere.haikang.bean.AttendanceBean;
		5	+import com.sincere.haikang.bean.SIngleCardBean;
5	import com.sincere.haikang.bean.StudentBean;	6	import com.sincere.haikang.bean.StudentBean;
6	import com.sincere.haikang.dao.DeviceDao;	7	import com.sincere.haikang.dao.DeviceDao;
7	import com.sincere.haikang.dao.UserDao;	8	import com.sincere.haikang.dao.UserDao;
	@@ -22,7 +23,9 @@ import org.springframework.util.StringUtils;		@@ -22,7 +23,9 @@ import org.springframework.util.StringUtils;
22	import org.springframework.web.client.RestTemplate;	23	import org.springframework.web.client.RestTemplate;
23		24
24	import java.io.*;	25	import java.io.*;
		26	+import java.text.SimpleDateFormat;
25	import java.util.ArrayList;	27	import java.util.ArrayList;
		28	+import java.util.Date;
26	import java.util.List;	29	import java.util.List;
27		30
28	@Component	31	@Component
	@@ -129,10 +132,13 @@ public class SchduleTask {		@@ -129,10 +132,13 @@ public class SchduleTask {
129	String clientIds = "";	132	String clientIds = "";
130	for (int i = 0; i < attendanceBeans.size(); i++) {	133	for (int i = 0; i < attendanceBeans.size(); i++) {
131	if (i < attendanceBeans.size() - 1) {	134	if (i < attendanceBeans.size() - 1) {
132	- if (attendanceBeans.get(i).getClint_type().equals("22")) {	135	+ AttendanceBean attendanceBean = attendanceBeans.get(i);
		136	+ System.out.println("attendanceBean:"+attendanceBean.toString());
		137	+ String clint_type = attendanceBean.getClint_type();
		138	+ if (null!=clint_type&&clint_type.equals("22")) {
133	type = 22;	139	type = 22;
134	clientIds += attendanceBeans.get(i).getClint_id() + ",";	140	clientIds += attendanceBeans.get(i).getClint_id() + ",";
135	- } else if (attendanceBeans.get(i).getClint_type().equals("18")) {	141	+ } else if (null!=clint_type&&clint_type.equals("18")) {
136	type = 18;	142	type = 18;
137	clientIds += attendanceBeans.get(i).getClint_id();	143	clientIds += attendanceBeans.get(i).getClint_id();
138	}	144	}
	@@ -167,13 +173,46 @@ public class SchduleTask {		@@ -167,13 +173,46 @@ public class SchduleTask {
167	int SchoolId = studentBean.getSchoolId();	173	int SchoolId = studentBean.getSchoolId();
168	String card = TextUtils.isEmpty(studentBean.getCard()) ? studentBean.getOldCard() : studentBean.getCard();	174	String card = TextUtils.isEmpty(studentBean.getCard()) ? studentBean.getOldCard() : studentBean.getCard();
169	if (!TextUtils.isEmpty(card)) {	175	if (!TextUtils.isEmpty(card)) {
170	- RestTemplate restTemplate = new RestTemplate();
171	- HttpHeaders headers = new HttpHeaders();
172	- headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
173	- String url = "http://campus.myjxt.com/api/OneCard/SendSingle?SchoolId=" + SchoolId + "&Card=" + card + "&ClassId=" + studentBean.getClassId();
174	- System.out.println("下发卡号url:" + url);
175	- ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
176	- System.out.println("下发卡号:" + responseEntity.getBody());	176	+
		177	+ List<AttendanceBean> attendanceBeans = deviceDao.getAttendancesWithSchoolId(SchoolId);
		178	+
		179	+ for (int i = 0; i < attendanceBeans.size(); i++) {
		180	+
		181	+ AttendanceBean attendanceBean = attendanceBeans.get(i);
		182	+
		183	+ String clint_type = attendanceBean.getClint_type();
		184	+
		185	+ if (null!=clint_type&&clint_type.equals("6")){
		186	+
		187	+ SIngleCardBean sIngleCardBean = new SIngleCardBean();
		188	+
		189	+ sIngleCardBean.setCardNo(card);
		190	+ sIngleCardBean.setEndTime("2050-09-04T00:52:22.510Z");
		191	+ sIngleCardBean.setId("5");
		192	+ sIngleCardBean.setShiduan("2");
		193	+ sIngleCardBean.setSn(attendanceBean.getClint_id());
		194	+ sIngleCardBean.setStartTime(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'").format(new Date()));
		195	+ sIngleCardBean.setType("1");
		196	+
		197	+ RestTemplate restTemplate = new RestTemplate();
		198	+ HttpHeaders headers = new HttpHeaders();
		199	+ MediaType mediaType = MediaType.parseMediaType(MediaType.APPLICATION_JSON_UTF8_VALUE);
		200	+ headers.setContentType(mediaType);
		201	+// String url = "http://campus.myjxt.com/api/OneCard/SendSingle?SchoolId=" + SchoolId + "&Card=" + card + "&ClassId=" + studentBean.getClassId();
		202	+// System.out.println("下发卡号url:" + url);
		203	+// ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
		204	+// System.out.println("下发卡号:" + responseEntity.getBody());
		205	+ System.out.println("sIngleCardBean:"+sIngleCardBean.toString());
		206	+ String url = "http://121.40.109.21:9000/setSignalCardInfo";
		207	+ HttpEntity<SIngleCardBean> httpEntity = new HttpEntity<>(sIngleCardBean,headers);
		208	+ ResponseEntity<String> responseEntity = restTemplate.postForEntity(url,httpEntity,String.class);
		209	+ System.out.println("下发卡号:" + responseEntity.getBody());
		210	+
		211	+
		212	+ }
		213	+
		214	+ }
		215	+
177	}	216	}
178		217
179		218
@@ -0,0 +1,17 @@		@@ -0,0 +1,17 @@
	1	+package com.sincere.haikang;
	2	+
	3	+import java.text.SimpleDateFormat;
	4	+import java.util.Date;
	5	+
	6	+public class Test {
	7	+ static int i ;
	8	+
	9	+ public static void main(String[] args) {
	10	+
	11	+ int num = 2147483647 ;
	12	+ long temp = num + 2L ;
	13	+ System.out.println(num) ;
	14	+
	15	+ }
	16	+
	17	+}
@@ -0,0 +1,89 @@		@@ -0,0 +1,89 @@
	1	+package com.sincere.haikang.bean;
	2	+
	3	+import java.io.Serializable;
	4	+
	5	+public class SIngleCardBean implements Serializable {
	6	+
	7	+ private String cardNo;
	8	+
	9	+ private String endTime;
	10	+
	11	+ private String id;
	12	+
	13	+ private String shiduan;
	14	+
	15	+ private String sn;
	16	+
	17	+ private String startTime;
	18	+
	19	+ private String type;
	20	+
	21	+ public String getCardNo() {
	22	+ return cardNo;
	23	+ }
	24	+
	25	+ public void setCardNo(String cardNo) {
	26	+ this.cardNo = cardNo;
	27	+ }
	28	+
	29	+ public String getEndTime() {
	30	+ return endTime;
	31	+ }
	32	+
	33	+ public void setEndTime(String endTime) {
	34	+ this.endTime = endTime;
	35	+ }
	36	+
	37	+ public String getId() {
	38	+ return id;
	39	+ }
	40	+
	41	+ public void setId(String id) {
	42	+ this.id = id;
	43	+ }
	44	+
	45	+ public String getShiduan() {
	46	+ return shiduan;
	47	+ }
	48	+
	49	+ public void setShiduan(String shiduan) {
	50	+ this.shiduan = shiduan;
	51	+ }
	52	+
	53	+ public String getSn() {
	54	+ return sn;
	55	+ }
	56	+
	57	+ public void setSn(String sn) {
	58	+ this.sn = sn;
	59	+ }
	60	+
	61	+ public String getStartTime() {
	62	+ return startTime;
	63	+ }
	64	+
	65	+ public void setStartTime(String startTime) {
	66	+ this.startTime = startTime;
	67	+ }
	68	+
	69	+ public String getType() {
	70	+ return type;
	71	+ }
	72	+
	73	+ public void setType(String type) {
	74	+ this.type = type;
	75	+ }
	76	+
	77	+ @Override
	78	+ public String toString() {
	79	+ return "SIngleCardBean{" +
	80	+ "cardNo='" + cardNo + '\'' +
	81	+ ", endTime='" + endTime + '\'' +
	82	+ ", id='" + id + '\'' +
	83	+ ", shiduan='" + shiduan + '\'' +
	84	+ ", sn='" + sn + '\'' +
	85	+ ", startTime='" + startTime + '\'' +
	86	+ ", type='" + type + '\'' +
	87	+ '}';
	88	+ }
	89	+}
@@ -0,0 +1,78 @@		@@ -0,0 +1,78 @@
	1	+package com.sincere.haikangface.bean;
	2	+
	3	+import java.io.Serializable;
	4	+
	5	+public class BaiduFaceRecorder implements Serializable {
	6	+
	7	+ private String name;
	8	+
	9	+ private String userId;
	10	+
	11	+ private String score;
	12	+
	13	+ private String time;
	14	+
	15	+ private String uploadImgUrl;
	16	+
	17	+ private String userImgUrl;
	18	+
	19	+ public String getName() {
	20	+ return name;
	21	+ }
	22	+
	23	+ public void setName(String name) {
	24	+ this.name = name;
	25	+ }
	26	+
	27	+ public String getUserId() {
	28	+ return userId;
	29	+ }
	30	+
	31	+ public void setUserId(String userId) {
	32	+ this.userId = userId;
	33	+ }
	34	+
	35	+ public String getScore() {
	36	+ return score;
	37	+ }
	38	+
	39	+ public void setScore(String score) {
	40	+ this.score = score;
	41	+ }
	42	+
	43	+ public String getTime() {
	44	+ return time;
	45	+ }
	46	+
	47	+ public void setTime(String time) {
	48	+ this.time = time;
	49	+ }
	50	+
	51	+ public String getUploadImgUrl() {
	52	+ return uploadImgUrl;
	53	+ }
	54	+
	55	+ public void setUploadImgUrl(String uploadImgUrl) {
	56	+ this.uploadImgUrl = uploadImgUrl;
	57	+ }
	58	+
	59	+ public String getUserImgUrl() {
	60	+ return userImgUrl;
	61	+ }
	62	+
	63	+ public void setUserImgUrl(String userImgUrl) {
	64	+ this.userImgUrl = userImgUrl;
	65	+ }
	66	+
	67	+ @Override
	68	+ public String toString() {
	69	+ return "BaiduFaceRecorder{" +
	70	+ "name='" + name + '\'' +
	71	+ ", userId='" + userId + '\'' +
	72	+ ", score='" + score + '\'' +
	73	+ ", time='" + time + '\'' +
	74	+ ", uploadImgUrl='" + uploadImgUrl + '\'' +
	75	+ ", userImgUrl='" + userImgUrl + '\'' +
	76	+ '}';
	77	+ }
	78	+}