Commit b69c9af7 authored by 赵啸非's avatar 赵啸非

添加皮肤feign接口

parent 0183b87a
......@@ -95,7 +95,7 @@
);
},},
{
label: "默认选择",
label: "皮肤选择",
align: "center",
prop: "used",
formatter: (row) => {
......
package com.mortals.xhx.module.skin.service.impl;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.mortals.framework.common.Rest;
import com.mortals.framework.exception.AppException;
import com.mortals.framework.model.Context;
import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
import com.mortals.xhx.common.code.YesNoEnum;
import com.mortals.xhx.common.pdu.RespData;
import com.mortals.xhx.common.pdu.UploadDeviceReq;
import com.mortals.xhx.common.pdu.skin.SkinBasePdu;
import com.mortals.xhx.common.utils.BeanUtil;
import com.mortals.xhx.feign.device.IDeviceMessageFeign;
import com.mortals.xhx.feign.skin.ISkinBaseFeign;
import com.mortals.xhx.module.device.model.DeviceEntity;
import com.mortals.xhx.module.device.model.DeviceQuery;
import com.mortals.xhx.module.device.service.DeviceService;
import com.mortals.xhx.module.skin.dao.SkinDao;
import com.mortals.xhx.module.skin.model.SkinEntity;
import com.mortals.xhx.module.skin.model.SkinQuery;
......@@ -20,6 +26,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.Map;
......@@ -39,6 +46,11 @@ public class SkinServiceImpl extends AbstractCRUDServiceImpl<SkinDao, SkinEntity
@Autowired
private ISkinBaseFeign skinBaseFeign;
@Autowired
private IDeviceMessageFeign messageFeign;
@Autowired
private DeviceService deviceService;
@Override
public Rest<Void> appUsed(SkinEntity skinEntity, Context context) {
......@@ -50,6 +62,11 @@ public class SkinServiceImpl extends AbstractCRUDServiceImpl<SkinDao, SkinEntity
skinEntity.setUsed(YesNoEnum.YES.getValue());
skinEntity.setUpdateTime(new Date());
this.getDao().update(skinEntity);
deviceService.find(new DeviceQuery()).forEach(item->{
notifyDevice(item);
});
return Rest.ok("使用应用成功!");
}
......@@ -65,9 +82,21 @@ public class SkinServiceImpl extends AbstractCRUDServiceImpl<SkinDao, SkinEntity
SkinEntity condition = new SkinEntity();
condition.setUsed(YesNoEnum.YES.getValue());
this.updateBatch(skinEntity,condition,context);
deviceService.find(new DeviceQuery()).forEach(item->{
notifyDevice(item);
});
}
}
private void notifyDevice(DeviceEntity entity) {
UploadDeviceReq uploadDeviceReq = new UploadDeviceReq();
uploadDeviceReq.setDeviceCodeList(Arrays.asList(entity.getDeviceCode()));
uploadDeviceReq.setAction("edition");
log.info("downMsg:{}", JSON.toJSONString(uploadDeviceReq));
messageFeign.downMsg(uploadDeviceReq);
}
@Override
public void syncSkin() {
SkinBasePdu skinBasePdu = new SkinBasePdu();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment