淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/controller/admin/QualityFactoryAdminController.java

@@ -1,1002 +1,935 @@
package com.yeshi.fanli.controller.admin;



import java.io.PrintWriter;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



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.yeshi.utils.JsonUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.google.gson.reflect.TypeToken;

import com.yeshi.fanli.entity.bus.lable.BoutiqueAutoRule;

import com.yeshi.fanli.entity.bus.lable.Label;

import com.yeshi.fanli.entity.bus.lable.LabelGoods;

import com.yeshi.fanli.entity.bus.lable.QualityFactory;

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.exception.QualityFactoryException;

import com.yeshi.fanli.service.AdminUserService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.lable.LabelGoodsService;

import com.yeshi.fanli.service.inter.lable.LabelService;

import com.yeshi.fanli.service.inter.lable.QualityFactoryService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;

import com.yeshi.fanli.tag.PageEntity;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



@Controller

@RequestMapping("admin/new/api/v1/qualityFactory")

public class QualityFactoryAdminController {



   @Resource

   private RedisManager redisManager;

   @Resource

   private LabelService labelService;

   @Resource

   private LabelGoodsService labelGoodsService;

   @Resource

   private QualityFactoryService qualityFactoryService;

   @Resource

   private TaoBaoGoodsBriefService taoBaoGoodsBriefService;

   @Resource

   private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

	
   @Resource

   private AdminUserService adminUserService;

	
	


   public static final int SALES_ASC = 1;

   public static final int SALES_DESC = 2;



   public static final int PRICE_ASC = 3;

   public static final int PRICE_DESC = 4;



   public static final int TKRATE_ASC = 5;

   public static final int TKRATE_DESC = 6;

	
	
   public static final int PROPOR_ASC = 7;

   public static final int PROPOR_DESC = 8;



   /**

    * 批量添加标签 --- 淘宝

    * 
    * @param callback

    * @param label

    * @param request

    * @param out

    */

   @RequestMapping(value = "addBatch")

   public void addBatch(String callback, String auctionIds, String lableNames, HttpServletRequest request, PrintWriter out) {



      try {

         // 获取当前操作用户

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         if (admin == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));

            return;

         }



         if (StringUtil.isNullOrEmpty(auctionIds)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择正确的商品入库")));

            return;

         }



         Gson gson = new Gson();

         List<Long> auctionIdList = gson.fromJson(auctionIds, new TypeToken<ArrayList<Long>>() {

         }.getType());

         if (auctionIdList == null || auctionIdList.size() == 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择正确的商品入库")));

            return;

         }



