package com.doumee.cloud.admin; import cn.hutool.core.io.IoUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.doumee.core.model.ApiResponse; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.dao.admin.request.InDeviceEntranceParam; import com.doumee.dao.admin.response.DevWgDataResponseParam; import com.doumee.dao.admin.response.DevWgResponseParam; import com.doumee.dao.admin.response.DevWgYtjResponseParam; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.BookingsService; import com.doumee.service.business.DevicesService; import com.doumee.service.system.SystemUserService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /** * 微光二维码请求入口 * * @author lishuai * @email * @date 2022-12-12 14:30:50 */ @Api(tags = "微光二维码请求入口接口",value = "") @RestController @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/business/wgListener") @Slf4j public class WgListenerCloudController { @Autowired private SystemUserService systemUserService; @Autowired private BookingsService bookingsService; @Autowired private DevicesService devicesService; @ApiOperation(value="微光二维码进场核销入口") @PostMapping("/qrcodeIn") public void qrcodeIn(HttpServletRequest request, HttpServletResponse response) throws Exception{ // 入口调用返回json response.setDateHeader("Expires", 0); response.setHeader("Cache-Control", "no-cache"); response.setHeader("Pragma", "no-cache"); DevWgResponseParam json = reqJSONObject( request); log.info("打印json数据================="+json); if(null == json) { ApiResponse.outputCode(response,"-1"); return; } try { if(StringUtils.equals("hello",json.getVgdecoderesult())){ //如果是心跳设置 devicesService.doHeartDeal(json.getDevicenumber()); log.info("心跳成功================="+json.getDevicenumber()); ApiResponse.outputCode(response,"-1"); }else{ bookingsService.openRoomDoor(json); log.info("扫码成功================="); ApiResponse.outputCode(response,"0000"); } }catch (Exception e){ e.printStackTrace(); log.info("扫码异常================="+e.getMessage()); ApiResponse.outputCode(response,"-1"); } } @ApiOperation(value="微光一体机二维码进场核销入口") @PostMapping("/qrcodeInYtj") public void qrcodeInNew(HttpServletRequest request, HttpServletResponse response) throws Exception{ // 入口调用返回json response.setDateHeader("Expires", 0); response.setHeader("Content-Type", "text/html;charset=UTF-8"); response.setHeader("Cache-Control", "no-cache"); response.setHeader("Pragma", "no-cache"); DevWgResponseParam json = reqJSONObjectYtj( request); log.info("打印json数据================="+json); if(null == json) { ApiResponse.outputCode(response,"-1"); return; } try { if(StringUtils.equals("hello",json.getVgdecoderesult())){ //如果是心跳设置 devicesService.doHeartDeal(json.getDevicenumber()); log.info("心跳成功================="+json.getDevicenumber()); ApiResponse.outputCode(response,-1,"心跳失败"); }else{ bookingsService.openRoomDoor(json); log.info("扫码成功================="); ApiResponse.outputCode(response,0,"认证成功"); } }catch (Exception e){ e.printStackTrace(); log.info("扫码异常================="+e.getMessage()); ApiResponse.outputCode(response,-1,e.getMessage()); } } private DevWgResponseParam reqJSONObjectYtj(HttpServletRequest request) throws Exception{ //"type":2,"data":"8tiDkHTlGJdmxP4yAkO7mPR2odwwPgtW","time":1692772938,"deviceSn":"C238180003" String input = IoUtil.read(request.getInputStream(), "utf-8"); log.info("一体机读头设备返回的二维码信息==========="+input); DevWgYtjResponseParam param1 = JSONObject.toJavaObject(JSONObject.parseObject(input), DevWgYtjResponseParam.class); DevWgResponseParam param = new DevWgResponseParam(); param.setVgdecoderesult(param1.getData()); param.setDevicenumber(param1.getDeviceSn()); log.info("一体机对象数据================="+param); //对象传json return param; } @ApiOperation(value="微光二维码出场核销出口") @PostMapping("/qrcodeOut") public void qrcodeOut( HttpServletRequest request, HttpServletResponse response) throws Exception { // 出口调用返回json DevWgResponseParam json = reqJSONObject( request); log.info("打印json数据=================="+json); if(null == json) { return; } ApiResponse.outputCode(response,"0000"); } /** * 微光二维码读头闸机请求，调用进出场接口json封装 */ private DevWgResponseParam reqJSONObject( HttpServletRequest request) throws Exception{ String input = IoUtil.read(request.getInputStream(), "utf-8"); log.info("读头设备返回的二维码信息==========="+input); String[] split = input.split("&&"); DevWgResponseParam param = new DevWgResponseParam(); int indexOne = split[0].indexOf("="); int indexTwo = split[1].indexOf("="); param.setVgdecoderesult(split[0].substring(indexOne+1)); param.setDevicenumber(split[1].substring(indexTwo+1)); log.info("对象数据================="+param); //对象传json // JSONObject json = getJSONObject(param); return param; } @ApiOperation(value="事件监听按类型处理---微光一体机进场") @PostMapping("/taskTwo") public void taskTwo( HttpServletRequest request, HttpServletResponse response) throws Exception { // 入口调用返回json JSONObject jsonObject = reqMachineJSONObject( request); log.info("参数================"+jsonObject); if(null == jsonObject) { return; } ApiResponse.outputCode(response,0,"success"); } @ApiOperation(value="事件监听按类型处理---微光一体机出场") @PostMapping("/taskOutTwo") public void taskOutTwo( HttpServletRequest request, HttpServletResponse response) throws Exception { // 入口调用返回json JSONObject jsonObject = reqMachineJSONObject( request); log.info("参数================"+jsonObject); if(null == jsonObject) { return; } ApiResponse.outputCode(response,0,"success"); } /** * 微光一体机闸机请求，调用进出场接口json封装 * @return */ private JSONObject reqMachineJSONObject( HttpServletRequest request) throws Exception { // 假设业务认证成功 String input = IoUtil.read(request.getInputStream(), "utf-8"); DevWgDataResponseParam responseParam = JSON.parseObject(input , DevWgDataResponseParam.class); //对象传json InDeviceEntranceParam param = new InDeviceEntranceParam(); if("1".equals(responseParam.getType())) { //人脸 param.setFlag("2"); param.setUserId(responseParam.getData()); }else if("2".equals(responseParam.getType())) { //二维码 param.setFlag("1"); param.setCode(responseParam.getData()); }else if("3".equals(responseParam.getType())) { //刷卡 param.setFlag("3"); // 根据会员实体卡号关联查询，会员工号 SystemUser memberDo = systemUserService.findById(1); if(null != memberDo) { param.setUserId( memberDo.getEmpNo()); } param.setCardNo(responseParam.getData()); } param.setDeskId(responseParam.getDeviceSn()); param.setInTime(DateUtil.getCurrDateTime()); param.setOutTime(DateUtil.getCurrDateTime()); JSONObject json =(JSONObject) JSONObject.toJSON(param); return (JSONObject)JSONObject.toJSON(param); } }