打卡作品旧数据迁移

pcloud-facade-book/src/main/java/com/pcloud/book/clock/service/BookClockInfoService.java

@@ -28,5 +28,7 @@ public interface BookClockInfoService {
     @RequestMapping(value = "/dealOldData4WeixinClock", method = RequestMethod.GET)
     void dealOldData4WeixinClock();
 
-
+    @ApiOperation(value = "处理关联作品的打卡的旧数据", httpMethod = "GET")
+    @RequestMapping(value = "/dealOldData4WeixinAtt", method = RequestMethod.GET)
+    void dealOldData4WeixinAtt();
 }

pcloud-service-book/src/main/java/com/pcloud/book/clock/biz/BookClockBiz.java

@@ -71,4 +71,9 @@ public interface BookClockBiz {
      * 处理关联应用的打卡的旧数据
      */
     void dealOldData4WeixinClock();
+
+    /**
+     * 处理关联作品的打卡的旧数据
+     */
+    void dealOldData4WeixinAtt();
 }

pcloud-service-book/src/main/java/com/pcloud/book/clock/biz/impl/BookClockBizImpl.java

@@ -11,6 +11,8 @@ import com.pcloud.book.clock.dto.BookClockInfoDTO;
 import com.pcloud.book.clock.dto.BookClockKeywordDTO;
 import com.pcloud.book.clock.dto.BookClockListDTO;
 import com.pcloud.book.clock.dto.BookGroupClockDTO;
+import com.pcloud.book.clock.dto.BookGroupClockKeywordDTO;
+import com.pcloud.book.clock.dto.PushBookClockKeywordDTO;
 import com.pcloud.book.clock.entity.BookClockInfo;
 import com.pcloud.book.clock.entity.BookClockKeyword;
 import com.pcloud.book.clock.entity.BookGroupClock;
@@ -28,6 +30,11 @@ import com.pcloud.book.group.dao.WeixinQrcodeDao;
 import com.pcloud.book.group.dto.BookGroupDTO;
 import com.pcloud.book.group.dto.BookWxQrcodeDTO;
 import com.pcloud.book.group.dto.ClassifyDTO;
+import com.pcloud.book.group.entity.BookGroupClassify;
+import com.pcloud.book.group.entity.GroupQrcode;
+import com.pcloud.book.group.vo.ClassifyVO;
+import com.pcloud.book.keywords.biz.BookKeywordBiz;
+import com.pcloud.book.keywords.vo.SetKeywordVO;
 import com.pcloud.book.weixinclock.biz.WeixinClockBiz;
 import com.pcloud.book.weixinclock.dto.WeixinClockDto;
 import com.pcloud.common.core.aspect.ParamLog;
@@ -54,12 +61,15 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * @Author: hzk
  * @Date: 2019/5/24 14:50
  * @Version 1.0
  */
 @Component("bookClockBiz")
