Browse Source

去处客户转交客户资料同步转换

anderx 7 years ago
parent
commit
cbdfc968b9

+ 2 - 0
src/main/java/com/goafanti/common/dao/OrganizationApplicationInfoMapper.java

@@ -74,4 +74,6 @@ public interface OrganizationApplicationInfoMapper {
 	 * @mbg.generated  Thu Jul 19 11:49:49 CST 2018
 	 */
 	int updateByPrimaryKey(OrganizationApplicationInfo record);
+
+	List<OrganizationApplicationInfo>  selectByUid(String uid);
 }

+ 6 - 0
src/main/java/com/goafanti/common/mapper/OrganizationApplicationInfoMapper.xml

@@ -300,4 +300,10 @@
       create_time = #{createTime,jdbcType=TIMESTAMP}
     where id = #{id,jdbcType=VARCHAR}
   </update>
+  <select id="selectByUid" resultType="com.goafanti.common.model.OrganizationApplicationInfo">
+  select 
+  <include refid="Base_Column_List" />
+  from organization_application_info
+  where uid=#{id,jdbcType=VARCHAR}
+  </select>
 </mapper>

+ 14 - 7
src/main/java/com/goafanti/customer/service/impl/CustomerServiceImpl.java

@@ -315,7 +315,6 @@ public class CustomerServiceImpl  extends BaseMybatisDao<UserMapper> implements
 
 	@Override
 	public CustomerOrganizationDetailBo findOrganizationCustomerDetail(String uid) {
-		
 		return userMapper.findOrganizationCustomerDetail(uid);
 	}
 
@@ -340,11 +339,18 @@ public class CustomerServiceImpl  extends BaseMybatisDao<UserMapper> implements
 			user.setCreditRating(bo.getCreditRating());
 			user.setIntegrity(countIntegrity(bo));
 			if (StringUtils.isNotBlank(bo.getPojectApplicationUrl())) {
-				oa.setId(UUID.randomUUID().toString());
-				oa.setCreateTime(date);
-				oa.setUid(bo.getUid());
-				oa.setPojectApplicationUrl(bo.getPojectApplicationUrl());
-				organizationApplicationInfoMapper.insert(oa);
+				List<OrganizationApplicationInfo> l=organizationApplicationInfoMapper.selectByUid(bo.getUid());
+				if(l.size()>0){
+					oa=l.get(0);
+					oa.setPojectApplicationUrl(bo.getPojectApplicationUrl());
+					organizationApplicationInfoMapper.updateByPrimaryKey(oa);
+				}else {
+					oa.setId(UUID.randomUUID().toString());
+					oa.setCreateTime(date);
+					oa.setUid(bo.getUid());
+					oa.setPojectApplicationUrl(bo.getPojectApplicationUrl());
+					organizationApplicationInfoMapper.insert(oa);
+				}
 			}
 		} catch (IllegalAccessException |InvocationTargetException e) {
 			e.printStackTrace();
@@ -901,6 +907,7 @@ public class CustomerServiceImpl  extends BaseMybatisDao<UserMapper> implements
 			user.setTransferTime(now);
 			flag = addUserLock(uid,TokenManager.getAdminId(),now); //指定用户锁定客户
 			if(flag <= 0) throw new BusinessException(new Error(ErrorConstants.CUSTOMER_ALREADY_RECEIVE,""));
+			organizationContactBookMapper.updateAdmin(uid,TokenManager.getAdminId());
 		}else if(operatorType.equals(AFTConstants.USER_TRANSFER_TO_OTHER)){
 			user.setAid(String.valueOf(params[0]));
 			user.setTransferTime(now);
@@ -908,7 +915,7 @@ public class CustomerServiceImpl  extends BaseMybatisDao<UserMapper> implements
 			if(flag > 0 ) flag = addUserLock(uid,String.valueOf(params[0]),now); //指定用户锁定客户
 			if(flag <= 0) throw new BusinessException(new Error(ErrorConstants.CUSTOMER_TRANSFER_FAIL,""));
 		}
-		organizationContactBookMapper.updateAdmin(uid,oldAid);
+		
 		return userMapper.updateByPrimaryKeySelective(user);
 	}