|
@@ -564,10 +564,12 @@ func (e *EmPloyService) DistributePerson(in *types.EmployDistributeReq) bool {
|
|
|
}
|
|
|
}
|
|
|
// 修改 topnet_info is_timeout
|
|
|
+ log.Println("修改 topnet_info ", topEnt, topMap)
|
|
|
if topEnt > 0 && len(topMap) > 0 {
|
|
|
for k, _ := range topMap {
|
|
|
c := MC.CrmMysql.Count(entity.EMPLOY_INFO, map[string]interface{}{"source_id": k, "is_timeout": 1, "ent_id": topEnt})
|
|
|
if c <= 0 {
|
|
|
+ ur
|
|
|
MC.CrmMysql.ExecBySql("UPDATE crm.topnet_info SET is_timeout = 1 WHERE info_id = ?", k)
|
|
|
}
|
|
|
}
|