股东大盘分红完成计算任务后删除临时表

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/mapper/KxsUserTradeMapper.java

@@ -47,5 +47,7 @@ public interface KxsUserTradeMapper extends BaseMapper<KxsUserTrade> {
     void insertTempShdTableData(@Param("tableName") String tableName, @Param("data") ShdTradeAmtVO shdTradeAmtVO);
 
     BigDecimal getStatAmount(String tableName);
+
+    void removeTempTable(String tempTableName);
 }
 

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/service/impl/KxsUserTradeServiceImpl.java

@@ -165,6 +165,8 @@ public class KxsUserTradeServiceImpl extends ServiceImpl<KxsUserTradeMapper, Kxs
             }
             return null;
         });
+
+        baseMapper.removeTempTable(tempTableName);
     }
 
     @Override

kxs-stat/kxs-stat-biz/src/main/resources/mapper/KxsUserTradeMapper.xml

@@ -127,6 +127,9 @@
         </set>
         where user_id = #{data.userId}
     </update>
+    <update id="removeTempTable">
+        DROP TEMPORARY TABLE IF EXISTS `${tableName}`;
+    </update>
 
 
 </mapper>

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsShdScoreServiceImpl.java

@@ -119,7 +119,11 @@ public class KxsShdScoreServiceImpl extends ServiceImpl<KxsShdScoreMapper, KxsSh
                         }
 
                         kxsShdScore.setMonth(month);
-                        kxsShdScoreMapper.insert(kxsShdScore);
+                        if(kxsShdScore.getId() == null){
+                            kxsShdScoreMapper.insert(kxsShdScore);
+                        }else{
+                            kxsShdScoreMapper.updateById(kxsShdScore);
+                        }
                     }else {
 
                         //存在数据则根据条件增加