|
@@ -10,6 +10,7 @@ import android.util.Log
|
|
|
import com.google.gson.Gson
|
|
|
import com.hboxs.serialport.plc.message.Message
|
|
|
import com.hboxs.serialport.plc.thread.ThreadSettingParam
|
|
|
+import com.hboxs.serialport.sbc.SBCHeartbeat
|
|
|
import com.qiniu.android.http.ResponseInfo
|
|
|
import com.qiniu.android.storage.UpCompletionHandler
|
|
|
import com.qiniu.android.storage.UploadManager
|
|
@@ -22,6 +23,7 @@ import com.quyunshuo.module.home.getui.MqttBaseBean
|
|
|
import com.quyunshuo.sbm10.base.BaseApplication
|
|
|
import com.quyunshuo.sbm10.base.BaseApplication.Companion.context
|
|
|
import com.quyunshuo.sbm10.base.addressenum.PlcSettingAddressEnum
|
|
|
+import com.quyunshuo.sbm10.base.utils.GsonUtil
|
|
|
import com.quyunshuo.sbm10.base.utils.JsonUtils
|
|
|
import com.quyunshuo.sbm10.base.utils.SpUtils
|
|
|
import com.quyunshuo.sbm10.base.utils.XLogUtil
|
|
@@ -216,30 +218,32 @@ class RemotePushUtil @Inject constructor() {
|
|
|
}
|
|
|
|
|
|
MqName.ELIMINATE -> {
|
|
|
- val map =setMap(msgId,"1")
|
|
|
+ val map = setMap(msgId, "1")
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MMKVName.CLEAR_ELIMINATE_REMOTE, map))
|
|
|
}
|
|
|
|
|
|
MqName.MATERIAL -> {
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
- if (DataBean.kind_data=="1"){
|
|
|
- SpUtils.putBoolean(MMKVName.MATERIAL,true)
|
|
|
- }else{
|
|
|
- SpUtils.putBoolean(MMKVName.MATERIAL,false)
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
+ if (DataBean.kind_data == "1") {
|
|
|
+ SpUtils.putBoolean(MMKVName.MATERIAL, true)
|
|
|
+ } else {
|
|
|
+ SpUtils.putBoolean(MMKVName.MATERIAL, false)
|
|
|
}
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.MATERIAL, map))
|
|
|
}
|
|
|
- MqName.SLEEP ->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+
|
|
|
+ MqName.SLEEP -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.SLEEP, map))
|
|
|
}
|
|
|
- MqName.RESTARTANDROID ->{
|
|
|
- if (Build.MODEL.equals("rk3566_r")){
|
|
|
+
|
|
|
+ MqName.RESTARTANDROID -> {
|
|
|
+ if (Build.MODEL.equals("rk3566_r")) {
|
|
|
val mManager: XzjhSystemManager =
|
|
|
context.getSystemService("xzjh_server") as XzjhSystemManager
|
|
|
mManager.xzjhRebootSys(false)
|
|
|
XLogUtil.d("重启屏幕成功")
|
|
|
- }else if (Build.MODEL.equals("rk3288")){
|
|
|
+ } else if (Build.MODEL.equals("rk3288")) {
|
|
|
try {
|
|
|
val proc = Runtime.getRuntime().exec(arrayOf("su", "-c", "reboot"))
|
|
|
proc.waitFor()
|
|
@@ -250,23 +254,23 @@ class RemotePushUtil @Inject constructor() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- MqName.PASSWORD->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+ MqName.PASSWORD -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.PASSWORD, map))
|
|
|
}
|
|
|
|
|
|
- MqName.VOLUME->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+ MqName.VOLUME -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.VOLUME, map))
|
|
|
}
|
|
|
|
|
|
- MqName.UPDATEPRODUCT->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
- Log.d(TAG, "getMqttMessageUPDATEPRODUCT: "+map)
|
|
|
+ MqName.UPDATEPRODUCT -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
+ Log.d(TAG, "getMqttMessageUPDATEPRODUCT: " + map)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.UPDATEPRODUCT, map))
|
|
|
}
|
|
|
|
|
|
- MqName.EQESTATUS->{
|
|
|
+ MqName.EQESTATUS -> {
|
|
|
//开机了则不能开机了。
|
|
|
//LogUtils.logWrite("定时开机:"+open);
|
|
|
// EventBus.getDefault().post(new ApiMessageEvent(AlarmClockEnum.OPEN_DEV.getContent(), "开机"));
|
|
@@ -283,43 +287,80 @@ class RemotePushUtil @Inject constructor() {
|
|
|
"netTime" to ld,
|
|
|
"eqeStatus" to DataBean.kind_data
|
|
|
)
|
|
|
- val map =setMap(msgId,responseContent)
|
|
|
+ val map = setMap(msgId, responseContent)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.EQESTATUS, map))
|
|
|
}
|
|
|
- MqName.OPENDOOR->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+
|
|
|
+ MqName.OPENDOOR -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.OPENDOOR, map))
|
|
|
}
|
|
|
- MqName.PHONE->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+
|
|
|
+ MqName.PHONE -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.PHONE, map))
|
|
|
}
|
|
|
- MqName.SLEEPDESC->{
|
|
|
+
|
|
|
+ MqName.SLEEPDESC -> {
|
|
|
val responseContent = hashMapOf(
|
|
|
"sleepDesc" to DataBean.kind_data
|
|
|
)
|
|
|
- val map =setMap(msgId,responseContent)
|
|
|
+ val map = setMap(msgId, responseContent)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.SLEEPDESC, map))
|
|
|
}
|
|
|
|
|
|
- MqName.UPDATELOGO->{
|
|
|
+ MqName.UPDATELOGO -> {
|
|
|
val data = DataBean.kind_data
|
|
|
val logo: String
|
|
|
- if (data=="0000"||data=="1"||data=="2"||data=="7777"){
|
|
|
+ if (data == "0000" || data == "1" || data == "2" || data == "7777") {
|
|
|
logo = data
|
|
|
- }else{
|
|
|
- logo = SpUtils.getString(MMKVName.LOGO_TEXT,"7777").toString()
|
|
|
+ } else {
|
|
|
+ logo = SpUtils.getString(MMKVName.LOGO_TEXT, "7777").toString()
|
|
|
}
|
|
|
- SpUtils.putString(MMKVName.LOGO_TEXT,logo)
|
|
|
+ SpUtils.putString(MMKVName.LOGO_TEXT, logo)
|
|
|
}
|
|
|
- MqName.BATCHUPDATEPRICE->{
|
|
|
- val map =setMap(msgId,DataBean.kind_data)
|
|
|
+
|
|
|
+ MqName.BATCHUPDATEPRICE -> {
|
|
|
+ val map = setMap(msgId, DataBean.kind_data)
|
|
|
EventBus.getDefault().post(ApiMessageEvent(MqName.BATCHUPDATEPRICE, map))
|
|
|
}
|
|
|
+
|
|
|
+ MqName.PRODUCEGOODS -> {
|
|
|
+ val no = GsonUtil.getAsString(DataBean.kind_data,"no","")
|
|
|
+ val productNo = GsonUtil.getAsString(DataBean.kind_data,"productNo","")
|
|
|
+ val status: String
|
|
|
+ var note =""
|
|
|
+ if (SBCHeartbeat.devCode=="02"){
|
|
|
+ status="1"
|
|
|
+ }else{
|
|
|
+ status="2"
|
|
|
+ if (SBCHeartbeat.devCode=="00"){
|
|
|
+ note = "刚上电"
|
|
|
+ }else if (SBCHeartbeat.devCode=="01"){
|
|
|
+ note = "开机中"
|
|
|
+ }else if (SBCHeartbeat.devCode=="03"){
|
|
|
+ note = "机器报警中"
|
|
|
+ }else if(SBCHeartbeat.devCode=="04"||SBCHeartbeat.devCode=="05"||
|
|
|
+ SBCHeartbeat.devCode=="07"||SBCHeartbeat.devCode=="10"){
|
|
|
+ note = "机器正在制作中"
|
|
|
+ }else{
|
|
|
+ note = "未知错误:"+SBCHeartbeat.devCode
|
|
|
+ }
|
|
|
+ }
|
|
|
+ val responseContent = hashMapOf(
|
|
|
+ "note" to note,
|
|
|
+ "status" to status,
|
|
|
+ "no" to no,
|
|
|
+ "productNo" to productNo
|
|
|
+ )
|
|
|
+ val map = setMap(msgId, responseContent)
|
|
|
+ Log.d(TAG, "PRODUCEGOODSgetMqttMessage: "+Gson().toJson(map))
|
|
|
+ EventBus.getDefault().post(ApiMessageEvent(MqName.PRODUCEGOODS, Gson().toJson(map)))
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private fun setMap(msgId:String,response:Any): HashMap<String, *> {
|
|
|
+ private fun setMap(msgId: String, response: Any): HashMap<String, *> {
|
|
|
val map = hashMapOf(
|
|
|
"clientId" to Heartbeat.deviceId,
|
|
|
"responseContent" to response,
|