|
@@ -31,10 +31,16 @@ func NewIgnoreActionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Igno
|
|
func (l *IgnoreActionLogic) IgnoreAction(req *types.IgnoreReq) (resp *types.Reply, err error) {
|
|
func (l *IgnoreActionLogic) IgnoreAction(req *types.IgnoreReq) (resp *types.Reply, err error) {
|
|
logx.Info(fmt.Sprintf("%+v", req))
|
|
logx.Info(fmt.Sprintf("%+v", req))
|
|
resp = &types.Reply{}
|
|
resp = &types.Reply{}
|
|
|
|
+ rid := ""
|
|
|
|
+ if req.Source == "2" {
|
|
|
|
+ rid = util.DecodeId(req.RelateId)
|
|
|
|
+ } else {
|
|
|
|
+ rid = req.RelateId
|
|
|
|
+ }
|
|
query := map[string]interface{}{
|
|
query := map[string]interface{}{
|
|
"position_id": req.PositionId,
|
|
"position_id": req.PositionId,
|
|
"itype": req.Source,
|
|
"itype": req.Source,
|
|
- "relate_id": util.DecodeId(req.RelateId),
|
|
|
|
|
|
+ "relate_id": rid,
|
|
}
|
|
}
|
|
info := T.CrmMysql.FindOne("connection_status", query, "id", "")
|
|
info := T.CrmMysql.FindOne("connection_status", query, "id", "")
|
|
if info != nil && len(*info) > 0 {
|
|
if info != nil && len(*info) > 0 {
|