fanli/src/main/java/com/yeshi/fanli/controller/apph5/AppH5QualityGoodsController.java
@@ -6,12 +6,11 @@ import javax.annotation.Resource; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.taobao.TbImgUtil; import com.google.gson.Gson; import com.google.gson.GsonBuilder; @@ -19,13 +18,13 @@ import com.yeshi.fanli.entity.bus.lable.Label; import com.yeshi.fanli.entity.bus.lable.MergeClass; import com.yeshi.fanli.entity.bus.lable.QualityFactory; import com.yeshi.fanli.entity.bus.user.CollectionGoods; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; import com.yeshi.fanli.entity.taobao.TaobaoMeterial; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.goods.GoodsClassService; import com.yeshi.fanli.service.inter.goods.TaoBaoClassService; import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; @@ -39,8 +38,9 @@ import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.taobao.TbImgUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @Controller @RequestMapping("api/apph5/v1/quality") @@ -80,10 +80,7 @@ private QualityFlashSaleService qualityFlashSaleService; @Resource private CollectionGoodsService collectionGoodsService; private CollectionGoodsV2Service collectionGoodsV2Service; /** * 9.9åå @@ -95,7 +92,6 @@ public void get9k9(String callback, Integer page, Long mcid, PrintWriter out) { get9k9ClassGoods("9.9", callback, page, mcid, out); } /** * 19.9åå @@ -130,13 +126,15 @@ get9k9ClassGoods("49.9", callback, page, mcid, out); } /** * 9k9ç±»åçååæ¥è¯¢ * @param labName æ ç¾åç§° * * @param labName * æ ç¾åç§° * @param callback * @param page * @param mcid 对åºç±»ç®id * @param mcid * 对åºç±»ç®id * @param out */ public void get9k9ClassGoods(String labName, String callback, Integer page, Long mcid, PrintWriter out) { @@ -196,7 +194,8 @@ } // æ ¹æ®æ ç¾id æ¥è¯¢æ°æ® List<QualityFactory> listQuery = qualityGoodsService.listQuerySmallAmount((page - 1) * pageSize, pageSize, null, labId, mergeCids); List<QualityFactory> listQuery = qualityGoodsService.listQuerySmallAmount((page - 1) * pageSize, pageSize, null, labId, mergeCids); // æ»æ¡æ° long count = qualityGoodsService.countQuerySmallAmount(null, labId, mergeCids); @@ -205,7 +204,8 @@ } JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -244,10 +244,6 @@ return data; } /** * 9.9åå-æ¯æ¥å¿ æ¢ @@ -293,9 +289,9 @@ get9k9ClassToDayRob("49.9", callback, page, mcid, out, 1.0, 50.0); } /** * 9k9ç±»ååå对åºçæ¯æ¥å¿ æ¢ * * @param labName * @param callback * @param page @@ -335,7 +331,6 @@ } } /** * æ¯æ¥å¿ æ¢ * @@ -345,32 +340,35 @@ * @return * @throws Exception */ public JSONObject queryEverydayRob(Integer page, Long labId, int sortField, Double startCouponAmount, Double endCouponAmount) throws Exception { public JSONObject queryEverydayRob(Integer page, Long labId, int sortField, Double startCouponAmount, Double endCouponAmount) throws Exception { if (page == null) page = 1; int pageSize = Constant.PAGE_SIZE; if (page > 3 ) { return null;// 20 æ¡ä¸é¡µè¯·æ±å°3é¡µç»æä»æ¥æ°å } // æ ¹æ®æ ç¾id æ¥è¯¢æ°æ® List<QualityFactory> listQuery = qualityGoodsService.listQueryEverydayRob((page - 1) * pageSize, pageSize, null, labId, sortField, startCouponAmount, endCouponAmount); List<QualityFactory> listQuery = qualityGoodsService.listQueryEverydayRob((page - 1) * pageSize, pageSize, null, labId, sortField, startCouponAmount, endCouponAmount); // åªåå50æ¡æ° long count = 50; //long count = qualityGoodsService.countQueryEverydayRob(null, labId, startCouponAmount, endCouponAmount); // long count = qualityGoodsService.countQueryEverydayRob(null, labId, // startCouponAmount, endCouponAmount); if (listQuery == null || listQuery.size() == 0) { return null; } JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -410,7 +408,6 @@ return data; } /** * åçè´ ï¼å®æ¹æ¨èãåçå¸ãæ¥å£ï¼ * @@ -447,7 +444,6 @@ JsonUtil.printMode(out, callback,JsonUtil.loadFalseResult(2, "æ²¡ææ´å¤äº")); return; } JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(jsonObject)); @@ -497,7 +493,6 @@ JsonUtil.printMode(out, callback,JsonUtil.loadFalseResult(2, "æ²¡ææ´å¤äº")); return; } JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(jsonObject)); @@ -570,7 +565,8 @@ try { List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "æå¥½è´§"); List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "æå¥½è´§"); if (taobaoMeterials == null || taobaoMeterials.size() == 0) { out.print(JsonUtil.loadFalseResult("ææ æ°æ®")); @@ -607,12 +603,12 @@ } } /** * 仿¥æ°åãï¼å®æ¹æ¨èã好å¸ç´æãæ¥å£ï¼ * * @param page * @param subName åç±»åç§° * @param subName * åç±»åç§° */ @RequestMapping(value = "todayNew") public void todayNew(String callback, Integer page, String subName, String uid, PrintWriter out) { @@ -638,7 +634,6 @@ int pageSize = Constant.PAGE_SIZE; List<TaoBaoGoodsBrief> listMaterial = taoKeGoodsService.listByMaterial(materialId, page, pageSize); if (listMaterial == null || listMaterial.size() == 0) { @@ -647,7 +642,8 @@ } JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -673,14 +669,15 @@ int collected = 0; // 夿æ¶è if (!StringUtil.isNullOrEmpty(uid)) { CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid), taoBaoGoodsBrief.getAuctionId()); CollectionGoodsV2 collectionGoods = collectionGoodsV2Service .findByUidAndAuctionId(Long.parseLong(uid), taoBaoGoodsBrief.getAuctionId()); if (collectionGoods != null) { collected = 1; } } TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, null); TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, null); taoBaoGoodsBriefExtra.setCollected(collected); array.add(gson.toJson(taoBaoGoodsBriefExtra)); @@ -689,7 +686,6 @@ JSONObject data = new JSONObject(); data.put("result_list", array); data.put("count", 1000); JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(data)); @@ -703,9 +699,6 @@ } } /** * æ½®åçåï¼å®æ¹æ¨èä¸çãæ½®æµèãï¼ * @@ -717,8 +710,8 @@ try { List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "æ½®æµè"); List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "æ½®æµè"); if (taobaoMeterials == null || taobaoMeterials.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("ææ æ°æ®")); @@ -769,7 +762,8 @@ try { List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(subName, "æ¯å©´ä¸»é¢"); List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(subName, "æ¯å©´ä¸»é¢"); if (taobaoMeterials == null || taobaoMeterials.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("ææ æ°æ®")); @@ -825,7 +819,8 @@ } JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -860,10 +855,9 @@ } /** * éæ¶æ¢è´ * * @param callback * @param page * @param out @@ -889,7 +883,8 @@ // ç²¾éåºæ°æ®å¤çè¿å å端 JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -930,9 +925,9 @@ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } /** * 大é¢å¸ï¼å¸é¢å¼èå´ï¼ * * @param callback * @param amount * @param page @@ -941,12 +936,10 @@ @RequestMapping("choiceCouponAmount") public void choiceCouponAmount(String callback, Integer amount, Integer page, PrintWriter out) { if (page == null) page = 1; int pageSize = Constant.PAGE_SIZE; Integer startAmount = null; Integer endAmount = null ; @@ -966,20 +959,20 @@ Integer startPropor = 20; List<QualityFactory> listQuery = qualityGoodsService.listQueryByCouponAmount((page - 1) * pageSize, pageSize, startAmount, endAmount, startPropor); List<QualityFactory> listQuery = qualityGoodsService.listQueryByCouponAmount((page - 1) * pageSize, pageSize, startAmount, endAmount, startPropor); if (listQuery == null || listQuery.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "æ²¡ææ´å¤äº")); return; } long count = qualityGoodsService.countQueryByCouponAmount(startAmount, endAmount, startPropor); // ç²¾éåºæ°æ®å¤çè¿å å端 JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); @@ -1018,10 +1011,9 @@ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } /** * è¶ é«å¥é * * @param callback * @param page * @param type @@ -1034,7 +1026,6 @@ page = 1; int pageSize = Constant.PAGE_SIZE; Integer startAmount = null; Integer endAmount = null ; @@ -1066,13 +1057,12 @@ return; } long count = qualityGoodsService.countQueryByRebateAmount(proportion, startAmount, endAmount, tkRate); // ç²¾éåºæ°æ®å¤çè¿å å端 JSONArray array = new JSONArray(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); //éååè¡¨æ°æ® for (QualityFactory quality : listQuery) { @@ -1110,6 +1100,7 @@ /** * è¶ é«å¥é * * @param callback * @param page * @param type @@ -1123,13 +1114,11 @@ int pageSize = Constant.PAGE_SIZE; Map<String, String> map = manageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); String fcRate = map.get("hongbao_fc_ratio"); JSONArray array = qualityGoodsService.getRecommendToIndex((page - 1) * pageSize, pageSize, proportion, fcRate); JSONArray array = qualityGoodsService.getRecommendToIndex((page - 1) * pageSize, pageSize, proportion, fcRate); if (array == null) { out.print(JsonUtil.loadFalseResult("æ²¡ææ´å¤äº")); fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java
@@ -12,9 +12,6 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; @@ -62,13 +59,16 @@ import com.yeshi.fanli.entity.taobao.TaoKeAppInfo; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.goods.CommonGoods; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.JumpDetailService; import com.yeshi.fanli.service.inter.config.SystemClientParamsService; import com.yeshi.fanli.service.inter.config.SystemConfigService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.goods.CommonGoodsService; import com.yeshi.fanli.service.inter.goods.HonestService; import com.yeshi.fanli.service.inter.goods.RecommendBannerService; import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService; @@ -103,6 +103,9 @@ import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @Controller @RequestMapping("api/v1/user") @@ -160,7 +163,7 @@ private HonestService honestService; @Resource private CollectionGoodsService collectionGoodsService; private CollectionGoodsV2Service collectionGoodsV2Service; @Resource private HongBaoManageMapper hongBaoManageMapper; @@ -206,6 +209,9 @@ @Resource private MonitorService monitorService; @Resource private CommonGoodsService commonGoodsService; @RequestMapping(value = "getrecommendsection") public void getRecommendSection(AcceptData acceptData, int index, PrintWriter out) { @@ -689,7 +695,7 @@ taoBaoGoodsBriefExtra.getTaoBaoQuanInfo().setCouponLink(tb.getCouponLink()); taoBaoGoodsBriefExtra.setAuctionUrl(tb.getAuctionUrl()); if (uid != null && !"".equals(uid.trim())) { CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid), CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), Long.parseLong(id)); data.put("collection", collectionGoods != null ? true : false); } @@ -977,7 +983,7 @@ // 夿æ¶è if (!StringUtil.isNullOrEmpty(uid)) { CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid), CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), Long.parseLong(id)); data.put("collected", collectionGoods != null ? true : false); } else @@ -1169,7 +1175,9 @@ if (goods == null)// ååä¸çº¿ { // 仿们çåååºæç´¢ CollectionGoods cgoods = collectionGoodsService.findByAuctionId(id); CommonGoods cgoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(id, CommonGoods.GOODS_TYPE_TB); if (cgoods != null) {// ååææ¬å°ç¼å // æååæç´¢åå SearchFilter sf = new SearchFilter(); @@ -1890,7 +1898,7 @@ if (StringUtil.isNullOrEmpty(uid)) { data.put("collected", false); } else { CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid), CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), Long.parseLong(id)); data.put("collected", collectionGoods != null ? true : false); } @@ -2082,8 +2090,8 @@ if (goods == null) { // 仿们çåååºæç´¢ CollectionGoods cgoods = collectionGoodsService.findByAuctionId(id); CommonGoods cgoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(id, CommonGoods.GOODS_TYPE_TB); // ååææ¬å°ç¼å if (cgoods != null) { // æååæç´¢åå @@ -2101,9 +2109,7 @@ } goodsList.add(gds); } } } } fanli/src/main/java/com/yeshi/fanli/controller/client/UserAccountController.java
@@ -9,6 +9,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.yeshi.utils.JsonUtil; import com.alipay.api.AlipayApiException; import com.yeshi.fanli.entity.accept.AcceptData; @@ -29,7 +30,6 @@ import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.InviteGetMoneyService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoService; @@ -49,13 +49,11 @@ import com.yeshi.fanli.service.inter.user.TBPidService; import com.yeshi.fanli.service.inter.user.UserAccountService; import com.yeshi.fanli.service.inter.user.UserInfoService; import com.yeshi.fanli.service.inter.user.WxDownService; import com.yeshi.fanli.util.GsonUtil; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.account.UserUtil; import com.yeshi.fanli.util.wx.WXLoginUtil; import org.yeshi.utils.JsonUtil; import net.sf.json.JSONObject; @@ -118,12 +116,7 @@ private AccountMessageService accountMessageService; @Resource private CollectionGoodsService collectionGoodsService; @Resource private HongBaoManageService hongBaoManageService; @Resource private WxDownService wxDownService; @Resource private UserAccountService userAccountService; fanli/src/main/java/com/yeshi/fanli/controller/client/UserInfoController.java
@@ -15,9 +15,6 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import org.apache.commons.beanutils.PropertyUtils; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; @@ -38,7 +35,6 @@ import com.yeshi.fanli.entity.bus.user.AccountDetails; import com.yeshi.fanli.entity.bus.user.AccountMessage; import com.yeshi.fanli.entity.bus.user.BindingAccount; import com.yeshi.fanli.entity.bus.user.CollectionGoods; import com.yeshi.fanli.entity.bus.user.Extract; import com.yeshi.fanli.entity.bus.user.ExtractRecord; import com.yeshi.fanli.entity.bus.user.HongBao; @@ -59,10 +55,13 @@ import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; import com.yeshi.fanli.exception.BindingAccountException; import com.yeshi.fanli.exception.ObjectStateException; import com.yeshi.fanli.exception.goods.CollectionGoodsException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoService; @@ -94,6 +93,9 @@ import com.yeshi.fanli.util.account.UserUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.util.wx.WXLoginUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @Controller @RequestMapping("api/v1/customer") @@ -151,8 +153,6 @@ private AccountMessageService accountMessageService; @Resource private CollectionGoodsService collectionGoodsService; @Resource private HongBaoManageService hongBaoManageService; @Resource @@ -169,6 +169,9 @@ @Resource private UserActiveLogService userActiveLogService; @Resource private CollectionGoodsV2Service collectionGoodsV2Service; private static final String PASSWORD_MAX_ERROR = "password_max_error"; private static final String EXTRACT_MIN_MONEY = "extract_min_money"; @@ -1419,24 +1422,32 @@ @RequestMapping("collectionGoods") public void collectionGoods(AcceptData acceptData, long uid, long auctionId, int type, PrintWriter out) { CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId); CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId); if (type == 1) { if (find != null) { out.print(JsonUtil.loadFalseResult("")); return; } CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid)); collectionGoodsService.save(cg); try { TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId); collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief); out.print(JsonUtil.loadTrueResult("æ¶èæå")); return; } catch (TaobaoGoodsDownException e) { out.print(JsonUtil.loadFalseResult(1, "åå已䏿¶")); } catch (CollectionGoodsException e1) { out.print(JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg())); } } else { if (find == null) { out.print(JsonUtil.loadTrueResult("åæ¶æ¶èæå")); return; } else { collectionGoodsService.delete(find); try { collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId); out.print(JsonUtil.loadTrueResult("åæ¶æ¶èæå")); return; } catch (CollectionGoodsException e) { out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); } } } @@ -1459,37 +1470,51 @@ return; } CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId); CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId); if (find == null) { // æ·»å æ¶è CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid)); collectionGoodsService.save(cg); try { TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId); collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(1)); } catch (TaobaoGoodsDownException e) { JsonUtil.printMode(out, callback, (JsonUtil.loadFalseResult(1, "åå已䏿¶"))); } catch (CollectionGoodsException e1) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg())); } } else { // åæ¶æ¶è collectionGoodsService.delete(find); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(0)); try { collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("åæ¶æ¶èæå")); } catch (CollectionGoodsException e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); } } } @RequestMapping("collectionGoodsList") public void collectionGoodsList(AcceptData acceptData, long uid, int page, PrintWriter out) { List<CollectionGoods> coList = collectionGoodsService.findCollectionGoods(uid, page + 1); int count = collectionGoodsService.getCount(uid); List<CollectionGoodsV2> collectionGoodsList = collectionGoodsV2Service.getCollectionGoodsList(uid, page + 1, Constant.PAGE_SIZE); // List<CollectionGoods> coList = // collectionGoodsService.findCollectionGoods(uid, page + 1); long count = collectionGoodsV2Service.getCollectionGoodsCount(uid); JSONObject data = new JSONObject(); Map<String, String> map = hongBaoManageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); String fcRate = map.get("hongbao_fc_ratio"); List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>(); coList.parallelStream().forEachOrdered(cg -> { TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.getTaoBaoGoodsBrief(cg); collectionGoodsList.parallelStream().forEachOrdered(cg -> { TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(cg.getCommonGoods()); goodsBrief.setSalesCount(TaoBaoUtil.getSaleCount(goodsBrief.getBiz30day())); TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, fcRate, ""); taoBaoGoodsBriefExtra.setCreatetime(new Date(cg.getCreateTime())); taoBaoGoodsBriefExtra.setCreatetime(cg.getCreateTime()); list.add(taoBaoGoodsBriefExtra); }); GsonBuilder builder = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() { @@ -1517,7 +1542,11 @@ } else { if (!StringUtil.isNullOrEmpty(ids)) { Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> { collectionGoodsService.delete(Long.parseLong(auctionIdStr), uid); try { collectionGoodsV2Service.cancelCollectionByAuctionId(uid, Long.parseLong(auctionIdStr)); } catch (Exception e) { e.printStackTrace(); } }); } } @@ -1526,7 +1555,12 @@ @RequestMapping("clearConllectionGoods") public void clearConllectionGoods(AcceptData acceptData, long uid, PrintWriter out) { collectionGoodsService.clear(uid); try { collectionGoodsV2Service.cancelCollectionByUid(uid); } catch (CollectionGoodsException e) { e.printStackTrace(); out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMessage())); } out.print(JsonUtil.loadTrueResult("å 餿å")); } @@ -1590,9 +1624,9 @@ .loadTrueResult(String.format("%s?id=" + id, Constant.systemCommonConfig.getAppShareInfoUrl()))); } /** * ç¨æ·éåå表æ¥è¯¢ 1.4.1 * * @param acceptData * @param id * @param out @@ -1645,12 +1679,12 @@ resultData.put("secondTeamTotal", secondTeamTotal); resultData.put("boss", bossData); } out.print(JsonUtil.loadTrueResult(resultData)); } /** * ç¨æ·éåç»è®¡ 1.4.1 * * @param acceptData * @param id * @param out @@ -1663,11 +1697,9 @@ long secondTeam = threeSaleSerivce.countSecondTeam(uid, 1); long secondTeamTotal = threeSaleSerivce.countSecondTeam(uid, null); JSONObject bossData = null; JSONObject bossData = new JSONObject(); ThreeSale threeSale = threeSaleSerivce.getMyBoss(uid); if (threeSale != null) { bossData = new JSONObject(); UserInfo boss = threeSale.getBoss(); if (boss != null) { bossData.put("nickName", boss.getNickName()); @@ -1679,7 +1711,6 @@ Date inviteTime = new Date(createTime); bossData.put("inviteTime", "é请æ¶é´: " + sdf.format(inviteTime)); } JSONObject resultData = new JSONObject(); @@ -1699,9 +1730,11 @@ /** * ç¨æ·éåä¿¡æ¯ä¿å 1.4.1 * * @param acceptData * @param uid * @param inviteId é请id * @param inviteId * é请id * @param nickname * @param out */ @@ -1753,9 +1786,11 @@ /** * å é¤éåå ³ç³» * * @param acceptData * @param uid * @param inviteId é请id * @param inviteId * é请id * @param out */ @RequestMapping(value = "removethreesale", method = RequestMethod.POST) fanli/src/main/java/com/yeshi/fanli/controller/h5/H5RecommendController.java
@@ -11,6 +11,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.JsonUtil; import com.google.gson.Gson; import com.google.gson.GsonBuilder; @@ -32,7 +33,6 @@ import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.SystemConfigService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService; import com.yeshi.fanli.service.inter.goods.ShareGoodsService; import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerService; @@ -49,7 +49,6 @@ import com.yeshi.fanli.util.Utils; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import org.yeshi.utils.JsonUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @@ -78,9 +77,6 @@ @Resource private SystemService systemService; @Resource private CollectionGoodsService collectionGoodsService; @Resource private ConfigService configService; fanli/src/main/java/com/yeshi/fanli/controller/web/WebRecommendController.java
@@ -11,6 +11,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.JsonUtil; import com.google.gson.Gson; import com.google.gson.GsonBuilder; @@ -20,17 +21,17 @@ import com.yeshi.fanli.entity.bus.recommend.RecommendSectionGoods; import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendBanner; import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendSection; import com.yeshi.fanli.entity.bus.user.CollectionGoods; import com.yeshi.fanli.entity.system.System; import com.yeshi.fanli.entity.taobao.ScanHistory; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.SystemConfigService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService; import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerService; import com.yeshi.fanli.service.inter.goods.SuperRecommendSectionService; @@ -44,7 +45,6 @@ import com.yeshi.fanli.util.ThreadUtil; import com.yeshi.fanli.util.Utils; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import org.yeshi.utils.JsonUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @@ -75,7 +75,7 @@ private SystemService systemService; @Resource private CollectionGoodsService collectionGoodsService; private CollectionGoodsV2Service collectionGoodsV2Service; @Resource private ConfigService configService; @@ -290,7 +290,7 @@ taoBaoGoodsBriefExtra.getTaoBaoQuanInfo().setCouponLink(tb.getCouponLink()); if (uid != null && !"".equals(uid.trim())) { CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid), CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid), Long.parseLong(id)); data.put("collection", collectionGoods != null ? true : false); } fanli/src/main/java/com/yeshi/fanli/controller/xcx/XcxRecommendController.java
@@ -8,6 +8,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.JsonUtil; import com.google.gson.Gson; import com.google.gson.GsonBuilder; @@ -21,7 +22,6 @@ import com.yeshi.fanli.service.inter.config.JumpDetailService; import com.yeshi.fanli.service.inter.config.SystemConfigService; import com.yeshi.fanli.service.inter.config.SystemService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.HonestService; import com.yeshi.fanli.service.inter.goods.RecommendBannerService; import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService; @@ -43,7 +43,6 @@ import com.yeshi.fanli.util.taobao.DaTaoKeUtil; import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import org.yeshi.utils.JsonUtil; import net.sf.json.JSONObject; @@ -108,8 +107,7 @@ @Resource private HonestService honestService; @Resource private CollectionGoodsService collectionGoodsService; @Resource private HongBaoManageMapper hongBaoManageMapper; fanli/src/main/java/com/yeshi/fanli/controller/xcx/XcxUserInfoController.java
@@ -11,22 +11,26 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import net.sf.json.JSONObject; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.HttpUtil; import org.yeshi.utils.IPUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.tencentcloud.COSManager; import com.yeshi.fanli.entity.accept.AcceptData; import com.yeshi.fanli.entity.bus.user.CollectionGoods; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.bus.user.WeiXinUser; import com.yeshi.fanli.entity.system.System; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; import com.yeshi.fanli.exception.goods.CollectionGoodsException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService; import com.yeshi.fanli.service.inter.hongbao.HongBaoService; @@ -45,14 +49,13 @@ import com.yeshi.fanli.service.inter.user.WxDownService; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.GsonUtil; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.ThreadUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.util.wx.WXLoginUtil; import org.yeshi.utils.HttpUtil; import org.yeshi.utils.IPUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.tencentcloud.COSManager; import net.sf.json.JSONObject; @Controller @RequestMapping("api/xcx/v1/XcxCustomer") @@ -107,12 +110,15 @@ private AccountMessageService accountMessageService; @Resource private CollectionGoodsService collectionGoodsService; private CollectionGoodsV2Service collectionGoodsV2Service; @Resource private HongBaoManageService hongBaoManageService; @Resource private WxDownService wxDownService; @Resource private RedisManager redisManager; /** * è·åç¨æ·ä¿¡æ¯ @@ -194,9 +200,10 @@ // æ¥è¯¢å°çç¨æ·ä¿¡æ¯ä¸ºç©º,é£ä¹éè¦å¡«å ä¸äºç¨æ·ä¿¡æ¯ if (loginType == Constant.WEIXIN) { form.setPortrait(weiXinUser.getHeadimgurl()); String wxHeadImg = COSManager.getInstance().uploadFile( HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()), Constant.WXHEADURL + UUID.randomUUID().toString()).getUrl(); String wxHeadImg = COSManager.getInstance() .uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()), Constant.WXHEADURL + UUID.randomUUID().toString()) .getUrl(); form.setWxPic(wxHeadImg); form.setNickName(weiXinUser.getNickname()); form.setWxName(weiXinUser.getNickname()); @@ -259,9 +266,10 @@ form.setPortrait(xinUser.getHeadimgurl()); form.setNickName(xinUser.getNickname()); form.setWxName(xinUser.getNickname()); String wxHeadImg = COSManager.getInstance().uploadFile( HttpUtil.getAsInputStream(xinUser.getHeadimgurl()), Constant.WXHEADURL + UUID.randomUUID().toString()).getUrl(); String wxHeadImg = COSManager.getInstance() .uploadFile(HttpUtil.getAsInputStream(xinUser.getHeadimgurl()), Constant.WXHEADURL + UUID.randomUUID().toString()) .getUrl(); form.setWxPic(wxHeadImg); } else if (formLoginType == Constant.TAOBAO) { form.setTbName(form.getNickName()); @@ -348,24 +356,32 @@ */ @RequestMapping("collectionGoods") public void collectionGoods(long uid, long auctionId, int type, PrintWriter out) { CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId); CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId); if (type == 1) { if (find != null) { out.print(JsonUtil.loadFalseResult("æ¨å·²æ¶è")); out.print(JsonUtil.loadFalseResult("")); return; } CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid)); collectionGoodsService.save(cg); try { TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId); collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief); out.print(JsonUtil.loadTrueResult("æ¶èæå")); return; } catch (TaobaoGoodsDownException e) { out.print(JsonUtil.loadFalseResult(1, "åå已䏿¶")); } catch (CollectionGoodsException e1) { out.print(JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg())); } } else { if (find == null) { out.print(JsonUtil.loadTrueResult("åæ¶æ¶èæå")); return; } else { collectionGoodsService.delete(find); try { collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId); out.print(JsonUtil.loadTrueResult("åæ¶æ¶èæå")); return; } catch (CollectionGoodsException e) { out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); } } } } @@ -381,20 +397,20 @@ */ @RequestMapping("collectionGoodsList") public void collectionGoodsList(long uid, int page, int pageSize, PrintWriter out) { List<CollectionGoods> coList = collectionGoodsService.findCollectionGoods(uid, page); int count = collectionGoodsService.getCount(uid); List<CollectionGoodsV2> coList = collectionGoodsV2Service.getCollectionGoodsList(uid, page, pageSize); long count = collectionGoodsV2Service.getCollectionGoodsCount(uid); JSONObject data = new JSONObject(); Map<String, String> map = hongBaoManageService.convertMap(); String proportion = map.get("hongbao_goods_proportion"); String fcRate = map.get("hongbao_fc_ratio"); List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>(); coList.parallelStream().forEachOrdered(cg -> { TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.getTaoBaoGoodsBrief(cg); TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(cg.getCommonGoods()); TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, fcRate,""); list.add(taoBaoGoodsBriefExtra); }); int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); data.put("totalPage", totalPage); data.put("list", GsonUtil.toJsonExpose(list)); data.put("count", count); @@ -414,7 +430,11 @@ public void deleteCollectionGoods(String ids, long uid, PrintWriter out) { if (ids != null) { Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> { collectionGoodsService.delete(Long.parseLong(auctionIdStr), uid); try { collectionGoodsV2Service.cancelCollection(uid, Long.parseLong(auctionIdStr)); } catch (Exception e) { e.printStackTrace(); } }); } @@ -431,7 +451,11 @@ */ @RequestMapping("clearConllectionGoods") public void clearConllectionGoods(long uid, PrintWriter out) { collectionGoodsService.clear(uid); try { collectionGoodsV2Service.cancelCollectionByUid(uid); } catch (CollectionGoodsException e) { e.printStackTrace(); } out.print(JsonUtil.loadTrueResult("å 餿å")); } fanli/src/main/java/com/yeshi/fanli/dao/mybatis/goods/CollectionGoodsV2Mapper.java
@@ -46,6 +46,25 @@ * @param uid * @return */ List<CollectionGoodsV2> selectCountByUid(@Param("uid") Long uid); long selectCountByUid(@Param("uid") Long uid); /** * æ ¹æ®ç¨æ·ID,ååIDï¼ååç±»åæ¥è¯¢åå * * @param id * @param goodsType * @param goodsId * @return */ CollectionGoodsV2 selectByUidAndGoodsTypeAndGoodsId(@Param("uid") Long uid, @Param("goodsType") int goodsType, @Param("goodsId") Long goodsId); /** * æ ¹æ®UIDå 餿¶è * * @param uid * @return */ int deleteByUid(@Param("uid") Long uid); } fanli/src/main/java/com/yeshi/fanli/mapping/goods/CollectionGoodsV2Mapper.xml
@@ -12,8 +12,7 @@ </association> <association property="commonGoods" column="cg_common_goods_id" javaType="com.yeshi.fanli.goods.CommonGoods" resultMap="com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper.BaseResultMap"> select="com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper.selectByPrimaryKey"> </association> </resultMap> @@ -47,7 +46,7 @@ <!-- è·åæ¶èçæ°é --> <select id="selectCountByUid" resultMap="BaseResultMap" <select id="selectCountByUid" resultType="java.lang.Long" parameterType="java.lang.Long"> select count(cg_id) @@ -55,6 +54,26 @@ where cg_uid = #{uid} </select> <select id="selectByUidAndGoodsTypeAndGoodsId" resultMap="BaseResultMap"> select v2.* from yeshi_ec_collection_goods_v2 v2 left join yeshi_ec_common_goods g on g.cg_id=v2.cg_common_goods_id where v2.cg_uid = #{uid} and g.cg_goods_id=#{goodsId} and g.cg_goods_type=#{goodsType} limit 1 </select> <!-- æ ¹æ®UIDå 餿¶è --> <delete id="deleteByUid" parameterType="java.lang.Long">delete from yeshi_ec_collection_goods_v2 where cg_uid = #{uid} </delete> <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">delete from yeshi_ec_collection_goods_v2 where cg_id = #{id,jdbcType=BIGINT} </delete> fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsServiceImpl.java
File was deleted fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java
@@ -62,6 +62,26 @@ collectionGoodsV2Mapper.insertSelective(collectionGoodsV2); } @Override public void addCollection(CollectionGoodsV2 goods) throws CollectionGoodsException { if (goods.getUserInfo() == null || goods.getCommonGoods() == null) throw new CollectionGoodsException(1, "æ°æ®ä¸å®æ´"); try { CommonGoods commonGoods = commonGoodsService.addOrUpdateCommonGoods(goods.getCommonGoods()); goods.setCommonGoods(commonGoods); } catch (CommonGoodsException e) { goods.setCommonGoods(null); } if (goods.getCommonGoods() == null) throw new CollectionGoodsException(3, "ååä¿¡æ¯æ·»å 失败"); CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper .selectByUidAndCommonGoodsId(goods.getUserInfo().getId(), goods.getCommonGoods().getId()); if (collectionGoodsV2 != null) throw new CollectionGoodsException(4, "åå已被æ¶è"); collectionGoodsV2Mapper.insertSelective(goods); } @Transactional @Override @@ -82,12 +102,33 @@ @Override public List<CollectionGoodsV2> getCollectionGoodsList(Long uid, int page, int pageSize) { return null; return collectionGoodsV2Mapper.selectByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize); } @Override public long getCollectionGoodsCount(Long uid) { return 0; return collectionGoodsV2Mapper.selectCountByUid(uid); } @Override public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException { CollectionGoodsV2 goodsV2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, CommonGoods.GOODS_TYPE_TB, auctionId); if (goodsV2 == null) throw new CollectionGoodsException(1, "æ æ¶è"); collectionGoodsV2Mapper.deleteByPrimaryKey(goodsV2.getId()); } @Override public void cancelCollectionByUid(Long uid) throws CollectionGoodsException { collectionGoodsV2Mapper.deleteByUid(uid); } @Override public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId) { CollectionGoodsV2 v2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, CommonGoods.GOODS_TYPE_TB, actionId); return v2; } } fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CommonGoodsServiceImpl.java
@@ -94,4 +94,9 @@ commonGoodsMapper.updateByPrimaryKeySelective(update); } @Override public CommonGoods getCommonGoodsByGoodsIdAndGoodsType(Long goodsId, int goodsType) { return commonGoodsMapper.selectByGoodsIdAndGoodsType(goodsId, goodsType); } } fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java
@@ -13,15 +13,18 @@ import com.google.gson.Gson; import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.exception.goods.CommonGoodsException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException; import com.yeshi.fanli.goods.CommonGoods; import com.yeshi.fanli.service.inter.activity.ActivityService; import com.yeshi.fanli.service.inter.goods.CollectionGoodsService; import com.yeshi.fanli.service.inter.goods.CommonGoodsService; import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService; import com.yeshi.fanli.service.inter.lable.QualityFactoryService; import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService; import com.yeshi.fanli.util.BeanUtil; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.factory.CommonGoodsFactory; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; @Service @@ -39,7 +42,7 @@ private TaoBaoGoodsBriefMapper taoBaoGoodsBriefMapper; @Resource private CollectionGoodsService collectionGoodsService; private CommonGoodsService commonGoodsService; @Override public void startUpdate() { @@ -103,7 +106,11 @@ throw new TaobaoGoodsUpdateException(2, "ååID为空"); // æ´æ°æ¶èä¿¡æ¯ collectionGoodsService.updateCollectionGoods(goods); try { commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(goods)); } catch (CommonGoodsException e) { e.printStackTrace(); } List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsBriefMapper.queryByAuctionId(goods.getAuctionId()); if (goodsList != null) fanli/src/main/java/com/yeshi/fanli/service/impl/user/BindingAccountServiceImpl.java
@@ -246,7 +246,7 @@ public boolean canVerifyAlipayAccount(Long uid) throws BindingAccountException { UserInfo userInfo = userInfoMapper.selectByPrimaryKeyForUpdate(uid); if (userInfo.getMyHongBao().compareTo(new BigDecimal("0")) <= 0) throw new BindingAccountException(1, "è´¦æ·æ ä½é¢"); throw new BindingAccountException(1, "ä½ çè´¦æ·ç®å没æä½é¢ï¼æ éç»å®æç°å¸å·ã"); AlipayAccountValidNormalHistory latest = alipayAccountValidNormalHistoryMapper.selectLatestByUid(uid); if (latest != null) { fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CollectionGoodsService.java
File was deleted fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CollectionGoodsV2Service.java
@@ -9,6 +9,7 @@ public interface CollectionGoodsV2Service { /** * æ·»å æ¶è * * @param uid * ç¨æ·ID @@ -17,6 +18,14 @@ * @throws CollectionGoodsException */ public void addCollection(Long uid, TaoBaoGoodsBrief goods) throws CollectionGoodsException; /** * æ·»å æ¶è * * @param goods * @throws CollectionGoodsException */ public void addCollection(CollectionGoodsV2 goods) throws CollectionGoodsException; /** * åæ¶æ¶è @@ -28,6 +37,25 @@ * @throws CollectionGoodsException */ public void cancelCollection(Long uid, Long id) throws CollectionGoodsException; /** * åæ¶æ¶è * * @param uid * -ç¨æ·ç¼å· * @param auctionId * -ååID * @throws CollectionGoodsException */ public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException; /** * åæ¶æ¶è * * @param uid * @throws CollectionGoodsException */ public void cancelCollectionByUid(Long uid) throws CollectionGoodsException; /** * è·åæ¶èè®°å½ @@ -47,4 +75,13 @@ */ public long getCollectionGoodsCount(Long uid); /** * æ ¹æ®ç¨æ·IDåæ·å®ååIDæ¥è¯¢æ¯å¦æ¶è * * @param uid * @param actionId * @return */ public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId); } fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CommonGoodsService.java
@@ -36,4 +36,13 @@ */ public void offlineCommonGoods(Long goodsId, int goodsType); /** * æ ¹æ®ååIDåååç±»åæ¥è¯¢åºåå * * @param goodsId * @param goodsType * @return */ CommonGoods getCommonGoodsByGoodsIdAndGoodsType(Long goodsId, int goodsType); } fanli/src/main/java/com/yeshi/fanli/util/Constant.java
@@ -14,9 +14,9 @@ public static boolean IS_TASK = false; // å¤ç½ç¯å¢ public static boolean IS_OUTNET = true; public static boolean IS_OUTNET = false; public static boolean IS_TEST = false; public static boolean IS_TEST = true; public static int PAGE_SIZE = 20; public static int[] TASK_TYPE = { 1001, 1002, 1003, 1004, 1005, 1006, 1007, 1008// 微信任å¡ç±»åç¼å· fanli/src/main/java/com/yeshi/fanli/util/factory/CollectionGoodsFactory.java
New file @@ -0,0 +1,23 @@ package com.yeshi.fanli.util.factory; import com.yeshi.fanli.entity.bus.user.CollectionGoods; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.goods.CollectionGoodsV2; import com.yeshi.fanli.goods.CommonGoods; import com.yeshi.fanli.util.taobao.TaoBaoUtil; public class CollectionGoodsFactory { public static CollectionGoods create(CollectionGoodsV2 collectionGoods) { if (collectionGoods == null) return null; CollectionGoods cg = null; CommonGoods commnonGoods = collectionGoods.getCommonGoods(); TaoBaoGoodsBrief taoBaoGoods = TaoBaoUtil.convert(commnonGoods); cg = TaoBaoUtil.getCollectionGoods(taoBaoGoods, collectionGoods.getUserInfo()); if (cg != null) cg.setId(collectionGoods.getId()); return cg; } } fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoBaoUtil.java
@@ -1425,6 +1425,35 @@ return collectionGoods; } public static CollectionGoods getCollectionGoods(TaoBaoGoodsBrief taoBaoGoodsBrief, UserInfo userInfo) { if (taoBaoGoodsBrief == null) return null; CollectionGoods collectionGoods = new CollectionGoods(); Field[] fields = taoBaoGoodsBrief.getClass().getDeclaredFields(); Field[] shFields = collectionGoods.getClass().getDeclaredFields(); for (int i = 0; i < fields.length; i++) { Field field = fields[i]; field.setAccessible(true); try { for (Field target : shFields) { target.setAccessible(true); if (target.getName().equalsIgnoreCase(field.getName())) { if (!field.getName().equalsIgnoreCase("createTime")) target.set(collectionGoods, field.get(taoBaoGoodsBrief)); break; } } } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } } collectionGoods.setUserInfo(userInfo); return collectionGoods; } /** * è·åååçç¨æ·åææ¯ä¾ * fanli/src/main/resource/druid.properties
@@ -22,15 +22,15 @@ #å¤ç½æ£å¼ druid.url=jdbc:mysql://172.16.16.17:3306/ec_quan druid.username=root druid.password=Yeshi2016@ #å¤ç½æ¬å°æµè¯ #druid.url=jdbc:mysql://gz-cdb-r13d0yi9.sql.tencentcdb.com:62929/ec_quan #druid.url=jdbc:mysql://172.16.16.17:3306/ec_quan #druid.username=root #druid.password=Yeshi2016@ #å¤ç½æ¬å°æµè¯ druid.url=jdbc:mysql://gz-cdb-r13d0yi9.sql.tencentcdb.com:62929/ec_quan druid.username=root druid.password=Yeshi2016@ druid.initialSize=10 druid.minIdle=6 druid.maxActive=100 fanli/src/main/resource/uml/Ä£¿é»®·Ö.acd
@@ -925,8 +925,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>1133</x> <y>336</y> <x>1107</x> <y>155</y> </constraint> <sourceConnections> <net.java.amateras.uml.activitydiagram.model.FlowModel> @@ -1049,8 +1049,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>771</x> <y>42</y> <x>541</x> <y>44</y> </constraint> <sourceConnections/> <targetConnections> @@ -1092,8 +1092,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>884</x> <y>50</y> <x>654</x> <y>52</y> </constraint> <sourceConnections/> <targetConnections> @@ -1135,8 +1135,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>963</x> <y>122</y> <x>733</x> <y>124</y> </constraint> <sourceConnections/> <targetConnections> @@ -1178,8 +1178,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>948</x> <y>197</y> <x>718</x> <y>199</y> </constraint> <sourceConnections/> <targetConnections> @@ -1221,8 +1221,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>807</x> <y>223</y> <x>577</x> <y>225</y> </constraint> <sourceConnections/> <targetConnections> @@ -1316,8 +1316,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>1172</x> <y>249</y> <x>1146</x> <y>68</y> </constraint> <sourceConnections/> <targetConnections> @@ -1359,8 +1359,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>1136</x> <y>438</y> <x>1110</x> <y>257</y> </constraint> <sourceConnections/> <targetConnections> @@ -2110,8 +2110,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>812</x> <y>128</y> <x>582</x> <y>130</y> </constraint> <sourceConnections> <net.java.amateras.uml.activitydiagram.model.FlowModel reference="../../parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel[14]/targetConnections/net.java.amateras.uml.activitydiagram.model.FlowModel"/> @@ -2148,8 +2148,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>694</x> <y>133</y> <x>464</x> <y>135</y> </constraint> <sourceConnections/> <targetConnections> @@ -2194,8 +2194,8 @@ <constraint> <height>-1</height> <width>-1</width> <x>924</x> <y>328</y> <x>898</x> <y>147</y> </constraint> <sourceConnections/> <targetConnections> @@ -2449,6 +2449,62 @@ <net.java.amateras.uml.activitydiagram.model.ActionModel reference="../net.java.amateras.uml.activitydiagram.model.ObjectModel/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel/targetConnections/net.java.amateras.uml.activitydiagram.model.FlowModel/source/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel[4]/target/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel[2]/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[3]/sourceConnections/net.java.amateras.uml.model.AnchorModel/target/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[4]/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel/target/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[5]/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[6]/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[6]/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel[31]"/> <net.java.amateras.uml.model.NoteModel reference="../net.java.amateras.uml.activitydiagram.model.ObjectModel/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel/targetConnections/net.java.amateras.uml.activitydiagram.model.FlowModel/source/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel[4]/target/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel[2]/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[3]/sourceConnections/net.java.amateras.uml.model.AnchorModel/target"/> <net.java.amateras.uml.activitydiagram.model.ActionModel reference="../net.java.amateras.uml.activitydiagram.model.ObjectModel/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel/targetConnections/net.java.amateras.uml.activitydiagram.model.FlowModel/source/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel[4]/target/parent/children/net.java.amateras.uml.activitydiagram.model.ActionModel[2]/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[3]/sourceConnections/net.java.amateras.uml.model.AnchorModel/target/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[4]/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel/target/parent/children/net.java.amateras.uml.activitydiagram.model.ObjectModel[5]/sourceConnections/net.java.amateras.uml.activitydiagram.model.FlowModel[6]/target"/> <net.java.amateras.uml.activitydiagram.model.ObjectModel> <backgroundColor reference="../../../backgroundColor"/> <foregroundColor reference="../../../foregroundColor"/> <showIcon>true</showIcon> <parent class="net.java.amateras.uml.activitydiagram.model.ActivityModel" reference="../../.."/> <listeners serialization="custom"> <java.beans.PropertyChangeSupport> <default> <source class="net.java.amateras.uml.activitydiagram.model.ObjectModel" reference="../../../.."/> <propertyChangeSupportSerializedDataVersion>2</propertyChangeSupportSerializedDataVersion> </default> <null/> </java.beans.PropertyChangeSupport> </listeners> <constraint> <height>-1</height> <width>-1</width> <x>543</x> <y>508</y> </constraint> <sourceConnections/> <targetConnections/> <children/> <filterProperty/> <stereoType></stereoType> <objectName>æ¶æ¯æå¡</objectName> <objectState></objectState> </net.java.amateras.uml.activitydiagram.model.ObjectModel> <net.java.amateras.uml.activitydiagram.model.ObjectModel> <backgroundColor reference="../../../backgroundColor"/> <foregroundColor reference="../../../foregroundColor"/> <showIcon>true</showIcon> <parent class="net.java.amateras.uml.activitydiagram.model.ActivityModel" reference="../../.."/> <listeners serialization="custom"> <java.beans.PropertyChangeSupport> <default> <source class="net.java.amateras.uml.activitydiagram.model.ObjectModel" reference="../../../.."/> <propertyChangeSupportSerializedDataVersion>2</propertyChangeSupportSerializedDataVersion> </default> <null/> </java.beans.PropertyChangeSupport> </listeners> <constraint> <height>-1</height> <width>-1</width> <x>856</x> <y>345</y> </constraint> <sourceConnections/> <targetConnections/> <children/> <filterProperty/> <stereoType></stereoType> <objectName>ç¼åæå¡</objectName> <objectState></objectState> </net.java.amateras.uml.activitydiagram.model.ObjectModel> </children> <filterProperty/> </net.java.amateras.uml.activitydiagram.model.ActivityModel> fanli/src/test/java/org/fanli/TBImgTest.java
@@ -13,7 +13,7 @@ import com.yeshi.fanli.util.ImageUtil; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; //@Ignore @Ignore public class TBImgTest { @Test