SIPAIIS_WMS_JSSW/src/main/java/com/sipai/netty/NettyServerHandler.java

package com.sipai.netty;

import java.math.BigDecimal;
import java.util.List;
import java.util.Map.Entry;

import javax.annotation.Resource;

import com.alibaba.fastjson.JSONObject;
import com.sipai.entity.scada.MPoint;
import com.sipai.entity.scada.MPointHistory;
import com.sipai.entity.user.Company;
import com.sipai.entity.work.ElectricityMeter;
import com.sipai.service.scada.MPointHistoryService;
import com.sipai.service.scada.MPointService;
import com.sipai.service.user.UnitService;
import com.sipai.service.work.ElectricityMeterService;
import com.sipai.tools.CommUtil;
import com.sipai.tools.SpringContextUtil;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;

public class NettyServerHandler extends ChannelInboundHandlerAdapter  {
    
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ByteBuf buf = (ByteBuf) msg;
        //String jsonStr = JSONObject.toJSONString(buf);
        System.out.println("Netty服务端接收信息（" +CommUtil.nowDate()+"）:"+ buf.toString(CharsetUtil.UTF_8));
        JSONObject jsonObject = null;
        try {
            //当数据不是json格式时，捕获异常，设为空
            jsonObject = JSONObject.parseObject(buf.toString(CharsetUtil.UTF_8));
        } catch (Exception e) {
            jsonObject = null;
        }
        if(null != jsonObject){
            ElectricityMeterService electricityMeterService = (ElectricityMeterService) SpringContextUtil.getBean("electricityMeterService");
            //获取电表ID
            String ID = (String) jsonObject.get("ID");
            ElectricityMeter electricityMeter = electricityMeterService.selectById(ID);
            if(electricityMeter!=null){
                String bizId = electricityMeter.getBizid();
                if(null != bizId && !"".equals(bizId)){
                    MPoint mPointEntity = null;
                    MPointHistory mPointHistory = null;
                    BigDecimal parmvalue = new BigDecimal("0");
                    String measuredt = "";
                    int num = 0;
                    int numHistory = 0;
                    MPointService mPointService = (MPointService) SpringContextUtil.getBean("mPointService");
                    MPointHistoryService mPointHistoryService = (MPointHistoryService) SpringContextUtil.getBean("mPointHistoryService");
                    String prefix = "";
                    String suffix = "";
                    if(electricityMeter.getPrefix()!=null && !"".equals(electricityMeter.getPrefix())){
                        prefix = electricityMeter.getPrefix()+"_";
                    }
                    if(electricityMeter.getSuffix()!=null && !"".equals(electricityMeter.getSuffix())){
                        suffix = "_"+electricityMeter.getSuffix();
                    }
                    for (Entry<String, Object> entry : jsonObject.entrySet()) {
                        if(!"ID".equals(entry.getKey())){
                            if(isNumber(entry.getValue().toString())){
                                //点位: 前缀_key_后缀
                                mPointEntity = mPointService.selectById(bizId, prefix+entry.getKey()+suffix);
                                if(mPointEntity!=null){
                                    parmvalue = new BigDecimal(entry.getValue().toString());
                                    measuredt = CommUtil.nowDate();
                                    mPointEntity.setParmvalue(parmvalue);
                                    mPointEntity.setMeasuredt(measuredt);
                                    int res = mPointService.update(bizId, mPointEntity);
                                    if(res>0){
                                        num++;
                                        mPointHistory=new MPointHistory();
                                        mPointHistory.setParmvalue(parmvalue);
                                        mPointHistory.setMeasuredt(measuredt);
                                        mPointHistory.setTbName("TB_MP_"+mPointEntity.getMpointcode());
                                        res = mPointHistoryService.save(bizId, mPointHistory);
                                        if(res>0){
                                            numHistory++;
                                        }
                                    }
                                }
                            }
                        }
                    }
                    System.out.println("Netty服务端处理信息（" +CommUtil.nowDate()+"）:成功更新主表"+ num+"条数据，成功更新子表"+ numHistory+"个；");
                }
            }
        }
        ByteBuf res = Unpooled.wrappedBuffer(new String("收到!信息如下, 请确认：" + buf.toString(CharsetUtil.UTF_8)).getBytes());
        /**
         * 给客户端回复消息
         */
        ctx.writeAndFlush(res);
    }

    /**
     * 连接成功后，自动执行该方法
     * @param ctx
     * @throws Exception
     */
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("服务器首次处理!");
        ByteBuf res = Unpooled.wrappedBuffer(new String("true").getBytes());
        ctx.writeAndFlush(res);
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        super.exceptionCaught(ctx, cause);
        /**
         * 异常捕获
         */
        cause.printStackTrace();
        ctx.close();
    }
    public static boolean isNumber(String str){
        String reg = "^[0-9]+(.[0-9]+)?$";
        return str.matches(reg);
    }
}