Просмотр исходного кода

[会员ID][修改]:会员ID修改同步,成长值历史表、会员历史表同步

release_toaliyun_real
Stormeye Wu 6 лет назад
Родитель
Сommit
98cceb14b4
10 измененных файлов: 88 добавлений и 8 удалений
  1. +5
    -1
      mallinkService/src/main/java/com/iformall/domain/vo/CUserTagNewIdVo.java
  2. +19
    -0
      mallinkService/src/main/java/com/iformall/domain/vo/WxCreditHistoryNewIdVo.java
  3. +17
    -0
      mallinkService/src/main/java/com/iformall/domain/vo/WxScoreHistoryNewIdVo.java
  4. +2
    -2
      mallinkService/src/main/java/com/iformall/mapper/WxCUserTagsMapper.java
  5. +3
    -1
      mallinkService/src/main/java/com/iformall/mapper/WxCreditHistoryMapper.java
  6. +3
    -0
      mallinkService/src/main/java/com/iformall/mapper/WxScoreHistoryMapper.java
  7. +24
    -3
      mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java
  8. +1
    -1
      mallinkService/src/main/resources/mapper/WxCUserTagsMapper.xml
  9. +7
    -0
      mallinkService/src/main/resources/mapper/WxCreditHistoryMapper.xml
  10. +7
    -0
      mallinkService/src/main/resources/mapper/WxScoreHistoryMapper.xml

mallinkService/src/main/java/com/iformall/domain/vo/CUserTagVo.java → mallinkService/src/main/java/com/iformall/domain/vo/CUserTagNewIdVo.java Просмотреть файл

@@ -5,13 +5,17 @@ import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;

import javax.persistence.Transient;