+@Slf4j
 public class BookClockBizImpl implements BookClockBiz {
 
     @Autowired
@@ -90,7 +100,9 @@ public class BookClockBizImpl implements BookClockBiz {
     private WeixinQrcodeDao weixinQrcodeDao;
     @Autowired
     private WeixinClockBiz weixinClockBiz;
-
+    @Autowired
+    private BookKeywordBiz bookKeywordBiz;
+    private ExecutorService timedTask = Executors.newFixedThreadPool(5);
 
     /**
      * 关联作品/应用及微信群
@@ -432,13 +444,13 @@ public class BookClockBizImpl implements BookClockBiz {
             weixinClockDto.setClockIntroduction("欢迎加入打卡，每天一次，养成良好习惯");
             weixinClockDto.setClockKeyword("每日打卡");
             List<BookClockInfoDTO> clockInfoIds = bookClockInfoDao.getAllClockInfoIds();
-            if(!ListUtils.isEmpty(clockInfoIds)){
-                for(BookClockInfoDTO bookClockInfoDTO: clockInfoIds){
+            if (!ListUtils.isEmpty(clockInfoIds)) {
+                for (BookClockInfoDTO bookClockInfoDTO : clockInfoIds) {
                     List<Long> list1 = bookGroupClockDao.getClassifyIdsByBookGroupId(bookClockInfoDTO.getBookClockInfoId());
                     List<Long> list2 = bookGroupClockDao.getClassifyIdsByClassfyId(bookClockInfoDTO.getBookClockInfoId());
                     list1.addAll(list2);
                     List<Long> resultList = list1.stream().distinct().collect(Collectors.toList());
-                    if(!ListUtils.isEmpty(resultList)) {
+                    if (!ListUtils.isEmpty(resultList)) {
                         weixinClockDto.setCreateUser(bookClockInfoDTO.getCreateUser());
                         weixinClockDto.setLastModifiedUser(bookClockInfoDTO.getCreateUser());
                         weixinClockDto.setGroupClassifyIds(resultList);
@@ -448,4 +460,52 @@ public class BookClockBizImpl implements BookClockBiz {
             }
         }).start();
     }
+
+    @Override
+    @ParamLog("微信群打卡作品数据迁移")
+    public void dealOldData4WeixinAtt() {
+            SetKeywordVO setKeywordVO = new SetKeywordVO();
+            List<BookClockInfoDTO> clockInfoIds = bookClockInfoDao.getAllAttInfoIds();
+            if(!ListUtils.isEmpty(clockInfoIds)){
+                for(BookClockInfoDTO bookClockInfoDTO: clockInfoIds){
+                    List<Long> list1 = bookGroupClockDao.getClassifyIdsByBookGroupId(bookClockInfoDTO.getBookClockInfoId());
+                    List<Long> list2 = bookGroupClockDao.getClassifyIdsByClassfyId(bookClockInfoDTO.getBookClockInfoId());
+                    //关联的关键词
+                    Map<String,Object> paramMap = new HashMap<>();
+                    paramMap.put("bookClockInfoId",bookClockInfoDTO.getBookClockInfoId());
+                    List<BookClockKeywordDTO> bookClockKeywordDTOS = bookClockKeywordDao.getKeywordsByInfoId(paramMap);
+                    if (bookClockKeywordDTOS.size() != 1){
+                        continue;
+                    }
+                    list1.addAll(list2);
+                    List<Long> resultList = list1.stream().distinct().collect(Collectors.toList());
+                    if(!ListUtils.isEmpty(resultList)) {
+                        for (Long id : resultList) {
+                            ClassifyVO classifyVO = bookGroupClassifyDao.getClassify(id);
+                            setKeywordVO.setGuide(bookClockKeywordDTOS.get(0).getGuide());
+                            setKeywordVO.setChannelId(classifyVO.getChannelId());
+                            setKeywordVO.setKeywords(bookClockKeywordDTOS.get(0).getKeyword());
+                            setKeywordVO.setPicUrl(bookClockInfoDTO.getOriginImg());
+                            setKeywordVO.setLinkUrl("/C" + classifyVO.getChannelId() + "/product/display/" + bookClockInfoDTO.getOriginId() + "?adviserId=" + bookClockInfoDTO.getCreateUser() + "&source_type=QRCODE");
+                            setKeywordVO.setDescription("签到打卡");
+                            setKeywordVO.setAddWarehouse(0);
+                            setKeywordVO.setClassifyId(id);
+                            setKeywordVO.setSetType(1);
+                            setKeywordVO.setReplyType(4);
+                            setKeywordVO.setMatchingRule(0);
+                            setKeywordVO.setBookGroupId(classifyVO.getBookGroupId());
+                            setKeywordVO.setContent(bookClockInfoDTO.getOriginTitle());
+                            setKeywordVO.setServeId(bookClockInfoDTO.getOriginId());
+                            setKeywordVO.setServeType(bookClockInfoDTO.getOriginType());
+                            setKeywordVO.setUserId(bookClockInfoDTO.getCreateUser());
+                            try {
+                                bookKeywordBiz.insertKeyword(setKeywordVO);
+                            }catch (BookBizException e){
+                                log.info("打卡关键词迁移失败："+e.toString());
+                            }
+                        }
+                    }
+                }
+            }
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/clock/dao/BookClockInfoDao.java

@@ -88,4 +88,5 @@ public interface BookClockInfoDao extends BaseDao<BookClockInfo> {
     void deleteBookClockInfo(Map<String, Object> paramMap);
 
     List<BookClockInfoDTO> getAllClockInfoIds();
+    List<BookClockInfoDTO> getAllAttInfoIds();
 }

pcloud-service-book/src/main/java/com/pcloud/book/clock/dao/impl/BookClockInfoDaoImpl.java

@@ -141,5 +141,9 @@ public class BookClockInfoDaoImpl extends BaseDaoImpl<BookClockInfo> implements
         return super.sqlSessionTemplate.selectList(getStatement("getAllClockInfoIds"),paramMap);
     }
 
-
+    @Override
+    public List<BookClockInfoDTO> getAllAttInfoIds() {
+        Map<String,Object> paramMap = new HashMap<>();
+        return super.sqlSessionTemplate.selectList(getStatement("getAllAttInfoIds"),paramMap);
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/clock/service/impl/BookClockInfoServiceImpl.java

@@ -76,5 +76,10 @@ public class BookClockInfoServiceImpl implements BookClockInfoService {
         bookClockBiz.dealOldData4WeixinClock();
     }
 
+    @Override
+    @RequestMapping(value = "/dealOldData4WeixinAtt", method = RequestMethod.GET)
+    public void dealOldData4WeixinAtt() {
+        bookClockBiz.dealOldData4WeixinAtt();
+    }
 
 }

pcloud-service-book/src/main/resources/mapper/clock/BookClockInfo.Mapper.xml

@@ -203,5 +203,9 @@
         from book_clock_info where origin_type = 'APP'
     </select>
 
+    <select id="getAllAttInfoIds" parameterType="map" resultMap="BaseResultMapDTO">
+        select <include refid="Base_Column_List"/>
+        from book_clock_info where origin_type = 'PRODUCT'
+    </select>
 
 </mapper>
\ No newline at end of file