|
|
@@ -328,6 +328,48 @@ func (s *CustomerService) AssignCustomerRequest(ctx context.Context, req *model.
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ city := []string{}
|
|
|
+ cityData := s.DataScope["cust_city_id"]
|
|
|
+ if cityData != nil {
|
|
|
+ for _, i := range cityData.([]interface{}) {
|
|
|
+ city = append(city, i.(string))
|
|
|
+ }
|
|
|
+ }
|
|
|
+ fmt.Println(city)
|
|
|
+ cust := []*model.CustCustomer{}
|
|
|
+ noNeedApprovalCust := []*model.CustCustomer{}
|
|
|
+ noNeedApprovalCustId := []int64{}
|
|
|
+ for _, v := range data {
|
|
|
+ if service.StringSlicecontains(city, strconv.Itoa(v.CustCityId)) {
|
|
|
+ noNeedApprovalCust = append(noNeedApprovalCust, v)
|
|
|
+ noNeedApprovalCustId = append(noNeedApprovalCustId, int64(v.Id))
|
|
|
+ } else {
|
|
|
+ cust = append(cust, v)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(noNeedApprovalCustId) != 0 {
|
|
|
+ err = s.ChangeCustBelong(noNeedApprovalCustId, req.SalesId, req.SalesName)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ req.Receive = AllocaTion
|
|
|
+ err = s.BatchCreatebelong(data, req)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ err = s.CreateDynamics("领取客户", &model.AssignCustomerReq{
|
|
|
+ Ids: noNeedApprovalCustId,
|
|
|
+ SalesId: req.SalesId,
|
|
|
+ SalesName: req.SalesName,
|
|
|
+ Remark: "",
|
|
|
+ Receive: Receive,
|
|
|
+ }, noNeedApprovalCustId...)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
remark, err := json.Marshal(map[string]string{
|
|
|
"applyUserId": strconv.Itoa(s.GetCxtUserId()),
|
|
|
"applyUserName": s.GetCxtUserName(),
|
|
|
@@ -339,7 +381,7 @@ func (s *CustomerService) AssignCustomerRequest(ctx context.Context, req *model.
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- for _, u := range data {
|
|
|
+ for _, u := range cust {
|
|
|
bizCode := strconv.Itoa(u.Id) + ":" + strconv.Itoa(s.GetCxtUserId())
|
|
|
_, err = workflowSrv.StartProcessInstance(bizCode, "11", string(remark), &workflow.StartProcessInstanceRequest{
|
|
|
ProcessCode: &AssignCustomerRequestProcessCode,
|