package com.sincere.att.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.sincere.att.feign.ScFeign;
import com.sincere.att.feign.XaFeign;
import com.sincere.att.logs.LogName;
import com.sincere.att.logs.LoggerUtils;
import com.sincere.att.mqtt.MqtUtils;
import com.sincere.att.vo.AttendanceInfoBean;
import com.sincere.att.vo.CheckOrderVo;
import com.sincere.att.vo.FingerOrderVo;
import com.sincere.att.vo.UserOrderVo;
import com.sincere.common.dto.smartCampus.SZ_AttendanceDto;
import com.sincere.common.dto.xiaoan.FingerDto;
import com.sincere.common.util.DateUtils;
import com.sincere.common.util.HttpClientUtils;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.math.BigInteger;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
/**
* 所有的设备请求都会在url参数里携带SN，这是设备序列号(serial number的缩写)，每个设备唯一标识
*/
@RestController
@RequestMapping("/iclock")
public class AttPushController {
private static final Logger Log_orderFail = LoggerUtils.Logger(LogName.orderFail);
private static final Logger Log_orderSuccess = LoggerUtils.Logger(LogName.orderSuccess);
private static final Logger Log_kaoInfo = LoggerUtils.Logger(LogName.kaoInfo);
private static Map<String, List<String>> cmdMap = new HashMap<>();
private static Map<String, Integer> cmdOrderMap = new HashMap<>();
private static String pwd = "22222222-6faf-48uh-a5a9-447ec68bfe2f";
private static String account = "yueqingzhijiao";
@Autowired
ScFeign scFeign;
@Autowired
XaFeign xaFeign;
@RequestMapping(value = "GetDeviceCmd", method = RequestMethod.GET)
@ApiOperation(value = "查询待处理指令")
@ApiImplicitParams({@ApiImplicitParam(name = "schoolId", value = "学校id"),
@ApiImplicitParam(name = "deviceId", value = "设备id")})
public String GetDeviceCmd(@RequestParam("schoolId") String schoolId,
@RequestParam("deviceId") String deviceId) {
try {
if(schoolId=="1221")
{
}
if(StringUtils.isNotBlank(deviceId)){
List<String> cmds = cmdMap.get(deviceId);
if (cmds != null && cmds.size() > 0) {
return cmds.toString();
}
return "cmd is empty";
}
else{
return "device not is null";
}
} catch (Exception e) {
return e.getMessage();
}
}
//C:${CmdID}:Check 检查并传送新数据
@RequestMapping(value = "GetLatestData", method = RequestMethod.GET)
@ApiOperation(value = "检查并上传新数据")
@ApiImplicitParams({@ApiImplicitParam(name = "schoolId", value = "学校id"),
@ApiImplicitParam(name = "deviceId", value = "设备id")})
public void GetLatestData(@RequestParam("schoolId") String schoolId,
@RequestParam("deviceId") String deviceId) {
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
String date=simpleDateFormat.format(new Date());
List<String> order = new ArrayList<>();
CheckOrderVo vo = new CheckOrderVo();
vo.setStudentName(deviceId+date);
int number = 1;
try {
number = cmdOrderMap.get(deviceId);
} catch (Exception e) {
}
number++;
cmdOrderMap.put(deviceId, number);
if (!order.contains(vo.toString())) {
order.add(vo.toString());
}
cmdMap.put(deviceId, order);
}
@RequestMapping(value = "sendSingleUser", method = RequestMethod.GET)
@ApiOperation(value = "下发单个用户")
@ApiImplicitParams({@ApiImplicitParam(name = "schoolId", value = "学校id"),
@ApiImplicitParam(name = "deviceId", value = "设备id"),
@ApiImplicitParam(name = "studentId", value = "学生id")})
public void sendSingleUser(@RequestParam("schoolId") String schoolId,
@RequestParam("deviceId") String deviceId,
@RequestParam("studentId") int studentId) {
// String result1 = HttpClientUtils.httpGet2("http://campus.myjxt.com/api/EasyN/GetStudentDetail?studentid="+studentId+"&schoolId="+schoolId);
JSONObject result = HttpClientUtils.httpGet("http://campus.myjxt.com/api/EasyN/GetStudentDetail?studentid="+studentId+"&schoolId="+schoolId);
JSONObject array = (JSONObject) result.get("data");
List<String> order = new ArrayList<>();
UserOrderVo vo = new UserOrderVo();
vo.setStudentId((Integer) array.get("studentId"));
vo.setStudentName((String) array.get("studentName"));
int number = 1;
try {
number = cmdOrderMap.get(deviceId);
} catch (Exception e) {
}
vo.setNumber(number);
number++;
cmdOrderMap.put(deviceId, number);
if (vo.getStudentId() != 0) {
// if (vo.getStudentId() == 72196){
//todo:测试专用
if (!order.contains(vo.toString())) {
order.add(vo.toString());
}
// }
}
cmdMap.put(deviceId, order);
}
@RequestMapping(value = "sendSingleFinger", method = RequestMethod.GET)
public void sendSingleFinger(@RequestParam("StudentId") int StudentId,@RequestParam(value = "deviceId") String deviceId) {
List<String> order = new ArrayList<>();
// for (int i = 0; i < array.size(); i++) {
// JSONObject student = (JSONObject) array.get(i);
FingerOrderVo vo = new FingerOrderVo();
int number = 1;
try {
number = cmdOrderMap.get(deviceId);
} catch (Exception e) {
}
vo.setNumber(number);
vo.setOrder(xaFeign.selectFinger((Integer) StudentId));
number++;
cmdOrderMap.put(deviceId, number);
if (StringUtils.isNotBlank(vo.getOrder())) {
order.add(vo.toString());
}
//}
cmdMap.put(deviceId, order);
//}
}
@RequestMapping(value = "sendUser", method = RequestMethod.GET)
public void sendUser(@RequestParam("roomId") int roomId) {
JSONObject object = new JSONObject();
object.put("pageIndex", 1);
object.put("roomId", roomId);
object.put("pageSize", 9999);
JSONObject result = HttpClientUtils.httpPostJson("http://campus.myjxt.com/api/Room/GetListPageRoom", object.toJSONString());
JSONArray array = (JSONArray) ((JSONObject) result.get("data")).get("roomList");
List<String> attendanceList = scFeign.selectRoomAttendance(roomId);
for (String attendance : attendanceList) {
List<String> order = new ArrayList<>();
for (int i = 0; i < array.size(); i++) {
JSONObject student = (JSONObject) array.get(i);
UserOrderVo vo = new UserOrderVo();
vo.setStudentId((Integer) student.get("studentid"));
vo.setStudentName((String) student.get("name"));
int number = 1;
try {
number = cmdOrderMap.get(attendance);
} catch (Exception e) {
}
vo.setNumber(number);
number++;
cmdOrderMap.put(attendance, number);
if (vo.getStudentId() != 0) {
// if (vo.getStudentId() == 72196){
//todo:测试专用
if (!order.contains(vo.toString())) {
order.add(vo.toString());
}
// }
}
}
cmdMap.put(attendance, order);
}
}
@RequestMapping(value = "sendFinger", method = RequestMethod.GET)
public void sendFinger(@RequestParam("roomId") int roomId,@RequestParam(value = "deviceId",required = false) String deviceId) {
JSONObject object = new JSONObject();
object.put("PageIndex", 1);
object.put("roomId", roomId);
object.put("pageSize", 9999);
JSONObject result = HttpClientUtils.httpPostJson("http://campus.myjxt.com/api/Room/GetListPageRoom", object.toJSONString());
JSONArray array = (JSONArray) ((JSONObject) result.get("data")).get("roomList");
List<String> attendanceList = scFeign.selectRoomAttendance(roomId);
for (String attendance : attendanceList) {
if(StringUtils.isNotBlank(deviceId)&&!attendance.contains(deviceId)) continue;
List<String> order = new ArrayList<>();
for (int i = 0; i < array.size(); i++) {
JSONObject student = (JSONObject) array.get(i);
FingerOrderVo vo = new FingerOrderVo();
int number = 1;
try {
number = cmdOrderMap.get(attendance);
} catch (Exception e) {
}
vo.setNumber(number);
vo.setOrder(xaFeign.selectFinger((Integer) student.get("studentid")));
number++;
cmdOrderMap.put(attendance, number);
if (StringUtils.isNotBlank(vo.getOrder())) {
order.add(vo.toString());
}
}
cmdMap.put(attendance, order);
}
}
/**
* 1，设备通完电以后第一个发送到后台的请求
* 格式为 /iclock/cdata?options=all&language=xxxx&pushver=xxxx
*/
@RequestMapping(value = "/cdata", params = {"options", "language", "pushver"}, method = RequestMethod.GET)
public void init(String SN,String options,String language,String pushver,HttpServletRequest request,
@RequestParam(required = false) String PushOptionsFlag,
HttpServletResponse response) {
try {
System.out.println("设备上电：" + SN);
if (cmdMap.get(SN) == null) {
System.out.println("设备上线：" + SN);
cmdMap.put(SN, new ArrayList<>());
cmdOrderMap.put(SN, 10000);
}
if (scFeign.selectAttendaceWithId(SN) == null) {
SZ_AttendanceDto attendanceDto = new SZ_AttendanceDto();
attendanceDto.setClint_id(SN);
attendanceDto.setClint_type("24");
attendanceDto.setIp(request.getRemoteAddr());
attendanceDto.setPort(request.getRemotePort());
attendanceDto.setIntime(DateUtils.date2String(new Date(), DateUtils.format2));
attendanceDto.setSchool_id("-1");
attendanceDto.setState(1);
scFeign.insertAttendance(attendanceDto);
} else {
scFeign.updateAttendance(SN);
}
String initOptions = initOptions(SN, PushOptionsFlag);
response.getWriter().write(initOptions);//返回成功以后设备会发送心跳请求
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 2，心跳请求，会从服务器拿到命令返回 给设备
*/
@RequestMapping("/getrequest")
public void heartBeat(String SN, HttpServletResponse response) {
scFeign.updateAttendance(SN);
StringBuffer sb = new StringBuffer("OK");
//System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"设备心跳：" + SN);
List<String> cmds = cmdMap.get(SN);
// if (null != cmds && cmds.size() > 10)
// cmds = cmds.subList(0, 10);
if (cmds == null) {//等于空说明从来没加载过，如果初始化加载过了，此时应该不为Null 只是size为0
System.out.println("设备上线：" + SN);
cmds = new ArrayList<>();
cmdMap.put(SN, cmds);
cmdOrderMap.put(SN, 10000);
}
if (cmds != null && cmds.size() > 0) {
sb.setLength(0);//如果有命令就不返回OK了
cmds.stream().forEach(cmd -> sb.append(cmd).append("\r\n\r\n"));
}
try {
response.setCharacterEncoding("gbk");
response.getWriter().write(sb.toString());
// System.out.println("返回数据成功：" + SN + "---学生数量:" + cmds.size());
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 3，候补心跳请求，正常情况下设备不发此请求，有大量数据上传的时候，不发上面的心跳，发这个请求，
* 这个请求，服务器只能返回OK，不可以返回命令
*/
@RequestMapping("/ping")
public void ping(HttpServletResponse response) {
System.out.println("考勤机心跳请求大量进来了......ping" + new SimpleDateFormat("HH:mm:ss").format(new Date()));
try {
response.getWriter().write("OK");
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 4，设备端处理完命令以后会发送该请求，告诉服务器命令的处理结果
*/
@RequestMapping("/devicecmd")
public void handleCmd(String SN, @RequestBody String data, HttpServletResponse response) {
//判断data 清空map
//ID=10000&Return=-10&CMD=DATA 指纹下发返回return=-10，表示指纹机没有这个用户数据
List<String> cmdList = cmdMap.get(SN);
String[] returnList = data.split("\n");
if (returnList != null && returnList.length > 0 && cmdList != null && cmdList.size() > 0) {
System.out.println("----returnList:" + returnList.length);
for (String message : returnList) {
System.out.println("----returnList:"+ SN + "," + message);
String number = message.substring(message.indexOf("=") + 1, message.indexOf("&"));
String result = message.substring(message.indexOf("=", message.indexOf("&")) + 1, message.indexOf("&", message.indexOf("&") + 1));
//if (result.equals("0")) {
Iterator<String> it = cmdList.iterator();
while (((Iterator) it).hasNext()) {
String b = it.next();
if (b.contains("C:" + number)) {
it.remove();
System.out.println("----设备接收数据"+(Integer.parseInt(result)==0?"成功":"--失败--")+":" + SN + "----number:" + number);
}
}
if(message.contains("CMD=DATA"))
{
}
if(message.contains("CMD=CHECK"))
{
}
//}
}
}
try {
response.getWriter().write("OK");
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 5 考勤数据上报
*/
@RequestMapping(value = "/cdata")
public void handleRtData(HttpServletRequest request, HttpServletResponse response, String SN, String table) throws UnsupportedEncodingException {
request.setCharacterEncoding("gbk");
String data = "";
ByteArrayOutputStream bos = null;
byte[] b = new byte[1024];
try {
InputStream is = request.getInputStream();
bos = new ByteArrayOutputStream();
int len = 0;
while ((len = is.read(b)) != -1) {
bos.write(b, 0, len);
}
data = new String(bos.toByteArray(), "gbk");
} catch (IOException e) {
e.printStackTrace();
}
if ("ATTLOG".equals(table)) {
String[] list = data.split("\t");
String cardNo = scFeign.selectStudentNumByStudentId(Integer.valueOf(list[0]));
if (StringUtils.isNotBlank(cardNo)) {
String cardNo10 = new BigInteger(cardNo, 16).toString();
//考勤日志
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String info = String.format("<AttendanceInfo submitTime=\"%s\"><Info device=\"%s\" card=\"%s\" operTime=\"%s\" direc=\"%s\"></Info></AttendanceInfo>",
simpleDateFormat.format(new Date()), SN, cardNo10, list[1], "-1");
AttendanceInfoBean attendanceInfoBean = new AttendanceInfoBean();
attendanceInfoBean.setInfo(info);
attendanceInfoBean.setIsControl(0);
attendanceInfoBean.setPwd(pwd);
attendanceInfoBean.setUsername(account);
String jsonResult = JSON.toJSONString(attendanceInfoBean);
String urlHXY = "http://campus.myjxt.com/api/XiaoAnCommon/SendHXY";
JSONObject jsonObject = HttpClientUtils.httpPostJson(urlHXY, jsonResult);
//if ((int) jsonObject.get("status") == 1) {
if ( Integer.parseInt(jsonObject.get("data").toString()) == 0) {
/**
* 签到成功发送数据到看板 add by 2020-11-17
*/
sendMQMessage(SN,cardNo);
Log_kaoInfo.info("出入寝签到成功:" + SN + " 卡号:" + cardNo);
} else {
Log_kaoInfo.info("出入寝签到失败:" + SN + " 卡号:" + cardNo + " result1:" + jsonObject.toJSONString());
}
} else {
System.out.println(list[0]+":card is "+cardNo);
}
}
if ("OPERLOG".equals(table)) {
//操作日志
if (data.substring(0, 3).contains("FP")) {
String[] finger = data.split("FP ");
for (int j = 0; j < finger.length; j++) {
String fingerInfo = finger[j];
if(org.springframework.util.StringUtils.isEmpty(fingerInfo)) continue;
//添加指纹
String studentId = fingerInfo .substring(fingerInfo .indexOf("=") + 1, fingerInfo .indexOf("\t", fingerInfo .indexOf("=")));
// String order = data.substring(3);
String ret= xaFeign.selectFinger(Integer.parseInt(studentId));
if(!org.springframework.util.StringUtils.isEmpty(ret)) continue;
//String order = data;
FingerDto fingerDto = new FingerDto();
fingerDto.setOrderMsg(fingerInfo);
fingerDto.setStudentId(Integer.valueOf(studentId));
fingerDto.setCreateTime(new Date());
xaFeign.insertFinger(fingerDto);
}
}
}
try {
response.getWriter().write("OK");
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendMQMessage(String deviceId,String cardNum) {
//获取寝室关联的场景id
String placeId = scFeign.selectPlaceAttendance(deviceId);
if (null != placeId) {
//关联的显示看板设备
List<String> kanbanIds = scFeign.selectRoomAttendance(Integer.parseInt(placeId));
for (int i = 0; i < kanbanIds.size(); i++) {
String kanbanId = kanbanIds.get(i);
String data = "{\"cmd\":\"" + 34 + "\",\"clientId\":\"" + kanbanId + "\",\"data\":{\"cardNum\":\"" + cardNum+"}}";
MqtUtils.getInstance().sendMsg(kanbanId, data);
}
} else {
String schoolId = scFeign.getSchoolIdWidthCardNum(cardNum);
if(org.springframework.util.StringUtils.isEmpty(schoolId)||Integer.parseInt(schoolId) <=0)return;
List<String> clintIds = scFeign.getClintIds(schoolId);
for (int i = 0; i < clintIds.size(); i++) {
String clintId = clintIds.get(i);
String data = "{\"cmd\":\"" + 34 + "\",\"clientId\":\"" + clintId + "\",\"data\":{\"cardNum\":\"" + cardNum + "}}";
MqtUtils.getInstance().sendMsg(clintId, data);
}
}
}
public static void main(String[] args) {
/*JSONObject object = new JSONObject();
object.put("pageIndex",1);
object.put("roomId","13299");
object.put("pageSize",9999);
JSONObject result = HttpClientUtils.httpPostJson("http://campus.myjxt.com/api/Room/GetListPageRoom",object.toJSONString());
JSONObject data = result.getJSONObject("data");
JSONArray roomList = data.getJSONArray("roomList");
for (int i = 0; i < roomList.size(); i++) {
String name = roomList.getJSONObject(i).getString("name");
String studentId = roomList.getJSONObject(i).getString("studentid");
System.out.println(name+","+studentId);
}*/
String cardNo = "FF013E0F";
String SN = "A4JS174260624";
String cardNo10 = new BigInteger(cardNo, 16).toString();
//考勤日志
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String info = String.format("<AttendanceInfo submitTime=\"%s\"><Info device=\"%s\" card=\"%s\" operTime=\"%s\" direc=\"%s\"></Info></AttendanceInfo>",
simpleDateFormat.format(new Date()), SN, cardNo10, DateUtils.date2String(new Date(), DateUtils.format2), "-1");
AttendanceInfoBean attendanceInfoBean = new AttendanceInfoBean();
attendanceInfoBean.setInfo(info);
attendanceInfoBean.setIsControl(0);
attendanceInfoBean.setPwd(pwd);
attendanceInfoBean.setUsername(account);
String jsonResult = JSON.toJSONString(attendanceInfoBean);
String urlHXY = "http://campus.myjxt.com/api/XiaoAnCommon/SendHXY";
JSONObject jsonObject = HttpClientUtils.httpPostJson(urlHXY, jsonResult);
if ((int) jsonObject.get("status") == 1) {
Log_kaoInfo.info("出入寝签到成功:" + SN + " 卡号:" + cardNo);
} else {
Log_orderFail.info("出入寝签到失败:" + SN + " 卡号:" + cardNo + " result1:" + jsonObject.toJSONString());
}
}
/**
* 设备通电以后连接到服务器，需要返回的初始化参数
*
* @param sn
* @param PushOptionsFlag
* @return
*/
private String initOptions(String sn, String PushOptionsFlag) {
StringBuffer devOptions = new StringBuffer();
devOptions.append("GET OPTION FROM: " + sn);
// + "\nStamp=" + devInfo.devInfoJson.getString("Stamp")
devOptions.append("\nATTLOGStamp=0");
devOptions.append("\nOPERLOGStamp=0");
devOptions.append("\nBIODATAStamp=0");
devOptions.append("\nATTPHOTOStamp=0");
devOptions.append("\nErrorDelay=10");//断网重连
devOptions.append("\nDelay=5");//心跳间隔
devOptions.append("\nTimeZone=8");//时区
devOptions.append("\nRealtime=1");//实时上传
devOptions.append("\nServerVer=3.0.1");//这个必须填写
// 1 考勤记录
// 2 操作日志
// 3 考勤照片
// 4 登记新指纹
// 5 登记新用户
// 6 指纹图片
// 7 修改用户信息
// 8 修改指纹
// 9 新登记人脸
// 10 用户照片
// 11 工作号码
// 12 比对照片
devOptions.append("\nTransFlag=111111111111");// 1-12二进制位 分别代表以上含义
System.out.println("PushOptionsFlag=============" + PushOptionsFlag);
if (PushOptionsFlag != null && PushOptionsFlag.equals("1")) {
// 支持参数单独获取的才要把需要获取的参数回传给设备 modifeid by max 20170926
devOptions.append("\nPushOptions=RegDeviceType,FingerFunOn,FaceFunOn,FPVersion,FaceVersion,NetworkType,HardwareId3,HardwareId5,HardwareId56,LicenseStatus3,LicenseStatus5,LicenseStatus56");
}
devOptions.append("\n");
return devOptions.toString();
}
}