From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/util/db/MongoDBManager.java | 224 ++++++++++++++++++++++++++++---------------------------- 1 files changed, 112 insertions(+), 112 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/db/MongoDBManager.java b/fanli/src/main/java/com/yeshi/fanli/util/db/MongoDBManager.java index b14a564..372e6ab 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/db/MongoDBManager.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/db/MongoDBManager.java @@ -1,112 +1,112 @@ -package com.yeshi.fanli.util.db; - -import java.util.List; - -import javax.annotation.Resource; - -import org.springframework.data.mongodb.core.MongoTemplate; -import org.springframework.data.mongodb.core.query.Criteria; -import org.springframework.data.mongodb.core.query.Query; -import org.springframework.data.mongodb.core.query.Update; -import org.springframework.stereotype.Component; - -import com.yeshi.fanli.entity.bus.help.HelpInfo; -import com.yeshi.common.entity.taobao.TaoBaoShopInfo; - -@Component -public class MongoDBManager { - @Resource - private MongoTemplate mongoTemplate; - - /** - * 淇濆瓨娣樺疂搴楅摵淇℃伅 - * - * @param tb - */ - public void saveTBShopInfo(TaoBaoShopInfo tb) { - if (tb == null) - return; - Query query = new Query(); - query.addCriteria(Criteria.where("userId").is(tb.getUserId())); - List<TaoBaoShopInfo> list = mongoTemplate.find(query, TaoBaoShopInfo.class); - if (list != null && list.size() > 0) { - Update update = Update.update("content", tb.getShopTitle()).set("shopType", tb.getShopType()) - .set("sellerNick", tb.getSellerNick()).set("pictureUrl", tb.getPictureUrl()) - .set("shopUrl", tb.getShopUrl()); - - mongoTemplate.updateMulti(query, update, TaoBaoShopInfo.class); - } else { - mongoTemplate.insert(tb); - } - } - - public TaoBaoShopInfo getTBShopInfo(Long userId) { - Query query = new Query(); - query.addCriteria(Criteria.where("userId").is(userId)); - TaoBaoShopInfo info = mongoTemplate.findOne(query, TaoBaoShopInfo.class); - return info; - } - - /** - * 淇濆瓨甯姪涓績璇︽儏椤甸潰 - * - * @param tb - */ - public void saveHelpInfo(HelpInfo helpInfo) { - - if (helpInfo == null) - return; - - Query query = new Query(); - query.addCriteria(Criteria.where("id").is(helpInfo.getId())); - - List<HelpInfo> list = mongoTemplate.find(query, HelpInfo.class); - - if (list == null || list.size() == 0) { - // 鎻掑叆 - mongoTemplate.insert(helpInfo); - } else { - - Update update = Update.update("content", helpInfo.getContent()).set("html", helpInfo.getHtml()); - mongoTemplate.updateMulti(query, update, HelpInfo.class); - } - } - - /** - * 鑾峰彇甯姪淇℃伅 - * - * @param id - * @return - */ - public HelpInfo getHelpInfo(Long id) { - Query query = new Query(); - query.addCriteria(Criteria.where("id").is(id)); - HelpInfo info = mongoTemplate.findOne(query, HelpInfo.class); - return info; - } - - /** - * 鍒犻櫎甯姪淇℃伅 - * - * @param id - * @return - */ - public void removeHelpInfo(Long id) { - Query query = new Query(); - query.addCriteria(Criteria.where("id").is(id)); - - List<HelpInfo> list = mongoTemplate.find(query, HelpInfo.class); - - if (list != null && list.size() > 0) { - HelpInfo helpInfo = list.get(0); - mongoTemplate.remove(helpInfo); - } - - } - - public void test() { - String jsonCommand = "flq.helpInfo.find().forEach(function(x){hcj.helpInfo.insert(x);});"; - mongoTemplate.executeCommand(jsonCommand); - } - -} +package com.yeshi.fanli.util.db; + +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.data.mongodb.core.query.Criteria; +import org.springframework.data.mongodb.core.query.Query; +import org.springframework.data.mongodb.core.query.Update; +import org.springframework.stereotype.Component; + +import com.yeshi.fanli.entity.bus.help.HelpInfo; +import com.yeshi.common.entity.taobao.TaoBaoShopInfo; + +@Component +public class MongoDBManager { + @Resource + private MongoTemplate mongoTemplate; + + /** + * 淇濆瓨娣樺疂搴楅摵淇℃伅 + * + * @param tb + */ + public void saveTBShopInfo(TaoBaoShopInfo tb) { + if (tb == null) + return; + Query query = new Query(); + query.addCriteria(Criteria.where("userId").is(tb.getUserId())); + List<TaoBaoShopInfo> list = mongoTemplate.find(query, TaoBaoShopInfo.class); + if (list != null && list.size() > 0) { + Update update = Update.update("content", tb.getShopTitle()).set("shopType", tb.getShopType()) + .set("sellerNick", tb.getSellerNick()).set("pictureUrl", tb.getPictureUrl()) + .set("shopUrl", tb.getShopUrl()); + + mongoTemplate.updateMulti(query, update, TaoBaoShopInfo.class); + } else { + mongoTemplate.insert(tb); + } + } + + public TaoBaoShopInfo getTBShopInfo(Long userId) { + Query query = new Query(); + query.addCriteria(Criteria.where("userId").is(userId)); + TaoBaoShopInfo info = mongoTemplate.findOne(query, TaoBaoShopInfo.class); + return info; + } + + /** + * 淇濆瓨甯姪涓績璇︽儏椤甸潰 + * + * @param tb + */ + public void saveHelpInfo(HelpInfo helpInfo) { + + if (helpInfo == null) + return; + + Query query = new Query(); + query.addCriteria(Criteria.where("id").is(helpInfo.getId())); + + List<HelpInfo> list = mongoTemplate.find(query, HelpInfo.class); + + if (list == null || list.size() == 0) { + // 鎻掑叆 + mongoTemplate.insert(helpInfo); + } else { + + Update update = Update.update("content", helpInfo.getContent()).set("html", helpInfo.getHtml()); + mongoTemplate.updateMulti(query, update, HelpInfo.class); + } + } + + /** + * 鑾峰彇甯姪淇℃伅 + * + * @param id + * @return + */ + public HelpInfo getHelpInfo(Long id) { + Query query = new Query(); + query.addCriteria(Criteria.where("id").is(id)); + HelpInfo info = mongoTemplate.findOne(query, HelpInfo.class); + return info; + } + + /** + * 鍒犻櫎甯姪淇℃伅 + * + * @param id + * @return + */ + public void removeHelpInfo(Long id) { + Query query = new Query(); + query.addCriteria(Criteria.where("id").is(id)); + + List<HelpInfo> list = mongoTemplate.find(query, HelpInfo.class); + + if (list != null && list.size() > 0) { + HelpInfo helpInfo = list.get(0); + mongoTemplate.remove(helpInfo); + } + + } + + public void test() { + String jsonCommand = "flq.helpInfo.find().forEach(function(x){hcj.helpInfo.insert(x);});"; + mongoTemplate.executeCommand(jsonCommand); + } + +} -- Gitblit v1.8.0