推荐信息修改，订单爬取规则修改，订单号过滤修改

admin

2019-08-01 f1cf83467c8d3b2693e286f3d1da753b103d94c2

 fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserSystemMsgServiceImpl.java

@@ -7,13 +7,16 @@


import org.springframework.stereotype.Service;



import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.msg.UserSystemMsgMapper;

import com.yeshi.fanli.entity.bus.msg.UserSystemMsg;

import com.yeshi.fanli.entity.bus.msg.UserSystemMsgTypeEnum;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.system.SystemZnx;

import com.yeshi.fanli.exception.msg.UserSystemMsgException;

import com.yeshi.fanli.service.inter.msg.UserMsgReadStateService;

import com.yeshi.fanli.service.inter.msg.UserSystemMsgService;

import com.yeshi.fanli.service.inter.user.SystemZnxService;

import com.yeshi.fanli.util.StringUtil;



@Service

@@ -21,6 +24,15 @@


   @Resource

   private UserSystemMsgMapper userSystemMsgMapper;



   @Resource

   private UserMsgReadStateService userMsgReadStateService;



   @Resource

   private UserInfoMapper userInfoMapper;



   @Resource

   private SystemZnxService systemZnxService;



   @Override

   public void addUserSystemMsg(Long uid, UserSystemMsgTypeEnum type, String title, String content, int timeTag,

@@ -50,6 +62,7 @@
         msg.setTimeTag(timeTag);

      }

      userSystemMsgMapper.insertSelective(msg);

      userMsgReadStateService.addSystemMsgUnReadCount(uid, 1);

   }



   @Override

@@ -99,4 +112,25 @@
      userSystemMsgMapper.setMsgReadByUid(uid);

   }



   @Override

   public void syncSystemZNX(Long uid) {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      if (user == null)

         return;

      long createTime = user.getCreatetime();

      List<SystemZnx> list = systemZnxService.listbyCreateTime(createTime);

      if (list != null && list.size() > 0) {

         for (SystemZnx znx : list) {

            UserSystemMsg msg = userSystemMsgMapper.selectBySystemZNXId(znx.getId());

            if (msg == null)

               try {

                  addUserSystemMsg(uid, UserSystemMsgTypeEnum.common, null, null, UserSystemMsg.TIME_TAG_COMMON, znx);

               } catch (UserSystemMsgException e) {

                  e.printStackTrace();

               }

         }



      }

   }



}