/**
* Created by syf on 2018/8/30.
*/
@Data
@ToString(callSuper = true)
@EqualsAndHashCode(callSuper = true)
public class CUserTagVo extends WxCUserTags {
public class CUserTagNewIdVo extends WxCUserTags {

@Transient
@io.swagger.annotations.ApiModelProperty(value="用户新的ID",name="newUserId")
private Long newUserId;
}

+ 19
- 0
mallinkService/src/main/java/com/iformall/domain/vo/WxCreditHistoryNewIdVo.java Просмотреть файл

@@ -0,0 +1,19 @@
package com.iformall.domain.vo;

import cn.afterturn.easypoi.excel.annotation.Excel;
import com.iformall.domain.po.WxCreditHistory;
import lombok.Data;
import lombok.EqualsAndHashCode;

import javax.persistence.Transient;
import java.util.Date;

@Data
@EqualsAndHashCode(callSuper = true)
public class WxCreditHistoryNewIdVo extends WxCreditHistory {

@Transient
@io.swagger.annotations.ApiModelProperty(value="用户新的ID",name="newUserId")
private Long newUserId;

}

+ 17
- 0
mallinkService/src/main/java/com/iformall/domain/vo/WxScoreHistoryNewIdVo.java Просмотреть файл

@@ -0,0 +1,17 @@
package com.iformall.domain.vo;

import com.iformall.domain.po.WxScoreHistory;
import lombok.Data;
import lombok.EqualsAndHashCode;

import javax.persistence.Transient;

@Data
@EqualsAndHashCode(callSuper = true)
public class WxScoreHistoryNewIdVo extends WxScoreHistory {

@Transient
@io.swagger.annotations.ApiModelProperty(value="用户新的ID",name="newUserId")
private Long newUserId;

}

+ 2
- 2
mallinkService/src/main/java/com/iformall/mapper/WxCUserTagsMapper.java Просмотреть файл

@@ -5,7 +5,7 @@ import java.util.List;

import com.iformall.common.CommonMapper;
import com.iformall.domain.po.WxCUserTags;
import com.iformall.domain.vo.CUserTagVo;
import com.iformall.domain.vo.CUserTagNewIdVo;
import org.apache.ibatis.annotations.Param;

public interface WxCUserTagsMapper extends CommonMapper<WxCUserTags, String> {
@@ -15,5 +15,5 @@ public interface WxCUserTagsMapper extends CommonMapper<WxCUserTags, String> {
long countUser(@Param("tagIds")String tagIds,@Param("tenantId")String tenantId,
@Param("startTime")Date startTime,@Param("endTime")Date endTime);

void updateNewId(CUserTagVo record);
void updateNewId(CUserTagNewIdVo record);
}

+ 3
- 1
mallinkService/src/main/java/com/iformall/mapper/WxCreditHistoryMapper.java Просмотреть файл

@@ -2,7 +2,7 @@ package com.iformall.mapper;

import java.util.*;
import com.iformall.common.CommonMapper;
import com.iformall.domain.po.WxScoreHistory;
import com.iformall.domain.vo.WxCreditHistoryNewIdVo;
import com.iformall.domain.vo.WxCreditHistoryVo;
import com.iformall.domain.po.WxCreditHistory;

@@ -18,4 +18,6 @@ public interface WxCreditHistoryMapper extends CommonMapper<WxCreditHistory, Lon

int countList(WxCreditHistory wxCreditHistory);

int updateNewId(WxCreditHistoryNewIdVo wxCreditHistory);

}

+ 3
- 0
mallinkService/src/main/java/com/iformall/mapper/WxScoreHistoryMapper.java Просмотреть файл

@@ -3,6 +3,7 @@ package com.iformall.mapper;
import java.util.*;
import com.iformall.common.CommonMapper;
import com.iformall.domain.po.WxScoreHistory;
import com.iformall.domain.vo.WxScoreHistoryNewIdVo;

public interface WxScoreHistoryMapper extends CommonMapper<WxScoreHistory, String> {

@@ -12,5 +13,7 @@ public interface WxScoreHistoryMapper extends CommonMapper<WxScoreHistory, Strin
int countTodayList(WxScoreHistory wxScoreHistory);

int countList(WxScoreHistory wxScoreHistory);

int updateNewId(WxScoreHistoryNewIdVo wxScoreHistoryNewIdVo);
}

+ 24
- 3
mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java Просмотреть файл

@@ -49,6 +49,12 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService {
@Autowired
WxTagsMapper wxTagsMapper;

@Autowired
WxScoreHistoryMapper scoreHistoryMapper;

@Autowired
WxCreditHistoryMapper creditHistoryMapper;

@Autowired
WxCUserTagsService wxCUserTagsService;

@@ -589,13 +595,28 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService {

@Override
public void updateObj(WxCUserBasicInfo record, Long newId) {
// update c_user_tags
CUserTagVo userTagVo = new CUserTagVo();
// 1. update c_user_tags
CUserTagNewIdVo userTagVo = new CUserTagNewIdVo();
userTagVo.setTenantId(record.getTenantId());
userTagVo.setUserId(record.getId());
userTagVo.setNewUserId(newId);
wxCUserTagsMapper.updateNewId(userTagVo);
// base info

// 2. update score history
WxScoreHistoryNewIdVo scoreHistoryNewIdVo = new WxScoreHistoryNewIdVo();
scoreHistoryNewIdVo.setTenantId(record.getTenantId());
scoreHistoryNewIdVo.setCUserId(record.getId());
scoreHistoryNewIdVo.setNewUserId(newId);
scoreHistoryMapper.updateNewId(scoreHistoryNewIdVo);

// 3. update credit history
WxCreditHistoryNewIdVo creditHistoryNewIdVo = new WxCreditHistoryNewIdVo();
creditHistoryNewIdVo.setTenantId(record.getTenantId());
creditHistoryNewIdVo.setCUserId(record.getId());
creditHistoryNewIdVo.setNewUserId(newId);
creditHistoryMapper.updateNewId(creditHistoryNewIdVo);

// 10. base info
CUserBaseVo userBaseVo = new CUserBaseVo();
org.springframework.beans.BeanUtils.copyProperties(record, userBaseVo);
userBaseVo.setNewId(newId);


+ 1
- 1
mallinkService/src/main/resources/mapper/WxCUserTagsMapper.xml Просмотреть файл

@@ -62,7 +62,7 @@
<include refid="dynamicWhereConditions"/>
</select>

<update id="updateNewId" parameterType="com.iformall.domain.vo.CUserTagVo">
<update id="updateNewId" parameterType="com.iformall.domain.vo.CUserTagNewIdVo">
update wx_c_user_tags
set user_id=#{newUserId}
where tenant_id=#{tenantId}


+ 7
- 0
mallinkService/src/main/resources/mapper/WxCreditHistoryMapper.xml Просмотреть файл

@@ -199,4 +199,11 @@
and `credit_type` = #{creditType}
</if>
</select>

<update id="updateNewId" parameterType="com.iformall.domain.vo.WxCreditHistoryNewIdVo">
update wx_credit_history
set c_user_id=#{newUserId}
where tenant_id=#{tenantId}
and c_user_id = #{userId}
</update>
</mapper>

+ 7
- 0
mallinkService/src/main/resources/mapper/WxScoreHistoryMapper.xml Просмотреть файл

@@ -114,4 +114,11 @@
</if>
</select>

<update id="updateNewId" parameterType="com.iformall.domain.vo.WxScoreHistoryNewIdVo">
update wx_score_history
set c_user_id=#{newUserId}
where tenant_id=#{tenantId}
and c_user_id = #{userId}
</update>

</mapper>

Загрузка…
Отмена
Сохранить