         qualityFactoryService.addBatch(auctionIdList,lableNames, admin);



         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("添加成功")));



      } catch (Exception e) {

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }

   }

	


	


   /**

    * 保存修改精品库商品关联信息

    * 
    * @param callback

    * @param label

    * @param request

    * @param out

    */

   @RequestMapping(value = "saveModify")

   public void saveModify(String callback, QualityFactory selectionGoods, HttpServletRequest request, PrintWriter out) {



      try {

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);



         if (admin == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));

         } else {



            Long id = selectionGoods.getId();

            QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);



            if (resultObj == null) {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));

            } else {

               Date nowTime = new Date();

               selectionGoods.setUpdatetime(nowTime);

               selectionGoods.setUpdateUser(admin);

               // 选择性更新数据

               int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);



               if (result > 0) {

                  out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));

               } else {

                  out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));

               }

            }

         }



      } catch (QualityFactoryException e) {

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }



   }



   /**

    * 统计商品数量

    * 
    * @param callback

    * @param out

    */

   @RequestMapping(value = "getCountAll")

   public void getCountAll(String callback, PrintWriter out) {



      try {



         Map<String, Object> countMap = qualityFactoryService.getCountAll();



         JSONObject data = new JSONObject();

         data.put("countData", countMap);

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));



      } catch (Exception e) {

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("系统异常")));

      }

   }



   /**

    * 批量移除商品至精品库外-不删除商品

    * 
    * @param callback

    * @param ids

    *            商品id

    * @param out

    */

   @RequestMapping(value = "removeGoods")

   public void removeGoods(String callback, String ids, PrintWriter out) {

      try {



         Gson gson = new Gson();

         List<String> goodsIds = gson.fromJson(ids, new TypeToken<ArrayList<String>>() {}.getType());



         if (goodsIds == null || goodsIds.size() == 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未检测到移除商品数据")));

         } else {

            // 商品移除精品库

            qualityFactoryService.deleteByGoodsId(goodsIds);

            // 清理商品所有标签

            labelGoodsService.deleteByGoodsId(goodsIds);



            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("移除成功")));

         }



      } catch (Exception e) {

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作失败")));

         e.printStackTrace();

      }



   }



   /**

    * 
    * @param callback

    * @param pageIndex

    * @param key

    *            搜索

    * @param totalSales

    *            销售量

    * @param price

    *            价格

    * @param tkRate

    *            佣金比例

    * @param goodsSource

    * @param days

    * @param startZkPrice

    * @param endZkPrice

    * @param startBiz30day

    * @param endBiz30day

    * @param startWeight

    * @param endWeight

    * @param startTkRate

    * @param endTkRate

    * @param startAmount

    * @param endAmount

    * @param hasCoupon

    * @param freeShipment

    * @param isPrepay

    * @param payRate30

    * @param goodRate

    * @param rfdRate

    * @param out

    */

   @RequestMapping(value = "query")

   public void query(String callback, Integer pageIndex,Integer pageSize, String key, Integer sort, Integer goodsSource,

         Integer days, Integer startZkPrice, Integer endZkPrice, Integer startBiz30day, 
         Integer endBiz30day, Integer startWeight, Integer endWeight, Integer startTkRate,

         Integer endTkRate, Integer startAmount, Integer endAmount, Integer hasCoupon, 
         Integer freeShipment, Integer isPrepay, Integer payRate30, Integer goodRate, Integer rfdRate,

         Integer startPropor, Integer endPropor,Long gcid, Integer keyType, PrintWriter out) {



      try {

         if (pageSize == null)

            pageSize = Constant.PAGE_SIZE;



         if (pageIndex == null)

            pageIndex = 1;



         Integer price = null;

         Integer tkRate = null;

         Integer totalSales = null;

         Integer propor = null;



         if (sort != null) {

            switch (sort) {

            case SALES_ASC:

               totalSales = 1;

               break;

            case SALES_DESC:

               totalSales = 2;

               break;

            case PRICE_ASC:

               price = 1;

               break;

            case PRICE_DESC:

               price = 2;

               break;

            case TKRATE_ASC:

               tkRate = 1;

               break;

            case TKRATE_DESC:

               tkRate = 2;

               break;

            case PROPOR_ASC:

               propor = 1;

               break;

            case PROPOR_DESC:   
               propor = 2;

               break;

            default:

               break;

            }

         }

			


         List<QualityFactory> selectionList = qualityFactoryService.query((pageIndex - 1) * pageSize, pageSize, key, totalSales,

               price, tkRate, propor, goodsSource, days, startZkPrice, endZkPrice, startBiz30day, endBiz30day, 
               startWeight, endWeight, startTkRate, endTkRate, startAmount, endAmount, hasCoupon, 
               freeShipment, isPrepay, payRate30, goodRate, rfdRate, startPropor,  endPropor, gcid, keyType);



         /* 暂无数据显示 */

         if (selectionList == null || selectionList.size() == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));

            return;

         }



         /* 有数据：处理返回格式 */



         long count = qualityFactoryService.queryCount(key, goodsSource, days, startZkPrice, endZkPrice, startBiz30day, 
               endBiz30day, startWeight, endWeight, startTkRate, endTkRate, startAmount,

               endAmount, hasCoupon, freeShipment, isPrepay, payRate30, goodRate, rfdRate,

               startPropor, endPropor, gcid, keyType);



         int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);



         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);



         List<Map<String, Object>> listmap = new ArrayList<Map<String, Object>>();



         /*  验证网络: 获取商品链接 图片链接   */

         List<TaoBaoGoodsBrief> goodsBriefList = new ArrayList<TaoBaoGoodsBrief>();

			
         StringBuffer idBuf = new StringBuffer();

         StringBuffer auctionIdBuf = new StringBuffer();

			
         int j = 0;

         for (int i = 0; i < selectionList.size(); i++ ) {

            QualityFactory selectionGoods = selectionList.get(i);

				
            TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();

            if (taoBaoGoodsBrief == null)

               continue; // 为空结束本次循环

				
				
            Long id = taoBaoGoodsBrief.getId();

            idBuf.append(id + ",");

				
            Long auctionId = taoBaoGoodsBrief.getAuctionId();

            if (auctionId != null) {

               j++;

               auctionIdBuf.append(auctionId + ",");

            }

				
            if (selectionList.size() <= 40) {

               // 小于40个参数

               if (i == selectionList.size()-1 ){

                  if (auctionIdBuf != null && auctionIdBuf.length() > 0) {

                     String auctionIds = auctionIdBuf.toString();

                     String ids = auctionIds.substring(0, auctionIds.length() -1);

                     List<TaoBaoGoodsBrief> list = TaoKeApiUtil.getBatchGoodsInfos(ids);

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

                        goodsBriefList.addAll(list);

                     }

							
                     auctionIdBuf = new StringBuffer();

                  }

               }

            } else {

               if (j == 40) {

                  // 大于40参数

                  String auctionIds = auctionIdBuf.toString();

                  String ids = auctionIds.substring(0, auctionIds.length() -1);

                  List<TaoBaoGoodsBrief> list = TaoKeApiUtil.getBatchGoodsInfos(ids);

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

                     goodsBriefList.addAll(list);

                  }

						
                  j= 0;

                  auctionIdBuf = new StringBuffer();

						
               } else if (i == selectionList.size()-1 ){

                  // 最后一个

                  String auctionIds = auctionIdBuf.toString();

                  String ids = auctionIds.substring(0, auctionIds.length() -1);

                  List<TaoBaoGoodsBrief> list = TaoKeApiUtil.getBatchGoodsInfos(ids);

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

                     goodsBriefList.addAll(list);

                  }

                  auctionIdBuf = new StringBuffer();

               }

            }

				
         }

			
			
         for (QualityFactory selectionGoods : selectionList) {



            TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();

            if (taoBaoGoodsBrief == null)

               continue; // 为空结束本次循环



            Map<String, Object> map = new HashMap<String, Object>();

				
            BoutiqueAutoRule boutiqueAutoRule = selectionGoods.getBoutiqueAutoRule();

            if (boutiqueAutoRule == null) {

               boutiqueAutoRule = new BoutiqueAutoRule();

               selectionGoods.setBoutiqueAutoRule(boutiqueAutoRule);

            }

				
            String reslutSource = "";

            Integer gsSource = selectionGoods.getGoodsSource();

            if (QualityFactory.SOURCE_TAOBAO == gsSource ) {

               reslutSource = "淘宝";

            } else if (QualityFactory.SOURCE_TAOBAO_MATERIAL == gsSource) {

               reslutSource = "淘宝推荐";

            } else if (QualityFactory.SOURCE_TAOBAO_DATAOKE == gsSource) {

               reslutSource = "大淘客";

            } else if (QualityFactory.SOURCE_JINGDONG == gsSource) {

               reslutSource = "京东";

            } else if (QualityFactory.SOURCE_PINDUODUO == gsSource) {

               reslutSource = "拼多多";

            } else if (QualityFactory.SOURCE_WEIPINHUI == gsSource) {

               reslutSource = "唯品会";

            } else if (QualityFactory.SOURCE_OTHER == gsSource) {

               reslutSource = "商务合作";

            }

				
            map.put("goodsSource", reslutSource);

				
				
            map.put("selectionGoods", selectionGoods);



            /* 商品销售状态： 0 在售 1停售 */

            int saleStae = 1;

            Long auctionId = taoBaoGoodsBrief.getAuctionId();

            if (auctionId != null) {

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

                  for (TaoBaoGoodsBrief tb :goodsBriefList) {

                     Long auctionIdTB = tb.getAuctionId();

                     if (auctionId.equals(auctionIdTB)) {

                        saleStae = 0;

                     }

                  }

               } 
            }

				
            map.put("saleStae", saleStae);

				


            /* 1 定向计划 2 营销返利 、高佣 3 普佣 */

            Integer includeDxjh = taoBaoGoodsBrief.getIncludeDxjh();

            String tkMktStatus = taoBaoGoodsBrief.getTkMktStatus();



            boolean include = false;

            if (includeDxjh != null) {

               if (includeDxjh == 1) {

                  // 定向计划

                  map.put("yongjinType", 1);

                  include = true;

               }

            }



            if (!include) {



               if ("1".equals(tkMktStatus)) {

                  // 营销返利 、高佣

                  map.put("yongjinType", 2);

               } else {

                  // 普佣

                  map.put("yongjinType", 3);

               }

            }

				
				
				
            // TODO /* 券后价--计算 */

            BigDecimal couponPrice = TaoBaoUtil.getAfterUseCouplePrice(taoBaoGoodsBrief);

            map.put("couponPrice", couponPrice);



            // TODO /* 预计收益： 公司、用户 */

            BigDecimal tkRateBrief = taoBaoGoodsBrief.getTkRate();

            BigDecimal zkPrice = taoBaoGoodsBrief.getZkPrice();

            BigDecimal profit = MoneyBigDecimalUtil.mul(tkRateBrief, zkPrice);

            // 计算结果

            BigDecimal estimateProfit = MoneyBigDecimalUtil.div(profit, new BigDecimal("100"));

            // 预计收益

            map.put("estimateProfit", estimateProfit);

				
				
            BigDecimal couponAmount = taoBaoGoodsBrief.getCouponAmount();

            if (couponAmount != null && zkPrice != null) {

               BigDecimal propors = couponAmount.divide(zkPrice ,10 ,BigDecimal.ROUND_HALF_DOWN);

               BigDecimal resultPropor = MoneyBigDecimalUtil.mul(propors, new BigDecimal("100"));

               map.put("propor", resultPropor);

            } else {

               map.put("propor", 0);

            }

				


            /* 商品标签列表 */

            Long id = taoBaoGoodsBrief.getId();

            int totalLabels = labelGoodsService.getCountQueryByGoodsId(id);

				
            //List<LabelGoods> labelList = labelService.getByGoodsId(id);

				
            map.put("totalLabels", totalLabels);



            listmap.add(map);

         }



         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls(); // 重点

         Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();



         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("listGoods", gson.toJson(listmap));

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));



      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }



   /**

    * 获取商品信息 以及对应标签列表；此商品标签候选项

    * 
    * @param callback

    * @param id 精选id

    * @param request

    * @param out

    */

   @RequestMapping(value = "getGoodsInfo")

   public void getGoodsInfo(String callback, Long id, HttpServletRequest request, PrintWriter out) {



      try {



         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);



         if (resultObj == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));

            return;

         }



         TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();

         if (taobao == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));

            return;

         }

			
         // 商品图片

         List<String> imgList = TaoBaoUtil.getTbImg(taobao.getAuctionId() + "");



         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls(); // 重点

         Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();



         JSONObject data = new JSONObject();

         // data.put("taobao", gson.toJson(taobao));

         data.put("imgList", gson.toJson(imgList));



         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));



      } catch (Exception e) {

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }



   }





   /**

    * 单个商品贴上标签

    * 
    * @param callback

    * @param id

    * @param labId

    * @param request

    * @param out

    */

   @RequestMapping(value = "addGoodsLable")

   public void addGoodsLable(String callback, Long id, Long labId, HttpServletRequest request, PrintWriter out) {



      try {

         // 获取当前操作用户

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

//         if (admin == null) {

//            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));

//            return;

//         }



         if (id == null || labId == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确的参数")));

            return;

         }



         TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByPrimaryKey(id);

         if (taoBaoGoodsBrief == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不存在")));

            return;

         }



         Label label = labelService.selectByPrimaryKey(labId);

         if (label == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该标签已不存在")));

            return;

         }



         /* 贴上标签 ： 已贴不处理则 */

         Long existence = labelGoodsService.isExistence(id, labId);



         // 该商品不存在此标签则添加， 反之不做处理

         if (existence == null || existence == 0l) {

            Date nowTime = new Date();

            // 贴上新标签

            LabelGoods lg = new LabelGoods();

            lg.setLabel(label);

            lg.setCreateUser(admin);

            lg.setCreatetime(nowTime);

            lg.setTaoBaoGoodsBrief(taoBaoGoodsBrief);



            int insert = labelGoodsService.insertSelective(lg);

            if (insert > 0) {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("添加成功")));

            } else {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("添加失败")));

            }

         } else {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("此商品已存在该标签")));

         }



      } catch (Exception e) {

         // TODO Auto-generated catch block

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }



   }



   /**

    * 删除商品关联的标签

    * 
    * @param callback

    * @param rid

    * @param request

    * @param out

    */

   @RequestMapping(value = "removeSingle")

   public void removeSingle(String callback, Long rid, HttpServletRequest request, PrintWriter out) {



      try {



         int deleteId = labelGoodsService.deleteByPrimaryKey(rid);



         if (deleteId > 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("删除成功")));

         } else {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("删除失败")));

         }



      } catch (Exception e) {

         // TODO Auto-generated catch block

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }



   }



   /**

    * 设置商品权重、等信息

    * 
    * @param callback

    * @param label

    * @param request

    * @param out

    */

   @RequestMapping(value = "saveInfo")

   public void saveInfo(String callback, QualityFactory selectionGoods, HttpServletRequest request, PrintWriter out) {



      try {

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

//

//         if (admin == null) {

//            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));

//            return;

//         } 


         Long id = selectionGoods.getId();

         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);



         if (resultObj == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));

         } else {

            Date nowTime = new Date();

            selectionGoods.setUpdatetime(nowTime);

            selectionGoods.setUpdateUser(admin);

            // 选择性更新数据

            int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);



            if (result > 0) {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));

            } else {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));

            }

         }

			


      } catch (QualityFactoryException e) {

         // TODO Auto-generated catch block

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

      }



   }



   @RequestMapping(value = "queryMyLabels")

   public void queryMyLabels(String callback, Integer pageIndex, Integer pageSize, 
         String ids, HttpServletRequest request, PrintWriter out) {



      try {

			
         if (StringUtil.isNullOrEmpty(ids)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));

            return;

         }

			
         Gson gson = new Gson();

         List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());

         if (idList == null || idList.size() == 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));

            return;

         }

			
         if (idList.size() > 1) {

            // 只处理单个商品

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:103")));

            return;

         }

			
			
         Long id = idList.get(0);

			
         if (id == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));

            return;

         }



         if (pageIndex == null)

            pageIndex = 1;



         if (pageSize == null)

            pageSize = Constant.PAGE_SIZE;



         // 商品标签列表

         List<LabelGoods> labelList = labelGoodsService.queryByGoodsId((pageIndex - 1) * pageSize, 
               pageSize, id);



         if (labelList == null || labelList.size() == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));

            return;

         }

			
         int count = labelGoodsService.getCountQueryByGoodsId(id);



         int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);



         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls(); 
         Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();



         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("labelList", rgson.toJson(labelList));



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));



      } catch (Exception e) {

         // TODO Auto-generated catch block

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }



   /**

    * 查询商品添加标签候选项

    * 
    * @param callback

    * @param pageIndex

    * @param pageSize

    * @param key

    * @param id

    * @param request

    * @param out

    */

   @RequestMapping(value = "queryLabel")

   public void queryLabel(String callback, Integer pageIndex, Integer pageSize, String key, 
         String ids, HttpServletRequest request, PrintWriter out) {



      try {



         if (StringUtil.isNullOrEmpty(ids)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));

            return;

         }

			
         Gson gson = new Gson();

         List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());

         if (idList == null || idList.size() == 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));

            return;

         }

			
         int count = 0;

         List<Label> labelList = null;

			
         if (pageIndex == null)

            pageIndex = 1;



         if (pageSize == null)

            pageSize = Constant.PAGE_SIZE;

			
         if (idList.size() > 1) {

            // 多个商品 查询所有标签

             labelList = labelService.query((pageIndex - 1) * pageSize, pageSize, key, null, null,null);

				
             count = labelService.getQueryCount(key, null, null);

				
         } else {

            // 单个商品

            Long id = idList.get(0);

            if (id == null) {

               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));

               return;

            }



            labelList = labelService.queryGoodsCandidate((pageIndex - 1) * pageSize, pageSize, key, id);



            count = labelService.getCountQueryGoodsCandidate(key, id);

         }

			
         if (labelList == null || labelList.size() == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));

            return;

         }

			
         int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);



         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls(); // 重点

         Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();



         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("labelList", rgson.toJson(labelList));



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));



      } catch (Exception e) {

         // TODO Auto-generated catch block

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }



   /**

    * 单个商品批量添加标签-关联lableId

    * 
    * @param callback

    * @param id

    * @param type

    * @param request

    * @param out

    */

   @RequestMapping(value = "addBatchcGoodsLabel")

   public void addBatchcGoodsLabel(String callback, String labIds, Long id, HttpServletRequest request, PrintWriter out) {



      try {

         // 获取当前操作用户

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

//         if (admin == null) {

//            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));

//            return;

//         }



         if (StringUtil.isNullOrEmpty(labIds)) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择标签"));

            return;

         }



         if (id == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择商品"));

            return;

         }



         Gson gson = new Gson();

         List<String> labIdList = gson.fromJson(labIds, new TypeToken<ArrayList<String>>() {

         }.getType());

         if (labIdList == null || labIdList.size() == 0) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择标签")));

            return;

         }



         TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByPrimaryKey(id);



         labelGoodsService.addBatchByLabId(taoBaoGoodsBrief, labIdList, admin);



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));



      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }

	
   @RequestMapping(value="updateGoodsBrief")

   public void updateGoodsBrief(String callback, TaoBaoGoodsBrief tb, PrintWriter out){

      try {

			
         // 实际未精选ID

         Long id = tb.getId();

			
         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);



         if (resultObj == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));

            return;

         }



         TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();

         if (taobao == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));

            return;

         }

			
         String title = tb.getTitle();

         String pictUrl = tb.getPictUrl();

			
         if (!StringUtil.isNullOrEmpty(title)) 
            taobao.setTitle(title);

			
         if (!StringUtil.isNullOrEmpty(pictUrl)) 
            taobao.setPictUrl(pictUrl);

			
         // 更新商品

         taoBaoGoodsUpdateService.getUpdateTaoBaoGoodsBrief(taobao);

			
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));

			
      } catch (Exception e) {

         e.printStackTrace();

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));

      }

		
   }

	
	
   /**

    * 批量添加标签 --- 精品库（随机权重）

    * @param callback

    * @param request

    * @param out @param         权重范围 大值

    * @param         佣金范围 小值

    */

   @RequestMapping(value = "setWeightBatch")

   public void setWeightBatch(String callback,String ids, Integer weight,Integer weightSmall, 
         Integer weightLarge, HttpServletRequest request, PrintWriter out) {



      try {  
		
          if (StringUtil.isNullOrEmpty(ids)) {

             out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未选择需操作的商品")));

             return;

          } 
			 
          Gson gson = new Gson();

          List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());

			 
          if (idList == null || idList.size() == 0) {

             out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择需操作的商品")));

             return;

          } 
            // 获取当前操作用户

          AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

			 
          qualityFactoryService.setWeightBatch(idList, admin, weight, weightSmall, weightLarge);

          out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("设置成功")));

	
      } catch ( Exception e) {

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));

         e.printStackTrace();

      }



   }

	
	
}

