package com.fgkj.dynamicload.services;
|
|
import java.util.List;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BaseDAOFactory;
|
import com.fgkj.dao.Dynamicload_Ack;
|
import com.fgkj.dao.Electric_4KW_ModbusAddress;
|
import com.fgkj.dao.UinfDaoFactory;
|
import com.fgkj.dto.User_log;
|
import com.fgkj.dynamicload.dto.Dynamicload_control;
|
import com.fgkj.dynamicload.impl.Dynamicload_controlImpl;
|
import com.fgkj.services.ServiceModel;
|
import com.fgkj.services.User_logService;
|
import com.modbus.data.BaseData;
|
import com.modbus.data.Modbus_ComBase;
|
import com.modbus.data.SocketClient;
|
|
public class Dynamicload_controlService {
|
private BaseDAO dao;
|
private ServiceModel model;
|
public Dynamicload_controlService() {
|
super();
|
dao=BaseDAOFactory.getBaseDAO(BaseDAO.DYNAMICLOAD_CONTROL);
|
model=new ServiceModel();
|
}
|
//手动加载页面_按钮操作
|
public ServiceModel update(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
boolean bl=dao.update(dtrol);
|
if(bl){
|
boolean b=Dynamicload_Ack.getButtonAck("FZ_b"+String.valueOf(dtrol.getNum()), dtrol.getDev_id());
|
if(bl){
|
model.setCode(1);
|
model.setMsg("按钮响应成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("按钮响应不成功!");
|
}
|
}else{
|
model.setCode(0);
|
model.setMsg("按钮响应不成功!");
|
}
|
return model;
|
}
|
//手动加载页面_按钮操作(sokcet)
|
public ServiceModel updatePLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
boolean bl=false;
|
BaseData basedata=null;
|
byte[] b=null;
|
String param="";
|
try {
|
switch (dtrol.getNum()) {
|
case 1: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,80,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b1()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮1参数:"+dtrol.getFZ_b1();
|
break;//按钮1
|
case 2: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,81,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b2()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮2参数:"+dtrol.getFZ_b2();
|
break;//
|
case 3: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,82,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b3()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮3参数:"+dtrol.getFZ_b3();
|
break;//
|
case 4: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,83,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b4()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮4参数:"+dtrol.getFZ_b4();
|
break;//
|
case 5: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,84,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b5()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮5参数:"+dtrol.getFZ_b5();
|
break;//
|
case 6: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,85,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b6()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮6参数:"+dtrol.getFZ_b6();
|
break;//
|
case 7: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,86,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b7()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮7参数:"+dtrol.getFZ_b7();
|
break;//
|
case 8: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,87,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b8()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮8参数:"+dtrol.getFZ_b8();
|
break;//
|
case 9: basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,88,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b9()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮9参数:"+dtrol.getFZ_b9();
|
break;
|
case 10:basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,89,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b10()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮10参数:"+dtrol.getFZ_b10();
|
break;
|
case 11:basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,90,1);
|
b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getFZ_b11()));
|
bl=SocketClient.SocketComm(b, dtrol.getDev_ip());
|
param=",按钮11参数:"+dtrol.getFZ_b11();
|
break;//按钮11
|
default:break;
|
}
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("写入成功");
|
} else{
|
model.setCode(0);
|
model.setMsg("写入失败");
|
}
|
{
|
String msg="启动"+dtrol.getDev_name()+"负载系统手动加载开关"+param;
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Start_up,UinfDaoFactory.dynamicload, msg);
|
User_logService uservice=new User_logService();
|
uservice.add(ulog);//将用户的操作记录下来
|
}
|
return model;
|
}
|
//手动/自动加载/突加突卸页面_全部分闸
|
public ServiceModel updateAll_open(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateAll_open(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//手动/自动加载/突加突卸页面_全部分闸<socket>
|
public ServiceModel updateAll_openPLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,11,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getAll_open()));
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载页面_启动加减载
|
public ServiceModel updateStart_auto(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateStart_auto(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载页面_启动加减载<socket>
|
public ServiceModel updateStart_autoPLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,8,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getStart_auto()));
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载页面_停止加减载
|
public ServiceModel updateStop_auto(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateStop_auto(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载页面_停止加减载<socket>
|
public ServiceModel updateStop_autoPLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,9,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getStop_auto()));
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//突加突卸
|
public ServiceModel updateSudden_crease(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateSudden_crease(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//突加突卸<socket>
|
public ServiceModel updateSudden_creasePLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,10,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getSudden_crease()));
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//总突加突卸
|
public ServiceModel updateAllSudden_crease(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateAllSudden_crease(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//总突加突卸<socket>
|
public ServiceModel updateAllSudden_creasePLC(Object obj) {
|
List<Dynamicload_control> list=(List<Dynamicload_control>) obj;
|
boolean bl = false;
|
for (Dynamicload_control dtrol : list) {
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,10,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getSudden_crease()));
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
bl=false;
|
}
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//总全部分闸
|
public ServiceModel updatedoubAll_open(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updatedoubAll_open(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//总全部分闸<socket>
|
public ServiceModel updatedoubAll_openPLC(Object obj) {
|
List<Dynamicload_control> list=(List<Dynamicload_control>) obj;
|
boolean bl = false;
|
for (Dynamicload_control dtrol : list) {
|
BaseData basedata = new BaseData(Modbus_ComBase.WRITE_SINGLE_COIL,11,1);
|
byte[] b=basedata.createSingleCollWiriteData(basedata.createButtonByte(dtrol.getAll_open()));
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
bl=false;
|
}
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载/突加突卸页面_设定功率
|
public ServiceModel updateSet_power(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateSet_power(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载/突加突卸页面_设定功率<socket>
|
public ServiceModel updateSet_powerPLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata =null;
|
byte[] b;
|
if(dtrol.getNum()==11){
|
basedata=new BaseData(Modbus_ComBase.WRITE_SINGLE_REGISTER,4,1);
|
b=basedata.createSingleResWiriteData((basedata.createIntByte((int)dtrol.getSet_power())));
|
}else{
|
basedata=new BaseData(Modbus_ComBase.WRITE_MULTIPLE_REGISTER,8,2);
|
b=basedata.createWiriteData(basedata.createFloatByte((int)dtrol.getSet_power()));
|
}
|
//多点写入
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
//自动加载页面修改间隔时间
|
public ServiceModel updateInterval_time(Object obj) {
|
boolean bl=((Dynamicload_controlImpl)dao).updateInterval_time(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
|
//自动加载页面修改间隔时间<socket>
|
public ServiceModel updateInterval_timePLC(Object obj) {
|
Dynamicload_control dtrol=(Dynamicload_control) obj;
|
BaseData basedata =null;
|
if(dtrol.getNum()==11){
|
basedata=new BaseData(Modbus_ComBase.WRITE_SINGLE_REGISTER,6,1);
|
}else{
|
basedata=new BaseData(Modbus_ComBase.WRITE_SINGLE_REGISTER,16,1);
|
}
|
byte[] b=basedata.createSingleResWiriteData(basedata.createIntByte(dtrol.getInterval_time()));
|
boolean bl=false;
|
try {
|
bl = SocketClient.SocketComm(b, dtrol.getDev_ip());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
bl=false;
|
}
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
}
|
