|  | @@ -6,6 +6,7 @@ import com.cherry.sdk.controller.utils.ScanGunKeyEventHelper;
 | 
	
		
			
				|  |  |  import com.emato.ich.api.ICSPApi;
 | 
	
		
			
				|  |  |  import com.emato.ich.api.ICSPClient;
 | 
	
		
			
				|  |  |  import com.emato.ich.api.ICSPResponseCodeEnum;
 | 
	
		
			
				|  |  | +import com.emato.ich.contant.OpenLockerResponseEnum;
 | 
	
		
			
				|  |  |  import com.emato.ich.contant.SystemConfigConstant;
 | 
	
		
			
				|  |  |  import com.emato.ich.crash.CrashApplication;
 | 
	
		
			
				|  |  |  import com.emato.ich.device.DeviceControl;
 | 
	
	
		
			
				|  | @@ -220,7 +221,7 @@ public class MainActivity extends AppCompatActivity  {
 | 
	
		
			
				|  |  |                  MqttMessage mqttMessage;
 | 
	
		
			
				|  |  |                  if (var1 != 0) {
 | 
	
		
			
				|  |  |                      try {
 | 
	
		
			
				|  |  | -                        mqttMessage = wrapMessage(message, objectMapper);
 | 
	
		
			
				|  |  | +                        mqttMessage = wrapMessage(String.valueOf(var1), message, objectMapper);
 | 
	
		
			
				|  |  |                          ichPublishClient.publish(String.format(ICHTopic.CALLBACK_FAILED, BaseUtils.getClientId()), mqttMessage);
 | 
	
		
			
				|  |  |                          Log.i(TAG, "openLocker: ==================>发送开锁失败消息成功! 锁板id: " + message.getSection() + ", 端口: " + message.getPort());
 | 
	
		
			
				|  |  |                      } catch (JsonProcessingException e) {
 | 
	
	
		
			
				|  | @@ -253,7 +254,7 @@ public class MainActivity extends AppCompatActivity  {
 | 
	
		
			
				|  |  |  //                    } while(atomicBoolean.get());
 | 
	
		
			
				|  |  |                      try {
 | 
	
		
			
				|  |  |                          Log.i(TAG, "onCreate: =====================>开锁成功! 锁板id: " + message.getSection() + ", 端口: " + message.getPort());
 | 
	
		
			
				|  |  | -                        mqttMessage = wrapMessage(message, objectMapper);
 | 
	
		
			
				|  |  | +                        mqttMessage = wrapMessage(String.valueOf(var1), message, objectMapper);
 | 
	
		
			
				|  |  |  //                        if (atomicInteger.get() <= 0) {
 | 
	
		
			
				|  |  |  //                            message.setCause("长时间未关闭柜门!");
 | 
	
		
			
				|  |  |  //                            mqttMessage.setPayload(objectMapper.writeValueAsBytes(message));
 | 
	
	
		
			
				|  | @@ -351,11 +352,11 @@ public class MainActivity extends AppCompatActivity  {
 | 
	
		
			
				|  |  |                  || super.onSupportNavigateUp();
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    private MqttMessage wrapMessage(Message message, ObjectMapper objectMapper) throws JsonProcessingException {
 | 
	
		
			
				|  |  | +    private MqttMessage wrapMessage(String code, Message message, ObjectMapper objectMapper) throws JsonProcessingException {
 | 
	
		
			
				|  |  |          MqttMessage mqttMessage = new MqttMessage();
 | 
	
		
			
				|  |  |          Message failedMsg = new Message();
 | 
	
		
			
				|  |  |          // TODO 失败原因枚举
 | 
	
		
			
				|  |  | -        failedMsg.setCause("失败原因枚举");
 | 
	
		
			
				|  |  | +        failedMsg.setCause(OpenLockerResponseEnum.getResponseInfo(code));
 | 
	
		
			
				|  |  |          failedMsg.setMessageId(message.getMessageId());
 | 
	
		
			
				|  |  |          failedMsg.setClientId(message.getClientId());
 | 
	
		
			
				|  |  |          failedMsg.setCmd(message.getCmd());
 |