package com.yeshi.fanli.controller.admin;

import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import com.yeshi.fanli.entity.accept.AdminAcceptData;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.taobao.TbImgUtil;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken;
import com.yeshi.fanli.entity.bus.lable.BoutiqueAutoRule;
import com.yeshi.fanli.entity.bus.lable.Label;
import com.yeshi.fanli.entity.bus.lable.LabelGoods;
import com.yeshi.fanli.entity.bus.lable.QualityFactory;
import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.exception.goods.quality.QualityFactoryException;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.lable.LabelGoodsService;
import com.yeshi.fanli.service.inter.lable.LabelService;
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.common.entity.PageEntity;
import com.yeshi.fanli.util.Constant;
import org.yeshi.utils.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.fanli.vo.quality.QualityFactoryVO;

import net.sf.json.JSONObject;

@Controller
@RequestMapping("admin/new/api/v1/qualityFactory")
public class QualityFactoryAdminController {

   @Resource
   private RedisManager redisManager;
   @Resource
   private LabelService labelService;
   @Resource
   private LabelGoodsService labelGoodsService;
   @Resource
   private QualityFactoryService qualityFactoryService;
   @Resource
   private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
   @Resource
   private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

   public static final int SALES_ASC = 1;
   public static final int SALES_DESC = 2;

