yunsu/cloud-socket/src/com/js/kbt/socket/DeviceHandler.java

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";
    	}
    }
}