diff --git a/pom.xml b/pom.xml
index a1f58ce..69dcae7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -69,13 +69,13 @@
hibernate-core
4.3.11.Final
-
+
org.jboss.logging
jboss-logging-annotations
2.0.1.Final
-
+
commons-fileupload
commons-fileupload
@@ -119,24 +119,11 @@
2.5.3
-
- org.slf4j
- slf4j-api
- 1.7.12
-
-
ch.qos.logback
logback-core
1.1.2
-
-
- ch.qos.logback
- logback-classic
- 1.1.2
-
-
org.apache.mina
mina-core
@@ -241,11 +228,6 @@
slf4j-api
1.7.5
-
- org.slf4j
- slf4j-log4j12
- 1.7.5
-
org.projectlombok
lombok
diff --git a/src/main/java/com/ifish/action/UpdateUserAction.java b/src/main/java/com/ifish/action/UpdateUserAction.java
index 9a7a15b..1a8d308 100644
--- a/src/main/java/com/ifish/action/UpdateUserAction.java
+++ b/src/main/java/com/ifish/action/UpdateUserAction.java
@@ -1,5 +1,10 @@
package com.ifish.action;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.ifish.entity.AliyunDeviceInfo;
+import com.ifish.service.PageListService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -15,6 +20,8 @@ import com.ifish.enums.ResultEnum;
import com.ifish.service.BaseService;
import com.ifish.util.IfishUtil;
+import java.util.Date;
+
/**
* @ClassName: UpdateUserAction
* @Description: TODO
@@ -27,6 +34,9 @@ public class UpdateUserAction {
@Autowired
private BaseService baseService;
+
+ @Autowired
+ private PageListService pageListService;
private static Logger log = LoggerFactory.getLogger(UpdateUserAction.class);
@@ -72,5 +82,55 @@ public class UpdateUserAction {
}
return IfishUtil.returnJson(ResultEnum.fail101.getKey(), "");
}
-
+
+ @RequestMapping(value = "/bindDevice.do")
+ @ResponseBody
+ public Object bindDevice(@RequestParam String deviceId,@RequestParam Integer userId){
+ AliyunDeviceInfo aliyunDeviceInfo = baseService.getAliyunDeviceInfo(deviceId);
+ if (aliyunDeviceInfo == null) {
+ aliyunDeviceInfo = new AliyunDeviceInfo();
+ aliyunDeviceInfo.setAliyunDeviceId(deviceId);
+ aliyunDeviceInfo.setUserId(userId);
+ aliyunDeviceInfo.setBindTime(new Date());
+ aliyunDeviceInfo.setLastUpdateTime(new Date());
+ } else {
+ aliyunDeviceInfo.setUserId(userId);
+ aliyunDeviceInfo.setLastUpdateTime(new Date());
+ }
+ return baseService.saveOrUpdateAliyunDeviceInfo(aliyunDeviceInfo);
+ }
+
+ @RequestMapping(value = "/userMessageIsRead.do")
+ @ResponseBody
+ public Object userMessageIsRead(@RequestParam Integer userId){
+ try {
+ return baseService.userMessageIsRead(userId);
+ } catch (Exception e) {
+ log.error("update userinfo:userId:{},error message:{}",userId);
+ }
+ return IfishUtil.returnJson(ResultEnum.fail101.getKey(), "");
+ }
+
+ @RequestMapping(value = "/userMessageNoReadCount.do")
+ @ResponseBody
+ public Object userMessageNoReadCount(@RequestParam Integer userId){
+ try {
+ return baseService.userMessageNoReadCount(userId);
+ } catch (Exception e) {
+ log.error("userMessageNoReadCount userinfo:userId:{},error message:{}",userId);
+ }
+ return IfishUtil.returnJson(ResultEnum.fail101.getKey(), "");
+ }
+
+ @RequestMapping(value = "/deleteMessages.do")
+ @ResponseBody
+ public Object deleteMessages(@RequestParam String pushIds){
+ try {
+ JSONArray pushId = JSONArray.parseArray(pushIds);
+ return pageListService.deletePushlist(pushId);
+ } catch (Exception e) {
+ log.error("deleteMessages : pushIds :{},error message:{}",pushIds);
+ }
+ return IfishUtil.returnJson(ResultEnum.fail101.getKey(), "");
+ }
}
diff --git a/src/main/java/com/ifish/dao/AliyunDeviceInfoDao.java b/src/main/java/com/ifish/dao/AliyunDeviceInfoDao.java
new file mode 100644
index 0000000..ffa004f
--- /dev/null
+++ b/src/main/java/com/ifish/dao/AliyunDeviceInfoDao.java
@@ -0,0 +1,11 @@
+package com.ifish.dao;
+
+import com.ifish.entity.AliyunDeviceInfo;
+
+/**
+ * @author: yan.y
+ * @Description:
+ * @Date: Created in 22:26 2019/5/20
+ */
+public interface AliyunDeviceInfoDao extends BaseDao {
+}
diff --git a/src/main/java/com/ifish/dao/PushListDao.java b/src/main/java/com/ifish/dao/PushListDao.java
index e67297b..a35820a 100644
--- a/src/main/java/com/ifish/dao/PushListDao.java
+++ b/src/main/java/com/ifish/dao/PushListDao.java
@@ -12,4 +12,8 @@ import com.ifish.hibernate.Pagination;
public interface PushListDao extends BaseDao{
public Pagination findByCriteria(Integer pushId,Integer userId,Integer firstResult,Integer pageSize);
+
+ void updatePushListIsRead(Integer userId);
+
+ int pushNoReadCount(Integer userId);
}
diff --git a/src/main/java/com/ifish/daoImpl/AliyunDeviceInfoDaoImpl.java b/src/main/java/com/ifish/daoImpl/AliyunDeviceInfoDaoImpl.java
new file mode 100644
index 0000000..d5619a0
--- /dev/null
+++ b/src/main/java/com/ifish/daoImpl/AliyunDeviceInfoDaoImpl.java
@@ -0,0 +1,20 @@
+package com.ifish.daoImpl;
+
+import com.ifish.dao.AliyunDeviceInfoDao;
+import com.ifish.entity.AliyunDeviceInfo;
+import com.ifish.hibernate.HibernateBaseDao;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author: yan.y
+ * @Description:
+ * @Date: Created in 22:27 2019/5/20
+ */
+@Repository
+public class AliyunDeviceInfoDaoImpl extends HibernateBaseDao implements AliyunDeviceInfoDao {
+
+ @Override
+ protected Class getEntityClass() {
+ return AliyunDeviceInfo.class;
+ }
+}
diff --git a/src/main/java/com/ifish/daoImpl/PushListDaoImpl.java b/src/main/java/com/ifish/daoImpl/PushListDaoImpl.java
index 508c7cd..a192333 100644
--- a/src/main/java/com/ifish/daoImpl/PushListDaoImpl.java
+++ b/src/main/java/com/ifish/daoImpl/PushListDaoImpl.java
@@ -1,8 +1,10 @@
package com.ifish.daoImpl;
+import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;
+import org.hibernate.SQLQuery;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Restrictions;
@@ -38,7 +40,7 @@ public class PushListDaoImpl extends HibernateBaseDao impleme
queryList.add(criterion);
}
if(userId!=null){
- Criterion criterion = Restrictions.or(Restrictions.eq("userId", userId),Restrictions.eq("pushType", PushTypeEnum.all_push.getKey()));
+ Criterion criterion = Restrictions.eq("userId", userId);
queryList.add(criterion);
}
else{
@@ -48,4 +50,18 @@ public class PushListDaoImpl extends HibernateBaseDao impleme
return this.findByCriteria(firstResult, pageSize,Order.desc("pushId"), queryList.toArray(new Criterion[queryList.size()]));
}
+ @Override
+ public void updatePushListIsRead(Integer userId) {
+ SQLQuery sqlQuery = this.getSession().createSQLQuery("update tbl_push_list set is_read = 0 where user_id = ? ");
+ sqlQuery.setParameter(0,userId);
+ sqlQuery.executeUpdate();
+ }
+
+ @Override
+ public int pushNoReadCount(Integer userId) {
+ SQLQuery sqlQuery = this.getSession().createSQLQuery("select count(1) from tbl_push_list t where t.user_id = ? and t.is_read = 1 ");
+ sqlQuery.setParameter(0,userId);
+ BigInteger count = (BigInteger) sqlQuery.list().get(0);
+ return count.intValue();
+ }
}
diff --git a/src/main/java/com/ifish/entity/AliyunDeviceInfo.java b/src/main/java/com/ifish/entity/AliyunDeviceInfo.java
new file mode 100644
index 0000000..d1e3af5
--- /dev/null
+++ b/src/main/java/com/ifish/entity/AliyunDeviceInfo.java
@@ -0,0 +1,61 @@
+package com.ifish.entity;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author: yan.y
+ * @Description: tbl_aliyun_device_info
+ * @Date: Created in 16:45 2018/1/28
+ * @Modified by:
+ */
+@Entity
+@Table(name = "tbl_aliyun_device_info")
+public class AliyunDeviceInfo implements Serializable{
+
+ @Id
+ @Column(name = "aliyun_device_id")
+ private String aliyunDeviceId;
+
+ @Column(name = "user_id")
+ private Integer userId;
+
+ @Column(name="bind_time",columnDefinition="timestamp")
+ private Date bindTime;
+
+ @Column(name="last_update_time",columnDefinition="timestamp")
+ private Date lastUpdateTime;
+
+ public String getAliyunDeviceId() {
+ return aliyunDeviceId;
+ }
+
+ public void setAliyunDeviceId(String aliyunDeviceId) {
+ this.aliyunDeviceId = aliyunDeviceId;
+ }
+
+ public Integer getUserId() {
+ return userId;
+ }
+
+ public void setUserId(Integer userId) {
+ this.userId = userId;
+ }
+
+ public Date getBindTime() {
+ return bindTime;
+ }
+
+ public void setBindTime(Date bindTime) {
+ this.bindTime = bindTime;
+ }
+
+ public Date getLastUpdateTime() {
+ return lastUpdateTime;
+ }
+
+ public void setLastUpdateTime(Date lastUpdateTime) {
+ this.lastUpdateTime = lastUpdateTime;
+ }
+}
diff --git a/src/main/java/com/ifish/entity/PushList.java b/src/main/java/com/ifish/entity/PushList.java
index 1d15a71..5697884 100644
--- a/src/main/java/com/ifish/entity/PushList.java
+++ b/src/main/java/com/ifish/entity/PushList.java
@@ -40,6 +40,8 @@ public class PushList implements Serializable{
private String neteaseStatus;
//创建时间
private Date createTime;
+ //是否已读
+ private Integer isRead;
public PushList() {}
@@ -133,5 +135,12 @@ public class PushList implements Serializable{
public void setNeteaseStatus(String neteaseStatus) {
this.neteaseStatus = neteaseStatus;
}
-
+
+ public Integer getIsRead() {
+ return isRead;
+ }
+
+ public void setIsRead(Integer isRead) {
+ this.isRead = isRead;
+ }
}
diff --git a/src/main/java/com/ifish/entity/User.java b/src/main/java/com/ifish/entity/User.java
index 7715048..5a75af5 100644
--- a/src/main/java/com/ifish/entity/User.java
+++ b/src/main/java/com/ifish/entity/User.java
@@ -133,6 +133,7 @@ public class User implements Serializable{
*/
@Column(name="latitude")
private Double latitude;
+
/**
* 修改时间
*/
@@ -283,6 +284,7 @@ public class User implements Serializable{
public void setLatitude(Double latitude) {
this.latitude = latitude;
}
+
public Date getLoginTime() {
return loginTime;
}
diff --git a/src/main/java/com/ifish/entity/hbm/PushList.hbm.xml b/src/main/java/com/ifish/entity/hbm/PushList.hbm.xml
index 5cc5d0a..10afa52 100644
--- a/src/main/java/com/ifish/entity/hbm/PushList.hbm.xml
+++ b/src/main/java/com/ifish/entity/hbm/PushList.hbm.xml
@@ -18,5 +18,6 @@
+
\ No newline at end of file
diff --git a/src/main/java/com/ifish/helper/UserHelper.java b/src/main/java/com/ifish/helper/UserHelper.java
index eeb800e..b6189e7 100644
--- a/src/main/java/com/ifish/helper/UserHelper.java
+++ b/src/main/java/com/ifish/helper/UserHelper.java
@@ -7,6 +7,7 @@ package com.ifish.helper;
import com.ifish.bean.DeviceUserBean;
import com.ifish.dao.DeviceUserDao;
+import com.ifish.dao.PushListDao;
import com.ifish.entity.*;
import com.ifish.enums.BooleanEnum;
import com.ifish.enums.GwellEnum;
@@ -25,6 +26,8 @@ import com.ifish.util.StringUtil;
import java.util.*;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.StringUtils;
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.Restrictions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -69,6 +72,8 @@ public class UserHelper implements UserHelperI {
@Autowired
private DeviceUserDao deviceUserDao;
+ @Autowired
+ private PushListDao pushListDao;
/**
* 登陆接口
*
@@ -293,6 +298,7 @@ public class UserHelper implements UserHelperI {
userMap.put("neteaseToken", tmpUser.getNeteaseToken());
userMap.put("userType", tmpUser.getUserType());
userMap.put("shopsUserId", tmpUser.getShopsUserId());
+ userMap.put("messageNoReadCount", this.pushListDao.pushNoReadCount(tmpUser.getUserId()));
if (tmpUser.getUpdateTime() != null) {
userMap.put("updateTime", IfishUtil.format(tmpUser.getUpdateTime()));
}
diff --git a/src/main/java/com/ifish/mapper/Tbl_User_Mapper.java b/src/main/java/com/ifish/mapper/Tbl_User_Mapper.java
index 015a469..534c16f 100644
--- a/src/main/java/com/ifish/mapper/Tbl_User_Mapper.java
+++ b/src/main/java/com/ifish/mapper/Tbl_User_Mapper.java
@@ -22,7 +22,7 @@ public interface Tbl_User_Mapper {
*
* @return
*/
- @Select("SELECT user_id,nick_name,user_password,phone_number,user_img,user_sex,signature,login_count,phone_type,update_time,login_time,create_time,login_type,remarks,"
+ @Select("SELECT user_id,nick_name,user_password,phone_number,user_img,user_sex,signature,login_count,phone_type,update_time,login_time,create_time,login_type,remarks,message_no_read_count,"
+ "address,P2PVerify_code1,P2PVerify_code2,gwell_userID,is_register_gwell,user_type,shops_user_id,netease_token,is_register_netease,latitude,longitude from tbl_user where phone_number=#{phoneNumber}")
User getUserByPhoneNumber(@Param("phoneNumber") String phoneNumber);
diff --git a/src/main/java/com/ifish/service/AliyunDeviceInfoService.java b/src/main/java/com/ifish/service/AliyunDeviceInfoService.java
new file mode 100644
index 0000000..174e3c2
--- /dev/null
+++ b/src/main/java/com/ifish/service/AliyunDeviceInfoService.java
@@ -0,0 +1,14 @@
+package com.ifish.service;
+
+import com.ifish.entity.AliyunDeviceInfo;
+
+/**
+ * @author: yan.y
+ * @Description:
+ * @Date: Created in 22:29 2019/5/20
+ */
+public interface AliyunDeviceInfoService {
+ AliyunDeviceInfo getAliyunDeviceInfo(String deviceId);
+
+ void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo);
+}
diff --git a/src/main/java/com/ifish/service/BaseService.java b/src/main/java/com/ifish/service/BaseService.java
index 27bc646..5f8850c 100644
--- a/src/main/java/com/ifish/service/BaseService.java
+++ b/src/main/java/com/ifish/service/BaseService.java
@@ -137,5 +137,33 @@ public interface BaseService {
//发送看护报告给用户
public Object getLookReportById(Integer reportId);
-
+
+ /**
+ * 获取阿里云推送设备信息
+ * @param deviceId
+ * @return
+ */
+ AliyunDeviceInfo getAliyunDeviceInfo(String deviceId);
+
+ /**
+ * 保存或修改阿里云推送设备信息
+ * @param aliyunDeviceInfo
+ * @return
+ */
+ Object saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo);
+
+ /**
+ * 用户消息已读
+ * @param userId
+ * @return
+ */
+ Object userMessageIsRead(Integer userId);
+
+ /**
+ * 查询消息未读数
+ * @param userId
+ * @return
+ */
+ Object userMessageNoReadCount(Integer userId);
+
}
diff --git a/src/main/java/com/ifish/service/PageListService.java b/src/main/java/com/ifish/service/PageListService.java
index 9c09644..c787809 100644
--- a/src/main/java/com/ifish/service/PageListService.java
+++ b/src/main/java/com/ifish/service/PageListService.java
@@ -1,5 +1,6 @@
package com.ifish.service;
+import com.alibaba.fastjson.JSONArray;
import com.ifish.dto.ShopsLookUserDto;
import com.ifish.entity.PushList;
import com.ifish.hibernate.Pagination;
@@ -18,5 +19,6 @@ public interface PageListService {
//看护列表
public Pagination getLookListByPage(Integer shopsUserId,Integer firstResult,Integer pageSize);
-
+
+ Object deletePushlist(JSONArray pushIds);
}
diff --git a/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java b/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java
new file mode 100644
index 0000000..afaae74
--- /dev/null
+++ b/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java
@@ -0,0 +1,33 @@
+package com.ifish.serviceImpl;
+
+import com.ifish.dao.AliyunDeviceInfoDao;
+import com.ifish.entity.AliyunDeviceInfo;
+import com.ifish.service.AliyunDeviceInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @author: yan.y
+ * @Description:
+ * @Date: Created in 22:29 2019/5/20
+ */
+@Service
+@Transactional
+public class AliyunDeviceInfoServiceImpl implements AliyunDeviceInfoService {
+
+ @Autowired
+ private AliyunDeviceInfoDao aliyunDeviceInfoDao;
+
+ @Override
+ public AliyunDeviceInfo getAliyunDeviceInfo(String deviceId) {
+ AliyunDeviceInfo aliyunDeviceInfo = aliyunDeviceInfoDao.get(deviceId);
+ return aliyunDeviceInfo;
+ }
+
+ @Override
+ public void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) {
+ this.aliyunDeviceInfoDao.saveOrUpdate(aliyunDeviceInfo);
+ }
+
+}
diff --git a/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java b/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java
index 1c9a961..31163a4 100644
--- a/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java
+++ b/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java
@@ -1,47 +1,30 @@
package com.ifish.serviceImpl;
-import java.io.File;
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-
+import com.alibaba.fastjson.JSON;
import com.ifish.dao.*;
import com.ifish.entity.*;
+import com.ifish.enums.*;
+import com.ifish.gwell.GwellApi;
+import com.ifish.jpush.SmsNumSend;
+import com.ifish.mail.Mail;
+import com.ifish.netease.NeteaseIM;
+import com.ifish.service.AliyunDeviceInfoService;
+import com.ifish.service.BaseService;
+import com.ifish.util.IfishFilePath;
+import com.ifish.util.IfishUtil;
import org.apache.commons.lang3.StringUtils;
-import org.apache.log4j.Logger;
+import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Restrictions;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
-import com.alibaba.fastjson.JSON;
-import com.ifish.enums.BooleanEnum;
-import com.ifish.enums.GwellEnum;
-import com.ifish.enums.Index1Enum;
-import com.ifish.enums.Index2Enum;
-import com.ifish.enums.Index3Enum;
-import com.ifish.enums.NeteaseEnum;
-import com.ifish.enums.PushTypeEnum;
-import com.ifish.enums.ResultEnum;
-import com.ifish.enums.SendTypeEnum;
-import com.ifish.enums.ShopsStatusEnum;
-import com.ifish.enums.SmsSignEnum;
-import com.ifish.enums.SmsTemplateEnum;
-import com.ifish.enums.SubDirectoryEnum;
-import com.ifish.enums.UserTypeEnum;
-import com.ifish.gwell.GwellApi;
-import com.ifish.jpush.SmsNumSend;
-import com.ifish.mail.Mail;
-import com.ifish.netease.NeteaseIM;
-import com.ifish.service.BaseService;
-import com.ifish.util.IfishFilePath;
-import com.ifish.util.IfishUtil;
+import java.io.File;
+import java.util.*;
/**
* @ClassName: BaseServiceImpl
@@ -91,8 +74,10 @@ public class BaseServiceImpl implements BaseService {
private DeviceHeaterDetailDao deviceHeaterDetailDao;
@Autowired
private DeviceHeaterDao deviceHeaterDao;
+ @Autowired
+ private AliyunDeviceInfoService aliyunDeviceInfoService;
- private static final Logger log = Logger.getLogger(BaseServiceImpl.class);
+ private static final Logger log = LoggerFactory.getLogger(BaseServiceImpl.class);
/**
* 获取验证码
*/
@@ -1176,7 +1161,6 @@ public class BaseServiceImpl implements BaseService {
@Override
public Object setRemindWaterInf(Device device) {
- Logger log = Logger.getLogger(BaseServiceImpl.class);
log.info("setRemindWaterInf begin");
Device tmpDevice = this.deviceDao.get(device.getDeviceId());
if (tmpDevice != null) {
@@ -1686,4 +1670,27 @@ public class BaseServiceImpl implements BaseService {
return IfishUtil.returnJson(ResultEnum.fail101.getKey(), "");
}
+ @Override
+ public AliyunDeviceInfo getAliyunDeviceInfo(String device) {
+ return this.aliyunDeviceInfoService.getAliyunDeviceInfo(device);
+ }
+
+ @Override
+ public Object saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) {
+ this.aliyunDeviceInfoService.saveOrUpdateAliyunDeviceInfo(aliyunDeviceInfo);
+ return IfishUtil.returnJson(ResultEnum.success.getKey(), "");
+ }
+
+ @Override
+ public Object userMessageIsRead(Integer userId) {
+ this.pushListDao.updatePushListIsRead(userId);
+ return IfishUtil.returnJson(ResultEnum.success.getKey(), "");
+ }
+
+ @Override
+ public Object userMessageNoReadCount(Integer userId) {
+ Map map = new HashMap();
+ map.put("messageNoReadCount",this.pushListDao.pushNoReadCount(userId));
+ return IfishUtil.returnJson(ResultEnum.success.getKey(), map);
+ }
}
diff --git a/src/main/java/com/ifish/serviceImpl/PageListServiceImpl.java b/src/main/java/com/ifish/serviceImpl/PageListServiceImpl.java
index cda805e..8702ac4 100644
--- a/src/main/java/com/ifish/serviceImpl/PageListServiceImpl.java
+++ b/src/main/java/com/ifish/serviceImpl/PageListServiceImpl.java
@@ -1,5 +1,10 @@
package com.ifish.serviceImpl;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.ifish.enums.ResultEnum;
+import com.ifish.util.IfishUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -36,4 +41,13 @@ public class PageListServiceImpl implements PageListService {
return userDao.findByCriteria(shopsUserId, firstResult, pageSize);
}
+ @Override
+ public Object deletePushlist(JSONArray pushIds) {
+ for (Object pushId : pushIds) {
+ JSONObject json = JSONObject.parseObject(String.valueOf(pushId));
+ int id = Integer.parseInt(json.getString("pushId"));
+ pushListDao.delete(pushListDao.get(id));
+ }
+ return IfishUtil.returnJson(ResultEnum.success.getKey(), "");
+ }
}
diff --git a/src/main/resources/jdbc.properties b/src/main/resources/jdbc.properties
index a5700c3..0cbf3ee 100644
--- a/src/main/resources/jdbc.properties
+++ b/src/main/resources/jdbc.properties
@@ -1,10 +1,10 @@
jdbc.driver=com.mysql.jdbc.Driver
-jdbc.url=jdbc\:mysql\://localhost\:3306/myfishdb?characterEncoding\=UTF-8
-#jdbc.url=jdbc\:mysql\://139.196.24.156\:3306/myfishdb?characterEncoding\=UTF-8
-jdbc.username=ifish
-jdbc.password=ifish7pwd
-#jdbc.username=root
-#jdbc.password=ifish7mysql
+#jdbc.url=jdbc\:mysql\://localhost\:3306/myfishdb?characterEncoding\=UTF-8
+jdbc.url=jdbc\:mysql\://139.196.24.156\:3306/myfishdb?characterEncoding\=UTF-8
+#jdbc.username=ifish
+#jdbc.password=ifish7pwd
+jdbc.username=root
+jdbc.password=ifish7mysql
#jdbc.testWhileIdle=true
jdbc.validationQuery=SELECT * FROM DUAL
initialSize=1