   public static final int PRICE_ASC = 3;
   public static final int PRICE_DESC = 4;

   public static final int TKRATE_ASC = 5;
   public static final int TKRATE_DESC = 6;

   public static final int PROPOR_ASC = 7;
   public static final int PROPOR_DESC = 8;

   /**
    * 保存修改精品库商品关联信息
    * 
    * @param callback
    * @param request
    * @param out
    */
   @RequestMapping(value = "saveModify")
   public void saveModify(AdminAcceptData acceptData, String callback, QualityFactory selectionGoods, HttpServletRequest request,
                     PrintWriter out) {

      try {
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         if (admin == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));
         } else {

            Long id = selectionGoods.getId();
            QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);

            if (resultObj == null) {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
            } else {
               Date nowTime = new Date();
               selectionGoods.setUpdatetime(nowTime);
               selectionGoods.setUpdateUser(admin);
               // 选择性更新数据
               int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);

               if (result > 0) {
                  out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));
               } else {
                  out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
               }
            }
         }

      } catch (QualityFactoryException e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
      }

   }

   /**
    * 统计商品数量
    * 
    * @param callback
    * @param out
    */
   @RequestMapping(value = "getCountAll")
   public void getCountAll(AdminAcceptData acceptData,String callback, PrintWriter out) {

      try {

         Map<String, Object> countMap = qualityFactoryService.getCountAll();

         JSONObject data = new JSONObject();
         data.put("countData", countMap);
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));

      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("系统异常")));
      }
   }

   /**
    * 批量移除商品至精品库外-不删除商品
    * 
    * @param callback
    * @param ids
    *            商品id
    * @param out
    */
   @RequestMapping(value = "removeGoods")
   public void removeGoods(AdminAcceptData acceptData,String callback, String ids, PrintWriter out) {
      try {
         Gson gson = new Gson();
         List<String> goodsIds = gson.fromJson(ids, new TypeToken<ArrayList<String>>() {
         }.getType());

         if (goodsIds == null || goodsIds.size() == 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未检测到移除商品数据")));
            return;
         }

         qualityFactoryService.deleteBatchByTaoBaoGoodsId(goodsIds);
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("移除成功")));
      } catch (Exception e) {
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作失败")));
         e.printStackTrace();
      }

   }

   /**
    * 查询
    * 
    * @param out
    */
   @RequestMapping(value = "query")
   public void query(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, Integer sort,
         QualityFactoryVO qualityFactoryVO, PrintWriter out) {

      try {
         if (pageSize == null)
            pageSize = Constant.PAGE_SIZE;

         if (pageIndex == null)
            pageIndex = 1;

         Integer price = null;
         Integer tkRate = null;
         Integer totalSales = null;
         Integer propor = null;

         if (sort != null) {
            switch (sort) {
            case SALES_ASC:
               totalSales = 1;
               break;
            case SALES_DESC:
               totalSales = 2;
               break;
            case PRICE_ASC:
               price = 1;
               break;
            case PRICE_DESC:
               price = 2;
               break;
            case TKRATE_ASC:
               tkRate = 1;
               break;
            case TKRATE_DESC:
               tkRate = 2;
               break;
            case PROPOR_ASC:
               propor = 1;
               break;
            case PROPOR_DESC:
               propor = 2;
               break;
            default:
               break;
            }
         }

         qualityFactoryVO.setPrice(price);
         qualityFactoryVO.setTkRate(tkRate);
         qualityFactoryVO.setTotalSales(totalSales);
         qualityFactoryVO.setPropor(propor);
         qualityFactoryVO.setStart((pageIndex - 1) * pageSize);
         qualityFactoryVO.setCount(pageSize);

         List<QualityFactory> selectionList = qualityFactoryService.query(qualityFactoryVO);

         /* 暂无数据显示 */
         if (selectionList == null || selectionList.size() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));
            return;
         }

         /* 有数据：处理返回格式 */

         long count = qualityFactoryService.queryCount(qualityFactoryVO);

         int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);

         List<Map<String, Object>> listmap = new ArrayList<Map<String, Object>>();

         /* 验证网络: 获取商品链接 图片链接 */
         List<TaoBaoGoodsBrief> goodsBriefList = new ArrayList<TaoBaoGoodsBrief>();

         StringBuffer idBuf = new StringBuffer();
         StringBuffer auctionIdBuf = new StringBuffer();

         int j = 0;
         for (int i = 0; i < selectionList.size(); i++) {
            QualityFactory selectionGoods = selectionList.get(i);

            TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();
            if (taoBaoGoodsBrief == null)
               continue; // 为空结束本次循环

            Long id = taoBaoGoodsBrief.getId();
            idBuf.append(id + ",");

            String auctionId = taoBaoGoodsBrief.getAuctionId();
            if (auctionId != null) {
               j++;
               auctionIdBuf.append(auctionId + ",");
            }

            if (selectionList.size() <= 40) {
               // 小于40个参数
               if (i == selectionList.size() - 1) {
                  if (auctionIdBuf != null && auctionIdBuf.length() > 0) {
                     String auctionIds = auctionIdBuf.toString();
                     String ids = auctionIds.substring(0, auctionIds.length() - 1);
                     List<TaoBaoGoodsBrief> list = null;
                     try {
                        list = TaoKeApiUtil.getBatchGoodsInfos(ids);
                     } catch (Exception e) {
                        e.printStackTrace();
                     }

                     if (list != null && list.size() > 0) {
                        goodsBriefList.addAll(list);
                     }

                     auctionIdBuf = new StringBuffer();
                  }
               }
            } else {
               if (j == 40) {
                  // 大于40参数
                  String auctionIds = auctionIdBuf.toString();
                  String ids = auctionIds.substring(0, auctionIds.length() - 1);
                  List<TaoBaoGoodsBrief> list = null;
                  try {
                     list = TaoKeApiUtil.getBatchGoodsInfos(ids);
                  } catch (Exception e) {
                     e.printStackTrace();
                  }

                  if (list != null && list.size() > 0) {
                     goodsBriefList.addAll(list);
                  }

                  j = 0;
                  auctionIdBuf = new StringBuffer();

               } else if (i == selectionList.size() - 1) {
                  // 最后一个
                  String auctionIds = auctionIdBuf.toString();
                  String ids = auctionIds.substring(0, auctionIds.length() - 1);
                  List<TaoBaoGoodsBrief> list = null;
                  try {
                     list = TaoKeApiUtil.getBatchGoodsInfos(ids);
                  } catch (Exception e) {
                     e.printStackTrace();
                  }

                  if (list != null && list.size() > 0) {
                     goodsBriefList.addAll(list);
                  }
                  auctionIdBuf = new StringBuffer();
               }
            }

         }

         for (QualityFactory selectionGoods : selectionList) {

            TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();

            if (taoBaoGoodsBrief == null)
               continue; // 为空结束本次循环

            // 设置图片大小
            taoBaoGoodsBrief.setPictUrl(TbImgUtil.getTBSize220Img(taoBaoGoodsBrief.getPictUrl()));

            String auctionUrl = taoBaoGoodsBrief.getAuctionUrl();
            if (auctionUrl != null && auctionUrl.trim().length() > 0 && auctionUrl.contains("id=null")) {
               auctionUrl = auctionUrl.replace("id=null", "id=" + taoBaoGoodsBrief.getAuctionId());
               taoBaoGoodsBrief.setAuctionUrl(auctionUrl);
            }

            Map<String, Object> map = new HashMap<String, Object>();

            BoutiqueAutoRule boutiqueAutoRule = selectionGoods.getBoutiqueAutoRule();
            if (boutiqueAutoRule == null) {
               boutiqueAutoRule = new BoutiqueAutoRule();
               selectionGoods.setBoutiqueAutoRule(boutiqueAutoRule);
            }

            String reslutSource = "";
            Integer gsSource = selectionGoods.getGoodsSource();
            if (QualityFactory.SOURCE_TAOBAO == gsSource) {
               reslutSource = "淘宝";
            } else if (QualityFactory.SOURCE_TAOBAO_MATERIAL == gsSource) {
               reslutSource = "淘宝推荐";
            } else if (QualityFactory.SOURCE_TAOBAO_DATAOKE == gsSource) {
               reslutSource = "大淘客";
            } else if (QualityFactory.SOURCE_JINGDONG == gsSource) {
               reslutSource = "京东";
            } else if (QualityFactory.SOURCE_PINDUODUO == gsSource) {
               reslutSource = "拼多多";
            } else if (QualityFactory.SOURCE_WEIPINHUI == gsSource) {
               reslutSource = "唯品会";
            } else if (QualityFactory.SOURCE_OTHER == gsSource) {
               reslutSource = "商务合作";
            }

            map.put("goodsSource", reslutSource);

            map.put("selectionGoods", selectionGoods);

            /* 商品销售状态： 0 在售 1停售 */
            int saleStae = 1;
            String auctionId = taoBaoGoodsBrief.getAuctionId();
            if (auctionId != null) {
               if (goodsBriefList != null && goodsBriefList.size() > 0) {
                  for (TaoBaoGoodsBrief tb : goodsBriefList) {
                     String auctionIdTB = tb.getAuctionId();
                     if (auctionId.equals(auctionIdTB)) {
                        saleStae = 0;
                     }
                  }
               }
            }

            map.put("saleStae", saleStae);

            /* 1 定向计划 2 营销返利 、高佣 3 普佣 */
            Integer includeDxjh = taoBaoGoodsBrief.getIncludeDxjh();
            String tkMktStatus = taoBaoGoodsBrief.getTkMktStatus();

            boolean include = false;
            if (includeDxjh != null) {
               if (includeDxjh == 1) {
                  // 定向计划
                  map.put("yongjinType", 1);
                  include = true;
               }
            }

            if (!include) {

               if ("1".equals(tkMktStatus)) {
                  // 营销返利 、高佣
                  map.put("yongjinType", 2);
               } else {
                  // 普佣
                  map.put("yongjinType", 3);
               }
            }

            /* 券后价--计算 */
            BigDecimal couponPrice = TaoBaoUtil.getCouponPrice(taoBaoGoodsBrief);
            map.put("couponPrice", couponPrice);

            /* 预计收益： 公司、用户 */
            BigDecimal tkRateBrief = taoBaoGoodsBrief.getTkRate();
            BigDecimal zkPrice = taoBaoGoodsBrief.getZkPrice();
            BigDecimal profit = MoneyBigDecimalUtil.mul(tkRateBrief, zkPrice);
            // 计算结果
            BigDecimal estimateProfit = MoneyBigDecimalUtil.div(profit, new BigDecimal("100"));
            // 预计收益
            map.put("estimateProfit", estimateProfit);

            BigDecimal couponAmount = taoBaoGoodsBrief.getCouponAmount();
            if (couponAmount != null && zkPrice != null) {
               BigDecimal propors = couponAmount.divide(zkPrice, 10, BigDecimal.ROUND_HALF_DOWN);
               BigDecimal resultPropor = MoneyBigDecimalUtil.mul(propors, new BigDecimal("100"));
               map.put("propor", resultPropor);
            } else {
               map.put("propor", 0);
            }

            /* 商品标签列表 */
            String id = taoBaoGoodsBrief.getAuctionId();
            int totalLabels = labelGoodsService.getCountQueryByGoodsId(id);

            // List<LabelGoods> labelList = labelService.getByGoodsId(id);

            map.put("totalLabels", totalLabels);

            listmap.add(map);
         }

         GsonBuilder gsonBuilder = new GsonBuilder();
         gsonBuilder.serializeNulls(); // 重点
         Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

         JSONObject data = new JSONObject();
         data.put("pe", pe);
         data.put("listGoods", gson.toJson(listmap));
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }

   /**
    * 获取商品信息 以及对应标签列表；此商品标签候选项
    * 
    * @param callback
    * @param id
    *            精选id
    * @param request
    * @param out
    */
   @RequestMapping(value = "getGoodsInfo")
   public void getGoodsInfo(AdminAcceptData acceptData,String callback, Long id, HttpServletRequest request, PrintWriter out) {

      try {

         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);

         if (resultObj == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
            return;
         }

         TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();
         if (taobao == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));
            return;
         }

         // 商品图片
         List<String> imgList = TaoBaoUtil.getTbImg(taobao.getAuctionId() + "");

         GsonBuilder gsonBuilder = new GsonBuilder();
         gsonBuilder.serializeNulls(); // 重点
         Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

         JSONObject data = new JSONObject();
         // data.put("taobao", gson.toJson(taobao));
         data.put("imgList", gson.toJson(imgList));

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));

      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
      }

   }

   /**
    * 单个商品贴上标签
    * 
    * @param callback
    * @param id
    * @param labId
    * @param request
    * @param out
    */
   @RequestMapping(value = "addGoodsLable")
   public void addGoodsLable(AdminAcceptData acceptData,String callback, String id, Long labId, HttpServletRequest request, PrintWriter out) {

      try {
         // 获取当前操作用户
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
         // if (admin == null) {
         // out.print(JsonUtil.loadJSONP(callback,
         // JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));
         // return;
         // }

         if (id == null || labId == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确的参数")));
            return;
         }

         TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByGoodsId(id);
         if (taoBaoGoodsBrief == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不存在")));
            return;
         }

         Label label = labelService.selectByPrimaryKey(labId);
         if (label == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该标签已不存在")));
            return;
         }

         /* 贴上标签 ： 已贴不处理则 */
         Long existence = labelGoodsService.isExistence(id, labId);

         // 该商品不存在此标签则添加， 反之不做处理
         if (existence == null || existence == 0l) {
            Date nowTime = new Date();
            // 贴上新标签
            LabelGoods lg = new LabelGoods();
            lg.setLabel(label);
            lg.setCreateUser(admin);
            lg.setCreatetime(nowTime);
            lg.setTaoBaoGoodsBrief(taoBaoGoodsBrief);

            int insert = labelGoodsService.insertSelective(lg);
            if (insert > 0) {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("添加成功")));
            } else {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("添加失败")));
            }
         } else {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("此商品已存在该标签")));
         }

      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
      }

   }

   /**
    * 删除商品关联的标签
    * 
    * @param callback
    * @param rid
    * @param request
    * @param out
    */
   @RequestMapping(value = "removeSingle")
   public void removeSingle(AdminAcceptData acceptData,String callback, Long rid, HttpServletRequest request, PrintWriter out) {

      try {

         int deleteId = labelGoodsService.deleteByPrimaryKey(rid);

         if (deleteId > 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("删除成功")));
         } else {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("删除失败")));
         }

      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
      }

   }

   /**
    * 设置商品权重、等信息
    * 
    * @param callback
    * @param label
    * @param request
    * @param out
    */
   @RequestMapping(value = "saveInfo")
   public void saveInfo(AdminAcceptData acceptData,String callback, QualityFactory selectionGoods, HttpServletRequest request, PrintWriter out) {

      try {
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
         //
         // if (admin == null) {
         // out.print(JsonUtil.loadJSONP(callback,
         // JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));
         // return;
         // }

         Long id = selectionGoods.getId();
         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);

         if (resultObj == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
         } else {
            Date nowTime = new Date();
            selectionGoods.setUpdatetime(nowTime);
            selectionGoods.setUpdateUser(admin);
            // 选择性更新数据
            int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);

            if (result > 0) {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));
            } else {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
            }
         }

      } catch (QualityFactoryException e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
      }

   }

   @RequestMapping(value = "queryMyLabels")
   public void queryMyLabels(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, String ids,
         HttpServletRequest request, PrintWriter out) {

      try {

         if (StringUtil.isNullOrEmpty(ids)) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));
            return;
         }

         Gson gson = new Gson();
         List<String> idList = gson.fromJson(ids, new TypeToken<ArrayList<String>>() {
         }.getType());
         if (idList == null || idList.size() == 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));
            return;
         }

         if (idList.size() > 1) {
            // 只处理单个商品
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:103")));
            return;
         }

         String id = idList.get(0);

         if (id == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));
            return;
         }

         if (pageIndex == null)
            pageIndex = 1;

         if (pageSize == null)
            pageSize = Constant.PAGE_SIZE;

         // 商品标签列表
         List<LabelGoods> labelList = labelGoodsService.queryByGoodsId((pageIndex - 1) * pageSize, pageSize, id);

         if (labelList == null || labelList.size() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));
            return;
         }

         int count = labelGoodsService.getCountQueryByGoodsId(id);

         int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);

         GsonBuilder gsonBuilder = new GsonBuilder();
         gsonBuilder.serializeNulls();
         Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

         JSONObject data = new JSONObject();
         data.put("pe", pe);
         data.put("labelList", rgson.toJson(labelList));

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }

   /**
    * 查询商品添加标签候选项
    * 
    * @param callback
    * @param pageIndex
    * @param pageSize
    * @param key
    * @param request
    * @param out
    */
   @RequestMapping(value = "queryLabel")
   public void queryLabel(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, String key, String ids,
         HttpServletRequest request, PrintWriter out) {

      try {

         if (StringUtil.isNullOrEmpty(ids)) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));
            return;
         }

         Gson gson = new Gson();
         List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
         }.getType());
         if (idList == null || idList.size() == 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));
            return;
         }

         int count = 0;
         List<Label> labelList = null;

         if (pageIndex == null)
            pageIndex = 1;

         if (pageSize == null)
            pageSize = Constant.PAGE_SIZE;

         if (idList.size() > 1) {
            // 多个商品 查询所有标签
            labelList = labelService.query((pageIndex - 1) * pageSize, pageSize, key, null, null, null);

            count = labelService.getQueryCount(key, null, null);

         } else {
            // 单个商品
            Long id = idList.get(0);
            if (id == null) {
               out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));
               return;
            }

            labelList = labelService.queryGoodsCandidate((pageIndex - 1) * pageSize, pageSize, key, id);

            count = labelService.getCountQueryGoodsCandidate(key, id);
         }

         if (labelList == null || labelList.size() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));
            return;
         }

         int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);

         GsonBuilder gsonBuilder = new GsonBuilder();
         gsonBuilder.serializeNulls(); // 重点
         Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

         JSONObject data = new JSONObject();
         data.put("pe", pe);
         data.put("labelList", rgson.toJson(labelList));

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }

   /**
    * 单个商品批量添加标签-关联lableId
    * 
    * @param callback
    * @param id
    * @param type
    * @param request
    * @param out
    */
   @RequestMapping(value = "addBatchcGoodsLabel")
   public void addBatchcGoodsLabel(AdminAcceptData acceptData,String callback, String labIds, Long id, HttpServletRequest request,
         PrintWriter out) {

      try {
         if (StringUtil.isNullOrEmpty(labIds)) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择标签"));
            return;
         }

         if (id == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择商品"));
            return;
         }

         Gson gson = new Gson();
         List<String> labIdList = gson.fromJson(labIds, new TypeToken<ArrayList<String>>() {
         }.getType());
         if (labIdList == null || labIdList.size() == 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择标签")));
            return;
         }

         TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByPrimaryKey(id);

         // 获取当前操作用户
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
         labelGoodsService.addBatchByLabId(taoBaoGoodsBrief, labIdList, admin);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));

      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }

   @RequestMapping(value = "updateGoodsBrief")
   public void updateGoodsBrief(AdminAcceptData acceptData,String callback, TaoBaoGoodsBrief tb, PrintWriter out) {
      try {

         // 实际未精选ID
         Long id = tb.getId();

         QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);

         if (resultObj == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
            return;
         }

         TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();
         if (taobao == null) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));
            return;
         }

         String title = tb.getTitle();
         String pictUrl = tb.getPictUrl();

         if (!StringUtil.isNullOrEmpty(title))
            taobao.setTitle(title);

         if (!StringUtil.isNullOrEmpty(pictUrl))
            taobao.setPictUrl(pictUrl);

         if (!StringUtil.isNullOrEmpty(tb.getPictUrlWhite()))
            taobao.setPictUrlWhite(tb.getPictUrlWhite());

         // 更新商品
         taoBaoGoodsUpdateService.getUpdateTaoBaoGoodsBrief(taobao);

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));

      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
      }

   }

   /**
    * 批量添加标签 --- 精品库（随机权重）
    * 
    * @param callback
    * @param request
    * @param out
    * @param 权重范围
    *            大值
    * @param 佣金范围
    *            小值
    */
   @RequestMapping(value = "setWeightBatch")
   public void setWeightBatch(AdminAcceptData acceptData,String callback, String ids, Integer weight, Integer weightSmall, Integer weightLarge,
         HttpServletRequest request, PrintWriter out) {

      try {

         if (StringUtil.isNullOrEmpty(ids)) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未选择需操作的商品")));
            return;
         }

         Gson gson = new Gson();
         List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
         }.getType());

         if (idList == null || idList.size() == 0) {
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择需操作的商品")));
            return;
         }
         // 获取当前操作用户
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         qualityFactoryService.setWeightBatch(idList, admin, weight, weightSmall, weightLarge);
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("设置成功")));

      } catch (Exception e) {
         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
         e.printStackTrace();
      }

   }

}