From 4fbcb5f2879f97f8f91d134414f835819510dfcf Mon Sep 17 00:00:00 2001 From: hupeng Date: Wed, 20 Feb 2019 12:51:10 +0800 Subject: [PATCH] =?UTF-8?q?[=E9=9C=80=E6=B1=82][=E6=96=B0=E5=A2=9E]:?= =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=AE=BE=E5=A4=87=E7=AE=A1=E7=90=86=E8=A1=A8?= =?UTF-8?q?,=E5=A4=A7=E5=B1=8F=E5=B9=BF=E5=91=8A=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/domain/po/WxDevice.java | 241 ++++++++++++++++++ .../com/iformall/domain/po/WxScreenAd.java | 176 +++++++++++++ .../com/iformall/enums/EnumDeviceHbCmd.java | 34 +++ .../enums/EnumDeviceOnlineStatus.java | 34 +++ .../com/iformall/enums/EnumDeviceStatus.java | 35 +++ .../com/iformall/enums/EnumDeviceType.java | 33 +++ .../iformall/enums/EnumScreenAdStatus.java | 34 +++ .../com/iformall/enums/EnumScreenAdType.java | 34 +++ .../com/iformall/mapper/WxDeviceMapper.java | 12 + .../com/iformall/mapper/WxScreenAdMapper.java | 13 + .../com/iformall/service/WxDeviceService.java | 58 +++++ .../iformall/service/WxScreenAdService.java | 58 +++++ .../service/impl/WxDeviceServiceImpl.java | 55 ++++ .../service/impl/WxScreenAdServiceImpl.java | 55 ++++ .../main/resources/mapper/WxDeviceMapper.xml | 92 +++++++ 15 files changed, 964 insertions(+) create mode 100644 mallinkService/src/main/java/com/iformall/domain/po/WxDevice.java create mode 100644 mallinkService/src/main/java/com/iformall/domain/po/WxScreenAd.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumDeviceHbCmd.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumDeviceOnlineStatus.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumDeviceStatus.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumDeviceType.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumScreenAdStatus.java create mode 100644 mallinkService/src/main/java/com/iformall/enums/EnumScreenAdType.java create mode 100644 mallinkService/src/main/java/com/iformall/mapper/WxDeviceMapper.java create mode 100644 mallinkService/src/main/java/com/iformall/mapper/WxScreenAdMapper.java create mode 100644 mallinkService/src/main/java/com/iformall/service/WxDeviceService.java create mode 100644 mallinkService/src/main/java/com/iformall/service/WxScreenAdService.java create mode 100644 mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java create mode 100644 mallinkService/src/main/java/com/iformall/service/impl/WxScreenAdServiceImpl.java create mode 100644 mallinkService/src/main/resources/mapper/WxDeviceMapper.xml diff --git a/mallinkService/src/main/java/com/iformall/domain/po/WxDevice.java b/mallinkService/src/main/java/com/iformall/domain/po/WxDevice.java new file mode 100644 index 000000000..03ff7f056 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/domain/po/WxDevice.java @@ -0,0 +1,241 @@ +package com.iformall.domain.po; + +import javax.persistence.Id; +import javax.persistence.Table; +import javax.persistence.Transient; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +@Table(name = "wx_device") +public class WxDevice implements Serializable { + private static final long serialVersionUID = 1L; + + @Id + protected Long id; + + @Transient + protected List ids; + @Transient + protected String sortColumns; + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getSortColumns() { + return sortColumns; + } + + public List getIds() { + return ids; + } + + public void setIds(List ids) { + this.ids = ids; + } + + /**租户id**/ + @io.swagger.annotations.ApiModelProperty(value="租户id",name="tenantId") + private String tenantId; + + /**设备id**/ + @io.swagger.annotations.ApiModelProperty(value="设备id",name="deviceId") + private Integer deviceId; + + /**设备类型**/ + @io.swagger.annotations.ApiModelProperty(value="设备类型",name="type") + private Integer type; + + /**设备状态**/ + @io.swagger.annotations.ApiModelProperty(value="设备状态",name="status") + private Integer status; + + /**版本号信息**/ + @io.swagger.annotations.ApiModelProperty(value="版本号信息",name="version") + private String version; + + /**创建时间**/ + @io.swagger.annotations.ApiModelProperty(value="创建时间",name="createDate") + private Date createDate; + + /**更新时间**/ + @io.swagger.annotations.ApiModelProperty(value="更新时间",name="updateDate") + private Date updateDate; + + /**在线状态**/ + @io.swagger.annotations.ApiModelProperty(value="在线状态",name="onlineStatus") + private Integer onlineStatus; + + /**第一次连线时间**/ + @io.swagger.annotations.ApiModelProperty(value="第一次连线时间",name="firstHbTime") + private Date firstHbTime; + + /**最后一次在线时间**/ + @io.swagger.annotations.ApiModelProperty(value="最后一次在线时间",name="lastHbTime") + private Date lastHbTime; + + /**需要执行的命令**/ + @io.swagger.annotations.ApiModelProperty(value="最后一次在线时间",name="hbCmd") + private Date hbCmd; + + public String getTenantId() { + return tenantId; + } + public void setTenantId(String _tenantId) { + tenantId = _tenantId; + } + + public Integer getDeviceId() { + return deviceId; + } + + public void setDeviceId(Integer deviceId) { + this.deviceId = deviceId; + } + + public Integer getType() { + return type; + } + + public void setType(Integer type) { + this.type = type; + } + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + + public String getVersion() { + return version; + } + + public void setVersion(String version) { + this.version = version; + } + + public Date getCreateDate() { + return createDate; + } + + public void setCreateDate(Date createDate) { + this.createDate = createDate; + } + + public Date getUpdateDate() { + return updateDate; + } + + public void setUpdateDate(Date updateDate) { + this.updateDate = updateDate; + } + + public Integer getOnlineStatus() { + return onlineStatus; + } + + public void setOnlineStatus(Integer onlineStatus) { + this.onlineStatus = onlineStatus; + } + + public Date getFirstHbTime() { + return firstHbTime; + } + + public void setFirstHbTime(Date firstHbTime) { + this.firstHbTime = firstHbTime; + } + + public Date getLastHbTime() { + return lastHbTime; + } + + public void setLastHbTime(Date lastHbTime) { + this.lastHbTime = lastHbTime; + } + + public Date getHbCmd() { + return hbCmd; + } + + public void setHbCmd(Date hbCmd) { + this.hbCmd = hbCmd; + } + + public static enum Field + { + Id_ASC("`id` ASC"),Id_DESC("`id` DESC") + ,TenantId_ASC("`tenant_id` ASC"),TenantId_DESC("`tenant_id` DESC") + ,DeviceId_ASC("`device_id` ASC"),DeviceId_DESC("`device_id` DESC") + ,Type_ASC("`type` ASC"),Type_DESC("`type` DESC") + ,Status_ASC("`status` ASC"),Status_DESC("`status` DESC") + ,Version_ASC("`version` ASC"),Version_DESC("`version` DESC") + ,CreateDate_ASC("`create_date` ASC"),CreateDate_DESC("`create_date` DESC") + ,UpdateDate_ASC("`update_date` ASC"),UpdateDate_DESC("`update_date` DESC") + ,LastHbTime_ASC("`last_hb_time` ASC"),LastHbTime_DESC("`last_hb_time` DESC") + ,FirstHbTime_ASC("`first_hb_time` ASC"),FirstHbTime_DESC("`first_hb_time` DESC") + ,OnlineStatus_ASC("`online_status` ASC"),OnlineStatus_DESC("`online_status` DESC") + ,HbCmd_ASC("`hb_cmd` ASC"),HbCmd_DESC("`hb_cmd` DESC") + ; + private String value; + Field(String value){ + this.value = value; + } + public String getValue() { + return value; + } + public void setCol(String value) { + this.value = value; + } + @Override + public String toString() { + return this.getValue(); + } + } + + public void setSortColumns(WxDevice.Field... fields) + { + if (fields == null || fields.length == 0) { + return; + } + for (int k = 0; k < fields.length; k++) { + if (fields[k] == null) { + return; + } + } + StringBuilder sb = new StringBuilder(fields[0].toString()); + for (int k = 1; k < fields.length; k++) { + sb.append(","); + sb.append(fields[k].toString()); + } + + this.sortColumns = sb.toString(); + + } + + public void setSortColumns(String sortColumns) + { + if (sortColumns == null || "".equals(sortColumns.trim())) { + return; + } + if (sortColumns.contains(",")) { + String[] cols = sortColumns.split(","); + List fList = new ArrayList(); + for (int k = 0; k < cols.length; k++) { + fList.add(Field.valueOf(cols[k])); + } + this.setSortColumns(fList.toArray(new Field[fList.size()])); + } else { + this.setSortColumns(Field.valueOf(sortColumns)); + } + } +} diff --git a/mallinkService/src/main/java/com/iformall/domain/po/WxScreenAd.java b/mallinkService/src/main/java/com/iformall/domain/po/WxScreenAd.java new file mode 100644 index 000000000..46e5e6e77 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/domain/po/WxScreenAd.java @@ -0,0 +1,176 @@ +package com.iformall.domain.po; + +import javax.persistence.Id; +import javax.persistence.Table; +import javax.persistence.Transient; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +@Table(name = "wx_screen_ad") +public class WxScreenAd implements Serializable { + private static final long serialVersionUID = 1L; + + @Id + protected Long id; + + @Transient + protected List ids; + @Transient + protected String sortColumns; + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getSortColumns() { + return sortColumns; + } + + public List getIds() { + return ids; + } + + public void setIds(List ids) { + this.ids = ids; + } + + /**租户id**/ + @io.swagger.annotations.ApiModelProperty(value="租户id",name="tenantId") + private String tenantId; + + /**广告类型**/ + @io.swagger.annotations.ApiModelProperty(value="广告类型",name="type") + private Integer type; + + /**广告状态**/ + @io.swagger.annotations.ApiModelProperty(value="设备状态",name="status") + private Integer status; + + /**创建时间**/ + @io.swagger.annotations.ApiModelProperty(value="创建时间",name="createDate") + private Date createDate; + + /**更新时间**/ + @io.swagger.annotations.ApiModelProperty(value="更新时间",name="updateDate") + private Date updateDate; + + /**封面**/ + @io.swagger.annotations.ApiModelProperty(value="封面",name="coverImg") + private String coverImg; + + public String getTenantId() { + return tenantId; + } + + public void setTenantId(String tenantId) { + this.tenantId = tenantId; + } + + public Integer getType() { + return type; + } + + public void setType(Integer type) { + this.type = type; + } + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + + public Date getCreateDate() { + return createDate; + } + + public void setCreateDate(Date createDate) { + this.createDate = createDate; + } + + public Date getUpdateDate() { + return updateDate; + } + + public void setUpdateDate(Date updateDate) { + this.updateDate = updateDate; + } + + public String getCoverImg() { + return coverImg; + } + + public void setCoverImg(String coverImg) { + this.coverImg = coverImg; + } + + public static enum Field + { + Id_ASC("`id` ASC"),Id_DESC("`id` DESC") + ,TenantId_ASC("`tenant_id` ASC"),TenantId_DESC("`tenant_id` DESC") + ,Type_ASC("`type` ASC"),Type_DESC("`type` DESC") + ,Status_ASC("`status` ASC"),Status_DESC("`status` DESC") + ,CreateDate_ASC("`create_date` ASC"),CreateDate_DESC("`create_date` DESC") + ,UpdateDate_ASC("`update_date` ASC"),UpdateDate_DESC("`update_date` DESC") + ; + private String value; + Field(String value){ + this.value = value; + } + public String getValue() { + return value; + } + public void setCol(String value) { + this.value = value; + } + @Override + public String toString() { + return this.getValue(); + } + } + + public void setSortColumns(WxScreenAd.Field... fields) + { + if (fields == null || fields.length == 0) { + return; + } + for (int k = 0; k < fields.length; k++) { + if (fields[k] == null) { + return; + } + } + StringBuilder sb = new StringBuilder(fields[0].toString()); + for (int k = 1; k < fields.length; k++) { + sb.append(","); + sb.append(fields[k].toString()); + } + + this.sortColumns = sb.toString(); + + } + + public void setSortColumns(String sortColumns) + { + if (sortColumns == null || "".equals(sortColumns.trim())) { + return; + } + if (sortColumns.contains(",")) { + String[] cols = sortColumns.split(","); + List fList = new ArrayList(); + for (int k = 0; k < cols.length; k++) { + fList.add(Field.valueOf(cols[k])); + } + this.setSortColumns(fList.toArray(new Field[fList.size()])); + } else { + this.setSortColumns(Field.valueOf(sortColumns)); + } + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumDeviceHbCmd.java b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceHbCmd.java new file mode 100644 index 000000000..de1e2efeb --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceHbCmd.java @@ -0,0 +1,34 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumDeviceHbCmd { + + CMD_NULL(0, "无"), + CMD_POWER_OFF(1, "关机"); + public static EnumDeviceHbCmd getEnum(Integer code) { + for (EnumDeviceHbCmd value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumDeviceHbCmd(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumDeviceOnlineStatus.java b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceOnlineStatus.java new file mode 100644 index 000000000..753d6e4f6 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceOnlineStatus.java @@ -0,0 +1,34 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumDeviceOnlineStatus { + + OFFLINE(0, "离线"), + ONLINE(1, "在线"); + public static EnumDeviceOnlineStatus getEnum(Integer code) { + for (EnumDeviceOnlineStatus value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumDeviceOnlineStatus(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumDeviceStatus.java b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceStatus.java new file mode 100644 index 000000000..63c4a407a --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceStatus.java @@ -0,0 +1,35 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumDeviceStatus { + + INIT(0, "初始化"), + VALID(1, "有效"), + INVALID(2, "无效"); + public static EnumDeviceStatus getEnum(Integer code) { + for (EnumDeviceStatus value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumDeviceStatus(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumDeviceType.java b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceType.java new file mode 100644 index 000000000..e9a5b52c6 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumDeviceType.java @@ -0,0 +1,33 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumDeviceType { + + SCREEN(0, "广告屏"); + public static EnumDeviceType getEnum(Integer code) { + for (EnumDeviceType value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumDeviceType(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdStatus.java b/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdStatus.java new file mode 100644 index 000000000..33ae64701 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdStatus.java @@ -0,0 +1,34 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumScreenAdStatus { + + VALID(0, "有效"), + INVALID(1, "无效"); + public static EnumScreenAdStatus getEnum(Integer code) { + for (EnumScreenAdStatus value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumScreenAdStatus(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdType.java b/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdType.java new file mode 100644 index 000000000..748e85064 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/enums/EnumScreenAdType.java @@ -0,0 +1,34 @@ +package com.iformall.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumScreenAdType { + + COUPON(0, "券"), + CAMPAIGN(1, "宣传页"); + public static EnumScreenAdType getEnum(Integer code) { + for (EnumScreenAdType value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumScreenAdType(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +} diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxDeviceMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxDeviceMapper.java new file mode 100644 index 000000000..ab43d5cd2 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/mapper/WxDeviceMapper.java @@ -0,0 +1,12 @@ +package com.iformall.mapper; + +import com.iformall.common.CommonMapper; +import com.iformall.domain.po.WxDevice; + +import java.util.List; + +public interface WxDeviceMapper extends CommonMapper { + + List findList(WxDevice wxDevice); + +} diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxScreenAdMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxScreenAdMapper.java new file mode 100644 index 000000000..4877477ad --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/mapper/WxScreenAdMapper.java @@ -0,0 +1,13 @@ +package com.iformall.mapper; + +import com.iformall.common.CommonMapper; +import com.iformall.domain.po.WxScreenAd; + + +import java.util.List; + +public interface WxScreenAdMapper extends CommonMapper { + + List findList(WxScreenAd wxScreenAd); + +} diff --git a/mallinkService/src/main/java/com/iformall/service/WxDeviceService.java b/mallinkService/src/main/java/com/iformall/service/WxDeviceService.java new file mode 100644 index 000000000..4b0dec811 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/WxDeviceService.java @@ -0,0 +1,58 @@ +package com.iformall.service; + + +import com.github.pagehelper.PageInfo; +import com.iformall.domain.po.WxDevice; + +import java.util.List; + +public interface WxDeviceService { + + + + /** + * 根据实体查询分页列表 + * + * @param record + * @param pageIndex + * @param pageSize + * @return + */ + PageInfo listAsPage(WxDevice record, Integer pageIndex, Integer pageSize); + + + /** + * 根据Id获得实体 + * + * @param id + * @return + */ + WxDevice getById(Long id); + + /** + * 保存或更新实体 + * + * @param record + */ + void saveOrUpdate(WxDevice record); + + + /** + * 根据Id删除实体 + * + * @param id + */ + void deleteById(Long id); + + + /** + * 根据实体查询分页列表 + * + * @param record + * @return + */ + List findList(WxDevice record); + + + +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/WxScreenAdService.java b/mallinkService/src/main/java/com/iformall/service/WxScreenAdService.java new file mode 100644 index 000000000..8375cdae2 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/WxScreenAdService.java @@ -0,0 +1,58 @@ +package com.iformall.service; + + +import com.github.pagehelper.PageInfo; +import com.iformall.domain.po.WxScreenAd; + +import java.util.List; + +public interface WxScreenAdService { + + + + /** + * 根据实体查询分页列表 + * + * @param record + * @param pageIndex + * @param pageSize + * @return + */ + PageInfo listAsPage(WxScreenAd record, Integer pageIndex, Integer pageSize); + + + /** + * 根据Id获得实体 + * + * @param id + * @return + */ + WxScreenAd getById(Long id); + + /** + * 保存或更新实体 + * + * @param record + */ + void saveOrUpdate(WxScreenAd record); + + + /** + * 根据Id删除实体 + * + * @param id + */ + void deleteById(Long id); + + + /** + * 根据实体查询分页列表 + * + * @param record + * @return + */ + List findList(WxScreenAd record); + + + +} diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java new file mode 100644 index 000000000..63f2b0b14 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxDeviceServiceImpl.java @@ -0,0 +1,55 @@ +package com.iformall.service.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.iformall.common.IdWorker; + +import com.iformall.domain.po.WxDevice; +import com.iformall.mapper.WxDeviceMapper; +import com.iformall.service.WxDeviceService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + + +@Service +public class WxDeviceServiceImpl implements WxDeviceService { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + WxDeviceMapper wxDeviceMapper; + + @Override + public PageInfo listAsPage(WxDevice record, Integer pageIndex, Integer pageSize) { + return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxDeviceMapper.findList(record)); + } + + @Override + public WxDevice getById(Long id) { + return wxDeviceMapper.selectByPrimaryKey(id); + } + + @Override + public void saveOrUpdate(WxDevice record) { + if (record.getId() == null) { + final IdWorker idWorker = IdWorker.get(); + record.setId(idWorker.nextId()); + wxDeviceMapper.insertSelective(record); + } else { + wxDeviceMapper.updateByPrimaryKeySelective(record); + } + } + + @Override + public void deleteById(Long id) { + wxDeviceMapper.deleteByPrimaryKey(id); + } + @Override + public List findList(WxDevice wxDevice) { + return wxDeviceMapper.findList(wxDevice); + } + +} diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxScreenAdServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxScreenAdServiceImpl.java new file mode 100644 index 000000000..b6f58b0db --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxScreenAdServiceImpl.java @@ -0,0 +1,55 @@ +package com.iformall.service.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.iformall.common.IdWorker; + +import com.iformall.domain.po.WxScreenAd; +import com.iformall.mapper.WxScreenAdMapper; +import com.iformall.service.WxScreenAdService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Service +public class WxScreenAdServiceImpl implements WxScreenAdService { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + WxScreenAdMapper wxScreenAdMapper; + + @Override + public PageInfo listAsPage(WxScreenAd record, Integer pageIndex, Integer pageSize) { + return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxScreenAdMapper.findList(record)); + } + + @Override + public WxScreenAd getById(Long id) { + return wxScreenAdMapper.selectByPrimaryKey(id); + } + + @Override + public void saveOrUpdate(WxScreenAd record) { + if (record.getId() == null) { + //record.setId(UUID.randomUUID().toString().replaceAll("-", "")); + final IdWorker idWorker = IdWorker.get(); + record.setId(idWorker.nextId()); + wxScreenAdMapper.insertSelective(record); + } else { + wxScreenAdMapper.updateByPrimaryKeySelective(record); + } + } + + @Override + public void deleteById(Long id) { + wxScreenAdMapper.deleteByPrimaryKey(id); + } + @Override + public List findList(WxScreenAd wxTagsType) { + return wxScreenAdMapper.findList(wxTagsType); + } + +} diff --git a/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml b/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml new file mode 100644 index 000000000..079dda52a --- /dev/null +++ b/mallinkService/src/main/resources/mapper/WxDeviceMapper.xml @@ -0,0 +1,92 @@ + + + + + + + + + + + + + + + + + + + + `id`, `tenant_id`, `device_id`, `type`, `status`, `version`, `create_date`, `update_date`, `online_status`, `first_hb_time`, `last_hb_time`, `hb_cmd` + + + + where 1 = 1 + + + and `id` = #{id} + + + + and `tenant_id` = #{tenantId} + + + + and `device_id` = #{deviceId} + + + + and `type` = #{type} + + + + and `status` = #{status} + + + + and `version` = #{version} + + + + and `create_date` = #{createDate} + + + + and `update_date` = #{updateDate} + + + + and `online_status` = #{onlineStatus} + + + + and `first_hb_time` = #{firstHbTime} + + + + and `last_hb_time` = #{lastHbTime} + + + + and `hb_cmd` = #{hbCmd} + + + + + and id in + + #{idItem} + + + order by ${sortColumns} + + + + + +