package com.js.kbt.socket; import javax.annotation.Resource; import org.springframework.stereotype.Service; import com.js.kbt.mapper.ParkingPointMapper; import com.js.kbt.mapper.UserMapper; import com.js.kbt.model.ParkingPoint; import com.js.kbt.model.ParkingPointExample; @Service("deviceHandler") public class DeviceHandler { @Resource(name="userMapper") private UserMapper userMapper; @Resource(name="parkingPointMapper") private ParkingPointMapper parkingPointMapper; public String processMsg(String content) { System.out.println("处理命令=="+content); if ("GET NUMBER".equals(content)) { return getNumber(); } else if (content.startsWith("DWN")) { return finishBill(content); } else if (content.startsWith("DWC")) { } else { } return "OK"; } private String getNumber() { return "00000000"; } public String finishBill(String content) { //车锁降下且车已离开,结算 String deviceId = content.substring("DWN".length()); System.out.println("设备号为="+deviceId); ParkingPointExample example = new ParkingPointExample(); example.createCriteria().andIdentityEqualTo(deviceId); if (parkingPointMapper.countByExample(example) == 0) { return "ERROR"; } else { ParkingPoint park = parkingPointMapper.selectByExample(example).get(0); Integer userId = park.getLastOccupierId(); //从用户账户扣费,结算订单,更新停车记录 System.out.println("=========用户账户扣费,结算订单,更新停车记录=========="); return "OK"; } } }