fix:导入素币兑换清单汇率计算问题

@@ -1401,7 +1401,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				createExchangeCashPersonCommand.PersonName,
 				createExchangeCashPersonCommand.PersonName,
 				createExchangeCashPersonCommand.PersonAccount,
 				createExchangeCashPersonCommand.PersonAccount,
 				createExchangeCashPersonCommand.ExchangedSuMoney,
 				createExchangeCashPersonCommand.ExchangedSuMoney,
-				"当前未创建任务兑换活动",
+				"当前未创建素币兑换活动",
 			}
 			}
 			failureDataList = append(failureDataList, row)
 			failureDataList = append(failureDataList, row)
 			continue
 			continue
@@ -1461,7 +1461,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				createExchangeCashPersonCommand.PersonName,
 				createExchangeCashPersonCommand.PersonName,
 				createExchangeCashPersonCommand.PersonAccount,
 				createExchangeCashPersonCommand.PersonAccount,
 				createExchangeCashPersonCommand.ExchangedSuMoney,
 				createExchangeCashPersonCommand.ExchangedSuMoney,
-				"无效的导入员工",
+				"无效的员工",
 			}
 			}
 			failureDataList = append(failureDataList, row)
 			failureDataList = append(failureDataList, row)
 			continue
 			continue
@@ -1484,7 +1484,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 			}
 			}
 			failureDataList = append(failureDataList, row)
 			failureDataList = append(failureDataList, row)
 			continue
 			continue
-		} else {
+		}
 		if len(peopleFound) != 0 {
 		if len(peopleFound) != 0 {
 			peopleFoundExchangedSuMoney := peopleFound[0].ExchangedSuMoney
 			peopleFoundExchangedSuMoney := peopleFound[0].ExchangedSuMoney
 			// 判断该员工兑换的素币是否超过本人持有的素币
 			// 判断该员工兑换的素币是否超过本人持有的素币
@@ -1501,7 +1501,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				}
 				}
 			}
 			}
 		}
 		}
-		}
+
 
 
 		if len(peopleFound) > 0 {  // 当前导入员工在素币兑换清单中，判断追加素币兑换或撤回素币兑换
 		if len(peopleFound) > 0 {  // 当前导入员工在素币兑换清单中，判断追加素币兑换或撤回素币兑换
 			// 获取当前员工已兑换素币
 			// 获取当前员工已兑换素币
@@ -1538,7 +1538,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				}
 				}
 
 
 				// 保存兑换素币清单更新
 				// 保存兑换素币清单更新
-				personUpdated, err := exchangeCashPersonListRepository.Save(peopleFound[0])
+				_, err := exchangeCashPersonListRepository.Save(peopleFound[0])
 				if err != nil {
 				if err != nil {
 					row := []interface{}{
 					row := []interface{}{
 						createExchangeCashPersonCommand.PersonName,
 						createExchangeCashPersonCommand.PersonName,
@@ -1671,7 +1671,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				if systemExchangedSuMoney == 0 {
 				if systemExchangedSuMoney == 0 {
 					newRate = 0
 					newRate = 0
 				} else {
 				} else {
-					newRate = (cashPoolFoundExchangedCash + personUpdated.ExchangedCash) / systemExchangedSuMoney
+					newRate = (cashPoolFoundExchangedCash - cashDecrement) / systemExchangedSuMoney
 				}
 				}
 
 
 				// 更新现金池命令
 				// 更新现金池命令
@@ -1748,7 +1748,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				}
 				}
 
 
 				// 保存兑换素币清单更新
 				// 保存兑换素币清单更新
-				personUpdated, err := exchangeCashPersonListRepository.Save(peopleFound[0])
+				_, err := exchangeCashPersonListRepository.Save(peopleFound[0])
 				if err != nil {
 				if err != nil {
 					row := []interface{}{
 					row := []interface{}{
 						createExchangeCashPersonCommand.PersonName,
 						createExchangeCashPersonCommand.PersonName,
@@ -1881,7 +1881,7 @@ func (cashPoolService *CashPoolService) ImportCreateExchangeCashPerson(createExc
 				if systemExchangedSuMoney == 0 {
 				if systemExchangedSuMoney == 0 {
 					newRate = 0
 					newRate = 0
 				} else {
 				} else {
-					newRate = (cashPoolFoundExchangedCash + personUpdated.ExchangedCash) / systemExchangedSuMoney
+					newRate = (cashPoolFoundExchangedCash + cashIncrement) / systemExchangedSuMoney
 				}
 				}
 
 
 				// 更新现金池命令
 				// 更新现金池命令
@@ -2345,13 +2345,6 @@ func (cashPoolService *CashPoolService) CreateExchangeCashPerson(createExchangeC
 	cashPoolFoundUnExchangeCash := cashPoolsFound[0].UnExchangeCash
 	cashPoolFoundUnExchangeCash := cashPoolsFound[0].UnExchangeCash
 	cashPoolFoundExchangedCash := cashPoolsFound[0].ExchangedCash
 	cashPoolFoundExchangedCash := cashPoolsFound[0].ExchangedCash
 
 
-	// 判断兑换活动的现金是否超过现金池未兑换现金
-	//if activityUpdated.ExchangedSuMoney * updateExchangeCashActivityCommand.ExchangeRate > cashPoolFoundUnExchangeCash {
-	//	return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "已超过投入现金池未兑换现金")
-	//}
-
-	// TODO
-
 	// 判断是否超过平台未兑换现金
 	// 判断是否超过平台未兑换现金
 	if activityUpdated.ExchangedSuMoney > activityFoundExchangedSuMoney {
 	if activityUpdated.ExchangedSuMoney > activityFoundExchangedSuMoney {
 		if (activityUpdated.ExchangedSuMoney - activityFoundExchangedSuMoney) * activityUpdated.Rate > cashPoolFoundUnExchangeCash {
 		if (activityUpdated.ExchangedSuMoney - activityFoundExchangedSuMoney) * activityUpdated.Rate > cashPoolFoundUnExchangeCash {
@@ -2359,7 +2352,6 @@ func (cashPoolService *CashPoolService) CreateExchangeCashPerson(createExchangeC
 		}
 		}
 	}
 	}
 
 
-
 	// 获取平台素币兑换情况
 	// 获取平台素币兑换情况
 	systemSuMoneyStatistics, err := employeeDao.CalculateSystemSuMoney(activityFound.CompanyId)
 	systemSuMoneyStatistics, err := employeeDao.CalculateSystemSuMoney(activityFound.CompanyId)
 	if err != nil {
 	if err != nil {