Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity

java110

2020-12-10 9943c60aca4c93600e54479d919d377e08a12ef4

 service-job/src/main/java/com/java110/job/adapt/ximoIot/XimoDeleteMachineTransactionIotAdapt.java

@@ -20,10 +20,9 @@
import com.java110.dto.machine.MachineDto;
import com.java110.entity.order.Business;
import com.java110.intf.common.IMachineInnerServiceSMO;
import com.java110.job.adapt.IDatabusAdapt;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.job.adapt.ximoIot.asyn.IXimoMachineAsyn;
import com.java110.po.machine.MachinePo;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -38,7 +37,7 @@
 * @desc add by 吴学文 18:58
 */
@Component(value = "ximoDeleteMachineTransactionIotAdapt")
public class XimoDeleteMachineTransactionIotAdapt implements IDatabusAdapt {
public class XimoDeleteMachineTransactionIotAdapt extends DatabusAdaptImpl {

    @Autowired
    private IXimoMachineAsyn ximoMachineAsynImpl;
@@ -67,6 +66,8 @@
            if (bObj instanceof JSONObject) {
                businessMachines = new JSONArray();
                businessMachines.add(bObj);
            } else if (bObj instanceof List) {
                businessMachines = JSONArray.parseArray(JSONObject.toJSONString(bObj));
            } else {
                businessMachines = (JSONArray) bObj;
            }
@@ -83,15 +84,15 @@
        MachinePo machinePo = BeanConvertUtil.covertBean(businessMachine, MachinePo.class);
        MachineDto machineDto = new MachineDto();
        machineDto.setMachineId(machinePo.getMachineId());
        List<MachineDto> machineDtos = machineInnerServiceSMOImpl.queryMachines(machineDto);

        Assert.listOnlyOne(machineDtos, "未找到设备");
//        List<MachineDto> machineDtos = machineInnerServiceSMOImpl.queryMachines(machineDto);
//
//        Assert.listOnlyOne(machineDtos, "未找到设备");

        MultiValueMap<String, Object> postParameters = new LinkedMultiValueMap<>();

        postParameters.add("extCommunityUuid", machineDtos.get(0));
        //postParameters.add("devSn", machinePo.getMachineCode());
        postParameters.add("uuids", machinePo.getMachineId());
        postParameters.add("extCommunityUuid", machinePo.getCommunityId());
        postParameters.add("devSns", machinePo.getMachineCode());
        //postParameters.add("uuids", machinePo.getMachineId());
        ximoMachineAsynImpl.deleteSend(postParameters);
    }
}