三方服务-调整大淘客功能

thirdPartyWares_service/src/main/java/com/bjtdba/thirdPartWares/dao/ThirdPartyGoodsDao.java

@@ -83,5 +83,6 @@ public interface ThirdPartyGoodsDao {
      */
     int deleteById( );
 
+    int deleteByType(Integer type);
 }
 

thirdPartyWares_service/src/main/java/com/bjtdba/thirdPartWares/service/impl/TaobaoServiceImpl.java

@@ -151,7 +151,8 @@ public class TaobaoServiceImpl implements TaobaoService {
 
             ThirdPartyWares thirdPartyWares = new ThirdPartyWares();
             thirdPartyWares.setType(5);
-            Number commissionRate = obj.get("commissionRate")!=null?(Number)obj.get("commissionRate"):(((Number)obj.get("commission_rate")).doubleValue()*0.01);
+            // 当前 淘宝联盟账号等级为初级 的总收益的 33%；中级 66%; 高级 100% -10%服务手续费
+            Number commissionRate = obj.get("commissionRate")!=null?(double)obj.get("commissionRate")*0.25:(((Number)obj.get("commission_rate")).doubleValue()*0.01);
             thirdPartyWares.setCommission_rate(commissionRate);//佣金比例
 
             Number market_price = obj.get("originalPrice") != null ? (Number)obj.get("originalPrice") : new Double(obj.get("zk_final_price").toString());
@@ -200,6 +201,7 @@ public class TaobaoServiceImpl implements TaobaoService {
      public Object saveThirdPartGood(){
         //定时执行180次3.6万条数据存入数据库
         int aa=1;
+         thirdPartyGoodsDao.deleteByType(1);
         for(int i=1;i<=180;i++){
             log.info("=================================开始循环第"+i+"次=========================");
             List<ThirdPartyWares> thirdPartyWaresList =selectTaobaoWaresList(i+"",200+"",null);
@@ -320,7 +322,8 @@ public class TaobaoServiceImpl implements TaobaoService {
             waresDetail.setCouponEndTime(dateFormat.format(dateFormat.parse((String) jsonObjects.get("couponEndTime"))));
         }
         //佣金 已经
-        double yongjin = waresDetail.getZk_final_price().doubleValue() * Double.parseDouble(jsonObjects.get("commissionRate").toString())/100;
+        // 当前 淘宝联盟账号等级为初级 的总收益的 33%；中级 66%; 高级 100% -10%服务手续费
+        double yongjin = waresDetail.getZk_final_price().doubleValue() * Double.parseDouble(jsonObjects.get("commissionRate").toString())/100*0.25;
         BigDecimal pv=null;//新增pv值  pv=佣金=养老金
         BigDecimal yanglaojin=null; //养老金=pv
         BigDecimal yongjin_obj=new BigDecimal(yongjin).setScale(2,BigDecimal.ROUND_HALF_UP);

thirdPartyWares_service/src/main/resources/mapper/ThirdPartyGoodsDao.xml

@@ -110,5 +110,9 @@
         delete from rrx_third_party_goods
     </delete>
 
+    <delete id="deleteByType" parameterType="java.lang.Integer">
+        delete from rrx_third_party_goods
+        where type = #{type,jdbcType=INTEGER}
+    </delete>
 </mapper>