|
@@ -259,7 +259,7 @@ func DistributeClueSync(this *biservice.DistributeClueReq) (int, int) {
|
|
|
if DistributeLock.TryLock() {
|
|
|
defer DistributeLock.Unlock()
|
|
|
saleMap, count := map[string]map[string]interface{}{}, 0
|
|
|
- saleData := JyBiTidb.SelectBySql("select * from jy_salesperson_info where is_complete = 1 or is_complete = 0")
|
|
|
+ saleData := JyBiTidb.SelectBySql("select * from dwd_f_crm_personnel_management where resign = 0")
|
|
|
if saleData != nil && len(*saleData) > 0 {
|
|
|
for _, v := range *saleData {
|
|
|
name := common.ObjToString(v["name"])
|
|
@@ -267,7 +267,7 @@ func DistributeClueSync(this *biservice.DistributeClueReq) (int, int) {
|
|
|
}
|
|
|
}
|
|
|
for _, data := range this.Datas {
|
|
|
- seatNumber := common.ObjToString(saleMap[data.Name]["seatNumber"])
|
|
|
+ seatNumber := common.ObjToString(saleMap[data.Name]["seat_number"])
|
|
|
distributedCount := int(data.DistributedCount)
|
|
|
if distributedCount > 0 {
|
|
|
distributedArr := this.ClueIdList[count : count+distributedCount]
|